diff --git a/README.md b/README.md index 6190e26..a3cae1b 100644 --- a/README.md +++ b/README.md @@ -47,7 +47,8 @@ https://www.yuque.com/u1475064/imk5n2/qtezcg32q1d0dr29#SbvXq #### 付费服务 -商业版: https://www.yuque.com/u1475064/imk5n2/qtezcg32q1d0dr29 +商业版授权: https://www.yuque.com/u1475064/imk5n2/qtezcg32q1d0dr29 +付费代部署: https://www.yuque.com/u1475064/imk5n2/qgq5cvgmavallqnl #### 项目结构 | 模块 | 功能 | diff --git a/im-platform/src/main/java/com/bx/implatform/service/impl/GroupMessageServiceImpl.java b/im-platform/src/main/java/com/bx/implatform/service/impl/GroupMessageServiceImpl.java index 0dde1fe..5ea3e1f 100644 --- a/im-platform/src/main/java/com/bx/implatform/service/impl/GroupMessageServiceImpl.java +++ b/im-platform/src/main/java/com/bx/implatform/service/impl/GroupMessageServiceImpl.java @@ -145,22 +145,22 @@ public class GroupMessageServiceImpl extends ServiceImpl loadOffineMessage(Long minId) { UserSession session = SessionContext.getSession(); + List messages = new ArrayList<>(); // 查询用户加入的群组 List members = groupMemberService.findByUserId(session.getUserId()); Map groupMemberMap = CollStreamUtil.toIdentityMap(members, GroupMember::getGroupId); Set groupIds = groupMemberMap.keySet(); - if (groupIds.isEmpty()) { - return Collections.EMPTY_LIST; - } // 只能拉取最近30天的消息 Date minDate = DateUtils.addDays(new Date(), Math.toIntExact(-Constant.MAX_OFFLINE_MESSAGE_DAYS)); - LambdaQueryWrapper wrapper = Wrappers.lambdaQuery(); - wrapper.gt(GroupMessage::getId, minId); - wrapper.gt(GroupMessage::getSendTime, minDate); - wrapper.in(GroupMessage::getGroupId, groupIds); - wrapper.orderByDesc(GroupMessage::getId); - wrapper.last("limit 50000"); - List messages = this.list(wrapper); + if(!groupIds.isEmpty()) { + LambdaQueryWrapper wrapper = Wrappers.lambdaQuery(); + wrapper.gt(GroupMessage::getId, minId); + wrapper.gt(GroupMessage::getSendTime, minDate); + wrapper.in(GroupMessage::getGroupId, groupIds); + wrapper.orderByDesc(GroupMessage::getId); + wrapper.last("limit 50000"); + messages = this.list(wrapper); + } // 查询退群前的消息 Date minQuitTime = minDate; if (minId > 0) { @@ -172,7 +172,7 @@ public class GroupMessageServiceImpl extends ServiceImpl quitMembers = groupMemberService.findQuitMembers(session.getUserId(), minQuitTime); for (GroupMember quitMember : quitMembers) { - wrapper = Wrappers.lambdaQuery(); + LambdaQueryWrapper wrapper = Wrappers.lambdaQuery(); wrapper.gt(GroupMessage::getId, minId); wrapper.between(GroupMessage::getSendTime, minDate, quitMember.getQuitTime()); wrapper.eq(GroupMessage::getGroupId, quitMember.getGroupId()); diff --git a/im-uniapp/components/chat-message-item/chat-message-item.vue b/im-uniapp/components/chat-message-item/chat-message-item.vue index dbcecc3..1574785 100644 --- a/im-uniapp/components/chat-message-item/chat-message-item.vue +++ b/im-uniapp/components/chat-message-item/chat-message-item.vue @@ -30,7 +30,7 @@ - + @@ -43,7 +43,7 @@ {{ fileSize }} - + @@ -66,7 +66,7 @@ - + diff --git a/im-uniapp/components/loading/loading.vue b/im-uniapp/components/custom-loading/custom-loading.vue similarity index 96% rename from im-uniapp/components/loading/loading.vue rename to im-uniapp/components/custom-loading/custom-loading.vue index b0f0c98..5845661 100644 --- a/im-uniapp/components/loading/loading.vue +++ b/im-uniapp/components/custom-loading/custom-loading.vue @@ -7,6 +7,7 @@