消耗补昨天数据

app/crontab_task/daily08.py

@@ -1,7 +1,11 @@
 from app.crontab_task.task import *
+from app.api_data.tx_ad_cost.get_cost_older import old_cost_daily08
 du = DateUtils()
 
 
 if __name__ == '__main__':
+    # 补昨日消耗
+    cost_yestoday_repair()
+
     # 阅文订单回补（特殊）
     yueweng_order_repair()

app/crontab_task/task.py

@@ -4,6 +4,8 @@ from app.api_data.platform_order.get_order import *
 from app.api_data.tx_ad_cost.get_cost_older import old_cost_hourly,old_cost_daily
 from app.etl.sync_to_ck_task import order_sync_ck
 from app.api_data.platform_order import yangguang
+from app.api_data.tx_ad_cost import get_cost_older
+from app.etl.data_stat_run import do_cost
 def hourly():
     t1 = threading.Thread(target=huasheng)
     t2 = threading.Thread(target=qiyue)
@@ -75,6 +77,13 @@ def daily():
 
     yangguang.get_channel_info()
 
+
+def cost_yestoday_repair():
+    dt = du.get_n_days(-1)
+    get_cost_older.run(dt,dt)
+    do_cost(dt,dt)
+
+
 def yueweng_order_repair():
     dt = du.get_n_days(-1)
     yueweng(dt, dt)
@@ -82,4 +91,5 @@ def yueweng_order_repair():
 
 
 if __name__ == '__main__':
-    hourly()
+    # hourly()
+    cost_yestoday_repair()