refactor: ottimizzazione query con laravel

Pek5892 · Pek5892 · commit 823125c103ce · 2026-02-13T16:03:08.000+01:00
diff --git a/modules/emails/ajax/complete.php b/modules/emails/ajax/complete.php
@@ -28,48 +28,66 @@
         $indirizzi_proposti = filter('indirizzi_proposti');
         $where = '';
 
-        if ($indirizzi_proposti == 1) {
-            $where .= 'AND an_tipianagrafiche_lang.title = "Cliente"';
-        } elseif ($indirizzi_proposti == 2) {
-            $where .= 'AND an_tipianagrafiche_lang.title = "Fornitore"';
-        } else {
-            $indirizzi_proposti = null;
+        // Definizione filtri per tipo anagrafica
+        $tipo_anagrafica = match ($indirizzi_proposti) {
+            1 => '"Cliente"',
+            2 => '"Fornitore"',
+            default => null
+        };
+
+        if ($tipo_anagrafica !== null) {
+            $where .= 'AND an_tipianagrafiche.name = '.$tipo_anagrafica;
         }
 
         $results = [];
 
-        // Tutte le anagrafiche
-        $q = "SELECT DISTINCT(an_anagrafiche.email), an_anagrafiche.idanagrafica, an_anagrafiche.ragione_sociale FROM an_anagrafiche INNER JOIN an_tipianagrafiche_anagrafiche ON an_tipianagrafiche_anagrafiche.idanagrafica=an_anagrafiche.idanagrafica INNER JOIN an_tipianagrafiche ON an_tipianagrafiche.id=an_tipianagrafiche_anagrafiche.idtipoanagrafica INNER JOIN an_tipianagrafiche_lang ON (an_tipianagrafiche_lang.id_lang=1 AND an_tipianagrafiche_lang.id_record=an_tipianagrafiche.id) WHERE email != '' ".$where.' ORDER BY ragione_sociale';
-        $rs = $dbo->fetchArray($q);
-
-        foreach ($rs as $r) {
-            if (!empty($r['email'])) {
+        // Funzione helper per aggiungere risultati all'array
+        $addResults = function($records) use (&$results) {
+            foreach ($records as $record) {
                 $results[] = [
-                    'value' => $r['email'],
-                    'label' => $r['ragione_sociale'].' <'.$r['email'].'>',
+                    'value' => $record['email'],
+                    'label' => $record['ragione_sociale'].' <'.$record['email'].'>',
                 ];
             }
-        }
+        };
 
-        $q = "SELECT DISTINCT(an_sedi.email), an_sedi.idanagrafica, nomesede AS ragione_sociale FROM an_sedi INNER JOIN an_anagrafiche ON an_anagrafiche.idanagrafica=an_sedi.idanagrafica INNER JOIN an_tipianagrafiche_anagrafiche ON an_tipianagrafiche_anagrafiche.idanagrafica=an_anagrafiche.idanagrafica INNER JOIN an_tipianagrafiche ON an_tipianagrafiche.id=an_tipianagrafiche_anagrafiche.idtipoanagrafica INNER JOIN an_tipianagrafiche_lang ON (an_tipianagrafiche_lang.id_lang=1 AND an_tipianagrafiche_lang.id_record=an_tipianagrafiche.id) WHERE an_sedi.email != '' ".$where.' ORDER BY ragione_sociale';
+        // Tutte le anagrafiche (query specifica senza join su se stessa)
+        $q = "
+            SELECT DISTINCT(an_anagrafiche.email) AS email,
+                   an_anagrafiche.idanagrafica,
+                   an_anagrafiche.ragione_sociale
+            FROM an_anagrafiche
+            INNER JOIN an_tipianagrafiche_anagrafiche ON an_tipianagrafiche_anagrafiche.idanagrafica = an_anagrafiche.idanagrafica
+            INNER JOIN an_tipianagrafiche ON an_tipianagrafiche.id = an_tipianagrafiche_anagrafiche.idtipoanagrafica
+            INNER JOIN an_tipianagrafiche_lang ON (an_tipianagrafiche_lang.id_lang = 1 AND an_tipianagrafiche_lang.id_record = an_tipianagrafiche.id)
+            WHERE an_anagrafiche.email != '' $where
+            ORDER BY ragione_sociale
+        ";
+        $addResults($dbo->fetchArray($q));
 
-        $sedi = $dbo->fetchArray($q);
-        foreach ($sedi as $sede) {
-            $results[] = [
-                'value' => $sede['email'],
-                'label' => $sede['ragione_sociale'].' <'.$sede['email'].'>',
-            ];
-        }
+        // Funzione helper per sedi e referenti (tabelle che richiedono join con an_anagrafiche)
+        $fetchEmails = function($table, $email_column, $name_column) use ($dbo, $where) {
+            $query = "
+                SELECT DISTINCT($table.$email_column) AS email,
+                       $table.idanagrafica,
+                       $name_column AS ragione_sociale
+                FROM $table
+                INNER JOIN an_anagrafiche ON an_anagrafiche.idanagrafica = $table.idanagrafica
+                INNER JOIN an_tipianagrafiche_anagrafiche ON an_tipianagrafiche_anagrafiche.idanagrafica = an_anagrafiche.idanagrafica
+                INNER JOIN an_tipianagrafiche ON an_tipianagrafiche.id = an_tipianagrafiche_anagrafiche.idtipoanagrafica
+                INNER JOIN an_tipianagrafiche_lang ON (an_tipianagrafiche_lang.id_lang = 1 AND an_tipianagrafiche_lang.id_record = an_tipianagrafiche.id)
+                WHERE $table.$email_column != '' $where
+                ORDER BY ragione_sociale
+            ";
+            
+            return $dbo->fetchArray($query);
+        };
 
-        $q = "SELECT DISTINCT(an_referenti.email), an_referenti.idanagrafica, an_referenti.nome AS ragione_sociale FROM an_referenti INNER JOIN an_anagrafiche ON an_anagrafiche.idanagrafica=an_referenti.idanagrafica INNER JOIN an_tipianagrafiche_anagrafiche ON an_tipianagrafiche_anagrafiche.idanagrafica=an_anagrafiche.idanagrafica INNER JOIN an_tipianagrafiche ON an_tipianagrafiche.id=an_tipianagrafiche_anagrafiche.idtipoanagrafica INNER JOIN an_tipianagrafiche_lang ON (an_tipianagrafiche_lang.id_lang=1 AND an_tipianagrafiche_lang.id_record=an_tipianagrafiche.id) WHERE an_referenti.email != '' ".$where.' ORDER BY ragione_sociale';
+        // Tutte le sedi
+        $addResults($fetchEmails('an_sedi', 'email', 'nomesede'));
 
-        $referenti = $dbo->fetchArray($q);
-        foreach ($referenti as $referente) {
-            $results[] = [
-                'value' => $referente['email'],
-                'label' => $referente['ragione_sociale'].' <'.$referente['email'].'>',
-            ];
-        }
+        // Tutti i referenti
+        $addResults($fetchEmails('an_referenti', 'email', 'nome'));
 
         echo json_encode($results);
 
diff --git a/modules/fatture/actions.php b/modules/fatture/actions.php
@@ -46,7 +46,7 @@
 
 // Controllo se la fattura è già stata inviata allo SDI
 if ($fattura) {
-    $stato_fe = $dbo->fetchOne('SELECT codice_stato_fe FROM co_documenti WHERE id = '.$fattura->id);
+    $stato_fe = ['codice_stato_fe' => $fattura->codice_stato_fe];
 }
 
 $ops = ['update', 'add_intervento', 'manage_documento_fe', 'manage_riga_fe', 'manage_articolo', 'manage_sconto', 'manage_riga', 'manage_descrizione', 'unlink_intervento', 'delete_riga', 'copy_riga', 'add_serial', 'add_articolo', 'edit-price'];
@@ -104,17 +104,14 @@
         $tipo = Tipo::find(post('idtipodocumento'));
         $fattura->tipo()->associate($tipo);
 
-        $data_fattura_precedente = $dbo->fetchOne('
-            SELECT
-                MAX(`data`) AS datamax
-            FROM
-                `co_documenti`
-                INNER JOIN `co_statidocumento` ON `co_statidocumento`.`id` = `co_documenti`.`idstatodocumento`
-                LEFT JOIN `co_statidocumento_lang` ON (`co_statidocumento`.`id` = `co_statidocumento_lang`.`id_record` AND `co_statidocumento_lang`.`id_lang` = '.prepare(Models\Locale::getDefault()->id).')
-                INNER JOIN `co_tipidocumento` ON `co_documenti`.`idtipodocumento` = `co_tipidocumento`.`id`
-                INNER JOIN `zz_segments` ON `zz_segments`.`id` = `co_documenti`.`id_segment`
-            WHERE
-                `co_statidocumento_lang`.`title` = "Emessa" AND `co_tipidocumento`.`dir` = "entrata" AND `co_documenti`.`id_segment`='.$fattura->id_segment);
+        $data_fattura_precedente = Fattura::whereHas('stato', function ($query) {
+                $query->where('name', 'Emessa');
+            })
+            ->whereHas('tipo', function ($query) {
+                $query->where('dir', 'entrata');
+            })
+            ->where('id_segment', $fattura->id_segment)
+            ->max('data');
 
         if ((setting('Data emissione fattura automatica') == 1) && ($dir == 'entrata') && ($stato->id == Stato::where('name', 'Emessa')->first()->id) && Carbon::parse($data)->lessThan(Carbon::parse($data_fattura_precedente['datamax'])) && (!empty($data_fattura_precedente['datamax']))) {
             $fattura->data = $data_fattura_precedente['datamax'];
@@ -429,8 +426,8 @@
 
         if (!empty($id_record) && $id_intervento !== null) {
             $copia_descrizione = post('copia_descrizione');
-            $intervento = $dbo->fetchOne('SELECT descrizione FROM in_interventi WHERE id = '.prepare($id_intervento));
-            if (!empty($copia_descrizione) && !empty($intervento['descrizione'])) {
+            $intervento = Modules\Interventi\Intervento::find($id_intervento);
+            if (!empty($copia_descrizione) && !empty($intervento->descrizione)) {
                 $riga = Descrizione::build($fattura);
                 $riga->descrizione = $intervento['descrizione'];
                 $riga->idintervento = $id_intervento;
@@ -861,7 +858,10 @@
         $order = explode(',', post('order', true));
 
         foreach ($order as $i => $id_riga) {
-            $dbo->query('UPDATE `co_righe_documenti` SET `order` = '.prepare($i + 1).' WHERE id='.prepare($id_riga));
+            Modules\Fatture\Components\Articolo::where('id', $id_riga)->update(['order' => $i + 1])
+                ?: Modules\Fatture\Components\Riga::where('id', $id_riga)->update(['order' => $i + 1])
+                ?: Modules\Fatture\Components\Descrizione::where('id', $id_riga)->update(['order' => $i + 1])
+                ?: Modules\Fatture\Components\Sconto::where('id', $id_riga)->update(['order' => $i + 1]);
         }
 
         break;
@@ -873,7 +873,8 @@
 
         // Metto l'intervento in stato "Fatturato"
         if (setting('Cambia automaticamente stato attività fatturate')) {
-            $dbo->query("UPDATE `in_interventi` SET `idstatointervento`=(SELECT `id` FROM `in_statiintervento` WHERE `codice`='FAT') WHERE `id`=".prepare($id_documento));
+            $stato_fatturato = Modules\Interventi\Stato::where('codice', 'FAT')->first()->id;
+            Modules\Interventi\Intervento::where('id', $id_documento)->update(['idstatointervento' => $stato_fatturato]);
         }
 
         // Individuazione del documento originale
@@ -1019,8 +1020,7 @@
         $data = post('data');
 
         $anagrafica = $fattura->anagrafica;
-        $id_tipo = database()->fetchOne('SELECT `co_tipidocumento`.`id` FROM `co_tipidocumento` WHERE `name` = "Nota di credito" AND `dir` = "entrata"')['id'];
-        $tipo = Tipo::find($id_tipo);
+        $tipo = Tipo::where('name', 'Nota di credito')->where('dir', 'entrata')->first();
         $nota = Fattura::build($anagrafica, $tipo, $data, $id_segment);
         $nota->ref_documento = $fattura->id;
         $nota->idconto = $fattura->idconto;
@@ -1174,11 +1174,28 @@
     case 'controlla_serial':
         if (post('is_rientrabile')) {
             // Controllo che i serial entrati e usciti siano uguali in modo da poterli registrare nuovamente.
-            $serial_uscita = $dbo->fetchOne('SELECT COUNT(id) AS `tot` FROM mg_prodotti WHERE serial='.prepare(post('serial')).' AND dir="uscita" AND id_articolo='.prepare(post('id_articolo')))['tot'];
-            $serial_entrata = $dbo->fetchOne('SELECT COUNT(id) AS `tot` FROM mg_prodotti WHERE serial='.prepare(post('serial')).' AND dir="entrata" AND id_articolo='.prepare(post('id_articolo')))['tot'];
+            $serial_uscita = $dbo->table('mg_prodotti')
+                ->where('serial', post('serial'))
+                ->where('dir', 'uscita')
+                ->where('id_articolo', post('id_articolo'))
+                ->count();
+            $serial_entrata = $dbo->table('mg_prodotti')
+                ->where('serial', post('serial'))
+                ->where('dir', 'entrata')
+                ->where('id_articolo', post('id_articolo'))
+                ->count();
             $has_serial = $serial_entrata != $serial_uscita;
         } else {
-            $has_serial = $dbo->fetchOne('SELECT id FROM mg_prodotti WHERE serial='.prepare(post('serial')).' AND dir="uscita" AND id_articolo='.prepare(post('id_articolo')).' AND (id_riga_documento IS NOT NULL OR id_riga_ordine IS NOT NULL OR id_riga_ddt IS NOT NULL)')['id'];
+            $has_serial = $dbo->table('mg_prodotti')
+                ->where('serial', post('serial'))
+                ->where('dir', 'uscita')
+                ->where('id_articolo', post('id_articolo'))
+                ->where(function ($query) {
+                    $query->whereNotNull('id_riga_documento')
+                        ->orWhereNotNull('id_riga_ordine')
+                        ->orWhereNotNull('id_riga_ddt');
+                })
+                ->value('id');
         }
 
         echo json_encode($has_serial);
@@ -1191,16 +1208,21 @@
         $save_inline_barcode = true;
 
         if (!empty($barcode)) {
-            $id_articolo = $dbo->selectOne('mg_articoli_barcode', 'idarticolo', ['barcode' => $barcode])['idarticolo'];
+            $id_articolo = $dbo->table('mg_articoli_barcode')->where('barcode', $barcode)->value('idarticolo');
             if (empty($id_articolo)) {
-                $id_articolo = $dbo->selectOne('mg_articoli', 'id', ['deleted_at' => null, 'attivo' => 1, 'barcode' => '', 'codice' => $barcode])['id'];
+                $id_articolo = $dbo->table('mg_articoli')
+                    ->where('deleted_at', null)
+                    ->where('attivo', 1)
+                    ->where('barcode', '')
+                    ->where('codice', $barcode)
+                    ->value('id');
                 $save_inline_barcode = false;
             }
         }
 
         if (!empty($id_articolo)) {
             $permetti_movimenti_sotto_zero = setting('Permetti selezione articoli con quantità minore o uguale a zero in Documenti di Vendita');
-            $qta_articolo = $dbo->selectOne('mg_articoli', 'qta', ['id' => $id_articolo])['qta'];
+            $qta_articolo = $dbo->table('mg_articoli')->where('id', $id_articolo)->value('qta');
 
             $originale = ArticoloOriginale::find($id_articolo);
 
@@ -1256,12 +1278,12 @@
 
                 // Aggiunta sconto combinato se è presente un piano di sconto nell'anagrafica
                 $join = ($dir == 'entrata' ? 'id_piano_sconto_vendite' : 'id_piano_sconto_acquisti');
-                $piano_sconto = $dbo->fetchOne('SELECT prc_guadagno FROM an_anagrafiche INNER JOIN mg_piani_sconto ON an_anagrafiche.'.$join.'=mg_piani_sconto.id WHERE idanagrafica='.prepare($id_anagrafica));
+                $piano_sconto = Modules\Anagrafiche\Anagrafica::find($id_anagrafica)->pianoSconto($dir);
                 if (!empty($piano_sconto)) {
-                    $sconto = parseScontoCombinato($piano_sconto['prc_guadagno'].'+'.$sconto);
+                    $sconto = parseScontoCombinato($piano_sconto->prc_guadagno.'+'.$sconto);
                 }
 
-                $provvigione = $dbo->selectOne('an_anagrafiche', 'provvigione_default', ['idanagrafica' => $fattura->idagente])['provvigione_default'];
+                $provvigione = Modules\Anagrafiche\Anagrafica::find($fattura->idagente)->provvigione_default;
 
                 $articolo->id_rivalsa_inps = setting('Cassa previdenziale predefinita') ?: null;
                 $articolo->id_ritenuta_acconto = setting('Ritenuta d\'acconto predefinita') ?: null;
@@ -1386,9 +1408,9 @@
 
             // Aggiunta sconto combinato se è presente un piano di sconto nell'anagrafica
             $join = ($dir == 'entrata' ? 'id_piano_sconto_vendite' : 'id_piano_sconto_acquisti');
-            $piano_sconto = $dbo->fetchOne('SELECT prc_guadagno FROM an_anagrafiche INNER JOIN mg_piani_sconto ON an_anagrafiche.'.$join.'=mg_piani_sconto.id WHERE idanagrafica='.prepare($id_anagrafica));
+            $piano_sconto = Modules\Anagrafiche\Anagrafica::find($id_anagrafica)->pianoSconto($dir);
             if (!empty($piano_sconto)) {
-                $sconto = parseScontoCombinato($piano_sconto['prc_guadagno'].'+'.$sconto);
+                $sconto = parseScontoCombinato($piano_sconto->prc_guadagno.'+'.$sconto);
             }
 
             $riga->setSconto($sconto, 'PRC');
@@ -1517,9 +1539,11 @@
 
 // Nota di debito
 if (get('op') == 'nota_addebito') {
-    $rs_segment = $dbo->fetchArray('SELECT `zz_segments`.* FROM `zz_segments` LEFT JOIN `zz_segments_lang` ON (`zz_segments`.`id` = `zz_segments_lang`.`id_record` AND `zz_segments_lang`.`id_lang` = '.prepare(Models\Locale::getDefault()->id).") WHERE `predefined_addebito`='1'");
+    $rs_segment = Models\Segment::whereHas('translations', function ($query) {
+        $query->where('id_lang', Models\Locale::getDefault()->id);
+    })->where('predefined_addebito', '1')->first();
     if (!empty($rs_segment)) {
-        $id_segment = $rs_segment[0]['id'];
+        $id_segment = $rs_segment->id;
     } else {
         $id_segment = $record['id_segment'];
     }
diff --git a/modules/fatture/modutil.php b/modules/fatture/modutil.php
@@ -192,15 +192,13 @@ function aggiungi_movimento($iddocumento, $dir, $primanota = 0)
         $fattura = Fattura::find($iddocumento);
         $is_nota = $fattura->isNota();
 
-        // Totale marca da bollo, inps, ritenuta, idagente
-        $query = 'SELECT data, bollo, ritenutaacconto, rivalsainps, split_payment FROM co_documenti WHERE id='.prepare($iddocumento);
-        $rs = $dbo->fetchArray($query);
-        $totale_bolli = $is_nota ? -$rs[0]['bollo'] : $rs[0]['bollo'];
-        $totale_ritenutaacconto = $is_nota ? -$rs[0]['ritenutaacconto'] : $rs[0]['ritenutaacconto'];
+        // Ottimizzazione: usa il modello Eloquent invece di query SQL diretta
+        $totale_bolli = $is_nota ? -$fattura->bollo : $fattura->bollo;
+        $totale_ritenutaacconto = $is_nota ? -$fattura->ritenutaacconto : $fattura->ritenutaacconto;
         $totale_ritenutacontributi = $is_nota ? -$fattura->totale_ritenuta_contributi : $fattura->totale_ritenuta_contributi;
-        $totale_rivalsainps = $is_nota ? -$rs[0]['rivalsainps'] : $rs[0]['rivalsainps'];
-        $data_documento = $rs[0]['data'];
-        $split_payment = $rs[0]['split_payment'];
+        $totale_rivalsainps = $is_nota ? -$fattura->rivalsainps : $fattura->rivalsainps;
+        $data_documento = $fattura->data;
+        $split_payment = $fattura->split_payment;
 
         $netto_fattura = get_netto_fattura($iddocumento);
         $totale_fattura = get_totale_fattura($iddocumento);
@@ -392,10 +390,9 @@ function get_new_idmastrino($table = 'co_movimenti')
     {
         $dbo = database();
 
-        $query = 'SELECT MAX(idmastrino) AS maxidmastrino FROM '.$table;
-        $rs = $dbo->fetchArray($query);
+        $maxidmastrino = $dbo->table($table)->max('idmastrino');
 
-        return intval($rs[0]['maxidmastrino']) + 1;
+        return intval($maxidmastrino) + 1;
     }
 }
 
diff --git a/modules/preventivi/actions.php b/modules/preventivi/actions.php
