From 0c82e3230c725537fd647f1cd631c5f02b148309 Mon Sep 17 00:00:00 2001
From: liweidong-hj <liweidong-hj@huafang.com>
Date: Wed, 11 Mar 2026 14:49:23 +0800
Subject: [PATCH] =?UTF-8?q?=E7=89=A9=E6=B5=81=E6=97=A5=E5=BF=97=E6=89=93?=
 =?UTF-8?q?=E5=8D=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../impl/TaskExecuteRecordServiceImpl.java    | 24 +++++++++++++++++--
 1 file changed, 22 insertions(+), 2 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 089f12c0..672c9d3b 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
@@ -126,6 +126,7 @@ public class  TaskExecuteRecordServiceImpl extends BaseServiceImpl<TaskExecuteRe
         }
 
         // 4. 保存更新后的任务记录
+        log.info("agv回调接口位置记录,任务单号{}：起点位置{}，终点位置{}",agvCallBack.getTaskCode(),taskExecuteRecord.getStartPos(),taskExecuteRecord.getEndPos()) ;
         boolean updateResult = updateById(taskExecuteRecord);
         if (!updateResult) {
             log.error("AGV回调失败：任务单号{}的执行记录更新保存失败", agvCallBack.getTaskCode());
@@ -136,11 +137,29 @@ public class  TaskExecuteRecordServiceImpl extends BaseServiceImpl<TaskExecuteRe
         if (method.equals(TaskExecuteRecord.STATUS_END)) {
             log.info("任务单号{}已完成，准备调用东哥接口", agvCallBack.getTaskCode());
 
-            //判断是否需要调用ctu接口
-            containerToCtu(agvCallBack.getTaskCode());
+            Long taskId = taskExecuteRecord.getTaskId();
+            if(null == taskId){
+                return R.fail("任务TaskId不存在"+taskId);
+            }
+
+            Task task = taskService.getById(taskId);
+            if(null == task){
+                return R.fail("任务Task不存在");
+            }
+
+            //状态为暂存 需要调用
+            if(Task.STATUS_TEMPORARY_STORAGE.equals(task.getTaskStatus())){
+
+            }
+            log.info("当前Task状态为{}，任务TaskCode为{}", task.getTaskStatus(),agvCallBack.getTaskCode());
 
             //判断是否需要调用agv接口
             containerToAgv(agvCallBack.getTaskCode());
+
+            //判断是否需要调用ctu接口
+            containerToCtu(agvCallBack.getTaskCode());
+
+
         }
 
         // 回调处理成功
@@ -267,6 +286,7 @@ public class  TaskExecuteRecordServiceImpl extends BaseServiceImpl<TaskExecuteRe
             return false;
         }
 
+        log.info("新增执行记录，taskCode：{}，起始位置：{}，终点位置：{}", agvSchedulingTaskVO.getTaskCode(), agvSchedulingTaskVO.getStartPos(),agvSchedulingTaskVO.getEndPos());
         TaskExecuteRecord taskExecuteRecord = new TaskExecuteRecord();
         taskExecuteRecord.setTaskId(task.getId());
         taskExecuteRecord.setTaskCode(agvSchedulingTaskVO.getTaskCode());