diff --git a/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/room/RoomMemberChangeIdentityCmdExe.java b/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/room/RoomMemberChangeIdentityCmdExe.java index 77ffeb78..77ecfdef 100644 --- a/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/room/RoomMemberChangeIdentityCmdExe.java +++ b/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); // 判断成员上限 diff --git a/rc-service/rc-service-wallet/wallet-application/src/main/java/com/red/circle/wallet/app/listener/WalletAssetSyncListenerV2.java b/rc-service/rc-service-wallet/wallet-application/src/main/java/com/red/circle/wallet/app/listener/WalletAssetSyncListenerV2.java index 72eaaa06..d1d8f432 100644 --- a/rc-service/rc-service-wallet/wallet-application/src/main/java/com/red/circle/wallet/app/listener/WalletAssetSyncListenerV2.java +++ b/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;