添加存储过程

sql-achievement/存储过程/测试环境/shanglifeecif_cron.sh

@@ -0,0 +1,51 @@
+#!/bin/bash
+#--------------------------------------------
+#Date: 2021/05/13  
+#Author:koucx
+export LANG="en_US.UTF-8"
+source /etc/profile
+source ~/.bash_profile;
+source /home/bireport/TDH-Client/init.sh
+################################################
+shanglifeecif_sql="
+BEGIN
+      -- 执行跑批任务
+     dbms_output.put_line( '跑批开始！');
+     dbms_output.put_line(to_char(sysdate,'yyyy-MM-dd HH:mm:ss') || '跑批开始！');
+    
+shanglifeecif.customertotaltemp();
+	
+	
+        --  DELETE FROM shanglifeecif.individual;
+	--初始化客户信息
+	--  shanglifeecif.init_all_individual();
+	--更新用户等级信息
+	--  shanglifeecif.up_t_customers_class_1();
+	--更新其它信息
+	--  shanglifeecif.up_other_customerinfo();
+	--更新被保人信息
+	--  shanglifeecif.update_insuredinfo();
+--   	 shanglifeecif.init_individual_main();
+   --	 shanglifeecif.same_customer();
+   --	 shanglifeecif.data_cleaning();
+   --	 shanglifeecif.init_insurancearrangement_main();
+   --	 shanglifeecif.insuranceclaimthread_main();
+   --	 shanglifeecif.init_indrelationship_main();
+   --	 shanglifeecif.partytimeline_main();
+   --	 shanglifeecif.age_sex_distribution();
+   --	 shanglifeecif.riskcode_statistics();
+   --	 shanglifeecif.bdnum_distribution();
+   --	 shanglifeecif.surrender_protection_temp();
+   --	 shanglifeecif.updateIndividualLable();
+--	 shanglifeecif.effective_customer();
+   EXCEPTION
+   -- 引用一个NO_DATA_FOUND的EXCEPTION。
+   WHEN NO_DATA_FOUND THEN
+   -- 输出变量v_comment的值。
+   dbms_output.put_line('当天跑批未完成！')
+    WHEN TOO_MANY_ROWS THEN
+    dbms_output.put_line('当天出现多条跑批数据！')
+END;"
+beeline -u "jdbc:hive2://10.50.254.45:10000"  --hiveconf hive.metastore.client.socket.timeout=86400000 --hiveconf hive.server2.idle.session.timeout=43200000 --hiveconf hive.server2.session.check.interval=900000 -e "${shanglifeecif_sql}"
+
+

sql-achievement/存储过程/测试环境/shanglifeecif_cron_test.sh

@@ -0,0 +1,56 @@
+#!/bin/bash
+#--------------------------------------------
+#Date: 2022/05/6  
+#Author:LuGuangChen
+export LANG="en_US.UTF-8"
+source /etc/profile
+source ~/.bash_profile;
+source /home/bireport/TDH-Client/init.sh
+################################################
+shanglifeecif_sql="
+BEGIN
+     dbms_output.put_line(to_char(sysdate,'yyyy-MM-dd HH:mm:ss') || '跑批开始！');
+    -- ok
+-- shanglifeecif.customertotaltemp();
+	
+	-- ok 
+  --   DELETE FROM shanglifeecif.individual;
+	--初始化客户信息
+--	  shanglifeecif.init_all_individual();
+	--更新用户等级信息 ok
+--	  shanglifeecif.up_t_customers_class_1();
+	--更新其它信息
+--	  shanglifeecif.up_other_customerinfo();
+	--更新被保人信息
+--	  shanglifeecif.update_insuredinfo();
+
+
+
+         shanglifeecif.same_customer();
+         shanglifeecif.data_cleaning();
+         shanglifeecif.init_insurancearrangement_main();
+         shanglifeecif.insuranceclaimthread_main();
+         shanglifeecif.init_indrelationship_main();
+         shanglifeecif.partytimeline_main();
+         shanglifeecif.age_sex_distribution();
+        shanglifeecif.customer_risk_temp();
+         shanglifeecif.riskcode_statistics();
+         shanglifeecif.bdnum_distribution();
+         shanglifeecif.surrender_protection_temp();
+         shanglifeecif.updateIndividualLable();
+         shanglifeecif.effective_customer();
+		 
+		-- 2022/05/20 start 陆光晨 分渠道展示
+		-- 初始化用户渠道关系表
+--		shanglifeecif.init_customerno_salecom_relation();
+		--客户信息添加渠道
+--		shanglifeecif.init_Individual_salecom();
+		-- 分渠道重新计算标签值，并更新到用户渠道关系表中
+--		shanglifeecif.update_customerno_salecom_relation_labels();
+		-- 2022/05/20 end 陆光晨 分渠道展示
+		
+
+        dbms_output.put_line(to_char(sysdate,'yyyy-MM-dd HH:mm:ss') || '跑批完成！');
+END;"
+beeline -u "jdbc:hive2://10.50.254.45:10000"  --hiveconf hive.metastore.client.socket.timeout=86400000  --hiveconf hive.server2.idle.session.timeout=43200000  --hiveconf hive.server2.session.check.interval=900000  --hiveconf hive.zookeeper.session.timeout=86400000 -e "${shanglifeecif_sql}"
+

