diff --git a/Src/Dlhis.ScheduledTask/Jobs/SyncFaceJob.cs b/Src/Dlhis.ScheduledTask/Jobs/SyncFaceJob.cs index 73af6cd2..d63327ca 100644 --- a/Src/Dlhis.ScheduledTask/Jobs/SyncFaceJob.cs +++ b/Src/Dlhis.ScheduledTask/Jobs/SyncFaceJob.cs @@ -1,45 +1,45 @@ -using Dlhis.Entity.Basic.Entity; -using Dlhis.ScheduledTask.Attributes; -using Dlhis.ScheduledTask.Common.Services; - -namespace Dlhis.ScheduledTask.Jobs; - -[RecurringJob(nameof(SyncFaceJob), "0 0/15 * * * ?", Name = "face数据同步sap")] -public class SyncFaceJob : BaseJob -{ - private readonly IJinkoJipService _jinkoJipService; - - /// - public SyncFaceJob(IServiceProvider serviceProvider, IJinkoJipService jinkoJipService) : base(serviceProvider) - { - _jinkoJipService = jinkoJipService; - } - - /// - protected override async Task RunAsync(IServiceProvider serviceProvider) - { - var faceDbContext = DbContext.ChangeDb("face"); - - var userFaces = await faceDbContext.Queryable() - .Where(x => x.UserCode.StartsWith("WB") == false && x.UserCode.StartsWith("LS") == false && x.UserCode.StartsWith("EXT") == false) - .Where(x => x.IsSync == false) - .ToPageListAsync(1, 1000); - - foreach (var data in userFaces) - { - try - { - var response = await _jinkoJipService.SyncFaceToSapAsync(data.UserCode, data.Face); - if (response.OLX == "S") - { - data.IsSync = true; - await faceDbContext.UpdateAsync(data); - } - } - catch (Exception e) - { - Logger.LogError(e, "上传工号{code}的face数据失败:{message}", data.UserCode, e.Message); - } - } - } -} \ No newline at end of file +// using Dlhis.Entity.Basic.Entity; +// using Dlhis.ScheduledTask.Attributes; +// using Dlhis.ScheduledTask.Common.Services; +// +// namespace Dlhis.ScheduledTask.Jobs; +// +// [RecurringJob(nameof(SyncFaceJob), "0 0/15 * * * ?", Name = "face数据同步sap")] +// public class SyncFaceJob : BaseJob +// { +// private readonly IJinkoJipService _jinkoJipService; +// +// /// +// public SyncFaceJob(IServiceProvider serviceProvider, IJinkoJipService jinkoJipService) : base(serviceProvider) +// { +// _jinkoJipService = jinkoJipService; +// } +// +// /// +// protected override async Task RunAsync(IServiceProvider serviceProvider) +// { +// var faceDbContext = DbContext.ChangeDb("face"); +// +// var userFaces = await faceDbContext.Queryable() +// .Where(x => x.UserCode.StartsWith("WB") == false && x.UserCode.StartsWith("LS") == false && x.UserCode.StartsWith("EXT") == false) +// .Where(x => x.IsSync == false) +// .ToPageListAsync(1, 1000); +// +// foreach (var data in userFaces) +// { +// try +// { +// var response = await _jinkoJipService.SyncFaceToSapAsync(data.UserCode, data.Face); +// if (response.OLX == "S") +// { +// data.IsSync = true; +// await faceDbContext.UpdateAsync(data); +// } +// } +// catch (Exception e) +// { +// Logger.LogError(e, "上传工号{code}的face数据失败:{message}", data.UserCode, e.Message); +// } +// } +// } +// } \ No newline at end of file