package de.palukku.mysqlperm.mysql;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

import org.bukkit.Bukkit;

import de.palukku.LobbySystem.System.main;

public class MySQLPerm {

    public static String username;
    public static String password;
    public static String database;
    public static String host;
    public static String port;
    public static Connection con;

    private static int MySQLSchedulerID;

    public static void connect() {
            try {
                con = DriverManager.getConnection("jdbc:mysql://" + "localhost" + ":" + "3306" + "/" + "mysqlpermissions", "root", "hyhost-98");
                Bukkit.getConsoleSender().sendMessage(main.prefix+"§aMySQL verbindung wurde aufgebaut!");
                onReconnectScheduler();
            } catch (SQLException e) {
                e.printStackTrace();
            }
    }

    private static void onReconnectScheduler()
    {
        MySQLSchedulerID = Bukkit.getScheduler().scheduleSyncRepeatingTask(main.plugin, new Runnable()
        {
            public void run()
            {
                onReconnect();
            }
        }, 20 * 60 * 60, 20 * 60 * 60);
    }

    private static void onReconnect()
    {
        if(con != null)
        {
            try
            {
                con.close();
                Bukkit.getConsoleSender().sendMessage(main.prefix+"§aMySQL verbindung wurde aufgebaut!");
                }

            catch (SQLException e)
            {
                Bukkit.getConsoleSender().sendMessage(main.prefix+"§aMySQL verbindung konnte nicht aufgebaut werden!");
                e.printStackTrace();
            }
        }

        Bukkit.getScheduler().scheduleSyncDelayedTask(main.plugin, new Runnable()
        {
            public void run()
            {
                try
                {
                    con = DriverManager.getConnection("jdbc:mysql://" + "localhost" + ":" + "3306" + "/" + "mysqlpermissions", "root", "hyhost-98");
                    Bukkit.getConsoleSender().sendMessage(main.prefix+"§aMySQL verbindung wurde aufgebaut!");
                }

                catch (SQLException e)
                {
                    Bukkit.getConsoleSender().sendMessage(main.prefix+"§aMySQL verbindung konnte nicht aufgebaut werden!");
                    e.printStackTrace();
                }
            }
        }, 1L);
    }

