房间在线用户增加过期时间校验

This commit is contained in:
tianfeng 2025-12-25 19:42:26 +08:00
parent 66a6880735
commit ffbef39f05

View File

@ -6,6 +6,7 @@ import com.red.circle.other.infra.database.mongo.dto.query.user.status.OnlineUse
import com.red.circle.other.infra.database.mongo.dto.query.user.status.OnlineUserQuery; import com.red.circle.other.infra.database.mongo.dto.query.user.status.OnlineUserQuery;
import com.red.circle.other.infra.database.mongo.entity.user.status.OnlineUser; import com.red.circle.other.infra.database.mongo.entity.user.status.OnlineUser;
import com.red.circle.other.infra.database.mongo.service.user.status.OnlineUserService; import com.red.circle.other.infra.database.mongo.service.user.status.OnlineUserService;
import com.red.circle.tool.core.date.TimestampUtils;
import com.red.circle.tool.core.text.StringUtils; import com.red.circle.tool.core.text.StringUtils;
import com.red.circle.other.inner.model.cmd.user.OnlineCountQryCmd; import com.red.circle.other.inner.model.cmd.user.OnlineCountQryCmd;
import com.red.circle.other.inner.model.cmd.user.OnlineUserBackQryCmd; import com.red.circle.other.inner.model.cmd.user.OnlineUserBackQryCmd;
@ -287,7 +288,9 @@ public class OnlineUserServiceImpl implements OnlineUserService {
@Override @Override
public List<OnlineUser> userOnlineByUserIds(Set<Long> userIds) { public List<OnlineUser> userOnlineByUserIds(Set<Long> userIds) {
Criteria criteria = Criteria.where("userId").in(userIds) Criteria criteria = Criteria.where("userId").in(userIds)
.and("status").is(UserOnlineStatusEnum.LANGUAGE_HALL); .and("status").is(UserOnlineStatusEnum.LANGUAGE_HALL)
.and("expiredTime").gte(TimestampUtils.now())
;
return mongoTemplate.find(Query.query(criteria) return mongoTemplate.find(Query.query(criteria)
.limit(200), OnlineUser.class); .limit(200), OnlineUser.class);
} }