| | |
|---|
| | | 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.mqtt.DevStatusDealer; |
|---|
| | | import com.dy.rtuMw.server.mqtt.MqttManager; |
|---|
| | | import com.dy.rtuMw.server.msCenter.MsCenterUnit; |
|---|
| | | import com.dy.rtuMw.server.tasks.WebDownCom4MqttTask; |
|---|
| | |
|---|
| | | * @return 结果 |
|---|
| | | */ |
|---|
| | | private BaseResponse<Command> dealMqttCommand(Command command){ |
|---|
| | | String rtuAddr = command.getRtuAddr() ; |
|---|
| | | if(rtuAddr == null || rtuAddr.trim().equals("")){ |
|---|
| | | return BaseResponseUtils.buildError(ReturnCommand.errored("出错，设备ID为空！", command.getId(), command.getCode())) ; |
|---|
| | | String mqttDevId = command.getRtuAddr() ;//FBox设备号 |
|---|
| | | if(mqttDevId == null || mqttDevId.trim().equals("")){ |
|---|
| | | return BaseResponseUtils.buildError(ReturnCommand.errored("出错，FBox设备ID为空！", command.getId(), command.getCode())) ; |
|---|
| | | } |
|---|
| | | if(!ServerProperties.mqttUnitEnable.booleanValue()){ |
|---|
| | | return BaseResponseUtils.buildError(ReturnCommand.errored("出错，MQTT连接模块配置未启动！", command.getId(), command.getCode())) ; |
|---|
| | | } |
|---|
| | | if(MqttManager.getInstance().poolIsClose()){ |
|---|
| | | return BaseResponseUtils.buildError(ReturnCommand.errored("出错，MQTT连接池水创建成功！", command.getId(), command.getCode())) ; |
|---|
| | | return BaseResponseUtils.buildError(ReturnCommand.errored("出错，MQTT连接池未创建成功！", command.getId(), command.getCode())) ; |
|---|
| | | } |
|---|
| | | if(!DevStatusDealer.oneOnLine(mqttDevId)){ |
|---|
| | | return BaseResponseUtils.buildError(ReturnCommand.errored("出错，FBox设备未在线！", command.getId(), command.getCode())) ; |
|---|
| | | } |
|---|
| | | |
|---|
| | | //生成异步任务 |
|---|
