|
|
@@ -138,6 +138,16 @@ public class YfQxzDeviceImpl extends DeviceAbstractImpl implements IYfQxzDevice
|
|
|
String topic = IotMqttConstant.YFQxzTopic.TOPIC_QXZ_CMD_PREFIX + cmdModel.getIotDevice().getDevCode();
|
|
|
IotDevice iotDevice= iIotDeviceService.selectIotDeviceByDevBid(cmdModel.getIotDevice().getDevBid());
|
|
|
mqttManager.publishMsg(iotDevice.getDevconnBid(), topic, mqttMsgContent);
|
|
|
+
|
|
|
+ if(methodName.equals(CmdDef.YfQxzCmdDef.CMD_REFRESH)){
|
|
|
+ JSONObject ext = new JSONObject();
|
|
|
+ ext.put("type", "interval");
|
|
|
+ JSONObject jobjParam = new JSONObject();
|
|
|
+ jobjParam.put("cmd", "read");
|
|
|
+ jobjParam.put("ext", ext);
|
|
|
+ String jsonString = JSONUtils.toJSONString(jobjParam);
|
|
|
+ mqttManager.publishMsg(iotDevice.getDevconnBid(), topic, jsonString);
|
|
|
+ }
|
|
|
log.info("【YFQXZ】发送指令完毕!connectionId:{},topic :{} mqttMsgContent: {}",iotDevice.getDevconnBid(),topic, mqttMsgContent);
|
|
|
|
|
|
cmdModel.setClogSendresult(clogSendresult);
|