现在的位置: 首页 > 综合 > 正文

python 火车票订票系统（12306）

2013年10月03日 ⁄ 综合 ⁄ 共 49165字 ⁄ 字号 小 中 大 ⁄ 评论关闭

研究方法，python+虚拟机＋https监视工具

#这只是一个半成品，只是实现了，一个完整的订票过程，对于，如果刷票，自己研究
#简单过程
#   第一、getRandAndCookie() 获得cook 和一个随机数用于登录
#   第二、getEnterRandCode() 得到登录时的识别码          
#   第三、setuseandpassword(randcode,use,password) 发送随机数、识别码和用户及密码。由于随机数只在内部使用，所以定义成了全局变量，
#   第四、GetTrainList() 得到所有车站列表，'@bjb|北京北|VAP|beijingbei|bjb|0' 其中有中文、拼音、拼音缩写、所一个ID(唯一)，其主要是可以，通过上面的列表，找到它的唯一ID,TranCityToId('南昌')
#   第五、GetTrainNumList(date,fromstationid,tostationid,starttime) 得到哪到哪的所在车次，消息格式如下，其中所以，一下车次的的ID:"id":"650000K1060I"
#        {"end_station_name":"北京西","end_time":"16:18","id":"650000K1060I","start_station_name":"深圳","start_time":"10:54","value":"K106"}
#        通过ChangeToTrainNumId('K106')得到车次ID
#   第六、QueryTrain(fromstationid,tostationid,date,stationNum,starttime) 就是点击查询按键，得到是否有能预订，格式如下
#        <span id='id_5700000Z6809'
#              class='base_txtdiv'
#              onmouseover=javascript:onStopHover('5700000Z6809#NCG#BXP')
#              onmouseout='onStopOut()'>Z68</span>,<img src='/otsweb/images/tips/first.gif'>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;南昌&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<br>&nbsp;&nbsp;&nbsp;&nbsp;20:12,<img src='/otsweb/images/tips/last.gif'>&nbsp;&nbsp;&nbsp;&nbsp;北京西&nbsp;&nbsp;&nbsp;&nbsp;<br>&nbsp;&nbsp;&nbsp;&nbsp;07:38,11:26,--,--,--,--,10,<font
color='#008800'>有</font>,<font color='#008800'>有</font>,--,<font color='#008800'>有</font>,<font color='#008800'>有</font>,--,<a name='btn130_2' class='btn130_2' style='text-decoration:none;'
#              onclick=javascript:getSelected('Z68#11:26#20:12#5700000Z6809#NCG#BXP#07:38#南昌#北京西#01#04#1*****31804*****00481*****03306*****00103*****0162#4AFCA0360B0B029AB6E00E3DF2231EE95B4CA798E4D91F296D9BF4CF#G1')>预&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;订</a>
#       通过choiceSubmitNum(stationNum,trainsubmitinfo)提取出getSelected()消息
#   第七、submitRequest(choiceSubmitNum(stationNum,trainsubmitinfo),date,starttime) 就是点击预订按钮
#   第八、getrandCheckCode()得到提交订单的识别码  
#   第十、CheckInMyTicket(info,randcode,peoples)点击提交，如果成功的话，就会返回{"errMsg":"Y"}

# 出于，网络是UTF8格式，所以，必须# -*- coding: utf-8 -*-，（当然，自己转换也是可以的）
# 出于这一个控制台信息，所以，识别码的图片在脚本同一目录

把代码贴上。

# -*- coding: utf-8 -*-


import pycurl

import StringIO

import ConfigParser

#这只是一个半成品，只是实现了，一个完整的订票过程，对于，如果刷票，自己研究

#简单过程

#   第一、getRandAndCookie() 获得cook 和一个随机数用于登录

#   第二、getEnterRandCode() 得到登录时的识别码

#   第三、setuseandpassword(randcode,use,password) 发送随机数、识别码和用户及密码。由于随机数只在内部使用，所以定义成了全局变量，

#   第四、GetTrainList() 得到所有车站列表，'@bjb|北京北|VAP|beijingbei|bjb|0' 其中有中文、拼音、拼音缩写、所一个ID(唯一)，其主要是可以，通过上面的列表，找到它的唯一ID,TranCityToId('南昌')

#   第五、GetTrainNumList(date,fromstationid,tostationid,starttime) 得到哪到哪的所在车次，消息格式如下，其中所以，一下车次的的ID:"id":"650000K1060I"

#        {"end_station_name":"北京西","end_time":"16:18","id":"650000K1060I","start_station_name":"深圳","start_time":"10:54","value":"K106"}

#        通过ChangeToTrainNumId('K106')得到车次ID

#   第六、QueryTrain(fromstationid,tostationid,date,stationNum,starttime) 就是点击查询按键，得到是否有能预订，格式如下

#        <span id='id_5700000Z6809'

#              class='base_txtdiv'

#              onmouseover=javascript:onStopHover('5700000Z6809#NCG#BXP')

#              onmouseout='onStopOut()'>Z68</span>,<img src='/otsweb/images/tips/first.gif'>      南昌     <br>    20:12,<img src='/otsweb/images/tips/last.gif'>    北京西    <br>    07:38,11:26,--,--,--,--,10,<font color='#008800'>有</font>,<font color='#008800'>有</font>,--,<font color='#008800'>有</font>,<font color='#008800'>有</font>,--,<a name='btn130_2' class='btn130_2' style='text-decoration:none;'

#              onclick=javascript:getSelected('Z68#11:26#20:12#5700000Z6809#NCG#BXP#07:38#南昌#北京西#01#04#1*****31804*****00481*****03306*****00103*****0162#4AFCA0360B0B029AB6E00E3DF2231EE95B4CA798E4D91F296D9BF4CF#G1')>预        订</a>

#       通过choiceSubmitNum(stationNum,trainsubmitinfo)提取出getSelected()消息

#   第七、submitRequest(choiceSubmitNum(stationNum,trainsubmitinfo),date,starttime) 就是点击预订按钮

#   第八、getrandCheckCode()得到提交订单的识别码

#   第十、CheckInMyTicket(info,randcode,peoples)点击提交，如果成功的话，就会返回{"errMsg":"Y"}


# 出于，网络是UTF8格式，所以，必须# -*- coding: utf-8 -*-，（当然，自己转换也是可以的）

# 出于这一个控制台信息，所以，识别码的图片在脚本同一目录

#得到头信息

# -*- coding: utf-8 -*-


import pycurl

import StringIO

import ConfigParser

import Image

import os

import re

import time

import json

import sys

import math

import binascii


#这只是一个半成品，只是实现了，一个完整的订票过程，对于，如果刷票，自己研究

#简单过程

#   第一、getRandAndCookie() 获得cook 和一个随机数用于登录 

#   第二、getEnterRandCode() 得到登录时的识别码          

#   第三、setuseandpassword(randcode,use,password) 发送随机数、识别码和用户及密码。由于随机数只在内部使用，所以定义成了全局变量，

#   第四、GetTrainList() 得到所有车站列表，'@bjb|北京北|VAP|beijingbei|bjb|0' 其中有中文、拼音、拼音缩写、所一个ID(唯一)，其主要是可以，通过上面的列表，找到它的唯一ID,TranCityToId('南昌')

#   第五、GetTrainNumList(date,fromstationid,tostationid,starttime) 得到哪到哪的所在车次，消息格式如下，其中所以，一下车次的的ID:"id":"650000K1060I"

#        {"end_station_name":"北京西","end_time":"16:18","id":"650000K1060I","start_station_name":"深圳","start_time":"10:54","value":"K106"}

#        通过ChangeToTrainNumId('K106')得到车次ID

#   第六、QueryTrain(fromstationid,tostationid,date,stationNum,starttime) 就是点击查询按键，得到是否有能预订，格式如下

#        <span id='id_5700000Z6809'

#              class='base_txtdiv'

#              onmouseover=javascript:onStopHover('5700000Z6809#NCG#BXP')

#              onmouseout='onStopOut()'>Z68</span>,<img src='/otsweb/images/tips/first.gif'>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;南昌&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<br>&nbsp;&nbsp;&nbsp;&nbsp;20:12,<img src='/otsweb/images/tips/last.gif'>&nbsp;&nbsp;&nbsp;&nbsp;北京西&nbsp;&nbsp;&nbsp;&nbsp;<br>&nbsp;&nbsp;&nbsp;&nbsp;07:38,11:26,--,--,--,--,10,<font color='#008800'>有</font>,<font color='#008800'>有</font>,--,<font color='#008800'>有</font>,<font color='#008800'>有</font>,--,<a name='btn130_2' class='btn130_2' style='text-decoration:none;'

#              onclick=javascript:getSelected('Z68#11:26#20:12#5700000Z6809#NCG#BXP#07:38#南昌#北京西#01#04#1*****31804*****00481*****03306*****00103*****0162#4AFCA0360B0B029AB6E00E3DF2231EE95B4CA798E4D91F296D9BF4CF#G1')>预&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;订</a>

