增加客户基础资料从表

src/main/java/com/uas/erp/schedular/finance/task/CustInfomationTask.java

@@ -10,6 +10,7 @@ import com.usoft.fin.external.open.api.protobuf.GetBaseInfoResp;
 import com.usoft.fin.external.open.api.protobuf.GetEnterpriseExtensionInfoReq;
 import com.usoft.fin.external.open.api.protobuf.GetEnterpriseExtensionInfoResp;
 import com.usoft.sdk.fin.client.TradingHallSdk;
+import com.usoft.sdk.fin.utils.ProtoBufUtil;
 import org.springframework.stereotype.Component;
 
 import java.text.SimpleDateFormat;
@@ -61,10 +62,580 @@ public class CustInfomationTask extends AbstractTask{
             sqls.addAll(getSixSqls(type,cuId,entExtInfoResp.getErpDataInfo()));
             //从表7 上下游信息 UPDOWNINFO
             sqls.addAll(getSevenSqls(type,cuId,entExtInfoResp.getErpDataInfo()));
+            CompanyEnterpriseCrawlerListFinRest companyEnterpriseCrawlerList =
+                    entExtInfoResp.getCompanyEnterpriseCrawlerList();
+            //从表8  失信被执行人 DISHONESTEXE
+            CompanyLawInfoFinRest companyLawInfo = companyEnterpriseCrawlerList.getCompanyLawInfo();
+            String laBreakFaithExPer = companyLawInfo.getLaBreakFaithExPer();
+            //sqls.addAll(get8Sqls(type,cuId,laBreakFaithExPer));
+            //从表9  被执行人   EXECUTEEINFO
+            List<CompanyLawByExecutePersonInfoFinRest> companyLawByExecutePersonInfoList =
+                    companyEnterpriseCrawlerList.getCompanyLawByExecutePersonInfoList();
+            sqls.addAll(get9Sqls(type,cuId,companyLawByExecutePersonInfoList));
+            //从表10  法院公告  COURTANNOUNCEMENT
+            List<CompanyCourtNoticeRest> companyCourtNoticeList =
+                    companyEnterpriseCrawlerList.getCompanyCourtNoticeList();
+            sqls.addAll(get10Sqls(type,cuId,companyCourtNoticeList));
+            //从表11  裁判文书   JUDGDOCUMENTS
+            List<CompanyJudgmentWritFinRest> companyJudgmentWritList =
+                    companyEnterpriseCrawlerList.getCompanyJudgmentWritList();
+            sqls.addAll(get11Sqls(type,cuId,companyJudgmentWritList));
+            //从表12  开庭公告   COURTANNOUNCE
+            List<CompanyOpenCourtNoticeFinRest> companyOpenCourtNoticeList =
+                    companyEnterpriseCrawlerList.getCompanyOpenCourtNoticeList();
+            sqls.addAll(get12Sqls(type,cuId,companyOpenCourtNoticeList));
+            //从表13  立案信息   CASEINFO
+            List<CompanyPutOnRecordInfoFinRest> companyPutOnRecordInfoList =
+                    companyEnterpriseCrawlerList.getCompanyPutOnRecordInfoList();
+            sqls.addAll(get13Sqls(type,cuId,companyPutOnRecordInfoList));
+            //从表14   股权冻结   STOCKFREEZE
+            String laEquityFreezing = companyLawInfo.getLaEquityFreezing();
+            sqls.addAll(get14Sqls(type,cuId,laEquityFreezing));
+            //从表15  经营异常   ABNORMALBUSINESS
+            CompanyManageRiskFinRest companyManageRisk = companyEnterpriseCrawlerList.getCompanyManageRisk();
+            String manageAbnormalIn = companyManageRisk.getManageAbnormalIn();
+            sqls.addAll(get15Sqls(type,cuId,manageAbnormalIn));
+            //从表16  行政处罚工商局  INDUSTRYCOMMERCE
+            String administrativePenaltyIndustrial = companyManageRisk.getAdministrativePenaltyIndustrial();
+            //sqls.addAll(get16Sqls(type,cuId,administrativePenaltyIndustrial));
+            //从表17  动产抵押   MORTGAGEINFO
+            String chattelMortgage = companyManageRisk.getChattelMortgage();
+            //sqls.addAll(get17Sqls(type,cuId,chattelMortgage));
+            //从表18   股权出质  EQUITYPLEDGE
+            String equityPledge = companyManageRisk.getEquityPledge();
+            //sqls.addAll(get18Sqls(type,cuId,equityPledge));
+            //从表19 股权质押   STOCKINFO
+            String pledgeOfStockRight = companyManageRisk.getPledgeOfStockRight();
+            //sqls.addAll(get19Sqls(type,cuId,pledgeOfStockRight));
+            //从表20 公示催告   PUBLICNOTICE
+            String serviceByPublication = companyManageRisk.getServiceByPublication();
+            sqls.addAll(get20Sqls(type,cuId,serviceByPublication));
+            //从表21 严重违法   ILLEGALINFORMATION
+            String severityBreakTheLaw = companyManageRisk.getSeverityBreakTheLaw();
+            //sqls.addAll(get21Sqls(type,cuId,severityBreakTheLaw));
+            //从表22 行政处罚税务局   TAXATIONBUREAU
+            String administrativePenaltyTax = companyManageRisk.getAdministrativePenaltyTax();
+            //sqls.addAll(get22Sqls(type,cuId,administrativePenaltyTax));
+            //从表23 行政处罚信用中国   CREDITCHINA
+            String administrativePenaltyCredit = companyManageRisk.getAdministrativePenaltyCredit();
+            //sqls.addAll(get23Sqls(type,cuId,administrativePenaltyCredit));
+            //从表24 环保处罚   ENVIRONMENTALINFO
+            String environmentalPenalties = companyManageRisk.getEnvironmentalPenalties();
+            //sqls.addAll(get24Sqls(type,cuId,environmentalPenalties));
+            //从表25 清算信息   CLEARINFO
+            String clearingInfo = companyManageRisk.getClearingInfo();
+            //sqls.addAll(get25Sqls(type,cuId,clearingInfo));
+            //从表26 司法拍卖   JUDICIALSALE
+            String judicialSale = companyManageRisk.getJudicialSale();
+            //sqls.addAll(get26Sqls(type,cuId,judicialSale));
+            //从表27 简易注销   SIMPLECANCE
+            String simpleCancellation = companyManageRisk.getSimpleCancellation();
+            //sqls.addAll(get27Sqls(type,cuId,simpleCancellation));
+            //从表28 欠税公告   TAXARREARS
+            int manageRiskEnId = companyManageRisk.getManageRiskEnId();
+            //sqls.addAll(get28Sqls(type,cuId,manageRiskEnId));
+            //从表29 土地抵押   MORTGAGELAND
+            String landMortgage = companyManageRisk.getLandMortgage();
+            //sqls.addAll(get29Sqls(type,cuId,landMortgage));
+
         }
         //System.out.println("COMMONSQLS:"+sqls);
         jdbcTemplate.batchExecute(sqls);
     }
