package net.themikishou.zcore.managers;

import java.io.File;
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 java.util.UUID;

import org.bukkit.Bukkit;
import org.bukkit.event.Listener;

import net.themikishou.zcore.ZCore;
import net.themikishou.zcore.basic.Executor;
import net.themikishou.zcore.basic.User;
import net.themikishou.zcore.basic.Warp;
import net.themikishou.zcore.database.MySQL;
import net.themikishou.zcore.listeners.PlayerChatListener;
import net.themikishou.zcore.listeners.PlayerJoinListener;
import net.themikishou.zcore.listeners.PlayerMoveListener;
import net.themikishou.zcore.utils.UserUtils;

public class RegisterManager {

	public static List<Listener> listeners = new ArrayList<Listener>();
	public static MySQL mysql;
	public static Connection conn;
	public static int task;

	public static void registerListeners() {
		Bukkit.getServer().getPluginManager().registerEvents(new PlayerJoinListener(), ZCore.getInstance());
		Bukkit.getServer().getPluginManager().registerEvents(new PlayerChatListener(), ZCore.getInstance());
		Bukkit.getServer().getPluginManager().registerEvents(new PlayerMoveListener(), ZCore.getInstance());
		listeners.add(new PlayerJoinListener());
		listeners.add(new PlayerChatListener());
	}

	public static void register() {
		registerListeners();
		registerMySQL();
		registerWarps();
		registerFiles();
		registerCommands();
		registerItems();
		registerBosses();
	}

	public static void registerMySQL() {
		checkTable();
	}

	public static void loadMySQL() {
		mysql = new MySQL(ZCore.getInstance());
	}

	public static void registerWarps() {
		Warp.getInstance().start();
	}

	public static void registerFiles() {
		File f = new File(ZCore.getInstance().getDataFolder(), File.separator);
		if(!f.exists()) f.mkdir();
		else return;
	}

	public static void registerCommands() {
		Executor.register();
	}


	public static void registerItems() {

	}

	public static void registerFloors() {
		LocationManager.load();
	}

	public static void registerBosses() {

	}

	public static void checkTable(){
		openConnection();
		StringBuilder sb = new StringBuilder();
		sb.append("create table if not exists users(");
		sb.append("uuid varchar(100) not null,");
		sb.append("name varchar(50) not null,");
		sb.append("kills int not null,");
		sb.append("deaths int not null,");
		sb.append("recs int not null,");
		sb.append("remainingrecs int not null,");
		sb.append("badges int not null,");
		sb.append("money int not null,");
		sb.append("apples int not null,");
		sb.append("stone int not null,");
		sb.append("level int not null,");
		sb.append("donatecoins int not null,");
		sb.append("points int not null,");
		sb.append("god tinyint(1) not null,");
		sb.append("para tinyint(1) not null,");
		sb.append("noblesse tinyint(1) not null,");
		sb.append("msg tinyint(1) not null,");
		sb.append("vipchat tinyint(1) not null,");
		sb.append("privatemsg tinyint(1) not null,");
		sb.append("firstLogin varchar(50) not null,");
		sb.append("lastLogin varchar(50) not null,");
		sb.append("firstIp varchar(50) not null,");
		sb.append("lastIp varchar(50) not null,");
		sb.append("primary key(uuid));");
		try {
			conn.createStatement().executeUpdate(sb.toString());
		} catch (SQLException e) {
			e.printStackTrace();
		}
	    closeConnection();
	}

	public static void loadData() throws SQLException{
		openConnection();
		int i = 0;
		ResultSet rs = conn.createStatement().executeQuery("SELECT * FROM `users`");
		while(rs.next()){
			User u = User.get(UUID.fromString(rs.getString("uuid")));
			u.setKills(rs.getInt("kills"));
			u.setDeaths(rs.getInt("deaths"));
			u.setRecs(rs.getInt("recs"));
			u.setRemainingRecs(rs.getInt("remainingrecs"));
			u.setBadges(rs.getInt("badges"));
			u.setMoney(rs.getInt("money"));
			u.setApples(rs.getInt("apples"));
			u.setStone(rs.getInt("stone"));
			u.setLevel(rs.getInt("level"));
			u.setDonateCoins(rs.getInt("donatecoins"));
			u.setPoints(rs.getInt("points"));
			u.setFirstIP(rs.getString("firstIp"));
			u.setLastIP(rs.getString("lastIp"));
			u.setGod(rs.getBoolean("god"));
			u.setName(rs.getString("name"));
			u.setNoblessed(rs.getBoolean("noblesse"));
			u.setParalyzed(rs.getBoolean("para"));
			u.setFirstLogin(rs.getString("firstLogin"));
			u.setLastLogin(rs.getString("lastLogin"));
			u.setWelcomeMessage(rs.getBoolean("msg"));
			u.setPrivateMessage(rs.getBoolean("privatemsg"));
			u.setVipChat(rs.getBoolean("vipchat"));
			i++;
		}
		Bukkit.getConsoleSender().sendMessage("§a§lLoaded §6§l" + i + " §a§lusers");
		closeConnection();
	}