#       通过choiceSubmitNum(stationNum,trainsubmitinfo)提取出getSelected()消息

#   第七、submitRequest(choiceSubmitNum(stationNum,trainsubmitinfo),date,starttime) 就是点击预订按钮

#   第八、getrandCheckCode()得到提交订单的识别码  

#   第十、CheckInMyTicket(info,randcode,peoples)点击提交，如果成功的话，就会返回{"errMsg":"Y"}


# 出于，网络是UTF8格式，所以，必须# -*- coding: utf-8 -*-，（当然，自己转换也是可以的）

# 出于这一个控制台信息，所以，识别码的图片在脚本同一目录

#得到头信息

def headerCookie(buf):

    global Cookie

   # print buf

    findindex  = buf.find("Set-Cookie:")

    if findindex >= 0:

        beginindex = buf.find(':')

        endindex = buf.find(';')

        if endindex >0:

            Cookie+=buf[beginindex+1:endindex+1]

#用于测试

def gethead(buf):

    #

    None

    #print buf

def setcer(curl):

    curl.setopt(pycurl.CAINFO, r"srca.cer") #根证书

    None

##得到随机数和cookie连接参数

def getRandAndCookie():

    global loginRand

    global Cookie

    Cookie = ''

    loginRand = ''

    curl = pycurl.Curl()

    b = StringIO.StringIO()

    curl.setopt(pycurl.URL, "https://www.12306.cn/otsweb/loginAction.do?method=loginAysnSuggest")

    curl.setopt(pycurl.WRITEFUNCTION, b.write)  

    curl.setopt(pycurl.SSL_VERIFYPEER, 0)

    curl.setopt(pycurl.SSL_VERIFYHOST, 0)

    curl.setopt(pycurl.HEADERFUNCTION, headerCookie)

    #curl.setopt(pycurl.COOKIE,Cookie)

    curl.perform()

    if curl.getinfo(pycurl.RESPONSE_CODE) == 200:

        back = b.getvalue()

        login = back.find('loginRand')

        if login >=0:

            begin =login + back[login:].find(':')

            begin += back[begin:].find('"')

            end =  back[begin+1:].find('"')

            loginRand = back[begin+1:end+begin+1]

    curl.close()

    return loginRand

def getEnterRandCode():

    #得到登录验证码图

    curl = pycurl.Curl()

    f = StringIO.StringIO()

    curl.setopt(pycurl.URL, "https://dynamic.12306.cn/otsweb/passCodeNewAction.do?module=login&rand=sjrand")

    #更改了 以前是https://www.12306.cn/otsweb/passCodeAction.do?rand=sjrand")

    curl.setopt(pycurl.WRITEFUNCTION, f.write)  

    curl.setopt(pycurl.SSL_VERIFYPEER, 0)

    curl.setopt(pycurl.SSL_VERIFYHOST, 0)

    curl.setopt(pycurl.HEADERFUNCTION, headerCookie)

    curl.setopt(pycurl.COOKIE,Cookie)

    curl.perform()

    backinfo = ''

    if curl.getinfo(pycurl.RESPONSE_CODE) == 200:

        backinfo = f.getvalue()

    curl.close()

    return backinfo

def GetKeyhttp():

    curl = pycurl.Curl()

    f = StringIO.StringIO()

    curl.setopt(pycurl.URL, "https://dynamic.12306.cn/otsweb/loginAction.do?method=init")

    curl.setopt(pycurl.WRITEFUNCTION, f.write)  

    curl.setopt(pycurl.SSL_VERIFYPEER, 0)

    curl.setopt(pycurl.SSL_VERIFYHOST, 0)

    curl.setopt(pycurl.HEADERFUNCTION, gethead)

    curl.setopt(pycurl.COOKIE,Cookie)

    curl.setopt(pycurl.ENCODING, 'gzip, deflate')

    curl.setopt(pycurl.HTTPHEADER,["Accept-Language:zh-CN",

                                   "Referer:https://dynamic.12306.cn/otsweb/",

                                   "Accept:*/*",

                                   "Accept-Encoding:gzip, deflate",

                                   "Connection:Keep-Alive"])

    curl.perform()

    backinfo = ''

    if curl.getinfo(pycurl.RESPONSE_CODE) == 200:

        backinfo = f.getvalue()

    curl.close()

    begin = backinfo.find('/otsweb/dynamicJsAction.do?jsversion=')

    end = backinfo[begin+1:].find('"') + begin+1

    return "https://dynamic.12306.cn"+backinfo[begin:end]

    #/otsweb/dynamicJsAction.do?jsversion=4296&method=loginJs

    

    return backinfo

    

def GetNewKey():

    http = GetKeyhttp()

    print http

    curl = pycurl.Curl()

    f = StringIO.StringIO()

    curl.setopt(pycurl.URL, http)

    curl.setopt(pycurl.WRITEFUNCTION, f.write)  

    curl.setopt(pycurl.SSL_VERIFYPEER, 0)

    curl.setopt(pycurl.SSL_VERIFYHOST, 0)

    curl.setopt(pycurl.HEADERFUNCTION, gethead)

    curl.setopt(pycurl.COOKIE,Cookie)

    curl.setopt(pycurl.ENCODING, 'gzip, deflate')

    curl.setopt(pycurl.HTTPHEADER,["Accept-Language:zh-CN",

                                   "Referer:https://dynamic.12306.cn/otsweb/loginAction.do?method=init",

                                   "Accept:*/*",

                                   "Accept-Encoding:gzip, deflate",

                                   "Connection:Keep-Alive"])

    curl.perform()

    backinfo = ''

    if curl.getinfo(pycurl.RESPONSE_CODE) == 200:

        backinfo = f.getvalue()

    curl.close()


    fkey = backinfo.find('function gc()')

    if fkey > 0:

        beginkey = backinfo[fkey:].find("'") + fkey

        end = backinfo[beginkey+1:].find("'") + beginkey+1

        return backinfo[beginkey+1:end].replace('=','%3D')+'='+(Get12306NewKey(backinfo[beginkey+1:end]).replace('=','%3D'))

def stringToLongArray(string, includeLength):

    length = len(string)

    result = []

    i = 0;

    while (i < length):

        re = 0

        try:

            re = ord(string[i:i+1])

            re = re | (ord(string[i+1:i+2] )<< 8)

            re = re | (ord(string[i+2:i+3] )<< 16)

            re = re | (ord(string[i+3:i+4] )<< 24)

        except:

            pass

        result.append(re)

        i += 4

    if (includeLength):

        result.append(length)

    return result

def longArrayToString(data,includeLength):

    length = len(data)

    n = (length - 1) << 2

    if (includeLength):

        m = data[length - 1]

        if((m < n - 3) or (m > n)):

            return None

        n = m

    bdata = ""

    for i in range(0,length):#(var i = 0;i < length;i ++ ):

        bdata  = bdata + chr(data[i] & 0xff) + chr(data[i] >> 8 & 0xff) + chr(data[i] >> 16 & 0xff) + chr(data[i] >> 24 & 0xff)

    if (includeLength):

        return bdata[0:n]

    else:

        return bdata

def Base32encrypt(string, key):

    if (string == ""):

        return "";

    delta = 0x9E3779B8

    v = stringToLongArray(string, True)

    k = stringToLongArray(key, False)

    k_length = len(k)

    if (k_length < 4):

        k.append(0)

        k.append(0)

        k.append(0)

        k_length = 4

    v_length = len(v)

    n = v_length - 1;

    z = v[n]

    y = v[0];

    q = math.floor(6 + 52 / (n + 1))

    sum = 0

    while (0 < q ):

        q = q -1

        sum = sum + delta & 0xffffffff;

        e = sum >> 2 & 3;

        for p in range(0,n):#(p = 0; p < n; p ++ ):

            y = v[p + 1];

            mx = (z >> 5 ^ y << 2) + (y >> 3 ^ z << 4) ^ (sum ^ y) + (k[p & 3 ^ e] ^ z);

            z = v[p] = v[p] + mx & 0xffffffff;

        p = n

        y = v[0];

        mx = (z >> 5 ^ y << 2) + (y >> 3 ^ z << 4) ^ (sum ^ y) + (k[p & 3 ^ e] ^ z);

        z = v[n] = v[n] + mx & 0xffffffff;

    return longArrayToString(v, False);

def encode32(inputbuf):

    keyStr = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/=";

    #inputbuf = escape(inputbuf);

    output = "";

    i = 0;

    sing = 0

    while (i < len(inputbuf)):

        chr1 = ord(inputbuf[i:i+1])

        i = i + 1

        try:

            chr2 = ord(inputbuf[i:i+1])

            i = i + 1

        except:

            chr2 = 0

            sing = sing or 0x1

        try:

            chr3 = ord(inputbuf[i:i+1])

            i = i + 1

        except:

            chr3 = 0

            sing = sing or 0x2

        enc1 = chr1 >> 2;

        enc2 = ((chr1 & 3) << 4) | (chr2 >> 4);

        enc3 = ((chr2 & 15) << 2) | (chr3 >> 6);

        enc4 = chr3 & 63;

        if (sing and 0x1):

            enc3 = enc4 = 64

        elif (sing and 0x2):

            enc4 = 64

        output = output + keyStr[enc1:enc1+1] + keyStr[enc2:enc2+1] + keyStr[enc3:enc3+1] + keyStr[enc4:enc4+1]


    return output

