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:07:25 +08:00
parent 1f5717f090
commit 9a294dc08a
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -137,11 +137,11 @@ public class UserHeartbeatListener implements MessageListener {
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();
Set<RoomUserRolesEnum> collect = body.values().stream() long onlineCount = body.entrySet().stream()
.filter(roleEnum -> !RoomUserRolesEnum.TOURIST.equals(roleEnum)) .filter(e -> !RoomUserRolesEnum.TOURIST.equals(e.getValue()))
.collect(Collectors.toSet()); .count();
handleOnlineUserCountTask(event.getUserId(), collect.size()); handleOnlineUserCountTask(event.getUserId(), (int) onlineCount);
} else { } else {
// 在他人房间活跃 // 在他人房间活跃
if (!tryAcquireMinuteTick(event.getUserId())) { if (!tryAcquireMinuteTick(event.getUserId())) {