From 3f797fdd7b71d09022f9328134c04b27018f32a2 Mon Sep 17 00:00:00 2001 From: liusuyi <13324259@qq.com> Date: 星期三, 29 十一月 2023 21:49:15 +0800 Subject: [PATCH] 优化日志 --- src/main/java/com/ard/alarm/stealelec/service/StealElecAlarmService.java | 6 +++--- 1 files changed, 3 insertions(+), 3 deletions(-) diff --git a/src/main/java/com/ard/alarm/stealelec/service/StealElecAlarmService.java b/src/main/java/com/ard/alarm/stealelec/service/StealElecAlarmService.java index ced8991..2714637 100644 --- a/src/main/java/com/ard/alarm/stealelec/service/StealElecAlarmService.java +++ b/src/main/java/com/ard/alarm/stealelec/service/StealElecAlarmService.java @@ -4,13 +4,13 @@ import com.alibaba.fastjson2.JSONObject; import com.ard.alarm.stealelec.domain.ArdAlarmStealelec; import com.ard.utils.http.HttpUtils; -import com.ard.utils.mqtt.MqttConsumer; +import com.ard.utils.mqtt.MqttProducer; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Value; import org.springframework.scheduling.annotation.Async; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Service; -import javax.annotation.Resource; + import java.util.ArrayList; import java.util.List; import java.util.Map; @@ -68,7 +68,7 @@ if (tempList.contains(wd.getId())) { continue; } - MqttConsumer.publish(2, false, "stealelec", JSON.toJSONString(wd)); + MqttProducer.publish(2, false, "stealelec", JSON.toJSONString(wd)); tempList.add(wd.getId()); } } -- Gitblit v1.9.3