push codes

pm/clue_daily/etl/clue_daily.sql

@@ -71,36 +71,36 @@ FROM
 		,grey_type
 		,count(distinct mas.device_id) as dau
 		,count(distinct a.user_id) as user_num
-		,count(distinct case when t1.msg_num>0 then t1.user_id end) msg_dev
-		,sum(t1.msg_num) msg_num
-		,count(distinct case when t1_v.valid_msg_num>0 then t1_v.user_id end) valid_msg_dev
-		,sum(t1_v.valid_msg_num) as valid_msg_num
-		,count(distinct case when t2.clue_num>0 then t2.user_id end) as clue_dev
-		,sum(t2.clue_num) as clue_num
+		,nvl(count(distinct case when t1.msg_num>0 then t1.user_id end),0) msg_dev
+		,nvl(sum(t1.msg_num),0) msg_num
+		,nvl(count(distinct case when t1_v.valid_msg_num>0 then t1_v.user_id end),0) valid_msg_dev
+		,nvl(sum(t1_v.valid_msg_num),0) as valid_msg_num
+		,nvl(count(distinct case when t2.clue_num>0 then t2.user_id end),0) as clue_dev
+		,nvl(sum(t2.clue_num),0) as clue_num
 
 
-		,count(distinct case when t10.msg_num>0 then t10.user_id end) msg_dev_4
-		,sum(t10.msg_num) msg_num_4
-		,count(distinct case when t10_v.valid_msg_num>0 then t10_v.user_id end) valid_msg_dev_4
-		,sum(t10_v.valid_msg_num) as valid_msg_num_4
-		,count(distinct case when t11.clue_num>0 then t11.user_id end) as clue_dev_4
-		,sum(t11.clue_num) as clue_num_4
+		,nvl(count(distinct case when t10.msg_num>0 then t10.user_id end),0) msg_dev_4
+		,nvl(sum(t10.msg_num),0) msg_num_4
+		,nvl(count(distinct case when t10_v.valid_msg_num>0 then t10_v.user_id end),0) valid_msg_dev_4
+		,nvl(sum(t10_v.valid_msg_num),0) as valid_msg_num_4
+		,nvl(count(distinct case when t11.clue_num>0 then t11.user_id end),0) as clue_dev_4
+		,nvl(sum(t11.clue_num),0) as clue_num_4
 
 
-		,count(distinct case when t4.msg_num>0 then t4.user_id end) msg_dev_kyc
-		,sum(t4.msg_num) msg_num_kyc
-		,count(distinct case when t4_v.valid_msg_num>0 then t4_v.user_id end) valid_msg_dev_kyc
-		,sum(t4_v.valid_msg_num) as valid_msg_num_kyc
-		,count(distinct case when t5.clue_num>0 then t5.user_id end) as clue_dev_kyc
-		,sum(t5.clue_num) as clue_num_kyc
+		,nvl(count(distinct case when t4.msg_num>0 then t4.user_id end),0) msg_dev_kyc
+		,nvl(sum(t4.msg_num),0) msg_num_kyc
+		,nvl(count(distinct case when t4_v.valid_msg_num>0 then t4_v.user_id end),0) valid_msg_dev_kyc
+		,nvl(sum(t4_v.valid_msg_num),0) as valid_msg_num_kyc
+		,nvl(count(distinct case when t5.clue_num>0 then t5.user_id end),0) as clue_dev_kyc
+		,nvl(sum(t5.clue_num),0) as clue_num_kyc
 
 
-		,count(distinct case when t7.msg_num>0 then t7.user_id end) msg_dev_qa
-		,sum(t7.msg_num) msg_num_qa
-		,count(distinct case when t7_v.valid_msg_num>0 then t7_v.user_id end) valid_msg_dev_qa
-		,sum(t7_v.valid_msg_num) as valid_msg_num_qa
-		,count(distinct case when t8.clue_num>0 then t8.user_id end) as clue_dev_qa
-		,sum(t8.clue_num) as clue_num_qa
+		,nvl(count(distinct case when t7.msg_num>0 then t7.user_id end),0) msg_dev_qa
+		,nvl(sum(t7.msg_num),0) msg_num_qa
+		,nvl(count(distinct case when t7_v.valid_msg_num>0 then t7_v.user_id end),0) valid_msg_dev_qa
+		,nvl(sum(t7_v.valid_msg_num),0) as valid_msg_num_qa
+		,nvl(count(distinct case when t8.clue_num>0 then t8.user_id end),0) as clue_dev_qa
+		,nvl(sum(t8.clue_num),0) as clue_num_qa
 
 	FROM
 	(
@@ -526,25 +526,25 @@ LEFT JOIN
 	SELECT t3.partition_date,a.device_os_type,a.grey_type
 			,case when b.active_type in ('1','2') then '新增设备'
 	                      when (b.active_type ='4' or b.active_type is null) then '老活跃设备' end  as active_type
-	    ,count(distinct case when t3.call_num>0 then t3.user_id end) as call_dev
-		,sum(t3.call_num) as call_num
-		,count(distinct case when t3_v.valid_call_num>0 then t3_v.user_id end) as valid_call_dev
-		,sum(t3_v.valid_call_num) as valid_call_num
+	    ,nvl(count(distinct case when t3.call_num>0 then t3.user_id end),0) as call_dev
+		,nvl(sum(t3.call_num),0) as call_num
+		,nvl(count(distinct case when t3_v.valid_call_num>0 then t3_v.user_id end),0) as valid_call_dev
+		,nvl(sum(t3_v.valid_call_num),0) as valid_call_num
 
-		,count(distinct case when t12.call_num>0 then t12.user_id end) as call_dev_4
-		,sum(t12.call_num) as call_num_4
-		,count(distinct case when t12_v.valid_call_num>0 then t12_v.user_id end) as valid_call_dev_4
-		,sum(t12_v.valid_call_num) as valid_call_num_4
+		,nvl(count(distinct case when t12.call_num>0 then t12.user_id end),0) as call_dev_4
+		,nvl(sum(t12.call_num),0) as call_num_4
+		,nvl(count(distinct case when t12_v.valid_call_num>0 then t12_v.user_id end),0) as valid_call_dev_4
+		,nvl(sum(t12_v.valid_call_num),0) as valid_call_num_4
 
-		,count(distinct case when t6.call_num>0 then t6.user_id end) as call_dev_kyc
-		,sum(t6.call_num) as call_num_kyc
-		,count(distinct case when t6_v.valid_call_num>0 then t6_v.user_id end) as valid_call_dev_kyc
-		,sum(t6_v.valid_call_num) as valid_call_num_kyc
+		,nvl(count(distinct case when t6.call_num>0 then t6.user_id end),0) as call_dev_kyc
+		,nvl(sum(t6.call_num),0) as call_num_kyc
+		,nvl(count(distinct case when t6_v.valid_call_num>0 then t6_v.user_id end),0) as valid_call_dev_kyc
+		,nvl(sum(t6_v.valid_call_num),0) as valid_call_num_kyc
 
-		,count(distinct case when t9.call_num>0 then t9.user_id end) as call_dev_qa
-		,sum(t9.call_num) as call_num_qa
-		,count(distinct case when t9_v.valid_call_num>0 then t9_v.user_id end) as valid_call_dev_qa
-		,sum(t9_v.valid_call_num) as valid_call_num_qa
+		,nvl(count(distinct case when t9.call_num>0 then t9.user_id end),0) as call_dev_qa
+		,nvl(sum(t9.call_num),0) as call_num_qa
+		,nvl(count(distinct case when t9_v.valid_call_num>0 then t9_v.user_id end),0) as valid_call_dev_qa
+		,nvl(sum(t9_v.valid_call_num),0) as valid_call_num_qa
 
 	FROM
 	(
@@ -1141,4 +1141,4 @@ group by t3.partition_date,a.device_os_type,a.grey_type,case when b.active_type
 on T1.partition_date=T2.partition_date
 AND T1.device_os_type=T2.device_os_type
 AND T1.active_type=T2.active_type
-AND T1.grey_type=T2.grey_type
\ No newline at end of file
+AND T1.grey_type=T2.grey_type

pm/clue_daily/job/step3.job

 #step3.job
 type=command
 dependencies=step2
-command=curl -X GET http://localhost:8553/api/report/email/clue_daily/weiyimin@igengmei.com/weiyimin@qq.com
\ No newline at end of file
+command=curl -X GET http://localhost:8553/api/report/email/clue_daily/liudi@igengmei.com,wangxin@igengmei.com,zhaoyang@igengmei.com/weiyimin@igengmei.com
\ No newline at end of file