1

app/etl/data_stat_task.py

@@ -144,7 +144,7 @@ select
        dt,channel,pitcher,stage,platform,book,
        order_count,order_user,order_amount,first_order_count,first_order_user,first_order_amount,
        view_count,click_count,follow_user,cost/100,reg_order_count,reg_order_user,reg_order_amount,reg_order_amount30,
-       web_view_count,platform_view_count,web_order_count
+       web_view_count,platform_view_count,web_order_count,0 total_cost,0 total_amount
 from
 (select dt,channel, pitcher,stage,platform,book,cost,view_count,click_count,follow_user,web_view_count,platform_view_count,web_order_count from dw_daily_channel_cost) a
     left outer join

app/etl/sync_to_ck_task.py

@@ -68,7 +68,7 @@ def campaign_vx():
 def dw_order_channel_cost_sync_ck(ymd):
     table='dw_daily_channel_cost'
     sql = f"select * from {table} where dt='{ymd}'"
-    col=ck.getColumns(f"{table}",str=True)
+    col=ck.getColumns(f"{table}")
     data = db.quchen_text.get_data_list(sql)
     data1=[]
     for i in data: