| | |
|---|
| | | |
|---|
| | | import com.dy.common.mw.protocol4Mqtt.MqttPubMsg; |
|---|
| | | import com.dy.common.mw.protocol4Mqtt.MqttSubMsg; |
|---|
| | | import com.dy.common.mw.protocol4Mqtt.MqttTopic; |
|---|
| | | import com.dy.common.mw.protocol4Mqtt.pSdV1.upVos.StateVo; |
|---|
| | | import com.dy.common.mw.protocol4Mqtt.Vo4Up; |
|---|
| | | import com.dy.common.util.Callback; |
|---|
| | | import lombok.Data; |
|---|
| | | import lombok.EqualsAndHashCode; |
|---|
| | |
|---|
| | | @Data |
|---|
| | | @EqualsAndHashCode(callSuper=false) |
|---|
| | | public class MqttSubMsgSdV1 extends MqttSubMsg { |
|---|
| | | public Integer address ;//寄存器地址 |
|---|
| | | public String value ;//寄存器值 |
|---|
| | | public Vo4Up vo4Up;//订阅的消息数据值对象 |
|---|
| | | |
|---|
| | | public MqttSubMsgSdV1(){} |
|---|
| | | |
|---|
| | | public MqttSubMsgSdV1(String deviceId, String topic, String msg) { |
|---|
| | | this.deviceId = deviceId ; |
|---|
| | | this.topic = topic ; |
|---|
| | | this.msg = msg ; |
|---|
| | | public MqttSubMsgSdV1(MqttTopic subTopic, String msg) { |
|---|
| | | this.deviceId = subTopic.devId ; |
|---|
| | | this.protocol = subTopic.protocol ; |
|---|
| | | this.topic = subTopic ; |
|---|
| | | this.metaData = msg ; |
|---|
| | | } |
|---|
| | | public String toString(){ |
|---|
| | | StringBuilder sb = new StringBuilder(); |
|---|
| | |
|---|
| | | .append("\n") ; |
|---|
| | | } |
|---|
| | | sb.append("主题:") |
|---|
| | | .append(topic) |
|---|
| | | .append(topic.longName()) |
|---|
| | | .append("\n") ; |
|---|
| | | sb.append("消息:") |
|---|
| | | .append(msg) |
|---|
| | | .append("\n") ; |
|---|
| | | |
|---|
| | | if(vo4Up != null){ |
|---|
| | | sb.append("数据:") |
|---|
| | | .append(vo4Up.toString()) |
|---|
| | | .append("\n") ; |
|---|
| | | }else{ |
|---|
| | | sb.append("元数据:") |
|---|
| | | .append(metaData) |
|---|
| | | .append("\n") ; |
|---|
| | | } |
|---|
| | | return sb.toString() ; |
|---|
| | | } |
|---|
| | | |
|---|
| | | public boolean subMsgMatchPubMsg(MqttPubMsg pubMsg){ |
|---|
| | | if (pubMsg instanceof MqttPubMsgSdV1) { |
|---|
| | | MqttPubMsgSdV1 pubMsgSdV1 = (MqttPubMsgSdV1) pubMsg; |
|---|
| | | if(this.address.intValue() == pubMsgSdV1.getAddress().intValue()){ |
|---|
| | | //MqttPubMsgSdV1 pubMsgSdV1 = (MqttPubMsgSdV1) pubMsg; |
|---|
| | | if(this.vo4Up != null && this.vo4Up instanceof StateVo){ |
|---|
| | | //只要上报的是状态数据，说明设备响应了命令 |
|---|
| | | return true ; |
|---|
| | | } |
|---|
| | | } |
|---|
| | |
|---|
| | | if (topic == null || topic.isEmpty()) { |
|---|
| | | return false; |
|---|
| | | } |
|---|
| | | if (msg == null || msg.isEmpty()) { |
|---|
| | | if (metaData == null || metaData.isEmpty()) { |
|---|
| | | return false; |
|---|
| | | } |
|---|
| | | return true; |
|---|
