From 3ccb7c60e1ed8b6748ed7fb8b64b1dbe50d62abf Mon Sep 17 00:00:00 2001
From: ningshuxia <ningshuxia0927@outlook.com>
Date: 星期五, 28 十月 2022 15:56:18 +0800
Subject: [PATCH] 修改 DataDocking4Socket 对接程序
---
Socket/IStation.DataDockingSocket4NT/control/SendControlJobHelper.cs | 47 +++++++++++++++++++++++++++--------------------
1 files changed, 27 insertions(+), 20 deletions(-)
diff --git a/Socket/IStation.DataDockingSocket4NT/control/SendControlJobHelper.cs b/Socket/IStation.DataDockingSocket4NT/control/SendControlJobHelper.cs
index 6d6dce1..09fc411 100644
--- a/Socket/IStation.DataDockingSocket4NT/control/SendControlJobHelper.cs
+++ b/Socket/IStation.DataDockingSocket4NT/control/SendControlJobHelper.cs
@@ -10,8 +10,11 @@
/// <summary>
/// 鍙戦�佹帶鍒舵寚浠よ緟鍔╃被
/// </summary>
- public class SendControlJobHelper
+ public class SendControlJobHelper
{
+ /// <summary>
+ /// 浠嶮Q閲岄潰鑾峰彇鎺у埗鎸囦护 杈呭姪绫�
+ /// </summary>
private static RabbitMqExChangeHelper _queueHelper = null;
/// <summary>
@@ -43,41 +46,45 @@
{
try
{
- if(paras==null)
+ if (paras == null)
{
- LogHelper.Info("鍗楅�氭帶鍒跺懡浠わ紝鏁版嵁搴忓垪鍖栧け璐�");
+ NtLogHelper.Info("鍗楅�氭帶鍒跺懡浠わ紝鏁版嵁搴忓垪鍖栧け璐�");
return true;
}
- byte[] bts = null;
- switch (paras.Type)
+ switch (paras.ControlType)
{
- case 0:bts = null; break;//浠庤緟鍔╃被涓幏鍙� 鍏抽棴
- case 1: bts = null; break;//浠庤緟鍔╃被涓幏鍙� 寮�鍚�
- case -1:bts = null;break;//浠庤緟鍔╃被涓幏鍙� 鍙橀
- default: break;
- }
- if (bts != null)
- {
- if (session != null)
- {
- if (session.IsConnected)
+ case Model.MonitorTestControlParas.eControlType.Stop:
{
- session.Send(bts, 0, bts.Length);
- LogHelper.Info(session.SessionName + ":" + BitTransfer.ToString(bts) + ", 鍙戦�佷竴鏉¤姹傛帶鍒舵寚浠�");
+ ShutDownMsgHelper.StartJob(session);
}
- }
+ break;
+ case Model.MonitorTestControlParas.eControlType.Start:
+ {
+ if (string.IsNullOrEmpty(paras.Context))
+ return false;
+ var context = Model.MonitorTestControlParas.StartContext.ToModel(paras.Context);
+ if (context == null)
+ return default;
+ NtLogHelper.Debug(context.ToJson());
+ StartUpMsgHelper.StartJob(session, context);
+ }
+ break;
+ default:
+ return false;
}
return true;
}
catch (Exception ex)
{
- LogHelper.Error("鍗楅�氭帶鍒跺懡浠�,鏁版嵁娑堟伅闃熷垪鍑洪敊锛岃嚜鍔ㄨ烦杩�", ex);
+ NtLogHelper.Error("鍗楅�氭帶鍒跺懡浠�,鏁版嵁娑堟伅闃熷垪鍑洪敊锛岃嚜鍔ㄨ烦杩�", ex);
return true;
}
});
});
-
}
+
+
+
}
}
--
Gitblit v1.9.3