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

Add more fields

Browse source
This commit is contained in:
Daniel 2021-10-15 09:51:34 -03:00
parent e997fc7bbc
commit c336e93ad9
2 changed files with 41 additions and 19 deletions
Download patch file Download diff file Expand all files Collapse all files

58
plugin/Scheduler/Objects/Scheduler_commands.php
View file

@ -9,9 +9,9 @@ class Scheduler_commands extends ObjectYPT {
public static $statusCanceled = 'c';
public static $statusExecuted = 'e';
public static $statusRepeat = 'r';
protected $id, $callbackURL, $parameters, $date_to_execute, $executed_in,
protected $id, $callbackURL, $parameters, $date_to_execute, $executed_in,
$status, $callbackResponse, $timezone,
$repeat_minute, $repeat_hour, $repeat_day_of_month, $repeat_month,
$repeat_minute, $repeat_hour, $repeat_day_of_month, $repeat_month,
$repeat_day_of_week, $type;
static function getSearchFieldsNames() {
@ -27,20 +27,20 @@ class Scheduler_commands extends ObjectYPT {
if (!static::isTableInstalled()) {
return false;
}
$sql = "SELECT * FROM " . static::getTableName() . " WHERE status='".self::$statusRepeat."' ";
$sql = "SELECT * FROM " . static::getTableName() . " WHERE status='" . self::$statusRepeat . "' ";
$minute = intval(date('i'));
$hour = intval(date('H'));
$day_of_month = intval(date('d'));
$month = intval(date('m'));
$day_of_week = intval(date('w'));
$sql .= " AND (repeat_minute IS NULL OR repeat_minute = {$minute}) ";
$sql .= " AND (repeat_hour IS NULL OR repeat_hour = {$hour}) ";
$sql .= " AND (repeat_day_of_month IS NULL OR repeat_day_of_month = {$day_of_month}) ";
$sql .= " AND (repeat_month IS NULL OR repeat_month = {$month}) ";
$sql .= " AND (repeat_minute IS NULL OR repeat_minute = {$minute}) ";
$sql .= " AND (repeat_hour IS NULL OR repeat_hour = {$hour}) ";
$sql .= " AND (repeat_day_of_month IS NULL OR repeat_day_of_month = {$day_of_month}) ";
$sql .= " AND (repeat_month IS NULL OR repeat_month = {$month}) ";
$sql .= " AND (repeat_day_of_week IS NULL OR repeat_day_of_week = {$day_of_week}) ";
//echo $sql;exit;
$res = sqlDAL::readSql($sql);
$fullData = sqlDAL::fetchAllAssoc($res);
@ -61,8 +61,8 @@ class Scheduler_commands extends ObjectYPT {
if (!static::isTableInstalled()) {
return false;
}
$sql = "SELECT * FROM " . static::getTableName() . " WHERE status='".self::$statusActive."' AND date_to_execute <= now() ";
$sql = "SELECT * FROM " . static::getTableName() . " WHERE status='" . self::$statusActive . "' AND date_to_execute <= now() ";
//echo $sql;
$res = sqlDAL::readSql($sql);
$fullData = sqlDAL::fetchAllAssoc($res);
@ -143,8 +143,8 @@ class Scheduler_commands extends ObjectYPT {
}
$this->setExecuted_in(date('Y-m-d H:i:s'));
$this->setCallbackResponse($callbackResponse);
if($this->status !== self::$statusRepeat){
if ($this->status !== self::$statusRepeat) {
$this->setStatus(self::$statusExecuted);
}
return $this->save();
@ -226,7 +226,7 @@ class Scheduler_commands extends ObjectYPT {
function setRepeat_month($repeat_month) {
$this->repeat_month = intval($repeat_month);
}
function getType() {
return $this->type;
}
@ -234,7 +234,7 @@ class Scheduler_commands extends ObjectYPT {
function setType($type) {
$this->type = $type;
}
function getRepeat_day_of_week() {
return $this->repeat_day_of_week;
}
@ -242,7 +242,7 @@ class Scheduler_commands extends ObjectYPT {
function setRepeat_day_of_week($repeat_day_of_week) {
$this->repeat_day_of_week = $repeat_day_of_week;
}
public static function deleteFromType($type) {
global $global;
if (!empty($type)) {
@ -253,14 +253,14 @@ class Scheduler_commands extends ObjectYPT {
}
return false;
}
public static function getAllFromType($type) {
global $global;
if (!static::isTableInstalled()) {
return false;
}
$sql = "SELECT * FROM " . static::getTableName() . " WHERE type=? ";
//echo $sql;
$res = sqlDAL::readSql($sql, 's', array($type));
$fullData = sqlDAL::fetchAllAssoc($res);
@ -276,4 +276,26 @@ class Scheduler_commands extends ObjectYPT {
return $rows;
}
public static function getAllActiveOrToRepeat() {
global $global;
if (!static::isTableInstalled()) {
return false;
}
$sql = "SELECT * FROM " . static::getTableName() . " WHERE status='" . (self::$statusActive) . "' OR status='" . (self::$statusRepeat) . "' ";
$sql .= self::getSqlFromPost();
$res = sqlDAL::readSql($sql);
$fullData = sqlDAL::fetchAllAssoc($res);
sqlDAL::close($res);
$rows = array();
if ($res != false) {
foreach ($fullData as $row) {
$rows[] = $row;
}
} else {
die($sql . '\nError : (' . $global['mysqli']->errno . ') ' . $global['mysqli']->error);
}
return $rows;
}
}

2
plugin/Scheduler/run.php
View file

@ -11,7 +11,7 @@ if(!AVideoPlugin::isEnabledByName('Scheduler')){
return die('Scheduler is disabled');
}
$rowActive = Scheduler_commands::getAllActive();
$rowActive = Scheduler_commands::getAllActiveOrToRepeat();
$total = count($rowActive);
_log("There are {$total} active requests");