From c77bce593ff4fa33f7cf76c04d556a07d1db77ca Mon Sep 17 00:00:00 2001
From: liuxy <lxy1605052545@163.com>
Date: Tue, 23 Sep 2025 14:56:39 +0800
Subject: [PATCH] =?UTF-8?q?add=EF=BC=9ANDC=E8=87=AA=E5=8A=A8=E9=87=8D?=
 =?UTF-8?q?=E8=BF=9E?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../quartz/task/NdcAutoReconnection.java      | 26 +++++++++++++++++++
 1 file changed, 26 insertions(+)
 create mode 100644 acs/nladmin-system/nlsso-server/src/main/java/org/nl/system/service/quartz/task/NdcAutoReconnection.java

diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/system/service/quartz/task/NdcAutoReconnection.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/system/service/quartz/task/NdcAutoReconnection.java
new file mode 100644
index 0000000..d68f1a4
--- /dev/null
+++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/system/service/quartz/task/NdcAutoReconnection.java
@@ -0,0 +1,26 @@
+package org.nl.system.service.quartz.task;
+
+import lombok.extern.slf4j.Slf4j;
+import org.nl.acs.auto.run.AutoRunService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+/**
+ * NDC自动重连
+ */
+@Slf4j
+@Component
+public class NdcAutoReconnection {
+
+    @Autowired
+    AutoRunService autoRunService;
+
+    public void run(String threadCode) throws Exception {
+        String[] threadCodes = threadCode.split(",");
+        for (String code : threadCodes) {
+            if (!autoRunService.getThreadByCode(code).isAlive()) {
+                autoRunService.startThread(code);
+            }
+        }
+    }
+}