package de.mlh1100.Bans;

import org.bukkit.Bukkit;

import java.sql.*;
import java.util.UUID;

public class MySQL {

     public static MySQL mysql;

    private String host = Bans.cfg.getString("MySQL.Host");
    private int port = Bans.cfg.getInt("MySQL.Port");
    private String database = Bans.cfg.getString("MySQL.Database");
    private String username = Bans.cfg.getString("MySQL.Username");
    private String password = Bans.cfg.getString("MySQL.Password");
    //l36Y2jMSb3ideCWG


    private boolean isConnected = false;

    private Connection con;

    void connect() {



        if(!isConnected) {
            try {


                Class.forName("com.mysql.jdbc.Driver");
                con = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/Bans?autoReconnect=true", username, password);
                createTableIfNotExists();
                Bukkit.getConsoleSender().sendMessage("§7[§bMySQL§7] §aVerbindung hergestellt");
                isConnected = true;
            } catch (SQLException ex) {
                System.out.println("§7[§bMySQL§7] §4Verbindung fehlgeschlagen! Fehler: " + ex.getMessage());
                ex.printStackTrace();
                isConnected = false;
            } catch (ClassNotFoundException e) {
                e.printStackTrace();
            }
        }

    }

    void disconnect(){
        if(isConnected) {
            try {

                if (con != null) {
                    con.close();
                    isConnected = false;
                    System.out.println("§7[§bMySQL§7] §aVerbingung wurde erflogreich geschlossen");
                }

            } catch (SQLException ex) {

                System.out.println("§7[§bMySQL§7] §4Verbingung konnte nicht werden geschlossen! Fehler: " + ex.getMessage());
                ex.printStackTrace();

            }
        }
    }

    private ResultSet query(String qry) {

        ResultSet rs = null;
        if(isConnected) {
            try {

                Statement st = con.createStatement();
                rs = st.executeQuery(qry);

            } catch (SQLException ex) {

                ex.printStackTrace();
                System.err.println(ex);


            }
        }
        return rs;
    }

    private void createTableIfNotExists() {
        if(isConnected) {
            try {
                PreparedStatement ps = con.prepareStatement("CREATE TABLE IF NOT EXISTS Bans(victim varchar(36), team varchar(36), reason TEXT, end varchar(100), PRIMARY KEY(victim))");
                ps.executeUpdate();
                ps.close();
            } catch (SQLException ex) {
                ex.printStackTrace();
            }
            try {
                PreparedStatement ps = con.prepareStatement("CREATE TABLE IF NOT EXISTS Mutes(victim varchar(36), team varchar(36), reason TEXT, end varchar(100), PRIMARY KEY(victim))");
                ps.executeUpdate();
                ps.close();
            } catch (SQLException ex) {
                ex.printStackTrace();
            }
            try {
                PreparedStatement ps = con.prepareStatement("CREATE TABLE IF NOT EXISTS Warns(victim varchar(36), team varchar(36), reason TEXT, end varchar(100), PRIMARY KEY(victim))");
                ps.executeUpdate();
                ps.close();
            } catch (SQLException ex) {
                ex.printStackTrace();
            }
            try {
                PreparedStatement ps = con.prepareStatement("CREATE TABLE IF NOT EXISTS Points(victim varchar(36), points varchar(100), PRIMARY KEY(victim))");
                ps.executeUpdate();
                ps.close();
            } catch(SQLException ex) {
                ex.printStackTrace();
            }
        }

    }

    public void addBan(UUID victim, UUID team, String reason, long secunds) {

        long current = System.currentTimeMillis();
        long milis = current * 1000;
        long end = secunds+milis;

        try {
            PreparedStatement ps = con.prepareStatement("INSERT INTO Bans VALUES (" + victim + "," + team + "," + reason + "," + end + ")");
            ps.executeUpdate();
            ps.close();
        } catch (SQLException ex) {
            ex.printStackTrace();
        }

    }

    public void addMute(UUID victim, UUID team, String reason, int secunds) {

        long current = System.currentTimeMillis();
        long milis = current * 1000;
        long end = secunds+milis;

        try {
            PreparedStatement ps = con.prepareStatement("INSERT INTO Mutes VALUES (" + victim + "," + team + "," + reason + "," + end + ")");
            ps.executeUpdate();
            ps.close();
        } catch (SQLException ex) {
            ex.printStackTrace();
        }

    }

    public void addWarn(UUID victim, UUID team, String reason) {
        try {
            PreparedStatement ps = con.prepareStatement("INSERT INTO Warns VALUES (" + victim + "," + team + "," + reason + ",604800)");
            ps.executeUpdate();
            ps.close();
        } catch (SQLException ex) {
            ex.printStackTrace();
        }

    }

