|
@ -516,8 +516,24 @@ public class ResiTopicServiceImpl extends BaseServiceImpl<ResiTopicDao, ResiTopi |
|
|
if (null != pastTopics && pastTopics.size() > 0) { |
|
|
if (null != pastTopics && pastTopics.size() > 0) { |
|
|
|
|
|
|
|
|
//2. 在缓存中拉取用户信息
|
|
|
//2. 在缓存中拉取用户信息
|
|
|
setCacheUserInfoWithIssue(topicPageFormDTO.getGroupId(), pastTopics); |
|
|
// setCacheUserInfoWithIssue(topicPageFormDTO.getGroupId(), pastTopics);
|
|
|
|
|
|
ResiGroupEntity resiGroup = resiGroupDao.selectById(topicPageFormDTO.getGroupId()); |
|
|
|
|
|
if(null == resiGroup){ |
|
|
|
|
|
throw new RenException("此小组信息不存在"); |
|
|
|
|
|
} |
|
|
|
|
|
List<String> userIds = pastTopics.stream().map(m -> m.getUserId()).collect(Collectors.toList()); |
|
|
|
|
|
List<UserInfoResultDTO> userInfos = disPoseUserInfo(resiGroup.getGroupType(), userIds); |
|
|
|
|
|
if (CollectionUtils.isEmpty(userInfos)){ |
|
|
|
|
|
throw new RenException("未查询到用户信息"); |
|
|
|
|
|
} |
|
|
|
|
|
pastTopics.forEach(t -> { |
|
|
|
|
|
userInfos.forEach(u -> { |
|
|
|
|
|
if (t.getUserId().equals(u.getUserId())){ |
|
|
|
|
|
t.setReleaseUserName(u.getReleaseUserName()); |
|
|
|
|
|
t.setReleaseUserHeadPhoto(u.getReleaseUserHeadPhoto()); |
|
|
|
|
|
} |
|
|
|
|
|
}); |
|
|
|
|
|
}); |
|
|
//3.用户徽章
|
|
|
//3.用户徽章
|
|
|
//3.1首先需要拿到客户Id
|
|
|
//3.1首先需要拿到客户Id
|
|
|
List<String> other = pastTopics.stream() |
|
|
List<String> other = pastTopics.stream() |
|
|