From 5bf10c1dafe485d506ec534f98e5220a3b83dd17 Mon Sep 17 00:00:00 2001
From: wanshenmean <cathay_xy@163.com>
Date: 星期四, 16 四月 2026 23:16:46 +0800
Subject: [PATCH] feat(WCS&WMS): 机械手扫码NG处理与线体条码读取与添加批量MES绑定解绑接口

---
 Code/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/RobotJob/RobotTaskProcessor.cs |   84 +++++++++++++++++++++++++++++------------
 1 files changed, 59 insertions(+), 25 deletions(-)

diff --git a/Code/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/RobotJob/RobotTaskProcessor.cs b/Code/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/RobotJob/RobotTaskProcessor.cs
index e30d316..c50f942 100644
--- a/Code/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/RobotJob/RobotTaskProcessor.cs
+++ b/Code/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/RobotJob/RobotTaskProcessor.cs
@@ -164,7 +164,8 @@
         /// </remarks>
         /// <param name="task">瑕佷笅鍙戠殑浠诲姟瀵硅薄</param>
         /// <param name="state">鏈哄櫒浜哄綋鍓嶇姸鎬�</param>
-        public async Task SendSocketRobotPickAsync(Dt_RobotTask task, RobotSocketState state)
+        /// <param name="isScanNG">鏄惁鎵爜NG</param>
+        public async Task SendSocketRobotPickAsync(Dt_RobotTask task, RobotSocketState state, bool isScanNG)
         {
             // 鏋勫缓鍙栬揣鎸囦护锛屾牸寮忥細Pickbattery,{婧愬湴鍧�}
             string taskString = $"Pickbattery,{task.RobotSourceAddress}";
@@ -183,6 +184,11 @@
 
                 // 灏嗕换鍔″叧鑱斿埌鐘舵�佸璞�
                 state.CurrentTask = task;
+
+                if(isScanNG)
+                {
+                    state.IsScanNG = true;
+                }
 
                 // 淇濇寔鍘熻涔夛細浠呭湪鐘舵�佸畨鍏ㄥ啓鍏ユ垚鍔熷悗鍐嶆洿鏂颁换鍔$姸鎬�
                 // 杩欐牱鍙互纭繚鐘舵�佸拰浠诲姟璁板綍鐨勪竴鑷存��
@@ -514,37 +520,37 @@
             }
 
             // 瑙f瀽杩斿洖鐨勪换鍔′俊鎭�
-            var taskInfos = JsonConvert.DeserializeObject<List<Dt_Task>>(content.Data.ToJson() ?? string.Empty) ?? new List<Dt_Task>();
-            var taskInfo = taskInfos.FirstOrDefault();
+            //var taskInfos = JsonConvert.DeserializeObject<List<Dt_Task>>(content.Data.ToJson() ?? string.Empty) ?? new List<Dt_Task>();
+            //var taskInfo = taskInfos.FirstOrDefault();
 
-            // 鑾峰彇婧愬湴鍧�
-            string sourceAddress = taskDTO.SourceAddress;
+            //// 鑾峰彇婧愬湴鍧�
+            //string sourceAddress = taskDTO.SourceAddress;
 
-            // 鏌ユ壘婧愬湴鍧�瀵瑰簲鐨勮緭閫佺嚎璁惧
-            IDevice? device = Storage.Devices.FirstOrDefault(x => x.DeviceProDTOs.Any(d => d.DeviceChildCode == sourceAddress));
+            //// 鏌ユ壘婧愬湴鍧�瀵瑰簲鐨勮緭閫佺嚎璁惧
+            //IDevice? device = Storage.Devices.FirstOrDefault(x => x.DeviceProDTOs.Any(d => d.DeviceChildCode == sourceAddress));
 
