from model.DateUtils import DateUtils from app.api_data.tx_ad_cost import get_cost_older from app.etl.data_stat_run import do_order from app.etl.dm.dm_pitcher_daily_overview import dm_pitcher_daily_overview from app.etl.dw.dw_channel_daily import dw_channel_daily from app.etl.dw.dw_pitcher_daily import dw_pitcher_trend from app.etl.src.src_book_info import src_book_info from app.etl.dw.dw_book_trend import book_trend import threading 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 import yangguang from app.api_data.tx_ad_cost import get_cost_older from app.etl.data_stat_run import do_cost du = DateUtils() def order_date_get(st,et): t1 = threading.Thread(target=huasheng, args=(st, et)) t2 = threading.Thread(target=qiyue, args=(st, et)) t3 = threading.Thread(target=qiyueyousheng, args=(st, et)) t4 = threading.Thread(target=wending, args=(st, et)) t5 = threading.Thread(target=zhangdu, args=(st, et)) t6 = threading.Thread(target=zhangzhongyun, args=(st, et)) t7 = threading.Thread(target=yueweng, args=(st, et)) t8 = threading.Thread(target=yangguang, args=(st, et)) t9 = threading.Thread(target=youshuge, args=(st, et)) t1.start() t1.join() t2.start() t2.join() t3.start() t3.join() t4.start() t4.join() t5.start() t5.join() t6.start() t6.join() t7.start() t7.join() t8.start() t8.join() t9.start() t9.join() yangguang.get_channel_info() def update_order(): # 1.获取数据 st = du.get_n_days(-2) et = du.get_n_days(0) print(st, et) order_date_get(st,et) st = du.get_n_days(-1) et = du.get_n_days(0) do_order(st, et) src_book_info() # 书籍卡点信息 # book_annual_expect_profit.run() # 年预期收益 dw_channel_daily() dw_pitcher_trend() book_trend() dm_pitcher_daily_overview() def update_order_do(): st = du.get_n_days(-10) et = du.get_n_days(0) print(st, et) do_order(st, et) if __name__=='__main__': # yangguang.get_channel_info() update_order_do()