Merge branch 'master' of http://8.140.179.55:20000/r/pipIrr-SV

liurunyu

2023-12-01 c40d049233f2706dd23aadf327dbf86ba0008a12

 pipIrr-platform/pipIrr-mw/pipIrr-mwTest-server/src/main/java/com/dy/testServer/forRmi/Manager.java

@@ -82,6 +82,8 @@
         doDealReportCount(rqVo) ;
      }else if(rqVo.code.equals(Code.cd5)){
         doDealReportOver(rqVo) ;
      }else if(rqVo.code.equals(Code.cd6)){
         doDealAllOver(rqVo) ;
      }
      return resVo ;
   }
@@ -114,6 +116,8 @@
         conVo.rtuAddrEnd = (Long)rtuAddrs[1] ;
         conVo.tcpServerIp = ServerProperties.tcpServerIp ;
         conVo.tcpServerPort = ServerProperties.tcpServerPort ;
         conVo.sendInterval = ServerProperties.sendInterval ;
         conVo.heartbeatTimes = ServerProperties.heartbeatTimes ;
         conVo.sendTimes = ServerProperties.sendTimes ;
         sta = new MwTestClientStatus() ;
         sta.confVo = conVo ;
@@ -157,6 +161,19 @@
      MwTestClientStatus sta = token2ClientMap.get("" + token);
      if(sta == null){
         sta = new MwTestClientStatus() ;
         sta.overCount = rqVo.overCount ;
         token2ClientMap.put("" + token, sta);
      }else{
         sta.overCount = rqVo.overCount ;
      }
   }


   private static void doDealAllOver(RmiRequestVo rqVo){
      int token = Integer.parseInt(rqVo.token) ;
      MwTestClientStatus sta = token2ClientMap.get("" + token);
      if(sta == null){
         sta = new MwTestClientStatus() ;
         if(rqVo.over != null && rqVo.over){
            sta.over = true ;
            sta.seconds = rqVo.seconds ;
@@ -170,4 +187,6 @@
      }
   }



}