从零开始学写脚本（大麦网抢票 上）【第二天】

这是我参与更文挑战的第3天，活动详情查看： 更文挑战

接着我们上期的教程，今天带大家一起来学习下怎么去大麦网抢票

 

我们先看看代码运行的视频效果

 

vkceyugu.cdn.bspapp.com/VKCEYUGU-4a…

 

由于今天写的时候频繁下单又取消，导致不能下单

控制台输出

 

E:\python3.9.5\damai\venv\Scripts\python.exe E:/python3.9.5/damai/main.py
###打开浏览器，进入大麦网###
###请点击登录###
###请扫码登录###
###Cookie保存成功###
###成功获取Cookie，重启浏览器###
###开始登录###
###载入Cookie###
###登录成功###
###进入抢票界面###
###等待--确认订单--页面出现，可自行刷新，若长期不跳转可选择-- CRTL+C --重新抢票###
###开始确认订单###
###选择购票人信息,可手动帮助点击###
本次抢票时间： 1.37282133102417
###等待跳转到--付款界面--，可自行刷新，若长期不跳转可选择-- CRTL+C --重新抢票###

 

创建配置参数文件

 

创建一个动态参数目录，把我们经常修改的参数写在里面

 

创建 config.json 文件

 

 

写入参数

 

{
    "sess": [1],
    "price": [2, 3, 1],
    "real_name": [1, 2],
    "nick_name": "程序工厂",
    "ticket_num": 1,
    "driver_path": "D:/python3.9.5/chromedriver.exe",
    "damai_url": "https://www.damai.cn/",
    "target_url": "https://detail.damai.cn/item.htm?spm=a2oeg.home.card_0.ditem_1.591b23e12Cgyqo&id=645040954905"
}

 

nick_name  你在大麦网账户的昵称

driver_path 浏览器驱动的地址

target_url 所抢票的购买地址

 

抢票代码

 

    # coding: utf-8
from json import loads
from time import sleep, time
from pickle import dump, load
from os.path import exists
from selenium import webdriver
from selenium.webdriver.common.by import By
from selenium.webdriver.support.ui import WebDriverWait
from selenium.webdriver.support import expected_conditions as EC
from selenium.webdriver.common.desired_capabilities import DesiredCapabilities
​
class Concert(object):
    def __init__(self, session, price, real_name, nick_name, ticket_num, damai_url, target_url,driver_path):
        self.session = session  # 场次序号优先级
        self.price = price  # 票价序号优先级
        self.real_name = real_name  # 实名者序号
        self.status = 0  # 状态标记
        self.time_start = 0  # 开始时间
        self.time_end = 0  # 结束时间
        self.num = 0  # 尝试次数
        self.ticket_num = ticket_num  # 购买票数
        self.nick_name = nick_name  # 用户昵称
        self.damai_url = damai_url  # 大麦网官网网址
        self.target_url = target_url  # 目标购票网址
        self.driver_path = driver_path  # 浏览器驱动地址
        self.driver = None
​
    def isClassPresent(self, item, name, ret=False):
        try:
            result = item.find_element_by_class_name(name)
            if ret:
                return result
            else:
                return True
        except:
            return False
​
    def get_cookie(self):
        self.driver.get(self.damai_url)
        print(u"###请点击登录###")
        self.driver.find_element_by_class_name('login-user').click()
        while self.driver.title.find('大麦网-全球演出赛事官方购票平台') != -1:  # 等待网页加载完成
            sleep(1)
        print(u"###请扫码登录###")
        while self.driver.title == '大麦登录':  # 等待扫码完成
            sleep(1)
        dump(self.driver.get_cookies(), open("cookies.pkl", "wb"))
        print(u"###Cookie保存成功###")
​
    def set_cookie(self):
        try:
            cookies = load(open("cookies.pkl", "rb"))  # 载入cookie
            for cookie in cookies:
                cookie_dict = {
                    'domain':'.damai.cn',  # 必须有，不然就是假登录
                    'name': cookie.get('name'),
                    'value': cookie.get('value'),
                    "expires": "",
                    'path': '/',
                    'httpOnly': False,
                    'HostOnly': False,
                    'Secure': False}
                self.driver.add_cookie(cookie_dict)
            print(u'###载入Cookie###')
        except Exception as e:
            print(e)
​
    def login(self):
        print(u'###开始登录###')
        self.driver.get(self.target_url)
        WebDriverWait(self.driver, 10, 0.1).until(EC.title_contains('大麦网'))
        self.set_cookie()
