|
|
@@ -103,35 +103,56 @@ def get_qiyue_user_info(account):
|
|
|
stage = account[0]
|
|
|
token = account[1]
|
|
|
page = 1
|
|
|
- size = 50
|
|
|
+ size = 100
|
|
|
freq = 0
|
|
|
li = []
|
|
|
while True:
|
|
|
timestamp = int(time.time())
|
|
|
url = order_url + "?" + "token=" + str(token) + "×tamp=" + str(timestamp) + "&page=" + str(
|
|
|
- page) + "&size=" + str(size) + "&date="
|
|
|
+ page) + "&size=" + str(size)
|
|
|
r = requests.get(url=url).json()
|
|
|
- print(r)
|
|
|
+ # print(r)
|
|
|
+
|
|
|
+ freq += 1
|
|
|
+ if freq == 59:
|
|
|
+ print("一分钟请求60次的限制 等待中")
|
|
|
+ time.sleep(61)
|
|
|
+ freq = 0
|
|
|
+
|
|
|
if r['code'] != 0:
|
|
|
- DingTalkUtils.send('七悦用户拉取接口错误'+r['msg'])
|
|
|
- else:
|
|
|
+ print(r)
|
|
|
continue
|
|
|
- i = r['data']['data']
|
|
|
- li.append(('七悦',
|
|
|
- i['id'],
|
|
|
- i['openid'],
|
|
|
- i['channel_id'],
|
|
|
- i['wechat_app_name'],
|
|
|
- i['wechat_app_id'],
|
|
|
+ # DingTalkUtils.send('七悦用户拉取接口错误'+r['msg'])
|
|
|
|
|
|
- ))
|
|
|
+ for i in r['data']['data']:
|
|
|
+ li.append(('七悦',
|
|
|
+ i['id'],
|
|
|
+ i['openid'],
|
|
|
+ i['channel_id'],
|
|
|
+ i['wechat_app_name'],
|
|
|
+ i['wechat_app_id'],
|
|
|
+ i['kandian'],
|
|
|
+ i['free_kandian'],
|
|
|
+ i['vip_endtime']
|
|
|
|
|
|
+ ))
|
|
|
+
|
|
|
+ if len(r['data']['data']) < size:
|
|
|
+ break
|
|
|
+ page += 1
|
|
|
+ print(f"{stage} 有粉丝{len(li)}")
|
|
|
+ if len(li)>0:
|
|
|
+ sql="replace into platform_user_info values (%s,%s,%s,%s,%s,%s,%s,%s,%s)"
|
|
|
+ db.quchen_text.executeMany(sql,li)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
-if __name__ == '__main__':
|
|
|
|
|
|
+if __name__ == '__main__':
|
|
|
+ st ='2020-11-01'
|
|
|
+ et ='2021-01-01'
|
|
|
+ db.quchen_text.execute(f'DELETE from ods_order where platform="七悦" and date>="{st}" and date<="{et}"')
|
|
|
for account in get_account("七悦"):
|
|
|
- get_qiyue_order_task('2021-06-03','2021-06-03',account)
|
|
|
+ get_qiyue_order_task(st, et, account)
|
|
|
# get_qiyue_user_info(account)
|
