update

task/recommend_strategy_fix.py

@@ -190,7 +190,7 @@ for t in range(0, task_days):
                       app_session_id
             )a
             LATERAL VIEW explode (a.recommend_type) v as recommend_type
-            group by partition_date,cl_id having session_pv0 >= 4) t0
+            group by partition_date,cl_id) t0
             on t1.device_id = t0.cl_id 
  LEFT JOIN
         (--精准曝光，卡片id和session_id去重
@@ -781,7 +781,7 @@ for t in range(0, task_days):
         on t2.partition_date=dev.partition_date and t2.cl_id=dev.device_id
     WHERE spam_pv.device_id IS NULL
       and dev.device_id is null
-    GROUP BY t1.partition_date,t1.device_os_type,t1.active_type,t2.card_content_type,t2.recommend_type
+    GROUP BY t1.partition_date,t1.device_os_type,t1.active_type,t2.card_content_type,t2.recommend_type  having t2.session_pv0 >= 4 or having session_pv >0
     order by day_id,device_os_type,active_type,card_content_type,recommend_type
     """.format(partition_day=today_str)
     ctr_df = spark.sql(ctr_sql)