diff --git a/src/main/java/com/zhgd/mqtt/server/DispatchHandler.java b/src/main/java/com/zhgd/mqtt/server/DispatchHandler.java index 94d31da9d..dc28cca8d 100644 --- a/src/main/java/com/zhgd/mqtt/server/DispatchHandler.java +++ b/src/main/java/com/zhgd/mqtt/server/DispatchHandler.java @@ -58,8 +58,7 @@ public class DispatchHandler { // 正赢人脸设备心跳推送 if (topic.equals("heartbeat/response")) { JSONObject jsonObject = JSONObject.parseObject(payLoad.toString()); - JSONObject body = jsonObject.getJSONObject("body"); - ufaceDevService.online(body.getString("sn")); + ufaceDevService.online(jsonObject.getString("sn")); } } diff --git a/src/main/resources/application.properties b/src/main/resources/application.properties index 720a36948..867c5145d 100644 --- a/src/main/resources/application.properties +++ b/src/main/resources/application.properties @@ -71,7 +71,7 @@ mqtt.url=tcp://jxj.zhgdyun.com:1883 mqtt.producer.clientId=mqttProd0729 mqtt.producer.defaultTopic=topic1 mqtt.consumer.clientId=mqttConsumer0729 -mqtt.consumer.defaultTopic=topic1,mqtt/face/+/Ack,mqtt/face/+/Rec,face/createFace/response,face/response,heartbeat/response +mqtt.consumer.defaultTopic=topic1,mqtt/face/+/Ack,mqtt/face/+/Rec,face/createFace/response,face/response,heartbeat/response #mqtt.consumer.defaultTopic=/P114101/202203010084 #server.http2.enabled=true #server.ssl.key-store=classpath:www.cscec1b1.com.jks