From 500a972b70462af345a78717e3abc06670ffb408 Mon Sep 17 00:00:00 2001 From: liguoyang Date: Sat, 9 Mar 2024 18:39:43 +0800 Subject: [PATCH] fix job --- .../SyncSapInfo/Job/SyncPersonJob.cs | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/Src/Dlhis.ScheduledTask/SyncSapInfo/Job/SyncPersonJob.cs b/Src/Dlhis.ScheduledTask/SyncSapInfo/Job/SyncPersonJob.cs index bd75db28..ff44ff33 100644 --- a/Src/Dlhis.ScheduledTask/SyncSapInfo/Job/SyncPersonJob.cs +++ b/Src/Dlhis.ScheduledTask/SyncSapInfo/Job/SyncPersonJob.cs @@ -67,16 +67,16 @@ public class SyncPersonJob var workCodes = persons.Select(x => x.ZWORKCODE).ToList(); var chunks = workCodes.Chunk(4000).ToList(); - await Scoped.Temp.Value.Create(async sp => + var dtoResult = await _devicePermissionApi.GetPermissionUsersInfoAsync(); + var dto = dtoResult.Data; + + Scoped.Temp.Value.Create(sp => { var dbContext = sp.GetService(); foreach (var searchCodes in chunks) { _logger.LogInformation("SAP分批处理Chunk数量:{count}", searchCodes.Count()); - var dtoResult = await _devicePermissionApi.GetPermissionUsersInfoAsync(); - var dto = dtoResult.Data; - var existsWorkCodes = dbContext.Queryable() .Where(x => searchCodes.Contains(x.ename)) .Select(x => x.ename) @@ -125,13 +125,13 @@ public class SyncPersonJob } } - var rResult = await _devicePermissionApi.RePermissionUsersInfoAsync(dto); - var r = rResult.Data; - - _logger.LogInformation("生成下发任务数量:{count}", r); } }); + var rResult = await _devicePermissionApi.RePermissionUsersInfoAsync(dto); + var r = rResult.Data; + _logger.LogInformation("生成下发任务数量:{count}", r); + return 0; }