fix 数据处理
This commit is contained in:
@@ -32,11 +32,11 @@ 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)
|
// .Select(x => x.UserCode)
|
||||||
.Distinct()
|
// .Distinct()
|
||||||
.ToListAsync();
|
// .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))
|
||||||
|
|||||||
Reference in New Issue
Block a user