Browse Source

多写方法删除

dev
sunyuchao 3 years ago
parent
commit
b570c6e678
  1. 22
      epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/controller/IcEventController.java
  2. 3
      epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/dao/IcEventDao.java
  3. 4
      epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/dao/ProjectDao.java
  4. 3
      epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/IcEventService.java
  5. 79
      epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/impl/IcEventServiceImpl.java
  6. 11
      epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/impl/ResiEventServiceImpl.java
  7. 69
      epmet-module/gov-project/gov-project-server/src/main/resources/mapper/IcEventDao.xml
  8. 26
      epmet-module/gov-project/gov-project-server/src/main/resources/mapper/ProjectDao.xml

22
epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/controller/IcEventController.java

@ -491,18 +491,6 @@ public class IcEventController {
return new Result();
}
/**
* @Description 上报事件-回复列表
* 模仿gov/project/resieventreply/list接口重新查询新表接口
* @author sun
*/
@PostMapping("icevent-list")
public Result<List<ReplyListResultDTO>> replyList(@LoginUser TokenDto tokenDto, @RequestBody ReplyListFormDTO formDTO){
formDTO.setCurrentUserId(tokenDto.getUserId());
ValidatorUtils.validateEntity(formDTO, ReplyListFormDTO.ReplyListForm.class);
return new Result<List<ReplyListResultDTO>>().ok(icEventService.icEventReplyList(formDTO));
}
/**
* 数据分析-个人档案-上报事件列表,根据epmetUserIdList查询
* 模仿gov/project/resieventreply/pageuserreported接口重新查询新表接口
@ -514,16 +502,6 @@ public class IcEventController {
return new Result<PageData<PageUserReportEventResDTO>>().ok(icEventService.icEventPageUserReported(formDTO));
}
/**
* 数字赋能平台-个人档案-事件详情
* 模仿gov/project/resieventreply/eventdetail-icdata 接口重新查询新表接口
* @author sun
*/
@PostMapping("icevent-eventdetail-icdata")
public Result<EventDetailResultDTO> icEventDetailForIcData(@RequestBody ResiEventDetailFormDTO formDTO) {
ValidatorUtils.validateEntity(formDTO, ResiEventDetailFormDTO.AddUserInternalGroup.class);
return new Result<EventDetailResultDTO>().ok(icEventService.icEventDetailForIcData(formDTO.getResiEventId()));
}
}

3
epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/dao/IcEventDao.java

@ -138,9 +138,6 @@ public interface IcEventDao extends BaseDao<IcEventEntity> {
*/
Integer getResiReportEventCount(@Param("reportorIdCard") String reportorIdCard);
List<ReplyListResultDTO> selectReplyList(@Param("icEventId") String icEventId);
List<PageUserReportEventResDTO> selectUserReported(PageUserReportEventFormDTO formDTO);
EventDetailResultDTO selectEventDetail(@Param("icEventId") String icEventId);
}

4
epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/dao/ProjectDao.java

@ -241,10 +241,6 @@ public interface ProjectDao extends BaseDao<ProjectEntity> {
@Param("categoryCode")String categoryCode,
@Param("excludeProjectId") String excludeProjectId,
@Param("epmetUserIds")List<String> epmetUserIds);
List<ProjectInfoIcData> selectCommonCategoryIcEventProject(@Param("customerId")String customerId,
@Param("categoryCode")String categoryCode,
@Param("excludeProjectId") String excludeProjectId,
@Param("epmetUserIds")List<String> epmetUserIds);
/**
* 数据分析-个人档案-话题详情页面的研判分析项目列表

3
epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/IcEventService.java

@ -221,9 +221,6 @@ public interface IcEventService extends BaseService<IcEventEntity> {
**/
void govRedDot(String icEventId);
List<ReplyListResultDTO> icEventReplyList(ReplyListFormDTO formDTO);
PageData<PageUserReportEventResDTO> icEventPageUserReported(PageUserReportEventFormDTO formDTO);
EventDetailResultDTO icEventDetailForIcData(String icEventId);
}

