fix 补充日志

This commit is contained in:
2025-12-09 17:38:14 +08:00
parent 6ee14f15d0
commit 61bd8e8bb0

View File

@@ -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<string, decimal>(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<UserBalanceUploadRecordEntity>()