| | |
| | | import com.dy.rtuMw.server.forTcp.TcpSessionCache; |
| | | import com.dy.rtuMw.server.local.CommandInnerDeaLer; |
| | | import com.dy.rtuMw.server.local.ReturnCommand; |
| | | import com.dy.rtuMw.server.msCenter.MsCenterUnit; |
| | | import com.dy.rtuMw.server.tasks.WebDownComTask; |
| | | import com.dy.common.mw.core.CoreUnit; |
| | | import com.dy.common.mw.protocol.Command; |
| | |
| | | return BaseResponseUtils.buildSuccess(list); |
| | | } |
| | | } |
| | | |
| | | |
| | | /** |
| | | * 注册消息接收者 |
| | | * @param msReceiverWebUrl 消息接收者web http post url |
| | | * @return |
| | | */ |
| | | @GetMapping("/registerMsReceiverWebUrl") |
| | | public BaseResponse<List<String>> registerMsReceiverWebUrl(String msReceiverWebUrl){ |
| | | try{ |
| | | MsCenterUnit.getInstance().registerMsReceiver(msReceiverWebUrl); |
| | | }catch (Exception e){ |
| | | log.error("注册消息接收者时发生异常", e); |
| | | return BaseResponseUtils.buildError("注册消息接收者时发生异常" + (e.getMessage() == null?"":(":" + e.getMessage()))); |
| | | } |
| | | return BaseResponseUtils.buildSuccess(true); |
| | | } |
| | | |
| | | /** |
| | | * 接收web系统发来升级任务 |
| | | * @param vo |