def Get12306NewKey(string):

    key = '1111'

    string = string

    b = Base32encrypt(key,string)

    b = binascii.b2a_hex(b)

    return  encode32(b)#encode32(b)

#发送用户和密码,即登录

def setuseandpassword(randcode,usename,password,newkey):#nrandcode验证码  usename 用户名 password 密码

    data =[]

    Crlf = '&'

    data.append('loginRand=%s'%(loginRand))

    data.append('refundLogin=N')

    data.append('refundFlag=Y')

    data.append('isClick=&form_tk=null')

    data.append('loginUser.user_name=%s'%(usename))

    data.append('nameErrorFocus=')

    data.append('user.password=%s'%(password))

    data.append('passwordErrorFocus=')

    data.append('randCode=%s'%(randcode))

    data.append('randErrorFocus=')

    

    data.append(newkey) #这个不知道为什么，不要还能登入

    data.append('myversion=undefined')

    

    senddata = Crlf.join(data)

    print senddata

    curl = pycurl.Curl()

    b = StringIO.StringIO()#https://dynamic.12306.cn/otsweb/loginAction.do?method=login

    curl.setopt(pycurl.URL, "https://dynamic.12306.cn/otsweb/loginAction.do?method=login")

    curl.setopt(pycurl.WRITEFUNCTION, b.write)

    curl.setopt(pycurl.SSL_VERIFYPEER, False)

    curl.setopt(pycurl.SSL_VERIFYHOST, False)

    curl.setopt(pycurl.HEADERFUNCTION, gethead)

    curl.setopt(pycurl.ENCODING, 'gzip, deflate')

    curl.setopt(pycurl.HTTPHEADER,["Accept-Language:zh-CN",

                                   "Accept-Encoding:gzip, deflate"])

    #curl.setopt(pycurl.CAINFO, r"/home/china/桌面/myPython/srca.cer") #根证书

    #curl.setopt(pycurl.SSLCERT,"/home/china/桌面/myPython/srca.cer") #客户端证书

    #curl.setopt(pycurl.SSLKEY, "/home/china/桌面/myPython/srca.cer") #客户端密钥

    curl.setopt(pycurl.COOKIE,Cookie)

    #curl.setopt(pycurl.HTTPPOST,data)

    curl.setopt(pycurl.POSTFIELDS,str(senddata))

    curl.perform()

    backinfo = None

    if curl.getinfo(pycurl.RESPONSE_CODE) == 200:

        backinfo = b.getvalue()

    curl.close()

    return backinfo

#用于分析，登录时返回，用户名的信息

def transitionGetUseInfo(info):

    if info == None:

        return 'error_ininfo'

    if info.find('请输入正确的验证码！') > 0:

        return 'error_rand_code'

    index = info.find("var hello = '")

    if index > 0:

        end = index+14+info[index+14:].find("'")

        return info[index+13:end]

    return 'error_unknow'

#得到火车列表，其中含有名字和ID等相关信息。名字有中、拼、缩写等

def GetTrainList():

    global train 

    url = 'https://dynamic.12306.cn/otsweb/js/common/station_name.js?version=5.68'

    curl = pycurl.Curl()

    b = StringIO.StringIO()

    curl.setopt(pycurl.URL, url)

    curl.setopt(pycurl.WRITEFUNCTION, b.write)  

    curl.setopt(pycurl.SSL_VERIFYPEER, 0)

    curl.setopt(pycurl.SSL_VERIFYHOST, 0)

    #curl.setopt(pycurl.HEADERFUNCTION, gethead)

    try:

        curl.setopt(pycurl.COOKIE,Cookie)

    except:

        None

    curl.perform()

    if curl.getinfo(pycurl.RESPONSE_CODE) == 200:

        train = b.getvalue()

        curl.close()

        return train

    curl.close()

    return None

#将火车站名转化为ID，拼音、拼音缩写、中文都可以，调用条会是，GetTrainList返回成功

def TranCityToId(stationName):

    Id = ""

    index =train.find('|'+stationName+'|')

    if index < 0:

        return None

    index = index +1

    begin = index-100

    if index < 100:

        begin = 0

    begin = index - train[index:begin:-1].find('@')

    if begin ==  -1:

        return None

    begin = begin+train[begin:].find('|')

    if begin ==  -1:

        return None

    begin = begin+train[begin+1:].find('|')+1

    if begin ==  -1:

        return None

    end = begin+train[begin+1:].find('|')+1

    if end ==  -1:

        return None

    return train[begin+1:end]

#查询列车，批定车次、时间、等 例如：北京到南昌 2013－01－02 L110，车站id是用TranCityToId转化而来的（

def QueryTrain(fromstationid,tostationid,stationtime,stationNum,starttime):#返回的结果，之所以不使用全局变量是因为，这个可以存在多个的。

    #stationNum 如果为None那就是所有的车次,stationtime格式：2013-01-02 starttime：00:00--24:00

    if fromstationid == None or tostationid == None or stationtime == None:

        return

    crlf = '&'

    httpurl = []

    httpurl.append('https://dynamic.12306.cn/otsweb/order/querySingleAction.do?method=queryLeftTicket')

    httpurl.append('orderRequest.train_date=%s'%(stationtime))#开车日期 2012-12-21

    httpurl.append('orderRequest.from_station_telecode=%s'%(fromstationid))#出发站id

    httpurl.append('orderRequest.to_station_telecode=%s'%(tostationid))#到站ID

    httpurl.append('orderRequest.train_no=%s'%(stationNum))#列车

    httpurl.append('trainPassType=%s'%('QB'))#路过类型，全部

    httpurl.append(r'trainClass=QB%23D%23Z%23T%23K%23QT%23')#%23 == #QB 全部 D:动车 Z：直达等

    httpurl.append('includeStudent=00')#是否是学生，默认为否

    httpurl.append('seatTypeAndNum=')#未知

    httpurl.append('orderRequest.start_time_str=%s'%(starttime.replace(':','%3A')))

    url = crlf.join(httpurl)

    curl = pycurl.Curl()

    b = StringIO.StringIO()

    curl.setopt(pycurl.URL, url)

    curl.setopt(pycurl.HTTPHEADER,["x-requested-with:XMLHttpRequest",

                                   "Accept:text/plain, */*",

                                   "Referer:https://dynamic.12306.cn/otsweb/order/querySingleAction.do?method=init"])

    curl.setopt(pycurl.WRITEFUNCTION, b.write)  

    curl.setopt(pycurl.SSL_VERIFYPEER, 0)

    curl.setopt(pycurl.SSL_VERIFYHOST, 0)

    curl.setopt(pycurl.HEADERFUNCTION, gethead)

    curl.setopt(pycurl.COOKIE,Cookie)

    curl.perform()

    backinfo = None

    if curl.getinfo(pycurl.RESPONSE_CODE) == 200:

        backinfo = b.getvalue()

    curl.close()

    return backinfo

#查询哪到哪的所有车的时间和ID。ID以后要用

def GetTrainNumList(date,fromstationid,tostationid,starttime):#date格式：2013-01-02,starttime 格式:00:00--24:00

    global TrainNumList

    url = 'https://dynamic.12306.cn/otsweb/order/querySingleAction.do?method=queryststrainall'

    crlf = '&'

    gdata = []

    gdata.append('date=%s'%(date))

    gdata.append('fromstation=%s'%(fromstationid))

    gdata.append('tostation=%s'%(tostationid))

    gdata.append('starttime=%s%%3A%s--%s%%3A%s'%(starttime[0:2],starttime[3:5],starttime[7:9],starttime[10:12]))

    data = crlf.join(gdata)

    

    curl = pycurl.Curl()

    b = StringIO.StringIO()

    curl.setopt(pycurl.URL, url)

    curl.setopt(pycurl.WRITEFUNCTION, b.write)  

    curl.setopt(pycurl.SSL_VERIFYPEER, 0)

    curl.setopt(pycurl.SSL_VERIFYHOST, 0)

    curl.setopt(pycurl.COOKIE,Cookie)

    curl.setopt(pycurl.POSTFIELDS,data)

    curl.perform()

    TrainNumList = None

    if curl.getinfo(pycurl.RESPONSE_CODE) == 200:

        TrainNumList = b.getvalue()

    curl.close()

    return TrainNumList

#通过列车号，转化为唯一ID,必须在GetTrainNumList）成功调用之后

