diff --git a/mallchat-chat-server/src/main/java/com/abin/mallchat/common/chat/service/impl/RoomAppServiceImpl.java b/mallchat-chat-server/src/main/java/com/abin/mallchat/common/chat/service/impl/RoomAppServiceImpl.java index a4cf2b7..5a0cfd7 100644 --- a/mallchat-chat-server/src/main/java/com/abin/mallchat/common/chat/service/impl/RoomAppServiceImpl.java +++ b/mallchat-chat-server/src/main/java/com/abin/mallchat/common/chat/service/impl/RoomAppServiceImpl.java @@ -222,7 +222,7 @@ public class RoomAppServiceImpl implements RoomAppService { AssertUtil.isNotEmpty(self, "您不是群成员"); List memberBatch = groupMemberDao.getMemberBatch(roomGroup.getId(), request.getUidList()); Set existUid = new HashSet<>(memberBatch); - List waitAddUidList = request.getUidList().stream().filter(a -> !existUid.contains(a)).collect(Collectors.toList()); + List waitAddUidList = request.getUidList().stream().filter(a -> !existUid.contains(a)).distinct().collect(Collectors.toList()); if (CollectionUtils.isEmpty(waitAddUidList)) { return; } @@ -350,7 +350,6 @@ public class RoomAppServiceImpl implements RoomAppService { return userBatch.get(friendUid); })); } - private Map getRoomBaseInfoMap(List roomIds, Long uid) { Map roomMap = roomCache.getBatch(roomIds); //房间根据好友和群组类型分组