|  |  | 
 |  |  | import com.dy.common.mw.UnitCallbackInterface; | 
 |  |  | import com.dy.common.mw.channel.tcp.TcpUnit; | 
 |  |  | import com.dy.common.mw.protocol.Command; | 
 |  |  | import com.dy.rtuMw.server.forTcp.RtuStatus; | 
 |  |  | import com.dy.common.mw.protocol.rtuState.RtuStatus; | 
 |  |  | import com.dy.rtuMw.server.local.localProtocol.*; | 
 |  |  |  | 
 |  |  | import java.util.HashMap; | 
 |  |  | 
 |  |  |         }else if(code.equals(CodeLocal.allRtuStates)){ | 
 |  |  |             return this.allRtuStates(com) ; | 
 |  |  |         }else if(code.equals(CodeLocal.partRtuStates)){ | 
 |  |  |             return this.partRtuStates(com) ; | 
 |  |  |             return this.someRtuStates(com) ; | 
 |  |  |         }else if(code.equals(CodeLocal.oneRtuStates)){ | 
 |  |  |             return this.oneRtuStates(com) ; | 
 |  |  |         }else if(code.equals(CodeLocal.allProtocols)){ | 
 |  |  |             return this.allProtocols(com) ; | 
 |  |  |         }else if(code.equals(CodeLocal.stopTcpSv)){ | 
 |  |  | 
 |  |  |      */ | 
 |  |  |     private Command allRtuStates(Command command) throws Exception{ | 
 |  |  |         Map<String, RtuStatus> map =  new RtuStatusDeal().dealAll() ; | 
 |  |  |         return ReturnCommand.successed("查询所有RTU在线情况结果", command.getId(), command.getCode(), map) ; | 
 |  |  |         return ReturnCommand.successed("查询所有RTU状态结果", command.getId(), command.getCode(), map) ; | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     /** | 
 |  |  |      * 查询部分RTU状态 | 
 |  |  |      * @throws Exception | 
 |  |  |      */ | 
 |  |  |     private Command partRtuStates(Command command) throws Exception{ | 
 |  |  |     private Command someRtuStates(Command command) throws Exception{ | 
 |  |  |         if(command.param != null && command.param instanceof String && !command.param.equals("")){ | 
 |  |  |             String[] rtuAddrGrp = ((String)command.param).split(","); | 
 |  |  |             Map<String, RtuStatus> map = new RtuStatusDeal().dealPart(rtuAddrGrp) ; | 
 |  |  |             Map<String, RtuStatus> map = new RtuStatusDeal().dealSome(rtuAddrGrp) ; | 
 |  |  |             return ReturnCommand.successed("查询部分RTU状态结果", command.getId(), command.getCode(), map) ; | 
 |  |  |         }else{ | 
 |  |  |             return ReturnCommand.errored("出错,命令参数应该是所查询RTU的地址串",  command.getId(), command.getCode()) ; | 
 |  |  | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     /** | 
 |  |  |      * 查询部分RTU状态 | 
 |  |  |      * @throws Exception | 
 |  |  |      */ | 
 |  |  |     private Command oneRtuStates(Command command) throws Exception{ | 
 |  |  |         if(command.param != null && command.param instanceof String && !command.param.equals("")){ | 
 |  |  |             String rtuAddr = (String)command.param; | 
 |  |  |             RtuStatus rtuStatus = new RtuStatusDeal().dealOne(rtuAddr) ; | 
 |  |  |             return ReturnCommand.successed("查询一个RTU状态结果", command.getId(), command.getCode(), rtuStatus) ; | 
 |  |  |         }else{ | 
 |  |  |             return ReturnCommand.errored("出错,命令参数应该是所查询RTU的地址",  command.getId(), command.getCode()) ; | 
 |  |  |         } | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     /** | 
 |  |  |      * 查询所有RTU协议配置 | 
 |  |  |      * @throws Exception | 
 |  |  |      */ |