- #!/usr/bin/env python
- # -*- encoding:utf-8 -*-
- '''
- Created on 2014年12月18日
- @author: liujichao
- '''
- import datetime
- import json
- import re
- import sys
- import time
- import Image
- import PyV8
- import requests
- import tools.email_helper as emailHelper
- reload(sys)
- sys.setdefaultencoding('utf-8') # @UndefinedVariable
- reqSingle = requests.Session()
- attCheCi=["G655","G6741","G67","G491"] #关注的车次
- dateList=["2015-02-18"] #关注的日期
- username="12306登录用户名"
- password="登录密码"
- #这个是需要手动提交订单后f12自己找的,挨个post请求去找,参数名为:oldPassengerStr 格式如下
- oldPassengerStr="姓名,1,130434199802036011,1_姓名2,1,130434199204238069,1_"
- #这个是需要手动提交订单后f12自己找的,挨个post请求去找,参数名为:passengerTicketStr 格式如下
- passengerTicketStr="O,0,1,姓名,1,130434199802036011,13683456789,N_O,0,1,姓名2,1,130434199204238069,13683456789,N"
- header={
- "Accept":"text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8",
- "Accept-Encoding":"gzip, deflate",
- "Accept-Language":"zh-cn,zh;q=0.8,en-us;q=0.5,en;q=0.3",
- "Connection":"keep-alive",
- "Host":"kyfw.12306.cn",
- "Referer":"https://kyfw.12306.cn/otn/safeguard/init",
- "User-Agent":"Mozilla/5.0 (Windows NT 5.1; rv:34.0) Gecko/20100101 Firefox/34.0"
- }
- ##定火车票
- def orderTicket(fromStation,toStation,trainDate,secretStr):
- header["Referer"]="https://kyfw.12306.cn/otn/leftTicket/init"
- orderInitReq= reqSingle.get("https://kyfw.12306.cn/otn/leftTicket/init",headers=header)
- header["Referer"]="https://kyfw.12306.cn/otn/leftTicket/init"
- aryKV=extractKey(orderInitReq.content,header)
- print aryKV
- #初始化订票
- header["Referer"]="https://kyfw.12306.cn/otn/leftTicket/init"
- orderInitReq= reqSingle.post("https://kyfw.12306.cn/otn/leftTicket/submitOrderRequest",data={
- aryKV[0]:aryKV[1],
- "train_date":trainDate,
- "myversion":"undefined",
- "purpose_codes":"ADULT",
- "query_from_station_name":fromStation,
- "query_to_station_name":toStation,
- "secretStr":secretStr,
- "tour_flag":"dc",
- "back_train_date":time.strftime('%Y-%m-%d',time.localtime(time.time())),
- "undefined":""
- },headers=header)
- print orderInitReq.content
- orderInitJson=orderInitReq.json()
- if orderInitJson.get("status")==False or orderInitJson.get("httpstatus")!=200:
- raise Exception("订票出现错误")
- initDcReq= reqSingle.post("https://kyfw.12306.cn/otn/confirmPassenger/initDc", data={"_json_att":""},headers=header)
- header["Referer"]="https://kyfw.12306.cn/otn/confirmPassenger/initDc"
- aryKV=extractKey(initDcReq.content,header)
- match =re.search("var globalRepeatSubmitToken = '(.*?)';", initDcReq.content)
- ticketToken=match.group(1)
- lianxirenReq=reqSingle.post("https://kyfw.12306.cn/otn/confirmPassenger/getPassengerDTOs", data={"REPEAT_SUBMIT_TOKEN":ticketToken,"_json_att":""},headers=header)
- lianxirenJson=lianxirenReq.json()
- #验证码
- #开始做验证码
- while True:
- r=reqSingle.get("https://kyfw.12306.cn/otn/passcodeNew/getPassCodeNew?module=passenger&rand=randp&",verify=False,timeout=5,headers=header)
- with open("orderRand.jpg","wb") as rimg:
- rimg.write(r.content)
- pass
- img=Image.open("orderRand.jpg")
- img.show()
- randCode=raw_input("请输入登录验证码:")
- #验证验证码
- randReq= reqSingle.post("https://kyfw.12306.cn/otn/passcodeNew/checkRandCodeAnsyn",data={
- "REPEAT_SUBMIT_TOKEN":ticketToken,
- "_json_att":"",
- "rand":"randp",
- "randCode":randCode},headers=header)
- randRes=randReq.json()
- if randRes.get("status") and randRes.get("httpstatus")==200 and randRes.get("data").get("result")=="1":
- break;
- pass
- print "验证码输入正确!"
- #检查票
- checkOrderInfoReq=reqSingle.post("https://kyfw.12306.cn/otn/confirmPassenger/checkOrderInfo", data={
- aryKV[0]:aryKV[1],
- "REPEAT_SUBMIT_TOKEN":ticketToken,
- "_json_att":"",
- "bed_level_order_num":"000000000000000000000000000000",
- "cancel_flag":2,
- "oldPassengerStr":oldPassengerStr,
- "passengerTicketStr":passengerTicketStr,
- "randCode":randCode,
- "tour_flag":"dc"
- })
- checkOrderInfoJson=checkOrderInfoReq.json()
- if checkOrderInfoJson.get("status")==False or checkOrderInfoJson.get("httpstatus")!=200:
- raise Exception("检查票出现错误")
- pass
- fromStationTelecode=re.search("'from_station_telecode':'(.*?)'", initDcReq.content).group(1)
- leftTicket=re.search("'ypInfoDetail':'(.*?)'", initDcReq.content).group(1)
- purpose_codes=re.search("'purpose_codes':'(.*?)'", initDcReq.content).group(1)
- station_train_code=re.search("'station_train_code':'(.*?)'", initDcReq.content).group(1)
- to_station_telecode=re.search("'to_station_telecode':'(.*?)'", initDcReq.content).group(1)
- train_no=re.search("'train_no':'(.*?)'", initDcReq.content).group(1)
- queueCountReq=reqSingle.post("https://kyfw.12306.cn/otn/confirmPassenger/getQueueCount",data={
- "REPEAT_SUBMIT_TOKEN":ticketToken,
- "_json_att":"",
- "fromStationTelecode":fromStationTelecode,
- "leftTicket":leftTicket,
- "purpose_codes":purpose_codes,
- "seatType":0,
- "stationTrainCode":station_train_code,
- "toStationTelecode":to_station_telecode,
- "train_date":datetime.datetime.fromtimestamp(time.mktime(time.strptime(trainDate,'%Y-%m-%d'))).strftime('%a %b %d %Y %H:%M:%S GMT+0800'),
- "train_no":train_no
- },headers=header)
- queueCountJson=queueCountReq.json()
- print queueCountReq.content
- if queueCountJson.get("status")==False or queueCountJson.get("httpstatus")!=200:
- raise Exception("获取队列错误")
- #确认队列
- key_check_isChange=re.search("'key_check_isChange':'(.*?)'", initDcReq.content).group(1)
- train_location=re.search("'train_location':'(.*?)'", initDcReq.content).group(1)
- singleForQueueReq=reqSingle.post("https://kyfw.12306.cn/otn/confirmPassenger/confirmSingleForQueue",data={
- "REPEAT_SUBMIT_TOKEN":ticketToken,
- "_json_att":"",
- "dwAll":"N",
- "key_check_isChange":key_check_isChange,
- "leftTicketStr":leftTicket,
- "oldPassengerStr":oldPassengerStr,
- "passengerTicketStr":passengerTicketStr,
- "purpose_codes":purpose_codes,
- "randCode":randCode,
- "train_location":train_location
- },headers=header)
- singleForQueueJson=singleForQueueReq.json()
- print singleForQueueReq.content
- if singleForQueueJson.get("status")==False or singleForQueueJson.get("httpstatus")!=200:
- raise Exception("confirmSingleForQueue异常")
- if singleForQueueJson.get("data") is None or singleForQueueJson.get("data").get("submitStatus")==False:
- raise Exception("confirmSingleForQueue异常")
- #等待orderid
- while True:
- orderWaitReq= reqSingle.get("https://kyfw.12306.cn/otn/confirmPassenger/queryOrderWaitTime",data={"REPEAT_SUBMIT_TOKEN":ticketToken,
- "_json_att":"",
- "random":time.time(),
- "tourFlag":"dc"
- },headers=header)
- print orderWaitReq.content
- orderWaitJson=orderWaitReq.json()
- if orderWaitJson.get("status") and orderWaitJson.get("httpstatus")==200:
- if orderWaitJson.get("data") is not None and orderWaitJson.get("data").get("orderId") is not None:
- orderId=orderWaitJson.get("data").get("orderId")
- break
- pass
- pass
- #进入队列
- dcQueueReq=reqSingle.post("https://kyfw.12306.cn/otn/confirmPassenger/resultOrderForDcQueue",data={
- "REPEAT_SUBMIT_TOKEN":ticketToken,
- "_json_att":"",
- "orderSequence_no":orderId
- }
- ,headers=header)
- dcQueueJson=dcQueueReq.json()
- if dcQueueJson.get("status") and dcQueueJson.get("httpstatus")==200 and dcQueueJson.get("data") is not None and dcQueueJson.get("data").get("submitStatus"):
- print "订票成功"
- pass
- else:
- print dcQueueJson.content
- print "订票失败"
- pass
- #https://kyfw.12306.cn/otn/confirmPassenger/resultOrderForDcQueue
- pass
- #检查是否登录
- def checkIsLogin():
- checkReq= reqSingle.post("https://kyfw.12306.cn/otn/login/checkUser", data={"_json_att":""},headers=header)
- print u"检查是否登录"+checkReq.content
- checkReqJson=checkReq.json()
- if checkReqJson.get("status") and checkReqJson.get("httpstatus")==200:
- if checkReqJson.get("data") is not None and checkReqJson.get("data").get("flag"):
- return True
- pass
- return False
- pass
- #提取js加密内容后的key和value
- def extractKey(htmlContent,headerxx):
- loginMatch=re.search(r'<script src="(/otn/dynamicJs/.*?)" type="text/javascript" xml:space="preserve"></script>', htmlContent)
- jsUrl="https://kyfw.12306.cn"+ loginMatch.group(1)
- jsReq=reqSingle.get(jsUrl,verify=False,timeout=15,headers=headerxx)
- jsContent= jsReq.content
- jsMatch=re.search("(function bin216.*?)function aj", jsContent)
- jsEncode= jsMatch.group(1)#获取加密的js内容
- keyMatch=re.search("var key='(.*?)'",jsContent)
- loginKey= keyMatch.group(1)#获取登录的key
- ctx=PyV8.JSContext()
- ctx.enter()
- ctx.eval(jsEncode)
- loginValue=ctx.locals.encode32(ctx.locals.bin216(ctx.locals.Base32.encrypt( "1111",loginKey)))
- return [loginKey,loginValue]
- pass
- #登录操作
- def login():
- header["Referer"]="https://kyfw.12306.cn/otn/login/init"
- r=reqSingle.get("https://kyfw.12306.cn/otn/login/init",verify=False,timeout=15,headers=header)
- loginContent=r.content
- aryKV=extractKey(loginContent,header)
- #开始做验证码
- while True:
- r=reqSingle.get("https://kyfw.12306.cn/otn/passcodeNew/getPassCodeNew?module=login&rand=sjrand&",verify=False,timeout=5,headers=header)
- with open("loginRand.jpg","wb") as rimg:
- rimg.write(r.content)
- pass
- img=Image.open("loginRand.jpg")
- img.show()
- randCode=raw_input("请输入登录验证码:")
- #验证验证码
- randReq= reqSingle.post("https://kyfw.12306.cn/otn/passcodeNew/checkRandCodeAnsyn",data={"rand":"sjrand","randCode":randCode},headers=header)
- randRes=randReq.json()
- if randRes.get("status") and randRes.get("httpstatus")==200 and randRes.get("data").get("result")=="1":
- break;
- pass
- print "验证码输入正确!"
- #开始登陆
- loginRes=reqSingle.post("https://kyfw.12306.cn/otn/login/loginAysnSuggest",data={
- aryKV[0]:aryKV[1],
- "loginUserDTO.user_name":username,
- "userDTO.password":password,
- "randCode":randCode,
- "myversion":"undefined",
- "randCode_validate":""
- },headers=header)
- print repr(r.request)
- print loginRes.content
- loginResJson=loginRes.json()
- if loginResJson.get("status") and loginResJson.get("httpstatus")==200:
- if loginResJson.get("data") is not None and loginResJson.get("data").get("loginCheck")=="Y":
- print "登录成功"
- else:
- raise Exception(loginRes.content)
- else:
- login()
- pass
- def checkTicket(dtStr):
- print dt
- while True:
- try:
- r= requests.get("https://kyfw.12306.cn/otn/leftTicket/queryT?leftTicketDTO.train_date="+dtStr+"&leftTicketDTO.from_station=BXP&leftTicketDTO.to_station=HDP&purpose_codes=ADULT",verify=False,timeout=5,headers=header)
- break
- except Exception:
- pass
- pass
- #print r.contentfd
- print r.content
- try:
- queryDataJson= json.loads(r.content)
- except Exception:
- return
- if queryDataJson["httpstatus"]==200 and queryDataJson["status"] :
- #print queryDataJson["data"]
- for checi in queryDataJson["data"]:
- tmpData=checi["queryLeftNewDTO"]
- trainCode=tmpData.get("station_train_code")
- #yzNum=tmpData.get("yz_num")
- yzNum=tmpData.get("ze_num")
- if trainCode in attCheCi:
- if yzNum!="--" and yzNum!="无" and (yzNum=="有" or int(yzNum)>=2):
- #发邮件
- fromStation=tmpData.get("start_station_name")
- toStation=tmpData.get("end_station_name")
- secretStr=checi.get("secretStr")
- orderTicket(fromStation, toStation, dtStr, secretStr)
- # body=dtStr+"-"+trainCode+"-"+yzNum+u"个硬座"
- # print body
- # mailer=emailHelper.email_helper("smtp.qq.com", "fd", "fss", "qq.com","plain")
- # mailer.send("[email protected]", u"有火车票了",body)
- # raise Exception("有票了")
- pass
- print trainCode+yzNum
- pass
- pass
- pass
- if __name__ == '__main__':
- # login()
- # if checkIsLogin():
- # print "登录成功"
- #
- # orderTicket("北京西","邯郸东","2015-01-14","MjAxNS0wMS0xNCMwMCNHNjczMSMwMjoxNSMwNzowNSMyNDAwMEc2NzMxMDUjQlhQI0hQUCMwOToyMCPljJfkuqzopb8j6YKv6YO45LicIzAxIzA2I08wMDAwMDA4MThNMDAwMDAwMTEwOTAwMDAwMDAyNiNQMiMxNDE5MDg2OTU2MTA0IzI5NEI0QkY0QTU2ODE2RDU1MzE5RkRCRkVEQzQ3Mzk2MUEyRUEwOEM0MUVCMjZGMDc3RUUyNzc0")
- # exit()
- login()
- if checkIsLogin():
- print "登录成功"
- while True:
- checkCount=0
- for dt in dateList:
- checkTicket(dt)
- time.sleep(2)
- checkCount+=1
- if checkCount%10==0:
- if checkIsLogin():
- print "成功状态"
- else:
- print "被踢了"
- pass
- pass
来源: http://www.phpxs.com/code/1009467/