sql-achievement/存储过程/生产环境/shanglifeecif_cron.sh

@@ -0,0 +1,61 @@
+#!/bin/bash
+#--------------------------------------------
+#Date: 2021/05/13  
+#Author:koucx
+export LANG="en_US.UTF-8"
+source /etc/profile
+source ~/.bash_profile;
+source /BIreport/TDH-Client/init.sh
+################################################
+shanglifeecif_sql="
+DECLARE
+    bes dsj.batch_execu_status2%ROWTYPE
+    curdate STRING
+BEGIN
+  SELECT * INTO bes
+	FROM dsj.batch_execu_status2  WHERE batch_number = to_char(sysdate,'yyyyMMdd');
+   -- 确定IF的条件语句为v_price的值大于20。
+   IF bes.batch_status = '00' THEN
+      -- 执行跑批任务
+      curdate:=  to_char(sysdate,'yyyy-MM-dd HH:mm:ss')
+     dbms_output.put_line(curdate || '跑批开始！');
+    
+   	 shanglifeecif.init_individual_main();
+   	 shanglifeecif.same_customer();
+   	 shanglifeecif.data_cleaning();
+   	 shanglifeecif.init_insurancearrangement_main();
+   	 shanglifeecif.insuranceclaimthread_main();
+   	 shanglifeecif.init_indrelationship_main();
+   	 shanglifeecif.partytimeline_main();
+   	 shanglifeecif.age_sex_distribution();
+   	 shanglifeecif.riskcode_statistics();
+   	 shanglifeecif.bdnum_distribution();
+   	 shanglifeecif.surrender_protection_temp();
+   	 shanglifeecif.updateIndividualLable();
+	 shanglifeecif.effective_customer();
+   	--跑批完成后，向跑批状态表插入数据
+       INSERT INTO dsj.batch_execu_status2 
+       	VALUES (
+       		'客户统一视图' || to_char(sysdate,'yyyyMMdd'),
+       		'ecif',
+       		'客户统一视图ETL任务',
+       		'ecif_etl',
+       		to_char(sysdate,'yyyyMMddHHmmss'),
+       		curdate,
+       		to_char(sysdate,'yyyy-MM-dd HH:mm:ss'),
+       		'00',
+       		NULL,'ecif',to_char(sysdate,'yyyy-MM-dd HH:mm:ss'),NULL,NULL
+       		);
+   END IF
+		dbms_output.put_line(to_char(sysdate,'yyyy-MM-dd HH:mm:ss') || '跑批完成！');
+   EXCEPTION
+   -- 引用一个NO_DATA_FOUND的EXCEPTION。
+   WHEN NO_DATA_FOUND THEN
+   -- 输出变量v_comment的值。
+   dbms_output.put_line('当天跑批未完成！')
+    WHEN TOO_MANY_ROWS THEN
+    dbms_output.put_line('当天出现多条跑批数据！')
+END;"
+beeline -u "jdbc:hive2://10.52.3.12:10000"  --hiveconf hive.metastore.client.socket.timeout=86400000 --hiveconf hive.server2.idle.session.timeout=43200000 --hiveconf hive.server2.session.check.interval=900000 -e "${shanglifeecif_sql}"
+
+

sql-achievement/存储过程/生产环境/存储过程.sql

@@ -3206,54 +3206,4 @@ UPDATE shanglifeecif.Individual si1 SET si1.label79 = '女儿生日临近' WHERE
 			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
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+END