From c5a8afa03d4f3fcd0b08a34d0a8a8a09b47741e4 Mon Sep 17 00:00:00 2001 From: tianfeng <769204422@qq.com> Date: Tue, 7 Apr 2026 19:03:45 +0800 Subject: [PATCH] =?UTF-8?q?=E5=9C=A8=E7=BA=BF=E7=94=A8=E6=88=B7=E5=88=97?= =?UTF-8?q?=E8=A1=A8=E6=8E=A5=E5=8F=A3=E4=BF=AE=E5=A4=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit (cherry picked from commit f4183cd27458d1068298f70287d7d3d2cecc6044) --- .../mongo/service/user/status/impl/OnlineUserServiceImpl.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/rc-service/rc-service-other/other-infrastructure/src/main/java/com/red/circle/other/infra/database/mongo/service/user/status/impl/OnlineUserServiceImpl.java b/rc-service/rc-service-other/other-infrastructure/src/main/java/com/red/circle/other/infra/database/mongo/service/user/status/impl/OnlineUserServiceImpl.java index 8457b5f9..c99a1903 100644 --- a/rc-service/rc-service-other/other-infrastructure/src/main/java/com/red/circle/other/infra/database/mongo/service/user/status/impl/OnlineUserServiceImpl.java +++ b/rc-service/rc-service-other/other-infrastructure/src/main/java/com/red/circle/other/infra/database/mongo/service/user/status/impl/OnlineUserServiceImpl.java @@ -205,7 +205,8 @@ public class OnlineUserServiceImpl implements OnlineUserService { public List flowSessionOnlineUser(String sessionId, UserOnlineStatusEnum status, Long lastTimingId) { Criteria criteria = Criteria.where("sessionId").is(Long.parseLong(sessionId)) - .and("status").is(status); + .and("status").is(status) + .and("expiredTime").gte(TimestampUtils.now()); if (Objects.nonNull(lastTimingId)) { criteria.and("timingId").gt(lastTimingId);