-            if (device != null)
-            {
-                // 灏嗚澶囪浆鎹负杈撻�佺嚎绫诲瀷
-                CommonConveyorLine conveyorLine = (CommonConveyorLine)device;
+            //if (device != null)
+            //{
+            //    // 灏嗚澶囪浆鎹负杈撻�佺嚎绫诲瀷
+            //    CommonConveyorLine conveyorLine = (CommonConveyorLine)device;
 
-                // 璁剧疆杈撻�佺嚎鐨勭洰鏍囧湴鍧�
-                conveyorLine.SetValue(ConveyorLineDBNameNew.Target, taskInfo.NextAddress, sourceAddress);
+            //    // 璁剧疆杈撻�佺嚎鐨勭洰鏍囧湴鍧�
+            //    conveyorLine.SetValue(ConveyorLineDBNameNew.Target, taskInfo.NextAddress, sourceAddress);
 
-                // 璁剧疆杈撻�佺嚎鐨勪换鍔″彿
-                conveyorLine.SetValue(ConveyorLineDBNameNew.TaskNo, taskInfo.TaskNum, sourceAddress);
+            //    // 璁剧疆杈撻�佺嚎鐨勪换鍔″彿
+            //    conveyorLine.SetValue(ConveyorLineDBNameNew.TaskNo, taskInfo.TaskNum, sourceAddress);
 
-                // 瑙﹀彂杈撻�佺嚎寮�濮嬫墽琛岋紙鍐欏叆 WCS_ACK = 1锛�
-                conveyorLine.SetValue(ConveyorLineDBNameNew.WCS_ACK, (short)1, sourceAddress);
+            //    // 瑙﹀彂杈撻�佺嚎寮�濮嬫墽琛岋紙鍐欏叆 WCS_ACK = 1锛�
+            //    conveyorLine.SetValue(ConveyorLineDBNameNew.WCS_ACK, (short)1, sourceAddress);
 
-                // 鏇存柊浠诲姟鐘舵�佸埌涓嬩竴闃舵
-                if (_taskService.UpdateTaskStatusToNext(taskInfo).Status)
-                {
-                    _logger.LogInformation("HandleInboundTaskAsync锛氬叆搴撲换鍔″鐞嗘垚鍔燂紝浠诲姟鍙�: {TaskNum}", taskInfo.TaskNum);
-                    QuartzLogger.Info($"HandleInboundTaskAsync锛氬叆搴撲换鍔″鐞嗘垚鍔燂紝浠诲姟鍙�: {taskInfo.TaskNum}", state.RobotCrane?.DeviceName ?? "Unknown");
-                    return true;
-                }
-            }
+            //    // 鏇存柊浠诲姟鐘舵�佸埌涓嬩竴闃舵
+            //    if (_taskService.UpdateTaskStatusToNext(taskInfo).Status)
+            //    {
+            //        _logger.LogInformation("HandleInboundTaskAsync锛氬叆搴撲换鍔″鐞嗘垚鍔燂紝浠诲姟鍙�: {TaskNum}", taskInfo.TaskNum);
+            //        QuartzLogger.Info($"HandleInboundTaskAsync锛氬叆搴撲换鍔″鐞嗘垚鍔燂紝浠诲姟鍙�: {taskInfo.TaskNum}", state.RobotCrane?.DeviceName ?? "Unknown");
+            //        return true;
+            //    }
+            //}
 
             return false;
         }
@@ -632,5 +638,33 @@
         {
             return _httpClientHelper.Post<WebResponseContent>(configKey, stockDTO.ToJson());
         }
+
+        /// <summary>
+        /// 璋冪敤鎵归噺鎷嗙洏纭 API
+        /// </summary>
+        /// <remarks>
+        /// 褰撴媶鐩樹换鍔″叏閮ㄥ彇瀹屾椂璋冪敤锛屼竴娆℃�т笂浼犳暣涓墭鐩樼殑瑙g粦鏁版嵁鍒� MES銆�
+        /// </remarks>
+        /// <param name="palletCode">婧愭墭鐩樺彿</param>
+        /// <returns>HTTP 鍝嶅簲缁撴灉</returns>
+        public HttpResponseResult<WebResponseContent> PostSplitPalletConfirmAsync(string palletCode)
+        {
+            var request = new { PalletCode = palletCode };
+            return _httpClientHelper.Post<WebResponseContent>(nameof(ConfigKey.SplitPalletConfirm), request.ToJson());
+        }
+
+        /// <summary>
+        /// 璋冪敤鎵归噺缁勭洏纭 API
+        /// </summary>
+        /// <remarks>
+        /// 褰撶粍鐩樹换鍔″叏閮ㄦ斁瀹屾椂璋冪敤锛屼竴娆℃�т笂浼犳暣涓墭鐩樼殑缁戝畾鏁版嵁鍒� MES銆�
+        /// </remarks>
+        /// <param name="palletCode">鐩爣鎵樼洏鍙�</param>
+        /// <returns>HTTP 鍝嶅簲缁撴灉</returns>
+        public HttpResponseResult<WebResponseContent> PostGroupPalletConfirmAsync(string palletCode)
+        {
+            var request = new { PalletCode = palletCode };
+            return _httpClientHelper.Post<WebResponseContent>(nameof(ConfigKey.GroupPalletConfirm), request.ToJson());
+        }
     }
 }

--
Gitblit v1.9.3