|
@ -405,31 +405,44 @@ public class IssueServiceImpl implements IssueService { |
|
|
return govIssueFeignClient.processList(issueId).getData(); |
|
|
return govIssueFeignClient.processList(issueId).getData(); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
/** |
|
|
|
|
|
* 居民端议事厅-表决中议题列表 |
|
|
|
|
|
* @param issueListFormDTO |
|
|
|
|
|
* @return |
|
|
|
|
|
*/ |
|
|
@Override |
|
|
@Override |
|
|
public List<VotingIssueListResultDTO> listVotingIssues(CommonIssueListFormDTO issueListFormDTO) { |
|
|
public List<VotingIssueListResultDTO> listVotingIssues(CommonIssueListFormDTO issueListFormDTO) { |
|
|
|
|
|
//1、查询表决中的议题列表,issue.created_time降序
|
|
|
Result<List<VotingIssueListResultDTO>> votingIssueListResult = govIssueFeignClient.votingList(issueListFormDTO); |
|
|
Result<List<VotingIssueListResultDTO>> votingIssueListResult = govIssueFeignClient.votingList(issueListFormDTO); |
|
|
if (!votingIssueListResult.success()) { |
|
|
if (!votingIssueListResult.success()) { |
|
|
throw new RenException(String.format("调用gov-issue查询表决中列表失败")); |
|
|
throw new RenException(String.format("调用gov-issue查询表决中列表失败")); |
|
|
} |
|
|
} |
|
|
List<VotingIssueListResultDTO> votingIssueList = votingIssueListResult.getData(); |
|
|
List<VotingIssueListResultDTO> votingIssueList = votingIssueListResult.getData(); |
|
|
if (votingIssueList != null && !CollectionUtils.isEmpty(votingIssueList)) { |
|
|
if (votingIssueList != null && !CollectionUtils.isEmpty(votingIssueList)) { |
|
|
List<String> topicIds = votingIssueList.stream().map(i -> i.getSourceId()).collect(Collectors.toList()); |
|
|
// 来源于话题的
|
|
|
TopicDetailBatchFormDTO form = new TopicDetailBatchFormDTO(); |
|
|
List<String> topicIds = votingIssueList.stream().filter(t -> t.getSourceType().equals("resi_topic")).map(i -> i.getSourceId()).collect(Collectors.toList()); |
|
|
form.setTopicIdList(topicIds); |
|
|
if (!CollectionUtils.isEmpty(topicIds)) { |
|
|
Result<List<ResiTopicDetailResultDTO>> topicDetailsResult = resiGroupOpenFeignClient.listTopicDetailsByIds(form); |
|
|
TopicDetailBatchFormDTO form = new TopicDetailBatchFormDTO(); |
|
|
if (!topicDetailsResult.success()) { |
|
|
form.setTopicIdList(topicIds); |
|
|
logger.error("调用resi-group批量查询详情失败"); |
|
|
Result<List<ResiTopicDetailResultDTO>> topicDetailsResult = resiGroupOpenFeignClient.listTopicDetailsByIds(form); |
|
|
} else { |
|
|
|
|
|
List<ResiTopicDetailResultDTO> topicDetails = topicDetailsResult.getData(); |
|
|
List<ResiTopicDetailResultDTO> topicDetails = topicDetailsResult.getData(); |
|
|
HashMap<String, ResiTopicDetailResultDTO> rtm = convertTopicDetailList2Map(topicDetails); |
|
|
if (!CollectionUtils.isEmpty(topicDetails)) { |
|
|
votingIssueList.forEach(vi -> { |
|
|
HashMap<String, ResiTopicDetailResultDTO> rtm = convertTopicDetailList2Map(topicDetails); |
|
|
ResiTopicDetailResultDTO rr = rtm.get(vi.getSourceId()); |
|
|
votingIssueList.forEach(vi -> { |
|
|
vi.setTopicImgs(rr == null ? null : rr.getTopicImgs()); |
|
|
ResiTopicDetailResultDTO rr = rtm.get(vi.getSourceId()); |
|
|
vi.setTopicVoices(rr == null ? null : rr.getTopicImgs()); |
|
|
vi.setTopicImgs(rr == null ? null : rr.getTopicImgs()); |
|
|
vi.setTopicContent(rr == null ? "" : rr.getTopicContent()); |
|
|
vi.setTopicVoices(rr == null ? null : rr.getTopicImgs()); |
|
|
vi.setLongitude(rr == null ? "" : rr.getLongitude()); |
|
|
vi.setTopicContent(rr == null ? "" : rr.getTopicContent()); |
|
|
vi.setLatitude(rr == null ? "" : rr.getLatitude()); |
|
|
vi.setLongitude(rr == null ? "" : rr.getLongitude()); |
|
|
}); |
|
|
vi.setLatitude(rr == null ? "" : rr.getLatitude()); |
|
|
|
|
|
// todo 赋值话题详情
|
|
|
|
|
|
}); |
|
|
|
|
|
} |
|
|
|
|
|
} |
|
|
|
|
|
//来源于事件的
|
|
|
|
|
|
List<String> icEventIds = votingIssueList.stream().filter(t -> t.getSourceType().equals("ic_event")).map(i -> i.getSourceId()).collect(Collectors.toList()); |
|
|
|
|
|
if(!CollectionUtils.isEmpty(icEventIds)){ |
|
|
|
|
|
// todo 查询事件详情
|
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
return votingIssueList; |
|
|
return votingIssueList; |
|
|