hsq / hsq-credit-manager · Files

package com.lhcredit.project.business.creditGrantingRisk.service;

import cn.hutool.core.util.ObjectUtil;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.lhcredit.common.utils.DateUtils;
import com.lhcredit.common.utils.http.HttpTemplate;
import com.lhcredit.project.business.BasicInformation.service.BasicInformationService;
import com.lhcredit.project.business.TianYC.entity.param.RequestParams;
import com.lhcredit.project.business.TianYC.entity.param.SFParams;
import com.lhcredit.project.business.creditGrantingRisk.domain.CreditGrantingRisk;
import com.lhcredit.project.business.creditGrantingRisk.mapper.CreditGrantingRiskMapper;
import com.lhcredit.project.business.judicial.service.JudicialService;
import com.lhcredit.project.business.judicialCasesData.domain.JudicialCasesData;
import com.lhcredit.project.business.judicialCasesData.service.IJudicialCasesDataService;
import com.lhcredit.project.business.judicialCasesStatistics.domain.JudicialCasesStatistics;
import com.lhcredit.project.business.judicialCasesStatistics.service.IJudicialCasesStatisticsService;
import com.lhcredit.project.business.judicialCasesStatisticsYear.domain.JudicialCasesStatisticsYear;
import com.lhcredit.project.business.judicialCasesStatisticsYear.service.IJudicialCasesStatisticsYearService;
import com.lhcredit.project.business.reportMake.ReportMakeService;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;

import java.lang.reflect.Field;
import java.math.BigDecimal;
import java.util.*;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.stream.Collectors;

/**
 * 授信风险 服务层实现
 *
 * @author lhcredit
 * @date 2024-06-11
 */
@Service
public class CreditGrantingRiskServiceImpl implements ICreditGrantingRiskService {
    @Autowired
    private CreditGrantingRiskMapper creditGrantingRiskMapper;
    @Autowired
    private JudicialService judicialService;
    @Autowired
    private IJudicialCasesDataService judicialCasesDataService;
    @Autowired
    private IJudicialCasesStatisticsYearService judicialCasesStatisticsYearService;
    @Autowired
    private IJudicialCasesStatisticsService judicialCasesStatisticsService;
    @Autowired
    private BasicInformationService basicInformationService;
    @Value("${dataCenters.url}")
    private String apiUrl;
    @Autowired
    private  HttpTemplate httpTemplate;

