. */ include_once __DIR__.'/../../core.php'; use Carbon\Carbon; use Modules\Anagrafiche\Tipo; use Modules\DDT\DDT; use Modules\Fatture\Fattura; use Modules\Fatture\Stato; use Modules\Ordini\Ordine; use Modules\PrimaNota\Mastrino; use Modules\PrimaNota\Movimento; use Plugins\ImportFE\FatturaElettronica; use Plugins\ImportFE\Interaction; use Util\XML; $file = null; switch (filter('op')) { case 'list': $list = Interaction::getRemoteList(); echo json_encode($list); break; case 'save': $temp_name = $_FILES['blob']['tmp_name']; $name = $_FILES['blob']['name']; if (string_ends_with($name, '.zip')) { $directory = FatturaElettronica::getImportDirectory(); Util\Zip::extract($temp_name, $directory); // Redirect forzato per l'importazione echo json_encode([ 'id' => 1, ]); exit; } else { $content = file_get_contents($temp_name); $file = FatturaElettronica::store($_FILES['blob']['name'], $content); } // no break case 'prepare': if (!isset($file)) { $name = filter('name'); $file = Interaction::getInvoiceFile($name); } try { if (!FatturaElettronica::isValid($file)) { echo json_encode([ 'already' => 1, ]); return; } } catch (Exception $e) { } // Individuazione ID fisico $files = Interaction::getFileList(); foreach ($files as $key => $value) { if ($value['name'] == $file) { $index = $key; break; } } echo json_encode([ 'id' => $index + 1, ]); break; case 'delete': $file_id = get('file_id'); $directory = FatturaElettronica::getImportDirectory(); $files = Interaction::getFileList(); $file = $files[$file_id]; if (!empty($file)) { delete($directory.'/'.$file['name']); } break; case 'download': $file_id = get('file_id'); $directory = FatturaElettronica::getImportDirectory(); $files = Interaction::getFileList(); $file = $files[$file_id]; if (!empty($file)) { download($directory.'/'.$file['name']); } break; case 'generate': $filename = post('filename'); $info = [ 'id_pagamento' => post('pagamento'), 'id_segment' => post('id_segment'), 'id_tipo' => post('id_tipo'), 'ref_fattura' => post('ref_fattura'), 'data_registrazione' => post('data_registrazione'), 'articoli' => post('articoli'), 'iva' => post('iva'), 'conto' => post('conto'), 'tipo_riga_riferimento' => post('tipo_riga_riferimento'), 'id_riga_riferimento' => post('id_riga_riferimento'), 'tipo_riga_riferimento_vendita' => post('tipo_riga_riferimento_vendita'), 'id_riga_riferimento_vendita' => post('id_riga_riferimento_vendita'), 'movimentazione' => post('movimentazione'), 'crea_articoli' => post('crea_articoli'), 'is_ritenuta_pagata' => post('is_ritenuta_pagata'), 'update_info' => post('update_info'), 'serial' => post('flag_crea_seriali') ? post('serial') : [], ]; $fattura_pa = FatturaElettronica::manage($filename); $id_fattura = $fattura_pa->save($info); $fattura_pa->delete(); $fattura = Fattura::find($id_fattura); $id_autofattura = post('autofattura'); $new_stato = (new Stato())->getByName('Pagato')->id_record; if ($fattura->isAutofattura() && !empty($id_autofattura)) { $autofattura_collegata = Fattura::find($id_autofattura); $fattura->registraScadenze(true); $autofattura_collegata->registraScadenze(true); $fattura->stato()->associate($new_stato); $autofattura_collegata->stato()->associate($new_stato); $mastrino = Mastrino::build('Compensazione autofattura', $fattura->data, false, true); $movimento1 = Movimento::build($mastrino, $fattura->anagrafica->idconto_cliente); $movimento1->setTotale($fattura->totale, 0); $movimento1->save(); $movimento2 = Movimento::build($mastrino, $fattura->anagrafica->idconto_fornitore); $movimento2->setTotale(0, $fattura->totale); $movimento2->save(); $fattura->id_autofattura = $id_autofattura; $fattura->save(); $autofattura_collegata->save(); } // Aggiorno la tipologia di anagrafica fornitore $anagrafica = $database->fetchOne('SELECT `idanagrafica` FROM `co_documenti` WHERE `co_documenti`.`id`='.prepare($id_fattura)); $id_tipo = (new Tipo())->getByName('Fornitore')->id_record; $rs_t = $database->fetchOne('SELECT * FROM `an_tipianagrafiche_anagrafiche` WHERE `idtipoanagrafica`='.prepare($id_tipo).' AND `idanagrafica`='.prepare($anagrafica['idanagrafica'])); // Se non trovo corrispondenza aggiungo all'anagrafica la tipologia fornitore if (empty($rs_t)) { $database->query("INSERT INTO `an_tipianagrafiche_anagrafiche` (`idtipoanagrafica`, `idanagrafica`) VALUES ($id_tipo, ".prepare($anagrafica['idanagrafica']).')'); } // Processo il file ricevuto if (Interaction::isEnabled()) { $process_result = Interaction::processInvoice($filename); if ($process_result != '') { flash()->error($process_result); redirect(base_path().'/controller.php?id_module='.$id_module); return; } } $files = Interaction::getFileList(); $file = $files[$id_record - 1]; if (get('sequence') == null) { redirect(base_path().'/editor.php?id_module='.$id_module.'&id_record='.$id_fattura); } elseif (!empty($file)) { redirect(base_path().'/editor.php?id_module='.$id_module.'&id_plugin='.$id_plugin.'&id_record='.$id_record.'&sequence=1'); flash()->info(tr('La fattura numero _NUM_ del _DATA_ (_ANAGRAFICA_) è stata importata correttamente', [ '_NUM_' => $fattura->numero, '_DATA_' => dateFormat($fattura->data), '_ANAGRAFICA_' => $fattura->anagrafica->ragione_sociale, ])); } else { flash()->info(tr('Tutte le fatture salvate sono state importate!')); redirect(base_path().'/controller.php?id_module='.$id_module); } break; case 'process': $name = get('name'); // Processo il file ricevuto if (Interaction::isEnabled()) { $process_result = Interaction::processInvoice($name); if (!empty($process_result)) { flash()->error($process_result); } } break; case 'compile': // Gestione del caso di anagrafica inesistente if (empty($anagrafica)) { echo json_encode([]); return; } $fatture = $anagrafica->fattureAcquisto() ->contabile() ->orderBy('created_at', 'DESC') ->take(10) ->get(); $righe = collect(); foreach ($fatture as $fattura) { $righe->push($fattura->righe); $righe->push($fattura->articoli); } $righe = $righe->flatten(); // Gestione del caso di anagrafica senza fatture o con fatture senza righe if ($fatture->isEmpty() || $righe->isEmpty()) { echo json_encode([]); return; } // Ricerca del tipo di documento più utilizzato $tipi = $fatture->groupBy(function ($item, $key) { return $item->tipo->id; })->transform(function ($item, $key) { return $item->count(); }); $id_tipo = $tipi->sort()->keys()->last(); // Ricerca del conto più utilizzato $conti = $righe->groupBy(function ($item, $key) { return $item->idconto; })->transform(function ($item, $key) { return $item->count(); }); $id_conto = $conti->sort()->keys()->last(); $conto = $database->fetchOne('SELECT * FROM co_pianodeiconti3 WHERE id = '.prepare($id_conto)); // Ricerca dell'IVA più utilizzata secondo percentuali $iva = []; $percentuali_iva = $righe->groupBy(function ($item, $key) { return $item->aliquota->percentuale; }); foreach ($percentuali_iva as $key => $values) { $aliquote = $values->mapToGroups(function ($item, $key) { return [$item->aliquota->id => $item->aliquota]; }); $id_aliquota = $aliquote->map(function ($item, $key) { return $item->count(); })->sort()->keys()->last(); $aliquota = $aliquote[$id_aliquota]->first(); $iva[$key] = [ 'id' => $aliquota->id, 'descrizione' => $aliquota->descrizione, ]; } echo json_encode([ 'id_tipo' => $id_tipo, 'conto' => [ 'id' => $conto['id'], 'descrizione' => $conto['descrizione'], ], 'iva' => $iva, ]); break; case 'riferimenti-automatici': if (empty($anagrafica)) { echo json_encode([]); return; } $results = []; // Dati ordini $DatiOrdini = XML::forceArray($fattura_pa->getBody()['DatiGenerali']['DatiOrdineAcquisto']); $DatiDDT = XML::forceArray($fattura_pa->getBody()['DatiGenerali']['DatiDDT']); $replaces = ['n ', 'N ', 'n. ', 'N. ', 'nr ', 'NR ', 'nr. ', 'NR. ', 'num ', 'NUM ', 'num. ', 'NUM. ', 'numero ', 'NUMERO ']; // Riorganizzazione dati ordini per numero di riga $dati_ordini = []; foreach ($DatiOrdini as $dato) { if (is_array($dato['RiferimentoNumeroLinea'])) { foreach ($dato['RiferimentoNumeroLinea'] as $dati => $linea) { foreach ($replaces as $replace) { if (string_starts_with($dato['IdDocumento'], $replace)) { $dato['IdDocumento'] = str_replace($replace, '', $dato['IdDocumento']); break; } } try { $dati_ordini[(int) $linea] = [ 'numero' => $dato['IdDocumento'], 'anno' => (new Carbon($dato['Data']))->format('Y'), ]; } catch (Exception $e) { $dati_ordini[(int) $linea] = [ 'numero' => $dato['IdDocumento'], ]; } } } else { foreach ($replaces as $replace) { if (string_starts_with($dato['IdDocumento'], $replace)) { $dato['IdDocumento'] = str_replace($replace, '', $dato['IdDocumento']); break; } } try { $dati_ordini[(int) $dato['RiferimentoNumeroLinea']] = [ 'numero' => $dato['IdDocumento'], 'anno' => (new Carbon($dato['Data']))->format('Y'), ]; } catch (Exception $e) { $dati_ordini[(int) $dato['RiferimentoNumeroLinea']] = [ 'numero' => $dato['IdDocumento'], ]; } } } // Riorganizzazione dati ddt per numero di riga $dati_ddt = []; foreach ($DatiDDT as $dato) { if (is_array($dato['RiferimentoNumeroLinea'])) { foreach ($dato['RiferimentoNumeroLinea'] as $dati => $linea) { foreach ($replaces as $replace) { if (string_starts_with($dato['NumeroDDT'], $replace)) { $dato['NumeroDDT'] = str_replace($replace, '', $dato['NumeroDDT']); break; } } try { $dati_ddt[(int) $linea] = [ 'numero' => $dato['NumeroDDT'], 'anno' => (new Carbon($dato['DataDDT']))->format('Y'), ]; } catch (Exception $e) { $dati_ddt[(int) $linea] = [ 'numero' => $dato['NumeroDDT'], ]; } } } else { foreach ($replaces as $replace) { if (string_starts_with($dato['NumeroDDT'], $replace)) { $dato['NumeroDDT'] = str_replace($replace, '', $dato['NumeroDDT']); break; } } try { $dati_ddt[(int) $dato['RiferimentoNumeroLinea']] = [ 'numero' => $dato['NumeroDDT'], 'anno' => (new Carbon($dato['DataDDT']))->format('Y'), ]; } catch (Exception $e) { $dati_ddt[(int) $dato['RiferimentoNumeroLinea']] = [ 'numero' => $dato['NumeroDDT'], ]; } } } // Iterazione sulle singole righe $righe = $fattura_pa->getRighe(); foreach ($righe as $key => $riga) { // Se la riga è descrittiva non la collego a documenti if ($riga['PrezzoTotale'] == 0) { continue; } $collegamento = null; $match_documento_da_fe = true; $numero_linea = (int) $riga['NumeroLinea']; // Visualizzazione codici articoli $codici = $riga['CodiceArticolo'] ?: []; $codici = !empty($codici) && !isset($codici[0]) ? [$codici] : $codici; // Ricerca dell'articolo collegato a ogni codice associato alla riga $id_articolo = null; foreach ($codici as $codice) { if (!empty($anagrafica) && empty($id_articolo)) { $id_articolo = $database->fetchOne('SELECT id_articolo AS id FROM mg_fornitore_articolo WHERE codice_fornitore = '.prepare($codice['CodiceValore']).' AND id_fornitore = '.prepare($anagrafica->id))['id']; if (empty($id_articolo)) { $id_articolo = $database->fetchOne('SELECT id_articolo AS id FROM mg_fornitore_articolo WHERE REPLACE(codice_fornitore, " ", "") = '.prepare($codice['CodiceValore']).' AND id_fornitore = '.prepare($anagrafica->id))['id']; } } if (empty($id_articolo)) { $id_articolo = $database->fetchOne('SELECT id FROM mg_articoli WHERE codice = '.prepare($codice['CodiceValore']).' AND deleted_at IS NULL')['id']; if (empty($id_articolo)) { $id_articolo = $database->fetchOne('SELECT id FROM mg_articoli WHERE REPLACE(codice, " ", "") = '.prepare($codice['CodiceValore']).' AND deleted_at IS NULL')['id']; } // Controllo se esistono articoli con barcode corrispondente al codice if (empty($id_articolo)) { $id_articolo = $database->fetchOne('SELECT id FROM mg_articoli WHERE barcode = '.prepare($codice['CodiceValore']).' AND deleted_at IS NULL')['id']; } if (empty($id_articolo)) { $id_articolo = $database->fetchOne('SELECT id FROM mg_articoli WHERE REPLACE(barcode, " ", "") = '.prepare($codice['CodiceValore']).' AND deleted_at IS NULL')['id']; } } if (!empty($id_articolo)) { break; } } // Se nella fattura elettronica è indicato un DDT cerco quel documento specifico $ddt = $dati_ddt[$numero_linea]; $query = "SELECT dt_righe_ddt.id, dt_righe_ddt.idddt AS id_documento, dt_righe_ddt.is_descrizione, dt_righe_ddt.idarticolo, dt_righe_ddt.is_sconto, 'ddt' AS ref, CONCAT('DDT num. ', IF(numero_esterno != '', numero_esterno, numero), ' del ', DATE_FORMAT(data, '%d/%m/%Y'), ' [', (SELECT descrizione FROM dt_statiddt WHERE id = idstatoddt) , ']') AS opzione FROM dt_righe_ddt INNER JOIN dt_ddt ON dt_ddt.id = dt_righe_ddt.idddt WHERE dt_ddt.numero_esterno = ".prepare($ddt['numero']).' AND YEAR(dt_ddt.data) = '.prepare($ddt['anno']).' AND dt_ddt.idanagrafica = '.prepare($anagrafica->id).' AND dt_righe_ddt.qta > dt_righe_ddt.qta_evasa AND |where|'; // Ricerca di righe DDT con stesso Articolo if (!empty($id_articolo)) { $query_articolo = replace($query, [ '|where|' => 'dt_righe_ddt.idarticolo = '.prepare($id_articolo), ]); $collegamento = $database->fetchOne($query_articolo); } // Ricerca di righe DDT per stessa descrizione if (empty($collegamento)) { $query_descrizione = replace($query, [ '|where|' => 'dt_righe_ddt.descrizione = '.prepare($riga['Descrizione']), ]); $collegamento = $database->fetchOne($query_descrizione); } // Se nella fattura elettronica NON è indicato un DDT ed è indicato anche un ordine // cerco per quell'ordine if (empty($collegamento)) { $ordine = $dati_ordini[$numero_linea]; $query = "SELECT or_righe_ordini.id, or_righe_ordini.idordine AS id_documento, or_righe_ordini.is_descrizione, or_righe_ordini.idarticolo, or_righe_ordini.is_sconto, 'ordine' AS ref, CONCAT('Ordine num. ', IF(numero_esterno != '', numero_esterno, numero), ' del ', DATE_FORMAT(data, '%d/%m/%Y'), ' [', (SELECT descrizione FROM or_statiordine WHERE id = idstatoordine) , ']') AS opzione FROM or_righe_ordini INNER JOIN or_ordini ON or_ordini.id = or_righe_ordini.idordine WHERE or_ordini.numero_esterno = ".prepare($ordine['numero']).' AND YEAR(or_ordini.data) = '.prepare($ordine['anno']).' AND or_ordini.idanagrafica = '.prepare($anagrafica->id).' AND or_righe_ordini.qta > or_righe_ordini.qta_evasa AND |where|'; // Ricerca di righe Ordine con stesso Articolo if (!empty($id_articolo)) { $query_articolo = replace($query, [ '|where|' => 'or_righe_ordini.idarticolo = '.prepare($id_articolo), ]); $collegamento = $database->fetchOne($query_articolo); } // Ricerca di righe Ordine per stessa descrizione if (empty($collegamento)) { $query_descrizione = replace($query, [ '|where|' => 'or_righe_ordini.descrizione = '.prepare($riga['Descrizione']), ]); $collegamento = $database->fetchOne($query_descrizione); } } /* * TENTATIVO 2: ricerca solo per articolo o descrizione su documenti * non referenziati nella fattura elettronica */ // Se non ci sono Ordini o DDT cerco per contenuto if (empty($collegamento)) { $match_documento_da_fe = false; $query = "SELECT dt_righe_ddt.id, dt_righe_ddt.idddt AS id_documento, dt_righe_ddt.is_descrizione, dt_righe_ddt.idarticolo, dt_righe_ddt.is_sconto, 'ddt' AS ref, CONCAT('DDT num. ', IF(numero_esterno != '', numero_esterno, numero), ' del ', DATE_FORMAT(data, '%d/%m/%Y'), ' [', (SELECT descrizione FROM dt_statiddt WHERE id = idstatoddt) , ']') AS opzione FROM dt_righe_ddt INNER JOIN dt_ddt ON dt_ddt.id = dt_righe_ddt.idddt WHERE dt_ddt.idanagrafica = ".prepare($anagrafica->id)." AND |where_ddt| AND dt_righe_ddt.qta > dt_righe_ddt.qta_evasa AND dt_ddt.idstatoddt IN (SELECT id FROM dt_statiddt WHERE descrizione != 'Fatturato') AND idtipoddt IN (SELECT id FROM dt_tipiddt WHERE dir='uscita') UNION SELECT or_righe_ordini.id, or_righe_ordini.idordine AS id_documento, or_righe_ordini.is_descrizione, or_righe_ordini.idarticolo, or_righe_ordini.is_sconto, 'ordine' AS ref, CONCAT('Ordine num. ', IF(numero_esterno != '', numero_esterno, numero), ' del ', DATE_FORMAT(data, '%d/%m/%Y'), ' [', (SELECT descrizione FROM or_statiordine WHERE id = idstatoordine) , ']') AS opzione FROM or_righe_ordini INNER JOIN or_ordini ON or_ordini.id = or_righe_ordini.idordine WHERE or_ordini.idanagrafica = ".prepare($anagrafica->id)." AND |where_ordini| AND or_righe_ordini.qta > or_righe_ordini.qta_evasa AND or_ordini.idstatoordine IN (SELECT id FROM or_statiordine WHERE descrizione != 'Fatturato') AND idtipoordine IN (SELECT id FROM or_tipiordine WHERE dir ='uscita')"; // Ricerca di righe DDT/Ordine con stesso Articolo if (!empty($id_articolo)) { $query_articolo = replace($query, [ '|where_ddt|' => 'dt_righe_ddt.idarticolo = '.prepare($id_articolo), '|where_ordini|' => 'or_righe_ordini.idarticolo = '.prepare($id_articolo), ]); $collegamento = $database->fetchOne($query_articolo); } // Ricerca di righe DDT/Ordine per stessa descrizione if (empty($collegamento)) { $query_descrizione = replace($query, [ '|where_ddt|' => 'dt_righe_ddt.descrizione = '.prepare($riga['Descrizione']), '|where_ordini|' => 'or_righe_ordini.descrizione = '.prepare($riga['Descrizione']), ]); $collegamento = $database->fetchOne($query_descrizione); } // Ricerca di righe DDT/Ordine per stesso importo if (empty($collegamento)) { $query_descrizione = replace($query, [ '|where_ddt|' => 'dt_righe_ddt.prezzo_unitario = '.prepare($riga['PrezzoUnitario']), '|where_ordini|' => 'or_righe_ordini.prezzo_unitario = '.prepare($riga['PrezzoUnitario']), ]); $collegamento = $database->fetchOne($query_descrizione); } } if (!empty($collegamento)) { // Individuazione del documento $documento = $collegamento['ref'] == 'ddt' ? DDT::find($collegamento['id_documento']) : Ordine::find($collegamento['id_documento']); // Individuazione della classe di gestione per la riga $namespace = $collegamento['ref'] == 'ddt' ? 'Modules\\DDT\\Components\\' : 'Modules\\Ordini\\Components\\'; if (!empty($collegamento['idarticolo'])) { $type = 'Articolo'; } elseif (!empty($collegamento['is_sconto'])) { $type = 'Sconto'; } elseif (!empty($collegamento['is_descrizione'])) { $type = 'Descrizione'; } else { $type = 'Riga'; } // Ricerca della riga $riga = $documento->getRiga($namespace.$type, $collegamento['id']); $riga_origine = $riga->getOriginalComponent(); if (!empty($riga->idarticolo)) { $desc_conto = $dbo->fetchOne('SELECT CONCAT( co_pianodeiconti2.numero, ".", co_pianodeiconti3.numero, " ", co_pianodeiconti3.descrizione ) AS descrizione FROM co_pianodeiconti3 INNER JOIN co_pianodeiconti2 ON co_pianodeiconti3.idpianodeiconti2=co_pianodeiconti2.id WHERE co_pianodeiconti3.id = '.prepare($riga->articolo->idconto_acquisto))['descrizione']; } // Compilazione dei dati $results[$key] = [ 'documento' => [ 'tipo' => $collegamento['ref'], 'id' => $collegamento['id_documento'], 'descrizione' => reference($documento, tr('Origine')), 'opzione' => $collegamento['opzione'], 'match_documento_da_fe' => $match_documento_da_fe, ], 'riga' => [ 'tipo' => get_class($riga), 'id' => $riga->id, 'descrizione' => $riga->descrizione, 'qta' => $riga->qta, 'um' => $riga->um, 'prezzo_unitario' => $riga->prezzo_unitario ?: $riga_origine->prezzo_unitario, 'id_iva' => $riga->id_iva, 'iva_percentuale' => $riga->aliquota->percentuale, 'id_articolo' => $riga->idarticolo, 'desc_articolo' => str_replace(' ', '_', $riga->articolo->codice.' - '.$riga->articolo->descrizione), 'id_conto' => $riga->articolo->idconto_acquisto, 'desc_conto' => str_replace(' ', '_', $desc_conto), ], ]; } } echo json_encode($results); break; }