+
+    //从表29 土地抵押   MORTGAGELAND
+    private List<String> get29Sqls(String type,int cuId,String landMortgage){
+        List<String> sqls = new ArrayList<>();
+        JSONArray landMortgageList = JSONArray.parseArray(landMortgage);
+        if(landMortgageList!=null && landMortgageList.size()>0){
+            if(type.equals("UPDATE")) {
+                sqls.add("delete from MORTGAGELAND where ML_CUID = " + cuId);
+            }
+            List<Map<String,String>> listObjectFir = (List<Map<String,String>>) JSONArray.parse(landMortgage);
+            int detno = 1;
+            for(Map<String,String> map : listObjectFir){
+                sqls.add("insert into MORTGAGELAND (ML_ID,ML_CUID,ML_DETNO,ML_MORTGAGOR,ML_MORTGAGEE,ML_USE,ML_NATURETYPE,ML_AREA,ML_VALUATIONMONEY,ML_PAWNAMOUNT,ML_STARTDATE,ML_ENDDATE) values " +
+                        "(MORTGAGELAND_SEQ.NEXTVAL,"+cuId+","+detno+")");
+                detno = detno+1;
+            }
+        }
+
+        return sqls;
+    }
+    //从表28 欠税公告   TAXARREARS
+    private List<String> get28Sqls(String type,int cuId,String manageRiskEnId){
+        List<String> sqls = new ArrayList<>();
+        JSONArray manageRiskEnIdList = JSONArray.parseArray(manageRiskEnId);
+        if(manageRiskEnIdList!=null && manageRiskEnIdList.size()>0){
+            if(type.equals("UPDATE")) {
+                sqls.add("delete from TAXARREARS where TA_CUID = " + cuId);
+            }
+            List<Map<String,String>> listObjectFir = (List<Map<String,String>>) JSONArray.parse(manageRiskEnId);
+            int detno = 1;
+            for(Map<String,String> map : listObjectFir){
+                sqls.add("insert into TAXARREARS (TA_ID,TA_CUID,TA_DETNO,TA_TAXTYPE,TA_TAXBALANCE,TA_CURRENTTAXBALANCE,TA_UNIT,TA_PUBLICDATE) values " +
+                        "(TAXARREARS_SEQ.NEXTVAL,"+cuId+","+detno+")");
+                detno = detno+1;
+            }
+        }
+
+        return sqls;
+    }
+    //从表27 简易注销   SIMPLECANCE
+    private List<String> get27Sqls(String type,int cuId,String simpleCancellation){
+        List<String> sqls = new ArrayList<>();
+        JSONArray simpleCancellationList = JSONArray.parseArray(simpleCancellation);
+        if(simpleCancellationList!=null && simpleCancellationList.size()>0){
+            if(type.equals("UPDATE")) {
+                sqls.add("delete from SIMPLECANCE where SC_CUID = " + cuId);
+            }
+            List<Map<String,String>> listObjectFir = (List<Map<String,String>>) JSONArray.parse(simpleCancellation);
+            int detno = 1;
+            for(Map<String,String> map : listObjectFir){
+                sqls.add("insert into SIMPLECANCE (SC_ID,SC_CUID,SC_DETNO,SC_ENTERPRISE,SC_CREDITCODE,SC_REGISTRAR,SC_ANNOUNCEMENT,SC_RESULT,SC_APPLICATIONDATE) values " +
+                        "(SIMPLECANCE_SEQ.NEXTVAL,"+cuId+","+detno+")");
+                detno = detno+1;
+            }
+        }
+
+        return sqls;
+    }
+    //从表26 司法拍卖   JUDICIALSALE
+    private List<String> get26Sqls(String type,int cuId,String judicialSale){
+        List<String> sqls = new ArrayList<>();
+        JSONArray judicialSaleList = JSONArray.parseArray(judicialSale);
+        if(judicialSaleList!=null && judicialSaleList.size()>0){
+            if(type.equals("UPDATE")) {
+                sqls.add("delete from JUDICIALSALE where JS_CUID = " + cuId);
+            }
+            List<Map<String,String>> listObjectFir = (List<Map<String,String>>) JSONArray.parse(judicialSale);
+            int detno = 1;
+            for(Map<String,String> map : listObjectFir){
+                sqls.add("insert into JUDICIALSALE (JS_ID,JS_CUID,JS_DETNO,JS_DETAIL) values " +
+                        "(JUDICIALSALE_SEQ.NEXTVAL,"+cuId+","+detno+")");
+                detno = detno+1;
+            }
+        }
+
+        return sqls;
+    }
+    //从表25 清算信息   CLEARINFO
+    private List<String> get25Sqls(String type,int cuId,String clearingInfo){
+        List<String> sqls = new ArrayList<>();
+        JSONArray clearingInfoList = JSONArray.parseArray(clearingInfo);
+        if(clearingInfoList!=null && clearingInfoList.size()>0){
+            if(type.equals("UPDATE")) {
+                sqls.add("delete from CLEARINFO where CI_CUID = " + cuId);
+            }
+            List<Map<String,String>> listObjectFir = (List<Map<String,String>>) JSONArray.parse(clearingInfo);
+            int detno = 1;
+            for(Map<String,String> map : listObjectFir){
+                sqls.add("insert into CLEARINFO (CI_ID,CI_CUID,CI_DETNO,CI_CHARGE,CI_MEMBER) values " +
+                        "(CLEARINFO_SEQ.NEXTVAL,"+cuId+","+detno+")");
+                detno = detno+1;
+            }
+        }
+
+        return sqls;
+    }
+    //从表24 环保处罚   ENVIRONMENTALINFO
+    private List<String> get24Sqls(String type,int cuId,String environmentalPenalties){
+        List<String> sqls = new ArrayList<>();
+        JSONArray environmentalPenaltiesList = JSONArray.parseArray(environmentalPenalties);
+        if(environmentalPenaltiesList!=null && environmentalPenaltiesList.size()>0){
+            if(type.equals("UPDATE")) {
+                sqls.add("delete from ENVIRONMENTALINFO where EI_CUID = " + cuId);
+            }
+            List<Map<String,String>> listObjectFir = (List<Map<String,String>>) JSONArray.parse(environmentalPenalties);
+            int detno = 1;
+            for(Map<String,String> map : listObjectFir){
+                sqls.add("insert into ENVIRONMENTALINFO (EI_ID,EI_CUID,EI_DETNO,EI_DOCUMETNO,EI_RESON,EI_TYPE,EI_BASIS,EI_RESULT,EI_UNIT,EI_DATE,EI_EXECUTION) values " +
+                        "(ENVIRONMENTALINFO_SEQ.NEXTVAL,"+cuId+","+detno+")");
+                detno = detno+1;
+            }
+        }
+
+        return sqls;
+    }
+    //从表23 行政处罚信用中国   CREDITCHINA
+    private List<String> get23Sqls(String type,int cuId,String administrativePenaltyCredit){
+        List<String> sqls = new ArrayList<>();
+        JSONArray administrativePenaltyCreditList = JSONArray.parseArray(administrativePenaltyCredit);
+        if(administrativePenaltyCreditList!=null && administrativePenaltyCreditList.size()>0){
+            if(type.equals("UPDATE")) {
+                sqls.add("delete from CREDITCHINA where CC_CUID = " + cuId);
+            }
+            List<Map<String,String>> listObjectFir = (List<Map<String,String>>) JSONArray.parse(administrativePenaltyCredit);
+            int detno = 1;
+            for(Map<String,String> map : listObjectFir){
+                sqls.add("insert into CREDITCHINA (CC_ID,CC_CUID,CC_DETNO,CC_DOCUMENTNO,CC_RESON,CC_STATUS,CC_DATE,CC_TYPE1,CC_TYPE2,CC_RESULT,CC_GEAR) values " +
+                        "(CREDITCHINA_SEQ.NEXTVAL,"+cuId+","+detno+")");
+                detno = detno+1;
+            }
+        }
+
+        return sqls;
+    }
+    //从表22 行政处罚税务局   TAXATIONBUREAU
+    private List<String> get22Sqls(String type,int cuId,String administrativePenaltyTax){
+        List<String> sqls = new ArrayList<>();
+        JSONArray administrativePenaltyTaxList = JSONArray.parseArray(administrativePenaltyTax);
+        if(administrativePenaltyTaxList!=null && administrativePenaltyTaxList.size()>0){
+            if(type.equals("UPDATE")) {
+                sqls.add("delete from TAXATIONBUREAU where TB_CUID = " + cuId);
+            }
+            List<Map<String,String>> listObjectFir = (List<Map<String,String>>) JSONArray.parse(administrativePenaltyTax);
+            int detno = 1;
+            for(Map<String,String> map : listObjectFir){
+                sqls.add("insert into TAXATIONBUREAU (TB_ID,TB_CUID,TB_DETNO,TB_CASENAME,TB_DOCUMENTNO,TB_CAUSE,TB_PUNISHMENTTYPE,TB_PUNISHMENTSTATUS,TB_PUNISHMENTRESULT,TB_PUNISHMENTDATE,TB_PUNISHMENTDEPART) values " +
+                        "(TAXATIONBUREAU_SEQ.NEXTVAL,"+cuId+","+detno+")");
+                detno = detno+1;
+            }
+        }
+
+        return sqls;
+    }
+    //从表21  严重违法   ILLEGALINFORMATION
+    private List<String> get21Sqls(String type,int cuId,String severityBreakTheLaw){
+        List<String> sqls = new ArrayList<>();
+        JSONArray severityBreakTheLawList = JSONArray.parseArray(severityBreakTheLaw);
+        if(severityBreakTheLawList!=null && severityBreakTheLawList.size()>0){
+            if(type.equals("UPDATE")) {
+                sqls.add("delete from ILLEGALINFORMATION where INF_CUID = " + cuId);
+            }
+            List<Map<String,String>> listObjectFir = (List<Map<String,String>>) JSONArray.parse(severityBreakTheLaw);
+            int detno = 1;
+            for(Map<String,String> map : listObjectFir){
+                sqls.add("insert into ILLEGALINFORMATION (INF_ID,INF_CUID,INF_DETNO,INF_DATE,INF_INCLUDEDORGAN,INF_RESON) values " +
+                        "(ILLEGALINFORMATION_SEQ.NEXTVAL,"+cuId+","+detno+")");
+                detno = detno+1;
+            }
+        }
+
+        return sqls;
+    }
+    //从表20 公示催告   PUBLICNOTICE
+    private List<String> get20Sqls(String type,int cuId,String serviceByPublication){
+        List<String> sqls = new ArrayList<>();
+        JSONArray serviceByPublicationList = JSONArray.parseArray(serviceByPublication);
+        if(serviceByPublicationList!=null && serviceByPublicationList.size()>0){
+            if(type.equals("UPDATE")) {
+                sqls.add("delete from PUBLICNOTICE where PN_CUID = " + cuId);
+            }
+            List<Map<String,String>> listObjectFir = (List<Map<String,String>>) JSONArray.parse(serviceByPublication);
+            int detno = 1;
+            for(Map<String,String> map : listObjectFir){
+                String cpdate = map.get("出票日");
+                if (cpdate!=null){
+                    cpdate = "to_date('"+cpdate+"','yyyy-MM-dd')";
+                }
+                String dpdate = map.get("到期日");
+                if (dpdate!=null){
+                    dpdate = "to_date('"+dpdate+"','yyyy-MM-dd')";
+                }
+                String ggdate = map.get("公告日期");
+                if (ggdate!=null){
+                    ggdate = "to_date('"+ggdate+"','yyyy-MM-dd')";
+                }
+                sqls.add("insert into PUBLICNOTICE (PN_ID,PN_CUID,PN_DETNO,PN_TICKETNUM,PN_APPLICATIONPERSON,PN_TICKETPERSON,PN_BEARER,PN_TYPE,PN_FACEAMOUNT,PN_DRAFTDATE,PN_ENDDATE,PN_PAYBANK,PN_PUBLICDATE,PN_DETAIL) values " +
+                        "(PUBLICNOTICE_SEQ.NEXTVAL,"+cuId+","+detno+",'"+map.get("票号")+"','"+map.get("申请人")+"','"+map.get("出票人")+
+                        "','"+map.get("持票人")+"','"+map.get("票据类型")+"','"+map.get("票面金额")+"',"+cpdate+","+dpdate+",'"+map.get("付款银行")+
+                        "',"+ggdate+",'"+map.get("公告内容")+"')");
+                detno = detno+1;
+            }
+        }
+
+        return sqls;
+    }
+    //从表19 股权质押   STOCKINFO
+    private List<String> get19Sqls(String type,int cuId,String pledgeOfStockRight){
+        List<String> sqls = new ArrayList<>();
+        JSONArray pledgeOfStockRightList = JSONArray.parseArray(pledgeOfStockRight);
+        if(pledgeOfStockRightList!=null && pledgeOfStockRightList.size()>0){
+            if(type.equals("UPDATE")) {
+                sqls.add("delete from STOCKINFO where SI_CUID = " + cuId);
+            }
+            List<Map<String,String>> listObjectFir = (List<Map<String,String>>) JSONArray.parse(pledgeOfStockRight);
+            int detno = 1;
+            for(Map<String,String> map : listObjectFir){
+                sqls.add("insert into STOCKINFO (SI_ID,SI_CUID,SI_DETNO,SI_CODE,SI_STOCKABBRE,SI_PLEDGERATIO,SI_PLEDGEDSHANUM,SI_MARKETVALUE,SI_PLEDGENUM,SI_SALEPLEDGENUM,SI_RESTRICTEDSHARES,SI_UPDOWN,SI_INDUSTRY) values " +
+                        "(STOCKINFO_SEQ.NEXTVAL,"+cuId+","+detno+")");
+                detno = detno+1;
+            }
+        }
+
+        return sqls;
+    }
+    //从表18   股权出质  EQUITYPLEDGE
+    private List<String> get18Sqls(String type,int cuId,String equityPledge){
+        List<String> sqls = new ArrayList<>();
+        JSONArray equityPledgeList = JSONArray.parseArray(equityPledge);
+        if(equityPledgeList!=null && equityPledgeList.size()>0){
+            if(type.equals("UPDATE")) {
+                sqls.add("delete from EQUITYPLEDGE where EP_CUID = " + cuId);
+            }
+            List<Map<String,String>> listObjectFir = (List<Map<String,String>>) JSONArray.parse(equityPledge);
+            int detno = 1;
+            for(Map<String,String> map : listObjectFir){
+                sqls.add("insert into EQUITYPLEDGE (EP_ID,EP_CUID,EP_DETNO,EP_REGNUMBER,EP_PLEDGOR,EP_PLEDGEE,EP_PLEDGTARDER,EP_PLEDGEQUILT,EP_DATE,EP_STATUS) values " +
+                        "(EQUITYPLEDGE_SEQ.NEXTVAL,"+cuId+","+detno+")");
+                detno = detno+1;
+            }
+        }
+
+        return sqls;
+    }
+
+    //从表17  动产抵押   MORTGAGEINFO
+    private List<String> get17Sqls(String type,int cuId,String chattelMortgage){
+        List<String> sqls = new ArrayList<>();
+        JSONArray chattelMortgageList = JSONArray.parseArray(chattelMortgage);
+        if(chattelMortgageList!=null && chattelMortgageList.size()>0){
+            if(type.equals("UPDATE")) {
+                sqls.add("delete from MORTGAGEINFO where MI_CUID = " + cuId);
+            }
+            List<Map<String,String>> listObjectFir = (List<Map<String,String>>) JSONArray.parse(chattelMortgage);
+            int detno = 1;
+            for(Map<String,String> map : listObjectFir){
+                sqls.add("insert into MORTGAGEINFO (MI_ID,MI_CUID,MI_DETNO,MI_REGISTRAR,MI_REGISTNO,MI_REGISTDATE,MI_TIMELIMIT,MI_TYPE,MI_NUMBER,MI_SCOPE,MI_COLLATERAL,MI_OWNERSHIP,MI_SITUATION,MI_REMARK) values " +
+                        "(MORTGAGEINFO_SEQ.NEXTVAL,"+cuId+","+detno+")");
+                detno = detno+1;
+            }
+        }
+
+        return sqls;
+    }
+
+    //从表16  行政处罚工商局  INDUSTRYCOMMERCE
+    private List<String> get16Sqls(String type,int cuId,String administrativePenaltyIndustrial){
+        List<String> sqls = new ArrayList<>();
+        JSONArray administrativePenaltyIndustrialList = JSONArray.parseArray(administrativePenaltyIndustrial);
+        if(administrativePenaltyIndustrialList!=null && administrativePenaltyIndustrialList.size()>0){
+            if(type.equals("UPDATE")) {
+                sqls.add("delete from INDUSTRYCOMMERCE where IC_CUID = " + cuId);
+            }
+            List<Map<String,String>> listObjectFir = (List<Map<String,String>>) JSONArray.parse(administrativePenaltyIndustrial);
+            int detno = 1;
+            for(Map<String,String> map : listObjectFir){
+                sqls.add("insert into INDUSTRYCOMMERCE (IC_ID,IC_CUID,IC_DETNO,IC_DOCUMENTNO,IC_ILLEGALTYPE,IC_CONTENT,IC_ANNOUNCEMENTDATE,IC_DECIDINGORGAN,IC_DECIDEDATE) values " +
+                        "(INDUSTRYCOMMERCE_SEQ.NEXTVAL,"+cuId+","+detno+")");
+                detno = detno+1;
+            }
+        }
+
+        return sqls;
+    }
+
+    //从表15  经营异常   ABNORMALBUSINESS
+    private List<String> get15Sqls(String type,int cuId,String manageAbnormalIn){
+        List<String> sqls = new ArrayList<>();
+        JSONArray manageAbnormalInList = JSONArray.parseArray(manageAbnormalIn);
+        if(manageAbnormalInList!=null && manageAbnormalInList.size()>0){
+            if(type.equals("UPDATE")) {
+                sqls.add("delete from ABNORMALBUSINESS where AB_CUID = " + cuId);
+            }
+            List<Map<String,String>> listObjectFir = (List<Map<String,String>>) JSONArray.parse(manageAbnormalIn);
+            int detno = 1;
+            for(Map<String,String> map : listObjectFir){
+                String s = map.get("列入日期");
+                if (s!=null){
+                    s="to_date('"+s+"','yyyy-MM-dd')";
+                }
+                sqls.add("insert into ABNORMALBUSINESS (AB_ID,AB_CUID,AB_DETNO,AB_DATE,AB_DECIDINGORGAN,AB_NOMERRESON) values " +
+                        "(ABNORMALBUSINESS_SEQ.NEXTVAL,"+cuId+","+detno+","+s+",'"+map.get("作出决定机关")+"','"+map.get("列入经营异常原因")+"')");
+                detno = detno+1;
+            }
+        }
+
+        return sqls;
+    }
+
+    //从表14   股权冻结   STOCKFREEZE
+    private List<String> get14Sqls(String type,int cuId,String laEquityFreezing){
+        List<String> sqls = new ArrayList<>();
+        JSONArray laEquityFreezingList = JSONArray.parseArray(laEquityFreezing);
+        if(laEquityFreezingList!=null && laEquityFreezingList.size()>0){
+            if(type.equals("UPDATE")) {
+                sqls.add("delete from STOCKFREEZE where SF_CUID = " + cuId);
+            }
+            List<Map<String,String>> listObjectFir = (List<Map<String,String>>) JSONArray.parse(laEquityFreezing);
+            int detno = 1;
+            for(Map<String,String> map : listObjectFir){
+                String s = map.get("冻结日期至");
+                if (s!=null){
+                    s="冻结日期至"+s;
+                }
+                sqls.add("insert into STOCKFREEZE (SF_ID,SF_CUID,SF_DETNO,SF_SUBJECTEDEXE,SF_FROZENEQUITY,SF_EQUITYAMOUNT,SF_DOCUMENTNO,SF_STATUS) values " +
+                        "(STOCKFREEZE_SEQ.NEXTVAL,"+cuId+","+detno+",'"+map.get("被执行人")+"','"+map.get("冻结股权标的企业")+"'," +
+                        "'"+map.get("被执行人持有股权、其他投资权益数额")+"','"+map.get("执行通知文书号")+"','"+s+"')");
+                detno = detno+1;
+            }
+        }
+
+        return sqls;
+    }
+
+    //从表13  立案信息   CASEINFO
+    private List<String> get13Sqls(String type,int cuId,
+                                   List<CompanyPutOnRecordInfoFinRest> companyPutOnRecordInfoList){
+        String regEx="[\n`~!@#$%^&*()+=|{}':;',\\[\\].<>/?~！@#￥%……&*（）——+|{}【】‘；：”“’。， 、？]";
+        String aa = " ";//这里是将特殊字符换为aa字符串," "代表直接去掉
+        List<String> sqls = new ArrayList<>();
+        if (companyPutOnRecordInfoList!=null && companyPutOnRecordInfoList.size()>0) {
+            if (type.equals("UPDATE")) {
+                sqls.add("delete from CASEINFO where CO_CUID = " + cuId);
+            }
+            int detno = 1;
+            for (CompanyPutOnRecordInfoFinRest cpor:companyPutOnRecordInfoList) {
+                String putDate = cpor.getPutDate();
+                if (putDate!=null){
+                    putDate = "to_date('"+putDate+"','yyyy-MM-dd')";
+                }
+                String putPublicProsecutor = cpor.getPutPublicProsecutor();
+                if (putPublicProsecutor!=null&&!putPublicProsecutor.equals("")){
+                    putPublicProsecutor = putPublicProsecutor.replaceAll(regEx,aa);
+                }
+
+                String putDefendant = cpor.getPutDefendant();
+                if (putDefendant!=null&&!putDefendant.equals("")){
+                    putDefendant = putDefendant.replaceAll(regEx,aa);
+                }
+                //System.err.println("putPublicProsecutor=="+putPublicProsecutor);
+                //System.err.println("putDefendant=="+putDefendant);
+                sqls.add("insert into CASEINFO (CO_ID,CO_CUID,CO_DETNO,CO_CASENO,CO_CASEDATE,CO_DEMANDANT,CO_DEFENDANT,CO_STATUS) values " +
+                        "(CASEINFO_SEQ.NEXTVAL," + cuId + "," + detno + ",'"+cpor.getPutCaseNumber()+"',"+putDate+
+                        ",'"+putPublicProsecutor+"','"+putDefendant+"','"+cpor.getPutCaseState()+"')");
+                detno = detno + 1;
+            }
+        }
+        return sqls;
+    }
+
+    //从表12  开庭公告   COURTANNOUNCE
+    private List<String> get12Sqls(String type,int cuId,
+                                   List<CompanyOpenCourtNoticeFinRest> companyOpenCourtNoticeList){
+        List<String> sqls = new ArrayList<>();
+        if (companyOpenCourtNoticeList!=null && companyOpenCourtNoticeList.size()>0) {
+            if (type.equals("UPDATE")) {
+                sqls.add("delete from COURTANNOUNCE where CA_CUID = " + cuId);
+            }
+            int detno = 1;
+            for (CompanyOpenCourtNoticeFinRest cocn:companyOpenCourtNoticeList) {
+                String openTime = cocn.getOpenTime();
+                if (openTime!=null){
+                    openTime = "to_date('"+openTime+"','yyyy-MM-dd hh24:mi')";
+                }
+                sqls.add("insert into COURTANNOUNCE (CA_ID,CA_CUID,CA_DETNO,CA_CASENO,CA_COURTTIME,CA_CASERESON,CA_DEMANDANT,CA_DEFENDANT,CA_PREFECTURE,CA_CONTENT) values " +
+                        "(COURTANNOUNCE_SEQ.NEXTVAL," + cuId + "," + detno + ",'"+cocn.getOpenRecordNumber()+"',"+openTime+
+                        ",'"+cocn.getOpenCauseOfAction()+"','"+cocn.getOpenAccuser()+"','"+cocn.getOpenAppellee()+"','"+cocn.getOpenRegion()+"','"+cocn.getOpenContent()+"')");
+                detno = detno + 1;
+            }
+        }
+        return sqls;
+    }
+    //从表11  裁判文书   JUDGDOCUMENTS
+    private List<String> get11Sqls(String type,int cuId,
+                                   List<CompanyJudgmentWritFinRest> companyJudgmentWritList){
+        List<String> sqls = new ArrayList<>();
+        if (companyJudgmentWritList!=null && companyJudgmentWritList.size()>0) {
+            if (type.equals("UPDATE")) {
+                sqls.add("delete from JUDGDOCUMENTS where JD_CUID = " + cuId);
+            }
+            int detno = 1;
+            for (CompanyJudgmentWritFinRest cjw:companyJudgmentWritList) {
+                String jubCaseMoney = cjw.getJubCaseMoney();
+                int caseMoney = 0;
+                if (jubCaseMoney!=null&&!jubCaseMoney.equals("")){
+                    caseMoney=Integer.parseInt(jubCaseMoney);
+                }
+                String jubReleaseDate = cjw.getJubReleaseDate();
+                String releaseDate ="";
+                if (jubReleaseDate!=null){
+                    releaseDate = "to_date('"+jubReleaseDate+"','yyyy-MM-dd')";
+                }
+                sqls.add("insert into JUDGDOCUMENTS (JD_ID,JD_CUID,JD_DETNO,JD_CASENAME,JD_CASERESON,JD_CASEMONEY,JD_PUBLICDATE,JD_CASENO,JD_CASEIDDENT,JD_COURT) values " +
+                        "(JUDGDOCUMENTS_SEQ.NEXTVAL," + cuId + "," + detno + ",'" +cjw.getJubCaseName()+ "','" +cjw.getJubCauseOfAction()+
+                        "',"+caseMoney+","+releaseDate+",'"+cjw.getJubCaseNumber()+"','"+cjw.getJubIdentity()+
+                        "','"+cjw.getJubExecutiveCourt()+"')");
+                detno = detno + 1;
+            }
+        }
+        return sqls;
+    }
+    //从表10  法院公告  COURTANNOUNCEMENT
+    private List<String> get10Sqls(String type,int cuId,
+                                   List<CompanyCourtNoticeRest> companyCourtNoticeList){
+        String regEx="[\n`~!@#$%^&*()+=|{}':;',\\[\\].<>/?~！@#￥%……&*（）——+|{}【】‘；：”“’。， 、？]";
+        String aa = " ";//这里是将特殊字符换为aa字符串," "代表直接去掉
+        List<String> sqls = new ArrayList<>();
+        if (companyCourtNoticeList!=null && companyCourtNoticeList.size()>0) {
+            if (type.equals("UPDATE")) {
+                sqls.add("delete from COURTANNOUNCEMENT where CA_CUID = " + cuId);
+            }
+            int detno = 1;
+            for (CompanyCourtNoticeRest ccn:companyCourtNoticeList) {
+                String courtPublishDate = ccn.getCourtPublishDate();
+                if (courtPublishDate!=null){
+                    courtPublishDate = "to_date('"+courtPublishDate+"','yyyy-MM-dd')";
+                }
+                String courtAppellor = ccn.getCourtAppellor();
+                if (courtAppellor!=null&&!courtAppellor.equals("")){
+                    courtAppellor = courtAppellor.replaceAll(regEx,aa);
+                }
+                String courtByAppellor = ccn.getCourtByAppellor();
+                if (courtByAppellor!=null&&!courtByAppellor.equals("")){
+                    courtByAppellor = courtByAppellor.replaceAll(regEx,aa);
+                }
+                sqls.add("insert into COURTANNOUNCEMENT (CA_ID,CA_CUID,CA_DETNO,CA_APPELLANT,CA_RESPONDENT,CA_TYPE,CA_PUBLICPERSON,CA_DATE,CA_DETAIL) values " +
+                        "(COURTANNOUNCEMENT_SEQ.NEXTVAL," + cuId + "," + detno + ",'" +courtAppellor+ "','" +courtByAppellor+
+                        "','"+ccn.getCourtNoticeType()+"','"+ccn.getCourtNoticePerson()+"',"+courtPublishDate+",'"+ccn.getCourtContent()+
+                        "')");
+                detno = detno + 1;
+            }
+        }
+        return sqls;
+    }
+    //从表9  被执行人   EXECUTEEINFO
+    private List<String> get9Sqls(String type,int cuId,List<CompanyLawByExecutePersonInfoFinRest> companyLawByExecutePersonInfoList){
+        List<String> sqls = new ArrayList<>();
+        if (companyLawByExecutePersonInfoList!=null && companyLawByExecutePersonInfoList.size()>0) {
+            if (type.equals("UPDATE")) {
+                sqls.add("delete from EXECUTEEINFO where EX_CUID = " + cuId);
+            }
+            int detno = 1;
+            for (CompanyLawByExecutePersonInfoFinRest ce:companyLawByExecutePersonInfoList) {
+                String registerDate = ce.getByRegisterDate();
+                if (registerDate!=null){
+                    registerDate="to_date('"+registerDate+"','yyyy-MM-dd')";
+                }
+                sqls.add("insert into EXECUTEEINFO (EX_ID,EX_CUID,EX_DETNO,EX_CASENO,EX_CASEDATE,EX_COURT,EX_STANDARD,EX_EXECUTOR,EX_IDCARD) values " +
+                        "(EXECUTEEINFO_SEQ.NEXTVAL," + cuId + "," + detno + ",'" + ce.getByCaseNumber()+ "'," +registerDate+
+                        ",'"+ce.getByExecuteCourt()+"','"+ce.getByExecuteObject()+"','"+ce.getByExecutePerson()+"','"+ce.getByIdNumber()+"')");
+                detno = detno + 1;
+            }
+        }
+        return sqls;
+    }
+    //从表8  失信被执行人 DISHONESTEXE
+    private List<String> get8Sqls(String type,int cuId,String laBreakFaithExPer){
+        List<String> sqls = new ArrayList<>();
+        JSONArray laBreakFaithExPerList = JSONArray.parseArray(laBreakFaithExPer);
+        if(laBreakFaithExPerList!=null && laBreakFaithExPerList.size()>0){
+            if(type.equals("UPDATE")) {
+                sqls.add("delete from DISHONESTEXE where DX_CUID = " + cuId);
+            }
+            List<Map<String,String>> listObjectFir = (List<Map<String,String>>) JSONArray.parse(laBreakFaithExPer);
+            int detno = 1;
+            for(Map<String,String> map : listObjectFir){
+                sqls.add("insert into DISHONESTEXE (DX_ID ,DX_CUID ,DX_DETNO ,DX_CASENO ,DX_PUBLICDATE ,DX_COURT ," +
+                "DX_CASEDATE ,DX_PROVINCE ,DX_SUBJECTEDEXECUT ,DX_DISHONESTEXECUTOR ,DX_LEGALINSTRU) values " +
+                "(DISHONESTEXE_SEQ.NEXTVAL,"+cuId+","+detno+")");
+                detno = detno+1;
+            }
+        }
+
+        return sqls;
+    }
     //主表 CUSTOMERINFOR SQL
     private List<String> getMainSqls(String type,int cuId,String cuCode,Map<String, Object> enMap,GetEnterpriseExtensionInfoResp entExtInfoResp) throws Exception{
         ArrayList<String> sqls = new ArrayList<>();
@@ -89,7 +660,7 @@ public class CustInfomationTask extends AbstractTask{
         //企业简介 员工人数 CompanyIndustryAndCommerceInfoRest.CompanyLawInfoFinRest enIntro insuredNumberOfPeople
         CompanyLawInfoFinRest compLawInfoRest = entCrawLFRest.getCompanyLawInfo();
         String cu_term = ((compBaseInfoByErmRest.getEnOpDate()==null || compBaseInfoByErmRest.getEnOpDate().equals(""))? "null" : (compBaseInfoByErmRest.getEnOpDate().contains("无固定期限")?"9999":compBaseInfoByErmRest.getEnOpDate()));
-        String cu_licensedate = (compBaseInfoByErmRest.getEnRegDate()==null||compBaseInfoByErmRest.getEnRegDate().equals("")?"null":"to_date('"+compBaseInfoByErmRest.getEnRegDate()+"','YYYY-MM-DD HH24:MI:SS')");
+        String cu_licensedate = (compBaseInfoByErmRest.getEnRegDate()==null||compBaseInfoByErmRest.getEnRegDate().equals("")?"null":"to_date('"+compBaseInfoByErmRest.getEnRegDate()+"','YYYY-MM-DD')");
         String cu_regcapital = (compBaseInfoByErmRest.getEnRegCapital() ==null || compBaseInfoByErmRest.getEnRegCapital().equals("") ? "null":compBaseInfoByErmRest.getEnRegCapital().replace("万元人民币",""));
         String cu_paidincapital =(compIndusAndCommInforRest.getContributedCapital() ==null ||compIndusAndCommInforRest.getContributedCapital().equals("") ? "null" : compIndusAndCommInforRest.getContributedCapital().replace("万元人民币",""));
         String cu_employeesnum = (compIndusAndCommInforRest.getInsuredNumberOfPeople() == null || compIndusAndCommInforRest.getInsuredNumberOfPeople().equals("") ? "null":compIndusAndCommInforRest.getInsuredNumberOfPeople());
@@ -99,8 +670,8 @@ public class CustInfomationTask extends AbstractTask{
                     "CU_TAXCREDIT,CU_REGISTSTATUS,CU_BUSINSSCOPE,CU_BUSINESSMAIN," +
                     "CU_CONTACT,CU_CONTACTNUM,CU_REGCAPITAL,CU_PAIDINCAPITAL," +
                     "CU_REGADD,CU_OFFICEADD,CU_INTRODUCTION,CU_EMPLOYEESNUM,cu_zjuu" +
-                    ") VALUES ("+cuId+",'"+cuCode+"',"+compBaseInfoByErmRest.getEnuu()+",'在录入','ENTERING',SYSDATE,'"+compBaseInfoByErmRest.getEnName()+"','"+compBaseInfoByErmRest.getEnLegalRepName()+"',"
-                    +cu_term+","+"'"+compBaseInfoByErmRest.getEnType()+"','"+restBaseInfo.getGrade()+"'," +cu_licensedate+",'"+compBaseInfoByErmRest.getEnCodeCrawled()+"',"+
+                    ") VALUES ("+cuId+",'"+cuCode+"',"+compBaseInfoByErmRest.getEnuu()+",'在录入','ENTERING',SYSDATE,'"+compBaseInfoByErmRest.getEnName()+"','"+compBaseInfoByErmRest.getEnLegalRepName()+"','"
+                    +cu_term+"',"+"'"+compBaseInfoByErmRest.getEnType()+"','"+restBaseInfo.getGrade()+"'," +cu_licensedate+",'"+compBaseInfoByErmRest.getEnCodeCrawled()+"',"+
                     "'"+entCrawLFRest.getConTheTaxCredit()+"','"+compBaseInfoByErmRest.getEnRegStatus()+"','"+compBaseInfoByErmRest.getEnOpRange()+"','"+restBaseInfo.getEnBusinessMain()+"',"+
                     "'"+restBaseInfo.getFsContactsMan()+"','"+restBaseInfo.getFsContactsPhone()+"',"+cu_regcapital+","+cu_paidincapital+",'"
                     +compBaseInfoByErmRest.getEnRegLocation()+"','"+restBaseInfo.getEnAddress()+"','"+compLawInfoRest.getEnIntro()+"',"+cu_employeesnum+",'10050877')");
@@ -110,7 +681,7 @@ public class CustInfomationTask extends AbstractTask{
             sqls.add("UPDATE CUSTOMERINFOR SET " +
                     " CU_STATUS='在录入',CU_STATUSCODE='ENTERING'," +
                     " CU_UPDATEDATE=SYSDATE,CU_NAME='"+compBaseInfoByErmRest.getEnName()+"',CU_LEGALPERSON='"+compBaseInfoByErmRest.getEnLegalRepName()+"'," +
-                    " CU_TERM = "+cu_term+",CU_ENTERPTYPE ='"+compBaseInfoByErmRest.getEnType()+"',CU_PLAFORMLEVEL='"+restBaseInfo.getGrade()+"'," +
+                    " CU_TERM = '"+cu_term+"',CU_ENTERPTYPE ='"+compBaseInfoByErmRest.getEnType()+"',CU_PLAFORMLEVEL='"+restBaseInfo.getGrade()+"'," +
                     " CU_LICENSEDATE = "+cu_licensedate+",CU_PAPERSCODE='"+compBaseInfoByErmRest.getEnCodeCrawled()+"'," +
                     " CU_TAXCREDIT ='"+entCrawLFRest.getConTheTaxCredit()+"',CU_REGISTSTATUS='"+compBaseInfoByErmRest.getEnRegStatus()+"',CU_BUSINSSCOPE='"+compBaseInfoByErmRest.getEnOpRange()+"',CU_BUSINESSMAIN='"+restBaseInfo.getEnBusinessMain()+"'," +
                     " CU_CONTACT='"+restBaseInfo.getFsContactsMan()+"',CU_CONTACTNUM='"+restBaseInfo.getFsContactsPhone()+"',CU_REGCAPITAL="+cu_regcapital+",CU_PAIDINCAPITAL="+cu_paidincapital+"," +
@@ -133,17 +704,15 @@ public class CustInfomationTask extends AbstractTask{
         //System.out.println("更新高管信息:"+enKeyPersonnel);
         JSONArray enKeyPerList = JSONArray.parseArray(enKeyPersonnel);
         if(enKeyPerList!=null && enKeyPerList.size()>0){
+            if(type.equals("UPDATE")) {
+                sqls.add("delete from CUSTOMEREXCUTIVE where CE_CUID = " + cuId);
+            }
             for(int ei = 0;ei < enKeyPerList.size();ei++){
                 JSONObject ek = enKeyPerList.getJSONObject(ei);
                 Set<Map.Entry<String, Object>> ekKeySet = ek.entrySet();
                 if(ekKeySet!= null && ekKeySet.size()>0){
                     for(Map.Entry<String, Object> ekMap : ekKeySet){
-                        sqls.add("MERGE INTO CUSTOMEREXCUTIVE INCUSTOMEREXCUTIVE " +
-                                " USING (SELECT NVL(MAX(CE_ID),0) CE_ID FROM CUSTOMEREXCUTIVE WHERE CE_CUID = "+cuId+" AND CE_NAME = '"+ekMap.getKey()+"' AND CE_POSITION ='"+ekMap.getValue()+"') " +
-                                " ONINCUSTOMEREXCUTIVE " +
-                                " ON (INCUSTOMEREXCUTIVE.CE_ID = ONINCUSTOMEREXCUTIVE.CE_ID) " +
-                                " WHEN NOT MATCHED THEN " +
-                                " INSERT (INCUSTOMEREXCUTIVE.CE_ID,INCUSTOMEREXCUTIVE.CE_CUID,INCUSTOMEREXCUTIVE.CE_DETNO,INCUSTOMEREXCUTIVE.CE_NAME,INCUSTOMEREXCUTIVE.CE_POSITION) " +
+                        sqls.add("INSERT into CUSTOMEREXCUTIVE (CE_ID,CE_CUID,CE_DETNO,CE_NAME,CE_POSITION) " +
                                 " VALUES(CUSTOMEREXCUTIVE_seq.nextval,"+cuId+",9999,'"+ekMap.getKey()+"','"+ekMap.getValue()+"')");
                     }
                 }
@@ -170,18 +739,16 @@ public class CustInfomationTask extends AbstractTask{
         //System.out.println("更新股东信息:"+compBaseInfoByErmRest.getEnShareholders());
         JSONArray enShareholdersList = JSONArray.parseArray(enShareholders_Str);
         if(enShareholdersList!=null && enShareholdersList.size()>0) {
+            if(type.equals("UPDATE")) {
+                sqls.add("delete from CUSTOMERSHAREHOLDER where CE_CUID = " + cuId);
+            }
             for (int i = 0; i < enShareholdersList.size(); i++) {
                 JSONObject enShareholders = enShareholdersList.getJSONObject(i);
                 Object cs_payableamount = ((enShareholders.get("认缴出资额(万元)")  == null || enShareholders.get("认缴出资额(万元)").equals("-")) ? "null" : enShareholders.get("认缴出资额(万元)") );
                 Object cs_investratio =	(enShareholders.getString("持股比例") == null ? 0 :enShareholders.getString("持股比例").replace("%",""));
-                Object cs_investdate = (enShareholders.getDate("认缴出资日期") == null ? "null" :"to_date('"+ new SimpleDateFormat("yyyy-MM-dd").format(enShareholders.getDate("认缴出资日期"))+"','yyyy-mm-dd')");
-                sqls.add("MERGE INTO CUSTOMERSHAREHOLDER INHOLDER " +
-                        " USING (SELECT NVL(MAX(CS_ID),0) CS_ID FROM CUSTOMERSHAREHOLDER WHERE CS_CUID = "+cuId+" AND CS_NAME = '"+enShareholders.get("股东")+"') ONHOLDER " +
-                        " ON (INHOLDER.CS_ID = ONHOLDER.CS_ID) " +
-                        " WHEN MATCHED THEN " +
-                        " UPDATE SET CS_DETNO = 9999, INHOLDER.CS_PAYABLEAMOUNT="+cs_payableamount+",INHOLDER.CS_INVESTRATIO="+cs_investratio+",INHOLDER.CS_INVESTDATE="+cs_investdate+" " +
-                        " WHEN NOT MATCHED THEN " +
-                        " INSERT (INHOLDER.CS_ID,INHOLDER.CS_CUID,INHOLDER.CS_DETNO,INHOLDER.CS_NAME,INHOLDER.CS_PAYABLEAMOUNT,INHOLDER.CS_INVESTRATIO,INHOLDER.CS_INVESTDATE) " +
+                Object cs_investdate = (enShareholders.getDate("认缴出资日期") == null ? "''" :"to_date('"+ new SimpleDateFormat("yyyy-MM-dd").format(enShareholders.getDate("认缴出资日期"))+"','yyyy-mm-dd')");
+                sqls.add("INSERT into CUSTOMERSHAREHOLDER (CS_ID,CS_CUID,CS_DETNO,CS_NAME,INHOLDER" +
+                        ".CS_PAYABLEAMOUNT,CS_INVESTRATIO,CS_INVESTDATE) " +
                         " VALUES(CUSTOMERSHAREHOLDER_SEQ.NEXTVAL,"+cuId+",9999,'"+enShareholders.get("股东")+"',"+cs_payableamount+","+cs_investratio+","+cs_investdate+")");
             }
             sqls.add("UPDATE CUSTOMERSHAREHOLDER SET CS_DETNO = (select RN from (SELECT ROWNUM RN,CS_ID FROM " +
@@ -220,7 +787,7 @@ public class CustInfomationTask extends AbstractTask{
             if(enChangingRecordList!=null && enChangingRecordList.size()>0) {
                 int detno = 1;
                 if(type.equals("UPDATE")){
-                    sqls.add("DELETE FSCHANGESINSTRUCTION WHERE CS_CUID = "+cuId);
+                    sqls.add("DELETE from FSCHANGESINSTRUCTION WHERE CS_CUID = "+cuId);
                 }
                 for (int i = 0; i < enChangingRecordList.size(); i++) {
                     JSONObject enChangingRecord = enChangingRecordList.getJSONObject(i);
@@ -282,7 +849,7 @@ public class CustInfomationTask extends AbstractTask{
         List<String> sqls = new ArrayList<>();
         int detno = 1;
         if(type.equals("UPDATE")){
-            sqls.add("DELETE CUSTOMERFINANCIAL WHERE CF_CUID = "+cuId);
+            sqls.add("DELETE from CUSTOMERFINANCIAL WHERE CF_CUID = "+cuId);
         }
         List<Map<String,Object>> inMsgList = new ArrayList<>();
         Calendar date = Calendar.getInstance();
@@ -595,7 +1162,7 @@ public class CustInfomationTask extends AbstractTask{
     private List<String> getSixSqls(String type,int cuId,ErpDataInfoRest erpDataInfoRest) throws Exception{
         List<String> sqls = new ArrayList<>();
         if(type.equals("UPDATE")){
-            sqls.add("DELETE MANAGEMENTINFO WHERE MT_CUID = "+cuId);
+            sqls.add("DELETE from MANAGEMENTINFO WHERE MT_CUID = "+cuId);
         }
         Calendar date = Calendar.getInstance();
         int year = Integer.valueOf(String.valueOf(date.get(Calendar.YEAR)));
@@ -650,7 +1217,7 @@ public class CustInfomationTask extends AbstractTask{
     private List<String> getSevenSqls(String type,int cuId,ErpDataInfoRest erpDataInfoRest){
         List<String> sqls = new ArrayList<>();
         if(type.equals("UPDATE")){
-            sqls.add("DELETE UPDOWNINFO WHERE UI_CUID = "+cuId);
+            sqls.add("DELETE from UPDOWNINFO WHERE UI_CUID = "+cuId);
         }
         Calendar date = Calendar.getInstance();
         int year = Integer.valueOf(String.valueOf(date.get(Calendar.YEAR)));
@@ -727,4 +1294,22 @@ public class CustInfomationTask extends AbstractTask{
         }
         return sqls;
     }
+
+
+    /**
+     * 客户信息下载
+     * @param enUUList
+     * @throws Exception
+     */
+    public void getEntityInfomation(List<Map<String, Object>> enUUList) throws Exception {
+        List<String> sqls = new ArrayList<>();
+        for(Map<String, Object> enMap : enUUList) {
+            int custUU = Integer.valueOf(enMap.get("CQ_CUSTUU").toString());//融资方UU--客户
+            //客户基本信息 CompanyBasicInfosByErmRest
+            GetEnterpriseExtensionInfoReq.Builder req = GetEnterpriseExtensionInfoReq.newBuilder();
+            req.setEnuu(10042875);
+            GetEnterpriseExtensionInfoResp resp = tradingHallSdk.getEnterpriseExtensionInfo(req);
+            System.out.println(ProtoBufUtil.toJSON(resp));
+        }
+    }
 }

src/test/java/com/uas/erp/test/ConnectToFinanceTest.java

@@ -8,6 +8,7 @@ import com.uas.erp.schedular.entity.Master;
 import com.uas.erp.schedular.finance.domain.*;
 import com.uas.erp.schedular.finance.task.AbstractTask;
 import com.uas.erp.schedular.finance.task.B2BInformation;
+import com.uas.erp.schedular.finance.task.CustInfomationTask;
 import com.uas.erp.schedular.util.ContextHolder;
 import com.usoft.fin.external.open.api.entity.OpenCapitalSideLoanOther;
 import com.usoft.fin.external.open.api.entity.OpenCapitalSideRepaymentPlanOther;
@@ -37,11 +38,14 @@ import java.util.Map;
  * <p>
  * Created by hejq on 2017-12-22.
  */
-//@RunWith(SpringJUnit4ClassRunner.class)
-//@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.NONE, classes = UasSchedulingApplication.class)
+@RunWith(SpringJUnit4ClassRunner.class)
+@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.NONE, classes = UasSchedulingApplication.class)
 public class ConnectToFinanceTest extends AbstractTask {
     @Autowired
     private B2BInformation b2BInformation;
+
+    @Autowired
+    private CustInfomationTask custInfomationTask;
     /**
      * 测试地址
      */
@@ -73,7 +77,7 @@ public class ConnectToFinanceTest extends AbstractTask {
         ContextHolder.setMaster(master);
         b2BInformation.getOfferQuotaInfoList();
     }
-   // @Test
+    @Test
     //客户资料下载
     public void testGetCustInfomation() throws Exception  {
         Master master = new Master();
@@ -89,9 +93,9 @@ public class ConnectToFinanceTest extends AbstractTask {
 //        jdbcTemplate.execute("UPDATE CUSTOMERQUOTA SET " +
 //                "CQ_CUSTCODE = (SELECT MAX(CU_CODE) FROM CUSTOMERINFOR WHERE CU_STATUSCODE <> 'DISABLE' AND CQ_FACTORUU = NVL(CU_ENUU,0) ) " +
 //                "where CQ_CUSTCODE is null and CQ_FACTORUU in (SELECT NVL(CU_ENUU,0) FROM CUSTOMERINFOR WHERE CU_STATUSCODE <> 'DISABLE') ");
-        Object[] cuUUList = jdbcTemplate.queryForArray("SELECT CQ_CUSTUU FROM CUSTOMERQUOTA WHERE CQ_CUSTUU > 0 " +
-                "AND CQ_CUSTUU NOT IN (SELECT NVL(CU_ENUU,0) FROM CUSTOMERINFOR where CU_STATUSCODE <> 'DISABLE') group by CQ_CUSTUU");
-//        if (cuUUList!=null &&cuUUList.length>0){
+        /*Object[] cuUUList = jdbcTemplate.queryForArray("SELECT CQ_CUSTUU FROM CUSTOMERQUOTA WHERE CQ_CUSTUU > 0 " +
+              "AND CQ_CUSTUU NOT IN (SELECT NVL(CU_ENUU,0) FROM CUSTOMERINFOR where CU_STATUSCODE <> 'DISABLE') group by CQ_CUSTUU");
+ */ //        if (cuUUList!=null &&cuUUList.length>0){
 //            for(Object cuUU : cuUUList){
 //                enMap = new HashMap<>();
 //                enMap.put("CQ_FACTORUU",10042875);//深圳市优软商城科技有限公司
@@ -105,8 +109,9 @@ public class ConnectToFinanceTest extends AbstractTask {
         enMap.put("CQ_RECORDERUU",0);//用户UU
         enMap.put("CQ_CUSTUU",10005285);//客户信息 深圳市吉利通电子有限公司
         enMap.put("CQ_CUSTUU",10042875);//客户信息 深圳市优软商城科技有限公司
+        enMap.put("CQ_CUSTUU",10000666);
         enUUList.add(enMap);
-        b2BInformation.getCustInfomation(enUUList);
+        custInfomationTask.getCustInfomation(enUUList);
 //        10042875	深圳市优软商城科技有限公司
 //        10000666	深圳市华商龙商务互联科技有限公司
 //        10041961	深圳市英唐智能控制股份有限公司