红包飘窗增加房间和红包ID

This commit is contained in:
tianfeng 2025-11-26 16:04:47 +08:00
parent 457db418eb
commit 4709b6f535

View File

@ -95,7 +95,7 @@ public class SendRoomRedPacketCmdExe {
); );
// 发送飘窗通知 // 发送飘窗通知
sendMessage(cmd); sendMessage(cmd, packetId);
log.info("发红包成功 userId={} packetId={} roomId={} type={} amount={} count={}", log.info("发红包成功 userId={} packetId={} roomId={} type={} amount={} count={}",
userId, packetId, cmd.getRoomId(), cmd.getPacketType(), userId, packetId, cmd.getRoomId(), cmd.getPacketType(),
@ -104,12 +104,14 @@ public class SendRoomRedPacketCmdExe {
return RoomRedPacketAppConvertor.toCO(redPacket); return RoomRedPacketAppConvertor.toCO(redPacket);
} }
private void sendMessage(SendRoomRedPacketCmd cmd) { private void sendMessage(SendRoomRedPacketCmd cmd, String packetId) {
try { try {
String roomAccount = roomProfileManagerService.getRoomAccount(cmd.getRoomId()); String roomAccount = roomProfileManagerService.getRoomAccount(cmd.getRoomId());
UserProfileDTO userProfile = userProfileAppConvertor.toUserProfileDTO(userProfileGateway.getByUserId(cmd.getReqUserId())); UserProfileDTO userProfile = userProfileAppConvertor.toUserProfileDTO(userProfileGateway.getByUserId(cmd.getReqUserId()));
Map<Object, Object> build = OfficialNoticeUtils.buildUserProfile(userProfile); Map<Object, Object> build = OfficialNoticeUtils.buildUserProfile(userProfile);
build.put("roomAccount", roomAccount); build.put("roomAccount", roomAccount);
build.put("roomId", String.valueOf(cmd.getRoomId()));
build.put("packetId", packetId);
if (cmd.getTotalAmount() >= 10000) { if (cmd.getTotalAmount() >= 10000) {
imGroupClient.sendMessageBroadcast( imGroupClient.sendMessageBroadcast(