xiaoyao-cvs-plugin/apps/sign.js

import MihoYoApi from "../model/mys/mihoyo-api.js"
import utils from '../model/mys/utils.js';
import promiseRetry from 'promise-retry';
import {
	Cfg,
	Data
} from "../components/index.js";
import moment from 'moment';
import {
	isV3
} from '../components/Changelog.js';
import gsCfg from '../model/gsCfg.js';
import fs from "fs";
import {
	segment
} from "oicq";
import YAML from 'yaml'

const _path = process.cwd();
let START = moment().unix();
const TODAY_DATE = moment().format('YYYY-MM-DD');
const RETRY_OPTIONS = {
	retries: 3,
	minTimeout: 5000,
	maxTimeout: 10000
};
let YamlDataUrl = `${_path}/plugins/xiaoyao-cvs-plugin/data/yaml`;
let yunpath = `${_path}/plugins/xiaoyao-cvs-plugin/data/yunToken/`;
let configSign = gsCfg.getfileYaml(`${_path}/plugins/xiaoyao-cvs-plugin/config/`, "config");
configSign.signlist = configSign.signlist || "原神|崩坏3|崩坏2|未定事件簿".split("|")
export const rule = {
	mysSign: {
		reg: `^#*(米游社|mys|社区)(原神|崩坏3|崩坏2|未定事件簿|大别野|崩坏星穹铁道|绝区零|全部)签到$`,
		describe: "米游社米游币签到（理论上会签到全部所以区分开了）"
	},
	bbsSeach: {
		reg: "^#*(米游币|米币)查询$",
		describe: "米币查询"
	},
	sign: {
		reg: `^#*(${configSign.signlist.join("|")})签到$`,
		describe: "米社规则签到"
	},
	signlist: {
		reg: "^#(米游币|米社(原神|崩坏3|崩坏2|未定事件簿)*)全部签到$",
		describe: "米游币全部签到"
	},
	sendyunTime: {
		reg: "^#*云原神(时间|剩余时间|剩余|还有多久|还剩多少分钟|查询)$",
		describe: "查询当前云原神剩余时间"
	},
	yunSign: {
		reg: "^#*云原神签到$",
		describe: "云原神签到"
	},
	yunAllSign: {
		reg: "^#云原神全部签到$",
		describe: "云原神全部签到"
	},
	yuntoken: {
		reg: "^(.*)ct(.*)$",
		describe: "云原神签到token获取"
	},
	cookiesDocHelp: {
		reg: "^#*(米游社|cookies|米游币|stoken|Stoken)(帮助|教程|绑定)$",
		describe: "cookies获取帮助"
	},
	yunHelp: {
		reg: "^#*(云原神|云)帮助$",
		describe: "cookies获取帮助"
	}
};
init()

