From c671893bd3fc3cbb32216b669dfbdb59052d5f03 Mon Sep 17 00:00:00 2001 From: zhongzb <972627721@qq.com> Date: Thu, 14 Sep 2023 22:46:19 +0800 Subject: [PATCH] =?UTF-8?q?fix:=E8=A7=A3=E5=86=B3=E4=BC=9A=E8=AF=9D?= =?UTF-8?q?=E5=88=97=E8=A1=A8=E6=8E=A8=E6=8B=89=E7=BB=93=E5=90=88=E9=97=AE?= =?UTF-8?q?=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../common/chat/service/impl/RoomAppServiceImpl.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) 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());