From 1f5717f090664800e1eccbc93bf56b6e3870af04 Mon Sep 17 00:00:00 2001 From: tianfeng <769204422@qq.com> Date: Thu, 5 Mar 2026 21:02:53 +0800 Subject: [PATCH] =?UTF-8?q?=E5=90=8C=E6=97=B6=E5=9C=A8=E7=BA=BF=E7=94=A8?= =?UTF-8?q?=E6=88=B7=E6=8E=92=E9=99=A4=E6=88=BF=E4=B8=BB?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../circle/live/app/listener/UserHeartbeatListener.java | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/rc-service/rc-service-live/live-application/src/main/java/com/red/circle/live/app/listener/UserHeartbeatListener.java b/rc-service/rc-service-live/live-application/src/main/java/com/red/circle/live/app/listener/UserHeartbeatListener.java index 268f950a..23f538fb 100644 --- a/rc-service/rc-service-live/live-application/src/main/java/com/red/circle/live/app/listener/UserHeartbeatListener.java +++ b/rc-service/rc-service-live/live-application/src/main/java/com/red/circle/live/app/listener/UserHeartbeatListener.java @@ -126,7 +126,14 @@ public class UserHeartbeatListener implements MessageListener { // 房间内同时在线用户数 if (Objects.equals(roomProfile.getUserId(), event.getUserId())) { List liveRoomUsers = liveMicUserCacheService.listUser(roomProfile.getId()); - Set userIdList = liveRoomUsers.stream().map(LiveRoomUser::getUserId).collect(Collectors.toSet()); + Set 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); Map body = roomMemberClient.mapMemberRoles(roleQry).getBody();