From 99ee0a23ebaf1718e925a2bc42dce0f9e7b410d4 Mon Sep 17 00:00:00 2001
From: "HUOJIN\\92525" <925259474@qq.com>
Date: Thu, 19 Mar 2026 21:48:39 +0800
Subject: [PATCH] no message

---
 .../modules/agvTask/mapper/AgvTaskMapper.java |  6 ++--
 .../agvTask/mapper/xml/AgvTaskMapper.xml      | 28 +++++++------------
 .../service/impl/TaskServiceImpl.java         | 19 +++++++++++++
 3 files changed, 32 insertions(+), 21 deletions(-)

diff --git a/cpte-boot-module/cpte-module-wms/src/main/java/org/cpte/modules/agvTask/mapper/AgvTaskMapper.java b/cpte-boot-module/cpte-module-wms/src/main/java/org/cpte/modules/agvTask/mapper/AgvTaskMapper.java
index 35e450a..8e33a2b 100644
--- a/cpte-boot-module/cpte-module-wms/src/main/java/org/cpte/modules/agvTask/mapper/AgvTaskMapper.java
+++ b/cpte-boot-module/cpte-module-wms/src/main/java/org/cpte/modules/agvTask/mapper/AgvTaskMapper.java
@@ -63,11 +63,11 @@ public interface AgvTaskMapper extends BaseMapper<AgvTask> {
     List<AgvTask> queryAgvTaskList(@Param("status") Integer status, @Param("agvVendor") String agvVendor);
 
     /**
-     * 查询当前点位最新的TES任务
+     * 根据容器查询Tes
      *
-     * @param endCode 终点
+     * @param carrierCodes 容器
      */
-    AgvTask queryByLastEndCode(@Param("endCode") String endCode);
+    List<AgvTask> queryByCarrierCode(@Param("carrierCodes") List<String> carrierCodes);
 
     /**
      * 根据业务ID查询AGV任务
diff --git a/cpte-boot-module/cpte-module-wms/src/main/java/org/cpte/modules/agvTask/mapper/xml/AgvTaskMapper.xml b/cpte-boot-module/cpte-module-wms/src/main/java/org/cpte/modules/agvTask/mapper/xml/AgvTaskMapper.xml
index f4e0563..513ffab 100644
--- a/cpte-boot-module/cpte-module-wms/src/main/java/org/cpte/modules/agvTask/mapper/xml/AgvTaskMapper.xml
+++ b/cpte-boot-module/cpte-module-wms/src/main/java/org/cpte/modules/agvTask/mapper/xml/AgvTaskMapper.xml
@@ -64,24 +64,6 @@
         order by agv.id
     </select>
 
-    <select id="queryByLastEndCode" resultType="org.cpte.modules.agvTask.entity.AgvTask">
-        (SELECT * FROM data_agv_task
-        WHERE start_code = #{endCode}
-        AND type = 'INBOUND'
-        AND agv_vendor = 'TES'
-        ORDER BY create_time DESC
-        LIMIT 1)
-        UNION ALL
-        (SELECT * FROM data_agv_task
-        WHERE end_code = #{endCode}
-        AND type ='OUTBOUND'
-        AND agv_vendor = 'TES'
-        ORDER BY create_time DESC
-        LIMIT 1)
-        ORDER BY create_time DESC
-        LIMIT 1
-    </select>
-
     <select id="pointTaskCountMap" resultType="java.util.Map">
         SELECT
         bp.point_code,
@@ -146,4 +128,14 @@
         AND bp.iz_active = 1
         ORDER BY bp.col_num
     </select>
+
+    <select id="queryByCarrierCode" resultType="org.cpte.modules.agvTask.entity.AgvTask">
+        SELECT * FROM data_agv_task agv
+        WHERE agv.status in (1,2,3)
+        AND agv.agv_vendor = 'TES'
+        AND agv.carrier_code in
+        <foreach collection="carrierCodes" item="carrierCode" open="(" separator="," close=")">
+            #{carrierCode}
+        </foreach>
+    </select>
 </mapper>
\ No newline at end of file
diff --git a/cpte-boot-module/cpte-module-wms/src/main/java/org/cpte/modules/shipping/service/impl/TaskServiceImpl.java b/cpte-boot-module/cpte-module-wms/src/main/java/org/cpte/modules/shipping/service/impl/TaskServiceImpl.java
index 97833f5..7394e28 100644
--- a/cpte-boot-module/cpte-module-wms/src/main/java/org/cpte/modules/shipping/service/impl/TaskServiceImpl.java
+++ b/cpte-boot-module/cpte-module-wms/src/main/java/org/cpte/modules/shipping/service/impl/TaskServiceImpl.java
@@ -8,6 +8,7 @@ import org.cpte.modules.agvTask.entity.AgvTask;
 import org.cpte.modules.agvTask.mapper.AgvTaskMapper;
 import org.cpte.modules.agvTask.service.IAgvTaskService;
 import org.cpte.modules.base.entity.*;
+import org.cpte.modules.base.mapper.PointMapper;
 import org.cpte.modules.base.service.IPointService;
 import org.cpte.modules.constant.enums.*;
 import org.cpte.modules.conveyorLine.vo.Station;
@@ -46,6 +47,9 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, Task> implements IT
     @Autowired
     private AgvTaskMapper agvTaskMapper;
 
+    @Autowired
+    private PointMapper pointMapper;
+
     @Autowired
     private IPointService pointService;
 
@@ -272,7 +276,22 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, Task> implements IT
 
         //当前所有工作站正在执行的任务
         Map<String, String> workStationTaskMap = getWorkStationTaskMap();
+
+        //查询所有执行的任务
+        List<String> stockCodeList = taskList.stream().map(Task::getStockCode).distinct().toList();
+        List<AgvTask> agvTaskList = agvTaskMapper.queryByCarrierCode(stockCodeList);
+        Map<String, AgvTask> agvTaskMap = agvTaskList.stream().collect(Collectors.toMap(AgvTask::getCarrierCode, agvTask -> agvTask));
         for (Task task : taskList) {
+            //根据容器找执行中的Tes任务
+            AgvTask agvTask = agvTaskMap.get(task.getStockCode());
+            if (agvTask != null) {
+                Point toPoint = pointMapper.queryByPointCode(agvTask.getEndCode());
+                task.setAgvTaskId(agvTask.getId());
+                task.setToPointCode(agvTask.getEndCode());
+                task.setToPointId(toPoint.getId());
+                continue;
+            }
+
             //起点
             Point fromPoint = fromPointMap.get(task.getFromPointId());
             //出库单