refactor: ottimizzazione importazione ricevute per evitare interruzioni in caso di ricevuta di scarto

Author: Pek5892

plugins/receiptFE/src/MissingReceiptTask.php

@@ -56,7 +56,16 @@ public function execute()
             foreach ($ricevute as $ricevuta) {
                 $name = $ricevuta['name'];
 
-                Ricevuta::process($name);
+                try {
+                    Ricevuta::process($name);
+                } catch (\Throwable $e) {
+                    $this->task->log('error', 'Errore importazione ricevuta FE mancante', [
+                        'file' => $name,
+                        'id_fattura' => $fattura->id,
+                        'message' => $e->getMessage(),
+                        'trace' => $e->getTraceAsString(),
+                    ]);
+                }
             }
         }
     }

plugins/receiptFE/src/ReceiptTask.php

@@ -69,6 +69,7 @@ public function execute()
         // Caricamento elenco di ricevute imporate
         $completed = $completed_cache->content;
         $count = (is_array($todo) ? count($todo) : 0);
+        $errors = 0;
 
         // Esecuzione di 10 imporazioni
         for ($i = 0; $i < 25 && $i < $count; ++$i) {
@@ -77,7 +78,18 @@ public function execute()
             if ($element !== null) {
                 // Importazione ricevuta
                 $name = $element['name'];
-                $fattura = Ricevuta::process($name);
+                try {
+                    $fattura = Ricevuta::process($name);
+                } catch (\Throwable $e) {
+                    ++$errors;
+                    $this->task->log('error', 'Errore importazione ricevuta FE', [
+                        'file' => $name,
+                        'message' => $e->getMessage(),
+                        'trace' => $e->getTraceAsString(),
+                    ]);
+
+                    continue;
+                }
 
                 if ($fattura !== null) {
                     $completed[] = $element;
@@ -97,11 +109,11 @@ public function execute()
             ];
         }
 
-        // Esecuzione dell'importazione
-        foreach ($list as $element) {
-            $name = $element['name'];
-
-            Ricevuta::process($name);
+        if ($errors > 0) {
+            $result = [
+                'response' => 2,
+                'message' => tr('Importazione completata con errori su alcune ricevute'),
+            ];
         }
 
         return $result;

plugins/receiptFE/src/Ricevuta.php

@@ -202,6 +202,33 @@ public function saveAllegato($codice)
         return $upload;
     }
 
+    /**
+     * Restituisce la lista normalizzata degli errori presenti nella ricevuta.
+     *
+     * @return array
+     */
+    protected function getListaErrori()
+    {
+        $lista_errori = $this->xml['ListaErrori']['Errore'] ?? [];
+        if (empty($lista_errori) || !is_array($lista_errori)) {
+            return [];
+        }
+
+        return XML::forceArray($lista_errori);
+    }
+
+    /**
+     * Restituisce il primo errore disponibile nella ricevuta.
+     *
+     * @return array
+     */
+    protected function getErrorePrincipale()
+    {
+        $lista_errori = $this->getListaErrori();
+
+        return $lista_errori[0] ?? [];
+    }
+
     /**
      * Aggiorna lo stato della fattura relativa alla ricevuta in modo tale da rispecchiare i dati richiesti.
      */
@@ -216,6 +243,9 @@ public function saveStato($codice, $id_allegato)
         }
 
         $descrizione = null;
+        $suggerimento = null;
+        $errore_principale = $this->getErrorePrincipale();
+
         // Processo la ricevuta e salvo data ricezione, codice e messaggio
         switch ($codice) {
             case 'RC':
@@ -245,8 +275,8 @@ public function saveStato($codice, $id_allegato)
                 break;
             case 'NS':
                 // Scartata
-                $descrizione = $this->xml['ListaErrori']['Errore']['Descrizione'];
-                $suggerimento = $this->xml['ListaErrori']['Errore']['Suggerimento'];
+                $descrizione = $errore_principale['Descrizione'] ?? null;
+                $suggerimento = $errore_principale['Suggerimento'] ?? null;
                 break;
             default:
                 // Codice non gestito
@@ -256,7 +286,7 @@ public function saveStato($codice, $id_allegato)
 
         // Se la fattura presenta già una ricevuta principale con un codice che non di scarto e il codice delle ricevuta da importare è 00404 (Fattura duplicata), non aggiorno la ricevuta.
         $codici_scarto = ['EC02', 'ERR', 'ERVAL', 'NS'];
-        if ($this->xml['ListaErrori']['Errore']['Codice'] == 00404 && !empty($fattura->id_ricevuta_principale) && !in_array($fattura->codice_stato_fe, $codici_scarto)) {
+        if (($errore_principale['Codice'] ?? null) == '00404' && !empty($fattura->id_ricevuta_principale) && !in_array($fattura->codice_stato_fe, $codici_scarto)) {
             return;
         }
         $data = $this->xml['DataOraRicezione'];
@@ -282,9 +312,10 @@ public function save($cambia_stato = true)
         // Individuazione codice per il nome dell'allegato
         $codice_nome = $codice_stato;
         if ($codice_nome == 'NS') {
-            $lista_errori = $this->xml['ListaErrori'];
-            $errore = $lista_errori[0] ?: $lista_errori;
-            $codice_nome = $codice_nome.' - '.$errore['Errore']['Codice'];
+            $errore = $this->getErrorePrincipale();
+            if (!empty($errore['Codice'])) {
+                $codice_nome = $codice_nome.' - '.$errore['Codice'];
+            }
         }
 
         $upload = $this->saveAllegato($codice_nome);