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
from logging import handlers


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))
    t10 = threading.Thread(target=guofeng, 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()
    t10.start()
    t10.join()
    yangguang.get_channel_info()

def update_order():
    # 1.获取数据

    st = du.get_n_days(-30)
    et = du.get_n_days(0)
    # print(st, et)
    order_date_get(st,et)
    # 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_zhangzhognyun():
    zhangzhongyun(start=du.get_n_days(-15),end=du.get_n_days(0))

def update_order_guofeng():
    guofeng(start=du.get_n_days(-15),end=du.get_n_days(0))

def update_order_do():
    st = du.get_n_days(-30)
    et = du.get_n_days(0)
    print(st, et)
    do_order(st, et)

if __name__=='__main__':
    logging.basicConfig(
        handlers=[
            logging.handlers.RotatingFileHandler('./update_order_data.log',
                                                 maxBytes=10 * 1024 * 1024,
                                                 backupCount=5,
                                                 encoding='utf-8')
            , logging.StreamHandler()  # 供输出使用
        ],
        level=logging.INFO,
        format="%(asctime)s - %(levelname)s %(filename)s %(funcName)s %(lineno)s - %(message)s"
    )
    # yangguang.get_channel_info()
    # update_order()
    # update_order()
    # update_order_zhangzhognyun()
    update_order_guofeng()