From 6b1c3d08808590cd8358c5c3b098fb5f72ef2993 Mon Sep 17 00:00:00 2001
From: zhang <zc857179121@qq.com>
Date: 星期二, 17 六月 2025 16:10:54 +0800
Subject: [PATCH] 1
---
zy-acs-manager/src/main/java/com/zy/acs/manager/core/listen/AgvDataSubscriber.java | 7 +++++++
1 files changed, 7 insertions(+), 0 deletions(-)
diff --git a/zy-acs-manager/src/main/java/com/zy/acs/manager/core/listen/AgvDataSubscriber.java b/zy-acs-manager/src/main/java/com/zy/acs/manager/core/listen/AgvDataSubscriber.java
index 34c7599..77a10ad 100644
--- a/zy-acs-manager/src/main/java/com/zy/acs/manager/core/listen/AgvDataSubscriber.java
+++ b/zy-acs-manager/src/main/java/com/zy/acs/manager/core/listen/AgvDataSubscriber.java
@@ -4,6 +4,7 @@
import com.zy.acs.common.domain.AgvProtocol;
import com.zy.acs.common.utils.RedisSupport;
import com.zy.acs.manager.core.service.AgvDataService;
+import com.zy.acs.manager.system.service.ConfigService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.context.event.ApplicationReadyEvent;
@@ -25,6 +26,10 @@
@Autowired
private AgvDataService agvDataService;
+ @Autowired
+ private ConfigService configService;
+
+
@EventListener(ApplicationReadyEvent.class)
private void start(){
// redis.deleteList(RedisConstant.AGV_DATA_FLAG);
@@ -34,6 +39,8 @@
// 闂撮殧
Thread.sleep(10);
+ if (configService.getVal("stopDownData", Boolean.class)) { return; }
+
AgvProtocol protocol = redis.pop(RedisConstant.AGV_DATA_FLAG);
if (null != protocol){
--
Gitblit v1.9.1