From 00d54db361d697cf8fdf2f15940f4650b21b3185 Mon Sep 17 00:00:00 2001
From: zhubaomin <zhubaomin>
Date: 星期一, 21 四月 2025 15:05:35 +0800
Subject: [PATCH] Merge branch 'master' of http://8.140.179.55:20000/r/pipIrr-SV

---
 pipIrr-platform/pipIrr-mw/pipIrr-mw-simulate-rtu202404/src/main/java/com/dy/simRtu202404/Server.java |  100 ++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 100 insertions(+), 0 deletions(-)

diff --git a/pipIrr-platform/pipIrr-mw/pipIrr-mw-simulate-rtu202404/src/main/java/com/dy/simRtu202404/Server.java b/pipIrr-platform/pipIrr-mw/pipIrr-mw-simulate-rtu202404/src/main/java/com/dy/simRtu202404/Server.java
new file mode 100644
index 0000000..b63daf2
--- /dev/null
+++ b/pipIrr-platform/pipIrr-mw/pipIrr-mw-simulate-rtu202404/src/main/java/com/dy/simRtu202404/Server.java
@@ -0,0 +1,100 @@
+package com.dy.simRtu202404;
+
+import com.dy.common.mw.UnitInterface;
+import com.dy.common.util.ConfigXml4Springboot;
+import com.dy.simRtu202404.tcpClient.TcpClUnit;
+import com.dy.simRtu202404.tcpClient.TcpClUnitConfigVo;
+import org.jdom2.Document;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.core.io.ResourceLoader;
+import org.springframework.stereotype.Component;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @Author: liurunyu
+ * @Date: 2025/02/26 11:03
+ * @Description
+ */
+@Component
+public class Server {
+    @Autowired
+    protected ResourceLoader resourceLoader ;
+
+    private ConfigXml4Springboot conf = null ;
+    private Document doc = null ;
+    private boolean showStartInfo = false ;
+
+    private List<UnitInterface> units = new ArrayList<UnitInterface>() ;
+
+    /**
+     * 鍚姩鏈嶅姟
+     */
+    public void startServer() {
+        long start = System.currentTimeMillis();
+        try {
+            this.conf = new ConfigXml4Springboot() ;
+            this.doc = this.conf.createDom(resourceLoader, "config.xml") ;
+            ////////////////
+            //鏈嶅姟 閰嶇疆
+            this.showStartInfo = this.conf.getSetAttrBoolean(this.doc, "config.server", "showStartInfo", null, null) ;
+
+            this.startUnits() ;
+
+            String svName ;
+            try{
+                svName = this.conf.getSetAttrTxt(this.doc, "config.server", "name", null, false, null) ;
+            }catch(Exception e){
+                svName = "" ;
+            }
+
+            String company ;
+            try{
+                company = this.conf.getSetAttrTxt(this.doc, "config.server", "company", null, true, null) ;
+            }catch(Exception e){
+                company = "" ;
+            }
+            System.out.println("OOOOOOOOOO           OOOOOOOO       OOOOOOOO") ;
+            System.out.println("@@@@@@@@@@@@@@@@#O    $@@@@@@@@&    @@@@@@@@#") ;
+            System.out.println("@@@@@@@@@@@@@@@@@@@#    @@@@@@@@# $@@@@@@@@&") ;
+            System.out.println("@@@@@@@@@@@@@@@@@@@@@#   #@@@@@@@@@@@@@@@@O") ;
+            System.out.println("@@@@@@@@@@@@@@@@@@@@@@@   &@@@@@@@@@@@@@@") ;
+            System.out.println("@@@@@@$      $@@@@@@@@@&   O@@@@@@@@@@@#") ;
+            System.out.println("@@@@@@$        @@@@@@@@@     @@@@@@@@@&      " + svName ) ;
+            System.out.println("@@@@@@$       O@@@@@@@@@     &@@@@@@@@") ;
+
+            if(ServerProperties.serverIp != null){
+                System.out.println("@@@@@@$       O@@@@@@@@@     &@@@@@@@@       杩滅▼涓棿浠舵湇鍔� " + (ServerProperties.serverIp + " " + ServerProperties.serverPort) ) ;
+            }else{
+                System.out.println("@@@@@@$       O@@@@@@@@@     &@@@@@@@@") ;
+            }
+            System.out.println("@@@@@@$      #@@@@@@@@@$     &@@@@@@@@       鏈琑TU鍦板潃 " + ServerProperties.rtuAddr ) ;
+            System.out.println("@@@@@@@@@@@@@@@@@@@@@@#      &@@@@@@@@       Running in standalone mode" ) ;
+            System.out.println("@@@@@@@@@@@@@@@@@@@@@&       &@@@@@@@@       Startup in " + (System.currentTimeMillis() - start) + " MS" ) ;
+            System.out.println("@@@@@@@@@@@@@@@@@@@#         &@@@@@@@@       " + company) ;
+            System.out.println("@@@@@@@@@@@@@@@@#O           &@@@@@@@@") ;
+
+        }catch(Exception e){
+            e.printStackTrace();
+        }
+    }
+
+
+    private void startUnits() {
+        try {
+            // ///////////////
+            // TCP 妯″潡
+            TcpClUnitConfigVo tcpVo = new TcpClUnitConfigVo();
+            AdapterImp_TcpClUnit tcpAdap = new AdapterImp_TcpClUnit();
+            tcpAdap.setConfig(tcpVo);
+            TcpClUnit tcpUnit = TcpClUnit.getInstance();
+            tcpUnit.setAdapter(tcpAdap);
+            tcpUnit.start(obj -> {
+            });
+            units.add(tcpUnit) ;
+        }catch (Exception e){
+            e.printStackTrace();
+        }
+    }
+}

--
Gitblit v1.8.0