创建我的世界服务器白名单管理

src/config/mc.yml

@@ -0,0 +1,4 @@
+#连接配置
+host: localhost
+port: 25575
+password: fenglin123

src/plugins/mc.ts

@@ -0,0 +1,219 @@
+import { param, plugins, runcod } from "../lib/decorators.js";
+import { Rcon } from "rcon-client"
+import { Permission } from '../lib/Permission.js';
+import { GroupMessage, PrivateFriendMessage, PrivateGroupMessage, Receive } from "node-napcat-ts";
+import { mccfg } from "../lib/config.js";
+import path from "path";
+import { fileURLToPath } from "url";
+import fs from 'fs'
+import { qqBot } from "../app.js";
+
+@plugins({
+    easycmd: true,
+    name: "我的世界工具箱",
+    version: "0.0.1",
+    describe: "这是一个我的世界工具箱，用来管理你的服务器",
+    author: "枫叶秋林",
+    help: {
+        enabled: true,
+        description: "查看帮助信息"
+    }
+})
+export class mc {
+    rcon: Rcon
+    constructor() {
+        this.rcon = new Rcon({
+            host: mccfg.host,
+            port: mccfg.port,
+            password: mccfg.password
+        })
+        qqBot.on('notice.group_decrease', async (context) => {
+            if (!context.user_id) {
+                return
+            }
+            const plId = await this.readpl(context.user_id)
+            if (plId?.plId) {
+                try {
+                    const rcon = await this.rcon.connect()
+                    if (context.sub_type === 'kick') {
+                        const res = await rcon.send(`ban ${plId?.plId}`)
+                        await this.deletepl(context.user_id)
+                        qqBot.send_group_msg({
+                            group_id: context.group_id,
+                            message: [{
+                                type: "text",
+                                data: {
+                                    text: `群友:${context.user_id}被踢出,玩家${plId.plId}已被封禁!:\n
+                                           指令执行结果：${res}`
+                                }
+                            }]
+                        })
+                        return
+                    }
+                    if (context.sub_type === 'leave') {
+                        const res = await rcon.send(`whitelist remove ${plId?.plId}`)
+                        if (res.includes(`Removed ${plId?.plId} from the whitelist`)) {
+                            await this.deletepl(context.user_id)
+                            qqBot.send_group_msg({
+                                group_id: context.group_id,
+                                message: [{
+                                    type: "text",
+                                    data: {
+                                        text: `群友:${context.user_id}离开群了,玩家${plId.plId}已移除白名单!`
+                                    }
+                                }]
+                            })
+                        }
+                    }
+                    rcon.end()
+                } catch (error) {
+                    console.log(error)
+                }
+            } else {
+                qqBot.send_group_msg({
+                    group_id: context.group_id,
+                    message: [{
+                        type: "text",
+                        data: {
+                            text: `群友:${context.user_id}离开群了,但是玩家${plId}不在白名单!`
+                        }
+                    }]
+                })
+            }
+        })
+    }
+
+    @runcod(["list", "在线玩家"], "查看在线玩家") //命令描述，用于显示在默认菜单中
+    async list() {
+        try {
+            const rcon = await this.rcon.connect()
+            const res = await rcon.send("list")
+            const players = res.split(":");
+            rcon.end()
+            return players[1]
+        } catch (error) {
+            return "连接失败"
+        }
+    }
+    @Permission('Admin')
+    @runcod(["指令", "cmd"], "运行指令") //命令描述，用于显示在默认菜单中
+    async cmd(@param("执行指令", 'text') runcod: Receive["text"]) {//参数装饰器，用于解析参数) {
+        try {
+            const rcon = await this.rcon.connect()
+            runcod.data.text = runcod.data.text?.replace(/,/g, ' ')
+            const res = await rcon.send(runcod?.data?.text ?? '')
+            rcon.end()
+            return res
+        } catch (error) {
+            return "连接失败"
+        }
+    }
+    @runcod(["绑定", ""], "绑定玩家") //命令描述，用于显示在默认菜单中
+    async bindPl(@param("Id", 'text') pId: Receive["text"],
+        context: PrivateFriendMessage | PrivateGroupMessage | GroupMessage) {
+        const seedId = context?.sender?.user_id ?? null
+        const plId = pId?.data?.text ?? null
+        if (!seedId || !plId) {
+            return "绑定失败"
+        }
+        try {
+            const rcon = await this.rcon.connect()
+            const res = await rcon.send(`whitelist add ${plId}`)
+            //Added feng_linH to the whitelist
+            if (res.includes(`Added ${plId} to the whitelist`)) {
+                await this.savepl(seedId, plId)
+                return "绑定成功!"
+            }
+            rcon.end()
+            return res
+        } catch (error: any) {
+            return `绑定失败:${error.message}`
+        }
+    }
+
+    @runcod(["解绑", ""], "解绑玩家") //命令描述，用于显示在默认菜单中
+    async unBindPl(
+        context: PrivateFriendMessage | PrivateGroupMessage | GroupMessage) {
+        const seedId = context?.sender?.user_id ?? null
+        if (!seedId) {
+            return "解绑失败"
+        }
+        try {
+            const plId = await this.readpl(seedId)
+            if (!plId) {
+                return "解绑失败"
+            }
+            const rcon = await this.rcon.connect()
+            const res = await rcon.send(`whitelist remove ${plId}`)
+            //Removed feng_linH from the whitelist
+            if (res.includes(`Removed ${plId} from the whitelist`)) {
+                await this.savepl(seedId, '')
+                return "解绑成功!"
+            }
+            rcon.end()
+            return res
+        } catch (error: any) {
+            return `解绑失败:${error.message}`
+        }
+    }
+
+
+
+    private async savepl(seedId: number, plId: string): Promise<void> {
+        const __dirname = path.dirname(fileURLToPath(import.meta.url));
+        //json
+        const filePath = path.join(__dirname, '..', '..', 'botQQ_screenshots', 'mcData.json');
+        let data: any = {};
+        if (fs.existsSync(filePath)) {
+            const fileContent = fs.readFileSync(filePath, 'utf-8');
+            data = JSON.parse(fileContent);
+        } else {
+            fs.writeFileSync(filePath, JSON.stringify(data));
+        }
+        if (data[seedId]) {
+            data[seedId].plId = plId;
+            data[seedId].updatetime = new Date().getTime()
+        } else {
+            data[seedId] = {
+                plId,
+                createtime: new Date().getTime(),
+                updatetime: new Date().getTime(),
+            }
+        }
+        fs.writeFileSync(filePath, JSON.stringify(data));
+        return;
+    }
+
+    private async readpl(seedId: number): Promise<{ plId: string, createtime: number, updatetime: number } | undefined> {
+        const __dirname = path.dirname(fileURLToPath(import.meta.url));
+        const filePath = path.join(__dirname, '..', '..', 'botQQ_screenshots', 'mcData.json');
+        let data: any = {};
+        if (fs.existsSync(filePath)) {
+            const fileContent = fs.readFileSync(filePath, 'utf-8');
+            data = JSON.parse(fileContent);
+            if (data[seedId]) {
+                return data[seedId];
+            }
+        }
+        if (data[seedId]) {
+            return data[seedId];
+        }
+    }
+    //deletepl
+    private async deletepl(seedId: number): Promise<void> {
+        const __dirname = path.dirname(fileURLToPath(import.meta.url));
+        const filePath = path.join(__dirname, '..', '..', 'botQQ_screenshots', 'mcData.json');
+        let data: any = {};
+        if (fs.existsSync(filePath)) {
+            const fileContent = fs.readFileSync(filePath, 'utf-8');
+            data = JSON.parse(fileContent);
+            if (data[seedId]) {
+                delete data[seedId];
+                fs.writeFileSync(filePath, JSON.stringify(data));
+            }
+        }
+    }
+
+
+
+}