✨:feat(中国移动云盘): 添加更多任务功能并优化代码结构
- 新增云朵大作战、果园任务、微信公众号签到等功能- 优化代码结构，支持多账号运行 - 添加环境变量配置说明 - 修复部分功能逻辑，提高稳定性
This commit is contained in:
liulong
parent
8a289dec82
commit
a56fb41d19
633
中国移动云盘.py
633
中国移动云盘.py
@ -5,14 +5,34 @@
|
||||
# @EditTime 2024/11/4
|
||||
# corn: 0 0 8,16,20 * * *
|
||||
# const $ = new Env('中国移动云盘');
|
||||
"""
|
||||
设置环境变量，ydyp_ck，格式 Basic XXXXXXXX#手机号#token#rekey#Os_SSo_Sid
|
||||
多个账号用@分割
|
||||
"""
|
||||
import asyncio
|
||||
import os
|
||||
import random
|
||||
import re
|
||||
import time
|
||||
import urllib.parse
|
||||
from datetime import datetime
|
||||
|
||||
import httpx
|
||||
import requests
|
||||
|
||||
from fn_print import fn_print
|
||||
from sendNotify import send_notification_message_collection
|
||||
|
||||
|
||||
|
||||
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"
|
||||
|
||||
if 'ydyp_ck' in os.environ:
|
||||
ydyp_ck = re.split("@", os.environ.get("ydyp_ck"))
|
||||
else:
|
||||
ydyp_ck = []
|
||||
fn_print("未查找到ydyp_ck变量.")
|
||||
|
||||
|
||||
class MobileCloudDisk:
|
||||
def __init__(self, cookie):
|
||||
@ -27,6 +47,10 @@ class MobileCloudDisk:
|
||||
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.rmkey = cookie.split("#")[3]
|
||||
self.Os_SSo_Sid = cookie.split("#")[4]
|
||||
self.fruit_url = 'https://happy.mail.10086.cn/jsp/cn/garden/'
|
||||
self.JwtHeaders = {
|
||||
'User-Agent': ua,
|
||||
'Accept': '*/*',
|
||||
@ -36,8 +60,7 @@ class MobileCloudDisk:
|
||||
'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': ''
|
||||
'Referer': 'https://happy.mail.10086.cn/jsp/cn/garden/wap/index.html?sourceid=1003'
|
||||
}
|
||||
|
||||
async def refresh_token(self):
|
||||
@ -60,7 +83,7 @@ class MobileCloudDisk:
|
||||
refresh_token = refresh_token_responses["data"]["token"]
|
||||
return refresh_token
|
||||
else:
|
||||
print(refresh_token_responses)
|
||||
fn_print(refresh_token_responses)
|
||||
return None
|
||||
|
||||
async def jwt(self):
|
||||
@ -73,13 +96,13 @@ class MobileCloudDisk:
|
||||
)
|
||||
jwt_datas = jwt_response.json()
|
||||
if jwt_datas["code"] != 0:
|
||||
print(jwt_datas["msg"])
|
||||
fn_print(jwt_datas["msg"])
|
||||
return False
|
||||
self.JwtHeaders["jwtToken"] = jwt_datas["result"]["token"]
|
||||
self.cookies["jwtToken"] = jwt_datas["result"]["token"]
|
||||
return True
|
||||
else:
|
||||
print("cookie可能失效了")
|
||||
fn_print("cookie可能失效了")
|
||||
return False
|
||||
|
||||
async def query_sign_in_status(self):
|
||||
@ -97,11 +120,11 @@ class MobileCloudDisk:
|
||||
if sign_response_data["msg"] == "success":
|
||||
today_sign = sign_response_data["result"].get("todaySignIn", False)
|
||||
if today_sign:
|
||||
print(f"用户【{self.account}】，===今日已签到☑️===")
|
||||
fn_print(f"用户【{self.account}】，===今日已签到☑️===")
|
||||
else:
|
||||
await self.sign_in()
|
||||
else:
|
||||
print(f"签到查询状态异常：{sign_response_datas.status_code}")
|
||||
fn_print(f"签到查询状态异常：{sign_response_datas.status_code}")
|
||||
|
||||
async def a_poke(self):
|
||||
"""
|
||||
@ -121,14 +144,14 @@ class MobileCloudDisk:
|
||||
if responses.status_code == 200:
|
||||
responses_data = responses.json()
|
||||
if "result" in responses_data:
|
||||
print(f"用户【{self.account}】，===戳一戳成功✅✅===, {responses_data['result']}")
|
||||
fn_print(f"用户【{self.account}】，===戳一戳成功✅✅===, {responses_data['result']}")
|
||||
successful_click += 1
|
||||
else:
|
||||
print(f"戳一戳发生异常：{responses.status_code}")
|
||||
fn_print(f"戳一戳发生异常：{responses.status_code}")
|
||||
if successful_click == 0:
|
||||
print(f"用户【{self.account}】，===未获得 x {self.click_num}===")
|
||||
fn_print(f"用户【{self.account}】，===未获得 x {self.click_num}===")
|
||||
except Exception as e:
|
||||
print(f"戳一戳执行异常：{e}")
|
||||
fn_print(f"戳一戳执行异常：{e}")
|
||||
|
||||
async def refresh_notetoken(self):
|
||||
"""
|
||||
@ -161,7 +184,7 @@ class MobileCloudDisk:
|
||||
if response.status_code == 200:
|
||||
response.raise_for_status()
|
||||
except Exception as e:
|
||||
print('出错了:', e)
|
||||
fn_print('出错了:', e)
|
||||
return
|
||||
self.note_token = response.headers.get('NOTE_TOKEN')
|
||||
self.note_auth = response.headers.get('APP_AUTH')
|
||||
@ -189,7 +212,7 @@ class MobileCloudDisk:
|
||||
continue
|
||||
if app_type == "cloud_app":
|
||||
if task_type == "month":
|
||||
print("\n🗓️云盘每月任务")
|
||||
fn_print("\n🗓️云盘每月任务")
|
||||
for month in tasks:
|
||||
task_id = month.get("id")
|
||||
if task_id in [110, 113, 417, 409]:
|
||||
@ -198,13 +221,13 @@ class MobileCloudDisk:
|
||||
task_status = month.get("state", "")
|
||||
|
||||
if task_status == "FINISH":
|
||||
print(f"【{self.account}】，===任务【{task_name}】已完成✅✅===")
|
||||
fn_print(f"【{self.account}】，===任务【{task_name}】已完成✅✅===")
|
||||
continue
|
||||
print(f"【{self.account}】，===任务【{task_name}】待完成✒️✒️===")
|
||||
fn_print(f"【{self.account}】，===任务【{task_name}】待完成✒️✒️===")
|
||||
await self.do_task(task_id, task_type="month", app_type="cloud_app")
|
||||
await asyncio.sleep(2)
|
||||
elif task_type == "day":
|
||||
print("\n🗓️云盘每日任务")
|
||||
fn_print("\n🗓️云盘每日任务")
|
||||
for day in tasks:
|
||||
task_id = day.get("id")
|
||||
if task_id == 404:
|
||||
@ -212,13 +235,13 @@ class MobileCloudDisk:
|
||||
task_name = day.get("name", "")
|
||||
task_status = day.get("state", "")
|
||||
if task_status == "FINISH":
|
||||
print(f"【{self.account}】，===任务【{task_name}】已完成✅✅===")
|
||||
fn_print(f"【{self.account}】，===任务【{task_name}】已完成✅✅===")
|
||||
continue
|
||||
print(f"【{self.account}】，===任务【{task_name}】待完成✒️✒️===")
|
||||
fn_print(f"【{self.account}】，===任务【{task_name}】待完成✒️✒️===")
|
||||
await self.do_task(task_id, task_type="day", app_type="cloud_app")
|
||||
elif app_type == "email_app":
|
||||
if task_type == "month":
|
||||
print("\n🗓️139邮箱每月任务")
|
||||
fn_print("\n🗓️139邮箱每月任务")
|
||||
for month in tasks:
|
||||
task_id = month.get("id")
|
||||
task_name = month.get("name", "")
|
||||
@ -226,13 +249,13 @@ class MobileCloudDisk:
|
||||
if task_id in [1004, 1005, 1015, 1020]:
|
||||
continue
|
||||
if task_status == "FINISH":
|
||||
print(f"【{self.account}】，===任务【{task_name}】已完成✅✅===")
|
||||
fn_print(f"【{self.account}】，===任务【{task_name}】已完成✅✅===")
|
||||
continue
|
||||
print(f"【{self.account}】，===任务【{task_name}】待完成✒️✒️===")
|
||||
fn_print(f"【{self.account}】，===任务【{task_name}】待完成✒️✒️===")
|
||||
await self.do_task(task_id, task_type="month", app_type="email_app")
|
||||
await asyncio.sleep(2)
|
||||
except Exception as e:
|
||||
print(f"任务列表获取异常，错误信息：{e}")
|
||||
fn_print(f"任务列表获取异常，错误信息：{e}")
|
||||
|
||||
async def do_task(self, task_id, task_type, app_type):
|
||||
"""
|
||||
@ -244,7 +267,7 @@ class MobileCloudDisk:
|
||||
"""
|
||||
await self.rm_sleep()
|
||||
task_url = f'https://caiyun.feixin.10086.cn/market/signin/task/click?key=task&id={task_id}'
|
||||
task_response = await self.client.get(
|
||||
await self.client.get(
|
||||
url=task_url,
|
||||
headers=self.JwtHeaders,
|
||||
cookies=self.cookies
|
||||
@ -276,11 +299,11 @@ class MobileCloudDisk:
|
||||
if sign_in_response.status_code == 200:
|
||||
sign_in_response_data = sign_in_response.json()
|
||||
if sign_in_response_data["msg"] == "success":
|
||||
print(f"用户【{self.account}】，===签到成功✅✅===")
|
||||
fn_print(f"用户【{self.account}】，===签到成功✅✅===")
|
||||
else:
|
||||
print(sign_in_response_data)
|
||||
fn_print(sign_in_response_data)
|
||||
else:
|
||||
print(f"签到发生异常：{sign_in_response.status_code}")
|
||||
fn_print(f"签到发生异常：{sign_in_response.status_code}")
|
||||
|
||||
async def get_notebook_id(self):
|
||||
"""
|
||||
@ -320,7 +343,523 @@ class MobileCloudDisk:
|
||||
if self.notebook_id:
|
||||
await self.create_note(headers)
|
||||
else:
|
||||
print(f"获取笔记id发生异常：{note_response.status_code}")
|
||||
fn_print(f"获取笔记id发生异常：{note_response.status_code}")
|
||||
|
||||
async def wx_app_sign(self):
|
||||
"""
|
||||
微信公众号签到
|
||||
:return:
|
||||
"""
|
||||
await self.rm_sleep()
|
||||
wx_sign_url = 'https://caiyun.feixin.10086.cn/market/playoffic/followSignInfo?isWx=true'
|
||||
wx_sign_response = await self.client.get(
|
||||
url=wx_sign_url,
|
||||
headers=self.JwtHeaders,
|
||||
cookies=self.cookies
|
||||
)
|
||||
if wx_sign_response.status_code == 200:
|
||||
wx_sign_response_data = wx_sign_response.json()
|
||||
if wx_sign_response_data["msg"] == "success":
|
||||
fn_print(f"用户【{self.account}】，===微信公众号签到成功✅✅===")
|
||||
if not wx_sign_response_data["result"].get("todaySignIn"):
|
||||
fn_print(f"用户【{self.account}】，===微信公众号签到失败，可能未绑定公众号❌===")
|
||||
else:
|
||||
fn_print(f"签到发生异常：{wx_sign_response.status_code}")
|
||||
|
||||
async def shake(self):
|
||||
"""
|
||||
摇一摇
|
||||
:return:
|
||||
"""
|
||||
successful_shake = 0
|
||||
try:
|
||||
for _ in range(self.click_num):
|
||||
responses = await self.client.post(
|
||||
url="https://caiyun.feixin.10086.cn:7071/market/shake-server/shake/shakeIt?flag=1",
|
||||
headers=self.JwtHeaders,
|
||||
cookies=self.cookies
|
||||
)
|
||||
if responses.status_code == 200:
|
||||
shake_response_data = responses.json()
|
||||
await asyncio.sleep(1)
|
||||
shake_prize_config = shake_response_data["result"].get("shakePrizeConfig")
|
||||
if shake_prize_config:
|
||||
fn_print(f"用户【{self.account}】，===摇一摇成功✅✅===, 获得：{shake_prize_config['name']}🎉🎉")
|
||||
successful_shake += 1
|
||||
else:
|
||||
fn_print(f"摇一摇未中奖，{shake_response_data}")
|
||||
else:
|
||||
fn_print(f"摇一摇发生异常：{responses.status_code}")
|
||||
except Exception as e:
|
||||
fn_print(f"摇一摇执行异常：{e}")
|
||||
if successful_shake == 0:
|
||||
fn_print(f"用户【{self.account}】，===未摇中 x {self.click_num}❌===")
|
||||
|
||||
async def surplus_num(self):
|
||||
"""
|
||||
查询剩余抽奖次数
|
||||
:return:
|
||||
"""
|
||||
await self.rm_sleep()
|
||||
draw_info_url = 'https://caiyun.feixin.10086.cn/market/playoffic/drawInfo'
|
||||
draw_url = "https://caiyun.feixin.10086.cn/market/playoffic/draw"
|
||||
|
||||
draw_info_response = await self.client.get(
|
||||
url=draw_info_url,
|
||||
headers=self.JwtHeaders
|
||||
)
|
||||
if draw_info_response.status_code == 200:
|
||||
draw_info_data = draw_info_response.json()
|
||||
if draw_info_data.get('msg') == "success":
|
||||
remain_num = draw_info_data["result"].get("surplusNumber", 0)
|
||||
fn_print(f"剩余抽奖次数{remain_num}")
|
||||
if remain_num > 50 - self.draw:
|
||||
for _ in range(self.draw):
|
||||
await self.rm_sleep()
|
||||
draw_responses = await self.client.get(
|
||||
url=draw_url,
|
||||
headers=self.JwtHeaders
|
||||
)
|
||||
if draw_responses.status_code == 200:
|
||||
draw_data = draw_responses.json()
|
||||
if draw_data.get("code") == 0:
|
||||
prize_name = draw_data["result"].get("prizeName", "")
|
||||
fn_print(f"用户【{self.account}】，===抽奖成功✅✅===, 获得：{prize_name}🎉🎉")
|
||||
else:
|
||||
fn_print(f"抽奖失败了❌：{draw_data}")
|
||||
else:
|
||||
fn_print(f"抽奖发生异常：{draw_responses.status_code}")
|
||||
else:
|
||||
pass
|
||||
else:
|
||||
fn_print(f"查询剩余抽奖次数发生异常：{draw_info_data.get('msg')}")
|
||||
else:
|
||||
fn_print(f"查询剩余抽奖次数发生异常：{draw_info_response.status_code}")
|
||||
|
||||
async def fruit_login(self):
|
||||
"""
|
||||
果园
|
||||
:return:
|
||||
"""
|
||||
token = await self.refresh_token()
|
||||
if token is not None:
|
||||
fn_print(f"用户【{self.account}】，===果园专区Token刷新成功✅✅===")
|
||||
await self.rm_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'
|
||||
}
|
||||
login_info_response = await self.client.get(
|
||||
url=login_info_url,
|
||||
headers=headers
|
||||
)
|
||||
cookies = login_info_response.cookies
|
||||
# 将 Cookie 信息拆分成多个 Cookie 头
|
||||
cookies_str = f"YZKF_SESSION={urllib.parse.quote_plus(cookies['YZKF_SESSION'])}; RMKEY={urllib.parse.quote_plus(self.rmkey)}; Os_SSo_Sid={urllib.parse.quote_plus(self.Os_SSo_Sid)}"
|
||||
self.treetHeaders['Cookie'] = cookies_str
|
||||
do_login_url = f'{self.fruit_url}login/userinfo.do'
|
||||
do_login_response = await self.client.get(
|
||||
url=do_login_url,
|
||||
headers=self.treetHeaders
|
||||
)
|
||||
if do_login_response.status_code == 200:
|
||||
do_login_data = do_login_response.json()
|
||||
if do_login_data.get('result', {}).get('islogin') != 1:
|
||||
fn_print(f"用户【{self.account}】，===果园专区登录失败❌===")
|
||||
return
|
||||
await self.fruit_task()
|
||||
else:
|
||||
fn_print(f"果园专区登录请求发生异常：{do_login_response.status_code}")
|
||||
else:
|
||||
fn_print(f"用户【{self.account}】，===果园专区Token刷新失败❌===")
|
||||
|
||||
async def fruit_task(self):
|
||||
"""
|
||||
果园专区任务
|
||||
:return:
|
||||
"""
|
||||
# 签到
|
||||
check_sign_responses = await self.client.get(
|
||||
url=f"{self.fruit_url}task/checkinInfo.do",
|
||||
headers=self.treetHeaders
|
||||
)
|
||||
if check_sign_responses.status_code == 200:
|
||||
check_sign_data = check_sign_responses.json()
|
||||
if check_sign_data.get("success"):
|
||||
today_checkin = check_sign_data.get("result", {}).get("todayCheckin", 0)
|
||||
if today_checkin == 1:
|
||||
fn_print(f"用户【{self.account}】，===今日已签到☑️☑️===")
|
||||
else:
|
||||
check_in_data = await self.client.get(
|
||||
url=f"{self.fruit_url}task/checkin.do",
|
||||
headers=self.treetHeaders
|
||||
)
|
||||
if check_in_data.status_code == 200:
|
||||
check_in_data = check_in_data.json()
|
||||
if check_in_data.get("result", {}).get("code", "") == 1:
|
||||
fn_print(f"用户【{self.account}】，===签到成功✅✅===")
|
||||
await self.rm_sleep()
|
||||
water_response = await self.client.get(
|
||||
url=f'{self.fruit_url}user/clickCartoon.do?cartoonType=widget',
|
||||
headers=self.treetHeaders
|
||||
)
|
||||
if water_response.status_code == 200:
|
||||
water_data = water_response.json()
|
||||
else:
|
||||
fn_print(f"领取水滴请求发生异常：{water_response.status_code}")
|
||||
color_response = await self.client.get(
|
||||
url=f'{self.fruit_url}user/clickCartoon.do?cartoonType=color',
|
||||
headers=self.treetHeaders
|
||||
)
|
||||
if color_response.status_code == 200:
|
||||
color_data = color_response.json()
|
||||
else:
|
||||
fn_print(f"领取每日雨滴请求发生异常：{color_response.status_code}")
|
||||
given_water = water_data.get("result", {}).get("given", 0)
|
||||
fn_print(f"用户【{self.account}】，===领取每日水滴💧💧：{given_water}===")
|
||||
fn_print(f"用户【{self.account}】，===领取每日雨滴💧💧：{color_data.get('result').get('msg')}===")
|
||||
else:
|
||||
fn_print(f"用户【{self.account}】，===签到失败❌===")
|
||||
else:
|
||||
fn_print(f"签到请求发生异常：{check_in_data.status_code}")
|
||||
else:
|
||||
fn_print(f"用户【{self.account}】，===果园签到查询失败❌, {check_sign_data.get('msg')}===")
|
||||
# 获取任务列表
|
||||
task_list_responses = await self.client.get(
|
||||
url=f'{self.fruit_url}task/taskList.do?clientType=PE',
|
||||
headers=self.treetHeaders
|
||||
)
|
||||
if task_list_responses.status_code == 200:
|
||||
task_list_data = task_list_responses.json()
|
||||
task_list = task_list_data.get('result', [])
|
||||
else:
|
||||
fn_print(f"任务列表请求发生异常：{task_list_responses.status_code}")
|
||||
task_state_responses = await self.client.get(
|
||||
url=f'{self.fruit_url}task/taskState.do',
|
||||
headers=self.treetHeaders
|
||||
)
|
||||
if task_state_responses.status_code == 200:
|
||||
task_state_data = task_state_responses.json()
|
||||
task_state_result = task_state_data.get('result', [])
|
||||
else:
|
||||
fn_print(f"任务状态请求发生异常：{task_state_responses.status_code}")
|
||||
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:
|
||||
fn_print(f"用户【{self.account}】，===任务【{task_name}】已完成✅✅===")
|
||||
else:
|
||||
await self.do_fruit_task(task_name, task_id, water_num)
|
||||
await self.tree_info()
|
||||
else:
|
||||
fn_print(f"签到请求发生异常：{check_sign_responses.status_code}")
|
||||
|
||||
async def do_fruit_task(self, task_name, task_id, water_num):
|
||||
"""
|
||||
执行果园任务
|
||||
:param task_name:
|
||||
:param task_id:
|
||||
:param water_num:
|
||||
:return:
|
||||
"""
|
||||
fn_print(f"用户【{self.account}】，===任务【{task_name}】开始执行🚀🚀===")
|
||||
do_task_url = f'{self.fruit_url}task/doTask.do?taskId={task_id}'
|
||||
do_task_response = await self.client.get(
|
||||
url=do_task_url,
|
||||
headers=self.treetHeaders
|
||||
)
|
||||
if do_task_response.status_code == 200:
|
||||
do_task_data = do_task_response.json()
|
||||
if do_task_data.get("success"):
|
||||
get_water_url = f'{self.fruit_url}task/givenWater.do?taskId={task_id}'
|
||||
get_water_response = await self.client.get(
|
||||
url=get_water_url,
|
||||
headers=self.treetHeaders
|
||||
)
|
||||
if get_water_response.status_code == 200:
|
||||
get_water_data = get_water_response.json()
|
||||
if get_water_data.get("success"):
|
||||
fn_print(f"用户【{self.account}】，===已完成任务【{task_name}】✅✅，领取水滴: {water_num}===")
|
||||
else:
|
||||
fn_print(
|
||||
f"用户【{self.account}】，===任务【{task_name}】领取水滴失败❌, {get_water_data.get('msg')}===")
|
||||
else:
|
||||
fn_print(f"领取水滴请求发生异常：{get_water_response.status_code}")
|
||||
else:
|
||||
fn_print(f"用户【{self.account}】，===任务【{task_name}】执行失败❌, {do_task_data.get('msg')}===")
|
||||
else:
|
||||
fn_print(f"任务执行请求发生异常：{do_task_response.status_code}")
|
||||
|
||||
async def tree_info(self):
|
||||
"""
|
||||
查询果园信息
|
||||
:return:
|
||||
"""
|
||||
tree_info_url = f'{self.fruit_url}user/treeInfo.do'
|
||||
tree_info_responses = await self.client.get(
|
||||
url=tree_info_url,
|
||||
headers=self.treetHeaders
|
||||
)
|
||||
if tree_info_responses.status_code == 200:
|
||||
tree_info_data = tree_info_responses.json()
|
||||
if not tree_info_data.get("success"):
|
||||
fn_print(f"用户【{self.account}】，===获取果园任务列表失败❌, {tree_info_data.get('msg')}===")
|
||||
else:
|
||||
collect_water = tree_info_data.get("result", {}).get("collectWater", 0)
|
||||
tree_level = tree_info_data.get("result", {}).get("treeLevel", 0)
|
||||
fn_print(f"用户【{self.account}】，===当前小树等级：{tree_level}，剩余水滴：{collect_water}===")
|
||||
if tree_level in (2, 4, 6, 8):
|
||||
# 开宝箱
|
||||
openbox_url = f'{self.fruit_url}prize/openBox.do'
|
||||
openbox_response = await self.client.get(
|
||||
url=openbox_url,
|
||||
headers=self.treetHeaders
|
||||
)
|
||||
if openbox_response.status_code == 200:
|
||||
openbox_data = openbox_response.json()
|
||||
fn_print(f"用户【{self.account}】，==={openbox_data.get('msg')}===")
|
||||
else:
|
||||
fn_print(f"开宝箱请求发生异常：{openbox_response.status_code}")
|
||||
watering_amout = collect_water // 20 # 计算需要浇水的次数
|
||||
watering_url = f'{self.fruit_url}user/watering.do?isFast=0'
|
||||
if watering_amout > 0:
|
||||
for index in range(watering_amout):
|
||||
watering_response = await self.client.get(
|
||||
url=watering_url,
|
||||
headers=self.treetHeaders
|
||||
)
|
||||
if watering_response.status_code == 200:
|
||||
watering_data = watering_response.json()
|
||||
if watering_data.get("success"):
|
||||
fn_print(f"用户【{self.account}】，===已完成{index + 1}次浇水🌊🌊===")
|
||||
else:
|
||||
fn_print(f"用户【{self.account}】，===浇水失败❌, {watering_data.get('msg')}===")
|
||||
await asyncio.sleep(3)
|
||||
else:
|
||||
fn_print(f"浇水请求发生异常：{watering_response.status_code}")
|
||||
else:
|
||||
fn_print(f"用户【{self.account}】，===水滴不足，无法浇水❌===")
|
||||
else:
|
||||
fn_print(f"查询果园信息请求发生异常：{tree_info_responses.status_code}")
|
||||
|
||||
async def cloud_game(self):
|
||||
"""
|
||||
云朵大作战
|
||||
:return:
|
||||
"""
|
||||
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_response = await self.client.get(
|
||||
url=game_info_url,
|
||||
headers=self.JwtHeaders,
|
||||
cookies=self.cookies
|
||||
)
|
||||
if game_info_response.status_code == 200:
|
||||
game_info_data = game_info_response.json()
|
||||
if game_info_data and game_info_data.get("code", -1) == 0:
|
||||
curr_num = 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", '')
|
||||
fn_print(f"今日剩余游戏次数：{curr_num}\n本月排名：{rank}\n合成次数：{count}")
|
||||
for _ in range(curr_num):
|
||||
await self.client.get(
|
||||
url=bigin_url,
|
||||
headers=self.JwtHeaders,
|
||||
cookies=self.cookies
|
||||
)
|
||||
fn_print("开始游戏， 等待10-15秒完成游戏")
|
||||
await asyncio.sleep(random.randint(10, 15))
|
||||
end_response = await self.client.get(
|
||||
url=end_url,
|
||||
headers=self.JwtHeaders,
|
||||
cookies=self.cookies
|
||||
)
|
||||
if end_response.status_code == 200:
|
||||
end_data = end_response.json()
|
||||
if end_data and end_data.get("code", -1) == 0:
|
||||
fn_print(f"用户【{self.account}】，===云朵大作战游戏成功✅✅===")
|
||||
else:
|
||||
fn_print(f"用户【{self.account}】，===云朵大作战游戏失败❌===")
|
||||
else:
|
||||
fn_print(f"用户【{self.account}】，===获取云朵大作战游戏信息失败❌===")
|
||||
else:
|
||||
fn_print(f"用户【{self.account}】，===获取云朵大作战游戏信息失败❌===")
|
||||
else:
|
||||
fn_print(f"云朵大作战请求发生异常：{game_info_response.status_code}")
|
||||
|
||||
async def receive(self):
|
||||
"""
|
||||
领取云朵
|
||||
:return:
|
||||
"""
|
||||
recevice_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_response = await self.client.get(
|
||||
url=recevice_url,
|
||||
headers=self.JwtHeaders,
|
||||
cookies=self.cookies
|
||||
)
|
||||
if receive_response.status_code == 200:
|
||||
receive_data = receive_response.json()
|
||||
await self.rm_sleep()
|
||||
else:
|
||||
fn_print(f"领取云朵请求发生异常：{receive_response.status_code}")
|
||||
prize_response = await self.client.get(
|
||||
url=prize_url,
|
||||
headers=self.JwtHeaders,
|
||||
cookies=self.cookies
|
||||
)
|
||||
if prize_response.status_code == 200:
|
||||
prize_data = prize_response.json()
|
||||
result = prize_data.get("result").get("result")
|
||||
rewards = ""
|
||||
for value in result:
|
||||
prize_name = value.get("prizeName")
|
||||
flag = value.get("flag")
|
||||
if flag == 1:
|
||||
rewards += f"待领取奖品：{prize_name}\n"
|
||||
receive_amout = receive_data["result"].get("receive", "")
|
||||
total_amout = receive_data["result"].get("total", "")
|
||||
fn_print(f"\n用户【{self.account}】，===当前待领取{receive_amout}个云朵===")
|
||||
fn_print(f"用户【{self.account}】，===当前云朵数量：{total_amout}个===")
|
||||
fn_print(f"用户【{self.account}】，===云朵数量：{total_amout}个，{rewards}===")
|
||||
else:
|
||||
fn_print(f"领取奖品请求发生异常：{prize_response.status_code}")
|
||||
|
||||
async def backup_cloud(self):
|
||||
"""
|
||||
备份云朵
|
||||
:return:
|
||||
"""
|
||||
backup_url = 'https://caiyun.feixin.10086.cn/market/backupgift/info'
|
||||
backup_response = await self.client.get(
|
||||
url=backup_url,
|
||||
headers=self.JwtHeaders
|
||||
)
|
||||
if backup_response.status_code == 200:
|
||||
backup_data = backup_response.json()
|
||||
state = backup_data.get("result", {}).get("state", {})
|
||||
if state == -1:
|
||||
fn_print(f"用户【{self.account}】，===本月未备份，暂无连续备份奖励❌===")
|
||||
elif state == 0:
|
||||
fn_print(f"用户【{self.account}】，===领取本月连续备份奖励===")
|
||||
cur_url = 'https://caiyun.feixin.10086.cn/market/backupgift/receive'
|
||||
cur_response = await self.client.get(
|
||||
url=cur_url,
|
||||
headers=self.JwtHeaders
|
||||
)
|
||||
if cur_response.status_code == 200:
|
||||
cur_data = cur_response.json()
|
||||
fn_print(f"用户【{self.account}】，===获得云朵数量：{cur_data.get('result').get('result')}===")
|
||||
else:
|
||||
fn_print(f"用户【{self.account}】，===获取云朵数量请求失败❌，{cur_response.status_code}===")
|
||||
elif state == 1:
|
||||
fn_print(f"用户【{self.account}】，===已领取本月连续备份奖励===")
|
||||
else:
|
||||
fn_print(f"用户【{self.account}】，===获取本月连续备份奖励状态异常❌，{backup_data}===")
|
||||
else:
|
||||
fn_print(f"用户【{self.account}】，===领取本月连续备份奖励请求失败❌，{backup_response.status_code}===")
|
||||
await self.rm_sleep()
|
||||
# 每月膨胀云朵
|
||||
expend_url = 'https://caiyun.feixin.10086.cn/market/signin/page/taskExpansion'
|
||||
expend_response = await self.client.get(
|
||||
url=expend_url,
|
||||
headers=self.JwtHeaders
|
||||
)
|
||||
if expend_response.status_code == 200:
|
||||
expend_data = expend_response.json()
|
||||
else:
|
||||
fn_print(f"用户【{self.account}】，===每月膨胀云朵请求失败❌，{expend_response.status_code}===")
|
||||
cur_month_backup = expend_data.get("result", {}).get("curMonthBackup", "") # 本月备份
|
||||
pre_month_backup = expend_data.get("result", {}).get("preMonthBackup", "") # 上月备份
|
||||
cur_month_backup_task_accept = expend_data.get("result", {}).get("curMonthBackupTaskAccept", "") # 本月是否领取
|
||||
next_month_backup_task_record_count = expend_data.get("result", {}).get("nextMonthBackupTaskRecordCount",
|
||||
"") # 下月备份云朵
|
||||
accept_date = expend_data.get("result", {}).get("aeptDate", "") # 月份
|
||||
|
||||
if cur_month_backup:
|
||||
fn_print(f"用户【{self.account}】，===本月已备份，下月可领取膨胀云朵: {next_month_backup_task_record_count}===")
|
||||
else:
|
||||
fn_print(f"用户【{self.account}】，===本月未备份，下月暂无膨胀云朵===")
|
||||
|
||||
if pre_month_backup:
|
||||
if cur_month_backup_task_accept:
|
||||
fn_print(f"用户【{self.account}】，===上月已备份，膨胀云朵已领取===")
|
||||
else:
|
||||
receive_url = f'https://caiyun.feixin.10086.cn/market/signin/page/receiveTaskExpansion?acceptDate={accept_date}'
|
||||
receive_response = await self.client.get(
|
||||
url=receive_url,
|
||||
headers=self.JwtHeaders,
|
||||
cookies=self.cookies
|
||||
)
|
||||
if receive_response.status_code == 200:
|
||||
receive_data = receive_response.json()
|
||||
if receive_data.get("code") != 0:
|
||||
fn_print(f"用户【{self.account}】，===领取膨胀云朵失败❌，{receive_data.get('msg')}===")
|
||||
else:
|
||||
fn_print(
|
||||
f"用户【{self.account}】，===领取膨胀云朵成功✅✅, {receive_data.get('result', {}).get('cloudCount'), ''}朵===")
|
||||
else:
|
||||
fn_print(f"用户【{self.account}】，===领取膨胀云朵请求失败❌，{receive_response.status_code}===")
|
||||
else:
|
||||
fn_print(f"用户【{self.account}】，===上月未备份，本月暂无膨胀云朵===")
|
||||
|
||||
async def open_send(self):
|
||||
"""
|
||||
通知云朵
|
||||
:return:
|
||||
"""
|
||||
send_url = 'https://caiyun.feixin.10086.cn/market/msgPushOn/task/status'
|
||||
send_response = await self.client.get(
|
||||
url=send_url,
|
||||
headers=self.JwtHeaders
|
||||
)
|
||||
if send_response.status_code == 200:
|
||||
send_data = send_response.json()
|
||||
push_on = send_data.get("result", {}).get("pushOn", "") # 0未开启，1开启，2未领取，3已领取
|
||||
first_task_status = send_data.get("result", {}).get("firstTaskStatus", "")
|
||||
second_task_status = send_data.get("result", {}).get("secondTaskStatus", "")
|
||||
on_duaration = send_data.get("result", {}).get("onDuration", "") # 开启时间
|
||||
if push_on == 1:
|
||||
reward_url = 'https://caiyun.feixin.10086.cn/market/msgPushOn/task/obtain'
|
||||
if first_task_status == 3:
|
||||
fn_print(f"用户【{self.account}】，===领取任务1奖励成功✅✅===")
|
||||
else:
|
||||
reward_response = await self.client.post(
|
||||
url=reward_url,
|
||||
headers=self.JwtHeaders,
|
||||
json={"type": 1}
|
||||
)
|
||||
if reward_response.status_code == 200:
|
||||
reward_data = reward_response.json()
|
||||
fn_print(f"用户【{self.account}】，===领取任务1奖励成功✅✅===")
|
||||
else:
|
||||
fn_print(f"用户【{self.account}】，===领取任务1奖励请求失败❌，{reward_response.status_code}===")
|
||||
if second_task_status == 2:
|
||||
reward2_response = await self.client.post(
|
||||
url=reward_url,
|
||||
headers=self.JwtHeaders,
|
||||
json={"type": 2}
|
||||
)
|
||||
if reward2_response.status_code == 200:
|
||||
reward_data = reward2_response.json()
|
||||
fn_print(f"用户【{self.account}】，===领取任务2奖励成功✅✅===")
|
||||
else:
|
||||
fn_print(f"用户【{self.account}】，===领取任务2奖励请求失败❌，{reward2_response.status_code}===")
|
||||
fn_print(f"用户【{self.account}】，===通知已开启天数: {on_duaration}, 满31天可领取奖励===")
|
||||
else:
|
||||
fn_print(f"用户【{self.account}】，===未开启通知权限===")
|
||||
else:
|
||||
fn_print(f"用户【{self.account}】，===开启通知云朵请求失败❌，{send_response.status_code}===")
|
||||
|
||||
async def create_note(self, headers):
|
||||
"""
|
||||
@ -384,9 +923,9 @@ class MobileCloudDisk:
|
||||
json=payload
|
||||
)
|
||||
if create_note_response.status_code == 200:
|
||||
print(f"用户【{self.account}】，===创建笔记成功✅✅===")
|
||||
fn_print(f"用户【{self.account}】，===创建笔记成功✅✅===")
|
||||
else:
|
||||
print(f"创建笔记发生异常：{create_note_response.status_code}")
|
||||
fn_print(f"创建笔记发生异常：{create_note_response.status_code}")
|
||||
|
||||
async def upload_file(self):
|
||||
"""
|
||||
@ -413,8 +952,8 @@ class MobileCloudDisk:
|
||||
if response is None:
|
||||
return
|
||||
if response.status_code != 200:
|
||||
print(f"上传文件发生异常：{response.status_code}")
|
||||
print(f"用户【{self.account}】，===上传文件成功✅✅===")
|
||||
fn_print(f"上传文件发生异常：{response.status_code}")
|
||||
fn_print(f"用户【{self.account}】，===上传文件成功✅✅===")
|
||||
|
||||
async def rm_sleep(self, min_delay=1, max_delay=1.5):
|
||||
delay = random.uniform(min_delay, max_delay)
|
||||
@ -427,21 +966,37 @@ class MobileCloudDisk:
|
||||
|
||||
async def run(self):
|
||||
if await self.jwt():
|
||||
print("=========开始签到=========")
|
||||
fn_print("=========开始签到=========")
|
||||
await self.query_sign_in_status()
|
||||
print("=========开始执行戳一戳=========")
|
||||
fn_print("=========开始执行戳一戳=========")
|
||||
await self.a_poke()
|
||||
await self.get_task_list(url="sign_in_3", app_type="cloud_app")
|
||||
print("=========开始执行☁️云朵大作战=========")
|
||||
# todo
|
||||
|
||||
fn_print("=========开始执行☁️云朵大作战=========")
|
||||
await self.cloud_game()
|
||||
fn_print("=========开始执行🌳果园任务=========")
|
||||
await self.fruit_login()
|
||||
fn_print("=========开始执行📝公众号任务=========")
|
||||
await self.wx_app_sign()
|
||||
await self.shake()
|
||||
await self.surplus_num()
|
||||
fn_print("=========开始执行🔥热门任务=========")
|
||||
await self.backup_cloud()
|
||||
await self.open_send()
|
||||
fn_print("=========开始执行📮139邮箱任务=========")
|
||||
await self.get_task_list(url="newsign_139mail", app_type="email_app")
|
||||
await self.receive()
|
||||
else:
|
||||
fn_print("token失效")
|
||||
|
||||
|
||||
async def main():
|
||||
ck = "Basic bW9iaWxlOjE4NTgyODUyMjYzOkdPVHpqTnRtfDF8UkNTfDE3MzMyOTcwODYzMzZ8UGdPVkZ6V1JWYjdSRjJ1Y3pNejNJd1o5b3FiYzJzNmw5QVdWMTlNZk1HdEt4LndXa2t4SkE2cmZEcGZWaUNBU1UyVW94dW9zSXNnZUxUVk9IWnczajd5Q1AzNnM3SEk5MDhFMDRRVm1FVjcwTWJjQXNDU3pLcEV0UlRpQ1pkUVFnUUdZcXpCVW5IeDhQak55QW1UbTRFb2pvQkRxMVBqVHdCcXBuZnNCTDFvLQ==#18582852263#STuid0000011730705776084kKnQ1rbi1wnexE5CovnoFuxLUtnkrgLL"
|
||||
mobileCloudDisk = MobileCloudDisk(ck)
|
||||
await mobileCloudDisk.run()
|
||||
tasks = []
|
||||
for ck in ydyp_ck:
|
||||
mobileCloudDisk = MobileCloudDisk(ck)
|
||||
tasks.append(mobileCloudDisk.run())
|
||||
await asyncio.gather(*tasks)
|
||||
|
||||
|
||||
if __name__ == '__main__':
|
||||
asyncio.run(main())
|
||||
send_notification_message_collection(f"中国移动云盘签到通知 - {datetime.now().strftime('%Y/%m/%d')}")
|
||||
|
||||
Loading…
Reference in New Issue
Block a user