From 33a3be23fcabe01f134299af9c244a04bb511459 Mon Sep 17 00:00:00 2001 From: Ytong <90929463+Ytong825@users.noreply.github.com> Date: Wed, 26 Feb 2025 22:56:37 +0800 Subject: [PATCH] =?UTF-8?q?Create=20=E9=A1=BA=E4=B8=B0=E5=8D=95=E7=8B=AC?= =?UTF-8?q?=E6=8E=A8=E9=80=81=E7=89=88.py?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- 顺丰单独推送版.py | 159 ++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 159 insertions(+) create mode 100644 顺丰单独推送版.py diff --git a/顺丰单独推送版.py b/顺丰单独推送版.py new file mode 100644 index 0000000..bc64fa4 --- /dev/null +++ b/顺丰单独推送版.py @@ -0,0 +1,159 @@ +#2025/2/26 顺丰速运Cookie绑定UID单独推送版 +#变量名：sfsyUrl（格式：cookie1#uid1&cookie2#uid2） +import hashlib +import json +import os +import random +import time +import requests +from urllib.parse import unquote + +requests.packages.urllib3.disable_warnings() + +# ================== 全局配置 ================== +APP_NAME = '顺丰速运' +ENV_NAME = 'sfsyUrl' +WX_TOKEN = os.getenv('WX_PUSHER_APP_TOKEN') + +class SFExpress: + def __init__(self, cookie, uid, index): + self.index = index + 1 + self.uid = uid.strip() + self.mobile = '未知账号' + self.total_point = '获取失败' + self.usable_honey = '获取失败' + self.sign_days = 0 + self.cookie = cookie.strip() + self.session = requests.Session() + self.session.verify = False + self.headers = { + 'User-Agent': 'Mozilla/5.0 (Linux; Android 10; SM-G981B) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/80.0.3987.162 Mobile Safari/537.36', + 'platform': 'MINI_PROGRAM' + } + + def login(self): + try: + decoded_url = unquote(self.cookie) + res = self.session.get(decoded_url, headers=self.headers, timeout=10) + if res.status_code != 200: + return False + + phone = self.session.cookies.get('_login_mobile_', '') + if len(phone) >= 11: + self.mobile = f"{phone[:3]}****{phone[7:]}" + return True + return False + except Exception as e: + print(f"账号{self.index}登录异常: {str(e)}") + return False + + def generate_sign(self): + timestamp = str(int(time.time() * 1000)) + raw = f'token=wwesldfs29aniversaryvdld29×tamp={timestamp}&sysCode=MCS-MIMP-CORE' + sign = hashlib.md5(raw.encode()).hexdigest() + self.headers.update({ + 'sysCode': 'MCS-MIMP-CORE', + 'timestamp': timestamp, + 'signature': sign + }) + + def get_data(self, url, data=None, method='POST'): + self.generate_sign() + try: + if method == 'GET': + response = self.session.get(url, headers=self.headers, timeout=10) + else: + response = self.session.post(url, json=data, headers=self.headers, timeout=10) + return response.json() if response.text else {} + except Exception as e: + print(f"请求异常: {str(e)}") + return {} + + def execute_tasks(self): + if not self.login(): + print(f"❌ 账号{self.index} 登录失败") + return False + + # 执行签到 + sign_res = self.get_data( + 'https://mcs-mimp-web.sf-express.com/mcs-mimp/commonPost/~memberNonactivity~integralTaskSignPlusService~automaticSignFetchPackage', + {'comeFrom': 'vioin', 'channelFrom': 'WEIXIN'} + ) + if sign_res.get('success'): + self.sign_days = sign_res.get('obj', {}).get('countDay', 0) + 1 + + # 获取积分 + point_res = self.get_data( + 'https://mcs-mimp-web.sf-express.com/mcs-mimp/commonPost/~memberNonactivity~integralTaskStrategyService~queryPointTaskAndSignFromES', + {'channelType': '1', 'deviceId': self._generate_deviceId()} + ) + if point_res.get('success'): + self.total_point = point_res.get('obj', {}).get('totalPoint', '获取失败') + + # 获取丰蜜 + honey_res = self.get_data( + 'https://mcs-mimp-web.sf-express.com/mcs-mimp/commonPost/~memberNonactivity~receiveExchangeIndexService~indexData', + {'inviteUserId': ''} + ) + if honey_res.get('success'): + self.usable_honey = honey_res.get('obj', {}).get('usableHoney', '获取失败') + + return True + + def _generate_deviceId(self): + return ''.join(random.choices('abcdef0123456789', k=36)) + +def send_notification(mobile, point, honey, days, uid): + if not WX_TOKEN or not uid: + print("⚠️ 未配置推送参数") + return + + message = [ + "🏣 顺丰速运账号报告\n", + f"📱 账号：{mobile}\n", + f"🏅 积分：{point}\n", + f"🍯 蜂蜜：{honey}\n", + f"📆 连续签到：{days}天\n" + ] + + try: + res = requests.post( + "https://wxpusher.zjiecode.com/api/send/message", + json={ + "appToken": WX_TOKEN, + "content": ''.join(message), + "contentType": 1, + "uids": [uid] + }, + timeout=10 + ) + if res.json().get('code') == 1000: + print(f"📤 推送到{uid}成功") + else: + print(f"推送到{uid}失败：{res.text}") + except Exception as e: + print(f"推送到{uid}异常：{str(e)}") + +if __name__ == '__main__': + raw_cookies = os.getenv(ENV_NAME, '').split('&') + print(f"📦 共检测到 {len(raw_cookies)} 个账号") + + for idx, item in enumerate(raw_cookies): + if not item.strip(): + continue + + # 解析cookie和uid + if '#' not in item: + print(f"❌ 第{idx+1}个账号格式错误，缺少#分隔符") + continue + + cookie, uid = item.split('#', 1) + if not cookie or not uid: + print(f"❌ 第{idx+1}个账号配置不完整") + continue + + print(f"\n====== 正在处理第 {idx+1} 个账号 ======") + sf = SFExpress(cookie, uid, idx) + if sf.execute_tasks(): + send_notification(sf.mobile, sf.total_point, sf.usable_honey, sf.sign_days, sf.uid) + time.sleep(random.randint(2, 5)) \ No newline at end of file