金币同步消息冗余逻辑优化

rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/room/RoomMemberChangeIdentityCmdExe.java

@@ -210,7 +210,6 @@ public class RoomMemberChangeIdentityCmdExe {
     }
 
     incrQuantity(cmd.getRoomId(), cmd.getRoles());
-    sendBadgeEventMessage(cmd.getRoomId());
   }
 
   private void executeChangeTourist(RoomMember roomMember) {
@@ -239,15 +238,6 @@ public class RoomMemberChangeIdentityCmdExe {
     roomProfileManagerService.incrCounterMember(roomId);
   }
 
-  private void sendBadgeEventMessage(Long roomId) {
-    RoomProfile roomProfile = roomProfileManagerService.getProfileById(roomId);
-    // 房间不存在
-    ResponseAssert.notNull(RoomErrorCode.ROOM_NOT_EXISTS, roomProfile);
-    userMqMessageService
-        .sendBadgeEvent(roomProfile.getUserId(),
-            BadgeKeyEnum.HOT_ROOM.name());
-  }
-
   private void checkJoinMaxMember(Long roomId, RoomUserRolesEnum roles) {
     RoomProfileManager manager = roomProfileManagerService.getById(roomId);
     // 判断成员上限

rc-service/rc-service-wallet/wallet-application/src/main/java/com/red/circle/wallet/app/listener/WalletAssetSyncListenerV2.java

@@ -82,12 +82,6 @@ public class WalletAssetSyncListenerV2 implements MessageListener {
                 receipt.getEventType(),
                 receipt.getReceiptType().getType(),
                 receipt.getAmount().getPennyAmount());
-
-            // 房间红包游戏
-            countGameRoomRedPacket(receipt);
-
-            // 统计游戏王数据
-            countGameKing20240420(receipt);
           }
         });
     long processTime = System.currentTimeMillis() - startTime;