    public ExecutorService executorService = Executors.newFixedThreadPool(20);
    //    public static  List<JudicialCasesData> changeJudicialCasesData( List<JudicialCasesData> list){
//        if (CollectionUtils.isEmpty(list))return null;
//        Arrays.stream(list.get(0).getClass().getDeclaredFields()).filter(f->f.get)
//    }
    public  JudicialCasesStatistics useDataCount(List<JudicialCasesData> judicialCasesData, Integer type,String name){
        Integer year1=0;
        Integer year3=0;
        Integer year5=0;
        Integer year6=0;
        Calendar c = Calendar.getInstance();
        c.setTime(new Date());
        c.add(Calendar.YEAR,-1);
        Integer oneyear =Integer.valueOf(DateUtils.parseDateToStr( "YYYY",c.getTime()));
        c.add(Calendar.YEAR,-2);
        Integer threeyear =Integer.valueOf(DateUtils.parseDateToStr( "YYYY",c.getTime()));
        c.add(Calendar.YEAR,-2);
        Integer fiveyear = Integer.valueOf(DateUtils.parseDateToStr( "YYYY",c.getTime()));
        if (CollectionUtils.isEmpty(judicialCasesData))judicialCasesData=new ArrayList<>();
        List<String> list = judicialCasesData.stream().filter(f -> null != f.getDLarq()).map(m -> DateUtils.parseDateToStr("YYYY", m.getDLarq())).collect(Collectors.toList());
        for(String s:list){
            Integer splitYear= Integer.valueOf(s);
            if(splitYear>oneyear){
                year1++;
            }else if(splitYear>threeyear){
                year3++;
            }else if(splitYear>fiveyear){
                year5++;
            }else {
                year6++;
            }
        }
        JudicialCasesStatistics judicialCasesStatistics=new JudicialCasesStatistics();
        judicialCasesStatistics.setCaseType(type);
        judicialCasesStatistics.setOneyear(year1);
        judicialCasesStatistics.setOnetothreeyear(year3);
        judicialCasesStatistics.setThreetofiveyear(year5);
        judicialCasesStatistics.setFiveyear(year6);
        judicialCasesStatistics.setCaseTypeStr(name);
        judicialCasesStatistics.setCountTotal(year1+year3+year5+year6);
        List<Field> collect = Arrays.stream(judicialCasesStatistics.getClass().getDeclaredFields()).filter(f -> f.getType().getSimpleName().equals(Integer.class.getSimpleName()))
                .collect(Collectors.toList());
        for (Field field : collect) {
            try {
                field.setAccessible(true);
                Object object = field.get(judicialCasesStatistics);
                if (null==object) field.set(judicialCasesStatistics,0);
            } catch (IllegalAccessException e) {
                throw new RuntimeException(e);
            }
        }
        return  judicialCasesStatistics;
    }
    @Override
    public Map<String, Object> getJudicialCasesData(String name){
        CountDownLatch latch=new CountDownLatch(7);
        Map<String, Object> map=new ConcurrentHashMap<String,Object>();
        Map<String, JudicialCasesStatistics> count=new ConcurrentHashMap<String,JudicialCasesStatistics>();
        Long cgId= -10L;
        executorService.execute(()->{
//            getStatictics(name,1,cgId);
            List<JudicialCasesData> judicialCasesData = getJudicialCasesData(name, 1, cgId,false,count,"民事案件");
            AtomicInteger i=new AtomicInteger(1);
            judicialCasesData=judicialCasesData.stream().map(m->{m.setDataStatus(i.getAndIncrement());m.setDLarqStr(DateUtils.parseDateToStr("yyyy-MM-dd",m.getDLarq()));;m.changeDate(); return m;}).collect(Collectors.toList());
            if (judicialCasesData.size()>20)judicialCasesData=judicialCasesData.subList(0,20);
            map.put("sifa1_list",CollectionUtils.isEmpty(judicialCasesData)?new JSONArray():judicialCasesData);
            latch.countDown();
        });
        executorService.execute(()->{
//            getStatictics(name,2,cgId);
            List<JudicialCasesData> judicialCasesData = getJudicialCasesData(name, 2, cgId,false,count,"刑事案件");
            AtomicInteger i=new AtomicInteger(1);
            judicialCasesData=judicialCasesData.stream().map(m->{m.setDataStatus(i.getAndIncrement());m.setDLarqStr(DateUtils.parseDateToStr("yyyy-MM-dd",m.getDLarq()));;m.changeDate();  return m;}).collect(Collectors.toList());
            if (judicialCasesData.size()>20)judicialCasesData=judicialCasesData.subList(0,20);
            map.put("sifa2_list",CollectionUtils.isEmpty(judicialCasesData)?new JSONArray():judicialCasesData);
            latch.countDown();
        });
        executorService.execute(()->{
//            getStatictics(name,3,cgId);
            List<JudicialCasesData> judicialCasesData = getJudicialCasesData(name, 3, cgId,false,count,"行政案件");
            AtomicInteger i=new AtomicInteger(1);
            judicialCasesData=judicialCasesData.stream().map(m->{m.setDataStatus(i.getAndIncrement());m.setDLarqStr(DateUtils.parseDateToStr("yyyy-MM-dd",m.getDLarq()));;m.changeDate();  return m;}).collect(Collectors.toList());
            if (judicialCasesData.size()>20)judicialCasesData=judicialCasesData.subList(0,20);
            map.put("sifa3_list",CollectionUtils.isEmpty(judicialCasesData)?new JSONArray():judicialCasesData);
            latch.countDown();
        });
        executorService.execute(()->{
//            getStatictics(name,4,cgId);
            List<JudicialCasesData> judicialCasesData = getJudicialCasesData(name, 4, cgId,false,count,"非诉保全案件");
            AtomicInteger i=new AtomicInteger(1);
            judicialCasesData=judicialCasesData.stream().map(m->{m.setDataStatus(i.getAndIncrement());m.setDLarqStr(DateUtils.parseDateToStr("yyyy-MM-dd",m.getDLarq()));;m.changeDate();  return m;}).collect(Collectors.toList());
            if (judicialCasesData.size()>20)judicialCasesData=judicialCasesData.subList(0,20);
            map.put("sifa4_list",CollectionUtils.isEmpty(judicialCasesData)?new JSONArray():judicialCasesData);
            latch.countDown();
        });
        executorService.execute(()->{
//            getStatictics(name,5,cgId);
            List<JudicialCasesData> judicialCasesData = getJudicialCasesData(name, 5, cgId,false,count,"执行案件");
            AtomicInteger i=new AtomicInteger(1);
            judicialCasesData=judicialCasesData.stream().map(m->{m.setDataStatus(i.getAndIncrement());m.setDLarqStr(DateUtils.parseDateToStr("yyyy-MM-dd",m.getDLarq()));;m.changeDate();  return m;}).collect(Collectors.toList());
            if (judicialCasesData.size()>20)judicialCasesData=judicialCasesData.subList(0,20);
            map.put("sifa5_list",CollectionUtils.isEmpty(judicialCasesData)?new JSONArray():judicialCasesData);
            latch.countDown();
        });
        executorService.execute(()->{
//            getStatictics(name,6,cgId);
            List<JudicialCasesData> judicialCasesData = getJudicialCasesData(name, 6, cgId,false,count,"破产案件");
            AtomicInteger i=new AtomicInteger(1);
            judicialCasesData=judicialCasesData.stream().map(m->{m.setDataStatus(i.getAndIncrement());m.setDLarqStr(DateUtils.parseDateToStr("yyyy-MM-dd",m.getDLarq()));; m.changeDate(); return m;}).collect(Collectors.toList());
            if (judicialCasesData.size()>20)judicialCasesData=judicialCasesData.subList(0,20);
            map.put("sifa6_list",CollectionUtils.isEmpty(judicialCasesData)?new JSONArray():judicialCasesData);
            latch.countDown();
        });
        executorService.execute(()->{
            List<JudicialCasesStatistics> judicialCasesStatisticsList = initData(cgId, name,false);
            judicialCasesStatisticsList=CollectionUtils.isEmpty(judicialCasesStatisticsList)?new ArrayList<JudicialCasesStatistics>(){
                {add(JudicialCasesStatistics.builder().caseTypeStr("合计").caseType(0).build());}
                { add(JudicialCasesStatistics.builder().caseTypeStr("民事案件").caseType(1).build());}
                { add(JudicialCasesStatistics.builder().caseTypeStr("行政案件").caseType(3).build());}
                { add(JudicialCasesStatistics.builder().caseTypeStr("执行案件").caseType(5).build());}
                { add(JudicialCasesStatistics.builder().caseTypeStr("刑事案件").caseType(2).build());}
                { add(JudicialCasesStatistics.builder().caseTypeStr("非诉保全案件").caseType(4).build());}
                { add(JudicialCasesStatistics.builder().caseTypeStr("破产案件").caseType(6).build());}
            }:judicialCasesStatisticsList;
            map.put("sifa2_statistics",judicialCasesStatisticsList);
            judicialCasesStatisticsList.forEach(i->{
                List<Field> collect = Arrays.stream(i.getClass().getDeclaredFields()).filter(f -> f.getType().getSimpleName().equals(Integer.class.getSimpleName()))
                        .collect(Collectors.toList());
                for (Field field : collect) {
                    try {
                        field.setAccessible(true);
                        Object object = field.get(i);
                        if (null==object) field.set(i,0);
                    } catch (IllegalAccessException e) {
                        throw new RuntimeException(e);
                    }
                }
                if (i.getCaseType()==0)map.put("sifaCount"+i.getCaseType(),i);

            });
            latch.countDown();
        });

        try {
            latch.await();
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
        //超过20条的数据只保留20
        map.putAll(count);
        return map;
    }

    @Override
    public CreditGrantingRisk insert(Long cgId, String name) {
        CreditGrantingRisk c = creditGrantingRiskMapper.selectCreditGrantingRiskByCgId(cgId);
        if(c!=null){
            List<JudicialCasesStatistics> judicialCasesStatisticsList = judicialCasesStatisticsService.selectJudicialCasesStatisticsList(JudicialCasesStatistics.builder().cgId(cgId).dataStatus(1).build());
            List<JudicialCasesData> judicialCasesData1 = judicialCasesDataService.selectTen(JudicialCasesData.builder().cgId(cgId).dataStatus(1).type("1").build());
            List<JudicialCasesData> judicialCasesData2 = judicialCasesDataService.selectTen(JudicialCasesData.builder().cgId(cgId).dataStatus(1).type("2").build());
            List<JudicialCasesData> judicialCasesData3 = judicialCasesDataService.selectTen(JudicialCasesData.builder().cgId(cgId).dataStatus(1).type("3").build());
            List<JudicialCasesData> judicialCasesData4 = judicialCasesDataService.selectTen(JudicialCasesData.builder().cgId(cgId).dataStatus(1).type("4").build());
            List<JudicialCasesData> judicialCasesData5 = judicialCasesDataService.selectTen(JudicialCasesData.builder().cgId(cgId).dataStatus(1).type("5").build());
            List<JudicialCasesData> judicialCasesData6 = judicialCasesDataService.selectTen(JudicialCasesData.builder().cgId(cgId).dataStatus(1).type("6").build());
            if(judicialCasesData1==null||judicialCasesData1.size()==0){judicialCasesData1=null;}
            if(judicialCasesData2==null||judicialCasesData2.size()==0){judicialCasesData2=null;}
            if(judicialCasesData3==null||judicialCasesData3.size()==0){judicialCasesData3=null;}
            if(judicialCasesData4==null||judicialCasesData4.size()==0){judicialCasesData4=null;}
            if(judicialCasesData5==null||judicialCasesData5.size()==0){judicialCasesData5=null;}
            if(judicialCasesData6==null||judicialCasesData6.size()==0){judicialCasesData6=null;}
            c.setMsajList(judicialCasesData1);
            c.setXsajList(judicialCasesData2);
            c.setXzajList(judicialCasesData3);
            c.setFsbqajList(judicialCasesData4);
            c.setZxajList(judicialCasesData5);
            c.setQzqsypcList(judicialCasesData6);
            c.setNumList(judicialCasesStatisticsList);
            return creditGrantingRiskChangeDate(c);
        }

        CountDownLatch latch = new CountDownLatch(20);

        CreditGrantingRisk creditGrantingRisk = new CreditGrantingRisk();
        creditGrantingRisk.setCgId(cgId);
        RequestParams requestParams = new RequestParams();
        requestParams.setName(name);

        JSONObject basicInformation = basicInformationService.baseinfo3(requestParams);
        if (basicInformation != null && "2000".equals(basicInformation.getString("code"))) {
            String creditNo = basicInformation.getJSONObject("data").getString("creditNo");
            requestParams.setCreditCode(creditNo);
        }
        try{
            //        股权出质
            JSONObject gqResult = judicialService.equityInfo(requestParams);
            if (StringUtils.equals("2000", gqResult.getString("code"))) {
                JSONObject data = gqResult.getJSONObject("data");
                if (ObjectUtil.isNotNull(data)) {
                    creditGrantingRisk.setGqcz(data.getJSONArray("items").toJSONString());
                }
            }
        }catch (Exception e){
            e.printStackTrace();
        }
        executorService.execute(() -> {

            latch.countDown();
        });
        executorService.execute(() -> {
            //        经营异常
            JSONObject abnormal = judicialService.abnormal(requestParams);
            if (StringUtils.equals("2000", abnormal.getString("code"))) {
                JSONObject data = abnormal.getJSONObject("data");
                if (ObjectUtil.isNotNull(data)) {
                    creditGrantingRisk.setJyyc(data.getJSONArray("items").toJSONString());
                }
            }

            latch.countDown();
        });
        executorService.execute(() -> {
            //        行政处罚
            JSONObject punishmentInfo = judicialService.punishmentInfo(requestParams);
            if (StringUtils.equals("2000", punishmentInfo.getString("code"))) {
                JSONObject data = punishmentInfo.getJSONObject("data");
                if (ObjectUtil.isNotNull(data)) {
                    creditGrantingRisk.setXzcf(data.getJSONArray("items").toJSONString());
                }
            }
            latch.countDown();
        });
        executorService.execute(() -> {
            //        海关行政处罚
            JSONObject hgcf = judicialService.ieSanction(requestParams);
            if (StringUtils.equals("2000", hgcf.getString("code"))) {
                JSONArray data = hgcf.getJSONArray("data");
                if (ObjectUtil.isNotNull(data)) {
                    creditGrantingRisk.setHgxzcf(data.toJSONString());
                }
            }
            latch.countDown();
        });

        executorService.execute(() -> {
            //        动产抵押
            JSONObject dyResult = judicialService.mortgageInfo(requestParams);
            if (StringUtils.equals("2000", dyResult.getString("code"))) {
                JSONObject data = dyResult.getJSONObject("data");
                if (ObjectUtil.isNotNull(data)) {
                    creditGrantingRisk.setDcdy(data.getJSONArray("items").toJSONString());
                }
            }
            latch.countDown();
        });

        executorService.execute(() -> {
            //        严重违法
            JSONObject illegalInfo = judicialService.illegalInfo(requestParams);
            if (StringUtils.equals("2000", illegalInfo.getString("code"))) {
                JSONObject data = illegalInfo.getJSONObject("data");
                if (ObjectUtil.isNotNull(data)) {
                    creditGrantingRisk.setYzwf(data.getJSONArray("items").toJSONString());
                }
            }
            latch.countDown();
        });
        executorService.execute(() -> {
            //        欠税公告
            JSONObject ownedTax = judicialService.ownTax(requestParams);
            if (StringUtils.equals("2000", ownedTax.getString("code"))) {
                JSONObject data = ownedTax.getJSONObject("data");
                if (ObjectUtil.isNotNull(data)) {
                    creditGrantingRisk.setQsgg(data.getJSONArray("items").toJSONString());
                }
            }
            latch.countDown();
        });
        executorService.execute(() -> {
            //        清算信息
            JSONObject jsonObject = judicialService.liquidating(requestParams);
            if (StringUtils.equals("2000", jsonObject.getString("code"))) {
                JSONObject data = jsonObject.getJSONObject("data");
                if (ObjectUtil.isNotNull(data)) {
                    creditGrantingRisk.setQsgg(data.getJSONArray("items").toJSONString());
                }
            }
            latch.countDown();
        });
        executorService.execute(() -> {
            //        抽样检查
            JSONObject jsonObject = judicialService.checkInfo(requestParams);
            if (StringUtils.equals("2000", jsonObject.getString("code"))) {
                JSONObject data = jsonObject.getJSONObject("data");
                if (ObjectUtil.isNotNull(data)) {
                    creditGrantingRisk.setCyjc(data.getJSONObject("companyCheck").getJSONArray("items").toJSONString());
                }
            }
            latch.countDown();
        });
        executorService.execute(() -> {
            //        司法协助
            JSONObject judicial = judicialService.judicial(requestParams);
            if (StringUtils.equals("2000", judicial.getString("code"))) {
                JSONObject data = judicial.getJSONObject("data");
                if (ObjectUtil.isNotNull(data)) {
                    creditGrantingRisk.setSfxz(data.getJSONArray("items").toJSONString());
                }
            }
            latch.countDown();
        });
        executorService.execute(() -> {
            //        司法拍卖
            JSONObject judicialSale = judicialService.judicialSale(requestParams);
            if (StringUtils.equals("2000", judicialSale.getString("code"))) {
                JSONObject data = judicialSale.getJSONObject("data");
                if (ObjectUtil.isNotNull(data)) {
                    creditGrantingRisk.setSfpm(data.getJSONArray("items").toJSONString());
                }
            }
            latch.countDown();
        });
//        executorService.execute(() -> {
//            //        民事案件
//            SFParams  sfParams =new SFParams();
//            sfParams.setName(name);
//            sfParams.setPageNum(1);
//            sfParams.setPageSize(10);
//            sfParams.setType("1");
//            JSONObject jsonObject = judicialService.entoutdetail(sfParams);
//            if (StringUtils.equals("2000", jsonObject.getString("code"))) {
//                JSONArray data = jsonObject.getJSONArray("data");
//                if (ObjectUtil.isNotNull(data)) {
//                    creditGrantingRisk.setMsaj(data.toJSONString());
//                }
//            }
//            latch.countDown();
//        });
//        executorService.execute(() -> {
//            //        刑事案件
//            SFParams  sfParams =new SFParams();
//            sfParams.setName(name);
//            sfParams.setPageNum(1);
//            sfParams.setPageSize(10);
//            sfParams.setType("2");
//            JSONObject jsonObject = judicialService.entoutdetail(sfParams);
//            if (StringUtils.equals("2000", jsonObject.getString("code"))) {
//                JSONArray data = jsonObject.getJSONArray("data");
//                if (ObjectUtil.isNotNull(data)) {
//                    creditGrantingRisk.setXsaj(data.toJSONString());
//                }
//            }
//            latch.countDown();
//        });
//        executorService.execute(() -> {
//            //        行政案件
//            SFParams  sfParams =new SFParams();
//            sfParams.setName(name);
//            sfParams.setPageNum(1);
//            sfParams.setPageSize(10);
//            sfParams.setType("3");
//            JSONObject jsonObject = judicialService.entoutdetail(sfParams);
//            if (StringUtils.equals("2000", jsonObject.getString("code"))) {
//                JSONArray data = jsonObject.getJSONArray("data");
//                if (ObjectUtil.isNotNull(data)) {
//                    creditGrantingRisk.setXzaj(data.toJSONString());
//                }
//            }
//            latch.countDown();
//        });
//        executorService.execute(() -> {
//            //        非诉保全
//            SFParams  sfParams =new SFParams();
//            sfParams.setName(name);
//            sfParams.setPageNum(1);
//            sfParams.setPageSize(10);
//            sfParams.setType("4");
//            JSONObject jsonObject = judicialService.entoutdetail(sfParams);
//            if (StringUtils.equals("2000", jsonObject.getString("code"))) {
//                JSONArray data = jsonObject.getJSONArray("data");
//                System.err.println("a"+data);
//                if (ObjectUtil.isNotNull(data)) {
//                    creditGrantingRisk.setFsbqaj(data.toJSONString());
//                }
//            }
//            latch.countDown();
//        });
//        executorService.execute(() -> {
//            //        执行案件
//            SFParams  sfParams =new SFParams();
//            sfParams.setName(name);
//            sfParams.setPageNum(1);
//            sfParams.setPageSize(10);
//            sfParams.setType("5");
//            JSONObject jsonObject = judicialService.entoutdetail(sfParams);
//            if (StringUtils.equals("2000", jsonObject.getString("code"))) {
//                JSONArray data = jsonObject.getJSONArray("data");
//                System.err.println("b"+data);
//                if (ObjectUtil.isNotNull(data)) {
//                    creditGrantingRisk.setZxaj(data.toJSONString());
//                }
//            }
//            latch.countDown();
//        });
//        executorService.execute(() -> {
//            //        强制清算与破产
//            SFParams  sfParams =new SFParams();
//            sfParams.setName(name);
//            sfParams.setPageNum(1);
//            sfParams.setPageSize(10);
//            sfParams.setType("6");
//            JSONObject jsonObject = judicialService.entoutdetail(sfParams);
//            if (StringUtils.equals("2000", jsonObject.getString("code"))) {
//                JSONArray data = jsonObject.getJSONArray("data");
//                if (ObjectUtil.isNotNull(data)) {
//                    creditGrantingRisk.setQzqsypc(data.toJSONString());
//                }
//            }
//            latch.countDown();
//        });
        executorService.execute(()->{
//            getStatictics(name,1,cgId);
            List<JudicialCasesData> judicialCasesData = getJudicialCasesData(name, 1, cgId,true,null,null);
            creditGrantingRisk.setMsajList(judicialCasesData);
            latch.countDown();
        });
        executorService.execute(()->{
//            getStatictics(name,2,cgId,false);
            List<JudicialCasesData> judicialCasesData = getJudicialCasesData(name, 2, cgId,true,null,null);
            creditGrantingRisk.setXsajList(judicialCasesData);
            latch.countDown();
        });
        executorService.execute(()->{
//            getStatictics(name,3,cgId,false);
            List<JudicialCasesData> judicialCasesData = getJudicialCasesData(name, 3, cgId,true,null,null);
            creditGrantingRisk.setXzajList(judicialCasesData);
            latch.countDown();
        });
        executorService.execute(()->{
//            getStatictics(name,4,cgId,false);
            List<JudicialCasesData> judicialCasesData = getJudicialCasesData(name, 4, cgId,true,null,null);
            creditGrantingRisk.setFsbqajList(judicialCasesData);
            latch.countDown();
        });
        executorService.execute(()->{
//            getStatictics(name,5,cgId,false);
            List<JudicialCasesData> judicialCasesData = getJudicialCasesData(name, 5, cgId,true,null,null);
            creditGrantingRisk.setZxajList(judicialCasesData);
            latch.countDown();
        });
        executorService.execute(()->{
//            getStatictics(name,6,cgId,false);
            List<JudicialCasesData> judicialCasesData = getJudicialCasesData(name, 6, cgId,true,null,null);
            creditGrantingRisk.setQzqsypcList(judicialCasesData);
            latch.countDown();
        });
        executorService.execute(()->{
            List<JudicialCasesStatistics> judicialCasesStatisticsList = initData(cgId, name,true);
            creditGrantingRisk.setNumList(judicialCasesStatisticsList);
            latch.countDown();
        });
        executorService.execute(() -> {
            //        限高
            SFParams  sfParams =new SFParams();
            sfParams.setName(name);
            sfParams.setPageNum(1);
            sfParams.setPageSize(10);
            JSONObject jsonObject = judicialService.xgbzxrorg(sfParams);
            if (StringUtils.equals("2000", jsonObject.getString("code"))) {
                JSONArray data = jsonObject.getJSONArray("data");
                if (ObjectUtil.isNotNull(data)) {
                    creditGrantingRisk.setXzgxf(data.toJSONString());
                }
            }
            latch.countDown();
        });
        executorService.execute(() -> {
            //        失信
            SFParams  sfParams =new SFParams();
            sfParams.setName(name);
            sfParams.setPageNum(1);
            sfParams.setPageSize(10);
            JSONObject jsonObject = judicialService.humanDishonest(sfParams);
            if (StringUtils.equals("2000", jsonObject.getString("code"))) {
                JSONArray data = jsonObject.getJSONArray("data");
                if (ObjectUtil.isNotNull(data)) {
                    creditGrantingRisk.setSxbzxr(data.toJSONString());
                }
            }
            latch.countDown();
        });

        try {
            latch.await();
            creditGrantingRiskMapper.insertCreditGrantingRisk(creditGrantingRisk);
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }

        return creditGrantingRiskChangeDate(creditGrantingRisk);
    }

    public  CreditGrantingRisk creditGrantingRiskChangeDate(CreditGrantingRisk c){
        if(StringUtils.isNotEmpty(c.getHgxzcf())){
            JSONArray array = changeDate(JSONArray.parseArray(c.getHgxzcf()), "penaltyDate");
            c.setHgxzcfList(array);
            c.setHgxzcf(array.toJSONString());
        }
        if(StringUtils.isNotEmpty(c.getYzwf())){
            JSONArray array = changeDate(JSONArray.parseArray(c.getYzwf()), "putDate");
            c.setYzwfList(array);
            c.setYzwf(array.toJSONString());
        }
        if(StringUtils.isNotEmpty(c.getGqcz())){
            JSONArray array = changeDate(JSONArray.parseArray(c.getGqcz()), "regDate", "putDate");
            c.setGqczList(array);
            c.setGqcz(array.toJSONString());
        }
        if(StringUtils.isNotEmpty(c.getQsgg())){
            JSONArray array = changeDate(JSONArray.parseArray(c.getQsgg()), "regDate");
            c.setQsggList(array);
            c.setQsgg(array.toJSONString());
        }
        if(StringUtils.isNotEmpty(c.getCyjc())){
            JSONArray array = changeDate(JSONArray.parseArray(c.getCyjc()), "checkDate");
            c.setCyjcList(array);
            c.setCyjc(array.toJSONString());
        }
        return c;
    }


    private List<JudicialCasesData> getJudicialCasesData(String ename, Integer type,Long cgId,boolean insertData,Map<String, JudicialCasesStatistics> count,String typeStr) {
        List<JudicialCasesData> selectData=new ArrayList<>();
        //处理司法数据
//        int i=1;
        List<JudicialCasesData> judicialCasesData =new ArrayList<>();
//        while (i<1000){//查询1w条左右上限
        String url = apiUrl + "sf/entoutreport/list";
        SFParams sfParams =new SFParams();
        sfParams.setName(ename);
        sfParams.setType(type+"");
        sfParams.setPageSize(1000);
        sfParams.setPageNum(1);
        JSONObject object = httpTemplate.getResult(httpTemplate.getSFUrl(url, sfParams));

//            JSONObject object = JSONObject.parseObject(s);
        if ("2000".equals( object.getString("code"))){
            JSONArray data = object.getJSONArray("data");
            if (null!=data&&!CollectionUtils.isEmpty(data)){
                JSONArray array = JSONArray.parseArray(data.toJSONString());
                for (Object o : array) {
                    JudicialCasesData judicialCasesData1 = JSONObject.parseObject(JSON.toJSONString(o), JudicialCasesData.class);
                    judicialCasesData1.setJsondata(JSON.toJSONString(o));
                    judicialCasesData.add(judicialCasesData1);
                }
            }
            if (null!=count){
                JudicialCasesStatistics judicialCasesStatistics = useDataCount(judicialCasesData, type, typeStr);
                count.put("sifaCount"+type,judicialCasesStatistics);
            }
        }else {
            if (null!=count)count.put("sifaCount"+type,useDataCount(new ArrayList<JudicialCasesData>(), type, typeStr));
        }
//            i++;
//            System.out.println(i);
//        }
        //立案日期倒叙
        judicialCasesData=judicialCasesData.stream().filter(f->null!=f.getDLarq()).sorted(Comparator.comparing(JudicialCasesData::getDLarq,Comparator.nullsLast(Comparator.reverseOrder()))).collect(Collectors.toList());
        //取最近3年
        judicialCasesData=judicialCasesData.stream().filter(f-> DateUtils.valid3Year(f.getDLarq())).collect(Collectors.toList());
        //取10条
//        if (judicialCasesData.size()>10){
//            judicialCasesData=judicialCasesData.subList(0,10);
//        }
        List<Field> fieldList = Arrays.stream(JudicialCasesData.class.getDeclaredFields()).filter(f -> f.getType().getSimpleName().equals(String.class.getSimpleName())).collect(Collectors.toList());

        for (JudicialCasesData j : judicialCasesData) {
            if (j.getCAh().equals("（2025）冀0209执1090号")){
                System.out.println(1);
            }
            if ("未结案".equals(j.getNAjjzjd())){
                j.setNLaay(anyou(j.getNLaayTree(),j.getNLaay()));
            }else {
                j.setNLaay(anyou(j.getNJaayTree(),j.getNJaay()));//已结案取结案案由
            }
            /**
             民事案件和行政案件的处理
             未结案->  起诉标的金额  || 起诉标的金额_估计
             已结案->  “结案标的金额”或“结案标的金额_估计”

             取 结案    |  结案金额 >0
             取 结案估  |  结案金额 >0||null  ; 结案估>0
             取 结案估  |  结案金额 >0||null  ; 结案估>0

             */
            if (type==1||type==3){//民事案件和行政案件的处理
                if("未结案".equals(j.getNAjjzjd())){//案件进展阶段
                    j=amountOfMoney(j.getNQsbdje(),j.getNQsbdjeGj(),"起诉标的金额（元）","起诉标的金额估计（元）",j);
                }else{
                    List<SelectItem> listVal= Arrays.asList(
                            new SelectItem(1,"结案标的金额（元）",j.getNJabdje()),
                            new  SelectItem(2,"结案标的金额估计（元）",j.getNJabdjeGj()),
                            new  SelectItem(3,"起诉标的金额（元",j.getNQsbdje()),
                            new SelectItem(4,"起诉标的金额估计（元",j.getNQsbdjeGj())
                    );
                    JSONObject jsonObject = streamGetAmountOfMoney(listVal);
                    j.setShowAmount(jsonObject.getString("num2"));
                    j.setTdName(jsonObject.getString("title"));
//                    //取结案标的金额估计（元）
//                    if (nullAndZero(j.getNJabdje()) &&!nullAndZero(j.getNJabdjeGj())){ // 金额=0 估值!=0
//                        j.setShowAmount(j.getNJabdjeGj());
//                        j.setTdName("结案标的金额估计（元）");
//                   //结案标的金额（元）
//                    }else if(!nullAndZero(j.getNJabdje())){
//                        j.setShowAmount(j.getNJabdje());
//                        j.setTdName("结案标的金额（元）");
//                    //结案全部为空
//                    }else if (nullAndZero(j.getNJabdje())&&nullAndZero(j.getNJabdjeGj())){
//                        //起诉金额估值
//                        if (nullAndZero(j.getNQsbdje())&&!nullAndZero(j.getNQsbdjeGj())){
//                            j.setShowAmount(j.getNQsbdjeGj());
//                            j.setTdName("起诉标的金额估计（元）");
//                        }else if (!nullAndZero(j.getNQsbdje())){
//                            j.setShowAmount(j.getNQsbdje());
//                            j.setTdName("起诉标的金额（元）");
//                        }else{
//                            j.setShowAmount(j.getNJabdje());
//                            j.setTdName("结案标的金额（元）");
//                        }
//
//                    }
                };
            }else if (type==2){

                /**
                 刑事案件的处理
                 未结案->  被请求赔偿金额
                 已结案->  “判处赔偿金额”或“判处赔偿金额_估计”
                 else  判处赔偿金额=0
                 */
                if("未结案".equals(j.getNAjjzjd())){//刑事案件的处理
                    j.setShowAmount(j.getNBqqpcje());
                    j.setTdName("被请求赔偿金额（元）");
                }else{
                    if (nullAndZero(j.getNPcpcje())&&!nullAndZero(j.getNPcpcjeGj())){//结案标的金额=0 结案标的金额_估计!=0
                        j.setShowAmount(j.getNPcpcjeGj());
                        j.setTdName("判处赔偿金额估计（元）");
                    }else{
                        j.setShowAmount(j.getNPcpcje());
                        j.setTdName("判处赔偿金额（元）");
                    }
                    j=amountOfMoney(j.getNPcpcje(),j.getNPcpcjeGj(),"判处赔偿金额（元）","判处赔偿金额估计（元）",j);

                };
            }else if (type==5) {

                /**
                 执行案件的处理
                 未结案->  申请执行标的金额
                 已结案->  “结案标的金额”或“结案标的金额_估计”
                 金额>0                          取  金额
                 金额=0 并且 估值=空               取  金额
                 金额=0 并且 估值！=空             取  估值
                 金额=空 并且 估值=空              取  任取空值
                 */
                if("未结案".equals(j.getNAjjzjd())){//案件进展阶段
                    j.setShowAmount(j.getNSqzxbdje());
                    j.setTdName("申请执行标的金额");
                }else{
                    j=amountOfMoney(j.getNJabdje(),j.getNJabdjeGj(),"结案标的金额（元）","结案标的金额估计（元）",j);
                };
            } else{
                j.setShowAmount(j.getNJabdje());
                j.setTdName("结案标的金额（元）");
            }
            j.setType(String.valueOf(type));
            j.setEname(ename);
            j.setDataStatus(1);
            j.setCgId(cgId);
            if (insertData){
                judicialCasesDataService.insertJudicialCasesData(j);
            }
            for (Field field : fieldList) {
                field.setAccessible(true);
                try {
                    Object stringVal = field.get(j);
                    if (null==stringVal||StringUtils.isEmpty(stringVal.toString())){
                        field.set(j, ReportMakeService.no_data);
                    }
                } catch (IllegalAccessException e) {
                    throw new RuntimeException(e);
                }
            }
        }
        selectData=judicialCasesData;
        if (insertData){
            selectData = judicialCasesDataService.selectTen(JudicialCasesData.builder().cgId(cgId).dataStatus(1).type(String.valueOf(type)).build());
        }

        return judicialCasesData;
    }
    public String anyou(String ayxq,String ay){
        if (com.lhcredit.common.utils.StringUtils.isNotEmpty(ayxq)){
            String[] split = ayxq.split(",");
            return split[split.length-1];
        }else{
            return ay;
        }
    }
    /**
     金额>0                      取  金额  1
     金额=0   并且   估值=空       取  金额  2
     金额=0   并且   估值！=空     取  估值  3
     金额=空  并且   估值=空       取  金额  4
     金额=空  并且   估值!=空      取  估值  5
     */
    public JudicialCasesData amountOfMoney(String jine,String guzhi,String jineName,String guzhiName,JudicialCasesData j){
        BigDecimal jineNum=null;
        BigDecimal guzhiNum=null;
        if (com.lhcredit.common.utils.StringUtils.isNotEmpty(jine)){
            jineNum=new BigDecimal(jine);
            if (com.lhcredit.common.utils.StringUtils.isNotEmpty(guzhi)){
                guzhiNum=new BigDecimal(guzhi);
                if (jineNum.compareTo(BigDecimal.ZERO)==0&&guzhiNum.compareTo(BigDecimal.ZERO)==1){
                    //3
                    j.setShowAmount(guzhi);
                    j.setTdName(guzhiName);
                    return j;
                }
            }
        }else{
            if (com.lhcredit.common.utils.StringUtils.isNotEmpty(guzhi)){
                //5
                j.setShowAmount(guzhi);
                j.setTdName(guzhiName);
                return j;
            }
        }
        j.setShowAmount(jine);
        j.setTdName(jineName);
        return j;//1,2,4
    }
    @NoArgsConstructor
    @Data
    public  class SelectItem{
        private int idx;
        private String title;
        private BigDecimal num2;
        private String num;

        public SelectItem(int idx, String title, String num) {
            this.idx = idx;
            this.title = title;
            this.num = num;
            if (com.lhcredit.common.utils.StringUtils.isEmpty(num)){
                this.num2 =null;
            }else{
                this.num2 = new BigDecimal(num);
            }
        }

    }

    public static JSONObject streamGetAmountOfMoney(List<SelectItem> listVal){
        List<SelectItem> val=null;//筛选的list
        SelectItem item1=listVal.get(0);//缓存第一个，全部为空时返回
        listVal= listVal.stream().filter(i->null!=i.num2).collect(Collectors.toList());//赛选!=null
        if (CollectionUtils.isEmpty(listVal)){
            return JSONObject.parseObject(JSON.toJSONString(item1));
        }
        //筛选 >0 后排序取第一个
        val=listVal.stream().filter(i->i.num2.compareTo(BigDecimal.ZERO)==1).sorted(Comparator.comparing(SelectItem::getIdx)).collect(Collectors.toList());
        if (CollectionUtils.isEmpty(val)){
            System.out.println("No item >0");
        }else {
            return JSONObject.parseObject(JSON.toJSONString(val.get(0)));//
        }
        //筛选 ==0 后排序取第一个
        val=listVal.stream().filter(i->i.num2.compareTo(BigDecimal.ZERO)==0).sorted(Comparator.comparing(SelectItem::getIdx)).collect(Collectors.toList());
        if (CollectionUtils.isEmpty(val)){
            System.out.println("No item =0");//这个就是全部为空的   会在上面返回
        }else {
            return JSONObject.parseObject(JSON.toJSONString(val.get(0)));
        }
        //不会走到这里
        return JSONObject.parseObject(JSON.toJSONString(listVal.get(0)));
    }
    public boolean nullAndZero(String str){
        if (com.lhcredit.common.utils.StringUtils.isEmpty(str)){
            return true;
        }
        if("0".equals(str)){
            return true;
        }
        return false;
    }
    public void getStatictics(String ename ,Integer type,Long cgId){
//        urlb=urlb.replace("${name}",ename);
//        String ss = new HttpUtils().qccObject(urlb, null);
        String url = apiUrl + "sf/entoutreport/caseCount";
        SFParams sfParams =new SFParams();
        sfParams.setName(ename);
        sfParams.setType(type+"");
        JSONObject object = httpTemplate.getResult(httpTemplate.getSFUrl(url, sfParams));
//        JSONObject object = JSONObject.parseObject(ss);
        Map<Integer, String> map = JudicialCasesEnum.getMap();//获取全部类型  处理后为缺少的类型
        JudicialCasesStatisticsYear insertData=null;
        if ("2000".equals( object.getString("code"))) {
            JSONArray data = object.getJSONArray("data");
            if (null != data && !CollectionUtils.isEmpty(data)) {
                List<JudicialCasesStatisticsYear> val2 = JSONArray.parseArray(data.toJSONString(), JudicialCasesStatisticsYear.class);
                val2.forEach(i -> {
                    i.setEname(ename);
                    i.setCgId(cgId);
                    if ("1".equals(i.getCaseType())) {
                        i.setCaseType(0);
                    } else {
                        i.setCaseType(i.getCaseType() - 1);
                    }
                });
                List<JudicialCasesStatisticsYear> collect = val2.stream().filter(i -> i.getCaseType()==type).collect(Collectors.toList());
                if (CollectionUtils.isEmpty(collect)){
                    insertData=new JudicialCasesStatisticsYear(type,map.get(type),ename,cgId);
                }else{
                    insertData=collect.get(0);
                    insertData.setCaseTypeStr(map.get(type));
                    insertData.setDataStatus(1);
                }
            }
            insertData.setCountTotal(countTotal(insertData));
            insertData.setCgId(cgId);
            judicialCasesStatisticsYearService.insertJudicialCasesStatisticsYear(insertData);
        }else{
            JudicialCasesStatisticsYear build = JudicialCasesStatisticsYear.builder().dataStatus(1).caseType(type).caseTypeStr(JudicialCasesEnum.getName(type))
                    .ename(ename).cgId(cgId).countTotal("0").fiveyear("0").onetothreeyear("0").threetofiveyear("0").oneyear("0").build();
            judicialCasesStatisticsYearService.insertJudicialCasesStatisticsYear(build);
        }

    }

    private String countTotal(JudicialCasesStatisticsYear insertData) {
        Integer year1 = Integer.valueOf(com.lhcredit.common.utils.StringUtils.isEmpty(insertData.getOneyear()) ? "0" : insertData.getOneyear());
        Integer year1_3 = Integer.valueOf(com.lhcredit.common.utils.StringUtils.isEmpty(insertData.getOnetothreeyear()) ? "0" : insertData.getOnetothreeyear());
        Integer year3_5 = Integer.valueOf(com.lhcredit.common.utils.StringUtils.isEmpty(insertData.getThreetofiveyear()) ? "0" : insertData.getThreetofiveyear());
        Integer year5 = Integer.valueOf(com.lhcredit.common.utils.StringUtils.isEmpty(insertData.getFiveyear()) ? "0" : insertData.getFiveyear());
        return (year1+year1_3+year3_5+year5)+"";
    }
    public static enum JudicialCasesEnum{
        NO0("合计",0),
        NO1("民事案件总数",1),
        NO2("刑事案件总数",2),
        NO3("行政案件总数",3),
        NO4("非诉保全案件总数",4),
        NO5("执行案件总数",5),
        NO6("破产案件总数",6)
        ;
        public String name;
        public Integer val;
        JudicialCasesEnum(String  name ,Integer val){
            this.name=name;
            this.val=val;
        }
        public static Map<Integer,String> getMap(){
            Map<Integer,String> map=new HashMap<>();
            for (JudicialCasesEnum value : JudicialCasesEnum.values()) {
                map.put(value.val,value.name);
            }
            return map;
        }
        public static String getName(Integer val) {
            for (JudicialCasesEnum value : JudicialCasesEnum.values()) {
                if(value.val==val){
                    return value.name;
                }
            }
            return null;
        }
    }

    public  List<JudicialCasesStatistics>  initData(Long cgId,String ename,boolean insertData){
        List<JudicialCasesStatistics> judicialCasesStatisticsList=new ArrayList<>();
        String url = apiUrl + "sf/entoutreport/caseCount";
        SFParams sfParams =new SFParams();
        sfParams.setName(ename);
        JSONObject object = httpTemplate.getResult(httpTemplate.getSFUrl(url, sfParams));
        //处理司法统计
        if ("2000".equals( object.getString("code"))) {
            JSONArray data = object.getJSONArray("data");
            if (null != data && !CollectionUtils.isEmpty(data)) {
                List<JudicialCasesStatistics> val2 = JSONArray.parseArray(data.toJSONString(), JudicialCasesStatistics.class);
                //      1总计 2民事 3刑事 4行政 5非诉保全 6执行 7强制清算与破产
                Map<Integer, String> map = JudicialCasesEnum.getMap();//获取全部类型  处理后为缺少的类型
                val2.forEach(i -> {
                    i.setEname(ename);
                    i.setCgId(cgId);
                    if ("1".equals(i.getCaseType())) {
                        i.setCaseType(0);
                    } else {
                        i.setCaseType(i.getCaseType() - 1);
                    }
                });
                Set<Integer> typeSet = val2.stream().map(JudicialCasesStatistics::getCaseType).collect(Collectors.toSet());
                typeSet.forEach(s -> {//将查询到的类型删除掉
                    map.remove(s);
                });
                //添加缺少的项目
                map.forEach((k, v) -> {
                    JudicialCasesStatistics build = JudicialCasesStatistics.builder().caseType(k).ename(ename).dataStatus(1).build();
                    val2.add(build);
                });
                Map<Integer, String> map1 = JudicialCasesEnum.getMap();
                val2.forEach(i -> {
                    i.setDataStatus(1);
                    String s = map1.get(i.getCaseType());
                    s=s.replaceAll("总数", "");
                    i.setCaseTypeStr(s);
                    i.setParamsdata(object.toJSONString());
                    i.setCgId(cgId);
                    if(insertData){
                        judicialCasesStatisticsService.insertJudicialCasesStatistics(i);
                    }

                });
                judicialCasesStatisticsList=val2;
            }
        }else{
            Map<Integer, String> map = JudicialCasesEnum.getMap();//获取全部类型  处理后为缺少的类型
            //添加缺少的项目
            map.forEach((k, v) -> {
                v=v.replaceAll("总数", "");
                JudicialCasesStatistics build = JudicialCasesStatistics.builder().caseType(k).caseTypeStr(v).cgId(cgId).dataStatus(1).build();
                if(insertData){
                    judicialCasesStatisticsService.insertJudicialCasesStatistics(build);
                }
            });
        }
        if(insertData){
            judicialCasesStatisticsList = judicialCasesStatisticsService.selectJudicialCasesStatisticsList(JudicialCasesStatistics.builder().cgId(cgId).dataStatus(1).build());
            if(judicialCasesStatisticsList==null||judicialCasesStatisticsList.size()==0){
                judicialCasesStatisticsList=null;
            }
        }
        //查询数据

        return judicialCasesStatisticsList;
    }
    public JSONArray changeDate(JSONArray arr,String... field){
        for (int i = 0; i < arr.size(); i++) {
            JSONObject jsonObject = arr.getJSONObject(i);
            try{
                for (String s : field) {
                    String string = jsonObject.getString(s);
                    if (StringUtils.isEmpty(string)||string.contains("-"))continue;
                    Date date= new Date(Long.parseLong(string))  ;
                    String str = DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD, date);
                    jsonObject.put(s,str);
                }
                arr.set(i,jsonObject);
            }catch (Exception e){
                e.printStackTrace();
            }
        }
        return arr;
    }


