|
@@ -76,10 +76,10 @@ public class MqttServiceImpl implements MqttService {
|
|
|
JSONObject value = JSONUtil.parseObj(pater);
|
|
|
Long wkSn = pater.getWkSn();
|
|
|
try {
|
|
|
- //发送消息
|
|
|
- mqttProducer.sendToMqtt(value.toString(), topic, mqttDto.getLevel());
|
|
|
//指令记录
|
|
|
saveMqttCommand(mqttDto, value, pater.getAck() ? MqttCommandStatusEnum.COMMAND_SEND : MqttCommandStatusEnum.COMMAND_SUCCESS, null);
|
|
|
+ //发送消息
|
|
|
+ mqttProducer.sendToMqtt(value.toString(), topic, mqttDto.getLevel());
|
|
|
map.put(wkSn, true);
|
|
|
} catch (Exception e) {
|
|
|
//指令记录
|