fix 补充处理

This commit is contained in:
2025-12-10 12:04:51 +08:00
parent 5f4704467b
commit 86c6283f81

View File

@@ -32,11 +32,14 @@ public class CostUploadJob : BaseJob
var endDayOfMonth = e.AddDays(-1); var endDayOfMonth = e.AddDays(-1);
//从余额找人 //从余额找人
//var userCodeAll = await DbContext.Queryable<UserBalanceEntity>() var userCodeAll = await DbContext.Queryable<UserBalanceEntity>()
// .Select(x => x.UserCode) .Where(x => SqlFunc.Subqueryable<UserBalanceUploadRecordEntity>()
// .Distinct() .Where(p => p.Year == year && p.Month == month)
// .ToListAsync(); .Where(p => p.UserCode == x.UserCode).NotAny())
var userCodeAll = await DbContext.Queryable<UserBalanceUploadRecordEntity>().Where(x => x.Cost < 0).Select(x => x.UserCode).ToListAsync(); .Select(x => x.UserCode)
.Distinct()
.ToListAsync();
//var userCodeAll = await DbContext.Queryable<UserBalanceUploadRecordEntity>().Where(x => x.Cost < 0).Select(x => x.UserCode).ToListAsync();
Logger.LogInformation("CostUploadJob消费上传人员:{count},统计区间为{s}{e}", userCodeAll.Count, s.ToString("yyyy-MM-dd"), endDayOfMonth.ToString("yyyy-MM-dd")); 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))