Merge remote-tracking branch 'origin/master'

wuzeyu

2024-05-20 281145b3d9743ce87de2ca7f6a64536088495d26

 pipIrr-platform/pipIrr-mw/pipIrr-mwTest-server/src/main/java/com/dy/testServer/console/Command.java

@@ -20,7 +20,8 @@
      commands = new String[]{
            "config 查看配置信息",   
            "show 显示mwTest情况",   
            "start 启动mwTest上报数据",	
            "start 启动mwTest建立TCP连接数据",
            "report 启动mwTest RTU上报数据",
            "exit 退出",
      };
   }
@@ -35,7 +36,9 @@
      } else if (command.equals("show")) {
         show(prtWrt);
      } else if (command.equals("start")) {
         start(prtWrt);
         startNetConnect(prtWrt);
      } else if (command.equals("report")) {
         startRtuReport(prtWrt);
      } else if(command.equals("exit")){
         exit = true ;
      } else {
@@ -65,7 +68,9 @@
      prtWrt.println("  每个mwTest分配的RtuAddr数：" + ServerProperties.rtuAddrPerMwTest);
      prtWrt.println("  通信中间件IP：" + ServerProperties.tcpServerIp);
      prtWrt.println("  通信中间件端口：" + ServerProperties.tcpServerPort);
      prtWrt.println("  mwTest发送数据间隔（秒）：" + ServerProperties.sendInterval);
      prtWrt.println("  mwTest每RtuAddr号发送数据次数：" + ServerProperties.sendTimes);
      prtWrt.println("  mwTest每一轮次发送数据，其中包括心跳发送次数：" + ServerProperties.heartbeatTimes);
      prtWrt.println("本服务RMI Server配置");
      String ip = null ;
      try {
@@ -99,12 +104,20 @@
                  prtWrt.println("    rtuAddr范围：" + sta.confVo.rtuAddrStart + "--" + sta.confVo.rtuAddrEnd);
               }
               if(sta.startVo != null){
                  prtWrt.println("    上报数据：" + (sta.startVo.start?"已经开始":"未开始"));
                  prtWrt.println("    TCP连接：" + (sta.startVo.start?"已经开始":"未开始"));
               }else{
                  prtWrt.println("    上报数据：未开始") ;
                  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 + "台RTU");
               }
               if(sta.over != null && sta.over){
                  prtWrt.println("    上报数据已经完成，共用时：" + sta.seconds + "秒");
@@ -115,11 +128,18 @@
      prtWrt.println("");
   }
   
   private static void start(PrintWriter prtWrt){
   private static void startNetConnect(PrintWriter prtWrt){
      prtWrt.println("");
      prtWrt.println("  已经允许mwTest上报数据了");
      prtWrt.println("  已经允许mwTest建立TCP连接");
      prtWrt.println("");
      Manager.enablemwTestStart = true ;
      Manager.enablemwTestStartTcpConnect = true ;
   }

   private static void startRtuReport(PrintWriter prtWrt){
      prtWrt.println("");
      prtWrt.println("  已经允许mwTest RTU上报数据了");
      prtWrt.println("");
      Manager.enablemwTestStartRtuReport = true ;
   }