From e0be58ec2cc7a75cde72081f64069e890a951b08 Mon Sep 17 00:00:00 2001
From: tianfeng <769204422@qq.com>
Date: Tue, 12 May 2026 19:03:20 +0800
Subject: [PATCH] =?UTF-8?q?live=20=E7=94=A8=E6=88=B7=E5=88=97=E8=A1=A8?=
 =?UTF-8?q?=E6=96=B0=E5=A2=9E=20=E8=B4=A2=E5=AF=8C=E7=AD=89=E7=BA=A7?=
 =?UTF-8?q?=E5=AD=97=E6=AE=B5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/red/circle/live/domain/live/LiveMicUser.java | 5 +++++
 .../live/infra/repository/LiveMicrophoneGatewayImpl.java  | 8 ++++++--
 2 files changed, 11 insertions(+), 2 deletions(-)

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());
           }
       }
   }