mirror of
https://github.com/3288588344/toulu.git
synced 2025-12-16 23:11:00 +08:00
882 lines
38 KiB
Python
882 lines
38 KiB
Python
# 脚本名称: [中国移动云盘]
|
||
# 功能描述: [签到 基础任务 果园 云朵大作战]
|
||
# 使用说明:
|
||
# - [抓包 Cookie：任意Authorization]
|
||
# - [注意事项: 简易方法，开抓包进App，搜refresh，找到authTokenRefresh.do ，请求头中的Authorization，响应体<token> xxx</token> 中xxx值（新版加密抓这个）]
|
||
# 环境变量设置:
|
||
# - 名称：[ydypCK] 格式：[Authorization值#手机号#token值]
|
||
# - 多账号处理方式：[换行或者&分割]
|
||
# 定时设置: [0 0 8,16,20 * * *]
|
||
# 更新日志:
|
||
# - [1.30]: [同一环境变量获取]
|
||
# 注: 本脚本仅用于个人学习和交流，请勿用于非法用途。作者不承担由于滥用此脚本所引起的任何责任，请在下载后24小时内删除。
|
||
# new Env("移动云盘")
|
||
#TL库:https://github.com/3288588344/toulu.git
|
||
#tg频道:https://t.me/TLtoulu
|
||
#QQ频道:https://pd.qq.com/s/672fku8ge
|
||
#微信机器人：kckl6688
|
||
#公众号:哆啦A梦的藏宝箱
|
||
import os
|
||
import random
|
||
import re
|
||
import time
|
||
from os import path
|
||
|
||
import requests
|
||
|
||
ua = 'Mozilla/5.0 (Linux; Android 11; M2012K10C Build/RP1A.200720.011; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/90.0.4430.210 Mobile Safari/537.36 MCloudApp/10.0.1'
|
||
|
||
err_accounts = '' # 异常账号
|
||
err_message = '' # 错误信息
|
||
user_amount = '' # 用户云朵·数量
|
||
GLOBAL_DEBUG = False
|
||
|
||
|
||
# 发送通知
|
||
def load_send():
|
||
cur_path = path.abspath(path.dirname(__file__))
|
||
notify_file = cur_path + "/notify.py"
|
||
|
||
if path.exists(notify_file):
|
||
try:
|
||
from notify import send # 导入模块的send为notify_send
|
||
print("加载通知服务成功！")
|
||
return send # 返回导入的函数
|
||
except ImportError:
|
||
print("加载通知服务失败~")
|
||
else:
|
||
print("加载通知服务失败~")
|
||
|
||
return False # 返回False表示未成功加载通知服务
|
||
|
||
|
||
class YP:
|
||
def __init__(self, cookie):
|
||
self.notebook_id = None
|
||
self.note_token = None
|
||
self.note_auth = None
|
||
self.click_num = 15 # 定义抽奖次数和摇一摇戳一戳次数
|
||
self.draw = 1 # 抽奖次数，首次免费
|
||
self.session = requests.Session()
|
||
|
||
self.timestamp = str(int(round(time.time() * 1000)))
|
||
self.cookies = {'sensors_stay_time': self.timestamp}
|
||
self.Authorization = cookie.split("#")[0]
|
||
self.account = cookie.split("#")[1]
|
||
self.auth_token = cookie.split("#")[2]
|
||
self.encrypt_account = self.account[:3] + "*" * 4 + self.account[7:]
|
||
self.fruit_url = 'https://happy.mail.10086.cn/jsp/cn/garden/'
|
||
|
||
self.jwtHeaders = {
|
||
'User-Agent': ua,
|
||
'Accept': '*/*',
|
||
'Host': 'caiyun.feixin.10086.cn:7071',
|
||
}
|
||
self.treeHeaders = {
|
||
'Host': 'happy.mail.10086.cn',
|
||
'Accept': 'application/json, text/plain, */*',
|
||
'User-Agent': ua,
|
||
'Referer': 'https://happy.mail.10086.cn/jsp/cn/garden/wap/index.html?sourceid=1003',
|
||
'Cookie': '',
|
||
}
|
||
|
||
# 捕获异常
|
||
|
||
def catch_errors(func):
|
||
def wrapper(self, *args, **kwargs):
|
||
try:
|
||
return func(self, *args, **kwargs)
|
||
except Exception as e:
|
||
global err_message
|
||
print("错误:", str(e))
|
||
err_message += f'用户[{self.encrypt_account}]:{e}\n' # 错误信息
|
||
return None
|
||
|
||
return wrapper
|
||
|
||
@catch_errors
|
||
def run(self):
|
||
if self.jwt():
|
||
self.signin_status()
|
||
self.click()
|
||
# 任务
|
||
self.get_tasklist(url = 'sign_in_3', app_type = 'cloud_app')
|
||
print(f'\n☁️ 云朵大作战')
|
||
self.cloud_game()
|
||
print(f'\n🌳 果园任务')
|
||
self.fruitLogin()
|
||
print(f'\n📰 公众号任务')
|
||
self.wxsign()
|
||
self.shake()
|
||
self.surplus_num()
|
||
print(f'\n🔥 热门任务')
|
||
self.backup_cloud()
|
||
self.open_send()
|
||
print(f'\n📧 139邮箱任务')
|
||
self.get_tasklist(url = 'newsign_139mail', app_type = 'email_app')
|
||
self.receive()
|
||
else:
|
||
global err_accounts
|
||
# 失效账号
|
||
err_accounts += f'{self.encrypt_account}\n'
|
||
|
||
@catch_errors
|
||
def send_request(self, url, headers=None, cookies=None, data=None, params=None, method='GET', debug=None,
|
||
retries=5):
|
||
|
||
debug = debug if debug is not None else GLOBAL_DEBUG
|
||
|
||
self.session.headers.update(headers or {})
|
||
if cookies:
|
||
self.session.cookies.update(cookies)
|
||
request_args = {'json': data} if isinstance(data, dict) else {'data': data}
|
||
|
||
for attempt in range(retries):
|
||
try:
|
||
response = self.session.request(method, url, params = params, **request_args)
|
||
response.raise_for_status()
|
||
if debug:
|
||
print(f'\n【{url}】响应数据:\n{response.text}')
|
||
return response
|
||
except (requests.RequestException, ConnectionError, TimeoutError) as e:
|
||
print(f"请求异常: {e}")
|
||
if attempt >= retries - 1:
|
||
print("达到最大重试次数。")
|
||
return None
|
||
time.sleep(1)
|
||
|
||
# 随机延迟默认1-1.5s
|
||
def sleep(self, min_delay=1, max_delay=1.5):
|
||
delay = random.uniform(min_delay, max_delay)
|
||
time.sleep(delay)
|
||
|
||
# 日志
|
||
def log_info(self, err_msg=None, amount=None):
|
||
global err_message, user_amount
|
||
if err_msg is not None:
|
||
err_message += f'用户[{self.encrypt_account}]:{err_msg}\n' # 错误信息
|
||
elif amount is not None:
|
||
user_amount += f'用户[{self.encrypt_account}]:{amount}\n' # 云朵数量
|
||
|
||
# 刷新令牌
|
||
def sso(self):
|
||
sso_url = 'https://orches.yun.139.com/orchestration/auth-rebuild/token/v1.0/querySpecToken'
|
||
sso_headers = {
|
||
'Authorization': self.Authorization,
|
||
'User-Agent': ua,
|
||
'Content-Type': 'application/json',
|
||
'Accept': '*/*',
|
||
'Host': 'orches.yun.139.com'
|
||
}
|
||
sso_payload = {"account": self.account, "toSourceId": "001005"}
|
||
sso_data = self.send_request(sso_url, headers = sso_headers, data = sso_payload, method = 'POST').json()
|
||
|
||
if sso_data['success']:
|
||
refresh_token = sso_data['data']['token']
|
||
return refresh_token
|
||
else:
|
||
print(sso_data['message'])
|
||
return None
|
||
|
||
# jwt
|
||
def jwt(self):
|
||
# 获取jwttoken
|
||
token = self.sso()
|
||
if token is not None:
|
||
|
||
jwt_url = f"https://caiyun.feixin.10086.cn:7071/portal/auth/tyrzLogin.action?ssoToken={token}"
|
||
jwt_data = self.send_request(jwt_url, headers = self.jwtHeaders, method = 'POST').json()
|
||
if jwt_data['code'] != 0:
|
||
print(jwt_data['msg'])
|
||
return False
|
||
self.jwtHeaders['jwtToken'] = jwt_data['result']['token']
|
||
self.cookies['jwtToken'] = jwt_data['result']['token']
|
||
return True
|
||
else:
|
||
print('-ck可能失效了')
|
||
return False
|
||
|
||
# 签到查询
|
||
@catch_errors
|
||
def signin_status(self):
|
||
self.sleep()
|
||
check_url = 'https://caiyun.feixin.10086.cn/market/signin/page/info?client=app'
|
||
check_data = self.send_request(check_url, headers = self.jwtHeaders, cookies = self.cookies).json()
|
||
if check_data['msg'] == 'success':
|
||
today_sign_in = check_data['result'].get('todaySignIn', False)
|
||
|
||
if today_sign_in:
|
||
print('✅已签到')
|
||
else:
|
||
print('❌ 未签到')
|
||
signin_url = 'https://caiyun.feixin.10086.cn/market/manager/commonMarketconfig/getByMarketRuleName?marketName=sign_in_3'
|
||
signin_data = self.send_request(signin_url, headers = self.jwtHeaders,
|
||
cookies = self.cookies).json()
|
||
|
||
if signin_data['msg'] == 'success':
|
||
print('✅签到成功')
|
||
else:
|
||
print(signin_data['msg'])
|
||
self.log_info(signin_data['msg'])
|
||
else:
|
||
print(check_data['msg'])
|
||
self.log_info(check_data['msg'])
|
||
|
||
# 戳一下
|
||
def click(self):
|
||
url = "https://caiyun.feixin.10086.cn/market/signin/task/click?key=task&id=319"
|
||
successful_click = 0 # 获得次数
|
||
|
||
try:
|
||
for _ in range(self.click_num):
|
||
return_data = self.send_request(url, headers = self.jwtHeaders, cookies = self.cookies).json()
|
||
time.sleep(0.2)
|
||
|
||
if 'result' in return_data:
|
||
print(f'✅{return_data["result"]}')
|
||
successful_click += 1
|
||
|
||
if successful_click == 0:
|
||
print(f'❌未获得 x {self.click_num}')
|
||
except Exception as e:
|
||
print(f'错误信息:{e}')
|
||
|
||
# 刷新笔记token
|
||
@catch_errors
|
||
def refresh_notetoken(self):
|
||
note_url = 'http://mnote.caiyun.feixin.10086.cn/noteServer/api/authTokenRefresh.do'
|
||
note_payload = {
|
||
"authToken": self.auth_token,
|
||
"userPhone": self.account
|
||
}
|
||
note_headers = {
|
||
'X-Tingyun-Id': 'p35OnrDoP8k;c=2;r=1122634489;u=43ee994e8c3a6057970124db00b2442c::8B3D3F05462B6E4C',
|
||
'Charset': 'UTF-8',
|
||
'Connection': 'Keep-Alive',
|
||
'User-Agent': 'mobile',
|
||
'APP_CP': 'android',
|
||
'CP_VERSION': '3.2.0',
|
||
'x-huawei-channelsrc': '10001400',
|
||
'Host': 'mnote.caiyun.feixin.10086.cn',
|
||
'Content-Type': 'application/json; charset=UTF-8',
|
||
'Accept-Encoding': 'gzip'
|
||
}
|
||
|
||
try:
|
||
response = self.send_request(note_url, headers = note_headers, data = note_payload, method = "POST")
|
||
response.raise_for_status()
|
||
except requests.exceptions.RequestException as e:
|
||
print('出错了:', e)
|
||
return
|
||
|
||
self.note_token = response.headers.get('NOTE_TOKEN')
|
||
self.note_auth = response.headers.get('APP_AUTH')
|
||
|
||
# 任务列表
|
||
def get_tasklist(self, url, app_type):
|
||
url = f'https://caiyun.feixin.10086.cn/market/signin/task/taskList?marketname={url}'
|
||
return_data = self.send_request(url, headers = self.jwtHeaders, cookies = self.cookies).json()
|
||
self.sleep()
|
||
# 任务列表
|
||
task_list = return_data.get('result', {})
|
||
|
||
try:
|
||
for task_type, tasks in task_list.items():
|
||
if task_type in ["new", "hidden", "hiddenabc"]:
|
||
continue
|
||
if app_type == 'cloud_app':
|
||
if task_type == "month":
|
||
print('\n📆 云盘每月任务')
|
||
for month in tasks:
|
||
task_id = month.get('id')
|
||
if task_id in [110, 113, 417, 409]:
|
||
continue
|
||
task_name = month.get('name', '')
|
||
task_status = month.get('state', '')
|
||
|
||
if task_status == 'FINISH':
|
||
print(f'-已完成: {task_name}')
|
||
continue
|
||
print(f'-去完成: {task_name}')
|
||
self.do_task(task_id, task_type = 'month', app_type = 'cloud_app')
|
||
time.sleep(2)
|
||
elif task_type == "day":
|
||
print('\n📆 云盘每日任务')
|
||
for day in tasks:
|
||
task_id = day.get('id')
|
||
if task_id == 404:
|
||
continue
|
||
task_name = day.get('name')
|
||
task_status = day.get('state', '')
|
||
|
||
if task_status == 'FINISH':
|
||
print(f'-已完成: {task_name}')
|
||
continue
|
||
print(f'-去完成: {task_name}')
|
||
self.do_task(task_id, task_type = 'day', app_type = 'cloud_app')
|
||
elif app_type == 'email_app':
|
||
if task_type == "month":
|
||
print('\n📆 139邮箱每月任务')
|
||
for month in tasks:
|
||
task_id = month.get('id')
|
||
task_name = month.get('name', '')
|
||
task_status = month.get('state', '')
|
||
if task_id in [1004, 1005, 1015, 1020]:
|
||
continue
|
||
|
||
if task_status == 'FINISH':
|
||
print(f'-已完成: {task_name}')
|
||
continue
|
||
print(f'-去完成: {task_name}')
|
||
self.do_task(task_id, task_type = 'month', app_type = 'email_app')
|
||
time.sleep(2)
|
||
except Exception as e:
|
||
print(f'错误信息:{e}')
|
||
|
||
# 做任务
|
||
@catch_errors
|
||
def do_task(self, task_id, task_type, app_type):
|
||
self.sleep()
|
||
task_url = f'https://caiyun.feixin.10086.cn/market/signin/task/click?key=task&id={task_id}'
|
||
self.send_request(task_url, headers = self.jwtHeaders, cookies = self.cookies)
|
||
|
||
if app_type == 'cloud_app':
|
||
if task_type == 'day':
|
||
if task_id == 106:
|
||
print('-开始上传文件，默认0kb')
|
||
self.updata_file()
|
||
elif task_id == 107:
|
||
self.refresh_notetoken()
|
||
print('-获取默认笔记id')
|
||
note_url = 'http://mnote.caiyun.feixin.10086.cn/noteServer/api/syncNotebookV3.do'
|
||
headers = {
|
||
'X-Tingyun-Id': 'p35OnrDoP8k;c=2;r=1122634489;u=43ee994e8c3a6057970124db00b2442c::8B3D3F05462B6E4C',
|
||
'Charset': 'UTF-8',
|
||
'Connection': 'Keep-Alive',
|
||
'User-Agent': 'mobile',
|
||
'APP_CP': 'android',
|
||
'CP_VERSION': '3.2.0',
|
||
'x-huawei-channelsrc': '10001400',
|
||
'APP_NUMBER': self.account,
|
||
'APP_AUTH': self.note_auth,
|
||
'NOTE_TOKEN': self.note_token,
|
||
'Host': 'mnote.caiyun.feixin.10086.cn',
|
||
'Content-Type': 'application/json; charset=UTF-8',
|
||
'Accept': '*/*'
|
||
}
|
||
payload = {
|
||
"addNotebooks": [],
|
||
"delNotebooks": [],
|
||
"notebookRefs": [],
|
||
"updateNotebooks": []
|
||
}
|
||
return_data = self.send_request(url = note_url, headers = headers, data = payload,
|
||
method = 'POST').json()
|
||
if return_data is None:
|
||
return print('出错了')
|
||
self.notebook_id = return_data['notebooks'][0]['notebookId']
|
||
print('开始创建笔记')
|
||
self.create_note(headers)
|
||
elif task_type == 'month':
|
||
pass
|
||
elif app_type == 'email_app':
|
||
if task_type == 'month':
|
||
pass
|
||
|
||
# 上传文件
|
||
@catch_errors
|
||
def updata_file(self):
|
||
url = 'http://ose.caiyun.feixin.10086.cn/richlifeApp/devapp/IUploadAndDownload'
|
||
headers = {
|
||
'x-huawei-uploadSrc': '1',
|
||
'x-ClientOprType': '11',
|
||
'Connection': 'keep-alive',
|
||
'x-NetType': '6',
|
||
'x-DeviceInfo': '6|127.0.0.1|1|10.0.1|Xiaomi|M2012K10C|CB63218727431865A48E691BFFDB49A1|02-00-00-00-00-00|android 11|1080X2272|zh||||032|',
|
||
'x-huawei-channelSrc': '10000023',
|
||
'x-MM-Source': '032',
|
||
'x-SvcType': '1',
|
||
'APP_NUMBER': self.account,
|
||
'Authorization': self.Authorization,
|
||
'X-Tingyun-Id': 'p35OnrDoP8k;c=2;r=1955442920;u=43ee994e8c3a6057970124db00b2442c::8B3D3F05462B6E4C',
|
||
'Host': 'ose.caiyun.feixin.10086.cn',
|
||
'User-Agent': 'okhttp/3.11.0',
|
||
'Content-Type': 'application/xml; charset=UTF-8',
|
||
'Accept': '*/*'
|
||
}
|
||
payload = '''
|
||
<pcUploadFileRequest>
|
||
<ownerMSISDN>{phone}</ownerMSISDN>
|
||
<fileCount>1</fileCount>
|
||
<totalSize>1</totalSize>
|
||
<uploadContentList length="1">
|
||
<uploadContentInfo>
|
||
<comlexFlag>0</comlexFlag>
|
||
<contentDesc><![CDATA[]]></contentDesc>
|
||
<contentName><![CDATA[000000.txt]]></contentName>
|
||
<contentSize>1</contentSize>
|
||
<contentTAGList></contentTAGList>
|
||
<digest>C4CA4238A0B923820DCC509A6F75849B</digest>
|
||
<exif/>
|
||
<fileEtag>0</fileEtag>
|
||
<fileVersion>0</fileVersion>
|
||
<updateContentID></updateContentID>
|
||
</uploadContentInfo>
|
||
</uploadContentList>
|
||
<newCatalogName></newCatalogName>
|
||
<parentCatalogID></parentCatalogID>
|
||
<operation>0</operation>
|
||
<path></path>
|
||
<manualRename>2</manualRename>
|
||
<autoCreatePath length="0"/>
|
||
<tagID></tagID>
|
||
<tagType></tagType>
|
||
</pcUploadFileRequest>
|
||
'''.format(phone = self.account)
|
||
|
||
response = requests.post(url = url, headers = headers, data = payload)
|
||
if response is None:
|
||
return
|
||
if response.status_code != 200:
|
||
return print('-上传失败')
|
||
print('-上传文件成功')
|
||
|
||
# 创建笔记
|
||
def create_note(self, headers):
|
||
note_id = self.get_note_id(32) # 获取随机笔记id
|
||
createtime = str(int(round(time.time() * 1000)))
|
||
time.sleep(3)
|
||
updatetime = str(int(round(time.time() * 1000)))
|
||
note_url = 'http://mnote.caiyun.feixin.10086.cn/noteServer/api/createNote.do'
|
||
payload = {
|
||
"archived": 0,
|
||
"attachmentdir": note_id,
|
||
"attachmentdirid": "",
|
||
"attachments": [],
|
||
"audioInfo": {
|
||
"audioDuration": 0,
|
||
"audioSize": 0,
|
||
"audioStatus": 0
|
||
},
|
||
"contentid": "",
|
||
"contents": [{
|
||
"contentid": 0,
|
||
"data": "<font size=\"3\">000000</font>",
|
||
"noteId": note_id,
|
||
"sortOrder": 0,
|
||
"type": "RICHTEXT"
|
||
}],
|
||
"cp": "",
|
||
"createtime": createtime,
|
||
"description": "android",
|
||
"expands": {
|
||
"noteType": 0
|
||
},
|
||
"latlng": "",
|
||
"location": "",
|
||
"noteid": note_id,
|
||
"notestatus": 0,
|
||
"remindtime": "",
|
||
"remindtype": 1,
|
||
"revision": "1",
|
||
"sharecount": "0",
|
||
"sharestatus": "0",
|
||
"system": "mobile",
|
||
"tags": [{
|
||
"id": self.notebook_id,
|
||
"orderIndex": "0",
|
||
"text": "默认笔记本"
|
||
}],
|
||
"title": "00000",
|
||
"topmost": "0",
|
||
"updatetime": updatetime,
|
||
"userphone": self.account,
|
||
"version": "1.00",
|
||
"visitTime": ""
|
||
}
|
||
create_note_data = self.send_request(note_url, headers = headers, data = payload, method = "POST")
|
||
if create_note_data.status_code == 200:
|
||
print('-创建笔记成功')
|
||
else:
|
||
print('-创建失败')
|
||
|
||
# 笔记id
|
||
def get_note_id(self, length):
|
||
characters = '19f3a063d67e4694ca63a4227ec9a94a19088404f9a28084e3e486b928039a299bf756ebc77aa4f6bfa250308ec6a8be8b63b5271a00350d136d117b8a72f39c5bd15cdfd350cba4271dc797f15412d9f269e666aea5039f5049d00739b320bb9e8585a008b52c1cbd86970cae9476446f3e41871de8d9f6112db94b05e5dc7ea0a942a9daf145ac8e487d3d5cba7cea145680efc64794d43dd15c5062b81e1cda7bf278b9bc4e1b8955846e6bc4b6a61c28f831f81b2270289e5a8a677c3141ddc9868129060c0c3b5ef507fbd46c004f6de346332ef7f05c0094215eae1217ee7c13c8dca6d174cfb49c716dd42903bb4b02d823b5f1ff93c3f88768251b56cc'
|
||
note_id = ''.join(random.choice(characters) for _ in range(length))
|
||
return note_id
|
||
|
||
# 公众号签到
|
||
@catch_errors
|
||
def wxsign(self):
|
||
self.sleep()
|
||
url = 'https://caiyun.feixin.10086.cn/market/playoffic/followSignInfo?isWx=true'
|
||
return_data = self.send_request(url, headers = self.jwtHeaders, cookies = self.cookies).json()
|
||
|
||
if return_data['msg'] != 'success':
|
||
return print(return_data['msg'])
|
||
if not return_data['result'].get('todaySignIn'):
|
||
return print('❌签到失败,可能未绑定公众号')
|
||
return print('✅签到成功')
|
||
|
||
# 摇一摇
|
||
def shake(self):
|
||
url = "https://caiyun.feixin.10086.cn:7071/market/shake-server/shake/shakeIt?flag=1"
|
||
successful_shakes = 0 # 记录成功摇中的次数
|
||
|
||
try:
|
||
for _ in range(self.click_num):
|
||
return_data = self.send_request(url = url, cookies = self.cookies, headers = self.jwtHeaders,
|
||
method = 'POST').json()
|
||
time.sleep(1)
|
||
shake_prize_config = return_data["result"].get("shakePrizeconfig")
|
||
|
||
if shake_prize_config:
|
||
print(f"🎉摇一摇获得: {shake_prize_config['name']}")
|
||
successful_shakes += 1
|
||
except Exception as e:
|
||
print(f'错误信息: {e}')
|
||
if successful_shakes == 0:
|
||
print(f'❌未摇中 x {self.click_num}')
|
||
|
||
# 查询剩余抽奖次数
|
||
@catch_errors
|
||
def surplus_num(self):
|
||
self.sleep()
|
||
draw_info_url = 'https://caiyun.feixin.10086.cn/market/playoffic/drawInfo'
|
||
draw_url = "https://caiyun.feixin.10086.cn/market/playoffic/draw"
|
||
|
||
draw_info_data = self.send_request(draw_info_url, headers = self.jwtHeaders).json()
|
||
|
||
if draw_info_data.get('msg') == 'success':
|
||
remain_num = draw_info_data['result'].get('surplusNumber', 0)
|
||
print(f'剩余抽奖次数{remain_num}')
|
||
if remain_num > 50 - self.draw:
|
||
for _ in range(self.draw):
|
||
self.sleep()
|
||
draw_data = self.send_request(url = draw_url, headers = self.jwtHeaders).json()
|
||
|
||
if draw_data.get("code") == 0:
|
||
prize_name = draw_data["result"].get("prizeName", "")
|
||
print("✅抽奖成功，获得:" + prize_name)
|
||
else:
|
||
print("❌抽奖失败")
|
||
else:
|
||
pass
|
||
else:
|
||
print(draw_info_data.get('msg'))
|
||
self.log_info(draw_info_data.get('msg'))
|
||
|
||
# 果园专区
|
||
@catch_errors
|
||
def fruitLogin(self):
|
||
token = self.sso()
|
||
if token is not None:
|
||
print("-果园专区token刷新成功")
|
||
self.sleep()
|
||
login_info_url = f'{self.fruit_url}login/caiyunsso.do?token={token}&account={self.account}&targetSourceId=001208&sourceid=1003&enableShare=1'
|
||
headers = {
|
||
'Host': 'happy.mail.10086.cn',
|
||
'Upgrade-Insecure-Requests': '1',
|
||
'User-Agent': ua,
|
||
'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',
|
||
'Referer': 'https://caiyun.feixin.10086.cn:7071/',
|
||
'Accept-Language': 'zh-CN,zh;q=0.9,en-US;q=0.8,en;q=0.7'
|
||
}
|
||
loginInfoData = requests.request("GET", login_info_url, headers = headers)
|
||
treeCookie = loginInfoData.request.headers['Cookie']
|
||
self.treeHeaders['cookie'] = treeCookie
|
||
|
||
do_login_url = f'{self.fruit_url}login/userinfo.do'
|
||
doLoginData = self.send_request(do_login_url, headers = self.treeHeaders).json()
|
||
if doLoginData.get('result', {}).get('islogin') != 1:
|
||
return print('❌果园登录失败')
|
||
# 去做果园任务
|
||
self.fruitTask()
|
||
else:
|
||
print("果园专区token刷新失败")
|
||
|
||
# 任务查询
|
||
@catch_errors
|
||
def fruitTask(self):
|
||
# 签到任务
|
||
check_sign_data = self.send_request(f'{self.fruit_url}task/checkinInfo.do',
|
||
headers = self.treeHeaders).json()
|
||
if check_sign_data.get('success'):
|
||
today_checkin = check_sign_data.get('result', {}).get('todayCheckin', 0)
|
||
if today_checkin == 1:
|
||
print('-果园今日已签到')
|
||
else:
|
||
checkin_data = self.send_request(f'{self.fruit_url}task/checkin.do',
|
||
headers = self.treeHeaders).json()
|
||
if checkin_data.get('result', {}).get('code', '') == 1:
|
||
print('-果园签到成功')
|
||
self.sleep()
|
||
water_data = self.send_request(f'{self.fruit_url}user/clickCartoon.do?cartoonType=widget',
|
||
headers = self.treeHeaders).json()
|
||
color_data = self.send_request(f'{self.fruit_url}user/clickCartoon.do?cartoonType=color',
|
||
headers = self.treeHeaders).json()
|
||
given_water = water_data.get('result', {}).get('given', 0)
|
||
print(f'-领取每日水滴: {given_water}')
|
||
print(f'-每日雨滴:{color_data.get("result").get("msg")}')
|
||
else:
|
||
print('-果园签到查询失败:', check_sign_data.get('msg', ''))
|
||
|
||
# 获取任务列表
|
||
task_list_data = self.send_request(f'{self.fruit_url}task/taskList.do?clientType=PE',
|
||
headers = self.treeHeaders).json()
|
||
task_state_data = self.send_request(f'{self.fruit_url}task/taskState.do', headers = self.treeHeaders).json()
|
||
task_state_result = task_state_data.get('result', [])
|
||
|
||
task_list = task_list_data.get('result', [])
|
||
|
||
for task in task_list:
|
||
task_id = task.get('taskId', '')
|
||
task_name = task.get('taskName', '')
|
||
water_num = task.get('waterNum', 0)
|
||
if task_id == 2002 or task_id == 2003:
|
||
continue
|
||
|
||
task_state = next(
|
||
(state.get('taskState', 0) for state in task_state_result if state.get('taskId') == task_id), 0)
|
||
|
||
if task_state == 2:
|
||
print(f'-已完成: {task_name}')
|
||
else:
|
||
self.do_fruit_task(task_name, task_id, water_num)
|
||
|
||
# 果树信息
|
||
self.tree_info()
|
||
|
||
# 做任务
|
||
@catch_errors
|
||
def do_fruit_task(self, task_name, task_id, water_num):
|
||
print(f'-去完成: {task_name}')
|
||
do_task_url = f'{self.fruit_url}task/doTask.do?taskId={task_id}'
|
||
do_task_data = self.send_request(do_task_url, headers = self.treeHeaders).json()
|
||
|
||
if do_task_data.get('success'):
|
||
get_water_url = f'{self.fruit_url}task/givenWater.do?taskId={task_id}'
|
||
get_water_data = self.send_request(get_water_url, headers = self.treeHeaders).json()
|
||
|
||
if get_water_data.get('success'):
|
||
print(f'-已完成任务获得水滴: {water_num}')
|
||
else:
|
||
print(f'❌领取失败: {get_water_data.get("msg", "")}')
|
||
else:
|
||
print(f'❌参与任务失败: {do_task_data.get("msg", "")}')
|
||
|
||
# 果树信息
|
||
@catch_errors
|
||
def tree_info(self):
|
||
treeinfo_url = f'{self.fruit_url}user/treeInfo.do'
|
||
treeinfo_data = self.send_request(treeinfo_url, headers = self.treeHeaders).json()
|
||
|
||
if not treeinfo_data.get('success'):
|
||
error_message = treeinfo_data.get('msg', '获取果园任务列表失败')
|
||
print(error_message)
|
||
else:
|
||
collect_water = treeinfo_data.get('result', {}).get('collectWater', 0)
|
||
tree_level = treeinfo_data.get('result', {}).get('treeLevel', 0)
|
||
print(f'-当前小树等级: {tree_level} 剩余水滴: {collect_water}')
|
||
if tree_level in (2, 4, 6, 8):
|
||
# 开宝箱
|
||
openbox_url = f'{self.fruit_url}prize/openBox.do'
|
||
openbox_data = self.send_request(openbox_url, headers = self.treeHeaders).json()
|
||
print(f'- {openbox_data.get("result").get("msg")}')
|
||
|
||
watering_amount = collect_water // 20 # 计算需要浇水的次数
|
||
watering_url = f'{self.fruit_url}user/watering.do?isFast=0'
|
||
if watering_amount > 0:
|
||
for _ in range(watering_amount):
|
||
watering_data = self.send_request(watering_url, headers = self.treeHeaders).json()
|
||
if watering_data.get('success'):
|
||
print('✔️ 浇水成功')
|
||
time.sleep(3)
|
||
else:
|
||
print('-水滴不足!')
|
||
|
||
# 云朵大作战
|
||
@catch_errors
|
||
def cloud_game(self):
|
||
game_info_url = 'https://caiyun.feixin.10086.cn/market/signin/hecheng1T/info?op=info'
|
||
bigin_url = 'https://caiyun.feixin.10086.cn/market/signin/hecheng1T/beinvite'
|
||
end_url = 'https://caiyun.feixin.10086.cn/market/signin/hecheng1T/finish?flag=true'
|
||
|
||
game_info_data = self.send_request(game_info_url, headers = self.jwtHeaders, cookies = self.cookies).json()
|
||
if game_info_data and game_info_data.get('code', -1) == 0:
|
||
currnum = game_info_data.get('result', {}).get('info', {}).get('curr', 0)
|
||
count = game_info_data.get('result', {}).get('history', {}).get('0', {}).get('count', '')
|
||
rank = game_info_data.get('result', {}).get('history', {}).get('0', {}).get('rank', '')
|
||
|
||
print(f'今日剩余游戏次数: {currnum}\n本月排名: {rank} 合成次数: {count}')
|
||
|
||
for _ in range(currnum):
|
||
self.send_request(bigin_url, headers = self.jwtHeaders, cookies = self.cookies).json()
|
||
print('-开始游戏,等待10-15秒完成游戏')
|
||
time.sleep(random.randint(10, 15))
|
||
end_data = self.send_request(end_url, headers = self.jwtHeaders, cookies = self.cookies).json()
|
||
if end_data and end_data.get('code', -1) == 0:
|
||
print('游戏成功')
|
||
else:
|
||
print("-获取游戏信息失败")
|
||
|
||
# 领取云朵
|
||
@catch_errors
|
||
def receive(self):
|
||
receive_url = "https://caiyun.feixin.10086.cn/market/signin/page/receive"
|
||
prize_url = f"https://caiyun.feixin.10086.cn/market/prizeApi/checkPrize/getUserPrizeLogPage?currPage=1&pageSize=15&_={self.timestamp}"
|
||
receive_data = self.send_request(receive_url, headers = self.jwtHeaders, cookies = self.cookies).json()
|
||
self.sleep()
|
||
prize_data = self.send_request(prize_url, headers = self.jwtHeaders, cookies = self.cookies).json()
|
||
result = prize_data.get('result').get('result')
|
||
rewards = ''
|
||
for value in result:
|
||
prizeName = value.get('prizeName')
|
||
flag = value.get('flag')
|
||
if flag == 1:
|
||
rewards += f'-待领取奖品: {prizeName}\n'
|
||
|
||
receive_amount = receive_data["result"].get("receive", "")
|
||
total_amount = receive_data["result"].get("total", "")
|
||
print(f'\n-当前待领取:{receive_amount}云朵')
|
||
print(f'-当前云朵数量:{total_amount}云朵')
|
||
msg = f'云朵数量:{total_amount} \n{rewards}'
|
||
self.log_info(amount = msg)
|
||
|
||
# 备份云朵
|
||
@catch_errors
|
||
def backup_cloud(self):
|
||
backup_url = 'https://caiyun.feixin.10086.cn/market/backupgift/info'
|
||
backup_data = self.send_request(backup_url, headers = self.jwtHeaders).json()
|
||
state = backup_data.get('result', {}).get('state', '')
|
||
if state == -1:
|
||
print('本月未备份,暂无连续备份奖励')
|
||
|
||
elif state == 0:
|
||
print('-领取本月连续备份奖励')
|
||
cur_url = 'https://caiyun.feixin.10086.cn/market/backupgift/receive'
|
||
cur_data = self.send_request(cur_url, headers = self.jwtHeaders).json()
|
||
print(f'-获得云朵数量:{cur_data.get("result").get("result")}')
|
||
|
||
elif state == 1:
|
||
print('-已领取本月连续备份奖励')
|
||
self.sleep()
|
||
expend_url = 'https://caiyun.feixin.10086.cn/market/signin/page/taskExpansion' # 每月膨胀云朵
|
||
expend_data = self.send_request(expend_url, headers = self.jwtHeaders, cookies = self.cookies).json()
|
||
|
||
curMonthBackup = expend_data.get('result', {}).get('curMonthBackup', '') # 本月备份
|
||
preMonthBackup = expend_data.get('result', {}).get('preMonthBackup', '') # 上月备份
|
||
curMonthBackupTaskAccept = expend_data.get('result', {}).get('curMonthBackupTaskAccept', '') # 本月是否领取
|
||
nextMonthTaskRecordCount = expend_data.get('result', {}).get('nextMonthTaskRecordCount', '') # 下月备份云朵
|
||
acceptDate = expend_data.get('result', {}).get('acceptDate', '') # 月份
|
||
|
||
if curMonthBackup:
|
||
print(f'- 本月已备份，下月可领取膨胀云朵: {nextMonthTaskRecordCount}')
|
||
else:
|
||
print('- 本月还未备份，下月暂无膨胀云朵')
|
||
|
||
if preMonthBackup:
|
||
if curMonthBackupTaskAccept:
|
||
print('- 上月已备份，膨胀云朵已领取')
|
||
else:
|
||
# 领取
|
||
receive_url = f'https://caiyun.feixin.10086.cn/market/signin/page/receiveTaskExpansion?acceptDate={acceptDate}'
|
||
receive_data = self.send_request(receive_url, headers = self.jwtHeaders,
|
||
cookies = self.cookies).json()
|
||
if receive_data.get("code") != 0:
|
||
print(f'-领取失败:{receive_data.get("msg")}')
|
||
else:
|
||
cloudCount = receive_data.get('result', {}).get('cloudCount', '')
|
||
print(f'- 膨胀云朵领取成功: {cloudCount}朵')
|
||
else:
|
||
print('-上月未备份，本月无膨胀云朵领取')
|
||
|
||
# # 开启备份
|
||
# def open_backup(self):
|
||
|
||
# 通知云朵
|
||
@catch_errors
|
||
def open_send(self):
|
||
send_url = 'https://caiyun.feixin.10086.cn/market/msgPushOn/task/status'
|
||
send_data = self.send_request(send_url, headers = self.jwtHeaders).json()
|
||
|
||
pushOn = send_data.get('result', {}).get('pushOn', '') # 0未开启，1开启，2未领取，3已领取
|
||
firstTaskStatus = send_data.get('result', {}).get('firstTaskStatus', '')
|
||
secondTaskStatus = send_data.get('result', {}).get('secondTaskStatus', '')
|
||
onDuaration = send_data.get('result', {}).get('onDuaration', '') # 开启时间
|
||
|
||
if pushOn == 1:
|
||
reward_url = 'https://caiyun.feixin.10086.cn/market/msgPushOn/task/obtain'
|
||
|
||
if firstTaskStatus == 3:
|
||
print('- 任务1奖励已领取')
|
||
else:
|
||
# 领取任务1
|
||
print('- 领取任务1奖励')
|
||
reward1_data = self.send_request(reward_url, headers = self.jwtHeaders, data = {"type": 1},
|
||
method = "POST").json()
|
||
print(reward1_data.get('result', {}).get('description', ''))
|
||
|
||
if secondTaskStatus == 2:
|
||
# 领取任务2
|
||
print('- 领取任务2奖励')
|
||
reward2_data = self.send_request(reward_url, headers = self.jwtHeaders, data = {"type": 2},
|
||
method = "POST").json()
|
||
print(reward2_data.get('result', {}).get('description', ''))
|
||
|
||
print(f'- 通知已开启天数: {onDuaration}, 满31天可领取奖励')
|
||
else:
|
||
print('- 通知权限未开启')
|
||
|
||
def get_announcement():
|
||
"""
|
||
获取公告信息
|
||
"""
|
||
external_url = 'https://github.com/3288588344/toulu/raw/refs/heads/main/tl.txt'
|
||
try:
|
||
response = requests.get(external_url)
|
||
if response.status_code == 200:
|
||
print( response.text)
|
||
print("公告获取成功，开始执行任务...")
|
||
else:
|
||
print(f"获取公告失败，状态码: {response.status_code}")
|
||
except requests.exceptions.RequestException as e:
|
||
print(f"获取公告时发生错误: {e}")
|
||
|
||
|
||
if __name__ == "__main__":
|
||
get_announcement()
|
||
env_name = 'ydypCK'
|
||
token = os.getenv(env_name)
|
||
if not token:
|
||
print(f'⛔️未获取到ck变量：请检查变量 {env_name} 是否填写')
|
||
exit(0)
|
||
|
||
cookies = re.split(r'[&\n]', token)
|
||
print(f"移动硬盘共获取到{len(cookies)}个账号")
|
||
|
||
for i, account_info in enumerate(cookies, start = 1):
|
||
print(f"\n======== ▷ 第 {i} 个账号 ◁ ========")
|
||
YP(account_info).run()
|
||
print("\n随机等待5-10s进行下一个账号")
|
||
time.sleep(random.randint(5, 10))
|
||
|
||
# 输出异常账号信息
|
||
if err_accounts != '':
|
||
print(f"\n失效账号:\n{err_accounts}")
|
||
else:
|
||
print('当前所有账号ck有效')
|
||
if err_message != '':
|
||
print(f'-错误信息: \n{err_message}')
|
||
print(user_amount)
|
||
# 在load_send中获取导入的send函数
|
||
send = load_send()
|
||
|
||
# 判断send是否可用再进行调用
|
||
if send:
|
||
msg = f"失效账号:\n{err_accounts}\n-错误信息:\n{err_message}\n-云朵数量: \n{user_amount}"
|
||
send('中国移动云盘任务信息', msg)
|
||
else:
|
||
print('通知服务不可用')
|