package fr.zeingraphics.icecore.database.icedatabase;

import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

import org.bukkit.entity.Player;

import fr.zeingraphics.icecore.IceCore;
import fr.zeingraphics.icecore.database.Database;
import fr.zeingraphics.icecore.database.icedatabase.rank.Rank;

/**
 * Created by zieba on 23/06/2017.
 */
public class IceDatabase extends Database {

    public IceDatabase() {
        super(IceCore.getInstance(), "jdbc:mysql://", "localhost", "iceserver", "root", "uYk895Hlz2");
    }

    public void createAccount(Player p) {
        if (!hasAccount(p)) {
            try {
                PreparedStatement statement = getConnection().prepareStatement("INSERT INTO players(uuid,pseudo,money,rank,level) VALUES (?,?,?,?,?)");
                statement.setString(1, p.getUniqueId().toString());
                statement.setString(2, p.getName());
                statement.setInt(3, 275);
                statement.setInt(4, Rank.PLAYER.getPower());
                statement.setDouble(5, 0);
                statement.execute();
                statement.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        } else {
            return;
        }
    }

    public boolean hasAccount(Player p){
        try {
            PreparedStatement statement = getConnection().prepareStatement("SELECT uuid from players WHERE uuid = ?");
            statement.setString(1, p.getUniqueId().toString());
            ResultSet result = statement.executeQuery();
            boolean hasAccount = result.next();
            statement.close();

            return hasAccount;
        } catch(SQLException e){
            e.printStackTrace();
        }

        return false;
    }

    public void setRank(Player rankedPlayer, Rank rankType){
        try {
            PreparedStatement statement = getConnection().prepareStatement("UPDATE players SET rank = ? WHERE uuid = ?");
            statement.setInt(1, rankType.getPower());
            statement.setString(2, rankedPlayer.getUniqueId().toString());
            statement.executeUpdate();
            statement.close();

        } catch(SQLException e){
            e.printStackTrace();
        }
    }

    public Rank getRank(Player rankedPlayer){
        try {
            PreparedStatement statement = getConnection().prepareStatement("SELECT rank FROM players WHERE uuid = ?");
            statement.setString(1, rankedPlayer.getUniqueId().toString());

            int rankPower = 0;
            ResultSet resultSet = statement.executeQuery();

            while(resultSet.next()){
                rankPower = resultSet.getInt("rank");
            }

            statement.close();

            return Rank.powerToRank(rankPower);
        } catch(SQLException e){
            e.printStackTrace();
        }

        return Rank.PLAYER;
    }

    public boolean hasRank(Player rankedPlayer, Rank rankType){
        if(getRank(rankedPlayer) == rankType){
            return true;
        } else {
            return false;
        }
    }

    public int getMoney(Player moneyPlayer){
        try {
            PreparedStatement statement = getConnection().prepareStatement("SELECT money FROM players WHERE uuid = ?");
            statement.setString(1, moneyPlayer.getUniqueId().toString());

            int money = 0;
            ResultSet resultSet = statement.executeQuery();

            while(resultSet.next()){
                money = resultSet.getInt("money");
            }

            statement.close();

            return money;
        } catch(SQLException e){
            e.printStackTrace();
        }

        return 0;
    }

    public void setMoney(Player moneyPlayer, int newMoney){
        try {
            PreparedStatement statement = getConnection().prepareStatement("UPDATE players SET money = ? WHERE uuid = ?");
            statement.setInt(1, newMoney);
            statement.setString(2, moneyPlayer.getUniqueId().toString());
            statement.executeUpdate();
            statement.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    public void addMoney(Player moneyPlayer, int addedMoney){
        int balance = getMoney(moneyPlayer);
        int newBalance = balance + addedMoney;

        try {
            PreparedStatement statement = getConnection().prepareStatement("UPDATE players SET money = ? WHERE uuid = ?");
            statement.setInt(1, newBalance);
            statement.setString(2, moneyPlayer.getUniqueId().toString());
            statement.executeUpdate();
            statement.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    public void removeMoney(Player moneyPlayer, int removedMoney){
        int balance = getMoney(moneyPlayer);
        int newBalance = balance - removedMoney;

        if (newBalance <= 0) {
            return;
        }

        try {
            PreparedStatement statement = getConnection().prepareStatement("UPDATE players SET money = ? WHERE uuid = ?");
            statement.setInt(1, newBalance);
            statement.setString(2, moneyPlayer.getUniqueId().toString());
            statement.executeUpdate();
            statement.close();

        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    public boolean hasMoney(Player moneyPlayer, int neededMoney){
        int nowBalance = getMoney(moneyPlayer);

        if(nowBalance == neededMoney || nowBalance > neededMoney){
            return true;
        } else {
            return false;
        }
    }

    public double getLevel(Player p){
        try {
            PreparedStatement statement = getConnection().prepareStatement("SELECT level FROM players WHERE uuid = ?");
            statement.setString(1, p.getUniqueId().toString());

            int level = 0;
            ResultSet resultSet = statement.executeQuery();

            while(resultSet.next()){
                level = resultSet.getInt("level");
            }

            statement.close();

            return level;
        } catch(SQLException e){
            e.printStackTrace();
        }

        return 0;
    }

    public void addLevel(Player p, double level){
        double levels = getLevel(p);
        double newLevel = levels + level;

        try {
            PreparedStatement statement = getConnection().prepareStatement("UPDATE players SET level = ? WHERE uuid = ?");
            statement.setDouble(1, newLevel);
            statement.setString(2, p.getUniqueId().toString());
            statement.executeUpdate();
            statement.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    public boolean hasLevel(Player p, int level){
        double nowLevel = getLevel(p);

        if(nowLevel == level || nowLevel > level){
            return true;
        } else {
            return false;
        }
    }

}