package me.zachbears27;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.bukkit.Bukkit;
import org.bukkit.Location;
import org.bukkit.command.Command;
import org.bukkit.command.CommandSender;
import org.bukkit.entity.Player;
import org.bukkit.event.EventHandler;
import org.bukkit.event.Listener;
import org.bukkit.event.entity.PlayerDeathEvent;
import org.bukkit.inventory.ItemStack;
import org.bukkit.plugin.java.JavaPlugin;
import java.sql.Statement;
import java.util.HashMap;

import me.zachbears27.MySQL;
import net.md_5.bungee.api.ChatColor;

//This Plugin Is Made For MumboCraft & It's Players & Staff.. Any misuse or re-distribution of this plugin will call for said plugin to be removed
//Plugin by A_Brave_Panda & Jamdoggy

public class DeathLocation extends JavaPlugin implements Listener {

	  HashMap<String, ItemStack[]> inventoryContents = new HashMap<String, ItemStack[]>();
	  HashMap<String, ItemStack[]> inventoryArmorContents = new HashMap<String, ItemStack[]>();

MySQL MySQLC = null;
Connection c = null;

String host = getConfig().getString("Hostname");
String port = getConfig().getString("Port");
String db = getConfig().getString("Database");
String username = getConfig().getString("Username");
String password = getConfig().getString("Password");
String table = getConfig().getString("Table");


 @Override
 public void onDisable() {

 }

 @Override
 public void onEnable() {
	  getServer().getPluginManager().registerEvents(this, this);
	  registerConfig();
	  MySQL MySQLC = new MySQL(host, port, db, username, password);
  try {
	c = MySQLC.openConnection();
} catch (ClassNotFoundException e) {
	e.printStackTrace();
} catch (SQLException e) {

	e.printStackTrace();
}

}

 public void registerConfig() {
 	saveDefaultConfig();




	}

 @EventHandler
 public void onPlayerDeath(PlayerDeathEvent e) {
  if (e.getEntity() instanceof Player) {
   Player p = e.getEntity();
   Location loc = e.getEntity().getLocation();
   double x = loc.getBlockX() + 0.5;
   double y = loc.getBlockY();
   double z = loc.getBlockZ() + 0.5;
   String dr = e.getDeathMessage();
   String world = loc.getWorld().getName();
   java.util.Date dt = new java.util.Date();

   java.text.SimpleDateFormat sdf =
        new java.text.SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

   String time = sdf.format(dt);
	 inventoryContents.put(p.getName(), p.getInventory().getContents());
	  inventoryArmorContents.put(p.getName(), p.getInventory().getArmorContents());

        int deathcount = 0;

		String statementstring = "SELECT * FROM " + table + " WHERE PlayerName = '" + p.getName() +"';";
		String statementstring2 = "INSERT INTO "+ table + " (id, PlayerName, X, Y, Z, DeathReason, world,Time, deathcount,inv,armor) VALUES (NULL, '" + p.getName() + "', '" + x + "', '" + y + "', '" + z + "', '" + dr + "', '" + world + "', '" + time + "', '" + deathcount + "', '" + inventoryContents + "', '" + inventoryArmorContents + "');";

	try {
		Statement statement = c.createStatement();
		ResultSet res = statement.executeQuery(statementstring);
		if(res.next()) {
			String statementstring3 = "UPDATE " + table + " SET X='" + x + "', Y='" + y + "', Z='" + z + "', DeathReason='" + dr + "', world='" + world + "',Time='" + time + "', deathcount='" + (res.getInt("deathcount") + 1) + "', inv='" + inventoryContents + "', armor='" + inventoryArmorContents + "' WHERE id='" + res.getInt("id") + "';";
			p.sendMessage(statementstring3);
			statement.executeUpdate(statementstring3);
			} else {
				statement.executeUpdate(statementstring2);
			}
	} catch (SQLException e2) {

		e2.printStackTrace();
	}
  }

  }