function init() {
	Data.createDir("", yunpath, false);
}
export async function sign(e) {
	let {
		skuid,
		cookie
	} = await getCookie(e);
	if (!cookie) {
		e.reply("请先绑定cookie~\n发送【cookie帮助】获取教程")
		return true;
	}

	START = moment().unix();
	let miHoYoApi = new MihoYoApi(e);
	let resultMessage = "";
	let msg = e.msg.replace(/#|签到|井|米游社|mys|社区/g, "");
	let ForumData = await getDataList(msg);
	e.reply(`开始尝试${msg}签到预计${msg=='全部'?"60":"5-10"}秒~`)
	for (let forum of ForumData) {
		if (!(configSign.signlist.includes(forum.name))) {
			continue;
		}
		resultMessage += `**${forum.name}**\n`
		try {
			// 1 BBS Sign
			let resObj = await promiseRetry((retry, number) => {
				// Bot.logger.info(`开始签到: [${forum.name}] 尝试次数: ${number}`);
				return miHoYoApi.honkai3rdSignTask(forum.name).catch((e) => {
					Bot.logger.error(`${forum.name} 签到失败: [${e.message}] 尝试次数: ${number}`);
					return retry(e);
				});
			}, RETRY_OPTIONS);
			Bot.logger.info(`${forum.name} 签到结果: [${resObj.message}]`);
			resultMessage += `签到: \n${resObj.message}\n`;
		} catch (e) {
			Bot.logger.error(`${forum.name} 签到失败 [${e.message}]`);
			resultMessage += `签到失败: [${e.message}]\n`;
		}

		await utils.randomSleepAsync();
	}
	await replyMsg(e, resultMessage);
	return true
}
export async function mysSign(e) {
	let isck = await cookie(e);
	if (!isck) {
		return true;
	}
	let iscount = "";
	let miHoYoApi = new MihoYoApi(e);
	let stokens = await miHoYoApi.getStoken(e.user_id)
	if (Object.keys(stokens).length == 0) {
		e.reply("未读取到stoken\n请发送【stoken帮助】查看配置教程配置~")
		return true;
	}
	if (e.uid[0] * 1 > 5) {
		e.reply("暂不支持hoyolab社区签到~")
		return true;
	}
	START = moment().unix();
	let resultMessage = "";
	let resObj=await mysSeach(e)
	if(resObj?.data?.can_get_points===0){
		resultMessage+=`今日米游币任务已完成~\n请勿重复操作\n当前米游币总持有数量为：${resObj.data.total_points}`;
		await replyMsg(e, resultMessage);
		return true
	}else if(!resObj?.data){
		resultMessage+=`登录Stoken失效\n请发送【stoken帮助】查看配置教程重新配置~`;
		await replyMsg(e, resultMessage);
		fs.unlink(`${YamlDataUrl}/${e.user_id}.yaml`,function(error){
			if(error){
				return ""
			}
		})
		return true;
	}
	// Execute task
	let msg = e.msg.replace(/#|签到|井|米游社|mys|社区/g, "");
	let ForumData = await getDataList(msg);
	e.reply(`开始尝试${msg}社区签到预计${msg=='全部'?"10-20":"1-3"}分钟~`)
	for (let forum of ForumData) {
		resultMessage += `**${forum.name}**\n`
		try {
			// 1 BBS Sign
			let resObj = await promiseRetry((retry, number) => {
				// Bot.logger.info(`开始签到: [${forum.name}] 尝试次数: ${number}`);
				return miHoYoApi.forumSign(forum.forumId).catch((e) => {
					Bot.logger.error(`${forum.name} 签到失败: [${e.message}] 尝试次数: ${number}`);
					return retry(e);
				});
			}, RETRY_OPTIONS);
			Bot.logger.mark(`${e.user_id}:${e.uid}:${forum.name} 签到结果: [${resObj.message}]`);
			resultMessage += `签到: [${resObj.message}]\n`;
		} catch (e) {
			Bot.logger.error(`${forum.name} 签到失败 [${e.message}]`);
			resultMessage += `签到失败: [${e.message}]\n`;
		}
		await utils.randomSleepAsync();
	}
	for (let forum of ForumData) {
		let trueDetail = 0;
		let Vote = 0;
		let Share = 0;
		let sumcount = 0;
		resultMessage += `\n**${forum.name}**\n`
		try {
			// 2 BBS list post
			let resObj = await promiseRetry((retry, number) => {
				// Bot.logger.info(`读取帖子列表: [${forum.name}] 尝试次数: ${number}`);
				return miHoYoApi.forumPostList(forum.forumId).catch((e) => {
					Bot.logger.error(`${forum.name} 读取帖子列表失败: [${e.message}] 尝试次数: ${number}`);
					return retry(e);
				});
			}, RETRY_OPTIONS);
			sumcount++;
			// Bot.logger.info(`${forum.name} 读取列表成功 [${resObj.message}]，读取到 [${resObj.data.list.length}] 条记录`);
			let postList = resObj.data.list;
			for (let post of postList) {
				post = post.post;
				// 2.1 BBS read post
				let resObj = await promiseRetry((retry, number) => {
					// Bot.logger.mark(`读取帖子: [${post.subject}] 尝试次数: ${number}`);
					return miHoYoApi.forumPostDetail(post['post_id']).catch((e) => {
						Bot.logger.error(`${forum.name} 读取帖子失败: [${e.message}] 尝试次数: ${number}`);
						return retry(e);
					});
				}, RETRY_OPTIONS);
				if (resObj?.message) {
					trueDetail++;
				}
				// Bot.logger.info(`${forum.name} [${post.subject}] 读取成功 [${resObj.message}]`);
				await utils.randomSleepAsync();
				// 2.2 BBS vote post
				resObj = await promiseRetry((retry, number) => {
					// Bot.logger.mark(`点赞帖子: [${post.subject}] 尝试次数: ${number}`);
					return miHoYoApi.forumPostVote(post['post_id']).catch((e) => {
						Bot.logger.error(`${forum.name} 点赞帖子失败: [${e.message}] 尝试次数: ${number}`);
						return retry(e);
					});
				}, RETRY_OPTIONS);
				if (resObj?.message) {
					Vote++;
				}
				// Bot.logger.mark(`${forum.name} [${post.subject}] 点赞成功 [${resObj.message}]`);
				await utils.randomSleepAsync();
			}
			// 2.3 BBS share post
			let sharePost = postList[0].post;
			resObj = await promiseRetry((retry, number) => {
				// Bot.logger.mark(`分享帖子: [${sharePost.subject}] 尝试次数: ${number}`);
				return miHoYoApi.forumPostShare(sharePost['post_id']).catch((e) => {
					Bot.logger.error(`${forum.name} 分享帖子失败: [${e.message}] 尝试次数: ${number}`);
					return retry(e);
				});
			}, RETRY_OPTIONS);
			if (resObj?.message) {
				Share++;
			}
		} catch (e) {
			Bot.logger.error(`${forum.name} 读帖点赞分享失败 [${e.message}]`);
			resultMessage += `读帖点赞分享: 失败 [${e.message}]\n`;
		}
		resultMessage += `共读取帖子记录${20*sumcount}\n浏览成功：${trueDetail}\n点赞成功：${Vote}\n分享成功：${Share}`;
		await utils.randomSleepAsync();
	}
	Bot.logger.mark(`用户qq${e.user_id}:${e.uid}:${resultMessage}`);
	await replyMsg(e, resultMessage);
	return true
}

export async function bbsSeach(e) {
	START = moment().unix();
	let isck = await cookie(e);
	if (!isck) {
		return true;
	}
	let miHoYoApi = new MihoYoApi(e);
	let stokens = await miHoYoApi.getStoken(e.user_id)
	if (Object.keys(stokens).length == 0) {
		let cookiesDoc = await getcookiesDoc()
		await replyMsg(e, "未读取到stoken请检查cookies是否包含login_ticket，请先绑定stoken再查询~\n" + cookiesDoc);
		return true;
	}
	let resObj = await mysSeach(e)
	if (!resObj?.data) {
		await replyMsg(e, `登录Stoken失效请重新获取cookies或stoken保存~`);
		fs.unlink(`${YamlDataUrl}/${e.user_id}.yaml`, function(error) {
			if (error) {
				return ""
			}
		})
		return true;
	}
	await replyMsg(e, `当前米游币数量为：${resObj.data.total_points},今日剩余可获取：${resObj.data.can_get_points}`);
	return true;
}
async function mysSeach(e) {
	let miHoYoApi = new MihoYoApi(e);
	try {
		let resObj = await promiseRetry((retry, number) => {
			return miHoYoApi.getTasksList().catch((e) => {
				return retry(e);
			});
		}, RETRY_OPTIONS);
		return resObj
	} catch (e) {

	}
}
async function replyMsg(e, resultMessage) {
	const END = moment().unix();
	Bot.logger.info(`运行结束, 用时 ${END - START} 秒`);
	resultMessage += `\n用时 ${END - START} 秒`;
	e.reply([segment.at(e.user_id), "\n" + resultMessage]);
}

async function getDataList(name) {
	let ForumData = Data.readJSON(`${_path}/plugins/xiaoyao-cvs-plugin/defSet/json`, "mys")
	for (let item of ForumData) {
		if (item.name == name) { //循环结束未找到的时候返回原数组签到全部
			return [item]
		}
	}
	return ForumData;
}

async function cookie(e) {
	let {
		cookie,
		uid,
		skuid
	} = await getCookie(e);
	let miHoYoApi = new MihoYoApi(e);
	let cookiesDoc = await getcookiesDoc();
	if (!cookie) {
		e.reply("cookie失效请重新绑定~【教程】\n" + cookiesDoc)
		return false;
	}
	let stokens = miHoYoApi.getStoken(e.user_id)
	if (Object.keys(stokens).length > 0) {
		return true;
	}
	if (!cookie.includes("login_ticket") && (isV3 && !skuid?.login_ticket)) {
		e.reply("米游社登录cookie不完整，请前往米游社通行证处重新获取cookie~\ncookies必须包含login_ticket【教程】 " + cookiesDoc)
		return false;
	}
	let flot = (await miHoYoApi.stoken(cookie, e));
	await utils.sleepAsync(1000); //延迟加载防止文件未生成
	if (!flot) {
		e.reply("登录失效请重新登录获取cookie发送机器人~")
		return false;
	}
	return true;
}
async function getCookie(e) {
	let skuid, cookie, uid
	if (isV3) {
		skuid = await gsCfg.getBingCookie(e.user_id);
		cookie = skuid?.ck;
		uid = skuid?.item;
	} 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];
		}
	}
	e.uid = uid;
	e.cookie = cookie;
	return {
		cookie,
		uid,
		skuid
	}
}
export async function cookiesDocHelp(e) {
	let cookiesDoc = await getcookiesDoc()
	e.reply(`【${e.msg.replace(/帮助|教程|绑定/g,"")}帮助】${cookiesDoc}\ncookies必须包含login_ticket获取后请私发机器人`);
	return true
}
async function getcookiesDoc() {
	return await gsCfg.getfileYaml(`${_path}/plugins/xiaoyao-cvs-plugin/config/`, "config").cookiesDoc
}
//定时米社米币签到任务
export async function allMysSign() {
	Bot.logger.mark(`开始米社米币签到任务`);
	let stoken = await gsCfg.getBingStoken();
	let isPushSign = await gsCfg.getfileYaml(`${_path}/plugins/xiaoyao-cvs-plugin/config/`, "config").isPushSign

	//获取需要签到的用户
	for (let dataUid of stoken) {
		for (let uuId in dataUid) {
			if (uuId[0] * 1 > 5) {
				continue;
			}
			let data = dataUid[uuId]
			let user_id = data.userId * 1;
			let e = {
				user_id,
				isTask: true
			};
			e.cookie = `stuid=${data.stuid};stoken=${data.stoken};ltoken=${data.ltoken};`;
			Bot.logger.mark(`正在为qq${user_id}：uid:${uuId}进行米游币签到中...`);
			e.msg = "全部"
			e.reply = (msg) => {
				//关闭签到消息推送
				if (!isPushSign || ismysbool) {
					return;
				}
				if (msg.includes("OK")) { //签到成功并且不是已签到的才推送
					// msg = msg.replace("签到成功", "自动签到成功");
					utils.relpyPrivate(user_id, msg + "uid:" + uuId + "\n自动签到成功");
				}
			};
			await mysSign(e);
			await utils.sleepAsync(10000);
		}
	}
	Bot.logger.mark(`米社米币签到任务完成`);
	return true
}

