From 32b044aa78edf5d3e54c380a7ded17a266af6948 Mon Sep 17 00:00:00 2001 From: liyj <15602261488@163.com> Date: Sat, 26 Oct 2024 12:01:01 +0800 Subject: [PATCH] 1、白云区矛盾纠纷多元化解平台数据割接脚本-同步在途工单 --- dyh-service/dyh-sync-bydyh/src/main/java/cn/huge/module/bycase/service/CaseInfoService.java | 284 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 281 insertions(+), 3 deletions(-) diff --git a/dyh-service/dyh-sync-bydyh/src/main/java/cn/huge/module/bycase/service/CaseInfoService.java b/dyh-service/dyh-sync-bydyh/src/main/java/cn/huge/module/bycase/service/CaseInfoService.java index 92cb758..e328a56 100644 --- a/dyh-service/dyh-sync-bydyh/src/main/java/cn/huge/module/bycase/service/CaseInfoService.java +++ b/dyh-service/dyh-sync-bydyh/src/main/java/cn/huge/module/bycase/service/CaseInfoService.java @@ -133,7 +133,7 @@ public List<GZCaseDTO> byToGzEndCase(int page, int size){ List<GZCaseDTO> gzCaseDTOList = new ArrayList<>(); Map<String, Object> terms = Maps.newHashMap(); - terms.put("EndProcess", "EndProcess"); + 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); @@ -445,7 +445,7 @@ } // 结案归档节点 if (ByFlowNodeEnum.FLOW_NODE_4.getIndex().equals(caseTask.getTaskNode()) - || ByFlowNodeEnum.FLOW_NODE_5.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("结案归档"); @@ -462,7 +462,7 @@ gzCaseTaskDTO.setCandeUserId(caseTask.getHandlerUserId()); gzCaseTaskDTO.setCandeUserName(caseTask.getHandlerUserName()); // 任务处理 - if ("2".equals(caseTask.getStatus())) { + if ("2".equals(caseTask.getStatus())){ gzCaseTaskDTO.setStatus(GZCaseTaskConsts.TASK_STATUS_2); }else { gzCaseTaskDTO.setStatus(GZCaseTaskConsts.TASK_STATUS_1); @@ -502,4 +502,282 @@ return gzCaseDTOList; } + /** + * 数据割接-进行中的纠纷案件信息 + * @return + */ + public List<GZCaseDTO> byToGzTodoCase(int page, int size){ + List<GZCaseDTO> gzCaseDTOList = new ArrayList<>(); + Map<String, Object> terms = Maps.newHashMap(); + terms.put("todoProcess", "todoProcess"); + 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){ + if ("2105191835025741".equals(caseInfo.getWantUnitId()) || "2105191835025741".equals(caseInfo.getMediateUnitId())){ + log.info("过滤演示案件"); + }else { + 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())) { + if (ByRegionEnum.getGZRegion(caseInfo.getRoad()) != null) { + 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); + gzCaseDTO.setByCaseTaskDTOList(caseTaskList); + gzCaseDTOList.add(gzCaseDTO); + } + } + return gzCaseDTOList; + } + } -- Gitblit v1.8.0