Browse Source

feat(tasks): 只传入触发次数的初始数据.

pull/515/head
cKey 4 years ago
parent
commit
1e0d5cba9f
  1. 1
      aspnet-core/modules/task-management/LINGYUN.Abp.BackgroundTasks.Quartz/LINGYUN/Abp/BackgroundTasks/Quartz/QuartzJobExecutorProvider.cs
  2. 4
      aspnet-core/modules/task-management/LINGYUN.Abp.BackgroundTasks.Quartz/LINGYUN/Abp/BackgroundTasks/Quartz/QuartzJobListener.cs

1
aspnet-core/modules/task-management/LINGYUN.Abp.BackgroundTasks.Quartz/LINGYUN/Abp/BackgroundTasks/Quartz/QuartzJobExecutorProvider.cs

@ -55,7 +55,6 @@ public class QuartzJobExecutorProvider : IQuartzJobExecutorProvider, ISingletonD
jobBuilder.UsingJobData(nameof(JobInfo.Group), job.Group);
// 计算增量需要
jobBuilder.UsingJobData(nameof(JobInfo.TriggerCount), job.TriggerCount);
jobBuilder.UsingJobData(nameof(JobInfo.MaxCount), job.MaxCount);
// 独占任务需要
jobBuilder.UsingJobData(nameof(JobInfo.LockTimeOut), job.LockTimeOut);
// 传递的作业参数

4
aspnet-core/modules/task-management/LINGYUN.Abp.BackgroundTasks.Quartz/LINGYUN/Abp/BackgroundTasks/Quartz/QuartzJobListener.cs

@ -61,10 +61,6 @@ public class QuartzJobListener : JobListenerSupport, ISingletonDependency
{
context.Put(nameof(JobInfo.TriggerCount), triggerCount + simpleTrigger.TimesTriggered);
}
if (context.MergedJobDataMap.TryGetValue(nameof(JobInfo.MaxCount), out var maxCount))
{
context.Put(nameof(JobInfo.MaxCount), maxCount);
}
}
using var scope = ServiceScopeFactory.CreateScope();

Loading…
Cancel
Save