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

Administrator

2023-12-20 dd694b8a3d05e2d785413182e1c28b25a5b3f431

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

@@ -8,9 +8,11 @@
import com.dy.testServer.ServerProperties;

public class Manager {
	
   public static boolean enablemwTestStart = false ;
	

   public static boolean enablemwTestStartTcpConnect = false ;

   public static boolean enablemwTestStartRtuReport = false ;

   public static int clientId = 1 ;
   
   public static long maxClient = 0 ;
@@ -79,10 +81,12 @@
      }else if(rqVo.code.equals(Code.cd3)){
         resVo.obj = doDealGetStart(rqVo) ;
      }else if(rqVo.code.equals(Code.cd4)){
         doDealReportCount(rqVo) ;
         resVo.obj = doDealGetReport(rqVo) ;
      }else if(rqVo.code.equals(Code.cd5)){
         doDealReportOver(rqVo) ;
         doDealReportCount(rqVo) ;
      }else if(rqVo.code.equals(Code.cd6)){
         doDealReportOver(rqVo) ;
      }else if(rqVo.code.equals(Code.cd7)){
         doDealAllOver(rqVo) ;
      }
      return resVo ;
@@ -127,9 +131,9 @@
      }
      return conVo ;
   }
   private static ResStartVo doDealGetStart(RmiRequestVo rqVo){
      ResStartVo rvo = new ResStartVo() ;
      rvo.start = enablemwTestStart ;
   private static ResStartTcpConnectVo doDealGetStart(RmiRequestVo rqVo){
      ResStartTcpConnectVo rvo = new ResStartTcpConnectVo() ;
      rvo.start = enablemwTestStartTcpConnect ;
      int token = Integer.parseInt(rqVo.token) ;
      MwTestClientStatus sta = token2ClientMap.get("" + token);
      if(sta == null){
@@ -141,7 +145,21 @@
      }
      return rvo ;
   }
	
   private static ResStartRtuReportVo doDealGetReport(RmiRequestVo rqVo){
      ResStartRtuReportVo rvo = new ResStartRtuReportVo() ;
      rvo.report = enablemwTestStartRtuReport ;
      int token = Integer.parseInt(rqVo.token) ;
      MwTestClientStatus sta = token2ClientMap.get("" + token);
      if(sta == null){
         sta = new MwTestClientStatus() ;
         sta.reportVo = rvo ;
         token2ClientMap.put("" + token, sta);
      }else{
         sta.reportVo = rvo ;
      }
      return rvo ;
   }

   
   private static void doDealReportCount(RmiRequestVo rqVo){
      int token = Integer.parseInt(rqVo.token) ;
@@ -161,10 +179,10 @@
      MwTestClientStatus sta = token2ClientMap.get("" + token);
      if(sta == null){
         sta = new MwTestClientStatus() ;
         sta.overCount = rqVo.count ;
         sta.overCount = rqVo.overCount ;
         token2ClientMap.put("" + token, sta);
      }else{
         sta.count = rqVo.count ;
         sta.overCount = rqVo.overCount ;
      }
   }