Merge remote-tracking branch 'origin/gzdyh_grid' into gzdyh_grid

wangwh

2024-10-25 e0b8a22df9a40e1b5691140e23721d2c0a5a5a0b

 dyh-service/dyh-mediate/src/main/java/cn/huge/module/cases/service/CaseInfoService.java

@@ -2,18 +2,19 @@

import cn.huge.base.common.exception.ServiceException;
import cn.huge.base.common.utils.*;
import cn.huge.module.cases.domain.bo.CaseAgentBO;
import cn.huge.module.cases.domain.bo.CasePersonBO;
import cn.huge.module.cases.domain.bo.CasePersonCountBO;
import cn.huge.module.cases.domain.dto.*;

import cn.huge.module.cases.domain.dto.CaseAreaDTO;
import cn.huge.module.cases.domain.po.CaseAgent;
import cn.huge.module.cases.domain.po.CaseInfoUnfold;
import cn.huge.module.cases.domain.po.CasePerson;
import cn.huge.module.cases.domain.po.*;
import cn.huge.module.client.api.impl.CustClientImpl;
import cn.huge.module.client.api.impl.SysClientImpl;
import cn.huge.module.client.api.impl.UtilsClientImpl;
import cn.huge.module.cases.dao.mapper.CaseInfoMapper;
import cn.huge.module.cases.domain.po.CaseInfo;
import cn.huge.module.constant.BaseConsts;
import cn.huge.module.cust.dto.CtUnitDTO;
import cn.huge.module.cust.dto.PaUserDTO;
import cn.huge.module.mediate.constant.*;
import cn.huge.module.cust.dto.CtUserDTO;
@@ -22,6 +23,7 @@
import cn.huge.module.mediate.dto.WechatBindCaseDTO;
import cn.huge.module.sys.dto.FileIdTypeInfoBaseDTO;
import cn.huge.module.sys.dto.QueAddrBaseDTO;
import cn.huge.module.sys.dto.QueAreaDTO;
import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
@@ -40,6 +42,7 @@

import java.io.File;
import java.io.IOException;
import java.net.URL;
import java.nio.file.Files;
import java.util.*;
import java.util.stream.Collectors;
@@ -233,6 +236,14 @@
            //复制填装案件表
            CaseInfo caseInfo = new CaseInfo();
            BeanUtils.copyProperties(registerSaveDTO, caseInfo);
            // 是否自行受理
            if (1 == registerSaveDTO.getIsSelfAccept()) {
                // 是
                caseInfo.setZxslStatus(CaseBaseConsts.ZXSL_STATUS_1);
            }else {
                // 否
                caseInfo.setZxslStatus(CaseBaseConsts.ZXSL_STATUS_0);
            }
            caseInfo.setUpdateTime(nowDate);

            // 常规登记-保存当事人
