| | |
| | | import com.dy.common.mw.protocol4Mqtt.MqttSubMsg; |
| | | import com.dy.common.mw.protocol4Mqtt.MqttTopic; |
| | | 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 ; |
| | | } |
| | |
| | | # 凉州: lz |
| | | # 金川: jc |
| | | # 嘉峪关: jyg |
| | | base.orgTag=ym |
| | | base.orgTag=jyg |
| | | |
| | | # 233服务器: |
| | | # 元谋: 60000 |
| | |
| | | # 凉州: 60104 |
| | | # 金川: 60105 |
| | | # 嘉峪关: 60106 |
| | | tcp.port=60000 |
| | | tcp.port=60106 |
| | | |
| | | #RTU上行数据最小间隔,大于这个间隔认为设备离线了,测控一体阀是3,表阀一体机是6,默认采用时间最长的6 |
| | | base.upData.min.interval=6 |
| | |
| | | # 凉州: mqtt.enable=false mqtt.protocolAndDeviceIds= mqtt.topicAndQos= |
| | | # 金川: mqtt.enable=true mqtt.protocolAndDeviceIds=? mqtt.topicAndQos=weather/1,1;soil/1,1;manure/1,1;state/1,1 |
| | | # 嘉峪关: mqtt.enable=true mqtt.protocolAndDeviceIds=? mqtt.topicAndQos=weather/1,1;soil/1,1;manure/1,1;state/1,1 |
| | | mqtt.enable=false |
| | | mqtt.enable=true |
| | | mqtt.ip=127.0.0.1 |
| | | mqtt.port=1883 |
| | | mqtt.user=dyyjy |
| | | mqtt.password=Dyyjy2025,;.abc!@# |
| | | mqtt.protocolAndDeviceIds=sd1/338220031439,sd1/338220031440 |
| | | mqtt.subTopicAndQos=weather/1,1;soil/1,1;manure/1,1 |
| | | #MQtt设备在一定时间(分钟)后未发布消息,认为设备离线 |
| | |
| | | noSubThenOff: MQtt设备在一定时间(分钟)后未发布消息,认为设备离线 |
| | | --> |
| | | <mqtt enable="${mqtt.enable}" |
| | | svIp="121.199.41.121" |
| | | svPort="1883" |
| | | svUserName="dyyjy" |
| | | svUserPassword="Dyyjy2025,;.abc!@#" |
| | | svIp="${mqtt.ip}" |
| | | svPort="${mqtt.port}" |
| | | svUserName="${mqtt.user}" |
| | | svUserPassword="${mqtt.password}" |
| | | poolMaxSize="10" |
| | | useMemoryPersistence="true" |
| | | protocolAndDeviceIds="${mqtt.protocolAndDeviceIds}" |