客户基础资料字符串字段解析信息增加

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

@@ -69,7 +69,7 @@ public class CustInfomationTask extends AbstractTask{
             //从表8  失信被执行人 DISHONESTEXE
             CompanyLawInfoFinRest companyLawInfo = companyEnterpriseCrawlerList.getCompanyLawInfo();
             String laBreakFaithExPer = companyLawInfo.getLaBreakFaithExPer();
-            //sqls.addAll(get8Sqls(type,cuId,laBreakFaithExPer));
+            sqls.addAll(get8Sqls(type,cuId,laBreakFaithExPer));
             //从表9  被执行人   EXECUTEEINFO
             List<CompanyLawByExecutePersonInfoFinRest> companyLawByExecutePersonInfoList =
                     companyEnterpriseCrawlerList.getCompanyLawByExecutePersonInfoList();
@@ -99,13 +99,13 @@ public class CustInfomationTask extends AbstractTask{
             sqls.addAll(get15Sqls(type,cuId,manageAbnormalIn));
             //从表16  行政处罚工商局  INDUSTRYCOMMERCE
             String administrativePenaltyIndustrial = companyManageRisk.getAdministrativePenaltyIndustrial();
-            //sqls.addAll(get16Sqls(type,cuId,administrativePenaltyIndustrial));
+            sqls.addAll(get16Sqls(type,cuId,administrativePenaltyIndustrial));
             //从表17  动产抵押   MORTGAGEINFO
             String chattelMortgage = companyManageRisk.getChattelMortgage();
-            //sqls.addAll(get17Sqls(type,cuId,chattelMortgage));
+            sqls.addAll(get17Sqls(type,cuId,chattelMortgage));
             //从表18   股权出质  EQUITYPLEDGE
             String equityPledge = companyManageRisk.getEquityPledge();
-            //sqls.addAll(get18Sqls(type,cuId,equityPledge));
+            sqls.addAll(get18Sqls(type,cuId,equityPledge));
             //从表19 股权质押   STOCKINFO
             String pledgeOfStockRight = companyManageRisk.getPledgeOfStockRight();
             //sqls.addAll(get19Sqls(type,cuId,pledgeOfStockRight));
@@ -114,22 +114,22 @@ public class CustInfomationTask extends AbstractTask{
             sqls.addAll(get20Sqls(type,cuId,serviceByPublication));
             //从表21 严重违法   ILLEGALINFORMATION
             String severityBreakTheLaw = companyManageRisk.getSeverityBreakTheLaw();
-            //sqls.addAll(get21Sqls(type,cuId,severityBreakTheLaw));
+            sqls.addAll(get21Sqls(type,cuId,severityBreakTheLaw));
             //从表22 行政处罚税务局   TAXATIONBUREAU
             String administrativePenaltyTax = companyManageRisk.getAdministrativePenaltyTax();
-            //sqls.addAll(get22Sqls(type,cuId,administrativePenaltyTax));
+            sqls.addAll(get22Sqls(type,cuId,administrativePenaltyTax));
             //从表23 行政处罚信用中国   CREDITCHINA
             String administrativePenaltyCredit = companyManageRisk.getAdministrativePenaltyCredit();
-            //sqls.addAll(get23Sqls(type,cuId,administrativePenaltyCredit));
+            sqls.addAll(get23Sqls(type,cuId,administrativePenaltyCredit));
             //从表24 环保处罚   ENVIRONMENTALINFO
             String environmentalPenalties = companyManageRisk.getEnvironmentalPenalties();
-            //sqls.addAll(get24Sqls(type,cuId,environmentalPenalties));
+            sqls.addAll(get24Sqls(type,cuId,environmentalPenalties));
             //从表25 清算信息   CLEARINFO
             String clearingInfo = companyManageRisk.getClearingInfo();
-            //sqls.addAll(get25Sqls(type,cuId,clearingInfo));
+            sqls.addAll(get25Sqls(type,cuId,clearingInfo));
             //从表26 司法拍卖   JUDICIALSALE
             String judicialSale = companyManageRisk.getJudicialSale();
-            //sqls.addAll(get26Sqls(type,cuId,judicialSale));
+            sqls.addAll(get26Sqls(type,cuId,judicialSale));
             //从表27 简易注销   SIMPLECANCE
             String simpleCancellation = companyManageRisk.getSimpleCancellation();
             //sqls.addAll(get27Sqls(type,cuId,simpleCancellation));
@@ -138,7 +138,7 @@ public class CustInfomationTask extends AbstractTask{
             //sqls.addAll(get28Sqls(type,cuId,manageRiskEnId));
             //从表29 土地抵押   MORTGAGELAND
             String landMortgage = companyManageRisk.getLandMortgage();
-            //sqls.addAll(get29Sqls(type,cuId,landMortgage));
+            sqls.addAll(get29Sqls(type,cuId,landMortgage));
 
         }
         //System.out.println("COMMONSQLS:"+sqls);
@@ -157,7 +157,7 @@ public class CustInfomationTask extends AbstractTask{
             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+")");
+                        "(MORTGAGELAND_SEQ.NEXTVAL,"+cuId+","+detno+",'"+map.get("抵押人名称")+"','"+map.get("抵押权人")+"','"+map.get("土地用途")+"','"+map.get("权属性质与使用权类型")+"','"+map.get("抵押面积（公顷）")+"','"+map.get("评估金额（万元）")+"','"+map.get("抵押金额（万元）")+"','"+map.get("登记起始日期")+"','"+map.get("结束日期")+"')");
                 detno = detno+1;
             }
         }
