Miglioramento delle tasks

cron.php

@@ -9,10 +9,10 @@
 // Schema crontab: "*/5 * * * * php <percorso_root>/cron.php"
 
 use Carbon\Carbon;
+use Cron\CronExpression;
 use Models\Cache;
 use Monolog\Handler\RotatingFileHandler;
 use Monolog\Logger;
-use Tasks\CronExpression;
 use Tasks\Task;
 
 // Rimozione delle limitazioni sull'esecuzione
@@ -39,7 +39,7 @@ $pattern = '[%datetime%] %level_name%: %message% %context%'.PHP_EOL;
 $formatter = new Monolog\Formatter\LineFormatter($pattern);
 
 $logger = new Logger('Tasks');
-$handler = new RotatingFileHandler(DOCROOT.'/logs/cron.log', 0);
+$handler = new RotatingFileHandler(DOCROOT.'/logs/cron.log', 7);
 $handler->setFormatter($formatter);
 $logger->pushHandler($handler);
 
@@ -47,13 +47,19 @@ $logger->pushHandler($handler);
 $ultima_esecuzione = Cache::get('Ultima esecuzione del cron');
 $data = $ultima_esecuzione->content;
 
+$riavvia = Cache::get('Riavvia cron');
+$disattiva = Cache::get('Disabilita cron');
+if (!empty($disattiva->content)) {
+    return;
+}
+
 // Impostazioni sugli slot di esecuzione
 $slot_duration = 5;
 
 // Controllo sull'ultima esecuzione
 $data = $data ? new Carbon($data) : null;
 $minimo_esecuzione = (new Carbon())->addMinutes($slot_duration * 5);
