update

task/advertisement_strategy_d.py

@@ -104,10 +104,10 @@ for t in range(0, task_days):
     for res in sql_res:
         print(res)
 
-    print("-----------------------------------------------------------------------------")
+    print("0-----------------------------------------------------------------------------")
     # 商详页PV
     bus_detail_pv_sql = """SELECT 
-    partition_date,count(1) welfare_pv
+    a2.partition_date,count(1) welfare_pv
     FROM 
     (
         SELECT cl_id,partition_date
@@ -131,7 +131,7 @@ for t in range(0, task_days):
     sql_res = bus_detail_pv_df.collect()
     for res in sql_res:
         print(res)
-    print("-----------------------------------------------------------------------------")
+    print("1-----------------------------------------------------------------------------")
     # cpc当日预算(有效口径)
     cpc_budget_sql = """SELECT day_id,sum(budget) as budget
         FROM
@@ -189,7 +189,7 @@ for t in range(0, task_days):
     sql_res = cpc_budget_df.collect()
     for res in sql_res:
         print(res)
-    print("-----------------------------------------------------------------------------")
+    print("2-----------------------------------------------------------------------------")
     cpc_income_total_consume_sql = """
     select partition_day,
 sum(case when advertise_type = 'cpc' AND advertise_business_type in('service') and advertise_calculate_type='cpc_log' then cpc_click_num end)   cpc_click_num,
@@ -218,7 +218,7 @@ group by partition_day
     cpc_income_total_consume_df_res = cpc_income_total_consume_df.collect()
     for res in cpc_income_total_consume_df_res:
         print(res)
-    print("-----------------------------------------------------------------------------")
+    print("3-----------------------------------------------------------------------------")
 #     for res in sql_res:
 #         # print(res)
 #         day_id = res.day_id