From 4db9fdf24e0e4904a89e068f3655b4b9fdfea555 Mon Sep 17 00:00:00 2001 From: ctrlcvs <1509167646@qq.com> Date: Mon, 29 May 2023 21:34:14 +0800 Subject: [PATCH] =?UTF-8?q?=E6=A0=BC=E5=BC=8F=E5=8C=96=E9=83=A8=E5=88=86?= =?UTF-8?q?=E5=86=85=E5=AE=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- model/mys/utils.js | 8 +- model/user.js | 1715 ++++++++++++++++++++++---------------------- 2 files changed, 872 insertions(+), 851 deletions(-) diff --git a/model/mys/utils.js b/model/mys/utils.js index 6849ff4..a5bd0cb 100644 --- a/model/mys/utils.js +++ b/model/mys/utils.js @@ -120,10 +120,10 @@ export async function getCookieMap(cookie) { */ export function recallMsg(e,r,times){ setTimeout(()=>{ - if(e?.group?.recallMsg){ - e?.group?.recallMsg(r.message_id) - }else if(e?.friend?.recallMsg){ - e?.friend?.recallMsg(r.message_id) + if(e?.group?.recallMsg&&r?.message_id){ + e?.group?.recallMsg(r?.message_id) + }else if(e?.friend?.recallMsg&&r?.message_id){ + e?.friend?.recallMsg(r?.message_id) } },1000 * times) } diff --git a/model/user.js b/model/user.js index 7f1f6fe..4ee020c 100644 --- a/model/user.js +++ b/model/user.js @@ -5,13 +5,14 @@ import lodash from 'lodash' import utils from '../model/mys/utils.js'; import gsCfg from './gsCfg.js'; import { - isV3 + isV3 } from '../components/Changelog.js'; import { - Cfg, - Data + Cfg, + Data } from "../components/index.js"; import moment from 'moment' + const _path = process.cwd(); const plugin = "xiaoyao-cvs-plugin" const nameData = ["原神", "崩坏3", "崩坏2", "未定事件簿"]; @@ -22,855 +23,875 @@ let cloudTask = false; let mysTask = false; /** 配置文件 */ export default class user { - constructor(e) { - this.e = e; - this.stokenPath = `./plugins/${plugin}/data/yaml/` - this.yunPath = `./plugins/${plugin}/data/yunToken/`; - Data.createDir("", this.yunPath, false) - this.ForumData = Data.readJSON(`${_path}/plugins/xiaoyao-cvs-plugin/defSet/json`, "mys") - this.configSign = gsCfg.getfileYaml(`${_path}/plugins/xiaoyao-cvs-plugin/config/`, "config"); - this.configSign.signlist = this.configSign.signlist || "原神|崩坏3|崩坏2|未定事件簿".split("|") - this.getToken = this.configSign.getToken || '' - this.getyunToken(this.e) - } + constructor(e) { + this.e = e; + this.stokenPath = `./plugins/${plugin}/data/yaml/` + this.yunPath = `./plugins/${plugin}/data/yunToken/`; + Data.createDir("", this.yunPath, false) + this.ForumData = Data.readJSON(`${_path}/plugins/xiaoyao-cvs-plugin/defSet/json`, "mys") + this.configSign = gsCfg.getfileYaml(`${_path}/plugins/xiaoyao-cvs-plugin/config/`, "config"); + this.configSign.signlist = this.configSign.signlist || "原神|崩坏3|崩坏2|未定事件簿".split("|") + this.getToken = this.configSign.getToken || '' + this.getyunToken(this.e) + } - async getCkData() { - let sumData = {}; - let yunres = await this.cloudSeach(); - let yundata = yunres.data - if (yunres.retcode === 0) { - sumData["云原神"] = { - "今日可获取": yundata?.coin?.free_coin_num, - "米云币": yundata?.coin?.coin_num, - "免费时长": yundata?.free_time?.free_time, - "总时长": yundata.total_time - } - } - let mysres = await this.bbsSeachSign(); - if (mysres.retcode === 0) { - sumData["米游社"] = { - "米游币任务": mysres.data.can_get_points != 0 ? "未完成" : "已完成", - "米游币余额": mysres.data.total_points, - "今日剩余可获取": mysres.data.can_get_points - } - } - let resSign = await this.multiSign(this.ForumData); - if (resSign?.upData) { - for (let item of resSign?.upData) { - let num = lodash.random(0, 9999); - item.upName = item.upName == "原神" ? "ys" : item.upName == "崩坏3" ? "bh3" : item.upName == - "崩坏2" ? "bh2" : item.upName == "未定事件簿" ? "wdy" : item.upName - sumData[item.upName + "" + num] = { - "uid": item.game_uid, - "游戏昵称": item.nickname, - "等级": item.level, - "今日签到": item.is_sign ? "已签到" : "未签到", - "累计签到": item.total_sign_day + "天", - "今天奖励": item.awards - } - } - } - return sumData; - } - async getData(type, data = {}, isck = true) { - if (isck) { - await this.cookie(this.e) - } - this.miHoYoApi = new miHoYoApi(this.e); - let res = await this.miHoYoApi.getData(type, data) - return res - } + async getCkData() { + let sumData = {}; + let yunres = await this.cloudSeach(); + let yundata = yunres.data + if (yunres.retcode === 0) { + sumData["云原神"] = { + "今日可获取": yundata?.coin?.free_coin_num, + "米云币": yundata?.coin?.coin_num, + "免费时长": yundata?.free_time?.free_time, + "总时长": yundata.total_time + } + } + let mysres = await this.bbsSeachSign(); + if (mysres.retcode === 0) { + sumData["米游社"] = { + "米游币任务": mysres.data.can_get_points != 0 ? "未完成" : "已完成", + "米游币余额": mysres.data.total_points, + "今日剩余可获取": mysres.data.can_get_points + } + } + let resSign = await this.multiSign(this.ForumData); + if (resSign?.upData) { + for (let item of resSign?.upData) { + let num = lodash.random(0, 9999); + item.upName = item.upName == "原神" ? "ys" : item.upName == "崩坏3" ? "bh3" : item.upName == + "崩坏2" ? "bh2" : item.upName == "未定事件簿" ? "wdy" : item.upName + sumData[item.upName + "" + num] = { + "uid": item.game_uid, + "游戏昵称": item.nickname, + "等级": item.level, + "今日签到": item.is_sign ? "已签到" : "未签到", + "累计签到": item.total_sign_day + "天", + "今天奖励": item.awards + } + } + } + return sumData; + } - async multiSign(forumData, isCk = false) { - let upData = [], - message = ''; - if (isCk) { - await this.cookie(this.e) - } - for (let forum of forumData) { - if (!(this.configSign.signlist.includes(forum.name))) { - continue; - } - let res - try { - message += `**${forum.name}**\n` - res = await this.getData("userGameInfo", forum, false) - await utils.sleepAsync(3000) //等几毫秒免得请求太频繁了 - if (res.retcode === -100) { - message = `用户：${this.e.user_id}：cookie失效` - return { - message, - upData - }; - } - if (res?.data?.list?.length === 0 || !res?.data?.list) { - message += `签到: 未绑定${forum.name}信息\n`; - if (this.allSign) { - this.allSign[forum.name].bindGame++; - } - await utils.randomSleepAsync() - continue; - } - message += `${forum.name}共计${res?.data?.list.length}个账号\n`; + async getData(type, data = {}, isck = true) { + if (isck) { + await this.cookie(this.e) + } + this.miHoYoApi = new miHoYoApi(this.e); + let res = await this.miHoYoApi.getData(type, data) + return res + } - for (let item of res?.data?.list) { - let data = Object.assign({}, forum, item) - item.is_sign = true; - item.upName = forum.name - res = await this.getData("isSign", data, false) - await utils.sleepAsync(500) - item.total_sign_day = res?.data?.total_sign_day - if (res?.data?.is_sign) { - if (this.allSign) { - this.allSign[forum.name].isSign++; - } - message += `${item.nickname}-${item.game_uid}：今日已签到~\n`; - } else { - let signMsg = ''; - for (let i = 0; i < 2; i++) { //循环请求 - await utils.sleepAsync(2000) - res = await this.getData("sign", data, false) - if (res?.data?.gt) { - let validate = await this.geetest(res.data) - if (validate) { - let header = {} - header["x-rpc-challenge"] = res["data"]["challenge"] - header["x-rpc-validate"] = validate - header["x-rpc-seccode"] = `${validate}|jordan` - data.headers = header - res = await this.getData("sign", data, false) - if (!res?.data?.gt) { - if (this.allSign) { - this.allSign[forum.name].sign++; - } - signMsg = `${item.nickname}-${item.game_uid}:验证码签到成功~\n` - item.total_sign_day++; - break; - } else { - if (this.allSign) { - this.allSign[forum.name].error++; - } - item.is_sign = false; - signMsg = - `${item.nickname}-${item.game_uid}:签到出现验证码~\n请晚点后重试，或者手动上米游社签到\n`; - } - } else { - if (this.allSign) { - this.allSign[forum.name].error++; - } - signMsg = `${item.nickname}-${item.game_uid}:验证码失败~\n` - } + async multiSign(forumData, isCk = false) { + let upData = [], + message = ''; + if (isCk) { + await this.cookie(this.e) + } + for (let forum of forumData) { + if (!(this.configSign.signlist.includes(forum.name))) { + continue; + } + let res + try { + message += `**${forum.name}**\n` + res = await this.getData("userGameInfo", forum, false) + await utils.sleepAsync(3000) //等几毫秒免得请求太频繁了 + if (res.retcode === -100) { + message = `用户：${this.e.user_id}：cookie失效` + return { + message, + upData + }; + } + if (res?.data?.list?.length === 0 || !res?.data?.list) { + message += `签到: 未绑定${forum.name}信息\n`; + if (this.allSign) { + this.allSign[forum.name].bindGame++; + } + await utils.randomSleepAsync() + continue; + } + message += `${forum.name}共计${res?.data?.list.length}个账号\n`; - } else { - if (this.allSign) { - this.allSign[forum.name].sign++; - } - item.total_sign_day++; - signMsg = - `${item.nickname}-${item.game_uid}：${res.message == "OK" ? "签到成功" : res.message}\n` - break; - } - } - message += signMsg - } - //获取签到信息和奖励信息 - const SignInfo = await this.getData("home", data, false) - if (SignInfo) { - let awards = SignInfo.data.awards[item.total_sign_day - 1]; - item.awards = awards?.name + "*" + awards?.cnt - } - upData.push(item) - await utils.randomSleepAsync() - } - } catch (e) { - if (this.allSign) { - this.allSign[forum.name].error++; - } - Bot.logger.error(`${forum.name} 签到失败 [${res?.message}]`); - message += `签到失败: [${res?.message}]\n`; - } - } - return { - message, - upData - } - } - async docHelp(type) { - return this.configSign[type.includes("云") ? "cloudDoc" : "cookiesDoc"] - } - async cloudSign() { - await this.cloudSeach() - let res = await this.getData("cloudReward") - Bot.logger.mark(`\n云原神签到用户:${this.e.user_id}:[接口返回]${res.message}\n`) - if (res?.data?.list?.length == 0 || !res?.data?.list) { - res.message = `您今天的奖励已经领取了~` - } else { - let sendMsg = `` - for (let item of res?.data?.list) { - let reward_id = item.id; - let reward_msg = item.msg; - res = await this.getData("cloudGamer", { - reward_id - }) - // let row=JSON.parse(reward_msg); - sendMsg += `\n领取奖励,ID:${reward_id},Msg:${reward_msg}` - } - res.message = sendMsg; - } - Bot.logger.mark(`\n云原神签到用户:${this.e.user_id}:${res.message}\n`) - return res - } - async cloudSeach() { - let res = await this.getData("cloudGet") - if (res?.retcode == -100) { - res.message = "云原神token失效/防沉迷" - res.isOk = false; - } else { - res.isOk = true; - if (res?.data?.total_time) { - res.message = - `米云币:${res?.data?.coin?.coin_num},免费时长:${res?.data?.free_time?.free_time}分钟,总时长:${res?.data?.total_time}分钟`; - } - } - return res; - } - async bbsSeachSign() { - let res = await this.getData("bbsisSign", { - name: "原神" - }) - if (!res?.data) { - res.message = `登录Stoken失效请重新获取cookies或stoken保存~`; - res.isOk = false; - this.delSytk(yamlDataUrl, this.e) - } else { - res.message = `当前米游币数量为：${res.data.total_points},今日剩余可获取：${res.data.can_get_points}` - res.isOk = true; - } - return res; - } - async getbbsSign(forumData) { - let message = '', - challenge = '', - res; - try { - res = await this.bbsSeachSign() - if (res?.data?.can_get_points == 0) { - return { - message: `签到任务已完成，无需重复签到` - } - } - for (let forum of forumData) { - let trueDetail = 0; - let Vote = 0; - let Share = 0; - let sumcount = 0; - message += `\n**${forum.name}**\n` - res = await this.getData("bbsSign", forum, false) - if (res?.retcode == -100) { - return { - message: '登录失效' - } - } - if (res?.retcode == 1034) { - challenge = await this.bbsGeetest() - if (challenge) { - forum["headers"] = { - "x-rpc-challenge": challenge - } - res = await this.getData("bbsSign", forum, false) - if (res?.retcode == 1034) { - message += `社区签到: 验证码失败\n`; - } else { - message += `社区签到: 验证码成功\n`; - } - } else { - message += `社区签到: 验证码失败\n`; - } - } else { - message += `社区签到: ${res.message}\n`; - } - Bot.logger.mark(`${this.e.user_id}:${this.e.uid}:${forum.name} 社区签到结果: [${res.message}]`); - res = await this.getData("bbsPostList", forum, false) - sumcount++; - let postList = res.data.list; - let postId - for (let post of postList) { - post = post.post; - postId = post['post_id'] - res = await this.getData("bbsPostFull", { - postId - }, false) - if (res?.message && res?.retcode == 0) { - trueDetail++; - } - if (res?.retcode == 1034) { - challenge = await this.bbsGeetest() - if (challenge) { - let data = { - postId, - headers: { - "x-rpc-challenge": challenge, - } - } - await this.getData("bbsPostFull", data, false) - } - } - res = await this.getData("bbsVotePost", { - postId - }, false) - if (res?.message && res?.retcode == 0) { - Vote++; - } - if (res?.retcode == 1034) { - challenge = await this.bbsGeetest() - if (challenge) { - let data = { - postId, - headers: { - "x-rpc-challenge": challenge, - } - } - await this.getData("bbsVotePost", data, false) - } - } - await utils.randomSleepAsync(2); - } - res = await this.getData("bbsShareConf", { - postId - }, false) - if (res?.message && res?.retcode == 0) { - Share++; - } - message += `共读取帖子记录${20 * sumcount}\n浏览：${trueDetail} 点赞：${Vote} 分享：${Share}\n`; - Bot.logger.mark(`\n用户${this.e.user_id}:\n${message}`) - await utils.randomSleepAsync(3); - } - } catch (ex) { - Bot.logger.error(`出问题了：${ex}`); - message += `${this.e.user_id}获取米游币异常`; - } - return { - message - } - } - async signTask(e = "") { - let mul = e; - //暂不支持多个uid签到 - Bot.logger.mark(`开始米社签到任务`); - let isAllSign = this.configSign.isAllSign - let userIdList = []; - let dir = './data/MysCookie/' - if (isV3) { - userIdList = (await gsCfg.getBingAllCk()).ckQQ - } else { - userIdList = NoteCookie; - } - if (mysTask) { - e.reply(`米社自动签到任务进行中，请勿重复触发指令`) - return false - } - mysTask = true; - let userIdkeys = Object.keys(userIdList); - let tips = ['开始米社签到任务'] - let time = userIdkeys.length * 25 + 5 + (userIdkeys.length / 3 * 60) - let finishTime = moment().add(time, 's').format('MM-DD HH:mm:ss') - tips.push(`\n签到用户：${userIdkeys.length}个`) - tips.push(`\n预计需要：${this.countTime(time)}`) - if (time > 120) { - tips.push(`\n完成时间：${finishTime}`) - } - Bot.logger.mark(`签到用户:${userIdkeys.length}个，预计需要${this.countTime(time)} ${finishTime} 完成`) - if (mul) { - await this.e.reply(tips) - if (this.e.msg.includes('force')) this.force = true - } else { - await utils.relpyPrivate(await gsCfg.getMasterQQ(), tips) - await utils.sleepAsync(lodash.random(1, 20) * 1000) - } - let _reply = e.reply - let msg = e?.msg; - //暂时先这样吧，等有空再优化~ - this.allSign = { - findModel: ["崩坏3", "崩坏2", '原神', '未定事件簿', '崩坏星穹铁道'], - "崩坏3": { - bindGame: 0, - sign: 0, - isSign: 0, - error: 0, - }, - "崩坏2": { - bindGame: 0, - sign: 0, - isSign: 0, - error: 0, - }, - "原神": { - bindGame: 0, - sign: 0, - isSign: 0, - error: 0, - }, - "未定事件簿": { - bindGame: 0, - sign: 0, - isSign: 0, - error: 0, - }, - "崩坏星穹铁道": { - bindGame: 0, - sign: 0, - isSign: 0, - error: 0, - }, - sendReply() { - let msg = "" - for (let item of this.findModel) { - msg += - `**${item}**\n已签：${this[item].isSign}\n签到成功：${this[item].sign}\n未绑定信息：${this[item].bindGame}\n签到失败异常：${this[item].error}\n` - } - return msg - } - } - for (let qq of userIdkeys) { - let user_id = qq; - let e = { - user_id, - qq, - isTask: true, - uid: userIdList[qq].uid, - cookie: userIdList[qq].cookie || userIdList[qq].ck, - }; - if (msg) { - e.msg = msg.replace(/全部|签到|米社/g, ""); - } else { - e.msg = "全部" - } - Bot.logger.mark(`正在为qq${user_id}米社签到中...`); + for (let item of res?.data?.list) { + let data = Object.assign({}, forum, item) + item.is_sign = true; + item.upName = forum.name + res = await this.getData("isSign", data, false) + await utils.sleepAsync(500) + item.total_sign_day = res?.data?.total_sign_day + if (res?.data?.is_sign) { + if (this.allSign) { + this.allSign[forum.name].isSign++; + } + message += `${item.nickname}-${item.game_uid}：今日已签到~\n`; + } else { + let signMsg = ''; + for (let i = 0; i < 2; i++) { //循环请求 + await utils.sleepAsync(2000) + res = await this.getData("sign", data, false) + if (res?.data?.gt) { + let validate = await this.geetest(res.data) + if (validate) { + let header = {} + header["x-rpc-challenge"] = res["data"]["challenge"] + header["x-rpc-validate"] = validate + header["x-rpc-seccode"] = `${validate}|jordan` + data.headers = header + res = await this.getData("sign", data, false) + if (!res?.data?.gt) { + if (this.allSign) { + this.allSign[forum.name].sign++; + } + signMsg = `${item.nickname}-${item.game_uid}:验证码签到成功~\n` + item.total_sign_day++; + break; + } else { + if (this.allSign) { + this.allSign[forum.name].error++; + } + item.is_sign = false; + signMsg = + `${item.nickname}-${item.game_uid}:签到出现验证码~\n请晚点后重试，或者手动上米游社签到\n`; + } + } else { + if (this.allSign) { + this.allSign[forum.name].error++; + } + signMsg = `${item.nickname}-${item.game_uid}:验证码失败~\n` + } - this.e = e; - let res = await this.multiSign(this.getDataList(e.msg)); - Bot.logger.mark(`${res.message}`) - e.reply = (msg) => { - if (!isAllSign || mul) { - return; - } - if (msg.includes("OK")) { - utils.relpyPrivate(qq, msg + "\n自动签到成功"); - } - }; - e.reply(res.message) - this.e.reply(res.message) - await utils.sleepAsync(15000); - } - msg = `米社签到任务完成\n` + this.allSign.sendReply() - Bot.logger.mark(msg); - if (mul) { - _reply(msg) - } else { - await utils.relpyPrivate(await gsCfg.getMasterQQ(), msg) - } - mysTask = false; - } - async cloudTask(e = "") { - let mul = e; - Bot.logger.mark(`云原神签到任务开始`); - let files = fs.readdirSync(this.yunPath).filter(file => file.endsWith('.yaml')) - if (files.length == 0) return; - let isCloudSignMsg = this.configSign.isCloudSignMsg - let userIdList = (files.join(",").replace(/.yaml/g, "").split(",")) - if (cloudTask) { - e.reply(`云原神自动签到任务进行中，请勿重复触发指令`) - return false - } - let tips = ['开始云原神签到任务'] - let time = userIdList.length * 3.5 + 5 - let finishTime = moment().add(time, 's').format('MM-DD HH:mm:ss') - tips.push(`\n签到用户：${userIdList.length}个`) - tips.push(`\n预计需要：${this.countTime(time)}`) - if (time > 120) { - tips.push(`\n完成时间：${finishTime}`) - } - Bot.logger.mark(`签到用户:${userIdList.length}个，预计需要${this.countTime(time)} ${finishTime} 完成`) - if (mul) { - await this.e.reply(tips) - } else { - await utils.relpyPrivate(await gsCfg.getMasterQQ(), tips) - await utils.sleepAsync(lodash.random(1, 20) * 1000) - } - cloudTask = true; - let _reply = e.reply - for (let qq of userIdList) { - let user_id = qq; - let e = { - user_id, - qq, - isTask: true - }; - Bot.logger.mark(`正在为qq${user_id}云原神签到中...`); - e.msg = "全部" - e.reply = (msg) => { - if (!isCloudSignMsg || mul) { - return; - } - if (msg.includes("领取奖励")) { - utils.relpyPrivate(qq, msg + "\n云原神自动签到成功"); - } - }; - this.e = e - await this.getyunToken(e) - let res = await this.cloudSign(); - this.e.reply(res.message) - await utils.sleepAsync(10000); - } - let msg = `云原神签到任务完成` - Bot.logger.mark(msg); - if (mul) { - _reply(msg) - } else { - await utils.relpyPrivate(await gsCfg.getMasterQQ(), msg) - } - cloudTask = false; - } - countTime(time) { - let hour = Math.floor((time / 3600) % 24) - let min = Math.floor((time / 60) % 60) - let sec = Math.floor(time % 60) - let msg = '' - if (hour > 0) msg += `${hour}小时` - if (min > 0) msg += `${min}分钟` - if (sec > 0) msg += `${sec}秒` - return msg - } - async bbsTask(e = "") { - let mul = e; - Bot.logger.mark(`开始米社米币签到任务`); - let stoken = await gsCfg.getBingStoken(); - let isPushSign = this.configSign.isPushSign - let userIdList = Object.keys(stoken) - if (bbsTask) { - e.reply(`米游币自动签到任务进行中，请勿重复触发指令`) - return false - } - let tips = ['开始米游币签到任务'] - let time = userIdList.length * 100 + 5 - let finishTime = moment().add(time, 's').format('MM-DD HH:mm:ss') - tips.push(`\n签到用户：${userIdList.length}个`) - tips.push(`\n预计需要：${this.countTime(time)}`) - if (time > 120) { - tips.push(`\n完成时间：${finishTime}`) - } - Bot.logger.mark(`签到用户:${userIdList.length}个，预计需要${this.countTime(time)} ${finishTime} 完成`) - if (mul) { - await this.e.reply(tips) - if (this.e.msg.includes('force')) this.force = true - } else { - await utils.relpyPrivate(await gsCfg.getMasterQQ(), tips) - await utils.sleepAsync(lodash.random(1, 20) * 1000) - } - bbsTask = true; - let _reply = e.reply - let counts = 0; - //获取需要签到的用户 - for (let dataUid of stoken) { - for (let uuId in dataUid) { - try { - if (uuId[0] * 1 > 5) { - continue; - } - let data = dataUid[uuId] - let user_id = data.userId * 1; - let e = { - user_id, - isTask: true - }; - counts++; - e.cookie = `stuid=${data.stuid};stoken=${data.stoken};ltoken=${data.ltoken};`; - Bot.logger.mark(`[米游币签到][第${counts}个]正在为qq${user_id}：uid:${uuId}签到中...`); - e.msg = "全部" - e.reply = (msg) => { - //关闭签到消息推送 - if (!isPushSign || mul) { - return; - } - if (msg.includes("OK")) { //签到成功并且不是已签到的才推送 - utils.relpyPrivate(user_id, msg + "uid:" + uuId + "\n自动签到成功"); - } - }; - this.e = e; - //await 代表同步 你可以尝试去除await以进行优化速度 - let res = await this.getbbsSign(this.ForumData); - e.reply(res.message) - await utils.sleepAsync(10000); - } catch (error) { - logger.error(`米游币签到报错：` + error) - } + } else { + if (this.allSign) { + this.allSign[forum.name].sign++; + } + item.total_sign_day++; + signMsg = + `${item.nickname}-${item.game_uid}：${res.message == "OK" ? "签到成功" : res.message}\n` + break; + } + } + message += signMsg + } + //获取签到信息和奖励信息 + const SignInfo = await this.getData("home", data, false) + if (SignInfo) { + let awards = SignInfo.data.awards[item.total_sign_day - 1]; + item.awards = awards?.name + "*" + awards?.cnt + } + upData.push(item) + await utils.randomSleepAsync() + } + } catch (e) { + if (this.allSign) { + this.allSign[forum.name].error++; + } + Bot.logger.error(`${forum.name} 签到失败 [${res?.message}]`); + message += `签到失败: [${res?.message}]\n`; + } + } + return { + message, + upData + } + } - } - } - let msg = `米社米币签到任务完成` - Bot.logger.mark(msg); - if (mul) { - _reply(msg) - } else { - await utils.relpyPrivate(await gsCfg.getMasterQQ(), msg) - } - bbsTask = false; - } - async bbsGeetest() { - if (!this.getToken) return "" - try { - let res = await this.getData('bbsGetCaptcha', false) - // let challenge = res.data["challenge"] - // await this.getData("geeType", res.data, false) - res.data.getToken = this.getToken - res = await this.getData("validate", res.data, false) - if (res?.data?.validate) { - res = await this.getData("bbsCaptchaVerify", res.data, false) - return res["data"]["challenge"] - } - } catch (error) { - //大概率是数据空导致报错这种情况很少见捏，所以你可以忽略不看 - Bot.logger.error('[validate][接口请求]异常信息：' + error) - return "" - } - return "" - } - async geetest(data) { - if (!this.getToken) return "" - try { - data.getToken = this.getToken - let res = await this.getData("validate", data, false) - if (res?.data?.validate) { - let validate = res?.data?.validate - return validate - } - } catch (error) { - //大概率是数据空导致报错这种情况很少见捏，所以你可以忽略不看 - Bot.logger.error('[validate][接口请求]异常信息：' + error) - return "" - } - return "" - } - getyunToken(e) { - let file = `${this.yunPath}${e.user_id}.yaml` - try { - let ck = fs.readFileSync(file, 'utf-8') - ck = YAML.parse(ck) - this.e.devId = ck.devId; - this.e.yuntoken = ck.yuntoken; - return ck - } catch (error) { - return "" - } - } - async cookie(e) { - let { - cookie, - uid, - skuid - } = await this.getCookie(e); - let cookiesDoc = await this.getcookiesDoc(); - if (!cookie) { - return false; - } - let stokens = this.getStoken(e.user_id) - if (!stokens) { - return true; - } - if (!cookie.includes("login_ticket") && (isV3 && !skuid?.login_ticket)) { - return false; - } - let flot = await this.stoken(cookie, e) - await utils.sleepAsync(1000); //延迟加载防止文件未生成 - if (!flot) { - return false; - } - return true; - } - async getcookiesDoc() { - return await gsCfg.getfileYaml(`${_path}/plugins/xiaoyao-cvs-plugin/config/`, "config").cookiesDoc - } - async getCookie(e) { - let skuid, cookie, uid - if (isV3) { - skuid = await gsCfg.getBingCookie(e.user_id); - cookie = skuid?.ck; - uid = skuid?.item; - if(!uid){ //获取uid为空时进行后续处理获取 (临时处理方式后续会进行解耦以避免这种情况。。待咕中.)s - uid=e.user.mainUid[e.isSr?'sr':'gs'] //由于目前只支持原神功能暂时先写死 - lodash.mapValues(e.user.mysUsers, function(o) { - if(o.uids[e.isSr?'sr':'gs'].includes(uid)){ - cookie=o.ck - } - }); - } - } else { - if (NoteCookie[e.user_id]) { - cookie = NoteCookie[e.user_id].cookie; - uid = NoteCookie[e.user_id].uid; - skuid = NoteCookie[e.user_id]; - } else if (BotConfig.dailyNote && BotConfig.dailyNote[e.user_id]) { - cookie = BotConfig.dailyNote[e.user_id].cookie; - uid = BotConfig.dailyNote[e.user_id].uid; - skuid = BotConfig.NoteCookie[e.user_id]; - } - } - if (!uid) { - uid = e.runtime?.user?._regUid - } - this.e.uid = uid; - this.e.cookie = cookie; - return { - cookie, - uid, - skuid - } - } - async stoken(cookie, e) { - this.e = e; - let datalist = this.getStoken(e.user_id) || {} - if (Object.keys(datalist).length > 0) { - return true; - } - const map = await utils.getCookieMap(cookie); - let loginTicket = map?.get("login_ticket"); - const loginUid = map?.get("login_uid") ? map?.get("login_uid") : map?.get("ltuid"); - if (isV3) { - loginTicket = gsCfg.getBingCookie(e.user_id).login_ticket - } - let mhyapi = new miHoYoApi(this.e); - let res = await mhyapi.getData("bbsStoken", { - loginUid, - loginTicket - }, false) - if (res?.data) { - datalist[e.uid] = { - stuid: map?.get("account_id"), - stoken: res.data.list[0].token, - ltoken: res.data.list[1].token, - uid: e.uid, - userId: e.user_id, - is_sign: true - } - gsCfg.saveBingStoken(e.user_id, datalist) - } - return true; - } - getStoken(userId) { - let file = `${yamlDataUrl}/${userId}.yaml` - try { - let ck = fs.readFileSync(file, 'utf-8') - ck = YAML.parse(ck) - if (ck?.uid) { - let datalist = {}; - ck.userId = this.e.user_id - datalist[ck.uid] = ck; - ck = datalist - gsCfg.saveBingStoken(this.e.user_id, datalist) - } - return ck[this.e.uid] || {} - } catch (error) { - return {} - } - } - async seachUid(data) { - let ltoken = '', v2Sk; - if (data?.data) { - let res; - if (this.e.sk) { - if (this.e.sk.get('stoken').includes('v2_')) { - res = await this.getData('getLtoken', { cookies: this.e.raw_message }, false) - ltoken = res?.data?.ltoken - } else { - v2Sk = await this.getData('getByStokenV2', { headers: { Cookie: this.e.raw_message } }, false) - } - this.e.cookie = - `ltoken=${this.e.sk?.get('ltoken') || ltoken};ltuid=${this.e.sk?.get('stuid')};cookie_token=${data.data.cookie_token}; account_id=${this.e.sk?.get('stuid')};` - // if(this.e.sk?.get('mid')){ - // this.e.cookie = - // `ltoken_v2=${this.e.sk?.get('ltoken')||ltoken};cookie_token_v2=${data.data.cookie_token}; account_mid_v2=${this.e.sk.get('mid')};ltmid_v2=${this.e.sk.get('mid')}` - // } - } else { - this.e.cookie = this.e.original_msg //发送的为cookies - this.cookies = `stuid=${this.e.stuid};stoken=${data?.data?.list[0].token};ltoken=${data?.data?.list[1].token}` - res = await this.getData('getLtoken', { cookies: this.cookies }, false) - v2Sk = await this.getData('getByStokenV2', { headers: { Cookie: this.cookies } }, false) - } - let list = [] - for (let item of ['崩坏星穹铁道', '原神']) { - let result = await this.getData("userGameInfo",this.getDataList(item)[0], false) - if (result?.retcode != 0) { - continue; - } - list.push(...result?.data?.list) - } - if(list.length==0) return false; - let uids = [] - for (let s of list) { - let datalist = {} - let uid = s.game_uid - uids.push(s.region_name+':'+uid) - datalist[uid] = { - stuid: this.e?.sk?.get('stuid') || this.e.stuid, - stoken: v2Sk?.data?.token?.token || this.e?.sk?.get('stoken') || data?.data?.list[0].token, - ltoken: this.e?.sk?.get('ltoken') || ltoken || data?.data?.list[1].token, - mid: this.e?.sk?.get('mid') || v2Sk?.data?.user_info?.mid, - uid: uid, - userId: this.e.user_id, - is_sign: true, - region_name:s.region_name, - region:s.region - } - await gsCfg.saveBingStoken(this.e.user_id, datalist) - } - let msg = `${uids.join('\n')}\nstoken绑定成功您可通过下列指令进行操作:`; - msg += '\n【#米币查询】查询米游币余额' - msg += '\n【#mys原神签到】获取米游币' - msg += '\n【#更新抽卡记录】更新抽卡记录' - msg += '\n【#刷新ck】刷新失效cookie' - msg += '\n【#我的stoken】查看绑定信息' - msg += '\n【#删除stoken】删除绑定信息' - this.e.reply(msg) - } - } + async docHelp(type) { + return this.configSign[type.includes("云") ? "cloudDoc" : "cookiesDoc"] + } - async delSytk(path = yamlDataUrl, e, type = "stoken") { - await this.getCookie(e); - if (type != "stoken") { - path = cloudDataUrl - } - let file = `${path}/${e.user_id}.yaml` - fs.exists(file, (exists) => { - if (!exists) { - return true; - } - let ck = fs.readFileSync(file, 'utf-8') - ck = YAML.parse(ck) - if (ck?.yuntoken) { - fs.unlinkSync(file); - } else if (ck) { - if (!ck[e.uid]) { - return true; - } - delete ck[e.uid]; - if (Object.keys(ck) == 0) { - fs.unlinkSync(file); - } else { - ck = YAML.stringify(ck) - fs.writeFileSync(file, ck, 'utf8') - } - } - e.reply(`已删除${e.msg}`) - return true; - }) - } - getDataList(name) { - let otherName = lodash.map(this.ForumData,'otherName') - for (let [index,item] of Object.entries(otherName)) { - if (item.includes(name)) { //循环结束未找到的时候返回原数组签到全部 - return [this.ForumData[index]] - } - } - return this.ForumData; - } + async cloudSign() { + await this.cloudSeach() + let res = await this.getData("cloudReward") + Bot.logger.mark(`\n云原神签到用户:${this.e.user_id}:[接口返回]${res.message}\n`) + if (res?.data?.list?.length == 0 || !res?.data?.list) { + res.message = `您今天的奖励已经领取了~` + } else { + let sendMsg = `` + for (let item of res?.data?.list) { + let reward_id = item.id; + let reward_msg = item.msg; + res = await this.getData("cloudGamer", { + reward_id + }) + // let row=JSON.parse(reward_msg); + sendMsg += `\n领取奖励,ID:${reward_id},Msg:${reward_msg}` + } + res.message = sendMsg; + } + Bot.logger.mark(`\n云原神签到用户:${this.e.user_id}:${res.message}\n`) + return res + } + + async cloudSeach() { + let res = await this.getData("cloudGet") + if (res?.retcode == -100) { + res.message = "云原神token失效/防沉迷" + res.isOk = false; + } else { + res.isOk = true; + if (res?.data?.total_time) { + res.message = + `米云币:${res?.data?.coin?.coin_num},免费时长:${res?.data?.free_time?.free_time}分钟,总时长:${res?.data?.total_time}分钟`; + } + } + return res; + } + + async bbsSeachSign() { + let res = await this.getData("bbsisSign", { + name: "原神" + }) + if (!res?.data) { + res.message = `登录Stoken失效请重新获取cookies或stoken保存~`; + res.isOk = false; + this.delSytk(yamlDataUrl, this.e) + } else { + res.message = `当前米游币数量为：${res.data.total_points},今日剩余可获取：${res.data.can_get_points}` + res.isOk = true; + } + return res; + } + + async getbbsSign(forumData) { + let message = '', + challenge = '', + res; + try { + res = await this.bbsSeachSign() + if (res?.data?.can_get_points == 0) { + return { + message: `签到任务已完成，无需重复签到` + } + } + for (let forum of forumData) { + let trueDetail = 0; + let Vote = 0; + let Share = 0; + let sumcount = 0; + message += `\n**${forum.name}**\n` + res = await this.getData("bbsSign", forum, false) + if (res?.retcode == -100) { + return { + message: '登录失效' + } + } + if (res?.retcode == 1034) { + challenge = await this.bbsGeetest() + if (challenge) { + forum["headers"] = { + "x-rpc-challenge": challenge + } + res = await this.getData("bbsSign", forum, false) + if (res?.retcode == 1034) { + message += `社区签到: 验证码失败\n`; + } else { + message += `社区签到: 验证码成功\n`; + } + } else { + message += `社区签到: 验证码失败\n`; + } + } else { + message += `社区签到: ${res.message}\n`; + } + Bot.logger.mark(`${this.e.user_id}:${this.e.uid}:${forum.name} 社区签到结果: [${res.message}]`); + res = await this.getData("bbsPostList", forum, false) + sumcount++; + let postList = res.data.list; + let postId + for (let post of postList) { + post = post.post; + postId = post['post_id'] + res = await this.getData("bbsPostFull", { + postId + }, false) + if (res?.message && res?.retcode == 0) { + trueDetail++; + } + if (res?.retcode == 1034) { + challenge = await this.bbsGeetest() + if (challenge) { + let data = { + postId, + headers: { + "x-rpc-challenge": challenge, + } + } + await this.getData("bbsPostFull", data, false) + } + } + res = await this.getData("bbsVotePost", { + postId + }, false) + if (res?.message && res?.retcode == 0) { + Vote++; + } + if (res?.retcode == 1034) { + challenge = await this.bbsGeetest() + if (challenge) { + let data = { + postId, + headers: { + "x-rpc-challenge": challenge, + } + } + await this.getData("bbsVotePost", data, false) + } + } + await utils.randomSleepAsync(2); + } + res = await this.getData("bbsShareConf", { + postId + }, false) + if (res?.message && res?.retcode == 0) { + Share++; + } + message += `共读取帖子记录${20 * sumcount}\n浏览：${trueDetail} 点赞：${Vote} 分享：${Share}\n`; + Bot.logger.mark(`\n用户${this.e.user_id}:\n${message}`) + await utils.randomSleepAsync(3); + } + } catch (ex) { + Bot.logger.error(`出问题了：${ex}`); + message += `${this.e.user_id}获取米游币异常`; + } + return { + message + } + } + + async signTask(e = "") { + let mul = e; + //暂不支持多个uid签到 + Bot.logger.mark(`开始米社签到任务`); + let isAllSign = this.configSign.isAllSign + let userIdList = []; + let dir = './data/MysCookie/' + if (isV3) { + userIdList = (await gsCfg.getBingAllCk()).ckQQ + } else { + userIdList = NoteCookie; + } + if (mysTask) { + e.reply(`米社自动签到任务进行中，请勿重复触发指令`) + return false + } + mysTask = true; + let userIdkeys = Object.keys(userIdList); + let tips = ['开始米社签到任务'] + let time = userIdkeys.length * 25 + 5 + (userIdkeys.length / 3 * 60) + let finishTime = moment().add(time, 's').format('MM-DD HH:mm:ss') + tips.push(`\n签到用户：${userIdkeys.length}个`) + tips.push(`\n预计需要：${this.countTime(time)}`) + if (time > 120) { + tips.push(`\n完成时间：${finishTime}`) + } + Bot.logger.mark(`签到用户:${userIdkeys.length}个，预计需要${this.countTime(time)} ${finishTime} 完成`) + if (mul) { + await this.e.reply(tips) + if (this.e.msg.includes('force')) this.force = true + } else { + await utils.relpyPrivate(await gsCfg.getMasterQQ(), tips) + await utils.sleepAsync(lodash.random(1, 20) * 1000) + } + let _reply = e.reply + let msg = e?.msg; + //暂时先这样吧，等有空再优化~ + this.allSign = { + findModel: ["崩坏3", "崩坏2", '原神', '未定事件簿', '崩坏星穹铁道'], + "崩坏3": { + bindGame: 0, + sign: 0, + isSign: 0, + error: 0, + }, + "崩坏2": { + bindGame: 0, + sign: 0, + isSign: 0, + error: 0, + }, + "原神": { + bindGame: 0, + sign: 0, + isSign: 0, + error: 0, + }, + "未定事件簿": { + bindGame: 0, + sign: 0, + isSign: 0, + error: 0, + }, + "崩坏星穹铁道": { + bindGame: 0, + sign: 0, + isSign: 0, + error: 0, + }, + sendReply() { + let msg = "" + for (let item of this.findModel) { + msg += + `**${item}**\n已签：${this[item].isSign}\n签到成功：${this[item].sign}\n未绑定信息：${this[item].bindGame}\n签到失败异常：${this[item].error}\n` + } + return msg + } + } + for (let qq of userIdkeys) { + let user_id = qq; + let e = { + user_id, + qq, + isTask: true, + uid: userIdList[qq].uid, + cookie: userIdList[qq].cookie || userIdList[qq].ck, + }; + if (msg) { + e.msg = msg.replace(/全部|签到|米社/g, ""); + } else { + e.msg = "全部" + } + Bot.logger.mark(`正在为qq${user_id}米社签到中...`); + + this.e = e; + let res = await this.multiSign(this.getDataList(e.msg)); + Bot.logger.mark(`${res.message}`) + e.reply = (msg) => { + if (!isAllSign || mul) { + return; + } + if (msg.includes("OK")) { + utils.relpyPrivate(qq, msg + "\n自动签到成功"); + } + }; + e.reply(res.message) + this.e.reply(res.message) + await utils.sleepAsync(15000); + } + msg = `米社签到任务完成\n` + this.allSign.sendReply() + Bot.logger.mark(msg); + if (mul) { + _reply(msg) + } else { + await utils.relpyPrivate(await gsCfg.getMasterQQ(), msg) + } + mysTask = false; + } + + async cloudTask(e = "") { + let mul = e; + Bot.logger.mark(`云原神签到任务开始`); + let files = fs.readdirSync(this.yunPath).filter(file => file.endsWith('.yaml')) + if (files.length == 0) return; + let isCloudSignMsg = this.configSign.isCloudSignMsg + let userIdList = (files.join(",").replace(/.yaml/g, "").split(",")) + if (cloudTask) { + e.reply(`云原神自动签到任务进行中，请勿重复触发指令`) + return false + } + let tips = ['开始云原神签到任务'] + let time = userIdList.length * 3.5 + 5 + let finishTime = moment().add(time, 's').format('MM-DD HH:mm:ss') + tips.push(`\n签到用户：${userIdList.length}个`) + tips.push(`\n预计需要：${this.countTime(time)}`) + if (time > 120) { + tips.push(`\n完成时间：${finishTime}`) + } + Bot.logger.mark(`签到用户:${userIdList.length}个，预计需要${this.countTime(time)} ${finishTime} 完成`) + if (mul) { + await this.e.reply(tips) + } else { + await utils.relpyPrivate(await gsCfg.getMasterQQ(), tips) + await utils.sleepAsync(lodash.random(1, 20) * 1000) + } + cloudTask = true; + let _reply = e.reply + for (let qq of userIdList) { + let user_id = qq; + let e = { + user_id, + qq, + isTask: true + }; + Bot.logger.mark(`正在为qq${user_id}云原神签到中...`); + e.msg = "全部" + e.reply = (msg) => { + if (!isCloudSignMsg || mul) { + return; + } + if (msg.includes("领取奖励")) { + utils.relpyPrivate(qq, msg + "\n云原神自动签到成功"); + } + }; + this.e = e + await this.getyunToken(e) + let res = await this.cloudSign(); + this.e.reply(res.message) + await utils.sleepAsync(10000); + } + let msg = `云原神签到任务完成` + Bot.logger.mark(msg); + if (mul) { + _reply(msg) + } else { + await utils.relpyPrivate(await gsCfg.getMasterQQ(), msg) + } + cloudTask = false; + } + + countTime(time) { + let hour = Math.floor((time / 3600) % 24) + let min = Math.floor((time / 60) % 60) + let sec = Math.floor(time % 60) + let msg = '' + if (hour > 0) msg += `${hour}小时` + if (min > 0) msg += `${min}分钟` + if (sec > 0) msg += `${sec}秒` + return msg + } + + async bbsTask(e = "") { + let mul = e; + Bot.logger.mark(`开始米社米币签到任务`); + let stoken = await gsCfg.getBingStoken(); + let isPushSign = this.configSign.isPushSign + let userIdList = Object.keys(stoken) + if (bbsTask) { + e.reply(`米游币自动签到任务进行中，请勿重复触发指令`) + return false + } + let tips = ['开始米游币签到任务'] + let time = userIdList.length * 100 + 5 + let finishTime = moment().add(time, 's').format('MM-DD HH:mm:ss') + tips.push(`\n签到用户：${userIdList.length}个`) + tips.push(`\n预计需要：${this.countTime(time)}`) + if (time > 120) { + tips.push(`\n完成时间：${finishTime}`) + } + Bot.logger.mark(`签到用户:${userIdList.length}个，预计需要${this.countTime(time)} ${finishTime} 完成`) + if (mul) { + await this.e.reply(tips) + if (this.e.msg.includes('force')) this.force = true + } else { + await utils.relpyPrivate(await gsCfg.getMasterQQ(), tips) + await utils.sleepAsync(lodash.random(1, 20) * 1000) + } + bbsTask = true; + let _reply = e.reply + let counts = 0; + //获取需要签到的用户 + for (let dataUid of stoken) { + for (let uuId in dataUid) { + try { + if (uuId[0] * 1 > 5) { + continue; + } + let data = dataUid[uuId] + let user_id = data.userId * 1; + let e = { + user_id, + isTask: true + }; + counts++; + e.cookie = `stuid=${data.stuid};stoken=${data.stoken};ltoken=${data.ltoken};`; + Bot.logger.mark(`[米游币签到][第${counts}个]正在为qq${user_id}：uid:${uuId}签到中...`); + e.msg = "全部" + e.reply = (msg) => { + //关闭签到消息推送 + if (!isPushSign || mul) { + return; + } + if (msg.includes("OK")) { //签到成功并且不是已签到的才推送 + utils.relpyPrivate(user_id, msg + "uid:" + uuId + "\n自动签到成功"); + } + }; + this.e = e; + //await 代表同步 你可以尝试去除await以进行优化速度 + let res = await this.getbbsSign(this.ForumData); + e.reply(res.message) + await utils.sleepAsync(10000); + } catch (error) { + logger.error(`米游币签到报错：` + error) + } + + } + } + let msg = `米社米币签到任务完成` + Bot.logger.mark(msg); + if (mul) { + _reply(msg) + } else { + await utils.relpyPrivate(await gsCfg.getMasterQQ(), msg) + } + bbsTask = false; + } + + async bbsGeetest() { + if (!this.getToken) return "" + try { + let res = await this.getData('bbsGetCaptcha', false) + // let challenge = res.data["challenge"] + // await this.getData("geeType", res.data, false) + res.data.getToken = this.getToken + res = await this.getData("validate", res.data, false) + if (res?.data?.validate) { + res = await this.getData("bbsCaptchaVerify", res.data, false) + return res["data"]["challenge"] + } + } catch (error) { + //大概率是数据空导致报错这种情况很少见捏，所以你可以忽略不看 + Bot.logger.error('[validate][接口请求]异常信息：' + error) + return "" + } + return "" + } + + async geetest(data) { + if (!this.getToken) return "" + try { + data.getToken = this.getToken + let res = await this.getData("validate", data, false) + if (res?.data?.validate) { + let validate = res?.data?.validate + return validate + } + } catch (error) { + //大概率是数据空导致报错这种情况很少见捏，所以你可以忽略不看 + Bot.logger.error('[validate][接口请求]异常信息：' + error) + return "" + } + return "" + } + + getyunToken(e) { + let file = `${this.yunPath}${e.user_id}.yaml` + try { + let ck = fs.readFileSync(file, 'utf-8') + ck = YAML.parse(ck) + this.e.devId = ck.devId; + this.e.yuntoken = ck.yuntoken; + return ck + } catch (error) { + return "" + } + } + + async cookie(e) { + let { + cookie, + uid, + skuid + } = await this.getCookie(e); + let cookiesDoc = await this.getcookiesDoc(); + if (!cookie) { + return false; + } + let stokens = this.getStoken(e.user_id) + if (!stokens) { + return true; + } + if (!cookie.includes("login_ticket") && (isV3 && !skuid?.login_ticket)) { + return false; + } + let flot = await this.stoken(cookie, e) + await utils.sleepAsync(1000); //延迟加载防止文件未生成 + if (!flot) { + return false; + } + return true; + } + + async getcookiesDoc() { + return await gsCfg.getfileYaml(`${_path}/plugins/xiaoyao-cvs-plugin/config/`, "config").cookiesDoc + } + + async getCookie(e) { + let skuid, cookie, uid + if (isV3) { + skuid = await gsCfg.getBingCookie(e.user_id); + cookie = skuid?.ck; + uid = skuid?.item; + if (!uid && e.user) { //获取uid为空时进行后续处理获取 (临时处理方式后续会进行解耦以避免这种情况。。待咕中.)s + uid = e.user?.mainUid[e.isSr ? 'sr' : 'gs'] //由于目前只支持原神功能暂时先写死 + lodash.mapValues(e.user.mysUsers, function (o) { + if (o.uids[e.isSr ? 'sr' : 'gs'].includes(uid)) { + cookie = o.ck + } + }); + } + } else { + if (NoteCookie[e.user_id]) { + cookie = NoteCookie[e.user_id].cookie; + uid = NoteCookie[e.user_id].uid; + skuid = NoteCookie[e.user_id]; + } else if (BotConfig.dailyNote && BotConfig.dailyNote[e.user_id]) { + cookie = BotConfig.dailyNote[e.user_id].cookie; + uid = BotConfig.dailyNote[e.user_id].uid; + skuid = BotConfig.NoteCookie[e.user_id]; + } + } + if (!uid) { + uid = e.runtime?.user?._regUid + } + this.e.uid = uid; + this.e.cookie = cookie; + return { + cookie, + uid, + skuid + } + } + + async stoken(cookie, e) { + this.e = e; + let datalist = this.getStoken(e.user_id) || {} + if (Object.keys(datalist).length > 0) { + return true; + } + const map = await utils.getCookieMap(cookie); + let loginTicket = map?.get("login_ticket"); + const loginUid = map?.get("login_uid") ? map?.get("login_uid") : map?.get("ltuid"); + if (isV3) { + loginTicket = gsCfg.getBingCookie(e.user_id).login_ticket + } + let mhyapi = new miHoYoApi(this.e); + let res = await mhyapi.getData("bbsStoken", { + loginUid, + loginTicket + }, false) + if (res?.data) { + datalist[e.uid] = { + stuid: map?.get("account_id"), + stoken: res.data.list[0].token, + ltoken: res.data.list[1].token, + uid: e.uid, + userId: e.user_id, + is_sign: true + } + gsCfg.saveBingStoken(e.user_id, datalist) + } + return true; + } + + getStoken(userId) { + let file = `${yamlDataUrl}/${userId}.yaml` + try { + let ck = fs.readFileSync(file, 'utf-8') + ck = YAML.parse(ck) + if (ck?.uid) { + let datalist = {}; + ck.userId = this.e.user_id + datalist[ck.uid] = ck; + ck = datalist + gsCfg.saveBingStoken(this.e.user_id, datalist) + } + return ck[this.e.uid] || {} + } catch (error) { + return {} + } + } + + async seachUid(data) { + let ltoken = '', v2Sk; + if (data?.data) { + let res; + if (this.e.sk) { + if (this.e.sk.get('stoken').includes('v2_')) { + res = await this.getData('getLtoken', {cookies: this.e.raw_message}, false) + ltoken = res?.data?.ltoken + } else { + v2Sk = await this.getData('getByStokenV2', {headers: {Cookie: this.e.raw_message}}, false) + } + this.e.cookie = + `ltoken=${this.e.sk?.get('ltoken') || ltoken};ltuid=${this.e.sk?.get('stuid')};cookie_token=${data.data.cookie_token}; account_id=${this.e.sk?.get('stuid')};` + // if(this.e.sk?.get('mid')){ + // this.e.cookie = + // `ltoken_v2=${this.e.sk?.get('ltoken')||ltoken};cookie_token_v2=${data.data.cookie_token}; account_mid_v2=${this.e.sk.get('mid')};ltmid_v2=${this.e.sk.get('mid')}` + // } + } else { + this.e.cookie = this.e.original_msg //发送的为cookies + this.cookies = `stuid=${this.e.stuid};stoken=${data?.data?.list[0].token};ltoken=${data?.data?.list[1].token}` + res = await this.getData('getLtoken', {cookies: this.cookies}, false) + v2Sk = await this.getData('getByStokenV2', {headers: {Cookie: this.cookies}}, false) + } + let list = [] + for (let item of ['崩坏星穹铁道', '原神']) { + let result = await this.getData("userGameInfo", this.getDataList(item)[0], false) + if (result?.retcode != 0) { + continue; + } + list.push(...result?.data?.list) + } + if (list.length == 0) return false; + let uids = [] + for (let s of list) { + let datalist = {} + let uid = s.game_uid + uids.push(s.region_name + ':' + uid) + datalist[uid] = { + stuid: this.e?.sk?.get('stuid') || this.e.stuid, + stoken: v2Sk?.data?.token?.token || this.e?.sk?.get('stoken') || data?.data?.list[0].token, + ltoken: this.e?.sk?.get('ltoken') || ltoken || data?.data?.list[1].token, + mid: this.e?.sk?.get('mid') || v2Sk?.data?.user_info?.mid, + uid: uid, + userId: this.e.user_id, + is_sign: true, + region_name: s.region_name, + region: s.region + } + await gsCfg.saveBingStoken(this.e.user_id, datalist) + } + let msg = `${uids.join('\n')}\nstoken绑定成功您可通过下列指令进行操作:`; + msg += '\n【#米币查询】查询米游币余额' + msg += '\n【#mys原神签到】获取米游币' + msg += '\n【#更新抽卡记录】更新抽卡记录' + msg += '\n【#刷新ck】刷新失效cookie' + msg += '\n【#我的stoken】查看绑定信息' + msg += '\n【#删除stoken】删除绑定信息' + this.e.reply(msg) + } + } + + async delSytk(path = yamlDataUrl, e, type = "stoken") { + await this.getCookie(e); + if (type != "stoken") { + path = cloudDataUrl + } + let file = `${path}/${e.user_id}.yaml` + fs.exists(file, (exists) => { + if (!exists) { + return true; + } + let ck = fs.readFileSync(file, 'utf-8') + ck = YAML.parse(ck) + if (ck?.yuntoken) { + fs.unlinkSync(file); + } else if (ck) { + if (!ck[e.uid]) { + return true; + } + delete ck[e.uid]; + if (Object.keys(ck) == 0) { + fs.unlinkSync(file); + } else { + ck = YAML.stringify(ck) + fs.writeFileSync(file, ck, 'utf8') + } + } + e.reply(`已删除${e.msg}`) + return true; + }) + } + + getDataList(name) { + let otherName = lodash.map(this.ForumData, 'otherName') + for (let [index, item] of Object.entries(otherName)) { + if (item.includes(name)) { //循环结束未找到的时候返回原数组签到全部 + return [this.ForumData[index]] + } + } + return this.ForumData; + } }