update

task/ecommerce_income_report.py

@@ -417,9 +417,10 @@ group by partition_day
     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
-    ad_flow_rat = (pv + cpc_click_num)/ welfare_pv
+    ad_flow_rat = (pv + cpc_click_num) / welfare_pv
     budget_consumption_rate = cpc_proportion_expend_amount/budget
     cpc_item_pricing = cpc_proportion_expend_recharge_amount/cpc_click_num
+    cpc_flow_rat = cpc_click_num / welfare_pv
     # tol_proportion_expend_amount
     db = pymysql.connect(host='172.16.40.158', port=4000, user='st_user', passwd='aqpuBLYzEV7tML5RPsN1pntUzFy',
                          db='jerry_prod')
@@ -427,11 +428,11 @@ group by partition_day
     partition_date = yesterday_str
     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,cpc_flow_rat) 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},{cpc_flow_rat});""".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
+        day_id=today_str,pid=pid,cpc_flow_rat=cpc_flow_rat
     )
     print(cpc_daily_click_sql)
     # cursor.execute("set names 'UTF8'")