From e61b56b05ee155466edfb6e58654d2c7a399d2b2 Mon Sep 17 00:00:00 2001
From: zcxlsm <patrickstarlsm@163.com>
Date: Wed, 27 Aug 2025 19:28:24 +0800
Subject: [PATCH] =?UTF-8?q?feat(property):=20=E6=B7=BB=E5=8A=A0=E8=87=AA?=
 =?UTF-8?q?=E5=8A=A8=E6=8A=84=E8=A1=A8=E5=8A=9F=E8=83=BD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../consumer/MeterRecordConsumer.java         | 45 -------------------
 1 file changed, 45 deletions(-)
 delete mode 100644 ruoyi-modules/Sis/src/main/java/org/dromara/sis/rocketmq/consumer/MeterRecordConsumer.java

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
deleted file mode 100644
index 591fb908..00000000
--- a/ruoyi-modules/Sis/src/main/java/org/dromara/sis/rocketmq/consumer/MeterRecordConsumer.java
+++ /dev/null
@@ -1,45 +0,0 @@
-
-//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);
-//        }
-//
-//    }
-//}