存储过程sql完善

sql-achievement/存储过程/人寿测试环境使用sql整理/保单件数分布统计.sql

@@ -13,14 +13,14 @@ BEGIN
 	--第一步 更新 Individual.NOVPolicy 有效记录数
 	UPDATE shanglifeecif.Individual si1 SET si1.NOVPolicy = (SELECT nvl(t.cnum,0) FROM (
 		SELECT temp.customerno,count(*) AS cnum FROM (
-			SELECT max(p.customerno) customerno,p.contno FROM policy_information p WHERE p.appflag = '有效' GROUP BY p.contno 
+			SELECT max(p.customerno) customerno,p.contno FROM dsj.policy_information p WHERE p.appflag = '有效' GROUP BY p.contno 
 		) temp GROUP BY temp.customerno
 	) t WHERE t.customerno =  si1.scustid); 
 	
 	--第二步 更新 Individual.NOIVPolicy 无效记录数
 	UPDATE shanglifeecif.Individual si1 SET si1.noivpolicy = (SELECT nvl(t.cnum,0) FROM (
 			SELECT temp.customerno,count(*) AS cnum FROM (
-			SELECT max(p.customerno) customerno,p.contno FROM policy_information p WHERE p.appflag <> '有效' GROUP BY p.contno 
+			SELECT max(p.customerno) customerno,p.contno FROM dsj.policy_information p WHERE p.appflag <> '有效' GROUP BY p.contno 
 		) temp GROUP BY temp.customerno
 	) t WHERE t.customerno =  si1.scustid); 
 	
@@ -49,7 +49,9 @@ BEGIN
 	
 	EXCEPTION
 			WHEN HIVE_EXCEPTION THEN 
-				 INSERT INTO shanglifeecif.exception_log(log_code,log_msg,log_time) VALUES (sqlcode(),sqlerrm(),sysdate());
+				 INSERT INTO shanglifeecif.exception_log(log_id,log_code,log_msg,log_time) VALUES (to_char(sysdate(),'yyyyMMddHHmmss'),sqlcode(),sqlerrm(),sysdate());
 			WHEN Others THEN
-				INSERT INTO shanglifeecif.exception_log(log_code,log_msg,log_time) VALUES (sqlcode(),sqlerrm(),sysdate());	
+				INSERT INTO shanglifeecif.exception_log(log_id,log_code,log_msg,log_time) VALUES (to_char(sysdate(),'yyyyMMddHHmmss'),sqlcode(),sqlerrm(),sysdate());	
+
+
 END	;

sql-achievement/存储过程/人寿测试环境使用sql整理/参与方事件.sql

@@ -14,7 +14,7 @@ BEGIN
 		created_by ,
 		created_time 
 	) select 
-   		row_number()over(),
+   		reflect("java.util.UUID", "randomUUID"),
    		trim(contno) as contno,
    		trim(max(customerno)) as customerno,
    		trim(max(name)) as name,

sql-achievement/存储过程/人寿测试环境使用sql整理/客户标签20210409预生产.sql

@@ -312,11 +312,11 @@ BEGIN
 	);
 	--48	是否有失效保单	Label44	有失效保单	NOIVPolicy	客户为保单投保人，持有保单中保单状态为失效 （最新文档逻辑）
 		UPDATE shanglifeecif.Individual si1 SET si1.label44 = '有失效保单' WHERE si1.scustid IN (
-		SELECT p.customerno FROM dsj.policy_information p WHERE p.contno IN (select contno from dsj.lccontstate where statetype = 'Available' and state = '1') 
+		SELECT p.customerno FROM dsj.policy_information p WHERE p.appflag <> '有效' and p.contno IN (select contno from dsj.lccontstate where statetype = 'Available' and state = '1') 
 	);
 	--49	是否有缴费期满长险保单	Label45	有缴费期满长险保单	POLICY_INFORMATION:paycount= payendyear AND riskperiod='长期险'	客户持有保险期限为一年以上，剩余保费期数为0
 		UPDATE shanglifeecif.Individual si1 SET si1.label45 = '有缴费期满长险保单' WHERE si1.scustid IN (
-		SELECT p.customerno FROM dsj.policy_information p WHERE p.appflag = '有效' and p.paycount = p.payendyear AND riskperiod='长期险'	
+		SELECT p.customerno FROM dsj.policy_information p WHERE p.appflag = '有效' and p.paycount = p.payendyear AND p.riskperiod='长期险'	
 	);
 	--50	是否有续期缴费的保单	Label46	有续期缴费的保单		客户为投保人，含有待缴费状态的保单
 		UPDATE shanglifeecif.Individual si1 SET si1.label46 = '有续期缴费保单' WHERE si1.scustid IN (
@@ -326,9 +326,7 @@ BEGIN
 	);
 	--51	有责任期满的保单	Label47	有责任期满的保单		客户持有保单含有保险期限已满的保单
 		UPDATE shanglifeecif.Individual si1 SET si1.label47 = '有责任期满的保单' WHERE si1.scustid IN (
-		SELECT p.customerno FROM dsj.policy_information p WHERE p.appflag = '有效' and p.contno IN (
-			select contno from dsj.lcpol where enddate < SYSDATE
-		) 
+		SELECT p.customerno FROM dsj.policy_information p WHERE p.enddate < to_char(SYSDATE,"yyyy-MM-dd HH:mm:ss.S")
 	);
 		
 	--52	第一张保单投保日期	Label48	首次投保日期XXXX-XX-XX	FADate	客户所有保单中投保时间最早的日期
@@ -345,7 +343,7 @@ BEGIN
 			) t WHERE t.insuredno = si1.scustid
 	);
 	
