From c67d28ce7d0ff1b7061d2bce2f43c255182fbbaa Mon Sep 17 00:00:00 2001 From: wangrunpu <2095588299@qq.com> Date: Fri, 19 Dec 2025 10:04:32 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=E8=AE=A2=E9=98=85iot=5Fhazard/warning?= =?UTF-8?q?=20=E6=8A=A5=E8=AD=A6=E4=BF=A1=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../dromara/hazard/handler/HazardMqttMessageHandler.java | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/ruoyi-modules/ruoyi-hazard/src/main/java/org/dromara/hazard/handler/HazardMqttMessageHandler.java b/ruoyi-modules/ruoyi-hazard/src/main/java/org/dromara/hazard/handler/HazardMqttMessageHandler.java index 5fac81da7..27c9a4c2c 100644 --- a/ruoyi-modules/ruoyi-hazard/src/main/java/org/dromara/hazard/handler/HazardMqttMessageHandler.java +++ b/ruoyi-modules/ruoyi-hazard/src/main/java/org/dromara/hazard/handler/HazardMqttMessageHandler.java @@ -59,11 +59,12 @@ public class HazardMqttMessageHandler implements MqttMessageHandler { log.info("【危险源模块】接收到MQTT消息 - Topic: {}, QoS: {}, Retained: {}, Payload: {}", topic, message.getQos(), message.isRetained(), payload); - // TODO: 根据不同的主题分发到不同的业务处理方法 if (topic.equals("iot_hazard_server")) { handleHazardMessage(topic, payload); } else if (topic.equals("status/online")){ handleOnlineMessage(topic, payload); + } else if (topic.equals("iot_hazard/warning")) { + handleWarningMessage(topic, payload); } else { log.warn("未知的消息主题: {}", topic); } @@ -102,6 +103,7 @@ public class HazardMqttMessageHandler implements MqttMessageHandler { public void subscribeTopics() { try { // 订阅一个主题，QoS=1 + mqttGateway.subscribe("iot_hazard/warning", 1); mqttGateway.subscribe("iot_hazard_server", 1); mqttGateway.subscribe("status/online", 1); log.info("危险源模块已订阅MQTT主题: iot_hazard_server"); @@ -195,4 +197,8 @@ public class HazardMqttMessageHandler implements MqttMessageHandler { } } + + private void handleWarningMessage(String topic, String payload) { + log.info("处理 告警 消息 - Topic: {}, Payload: {}", topic, payload); + } }