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<OnlineUser> 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);