uid去重
This commit is contained in:
@@ -26,14 +26,12 @@ import com.accompany.core.service.user.UsersBaseService;
|
||||
import com.accompany.core.util.StringUtils;
|
||||
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
||||
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
||||
import com.google.common.collect.Maps;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.apache.commons.collections.CollectionUtils;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.context.ApplicationContext;
|
||||
import org.springframework.context.annotation.Lazy;
|
||||
import org.springframework.stereotype.Service;
|
||||
import redis.clients.jedis.Response;
|
||||
|
||||
import java.util.*;
|
||||
import java.util.stream.Collectors;
|
||||
@@ -141,6 +139,7 @@ public class UserInRoomService {
|
||||
}
|
||||
|
||||
public Map<Long, RoomVo> getUserInRoomMapBatchCache(List<String> uids) {
|
||||
uids = uids.stream().filter(StringUtils::isNotBlank).distinct().collect(Collectors.toList());
|
||||
return uids.stream().map(uid -> {
|
||||
String roomVoStr = jedisService.hget(RedisKey.user_in_room.getKey(), uid);
|
||||
if (StringUtils.isBlank(roomVoStr)){
|
||||
|
Reference in New Issue
Block a user