diff --git a/Src/Dlhis.ScheduledTask/Jobs/CostUploadJob.cs b/Src/Dlhis.ScheduledTask/Jobs/CostUploadJob.cs index c88f1ad0..60f91015 100644 --- a/Src/Dlhis.ScheduledTask/Jobs/CostUploadJob.cs +++ b/Src/Dlhis.ScheduledTask/Jobs/CostUploadJob.cs @@ -32,11 +32,14 @@ public class CostUploadJob : BaseJob var endDayOfMonth = e.AddDays(-1); //从余额找人 - //var userCodeAll = await DbContext.Queryable() - // .Select(x => x.UserCode) - // .Distinct() - // .ToListAsync(); - var userCodeAll = await DbContext.Queryable().Where(x => x.Cost < 0).Select(x => x.UserCode).ToListAsync(); + var userCodeAll = await DbContext.Queryable() + .Where(x => SqlFunc.Subqueryable() + .Where(p => p.Year == year && p.Month == month) + .Where(p => p.UserCode == x.UserCode).NotAny()) + .Select(x => x.UserCode) + .Distinct() + .ToListAsync(); + //var userCodeAll = await DbContext.Queryable().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")); foreach (var userCodes in userCodeAll.Chunk(100))