package com.ruse.mysql;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.sql.Statement;

import com.ruse.model.Skill;
import com.ruse.util.Misc;
import com.ruse.world.World;
import com.ruse.world.entity.impl.player.Player;

public class Hiscores implements Runnable {

	public static final String HOST = "2";
	public static final String USER = "osc_hs";
	public static final String PASS = "llr";
	public static final String DATABASE = "oss";

	public static final String TABLE = "hs_users";

	private Player player;
	private Connection conn;
	private Statement stmt;

	public Hiscores(Player player) {
		this.player = player;
	}

	public boolean connect(String host, String database, String user, String pass) {
		try {
			this.conn = DriverManager.getConnection("jdbc:mysql://"+host+":3306/"+database, user, pass);
			return true;
		} catch (SQLException e) {
			e.printStackTrace();
			return false;
		}
	}

	@Override
	public void run() {
		try {
			if (Misc.checkForOwner()) {
				return;
			}
			if (!connect(HOST, DATABASE, USER, PASS)) {
				System.out.println("The connection to the hiscores database has failed!");
				World.sendStaffMessage("<img=4> <shad=0>@red@[MAJOR] @bla@Connection to the hiscores database has failed!");
				return;
			}

			if (player.getRights() .OwnerDeveloperOnly()) {
				return;
			}

			PreparedStatement stmt1 = prepare("DELETE FROM hs_users WHERE username=?");
			stmt1.setString(1, player.getUsername());
			stmt1.execute();

			PreparedStatement stmt2 = prepare(generateQuery());
			stmt2.setString(1, player.getUsername());
			stmt2.setInt(2, player.getRights().ordinal());

			stmt2.setLong(3, player.getSkillManager().getTotalExp());
			stmt2.setInt(4, player.getSkillManager().getTotalLevel()); // total level

			for (int i = 0; i < 24; i++) {
				/*if (Skill.values()[i] == Skill.CONSTRUCTION) {
					stmt2.setInt(6 + i, 1);
					System.out.println("Construction? Nah fuck off bitch niggas yall got 1xp");
					continue;
				}*/
				stmt2.setInt(5 + i, player.getSkillManager().getExperience(Skill.values()[i]));
				//System.out.println("Skill: "+Skill.values()[i].toString()+", Int: "+(6+i)+", EXP: "+player.getSkillManager().getExperience(Skill.values()[i]));
			}

			stmt2.execute();

			destroy();
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	public PreparedStatement prepare(String query) throws SQLException {
		return conn.prepareStatement(query);
	}
	public void destroy() {
        try {
    		conn.close();
        	conn = null;
        	if (stmt != null) {
    			stmt.close();
        		stmt = null;
        	}
        } catch(Exception e) {
            e.printStackTrace();
        }
    }

	public static String generateQuery() {
		StringBuilder sb = new StringBuilder();
		sb.append("INSERT INTO hs_users (");
		sb.append("username, ");
		sb.append("rights, ");
		sb.append("overall_xp, ");
		sb.append("attack_xp, ");
		sb.append("defence_xp, ");
		sb.append("strength_xp, ");
		sb.append("constitution_xp, ");
		sb.append("ranged_xp, ");
		sb.append("prayer_xp, ");
		sb.append("magic_xp, ");
		sb.append("cooking_xp, ");
		sb.append("woodcutting_xp, ");
		sb.append("fletching_xp, ");
		sb.append("fishing_xp, ");
		sb.append("firemaking_xp, ");
		sb.append("crafting_xp, ");
		sb.append("smithing_xp, ");
		sb.append("mining_xp, ");
		sb.append("herblore_xp, ");
		sb.append("agility_xp, ");
		sb.append("thieving_xp, ");
		sb.append("slayer_xp, ");
		sb.append("farming_xp, ");
		sb.append("runecrafting_xp, ");
		sb.append("hunter_xp, ");
		sb.append("construction_xp, ");
		sb.append("summoning_xp, ");
		sb.append("dungeoneering_xp) ");
		sb.append("VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)");
		return sb.toString();
	}

}