package com.nebula.core.bounty; import com.nebula.core.NebulaCore; import com.nebula.core.economy.CurrencyType; import org.bukkit.Bukkit; import org.bukkit.entity.Player; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.util.*; import java.util.concurrent.ConcurrentHashMap; public class BountyManager { private final NebulaCore plugin; private final Map> activeBounties; public BountyManager(NebulaCore plugin) { this.plugin = plugin; this.activeBounties = new ConcurrentHashMap<>(); loadBounties(); startExpirationChecker(); } public boolean placeBounty(Player placer, Player target, double amount, CurrencyType currency) { if (placer.getUniqueId().equals(target.getUniqueId())) { return false; } if (amount < plugin.cfg().getBountyMinimum() || amount > plugin.cfg().getBountyMaximum()) { return false; } if (!plugin.getEconomyManager().hasBalance(placer.getUniqueId(), currency, amount)) { return false; } plugin.getEconomyManager().removeBalance(placer.getUniqueId(), currency, amount); Bounty bounty = new Bounty( target.getUniqueId(), placer.getUniqueId(), amount, currency, System.currentTimeMillis(), System.currentTimeMillis() + (7L * 24 * 60 * 60 * 1000) ); activeBounties.computeIfAbsent(target.getUniqueId(), k -> new ArrayList<>()).add(bounty); saveBounty(bounty); return true; } public void claimBounty(Player killer, Player victim) { List bounties = activeBounties.get(victim.getUniqueId()); if (bounties == null || bounties.isEmpty()) return; double totalReward = 0; CurrencyType currency = CurrencyType.COINS; for (Bounty bounty : new ArrayList<>(bounties)) { totalReward += bounty.getAmount(); currency = bounty.getCurrency(); bounties.remove(bounty); deleteBounty(bounty); } if (totalReward > 0) { plugin.getEconomyManager().addBalance(killer.getUniqueId(), currency, totalReward); Map placeholders = new HashMap<>(); placeholders.put("amount", String.valueOf(totalReward)); placeholders.put("player", victim.getName()); plugin.msg().send(killer, "bounty.claimed", placeholders); } } public List getBounties(UUID target) { return activeBounties.getOrDefault(target, new ArrayList<>()); } public double getTotalBounty(UUID target) { return getBounties(target).stream().mapToDouble(Bounty::getAmount).sum(); } private void loadBounties() { String sql = "SELECT * FROM bounties WHERE expires_at > ?"; try (Connection conn = plugin.getDatabaseManager().getConnection(); PreparedStatement stmt = conn.prepareStatement(sql)) { stmt.setLong(1, System.currentTimeMillis()); ResultSet rs = stmt.executeQuery(); while (rs.next()) { UUID target = UUID.fromString(rs.getString("target")); UUID placer = UUID.fromString(rs.getString("placer")); double amount = rs.getDouble("amount"); CurrencyType currency = CurrencyType.valueOf(rs.getString("currency")); long placedAt = rs.getLong("placed_at"); long expiresAt = rs.getLong("expires_at"); Bounty bounty = new Bounty(target, placer, amount, currency, placedAt, expiresAt); activeBounties.computeIfAbsent(target, k -> new ArrayList<>()).add(bounty); } } catch (SQLException e) { plugin.getLogger().severe("Failed to load bounties: " + e.getMessage()); } } private void saveBounty(Bounty bounty) { String sql = "INSERT INTO bounties (target, placer, amount, currency, placed_at, expires_at) VALUES (?, ?, ?, ?, ?, ?)"; plugin.getDatabaseManager().executeAsync(sql, bounty.getTarget().toString(), bounty.getPlacer().toString(), bounty.getAmount(), bounty.getCurrency().name(), bounty.getPlacedAt(), bounty.getExpiresAt() ); } private void deleteBounty(Bounty bounty) { String sql = "DELETE FROM bounties WHERE target = ? AND placer = ? AND placed_at = ?"; plugin.getDatabaseManager().executeAsync(sql, bounty.getTarget().toString(), bounty.getPlacer().toString(), bounty.getPlacedAt() ); } private void startExpirationChecker() { Bukkit.getScheduler().runTaskTimerAsynchronously(plugin, () -> { long now = System.currentTimeMillis(); activeBounties.values().forEach(bounties -> bounties.removeIf(bounty -> { if (bounty.isExpired(now)) { deleteBounty(bounty); return true; } return false; }) ); }, 20L * 60, 20L * 60); } }