初始化

tangxu

2024-01-09 ddc2780231ea76be74fadb7486401a3d0d17b101

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
namespace Yw.Server
{
    /// <summary>
    /// 设备评价任务辅助类
    /// </summary>
    public class EquipmentEvaluateJobHelper
    {
 
        private IScheduler _sched;//调度器
 
        /// <summary>
        /// 绑定
        /// </summary>
        public Model.HealthMultiEvaluationModelBinding Binding { get; set; }
 
        /// <summary>
        /// 开始任务
        /// </summary>
        public async Task StartJob(Model.HealthMultiEvaluationModelBinding binding)
        {
            if (_sched != null)
            {
                return;
            }
 
            this.Binding = binding;
            var jobName = EquipmentEvaluateJobNameHelper.GetJobName(binding);
            var jobGroupName = EquipmentEvaluateJobNameHelper.GetJobGroupName(binding);
            var triggerName = EquipmentEvaluateJobNameHelper.GetTriggerName(binding);
 
            // 1.创建scheduler的引用
            var fac = new Quartz.Impl.StdSchedulerFactory();
            _sched = await fac.GetScheduler();
 
            //2.启动 scheduler
            await _sched.Start();
 
            //3.创建任务
            var job = JobBuilder.Create<EquipmentEvaluateJob>()
             .WithIdentity(jobName, jobGroupName)
             .Build();
            job.JobDataMap.Put(EquipmentEvaluateJob.Instance, binding);
 
            //4.创建Trigger
            ITrigger trigger = null;
            if (binding.CronType == Health.eCronType.Real)
            {
                trigger = TriggerBuilder.Create()
               .WithIdentity(triggerName, jobGroupName)
               .WithSimpleSchedule(x => x.WithIntervalInSeconds(int.Parse(binding.CronParas))
               .RepeatForever().WithMisfireHandlingInstructionNextWithRemainingCount())
               .Build();
            }
            else
            {
                trigger = TriggerBuilder.Create()
                .WithIdentity(triggerName, jobGroupName)
                .WithCronSchedule(binding.CronParas)
                .Build();
            }
 
            //5.加入调度管理器
            await _sched.ScheduleJob(job, trigger);
        }
 
        /// <summary>
        /// 取消任务
        /// </summary>
        public async Task CancelJob()
        {
            if (_sched == null)
                return;
            var jobGroupName = EquipmentEvaluateJobNameHelper.GetJobGroupName(this.Binding);
            var triggerName = EquipmentEvaluateJobNameHelper.GetTriggerName(this.Binding);
            var triggerKey = new TriggerKey(triggerName, jobGroupName);
            if (await _sched.CheckExists(triggerKey))
            {
                await _sched.UnscheduleJob(triggerKey);
            }
        }
 
 
    }
}