  public boolean onCommand(CommandSender sender, Command cmd, String label, String[] args) {
   	Player p = (Player)sender;
	boolean tp = false;
	String statementstring4 = null;
	if(cmd.getLabel().equalsIgnoreCase("loadinv")) {

		  if(inventoryContents.containsKey(p.getName()) && inventoryArmorContents.containsKey(p.getName())){
			    p.getInventory().clear();
			    p.getInventory().setContents(inventoryContents.get(p.getName()));
			    p.getInventory().setArmorContents(inventoryArmorContents.get(p.getName()));
		  }
	} else if(cmd.getLabel().equalsIgnoreCase("death")) {
   	  if(args.length != 0) {
   		if(args[0].equals("tp")) {
   		  if(p.hasPermission("death.teleport")) {
              String sanitised_arg = args[1].replace("\\","");
              sanitised_arg = sanitised_arg.replace("'","");
   	   		statementstring4 = "SELECT * FROM " + table + " WHERE PlayerName = '" + sanitised_arg.toString() +"';";
   			try {
   				Statement statement = c.createStatement();
   				ResultSet res = statement.executeQuery(statementstring4);
   				if(res.next()) {
   			        Location l = new Location(Bukkit.getWorld(res.getString("world")), res.getDouble("X"), res.getInt("Y"), res.getDouble("Z"));
   					p.teleport(l);
   					p.sendMessage(ChatColor.GRAY +  "You have been teleported to " + ChatColor.GOLD + "" + ChatColor.BOLD + res.getString("PlayerName") + ChatColor.GRAY + "'s death location at [" +  ChatColor.GOLD + "" +
   							res.getString("world") + ": " + res.getString("X") + ", " + res.getString("Y") + ", " + res.getString("Z") + ChatColor.GRAY + "] at: " + ChatColor.GOLD + "" +
   							res.getString("time") + ChatColor.GRAY + ".");
   					p.sendMessage(ChatColor.GRAY + "Cause of Death: " + ChatColor.GOLD + res.getString("DeathReason") + ChatColor.GRAY + "." );
   				} else {
   				    p.sendMessage(ChatColor.RED + args[1] + " hasn't died! (yet :D)");
   				}
   			} catch (SQLException e) {
   				e.printStackTrace();
   			}
   	   	  } else {
   	 		p.sendMessage(ChatColor.RED + "Panda & Jam Say You Have No Permission!");
   	 	  }
		  tp = true;
		} else if (p.hasPermission("death.others")) {
   		  // Player used /death <name> and has permission to do so
			  String sanitised_arg = args[0].replace("\\","");
	          sanitised_arg = sanitised_arg.replace("'","");
   		  statementstring4 = "SELECT * FROM " + table + " WHERE PlayerName = '" + sanitised_arg +"';";

		} else {
   		  // Player used /death <name> but doesn't have permission to do so
		  statementstring4 = "SELECT * FROM " + table + " WHERE PlayerName = '" + p.getName() +"';";
		}
	  } else {
		// Player just used /death with no args - use their own name
		statementstring4 = "SELECT * FROM " + table + " WHERE PlayerName = '" + p.getName() +"';";
	  }

	  // If 'tp' wasn't used...
	  if (!tp) {
		  try {
			Statement statement = c.createStatement();
			ResultSet res = statement.executeQuery(statementstring4);
			if(res.next()) {

				p.sendMessage(ChatColor.GRAY +  "Player " + ChatColor.GOLD + "" + ChatColor.BOLD + res.getString("PlayerName") + ChatColor.GRAY + " died at [" +  ChatColor.GOLD + "" +
						res.getString("world") + ": " + res.getString("X") + ", " + res.getString("Y") + ", " + res.getString("Z") + ChatColor.GRAY + "] at: " + ChatColor.GOLD + "" +
						res.getString("time") + ChatColor.GRAY + ".");
				p.sendMessage(ChatColor.GRAY + "Cause of Death: " + ChatColor.GOLD + res.getString("DeathReason") + ChatColor.GRAY + "." );

			}else if(args.length != 0) {
	                p.sendMessage(ChatColor.RED + args[0] + " hasn't died! (yet :D)");
	              } else {
	                p.sendMessage(ChatColor.RED + " You haven't died! (yet :D)");
	              }
		  } catch (SQLException e) {

			e.printStackTrace();
		  }
   	  }
   	}
	return true;
  }
}