| | |
|---|
| | | MqttSubMsgSdV1 msg = new MqttSubMsgSdV1(subTopic, strTxt); |
|---|
| | | Vo4Up vo ; |
|---|
| | | DevRunInfo stInfo = null ; |
|---|
| | | switch (subTopic.name) { |
|---|
| | | switch (subTopic.type) { |
|---|
| | | case ProtocolConstantSdV1.SubTopicWeather -> { |
|---|
| | | vo = JSON.parseObject(strTxt, WeatherVo.class); |
|---|
| | | break; |
|---|
| | |
|---|
| | | break; |
|---|
| | | } |
|---|
| | | default -> { |
|---|
| | | throw new Exception("接收到MQTT消息，协议" + subTopic.protocol + "，设备ID" + subTopic.devId + "，主题" + subTopic.name + "消息解析逻辑未实现"); |
|---|
| | | throw new Exception("接收到MQTT消息，协议" + subTopic.protocol + "，设备ID" + subTopic.devId + "，主题" + subTopic.type + "消息解析逻辑未实现"); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | vo.setNo(subTopic.no) ; |
|---|
| | | msg.vo4Up = vo ; |
|---|
| | | callback.callback(msg); |
|---|
| | | callback.notify(msg.deviceId, stInfo); |
|---|
| | |
|---|
| | | msg.isCacheForOffLine = false ; |
|---|
| | | msg.hasResponse = true ; |
|---|
| | | msg.cd = CodeSdV1.cd_Fault ; |
|---|
| | | msg.topic = new MqttTopic(orgTag, com.protocol, com.rtuAddr, ProtocolConstantSdV1.PubTopicFault) ; |
|---|
| | | msg.topic = new MqttTopic(orgTag, com.protocol, com.rtuAddr, ProtocolConstantSdV1.PubTopicFault, cvo.no) ; |
|---|
| | | msg.msg = JSON.toJSONString(new FaultClearVo(cvo.startTrueStopFalse ?(byte)1:0)) ; |
|---|
| | | return msg ; |
|---|
| | | } |
|---|
| | |
|---|
| | | msg.isCacheForOffLine = false ; |
|---|
| | | msg.hasResponse = true ; |
|---|
| | | msg.cd = CodeSdV1.cd_Fault ; |
|---|
| | | msg.topic = new MqttTopic(orgTag, com.protocol, com.rtuAddr, ProtocolConstantSdV1.PubTopicStir) ; |
|---|
| | | msg.topic = new MqttTopic(orgTag, com.protocol, com.rtuAddr, ProtocolConstantSdV1.PubTopicStir, cvo.no) ; |
|---|
| | | msg.msg = JSON.toJSONString(new StirStartVo(cvo.startTrueStopFalse ?(byte)1:0)) ; |
|---|
| | | return msg ; |
|---|
| | | } |
|---|
| | |
|---|
| | | msg.isCacheForOffLine = false ; |
|---|
| | | msg.hasResponse = true ; |
|---|
| | | msg.cd = CodeSdV1.cd_Fault ; |
|---|
| | | msg.topic = new MqttTopic(orgTag, com.protocol, com.rtuAddr, ProtocolConstantSdV1.PubTopicInject) ; |
|---|
| | | msg.topic = new MqttTopic(orgTag, com.protocol, com.rtuAddr, ProtocolConstantSdV1.PubTopicInject, cvo.no) ; |
|---|
| | | msg.msg = JSON.toJSONString(new InjectStartVo(cvo.startTrueStopFalse ?(byte)1:0)) ; |
|---|
| | | return msg ; |
|---|
| | | } |
|---|
| | |
|---|
| | | msg.isCacheForOffLine = false ; |
|---|
| | | msg.hasResponse = true ; |
|---|
| | | msg.cd = CodeSdV1.cd_Fault ; |
|---|
| | | msg.topic = new MqttTopic(orgTag, com.protocol, com.rtuAddr, ProtocolConstantSdV1.PubTopicIrr) ; |
|---|
| | | msg.topic = new MqttTopic(orgTag, com.protocol, com.rtuAddr, ProtocolConstantSdV1.PubTopicIrr, cvo.no) ; |
|---|
| | | msg.msg = JSON.toJSONString(new StirStartVo(cvo.startTrueStopFalse ?(byte)1:0)) ; |
|---|
| | | return msg ; |
|---|
| | | } |
|---|
| | |
|---|
| | | msg.isCacheForOffLine = false ; |
|---|
| | | msg.hasResponse = false ; |
|---|
| | | msg.cd = CodeSdV1.cd_Param ; |
|---|
| | | msg.topic = new MqttTopic(orgTag, com.protocol, com.rtuAddr, ProtocolConstantSdV1.PubTopicParam) ; |
|---|
| | | msg.topic = new MqttTopic(orgTag, com.protocol, com.rtuAddr, ProtocolConstantSdV1.PubTopicParam, cvo.no) ; |
|---|
| | | msg.msg = JSON.toJSONString(new ParamSetVo(cvo.stirDuration, cvo.injectDuration)) ; |
|---|
| | | return msg ; |
|---|
| | | } |
|---|
