|
|
@ -1555,12 +1555,14 @@ public class IssueServiceImpl extends BaseServiceImpl<IssueDao, IssueEntity> imp |
|
|
|
if (!CollectionUtils.isEmpty(votedCount)){ |
|
|
|
userIds.addAll(votedCount); |
|
|
|
} |
|
|
|
// 话题创建者
|
|
|
|
Result<String> topicCreatedUser = resiGroupOpenFeignClient.topicCreatedUser(issueEntity.getSourceId()); |
|
|
|
if (!topicCreatedUser.success()){ |
|
|
|
throw new RenException("【查询话题创建者失败】["+topicCreatedUser.getMsg()+"]"); |
|
|
|
if("resi_topic".equals(issueEntity.getSourceType())){ |
|
|
|
// 话题创建者
|
|
|
|
Result<String> topicCreatedUser = resiGroupOpenFeignClient.topicCreatedUser(issueEntity.getSourceId()); |
|
|
|
if (!topicCreatedUser.success()){ |
|
|
|
throw new RenException("【查询话题创建者失败】["+topicCreatedUser.getMsg()+"]"); |
|
|
|
} |
|
|
|
userIds.add(topicCreatedUser.getData()); |
|
|
|
} |
|
|
|
userIds.add(topicCreatedUser.getData()); |
|
|
|
// 去重
|
|
|
|
return userIds.stream().distinct().collect(Collectors.toList()); |
|
|
|
} |
|
|
|