From d3cae98dfd975bf37a2945cd43f53829dac15fe1 Mon Sep 17 00:00:00 2001 From: weiqun Date: Tue, 16 Jun 2026 11:15:41 +0800 Subject: [PATCH] =?UTF-8?q?=E5=88=A0=E9=99=A4=E6=81=A9=E5=B1=B1=E7=B4=AF?= =?UTF-8?q?=E7=A7=AF=E7=A7=AF=E5=88=86,=E5=B9=B6=E6=B7=BB=E5=8A=A0?= =?UTF-8?q?=E6=90=BA=E8=B6=A3=E4=BB=A3=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- enshan_sign.py | 253 +++++++++++++++++-------------------------------- 1 file changed, 85 insertions(+), 168 deletions(-) diff --git a/enshan_sign.py b/enshan_sign.py index 4f7e49c..f8b7553 100644 --- a/enshan_sign.py +++ b/enshan_sign.py @@ -6,6 +6,7 @@ Python3 依赖: requests DrissionPage Linux 依赖: ChromiumPage ChromiumOptions +携趣代理: RS_PROXY_API (青龙面板环境变量自动注入) https://www.xiequ.cn/index.html?fb97ebf3 Cookie 登录 www.right.com.cn -> F12 -> Application -> Cookies -> 复制全部 Cookie,Uid 通过个人空间 URL 中获取,保存在 enshan_config,json 配置中 """ @@ -18,55 +19,43 @@ import requests import shutil from DrissionPage import ChromiumPage, ChromiumOptions +RS_PROXY_API = os.environ.get('RS_PROXY_API', '') + # ================= 配置区域 ================= CONFIG_FILE = "/ql/data/scripts/enshan_config.json" # ============================================ -# 青龙内置通知函数 (v3.4 修复版) +# 青龙内置通知函数 def notify(title, content): - """使用青龙2.x内置通知模块发送通知 - - 青龙2.x的通知机制：脚本最后输出的内容会被青龙捕获 - 格式要求：标题用【】包裹，内容在下方 - """ - # 青龙2.x 标准通知格式：标题【】包裹，内容换行 + """使用青龙2.x内置通知模块发送通知""" print(f"\n{'='*60}") print(f"【{title}】") print(f"{'='*60}") print(content) print(f"{'='*60}\n") - # 尝试导入青龙notify模块（青龙2.x） try: import sys ql_base = os.environ.get('QL_DIR', '/ql') - notify_paths = [ - f'{ql_base}/data/scripts', - f'{ql_base}/scripts', - f'{ql_base}/src', - ] - for p in notify_paths: + for p in [f'{ql_base}/data/scripts', f'{ql_base}/scripts', f'{ql_base}/src']: if p not in sys.path: sys.path.insert(0, p) from notify import send send(title, content) print("✅ 通知发送成功") - except Exception as e: - pass # 已打印格式，青龙会自动捕获 + except: + pass -# 统一的 User-Agent USER_AGENT = "Mozilla/5.0 (Linux; Android 13; SM-G981B) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/116.0.0.0 Mobile Safari/537.36" def random_wait(): - """随机倒数函数 (0-900秒)""" - delay = random.randint(0, 900) - print(f"🎲 随机延迟启动: 将在 {delay} 秒后开始执行任务...") + """随机延迟 (0-10秒)""" + delay = random.randint(0, 10) + print(f"🎲 随机延迟: {delay} 秒") time.sleep(delay) - print("⏰ 倒计时结束，任务开始！") def force_kill_chrome(): - """强制清理残留的浏览器进程""" - print("🧹 正在清理残留的浏览器进程...") + """清理残留浏览器进程""" try: os.system("pkill -f chromium") os.system("pkill -f chrome") @@ -74,6 +63,20 @@ def force_kill_chrome(): except: pass +def get_proxy(): + """获取代理""" + if not RS_PROXY_API: + print("⚠️ 未配置 RS_PROXY_API") + return "" + try: + r = requests.get(RS_PROXY_API, timeout=10) + proxy = r.text.strip().split('\n')[0].strip('\r\n ') + print(f"🌐 代理: {proxy}") + return proxy + except Exception as e: + print(f"❌ 代理获取失败: {e}") + return "" + if not os.path.exists("/ql"): CONFIG_FILE = os.path.join(os.path.dirname(os.path.abspath(__file__)), "enshan_config.json") @@ -91,20 +94,25 @@ def load_config(): with open(CONFIG_FILE, 'r', encoding='utf-8') as f: return json.load(f) +def extract_regex(pattern, text, default="0"): + try: + match = re.search(pattern, text) + return match.group(1).strip() if match else default + except: + return default + def save_cookie_to_config(new_cookie_str): try: data = load_config() if not data: return if "rHEX_2132_auth" not in new_cookie_str: return - - print("💾 正在更新 config.json 中的 Cookie...") + print("💾 更新 Cookie...") data['cookie'] = new_cookie_str - with open(CONFIG_FILE, 'w', encoding='utf-8') as f: json.dump(data, f, indent=4, ensure_ascii=False) - print("✅ Cookie 更新成功！") + print("✅ Cookie 更新成功") except Exception as e: - print(f"❌ 保存 Cookie 失败: {str(e)}") + print(f"❌ 保存 Cookie 失败: {e}") def get_cookies_safe(page): try: @@ -115,61 +123,38 @@ def get_cookies_safe(page): print(f"❌ 获取 Cookie 异常: {e}") return "" -def extract_regex(pattern, text, default="0"): - try: - match = re.search(pattern, text) - return match.group(1).strip() if match else default - except: - return default - def run_sign_in(): - # 1. 执行随机延迟 random_wait() - # 2. 读取配置 config = load_config() if not config: - notify("恩山签到", "❌ 错误: 无法加载 config.json，请检查文件是否存在") + notify("恩山签到", "❌ 无法加载 config.json") return raw_cookie = config.get('cookie', '') - user_uid = config.get('USER_UID', '') - - if not raw_cookie or not user_uid: - notify("恩山签到", "❌ 错误: config.json 中缺少 cookie 或 USER_UID，请检查配置") + if not raw_cookie: + notify("恩山签到", "❌ config.json 中缺少 cookie") return - # 3. 初始化浏览器配置 (v3.3 防冲突机制) + proxy = get_proxy() + + # 初始化浏览器 co = ChromiumOptions() - - # 随机生成端口，避免 9222 被占用导致的崩溃 rand_port = random.randint(9300, 19000) co.set_local_port(rand_port) - print(f"🔌 分配随机通信端口: {rand_port}") - - # 随机生成独立临时数据目录，用完即焚 rand_dir = f"/tmp/drissionpage_enshan_{rand_port}" co.set_user_data_path(rand_dir) - print(f"📁 分配独立数据目录: {rand_dir}") - - # 按照内核提示，加入 --headless=new co.set_argument('--headless=new') - - # 核心环境参数 co.set_argument('--no-sandbox') co.set_argument('--disable-gpu') co.set_argument('--disable-dev-shm-usage') - - # 杂项优化参数 co.set_argument('--disable-software-rasterizer') co.set_argument('--disable-features=VizDisplayCompositor') co.set_argument('--disable-extensions') co.set_argument('--disable-popup-blocking') - co.set_argument('--window-size=375,812') co.set_user_agent(user_agent=USER_AGENT) - # 路径检测 browser_path = "" if os.path.exists("/usr/bin/chromium-browser"): browser_path = "/usr/bin/chromium-browser" @@ -179,10 +164,12 @@ def run_sign_in(): if browser_path: co.set_paths(browser_path=browser_path) else: - notify("恩山签到", "❌ 错误: 未找到 chromium 可执行文件，请检查依赖安装") + notify("恩山签到", "❌ 未找到 chromium") return - # 4. 尝试启动浏览器 + if proxy: + co.set_proxy(f"http://{proxy}") + page = None for attempt in range(3): try: @@ -190,35 +177,30 @@ def run_sign_in(): page = ChromiumPage(co) if page: break except Exception as e: - print(f"⚠️ 浏览器启动失败 (第 {attempt+1} 次尝试): {e}") + print(f"⚠️ 浏览器启动失败 ({attempt+1}/3): {e}") time.sleep(5) if not page: - notify("恩山签到", "❌ 浏览器连续启动失败 (v3.3)，请尝试重启青龙容器") - # 清理临时目录 + notify("恩山签到", "❌ 浏览器启动失败") shutil.rmtree(rand_dir, ignore_errors=True) return try: - print("=== 开始执行恩山签到 (By Funseason - v3.3 青龙适配版) ===") + print("=== 开始恩山签到 ===") - # 5. 访问主页 & 注入 Cookie - print("1. 访问主页确立作用域...") + # 访问主页 page.get('https://www.right.com.cn/forum/forum.php?mobile=2', timeout=30, retry=2) try: page.set.cookies(raw_cookie) except: pass - - print("2. 刷新页面并过盾...") page.refresh() time.sleep(5) title = page.title if "安全" in title or "验证" in title: - print("🛡️ 检测到防火墙拦截，正在等待自动跳转...") + print("🛡️ 检测到防火墙，等待...") time.sleep(15) - # 6. 获取 Formhash - print("3. 正在获取签到信息...") + # 获取签到页 check_url = "https://www.right.com.cn/forum/erling_qd-sign_in_m.html" page.get(check_url, timeout=30, retry=2) time.sleep(3) @@ -226,7 +208,7 @@ def run_sign_in(): is_signed = False html = page.html - # 提取 Formhash + # 提取 formhash formhash = extract_regex(r"var FORMHASH = '([0-9a-zA-Z]+)'", html, "") if not formhash: formhash = extract_regex(r'name="formhash" value="([0-9a-zA-Z]+)"', html, "") @@ -237,7 +219,7 @@ def run_sign_in(): if not formhash: try: if "登录" in page.ele('tag:body').text: - notify("恩山签到", "❌ Cookie 已失效，请更新 config.json 中的 cookie") + notify("恩山签到", "❌ Cookie 已失效") return except: pass @@ -246,23 +228,23 @@ def run_sign_in(): body_text = page.ele('tag:body').text if "连续签到" in body_text and "立即签到" not in body_text: is_signed = True - print("ℹ️ 状态: 今天已经签到过了。") + print("ℹ️ 今日已签到") except: pass - + if not formhash and not is_signed: - notify("恩山签到", "❌ 无法提取 Formhash，可能是页面结构变化") + notify("恩山签到", "❌ 无法获取 Formhash") return if formhash: - print(f"🔑 获取 Formhash 成功: {formhash}") + print(f"🔑 Formhash: {formhash}") - # 7. 执行签到 (JS 注入) + # 执行签到 sign_success = False sign_msg = "已签到" if not is_signed: sign_api = "https://www.right.com.cn/forum/plugin.php?id=erling_qd:action&action=sign" - print("🚀 正在发送签到请求...") + print("🚀 签到请求中...") js_code = f""" return fetch("{sign_api}", {{ method: "POST", @@ -275,114 +257,49 @@ def run_sign_in(): """ try: result = page.run_js(js_code) - print(f"📥 签到接口返回: {result}") + print(f"📥 返回: {result}") if result and (result.get('success') or "已经签到" in str(result)): sign_success = True sign_msg = result.get('message', '签到成功') else: sign_msg = result.get('message', '未知错误') if result else "接口无响应" except Exception as js_err: - print(f"❌ JS 执行异常: {js_err}") + print(f"❌ JS异常: {js_err}") sign_success = False - sign_msg = "JS执行失败或WAF拦截" + sign_msg = "JS执行失败" else: sign_success = True - # 8. 最终数据获取与推送 + # 获取签到统计 + page.get(check_url) + time.sleep(2) + sign_html = page.html + + today_points = extract_regex(r'erqd-current-point[^>]*>(\d+)', sign_html, "未知") + if today_points == "未知": today_points = extract_regex(r'今日积分.*?(\d+)', sign_html, "未知") + continuous_days = extract_regex(r'erqd-continuous-days[^>]*>(\d+)', sign_html, "未知") + if continuous_days == "未知": continuous_days = extract_regex(r'连续签到.*?(\d+)', sign_html, "未知") + total_days = extract_regex(r'erqd-total-days[^>]*>(\d+)', sign_html, "未知") + if total_days == "未知": total_days = extract_regex(r'总签到天数.*?(\d+)', sign_html, "未知") + + # 保存Cookie + final_cookies = get_cookies_safe(page) + save_cookie_to_config(final_cookies) + + # 简化通知 if sign_success: - print("4. 正在获取最终积分数据...") - - # 8.1 获取签到数据 - page.get(check_url) - time.sleep(2) - sign_html = page.html - today_points = extract_regex(r'erqd-current-point[^>]*>(\d+)', sign_html, "未知") - if today_points == "未知": today_points = extract_regex(r'今日积分.*?(\d+)', sign_html, "未知") - continuous_days = extract_regex(r'erqd-continuous-days[^>]*>(\d+)', sign_html, "未知") - if continuous_days == "未知": continuous_days = extract_regex(r'连续签到.*?(\d+)', sign_html, "未知") - total_days = extract_regex(r'erqd-total-days[^>]*>(\d+)', sign_html, "未知") - if total_days == "未知": total_days = extract_regex(r'总签到天数.*?(\d+)', sign_html, "未知") - - # 8.2 刷新缓存 - print("🔄 正在刷新积分缓存...") - credit_log_url = "https://www.right.com.cn/forum/home.php?mod=spacecp&ac=credit&op=log&mobile=2" - page.get(credit_log_url) - time.sleep(2) - - # 8.3 获取个人资料 - profile_url = f"https://www.right.com.cn/forum/home.php?mod=space&uid={user_uid}&do=profile&mycenter=1&mobile=2" - print(f"📥 正在抓取个人资料页 (UID: {user_uid})...") - page.get(profile_url) - - total_points = "未知" - contribution = "未知" - enshan_coin = "未知" - - try: - time.sleep(3) - all_lis = page.eles('tag:li') - for i, li in enumerate(all_lis): - raw = li.text - clean_text = raw.replace(" ", "").replace("\n", "").replace("\r", "") - if not clean_text: continue - - if ("积分" in clean_text and "今日" not in clean_text) or "Points" in clean_text: - match_cn = re.search(r'(\d+)积分', clean_text) - match_en = re.search(r'(\d+)Points', clean_text) - if match_cn: - total_points = match_cn.group(1) - elif match_en: - total_points = match_en.group(1) - - if "贡献" in clean_text or "Contributions" in clean_text: - match_cn = re.search(r'(\d+)分贡献', clean_text) - match_en = re.search(r'(\d+)pointsContributions', clean_text) - if match_cn: - contribution = match_cn.group(1) - elif match_en: - contribution = match_en.group(1) - - if "恩山币" in clean_text or "EnshanCoin" in clean_text or "coins" in clean_text: - match_cn = re.search(r'(\d+)币恩山币', clean_text) - match_en = re.search(r'(\d+)coinsFavormountaintribute', clean_text) - match_fallback = re.search(r'(\d+)coins', clean_text) - if match_cn: - enshan_coin = match_cn.group(1) - elif match_en: - enshan_coin = match_en.group(1) - elif match_fallback: - enshan_coin = match_fallback.group(1) - - except Exception as e: - print(f"❌ 数据解析异常: {e}") - - # 8.4 构建通知内容 if is_signed: status_text = "今日已签到" else: status_text = "签到成功" - notify_body = f"""📋 恩山论坛签到报告 + notify_body = f"""✅ {status_text} -✅ 状态: {status_text} -━━━━━━━━━━━━━━━ -📈 签到统计: -├─ 今日积分: {today_points} -├─ 连续签到: {continuous_days} 天 -└─ 总签到天数: {total_days} 天 - -💰 账户信息: -├─ 总积分: {total_points} -├─ 贡献分: {contribution} -└─ 恩山币: {enshan_coin} 币 -""" +📊 今日积分: {today_points} +📅 连续签到: {continuous_days} 天 +📆 总签到天数: {total_days} 天""" notify("恩山签到", notify_body) - - # 保存更新的 Cookie - final_cookies = get_cookies_safe(page) - save_cookie_to_config(final_cookies) - else: notify("恩山签到", f"❌ 签到失败: {sign_msg}") @@ -397,7 +314,6 @@ def run_sign_in(): except: pass force_kill_chrome() - # 执行完毕后销毁临时目录 try: shutil.rmtree(rand_dir, ignore_errors=True) except: @@ -405,3 +321,4 @@ def run_sign_in(): if __name__ == "__main__": run_sign_in() +