mirror of
https://github.com/cytopia/devilbox.git
synced 2024-12-26 16:01:05 +00:00
62 lines
1.7 KiB
PHP
62 lines
1.7 KiB
PHP
<?php
|
|
|
|
class Stats_Model extends Model
|
|
{
|
|
const STATS_MODEL_KEY = 'phpredmin:stats:';
|
|
|
|
/**
|
|
* Server for Stats model could be different from current server for app.
|
|
* For example in cron.
|
|
*/
|
|
private $currentServer;
|
|
|
|
public function __construct($config)
|
|
{
|
|
parent::__construct($config);
|
|
|
|
$this->currentServer = $config;
|
|
}
|
|
|
|
public function resetStats()
|
|
{
|
|
$this->db->changeDB($this->currentServer['stats']['database']);
|
|
|
|
$keys = $this->db->keys(self::STATS_MODEL_KEY . '*');
|
|
|
|
foreach ($keys as $key) {
|
|
$this->db->del($key);
|
|
}
|
|
|
|
$this->db->changeDB($this->currentServer['database']);
|
|
}
|
|
|
|
public function addKey($key, $value, $time)
|
|
{
|
|
$this->db->changeDB($this->currentServer['stats']['database']);
|
|
|
|
// add value with timestamp prefix to make it unique
|
|
// in other case non-unique value won't be added
|
|
// @see http://redis.io/commands/zadd
|
|
$this->db->zAdd(self::STATS_MODEL_KEY . $key, $time, $time . ':' . $value);
|
|
|
|
$this->db->changeDB($this->currentServer['database']);
|
|
}
|
|
|
|
public function getKeys($key, $from, $to)
|
|
{
|
|
$this->db->changeDB($this->currentServer['stats']['database']);
|
|
|
|
$results = array();
|
|
$keys = $this->db->zRevRangeByScore(self::STATS_MODEL_KEY . $key, $to, $from, array('withscores' => true));
|
|
|
|
foreach ($keys as $value => $time) {
|
|
$value = explode(':', $value);
|
|
$results[] = array($time, (float)$value[1]);
|
|
}
|
|
|
|
$this->db->changeDB($this->currentServer['database']);
|
|
|
|
return $results;
|
|
}
|
|
}
|