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-03-05 21:02:53 +08:00
parent 75b1fb5dc6
commit 1f5717f090
1 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
rc-service/rc-service-live/live-application/src/main/java/com/red/circle/live/app/listener/UserHeartbeatListener.java
View File

@ -126,7 +126,14 @@ public class UserHeartbeatListener implements MessageListener {
// 房间内同时在线用户数 // 房间内同时在线用户数
if (Objects.equals(roomProfile.getUserId(), event.getUserId())) { if (Objects.equals(roomProfile.getUserId(), event.getUserId())) {
List<LiveRoomUser> liveRoomUsers = liveMicUserCacheService.listUser(roomProfile.getId()); List<LiveRoomUser> liveRoomUsers = liveMicUserCacheService.listUser(roomProfile.getId());
Set<Long> userIdList = liveRoomUsers.stream().map(LiveRoomUser::getUserId).collect(Collectors.toSet()); Set<Long> userIdList = liveRoomUsers.stream()
.map(LiveRoomUser::getUserId)
.filter(userId -> !userId.equals(roomProfile.getUserId()))
.collect(Collectors.toSet());
if (CollectionUtils.isEmpty(userIdList)) {
return;
}
MemberRolesQryCmd roleQry = new MemberRolesQryCmd().setRoomId(roomId).setUserIds(userIdList); MemberRolesQryCmd roleQry = new MemberRolesQryCmd().setRoomId(roomId).setUserIds(userIdList);
Map<Long, RoomUserRolesEnum> body = roomMemberClient.mapMemberRoles(roleQry).getBody(); Map<Long, RoomUserRolesEnum> body = roomMemberClient.mapMemberRoles(roleQry).getBody();