update

task/recommend_strategy_fix.py

@@ -115,7 +115,27 @@ for t in range(1, task_days):
         NVL(sum(post_click_pv),0) as post_click_pv
     
     FROM
-    ( SELECT  partition_date,            
+
+    (
+        SELECT partition_date
+             ,device_os_type
+             ,CASE WHEN active_type = '4'  THEN '老活'
+                   WHEN active_type  IN ('1','2')  THEN '新增' END AS active_type
+             ,device_id
+        FROM online.ml_device_day_active_status
+        WHERE partition_date=regexp_replace(DATE_SUB(current_date,1) ,'-','')
+          AND active_type IN ('1','2','4')
+          AND first_channel_source_type not IN ('yqxiu1','yqxiu2','yqxiu3','yqxiu4','yqxiu5','mxyc1','mxyc2','mxyc3'
+            ,'wanpu','jinshan','jx','maimai','zhuoyi','huatian','suopingjingling','mocha','mizhe','meika','lamabang'
+            ,'js-az1','js-az2','js-az3','js-az4','js-az5','jfq-az1','jfq-az2','jfq-az3','jfq-az4','jfq-az5','toufang1'
+            ,'toufang2','toufang3','toufang4','toufang5','toufang6','TF-toufang1','TF-toufang2','TF-toufang3','TF-toufang4'
+            ,'TF-toufang5','tf-toufang1','tf-toufang2','tf-toufang3','tf-toufang4','tf-toufang5','benzhan','promotion_aso100'
+            ,'promotion_qianka','promotion_xiaoyu','promotion_dianru','promotion_malioaso','promotion_malioaso-shequ'
+            ,'promotion_shike','promotion_julang_jl03','promotion_zuimei')
+          AND first_channel_source_type not LIKE 'promotion\_jf\_%'
+    )t1 
+        JOIN
+            ( SELECT  partition_date,            
                     cl_id,
                     count(card_id) as session_pv0
             FROM
@@ -173,26 +193,8 @@ for t in range(1, task_days):
             )a
             LATERAL VIEW explode (a.recommend_type) v as recommend_type
             group by partition_date,cl_id,v.recommend_type having session_pv0 >= 4) t0
+            on on t1.device_id = t0.cl_id 
 left join
-    (
-        SELECT partition_date
-             ,device_os_type
-             ,CASE WHEN active_type = '4'  THEN '老活'
-                   WHEN active_type  IN ('1','2')  THEN '新增' END AS active_type
-             ,device_id
-        FROM online.ml_device_day_active_status
-        WHERE partition_date=regexp_replace(DATE_SUB(current_date,1) ,'-','')
-          AND active_type IN ('1','2','4')
-          AND first_channel_source_type not IN ('yqxiu1','yqxiu2','yqxiu3','yqxiu4','yqxiu5','mxyc1','mxyc2','mxyc3'
-            ,'wanpu','jinshan','jx','maimai','zhuoyi','huatian','suopingjingling','mocha','mizhe','meika','lamabang'
-            ,'js-az1','js-az2','js-az3','js-az4','js-az5','jfq-az1','jfq-az2','jfq-az3','jfq-az4','jfq-az5','toufang1'
-            ,'toufang2','toufang3','toufang4','toufang5','toufang6','TF-toufang1','TF-toufang2','TF-toufang3','TF-toufang4'
-            ,'TF-toufang5','tf-toufang1','tf-toufang2','tf-toufang3','tf-toufang4','tf-toufang5','benzhan','promotion_aso100'
-            ,'promotion_qianka','promotion_xiaoyu','promotion_dianru','promotion_malioaso','promotion_malioaso-shequ'
-            ,'promotion_shike','promotion_julang_jl03','promotion_zuimei')
-          AND first_channel_source_type not LIKE 'promotion\_jf\_%'
-    )t1 on t0.cl_id=t1.device_id and t0.partition_date=t1.partition_date
-        JOIN
         (--精准曝光，卡片id和session_id去重
             SELECT  partition_date,
                     card_content_type,
@@ -256,7 +258,7 @@ left join
             LATERAL VIEW explode (a.recommend_type) v as recommend_type
             group by partition_date,card_content_type,cl_id,v.recommend_type,card_id
           )t2  
-        on t1.device_id=t2.cl_id and t1.partition_date=t2.partition_date 
+        on t0.device_id=t2.cl_id and t0.partition_date=t2.partition_date 
         LEFT JOIN
         (--卡片，卡片id和session_id去重
             SELECT  partition_date,