update

task/search_strategy_d.py

@@ -76,8 +76,8 @@ for t in range(0, task_days):
             ,t3.device_os_type as device_type
             ,t3.active_type as active_type
             ,t3.channel as channel_type
-            ,NVL(t3.search_pv,0) as 1_pv
-            ,NVL(t3.search_uv,0) as 1_uv
+            ,NVL(t3.search_pv,0) as pv
+            ,NVL(t3.search_uv,0) as uv
             ,NVL(t4.hexin_card_click_pv,0) as search_core_pv
             ,NVL(t4.neirong_card_click_pv,0) as search_pv
     FROM
@@ -261,8 +261,8 @@ for t in range(0, task_days):
 
 
     collects_sql = """
-    SELECT device_type,active_type,channel_type,if(NVL(sum(1_uv),0) <> 0 ,NVL(sum(search_core_pv),0)/NVL(sum(1_uv),0) , 0) as core_pv_division_uv ,
-    if(NVL(sum(1_uv),0) <> 0 ,NVL(sum(1_search_pv),0)/NVL(sum(1_uv),0) , 0) as pv_division_uv
+    SELECT device_type,active_type,channel_type,if(NVL(sum(uv),0) <> 0 ,NVL(sum(search_core_pv),0)/NVL(sum(uv),0) , 0) as core_pv_division_uv ,
+    if(NVL(sum(uv),0) <> 0 ,NVL(sum(search_pv),0)/NVL(sum(uv),0) , 0) as pv_division_uv
     FROM data_table GROUP BY device_type,active_type,channel_type
     """
     finnal_df = spark.sql(collects_sql)