package com.konicmc.plugin.economy; import com.konicmc.plugin.KonicMC; import com.konicmc.plugin.database.PlayerData; 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 EconomyManager { private final KonicMC plugin; private final Map playerDataCache; public EconomyManager(KonicMC plugin) { this.plugin = plugin; this.playerDataCache = new ConcurrentHashMap<>(); } public PlayerData getPlayerData(UUID uuid) { return playerDataCache.computeIfAbsent(uuid, this::loadPlayerData); } private PlayerData loadPlayerData(UUID uuid) { try (Connection conn = plugin.getDatabaseManager().getConnection(); PreparedStatement stmt = conn.prepareStatement( "SELECT * FROM players WHERE uuid = ?")) { stmt.setString(1, uuid.toString()); ResultSet rs = stmt.executeQuery(); if (rs.next()) { return new PlayerData( uuid, rs.getString("name"), rs.getDouble("balance"), rs.getInt("kills"), rs.getInt("deaths"), rs.getLong("playtime"), rs.getLong("last_login"), rs.getLong("last_vote"), rs.getLong("last_daily"), rs.getInt("daily_streak"), rs.getString("discord_id"), rs.getInt("team_id"), new HashMap<>() ); } } catch (SQLException e) { plugin.getLogger().severe("Failed to load player data: " + e.getMessage()); } return null; } public void savePlayerData(PlayerData data) { try (Connection conn = plugin.getDatabaseManager().getConnection(); PreparedStatement stmt = conn.prepareStatement( "INSERT OR REPLACE INTO players (uuid, name, balance, kills, deaths, playtime, last_login, last_vote, last_daily, daily_streak, discord_id, team_id) " + "VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)")) { stmt.setString(1, data.getUuid().toString()); stmt.setString(2, data.getName()); stmt.setDouble(3, data.getBalance()); stmt.setInt(4, data.getKills()); stmt.setInt(5, data.getDeaths()); stmt.setLong(6, data.getPlaytime()); stmt.setLong(7, data.getLastLogin()); stmt.setLong(8, data.getLastVote()); stmt.setLong(9, data.getLastDaily()); stmt.setInt(10, data.getDailyStreak()); stmt.setString(11, data.getDiscordId()); stmt.setInt(12, data.getTeamId()); stmt.executeUpdate(); } catch (SQLException e) { plugin.getLogger().severe("Failed to save player data: " + e.getMessage()); } } public void createPlayerData(UUID uuid, String name) { PlayerData data = new PlayerData(uuid, name); playerDataCache.put(uuid, data); savePlayerData(data); } public double getBalance(UUID uuid) { PlayerData data = getPlayerData(uuid); return data != null ? data.getBalance() : 0.0; } public void setBalance(UUID uuid, double amount) { PlayerData data = getPlayerData(uuid); if (data != null) { data.setBalance(amount); savePlayerData(data); } } public void addBalance(UUID uuid, double amount) { PlayerData data = getPlayerData(uuid); if (data != null) { data.addBalance(amount); savePlayerData(data); } } public boolean removeBalance(UUID uuid, double amount) { PlayerData data = getPlayerData(uuid); if (data != null && data.removeBalance(amount)) { savePlayerData(data); return true; } return false; } public boolean hasBalance(UUID uuid, double amount) { PlayerData data = getPlayerData(uuid); return data != null && data.hasBalance(amount); } public List> getTopBalances(int limit) { try (Connection conn = plugin.getDatabaseManager().getConnection(); PreparedStatement stmt = conn.prepareStatement( "SELECT uuid, balance FROM players ORDER BY balance DESC LIMIT ?")) { stmt.setInt(1, limit); ResultSet rs = stmt.executeQuery(); List> top = new ArrayList<>(); while (rs.next()) { UUID uuid = UUID.fromString(rs.getString("uuid")); double balance = rs.getDouble("balance"); top.add(new AbstractMap.SimpleEntry<>(uuid, balance)); } return top; } catch (SQLException e) { plugin.getLogger().severe("Failed to get top balances: " + e.getMessage()); } return new ArrayList<>(); } public void unloadPlayerData(UUID uuid) { PlayerData data = playerDataCache.remove(uuid); if (data != null) { savePlayerData(data); } } public String formatMoney(double amount) { String symbol = plugin.getConfig().getString("economy.currency-symbol", "$"); return symbol + String.format("%.2f", amount); } }