yuangb/jinko.yikatong
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix .

Browse Source
This commit is contained in:
liguoyang
2025-12-09 17:44:48 +08:00
parent 61bd8e8bb0
commit 80d9701540
1 changed files with 16 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
Src/Dlhis.ScheduledTask/Jobs/CostUploadJob.cs
View File

@@ -42,7 +42,7 @@ public class CostUploadJob : BaseJob
.Distinct() .Distinct()
.ToListAsync(); .ToListAsync();
Logger.LogInformation("CostUploadJob消费上传人员:{count}", userCodeAll.Count); Logger.LogInformation("CostUploadJob消费上传人员:{count},统计区间为{s}{e}", userCodeAll.Count, s.ToString("yyyy-MM-dd"), endDayOfMonth.ToString("yyyy-MM-dd"));
foreach (var userCodes in userCodeAll.Chunk(100)) foreach (var userCodes in userCodeAll.Chunk(100))
{ {
@@ -50,20 +50,25 @@ public class CostUploadJob : BaseJob
foreach (var userCode in userCodes) foreach (var userCode in userCodes)
{ {
var balance = await DbContext.Queryable<BalanceRecordEntity>() var balance = await DbContext.Queryable<BalanceRecordEntity>()
.Where(x => x.UserCode == userCode) .Where(x => x.UserCode == userCode)
.Where(x => x.Status == BalanceRecordStatusEnumType.Valid) .Where(x => x.Status == BalanceRecordStatusEnumType.Valid)
.Where(x => x.Type == BalanceRecordTypeEnumType.Out) .Where(x => x.Type == BalanceRecordTypeEnumType.Out)
.Where(x => x.CostDate >= s && x.CostDate < e) .Where(x => x.CostDate >= s && x.CostDate < e)
.Where(x => !BalanceRecordSourceConstants.IgnoreSources.Contains(x.Source)) .Where(x => !BalanceRecordSourceConstants.IgnoreSources.Contains(x.Source))
.SumAsync(x => x.Amount); .SumAsync(x => x.Amount);
if (balance == 0) if (balance != 0)
{ {
continue; dict.Add(userCode, Math.Abs(balance));
} }
dict.Add(userCode, Math.Abs(balance));
} }
if (!dict.Any())
{
Logger.LogInformation("CostUploadJob统计人员:{count}", dict.Count);
continue;
}
var request = new UploadCostRequest var request = new UploadCostRequest
{ {
Data = dict.Select(x => new UploadCostItemRequest Data = dict.Select(x => new UploadCostItemRequest