Browse Source

我参与的议题-修改

master
zhaoqifeng 5 years ago
parent
commit
0c0f18b533
  1. 20
      epmet-module/gov-issue/gov-issue-client/src/main/java/com/epmet/dto/result/MyPartIssuesResultDTO.java
  2. 4
      epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/service/impl/IssueVoteStatisticalServiceImpl.java
  3. 8
      epmet-module/gov-issue/gov-issue-server/src/main/resources/mapper/IssueVoteDetailDao.xml

20
epmet-module/gov-issue/gov-issue-client/src/main/java/com/epmet/dto/result/MyPartIssuesResultDTO.java

@ -1,6 +1,7 @@
package com.epmet.dto.result;
import com.fasterxml.jackson.annotation.JsonIgnore;
import lombok.AllArgsConstructor;
import lombok.Data;
import java.io.Serializable;
@ -10,6 +11,7 @@ import java.io.Serializable;
* @DateTime 2020/11/10 9:50 上午
*/
@Data
@AllArgsConstructor
public class MyPartIssuesResultDTO implements Serializable {
private static final long serialVersionUID = 2081387920547808112L;
@ -38,4 +40,22 @@ public class MyPartIssuesResultDTO implements Serializable {
@JsonIgnore
private String gridId;
@Override
public boolean equals(Object obj) {
if (this == obj) {
return true;
}
if (obj == null || getClass() != obj.getClass()) {
return false;
}
MyPartIssuesResultDTO u = (MyPartIssuesResultDTO)obj;
return issueId.equals(u.issueId);
}
@Override
public int hashCode() {
String in = issueId;
return in.hashCode();
}
}

4
epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/service/impl/IssueVoteStatisticalServiceImpl.java

@ -563,8 +563,10 @@ public class IssueVoteStatisticalServiceImpl extends BaseServiceImpl<IssueVoteSt
if (CollectionUtils.isEmpty(myPartIssuesResult)){
return new ArrayList<>();
}
Set<MyPartIssuesResultDTO> set = new HashSet<>(myPartIssuesResult);
myPartIssuesResult = new ArrayList<>(set);
List<MyPartIssuesResultDTO> collect = myPartIssuesResult.stream().sorted(Comparator.comparing(MyPartIssuesResultDTO::getShiftIssueTime).reversed()).distinct().collect(Collectors.toList());
List<String> orgIds = collect.stream().map(m -> m.getGridId()).collect(Collectors.toList());
List<String> orgIds = collect.stream().map(MyPartIssuesResultDTO::getGridId).collect(Collectors.toList());
Result<List<AllGridsByUserIdResultDTO>> listResult = govOrgOpenFeignClient.getGridListByGridIds(orgIds);
if (!listResult.success()){
throw new RenException("查询议题来源网格名称失败......");

8
epmet-module/gov-issue/gov-issue-server/src/main/resources/mapper/IssueVoteDetailDao.xml

@ -73,7 +73,7 @@
</select>
<!-- 个人中心-我参与的议题列表 -->
<select id="myPartIssues" resultType="com.epmet.dto.result.MyPartIssuesResultDTO">
<select id="myPartIssues" resultType="com.epmet.dto.result.MyPartIssuesResultDTO">
SELECT
vd.ISSUE_ID,
i.SUGGESTION,
@ -85,6 +85,9 @@
WHERE i.DEL_FLAG = '0'
AND vd.DEL_FLAG = '0'
AND vd.CREATED_BY = #{userId}
<foreach collection="topicIds" item="topicId" open="AND (" separator="AND" close=")">
i.SOURCE_ID != #{topicId}
</foreach>
ORDER BY i.CREATED_TIME DESC
</select>
@ -97,8 +100,7 @@
UNIX_TIMESTAMP(i.CREATED_TIME) AS shiftIssueTime
FROM issue i
WHERE i.DEL_FLAG = '0'
AND
<foreach collection="topicIds" item="topicId" separator=" OR ">
<foreach collection="topicIds" item="topicId" open="AND (" separator="OR" close=")">
i.SOURCE_ID = #{topicId}
</foreach>
ORDER BY i.CREATED_TIME DESC

Loading…
Cancel
Save