数据对接

ningshuxia

2022-11-22 4efe844d9bcc03435cbbeb1aedbda5bf6ebf5912

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
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using IStation.Model;
using IStation.Untity;
 
namespace IStation.DataDockingSocket
{
    public class HandleHelper : IDataDockingSocket.IHandleHelper
    {
        static  IMonitorDataDockingSession _session;
        public static IMonitorDataDockingSession GetLastSession()
        {//关机用的是定时器, 定时器里面需要获取最近的一次链接
            return _session;
        }
 
 
        /// <summary>
        /// 处理注册码
        /// </summary>
        public void HandleRegisterCode(IMonitorDataDockingSession session)
        {
            if (session == null)
                return;
            if (!session.IsConnected)
                return;
 
            if (SessionHelper.Cache != null)
            {
                if (SessionHelper.Cache != session)
                {
                    if (SessionHelper.Cache.IsConnected)
                    {
                        SessionHelper.Cache.Close($"{session.SessionName} 中，产生新的会话！");
                    }
                }
            }
 
            SessionHelper.Cache = session;
 
 
            foreach (var item in MonitorMsgHelper.GetInstructionQuerys())
            {
                SendInstructionJobHelper.StartJob(session, item);
                if (item.SpaceTime >= 1)
                    Thread.Sleep(item.SpaceTime * 1000);
            }
 
            SendControlJobHelper.StartJob(session);
        }
 
        /// <summary>
        /// 处理心跳包
        /// </summary>
        public void HandleHeartbeat(IMonitorDataDockingSession session)
        {
            _session = session;
        }
 
        /// <summary>
        /// 处理数据
        /// </summary>
        public void HandleData
            (
                IMonitorDataDockingSession session,
                byte[] byteMessage,
                List<DataDockingConfigure.Mapper> mappers,
                Action<List<MonitorDataDockingReceiveRecord>> onReceive
            )
        {
            if (session == null)
                return;
            if (!session.IsConnected)
                return;
            if (byteMessage == null || byteMessage.Length < 4)
            {
                return;
            }
            NtLogHelper.Info("开始处理数据...");
            _session = session;
            if (MonitorMsgHelper.IsNeedHandle(byteMessage))
            {
                NtLogHelper.Info("MonitorMsgHelper...");
                //监控指令
                var receList = MonitorMsgHelper.HandleReceive(byteMessage);
                if (receList == null || receList.Count == 0)
                    return;
 
                NtLogHelper.Info("MonitorMsgHelper Over");
                NtLogHelper.Src(byteMessage); 
 
                onReceive(receList);
 
                return;//成功就返回掉
            }
            //不要加else
            if (ShutDownMsgHelper.IsNeedHandle(byteMessage))
            {
                NtLogHelper.Info("ShutDownMsgHelper...");
                if (ShutDownMsgHelper.HandleReceive(session, byteMessage))
                {
                    NtLogHelper.Info("ShutDownMsgHelper Over");
                    return;
                }
            }
            //不要加else
            if (StartUpMsgHelper.IsNeedHandle(byteMessage))
            {
                NtLogHelper.Info("StartUpMsgHelper... ");
                if (StartUpMsgHelper.HandleReceive(session, byteMessage))
                {
                    NtLogHelper.Info("StartUpMsgHelper Over");
                    return;
                }
            }
            NtLogHelper.Info("数据处理结束...");
 
        }
 
        public bool Valid(byte[] bytes)
        {
            return false;
        }
 
    } 
}