airasia_python/airasia/OrderRelation.py

from  airasia.OrderRelationEntity import OrderRelationEntity,PassengerEntity;
import json
import urllib3
import requests
import re
from pyquery import PyQuery as pq
from   utils.HttpUtils import  HttpUtils;

urllib3.disable_warnings()

headers = {
    'Accept-Encoding': 'gzip',
    "Content-Encoding": "gzip, deflate, sdch",
    "Accept-Language": "zh-CN,zh;q=0.8,en;q=0.6",
    "Upgrade-Insecure-Requests": "1",
    "Accept": "text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,*/*;q=0.8",
    "User-Agent":"Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/65.0.3325.146 Safari/537.36",
}




#解析出结果信息
def getResultInfo(html):
    if "|0|hiddenField" in html:
        results = html.index("|0|hiddenField");
        str = html[results:html.__len__()];
        if "|" in str:
            strs = str.split("|");
            for ss in strs:
                if "alert" in ss:
                    return  ss;
















# 从页面解析参数
def parserValueFroms(html ):
    jsoup =pq(html);
    __EVENTTARGET = jsoup.find("#eventTarget").attr("value");
    __EVENTARGUMENT =  jsoup.find("#eventArgument").attr("value");
    viewState = jsoup.find("#viewState").attr("value");
    __VIEWSTATEGENERATOR = jsoup.find("#__VIEWSTATEGENERATOR").attr("value");
    ControlGroupBookingListView_BookingListSearchInputView_RadioForAgent = jsoup.find("#ControlGroupBookingListView_BookingListSearchInputView_RadioForAgent").attr("value");
    ControlGroupBookingListView_BookingListSearchInputView_TextBoxKeyword = jsoup.find("#ControlGroupBookingListView_BookingListSearchInputView_TextBoxKeyword").attr("value");




    froms = {
        "__EVENTARGUMENT":"",
        "__EVENTTARGET":"",
        "__VIEWSTATE":viewState,
        "__VIEWSTATEGENERATOR":__VIEWSTATEGENERATOR,
        "ControlGroupBookingListView$BookingListSearchInputView$DropDownListTypeOfSearch":"0",
        "ControlGroupBookingListView$BookingListSearchInputView$Search":ControlGroupBookingListView_BookingListSearchInputView_RadioForAgent,
        "ControlGroupBookingListView$BookingListSearchInputView$TextBoxKeyword":"KEYWORD",
        "pageToken":""
    };
    return  froms;

