From 90828f3832bc61241c3302386f072a2baf04bece Mon Sep 17 00:00:00 2001
From: yang_shj <1069818635@QQ.com>
Date: Mon, 25 Mar 2024 16:23:19 +0800
Subject: [PATCH] =?UTF-8?q?#fdp=E5=91=8A=E8=AD=A6=E6=97=A5=E5=BF=97?=
 =?UTF-8?q?=E6=89=93=E5=8D=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/java/com/hnac/hzims/alarm/mqtt/FdpMqttConsumer.java      | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/hzims-service/hzims-alarm/src/main/java/com/hnac/hzims/alarm/mqtt/FdpMqttConsumer.java b/hzims-service/hzims-alarm/src/main/java/com/hnac/hzims/alarm/mqtt/FdpMqttConsumer.java
index 97a8822..ca67dc9 100644
--- a/hzims-service/hzims-alarm/src/main/java/com/hnac/hzims/alarm/mqtt/FdpMqttConsumer.java
+++ b/hzims-service/hzims-alarm/src/main/java/com/hnac/hzims/alarm/mqtt/FdpMqttConsumer.java
@@ -5,6 +5,7 @@ import com.hnac.hzims.alarm.config.entity.AlarmEntity;
 import com.hnac.hzims.alarm.source.service.FdpAlarmService;
 import com.hnac.hzims.alarm.monitor.service.AlarmSaveService;
 import com.hnac.hzinfo.subscribe.SubscribeCallBack;
+import lombok.extern.slf4j.Slf4j;
 import org.springblade.core.log.exception.ServiceException;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -18,6 +19,7 @@ import java.util.Map;
  */
 
 @Service
+@Slf4j
 public class FdpMqttConsumer implements SubscribeCallBack {
     @Autowired
     private FdpAlarmService fdpAlarmService;
@@ -25,7 +27,7 @@ public class FdpMqttConsumer implements SubscribeCallBack {
     private AlarmSaveService alarmSaveService;
     @Override
     public void onMessage(Map<String, Object> data) {
-        System.out.println("监听到消息"+data.toString());
+        log.error("监听Fdp消息 : {}" ,data.toString());
         String s = JSONObject.toJSONString(data);
         //消费代码