diff --git a/rc-service/rc-service-live/live-domain/src/main/java/com/red/circle/live/domain/live/LiveMicUser.java b/rc-service/rc-service-live/live-domain/src/main/java/com/red/circle/live/domain/live/LiveMicUser.java index e8d733e7..39bc63c1 100644 --- a/rc-service/rc-service-live/live-domain/src/main/java/com/red/circle/live/domain/live/LiveMicUser.java +++ b/rc-service/rc-service-live/live-domain/src/main/java/com/red/circle/live/domain/live/LiveMicUser.java @@ -71,6 +71,11 @@ public class LiveMicUser 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 8a40b63e..05349842 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 @@ -180,8 +180,11 @@ public class LiveMicrophoneGatewayImpl implements LiveMicrophoneGateway { LiveMicUser micUser = liveMicrophoneInfraConvertor.toLiveMicUser(userProfile); ResponseAssert.notNull(UserErrorCode.USER_INFO_NOT_FOUND, micUser); micUser.setRoles(Objects.toString(roomMemberClient.getMemberRoles(roomId, userId).getBody())); - micUser.setCharmLevel(userLevelClient.getUserLevel( - SysOriginPlatformEnum.valueOf(roomProfile.getSysOrigin()), userId).getBody().getCharmLevel()); + WealthAndCharmLevelDTO body = userLevelClient.getUserLevel(SysOriginPlatformEnum.valueOf(roomProfile.getSysOrigin()), userId).getBody(); + if (Objects.nonNull(body)) { + micUser.setCharmLevel(body.getCharmLevel()); + micUser.setWealthLevel(body.getWealthLevel()); + } LiveMicrophone liveMicrophone = new LiveMicrophone() .setMicIndex(micSeat.getMicIndex()) @@ -625,6 +628,7 @@ public class LiveMicrophoneGatewayImpl implements LiveMicrophoneGateway { if (Objects.nonNull(wealthAndCharmLevelDTO)) { liveMicrophone.getUser().setCharmLevel(wealthAndCharmLevelDTO.getCharmLevel()); + liveMicrophone.getUser().setWealthLevel(wealthAndCharmLevelDTO.getWealthLevel()); } } }