package com.dy.common.mw.protocol4Mqtt.pSdV1; import com.alibaba.fastjson2.JSON; import com.alibaba.fastjson2.JSONObject; import com.dy.common.mw.protocol.Command; import com.dy.common.mw.protocol4Mqtt.pSdV1.downVos.ComCtrlVo; import org.eclipse.paho.client.mqttv3.MqttMessage; /** * @Author: liurunyu * @Date: 2025/6/5 11:41 * @Description */ public class ProtocolParserSdV1 { public MqttSubMsgSdV1 parseSubMsg(String deviceId, String topic, MqttMessage mqttMsg) throws Exception { MqttSubMsgSdV1 ms = new MqttSubMsgSdV1(deviceId, topic, new String(mqttMsg.getPayload(), "UTF-8")); return ms; } public MqttPubMsgSdV1 createPubMsg(String orgTag, Command com) throws Exception { MqttPubMsgSdV1 msg = null ; switch (com.code){ case CodeSdV1.cd_Fault:{ //故障解除命令 this.checkParam(com); this.checkRtnWebUrl(com); msg = this.createPubMsgOfFault(orgTag, com) ; break ; } case CodeSdV1.cd_Stir:{ //搅拌启停命令 this.checkParam(com); this.checkRtnWebUrl(com); msg = this.createPubMsgOfStir(orgTag, com) ; break ; } case CodeSdV1.cd_Inject:{ //注肥启停命令 this.checkParam(com); this.checkRtnWebUrl(com); msg = this.createPubMsgOfInject(orgTag, com) ; break ; } case CodeSdV1.cd_Irr:{ //灌溉启停命令 this.checkParam(com); this.checkRtnWebUrl(com); msg = this.createPubMsgOfIrr(orgTag, com) ; break ; } default:{ throw new Exception("接收到MQTT命令,协议" + com.protocol + "版本" + com.protocolVersion + "功能码" + com.code + "构造器未实现") ; } } return msg ; } private void checkParam(Command com)throws Exception { if(com.param == null){ throw new Exception("接收到MQTT命令,协议" + com.protocol + "版本" + com.protocolVersion + "功能码" + com.code + "命令数据为空") ; } } private void checkRtnWebUrl(Command com)throws Exception { if(com.rtuResultSendWebUrl == null || com.rtuResultSendWebUrl.trim().equals("")){ throw new Exception("接收到MQTT命令,协议" + com.protocol + "版本" + com.protocolVersion + "功能码" + com.code + "命令结果回收URL为空") ; } } private MqttPubMsgSdV1 createPubMsgOfFault(String orgTag, Command com) throws Exception { JSONObject obj = (JSONObject) com.param; String json = obj.toJSONString(); ComCtrlVo cvo = JSON.parseObject(json, ComCtrlVo.class); if(cvo == null){ throw new Exception("json转ComCtrlVo为null") ; } MqttPubMsgSdV1 msg = new MqttPubMsgSdV1() ; this.setPubMsgBase(com, msg); msg.isCacheForOffLine = false ; msg.hasResponse = true ; msg.address = 123 ; msg.value = "" + (cvo.isDo?1:0); msg.topic = createTopic(orgTag, com) ; msg.msg = "" ; return msg ; } private MqttPubMsgSdV1 createPubMsgOfStir(String orgTag, Command com) throws Exception { JSONObject obj = (JSONObject) com.param; String json = obj.toJSONString(); ComCtrlVo cvo = JSON.parseObject(json, ComCtrlVo.class); if(cvo == null){ throw new Exception("json转ComCtrlVo为null") ; } MqttPubMsgSdV1 msg = new MqttPubMsgSdV1() ; this.setPubMsgBase(com, msg); msg.isCacheForOffLine = false ; msg.hasResponse = true ; msg.address = 123 ; msg.value = "" + (cvo.isDo?1:0); msg.topic = createTopic(orgTag, com) ; msg.msg = "" ; return msg ; } private MqttPubMsgSdV1 createPubMsgOfInject(String orgTag, Command com) throws Exception { JSONObject obj = (JSONObject) com.param; String json = obj.toJSONString(); ComCtrlVo cvo = JSON.parseObject(json, ComCtrlVo.class); if(cvo == null){ throw new Exception("json转ComCtrlVo为null") ; } MqttPubMsgSdV1 msg = new MqttPubMsgSdV1() ; this.setPubMsgBase(com, msg); msg.isCacheForOffLine = false ; msg.hasResponse = true ; msg.address = 123 ; msg.value = "" + (cvo.isDo?1:0); msg.topic = createTopic(orgTag, com) ; msg.msg = "" ; return msg ; } private MqttPubMsgSdV1 createPubMsgOfIrr(String orgTag, Command com) throws Exception { JSONObject obj = (JSONObject) com.param; String json = obj.toJSONString(); ComCtrlVo cvo = JSON.parseObject(json, ComCtrlVo.class); if(cvo == null){ throw new Exception("json转ComCtrlVo为null") ; } MqttPubMsgSdV1 msg = new MqttPubMsgSdV1() ; this.setPubMsgBase(com, msg); msg.isCacheForOffLine = false ; msg.hasResponse = true ; msg.address = 123 ; msg.value = "" + (cvo.isDo?1:0); msg.topic = createTopic(orgTag, com) ; msg.msg = "" ; return msg ; } private void setPubMsgBase(Command com, MqttPubMsgSdV1 msg){ msg.commandId = com.id ; msg.deviceId = com.rtuAddr ; msg.mqttResultSendWebUrl = com.rtuResultSendWebUrl ; } private String createTopic(String orgTag, Command com){ String topic = null ; switch (com.code){ case CodeSdV1.cd_Fault:{ topic = orgTag + "/" + com.protocol + com.protocolVersion + "/" + com.rtuAddr + "/control/m4" ; break ; } case CodeSdV1.cd_Stir:{ topic = orgTag + "/" + com.protocol + com.protocolVersion + "/" + com.rtuAddr + "/control/m80" ; break ; } case CodeSdV1.cd_Inject:{ topic = orgTag + "/" + com.protocol + com.protocolVersion + "/" + com.rtuAddr + "/control/m1" ; break ; } case CodeSdV1.cd_Irr:{ topic = orgTag + "/" + com.protocol + com.protocolVersion + "/" + com.rtuAddr + "/control/m2" ; break ; } default:{ topic = null ; break; } } return topic ; } }