package sk.YMasterSk.VIP;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.Calendar;
import java.util.Date;

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

public class Main extends JavaPlugin {

	static String JDBCuser;
	static String JDBCpass;
	static String JDBCurl;
	static Connection connection;
	static Statement st;
	private static final DateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

	public void onEnable(){

		getConfig().options().copyDefaults(true);
		saveConfig();

		JDBCuser = getConfig().getString("user");
		JDBCpass = getConfig().getString("password");
		JDBCurl = getConfig().getString("uri");

		try {

			connection = DriverManager.getConnection(JDBCurl, JDBCuser, JDBCpass);

			Bukkit.getConsoleSender().sendMessage("§8[§cVIP§8] §aVIP has been connected to MySQL Server!");

			st = connection.createStatement();
			st.execute("CREATE TABLE IF NOT EXISTS `vip` (`steamid` VARCHAR(20), `timestamp` VARCHAR(40), `enddate` VARCHAR(40));");

		} catch (SQLException e){

			Bukkit.getPluginManager().disablePlugin(this);

			Bukkit.getConsoleSender().sendMessage("§8[§cVIP§8] §cCouldn't connect to MySQL database, disabling plugin.");
    		Bukkit.getConsoleSender().sendMessage("§8[§cVIP§8] §7SQLException: §a" + e.getMessage());
    		Bukkit.getConsoleSender().sendMessage("§8[§cVIP§8] §7SQLState: §a" + e.getSQLState());

		}

	}

	public void onDisable(){

		try {

			if(connection != null && connection.isClosed()){

				connection.close();

			}

		} catch (Exception e){

			e.printStackTrace();

		}

	}

	public void setVIP(String steamid){

		try {

			Date cd = new Date();
			Calendar c = Calendar.getInstance();
			c.setTime(cd);

			c.add(Calendar.DATE, 31);
			boolean vyber;
			vyber = st.execute("SELECT enddate FROM `vip` WHERE steamid ='" + steamid + "' AND enddate >= '\"+df.format(cd)+\"';\");
			Date nd = c.getTime();
			if (!vyber) {
				st.execute("INSERT INTO `vip` (`playername`, `steamid`, `timestamp`, `enddate`) VALUES ('SMS', '\"" + steamid + "\"', '\"" + df.format(cd) + "\"', '\"" + df.format(nd) + "\"') ON DUPLICATE KEY UPDATE enddate=now()+INTERVAL 1 MONTH;");
			} else {
				st.execute("INSERT INTO `vip` (`playername`, `steamid`, `timestamp`, `enddate`) VALUES ('SMS', '\"" + steamid + "\"', '\"" + df.format(cd) + "\"', '\"" + df.format(nd) + "\"') ON DUPLICATE KEY UPDATE enddate=DATE_ADD('\"" + df.format(nd) + "\"', interval 1 month);");
			}

		} catch (Exception e){

			e.printStackTrace();

		}

	}

	public boolean onCommand(CommandSender sender, Command cmd, String label, String[] args){

		if(cmd.getName().equalsIgnoreCase("vipadd")){

			if(sender.hasPermission("*")){
				//
				if(args.length == 1){

					String steamid = args[0];

					setVIP(steamid);

					sender.sendMessage("§7Inserted to database, where Steam ID is: §a" + steamid);

				}else {

					sender.sendMessage("§cUsage: §7/vipadd <steamid>");

				}

			}
			//
		}
		return false;

	}

}