45 lines
1.6 KiB
C#
45 lines
1.6 KiB
C#
// 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;
|
|
//
|
|
// /// <inheritdoc />
|
|
// public SyncFaceJob(IServiceProvider serviceProvider, IJinkoJipService jinkoJipService) : base(serviceProvider)
|
|
// {
|
|
// _jinkoJipService = jinkoJipService;
|
|
// }
|
|
//
|
|
// /// <inheritdoc />
|
|
// protected override async Task RunAsync(IServiceProvider serviceProvider)
|
|
// {
|
|
// var faceDbContext = DbContext.ChangeDb("face");
|
|
//
|
|
// var userFaces = await faceDbContext.Queryable<GainfoFaceEntity>()
|
|
// .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);
|
|
// }
|
|
// }
|
|
// }
|
|
// } |