​
    def enter_concert(self):
        print(u'###打开浏览器，进入大麦网###')
        if not exists('cookies.pkl'):   # 如果不存在cookie.pkl,就获取一下
            self.driver = webdriver.Chrome(executable_path=self.driver_path)
            self.get_cookie()
            print(u'###成功获取Cookie，重启浏览器###')
            self.driver.quit()
​
        options = webdriver.ChromeOptions()
        # 禁止图片、js、css加载
        prefs = {"profile.managed_default_content_settings.images": 2,
                 "profile.managed_default_content_settings.javascript": 1,
                 'permissions.default.stylesheet': 2}
        options.add_experimental_option("prefs", prefs)
​
        # 更换等待策略为不等待浏览器加载完全就进行下一步操作
        capa = DesiredCapabilities.CHROME
        capa["pageLoadStrategy"] = "none"
        self.driver = webdriver.Chrome(executable_path=self.driver_path, options=options, desired_capabilities=capa)
        self.login()
        self.driver.refresh()
        try:
            locator = (By.XPATH, "/html/body/div[1]/div/div[3]/div[1]/a[2]/div")
            WebDriverWait(self.driver, 5, 0.3).until(EC.text_to_be_present_in_element(locator, self.nick_name))
            self.status = 1
            print(u"###登录成功###")
            self.time_start = time()
        except:
            self.status = 0
            self.driver.quit()
            raise Exception(u"***错误：登录失败,请删除cookie后重试***")
​
    def choose_ticket(self):
        print(u"###进入抢票界面###")
        while self.driver.title.find('确认订单') == -1:  # 如果跳转到了确认界面就算这步成功了，否则继续执行此步
            self.num += 1
​
            if con.driver.current_url.find("buy.damai.cn") != -1:
                break
​
            # 确认页面刷新成功
            try:
                #box = self.driver.find_element_by_class_name('perform__order__box')
                box = WebDriverWait(self.driver, 1, 0.1).until(EC.presence_of_element_located((By.CLASS_NAME, 'perform__order__box')))
            except:
                raise Exception(u"***Error: 页面刷新出错***")
​
            try:
                buybutton = box.find_element_by_class_name('buybtn')
                buybutton_text = buybutton.text
            except:
                raise Exception(u"***Error: buybutton 位置找不到***")
​
            if buybutton_text == "即将开抢" or buybutton_text == "即将开售":
                self.status = 2
                raise Exception(u"---尚未开售，刷新等待---")
​
            try:
                selects = box.find_elements_by_class_name('perform__order__select')
                for item in selects:
                    if item.find_element_by_class_name('select_left').text == '场次':
                        session = item
                        # print('\t场次定位成功')
                    elif item.find_element_by_class_name('select_left').text == '票档':
                        price = item
                        # print('\t票档定位成功')
​
                session_list = session.find_elements_by_class_name('select_right_list_item')
                # print('可选场次数量为：{}'.format(len(session_list)))
                for i in self.session:  # 根据优先级选择一个可行场次
                    j = session_list[i-1]
                    k = self.isClassPresent(j, 'presell', True)
                    if k: # 如果找到了带presell的类
                        if k.text == '无票':
                            continue
                        elif k.text == '预售':
                            j.click()
                            break
                    else:
                        j.click()
                        break
​
                price_list = price.find_elements_by_class_name('select_right_list_item')
                # print('可选票档数量为：{}'.format(len(price_list)))
                for i in self.price:
                    j = price_list[i-1]
                    k = self.isClassPresent(j, 'notticket')
                    if k:  # 存在notticket代表存在缺货登记，跳过
                        continue
                    else:
                        j.click()
                        break
            except:
                raise Exception(u"***Error: 选择场次or票档不成功***")
​
            try:
                ticket_num_up = box.find_element_by_class_name('cafe-c-input-number-handler-up')
            except:
                if buybutton_text == "选座购买":  # 选座购买没有增减票数键
                    buybutton.click()
                    self.status = 5
                    print(u"###请自行选择位置和票价###")
                    break
                elif buybutton_text == "提交缺货登记":
                    raise Exception(u'###票已被抢完，持续捡漏中...或请关闭程序并手动提交缺货登记###')
                else:
                    raise Exception(u"***Error: ticket_num_up 位置找不到***")
​
            if buybutton_text == "立即预订":
                for i in range(self.ticket_num-1):  # 设置增加票数
                    ticket_num_up.click()
                buybutton.click()
                self.status = 3
​
            elif buybutton_text == "立即购买":
                for i in range(self.ticket_num-1):  # 设置增加票数
                    ticket_num_up.click()
                buybutton.click()
                self.status = 4
