| | |
|---|
| | | 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.mw.protocol4Mqtt.pSdV1.upVos.ManureVo; |
|---|
| | | import com.dy.common.util.Callback; |
|---|
| | | import lombok.Data; |
|---|
| | | import lombok.EqualsAndHashCode; |
|---|
| | |
|---|
| | | public boolean subMsgMatchPubMsg(MqttPubMsg pubMsg){ |
|---|
| | | if (pubMsg instanceof MqttPubMsgSdV1) { |
|---|
| | | //MqttPubMsgSdV1 pubMsgSdV1 = (MqttPubMsgSdV1) pubMsg; |
|---|
| | | if(this.vo4Up != null && this.vo4Up instanceof StateVo){ |
|---|
| | | if(this.vo4Up != null && this.vo4Up instanceof ManureVo){ |
|---|
| | | //只要上报的是状态数据，说明设备响应了命令 |
|---|
| | | return true ; |
|---|
| | | } |
|---|
