update

task/ecommerce_income_report.py

@@ -413,7 +413,7 @@ group by partition_day
     #  cpc_income.cpc_proportion_expend_recharge_amount/cpc_income.cpc_click_num as cpc_item_pricing,
     #  cpc_income.tol_proportion_expend_amount as tol_proportion_expend_amount
     # """
-
+    print(referrer_search_welfare_pv,welfare_pv)
     pv_div_dau = referrer_search_welfare_pv/dau
     pv_div_quanzhong_dau = referrer_search_welfare_pv/quanzhong_dau
     search_pv_div_all_pv = referrer_search_welfare_pv / welfare_pv
@@ -428,7 +428,7 @@ group by partition_day
     pid = hashlib.md5(partition_date.encode("utf8")).hexdigest()
     cpc_daily_click_sql = """replace into ecommerce_income_report(
     pv_div_dau,pv_div_quanzhong_dau,ad_flow_rat,budget_consumption_rate,cpc_item_pricing,tol_proportion_expend_amount,partition_day,day_id,pid,search_pv_div_all_pv) VALUES(
-    {pv_div_dau},{pv_div_quanzhong_dau},{ad_flow_rat},{budget_consumption_rate},{cpc_item_pricing},{tol_proportion_expend_amount},'{partition_day}','{day_id}','{pid}',search_pv_div_all_pv);""".format(
+    {pv_div_dau},{pv_div_quanzhong_dau},{ad_flow_rat},{budget_consumption_rate},{cpc_item_pricing},{tol_proportion_expend_amount},'{partition_day}','{day_id}','{pid}',{search_pv_div_all_pv});""".format(
         pv_div_dau=pv_div_dau,pv_div_quanzhong_dau=pv_div_quanzhong_dau,ad_flow_rat=ad_flow_rat,budget_consumption_rate=budget_consumption_rate,
         cpc_item_pricing=cpc_item_pricing,tol_proportion_expend_amount=tol_proportion_expend_amount,partition_day=today_str,search_pv_div_all_pv=search_pv_div_all_pv,
         day_id=today_str,pid=pid