From 72927a198cf7b88f7a24bd3bff106295f4294a77 Mon Sep 17 00:00:00 2001
From: liweidong-hj <liweidong-hj@huafang.com>
Date: Wed, 11 Mar 2026 16:22:49 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E5=9B=9E=E8=B0=83=E5=90=8E?=
 =?UTF-8?q?=E7=9A=84=E7=8A=B6=E6=80=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../impl/TaskExecuteRecordServiceImpl.java      | 17 ++++++++---------
 1 file changed, 8 insertions(+), 9 deletions(-)

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 672c9d3b..98cab218 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
@@ -147,18 +147,17 @@ public class  TaskExecuteRecordServiceImpl extends BaseServiceImpl<TaskExecuteRe
                 return R.fail("任务Task不存在");
             }
 
+
+            log.info("当前Task状态为{}，任务TaskCode为{}", task.getTaskStatus(),agvCallBack.getTaskCode());
             //状态为暂存 需要调用
             if(Task.STATUS_TEMPORARY_STORAGE.equals(task.getTaskStatus())){
-
+                //判断是否需要调用agv接口
+                containerToAgv(agvCallBack.getTaskCode());
+            }
+            if(Task.STATUS_CONVEYOR_END.equals(task.getTaskStatus())){
+                //判断是否需要调用ctu接口
+                containerToCtu(agvCallBack.getTaskCode());
             }
-            log.info("当前Task状态为{}，任务TaskCode为{}", task.getTaskStatus(),agvCallBack.getTaskCode());
-
-            //判断是否需要调用agv接口
-            containerToAgv(agvCallBack.getTaskCode());
-
-            //判断是否需要调用ctu接口
-            containerToCtu(agvCallBack.getTaskCode());
-
 
         }