​
    def check_order(self):
        if self.status in [3, 4, 5]:
            if self.real_name is not None:
                print(u"###等待--确认订单--页面出现，可自行刷新，若长期不跳转可选择-- CRTL+C --重新抢票###")
                try:
                    tb = WebDriverWait(self.driver, 1, 0.1).until(EC.presence_of_element_located((By.XPATH, '/html/body/div[3]/div[2]/div')))
                except:
                    raise Exception(u"***Error：实名信息选择框没有显示***")
​
                print(u'###开始确认订单###')
                print(u'###选择购票人信息,可手动帮助点击###')
                init_sleeptime = 0.0
                Labels = tb.find_elements_by_tag_name('label')
​
                # 防止点击过快导致没有选择多个人
                while True:
                    init_sleeptime += 0.1
                    true_num = 0
                    for num_people in self.real_name:
                        tag_input = Labels[num_people-1].find_element_by_tag_name('input')
                        if tag_input.get_attribute('aria-checked') == 'false':
                            sleep(init_sleeptime)
                            tag_input.click()
                        else:
                            true_num += 1
                    if true_num == len(self.real_name):
                        break
                print("本次抢票时间：", time()-self.time_start)
                self.driver.find_element_by_xpath('/html/body/div[3]/div[2]/div/div[9]/button').click() # 同意以上协议并提交订单
​
            else:
                self.driver.find_element_by_xpath('/html/body/div[2]/div[2]/div/div[8]/button').click()
​
            # 判断title是不是支付宝
            print(u"###等待跳转到--付款界面--，可自行刷新，若长期不跳转可选择-- CRTL+C --重新抢票###")
            try:
                WebDriverWait(self.driver, 3600, 0.1).until(EC.title_contains('支付宝'))
            except:
                raise Exception(u'***Error: 长期跳转不到付款界面***')
​
            self.status = 6
            print(u'###成功提交订单,请手动支付###')
            self.time_end = time()
​
​
if __name__ == '__main__':
    try:
        with open('./config.json', 'r', encoding='utf-8') as f:
            config = loads(f.read())
            # params: 场次优先级，票价优先级，实名者序号, 用户昵称， 购买票数， 官网网址， 目标网址, 浏览器驱动地址
        con = Concert(config['sess'], config['price'], config['real_name'], config['nick_name'], config['ticket_num'], config['damai_url'], config['target_url'], config['driver_path'])
        con.enter_concert()
    except Exception as e:
        print(e)
        exit(1)
    while True:
        try:
            con.choose_ticket()
            con.check_order()
        except Exception as e:
            con.driver.get(con.target_url)
            print(e)
            continue
​
        if con.status == 6:
            print(u"###经过%d轮奋斗，共耗时%.1f秒，抢票成功！请确认订单信息###" % (con.num, round(con.time_end-con.time_start, 3)))
            break
    

 

我们下来看看运行开始逻辑

 

if __name__ == '__main__':
    try:
        with open('./config.json', 'r', encoding='utf-8') as f:
            config = loads(f.read())
            # params: 场次优先级，票价优先级，实名者序号, 用户昵称， 购买票数， 官网网址， 目标网址, 浏览器驱动地址
        con = Concert(config['sess'], config['price'], config['real_name'], config['nick_name'], config['ticket_num'], config['damai_url'], config['target_url'], config['driver_path'])
        con.enter_concert()
    except Exception as e:
        print(e)
        exit(1)   

 

try:

except Exception as e:

 

是 异常（运行报错）捕获，如果在 try 和 except Exception as e:  之间的代码，如果出现异常了，就会进入 except Exception as e:  下面的方法 

print(e)

exit(1)  

print是打印的意思，e是具体的异常错误，print(e)，意思是把运行具体的报错信息打印出来，方便我们写代码的人看到具体是什么错误，exit(1) 退出程序

读取指定地址的文件

 

with open('./config.json', 'r', encoding='utf-8') as f:

 

以utf-8的格式，打开我们前面创建的配置参数文件，f 作为他的标志

 

 

读取文件内容

 config = loads(f.read())

 

read 为读取的意思，loads是加载信息，f是前面打开的文件， 那么 loads(f.read())，就是读取config.json文件的内容，然后把读到的内容给config，后面就可以直接用 config 取到config.json的内容

把读取到的文件赋值给指定参数

con = Concert(config['sess'], config['price'], config['real_name'], config['nick_name'], config['ticket_num'], config['damai_url'], config['target_url'], config['driver_path'])

 

config['sess'] 就是读取 config.json 文件里 sess 的参数,后面几个也一样

 

 

