mirror of
https://github.com/yoimiya-kokomi/miao-plugin.git
synced 2024-11-16 04:35:42 +00:00
289 lines
8.1 KiB
JavaScript
289 lines
8.1 KiB
JavaScript
import fs from 'fs'
|
|
import lodash from 'lodash'
|
|
import Format from './Format.js'
|
|
import Character from './models/Character.js'
|
|
import Miao from './profile-data/miao.js'
|
|
import Enka from './profile-data/enka.js'
|
|
import Data from './Data.js'
|
|
|
|
const _path = process.cwd()
|
|
|
|
let sysCfg = await Data.importModule('plugins/miao-plugin/config/system', 'profile.js')
|
|
let diyCfg = await Data.importModule('plugins/miao-plugin/config/', 'profile.js')
|
|
|
|
const userPath = `${_path}/data/UserData/`
|
|
|
|
if (!fs.existsSync(userPath)) {
|
|
fs.mkdirSync(userPath)
|
|
}
|
|
|
|
function sleep (ms) {
|
|
return new Promise((resolve) => setTimeout(resolve, ms))
|
|
}
|
|
|
|
function getServ (uid) {
|
|
return (diyCfg.profileApi || sysCfg.profileApi)({ uid, Miao, Enka, diyCfg })
|
|
}
|
|
|
|
const requestInterval = diyCfg.requestInterval || sysCfg.requestInterval || 5
|
|
|
|
let Profile = {
|
|
async request (uid, e) {
|
|
if (uid.toString().length !== 9) {
|
|
return false
|
|
}
|
|
let Serv = getServ(uid)
|
|
|
|
let cdTime = await Profile.inCd(uid)
|
|
if (cdTime) {
|
|
e.reply(`请求过快，请${cdTime}秒后重试..`)
|
|
return false
|
|
}
|
|
|
|
await Profile.setCd(uid, 20) // 发起请求设置20s cd
|
|
e.reply('开始获取数据，可能会需要一定时间~')
|
|
await sleep(500)
|
|
let data
|
|
try {
|
|
data = await Serv.request({ uid, e, sysCfg, diyCfg, setCd: Profile.setCd })
|
|
if (!data) {
|
|
return false
|
|
}
|
|
// enka服务测冷却时间5分钟
|
|
let cdTime = requestInterval * 60
|
|
if (data.ttl) {
|
|
cdTime = Math.max(cdTime, data.ttl * 1)
|
|
delete data.ttl
|
|
}
|
|
await Profile.setCd(uid, cdTime) // 根据设置设置cd
|
|
return Profile.save(uid, data, Serv.key)
|
|
} catch (err) {
|
|
console.log(err)
|
|
e.reply('请求失败')
|
|
return false
|
|
}
|
|
},
|
|
|
|
async setCd (uid, cdTime = 5 * 60) {
|
|
let ext = new Date() * 1 + cdTime * 1000
|
|
await redis.set(`miao:role-all:${uid}`, ext + '', { EX: cdTime })
|
|
},
|
|
|
|
async inCd (uid) {
|
|
let ext = await redis.get(`miao:role-all:${uid}`)
|
|
if (!ext || isNaN(ext)) {
|
|
return false
|
|
}
|
|
let cd = new Date() * 1 - ext
|
|
if (cd < 0) {
|
|
return Math.ceil(0 - cd / 1000)
|
|
}
|
|
return false
|
|
},
|
|
|
|
save (uid, data, dataSource = 'enka') {
|
|
let userData = {}
|
|
const userFile = `${userPath}/${uid}.json`
|
|
if (fs.existsSync(userFile)) {
|
|
userData = JSON.parse(fs.readFileSync(userFile, 'utf8')) || {}
|
|
}
|
|
lodash.assignIn(userData, lodash.pick(data, 'uid,name,lv,avatar'.split(',')))
|
|
userData.chars = userData.chars || {}
|
|
lodash.forEach(data.chars, (char, charId) => {
|
|
let original = userData.chars[charId] || {}
|
|
if (char.dataSource === 'miao-pre' && original && original.dataSource) {
|
|
original.dataSource = char.dataSource
|
|
} else {
|
|
userData.chars[charId] = char
|
|
}
|
|
})
|
|
fs.writeFileSync(userFile, JSON.stringify(userData), '', ' ')
|
|
return data
|
|
},
|
|
|
|
saveCharData (uid, ds) {
|
|
if (!uid || !ds.id) {
|
|
return
|
|
}
|
|
let userData = {}
|
|
const userFile = `${userPath}/${uid}.json`
|
|
if (fs.existsSync(userFile)) {
|
|
userData = JSON.parse(fs.readFileSync(userFile, 'utf8')) || {}
|
|
}
|
|
userData.chars = userData.chars || {}
|
|
userData.chars[ds.id] = ds
|
|
fs.writeFileSync(userFile, JSON.stringify(userData), '', ' ')
|
|
return ds
|
|
},
|
|
|
|
_get (uid, charId) {
|
|
const userFile = `${userPath}/${uid}.json`
|
|
let userData = {}
|
|
if (fs.existsSync(userFile)) {
|
|
userData = JSON.parse(fs.readFileSync(userFile, 'utf8')) || {}
|
|
}
|
|
if (userData && userData.chars && userData.chars[charId]) {
|
|
return userData.chars[charId]
|
|
}
|
|
return false
|
|
},
|
|
|
|
async get (uid, charId, onlyAvailable = false) {
|
|
if (onlyAvailable) {
|
|
let data = await Profile.get(uid, charId)
|
|
if (data && data.dataSource && data.dataSource !== 'input') {
|
|
return data
|
|
}
|
|
return false
|
|
}
|
|
|
|
let data = Profile._get(uid, charId)
|
|
let Serv = getServ(uid)
|
|
if (Serv.getCharData && data && data.id) {
|
|
return await Serv.getCharData(uid, data, Profile.saveCharData, { sysCfg, diyCfg })
|
|
}
|
|
return data
|
|
},
|
|
|
|
getAll (uid) {
|
|
const userFile = `${userPath}/${uid}.json`
|
|
let userData = {}
|
|
if (fs.existsSync(userFile)) {
|
|
userData = JSON.parse(fs.readFileSync(userFile, 'utf8')) || {}
|
|
}
|
|
if (userData && userData.chars) {
|
|
return userData.chars
|
|
}
|
|
return false
|
|
},
|
|
|
|
formatArti (ds, markCfg = false, isMain = false) {
|
|
if (lodash.isArray(ds[0])) {
|
|
let ret = []
|
|
lodash.forEach(ds, (d) => {
|
|
ret.push(Profile.formatArti(d, markCfg, isMain))
|
|
})
|
|
return ret
|
|
}
|
|
let title = ds[0]
|
|
let val = ds[1]
|
|
let num = ds[1]
|
|
if (!title || title === 'undefined') {
|
|
return []
|
|
}
|
|
if (/伤害加成/.test(title) && val < 1) {
|
|
val = Format.pct(val * 100)
|
|
num = num * 100
|
|
} else if (/伤害加成|大|暴|充能|治疗/.test(title)) {
|
|
val = Format.pct(val)
|
|
} else {
|
|
val = Format.comma(val, 1)
|
|
}
|
|
|
|
if (/元素伤害加成/.test(title)) {
|
|
title = title.replace('元素伤害', '伤')
|
|
} else if (title === '物理伤害加成') {
|
|
title = '物伤加成'
|
|
}
|
|
|
|
let mark = 0
|
|
if (markCfg) {
|
|
mark = Format.comma(markCfg[title] * num || 0)
|
|
if (isMain) {
|
|
mark = mark / 4
|
|
}
|
|
}
|
|
return { title, val, mark }
|
|
},
|
|
|
|
inputProfile (uid, e) {
|
|
let { avatar, inputData } = e
|
|
let char = Character.get(avatar)
|
|
let originalData = Profile._get(uid, char.id)
|
|
if (!originalData || !['enka', 'input2'].includes(originalData.dataSource)) {
|
|
return `请先获取${char.name}的面板数据后，再进行面板数据更新`
|
|
}
|
|
inputData = inputData.replace('#', '')
|
|
inputData = inputData.replace(/[，；、\n\t]/g, ',')
|
|
let attr = originalData.attr || {}
|
|
let attrMap = {
|
|
hp: /生命/,
|
|
def: /防御/,
|
|
atk: /攻击/,
|
|
mastery: /精通/,
|
|
cRate: /(暴击率|暴率|暴击$)/,
|
|
cDmg: /(暴伤|暴击伤害)/,
|
|
hInc: /治疗/,
|
|
recharge: /充能/,
|
|
dmgBonus: /[火水雷草风岩冰素]伤|^伤/,
|
|
phyBonus: /(物理|物伤)/
|
|
}
|
|
lodash.forEach(inputData.split(','), (ds, idx) => {
|
|
ds = ds.trim()
|
|
if (!ds) {
|
|
return
|
|
}
|
|
let dRet = /(.*?)([0-9.+\s]+)/.exec(ds)
|
|
if (!dRet || !dRet[1] || !dRet[2]) {
|
|
return
|
|
}
|
|
let name = dRet[1].trim()
|
|
let data = dRet[2].trim()
|
|
name = name.replace('爆', '暴')
|
|
let range = (src, min = 0, max = 1200) => Math.max(min, Math.min(max, src * 1 || 0))
|
|
|
|
lodash.forEach(attrMap, (reg, key) => {
|
|
if (reg.test(name)) {
|
|
let tmp = data.split('+')
|
|
switch (key) {
|
|
case 'hp':
|
|
attr[key + 'Base'] = range(tmp[0].trim(), 0, 16000)
|
|
attr[key] = range(tmp[0].trim() * 1 + tmp[1].trim() * 1, attr[key + 'Base'], 50000)
|
|
break
|
|
case 'def':
|
|
case 'atk':
|
|
attr[key + 'Base'] = range(tmp[0].trim(), 0, 1100)
|
|
attr[key] = range(tmp[0].trim() * 1 + tmp[1].trim() * 1, attr[key + 'Base'], 4500)
|
|
break
|
|
case 'mastery':
|
|
attr[key] = range(data, 0, 1200)
|
|
break
|
|
case 'cRate':
|
|
attr[key] = range(data, -95, 120)
|
|
break
|
|
case 'cDmg':
|
|
attr[key] = range(data, 0, 320)
|
|
break
|
|
case 'recharge':
|
|
case 'hInc':
|
|
attr[key] = range(data, 0, 400)
|
|
break
|
|
case 'dmgBonus':
|
|
case 'phyBonus':
|
|
attr[key] = range(data, 0, 200)
|
|
break
|
|
}
|
|
}
|
|
})
|
|
})
|
|
|
|
if (lodash.keys(attr) < 3) {
|
|
return false
|
|
}
|
|
|
|
originalData.dataSource = 'input2'
|
|
originalData.attr = attr
|
|
|
|
let userData = {}
|
|
const userFile = `${userPath}/${uid}.json`
|
|
if (fs.existsSync(userFile)) {
|
|
userData = JSON.parse(fs.readFileSync(userFile, 'utf8')) || {}
|
|
}
|
|
userData.chars = userData.chars || {}
|
|
userData.chars[avatar] = originalData
|
|
fs.writeFileSync(userFile, JSON.stringify(userData), '', ' ')
|
|
return true
|
|
}
|
|
}
|
|
export default Profile
|