79
epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/impl/IcEventServiceImpl.java

@ -22,7 +22,6 @@ import com.epmet.commons.tools.scan.result.SyncScanResult;
import com.epmet.commons.tools.utils.*;
import com.epmet.constant.*;
import com.epmet.dao.IcEventDao;
import com.epmet.dao.ProjectDao;
import com.epmet.dto.*;
import com.epmet.dto.form.*;
import com.epmet.dto.form.demand.DemandRecId;
@ -95,10 +94,6 @@ public class IcEventServiceImpl extends BaseServiceImpl<IcEventDao, IcEventEntit
private EpmetMessageOpenFeignClient messageOpenFeignClient;
@Autowired
private ProjectSatisfactionDetailService projectSatisfactionDetailService;
@Autowired
private ProjectDao projectDao;
@Autowired
private EpmetUserOpenFeignClient epmetUserOpenFeignClient;
public CustomerStaffInfoCacheResult getStaffInfo(String customerId,String staffId){
@ -1586,17 +1581,6 @@ public class IcEventServiceImpl extends BaseServiceImpl<IcEventDao, IcEventEntit
baseDao.updateById(entity);
}
@Override
public List<ReplyListResultDTO> icEventReplyList(ReplyListFormDTO formDTO) {
List<ReplyListResultDTO> list = baseDao.selectReplyList(formDTO.getResiEventId());
list.forEach(dto -> {
if (dto.getReplyUserId().equals(formDTO.getCurrentUserId())) {
dto.setReplyName("我");
}
});
return list;
}
@Override
public PageData<PageUserReportEventResDTO> icEventPageUserReported(PageUserReportEventFormDTO formDTO) {
if (org.apache.commons.collections4.CollectionUtils.isEmpty(formDTO.getEpmetUserIdList())) {
@ -1607,67 +1591,4 @@ public class IcEventServiceImpl extends BaseServiceImpl<IcEventDao, IcEventEntit
return new PageData<>(pageInfo.getList(), pageInfo.getTotal());
}
@Override
public EventDetailResultDTO icEventDetailForIcData(String icEventId) {
EventDetailResultDTO dto = baseDao.selectEventDetail(icEventId);
if (null == dto) {
return new EventDetailResultDTO();
}
//附件按类型分组【图片、语音】
List<String> eventImgs = new ArrayList<>();
List<FileCommonDTO> voiceList = new ArrayList<>();
dto.getAttachmentList().forEach(file -> {
if ("image".equals(file.getType())) {
eventImgs.add(file.getUrl());
} else if ("voice".equals(file.getType())) {
FileCommonDTO fl = new FileCommonDTO();
fl.setUrl(file.getUrl());
fl.setDuration(file.getDuration());
voiceList.add(fl);
}
});
dto.setEventImgs(eventImgs);
dto.setVoiceList(voiceList);
// 已转项目
if (dto.getIsProject()) {
// 查询项目信息
EventProjectInfoDTO eventProjectInfo = projectDao.selectEventProjectInfo(dto.getProjectId());
// 查询操作人的名字
Result<String> staffName = govOrgOpenFeignClient.staffName(eventProjectInfo.getUserId());
if (!staffName.success()) {
throw new RenException("查询工作人员名字失败");
}
eventProjectInfo.setOperationName(staffName.getData());
dto.setProjectInfo(eventProjectInfo);
}
// 查询报事人名字
List<String> userIdList = new ArrayList<>();
userIdList.add(dto.getEventUserId());
Result<List<UserBaseInfoResultDTO>> userResult = epmetUserOpenFeignClient.queryUserBaseInfo(userIdList);
if (!userResult.success() || CollectionUtils.isEmpty(userResult.getData())) {
throw new RenException("查询当前用户信息异常");
}
userResult.getData().forEach(u -> {
if (u.getUserId().equals(dto.getEventUserId())) {
dto.setEventPeopleName(u.getUserShowName());
}
});
// 查询所属网格
Result<String> gridNameResult = govOrgOpenFeignClient.gridName(dto.getGridId());
if (!gridNameResult.success()) {
throw new RenException("查询所属网格失败");
}
dto.setGridName(gridNameResult.getData());
// 查询报事的org
List<String> orgNameList = dto.getOrgNameList();
Result<List<String>> orgResult = govOrgOpenFeignClient.selectOrgNameByType(orgNameList);
if (!orgResult.success()) {
throw new RenException("查询组织名称失败");
}
List<String> data = orgResult.getData();
dto.setEventOrg(data);
return dto;
}
}

