From ee5046d151a858339aa137790bc830efe7f55980 Mon Sep 17 00:00:00 2001
From: zhang <zc857179121@qq.com>
Date: 星期三, 18 六月 2025 15:13:14 +0800
Subject: [PATCH] 1
---
zy-acs-manager/src/main/java/com/zy/acs/manager/core/listen/AgvCompleteSubscriber.java | 14 +++++++-------
1 files changed, 7 insertions(+), 7 deletions(-)
diff --git a/zy-acs-manager/src/main/java/com/zy/acs/manager/core/listen/AgvCompleteSubscriber.java b/zy-acs-manager/src/main/java/com/zy/acs/manager/core/listen/AgvCompleteSubscriber.java
index 285faef..dd67e4e 100644
--- a/zy-acs-manager/src/main/java/com/zy/acs/manager/core/listen/AgvCompleteSubscriber.java
+++ b/zy-acs-manager/src/main/java/com/zy/acs/manager/core/listen/AgvCompleteSubscriber.java
@@ -31,19 +31,19 @@
@EventListener(ApplicationReadyEvent.class)
- private void start(){
+ private void start() {
thread = new Thread(() -> {
while (!Thread.currentThread().isInterrupted()) {
try {
// 闂撮殧
Thread.sleep(30);
- if (configService.getVal("stopDownData", Boolean.class)) { return; }
+ if (!configService.getVal("stopDownData", Boolean.class)) {
+ AgvProtocol protocol = redis.pop(RedisConstant.AGV_COMPLETE_FLAG);
+ if (null != protocol) {
- AgvProtocol protocol = redis.pop(RedisConstant.AGV_COMPLETE_FLAG);
- if (null != protocol){
-
- mainService.upDataSubscribe(protocol);
+ mainService.upDataSubscribe(protocol);
+ }
}
} catch (Exception e) {
@@ -55,7 +55,7 @@
}
@PreDestroy
- public void shutDown(){
+ public void shutDown() {
if (thread != null) thread.interrupt();
}
--
Gitblit v1.9.1