    public void addPoint(UUID victim, int points) {
        int pointsBefore;
        ResultSet rs = query("SELECT points FROM Points WHERE victim =" + victim);
        pointsBefore = Integer.valueOf(rs.toString());
        int pointsAfter = points + pointsBefore;

        try {
            PreparedStatement ps = con.prepareStatement("UPDATE Points SET points =" + pointsAfter + "WHERE victim =" + victim);
            ps.executeUpdate();
            ps.close();
        } catch(SQLException ex) {
            ex.printStackTrace();
        }

    }

    public boolean isBanned(UUID uuid) {

        ResultSet rs = query("SELECT victim FROM Bans WHERE victim = " + uuid);
        try {
            if((getEndBan(uuid) - System.currentTimeMillis()) <= 0) {
                return false;
            }
            return rs.next();

        } catch (SQLException ex) {
            ex.printStackTrace();
        }
        return false;

    }

    public boolean isMuted(UUID uuid) {

        ResultSet rs = query("SELECT victim FROM Mutes WHERE victim = " + uuid);
        try {
            if((getEndMute(uuid) - System.currentTimeMillis()) <= 0) {
                return false;
            }
            return rs.next();
        } catch (SQLException ex) {
            ex.printStackTrace();
        }
        return false;

    }

    public String getReasonBan(UUID uuid) {

        ResultSet rs = query("SELECT reason FROM Bans WHERE victim = " + uuid);
        return rs.toString();

    }

    public long getEndBan(UUID uuid) {

        ResultSet rs = query("SELECT end FROM Bans WHERE victim = " + uuid);
        return Long.valueOf(rs.toString());

    }

    public String getDurationBan(UUID uuid) {

        long end = getEndBan(uuid);
        if(end == -1) {
            return "§4Permanent";
        }
        int secunds = 0;
        int minutes = 0;
        int hours = 0;
        int days = 0;

        while(end >= 60) {
            minutes++;
            secunds -= 60;
        }
        while(minutes >= 60) {
            hours++;
            minutes -= 60;
        }
        while(hours >= 24) {
            days++;
            hours -= 24;
        }

        return "§c" + days + " §eTag(e), §c" + hours + " §eStunde(n), §c" + minutes + " §eMinute(n), §c" + secunds + " §eSekunde(n)";

    }

    public String getTeamBan(UUID uuid) {

        ResultSet rs = query("SELECT team FROM Bans WHERE victim = " + uuid);
        return rs.toString();

    }

    public boolean hacksBefore(UUID uuid) {

        ResultSet rs = query("SELECT reason FROM Bans WHERE victim = " + uuid);
        try {
            return rs.next();
        } catch (SQLException ex) {
            ex.printStackTrace();
        }

        return false;
    }

    public String getResonMute(UUID uuid) {

        ResultSet rs = query("SELECT reason FROM Mutes WHERE victim = " + uuid);
        return rs.toString();

    }

    public String getStartMute(UUID uuid) {

        ResultSet rs = query("SELECT start FROM Mutes WHERE victim = " + uuid);
        return rs.toString();

    }

    public long getEndMute(UUID uuid) {

        ResultSet rs = query("SELECT end FROM Mutes WHERE victim = " + uuid);
        return Long.valueOf(rs.toString());

    }

    public String getDurationMute(UUID uuid) {

        long current = System.currentTimeMillis();
        long end = getEndMute(uuid);
        if(end == -1) {
            return "§4Permanent";
        }
        long time = end - current;
        int secunds = 0;
        int minutes = 0;
        int hours = 0;
        int days = 0;

        while(time >= 1000) {
            secunds++;
            time -= 1000;
        }
        while(secunds >= 60) {
            minutes++;
            secunds -= 60;
        }
        while(minutes >= 60) {
            hours++;
            minutes -= 60;
        }
        while(hours >= 24) {
            days++;
            hours -= 24;
        }

        return "§c" + days + " §eTag(e), §c" + hours + " §eStunden, §c" + minutes + " §eMinuten, §c" + secunds + " §eSekunden";
    }

    public String getTeamMute(UUID uuid) {

        ResultSet rs = query("SELECT team FROM Mutes WHERE victim = " + uuid);
        return rs.toString();

    }

    public int getPoints(UUID uuid) {

        ResultSet rs = query("SELECT points FROM Points WHERE victim =" + uuid);
        return Integer.valueOf(rs.toString());

    }

}