From d8b10d161ed039cdb58c3a84bdff395265125a3f Mon Sep 17 00:00:00 2001 From: HuangLei Date: Wed, 18 Jun 2025 14:55:10 +0800 Subject: [PATCH] =?UTF-8?q?feat(mq):=20=E6=B7=BB=E5=8A=A0=20RocketMQ?= =?UTF-8?q?=E7=9B=B8=E5=85=B3=E7=9A=84=E5=B8=B8=E9=87=8F=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 新增 GroupConstants 接口，定义了多个消费者组常量- 新增 TopicNameConstants 接口，定义了多个主题名常量 - 新增 TopicTagConstants 接口，定义了多个主题标签常量 --- .../mq/rocketmq/core/GroupConstants.java | 28 +++++++++++++ .../mq/rocketmq/core/TopicNameConstants.java | 41 +++++++++++++++++++ .../mq/rocketmq/core/TopicTagConstants.java | 27 ++++++++++++ 3 files changed, 96 insertions(+) create mode 100644 yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/rocketmq/core/GroupConstants.java create mode 100644 yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/rocketmq/core/TopicNameConstants.java create mode 100644 yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/rocketmq/core/TopicTagConstants.java diff --git a/yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/rocketmq/core/GroupConstants.java b/yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/rocketmq/core/GroupConstants.java new file mode 100644 index 0000000000..3418912ccf --- /dev/null +++ b/yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/rocketmq/core/GroupConstants.java @@ -0,0 +1,28 @@ +package cn.iocoder.yudao.framework.mq.rocketmq.core; + +/** + * @author bixuan + * @version 1.0 + * @description: TODO + * @date 2025/5/4 10:22 + */ +public interface GroupConstants { + String BIND_CARD_PACKAGE_GROUP = "bind-card-package-group"; + String UNBIND_CARD_PACKAGE_GROUP = "unbind-card-package-group"; + String CHANGE_CARD_PACKAGE_GROUP = "change-card-package-group"; + String SYNC_BATCH_GROUP = "sync-batch-group"; + String SYNC_CARD_PACKAGE_GROUP = "sync-card-package-group"; + String SYNC_CARD_PACKAGE_TRAFFIC_GROUP = "sync-card-package-traffic-group"; + String SYNC_CARD_POOL_TRAFFIC_GROUP = "sync-card-pool-traffic-group"; + String SYNC_POOL_TRAFFIC_GROUP = "sync-pool-traffic-group"; + String SYNC_STATISTICS_CARD_POOL_TRAFFIC_GROUP = "sync-statistics-card-pool-traffic-group"; + String SYNC_STATISTICS_CARD_PACKAGE_TRAFFIC_GROUP = "sync-statistics-card-package-traffic-group"; + String PAY_ORDER_DELAY_CLOSE_GROUP = "pay-order-delay-close-group"; + String PAY_ORDER_GENERATE_BILL_GROUP = "pay-order-generate-bill-group"; + String REFUND_ORDER_WRITE_OFF_BILL_GROUP = "refund-order-write-off-bill-group"; + String SYNC_PACKAGE_TRAFFIC_GROUP = "sync-package-traffic-group"; + String PAY_ORDER_REFUND_GROUP = "pay-order-refund-group"; + String EIOT_CLUB_NOTIFY_SUBPKGLIST_GROUP = "eiot-club-notify-subPkgList-group"; + String EIOT_CLUB_NOTIFY_REFUND_GROUP = "eiot-club-notify-refund-group"; + +} diff --git a/yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/rocketmq/core/TopicNameConstants.java b/yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/rocketmq/core/TopicNameConstants.java new file mode 100644 index 0000000000..52bc432bef --- /dev/null +++ b/yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/rocketmq/core/TopicNameConstants.java @@ -0,0 +1,41 @@ +package cn.iocoder.yudao.framework.mq.rocketmq.core; + + + +/** + * @program: b2b2c-admin + * @ClassName TopicNameConstants + * @description: + * @author: HuangLei + * @create: 2025/4/28/周一 9:55 + * @Version 1.0 + **/ +public interface TopicNameConstants { + + + /** + * 运营商主题,相同操作消息可以使用tag区分 + */ + String IOT_OPERATOR = "iot-operator"; + + /** + * 事务主题,相同操作消息可以使用tag区分 + */ + String IOT_TRANSACTION = "iot-transaction"; + + /** + * 延时主题,相同操作消息可以使用tag区分 + */ + String IOT_DELAY = "iot-delay"; + + /** + * 退款主题,相同操作消息可以使用tag区分 + */ + String PAY_REFUND_ORDER = "pay-refund-order"; + + + /** + * eiotclub异步通知主题 + */ + String EIOT_CLUB_NOTIFY_TOPIC = "eiot-club-notify"; +} diff --git a/yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/rocketmq/core/TopicTagConstants.java b/yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/rocketmq/core/TopicTagConstants.java new file mode 100644 index 0000000000..b177a6b347 --- /dev/null +++ b/yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/rocketmq/core/TopicTagConstants.java @@ -0,0 +1,27 @@ +package cn.iocoder.yudao.framework.mq.rocketmq.core; + +/** + * @description: TODO + * @author bixuan + * @date 2025/5/4 10:22 + * @version 1.0 + */ + public interface TopicTagConstants { + String BIND_CARD_PACKAGE_TAG = "bind_card_package"; + String UNBIND_CARD_PACKAGE_TAG = "unbind_card_package"; + String CHANGE_CARD_PACKAGE_TAG = "change_card_package"; + String SYNC_BATCH_TAG = "sync_batch"; + String SYNC_CARD_PACKAGE_TAG = "sync_card_package"; + String SYNC_CARD_PACKAGE_TRAFFIC_TAG = "sync_card_package_traffic"; + String SYNC_CARD_POOL_TRAFFIC_TAG = "sync_card_pool_traffic"; + String SYNC_POOL_TRAFFIC_TAG = "sync_pool_traffic"; + String SYNC_STATISTICS_CARD_POOL_TRAFFIC_TAG = "sync_statistics_card_pool_traffic"; + String SYNC_STATISTICS_CARD_PACKAGE_TRAFFIC_TAG = "sync_statistics_card_package_traffic"; + + String PAY_ORDER_SUCCESS_BILL_TAG = "pay_order_success_bill"; + String REFUND_SUCCESS_BILL_TAG = "refund_success_bill"; + String DELAY_PAY_ORDER_DELAY_CLOSE = "delay_pay_order_close"; + + + +}