添加自动关闭

tangxu

2022-10-27 7e7e1c9dd1c39b2c38b0a758f3cc9faa0921b808

 Socket/IStation.DataDockingSocket4NT/MsgHandle/HandleHelper.cs

@@ -11,7 +11,11 @@
{
    public class HandleHelper : IDataDockingSocket.IHandleHelper
    {
   
        static  IMonitorDataDockingSession _session;
        public static IMonitorDataDockingSession GetLastSession()
        {//关机用的是定时器, 定时器里面需要获取最近的一次链接
            return _session;
        }


        /// <summary>
@@ -53,7 +57,7 @@
        /// </summary>
        public void HandleHeartbeat(IMonitorDataDockingSession session)
        {

            _session = session;
        }

        /// <summary>
@@ -75,9 +79,9 @@
            {
                return;
            }

            if (MonitorMsgHelper.IsCurrentMsg(byteMessage))
            {
            _session = session;
            if (MonitorMsgHelper.IsNeedHandle(byteMessage))
            {//监控指令
                var receList = MonitorMsgHelper.HandleReceive(byteMessage);
                if (receList == null || receList.Count == 0)
                    return;
@@ -94,14 +98,16 @@
                return;//成功就返回掉
            }
            //不要加else
            if (ShunDownMsgHelper.InstructionStatus == eShutDownInstructionStatus.关机机指令发送)
            if (ShutDownMsgHelper.IsNeedHandle(byteMessage))
            {
                ShunDownMsgHelper.HandleReceive(session,byteMessage);
                if (ShutDownMsgHelper.HandleReceive(session, byteMessage))
                    return;
            }
            //不要加else
            if (StartUpMsgHelper.IsCurrentMsg(byteMessage))
            if (StartUpMsgHelper.IsNeedHandle(byteMessage))
            {

                if (StartUpMsgHelper.HandleReceive(session, byteMessage))
                    return;
            }

        }