-	UPDATE shanglifeecif.Individual si1 SET si1.label48 = '首次投保日期' ||  to_char(si1.fadate, 'yyyy-MM-dd')  WHERE si1.fadate IS NOT NULL;
+	UPDATE shanglifeecif.Individual si1 SET si1.label48 = '首次投保日期'||  to_char(si1.fadate, 'yyyy-MM-dd')  WHERE si1.fadate IS NOT NULL;
 
 	--53	最后一次寿险投保距今时长	Label49	最后一次投保距今XXX天	LAPPDate	当前日期减去客户所有保单中最后一次投保的保单的投保时间
 	UPDATE shanglifeecif.Individual si1 SET si1.LAPPDate = (
@@ -398,6 +396,7 @@ BEGIN
 
 	--UPDATE shanglifeecif.Individual si1 SET si1.Label53 =  '最近机构' || si1.Label53 WHERE si1.Label53 IS NOT NULL;
 	--58	最近保单状态	Label54	"未承保承保新增附加险终止续保未对账对账失败"	LPState	客户最后一张保单的保单状态
+	/*
 	UPDATE shanglifeecif.Individual si1 SET si1.label54 = 
 	(SELECT 
 		(CASE temp.appflag 
@@ -412,10 +411,18 @@ BEGIN
 	FROM (
 		SELECT t.appflag,p.customerno,row_number()OVER(PARTITION BY p.customerno ORDER BY p.polapplydate desc) rd FROM dsj.policy_information p,dsj.lccont t WHERE p.contno = t.contno
 	) temp WHERE temp.rd = 1  AND si1.scustid = temp.customerno);
+	*/
+	UPDATE shanglifeecif.Individual si1 SET si1.label54 = (
+		SELECT '最近保单状态'||trim(t.appflag) FROM (
+			SELECT row_number()OVER(PARTITION BY p.customerno ORDER BY p.polapplydate DESC) rd,p.customerno,p.appflag FROM dsj.policy_information p
+		) t WHERE t.rd = 1 AND si1.scustid = t.customerno
+	);
 	
+	--	最近一次保全类型	label55	客户最后一次办理保全业务的业务类型	
+
 	UPDATE shanglifeecif.Individual si1 SET si1.label55 = (
 	SELECT 
-		CASE t.edortype
+		'最近一次保全类型'||CASE t.edortype
 			WHEN 'AE' THEN '投保人变更'
 			WHEN 'AM' THEN '客户联系方式变更'
 			WHEN 'AP' THEN '自垫选择权变更'
@@ -513,16 +520,23 @@ BEGIN
 	(SELECT p.customerno FROM dsj.policy_information p,dsj.lmriskapp l WHERE p.appflag = '有效' and p.riskcode = l.riskcode AND l.bonusflag = 1);
 	
 	--69	一单寿险客户	Label65	一单寿险客户	客户仅购买了一张保单，且保单类型为寿险型保单
-	UPDATE shanglifeecif.Individual si1 SET si1.label65 = '一单寿险客户' WHERE si1.scustid IN (SELECT t.customerno FROM (
-		SELECT count(*) AS pnum,p.customerno FROM dsj.POLICY_INFORMATION p 
-	LEFT JOIN dsj.riskkind b on p.riskcode = b.riskcode
-	WHERE (b.kindtype = '新型寿险' or b.kindtype = '人寿保险') and p.appflag = '有效' GROUP BY p.customerno
-	) t WHERE t.pnum = 1);
-	--70	缴费期满客户	Label66	缴费期满客户	POLICY_INFORMATION:paycount= payendyear	客户缴费期数已满
-	UPDATE shanglifeecif.Individual si1 SET si1.label66 = '缴费期满客户' WHERE si1.scustid IN (SELECT t.customerno FROM (
+	UPDATE shanglifeecif.Individual si1 SET si1.label65 = '一单寿险客户' WHERE si1.scustid IN (SELECT temp.customerno FROM (
+		SELECT pi.customerno,count(*) AS tnum,max(t.pnum) AS pnum FROM (
 			SELECT count(*) AS pnum,p.customerno FROM dsj.POLICY_INFORMATION p 
-		WHERE p.appflag = '有效' and p.paycount = p.payendyear GROUP BY p.customerno
-		) t WHERE t.pnum > 0);
+		LEFT JOIN dsj.riskkind b on p.riskcode = b.riskcode
+		WHERE (b.kindtype = '新型寿险' or b.kindtype = '人寿保险') GROUP BY p.customerno
+		) t LEFT JOIN dsj.POLICY_INFORMATION pi ON pi.customerno = t.customerno
+		GROUP BY pi.customerno
+	)temp WHERE temp.tnum = temp.pnum AND tnum = 1);
+	--70	缴费期满客户	Label66	缴费期满客户	POLICY_INFORMATION:paycount= payendyear	客户缴费期数已满
+	UPDATE shanglifeecif.Individual si1 SET si1.label66 = '缴费期满客户' WHERE si1.scustid IN (
+		SELECT temp.customerno FROM (
+		SELECT count(*) AS tnum,max(t.customerno) AS customerno,max(t.pnum) AS pnum FROM (
+		SELECT p.customerno,count(*) AS pnum FROM  dsj.policy_information p WHERE p.paycount = p.payendyear  GROUP BY p.customerno 
+		) t LEFT JOIN dsj.policy_information pi ON pi.customerno = t.customerno
+		GROUP BY pi.customerno
+		) temp WHERE temp.tnum = temp.pnum
+	);
 	--71	生日与司庆日同一天客户	Label67	生日与司庆日同天	2月15号 为司庆日	客户生日和公司司庆日为同一天
 	UPDATE shanglifeecif.Individual si1 SET si1.Label67 = '生日与司庆日同天' where si1.birthday like '%-02-15%';	
 	--72	持有有效保单产品类型客户标签	Label68	持有有效保单，未持有有效保单		客户名下是否有投保人为自己的有效保单
@@ -543,7 +557,30 @@ BEGIN
 						END
 						) where 1 = 1;	
 	--74	最近接触业务类型	Label70	最近投诉、最近问询（咨询）、最近营销、最近理赔、最近出险、最近保全	Individual.LCType	客户最后一次接触的业务类型
+	
+	UPDATE shanglifeecif.Individual si1 SET si1.Label70 = (
+	SELECT '最近'||t.scenario FROM (
+	SELECT 
+	row_number()OVER(PARTITION BY pl.partyid ORDER BY pl.sdate desc) rn,
+	pl.partyid,
+	pl.scenario
+	FROM shanglifeecif.partytimeline pl WHERE pl.partyid IS NOT NULL
+) t WHERE t.rn = 1 AND si1.scustid = t.partyid
+);
+
+	
 	--75	最近接触方式	Label71	最近外呼、最近呼入、微信	Individual.LCMethod	客户最后一次接触的方式
+	UPDATE shanglifeecif.Individual si1 SET si1.Label71 = (
+	SELECT '最近'||CASE t.scenario WHEN '回访' THEN '外呼' WHEN '咨询' THEN '呼入' END FROM (
+	SELECT 
+	row_number()OVER(PARTITION BY pl.partyid ORDER BY pl.sdate desc) rn,
+	pl.partyid,
+	pl.scenario
+	FROM shanglifeecif.partytimeline pl WHERE pl.partyid IS NOT NULL AND (pl.scenario = '回访' OR pl.scenario = '咨询')
+) t WHERE t.rn = 1 AND si1.scustid = t.partyid
+);
+	
+	
 	--77	是否关注官微	Label73	关注官微	无	0
 	--UPDATE shanglifeecif.Individual si1 SET si1.Label73 = '关注官微'
 	--WHERE si1.idcard IN (SELECT a.certificate_no FROM account a) 
@@ -553,11 +590,12 @@ BEGIN
 
 	--78	是否注册官微	Label74	注册官微	无	0
 	UPDATE shanglifeecif.Individual si1 SET si1.Label74 = '注册官微'
-	WHERE si1.idcard IN (SELECT a.certificate_no FROM account a WHERE a.account_status = 0) 
-		OR si1.passport IN (SELECT a.certificate_no FROM account a WHERE a.account_status = 0) 
-		OR si1.Dlicense IN  (SELECT a.certificate_no FROM account a WHERE a.account_status = 0) 
-		OR si1.othernumber IN (SELECT a.certificate_no FROM account a WHERE a.account_status = 0);
+	WHERE si1.idcard IN (SELECT a.certificate_no FROM dsj.account a WHERE a.account_status = 0) 
+		OR si1.passport IN (SELECT a.certificate_no FROM dsj.account a WHERE a.account_status = 0) 
+		OR si1.Dlicense IN  (SELECT a.certificate_no FROM dsj.account a WHERE a.account_status = 0) 
+		OR si1.othernumber IN (SELECT a.certificate_no FROM dsj.account a WHERE a.account_status = 0);
 		
+
 		
 	--	本人生日提醒	Label77	本人生日临近		客户生日-当前日期<5
 	--UPDATE shanglifeecif.Individual si1 SET si1.label77 = '本人生日临近' WHERE DATEDIFF(to_char(SYSDATE,"2021-MM-dd"),to_char(si1.birthday,"2021-MM-dd"))<=5 AND 
@@ -566,13 +604,13 @@ BEGIN
 		DATEDIFF(to_char(si1.birthday,"2021-MM-dd"),to_char(SYSDATE,"2021-MM-dd"))>0;
 
 	UPDATE shanglifeecif.Individual si1 SET si1.label78 = '父母生日临近' WHERE si1.scustid IN (
-	SELECT si.scustid FROM shanglifeecif.indrelationship sis LEFT JOIN shanglifeecif.individual si ON sis.indid1 = si.scustid
+	SELECT sis.indid1 FROM shanglifeecif.indrelationship sis LEFT JOIN shanglifeecif.individual si ON sis.indid2 = si.scustid
 		WHERE sis.rstype = '父母' AND DATEDIFF(to_char(si.birthday,"2021-MM-dd"),to_char(SYSDATE,"2021-MM-dd"))<=5 AND 
 		DATEDIFF(to_char(si.birthday,"2021-MM-dd"),to_char(SYSDATE,"2021-MM-dd"))>0
-);
+	);
 
 	UPDATE shanglifeecif.Individual si1 SET si1.label79 = '子女生日临近' WHERE si1.scustid IN (
-		SELECT si.scustid FROM shanglifeecif.indrelationship sis LEFT JOIN shanglifeecif.individual si ON sis.indid1 = si.scustid
+		SELECT sis.indid1 FROM shanglifeecif.indrelationship sis LEFT JOIN shanglifeecif.individual si ON sis.indid2 = si.scustid
 			WHERE sis.rstype = '子女' AND DATEDIFF(to_char(si.birthday,"2021-MM-dd"),to_char(SYSDATE,"2021-MM-dd"))<=5 AND 
 			DATEDIFF(to_char(si.birthday,"2021-MM-dd"),to_char(SYSDATE,"2021-MM-dd"))>0
 	);
