|
|
@@ -3,8 +3,7 @@ import threading
|
|
|
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.yangguang import yangguang
|
|
|
-
|
|
|
+from app.api_data.platform_order import yangguang
|
|
|
def hourly():
|
|
|
t1 = threading.Thread(target=huasheng)
|
|
|
t2 = threading.Thread(target=qiyue)
|
|
|
@@ -13,7 +12,7 @@ def hourly():
|
|
|
t5 = threading.Thread(target=zhangdu)
|
|
|
t6 = threading.Thread(target=zhangzhongyun)
|
|
|
t7 = threading.Thread(target=yueweng)
|
|
|
- t8 = threading.Thread(target=yangguang)
|
|
|
+ t8 = threading.Thread(target=yangguang.yangguang)
|
|
|
t9 = threading.Thread(target=youshuge)
|
|
|
t10 = threading.Thread(target=old_cost_hourly)
|
|
|
t1.start()
|
|
|
@@ -42,7 +41,7 @@ def daily():
|
|
|
st = du.get_n_days(-10)
|
|
|
et = du.get_n_days(-1)
|
|
|
|
|
|
- yangguang.get_channel_info()
|
|
|
+
|
|
|
t1 = threading.Thread(target=huasheng,args=(st,et))
|
|
|
t2 = threading.Thread(target=qiyue,args=(st,et))
|
|
|
t3 = threading.Thread(target=qiyueyousheng,args=(st,et))
|
|
|
@@ -74,6 +73,7 @@ def daily():
|
|
|
t10.start()
|
|
|
t10.join()
|
|
|
|
|
|
+ yangguang.get_channel_info()
|
|
|
|
|
|
def yueweng_order_repair():
|
|
|
dt = du.get_n_days(-1)
|
