Miao-Yunzai/plugins/genshin/apps/exchange.js

153 lines
4.4 KiB
JavaScript

import plugin from '../../../lib/plugins/plugin.js'
import common from '../../../lib/common/common.js'
import fetch from 'node-fetch'
import MysInfo from '../model/mys/mysInfo.js'
export class exchange extends plugin {
constructor() {
super({
name: '兑换码',
dsc: '前瞻直播兑换码',
event: 'message',
priority: 1000,
rule: [
{
reg: /^(#|\*)?(原神|星铁|崩铁|崩三|崩坏三|崩坏3)?(直播|前瞻)?兑换码$/,
fnc: 'getCode'
},
{
reg: '^#(兑换码使用|cdk-u).+',
fnc: 'useCode'
}
]
})
}
async getCode() {
let reg = this.e.msg.match(/^(#|\*)?(原神|星铁|崩铁|崩三|崩坏三|崩坏3)?(直播|前瞻)?兑换码$/)
this.uid = '75276550'
if (reg[1] == '*' || ['星铁', '崩铁'].includes(reg[2])) {
this.uid = '80823548'
}
if (['崩三', '崩坏三', '崩坏3'].includes(reg[2])) {
this.uid = '73565430'
}
this.now = parseInt(Date.now() / 1000)
let actid = await this.getActId()
if (!actid) {
logger.info('[兑换码] 未获取到actId')
return true
}
this.actId = actid
/** index info */
let index = await this.getData('index')
if (!index || !index.data) {
return true
}
if (index.data === null) {
return await this.reply(`错误:\n${index.message}`)
}
let index_data = index.data.live
let title = index_data['title']
this.code_ver = index_data['code_ver']
if (index_data.remain > 0) {
return await this.reply(`暂无${title}直播兑换码`, true)
}
let code = await this.getData('code')
if (!code || !code.data?.code_list) {
logger.info('[兑换码] 未获取到兑换码')
return true
}
let codes = []
for (let val of code.data.code_list) {
if (val.code) {
codes.push([val.code, segment.button([
{ text: '兑换', callback: `#兑换码使用${val.code}` },
])])
}
}
let msg = [`兑换码过期时间: \n${this.deadline}`, ...codes]
msg = await common.makeForwardMsg(this.e, msg, `${title}-直播兑换码`)
await this.reply(msg)
}
async getData(type) {
let url = {
index: `https://api-takumi.mihoyo.com/event/miyolive/index`,
code: `https://api-takumi-static.mihoyo.com/event/miyolive/refreshCode?version=${this.code_ver}&time=${this.now}`,
actId: `https://bbs-api.mihoyo.com/painter/api/user_instant/list?offset=0&size=20&uid=${this.uid}`,
}
let response
try {
response = await fetch(url[type], {
method: 'get',
headers: {
'x-rpc-act_id': this.actId
}
})
} catch (error) {
logger.error(error.toString())
return false
}
if (!response.ok) {
logger.error(`[兑换码接口错误][${type}] ${response.status} ${response.statusText}`)
return false
}
const res = await response.json()
return res
}
// 获取 "act_id"
async getActId() {
let ret = await this.getData('actId')
if (ret.error || ret.retcode !== 0) {
return ''
}
for (const p of ret.data.list) {
let post
try {
post = p.post.post
} catch (e) {
logger.error('活动数据获取异常')
logger.error(e)
}
if (!post) {
continue
}
let date = new Date(post.created_at * 1000)
if (this.uid == '80823548') {
date.setDate(date.getDate() + 1)
this.deadline = `${date.getFullYear()}-${date.getMonth() + 1}-${date.getDate()} 23:59:59`
} else if (this.uid == '73565430') {
date.setDate(date.getDate() + 5)
this.deadline = `${date.getFullYear()}-${date.getMonth() + 1}-${date.getDate()} 12:00:00`
} else {
date.setDate(date.getDate() + 3)
this.deadline = `${date.getFullYear()}-${date.getMonth() + 1}-${date.getDate()} 12:00:00`
}
let structured_content = post.structured_content
let result = structured_content.match(/{\"link\":\"https:\/\/webstatic.mihoyo.com\/bbs\/event\/live\/index.html\?act_id=(.*?)\\/)
if (result) {
return result[1]
}
}
}
// 兑换码使用
async useCode() {
const cdkCode = this.e.msg.replace(/#(兑换码使用|cdk-u)/, '').trim()
const res = await MysInfo.get(this.e, 'useCdk', { cdk: cdkCode })
if (res) {
this.e.reply(`${res.data.msg}`)
}
}
}