zouxuan 2 年 前
コミット
b6d9772e28

+ 4 - 1
cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/service/impl/ImServiceImpl.java

@@ -100,8 +100,11 @@ public class ImServiceImpl implements ImService {
     @Override
     public void sendDisplay(String imUserId, ImNetworkRoom room,String serviceProvider) throws Exception {
         // IM发送用户消息
+        RoleEnum roleEnum = RoleEnum.valueOf(imGroupService.analysisImUserClient(imUserId));
         ImNetworkRoomMember roomMember = imNetworkRoomMemberService.lambdaQuery().eq(ImNetworkRoomMember::getUserId, imUserId)
-                .eq(ImNetworkRoomMember::getRoomId, room.getRoomId()).last("LIMIT 1").one();
+                .eq(ImNetworkRoomMember::getRoomId, room.getRoomId())
+                .eq(ImNetworkRoomMember::getRole,roleEnum.getValue())
+                .last("LIMIT 1").one();
         if (TencentCloudRTCPlugin.PLUGIN_NAME.equals(serviceProvider) || StringUtils.isEmpty(serviceProvider)) {
             // 获取RTC服务提供方
             RTCRoomPluginService pluginService = rtcRoomPluginContext.getPluginService(TencentCloudRTCPlugin.PLUGIN_NAME);