From bc4466854003e64a6789b13e2801bf310f67bd16 Mon Sep 17 00:00:00 2001 From: haosicheng Date: Wed, 24 Sep 2025 14:46:33 +0800 Subject: [PATCH 1/2] =?UTF-8?q?Todo:=20=E9=9B=86=E6=88=90=E5=A4=9A?= =?UTF-8?q?=E5=B9=B3=E5=8F=B0=20=E8=A7=A3=E5=86=B3PDD=E6=89=93=E5=8C=85?= =?UTF-8?q?=E5=90=8Ejs=E6=96=87=E4=BB=B6=E4=BD=8D=E7=BD=AE=E6=A3=80?= =?UTF-8?q?=E7=B4=A2=E9=97=AE=E9=A2=98=20Todo:=20=E9=9B=86=E6=88=90?= =?UTF-8?q?=E5=A4=9A=E5=B9=B3=E5=8F=B0=20=E8=A7=A3=E5=86=B3=E6=89=93?= =?UTF-8?q?=E5=8C=85=E6=97=A5=E5=BF=97=E8=A7=84=E5=88=92=E9=97=AE=E9=A2=98?= =?UTF-8?q?=20Todo:=20=E9=9B=86=E6=88=90=E5=A4=9A=E5=B9=B3=E5=8F=B0=20?= =?UTF-8?q?=E8=A7=A3=E5=86=B3=E5=90=8E=E7=AB=AF=E8=BF=9E=E6=8E=A5=E5=BF=83?= =?UTF-8?q?=E8=B7=B3=E4=B8=8E=E9=87=8D=E8=BF=9E=E7=AE=A1=E7=90=86=E9=97=AE?= =?UTF-8?q?=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- config.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/config.py b/config.py index 6a88fb5..e09c105 100644 --- a/config.py +++ b/config.py @@ -10,8 +10,8 @@ import json # 用于将令牌保存为 JSON 格式 # 后端服务器配置 # BACKEND_HOST = "192.168.5.233" # BACKEND_HOST = "192.168.5.12" -BACKEND_HOST = "shuidrop.com" -# BACKEND_HOST = "test.shuidrop.com" +# BACKEND_HOST = "shuidrop.com" +BACKEND_HOST = "test.shuidrop.com" # BACKEND_PORT = "8000" BACKEND_PORT = "" # BACKEND_WS_URL = f"ws://{BACKEND_HOST}:{BACKEND_PORT}" From 1a03610e9109f0e5d9c69d263b0d388762156e7a Mon Sep 17 00:00:00 2001 From: haosicheng Date: Thu, 25 Sep 2025 17:42:21 +0800 Subject: [PATCH 2/2] =?UTF-8?q?Todo:=20=E6=95=B4=E4=BD=93=E6=95=B4?= =?UTF-8?q?=E4=BD=93=E9=80=BB=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- Utils/Pdd/PddUtils.py | 135 ++++++++++++++++++++++++++++-------------- config.py | 12 ++-- 2 files changed, 96 insertions(+), 51 deletions(-) diff --git a/Utils/Pdd/PddUtils.py b/Utils/Pdd/PddUtils.py index aedbc73..81d0105 100644 --- a/Utils/Pdd/PddUtils.py +++ b/Utils/Pdd/PddUtils.py @@ -40,7 +40,7 @@ from Utils.message_models import PlatformMessage class Track: """滑块轨迹生成类""" - + @staticmethod def get_track(distance): distance = int(distance) + random.randint(7, 11) + 0.8 @@ -853,7 +853,7 @@ class Track: class ImgDistance: """滑块图像识别距离计算类""" - + def __init__(self, bg, tp): self.bg = bg self.tp = tp @@ -999,8 +999,7 @@ class ImgDistance: save_path=save_path ) - -# AutiContent类已移除 - 后端会提供所有必要的anti_content + # AutiContent类已移除 - 后端会提供所有必要的anti_content def gzip_compress(self, data): """压缩数据""" @@ -1011,7 +1010,7 @@ class ImgDistance: return result except Exception as e: logger.error(f"调用gzipCompress函数失败: {e}") - + # fallback处理：简单返回原数据 logger.warning("使用fallback处理，返回原数据") return data @@ -1019,7 +1018,7 @@ class ImgDistance: class EncryptTool: """加密工具类""" - + @staticmethod def aes_encrypt(text, key, iv): cipher = AES.new(key.encode('utf-8'), AES.MODE_CBC, iv.encode('utf-8')) @@ -1059,7 +1058,7 @@ class EncryptTool: class PddLogin: """拼多多登录核心类""" - + def __init__(self, log_callback=None): super().__init__() self.login_api = "https://mms.pinduoduo.com/janus/api/auth" @@ -1605,14 +1604,14 @@ class PddLogin: return result # 发送验证码通知给后端，并获取验证码 - def request_verification_code(self, username, store_id, backend_anti_content): + def request_verification_code(self, username, store_id, backend_anti_content, phone_number=None): """向后端请求获取手机验证码""" - self._log(f"开始请求验证码，用户名: {username}, 店铺ID: {store_id}", "INFO") - + self._log(f"开始请求验证码，用户名: {username}, 店铺ID: {store_id}, 手机号: {phone_number}", "INFO") + # 使用后端下发的anti_content anti_content = backend_anti_content self._log(f"使用后端下发的anti_content", "DEBUG") - + self.headers["anti-content"] = anti_content url = "https://mms.pinduoduo.com/janus/api/user/getLoginVerificationCode" payload = { @@ -1621,33 +1620,34 @@ class PddLogin: } response = requests.post(url, headers=self.headers, json=payload, cookies=self.cookies) self._log(f"发送验证码请求结果: {response.text}") - - # 发送消息给后端，告知需要验证码 + + # 发送消息给后端，告知需要验证码（包含手机号） self._log("准备向后端发送验证码需求通知", "INFO") - self._send_verification_needed_message(store_id) - + self._send_verification_needed_message(store_id, phone_number) # 🔥 传递手机号 + # 这里需要等待后端重新下发包含验证码的登录参数 # 实际实现中这个方法会在接收到新的登录参数后被重新调用 return None - def _send_verification_needed_message(self, store_id): + def _send_verification_needed_message(self, store_id, phone_number=None): """向后端发送需要验证码的通知""" try: - self._log(f"开始发送验证码需求通知，店铺ID: {store_id}", "INFO") + self._log(f"开始发送验证码需求通知，店铺ID: {store_id}, 手机号: {phone_number}", "INFO") from WebSocket.backend_singleton import get_backend_client backend = get_backend_client() self._log(f"获取到后端客户端: {backend is not None}", "DEBUG") - + if backend: message = { "type": "connect_message", "store_id": store_id, "status": False, - "content": "需要验证码" + "content": "需要验证码", + "phone_number": phone_number # 🔥 新增手机号字段 } self._log(f"准备发送验证码通知消息: {message}", "DEBUG") backend.send_message(message) - self._log("✅ 成功向后端发送验证码需求通知", "SUCCESS") + self._log("✅ 成功向后端发送验证码需求通知（含手机号）", "SUCCESS") else: self._log("❌ 后端客户端为空，无法发送验证码需求通知", "ERROR") except Exception as e: @@ -1661,7 +1661,7 @@ class PddLogin: self._log(f"开始发送验证码错误通知，店铺ID: {store_id}, 错误: {error_msg}", "INFO") from WebSocket.backend_singleton import get_backend_client backend = get_backend_client() - + if backend: message = { "type": "connect_message", @@ -1685,7 +1685,7 @@ class PddLogin: self._log(f"开始发送登录成功通知，店铺ID: {store_id}", "INFO") from WebSocket.backend_singleton import get_backend_client backend = get_backend_client() - + if backend: message = { "type": "connect_message", @@ -1708,7 +1708,7 @@ class PddLogin: self._log(f"开始发送登录失败通知，店铺ID: {store_id}, 错误: {error_msg}", "INFO") from WebSocket.backend_singleton import get_backend_client backend = get_backend_client() - + if backend: message = { "type": "connect_message", @@ -1731,10 +1731,12 @@ class PddLogin: self._log("🚀 [PddLogin] 开始使用参数登录", "INFO") # 检查验证码字段（兼容 code 和 verification_code） verification_code = login_params.get("verification_code") or login_params.get("code", "") - self._log(f"📋 [PddLogin] 登录参数: username={login_params.get('username', 'N/A')}, 包含验证码={bool(verification_code)}", "DEBUG") - + self._log( + f"📋 [PddLogin] 登录参数: username={login_params.get('username', 'N/A')}, 包含验证码={bool(verification_code)}", + "DEBUG") + self.headers["anti-content"] = login_params.get("anti_content", "") - + # 直接使用后端提供的参数构建登录请求 ts = login_params.get("timestamp", int(round(time.time() * 1000))) payload = { @@ -1800,12 +1802,36 @@ class PddLogin: self._log(f"🔍 [Debug] 登录请求URL: {self.login_api}", "DEBUG") self._log(f"🔍 [Debug] 登录请求payload: {payload}", "DEBUG") self._log(f"🔍 [Debug] 登录请求headers: {dict(self.headers)}", "DEBUG") - + response = requests.post(self.login_api, headers=self.headers, json=payload, cookies=self.cookies) self.cookies.update(response.cookies.get_dict()) + + # 🔥 增强日志输出 - 打印完整响应信息 self._log(f"登录响应状态码: {response.status_code}") - self._log(f"登录响应内容: {response.text}") - + self._log(f"登录响应Headers: {dict(response.headers)}") + self._log(f"登录完整响应内容: {response.text}") + + # 🔥 尝试解析JSON响应获取更多信息 + response_json = None # 🔥 在外部定义变量 + try: + response_json = response.json() + self._log(f"登录响应JSON结构: {json.dumps(response_json, ensure_ascii=False, indent=2)}") + + # 特别关注result字段中可能包含的手机号信息 + if "result" in response_json: + result_data = response_json["result"] + self._log(f"响应result字段详情: {json.dumps(result_data, ensure_ascii=False, indent=2)}") + + # 查找可能的手机号字段 + possible_phone_fields = ["phone", "mobile", "phoneNumber", "mobileNumber", "telephone", "tel", + "cellphone", "handphone"] + for field in possible_phone_fields: + if field in result_data: + self._log(f"🔍 发现可能的手机号字段 {field}: {result_data[field]}") + + except Exception as e: + self._log(f"解析响应JSON失败: {e}", "DEBUG") + # 检查响应内容 if "需要手机验证" in response.text: self._log("✅ 检测到需要手机验证的响应", "INFO") @@ -1819,7 +1845,8 @@ class PddLogin: salt = self.vc_pre_ck_b() # 获取生成aes key和iv 的密文值 pictures = self.obtain_captcha() # 获取验证码图片 - distance = round((ImgDistance(bg=pictures[0], tp=pictures[1]).main() * (272 / 320)) + (48.75 / 2), 2) # 计算距离 + distance = round((ImgDistance(bg=pictures[0], tp=pictures[1]).main() * (272 / 320)) + (48.75 / 2), + 2) # 计算距离 track_list = Track.get_track(distance=distance) # 生成轨迹 captcha_collect = self.captcha_collect(salt=salt, track_list=track_list) # 生成captcha_collect参数 @@ -1833,7 +1860,8 @@ class PddLogin: success_count += 1 # 如果滑块成功 success_count 计数一次 成功8次还是显示验证码则失败 返回False if success_count < 8: - return self.login_with_params(login_params=login_params, store_id=store_id, success_count=success_count) + return self.login_with_params(login_params=login_params, store_id=store_id, + success_count=success_count) else: return False else: @@ -1853,7 +1881,7 @@ class PddLogin: response_data = response.json() error_msg = response_data.get('errorMsg', '验证码验证失败') self._log(f"服务器返回错误: {error_msg}", "WARNING") - + # 不要重新发送验证码请求，直接报告验证失败 self._send_verification_error_message(store_id, error_msg) # 直接使用官方错误信息 return "verification_code_error" # 返回特殊状态，避免重复发送消息 @@ -1863,9 +1891,27 @@ class PddLogin: username = login_params.get("username") backend_anti_content = login_params.get("anti_content") self._log(f"为用户 {username} 发送验证码，使用后端anti_content", "INFO") - - # 传递后端下发的anti_content - self.request_verification_code(username, store_id, backend_anti_content) + + # 🔥 从响应中提取手机号 + phone_number = None + try: + if response_json and isinstance(response_json, dict): + phone_number = response_json.get("result") # 手机号在result字段中 + if phone_number and isinstance(phone_number, str): + self._log(f"🔍 从登录响应中提取到手机号: {phone_number}", "SUCCESS") + else: + self._log("⚠️ 响应中的result字段不包含有效手机号", "WARNING") + self._log(f"🔍 DEBUG: response_json = {response_json}", "DEBUG") + else: + self._log("⚠️ response_json 为空或格式不正确", "WARNING") + self._log(f"🔍 DEBUG: response_json = {response_json}", "DEBUG") + except Exception as e: + self._log(f"❌ 提取手机号时出错: {e}", "DEBUG") + import traceback + self._log(f"🔍 DEBUG: 错误详情: {traceback.format_exc()}", "DEBUG") + + # 传递后端下发的anti_content和手机号 + self.request_verification_code(username, store_id, backend_anti_content, phone_number) # 🔥 传递手机号 return "need_verification_code" else: @@ -1883,6 +1929,7 @@ class PddLogin: self._send_login_failure_message(store_id, error_msg) return "login_failure" # 返回特殊状态，避免重复发送消息 + # ===== 登录相关类集成结束 ===== @@ -1970,13 +2017,13 @@ class ChatPdd: raise FileNotFoundError(f"找不到必需的JS文件: {file_path}") return True - + @staticmethod def _get_resource_path(relative_path): """获取资源文件的绝对路径（兼容PyInstaller打包环境）""" try: print(f"[DEBUG] 正在解析资源路径: {relative_path}") - + # PyInstaller环境下的基础路径 if hasattr(sys, '_MEIPASS'): # PyInstaller 临时目录 @@ -1992,10 +2039,10 @@ class ChatPdd: # 向上两级目录到项目根目录 base_path = os.path.dirname(os.path.dirname(base_path)) print(f"[DEBUG] 开发环境，计算的项目根目录: {base_path}") - + resource_path = os.path.join(base_path, relative_path) print(f"[DEBUG] 拼接后的完整资源路径: {resource_path}") - + # 检查路径是否存在 if os.path.exists(resource_path): print(f"[DEBUG] ✅ 资源路径存在: {resource_path}") @@ -2012,7 +2059,7 @@ class ChatPdd: print(f"[DEBUG] 📄 {item}") except Exception as e: print(f"[DEBUG] 无法列出目录内容: {e}") - + return resource_path except Exception as e: print(f"[ERROR] 获取资源路径失败: {e}") @@ -2889,11 +2936,11 @@ class PddListenerForGUI: self._log("🔄 [PDD] 开始创建PddLogin实例", "DEBUG") pdd_login = PddLogin(log_callback=self.log_callback) self._log("✅ [PDD] PddLogin实例创建成功", "DEBUG") - + self._log("🔄 [PDD] 开始执行登录", "DEBUG") login_result = pdd_login.login_with_params(params_dict, store_id) self._log(f"📊 [PDD] 登录结果: {login_result}", "DEBUG") - + if login_result == "need_verification_code": self._log("⚠️ [PDD] 需要手机验证码，已通知后端，等待重新下发包含验证码的登录参数", "WARNING") return "need_verification_code" # 返回特殊标识，避免被覆盖 @@ -2909,7 +2956,7 @@ class PddListenerForGUI: elif isinstance(login_result, dict): # 登录成功，获取到cookies self._log("✅ [PDD] 登录成功，使用获取的cookies连接平台", "SUCCESS") - + # 将cookies字典转换为字符串格式，与原有逻辑兼容 import json cookies_str = json.dumps(login_result) @@ -3055,8 +3102,6 @@ class PddListenerForGUI: self._log(f"❌ [PDD] 解析登录参数失败: {e}", "ERROR") return {} - - def get_status(self) -> Dict[str, Any]: return { "running": self.running, diff --git a/config.py b/config.py index e09c105..2d9e57d 100644 --- a/config.py +++ b/config.py @@ -9,13 +9,13 @@ import json # 用于将令牌保存为 JSON 格式 # 后端服务器配置 # BACKEND_HOST = "192.168.5.233" -# BACKEND_HOST = "192.168.5.12" +BACKEND_HOST = "192.168.5.12" # BACKEND_HOST = "shuidrop.com" -BACKEND_HOST = "test.shuidrop.com" -# BACKEND_PORT = "8000" -BACKEND_PORT = "" -# BACKEND_WS_URL = f"ws://{BACKEND_HOST}:{BACKEND_PORT}" -BACKEND_WS_URL = f"wss://{BACKEND_HOST}" +# BACKEND_HOST = "test.shuidrop.com" +BACKEND_PORT = "8000" +# BACKEND_PORT = "" +BACKEND_WS_URL = f"ws://{BACKEND_HOST}:{BACKEND_PORT}" +# BACKEND_WS_URL = f"wss://{BACKEND_HOST}" # WebSocket配置 WS_CONNECT_TIMEOUT = 16.0