From 0ac99b00750579e65aed767324629f65f7071482 Mon Sep 17 00:00:00 2001
From: tianfeng <769204422@qq.com>
Date: Mon, 24 Nov 2025 14:18:41 +0800
Subject: [PATCH] test update

---
 .../test/java/badge/BatchSendBadgeTest.java   | 28 ++++++++++++++-----
 1 file changed, 21 insertions(+), 7 deletions(-)

diff --git a/rc-service/rc-service-other/other-start/src/test/java/badge/BatchSendBadgeTest.java b/rc-service/rc-service-other/other-start/src/test/java/badge/BatchSendBadgeTest.java
index ce47188b..2431889d 100644
--- a/rc-service/rc-service-other/other-start/src/test/java/badge/BatchSendBadgeTest.java
+++ b/rc-service/rc-service-other/other-start/src/test/java/badge/BatchSendBadgeTest.java
@@ -72,10 +72,10 @@ public class BatchSendBadgeTest {
 //            sendHostAndAgencyBadges(executor);
 
             // 2. 批量发放BD LEADER勋章
-//            sendBdLeaderBadges(executor);
+            sendBdLeaderBadges(executor);
 
             // 3. 批量发放BD勋章
-            sendBdBadges(executor);
+//            sendBdBadges(executor);
 
             // 4. 批量发放管理员勋章
 //            sendAdminBadges(executor);
@@ -167,6 +167,13 @@ public class BatchSendBadgeTest {
         List<RoomBdLead> list = roomBdLeadService.list();
         log.info("开始发放BD Leader勋章，总数: {}", list.size());
 
+        BadgeConfig bdLeaderConfig = badgeConfigService.getByBadgeKey(BadgeKeyEnum.BD_LEADER.name());
+        if (bdLeaderConfig == null) {
+            log.error("{}徽章不存在", BadgeKeyEnum.BD_LEADER.name());
+            return;
+        }
+
+
         AtomicInteger counter = new AtomicInteger(0);
 
         list.forEach(bdLead -> {
@@ -174,11 +181,18 @@ public class BatchSendBadgeTest {
                 try {
                     Long userId = bdLead.getUserId();
 
-                    userMqMessageService.sendBadgeOperateEvent(
-                        userId,
-                        BadgeKeyEnum.BD_LEADER.name(),
-                        BadgeOperateEvent.OperationType.WEAR.name()
-                    );
+                    BadgeBackpack existBadge = badgeBackpackService.query()
+                            .eq(BadgeBackpack::getUserId, userId)
+                            .eq(BadgeBackpack::getBadgeId, bdLeaderConfig.getId())
+                            .getOne();
+                    if (existBadge == null) {
+                        // 发放BD勋章
+                        userMqMessageService.sendBadgeOperateEvent(
+                                userId,
+                                BadgeKeyEnum.BD_LEADER.name(),
+                                BadgeOperateEvent.OperationType.WEAR.name()
+                        );
+                    }
 
                     int count = counter.incrementAndGet();
                     if (count % 100 == 0) {