# 订单关联
class OrderRelation():
    def __init__(self,params):
        self.josn_str = params;

        # 转换为实体类字段
        orderRelationEntityDict  = json.loads(self.josn_str);
        # print(orderRelationEntityDict);
        result = "";


        self.orderRelationEntity = OrderRelationEntity();
        self.orderRelationEntity.__dict__ = orderRelationEntityDict;
        print(self.orderRelationEntity.singleAccountPassWord)
        self.passengerEntity=  PassengerEntity();
        self.passengerEntity.__dict__ =self.orderRelationEntity.passengers;
        print(self.passengerEntity.bigNo)
    def worker(self):
        #代理ip
        proxies = {



        };

        # print("订单开始关联，关联信息为---"+self.josn_str);
        session = requests.session()
        session.headers.update(headers);
        HttpUtils.get(session,"https://www.airasia.com/my/en/login/travel-agent.page",proxies);
        print(session.cookies)
        logindata = {
            "__EVENTARGUMENT": "",
            "__EVENTTARGET": "ControlGroupLoginAgentView$AgentLoginView$LinkButtonLogIn",
            "ControlGroupLoginAgentView$AgentLoginView$TextBoxUserID": self.orderRelationEntity.singleAccount,
            "ControlGroupLoginAgentView$AgentLoginView$PasswordFieldPassword": self.orderRelationEntity.singleAccountPassWord,
            "pageToken": "",
            "TimeZoneDiff": "480"
        }
        res = HttpUtils.post(session,"https://booking2.airasia.com/LoginAgent.aspx", data=logindata);
        # print(res.content)
        AgentHome = res.url
        htym = res.content.decode()
        aacc = 'window.location.reload'
        print(AgentHome)
        if aacc in htym:
            print('哈哈 需要刷新一下')
            res = session.get(AgentHome)
            htym = res.content.decode()
        else:
            print(htym)

        currencycode = 'default'
        if 'ZENG' in htym:
            print("登录成功")
            print("开始跳转到订单查询页面");
            BookingListGetHtml = HttpUtils.get(session,"https://booking2.airasia.com/BookingList.aspx",proxies=proxies);
            print("进行订单的查询")

            BookingListFroms = parserValueFroms(BookingListGetHtml.content.decode());
            # print(BookingListFroms)
            BookingListPostHtml = HttpUtils.post(session,"https://booking2.airasia.com/BookingList.aspx",data=BookingListFroms,proxies=proxies)
            # print(BookingListPostHtml.content.decode())
            # 提交订单
            orderNo = self.orderRelationEntity.orderNo;
            # 解析出表单参数
            BookingListFroms["__EVENTARGUMENT"]="Edit:"+orderNo;
            BookingListFroms["__EVENTTARGET"]="ControlGroupBookingListView$BookingListSearchInputView";
            # print(BookingListFroms)
            BookingListPostHtml2 = HttpUtils.post(session,"https://booking2.airasia.com/BookingList.aspx",data=BookingListFroms,proxies=proxies);
            # print(BookingListPostHtml2.url)


            # #
            # ChangeItinerary = HttpUtils.get(session,"https://booking2.airasia.com/ChangeItinerary.aspx",proxies=proxies)
            #
            # BookingListFroms["MemberLoginChangeItineraryView2$TextBoxUserID"]="";
            # BookingListFroms["MemberLoginChangeItineraryView2$PasswordFieldPassword"]="";
            # BookingListFroms["memberLogin_chk_RememberMe"]="";
            # BookingListFroms["HiddenFieldPageBookingData"]=orderNo;
            # BookingListFroms["hdRememberMeEmail"]="";
            # BookingListFroms["__EVENTTARGET"]="ChangeControl$LinkButtonEarnBiggies";
            # BookingListFroms["__EVENTARGUMENT"]="";
            #
            # ChangeItineraryPostHtml = HttpUtils.post(session,"https://booking2.airasia.com/ChangeItinerary.aspx",data=BookingListFroms,proxies=proxies);
            EarnBiggiesGetHtml= HttpUtils.get(session,url="https://booking2.airasia.com/EarnBiggies.aspx",proxies=proxies);
            # print(EarnBiggiesGetHtml.content.decode())


            # 进入出订单关联的url中需要的 hashkey
            EarnBiggiesGetHtmlJsoup = pq(EarnBiggiesGetHtml.content.decode());
            src = EarnBiggiesGetHtmlJsoup.find("#glu").attr("src");
            if src is None:
                print("获取接口地址失败");
                EarnBiggiesGetHtml= HttpUtils.get(session,url="https://booking2.airasia.com/EarnBiggies.aspx",proxies=proxies);

            # 进入出订单关联的url中需要的 hashkey
                EarnBiggiesGetHtmlJsoup = pq(EarnBiggiesGetHtml.content.decode());
                src = EarnBiggiesGetHtmlJsoup.find("#glu").attr("src");
                print("重新获取一次")
            else:
                print(src);
            print("进入订单关联页面")
            src = src.replace("http","https");
            print("替换后的地址为-->"+src);
            PassengerBigIDLiveHtml = HttpUtils.get(session,src,proxies=proxies);
            # 解析表格
            PassengerBigIDLiveHtmlJsoup = pq(PassengerBigIDLiveHtml.content.decode());
            biggridview = PassengerBigIDLiveHtmlJsoup.find(".biggridview");
            # print(biggridview)
            centers = biggridview.html();
            trs = pq(centers).find("tr");

            passengerInfos = [];
            for tr in  trs.items():
                passengerInfo = {};
                center=tr.find("td");
                spans = center.find("span");
                for span in spans:
                    id = pq(span).attr("id");
                    if id.find("firstname")>0:
                        passengerInfo.setdefault("firstname",pq(span).text())
                    elif id.find("lastname"):
                        passengerInfo.setdefault("lastname",pq(span).text())

                key1 = center.find("input[type=hidden]").attr("name");
                key1Value = center.find("input[type=hidden]").attr("value");
                key2 = center.find("input[type=text]").attr("name");
                passengerInfo.setdefault("key1",key1);
                passengerInfo.setdefault("key1Value",key1Value);
                passengerInfo.setdefault("key2",key2);
                if passengerInfo is not  None and passengerInfo.__len__() > 0 and passengerInfo.get("firstname") is not  None:
                    passengerInfos.append(passengerInfo);


            # print(json.dumps(passengerInfos))
            if passengerInfos is None or passengerInfos.__len__() <=0 :
                print("无可关联用户")
                return  "无可关联用户";
            print("开始关联");
            PassengerBigIDLiveHtmlJsoup = pq(PassengerBigIDLiveHtml.content.decode());
            __VIEWSTATEGENERATOR =  PassengerBigIDLiveHtmlJsoup.find("#__VIEWSTATEGENERATOR").attr("value");
            __VIEWSTATE = PassengerBigIDLiveHtmlJsoup.find("#__VIEWSTATE").attr("value");
            __EVENTVALIDATION =PassengerBigIDLiveHtmlJsoup.find("#__EVENTVALIDATION").attr("value");
            PassengerBigIDLiveHtmlFroms = {

                "ScriptManager1":"MainUpdatePanel|LinkButton1",
                "__EVENTTARGET":"LinkButton1",
                "__EVENTARGUMENT":"",
                "__VIEWSTATE":__VIEWSTATE,
                "__VIEWSTATEGENERATOR":__VIEWSTATEGENERATOR,
                "__EVENTVALIDATION":__EVENTVALIDATION,
                "hfpnr":orderNo,
                "hfurl":"https://member.airasia.com/big-look-up.aspx",
                "__ASYNCPOST":"true"

            }
            # print("passengerInfos--->"+json.dumps(passengerInfos));
            # print("PassengerBigIDLiveHtmlFroms-->"+json.dumps(PassengerBigIDLiveHtmlFroms))

            for centerList in  passengerInfos:
                # print("centerList--->"+json.dumps(centerList))
                if centerList.get("firstname") == self.passengerEntity.firstName and centerList.get("lastname")==self.passengerEntity.lastName:
                    PassengerBigIDLiveHtmlFroms.setdefault(centerList.get("key1"),centerList.get("key1Value"));
                    PassengerBigIDLiveHtmlFroms.setdefault(centerList.get("key2"),self.passengerEntity.bigNo);





            # print(json.dumps(PassengerBigIDLiveHtmlFroms));
            PassengerBigIDLiveHtmlPostResp = HttpUtils.post(session,src,data=PassengerBigIDLiveHtmlFroms,proxies=proxies)
            if "0|error|500||" in PassengerBigIDLiveHtmlPostResp.content.decode():
                #重新请求一次
                PassengerBigIDLiveHtmlPostResp = HttpUtils.post(session,src,data=PassengerBigIDLiveHtmlFroms,proxies=proxies);

            result =    getResultInfo(PassengerBigIDLiveHtmlPostResp.content.decode());
            print("结果为-->"+result);

        return result;