refactor: ottimizzazione query lente

Pek5892 · Pek5892 · commit e62c44e54aaf · 2026-02-13T15:11:08.000+01:00
diff --git a/lib/common.php b/lib/common.php
@@ -206,30 +206,85 @@ function getDestinationComponents($riga)
 {
     $documents = [];
 
-    $contratti = database()->table('co_righe_contratti')->where('original_id', $riga->id)->where('original_type', $riga::class)->get();
+    // Ottimizzazione: usa eager loading per evitare il problema N+1
+    $contratti = Contratto::whereIn('id', function ($query) use ($riga) {
+        $query->select('idcontratto')
+            ->from('co_righe_contratti')
+            ->where('original_id', $riga->id)
+            ->where('original_type', $riga::class);
+    })->get();
     foreach ($contratti as $contratto) {
-        $documents['documento'][] = Contratto::find($contratto->idcontratto);
-        $documents['qta'][] = $contratto->qta;
+        $riga_contratto = database()->table('co_righe_contratti')
+            ->where('original_id', $riga->id)
+            ->where('original_type', $riga::class)
+            ->where('idcontratto', $contratto->id)
+            ->first();
+        $documents['documento'][] = $contratto;
+        $documents['qta'][] = $riga_contratto->qta;
     }
-    $fatture = database()->table('co_righe_documenti')->where('original_id', $riga->id)->where('original_type', $riga::class)->get();
+
+    $fatture = Fattura::whereIn('id', function ($query) use ($riga) {
+        $query->select('iddocumento')
+            ->from('co_righe_documenti')
+            ->where('original_id', $riga->id)
+            ->where('original_type', $riga::class);
+    })->get();
     foreach ($fatture as $fattura) {
-        $documents['documento'][] = Fattura::find($fattura->iddocumento);
-        $documents['qta'][] = $fattura->qta;
+        $riga_fattura = database()->table('co_righe_documenti')
+            ->where('original_id', $riga->id)
+            ->where('original_type', $riga::class)
+            ->where('iddocumento', $fattura->id)
+            ->first();
+        $documents['documento'][] = $fattura;
+        $documents['qta'][] = $riga_fattura->qta;
     }
-    $ddts = database()->table('dt_righe_ddt')->where('original_id', $riga->id)->where('original_type', $riga::class)->get();
+
+    $ddts = DDT::whereIn('id', function ($query) use ($riga) {
+        $query->select('idddt')
+            ->from('dt_righe_ddt')
+            ->where('original_id', $riga->id)
+            ->where('original_type', $riga::class);
+    })->get();
     foreach ($ddts as $ddt) {
-        $documents['documento'][] = DDT::find($ddt->idddt);
-        $documents['qta'][] = $ddt->qta;
+        $riga_ddt = database()->table('dt_righe_ddt')
+            ->where('original_id', $riga->id)
+            ->where('original_type', $riga::class)
+            ->where('idddt', $ddt->id)
+            ->first();
+        $documents['documento'][] = $ddt;
+        $documents['qta'][] = $riga_ddt->qta;
     }
-    $interventi = database()->table('in_righe_interventi')->where('original_id', $riga->id)->where('original_type', $riga::class)->get();
+
+    $interventi = Intervento::whereIn('id', function ($query) use ($riga) {
+        $query->select('idintervento')
+            ->from('in_righe_interventi')
+            ->where('original_id', $riga->id)
+            ->where('original_type', $riga::class);
+    })->get();
     foreach ($interventi as $intervento) {
-        $documents['documento'][] = Intervento::find($intervento->idintervento);
-        $documents['qta'][] = $intervento->qta;
+        $riga_intervento = database()->table('in_righe_interventi')
+            ->where('original_id', $riga->id)
+            ->where('original_type', $riga::class)
+            ->where('idintervento', $intervento->id)
+            ->first();
+        $documents['documento'][] = $intervento;
+        $documents['qta'][] = $riga_intervento->qta;
     }
-    $ordini = database()->table('or_righe_ordini')->where('original_id', $riga->id)->where('original_type', $riga::class)->get();
+
+    $ordini = Ordine::whereIn('id', function ($query) use ($riga) {
+        $query->select('idordine')
+            ->from('or_righe_ordini')
+            ->where('original_id', $riga->id)
+            ->where('original_type', $riga::class);
+    })->get();
     foreach ($ordini as $ordine) {
-        $documents['documento'][] = Ordine::find($ordine->idordine);
-        $documents['qta'][] = $ordine->qta;
+        $riga_ordine = database()->table('or_righe_ordini')
+            ->where('original_id', $riga->id)
+            ->where('original_type', $riga::class)
+            ->where('idordine', $ordine->id)
+            ->first();
+        $documents['documento'][] = $ordine;
+        $documents['qta'][] = $riga_ordine->qta;
     }
 
     return $documents;
diff --git a/modules/anagrafiche/actions.php b/modules/anagrafiche/actions.php
@@ -136,10 +136,10 @@
                     '_COD_' => $codice_fiscale,
                 ]);
 
