DataCenterGame/example/update_order_data.py

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()

if __name__=='__main__':
    update_order()