tyler.durden/pandorafms
1
0
Fork 0
mirror of https://github.com/pandorafms/pandorafms.git synced 2025-07-28 00:04:37 +02:00
Code Issues Packages Projects Releases Wiki Activity

Added new cron functions to console

Browse Source
This commit is contained in:
fermin831 2017-11-23 12:30:04 +01:00
parent 98a343a3b3
commit 00bdcf5996
1 changed files with 194 additions and 76 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

270
pandora_console/include/functions_cron.php
View File

@ -30,24 +30,30 @@ function cron_update_module_interval ($module_id, $cron) {
$module_interval = db_get_value_filter('module_interval','tagente_modulo',array("id_agente_modulo" => $module_id)); $module_interval = db_get_value_filter('module_interval','tagente_modulo',array("id_agente_modulo" => $module_id));
return db_process_sql ('UPDATE tagente_estado SET current_interval = ' . $module_interval . ' WHERE id_agente_modulo = ' . (int) $module_id); return db_process_sql ('UPDATE tagente_estado SET current_interval = ' . $module_interval . ' WHERE id_agente_modulo = ' . (int) $module_id);
} else { } else {
return db_process_sql ('UPDATE tagente_estado SET current_interval = ' . cron_next_execution ($cron) . ' WHERE id_agente_modulo = ' . (int) $module_id); return db_process_sql (
'UPDATE tagente_estado SET current_interval = ' .
cron_next_execution ($cron, $module_interval, $module_id) .
' WHERE id_agente_modulo = ' .
(int) $module_id)
;
} }
} }
// Get the number of seconds left to the next execution of the given cron entry. // Get the number of seconds left to the next execution of the given cron entry.
function cron_next_execution ($cron) { function cron_next_execution ($cron, $module_interval, $module_id) {
// Get day of the week and month from cron config // Get day of the week and month from cron config
list ($minute, $hour, $mday, $month, $wday) = explode (" ", $cron); list ($minute, $hour, $mday, $month, $wday) = explode (" ", $cron);
// Get current time // Get last execution time
$cur_time = time(); $last_execution = db_get_value('utimestamp', 'tagente_estado', 'id_agente_modulo', $module_id);
$cur_time = ($last_execution !== false) ? $last_execution : time();
// Any day of the way // Any day of the way
if ($wday == '*') { if ($wday == '*') {
$nex_time = cron_next_execution_date ($cron, $cur_time); $nex_time = cron_next_execution_date ($cron, $cur_time, $module_interval);
return $nex_time - $cur_time; return $nex_time - $cur_time;
} }
@ -55,7 +61,7 @@ function cron_next_execution ($cron) {
$count = 0; $count = 0;
$nex_time = $cur_time; $nex_time = $cur_time;
do { do {
$nex_time = cron_next_execution_date ($cron, $nex_time); $nex_time = cron_next_execution_date ($cron, $nex_time, $module_interval);
$nex_time_wd = $nex_time; $nex_time_wd = $nex_time;
list ($nex_mon, $nex_wday) = explode (" ", date ("m w", $nex_time_wd)); list ($nex_mon, $nex_wday) = explode (" ", date ("m w", $nex_time_wd));
@ -80,90 +86,202 @@ function cron_next_execution ($cron) {
} }
// Get the next execution date for the given cron entry in seconds since epoch. // Get the next execution date for the given cron entry in seconds since epoch.
function cron_next_execution_date ($cron, $cur_time = false) { function cron_next_execution_date ($cron, $cur_time = false, $module_interval = 300) {
// Get cron configuration // Get cron configuration
list ($min, $hour, $mday, $mon, $wday) = explode (" ", $cron); $cron_array = explode (" ", $cron);
// Months start from 0 // Months start from 0
if ($mon != '*') { if ($cron_array[3] != '*') {
$mon -= 1; $mon_s = cron_get_interval ($cron_array[3]);
if ($mon_s['up'] !== false) {
$cron_array[3] = $mon_s['down'] - 1 . "-" . $mon_s['up'] - 1;
} else {
$cron_array[3] = $mon_s['down'] - 1;
}
} }
// Get current time // Get current time
if ($cur_time === false) { if ($cur_time === false) $cur_time = time();
$cur_time = time();
} $nex_time = $cur_time + $module_interval;
list ($cur_min, $cur_hour, $cur_mday, $cur_mon, $cur_year) = explode (" ", date ("i H d m Y", $cur_time)); $nex_time_array = explode (" ", date ("i H d m Y", $nex_time));
if (cron_is_in_cron($cron_array, $nex_time_array)) return $nex_time;
// Get first next date candidate from cron configuration // Get first next date candidate from next cron configuration
$nex_min = $min; // Initialize some vars
$nex_hour = $hour; $prev_ovfl = false;
$nex_mday = $mday;
$nex_mon = $mon; // Update minutes
$nex_year = $cur_year; $min_s = cron_get_interval ($cron_array[0]);
$nex_time_array[0] = ($min_s['down'] == '*') ? 0 : $min_s['down'];
// Replace wildcards $nex_time = cron_valid_date($nex_time_array);
if ($min == '*') { if ($nex_time >= $cur_time) {
if ($hour != '*' || $mday != '*' || $wday != '*' || $mon != '*') { if (cron_is_in_cron($cron_array, $nex_time_array) && $nex_time) {
$nex_min = 0; return $nex_time;
}
else {
$nex_min = $cur_min;
} }
} }
if ($hour == '*') {
if ($mday != '*' || $wday != '*' ||$mon != '*') { // Check if next hour is in cron
$nex_hour = 0; $nex_time_array[1]++;
} $nex_time = cron_valid_date($nex_time_array);
else {
$nex_hour = $cur_hour; if ($nex_time === false) {
} // Update the month day if overflow
} $prev_ovfl = true;
if ($mday == '*') { $nex_time_array[1] = 0;
if ($mon != '*') { $nex_time_array[2]++;
$nex_mday = 1; $nex_time = cron_valid_date($nex_time_array);
} if ($nex_time === false) {
else { // Update the month if overflow
$nex_mday = $cur_mday; $nex_time_array[2] = 1;
} $nex_time_array[3]++;
} $nex_time = cron_valid_date($nex_time_array);
if ($mon == '*') { if ($nex_time === false) {
$nex_mon = $cur_mon; #Update the year if overflow
} $nex_time_array[3] = 0;
$nex_time_array[4]++;
// Find the next execution date $nex_time = cron_valid_date($nex_time_array);
$count = 0;
do {
$next_time = mktime($nex_hour, $nex_min, 0, $nex_mon, $nex_mday, $nex_year);
if ($next_time > $cur_time) {
return $next_time;
}
if ($min == '*' && $hour == '*' && $wday == '*' && $mday == '*' && $mon == '*') {
list ($nex_min, $nex_hour, $nex_mday, $nex_mon, $nex_year) = explode (" ", date ("i H d m Y", $next_time + SECONDS_1MINUTE));
}
else if ($hour == '*' && $wday == '*' && $mday == '*' && $mon == '*') {
list ($nex_min, $nex_hour, $nex_mday, $nex_mon, $nex_year) = explode (" ", date ("i H d m Y", $next_time + SECONDS_1HOUR));
}
else if ($mday == '*' && $mon == '*') {
list ($nex_min, $nex_hour, $nex_mday, $nex_mon, $nex_year) = explode (" ", date ("i H d m Y", $next_time + SECONDS_1DAY));
}
else if ($mon == '*') {
$nex_mon = $nex_mon + 1;
if ($nex_mon > 11) {
$nex_mon = 0;
$nex_year++;
} }
} }
else {
$nex_year++;
}
$count++;
} }
while ($count < SECONDS_1DAY); // Check the hour
if (cron_is_in_cron($cron_array, $nex_time_array) && $nex_time) {
return $nex_time;
}
// Update the hour if fails
$hour_s = cron_get_interval ($cron_array[1]);
$nex_time_array[1] = ($hour_s['down'] == '*') ? 0 : $hour_s['down'];
// When an overflow is passed check the hour update again
if ($prev_ovfl) {
$nex_time = cron_valid_date($nex_time_array);
if (cron_is_in_cron($cron_array, $nex_time_array) && $nex_time) {
return $nex_time;
}
}
$prev_ovfl = false;
// Check if next day is in cron
$nex_time_array[2]++;
$nex_time = cron_valid_date($nex_time_array);
if ($nex_time === false) {
// Update the month if overflow
$prev_ovfl = true;
$nex_time_array[2] = 1;
$nex_time_array[3]++;
$nex_time = cron_valid_date($nex_time_array);
if ($nex_time === false) {
// Update the year if overflow
$nex_time_array[3] = 0;
$nex_time_array[4]++;
$nex_time = cron_valid_date($nex_time_array);
}
}
// Check the day
if (cron_is_in_cron($cron_array, $nex_time_array) && $nex_time) {
return $nex_time;
}
// Update the day if fails
$mday_s = cron_get_interval ($cron_array[2]);
$nex_time_array[2] = ($mday_s['down'] == '*') ? 1 : $mday_s['down'];
// When an overflow is passed check the hour update in the next execution
if ($prev_ovfl) {
$nex_time = cron_valid_date($nex_time_array);
if (cron_is_in_cron($cron_array, $nex_time_array) && $nex_time) {
return $nex_time;
}
}
$prev_ovfl = false;
// Check if next month is in cron
$nex_time_array[3]++;
$nex_time = cron_valid_date($nex_time_array);
if ($nex_time === false) {
#Update the year if overflow
$prev_ovfl = true;
$nex_time_array[3]++;
$nex_time = cron_valid_date($nex_time_array);
}
// Check the month
if (cron_is_in_cron($cron_array, $nex_time_array) && $nex_time) {
return $nex_time;
}
// Update the month if fails
$mon_s = cron_get_interval ($cron_array[3]);
$nex_time_array[3] = ($mon_s['down'] == '*') ? 0 : $mon_s['down'];
// When an overflow is passed check the hour update in the next execution
if ($prev_ovfl) {
$nex_time = cron_valid_date($nex_time_array);
if (cron_is_in_cron($cron_array, $nex_time_array) && $nex_time) {
return $nex_time;
}
}
// Update the year
$nex_time_array[4]++;
$nex_time = cron_valid_date($nex_time_array);
return ($nex_time !== false) ? $nex_time : $module_interval;
}
// Get an array with the cron interval
function cron_get_interval ($element) {
# Not a range
if (!preg_match('/(\d+)\-(\d+)/', $element, $capture)) {
return array(
'down' => $element,
'up' => false
);
}
return array(
'down' => $capture[1],
'up' => $capture[2]
);
}
// Returns if a date is in a cron. Recursive.
function cron_is_in_cron($elems_cron, $elems_curr_time) {
// Something went wrong, default to 5 minutes $elem_cron = array_shift($elems_cron);
return $cur_time + SECONDS_5MINUTES; $elem_curr_time = array_shift($elems_curr_time);
// If there is no elements means that is in cron
if ($elem_cron === null || $elem_curr_time === null) return true;
// Go to last element if current is a wild card
if ($elem_cron != '*') {
$elem_s = cron_get_interval($elem_cron);
// Check if there is no a range
if (($elem_s['up'] === false) && ($elem_s['down'] != $elem_curr_time)) {
return false;
}
// Check if there is on the range
if ($elem_s['up'] !== false) {
if ($elem_s['down'] < $elem_s['up']) {
if ($elem_curr_time < $elem_s['down'] || $elem_curr_time > $elem_s['up']){
return false;
}
} else {
if ($elem_curr_time > $elem_s['down'] || $elem_curr_time < $elem_s['up']){
return false;
}
}
}
}
return cron_is_in_cron($elems_cron, $elems_curr_time);
}
function cron_valid_date ($da) {
$st = sprintf("%04d:%02d:%02d %02d:%02d:00", $da[4], $da[3], $da[2], $da[1], $da[0]);
$time = strtotime($st);
return $time;
} }
// Check if cron is properly constructed // Check if cron is properly constructed