diff --git a/中国移动云盘.py b/中国移动云盘.py index ef443e3..6ebdfd7 100644 --- a/中国移动云盘.py +++ b/中国移动云盘.py @@ -5,14 +5,40 @@ # @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 + +os.environ['ydyp_ck'] = ( + "Basic bW9iaWxlOjE4NTgyODUyMjYzOkdPVHpqTnRtfDF8UkNTfDE3MzMyOTcwODYzMzZ8UGdPVkZ6V1JWYjdSRjJ1Y3pNejNJd1o5b3FiYzJzNmw5QVdWMTlNZk1HdEt4LndXa2t4SkE2cmZEcGZWaUNBU1UyVW94dW9zSXNnZUxUVk9IWnczajd5Q1AzNnM3SEk5MDhFMDRRVm1FVjcwTWJjQXNDU3pLcEV0UlRpQ1pkUVFnUUdZcXpCVW5IeDhQak55QW1UbTRFb2pvQkRxMVBqVHdCcXBuZnNCTDFvLQ==" + "#18582852263" + "#STuid0000011730705776084kKnQ1rbi1wnexE5CovnoFuxLUtnkrgLL" + "#b94fd25a57faed94" + "#00czMDk3NzU1OTAwMTQ3MDQx0421561D000004" +) 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 +53,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 +66,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 +89,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 +102,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 +126,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 +150,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 +190,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 +218,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 +227,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 +241,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 +255,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 +273,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 +305,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 +349,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 +929,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 +958,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 +972,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')}")