package com.shoporder.managers; import com.shoporder.ShopOrder; import com.shoporder.data.Order; import com.shoporder.data.OrderStatus; import lombok.Getter; import org.bukkit.Bukkit; import org.bukkit.Material; import org.bukkit.entity.Player; import org.bukkit.inventory.ItemStack; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.UUID; import java.util.concurrent.CompletableFuture; import java.util.stream.Collectors; @Getter public class OrderManager { private final ShopOrder plugin; private final Map orders = new HashMap<>(); private final Map lastOrderTime = new HashMap<>(); public OrderManager(ShopOrder plugin) { this.plugin = plugin; } public void loadOrders() { plugin.getFoliaLib().getScheduler().runAsync(task -> { plugin.getDatabaseManager().getAllOrders().thenAccept(loadedOrders -> { orders.clear(); for (Order order : loadedOrders) { orders.put(order.getId(), order); } plugin.getLogger().info("Loaded " + orders.size() + " orders from database"); }); }); } public void saveOrders() { for (Order order : orders.values()) { plugin.getDatabaseManager().updateOrder(order); } } public CompletableFuture createOrder(Player player, String materialKey, int quantity, double pricePerItem) { return CompletableFuture.supplyAsync(() -> { double totalCost = pricePerItem * quantity; double taxPercentage = plugin.getConfigManager().getTaxPercentage(); double taxAmount = totalCost * (taxPercentage / 100.0); double totalDeduction = totalCost + taxAmount; if (!plugin.getEconomyManager().has(player, totalDeduction)) { return null; } if (!plugin.getEconomyManager().withdraw(player, totalDeduction)) { return null; } String orderId = UUID.randomUUID().toString().substring(0, 8); Order order = new Order( orderId, player.getUniqueId(), player.getName(), materialKey, quantity, pricePerItem, totalCost, taxAmount, null, null, OrderStatus.PENDING, System.currentTimeMillis(), 0L, 0L, pricePerItem, totalCost, 0.0 ); orders.put(orderId, order); lastOrderTime.put(player.getUniqueId(), System.currentTimeMillis()); plugin.getDatabaseManager().saveOrder(order); return order; }); } public CompletableFuture acceptOrder(String orderId, Player deliverer) { return CompletableFuture.supplyAsync(() -> { Order order = orders.get(orderId); if (order == null || order.getStatus() != OrderStatus.PENDING) { return false; } if (order.getPlayerId().equals(deliverer.getUniqueId())) { return false; } order.setStatus(OrderStatus.IN_PROGRESS); order.setDeliveryPlayerId(deliverer.getUniqueId()); order.setDeliveryPlayerName(deliverer.getName()); order.setAcceptedAt(System.currentTimeMillis()); plugin.getDatabaseManager().updateOrder(order); plugin.getFoliaLib().getScheduler().runAtEntity(deliverer, task -> { String message = plugin.getConfigManager().getMessage("order.accepted") .replace("{id}", orderId) .replace("{item}", order.getMaterialKey().replace("_", " ")) .replace("{quantity}", String.valueOf(order.getQuantity())); deliverer.sendMessage(plugin.getConfigManager().getPrefix() + message); }); Player orderOwner = Bukkit.getPlayer(order.getPlayerId()); if (orderOwner != null && orderOwner.isOnline()) { plugin.getFoliaLib().getScheduler().runAtEntity(orderOwner, task -> { String message = plugin.getConfigManager().getMessage("order.being-delivered") .replace("{id}", orderId) .replace("{deliverer}", deliverer.getName()); orderOwner.sendMessage(plugin.getConfigManager().getPrefix() + message); }); } return true; }); } public CompletableFuture deliverOrder(String orderId, Player deliverer) { return CompletableFuture.supplyAsync(() -> { Order order = orders.get(orderId); if (order == null || order.getStatus() != OrderStatus.IN_PROGRESS) { return false; } if (order.getDeliveryPlayerId() == null || !order.getDeliveryPlayerId().equals(deliverer.getUniqueId())) { return false; } order.setStatus(OrderStatus.COMPLETED); order.setCompletedAt(System.currentTimeMillis()); plugin.getDatabaseManager().updateOrder(order); plugin.getFoliaLib().getScheduler().runAtEntity(deliverer, task -> { plugin.getEconomyManager().deposit(deliverer, order.getTotalCost()); String message = plugin.getConfigManager().getMessage("order.delivered") .replace("{id}", orderId) .replace("{amount}", plugin.getEconomyManager().format(order.getTotalCost())); deliverer.sendMessage(plugin.getConfigManager().getPrefix() + message); }); Player orderOwner = Bukkit.getPlayer(order.getPlayerId()); if (orderOwner != null && orderOwner.isOnline()) { plugin.getFoliaLib().getScheduler().runAtEntity(orderOwner, task -> { String message = plugin.getConfigManager().getMessage("order.completed") .replace("{id}", orderId) .replace("{deliverer}", order.getDeliveryPlayerName()); orderOwner.sendMessage(plugin.getConfigManager().getPrefix() + message); }); } return true; }); } public CompletableFuture cancelOrder(String orderId, Player player) { return CompletableFuture.supplyAsync(() -> { Order order = orders.get(orderId); if (order == null) { return false; } boolean isOwner = order.getPlayerId().equals(player.getUniqueId()); boolean isDeliverer = order.getDeliveryPlayerId() != null && order.getDeliveryPlayerId().equals(player.getUniqueId()); if (!isOwner && !isDeliverer && !player.hasPermission("shoporder.admin")) { return false; } if (order.getStatus() == OrderStatus.COMPLETED || order.getStatus() == OrderStatus.CANCELLED) { return false; } OrderStatus oldStatus = order.getStatus(); order.setStatus(OrderStatus.CANCELLED); order.setCompletedAt(System.currentTimeMillis()); plugin.getDatabaseManager().updateOrder(order); if (isOwner && oldStatus == OrderStatus.PENDING) { int refundPercent = plugin.getConfigManager().getConfig().getInt("order.refund-percentage", 75); double refund = (order.getTotalCost() + order.getTaxAmount()) * (refundPercent / 100.0); plugin.getFoliaLib().getScheduler().runAtEntity(player, task -> { plugin.getEconomyManager().deposit(player, refund); String message = plugin.getConfigManager().getMessage("order.cancelled-owner") .replace("{id}", orderId) .replace("{refund}", plugin.getEconomyManager().format(refund)); player.sendMessage(plugin.getConfigManager().getPrefix() + message); }); } else if (isDeliverer && oldStatus == OrderStatus.IN_PROGRESS) { plugin.getFoliaLib().getScheduler().runAtEntity(player, task -> { String message = plugin.getConfigManager().getMessage("order.cancelled-deliverer") .replace("{id}", orderId); player.sendMessage(plugin.getConfigManager().getPrefix() + message); }); order.setDeliveryPlayerId(null); order.setDeliveryPlayerName(null); order.setStatus(OrderStatus.PENDING); order.setAcceptedAt(0L); } return true; }); } public boolean validateDeliveryItems(Order order, ItemStack[] items) { Material requiredMaterial = Material.getMaterial(order.getMaterialKey()); if (requiredMaterial == null) { return false; } int totalCount = 0; for (ItemStack item : items) { if (item != null && item.getType() == requiredMaterial) { totalCount += item.getAmount(); } } return totalCount >= order.getQuantity(); } public void removeDeliveryItems(Order order, ItemStack[] items) { Material requiredMaterial = Material.getMaterial(order.getMaterialKey()); int remaining = order.getQuantity(); for (int i = 0; i < items.length && remaining > 0; i++) { ItemStack item = items[i]; if (item != null && item.getType() == requiredMaterial) { int toRemove = Math.min(item.getAmount(), remaining); item.setAmount(item.getAmount() - toRemove); remaining -= toRemove; if (item.getAmount() <= 0) { items[i] = null; } } } } public List getPlayerOrders(UUID playerId) { return orders.values().stream() .filter(order -> order.getPlayerId().equals(playerId)) .sorted((o1, o2) -> Long.compare(o2.getCreatedAt(), o1.getCreatedAt())) .collect(Collectors.toList()); } public List getPendingOrders() { return orders.values().stream() .filter(order -> order.getStatus() == OrderStatus.PENDING) .sorted((o1, o2) -> Long.compare(o2.getCreatedAt(), o1.getCreatedAt())) .collect(Collectors.toList()); } public List getInProgressOrders(UUID delivererId) { return orders.values().stream() .filter(order -> order.getStatus() == OrderStatus.IN_PROGRESS) .filter(order -> order.getDeliveryPlayerId() != null && order.getDeliveryPlayerId().equals(delivererId)) .sorted((o1, o2) -> Long.compare(o2.getAcceptedAt(), o1.getAcceptedAt())) .collect(Collectors.toList()); } public Order getOrder(String orderId) { return orders.get(orderId); } public boolean isOnCooldown(Player player) { if (player.hasPermission("shoporder.bypass.cooldown")) { return false; } Long lastTime = lastOrderTime.get(player.getUniqueId()); if (lastTime == null) { return false; } int cooldown = plugin.getConfigManager().getConfig().getInt("order.cooldown", 60); return (System.currentTimeMillis() - lastTime) < (cooldown * 1000L); } public long getCooldownRemaining(Player player) { Long lastTime = lastOrderTime.get(player.getUniqueId()); if (lastTime == null) { return 0; } int cooldown = plugin.getConfigManager().getConfig().getInt("order.cooldown", 60); long elapsed = System.currentTimeMillis() - lastTime; long remaining = (cooldown * 1000L) - elapsed; return Math.max(0, remaining / 1000); } public Map getStatistics() { Map stats = new HashMap<>(); stats.put("total", orders.size()); stats.put("pending", (int) orders.values().stream().filter(o -> o.getStatus() == OrderStatus.PENDING).count()); stats.put("in_progress", (int) orders.values().stream().filter(o -> o.getStatus() == OrderStatus.IN_PROGRESS).count()); stats.put("completed", (int) orders.values().stream().filter(o -> o.getStatus() == OrderStatus.COMPLETED).count()); return stats; } public double getTotalRevenue() { return orders.values().stream() .filter(o -> o.getStatus() == OrderStatus.COMPLETED) .mapToDouble(Order::getTotalCost) .sum(); } }