feat(MES): 添加MES接口相关实体和DTO JS扩展文件至JSX格式并更新配置

wanshenmean

4 天以前 ce1292c9cf37195b6abd2699dfc5d6cb3e143c9b

 Code/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/SocketServer/TcpSocketServer.Clients.cs

@@ -10,10 +10,13 @@
    public partial class TcpSocketServer
    {
        /// <summary>
        /// 检索当前在服务中注册的所有客户端标识符的只读列表。
        /// 获取所有已连接客户端 ID 列表
        /// </summary>
        /// <remarks>返回的列表表示调用时刻客户端ID的快照。后续对客户端集合的更改不会影响返回的列表。此方法是线程安全的。</remarks>
        /// <returns>包含客户端ID的<see cref="IReadOnlyList{String}"/>。如果没有客户端注册，列表将为空。</returns>
        /// <remarks>
        /// 返回当前在服务器注册的客户端标识列表。
        /// 这是一个只读列表的快照，线程安全。
        /// </remarks>
        /// <returns>客户端 ID 列表</returns>
        public IReadOnlyList<string> GetClientIds()
        {
            lock (_syncRoot)
@@ -23,11 +26,13 @@
        }

        /// <summary>
        /// 检索与指定设备标识符关联的客户端标识符。
        /// 根据设备 ID 获取客户端 ID
        /// </summary>
        /// <remarks>此方法是线程安全的。如果未找到设备标识符，方法将返回null而不是抛出异常。</remarks>
        /// <param name="deviceId">要检索客户端标识符的设备的唯一标识符。不能为null。</param>
        /// <returns>与指定设备标识符关联的客户端标识符，如果不存在关联则返回null。</returns>
        /// <remarks>
        /// 在设备绑定表中查找对应的客户端 ID。
        /// </remarks>
        /// <param name="deviceId">设备唯一标识</param>
        /// <returns>客户端 ID，如果未找到则返回 null</returns>
        public string? GetClientIdByDevice(string deviceId)
        {
            lock (_syncRoot)
@@ -37,13 +42,15 @@
        }

        /// <summary>
        /// 异步向指定设备发送消息。
        /// 异步向指定设备发送消息
        /// </summary>
        /// <remarks>如果指定设备未注册或无法找到，则返回 <see langword="false"/>。</remarks>
        /// <param name="deviceId">目标设备的唯一标识符。不能为null或空。</param>
        /// <param name="message">要发送给设备的消息。不能为null。</param>
        /// <returns>表示异步操作的任务。如果消息成功发送，任务结果为 <see langword="true"/>；
        /// 否则为 <see langword="false"/>。</returns>
        /// <remarks>
        /// 通过设备 ID 查找对应的客户端连接，然后发送消息。
        /// 如果设备未注册或连接不存在，返回 false。
        /// </remarks>
        /// <param name="deviceId">目标设备唯一标识</param>
        /// <param name="message">要发送的消息</param>
        /// <returns>发送是否成功</returns>
        public Task<bool> SendToDeviceAsync(string deviceId, string message)
        {
            var clientId = GetClientIdByDevice(deviceId);
@@ -52,15 +59,16 @@
        }

        /// <summary>
        /// 通过TCP连接异步向指定客户端发送带帧的文本消息。
        /// 异步向指定客户端发送消息
        /// </summary>
        /// <remarks>如果客户端未连接或不存在，此方法将返回 <see langword="false"/> 且不发送消息。
        /// 消息将优先使用客户端首选的文本编码进行编码；否则使用默认编码。
        /// 此方法对于向不同客户端的并发调用是线程安全的。</remarks>
        /// <param name="clientId">要发送消息到的客户端的唯一标识符。必须对应已连接的客户端。</param>
        /// <param name="message">要发送给客户端的文本消息。不能为null。</param>
        /// <returns>表示异步操作的任务。如果消息成功发送，任务结果为 <see langword="true"/>；
        /// 否则，如果客户端未连接或不存在，结果为 <see langword="false"/>。</returns>
        /// <remarks>
        /// 使用帧格式发送消息（添加头尾标识）。
        /// 每个客户端的发送操作是互斥的（通过信号量实现）。
        /// 如果客户端未连接或不存在，发送失败返回 false。
        /// </remarks>
        /// <param name="clientId">目标客户端 ID</param>
        /// <param name="message">要发送的消息</param>
        /// <returns>发送是否成功</returns>
        public async Task<bool> SendToClientAsync(string clientId, string message)
        {
            TcpClient? client;
@@ -80,9 +88,11 @@

            enc ??= _textEncoding;

            // 获取客户端发送锁
            if (sem != null) await sem.WaitAsync();
            try
            {
                // 发送消息
                var ns = client.GetStream();
                var framedMessage = BuildFramedMessage(message);
                var data = enc.GetBytes(framedMessage);
@@ -96,12 +106,13 @@
        }

        /// <summary>
        /// 异步向所有已连接的客户端发送指定的消息。
        /// 异步广播消息到所有客户端
        /// </summary>
        /// <remarks>如果向某个客户端发送消息时发生错误，异常将被抑制并继续向其他客户端广播。
        /// 当所有发送操作完成后，此方法结束。</remarks>
        /// <param name="message">要广播给所有客户端的消息。不能为null。</param>
        /// <returns>表示异步广播操作的任务。</returns>
        /// <remarks>
        /// 将消息发送给所有已连接的客户端。
        /// 如果某个客户端发送失败，不影响其他客户端的发送。
        /// </remarks>
        /// <param name="message">要广播的消息</param>
        public async Task BroadcastAsync(string message)
        {
            List<TcpClient> clients;
@@ -110,6 +121,7 @@
                clients = _clients.Values.ToList();
            }

            // 并行发送消息到所有客户端
            await Task.WhenAll(clients.Select(c => Task.Run(async () =>
            {
                try { await SendMessageAsync(c, message); } catch { }
@@ -117,14 +129,15 @@
        }

        /// <summary>
        /// 通过网络流异步向指定的TCP客户端发送带帧的文本消息。
        /// 通过 NetworkStream 发送消息
        /// </summary>
        /// <remarks>如果客户端为null或未连接，此方法将立即返回而不发送消息。
        /// 消息将使用配置的文本编码进行编码并添加帧头后通过网络流发送。</remarks>
        /// <param name="client">要发送消息到的TCP客户端。必须处于连接状态；否则方法不执行任何操作。</param>
        /// <param name="message">要发送给客户端的文本消息。消息在传输前将被编码并添加帧头。</param>
        /// <returns>表示异步发送操作的任务。</returns>
        private async Task SendMessageAsync(TcpClient client, string message)
        /// <remarks>
        /// 直接使用 TcpClient 的 NetworkStream 发送消息。
        /// 消息会添加帧头帧尾。
        /// </remarks>
        /// <param name="client">TCP 客户端</param>
        /// <param name="message">消息内容</param>
        public async Task SendMessageAsync(TcpClient client, string message)
        {
            if (client == null || !client.Connected)
            {