log

device-api-service/src/main/java/com/xy/service/DeviceMqttConsumerImpl.java

@@ -80,6 +80,7 @@ public class DeviceMqttConsumerImpl implements DeviceMqttConsumer {
     @Override
     @ApiOperation("设备消息推送")
     public void devicePushMsg(DeviceMqttDto.RequestParams requestParams) {
+        log.info("设备消息推送MQTT：{}", JSONUtil.toJsonPrettyStr(requestParams));
         DeviceEventMsg deviceEventMsg = JSONUtil.toBean(requestParams.getData(), DeviceEventMsg.class);
         if (deviceEventMsg != null) {
             Long deviceId = deviceEventMsg.getDeviceId();
@@ -215,6 +216,7 @@ public class DeviceMqttConsumerImpl implements DeviceMqttConsumer {
 
 
             //短信通知
+            log.info("设备告警，短信通知处理开始。。。");
             deviceSmsPushMsg(merc,deviceInfo,createTime,code);
         }
     }