@@ -590,7 +628,20 @@ BEGIN
 		SELECT rm.contnos FROM dsj.cc_record_main rm WHERE rm.reasonsecondname LIKE '%理赔%'
 		and rm.contnos IS not NULL AND DATEDIFF(SYSDATE,rm.starttime) < 7)
 	);
-			
+	
+	--75	续期临期未缴费	label88	续期缴费期到宽限期未交费，续期缴费日期-当前日期<5	续期临期未缴费	
+	
+	UPDATE shanglifeecif.Individual si1 SET si1.Label88 = '续期临期未缴费' WHERE si1.scustid IN (
+		SELECT p.customerno FROM dsj.policy_information p WHERE p.appflag = '有效'AND p.payintv = '期缴' AND p.payendyear<>p.paycount  AND 
+		DATEDIFF(p.paytodate,to_char(SYSDATE,'yyyy-MM-dd HH:mm:ss.S')) > 0 and DATEDIFF(p.paytodate,to_char(SYSDATE,'yyyy-MM-dd HH:mm:ss.S')) < 5
+	);
+	--76	续期到期未缴费	label89	过了续期宽限期，仍未缴费	续期到期未缴费	
+	UPDATE shanglifeecif.Individual si1 SET si1.Label89 = '续期到期未缴费' WHERE si1.scustid IN (
+		SELECT p.customerno FROM dsj.policy_information p WHERE p.appflag = '有效'AND p.payintv = '期缴' AND p.payendyear<>p.paycount  AND 
+		to_char(SYSDATE,'yyyy-MM-dd HH:mm:ss.S') > DATE_ADD(p.paytodate, 60)
+	);
+
+		
 	--93	失效客户	Label91	失效客户	所有保单都是失效状态	客户名下所有保单均失效的客户
 	UPDATE shanglifeecif.Individual si1 SET si1.Label91 = '失效客户' WHERE si1.scustid IN (SELECT temp.customerno FROM (
 	SELECT count(*) AS tnum,max(t.customerno) AS customerno,max(t.pnum) AS pnum FROM (
@@ -599,6 +650,13 @@ BEGIN
 	GROUP BY pi.customerno
 	) temp WHERE temp.tnum = temp.pnum);
 	
+	--	终止客户	label93	客户的所有保单缴费期满且承保期限已满正常终止的客户	终止客户	
+	UPDATE shanglifeecif.Individual si1 SET si1.Label93 = '终止客户' WHERE si1.scustid IN (SELECT temp.customerno FROM (
+	SELECT count(*) AS tnum,max(t.customerno) AS customerno,max(t.pnum) AS pnum FROM (
+	SELECT p.customerno,count(*) AS pnum FROM  dsj.policy_information p WHERE p.appflag = '终止' AND p.enddate < to_char(SYSDATE,'yyyy-MM-dd HH:mm:ss.S') GROUP BY p.customerno 
+	) t LEFT JOIN dsj.policy_information pi ON pi.customerno = t.customerno
+	GROUP BY pi.customerno
+	) temp WHERE temp.tnum = temp.pnum);
 	
 	--98	大龄	Label96	大龄 来电客户年龄50岁以上
 	UPDATE shanglifeecif.Individual si1 SET si1.Label96 = '大龄'  where si1.scustid IN (
@@ -641,47 +699,67 @@ BEGIN
 	UPDATE shanglifeecif.Individual si1 SET si1.Label103 = '要求较多' WHERE si1.scustid IN (
 		SELECT p.customerno FROM dsj.policy_information p WHERE p.contno IN (
 			SELECT temp.policyno FROM (
-				SELECT max(t.mnum) AS mnum,f.policyno,count(*) AS fnum,(count(*)/max(t.mnum)) FROM (
-					SELECT count(*) AS mnum,m.contnos FROM dsj.cc_record_main m WHERE m.contnos IS NOT null
-					GROUP BY m.contnos
-					) t LEFT JOIN dsj.cc_swfflowmain f ON t.contnos = f.policyno
-					WHERE f.flowid LIKE 'ZX%' AND f.policyno IS NOT NULL
-					GROUP BY f.policyno
+				SELECT t.policyno,max(t.mnum) mnum,max(t.fnum) fnum FROM (
+					SELECT m.contnos policyno,count(*) AS mnum,'' AS fnum FROM dsj.cc_record_main m WHERE m.contnos IS NOT NULL GROUP BY m.contnos
+					UNION 
+					SELECT f.policyno,'' AS mnum,count(*) AS fnum FROM  dsj.cc_swfflowmain f WHERE f.modelno = 1 GROUP BY f.policyno 
+				)t GROUP BY t.policyno
 			) temp WHERE (temp.fnum/temp.mnum)>0.7
-		)
+		) 
 	);
 	--106	易投诉升级	Label104	易投诉升级	"flowid like'ZX%'转办标志 Z select (select r.idname from cc_swf_sort r where r.id=f.complaintProject and r.idname='投诉') as swfName --from cc_swfflowmain f where f.policyno='2020021500000456' and flowid like'ZX%'"	咨询转办单项目为投诉
- UPDATE shanglifeecif.Individual si1 SET si1.Label104 = (SELECT "易投诉升级" FROM (
-
-	SELECT p.customerno,row_number()OVER(PARTITION BY p.customerno) rn
-	FROM (
-	SELECT max(t.mnum) AS mnum,f.policyno,count(*) AS fnum FROM (
-	SELECT count(*) AS mnum,m.contnos FROM dsj.cc_record_main m WHERE m.contnos IS NOT null
-	GROUP BY m.contnos
-	) t LEFT JOIN dsj.cc_swfflowmain f ON t.contnos = f.policyno
-	LEFT JOIN dsj.cc_swf_sort r ON r.id=f.complaintProject
-	WHERE f.flowid LIKE 'ZX%' AND r.idname='投诉' and f.policyno IS NOT NULL
-	GROUP BY f.policyno
-	) temp LEFT JOIN dsj.policy_information p ON temp.policyno = p.contno
-	WHERE temp.fnum = temp.mnum
-) tt WHERE tt.rn = 1 AND tt.customerno IS NOT NULL AND si1.scustid = tt.customerno);
+	UPDATE shanglifeecif.Individual si1 SET si1.Label104 = '易投诉升级' WHERE si1.scustid IN (
+		SELECT p.customerno FROM dsj.policy_information p WHERE p.contno IN (
+			SELECT temp.policyno FROM (
+				SELECT t.policyno,max(t.mnum) mnum,max(t.fnum) fnum FROM (
+					SELECT m.contnos policyno,count(*) AS mnum,'' AS fnum FROM dsj.cc_record_main m WHERE m.contnos IS NOT NULL GROUP BY m.contnos
+					UNION 
+					SELECT f.policyno,'' AS mnum,count(*) AS fnum FROM  dsj.cc_swfflowmain f,dsj.cc_swf_sort r WHERE r.id=f.complaintProject and f.modelno = 1 AND r.idname='投诉' GROUP BY f.policyno 
+				)t GROUP BY t.policyno
+			) temp WHERE temp.mnum = temp.fnum
+		)
+	);
 	--107	高频投诉	Label105	高频投诉	"select count(1) from cc_action_data_complaints c where c.productno='2018110400035608'"	--半年之内来过两次以上投诉的，投诉受理日期间隔<180天，且投诉次数>2
-	UPDATE shanglifeecif.Individual si1 SET si1.Label105 = '高频投诉' WHERE si1.scustid in
-
-	(SELECT p.customerno FROM dsj.policy_information p WHERE p.contno IN 
-
-	(SELECT temp.productno FROM (
+	--UPDATE shanglifeecif.Individual si1 SET si1.Label105 = '高频投诉' WHERE si1.scustid in
+	--(SELECT p.customerno FROM dsj.policy_information p WHERE p.contno IN 
+	--(SELECT temp.productno FROM (
 		
-		SELECT t.productno,t.sinserttime,
-		(SELECT tt.inserttime FROM (SELECT cad.inserttime,row_number()OVER(PARTITION BY cad.productno ORDER BY cad.inserttime) rownum,cad.productno FROM dsj.cc_action_complaints ca,dsj.cc_action_data_complaints cad 
-			WHERE  cad.complaintsid=ca.complaintsid AND cad.productno IS NOT NULL) tt WHERE tt.productno = t.productno AND tt.rownum = t.rn+1) AS esinserttime
-			 FROM 
-			(
-				select cd.productno,row_number()OVER(PARTITION BY cd.productno ORDER BY cd.inserttime) rn,cd.inserttime AS sinserttime
-				from dsj.cc_action_complaints c,dsj.cc_action_data_complaints cd WHERE  cd.complaintsid=c.complaintsid AND cd.productno IS NOT NULL
-			) t
-	) temp WHERE temp.esinserttime IS NOT NULL AND DATEDIFF(temp.esinserttime,temp.sinserttime) < 180));
-    
+		--SELECT t.productno,t.sinserttime,
+		--(SELECT tt.inserttime FROM (SELECT cad.inserttime,row_number()OVER(PARTITION BY cad.productno ORDER BY cad.inserttime) rownum,cad.productno FROM dsj.cc_action_complaints --ca,dsj.cc_action_data_complaints cad 
+			--WHERE  cad.complaintsid=ca.complaintsid AND cad.productno IS NOT NULL) tt WHERE tt.productno = t.productno AND tt.rownum = t.rn+1) AS esinserttime
+			-- FROM 
+			--(
+			--	select cd.productno,row_number()OVER(PARTITION BY cd.productno ORDER BY cd.inserttime) rn,cd.inserttime AS sinserttime
+			--	from dsj.cc_action_complaints c,dsj.cc_action_data_complaints cd WHERE  cd.complaintsid=c.complaintsid AND cd.productno IS NOT NULL
+			--) t
+	--) temp WHERE temp.esinserttime IS NOT NULL AND DATEDIFF(temp.esinserttime,temp.sinserttime) < 180));
+    UPDATE shanglifeecif.Individual si1 SET si1.Label105 = '高频投诉' WHERE si1.scustid in (
+		SELECT t.customerno FROM (
+			SELECT 
+					row_number()OVER(PARTITION BY t1.customerno ORDER BY ca.inserttime) rownum,
+					t1.customerno,
+					t1.contno,
+					ca.inserttime FROM (
+				SELECT 
+					max(p.customerno) customerno,
+					p.contno
+				FROM dsj.policy_information p GROUP BY p.contno
+			) t1 LEFT JOIN dsj.cc_action_complaints ca ON t1.contno = ca.productnos
+			
+		) t LEFT JOIN (
+				SELECT 
+					row_number()OVER(PARTITION BY t1.customerno ORDER BY ca.inserttime) rownum,
+					t1.customerno,
+					t1.contno,
+					ca.inserttime FROM (
+				SELECT 
+					max(p.customerno) customerno,
+					p.contno
+				FROM dsj.policy_information p GROUP BY p.contno
+			) t1 LEFT JOIN dsj.cc_action_complaints ca ON t1.contno = ca.productnos
+		) tt ON t.customerno = tt.customerno AND t.rownum = tt.rownum+1
+		WHERE  DATEDIFF(tt.inserttime,t.inserttime) < 180
+	);
     
     --SELECT c.productno,c.inserttime FROM cc_action_data_complaints c  WHERE c.productno IS NOT NULL GROUP BY c.productno
 	--108	重大投诉影响	Label106	重大投诉影响	投诉来源	投诉来源是保监局、保监会、媒体转办的
@@ -705,7 +783,7 @@ BEGIN
 		         when '916' then '同业公会'
 		         when '917' then '其他转办'
 		         when '918' then '呼出'
-		         else c.complaintsSource END),',') as complaintsSource,p.contno from dsj.cc_action_complaints c,dsj.cc_action_data_complaints cd,policy_information p
+		         else c.complaintsSource END),',') as complaintsSource,p.contno from dsj.cc_action_complaints c,dsj.cc_action_data_complaints cd,dsj.policy_information p
 		         
 		where cd.complaintsid=c.complaintsid AND p.contno = cd.productno GROUP BY p.contno
 