def ChangeToTrainNumId(train_no):

    index = TrainNumList.find(train_no)

    if index <= -1:

        return None

    begin = index - TrainNumList[index::-1].find('{')

    begin = begin + TrainNumList[begin:].find(r'"id":')

    begin = begin + TrainNumList[begin+6:].find(r'"')-6

    end = begin + TrainNumList[begin+1:].find(r'"')

    return TrainNumList[begin:end+1]

#用于选择，查询后的可预定的车次字符串

def choiceSubmitNum(TrainId,info):

    begin = 0

    while True:

        temp = info[begin:].find('onclick=javascript:getSelected(')

        if temp == -1:

            break

        begin += temp

        begin += info[begin:].find("'")

        end =begin+1+ info[begin+1:].find("'")

        if info[begin+1:end].find(TrainId) >= 0:

            backinfo = info[begin+1:end]

            return backinfo

    return None

def strtohex(nstr):

    tstr = ''

    for i in nstr:

        tstr+=str(hex(ord(i)))

    tstr = tstr.replace('0x','%')

    return tstr.upper()

#得到提交定单的令牌,相当于点击预定

def submitRequest(selectStr,train_date ,start_time_str):#返回的结果，之所以不使用全局变量是因为，这个可以存在多个的。

    #selectStr 此是点击查询后得到的字符串列表，以#分开的

    #train_date 开车日期，例如：2012-12-21

    #start_time_str 00:00--24:00'

    if selectStr == None:

        return None

    selectStr_arr = selectStr.split("#")

    station_train_code=selectStr_arr[0]#车次

    lishi=selectStr_arr[1]#历时

    starttime=selectStr_arr[2]#开车时间 

    trainno=selectStr_arr[3]#车次编号,唯一

    from_station_telecode=selectStr_arr[4]#出发站编号，字符

    to_station_telecode=selectStr_arr[5]#到站编号，字符

    arrive_time=selectStr_arr[6]#到达时间

    from_station_name=selectStr_arr[7]#出发站名字

    to_station_name=selectStr_arr[8]#到站名字

    from_station_no=selectStr_arr[9]#出发站编号，数字

    to_station_no=selectStr_arr[10]#到站编号，数字

    ypInfoDetail=selectStr_arr[11]#暂时不知道

    mmStr = selectStr_arr[12]#暂时不知道

    locationCode = selectStr_arr[13]

    lishi = lishi.replace(':','%3A')

    starttime = starttime.replace(':','%3A')

    arrive_time = arrive_time.replace(':','%3A')

    data =[]

    Crlf = '&'

    data.append('station_train_code=%s'%(station_train_code))

    data.append('train_date=%s'%(train_date))#车的日期，年月日 '2013-02-25'

    data.append('seattype_num=')#未知

    data.append('from_station_telecode=%s'%(from_station_telecode))

    data.append('to_station_telecode=%s'%(to_station_telecode))

    data.append('include_student=00')#学生与否

    data.append('from_station_telecode_name=%s'%(strtohex(from_station_name)))#

    data.append('to_station_telecode_name=%s'%(strtohex(to_station_name)))

    data.append('round_train_date=%s'%(train_date))#往返日期

    data.append('round_start_time_str=%s'%(start_time_str.replace(':','%3A')))#出发时间范围

    data.append('single_round_type=%s'%('1'))#是否往返

    data.append('train_pass_type=%s'%('QB'))#列车路过的类型

    data.append('train_class_arr=%s'%('QB%23D%23Z%23T%23K%23QT%23'))#获取列车类别，为多选框，#号分隔

    data.append('start_time_str=%s'%(start_time_str.replace(':','%3A')))

    data.append('lishi=%s'%(lishi))#历时时间

    data.append('train_start_time=%s'%(starttime))

    data.append('trainno4=%s'%(trainno))#列车ID，唯一性的。5700000Z6809

    data.append('arrive_time=%s'%(arrive_time))#到站时间

    data.append('from_station_name=%s'%(strtohex(from_station_name)))

    data.append('to_station_name=%s'%(strtohex(to_station_name)))

    data.append('from_station_no=%s'%(from_station_no))

    data.append('to_station_no=%s'%(to_station_no))

    data.append('ypInfoDetail=%s'%(ypInfoDetail))

    data.append('mmStr=%s'%(mmStr))

    data.append('locationCode=%s'%(locationCode))

    senddata = Crlf.join(data)


    curl = pycurl.Curl()

    curl.setopt(pycurl.URL, "https://dynamic.12306.cn/otsweb/order/querySingleAction.do?method=submutOrderRequest")

    curl.setopt(pycurl.SSL_VERIFYPEER, False)

    curl.setopt(pycurl.SSL_VERIFYHOST, False)

    curl.setopt(pycurl.HTTPHEADER,["Referer: https://dynamic.12306.cn/otsweb/order/querySingleAction.do?method=init",

                                   "Content-Type: application/x-www-form-urlencoded"])

    curl.setopt(pycurl.COOKIE,Cookie)

    curl.setopt(pycurl.HEADERFUNCTION, gethead)

    b = StringIO.StringIO()

    curl.setopt(pycurl.WRITEFUNCTION, b.write)

    curl.setopt(pycurl.POSTFIELDS,senddata)

    curl.perform()

    curl.getinfo(pycurl.RESPONSE_CODE)

    code = curl.getinfo(pycurl.RESPONSE_CODE)

    curl.close()

    #print b.getvalue()

    if code == 302:

        initcurl = pycurl.Curl()

        b = StringIO.StringIO()

        initcurl.setopt(pycurl.URL, "https://dynamic.12306.cn/otsweb/order/confirmPassengerAction.do?method=init")

        initcurl.setopt(pycurl.WRITEFUNCTION, b.write)

        initcurl.setopt(pycurl.SSL_VERIFYPEER, False)

        initcurl.setopt(pycurl.SSL_VERIFYHOST, False)

        initcurl.setopt(pycurl.HTTPHEADER,["Referer:https://dynamic.12306.cn/otsweb/order/querySingleAction.do?method=init"])

        initcurl.setopt(pycurl.COOKIE,Cookie)

        initcurl.setopt(pycurl.HEADERFUNCTION, gethead)

        initcurl.perform()

        #print '2',b.getvalue()

        initcurl.close()

        return b.getvalue()

    return None

#得到提交订单，识别码

def getrandCheckCode():

    curl = pycurl.Curl()

    f = StringIO.StringIO()

    curl.setopt(pycurl.URL, "https://dynamic.12306.cn/otsweb/passCodeNewAction.do?module=passenger&rand=randp")

    #https://www.12306.cn/otsweb/passCodeAction.do?rand=randp")

    curl.setopt(pycurl.HTTPHEADER,["Referer:https://dynamic.12306.cn/otsweb/order/confirmPassengerAction.do?method=init"])

    curl.setopt(pycurl.WRITEFUNCTION, f.write)  

    curl.setopt(pycurl.SSL_VERIFYPEER, 0)

    curl.setopt(pycurl.SSL_VERIFYHOST, 0)

    curl.setopt(pycurl.COOKIE,Cookie)

    curl.setopt(pycurl.HEADERFUNCTION, gethead)

    curl.perform()

    backinfo = None

    if curl.getinfo(pycurl.RESPONSE_CODE) == 200:

        backinfo = f.getvalue()

    curl.close()

    return backinfo

#从html得到其值，<name='hyy' value='china'>

def getvalue(info,name):

    begin = info.find(name)

    if begin == -1:

        return ''

    if cmp(info[begin-6:begin],'name="') != 0:

        return ''

    begin = begin+info[begin:].find('value="')

    end = begin + 7 + info[begin+7:].find('"')

    return info[begin+7:end]