//定时签到任务
export async function allSign(e = "") {
	Bot.logger.mark(`开始米社签到任务`);
	let isAllSign = await gsCfg.getfileYaml(`${_path}/plugins/xiaoyao-cvs-plugin/config/`, "config").isAllSign
	let userIdList = [];
	if (isV3) {
		let dir = './data/MysCookie/'
		let files = fs.readdirSync(dir).filter(file => file.endsWith('.yaml'))
		userIdList = (files.join(",").replace(/.yaml/g, "").split(","))
	} else {
		for (let [user_id, cookie] of Object.entries(NoteCookie)) {
			userIdList.push(user_id)
		}
	}
	let msg = e?.msg;
	for (let qq of userIdList) {
		let user_id = qq;
		let e = {
			user_id,
			qq,
			isTask: true
		};
		if (msg) {
			e.msg = msg.replace(/全部|签到|米社/g, "");
		} else {
			e.msg = "全部"
		}
		Bot.logger.mark(`正在为qq${user_id}米社签到中...`);
		e.reply = (msg) => {
			if (!isAllSign || isbool) {
				return;
			}
			if (msg.includes("OK")) {
				utils.relpyPrivate(qq, msg + "\n自动签到成功");
			}
		};
		await sign(e);
		await utils.sleepAsync(10000);
	}
	Bot.logger.mark(`米社签到任务完成`);
}
const checkAuth = async function(e) {
	return await e.checkAuth({
		auth: "master",
		replyMsg: `只有主人才能命令我哦~
    (*/ω＼*)`
	});
}
let isbool = false;
let ismysbool = false;
export async function signlist(e) {
	if (!await checkAuth(e)) {
		return true;
	}
	if (isbool) {
		e.reply(`米社签到中请勿重复执行`)
		return true;
	}
	if (ismysbool) {
		e.reply(`米游币签到中请勿重复执行`)
		return true;
	}
	let msg = e.msg.replace(/#|全部签到/g, "")
	e.reply(`开始执行${msg}签到中，请勿重复执行`);
	if (msg == "米游币") {
		if (!fs.existsSync(YamlDataUrl)) {
			Data.createDir("", YamlDataUrl, false);
			e.reply("未读取到可签到文件")
			return true;
		}
		ismysbool = true;
		await allMysSign()
	} else {
		isbool = true;
		await allSign(e)
	}
	e.reply(`${msg}签到任务已完成`);
	ismysbool = false;
	isbool = false;
	return true;
}
let isYun = false;
export async function yunAllSign(e) {
	if (!await checkAuth(e)) {
		return true;
	}

	e.reply(`开始执行云原神签到中，请勿重复执行`);
	if (isYun) {
		e.reply(`云原神签到中请勿重复执行`)
		return true;
	}
	isYun = true;
	await yunSignlist(e);
	e.reply(`云原神签到任务已完成`);
}

export async function yunSignlist(e) {
	Bot.logger.mark(`云原神签到任务开始`);
	let files = fs.readdirSync(yunpath).filter(file => file.endsWith('.yaml'))
	let isYunSignMsg = await gsCfg.getfileYaml(`${_path}/plugins/xiaoyao-cvs-plugin/config/`, "config").isYunSignMsg
	let userIdList = (files.join(",").replace(/.yaml/g, "").split(","))
	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 (!isYunSignMsg || isYun) {
				return;
			}
			if (msg.includes("领取奖励")) {
				utils.relpyPrivate(qq, msg + "\n云原神自动签到成功");
			}
		};
		await yunSign(e);
		await utils.sleepAsync(10000);
	}
	Bot.logger.mark(`云原神签到任务完成`);
}


