package com.vencillio.core.network.mysql;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

import com.vencillio.VencillioConstants;
import com.vencillio.core.util.Utility;
import com.vencillio.rs2.entity.World;
import com.vencillio.rs2.entity.item.Item;
import com.vencillio.rs2.entity.player.Player;
import com.vencillio.rs2.entity.player.net.Client;
import com.vencillio.rs2.entity.player.net.out.impl.SendMessage;
public class VoteUpdater implements Runnable {

    public static final String HOST = "";
    public static final String USER = "";
    public static final String PASS = "";
    public static final String DATABASE = "";

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

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

    @Override
    public void run() {
    if ((System.currentTimeMillis() - player.getLastRequestedLookup()) < 30000) {
        player.send(new SendMessage("Sorry, you can only check your votes once per 30 seconds."));
        return;
    }
        try {
            if (!connect(HOST, DATABASE, USER, PASS)) {
                return;
            }
            player.setLastRequestedLookup(System.currentTimeMillis());
            String name = player.getUsername().replace(" ", "_");
            ResultSet rs = executeQuery("SELECT * FROM fx_votes WHERE username='"+name+"' AND claimed=0 AND callback_date IS NOT NULL");
            while (rs.next()) {
                String timestamp = rs.getTimestamp("callback_date").toString();
                String ipAddress = rs.getString("ip_address");
                int siteId = rs.getInt("site_id");
                player.voteAmount ++;
                System.out.println("Vote claimed by "+name+". (sid: "+siteId+", ip: "+ipAddress+", time: "+timestamp+")");
                rs.updateInt("claimed", 1); // do not delete otherwise they can reclaim!
                rs.updateRow();
            }
            if (player.voteAmount >= 1) {
                player.send(new SendMessage("You have received "+player.voteAmount+" vote tickets for voting!"));
                player.getInventory().add(4067, player.voteAmount);
                player.voteAmount = 0;
                World.sendGlobalMessage("<img=1><col=FFDF00>"+ player.getUsername() + " has voted and claimed their reward!</col>");
            }
            destroy();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }


    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) {
            System.out.println("Failing connecting to database!");
            return false;
        }
    }

    public void destroy() {
        try {
            conn.close();
            conn = null;
            if (stmt != null) {
                stmt.close();
                stmt = null;
            }
        } catch(Exception e) {
            e.printStackTrace();
        }
    }

    public int executeUpdate(String query) {
        try {
            this.stmt = this.conn.createStatement(1005, 1008);
            int results = stmt.executeUpdate(query);
            return results;
        } catch (SQLException ex) {
            ex.printStackTrace();
        }
        return -1;
    }

    public ResultSet executeQuery(String query) {
        try {
            this.stmt = this.conn.createStatement(1005, 1008);
            ResultSet results = stmt.executeQuery(query);
            return results;
        } catch (SQLException ex) {
            ex.printStackTrace();
        }
        return null;
    }
}