feat(property): 添加自动抄表功能

ruoyi-modules/Sis/src/main/java/org/dromara/sis/rocketmq/consumer/MeterRecordConsumer.java

@@ -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);
-//        }
-//
-//    }
-//}