From 2b29a4a26019e3d1692c4b4c76746dba9fac7b22 Mon Sep 17 00:00:00 2001 From: aijinhui <aijinhui> Date: 星期六, 07 十月 2023 14:39:16 +0800 Subject: [PATCH] 报警数量统计年 --- ard-work/src/main/java/com/ruoyi/utils/mqtt/MqttConsumerCallback.java | 6 ++++++ 1 files changed, 6 insertions(+), 0 deletions(-) diff --git a/ard-work/src/main/java/com/ruoyi/utils/mqtt/MqttConsumerCallback.java b/ard-work/src/main/java/com/ruoyi/utils/mqtt/MqttConsumerCallback.java index 8504a14..62a2ca2 100644 --- a/ard-work/src/main/java/com/ruoyi/utils/mqtt/MqttConsumerCallback.java +++ b/ard-work/src/main/java/com/ruoyi/utils/mqtt/MqttConsumerCallback.java @@ -78,6 +78,12 @@ IStorageMinioEventService storageMinioEventService = SpringUtils.getBean(IStorageMinioEventService.class); storageMinioEventService.parseStorageMinioEvent(new String(message.getPayload(), StandardCharsets.UTF_8)); } + if (topic.equals("radarWellData")) + { + System.out.println(new String(message.getPayload(), StandardCharsets.UTF_8)); + IStorageMinioEventService storageMinioEventService = SpringUtils.getBean(IStorageMinioEventService.class); + storageMinioEventService.parseStorageMinioEvent(new String(message.getPayload(), StandardCharsets.UTF_8)); + } } catch (Exception e) { log.debug("澶勭悊mqtt娑堟伅寮傚父:" + e); } -- Gitblit v1.9.3