coordinate/tls_registration_gui.py

import sys
import time
import json
import os
import re
import uuid
import socket
import threading
import random
import requests
from datetime import datetime
from typing import Optional, Dict

from PyQt5.QtWidgets import (
    QApplication, QMainWindow, QWidget, QVBoxLayout, QHBoxLayout, 
    QGridLayout, QGroupBox, QLabel, QLineEdit, QSpinBox, QPushButton, 
    QTableWidget, QTableWidgetItem, QAbstractItemView, QTextEdit, 
    QHeaderView, QMessageBox
)
from PyQt5.QtCore import pyqtSignal, QObject, Qt

from DrissionPage.common import Keys
from DrissionPage import ChromiumPage, ChromiumOptions

import configure
from utils.cloudflare_bypass_for_scraping import CloudflareBypasser
from toolkit.vs_cloud_api import VSCloudApi
from toolkit.mihomo_tunnel import MihomoTunnel
from vs_types import BizLogicError 
from utils.mouse import HumanMouse
from utils.keyboard import HumanKeyboard
from utils.fingerprint_utils import FingerprintGenerator
from utils.fake_utils import generate_random_account_detail

def load_proxies(pool_name):
    """从 config/proxies.json 读取对应的代理池"""
    config_path = os.path.join(os.path.dirname(__file__), 'config', 'proxies.json')
    try:
        with open(config_path, 'r', encoding='utf-8') as f:
            data = json.load(f)
            proxies = data.get(pool_name, [])
            if not proxies:
                raise ValueError(f"代理池 '{pool_name}' 为空或不存在！")
            return proxies
    except Exception as e:
        raise Exception(f"读取代理配置文件失败: {e}")

# ================= 用于跨线程更新UI的信号类 =================
class GuiSignals(QObject):
    log_signal = pyqtSignal(str)              # 传递日志文本
    status_signal = pyqtSignal(int, str)      # 传递行号和状态文本

