新增一个水质仪对接

lixiaojun

2024-11-19 a5b6334ae09f2be1a5c073169458b55df68b0b2e

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
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
namespace IStation.DataDockingSocket
{
    /// <summary>
    /// Modbus辅助类 
    /// </summary>
    public class SendInstructionJobHelper
    {
        private static IScheduler _sched;//调度器
 
        /// <summary>
        /// 开始任务
        /// </summary>
        public static async void StartJob(Yw.Model.IMonitorDataDockingSession session, InstructionItem item)
        {
            if (session == null)
                return;
            if (!session.IsConnected)
                return;
            if (item == null)
                return;
            if (string.IsNullOrEmpty(item.Instruction))
                return;
            if (item.RuleItems == null || item.RuleItems.Count < 1)
                return;
 
            LogHelper.Info($"{session.SessionName} 开始处理发送指令任务，指令:{item.Instruction} !");
 
            var jobName = SendInstructionJobNameHelper.GetJobName(session, item.Instruction);
            var jobGroupName = SendInstructionJobNameHelper.GetJobGroupName(session, item.Instruction);
            var triggerName = SendInstructionJobNameHelper.GetTriggerName(session, item.Instruction);
 
            //判断是否存在
            if (_sched != null)
            {
                var triggerKey = new TriggerKey(triggerName, jobGroupName);
                if (await _sched.CheckExists(triggerKey))
                {
                    LogHelper.Info($"{session.SessionName} 中，指令：{item.Instruction} 的主动请求数据任务已经开启，无需重复开启！");
                    return;
                }
            }
 
            //判断是否开启调取器
            if (_sched == null)
            {
                // 1.创建scheduler的引用
                var fac = new Quartz.Impl.StdSchedulerFactory();
                _sched = await fac.GetScheduler();
 
                //2.启动 scheduler
                await _sched.Start();
            }
 
            //3.创建任务
            var job = JobBuilder.Create<SendInstructionJob>()
             .WithIdentity(jobName, jobGroupName)
             .Build();
            job.JobDataMap.Put(SendInstructionJob.Session, session);
            job.JobDataMap.Put(SendInstructionJob.Instruction, BitTransfer.FromString(item.Instruction));
 
            //4.创建Trigger
            var trigger = TriggerBuilder.Create()
            .WithIdentity(triggerName, jobGroupName)
            .WithSimpleSchedule(x => x.WithIntervalInSeconds(item.Frequency).RepeatForever()
            .WithMisfireHandlingInstructionNextWithRemainingCount())
            .Build();
 
            //5.加入调度管理器
            await _sched.ScheduleJob(job, trigger);
            session.SessionClosedEvent += () => CancelJob(session, item.Instruction);
            LogHelper.Info($"{session.SessionName} 中，指令:{item.Instruction}  的主动请求数据线程开启成功！");
        }
 
        /// <summary>
        /// 取消任务
        /// </summary>
        private static async void CancelJob(Yw.Model.IMonitorDataDockingSession session, string instruction)
        {
            if (_sched == null)
                return;
            LogHelper.Info($"{session.SessionName}  正打算终止主动请求数据任务");
            var triggerName = SendInstructionJobNameHelper.GetTriggerName(session, instruction);
            var jobGroupName = SendInstructionJobNameHelper.GetJobGroupName(session, instruction);
            var triggerKey = new TriggerKey(triggerName, jobGroupName);
            if (await _sched.CheckExists(triggerKey))
            {
                await _sched.UnscheduleJob(triggerKey);
                LogHelper.Info($"{session.SessionName},指令:{instruction}  主动请求数据任务终止成功");
            }
            else
            {
                LogHelper.Info($"{session.SessionName},指令:{instruction}  主动请求数据任务不存在");
            }
        }
 
 
 
 
    }
}