DataCenterGame/app/api_data/platform_order/yangguang.py

from app.api_data.order_util import *
from model.DataBaseUtils import MysqlUtils
from model.DingTalkUtils import DingTalkDecorators,DingTalkUtils

db = MysqlUtils()



@DingTalkDecorators("阳光")
def yangguang(start=None, end=None):
    if start:
        start = start + ' 00:00:00'
        end = end + ' 23:59:59'
    else:
        start = du.getTodayOrYestoday() + ' 00:00:00'
        end = du.get_n_hours_ago(0)

    client_id = 10008097
    token = '2xa1d55tTPBjeEA8Ho'
    accounts = get_account("阳光")
    if accounts.__len__() == 0:
        return
    else:
        print(f"阳光账号数：{accounts.__len__()}")

    for i in accounts:
        stage = i[0]
        vip_id = i[1]
        print(vip_id)
        get_yg_vip_channel(stage, vip_id, client_id, token)
        get_yg_data(stage, vip_id, client_id, token, start, end)
    x = 1
    while True:
        a = db.quchen_text.getOne("select count(1) from yangguang_path where update_time is null")
        print(f" vip 待处理数量 {a} 正在等待数据回调")
        if a == 0:
            break
        time.sleep(60)
        x += 1
        if x > 10:
            DingTalkUtils.send('阳光订单回调延时10min', '18860455786')
            break

    for i in accounts:
        vip_id = i[1]
        stage = i[0]
        parse_yg_data(vip_id, stage)



def get_account(plactform, id=None):
    op = f" and id={id} " if id else ''
    data = db.quchen_text.getData(f"select text from order_account_text where platform='{plactform}' {op}")
    new_data = []
    for i in data:
        new_data.append(i[0].replace('\n', '').split(","))
    return new_data

def daily_yg():
    st = du.get_n_days(-10)
    et = du.get_n_days(-1)
    yangguang(st, et)

if __name__ == '__main__':
    yangguang()