#!/usr/bin/env python
# -*- coding: utf-8 -*-
"""
get_order_daily.py
"""


def get_zzy_order(st, et):
    API_list = al.zzy_account_list
    url = 'https://openapi.818tu.com/partners/channel/channels/list?'

    for x in API_list:
        my_key = x[0]
        secert = x[1]
        stage = x[2]
        my_sign = md5value(secert + 'key=' + my_key)
        parameter = 'key=' + my_key + '&sign=' + my_sign
        channel_list = requests.get(url + parameter)  # 获取子渠道列表

        if 'data' in channel_list.json().keys():
            items = channel_list.json()['data']['items']
        elif len(x) > 3:
            # print(channel_list.json())
            my_key = x[3]
            secert = x[4]
            my_sign = md5value(secert + 'key=' + my_key)
            parameter = 'key=' + my_key + '&sign=' + my_sign
            # url = 'https://openapi.818tu.com/partners/channel/channels/list?'
            channel_list = requests.get(url + parameter)
            items = channel_list.json()['data']['items']
        else:
            print(channel_list.json())
            items = []

        for item in items:  # 获取channel_id 后逐个拉取历史orders
            r = ()
            channel_id = item['id']
            channel = item['nickname']
            status = str(1)
            per_page = str(1000)
            limit_time = et
            get_time = st
            lt = parse.urlencode({'created_at[lt]': limit_time})
            gt = parse.urlencode({'created_at[gt]': get_time})
            url_1 = 'https://openapi.818tu.com/partners/channel/orders/list?'
            my_sign_1 = md5value(secert + 'channel_id=' + str(
                channel_id) + '&created_at[gt]=' + get_time + '&created_at[lt]=' + limit_time + '&key=' + my_key + '&per_page=' + per_page + '&status=' + status)
            parameter_1 = 'channel_id=' + str(
                channel_id) + '&' + gt + '&' + lt + '&per_page=' + per_page + '&status=' + status + '&key=' + my_key + '&sign=' + my_sign_1
            orders = requests.get(url_1 + parameter_1)
            t = orders.json()['data']['count'] // int(per_page) + 1
            for page in range(1, t + 1):
                my_sign_2 = md5value(secert + 'channel_id=' + str(
                    channel_id) + '&created_at[gt]=' + get_time + '&created_at[lt]=' + limit_time + '&key=' + my_key + '&page=' + str(
                    page) + '&per_page=' + per_page + '&status=' + status)
                parameter_2 = 'channel_id=' + str(channel_id) + '&' + gt + '&' + lt + '&page=' + str(
                    page) + '&per_page=' + per_page + '&status=' + status + '&key=' + my_key + '&sign=' + my_sign_2
                orders_1 = requests.get(url_1 + parameter_2)
                b = orders_1.json()['data']['items']

                for a in b:
                    c = {}
                    c['user_id'] = str(a['member']['openid'])
                    c['channel'] = channel
                    c['reg_time'] = a['member']['created_at']
                    c['channel_id'] = channel_id
                    c['amount'] = round(a['price'] / 100, 2)
                    c['order_id'] = str(a['id'])
                    c['order_time'] = a['created_at']
                    c['platform'] = '掌中云'
                    c['stage'] = stage
                    # c['amount']=a['amount']
                    dtime = datetime.datetime.strptime(a['created_at'][0:10], "%Y-%m-%d")
                    c['date'] = ((int(time.mktime(dtime.timetuple())) + 8 * 3600) // 86400) * 86400 - 8 * 3600

                    if str(a['from_novel_id']) != 'None':
                        c['from_novel'] = a['from_novel']['title']
                    else:
                        c['from_novel'] = 'None'
                    """
                    del a['member']
                    del a['referral_link_id']
                    del a['id']
                    del a['created_at']
                    del a['paid_at']
                    del a['border_id']
                    del a['from_novel_id']
                    del a['status']
                    del a['price']
                    del a['agent_uid']
                    """
                    x = sorted(c.items(), key=lambda item: item[0])
                    x = dict(x)
                    x = tuple(x.values())
                    r = r + ((x),)

            if len(r) > 0:
                mysql_insert_order(r)

            print('zzy', channel, len(r))