ticket-damai's Introduction

pick-ticket-damai

大麦捡漏/pyppeteer/aiohttp 仅供参考，学习

配置：下载谷歌浏览器，安装后在浏览器地址栏输入chrome://version复制"可执行文件路径"，终端启动浏览器并登录：

C:\Users\chrome.exe --remote-debugging-port=9222 --user-data-dir="D:\Test"
可执行文件路径                             默认端口                自定义文件夹

选票：可在项目(damai)同级或用户根目录添加"config.yaml", 详解见damai.configs.default_configs.py
运行：python run.py

pyppeteer模拟购票

详见damai.init，damai.configs.default_configs

aiohttp请求购票

新仓库中优化了api请求submit的逻辑，之前不会正确退出，可删，可完全使用此仓库。
详见damai.init，damai.configs.default_configs

example3，可自定义购票逻辑。

import asyncio

from loguru import logger

from damai.performer import ApiFetchPerform
from damai.utils import make_ticket_data

POLL = 2
COUNT = 2


class Gather(ApiFetchPerform):

    async def submit(self, item_id, sku_id, tickets):
        for _ in range(POLL):
            tasks = [self._submit(item_id, sku_id, tickets) for _ in range(COUNT)]
            await asyncio.gather(*tasks)
        await super().submit(item_id, sku_id, tickets)

    async def _submit(self, item_id, sku_id, tickets):
        crate_response = {}
        try:
            build_response = await self.build_order(f'{item_id}_{tickets}_{sku_id}')
            data = build_response.get("data")
            if data:
                data = make_ticket_data(data)
                crate_response = await self.create_order(data)
        except Exception as e:
            logger.info(f'{type(e)} {e}')
        else:
            logger.info(f'生成：{build_response.get("ret")}')
            logger.info(f'创建：{crate_response.get("ret")}')