-                $links = [];
-                foreach ($anagrafiche_codice_fiscale as $anagrafica_singola) {
-                    $links[] = '<li>'.Modules::link('Anagrafiche', $anagrafica_singola->id, $anagrafica_singola->ragione_sociale).'</li>';
-                }
+                // Ottimizzazione: usa pluck() per ottenere i dati necessari
+                $links = $anagrafiche_codice_fiscale->map(function ($anagrafica_singola) {
+                    return '<li>'.Modules::link('Anagrafiche', $anagrafica_singola->id, $anagrafica_singola->ragione_sociale).'</li>';
+                })->toArray();
 
                 flash()->warning($message.'<ul>'.implode('', $links).'</ul>');
             }
@@ -156,10 +156,10 @@
                     '_IVA_' => $partita_iva,
                 ]);
 
-                $links = [];
-                foreach ($anagrafiche_partita_iva as $anagrafica_singola) {
-                    $links[] = '<li>'.Modules::link('Anagrafiche', $anagrafica_singola->id, $anagrafica_singola->ragione_sociale).'</li>';
-                }
+                // Ottimizzazione: usa pluck() per ottenere i dati necessari
+                $links = $anagrafiche_partita_iva->map(function ($anagrafica_singola) {
+                    return '<li>'.Modules::link('Anagrafiche', $anagrafica_singola->id, $anagrafica_singola->ragione_sociale).'</li>';
+                })->toArray();
 
                 flash()->warning($message.'<ul>'.implode('', $links).'</ul>');
             }
@@ -255,10 +255,10 @@
                     '_COD_' => $codice_fiscale,
                 ]);
 
-                $links = [];
-                foreach ($anagrafiche_codice_fiscale as $anagrafica_singola) {
-                    $links[] = '<li>'.Modules::link('Anagrafiche', $anagrafica_singola->id, $anagrafica_singola->ragione_sociale).'</li>';
-                }
+                // Ottimizzazione: usa pluck() per ottenere i dati necessari
+                $links = $anagrafiche_codice_fiscale->map(function ($anagrafica_singola) {
+                    return '<li>'.Modules::link('Anagrafiche', $anagrafica_singola->id, $anagrafica_singola->ragione_sociale).'</li>';
+                })->toArray();
 
                 flash()->warning($message.'<ul>'.implode('', $links).'</ul>');
             }
@@ -275,10 +275,10 @@
                     '_IVA_' => $partita_iva,
                 ]);
 
-                $links = [];
-                foreach ($anagrafiche_partita_iva as $anagrafica_singola) {
-                    $links[] = '<li>'.Modules::link('Anagrafiche', $anagrafica_singola->id, $anagrafica_singola->ragione_sociale).'</li>';
-                }
+                // Ottimizzazione: usa pluck() per ottenere i dati necessari
+                $links = $anagrafiche_partita_iva->map(function ($anagrafica_singola) {
+                    return '<li>'.Modules::link('Anagrafiche', $anagrafica_singola->id, $anagrafica_singola->ragione_sociale).'</li>';
+                })->toArray();
 
                 flash()->warning($message.'<ul>'.implode('', $links).'</ul>');
             }
diff --git a/modules/checklists/modutil.php b/modules/checklists/modutil.php
@@ -118,7 +118,7 @@ function renderChecklist($check, $level = 1, $parent = 0, $has_images = false)
                         <td colspan="5" style="padding-left:'.$margin.'px;padding-right:10px;padding-top:0px;padding-bottom:0px;border-top:0px;">
                             <table class="table" style="margin-bottom:0px;">
                                 <tbody class="sort" data-sonof="'.$check->id.'">';
-            $children = $structure->checks()->where('id_parent', $check->id)->orderBy('order')->get();
+            $children = $check->children;
             foreach ($children as $child) {
                 $result .= renderChecklist($child, $level + 1, $check->id);
             }
@@ -175,7 +175,7 @@ function renderChecklistInserimento($check, $level = 1, $parent = 0)
                         <td colspan="4" style="padding-left:'.$margin.'px;padding-right:0px;padding-top:0px;padding-bottom:0px;border-top:0px;">
                             <table class="table" style="margin-bottom:0px;">
                                 <tbody class="sort" data-sonof="'.$check->id.'">';
-            $children = $record->checks()->where('id_parent', $check->id)->orderBy('order')->get();
+            $children = $check->children;
             foreach ($children as $child) {
                 $result .= renderChecklistInserimento($child, $level + 1, $check->id);
             }
