root/dev/mods/value_editor/eve_central_sync.php @ 336

<?php
/**
*       Verify that the EVE central tracking table exists.
*/
function verify_sync_table() {
        $query = new DBQuery();

        $query->execute("SHOW TABLES LIKE 'kb3_eve_central'");
        if ($query->recordCount() == 0) {
                $query->execute("CREATE TABLE kb3_eve_central (item_id int unsigned not null, item_price varchar(20), last_updated timestamp NOT NULL default CURRENT_TIMESTAMP on update CURRENT_TIMESTAMP, primary key (item_id)) engine=myisam comment='EVE central sync tracker'");
        }
}

/**
*       Retrieve the item value from EVE Central
*/
function ec_get_value($item_id) {
        $query = new DBQuery();

        $query->execute("SELECT item_price, unix_timestamp(last_updated) last_upd FROM kb3_eve_central WHERE item_id=$item_id");
        // If there's 1 record, then we have an archived value.
        if ($query->recordcount() == 1) {
                // Is it recent enough?
                $data = $query->getrow();
                if (48*3600 > (date('U') - $data['last_upd'])) {
                        file_put_contents(KB_CACHEDIR . '/ec', "Handling from cache.\n", FILE_APPEND);
                        return $data['item_price'];
                } else {
                        // Not recent enough, interrogate EVE Central
                        return ask_eve_central($item_id);
                }
        } else {
                return ask_eve_central($item_id);
        }
}

/**
*       Query EVE Central's XML feed.
*/
function ask_eve_central($item_id) {
        file_put_contents(KB_CACHEDIR.'/ec', "Handling from live.\n", FILE_APPEND);
        $query = new DBQuery();
        $file = fopen("http://eve-central.com/home/marketstat_xml.html?typeid=$item_id", 'r');
        if (! $file) {
                return -99;
        }
        $content = stream_get_contents($file);
        fclose($file);
        file_put_contents(KB_CACHEDIR.'/ec', "$content\n", FILE_APPEND);
        if (!preg_match('/market_stat/', $content)) {
                return -99;
        }
        if (preg_match('/avg_price>None/', $content)) {
                return -99;
        }
        preg_match('/<avg_sell_price>(\d+\.\d{2})\d+</', $content, $match);
        $sell = $match[1];
        preg_match('/<avg_buy_price>(\d+\.\d{2})\d+</', $content, $match);
        $buy = $match[1];
        $weighted_average = round(((1.6 * $buy + 0.8 * $sell) / 2),2);
        if (0 == $weighted_average) {
                return -99;
        }
        $query->execute("REPLACE INTO kb3_eve_central (item_id, item_price) VALUES ($item_id, '$weighted_average')");
        return $weighted_average;
}

/**
*       Wrapper to do all to work.  Updates the items table based on the cached or live data.
*/
function ec_update_value($item_id) {
        $query = new DBQuery();

        // Don't try if we can't open URLs with fopen.
        if (1 != ini_get('allow_url_fopen')) {
                return;
        }
        // Don't try if the item id isn't an integer.
        if (!is_numeric($item_id)) {
                return;
        }
        // Verify we have a sync table to use.
        verify_sync_table();
        // The destroyed items etc feed in the -internal- killboard item ID.
        // EVE Central needs the external ID if we have it.
        $query->execute("SELECT itm_externalid FROM kb3_items WHERE itm_id=$item_id");
        $data = $query->getRow();
        $e_item_id = $data['itm_externalid'];
        // Don't try if the item id isn't an integer or it's 0.
        if (!is_numeric($e_item_id) OR 0 == $e_item_id) {
                return;
        }
        file_put_contents(KB_CACHEDIR.'/ec', "Request for $item_id -> $e_item_id\n", FILE_APPEND);

        $value = ec_get_value($e_item_id);
        if (-99 != $value) {
                $query->execute("update kb3_items set itm_value='$value' WHERE itm_id=$item_id");
                return true;
        } else {
                file_put_contents(KB_CACHEDIR.'/ec', "Failed to find it.\n", FILE_APPEND);
        }
        return false;
}
?>