From 30b0f1f97665f07145e3580dab577fae75ee0fa7 Mon Sep 17 00:00:00 2001
From: Junjie <fallin.jie@qq.com>
Date: 星期一, 27 四月 2026 10:23:23 +0800
Subject: [PATCH] fix: persist station flow capacity audit fields
---
src/main/java/com/zy/core/ServerBootstrap.java | 8 ++++++--
1 files changed, 6 insertions(+), 2 deletions(-)
diff --git a/src/main/java/com/zy/core/ServerBootstrap.java b/src/main/java/com/zy/core/ServerBootstrap.java
index 8e4a67e..82d1ebd 100644
--- a/src/main/java/com/zy/core/ServerBootstrap.java
+++ b/src/main/java/com/zy/core/ServerBootstrap.java
@@ -25,6 +25,8 @@
@Component
public class ServerBootstrap {
+ private static boolean initThread = false;
+
@Autowired
private MainProcess mainProcess;
@Autowired
@@ -34,6 +36,9 @@
@Async
public void init() throws InterruptedException {
+ if (initThread) {
+ return;
+ }
News.info("鏍稿績鎺у埗灞傚紑濮嬪垵濮嬪寲...............................................");
clearStartupRuntimeLocks();
// 鍒濆鍖栨秷鎭槦鍒�
@@ -42,6 +47,7 @@
initThread();
// 寮�濮嬩富娴佺▼杩涚▼
mainProcess.start();
+ initThread = true;
News.info("鏍稿績鎺у埗灞傚凡鍚姩...............................................");
}
@@ -146,8 +152,6 @@
thread = new ZyStationThread(deviceConfig, redisUtil);
} else if (deviceConfig.getThreadImpl().equals("ZyStationV3Thread")) {
thread = new ZyStationV3Thread(deviceConfig, redisUtil);
- } else if (deviceConfig.getThreadImpl().equals("ZyStationV4Thread")) {
- thread = new ZyStationV4Thread(deviceConfig, redisUtil);
} else if (deviceConfig.getThreadImpl().equals("ZyStationV5Thread")) {
thread = new ZyStationV5Thread(deviceConfig, redisUtil);
} else {
--
Gitblit v1.9.1