jinql
/
12306
mirror of https://github.com/testerSunshine/12306
1
0
Fork 0
Code Issues Releases Wiki Activity

增加提交订单验证码校验

pull/4/head
wenxianping 2018-01-11 16:01:37 +08:00
parent 53f030537d
commit 1d1237e1a4
1 changed files with 31 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

49
init/select_ticket_info.py
View File

@ -466,32 +466,45 @@ class select:
try: try:
for i in range(3): for i in range(3):
if is_node_code: if is_node_code:
print("需要验证码，正在使用自动识别验证码功能") print("正在使用自动识别验证码功能")
randurl = 'https://kyfw.12306.cn/otn/passcodeNew/checkRandCodeAnsyn'
codeimg = 'https://kyfw.12306.cn/otn/passcodeNew/getPassCodeNew?module=passenger&rand=sjrand&%s' % random.random() codeimg = 'https://kyfw.12306.cn/otn/passcodeNew/getPassCodeNew?module=passenger&rand=sjrand&%s' % random.random()
result = myurllib2.get(codeimg) result = myurllib2.get(codeimg)
img_path = './tkcode' img_path = './tkcode'
open(img_path, 'wb').write(result) open(img_path, 'wb').write(result)
data['randCode'] = DamatuApi(_get_yaml()["damatu"]["uesr"], _get_yaml()["damatu"]["pwd"], randCode = DamatuApi(_get_yaml()["damatu"]["uesr"], _get_yaml()["damatu"]["pwd"],
img_path).main() img_path).main()
randData = {
"randCode": randCode,
"rand": "randp",
"_json_att": None,
"REPEAT_SUBMIT_TOKEN": self.get_token()
}
fresult = json.loads(myurllib2.Post(randurl, randData), encoding='utf8') # 校验验证码是否正确
checkcode = fresult['data']['msg']
if checkcode == 'FALSE':
print ("验证码有误,第{}次尝试重试".format(i))
else:
print("验证码通过,正在提交订单")
data['randCode'] = randCode
else: else:
print("不需要验证码") print("不需要验证码")
checkQueueOrderResult = json.loads(myurllib2.Post(checkQueueOrderUrl, data)) checkQueueOrderResult = json.loads(myurllib2.Post(checkQueueOrderUrl, data))
if "status" in checkQueueOrderResult and checkQueueOrderResult["status"]: if "status" in checkQueueOrderResult and checkQueueOrderResult["status"]:
c_data = checkQueueOrderResult["data"] if "data" in checkQueueOrderResult else {} c_data = checkQueueOrderResult["data"] if "data" in checkQueueOrderResult else {}
if 'submitStatus' in c_data and c_data['submitStatus'] is True: if 'submitStatus' in c_data and c_data['submitStatus'] is True:
print("提交订单成功！") print("提交订单成功！")
break self.queryOrderWaitTime()
else:
if 'errMsg' in c_data and c_data['errMsg']:
print("提交订单失败，{0}，重新识别中".format(c_data['errMsg']))
else:
print(c_data)
print('订票失败!很抱歉,请重试提交预订功能!')
elif "messages" in checkQueueOrderResult and checkQueueOrderResult["messages"]:
print("提交订单失败,错误信息: " + checkQueueOrderResult["messages"])
else: else:
print("提交订单中，请耐心等待：" + str(checkQueueOrderResult["validateMessages"])) if 'errMsg' in c_data and c_data['errMsg']:
self.queryOrderWaitTime() print("提交订单失败，{0}".format(c_data['errMsg']))
else:
print(c_data)
print('订票失败!很抱歉,请重试提交预订功能!')
elif "messages" in checkQueueOrderResult and checkQueueOrderResult["messages"]:
print("提交订单失败,错误信息: " + checkQueueOrderResult["messages"])
else:
print("提交订单中，请耐心等待：" + str(checkQueueOrderResult["validateMessages"]))
except ValueError: except ValueError:
print("接口 {} 无响应".format(checkQueueOrderUrl)) print("接口 {} 无响应".format(checkQueueOrderUrl))