Browse Source

议题、项目分类信息保存自测代码调整

master
sunyuchao 5 years ago
parent
commit
745e93b4f9
  1. 4
      epmet-module/gov-issue/gov-issue-client/src/main/java/com/epmet/feign/GovIssueOpenFeignClient.java
  2. 8
      epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/service/impl/IssueProjectCategoryDictServiceImpl.java
  3. 55
      epmet-module/gov-project/gov-project-client/src/main/java/com/epmet/dto/result/ProjectCategoryDTOResultDTO.java
  4. 9
      epmet-module/gov-project/gov-project-client/src/main/java/com/epmet/dto/result/ProjectIssueCategoryResultDTO.java
  5. 96
      epmet-module/gov-project/gov-project-client/src/main/java/com/epmet/dto/result/ProjectIssueDTOResultDTO.java
  6. 12
      epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/impl/ProjectCategoryServiceImpl.java

4
epmet-module/gov-issue/gov-issue-client/src/main/java/com/epmet/feign/GovIssueOpenFeignClient.java

@ -34,8 +34,8 @@ import java.util.Map;
* @author yinzuomei@elink-cn.com
* @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)
@FeignClient(name = ServiceConstant.GOV_ISSUE_SERVER, fallback = GovIssueOpenFeignClientFallBack.class,url = "localhost:8101")
public interface GovIssueOpenFeignClient {
/**

8
epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/service/impl/IssueProjectCategoryDictServiceImpl.java

@ -32,7 +32,9 @@ import com.epmet.dto.form.CustomerCategoryListFormDTO;
import com.epmet.dto.form.ProjectSaveCategoryFormDTO;
import com.epmet.dto.form.SaveIssueCategoryFormDTO;
import com.epmet.dto.result.CustomerCategoryListResultDTO;
import com.epmet.dto.result.ProjectCategoryDTOResultDTO;
import com.epmet.dto.result.ProjectIssueCategoryResultDTO;
import com.epmet.dto.result.ProjectIssueDTOResultDTO;
import com.epmet.entity.IssueProjectCategoryDictEntity;
import com.epmet.redis.IssueProjectCategoryDictRedis;
import com.epmet.service.IssueProjectCategoryDictService;
@ -149,14 +151,16 @@ public class IssueProjectCategoryDictServiceImpl extends BaseServiceImpl<IssuePr
if (null == dto) {
throw new RenException(String.format("保存项目分类信息,获取项目对应的议题基本信息失败,projectId->%s", formDTO.getProjectId()));
}
//resultDTO.setIssueDTO(dto);
ProjectIssueDTOResultDTO issueDTO = ConvertUtils.sourceToTarget(dto,ProjectIssueDTOResultDTO.class);
resultDTO.setIssueDTO(issueDTO);
//2.批量查询分类信息
List<String> categoryIdList = formDTO.getCategoryList().stream().map(SaveIssueCategoryFormDTO::getId).collect(Collectors.toList());
List<IssueProjectCategoryDictDTO> categoryList = getCategoryList(categoryIdList);
if (null == categoryList) {
throw new RenException(String.format("保存项目分类信息,根据分类Id获取分类信息失败"));
}
// resultDTO.setCategoryList(categoryList);
List<ProjectCategoryDTOResultDTO> list = ConvertUtils.sourceToTarget(categoryList,ProjectCategoryDTOResultDTO.class);
resultDTO.setCategoryList(list);
return resultDTO;
}

55
epmet-module/gov-project/gov-project-client/src/main/java/com/epmet/dto/result/ProjectCategoryDTOResultDTO.java

@ -0,0 +1,55 @@
package com.epmet.dto.result;
import lombok.Data;
import java.io.Serializable;
/**
* @dscription 项目所属网格分类基本信息-接口返参
* @author sun
*/
@Data
public class ProjectCategoryDTOResultDTO implements Serializable {
private static final long serialVersionUID = 5957826616179876849L;
/**
* 主键
*/
private String id;
/**
* 客户id, 产品默认default
*/
private String customerId;
/**
* 上级分类ID 顶级此列存储0
*/
private String pid;
/**
* 所有上级分类ID用逗号分开
*/
private String pids;
/**
* 分类编码分类编码+customer_id唯一
*/
private String categoryCode;
/**
* 分类名称
*/
private String categoryName;
/**
* 分类类别1,2,3,4....
*/
private String categoryType;
/**
* 排序
*/
private Integer sort;
}

9
epmet-module/gov-project/gov-project-client/src/main/java/com/epmet/dto/result/ProjectIssueCategoryResultDTO.java

@ -3,6 +3,7 @@ package com.epmet.dto.result;
import lombok.Data;
import java.io.Serializable;
import java.util.List;
/**
* @dscription 项目所属网格分类基本信息-接口返参
@ -15,10 +16,10 @@ public class ProjectIssueCategoryResultDTO implements Serializable {
/**
* 项目Id
*/
/*private IssueDTO issueDTO;
*//**
private ProjectIssueDTOResultDTO issueDTO;
/**
* 项目标题
*//*
private List<IssueProjectCategoryDictDTO> categoryList;*/
*/
private List<ProjectCategoryDTOResultDTO> categoryList;
}

