From 4f99f59668c9160ca60958b7347944def26f2228 Mon Sep 17 00:00:00 2001
From: liurunyu <lry9898@163.com>
Date: 星期日, 27 四月 2025 10:58:53 +0800
Subject: [PATCH] 回退配置
---
pipIrr-platform/pipIrr-mw/pipIrr-mwTest-server/src/main/java/com/dy/testServer/console/Command.java | 146 ++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 146 insertions(+), 0 deletions(-)
diff --git a/pipIrr-platform/pipIrr-mw/pipIrr-mwTest-server/src/main/java/com/dy/testServer/console/Command.java b/pipIrr-platform/pipIrr-mw/pipIrr-mwTest-server/src/main/java/com/dy/testServer/console/Command.java
new file mode 100644
index 0000000..cca3779
--- /dev/null
+++ b/pipIrr-platform/pipIrr-mw/pipIrr-mwTest-server/src/main/java/com/dy/testServer/console/Command.java
@@ -0,0 +1,146 @@
+package com.dy.testServer.console;
+
+import java.io.PrintWriter;
+import java.net.InetAddress;
+import java.net.UnknownHostException;
+import java.util.Iterator;
+import java.util.Map;
+import java.util.Set;
+
+import com.dy.common.mw.channel.rmi.RmiConfigVo;
+import com.dy.common.mw.channel.rmi.RmiUnit;
+import com.dy.testServer.ServerProperties;
+import com.dy.testServer.forRmi.MwTestClientStatus;
+import com.dy.testServer.forRmi.Manager;
+
+public class Command {
+
+ private static final String[] commands ;
+ static{
+ commands = new String[]{
+ "config 鏌ョ湅閰嶇疆淇℃伅",
+ "show 鏄剧ずmwTest鎯呭喌",
+ "start 鍚姩mwTest寤虹珛TCP杩炴帴鏁版嵁",
+ "report 鍚姩mwTest RTU涓婃姤鏁版嵁",
+ "exit 閫�鍑�",
+ };
+ }
+
+
+ public static boolean dealCommand(String command, PrintWriter prtWrt){
+ boolean exit = false ;
+ if (command.equals("help")) {
+ outCommand(prtWrt);
+ } else if (command.equals("config")) {
+ config(prtWrt);
+ } else if (command.equals("show")) {
+ show(prtWrt);
+ } else if (command.equals("start")) {
+ startNetConnect(prtWrt);
+ } else if (command.equals("report")) {
+ startRtuReport(prtWrt);
+ } else if(command.equals("exit")){
+ exit = true ;
+ } else {
+ outError(prtWrt);
+ }
+ return exit ;
+ }
+ private static void outCommand(PrintWriter prtWrt){
+ prtWrt.println("");
+ prtWrt.println("鍛戒护");
+ for(String s : commands){
+ prtWrt.println(" " + s);
+ }
+ prtWrt.println("");
+ }
+ private static void outError(PrintWriter prtWrt){
+ prtWrt.println("");
+ prtWrt.println("鍛戒护涓嶅彲璇嗗埆锛�");
+ prtWrt.println("");
+ }
+
+ private static void config(PrintWriter prtWrt){
+ prtWrt.println("");
+ prtWrt.println("鐩稿叧mwTest鐨勯厤缃�");
+ prtWrt.println(" 妯℃嫙瀹㈡埛鐨凴tuAddr璧峰鍙凤細" + ServerProperties.rtuAddrStart);
+ prtWrt.println(" 妯℃嫙瀹㈡埛鐨凴tuAddr鎴鍙凤細" + ServerProperties.rtuAddrEnd);
+ prtWrt.println(" 姣忎釜mwTest鍒嗛厤鐨凴tuAddr鏁帮細" + ServerProperties.rtuAddrPerMwTest);
+ prtWrt.println(" 閫氫俊涓棿浠禝P锛�" + ServerProperties.tcpServerIp);
+ prtWrt.println(" 閫氫俊涓棿浠剁鍙ｏ細" + ServerProperties.tcpServerPort);
+ prtWrt.println(" mwTest鍙戦�佹暟鎹棿闅旓紙绉掞級锛�" + ServerProperties.sendInterval);
+ prtWrt.println(" mwTest姣廟tuAddr鍙峰彂閫佹暟鎹鏁帮細" + ServerProperties.sendTimes);
+ prtWrt.println(" mwTest姣忎竴杞鍙戦�佹暟鎹紝鍏朵腑鍖呮嫭蹇冭烦鍙戦�佹鏁帮細" + ServerProperties.heartbeatTimes);
+ prtWrt.println("鏈湇鍔MI Server閰嶇疆");
+ String ip = null ;
+ try {
+ ip = InetAddress.getLocalHost().getHostAddress();
+ } catch (UnknownHostException e) {
+ e.printStackTrace();
+ }
+ RmiConfigVo confVo = RmiUnit.getInstance().getAdapter().getConfig() ;
+ if(ip != null){
+ prtWrt.println(" RMI Server锛�" + ip + ":" + confVo.port + "/" + confVo.context);
+ }else{
+ prtWrt.println(" RMI Server锛歔ip]:" + confVo.port + "/" + confVo.context);
+ }
+ prtWrt.println("");
+ }
+
+ private static void show(PrintWriter prtWrt){
+ prtWrt.println("");
+ prtWrt.println("褰撳墠宸叉敞鍐宮wTest瀹㈡埛绔暟閲忥細" + Manager.id2TokenMap.size());
+ if(Manager.id2TokenMap.size() > 0){
+ prtWrt.println("mwTest瀹㈡埛绔強鍏跺伐浣滀俊鎭�");
+ Set<Map.Entry<String, MwTestClientStatus>> set = Manager.token2ClientMap.entrySet() ;
+ Iterator<Map.Entry<String, MwTestClientStatus>> it = set.iterator() ;
+ Map.Entry<String, MwTestClientStatus> ent ;
+ while(it.hasNext()){
+ ent = it.next() ;
+ prtWrt.println(" mwTest瀹㈡埛绔�(token=" + ent.getKey() + ")");
+ MwTestClientStatus sta = ent.getValue() ;
+ if(sta != null){
+ if(sta.confVo != null){
+ prtWrt.println(" rtuAddr鑼冨洿锛�" + sta.confVo.rtuAddrStart + "--" + sta.confVo.rtuAddrEnd);
+ }
+ if(sta.startVo != null){
+ prtWrt.println(" TCP杩炴帴锛�" + (sta.startVo.start?"宸茬粡寮�濮�":"鏈紑濮�"));
+ }else{
+ prtWrt.println(" TCP杩炴帴锛氭湭寮�濮�") ;
+ }
+ if(sta.reportVo != null){
+ prtWrt.println(" RTU涓婃姤鏁版嵁锛�" + (sta.reportVo.report?"宸茬粡寮�濮�":"鏈紑濮�"));
+ }else{
+ prtWrt.println(" RTU涓婃姤鏁版嵁锛氭湭寮�濮�") ;
+ }
+ if(sta.count != null){
+ prtWrt.println(" 宸茬粡涓婃姤鏁版嵁锛�" + sta.count + "鏉�");
+ }
+ if(sta.overCount != null){
+ prtWrt.println(" 宸茬粡瀹屾垚涓婃姤鏁版嵁锛�" + sta.overCount + "鍙癛TU");
+ }
+ if(sta.over != null && sta.over){
+ prtWrt.println(" 涓婃姤鏁版嵁宸茬粡瀹屾垚锛屽叡鐢ㄦ椂锛�" + sta.seconds + "绉�");
+ }
+ }
+ }
+ }
+ prtWrt.println("");
+ }
+
+ private static void startNetConnect(PrintWriter prtWrt){
+ prtWrt.println("");
+ prtWrt.println(" 宸茬粡鍏佽mwTest寤虹珛TCP杩炴帴");
+ prtWrt.println("");
+ Manager.enablemwTestStartTcpConnect = true ;
+ }
+
+ private static void startRtuReport(PrintWriter prtWrt){
+ prtWrt.println("");
+ prtWrt.println(" 宸茬粡鍏佽mwTest RTU涓婃姤鏁版嵁浜�");
+ prtWrt.println("");
+ Manager.enablemwTestStartRtuReport = true ;
+ }
+
+
+}
--
Gitblit v1.8.0