diff --git a/accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/user/UserInRoomService.java b/accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/user/UserInRoomService.java index ff489f129..cce5b61b9 100644 --- a/accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/user/UserInRoomService.java +++ b/accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/user/UserInRoomService.java @@ -34,7 +34,6 @@ import org.springframework.context.annotation.Lazy; import org.springframework.stereotype.Service; import java.util.*; -import java.util.stream.Collectors; /** * Created by liuguofu on 2017/10/17. @@ -139,14 +138,19 @@ public class UserInRoomService { } public Map getUserInRoomMapBatchCache(List uids) { - uids = uids.stream().filter(StringUtils::isNotBlank).distinct().collect(Collectors.toList()); - return uids.stream().map(uid -> { + Map resultMap = new HashMap<>(); + for (String uid : uids) { + if (StringUtils.isBlank(uid)) { + continue; + } String roomVoStr = jedisService.hget(RedisKey.user_in_room.getKey(), uid); if (StringUtils.isBlank(roomVoStr)){ return null; } - return GsonUtil.getDefGson().fromJson(roomVoStr, RoomVo.class); - }).filter(Objects::nonNull).collect(Collectors.toMap(RoomVo::getUid, roomVo -> roomVo)); + RoomVo roomVo = GsonUtil.getDefGson().fromJson(roomVoStr, RoomVo.class); + resultMap.put(Long.valueOf(uid), roomVo); + } + return resultMap; } public void updateUserInRoomRecord(Long uid, Long roomUid, Byte behaveType) {