客户信息，客户标签和目的表表结构

sql-achievement/存储过程/客户信息koucx.sql

@@ -0,0 +1,104 @@
+--初始化个人信息
+CREATE OR REPLACE PROCEDURE shanglifeecif.initIndividual() IS
+DECLARE
+indidcount INT;
+BEGIN
+	--清空数据
+	DELETE FROM shanglifeecif.individual;
+	indidcount :=1;
+	--初始化非本人身份证客户信息
+	INSERT INTO shanglifeecif.individual(
+					indid,
+					CustID,
+					scustid,
+					name,
+					gender,
+					birthday,
+					idcard,
+					Passport,
+					Dlicense,
+					CREATED_BY,
+					CREATED_TIME) 
+	SELECT row_number()over(),"CP" || lpad(row_number()over(),9,'0'),pi.CUSTOMERNO,pi.NAME,pi.SEX,to_char(pi.BIRTHDAY,'yyyy-MM-dd HH:mm:ss'),pi.idcard,pi.Passport,pi.Dlicense,'koucx',sysdate() FROM(
+		SELECT CUSTOMERNO,NAME,SEX,BIRTHDAY,
+			max(CASE IDTYPE WHEN '0' THEN IDNO ELSE null END) idcard,
+			max(CASE IDTYPE WHEN '1' THEN IDNO ELSE NULL END) Passport,
+			max(CASE IDTYPE WHEN '3' THEN IDNO ELSE NULL END) Dlicense
+			FROM shanghailifeecif.policy_information WHERE IDNO IS NOT NULL GROUP BY CUSTOMERNO,NAME,SEX,BIRTHDAY,IDTYPE,IDNO
+		UNION 
+		SELECT INSUREDNO AS CUSTOMERNO,INSUREDNAME AS NAME,INSUREDSEX AS SEX,INSUREDBIRTHDAY AS BIRTHDAY,
+			max(CASE INSUREDIDTYPE WHEN '0' THEN insuredidno ELSE null END) idcard,
+			max(CASE INSUREDIDTYPE WHEN '1' THEN insuredidno ELSE NULL END) Passport,
+			max(CASE INSUREDIDTYPE WHEN '3' THEN insuredidno ELSE NULL END) Dlicense
+		FROM shanghailifeecif.policy_information WHERE INSUREDIDNO IS NOT NULL GROUP BY INSUREDNO,INSUREDNAME,INSUREDSEX,INSUREDBIRTHDAY,INSUREDIDTYPE,insuredidno
+	) AS pi;
+	
+	/*SELECT count(*) INTO indidcount FROM shanglifeecif.individual; 
+	--初始化非本人护照客户信息
+	INSERT INTO shanglifeecif.individual(
+					indid,
+					CustID,
+					scustid,
+					name,
+					gender,
+					birthday,
+					Passport,
+					CREATED_BY,
+					CREATED_TIME) 
+	SELECT row_number()over()+indidcount+1,"CP" || lpad(row_number()over()+indidcount,9,'0'),pi.CUSTOMERNO,pi.NAME,pi.SEX,to_char(pi.BIRTHDAY,'yyyy-MM-dd HH:mm:ss'),pi.IDNO,'koucx',sysdate() FROM(
+		SELECT CUSTOMERNO,NAME,SEX,BIRTHDAY,IDTYPE,IDNO FROM shanghailifeecif.policy_information WHERE IDNO IS NOT NULL AND IDTYPE = 1 AND RELATIONTOAPPNT<>'本人' GROUP BY CUSTOMERNO,NAME,SEX,BIRTHDAY,IDTYPE,IDNO
+		UNION 
+		SELECT INSUREDNO AS CUSTOMERNO,INSUREDNAME AS NAME,INSUREDSEX AS SEX,INSUREDBIRTHDAY AS BIRTHDAY,INSUREDIDTYPE AS IDTYPE,insuredidno AS IDNO FROM shanghailifeecif.policy_information WHERE INSUREDIDNO IS NOT NULL AND INSUREDIDTYPE = 1 AND RELATIONTOAPPNT<>'本人' GROUP BY INSUREDNO,INSUREDNAME,INSUREDSEX,INSUREDBIRTHDAY,INSUREDIDTYPE,insuredidno
+	) AS pi;
+	
+	SELECT count(*) INTO indidcount FROM shanglifeecif.individual; 
+	--初始化非本人驾驶证客户信息
+	INSERT INTO shanglifeecif.individual(
+					indid,
+					CustID,
+					scustid,
+					name,
+					gender,
+					birthday,
+					Dlicense,
+					CREATED_BY,
+					CREATED_TIME) 
+	SELECT row_number()over()+indidcount+1,"CP" || lpad(row_number()over()+indidcount,9,'0'),pi.CUSTOMERNO,pi.NAME,pi.SEX,to_char(pi.BIRTHDAY,'yyyy-MM-dd HH:mm:ss'),pi.IDNO,'koucx',sysdate() FROM(
+		SELECT CUSTOMERNO,NAME,SEX,BIRTHDAY,
+			max(CASE IDTYPE WHEN '0' THEN IDNO ELSE null END) idcard,
+			max(CASE IDTYPE WHEN '1' THEN IDNO ELSE NULL END) Passport,
+			max(CASE IDTYPE WHEN '3' THEN IDNO ELSE NULL END) Dlicense
+			FROM shanghailifeecif.policy_information WHERE IDNO IS NOT NULL AND IDTYPE = 3 AND RELATIONTOAPPNT<>'本人' GROUP BY CUSTOMERNO,NAME,SEX,BIRTHDAY,IDTYPE,IDNO
+		UNION 
+		SELECT INSUREDNO AS CUSTOMERNO,INSUREDNAME AS NAME,INSUREDSEX AS SEX,INSUREDBIRTHDAY AS BIRTHDAY,INSUREDIDTYPE AS IDTYPE,insuredidno AS IDNO FROM shanghailifeecif.policy_information WHERE INSUREDIDNO IS NOT NULL AND INSUREDIDTYPE = 3 AND RELATIONTOAPPNT<>'本人' GROUP BY INSUREDNO,INSUREDNAME,INSUREDSEX,INSUREDBIRTHDAY,INSUREDIDTYPE,insuredidno
+	) AS pi;
+	
+	
+	SELECT count(*) INTO indidcount FROM shanglifeecif.individual; 
+	--初始化单独处理本人客户信息
+	INSERT INTO shanglifeecif.individual(
+					indid,
+					CustID,
+					scustid,
+					name,
+					gender,
+					birthday,
+					idcard,
+					Passport,
+					Dlicense,
+					CREATED_BY,
+					CREATED_TIME) 
+	SELECT row_number()over()+indidcount+1,"CP" || lpad(row_number()over()+indidcount,9,'0'),pi.CUSTOMERNO,pi.NAME,pi.SEX,to_char(pi.BIRTHDAY,'yyyy-MM-dd HH:mm:ss'),pi.idcard,pi.Passport,pi.Dlicense,'koucx',sysdate() FROM(
+		SELECT CUSTOMERNO,NAME,SEX,BIRTHDAY,
+		max(CASE IDTYPE WHEN '0' THEN IDNO ELSE CASE INSUREDIDTYPE WHEN '0' THEN insuredidno ELSE null END END) idcard,
+		max(CASE IDTYPE WHEN '1' THEN IDNO ELSE CASE INSUREDIDTYPE WHEN '1' THEN insuredidno ELSE NULL END END) Passport,
+		max(CASE IDTYPE WHEN '3' THEN IDNO ELSE CASE INSUREDIDTYPE WHEN '3' THEN insuredidno ELSE NULL END END) Dlicense
+		 FROM shanghailifeecif.policy_information WHERE IDNO IS NOT NULL AND RELATIONTOAPPNT ='本人' GROUP BY CUSTOMERNO,NAME,SEX,BIRTHDAY,IDTYPE,IDNO
+	) AS pi;*/
+	
+	EXCEPTION
+			WHEN HIVE_EXCEPTION THEN 
+				 INSERT INTO shanglifeecif.exception_log(log_code,log_msg,log_time) VALUES (sqlcode(),sqlerrm(),sysdate());
+			WHEN Others THEN
+				INSERT INTO shanglifeecif.exception_log(log_code,log_msg,log_time) VALUES (sqlcode(),sqlerrm(),sysdate());
+END	;

sql-achievement/存储过程/所有目的表表结构.sql