    @Override
    public  CreditGrantingRisk findByCgId(Long cgId){
        CreditGrantingRisk c = creditGrantingRiskMapper.selectCreditGrantingRiskByCgId(cgId);
        if(c!=null){
            if(StringUtils.isNotEmpty(c.getXzcf())){
                c.setXzcfList(JSONArray.parseArray(c.getXzcf()));
            }
            if(StringUtils.isNotEmpty(c.getJyyc())){
                c.setJyycList(JSONArray.parseArray(c.getJyyc()));
            }
            if(StringUtils.isNotEmpty(c.getHgxzcf())){
                c.setHgxzcfList(changeDate(JSONArray.parseArray(c.getHgxzcf()),"penaltyDate"));
            }
            if(StringUtils.isNotEmpty(c.getYzwf())){
                c.setYzwfList(changeDate(JSONArray.parseArray(c.getYzwf()),"putDate","putDate"));
            }
            if(StringUtils.isNotEmpty(c.getGqcz())){
                c.setGqczList(JSONArray.parseArray(c.getGqcz()));
            }
            if(StringUtils.isNotEmpty(c.getQsgg())){
                c.setQsggList(changeDate(JSONArray.parseArray(c.getQsgg()),"regDate"));
            }
            if(StringUtils.isNotEmpty(c.getQsxx())){
                c.setQsxxList(JSONArray.parseArray(c.getQsxx()));
            }
            if(StringUtils.isNotEmpty(c.getDcdy())){
                c.setDcdyList(JSONArray.parseArray(c.getDcdy()));
            }
            if(StringUtils.isNotEmpty(c.getCyjc())){
                c.setCyjcList(JSONArray.parseArray(c.getCyjc()));
            }
            if(StringUtils.isNotEmpty(c.getSxbzxr())){
                c.setSxbzxrList(JSONArray.parseArray(c.getSxbzxr()));
            }
            if(StringUtils.isNotEmpty(c.getXzgxf())){
                c.setXzgxfList(JSONArray.parseArray(c.getXzgxf()));
            }
            if(StringUtils.isNotEmpty(c.getSfxz())){
                c.setSfxzList(JSONArray.parseArray(c.getSfxz()));
            }
            if(StringUtils.isNotEmpty(c.getSfpm())){
                c.setSfpmList(JSONArray.parseArray(c.getSfpm()));
            }
            List<JudicialCasesStatistics> judicialCasesStatisticsList = judicialCasesStatisticsService.selectJudicialCasesStatisticsList(JudicialCasesStatistics.builder().cgId(cgId).dataStatus(1).build());
            List<JudicialCasesData> judicialCasesData1 = judicialCasesDataService.selectTen(JudicialCasesData.builder().cgId(cgId).dataStatus(1).type("1").build());
            List<JudicialCasesData> judicialCasesData2 = judicialCasesDataService.selectTen(JudicialCasesData.builder().cgId(cgId).dataStatus(1).type("2").build());
            List<JudicialCasesData> judicialCasesData3 = judicialCasesDataService.selectTen(JudicialCasesData.builder().cgId(cgId).dataStatus(1).type("3").build());
            List<JudicialCasesData> judicialCasesData4 = judicialCasesDataService.selectTen(JudicialCasesData.builder().cgId(cgId).dataStatus(1).type("4").build());
            List<JudicialCasesData> judicialCasesData5 = judicialCasesDataService.selectTen(JudicialCasesData.builder().cgId(cgId).dataStatus(1).type("5").build());
            List<JudicialCasesData> judicialCasesData6 = judicialCasesDataService.selectTen(JudicialCasesData.builder().cgId(cgId).dataStatus(1).type("6").build());
            c.setMsajList(judicialCasesData1);
            c.setXsajList(judicialCasesData2);
            c.setXzajList(judicialCasesData3);
            c.setFsbqajList(judicialCasesData4);
            c.setZxajList(judicialCasesData5);
            c.setQzqsypcList(judicialCasesData6);
            c.setNumList(judicialCasesStatisticsList);
            return creditGrantingRiskChangeDate(c);
        }
        return creditGrantingRiskChangeDate(c);
    }
}