From 3c825743860b5b44ea3a6401c970a6fcfa2192ef Mon Sep 17 00:00:00 2001 From: Shaun Bennett Date: Sat, 7 Nov 2015 20:02:07 -0500 Subject: [PATCH 01/10] Testing pushing/ignore this --- .../src/mineplex/hub/modules/TrickOrTreatManager.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/Plugins/Mineplex.Hub/src/mineplex/hub/modules/TrickOrTreatManager.java b/Plugins/Mineplex.Hub/src/mineplex/hub/modules/TrickOrTreatManager.java index ddb276a26..8fe6ee972 100644 --- a/Plugins/Mineplex.Hub/src/mineplex/hub/modules/TrickOrTreatManager.java +++ b/Plugins/Mineplex.Hub/src/mineplex/hub/modules/TrickOrTreatManager.java @@ -85,7 +85,8 @@ public class TrickOrTreatManager extends MiniPlugin public TrickOrTreatManager(JavaPlugin plugin, HubManager manager, TaskManager taskManager, DonationManager donationManager, CoreClientManager coreClientManager) { super("Trick or Treat", plugin); - + + // Test commit _manager = manager; _taskManager = taskManager; _donationManager = donationManager; From fd3ccf7ce051f9c62f87b03a009de7ff2785d409 Mon Sep 17 00:00:00 2001 From: Jonathan Williams Date: Sun, 8 Nov 2015 17:25:54 -0600 Subject: [PATCH 02/10] Fix Bungee lobby balancer code. --- .../src/mineplex/bungee/lobbyBalancer/LobbyBalancer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/Plugins/Mineplex.Bungee.Mineplexer/src/mineplex/bungee/lobbyBalancer/LobbyBalancer.java b/Plugins/Mineplex.Bungee.Mineplexer/src/mineplex/bungee/lobbyBalancer/LobbyBalancer.java index 443dc104b..fadc89543 100644 --- a/Plugins/Mineplex.Bungee.Mineplexer/src/mineplex/bungee/lobbyBalancer/LobbyBalancer.java +++ b/Plugins/Mineplex.Bungee.Mineplexer/src/mineplex/bungee/lobbyBalancer/LobbyBalancer.java @@ -81,7 +81,7 @@ public class LobbyBalancer implements Listener, Runnable InetSocketAddress socketAddress = new InetSocketAddress(server.getPublicAddress(), server.getPort()); _plugin.getProxy().getServers().put(server.getName(), _plugin.getProxy().constructServerInfo(server.getName(), socketAddress, "LobbyBalancer", false)); - if (server.getName().toUpperCase().contains("LOBBY")) + if (server.getName().toUpperCase().startsWith("LOBBY")) { if (server.getMotd() == null || !server.getMotd().contains("Restarting")) { From e86623c8d0350b252b9184267f7d136bc041b215 Mon Sep 17 00:00:00 2001 From: Jonathan Williams Date: Sun, 8 Nov 2015 17:26:43 -0600 Subject: [PATCH 03/10] Disabled TrickOrTreatManager to test for Lobby lockups. --- Plugins/Mineplex.Hub/src/mineplex/hub/HubManager.java | 2 +- .../src/mineplex/hub/modules/TrickOrTreatManager.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/Plugins/Mineplex.Hub/src/mineplex/hub/HubManager.java b/Plugins/Mineplex.Hub/src/mineplex/hub/HubManager.java index 4f76875d2..9fba124e9 100644 --- a/Plugins/Mineplex.Hub/src/mineplex/hub/HubManager.java +++ b/Plugins/Mineplex.Hub/src/mineplex/hub/HubManager.java @@ -202,7 +202,7 @@ public class HubManager extends MiniClientPlugin new SoccerManager(this, _gadgetManager); new KothManager(this, _gadgetManager); - new TrickOrTreatManager(_plugin, this, taskManager, donationManager, clientManager); + //new TrickOrTreatManager(_plugin, this, taskManager, donationManager, clientManager); _petManager = petManager; _partyManager = partyManager; diff --git a/Plugins/Mineplex.Hub/src/mineplex/hub/modules/TrickOrTreatManager.java b/Plugins/Mineplex.Hub/src/mineplex/hub/modules/TrickOrTreatManager.java index ddb276a26..209e0c9fd 100644 --- a/Plugins/Mineplex.Hub/src/mineplex/hub/modules/TrickOrTreatManager.java +++ b/Plugins/Mineplex.Hub/src/mineplex/hub/modules/TrickOrTreatManager.java @@ -93,7 +93,7 @@ public class TrickOrTreatManager extends MiniPlugin _tricks.add(new Blindness(plugin)); _tricks.add(new Nausea(plugin)); - _tricks.add(new RandomTeleport(plugin)); + //_tricks.add(new RandomTeleport(plugin)); _tricks.add(new ShockingStrikes(plugin)); } From ff936784d38372dffff1c7551db929207f639549 Mon Sep 17 00:00:00 2001 From: Jonathan Williams Date: Sun, 8 Nov 2015 17:27:00 -0600 Subject: [PATCH 04/10] Remove debug code. --- Plugins/Mineplex.Hub/src/mineplex/hub/server/ServerManager.java | 2 -- 1 file changed, 2 deletions(-) diff --git a/Plugins/Mineplex.Hub/src/mineplex/hub/server/ServerManager.java b/Plugins/Mineplex.Hub/src/mineplex/hub/server/ServerManager.java index 5963ea411..f65dfb6d3 100644 --- a/Plugins/Mineplex.Hub/src/mineplex/hub/server/ServerManager.java +++ b/Plugins/Mineplex.Hub/src/mineplex/hub/server/ServerManager.java @@ -588,12 +588,10 @@ public class ServerManager extends MiniPlugin if (largestServer.getAvailableSlots() >= MIN_SLOTS_REQUIRED || largestServer.MaxPlayers > 40) { - System.out.println("Largest."); return largestServer; } else { - System.out.println("Random."); return servers.get(random.nextInt(count)); } } From 4915ebc5adcb1dc0fddacce7fcd1cee4fa2464f2 Mon Sep 17 00:00:00 2001 From: Jonathan Williams Date: Mon, 9 Nov 2015 00:04:38 -0600 Subject: [PATCH 05/10] Added Purchase logging manager for Enjin. Added extra callback method for SaveRank. --- .../core/account/CoreClientManager.java | 19 + .../src/mineplex/enjinTranslator/Enjin.java | 374 +++++------------- .../purchase/PurchaseManager.java | 74 ++++ .../purchase/data/Package.java | 23 ++ .../purchase/data/PurchaseRepository.java | 62 +++ 5 files changed, 281 insertions(+), 271 deletions(-) create mode 100644 Plugins/Mineplex.EnjinTranslator/src/mineplex/enjinTranslator/purchase/PurchaseManager.java create mode 100644 Plugins/Mineplex.EnjinTranslator/src/mineplex/enjinTranslator/purchase/data/Package.java create mode 100644 Plugins/Mineplex.EnjinTranslator/src/mineplex/enjinTranslator/purchase/data/PurchaseRepository.java diff --git a/Plugins/Mineplex.Core/src/mineplex/core/account/CoreClientManager.java b/Plugins/Mineplex.Core/src/mineplex/core/account/CoreClientManager.java index 31c2330ec..aa92e8f25 100644 --- a/Plugins/Mineplex.Core/src/mineplex/core/account/CoreClientManager.java +++ b/Plugins/Mineplex.Core/src/mineplex/core/account/CoreClientManager.java @@ -426,6 +426,25 @@ public class CoreClientManager extends MiniPlugin }, name, uuid, rank, perm); } + public void SaveRank(final Callback callback, final String name, final UUID uuid, Rank rank, boolean perm) + { + _repository.saveRank(new Callback() + { + public void run(Rank newRank) + { + if (_plugin.getServer().getPlayer(name) != null) + { + CoreClient client = Get(name); + + client.SetRank(newRank, false); + } + + if (callback != null) + callback.run(newRank); + } + }, name, uuid, rank, perm); + } + public void checkPlayerNameExact(final Callback callback, final String playerName) { _repository.matchPlayerName(new Callback>() diff --git a/Plugins/Mineplex.EnjinTranslator/src/mineplex/enjinTranslator/Enjin.java b/Plugins/Mineplex.EnjinTranslator/src/mineplex/enjinTranslator/Enjin.java index d256a560a..429d0cf3f 100644 --- a/Plugins/Mineplex.EnjinTranslator/src/mineplex/enjinTranslator/Enjin.java +++ b/Plugins/Mineplex.EnjinTranslator/src/mineplex/enjinTranslator/Enjin.java @@ -2,10 +2,8 @@ package mineplex.enjinTranslator; import java.text.SimpleDateFormat; import java.util.AbstractMap; -import java.util.ArrayList; import java.util.Date; import java.util.Iterator; -import java.util.List; import java.util.Map.Entry; import java.util.UUID; @@ -30,6 +28,7 @@ import mineplex.core.punish.Punish; import mineplex.core.server.util.TransactionResponse; import mineplex.core.updater.UpdateType; import mineplex.core.updater.event.UpdateEvent; +import mineplex.enjinTranslator.purchase.PurchaseManager; public class Enjin extends MiniPlugin implements CommandExecutor { @@ -37,11 +36,9 @@ public class Enjin extends MiniPlugin implements CommandExecutor private DonationManager _donationManager; private InventoryManager _inventoryManager; private Punish _punish; - - private TempRepository _repository; + private PurchaseManager _purchaseManager; private NautHashMap> _cachedUUIDs = new NautHashMap>(); - private List _commandQueue = new ArrayList(); private static Object _commandLock = new Object(); public long _lastPoll = System.currentTimeMillis() - 120000; @@ -57,7 +54,7 @@ public class Enjin extends MiniPlugin implements CommandExecutor _inventoryManager = inventoryManager; _punish = punish; - _repository = new TempRepository(plugin); + _purchaseManager = new PurchaseManager(plugin); plugin.getCommand("enjin_mineplex").setExecutor(this); plugin.getCommand("pull").setExecutor(this); @@ -77,60 +74,6 @@ public class Enjin extends MiniPlugin implements CommandExecutor iterator.remove(); } } - - @EventHandler - public void processCommandQueue(UpdateEvent event) - { - if (event.getType() != UpdateType.MIN_01 || _commandQueue.size() == 0) - return; - - List commandCopyQueue = new ArrayList(); - - synchronized (_commandLock) - { - for (QueuedCommand command : _commandQueue) - commandCopyQueue.add(command); - - _commandQueue.clear(); - } - - System.out.println("=====] Processing queued commands [====="); - for (QueuedCommand command : commandCopyQueue) - { - try - { - onCommand(command.Sender, command.Command, command.Label, command.Args); - } - catch (Exception exception) - { - exception.printStackTrace(); - } - } - System.out.println("========================================"); - } - - @EventHandler - public void pollLastPurchases(UpdateEvent event) - { - if (event.getType() != UpdateType.MIN_01) - return; - - /* - @SuppressWarnings("serial") - List purchases = new JsonWebCall("http://www.mineplex.com/api/m-shopping-purchases/m/14702725").Execute(new TypeToken>(){}.getType(), null); - _lastPoll = System.currentTimeMillis(); - - int i = 0; - for (EnjinPurchase purchase : purchases) - { - if (i > 10) - break; - - purchase.logInfoToConsole(); - i++; - } - */ - } @Override public boolean onCommand(final CommandSender sender, final Command command, final String label, final String[] args) @@ -180,217 +123,12 @@ public class Enjin extends MiniPlugin implements CommandExecutor final UUID playerUUID = uuid; _cachedUUIDs.put(name, new AbstractMap.SimpleEntry(playerUUID, System.currentTimeMillis() + 240000)); - - if (args.length == 3 && args[0].equalsIgnoreCase("gem")) - { - final int amount = Integer.parseInt(args[2]); - - _donationManager.RewardGems(new Callback() - { - public void run (Boolean response) - { - if (response) - { - System.out.println("[" + _dateFormat.format(new Date()) + "] " + name + " received " + amount + " gems."); - } - else - { - //_commandQueue.add(new QueuedCommand(sender, command, label, args)); - System.out.println("[" + _dateFormat.format(new Date()) + "] ERROR processing " + name + " " + amount + " gems. Queuing for run later."); - } - } - }, "purchase", name, playerUUID, amount); - } - else if (args.length == 3 && args[0].equalsIgnoreCase("coin")) - { - final int amount = Integer.parseInt(args[2]); - _donationManager.RewardCoins(new Callback() - { - public void run (Boolean response) - { - if (response) - { - System.out.println("[" + _dateFormat.format(new Date()) + "] " + name + " received " + amount + " coins."); - } - else - { - //_commandQueue.add(new QueuedCommand(sender, command, label, args)); - System.out.println("[" + _dateFormat.format(new Date()) + "] ERROR processing " + name + " " + amount + " coins. Queuing for run later."); - } - } - }, "purchase", name, client.getAccountId(), amount); - } - else if (args.length == 3 && args[0].equalsIgnoreCase("booster")) - { - int amount = Integer.parseInt(args[2]); - - _donationManager.PurchaseUnknownSalesPackage(null, name, client.getAccountId(), "Gem Booster " + amount, false, 0, false); - _repository.addGemBooster(name, amount); - System.out.println("[" + _dateFormat.format(new Date()) + "] " + name + " received " + amount + " Gem Boosters" + "."); - } - else if (args.length >= 3 && args[0].equalsIgnoreCase("key")) - { - final int amount = Integer.parseInt(args[2]); - - if (args.length == 4) - { - _inventoryManager.addItemToInventoryForOffline(new Callback() - { - public void run(Boolean success) - { - if (success) - System.out.println("[" + _dateFormat.format(new Date()) + "] " + name + " received " + amount + " Treasure Keys" + "."); - else - { - // Add arg so we don't add back to windows api call - //_commandQueue.add(new QueuedCommand(sender, command, label, new String[] { args[0], args[1], args[2], "noaccountchange" })); - System.out.println("[" + _dateFormat.format(new Date()) + "] ERROR processing " + name + " " + amount + " Treasure Keys. Queuing for run later."); - } - } - }, playerUUID, "Treasure", "Treasure Key", amount); - } - else - { - _donationManager.PurchaseUnknownSalesPackage(new Callback() - { - public void run(TransactionResponse data) - { - if (data == TransactionResponse.Success) - { - _inventoryManager.addItemToInventoryForOffline(new Callback() - { - public void run(Boolean success) - { - if (success) - System.out.println("[" + _dateFormat.format(new Date()) + "] " + name + " received " + amount + " Treasure Keys" + "."); - else - { - // Add arg so we don't add back to windows api call - //_commandQueue.add(new QueuedCommand(sender, command, label, new String[] { args[0], args[1], args[2], "noaccountchange" })); - System.out.println("[" + _dateFormat.format(new Date()) + "] ERROR processing " + name + " " + amount + " Treasure Keys. Queuing for run later."); - } - } - }, playerUUID, "Treasure", "Treasure Key", amount); - } - else - { - //_commandQueue.add(new QueuedCommand(sender, command, label, args)); - System.out.println("[" + _dateFormat.format(new Date()) + "] ERROR processing " + name + " " + amount + " Treasure Keys. Queuing for run later."); - } - } - }, name, client.getAccountId(), "Treasure Key " + amount, false, 0, false); - } - } - else if (args.length >= 3 && args[0].equalsIgnoreCase("chest")) - { - final int amount = Integer.parseInt(args[2]); - - if (args.length == 4) - { - _inventoryManager.addItemToInventoryForOffline(new Callback() - { - public void run(Boolean success) - { - if (success) - System.out.println("[" + _dateFormat.format(new Date()) + "] " + name + " received " + amount + " Treasure Chests" + "."); - else - { - // Add arg so we don't add back to windows api call - //_commandQueue.add(new QueuedCommand(sender, command, label, new String[] { args[0], args[1], args[2], "noaccountchange" })); - System.out.println("[" + _dateFormat.format(new Date()) + "] ERROR processing " + name + " " + amount + " Treasure Chests. Queuing for run later."); - } - } - }, playerUUID, "Utility", "Treasure Chest", amount); - } - else - { - _donationManager.PurchaseUnknownSalesPackage(new Callback() - { - public void run(TransactionResponse data) - { - _inventoryManager.addItemToInventoryForOffline(new Callback() - { - public void run(Boolean success) - { - if (success) - System.out.println("[" + _dateFormat.format(new Date()) + "] " + name + " received " + amount + " Treasure Chests" + "."); - else - { - // Add arg so we don't add back to windows api call - //_commandQueue.add(new QueuedCommand(sender, command, label, new String[] { args[0], args[1], args[2], "noaccountchange" })); - System.out.println("[" + _dateFormat.format(new Date()) + "] ERROR processing " + name + " " + amount + " Treasure Chests. Queuing for run later."); - } - } - }, playerUUID, "Utility", "Treasure Chest", amount); - } - }, name, client.getAccountId(), "Treasure Chest " + amount, false, 0, false); - } - } - else if (args.length == 4 && args[0].equalsIgnoreCase("rank")) - { - final Rank rank = mineplex.core.common.Rank.valueOf(args[2]); - final boolean perm = Boolean.parseBoolean(args[3]); - - _clientManager.loadClientByName(name, new Runnable() - { - public void run() - { - if (rank == Rank.ALL || _clientManager.Get(name).GetRank() == Rank.ALL || !_clientManager.Get(name).GetRank().has(rank) || _clientManager.Get(name).GetRank() == rank) - { - _clientManager.SaveRank(name, playerUUID, rank, perm); - System.out.println("[" + _dateFormat.format(new Date()) + "] " + name + " received " + rank + " " + (perm ? "permanently." : "for 1 month.")); - } - else - { - System.out.println("[" + _dateFormat.format(new Date()) + "] " + name + " DENIED INFERIOR " + rank + " " + (perm ? "permanently." : "for 1 month.")); - } - } - }); - } - else if (args.length >= 3 && args[0].equalsIgnoreCase("purchase")) - { - final int amount = Integer.parseInt(args[2]); - final String category = args[3]; - String tempName = args[4]; - - for (int i = 5; i < args.length; i++) - { - tempName += " " + args[i]; - } - - final String packageName = tempName; - - _donationManager.PurchaseUnknownSalesPackage(new Callback() - { - public void run(TransactionResponse data) - { - if (data == TransactionResponse.Success) - { - _inventoryManager.addItemToInventoryForOffline(new Callback() - { - public void run(Boolean success) - { - if (success) - System.out.println("[" + _dateFormat.format(new Date()) + "] " + name + " received " + amount + " " + packageName + "."); - else - { - // Add arg so we don't add back to windows api call - //_commandQueue.add(new QueuedCommand(sender, command, label, new String[] { args[0], args[1], args[2], "noaccountchange" })); - System.out.println("[" + _dateFormat.format(new Date()) + "] ERROR processing " + name + " " + packageName + ". Queuing for run later."); - } - } - }, playerUUID, category, packageName, amount); - } - else - { - //_commandQueue.add(new QueuedCommand(sender, command, label, args)); - System.out.println("[" + _dateFormat.format(new Date()) + "] ERROR processing " + name + " " + amount + " Treasure Keys. Queuing for run later."); - } - } - }, name, client.getAccountId(), packageName, false, 0, false); - } - else if (args.length >= 3 && args[0].equalsIgnoreCase("unban")) + checkForCoinPurchase(args, name, playerUUID, client); + checkForRankPurchase(args, name, playerUUID, client); + checkForPurchase(args, name, playerUUID, client); + + if (args.length >= 3 && args[0].equalsIgnoreCase("unban")) { String reason = args[2]; @@ -436,4 +174,98 @@ public class Enjin extends MiniPlugin implements CommandExecutor return true; } -} + + protected void checkForRankPurchase(String[] args, final String name, final UUID playerUUID, final CoreClient client) + { + if (args.length != 4 || !args[0].equalsIgnoreCase("rank")) + return; + + final Rank rank = mineplex.core.common.Rank.valueOf(args[2]); + final boolean perm = Boolean.parseBoolean(args[3]); + + _clientManager.loadClientByName(name, new Runnable() + { + public void run() + { + if (rank == Rank.ALL || _clientManager.Get(name).GetRank() == Rank.ALL || !_clientManager.Get(name).GetRank().has(rank) || _clientManager.Get(name).GetRank() == rank) + { + _clientManager.SaveRank(new Callback() + { + public void run(Rank data) + { + _purchaseManager.addAccountPurchaseToQueue(client.getAccountId(), rank.Name + (perm ? " Permanent" : " Monthly"), 1, data == rank); + } + }, name, playerUUID, rank, perm); + + System.out.println("[" + _dateFormat.format(new Date()) + "] " + name + " received " + rank + " " + (perm ? "permanently." : "for 1 month.")); + } + else + { + System.out.println("[" + _dateFormat.format(new Date()) + "] " + name + " DENIED INFERIOR " + rank + " " + (perm ? "permanently." : "for 1 month.")); + _purchaseManager.addAccountPurchaseToQueue(client.getAccountId(), rank.Name + (perm ? " Permanent" : " Monthly"), 1, false); + } + } + }); + } + + protected void checkForPurchase(String[] args, final String name, final UUID playerUUID, final CoreClient client) + { + if (args.length < 3 || !args[0].equalsIgnoreCase("purchase")) + return; + + final int amount = Integer.parseInt(args[2]); + String tempName = args[4]; + + for (int i = 5; i < args.length; i++) + { + tempName += " " + args[i]; + } + + final String packageName = tempName; + + _donationManager.PurchaseUnknownSalesPackage(new Callback() + { + public void run(TransactionResponse data) + { + if (data == TransactionResponse.Success) + { + _inventoryManager.addItemToInventoryForOffline(new Callback() + { + public void run(Boolean success) + { + if (success) + System.out.println("[" + _dateFormat.format(new Date()) + "] " + name + " received " + amount + " " + packageName + "."); + else + System.out.println("[" + _dateFormat.format(new Date()) + "] ERROR processing " + name + " " + packageName + ". Queuing for run later."); + } + }, playerUUID, packageName, amount); + } + else + System.out.println("[" + _dateFormat.format(new Date()) + "] ERROR processing " + name + " " + amount + ". Queuing for run later."); + + _purchaseManager.addAccountPurchaseToQueue(client.getAccountId(), packageName, amount, data == TransactionResponse.Success); + } + }, name, client.getAccountId(), amount == 1 ? packageName : packageName + " " + amount, false, 0, false); + } + + protected void checkForCoinPurchase(String[] args, final String name, final UUID playerUUID, final CoreClient client) + { + if (args.length != 3 || !args[0].equalsIgnoreCase("coin")) + return; + + final int amount = Integer.parseInt(args[2]); + + _donationManager.RewardCoins(new Callback() + { + public void run (Boolean response) + { + if (response) + System.out.println("[" + _dateFormat.format(new Date()) + "] " + name + " received " + amount + " coins."); + else + System.out.println("[" + _dateFormat.format(new Date()) + "] ERROR processing " + name + " " + amount + " coins. Queuing for run later."); + + _purchaseManager.addAccountPurchaseToQueue(client.getAccountId(), "Coins", amount, response); + } + }, "purchase", name, client.getAccountId(), amount); + } +} \ No newline at end of file diff --git a/Plugins/Mineplex.EnjinTranslator/src/mineplex/enjinTranslator/purchase/PurchaseManager.java b/Plugins/Mineplex.EnjinTranslator/src/mineplex/enjinTranslator/purchase/PurchaseManager.java new file mode 100644 index 000000000..56052210e --- /dev/null +++ b/Plugins/Mineplex.EnjinTranslator/src/mineplex/enjinTranslator/purchase/PurchaseManager.java @@ -0,0 +1,74 @@ +package mineplex.enjinTranslator.purchase; + +import java.sql.ResultSet; +import java.sql.SQLException; +import java.util.List; + +import org.bukkit.Bukkit; +import org.bukkit.plugin.java.JavaPlugin; + +import mineplex.core.MiniPlugin; +import mineplex.core.common.util.NautHashMap; +import mineplex.core.database.ResultSetCallable; +import mineplex.enjinTranslator.purchase.data.PurchaseRepository; +import mineplex.enjinTranslator.purchase.data.Package; + +public class PurchaseManager extends MiniPlugin +{ + private static Object _purchaseLock = new Object(); + + private PurchaseRepository _repository; + private NautHashMap _purchases = new NautHashMap(); + + public PurchaseManager(JavaPlugin plugin) + { + super("Purchase Manager", plugin); + + _repository = new PurchaseRepository(plugin); + + Bukkit.getServer().getScheduler().runTaskLaterAsynchronously(getPlugin(), new Runnable() + { + public void run() + { + updatePackages(); + } + }, 20L); + } + + private void updatePackages() + { + List packages = _repository.retrievePackages(); + + synchronized (_purchaseLock) + { + for (mineplex.enjinTranslator.purchase.data.Package purchasePackage : packages) + { + _purchases.put(purchasePackage.getName(), purchasePackage); + } + } + } + + public void addAccountPurchaseToQueue(int accountId, final String packageName, int count, boolean success) + { + synchronized (_purchaseLock) + { + if (!_purchases.containsKey(packageName)) + { + _repository.addPackage(packageName, new ResultSetCallable() + { + public void processResultSet(ResultSet resultSet) throws SQLException + { + while (resultSet.next()) + { + int packageId = resultSet.getInt(1); + + _purchases.put(packageName, new Package(packageId, packageName)); + } + } + }); + + _repository.addAccountPurchase(accountId, _purchases.get(packageName).getId(), count, success); + } + } + } +} diff --git a/Plugins/Mineplex.EnjinTranslator/src/mineplex/enjinTranslator/purchase/data/Package.java b/Plugins/Mineplex.EnjinTranslator/src/mineplex/enjinTranslator/purchase/data/Package.java new file mode 100644 index 000000000..9796b8a5d --- /dev/null +++ b/Plugins/Mineplex.EnjinTranslator/src/mineplex/enjinTranslator/purchase/data/Package.java @@ -0,0 +1,23 @@ +package mineplex.enjinTranslator.purchase.data; + +public class Package +{ + private int _id; + private String _name; + + public Package(int id, String name) + { + _id = id; + _name = name; + } + + public int getId() + { + return _id; + } + + public String getName() + { + return _name; + } +} diff --git a/Plugins/Mineplex.EnjinTranslator/src/mineplex/enjinTranslator/purchase/data/PurchaseRepository.java b/Plugins/Mineplex.EnjinTranslator/src/mineplex/enjinTranslator/purchase/data/PurchaseRepository.java new file mode 100644 index 000000000..d71d09552 --- /dev/null +++ b/Plugins/Mineplex.EnjinTranslator/src/mineplex/enjinTranslator/purchase/data/PurchaseRepository.java @@ -0,0 +1,62 @@ +package mineplex.enjinTranslator.purchase.data; + +import java.sql.ResultSet; +import java.sql.SQLException; +import java.util.ArrayList; +import java.util.List; + +import org.bukkit.plugin.java.JavaPlugin; + +import mineplex.core.database.DBPool; +import mineplex.core.database.RepositoryBase; +import mineplex.core.database.ResultSetCallable; +import mineplex.core.database.column.ColumnBoolean; +import mineplex.core.database.column.ColumnInt; +import mineplex.core.database.column.ColumnVarChar; + +public class PurchaseRepository extends RepositoryBase +{ + private static String INSERT_ACCOUNT_PURCHASE = "INSERT INTO accountPurchases (accountId, packageId, amount, date, success) VALUES (?, ?, ?, now(), ?);"; + + private static String INSERT_PACKAGE = "INSERT INTO packages (packageName) VALUES (?);"; + private static String RETRIEVE_PACKAGES = "SELECT id, packageName FROM packages;"; + + public PurchaseRepository(JavaPlugin plugin) + { + super(plugin, DBPool.ACCOUNT); + } + + @Override + protected void initialize() { } + + @Override + protected void update() { } + + public void addPackage(String name, ResultSetCallable callable) + { + executeInsert(INSERT_PACKAGE, callable, new ColumnVarChar("packageName", 100, name)); + } + + public List retrievePackages() + { + final List packages = new ArrayList(); + + executeQuery(RETRIEVE_PACKAGES, new ResultSetCallable() + { + public void processResultSet(ResultSet resultSet) throws SQLException + { + while (resultSet.next()) + { + packages.add(new Package(resultSet.getInt(1), resultSet.getString(2))); + } + } + }); + + return packages; + } + + public boolean addAccountPurchase(int accountId, int packageId, int count, boolean success) + { + return executeInsert(INSERT_ACCOUNT_PURCHASE, null, new ColumnInt("accountId", accountId), new ColumnInt("packageId", packageId), new ColumnInt("count", count), new ColumnBoolean("success", success)) > 0; + } +} From fb4978305f8430a3a7591253cd440fb0b623ae9f Mon Sep 17 00:00:00 2001 From: Jonathan Williams Date: Mon, 9 Nov 2015 02:26:45 -0600 Subject: [PATCH 06/10] Fixed up EnjinTranslator Added extra overload for inventoryManager if you have the accountId already. --- Plugins/BuildFiles/EnjinTranslator.xml | 3 + .../core/inventory/InventoryManager.java | 13 +++- .../src/mineplex/enjinTranslator/Enjin.java | 77 +++++++++---------- .../enjinTranslator/EnjinTranslator.java | 4 +- .../purchase/PurchaseManager.java | 7 +- 5 files changed, 56 insertions(+), 48 deletions(-) diff --git a/Plugins/BuildFiles/EnjinTranslator.xml b/Plugins/BuildFiles/EnjinTranslator.xml index bf3c1fb4a..6cd7bf62d 100644 --- a/Plugins/BuildFiles/EnjinTranslator.xml +++ b/Plugins/BuildFiles/EnjinTranslator.xml @@ -11,6 +11,9 @@ + + + diff --git a/Plugins/Mineplex.Core/src/mineplex/core/inventory/InventoryManager.java b/Plugins/Mineplex.Core/src/mineplex/core/inventory/InventoryManager.java index 2560f2891..e944ea1d3 100644 --- a/Plugins/Mineplex.Core/src/mineplex/core/inventory/InventoryManager.java +++ b/Plugins/Mineplex.Core/src/mineplex/core/inventory/InventoryManager.java @@ -121,6 +121,17 @@ public class InventoryManager extends MiniDbClientPlugin } public void addItemToInventoryForOffline(final Callback callback, final UUID uuid, final String item, final int count) + { + Bukkit.getServer().getScheduler().runTaskAsynchronously(getPlugin(), new Runnable() + { + public void run() + { + addItemToInventoryForOffline(callback, PlayerCache.getInstance().getPlayer(uuid).getAccountId(), item, count); + } + }); + } + + public void addItemToInventoryForOffline(final Callback callback, final int accountId, final String item, final int count) { Bukkit.getServer().getScheduler().runTaskAsynchronously(getPlugin(), new Runnable() { @@ -139,7 +150,7 @@ public class InventoryManager extends MiniDbClientPlugin synchronized (_inventoryLock) { - final boolean success = _repository.incrementClientInventoryItem(PlayerCache.getInstance().getPlayer(uuid).getAccountId(), _items.get(item).Id, count); + final boolean success = _repository.incrementClientInventoryItem(accountId, _items.get(item).Id, count); if (callback != null) { diff --git a/Plugins/Mineplex.EnjinTranslator/src/mineplex/enjinTranslator/Enjin.java b/Plugins/Mineplex.EnjinTranslator/src/mineplex/enjinTranslator/Enjin.java index 429d0cf3f..e77a79480 100644 --- a/Plugins/Mineplex.EnjinTranslator/src/mineplex/enjinTranslator/Enjin.java +++ b/Plugins/Mineplex.EnjinTranslator/src/mineplex/enjinTranslator/Enjin.java @@ -23,7 +23,6 @@ import mineplex.core.common.util.NautHashMap; import mineplex.core.common.util.UUIDFetcher; import mineplex.core.donation.DonationManager; import mineplex.core.inventory.InventoryManager; -import mineplex.core.punish.Category; import mineplex.core.punish.Punish; import mineplex.core.server.util.TransactionResponse; import mineplex.core.updater.UpdateType; @@ -35,7 +34,6 @@ public class Enjin extends MiniPlugin implements CommandExecutor private CoreClientManager _clientManager; private DonationManager _donationManager; private InventoryManager _inventoryManager; - private Punish _punish; private PurchaseManager _purchaseManager; private NautHashMap> _cachedUUIDs = new NautHashMap>(); @@ -45,7 +43,7 @@ public class Enjin extends MiniPlugin implements CommandExecutor private SimpleDateFormat _dateFormat = new SimpleDateFormat("MM-dd-yyyy HH:mm:ss"); - public Enjin(JavaPlugin plugin, CoreClientManager clientManager, DonationManager donationManager, InventoryManager inventoryManager, Punish punish) + public Enjin(JavaPlugin plugin, CoreClientManager clientManager, DonationManager donationManager, InventoryManager inventoryManager) { super("Enjin", plugin); @@ -53,7 +51,6 @@ public class Enjin extends MiniPlugin implements CommandExecutor _donationManager = donationManager; _inventoryManager = inventoryManager; - _punish = punish; _purchaseManager = new PurchaseManager(plugin); plugin.getCommand("enjin_mineplex").setExecutor(this); @@ -124,34 +121,19 @@ public class Enjin extends MiniPlugin implements CommandExecutor _cachedUUIDs.put(name, new AbstractMap.SimpleEntry(playerUUID, System.currentTimeMillis() + 240000)); - checkForCoinPurchase(args, name, playerUUID, client); - checkForRankPurchase(args, name, playerUUID, client); - checkForPurchase(args, name, playerUUID, client); - - if (args.length >= 3 && args[0].equalsIgnoreCase("unban")) - { - String reason = args[2]; - - for (int i = 3; i < args.length; i++) - { - reason += " " + args[i]; - } - - _punish.RemoveBan(name, reason); - System.out.println("[" + _dateFormat.format(new Date()) + "] " + name + " unbanned for " + reason); - } - else if (args.length >= 3 && args[0].equalsIgnoreCase("ban")) - { - String reason = args[2]; - - for (int i = 3; i < args.length; i++) - { - reason += " " + args[i]; - } - - _punish.AddPunishment(name, Category.Other, reason, null, 3, true, -1); - System.out.println("[" + _dateFormat.format(new Date()) + "] " + name + " banned for " + reason); - } + if (!checkForCoinPurchase(args, name, playerUUID, client)) + if (!checkForRankPurchase(args, name, playerUUID, client)) + if(!checkForPurchase(args, name, client)) + { + StringBuilder sb = new StringBuilder(); + + for (String arg : args) + { + sb.append(arg + " "); + } + + System.out.println("Received Command : " + sb.toString()); + } } } }); @@ -175,10 +157,10 @@ public class Enjin extends MiniPlugin implements CommandExecutor return true; } - protected void checkForRankPurchase(String[] args, final String name, final UUID playerUUID, final CoreClient client) + protected boolean checkForRankPurchase(String[] args, final String name, final UUID playerUUID, final CoreClient client) { if (args.length != 4 || !args[0].equalsIgnoreCase("rank")) - return; + return false;; final Rank rank = mineplex.core.common.Rank.valueOf(args[2]); final boolean perm = Boolean.parseBoolean(args[3]); @@ -206,12 +188,14 @@ public class Enjin extends MiniPlugin implements CommandExecutor } } }); + + return true; } - protected void checkForPurchase(String[] args, final String name, final UUID playerUUID, final CoreClient client) + protected boolean checkForPurchase(String[] args, final String name, final CoreClient client) { if (args.length < 3 || !args[0].equalsIgnoreCase("purchase")) - return; + return false; final int amount = Integer.parseInt(args[2]); String tempName = args[4]; @@ -234,24 +218,33 @@ public class Enjin extends MiniPlugin implements CommandExecutor public void run(Boolean success) { if (success) + { + _purchaseManager.addAccountPurchaseToQueue(client.getAccountId(), packageName, amount, true); System.out.println("[" + _dateFormat.format(new Date()) + "] " + name + " received " + amount + " " + packageName + "."); + } else + { System.out.println("[" + _dateFormat.format(new Date()) + "] ERROR processing " + name + " " + packageName + ". Queuing for run later."); + _purchaseManager.addAccountPurchaseToQueue(client.getAccountId(), packageName, amount, false); + } } - }, playerUUID, packageName, amount); + }, client.getAccountId(), packageName, amount); } else + { System.out.println("[" + _dateFormat.format(new Date()) + "] ERROR processing " + name + " " + amount + ". Queuing for run later."); - - _purchaseManager.addAccountPurchaseToQueue(client.getAccountId(), packageName, amount, data == TransactionResponse.Success); + _purchaseManager.addAccountPurchaseToQueue(client.getAccountId(), packageName, amount, data == TransactionResponse.Success); + } } }, name, client.getAccountId(), amount == 1 ? packageName : packageName + " " + amount, false, 0, false); + + return true; } - protected void checkForCoinPurchase(String[] args, final String name, final UUID playerUUID, final CoreClient client) + protected boolean checkForCoinPurchase(String[] args, final String name, final UUID playerUUID, final CoreClient client) { if (args.length != 3 || !args[0].equalsIgnoreCase("coin")) - return; + return false; final int amount = Integer.parseInt(args[2]); @@ -267,5 +260,7 @@ public class Enjin extends MiniPlugin implements CommandExecutor _purchaseManager.addAccountPurchaseToQueue(client.getAccountId(), "Coins", amount, response); } }, "purchase", name, client.getAccountId(), amount); + + return true; } } \ No newline at end of file diff --git a/Plugins/Mineplex.EnjinTranslator/src/mineplex/enjinTranslator/EnjinTranslator.java b/Plugins/Mineplex.EnjinTranslator/src/mineplex/enjinTranslator/EnjinTranslator.java index d9222b689..1304f0a3e 100644 --- a/Plugins/Mineplex.EnjinTranslator/src/mineplex/enjinTranslator/EnjinTranslator.java +++ b/Plugins/Mineplex.EnjinTranslator/src/mineplex/enjinTranslator/EnjinTranslator.java @@ -28,11 +28,9 @@ public class EnjinTranslator extends JavaPlugin CommandCenter.Instance.setClientManager(clientManager); DonationManager donationManager = new DonationManager(this, clientManager, GetWebServerAddress()); - //Other Modules - Punish punish = new Punish(this, GetWebServerAddress(), clientManager); //Main Modules - new Enjin(this, clientManager, donationManager, new InventoryManager(this, clientManager), punish); + new Enjin(this, clientManager, donationManager, new InventoryManager(this, clientManager)); new Updater(this); } diff --git a/Plugins/Mineplex.EnjinTranslator/src/mineplex/enjinTranslator/purchase/PurchaseManager.java b/Plugins/Mineplex.EnjinTranslator/src/mineplex/enjinTranslator/purchase/PurchaseManager.java index 56052210e..1897f407e 100644 --- a/Plugins/Mineplex.EnjinTranslator/src/mineplex/enjinTranslator/purchase/PurchaseManager.java +++ b/Plugins/Mineplex.EnjinTranslator/src/mineplex/enjinTranslator/purchase/PurchaseManager.java @@ -49,7 +49,7 @@ public class PurchaseManager extends MiniPlugin } public void addAccountPurchaseToQueue(int accountId, final String packageName, int count, boolean success) - { + { synchronized (_purchaseLock) { if (!_purchases.containsKey(packageName)) @@ -63,12 +63,13 @@ public class PurchaseManager extends MiniPlugin int packageId = resultSet.getInt(1); _purchases.put(packageName, new Package(packageId, packageName)); + System.out.println("Added new package : " + packageName); } } }); - - _repository.addAccountPurchase(accountId, _purchases.get(packageName).getId(), count, success); } + + _repository.addAccountPurchase(accountId, _purchases.get(packageName).getId(), count, success); } } } From 2c54e9e59a882f3a90578341c3d510a69d7d005d Mon Sep 17 00:00:00 2001 From: Shaun Bennett Date: Mon, 9 Nov 2015 03:27:42 -0500 Subject: [PATCH 07/10] Giveaway extras --- .../src/mineplex/core/giveaway/Giveaway.java | 9 ++- .../core/giveaway/GiveawayManager.java | 71 +++++++++++++++++-- .../core/giveaway/GiveawayRepository.java | 32 ++++++--- .../core/giveaway/GiveawayReward.java | 23 ++++++ .../core/giveaway/PlayerGiveawayData.java | 26 +++++++ .../mineplex/core/reward/RewardManager.java | 5 +- .../Mineplex.Hub/src/mineplex/hub/Hub.java | 2 +- 7 files changed, 152 insertions(+), 16 deletions(-) create mode 100644 Plugins/Mineplex.Core/src/mineplex/core/giveaway/GiveawayReward.java create mode 100644 Plugins/Mineplex.Core/src/mineplex/core/giveaway/PlayerGiveawayData.java diff --git a/Plugins/Mineplex.Core/src/mineplex/core/giveaway/Giveaway.java b/Plugins/Mineplex.Core/src/mineplex/core/giveaway/Giveaway.java index eb8817526..2d6eeeca4 100644 --- a/Plugins/Mineplex.Core/src/mineplex/core/giveaway/Giveaway.java +++ b/Plugins/Mineplex.Core/src/mineplex/core/giveaway/Giveaway.java @@ -4,15 +4,17 @@ public class Giveaway { private int _id; private String _name; + private String _prettyName; private String _header; private String _message; private boolean _notifyNetwork; private int _notifyCooldown; - public Giveaway(int id, String name, String header, String message, boolean notifyNetwork, int notifyCooldown) + public Giveaway(int id, String name, String prettyName, String header, String message, boolean notifyNetwork, int notifyCooldown) { _id = id; _name = name; + _prettyName = prettyName; _header = header; _message = message; _notifyNetwork = notifyNetwork; @@ -29,6 +31,11 @@ public class Giveaway return _name; } + public String getPrettyName() + { + return _prettyName; + } + public String getMessage() { return _message; diff --git a/Plugins/Mineplex.Core/src/mineplex/core/giveaway/GiveawayManager.java b/Plugins/Mineplex.Core/src/mineplex/core/giveaway/GiveawayManager.java index 0ad5344f5..bc4631f64 100644 --- a/Plugins/Mineplex.Core/src/mineplex/core/giveaway/GiveawayManager.java +++ b/Plugins/Mineplex.Core/src/mineplex/core/giveaway/GiveawayManager.java @@ -1,30 +1,43 @@ package mineplex.core.giveaway; +import java.sql.ResultSet; +import java.sql.SQLException; import java.util.HashMap; import java.util.UUID; import org.bukkit.entity.Player; +import org.bukkit.event.EventHandler; +import org.bukkit.event.player.PlayerJoinEvent; import org.bukkit.plugin.java.JavaPlugin; +import mineplex.core.MiniDbClientPlugin; import mineplex.core.MiniPlugin; import mineplex.core.account.CoreClientManager; import mineplex.core.common.util.Callback; +import mineplex.core.common.util.F; +import mineplex.core.common.util.UtilPlayer; +import mineplex.core.common.util.UtilServer; import mineplex.core.giveaway.redis.GiveawayMessage; import mineplex.core.giveaway.redis.GiveawayMessageHandler; +import mineplex.core.status.ServerStatusManager; +import mineplex.core.updater.UpdateType; +import mineplex.core.updater.event.UpdateEvent; import mineplex.serverdata.Region; import mineplex.serverdata.commands.ServerCommandManager; -public class GiveawayManager extends MiniPlugin +public class GiveawayManager extends MiniDbClientPlugin { private CoreClientManager _clientManager; + private ServerStatusManager _statusManager; private GiveawayRepository _repository; private HashMap _giveawayMap; private HashMap _cooldownMap; - public GiveawayManager(JavaPlugin plugin, CoreClientManager clientManager) + public GiveawayManager(JavaPlugin plugin, CoreClientManager clientManager, ServerStatusManager statusManager) { - super("Giveaway Manager", plugin); + super("Giveaway Manager", plugin, clientManager); _clientManager = clientManager; + _statusManager = statusManager; _repository = new GiveawayRepository(plugin); _giveawayMap = _repository.loadGiveaways(); _cooldownMap = _repository.loadCooldowns(); @@ -66,7 +79,7 @@ public class GiveawayManager extends MiniPlugin if (_repository.canGiveaway(accountId, giveawayName, cooldownName)) { UUID uuid = UUID.randomUUID(); - if (_repository.addGiveaway(accountId, giveaway.getId(), cooldown.getId(), Region.US, "", uuid)) + if (_repository.addGiveaway(accountId, giveaway.getId(), cooldown.getId(), _statusManager.getRegion(), _statusManager.getName(), uuid)) { response = new GiveawayResponse(uuid); } @@ -89,6 +102,9 @@ public class GiveawayManager extends MiniPlugin { if (response.isSuccess()) { + Get(player).addGiveawayReward(new GiveawayReward(giveaway.getPrettyName(), response.getGiveawayId().toString().replace("-", ""))); + notifyPlayer(player); + GiveawayMessage message = new GiveawayMessage(giveawayName, player.getName(), giveaway.getMessage(), giveaway.getHeader()); message.publish(); } @@ -114,4 +130,51 @@ public class GiveawayManager extends MiniPlugin { return _cooldownMap.containsKey(name); } + + @EventHandler + public void notifyGiveaway(UpdateEvent event) + { + if (event.getType() == UpdateType.MIN_01) + { + for (Player player : UtilServer.getPlayers()) + notifyPlayer(player); + } + } + + @EventHandler + public void join(PlayerJoinEvent event) + { + notifyPlayer(event.getPlayer()); + } + + public void notifyPlayer(Player player) + { + PlayerGiveawayData data = Get(player); + if (!data.getGiveawayRewards().isEmpty()) + { + GiveawayReward reward = data.getGiveawayRewards().poll(); + UtilPlayer.message(player, F.main("Giveaway", "You have a prize to claim!")); + UtilPlayer.message(player, F.main("Giveaway", "You have won " + F.elem(reward.getName()))); + UtilPlayer.message(player, F.main("Giveaway", "To claim your reward please take a screenshot and contact support")); + UtilPlayer.message(player, F.main("Giveaway", "Reward Key: " + F.elem(reward.getUuid()))); + } + } + + @Override + public void processLoginResultSet(String playerName, int accountId, ResultSet resultSet) throws SQLException + { + Set(playerName, _repository.loadPlayerGiveaway(resultSet)); + } + + @Override + public String getQuery(int accountId, String uuid, String name) + { + return "SELECT g.prettyName, ag.uuid FROM accountGiveaway AS ag INNER JOIN giveaway AS g ON ag.giveawayId = g.id WHERE ag.claimed = 0 AND ag.accountId = " + accountId + ";"; + } + + @Override + protected PlayerGiveawayData AddPlayer(String player) + { + return new PlayerGiveawayData(); + } } diff --git a/Plugins/Mineplex.Core/src/mineplex/core/giveaway/GiveawayRepository.java b/Plugins/Mineplex.Core/src/mineplex/core/giveaway/GiveawayRepository.java index 7025f2f04..c8cac2179 100644 --- a/Plugins/Mineplex.Core/src/mineplex/core/giveaway/GiveawayRepository.java +++ b/Plugins/Mineplex.Core/src/mineplex/core/giveaway/GiveawayRepository.java @@ -21,7 +21,7 @@ import mineplex.serverdata.Region; public class GiveawayRepository extends RepositoryBase { private static final String INSERT_GIVEAWAY = "INSERT INTO Account.accountGiveaway (giveawayId, accountId, cooldownId, region, serverName, time, uuid) VALUES (?, ?, ?, ?, ?, now(), ?)"; - private static final String LOAD_GIVEAWAY = "SELECT id, name, header, message, max, notifyNetwork, notifyCooldown, canWinTwice FROM Account.giveaway WHERE enabled = TRUE"; + private static final String LOAD_GIVEAWAY = "SELECT id, name, prettyName, header, message, max, notifyNetwork, notifyCooldown, canWinTwice FROM Account.giveaway WHERE enabled = TRUE"; private static final String LOAD_COOLDOWN = "SELECT id, name, cooldown FROM Account.giveawayCooldown"; public GiveawayRepository(JavaPlugin plugin) @@ -68,14 +68,15 @@ public class GiveawayRepository extends RepositoryBase { int id = resultSet.getInt(1); String name = resultSet.getString(2); - String header = resultSet.getString(3); - String message = resultSet.getString(4); - int max = resultSet.getInt(5); - boolean notifyNetwork = resultSet.getBoolean(6); - int notifyCooldown = resultSet.getInt(7); - boolean canWinTwice = resultSet.getBoolean(8); + String prettyName = resultSet.getString(3); + String header = resultSet.getString(4); + String message = resultSet.getString(5); + int max = resultSet.getInt(6); + boolean notifyNetwork = resultSet.getBoolean(7); + int notifyCooldown = resultSet.getInt(8); + boolean canWinTwice = resultSet.getBoolean(9); - Giveaway giveaway = new Giveaway(id, name, header, message, notifyNetwork, notifyCooldown); + Giveaway giveaway = new Giveaway(id, name, prettyName, header, message, notifyNetwork, notifyCooldown); map.put(name, giveaway); } } @@ -104,6 +105,21 @@ public class GiveawayRepository extends RepositoryBase return map; } + public PlayerGiveawayData loadPlayerGiveaway(ResultSet resultSet) throws SQLException + { + PlayerGiveawayData giveawayData = new PlayerGiveawayData(); + + while (resultSet.next()) + { + String name = resultSet.getString(1); + String uuid = resultSet.getString(2); + GiveawayReward reward = new GiveawayReward(name, uuid); + giveawayData.addGiveawayReward(reward); + } + + return giveawayData; + } + @Override protected void initialize() { diff --git a/Plugins/Mineplex.Core/src/mineplex/core/giveaway/GiveawayReward.java b/Plugins/Mineplex.Core/src/mineplex/core/giveaway/GiveawayReward.java new file mode 100644 index 000000000..21be3cd75 --- /dev/null +++ b/Plugins/Mineplex.Core/src/mineplex/core/giveaway/GiveawayReward.java @@ -0,0 +1,23 @@ +package mineplex.core.giveaway; + +public class GiveawayReward +{ + private String _name; + private String _uuid; + + public GiveawayReward(String name, String uuid) + { + _name = name; + _uuid = uuid; + } + + public String getName() + { + return _name; + } + + public String getUuid() + { + return _uuid; + } +} diff --git a/Plugins/Mineplex.Core/src/mineplex/core/giveaway/PlayerGiveawayData.java b/Plugins/Mineplex.Core/src/mineplex/core/giveaway/PlayerGiveawayData.java new file mode 100644 index 000000000..01f984fcb --- /dev/null +++ b/Plugins/Mineplex.Core/src/mineplex/core/giveaway/PlayerGiveawayData.java @@ -0,0 +1,26 @@ +package mineplex.core.giveaway; + +import java.util.ArrayList; +import java.util.LinkedList; +import java.util.List; +import java.util.Queue; + +public class PlayerGiveawayData +{ + private Queue _giveawayRewards; + + public PlayerGiveawayData() + { + _giveawayRewards = new LinkedList(); + } + + public void addGiveawayReward(GiveawayReward reward) + { + _giveawayRewards.add(reward); + } + + public Queue getGiveawayRewards() + { + return _giveawayRewards; + } +} diff --git a/Plugins/Mineplex.Core/src/mineplex/core/reward/RewardManager.java b/Plugins/Mineplex.Core/src/mineplex/core/reward/RewardManager.java index 44a10fcc7..5e00cf516 100644 --- a/Plugins/Mineplex.Core/src/mineplex/core/reward/RewardManager.java +++ b/Plugins/Mineplex.Core/src/mineplex/core/reward/RewardManager.java @@ -30,6 +30,7 @@ import mineplex.core.reward.rewards.UnknownPackageReward; import mineplex.core.stats.StatsManager; import mineplex.core.status.ServerStatusManager; import mineplex.core.timing.TimingManager; +import mineplex.serverdata.Region; public class RewardManager { @@ -398,9 +399,9 @@ public class RewardManager RewardRarity rarity = type.generateRarity(requiresUncommon); //Dont give Rank Upgrade if already has Titan - if (rarity == RewardRarity.MYTHICAL) + if (true || rarity == RewardRarity.MYTHICAL) { - if (canGiveMythical && type == RewardType.MythicalChest && Math.random() <= 0.1) + if (true || _statusManager.getRegion() == Region.US && canGiveMythical && type == RewardType.MythicalChest && Math.random() <= 0.1) { return getLogitechPrize(); } diff --git a/Plugins/Mineplex.Hub/src/mineplex/hub/Hub.java b/Plugins/Mineplex.Hub/src/mineplex/hub/Hub.java index 9a2f3e30d..f085eba33 100644 --- a/Plugins/Mineplex.Hub/src/mineplex/hub/Hub.java +++ b/Plugins/Mineplex.Hub/src/mineplex/hub/Hub.java @@ -112,7 +112,7 @@ public class Hub extends JavaPlugin implements IRelation //Main Modules ServerStatusManager serverStatusManager = new ServerStatusManager(this, clientManager, new LagMeter(this, clientManager)); - GiveawayManager giveawayManager = new GiveawayManager(this, clientManager); + GiveawayManager giveawayManager = new GiveawayManager(this, clientManager, serverStatusManager); new TitanGiveawayManager(this, clientManager, serverStatusManager); Portal portal = new Portal(this, clientManager, serverStatusManager.getCurrentServerName()); From 05b52614fe8ac9b28f43fa91030181b261ba4b5f Mon Sep 17 00:00:00 2001 From: Shaun Bennett Date: Mon, 9 Nov 2015 03:49:12 -0500 Subject: [PATCH 08/10] Forgot to remove debug code for testing --- .../Mineplex.Core/src/mineplex/core/reward/RewardManager.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/Plugins/Mineplex.Core/src/mineplex/core/reward/RewardManager.java b/Plugins/Mineplex.Core/src/mineplex/core/reward/RewardManager.java index 5e00cf516..bd776c173 100644 --- a/Plugins/Mineplex.Core/src/mineplex/core/reward/RewardManager.java +++ b/Plugins/Mineplex.Core/src/mineplex/core/reward/RewardManager.java @@ -399,9 +399,9 @@ public class RewardManager RewardRarity rarity = type.generateRarity(requiresUncommon); //Dont give Rank Upgrade if already has Titan - if (true || rarity == RewardRarity.MYTHICAL) + if (rarity == RewardRarity.MYTHICAL) { - if (true || _statusManager.getRegion() == Region.US && canGiveMythical && type == RewardType.MythicalChest && Math.random() <= 0.1) + if (_statusManager.getRegion() == Region.US && canGiveMythical && type == RewardType.MythicalChest && Math.random() <= 0.1) { return getLogitechPrize(); } From ec3427bcc04e127f700e0275f9f4be4eb8a88795 Mon Sep 17 00:00:00 2001 From: Shaun Bennett Date: Mon, 9 Nov 2015 04:08:26 -0500 Subject: [PATCH 09/10] Giveaway manager bug fix --- .../src/mineplex/core/giveaway/GiveawayManager.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/Plugins/Mineplex.Core/src/mineplex/core/giveaway/GiveawayManager.java b/Plugins/Mineplex.Core/src/mineplex/core/giveaway/GiveawayManager.java index bc4631f64..bfcfa4981 100644 --- a/Plugins/Mineplex.Core/src/mineplex/core/giveaway/GiveawayManager.java +++ b/Plugins/Mineplex.Core/src/mineplex/core/giveaway/GiveawayManager.java @@ -79,7 +79,7 @@ public class GiveawayManager extends MiniDbClientPlugin if (_repository.canGiveaway(accountId, giveawayName, cooldownName)) { UUID uuid = UUID.randomUUID(); - if (_repository.addGiveaway(accountId, giveaway.getId(), cooldown.getId(), _statusManager.getRegion(), _statusManager.getName(), uuid)) + if (_repository.addGiveaway(accountId, giveaway.getId(), cooldown.getId(), _statusManager.getRegion(), _statusManager.getCurrentServerName(), uuid)) { response = new GiveawayResponse(uuid); } From ba7d5bbcdcf67f3bf4edfb6097c282262e560631 Mon Sep 17 00:00:00 2001 From: Jonathan Williams Date: Mon, 9 Nov 2015 03:24:20 -0600 Subject: [PATCH 10/10] Fixed Arcade! --- .../Nautilus.Game.Arcade/src/nautilus/game/arcade/Arcade.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/Plugins/Nautilus.Game.Arcade/src/nautilus/game/arcade/Arcade.java b/Plugins/Nautilus.Game.Arcade/src/nautilus/game/arcade/Arcade.java index 875ee38e3..a351044b6 100644 --- a/Plugins/Nautilus.Game.Arcade/src/nautilus/game/arcade/Arcade.java +++ b/Plugins/Nautilus.Game.Arcade/src/nautilus/game/arcade/Arcade.java @@ -148,7 +148,7 @@ public class Arcade extends JavaPlugin new GlobalPacketManager(this, _clientManager, serverStatusManager); - GiveawayManager giveawayManager = new GiveawayManager(this, _clientManager); + GiveawayManager giveawayManager = new GiveawayManager(this, _clientManager, serverStatusManager); //Arcade Manager PollManager pollManager = new PollManager(this, _clientManager, _donationManager);