770 lines
34 KiB
PHP
770 lines
34 KiB
PHP
|
<?php
|
||
|
|
/*
|
||
|
|
* OpenSTAManager: il software gestionale open source per l'assistenza tecnica e la fatturazione
|
||
|
|
* Copyright (C) DevCode s.r.l.
|
||
|
|
*
|
||
|
|
* This program is free software: you can redistribute it and/or modify
|
||
|
|
* it under the terms of the GNU General Public License as published by
|
||
|
|
* the Free Software Foundation, either version 3 of the License, or
|
||
|
|
* (at your option) any later version.
|
||
|
|
*
|
||
|
|
* This program is distributed in the hope that it will be useful,
|
||
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||
|
|
* GNU General Public License for more details.
|
||
|
|
*
|
||
|
|
* You should have received a copy of the GNU General Public License
|
||
|
|
* along with this program. If not, see <https://www.gnu.org/licenses/>.
|
||
|
|
*/
|
||
|
|
|
||
|
|
include_once __DIR__.'/../../core.php';
|
||
|
|
include __DIR__.'/settings.php';
|
||
|
|
|
||
|
|
use Carbon\Carbon;
|
||
|
|
use Modules\Anagrafiche\Tipo;
|
||
|
|
use Modules\DDT\DDT;
|
||
|
|
use Modules\Fatture\Fattura;
|
||
|
|
use Modules\Fatture\Gestori\Movimenti as GestoreMovimenti;
|
||
|
|
use Modules\Fatture\Stato;
|
||
|
|
use Modules\Ordini\Ordine;
|
||
|
|
use Modules\Pagamenti\Pagamento;
|
||
|
|
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 'prepare':
|
||
|
|
if (!isset($file)) {
|
||
|
|
$name = filter('name');
|
||
|
|
$file = Interaction::getInvoiceFile($name);
|
||
|
|
}
|
||
|
|
|
||
|
|
try {
|
||
|
|
if (!FatturaElettronica::isValid($file, 'Fatture di vendita', 'Importazione FE')) {
|
||
|
|
echo json_encode([
|
||
|
|
'already' => 1,
|
||
|
|
]);
|
||
|
|
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
} catch (Exception) {
|
||
|
|
}
|
||
|
|
|
||
|
|
// Individuazione ID fisico
|
||
|
|
$files = Interaction::getFileList([], 'Fatture di vendita', 'Importazione FE');
|
||
|
|
foreach ($files as $key => $value) {
|
||
|
|
if ($value['name'] == $file) {
|
||
|
|
$index = $key;
|
||
|
|
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
echo json_encode([
|
||
|
|
'id' => $index + 1,
|
||
|
|
]);
|
||
|
|
|
||
|
|
case 'save':
|
||
|
|
$directory = FatturaElettronica::getImportDirectory('Fatture di vendita', 'Importazione FE');
|
||
|
|
|
||
|
|
if (!$file) {
|
||
|
|
$temp_name = $_FILES['blob1']['tmp_name'];
|
||
|
|
$name = $_FILES['blob1']['name'];
|
||
|
|
}
|
||
|
|
|
||
|
|
if (setting('Metodo di importazione XML fatture di vendita') == 'Automatico') {
|
||
|
|
if (string_ends_with($name, '.zip')) {
|
||
|
|
Util\Zip::extract($temp_name, $directory);
|
||
|
|
|
||
|
|
// Redirect forzato per l'importazione
|
||
|
|
echo json_encode([
|
||
|
|
'id' => 1,
|
||
|
|
]);
|
||
|
|
|
||
|
|
$files_xml = scandir($directory);
|
||
|
|
} else {
|
||
|
|
$files_xml[] = $file ?: $files;
|
||
|
|
}
|
||
|
|
|
||
|
|
$i = 1;
|
||
|
|
foreach ($files_xml as $xml) {
|
||
|
|
if ($xml != '.' && $xml != '..' && is_file($directory.'/'.$xml)) {
|
||
|
|
if (FatturaElettronica::isValid($xml, 'Fatture di vendita', 'Importazione FE')) {
|
||
|
|
if (string_ends_with($xml, '.p7m')) {
|
||
|
|
$file = XML::decodeP7M($directory.'/'.$xml);
|
||
|
|
} else {
|
||
|
|
$file = XML::readFile($directory.'/'.$xml);
|
||
|
|
}
|
||
|
|
|
||
|
|
$data = $file['FatturaElettronicaBody']['DatiGenerali']['DatiGeneraliDocumento']['Data'];
|
||
|
|
|
||
|
|
$fattura_pa = FatturaElettronica::manage($xml, 'Fattura di vendita', 'Importazione FE');
|
||
|
|
|
||
|
|
// Tipo documento
|
||
|
|
$fattura_body = $fattura_pa->getBody();
|
||
|
|
$dati_generali = $fattura_body['DatiGenerali']['DatiGeneraliDocumento'];
|
||
|
|
$id_tipo = $database->fetchOne('SELECT id FROM co_tipidocumento WHERE dir = "entrata" AND codice_tipo_documento_fe = '.prepare($dati_generali['TipoDocumento']))['id'];
|
||
|
|
|
||
|
|
// Tipo pagamento
|
||
|
|
$pagamenti = [];
|
||
|
|
if (isset($fattura_body['DatiPagamento'])) {
|
||
|
|
$pagamenti = $fattura_body['DatiPagamento'];
|
||
|
|
$pagamenti = isset($pagamenti[0]) ? $pagamenti : [$pagamenti];
|
||
|
|
}
|
||
|
|
$metodi = isset($pagamenti[0]['DettaglioPagamento']) ? $pagamenti[0]['DettaglioPagamento'] : [];
|
||
|
|
$metodi = isset($metodi[0]) ? $metodi : [$metodi];
|
||
|
|
$codice_modalita_pagamento = $metodi[0]['ModalitaPagamento'];
|
||
|
|
$pagamento = Pagamento::where('codice_modalita_pagamento_fe', $codice_modalita_pagamento)->where('predefined', '1')->first();
|
||
|
|
|
||
|
|
if (!empty($pagamento)) {
|
||
|
|
$id_pagamento = $pagamento->id;
|
||
|
|
} else {
|
||
|
|
$id_pagamento = $settings['id_pagamento'];
|
||
|
|
}
|
||
|
|
|
||
|
|
$fattura_pa->saveFattura($id_pagamento, $settings['id_segment'], $id_tipo, $data, false, false, 'Cliente');
|
||
|
|
|
||
|
|
$righe = $fattura_pa->getRighe();
|
||
|
|
|
||
|
|
$articoli = [];
|
||
|
|
$iva = [];
|
||
|
|
$conti = [];
|
||
|
|
|
||
|
|
foreach ($righe as $key => $riga) {
|
||
|
|
$articoli[$key] = 0;
|
||
|
|
|
||
|
|
$aliquota_iva = $riga['AliquotaIVA'];
|
||
|
|
|
||
|
|
$iva[$key] = $settings['iva'][$aliquota_iva];
|
||
|
|
|
||
|
|
$conti[$key] = $settings['id_conto'];
|
||
|
|
}
|
||
|
|
|
||
|
|
$fattura_pa->saveRighe($articoli, $iva, $conti);
|
||
|
|
|
||
|
|
$fattura_pa->saveAllegati('Fatture di vendita');
|
||
|
|
|
||
|
|
$id_record = $fattura_pa->getFattura()->id;
|
||
|
|
$fattura = Fattura::find($id_record);
|
||
|
|
$fattura->gestoreMovimenti = new GestoreMovimenti($fattura);
|
||
|
|
|
||
|
|
// Registrazione scadenze
|
||
|
|
$fattura->registraScadenze(false);
|
||
|
|
|
||
|
|
// Registrazione movimenti
|
||
|
|
|
||
|
|
$fattura->gestoreMovimenti->registra();
|
||
|
|
|
||
|
|
// Imposto lo stato in GEN
|
||
|
|
$dbo->query("UPDATE co_documenti SET codice_stato_fe='GEN', data_stato_fe=NOW() WHERE id=".prepare($id_record));
|
||
|
|
delete($directory.'/'.$xml);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
} else {
|
||
|
|
if (string_ends_with($name, '.zip')) {
|
||
|
|
$directory = FatturaElettronica::getImportDirectory('Fatture di vendita', 'Importazione FE');
|
||
|
|
|
||
|
|
Util\Zip::extract($temp_name, $directory);
|
||
|
|
|
||
|
|
// Redirect forzato per l'importazione
|
||
|
|
echo json_encode([
|
||
|
|
'id' => 1,
|
||
|
|
]);
|
||
|
|
|
||
|
|
exit;
|
||
|
|
} else {
|
||
|
|
$files_xml[] = $file ?: $files;
|
||
|
|
|
||
|
|
$i = 1;
|
||
|
|
foreach ($files_xml as $xml) {
|
||
|
|
if ($xml != '.' && $xml != '..' && is_file($directory.'/'.$xml)) {
|
||
|
|
if (FatturaElettronica::isValid($xml, 'Fatture di vendita', 'Importazione FE')) {
|
||
|
|
if (string_ends_with($xml, '.p7m')) {
|
||
|
|
$file = XML::decodeP7M($directory.'/'.$xml);
|
||
|
|
} else {
|
||
|
|
$file = XML::readFile($directory.'/'.$xml);
|
||
|
|
}
|
||
|
|
|
||
|
|
$file = FatturaElettronica::store($xml, $content);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
break;
|
||
|
|
|
||
|
|
case 'delete':
|
||
|
|
$file_id = get('file_id');
|
||
|
|
|
||
|
|
$directory = FatturaElettronica::getImportDirectory('Fatture di vendita', 'Importazione FE');
|
||
|
|
$files = Interaction::getFileList([], 'Fatture di vendita', 'Importazione FE');
|
||
|
|
$file = $files[$file_id];
|
||
|
|
|
||
|
|
if (!empty($file)) {
|
||
|
|
delete($directory.'/'.$file['name']);
|
||
|
|
}
|
||
|
|
|
||
|
|
break;
|
||
|
|
|
||
|
|
case 'download':
|
||
|
|
$file_id = get('file_id');
|
||
|
|
|
||
|
|
$directory = FatturaElettronica::getImportDirectory('Fatture di vendita');
|
||
|
|
$files = Interaction::getFileList([], 'Fatture di vendita', 'Importazione FE');
|
||
|
|
$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, 'Fatture di vendita', 'Importazione FE');
|
||
|
|
$id_fattura = $fattura_pa->save($info, 'Cliente');
|
||
|
|
$fattura_pa->delete();
|
||
|
|
$fattura = Fattura::find($id_fattura);
|
||
|
|
$id_autofattura = post('autofattura');
|
||
|
|
$new_stato = Stato::where('name', 'Pagato')->first()->id;
|
||
|
|
|
||
|
|
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 cliente
|
||
|
|
$anagrafica = $database->fetchOne('SELECT `idanagrafica` FROM `co_documenti` WHERE `co_documenti`.`id`='.prepare($id_fattura));
|
||
|
|
$id_tipo = Tipo::where('name', 'Cliente')->first()->id;
|
||
|
|
$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 cliente
|
||
|
|
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([], 'Fatture di vendita', 'Importazione FE');
|
||
|
|
$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);
|
||
|
|
}
|
||
|
|
|
||
|
|
$record = null;
|
||
|
|
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(fn ($item, $key) => $item->tipo->id)->transform(fn ($item, $key) => $item->count());
|
||
|
|
$id_tipo = $tipi->sort()->keys()->last();
|
||
|
|
|
||
|
|
// Ricerca del conto più utilizzato
|
||
|
|
$conti = $righe->groupBy(fn ($item, $key) => $item->idconto)->transform(fn ($item, $key) => $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(fn ($item, $key) => $item->aliquota->percentuale);
|
||
|
|
foreach ($percentuali_iva as $key => $values) {
|
||
|
|
$aliquote = $values->mapToGroups(fn ($item, $key) => [$item->aliquota->id => $item->aliquota]);
|
||
|
|
$id_aliquota = $aliquote->map(fn ($item, $key) => $item->count())->sort()->keys()->last();
|
||
|
|
$aliquota = $aliquote[$id_aliquota]->first();
|
||
|
|
|
||
|
|
$iva[$key] = [
|
||
|
|
'id' => $aliquota->id,
|
||
|
|
'descrizione' => $aliquota->getTranslation('title'),
|
||
|
|
];
|
||
|
|
}
|
||
|
|
|
||
|
|
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) {
|
||
|
|
$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) {
|
||
|
|
$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) {
|
||
|
|
$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) {
|
||
|
|
$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'), ' [', `dt_statiddt_lang`.`title`, ']') AS opzione
|
||
|
|
FROM
|
||
|
|
`dt_righe_ddt`
|
||
|
|
INNER JOIN `dt_ddt` ON `dt_ddt`.`id` = `dt_righe_ddt`.`idddt`
|
||
|
|
INNER JOIN `dt_statiddt` ON `dt_statiddt`.`id` = `dt_ddt`.`idstatoddt`
|
||
|
|
LEFT JOIN `dt_statiddt_lang` ON `dt_statiddt_lang`.`id_record` = `dt_statiddt`.`id` AND `dt_statiddt_lang`.`id_lang` = ".prepare(Models\Locale::getDefault()->id).'
|
||
|
|
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'), ' [', `or_statiordine_lang`.`title` , ']') AS opzione
|
||
|
|
FROM `or_righe_ordini`
|
||
|
|
INNER JOIN `or_ordini` ON `or_ordini`.`id` = `or_righe_ordini`.`idordine`
|
||
|
|
INNER JOIN `or_statiordine` ON `or_statiordine`.`id` = `or_ordini`.`idstatoordine`
|
||
|
|
LEFT JOIN `or_statiordine_lang` ON `or_statiordine_lang`.`id_record` = `or_statiordine`.`id` AND `or_statiordine_lang`.`id_lang` = ".prepare(Models\Locale::getDefault()->id).'
|
||
|
|
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'), ' [', `dt_statiddt_lang`.`title`, ']') AS opzione
|
||
|
|
FROM
|
||
|
|
`dt_righe_ddt`
|
||
|
|
INNER JOIN `dt_ddt` ON `dt_ddt`.`id` = `dt_righe_ddt`.`idddt`
|
||
|
|
INNER JOIN `dt_statiddt` ON `dt_statiddt`.`id` = `dt_ddt`.`idstatoddt`
|
||
|
|
LEFT JOIN `dt_statiddt_lang` ON (`dt_statiddt_lang`.`id_record` = `dt_statiddt`.`id` AND `dt_statiddt_lang`.`id_lang` = ".prepare(Models\Locale::getDefault()->id).')
|
||
|
|
INNER JOIN `dt_tipiddt` ON `dt_ddt`.`idtipoddt` = `dt_tipiddt`.`id`
|
||
|
|
WHERE
|
||
|
|
`dt_ddt`.`idanagrafica` = '.prepare($anagrafica->id)." AND
|
||
|
|
|where_ddt| AND
|
||
|
|
`dt_righe_ddt`.`qta` > `dt_righe_ddt`.`qta_evasa` AND
|
||
|
|
`dt_statiddt_lang`.`title` != 'Fatturato' AND
|
||
|
|
`dt_tipiddt`.`dir` = 'entrata'
|
||
|
|
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_stati`ordine WHERE `id` = `idstatoordine`) , ']') AS opzione
|
||
|
|
FROM
|
||
|
|
`or_righe_ordini`
|
||
|
|
INNER JOIN `or_ordini` ON `or_ordini`.`id` = `or_righe_ordini`.`idordine`
|
||
|
|
INNER JOIN `or_statiordine` ON `or_statiordine`.`id` = `or_ordini`.`idstatoordine`
|
||
|
|
LEFT JOIN `or_statiordine_lang` ON (`or_statiordine_lang`.`id_record` = `or_statiordine`.`id` AND `or_statiordine_lang`.`id_lang` = ".prepare(Models\Locale::getDefault()->id).')
|
||
|
|
INNER JOIN `or_tipiordine` ON `or_ordini`.`idtipoordine` = `or_tipiordine`.`id`
|
||
|
|
WHERE
|
||
|
|
`or_ordini`.`idanagrafica` = '.prepare($anagrafica->id)." AND
|
||
|
|
|where_ordini| AND
|
||
|
|
`or_righe_ordini`.`qta` > `or_righe_ordini`.`qta_evasa` AND
|
||
|
|
`or_statiordine_lang` WHERE `title` != 'Fatturato' AND
|
||
|
|
`or_tipiordine`.`dir` ='entrata'";
|
||
|
|
|
||
|
|
// 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' => $riga::class,
|
||
|
|
'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->getTranslation('title')),
|
||
|
|
'id_conto' => $riga->articolo->idconto_acquisto,
|
||
|
|
'desc_conto' => str_replace(' ', '_', $desc_conto),
|
||
|
|
],
|
||
|
|
];
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
echo json_encode($results);
|
||
|
|
|
||
|
|
break;
|
||
|
|
}
|