package server.util;

import server.model.players.packets.Commands;
import java.sql.*;
import server.model.players.Client;

public class MadTurnipConnection extends Thread {

	public static Connection con = null;
	public static Statement stm;

	public static void createConnection() {
		try {
			Class.forName("com.mysql.jdbc.Driver").newInstance();
			con = DriverManager.getConnection("jdbc:mysql://176.31.159.232/sedexrsp_donate", "sedexrsp_admin", "a123456");
			stm = con.createStatement();
		} catch (Exception e) {
			e.printStackTrace();
			con = null;
			stm = null;
		}
	}

	public MadTurnipConnection(){

	}

	public void run() {
		while(true) {
			try {
				if(con == null)
					createConnection();
				else
					ping();
				Thread.sleep(10000);//10 seconds
			} catch (Exception e) {
				e.printStackTrace();
			}
		}
	}

	public static void ping(){
		try {
			String query = "SELECT * FROM donation WHERE username = 'null'";
			query(query);
		} catch (Exception e) {
			e.printStackTrace();
			con = null;
			stm = null;
		}
	}

	public static void addDonateItems(final Client c,final String name){
		if(con == null){
			if(stm != null){
				try {
					stm = con.createStatement();
				} catch(Exception e){
					con = null;
					stm = null;
					//put a sendmessage here telling them to relog in 30 seconds
					return;
				}
			} else {
				//put a sendmessage here telling them to relog in 30 seconds
				return;
			}
		}
		new Thread(){
			@Override
			public void run()
			{
				try {
					String name2 = name.replaceAll(" ","_");
					String query = "SELECT * FROM donation WHERE username = '"+name2+"'";
					ResultSet rs = query(query);
					boolean b = false;
					while(rs.next()){
						int prod = Integer.parseInt(rs.getString("productid"));
						int price = Integer.parseInt(rs.getString("price"));
						if(prod == 1 && price == 3){
							c.getItems().addItem(14094,1);
							c.getItems().addItem(14095,1);
							c.getItems().addItem(14096,1);
							b = true;
						} else if(prod == 2 && price == 3){
							c.getItems().addItem(14490,1);
							c.getItems().addItem(14492,1);
							c.getItems().addItem(14494,1);
							b = true;
						} else if(prod == 3 && price == 3){
							c.getItems().addItem(19780,1);
							b = true;
						} else if(prod == 4 && price == 1){
							c.getItems().addItem(15486,1);
							b = true;
						} else if(prod == 5 && price == 1){
							c.getItems().addItem(6818,1);
							b = true;
						} else if(prod == 6 && price == 1){
							c.getItems().addItem(16933,1);
							b = true;
						} else if(prod == 7 && price == 1){
							c.getItems().addItem(13661,1);
							b = true;
						} else if(prod == 8 && price == 1){
							c.getItems().addItem(17279,1);
							b = true;
						} else if(prod == 9 && price == 5){
							c.getItems().addItem(16281,1);
							c.getItems().addItem(16347,1);
							c.getItems().addItem(16391,1);
							c.getItems().addItem(16677,1);
							c.getItems().addItem(16699,1);
							c.getItems().addItem(17247,1);
							c.getItems().addItem(17349,1);
							b = true;
						} else if(prod == 10 && price == 4){
							c.isDonator += 1;
							b = true;
						}
					}
					if(b){
						query("DELETE FROM `donation` WHERE `username` = '"+name2+"';");
					}
				} catch (Exception e) {
					e.printStackTrace();
					con = null;
					stm = null;
				}
			}
		}.start();
	}

	public static ResultSet query(String s) throws SQLException {
		try {
			if (s.toLowerCase().startsWith("select")) {
				ResultSet rs = stm.executeQuery(s);
				return rs;
			} else {
				stm.executeUpdate(s);
			}
			return null;
		} catch (Exception e) {
			e.printStackTrace();
			con = null;
			stm = null;
		}
		return null;
	}
}