add watcher if order is blocked to processing status

Staff plugin-logistique
,
1

add watcher if order is blocked to processing status

diff --git a/core/class/logistique.class.php b/core/class/logistique.class.php
index 74c2494..0a7e452 100644
--- a/core/class/logistique.class.php
+++ b/core/class/logistique.class.php
@@ -2852,9 +2852,37 @@ class logistique extends eqLogic {
         }
     }
 
+    public static function watchQueueBLS() {
+        $path = __DIR__.'/../../data/queue/';
+
+        $files = scandir($path);
+        foreach($files as $file){
+            if($file == '.' || $file == '..') continue;
+            $file = $path.$file;
+            $extension = pathinfo($file, PATHINFO_EXTENSION);
+            //On ne veut traiter que les fichiers différents de .start
+            if($extension == 'start') continue;
+
+            //on recupere le contenu du fichier
+            $fileProcessing = file_get_contents($file);
+            $fileProcessing = json_decode($fileProcessing, true);
+            $timeSendQueue = $fileProcessing['time'];
+            $timeNow = time();
+            //Si le fichier est en attente depuis plus de 5 minutes on le repasse en start et on change la valeur de time
+            if($timeNow - $timeSendQueue > 300) {
+                log::add('logistique', 'info', 'Fichier en attente depuis plus de 5 minutes '.$file.' je le repasse .start');
+                $fileProcessing['time'] = $timeNow;
+                file_put_contents($file, json_encode($fileProcessing));
+                $fileWithoutExtension = pathinfo($file, PATHINFO_FILENAME);
+                rename($file, $fileWithoutExtension . '.start');
+            }
+        }
+    }
+
     public static function cron5() {
         self::queueErrorGenerateLabelWorker();
         self::updateGlobalsCounter();
+        self::watchQueueBLS();
     }
 
     public static function cron15() {

GitHub
sha: 4ca071437f8b316f76931d9419c4368af0a77de2