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(-1)
    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_zhangzhongyun_single():
    i = 'vip-qucheng8qi,17838a8f9ea64f809a88a5cd872c7375,'
    new_data = i.replace('\n', '').split(",")
    print(new_data)
    get_zzy_order_task(start=du.get_n_days(-1), end=du.get_n_days(0), account=new_data)


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

def update_order_guofeng_alone():
    import re
    account='87522768,rSBu9iyZ3zqKQ8Qt,1042064,趣程31期,qucheng31qi31@163.com'

    account=account.replace('\n', '').split(",")
    print(account)
    get_gf_order_task(start=du.get_n_days(-180), end=du.get_n_days(0), account=account)

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_zhangzhognyun()
    # update_order_zhangzhognyun()
    # update_order_zhangzhongyun_single()
    # update_order_guofeng()
    update_order_guofeng_alone()