hy/aslan-server
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

房间成员新增 财富魅力等级-修复

Browse Source
This commit is contained in:
tianfeng 2026-05-12 19:32:36 +08:00
parent b288fe86a9
commit 00658d2049
2 changed files with 19 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
rc-service/rc-service-live/live-client/src/main/java/com/red/circle/live/app/dto/clientobject/LiveMicUserCO.java
View File

@ -69,6 +69,11 @@ public class LiveMicUserCO implements Serializable {
*/ */
private String roles; private String roles;
/**
* 财富经验-等级.
*/
private Integer wealthLevel;
/** /**
* 魅力等级. * 魅力等级.
*/ */

17
rc-service/rc-service-live/live-infrastructure/src/main/java/com/red/circle/live/infra/repository/LiveMicrophoneGatewayImpl.java
View File

@ -151,10 +151,21 @@ public class LiveMicrophoneGatewayImpl implements LiveMicrophoneGateway {
//获取房间用户心动值 //获取房间用户心动值
Map<Long, Long> liveHeartbeatMap = getLiveHeartbeatMap(liveHeartbeatClient.listLiveHeartbeat(roomId).getBody()); Map<Long, Long> liveHeartbeatMap = getLiveHeartbeatMap(liveHeartbeatClient.listLiveHeartbeat(roomId).getBody());
List<WealthAndCharmLevelDTO> body = userLevelClient.getUsersLevel(SysOriginPlatformEnum.ATYOU, userIds.stream().toList()).getBody();
Map<Long, WealthAndCharmLevelDTO> levelDTOMap = body.stream()
.collect(Collectors.toMap(WealthAndCharmLevelDTO::getUserId, v -> v, (v1, v2) -> v1));
return micUsers.stream().peek(mickUser -> return micUsers.stream().map(mickUser -> {
mickUser.setRoles(Objects.toString(Optional.ofNullable(roomUserRoles.get(mickUser.getId())).orElse(RoomUserRolesEnum.TOURIST))) WealthAndCharmLevelDTO levelDTO = levelDTOMap.get(mickUser.getId());
.setHeartbeatVal(Objects.nonNull(liveHeartbeatMap.get(mickUser.getId())) ? liveHeartbeatMap.get(mickUser.getId()) : 0L)) 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)); .collect(Collectors.toMap(LiveMicUser::getId, v -> v));
} }