	public static void saveData() throws SQLException{
		openConnection();
		int i = 0;
		for(User u : UserUtils.getUsers()){
			StringBuilder sb = new StringBuilder();
			sb.append("INSERT INTO users (uuid, name, kills, deaths, recs, remainingrecs, badges, money, apples, stone, level, donatecoins, points, god, para, noblesse, msg, vipchat, privatemsg, firstLogin, lastLogin, firstIp, lastIp) VALUES (");
			sb.append("'" + u.getUUID() +"',");
			sb.append("'" + u.getName() +"',");
			sb.append("'" + u.getKills() +"',");
			sb.append("'" + u.getDeaths() +"',");
			sb.append("'" + u.getRecs() +"',");
			sb.append("'" + u.getRemainingRecs() +"',");
			sb.append("'" + u.getBadges() +"',");
			sb.append("'" + u.getMoney() +"',");
			sb.append("'" + u.getApples() +"',");
			sb.append("'" + u.getStone() +"',");
			sb.append("'" + u.getLevel() +"',");
			sb.append("'" + u.getDonateCoins() +"',");
			sb.append("'" + u.getPoints() +"',");
			sb.append("'" + (u.isGod() ? 1 : 0) +"',");
			sb.append("'" + (u.isParalyzed() ? 1 : 0) +"',");
			sb.append("'" + (u.isNoblessed() ? 1 : 0) +"',");
			sb.append("'" + (u.isWelcomeMessage() ? 1 : 0) +"',");
			sb.append("'" + (u.toggledVipChat() ? 1 : 0) +"',");
			sb.append("'" + (u.isPrivateMessage() ? 1 : 0) +"',");
			sb.append("'" + u.getFirstLogin() + "',");
			sb.append("'" + u.getLastLogin() + "',");
			sb.append("'" + u.getFirstIP() + "',");
			sb.append("'" + u.getLastIP() + "'");
			sb.append(") ON DUPLICATE KEY UPDATE ");
			sb.append("name='" + u.getName() +"',");
			sb.append("kills='" + u.getKills() +"',");
			sb.append("deaths='" + u.getDeaths() +"',");
			sb.append("recs='" + u.getRecs() +"',");
			sb.append("remainingrecs='" + u.getRemainingRecs() +"',");
			sb.append("badges='" + u.getBadges() +"',");
			sb.append("money='" + u.getMoney() +"',");
			sb.append("apples='" + u.getApples() +"',");
			sb.append("stone='" + u.getStone() +"',");
			sb.append("level='" + u.getLevel() +"',");
			sb.append("donatecoins='" + u.getDonateCoins() +"',");
			sb.append("points='" + u.getPoints() +"',");
			sb.append("god='" + (u.isGod() ? 1 : 0) +"',");
			sb.append("para='" + (u.isParalyzed() ? 1 : 0) +"',");
			sb.append("noblesse='" + (u.isNoblessed() ? 1 : 0) +"',");
			sb.append("msg='" + (u.isWelcomeMessage() ? 1 : 0) +"',");
			sb.append("vipchat='" + (u.toggledVipChat() ? 1 : 0) +"',");
			sb.append("privatemsg='" + (u.isWelcomeMessage() ? 1 : 0) +"',");
			sb.append("firstLogin='" + u.getFirstLogin() +"',");
			sb.append("lastLogin='" + u.getLastLogin() +"',");
			sb.append("firstIp='" + u.getFirstIP() + "',");
			sb.append("lastIp='" + u.getLastIP() + "';");
			conn.createStatement().executeUpdate(sb.toString());
			i++;
		}
		Bukkit.getConsoleSender().sendMessage("§a§lSaved §6§l" + i + " §a§lusers");
		closeConnection();
	}

	public static void openConnection(){
		if(!isConnected()){
			try{
				DriverManager.getConnection("jdbc:mysql://localhost:3306/youtube?user=root&password=L3gol4s21");
			} catch(SQLException e){
				e.printStackTrace();
			}
		}
	}

	public static void closeConnection(){
		if(isConnected()){
			try{
				conn.close();
			} catch(SQLException e){
				e.printStackTrace();
			}

		}
	}
		public static boolean isConnected() {
			try{
				if(conn == null) return false;
				if(conn.isClosed()) return false;
			} catch(SQLException e){
				e.printStackTrace();
			}
			return true;
		}

}