yuangb/jinko.yikatong
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix 停用face上传

Browse Source
This commit is contained in:
liguoyang
2024-11-18 13:31:37 +08:00
parent 93764dd9a3
commit fdd70ec871
1 changed files with 45 additions and 45 deletions
Download Patch File Download Diff File Expand all files Collapse all files

90
Src/Dlhis.ScheduledTask/Jobs/SyncFaceJob.cs
View File

@@ -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;
/// <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);
}
}
}
}
// 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);
// }
// }
// }
// }