@@ -186,6 +186,7 @@ public class CustInfomationTask extends AbstractTask{
     //从表27 简易注销   SIMPLECANCE
     private List<String> get27Sqls(String type,int cuId,String simpleCancellation){
         List<String> sqls = new ArrayList<>();
+        System.err.println(simpleCancellation);
         JSONArray simpleCancellationList = JSONArray.parseArray(simpleCancellation);
         if(simpleCancellationList!=null && simpleCancellationList.size()>0){
             if(type.equals("UPDATE")) {
@@ -195,7 +196,8 @@ public class CustInfomationTask extends AbstractTask{
             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+")");
+                        "(SIMPLECANCE_SEQ.NEXTVAL,"+cuId+","+detno+",'"+map.get("企业名称")+"','"+map.get("统一社会信用代码")+"'," +
+                        "'"+map.get("登记机关")+"','"+map.get("公告期")+"','"+map.get("简易注销结果")+"','"+map.get("公告申请日期")+"')");
                 detno = detno+1;
             }
         }
@@ -214,7 +216,7 @@ public class CustInfomationTask extends AbstractTask{
             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+")");
+                        "(JUDICIALSALE_SEQ.NEXTVAL,"+cuId+","+detno+",'"+map.get("司法拍卖详情")+"')");
                 detno = detno+1;
             }
         }
@@ -233,7 +235,7 @@ public class CustInfomationTask extends AbstractTask{
             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+")");
+                        "(CLEARINFO_SEQ.NEXTVAL,"+cuId+","+detno+",'"+map.get("清算组负责人")+"','"+map.get("清算组成员")+"')");
                 detno = detno+1;
             }
         }
@@ -252,7 +254,8 @@ public class CustInfomationTask extends AbstractTask{
             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+")");
+                        "(ENVIRONMENTALINFO_SEQ.NEXTVAL,"+cuId+","+detno+",'"+map.get("决定书文号")+"','"+map.get("处罚事由")+
+                        "','"+map.get("违法类型")+"','"+map.get("处罚依据")+"','"+map.get("处罚结果")+"','"+map.get("处罚单位")+"','"+map.get("处罚日期")+"','"+map.get("执行情况")+"')");
                 detno = detno+1;
             }
         }
@@ -271,7 +274,9 @@ public class CustInfomationTask extends AbstractTask{
             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+")");
+                        "(CREDITCHINA_SEQ.NEXTVAL,"+cuId+","+detno+",'"+map.get("决定文书号")+"','"+map.get("处罚事由")+"','"+map.get("处罚状态")+
+                        "','"+map.get("决定日期")+"','"+map.get("处罚类型1")+"','"+map.get("处罚类型2")+"','"+map.get("处罚结果")+"'," +
+                        "'"+map.get("处罚机关")+"')");
                 detno = detno+1;
             }
         }
