yetangitu/Oinktube
1
0
Fork 0
mirror of https://github.com/DanielnetoDotCom/YouPHPTube synced 2025-10-06 03:50:04 +02:00
Code Issues Releases Wiki Activity

Improve scheduler

Browse source
This commit is contained in:
Daniel 2021-10-15 09:58:13 -03:00
parent c336e93ad9
commit dccbd88e36
2 changed files with 24 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -21,6 +21,22 @@ class Scheduler_commands extends ObjectYPT {
static function getTableName() {
return 'scheduler_commands';
}
public static function getTimesNow() {
$minute = intval(date('i'));
$hour = intval(date('H'));
$day_of_month = intval(date('d'));
$month = intval(date('m'));
$day_of_week = intval(date('w'));
return array(
'minute'=>$minute,
'hour'=>$hour,
'day_of_month'=>$day_of_month,
'month'=>$month,
'day_of_week'=>$day_of_week,
);
}
public static function getAllScheduledTORepeat() {
global $global;
@ -29,17 +45,13 @@ class Scheduler_commands extends ObjectYPT {
}
$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'));
$times = self::getTimesNow();
$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}) ";
$sql .= " AND (repeat_minute IS NULL OR repeat_minute = {$times['minute']}) ";
$sql .= " AND (repeat_hour IS NULL OR repeat_hour = {$times['hour']}) ";
$sql .= " AND (repeat_day_of_month IS NULL OR repeat_day_of_month = {$times['day_of_month']}) ";
$sql .= " AND (repeat_month IS NULL OR repeat_month = {$times['month']}) ";
$sql .= " AND (repeat_day_of_week IS NULL OR repeat_day_of_week = {$times['day_of_week']}) ";
//echo $sql;exit;
$res = sqlDAL::readSql($sql);

2
plugin/Scheduler/run.php
View file

@ -16,6 +16,7 @@ $total = count($rowActive);
_log("There are {$total} active requests");
$rows = Scheduler_commands::getAllActiveAndReady();
_log("getAllActiveAndReady found ".count($rows));
foreach ($rows as $value) {
$id = Scheduler::run($value['id']);
if(empty($id)){
@ -25,6 +26,7 @@ foreach ($rows as $value) {
$rows = Scheduler_commands::getAllScheduledTORepeat();
_log("getAllScheduledTORepeat found ".count($rows) . ' on time '. json_encode(Scheduler_commands::getTimesNow()));
foreach ($rows as $value) {
$id = Scheduler::run($value['id']);
if(empty($id)){