@@ -0,0 +1,945 @@
+-- 创建ES表。
+DROP TABLE IF EXISTS shanglifeecif.individual;
+CREATE TABLE shanglifeecif.Individual(
+   
+    IndID STRING  COMMENT '个体ID' ,
+    CustID STRING    COMMENT '客户号 本系统统一生成的全司范围的唯一标识' ,
+    SCustID STRING    COMMENT '上游客户号 上游系统的客户ID' ,
+    Name STRING NOT NULL   COMMENT '名称 T_CUSTOMER_CLASS.CUSTOMER_NAME' ,
+    Birthday DATE    COMMENT '出生日期 T_CUSTOMER_CLASS.BIRTHDATE' ,
+    NOBirth STRING    COMMENT '出生国家' ,
+    SOBirth STRING    COMMENT '出生省份' ,
+    COBirth STRING   COMMENT '出生城市' ,
+    Dday DATE    COMMENT '死亡日期' ,
+    Gender STRING    COMMENT '性别 GB/T 2261.1-2003规定的一位数字代码执行，前三位填充G00: G000:未知的性别; G001:男性; G002:女性 ; G009:未说明的性别 ;
+T_CUSTOMER_CLASS.GENDER
+code	codename
+0	男
+1	女' ,
+    Ethnic STRING    COMMENT '民族' ,
+    Nation STRING    COMMENT '国籍' ,
+    HomeAdress STRING    COMMENT '籍贯 UNDERWRITE_REPORT_LIST.POLICY_HOLDER_ADDRESS' ,
+    RegResidence STRING    COMMENT '户口所在地' ,
+    MaritalStat STRING    COMMENT '婚姻状况 一对多' ,
+    MaritalStatDate DATE    COMMENT '婚姻状况日期 一对多' ,
+    Offspring STRING    COMMENT '生育状况' ,
+    Support STRING   COMMENT '赡养状况' ,
+    EmpStat STRING    COMMENT '就业状况 一对多' ,
+    EmpStatDate STRING    COMMENT '就业状况日期 一对多' ,
+    RAID STRING   COMMENT '联系地址' ,
+    RAL STRING    COMMENT '联系地址不分段' ,
+    AL STRING    COMMENT '曾用地址不分段' ,
+    COAdress INT    COMMENT '地址登录数量' ,
+    PMPhone STRING    COMMENT '常用手机 正在使用的手机' ,
+    Mhone1 STRING    COMMENT '曾用手机1' ,
+    Mhone2 STRING    COMMENT '曾用手机2' ,
+    SOPhone INT    COMMENT '手机登录数量' ,
+    Height DECIMAL(8,2)    COMMENT '身高' ,
+    Weight DECIMAL(8,2)    COMMENT '体重' ,
+    CIllness STRING    COMMENT '当前疾病' ,
+    PIllness STRING    COMMENT '曾患疾病' ,
+    CDiseases STRING    COMMENT '先天性疾病' ,
+    BMI DECIMAL(8,2)    COMMENT 'BMI体制指数' ,
+    FMHistory STRING    COMMENT '家族病史' ,
+    EvaDate DATE    COMMENT '健康评估日期' ,
+    COHEvaluation INT    COMMENT '健康评估登录数量' ,
+    HPhone STRING    COMMENT '家庭电话' ,
+    OccupationId STRING    COMMENT '职业代码 UNDERWRITE_REPORT_LIST.POLICY_HOLDER_CODE' ,
+    Occupation STRING    COMMENT '职业名称 UNDERWRITE_REPORT_LIST.POLICY_HOLDER_NAME' ,
+    Odate DATE    COMMENT '职业时间 一对多' ,
+    Employer STRING    COMMENT '工作单位' ,
+    WPhone STRING    COMMENT '工作电话' ,
+    EmpDate DATE    COMMENT '工作单位时间' ,
+    LEmployer STRING    COMMENT '曾经工作单位' ,
+    IDCard STRING    COMMENT '身份证 code	codename
+0	身份证
+1	护照
+2	军人证（军官证）
+3	驾照
+4	户口本
+5	学生证
+6	工作证
+7	出生证
+8	其它
+9	无证件
+A	士兵证
+B	回乡证
+C	临时身份证
+D	警官证
+E	台胞证
+F	港、澳通行证
+I	外国人永久居留身份证
+J	港澳台居民居住证
+K	港澳居民居住证
+M	台湾居民居住证
+T_CUSTOMER_CLASS.ID_NO' ,
+    Passport STRING    COMMENT '护照' ,
+    Dlicense STRING    COMMENT '驾驶证' ,
+    Education STRING    COMMENT '最高学历' ,
+    University STRING    COMMENT '毕业学校' ,
+    Edate DATE    COMMENT '学历时间' ,
+    Wechat STRING    COMMENT '微信' ,
+    Weibo STRING    COMMENT '微博' ,
+    Email STRING    COMMENT '邮箱' ,
+    QQ STRING    COMMENT 'QQ' ,
+    Tiktok STRING    COMMENT '抖音' ,
+    SAccount1 STRING    COMMENT '社交账号1' ,
+    SA1Cat STRING    COMMENT '社交账号1类别' ,
+    SAccount2 STRING    COMMENT '社交账号2' ,
+    SA2Cat STRING    COMMENT '社交账号2类别' ,
+    CType STRING    COMMENT '首选联系方式 手机，微信，微博，邮箱，QQ，抖音，其他' ,
+    Father STRING    COMMENT '父亲 HEALTH_INSURANCE_LISTING.INSUREDNAME
+HEALTH_INSURANCE_LISTING.RELATION:投保人与被保人关系' ,
+    Mother STRING    COMMENT '母亲' ,
+    Mate STRING    COMMENT '配偶' ,
+    child1 STRING    COMMENT '子女1' ,
+    child2 STRING    COMMENT '子女2' ,
+    COChild INT    COMMENT '子女登录数量' ,
+    RPID STRING    COMMENT '房产' ,
+    RPDescribe STRING    COMMENT '房产描述' ,
+    CORP INT    COMMENT '房产登录数量' ,
+    VID STRING    COMMENT '车辆' ,
+    VDescribe STRING    COMMENT '车辆描述' ,
+    COVehicle INT    COMMENT '车辆登录数量' ,
+    Anniversary1 DATE    COMMENT '纪念日1' ,
+    A1Describe STRING    COMMENT '纪念日1类型' ,
+    Anniversary2 DATE    COMMENT '纪念日2' ,
+    A2Describe STRING    COMMENT '纪念日2类型' ,
+    SOAnniversary INT    COMMENT '纪念日登录数量' ,
+    CustType STRING    COMMENT '客户类型' ,
+    BankName STRING    COMMENT '开户银行' ,
+    TOBankCard STRING    COMMENT '银行卡类型 如：master、visa、银联等。' ,
+    AccName STRING    COMMENT '账户名' ,
+    BankAccNo STRING    COMMENT '银行帐号' ,
+    COBAccount INT    COMMENT '账户登录数量' ,
+    SOTLIRisk DECIMAL(32,8)    COMMENT '传统寿险种保额合计' ,
+    SOAIRisk DECIMAL(32,8)    COMMENT '意外类险种保额合计' ,
+    SOSIIRisk DECIMAL(32,8)    COMMENT '重疾类险种保额合计' ,
+    SOMCIRisk DECIMAL(32,8)    COMMENT '医疗费用类险种保额合计' ,
+    SOMEIRisk DECIMAL(32,8)    COMMENT '医疗补贴类险种保额合计' ,
+    SOEFIRisk DECIMAL(32,8)    COMMENT '教育金类险种保额合计' ,
+    SOPIRisk DECIMAL(32,8)    COMMENT '养老金类险种保额合计' ,
+    SOWMIRisk DECIMAL(32,8)    COMMENT '财富管理险种保额合计' ,
+    CustClass INT    COMMENT '客户等级 T_CUSTOMER_CLASS.CLASS_VALUE
+code	codename
+1	钻石
+2	白金
+3	黄金
+4	普通
+0	无' ,
+    ConValue INT    COMMENT '贡献度分' ,
+    Awarded3 INT    COMMENT '家庭加分' ,
+    Awarded2 INT    COMMENT '续期加分' ,
+    Awarded1 INT    COMMENT '保单加分' ,
+    SOValue INT    COMMENT '总分值' ,
+    EndDate DATE    COMMENT '客户等级失效日期' ,
+    SystemTag1 STRING    COMMENT '系统标签域1' ,
+    SystemTag2 STRING    COMMENT '系统标签域2' ,
+    SystemTag3 STRING    COMMENT '系统标签域3' ,
+    SystemTag4 STRING    COMMENT '系统标签域4' ,
+    SystemTag5 STRING    COMMENT '系统标签域5' ,
+    COCommunication INT    COMMENT '接触次数' ,
+    LCDate DATE    COMMENT '最近接触时间' ,
+    LCType STRING    COMMENT '最近接触类型 投诉、问询、营销' ,
+    LCMethod STRING    COMMENT '最近接触方式 外呼、呼入' ,
+    COComplaint INT    COMMENT '投诉次数 当前客户投保保单相关投诉，包括非本人投诉' ,
+    LCPTDate DATE    COMMENT '最近投诉时间 当前客户投保保单相关投诉，包括非本人投诉' ,
+    LCPTReason STRING    COMMENT '最近投诉原因 当前客户投保保单相关投诉，包括非本人投诉' ,
+    LCPTLink STRING    COMMENT '最近投诉环节 当前客户投保保单相关投诉，包括非本人投诉' ,
+    LCPTResult STRING    COMMENT '最近投诉处理结果 当前客户投保保单相关投诉，包括非本人投诉' ,
+    LCPTDuration DECIMAL(8,2)    COMMENT '最近投诉处理时长 当前客户投保保单相关投诉，包括非本人投诉' ,
+    LCPTPerson STRING    COMMENT '最近投诉人' ,
+    SOPPremium DECIMAL(32,8)    COMMENT '累计已缴保费' ,
+    LAPPDate DATE    COMMENT '最近投保日期' ,
+    CNDate DATE    COMMENT '最近报案日期' ,
+    CNStatus STRING    COMMENT '最近报案状态' ,
+    COClaim INT    COMMENT '赔付次数' ,
+    SOClaim DECIMAL(32,8)    COMMENT '赔付总额' ,
+    COCNotification INT    COMMENT '报案登录数量' ,
+    FADate DATE    COMMENT '首次投保日期 当前客户为投保人时' ,
+    FAChannel STRING    COMMENT '首张保单所属渠道 InsuranceArrangement.AgentChannel' ,
+    FAOrg STRING    COMMENT '首张保单所属机构 InsuranceArrangement.AgentOrg' ,
+    LPNo STRING    COMMENT '最近保险单号 当前客户为投保人时' ,
+    LPState STRING    COMMENT '最近保单状态 当前客户为投保人时' ,
+    LPName STRING    COMMENT '最近投保险种名称 当前客户为投保人时' ,
+    LPChannel STRING    COMMENT '最近保单所属渠道 InsuranceArrangement.AgentChannel' ,
+    LPOrg STRING    COMMENT '最近保单所属机构 InsuranceArrangement.AgentOrg' ,
+    COPolicy INT    COMMENT '保单登录数量' ,
+    LPOSType STRING    COMMENT '最近保全类型 AUDIT_EDORLIST.EDORNAME' ,
+    IAccNo1 STRING    COMMENT '保险账户1' ,
+    IAccName1 STRING    COMMENT '保险账户1名称' ,
+    IAccNo2 STRING    COMMENT '保险账户2' ,
+    IAccName2 STRING    COMMENT '保险账户2名称' ,
+    IAccNo3 STRING    COMMENT '保险账户3' ,
+    IAccName3 STRING    COMMENT '保险账户3名称' ,
+    SOIAccount1 DECIMAL(32,8)    COMMENT '保险账户1余额' ,
+    SOIAccount2 DECIMAL(32,8)    COMMENT '保险账户2余额' ,
+    SOIAccount3 DECIMAL(32,8)    COMMENT '保险账户3余额' ,
+    COIAccount INT    COMMENT '保险账户登录数量' ,
+    HOMEID STRING    COMMENT '家庭号 大数据平台HOME_NETWORK' ,
+    BranchCode STRING    COMMENT '机构代码 数据归属机构，用于权限控制' ,
+    CustState STRING    COMMENT '客户状态 party可能会合并导致当前记录不再可用' ,
+    DataSource STRING    COMMENT '数据来源' ,
+    Smoking STRING    COMMENT '吸烟情况 从不、戒烟、吸烟' ,
+    Drinking STRING    COMMENT '饮酒情况 从不、戒酒、饮酒' ,
+    Pregnancy STRING    COMMENT '怀孕情况' ,
+    Hobby1 STRING    COMMENT '兴趣爱好1' ,
+    Hobby2 STRING    COMMENT '兴趣爱好2' ,
+    Hobby3 STRING    COMMENT '兴趣爱好3' ,
+    PIncome DECIMAL(32,8)    COMMENT '个人年收入' ,
+    FIncome DECIMAL(32,8)    COMMENT '家庭年收入' ,
+    IncomeSource STRING    COMMENT '收入来源' ,
+    SIStatus STRING    COMMENT '社保情况' ,
+    NOVPolicy INT    COMMENT '有效保单件数' ,
+    NOIVPolicy INT    COMMENT '失效保单件数' ,
+    NOSTInsurance STRING    COMMENT '短意险保单持有情况 仅持有短意险保单，持有短意险保单，无短意险保单' ,
+    NOSPInsurance STRING    COMMENT '趸交保单持有情况 仅持有趸交保单，持有趸交保单，无趸交保单' ,
+    ISelf STRING    COMMENT '本人投保情况 仅本人投保，本人已投保，本人未投保' ,
+    IParent STRING    COMMENT '父母投保情况 仅父母投保，父母已投保，父母未投保' ,
+    IChildren STRING    COMMENT '子女投保情况 仅子女投保，子女已投保，子女未·投保' ,
+    Imate STRING    COMMENT '配偶投保情况 仅配偶投保，配偶已投保，配偶未投保' ,
+     CREATED_BY STRING   COMMENT '创建人' ,
+    CREATED_TIME DATE    COMMENT '创建时间' ,
+    UPDATED_BY STRING    COMMENT '更新人' ,
+    UPDATED_TIME DATE    COMMENT '更新时间' ,
+    Label1 STRING    COMMENT 'Label1' ,
+    Label2 STRING    COMMENT 'Label2' ,
+    Label3 STRING    COMMENT 'Label3' ,
+    Label4 STRING    COMMENT 'Label4' ,
+    Label5 STRING    COMMENT 'Label5' ,
+    Label6 STRING    COMMENT 'Label6' ,
+    Label7 STRING    COMMENT 'Label7' ,
+    Label8 STRING    COMMENT 'Label8' ,
+    Label9 STRING    COMMENT 'Label9' ,
+    Label10 STRING    COMMENT 'Label10' ,
+    Label11 STRING    COMMENT 'Label11' ,
+    Label12 STRING    COMMENT 'Label12' ,
+    Label13 STRING    COMMENT 'Label13' ,
+    Label14 STRING    COMMENT 'Label14' ,
+    Label15 STRING    COMMENT 'Label15' ,
+    Label16 STRING    COMMENT 'Label16' ,
+    Label17 STRING    COMMENT 'Label17' ,
+    Label18 STRING    COMMENT 'Label18' ,
+    Label19 STRING    COMMENT 'Label19' ,
+    Label20 STRING    COMMENT 'Label20' ,
+    Label21 STRING    COMMENT 'Label21' ,
+    Label22 STRING    COMMENT 'Label22' ,
+    Label23 STRING    COMMENT 'Label23' ,
+    Label24 STRING    COMMENT 'Label24' ,
+    Label25 STRING    COMMENT 'Label25' ,
+    Label26 STRING    COMMENT 'Label26' ,
+    Label27 STRING    COMMENT 'Label27' ,
+    Label28 STRING    COMMENT 'Label28' ,
+    Label29 STRING    COMMENT 'Label29' ,
+    Label30 STRING    COMMENT 'Label30' ,
+    Label31 STRING    COMMENT 'Label31' ,
+    Label32 STRING    COMMENT 'Label32' ,
+    Label33 STRING    COMMENT 'Label33' ,
+    Label34 STRING    COMMENT 'Label34' ,
+    Label35 STRING    COMMENT 'Label35' ,
+    Label36 STRING    COMMENT 'Label36' ,
+    Label37 STRING    COMMENT 'Label37' ,
+    Label38 STRING    COMMENT 'Label38' ,
+    Label39 STRING    COMMENT 'Label39' ,
+    Label40 STRING    COMMENT 'Label40' ,
+    Label41 STRING    COMMENT 'Label41' ,
+    Label42 STRING    COMMENT 'Label42' ,
+    Label43 STRING    COMMENT 'Label43' ,
+    Label44 STRING    COMMENT 'Label44' ,
+    Label45 STRING    COMMENT 'Label45' ,
+    Label46 STRING    COMMENT 'Label46' ,
+    Label47 STRING    COMMENT 'Label47' ,
+    Label48 STRING    COMMENT 'Label48' ,
+    Label49 STRING    COMMENT 'Label49' ,
+    Label50 STRING    COMMENT 'Label50' ,
+    Label51 STRING    COMMENT 'Label51' ,
+    Label52 STRING    COMMENT 'Label52' ,
+    Label53 STRING    COMMENT 'Label53' ,
+    Label54 STRING    COMMENT 'Label54' ,
+    Label55 STRING    COMMENT 'Label55' ,
+    Label56 STRING    COMMENT 'Label56' ,
+    Label57 STRING    COMMENT 'Label57' ,
+    Label58 STRING    COMMENT 'Label58' ,
+    Label59 STRING    COMMENT 'Label59' ,
+    Label60 STRING    COMMENT 'Label60' ,
+    Label61 STRING    COMMENT 'Label61' ,
+    Label62 STRING    COMMENT 'Label62' ,
+    Label63 STRING    COMMENT 'Label63' ,
+    Label64 STRING    COMMENT 'Label64' ,
+    Label65 STRING    COMMENT 'Label65' ,
+    Label66 STRING    COMMENT 'Label66' ,
+    Label67 STRING    COMMENT 'Label67' ,
+    Label68 STRING    COMMENT 'Label68' ,
+    Label69 STRING    COMMENT 'Label69' ,
+    Label70 STRING    COMMENT 'Label70' ,
+    Label71 STRING    COMMENT 'Label71' ,
+    Label72 STRING    COMMENT 'Label72' ,
+    Label73 STRING    COMMENT 'Label73' ,
+    Label74 STRING    COMMENT 'Label74' ,
+    Label75 STRING    COMMENT 'Label75' ,
+    Label76 STRING    COMMENT 'Label76' ,
+    Label77 STRING    COMMENT 'Label77' ,
+    Label78 STRING    COMMENT 'Label78' ,
+    Label79 STRING    COMMENT 'Label79' ,
+    Label80 STRING    COMMENT 'Label80' ,
+    Label81 STRING    COMMENT 'Label81' ,
+    Label82 STRING    COMMENT 'Label82' ,
+    Label83 STRING    COMMENT 'Label83' ,
+    Label84 STRING    COMMENT 'Label84' ,
+    Label85 STRING    COMMENT 'Label85' ,
+    Label86 STRING    COMMENT 'Label86' ,
+    Label87 STRING    COMMENT 'Label87' ,
+    Label88 STRING    COMMENT 'Label88' ,
+    Label89 STRING    COMMENT 'Label89' ,
+    Label90 STRING    COMMENT 'Label90' ,
+    Label91 STRING    COMMENT 'Label91' ,
+    Label92 STRING    COMMENT 'Label92' ,
+    Label93 STRING    COMMENT 'Label93' ,
+    Label94 STRING    COMMENT 'Label94' ,
+    Label95 STRING    COMMENT 'Label95' ,
+    Label96 STRING    COMMENT 'Label96' ,
+    Label97 STRING    COMMENT 'Label97' ,
+    Label98 STRING    COMMENT 'Label98' ,
+    Label99 STRING    COMMENT 'Label99' ,
+    Label100 STRING    COMMENT 'Label100' ,
+    Label101 STRING    COMMENT 'Label101' ,
+    Label102 STRING    COMMENT 'Label102' ,
+    Label103 STRING    COMMENT 'Label103' ,
+    Label104 STRING    COMMENT 'Label104' ,
+    Label105 STRING    COMMENT 'Label105' ,
+    Label106 STRING    COMMENT 'Label106' ,
+    Label107 STRING    COMMENT 'Label107' ,
+    Label108 STRING    COMMENT 'Label108' ,
+    Label109 STRING    COMMENT 'Label109' ,
+    Label110 STRING    COMMENT 'Label110' ,
+    Label111 STRING    COMMENT 'Label111' ,
+    Label112 STRING    COMMENT 'Label112' ,
+    Label113 STRING    COMMENT 'Label113' ,
+    Label114 STRING    COMMENT 'Label114' ,
+    Label115 STRING    COMMENT 'Label115' ,
+    Label116 STRING    COMMENT 'Label116' ,
+    Label117 STRING    COMMENT 'Label117' ,
+    Label118 STRING    COMMENT 'Label118' ,
+    Label119 STRING    COMMENT 'Label119' ,
+    Label120 STRING    COMMENT 'Label120' ,
+    PRIMARY KEY (IndID)
+) COMMENT '个人信息 '
+stored as ES
+with shard number 10
+replication 1;
+
+DROP TABLE IF EXISTS shanglifeecif.Adress;
+CREATE  TABLE shanglifeecif.Adress(
+AID	string	DEFAULT NULL COMMENT '	地址ID	',
+PartyID	string		DEFAULT NULL COMMENT '	参与方ID	',
+PartyName	string		DEFAULT NULL COMMENT '	参与方名称	',
+PartyPhone	string		DEFAULT NULL COMMENT '	参与方手机号',
+PartyIDCard	string		DEFAULT NULL COMMENT '	参与方证件号码',
+ACountry	string		DEFAULT NULL COMMENT '	地址_国家	',
+AState	string		DEFAULT NULL COMMENT '	地址_省	',
+ACity	string		DEFAULT NULL COMMENT '	地址_市县	',
+ATown	string		DEFAULT NULL COMMENT '	地址_区镇	',
+AStreet	string		DEFAULT NULL COMMENT '	地址_街道	',
+AStreetNo	string		DEFAULT NULL COMMENT '	地址_门牌号	',
+APostCode	string		DEFAULT NULL COMMENT '	地址_邮政编码	',
+APhone	string		DEFAULT NULL COMMENT '	地址_电话	',
+ADescribe	string		DEFAULT NULL COMMENT '	地址描述	',
+ADate	DATE		DEFAULT NULL COMMENT '	地址时间	',
+Longitude	string		DEFAULT NULL COMMENT '	经度	',
+Latitude	string		DEFAULT NULL COMMENT '	纬度	',
+AType	string	DEFAULT NULL COMMENT '	地址类型	',
+CREATED_BY	string		DEFAULT NULL COMMENT '	创建人	',
+CREATED_TIME	DATE		DEFAULT NULL COMMENT '	创建时间	',
+UPDATED_BY	string		DEFAULT NULL COMMENT '	更新人	',
+UPDATED_TIME	DATE		DEFAULT NULL COMMENT '	更新时间	'
+)
+COMMENT '地址信息'
+stored as ES
+with shard number 10
+replication 1;
+
+DROP TABLE IF EXISTS shanglifeecif.Organisation;
+CREATE  TABLE shanglifeecif.Organisation(
+
+OID	string	DEFAULT NULL COMMENT '	团体ID	',
+CustID	string	DEFAULT NULL COMMENT '	客户ID	',
+SCustID	string	DEFAULT NULL COMMENT '	上游客户ID	',
+Name	string	DEFAULT NULL COMMENT '	名称	',
+OCID	string	DEFAULT NULL COMMENT '	联系人	',
+OCName	string	DEFAULT NULL COMMENT '	联系人姓名	',
+OCPhone	string	DEFAULT NULL COMMENT '	联系人电话	',
+OFCID	string	DEFAULT NULL COMMENT '	财务联系人	',
+OFCName	string	DEFAULT NULL COMMENT '	财务联系人姓名	',
+OFCPhone	string	DEFAULT NULL COMMENT '	财务联系人电话	',
+OLevel	string	DEFAULT NULL COMMENT '	组织层级	',
+SCCode	string	DEFAULT NULL COMMENT '	统一社会信用代码	',
+OLPerson	string	DEFAULT NULL COMMENT '	法人	',
+BizType	string	DEFAULT NULL COMMENT '	行业类型	',
+RegDate	DATE	DEFAULT NULL COMMENT '	注册日期	',
+LegalStruct	string	DEFAULT NULL COMMENT '	企业性质	',
+RegAddress	string	DEFAULT NULL COMMENT '	注册地址	',
+RegFun	double	DEFAULT NULL COMMENT '	注册资金	',
+NuOfEmployees	INT	DEFAULT NULL COMMENT '	员工人数	',
+OState	string	DEFAULT NULL COMMENT '	经营状况	',
+OSDate	DATE	DEFAULT NULL COMMENT '	经营状况日期	',
+BranchCode	string	DEFAULT NULL COMMENT '	机构代码	',
+systemtag1 string DEFAULT NULL COMMENT '系统标签域1', 
+systemtag2 string DEFAULT NULL COMMENT '系统标签域2', 
+systemtag3 string DEFAULT NULL COMMENT '系统标签域3', 
+Wechat1	string	DEFAULT NULL COMMENT '	微信公众号	',
+Wechat2	string	DEFAULT NULL COMMENT '	微信服务号	',
+weibo string DEFAULT NULL COMMENT '微博', 
+  email string DEFAULT NULL COMMENT '邮箱', 
+  qq string DEFAULT NULL COMMENT 'QQ', 
+  tiktok string DEFAULT NULL COMMENT '抖音', 
+  saccount1 string DEFAULT NULL COMMENT '社交账号1', 
+  sa1cat string DEFAULT NULL COMMENT '社交账号1类别',  -- dialect: ORACLE
+  saccount2 string DEFAULT NULL COMMENT '社交账号2', 
+  sa2cat string DEFAULT NULL COMMENT '社交账号2类别',  -- dialect: ORACLE
+  ctype string DEFAULT NULL COMMENT '客户类型',  -- dialect: ORACLE
+  bankname string DEFAULT NULL COMMENT '开户银行',  -- dialect: ORACLE
+  tobankcard string DEFAULT NULL COMMENT '银行卡类型',  -- dialect: ORACLE
+  accname string DEFAULT NULL COMMENT '账户名', 
+  bankaccno string DEFAULT NULL COMMENT '银行帐号', 
+  cobaccount INT DEFAULT NULL COMMENT '账户登录数量', 
+  sotlirisk double DEFAULT NULL COMMENT '传统寿险种保额合计', 
+  soairisk double DEFAULT NULL COMMENT '意外类险种保额合计', 
+  sosiirisk double DEFAULT NULL COMMENT '重疾类险种保额合计', 
+  somcirisk double DEFAULT NULL COMMENT '医疗费用类险种保额合计', 
+  someirisk double DEFAULT NULL COMMENT '医疗补贴类险种保额合计', 
+  soefirisk double DEFAULT NULL COMMENT '教育金类险种保额合计', 
+  sopirisk double DEFAULT NULL COMMENT '养老金类险种保额合计', 
+  sowmirisk double DEFAULT NULL COMMENT '财富管理险种保额合计', 
+  custclass INT DEFAULT NULL COMMENT '客户等级', 
+  convalue INT DEFAULT NULL COMMENT '贡献度分', 
+  awarded3 INT DEFAULT NULL COMMENT '家庭加分', 
+  awarded2 INT DEFAULT NULL COMMENT '续期加分', 
+  awarded1 INT DEFAULT NULL COMMENT '保单加分', 
+  sovalue INT DEFAULT NULL COMMENT '总分值', 
+  enddate DATE DEFAULT NULL COMMENT '客户等级失效日期', 
+  cocommunication INT DEFAULT NULL COMMENT '接触次数', 
+  lcdate DATE DEFAULT NULL COMMENT '最近接触时间', 
+  lctype string DEFAULT NULL COMMENT '最近接触类型',  -- dialect: ORACLE
+  cocomplaint INT DEFAULT NULL COMMENT '投诉次数', 
+  lcptdate DATE DEFAULT NULL COMMENT '最近投诉时间', 
+  lcptreason string DEFAULT NULL COMMENT '最近投诉原因',  -- dialect: ORACLE
+  lcptlink string DEFAULT NULL COMMENT '最近投诉环节',  -- dialect: ORACLE
+  lcptresult string DEFAULT NULL COMMENT '最近投诉处理结果',  -- dialect: ORACLE
+  lcptduration double DEFAULT NULL COMMENT '最近投诉处理时长', 
+  lcptperson string DEFAULT NULL COMMENT '最近投诉人',  -- dialect: ORACLE
+  soppremium double DEFAULT NULL COMMENT '累计已缴保费', 
+  lappdate DATE DEFAULT NULL COMMENT '最近投保日期', 
+  cndate DATE DEFAULT NULL COMMENT '最近报案日期', 
+  cnstatus string DEFAULT NULL COMMENT '最近报案状态',  -- dialect: ORACLE
+  cocnotification INT DEFAULT NULL COMMENT '报案登录数量', 
+  fadate DATE DEFAULT NULL COMMENT '首次投保日期', 
+  ladate DATE DEFAULT NULL COMMENT '最近投保日期', 
+  lpno string DEFAULT NULL COMMENT '最近保险单号', 
+  lpstate string DEFAULT NULL COMMENT '最近保单状态',  -- dialect: ORACLE
+  lpname string DEFAULT NULL COMMENT '最近投保险种名称', 
+  copolicy INT DEFAULT NULL COMMENT '保单登录数量', 
+  iaccno1 string DEFAULT NULL COMMENT '保险账户1', 
+  IAccName1 string DEFAULT NULL COMMENT '保险账户名称1', 
+  iaccno2 string DEFAULT NULL COMMENT '保险账户2', 
+  IAccName2 string DEFAULT NULL COMMENT '保险账户名称2', 
+  iaccno3 string DEFAULT NULL COMMENT '保险账户3', 
+  IAccName3 string DEFAULT NULL COMMENT '保险账户名称3', 
+  soiaccount1 double DEFAULT NULL COMMENT '保险账户1余额', 
+  soiaccount2 double DEFAULT NULL COMMENT '保险账户2余额', 
+  soiaccount3 double DEFAULT NULL COMMENT '保险账户3余额', 
+  coiaccount INT DEFAULT NULL COMMENT '保险账户登录数量',
+  CustState string DEFAULT NULL COMMENT '客户状态', 
+  DataSource string DEFAULT NULL COMMENT '数据来源',
+  CREATED_BY	string DEFAULT NULL COMMENT '	创建人	',
+	CREATED_TIME	TIMESTAMP	DEFAULT NULL COMMENT '	创建时间	',
+	UPDATED_BY	string	DEFAULT NULL COMMENT '	更新人	',
+	UPDATED_TIME	date DEFAULT NULL COMMENT '	更新时间	'
+)
+COMMENT '团体'
+stored as ES
+with shard number 10
+replication 1;
+
+DROP TABLE IF EXISTS shanglifeecif.PrivacyPreferenceInstructions;
+CREATE  TABLE shanglifeecif.PrivacyPreferenceInstructions(
+CREATED_BY	string	DEFAULT NULL COMMENT '	创建人	',
+CREATED_TIME	date	DEFAULT NULL COMMENT '	创建时间	',
+UPDATED_BY	string	DEFAULT NULL COMMENT '	更新人	',
+UPDATED_TIME	date	DEFAULT NULL COMMENT '	更新时间	',
+PPIID	string	DEFAULT NULL COMMENT '	偏好ID	',
+IndID	string	DEFAULT NULL COMMENT '	个体ID	',
+IndPhone	string	DEFAULT NULL COMMENT '	个人手机号	',
+IndIDCard	string	DEFAULT NULL COMMENT '	个人证件	',
+IndName	string	DEFAULT NULL COMMENT '	个人名称	',
+Type	string	DEFAULT NULL COMMENT '	类别	',
+W1Stime	string	DEFAULT NULL COMMENT '	周一起始时间	',
+W1Etime	string	DEFAULT NULL COMMENT '	周一结束时间	',
+W2Stime	string	DEFAULT NULL COMMENT '	周二起始时间	',
+W2Etime	string	DEFAULT NULL COMMENT '	周二结束时间	',
+W3Stime	string	DEFAULT NULL COMMENT '	周三起始时间	',
+W3Etime	string	DEFAULT NULL COMMENT '	周三结束时间	',
+W4Stime	string	DEFAULT NULL COMMENT '	周四起始时间	',
+W4Etime	string	DEFAULT NULL COMMENT '	周四结束时间	',
+W5Stime	string	DEFAULT NULL COMMENT '	周五起始时间	',
+W5Etime	string	DEFAULT NULL COMMENT '	周五结束时间	',
+W6Stime	string	DEFAULT NULL COMMENT '	周六起始时间	',
+W6Etime	string	DEFAULT NULL COMMENT '	周六结束时间	',
+W7Stime	string	DEFAULT NULL COMMENT '	周日起始时间	',
+W7Etime	string	DEFAULT NULL COMMENT '	周日结束时间	'
+)
+COMMENT '隐私偏好设定'
+stored as ES
+with shard number 10
+replication 1;
+
+DROP TABLE IF EXISTS shanglifeecif.HealthStatus;
+CREATE  TABLE shanglifeecif.HealthStatus(
+CREATED_BY	string	DEFAULT NULL COMMENT '	创建人	',
+CREATED_TIME	date	DEFAULT NULL COMMENT '	创建时间	',
+UPDATED_BY	string	DEFAULT NULL COMMENT '	更新人	',
+UPDATED_TIME	date	DEFAULT NULL COMMENT '	更新时间	',
+HSID	string	DEFAULT NULL COMMENT '	健康状况ID	',
+IndID	string	DEFAULT NULL COMMENT '	个体ID	',
+IndName	string	DEFAULT NULL COMMENT '	个人名称	',
+IndPhone	string	DEFAULT NULL COMMENT '	个人手机	',
+IndIDCard	string	DEFAULT NULL COMMENT '	个人证件号码	',
+EvaDate	DATE	DEFAULT NULL COMMENT '	评估日期	',
+Height	double	DEFAULT NULL COMMENT '	身高	',
+Weight	double	DEFAULT NULL COMMENT '	体重	',
+CIllness	string	DEFAULT NULL COMMENT '	当前疾病	',
+PIllness	string	DEFAULT NULL COMMENT '	曾患疾病	',
+BMI	double	DEFAULT NULL COMMENT '	BMI体制指数	'
+)
+COMMENT '健康状况'
+stored as ES
+with shard number 10
+replication 1;
+
+DROP TABLE IF EXISTS shanglifeecif.RealProperty;
+CREATE  TABLE shanglifeecif.RealProperty(
+CREATED_BY	string	DEFAULT NULL COMMENT '	创建人	',
+CREATED_TIME	date	DEFAULT NULL COMMENT '	创建时间	',
+UPDATED_BY	string	DEFAULT NULL COMMENT '	更新人	',
+UPDATED_TIME	date	DEFAULT NULL COMMENT '	更新时间	',
+RPID	string	DEFAULT NULL COMMENT '	房产ID	',
+IndID	string	DEFAULT NULL COMMENT '	IndID	',
+IndName	string	DEFAULT NULL COMMENT '	个人名称	',
+IndPhone	string	DEFAULT NULL COMMENT '	个人手机	',
+IndIDCard	string	DEFAULT NULL COMMENT '	个人证件号码	',
+RPAID	string	DEFAULT NULL COMMENT '	房产地址	',
+RPAL	string	DEFAULT NULL COMMENT '	房产地址不分段	',
+RPRegNo	string	DEFAULT NULL COMMENT '	产权证号码	',
+BLDGType	string	DEFAULT NULL COMMENT '	房产结构	',
+BLDGStyle	string	DEFAULT NULL COMMENT '	房型	',
+RPType	string	DEFAULT NULL COMMENT '	房产类型	',
+RPOSize	double	DEFAULT NULL COMMENT '	建筑面积	',
+RPTSize	double	DEFAULT NULL COMMENT '	实得面积	',
+RPSTime	DATE	DEFAULT NULL COMMENT '	开始时间	',
+RPETime	DATE	DEFAULT NULL COMMENT '	结束时间	'
+)
+COMMENT '房产'
+stored as ES
+with shard number 10
+replication 1;
+
+DROP TABLE IF EXISTS shanglifeecif.Vehicle;
+CREATE  TABLE shanglifeecif.Vehicle(
+CREATED_BY	string	DEFAULT NULL COMMENT '	创建人	',
+CREATED_TIME	date	DEFAULT NULL COMMENT '	创建时间	',
+UPDATED_BY	string	DEFAULT NULL COMMENT '	更新人	',
+UPDATED_TIME	date	DEFAULT NULL COMMENT '	更新时间	',
+VID	string	DEFAULT NULL COMMENT '	车辆ID	',
+IndID	string	DEFAULT NULL COMMENT '	个人ID	',
+VMake	string	DEFAULT NULL COMMENT '	车型	',
+VModel	string	DEFAULT NULL COMMENT '	型号	',
+VINNumber	string	DEFAULT NULL COMMENT '	VIN码	',
+VCNumber	string	DEFAULT NULL COMMENT '	车架号	',
+VRNumber	string	DEFAULT NULL COMMENT '	牌照号码	',
+VSTime	DATE	DEFAULT NULL COMMENT '	开始时间	',
+VETime	DATE	DEFAULT NULL COMMENT '	结束时间	'
+)
+COMMENT '车辆'
+stored as ES
+with shard number 10
+replication 1;
+
+DROP TABLE IF EXISTS shanglifeecif.IndRelationShip;
+CREATE  TABLE shanglifeecif.IndRelationShip(
+
+IRSID	string	DEFAULT NULL COMMENT '	个体关系ID	',
+RSType	string	DEFAULT NULL COMMENT '	关系类型	',
+IndID1	string	DEFAULT NULL COMMENT '	个体1	',
+Name1	string	DEFAULT NULL COMMENT '	个体1名称	',
+Mphone1	string	DEFAULT NULL COMMENT '	个体1手机	',
+IDCard1	string	DEFAULT NULL COMMENT '	个体1证件号码	',
+Role1	string	DEFAULT NULL COMMENT '	个体1角色	',
+IndID2	string	DEFAULT NULL COMMENT '	个体2	',
+Name2	string	DEFAULT NULL COMMENT '	个体2名称	',
+Mphone2	string	DEFAULT NULL COMMENT '	个体2手机	',
+IDCard2	string	DEFAULT NULL COMMENT '	个体2证件号码	',
+Role2	string	DEFAULT NULL COMMENT '	个体2角色	',
+RSSTime	DATE	DEFAULT NULL COMMENT '	开始时间	',
+RSETime	DATE	DEFAULT NULL COMMENT '	结束时间	',
+RSDescribe	string	DEFAULT NULL COMMENT '	关系描述	',
+CREATED_BY	string	DEFAULT NULL COMMENT '	创建人	',
+CREATED_TIME	date	DEFAULT NULL COMMENT '	创建时间	',
+UPDATED_BY	string	DEFAULT NULL COMMENT '	更新人	',
+UPDATED_TIME	date	DEFAULT NULL COMMENT '	更新时间	'
+)
+COMMENT '个体关系'
+stored as ES
+with shard number 10
+replication 1;
+
+DROP TABLE IF EXISTS shanglifeecif.IndOrgRelationShip;
+CREATE  TABLE shanglifeecif.IndOrgRelationShip(
+CREATED_BY	string	DEFAULT NULL COMMENT '	创建人	',
+CREATED_TIME	date	DEFAULT NULL COMMENT '	创建时间	',
+UPDATED_BY	string	DEFAULT NULL COMMENT '	更新人	',
+UPDATED_TIME	date	DEFAULT NULL COMMENT '	更新时间	',
+IORSID	string	DEFAULT NULL COMMENT '	关系ID	',
+RSType	string	DEFAULT NULL COMMENT '	关系类型	',
+IndID	string	DEFAULT NULL COMMENT '	个体	',
+IndName	string	DEFAULT NULL COMMENT '	个体名称	',
+Mphone	string	DEFAULT NULL COMMENT '	个体手机	',
+IDCard	string	DEFAULT NULL COMMENT '	个体证件号码	',
+IRole	string	DEFAULT NULL COMMENT '	个体角色	',
+OID	string	DEFAULT NULL COMMENT '	团体	',
+SCCode	string	DEFAULT NULL COMMENT '	统一社会信用代码	',
+OrgName	string	DEFAULT NULL COMMENT '	团体名称	',
+OCID	string	DEFAULT NULL COMMENT '	联系人	',
+OCName	string	DEFAULT NULL COMMENT '	联系人姓名	',
+OCPhone	string	DEFAULT NULL COMMENT '	联系人电话	',
+ORole	string	DEFAULT NULL COMMENT '	团体角色	',
+RSSTime	DATE	DEFAULT NULL COMMENT '	开始时间	',
+RSETime	DATE	DEFAULT NULL COMMENT '	结束时间	',
+RSDescribe	string	DEFAULT NULL COMMENT '	关系描述	'
+)
+COMMENT '个人团体关系'
+stored as ES
+with shard number 10
+replication 1;
+
+DROP TABLE IF EXISTS shanglifeecif.InsuranceArrangement;
+CREATE TABLE shanglifeecif.InsuranceArrangement(
+    IAID STRING NOT NULL  COMMENT '保单ID' ,
+    PolicyNo STRING    COMMENT '保险单号 INSURANCEINFO.CONTNO' ,
+    PANo STRING    COMMENT '投保单号 INSURANCEINFO.PRTNO' ,
+    AGRMNTAge STRING    COMMENT '保险期限' ,
+    PBInst STRING    COMMENT '受益分配方式' ,
+    PWComp STRING    COMMENT '承保分公司 HEALTH_INSURANCE_LISTING.AGENTGROUPAREA 营业区HEALTH_INSURANCE_LISTING.AGENTGROUP 营业部' ,
+    PINDate DATE    COMMENT '起保日期 POLICY_INFORMATION.CVALIDATE' ,
+    PMDate DATE    COMMENT '终保日期 POLICY_INFORMATION.ENDDATE' ,
+    PISDate DATE    COMMENT '签单日期 INSURANCEINFO.SIGNDATE' ,
+    PADate DATE    COMMENT '投保日期 INSURANCEINFO.POLAPPLYDATE' ,
+    RenewalDate DATE    COMMENT '续保日期' ,
+    NORenewal INT    COMMENT '续保次数 POLICY_INFORMATION.PAYCOUNT' ,
+    PolicyType STRING    COMMENT '保单类型 PERSONAL_INSURANCE.CONTTYPE,需上游给出类型枚举值' ,
+    SChannel STRING    COMMENT '销售渠道 HEALTH_INSURANCE_LISTING.SALECHANNELS
+1	团险渠道
+2	个人营销
+3	银行代理
+4	中介渠道
+5	网销渠道' ,
+    BSource STRING    COMMENT '业务来源' ,
+    PolicyState STRING   COMMENT '保单状态 保单包括投保单的所处的状态，例如：录入、生效、批单等
+INSURANCEINFO.APPFLAG
+code	codename
+0	未承保
+1	承保
+2	新增附加险
+4	终止
+9	续保
+B	未对账
+F	对账失败' ,
+    TOPay STRING   COMMENT '缴费类型' ,
+    Payment STRING   COMMENT '缴费方式 POLICY_INFORMATION.PAYINTV' ,
+    Risk DOUBLE    COMMENT '总保额 HEALTH_INSURANCE_LISTING.AMNT(测试环境中，此表保单数据量较其他表如：POLICY_INFORMATION，INSURANCEINFO 缺少至少一个数据量级)' ,
+    Prem DOUBLE   COMMENT '总保费 INSURANCEINFO.PREM' ,
+    Currency STRING    COMMENT '币种' ,
+    NPDate DATE    COMMENT '下次缴费日期' ,
+    SOInsured INT    COMMENT '被保人数 HEALTH_GROUP_LISTING.PEOPLES3,团单' ,
+    BSInsured DOUBLE    COMMENT '基本保额 保险合同条款费率表中载明的单位保额。比如中国人寿的康宁终身保险就是这样，如果购买的基本保险金额是10万的话，那么大病的保险金额就是基本保险金额的2倍即20万；' ,
+    InsurValue DOUBLE    COMMENT '保单价值 保单价值，即保单现金价值。是指带有储蓄性质的人身bai保险单所具有的价值。保险人为履行合同责任通常提存责任准备金，如果您中途退保，即以该保单的责任准备金作为给付解约的退还金。被保险人要求解约或退保时，寿险公司应该发还的金额。
+在长期寿险契约中，保险人为履行契约责任，通常需要提存一定数额的责任准备金。当被保险人于保险有效期内因故要求解约或退保时，保险人按规定，将提存的责任准备金减去解约扣除后的余额退还给被保险人，这部分余额即解约金，亦即退保时保单所具有的现金价值。' ,
+    ApplicantID STRING    COMMENT '投保人 根据POLICY_INFORMATION.CUSTOMERNO关联individual上游客户号，再找到individualid' ,
+    AppName STRING   COMMENT '投保人名称 POLICY_INFORMATION.NAME' ,
+    AppPhone STRING COMMENT '投保人手机' ,
+    AppCertID STRING  COMMENT '投保人证件号码 POLICY_INFORMATION.IDNO' ,
+    InsuredID STRING    COMMENT '主被保险人' ,
+    InsName STRING  COMMENT '主被保险人名称 POLICY_INFORMATION.INSUREDNAME' ,
+    InsPhone STRING  COMMENT '主被保险人手机' ,
+    InsCertID STRING   COMMENT '主被保险人证件号码 POLICY_INFORMATION.INSUREDIDNO' ,
+    ProductID STRING   COMMENT '险种代码 POLICY_INFORMATION.RISKCODE' ,
+    ProductName STRING   COMMENT '险种名称 INSURANCEINFO.RISKNAME' ,
+    SalesPerson STRING   COMMENT '业务员' ,
+    SPName STRING   COMMENT '业务员名称 HEALTH_INSURANCE_LISTING.AGENTCODE' ,
+    IAccount STRING  COMMENT '所属保险账户' ,
+    BranchCode STRING  COMMENT '机构代码' ,
+    PolicyBelong STRING   COMMENT '业绩归属 POLICY_INFORMATION.SALECOM' ,
+    AgentChannel STRING  COMMENT '代理渠道 INSURANCEINFO.SELLTYPE' ,
+    AgentOrg STRING   COMMENT '代理机构' ,
+    RegType STRING  COMMENT '户籍类型' ,
+    PIncome STRING  COMMENT '个人年收入' ,
+    FIncome DOUBLE   COMMENT '家庭年收入' ,
+    IncomeSource STRING   COMMENT '收入来源' ,
+    SocialInsurance STRING   COMMENT '是否有社保' ,
+    OIPolicy STRING   COMMENT '是否投保其他保险公司' ,
+    OICompany STRING  COMMENT '其他保险公司' ,
+    OICProduct STRING  COMMENT '其他保险公司险种' ,
+    OIAmount DOUBLE   COMMENT '其他保险公司保额' ,
+    Drinking STRING   COMMENT '是否饮酒' ,
+    DFavor STRING  COMMENT '饮酒喜好' ,
+    POService STRING  COMMENT '是否保全 投保人持有保单是否在AUDIT_EDORLIST.CONTNO存在' ,
+    PayEndYear INT    COMMENT '缴费年期 POLICY_INFORMATION.PAYENDYEAR' ,
+    LoanMoney DOUBLE COMMENT '保单质押贷款金额' ,
+    CREATED_BY STRING   COMMENT '创建人' ,
+    CREATED_TIME DATE    COMMENT '创建时间' ,
+    UPDATED_BY STRING   COMMENT '更新人' ,
+    UPDATED_TIME DATE   COMMENT '更新时间' 
+) 
+COMMENT '保单 确定参与方之间，参与方和保险公司之间的协议，使相关各方能在遵守一定的规则并履行相关义务的前提下进行产品或资源或服务的供给'
+stored as ES
+with shard number 10
+replication 1;
+
+ALTER TABLE shanglifeecif.InsuranceArrangement ADD COLUMNS (LoanMoney double);
+
+
+DROP TABLE IF EXISTS shanglifeecif.IndIARelationShip;
+CREATE  TABLE shanglifeecif.IndIARelationShip(
+CREATED_BY	string	DEFAULT NULL COMMENT '	创建人	',
+CREATED_TIME	date	DEFAULT NULL COMMENT '	创建时间	',
+UPDATED_BY	string	DEFAULT NULL COMMENT '	更新人	',
+UPDATED_TIME	date	DEFAULT NULL COMMENT '	更新时间	',
+IIARSID	string	DEFAULT NULL COMMENT '	关系ID	',
+IndID	string	DEFAULT NULL COMMENT '	个人ID	',
+IndName	string	DEFAULT NULL COMMENT '	个人名称	',
+IndPhone	string	DEFAULT NULL COMMENT '	个人手机	',
+IndIDCard	string	DEFAULT NULL COMMENT '	个人证件号码	',
+RolePlayer	string	DEFAULT NULL COMMENT '	角色	',
+ROBeneficiary	double	DEFAULT NULL COMMENT '	受益比例	',
+IAID	string	DEFAULT NULL COMMENT '	保单号	',
+PolicyNo	string	DEFAULT NULL COMMENT '	保险单号	',
+PANo	string	DEFAULT NULL COMMENT '	投保单号	',
+PolicyState	string	DEFAULT NULL COMMENT '	保单状态	',
+RSSTime	DATE	DEFAULT NULL COMMENT '	开始时间	',
+RSEtime	DATE	DEFAULT NULL COMMENT '	结束时间	'
+)
+COMMENT '个人保单关系'
+stored as ES
+with shard number 10
+replication 1;
+
+DROP TABLE IF EXISTS shanglifeecif.Communication;
+CREATE  TABLE shanglifeecif.Communication(
+CREATED_BY	string	DEFAULT NULL COMMENT '	创建人	',
+CREATED_TIME	date	DEFAULT NULL COMMENT '	创建时间	',
+UPDATED_BY	string	DEFAULT NULL COMMENT '	更新人	',
+UPDATED_TIME	date	DEFAULT NULL COMMENT '	更新时间	',
+CommID	string	DEFAULT NULL COMMENT '	接触ID	',
+IndID	string	DEFAULT NULL COMMENT '	接触人ID	',
+CPName	string	DEFAULT NULL COMMENT '	接触人名称	',
+CPPhone	string	DEFAULT NULL COMMENT '	接触人手机	',
+CPCertID	string	DEFAULT NULL COMMENT '	接触人证件号码	',
+PolicyNo	string	DEFAULT NULL COMMENT '	保险单号	',
+CommType	string	DEFAULT NULL COMMENT '	接触类型	',
+CommChannel	string	DEFAULT NULL COMMENT '	接触渠道	',
+Reason	string	DEFAULT NULL COMMENT '	接触原因	',
+CommTime	date	DEFAULT NULL COMMENT '	接触时间	',
+CommDescribe	string	DEFAULT NULL COMMENT '	接触描述	',
+CompLink	string	DEFAULT NULL COMMENT '	投诉环节	',
+CompReason	string	DEFAULT NULL COMMENT '	投诉原因	',
+ProcedureResult	string	DEFAULT NULL COMMENT '	处理结果	',
+CommLevel	string	DEFAULT NULL COMMENT '	接触等级	',
+RVType	string	DEFAULT NULL COMMENT '	回访类型	',
+RVDate	DATE	DEFAULT NULL COMMENT '	回访时间	',
+RVDuration	double	DEFAULT NULL COMMENT '	回访时长	',
+CPTDuration	double	DEFAULT NULL COMMENT '	投诉处理时长	'
+)
+COMMENT '接触'
+stored as ES
+with shard number 10
+replication 1;
+
+DROP TABLE IF EXISTS shanglifeecif.InsuranceClaimThread;
+CREATE  TABLE shanglifeecif.InsuranceClaimThread(
+ICThreadID	string	DEFAULT NULL COMMENT '	保险理赔Id	',
+CRNo	string	DEFAULT NULL COMMENT '	立案号	',
+CompanyNo	string	DEFAULT NULL COMMENT '	公司代码	',
+PolicyNo	string	DEFAULT NULL COMMENT '	保险单号	',
+ApplicantID	string	DEFAULT NULL COMMENT '	投保人	',
+AppName	string	DEFAULT NULL COMMENT '	投保人名称	',
+AppPhone	string	DEFAULT NULL COMMENT '	投保人手机	',
+AppCertID	string	DEFAULT NULL COMMENT '	投保人证件号码	',
+CNNo	string	DEFAULT NULL COMMENT '	报案号	',
+LossTime	date	DEFAULT NULL COMMENT '	损失发生时间	',
+RPID	string	DEFAULT NULL COMMENT '	报案人	',
+RPName	string	DEFAULT NULL COMMENT '	报案人名称	',
+RPPhone	string	DEFAULT NULL COMMENT '	报案人电话	',
+LPID	string	DEFAULT NULL COMMENT '	出险人	',
+LPName	string	DEFAULT NULL COMMENT '	出险人名称	',
+CNDate	DATE	DEFAULT NULL COMMENT '	报案日期	',
+LossDescribe	string	DEFAULT NULL COMMENT '	损失原因	',
+CRDate	DATE	DEFAULT NULL COMMENT '	立案日期	',
+CNDescribe	string	DEFAULT NULL COMMENT '	报案描述	',
+ClaimStatus	string	DEFAULT NULL COMMENT '	理赔状态	',
+CSDate	DATE	DEFAULT NULL COMMENT '	理赔状态日期	',
+RelationShip	string	DEFAULT NULL COMMENT '	报案人与出险人关系	',
+CCNo1	string	DEFAULT NULL COMMENT '	赔案号1	',
+CCStatus1	string	DEFAULT NULL COMMENT '	赔案状态1	',
+CCSDate1	DATE	DEFAULT NULL COMMENT '	赔案状态日期1	',
+ProductID1	string	DEFAULT NULL COMMENT '	险种代码1	',
+CCAMT1	double	DEFAULT NULL COMMENT '	赔付金额1	',
+CCNo2	string	DEFAULT NULL COMMENT '	赔案号2	',
+CCStatus2	string	DEFAULT NULL COMMENT '	赔案状态2	',
+CCSDate2	DATE	DEFAULT NULL COMMENT '	赔案状态日期2	',
+ProductID2	string	DEFAULT NULL COMMENT '	险种代码2	',
+CCAMT2	double	DEFAULT NULL COMMENT '	赔付金额2	',
+BranchCode	string	DEFAULT NULL COMMENT '	机构代码	',
+ClaimCaseStatus	string	DEFAULT NULL COMMENT '	案件状态	',
+CREATED_BY	string	DEFAULT NULL COMMENT '	创建人	',
+CREATED_TIME	date	DEFAULT NULL COMMENT '	创建时间	',
+UPDATED_BY	string	DEFAULT NULL COMMENT '	更新人	',
+UPDATED_TIME date DEFAULT NULL COMMENT '	更新时间	'
+)
+COMMENT '保险理赔'
+stored as ES
+with shard number 10
+replication 1;
+
+DROP TABLE IF EXISTS shanglifeecif.Payment;
+CREATE  TABLE shanglifeecif.Payment(
+CREATED_BY	string	DEFAULT NULL COMMENT '	创建人	',
+CREATED_TIME	date	DEFAULT NULL COMMENT '	创建时间	',
+UPDATED_BY	string	DEFAULT NULL COMMENT '	更新人	',
+UPDATED_TIME	date	DEFAULT NULL COMMENT '	更新时间	',
+PaymentID	string	DEFAULT NULL COMMENT '	收付交易 ID	',
+IndID	string	DEFAULT NULL COMMENT '	个人ID	',
+PlolicyNo	string	DEFAULT NULL COMMENT '	保险单号	',
+PaymentReason	string	DEFAULT NULL COMMENT '	收付原因	',
+PaymentItem	string	DEFAULT NULL COMMENT '	收付项目	',
+PaymentChannel	string	DEFAULT NULL COMMENT '	收付方式	',
+BankAccNo	string	DEFAULT NULL COMMENT '	银行账号	',
+Currency	string	DEFAULT NULL COMMENT '	币种	',
+SOPayment	double	DEFAULT NULL COMMENT '	收付金额	',
+IndName	string	DEFAULT NULL COMMENT '	个人名称	',
+IndPhone	string	DEFAULT NULL COMMENT '	个人手机	',
+IndIDCard	string	DEFAULT NULL COMMENT '	个人证件号码	',
+DOPPayment	DATE	DEFAULT NULL COMMENT '	计划收付日期	',
+DOAPayment	DATE	DEFAULT NULL COMMENT '	实付日期	'
+)
+COMMENT '收付交易'
+stored as ES
+with shard number 10
+replication 1;
+
+DROP TABLE IF EXISTS shanglifeecif.InsuranceAccount;
+CREATE  TABLE shanglifeecif.InsuranceAccount(
+CREATED_BY	string	DEFAULT NULL COMMENT '	创建人	',
+CREATED_TIME	date	DEFAULT NULL COMMENT '	创建时间	',
+UPDATED_BY	string	DEFAULT NULL COMMENT '	更新人	',
+UPDATED_TIME	date DEFAULT NULL COMMENT '	更新时间	',
+IAccID	string	DEFAULT NULL COMMENT '	保险账户ID	',
+IndID	string	DEFAULT NULL COMMENT '	个人ID	',
+IndName	string	DEFAULT NULL COMMENT '	个人名称	',
+IndPhone	string	DEFAULT NULL COMMENT '	个人手机	',
+IndIDCard	string	DEFAULT NULL COMMENT '	个人证件号码	',
+RegDate	DATE	DEFAULT NULL COMMENT '	开户日期	',
+UnRegDate	DATE	DEFAULT NULL COMMENT '	销户日期	',
+IAccName	string	DEFAULT NULL COMMENT '	保险账户名称	',
+IAccType	string	DEFAULT NULL COMMENT '	保险账户类型	',
+IAccStatus	string	DEFAULT NULL COMMENT '	保险账户状态	',
+FixedRate	double	DEFAULT NULL COMMENT '	固定利率	',
+AccCDate	DATE	DEFAULT NULL COMMENT '	账户变动日期	',
+AccBalance	double	DEFAULT NULL COMMENT '	账户余额	',
+FrozenCapital	double	DEFAULT NULL COMMENT '	冻结余额	',
+OutstdInterest	double	DEFAULT NULL COMMENT '	未结算利息	',
+LBdate	DATE	DEFAULT NULL COMMENT '	上次结算日期	',
+LABalance	double	DEFAULT NULL COMMENT '	上次结算余额	',
+InterestType	string	DEFAULT NULL COMMENT '	计息类型	',
+SettlementCycle	INT	DEFAULT NULL COMMENT '	结算周期	',
+SettlementTime	date	DEFAULT NULL COMMENT '	结算时点	',
+SettlementType	string	DEFAULT NULL COMMENT '	结算类型	'
+)
+COMMENT '保险账户'
+stored as ES
+with shard number 10
+replication 1;
+
+DROP TABLE IF EXISTS shanglifeecif.PartyLabel;
+CREATE  TABLE shanglifeecif.PartyLabel(
+CREATED_BY	string	DEFAULT NULL COMMENT '	创建人	',
+CREATED_TIME	date	DEFAULT NULL COMMENT '	创建时间	',
+UPDATED_BY	string	DEFAULT NULL COMMENT '	更新人	',
+UPDATED_TIME	date	DEFAULT NULL COMMENT '	更新时间	',
+LabelID	string	DEFAULT NULL COMMENT '	标签ID	',
+PartyID	string	DEFAULT NULL COMMENT '	参与方ID	',
+LabelName	string	DEFAULT NULL COMMENT '	标签名称	',
+LabelDescribe	string	DEFAULT NULL COMMENT '	标签描述	',
+LabelType	string	DEFAULT NULL COMMENT '	标签类别	',
+LabelLevel	INT	DEFAULT NULL COMMENT '	标签层级	',
+LCDate	date	DEFAULT NULL COMMENT '	标签创建BrancheCode日期	',
+LabelStatus	string	DEFAULT NULL COMMENT '	标签状态	',
+AuthorID	string	DEFAULT NULL COMMENT '	标签创建人	',
+BrancheCode	string	DEFAULT NULL COMMENT '	机构代码	',
+PartyName	string	DEFAULT NULL COMMENT '	参与方名称	',
+PartyIDNumber	string	DEFAULT NULL COMMENT '	参与方证件号码	',
+PartyPhone	string	DEFAULT NULL COMMENT '	参与方电话	',
+LabelCode	string	DEFAULT NULL COMMENT '	标签生成逻辑	'
+)
+COMMENT '参与方标签'
+stored as ES
+with shard number 10
+replication 1;
+
+DROP TABLE IF EXISTS shanglifeecif.MergeRelationship;
+CREATE  TABLE shanglifeecif.MergeRelationship(
+CREATED_BY	string	DEFAULT NULL COMMENT '	创建人	',
+CREATED_TIME	date	DEFAULT NULL COMMENT '	创建时间	',
+UPDATED_BY	string	DEFAULT NULL COMMENT '	更新人	',
+UPDATED_TIME	date	DEFAULT NULL COMMENT '	更新时间	',
+MRSID	string	DEFAULT NULL COMMENT '	合并关系ID	',
+Party1ID	string	DEFAULT NULL COMMENT '	合并方	',
+Party2ID	string	DEFAULT NULL COMMENT '	被合并方	',
+Party1Name	string	DEFAULT NULL COMMENT '	合并方名称	',
+Party1IDCard	string	DEFAULT NULL COMMENT '	合并方证件号码	',
+Party1Phone	string	DEFAULT NULL COMMENT '	合并方电话	',
+Party2Name	string	DEFAULT NULL COMMENT '	被合并方名称	',
+Party2IDCard	string	DEFAULT NULL COMMENT '	被合并方证件号码	',
+Party2Phone	string	DEFAULT NULL COMMENT '	被合并方电话	',
+MergeDate	date	DEFAULT NULL COMMENT '	合并日期	',
+MergeMethod	string	DEFAULT NULL COMMENT '	合并方式	',
+MergeAuditorID	string	DEFAULT NULL COMMENT '	合并批准人	',
+MergeAuditorName	string	DEFAULT NULL COMMENT '	合并批准人名称	',
+Party1Backup	string	DEFAULT NULL COMMENT '	合并方备份	',
+MRSStatus	string	DEFAULT NULL COMMENT '	合并关系状态	'
+)
+COMMENT '参与方合并关系'
+stored as ES
+with shard number 10
+replication 1;
+
+DROP TABLE IF EXISTS shanglifeecif.PartyTimeLine;
+CREATE  TABLE shanglifeecif.PartyTimeLine(
+CREATED_BY	string	DEFAULT NULL COMMENT '	创建人	',
+CREATED_TIME	date	DEFAULT NULL COMMENT '	创建时间	',
+UPDATED_BY	string	DEFAULT NULL COMMENT '	更新人	',
+UPDATED_TIME	date	DEFAULT NULL COMMENT '	更新时间	',
+TripID	string	DEFAULT NULL COMMENT '	旅程ID	',
+PartyID	string	DEFAULT NULL COMMENT '	参与方ID	',
+Name	string	DEFAULT NULL COMMENT '	参与方名称	',
+PCertID	string	DEFAULT NULL COMMENT '	参与方证件号码	',
+PPhone	string	DEFAULT NULL COMMENT '	参与方手机	',
+PRole	string	DEFAULT NULL COMMENT '	参与方角色	',
+Scenario	string	DEFAULT NULL COMMENT '	场景	',
+SDate	date	DEFAULT NULL COMMENT '	发生日期	',
+ThreadID	string	DEFAULT NULL COMMENT '	关联ID	',
+ParentID	string	DEFAULT NULL COMMENT '	父ID	',
+Describe	string	DEFAULT NULL COMMENT '	描述	',
+Channel	string	DEFAULT NULL COMMENT '	来源	'
+)
+COMMENT '参与方事件'
+stored as ES
+with shard number 10
+replication 1;