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

fix 队列处理

Browse Source
This commit is contained in:
liguoyang
2024-03-29 11:03:25 +08:00
parent b7afd65440
commit fb74503bd6
5 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
Src/Dlhis.ScheduledTask/Jobs/SyncOrganizationJob.cs
View File

@@ -10,7 +10,7 @@ namespace Dlhis.ScheduledTask.Jobs;
/// <summary> /// <summary>
/// SAP组织架构数据同步 /// SAP组织架构数据同步
/// </summary> /// </summary>
[RecurringJob(nameof(SyncOrganizationJob), "0 0 0 * * ?", Name = "SAP组织架构数据同步", Queue = "SAP")] [RecurringJob(nameof(SyncOrganizationJob), "0 0 0 * * ?", Name = "SAP组织架构数据同步", Queue = "sap")]
public class SyncOrganizationJob : BaseJob public class SyncOrganizationJob : BaseJob
{ {
private readonly IJinkoSapService _jinkoSapService; private readonly IJinkoSapService _jinkoSapService;

2
Src/Dlhis.ScheduledTask/Jobs/SyncOriginCardInfoJob.cs
View File

@@ -14,7 +14,7 @@ namespace Dlhis.ScheduledTask.Jobs;
/// <summary> /// <summary>
/// 上传考勤记录 /// 上传考勤记录
/// </summary> /// </summary>
[RecurringJob(nameof(SyncOriginCardInfoJob), "0/20 * * * * ?", Name = "上传考勤记录", Queue = "SAP")] [RecurringJob(nameof(SyncOriginCardInfoJob), "0/20 * * * * ?", Name = "上传考勤记录", Queue = "sap")]
public class SyncOriginCardInfoJob : BaseJob public class SyncOriginCardInfoJob : BaseJob
{ {
private readonly IJinkoJIPService _jinkoJIPService; private readonly IJinkoJIPService _jinkoJIPService;

2
Src/Dlhis.ScheduledTask/Jobs/SyncPersonJob.cs
View File

@@ -17,7 +17,7 @@ namespace Dlhis.ScheduledTask.Jobs;
/// <summary> /// <summary>
/// SAP人员信息同步 /// SAP人员信息同步
/// </summary> /// </summary>
[RecurringJob(nameof(SyncPersonJob), "0 0 1-4 * * ?", Name = "SAP人员信息同步", Queue = "SAP")] [RecurringJob(nameof(SyncPersonJob), "0 0 1-4 * * ?", Name = "SAP人员信息同步", Queue = "sap")]
public class SyncPersonJob : BaseJob public class SyncPersonJob : BaseJob
{ {
private readonly IJinkoSapService _jinkoSapService; private readonly IJinkoSapService _jinkoSapService;

2
Src/Dlhis.ScheduledTask/Jobs/SyncPositionJob.cs
View File

@@ -9,7 +9,7 @@ namespace Dlhis.ScheduledTask.Jobs;
/// <summary> /// <summary>
/// SAP岗位信息同步 /// SAP岗位信息同步
/// </summary> /// </summary>
[RecurringJob(nameof(SyncPositionJob), "0 0 0 * * ?", Name = "SAP岗位信息同步", Queue = "SAP")] [RecurringJob(nameof(SyncPositionJob), "0 0 0 * * ?", Name = "SAP岗位信息同步", Queue = "sap")]
public class SyncPositionJob : BaseJob public class SyncPositionJob : BaseJob
{ {
private readonly IJinkoSapService _jinkoSapService; private readonly IJinkoSapService _jinkoSapService;

2
Src/Dlhis.ScheduledTask/Packs/JobPack.cs
View File

@@ -40,7 +40,7 @@ public class JobPack : BaseAppPack
var todo = job.GetMethod(nameof(BaseJob.TodoAsync)); var todo = job.GetMethod(nameof(BaseJob.TodoAsync));
var todoExp = Expression.Call(parameterExpression, todo); var todoExp = Expression.Call(parameterExpression, todo);
var nJob = (Job)setJob.Invoke(null, new object[] { Expression.Lambda(todoExp), job, "default" }); var nJob = (Job)setJob.Invoke(null, new object[] { Expression.Lambda(todoExp), job, recurringSetting.Queue });
m.Value.AddOrUpdate(recurringSetting.UniqueJobKey, nJob, recurringSetting.Cron, new RecurringJobOptions m.Value.AddOrUpdate(recurringSetting.UniqueJobKey, nJob, recurringSetting.Cron, new RecurringJobOptions
{ {
TimeZone = TimeZoneInfo.Local TimeZone = TimeZoneInfo.Local