-if (!empty($data) && $data->greaterThanOrEqualTo($minimo_esecuzione)) {
+if (!empty($data) && $minimo_esecuzione->greaterThanOrEqualTo($data)) {
     return;
 }
 
@@ -61,47 +67,69 @@ if (!empty($data) && $data->greaterThanOrEqualTo($minimo_esecuzione)) {
 $adesso = new Carbon();
 $ultima_esecuzione->set($adesso->__toString());
 
-// Calcolo del primo slot disponibile
+// Prima esecuzione immediata
-$adesso = new Carbon();
+$slot_minimo = $adesso->copy();
-$slot = (new Carbon())->startOfHour();
-while ($adesso->greaterThanOrEqualTo($slot)) {
-    $slot->addMinutes($slot_duration);
-}
 
 // Esecuzione ricorrente
 $number = 1;
 while (true) {
-    // Risveglio programmato tramite slot
+    $riavvia->refresh();
-    $timestamp = $slot->getTimestamp();
+    $disattiva->refresh();
-    time_sleep_until($timestamp);
 
     // Controllo su possibili aggiornamenti per bloccare il sistema
     $database_online = $database->isInstalled() && !Update::isUpdateAvailable();
-    if (!$database_online) {
+    if (!$database_online || !empty($disattiva->content) || !empty($riavvia->content)) {
         return;
     }
 
-    // Registrazione nei log
+    // Risveglio programmato tramite slot
-    $logger->info('Cron #'.$number.' (slot timestamp: '.$timestamp.')');
+    $timestamp = $slot_minimo->getTimestamp();
+    time_sleep_until($timestamp);
+
+    // Registrazione dell'iterazione nei log
+    $logger->info('Cron #'.$number.' iniziato', [
+        'slot' => $slot_minimo->toDateTimeString(),
+        'slot-unix' => $timestamp,
+    ]);
+
+    // Calcolo del primo slot disponibile per l'esecuzione successiva
+    $inizio_iterazione = new Carbon();
+    $slot_minimo = $inizio_iterazione->copy()->startOfHour();
+    while ($inizio_iterazione->greaterThanOrEqualTo($slot_minimo)) {
+        $slot_minimo->addMinutes($slot_duration);
+    }
 
     // Aggiornamento dei cron disponibili
     $tasks = Task::all();
     foreach ($tasks as $task) {
+        $adesso = new Carbon();
+
+        // Individuazione delle informazioni previste dalla relativa espressione
         $cron = CronExpression::factory($task->expression);
+        $data_successiva = Carbon::instance($cron->getNextRunDate($adesso));
 
         // Esecuzione diretta solo nel caso in cui sia prevista
-        if ($cron->isDue()) {
+        if ($cron->isDue($inizio_iterazione) || $cron->isDue($adesso)) {
+            // Registrazione dell'esecuzione nei log
+            $logger->info($task->name.': '.$task->expression);
+
             $task->execute();
         }
+
+        // Calcolo dello successivo slot
+        if ($data_successiva->lessThan($slot_minimo)) {
+            $slot_minimo = $data_successiva;
+        }
     }
 
+    // Registrazione dello slot successivo nei log
+    $logger->info('Cron #'.$number.' concluso', [
+        'next-slot' => $slot_minimo->toDateTimeString(),
+        'next-slot-unix' => $timestamp,
+    ]);
+
     // Registrazione dell'esecuzione
     $adesso = new Carbon();
     $ultima_esecuzione->set($adesso->__toString());
-
-    // Individuazione dello slot di 5 minuti per l'esecuzione successiva
-    while ($adesso->greaterThanOrEqualTo($slot)) {
-        $slot->addMinutes($slot_duration);
-    }
     ++$number;
 }

modules/backups/src/BackupHook.php

@@ -1,41 +0,0 @@
-<?php
-
-namespace Modules\Backups;
-
-use Backup;
-use Hooks\Manager;
-
-/**
- * Hook dedicato alla gestione del backup giornaliero automatico, se abilitato da Impostazioni.
- */
-class BackupHook extends Manager
-{
-    public function isSingleton()
-    {
-        return true;
-    }
-
-    public function needsExecution()
-    {
-        return setting('Backup automatico') && !Backup::isDailyComplete();
-    }
-
-    public function execute()
-    {
-        $result = Backup::daily();
-
-        return $result;
-    }
-
-    public function response()
-    {
-        $show = boolval(setting('Backup automatico')) && !Backup::isDailyComplete();
-        $message = $show ? tr('Backup in corso...') : tr('Backup automatico completato!');
-
-        return [
-            'icon' => 'fa fa-file-o text-success',
-            'message' => $message,
-            'show' => $show,
-        ];
-    }
-}

modules/backups/src/BackupTask.php

@@ -0,0 +1,24 @@
+<?php
+
+namespace Modules\Backups;
+
+use Backup;
+use Tasks\Manager;
+
+/**
+ * Task dedicato alla gestione del backup giornaliero automatico, se abilitato da Impostazioni.
+ */
+class BackupTask extends Manager
+{
+    public function needsExecution()
+    {
+        return setting('Backup automatico') && !Backup::isDailyComplete();
+    }
+
+    public function execute()
+    {
+        if (setting('Backup automatico') && !Backup::isDailyComplete()) {
+            Backup::daily();
+        }
+    }
+}

update/2_4_18.sql

@@ -9,4 +9,11 @@ CREATE TABLE IF NOT EXISTS `zz_tasks` (
 ) ENGINE=InnoDB;
 
 INSERT INTO `zz_cache` (`id`, `name`, `content`, `valid_time`, `expire_at`) VALUES
-(NULL, 'Ultima esecuzione del cron', '', '1 month', NULL);
+(NULL, 'Ultima esecuzione del cron', '', '1 month', NULL),
+(NULL, 'Riavvia cron', '', '1 month', NULL),
+(NULL, 'Disabilita cron', '', '1 month', NULL);
+
+INSERT INTO `zz_tasks` (`id`, `name`, `class`, `expression`, `last_executed_at`) VALUES
+(NULL, 'Backup automatico', 'Modules\\Backups\\BackupTask', '0 0 * * *', NULL);
+
+DELETE FROM `zz_hooks` WHERE `class` = 'Modules\\Backups\\BackupHook';