|
|
@@ -116,7 +116,7 @@ def get_yangguang_order(st,et,account_list):
|
|
|
def get_yangguang_order_task(st,et,account):
|
|
|
order_list = ()
|
|
|
url = 'https://api.yifengaf.cn:443/api/channeldataapi/orders'
|
|
|
- url_frequency = 1
|
|
|
+ url_frequency = 0
|
|
|
##接口鉴权参数
|
|
|
client_id = account[0]
|
|
|
token = account[1]
|
|
|
@@ -126,6 +126,7 @@ def get_yangguang_order_task(st,et,account):
|
|
|
stage = account[2]
|
|
|
channel = account[4]
|
|
|
|
|
|
+ order_st_date = date_util.getSelfDateStr(int(st-86400),date_format='%Y-%m-%d')
|
|
|
for i in range((et-st)//86400 + 1):
|
|
|
last_id = 111
|
|
|
statis_unix_time = st + (i-1)*86400
|
|
|
@@ -135,7 +136,7 @@ def get_yangguang_order_task(st,et,account):
|
|
|
if st == et:
|
|
|
break
|
|
|
|
|
|
- if url_frequency//30 == 0 :
|
|
|
+ if url_frequency % 3 == 0 :
|
|
|
time.sleep(61)
|
|
|
url_frequency += 1
|
|
|
|
|
|
@@ -203,7 +204,7 @@ def get_yangguang_order_task(st,et,account):
|
|
|
x = tuple(x.values())
|
|
|
order_list = order_list + ((x),)
|
|
|
|
|
|
- print(f"数据日期-{search_date}-公众号-{channel}-获取数据-{len(order_list)}条，例如: {order_list[0:1]}")
|
|
|
+ print(f"数据日期-{order_st_date}到{search_date}-公众号-{channel}-获取数据-{len(order_list)}条，例如: {order_list[0:1]}")
|
|
|
return order_list
|
|
|
|
|
|
|
|
|
@@ -240,7 +241,7 @@ def start_order_job():
|
|
|
#if __name__ == '__main__':
|
|
|
# start_order_job()
|
|
|
|
|
|
-start_job_time = '2020-11-11 01:20:00'
|
|
|
+start_job_time = '2020-11-17 01:20:00'
|
|
|
if __name__ == '__main__':
|
|
|
scheduler = BlockingScheduler()
|
|
|
scheduler.add_job(start_order_job, 'interval', days =1 ,start_date=start_job_time)
|
