From fb74503bd6197119fbe234c72dbd292fda5eb0ac Mon Sep 17 00:00:00 2001 From: liguoyang Date: Fri, 29 Mar 2024 11:03:25 +0800 Subject: [PATCH] =?UTF-8?q?fix=20=E9=98=9F=E5=88=97=E5=A4=84=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- Src/Dlhis.ScheduledTask/Jobs/SyncOrganizationJob.cs | 2 +- Src/Dlhis.ScheduledTask/Jobs/SyncOriginCardInfoJob.cs | 2 +- Src/Dlhis.ScheduledTask/Jobs/SyncPersonJob.cs | 2 +- Src/Dlhis.ScheduledTask/Jobs/SyncPositionJob.cs | 2 +- Src/Dlhis.ScheduledTask/Packs/JobPack.cs | 2 +- 5 files changed, 5 insertions(+), 5 deletions(-) diff --git a/Src/Dlhis.ScheduledTask/Jobs/SyncOrganizationJob.cs b/Src/Dlhis.ScheduledTask/Jobs/SyncOrganizationJob.cs index f39cc83f..d30c084a 100644 --- a/Src/Dlhis.ScheduledTask/Jobs/SyncOrganizationJob.cs +++ b/Src/Dlhis.ScheduledTask/Jobs/SyncOrganizationJob.cs @@ -10,7 +10,7 @@ namespace Dlhis.ScheduledTask.Jobs; /// /// SAP组织架构数据同步 /// -[RecurringJob(nameof(SyncOrganizationJob), "0 0 0 * * ?", Name = "SAP组织架构数据同步", Queue = "SAP")] +[RecurringJob(nameof(SyncOrganizationJob), "0 0 0 * * ?", Name = "SAP组织架构数据同步", Queue = "sap")] public class SyncOrganizationJob : BaseJob { private readonly IJinkoSapService _jinkoSapService; diff --git a/Src/Dlhis.ScheduledTask/Jobs/SyncOriginCardInfoJob.cs b/Src/Dlhis.ScheduledTask/Jobs/SyncOriginCardInfoJob.cs index e3c9b6d9..000818dd 100644 --- a/Src/Dlhis.ScheduledTask/Jobs/SyncOriginCardInfoJob.cs +++ b/Src/Dlhis.ScheduledTask/Jobs/SyncOriginCardInfoJob.cs @@ -14,7 +14,7 @@ namespace Dlhis.ScheduledTask.Jobs; /// /// 上传考勤记录 /// -[RecurringJob(nameof(SyncOriginCardInfoJob), "0/20 * * * * ?", Name = "上传考勤记录", Queue = "SAP")] +[RecurringJob(nameof(SyncOriginCardInfoJob), "0/20 * * * * ?", Name = "上传考勤记录", Queue = "sap")] public class SyncOriginCardInfoJob : BaseJob { private readonly IJinkoJIPService _jinkoJIPService; diff --git a/Src/Dlhis.ScheduledTask/Jobs/SyncPersonJob.cs b/Src/Dlhis.ScheduledTask/Jobs/SyncPersonJob.cs index 981da2f5..7fee28a8 100644 --- a/Src/Dlhis.ScheduledTask/Jobs/SyncPersonJob.cs +++ b/Src/Dlhis.ScheduledTask/Jobs/SyncPersonJob.cs @@ -17,7 +17,7 @@ namespace Dlhis.ScheduledTask.Jobs; /// /// SAP人员信息同步 /// -[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 { private readonly IJinkoSapService _jinkoSapService; diff --git a/Src/Dlhis.ScheduledTask/Jobs/SyncPositionJob.cs b/Src/Dlhis.ScheduledTask/Jobs/SyncPositionJob.cs index 173b3743..12028534 100644 --- a/Src/Dlhis.ScheduledTask/Jobs/SyncPositionJob.cs +++ b/Src/Dlhis.ScheduledTask/Jobs/SyncPositionJob.cs @@ -9,7 +9,7 @@ namespace Dlhis.ScheduledTask.Jobs; /// /// SAP岗位信息同步 /// -[RecurringJob(nameof(SyncPositionJob), "0 0 0 * * ?", Name = "SAP岗位信息同步", Queue = "SAP")] +[RecurringJob(nameof(SyncPositionJob), "0 0 0 * * ?", Name = "SAP岗位信息同步", Queue = "sap")] public class SyncPositionJob : BaseJob { private readonly IJinkoSapService _jinkoSapService; diff --git a/Src/Dlhis.ScheduledTask/Packs/JobPack.cs b/Src/Dlhis.ScheduledTask/Packs/JobPack.cs index 40e77023..342e24f5 100644 --- a/Src/Dlhis.ScheduledTask/Packs/JobPack.cs +++ b/Src/Dlhis.ScheduledTask/Packs/JobPack.cs @@ -40,7 +40,7 @@ public class JobPack : BaseAppPack var todo = job.GetMethod(nameof(BaseJob.TodoAsync)); 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 { TimeZone = TimeZoneInfo.Local