yetangitu/Oinktube
1
0
Fork 0
mirror of https://github.com/DanielnetoDotCom/YouPHPTube synced 2025-10-03 01:39:24 +02:00
Code Issues Releases Wiki Activity
Oinktube/objects/video_statistic.php
DanielnetoDotCom 2153147be4 Improve json_decode
2021-04-15 09:10:29 -03:00

430 lines
15 KiB
PHP
Raw Blame History

<?php
global $global, $config;
if (!isset($global['systemRootPath'])) {
require_once '../videos/configuration.php';
}
require_once $global['systemRootPath'] . 'objects/bootGrid.php';
require_once $global['systemRootPath'] . 'objects/user.php';
require_once $global['systemRootPath'] . 'objects/functions.php';
class VideoStatistic extends ObjectYPT
{
protected $id;
protected $when;
protected $ip;
protected $users_id;
protected $videos_id;
protected $lastVideoTime;
protected $session_id;
public static function getSearchFieldsNames()
{
return array();
}
public static function getTableName()
{
return 'videos_statistics';
}
public static function create($videos_id, $currentTime = 0)
{
global $global;
/**
* Dont crash if is an old version
$res = sqlDAL::readSql("SHOW TABLES LIKE 'videos_statistics'");
$result = sqlDal::num_rows($res);
sqlDAL::close($res);
if (empty($result)) {
echo "<div class='alert alert-danger'>You need to <a href='{$global['webSiteRootURL']}update'>update your system</a></div>";
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)
{
$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();
}
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');
}
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 "<hr>".$row['total']." --- ".$sql, "<br>";
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 (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;
}
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 (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;
}
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;
// 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);
$channels = array();
if ($res != false) {
$channelsPerUser = array();
// 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'];
}
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'];
});
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.created) >= 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;
$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.created) >= DATE_SUB(DATE(NOW()), INTERVAL {$daysLimit} DAY) ";
$res2 = sqlDAL::readSql($sql2);
$result2 = sqlDAL::fetchAssoc($res2);
sqlDAL::close($res2);
if (!empty($result2)) {
return intval($result2['total']);
}
return 0;
}
}
Reference in a new issue View git blame Copy permalink