diff --git a/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/constant/AppClientConstant.java b/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/constant/AppClientConstant.java
index 2d12ab77ce..7b08e851d5 100644
--- a/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/constant/AppClientConstant.java
+++ b/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/constant/AppClientConstant.java
@@ -54,4 +54,12 @@ public interface AppClientConstant {
* app类型-工作端
*/
String APP_WORK = "work";
+ /**
+ * 来源类型-话题:topic
+ */
+ String TOPIC = "topic";
+ /**
+ * 来源类型-议题:issue
+ */
+ String ISSUE = "issue";
}
diff --git a/epmet-module/gov-issue/gov-issue-client/src/main/java/com/epmet/constant/IssueOpenConstant.java b/epmet-module/gov-issue/gov-issue-client/src/main/java/com/epmet/constant/IssueOpenConstant.java
index 6d971c59d5..48a9cfc1f0 100644
--- a/epmet-module/gov-issue/gov-issue-client/src/main/java/com/epmet/constant/IssueOpenConstant.java
+++ b/epmet-module/gov-issue/gov-issue-client/src/main/java/com/epmet/constant/IssueOpenConstant.java
@@ -27,4 +27,9 @@ public interface IssueOpenConstant {
* 议题解决类型-未解决
*/
String ISSUE_UNRESOLVED = "unresolved";
+
+ /**
+ * 议题来源类型 eg:resi_topic
+ */
+ String SOURCE_TYPE_RT="resi_topic";
}
diff --git a/epmet-module/gov-issue/gov-issue-client/src/main/java/com/epmet/dto/IssueDTO.java b/epmet-module/gov-issue/gov-issue-client/src/main/java/com/epmet/dto/IssueDTO.java
index 457a165fd6..0da96662ee 100644
--- a/epmet-module/gov-issue/gov-issue-client/src/main/java/com/epmet/dto/IssueDTO.java
+++ b/epmet-module/gov-issue/gov-issue-client/src/main/java/com/epmet/dto/IssueDTO.java
@@ -17,9 +17,10 @@
package com.epmet.dto;
+import lombok.Data;
+
import java.io.Serializable;
import java.util.Date;
-import lombok.Data;
/**
@@ -143,4 +144,18 @@ public class IssueDTO implements Serializable {
*/
private Date updatedTime;
+ /**
+ * 转项目日期 (服务间调用日期一致性) 戳
+ */
+ private Long shiftedTimeStamp;
+
+ /**
+ * 关闭日期 戳
+ */
+ private Long closedTimeStamp;
+
+ /**
+ * 议题转项目后-对应的项目id
+ */
+ private String projectId;
}
\ No newline at end of file
diff --git a/epmet-module/gov-issue/gov-issue-client/src/main/java/com/epmet/dto/result/IssueProjectResultDTO.java b/epmet-module/gov-issue/gov-issue-client/src/main/java/com/epmet/dto/result/IssueProjectResultDTO.java
index bcad9ff776..51ab9d952d 100644
--- a/epmet-module/gov-issue/gov-issue-client/src/main/java/com/epmet/dto/result/IssueProjectResultDTO.java
+++ b/epmet-module/gov-issue/gov-issue-client/src/main/java/com/epmet/dto/result/IssueProjectResultDTO.java
@@ -1,6 +1,7 @@
package com.epmet.dto.result;
+import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data;
import java.io.Serializable;
@@ -26,6 +27,7 @@ public class IssueProjectResultDTO implements Serializable {
/**
* 议题转项目时间(项目表创建时间)
*/
+ @JsonFormat
private Date shiftedTime;
}
diff --git a/epmet-module/gov-issue/gov-issue-client/src/main/java/com/epmet/feign/GovIssueOpenFeignClient.java b/epmet-module/gov-issue/gov-issue-client/src/main/java/com/epmet/feign/GovIssueOpenFeignClient.java
index 7b4878096a..9e01905c9e 100644
--- a/epmet-module/gov-issue/gov-issue-client/src/main/java/com/epmet/feign/GovIssueOpenFeignClient.java
+++ b/epmet-module/gov-issue/gov-issue-client/src/main/java/com/epmet/feign/GovIssueOpenFeignClient.java
@@ -7,9 +7,6 @@ import com.epmet.dto.form.MyPartIssuesFormDTO;
import com.epmet.dto.form.MyPubIssuesAuditingFormDTO;
import com.epmet.dto.result.MyPartIssuesResultDTO;
import com.epmet.dto.result.MyPubIssuesAuditingResultDTO;
-import org.springframework.cloud.openfeign.FeignClient;
-
-import com.epmet.commons.tools.constant.ServiceConstant;
import com.epmet.feign.fallback.GovIssueOpenFeignClientFallBack;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.http.MediaType;
@@ -25,7 +22,7 @@ import java.util.List;
* @date 2020/6/4 13:37
*/
@FeignClient(name = ServiceConstant.GOV_ISSUE_SERVER, fallback = GovIssueOpenFeignClientFallBack.class)
-//@FeignClient(name = ServiceConstant.GOV_ISSUE_SERVER, fallback = GovIssueOpenFeignClientFallBack.class,url = "localhost:8101")
+// @FeignClient(name = ServiceConstant.GOV_ISSUE_SERVER, fallback = GovIssueOpenFeignClientFallBack.class,url = "localhost:8101")
public interface GovIssueOpenFeignClient {
/**
diff --git a/epmet-module/gov-issue/gov-issue-server/src/main/resources/mapper/IssueDao.xml b/epmet-module/gov-issue/gov-issue-server/src/main/resources/mapper/IssueDao.xml
index f69fccd5f3..b68ac683ed 100644
--- a/epmet-module/gov-issue/gov-issue-server/src/main/resources/mapper/IssueDao.xml
+++ b/epmet-module/gov-issue/gov-issue-server/src/main/resources/mapper/IssueDao.xml
@@ -391,25 +391,31 @@
WHERE i.DEL_FLAG = '0'
AND i.ISSUE_STATUS = 'voting'
AND i.CREATED_BY = #{userId}
+ ORDER BY i.CREATED_TIME DESC
\ No newline at end of file
diff --git a/epmet-module/gov-project/gov-project-client/src/main/java/com/epmet/dto/ProjectDTO.java b/epmet-module/gov-project/gov-project-client/src/main/java/com/epmet/dto/ProjectDTO.java
index ef8c8f0d11..1d75e9adfe 100644
--- a/epmet-module/gov-project/gov-project-client/src/main/java/com/epmet/dto/ProjectDTO.java
+++ b/epmet-module/gov-project/gov-project-client/src/main/java/com/epmet/dto/ProjectDTO.java
@@ -17,9 +17,11 @@
package com.epmet.dto;
+import lombok.Data;
+
import java.io.Serializable;
import java.util.Date;
-import lombok.Data;
+import java.util.List;
/**
@@ -113,4 +115,8 @@ public class ProjectDTO implements Serializable {
*/
private Date updatedTime;
+ /**
+ * 当前处理部门名称列表
+ */
+ private List currentDepartmentNameList;
}
\ No newline at end of file
diff --git a/epmet-module/gov-project/gov-project-client/src/main/java/com/epmet/dto/ProjectRelatedPersonnelDTO.java b/epmet-module/gov-project/gov-project-client/src/main/java/com/epmet/dto/ProjectRelatedPersonnelDTO.java
index d01a0bc70d..4ac72f72cc 100644
--- a/epmet-module/gov-project/gov-project-client/src/main/java/com/epmet/dto/ProjectRelatedPersonnelDTO.java
+++ b/epmet-module/gov-project/gov-project-client/src/main/java/com/epmet/dto/ProjectRelatedPersonnelDTO.java
@@ -58,6 +58,16 @@ public class ProjectRelatedPersonnelDTO implements Serializable {
*/
private String userId;
+ /**
+ * 来源类型(话题:topic 议题:issue)
+ */
+ private String sourceType;
+
+ /**
+ * 来源Id(话题或议题Id)
+ */
+ private String sourceId;
+
/**
* 删除标识
*/
diff --git a/epmet-module/gov-project/gov-project-client/src/main/java/com/epmet/feign/GovProjectOpenFeignClient.java b/epmet-module/gov-project/gov-project-client/src/main/java/com/epmet/feign/GovProjectOpenFeignClient.java
index ed9bbab6ed..fc0adf94cd 100644
--- a/epmet-module/gov-project/gov-project-client/src/main/java/com/epmet/feign/GovProjectOpenFeignClient.java
+++ b/epmet-module/gov-project/gov-project-client/src/main/java/com/epmet/feign/GovProjectOpenFeignClient.java
@@ -22,6 +22,7 @@ import java.util.List;
* @author yinzuomei@elink-cn.com
* @date 2020/6/4 13:32
*/
+// @FeignClient(name = ServiceConstant.GOV_PROJECT_SERVER, fallback = GovProjectOpenFeignClientFallback.class,url = "localhost:8102")
@FeignClient(name = ServiceConstant.GOV_PROJECT_SERVER, fallback = GovProjectOpenFeignClientFallback.class)
public interface GovProjectOpenFeignClient {
/**
@@ -53,4 +54,14 @@ public interface GovProjectOpenFeignClient {
*/
@PostMapping("gov/project/project/issuetoprojectlist")
Result> issueToProjectList(MyPartProjectsFormDTO formDTO);
+
+ /**
+ * @return com.epmet.commons.tools.utils.Result>
+ * @param projectIds 项目id数组
+ * @author yinzuomei
+ * @description 根据项目id查询项目基本信息
+ * @Date 2020/11/11 17:40
+ **/
+ @PostMapping("gov/project/project/queryprojectinfobyids")
+ Result> queryProjectInfoByIds(@RequestBody List projectIds);
}
diff --git a/epmet-module/gov-project/gov-project-client/src/main/java/com/epmet/feign/fallback/GovProjectOpenFeignClientFallback.java b/epmet-module/gov-project/gov-project-client/src/main/java/com/epmet/feign/fallback/GovProjectOpenFeignClientFallback.java
index 9326b0cdaa..05201b8e22 100644
--- a/epmet-module/gov-project/gov-project-client/src/main/java/com/epmet/feign/fallback/GovProjectOpenFeignClientFallback.java
+++ b/epmet-module/gov-project/gov-project-client/src/main/java/com/epmet/feign/fallback/GovProjectOpenFeignClientFallback.java
@@ -9,7 +9,6 @@ import com.epmet.dto.form.ProjectListFromDTO;
import com.epmet.dto.result.MyPartProjectsResultDTO;
import com.epmet.dto.result.PendProjectListResultDTO;
import com.epmet.dto.result.ProcessAndCurrentDeptResultDTO;
-import com.epmet.dto.result.ProcesslistResultDTO;
import com.epmet.feign.GovProjectOpenFeignClient;
import com.epmet.resi.mine.dto.from.MyPartProjectsFormDTO;
import org.springframework.stereotype.Component;
@@ -51,4 +50,16 @@ public class GovProjectOpenFeignClientFallback implements GovProjectOpenFeignCli
public Result> issueToProjectList(MyPartProjectsFormDTO formDTO) {
return ModuleUtils.feignConError(ServiceConstant.GOV_PROJECT_SERVER, "issueToProjectList", formDTO);
}
+
+ /**
+ * @param projectIds 项目id数组
+ * @return com.epmet.commons.tools.utils.Result>
+ * @author yinzuomei
+ * @description 根据项目id查询项目基本信息
+ * @Date 2020/11/11 17:40
+ **/
+ @Override
+ public Result> queryProjectInfoByIds(List projectIds) {
+ return ModuleUtils.feignConError(ServiceConstant.GOV_PROJECT_SERVER, "queryProjectInfoByIds", projectIds);
+ }
}
diff --git a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/controller/ProjectController.java b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/controller/ProjectController.java
index d8309d93af..0261e4a7ba 100644
--- a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/controller/ProjectController.java
+++ b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/controller/ProjectController.java
@@ -17,18 +17,14 @@
package com.epmet.controller;
-import com.epmet.commons.tools.annotation.LoginUser;
-import com.epmet.commons.tools.annotation.RequirePermission;
-import com.epmet.commons.tools.enums.RequirePermissionEnum;
import com.epmet.commons.tools.page.PageData;
-import com.epmet.commons.tools.security.dto.TokenDto;
import com.epmet.commons.tools.utils.ExcelUtils;
import com.epmet.commons.tools.utils.Result;
import com.epmet.commons.tools.validator.AssertUtils;
import com.epmet.commons.tools.validator.ValidatorUtils;
import com.epmet.commons.tools.validator.group.AddGroup;
-import com.epmet.commons.tools.validator.group.UpdateGroup;
import com.epmet.commons.tools.validator.group.DefaultGroup;
+import com.epmet.commons.tools.validator.group.UpdateGroup;
import com.epmet.dto.ProjectDTO;
import com.epmet.dto.form.LatestListFormDTO;
import com.epmet.dto.form.ProjectListFromDTO;
@@ -192,4 +188,8 @@ public class ProjectController {
return new Result>().ok(projectService.issueToProjectList(formDTO));
}
+ @PostMapping("queryprojectinfobyids")
+ public Result> queryProjectInfoByIds(@RequestBody List projectIds){
+ return new Result>().ok(projectService.queryProjectInfoByIds(projectIds));
+ }
}
\ No newline at end of file
diff --git a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/entity/ProjectRelatedPersonnelEntity.java b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/entity/ProjectRelatedPersonnelEntity.java
index b2ed014ced..6b99f72f4a 100644
--- a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/entity/ProjectRelatedPersonnelEntity.java
+++ b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/entity/ProjectRelatedPersonnelEntity.java
@@ -58,4 +58,14 @@ public class ProjectRelatedPersonnelEntity extends BaseEpmetEntity {
*/
private String userId;
+ /**
+ * 来源类型(话题:topic 议题:issue)
+ */
+ private String sourceType;
+
+ /**
+ * 来源Id(话题或议题Id)
+ */
+ private String sourceId;
+
}
diff --git a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/excel/ProjectRelatedPersonnelExcel.java b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/excel/ProjectRelatedPersonnelExcel.java
index 8cfb220d77..081bb9182d 100644
--- a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/excel/ProjectRelatedPersonnelExcel.java
+++ b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/excel/ProjectRelatedPersonnelExcel.java
@@ -46,6 +46,12 @@ public class ProjectRelatedPersonnelExcel {
@Excel(name = "用户ID")
private String userId;
+ @Excel(name = "来源类型")
+ private String sourceType;
+
+ @Excel(name = "来源ID")
+ private String sourceId;
+
@Excel(name = "删除标识")
private String delFlag;
diff --git a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/ProjectService.java b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/ProjectService.java
index 4f339c3a3f..35f81839d8 100644
--- a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/ProjectService.java
+++ b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/ProjectService.java
@@ -19,7 +19,6 @@ package com.epmet.service;
import com.epmet.commons.mybatis.service.BaseService;
import com.epmet.commons.tools.page.PageData;
-import com.epmet.commons.tools.security.dto.TokenDto;
import com.epmet.dto.ProjectDTO;
import com.epmet.dto.form.*;
import com.epmet.dto.result.*;
@@ -224,4 +223,6 @@ public interface ProjectService extends BaseService {
* @Description 根据议题Id集合查询对应的项目信息
**/
List issueToProjectList(MyPartProjectsFormDTO formDTO);
+
+ List queryProjectInfoByIds(List projectIds);
}
\ No newline at end of file
diff --git a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/impl/ProjectServiceImpl.java b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/impl/ProjectServiceImpl.java
index f247526cff..c7a3d93804 100644
--- a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/impl/ProjectServiceImpl.java
+++ b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/impl/ProjectServiceImpl.java
@@ -688,6 +688,18 @@ public class ProjectServiceImpl extends BaseServiceImpl getClosedProjectList(LatestListFormDTO formDTO) {
+
+ return baseDao.selectClosedProjectList(formDTO);
+ }
+
/**
* @param formDTO
* @return
@@ -804,7 +816,7 @@ public class ProjectServiceImpl extends BaseServiceImpl projectStaffIds = entityList.stream().map(ProjectStaffEntity::getId).distinct().collect(Collectors.toList());
if(!CollectionUtils.isEmpty(projectStaffIds)){
List container = new LinkedList<>();
@@ -827,8 +839,12 @@ public class ProjectServiceImpl extends BaseServiceImpl getClosedProjectList(LatestListFormDTO formDTO) {
-
- return baseDao.selectClosedProjectList(formDTO);
- }
-
@Override
public void response(ProjectResponseFormDTO formDTO) {
//公开回复内容审核
@@ -1388,4 +1392,21 @@ public class ProjectServiceImpl extends BaseServiceImpl queryProjectInfoByIds(List projectIds) {
+ List entityList=baseDao.selectBatchIds(projectIds);
+ List projectDTOList=ConvertUtils.sourceToTarget(entityList, ProjectDTO.class);
+ //2.使用已有方法查询项目当前处理部门信息
+ projectDTOList.forEach(l -> {
+ if (ProjectConstant.CLOSED.equals(l.getStatus())) {
+ l.setCurrentDepartmentNameList(new ArrayList());
+ } else {
+ ProjectDTO dto = new ProjectDTO();
+ dto.setId(l.getId());
+ l.setCurrentDepartmentNameList(baseDao.selectDepartmentNameList(dto));
+ }
+ });
+ return projectDTOList;
+ }
+
}
\ No newline at end of file
diff --git a/epmet-module/gov-project/gov-project-server/src/main/resources/db/migration/V0.0.4__alter_project_related_personnel.sql b/epmet-module/gov-project/gov-project-server/src/main/resources/db/migration/V0.0.4__alter_project_related_personnel.sql
new file mode 100644
index 0000000000..9a3bbf1344
--- /dev/null
+++ b/epmet-module/gov-project/gov-project-server/src/main/resources/db/migration/V0.0.4__alter_project_related_personnel.sql
@@ -0,0 +1,5 @@
+ALTER TABLE `project_related_personnel` ADD COLUMN `SOURCE_TYPE` VARCHAR (32) CHARACTER
+SET utf8mb4 COLLATE utf8mb4_general_ci NULL COMMENT '来源类型(话题:topic 议题:issue)' AFTER `GRID_ID`,
+ ADD COLUMN `SOURCE_ID` VARCHAR (64) CHARACTER
+SET utf8mb4 COLLATE utf8mb4_general_ci NULL COMMENT '来源Id(话题或议题Id)' AFTER `SOURCE_TYPE`;
+
diff --git a/epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/member/result/ApplyingMemberResultDTO.java b/epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/member/result/ApplyingMemberResultDTO.java
index 881333be54..6374a9314b 100644
--- a/epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/member/result/ApplyingMemberResultDTO.java
+++ b/epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/member/result/ApplyingMemberResultDTO.java
@@ -3,6 +3,7 @@ package com.epmet.resi.group.dto.member.result;
import lombok.Data;
import java.io.Serializable;
+import java.util.List;
/**
* @Description
@@ -45,4 +46,9 @@ public class ApplyingMemberResultDTO implements Serializable {
* 入群被拒 - rejected 、
*/
private String status;
+
+ /**
+ * 用户徽章Url列表
+ */
+ private List badgeList;
}
diff --git a/epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/member/result/GroupMemberListResultDTO.java b/epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/member/result/GroupMemberListResultDTO.java
index a5f69fc7c3..b6aaf3b8db 100644
--- a/epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/member/result/GroupMemberListResultDTO.java
+++ b/epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/member/result/GroupMemberListResultDTO.java
@@ -4,6 +4,7 @@ import lombok.Data;
import javax.validation.constraints.NotBlank;
import java.io.Serializable;
+import java.util.List;
/**
* @Description
@@ -43,4 +44,9 @@ public class GroupMemberListResultDTO implements Serializable {
* 审核通过 - approved、 已禁言 - silent
*/
private String status;
+
+ /**
+ * 用户徽章列表
+ */
+ private List badgeList;
}
diff --git a/epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/topic/form/CustomerPageFormDTO.java b/epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/topic/form/CustomerPageFormDTO.java
new file mode 100644
index 0000000000..5c824b35ff
--- /dev/null
+++ b/epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/topic/form/CustomerPageFormDTO.java
@@ -0,0 +1,30 @@
+package com.epmet.resi.group.dto.topic.form;
+
+import lombok.Data;
+
+import javax.validation.constraints.Min;
+import javax.validation.constraints.NotBlank;
+import java.io.Serializable;
+
+/**
+ * @Description 客户Id 用户Id 分页
+ * @ClassName CustomerPageFormDTO
+ * @Auth wangc
+ * @Date 2020-11-11 23:15
+ */
+@Data
+public class CustomerPageFormDTO implements Serializable {
+ private static final long serialVersionUID = 8678047078015445193L;
+
+ @NotBlank(message = "客户Id不能为空")
+ private String customerId;
+
+ @NotBlank(message = "用户Id不能为空")
+ private String userId;
+
+ @Min(1)
+ private Integer pageNo;
+
+ @Min(1)
+ private Integer pageSize;
+}
diff --git a/epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/topic/result/MyTopicsResultDTO.java b/epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/topic/result/MyTopicsResultDTO.java
index fd08497c00..2a3573f726 100644
--- a/epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/topic/result/MyTopicsResultDTO.java
+++ b/epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/topic/result/MyTopicsResultDTO.java
@@ -9,6 +9,7 @@ public class MyTopicsResultDTO {
private Long releaseTime;
private String topicContent;
private String releaseGroupName;
+ private String releaseGridId;
private String releaseGridName;
}
diff --git a/epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/topic/result/ParticipatedTopicUnitResultDTO.java b/epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/topic/result/ParticipatedTopicUnitResultDTO.java
new file mode 100644
index 0000000000..d5c9f9bc24
--- /dev/null
+++ b/epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/topic/result/ParticipatedTopicUnitResultDTO.java
@@ -0,0 +1,26 @@
+package com.epmet.resi.group.dto.topic.result;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @Description 个人中心 参与过的话题返参DTO
+ * @ClassName ParticipatedTopicUnitResultDTO
+ * @Auth wangc
+ * @Date 2020-11-11 23:00
+ */
+@Data
+public class ParticipatedTopicUnitResultDTO implements Serializable {
+ private static final long serialVersionUID = 1392205563783715932L;
+
+ private String topicId;
+
+ private String topicReleaseGridName;
+
+ private String topicContent;
+
+ private Long releaseTime;
+
+ private String topicReleaseGroupName;
+}
diff --git a/epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/feign/ResiGroupOpenFeignClient.java b/epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/feign/ResiGroupOpenFeignClient.java
index 92001cc862..8b5c663df6 100644
--- a/epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/feign/ResiGroupOpenFeignClient.java
+++ b/epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/feign/ResiGroupOpenFeignClient.java
@@ -4,7 +4,9 @@ import com.epmet.commons.tools.constant.ServiceConstant;
import com.epmet.commons.tools.utils.Result;
import com.epmet.resi.group.dto.group.form.GroupInfoFormDTO;
import com.epmet.resi.group.dto.group.result.GroupInfoResultDTO;
+import com.epmet.resi.group.dto.topic.form.CustomerPageFormDTO;
import com.epmet.resi.group.dto.topic.result.IssueGridResultDTO;
+import com.epmet.resi.group.dto.topic.result.ParticipatedTopicUnitResultDTO;
import com.epmet.resi.group.feign.fallback.ResiGroupOpenFeignClientFallback;
import com.epmet.resi.mine.dto.from.MyPartProjectsFormDTO;
import org.springframework.cloud.openfeign.FeignClient;
@@ -39,4 +41,13 @@ public interface ResiGroupOpenFeignClient {
@PostMapping("resi/group/group/groupinfo")
Result> selectGroupInfo(@RequestBody GroupInfoFormDTO groupInfoFormDTO);
+ /**
+ * @Description 个人中心-我参与过的话题
+ * @param param
+ * @return java.util.List
+ * @author wangc
+ * @date 2020.11.11 23:20
+ */
+ @PostMapping("resi/group/topic/my-part-topics")
+ Result> myPartTopics(@RequestBody CustomerPageFormDTO param);
}
diff --git a/epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/feign/fallback/ResiGroupOpenFeignClientFallback.java b/epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/feign/fallback/ResiGroupOpenFeignClientFallback.java
index f29e47292d..2300137e09 100644
--- a/epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/feign/fallback/ResiGroupOpenFeignClientFallback.java
+++ b/epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/feign/fallback/ResiGroupOpenFeignClientFallback.java
@@ -5,7 +5,9 @@ import com.epmet.commons.tools.utils.ModuleUtils;
import com.epmet.commons.tools.utils.Result;
import com.epmet.resi.group.dto.group.form.GroupInfoFormDTO;
import com.epmet.resi.group.dto.group.result.GroupInfoResultDTO;
+import com.epmet.resi.group.dto.topic.form.CustomerPageFormDTO;
import com.epmet.resi.group.dto.topic.result.IssueGridResultDTO;
+import com.epmet.resi.group.dto.topic.result.ParticipatedTopicUnitResultDTO;
import com.epmet.resi.group.feign.ResiGroupOpenFeignClient;
import com.epmet.resi.mine.dto.from.MyPartProjectsFormDTO;
import org.springframework.stereotype.Component;
@@ -31,4 +33,9 @@ public class ResiGroupOpenFeignClientFallback implements ResiGroupOpenFeignClien
return ModuleUtils.feignConError(ServiceConstant.RESI_GROUP_SERVER, "selectGroupInfo", groupInfoFormDTO);
}
+ @Override
+ public Result> myPartTopics(CustomerPageFormDTO param) {
+ return ModuleUtils.feignConError(ServiceConstant.RESI_GROUP_SERVER, "myPartTopics", param);
+ }
+
}
diff --git a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/member/service/impl/ResiGroupMemberServiceImpl.java b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/member/service/impl/ResiGroupMemberServiceImpl.java
index 318989299c..6c3b9ff19c 100644
--- a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/member/service/impl/ResiGroupMemberServiceImpl.java
+++ b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/member/service/impl/ResiGroupMemberServiceImpl.java
@@ -31,12 +31,10 @@ import com.epmet.commons.tools.page.PageData;
import com.epmet.commons.tools.utils.ConvertUtils;
import com.epmet.commons.tools.utils.Result;
import com.epmet.constant.ReadFlagConstant;
-import com.epmet.dto.form.UserMessageFormDTO;
-import com.epmet.dto.form.UserResiInfoFormDTO;
-import com.epmet.dto.form.UserResiInfoListFormDTO;
-import com.epmet.dto.form.WxSubscribeMessageFormDTO;
+import com.epmet.dto.form.*;
import com.epmet.dto.result.UserResiInfoResultDTO;
import com.epmet.feign.EpmetMessageOpenFeignClient;
+import com.epmet.feign.EpmetUserOpenFeignClient;
import com.epmet.modules.constant.GroupMemberConstant;
import com.epmet.modules.constant.UserMessageConstant;
import com.epmet.modules.feign.EpmetUserFeignClient;
@@ -65,6 +63,7 @@ import com.epmet.resi.group.dto.member.GroupMemeberOperationDTO;
import com.epmet.resi.group.dto.member.ResiGroupMemberDTO;
import com.epmet.resi.group.dto.member.ResiGroupMemberInfoRedisDTO;
import com.epmet.resi.group.dto.member.form.*;
+import com.epmet.resi.group.dto.member.form.CommonGridIdListFormDTO;
import com.epmet.resi.group.dto.member.result.ApplyingMemberResultDTO;
import com.epmet.resi.group.dto.member.result.GridVotableCountResultDTO;
import com.epmet.resi.group.dto.member.result.GroupMemberListResultDTO;
@@ -75,10 +74,12 @@ import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
+import org.springframework.util.CollectionUtils;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.*;
+import java.util.stream.Collectors;
/**
* 群组成员关系表
@@ -118,6 +119,8 @@ public class ResiGroupMemberServiceImpl extends BaseServiceImpl page(Map params) {
@@ -329,6 +332,24 @@ public class ResiGroupMemberServiceImpl extends BaseServiceImpl>> badgeR
+ = userOpenFeignClient.userShowBadge(new UserGroupFormDTO(group.getCustomerId(), userIdList));
+ if(null != badgeR && badgeR.success() && null != badgeR.getData() && !badgeR.getData().isEmpty()){
+ Map> map = badgeR.getData();
+ list.forEach(member -> {
+ member.setBadgeList(
+ CollectionUtils.isEmpty(map.get(member.getUserId())) ?
+ Collections.EMPTY_LIST:
+ map.get(member.getUserId()).stream().map(UserBadgeUnitFormDTO :: getBadgeIcon).collect(Collectors.toList()) );
+ });
+ }else{
+ list.forEach(member -> member.setBadgeList(Collections.EMPTY_LIST));
+ }
+ }
+
return list;
}
@@ -368,6 +389,26 @@ public class ResiGroupMemberServiceImpl extends BaseServiceImpl>> badgeR
+ = userOpenFeignClient.userShowBadge(new UserGroupFormDTO(group.getCustomerId(), userIdList));
+ if(null != badgeR && badgeR.success() && null != badgeR.getData() && !badgeR.getData().isEmpty()){
+ Map> map = badgeR.getData();
+ list.forEach(member -> {
+ member.setBadgeList(
+ CollectionUtils.isEmpty(map.get(member.getApplyUserId())) ?
+ Collections.EMPTY_LIST:
+ map.get(member.getApplyUserId()).stream().map(UserBadgeUnitFormDTO :: getBadgeIcon).collect(Collectors.toList()) );
+ });
+ }else{
+ list.forEach(member -> member.setBadgeList(Collections.EMPTY_LIST));
+ }
+ }
+
return list;
}
diff --git a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/controller/ResiTopicController.java b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/controller/ResiTopicController.java
index de0f3a665d..917d3beab5 100644
--- a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/controller/ResiTopicController.java
+++ b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/controller/ResiTopicController.java
@@ -272,5 +272,18 @@ public class ResiTopicController {
return new Result().ok(myTopics);
}
+ /**
+ * @Description 个人中心-我参与过的话题
+ * @param param
+ * @return java.util.List
+ * @author wangc
+ * @date 2020.11.11 23:20
+ */
+ @PostMapping("my-part-topics")
+ public Result> myPartTopics(@RequestBody CustomerPageFormDTO param){
+ ValidatorUtils.validateEntity(param);
+ return new Result>().ok(topicService.getParticipatedTopics(param));
+ }
+
}
diff --git a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/dao/ResiTopicDao.java b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/dao/ResiTopicDao.java
index 1cc8f528fe..e7cd14a7eb 100644
--- a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/dao/ResiTopicDao.java
+++ b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/dao/ResiTopicDao.java
@@ -161,4 +161,13 @@ public interface ResiTopicDao extends BaseDao {
*/
List selectIssueList(@Param("topicList") List topicList);
+ /**
+ * @Description 查询我参与过的话题
+ * @param customerId
+ * @param userId
+ * @return java.util.List
+ * @author wangc
+ * @date 2020.11.11 23:08
+ */
+ List selectParticipatedTopics(@Param("customerId") String customerId,@Param("userId") String userId);
}
\ No newline at end of file
diff --git a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/service/ResiTopicService.java b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/service/ResiTopicService.java
index b366ac7109..4128358aa5 100644
--- a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/service/ResiTopicService.java
+++ b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/service/ResiTopicService.java
@@ -271,4 +271,13 @@ public interface ResiTopicService extends BaseService {
* @date 2020.11.10 15:03
*/
List listMyTopics(String customerId, String userId, Integer pageNo, Integer pageSize);
+
+ /**
+ * @Description 个人中心-我参与过的话题
+ * @param param
+ * @return java.util.List
+ * @author wangc
+ * @date 2020.11.11 23:20
+ */
+ List getParticipatedTopics(CustomerPageFormDTO param);
}
\ No newline at end of file
diff --git a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/service/impl/ResiTopicServiceImpl.java b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/service/impl/ResiTopicServiceImpl.java
index 6e86d0221b..c207a9f736 100644
--- a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/service/impl/ResiTopicServiceImpl.java
+++ b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/service/impl/ResiTopicServiceImpl.java
@@ -37,12 +37,15 @@ import com.epmet.commons.tools.utils.ConvertUtils;
import com.epmet.commons.tools.utils.DateUtils;
import com.epmet.commons.tools.utils.Result;
import com.epmet.commons.tools.utils.ScanContentUtils;
+import com.epmet.constant.OrgInfoConstant;
import com.epmet.dto.CustomerGridDTO;
import com.epmet.dto.form.*;
import com.epmet.dto.result.CommonDataFilterResultDTO;
import com.epmet.dto.result.IssueInitiatorResultDTO;
+import com.epmet.dto.result.OrgInfoResultDTO;
import com.epmet.dto.result.UserResiInfoResultDTO;
import com.epmet.feign.EpmetUserOpenFeignClient;
+import com.epmet.feign.GovOrgOpenFeignClient;
import com.epmet.modules.constant.GroupMemberConstant;
import com.epmet.modules.constant.ResiGroupRedisKeys;
import com.epmet.modules.feign.EpmetUserFeignClient;
@@ -81,6 +84,7 @@ import com.epmet.resi.group.dto.topic.form.CheckTopicPublisherFormDTO;
import com.epmet.resi.group.dto.topic.form.GovTopicIssueInfoFormDTO;
import com.epmet.resi.group.dto.topic.result.*;
import com.github.pagehelper.PageHelper;
+import com.github.pagehelper.PageInfo;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.apache.commons.logging.Log;
@@ -141,6 +145,9 @@ public class ResiTopicServiceImpl extends BaseServiceImpl listMyTopics(String customerId, String userId, Integer pageNo, Integer pageSize) {
PageHelper.startPage(pageNo, pageSize);
List myTopics = resiTopicDao.listMyTopics(userId, customerId);
- // todo 查询网格名称,赋值
+
+ HashMap gridIdAndNames = new HashMap<>();
+ Set gridIds = myTopics.stream().map(c -> c.getReleaseGridId()).collect(Collectors.toSet());
+
+ OrgInfoFormDTO form = new OrgInfoFormDTO();
+ form.setOrgType(OrgInfoConstant.GRID);
+ form.setOrgIds(new ArrayList<>(gridIds));
+ Result> gridInfoResult = govOrgOpenFeignClient.selectOrgInfo(form);
+ if (gridInfoResult.success()) {
+ List grids = gridInfoResult.getData();
+ for (OrgInfoResultDTO grid : grids) {
+ gridIdAndNames.put(grid.getOrgId(), grid.getOrgName());
+ }
+ }
+
+ for (MyTopicsResultDTO myTopic : myTopics) {
+ myTopic.setReleaseGridName(gridIdAndNames.get(myTopic.getReleaseGridId()));
+ }
+
return myTopics;
}
+
+ /**
+ * @Description 个人中心-我参与过的话题
+ * @param param
+ * @return java.util.List
+ * @author wangc
+ * @date 2020.11.11 23:20
+ */
+ @Override
+ public List getParticipatedTopics(CustomerPageFormDTO param) {
+
+ PageInfo page =
+ PageHelper.startPage(Optional.ofNullable(param.getPageNo()).orElse(NumConstant.ONE),
+ Optional.ofNullable(param.getPageSize()).orElse(NumConstant.ONE)).doSelectPageInfo(() ->
+ baseDao.selectParticipatedTopics(param.getCustomerId(),param.getUserId()));
+ List result = page.getList();
+ if(CollectionUtils.isEmpty(result)) return Collections.EMPTY_LIST;
+ Result> gridR = govOrgOpenFeignClient.selectOrgInfo(
+ new OrgInfoFormDTO(OrgInfoConstant.GRID,result.stream().map(ParticipatedTopicUnitResultDTO :: getTopicReleaseGridName).distinct().collect(Collectors.toList())));
+ if(gridR.success() && !CollectionUtils.isEmpty(gridR.getData())){
+ return result.stream().flatMap(topic -> gridR.getData().stream() .filter(grid -> StringUtils.equals(grid.getOrgId(),topic.getTopicReleaseGridName())).map(orgInfo -> {
+ topic.setTopicReleaseGridName(orgInfo.getOrgId());
+ return topic;
+ })).collect(Collectors.toList());
+ } return Collections.EMPTY_LIST;
+ }
}
diff --git a/epmet-module/resi-group/resi-group-server/src/main/resources/mapper/topic/ResiTopicDao.xml b/epmet-module/resi-group/resi-group-server/src/main/resources/mapper/topic/ResiTopicDao.xml
index cf570c9eda..cb4d75b345 100644
--- a/epmet-module/resi-group/resi-group-server/src/main/resources/mapper/topic/ResiTopicDao.xml
+++ b/epmet-module/resi-group/resi-group-server/src/main/resources/mapper/topic/ResiTopicDao.xml
@@ -451,7 +451,8 @@
select t.id as topicId,
t.topic_content as topicContent,
unix_timestamp(t.created_time) as releaseTime,
- g.GROUP_NAME as releaseGroupName
+ g.GROUP_NAME as releaseGroupName,
+ g.GRID_ID as releaseGridId
from resi_topic t
inner join resi_group g on (t.GROUP_ID = g.ID and g.CUSTOMER_ID = #{customerId})
where t.CREATED_BY = #{userId}
@@ -473,5 +474,26 @@
+
+
diff --git a/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/person/service/impl/IssueServiceImpl.java b/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/person/service/impl/IssueServiceImpl.java
index 2cb0181662..8f321cceb9 100644
--- a/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/person/service/impl/IssueServiceImpl.java
+++ b/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/person/service/impl/IssueServiceImpl.java
@@ -5,18 +5,24 @@ import com.epmet.commons.tools.exception.RenException;
import com.epmet.commons.tools.security.dto.TokenDto;
import com.epmet.commons.tools.utils.Result;
import com.epmet.constant.IssueOpenConstant;
+import com.epmet.constant.OrgInfoConstant;
import com.epmet.dto.IssueDTO;
+import com.epmet.dto.ProjectDTO;
import com.epmet.dto.form.MyPartIssuesFormDTO;
import com.epmet.dto.form.MyPubIssuesAuditingFormDTO;
+import com.epmet.dto.form.OrgInfoFormDTO;
import com.epmet.dto.result.*;
import com.epmet.feign.GovIssueOpenFeignClient;
import com.epmet.feign.GovOrgOpenFeignClient;
import com.epmet.feign.GovProjectOpenFeignClient;
import com.epmet.modules.person.service.IssueService;
+import com.epmet.resi.group.dto.group.form.GroupInfoFormDTO;
+import com.epmet.resi.group.dto.group.result.GroupInfoResultDTO;
import com.epmet.resi.group.dto.topic.result.IssueGridResultDTO;
import com.epmet.resi.group.feign.ResiGroupOpenFeignClient;
import com.epmet.resi.mine.dto.from.MyPartProjectsFormDTO;
import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.beans.factory.annotation.Autowired;
@@ -146,13 +152,56 @@ public class IssueServiceImpl implements IssueService {
/**
* @param formDTO
* @author yinzuomei
- * @description 个人中心-我发起的议题列表-已转项目
+ * @description 个人中心-我发起的议题列表-已转项目 按照转项目时间排序
* @Date 2020/11/11 13:35
**/
@Override
public List getMyPubIssuesShiftProject(MyPubIssuesAuditingFormDTO formDTO) {
- //todo
- return null;
+ //查询我发起的议题,并且 已转项目
+ formDTO.setIssueStatus(IssueOpenConstant.ISSUE_SHIFT_PROJECT);
+ Result> issueResult=issueOpenFeignClient.getMyPubIssues(formDTO);
+ if(null==issueResult||CollectionUtils.isEmpty(issueResult.getData())){
+ return new ArrayList<>();
+ }
+ //议题来源话题id集合
+ List topicIds=new ArrayList<>();
+ List projectIds=new ArrayList<>();
+ issueResult.getData().forEach(issueDTO ->{
+ if(IssueOpenConstant.SOURCE_TYPE_RT.equals(issueDTO.getSourceType())&& StringUtils.isNotBlank(issueDTO.getSourceId())){
+ topicIds.add(issueDTO.getSourceId());
+ projectIds.add(issueDTO.getProjectId());
+ }
+ } );
+ //查询网格名称
+ Result> gridNameList = govOrgOpenFeignClient.selectOrgInfo(new OrgInfoFormDTO(OrgInfoConstant.GRID, issueResult.getData().stream().map(m -> m.getGridId()).collect(Collectors.toList())));
+ if (!gridNameList.success()){
+ logger.error("查询议题来源网格名称失败......");
+ }
+ //查询话题来源小组名称
+ Result> groupNameList = resiGroupOpenFeignClient.selectGroupInfo(new GroupInfoFormDTO(topicIds));
+ if (!groupNameList.success()){
+ logger.error("查询议题来源小组名称失败......");
+ }
+ //查询项目基本信息
+ Result> projectRes=govProjectOpenFeignClient.queryProjectInfoByIds(projectIds);
+ if(!projectRes.success()){
+ logger.error("查询项目信息失败......");
+ }
+ List list=new ArrayList<>();
+ for(IssueDTO issueDTO:issueResult.getData()){
+ MyPubIssuesShiftProjectResultDTO resultDTO=new MyPubIssuesShiftProjectResultDTO();
+ resultDTO.setProjectId(issueDTO.getProjectId());
+ gridNameList.getData().stream().filter(o -> issueDTO.getGridId().equals(o.getOrgId())).forEach(o -> resultDTO.setTopicReleaseGridName(o.getOrgName()));
+ groupNameList.getData().stream().filter(g -> issueDTO.getSourceId().equals(g.getTopicId())).forEach(g -> resultDTO.setTopicReleaseGroupName(g.getTopicGroupName()));
+ resultDTO.setShiftProjectTime(issueDTO.getShiftedTimeStamp());
+
+
+ projectRes.getData().stream().filter(p->issueDTO.getProjectId().equals(p.getId())).forEach(projectDTO -> resultDTO.setProjectTitle(projectDTO.getTitle()));
+ //当前处理部门名称列表
+ projectRes.getData().stream().filter(p->issueDTO.getProjectId().equals(p.getId())).forEach(projectDTO -> resultDTO.setDepartmentNameList(projectDTO.getCurrentDepartmentNameList()));
+ list.add(resultDTO);
+ }
+ return list;
}
/**
@@ -169,7 +218,34 @@ public class IssueServiceImpl implements IssueService {
if(null==issueResult||CollectionUtils.isEmpty(issueResult.getData())){
return new ArrayList<>();
}
- //todo
- return null;
+ //议题来源话题id集合
+ List topicIds=new ArrayList<>();
+ issueResult.getData().forEach(issueDTO ->{
+ if(IssueOpenConstant.SOURCE_TYPE_RT.equals(issueDTO.getSourceType())&& StringUtils.isNotBlank(issueDTO.getSourceId())){
+ topicIds.add(issueDTO.getSourceId());
+ }
+ } );
+ //查询网格名称
+ Result> gridNameList = govOrgOpenFeignClient.selectOrgInfo(new OrgInfoFormDTO(OrgInfoConstant.GRID, issueResult.getData().stream().map(m -> m.getGridId()).collect(Collectors.toList())));
+ if (!gridNameList.success()){
+ logger.error("查询议题来源网格名称失败......");
+ }
+ //查询话题来源小组名称
+ Result> groupNameList = resiGroupOpenFeignClient.selectGroupInfo(new GroupInfoFormDTO(topicIds));
+ if (!groupNameList.success()){
+ logger.error("查询议题来源小组名称失败......");
+ }
+ List resultDTOList=new ArrayList<>();
+ for(IssueDTO issueDTO:issueResult.getData()){
+ MyPubIssuesClosedResultDTO resultDTO=new MyPubIssuesClosedResultDTO();
+ resultDTO.setIssueId(issueDTO.getId());
+ resultDTO.setIssueTitle(issueDTO.getIssueTitle());
+ resultDTO.setSuggestion(issueDTO.getSuggestion());
+ resultDTO.setClosedTime(issueDTO.getClosedTimeStamp());
+ gridNameList.getData().stream().filter(o -> issueDTO.getGridId().equals(o.getOrgId())).forEach(o -> resultDTO.setTopicReleaseGridName(o.getOrgName()));
+ groupNameList.getData().stream().filter(g -> issueDTO.getSourceId().equals(g.getTopicId())).forEach(g -> resultDTO.setTopicReleaseGroupName(g.getTopicGroupName()));
+ resultDTOList.add(resultDTO);
+ }
+ return resultDTOList;
}
}
diff --git a/epmet-user/epmet-user-server/src/main/resources/db/migration/V0.0.7__add_useradvice.sql b/epmet-user/epmet-user-server/src/main/resources/db/migration/V0.0.7__add_useradvice.sql
new file mode 100644
index 0000000000..e2e4c2cf9b
--- /dev/null
+++ b/epmet-user/epmet-user-server/src/main/resources/db/migration/V0.0.7__add_useradvice.sql
@@ -0,0 +1,42 @@
+CREATE TABLE `user_advice` (
+ `ID` varchar(64) NOT NULL COMMENT '主键',
+ `CUSTOMER_ID` varchar(64) NOT NULL COMMENT '客户ID',
+ `CUSTOMER_NAME` varchar(64) NOT NULL COMMENT '客户名',
+ `AGENCY_ID` varchar(64) NOT NULL COMMENT '组织ID',
+ `AGENCY_NAME` varchar(64) NOT NULL COMMENT '组织名',
+ `GRID_ID` varchar(64) NOT NULL COMMENT '网格ID',
+ `GRID_NAME` varchar(64) NOT NULL COMMENT '网格名',
+ `USER_ID` varchar(64) NOT NULL COMMENT 'userid',
+ `USER_NAME` varchar(32) NOT NULL COMMENT '用户姓名',
+ `REG_PHONE` varchar(32) NOT NULL COMMENT '用户注册手机号',
+ `ADVICE_CONTENT` varchar(500) NOT NULL COMMENT '建议描述',
+ `PHONE` varchar(32) DEFAULT NULL COMMENT '填写手机号',
+ `ADVICE_TIME` datetime NOT NULL COMMENT '建议时间',
+ `ADVICE_TYPE` varchar(32) DEFAULT NULL COMMENT '问题分类(gov政府software软件,逗号分隔)',
+ `REPLY_CONTENT` varchar(500) DEFAULT NULL COMMENT '回复内容',
+ `REPLY_USER_ID` varchar(64) DEFAULT NULL COMMENT '回复人id',
+ `REPLY_USER_NAME` varchar(32) DEFAULT NULL COMMENT '回复人姓名',
+ `REPLY_TIME` datetime DEFAULT NULL COMMENT '回复时间',
+ `GOV_CONTENT` varchar(500) DEFAULT NULL COMMENT '政府存证文字',
+ `DEL_FLAG` varchar(1) NOT NULL COMMENT '删除标志',
+ `REVISION` int(11) NOT NULL COMMENT '乐观锁',
+ `CREATED_BY` varchar(64) NOT NULL COMMENT '创建人',
+ `CREATED_TIME` datetime NOT NULL COMMENT '创建时间',
+ `UPDATED_BY` varchar(64) NOT NULL COMMENT '更新人',
+ `UPDATED_TIME` datetime NOT NULL COMMENT '更新时间',
+ PRIMARY KEY (`ID`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='用户建议表';
+
+CREATE TABLE `user_advice_img` (
+ `ID` varchar(64) NOT NULL COMMENT '主键',
+ `ADVICE_ID` varchar(64) NOT NULL COMMENT '建议id',
+ `TYPE` varchar(10) NOT NULL COMMENT '图片类型,resi是用户上传的建议图片,oper是运营上传的代替政府回复的存证',
+ `IMG_URL` varchar(255) NOT NULL COMMENT '图片url',
+ `DEL_FLAG` varchar(1) NOT NULL COMMENT '删除标志',
+ `REVISION` int(11) NOT NULL COMMENT '乐观锁',
+ `CREATED_BY` varchar(64) NOT NULL COMMENT '创建人',
+ `CREATED_TIME` datetime NOT NULL COMMENT '创建时间',
+ `UPDATED_BY` varchar(64) NOT NULL COMMENT '更新人',
+ `UPDATED_TIME` datetime NOT NULL COMMENT '更新时间',
+ PRIMARY KEY (`ID`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='用户建议图片';