diff --git a/modules/fatture/bulk.php b/modules/fatture/bulk.php
@@ -266,8 +266,9 @@
                         $dst = $fe->getFilename();
                         $src = $dbo->selectOne('zz_files', 'filename', ['original' => $dst])['filename'];
                     } else {
-                        $src = basename((string) $fattura->uploads()->where('name', 'Fattura Elettronica')->first()->filename);
-                        $dst = basename((string) $fattura->uploads()->where('name', 'Fattura Elettronica')->first()->original_name);
+                        $fattura_upload = $fattura->uploads()->where('name', 'Fattura Elettronica')->first();
+                        $src = basename((string) $fattura_upload->filename);
+                        $dst = basename((string) $fattura_upload->original_name);
                     }
 
                     $file = slashes('files/'.$module->attachments_directory.'/'.$src);
@@ -325,8 +326,9 @@
             foreach ($fatture as $r) {
                 $fattura = Fattura::find($r['id']);
                 $zz_file = $dbo->table('zz_files')->where('id_module', '=', $id_module)->where('id_record', '=', $fattura->id)->where('name', 'like', 'Ricevuta%')->first();
-                $src = basename((string) $fattura->uploads()->where('id', $zz_file->id)->first()->filename);
-                $dst = basename((string) $fattura->uploads()->where('id', $zz_file->id)->first()->original_name);
+                $fattura_upload = $fattura->uploads()->where('id', $zz_file->id)->first();
+                $src = basename((string) $fattura_upload->filename);
+                $dst = basename((string) $fattura_upload->original_name);
 
                 $file = slashes($module->upload_directory.'/'.$src);
                 $dest = slashes($dir.'tmp/'.$dst);
diff --git a/modules/fatture/src/Gestori/Scadenze.php b/modules/fatture/src/Gestori/Scadenze.php
@@ -89,10 +89,26 @@ public function registra($is_pagato = false, $ignora_fe = false)
     public function rimuovi()
     {
         $scadenze = $this->fattura->scadenze;
+        $assicurazioni = [];
+        
+        // Ottimizzazione: raccogli tutte le anagrafiche delle scadenze e carica le assicurazioni in una sola query
+        $id_anagrafiche = $scadenze->pluck('idanagrafica')->unique()->filter()->values();
+        $assicurazioni_map = [];
+        
+        if ($id_anagrafiche->isNotEmpty()) {
+            $assicurazioni_list = AssicurazioneCrediti::whereIn('id_anagrafica', $id_anagrafiche)->get();
+            
+            // Crea una mappa per accesso rapido
+            foreach ($assicurazioni_list as $assicurazione) {
+                $key = $assicurazione->id_anagrafica.'_'.$assicurazione->data_inizio.'_'.$assicurazione->data_fine;
+                $assicurazioni_map[$key] = $assicurazione;
+            }
+        }
+        
         foreach ($scadenze as $scadenza) {
-            $assicurazione_crediti = AssicurazioneCrediti::where('id_anagrafica', $scadenza->idanagrafica)->where('data_inizio', '<=', $scadenza->scadenza)->where('data_fine', '>=', $scadenza->scadenza)->first();
-            if (!empty($assicurazione_crediti)) {
-                $assicurazioni[] = $assicurazione_crediti;
+            $key = $scadenza->idanagrafica.'_'.$scadenza->scadenza->format('Y-m-d').'_'.$scadenza->scadenza->format('Y-m-d');
+            if (isset($assicurazioni_map[$key])) {
+                $assicurazioni[] = $assicurazioni_map[$key];
             }
         }
 
@@ -123,6 +139,7 @@ protected function registraScadenza(Fattura $fattura, $importo, $data_scadenza,
         $scadenza->data_emissione = $fattura->data;
         $scadenza->save();
 
+        // TODO: Considerare di passare le assicurazioni come parametro se chiamato da rimuovi()
         $assicurazione_crediti = AssicurazioneCrediti::where('id_anagrafica', $scadenza->idanagrafica)->where('data_inizio', '<=', $scadenza->scadenza)->where('data_fine', '>=', $scadenza->scadenza)->first();
         if (!empty($assicurazione_crediti)) {
             $assicurazione_crediti->fixTotale();
diff --git a/modules/impianti/actions.php b/modules/impianti/actions.php
@@ -117,6 +117,13 @@
             $id_record = $dbo->lastInsertedID();
 
             $checks_categoria = $dbo->fetchArray('SELECT * FROM zz_checks WHERE id_module = '.prepare($id_modulo_categorie_impianti).' AND id_record = '.prepare($id_categoria));
+            
+            $id_checks_categoria = array_column($checks_categoria, 'id');
+            $utenti_checks = [];
+            if (!empty($id_checks_categoria)) {
+                $utenti_checks = $dbo->table('zz_check_user')->whereIn('id_check', $id_checks_categoria)->get()->groupBy('id_check');
+            }
+            
             foreach ($checks_categoria as $check_categoria) {
                 $id_parent_new = null;
                 if ($check_categoria['id_parent']) {
@@ -131,9 +138,10 @@
 
                 // Riporto anche i permessi della check
                 $users = [];
-                $utenti = $dbo->table('zz_check_user')->where('id_check', $check_categoria['id'])->get();
-                foreach ($utenti as $utente) {
-                    $users[] = $utente->id_utente;
+                if (isset($utenti_checks[$check_categoria['id']])) {
+                    foreach ($utenti_checks[$check_categoria['id']] as $utente) {
+                        $users[] = $utente->id_utente;
+                    }
                 }
                 $check->setAccess($users, null);
             }
@@ -198,10 +206,20 @@
         ]);
 
         $checks_categoria = $dbo->fetchArray('SELECT * FROM zz_checks WHERE id_module = '.prepare($id_modulo_categorie_impianti).' AND id_record = '.prepare(post('id_categoria')));
+        
+        $id_parents = array_filter(array_column($checks_categoria, 'id_parent'));
+        $parents_map = [];
+        if (!empty($id_parents)) {
+            $parents = $dbo->select('zz_checks', '*', ['id' => $id_parents]);
+            foreach ($parents as $parent) {
+                $parents_map[$parent['id']] = $parent;
+            }
+        }
+        
         foreach ($checks_categoria as $check_categoria) {
             $id_parent_new = null;
-            if ($check_categoria['id_parent']) {
-                $parent = $dbo->selectOne('zz_checks', '*', ['id' => $check_categoria['id_parent']]);
+            if ($check_categoria['id_parent'] && isset($parents_map[$check_categoria['id_parent']])) {
+                $parent = $parents_map[$check_categoria['id_parent']];
                 $id_parent_new = $dbo->selectOne('zz_checks', '*', ['content' => $parent['content'], 'id_module' => $id_module, 'id_record' => $id_record])['id'];
             }
             $check = Check::build($user, $structure, $id_record, $check_categoria['content'], $id_parent_new, $check_categoria['is_titolo'], $check_categoria['order']);
diff --git a/modules/listini_cliente/actions.php b/modules/listini_cliente/actions.php
@@ -130,13 +130,9 @@
         $dbo->query('UPDATE mg_listini SET nome = CONCAT (nome, " (copia)") WHERE id = '.prepare($id_record_new));
 
         $articoli = Articolo::where('id_listino', $id_record)->get();
-        foreach ($articoli as $articolo) {
-            $dbo->query('CREATE TEMPORARY TABLE tmp SELECT * FROM mg_listini_articoli WHERE id= '.prepare($articolo->id));
-            $dbo->query('ALTER TABLE tmp DROP id');
-            $dbo->query('INSERT INTO mg_listini_articoli SELECT NULL,tmp. * FROM tmp');
-            $id_riga_new = $dbo->lastInsertedID();
-            $dbo->query('DROP TEMPORARY TABLE tmp');
-            $dbo->query('UPDATE mg_listini_articoli SET id_listino = '.prepare($id_record_new).' WHERE id = '.prepare($id_riga_new));
+        if ($articoli->isNotEmpty()) {
+            $dbo->query('INSERT INTO mg_listini_articoli (SELECT NULL, tmp.* FROM mg_listini_articoli tmp WHERE tmp.id IN ('.implode(',', $articoli->pluck('id')->toArray()).'))');
+            $dbo->query('UPDATE mg_listini_articoli SET id_listino = '.prepare($id_record_new).' WHERE id_listino = '.prepare($id_record));
         }
 
         flash()->info(tr('Listino duplicato correttamente!'));
diff --git a/modules/listini_cliente/bulk.php b/modules/listini_cliente/bulk.php
@@ -25,14 +25,10 @@
 
 switch (post('op')) {
     case 'change_prezzo':
-        foreach ($id_records as $id) {
-            $listino = Listino::find($id);
-
-            $articoli = Articolo::where('id_listino', $id)->get();
-            foreach ($articoli as $articolo) {
-                $articolo->sconto_percentuale = post('percentuale');
-                $articolo->save();
-            }
+        $articoli = Articolo::whereIn('id_listino', $id_records)->get();
+        foreach ($articoli as $articolo) {
+            $articolo->sconto_percentuale = post('percentuale');
+            $articolo->save();
         }
 
         flash()->info(tr('Listini aggiornati!'));
