mirror of https://github.com/testerSunshine/12306
优化查询逻辑
parent
2465d61554
commit
0e6f2ceee2
|
@ -196,7 +196,7 @@ urls = {
|
||||||
"Referer": "https://kyfw.12306.cn/otn/leftTicket/init",
|
"Referer": "https://kyfw.12306.cn/otn/leftTicket/init",
|
||||||
"Host": "kyfw.12306.cn",
|
"Host": "kyfw.12306.cn",
|
||||||
"re_try": 10,
|
"re_try": 10,
|
||||||
"re_time": 0.1,
|
"re_time": 0.01,
|
||||||
"s_time": 0.1,
|
"s_time": 0.1,
|
||||||
"is_logger": True,
|
"is_logger": True,
|
||||||
"is_json": True,
|
"is_json": True,
|
||||||
|
@ -207,7 +207,7 @@ urls = {
|
||||||
"Referer": "https://kyfw.12306.cn/otn/confirmPassenger/initDc",
|
"Referer": "https://kyfw.12306.cn/otn/confirmPassenger/initDc",
|
||||||
"Host": "kyfw.12306.cn",
|
"Host": "kyfw.12306.cn",
|
||||||
"re_try": 10,
|
"re_try": 10,
|
||||||
"re_time": 0.1,
|
"re_time": 0.01,
|
||||||
"s_time": 0.1,
|
"s_time": 0.1,
|
||||||
"is_logger": True,
|
"is_logger": True,
|
||||||
"is_json": True,
|
"is_json": True,
|
||||||
|
@ -218,7 +218,7 @@ urls = {
|
||||||
"Referer": "https://kyfw.12306.cn/otn/confirmPassenger/initDc",
|
"Referer": "https://kyfw.12306.cn/otn/confirmPassenger/initDc",
|
||||||
"Host": "kyfw.12306.cn",
|
"Host": "kyfw.12306.cn",
|
||||||
"re_try": 10,
|
"re_try": 10,
|
||||||
"re_time": 0.1,
|
"re_time": 0.01,
|
||||||
"s_time": 0.1,
|
"s_time": 0.1,
|
||||||
"is_logger": True,
|
"is_logger": True,
|
||||||
"is_json": True,
|
"is_json": True,
|
||||||
|
@ -229,7 +229,7 @@ urls = {
|
||||||
"Referer": "https://kyfw.12306.cn/otn/confirmPassenger/initDc",
|
"Referer": "https://kyfw.12306.cn/otn/confirmPassenger/initDc",
|
||||||
"Host": "kyfw.12306.cn",
|
"Host": "kyfw.12306.cn",
|
||||||
"re_try": 10,
|
"re_try": 10,
|
||||||
"re_time": 0.1,
|
"re_time": 0.01,
|
||||||
"s_time": 0.1,
|
"s_time": 0.1,
|
||||||
"is_logger": True,
|
"is_logger": True,
|
||||||
"is_json": True,
|
"is_json": True,
|
||||||
|
@ -240,7 +240,7 @@ urls = {
|
||||||
"Referer": "https://kyfw.12306.cn/otn/confirmPassenger/initDc",
|
"Referer": "https://kyfw.12306.cn/otn/confirmPassenger/initDc",
|
||||||
"Host": "kyfw.12306.cn",
|
"Host": "kyfw.12306.cn",
|
||||||
"re_try": 10,
|
"re_try": 10,
|
||||||
"re_time": 0.1,
|
"re_time": 0.01,
|
||||||
"s_time": 0.1,
|
"s_time": 0.1,
|
||||||
"is_logger": True,
|
"is_logger": True,
|
||||||
"is_json": True,
|
"is_json": True,
|
||||||
|
@ -251,7 +251,7 @@ urls = {
|
||||||
"Referer": "https://kyfw.12306.cn/otn/confirmPassenger/initDc",
|
"Referer": "https://kyfw.12306.cn/otn/confirmPassenger/initDc",
|
||||||
"Host": "kyfw.12306.cn",
|
"Host": "kyfw.12306.cn",
|
||||||
"re_try": 10,
|
"re_try": 10,
|
||||||
"re_time": 0.1,
|
"re_time": 0.01,
|
||||||
"s_time": 0.1,
|
"s_time": 0.1,
|
||||||
"is_logger": False,
|
"is_logger": False,
|
||||||
"is_json": False,
|
"is_json": False,
|
||||||
|
@ -262,7 +262,7 @@ urls = {
|
||||||
"Referer": "https://kyfw.12306.cn/otn/confirmPassenger/initDc",
|
"Referer": "https://kyfw.12306.cn/otn/confirmPassenger/initDc",
|
||||||
"Host": "kyfw.12306.cn",
|
"Host": "kyfw.12306.cn",
|
||||||
"re_try": 10,
|
"re_try": 10,
|
||||||
"re_time": 0.1,
|
"re_time": 0.01,
|
||||||
"s_time": 0.1,
|
"s_time": 0.1,
|
||||||
"is_logger": True,
|
"is_logger": True,
|
||||||
"is_json": True,
|
"is_json": True,
|
||||||
|
@ -273,7 +273,7 @@ urls = {
|
||||||
"Referer": "https://kyfw.12306.cn/otn/queryOrder/initNoComplete",
|
"Referer": "https://kyfw.12306.cn/otn/queryOrder/initNoComplete",
|
||||||
"Host": "kyfw.12306.cn",
|
"Host": "kyfw.12306.cn",
|
||||||
"re_try": 10,
|
"re_try": 10,
|
||||||
"re_time": 0.1,
|
"re_time": 0.01,
|
||||||
"s_time": 0.1,
|
"s_time": 0.1,
|
||||||
"is_logger": True,
|
"is_logger": True,
|
||||||
"is_json": True,
|
"is_json": True,
|
||||||
|
@ -284,7 +284,7 @@ urls = {
|
||||||
"Referer": "https://kyfw.12306.cn/otn/queryOrder/initNoComplete",
|
"Referer": "https://kyfw.12306.cn/otn/queryOrder/initNoComplete",
|
||||||
"Host": "kyfw.12306.cn",
|
"Host": "kyfw.12306.cn",
|
||||||
"re_try": 10,
|
"re_try": 10,
|
||||||
"re_time": 0.1,
|
"re_time": 0.01,
|
||||||
"s_time": 0.1,
|
"s_time": 0.1,
|
||||||
"is_logger": False,
|
"is_logger": False,
|
||||||
"is_json": False,
|
"is_json": False,
|
||||||
|
@ -295,7 +295,7 @@ urls = {
|
||||||
"Referer": "https://kyfw.12306.cn/otn/queryOrder/initNoComplete",
|
"Referer": "https://kyfw.12306.cn/otn/queryOrder/initNoComplete",
|
||||||
"Host": "kyfw.12306.cn",
|
"Host": "kyfw.12306.cn",
|
||||||
"re_try": 10,
|
"re_try": 10,
|
||||||
"re_time": 0.1,
|
"re_time": 0.01,
|
||||||
"s_time": 0.1,
|
"s_time": 0.1,
|
||||||
"is_logger": True,
|
"is_logger": True,
|
||||||
"is_json": True,
|
"is_json": True,
|
||||||
|
@ -307,7 +307,7 @@ urls = {
|
||||||
"Host": "kyfw.12306.cn",
|
"Host": "kyfw.12306.cn",
|
||||||
"Content-Type": 1,
|
"Content-Type": 1,
|
||||||
"re_try": 10,
|
"re_try": 10,
|
||||||
"re_time": 0.1,
|
"re_time": 0.01,
|
||||||
"s_time": 0.1,
|
"s_time": 0.1,
|
||||||
"is_logger": True,
|
"is_logger": True,
|
||||||
"is_json": True,
|
"is_json": True,
|
||||||
|
@ -319,7 +319,7 @@ urls = {
|
||||||
"Host": "kyfw.12306.cn",
|
"Host": "kyfw.12306.cn",
|
||||||
"Content-Type": 1,
|
"Content-Type": 1,
|
||||||
"re_try": 10,
|
"re_try": 10,
|
||||||
"re_time": 0.1,
|
"re_time": 0.01,
|
||||||
"s_time": 0.1,
|
"s_time": 0.1,
|
||||||
"is_logger": True,
|
"is_logger": True,
|
||||||
"is_json": True,
|
"is_json": True,
|
||||||
|
@ -331,7 +331,7 @@ urls = {
|
||||||
"Content-Type": 1,
|
"Content-Type": 1,
|
||||||
"Host": "kyfw.12306.cn",
|
"Host": "kyfw.12306.cn",
|
||||||
"re_try": 10,
|
"re_try": 10,
|
||||||
"re_time": 0.1,
|
"re_time": 0.01,
|
||||||
"s_time": 0.1,
|
"s_time": 0.1,
|
||||||
"is_logger": True,
|
"is_logger": True,
|
||||||
"is_json": True,
|
"is_json": True,
|
||||||
|
|
|
@ -244,8 +244,7 @@ class select:
|
||||||
sor.sendSubmitOrderRequest()
|
sor.sendSubmitOrderRequest()
|
||||||
else:
|
else:
|
||||||
random_time = round(random.uniform(0.5, 0.5), 2)
|
random_time = round(random.uniform(0.5, 0.5), 2)
|
||||||
time.sleep(random_time)
|
print(u"正在第{0}次查询 随机停留时长:{6} 乘车日期: {1} 车次:{2} 查询无票 cdn轮询IP:{4}当前cdn总数:{5} 总耗时:{3}ms".format(num,
|
||||||
print u"正在第{0}次查询 随机停留时长:{6} 乘车日期: {1} 车次:{2} 查询无票 cdn轮询IP:{4}当前cdn总数:{5} 总耗时:{3}ms".format(num,
|
|
||||||
",".join(
|
",".join(
|
||||||
self.station_dates),
|
self.station_dates),
|
||||||
",".join(
|
",".join(
|
||||||
|
@ -255,7 +254,8 @@ class select:
|
||||||
queryResult.get("cdn", None),
|
queryResult.get("cdn", None),
|
||||||
len(
|
len(
|
||||||
self.cdn_list),
|
self.cdn_list),
|
||||||
random_time)
|
random_time))
|
||||||
|
time.sleep(random_time)
|
||||||
except PassengerUserException as e:
|
except PassengerUserException as e:
|
||||||
print e.message
|
print e.message
|
||||||
break
|
break
|
||||||
|
|
|
@ -14,7 +14,7 @@ class checkUser:
|
||||||
检查用户登录, 检查间隔为2分钟
|
检查用户登录, 检查间隔为2分钟
|
||||||
:return:
|
:return:
|
||||||
"""
|
"""
|
||||||
CHENK_TIME = 1
|
CHENK_TIME = 0.3
|
||||||
if wrapcache.get("user_time") is None:
|
if wrapcache.get("user_time") is None:
|
||||||
check_user_url = self.session.urls["check_user_url"]
|
check_user_url = self.session.urls["check_user_url"]
|
||||||
data = {"_json_att": ""}
|
data = {"_json_att": ""}
|
||||||
|
|
|
@ -39,7 +39,6 @@ class query:
|
||||||
self.arrival_time = session.arrival_time
|
self.arrival_time = session.arrival_time
|
||||||
self.take_time = session.take_time
|
self.take_time = session.take_time
|
||||||
|
|
||||||
|
|
||||||
@classmethod
|
@classmethod
|
||||||
def station_seat(self, index):
|
def station_seat(self, index):
|
||||||
"""
|
"""
|
||||||
|
@ -90,7 +89,7 @@ class query:
|
||||||
self.session.queryUrl)
|
self.session.queryUrl)
|
||||||
station_ticket = self.httpClint.send(select_url)
|
station_ticket = self.httpClint.send(select_url)
|
||||||
if station_ticket.get("c_url", ""):
|
if station_ticket.get("c_url", ""):
|
||||||
print(station_ticket.get("c_url", ""))
|
print(u"设置当前查询url为: {}".format(station_ticket.get("c_url", "")))
|
||||||
self.session.queryUrl = station_ticket.get("c_url", "") # 重设查询接口
|
self.session.queryUrl = station_ticket.get("c_url", "") # 重设查询接口
|
||||||
continue
|
continue
|
||||||
value = station_ticket.get("data", "")
|
value = station_ticket.get("data", "")
|
||||||
|
|
|
@ -57,7 +57,6 @@ class submitOrderRequest:
|
||||||
submitResult = self.session.httpClint.send(submit_station_url, self.data_apr())
|
submitResult = self.session.httpClint.send(submit_station_url, self.data_apr())
|
||||||
if 'data' in submitResult and submitResult['data']:
|
if 'data' in submitResult and submitResult['data']:
|
||||||
if submitResult['data'] == 'N':
|
if submitResult['data'] == 'N':
|
||||||
print (u'出票成功')
|
|
||||||
coi = checkOrderInfo(self.session, self.train_no, self.set_type, self.passengerTicketStrList,
|
coi = checkOrderInfo(self.session, self.train_no, self.set_type, self.passengerTicketStrList,
|
||||||
self.oldPassengerStr,
|
self.oldPassengerStr,
|
||||||
self.train_date, self.ticke_peoples)
|
self.train_date, self.ticke_peoples)
|
||||||
|
|
Loading…
Reference in New Issue