Concert 是前面写的一个方法

 

 class Concert(object):
    def __init__(self, session, price, real_name, nick_name, ticket_num, damai_url, target_url,driver_path):
        self.session = session  # 场次序号优先级
        self.price = price  # 票价序号优先级
        self.real_name = real_name  # 实名者序号
        self.status = 0  # 状态标记
        self.time_start = 0  # 开始时间
        self.time_end = 0  # 结束时间
        self.num = 0  # 尝试次数
        self.ticket_num = ticket_num  # 购买票数
        self.nick_name = nick_name  # 用户昵称
        self.damai_url = damai_url  # 大麦网官网网址
        self.target_url = target_url  # 目标购票网址
        self.driver_path = driver_path  # 浏览器驱动地址
        self.driver = None

 

连起来就是，把文件里读取过来的信息，赋值按照每个参数的单独读取，然后穿给我们定义的变量里，在这个程序里，哪里要用到的话就可以直接以 self.session 方式调用

  

接着看后面一行代码

con.enter_concert()

 

con.enter_concert() 是我们前面写的一个登录方法

 

    def enter_concert(self):
        print(u'###打开浏览器，进入大麦网###')
        if not exists('cookies.pkl'):   # 如果不存在cookie.pkl,就获取一下
            self.driver = webdriver.Chrome(executable_path=self.driver_path)
            self.get_cookie()
            print(u'###成功获取Cookie，重启浏览器###')
            self.driver.quit()
​
        options = webdriver.ChromeOptions()
        # 禁止图片、js、css加载
        prefs = {"profile.managed_default_content_settings.images": 2,
                 "profile.managed_default_content_settings.javascript": 1,
                 'permissions.default.stylesheet': 2}
        options.add_experimental_option("prefs", prefs)
​
        # 更换等待策略为不等待浏览器加载完全就进行下一步操作
        capa = DesiredCapabilities.CHROME
        capa["pageLoadStrategy"] = "none"
        self.driver = webdriver.Chrome(executable_path=self.driver_path, options=options, desired_capabilities=capa)
        self.login()
        self.driver.refresh()
        try:
            locator = (By.XPATH, "/html/body/div[1]/div/div[3]/div[1]/a[2]/div")
            WebDriverWait(self.driver, 5, 0.3).until(EC.text_to_be_present_in_element(locator, self.nick_name))
            self.status = 1
            print(u"###登录成功###")
            self.time_start = time()
        except:
            self.status = 0
            self.driver.quit()
            raise Exception(u"***错误：登录失败,请删除cookie后重试***")
​

 

其中

 

if not exists('cookies.pkl'):

 

这行代码的意思是， if not exists (如果 不存在 ) cookies.pkl 文件,执行代码

 

self.driver = webdriver.Chrome(executable_path=self.driver_path)self.get_cookie()print(u'###成功获取Cookie，重启浏览器###')self.driver.quit()

 

self.driver = webdriver.Chrome(executable_path=self.driver_path)

 

这行代码在我们上一课讲过，打开浏览器

 

self.get_cookie()  是我们代码中的一个方法

    def get_cookie(self):
        self.driver.get(self.damai_url)
        print(u"###请点击登录###")
        self.driver.find_element_by_class_name('login-user').click()
        while self.driver.title.find('大麦网-全球演出赛事官方购票平台') != -1:  # 等待网页加载完成
            sleep(1)
        print(u"###请扫码登录###")
        while self.driver.title == '大麦登录':  # 等待扫码完成
            sleep(1)
        dump(self.driver.get_cookies(), open("cookies.pkl", "wb"))
        print(u"###Cookie保存成功###")

 

打开浏览器，访问 self.damai_url （配置参数文件里 damai_url  填写的地址）地址，点击 login-user 按钮，页面就自动跳转到大麦网的登录页面了，这时候因为登录页面有多种登录方式，我们也不确定使用者具体使用那种登录方式，这是比较好的一个解决办法就是让用户自己手动登录账户，然后我们把他的登录信息存成 cookies.pkl 文件，下次进入方法如果有这个文件就不用重复登录系统了

 

接着运行到了下面代码

 

  while True:
        try:
            con.choose_ticket()
            con.check_order()
        except Exception as e:
            con.driver.get(con.target_url)
            print(e)
            continue
​
        if con.status == 6:
            print(u"###经过%d轮奋斗，共耗时%.1f秒，抢票成功！请确认订单信息###" % (con.num, round(con.time_end-con.time_start, 3)))
            break

今天先到这里，我们抢票的逻辑我们下期继续讲解

**需要源码的扫描头像关注我 回复："大麦网源码" 获取本期源码

本期代码主要参考自GitHub上代码

github地址： https://github.com/BBDrive/damai_ticket

代码是二年前写的，下载下来还不能运行，稍微修改了些代码，作为本期课程素材