From fcf2f1afcbccdb5f6168140684957f6ec69b2163 Mon Sep 17 00:00:00 2001
From: zhang <zc857179121@qq.com>
Date: 星期三, 18 六月 2025 08:19:24 +0800
Subject: [PATCH] 1
---
zy-acs-manager/src/main/java/com/zy/acs/manager/core/scheduler/KernelScheduler.java | 6 ++++++
1 files changed, 6 insertions(+), 0 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 43d4ac0..8165c21 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
@@ -69,6 +69,7 @@
@Autowired
private AgvModelService agvModelService;
+
@Scheduled(cron = "0/1 * * * * ? ")
private void startupBus() throws InterruptedException {
// if (!configService.getVal("TaskAssignMode", Boolean.class)) { return; }
@@ -112,6 +113,9 @@
try {
Thread.sleep(CORE_SCAN_FREQUENCY_MILLISECOND);
+ if (configService.getVal("stopDownData", Boolean.class)) { return; }
+
+
List<Segment> segments = segmentService.list(new LambdaQueryWrapper<Segment>()
.eq(Segment::getState, SegmentStateType.WAITING.toString())
);
@@ -133,6 +137,8 @@
try {
Thread.sleep(CORE_SCAN_FREQUENCY_MILLISECOND);
+ if (configService.getVal("stopDownData", Boolean.class)) { return; }
+
List<String> actionGroupIds = actionService.selectGroupNo(ActionStsType.PREPARE);
for (String actionGroupId : actionGroupIds) {
mainService.publishAction(actionGroupId);
--
Gitblit v1.9.1