@@ -290,7 +295,8 @@ public class CustInfomationTask extends AbstractTask{
             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+")");
+                        "(TAXATIONBUREAU_SEQ.NEXTVAL,"+cuId+","+detno+",'"+map.get("案件名称")+"','"+map.get("决定文书号")+
+                        "','"+map.get("处罚事由")+"','"+map.get("处罚类型")+"','"+map.get("处罚状态")+"','"+map.get("处罚结果")+"','"+map.get("处罚决定日期")+"','')");
                 detno = detno+1;
             }
         }
@@ -309,7 +315,7 @@ public class CustInfomationTask extends AbstractTask{
             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+")");
+                        "(ILLEGALINFORMATION_SEQ.NEXTVAL,"+cuId+","+detno+",'"+map.get("列入日期")+"','"+map.get("作出决定机关")+"','"+map.get("列入严重违法失信企业名单原因")+"')");
                 detno = detno+1;
             }
         }
@@ -361,7 +367,8 @@ public class CustInfomationTask extends AbstractTask{
             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+")");
+                        "(STOCKINFO_SEQ.NEXTVAL,"+cuId+","+detno+",'"+map.get("股票代码")+"','"+map.get("股票简称")+"','"+map.get("质押比例")+
+                        "','"+map.get("质押股数（股）")+"','"+map.get("质押市值")+"','"+map.get("质押笔数")+"','"+map.get("无限售股质押数")+"','"+map.get("限售股质押数（股）")+"','"+map.get("一年涨跌幅")+"','"+map.get("所属行业")+"')");
                 detno = detno+1;
             }
         }
@@ -380,7 +387,8 @@ public class CustInfomationTask extends AbstractTask{
             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+")");
+                        "(EQUITYPLEDGE_SEQ.NEXTVAL,"+cuId+","+detno+",'"+map.get("登记编号")+"','"+map.get("出质人")+"','"+map.get("质权人")+
+                        "','"+map.get("出质股权标的企业")+"','"+map.get("出质股权数额(万元)")+"','"+map.get("登记日期")+"','"+map.get("状态")+"'");
                 detno = detno+1;
             }
         }
@@ -400,7 +408,9 @@ public class CustInfomationTask extends AbstractTask{
             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+")");
+                        "(MORTGAGEINFO_SEQ.NEXTVAL,"+cuId+","+detno+",'"+map.get("登记机关")+"','"+map.get("登记编号")+"','"+map.get("登记日期")+
+                        "','"+map.get("债权人履行债务的期限")+"','"+map.get("种类")+"','"+map.get("数额")+"','"+map.get("担保的范围")+
+                        "','"+map.get("抵押物名称")+"','"+map.get("所有权或使用权归属")+"','"+map.get("数量、质量、状况、所在地等情况")+"','"+map.get("备注")+"')");
                 detno = detno+1;
             }
         }
@@ -420,7 +430,7 @@ public class CustInfomationTask extends AbstractTask{
             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+")");
+                        "(INDUSTRYCOMMERCE_SEQ.NEXTVAL,"+cuId+","+detno+",'"+map.get("决定文书号")+"','"+map.get("违法行为类型")+"','"+map.get("行政处罚内容")+"','"+map.get("公示日期")+"','"+map.get("决定机关")+"','"+map.get("决定日期")+"')");
                 detno = detno+1;
             }
         }
@@ -631,7 +641,9 @@ public class CustInfomationTask extends AbstractTask{
             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+")");
+                "(DISHONESTEXE_SEQ.NEXTVAL,"+cuId+","+detno+",'"+map.get("案号")+"','"+map.get("发布日期")+"','"+map.get(
+                        "执行法院")+"','"+map.get("立案日期")+"','"+map.get("省份")+"','"+map.get("被执行人旅行的情况")+"','"+map.get(
+                                "失信被执行人行为具体情形")+"','"+map.get("生效法律文书确定的义务")+"')");
                 detno = detno+1;
             }
         }