Add platform listener impl (pre)

alazeprt · alazeprt · commit b7977134474d · 2024-09-21T16:58:23.000+08:00
diff --git a/common/src/main/kotlin/me/regadpole/plumbot/PlatformImpl.kt b/common/src/main/kotlin/me/regadpole/plumbot/PlatformImpl.kt
@@ -0,0 +1,5 @@
+package me.regadpole.plumbot
+
+abstract class PlatformImpl {
+    abstract fun getPlayerList() : List<String>
+}
diff --git a/common/src/main/kotlin/me/regadpole/plumbot/PlumBot.kt b/common/src/main/kotlin/me/regadpole/plumbot/PlumBot.kt
@@ -26,6 +26,8 @@ object PlumBot : Plugin() {
 
     private lateinit var database: Database
 
+    var playerList = mutableListOf<String>()
+
     override fun onLoad() {
         ConfigResolver.loadConfig()
         config = ConfigResolver.getConfigLoader()
@@ -63,13 +65,19 @@ object PlumBot : Plugin() {
             }
         }
         info("成功启用机器人服务!")
+        config.getConfig().groups.enableGroups.forEach {
+            bot.sendGroupMsg(it, lang.getLangConf().onEnable ?: return@forEach)
+        }
     }
 
     override fun onDisable() {
         bot.shutdown()
         info("成功关闭机器人服务")
         database.close()
         info("成功关闭数据库链接!")
+        config.getConfig().groups.enableGroups.forEach {
+            bot.sendGroupMsg(it, lang.getLangConf().onDisable ?: return@forEach)
+        }
     }
 
     fun reloadConfig() {
diff --git a/common/src/main/kotlin/me/regadpole/plumbot/config/LangConfig.kt b/common/src/main/kotlin/me/regadpole/plumbot/config/LangConfig.kt
@@ -28,6 +28,10 @@ class LangConfig(langConfig: Configuration) {
                 val addBind = config.getString("whitelist.user.addBind")
                 val removeBind = config.getString("whitelist.user.removeBind")
                 val queryBind = config.getString("whitelist.user.queryBind")
+                val fullBind = config.getString("whitelist.user.fullBind")
+                val existsBind = config.getString("whitelist.user.existsBind")
+                val notExistsBind = config.getString("whitelist.user.nonExistsBind")
+                val notBelongToYou = config.getString("whitelist.user.notBelongToYou")
             }
             class Admin(config: Configuration) {
                 val addBind = config.getString("whitelist.admin.addBind")
diff --git a/common/src/main/kotlin/me/regadpole/plumbot/internal/WhitelistHelper.kt b/common/src/main/kotlin/me/regadpole/plumbot/internal/WhitelistHelper.kt
@@ -3,7 +3,7 @@ package me.regadpole.plumbot.internal
 import me.regadpole.plumbot.PlumBot
 
 
-class WhitelistHelper {
+object WhitelistHelper {
     fun checkCount(user: String): Boolean {
         val idList = PlumBot.getDatabase().getBind(user).values
         val maxCount: Int = PlumBot.getConfig().getConfig().groups.forwarding.whitelist.maxCount
@@ -15,6 +15,10 @@ class WhitelistHelper {
         return PlumBot.getDatabase().getBindByName(name).isNullOrEmpty()
     }
 
+    fun checkIDBelong(user: String, name: String): Boolean {
+        return PlumBot.getDatabase().getBindByName(name) == user
+    }
+
     fun addAndGet(user: String, name: String): MutableMap<Int, String> {
         PlumBot.getDatabase().addBind(user, name)
         return PlumBot.getDatabase().getBind(user)
diff --git a/common/src/main/kotlin/me/regadpole/plumbot/listener/GPlatformListener.kt b/common/src/main/kotlin/me/regadpole/plumbot/listener/GPlatformListener.kt
@@ -0,0 +1,113 @@
+package me.regadpole.plumbot.listener
+
+import me.regadpole.plumbot.PlumBot
+import me.regadpole.plumbot.internal.WhitelistHelper
+import taboolib.common5.util.replace
+
+object GPlatformListener {
+    fun onGroupMessage(message: String, groupId: String, senderId: String, senderName: String) {
+        if (!PlumBot.getConfig().getConfig().groups.enableGroups.contains(groupId)) return
+        if (message.startsWith(PlumBot.getConfig().getConfig().groups.prefix ?: "/")) {
+            if (PlumBot.getConfig().getConfig().groups.forwarding.sdc) {
+                PlumBot.getConfig().getCommands().adminCommand.forEach {
+                    if (it.key == message.substring(1) && PlumBot.getConfig().getConfig().groups.botAdmins.
+                        contains(senderId)) {
+                        // TODO: 执行配置文件内游戏命令并返回
+                    }
+                }
+                PlumBot.getConfig().getCommands().userCommand.forEach {
+                    if (it.key == message.substring(1)) {
+                        // TODO: 执行配置文件内游戏命令并返回
+                    }
+                }
+            }
+            if (message.substring(1) == "help" || message.substring(1) == "帮助") {
+
+            }
+            if (PlumBot.getConfig().getConfig().groups.forwarding.tps && message.substring(1) == "tps") {
+                // TODO: 获取服务器 TPS 并返回
+            }
+            if (PlumBot.getConfig().getConfig().groups.forwarding.online && message.substring(1) == "在线人数") {
+                // TODO: 看看这样写有没有问题((
+                PlumBot.getBot().sendGroupMsg(groupId, "在线玩家: ${PlumBot.playerList.joinToString(", ")}")
+            }
+            if (PlumBot.getConfig().getConfig().groups.botAdmins.contains(groupId) && message.substring(1) == "cmd") {
+                // TODO: 执行message内游戏命令并返回
+            }
+            if (PlumBot.getConfig().getConfig().groups.forwarding.whitelist.enable && message.substring(1) == "申请白名单" &&
+                message.split(" ").size == 2) {
+                val player = message.substring(6)
+                if (!WhitelistHelper.checkCount(senderId)) {
+                    PlumBot.getBot().sendGroupMsg(
+                        groupId, PlumBot.getLangConfig().getLangConf().whitelist.user.fullBind!!
+                        .replace("%player_name%", player)
+                        .replace("%whitelist_name%", PlumBot.getDatabase().getBind(senderId).values.joinToString(", "))
+                        .replace("%platform_id%", senderId)
+                        .replace("%max_limit%", PlumBot.getConfig().getConfig().groups.forwarding.whitelist.maxCount.toString()))
+                }
+                if (!WhitelistHelper.checkIDNotExist(player)) {
+                    PlumBot.getBot().sendGroupMsg(
+                        groupId, PlumBot.getLangConfig().getLangConf().whitelist.user.existsBind!!
+                        .replace("%player_name%", player))
+                }
+                WhitelistHelper.addAndGet(senderId, player)
+                PlumBot.getBot().sendGroupMsg(
+                    groupId, PlumBot.getLangConfig().getLangConf().whitelist.user.addBind!!
+                    .replace("%player_name%", player)
+                    .replace("%whitelist_name%", PlumBot.getDatabase().getBind(senderId).values.joinToString(", "))
+                    .replace("%platform_id%", senderId))
+            }
+            if (PlumBot.getConfig().getConfig().groups.forwarding.whitelist.enable && message.substring(1) == "移除白名单" &&
+                message.split(" ").size == 2) {
+                val player = message.substring(6)
+                if (WhitelistHelper.checkIDNotExist(player)) {
+                    PlumBot.getBot().sendGroupMsg(
+                        groupId, PlumBot.getLangConfig().getLangConf().whitelist.user.notExistsBind!!
+                        .replace("%player_name%", player))
+                }
+                if (!WhitelistHelper.checkIDBelong(senderId, player)) {
+                    PlumBot.getBot().sendGroupMsg(
+                        groupId, PlumBot.getLangConfig().getLangConf().whitelist.user.notBelongToYou!!
+                        .replace("%player_name%", player))
+                }
+                PlumBot.getDatabase().removeBindByName(player)
+                PlumBot.getBot().sendGroupMsg(
+                    groupId, PlumBot.getLangConfig().getLangConf().whitelist.user.addBind!!
+                    .replace("%player_name%", player)
+                    .replace("%whitelist_name%", PlumBot.getDatabase().getBind(senderId).values.joinToString(", "))
+                    .replace("%platform_id%", senderId))
+            }
+            if (PlumBot.getConfig().getConfig().groups.forwarding.whitelist.enable && message.substring(1) == "查询白名单") {
+                PlumBot.getBot().sendGroupMsg(
+                    groupId, PlumBot.getLangConfig().getLangConf().whitelist.user.queryBind!!
+                        .replace("%whitelist_name%", PlumBot.getDatabase().getBind(senderId).values.joinToString(", ")))
+            }
+        }
+        if (PlumBot.getConfig().getConfig().groups.forwarding.sdr) {
+            PlumBot.getConfig().getReturns().adminReturn.forEach {
+                if (it.key == message && PlumBot.getConfig().getConfig().groups.botAdmins.contains(senderId)) {
+                    PlumBot.getBot().sendGroupMsg(groupId, it.value)
+                }
+            }
+            PlumBot.getConfig().getReturns().userReturn.forEach {
+                if (it.key == message) {
+                    PlumBot.getBot().sendGroupMsg(groupId, it.value)
+                }
+            }
+        }
+        if (PlumBot.getConfig().getConfig().groups.forwarding.message.mode == 0) {
+            PlumBot.getBot().sendGroupMsg(
+                groupId, PlumBot.getLangConfig().getLangConf().forwarding.toServer!!
+                .replace("%group_name%", PlumBot.getBot().getGroupName(groupId)?: groupId)
+                .replace("%message%", message)
+                .replace("%platform_name%", senderName))
+        } else if (PlumBot.getConfig().getConfig().groups.forwarding.message.mode == 1 &&
+            message.startsWith(PlumBot.getConfig().getConfig().groups.forwarding.message.prefix!!)) {
+            PlumBot.getBot().sendGroupMsg(
+                groupId, PlumBot.getLangConfig().getLangConf().forwarding.toServer!!
+                .replace("%group_name%", PlumBot.getBot().getGroupName(groupId)?: groupId)
+                .replace("%message%", message.replace(PlumBot.getConfig().getConfig().groups.forwarding.message.prefix!!, ""))
+                .replace("%platform_name%", senderName))
+        }
+    }
+}
diff --git a/common/src/main/kotlin/me/regadpole/plumbot/listener/game/GameListener.kt b/common/src/main/kotlin/me/regadpole/plumbot/listener/game/GameListener.kt
@@ -5,6 +5,7 @@ import me.regadpole.plumbot.event.GDeathEvent
 import me.regadpole.plumbot.event.GJoinEvent
 import me.regadpole.plumbot.event.GPlayerChatEvent
 import me.regadpole.plumbot.event.GQuitEvent
+import taboolib.common5.util.replace
 
 object GameListener {
     fun onChat(event: GPlayerChatEvent) {
@@ -16,6 +17,7 @@ object GameListener {
             var message: String = PlumBot.getLangConfig().getLangConf().forwarding.toPlatform?: return
             message = message.replace("%server_name%", event.player.server)
                 .replace("%world_name%", event.player.position.world)
+                .replace("%player_name%", event.player.name)
                 .replace("%message%", event.message)
             PlumBot.getConfig().getConfig().groups.enableGroups.forEach {
                 PlumBot.getBot().sendGroupMsg(it, message)
@@ -36,6 +38,10 @@ object GameListener {
     }
 
     fun onJoin(event: GJoinEvent) {
+        PlumBot.playerList.add(event.player.name)
+        if (!PlumBot.getConfig().getConfig().groups.forwarding.whitelist.enable) {
+            return
+        }
         if (PlumBot.getDatabase().getBindByName(event.player.name) == null) {
             var message: String = PlumBot.getLangConfig().getLangConf().whitelist.kickServer?: return
             message = message.replace("%enable_groups%", PlumBot.getConfig().getConfig().groups.enableGroups.joinToString("/"))
@@ -57,6 +63,7 @@ object GameListener {
     }
 
     fun onQuit(event: GQuitEvent) {
+        PlumBot.playerList.remove(event.player.name)
         if (PlumBot.getConfig().getConfig().groups.forwarding.joinAndLeave) {
             var message: String = PlumBot.getLangConfig().getLangConf().playerLeaveMsg?: return
             message = message.replace("%player_name%", event.player.name)
diff --git a/common/src/main/kotlin/me/regadpole/plumbot/listener/kook/KookListener.kt b/common/src/main/kotlin/me/regadpole/plumbot/listener/kook/KookListener.kt
@@ -1,5 +1,6 @@
 package me.regadpole.plumbot.listener.kook
 
+import me.regadpole.plumbot.listener.GPlatformListener
 import snw.jkook.event.EventHandler
 import snw.jkook.event.Listener
 import snw.jkook.event.channel.ChannelMessageEvent
@@ -8,17 +9,18 @@ import snw.jkook.event.user.UserLeaveGuildEvent
 
 class KookListener : Listener {
     @EventHandler
-    fun onChannelMessage(e: ChannelMessageEvent) {
-
+    fun onChannelMessage(event: ChannelMessageEvent) {
+        GPlatformListener.onGroupMessage(event.message.component.toString(),
+            event.channel.id, event.message.sender.id, event.message.sender.name)
     }
 
     @EventHandler
-    fun onPrivateMessage(e: PrivateMessageReceivedEvent) {
+    fun onPrivateMessage(event: PrivateMessageReceivedEvent) {
 
     }
 
     @EventHandler
-    fun onPrivateMessage(e: UserLeaveGuildEvent) {
+    fun onPrivateMessage(event: UserLeaveGuildEvent) {
 
     }
 }
diff --git a/common/src/main/kotlin/me/regadpole/plumbot/listener/qq/QQListener.kt b/common/src/main/kotlin/me/regadpole/plumbot/listener/qq/QQListener.kt
@@ -5,11 +5,13 @@ import cn.evole.onebot.client.interfaces.Listener
 import cn.evole.onebot.sdk.event.message.GroupMessageEvent
 import cn.evole.onebot.sdk.event.message.PrivateMessageEvent
 import cn.evole.onebot.sdk.event.notice.group.GroupDecreaseNoticeEvent
+import me.regadpole.plumbot.listener.GPlatformListener
 
 
 class QQListener: Listener {
     @SubscribeEvent
     fun onGroupMessage(event: GroupMessageEvent) {
+        GPlatformListener.onGroupMessage(event.message, event.groupId.toString(), event.sender.userId, event.sender.nickname)
     }
 
     @SubscribeEvent
diff --git a/common/src/main/resources/lang/zh_CN.yml b/common/src/main/resources/lang/zh_CN.yml
@@ -12,10 +12,10 @@ onDisable: "PlumBot已关闭"
 
 # 消息转发
 forwarding:
-  # 可选占位符：%server_name%, %world_name%, %message%
-  toPlatform: "[服务器]%message%"
-  # 可选占位符：%group_name%, %message%
-  toServer: "[%group_name%]%message%"
+  # 可选占位符：%server_name%, %player_name%, %world_name%, %message%
+  toPlatform: "[服务器] %player_name%: %message%"
+  # 可选占位符：%group_name%, %platform_name%, %message%
+  toServer: "[%group_name%] %qq_id%: %message%"
 
 # 可选占位符：%player_name%, %server_name%
 playerJoinMsg: "%player_name%进入服务器"
@@ -32,6 +32,12 @@ whitelist:
     removeBind: "成功删除白名单，您目前的白名单为%whitelist_name%"
     # 可选占位符：%whitelist_name%, %platform_id%
     queryBind: "您目前的白名单为%whitelist_name%"
+    # 可选占位符：%player_name%, %whitelist_name%, %platform_id%, %whitelist_limit%
+    fullBind: "你能申请的白名单数额已满: %whitelist_limit%"
+    # 可选占位符：%player_name%
+    existsBind: "%player_name% 已被他人绑定!"
+    notExistsBind: "%player_name% 暂未被人绑定过!"
+    notBelongToYou: "%player_name% 不是由你绑定的!"
   admin:
     # 可选占位符：%player_name%, %whitelist_name%, %target_platform_id%, %sender_platform_id%
     addBind: "成功申请白名单，%target_platform_id%目前的白名单为%whitelist_name%"
@@ -43,4 +49,15 @@ whitelist:
 commandSendFinish: "已发送指令到服务器"
 
 # 可选占位符：%player_name%, %world_name%, %pos%
-messageOnDie: "玩家%player_name%在%world_name%的%pos%死亡"
+messageOnDie: "玩家%player_name%在%world_name%的%pos%死亡"
+
+# 可选占位符: %prefix%
+help:
+  - "PlumBot 帮助"
+  - "%prefix%在线人数   - 查看在线人数"
+  - "%prefix%tps   - 查看服务器TPS"
+  - "%prefix%申请白名单 <游戏名>   - 申请白名单"
+  - "%prefix%移除白名单 <游戏名>   - 移除白名单"
+  - "%prefix%查询白名单   - 查询自己申请的所有白名单"
+  - "管理员命令"
+  - "%prefix%cmd <命令>   - 向服务器发送命令并获取返回值"

Original file line number	Diff line number	Diff line change
`@@ -26,6 +26,8 @@ object PlumBot : Plugin() {`
`26`	`26`
`27`	`27`	`private lateinit var database: Database`
`28`	`28`
	`29`	`+ var playerList = mutableListOf<String>()`
	`30`	`+`
`29`	`31`	`override fun onLoad() {`
`30`	`32`	`ConfigResolver.loadConfig()`
`31`	`33`	`config = ConfigResolver.getConfigLoader()`
`@@ -63,13 +65,19 @@ object PlumBot : Plugin() {`
`63`	`65`	`}`
`64`	`66`	`}`
`65`	`67`	`info("成功启用机器人服务!")`
	`68`	`+ config.getConfig().groups.enableGroups.forEach {`
	`69`	`+ bot.sendGroupMsg(it, lang.getLangConf().onEnable ?: return@forEach)`
	`70`	`+ }`
`66`	`71`	`}`
`67`	`72`
`68`	`73`	`override fun onDisable() {`
`69`	`74`	`bot.shutdown()`
`70`	`75`	`info("成功关闭机器人服务")`
`71`	`76`	`database.close()`
`72`	`77`	`info("成功关闭数据库链接!")`
	`78`	`+ config.getConfig().groups.enableGroups.forEach {`
	`79`	`+ bot.sendGroupMsg(it, lang.getLangConf().onDisable ?: return@forEach)`
	`80`	`+ }`
`73`	`81`	`}`
`74`	`82`
`75`	`83`	`fun reloadConfig() {`
Original file line number	Diff line number	Diff line change
`@@ -1,5 +1,6 @@`
`1`	`1`	`package me.regadpole.plumbot.listener.kook`
`2`	`2`
	`3`	`+import me.regadpole.plumbot.listener.GPlatformListener`
`3`	`4`	`import snw.jkook.event.EventHandler`
`4`	`5`	`import snw.jkook.event.Listener`
`5`	`6`	`import snw.jkook.event.channel.ChannelMessageEvent`
`@@ -8,17 +9,18 @@ import snw.jkook.event.user.UserLeaveGuildEvent`
`8`	`9`
`9`	`10`	`class KookListener : Listener {`
`10`	`11`	`@EventHandler`
`11`		`- fun onChannelMessage(e: ChannelMessageEvent) {`
`12`		`-`
	`12`	`+ fun onChannelMessage(event: ChannelMessageEvent) {`
	`13`	`+ GPlatformListener.onGroupMessage(event.message.component.toString(),`
	`14`	`+ event.channel.id, event.message.sender.id, event.message.sender.name)`
`13`	`15`	`}`
`14`	`16`
`15`	`17`	`@EventHandler`
`16`		`- fun onPrivateMessage(e: PrivateMessageReceivedEvent) {`
	`18`	`+ fun onPrivateMessage(event: PrivateMessageReceivedEvent) {`
`17`	`19`
`18`	`20`	`}`
`19`	`21`
`20`	`22`	`@EventHandler`
`21`		`- fun onPrivateMessage(e: UserLeaveGuildEvent) {`
	`23`	`+ fun onPrivateMessage(event: UserLeaveGuildEvent) {`
`22`	`24`
`23`	`25`	`}`
`24`	`26`	`}`