You need to update your system";
return false;
}
*/
if (empty($videos_id)) {
die(__("You need a video to generate statistics"));
}
$userId = empty($_SESSION["user"]["id"]) ? "NULL" : $_SESSION["user"]["id"];
$lastVideoTime = 0;
if (empty($currentTime)) {
$lastStatistic = self::getLastStatistics($videos_id, $userId);
if (empty($currentTime) && !empty($lastStatistic)) {
$lastVideoTime = intval($lastStatistic['lastVideoTime']);
}
} else {
$lastVideoTime = intval($currentTime);
}
$sql = "INSERT INTO videos_statistics "
. "(`when`,ip, users_id, videos_id, lastVideoTime, created, modified, session_id) values "
. "(now(),?," . $userId . ",?,{$lastVideoTime},now(),now(),'" . session_id() . "')";
$insert_row = sqlDAL::writeSql($sql, "si", array(getRealIpAddr(), $videos_id));
if (!empty($global['mysqli']->insert_id)) {
return $global['mysqli']->insert_id;
} else {
die($sql . ' Save Video Statistics Error : (' . $global['mysqli']->errno . ') ' . $global['mysqli']->error);
}
}
static function updateStatistic($videos_id, $users_id, $lastVideoTime) {
$lastStatistic = self::getLastStatistics($videos_id, $users_id);
if (empty($lastStatistic)) {
$vs = new VideoStatistic(0);
$vs->setUsers_id($users_id);
$vs->setVideos_id($videos_id);
$vs->setWhen(date("Y-m-d h:i:s"));
} else {
$vs = new VideoStatistic($lastStatistic['id']);
}
$vs->setLastVideoTime($lastVideoTime);
return $vs->save();
}
function save() {
$this->setSession_id(session_id());
if (empty($this->session_id) && empty($this->users_id)) {
return false;
}
if (empty($this->users_id)) {
$this->setUsers_id('null');
}
return parent::save();
}
static function getLastStatistics($videos_id, $users_id = 0) {
if (!empty($users_id)) {
$sql = "SELECT * FROM videos_statistics WHERE videos_id = ? AND users_id = ? ORDER BY modified DESC LIMIT 1 ";
$res = sqlDAL::readSql($sql, 'ii', array($videos_id, $users_id), true);
} else {
$sql = "SELECT * FROM videos_statistics WHERE videos_id = ? AND session_id = ? ORDER BY modified DESC LIMIT 1 ";
$res = sqlDAL::readSql($sql, 'is', array($videos_id, session_id()), true);
}
$result = sqlDAL::fetchAssoc($res);
sqlDAL::close($res);
if (!empty($result)) {
return $result;
}
return false;
}
static function getLastVideoTimeFromVideo($videos_id, $users_id) {
$row = self::getLastStatistics($videos_id, $users_id);
if (empty($row)) {
return 0;
}
return intval($row['lastVideoTime']);
}
static function getStatisticTotalViews($videos_id, $uniqueUsers = false, $startDate = "", $endDate = "") {
global $global;
if ($uniqueUsers) {
$ast = "distinct(users_id)";
} else {
$ast = "*";
}
$sql = "SELECT count({$ast}) as total FROM videos_statistics WHERE 1=1 ";
$formats = "";
$values = array();
if (!empty($videos_id)) {
$sql .= " AND videos_id = ? ";
$formats .= "i";
$values[] = $videos_id;
}
if (!empty($startDate)) {
$sql .= " AND `when` >= ? ";
$formats .= "s";
$values[] = $startDate;
}
if (!empty($endDate)) {
$sql .= " AND `when` <= ? ";
$formats .= "s";
$values[] = $endDate;
}
$res = sqlDAL::readSql($sql, $formats, $values);
$result = sqlDAL::fetchAssoc($res);
sqlDAL::close($res);
if (!empty($result)) {
//echo "
".$row['total']." --- ".$sql, "
";
return $result['total'];
}
return 0;
}
static function getTotalLastDaysAsync($video_id, $numberOfDays) {
global $global, $advancedCustom;
$md5 = ("{$video_id}_{$numberOfDays}");
$path = getCacheDir() . "getTotalLastDaysAsync/";
make_path($path);
$cacheFileName = "{$path}{$md5}";
if (empty($advancedCustom->AsyncJobs) || !file_exists($cacheFileName)) {
if (file_exists($cacheFileName . ".lock")) {
return array();
}
$total = static::getTotalLastDays($video_id, $numberOfDays);
file_put_contents($cacheFileName, json_encode($total));
return $total;
}
$return = json_decode(file_get_contents($cacheFileName));
if (time() - filemtime($cacheFileName) > 60) {
// file older than 1 min
$command = ("php '{$global['systemRootPath']}objects/getTotalLastDaysAsync.php' '$video_id' '$numberOfDays' '$cacheFileName'");
_error_log("getTotalLastDaysAsync: {$command}");
exec($command . " > /dev/null 2>/dev/null &");
}
return $return;
}
static function getTotalLastDays($video_id, $numberOfDays, $returnArray = array()) {
if ($numberOfDays < 0) {
return $returnArray;
}
$date = date("Y-m-d", strtotime("-{$numberOfDays} days"));
$returnArray[] = static::getStatisticTotalViews($video_id, false, $date . " 00:00:00", $date . " 23:59:59");
$numberOfDays--;
return static::getTotalLastDays($video_id, $numberOfDays, $returnArray);
}
static function getTotalToday($video_id, $hour = 0, $returnArray = array()) {
if ($hour >= 24) {
return $returnArray;
}
$date = date("Y-m-d {$hour}", time());
//echo $date;exit;
$returnArray[] = static::getStatisticTotalViews($video_id, false, $date . ":00:00", $date . ":59:59");
$hour++;
return static::getTotalToday($video_id, $hour, $returnArray);
}
static function getTotalTodayAsync($video_id) {
global $global, $advancedCustom;
$cacheFileName = getCacheDir() . "getTotalTodayAsync_{$video_id}";
if (empty($advancedCustom->AsyncJobs) || !file_exists($cacheFileName)) {
if (file_exists($cacheFileName . ".lock")) {
return array();
}
$total = static::getTotalToday($video_id);
file_put_contents($cacheFileName, json_encode($total));
return $total;
}
$return = json_decode(file_get_contents($cacheFileName));
if (time() - filemtime($cacheFileName) > 60) {
// file older than 1 min
$command = ("php '{$global['systemRootPath']}objects/getTotalTodayAsync.php' '$video_id' '$cacheFileName'");
_error_log("getTotalTodayAsync: {$command}");
exec($command . " > /dev/null 2>/dev/null &");
}
return $return;
}
function getWhen() {
return $this->when;
}
function getIp() {
return $this->ip;
}
function getUsers_id() {
return $this->users_id;
}
function getVideos_id() {
return $this->videos_id;
}
function getLastVideoTime() {
return $this->lastVideoTime;
}
function setWhen($when) {
$this->when = $when;
}
function setIp($ip) {
$this->ip = $ip;
}
function setUsers_id($users_id) {
$this->users_id = intval($users_id);
if (empty($this->users_id)) {
$this->users_id = 'null';
}
}
function setVideos_id($videos_id) {
$this->videos_id = intval($videos_id);
}
function setLastVideoTime($lastVideoTime) {
$this->lastVideoTime = intval($lastVideoTime);
}
function getSession_id() {
return $this->session_id;
}
function setSession_id($session_id) {
$this->session_id = $session_id;
}
static function getChannelsWithMoreViews($daysLimit = 30) {
global $global;
// get unique videos ids from the requested timeframe
$sql = "SELECT distinct(videos_id) as videos_id FROM videos_statistics WHERE DATE(created) >= DATE_SUB(DATE(NOW()), INTERVAL {$daysLimit} DAY) ";
$res = sqlDAL::readSql($sql);
$fullData = sqlDAL::fetchAllAssoc($res);
sqlDAL::close($res);
// get the channel owner from each of those videos
$channels = array();
if ($res != false) {
foreach ($fullData as $row) {
$users_id = Video::getOwner($row['videos_id']);
if (empty($channels[$users_id])) {
$channels[$users_id] = array();
}
$channels[$users_id][] = $row['videos_id'];
}
foreach ($channels as $key => $value) {
// count how many views each one has
$sql2 = "SELECT count(id) as total FROM videos_statistics WHERE videos_id IN (" . implode(",", $value) . ") AND DATE(created) >= DATE_SUB(DATE(NOW()), INTERVAL {$daysLimit} DAY) ";
$res2 = sqlDAL::readSql($sql2);
$result2 = sqlDAL::fetchAssoc($res2);
sqlDAL::close($res2);
if (!empty($result2)) {
$channels[$key]['users_id'] = $key;
$channels[$key]['total'] = intval($result2['total']);
}
}
}
// return more first
usort($channels, function($a, $b) {
return $b['total'] - $a['total'];
});
return $channels;
}
static function getUsersIDFromChannelsWithMoreViews($daysLimit = 30) {
$channels = self::getChannelsWithMoreViews($daysLimit);
$users_id = array();
foreach ($channels as $value) {
$users_id[] = $value['users_id'];
}
return $users_id;
}
}