    public static void close() {
        if(IsConnected()) {
            try {
                con.close();
                Bukkit.getConsoleSender().sendMessage(main.prefix+"§aMySQL verbindung geschlossen!");
                if(Bukkit.getScheduler().isCurrentlyRunning(MySQLSchedulerID)){
                    Bukkit.getScheduler().cancelTask(MySQLSchedulerID);
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

    public static boolean IsConnected() {
        return con != null;
    }

    public static void createTable() {

        /*
         * Syntax; Spielername, Gruppe
         *
         */

        if(IsConnected()) {
        try {
            con.createStatement().executeUpdate("CREATE TABLE IF NOT EXISTS Players(UUID VARCHAR(100), Gruppe VARCHAR(100))");
        } catch (SQLException e) {
            e.printStackTrace();
        }
        }
    }

    public static void update(String qry) {
        if(IsConnected()) {
            try {
                con.createStatement().executeUpdate(qry);
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

    public static ResultSet getResult(String qry) {
        if(IsConnected()) {
            try {
                return con.createStatement().executeQuery(qry);
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        return null;
    }

    public static void SetUser(String playeruuid, String Group) {
        MySQLPerm.update("INSERT INTO Players (UUID, Gruppe) VALUES ('"+playeruuid+"','"+Group+"')");
    }

    public static void removePlayer(String playeruuid) {
        MySQLPerm.update("DELETE FROM Players WHERE UUID='"+playeruuid+"'");
    }

    public static String getRank(String playeruuid) {
        ResultSet rs = MySQLPerm.getResult("SELECT * FROM Players WHERE UUID='"+playeruuid+"'");
        try {
            while(rs.next()) {
                return rs.getString("Gruppe");
            }
        } catch(SQLException e) {
            e.printStackTrace();
        }
        return "spieler";
    }
    public static void SetUserName(String playername, String Group) {
        playername = UUIDFetcher.getUUID(playername).toString();
        MySQLPerm.update("INSERT INTO Players (UUID, Gruppe) VALUES ('"+playername+"','"+Group+"')");
    }

    public static void removePlayerName(String playername) {
        playername = UUIDFetcher.getUUID(playername).toString();
        MySQLPerm.update("DELETE FROM Players WHERE UUID='"+playername+"'");
    }

    public static String getRankName(String playername) {
        playername = UUIDFetcher.getUUID(playername).toString();
        ResultSet rs = MySQLPerm.getResult("SELECT * FROM Players WHERE UUID='"+playername+"'");
        try {
            while(rs.next()) {
                return rs.getString("Gruppe");
            }
        } catch(SQLException e) {
            return "spieler";
        }
        return "spieler";
    }
    public static boolean HasRangName(String playername) {
        playername = UUIDFetcher.getUUID(playername).toString();
        ResultSet rs = MySQLPerm.getResult("SELECT * FROM Players WHERE UUID='"+playername+"'");
        try {
            return rs.next();
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return false;

    }

    public static List<String> getPlayers() {
        List<String> list = new ArrayList<String>();
        ResultSet rs = MySQLPerm.getResult("SELECT * FROM Players");
        try {
            while(rs.next()) {
                list.add(rs.getString("UUID"));
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return list;

    }


    public static boolean HasRang(String uuid) {
        ResultSet rs = MySQLPerm.getResult("SELECT * FROM Players WHERE UUID='"+uuid+"'");
        try {
            return rs.next();
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return false;

    }

    public static boolean RankPremium(String playername) {
        String rank = getRankName(playername);

        if(!(rank.equalsIgnoreCase("spieler"))) {
            return true;
        } else {
            return false;
        }
    }
    public static boolean RankYoutuber(String playername) {
        String rank = getRankName(playername);

        if(!(rank.equalsIgnoreCase("spieler") || rank.equalsIgnoreCase("premium"))) {
            return true;
        } else {
            return false;
        }
    }
    public static boolean RankBuilder(String playername) {
        String rank = getRankName(playername);

        if(!(rank.equalsIgnoreCase("spieler") || rank.equalsIgnoreCase("premium") || rank.equalsIgnoreCase("youtuber") || rank.equalsIgnoreCase("supporter"))) {
            return true;
        } else {
            return false;
        }
    }
    public static boolean RankSupporter(String playername) {
        String rank = getRankName(playername);

        if(!(rank.equalsIgnoreCase("spieler") || rank.equalsIgnoreCase("premium") || rank.equalsIgnoreCase("youtuber"))) {
            return true;
        } else {
            return false;
        }
    }
    public static boolean RankModerator(String playername) {
        String rank = getRankName(playername);

        if(!(rank.equalsIgnoreCase("spieler") || rank.equalsIgnoreCase("premium") || rank.equalsIgnoreCase("youtuber") || rank.equalsIgnoreCase("supporter") || rank.equalsIgnoreCase("builder"))) {
            return true;
        } else {
            return false;
        }
    }
    public static boolean RankDeveloper(String playername) {
        String rank = getRankName(playername);

        if(!(rank.equalsIgnoreCase("spieler") || rank.equalsIgnoreCase("premium") || rank.equalsIgnoreCase("youtuber") || rank.equalsIgnoreCase("supporter") || rank.equalsIgnoreCase("builder") || rank.equalsIgnoreCase("moderator"))) {
            return true;
        } else {
            return false;
        }
    }
    public static boolean RankAdmin(String playername) {
        String rank = getRankName(playername);

        if(rank.equalsIgnoreCase("admin")) {
            return true;
        } else {
            return false;
        }
    }
}