@@ -724,30 +802,51 @@ BEGIN
 		WHERE si1.scustid IN (SELECT p.customerno FROM dsj.policy_information p WHERE 
 		p.appflag = '有效' AND p.payintv = '期缴' and
 		((p.salecom = '03' AND p.prem>50000) OR (p.salecom = '02' AND p.prem>20000) OR (p.salecom = '06' AND p.prem>20000)));
+		
+	--最近理赔结案	label108	最近15天做过理赔，当前日期-理赔结案日期<15天	最近理赔结案	
+	UPDATE shanglifeecif.Individual si1 SET si1.Label108 = '最近理赔结案' WHERE si1.scustid IN (
+		SELECT c.insuredno FROM dsj.INSURANCE_CLAIM c WHERE DATEDIFF(to_char(SYSDATE,'yyyy-MM-dd HH:mm:ss.S'),c.endcasedate) < 15
+	);	
 	--111	理赔报案追踪	Label109	理赔报案追踪		理赔状态为报案状态，且理赔报案日-当前日期<30天
 	UPDATE shanglifeecif.Individual si1 SET si1.Label109 = '理赔报案追踪' WHERE si1.scustid IN (SELECT p.customerno FROM dsj.policy_information p WHERE p.appflag = '有效' and p.contno IN (SELECT c.CONTNO FROM dsj.insurance_claim c WHERE c.LLCLAIMSTATE = '报案' AND DATEDIFF(sysdate(), c.RPTDATE) <30) );
 	--112	理赔处理中	Label110	理赔处理中		理赔状态为受理或立案
 	UPDATE shanglifeecif.Individual si1 SET si1.label110 = '理赔处理中' WHERE si1.scustid IN (
 		SELECT p.customerno FROM dsj.policy_information p WHERE p.appflag = '有效' and p.contno IN (SELECT c.contno FROM dsj.INSURANCE_CLAIM c WHERE c.llclaimstate = '受理' OR c.llclaimstate = '立案')
 	);