def CheckInMyTicket(submitRequestInfo,randCode,peoples):

    #submitRequest返回的数据，也可以通过，它来验证，返回数据的正确性 ，如果订单成功就会返回{"errMsg":"Y"}

    data =[]

    Crlf = '&'

    token = getvalue(submitRequestInfo,'org.apache.struts.taglib.html.TOKEN')

    if len(token)<=1:

        return None

    data.append('org.apache.struts.taglib.html.TOKEN=%s'%(token))

    data.append('leftTicketStr=%s'%(getvalue(submitRequestInfo,'leftTicketStr')))

    data.append('textfield=%s'%(strtohex(getvalue(submitRequestInfo,'textfield'))))

    data.append('orderRequest.train_date=%s'%(getvalue(submitRequestInfo,'orderRequest.train_date')))

    data.append('orderRequest.train_no=%s'%(getvalue(submitRequestInfo,'orderRequest.train_no')))

    data.append('orderRequest.station_train_code=%s'%(getvalue(submitRequestInfo,'orderRequest.station_train_code')))

    data.append('orderRequest.from_station_telecode=%s'%(getvalue(submitRequestInfo,'orderRequest.from_station_telecode')))

    data.append('orderRequest.to_station_telecode=%s'%(getvalue(submitRequestInfo,'orderRequest.to_station_telecode')))

    data.append('orderRequest.seat_type_code=%s'%(getvalue(submitRequestInfo,'orderRequest.seat_type_code')))

    data.append('orderRequest.ticket_type_order_num=%s'%(getvalue(submitRequestInfo,'orderRequest.ticket_type_order_num')))

    data.append('orderRequest.bed_level_order_num=%s'%(getvalue(submitRequestInfo,'orderRequest.bed_level_order_num')))#

    data.append('orderRequest.start_time=%s'%(getvalue(submitRequestInfo,'orderRequest.start_time').replace(':','%3A')))#00%3A40&

    data.append('orderRequest.end_time=%s'%(getvalue(submitRequestInfo,'orderRequest.end_time').replace(':','%3A')))#14%3A13&

    data.append('orderRequest.from_station_name=%s'%(strtohex(getvalue(submitRequestInfo,'orderRequest.from_station_name'))))#%E5%8D%97%E6%98%8C&

    data.append('orderRequest.to_station_name=%s'%(strtohex(getvalue(submitRequestInfo,'orderRequest.to_station_name'))))#%E5%8C%97%E4%BA%AC%E8%A5%BF&

    data.append('orderRequest.cancel_flag=%s'%(getvalue(submitRequestInfo,'orderRequest.cancel_flag')))#1&

    data.append('orderRequest.id_mode=%s'%(getvalue(submitRequestInfo,'Y')))#Y&

    #最多五个人

    i = 1

    for persion in peoples.values():

        data.append('passengerTickets=%s,%s,%s,%s,%s,%s,%s,%s'%(persion['seat'],'0',persion['ticket'],strtohex(persion['name']),persion['cardtype'],persion['idcard'],'','Y'))

        data.append('oldPassengers=%s'%(''))#&如果是在常用联系人里就会使用此项

        data.append('passenger_%d_seat=%s'%(i,persion['seat']))#1 硬座 3 硬卧 4 软卧

        data.append('passenger_%d_ticket=%s'%(i,persion['ticket']))#1&成人票，2 儿童票 3 学生票 4 残军票

        data.append('passenger_%d_name=%s'%(i,strtohex(persion['name'])))#

        data.append('passenger_%d_cardtype=%s'%(i,persion['cardtype']))#1 二代身份证 2 一代身份证  c 港澳通行证 G 台湾通行证 B 护照

        data.append('passenger_%d_cardno=%s'%(i,persion['idcard']))#& ID

        data.append('passenger_%d_mobileno=%s'%(i,persion['mobileno']))#电话号

        #data.append('checkbox9=%s'%('Y'))#是否保存在学用联系人,默认是不加入

        i+=1

    while i <= 5:

        data.append('oldPassengers=%s'%(''))#&

        #data.append('checkbox9=%s'%('Y'))#Y&

        i+=1

    data.append('randCode=%s'%(randCode))#=ze9q&

    data.append('orderRequest.reserve_flag=%s'%(getvalue(submitRequestInfo,'orderRequest.reserve_flag')))#=A&

    sendcheckdata =  Crlf.join(data)

    data.append('tFlag=%s'%('dc'))#=dc submit_form_confirm('confirmPassenger','dc')

    

    senddata = Crlf.join(data)

    curl = pycurl.Curl()

    b = StringIO.StringIO()

    curl.setopt(pycurl.WRITEFUNCTION, b.write)

    #用于查询是否有票或及排队情况

    curl.setopt(pycurl.URL, "https://dynamic.12306.cn/otsweb/order/confirmPassengerAction.do?method=checkOrderInfo&rand=%s"%(randCode))

    curl.setopt(pycurl.SSL_VERIFYPEER, False)

    curl.setopt(pycurl.SSL_VERIFYHOST, False)

    curl.setopt(pycurl.HTTPHEADER,["x-requested-with:XMLHttpRequest",

                                   "Content-Type:application/x-www-form-urlencoded",

                                   "Referer:https://dynamic.12306.cn/otsweb/order/confirmPassengerAction.do?method=init#"])

   

    curl.setopt(pycurl.COOKIE,Cookie)

    curl.setopt(pycurl.HEADERFUNCTION, gethead)

    curl.setopt(pycurl.POSTFIELDS,senddata)

    time.sleep(0.2)

    curl.perform()

    backinfo = ""

    print "f",b.getvalue()

    if curl.getinfo(pycurl.RESPONSE_CODE) == 200:

        backinfo = b.getvalue()

        curl.close()

        time.sleep(0.2)#这个提交的不能太快，应该是12306防快提交

        curl = pycurl.Curl()

        b = StringIO.StringIO()

        curl.setopt(pycurl.WRITEFUNCTION, b.write)

        httpdata = []

        #得到结果，如果有足够的票就返回{"checkHuimd":"Y","check608":"Y","msg":"","errMsg":"Y"}

        httpdata.append("https://dynamic.12306.cn/otsweb/order/confirmPassengerAction.do?method=getQueueCount")

        httpdata.append("train_date=%s"%(getvalue(submitRequestInfo,'orderRequest.train_date')))

        httpdata.append("train_no=%s"%(getvalue(submitRequestInfo,'orderRequest.train_no')))

        httpdata.append("station=%s"%(getvalue(submitRequestInfo,'orderRequest.station_train_code')))

        httpdata.append("seat=%s"%(persion['seat']))

        httpdata.append("from=%s"%(getvalue(submitRequestInfo,'orderRequest.from_station_telecode')))

        httpdata.append("to=%s"%(getvalue(submitRequestInfo,'orderRequest.to_station_telecode')))

        httpdata.append("ticket=%s"%(getvalue(submitRequestInfo,'leftTicketStr')))

        curl.setopt(pycurl.URL, Crlf.join(httpdata))

        curl.setopt(pycurl.SSL_VERIFYPEER, False)

        curl.setopt(pycurl.SSL_VERIFYHOST, False)

        curl.setopt(pycurl.HTTPHEADER,["x-requested-with:XMLHttpRequest",

                                       "Content-Type:application/x-www-form-urlencoded",

                                       "Referer:https://dynamic.12306.cn/otsweb/order/confirmPassengerAction.do?method=init#"])

       

        curl.setopt(pycurl.COOKIE,Cookie)

        curl.setopt(pycurl.HEADERFUNCTION, gethead)

        curl.perform()

        backinfo = b.getvalue()

        print 's',b.getvalue()

        if curl.getinfo(pycurl.RESPONSE_CODE) == 200:

            curl.close()

            time.sleep(1)#这个提交的不能太快，应该是12306防快提交

            curl = pycurl.Curl()

            b = StringIO.StringIO()

            curl.setopt(pycurl.WRITEFUNCTION, b.write) 

            curl.setopt(pycurl.URL, "https://dynamic.12306.cn/otsweb/order/confirmPassengerAction.do?method=confirmSingleForQueue")

            curl.setopt(pycurl.SSL_VERIFYPEER, False)

            curl.setopt(pycurl.SSL_VERIFYHOST, False)

            curl.setopt(pycurl.HTTPHEADER,["x-requested-with:XMLHttpRequest",

                                           "Content-Type:application/x-www-form-urlencoded",

                                           "Referer:https://dynamic.12306.cn/otsweb/order/confirmPassengerAction.do?method=init#"])

            curl.setopt(pycurl.COOKIE,Cookie)

            curl.setopt(pycurl.HEADERFUNCTION, gethead)

            curl.setopt(pycurl.POSTFIELDS,sendcheckdata)

            curl.perform()

            backinfo = b.getvalue()

    curl.close()

    return backinfo

def GetMyPeople():#得到学用联系人

    url = "https://dynamic.12306.cn/otsweb/order/confirmPassengerAction.do?method=getpassengerJson"

    curl = pycurl.Curl()

    b = StringIO.StringIO()

    curl.setopt(pycurl.URL, url)

    curl.setopt(pycurl.WRITEFUNCTION, b.write)  

    curl.setopt(pycurl.SSL_VERIFYPEER, 0)

    curl.setopt(pycurl.SSL_VERIFYHOST, 0)

    curl.setopt(pycurl.COOKIE,Cookie)

    curl.setopt(pycurl.POSTFIELDS,'')

    curl.perform()

    if curl.getinfo(pycurl.RESPONSE_CODE) == 200:

        train = b.getvalue()

        curl.close()

        return train

    curl.close()

    return None

def QueryUnfinishedTicket():#查询未完成的订单

    url = "https://dynamic.12306.cn/otsweb/order/myOrderAction.do?method=queryMyOrderNotComplete&leftmenu=Y"

    curl = pycurl.Curl()

    b = StringIO.StringIO()

    curl.setopt(pycurl.URL, url)

    curl.setopt(pycurl.WRITEFUNCTION, b.write)  

    curl.setopt(pycurl.SSL_VERIFYPEER, 0)

    curl.setopt(pycurl.SSL_VERIFYHOST, 0)

    curl.setopt(pycurl.HTTPHEADER,["Referer:https://dynamic.12306.cn/otsweb/loginAction.do?method=login"])

    curl.setopt(pycurl.COOKIE,Cookie)

    curl.setopt(pycurl.POSTFIELDS,'')

    curl.perform()

    if curl.getinfo(pycurl.RESPONSE_CODE) == 200:

        ticket = b.getvalue()

        curl.close()

        return ticket

    curl.close()

    return None

