From 61bd8e8bb0b2ba5b69326466c807cf3c9a9c5886 Mon Sep 17 00:00:00 2001 From: liguoyang Date: Tue, 9 Dec 2025 17:38:14 +0800 Subject: [PATCH] =?UTF-8?q?fix=20=E8=A1=A5=E5=85=85=E6=97=A5=E5=BF=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- Src/Dlhis.ScheduledTask/Jobs/CostUploadJob.cs | 15 ++++++++++----- 1 file changed, 10 insertions(+), 5 deletions(-) diff --git a/Src/Dlhis.ScheduledTask/Jobs/CostUploadJob.cs b/Src/Dlhis.ScheduledTask/Jobs/CostUploadJob.cs index 9dcf7ff5..a5c0c884 100644 --- a/Src/Dlhis.ScheduledTask/Jobs/CostUploadJob.cs +++ b/Src/Dlhis.ScheduledTask/Jobs/CostUploadJob.cs @@ -42,6 +42,8 @@ public class CostUploadJob : BaseJob .Distinct() .ToListAsync(); + Logger.LogInformation("CostUploadJob消费上传人员:{count}", userCodeAll.Count); + foreach (var userCodes in userCodeAll.Chunk(100)) { var dict = new Dictionary(userCodes.Length); @@ -62,8 +64,7 @@ public class CostUploadJob : BaseJob dict.Add(userCode, Math.Abs(balance)); } - - var response = await jipApi.UploadCostAsync(new UploadCostRequest + var request = new UploadCostRequest { Data = dict.Select(x => new UploadCostItemRequest { @@ -73,10 +74,14 @@ public class CostUploadJob : BaseJob Code = "2086" }).ToList() - }); - - + }; + var response = await jipApi.UploadCostAsync(request); var handleData = response.Data.Where(x => x.Success == "S").ToList(); + Logger.LogInformation("CostUploadJob消费上传成功人员:{count}", handleData.Count); + if (!handleData.Any()) + { + continue; + } var workCodes = handleData.Select(x => x.WorkCode).ToList(); var records = await DbContext.Queryable()