510 lines
12 KiB
JavaScript
510 lines
12 KiB
JavaScript
import plugin from '../../../lib/plugins/plugin.js'
|
||
import { segment } from "oicq";
|
||
import fetch from 'node-fetch'
|
||
import fs from 'fs'
|
||
import Cfg from '../model/Config.js';
|
||
import lodash from "lodash";
|
||
import { Config } from '../components/index.js'
|
||
//默认配置
|
||
let def = {
|
||
r18: 0,
|
||
recall: 30,
|
||
cd: 300,
|
||
}
|
||
//存cd的变量
|
||
let temp = {};
|
||
|
||
let api = "https://api.lolicon.app/setu/v2";
|
||
|
||
let startMsg = [
|
||
"正在给你找setu了，你先等等再冲~",
|
||
"你先别急，正在找了~",
|
||
"马上去给你找涩图，你先憋一会~"
|
||
]
|
||
|
||
let CDMsg = [
|
||
"你这么喜欢色图，还不快点冲！",
|
||
"你的色图不出来了！",
|
||
"注意身体，色图看多了对身体不太好",
|
||
"憋住，不准冲！",
|
||
"憋再冲了！",
|
||
"呃...好像冲了好多次...感觉不太好呢...",
|
||
"憋冲了！你已经冲不出来了！",
|
||
"你急啥呢？",
|
||
"你是被下半身控制了大脑吗？"
|
||
]
|
||
let sendMsg = [
|
||
"给大佬递图",
|
||
"这是你的🐍图",
|
||
"你是大色批",
|
||
"看！要色图的色批出现了！",
|
||
"？",
|
||
"喏，图",
|
||
"给给给个🐍图",
|
||
"色图有我好冲吗？",
|
||
"呐呐呐，欧尼酱别看色图了呐",
|
||
"有什么好色图有给发出来让大伙看看！",
|
||
"没有，有也不给（骗你的～）",
|
||
"天天色图色图的，今天就把你变成色图！",
|
||
"咱没有色图（骗你的～）",
|
||
"哈？你的脑子一天都在想些什么呢，咱才没有这种东西啦。",
|
||
"呀！不要啊！等一...下~",
|
||
"呜...不要啦！太色了咱~",
|
||
"不要这样子啦(*/ω＼*)",
|
||
"Hen....Hentai！。",
|
||
"讨....讨厌了（脸红）",
|
||
"你想...想做什么///",
|
||
"啊.....你...你要干什么？！走开.....走开啦大hentai！一巴掌拍飞！(╯‵□′)╯︵┻━┻",
|
||
"变态baka死宅？",
|
||
"已经可以了，现在很多死宅也都没你这么恶心了",
|
||
"噫…你这个死变态想干嘛！居然想叫咱做这种事，死宅真恶心！快离我远点，我怕你污染到周围空气了（嫌弃脸）",
|
||
"这么喜欢色图呢？不如来点岛风色图？",
|
||
"hso！",
|
||
"这么喜欢看色图哦？变态？",
|
||
"eee，死肥宅不要啦！恶心心！",
|
||
]
|
||
export class sese extends plugin {
|
||
constructor() {
|
||
super({
|
||
name: 'setu',
|
||
event: 'message',
|
||
priority: 5000,
|
||
rule: [
|
||
{
|
||
reg: '^#椰奶tag(.*)$',
|
||
fnc: 'setutag'
|
||
},
|
||
{
|
||
reg: '^#(setu|无内鬼)(\\s?\\d+?张)?$',
|
||
fnc: 'setu'
|
||
},
|
||
{
|
||
reg: '^#撤回间隔[0-9]+$',
|
||
fnc: 'setrecall'
|
||
},
|
||
{
|
||
reg: '^#群cd[0-9]+$',
|
||
fnc: 'groupcd'
|
||
},
|
||
{
|
||
reg: '^#(开启|关闭)(私聊)?涩涩$',
|
||
fnc: 'setsese'
|
||
},
|
||
{
|
||
reg: '^.*cd[0-9]+$',
|
||
fnc: 'atcd'
|
||
}
|
||
]
|
||
})
|
||
this.fk = "./plugins/yenai-plugin/resources/img/风控.png"
|
||
this.path_folder = "./plugins/yenai-plugin/config/setu"
|
||
this.path = "./plugins/yenai-plugin/config/setu/setu.json"
|
||
this.path_s = "./plugins/yenai-plugin/config/setu/setu_s.json"
|
||
}
|
||
|
||
async init() {
|
||
if (!fs.existsSync(this.path_folder)) {
|
||
fs.mkdirSync(this.path_folder)
|
||
}
|
||
}
|
||
|
||
async setu(e) {
|
||
if (!e.isMaster) {
|
||
if (!Config.Notice.sese) return
|
||
}
|
||
|
||
let cds = await this.getcd(e)
|
||
|
||
if (cds) return e.reply(` ${lodash.sample(CDMsg)}你的CD还有${cds}`, false, { at: true })
|
||
|
||
let num = e.msg.match(/\d?\d张/)
|
||
|
||
if (!num) {
|
||
num = 1
|
||
} else {
|
||
num = num[0].replace("张", "").trim()
|
||
}
|
||
|
||
if (num > 20) {
|
||
return e.reply("❎ 最大张数不能大于20张")
|
||
} else if (num > 5) {
|
||
e.reply("你先等等，你冲的有点多~")
|
||
} else {
|
||
e.reply(lodash.sample(startMsg))
|
||
}
|
||
|
||
let r18 = await this.getr18(e)
|
||
|
||
let res = await this.setuapi(r18, num)
|
||
|
||
if (!res) return e.reply("接口失效")
|
||
|
||
this.sendMsg(e, res)
|
||
|
||
}
|
||
|
||
//tag搜图
|
||
async setutag(e) {
|
||
if (!e.isMaster) {
|
||
if (!Config.Notice.sese) return
|
||
}
|
||
|
||
let cds = await this.getcd(e)
|
||
|
||
if (cds) return e.reply(` ${lodash.sample(CDMsg)}你的CD还有${cds}`, false, { at: true })
|
||
|
||
let msg = e.msg.replace(/#|椰奶tag/g, "").trim()
|
||
|
||
let num = e.msg.match(/\d?\d张/)
|
||
|
||
if (!num) {
|
||
num = 1
|
||
} else {
|
||
msg = msg.replace(num[0], "").trim()
|
||
num = num[0].replace("张", "").trim()
|
||
}
|
||
|
||
if (num > 20) {
|
||
return e.reply("❎ 最大张数不能大于20张")
|
||
} else if (num > 5) {
|
||
e.reply("你先等等，你冲的有点多~")
|
||
} else {
|
||
e.reply(lodash.sample(startMsg))
|
||
}
|
||
|
||
if (!msg) return e.reply("tag为空！！！", false, { at: true })
|
||
|
||
msg = msg.split(" ")
|
||
|
||
if (msg.length > 3) return e.reply("tag最多只能指定三个哦~", false, { at: true })
|
||
|
||
msg = msg.map((item) => {
|
||
return `&tag=${item}`
|
||
})
|
||
|
||
msg = msg.join("");
|
||
|
||
let r18 = await this.getr18(e)
|
||
//接口
|
||
let res = await this.setuapi(r18, num, msg)
|
||
|
||
if (!res) return e.reply("❎ 接口失效")
|
||
|
||
if (res.length == 0) return e.reply("没有找到相关的tag", false, { at: true })
|
||
//发送消息
|
||
this.sendMsg(e, res)
|
||
}
|
||
|
||
//设置撤回间隔
|
||
async setrecall(e) {
|
||
if (!e.isGroup) return e.reply("❎ 请在群聊使用此指令");
|
||
|
||
if (!e.isMaster) return e.reply("❎ 该命令仅限管理员可用", true);
|
||
|
||
let recall = e.msg.replace(/#|撤回间隔/g, "").trim()
|
||
|
||
let res = {};
|
||
|
||
if (!fs.existsSync(this.path)) {
|
||
res = await Cfg.getread(this.path)
|
||
}
|
||
|
||
if (!res[e.group_id]) res[e.group_id] = def
|
||
|
||
res[e.group_id].recall = Number(recall)
|
||
|
||
if (await Cfg.getwrite(this.path, res)) {
|
||
e.reply(`✅ 设置群${e.group_id}撤回间隔${recall}s成功`)
|
||
} else {
|
||
e.reply(`❎ 设置失败`)
|
||
}
|
||
|
||
}
|
||
|
||
//群CD
|
||
async groupcd(e) {
|
||
if (!e.isMaster) return e.reply("❎ 该命令仅限管理员可用", true);
|
||
|
||
let cd = e.msg.replace(/#|群cd/g, "").trim()
|
||
|
||
let res = {};
|
||
|
||
if (fs.existsSync(this.path)) {
|
||
res = await Cfg.getread(this.path)
|
||
}
|
||
|
||
if (!res[e.group_id]) res[e.group_id] = def
|
||
|
||
res[e.group_id].cd = Number(cd)
|
||
|
||
if (await Cfg.getwrite(this.path, res)) {
|
||
e.reply(`✅ 设置群${e.group_id}CD成功，CD为${cd}s`)
|
||
temp = {};
|
||
} else {
|
||
e.reply(`❎ 设置失败`)
|
||
}
|
||
}
|
||
|
||
//开启r18
|
||
async setsese(e) {
|
||
if (!e.isMaster) return e.reply("❎ 该命令仅限管理员可用", true);
|
||
|
||
let yes = false
|
||
let res = {};
|
||
|
||
if (/开启/.test(e.msg)) yes = true
|
||
|
||
if (/私聊/.test(e.msg) || !e.isGroup) {
|
||
|
||
if (fs.existsSync(this.path_s)) {
|
||
res = await Cfg.getread(this.path_s)
|
||
}
|
||
|
||
res.friendr18 = yes ? 1 : 0
|
||
|
||
if (await Cfg.getwrite(this.path_s, res)) {
|
||
e.reply(`✅ 已${yes ? "开启" : "关闭"}私聊涩涩功能~`)
|
||
} else {
|
||
e.reply(`❎ 设置失败`)
|
||
}
|
||
|
||
return;
|
||
}
|
||
|
||
if (fs.existsSync(this.path)) {
|
||
res = await Cfg.getread(this.path)
|
||
}
|
||
|
||
if (!res[e.group_id]) res[e.group_id] = def
|
||
|
||
|
||
res[e.group_id].r18 = yes ? 1 : 0
|
||
|
||
if (await Cfg.getwrite(this.path, res)) {
|
||
e.reply(`✅ 已${yes ? "开启" : "关闭"}${e.group_id}的涩涩模式~`)
|
||
} else {
|
||
e.reply(`❎ 设置失败`)
|
||
}
|
||
|
||
}
|
||
|
||
//单独设置私聊cd
|
||
async atcd(e) {
|
||
if (e.message[0].type != "at") return;
|
||
|
||
if (!e.isGroup) return e.reply("❎ 请在群聊使用此指令");
|
||
|
||
if (!e.isMaster) return e.reply("❎ 该命令仅限管理员可用", true);
|
||
|
||
let cd = e.msg.match(/[0-9]\d*/g)
|
||
|
||
if (!cd) return e.reply("❎ CD为空，请检查", true);
|
||
|
||
let qq = e.message[0].qq
|
||
|
||
let res = {};
|
||
if (fs.existsSync(this.path_s)) {
|
||
res = await Cfg.getread(this.path_s)
|
||
}
|
||
|
||
res[qq] = Number(cd)
|
||
if (await Cfg.getwrite(this.path_s, res)) {
|
||
e.reply(`✅ 设置用户${qq}的cd成功，cd时间为${cd}秒`)
|
||
delete temp[qq]
|
||
} else {
|
||
e.reply(`❎ 设置失败`)
|
||
}
|
||
|
||
}
|
||
|
||
//请求api
|
||
async setuapi(r18, num = 1, tag = "") {
|
||
let url = `${api}?r18=${r18}&num=${num}${tag}`;
|
||
let result = await fetch(url).then(res => res.json()).catch(err => console.log(err))
|
||
if (!result) return false;
|
||
return result.data
|
||
}
|
||
|
||
|
||
//发送消息
|
||
async sendMsg(e, img) {
|
||
//获取配置
|
||
let cfgs = {};
|
||
if (fs.existsSync(this.path)) {
|
||
cfgs = await Cfg.getread(this.path)
|
||
}
|
||
//默认撤回间隔
|
||
let time = def.recall
|
||
//默认CD
|
||
let cd = def.cd
|
||
//获取当前时间
|
||
let present = parseInt(new Date().getTime() / 1000)
|
||
//消息
|
||
let msg = [];
|
||
for (let i of img) {
|
||
let { pid, title, tags, author, r18 } = i
|
||
msg.push([
|
||
`${lodash.sample(sendMsg)}\n`,
|
||
`标题：${title}\n`,
|
||
`画师：${author}\n`,
|
||
`pid：${pid}\n`,
|
||
`r18：${r18}\n`,
|
||
`tag：${lodash.truncate(tags.join(","))}`,
|
||
segment.image(`https://pixiv.re/${pid}.png`),
|
||
])
|
||
}
|
||
|
||
|
||
//制作转发消息
|
||
let forwardMsg = []
|
||
for (let i of msg) {
|
||
forwardMsg.push(
|
||
{
|
||
message: i,
|
||
nickname: e.sender.nickname,
|
||
user_id: e.sender.user_id
|
||
}
|
||
)
|
||
}
|
||
if (e.isGroup) {
|
||
//看看有没有设置
|
||
if (cfgs[e.group_id]) {
|
||
time = cfgs[e.group_id].recall
|
||
cd = cfgs[e.group_id].cd
|
||
}
|
||
//发送消息并写入cd
|
||
forwardMsg = await e.group.makeForwardMsg(forwardMsg)
|
||
let res = await e.group.sendMsg(forwardMsg)
|
||
.then((item) => {
|
||
if (!e.isMaster) {
|
||
if (cd != 0) {
|
||
temp[e.user_id + e.group_id] = present + cd
|
||
setTimeout(() => {
|
||
delete temp[e.user_id + e.group_id];
|
||
}, cd * 1000);
|
||
}
|
||
}
|
||
return item
|
||
}).catch(() => {
|
||
e.reply(segment.image(this.fk))
|
||
logger.error("[椰奶]Bot被风控，发送被风控图片")
|
||
})
|
||
//撤回间隔
|
||
if (time > 0 && res && res.message_id) {
|
||
setTimeout(() => {
|
||
e.group.recallMsg(res.message_id);
|
||
logger.mark("[椰奶]执行撤回")
|
||
}, time * 1000);
|
||
}
|
||
} else {
|
||
//私聊
|
||
let CD = {};
|
||
if (fs.existsSync(this.path_s)) {
|
||
CD = await Cfg.getread(this.path_s)
|
||
}
|
||
if (CD[e.user_id]) {
|
||
CD = CD[e.user_id]
|
||
} else {
|
||
CD = def.cd
|
||
}
|
||
forwardMsg = await e.friend.makeForwardMsg(forwardMsg)
|
||
await e.friend.sendMsg(forwardMsg)
|
||
.then(() => {
|
||
if (!e.isMaster) {
|
||
if (CD != 0) {
|
||
temp[e.user_id] = present + CD
|
||
setTimeout(() => {
|
||
delete temp[e.user_id];
|
||
}, CD * 1000);
|
||
}
|
||
}
|
||
}).catch((err) => {
|
||
e.reply(segment.image(this.fk))
|
||
console.log(err);
|
||
})
|
||
}
|
||
}
|
||
|
||
//CD
|
||
async getcd(e) {
|
||
//获取现在的时间并转换为秒
|
||
let present = parseInt(new Date().getTime() / 1000)
|
||
|
||
if (e.isGroup) {
|
||
|
||
if (temp[e.user_id + e.group_id]) {
|
||
|
||
let over = (temp[e.user_id + e.group_id] - present)
|
||
|
||
if (over > 0) {
|
||
return Secondformat(over)
|
||
} else return false
|
||
|
||
} else return false
|
||
|
||
} else {
|
||
if (temp[e.user_id]) {
|
||
|
||
let over = (temp[e.user_id] - present)
|
||
|
||
if (over > 0) {
|
||
return Secondformat(over)
|
||
} else return false
|
||
|
||
} else return false
|
||
}
|
||
}
|
||
|
||
//获取r18
|
||
async getr18(e) {
|
||
let cfgs
|
||
if (e.isGroup) {
|
||
//获取配置
|
||
if (fs.existsSync(this.path)) {
|
||
cfgs = await Cfg.getread(this.path)
|
||
} else return def.r18
|
||
|
||
if (cfgs[e.group_id]) {
|
||
return cfgs[e.group_id].r18
|
||
} else {
|
||
return def.r18
|
||
}
|
||
} else {
|
||
if (fs.existsSync(this.path_s)) {
|
||
cfgs = await Cfg.getread(this.path_s)
|
||
} else return def.r18
|
||
|
||
if (cfgs.friendr18) {
|
||
return cfgs.friendr18
|
||
} else {
|
||
return def.r18
|
||
}
|
||
|
||
}
|
||
}
|
||
}
|
||
/**
|
||
* @description: 格式化秒
|
||
* @param {Number} value 秒
|
||
* @return {String}
|
||
*/
|
||
function Secondformat(value) {
|
||
let time = Cfg.getsecond(value)
|
||
|
||
let { second, minute, hour, day } = time
|
||
// 处理返回消息
|
||
let result = ''
|
||
if (second != 0) {
|
||
result = parseInt(second) + '秒'
|
||
}
|
||
if (minute > 0) {
|
||
result = parseInt(minute) + '分' + result
|
||
}
|
||
if (hour > 0) {
|
||
result = parseInt(hour) + '小时' + result
|
||
}
|
||
if (day > 0) {
|
||
result = parseInt(day) + '天' + result
|
||
}
|
||
return result
|
||
} |