From 616e0764ed9e61ab8a2e8b523eecbba6b98c5c13 Mon Sep 17 00:00:00 2001 From: ‘liusuyi’ <1951119284@qq.com> Date: 星期三, 01 十一月 2023 17:09:55 +0800 Subject: [PATCH] 增加告警前端发送的强制引导信息接收并发送mqtt --- 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