|  |  | 
 |  |  |          doDealReportCount(rqVo) ; | 
 |  |  |       }else if(rqVo.code.equals(Code.cd5)){ | 
 |  |  |          doDealReportOver(rqVo) ; | 
 |  |  |       }else if(rqVo.code.equals(Code.cd6)){ | 
 |  |  |          doDealAllOver(rqVo) ; | 
 |  |  |       } | 
 |  |  |       return resVo ; | 
 |  |  |    } | 
 |  |  | 
 |  |  |          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 ; | 
 |  |  | 
 |  |  |       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 ; | 
 |  |  | 
 |  |  |       } | 
 |  |  |    } | 
 |  |  |  | 
 |  |  |  | 
 |  |  |  | 
 |  |  | } |