From 185acb7fe00615c4a5d450e5f7cc69fc44809c0d Mon Sep 17 00:00:00 2001 From: xtaodada Date: Fri, 28 Jan 2022 21:48:51 +0800 Subject: [PATCH] =?UTF-8?q?=E2=9C=A8=20v0.3.3=20=E6=94=AF=E6=8C=81?= =?UTF-8?q?=E7=B1=B3=E6=B8=B8=E7=A4=BE=E7=9C=8B=E3=80=81=E5=88=86=E4=BA=AB?= =?UTF-8?q?=E5=B8=96=E4=BB=BB=E5=8A=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- README.md | 5 +- defs/db.py | 19 ++++- defs/mys2.py | 5 +- defs/mysbbs.py | 197 +++++++++++++++++++++++++++++++++++++++++++++++ plugins/start.py | 2 +- 5 files changed, 223 insertions(+), 5 deletions(-) create mode 100644 defs/mysbbs.py diff --git a/README.md b/README.md index b6cb51d..f5a932e 100644 --- a/README.md +++ b/README.md @@ -39,7 +39,9 @@ Bot 实例: [@Genshin_All_Info_Bot](https://t.me/Genshin_All_Info_Bot) ## 特别感谢 -[genshinstats](https://github.com/thesadru/genshinstats/) +[AutoMihoyoBBS](https://github.com/Womsxd/AutoMihoyoBBS) + +[genshinstats](https://github.com/thesadru/genshinstats) [GenshinUID](https://github.com/KimigaiiWuyi/GenshinUID) @@ -48,4 +50,3 @@ Bot 实例: [@Genshin_All_Info_Bot](https://t.me/Genshin_All_Info_Bot) [PaimonBot](https://github.com/XiaoMiku01/PaimonBot) [YuanShen_User_Info](https://github.com/Womsxd/YuanShen_User_Info) - diff --git a/defs/db.py b/defs/db.py index 0455c66..05eeb74 100644 --- a/defs/db.py +++ b/defs/db.py @@ -10,6 +10,7 @@ from shutil import copyfile import requests from ci import client +from defs.mysbbs import MihoyoBbs mhyVersion = "2.11.1" @@ -50,7 +51,7 @@ async def deal_ck(mes, qid): mysid_data = aid.group(0).split('=') mysid = mysid_data[1] cookie = ';'.join(filter(lambda x: x.split('=')[0] in [ - "cookie_token", "account_id"], [i.strip() for i in mes.split(';')])) + "cookie_token", "account_id", "login_ticket", "stoken"], [i.strip() for i in mes.split(';')])) mys_data = await GetMysInfo(mysid, cookie) for i in mys_data['data']['list']: if i['game_id'] != 2: @@ -257,6 +258,22 @@ async def GetSignInfo(Uid, ServerID="cn_gf01"): print("获取签到信息失败，请重试") +async def MybSign(Uid): + try: + bbs = MihoyoBbs(await OwnerCookies(Uid)) + if bbs.Task_do["bbs_Read_posts"] and bbs.Task_do["bbs_Share"]: + return f"今天已经全部完成了！一共获得{bbs.Today_have_getcoins}个米游币，目前有{bbs.Have_coins}个米游币" + await bbs.read_posts() + await bbs.share_post() + bbs.Get_taskslist() + return f"今天已经获得{bbs.Today_have_getcoins}个米游币，还能获得{bbs.Today_getcoins}个米游币，目前有{bbs.Have_coins}个米游币" + except Exception as e: + if str(e).find("Cookie 缺失") != -1: + return "Cookie 缺失 login_ticket，无法运行米游币任务。" + traceback.print_exc() + print("获取米游社任务信息失败，请重试") + + async def GetSignList(): try: req = await client.get( diff --git a/defs/mys2.py b/defs/mys2.py index cdffab9..18deac5 100644 --- a/defs/mys2.py +++ b/defs/mys2.py @@ -11,7 +11,7 @@ from PIL import Image, ImageDraw, ImageFilter from pyrogram.types import Message from defs.db import GetAward, MysSign, GetSignInfo, GetSignList, GetDaily, cacheDB, GetMysInfo, \ - errorDB, GetCharacter, GetInfo, GetSpiralAbyssInfo + errorDB, GetCharacter, GetInfo, GetSpiralAbyssInfo, MybSign from defs.event import ys_font WEAPON_PATH = os.path.join("assets", 'weapon') @@ -120,6 +120,7 @@ async def award(uid): # 签到函数 async def sign(uid): try: + # 任务签到 sign_data = await MysSign(uid) sign_info = await GetSignInfo(uid) sign_info = sign_info['data'] @@ -136,6 +137,8 @@ async def sign(uid): mes_im = status sign_missed = sign_info['sign_cnt_missed'] im = mes_im + "!" + "\n" + get_im + "\n" + f"本月漏签次数：{sign_missed}" + # 米游币 + im += "\n============\n" + await MybSign(uid) except: im = "签到失败，请检查Cookies是否失效。" return im diff --git a/defs/mysbbs.py b/defs/mysbbs.py new file mode 100644 index 0000000..e36fc4d --- /dev/null +++ b/defs/mysbbs.py @@ -0,0 +1,197 @@ +import asyncio +import hashlib +import string +import time +import uuid +import requests +import random +# md5计算 + + +def md5(text: str) -> str: + md5 = hashlib.md5() + md5.update(text.encode()) + return md5.hexdigest() + + +# 随机文本 +def random_text(num: int) -> str: + return ''.join(random.sample(string.ascii_lowercase + string.digits, num)) + + +# 时间戳 +def timestamp() -> int: + return int(time.time()) + + +# 获取请求Header里的DS 当web为true则生成网页端的DS +def get_ds() -> str: + n = "fd3ykrh7o1j54g581upo1tvpam0dsgtf" + i = str(timestamp()) + r = random_text(6) + c = md5("salt=" + n + "&t=" + i + "&r=" + r) + return f"{i},{r},{c}" + + +# 生成一个device id +def get_device_id(ck) -> str: + return str(uuid.uuid3(uuid.NAMESPACE_URL, ck)).replace( + '-', '').upper() + + +class MihoyoBbs: + def __init__(self, ck): + if "login_ticket" not in ck: + raise Exception("Cookie 缺失 login_ticket") + if "stoken" not in ck: + # 登录操作 + temp_Cookies = ck.split(";") + for i in temp_Cookies: + if i.split("=")[0] == "login_ticket": + self.mihoyobbs_Login_ticket = i.split("=")[1] + if i.split("=")[0] == "account_id": + self.mihoyobbs_Stuid = i.split("=")[1] + # 直接拿cookie里面的Uid + data = requests.get(url="https://api-takumi.mihoyo.com/auth/api/getMultiTokenByLoginTicket" + "?login_ticket={}&token_types=3&" + "uid={}".format(self.mihoyobbs_Login_ticket, self.mihoyobbs_Stuid)).json() + try: + self.mihoyobbs_Stoken = data["data"]["list"][0]["token"] + except TypeError: + raise Exception("Cookie 缺失 login_ticket") + else: + temp_Cookies = ck.split(";") + for i in temp_Cookies: + if i.split("=")[0] == "account_id": + self.mihoyobbs_Stuid = i.split("=")[1] + if i.split("=")[0] == "stoken": + self.mihoyobbs_Stoken = i.split("=")[1] + self.headers = { + "DS": get_ds(), + "cookie": f"stuid={self.mihoyobbs_Stuid};stoken={self.mihoyobbs_Stoken}", + "x-rpc-client_type": "2", + "x-rpc-app_version": "2.7.0", + "x-rpc-sys_version": "6.0.1", + "x-rpc-channel": "mihoyo", + "x-rpc-device_id": get_device_id(ck), + "x-rpc-device_name": random_text(random.randint(1, 10)), + "x-rpc-device_model": "Mi 10", + "Referer": "https://app.mihoyo.com", + "Host": "bbs-api.mihoyo.com", + "User-Agent": "okhttp/4.8.0" + } + self.Task_do = { + "bbs_Sign": False, + "bbs_Read_posts": False, + "bbs_Read_posts_num": 3, + "bbs_Like_posts": False, + "bbs_Like_posts_num": 5, + "bbs_Share": False + } + self.Today_getcoins = 0 + self.Today_have_getcoins = 0 + self.Have_coins = 0 + self.Get_taskslist() + # 如果这三个任务都做了就没必要获取帖子了 + if self.Task_do["bbs_Read_posts"] and self.Task_do["bbs_Share"]: + pass + else: + self.postsList = self.get_list() + + # 获取任务列表，用来判断做了哪些任务 + def Get_taskslist(self): + # log.info("正在获取任务列表") + req = requests.get(url="https://bbs-api.mihoyo.com/apihub/sapi/getUserMissionsState", headers=self.headers) + data = req.json() + if "err" in data["message"] or data["retcode"] == -100: + # log.error("获取任务列表失败，你的cookie可能已过期，请重新设置cookie。") + raise Exception("获取任务列表失败，你的cookie可能已过期，请重新设置cookie。") + else: + self.Today_getcoins = data["data"]["can_get_points"] + self.Today_have_getcoins = data["data"]["already_received_points"] + self.Have_coins = data["data"]["total_points"] + # 如果当日可获取米游币数量为0直接判断全部任务都完成了 + if self.Today_getcoins == 0: + self.Task_do["bbs_Sign"] = True + self.Task_do["bbs_Read_posts"] = True + self.Task_do["bbs_Like_posts"] = True + self.Task_do["bbs_Share"] = True + else: + # 如果第0个大于或等于62则直接判定任务没做 + if data["data"]["states"][0]["mission_id"] >= 62: + # log.info(f"新的一天，今天可以获得{Today_getcoins}个米游币") + pass + else: + # log.info(f"似乎还有任务没完成，今天还能获得{Today_getcoins}") + for i in data["data"]["states"]: + # # 58是讨论区签到 + # if i["mission_id"] == 58: + # if i["is_get_award"]: + # self.Task_do["bbs_Sign"] = True + # 59是看帖子 + if i["mission_id"] == 59: + if i["is_get_award"]: + self.Task_do["bbs_Read_posts"] = True + else: + self.Task_do["bbs_Read_posts_num"] -= i["happened_times"] + # 60是给帖子点赞 + # elif i["mission_id"] == 60: + # if i["is_get_award"]: + # self.Task_do["bbs_Like_posts"] = True + # else: + # self.Task_do["bbs_Like_posts_num"] -= i["happened_times"] + # 61是分享帖子 + elif i["mission_id"] == 61: + if i["is_get_award"]: + self.Task_do["bbs_Share"] = True + # 分享帖子，是最后一个任务，到这里了下面都是一次性任务，直接跳出循环 + break + + # 获取帖子列表 + def get_list(self) -> list: + temp_list = [] + # log.info("正在获取帖子列表......") + req = requests.get(url="https://bbs-api.mihoyo.com/post/api/getForumPostList?forum_id=" + "5&is_good=false&is_hot=false&page_size=20&sort_type=1", headers=self.headers) + data = req.json() + for n in range(5): + temp_list.append([data["data"]["list"][n]["post"]["post_id"], data["data"]["list"][n]["post"]["subject"]]) + # log.info("已获取{}个帖子".format(len(temp_list))) + return temp_list + + # 看帖子 + async def read_posts(self): + if self.Task_do["bbs_Read_posts"]: + pass + # log.info("看帖任务已经完成过了~") + else: + # log.info("正在看帖......") + for i in range(self.Task_do["bbs_Read_posts_num"]): + req = requests.get( + url="https://bbs-api.mihoyo.com/post/api/getPostFull?post_id={}".format(self.postsList[i][0]), + headers=self.headers) + data = req.json() + if data["message"] == "OK": + pass + # log.debug("看帖：{} 成功".format(self.postsList[i][1])) + await asyncio.sleep(random.randint(1, 2)) + + # 分享操作 + async def share_post(self): + if self.Task_do["bbs_Share"]: + pass + # log.info("分享任务已经完成过了~") + else: + # log.info("正在执行分享任务......") + for i in range(3): + req = requests.get( + url="https://bbs-api.mihoyo.com/apihub/api/getShareConf?entity_id={}&entity_type=1".format( + self.postsList[0][0]), headers=self.headers) + data = req.json() + if data["message"] == "OK": + # log.debug("分享：{} 成功".format(self.postsList[0][1])) + # log.info("分享任务执行成功......") + break + else: + # log.debug(f"分享任务执行失败，正在执行第{i+2}次，共3次") + await asyncio.sleep(random.randint(1, 2)) diff --git a/plugins/start.py b/plugins/start.py index 7807cca..9c79e2a 100644 --- a/plugins/start.py +++ b/plugins/start.py @@ -2,7 +2,7 @@ from ci import admin_id from pyrogram import Client from pyrogram.types import Message, CallbackQuery, InlineKeyboardMarkup, InlineKeyboardButton -HELP_MSG_PRE = 'PaimonBot 0.3.2beta By Xtao-Labs\n\n' \ +HELP_MSG_PRE = 'PaimonBot 0.3.3beta By Xtao-Labs\n\n' \ '🔅 以下是小派蒙我学会了的功能（部分）：\n' HELP_MSG = """① [武器/今日武器] 查看今日武器材料和武器 ② [天赋/今日天赋] 查看今日天赋材料和角色