(optimise) message delivery delay

NyaaCat · Sep 6, 2024 · e7f5b74 · e7f5b74
1 parent 087a59f
commit e7f5b74
Showing 1 changed file with 4 additions and 4 deletions.
diff --git 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());