更新 Points_Based/D_SFSY_DWHD.py

Points_Based/D_SFSY_DWHD.py

@@ -4,6 +4,7 @@ import hashlib
 import json
 import os
 import random
+import re
 import time
 from datetime import datetime
 from typing import Dict, List, Optional, Any
@@ -640,7 +641,7 @@ class DragonBoatExecutor:
 
 
 # ==================== 账号执行 ====================
-def run_account(account_url: str, index: int) -> Dict[str, Any]:
+def run_account(account_url: str, index: int, invite_pool: List[str]) -> Dict[str, Any]:
     """执行单个账号"""
     logger = Logger()
     proxy_url = os.getenv('SF_PROXY_API_URL', '')
@@ -732,13 +733,13 @@ def main():
             print(f"\n{'='*60}")
             print(f"开始处理第 {idx+1}/{len(account_urls)} 个账号")
             print("="*60)
-            result = run_account(url, idx)
+            result = run_account(url, idx, invite_pool)
             all_results.append(result)
             if idx < len(account_urls) - 1:
                 time.sleep(2)
     else:
         with ThreadPoolExecutor(max_workers=CONCURRENT_NUM) as pool:
-            futures = {pool.submit(run_account, url, idx): idx for idx, url in enumerate(account_urls)}
+            futures = {pool.submit(run_account, url, idx, invite_pool): idx for idx, url in enumerate(account_urls)}
             for future in as_completed(futures):
                 all_results.append(future.result())