diff --git a/快手极速版200/快手极速版_ENC.py b/快手极速版200/快手极速版_ENC.py new file mode 100644 index 0000000..23bbfd2 --- /dev/null +++ b/快手极速版200/快手极速版_ENC.py @@ -0,0 +1,245 @@ + +# 入口: 快手极速版App 一机一号一个实名 只限安卓机器 （无需root） 最好一号一ip +# 需抓取数据: +# * 开抓包点福利后 搜索 earn/overview/tasks 找到此请求的cookie 同时找到此请求下的请求头的user-agent的值 +# * 登录时搜索 api_client_salt 找到5kb左右的链接 在响应里最下面找到你的salt +# * 如果一个青龙跑两号及以上 则就需要填写socket5代理防止黑ip,注意一号一代理,不允许多号共用 第一个号不使用代理则不填 @代理ip|端口|代理用户名|代理密码 +# * 变量: LinDong_ksjsb 填写上面获取的数据 格式为 备注@cookie@salt@user-agent [@代理ip|端口|代理用户名|代理密码](可选) 多号换行或新建同名变量 +# * 变量: lindong_ksCard 卡密变量 关注公众号 +# * 可选变量(可不填): lindong_ks_thread 最大线程数 默认 1 +# * 可选变量(可不填): lindong_ks_maxgold 最大金币数 默认 50w (跑多了第二天可能1金币 有此需求请勿兑换金币) +# * 可选变量(可不填): lindong_ks_run_task 额外执行任务 默认 无 多个额外执行的任务用,分割 +# * 可选的是 0:签到 | 1.宝箱 | 2.宝箱广告(需要运行宝箱广告必须开宝箱) | 3.饭补广告 +# * 可选变量(可不填): lindong_ks_skipTaskAd 是否跳过任务广告 默认否 填1跳过 +# * 需要安装依赖: py的 requests[socks] +# * 多号方式 [ 换行 | 新建同名变量 | & 分割 ] +# * tg群组:https://t.me/+1BVEpYhydgplYWY9 +# ======================================================================================== +import os +import sys +import platform +import subprocess +import importlib +import json +import logging +import glob +try: + import requests +except ImportError: + print("请安装依赖: pip install requests") + sys.exit(1) + + +MODULE_NAME = 'ksjsb' +API_BASE_URL = 'http://pyenc.lindong.xyz' + +MAX_RETRY = 3 +logging.basicConfig(level=logging.INFO, format='[%(levelname)s] ===> %(message)s') +log = logging.getLogger(__name__) + +class SoManager: + def __init__(self, module_name, api_base_url): + self.module_name = module_name + self.api_base_url = api_base_url.rstrip('/') + self.api_url = f"{self.api_base_url}/api.php" + self.version_file = f"{module_name}.version" + self.python_version = f"{sys.version_info.major}.{sys.version_info.minor}" + self.arch = self._get_arch() + self.platform_key = f"{self.arch}_py{self.python_version.replace('.', '')}" + + + + def _get_arch(self): + machine = platform.machine().lower() + if machine in ['x86_64', 'amd64', 'x64']: + return 'x64' + elif machine in ['aarch64', 'arm64']: + return 'aarch64' + else: + log.warning(f"未知架构 {machine}，默认使用 x64") + return 'x64' + + def _check_system_compatibility(self): + if sys.version_info.major != 3 or sys.version_info.minor not in [10, 11]: + log.error(f"不支持的Python版本 {sys.version}，请使用Python 3.10或3.11") + return False + if platform.system() != 'Linux': + log.error(f"不支持的操作系统 {platform.system()}，请使用Linux系统") + return False + log.info(f"系统检测通过 [Python {sys.version}] [{platform.system()} {platform.machine()}]") + return True + + def _get_local_version(self): + try: + if os.path.exists(self.version_file): + with open(self.version_file, 'r') as f: + return f.read().strip() + except Exception as e: + log.warning(f"读取本地版本失败: {e}") + return None + + def _save_local_version(self, version): + try: + with open(self.version_file, 'w') as f: + f.write(str(version)) + except Exception as e: + log.error(f"保存版本号失败: {e}") + + def _get_remote_latest(self): + try: + payload = { + "action": "get_latest", + "module_name": self.module_name + } + + response = requests.post( + self.api_url, + json=payload, + timeout=30, + headers={'Content-Type': 'application/json'} + ) + + if response.status_code != 200: + log.error(f"API请求失败: HTTP {response.status_code}") + return None + + data = response.json() + if not data.get('success'): + log.error(f"API返回错误: {data.get('message', '未知错误')}") + return None + + return data + + except requests.exceptions.RequestException as e: + log.error(f"网络请求失败: {e}") + return None + except json.JSONDecodeError as e: + log.error(f"JSON解析失败: {e}") + return None + except Exception as e: + log.error(f"获取远程版本失败: {e}") + return None + + def _download_file(self, download_url): + """下载.so文件""" + temp_file = f"{self.so_filename}.tmp" + + for attempt in range(MAX_RETRY): + try: + log.info(f"开始下载 (尝试 {attempt + 1}/{MAX_RETRY}): {download_url}") + + response = requests.get(download_url, timeout=180, stream=True) + if response.status_code != 200: + log.error(f"下载失败: HTTP {response.status_code}") + continue + with open(temp_file, 'wb') as f: + for chunk in response.iter_content(chunk_size=8192): + if chunk: + f.write(chunk) + if os.path.getsize(temp_file) == 0: + log.error("下载的文件为空") + os.remove(temp_file) + continue + if os.path.exists(self.so_filename): + os.remove(self.so_filename) + os.rename(temp_file, self.so_filename) + + log.info(f"文件下载成功: {self.so_filename}") + return True + + except Exception as e: + log.error(f"下载失败: {e}") + if os.path.exists(temp_file): + os.remove(temp_file) + + log.error(f"下载失败，已尝试 {MAX_RETRY} 次") + return False + + def _execute_module(self): + """执行模块""" + try: + if not os.path.exists(self.so_filename): + log.error(f".so文件不存在: {self.so_filename}") + return False + + print('=' * 50) + module_obj = importlib.import_module(self.so_moudel) + if hasattr(module_obj, 'main'): + module_obj.main() + else: + log.warning("模块中没有找到main函数") + + return True + + except ImportError as e: + log.error(f"模块导入失败: {e}") + return False + except AttributeError as e: + log.error(f"模块执行失败: {e}") + return False + except Exception as e: + log.error(f"执行异常: {e}") + return False + + def check_and_update(self): + remote_info = self._get_remote_latest() + if not remote_info: + log.error("无法获取远程版本信息") + return False + remote_version = str(remote_info['latest_version']) + self.so_filename = f"{self.module_name}_{remote_version}.so" + self.so_moudel = f"{self.module_name}_{remote_version}" + local_version = self._get_local_version() + vlocal_version = 'v' + local_version if local_version else '无' + + log.info(f"本地版本: {vlocal_version} | 远程最新版本: v{remote_version}") + need_download = False + if not os.path.exists(self.so_filename): + log.info("本地文件不存在，需要下载") + need_download = True + elif local_version != remote_version: + log.info("版本不一致，需要更新") + need_download = True + else: + log.info("版本已是最新，无需下载") + + if need_download: + files = remote_info.get('files', {}) + download_url = files.get(self.platform_key) + + if not download_url: + log.error(f"没有找到适合平台 {self.platform_key} 的下载链接") + available_platforms = list(files.keys()) + log.error(f"可用平台: {available_platforms}") + return False + + if self._download_file(download_url): + self._save_local_version(remote_version) + else: + log.error("文件下载失败") + return False + + return True + + def run(self): + if not self._check_system_compatibility(): + return False + if not self.check_and_update(): + return False + return self._execute_module() + +def main(): + try: + manager = SoManager(MODULE_NAME, API_BASE_URL) + manager.run() + + + except KeyboardInterrupt: + log.info("用户中断执行") + sys.exit(1) + except Exception as e: + log.error(f"未知错误: {e}") + sys.exit(1) + +if __name__ == '__main__': + main() \ No newline at end of file