+	
+	--最近保全完成	label111	最近15天做过保全，来电日期-保全申请日期<15天	最近保全完成	
+
+	UPDATE shanglifeecif.Individual si1 SET si1.Label111 = '最近保全完成' WHERE si1.scustid IN (
+	SELECT p.customerno FROM dsj.policy_information p WHERE p.contno IN (
+		SELECT e.contno FROM dsj.edorinfo e WHERE DATEDIFF(to_char(SYSDATE,'yyyy-MM-dd HH:mm:ss.S'),e.edorappdate) < 15 AND e.eodrstate = '确认生效'
+	)
+);
 	--115	生存金未领	Label113	生存金未领	判断逻辑不详	生存金领取方式为自动转账、存在生存金且未领取
 	UPDATE shanglifeecif.Individual si1 SET si1.label113 = '生存金未领' WHERE si1.scustid IN (
 	SELECT p.customerno FROM dsj.policy_information p WHERE p.appflag = '有效' and p.contno IN (
-		SELECT contno FROM Lcinsureacc WHERE acctype = '005' and   insuaccbala>0
+		SELECT contno FROM dsj.Lcinsureacc WHERE acctype = '005' and   insuaccbala>0
 	) 
 );
 	--117	红利垫缴还款	Label115	红利垫缴还款	判断逻辑不详	存在红利，且红利已经垫交保单还款
-		UPDATE shanglifeecif.Individual si1 SET si1.label117 = '红利垫缴还款' WHERE si1.scustid IN (
+		UPDATE shanglifeecif.Individual si1 SET si1.label115 = '红利垫缴还款' WHERE si1.scustid IN (
 		SELECT p.customerno FROM dsj.policy_information p WHERE p.appflag = '有效' and p.contno IN (
 			SELECT contno FROM dsj.loloandetail WHERE moneytype='HLDKDK'
 		) 
 	);
+	--	宽限期	label117	宽限日末日-当前日期<3天	宽限期	
+	UPDATE shanglifeecif.Individual si1 SET si1.label117 = '宽限期' WHERE si1.scustid IN (
+
+	SELECT p.customerno FROM dsj.policy_information p WHERE p.payintv= '期缴' AND p.appflag='有效' AND p.payendyear!=p.paycount and 
+	DATEDIFF(DATE_ADD(p.paytodate, 60),to_char(SYSDATE,'yyyy-MM-dd HH:mm:ss.S')) < 3
+);
+	
 	--122	重点银行	Label120	重点银行	判断逻辑不详	保单的销售渠道网点为招商银行
 	UPDATE shanglifeecif.Individual si1 SET si1.Label120 = '重点银行' WHERE 
 	si1.scustid IN (SELECT p.customerno  FROM dsj.policy_information p WHERE p.AGENTCOM LIKE '%招商银行%');
 	EXCEPTION
 			WHEN HIVE_EXCEPTION THEN 
-				 INSERT INTO shanglifeecif.exception_log(log_code,log_msg,log_time) VALUES (sqlcode(),sqlerrm(),sysdate());
+				 INSERT INTO shanglifeecif.exception_log(log_id,log_code,log_msg,log_time) VALUES (to_char(sysdate(),'yyyyMMddHHmmss'),sqlcode(),sqlerrm(),sysdate());
 			WHEN Others THEN
-				INSERT INTO shanglifeecif.exception_log(log_code,log_msg,log_time) VALUES (sqlcode(),sqlerrm(),sysdate());	
+				INSERT INTO shanglifeecif.exception_log(log_id,log_code,log_msg,log_time) VALUES (to_char(sysdate(),'yyyyMMddHHmmss'),sqlcode(),sqlerrm(),sysdate());	
+
 END

sql-achievement/存储过程/人寿测试环境使用sql整理/年龄段性别分布统计.sql

@@ -24,7 +24,7 @@ BEGIN
 	) t;
 		EXCEPTION
 			WHEN HIVE_EXCEPTION THEN 
-				 INSERT INTO shanglifeecif.exception_log(log_code,log_msg,log_time) VALUES (sqlcode(),sqlerrm(),sysdate());
+				 INSERT INTO shanglifeecif.exception_log(log_id,log_code,log_msg,log_time) VALUES (to_char(sysdate(),'yyyyMMddHHmmss'),sqlcode(),sqlerrm(),sysdate());
 			WHEN Others THEN
-				INSERT INTO shanglifeecif.exception_log(log_code,log_msg,log_time) VALUES (sqlcode(),sqlerrm(),sysdate());		
+				INSERT INTO shanglifeecif.exception_log(log_id,log_code,log_msg,log_time) VALUES (to_char(sysdate(),'yyyyMMddHHmmss'),sqlcode(),sqlerrm(),sysdate());		
 END	;

sql-achievement/存储过程/人寿测试环境使用sql整理/最新目的表表结构.sql

@@ -586,3 +586,18 @@ COMMENT '
 stored as ES
 with shard number 10
 replication 1;
+
+
+DROP TABLE IF EXISTS shanglifeecif.surrenderprotectiontemp;
+CREATE  TABLE shanglifeecif.surrenderprotectiontemp(
+  tbid string DEFAULT NULL COMMENT '唯一标识', 
+  scustid string DEFAULT NULL COMMENT '退保客户号', 
+  tbday string DEFAULT NULL COMMENT '退保保障天数'
+)
+COMMENT '退保保障天数临时表'
+stored as ES
+with shard number 10
+replication 1;
+
+
+

sql-achievement/存储过程/人寿测试环境使用sql整理/险种大类统计.sql

@@ -9,6 +9,59 @@ STORED AS ES
 with shard number 10
 replication 1;
 
+CREATE OR REPLACE PROCEDURE shanglifeecif.customertotaltemp() IS
+DECLARE
+BEGIN
+		DELETE FROM shanglifeecif.customertotaltemp;
+		insert into shanglifeecif.customertotaltemp(
+			scustid,
+		 	name,
+		 	gender,
+		 	birthday,
+		 	idcard,
+		 	idtype
+		)
+		SELECT 
+			scustid ,
+			max(name) as name,
+			max(gender) as gender ,
+			to_char(max(birthday),"yyyy-MM-dd")  birthday,
+			max(idcard) as idcard,
+			max(idtype) AS idtype
+		FROM (
+			SELECT
+				trim(customerno) AS scustid,--投保人
+				trim(name) AS name,
+				trim(sex) AS gender,
+				trim(birthday) AS  birthday,
+				trim(idtype) AS idtype , 
+				trim(idno) AS idcard
+			FROM
+				dsj.policy_information 
+			WHERE customerno IS NOT NULL
+			UNION 
+			SELECT 
+				trim(insuredno) AS scustid,--被保人
+				trim(insuredname) AS name,
+				trim(insuredsex) AS gender,
+				trim(insuredbirthday) AS  birthday,
+				trim(insuredidtype) AS idtype , 
+				trim(insuredidno) AS idcard
+			FROM
+				dsj.policy_information
+			WHERE insuredno IS NOT NULL
+			) tmpTable GROUP BY scustid;
+			
+		UPDATE shanglifeecif.customertotaltemp sct SET sct.mobile = (SELECT trim(t.MOBILE) FROM dsj.t_customer_class t WHERE sct.scustid=t.customer_id);
+
+	EXCEPTION
+			WHEN HIVE_EXCEPTION THEN 
+				 INSERT INTO shanglifeecif.exception_log(log_id,log_code,log_msg,log_time) VALUES (to_char(sysdate(),'yyyyMMddHHmmss'),sqlcode(),sqlerrm(),sysdate());
+			WHEN Others THEN
+				INSERT INTO shanglifeecif.exception_log(log_id,log_code,log_msg,log_time) VALUES (to_char(sysdate(),'yyyyMMddHHmmss'),sqlcode(),sqlerrm(),sysdate());	
+END	;
+
+
 CREATE OR REPLACE PROCEDURE shanglifeecif.customer_risk_temp() 
 IS
 DECLARE
