From 368eea91e89ef68b98861bd2c1a3677abb5df264 Mon Sep 17 00:00:00 2001
From: yuyongle <1150359267@qq.com>
Date: Wed, 27 Aug 2025 18:14:14 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E4=BA=86=E6=B0=B4=E7=94=B5?=
 =?UTF-8?q?=E6=8A=84=E8=A1=A8bug?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../consumer/MeterRecordConsumer.java         | 88 +++++++++----------
 1 file changed, 44 insertions(+), 44 deletions(-)

diff --git a/ruoyi-modules/Sis/src/main/java/org/dromara/sis/rocketmq/consumer/MeterRecordConsumer.java b/ruoyi-modules/Sis/src/main/java/org/dromara/sis/rocketmq/consumer/MeterRecordConsumer.java
index 8360613a..3a0a80d0 100644
--- a/ruoyi-modules/Sis/src/main/java/org/dromara/sis/rocketmq/consumer/MeterRecordConsumer.java
+++ b/ruoyi-modules/Sis/src/main/java/org/dromara/sis/rocketmq/consumer/MeterRecordConsumer.java
@@ -1,44 +1,44 @@
-package org.dromara.sis.rocketmq.consumer;
-
-import lombok.RequiredArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
-import org.apache.rocketmq.common.message.MessageExt;
-import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
-import org.apache.rocketmq.spring.core.RocketMQListener;
-import org.dromara.sis.rocketmq.RocketMqConstants;
-import org.dromara.sis.rocketmq.producer.ProducerService;
-import org.springframework.stereotype.Component;
-
-/**
- * @author lsm
- * @apiNote MeterRecordConsumer
- * @since 2025/8/25
- */
-@Slf4j
-@Component
-@RequiredArgsConstructor
-@RocketMQMessageListener(
-    topic = RocketMqConstants.TOPIC,
-    consumerGroup = RocketMqConstants.METER_GROUP,
-    selectorExpression = RocketMqConstants.METER_RECORD,
-    nameServer = "${rocketmq.cluster1.name-server}"
-)
-public class MeterRecordConsumer implements RocketMQListener<MessageExt> {
-
-    private final ProducerService producerService;
-
-    @Override
-    public void onMessage(MessageExt ext) {
-        try {
-            if (ext.getBody() == null) {
-                log.info("仪表上报消息数据，不转发！");
-            } else {
-                producerService.defaultSend(RocketMqConstants.TOPIC, RocketMqConstants.METER_RECORD, new String(ext.getBody()));
-                log.info("转发仪表上报数据处理成功");
-            }
-        } catch (Exception e) {
-            log.error("转发仪表上报数据处理失败，", e);
-        }
-
-    }
-}
+//package org.dromara.sis.rocketmq.consumer;
+//
+//import lombok.RequiredArgsConstructor;
+//import lombok.extern.slf4j.Slf4j;
+//import org.apache.rocketmq.common.message.MessageExt;
+//import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
+//import org.apache.rocketmq.spring.core.RocketMQListener;
+//import org.dromara.sis.rocketmq.RocketMqConstants;
+//import org.dromara.sis.rocketmq.producer.ProducerService;
+//import org.springframework.stereotype.Component;
+//
+///**
+// * @author lsm
+// * @apiNote MeterRecordConsumer
+// * @since 2025/8/25
+// */
+//@Slf4j
+//@Component
+//@RequiredArgsConstructor
+//@RocketMQMessageListener(
+//    topic = RocketMqConstants.TOPIC,
+//    consumerGroup = RocketMqConstants.METER_GROUP,
+//    selectorExpression = RocketMqConstants.METER_RECORD,
+//    nameServer = "${rocketmq.cluster1.name-server}"
+//)
+//public class MeterRecordConsumer implements RocketMQListener<MessageExt> {
+//
+//    private final ProducerService producerService;
+//
+//    @Override
+//    public void onMessage(MessageExt ext) {
+//        try {
+//            if (ext.getBody() == null) {
+//                log.info("仪表上报消息数据，不转发！");
+//            } else {
+//                producerService.defaultSend(RocketMqConstants.TOPIC, RocketMqConstants.METER_RECORD, new String(ext.getBody()));
+//                log.info("转发仪表上报数据处理成功");
+//            }
+//        } catch (Exception e) {
+//            log.error("转发仪表上报数据处理失败，", e);
+//        }
+//
+//    }
+//}