394 lines
13 KiB
Java
394 lines
13 KiB
Java
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<PersonalAntiFraudDataEnum> getDataList(){
|
||
List<PersonalAntiFraudDataEnum> 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<PersonalAntiFraudDataEnum> 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<DefaultAttribute> praAttributes = element.attributes();
|
||
if(CollectionUtils.isNotEmpty(praAttributes)) {
|
||
for (DefaultAttribute praAttribute : praAttributes) {
|
||
obj.put(praAttribute.getName(), praAttribute.getStringValue().trim());//收集主参
|
||
}
|
||
}
|
||
List<Element> listElements = element.elements();
|
||
//item单独保存，暂不处理item中数据
|
||
List<Element> 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<Element> 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<String> 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();
|
||
}
|
||
}
|
||
}
|