package me.matthew.zkits.manager.mysql;

import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.UUID;

import org.bukkit.Bukkit;

import lombok.Getter;
import me.matthew.zkits.manager.SystemManager;
import me.matthew.zkits.manager.profile.Profile;

public class MySqlManager {

    @Getter private MySql mysql;

    public MySqlManager() {
        if (SystemManager.getSettingsfile().getConfig().getBoolean("mysql.enabled") == true) {
            this.mysql = new MySql(SystemManager.getSettingsfile().getConfig().getString("mysql.host"),
                    SystemManager.getSettingsfile().getConfig().getInt("mysql.port"),
                    SystemManager.getSettingsfile().getConfig().getString("mysql.database"),
                    SystemManager.getSettingsfile().getConfig().getString("mysql.username"),
                    SystemManager.getSettingsfile().getConfig().getString("mysql.password"));
            connect();
        }
    }

    public Boolean isConnected() {
        return SystemManager.getSettingsfile().getConfig().getBoolean("mysql.enabled") && getMysql().getConnection() != null;
    }

    public void connect() {
        if (!isConnected()) {
            try {
                getMysql().setConnection(DriverManager.getConnection("jdbc:mysql://" + getMysql().getHost() + ":" + getMysql().getPort() + "/" + getMysql().getDatabase() + "?autoReconnect=true", getMysql().getUsername(), getMysql().getPassword()));
                System.out.println("MYSQL has been connected.");
                createTable();
            } catch (SQLException e) {
                System.out.println("MYSQL has not connected.");
            }
        }
    }

    public void disconnect() {
        try {
            getMysql().getConnection().close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    public void createTable() {
        if (isConnected()) {
            try {
                PreparedStatement preparedstatement = getStatement("CREATE TABLE IF NOT EXISTS users (uuid VARCHAR(255), name VARCHAR(255), balance DOUBLE, kills INT, deaths INT)");
                preparedstatement.executeUpdate();
                preparedstatement = getStatement("CREATE TABLE IF NOT EXISTS users (name VARCHAR(255), balance DOUBLE, kills INT, point INT)");
            } catch (SQLException e) {

            }
        }
    }

    public PreparedStatement getStatement(String string) {
        if (isConnected()) {
            PreparedStatement preparedstatement;
            try {
                preparedstatement = getMysql().getConnection().prepareStatement(string);
                return preparedstatement;
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        return null;
    }

    public ResultSet getResult(String string) {
        if (isConnected()) {
            PreparedStatement preparedstatement;
            ResultSet resultset;
            try {
                preparedstatement = getStatement(string);
                resultset = preparedstatement.executeQuery();
                return resultset;
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        return null;
    }

    public void createProfile(String uuid) {
        if (isConnected()) {
            try {
                PreparedStatement preparedstatement = getStatement("INSERT INTO users (uuid, name, balance, kills, deaths) VALUES ('" + uuid + "', '" + Bukkit.getServer().getOfflinePlayer(UUID.fromString(uuid)).getName() + "', '" + SystemManager.getProfilemanager().getProfile(UUID.fromString(uuid)).getBalance() + "', '" + SystemManager.getProfilemanager().getProfile(UUID.fromString(uuid)).getKills() + "', '" + SystemManager.getProfilemanager().getProfile(UUID.fromString(uuid)).getDeaths() + "')");
                preparedstatement.executeUpdate();
            } catch (SQLException e) {

            }
        }
    }

    public Boolean isRegistered(String uuid) {
        if (isConnected()) {
            try {
                PreparedStatement preparedstatement = getStatement("SELECT * FROM `users` WHERE uuid= ?");
                preparedstatement.setString(1, uuid);
                ResultSet resultset = preparedstatement.executeQuery();
                Boolean user = resultset.next();
                preparedstatement.close();
                resultset.close();
                return user;
            } catch (Exception e) {
                System.out.println("Error with registered checking...");
                return false;
            }
        }
        return false;
    }

    public void saveProfile(Profile profile) {
        if (isConnected()) {
            if (!SystemManager.getMysqlmanager().isRegistered(profile.getUuid().toString())) {
                SystemManager.getMysqlmanager().createProfile(profile.getUuid().toString());
            }
            SystemManager.getMysqlmanager().setBalance(profile.getUuid().toString(), profile.getBalance());
            SystemManager.getMysqlmanager().setKills(profile.getUuid().toString(), profile.getKills());
            SystemManager.getMysqlmanager().setDeaths(profile.getUuid().toString(), profile.getDeaths());
        }
    }

    public Double getBalance(String uuid) {
        if (isConnected()) {
            try {
                PreparedStatement preparedstatement = getStatement("SELECT * FROM `users` WHERE uuid= ?");
                preparedstatement.setString(1, uuid);
                ResultSet resultset = preparedstatement.executeQuery();
                resultset.next();
                Double balance = resultset.getDouble("balance");
                preparedstatement.close();
                resultset.close();
                return balance;
            } catch (Exception e) {
                System.out.println("Error with balance checking...");
                return null;
            }
        }
        return 0.0;
    }

    public Integer getKills(String uuid) {
        if (isConnected()) {
            try {
                PreparedStatement preparedstatement = getStatement("SELECT * FROM `users` WHERE uuid= ?");
                preparedstatement.setString(1, uuid);
                ResultSet resultset = preparedstatement.executeQuery();
                resultset.next();
                Integer kills = resultset.getInt("kills");
                preparedstatement.close();
                resultset.close();
                return kills;
            } catch (Exception e) {
                System.out.println("Error with kills checking...");
                return null;
            }
        }
        return 0;
    }

    public Integer getDeaths(String uuid) {
        if (isConnected()) {
            try {
                PreparedStatement preparedstatement = getStatement("SELECT * FROM `users` WHERE uuid= ?");
                preparedstatement.setString(1, uuid);
                ResultSet resultset = preparedstatement.executeQuery();
                resultset.next();
                Integer deaths = resultset.getInt("deaths");
                preparedstatement.close();
                resultset.close();
                return deaths;
            } catch (Exception e) {
                System.out.println("Error with deaths checking...");
                return null;
            }
        }
        return 0;
    }

    public void setBalance(String uuid, Double balance) {
        if (isConnected()) {
            try {
                PreparedStatement preparedstatement = getStatement("UPDATE users SET balance= ? WHERE uuid= ?");
                preparedstatement.setDouble(1, balance);
                preparedstatement.setString(2, uuid);
                preparedstatement.executeUpdate();
                preparedstatement.close();
            } catch (Exception e) {
                System.out.println("Error with updating balance...");
                return;
            }
        }
    }

    public void setKills(String uuid, Integer kills) {
        if (isConnected()) {
            try {
                PreparedStatement preparedstatement = getStatement("UPDATE users SET kills= ? WHERE uuid= ?");
                preparedstatement.setInt(1, kills);
                preparedstatement.setString(2, uuid);
                preparedstatement.executeUpdate();
                preparedstatement.close();
            } catch (Exception e) {
                System.out.println("Error with updating kills...");
                return;
            }
        }
    }

    public void setDeaths(String uuid, Integer deaths) {
        if (isConnected()) {
            try {
                PreparedStatement preparedstatement = getStatement("UPDATE users SET deaths= ? WHERE uuid= ?");
                preparedstatement.setInt(1, deaths);
                preparedstatement.setString(2, uuid);
                preparedstatement.executeUpdate();
                preparedstatement.close();
            } catch (Exception e) {
                System.out.println("Error with updating deaths...");
                return;
            }
        }
    }

}