# ================= 核心业务类 =================
class TlsRegistrator:
    def __init__(self, tls_url, proxy_config: Optional[Dict]=None, capsolver_key: Optional[str]=None, signals: GuiSignals=None):
        self.proxy_config = proxy_config
        self.capsolver_key = capsolver_key
        self.account_detail = None  # 动态绑定
        self.signals = signals      # 绑定UI信号
        
        self.instance_id = uuid.uuid4().hex[:8]
        self.tls_url = tls_url
        self.workspace = os.path.abspath(os.path.join("data/temp_browser_data", f"reg_session_{self.instance_id}"))
        self.page = None
        self.mouse = None
        self.keyboard = None
        self.tunnel = None

    def _log(self, msg):
        now = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
        log_str = f"[{now}][Bot-{self.instance_id}] {msg}"
        if self.signals:
            self.signals.log_signal.emit(log_str)
        else:
            print(log_str)

    def _get_free_port(self):
        with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
            s.bind(('', 0))
            return s.getsockname()[1]
        
    def save_screenshot(self, name_prefix):
        try:
            timestamp = int(time.time())
            filename = f"{self.instance_id}_{name_prefix}_{timestamp}.jpg"
            save_path = os.path.join("data", filename)
            os.makedirs("data", exist_ok=True)
            self.page.get_screenshot(path=save_path, full_page=False)
            self._log(f"Screenshot saved to {save_path}")
        except Exception as e:
            self._log(f"Failed to save screenshot: {e}")

    def init_browser(self):
        self._log("Initializing browser...")
        co = ChromiumOptions()
        port = self._get_free_port()
        co.set_local_port(port)
        co.set_user_data_path(self.workspace)
        
        chrome_path = configure.CHROME_PATH or os.getenv("CHROME_BIN")
        if chrome_path and os.path.exists(chrome_path):
            co.set_paths(browser_path=chrome_path)
        
        if self.proxy_config and self.proxy_config.get("ip"):
            p = self.proxy_config
            if p.get('username') and p.get('password'):
                self._log(f"Starting Proxy Tunnel for {p.get('ip')}...")
                exit_node = {
                    "name": "ExitNode", "type": p.get('proto'),
                    "server": p.get('ip'), "port": p.get('port'),
                    "username": p.get('username'), "password": p.get('password')
                }
                relay_node = random.choice(configure.MIHOMO_RELAY_NODES) if configure.MIHOMO_RELAY_NODES else None
                mihomo_path = configure.MIHOMO_BIN_PATH or os.getenv("MIHOMO_BIN")
                if not mihomo_path:
                    raise BizLogicError(message='Mihomo path is null')
                self.tunnel = MihomoTunnel(mihomo_path, exit_node=exit_node, relay_node=relay_node)
                local_proxy = self.tunnel.start()
                co.set_argument(f'--proxy-server={local_proxy}')
            else:
                proxy_str = f"{p.get('proto')}://{p.get('ip')}:{p.get('port')}"
                co.set_argument(f'--proxy-server={proxy_str}')
        else:
            self._log("[WARN] No proxy configured!")

        fingerprint_gen = FingerprintGenerator()
        specific_fp = fingerprint_gen.generate(self.instance_id)
        
        co.headless(False)
        co.set_argument('--no-sandbox')
        co.set_argument('--disable-dev-shm-usage')
        co.set_argument('--window-size=1920,1080')
        co.set_argument('--disable-blink-features=AutomationControlled')
        co.set_argument(f"--fingerprint={specific_fp.get('seed')}")
        co.set_argument(f"--fingerprint-platform={specific_fp.get('platform')}")
        co.set_argument(f"--fingerprint-brand={specific_fp.get('brand')}")
        
        self.page = ChromiumPage(co)
        self.page.get(self.tls_url)
        time.sleep(5)
        
        cf_bypasser = CloudflareBypasser(self.page, log=True)
        cf_bypasser.bypass(max_retry=8)
        time.sleep(3)
        cf_bypasser.handle_waiting_room()
        
        self._log("正在初始化拟人化工具...")
        self.mouse = HumanMouse(self.page, debug=False)
        self.keyboard = HumanKeyboard(self.page)
        
        viewport_width = self.page.rect.viewport_size[0]
        viewport_height = self.page.rect.viewport_size[1]
        init_x = random.randint(10, viewport_width - 10)
        init_y = random.randint(10, viewport_height - 10)
        self.mouse.move(init_x, init_y) 
        self._log("浏览器初始化完成。")

    def solve_captcha(self, page_url: str, task_type: str, site_key: str, use_proxy=False, action: str=None, api_domain: str=None) -> str:
        if not self.capsolver_key: raise ValueError("Capsolver API key missing")
        task = {"type": task_type, "websiteURL": page_url, "websiteKey": site_key}
        if api_domain: task["apiDomain"] = api_domain
        if use_proxy:
            proxy = self.proxy_config
            task["proxyType"] = proxy.get('proto', 'http')
            task["proxyAddress"] = proxy.get('ip')
            task["proxyPort"] = int(proxy.get('port'))
            if proxy.get('username'):
                task["proxyLogin"] = proxy.get('username')
                task["proxyPassword"] = proxy.get('password')
        if action: task["pageAction"] = action

        payload = {"clientKey": self.capsolver_key, "task": task}
        res = requests.post("https://api.capsolver.com/createTask", json=payload, timeout=20)
        if res.status_code != 200 or res.json().get("errorId") != 0:
            raise Exception(f"Failed to create capsolver task: {res.text}")
        task_id = res.json().get("taskId")
        
        for _ in range(30):
            r = requests.post("https://api.capsolver.com/getTaskResult", json={"clientKey": self.capsolver_key, "taskId": task_id}, timeout=20)
            data = r.json()
            if data.get("status") == "ready": 
                return data["solution"].get("gRecaptchaResponse") or data["solution"].get("token")
            time.sleep(3)
        raise Exception("Capsolver task timeout")

    def register(self):
        email = self.account_detail.get('email')
        password = self.account_detail.get('pwd')
        self._log(f"开始执行自动注册: {email}")

        btn_selector = '#submit'
        if not self.page.wait.ele_displayed(btn_selector, timeout=3):
            register_btn = self.page.ele("tag:a@@href:registration")
            if register_btn: self.mouse.human_click_ele(register_btn)
            time.sleep(3)
        if not self.page.wait.ele_displayed(btn_selector, timeout=10):
            raise BizLogicError(message=f"Can't find selector={btn_selector}")
            
        time.sleep(random.uniform(0.5, 1))
        self._log("正在填写邮箱和密码...")
        self.mouse.human_click_ele(self.page.ele('#email'))
        self.keyboard.type_text(email, humanize=True)
        time.sleep(random.uniform(0.2, 0.5))
        
        self.mouse.human_click_ele(self.page.ele('#password'))
        self.keyboard.type_text(password, humanize=True)
        time.sleep(random.uniform(0.2, 0.5))
        
        self.mouse.human_click_ele(self.page.ele('#confirm-password'))
        self.keyboard.type_text(password, humanize=True)
        time.sleep(random.uniform(0.2, 0.5))

        self._log("正在勾选必选条款...")
        for checkbox_id in ['#terms-and-conditions', '#biometric-data', '#privacy-notice']:
            self.mouse.human_click_ele(self.page.ele(checkbox_id).next())
            time.sleep(random.uniform(0.3, 0.6))
                
        self._log("提交注册...")
        time.sleep(random.uniform(0.3, 0.6))
        self.mouse.human_click_ele(self.page.ele(btn_selector))

        self._log("正在等待验证结果 (最多15秒)...")
        success_dialog = self.page.wait.ele_displayed('tag:h1@text():Check your email inbox', timeout=15)
        if not success_dialog:
            self.save_screenshot("failed_submit.png") 
            raise BizLogicError(message='Failed to submit account registration')     
        self._log("✅ 操作成功！已弹出提示：Check your email inbox")
        return True
    
    def activate(self, sent_at=None):
        email = self.account_detail.get('email')
        if not sent_at:
            sent_at = datetime.utcnow().strftime("%Y-%m-%d %H:%M:%S")
        
        self._log("获取激活邮件...")
        content_out = VSCloudApi.Instance().fetch_mail_content(
            email='hujiarui8@gmail.com', sender='TLSContact', recipient=email,
            subject_keywords='TLSContact', body_keywords='', sent_date=sent_at, expiry=600
        )
        match = re.search(r'https://\S+', content_out)
        activate_link = match.group(0) if match else None
        if not activate_link:
            raise Exception("未找到激活链接")
            
        self.page.get(activate_link)
        btn_selector = "#activation-pending-button"
        if not self.page.wait.ele_displayed(btn_selector, timeout=10):
            raise BizLogicError(message=f"Wait ele={btn_selector} timeout")
        self.page.ele(btn_selector).click()
        time.sleep(3)
        self._log("✅ 激活成功！")
    
    def make_account_useful(self):
        def fill_date_field(page, selector, date_str):
            if not date_str:
                return
            ele = page.ele(selector)
            ele.scroll.to_see(center=True)
            js_detect_format = """
                const parts = new Intl.DateTimeFormat().formatToParts(new Date(2023, 11, 31));
                let format = [];
                for (let part of parts) {
                    if (part.type === 'year') format.push('Y');
                    if (part.type === 'month') format.push('M');
                    if (part.type === 'day') format.push('D');
                }
                return format;
            """
            date_format = page.run_js(js_detect_format)
            year, month, day = date_str.split('-')
            date_dict = {'Y': year, 'M': month.zfill(2), 'D': day.zfill(2)}
            ele.click()
            time.sleep(0.1)
            page.actions.type(Keys.LEFT * 3)
            time.sleep(0.1)
            for i, char in enumerate(date_format):
                val = date_dict[char]
                page.actions.type(val)
                time.sleep(0.1)
                if char == 'Y':
                    if i < 2:
                        page.actions.type(Keys.RIGHT)
                        time.sleep(0.1)

        # email = self.account_detail.get('email')
        # password = self.account_detail.get('pwd')
        # location = self.account_detail.get('location')
        
        # self._log("=== 开始执行自动填表流程 ===")
        # btn_selector = 'tag:button@@text():Login'
        # if not self.page.wait.ele_displayed(btn_selector, timeout=3):
        #     login_btn = self.page.ele("tag:a@@href:login")
        #     if login_btn: self.mouse.human_click_ele(login_btn)
        #     time.sleep(3)
        # if not self.page.wait.ele_displayed(btn_selector, timeout=10):
        #     raise BizLogicError(message=f"Can't find selector={btn_selector}")
            
        # recpatchav2_token = ""
        # if self.page.ele('.g-recaptcha') or self.page.ele('xpath://iframe[contains(@src, "recaptcha")]'):
        #     self._log("Solving ReCaptcha...")
        #     recpatchav2_token = self.solve_captcha(self.page.url, "ReCaptchaV2TaskProxyLess", "6LcDpXcfAAAAAM7wOEsF_38DNsL20tTvPTKxpyn0")
        
        # input_ele = self.page.ele('tag:label@@text():Email').next()
        # self.mouse.human_click_ele(input_ele)
        # time.sleep(random.uniform(0.2, 0.6))
        # self.keyboard.type_text(email, humanize=True)
        # time.sleep(random.uniform(0.5, 1.2)) 
    
        # input_ele = self.page.ele('tag:label@@text():Password').next()
        # self.mouse.human_click_ele(input_ele)
        # time.sleep(random.uniform(0.2, 0.6))
        # self.keyboard.type_text(password, humanize=True)
        
        # if recpatchav2_token:
        #     inject_recpatchav2_token_js = f"""
        #     var g = document.getElementById('g-recaptcha-response');
        #     if(g) {{ g.value = "{recpatchav2_token}"; }}
        #     """
        #     self._log("Inject ReCaptchaV2 Token via JS...")
        #     self.page.run_js(inject_recpatchav2_token_js)
        #     time.sleep(random.uniform(0.5, 1.0))
        
        # self._log("Submitting Login...")
        # time.sleep(random.uniform(0.3, 0.8))
        # login_btn = self.page.ele('tag:button@@text():Login')
        # self.mouse.human_click_ele(login_btn)

        # self._log("Waiting for dashboard redirect...")
        # self.page.wait.url_change('login-actions', exclude=True, timeout=45)
        # time.sleep(4)

        # if "login-actions" in self.page.url or "auth" in self.page.url:
        #     raise BizLogicError(message="Login Failed! Invalid credentials or Captcha rejected.")

        # self._log("Waiting for dashboard...")
        # self.page.wait.load_start()
        # time.sleep(5)

        # self._log("Parsing Dashboard for Travel Group...")
        # html = self.page.html
        # js_pattern = r'\\"travelGroups\\":\s*(\[.*?\]),\\"availableCountriesToCreateGroups'
        # js_match = re.search(js_pattern, html, re.DOTALL)
        
        # groups = []
        # if js_match:
        #     json_str = js_match.group(1).replace(r'\"', '"')
        #     groups = json.loads(json_str)

        # travel_group = None
        # for g in groups:
        #     if location in g.get('vacName', ''):
        #         travel_group = g
        #         break
        
        # if not travel_group:
        #     raise BizLogicError(message=f"Travel Group not found for {location}")
        
        # formgroup_id = travel_group.get('formGroupId')
        # self._log(f"Waiting for group button to render: {formgroup_id}")
        # btn_selector = f'tag:a@@data-testid=btn-select-group'            
        # self._log(f"Select group_id={formgroup_id}...")
        # self.mouse.human_click_ele(self.page.ele(btn_selector))
        
        # self._log("Waiting for url redirect...")
        # self.page.wait.url_change('travel-groups', exclude=True, timeout=45)
        # time.sleep(2)

        # if "travel-groups" in self.page.url or "auth" in self.page.url:
        #     raise BizLogicError(message="Redirect to service-level Failed!")
        
        # btn_selector_add = 'tag:button@@data-testid=btn-add-applicant'
        # btn_selector_max = 'tag:button@@data-testid=btn-max-number-of-applicants'
        # error_selector = 'tag:h2@text():Something went wrong'

        # for attempt in range(2):
        #     try:
        #         btn_selector = btn_selector_add
        #         if not self.page.wait.ele_displayed(btn_selector, timeout=10):
        #             btn_selector = btn_selector_max
        #             if not self.page.ele(btn_selector):
        #                 raise BizLogicError(message=f"Can't find selector={btn_selector}")

        #         add_btn = self.page.ele(btn_selector)
        #         add_btn.scroll.to_see(center=True)
        #         time.sleep(random.uniform(0.6, 0.8))
        #         add_btn.click()

        #         if self.page.wait.ele_displayed(error_selector, timeout=5):
        #             raise BizLogicError("Page shows 'Something went wrong'")
        #         break
        #     except Exception as e:
        #         if attempt == 0:
        #             self.page.refresh()
        #             time.sleep(5)
        #         else:
        #             raise BizLogicError(message=f"Click add applicant failed after retry: {e}")
        
        self._log("开始填充表单字段...")
        visa_type = self.account_detail.get("visa_type")
        if visa_type:
            btn = self.page.ele('tag:button@@data-testid=input-visa-type')
            btn.scroll.to_see(center=True)
            btn.click()
            time.sleep(0.5)
            self.page.ele(f'tag:span@@text():{visa_type}').click(by_js=True)
            time.sleep(0.5)

        tavel_purpose = self.account_detail.get("travel_purpose")
        if tavel_purpose:
            btn = self.page.ele('tag:button@@data-testid=input-travel-purpose')
            btn.scroll.to_see(center=True)
            btn.click()
            time.sleep(0.5)
            self.page.ele(f'tag:span@@text():{tavel_purpose}').click(by_js=True)
            time.sleep(0.5)

        application_form_id = self.account_detail.get('application_form_id')
        if application_form_id:
            ele = self.page.ele('tag:input@@data-testid=f_cai')
            ele.scroll.to_see(center=True)
            ele.input(application_form_id)

        last_name = self.account_detail.get('last_name')
        if last_name:
            ele = self.page.ele('tag:input@@data-testid=f_pers_surnames')
            ele.scroll.to_see(center=True)
            ele.input(last_name.upper())

        first_name = self.account_detail.get('first_name')
        if first_name:
            ele = self.page.ele('tag:input@@data-testid=f_pers_givennames')
            ele.scroll.to_see(center=True)
            ele.input(first_name.upper())

        gender = self.account_detail.get('gender')
        if gender:
            try:
                gender = gender.capitalize()
                ele = self.page.ele(f'tag:label@@text():{gender}')
                ele.scroll.to_see(center=True)
                ele.click()
            except Exception as e:
                self._log(e)
            
        fill_date_field(self.page, 'tag:input@@data-testid=f_pers_birth_date', self.account_detail.get('birthday'))

        nationality = self.account_detail.get('nationality')
        if nationality:
            nationality = nationality.title()
            btn = self.page.ele('tag:label@@for=f_pers_nationality').next()
            btn.scroll.to_see(center=True)
            btn.click()
            time.sleep(0.5)
            self.page.ele(f'tag:li@@role=option@@text():{nationality}').click(by_js=True)
            time.sleep(0.5)
            
        province_residence = self.account_detail.get('province_residence')
        if province_residence:
            try:
                province_residence = province_residence.title()
                btn = self.page.ele('tag:label@@for=f_pers_province').next()
                btn.scroll.to_see(center=True)
                btn.click()
                time.sleep(0.5)
                self.page.ele(f'tag:li@@role=option@@text():{province_residence}').click(by_js=True)
                time.sleep(0.5)
            except Exception as e:
                self._log(e)

        passport_type = self.account_detail.get('passport_type')
        if passport_type:
            btn = self.page.ele('tag:label@@for=f_identity_type').next()
            btn.scroll.to_see(center=True)
            btn.click()
            time.sleep(0.5)
            self.page.ele(f'tag:li@@role=option@@text():{passport_type}').click(by_js=True)
            time.sleep(0.5)
            
        passport_no = self.account_detail.get('passport_no')
        if passport_no:
            ele = self.page.ele('tag:input@@data-testid=f_pass_num')
            ele.scroll.to_see(center=True)
            ele.input(passport_no.upper())
            
        passport_issue_date = self.account_detail.get('passport_issue_date')
        if passport_issue_date:
            try:
                fill_date_field(self.page, 'tag:input@@data-testid=fi_passport_issue_date', passport_issue_date)
                time.sleep(0.5)
            except Exception as e:
                self._log(e)
                
        passport_expiry_date = self.account_detail.get('passport_expiry_date')
        if passport_expiry_date:
            try:
                fill_date_field(self.page, 'tag:input@@data-testid=fi_passport_expiry_date', passport_expiry_date)
                time.sleep(0.5)
            except Exception as e:
                self._log(e)
            
        phone_country_code = self.account_detail.get('phone_country_code')
        phone_number = self.account_detail.get('phone_number')
        if phone_country_code:
            div = self.page.ele('tag:label@@for=f_pers_mobile_phone').next()
            btn = div.ele('tag:button')
            btn.scroll.to_see(center=True)
            btn.click()
            time.sleep(0.5)
            self.page.ele(f'tag:li@@role=option@@text():+{phone_country_code}').click(by_js=True)
            time.sleep(0.5)
            div.ele('tag:input@@type:tel').input(phone_number)

        fill_date_field(self.page, 'tag:input@@data-testid=fi_trav_origin_departure_date', self.account_detail.get('departure_origin_date'))
        fill_date_field(self.page, 'tag:input@@data-testid=f_trav_departure_date', self.account_detail.get('arrival_schengen_area_date'))
        fill_date_field(self.page, 'tag:input@@data-testid=f_trav_arrival_date', self.account_detail.get('departure_schengen_area_date'))
            
        submit_btn = self.page.ele('tag:button@@data-testid=btn-submit')
        submit_btn.scroll.to_see(center=True)
        time.sleep(1)
        submit_btn.click()
        time.sleep(6)
        
        confirm_btn = self.page.ele('tag:button@@text():Confirm')
        if confirm_btn:
            confirm_btn.scroll.to_see(center=True)
            confirm_btn.click()
            time.sleep(6)
        self._log("✅ 自动填表提交成功！")
        
    def upload_account_to_server(self):
        api_url = 'https://api.text.skin/api/account/add'
        api_token = 'tok_e946329a60ff45ba807f3f41b0e8b7fc'

        headers = {
            'accept': 'application/json',
            'Authorization': f'Bearer {api_token}',
            'Content-Type': 'application/json'
        }

        payload = {
            "pool_name": self.account_detail.get("pool_name", "default_pool"),
            "username": self.account_detail.get("email"),
            "password": self.account_detail.get("pwd"),
            "extra_data": self.account_detail
        }

        try:
            self._log(f"Uploading account {self.account_detail['email']} to server...")
            resp = requests.post(api_url, json=payload, headers=headers, timeout=10)
            if resp.status_code == 200:
                self._log(f"✅ [API Upload Success] Server responded: {resp.text}")
                return True
            else:
                self._log(f"❌ [API Upload Failed] Status: {resp.status_code}, Body: {resp.text}")
                return False
        except Exception as e:
            self._log(f"❌ [API Upload Error]: {e}")
            return False

    def cleanup(self):
        self._log("Cleaning up resources...")
        if self.page:
            try: self.page.quit()
            except: pass