96
epmet-module/gov-project/gov-project-client/src/main/java/com/epmet/dto/result/ProjectIssueDTOResultDTO.java

@ -0,0 +1,96 @@
package com.epmet.dto.result;
import lombok.Data;
import java.io.Serializable;
import java.util.Date;
/**
* @dscription 项目所属网格分类基本信息-接口返参
* @author sun
*/
@Data
public class ProjectIssueDTOResultDTO implements Serializable {
private static final long serialVersionUID = 5957826616179876849L;
/**
* 议题ID
*/
private String id;
/**
* 议题状态 表决中voting 已转项目shift_project 已关闭closed
*/
private String issueStatus;
/**
* 来源类型 eg:resi_topic
*/
private String sourceType;
/**
* 来源ID eg:2223232(当SOURCE_TYPE为"resi_topic"这里指话题的ID)
*/
private String sourceId;
/**
* 关闭理由 未关闭时可以为空关闭议题时必填的理由转项目后而且已经结案这个字段不回写
*/
private String closeReason;
/**
* 解决类型 未关闭时可以为空已解决resolved未解决unresolved对应在关闭议题时所选的checkbox转项目后而且已经结案这个字段不回写
*/
private String resolveType;
/**
* 议题名称 最多20字
*/
private String issueTitle;
/**
* 建议 最多1000字
*/
private String suggestion;
/**
* 客户ID
*/
private String customerId;
/**
* 网格ID 居民端议题对应一个网格Id
*/
private String gridId;
/**
* 所属机关 数据权限-非必填11:22:33(agencyId)数据权限控制
*/
private String orgIdPath;
/**
* 组织ID 数据权限-非必填agencyId
*/
private String orgId;
/**
* 表决截止日期
*/
private Date votingDeadline;
/**
* 表决发起日期转议题日期
*/
private Date decidedTime;
/**
* 转项目日期 服务间调用日期一致性
*/
private Date shiftedTime;
/**
* 关闭日期
*/
private Date closedTime;
}

12
epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/impl/ProjectCategoryServiceImpl.java

@ -31,8 +31,7 @@ import com.epmet.dao.ProjectTagsDao;
import com.epmet.dto.ProjectCategoryDTO;
import com.epmet.dto.form.ProjectCategoryTagListFormDTO;
import com.epmet.dto.form.ProjectSaveCategoryFormDTO;
import com.epmet.dto.result.ProjectCategoryTagListResultDTO;
import com.epmet.dto.result.ProjectCategoryTagResultDTO;
import com.epmet.dto.result.*;
import com.epmet.entity.ProjectCategoryEntity;
import com.epmet.feign.GovIssueOpenFeignClient;
import com.epmet.redis.ProjectCategoryRedis;
@ -42,6 +41,7 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.Map;
@ -151,12 +151,12 @@ public class ProjectCategoryServiceImpl extends BaseServiceImpl<ProjectCategoryD
public void saveCategory(ProjectSaveCategoryFormDTO formDTO) {
//1.查询项目所属客户和所属网格信息以及分类对应的分类信息
/*Result<ProjectIssueCategoryResultDTO> result = govIssueOpenFeignClient.getProjectAndCategoryInfo(formDTO);
Result<ProjectIssueCategoryResultDTO> result = govIssueOpenFeignClient.getProjectAndCategoryInfo(formDTO);
if (!result.success()) {
throw new RenException(String.format("保存项目分类,获取项目对应的议题信息以及分类信息失败,projiectId->%s", formDTO.getProjectId()));
}
IssueDTO issue = result.getData().getIssueDTO();
List<IssueProjectCategoryDictDTO> categoryList = result.getData().getCategoryList();
ProjectIssueDTOResultDTO issue = result.getData().getIssueDTO();
List<ProjectCategoryDTOResultDTO> categoryList = result.getData().getCategoryList();
//2.汇总批量新增数据
List<ProjectCategoryEntity> entityList = new ArrayList<>();
@ -180,7 +180,7 @@ public class ProjectCategoryServiceImpl extends BaseServiceImpl<ProjectCategoryD
//4.批量保存议题分类信息
if (!insertBatch(entityList)) {
throw new RenException(String.format("项目分类信息保存失败"));
}*/
}
}

Loading…
Cancel
Save