<?php
$servername = "xxx";
$username = "xxx";
$password = "xxx";
$dbname = "xxx";

$conn = new mysqli($servername, $username, $password, $dbname);
if ($conn->connect_error) {
    die("Connection failed: " . $conn->connect_error . "\n");
}

$command = readline("Item Unique_ID: ");
// $players = $conn->query("SELECT * FROM store_players;");
// $items = $conn->query("SELECT * FROM store_items;");

$players = $conn->query("SELECT DISTINCT player_id AS player_id FROM store_items");

foreach ($players as $player) {
	echo "Handling... " . $player['player_id'] . "<br/ >";
	$items = $conn->query("SELECT * FROM store_items WHERE player_id=" . $player['player_id']);
	$total = 0;
	foreach ($items as $item) {
		$total += $item['price_of_purchase'];
	}
	echo "Got data " . $total . " for user " . $player['player_id'] . "<br />";
	$conn->query("UPDATE store_players SET credits = credits + " . $total . " WHERE id=" . $player['player_id'])
	echo "Updated player credits successfully. <br />"
	$conn->query("DELETE FROM store_items WHERE player_id=" . $player['player_id'])
	echo "Deleted Store Items Successfully :D <br />"
}


/*
Array
(
    [id] => 962
    [player_id] => 7072
    [type] => hat
    [unique_id] => models/store/hats/afro.mdl
    [date_of_purchase] => 1423782508
    [date_of_expiration] => 0
    [price_of_purchase] => 150
)

Array
(
    [id] => 9161
    [authid] => 1:47577598
    [name] => Kikud
    [credits] => 0
    [date_of_join] => 1425727250
    [date_of_last_join] => 1425727250
)
*/


function findItems(){
    global $mask, $items;
    $mask = "|%5.5s |%-10.10s |%-25.25s |%-7.7s |%-12.12s |%-10.10s |\r\n";
    printf($mask, "ID", "SteamID", "Name", "Credits", "Date Of Join", "Last Join");
    foreach($items as $value) {
        $playerValue = findPlayer($value['player_id']);
		echo "GUNSTAR " . $playerValue['id'];
        refundPlayer($playerValue['id'], (string)($playerValue['credits'] + $value['price_of_purchase']), $value['id']);
    }
}

function findPlayer($player_id) {
    global $players, $mask;
    foreach($players as $value) {
        if ($value['id'] == $player_id) {
            printf($mask, $value['id'], $value['authid'], $value['name'], $value['credits'], $value['date_of_join'], $value['date_of_last_join']);
			return $value;
        }
    }
}

function refundPlayer($player_id, $amount, $item_id) {
    global $conn;
    $sql = "UPDATE store_players SET credits=" . $amount . " WHERE id=" . $player_id;
	echo $sql;
    if (mysqli_query($conn, $sql)) {
        echo "Record updated successfully, removing entry...";
        $sql = "DELETE FROM store_players WHERE id=" . $item_id;
        if (mysqli_query($conn, $sql)) {
        	echo "Record removed successfully";
        } else {
        	echo "Error removing record: " . $conn->error;
        }
    } else {
        echo "Error updating record: " . $conn->error;
    }
}

// findItems();

// refundPlayer("3260", "123");

$conn->close();
?>