From efe7ec389bfbd88187f5079e527a910ec2ba1004 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=9D=8E=E5=B0=8F=E6=9E=97?= <320730042@qq.com>
Date: Tue, 9 Jul 2024 15:41:26 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E5=88=9D=E5=A7=8B=E5=8C=96XXManager?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/bellmann/runner/InterfaceService.java | 49 +++++++++++++++++++
 .../bellmann/runner/ServiceManagerRunner.java | 24 +++++++++
 2 files changed, 73 insertions(+)
 create mode 100644 src/main/java/com/bellmann/runner/InterfaceService.java
 create mode 100644 src/main/java/com/bellmann/runner/ServiceManagerRunner.java

diff --git a/src/main/java/com/bellmann/runner/InterfaceService.java b/src/main/java/com/bellmann/runner/InterfaceService.java
new file mode 100644
index 0000000..eef138a
--- /dev/null
+++ b/src/main/java/com/bellmann/runner/InterfaceService.java
@@ -0,0 +1,49 @@
+package com.bellmann.runner;
+
+
+import com.zznode.cap.api.CAP;
+import com.zznode.cap.api.ServiceManager;
+import com.zznode.itms.api.ACSManager;
+import com.zznode.itms.api.InventoryManager;
+import com.zznode.itms.api.NBIManager;
+import com.zznode.itms.api.OAMManager;
+import lombok.Getter;
+
+
+public class InterfaceService extends ServiceManager {
+    static InterfaceService service = null;
+
+    //任务超时的时间
+    @Getter
+    private static String task_timeOut;
+
+    public InterfaceService(String[] args) {
+        super(args);
+    }
+    @Override
+    public boolean init() {
+        CAP.trDebug("Start init service INTERFACE");
+        if (!super.init()) {
+            CAP.trError("Failed to init QUERYService.");
+            return false;
+        }
+        service = this;
+        task_timeOut = getStringValueByName("TaskTimeOut");
+        ACSManager.init(getStringValueByName("Service.Name.ACSManager"));
+        NBIManager.init(getStringValueByName("Service.Name.NBI"));
+        InventoryManager.init(getStringValueByName("Service.Name.Inventory"));
+        OAMManager.init(getStringValueByName("Service.Name.OAM"));
+        return true;
+    }
+
+
+    public synchronized static InterfaceService getInstance(){
+        if(service != null){
+            return service;
+        }
+        String[] arg = new String[] { "-ServerName", "INTERFACE" };
+        service = new InterfaceService(arg);
+        return service;
+    }
+
+}
diff --git a/src/main/java/com/bellmann/runner/ServiceManagerRunner.java b/src/main/java/com/bellmann/runner/ServiceManagerRunner.java
new file mode 100644
index 0000000..c7137fa
--- /dev/null
+++ b/src/main/java/com/bellmann/runner/ServiceManagerRunner.java
@@ -0,0 +1,24 @@
+package com.bellmann.runner;
+
+import lombok.extern.log4j.Log4j2;
+import org.springframework.boot.ApplicationArguments;
+import org.springframework.boot.ApplicationRunner;
+import org.springframework.core.annotation.Order;
+import org.springframework.stereotype.Component;
+
+@Component
+@Order(value = 1)
+@Log4j2
+public class ServiceManagerRunner implements ApplicationRunner {
+
+    @Override
+    public void run(ApplicationArguments args) {
+        new Thread("ServiceManager") {
+            @Override
+            public void run() {
+                InterfaceService.getInstance().start();
+            }
+        }.start();
+        log.info("ServiceManager started");
+    }
+}