From f423e1277f91427f0a767bd1224c1260dcb73086 Mon Sep 17 00:00:00 2001
From: wanshenmean <cathay_xy@163.com>
Date: 星期一, 20 四月 2026 22:47:54 +0800
Subject: [PATCH] feat: 添加空箱入库功能及相关优化

---
 Code/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/RobotJob/Workflow/RobotPrefixCommandHandler.cs |   29 +++++++++--------------------
 1 files changed, 9 insertions(+), 20 deletions(-)

diff --git a/Code/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/RobotJob/Workflow/RobotPrefixCommandHandler.cs b/Code/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/RobotJob/Workflow/RobotPrefixCommandHandler.cs
index e365ffb..d7aa124 100644
--- a/Code/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/RobotJob/Workflow/RobotPrefixCommandHandler.cs
+++ b/Code/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/RobotJob/Workflow/RobotPrefixCommandHandler.cs
@@ -1,7 +1,7 @@
 using System.Net.Sockets;
 using WIDESEAWCS_Common.HttpEnum;
 using WIDESEAWCS_Common.TaskEnum;
-using WIDESEAWCS_DTO.TaskInfo;
+using WIDESEAWCS_Core.Helper;
 using WIDESEAWCS_ITaskInfoService;
 using WIDESEAWCS_Model.Models;
 using WIDESEAWCS_Tasks.Workflow.Abstractions;
@@ -126,7 +126,7 @@
                 var parts = message.Split(',');
 
                 // 妫�鏌ユ秷鎭牸寮忔槸鍚︽湁鏁堬細鑷冲皯瑕佹湁鍛戒护鍓嶇紑锛屼笖鐘舵�佷腑鏈夊綋鍓嶄换鍔�
-                if (parts.Length < 1 || state.CurrentTask == null)
+                if (parts.Length < 1)
                 {
                     return;
                 }
@@ -143,7 +143,7 @@
                     .ToArray();
 
                 // 浠庢暟鎹簱閲嶆柊鏌ヨ褰撳墠浠诲姟锛堢‘淇濊幏鍙栨渶鏂扮姸鎬侊級
-                var task = await _robotTaskService.Repository.QueryFirstAsync(x => x.RobotTaskId == state.CurrentTask.RobotTaskId);
+                var task = await _robotTaskService.Repository.QueryFirstAsync(x => x.RobotTaskState == TaskRobotStatusEnum.RobotExecuting.GetHashCode() && x.RobotRoadway == state.RobotCrane.DeviceName);
 
                 if (task != null)
                 {
@@ -275,17 +275,10 @@
                         if (task != null)
                             task.RobotTaskTotalNum -= positions.Length;
 
-                        if (isFlowA)
-                        {
-                            // 娴佸悜A锛氫笉璋冪敤 API锛屼粎閫掑璁℃暟
-                        }
-                        else
-                        {
-                            // 娴佸悜B锛氳皟鐢ㄦ崲鐩� API
-                            var stockDTO = RobotTaskProcessor.BuildStockDTO(state, positions);
-                            var result = _taskProcessor.PostGroupPalletAsync(nameof(ConfigKey.ChangePalletAsync), stockDTO);
-                            putSuccess = result.Data.Status && result.IsSuccess;
-                        }
+                        // 涓ゆ祦鍚戝潎璋冪敤鎹㈢洏 API
+                        var stockDTO = RobotTaskProcessor.BuildStockDTO(state, positions);
+                        var result = _taskProcessor.PostGroupPalletAsync(nameof(ConfigKey.ChangePalletAsync), stockDTO);
+                        putSuccess = result.Data.Status && result.IsSuccess;
 
                         // 鍒囧洖 Phase 1锛岀户缁彇姝e父鐢佃姱
                         state.ChangePalletPhase = 1;
@@ -294,14 +287,10 @@
                     {
                         if (isFlowA)
                         {
-                            // 娴佸悜A锛氭斁鍋囩數鑺埌鐩爣鎵樼洏锛岄�掑璁℃暟锛岃皟鐢ㄦ崲鐩� API
+                            // 娴佸悜A锛氭斁鍋囩數鑺埌鐩爣鎵樼洏锛屼粎閫掑璁℃暟锛屼笉璋冪敤 API
                             state.RobotTaskTotalNum += positions.Length;
                             if (task != null)
                                 task.RobotTaskTotalNum -= positions.Length;
-
-                            var stockDTO = RobotTaskProcessor.BuildStockDTO(state, positions);
-                            var result = _taskProcessor.PostGroupPalletAsync(nameof(ConfigKey.ChangePalletAsync), stockDTO);
-                            putSuccess = result.Data.Status && result.IsSuccess;
                         }
                         else
                         {
@@ -371,4 +360,4 @@
             }
         }
     }
-}
+}
\ No newline at end of file

--
Gitblit v1.9.3