package cn.huge.module.bycase.service;
|
|
import cn.huge.base.common.constant.GzRegionEnum;
|
import cn.huge.base.common.exception.ServiceException;
|
import cn.huge.base.common.utils.ObjectUtils;
|
import cn.huge.module.bycase.domain.dto.*;
|
import cn.huge.module.bycase.domain.po.CaseAgent;
|
import cn.huge.module.bycase.domain.po.CaseInfo;
|
import cn.huge.module.bycase.dao.mapper.CaseInfoMapper;
|
import cn.huge.module.bycase.domain.po.CasePerson;
|
import cn.huge.module.bycase.domain.po.CaseTask;
|
import cn.huge.module.client.api.impl.UtilsClientImpl;
|
import cn.huge.module.constant.*;
|
import cn.huge.module.mediate.constant.*;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.google.common.collect.Maps;
|
import org.apache.commons.collections.CollectionUtils;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.data.domain.Sort;
|
import org.springframework.stereotype.Service;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.data.domain.Page;
|
import org.springframework.data.domain.PageImpl;
|
import org.springframework.data.domain.PageRequest;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import javax.management.Query;
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* @title: 纠纷信息表业务逻辑处理
|
* @Description 纠纷信息表业务逻辑处理
|
* @company hugeinfo
|
* @author liyj
|
* @Time 2024-10-21 08:46:39
|
* @version 1.0.0
|
*/
|
@Slf4j
|
@Service
|
@Transactional(rollbackFor = Exception.class)
|
public class CaseInfoService extends ServiceImpl<CaseInfoMapper, CaseInfo>{
|
|
@Autowired
|
private CaseInfoMapper mapper;
|
@Autowired
|
private UtilsClientImpl utilsClient;
|
@Autowired
|
private CasePersonService casePersonService;
|
@Autowired
|
private CaseAgentService caseAgentService;
|
@Autowired
|
private CaseTaskService caseTaskService;
|
|
/**
|
* 更新对象
|
* @param entity 对象
|
*/
|
public void updateCaseInfo(CaseInfo entity){
|
try{
|
mapper.updateCaseInfo(entity);
|
}catch (Exception e){
|
log.error("[CaseInfoService.updateCaseInfo]调用失败，异常信息："+e, e);
|
throw new ServiceException("CaseInfoService.updateCaseInfo", e);
|
}
|
}
|
|
/**
|
* 条件更新对象
|
* @param entity 对象
|
* @param terms 条件
|
*/
|
public void updateCaseInfoTerms(CaseInfo entity, Map<String, Object> terms){
|
try{
|
mapper.updateCaseInfoTerms(entity, terms);
|
}catch (Exception e){
|
log.error("[CaseInfoService.updateCaseInfoTerms]调用失败，异常信息："+e, e);
|
throw new ServiceException("CaseInfoService.updateCaseInfoTerms", e);
|
}
|
}
|
|
/**
|
* 根据编号物理删除
|
* @param id 查询条件集合
|
*/
|
public void deleteCaseInfo(String id){
|
try{
|
mapper.deleteCaseInfo(id);
|
}catch (Exception e){
|
log.error("[CaseInfoService.deleteCaseInfo]调用失败，异常信息："+e, e);
|
throw new ServiceException("CaseInfoService.deleteCaseInfo", e);
|
}
|
}
|
|
/**
|
* 按条件查询
|
* @param terms 条件
|
* @return List
|
*/
|
public List<CaseInfo> listTerms(Map<String, Object> terms){
|
return mapper.listTerms(terms);
|
}
|
|
/**
|
* 按条件统计
|
* @param terms 条件
|
* @return long
|
*/
|
public long countTerms(Map<String, Object> terms){
|
return mapper.countTerms(terms);
|
}
|
|
/**
|
* 按条件分页查询
|
* @param page 分页对象
|
* @param terms 条件
|
* @return Page
|
*/
|
public Page<CaseInfo> pageQuery(PageRequest page, Map<String, Object> terms){
|
long total = mapper.countTerms(terms);
|
List<CaseInfo> content = mapper.pageTerms(page, terms);
|
return new PageImpl<CaseInfo>(content, page, total);
|
}
|
|
/**
|
* 数据割接-已结束的纠纷案件信息
|
* @return
|
*/
|
public List<GZCaseDTO> byToGzEndCase(int page, int size){
|
List<GZCaseDTO> gzCaseDTOList = new ArrayList<>();
|
Map<String, Object> terms = Maps.newHashMap();
|
terms.put("EndProcess", "EndProcess");
|
Sort sort = Sort.by(Sort.Direction.DESC, "create_time");
|
PageRequest pageRequest = PageRequest.of(page-1, size, sort);
|
Page<CaseInfo> caseInfoPage = this.pageQuery(pageRequest, terms);
|
for (CaseInfo caseInfo: caseInfoPage){
|
GZCaseDTO gzCaseDTO = new GZCaseDTO();
|
// 封装案件信息
|
GZCaseInfoDTO gzCaseInfoDTO = new GZCaseInfoDTO();
|
BeanUtils.copyProperties(caseInfo, gzCaseInfoDTO);
|
// 生成事项编号
|
gzCaseInfoDTO.setCaseRef(utilsClient.createCaseRef());
|
// 都是3级事件
|
gzCaseInfoDTO.setCaseLevel(CaseBaseConsts.CASE_LEVEL_3);
|
// 映射来访时间
|
gzCaseInfoDTO.setVisitTime(caseInfo.getAcceptTime());
|
// 映射来访人数
|
gzCaseInfoDTO.setVisitPeopleNum(caseInfo.getPeopleNum());
|
// 映射纠纷类型
|
// gzCaseInfoDTO.setCaseTypeFirst();
|
// gzCaseInfoDTO.setCaseTypeFirstName();
|
// gzCaseInfoDTO.setCaseType();
|
// gzCaseInfoDTO.setCaseTypeName();
|
// 映射问题属地
|
gzCaseInfoDTO.setQueProv(GzRegionEnum.PROV_1.getIndex());
|
gzCaseInfoDTO.setQueProvName(GzRegionEnum.PROV_1.getDes());
|
gzCaseInfoDTO.setQueCity(GzRegionEnum.CITY_1.getIndex());
|
gzCaseInfoDTO.setQueCityName(GzRegionEnum.CITY_1.getDes());
|
gzCaseInfoDTO.setQueArea(GzRegionEnum.AREA_7.getIndex());
|
gzCaseInfoDTO.setQueAreaName(GzRegionEnum.AREA_7.getDes());
|
if (StringUtils.isNotEmpty(caseInfo.getRoad())) {
|
gzCaseInfoDTO.setQueRoad(ByRegionEnum.getGZRegion(caseInfo.getRoad()).getIndex());
|
gzCaseInfoDTO.setQueRoadName(ByRegionEnum.getGZRegion(caseInfo.getRoad()).getDes());
|
}
|
gzCaseInfoDTO.setQueVillage(null);
|
gzCaseInfoDTO.setQueVillageName(null);
|
if ("2".equals(caseInfo.getInputWay())) {
|
gzCaseInfoDTO.setInputWay(2);
|
}else {
|
gzCaseInfoDTO.setInputWay(1);
|
}
|
// 映射事项来源、来访形式
|
if (ByCaseConstsEnum.CASE_CANAL_1.getIndex().equals(caseInfo.getCanal())){
|
if (caseInfo.getMediateUnitId().equals(caseInfo.getInputUnitId())){
|
// 事项来源
|
gzCaseInfoDTO.setCanal(CaseBaseConstsEnum.CASE_CANAL_3.getIndex());
|
gzCaseInfoDTO.setCanalName(CaseBaseConstsEnum.CASE_CANAL_3.getDes());
|
// 来访形式
|
gzCaseInfoDTO.setVisitWay(CaseBaseConstsEnum.getVisitWayByCanal(gzCaseInfoDTO.getCanal()).getIndex());
|
gzCaseInfoDTO.setVisitWayName(CaseBaseConstsEnum.getVisitWayByCanal(gzCaseInfoDTO.getCanal()).getDes());
|
}else {
|
// 事项来源
|
gzCaseInfoDTO.setCanal(CaseBaseConstsEnum.CASE_CANAL_1.getIndex());
|
gzCaseInfoDTO.setCanalName(CaseBaseConstsEnum.CASE_CANAL_1.getDes());
|
// 来访形式
|
gzCaseInfoDTO.setVisitWay(CaseBaseConstsEnum.getVisitWayByCanal(gzCaseInfoDTO.getCanal()).getIndex());
|
gzCaseInfoDTO.setVisitWayName(CaseBaseConstsEnum.getVisitWayByCanal(gzCaseInfoDTO.getCanal()).getDes());
|
}
|
}else if (ByCaseConstsEnum.CASE_CANAL_2.getIndex().equals(caseInfo.getCanal())){
|
// 事项来源
|
gzCaseInfoDTO.setCanal(CaseBaseConstsEnum.CASE_CANAL_2.getIndex());
|
gzCaseInfoDTO.setCanalName(CaseBaseConstsEnum.CASE_CANAL_2.getDes());
|
// 来访形式
|
gzCaseInfoDTO.setVisitWay(CaseBaseConstsEnum.getVisitWayByCanal(gzCaseInfoDTO.getCanal()).getIndex());
|
gzCaseInfoDTO.setVisitWayName(CaseBaseConstsEnum.getVisitWayByCanal(gzCaseInfoDTO.getCanal()).getDes());
|
}
|
// 映射是否自行受理
|
gzCaseInfoDTO.setZxslStatus(CaseBaseConsts.ZXSL_STATUS_0);
|
// 是否重大矛盾纠纷
|
gzCaseInfoDTO.setMajorStatus(CaseBaseConsts.MAJOR_STATUS_0);
|
// 映射事项状态、事项进度、对外展示事项进度
|
if (ByCaseConstsEnum.CASE_PROCESS_1.getIndex().equals(caseInfo.getProcess())){
|
// 事项状态
|
gzCaseInfoDTO.setStatus(CaseStatusBaseConstsEnum.CASE_STATUS_3.getIndex());
|
gzCaseInfoDTO.setStatusName(CaseStatusBaseConstsEnum.CASE_STATUS_3.getDes());
|
// 事项进度
|
gzCaseInfoDTO.setProcess(CaseProcessBaseConstsEnum.getByStatus(gzCaseInfoDTO.getStatus()).getIndex());
|
gzCaseInfoDTO.setProcessName(CaseProcessBaseConstsEnum.getByStatus(gzCaseInfoDTO.getStatus()).getDes());
|
// 对外展示事项进度
|
gzCaseInfoDTO.setInfoProcess(CaseInfoProcessBaseConstsEnum.getByProcess(gzCaseInfoDTO.getProcess()).getIndex());
|
gzCaseInfoDTO.setInfoProcessName(CaseInfoProcessBaseConstsEnum.getByProcess(gzCaseInfoDTO.getProcess()).getDes());
|
}else if (ByCaseConstsEnum.CASE_PROCESS_2.getIndex().equals(caseInfo.getProcess())){
|
// 事项状态
|
gzCaseInfoDTO.setStatus(CaseStatusBaseConstsEnum.CASE_STATUS_3.getIndex());
|
gzCaseInfoDTO.setStatusName(CaseStatusBaseConstsEnum.CASE_STATUS_3.getDes());
|
// 事项进度
|
gzCaseInfoDTO.setProcess(CaseProcessBaseConstsEnum.getByStatus(gzCaseInfoDTO.getStatus()).getIndex());
|
gzCaseInfoDTO.setProcessName(CaseProcessBaseConstsEnum.getByStatus(gzCaseInfoDTO.getStatus()).getDes());
|
// 对外展示事项进度
|
gzCaseInfoDTO.setInfoProcess(CaseInfoProcessBaseConstsEnum.getByProcess(gzCaseInfoDTO.getProcess()).getIndex());
|
gzCaseInfoDTO.setInfoProcessName(CaseInfoProcessBaseConstsEnum.getByProcess(gzCaseInfoDTO.getProcess()).getDes());
|
}else if (ByCaseConstsEnum.CASE_PROCESS_3.getIndex().equals(caseInfo.getProcess())){
|
// 事项状态
|
gzCaseInfoDTO.setStatus(CaseStatusBaseConstsEnum.CASE_STATUS_4.getIndex());
|
gzCaseInfoDTO.setStatusName(CaseStatusBaseConstsEnum.CASE_STATUS_4.getDes());
|
// 事项进度
|
gzCaseInfoDTO.setProcess(CaseProcessBaseConstsEnum.getByStatus(gzCaseInfoDTO.getStatus()).getIndex());
|
gzCaseInfoDTO.setProcessName(CaseProcessBaseConstsEnum.getByStatus(gzCaseInfoDTO.getStatus()).getDes());
|
// 对外展示事项进度
|
gzCaseInfoDTO.setInfoProcess(CaseInfoProcessBaseConstsEnum.getByProcess(gzCaseInfoDTO.getProcess()).getIndex());
|
gzCaseInfoDTO.setInfoProcessName(CaseInfoProcessBaseConstsEnum.getByProcess(gzCaseInfoDTO.getProcess()).getDes());
|
}else if (ByCaseConstsEnum.CASE_PROCESS_4.getIndex().equals(caseInfo.getProcess())){
|
// 事项状态
|
gzCaseInfoDTO.setStatus(CaseStatusBaseConstsEnum.CASE_STATUS_7.getIndex());
|
gzCaseInfoDTO.setStatusName(CaseStatusBaseConstsEnum.CASE_STATUS_7.getDes());
|
// 事项进度
|
gzCaseInfoDTO.setProcess(CaseProcessBaseConstsEnum.getByStatus(gzCaseInfoDTO.getStatus()).getIndex());
|
gzCaseInfoDTO.setProcessName(CaseProcessBaseConstsEnum.getByStatus(gzCaseInfoDTO.getStatus()).getDes());
|
// 对外展示事项进度
|
gzCaseInfoDTO.setInfoProcess(CaseInfoProcessBaseConstsEnum.getByProcess(gzCaseInfoDTO.getProcess()).getIndex());
|
gzCaseInfoDTO.setInfoProcessName(CaseInfoProcessBaseConstsEnum.getByProcess(gzCaseInfoDTO.getProcess()).getDes());
|
}else if (ByCaseConstsEnum.CASE_PROCESS_5.getIndex().equals(caseInfo.getProcess())){
|
// 事项状态
|
gzCaseInfoDTO.setStatus(CaseStatusBaseConstsEnum.CASE_STATUS_8.getIndex());
|
gzCaseInfoDTO.setStatusName(CaseStatusBaseConstsEnum.CASE_STATUS_8.getDes());
|
// 事项进度
|
gzCaseInfoDTO.setProcess(CaseProcessBaseConstsEnum.getByStatus(gzCaseInfoDTO.getStatus()).getIndex());
|
gzCaseInfoDTO.setProcessName(CaseProcessBaseConstsEnum.getByStatus(gzCaseInfoDTO.getStatus()).getDes());
|
// 对外展示事项进度
|
gzCaseInfoDTO.setInfoProcess(CaseInfoProcessBaseConstsEnum.getByProcess(gzCaseInfoDTO.getProcess()).getIndex());
|
gzCaseInfoDTO.setInfoProcessName(CaseInfoProcessBaseConstsEnum.getByProcess(gzCaseInfoDTO.getProcess()).getDes());
|
}else if (ByCaseConstsEnum.CASE_PROCESS_6.getIndex().equals(caseInfo.getProcess())){
|
// 事项状态
|
gzCaseInfoDTO.setStatus(CaseStatusBaseConstsEnum.CASE_STATUS_8.getIndex());
|
gzCaseInfoDTO.setStatusName(CaseStatusBaseConstsEnum.CASE_STATUS_8.getDes());
|
// 事项进度
|
gzCaseInfoDTO.setProcess(CaseProcessBaseConstsEnum.getByStatus(gzCaseInfoDTO.getStatus()).getIndex());
|
gzCaseInfoDTO.setProcessName(CaseProcessBaseConstsEnum.getByStatus(gzCaseInfoDTO.getStatus()).getDes());
|
// 对外展示事项进度
|
gzCaseInfoDTO.setInfoProcess(CaseInfoProcessBaseConstsEnum.getByProcess(gzCaseInfoDTO.getProcess()).getIndex());
|
gzCaseInfoDTO.setInfoProcessName(CaseInfoProcessBaseConstsEnum.getByProcess(gzCaseInfoDTO.getProcess()).getDes());
|
}else if (ByCaseConstsEnum.CASE_PROCESS_7.getIndex().equals(caseInfo.getProcess())){
|
// 事项状态
|
gzCaseInfoDTO.setStatus(CaseStatusBaseConstsEnum.CASE_STATUS_8.getIndex());
|
gzCaseInfoDTO.setStatusName(CaseStatusBaseConstsEnum.CASE_STATUS_8.getDes());
|
// 事项进度
|
gzCaseInfoDTO.setProcess(CaseProcessBaseConstsEnum.getByStatus(gzCaseInfoDTO.getStatus()).getIndex());
|
gzCaseInfoDTO.setProcessName(CaseProcessBaseConstsEnum.getByStatus(gzCaseInfoDTO.getStatus()).getDes());
|
// 对外展示事项进度
|
gzCaseInfoDTO.setInfoProcess(CaseInfoProcessBaseConstsEnum.getByProcess(gzCaseInfoDTO.getProcess()).getIndex());
|
gzCaseInfoDTO.setInfoProcessName(CaseInfoProcessBaseConstsEnum.getByProcess(gzCaseInfoDTO.getProcess()).getDes());
|
}
|
// 映射小程序是否可见
|
gzCaseInfoDTO.setPartyShow(CaseBaseConsts.PARTY_SHOW_1);
|
// 映射删除状态
|
if (ByBaseConsts.DELETE_STATUS_99.equals(caseInfo.getDeleteStatus())) {
|
gzCaseInfoDTO.setDeleteStatus(BaseConsts.DELETE_STATUS_1);
|
}else {
|
gzCaseInfoDTO.setDeleteStatus(BaseConsts.DELETE_STATUS_0);
|
}
|
gzCaseDTO.setGzCaseInfoDTO(gzCaseInfoDTO);
|
|
// 封装案件扩展信息
|
GZCaseInfoUnfoldDTO gzCaseInfoUnfoldDTO = new GZCaseInfoUnfoldDTO();
|
BeanUtils.copyProperties(caseInfo, gzCaseInfoUnfoldDTO);
|
// 映射调解结果名称
|
gzCaseInfoUnfoldDTO.setMediResultName(MediResultBaseConstsEnum.getDes(caseInfo.getMediResult()));
|
// 映射达成协议类型
|
if (ByCaseConstsEnum.CASE_PROCESS_4.getIndex().equals(caseInfo.getProcess())){
|
// 调解成功
|
if (ByCaseConstsEnum.MEDI_RESULT_1.getIndex().equals(caseInfo.getMediResult())){
|
if (StringUtils.isNotEmpty(caseInfo.getAgreeContent())){
|
gzCaseInfoUnfoldDTO.setAgreeType(CaseBaseConstsEnum.AGREE_TYPE_1.getIndex());
|
gzCaseInfoUnfoldDTO.setAgreeTypeName(CaseBaseConstsEnum.AGREE_TYPE_1.getDes());
|
}else {
|
gzCaseInfoUnfoldDTO.setAgreeType(CaseBaseConstsEnum.AGREE_TYPE_2.getIndex());
|
gzCaseInfoUnfoldDTO.setAgreeTypeName(CaseBaseConstsEnum.AGREE_TYPE_2.getDes());
|
}
|
}
|
}
|
// 映射结案意见
|
gzCaseInfoUnfoldDTO.setWindupContent(caseInfo.getMediContent());
|
// 映射是否转诉讼案件
|
if (ByCaseConsts.CIVIL_STATUS_2 == caseInfo.getCivilStatus()){
|
gzCaseInfoUnfoldDTO.setCivilStatus(CaseBaseConsts.CIVIL_STATUS_1);
|
}else {
|
gzCaseInfoUnfoldDTO.setCivilStatus(CaseBaseConsts.CIVIL_STATUS_0);
|
}
|
// 映射办结时间
|
if (ObjectUtils.isNotEmpty(caseInfo.getFileTime())) {
|
gzCaseInfoUnfoldDTO.setCloseTime(caseInfo.getFileTime());
|
}else if (ObjectUtils.isNotEmpty(caseInfo.getMediEndTime())){
|
gzCaseInfoUnfoldDTO.setCloseTime(caseInfo.getMediEndTime());
|
}else {
|
gzCaseInfoUnfoldDTO.setCloseTime(caseInfo.getUpdateTime());
|
}
|
// 映射是否申请司法确认
|
if (ByCaseConsts.JUDIC_APPLY_2 == caseInfo.getCivilStatus()){
|
gzCaseInfoUnfoldDTO.setJudicApply(CaseBaseConsts.JUDIC_APPLY_1);
|
}else {
|
gzCaseInfoUnfoldDTO.setJudicApply(CaseBaseConsts.JUDIC_APPLY_0);
|
}
|
// 映射是否已归档
|
if (ByCaseConsts.FILE_STATUS_2 == caseInfo.getCivilStatus()){
|
gzCaseInfoUnfoldDTO.setFileStatus(CaseBaseConsts.FILE_STATUS_1);
|
}else {
|
gzCaseInfoUnfoldDTO.setFileStatus(CaseBaseConsts.FILE_STATUS_0);
|
}
|
// 映射是否已回访
|
if (ByCaseConsts.VISIT_STATUS_2 == caseInfo.getCivilStatus()){
|
gzCaseInfoUnfoldDTO.setVisitUpStatus(CaseBaseConsts.VISIT_UP_STATUS_1);
|
}else {
|
gzCaseInfoUnfoldDTO.setVisitUpStatus(CaseBaseConsts.VISIT_UP_STATUS_0);
|
}
|
// 映射当事人是否满意
|
if (ByCaseConsts.PARTY_JOY_2 == caseInfo.getCivilStatus()){
|
gzCaseInfoUnfoldDTO.setPartyJoy(CaseBaseConsts.PARTY_JOY_1);
|
}else {
|
gzCaseInfoUnfoldDTO.setPartyJoy(CaseBaseConsts.PARTY_JOY_0);
|
}
|
gzCaseDTO.setGzCaseInfoUnfoldDTO(gzCaseInfoUnfoldDTO);
|
|
// 封装当事人信息
|
QueryWrapper<CasePerson> casePersonQueryWrapper = new QueryWrapper<>();
|
casePersonQueryWrapper.eq("case_id", caseInfo.getId());
|
List<CasePerson> casePersonList = casePersonService.list(casePersonQueryWrapper);
|
if (CollectionUtils.isNotEmpty(casePersonList)){
|
List<GZCasePersonDTO> gzCasePersonDTOList = new ArrayList<>();
|
for (CasePerson casePerson: casePersonList){
|
GZCasePersonDTO gzCasePersonDTO = new GZCasePersonDTO();
|
BeanUtils.copyProperties(casePerson, gzCasePersonDTO);
|
// 映射是否有个人极端倾向
|
gzCasePersonDTO.setExtreme(CaseBaseConsts.EXTREME_0);
|
// 映射删除状态
|
if (ByBaseConsts.DELETE_STATUS_99.equals(casePerson.getDeleteStatus())) {
|
gzCasePersonDTO.setDeleteStatus(BaseConsts.DELETE_STATUS_1);
|
}else {
|
gzCasePersonDTO.setDeleteStatus(BaseConsts.DELETE_STATUS_0);
|
}
|
gzCasePersonDTOList.add(gzCasePersonDTO);
|
}
|
gzCaseDTO.setGzCasePersonDTOList(gzCasePersonDTOList);
|
}
|
|
// 封装当事人代理人信息
|
QueryWrapper<CaseAgent> caseAgentQueryWrapper = new QueryWrapper<>();
|
caseAgentQueryWrapper.eq("case_id", caseInfo.getId());
|
List<CaseAgent> caseAgentList = caseAgentService.list(caseAgentQueryWrapper);
|
if (CollectionUtils.isNotEmpty(caseAgentList)){
|
List<GZCaseAgentDTO> gzCaseAgentDTOList = new ArrayList<>();
|
for (CaseAgent caseAgent: caseAgentList){
|
GZCaseAgentDTO gzCaseAgentDTO = new GZCaseAgentDTO();
|
BeanUtils.copyProperties(caseAgent, gzCaseAgentDTO);
|
// 映射是否有个人极端倾向
|
gzCaseAgentDTO.setExtreme(CaseBaseConsts.EXTREME_0);
|
// 映射删除状态
|
if (ByBaseConsts.DELETE_STATUS_99.equals(caseAgent.getDeleteStatus())) {
|
gzCaseAgentDTO.setDeleteStatus(BaseConsts.DELETE_STATUS_1);
|
}else {
|
gzCaseAgentDTO.setDeleteStatus(BaseConsts.DELETE_STATUS_0);
|
}
|
gzCaseAgentDTOList.add(gzCaseAgentDTO);
|
}
|
gzCaseDTO.setGzCaseAgentDTOList(gzCaseAgentDTOList);
|
}
|
|
// 封装案件任务信息
|
QueryWrapper<CaseTask> caseTaskQueryWrapper = new QueryWrapper<>();
|
caseTaskQueryWrapper.eq("case_id", caseInfo.getId()).orderByAsc("create_time");
|
List<CaseTask> caseTaskList = caseTaskService.list(caseTaskQueryWrapper);
|
if (CollectionUtils.isNotEmpty(caseTaskList)){
|
List<GZCaseTaskDTO> gzCaseTaskDTOList = new ArrayList<>();
|
for (CaseTask caseTask: caseTaskList){
|
GZCaseTaskDTO gzCaseTaskDTO = new GZCaseTaskDTO();
|
BeanUtils.copyProperties(caseTask, gzCaseTaskDTO);
|
// 映射工作流流程定义编号
|
if (CaseBaseConstsEnum.CASE_CANAL_3.getIndex().equals(gzCaseInfoDTO.getCanal())){
|
gzCaseTaskDTO.setFlowableId(GZFlowableConsts.GZDYH_JB_ZXPC_V1);
|
gzCaseTaskDTO.setFlowId("20241002");
|
}else {
|
gzCaseTaskDTO.setFlowableId(GZFlowableConsts.GZDYH_JB_LFDJ_V1);
|
gzCaseTaskDTO.setFlowId("20241001");
|
}
|
// 映射工作流节点类型
|
if ("1".equals(caseTask.getTaskNodeType())) {
|
gzCaseTaskDTO.setNodeType(1);
|
}
|
if ("2".equals(caseTask.getTaskNodeType())) {
|
gzCaseTaskDTO.setNodeType(2);
|
}
|
if ("3".equals(caseTask.getTaskNodeType())) {
|
gzCaseTaskDTO.setNodeType(3);
|
}
|
// 指派调解员节点
|
if (ByFlowNodeEnum.FLOW_NODE_2.getIndex().equals(caseTask.getTaskNode())){
|
gzCaseTaskDTO.setNodeId(GZFlowNodeEnum.FLOW_NODE_DSL.getIndex());
|
gzCaseTaskDTO.setNodeName(GZFlowNodeEnum.FLOW_NODE_DSL.getDes());
|
gzCaseTaskDTO.setNodeShowName("事件流转");
|
// 映射签收状态
|
gzCaseTaskDTO.setSignStatus(GZCaseTaskConsts.SIGN_STATUS_2);
|
gzCaseTaskDTO.setSignTime(caseTask.getCreateTime());
|
gzCaseTaskDTO.setSignUnitId(caseTask.getHandlerUnitId());
|
gzCaseTaskDTO.setSignUnitName(caseTask.getHandlerUnitName());
|
gzCaseTaskDTO.setSignUserId(caseTask.getHandlerUserId());
|
gzCaseTaskDTO.setSignUserName(caseTask.getHandlerUserName());
|
if (CaseBaseConstsEnum.CASE_CANAL_3.getIndex().equals(gzCaseInfoDTO.getCanal())){
|
// 自行受理
|
gzCaseTaskDTO.setHandleIllust("自行受理");
|
}else {
|
// 自行受理
|
gzCaseTaskDTO.setHandleIllust("派单至："+caseTask.getHandlerUnitName());
|
}
|
}
|
// 纠纷调解节点
|
if (ByFlowNodeEnum.FLOW_NODE_3.getIndex().equals(caseTask.getTaskNode())){
|
gzCaseTaskDTO.setNodeId(GZFlowNodeEnum.FLOW_NODE_BLFK.getIndex());
|
gzCaseTaskDTO.setNodeName(GZFlowNodeEnum.FLOW_NODE_BLFK.getDes());
|
gzCaseTaskDTO.setNodeShowName("办理反馈");
|
// 映射签收状态
|
gzCaseTaskDTO.setSignStatus(GZCaseTaskConsts.SIGN_STATUS_0);
|
}
|
// 结案归档节点
|
if (ByFlowNodeEnum.FLOW_NODE_4.getIndex().equals(caseTask.getTaskNode())
|
|| ByFlowNodeEnum.FLOW_NODE_5.getIndex().equals(caseTask.getTaskNode()) ){
|
gzCaseTaskDTO.setNodeId(GZFlowNodeEnum.FLOW_NODE_JAGD.getIndex());
|
gzCaseTaskDTO.setNodeName(GZFlowNodeEnum.FLOW_NODE_JAGD.getDes());
|
gzCaseTaskDTO.setNodeShowName("结案归档");
|
// 映射签收状态
|
gzCaseTaskDTO.setSignStatus(GZCaseTaskConsts.SIGN_STATUS_0);
|
}
|
// 映射纠纷任务类型
|
gzCaseTaskDTO.setCaseTaskType(GZCaseTaskConsts.CASE_TASK_TYPE_1);
|
// 映射任务所属
|
gzCaseTaskDTO.setCandeUnitId(caseTask.getHandlerUnitId());
|
gzCaseTaskDTO.setCandeUnitName(caseTask.getHandlerUnitName());
|
gzCaseTaskDTO.setCandeDeptId(caseTask.getHandlerDeptId());
|
gzCaseTaskDTO.setCandeDeptName(caseTask.getHandlerDeptName());
|
gzCaseTaskDTO.setCandeUserId(caseTask.getHandlerUserId());
|
gzCaseTaskDTO.setCandeUserName(caseTask.getHandlerUserName());
|
// 任务处理
|
if ("2".equals(caseTask.getStatus())) {
|
gzCaseTaskDTO.setStatus(GZCaseTaskConsts.TASK_STATUS_2);
|
}else {
|
gzCaseTaskDTO.setStatus(GZCaseTaskConsts.TASK_STATUS_1);
|
}
|
gzCaseTaskDTO.setHandleUnitId(caseTask.getHandlerUnitId());
|
gzCaseTaskDTO.setHandleUnitName(caseTask.getHandlerUnitName());
|
gzCaseTaskDTO.setHandleDeptId(caseTask.getHandlerDeptId());
|
gzCaseTaskDTO.setHandleDeptName(caseTask.getHandlerDeptName());
|
gzCaseTaskDTO.setHandleUserId(caseTask.getHandlerUserId());
|
gzCaseTaskDTO.setHandleUserName(caseTask.getHandlerUserName());
|
// 映射处理结果
|
if ("2".equals(caseTask.getHandleResult())){
|
gzCaseTaskDTO.setHandleResult(GZCaseTaskConsts.HANDLE_RESULT_4);
|
}else if ("3".equals(caseTask.getHandleResult())){
|
gzCaseTaskDTO.setHandleResult(GZCaseTaskConsts.HANDLE_RESULT_3);
|
}else {
|
gzCaseTaskDTO.setHandleResult(GZCaseTaskConsts.HANDLE_RESULT_0);
|
}
|
// 映射任任务处理时间
|
gzCaseTaskDTO.setHandleTime(caseTask.getFinishTime());
|
// 计算任务耗时、是否超时、超时多少
|
gzCaseTaskDTO.setUsetimeHour(GZTaskUsetimeUtils.getUsetimeHour(gzCaseTaskDTO.getHandleTime(), gzCaseTaskDTO.getCreateTime()));
|
gzCaseTaskDTO.setOvertimeStatus(GZTaskUsetimeUtils.getOvertimeStatus(gzCaseTaskDTO.getHandleTime(), gzCaseTaskDTO.getExpireTime()));
|
gzCaseTaskDTO.setOvertimeHour(GZTaskUsetimeUtils.getOvertimeHour(gzCaseTaskDTO.getHandleTime(), gzCaseTaskDTO.getExpireTime()));
|
// 映射删除状态
|
if (ByBaseConsts.DELETE_STATUS_99.equals(caseTask.getDeleteStatus())) {
|
gzCaseTaskDTO.setDeleteStatus(BaseConsts.DELETE_STATUS_1);
|
}else {
|
gzCaseTaskDTO.setDeleteStatus(BaseConsts.DELETE_STATUS_0);
|
}
|
gzCaseTaskDTOList.add(gzCaseTaskDTO);
|
}
|
gzCaseDTO.setGzCaseTaskDTOList(gzCaseTaskDTOList);
|
}
|
gzCaseDTOList.add(gzCaseDTO);
|
}
|
return gzCaseDTOList;
|
}
|
|
}
|
