shingyu/yenai-plugin
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

🎨 氵

Browse Source
This commit is contained in:
yeyang
2024-04-23 21:13:29 +08:00
parent af26c64650
commit d52dc665f4
9 changed files with 429 additions and 397 deletions
Download Patch File Download Diff File Expand all files Collapse all files

374
apps/assistant.js
View File

@@ -1,19 +1,11 @@
import _ from "lodash"
import moment from "moment"
import fs from "node:fs"
import yaml from "yaml"
import { Config, Version } from "../components/index.js"
import { status } from "../constants/other.js"
import { common, QQApi } from "../model/index.js"
import { sleep } from "../tools/index.js"
/** API请求错误文案 */
const API_ERROR = "❎ 出错辣，请稍后重试"
import { API_ERROR } from "../constants/errorMsg.js"
// 命令正则
let FriendsReg = /^#发好友\s?(\d+)\s?([^]*)$/
let GroupMsgReg = /^#发群聊\s?(\d+)\s?([^]*)$/
let GroupListMsgReg = /^#发群列表\s?(\d+(,\d+){0,})\s?([^]*)$/
let friendTypeReg = /^#更改好友申请方式([0123])((.*)\s(.*))?$/
export class Assistant extends plugin {
@@ -39,18 +31,6 @@ export class Assistant extends plugin {
reg: "^#改状态",
fnc: "SetOnlineStatus"
},
{
reg: FriendsReg, // 发好友
fnc: "SendFriendMsg"
},
{
reg: GroupMsgReg, // 发群聊
fnc: "SendGroupMsg"
},
{
reg: GroupListMsgReg, // 发群列表
fnc: "SendGroupListMsg"
},
{
reg: "^#退群",
fnc: "QuitGroup"
@@ -71,22 +51,6 @@ export class Assistant extends plugin {
reg: "^#取face",
fnc: "Face"
},
{
reg: "^#获?取说说列表(\\d+)?$",
fnc: "Qzonelist"
},
{
reg: "^#删说说(\\d+)$",
fnc: "Qzonedel"
},
{
reg: "^#发说说",
fnc: "Qzonesay"
},
{
reg: "^#(清空说说|清空留言)$",
fnc: "QzonedelAll"
},
{
reg: "^#改群名片",
fnc: "SetGroupCard"
@@ -124,12 +88,8 @@ export class Assistant extends plugin {
fnc: "setModel"
},
{
reg: "^#拉[黑白](群聊?)?",
fnc: "BlockOne"
},
{
reg: "^#(取消|(删|移)除)拉[黑白](群聊?)?",
fnc: "CancelBlockOne"
reg: "^#?(查?看|取)头像",
fnc: "LookAvatar"
}
]
})
@@ -367,104 +327,6 @@ export class Assistant extends plugin {
return true
}
/**
* 发好友
* @param e
*/
async SendFriendMsg(e) {
if (!common.checkPermission(e, "master")) return
let regRet = FriendsReg.exec(e.msg)
let qq = regRet[1]
e.message[0].text = regRet[2]
if (!/^\d+$/.test(qq)) return e.reply("❎ QQ号不正确，人家做不到的啦>_<~")
if (!this.Bot.fl.get(Number(qq))) return e.reply("❎ 好友列表查无此人")
if (!e.message[0].text) e.message.shift()
if (e.message.length === 0) return e.reply("❎ 消息不能为空")
await this.Bot.pickFriend(qq).sendMsg(e.message)
.then(() => e.reply("✅ 私聊消息已送达"))
.catch(err => common.handleException(e, err, { MsgTemplate: "❎ 发送失败\n错误信息为:{error}" }))
}
/**
* 发群聊
* @param e
*/
async SendGroupMsg(e) {
if (!common.checkPermission(e, "master")) return
let regRet = GroupMsgReg.exec(e.msg)
let gpid = regRet[1]
e.message[0].text = regRet[2]
if (!e.message[0].text) e.message.shift()
if (e.message.length === 0) return e.reply("❎ 消息不能为空")
if (!/^\d+$/.test(gpid)) return e.reply("❎ 您输入的群号不合法")
if (!this.Bot.gl.get(Number(gpid))) return e.reply("❎ 群聊列表查无此群")
await this.Bot.pickGroup(gpid).sendMsg(e.message)
.then(() => e.reply("✅ 群聊消息已送达"))
.catch((err) => common.handleException(e, err, { MsgTemplate: "❎ 发送失败\n错误信息为:{error}" }))
}
// 发送群列表
async SendGroupListMsg(e) {
if (!common.checkPermission(e, "master")) return
// 获取参数
let regRet = GroupListMsgReg.exec(e.msg)
let gpid = regRet[1]
e.message[0].text = regRet[3]
if (!e.message[0].text) e.message.shift()
if (e.message.length === 0) return e.reply("❎ 消息不能为空")
let groupidList = []
let sendList = []
// 获取群列表
let listMap = Array.from(this.Bot.gl.values())
listMap.forEach((item) => {
groupidList.push(item.group_id)
})
let groupids = gpid.split(",")
if (!groupids.every(item => item <= groupidList.length)) return e.reply("❎ 序号超过合法值！！！")
groupids.forEach((item) => {
sendList.push(groupidList[Number(item) - 1])
})
if (sendList.length > 3) return e.reply("❎ 不能同时发太多群聊，号寄概率增加！！！")
if (sendList.length === 1) {
await this.Bot.pickGroup(sendList[0]).sendMsg(e.message)
.then(() => e.reply("✅ " + sendList[0] + " 群聊消息已送达"))
.catch((err) =>
common.handleException(e, err, { MsgTemplate: `❎ ${sendList[0]} 发送失败\n错误信息为:{error}` })
)
} else {
e.reply("发送多个群聊，将每5秒发送一条消息！")
for (let i of sendList) {
await this.Bot.pickGroup(i).sendMsg(e.message)
.then(() => e.reply("✅ " + i + " 群聊消息已送达"))
.catch((err) =>
common.handleException(e, err, { MsgTemplate: `❎ ${i} 发送失败\n错误信息为:{error}` }))
await sleep(5000)
}
}
return false
}
/**
* 退群
* @param e
@@ -630,122 +492,6 @@ export class Assistant extends plugin {
}
}
/**
* QQ空间 说说列表
* @param e
*/
async Qzonelist(e) {
if (!common.checkPermission(e, "master")) return
let page = e.msg.replace(/#|获?取说说列表/g, "").trim()
if (!page) {
page = 0
} else {
page = page - 1
}
// 获取说说列表
let list = await new QQApi(e).getQzone(5, page * 5)
if (!list) return e.reply(API_ERROR)
if (list.total == 0) return e.reply("✅ 说说列表为空")
let msg = [
"✅ 获取成功，说说列表如下:\n",
...list.msglist.map((item, index) =>
`${page * 5 + index + 1}.${_.truncate(item.content, { length: 15 })}\n- [${item.secret ? "私密" : "公开"}] | ${moment(item.created_time * 1000).format("MM/DD HH:mm")} | ${item.commentlist?.length || 0}条评论\n`
),
`页数：[${page + 1}/${Math.ceil(list.total / 5)}]`
]
e.reply(msg)
}
/**
* 删除说说
* @param e
*/
async Qzonedel(e) {
if (!common.checkPermission(e, "master")) return
let pos = e.msg.match(/\d+/)
// 获取说说列表
let list = await new QQApi(e).getQzone(1, pos - 1)
if (!list) return e.reply(API_ERROR)
if (!list.msglist) return e.reply("❎ 未获取到该说说")
// 要删除的说说
let domain = list.msglist[0]
// 请求接口
let result = await new QQApi(e).delQzone(domain.tid, domain.t1_source)
if (!result) return e.reply(API_ERROR)
// debug
logger.debug(e.logFnc, result)
if (result.subcode != 0) e.reply("❎ 未知错误" + JSON.parse(result))
// 发送结果
e.reply(`✅ 删除说说成功：\n ${pos}.${_.truncate(domain.content, { length: 15 })} \n - [${domain.secret ? "私密" : "公开"}] | ${moment(domain.created_time * 1000).format("MM/DD HH:mm")} | ${domain.commentlist?.length || 0} 条评论`)
}
/**
* 发说说
* @param e
*/
async Qzonesay(e) {
if (!common.checkPermission(e, "master")) return
let con = e.msg.replace(/#|发说说/g, "").trim()
let result = await new QQApi(e).setQzone(con, e.img)
if (!result) return e.reply(API_ERROR)
if (result.code != 0) return e.reply(`❎ 说说发表失败\n${JSON.stringify(result)}`)
let msg = [ "✅ 说说发表成功，内容：\n", _.truncate(result.content, { length: 15 }) ]
if (result.pic) {
msg.push(segment.image(result.pic[0].url1))
}
msg.push(`\n- [${result.secret ? "私密" : "公开"}] | ${moment(result.t1_ntime * 1000).format("MM/DD HH:mm")}`)
e.reply(msg)
}
/**
* 清空说说和留言
* @param e
*/
async QzonedelAll(e) {
if (!common.checkPermission(e, "master")) return
if (/清空说说/.test(e.msg)) {
this.setContext("_QzonedelAllContext")
e.reply("✳️ 即将删除全部说说请发送：\n" + "------确认清空或取消------")
e.Qzonedetermine = true
} else if (/清空留言/.test(e.msg)) {
this.setContext("_QzonedelAllContext")
e.reply("✳️ 即将删除全部留言请发送：\n" + "------确认清空或取消------")
e.Qzonedetermine = false
}
}
async _QzonedelAllContext(e) {
let msg = this.e.msg
if (/#?确认清空/.test(msg)) {
this.finish("_QzonedelAllContext")
let result
if (e.Qzonedetermine) {
result = await new QQApi(this.e).delQzoneAll()
} else {
result = await new QQApi(this.e).delQzoneMsgbAll()
}
this.e.reply(result)
return true
} else if (/#?取消/.test(msg)) {
this.finish("_QzonedelAllContext")
this.e.reply("✅ 已取消")
return false
} else {
this.setContext("_QzonedelAllContext")
this.e.reply("❎ 请输入:确认清空或取消")
return false
}
}
// 获取群|好友列表
async GlOrFl(e) {
if (!common.checkPermission(e, "master")) return
@@ -859,109 +605,19 @@ export class Assistant extends plugin {
e.reply(_.get(res, [ "13031", "data", "rsp", "iRet" ]) == 0 ? "设置成功" : "设置失败")
}
async BlockOne(e) {
if (!common.checkPermission(e, "master")) return
let type = ""
let name = "拉"
if (/^#拉白(群聊?)?/.test(this.e.msg)) {
type += "white"
name += "白"
} else {
type += "black"
name += "黑"
}
if (/^#拉[黑白](群聊?)/.test(this.e.msg)) {
type += "Group"
name += "群"
} else {
type += Version.name == "TRSS-Yunzai" ? "User" : "QQ"
}
const configPath = "config/config/other.yaml"
/** 判断at */
if (this.e.at) {
this.blackResult = this.e.at
} else {
if (Version.name == "TRSS-Yunzai") {
/** TRSS-Yunzai匹配所有字符 */
const blackId = this.e.msg.replace(/^#拉[黑白](群聊?)?/, "").trim()
this.blackResult = Number(blackId) || String(blackId)
} else {
const match = this.e.msg.match(/\d+/)
if (match?.[0]) { this.blackResult = Number(match[0]) || String(match[0]) }
}
}
if (!this.blackResult || common.getPermission(new Proxy({
get isMaster() { return Config.masterQQ.includes(this.user_id) || Config.masterQQ.includes(String(this.user_id)) },
user_id: this.blackResult
}, {
get: (target, prop, receiver) => target[prop] ?? e[prop]
}), "master") === true) { return this.e.reply(`❎ ${name}失败，没有键入用户或群号`) }
// 查看头像
async LookAvatar() {
const id = this.e.msg.replace(/^#?((查?看头像)|取头像)/, "").trim() || this.e.at ||
this.e.message.find(item => item.type == "at")?.qq || this.e.user_id
try {
const yamlContentBuffer = await fs.promises.readFile(configPath)
const yamlContent = yamlContentBuffer.toString("utf-8")
const data = yaml.parse(yamlContent)
if (!Array.isArray(data[type])) { data[type] = [] }
if (!data[type].includes(this.blackResult)) {
data[type].push(this.blackResult)
const updatedYaml = yaml.stringify(data, { quote: false })
const resultYaml = updatedYaml.replace(/"/g, "")
await fs.promises.writeFile(configPath, resultYaml, "utf-8")
await this.e.reply(`✅ 已把这个坏淫${name}掉惹！！！`)
} else {
await this.e.reply(`❎ 已把这个坏淫${name}过辣`)
}
let url = await this.e.group?.pickMember(id)?.getAvatarUrl()
if (!url) url = await this.e.bot.pickFriend(id).getAvatarUrl()
const msgTest = this.e.msg.includes("取头像")
if (url) return await this.e.reply(msgTest ? `${url}` : segment.image(url))
} catch (error) {
await this.e.reply(`❎ 额...${name}失败哩，可能这个淫比较腻害>_<`)
logger.error(error)
}
}
async CancelBlockOne(e) {
if (!common.checkPermission(e, "master")) return
let type = ""
let name = "取消拉"
if (/^#(取消|删除|移除)(群聊?)?拉白(群聊?)?/.test(this.e.msg)) {
type += "white"
name += "白"
} else {
type += "black"
name += "黑"
}
if (/^#(取消|删除|移除)拉[黑白](群聊?)/.test(this.e.msg)) {
type += "Group"
name += "群"
} else {
type += Version.name == "TRSS-Yunzai" ? "User" : "QQ"
}
const configPath = "config/config/other.yaml"
if (this.e.at) {
this.blackResult = this.e.at
} else {
if (Version.name == "TRSS-Yunzai") {
const blackId = this.e.msg.replace(/^#(取消|(删|移)除)拉[黑白](群聊?)?/, "").trim()
this.blackResult = Number(blackId) || String(blackId)
} else {
const match = this.e.msg.match(/\d+/)
if (match?.[0]) { this.blackResult = Number(match[0]) || String(match[0]) }
}
}
if (!this.blackResult) { return this.e.reply(`❎ ${name}失败，没有键入用户或群号`) }
try {
const yamlContentBuffer = await fs.promises.readFile(configPath)
const yamlContent = yamlContentBuffer.toString("utf-8")
const data = yaml.parse(yamlContent)
if (Array.isArray(data[type]) && data[type].includes(this.blackResult)) {
const itemToRemove = this.blackResult.toString()
data[type] = data[type].filter(item => item.toString() !== itemToRemove)
const updatedYaml = yaml.stringify(data)
await fs.promises.writeFile(configPath, updatedYaml, "utf-8")
await this.e.reply(`✅ 已把这个坏淫${name}掉惹！！！`)
} else {
await this.e.reply(`❎ ${name}失败，找不到辣>_<`)
}
} catch (error) {
await this.e.reply(`❎ 额...${name}失败哩，可能这个淫比较腻害>_<`)
logger.error(error)
logger.error("获取头像错误", error)
}
await this.reply("❎ 获取头像错误", true)
return false
}
}

130
apps/assistant/BlockOne.js Normal file
View File

@@ -0,0 +1,130 @@
import fs from "node:fs"
import yaml from "yaml"
import { Config, Version } from "../../components/index.js"
import { common } from "../../model/index.js"
export class BlockOne extends plugin {
constructor() {
super({
name: "椰奶助手-拉黑白名单",
event: "message.group",
priority: 500,
rule: [
{
reg: "^#拉[黑白](群聊?)?",
fnc: "BlockOne"
},
{
reg: "^#(取消|(删|移)除)拉[黑白](群聊?)?",
fnc: "CancelBlockOne"
}
]
})
}
async BlockOne(e) {
if (!common.checkPermission(e, "master")) return
let type = ""
let name = "拉"
if (/^#拉白(群聊?)?/.test(this.e.msg)) {
type += "white"
name += "白"
} else {
type += "black"
name += "黑"
}
if (/^#拉[黑白](群聊?)/.test(this.e.msg)) {
type += "Group"
name += "群"
} else {
type += Version.name == "TRSS-Yunzai" ? "User" : "QQ"
}
const configPath = "config/config/other.yaml"
/** 判断at */
if (this.e.at) {
this.blackResult = this.e.at
} else {
if (Version.name == "TRSS-Yunzai") {
/** TRSS-Yunzai匹配所有字符 */
const blackId = this.e.msg.replace(/^#拉[黑白](群聊?)?/, "").trim()
this.blackResult = Number(blackId) || String(blackId)
} else {
const match = this.e.msg.match(/\d+/)
if (match?.[0]) { this.blackResult = Number(match[0]) || String(match[0]) }
}
}
if (!this.blackResult || common.getPermission(new Proxy({
get isMaster() { return Config.masterQQ.includes(this.user_id) || Config.masterQQ.includes(String(this.user_id)) },
user_id: this.blackResult
}, {
get: (target, prop, receiver) => target[prop] ?? e[prop]
}), "master") === true) { return this.e.reply(`❎ ${name}失败，没有键入用户或群号`) }
try {
const yamlContentBuffer = await fs.promises.readFile(configPath)
const yamlContent = yamlContentBuffer.toString("utf-8")
const data = yaml.parse(yamlContent)
if (!Array.isArray(data[type])) { data[type] = [] }
if (!data[type].includes(this.blackResult)) {
data[type].push(this.blackResult)
const updatedYaml = yaml.stringify(data, { quote: false })
const resultYaml = updatedYaml.replace(/"/g, "")
await fs.promises.writeFile(configPath, resultYaml, "utf-8")
await this.e.reply(`✅ 已把这个坏淫${name}掉惹！！！`)
} else {
await this.e.reply(`❎ 已把这个坏淫${name}过辣`)
}
} catch (error) {
await this.e.reply(`❎ 额...${name}失败哩，可能这个淫比较腻害>_<`)
logger.error(error)
}
}
async CancelBlockOne(e) {
if (!common.checkPermission(e, "master")) return
let type = ""
let name = "取消拉"
if (/^#(取消|删除|移除)(群聊?)?拉白(群聊?)?/.test(this.e.msg)) {
type += "white"
name += "白"
} else {
type += "black"
name += "黑"
}
if (/^#(取消|删除|移除)拉[黑白](群聊?)/.test(this.e.msg)) {
type += "Group"
name += "群"
} else {
type += Version.name == "TRSS-Yunzai" ? "User" : "QQ"
}
const configPath = "config/config/other.yaml"
if (this.e.at) {
this.blackResult = this.e.at
} else {
if (Version.name == "TRSS-Yunzai") {
const blackId = this.e.msg.replace(/^#(取消|(删|移)除)拉[黑白](群聊?)?/, "").trim()
this.blackResult = Number(blackId) || String(blackId)
} else {
const match = this.e.msg.match(/\d+/)
if (match?.[0]) { this.blackResult = Number(match[0]) || String(match[0]) }
}
}
if (!this.blackResult) { return this.e.reply(`❎ ${name}失败，没有键入用户或群号`) }
try {
const yamlContentBuffer = await fs.promises.readFile(configPath)
const yamlContent = yamlContentBuffer.toString("utf-8")
const data = yaml.parse(yamlContent)
if (Array.isArray(data[type]) && data[type].includes(this.blackResult)) {
const itemToRemove = this.blackResult.toString()
data[type] = data[type].filter(item => item.toString() !== itemToRemove)
const updatedYaml = yaml.stringify(data)
await fs.promises.writeFile(configPath, updatedYaml, "utf-8")
await this.e.reply(`✅ 已把这个坏淫${name}掉惹！！！`)
} else {
await this.e.reply(`❎ ${name}失败，找不到辣>_<`)
}
} catch (error) {
await this.e.reply(`❎ 额...${name}失败哩，可能这个淫比较腻害>_<`)
logger.error(error)
}
}
}

148
apps/assistant/Qzone.js Normal file
View File

@@ -0,0 +1,148 @@
import _ from "lodash"
import moment from "moment"
import { common, QQApi } from "../../model/index.js"
import { API_ERROR } from "../../constants/errorMsg.js"
export class Qzone extends plugin {
constructor() {
super({
name: "椰奶助手-空间",
event: "message.group",
priority: 500,
rule: [
{
reg: "^#获?取说说列表(\\d+)?$",
fnc: "Qzonelist"
},
{
reg: "^#删说说(\\d+)$",
fnc: "Qzonedel"
},
{
reg: "^#发说说",
fnc: "Qzonesay"
},
{
reg: "^#(清空说说|清空留言)$",
fnc: "QzonedelAll"
}
]
})
}
/**
* QQ空间 说说列表
* @param e
*/
async Qzonelist(e) {
if (!common.checkPermission(e, "master")) return
let page = e.msg.replace(/#|获?取说说列表/g, "").trim()
if (!page) {
page = 0
} else {
page = page - 1
}
// 获取说说列表
let list = await new QQApi(e).getQzone(5, page * 5)
if (!list) return e.reply(API_ERROR)
if (list.total == 0) return e.reply("✅ 说说列表为空")
let msg = [
"✅ 获取成功，说说列表如下:\n",
...list.msglist.map((item, index) =>
`${page * 5 + index + 1}.${_.truncate(item.content, { length: 15 })}\n- [${item.secret ? "私密" : "公开"}] | ${moment(item.created_time * 1000).format("MM/DD HH:mm")} | ${item.commentlist?.length || 0}条评论\n`
),
`页数：[${page + 1}/${Math.ceil(list.total / 5)}]`
]
e.reply(msg)
}
/**
* 删除说说
* @param e
*/
async Qzonedel(e) {
if (!common.checkPermission(e, "master")) return
let pos = e.msg.match(/\d+/)
// 获取说说列表
let list = await new QQApi(e).getQzone(1, pos - 1)
if (!list) return e.reply(API_ERROR)
if (!list.msglist) return e.reply("❎ 未获取到该说说")
// 要删除的说说
let domain = list.msglist[0]
// 请求接口
let result = await new QQApi(e).delQzone(domain.tid, domain.t1_source)
if (!result) return e.reply(API_ERROR)
// debug
logger.debug(e.logFnc, result)
if (result.subcode != 0) e.reply("❎ 未知错误" + JSON.parse(result))
// 发送结果
e.reply(`✅ 删除说说成功：\n ${pos}.${_.truncate(domain.content, { length: 15 })} \n - [${domain.secret ? "私密" : "公开"}] | ${moment(domain.created_time * 1000).format("MM/DD HH:mm")} | ${domain.commentlist?.length || 0} 条评论`)
}
/**
* 发说说
* @param e
*/
async Qzonesay(e) {
if (!common.checkPermission(e, "master")) return
let con = e.msg.replace(/#|发说说/g, "").trim()
let result = await new QQApi(e).setQzone(con, e.img)
if (!result) return e.reply(API_ERROR)
if (result.code != 0) return e.reply(`❎ 说说发表失败\n${JSON.stringify(result)}`)
let msg = [ "✅ 说说发表成功，内容：\n", _.truncate(result.content, { length: 15 }) ]
if (result.pic) {
msg.push(segment.image(result.pic[0].url1))
}
msg.push(`\n- [${result.secret ? "私密" : "公开"}] | ${moment(result.t1_ntime * 1000).format("MM/DD HH:mm")}`)
e.reply(msg)
}
/**
* 清空说说和留言
* @param e
*/
async QzonedelAll(e) {
if (!common.checkPermission(e, "master")) return
if (/清空说说/.test(e.msg)) {
this.setContext("_QzonedelAllContext")
e.reply("✳️ 即将删除全部说说请发送：\n" + "------确认清空或取消------")
this.e.Qzonedetermine = true
} else if (/清空留言/.test(e.msg)) {
this.setContext("_QzonedelAllContext")
e.reply("✳️ 即将删除全部留言请发送：\n" + "------确认清空或取消------")
this.e.Qzonedetermine = false
}
}
async _QzonedelAllContext() {
let msg = this.e.msg
if (/#?确认清空/.test(msg)) {
this.finish("_QzonedelAllContext")
let result
if (this.e.Qzonedetermine) {
result = await new QQApi(this.e).delQzoneAll()
} else {
result = await new QQApi(this.e).delQzoneMsgbAll()
}
this.e.reply(result)
return true
} else if (/#?取消/.test(msg)) {
this.finish("_QzonedelAllContext")
this.e.reply("✅ 已取消")
return false
} else {
this.setContext("_QzonedelAllContext")
this.e.reply("❎ 请输入:确认清空或取消")
return false
}
}
}

128
apps/assistant/sendMsg.js Normal file
View File

@@ -0,0 +1,128 @@
import { common } from "../../model/index.js"
import { sleep } from "../../tools/index.js"
let FriendsReg = /^#发好友\s?(\d+)\s?([^]*)$/
let GroupMsgReg = /^#发群聊\s?(\d+)\s?([^]*)$/
let GroupListMsgReg = /^#发群列表\s?(\d+(,\d+){0,})\s?([^]*)$/
export class sendMsg extends plugin {
constructor() {
super({
name: "椰奶助手-发消息",
event: "message.group",
priority: 500,
rule: [
{
reg: FriendsReg, // 发好友
fnc: "SendFriendMsg"
},
{
reg: GroupMsgReg, // 发群聊
fnc: "SendGroupMsg"
},
{
reg: GroupListMsgReg, // 发群列表
fnc: "SendGroupListMsg"
}
]
})
}
/**
* 发好友
* @param e
*/
async SendFriendMsg(e) {
if (!common.checkPermission(e, "master")) return
let regRet = FriendsReg.exec(e.msg)
let qq = regRet[1]
e.message[0].text = regRet[2]
if (!/^\d+$/.test(qq)) return e.reply("❎ QQ号不正确，人家做不到的啦>_<~")
if (!this.Bot.fl.get(Number(qq))) return e.reply("❎ 好友列表查无此人")
if (!e.message[0].text) e.message.shift()
if (e.message.length === 0) return e.reply("❎ 消息不能为空")
await this.Bot.pickFriend(qq).sendMsg(e.message)
.then(() => e.reply("✅ 私聊消息已送达"))
.catch(err => common.handleException(e, err, { MsgTemplate: "❎ 发送失败\n错误信息为:{error}" }))
}
/**
* 发群聊
* @param e
*/
async SendGroupMsg(e) {
if (!common.checkPermission(e, "master")) return
let regRet = GroupMsgReg.exec(e.msg)
let gpid = regRet[1]
e.message[0].text = regRet[2]
if (!e.message[0].text) e.message.shift()
if (e.message.length === 0) return e.reply("❎ 消息不能为空")
if (!/^\d+$/.test(gpid)) return e.reply("❎ 您输入的群号不合法")
if (!this.Bot.gl.get(Number(gpid))) return e.reply("❎ 群聊列表查无此群")
await this.Bot.pickGroup(gpid).sendMsg(e.message)
.then(() => e.reply("✅ 群聊消息已送达"))
.catch((err) => common.handleException(e, err, { MsgTemplate: "❎ 发送失败\n错误信息为:{error}" }))
}
// 发送群列表
async SendGroupListMsg(e) {
if (!common.checkPermission(e, "master")) return
// 获取参数
let regRet = GroupListMsgReg.exec(e.msg)
let gpid = regRet[1]
e.message[0].text = regRet[3]
if (!e.message[0].text) e.message.shift()
if (e.message.length === 0) return e.reply("❎ 消息不能为空")
let groupidList = []
let sendList = []
// 获取群列表
let listMap = Array.from(this.Bot.gl.values())
listMap.forEach((item) => {
groupidList.push(item.group_id)
})
let groupids = gpid.split(",")
if (!groupids.every(item => item <= groupidList.length)) return e.reply("❎ 序号超过合法值！！！")
groupids.forEach((item) => {
sendList.push(groupidList[Number(item) - 1])
})
if (sendList.length > 3) return e.reply("❎ 不能同时发太多群聊，号寄概率增加！！！")
if (sendList.length === 1) {
await this.Bot.pickGroup(sendList[0]).sendMsg(e.message)
.then(() => e.reply("✅ " + sendList[0] + " 群聊消息已送达"))
.catch((err) =>
common.handleException(e, err, { MsgTemplate: `❎ ${sendList[0]} 发送失败\n错误信息为:{error}` })
)
} else {
e.reply("发送多个群聊，将每5秒发送一条消息！")
for (let i of sendList) {
await this.Bot.pickGroup(i).sendMsg(e.message)
.then(() => e.reply("✅ " + i + " 群聊消息已送达"))
.catch((err) =>
common.handleException(e, err, { MsgTemplate: `❎ ${i} 发送失败\n错误信息为:{error}` }))
await sleep(5000)
}
}
return false
}
}

32
apps/fun.js
View File

@@ -1,21 +1,9 @@
import _ from "lodash"
import { Config } from "../components/index.js"
import { pandadiuType, xiurenTypeId } from "../constants/fun.js"
import { common, funApi, uploadRecord } from "../model/index.js"
/** 开始执行文案 */
const START_EXECUTION = "椰奶产出中......"
const picApis = Config.getConfig("picApi")
/** 解析匹配模式 */
const picApiKeys = []
_.forIn(picApis, (values, key) => {
let mode = values.mode !== undefined ? values.mode : picApis.mode
key = key.split("|").map(item => mode ? "^" + item + "$" : item).join("|")
picApiKeys.push(key)
})
export class Fun extends plugin {
constructor(e) {
super({
@@ -50,10 +38,6 @@ export class Fun extends plugin {
{
reg: `^#来点(${Object.keys(xiurenTypeId).join("|")})$`,
fnc: "xiuren"
},
{
reg: "^#?(查?看|取)头像",
fnc: "LookAvatar"
}
]
})
@@ -162,20 +146,4 @@ export class Fun extends plugin {
.then(res => common.recallSendForwardMsg(e, res))
.catch(err => common.handleException(e, err))
}
// 查看头像
async LookAvatar() {
const id = this.e.msg.replace(/^#?((查?看头像)|取头像)/, "").trim() || this.e.at ||
this.e.message.find(item => item.type == "at")?.qq || this.e.user_id
try {
let url = await this.e.group?.pickMember(id)?.getAvatarUrl()
if (!url) url = await this.e.bot.pickFriend(id).getAvatarUrl()
const msgTest = this.e.msg.includes("取头像")
if (url) return await this.e.reply(msgTest ? `${url}` : segment.image(url))
} catch (error) {
logger.error("获取头像错误", error)
}
await this.reply("❎ 获取头像错误", true)
return false
}
}

4
apps/groupAdmin/groupAdminOther.js
View File

@@ -1,8 +1,8 @@
import moment from "moment"
import _ from "lodash"
import { QQApi, common, puppeteer } from "../../model/index.js"
// API请求错误文案
const API_ERROR = "❎ 出错辣，请稍后重试"
import { API_ERROR } from "../../constants/errorMsg.js"
export class GroupAdminOther extends plugin {
constructor() {
super({

4
apps/groupAdmin/groupAnnounce.js
View File

@@ -1,6 +1,6 @@
import { QQApi, common } from "../../model/index.js"
// API请求错误文案
const API_ERROR = "❎ 出错辣，请稍后重试"
import { API_ERROR } from "../../constants/errorMsg.js"
export class GroupAnnounce extends plugin {
constructor() {
super({

4
apps/groupAdmin/groupLuckyword.js
View File

@@ -1,6 +1,6 @@
import { QQApi, common } from "../../model/index.js"
// API请求错误文案
const API_ERROR = "❎ 出错辣，请稍后重试"
import { API_ERROR } from "../../constants/errorMsg.js"
export class GroupLuckyword extends plugin {
constructor() {
super({

2
constants/errorMsg.js Normal file
View File

@@ -0,0 +1,2 @@
/** API请求错误message */
export const API_ERROR = "❎ 出错辣，请稍后重试"