import datetime import json import multiprocessing import os import random import re import sched import sys import threading import time import traceback from urllib import parse import requests from tools import loggerKit, redis_client, file_writer from tools.utils import get_random_browser, get_external_ip, get_random_proxy_at_redis, save_all_proxy_ip, \ save_all_proxy_ip_v2, get_proxy_from_file # 创建定时器对象 scheduler = sched.scheduler(time.time, time.sleep) # 保存事件对象 event = None """ 保留登陆账号的信息 """ def save_account_info(account, passwd, target_url, single_proxy): lock = threading.Lock() with lock: if single_proxy is not None: # event_cname sub_str = target_url.replace("https://t.livepocket.jp/", "") strs = sub_str.split('/') cname = strs[len(strs) - 1] loggerKit.info(f'target_url: {target_url}, account: {account}, passwd: {passwd}') user_agent = get_random_browser() # single_proxy = 'rrehqcjf:33f90umk8x32@185.199.228.220:7300' proxies = { 'http': f'http://{single_proxy}', # 'https': f'https://{single_proxy}' } loggerKit.info(f'proxies: {proxies}') # session if redis_client.get(f'token_{account}') is None: """ 模拟登录 """ # 定义请求地址 stamp = str(int(time.time())) login_url = f"https://t.livepocket.jp/api/sessions/create?mytimestamp={stamp}" # 定义请求header headers = {'Content-Type': 'application/x-www-form-urlencoded;', 'Referer': 'https://t.livepocket.jp/login?acroot=header-new_p_u_nl', 'Sec-Ch-Ua': 'Chromium";v="124", "Google Chrome";v="124", "Not-A.Brand";v="99', 'User-Agent': user_agent, 'path': f'/api/sessions/create?mytimestamp={stamp}', 'Origin': 'https://t.livepocket.jp', 'Sec-Ch-Ua-Mobile': '?0', 'Sec-Fetch-Mode': 'cors', 'Sec-Fetch-Site': 'same-origin', 'Priority': 'u=1, i' } # 通过字典方式定义请求body form_data = {"login": account, "password": passwd, "auto_login": "on", "login_password": f"{account}&{passwd}" } data = parse.urlencode(form_data) session = requests.session() content = session.post(url=login_url, headers=headers, data=data, proxies=proxies).text # loggerKit.info(f'login info: {content}') if 'token' not in content: loggerKit.info( f'login account:{account}, 登录失败，正在重试！！！') # # 生成 2 到 6 分之间的随机等待时间 # wait_time = random.uniform(120, 180) # # 打印等待时间并等待 # loggerKit.info(f"等待 {wait_time:.2f} 秒...") # time.sleep(wait_time) return cookie = session.cookies response_cookie = cookie.get_dict() login_resp = json.loads(content) token = login_resp['result']['token'] login_session = response_cookie['ci_session'] php_session = response_cookie['PHPSESSID'] loggerKit.info(f'login account:{account}, 代理IP:{single_proxy}, token: {token} login success!!!') redis_client.set(f'token_{account}', token) redis_client.set(f'php_session_{account}', php_session) redis_client.set(f'ci_session_{account}', login_session) # 存储 account 、token 与 proxy_ip 对应关系 redis_client.set(f'proxy_ip_{account}', single_proxy) file_writer.write_to_file(f'login account:{account}, 代理IP:{single_proxy}, token: {token} 登录成功!!!') print(f"login account:{account}, 代理IP:{single_proxy}, token: {token} 登录成功!!!") else: token = redis_client.get(f'token_{account}') login_session = redis_client.get(f'ci_session_{account}') php_session = redis_client.get(f'php_session_{account}') print(f"login account:{account}, login_session:{login_session}, token: {token} 已经登录!!!") def get_ticket(account, passwd, target_url, single_proxy): if single_proxy is not None: # 开始业务逻辑 lock = threading.Lock() with lock: # event_cname sub_str = target_url.replace("https://t.livepocket.jp/", "") strs = sub_str.split('/') cname = strs[len(strs) - 1] loggerKit.info(f'target_url: {target_url}, account: {account}, passwd: {passwd}') user_agent = get_random_browser() # single_proxy = 'rrehqcjf:33f90umk8x32@185.199.228.220:7300' proxies = { 'http': f'http://{single_proxy}', # 'https': f'https://{single_proxy}' } loggerKit.info(f'proxies: {proxies}') # session if redis_client.get(f'token_{account}') is None: """ 模拟登录 """ # 定义请求地址 stamp = str(int(time.time())) login_url = f"https://t.livepocket.jp/api/sessions/create?mytimestamp={stamp}" # 定义请求header headers = {'Content-Type': 'application/x-www-form-urlencoded;', 'Referer': 'https://t.livepocket.jp/login?acroot=header-new_p_u_nl', 'Sec-Ch-Ua': 'Chromium";v="124", "Google Chrome";v="124", "Not-A.Brand";v="99', 'User-Agent': user_agent, 'path': f'/api/sessions/create?mytimestamp={stamp}', 'Origin': 'https://t.livepocket.jp', 'Sec-Ch-Ua-Mobile': '?0', 'Sec-Fetch-Mode': 'cors', 'Sec-Fetch-Site': 'same-origin', 'Priority': 'u=1, i' } # 通过字典方式定义请求body form_data = {"login": account, "password": passwd, "auto_login": "on", "login_password": f"{account}&{passwd}" } data = parse.urlencode(form_data) session = requests.session() content = session.post(url=login_url, headers=headers, data=data, proxies=proxies).text # loggerKit.info(f'login info: {content}') if 'token' not in content: loggerKit.info( f'login account:{account}, 登录失败，正在重试！！！') # # 生成 2 到 6 分之间的随机等待时间 # wait_time = random.uniform(120, 180) # # 打印等待时间并等待 # loggerKit.info(f"等待 {wait_time:.2f} 秒...") # time.sleep(wait_time) return cookie = session.cookies response_cookie = cookie.get_dict() login_resp = json.loads(content) token = login_resp['result']['token'] login_session = response_cookie['ci_session'] php_session = response_cookie['PHPSESSID'] loggerKit.info(f'login account:{account}, 代理IP:{single_proxy}, token: {token} login success!!!') redis_client.set(f'token_{account}', token) redis_client.set(f'php_session_{account}', php_session) redis_client.set(f'ci_session_{account}', login_session) file_writer.write_to_file(f'login account:{account}, 代理IP:{single_proxy}, token: {token} 登录成功!!!') else: token = redis_client.get(f'token_{account}') login_session = redis_client.get(f'ci_session_{account}') php_session = redis_client.get(f'php_session_{account}') # event_id # 从redis中查询，查询不到再去请求 event_id = redis_client.get(f'event_id_{cname}') if event_id == 0 or event_id is None: response = requests.get(target_url, proxies=proxies) if response.status_code == 200: html_string = response.content.decode('utf8') start_index = html_string.find('https://t.livepocket.jp/purchase/verify?event_id=') if start_index != -1: end_index = html_string.find("'", start_index) if end_index != -1: event_id = html_string[ start_index + len('https://t.livepocket.jp/purchase/verify?event_id='):end_index] redis_client.set(f'event_id_{cname}', event_id) loggerKit.info(f'event_id: {event_id}') else: loggerKit.warning('End index not found.') else: loggerKit.warning('Substring not found.') else: loggerKit.error('Failed to fetch the page. Status code: {0}', response.status_code) # ticket_id # 从redis中查询，不存在则请求 ticket_id = redis_client.get(f'ticket_id_{cname}') if ticket_id == 0 or ticket_id is None: response = requests.get(target_url, proxies=proxies) if response.status_code == 200: html_string = response.text match = re.search(r'id="js_order_limited_(\d+)"', html_string) if match: ticket_id = match.group(1) redis_client.set(f'ticket_id_{cname}', ticket_id) loggerKit.info(f'ticket_id: {ticket_id}') else: loggerKit.warning("未找到匹配的数值") # redirect_url1 net_url = 'https://t.livepocket.jp/purchase?type=new' result = requests.Session() header = { 'Host': 't.livepocket.jp', 'User-Agent': "Mozilla/5.0 (Windows NT 6.3; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) " "Chrome/69.0.3947.100 Safari/537.36", 'Content-Type': 'application/x-www-form-urlencoded', 'Referer': f'{target_url}', } # my_session = 'IN7u3uuP5WcizQkmRzF%2F3OsLuNNQePnxNBvnlPgqT6FPz2BgyKT2KCJaMvdj8ZSa6wNp2xZIL6VoA7Mj0R2zECMZkOKJOLbsNwUdXwvcsROxjfCzibxEaj4nG%2Bq29dCEUdiWI2TgUsKSFGRZaOP0p37ktl%2B1wSMqMAk918Nkt7APIxpQtZ%2BoLwId4PMOkN3oOIwT3CvsuDbgPQHIuokZXcnNe8uOAUuZBLW4nKOdYimLcSw6oTMt85UXkwm4OyTdxYR3%2B8crA0OfQCyfHXqY%2Bj0t9R0mmNSusRXRDuDBmOCFR58vHVuuwZ0AXNHYoYB0sdm28VL9xgHHrzkvm2M9cpLEIVWUWBWGaZgtO3xp2d8L70%2BfAKwyv6JPGcGmGf9wUQzBltssBpMmYqSfkws1%2Bp8BOhmXOqfljSYbWcxxVVSw%2B2dtoxBXsTf793mD9sVYRsrr8YPGz4JPVGWGU0outg%3D%3D' cookies = { 'ci_session': f'{login_session}', 'PHPSESSID': f'{php_session}', 'list_count': '{"success":true,"result":{"myticket_count":{"count":"0"},"today_event":{"total_count":0,"data_list":[]},"unread_count":5},"submit":true}', 'sns_status': '{"success":true,"result":{"facebook":0,"twitter":0,"mixi":0,"line":0,"yahoo":0,"plusid":1,"google":0},"submit":true}', 'display_init': '{"success":true,"result":{"purchased_tickets":{"total_count":0,"data_list":{"ticket_info":[]}},"lottery_tickets":{"total_count":0,"data_list":{"ticket_info":[]}},"order_limited_event_tickets":{"data_list":{"ticket_info":[]},"total_count":0},"event_order_limit":true},"submit":true}', } ticket_key = f'ticket_id_{ticket_id}' form_data = { 'redirect_url': 'https://t.livepocket.jp/purchase/', 'event_id': event_id, 'event_cname': f'{cname}', 'ticket_type': 'lottery', 'facebook_ticket_count': 0, 'twitter_ticket_count': 0, 'plusid_linkage_invalidation_flg': 0, ticket_key: 1 } loggerKit.info('form_data: {0}', form_data) response = result.post(net_url, headers=header, cookies=cookies, data=form_data, allow_redirects=False, proxies=proxies) loggerKit.info('response.headers: {0}', response.headers) if 'Location' in response.headers: redirect_url1 = response.headers['Location'] loggerKit.info('redirect_url1: {0}', redirect_url1) else: return # https://t.livepocket.jp/purchase/security?id=309887&type=new # redirect_url2 response2 = result.get(redirect_url1, headers=header, cookies=cookies, allow_redirects=False, proxies=proxies) loggerKit.info('response2.headers: {0}', response2.headers) if 'Location' in response2.headers: redirect_url2 = response2.headers['Location'] loggerKit.info('redirect_url2: {0}', redirect_url2) else: return # https://t.livepocket.jp/purchase/confirm?id=309887&reserved_session_id=423272 # redirect_url3 response3 = result.get(redirect_url2, headers=header, cookies=cookies, allow_redirects=False, proxies=proxies) print('response3.headers: ', response3.headers) if 'Location' in response3.headers: redirect_url3 = response3.headers['Location'] loggerKit.info('redirect_url3: {0}', redirect_url3) else: loggerKit.warning('redirect_url3 is None') return # https://t.livepocket.jp/purchase/confirm?id=309887&reserved_session_id=794986&otoken=mMyZTgzMmQ4OWQ5ZjY5NWFlNGE2ZmJlMWM5Mm # drawing_tickets # drawing_url = 'https://t.livepocket.jp/api/drawing_tickets/entry?mytimestamp=' + str(int(time.time())) region_string = redirect_url3.split('?')[1] params = region_string.split('&') reserve_session_id = params[1].split("=")[1] drawing_headers = { 'Host': 't.livepocket.jp', 'User-Agent': user_agent, 'Content-Type': 'application/x-www-form-urlencoded', 'Referer': f'{redirect_url3}', } drawing_cookies = { 'ci_session': f'{login_session}', 'PHPSESSID': f'{php_session}', } drawing_form_data = { 'utoken': f'{token}', 'onetime_token_name': 'buy_ticket', 'onetime_token_value': params[2].split('=')[1], 'url': f'https://t.livepocket.jp/purchase/confirm?id={event_id}&reserved_session_id={reserve_session_id}', 'payment_method': 0, 'reserve_session_id': reserve_session_id, 'event_id': event_id, 'reserve_ticket[0][ticket_id]': ticket_id, 'reserve_ticket[0][amount]': 1, 'payment_type': 'credit' } drawing_response = result.post( f'https://t.livepocket.jp/api/drawing_tickets/entry?mytimestamp={str(int(time.time()))}', headers=drawing_headers, cookies=drawing_cookies, data=drawing_form_data, allow_redirects=False, proxies=proxies) loggerKit.info('drawing_response.text: {0}', drawing_response.text) drawing_data = json.loads(drawing_response.text) if drawing_data['success']: order_id = drawing_data['result']['order_id'] onetime_token_name = drawing_data['result']['onetime_token_name'] onetime_token_value = drawing_data['result']['onetime_token_value'] loggerKit.info( 'account: {0}, order_id: {1}, onetime_token_name: {2}, onetime_token_value: {3}， Get Ticket!!!', account, order_id, onetime_token_name, onetime_token_value) file_writer.write_to_file(f'account: {account}, order_id: {order_id}, Order Ticket!!!') # 写入票券信息到文件 write_ticket_info(account, order_id) # 写入票券信息到文件 def write_ticket_info(account, order_id): # 获取当前日期和时间 now = datetime.datetime.now() # 创建文件夹 result_dir = 'results' if not os.path.exists(result_dir): os.makedirs(result_dir) # 创建文件 file_name = now.strftime('抢券结果_%Y-%m-%d_%H_%M') + '.txt' file_path = os.path.join(result_dir, file_name) with open(file_path, 'a+', encoding='utf-8') as f: f.write(f'account: {account}, order_id: {order_id}\n') """ 下单 """ def get_ticket_order(account, passwd, target_url, single_proxy): if single_proxy is not None: # 开始业务逻辑 lock = threading.Lock() with lock: # event_cname sub_str = target_url.replace("https://t.livepocket.jp/", "") strs = sub_str.split('/') cname = strs[len(strs) - 1] loggerKit.info(f'target_url: {target_url}, account: {account}, passwd: {passwd}') user_agent = get_random_browser() # single_proxy = 'rrehqcjf:33f90umk8x32@185.199.228.220:7300' proxies = { 'http': f'http://{single_proxy}', # 'https': f'https://{single_proxy}' } loggerKit.info(f'proxies: {proxies}') # session if redis_client.get(f'token_{account}') is None: """ 模拟登录 """ # 定义请求地址 stamp = str(int(time.time())) login_url = f"https://t.livepocket.jp/api/sessions/create?mytimestamp={stamp}" # 定义请求header headers = {'Content-Type': 'application/x-www-form-urlencoded;', 'Referer': 'https://t.livepocket.jp/login?acroot=header-new_p_u_nl', 'Sec-Ch-Ua': 'Chromium";v="124", "Google Chrome";v="124", "Not-A.Brand";v="99', 'User-Agent': user_agent, 'path': f'/api/sessions/create?mytimestamp={stamp}', 'Origin': 'https://t.livepocket.jp', 'Sec-Ch-Ua-Mobile': '?0', 'Sec-Fetch-Mode': 'cors', 'Sec-Fetch-Site': 'same-origin', 'Priority': 'u=1, i' } # 通过字典方式定义请求body form_data = {"login": account, "password": passwd, "auto_login": "on", "login_password": f"{account}&{passwd}" } data = parse.urlencode(form_data) session = requests.session() content = session.post(url=login_url, headers=headers, data=data, proxies=proxies).text # loggerKit.info(f'login info: {content}') if 'token' not in content: loggerKit.info( f'login account:{account}, 登录失败，正在重试！！！') # # 生成 2 到 6 分之间的随机等待时间 # wait_time = random.uniform(120, 180) # # 打印等待时间并等待 # loggerKit.info(f"等待 {wait_time:.2f} 秒...") # time.sleep(wait_time) return cookie = session.cookies response_cookie = cookie.get_dict() login_resp = json.loads(content) token = login_resp['result']['token'] login_session = response_cookie['ci_session'] php_session = response_cookie['PHPSESSID'] loggerKit.info(f'login account:{account}, 代理IP:{single_proxy}, token: {token} login success!!!') redis_client.set(f'token_{account}', token) redis_client.set(f'php_session_{account}', php_session) redis_client.set(f'ci_session_{account}', login_session) file_writer.write_to_file(f'login account:{account}, 代理IP:{single_proxy}, token: {token} 登录成功!!!') else: token = redis_client.get(f'token_{account}') login_session = redis_client.get(f'ci_session_{account}') php_session = redis_client.get(f'php_session_{account}') # event_id # 从redis中查询，查询不到再去请求 event_id = redis_client.get(f'event_id_{cname}') if event_id == 0 or event_id is None: response = requests.get(target_url, proxies=proxies) if response.status_code == 200: html_string = response.content.decode('utf8') start_index = html_string.find('https://t.livepocket.jp/purchase/verify?event_id=') if start_index != -1: end_index = html_string.find("'", start_index) if end_index != -1: event_id = html_string[ start_index + len('https://t.livepocket.jp/purchase/verify?event_id='):end_index] redis_client.set(f'event_id_{cname}', event_id) loggerKit.info(f'event_id: {event_id}') else: loggerKit.warning('End index not found.') else: loggerKit.warning('Substring not found.') else: loggerKit.error('Failed to fetch the page. Status code: {0}', response.status_code) # ticket_id # 从redis中查询，不存在则请求 ticket_id = redis_client.get(f'ticket_id_{cname}') if ticket_id == 0 or ticket_id is None: response = requests.get(target_url, proxies=proxies) if response.status_code == 200: html_string = response.text match = re.search(r'id="js_order_limited_(\d+)"', html_string) if match: ticket_id = match.group(1) redis_client.set(f'ticket_id_{cname}', ticket_id) loggerKit.info(f'ticket_id: {ticket_id}') else: loggerKit.warning("未找到匹配的数值") # redirect_url1 net_url = 'https://t.livepocket.jp/purchase?type=new' result = requests.Session() header = { 'Host': 't.livepocket.jp', 'User-Agent': "Mozilla/5.0 (Windows NT 6.3; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) " "Chrome/69.0.3947.100 Safari/537.36", 'Content-Type': 'application/x-www-form-urlencoded', 'Referer': f'{target_url}', } # my_session = 'IN7u3uuP5WcizQkmRzF%2F3OsLuNNQePnxNBvnlPgqT6FPz2BgyKT2KCJaMvdj8ZSa6wNp2xZIL6VoA7Mj0R2zECMZkOKJOLbsNwUdXwvcsROxjfCzibxEaj4nG%2Bq29dCEUdiWI2TgUsKSFGRZaOP0p37ktl%2B1wSMqMAk918Nkt7APIxpQtZ%2BoLwId4PMOkN3oOIwT3CvsuDbgPQHIuokZXcnNe8uOAUuZBLW4nKOdYimLcSw6oTMt85UXkwm4OyTdxYR3%2B8crA0OfQCyfHXqY%2Bj0t9R0mmNSusRXRDuDBmOCFR58vHVuuwZ0AXNHYoYB0sdm28VL9xgHHrzkvm2M9cpLEIVWUWBWGaZgtO3xp2d8L70%2BfAKwyv6JPGcGmGf9wUQzBltssBpMmYqSfkws1%2Bp8BOhmXOqfljSYbWcxxVVSw%2B2dtoxBXsTf793mD9sVYRsrr8YPGz4JPVGWGU0outg%3D%3D' cookies = { 'ci_session': f'{login_session}', 'PHPSESSID': f'{php_session}', 'list_count': '{"success":true,"result":{"myticket_count":{"count":"0"},"today_event":{"total_count":0,"data_list":[]},"unread_count":5},"submit":true}', 'sns_status': '{"success":true,"result":{"facebook":0,"twitter":0,"mixi":0,"line":0,"yahoo":0,"plusid":1,"google":0},"submit":true}', 'display_init': '{"success":true,"result":{"purchased_tickets":{"total_count":0,"data_list":{"ticket_info":[]}},"lottery_tickets":{"total_count":0,"data_list":{"ticket_info":[]}},"order_limited_event_tickets":{"data_list":{"ticket_info":[]},"total_count":0},"event_order_limit":true},"submit":true}', } ticket_key = f'ticket_id_{ticket_id}' form_data = { 'redirect_url': 'https://t.livepocket.jp/purchase/', 'event_id': event_id, 'event_cname': f'{cname}', 'ticket_type': 'lottery', 'facebook_ticket_count': 0, 'twitter_ticket_count': 0, 'plusid_linkage_invalidation_flg': 0, ticket_key: 1 } loggerKit.info('form_data: {0}', form_data) response = result.post(net_url, headers=header, cookies=cookies, data=form_data, allow_redirects=False, proxies=proxies) loggerKit.info('response.headers: {0}', response.headers) if 'Location' in response.headers: redirect_url1 = response.headers['Location'] loggerKit.info('redirect_url1: {0}', redirect_url1) else: return # https://t.livepocket.jp/purchase/security?id=309887&type=new # redirect_url2 response2 = result.get(redirect_url1, headers=header, cookies=cookies, allow_redirects=False, proxies=proxies) loggerKit.info('response2.headers: {0}', response2.headers) if 'Location' in response2.headers: redirect_url2 = response2.headers['Location'] loggerKit.info('redirect_url2: {0}', redirect_url2) else: return # https://t.livepocket.jp/purchase/confirm?id=309887&reserved_session_id=423272 # redirect_url3 response3 = result.get(redirect_url2, headers=header, cookies=cookies, allow_redirects=False, proxies=proxies) print('response3.headers: ', response3.headers) if 'Location' in response3.headers: redirect_url3 = response3.headers['Location'] loggerKit.info('redirect_url3: {0}', redirect_url3) else: loggerKit.warning('redirect_url3 is None') return # https://t.livepocket.jp/purchase/confirm?id=309887&reserved_session_id=794986&otoken=mMyZTgzMmQ4OWQ5ZjY5NWFlNGE2ZmJlMWM5Mm # drawing_tickets # drawing_url = 'https://t.livepocket.jp/api/drawing_tickets/entry?mytimestamp=' + str(int(time.time())) region_string = redirect_url3.split('?')[1] params = region_string.split('&') reserve_session_id = params[1].split("=")[1] drawing_headers = { 'Host': 't.livepocket.jp', 'User-Agent': user_agent, 'Content-Type': 'application/x-www-form-urlencoded', 'Referer': f'{redirect_url3}', } drawing_cookies = { 'ci_session': f'{login_session}', 'PHPSESSID': f'{php_session}', } drawing_form_data = { 'utoken': f'{token}', 'onetime_token_name': 'buy_ticket', 'onetime_token_value': params[2].split('=')[1], 'url': f'https://t.livepocket.jp/purchase/confirm?id={event_id}&reserved_session_id={reserve_session_id}', 'payment_method': 0, 'reserve_session_id': reserve_session_id, 'event_id': event_id, 'reserve_ticket[0][ticket_id]': ticket_id, 'reserve_ticket[0][amount]': 1, 'payment_type': 'credit' } drawing_response = result.post( f'https://t.livepocket.jp/api/drawing_tickets/entry?mytimestamp={str(int(time.time()))}', headers=drawing_headers, cookies=drawing_cookies, data=drawing_form_data, allow_redirects=False, proxies=proxies) loggerKit.info('drawing_response.text: {0}', drawing_response.text) drawing_data = json.loads(drawing_response.text) if drawing_data['success']: order_id = drawing_data['result']['order_id'] onetime_token_name = drawing_data['result']['onetime_token_name'] onetime_token_value = drawing_data['result']['onetime_token_value'] loggerKit.info( 'account: {0}, order_id: {1}, onetime_token_name: {2}, onetime_token_value: {3}， Get Ticket!!!', account, order_id, onetime_token_name, onetime_token_value) file_writer.write_to_file(f'account: {account}, order_id: {order_id}, Order Ticket!!!') # 写入文件 def process_account(pocket_url, account, single_proxy): try: run_threading(account, 'panyue666', pocket_url, single_proxy) except Exception as ex: loggerKit.error(f'error: {traceback.format_exc()}, account:{account}') """ 登陆 """ def process_account_login(pocket_url, account, single_proxy): try: run_threading_login(account, 'panyue666', pocket_url, single_proxy) except Exception as ex: loggerKit.error(f'error: {traceback.format_exc()}, account:{account}') def process_running(max_threads, pocket_url): # log_name = f"data_{datetime.datetime.now().strftime('%Y%m%d%H%M')}.txt" while True: with open('accounts.txt', 'r') as accounts: account_list = accounts.readlines() threads = [] for account in account_list: single_proxy, random_index = get_random_proxy_at_redis(600) thread = threading.Thread(target=process_account, args=(pocket_url, account.strip(), single_proxy)) threads.append(thread) thread.start() # 如果当前线程数达到上限,等待有线程结束后再创建新线程 if len(threads) == max_threads: for t in threads: t.join() threads.clear() # 等待所有线程执行完毕 for thread in threads: thread.join() """ 手动定时 """ def process_running_manual(max_threads, pocket_url): # log_name = f"data_{datetime.datetime.now().strftime('%Y%m%d%H%M')}.txt" while True: with open('accounts.txt', 'r') as accounts: account_list = accounts.readlines() threads = [] for account in account_list: # single_proxy = get_proxy_from_file("proxy_list.txt") # 从redis 中获取 proxy_ip single_proxy = redis_client.get(f'proxy_ip_{account}') print(f"当前账号: {account}, 当前代理：{single_proxy}") loggerKit.info(f"当前账号: {account}, 当前代理：{single_proxy}") thread = threading.Thread(target=process_account, args=(pocket_url, account.strip(), single_proxy)) threads.append(thread) thread.start() # 如果当前线程数达到上限,等待有线程结束后再创建新线程 if len(threads) == max_threads: for t in threads: t.join() threads.clear() # 等待所有线程执行完毕 for thread in threads: thread.join() """ 账号批量登陆 """ def login_account(max_threads, accounts_path, pocket_url): with open(accounts_path, 'r') as accounts: account_list = accounts.readlines() threads = [] for account in account_list: single_proxy = get_proxy_from_file("proxy_list.txt") print(f"当前账号: {account}, 当前代理：{single_proxy}") loggerKit.info(f"当前账号: {account}, 当前代理：{single_proxy}") thread = threading.Thread(target=save_account_info, args=(account.strip(), "panyue666", pocket_url, single_proxy)) threads.append(thread) thread.start() # 如果当前线程数达到上限,等待有线程结束后再创建新线程 if len(threads) == max_threads: for t in threads: t.join() threads.clear() # 等待所有线程执行完毕 for thread in threads: thread.join() def run_threading(account, password, url, single_proxy): try: get_ticket(account, password, url, single_proxy) except Exception as ex: loggerKit.error(f'error: {traceback.format_exc()}, account:{account}') """ 登陆 """ def run_threading_login(account, password, url, single_proxy): try: save_account_info(account, password, url, single_proxy) except Exception as ex: loggerKit.error(f'error: {traceback.format_exc()}, account:{account}') """ 下单 """ def run_threading_order(max_threads, account_path, url): while True: try: with open('accounts.txt', 'r') as accounts: account_list = accounts.readlines() threads = [] for account in account_list: # single_proxy = get_proxy_from_file("proxy_list.txt") # 从redis 中获取 proxy_ip single_proxy = redis_client.get(f'proxy_ip_{account}') print(f"当前账号: {account}, 当前代理：{single_proxy}") loggerKit.info(f"当前账号: {account}, 当前代理：{single_proxy}") thread = threading.Thread(target=get_ticket_order, args=(account, "panyue666", url, single_proxy)) threads.append(thread) thread.start() # 如果当前线程数达到上限,等待有线程结束后再创建新线程 if len(threads) == max_threads: for t in threads: t.join() threads.clear() # 等待所有线程执行完毕 for thread in threads: thread.join() except Exception as ex: loggerKit.error(f'error: {traceback.format_exc()}, account:{account_path}') def run_daily_job(hour, minute): # 获取当前日期和时间 now = datetime.datetime.now() # 计算下次运行时间 run_time = datetime.datetime(now.year, now.month, now.day, hour, minute) if run_time < now: # 如果运行时间小于当前时间，则在明天的相应时间运行任务 run_time = run_time + datetime.timedelta(days=1) # 计算等待时间 wait_time = (run_time - now).total_seconds() # 创建定时器对象 scheduler = sched.scheduler(time.time, time.sleep) # 添加定时任务 scheduler.enter(wait_time, 1, looper_job, ()) # 启动定时器 scheduler.run() """ 手动定时任务 """ def run_manual_job(hour, minute, thread_num, pocket_url): global event # 获取当前日期和时间 now = datetime.datetime.now() # 计算下次运行时间 run_time = datetime.datetime(now.year, now.month, now.day, hour, minute) if run_time < now: # 如果运行时间小于当前时间，则在明天的相应时间运行任务 run_time = run_time + datetime.timedelta(days=1) # 计算等待时间 wait_time = (run_time - now).total_seconds() # 添加定时任务，并保存事件对象 event = scheduler.enter(wait_time, 1, manual_job, argument=(thread_num, pocket_url,)) # 启动定时器 scheduler.run() """ 取消定时任务 """ def cancel_manual_job(): sys.exit() """ 停止下单 """ def stop_order_job(): sys.exit() def looper_job(): while 1: process_running(max_threads=1, pocket_url='https://t.livepocket.jp/e/l3im7') """ 手动定时 """ def manual_job(thread_num, pocket_url): process_running_manual(max_threads=thread_num, pocket_url=pocket_url) if __name__ == '__main__': # 下面一行代码即可打包多进程 multiprocessing.freeze_support() # 代理IP存储 save_all_proxy_ip_v2() # 定时抢劵 run_daily_job(13, 20)