@@ -242,10 +253,15 @@
            caseInfo.setDefendants(defendants.toString());
            caseInfo.setDagents(dagents.toString());
            caseInfo.setCaseRef(utilsClient.createCaseRef());
            caseInfo.setCanal(CaseBaseConstsEnum.CASE_CANAL_1.getIndex());
            caseInfo.setCanalName(CaseBaseConstsEnum.CASE_CANAL_1.getDes());
            caseInfo.setVisitWay(CaseBaseConstsEnum.VISIT_WAY_1.getIndex());
            caseInfo.setVisitWayName(CaseBaseConstsEnum.VISIT_WAY_1.getDes());
            caseInfo.setVisitWay(CaseBaseConstsEnum.getVisitWayByCanal(caseInfo.getCanal()).getIndex());
            caseInfo.setVisitWayName(CaseBaseConstsEnum.getVisitWayByCanal(caseInfo.getCanal()).getDes());
            //默认小程序可见
            if(ObjectUtils.isNotEmpty(caseInfo.getCanal())){
                if(CaseBaseConstsEnum.CASE_CANAL_1.getIndex().equals(caseInfo.getCanal())){
                    caseInfo.setPartyShow(1);
                }
            }
            
            //todo case_title生成、经纬度转换
            if (0 == registerSaveDTO.getOperateType()) {
                caseInfo.setInputUnitId(loginUser.getUnitId());
@@ -258,7 +274,7 @@
                //默认添加省市
                caseInfo.setQueProv("19");
                caseInfo.setQueProvName("广东省");
                caseInfo.setQueCity("1601");
                caseInfo.setQueCity("440100");
                caseInfo.setQueCityName("广州市");
                // 删除草稿案件
                if (1 == registerSaveDTO.getIsDraft()) {
@@ -600,6 +616,13 @@
        caseInfo.setInputUserId(loginUser.getId());
        caseInfo.setInputUserName(loginUser.getTrueName());
        caseInfo.setInputWay(CaseBaseConsts.INPUT_WAY_1);
        caseInfo.setPartyShow(1);
        if(ObjectUtils.isEmpty(registerSaveDTO.getPeopleNum())){
            caseInfo.setPeopleNum(0);
        }
        if(ObjectUtils.isEmpty(registerSaveDTO.getAmount())){
            caseInfo.setAmount(0.0);
        }
        //默认添加省市
        caseInfo.setQueProv("19");
        caseInfo.setQueProvName("广东省");
@@ -675,6 +698,9 @@
        // 临时加上一级纠纷类型
        caseInfo.setCaseTypeFirst("24_01-2");
        caseInfo.setCaseTypeFirstName("劳动社保");
        //小程序是否查看
        caseInfo.setPartyShow(1);

        this.saveOrUpdate(caseInfo);

        caseInfoUnfoldService.saveOrUpdate(caseInfoUnfold);
@@ -729,9 +755,12 @@
        int peopleNum = 0;
        // 保存申请人
        List<CasePerson> personList = registerSaveDTO.getPersonList();
        Map<String,String> personIdMap = new HashMap<>();
        if (CollectionUtils.isNotEmpty(personList)) {
            for (CasePerson casePerson : personList) {
                casePerson.setId(utilsClient.getNewTimeCaseId());
                String newTimeCaseId = utilsClient.getNewTimeCaseId();
                personIdMap.put(casePerson.getAgentCode(), newTimeCaseId);
                casePerson.setId(newTimeCaseId);
                casePerson.setCaseId(registerSaveDTO.getId());
                casePerson.setPartyUserId(loginUser.getId());
                casePerson.setCustId(registerSaveDTO.getCustId());
@@ -762,6 +791,7 @@
            if (CollectionUtils.isNotEmpty(agentList)) {
                for (CaseAgent caseAgent : agentList) {
                    caseAgent.setId(utilsClient.getNewTimeCaseId());
                    caseAgent.setPersonId(personIdMap.get(caseAgent.getAgentCode()));
                    caseAgent.setPartyUserId(loginUser.getId());
                    caseAgent.setCaseId(registerSaveDTO.getId());
                    caseAgent.setAgentTypeName(CaseBaseConstsEnum.getDes(caseAgent.getAgentType()));
@@ -797,11 +827,22 @@
        QueryWrapper<CasePerson> casePersonQueryWrapper = new QueryWrapper<>();
        casePersonQueryWrapper.eq("case_id", registerSaveDTO.getId());
        List<CasePerson> personList = personService.list(casePersonQueryWrapper);
        Map<String,String> personNameMap = new HashMap<>();
        if(ObjectUtils.isNotEmpty(personList)){
            for (CasePerson casePerson : personList) {
                personNameMap.put(casePerson.getId(),casePerson.getTrueName());
            }
        }
        registerSaveDTO.setPersonList(personList);

        QueryWrapper<CaseAgent> caseAgentQueryWrapper = new QueryWrapper<>();
        caseAgentQueryWrapper.eq("case_id", registerSaveDTO.getId());
        List<CaseAgent> agentList = agentService.list(caseAgentQueryWrapper);
        if(ObjectUtils.isNotEmpty(agentList)){
            for (CaseAgent caseAgent : agentList) {
                caseAgent.setAgentPersonName(personNameMap.get(caseAgent.getPersonId()));
            }
        }
        registerSaveDTO.setAgentList(agentList);

        return registerSaveDTO;
@@ -838,6 +879,7 @@
        }
        List<String> ids = casePersonList.stream().map(CasePerson::getCaseId).collect(Collectors.toList());
        terms.put("ids", ids);
        terms.put("partyShow",1);
        long total = mapper.countTerms(terms);
        List<CaseInfo> content = mapper.pageTerms(page, terms);
        if (ObjectUtils.isNotEmpty(content)) {
@@ -906,20 +948,43 @@
        List<CasePageDTO> content = mapper.pageTermsAll(page, terms);
        if (ObjectUtils.isNotEmpty(content)) {
            for (CasePageDTO casePageDTO : content) {
                QueryWrapper<CasePerson> personWrapper1 = new QueryWrapper<>();
                personWrapper1.eq("case_id", casePageDTO.getId());
                List<CasePerson> casePersonList1 = personService.list(personWrapper1);
                if(ObjectUtils.isNotEmpty(casePageDTO.getQueRoadName())){
                    casePageDTO.setAreaName(casePageDTO.getQueRoadName());
                }else if(ObjectUtils.isNotEmpty(casePageDTO.getAreaName())){
                    casePageDTO.setAreaName(casePageDTO.getAreaName());
                }else if(ObjectUtils.isNotEmpty(casePageDTO.getQueCityName())){
                    casePageDTO.setAreaName(casePageDTO.getQueCityName());
                }
                if(ObjectUtils.isNotEmpty(casePageDTO.getCaseLevel())){
                    switch (casePageDTO.getCaseLevel()){
                        case "1":
                            casePageDTO.setCaseLevel("一级");
                            break;
                        case "2":
                            casePageDTO.setCaseLevel("二级");
                            break;
                        case "3":
                            casePageDTO.setCaseLevel("三级");
                            break;
                    }
                }
                //申请人集合
                List<CasePersonWeDTO> plaintiffList = new ArrayList<>();
                //被申请人集合
                List<CasePersonWeDTO> defendantList = new ArrayList<>();
                for (CasePerson casePerson : casePersonList1) {
                    CasePersonWeDTO casePersonWechatDTO = new CasePersonWeDTO();
                    BeanUtils.copyProperties(casePerson, casePersonWechatDTO);
                    if (CaseBaseConstsEnum.PERSON_TYPE_1.getIndex().equals(casePerson.getPerType())) {
                        plaintiffList.add(casePersonWechatDTO);
                    } else if (CaseBaseConstsEnum.PERSON_TYPE_2.getIndex().equals(casePerson.getPerType())) {
                        defendantList.add(casePersonWechatDTO);
                //如果是导出调用，不查询extend信息
                if(ObjectUtils.isEmpty(terms.get("report"))){
                    QueryWrapper<CasePerson> personWrapper1 = new QueryWrapper<>();
                    personWrapper1.eq("case_id", casePageDTO.getId());
                    List<CasePerson> casePersonList1 = personService.list(personWrapper1);
                    for (CasePerson casePerson : casePersonList1) {
                        CasePersonWeDTO casePersonWechatDTO = new CasePersonWeDTO();
                        BeanUtils.copyProperties(casePerson, casePersonWechatDTO);
                        if (CaseBaseConstsEnum.PERSON_TYPE_1.getIndex().equals(casePerson.getPerType())) {
                            plaintiffList.add(casePersonWechatDTO);
                        } else if (CaseBaseConstsEnum.PERSON_TYPE_2.getIndex().equals(casePerson.getPerType())) {
                            defendantList.add(casePersonWechatDTO);
                        }
                    }
                }
                casePageDTO.setDefendantList(defendantList);
@@ -929,39 +994,99 @@
        return new PageImpl<CasePageDTO>(content, page, total);
    }

    public CaseStatisticsBaseDTO statistics(Map<String, Object> terms) throws IOException {
    /**
     * 纠纷态势
     * 筛选范围：如果已经有承办部门，就按承办部门的区域筛选。如果没有承办部门按问题归属区域筛选
     * */
    public CaseStatisticsBaseDTO statistics(Map<String, Object> terms,String userId) throws IOException {
        Object canal = null;
        if(ObjectUtils.isNotEmpty(terms.get("canal"))){
            canal = terms.get("canal");
        }
        terms.put("statistics", "1");
        //根据用户筛选区域范围
        CtUnitDTO ctUnitDTO = custClient.getUnitByUserId(userId);
        String areaCode = null;
        //目前没有村居数据，所以单位等级是4的也归集到3里面
        if(ctUnitDTO.getUnitGrade().equals(1)){
            terms.put("queCity", ctUnitDTO.getCity());
        }else if(ctUnitDTO.getUnitGrade().equals(2)){
            terms.put("queArea", ctUnitDTO.getArea());
        }else if(ctUnitDTO.getUnitGrade().equals(3) || ctUnitDTO.getUnitGrade().equals(4)){
            terms.put("queRoad", ctUnitDTO.getRoad());
        }

        //目前没有村居，所以区和街道进来都是按街道展示
        String areaType = null;//兼容白云数据
        List<Integer> unitGrades = new ArrayList<>();
        if(ObjectUtils.isNotEmpty(terms.get("queRoad"))){
            terms.put("areaType","2");
            areaType = "2";
            areaCode = terms.get("queRoad")+"";
            unitGrades.add(3);
            unitGrades.add(4);
        }else if(ObjectUtils.isNotEmpty(terms.get("queArea"))){
            terms.put("areaType","2");
            areaType = "2";
            areaCode = terms.get("queArea")+"";
            unitGrades.add(2);
        }else{
            areaType = "1";
            unitGrades.add(1);
            areaCode = ctUnitDTO.getCity();
        }
        //基础数据统计
        CaseStatisticsBaseDTO caseStatisticsBaseDTO = mapper.statisticsBase(terms);
        Integer baseTotalNum = dellNull(caseStatisticsBaseDTO.getResolveNum()) + dellNull(caseStatisticsBaseDTO.getUnResolveNum())+ dellNull(caseStatisticsBaseDTO.getResolveingNum());
        caseStatisticsBaseDTO.setResolveRate(BigDecimalUtil.integerDivideDelZero(caseStatisticsBaseDTO.getResolveNum()*100, baseTotalNum,1));
        caseStatisticsBaseDTO.setUnResolveRate(BigDecimalUtil.integerDivideDelZero(caseStatisticsBaseDTO.getUnResolveNum()*100, baseTotalNum,1));
        caseStatisticsBaseDTO.setResolveingRate(BigDecimalUtil.integerDivideDelZero(caseStatisticsBaseDTO.getResolveingNum()*100, baseTotalNum,1));
        Integer baseTotalNum = dellNull(caseStatisticsBaseDTO.getResolveNum()) + dellNull(caseStatisticsBaseDTO.getUnResolveNum()) + dellNull(caseStatisticsBaseDTO.getResolveingNum());
        Integer resolveTotalNum = dellNull(caseStatisticsBaseDTO.getResolveNum()) + dellNull(caseStatisticsBaseDTO.getUnResolveNum());
        caseStatisticsBaseDTO.setResolveRate(BigDecimalUtil.integerDivideDelZero(caseStatisticsBaseDTO.getResolveNum() * 100, resolveTotalNum, 1));
        caseStatisticsBaseDTO.setUnResolveRate(BigDecimalUtil.integerDivideDelZero(caseStatisticsBaseDTO.getUnResolveNum() * 100, resolveTotalNum, 1));
        caseStatisticsBaseDTO.setResolveingRate(BigDecimalUtil.integerDivideDelZero(caseStatisticsBaseDTO.getResolveingNum() * 100, baseTotalNum, 1));
        Integer levelTotalNum = caseStatisticsBaseDTO.getOneLevelNum() + caseStatisticsBaseDTO.getTwoLevelNum() + caseStatisticsBaseDTO.getThreeLevelNum();
        caseStatisticsBaseDTO.setOneLevelRate(BigDecimalUtil.integerDivideDelZero(caseStatisticsBaseDTO.getOneLevelNum()*100, levelTotalNum,1));
        caseStatisticsBaseDTO.setTwoLevelRate(BigDecimalUtil.integerDivideDelZero(caseStatisticsBaseDTO.getTwoLevelNum()*100, levelTotalNum,1));
        caseStatisticsBaseDTO.setThreeLevelRate(BigDecimalUtil.integerDivideDelZero(caseStatisticsBaseDTO.getThreeLevelNum()*100, levelTotalNum,1));
        caseStatisticsBaseDTO.setOneLevelRate(BigDecimalUtil.integerDivideDelZero(caseStatisticsBaseDTO.getOneLevelNum() * 100, levelTotalNum, 1));
        caseStatisticsBaseDTO.setTwoLevelRate(BigDecimalUtil.integerDivideDelZero(caseStatisticsBaseDTO.getTwoLevelNum() * 100, levelTotalNum, 1));
        caseStatisticsBaseDTO.setThreeLevelRate(BigDecimalUtil.integerDivideDelZero(caseStatisticsBaseDTO.getThreeLevelNum() * 100, levelTotalNum, 1));
        //区域数据统计
        terms.put("isArea","1");
        List<CaseStatisticsAreaDTO> caseStatisticsAreaDTOS = mapper.statisticsArea(terms);
        if(ObjectUtils.isEmpty(caseStatisticsAreaDTOS)){
        if (ObjectUtils.isEmpty(caseStatisticsAreaDTOS)) {
            caseStatisticsAreaDTOS = new ArrayList<>();
        }
        CaseStatisticsAreaDTO allArea = new CaseStatisticsAreaDTO();
        allArea.setAreaName("本级");
        allArea.setAreaCode("1");
        List<String> areaCodeList = new ArrayList<>();
        List<CaseStatisticsAreaDTO> areaList = new ArrayList<>();
        List<String> areaNames = new ArrayList<>();//为兼容白云区数据
        for (CaseStatisticsAreaDTO caseStatisticsAreaDTO : caseStatisticsAreaDTOS) {
            allArea.setCaseNum(dellNull(caseStatisticsAreaDTO.getCaseNum()) + dellNull(allArea.getCaseNum()));
            allArea.setResolveNum(dellNull(caseStatisticsAreaDTO.getResolveNum()) + dellNull(allArea.getResolveNum()));
            allArea.setUnResolveNum(dellNull(caseStatisticsAreaDTO.getUnResolveNum()) + dellNull(allArea.getUnResolveNum()));
            allArea.setResolveingNum(dellNull(caseStatisticsAreaDTO.getResolveingNum()) + dellNull(allArea.getResolveingNum()));
            areaCodeList.add(caseStatisticsAreaDTO.getAreaCode());
            areaNames.add(caseStatisticsAreaDTO.getAreaName());
            //本及：承办单位是本及和没有承办单位并且没有下级区域编码
            if(ObjectUtils.isEmpty(caseStatisticsAreaDTO.getAreaCode()) || unitGrades.contains(caseStatisticsAreaDTO.getUnitGrade())){
                allArea.setCaseNum(dellNull(caseStatisticsAreaDTO.getCaseNum()) + dellNull(allArea.getCaseNum()));
                allArea.setResolveNum(dellNull(caseStatisticsAreaDTO.getResolveNum()) + dellNull(allArea.getResolveNum()));
                allArea.setUnResolveNum(dellNull(caseStatisticsAreaDTO.getUnResolveNum()) + dellNull(allArea.getUnResolveNum()));
                allArea.setResolveingNum(dellNull(caseStatisticsAreaDTO.getResolveingNum()) + dellNull(allArea.getResolveingNum()));
            }else{
                areaList.add(caseStatisticsAreaDTO);
                areaCodeList.add(caseStatisticsAreaDTO.getAreaCode());
            }
        }
        caseStatisticsAreaDTOS.add(allArea);
        List<CaseAreaDTO> queArea = listAreaByType(terms.get("areaType"), terms.get("queArea"));
        log.info("listAreaByType {}",JSON.toJSONString(queArea));
        for (CaseAreaDTO caseAreaDTO : queArea) {
            if(!areaCodeList.contains(caseAreaDTO.getAreaCode())){
        areaList.add(allArea);
        if("1".equals(areaType)){
            Map<String, String> area = getArea();
            for (String areaName : area.keySet()) {
                if(!areaNames.contains(areaName)){
                    CaseStatisticsAreaDTO areaChild = new CaseStatisticsAreaDTO();
                    areaChild.setAreaCode(area.get(areaName));
                    areaChild.setAreaName(areaName);
                    areaList.add(areaChild);
                }
            }
        }

        List<QueAreaDTO> queArea = listAreaByType(areaCode);
        log.info("listAreaByType {}", JSON.toJSONString(queArea));
        for (QueAreaDTO caseAreaDTO : queArea) {
            if (!areaCodeList.contains(caseAreaDTO.getAreaCode())) {
                CaseStatisticsAreaDTO areaChild = new CaseStatisticsAreaDTO();
                areaChild.setAreaCode(caseAreaDTO.getAreaCode());
                areaChild.setAreaName(caseAreaDTO.getAreaName());
@@ -969,18 +1094,17 @@
                areaChild.setResolveNum(0);
                areaChild.setUnResolveNum(0);
                areaChild.setResolveingNum(0);
                caseStatisticsAreaDTOS.add(areaChild);
                areaList.add(areaChild);
            }
        }

        if(ObjectUtils.isNotEmpty(caseStatisticsAreaDTOS)){
            sortArea(caseStatisticsAreaDTOS);
        if (ObjectUtils.isNotEmpty(areaList)) {
            sortArea(areaList);
        }
        caseStatisticsBaseDTO.setAreaList(caseStatisticsAreaDTOS);
        terms.remove("isArea");
        caseStatisticsBaseDTO.setAreaList(areaList);
        //纠纷类型统计
        List<CaseStatisticsTypeDTO> caseStatisticsTypeDTOS = mapper.statisticsType(terms);
        if(ObjectUtils.isNotEmpty(caseStatisticsTypeDTOS)){
        List<CaseStatisticsTypeDTO> caseStatisticsTypeDTOS = mapper.statisticsTypeFirst(terms);
        if (ObjectUtils.isNotEmpty(caseStatisticsTypeDTOS)) {
            sortType(caseStatisticsTypeDTOS);
        }
        Integer typeTotalNum = 0;
@@ -989,130 +1113,299 @@
        List<CaseStatisticsTypeDTO> typeList = new ArrayList<>();
        for (CaseStatisticsTypeDTO caseStatisticsTypeDTO : caseStatisticsTypeDTOS) {
            typeTotalNum = typeTotalNum + dellNull(caseStatisticsTypeDTO.getCaseNum());
            if(i > 5){
            if (i > 5) {
                otherCaseNum = otherCaseNum + dellNull(caseStatisticsTypeDTO.getCaseNum());
            }else{
            } else {
                typeList.add(caseStatisticsTypeDTO);
            }
            i++;
        }
        for (CaseStatisticsTypeDTO caseStatisticsTypeDTO : typeList) {
            caseStatisticsTypeDTO.setCaseRate(BigDecimalUtil.integerDivideDelZero(caseStatisticsTypeDTO.getCaseNum()*100, typeTotalNum,1));
            caseStatisticsTypeDTO.setCaseRate(BigDecimalUtil.integerDivideDelZero(caseStatisticsTypeDTO.getCaseNum() * 100, typeTotalNum, 1));
        }
        CaseStatisticsTypeDTO caseStatisticsTypeDTO = new CaseStatisticsTypeDTO();
        caseStatisticsTypeDTO.setCaseTypeName("其他");
        caseStatisticsTypeDTO.setCaseNum(otherCaseNum);
        caseStatisticsTypeDTO.setCaseRate(BigDecimalUtil.integerDivideDelZero(caseStatisticsTypeDTO.getCaseNum()*100, typeTotalNum,1));
        caseStatisticsTypeDTO.setCaseRate(BigDecimalUtil.integerDivideDelZero(caseStatisticsTypeDTO.getCaseNum() * 100, typeTotalNum, 1));
        typeList.add(caseStatisticsTypeDTO);
        caseStatisticsBaseDTO.setTypeList(typeList);
        //事项来源
        terms.put("canal",CaseBaseConstsEnum.CASE_CANAL_1.getIndex());
        terms.put("canal", CaseBaseConstsEnum.CASE_CANAL_1.getIndex());
        CaseStatisticsSourceDTO oneSource = mapper.statisticsSource(terms);
        if(ObjectUtils.isEmpty(oneSource)){
            oneSource = new CaseStatisticsSourceDTO();
        }
        oneSource.setCanalName(CaseBaseConstsEnum.CASE_CANAL_1.getDes());
        terms.put("canal",CaseBaseConstsEnum.CASE_CANAL_2.getIndex());
        terms.put("canal", CaseBaseConstsEnum.CASE_CANAL_2.getIndex());
        CaseStatisticsSourceDTO twoSource = mapper.statisticsSource(terms);
        if(ObjectUtils.isEmpty(twoSource)){
            twoSource = new CaseStatisticsSourceDTO();
        }
        twoSource.setCanalName(CaseBaseConstsEnum.CASE_CANAL_2.getDes());

        Integer sourceTotalNum = dellNull(oneSource.getCaseNum()) + dellNull(oneSource.getCaseNum());
        oneSource.setCaseRate(BigDecimalUtil.integerDivideDelZero(oneSource.getCaseNum()*100, sourceTotalNum,1));
        oneSource.setResolveRate(BigDecimalUtil.integerDivideDelZero(oneSource.getResolveNum()*100, oneSource.getCaseNum(),1));
        twoSource.setCaseRate(BigDecimalUtil.integerDivideDelZero(twoSource.getCaseNum()*100, sourceTotalNum,1));
        twoSource.setResolveRate(BigDecimalUtil.integerDivideDelZero(twoSource.getResolveNum()*100, twoSource.getCaseNum(),1));
        terms.put("canal", CaseBaseConstsEnum.CASE_CANAL_3.getIndex());
        CaseStatisticsSourceDTO threeSource = mapper.statisticsSource(terms);
        if(ObjectUtils.isEmpty(threeSource)){
            threeSource = new CaseStatisticsSourceDTO();
        }

        CaseStatisticsSourceDTO threeSource = new CaseStatisticsSourceDTO();
        threeSource.setCanalName("自行排查");
        threeSource.setResolveRate("0");
        threeSource.setCaseRate("0");
        CaseStatisticsSourceDTO fourSource = new CaseStatisticsSourceDTO();
        fourSource.setCanalName("协同推送");
        fourSource.setResolveRate("0");
        fourSource.setCaseRate("0");
        terms.put("canal", CaseBaseConstsEnum.CASE_CANAL_4.getIndex());
        CaseStatisticsSourceDTO fourSource = mapper.statisticsSource(terms);
        if(ObjectUtils.isEmpty(fourSource)){
            fourSource = new CaseStatisticsSourceDTO();
        }

        Integer sourceTotalNum = dellNull(oneSource.getCaseNum()) + dellNull(twoSource.getCaseNum()) + dellNull(threeSource.getCaseNum()) + dellNull(fourSource.getCaseNum());
        Integer oneTotalNum = dellNull(oneSource.getResolveNum()) + dellNull(oneSource.getUnResolveNum());
        Integer twoTotalNum = dellNull(twoSource.getResolveNum()) + dellNull(twoSource.getUnResolveNum());
        Integer threeTotalNum = dellNull(threeSource.getResolveNum()) + dellNull(threeSource.getUnResolveNum());
        Integer fourTotalNum = dellNull(fourSource.getResolveNum()) + dellNull(fourSource.getUnResolveNum());
        oneSource.setCaseRate(BigDecimalUtil.integerDivideDelZero(oneSource.getCaseNum() * 100, sourceTotalNum, 1));
        oneSource.setResolveRate(BigDecimalUtil.integerDivideDelZero(oneSource.getResolveNum() * 100, oneTotalNum, 1));

        twoSource.setCaseRate(BigDecimalUtil.integerDivideDelZero(twoSource.getCaseNum() * 100, sourceTotalNum, 1));
        twoSource.setResolveRate(BigDecimalUtil.integerDivideDelZero(twoSource.getResolveNum() * 100, twoTotalNum, 1));


        threeSource.setCanalName(CaseBaseConstsEnum.CASE_CANAL_3.getDes());
        threeSource.setCaseRate(BigDecimalUtil.integerDivideDelZero(threeSource.getCaseNum() * 100, sourceTotalNum, 1));
        threeSource.setResolveRate(BigDecimalUtil.integerDivideDelZero(threeSource.getResolveNum() * 100, threeTotalNum, 1));

        fourSource.setCanalName(CaseBaseConstsEnum.CASE_CANAL_4.getDes());
        fourSource.setCaseRate(BigDecimalUtil.integerDivideDelZero(fourSource.getCaseNum() * 100, sourceTotalNum, 1));
        fourSource.setResolveRate(BigDecimalUtil.integerDivideDelZero(fourSource.getResolveNum() * 100, fourTotalNum, 1));

        caseStatisticsBaseDTO.setOneSource(oneSource);
        caseStatisticsBaseDTO.setTwoSource(twoSource);
        caseStatisticsBaseDTO.setThreeSource(threeSource);
        caseStatisticsBaseDTO.setFourSource(fourSource);

        //案件集合
        Sort sort = Sort.by(Sort.Direction.DESC, "a.create_time");
        PageRequest pageRequest = PageRequest.of(0, 5, sort);
        Page<CasePageDTO> casePageDTOS = pageQueryAll(pageRequest, terms);
        if(ObjectUtils.isNotEmpty(casePageDTOS.getContent())){
            caseStatisticsBaseDTO.setCaseList(casePageDTOS.getContent());
        if(ObjectUtils.isEmpty(canal)){
            terms.remove("canal");
        }else{
            terms.put("canal", canal);
        }
        Sort sort = Sort.by(Sort.Direction.DESC, "a.create_time");
        PageRequest pageRequest = PageRequest.of(0, 30, sort);
        terms.remove("statistics");
        Page<CasePageDTO> casePageDTOS = pageQueryAll(pageRequest, terms);
        if (ObjectUtils.isNotEmpty(casePageDTOS.getContent())) {
            caseStatisticsBaseDTO.setCaseList(casePageDTOS.getContent());
        } else {
            caseStatisticsBaseDTO.setCaseList(new ArrayList<>());
        }
        return caseStatisticsBaseDTO;
    }

    public List<CaseStatisticsTypeDTO> sortType(List<CaseStatisticsTypeDTO> caseStatisticsTypeDTOS){
        caseStatisticsTypeDTOS.sort((o1, o2)->{
    public List<CaseStatisticsTypeDTO> sortType(List<CaseStatisticsTypeDTO> caseStatisticsTypeDTOS) {
        caseStatisticsTypeDTOS.sort((o1, o2) -> {
            Integer totalScore1 = o1.getCaseNum();
            Integer totalScore2 = o2.getCaseNum();
            if(totalScore1 < totalScore2) {
            if (totalScore1 < totalScore2) {
                return 1;
            }else if (totalScore1.equals(totalScore2)){
            } else if (totalScore1.equals(totalScore2)) {
                return 0;
            }else{
            } else {
                return -1;
            }
        });
        return caseStatisticsTypeDTOS;
    }

    public List<CaseStatisticsAreaDTO> sortArea(List<CaseStatisticsAreaDTO> caseStatisticsAreaDTOS){
        caseStatisticsAreaDTOS.sort((o1, o2)->{
            Integer totalScore1 = Integer.valueOf(o1.getAreaCode());
            Integer totalScore2 = Integer.valueOf(o2.getAreaCode());
            if(totalScore1 > totalScore2) {
    public Map<String, String> getArea(){
        Map<String, String> map = new HashMap<>();
        map.put("越秀区","2");
        map.put("海珠区","3");
        map.put("荔湾区","4");
        map.put("天河区","5");
        map.put("白云区","6");
        map.put("黄埔区","7");
        map.put("花都区","8");
        map.put("番禺区","9");
        map.put("南沙区","10");
        map.put("从化区","11");
        map.put("增城区","12");
        return map;
    }

    public List<CaseStatisticsAreaDTO> sortArea(List<CaseStatisticsAreaDTO> caseStatisticsAreaDTOS) {
        Map<String, String> map = getArea();
        for (CaseStatisticsAreaDTO caseStatisticsAreaDTO : caseStatisticsAreaDTOS) {
            caseStatisticsAreaDTO.setAreaCode(caseStatisticsAreaDTO.getAreaCode().replace("-",""));
            if(map.containsKey(caseStatisticsAreaDTO.getAreaName())){
                caseStatisticsAreaDTO.setAreaCode(map.get(caseStatisticsAreaDTO.getAreaName()));
            }
        }
        caseStatisticsAreaDTOS.sort((o1, o2) -> {
            Long totalScore1 = Long.valueOf(o1.getAreaCode());
            Long totalScore2 = Long.valueOf(o2.getAreaCode());
            if (totalScore1 > totalScore2) {
                return 1;
            }else if (totalScore1.equals(totalScore2)){
            } else if (totalScore1.equals(totalScore2)) {
                return 0;
            }else{
            } else {
                return -1;
            }
        });
        return caseStatisticsAreaDTOS;
    }

    public Integer dellNull(Integer number){
        if(ObjectUtils.isEmpty(number)){
    public Integer dellNull(Integer number) {
        if (ObjectUtils.isEmpty(number)) {
            return 0;
        }
        return number;
    }

    /**
     * 根据json文件获取区域信息
     * */
    public CaseAreaDTO getArea() throws IOException {
        Class<?> clazz = CaseAreaDTO.class;
        String path = clazz.getProtectionDomain().getCodeSource().getLocation().getPath();
        ObjectMapper mapper = new ObjectMapper();
        File file = new File(path+ "cn"+File.separator+"huge"+File.separator+"module"+File.separator+"cases"+File.separator+"domain"+File.separator+"json"+File.separator+"Area.json");
        CaseAreaDTO obj = mapper.readValue(file, CaseAreaDTO.class);
        return obj;
    }


    /**
     * 根据不同的等级获取不同区域子集合
     * @param areaType 1-市级 2-区
     * */
    public List<CaseAreaDTO> listAreaByType(Object areaType,Object areaCode) throws IOException {
        log.info("listAreaByType {},{}",areaType,areaCode);
        CaseAreaDTO area = getArea();
        log.info("listAreaByType area {}",JSON.toJSONString(area));
        if(ObjectUtils.isEmpty(areaType) || areaType.equals("") || areaType.equals("1")){
            return area.getChildren();
     */
    public List<QueAreaDTO> listAreaByType(Object areaCode) {
        log.info("listAreaByType {},{}", areaCode);
        String parentId = "1601";
        if (ObjectUtils.isNotEmpty(areaCode)) {
            parentId = String.valueOf(areaCode);
        }
        if(areaType.equals("2")){
            List<CaseAreaDTO> children = area.getChildren();
            for (CaseAreaDTO child : children) {
                if(child.getAreaCode().equals(areaCode)){
                    return child.getChildren();
        List<QueAreaDTO> queAreaDTOS = sysClient.listByParentId(parentId);
        return queAreaDTOS;
    }

    public Page<CasePageDTO> pagePerson(PageRequest page, Map<String, Object> terms,String certiNo) {
        QueryWrapper<CasePerson> personWrapper = new QueryWrapper<>();
        personWrapper.select("case_id,certi_no");
        personWrapper.eq("certi_no", certiNo);
        List<CasePerson> personList = personService.list(personWrapper);
        List<String> ids = new ArrayList<>();
        if(ObjectUtils.isNotEmpty(personList)){
            for (CasePerson casePerson : personList) {
                ids.add(casePerson.getCaseId());
            }
        }
        QueryWrapper<CaseAgent> agentWrapper = new QueryWrapper<>();
        agentWrapper.select("case_id,certi_no");
        agentWrapper.in("certi_no", certiNo);
        List<CaseAgent> agentList = agentService.list(agentWrapper);
        if(ObjectUtils.isNotEmpty(agentList)){
            for (CaseAgent caseAgent : agentList) {
                ids.add(caseAgent.getCaseId());
            }
        }
        if(ObjectUtils.isEmpty(ids)){
            return new PageImpl<CasePageDTO>(new ArrayList<>(), page, 0);
        }
        terms.put("ids", ids);
        long total = mapper.countTermsAll(terms);
        List<CasePageDTO> content = mapper.pageTermsAll(page, terms);
        if (ObjectUtils.isNotEmpty(content)) {
            for (CasePageDTO casePageDTO : content) {
                if(ObjectUtils.isNotEmpty(casePageDTO.getQueRoadName())){
                    casePageDTO.setAreaName(casePageDTO.getQueRoadName());
                }else if(ObjectUtils.isNotEmpty(casePageDTO.getAreaName())){
                    casePageDTO.setAreaName(casePageDTO.getAreaName());
                }else if(ObjectUtils.isNotEmpty(casePageDTO.getQueCityName())){
                    casePageDTO.setAreaName(casePageDTO.getQueCityName());
                }
                if(ObjectUtils.isNotEmpty(casePageDTO.getCaseLevel())){
                    switch (casePageDTO.getCaseLevel()){
                        case "1":
                            casePageDTO.setCaseLevel("一级");
                            break;
                        case "2":
                            casePageDTO.setCaseLevel("二级");
                            break;
                        case "3":
                            casePageDTO.setCaseLevel("三级");
                            break;
                    }
                }
            }
        }
        return new ArrayList<>();
        return new PageImpl<CasePageDTO>(content, page, total);
    }

    public CasePersonCountBO countPerson(String certiNo){
        CasePersonCountBO casePersonCountBO = new CasePersonCountBO();

        Integer plaintiffNum = 0;//申请方当事人数
        Integer defendantNum = 0;//被申请方当事人数
        Integer pagentsNum = 0;//申请方代理人数
        Integer dagentsNum = 0;//被申请方代理人数

        List<CasePerson> personList = personService.listByCertiNo(certiNo);
        List<String> ids = new ArrayList<>();
        if(ObjectUtils.isNotEmpty(personList)){
            for (CasePerson casePerson : personList) {
                ids.add(casePerson.getCaseId());
                if(CaseBaseConstsEnum.PERSON_TYPE_1.getIndex().equals(casePerson.getPerType())){
                    plaintiffNum++;
                }
                if(CaseBaseConstsEnum.PERSON_TYPE_2.getIndex().equals(casePerson.getPerType())){
                    defendantNum++;
                }
            }
        }

        List<CaseAgent> agentList = agentService.listByCertiNo(certiNo);
        if(ObjectUtils.isNotEmpty(agentList)){
            for (CaseAgent caseAgent : agentList) {
                ids.add(caseAgent.getCaseId());
                if(CaseBaseConstsEnum.PERSON_TYPE_3.getIndex().equals(caseAgent.getPerType())){
                    pagentsNum++;
                }
                if(CaseBaseConstsEnum.PERSON_TYPE_4.getIndex().equals(caseAgent.getPerType())){
                    dagentsNum++;
                }
            }
        }
        casePersonCountBO.setDagentsNum(dagentsNum);
        casePersonCountBO.setPagentsNum(pagentsNum);
        casePersonCountBO.setDefendantNum(defendantNum);
        casePersonCountBO.setPlaintiffNum(plaintiffNum);
        casePersonCountBO.setTotalNum(ids.size());
        casePersonCountBO.setZzzxNum(ids.size());
        return casePersonCountBO;
    }

    public List<CaseStatisticsTypeDTO> statisticsCaseType(Map<String, Object> terms,String userId){
        //根据用户筛选区域范围
        CtUnitDTO ctUnitDTO = custClient.getUnitByUserId(userId);
        if(ctUnitDTO.getUnitGrade().equals(2)){
            terms.put("queArea", ctUnitDTO.getArea());
        }else if(ctUnitDTO.getUnitGrade().equals(3) || ctUnitDTO.getUnitGrade().equals(4)){
            terms.put("queRoad", ctUnitDTO.getRoad());
        }
        if(ObjectUtils.isEmpty(terms.get("caseTypeFirst"))){
            //筛选一级为其他的纠纷类型
            List<CaseStatisticsTypeDTO> caseStatisticsTypeDTOS = mapper.statisticsTypeFirst(terms);
            if (ObjectUtils.isNotEmpty(caseStatisticsTypeDTOS)) {
                sortType(caseStatisticsTypeDTOS);
            }
            int i = 1;
            List<String> caseTypeList = new ArrayList<>();
            for (CaseStatisticsTypeDTO caseStatisticsTypeDTO : caseStatisticsTypeDTOS) {
                if (i > 5) {
                    caseTypeList.add(caseStatisticsTypeDTO.getCaseType());
                }
                i++;
            }
            if(ObjectUtils.isEmpty(caseTypeList)){
                return new ArrayList<>();
            }
            terms.put("caseTypeFirstList", caseTypeList);
        }
        List<CaseStatisticsTypeDTO> caseStatisticsTypeDTOS = mapper.statisticsType(terms);
        if (ObjectUtils.isNotEmpty(caseStatisticsTypeDTOS)) {
            sortType(caseStatisticsTypeDTOS);
        }
        Integer typeTotalNum = 0;
        for (CaseStatisticsTypeDTO caseStatisticsTypeDTO : caseStatisticsTypeDTOS) {
            typeTotalNum = typeTotalNum + dellNull(caseStatisticsTypeDTO.getCaseNum());
        }
        for (CaseStatisticsTypeDTO caseStatisticsTypeDTO : caseStatisticsTypeDTOS) {
            caseStatisticsTypeDTO.setCaseRate(BigDecimalUtil.integerDivideDelZero(caseStatisticsTypeDTO.getCaseNum() * 100, typeTotalNum, 1));
        }
        return caseStatisticsTypeDTOS;
    }
}