# ================= PyQt5 GUI 主窗口 =================
class MainWindow(QMainWindow):
    def __init__(self):
        super().__init__()
        self.setWindowTitle("TLS 批量注册工具 v1.0 (PyQt5)")
        self.resize(1000, 700)

        self.bot = None
        self.profiles = []
        self.capsolver_key = os.getenv("CAPSOLVER_KEY", "CAP-5441DD341DD3CC2FAEF0BE6FE493EE9A")

        # 实例化信号类并绑定槽函数
        self.signals = GuiSignals()
        self.signals.log_signal.connect(self.append_log)
        self.signals.status_signal.connect(self.update_table_status)

        self.init_ui()

    def init_ui(self):
        main_widget = QWidget()
        main_layout = QVBoxLayout(main_widget)

        # 1. 基础设置区域
        group_settings = QGroupBox("1. 基础设置")
        layout_settings = QGridLayout()
        
        layout_settings.addWidget(QLabel("地区 (如 CN-Beijing):"), 0, 0)
        self.input_region = QLineEdit("CN-Beijing")
        layout_settings.addWidget(self.input_region, 0, 1)

        layout_settings.addWidget(QLabel("代理池名 (从proxies.json读取):"), 0, 2)
        self.input_pool = QLineEdit("local")
        layout_settings.addWidget(self.input_pool, 0, 3)

        layout_settings.addWidget(QLabel("目标 URL:"), 1, 0)
        self.input_url = QLineEdit("https://visas-fr.tlscontact.com/en-us/country/gb/vac/gbLON2fr")
        layout_settings.addWidget(self.input_url, 1, 1, 1, 3)

        group_settings.setLayout(layout_settings)
        main_layout.addWidget(group_settings)

        # 2. 生成区域
        group_gen = QGroupBox("2. 生成虚拟信息")
        layout_gen = QHBoxLayout()
        layout_gen.addWidget(QLabel("生成数量 (1-100):"))
        self.spin_count = QSpinBox()
        self.spin_count.setRange(1, 100)
        self.spin_count.setValue(5)
        layout_gen.addWidget(self.spin_count)

        self.btn_generate = QPushButton("生成虚拟信息")
        self.btn_generate.setStyleSheet("background-color: lightblue;")
        self.btn_generate.clicked.connect(self.action_generate)
        layout_gen.addWidget(self.btn_generate)
        layout_gen.addStretch()

        group_gen.setLayout(layout_gen)
        main_layout.addWidget(group_gen)

        # 3. 表格展示区域
        self.table = QTableWidget()
        self.table.setColumnCount(5)
        self.table.setHorizontalHeaderLabels(["序号", "邮箱", "密码", "姓名", "当前状态"])
        self.table.horizontalHeader().setSectionResizeMode(QHeaderView.Stretch)
        self.table.setSelectionBehavior(QAbstractItemView.SelectRows)
        self.table.setEditTriggers(QAbstractItemView.NoEditTriggers)
        main_layout.addWidget(self.table)

        # 4. 浏览器操作区域
        group_actions = QGroupBox("3. 浏览器操作 (需先在表格中点击选中一行)")
        layout_actions = QHBoxLayout()

        self.btn_start = QPushButton("[全局] 启动浏览器")
        self.btn_start.clicked.connect(self.action_start_browser)
        layout_actions.addWidget(self.btn_start)

        self.btn_register = QPushButton("1. 自动注册并激活")
        self.btn_register.setStyleSheet("background-color: #d0f0c0;")
        self.btn_register.clicked.connect(self.action_register)
        layout_actions.addWidget(self.btn_register)

        self.btn_fill = QPushButton("2. 自动填表")
        self.btn_fill.setStyleSheet("background-color: #ffd700;")
        self.btn_fill.clicked.connect(self.action_fill)
        layout_actions.addWidget(self.btn_fill)

        self.btn_upload = QPushButton("3. 上报并标记已用")
        self.btn_upload.setStyleSheet("background-color: #ffb6c1;")
        self.btn_upload.clicked.connect(self.action_upload)
        layout_actions.addWidget(self.btn_upload)

        self.btn_close = QPushButton("[全局] 关闭浏览器")
        self.btn_close.setStyleSheet("color: red;")
        self.btn_close.clicked.connect(self.action_close_browser)
        layout_actions.addWidget(self.btn_close)

        group_actions.setLayout(layout_actions)
        main_layout.addWidget(group_actions)

        # 5. 日志区域
        group_log = QGroupBox("运行日志")
        layout_log = QVBoxLayout()
        self.text_log = QTextEdit()
        self.text_log.setReadOnly(True)
        layout_log.addWidget(self.text_log)
        group_log.setLayout(layout_log)
        main_layout.addWidget(group_log)

        self.setCentralWidget(main_widget)

    # ---------------- 槽函数：UI 更新 ----------------
    def append_log(self, text):
        self.text_log.append(text)
        self.text_log.moveCursor(self.text_log.textCursor().End)

    def update_table_status(self, row, status):
        item = QTableWidgetItem(status)
        item.setTextAlignment(Qt.AlignCenter)
        self.table.setItem(row, 4, item)

    # ---------------- 业务逻辑触发 ----------------
    def run_in_thread(self, target_func, *args):
        t = threading.Thread(target=target_func, args=args, daemon=True)
        t.start()

    def action_generate(self):
        count = self.spin_count.value()
        region = self.input_region.text().strip()
        pool = self.input_pool.text().strip()

        self.append_log(f"开始生成 {count} 个 {region} 地区的虚拟信息...")
        self.profiles.clear()
        self.table.setRowCount(0)

        for i in range(count):
            try:
                acc = generate_random_account_detail(region)
                acc['pool_name'] = pool
                self.profiles.append(acc)

                self.table.insertRow(i)
                self.table.setItem(i, 0, QTableWidgetItem(str(i+1)))
                self.table.setItem(i, 1, QTableWidgetItem(acc.get('email', '')))
                self.table.setItem(i, 2, QTableWidgetItem(acc.get('pwd', '')))
                
                name = f"{acc.get('first_name','')} {acc.get('last_name','')}"
                self.table.setItem(i, 3, QTableWidgetItem(name))
                
                self.update_table_status(i, "就绪")
            except Exception as e:
                self.append_log(f"生成时出错: {e}")
        
        self.append_log("✅ 虚拟信息生成完毕！")

    def action_start_browser(self):
        pool = self.input_pool.text().strip()
        url = self.input_url.text().strip()

        def _task():
            try:
                self.signals.log_signal.emit(f"正在读取代理池 {pool} ...")
                proxies = load_proxies(pool)
                proxy = random.choice(proxies)
                self.signals.log_signal.emit(f"已选取代理: {proxy.get('ip')}")

                self.bot = TlsRegistrator(
                    tls_url=url, 
                    proxy_config=proxy, 
                    capsolver_key=self.capsolver_key,
                    signals=self.signals
                )
                self.bot.init_browser()
            except Exception as e:
                self.signals.log_signal.emit(f"❌ 浏览器启动失败: {e}")

        self.run_in_thread(_task)

    def _get_selected_row(self):
        row = self.table.currentRow()
        if row < 0:
            QMessageBox.warning(self, "警告", "请先在表格中点击选中需要操作的虚拟账号！")
            return None
        return row

    def action_register(self):
        row = self._get_selected_row()
        if row is None: return
        if not self.bot:
            QMessageBox.warning(self, "警告", "请先启动浏览器！")
            return

        profile = self.profiles[row]

        def _task():
            try:
                self.bot.account_detail = profile
                self.signals.status_signal.emit(row, "注册中...")
                sent_at = datetime.utcnow().strftime("%Y-%m-%d %H:%M:%S")
                
                self.bot.register()
                self.signals.status_signal.emit(row, "激活中...")
                
                self.bot.activate(sent_at=sent_at)
                self.signals.status_signal.emit(row, "注册激活完成")
            except Exception as e:
                self.signals.log_signal.emit(f"❌ 注册过程异常: {e}")
                self.signals.status_signal.emit(row, "注册失败")

        self.run_in_thread(_task)

    def action_fill(self):
        row = self._get_selected_row()
        if row is None: return
        if not self.bot:
            QMessageBox.warning(self, "警告", "请先启动浏览器！")
            return

        profile = self.profiles[row]

        def _task():
            try:
                self.bot.account_detail = profile
                self.signals.status_signal.emit(row, "填表中...")
                
                self.bot.make_account_useful()
                
                self.signals.status_signal.emit(row, "填表完成")
            except Exception as e:
                self.signals.log_signal.emit(f"❌ 填表过程异常: {e}")
                self.signals.status_signal.emit(row, "填表失败")

        self.run_in_thread(_task)

    def action_upload(self):
        row = self._get_selected_row()
        if row is None: return
        if not self.bot: return

        profile = self.profiles[row]

        def _task():
            try:
                self.bot.account_detail = profile
                self.signals.status_signal.emit(row, "上报中...")
                
                success = self.bot.upload_account_to_server()
                if success:
                    self.signals.status_signal.emit(row, "已使用(上报成功)")
                else:
                    self.signals.status_signal.emit(row, "上报失败")
            except Exception as e:
                self.signals.log_signal.emit(f"❌ 上报异常: {e}")
                self.signals.status_signal.emit(row, "上报异常")

        self.run_in_thread(_task)

    def action_close_browser(self):
        if self.bot:
            self.bot.cleanup()
            self.bot = None
            self.append_log("✅ 浏览器已关闭。")
            
    def closeEvent(self, event):
        """主窗口关闭时，确保清理资源"""
        if self.bot:
            self.bot.cleanup()
        event.accept()

if __name__ == "__main__":
    app = QApplication(sys.argv)
    window = MainWindow()
    window.show()
    sys.exit(app.exec_())