def WaitQueryCheckOutInfo():#得到提交订单的结果

    curl = pycurl.Curl()

    b = StringIO.StringIO()

    curl.setopt(pycurl.WRITEFUNCTION, b.write) 

    curl.setopt(pycurl.URL, "https://dynamic.12306.cn/otsweb/order/myOrderAction.do?method=queryOrderWaitTime&tourFlag=dc")

    curl.setopt(pycurl.SSL_VERIFYPEER, False)

    curl.setopt(pycurl.SSL_VERIFYHOST, False)

    curl.setopt(pycurl.HTTPHEADER,["x-requested-with:XMLHttpRequest",

                                    "Content-Type:application/x-www-form-urlencoded",

                                    "Referer:https://dynamic.12306.cn/otsweb/order/confirmPassengerAction.do?method=init"])

    curl.setopt(pycurl.COOKIE,Cookie)

    curl.perform()

    backinfo = None

    if curl.getinfo(pycurl.RESPONSE_CODE) == 200:

        backinfo = b.getvalue()

    curl.close()

    return backinfo

def writefile_map(name,data):

    files = open(name,'wb')

    files.write(data)

    files.close()

    

    try:

        os.startfile(name)

    except:

        im = Image.open(name)

        im.show()

    #os.startfile(name)

def ReadConfig():

    try:

     config = ConfigParser.ConfigParser()

     config.readfp(open('/home/china/桌面/myPython/cookie.ini',"rb"))

     return config.get("Myini","cookie")

    except:

        return ''

def WriteConfig(nCookie):

    config = ConfigParser.ConfigParser()

    config.set("Myini","cookie",nCookie)

    cf.write(open("/home/china/桌面/myPython/cookie.ini", "w"))

def FlashAllTrainListCode():

    curl = pycurl.Curl()

    b = StringIO.StringIO()

    curl.setopt(pycurl.WRITEFUNCTION, b.write) 

    curl.setopt(pycurl.URL, "https://dynamic.12306.cn/TrainQuery/passCodeActi0n.do?rand=rrand?0.38251218537598275")

    curl.setopt(pycurl.SSL_VERIFYPEER, False)

    curl.setopt(pycurl.SSL_VERIFYHOST, False)

    curl.setopt(pycurl.HTTPHEADER,["Referer:http://dynamic.12306.cn/TrainQuery/trainPassStationByTrainCode.jsp"])

    curl.setopt(pycurl.COOKIE,Cookie)

    curl.setopt(pycurl.HEADERFUNCTION, headerCookie)

    curl.perform()

    backinfo = None

    if curl.getinfo(pycurl.RESPONSE_CODE) == 200:

        backinfo = b.getvalue()

    curl.close()

    return backinfo

def GetAllTrainListCode():

    curl = pycurl.Curl()

    b = StringIO.StringIO()

    curl.setopt(pycurl.WRITEFUNCTION, b.write) 

    curl.setopt(pycurl.URL, "https://dynamic.12306.cn/TrainQuery/passCodeActi0n.do?rand=rrand")

    curl.setopt(pycurl.SSL_VERIFYPEER, False)

    curl.setopt(pycurl.SSL_VERIFYHOST, False)

    curl.setopt(pycurl.HTTPHEADER,["Referer:http://dynamic.12306.cn/TrainQuery/trainPassStationByTrainCode.jsp"])

    curl.setopt(pycurl.COOKIE,Cookie)

    curl.setopt(pycurl.HEADERFUNCTION, headerCookie)

    curl.perform()

    backinfo = None

    if curl.getinfo(pycurl.RESPONSE_CODE) == 200:

        backinfo = b.getvalue()

    curl.close()

    return backinfo

def GetAllTrainListStationtoStationAndTrain(nmonth,nday,train,rand,startStation,arriveStation):

    #condition=&nmonth2=08&nmonth2_new_value=true&

    #nday2=08&nday2_new_value=false&

    #startStation_ticketPrice1=%E5%8C%97%E4%BA%AC&

    #startStation_ticketPrice1_new_value=false&

    #arriveStation_ticketPrice1=%E5%8D%97%E6%98%8C&

    #arriveStation_ticketPrice1_new_value=false&

    #trainCode=Z65&

    #trainCode_new_value=false&rFlag=1&name_ckball=value_ckball&tFlagDC=DC&tFlagZ=Z&tFlagT=T&tFlagK=K&tFlagPK=PK&tFlagPKE=PKE&tFlagLK=LK&randCode=1


    data =[]

    Crlf = '&'

    data.append('condition=')

    data.append('nmonth2=%s'%(nmonth))

    data.append('nmonth2_new_value=true')

    data.append('nday2=%s'%(nday))

    data.append('nday2_new_value=false')

    data.append('startStation_ticketPrice1=%s'%(startStation))

    data.append('startStation_ticketPrice1_new_value=false')

    data.append('arriveStation_ticketPrice1=%s'%(arriveStation))

    data.append('arriveStation_ticketPrice1_new_value=false')

    data.append('trainCode=%s'%(train))

    data.append('trainCode_new_value=false&rFlag=1&name_ckball=value_ckball&tFlagDC=DC&tFlagZ=Z&tFlagT=T&tFlagK=K&tFlagPK=PK&tFlagPKE=PKE&tFlagLK=LK')

    data.append('randCode=%s'%(rand))

    senddata = Crlf.join(data)

    #print senddata

    curl = pycurl.Curl()

    b = StringIO.StringIO()

    curl.setopt(pycurl.WRITEFUNCTION, b.write) 

    curl.setopt(pycurl.URL, "https://dynamic.12306.cn/TrainQuery/iframeTicketPriceByStation.jsp")

    curl.setopt(pycurl.SSL_VERIFYPEER, False)

    curl.setopt(pycurl.SSL_VERIFYHOST, False)

    curl.setopt(pycurl.HTTPHEADER,["Referer:http://dynamic.12306.cn/TrainQuery/ticketPriceByStation.jsp"])

    curl.setopt(pycurl.COOKIE,Cookie)

    curl.setopt(pycurl.POSTFIELDS,senddata)

    curl.perform()

    backinfo = None

    if curl.getinfo(pycurl.RESPONSE_CODE) == 200:

        backinfo = b.getvalue()

    curl.close()

    return backinfo

def GetAllTrainListStationtoStation(nmonth,nday,rand,startStation,arriveStation):

    #nmonth1=08&

    #nmonth1_new_value=true&

    #nday1=08&

    #nday1_new_value=false&

    #startStation=%E5%8D%97%E6%98%8C&

    #startStation_new_value=false&

    #arriveStation=%E5%8C%97%E4%BA%AC&

    #arriveStation_new_value=false&rFlag=1&name_ckball=value_ckball&tFlagDC=DC&tFlagZ=Z&tFlagT=T&tFlagK=K&tFlagPK=PK&tFlagPKE=PKE&tFlagLK=LK&randCode=5


    data =[]

    Crlf = '&'

    data.append('nmonth1=%s'%(nmonth))

    data.append('nmonth1_new_value=true')

    data.append('nday1=%s'%(nday))

    data.append('nmonth1_new_value=false')

    data.append('startStation=%s'%(startStation))

    data.append('trainCode1_new_value=false')

    data.append('arriveStation=%s'%(arriveStation))

    data.append('arriveStation_new_value=false&rFlag=1&name_ckball=value_ckball&tFlagDC=DC&tFlagZ=Z&tFlagT=T&tFlagK=K&tFlagPK=PK&tFlagPKE=PKE&tFlagLK=LK')

    data.append('randCode=%s'%(rand))

    senddata = Crlf.join(data)

    #print senddata

    curl = pycurl.Curl()

    b = StringIO.StringIO()

    curl.setopt(pycurl.WRITEFUNCTION, b.write) 

    curl.setopt(pycurl.URL, "https://dynamic.12306.cn/TrainQuery/iframeTrainInfoByStation.jsp")

    curl.setopt(pycurl.SSL_VERIFYPEER, False)

    curl.setopt(pycurl.SSL_VERIFYHOST, False)

    curl.setopt(pycurl.HTTPHEADER,["Referer:http://dynamic.12306.cn/TrainQuery/trainInfoByStation.jsp"])

    curl.setopt(pycurl.COOKIE,Cookie)

    curl.setopt(pycurl.POSTFIELDS,senddata)

    curl.perform()

    backinfo = None

    if curl.getinfo(pycurl.RESPONSE_CODE) == 200:

        backinfo = b.getvalue()

    curl.close()

    return backinfo

