From 00658d20493d9f75dfa6f19af1705a836fd125b5 Mon Sep 17 00:00:00 2001 From: tianfeng <769204422@qq.com> Date: Tue, 12 May 2026 19:32:36 +0800 Subject: [PATCH] =?UTF-8?q?=E6=88=BF=E9=97=B4=E6=88=90=E5=91=98=E6=96=B0?= =?UTF-8?q?=E5=A2=9E=20=E8=B4=A2=E5=AF=8C=E9=AD=85=E5=8A=9B=E7=AD=89?= =?UTF-8?q?=E7=BA=A7-=E4=BF=AE=E5=A4=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../app/dto/clientobject/LiveMicUserCO.java | 5 +++++ .../repository/LiveMicrophoneGatewayImpl.java | 17 ++++++++++++++--- 2 files changed, 19 insertions(+), 3 deletions(-) diff --git a/rc-service/rc-service-live/live-client/src/main/java/com/red/circle/live/app/dto/clientobject/LiveMicUserCO.java b/rc-service/rc-service-live/live-client/src/main/java/com/red/circle/live/app/dto/clientobject/LiveMicUserCO.java index d42f6aee..2091dadb 100644 --- a/rc-service/rc-service-live/live-client/src/main/java/com/red/circle/live/app/dto/clientobject/LiveMicUserCO.java +++ b/rc-service/rc-service-live/live-client/src/main/java/com/red/circle/live/app/dto/clientobject/LiveMicUserCO.java @@ -69,6 +69,11 @@ public class LiveMicUserCO implements Serializable { */ private String roles; + /** + * 财富经验-等级. + */ + private Integer wealthLevel; + /** * 魅力等级. */ diff --git a/rc-service/rc-service-live/live-infrastructure/src/main/java/com/red/circle/live/infra/repository/LiveMicrophoneGatewayImpl.java b/rc-service/rc-service-live/live-infrastructure/src/main/java/com/red/circle/live/infra/repository/LiveMicrophoneGatewayImpl.java index 05349842..8ec2d2f2 100644 --- a/rc-service/rc-service-live/live-infrastructure/src/main/java/com/red/circle/live/infra/repository/LiveMicrophoneGatewayImpl.java +++ b/rc-service/rc-service-live/live-infrastructure/src/main/java/com/red/circle/live/infra/repository/LiveMicrophoneGatewayImpl.java @@ -151,10 +151,21 @@ public class LiveMicrophoneGatewayImpl implements LiveMicrophoneGateway { //获取房间用户心动值 Map liveHeartbeatMap = getLiveHeartbeatMap(liveHeartbeatClient.listLiveHeartbeat(roomId).getBody()); + List body = userLevelClient.getUsersLevel(SysOriginPlatformEnum.ATYOU, userIds.stream().toList()).getBody(); + Map levelDTOMap = body.stream() + .collect(Collectors.toMap(WealthAndCharmLevelDTO::getUserId, v -> v, (v1, v2) -> v1)); - return micUsers.stream().peek(mickUser -> - mickUser.setRoles(Objects.toString(Optional.ofNullable(roomUserRoles.get(mickUser.getId())).orElse(RoomUserRolesEnum.TOURIST))) - .setHeartbeatVal(Objects.nonNull(liveHeartbeatMap.get(mickUser.getId())) ? liveHeartbeatMap.get(mickUser.getId()) : 0L)) + return micUsers.stream().map(mickUser -> { + WealthAndCharmLevelDTO levelDTO = levelDTOMap.get(mickUser.getId()); + LiveMicUser liveMicUser = mickUser.setRoles(Objects.toString(Optional.ofNullable(roomUserRoles.get(mickUser.getId())).orElse(RoomUserRolesEnum.TOURIST))) + .setHeartbeatVal(Objects.nonNull(liveHeartbeatMap.get(mickUser.getId())) ? liveHeartbeatMap.get(mickUser.getId()) : 0L); + if (Objects.nonNull(liveMicUser)) { + liveMicUser.setCharmLevel(levelDTO.getCharmLevel()); + liveMicUser.setWealthLevel(levelDTO.getWealthLevel()); + } + + return liveMicUser; + }) .collect(Collectors.toMap(LiveMicUser::getId, v -> v)); }