diff --git a/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/redpacket/SendRoomRedPacketCmdExe.java b/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/redpacket/SendRoomRedPacketCmdExe.java index 0d83eb8d..c29a423a 100644 --- a/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/redpacket/SendRoomRedPacketCmdExe.java +++ b/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/redpacket/SendRoomRedPacketCmdExe.java @@ -95,7 +95,7 @@ public class SendRoomRedPacketCmdExe { ); // 发送飘窗通知 - sendMessage(cmd); + sendMessage(cmd, packetId); log.info("发红包成功 userId={} packetId={} roomId={} type={} amount={} count={}", userId, packetId, cmd.getRoomId(), cmd.getPacketType(), @@ -104,12 +104,14 @@ public class SendRoomRedPacketCmdExe { return RoomRedPacketAppConvertor.toCO(redPacket); } - private void sendMessage(SendRoomRedPacketCmd cmd) { + private void sendMessage(SendRoomRedPacketCmd cmd, String packetId) { try { String roomAccount = roomProfileManagerService.getRoomAccount(cmd.getRoomId()); UserProfileDTO userProfile = userProfileAppConvertor.toUserProfileDTO(userProfileGateway.getByUserId(cmd.getReqUserId())); Map build = OfficialNoticeUtils.buildUserProfile(userProfile); build.put("roomAccount", roomAccount); + build.put("roomId", String.valueOf(cmd.getRoomId())); + build.put("packetId", packetId); if (cmd.getTotalAmount() >= 10000) { imGroupClient.sendMessageBroadcast(