|
|
|
@ -206,12 +206,16 @@ public class GroupMessageServiceImpl extends ServiceImpl<GroupMessageMapper, Gro |
|
|
|
if(!imClient.isOnline(session.getUserId())){ |
|
|
|
throw new GlobalException(ResultCode.PROGRAM_ERROR, "网络连接失败,无法拉取离线消息"); |
|
|
|
} |
|
|
|
// 开启加载中标志
|
|
|
|
this.sendLoadingMessage(true); |
|
|
|
|
|
|
|
// 查询用户加入的群组
|
|
|
|
List<GroupMember> members = groupMemberService.findByUserId(session.getUserId()); |
|
|
|
Map<Long, GroupMember> groupMemberMap = CollStreamUtil.toIdentityMap(members, GroupMember::getGroupId); |
|
|
|
Set<Long> groupIds = groupMemberMap.keySet(); |
|
|
|
if(CollectionUtil.isEmpty(groupIds)){ |
|
|
|
return; |
|
|
|
} |
|
|
|
// 开启加载中标志
|
|
|
|
this.sendLoadingMessage(true); |
|
|
|
// 只能拉取最近1个月的,最多拉取1000条
|
|
|
|
Date minDate = DateUtils.addMonths(new Date(), -1); |
|
|
|
LambdaQueryWrapper<GroupMessage> wrapper = Wrappers.lambdaQuery(); |
|
|
|
|