本文實例講述了python代碼寫的12306訂票代碼，分享給大家供大家參考。
具體實現方法如下：
import datetimeimport jsonimport reimport sysimport time import Imageimport PyV8import requests import tools.email_helper as emailHelper reload(sys)sys.setdefaultencoding('utf-8') # @UndefinedVariablereqSingle = 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和valuedef 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() passdef 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("630419595@qq.com", u"有火車票了",body)# raise Exception("有票了") pass print trainCode+yzNum pass pass passif __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 大家搶到回家過年的車票了嗎？
希望本文所述對大家的Python程序設計有所幫助。
