package de.hannezhd.citybuildsystem.Economy;

import de.hannezhd.citybuildsystem.Citybuild_system;
import de.hannezhd.citybuildsystem.util.MYSQLManager;
import org.bukkit.Bukkit;
import org.bukkit.command.Command;
import org.bukkit.command.CommandExecutor;
import org.bukkit.command.CommandSender;
import org.bukkit.configuration.file.YamlConfiguration;
import org.bukkit.entity.Player;
import org.bukkit.plugin.Plugin;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Locale;

public class Risecoins2 implements CommandExecutor {
    private MYSQLManager mysqlManager;
    public Risecoins2(Plugin plugin) {
        // Initialize the MYSQLManager and open the connection
        this.mysqlManager = new MYSQLManager(plugin.getDataFolder());
        mysqlManager.connect();
    }
    public boolean onCommand(CommandSender sender, Command command, String label, String[] args) {
        if (sender instanceof Player) {
            Player player = (Player) sender;
            if (args.length > 0) {
                if (args.length == 1) {
                    player.sendMessage(Citybuild_system.prefix + "§cBenutze: /money <set | add | remove> <name> <anzahl>");
                    return true;
                }
                Player selectedPlayer = Bukkit.getPlayer(args[1]);

                if (sender != null) {
                    YamlConfiguration cfg;
                    double moneyremove;
                    if (args[0].equalsIgnoreCase("set")) {
                        if (player.hasPermission("money.set")) {
                            if (args.length == 3) {
                                double moneySet = Double.parseDouble(args[2]);
                                if (moneySet < 0) {
                                    moneySet = 0;
                                }

                                updateBalance(selectedPlayer.getName(), moneySet);

                                String formattedMoney = String.format(Locale.ENGLISH, "%,.2f", moneySet);
                                player.sendMessage(Citybuild_system.prefix + "§aDu hast den Kontostand von §6" + selectedPlayer.getName() + " §aauf §6" + formattedMoney + " §agesetzt");
                            } else {
                                player.sendMessage(Citybuild_system.prefix + "§cBenutze /money set <name> <Anzahl>");
                            }
                        } else {
                            player.sendMessage(Citybuild_system.prefix + "§cDazu hast du keine Rechte");
                        }
                    }
                }
            }
        }
        return false;
    }
    private void updateBalance(String playerName, double balance) {
        try (Connection connection = mysqlManager.getConnection();
             PreparedStatement preparedStatement = connection.prepareStatement(
                     "INSERT INTO player_accounts (player_name, balance) VALUES (?, ?) " +
                             "ON DUPLICATE KEY UPDATE balance = ?"
             )
        ) {
            preparedStatement.setString(1, playerName);
            preparedStatement.setDouble(2, balance);
            preparedStatement.setDouble(3, balance);
            preparedStatement.executeUpdate();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}