From 86c6283f818995b6f9ddf78c0f66b6438276e5cd Mon Sep 17 00:00:00 2001 From: liguoyang Date: Wed, 10 Dec 2025 12:04:51 +0800 Subject: [PATCH] =?UTF-8?q?fix=20=E8=A1=A5=E5=85=85=E5=A4=84=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- Src/Dlhis.ScheduledTask/Jobs/CostUploadJob.cs | 13 ++++++++----- 1 file changed, 8 insertions(+), 5 deletions(-) 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))