修改根据客户名称判断添加还是更新

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

@@ -118,6 +118,7 @@ public class B2BInformation  extends AbstractTask{
 				enMap.put("CQ_CUSTUU", rest.getOfferQuoteInfo().getFsEnuu());
 				enMap.put("CQ_FACTORUU", rest.getOfferQuoteInfo().getCsEnuu());
 				enMap.put("CQ_RECORDERUU", rest.getOfferQuoteInfo().getApplyUu());
+				enMap.put("CQ_CUSTNAME",rest.getOfferQuoteInfo().getFsEnName());
 				if (!enUUList.contains(enMap)) {
 					enUUList.add(enMap);
 				}

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

@@ -31,6 +31,7 @@ public class CustInfomationTask extends AbstractTask{
         List<String> sqls = new ArrayList<>();
         for(Map<String, Object> enMap : enUUList){
             int custUU = Integer.valueOf(enMap.get("CQ_CUSTUU").toString());//融资方UU--客户
+            Object cq_custname = enMap.get("CQ_CUSTNAME");
             //客户基本信息 CompanyBasicInfosByErmRest
             GetEnterpriseExtensionInfoReq.Builder entExtReq = GetEnterpriseExtensionInfoReq.newBuilder();
             entExtReq.setEnuu(custUU);  //正式   测试 entExtReq.setEnuu(10046945);
@@ -39,107 +40,110 @@ public class CustInfomationTask extends AbstractTask{
             if(compBaseInfoByErmRest.getEnName()==null||compBaseInfoByErmRest.getEnName().equals("")){
                 break;
             }
-            int cuId = jdbcTemplate.getInt("SELECT NVL(MAX(CU_ID),0) FROM CUSTOMERINFOR WHERE CU_ENUU = ? ", custUU);
-            //System.out.println("cuId:"+cuId);
-            String type = "UPDATE";
-            String cuCode = compBaseInfoByErmRest.getCode();
-            if(cuId == 0){
-                type = "INSERT";
-                cuId = jdbcTemplate.generate("CUSTOMERINFOR_SEQ");
-                cuCode = (compBaseInfoByErmRest.getCode() ==null || compBaseInfoByErmRest.getCode().equals("") )? jdbcTemplate.generateCode("Customer!Infor", 2):compBaseInfoByErmRest.getCode();
-            }
-            //主表 客户资料
-            sqls.addAll(getMainSqls(type,cuId,cuCode,enMap,entExtInfoResp));
-            //从表1 高管信息 CUSTOMEREXCUTIVE
-            sqls.addAll(getOneSqls(type,cuId,compBaseInfoByErmRest.getEnKeyPersonnel()));
-            //从表2 股东信息 CUSTOMERSHAREHOLDER
-            sqls.addAll(getTwoSqls(type,cuId,compBaseInfoByErmRest.getEnShareholders()));
-            //TODO 从表3 主要关联企业 CUSTOMERUDSTREAM 暂未提供
-            //sqls.addAll(getThreeSqls(type,cuId));
-            //从表4 变更说明 FSCHANGESINSTRUCTION
-            sqls.addAll(getFourSqls(type,cuId,compBaseInfoByErmRest.getEnChangingRecords()));
-            //从表5 客户财务报表 CUSTOMERFINANCIAL
-            sqls.addAll(getFiveSqls(type,cuId,entExtInfoResp.getErpDataInfo()));
-            //从表6 经营信息 MANAGEMENTINFO ErpPurchaseInfo ErpSaleInfo 
-            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
+            if (cq_custname!=null){
+                int cuId = jdbcTemplate.getInt("SELECT NVL(MAX(CU_ID),0) FROM CUSTOMERINFOR WHERE CU_NAME = ? ",
+                        cq_custname.toString());
+                //System.out.println("cuId:"+cuId);
+                String type = "UPDATE";
+                String cuCode = compBaseInfoByErmRest.getCode();
+                if(cuId == 0){
+                    type = "INSERT";
+                    cuId = jdbcTemplate.generate("CUSTOMERINFOR_SEQ");
+                    cuCode = (compBaseInfoByErmRest.getCode() ==null || compBaseInfoByErmRest.getCode().equals("") )? jdbcTemplate.generateCode("Customer!Infor", 2):compBaseInfoByErmRest.getCode();
+                }
+                //主表 客户资料
+                sqls.addAll(getMainSqls(type,cuId,cuCode,enMap,entExtInfoResp));
+                //从表1 高管信息 CUSTOMEREXCUTIVE
+                sqls.addAll(getOneSqls(type,cuId,compBaseInfoByErmRest.getEnKeyPersonnel()));
+                //从表2 股东信息 CUSTOMERSHAREHOLDER
+                sqls.addAll(getTwoSqls(type,cuId,compBaseInfoByErmRest.getEnShareholders()));
+                // 从表3 主要关联企业 CUSTOMERUDSTREAM 暂未提供
+                //sqls.addAll(getThreeSqls(type,cuId));
+                //从表4 变更说明 FSCHANGESINSTRUCTION
+                sqls.addAll(getFourSqls(type,cuId,compBaseInfoByErmRest.getEnChangingRecords()));
+                //从表5 客户财务报表 CUSTOMERFINANCIAL
+                sqls.addAll(getFiveSqls(type,cuId,entExtInfoResp.getErpDataInfo()));
+                //从表6 经营信息 MANAGEMENTINFO ErpPurchaseInfo ErpSaleInfo
+                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));
+                //从表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);