From 7e7e1c9dd1c39b2c38b0a758f3cc9faa0921b808 Mon Sep 17 00:00:00 2001
From: tangxu <76880903@qq.com>
Date: 星期四, 27 十月 2022 15:20:55 +0800
Subject: [PATCH] 添加自动关闭
---
Socket/IStation.DataDockingSocket4NT/MsgHandle/HandleHelper.cs | 24 +++++++++++++++---------
1 files changed, 15 insertions(+), 9 deletions(-)
diff --git a/Socket/IStation.DataDockingSocket4NT/MsgHandle/HandleHelper.cs b/Socket/IStation.DataDockingSocket4NT/MsgHandle/HandleHelper.cs
index 36382c1..1ba5022 100644
--- a/Socket/IStation.DataDockingSocket4NT/MsgHandle/HandleHelper.cs
+++ b/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;//鎴愬姛灏辫繑鍥炴帀
}
//涓嶈鍔爀lse
- if (ShunDownMsgHelper.InstructionStatus == eShutDownInstructionStatus.鍏虫満鏈烘寚浠ゅ彂閫�)
+ if (ShutDownMsgHelper.IsNeedHandle(byteMessage))
{
- ShunDownMsgHelper.HandleReceive(session,byteMessage);
+ if (ShutDownMsgHelper.HandleReceive(session, byteMessage))
+ return;
}
//涓嶈鍔爀lse
- if (StartUpMsgHelper.IsCurrentMsg(byteMessage))
+ if (StartUpMsgHelper.IsNeedHandle(byteMessage))
{
-
+ if (StartUpMsgHelper.HandleReceive(session, byteMessage))
+ return;
}
}
--
Gitblit v1.9.3