def GetAllTrainList(nmonth,nday,trainCode,rand):

    #nmonth1=03&nmonth1_new_value=false&nday1=13&nday1_new_value=false&trainCode1=Z68&trainCode1_new_value=true&randCode=9

    data =[]

    Crlf = '&'

    data.append('nmonth1=%s'%(nmonth))

    data.append('nmonth1_new_value=false')

    data.append('nday1=%s'%(nday))

    data.append('nmonth1_new_value=false')

    data.append('trainCode1=%s'%(trainCode))

    data.append('trainCode1_new_value=true')

    data.append('startStation_ticketPrice1=保定')

    data.append('randCode=%s'%(rand))

    senddata = Crlf.join(data)

    #print senddata

    curl = pycurl.Curl()

    b = StringIO.StringIO()

    curl.setopt(pycurl.WRITEFUNCTION, b.write) 

    curl.setopt(pycurl.URL, "https://dynamic.12306.cn/TrainQuery/iframeTrainPassStationByTrainCode.jsp")

    curl.setopt(pycurl.SSL_VERIFYPEER, False)

    curl.setopt(pycurl.SSL_VERIFYHOST, False)

    curl.setopt(pycurl.HTTPHEADER,["Referer:http://dynamic.12306.cn/TrainQuery/trainPassStationByTrainCode.jsp"])

    curl.setopt(pycurl.COOKIE,Cookie)

    curl.setopt(pycurl.POSTFIELDS,senddata)

    curl.perform()

    backinfo = None

    if curl.getinfo(pycurl.RESPONSE_CODE) == 200:

        backinfo = b.getvalue()

    curl.close()

    return backinfo

#TrainNumStr T15 ,date 2012-12-21

def GetStationFromTrainNumStr(TrainNumStr,ndate):

    data =[]

    Crlf = '&'

    data.append('method=getTrainName')

    data.append('inputValue='+TrainNumStr)

    data.append('date='+ndate.replace("-",""))

    senddata = Crlf.join(data)

    print senddata

    curl = pycurl.Curl()

    b = StringIO.StringIO()

    curl.setopt(pycurl.WRITEFUNCTION, b.write) 

    curl.setopt(pycurl.URL, "https://dynamic.12306.cn/TrainQuery/autocomplete.do")

    curl.setopt(pycurl.SSL_VERIFYPEER, False)

    curl.setopt(pycurl.SSL_VERIFYHOST, False)

    curl.setopt(pycurl.HTTPHEADER,["Referer:http://dynamic.12306.cn/TrainQuery/trainPassStationByTrainCode.jsp",

                                   "x-requested-with: XMLHttpRequest"])

    curl.setopt(pycurl.COOKIE,Cookie)

    curl.setopt(pycurl.POSTFIELDS,senddata)

    curl.perform()

    backinfo = None

    if curl.getinfo(pycurl.RESPONSE_CODE) == 200:

        backinfo = b.getvalue()

    curl.close()

    return backinfo

def GetTrainAllListFromStationAndTimeAndTrainNum(train_no,from_station_telecode,to_station_telecode,depart_date):

    if(train_no == None or from_station_telecode == None or to_station_telecode == None or  depart_date == None):

        return ""

    crlf = '&'

    httpurl = []

    httpurl.append('https://dynamic.12306.cn/otsweb/order/querySingleAction.do?method=queryaTrainStopTimeByTrainNo')

    httpurl.append('train_no='+train_no)

    httpurl.append('from_station_telecode='+from_station_telecode)

    httpurl.append('to_station_telecode='+to_station_telecode)

    httpurl.append('depart_date='+depart_date)

    

    url = crlf.join(httpurl)

    

    curl = pycurl.Curl()

    b = StringIO.StringIO()

    curl.setopt(pycurl.URL, url)

    curl.setopt(pycurl.HTTPHEADER,["x-requested-with: XMLHttpRequest",

                                   "https://dynamic.12306.cn/otsweb/order/querySingleAction.do?method=init"])

    curl.setopt(pycurl.WRITEFUNCTION, b.write)  

    curl.setopt(pycurl.SSL_VERIFYPEER, 0)

    curl.setopt(pycurl.SSL_VERIFYHOST, 0)

    curl.setopt(pycurl.COOKIE,Cookie)

    curl.perform()

    backinfo = None

    if curl.getinfo(pycurl.RESPONSE_CODE) == 200:

        backinfo = b.getvalue()

    curl.close()

    return backinfo

def ChangeStationFromTrainNumStrRe(info):

    if info == None:

        return None

    com = r'''parent.mygrid.addRow\(\d+,"\d+,(.*?)\^.*?self,(\d\d:\d\d),(\d\d:\d\d),(\d\d:\d\d),.*?,.*?\^self,.*?,.*?,(.*?),(.*?),(.*?),(.*?),(.*?),(.*?),(.*?),(.*?),(.*?)"'''#

    backinfo = {}

    p = re.compile(com,re.DOTALL)

    for m in p.finditer(info):

        #print m.group(1),m.group(2),m.group(3),m.group(4),m.group(5),m.group(6),m.group(7),m.group(8),m.group(9),m.group(10),m.group(11),m.group(12),m.group(13)

        if len(m.group(1))>1:

            backinfo[m.group(1)]=[m.group(5),m.group(6),m.group(7),m.group(8),m.group(9),m.group(10),m.group(11),m.group(12),m.group(13)];

    if len(backinfo) == 0:

        return None

    print backinfo


def GetTrainAllListFromStationAndTimeAndTrainNumRe(info):

    if info == None:

        return None

    com = r'''parent.mygrid.addRow\(\d+,"\d+,(.*?)\^.*?self,.*?self,(.*?),(.*?),(.*?),(.*?),(.*?),(.*?),(.*?),(.*?),(.*?),(\d\d:\d\d),(\d\d:\d\d),(\d\d:\d\d).*?"'''

    backinfo = {}

    p = re.compile(com,re.DOTALL)

    for m in p.finditer(info):

        #print m.group(1),m.group(2),m.group(3),m.group(4),m.group(5),m.group(6),m.group(7),m.group(8),m.group(9),m.group(10),m.group(11),m.group(12),m.group(13)

        if len(m.group(1))>1:

            backinfo[m.group(1)]=[m.group(11),m.group(12),m.group(13),m.group(2),m.group(3),m.group(4),m.group(5),m.group(6),m.group(7),m.group(8),m.group(9),m.group(10)];

    if len(backinfo) == 0:

        return None

    return backinfo

def ChangeStationFromTrainNumStr(statin):

    com = r'''<option.*?value='(.*?)_(.*?)'>.*?\（(.*?)→(.*?)\）.*?</option>'''#

    backinfo = []

    p = re.compile(com,re.DOTALL)

    for m in p.finditer(statin):

        listinfo = [m.group(1),m.group(2),m.group(3),m.group(4)]

        backinfo.append(listinfo)

    return backinfo

def GetInfoFromTrainNum():

    statin = 'T145'

    date = '2013-03-14'

    getRandAndCookie()

    GetAllTrainListCode()

    info =  GetStationFromTrainNumStr(statin,date)

    infolist = ChangeStationFromTrainNumStr(info)

    print info.decode("utf-8")

    GetTrainList()

    for i in infolist:

        print GetTrainAllListFromStationAndTimeAndTrainNum(i[1],TranCityToId(i[2]),TranCityToId(i[3]),date)

def GetAllTrainNameList():

    TrainNameList = []

    try:

        tfile = open('traininfo.txt','r')

        buf = tfile.readline()

        while buf:

            be = buf.find(';')

            if be > 0:

                en = buf[be+1:].find(';')

                if en > 0:

                    TrainNameList.append(buf[be+1:en+be+1])

            buf = tfile.readline()

        tfile.close()

    except:

        return None

    return TrainNameList

def GetTrainPriceInfo(info):

    if info == None or len(info) < 100:

        return None

    com = '''innerHTML="(<.*?>(.+?)</.*?>.*?（(.*?)）.*?<.*?>(.+?)</.*?>.*?<.*?>(.+?)</.*?>.*?<.*?>(.+?)</.*?>.*?)"'''#

    backinfo = [[],{}]

    p = re.compile(com,re.DOTALL)

    for m in p.finditer(info):

        #print m.group(2),m.group(3).decode("UTF-8"),m.group(4).decode("UTF-8"),m.group(5).decode("UTF-8"),m.group(6)

        listinfo = [m.group(2),m.group(3),m.group(4),m.group(5),m.group(6)]

        backinfo[0] = listinfo

        break


    if(len(backinfo[0]) == 0):

        return None

    com = '''parent.mygrid.addRow\\(.*?"(.*?),(.*?)\\^.*?,.*?,(.*?),(.*?),(.*?),(.*?),(.*?),(.*?),(.*?),(.*?),(.*?),(.*?),(.*?),(.*?)"'''

    listinfo = {}

    p = re.compile(com,re.DOTALL)

    for m in p.finditer(info):

        #print m.group(1),m.group(2).decode("UTF-8"),m.group(3),m.group(4),m.group(5),m.group(6),m.group(7),m.group(8),m.group(9),m.group(10),m.group(11),m.group(12),m.group(13),m.group(14)

        listinfo[m.group(1)] = [m.group(2),m.group(3),m.group(4),m.group(5),m.group(6),m.group(7),m.group(8),m.group(9),m.group(10),m.group(11),m.group(12),m.group(13),m.group(14)]

    backinfo[1] = listinfo

    return backinfo

