修改 南通对接程序

ningshuxia

2022-10-28 0a1f644804e884ed2d612b78a916e59a6d320011

 Socket/IStation.DataDockingSocket4NT/MsgHandle/HandleHelper.cs

@@ -7,7 +7,7 @@
using IStation.Model;
using IStation.Untity;

namespace IStation.DataDockingSocket.MsgHandle
namespace IStation.DataDockingSocket
{
    public class HandleHelper : IDataDockingSocket.IHandleHelper
    {
@@ -79,19 +79,18 @@
            {
                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.Src(byteMessage);

                //  NtLogHelper.Debug(src_list);
                //NtLogHelper.Info($"解析数据数量:{receList.Count}\n\r" +
                //    $"{JsonHelper.Object2Json(receList)}");

                NtLogHelper.Info("MonitorMsgHelper Over");
                NtLogHelper.Src(byteMessage); 

                onReceive(receList);

@@ -100,15 +99,24 @@
            //不要加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("数据处理结束...");

        }