New update 2.1.0 with Title perform when point change

PlayerNguyen · PlayerNguyen · commit aa936fccdb4f · 2020-11-09T18:15:02.000+07:00
diff --git a/src/main/java/me/playernguyen/opteco/OptEco.java b/src/main/java/me/playernguyen/opteco/OptEco.java
@@ -19,6 +19,7 @@
 import me.playernguyen.opteco.logger.OptEcoDebugger;
 import me.playernguyen.opteco.manager.ManagerSet;
 import me.playernguyen.opteco.placeholderapi.OptEcoExpansion;
+import me.playernguyen.opteco.schedule.ScheduleManager;
 import me.playernguyen.opteco.transaction.TransactionManager;
 import me.playernguyen.opteco.updater.OptEcoUpdater;
 import me.playernguyen.opteco.utils.MessageFormat;
@@ -28,6 +29,7 @@
 import org.bukkit.plugin.Plugin;
 import org.bukkit.plugin.java.JavaPlugin;
 
+import java.sql.SQLException;
 import java.util.ArrayList;
 import java.util.logging.Logger;
 
@@ -56,13 +58,15 @@ public class OptEco extends JavaPlugin {
     private MessageFormat messageFormat;
     private TransactionManager transactionManager;
     private Metrics metrics;
+    private ScheduleManager scheduleManager;
 
     @Override
     public void onEnable() {
         this.setupInstance();
         this.setupLoader();
         this.setupManager();
         this.setupUpdater();
+        this.setupSchedule();
         this.setupStorage();
         this.setupAccount();
         this.hookPlaceHolderAPI();
@@ -72,6 +76,10 @@ public void onEnable() {
         this.waterMarkPrint();
     }
 
+    private void setupSchedule() {
+        this.scheduleManager = new ScheduleManager(this);
+    }
+
     private void announcePlayerPoints() {
         // Find BossShopPro
         Plugin plugin = Bukkit.getPluginManager().getPlugin("PlayerPoints");
@@ -332,4 +340,8 @@ public OptEcoCacheAccountManager getAccountManager() {
         return accountManager;
     }
 
+    public ScheduleManager getScheduleManager() {
+        return scheduleManager;
+    }
+
 }
diff --git a/src/main/java/me/playernguyen/opteco/OptEcoConfiguration.java b/src/main/java/me/playernguyen/opteco/OptEcoConfiguration.java
@@ -12,6 +12,8 @@ public enum OptEcoConfiguration {
     MINIMUM_TRANSACT_VALUE("Settings.Preferences.MinimumCanTransact", 0.1),
     STORAGE_TYPE("Settings.Storage.Type", StorageType.SQLITE.toString().toLowerCase()),
 
+    USE_DOUBLE("Settings.Preferences.UseDouble", false),
+
     MYSQL_HOST("Settings.SQL.MySQL.Host", "localhost"),
     MYSQL_DATABASE("Settings.SQL.MySQL.Database", "dbname"),
     MYSQL_PORT("Settings.SQL.MySQL.Port", "3306"),
@@ -31,7 +33,11 @@ public enum OptEcoConfiguration {
     REFRESH_TIME("Settings.Preferences.Cache.RefreshTime", 5),
 
     DEBUG("Settings.Debug", false),
-    LANGUAGE_FILE("Settings.Preferences.Language", "language.yml");
+    LANGUAGE_FILE("Settings.Preferences.Language", "language.yml"),
+
+    TITLE_STAY("Settings.Title.Stay", 20),
+    TITLE_FADE_OUT("Settings.Title.FadeOut", 100),
+    ;
 
     private final String path;
     private final Object wh;
diff --git a/src/main/java/me/playernguyen/opteco/OptEcoImplementation.java b/src/main/java/me/playernguyen/opteco/OptEcoImplementation.java
@@ -6,6 +6,7 @@
 import me.playernguyen.opteco.configuration.OptEcoLanguageLoader;
 import me.playernguyen.opteco.configuration.StorageType;
 import me.playernguyen.opteco.logger.Debugger;
+import me.playernguyen.opteco.schedule.ScheduleManager;
 import me.playernguyen.opteco.transaction.TransactionManager;
 
 import java.util.logging.Logger;
@@ -93,5 +94,12 @@ protected Logger getLogger() {
         return getPlugin().getLogger();
     }
 
+    /**
+     * @return Schedule manager
+     */
+    protected ScheduleManager getScheduleManager() {
+        return this.getPlugin().getScheduleManager();
+    }
+
 
 }
diff --git a/src/main/java/me/playernguyen/opteco/OptEcoLanguage.java b/src/main/java/me/playernguyen/opteco/OptEcoLanguage.java
@@ -58,7 +58,10 @@ public enum OptEcoLanguage {
     GRAY_BAR("RED_BAR", "&7---------------------------"),
     COMMAND_TOP_FORMAT("COMMAND.TOP.FORMAT", "&7%id%. &6%name%  ~  &c%balance%"),
 
-    UNACCEPTED_VALUE_PAYMENT("COMMAND.UNACCEPTED_VALUE", "&cThis value is unaccepted in transaction")
+    UNACCEPTED_VALUE_PAYMENT("COMMAND.UNACCEPTED_VALUE", "&cThis value is unaccepted in transaction"),
+    MUST_BE_INTEGER("MUST_BE_INTEGER", "&cThe value must be an integer!"),
+
+
     ;
 
     private final String path;
diff --git a/src/main/java/me/playernguyen/opteco/account/OptEcoCacheAccount.java b/src/main/java/me/playernguyen/opteco/account/OptEcoCacheAccount.java
@@ -32,10 +32,6 @@ public void setLastUpdate(long lastUpdate) {
     }
 
     public static OptEcoCacheAccount loadFromAccount(Account account) {
-
-//        if (account != null) return new OptEcoCacheAccount(account.getBalance(), System.currentTimeMillis());
-//
-//    	else return new OptEcoCacheAccount(0, System.currentTimeMillis());
     	return (account != null)
                 ? new OptEcoCacheAccount(account.getBalance(), System.currentTimeMillis())
                 : new OptEcoCacheAccount(0, System.currentTimeMillis());
diff --git a/src/main/java/me/playernguyen/opteco/account/SQLAccountDatabase.java b/src/main/java/me/playernguyen/opteco/account/SQLAccountDatabase.java
@@ -1,6 +1,7 @@
 package me.playernguyen.opteco.account;
 
 import me.playernguyen.opteco.OptEcoImplementation;
+import me.playernguyen.opteco.event.OptEcoPointChangedEvent;
 import me.playernguyen.opteco.sql.SQLEstablish;
 import org.bukkit.Bukkit;
 import org.jetbrains.annotations.NotNull;
@@ -136,8 +137,8 @@ public boolean hasAccount(UUID uuid) {
     }
 
     @Override
-    public boolean setBalance(UUID uuid, double amount) {
-        return this.save(new Account(uuid, amount));
+    public boolean setBalance(UUID uuid, double newBalance) {
+        return this.save(new Account(uuid, newBalance));
     }
 
     @Override
@@ -147,11 +148,27 @@ public double getBalance(UUID uuid) {
 
     @Override
     public boolean takeBalance(UUID uuid, double amount) {
+        // Take balance
+        // Call event
+        Bukkit.getPluginManager().callEvent(new OptEcoPointChangedEvent(
+                uuid,
+                this.getBalance(uuid),
+                this.getBalance(uuid) - amount,
+                OptEcoPointChangedEvent.ModifyType.DECREASE
+        ));
         return this.setBalance(uuid, this.getBalance(uuid) - amount);
     }
 
     @Override
     public boolean addBalance(UUID uuid, double amount) {
+        // Add new balance
+        // Call event
+        Bukkit.getPluginManager().callEvent(new OptEcoPointChangedEvent(
+                uuid,
+                this.getBalance(uuid),
+                this.getBalance(uuid) + amount,
+                OptEcoPointChangedEvent.ModifyType.INCREASE
+        ));
         return this.setBalance(uuid, this.getBalance(uuid) + amount);
     }
 
diff --git a/src/main/java/me/playernguyen/opteco/account/mysql/MySQLAccountDatabase.java b/src/main/java/me/playernguyen/opteco/account/mysql/MySQLAccountDatabase.java
@@ -5,6 +5,7 @@
 import me.playernguyen.opteco.account.SQLAccountDatabase;
 import me.playernguyen.opteco.sql.MySQLEstablish;
 
+import java.sql.SQLException;
 import java.util.ArrayList;
 import java.util.Arrays;
 
diff --git a/src/main/java/me/playernguyen/opteco/command/SubCommandAdd.java b/src/main/java/me/playernguyen/opteco/command/SubCommandAdd.java
@@ -3,6 +3,7 @@
 import me.playernguyen.opteco.OptEco;
 import me.playernguyen.opteco.OptEcoConfiguration;
 import me.playernguyen.opteco.OptEcoLanguage;
+import me.playernguyen.opteco.event.OptEcoPointChangedEvent;
 import me.playernguyen.opteco.permission.OptEcoPermission;
 import me.playernguyen.opteco.utils.MathUtils;
 import org.bukkit.Bukkit;
@@ -74,7 +75,8 @@ private boolean execute(CommandSender sender, ArrayList<String> args) {
                             .replace("%who%", args.get(0))
             );
             // Refresh the cache account
-            this.getAccountManager().refresh(target.getUniqueId());
+            if (target.isOnline())
+                this.getAccountManager().refresh(target.getUniqueId());
         } else {
             sender.sendMessage(
                     getMessageFormat().format(getPlugin().getLanguageLoader().getLanguage(OptEcoLanguage.COMMAND_FAILED_ADD))
diff --git a/src/main/java/me/playernguyen/opteco/command/SubCommandMe.java b/src/main/java/me/playernguyen/opteco/command/SubCommandMe.java
@@ -35,9 +35,9 @@ public boolean onPlayerCommand(Player player, ArrayList<String> args) {
                                 .replace("%value%", getMessageFormat()
                                         .numberFormat(optEcoCacheAccount.getBalance())
                                 ).replace("%currency%", getPlugin()
-                                        .getConfigurationLoader()
-                                        .getString(OptEcoConfiguration.CURRENCY_SYMBOL)
-                                )
+                                .getConfigurationLoader()
+                                .getString(OptEcoConfiguration.CURRENCY_SYMBOL)
+                        )
                 )
         );
         return true;
diff --git a/src/main/java/me/playernguyen/opteco/command/SubCommandPay.java b/src/main/java/me/playernguyen/opteco/command/SubCommandPay.java
@@ -83,14 +83,32 @@ public boolean onPlayerCommand(Player player, ArrayList<String> args) {
             );
             return true;
         }
-        // If lower than the minimum transact
-        if ((dummyValue % 1) < getConfigurationLoader().getDouble(OptEcoConfiguration.MINIMUM_TRANSACT_VALUE)) {
+//        // If lower than the minimum transact
+//        System.out.println(dummyValue % 1);
+//        System.out.println(getConfigurationLoader().getDouble(OptEcoConfiguration.MINIMUM_TRANSACT_VALUE));
+//        System.out.println(
+//                dummyValue % 1 != 0 &&
+//                (dummyValue % 1) < getConfigurationLoader().getDouble(OptEcoConfiguration.MINIMUM_TRANSACT_VALUE));
+//
+//        if ((dummyValue % 1) >= getConfigurationLoader().getDouble(OptEcoConfiguration.MINIMUM_TRANSACT_VALUE)) {
+//            player.sendMessage(
+//                    getMessageFormat()
+//                        .format(getLanguageLoader().getLanguage(OptEcoLanguage.UNACCEPTED_VALUE_PAYMENT))
+//            );
+//            return true;
+//        }
+        // Whether player is using double in not double mode
+        if (!getConfigurationLoader().getBool(OptEcoConfiguration.USE_DOUBLE)
+                && (dummyValue % 1) != 0
+        ) {
             player.sendMessage(
-                    getMessageFormat()
-                        .format(getLanguageLoader().getLanguage(OptEcoLanguage.UNACCEPTED_VALUE_PAYMENT))
+                    getMessageFormat().format(
+                            getLanguageLoader().getLanguage(OptEcoLanguage.MUST_BE_INTEGER)
+                    )
             );
             return true;
         }
+
         // If sender don't have enough points
         OptEcoCacheAccount optEcoCacheAccount = getAccountManager().get(player.getUniqueId());
         double balance = optEcoCacheAccount.getBalance();
diff --git a/src/main/java/me/playernguyen/opteco/command/SubCommandPayConfirm.java b/src/main/java/me/playernguyen/opteco/command/SubCommandPayConfirm.java
@@ -5,6 +5,8 @@
 import me.playernguyen.opteco.OptEcoLanguage;
 import me.playernguyen.opteco.permission.OptEcoPermission;
 import me.playernguyen.opteco.transaction.Transaction;
+import net.md_5.bungee.api.ChatMessageType;
+import net.md_5.bungee.api.chat.ComponentBuilder;
 import org.bukkit.Bukkit;
 import org.bukkit.command.CommandSender;
 import org.bukkit.command.RemoteConsoleCommandSender;
diff --git a/src/main/java/me/playernguyen/opteco/configuration/OptEcoConfigurationLoader.java b/src/main/java/me/playernguyen/opteco/configuration/OptEcoConfigurationLoader.java
@@ -7,7 +7,7 @@ public class OptEcoConfigurationLoader extends OptEcoLoaderAbstract {
     private static final String CONFIG_FILE = "config.yml";
     private static final String SYSTEM_LINE_SEPARATOR = System.lineSeparator();
     private static final String HEADER_HELPER =
-            "[-] OptEco auto-generated plugin.yml" + SYSTEM_LINE_SEPARATOR +
+            "[~] OptEco auto-generated plugin.yml" + SYSTEM_LINE_SEPARATOR +
                     "[-]  More help at https://github.com/PlayerNguyen/OptEco/wiki" + SYSTEM_LINE_SEPARATOR +
                     "[-]  Any issue at https://github.com/PlayerNguyen/OptEco/issues" + SYSTEM_LINE_SEPARATOR;
 
diff --git a/src/main/java/me/playernguyen/opteco/configuration/OptEcoLoaderAbstract.java b/src/main/java/me/playernguyen/opteco/configuration/OptEcoLoaderAbstract.java
@@ -16,24 +16,6 @@ public abstract class OptEcoLoaderAbstract extends OptEcoImplementation {
 
     private String header;
 
-//    public LoaderAbstract(File file) {
-//        this.file = file;
-//        this.configuration = YamlConfiguration.loadConfiguration(file);
-//        this.header = "";
-//    }
-//
-//    public LoaderAbstract(String filename) {
-//        this.file = new File(getPlugin().getDataFolder(), filename + ".yml");
-//        this.configuration = YamlConfiguration.loadConfiguration(file);
-//        this.header = "";
-//    }
-//
-//    public LoaderAbstract(String filename, String header) {
-//        this.file = new File(getPlugin().getDataFolder(), filename + ".yml");
-//        this.configuration = YamlConfiguration.loadConfiguration(file);
-//        this.header = header;
-//    }
-
     public OptEcoLoaderAbstract(String name, String header, String parent, boolean fromResource) {
         // Parent handle
         // /OptEco folder
@@ -119,4 +101,8 @@ public int getInt(OptEcoConfiguration configuration) {
         return getConfiguration().getInt(configuration.getPath());
     }
 
+    public long getLong(OptEcoConfiguration configuration) {
+        return getConfiguration().getLong(configuration.getPath());
+    }
+
 }
diff --git a/src/main/java/me/playernguyen/opteco/event/OptEcoEvent.java b/src/main/java/me/playernguyen/opteco/event/OptEcoEvent.java
@@ -0,0 +1,24 @@
+package me.playernguyen.opteco.event;
+
+import org.bukkit.event.Event;
+import org.bukkit.event.HandlerList;
+import org.jetbrains.annotations.NotNull;
+
+/**
+ * OptEco Event implementation
+ */
+public abstract class OptEcoEvent extends Event {
+
+    // Static Fields
+    private static final HandlerList handlerList = new HandlerList();
+
+    @Override
+    public @NotNull HandlerList getHandlers() {
+        return handlerList;
+    }
+
+    public static HandlerList getHandlerList() {
+        return handlerList;
+    }
+
+}
diff --git a/src/main/java/me/playernguyen/opteco/event/OptEcoPointChangedEvent.java b/src/main/java/me/playernguyen/opteco/event/OptEcoPointChangedEvent.java
@@ -0,0 +1,46 @@
+package me.playernguyen.opteco.event;
+
+import org.bukkit.event.HandlerList;
+import org.jetbrains.annotations.NotNull;
+
+import java.util.UUID;
+
+public class OptEcoPointChangedEvent extends OptEcoEvent {
+
+    private final UUID who;
+    private final double oldPoint;
+    private final double newPoint;
+    private final ModifyType type;
+
+    public OptEcoPointChangedEvent(UUID who, double oldPoint, double newPoint, ModifyType type) {
+        this.who = who;
+        this.oldPoint = oldPoint;
+        this.newPoint = newPoint;
+        this.type = type;
+    }
+
+    @Override
+    public @NotNull HandlerList getHandlers() {
+        return super.getHandlers();
+    }
+
+    public double getNewPoint() {
+        return newPoint;
+    }
+
+    public double getOldPoint() {
+        return oldPoint;
+    }
+
+    public UUID getWho() {
+        return who;
+    }
+
+    public ModifyType getType() {
+        return type;
+    }
+
+    public enum ModifyType {
+        INCREASE, DECREASE
+    }
+}
diff --git a/src/main/java/me/playernguyen/opteco/listener/OptEcoPlayerListener.java b/src/main/java/me/playernguyen/opteco/listener/OptEcoPlayerListener.java
@@ -1,5 +1,7 @@
 package me.playernguyen.opteco.listener;
 
+import me.playernguyen.opteco.event.OptEcoPointChangedEvent;
+import me.playernguyen.opteco.schedule.PointChangedPerformance;
 import org.bukkit.entity.Player;
 import org.bukkit.event.EventHandler;
 import org.bukkit.event.player.PlayerJoinEvent;
@@ -33,4 +35,11 @@ public void onPlayerQuitEvent(PlayerQuitEvent e) {
         getDebugger().warn("Remove the player data into manager...");
     }
 
+
+    @EventHandler
+    public void onChange(OptEcoPointChangedEvent e) {
+        // Call new async
+        this.getScheduleManager().callAsyncTimer(new PointChangedPerformance(e), 0, 0);
+    }
+
 }
diff --git a/src/main/java/me/playernguyen/opteco/logger/Debugger.java b/src/main/java/me/playernguyen/opteco/logger/Debugger.java
@@ -10,6 +10,8 @@ public interface Debugger {
 
     void error(String var1);
 
+    void notice(String var1);
+
     void printException(Exception exception);
 
 }
diff --git a/src/main/java/me/playernguyen/opteco/logger/OptEcoDebugger.java b/src/main/java/me/playernguyen/opteco/logger/OptEcoDebugger.java
diff --git a/src/main/java/me/playernguyen/opteco/schedule/CloseConnectionRunnable.java b/src/main/java/me/playernguyen/opteco/schedule/CloseConnectionRunnable.java
diff --git a/src/main/java/me/playernguyen/opteco/schedule/PointChangedPerformance.java b/src/main/java/me/playernguyen/opteco/schedule/PointChangedPerformance.java
diff --git a/src/main/java/me/playernguyen/opteco/schedule/ScheduleManager.java b/src/main/java/me/playernguyen/opteco/schedule/ScheduleManager.java
diff --git a/src/main/java/me/playernguyen/opteco/sql/MySQLEstablish.java b/src/main/java/me/playernguyen/opteco/sql/MySQLEstablish.java
diff --git a/src/main/java/me/playernguyen/opteco/transaction/TransactionManager.java b/src/main/java/me/playernguyen/opteco/transaction/TransactionManager.java
diff --git a/src/main/java/me/playernguyen/opteco/transaction/mysql/TransactionMySQLStorage.java b/src/main/java/me/playernguyen/opteco/transaction/mysql/TransactionMySQLStorage.java
