qc-dgp/dgp/tests/b.py

#!/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))