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 a3a2791..9bd4d9a 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 @@ -99,11 +99,13 @@ public class RoomAppServiceImpl implements RoomAppService { CursorPageBaseResp page; if (Objects.nonNull(uid)) { Double hotEnd = getCursorOrNull(request.getCursor()); - Double hotStart; + Double hotStart = null; //用户基础会话 CursorPageBaseResp contactPage = contactDao.getContactPage(uid, request); List baseRoomIds = contactPage.getList().stream().map(Contact::getRoomId).collect(Collectors.toList()); - hotStart = getCursorOrNull(contactPage.getCursor()); + if (!contactPage.getIsLast()) { + hotStart = getCursorOrNull(contactPage.getCursor()); + } //热门房间 Set> typedTuples = hotRoomCache.getRoomRange(hotStart, hotEnd); List hotRoomIds = typedTuples.stream().map(ZSetOperations.TypedTuple::getValue).filter(Objects::nonNull).map(Long::parseLong).collect(Collectors.toList());