From 022ddbe53fec5c337e3c7e2ae380f7df61ec6204 Mon Sep 17 00:00:00 2001
From: liweidong-hj <liweidong-hj@huafang.com>
Date: Sat, 21 Mar 2026 10:20:39 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E8=99=9A=E6=8B=9F=E8=B4=A7?=
 =?UTF-8?q?=E6=9E=B6=E7=BB=91=E5=AE=9A=E5=A4=B1=E8=B4=A5=E7=8A=B6=E6=80=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../desk/logistics/pojo/entity/Task.java      | 13 ++++--
 .../service/ITaskExecuteRecordService.java    |  3 +-
 .../impl/StorageMonitoringServiceImpl.java    |  2 +-
 .../impl/TaskExecuteRecordServiceImpl.java    | 45 +++++++++++--------
 4 files changed, 39 insertions(+), 24 deletions(-)

diff --git a/blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/logistics/pojo/entity/Task.java b/blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/logistics/pojo/entity/Task.java
index 467d80d1..26bd50c9 100644
--- a/blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/logistics/pojo/entity/Task.java
+++ b/blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/logistics/pojo/entity/Task.java
@@ -54,14 +54,19 @@ public class Task extends BaseEntity {
     public static final Integer STATUS_TEMPORARY_STORAGE= 6;
 
     /**
-     * mes调用ctu库位
+     * mes调用ctu到库位(上)
      */
-    public static final Integer STATUS_MES_CTU_k= 7;
+    public static final Integer STATUS_MES_CTU_UP= 7;
 
     /**
-     * mes调用ctu梳齿架
+     * mes调用ctu梳齿架（下）
      */
-    public static final Integer STATUS_MES_CTU_s= 8;
+    public static final Integer STATUS_MES_CTU_BELOW= 8;
+
+    /**
+     * 虚拟货架绑定失败
+     */
+    public static final Integer BOUND_VIRTUAL_SHELVES= 9;
 
     /**
      * ID主键
diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/ITaskExecuteRecordService.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/ITaskExecuteRecordService.java
index 96fdc94b..b078067b 100644
--- a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/ITaskExecuteRecordService.java
+++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/ITaskExecuteRecordService.java
@@ -25,6 +25,7 @@
  */
 package org.springblade.desk.logistics.service;
 
+import com.alibaba.fastjson2.JSONObject;
 import org.springblade.core.mp.base.BaseService;
 import org.springblade.core.tool.api.R;
 import org.springblade.desk.logistics.pojo.dto.AGVCallBackDto;
@@ -49,7 +50,7 @@ public interface ITaskExecuteRecordService extends BaseService<TaskExecuteRecord
      * @param stationCode 站点编码
      * @return
      */
-    boolean boundVirtualShelves(String virtualShelvesCode,String stationCode);
+    JSONObject boundVirtualShelves(String virtualShelvesCode, String stationCode);
 
     /**
      *  调用AGV小车
diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/StorageMonitoringServiceImpl.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/StorageMonitoringServiceImpl.java
index 35a4d7e0..30473ac9 100644
--- a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/StorageMonitoringServiceImpl.java
+++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/StorageMonitoringServiceImpl.java
@@ -201,7 +201,7 @@ public class StorageMonitoringServiceImpl implements IStorageMonitoringService {
 
                 //调用成功 添加任务
                 if(null != ctuSchedulingTask && ctuSchedulingTask.getCode().equals("0")){
-                    firstTask.setTaskStatus(Task.STATUS_MES_CTU_s);
+                    firstTask.setTaskStatus(Task.STATUS_MES_CTU_BELOW);
                     boolean taskUpdate = taskService.updateById(firstTask);
                     if (!taskUpdate) {
                         log.error("定时Task状态修改失败，但CTU调度已成功，taskCode：{}", firstTask);
diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/TaskExecuteRecordServiceImpl.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/TaskExecuteRecordServiceImpl.java
index 54484bef..ba0d95e7 100644
--- a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/TaskExecuteRecordServiceImpl.java
+++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/TaskExecuteRecordServiceImpl.java
@@ -164,7 +164,7 @@ public class TaskExecuteRecordServiceImpl extends BaseServiceImpl<TaskExecuteRec
 
             log.info("当前Task状态为{}，任务TaskCode为{}", task.getTaskStatus(), agvCallBack.getTaskCode());
             //状态为暂存 需要调用
-            if (Task.STATUS_MES_CTU_s.equals(task.getTaskStatus())) {
+            if (Task.STATUS_MES_CTU_BELOW.equals(task.getTaskStatus())) {
                 //判断是否需要调用agv接口
                 boolean conAgvReturn = containerToAgv(agvCallBack.getTaskCode());
                 log.info("AGV小车接口调用返回值:{}", conAgvReturn);
@@ -180,7 +180,7 @@ public class TaskExecuteRecordServiceImpl extends BaseServiceImpl<TaskExecuteRec
                     return R.fail("CTU小车接口调用失败");
                 }
             }
-            if(Task.STATUS_MES_CTU_k.equals(task.getTaskStatus())){
+            if(Task.STATUS_MES_CTU_UP.equals(task.getTaskStatus())){
                 //以放到库位 修改状态
                 boolean ctuLocation =  updateMesCtuLocation(agvCallBack.getTaskCode());
                 log.info("MES调用CTU放倒库位:{}", ctuLocation);
@@ -267,7 +267,7 @@ public class TaskExecuteRecordServiceImpl extends BaseServiceImpl<TaskExecuteRec
 
 
     @Override
-    public boolean boundVirtualShelves(String virtualShelvesCode, String stationCode) {
+    public JSONObject boundVirtualShelves(String virtualShelvesCode, String stationCode) {
         String url = "http://172.22.252.10:8181/rcms/services/rest/hikRpcService/bindPodAndBerth";
 
         Map<String, Object> requestBody = new HashMap<>();
@@ -284,19 +284,12 @@ public class TaskExecuteRecordServiceImpl extends BaseServiceImpl<TaskExecuteRec
             log.info("绑定虚拟货架响应：{}", responseStr);
 
             JSONObject response = JSON.parseObject(responseStr);
-            String code = response.getString("code");
 
-            if ("0".equals(code)) {
-                log.info("绑定虚拟货架成功，虚拟货架：{}，站点：{}", virtualShelvesCode, stationCode);
-                return true;
-            } else {
-                log.error("绑定虚拟货架失败，虚拟货架：{}，站点：{}，响应：{}",
-                        virtualShelvesCode, stationCode, responseStr);
-                return false;
-            }
+            return  response;
+
         } catch (Exception e) {
             log.error("绑定虚拟货架异常，虚拟货架：{}，站点：{}", virtualShelvesCode, stationCode, e);
-            return false;
+            return null;
         }
     }
 
@@ -492,7 +485,7 @@ public class TaskExecuteRecordServiceImpl extends BaseServiceImpl<TaskExecuteRec
             }
 
             // 8. 所有操作成功后，更新任务状态
-            task.setTaskStatus(Task.STATUS_MES_CTU_k);
+            task.setTaskStatus(Task.STATUS_MES_CTU_UP);
             boolean taskUpdate = taskService.updateById(task);
             if (!taskUpdate) {
                 log.error("Task状态修改失败，但CTU调度已成功，taskCode：{}", taskCode);
@@ -713,17 +706,33 @@ public class TaskExecuteRecordServiceImpl extends BaseServiceImpl<TaskExecuteRec
         }
 
         // 站点绑定虚拟货架
-        boolean shelves = boundVirtualShelves(
+        JSONObject response = boundVirtualShelves(
                 virtualShelves.getVirtualShelvesCode(),
                 startPos
         );
-        if (!shelves) {
-            throw new ServiceException("站点绑定虚拟货架失败");
-        } else {
+        String code = response.getString("code");
+        String message = response.getString("message");
+
+        if ("0".equals(code)) {
+            log.info("绑定虚拟货架成功，虚拟货架：{}，站点：{}", virtualShelves.getVirtualShelvesCode(), startPos);
+
             virtualShelves.setIsBound(VirtualShelves.BOUND_YES);
             virtualShelvesService.updateById(virtualShelves);
+
+        } else {
+            log.error("绑定虚拟货架失败，虚拟货架：{}，站点：{}，响应：{}",
+                    virtualShelves.getVirtualShelvesCode(), startPos, response);
+
+            //修改Task状态
+            task.setTaskStatus(Task.BOUND_VIRTUAL_SHELVES);
+            task.setRemark(message);
+            taskService.updateById(task);
+
+            return false;
         }
 
+
+
         // 调用AGV
         AgvSchedulingTaskVO agvSchedulingTaskVO = genAgvSchedulingTask(
                 taskType,