From d58a5160d46bd0f83fdd73e9e49061b33e1d241b Mon Sep 17 00:00:00 2001
From: vincentlu <t1341870251@gmail.com>
Date: 星期四, 15 一月 2026 15:21:50 +0800
Subject: [PATCH] #

---
 zy-acs-manager/src/main/java/com/zy/acs/manager/manager/service/impl/TravelServiceImpl.java |   17 ++++++++++++++++-
 1 files changed, 16 insertions(+), 1 deletions(-)

diff --git a/zy-acs-manager/src/main/java/com/zy/acs/manager/manager/service/impl/TravelServiceImpl.java b/zy-acs-manager/src/main/java/com/zy/acs/manager/manager/service/impl/TravelServiceImpl.java
index c90f569..7010598 100644
--- a/zy-acs-manager/src/main/java/com/zy/acs/manager/manager/service/impl/TravelServiceImpl.java
+++ b/zy-acs-manager/src/main/java/com/zy/acs/manager/manager/service/impl/TravelServiceImpl.java
@@ -10,12 +10,14 @@
 import com.zy.acs.manager.manager.service.SegmentService;
 import com.zy.acs.manager.manager.service.TravelService;
 import com.zy.acs.framework.exception.CoolException;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 import java.util.Date;
 import java.util.List;
 
+@Slf4j
 @Service("travelService")
 public class TravelServiceImpl extends ServiceImpl<TravelMapper, Travel> implements TravelService {
 
@@ -40,7 +42,20 @@
             travel.setState(TravelStateType.FINISH.toString());
             travel.setUpdateTime(new Date());
             if (!this.updateById(travel)) {
-                throw new CoolException("鏇存柊Travel澶辫触");
+                throw new CoolException("Travel failed to update");
+            }
+        }
+    }
+
+    @Override
+    public void finishAll(Long agvId) {
+        List<Travel> travelList = this.list(new LambdaQueryWrapper<Travel>()
+                .eq(Travel::getAgvId, agvId).eq(Travel::getState, TravelStateType.RUNNING.toString()));
+        for (Travel travel : travelList) {
+            travel.setState(TravelStateType.FINISH.toString());
+            travel.setUpdateTime(new Date());
+            if (!this.updateById(travel)) {
+                log.error("failed to finish travel all");
             }
         }
     }

--
Gitblit v1.9.1