From 70930071a49190f414c8d8bc9c9e9795a4096739 Mon Sep 17 00:00:00 2001
From: zhang <zc857179121@qq.com>
Date: 星期一, 23 三月 2026 16:08:27 +0800
Subject: [PATCH] Merge branch 'refs/heads/rcs_master' into jdxaj

---
 zy-acs-manager/src/main/java/com/zy/acs/manager/core/scheduler/KernelScheduler.java |    7 +++++--
 1 files changed, 5 insertions(+), 2 deletions(-)

diff --git a/zy-acs-manager/src/main/java/com/zy/acs/manager/core/scheduler/KernelScheduler.java b/zy-acs-manager/src/main/java/com/zy/acs/manager/core/scheduler/KernelScheduler.java
index f66e3ce..7224c27 100644
--- a/zy-acs-manager/src/main/java/com/zy/acs/manager/core/scheduler/KernelScheduler.java
+++ b/zy-acs-manager/src/main/java/com/zy/acs/manager/core/scheduler/KernelScheduler.java
@@ -71,13 +71,13 @@
     @Autowired
     private LocService locService;
     @Autowired
-    private AgvModelService agvModelService;
+    private TravelService travelService;
     @Autowired
     private TransferStationHandler transferStationHandler;
 
     @Scheduled(cron = "0/1 * * * * ? ")
     private void startupBus() throws InterruptedException {
-//        if (!configService.getVal("TaskAssignMode", Boolean.class)) { return; }
+        if (!configService.getVal("TaskAssignMode", Boolean.class)) { return; }
         if (!this.lock.tryLock(LOCK_TIMEOUT, TimeUnit.SECONDS)) { return; }
         List<Bus> busList = busService.selectInSts(BusStsType.RECEIVE, BusStsType.PROGRESS);
         for (Bus bus : busList) {
@@ -88,6 +88,7 @@
 
     @Scheduled(cron = "0/1 * * * * ? ")
     private void calculateSeg() throws InterruptedException {
+        if (!configService.getVal("TaskAssignMode", Boolean.class)) { return; }
         if (!this.lock.tryLock(LOCK_TIMEOUT, TimeUnit.SECONDS)) { return; }
         List<Task> taskList = taskService.selectBySts(TaskStsType.WAITING);
 
@@ -124,6 +125,8 @@
                     for (Segment segment : segments) {
                         if (transferStationHandler.hasDelayAtSta(segment)) {
                             continue;
+                        } else {
+                            travelService.clearRollerWaiting(segment.getTravelId());
                         }
                         try {
                             txTemplate.executeWithoutResult(status -> {

--
Gitblit v1.9.1