11
epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/impl/ResiEventServiceImpl.java

@ -20,7 +20,6 @@ package com.epmet.service.impl;
import com.alibaba.fastjson.JSON;
import com.epmet.commons.mybatis.service.impl.BaseServiceImpl;
import com.epmet.commons.tools.constant.AppClientConstant;
import com.epmet.commons.tools.constant.CustomerIdConstant;
import com.epmet.commons.tools.constant.NumConstant;
import com.epmet.commons.tools.constant.StrConstant;
import com.epmet.commons.tools.dto.form.FileCommonDTO;
@ -938,16 +937,8 @@ public class ResiEventServiceImpl extends BaseServiceImpl<ResiEventDao, ResiEven
List<ProjectDataDTO> projectData=new ArrayList<>();
for(IssueProjectCategoryDictDTO categoryDictDTO:categoryRes.getData()){
//当前项目分类一致,排除当前项目,相同分类编码
//2022.6.27 市北客户继续沿用直接接口,其他客户不在查询resi_event表 改查ic_eveent表数据 sun start
List<ProjectInfoIcData> projectList = new ArrayList<>();
if (CustomerIdConstant.SHI_BEI_CUSTOMER_ID.equals(projectCategoryDTOList.get(NumConstant.ZERO).getCustomerId())) {
projectList = projectDao.selectCommonCategoryEventProject(projectCategoryDTOList.get(NumConstant.ZERO).getCustomerId(),
List<ProjectInfoIcData> projectList = projectDao.selectCommonCategoryEventProject(projectCategoryDTOList.get(NumConstant.ZERO).getCustomerId(),
categoryDictDTO.getCategoryCode(), formDTO.getProjectId(), formDTO.getEpmetUserIdList());
} else {
projectList = projectDao.selectCommonCategoryIcEventProject(projectCategoryDTOList.get(NumConstant.ZERO).getCustomerId(),
categoryDictDTO.getCategoryCode(), formDTO.getProjectId(), formDTO.getEpmetUserIdList());
}
//2022.6.27 市北客户继续沿用直接接口,其他客户不在查询resi_event表 改查ic_eveent表数据 sun end
if(!CollectionUtils.isEmpty(projectList)){
ProjectDataDTO projectDataDTO=new ProjectDataDTO();
projectDataDTO.setFirstCategoryCode(categoryDictDTO.getCategoryCode());

69
epmet-module/gov-project/gov-project-server/src/main/resources/mapper/IcEventDao.xml

@ -376,21 +376,6 @@
and e.DEL_FLAG = '0'
</select>
<select id="selectReplyList" resultType="com.epmet.dto.result.ReplyListResultDTO">
SELECT
rer.user_show_name as replyName,
rer.created_time as replyTime,
rer.content as replyContent,
rer.from_user_id as replyUserId
FROM
ic_event_reply rer
WHERE
rer.del_flag = '0'
AND rer.ic_event_id = #{icEventId}
ORDER BY
rer.created_time DESC
</select>
<select id="selectUserReported" resultType="com.epmet.dto.result.PageUserReportEventResDTO">
SELECT
re.id AS resiEventId,
@ -408,59 +393,5 @@
ORDER BY re.created_time desc
</select>
<!-- 报事详情 -->
<resultMap id="selectEventDetailMap" type="com.epmet.dto.result.EventDetailResultDTO">
<result property="isProject" column="isProject"/>
<result property="eventTime" column="eventTime"/>
<result property="eventContent" column="eventContent"/>
<result property="eventAddress" column="eventAddress"/>
<result property="isClosed" column="isClosed"/>
<result property="isResolve" column="isResolve"/>
<result property="isRollback" column="isRollback"/>
<result property="projectId" column="projectId"/>
<result property="gridId" column="gridId"/>
<result property="eventUserId" column="eventUserId"/>
<!--<collection property="eventImgs" ofType="java.lang.String">
<result column="eventImg"/>
</collection>-->
<collection property="attachmentList" ofType="com.epmet.dto.result.EventDetailResultDTO$Attachment">
<result column="resiEventAttachmentId"/><!-- 附件表ID,如果附件url和type一样会被去重 加上id就可以了 -->
<result column="url" property="url"/>
<result column="type" property="type"/>
<result column="duration" property="duration"/>
</collection>
<!--<collection property="eventPerson" ofType="java.lang.String">
<result column="person"/>
</collection>
<collection property="eventPersonIds" ofType="java.lang.String">
<result column="personUserId"/>
</collection>-->
<collection property="orgNameList" ofType="java.lang.String">
<result column="orgId"/>
</collection>
</resultMap>
<select id="selectEventDetail" resultType="com.epmet.dto.result.EventDetailResultDTO">
SELECT
IFNULL(DATE_FORMAT(re.CREATED_TIME,'%Y-%m-%d %H:%i:%s'),'') AS eventTime,
IFNULL(re.EVENT_CONTENT,'') AS eventContent,
IFNULL(re.ADDRESS,'') AS eventAddress,
(CASE WHEN re.`STATUS` = 'processing' THEN FALSE WHEN re.`STATUS` = 'closed_case' THEN TRUE ELSE FALSE END) AS isClosed,
(IF(IFNULL(re.RESOLVE_STATUS,TRUE) OR '' = re.RESOLVE_STATUS, TRUE, FALSE)) AS isResolve,
(CASE WHEN re.READ_FLAG = 1 THEN FALSE ELSE TRUE END) AS isRollback,
(CASE WHEN re.operation_type = 1 THEN TRUE ELSE FALSE END) AS isProject,
if(re.operation_type='1', re.OPERATION_ID, '') AS projectId,
ea.id AS resiEventAttachmentId,
ea.ATTACHMENT_URL AS url,
ea.ATTACHMENT_TYPE AS type,
ea.duration AS duration,
re.GRID_ID AS gridId,
re.REPORT_USER_ID AS eventUserId,
re.AGENCY_ID AS orgId
FROM ic_event re
LEFT JOIN ic_event_attachment ea ON (ea.IC_EVENT_ID = re.ID AND ea.DEL_FLAG = '0')
WHERE re.DEL_FLAG = '0'
AND re.ID = #{icEventId}
order by ea.sort asc
</select>
</mapper>

26
epmet-module/gov-project/gov-project-server/src/main/resources/mapper/ProjectDao.xml

@ -440,32 +440,6 @@
order by p.CREATED_TIME desc
</select>
<select id="selectCommonCategoryIcEventProject" parameterType="map" resultType="com.epmet.dto.result.ProjectInfoIcData">
select
distinct
pc.project_id as projectId,
p.title as projectTitle,
p.origin_id as resiEventId,
p.`status` as projectStatus,
'' as issueId,
'' as topicId
FROM project_category pc
INNER JOIN project p ON (pc.project_id = p.id)
INNER JOIN ic_event re ON (p.origin_id = re.id)
WHERE
pc.del_flag = '0'
AND p.del_flag = '0'
AND re.del_flag = '0'
AND pc.customer_id = #{customerId}
AND p.origin = 'ic_event'
AND pc.project_id != #{excludeProjectId}
<foreach collection="epmetUserIds" item="epmetUserId" open="AND( " separator=" OR " index="index" close=")">
re.report_user_id = #{epmetUserId}
</foreach>
AND pc.category_code like concat(#{categoryCode},'%')
ORDER BY p.created_time desc
</select>
<!-- 数据分析-个人档案-话题详情页面的研判分析项目列表 -->
<select id="selectCommonCategoryIssueProject" parameterType="map" resultType="com.epmet.dto.result.ProjectInfoIcData">
SELECT

Loading…
Cancel
Save