From 1c1236d437b3d7d517e1f5e9bb7be1c57a60810d Mon Sep 17 00:00:00 2001 From: tangfutang Date: Wed, 27 May 2020 14:47:30 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AE=A2=E6=88=B7=EF=BC=88=E5=BC=A0=E7=A3=8A?= =?UTF-8?q?=EF=BC=89=E6=9B=B4=E6=96=B0=E9=B9=8F=E5=85=83=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../query_report/pengyuandata.jsp | 4 +- .../V20200521/customer(zhanglei)_20200521.sql | 204 +++++++++ .../com/tenwa/httpclient/PyPafUtils.java | 393 ++++++++++++++++++ .../controller/BigDataController.java | 282 +------------ 4 files changed, 601 insertions(+), 282 deletions(-) create mode 100644 src_tenwa/com/tenwa/httpclient/PyPafUtils.java diff --git a/WebContent/Tenwa/Lease/Flow/Comm/BigdataPengyuan/query_report/pengyuandata.jsp b/WebContent/Tenwa/Lease/Flow/Comm/BigdataPengyuan/query_report/pengyuandata.jsp index 5f44127f0..38bf92690 100644 --- a/WebContent/Tenwa/Lease/Flow/Comm/BigdataPengyuan/query_report/pengyuandata.jsp +++ b/WebContent/Tenwa/Lease/Flow/Comm/BigdataPengyuan/query_report/pengyuandata.jsp @@ -63,12 +63,12 @@ // String resultals =bdc.getCustomerInfoPerson(flowunid, Sqlca); // if(!"false".equals(resultals)){ // String[] sReturn = resultals.split("@"); - params.put("queryType","25212"); + params.put("queryType","25136"); params.put("name",CurPage.getParameter("fullName")); params.put("documentNo",CurPage.getParameter("fullcertId")); params.put("phone",CurPage.getParameter("fullphone")); params.put("queryReasonID","101"); - params.put("subreportIDs","96040"); + params.put("subreportIDs","96100"); params.put("refID",""); // } FileInputStream fr = null; diff --git a/src_sql/投产SQL/V20200521/customer(zhanglei)_20200521.sql b/src_sql/投产SQL/V20200521/customer(zhanglei)_20200521.sql index 9997a3821..6ae2572ca 100644 --- a/src_sql/投产SQL/V20200521/customer(zhanglei)_20200521.sql +++ b/src_sql/投产SQL/V20200521/customer(zhanglei)_20200521.sql @@ -115,3 +115,207 @@ INSERT INTO `bf_templatelable` (`ID`, `LABLEID`, `TEMPLATEID`, `INPUTUSERID`, `I VALUES ('fbb7a95f12ad41f490781b7acbf65079', '870f11068af6485d8ae0b2a859da3811', '7acb675c671b4f92ab8b45d26e477055', NULL, NULL, NULL, NULL, NULL, NULL); + +-- ÐÞ¸ÄÅôÔª½Ó¿Ú +drop table if exists bigdata_py_paf_personjudicialriskinfoitem; +CREATE TABLE `bigdata_py_paf_personjudicialriskinfoitem` ( + `id` varchar(32) NOT NULL COMMENT 'id', + `applyid` varchar(32) NOT NULL COMMENT 'ÇëÇóid', + `batno` varchar(32) DEFAULT NULL COMMENT '²éѯÅú´ÎºÅ', + `reportid` varchar(32) DEFAULT NULL COMMENT '±¨¸æ±àºÅ', + `timeperiod` varchar(32) DEFAULT NULL COMMENT 'ͳ¼Æʱ¼ä¶Î£º1-½ü1Äê¡¢2-½ü2Äê¡¢3-½ü5Äê¡¢4-ÀúÊ·', + `civilcasecount` varchar(32) DEFAULT NULL COMMENT 'ÃñÊ°¸¼þ±»¸æ·çÏÕʼþÊýÁ¿', + `criminalcasecount` varchar(32) DEFAULT NULL COMMENT 'ÐÌÊ°¸¼þ±»¸æ·çÏÕʼþÊýÁ¿', + `judicialcount` varchar(32) DEFAULT NULL COMMENT '˾·¨±»Ö´ÐÐÈË·çÏÕʼþÊýÁ¿', + `endcasecount` varchar(32) DEFAULT NULL COMMENT 'ÖÕ±¾°¸¼þ·çÏÕʼþÊýÁ¿', + `breakfaithcount` varchar(32) DEFAULT NULL COMMENT 'ʧÐű»Ö´ÐÐÈË·çÏÕʼþÊýÁ¿', + `judicialtotalcount` varchar(32) DEFAULT NULL COMMENT '£¨Ë¾·¨ÉæËß·çÏÕʼþ£©ºÏ¼Æ', + `taxpunishcount` varchar(32) DEFAULT NULL COMMENT 'Ë°Îñ´¦·£Ê¼þÊýÁ¿', + `marketpunishcount` varchar(32) DEFAULT NULL COMMENT 'Êг¡¼à¹Ü´¦·£Ê¼þÊýÁ¿', + `customspunishcount` varchar(32) DEFAULT NULL COMMENT 'º£¹Ø´¦·£Ê¼þÊýÁ¿', + `environmentpunishcount` varchar(32) DEFAULT NULL COMMENT '»·±£´¦·£Ê¼þÊýÁ¿', + `otherpunishcount` varchar(32) DEFAULT NULL COMMENT 'ÆäËûÐÐÕþ´¦·£Ê¼þÊýÁ¿', + `punishtotalcount` varchar(32) DEFAULT NULL COMMENT '£¨ÐÐÕþ´¦·£Ê¼þ£©ºÏ¼Æ', + PRIMARY KEY (`id`) +) ENGINE=InnoDB DEFAULT CHARSET=gbk; + + +drop table if exists bigdata_py_paf_personjudicialriskinfo; +CREATE TABLE `bigdata_py_paf_personjudicialriskinfo` ( + `id` varchar(32) NOT NULL COMMENT 'id', + `applyid` varchar(32) NOT NULL COMMENT 'ÇëÇóid', + `batno` varchar(32) DEFAULT NULL COMMENT '²éѯÅú´ÎºÅ', + `reportid` varchar(32) DEFAULT NULL COMMENT '±¨¸æ±àºÅ', + `subreporttype` varchar(32) DEFAULT NULL COMMENT '14277', + `subreporttypecost` varchar(32) DEFAULT NULL COMMENT '96100', + `treatresult` varchar(32) DEFAULT NULL COMMENT '×Ó±¨¸æ²éѯ״̬,1£º²éµÃ£¬2£ºÎ´²éµÃ£¬3£ºÆäËûÔ­Òòδ²éµÃ', + `treaterrorcode` varchar(32) DEFAULT NULL COMMENT 'treatResult=3ʱµÄ´íÎó´úÂë,Ïê¼ûÊý¾Ý×Öµä,treatResult!=3ʱ,¸ÃÊôÐÔ²»´æÔÚ', + `errormessage` varchar(255) DEFAULT NULL COMMENT 'treatResult=3ʱµÄ´íÎóÃèÊöÐÅÏ¢,treatResult!=3ʱ,¸ÃÊôÐÔµÄֵΪ¿Õ', + PRIMARY KEY (`id`) +) ENGINE=InnoDB DEFAULT CHARSET=gbk; + +drop table if exists bigdata_py_paf_personriskrosterinfo; +CREATE TABLE `bigdata_py_paf_personriskrosterinfo` ( + `id` varchar(32) NOT NULL COMMENT 'id', + `applyid` varchar(32) NOT NULL COMMENT 'ÇëÇóid', + `batno` varchar(32) DEFAULT NULL COMMENT '²éѯÅú´ÎºÅ', + `reportid` varchar(32) DEFAULT NULL COMMENT '±¨¸æ±àºÅ', + `subreporttype` varchar(32) DEFAULT NULL COMMENT '14277', + `subreporttypecost` varchar(32) DEFAULT NULL COMMENT '96100', + `treatresult` varchar(32) DEFAULT NULL COMMENT '×Ó±¨¸æ²éѯ״̬,1£º²éµÃ£¬2£ºÎ´²éµÃ£¬3£ºÆäËûÔ­Òòδ²éµÃ', + `treaterrorcode` varchar(32) DEFAULT NULL COMMENT 'treatResult=3ʱµÄ´íÎó´úÂë,Ïê¼ûÊý¾Ý×Öµä,treatResult!=3ʱ,¸ÃÊôÐÔ²»´æÔÚ', + `errormessage` varchar(32) DEFAULT NULL COMMENT 'treatResult=3ʱµÄ´íÎóÃèÊöÐÅÏ¢,treatResult!=3ʱ,¸ÃÊôÐÔµÄֵΪ¿Õ', + `risktypes` varchar(255) DEFAULT NULL COMMENT 'ÃüÖзçÏÕÀàÐÍ£¬¶à¸ö·çÏÕÀàÐÍÒÔÓ¢ÎĶººÅ¸ô¿ª£¨treatresultΪ3ʱ¿ÉÄÜûÓиýڵ㣨²»´æÔÚtreatresultΪ2µÄÇé¿ö£©£©', + PRIMARY KEY (`id`) +) ENGINE=InnoDB DEFAULT CHARSET=gbk; + +drop table if exists bigdata_py_paf_mobilestatusinfoitem; +CREATE TABLE `bigdata_py_paf_mobilestatusinfoitem` ( + `id` varchar(32) NOT NULL COMMENT 'id', + `applyid` varchar(32) NOT NULL COMMENT 'ÇëÇóid', + `batno` varchar(32) DEFAULT NULL COMMENT '²éѯÅú´ÎºÅ', + `reportid` varchar(32) DEFAULT NULL COMMENT '±¨¸æ±àºÅ', + `phonestatus` varchar(32) DEFAULT NULL COMMENT 'ÊÖ»ú״̬ 1£ºÕý³£ÔÚÓà 2: Í£»ú 3£ºÎ´ÆôÓà 4£ºÒÑÏúºÅ 6£ºÔ¤ÏúºÅ¸ÃÖµ¿ÉÄÜΪ¿Õ', + `timelength` varchar(32) DEFAULT NULL COMMENT 'ÊÖ»úºÅÂëÔÚÍøʱ³¤ 1£º²»×ã3¸öÔ 2£º3-6¸öÔ 3£º6-12¸öÔ 4£º12-24¸öÔ 5£º24¸öÔÂ', + `operator` varchar(32) DEFAULT NULL COMMENT 'ÔËÓªÉÌ 1£ºÖйúµçÐÅ 2£ºÖйúÒƶ¯ 3:ÖйúÁªÍ¨', + `areainfo` varchar(32) DEFAULT NULL COMMENT 'ÊÖ»úºÅÂë¹éÊôµØ', + PRIMARY KEY (`id`) +) ENGINE=InnoDB DEFAULT CHARSET=gbk; + + +drop table if exists bigdata_py_paf_mobilestatusinfo; +CREATE TABLE `bigdata_py_paf_mobilestatusinfo` ( + `id` varchar(32) NOT NULL COMMENT 'id', + `applyid` varchar(32) NOT NULL COMMENT 'ÇëÇóid', + `batno` varchar(32) DEFAULT NULL COMMENT '²éѯÅú´ÎºÅ', + `reportid` varchar(32) DEFAULT NULL COMMENT '±¨¸æ±àºÅ', + `subreporttype` varchar(32) DEFAULT NULL COMMENT '14277', + `subreporttypecost` varchar(32) DEFAULT NULL COMMENT '96100', + `treatresult` varchar(32) DEFAULT NULL COMMENT '×Ó±¨¸æ²éѯ״̬,1£º²éµÃ£¬2£ºÎ´²éµÃ£¬3£ºÆäËûÔ­Òòδ²éµÃ', + `treaterrorcode` varchar(32) DEFAULT NULL COMMENT 'treatResult=3ʱµÄ´íÎó´úÂë,Ïê¼ûÊý¾Ý×Öµä,treatResult!=3ʱ,¸ÃÊôÐÔ²»´æÔÚ', + `errormessage` varchar(255) DEFAULT NULL COMMENT 'treatResult=3ʱµÄ´íÎóÃèÊöÐÅÏ¢,treatResult!=3ʱ,¸ÃÊôÐÔµÄֵΪ¿Õ', + PRIMARY KEY (`id`) +) ENGINE=InnoDB DEFAULT CHARSET=gbk; + +drop table if exists bigdata_py_paf_mobilecheckinfoitem; +CREATE TABLE `bigdata_py_paf_mobilecheckinfoitem` ( + `id` varchar(32) NOT NULL COMMENT 'id', + `applyid` varchar(32) NOT NULL COMMENT 'ÇëÇóid', + `batno` varchar(32) DEFAULT NULL COMMENT '²éѯÅú´ÎºÅ', + `reportid` varchar(32) DEFAULT NULL COMMENT '±¨¸æ±àºÅ', + `checkresult` varchar(32) DEFAULT NULL COMMENT 'ÊÖ»úºÅÂëºË²é½á¹û,ÓÐ:Ò»Ö¡¢²»Ò»ÖÂ', + `operator` varchar(32) DEFAULT NULL COMMENT 'ÔËÓªÉÌ 1£ºÖйúµçÐÅ 2£ºÖйúÒƶ¯ 3:ÖйúÁªÍ¨', + `areainfo` varchar(32) DEFAULT NULL COMMENT 'ÊÖ»úºÅÂë¹éÊôµØ', + PRIMARY KEY (`id`) +) ENGINE=InnoDB DEFAULT CHARSET=gbk; + +drop table if exists bigdata_py_paf_mobilecheckinfo; +CREATE TABLE `bigdata_py_paf_mobilecheckinfo` ( + `id` varchar(32) NOT NULL COMMENT 'id', + `applyid` varchar(32) NOT NULL COMMENT 'ÇëÇóid', + `batno` varchar(32) DEFAULT NULL COMMENT '²éѯÅú´ÎºÅ', + `reportid` varchar(32) DEFAULT NULL COMMENT '±¨¸æ±àºÅ', + `subreporttype` varchar(32) DEFAULT NULL COMMENT '14277', + `subreporttypecost` varchar(32) DEFAULT NULL COMMENT '96100', + `treatresult` varchar(32) DEFAULT NULL COMMENT '×Ó±¨¸æ²éѯ״̬,1£º²éµÃ£¬2£ºÎ´²éµÃ£¬3£ºÆäËûÔ­Òòδ²éµÃ', + `treaterrorcode` varchar(32) DEFAULT NULL COMMENT 'treatResult=3ʱµÄ´íÎó´úÂë,Ïê¼ûÊý¾Ý×Öµä,treatResult!=3ʱ,¸ÃÊôÐÔ²»´æÔÚ', + `errormessage` varchar(255) DEFAULT NULL COMMENT 'treatResult=3ʱµÄ´íÎóÃèÊöÐÅÏ¢,treatResult!=3ʱ,¸ÃÊôÐÔµÄֵΪ¿Õ', + PRIMARY KEY (`id`) +) ENGINE=InnoDB DEFAULT CHARSET=gbk; + + +drop table if exists bigdata_py_paf_policecheckinfoitem; +CREATE TABLE `bigdata_py_paf_policecheckinfoitem` ( + `id` varchar(32) NOT NULL COMMENT 'id', + `applyid` varchar(32) NOT NULL COMMENT 'ÇëÇóid', + `batno` varchar(32) DEFAULT NULL COMMENT '²éѯÅú´ÎºÅ', + `reportid` varchar(32) DEFAULT NULL COMMENT '±¨¸æ±àºÅ', + `name` varchar(32) DEFAULT NULL COMMENT '±»²éѯÕßÐÕÃû', + `documentno` varchar(32) DEFAULT NULL COMMENT '±»²éѯÕßÖ¤¼þºÅÂë', + `result` varchar(32) DEFAULT NULL COMMENT 'Éí·ÝÈÏÖ¤½á¹û£¬1£¬Ò»Ö 2,²»Ò»ÖÂ', + PRIMARY KEY (`id`) +) ENGINE=InnoDB DEFAULT CHARSET=gbk; + +drop table if exists bigdata_py_paf_policecheckinfo; +CREATE TABLE `bigdata_py_paf_policecheckinfo` ( + `id` varchar(32) NOT NULL COMMENT 'id', + `applyid` varchar(32) NOT NULL COMMENT 'ÇëÇóid', + `batno` varchar(32) DEFAULT NULL COMMENT '²éѯÅú´ÎºÅ', + `reportid` varchar(32) DEFAULT NULL COMMENT '±¨¸æ±àºÅ', + `subreporttype` varchar(32) DEFAULT NULL COMMENT '14277', + `subreporttypecost` varchar(32) DEFAULT NULL COMMENT '96100', + `treatresult` varchar(32) DEFAULT NULL COMMENT '×Ó±¨¸æ²éѯ״̬,1£º²éµÃ£¬2£ºÎ´²éµÃ£¬3£ºÆäËûÔ­Òòδ²éµÃ', + `treaterrorcode` varchar(32) DEFAULT NULL COMMENT 'treatResult=3ʱµÄ´íÎó´úÂë,Ïê¼ûÊý¾Ý×Öµä,treatResult!=3ʱ,¸ÃÊôÐÔ²»´æÔÚ', + `errormessage` varchar(32) DEFAULT NULL COMMENT 'treatResult=3ʱµÄ´íÎóÃèÊöÐÅÏ¢,treatResult!=3ʱ,¸ÃÊôÐÔµÄֵΪ¿Õ', + PRIMARY KEY (`id`) +) ENGINE=InnoDB DEFAULT CHARSET=gbk; + +drop table if exists bigdata_py_paf_personbaseinfo; +CREATE TABLE `bigdata_py_paf_personbaseinfo` ( + `id` varchar(32) NOT NULL COMMENT 'id', + `applyid` varchar(32) NOT NULL COMMENT 'ÇëÇóid', + `batno` varchar(32) DEFAULT NULL COMMENT '²éѯÅú´ÎºÅ', + `reportid` varchar(32) DEFAULT NULL COMMENT '±¨¸æ±àºÅ', + `subreporttype` varchar(32) DEFAULT NULL COMMENT '14277', + `subreporttypecost` varchar(32) DEFAULT NULL COMMENT '96100', + `treatresult` varchar(32) DEFAULT NULL COMMENT '×Ó±¨¸æ²éѯ״̬,1£º²éµÃ£¬2£ºÎ´²éµÃ£¬3£ºÆäËûÔ­Òòδ²éµÃ', + `treaterrorcode` varchar(32) DEFAULT NULL COMMENT 'treatResult=3ʱµÄ´íÎó´úÂë,Ïê¼ûÊý¾Ý×Öµä,treatResult!=3ʱ,¸ÃÊôÐÔ²»´æÔÚ', + `errormessage` varchar(255) DEFAULT NULL COMMENT 'treatResult=3ʱµÄ´íÎóÃèÊöÐÅÏ¢,treatResult!=3ʱ,¸ÃÊôÐÔµÄֵΪ¿Õ', + `name` varchar(32) DEFAULT NULL COMMENT 'ÐÕÃû', + `docno` varchar(32) DEFAULT NULL COMMENT 'Ö¤¼þºÅÂë', + `birthday` varchar(32) DEFAULT NULL COMMENT '³öÉúÈÕÆÚ', + `genderid` varchar(32) DEFAULT NULL COMMENT 'ÐÔ±ðID,1:ÄÐ 2:Å® 3:²»Ïê', + `age` varchar(32) DEFAULT NULL COMMENT 'ÄêÁä', + `originaladdress` varchar(255) DEFAULT NULL COMMENT 'µØÖ·', + `verifyresult` varchar(255) DEFAULT NULL COMMENT 'УÑé½á¹û', + PRIMARY KEY (`id`) +) ENGINE=InnoDB DEFAULT CHARSET=gbk; + +drop table if exists bigdata_py_paf_personantifraudscoreinfo; +CREATE TABLE `bigdata_py_paf_personantifraudscoreinfo` ( + `id` varchar(32) NOT NULL COMMENT 'id', + `applyid` varchar(32) NOT NULL COMMENT 'ÇëÇóid', + `batno` varchar(32) DEFAULT NULL COMMENT '²éѯÅú´ÎºÅ', + `reportid` varchar(32) DEFAULT NULL COMMENT '±¨¸æ±àºÅ', + `subreporttype` varchar(32) DEFAULT NULL COMMENT '14277', + `subreporttypecost` varchar(32) DEFAULT NULL COMMENT '96100', + `treatresult` varchar(32) DEFAULT NULL COMMENT '×Ó±¨¸æ²éѯ״̬,1£º²éµÃ£¬2£ºÎ´²éµÃ£¬3£ºÆäËûÔ­Òòδ²éµÃ', + `treaterrorcode` varchar(32) DEFAULT NULL COMMENT 'treatResult=3ʱµÄ´íÎó´úÂë,Ïê¼ûÊý¾Ý×Öµä,treatResult!=3ʱ,¸ÃÊôÐÔ²»´æÔÚ', + `errormessage` varchar(32) DEFAULT NULL COMMENT 'treatResult=3ʱµÄ´íÎóÃèÊöÐÅÏ¢,treatResult!=3ʱ,¸ÃÊôÐÔµÄֵΪ¿Õ', + `riskscore` varchar(32) DEFAULT NULL COMMENT '·çÏÕÖ¸Êý£¬È¡Öµ·¶Î§[0-1000]', + `risklevel` varchar(32) DEFAULT NULL COMMENT '·çÏյȼ¶£ºµÍ·çÏÕ¡¢ÖзçÏÕ¡¢¸ß·çÏÕ', + `hittypes` varchar(255) DEFAULT NULL COMMENT '·çÏÕ±êÇ©£ºÉí·ÝÈÏÖ¤²»Ò»Ö¡¢ÊÖ»úÈÏÖ¤²»Ò»ÖÂ/ÒÉËÆÐéÄâÊÖ»úºÅ¡¢ÊÖ»úºÅÂë״̬Òì³£/ÒÉËÆÒì³£ÊÖ»úºÅ¡¢ÊÖ»úÈëÍøʱ³¤½Ï¶Ì¡¢ÃüÖзçÏÕÃûµ¥¡¢Ë¾·¨·çÏÕ¸ß/ÖÐ/µÍ¡¢Î´¼ì²âµ½·çÏÕÐÅÏ¢£¬¿ÉÄÜΪ1¸ö»ò¶à¸ö£¬¶à¸ö·çÏÕ±êÇ©ÒÔÓ¢ÎĶººÅ¸ô¿ª', + PRIMARY KEY (`id`) +) ENGINE=InnoDB DEFAULT CHARSET=gbk; + +drop table if exists bigdata_py_paf_personantifrauddescinfo; +CREATE TABLE `bigdata_py_paf_personantifrauddescinfo` ( + `id` varchar(32) NOT NULL COMMENT 'id', + `applyid` varchar(32) NOT NULL COMMENT 'ÇëÇóid', + `batno` varchar(32) DEFAULT NULL COMMENT '²éѯÅú´ÎºÅ', + `reportid` varchar(32) DEFAULT NULL COMMENT '±¨¸æ±àºÅ', + `subreporttype` varchar(32) DEFAULT NULL COMMENT '14277', + `subreporttypecost` varchar(32) DEFAULT NULL COMMENT '96100', + `treatresult` varchar(32) DEFAULT NULL COMMENT '×Ó±¨¸æ²éѯ״̬,1£º²éµÃ£¬2£ºÎ´²éµÃ£¬3£ºÆäËûÔ­Òòδ²éµÃ', + `treaterrorcode` varchar(32) DEFAULT NULL COMMENT 'treatResult=3ʱµÄ´íÎó´úÂë,Ïê¼ûÊý¾Ý×Öµä,treatResult!=3ʱ,¸ÃÊôÐÔ²»´æÔÚ', + `errormessage` varchar(255) DEFAULT NULL COMMENT 'treatResult=3ʱµÄ´íÎóÃèÊöÐÅÏ¢,treatResult!=3ʱ,¸ÃÊôÐÔµÄֵΪ¿Õ', + `antifraudscore` varchar(32) DEFAULT NULL COMMENT 'ÆÛÕ©·çÏÕÖ¸Êý£¬È¡Öµ·¶Î§[0-1000]£¬¿ÉÄÜΪ¿Õ', + `antifraudscorerisklevel` varchar(32) DEFAULT NULL COMMENT 'ÆÛÕ©·çÏÕÖ¸Êý·çÏյȼ¶£ºµÍ·çÏÕ¡¢ÖзçÏÕ¡¢¸ß·çÏÕ£¬¿ÉÄÜΪ¿Õ', + `policecheckrisklevel` varchar(32) DEFAULT NULL COMMENT 'Éí·ÝÈÏÖ¤½á¹û·çÏյȼ¶£ºµÍ·çÏÕ¡¢ÖзçÏÕ¡¢¸ß·çÏÕ£¬¿ÉÄÜΪ¿Õ', + `policecheckdesc` varchar(255) DEFAULT NULL COMMENT 'Éí·ÝÈÏÖ¤½á¹ûÃèÊö£¬¿ÉÄÜΪ¿Õ', + `mobilecheckrisklevel` varchar(32) DEFAULT NULL COMMENT 'ÊÖ»úºÅÂëºË²é½á¹û·çÏյȼ¶£ºµÍ·çÏÕ¡¢ÖзçÏÕ¡¢¸ß·çÏÕ£¬¿ÉÄÜΪ¿Õ', + `mobilecheckdesc` varchar(255) DEFAULT NULL COMMENT 'ÊÖ»úºÅÂëºË²é½á¹ûÃèÊö£¬¿ÉÄÜΪ¿Õ', + `mobilestatusrisklevel` varchar(32) DEFAULT NULL COMMENT 'ÊÖ»úºÅÂë״̬¼°ÔÚÍøʱ³¤½á¹û·çÏյȼ¶£ºµÍ·çÏÕ¡¢ÖзçÏÕ¡¢¸ß·çÏÕ£¬¿ÉÄÜΪ¿Õ', + `mobilestatusdesc` varchar(255) DEFAULT NULL COMMENT 'ÊÖ»úºÅÂë״̬¼°ÔÚÍøʱ³¤½á¹ûÃèÊö£¬¿ÉÄÜΪ¿Õ', + `riskrosterrisklevel` varchar(32) DEFAULT NULL COMMENT '·çÏÕÃûµ¥½á¹û·çÏյȼ¶£ºµÍ·çÏÕ¡¢ÖзçÏÕ¡¢¸ß·çÏÕ£¬¿ÉÄÜΪ¿Õ', + `riskrosterdesc` varchar(255) DEFAULT NULL COMMENT '·çÏÕÃûµ¥½á¹ûÃèÊö£¬¿ÉÄÜΪ¿Õ', + `judicialrisklevel` varchar(32) DEFAULT NULL COMMENT '˾·¨·çÏÕ½á¹û·çÏյȼ¶£ºµÍ·çÏÕ¡¢ÖзçÏÕ¡¢¸ß·çÏÕ£¬¿ÉÄÜΪ¿Õ', + `judicialriskdesc` varchar(255) DEFAULT NULL COMMENT '˾·¨·çÏÕ½á¹ûÃèÊö£¬¿ÉÄÜΪ¿Õ', + PRIMARY KEY (`id`) +) ENGINE=InnoDB DEFAULT CHARSET=gbk; + + + + + + diff --git a/src_tenwa/com/tenwa/httpclient/PyPafUtils.java b/src_tenwa/com/tenwa/httpclient/PyPafUtils.java new file mode 100644 index 000000000..55086426e --- /dev/null +++ b/src_tenwa/com/tenwa/httpclient/PyPafUtils.java @@ -0,0 +1,393 @@ +package com.tenwa.httpclient; + +import com.alibaba.fastjson.JSONObject; +import com.amarsoft.are.ARE; +import com.amarsoft.are.log.Log; +import org.apache.commons.collections.CollectionUtils; +import org.dom4j.Element; +import org.dom4j.tree.DefaultAttribute; +import java.sql.Statement; +import java.util.*; + +/** + * ÅôÔª¸öÈË·¢ÆÛÕ©Êý¾Ý´æ´¢sql´¦ÀíÉú³É + */ +public class PyPafUtils { + + private static Log logger= ARE.getLog(); + + private static String[] personAntiFraudDescInfo = { + "id", + "applyid", + "batNo", + "reportID", + "subReportType", + "subReportTypeCost", + "treatResult", + "treatErrorCode", + "errorMessage", + "antiFraudScore", + "antiFraudScoreRiskLevel", + "policeCheckRiskLevel", + "policeCheckDesc", + "mobileCheckRiskLevel", + "mobileCheckDesc", + "mobileStatusRiskLevel", + "mobileStatusDesc", + "riskRosterRiskLevel", + "riskRosterDesc", + "judicialRiskLevel", + "judicialRiskDesc" + }; + + private static String[] personAntiFraudScoreInfo = { + "id", + "applyid", + "batno", + "reportid", + "subreporttype", + "subreporttypecost", + "treatresult", + "treaterrorcode", + "errormessage", + "riskscore", + "risklevel", + "hittypes" + }; + + private static String[] personBaseInfo = { + "id", + "applyid", + "batno", + "reportid", + "subreporttype", + "subreporttypecost", + "treatresult", + "treaterrorcode", + "errormessage", + "name", + "docno", + "birthday", + "genderid", + "age", + "originaladdress", + "verifyresult" + }; + + private static String[] policeCheckInfo = { + "id", + "applyid", + "batno", + "reportid", + "subreporttype", + "subreporttypecost", + "treatresult", + "treaterrorcode", + "errormessage" + }; + + private static String[] policeCheckInfoItem = { + "id", + "applyid", + "batno", + "reportid", + "name", + "documentno", + "result" + }; + + private static String[] mobileCheckInfo = { + "id", + "applyid", + "batno", + "reportid", + "subreporttype", + "subreporttypecost", + "treatresult", + "treaterrorcode", + "errormessage" + }; + + private static String[] mobileCheckInfoItem = { + "id", + "applyid", + "batno", + "reportid", + "checkresult", + "operator", + "areainfo" + }; + + private static String[] mobileStatusInfo = { + "id", + "applyid", + "batno", + "reportid", + "subreporttype", + "subreporttypecost", + "treatresult", + "treaterrorcode", + "errormessage" + }; + + private static String[] mobileStatusInfoItem = { + "id", + "applyid", + "batno", + "reportid", + "phonestatus", + "timelength", + "operator", + "areainfo" + }; + + private static String[] personRiskRosterInfo = { + "id", + "applyid", + "batno", + "reportid", + "subreporttype", + "subreporttypecost", + "treatresult", + "treaterrorcode", + "errormessage", + "riskTypes" + }; + + private static String[] personJudicialRiskInfo = { + "id", + "applyid", + "batno", + "reportid", + "subreporttype", + "subreporttypecost", + "treatresult", + "treaterrorcode", + "errormessage" + }; + + private static String[] personJudicialRiskInfoItem = { + "id", + "applyid", + "batno", + "reportid", + "timeperiod", + "civilcasecount", + "criminalcasecount", + "judicialcount", + "endcasecount", + "breakfaithcount", + "judicialtotalcount", + "taxpunishcount", + "marketpunishcount", + "customspunishcount", + "environmentpunishcount", + "otherpunishcount", + "punishtotalcount" + }; + + /** + * Êý¾Ý¿â±íÃûºÍÁÐ×ֶζÔÓ¦¹Øϵ + */ + public enum PersonalAntiFraudDataEnum{ + pafdi("personAntiFraudDescInfo", personAntiFraudDescInfo, "1", "¸öÈË·´ÆÛÕ©·çÏÕ×ÛÊöÐÅÏ¢"), + pafsi("personAntiFraudScoreInfo", personAntiFraudScoreInfo, "1", "ÆÛÕ©·çÏÕÖ¸ÊýÐÅÏ¢"), + pbi("personBaseInfo", personBaseInfo, "1", "Ö¤¼þºÅÂëУÑéÐÅÏ¢"), + pci("policeCheckInfo", policeCheckInfo, "1", "Éí·ÝÈÏÖ¤"), + pcii("policeCheckInfoItem", policeCheckInfoItem, "2", "Éí·ÝÈÏÖ¤item"), + mci("mobileCheckInfo", mobileCheckInfo, "1", "ÊÖ»úºÅÂëºË²é"), + mcii("mobileCheckInfoItem", mobileCheckInfoItem, "2", "ÊÖ»úºÅÂëºË²éitem"), + msi("mobileStatusInfo", mobileStatusInfo, "1", "ÊÖ»úºÅÂë״̬ºÍÔÚÍøʱ³¤"), + msii("mobileStatusInfoItem", mobileStatusInfoItem, "2", "ÊÖ»úºÅÂë״̬ºÍÔÚÍøʱ³¤item"), + prri("personRiskRosterInfo", personRiskRosterInfo, "1", "·çÏÕÃûµ¥ÐÅÏ¢"), + pjri("personJudicialRiskInfo", personJudicialRiskInfo, "1", "˾·¨·çÏÕ»ã×ÜÐÅÏ¢"), + pjrii("personJudicialRiskInfoItem", personJudicialRiskInfoItem, "2", "˾·¨·çÏÕ»ã×ÜÐÅÏ¢item"); + + private String code; //ÀàÐÍ + private String[] value; // ¶ÔÓ¦¹Øϵ + private String type; //ÀàÐÍ + private String desc; //ÃèÊö + + private PersonalAntiFraudDataEnum(String code, String[] value, String type, String desc){ + this.code=code; + this.value=value; + this.type=type; + this.desc=desc; + } + + public String[] getValue() { + return this.value; + } + + public String getType() { + return type; + } + + public String getDesc() { + return desc; + } + + public String getCode() { + return this.code; + } + + /** + * »ñÈ¡Ö÷±í + * @return + */ + public static List getDataList(){ + List list = new ArrayList<>(); + for(PersonalAntiFraudDataEnum data : PersonalAntiFraudDataEnum.values()){ + if("1".equals(data.getType())){ + list.add(data); + } + } + return list; + } + + /** + * ¸ù¾Ýcode Êý¾Ý¿â±íÃûµÄÁÐ×ֶΠ+ * @param code + * @return + */ + public static String[] getValueData(String code){ + for(PersonalAntiFraudDataEnum data : PersonalAntiFraudDataEnum.values()){ + if(data.getCode().toLowerCase().equals(code.toLowerCase())){ + return data.getValue(); + } + } + return null; + } + } + + /** + * ±£´æ¸öÈË·´ÆÛÕ©Êý¾Ý + * @param + * @param + * @return + */ + public static void savePafData(String applyId, String batNo, String reportID, + Statement stat, Element cisReport){ + try{ + List personalAntiFraudDataEnumList = PersonalAntiFraudDataEnum.getDataList(); + if(CollectionUtils.isNotEmpty(personalAntiFraudDataEnumList)) { + for (PersonalAntiFraudDataEnum personalAntiFraudDataEnum : personalAntiFraudDataEnumList) { + insertPafData(personalAntiFraudDataEnum.getCode(), applyId, batNo, reportID, stat, cisReport); + } + } + }catch (Exception e){ + e.printStackTrace(); + } + } + + /** + * ¸ù¾Ý±íÃûºÍÁÐÃû³õʼ»¯sql + * @param tableName + * @param + * @return + */ + public static void insertPafData(String tableName, String applyId, String batNo, String reportID, + Statement stat, Element cisReport){ + try{ + //±éÀú¼¯ºÏ-×é×°²ÎÊý + Element element = cisReport.element(tableName); + JSONObject obj = initObj(applyId, batNo, reportID); + List praAttributes = element.attributes(); + if(CollectionUtils.isNotEmpty(praAttributes)) { + for (DefaultAttribute praAttribute : praAttributes) { + obj.put(praAttribute.getName(), praAttribute.getStringValue().trim());//ÊÕ¼¯Ö÷²Î + } + } + List listElements = element.elements(); + //itemµ¥¶À±£´æ£¬Ôݲ»´¦ÀíitemÖÐÊý¾Ý + List listSonElements = new ArrayList<>(); + if(CollectionUtils.isNotEmpty(listElements)){ + for(Element fieldElement : listElements){ + if("item".equals(fieldElement.getName())) { + listSonElements.add(fieldElement);//ÊÕ¼¯item + }else { + obj.put(fieldElement.getName(), fieldElement.getStringValue().trim());//ÊÕ¼¯Ö÷²Î + } + } + } + //±£´æÖ÷²ÎÊý¾Ýµ½±í + excuteSql(tableName, obj, stat); + //´¦ÀíitemÊý¾Ý + if(CollectionUtils.isNotEmpty(listSonElements)){ + //itemÊý¾ÝÐè¸ü¸Ä±íÃû + tableName = tableName + "item"; + //³õʼ»¯obj²ÎÊý + obj = initObj(applyId, batNo, reportID); + for(Element fieldSonElement : listSonElements){ + List listFieldGraElements = fieldSonElement.elements(); + if(CollectionUtils.isNotEmpty(listFieldGraElements)){ + for(Element fieldGraElement : listFieldGraElements){ + obj.put(fieldGraElement.getName(), fieldGraElement.getStringValue().trim()); + } + //±£´æitemÊý¾Ýµ½±í + excuteSql(tableName, obj, stat); + //³õʼ»¯obj²ÎÊý + obj = initObj(applyId, batNo, reportID); + } + } + } + }catch (Exception e){ + e.printStackTrace(); + } + } + + /** + * obj³õʼ»¯ + * @param applyId + * @param batNo + * @param reportID + */ + private static JSONObject initObj(String applyId, String batNo, String reportID){ + JSONObject obj = new JSONObject(); + String id = UUID.randomUUID().toString().replace("-", ""); + obj.put("id", id); + obj.put("applyId", applyId); + obj.put("batNo", batNo); + obj.put("reportID", reportID); + return obj; + } + + + /** + * ÕûÀísql²¢±£´æ + * @param tableName ±íÃû + * @param obj ²ÎÊý + * @param stat jdbcͨµÀ + */ + private static void excuteSql(String tableName, JSONObject obj, Statement stat){ + try{ + logger.info("insertPafData#excuteSql Ìí¼ÓÒ»Ìõ¼Ç¼£º" + tableName.toLowerCase()); + String keys = ""; + String values = ""; + String sql = "INSERT INTO bigdata_py_paf_" + tableName.toLowerCase() + "({keys}) VALUES({values})"; + String[] keysSqlArr = PersonalAntiFraudDataEnum.getValueData(tableName); + if(null == keysSqlArr){ + logger.warn("insertPafData#excuteSql µ±Ç°Êý¾Ý¿â±íµÄÁÐ×ֶζÔÓ¦¹ØϵδÅäÖãº" + tableName.toLowerCase()); + return; + } + String[] valueArr = new String[keysSqlArr.length]; + //Ìî³äÊý×éµÄÿ¸öÏîΪµ¥ÒýºÅ + Arrays.fill(valueArr, "''"); + Set keySet = obj.keySet(); + for(int i = 0; i < keysSqlArr.length; i++){ + for(String key : keySet){ + if(keysSqlArr[i].toLowerCase().equals(key.toLowerCase())){ + valueArr[i] = "'" + obj.getString(key) + "'"; + } + } + } + keys = Arrays.toString(keysSqlArr).replace("[", "").replace("]", ""); + values = Arrays.toString(valueArr).replace("[", "").replace("]", ""); + sql = sql.replaceAll("\\{keys\\}", keys).replaceAll("\\{values\\}", values); + logger.info("insertPafData#excuteSql Ìí¼ÓÒ»Ìõ¼Ç¼£º[·â×°sql]£º" + sql); + stat.execute(sql); + }catch (Exception e){ + e.printStackTrace(); + } + } +} diff --git a/src_tenwa/com/tenwa/httpclient/controller/BigDataController.java b/src_tenwa/com/tenwa/httpclient/controller/BigDataController.java index 07db76ceb..5236a8515 100644 --- a/src_tenwa/com/tenwa/httpclient/controller/BigDataController.java +++ b/src_tenwa/com/tenwa/httpclient/controller/BigDataController.java @@ -14,6 +14,7 @@ import java.util.Map.Entry; import java.util.Set; import java.util.regex.Pattern; +import com.tenwa.httpclient.PyPafUtils; import org.dom4j.Document; import org.dom4j.Element; import org.dom4j.io.SAXReader; @@ -327,286 +328,7 @@ public class BigDataController { } } else if("pengyuan_af".equals(type)){//¸öÈË·´ÆÛÕ© - //Éí·ÝÈÏÖ¤ÐÅÏ¢ - JSONArray array = new JSONArray(); - JSONObject object = new JSONObject(); - object.put("type", "tables"); - object.put("subTable", array); - List fieldList = new ArrayList(); - JSONObject subTable1 = new JSONObject(); - subTable1 = new JSONObject(); - subTable1.put("name", "item"); - subTable1.put("type", "table"); - subTable1.put("tableName", "bigdata_py_certid_info"); - fieldList.add("name"); - fieldList.add("documentNo"); - fieldList.add("result"); - subTable1.put("field", fieldList); - array.add(subTable1); - savePengyuanResultData(object, cisReport, "policeCheckInfo", stat, otherFields, dateFields, stringFields); - //ÊÖ»úºÅÂëºË²é½á¹û - object.clear(); - array.clear(); - object.put("type", "tables"); - object.put("subTable", array); - fieldList.clear(); - subTable1 = new JSONObject(); - subTable1.put("name", "item"); - subTable1.put("type", "table"); - subTable1.put("tableName", "bigdata_py_phone_info"); - fieldList.add("areaInfo"); - fieldList.add("documentNoCheckResult"); - fieldList.add("nameCheckResult"); - fieldList.add("operator"); - fieldList.add("phoneCheckResult"); - subTable1.put("field", fieldList); - array.add(subTable1); - savePengyuanResultData(object, cisReport, "mobileCheckInfo", stat, otherFields, dateFields, stringFields); - - //¸öÈË·´ÆÛÕ©·çÏÕ×ÛÊöÐÅÏ¢ - object.clear(); - object.put("type", "table"); - object.put("tableName", "bigdata_py_pe_an_sp_de_info"); - fieldList.clear(); - fieldList.add("personAntiSpoofingDesc"); - object.put("field", fieldList); - savePengyuanResultData(object, cisReport, "personAntiSpoofingDescInfo", stat, otherFields, dateFields, stringFields); - - //¸öÈË·´ÆÛÕ©·çÏÕÆÀ·ÖÐÅÏ¢ - object.clear(); - object.put("type", "table"); - object.put("tableName", "bigdata_py_pe_an_sp_info"); - fieldList.clear(); - fieldList.add("riskScore"); - fieldList.add("riskLevel"); - fieldList.add("suggest"); - fieldList.add("hitTypes"); - object.put("field", fieldList); - savePengyuanResultData(object, cisReport, "personAntiSpoofingInfo", stat, otherFields, dateFields, stringFields); - - //ÊÖ»úºÅÂëÐÅÏ¢ - object.clear(); - array.clear(); - object.put("type", "tables"); - object.put("subTable", array); - fieldList.clear(); - subTable1 = new JSONObject(); - subTable1.put("name", "item"); - subTable1.put("type", "table"); - subTable1.put("tableName", "bigdata_py_phonestatus_info"); - fieldList.add("areaInfo"); - fieldList.add("cancelTime"); - fieldList.add("operator"); - fieldList.add("phoneStatus"); - fieldList.add("timeLength"); - subTable1.put("field", fieldList); - array.add(subTable1); - savePengyuanResultData(object, cisReport, "mobileStatusInfo", stat, otherFields, dateFields, stringFields); - - //ÊÇ·ñÃüÖи߷çÏÕÃûµ¥£¬²»ÔÚ·µ»Ø - /* object.clear(); - object.put("type", "table"); - object.put("tableName", "bigdata_py_person_risk_assess"); - fieldList.clear(); - fieldList.add("checkResult"); - fieldList.add("riskType"); - object.put("field", fieldList); - savePengyuanResultData(object, cisReport, "personRiskAssess", stat, otherFields, dateFields, stringFields); - */ - //ÊÇ·ñÃüÖÐÑòëµ³Ãûµ¥ ,²»ÔÚ·µ»Ø - /*object.clear(); - object.put("type", "table"); - object.put("tableName", "bigdata_py_ec_info"); - fieldList.clear(); - fieldList.add("state"); - object.put("field", fieldList); - savePengyuanResultData(object, cisReport, "econnoisserurInfo", stat, otherFields, dateFields, stringFields); - */ - //ÊÇ·ñÃüÖÐÆÛÕ©·çÏÕÃûµ¥£¬²»ÔÚ·µ»Ø - /*object.clear(); - object.put("type", "table"); - object.put("tableName", "bigdata_py_fraud_risk_info"); - fieldList.clear(); - fieldList.add("state"); - object.put("field", fieldList); - savePengyuanResultData(object, cisReport, "fraudRiskInfo", stat, otherFields, dateFields, stringFields); - */ - //¸öÈ˱»»ú¹¹²éѯ¸ÅÒªÐÅÏ¢ - array.clear(); - object.clear(); - object.put("type", "tables"); - object.put("subTable", array); - fieldList.clear(); - subTable1 = new JSONObject(); - subTable1.put("name", "items"); - subTable1.put("type", "arrayTable"); - subTable1.put("tableName", "bigdata_py_his_que_info"); - fieldList.add("unitMember"); - fieldList.add("last1Month"); - fieldList.add("last3Month"); - fieldList.add("last6Month"); - fieldList.add("last12Month"); - fieldList.add("last18Month"); - fieldList.add("last24Month"); - subTable1.put("field", fieldList); - - JSONObject subTable2 = new JSONObject(); - subTable2 = new JSONObject(); - subTable2.put("name", "count"); - subTable2.put("type", "table"); - subTable2.put("tableName", "bigdata_py_his_que_info_count"); - fieldList = new ArrayList(); - fieldList.add("last1Month"); - fieldList.add("last3Month"); - fieldList.add("last6Month"); - fieldList.add("last12Month"); - fieldList.add("last18Month"); - fieldList.add("last24Month"); - subTable2.put("field", fieldList); - - JSONObject subTable3 = new JSONObject(); - /*subTable3.put("name", "suspectedBulllending"); - subTable3.put("type", "table"); - subTable3.put("tableName", "bigdata_py_his_que_info_sb"); - fieldList = new ArrayList(); - fieldList.add("appplyCnt"); - fieldList.add("applyNetLoanCnt"); - fieldList.add("applyFinclCnt"); - subTable3.put("field", fieldList);*/ - - array.add(subTable1); - array.add(subTable2); -// array.add(subTable3); - //savePengyuanResultData(object, cisReport, "historySimpleQueryInfo", stat, otherFields, dateFields, stringFields); - - - //½üÈýÄêÐÅ´ûÓâÆÚÐÅÏ¢ - array.clear(); - object.clear(); - object.put("type", "tables"); - object.put("subTable", array); - fieldList.clear(); - subTable1 = new JSONObject(); - subTable1.put("name", "stat"); - subTable1.put("type", "table"); - subTable1.put("tableName", "bigdata_py_overdue_summary"); - fieldList.add("overdueAmount"); - fieldList.add("overdueDays"); - fieldList.add("overdueCount"); - subTable1.put("field", fieldList); - - subTable2 = new JSONObject(); - subTable2.put("name", "items"); - subTable2.put("type", "arrayTable"); - subTable2.put("tableName", "bigdata_py_overdue_info"); - fieldList = new ArrayList(); - fieldList.add("overdueAmount"); - fieldList.add("overdueDays"); - fieldList.add("overdueCount"); - subTable2.put("field", fieldList); - - array.add(subTable1); - array.add(subTable2); - //savePengyuanResultData(object, cisReport, "microNearlyThreeYearsOverdueInfo", stat, otherFields, dateFields, stringFields); - - //ÏÕÐÅÏ¢·ç - array.clear(); - object.clear(); - object.put("type", "tables"); - object.put("subTable", array); - fieldList.clear(); - subTable1 = new JSONObject(); - subTable1.put("name", "stat"); - subTable1.put("type", "table"); - subTable1.put("tableName", "bigdata_py_pr_stat"); - fieldList.add("totleCount"); - fieldList.add("alCount"); - fieldList.add("zxCount"); - fieldList.add("sxCount"); - fieldList.add("swCount"); - fieldList.add("cqggCount"); - fieldList.add("wdyqCount"); - subTable1.put("field", fieldList); - - subTable2 = new JSONObject(); - subTable2.put("name", "summary"); - subTable2.put("type", "tables"); - JSONArray subArray = new JSONArray(); - subTable2.put("subTable", subArray); - - subTable3 = new JSONObject(); - subTable3.put("name", "als"); - subTable3.put("type", "arrayTable"); - subTable3.put("tableName", "bigdata_py_pr_als"); - fieldList = new ArrayList(); - fieldList.add("recordId"); - fieldList.add("bt"); - fieldList.add("ajlx"); - fieldList.add("sjnf"); - fieldList.add("dsrlx"); - subTable3.put("field", fieldList); - subArray.add(subTable3); - - JSONObject subTable4 = new JSONObject(); - subTable4.put("name", "zxs"); - subTable4.put("type", "arrayTable"); - subTable4.put("tableName", "bigdata_py_pr_zxs"); - fieldList = new ArrayList(); - fieldList.add("recordId"); - fieldList.add("bt"); - fieldList.add("zxbd"); - fieldList.add("larq"); - subTable4.put("field", fieldList); - subArray.add(subTable4); - - JSONObject subTable5 = new JSONObject(); - subTable5.put("name", "sxs"); - subTable5.put("type", "arrayTable"); - subTable5.put("tableName", "bigdata_py_pr_sxs"); - fieldList = new ArrayList(); - fieldList.add("recordId"); - fieldList.add("bt"); - fieldList.add("larq"); - fieldList.add("fbrq"); - subTable5.put("field", fieldList); - subArray.add(subTable5); - - JSONObject subTable6 = new JSONObject(); - subTable6.put("name", "sws"); - subTable6.put("type", "arrayTable"); - subTable6.put("tableName", "bigdata_py_pr_sws"); - fieldList = new ArrayList(); - fieldList.add("recordId"); - fieldList.add("bt"); - fieldList.add("ggrq"); - subTable6.put("field", fieldList); - subArray.add(subTable6); - - JSONObject subTable7 = new JSONObject(); - subTable7.put("name", "cqs"); - subTable7.put("type", "arrayTable"); - subTable7.put("tableName", "bigdata_py_pr_cqs"); - fieldList = new ArrayList(); - fieldList.add("recordId"); - fieldList.add("bt"); - fieldList.add("fbrq"); - subTable7.put("field", fieldList); - subArray.add(subTable7); - - JSONObject subTable8 = new JSONObject(); - subTable8.put("name", "wdyqs"); - subTable8.put("type", "arrayTable"); - subTable8.put("tableName", "bigdata_py_pr_wdyqs"); - fieldList = new ArrayList(); - fieldList.add("recordId"); - fieldList.add("bt"); - fieldList.add("fbrq"); - subTable8.put("field", fieldList); - subArray.add(subTable8); - - array.add(subTable1); - array.add(subTable2); - savePengyuanResultData(object, cisReport, "personRiskInfo", stat, otherFields, dateFields, stringFields); + PyPafUtils.savePafData(applyId, batNo, reportID, stat, cisReport); } } } catch(Exception e) {