| | |
|---|
| | | package com.dy.rtuMw.server.local; |
|---|
| | | |
|---|
| | | import com.dy.common.mw.UnitStartedCallbackInterface; |
|---|
| | | 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.local.localProtocol.*; |
|---|
| | |
|---|
| | | return this.stopTcpSv(com) ; |
|---|
| | | }else if(code.equals(CodeLocal.recoverTcpSv)){ |
|---|
| | | return this.recoverTcpSv(com) ; |
|---|
| | | }else if(code.equals(CodeLocal.mwInfo)){ |
|---|
| | | }else if(code.equals(CodeLocal.mwState)){ |
|---|
| | | return this.mwInfo(com) ; |
|---|
| | | } |
|---|
| | | return ReturnCommand.errored("出错，收到内部命令的功能码不能识别！", com.getId(), com.getCode()) ; |
|---|
| | |
|---|
| | | * @throws Exception |
|---|
| | | */ |
|---|
| | | private Command stopTcpSv(Command command) throws Exception{ |
|---|
| | | TcpUnit.getInstance().stop(new UnitStartedCallbackInterface(){ |
|---|
| | | TcpUnit.getInstance().stop(new UnitCallbackInterface(){ |
|---|
| | | public void call(Object obj) throws Exception { |
|---|
| | | |
|---|
| | | } |
|---|
