pipIrr-SV.git - Gitblit

			@@ -1,7 +1,9 @@
			package com.dy.rtuMw.server.local;

			import com.dy.rtuMw.server.local.localProtocol.*;
			import com.dy.common.mw.UnitStartedCallbackInterface;
			import com.dy.common.mw.channel.tcp.TcpUnit;
			import com.dy.common.mw.protocol.Command;
			import com.dy.rtuMw.server.local.localProtocol.*;

			/**
			* @Author liurunyu
			@@ -23,6 +25,12 @@
			return this.onLine(com) ;
			}else if(code.equals(CodeLocal.allProtocols)){
			return this.allProtocols(com) ;
			}else if(code.equals(CodeLocal.stopTcpSv)){
			return this.stopTcpSv(com) ;
			}else if(code.equals(CodeLocal.recoverTcpSv)){
			return this.recoverTcpSv(com) ;
			}else if(code.equals(CodeLocal.mwState)){
			return this.mwInfo(com) ;
			}
			return ReturnCommand.errored("出错，收到内部命令的功能码不能识别！", com.getId(), com.getCode()) ;
			}
			@@ -54,4 +62,38 @@
			return ReturnCommand.successed("查询所有通信协议配置", command.getId(), command.getCode(), mc) ;
			}

			/**
			* 停止TCP服务，不再接入新的TCP连接，已经TCP连接的全部断连接
			* @throws Exception
			*/
			private Command stopTcpSv(Command command) throws Exception{
			TcpUnit.getInstance().stop(new UnitStartedCallbackInterface(){
			public void call(Object obj) throws Exception {

			}
			});
			return ReturnCommand.successed("已经启动停止TCP服务", command.getId(), command.getCode(), null) ;
			}

			/**
			* 恢复TCP服务，接入新的TCP连接
			* @throws Exception
			*/
			private Command recoverTcpSv(Command command) throws Exception{
			TcpUnit.getInstance().recover();
			return ReturnCommand.successed("已经启动恢复TCP服务", command.getId(), command.getCode(), null) ;
			}



			/**
			* 查询通信中间件运行情况
			* @throws Exception
			*/
			private Command mwInfo(Command command) throws Exception{
			MwInfoVo mwInfo = new MwInfoDeal().deal() ;
			return ReturnCommand.successed("查询通信中间件运行情况", command.getId(), command.getCode(), mwInfo) ;
			}


			}