export async function yunSign(e) {
	if (!(await getyunToken(e))) {
		e.reply("尚未绑定云原神token\n" + await yunDoc())
		return true;
	}
	let miHoYoApi = new MihoYoApi(e);
	e.reply((await miHoYoApi.yunGenshen()).sendMSg)
	return;
}
const getyunToken = async function(e) {
	let file = `${yunpath}/${e.user_id}.yaml`
	try {
		let ck = fs.readFileSync(file, 'utf-8')
		ck = YAML.parse(ck)
		e.devId = ck.devId;
		e.yuntoken = ck.yuntoken;
		return ck
	} catch (error) {
		return ""
	}
}
export async function sendyunTime(e) {
	if (!(await getyunToken(e))) {
		e.reply("尚未绑定云原神token\n" + await yunDoc())
		return true;
	}
	let miHoYoApi = new MihoYoApi(e);
	e.reply((await miHoYoApi.logyunGenshen()).log_msg)
	return;
}
export async function yuntoken(e) {
	if (e.msg.includes("ltoken") || e.msg.includes("_MHYUUID")) { //防止拦截米社cookie
		return false;
	}
	if (["ct", "si", "devId"].includes(e.msg)) {
		e.reply(`格式支持\nai=*;ci=*;oi=*;ct=***********;si=**************;bi=***********;devId=***********`)
		return false;
	}
	let msg = e.msg.split("devId")

	if (msg.length < 2) {
		return false;
	}
	let devId = msg[1].replace(/=/, "")
	let yuntoken = msg[0];
	e.devId = devId;
	e.yuntoken = yuntoken;
	let miHoYoApi = new MihoYoApi(e);
	let objData = (await miHoYoApi.logyunGenshen()) //校验token是否有效
	if (objData.retcode != 0) {
		e.reply(objData.message)
		return true;
	}
	let datalist = {
		devId: devId,
		yuntoken: yuntoken,
		qq: e.user_id,
		uid: e.uid,
		sign: true
	}
	let yamlStr = YAML.stringify(datalist);
	fs.writeFileSync(`${yunpath}${e.user_id}.yaml`, yamlStr, 'utf8');
	e.reply("云原神cookie保存成功~\n您后续可发送【#云原神查询】获取使用时间~")
	return true;
}


export async function yunHelp(e) {
	e.reply("云原神帮助：\n" + await yunDoc())
	return true;
}

const yunDoc = async function() {
	return await gsCfg.getfileYaml(`${_path}/plugins/xiaoyao-cvs-plugin/config/`, "config").yunDoc
}