diff --git a/objects/video_statistic.php b/objects/video_statistic.php
index 0ca5620ae..58c5461ad 100644
--- a/objects/video_statistic.php
+++ b/objects/video_statistic.php
@@ -1,584 +1,589 @@
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);
}
}
public static function updateStatistic($videos_id, $users_id, $lastVideoTime, $seconds_watching_video = 0) {
$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);
if (!empty($seconds_watching_video) && $seconds_watching_video > 0) {
$totalVideoWatched = $vs->getSeconds_watching_video() + $seconds_watching_video;
_error_log("updateStatistic: add more [$seconds_watching_video] to video [$videos_id] " . get_browser_name());
$vs->setSeconds_watching_video($totalVideoWatched);
$v = new Video('', '', $videos_id);
$v->addSecondsWatching($seconds_watching_video);
//$totalVideoSeconds = timeToSeconds($hms);
//Video::addViewPercent();
}
$id = $vs->save();
/*
if(!empty($id)){
Video::clearCache($videos_id);
}
*/
return $id;
}
public function save() {
if (empty($this->videos_id)) {
return false;
}
$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');
}
$this->seconds_watching_video = intval($this->seconds_watching_video);
return parent::save();
}
public 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;
}
public static function getLastVideoTimeFromVideo($videos_id, $users_id) {
$row = self::getLastStatistics($videos_id, $users_id);
if (empty($row)) {
return 0;
}
return intval($row['lastVideoTime']);
}
public 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;
}
public static function getTotalLastDaysAsync($video_id, $numberOfDays) {
global $global, $advancedCustom;
$md5 = ("{$video_id}_{$numberOfDays}");
$path = getCacheDir() . "getTotalLastDaysAsync/";
make_path($path);
$cacheFileName = "{$path}{$md5}";
if (!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;
}
public 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);
}
public 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);
}
public static function getTotalTodayAsync($video_id) {
global $global, $advancedCustom;
$cacheFileName = getCacheDir() . "getTotalTodayAsync_{$video_id}";
if (!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;
}
public function getWhen() {
return $this->when;
}
public function getIp() {
return $this->ip;
}
public function getUsers_id() {
return $this->users_id;
}
public function getVideos_id() {
return $this->videos_id;
}
public function getLastVideoTime() {
return $this->lastVideoTime;
}
public function setWhen($when) {
$this->when = $when;
}
public function setIp($ip) {
$this->ip = $ip;
}
public function setUsers_id($users_id) {
$this->users_id = intval($users_id);
if (empty($this->users_id)) {
$this->users_id = 'null';
}
}
public function setVideos_id($videos_id) {
$this->videos_id = intval($videos_id);
}
public function setLastVideoTime($lastVideoTime) {
$this->lastVideoTime = intval($lastVideoTime);
}
public function getSession_id() {
return $this->session_id;
}
public function setSession_id($session_id) {
$this->session_id = $session_id;
}
public static function getChannelsWithMoreViews($daysLimit = 30) {
global $global;
$cacheName3 = "getChannelsWithMoreViews{$daysLimit}" . DIRECTORY_SEPARATOR . md5(json_encode(array($_GET, $_POST)));
$cache = ObjectYPT::getCache($cacheName3, 3600); // 1 hour cache
if (!empty($cache)) {
_error_log('getChannelsWithMoreViews cache found ' . $cacheName3);
return object_to_array($cache);
} else {
_error_log('getChannelsWithMoreViews no cache found ' . $cacheName3);
}
// get unique videos ids from the requested timeframe
$sql = "SELECT distinct(videos_id) as videos_id FROM videos_statistics WHERE DATE(`when`) >= DATE_SUB(DATE(NOW()), INTERVAL {$daysLimit} DAY) ";
$channels = array();
$channelsPerUser = array();
$cacheName2 = "getChannelsWithMoreViews" . DIRECTORY_SEPARATOR . md5($sql);
$cache2 = ObjectYPT::getCache($cacheName2, 3600); // 1 hour cache
if (!empty($cache2)) {
$channelsPerUser = object_to_array($cache2);
}
if (empty($channelsPerUser)) {
$res = sqlDAL::readSql($sql);
$fullData = sqlDAL::fetchAllAssoc($res);
sqlDAL::close($res);
if ($res != false) {
// get the channel owner from each of those videos
foreach ($fullData as $row) {
$users_id = Video::getOwner($row['videos_id']);
if (empty($channelsPerUser[$users_id])) {
$channelsPerUser[$users_id] = array();
}
$channelsPerUser[$users_id][] = $row['videos_id'];
}
}
$response = ObjectYPT::setCache($cacheName2, $channelsPerUser);
}
if (!empty($channelsPerUser)) {
foreach ($channelsPerUser 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 $a['total'] - $b['total'];
});
}
$response = ObjectYPT::setCache($cacheName3, $channels);
_error_log('getChannelsWithMoreViews cache saved [' . json_encode($response) . '] ' . $cacheName3);
return $channels;
}
public static function getVideosWithMoreViews($status, $showOnlyLoggedUserVideos, $showUnlisted, $suggestedOnly, $daysLimit = 30) {
global $global;
// get unique videos ids from the requested timeframe
$sql = "SELECT distinct(videos_id) as videos_id FROM videos_statistics s "
. " LEFT JOIN videos v ON v.id = videos_id "
. " WHERE DATE(s.`when`) >= DATE_SUB(DATE(NOW()), INTERVAL {$daysLimit} DAY) ";
if ($showOnlyLoggedUserVideos === true && !Permissions::canModerateVideos()) {
$sql .= " AND v.users_id = '" . User::getId() . "'";
} elseif (!empty($showOnlyLoggedUserVideos)) {
$sql .= " AND v.users_id = '{$showOnlyLoggedUserVideos}'";
}
if (!empty($_GET['channelName'])) {
$user = User::getChannelOwner($_GET['channelName']);
$sql .= " AND v.users_id = '{$user['id']}' ";
}
if ($status == "viewable") {
if (User::isLogged()) {
$sql .= " AND (v.status IN ('" . implode("','", Video::getViewableStatus($showUnlisted)) . "') OR (v.status='u' AND v.users_id ='" . User::getId() . "'))";
} else {
$sql .= " AND v.status IN ('" . implode("','", Video::getViewableStatus($showUnlisted)) . "')";
}
} elseif ($status == "viewableNotUnlisted") {
$sql .= " AND v.status IN ('" . implode("','", Video::getViewableStatus(false)) . "')";
} elseif (!empty($status)) {
$sql .= " AND v.status = '{$status}'";
}
$sql .= AVideoPlugin::getVideoWhereClause();
if ($suggestedOnly) {
$sql .= " AND v.isSuggested = 1 ";
}
$sql .= static::getSqlLimit();
$res = sqlDAL::readSql($sql);
$fullData = sqlDAL::fetchAllAssoc($res);
sqlDAL::close($res);
$channels = array();
$videos = array();
if ($res != false) {
foreach ($fullData as $key => $value) {
// count how many views each one has
$sql2 = "SELECT count(id) as total FROM videos_statistics WHERE videos_id = {$value['videos_id']} AND DATE(created) >= DATE_SUB(DATE(NOW()), INTERVAL {$daysLimit} DAY) ";
$res2 = sqlDAL::readSql($sql2);
$result2 = sqlDAL::fetchAssoc($res2);
sqlDAL::close($res2);
if (!empty($result2)) {
$video = Video::getVideo($value['videos_id'], $status, false, false, $suggestedOnly, $showUnlisted, false, $showOnlyLoggedUserVideos);
if (empty($video)) {
continue;
}
$video['total'] = $result2['total'];
$videos[] = $video;
}
}
}
// return more first
usort($videos, function ($a, $b) {
return $a['total'] - $b['total'];
});
return $videos;
}
public static function getUsersIDFromChannelsWithMoreViews($daysLimit = 30) {
$channels = self::getChannelsWithMoreViews($daysLimit);
$users_id = array();
foreach ($channels as $value) {
$users_id[] = $value['users_id'];
}
return $users_id;
}
public static function getChannelsTotalViews($users_id, $daysLimit = 30) {
global $global;
$cacheName = "getChannelsTotalViews($users_id, $daysLimit)";
$cache = ObjectYPT::getCache($cacheName, 3600); // 1 hour cache
if (!empty($cache)) {
return object_to_array($cache);
}
$users_id = intval($users_id);
// count how many views each one has
$sql2 = "SELECT count(s.id) as total FROM videos_statistics s "
. " LEFT JOIN videos v ON v.id = videos_id WHERE v.users_id = $users_id "
. " AND DATE(s.`when`) >= DATE_SUB(DATE(NOW()), INTERVAL {$daysLimit} DAY) ";
$res2 = sqlDAL::readSql($sql2);
$result2 = sqlDAL::fetchAssoc($res2);
sqlDAL::close($res2);
$result = 0;
if (!empty($result2)) {
$result = intval($result2['total']);
}
ObjectYPT::setCache($cacheName, $result);
return 0;
}
public static function getTotalStatisticsRecords() {
global $global;
$sql2 = "SELECT count(s.id) as total FROM videos_statistics s ";
$res2 = sqlDAL::readSql($sql2);
$result2 = sqlDAL::fetchAssoc($res2);
sqlDAL::close($res2);
$result = 0;
if (!empty($result2)) {
return intval($result2['total']);
}
ObjectYPT::setCache($cacheName, $result);
return 0;
}
public static function deleteOldStatistics($days) {
global $global;
$days = intval($days);
if (!empty($days)) {
$sql = "DELETE FROM " . static::getTableName() . " ";
$sql .= " WHERE created < DATE_SUB(NOW(), INTERVAL ? DAY) ";
$global['lastQuery'] = $sql;
//_error_log("Delete Query: ".$sql);
return sqlDAL::writeSql($sql, "i", array($days));
}
_error_log("Id for table " . static::getTableName() . " not defined for deletion", AVideoLog::$ERROR);
return false;
}
function getSeconds_watching_video() {
return intval($this->seconds_watching_video);
}
function setSeconds_watching_video($seconds_watching_video) {
$this->seconds_watching_video = intval($seconds_watching_video);
}
function getJson() {
return $this->json;
}
function setJson($json) {
if(!is_string($json)){
$json = _json_encode($json);
}
$this->json = $json;
}
public static function getAllFromVideos_id($videos_id) {
global $global;
if (!static::isTableInstalled()) {
return false;
}
$videos_id = intval($videos_id);
if (empty($videos_id)) {
return false;
}
$sql = "SELECT * FROM " . static::getTableName() . " WHERE videos_id=$videos_id ";
$sql .= self::getSqlFromPost();
//echo $sql;//exit;
$res = sqlDAL::readSql($sql);
$fullData = sqlDAL::fetchAllAssoc($res);
sqlDAL::close($res);
$rows = array();
if ($res != false) {
$isPluginEnabled = AVideoPlugin::isEnabledByName('User_Location');
foreach ($fullData as $row) {
$row['users'] = User::getNameIdentificationById($row['users_id']);
$row['when_human'] = humanTimingAgo($row['when']);
$row['seconds_watching_video_human'] = seconds2human($row['seconds_watching_video']);
if ($isPluginEnabled) {
$json = _json_decode($row['json']);
if (empty($json)) {
$json = new stdClass();
}
if (empty($json->location)) {
$json->location = User_Location::getLocationFromIP($row['ip']);
$vs = new VideoStatistic($row['id']);
$vs->setJson($json);
$vs->save();
}
$json->location = object_to_array($json->location);
$row['location'] = $json->location;
- $row['location_name'] = "{$json->location['country_name']}, {$json->location['city_name']}, {$json->location['region_name']}";
+ if(empty($json->location['country_name']) || $json->location['country_name'] === '-'){
+ $row['location_name'] = $row['ip'];
+ }else{
+ $row['location_name'] = "{$json->location['country_name']}, {$json->location['city_name']}, {$json->location['region_name']}";
+ }
+
} else {
$row['location_name'] = $row['location'] = '';
}
$rows[] = $row;
}
} else {
die($sql . '\nError : (' . $global['mysqli']->errno . ') ' . $global['mysqli']->error);
}
return $rows;
}
public static function getTotalFromVideos_id($videos_id) {
global $global;
if (!static::isTableInstalled()) {
return false;
}
$videos_id = intval($videos_id);
if (empty($videos_id)) {
return false;
}
$sql = "SELECT count(id) as total FROM " . static::getTableName() . " WHERE videos_id=$videos_id ";
$sql .= self::getSqlSearchFromPost();
//echo $sql;//exit;
$res = sqlDAL::readSql($sql);
$result = sqlDAL::fetchAssoc($res);
if (!empty($result)) {
return intval($result['total']);
}
return 0;
}
}