Python爬虫之12306-买票器小白源码

梦里梦外; 2023-10-11 13:15 26阅读 0赞

研究不易

import requests
    import re
    import urllib.parse
    import json
    import datetime
    from collections import OrderedDict
    self=requests.session()
    self.verify=False
    self.headers={
        'Accept':'text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,image/apng,*/*;q=0.8',
        'Accept-Encoding':'gzip, deflate, br',
        'Accept-Language':'zh-CN,zh;q=0.9',
        'Connection':'keep-alive',
        'Host':'kyfw.12306.cn',
        'Cache-Control':'no-cache',
        'User-Agent':'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/68.0.3440.106 Safari/537.36',
        }
    def dow():
        url='https://kyfw.12306.cn/passport/captcha/captcha-image?login_site=E&module=login&rand=sjrand'
        requests.packages.urllib3.disable_warnings()
        res=self.get(url)
        print(res.status_code)
        if res.status_code==200:
           with open('login.jpg','wb') as f:
              f.write(res.content)
        else:
            dow()
    #验证
    def yanzhengma():
         #获取验证码
         dow()
         # 1 2 3 4 5 6 7 8
         xylist=['35,35','105,35','175,35','245,35','35,105','105,105','175,105','245,105']
         print('请依次输入验证码的位置并换行,0表示结束')
         ilist=[]
         while True:
            i=input()
            if i=='0':
                break
            ilist.append(xylist[int(i)-1])
         xy=','.join(ilist)
         print(xy)
    
         data={
             'answer':xy,
             'login_site':'E',
             'rand':'sjrand'
         }
         url='https://kyfw.12306.cn/passport/captcha/captcha-check'
         requests.packages.urllib3.disable_warnings()
         res=self.post(url,data=data)
         print(res.url)
         print(res.text)
         code=re.search('_code.*?(\d)',res.text,re.S).group(1)
    
         print(code)
    
         # 成功返回True，失败递归调用
         if code=='4':
             print('验证成功，请登陆')
    
         elif code=='5':
             print('验证错误')
             yanzhengma()
         elif code=='7':
             print('验证超时')
             yanzhengma()
         else:
             print('验证失败')
             yanzhengma()
    def login():
         yanzhengma()#验证码
         data={
             'username':'18772565439',
             'password':'654321qw',
             'appid':'otn'
         }
         url='https://kyfw.12306.cn/passport/web/login'
         requests.packages.urllib3.disable_warnings()
         res=self.post(url,data=data)
         print(res.text)
         code=re.search('_code.*?(\d)',res.text,re.S).group(1)
    
    
         # 成功返回True，失败递归调用
         if code=='0':
             yzdata={
             'appid':'otn'
             }
             tk_url='https://kyfw.12306.cn/passport/web/auth/uamtk'
             resp3=self.post(tk_url,data=yzdata)
             print('-----------------第一次验证-----------------')
             print(resp3.text)
             login_message=resp3.json()['newapptk']
             print('loginMessage=',login_message)
             yz2data={
                 'tk':login_message
             }
             client_url='https://kyfw.12306.cn/otn/uamauthclient'
             resp4=self.post(client_url,data=yz2data)
             print('-----------------第二次验证-----------------')
             print(resp4.text)
             print('登陆成功，可以开始购票')
    
         elif code=='1':
             print('密码输入错误。如果输错次数超过4次，用户将被锁定。')
             login()
         else:
    
             print('登录失败')
             login()
    def shoppiao():
    
        data={
           'leftTicketDTO.train_date':'2018-10-15',#时间
            'leftTicketDTO.from_station':'BJQ',#出发站码
            'leftTicketDTO.to_station':'CBN',#目的地码
            'purpose_codes':'ADULT'#票类型ADULT成人，STUDENT学生
        }
        url='https://kyfw.12306.cn/otn/leftTicket/queryA?'
        requests.packages.urllib3.disable_warnings()
        res=self.get(url,params=data)
        print(res.status_code)
        print(res.text)
        dictr=json.loads(res.text)
        pklist=dictr.get('data').get('result')
        for item in pklist:
            sp_item = item.split('|')
            for index, item in enumerate(sp_item,0):
    
                print('{}:\t{}'.format(index, item))
            '''
            通过分析
            0：列车信息（订票时候需要） 1：信息 2：火车编号
            3：列车号 4：始发站   5：终点站   6：起始站  7：目标站    8：出发时间       9：到达时间
            10：行车时间
            11：有3种状态：Y, N, IS_TIME_NOT_BUY 分别对应，可以预定，不可以预定，其他原因----对应的是第1项
            12：参数leftTicket
            13：日期
            14：
            15：参数train_location
            21：高级动卧   22：        23：软卧 24：软座  25：特等座  26：无座 28：硬卧  29：硬座  30：二等座  31：一等座  32：商务座 33：动卧
           '''
            if sp_item[11]=='Y':#可以买票，开始订票
                if sp_item[30]!='无':#买二等座
                    print(sp_item[30])
                    if vel_longin_2():#验证登陆
                       print('已经登陆可以开始下单')
                       self.headers['X-Requested-With']='XMLHttpRequest'
                       secretStr=urllib.parse.unquote(sp_item[0])
    
    
                       self.headers['Referer'] = 'https://kyfw.12306.cn/otn/leftTicket/init'
    
                       submitOrderRequest(secretStr)
    
                       data = OrderedDict()
                       data["_json_att"] =''
                       data["fromStationTelecode"] =sp_item[6]
                       data["leftTicket"] = sp_item[12]
                       data['purpose_codes']='00'
                       data['REPEAT_SUBMIT_TOKEN']=''
                       data["seatType"] = 'O'
                       data["stationTrainCode"] = sp_item[3]
                       data["toStationTelecode"] =sp_item[7]
                       data["train_date"] = str(datetime.datetime.strptime(sp_item[13], '%Y%m%d').strftime('%a %b %d %Y %H:%M:%S GMT+0800'))
                       data["train_location"] = sp_item[15]
                       data["train_no"] =sp_item[2]
    
                       '''
                       data={
                            'train_date':str(datetime.datetime.strptime(sp_item[13], '%Y%m%d').strftime('%a %b %d %Y %H:%M:%S GMT+0800')),
                            'train_no':sp_item[2],#火车编号
                            'stationTrainCode':sp_item[3],#列车号
                            'seatType':'O',#座位类型 1是硬座(无座)，2是软座，3是硬卧，4是软卧,  O 大写字母  是高铁二等座，M是高铁一等座，商务座(9),特等座(P),高级软卧(6)
                           'fromStationTelecode':sp_item[6],#起始站编号
                            'toStationTelecode':sp_item[7],#目标站编号
                            'leftTicket':sp_item[12],
                            'train_location':sp_item[15],#15项Q6
                       }
                    '''
                       shopdin(data)
    
                    else:
                        login()
                        shoppiao()
            break
    
    def submitOrderRequest(secretStr):
        data = OrderedDict()
        data["secretStr"] = secretStr
        data["train_date"] = '2018-09-20'
        data["tour_flag"] = "dc"
        data["purpose_codes"] = "ADULT"
        data["query_from_station_name"] ='深圳'
        data["query_to_station_name"] = '赤壁'
        data["undefined"] = ''
        url='https://kyfw.12306.cn/otn/leftTicket/submitOrderRequest'
        res=self.post(url,data=data)
        print(res.text)
    #开始下单
    def shopdin(data1):
        #获取1个参数
        liop=initDc()
         #改变Headers
        self.headers['Referer'] = 'https://kyfw.12306.cn/otn/confirmPassenger/initDc'
        self.headers['Origin']='https://kyfw.12306.cn'
        print(self.headers)
        #请求并获取联系人参数
        pasdir=PassengerDTOs(liop[0])
        print(type(pasdir))
        # 二等座 0  (车票类型:ticket_type_codes 成人票1)      ,1,张三(passenger_name),   1(证件类型:passenger_id_type_code),320xxxxxx(passenger_id_no),151xxxx(mobile_no),N
        passengerTicketStr=data1['seatType']+ ',0,'+pasdir['passenger_type']+','+pasdir['passenger_name']+','+pasdir['passenger_id_type_code']+','+pasdir['passenger_id_no']+','+pasdir['mobile_no']+',N'
        #张三(passenger_name),1(证件类型:passenger_id_type_code),320xxxxxx(passenger_id_no),1(passenger_type)_
        oldPassengerStr=pasdir['passenger_name']+','+pasdir['passenger_id_type_code']+','+pasdir['passenger_id_no']+','+pasdir['passenger_type']+'_'
        data = OrderedDict()
        data["_json_att"] =''
        data["ed_level_order_num"] ='000000000000000000000000000000'
        data["cancel_flag"] ='2'
        data["oldPassengerStr"] = oldPassengerStr
        data["passengerTicketStr"] = passengerTicketStr
        data["randCode"] =''
        data["tour_flag"] ='dc'
        data["whatsSelect"] ='1'
        '''
        data={
            'cancel_flag':'2',#固定
            'ed_level_order_num':'000000000000000000000000000000',#固定
            'passengerTicketStr':passengerTicketStr,#联系人
            'oldPassengerStr':oldPassengerStr,#联系人
            'tour_flag':'dc',#单程
            'randCode':'',#空
            'whatsSelect':'1',#是否选择了联系人,
        }
        '''
        OrderInfo(data)
        data1['REPEAT_SUBMIT_TOKEN']=liop[0]
        #提交订单
        getQueueCount(data1)
        data2= OrderedDict()
        data2["_json_att"] =''#空
        data2["choose_seats"] =''#空
        data2["dwAll"] ='N'#固定
        data2["key_check_isChange"] =liop[1]#页面找
        data2["leftTicketStr"] = data1['leftTicket']#列车
        data2["oldPassengerStr"] =oldPassengerStr#联系人
        data2["passengerTicketStr"] =passengerTicketStr#联系人
        data2["purpose_codes"] ='00'#
        data2["randCode"] =''#随机数 空
        data2["REPEAT_SUBMIT_TOKEN"] =liop[0]
        data2["roomType"] ='00'#固定
        data2["seatDetailType"] ='000'#选铺 暂不支持 默认参数
        data2["train_location"] = data1['train_location']#q6
        data2["whatsSelect"] ='1'#固定
        tijiao(data2)
    def tijiao(data):
        url='https://kyfw.12306.cn/otn/confirmPassenger/confirmSingleForQueue'
        res=self.post(url,data=data)
        print(res.status_code)
        print(res.text)
    #获取联系人
    def PassengerDTOs(REPEAT_SUBMIT_TOKEN):
        data={
            '_json_att':'',#空
            'REPEAT_SUBMIT_TOKEN':REPEAT_SUBMIT_TOKEN#页面找
        }
        url='https://kyfw.12306.cn/otn/confirmPassenger/getPassengerDTOs'
        res=self.post(url,data=data)
        #print(res.text)
        passen=res.json().get('data').get('normal_passengers')[1]
        print(passen)
        return passen
    
    #订单页面----获取参数
    def initDc():
        url='https://kyfw.12306.cn/otn/confirmPassenger/initDc'
        res=self.post(url,data={'_json_att':''})
        REPEAT_SUBMIT_TOKEN=re.search('globalRepeatSubmitToken = .(.*?).;',res.text,re.S).group(1)
        ticketInfoForPassengerForm_name = re.compile(r'var ticketInfoForPassengerForm=(\{.+\})?')
        order_request_params_name = re.compile(r'var orderRequestDTO=(\{.+\})?')
        re_tfpf = re.findall(ticketInfoForPassengerForm_name, res.text)
        re_orp = re.findall(order_request_params_name, res.text)
        key_check_isChange=re.search('key_check_isChange.:.(.*?).,',res.text,re.S).group(1)
        return [REPEAT_SUBMIT_TOKEN,key_check_isChange]
     #选乘客票种提交
    def OrderInfo(data):
        url='https://kyfw.12306.cn/otn/confirmPassenger/checkOrderInfo'
        res=self.post(url,data=data)
        print(res.status_code)
        print(res.text)
    #提交订单列车余票。
    def getQueueCount(data):
        url='https://kyfw.12306.cn/otn/confirmPassenger/getQueueCount'
        res=self.post(url,data=data)
        print(res.status_code)
        print(res.text)
    def vel_longin_2():
        url='https://kyfw.12306.cn/otn/login/checkUser'
        requests.packages.urllib3.disable_warnings()
        res=self.post(url,data={'_json_att':''})
        login_vel=res.json().get('data')['flag']
    
        return login_vel
    if __name__ == '__main__':
        #yanzhengma()
        shoppiao()
        vel_longin_2()

转载于:https://www.cnblogs.com/ruogu/p/9716620.html