From e7f5b74f85300ecc0025310138ce00985fe9bdb7 Mon Sep 17 00:00:00 2001 From: langua Date: Fri, 6 Sep 2024 17:42:15 +0200 Subject: [PATCH] (optimise) message delivery delay --- .../java/cat/nyaa/ukit/loginpush/LoginPushFunction.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/main/java/cat/nyaa/ukit/loginpush/LoginPushFunction.java b/src/main/java/cat/nyaa/ukit/loginpush/LoginPushFunction.java index bfa735b..ba622c5 100644 --- a/src/main/java/cat/nyaa/ukit/loginpush/LoginPushFunction.java +++ b/src/main/java/cat/nyaa/ukit/loginpush/LoginPushFunction.java @@ -78,14 +78,14 @@ public boolean invokeCommand(CommandSender commandSender, Command command, Strin @EventHandler public void onPlayerJoin(PlayerJoinEvent event) { Bukkit.getAsyncScheduler().runNow(pluginInstance,(task)->{ - countAndSendMessageIfHasMessage(event.getPlayer()); + countAndSendMessageIfHasMessage(event.getPlayer(), 20 * 3); }); } @EventHandler public void onAFKStatusChange(AfkStatusChangeEvent event) { if (!event.getValue()) { - countAndSendMessageIfHasMessage(event.getAffected().getBase()); + countAndSendMessageIfHasMessage(event.getAffected().getBase(), 10); } } @@ -108,13 +108,13 @@ public LoginPushRecorder getLoginPushRecorder() { return loginPushRecorder; } - private void countAndSendMessageIfHasMessage(Player player) { + private void countAndSendMessageIfHasMessage(Player player, long delayInTick) { try { int unreadPush = loginPushRecorder.countUnreadPush(player.getUniqueId()); if (unreadPush > 0) { Bukkit.getGlobalRegionScheduler().runDelayed(pluginInstance, (ignored) -> player.sendMessage(pluginInstance.language.loginPushLang.login_push_notice.produce( Pair.of("number", unreadPush) - )), 20 * 3); + )), delayInTick); } } catch (SQLException e) { pluginInstance.getLogger().warning(e.getMessage());