package main;

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

import org.bukkit.Bukkit;
import org.bukkit.command.Command;
import org.bukkit.command.CommandSender;
import org.bukkit.entity.Player;
import org.bukkit.plugin.java.JavaPlugin;

import com.mysql.jdbc.PreparedStatement;


//import comandos.Registrar;

public class Main extends JavaPlugin{

	public static Main pl;
	String host = getConfig().getString("MySQL.Host");
	String database = getConfig().getString("MySQL.DB");
	String user = getConfig().getString("MySQL.User");
	String pass = getConfig().getString("MySQL.Pass");
	private static DB db=null;


	public boolean hasPlayer(String player){
	    try{
	        Class.forName("com.mysql.jdbc.Driver");
	        String sql = "SELECT * FROM `ulogin_user` WHERE `nome`='" + player + "';";
	        ResultSet rs = db.query(sql);
	        while(rs.next()){
	            return rs.getString("player").equalsIgnoreCase(player);
	        }
	        return false;
	    }catch(Exception e){
	        e.printStackTrace();
	    }
	    return false;
	}

	public void onEnable() {
		saveDefaultConfig();
		//getCommand("registrar").setExecutor(new Registrar());
		//getCommand("register").setExecutor(new Registrar());
		db=DB.load(host, database, user, pass);
		db.update("CREATE TABLE IF NOT EXISTS `ulogin_user` (`nome` varchar(25) not null,`ip` varchar(60) not null,`senha` varchar(60) not null);");
		pl = this;
	Bukkit.getServer().getConsoleSender().sendMessage("§6-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-");
	Bukkit.getServer().getConsoleSender().sendMessage("§b[uLogin] §aIniciando plugin...");
	Bukkit.getServer().getConsoleSender().sendMessage("§cCriado por Ultra_PvP");
	Bukkit.getServer().getConsoleSender().sendMessage("§aObrigado por usar meu(s) plugin(s)!");
	Bukkit.getServer().getConsoleSender().sendMessage("§6-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-");
	}
	public void onDisable() {
		Bukkit.getServer().getConsoleSender().sendMessage("§6-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-");
		Bukkit.getServer().getConsoleSender().sendMessage("§b[uLogin] §aDesativando plugin...");
		Bukkit.getServer().getConsoleSender().sendMessage("§cCriado por Ultra_PvP");
		Bukkit.getServer().getConsoleSender().sendMessage("§aObrigado por usar meu(s) plugin(s)!");
		Bukkit.getServer().getConsoleSender().sendMessage("§6-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-");
	}
	public boolean onCommand(CommandSender sender, Command cmd, String label, String[] args) {
				Player p = (Player)sender;
		if (!(sender instanceof Player)) {
			p.sendMessage("§cUse este comando in-game.");
			return true;
		}
		if (cmd.getName().equalsIgnoreCase("registrar") || cmd.getName().equalsIgnoreCase("register")) {
			if (!p.hasPermission(Main.pl.getConfig().getString("Permissao_Registrar"))) {
				p.sendMessage(Main.pl.getConfig().getString("Registrar_Sem_Permissao").replace("&", "§"));
				return true;
			}
			if (args.length == 0) {
				p.sendMessage(Main.pl.getConfig().getString("Registrar_Use").replace("&", "§"));
				return true;
			}

			if (checkPlayer(p.getName())) {
				p.sendMessage("§cEssa conta ja existe.");
				return true;
			}else{
				db.update("INSERT INTO `ulogin_user`(`nome`, `ip`, `senha`) VALUES ('" + p.getName() + "','" + p.getAddress().getHostName() +"','" +  args[0] + "')");
				p.sendMessage(Main.pl.getConfig().getString("Registrar_Registrado").replace("&", "§"));
				return true;

			}

		}

		return false;
}
	public boolean checkPlayer(String uuid) {
        if (!Main.db.isConnected()) {
            return false;
        }

        int count = 0;
        PreparedStatement preparedStatement = null;
        ResultSet resultSet = null;

        try {
            StringBuilder queryBuilder = new StringBuilder();
            queryBuilder.append("SELECT `nome`, `ip`, `senha` ");
            queryBuilder.append("FROM `ulogin_user` ");
            queryBuilder.append("WHERE `nome` = 'Ultra_PvP'");
            queryBuilder.append("LIMIT 1;");

            preparedStatement = (PreparedStatement) Main.db.getConnection().prepareStatement(queryBuilder.toString());
            preparedStatement.setString(1, uuid);
            resultSet = preparedStatement.executeQuery();

            if (resultSet.next()) {
                count = resultSet.getInt(1);
            }

        } catch (final SQLException sqlException) {
            sqlException.printStackTrace();

        } finally {
            if (resultSet != null) {
                try {
                    resultSet.close();
                } catch (final SQLException ignored) {
                }
            }

            if (preparedStatement != null) {
                try {
                    preparedStatement.close();
                } catch (final SQLException ignored) {
                }
            }
        }

        return count > 0;
    }

}