@@ -41,7 +94,13 @@ BEGIN
 			sit.risk_categories_name,
 			sit.Risk
 	FROM shanglifeecif.individual si 
-	LEFT JOIN shanglifeecif.insurancearrangement sit ON si.scustid = sit.applicantscustid;			
+	LEFT JOIN shanglifeecif.insurancearrangement sit ON si.scustid = sit.applicantscustid;
+		EXCEPTION
+			WHEN HIVE_EXCEPTION THEN 
+				 INSERT INTO shanglifeecif.exception_log(log_id,log_code,log_msg,log_time) VALUES (to_char(sysdate(),'yyyyMMddHHmmss'),sqlcode(),sqlerrm(),sysdate());
+			WHEN Others THEN
+				INSERT INTO shanglifeecif.exception_log(log_id,log_code,log_msg,log_time) VALUES (to_char(sysdate(),'yyyyMMddHHmmss'),sqlcode(),sqlerrm(),sysdate());	
+
 END	;
 
 /

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

@@ -1,329 +1,303 @@
 -- 创建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 '个人信息 '
+CREATE  TABLE shanglifeecif.individual(
+  indid string DEFAULT NULL COMMENT '个体ID', 
+  custid string DEFAULT NULL COMMENT '客户号 本系统统一生成的全司范围的唯一标识', 
+  scustid string DEFAULT NULL COMMENT '上游客户号 上游系统的客户ID', 
+  name string DEFAULT NULL COMMENT '名称 T_CUSTOMER_CLASS.CUSTOMER_NAME', 
+  birthday string DEFAULT NULL COMMENT '出生日期 T_CUSTOMER_CLASS.BIRTHDATE', 
+  nobirth string DEFAULT NULL COMMENT '出生国家', 
+  sobirth string DEFAULT NULL COMMENT '出生省份', 
+  cobirth string DEFAULT NULL COMMENT '出生城市', 
+  dday string DEFAULT NULL COMMENT '死亡日期', 
+  gender string DEFAULT NULL COMMENT '性别',
+  ethnic string DEFAULT NULL COMMENT '民族', 
+  nation string DEFAULT NULL COMMENT '国籍', 
+  homeadress string DEFAULT NULL COMMENT '籍贯 UNDERWRITE_REPORT_LIST.POLICY_HOLDER_ADDRESS', 
+  regresidence string DEFAULT NULL COMMENT '户口所在地', 
+  maritalstat string DEFAULT NULL COMMENT '婚姻状况 一对多', 
+  maritalstatdate string DEFAULT NULL COMMENT '婚姻状况日期 一对多', 
+  offspring string DEFAULT NULL COMMENT '生育状况', 
+  support string DEFAULT NULL COMMENT '赡养状况', 
+  empstat string DEFAULT NULL COMMENT '就业状况 一对多', 
+  empstatdate string DEFAULT NULL COMMENT '就业状况日期 一对多', 
+  raid string DEFAULT NULL COMMENT '联系地址', 
+  ral string DEFAULT NULL COMMENT '联系地址不分段', 
+  al string DEFAULT NULL COMMENT '曾用地址不分段', 
+  coadress int DEFAULT NULL COMMENT '地址登录数量', 
+  pmphone string DEFAULT NULL COMMENT '常用手机 正在使用的手机', 
+  mhone1 string DEFAULT NULL COMMENT '曾用手机1', 
+  mhone2 string DEFAULT NULL COMMENT '曾用手机2', 
+  sophone int DEFAULT NULL COMMENT '手机登录数量', 
+  height double DEFAULT NULL COMMENT '身高', 
+  weight double DEFAULT NULL COMMENT '体重', 
+  cillness string DEFAULT NULL COMMENT '当前疾病', 
+  pillness string DEFAULT NULL COMMENT '曾患疾病', 
+  cdiseases string DEFAULT NULL COMMENT '先天性疾病', 
+  bmi double DEFAULT NULL COMMENT 'BMI体制指数', 
+  fmhistory string DEFAULT NULL COMMENT '家族病史', 
+  evadate string DEFAULT NULL COMMENT '健康评估日期', 
+  cohevaluation int DEFAULT NULL COMMENT '健康评估登录数量', 
+  hphone string DEFAULT NULL COMMENT '家庭电话', 
+  occupationid string DEFAULT NULL COMMENT '职业代码 UNDERWRITE_REPORT_LIST.POLICY_HOLDER_CODE', 
+  occupation string DEFAULT NULL COMMENT '职业名称 UNDERWRITE_REPORT_LIST.POLICY_HOLDER_NAME', 
+  odate string DEFAULT NULL COMMENT '职业时间 一对多', 
+  employer string DEFAULT NULL COMMENT '工作单位', 
+  wphone string DEFAULT NULL COMMENT '工作电话', 
+  empdate string DEFAULT NULL COMMENT '工作单位时间', 
+  lemployer string DEFAULT NULL COMMENT '曾经工作单位', 
+  idcard string DEFAULT NULL COMMENT '身份证 T_CUSTOMER_CLASS.ID_NO', 
+  passport string DEFAULT NULL COMMENT '护照', 
+  dlicense string DEFAULT NULL COMMENT '驾驶证', 
+  education string DEFAULT NULL COMMENT '最高学历', 
+  university string DEFAULT NULL COMMENT '毕业学校', 
+  edate string DEFAULT NULL COMMENT '学历时间', 
+  wechat 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类别', 
+  saccount2 string DEFAULT NULL COMMENT '社交账号2', 
+  sa2cat string DEFAULT NULL COMMENT '社交账号2类别', 
+  ctype string DEFAULT NULL COMMENT '首选联系方式 手机，微信，微博，邮箱，QQ，抖音，其他', 
+  father string DEFAULT NULL COMMENT '父亲 HEALTH_INSURANCE_LISTING.INSUREDNAME
+HEALTH_INSURANCE_LISTING.RELATION:投保人与被保人关系', 
+  mother string DEFAULT NULL COMMENT '母亲', 
+  mate string DEFAULT NULL COMMENT '配偶', 
+  child1 string DEFAULT NULL COMMENT '子女1', 
+  child2 string DEFAULT NULL COMMENT '子女2', 
+  cochild int DEFAULT NULL COMMENT '子女登录数量', 
+  rpid string DEFAULT NULL COMMENT '房产', 
+  rpdescribe string DEFAULT NULL COMMENT '房产描述', 
+  corp int DEFAULT NULL COMMENT '房产登录数量', 
+  vid string DEFAULT NULL COMMENT '车辆', 
+  vdescribe string DEFAULT NULL COMMENT '车辆描述', 
+  covehicle int DEFAULT NULL COMMENT '车辆登录数量', 
+  anniversary1 string DEFAULT NULL COMMENT '纪念日1', 
+  a1describe string DEFAULT NULL COMMENT '纪念日1类型', 
+  anniversary2 string DEFAULT NULL COMMENT '纪念日2', 
+  a2describe string DEFAULT NULL COMMENT '纪念日2类型', 
+  soanniversary int DEFAULT NULL COMMENT '纪念日登录数量', 
+  custtype string DEFAULT NULL COMMENT '客户类型', 
+  bankname string DEFAULT NULL COMMENT '开户银行', 
+  tobankcard string DEFAULT NULL COMMENT '银行卡类型 如：master、visa、银联等。', 
+  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 string DEFAULT NULL COMMENT '客户等级失效日期', 
+  systemtag1 string DEFAULT NULL COMMENT '系统标签域1', 
+  systemtag2 string DEFAULT NULL COMMENT '系统标签域2', 
+  systemtag3 string DEFAULT NULL COMMENT '系统标签域3', 
+  systemtag4 string DEFAULT NULL COMMENT '系统标签域4', 
+  systemtag5 string DEFAULT NULL COMMENT '系统标签域5', 
+  cocommunication int DEFAULT NULL COMMENT '接触次数', 
+  lcdate string DEFAULT NULL COMMENT '最近接触时间', 
+  lctype string DEFAULT NULL COMMENT '最近接触类型 投诉、问询、营销', 
+  lcmethod string DEFAULT NULL COMMENT '最近接触方式 外呼、呼入', 
+  cocomplaint int DEFAULT NULL COMMENT '投诉次数 当前客户投保保单相关投诉，包括非本人投诉', 
+  lcptdate string DEFAULT NULL COMMENT '最近投诉时间 当前客户投保保单相关投诉，包括非本人投诉', 
+  lcptreason string DEFAULT NULL COMMENT '最近投诉原因 当前客户投保保单相关投诉，包括非本人投诉', 
+  lcptlink string DEFAULT NULL COMMENT '最近投诉环节 当前客户投保保单相关投诉，包括非本人投诉', 
+  lcptresult string DEFAULT NULL COMMENT '最近投诉处理结果 当前客户投保保单相关投诉，包括非本人投诉', 
+  lcptduration double DEFAULT NULL COMMENT '最近投诉处理时长 当前客户投保保单相关投诉，包括非本人投诉', 
+  lcptperson string DEFAULT NULL COMMENT '最近投诉人', 
+  soppremium double DEFAULT NULL COMMENT '累计已缴保费', 
+  lappdate string DEFAULT NULL COMMENT '最近投保日期', 
+  cndate string DEFAULT NULL COMMENT '最近报案日期', 
+  cnstatus string DEFAULT NULL COMMENT '最近报案状态', 
+  coclaim int DEFAULT NULL COMMENT '赔付次数', 
+  soclaim double DEFAULT NULL COMMENT '赔付总额', 
+  cocnotification int DEFAULT NULL COMMENT '报案登录数量', 
+  fadate string DEFAULT NULL COMMENT '首次投保日期 当前客户为投保人时', 
+  fachannel string DEFAULT NULL COMMENT '首张保单所属渠道 InsuranceArrangement.AgentChannel', 
+  faorg string DEFAULT NULL COMMENT '首张保单所属机构 InsuranceArrangement.AgentOrg', 
+  lpno string DEFAULT NULL COMMENT '最近保险单号 当前客户为投保人时', 
+  lpstate string DEFAULT NULL COMMENT '最近保单状态 当前客户为投保人时', 
+  lpname string DEFAULT NULL COMMENT '最近投保险种名称 当前客户为投保人时', 
+  lpchannel string DEFAULT NULL COMMENT '最近保单所属渠道 InsuranceArrangement.AgentChannel', 
+  lporg string DEFAULT NULL COMMENT '最近保单所属机构 InsuranceArrangement.AgentOrg', 
+  copolicy int DEFAULT NULL COMMENT '保单登录数量', 
+  lpostype string DEFAULT NULL COMMENT '最近保全类型 AUDIT_EDORLIST.EDORNAME', 
+  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 '保险账户登录数量', 
+  homeid string DEFAULT NULL COMMENT '家庭号 大数据平台HOME_NETWORK', 
+  branchcode string DEFAULT NULL COMMENT '机构代码 数据归属机构，用于权限控制', 
+  custstate string DEFAULT NULL COMMENT '客户状态 party可能会合并导致当前记录不再可用', 
+  datasource string DEFAULT NULL COMMENT '数据来源', 
+  smoking string DEFAULT NULL COMMENT '吸烟情况 从不、戒烟、吸烟', 
+  drinking string DEFAULT NULL COMMENT '饮酒情况 从不、戒酒、饮酒', 
+  pregnancy string DEFAULT NULL COMMENT '怀孕情况', 
+  hobby1 string DEFAULT NULL COMMENT '兴趣爱好1', 
+  hobby2 string DEFAULT NULL COMMENT '兴趣爱好2', 
+  hobby3 string DEFAULT NULL COMMENT '兴趣爱好3', 
+  pincome double DEFAULT NULL COMMENT '个人年收入', 
+  fincome double DEFAULT NULL COMMENT '家庭年收入', 
+  regtype string DEFAULT NULL COMMENT '户籍类型', 
+  incomesource string DEFAULT NULL COMMENT '收入来源', 
+  sistatus string DEFAULT NULL COMMENT '社保情况', 
+  novpolicy int DEFAULT NULL COMMENT '有效保单件数', 
+  noivpolicy int DEFAULT NULL COMMENT '失效保单件数', 
+  nostinsurance string DEFAULT NULL COMMENT '短意险保单持有情况 仅持有短意险保单，持有短意险保单，无短意险保单', 
+  nospinsurance string DEFAULT NULL COMMENT '趸交保单持有情况 仅持有趸交保单，持有趸交保单，无趸交保单', 
+  iself string DEFAULT NULL COMMENT '本人投保情况 仅本人投保，本人已投保，本人未投保', 
+  iparent string DEFAULT NULL COMMENT '父母投保情况 仅父母投保，父母已投保，父母未投保', 
+  ichildren string DEFAULT NULL COMMENT '子女投保情况 仅子女投保，子女已投保，子女未·投保', 
+  imate string DEFAULT NULL COMMENT '配偶投保情况 仅配偶投保，配偶已投保，配偶未投保', 
+  policybelong string DEFAULT NULL COMMENT '业绩归属',
+  zipcode string DEFAULT NULL, 
+  othernumber string DEFAULT NULL, 
+  otheridnumber string DEFAULT NULL, 
+  officialcalculus string DEFAULT NULL,
+  created_by string DEFAULT NULL COMMENT '创建人', 
+  created_time date DEFAULT NULL COMMENT '创建时间', 
+  updated_by string DEFAULT NULL COMMENT '更新人', 
+  updated_time date DEFAULT NULL COMMENT '更新时间', 
+  label1 string DEFAULT NULL COMMENT 'Label1', 
+  label2 string DEFAULT NULL COMMENT 'Label2', 
+  label3 string DEFAULT NULL COMMENT 'Label3', 
+  label4 string DEFAULT NULL COMMENT 'Label4', 
+  label5 string DEFAULT NULL COMMENT 'Label5', 
+  label6 string DEFAULT NULL COMMENT 'Label6', 
+  label7 string DEFAULT NULL COMMENT 'Label7', 
+  label8 string DEFAULT NULL COMMENT 'Label8', 
+  label9 string DEFAULT NULL COMMENT 'Label9', 
+  label10 string DEFAULT NULL COMMENT 'Label10', 
+  label11 string DEFAULT NULL COMMENT 'Label11', 
+  label12 string DEFAULT NULL COMMENT 'Label12', 
+  label13 string DEFAULT NULL COMMENT 'Label13', 
+  label14 string DEFAULT NULL COMMENT 'Label14', 
+  label15 string DEFAULT NULL COMMENT 'Label15', 
+  label16 string DEFAULT NULL COMMENT 'Label16', 
+  label17 string DEFAULT NULL COMMENT 'Label17', 
+  label18 string DEFAULT NULL COMMENT 'Label18', 
+  label19 string DEFAULT NULL COMMENT 'Label19', 
+  label20 string DEFAULT NULL COMMENT 'Label20', 
+  label21 string DEFAULT NULL COMMENT 'Label21', 
+  label22 string DEFAULT NULL COMMENT 'Label22', 
+  label23 string DEFAULT NULL COMMENT 'Label23', 
+  label24 string DEFAULT NULL COMMENT 'Label24', 
+  label25 string DEFAULT NULL COMMENT 'Label25', 
+  label26 string DEFAULT NULL COMMENT 'Label26', 
+  label27 string DEFAULT NULL COMMENT 'Label27', 
+  label28 string DEFAULT NULL COMMENT 'Label28', 
+  label29 string DEFAULT NULL COMMENT 'Label29', 
+  label30 string DEFAULT NULL COMMENT 'Label30', 
+  label31 string DEFAULT NULL COMMENT 'Label31', 
+  label32 string DEFAULT NULL COMMENT 'Label32', 
+  label33 string DEFAULT NULL COMMENT 'Label33', 
+  label34 string DEFAULT NULL COMMENT 'Label34', 
+  label35 string DEFAULT NULL COMMENT 'Label35', 
+  label36 string DEFAULT NULL COMMENT 'Label36', 
+  label37 string DEFAULT NULL COMMENT 'Label37', 
+  label38 string DEFAULT NULL COMMENT 'Label38', 
+  label39 string DEFAULT NULL COMMENT 'Label39', 
+  label40 string DEFAULT NULL COMMENT 'Label40', 
+  label41 string DEFAULT NULL COMMENT 'Label41', 
+  label42 string DEFAULT NULL COMMENT 'Label42', 
+  label43 string DEFAULT NULL COMMENT 'Label43', 
+  label44 string DEFAULT NULL COMMENT 'Label44', 
+  label45 string DEFAULT NULL COMMENT 'Label45', 
+  label46 string DEFAULT NULL COMMENT 'Label46', 
+  label47 string DEFAULT NULL COMMENT 'Label47', 
+  label48 string DEFAULT NULL COMMENT 'Label48', 
+  label49 string DEFAULT NULL COMMENT 'Label49', 
+  label50 string DEFAULT NULL COMMENT 'Label50', 
+  label51 string DEFAULT NULL COMMENT 'Label51', 
+  label52 string DEFAULT NULL COMMENT 'Label52', 
+  label53 string DEFAULT NULL COMMENT 'Label53', 
+  label54 string DEFAULT NULL COMMENT 'Label54', 
+  label55 string DEFAULT NULL COMMENT 'Label55', 
+  label56 string DEFAULT NULL COMMENT 'Label56', 
+  label57 string DEFAULT NULL COMMENT 'Label57', 
+  label58 string DEFAULT NULL COMMENT 'Label58', 
+  label59 string DEFAULT NULL COMMENT 'Label59', 
+  label60 string DEFAULT NULL COMMENT 'Label60', 
+  label61 string DEFAULT NULL COMMENT 'Label61', 
+  label62 string DEFAULT NULL COMMENT 'Label62', 
+  label63 string DEFAULT NULL COMMENT 'Label63', 
+  label64 string DEFAULT NULL COMMENT 'Label64', 
+  label65 string DEFAULT NULL COMMENT 'Label65', 
+  label66 string DEFAULT NULL COMMENT 'Label66', 
+  label67 string DEFAULT NULL COMMENT 'Label67', 
+  label68 string DEFAULT NULL COMMENT 'Label68', 
+  label69 string DEFAULT NULL COMMENT 'Label69', 
+  label70 string DEFAULT NULL COMMENT 'Label70', 
+  label71 string DEFAULT NULL COMMENT 'Label71', 
+  label72 string DEFAULT NULL COMMENT 'Label72', 
+  label73 string DEFAULT NULL COMMENT 'Label73', 
+  label74 string DEFAULT NULL COMMENT 'Label74', 
+  label75 string DEFAULT NULL COMMENT 'Label75', 
+  label76 string DEFAULT NULL COMMENT 'Label76', 
+  label77 string DEFAULT NULL COMMENT 'Label77', 
+  label78 string DEFAULT NULL COMMENT 'Label78', 
+  label79 string DEFAULT NULL COMMENT 'Label79', 
+  label80 string DEFAULT NULL COMMENT 'Label80', 
+  label81 string DEFAULT NULL COMMENT 'Label81', 
+  label82 string DEFAULT NULL COMMENT 'Label82', 
+  label83 string DEFAULT NULL COMMENT 'Label83', 
+  label84 string DEFAULT NULL COMMENT 'Label84', 
+  label85 string DEFAULT NULL COMMENT 'Label85', 
+  label86 string DEFAULT NULL COMMENT 'Label86', 
+  label87 string DEFAULT NULL COMMENT 'Label87', 
+  label88 string DEFAULT NULL COMMENT 'Label88', 
+  label89 string DEFAULT NULL COMMENT 'Label89', 
+  label90 string DEFAULT NULL COMMENT 'Label90', 
+  label91 string DEFAULT NULL COMMENT 'Label91', 
+  label92 string DEFAULT NULL COMMENT 'Label92', 
+  label93 string DEFAULT NULL COMMENT 'Label93', 
+  label94 string DEFAULT NULL COMMENT 'Label94', 
+  label95 string DEFAULT NULL COMMENT 'Label95', 
+  label96 string DEFAULT NULL COMMENT 'Label96', 
+  label97 string DEFAULT NULL COMMENT 'Label97', 
+  label98 string DEFAULT NULL COMMENT 'Label98', 
+  label99 string DEFAULT NULL COMMENT 'Label99', 
+  label100 string DEFAULT NULL COMMENT 'Label100', 
+  label101 string DEFAULT NULL COMMENT 'Label101', 
+  label102 string DEFAULT NULL COMMENT 'Label102', 
+  label103 string DEFAULT NULL COMMENT 'Label103', 
+  label104 string DEFAULT NULL COMMENT 'Label104', 
+  label105 string DEFAULT NULL COMMENT 'Label105', 
+  label106 string DEFAULT NULL COMMENT 'Label106', 
+  label107 string DEFAULT NULL COMMENT 'Label107', 
+  label108 string DEFAULT NULL COMMENT 'Label108', 
+  label109 string DEFAULT NULL COMMENT 'Label109', 
+  label110 string DEFAULT NULL COMMENT 'Label110', 
+  label111 string DEFAULT NULL COMMENT 'Label111', 
+  label112 string DEFAULT NULL COMMENT 'Label112', 
+  label113 string DEFAULT NULL COMMENT 'Label113', 
+  label114 string DEFAULT NULL COMMENT 'Label114', 
+  label115 string DEFAULT NULL COMMENT 'Label115', 
+  label116 string DEFAULT NULL COMMENT 'Label116', 
+  label117 string DEFAULT NULL COMMENT 'Label117', 
+  label118 string DEFAULT NULL COMMENT 'Label118', 
+  label119 string DEFAULT NULL COMMENT 'Label119', 
+  label120 string DEFAULT NULL COMMENT 'Label120'
+)
+COMMENT '客户信息 '
 stored as ES
 with shard number 10
 replication 1;