From 0dd193dc648520ff79122bd32ae94d7f7de5c3c9 Mon Sep 17 00:00:00 2001
From: tianfeng <769204422@qq.com>
Date: Thu, 8 Jan 2026 20:25:34 +0800
Subject: [PATCH] =?UTF-8?q?buy=5Fsuccess=20=E4=BF=AE=E5=A4=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/red/circle/order/app/listener/BuySuccessListener.java | 2 +-
 .../com/red/circle/other/app/listener/BadgeCheckListener.java | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/rc-service/rc-service-order/order-application/src/main/java/com/red/circle/order/app/listener/BuySuccessListener.java b/rc-service/rc-service-order/order-application/src/main/java/com/red/circle/order/app/listener/BuySuccessListener.java
index aa31be3f..257f56ce 100644
--- a/rc-service/rc-service-order/order-application/src/main/java/com/red/circle/order/app/listener/BuySuccessListener.java
+++ b/rc-service/rc-service-order/order-application/src/main/java/com/red/circle/order/app/listener/BuySuccessListener.java
@@ -77,7 +77,7 @@ public class BuySuccessListener implements MessageListener {
             .logTag("语音房会话")
             .consumeMsgTimeoutMinute(15)
             .repeatConsumeMinute(15)
-            .repeatConsumeTag(extractOrderNo(message))
+            .repeatConsumeTag("BuySuccess")
             .checkConsumeTag(BuySuccessSink.TAG)
             .message(message)
             .build(),
diff --git a/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/listener/BadgeCheckListener.java b/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/listener/BadgeCheckListener.java
index c5d65dec..1fd8fa1f 100644
--- a/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/listener/BadgeCheckListener.java
+++ b/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/listener/BadgeCheckListener.java
@@ -18,8 +18,8 @@ import lombok.extern.slf4j.Slf4j;
  *
  * @author pengliang on 2021/4/8
  */
-@Slf4j
-@RocketMqMessageListener(groupId = BadgeCheckSink.INPUT, tag = BadgeCheckSink.TAG)
+//@Slf4j
+//@RocketMqMessageListener(groupId = BadgeCheckSink.INPUT, tag = BadgeCheckSink.TAG)
 @RequiredArgsConstructor
 public class BadgeCheckListener implements MessageListener {