def savePrice(priceListFile,infolist):

    for sinfolist in infolist[0]:

        priceListFile.write(sinfolist)

        priceListFile.write(';')

    for i in range(1,len(infolist)):

        jsoninfo =  json.dumps(infolist[i], encoding="UTF-8", ensure_ascii=False)

        priceListFile.write(jsoninfo.encode('UTF-8'))

    priceListFile.write('\n')

def GetQuery(TrainNameList):#查询 车次及价格

    if TrainNameList == None:

        print 'can find TrainNameList'

        return None

    backinfo = []

    date = time.strftime("%Y-%m-%d",)

    nmonth = '%02d'%(time.localtime(time.time()).tm_mon)

    nday = '%02d'%(time.localtime(time.time()).tm_mday)

    trainCode = "K106"

    j = 0

    

    

    getRandAndCookie()

    print 'alltrainNum:',len(TrainNameList)

    #codemap = GetAllTrainListCode()

    #writefile_map('codein.png',codemap)

    #randcode = raw_input('imput code:')

    try:

        priceListFile = open('trainproce.txt','r')

        buf = priceListFile.readline()

        while buf:

            liinfo = [[],{}]

            if len(buf)>20:

                f = buf.find('{')

                if f < 0:

                    break

                liinfo[0] = buf[0:f-1].split(';')

                liinfo[1] = eval(buf[f:])

                backinfo.append(liinfo)

            buf = priceListFile.readline()

        priceListFile.close()

    except:

       pass

    print len(backinfo)


    priceListFile = open('trainproce.txt','w')

    j = 0

    for bprict in backinfo:

        j = j +1

        savePrice(priceListFile,bprict)


    '''for trainCode in TrainNameList:

        for bprict in backinfo:

            if trainCode == bprict[0][0]:

                trainCode = None

                break

        if None == trainCode:

            continue

        codemap = GetAllTrainListCode()

        infolist = None

        print trainCode,

        for i in range(0,10):

            

            info = GetAllTrainList(nmonth,nday,trainCode,i)

            infolist = GetTrainPriceInfo(info)

            if infolist != None:#已查到

                savePrice(priceListFile,infolist)

                j = j +1

                backinfo.append(infolist)

                break

        if infolist == None:

            print 'error',j

        else:

            print 'ok',j'''

        #randcode = raw_input('imput code:')

    priceListFile.close()

    priceListFiles = open('trainproce_a_t.txt','a')

    nowbacklen = len(backinfo)

    for cc in range(0,nowbacklen):

        print cc

        subinfo = backinfo[cc]

        infoRe = None

        ssubinfo = subinfo[0]

        for j in range(1,len(ssubinfo[1])+1):

            subbackinfo = {}

            for k in range(j+1,len(ssubinfo[1])+1):

                codemap = GetAllTrainListCode()

                print ssubinfo[0],subinfo[1]['%d'%(j)][0].decode('utf-8'),subinfo[1]['%d'%(k)][0].decode('utf-8'),

                for i in range(0,10):

                    #json.dumps(infolist[1], encoding="UTF-8", ensure_ascii=False)

                    

                    infoRe = GetTrainAllListFromStationAndTimeAndTrainNumRe(

                        GetAllTrainListStationtoStationAndTrain(nmonth,nday,ssubinfo[0],i,subinfo[1]['%d'%(j)][0],subinfo[1]['%d'%(k)][0]))

                   # print 'y',infoRe == None,infoRe

                    

                    if infoRe != None:

                        print 'h',infoRe

                        break

                if infoRe == None:

                    print 'error'

                else:

                    intoinfo = [subinfo[1]['%d'%(k)][0]]

                    for t in infoRe[ssubinfo[0]]:

                        intoinfo.append(t)

                    #print intoinfo

                    

                    subbackinfo['%d'%(k-j)] = intoinfo

                    priceListFiles.write(ssubinfo[0])#车次

                    priceListFiles.write(';')

                    #jsoninfo =  json.dumps(intoinfo, encoding="UTF-8", ensure_ascii=False)

                    priceListFiles.write(str(intoinfo).encode('UTF-8'))

                    priceListFiles.write('\n')

                    print 'ok'

                    break

            if len(subbackinfo)>0:

                backinfo.append([[subinfo[0],subinfo[1],subbackinfo['1'],subbackinfo['%d'%(len(subbackinfo)-1)],len(subbackinfo)],

                                 subbackinfo])

                #print backinfo[cc]

        print len(backinfo)

        #break

    priceListFiles.close()

    priceListFile = open('trainproce_a.txt','w')

    j = 0

    for bprict in backinfo:

        j = j +1

        savePrice(priceListFile,bprict)


    priceListFile.close()

    return backinfo


def GetTicket(use,password,fromcity,tocity,date,stationName,Peoples):

    getRandAndCookie()

    codemap = getEnterRandCode()


    writefile_map('codein.png',codemap)

    randcode = raw_input('imput code:')

    

    newkey = GetNewKey()

    print newkey

    

    #getRandCode()


    info = setuseandpassword(randcode,use,password,newkey)

    #print info

    backinfo = transitionGetUseInfo(info)

    if backinfo.find('error') >=0:#也就是没有错误时

        print backinfo

        return None

    print "提示：",backinfo.decode("UTF-8")

    backinfo = GetTrainList()

    if backinfo == None:

        return None

    fromstationid = TranCityToId(fromcity)

    tostationid = TranCityToId(tocity)

    if fromstationid == None:

        print '出发站未找到'

        return None

    if tostationid == None:

        print '到站未找到'

        return None

    starttime = '00:00--24:00'

    isstudent = False

    seatType = ''

    backinfo = GetTrainNumList(date,fromstationid,tostationid,starttime)

    print backinfo

    if backinfo == None:

        print 'GetTrainNumList 错误'

        return None

    print stationName

    stationNum = ChangeToTrainNumId(stationName)

    if stationNum == None:

        print 'ChangeToTrainNumId error'

        return None

    trainsubmitinfo = QueryTrain(fromstationid,tostationid,date,stationNum,starttime)

    #print trainsubmitinfo

    if trainsubmitinfo == None:

        print 'QueryTrain error'

        return None

    info = submitRequest(choiceSubmitNum(stationNum,trainsubmitinfo),date,starttime)

    #print info

    if info == None:

        print 'submitRequest error'

        return None

    codemap = getrandCheckCode()

    if len(codemap)<=0:

        print 'getrandCheckCode error'

        return None

    writefile_map('checkout.png',codemap)

    

    randcode = raw_input('imput code:')

    return CheckInMyTicket(info,randcode,Peoples)

    #print GetMyPeople()

def RistTrain():#从12306得到数据库

    statin = 'T145'

    date = time.strftime("%Y-%m-%d",time.localtime(time.time()))

    print date

    getRandAndCookie()

    GetAllTrainListCode()

    GetTrainList()

    f = open("info.txt","w")

    for i in range(0,9999):

        statin = "%s"%(i)#raw_input('imput code:')

        info =  GetStationFromTrainNumStr(statin,date)

        f.write(info)

        infolist = ChangeStationFromTrainNumStr(info)

        print info.decode("utf-8")

    for i in range(0,9999):

        statin = "G%s"%(i)#raw_input('imput code:')

        info =  GetStationFromTrainNumStr(statin,date)

        f.write(info)

        infolist = ChangeStationFromTrainNumStr(info)

        print info.decode("utf-8")

    f.close()

    f = open("info.txt","r")

    allinfo = {}

    line  = f.readline()

    num = 0

    while line:

        infolist = ChangeStationFromTrainNumStr(line)

        for i in infolist:

            print '1',num,i[1]

            allinfo[i[1]] = i[0]+';'+i[2]+';'+i[3]

            num = num +1

        line = f.readline()

    f.close()

    num = 0

    w = open('train.txt','w')

    for subinfo in allinfo.keys():

        print num,'2',subinfo,allinfo[subinfo]

        num = num+1

        w.write(subinfo)

        w.write(';')

        w.write(allinfo[subinfo])

        w.write('\n')

    w.close()

    q = open('traininfo.txt','w')

    sp = ';'

    num = 0

    for subinfo in allinfo.keys():

 
返回
【上篇】
【下篇】

作者:

抱歉!评论已关闭.

返回首页

Copyright © 2013-2018 学步园  保留所有权利.
软文销售 QQ客服：2265327166 点击这里给我发消息（其他合作也可洽谈）
必威体育
必威电竞