From ce1292c9cf37195b6abd2699dfc5d6cb3e143c9b Mon Sep 17 00:00:00 2001
From: wanshenmean <cathay_xy@163.com>
Date: 星期日, 12 四月 2026 23:38:19 +0800
Subject: [PATCH] feat(MES): 添加MES接口相关实体和DTO JS扩展文件至JSX格式并更新配置
---
Code/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/SocketServer/SocketClientGateway.cs | 37 +++++++++++++++++++++++++++++++++++--
1 files changed, 35 insertions(+), 2 deletions(-)
diff --git a/Code/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/SocketServer/SocketClientGateway.cs b/Code/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/SocketServer/SocketClientGateway.cs
index 96879a3..feef4f1 100644
--- a/Code/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/SocketServer/SocketClientGateway.cs
+++ b/Code/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/SocketServer/SocketClientGateway.cs
@@ -5,36 +5,69 @@
namespace WIDESEAWCS_Tasks.SocketServer
{
/// <summary>
- /// TcpSocketServer 的适配器实现，保持底层行为不变，仅做访问收口。
+ /// TcpSocketServer 鐨勭綉鍏冲疄鐜�
/// </summary>
+ /// <remarks>
+ /// 瀹炵幇 ISocketClientGateway 鎺ュ彛锛屽皢搴曞眰 TCP 閫氫俊缁嗚妭灏佽銆�
+ /// 浣夸笟鍔″眰涓嶇洿鎺ヤ緷璧� TcpSocketServer锛屼究浜庡崟鍏冩祴璇曞拰鏇挎崲瀹炵幇銆�
+ /// </remarks>
public class SocketClientGateway : ISocketClientGateway
{
+ /// <summary>
+ /// TCP Socket 鏈嶅姟鍣ㄥ疄渚�
+ /// </summary>
private readonly TcpSocketServer _tcpSocket;
+ /// <summary>
+ /// 鏋勯�犲嚱鏁�
+ /// </summary>
+ /// <param name="tcpSocket">TCP Socket 鏈嶅姟鍣ㄥ疄渚�</param>
public SocketClientGateway(TcpSocketServer tcpSocket)
{
_tcpSocket = tcpSocket;
}
+ /// <summary>
+ /// 寮傛鍙戦�佹秷鎭埌鎸囧畾瀹㈡埛绔�
+ /// </summary>
+ /// <param name="clientId">鐩爣瀹㈡埛绔� ID</param>
+ /// <param name="message">娑堟伅鍐呭</param>
+ /// <returns>鍙戦�佹槸鍚︽垚鍔�</returns>
public Task<bool> SendToClientAsync(string clientId, string message)
{
return _tcpSocket.SendToClientAsync(clientId, message);
}
+ /// <summary>
+ /// 閫氳繃 TcpClient 鍙戦�佹秷鎭�
+ /// </summary>
+ /// <param name="client">TCP 瀹㈡埛绔繛鎺�</param>
+ /// <param name="message">娑堟伅鍐呭</param>
public Task SendMessageAsync(TcpClient client, string message)
{
return _tcpSocket.SendMessageAsync(client, message);
}
+ /// <summary>
+ /// 鑾峰彇鎵�鏈夊凡杩炴帴瀹㈡埛绔� ID
+ /// </summary>
+ /// <returns>瀹㈡埛绔� ID 鍒楄〃</returns>
public IReadOnlyList<string> GetClientIds()
{
return _tcpSocket.GetClientIds();
}
+ /// <summary>
+ /// 澶勭悊瀹㈡埛绔繛鎺ョ殑娑堟伅寰幆
+ /// </summary>
+ /// <param name="client">TCP 瀹㈡埛绔繛鎺�</param>
+ /// <param name="clientId">瀹㈡埛绔� ID</param>
+ /// <param name="cancellationToken">鍙栨秷浠ょ墝</param>
+ /// <param name="robotCrane">鏈哄櫒浜虹姸鎬�</param>
+ /// <returns>浠诲姟</returns>
public Task HandleClientAsync(TcpClient client, string clientId, CancellationToken cancellationToken, RobotSocketState robotCrane)
{
return _tcpSocket.HandleClientAsync(client, clientId, cancellationToken, robotCrane);
}
}
}
-
--
Gitblit v1.9.3