|
|
@@ -1,7 +1,6 @@
|
|
|
package com.zd.laboratory.mqtt.config;
|
|
|
|
|
|
import cn.hutool.core.collection.CollUtil;
|
|
|
-import com.alibaba.fastjson.JSON;
|
|
|
import com.alibaba.fastjson.JSONObject;
|
|
|
import com.zd.algorithm.api.fire.RemoteFireDeviceService;
|
|
|
import com.zd.common.core.redis.RedisService;
|
|
|
@@ -284,8 +283,7 @@ public class MqttConfig {
|
|
|
MessageHeaders messageHeaders = message.getHeaders();
|
|
|
String receivedTopic = (String) messageHeaders.get(MqttHeaders.RECEIVED_TOPIC);
|
|
|
// logger.info("[通道] - [{}],[{}]", receivedTopic,message.getPayload());
|
|
|
-// String messageStr = message.getPayload().toString();
|
|
|
- String messageStr = JSON.toJSONString(message.getPayload());
|
|
|
+ String messageStr = message.getPayload().toString();
|
|
|
if (receivedTopic.startsWith(devicePrefix)) {
|
|
|
if (receivedTopic.contains("788D4C6C6187ABC")) {
|
|
|
logger.info("[原始消息] - [{}]", message.getPayload());
|