package cn.huge.module.syncbydyh.service;
|
|
import cn.huge.base.common.exception.ServiceException;
|
import cn.huge.base.common.utils.ObjectUtils;
|
import cn.huge.module.cases.domain.dto.AcceptTaskDTO;
|
import cn.huge.module.cases.domain.po.*;
|
import cn.huge.module.cases.service.*;
|
import cn.huge.module.client.api.impl.CustClientImpl;
|
import cn.huge.module.cust.constant.UserBaseConsts;
|
import cn.huge.module.cust.dto.CtUnitDTO;
|
import cn.huge.module.cust.dto.CtUserDTO;
|
import cn.huge.module.disp.dto.DispCaseBaseDTO;
|
import cn.huge.module.judic.domain.po.JudicAssist;
|
import cn.huge.module.judic.domain.po.JudicInfo;
|
import cn.huge.module.judic.service.JudicAssistService;
|
import cn.huge.module.judic.service.JudicInfoService;
|
import cn.huge.module.syncbydyh.client.api.impl.SyncBydyhClientImpl;
|
import cn.huge.module.syncbydyh.domain.dto.ByCaseTaskDTO;
|
import cn.huge.module.syncbydyh.domain.dto.GZCaseDTO;
|
import cn.huge.module.syncbydyh.domain.dto.GZJudicAssistDTO;
|
import cn.huge.module.syncbydyh.domain.dto.GZJudicDTO;
|
import cn.huge.module.syncbydyh.domain.po.SyCause;
|
import cn.huge.module.syncbydyh.domain.po.ThirdCause;
|
import com.alibaba.fastjson.JSON;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
|
import lombok.extern.slf4j.Slf4j;
|
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.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.util.ArrayList;
|
import java.util.List;
|
|
/**
|
* @title: 白云区矛盾纠纷多元化解平台数据割接-公共逻辑处理
|
* @Description 白云区矛盾纠纷多元化解平台数据割接-公共逻辑处理
|
* @company hugeinfo
|
* @author liyj
|
* @Time 2024-08-19 20:04:19
|
* @version 1.0.0
|
*/
|
@Slf4j
|
@Service
|
public class ByToGzService{
|
|
@Autowired
|
private SyncBydyhClientImpl syncBydyhClient;
|
@Autowired
|
private CaseInfoService caseInfoService;
|
@Autowired
|
private CaseInfoUnfoldService caseInfoUnfoldService;
|
@Autowired
|
private CasePersonService casePersonService;
|
@Autowired
|
private CaseAgentService caseAgentService;
|
@Autowired
|
private CaseTaskService caseTaskService;
|
@Autowired
|
private ThirdCauseService thirdCauseService;
|
@Autowired
|
private SyCauseService syCauseService;
|
@Autowired
|
private CustClientImpl custClient;
|
@Autowired
|
private ByToGzCaseTaskService byToGzCaseTaskService;
|
@Autowired
|
private JudicInfoService judicInfoService;
|
@Autowired
|
private JudicAssistService judicAssistService;
|
|
/**
|
* 白云区矛盾纠纷多元化解平台数据割接-已结束的纠纷案件信息
|
*/
|
public void byToGzEndCase(){
|
try{
|
List<CaseInfo> errorCaseList = new ArrayList<>();
|
int operSize = 100;
|
// int endCaseCount = 1100;
|
int endCaseCount = syncBydyhClient.countEndCase();
|
if (endCaseCount > 0) {
|
int allPage = 1;
|
if(operSize < endCaseCount) {
|
allPage = (endCaseCount / operSize) + 1;
|
}
|
for (int operPage=1; operPage<=allPage; operPage++) {
|
List<GZCaseDTO> byToGzDTOList = syncBydyhClient.byToGzEndCase(operPage, operSize);
|
for (GZCaseDTO byToGzDTO: byToGzDTOList){
|
CaseInfo oldCaseInfo = caseInfoService.getById(byToGzDTO.getGzCaseInfoDTO().getId());
|
if (ObjectUtils.isEmpty(oldCaseInfo)) {
|
try {
|
// 新增案件信息
|
CaseInfo caseInfo = byToGzDTO.getGzCaseInfoDTO();
|
if (StringUtils.isNotEmpty(caseInfo.getCaseClaim())) {
|
if (caseInfo.getCaseClaim().length() > 200) {
|
caseInfo.setCaseClaim("详见申请材料");
|
}
|
}
|
if (StringUtils.isNotEmpty(caseInfo.getCaseDes())) {
|
if (caseInfo.getCaseDes().length() > 200) {
|
caseInfo.setCaseDes("详见申请材料");
|
}
|
}
|
caseInfoService.save(caseInfo);
|
// 新增案件扩展信息
|
caseInfoUnfoldService.save(byToGzDTO.getGzCaseInfoUnfoldDTO());
|
// 新增当事人信息
|
List<CasePerson> casePersonList = byToGzDTO.getGzCasePersonDTOList();
|
if (CollectionUtils.isNotEmpty(casePersonList)) {
|
for (CasePerson casePerson : casePersonList) {
|
casePersonService.save(casePerson);
|
}
|
}
|
// 新增当事人代理人信息
|
List<CaseAgent> caseAgentList = byToGzDTO.getGzCaseAgentDTOList();
|
if (CollectionUtils.isNotEmpty(caseAgentList)) {
|
for (CaseAgent caseAgent : caseAgentList) {
|
caseAgentService.save(caseAgent);
|
}
|
}
|
// 新增纠纷任务信息
|
List<CaseTask> caseTaskList = byToGzDTO.getGzCaseTaskDTOList();
|
if (CollectionUtils.isNotEmpty(caseTaskList)) {
|
for (CaseTask caseTask : caseTaskList) {
|
caseTaskService.save(caseTask);
|
}
|
}
|
} catch (Exception e) {
|
log.error("[ByToGzService.byToGzEndCase]调用失败，异常信息：" + e, e);
|
log.error("案件信息：" + byToGzDTO.getGzCaseInfoDTO().toString());
|
errorCaseList.add(byToGzDTO.getGzCaseInfoDTO());
|
}
|
}
|
}
|
}
|
}
|
}catch (Exception e){
|
log.error("[ByToGzService.byToGzEndCase]调用失败，异常信息："+e, e);
|
throw new ServiceException("ByToGzService.byToGzEndCase", e);
|
}
|
}
|
|
/**
|
* 白云区矛盾纠纷多元化解平台数据割接-进行中的纠纷案件信息
|
*/
|
public void byToGzTodoCase(){
|
try{
|
int operSize = 100;
|
// int endCaseCount = 1100;
|
int endCaseCount = syncBydyhClient.countTodoCase();
|
if (endCaseCount > 0) {
|
int allPage = 1;
|
if(operSize < endCaseCount) {
|
allPage = (endCaseCount / operSize) + 1;
|
}
|
for (int operPage=1; operPage<=allPage; operPage++) {
|
List<GZCaseDTO> byToGzDTOList = syncBydyhClient.byToGzTodoCase(operPage, operSize);
|
for (GZCaseDTO byToGzDTO: byToGzDTOList){
|
CaseInfo oldCaseInfo = caseInfoService.getById(byToGzDTO.getGzCaseInfoDTO().getId());
|
if (ObjectUtils.isEmpty(oldCaseInfo)) {
|
try {
|
// 新增案件信息
|
CaseInfo caseInfo = byToGzDTO.getGzCaseInfoDTO();
|
if (StringUtils.isNotEmpty(caseInfo.getCaseClaim())) {
|
if (caseInfo.getCaseClaim().length() > 200) {
|
caseInfo.setCaseClaim("详见申请材料");
|
}
|
}
|
if (StringUtils.isNotEmpty(caseInfo.getCaseDes())) {
|
if (caseInfo.getCaseDes().length() > 200) {
|
caseInfo.setCaseDes("详见申请材料");
|
}
|
}
|
caseInfoService.save(caseInfo);
|
// 新增案件扩展信息
|
CaseInfoUnfold caseInfoUnfold = byToGzDTO.getGzCaseInfoUnfoldDTO();
|
caseInfoUnfoldService.save(caseInfoUnfold);
|
// 新增当事人信息
|
List<CasePerson> casePersonList = byToGzDTO.getGzCasePersonDTOList();
|
if (CollectionUtils.isNotEmpty(casePersonList)) {
|
for (CasePerson casePerson : casePersonList) {
|
casePersonService.save(casePerson);
|
}
|
}
|
// 新增当事人代理人信息
|
List<CaseAgent> caseAgentList = byToGzDTO.getGzCaseAgentDTOList();
|
if (CollectionUtils.isNotEmpty(caseAgentList)) {
|
for (CaseAgent caseAgent : caseAgentList) {
|
caseAgentService.save(caseAgent);
|
}
|
}
|
// 启动流程
|
caseTaskService.deleteByCaseId(caseInfo.getId());
|
if (StringUtils.isNotEmpty(caseInfoUnfold.getMediateUnitId())
|
&& StringUtils.isNotEmpty(caseInfo.getWantUnitId())
|
&& caseInfo.getWantUnitId().equals(caseInfoUnfold.getMediateUnitId())) {
|
CtUserDTO ctUserDTO = custClient.clientGetUserAll(caseInfo.getInputUserId());
|
byToGzCaseTaskService.webStartFlowZXSL(caseInfo, ctUserDTO);
|
} else {
|
DispCaseBaseDTO dispCaseBaseDTO = new DispCaseBaseDTO();
|
BeanUtils.copyProperties(caseInfo, dispCaseBaseDTO);
|
dispCaseBaseDTO.setWantUserId(null);
|
dispCaseBaseDTO.setWantUserName(null);
|
if (StringUtils.isNotEmpty(caseInfoUnfold.getMediateUnitId())) {
|
dispCaseBaseDTO.setWantUnitId(caseInfoUnfold.getMediateUnitId());
|
dispCaseBaseDTO.setWantUnitName(caseInfoUnfold.getMediateUnitName());
|
String dslCaseTaskId = byToGzCaseTaskService.webStartFlowLFDJ(caseInfo, dispCaseBaseDTO);
|
|
List<ByCaseTaskDTO> byCaseTaskDTOList = byToGzDTO.getByCaseTaskDTOList();
|
if (CollectionUtils.isNotEmpty(byCaseTaskDTOList)) {
|
for (ByCaseTaskDTO byCaseTaskDTO : byCaseTaskDTOList) {
|
if ("F22_00019-2".equals(byCaseTaskDTO.getTaskNode())) {
|
AcceptTaskDTO acceptTaskDTO = new AcceptTaskDTO();
|
acceptTaskDTO.setCaseTaskId(dslCaseTaskId);
|
try {
|
byToGzCaseTaskService.webAccept(acceptTaskDTO, byCaseTaskDTO.getHandlerUserId(), byCaseTaskDTO.getCreateTime());
|
} catch (Exception e) {
|
log.error(e.getMessage(), e);
|
}
|
}
|
}
|
}
|
} else {
|
byToGzCaseTaskService.webStartFlowLFDJ(caseInfo, dispCaseBaseDTO);
|
}
|
}
|
} catch (Exception e) {
|
log.error("[ByToGzService.byToGzEndCase]调用失败，异常信息：" + e, e);
|
}
|
}
|
}
|
}
|
}
|
}catch (Exception e){
|
log.error("[ByToGzService.byToGzEndCase]调用失败，异常信息："+e, e);
|
throw new ServiceException("ByToGzService.byToGzEndCase", e);
|
}
|
}
|
|
/**
|
* 白云区矛盾纠纷多元化解平台数据割接-更新纠纷类型
|
*/
|
public void upThirdCause(){
|
try{
|
QueryWrapper<CaseInfo> caseInfoQueryWrapper = new QueryWrapper<>();
|
caseInfoQueryWrapper.select("id", "case_type").isNull("case_type_first");
|
List<CaseInfo> caseInfoList = caseInfoService.list(caseInfoQueryWrapper);
|
QueryWrapper<ThirdCause> thirdCauseQueryWrapper = new QueryWrapper<>();
|
for (CaseInfo caseInfo: caseInfoList){
|
thirdCauseQueryWrapper.clear();
|
thirdCauseQueryWrapper.eq("third_code", caseInfo.getCaseType());
|
ThirdCause thirdCause = thirdCauseService.getOne(thirdCauseQueryWrapper);
|
if (ObjectUtils.isNotEmpty(thirdCause)){
|
SyCause syCause = syCauseService.getById(thirdCause.getCauseCode());
|
if (ObjectUtils.isNotEmpty(syCause)){
|
// 查询父级
|
SyCause syCausePanrent = syCauseService.getById(syCause.getParentId());
|
if (ObjectUtils.isNotEmpty(syCausePanrent)){
|
try{
|
CaseInfo caseInfoPO = new CaseInfo();
|
caseInfoPO.setId(caseInfo.getId());
|
caseInfoPO.setCaseType(syCause.getId());
|
caseInfoPO.setCaseTypeName(syCause.getName());
|
caseInfoPO.setCaseTypeFirst(syCausePanrent.getId());
|
caseInfoPO.setCaseTypeFirstName(syCausePanrent.getName());
|
caseInfoService.updateCaseInfo(caseInfoPO);
|
}catch (Exception e){
|
log.error("[ByToGzService.upThirdCause]调用失败，异常信息："+e, e);
|
}
|
}
|
}
|
}
|
}
|
}catch (Exception e){
|
log.error("[ByToGzService.byToGzEndCase]调用失败，异常信息："+e, e);
|
throw new ServiceException("ByToGzService.byToGzEndCase", e);
|
}
|
|
}
|
|
/**
|
* 白云区矛盾纠纷多元化解平台数据割接-更新问题属地的村级社区
|
*/
|
public void upQueAddr(){
|
try{
|
List<CaseInfoUnfold> caseInfoUnfoldList = caseInfoUnfoldService.list();
|
for (CaseInfoUnfold caseInfoUnfold: caseInfoUnfoldList){
|
if (StringUtils.isNotEmpty(caseInfoUnfold.getMediateUnitId())) {
|
CtUnitDTO ctUnitDTO = custClient.getUnitById(caseInfoUnfold.getMediateUnitId());
|
if (ObjectUtils.isNotEmpty(ctUnitDTO)){
|
if (StringUtils.isNotEmpty(ctUnitDTO.getVillage())) {
|
CaseInfo caseInfo = new CaseInfo();
|
caseInfo.setId(caseInfoUnfold.getId());
|
caseInfo.setQueVillage(ctUnitDTO.getVillage());
|
caseInfo.setQueVillageName(ctUnitDTO.getVillageName());
|
caseInfoService.updateCaseInfo(caseInfo);
|
}
|
}
|
}
|
}
|
}catch (Exception e){
|
log.error("[ByToGzService.upQueAddr]调用失败，异常信息："+e, e);
|
throw new ServiceException("ByToGzService.upQueAddr", e);
|
}
|
|
}
|
|
/**
|
* 白云区矛盾纠纷多元化解平台数据割接-更新纠纷类型
|
*/
|
public void upCauseByOld(){
|
try{
|
QueryWrapper<CaseInfo> caseInfoQueryWrapper = new QueryWrapper<>();
|
caseInfoQueryWrapper.select("id", "old_case_type").isNotNull("old_case_type");
|
List<CaseInfo> caseInfoList = caseInfoService.list(caseInfoQueryWrapper);
|
QueryWrapper<ThirdCause> thirdCauseQueryWrapper = new QueryWrapper<>();
|
for (CaseInfo caseInfo: caseInfoList){
|
thirdCauseQueryWrapper.clear();
|
thirdCauseQueryWrapper.eq("third_code", caseInfo.getOldCaseType());
|
ThirdCause thirdCause = thirdCauseService.getOne(thirdCauseQueryWrapper);
|
if (ObjectUtils.isNotEmpty(thirdCause)){
|
SyCause syCause = syCauseService.getById(thirdCause.getCauseCode());
|
if (ObjectUtils.isNotEmpty(syCause)){
|
// 查询父级
|
SyCause syCausePanrent = syCauseService.getById(syCause.getParentId());
|
if (ObjectUtils.isNotEmpty(syCausePanrent)){
|
try{
|
CaseInfo caseInfoPO = new CaseInfo();
|
caseInfoPO.setId(caseInfo.getId());
|
caseInfoPO.setCaseType(syCause.getId());
|
caseInfoPO.setCaseTypeName(syCause.getName());
|
caseInfoPO.setCaseTypeFirst(syCausePanrent.getId());
|
caseInfoPO.setCaseTypeFirstName(syCausePanrent.getName());
|
caseInfoService.updateCaseInfo(caseInfoPO);
|
}catch (Exception e){
|
log.error("[ByToGzService.upThirdCause]调用失败，异常信息："+e, e);
|
}
|
}
|
}
|
}
|
}
|
}catch (Exception e){
|
log.error("[ByToGzService.byToGzEndCase]调用失败，异常信息："+e, e);
|
throw new ServiceException("ByToGzService.byToGzEndCase", e);
|
}
|
|
}
|
|
|
/**
|
* 白云区矛盾纠纷多元化解平台数据割接-进行中的纠纷案件信息
|
*/
|
public void byToGzJudic(){
|
try{
|
int operSize = 100;
|
int judicCount = syncBydyhClient.countJudic();
|
if (judicCount > 0) {
|
int allPage = 1;
|
if(operSize < judicCount) {
|
allPage = (judicCount / operSize) + 1;
|
}
|
for (int operPage=1; operPage<=allPage; operPage++) {
|
List<GZJudicDTO> byToGzDTOList = syncBydyhClient.byToGzJudic(operPage, operSize);
|
log.info("byToGzJudic byToGzDTOList {}", JSON.toJSONString(byToGzDTOList));
|
for (GZJudicDTO byToGzDTO: byToGzDTOList){
|
JudicInfo judicInfo = judicInfoService.getById(byToGzDTO.getGzJudicInfoDTO().getId());
|
if (ObjectUtils.isEmpty(judicInfo)) {
|
judicInfo = new JudicInfo();
|
BeanUtils.copyProperties(byToGzDTO.getGzJudicInfoDTO(), judicInfo);
|
log.info("byToGzJudic judicInfo insert {}", JSON.toJSONString(judicInfo));
|
judicInfoService.save(judicInfo);
|
}
|
List<GZJudicAssistDTO> gzJudicAssistDTOList = byToGzDTO.getGzJudicAssistDTOList();
|
if(ObjectUtils.isNotEmpty(gzJudicAssistDTOList)){
|
for (GZJudicAssistDTO gzJudicAssistDTO: gzJudicAssistDTOList){
|
JudicAssist judicAssist = judicAssistService.getById(gzJudicAssistDTO.getId());
|
if(ObjectUtils.isEmpty(judicAssist)){
|
judicAssist = new JudicAssist();
|
BeanUtils.copyProperties(gzJudicAssistDTO, judicAssist);
|
log.info("byToGzJudic judicAssist insert {}", JSON.toJSONString(judicAssist));
|
judicAssistService.save(judicAssist);
|
}
|
}
|
}
|
}
|
}
|
}
|
}catch (Exception e){
|
log.error("[ByToGzService.byToGzJudic]调用失败，异常信息："+e, e);
|
throw new ServiceException("ByToGzService.byToGzJudic", e);
|
}
|
}
|
|
}
|
