802 lines
32 KiB
PHP
802 lines
32 KiB
PHP
<?php
|
|
|
|
namespace App\Livewire\Settings;
|
|
|
|
use App\Jobs\ImportTerritoryPdfFolder;
|
|
use App\Models\AnnoTeocratico;
|
|
use App\Models\Assegnazione;
|
|
use App\Models\Campagna;
|
|
use App\Models\Proclamatore;
|
|
use App\Models\Setting;
|
|
use App\Models\Territorio;
|
|
use App\Models\Tipologia;
|
|
use App\Models\User;
|
|
use App\Models\Zona;
|
|
use App\Services\TerritorioPdfImportDispatcher;
|
|
use App\Services\TerritorioPdfImportState;
|
|
use Barryvdh\DomPDF\Facade\Pdf;
|
|
use Carbon\Carbon;
|
|
use Illuminate\Support\Facades\DB;
|
|
use Illuminate\Support\Str;
|
|
use Livewire\Component;
|
|
use Livewire\WithFileUploads;
|
|
|
|
class XmlExchange extends Component
|
|
{
|
|
use WithFileUploads;
|
|
|
|
public $sqlDump;
|
|
public $xmlImport;
|
|
public array $importStats = [];
|
|
public array $importIssues = [];
|
|
public array $pdfFolder = [];
|
|
public array $pdfImportLogs = [];
|
|
public array $pdfImportStats = [];
|
|
public array $pdfImportIssues = [];
|
|
public ?string $currentPdfImportId = null;
|
|
public string $pdfImportStatus = 'idle';
|
|
public string $pdfImportLogText = '';
|
|
|
|
public function mount(): void
|
|
{
|
|
$this->currentPdfImportId = request()->query('pdf-import');
|
|
|
|
if ($this->currentPdfImportId) {
|
|
$this->refreshPdfImportStatus();
|
|
}
|
|
}
|
|
|
|
public function convertLegacySqlToXml()
|
|
{
|
|
$this->validate([
|
|
'sqlDump' => ['required', 'file', 'mimes:sql,txt'],
|
|
]);
|
|
|
|
$content = file_get_contents($this->sqlDump->getRealPath());
|
|
$dataset = $this->legacySqlToDataset($content ?: '');
|
|
$xml = $this->datasetToXml($dataset, 'legacy-sql-conversion');
|
|
|
|
return response()->streamDownload(function () use ($xml) {
|
|
echo $xml;
|
|
}, 'termanager-conversion.xml', ['Content-Type' => 'application/xml; charset=UTF-8']);
|
|
}
|
|
|
|
public function importXmlIntoApp(): void
|
|
{
|
|
$this->importStats = [];
|
|
$this->importIssues = [];
|
|
|
|
$this->validate([
|
|
'xmlImport' => ['required', 'file', 'mimes:xml,txt'],
|
|
]);
|
|
|
|
$content = file_get_contents($this->xmlImport->getRealPath());
|
|
if (! $content) {
|
|
$this->addError('xmlImport', 'File XML non valido.');
|
|
return;
|
|
}
|
|
|
|
$xml = @simplexml_load_string($content);
|
|
if (! $xml) {
|
|
$this->addError('xmlImport', 'Impossibile leggere il file XML.');
|
|
return;
|
|
}
|
|
|
|
$actorId = auth()->id() ?? User::query()->value('id');
|
|
if (! $actorId) {
|
|
$this->addError('xmlImport', 'Serve almeno un utente nel sistema per importare i dati.');
|
|
return;
|
|
}
|
|
|
|
$stats = [
|
|
'zone_importate' => 0,
|
|
'tipologie_importate' => 0,
|
|
'proclamatori_importati' => 0,
|
|
'anni_importati' => 0,
|
|
'campagne_importate' => 0,
|
|
'territori_importati' => 0,
|
|
'assegnazioni_importate' => 0,
|
|
'duplicate_territori' => 0,
|
|
'assegnazioni_saltate' => 0,
|
|
];
|
|
|
|
DB::transaction(function () use ($xml, $actorId, &$stats) {
|
|
Assegnazione::query()->delete();
|
|
Campagna::query()->delete();
|
|
Territorio::query()->withTrashed()->forceDelete();
|
|
Proclamatore::query()->withTrashed()->forceDelete();
|
|
Tipologia::query()->delete();
|
|
Zona::query()->delete();
|
|
AnnoTeocratico::query()->delete();
|
|
Setting::query()->delete();
|
|
|
|
$settingsNode = $xml->settings;
|
|
if ($settingsNode) {
|
|
Setting::instance()->update([
|
|
'congregazione_nome' => (string) ($settingsNode->congregazione_nome ?? ''),
|
|
'giorni_giacenza_da_assegnare' => (int) ($settingsNode->giorni_giacenza_da_assegnare ?? 120),
|
|
'giorni_giacenza_prioritari' => (int) ($settingsNode->giorni_giacenza_prioritari ?? 180),
|
|
'giorni_per_smarrito' => (int) ($settingsNode->giorni_per_smarrito ?? 120),
|
|
'home_limit_list' => (int) ($settingsNode->home_limit_list ?? 10),
|
|
'assignment_link_ttl_hours' => (int) ($settingsNode->assignment_link_ttl_months ?? $settingsNode->assignment_link_ttl_hours ?? 1),
|
|
'audit_retention_days' => (int) ($settingsNode->audit_retention_days ?? 730),
|
|
'setup_completed' => true,
|
|
]);
|
|
}
|
|
|
|
$zoneMap = [];
|
|
foreach (($xml->zones->zone ?? []) as $zoneNode) {
|
|
$z = Zona::create([
|
|
'nome' => (string) $zoneNode->nome,
|
|
'attivo' => ((int) ($zoneNode->attivo ?? 1)) === 1,
|
|
]);
|
|
$stats['zone_importate']++;
|
|
$legacyId = (string) ($zoneNode['legacy_id'] ?? '');
|
|
if ($legacyId !== '') {
|
|
$zoneMap[$legacyId] = $z->id;
|
|
}
|
|
}
|
|
|
|
$tipologiaMap = [];
|
|
foreach (($xml->tipologie->tipologia ?? []) as $tipologiaNode) {
|
|
$t = Tipologia::create([
|
|
'nome' => (string) $tipologiaNode->nome,
|
|
'attivo' => ((int) ($tipologiaNode->attivo ?? 1)) === 1,
|
|
]);
|
|
$stats['tipologie_importate']++;
|
|
$legacyId = (string) ($tipologiaNode['legacy_id'] ?? '');
|
|
if ($legacyId !== '') {
|
|
$tipologiaMap[$legacyId] = $t->id;
|
|
}
|
|
}
|
|
|
|
$proclamatoreMap = [];
|
|
foreach (($xml->proclamatori->proclamatore ?? []) as $proclamatoreNode) {
|
|
$p = Proclamatore::create([
|
|
'nome' => (string) $proclamatoreNode->nome,
|
|
'cognome' => (string) $proclamatoreNode->cognome,
|
|
'attivo' => ((int) ($proclamatoreNode->attivo ?? 1)) === 1,
|
|
]);
|
|
$stats['proclamatori_importati']++;
|
|
$legacyId = (string) ($proclamatoreNode['legacy_id'] ?? '');
|
|
if ($legacyId !== '') {
|
|
$proclamatoreMap[$legacyId] = $p->id;
|
|
}
|
|
}
|
|
|
|
$annoMap = [];
|
|
foreach (($xml->anni_teocratici->anno ?? []) as $annoNode) {
|
|
$label = (string) $annoNode->label;
|
|
$anno = AnnoTeocratico::create([
|
|
'label' => $label,
|
|
'start_date' => (string) $annoNode->start_date,
|
|
'end_date' => (string) $annoNode->end_date,
|
|
]);
|
|
$stats['anni_importati']++;
|
|
$legacyId = (string) ($annoNode['legacy_id'] ?? '');
|
|
if ($legacyId !== '') {
|
|
$annoMap[$legacyId] = $anno->id;
|
|
}
|
|
}
|
|
|
|
$campagnaMap = [];
|
|
foreach (($xml->campagne->campagna ?? []) as $campagnaNode) {
|
|
$campagna = Campagna::create([
|
|
'descrizione' => (string) $campagnaNode->descrizione,
|
|
'start_date' => (string) $campagnaNode->start_date,
|
|
'end_date' => (string) $campagnaNode->end_date,
|
|
]);
|
|
$stats['campagne_importate']++;
|
|
$legacyId = (string) ($campagnaNode['legacy_id'] ?? '');
|
|
if ($legacyId !== '') {
|
|
$campagnaMap[$legacyId] = $campagna->id;
|
|
}
|
|
}
|
|
|
|
$territorioMap = [];
|
|
$territoriNumeroVisti = [];
|
|
foreach (($xml->territori->territorio ?? []) as $territorioNode) {
|
|
$legacyZonaId = (string) ($territorioNode->legacy_zona_id ?? '');
|
|
$legacyTipologiaId = (string) ($territorioNode->legacy_tipologia_id ?? '');
|
|
$numero = trim((string) $territorioNode->numero);
|
|
$legacyId = (string) ($territorioNode['legacy_id'] ?? '');
|
|
|
|
if ($numero === '' || isset($territoriNumeroVisti[$numero])) {
|
|
$stats['duplicate_territori']++;
|
|
$this->pushImportIssue('territorio', $legacyId, 'Territorio duplicato o numero vuoto (numero=' . ($numero !== '' ? $numero : 'vuoto') . ')');
|
|
continue;
|
|
}
|
|
|
|
if (!isset($zoneMap[$legacyZonaId], $tipologiaMap[$legacyTipologiaId])) {
|
|
$this->pushImportIssue('territorio', $legacyId, 'Riferimento zona/tipologia non trovato (zona=' . $legacyZonaId . ', tipologia=' . $legacyTipologiaId . ')');
|
|
continue;
|
|
}
|
|
|
|
$territorio = Territorio::create([
|
|
'numero' => $numero,
|
|
'zona_id' => $zoneMap[$legacyZonaId],
|
|
'tipologia_id' => $tipologiaMap[$legacyTipologiaId],
|
|
'confini' => (string) ($territorioNode->confini ?? ''),
|
|
'note' => (string) ($territorioNode->note ?? ''),
|
|
'attivo' => ((int) ($territorioNode->attivo ?? 1)) === 1,
|
|
'prioritario' => ((int) ($territorioNode->prioritario ?? 0)) === 1,
|
|
]);
|
|
|
|
$territoriNumeroVisti[$numero] = true;
|
|
$stats['territori_importati']++;
|
|
|
|
if ($legacyId !== '') {
|
|
$territorioMap[$legacyId] = $territorio->id;
|
|
}
|
|
}
|
|
|
|
foreach (($xml->assegnazioni->assegnazione ?? []) as $assegnazioneNode) {
|
|
$legacyTerritorio = (string) ($assegnazioneNode->legacy_territorio_id ?? '');
|
|
$legacyProclamatore = (string) ($assegnazioneNode->legacy_proclamatore_id ?? '');
|
|
$legacyAnno = (string) ($assegnazioneNode->legacy_anno_id ?? '');
|
|
$legacyId = (string) ($assegnazioneNode['legacy_id'] ?? '');
|
|
$assignedAt = $this->normalizeDateForDb((string) ($assegnazioneNode->assigned_at ?? ''), false);
|
|
$returnedAt = $this->normalizeDateForDb((string) ($assegnazioneNode->returned_at ?? ''), true);
|
|
|
|
if (!isset($territorioMap[$legacyTerritorio], $proclamatoreMap[$legacyProclamatore], $annoMap[$legacyAnno])) {
|
|
$stats['assegnazioni_saltate']++;
|
|
$this->pushImportIssue('assegnazione', $legacyId, 'Riferimenti mancanti (territorio=' . $legacyTerritorio . ', proclamatore=' . $legacyProclamatore . ', anno=' . $legacyAnno . ')');
|
|
continue;
|
|
}
|
|
|
|
if ($assignedAt === null) {
|
|
$stats['assegnazioni_saltate']++;
|
|
$this->pushImportIssue('assegnazione', $legacyId, 'Data assigned_at non valida o vuota');
|
|
continue;
|
|
}
|
|
|
|
$legacyCampagna = (string) ($assegnazioneNode->legacy_campagna_id ?? '');
|
|
|
|
Assegnazione::create([
|
|
'territorio_id' => $territorioMap[$legacyTerritorio],
|
|
'proclamatore_id' => $proclamatoreMap[$legacyProclamatore],
|
|
'anno_teocratico_id' => $annoMap[$legacyAnno],
|
|
'assigned_at' => $assignedAt,
|
|
'returned_at' => $returnedAt,
|
|
'counted_in_campaign' => ((int) ($assegnazioneNode->counted_in_campaign ?? 0)) === 1,
|
|
'campaign_id' => $legacyCampagna !== '' && isset($campagnaMap[$legacyCampagna]) ? $campagnaMap[$legacyCampagna] : null,
|
|
'note' => (string) ($assegnazioneNode->note ?? ''),
|
|
'created_by' => $actorId,
|
|
'returned_by' => $returnedAt !== null ? $actorId : null,
|
|
]);
|
|
$stats['assegnazioni_importate']++;
|
|
}
|
|
});
|
|
|
|
$this->importStats = $stats;
|
|
|
|
$message = 'Import XML completato con successo.';
|
|
if ($stats['duplicate_territori'] > 0 || $stats['assegnazioni_saltate'] > 0) {
|
|
$message .= ' Territori duplicati saltati: ' . $stats['duplicate_territori'] . '. Assegnazioni saltate: ' . $stats['assegnazioni_saltate'] . '.';
|
|
}
|
|
|
|
session()->flash('success', $message);
|
|
}
|
|
|
|
public function importTerritoryPdfFolder(): void
|
|
{
|
|
$this->validate([
|
|
'pdfFolder' => ['required', 'array', 'min:1'],
|
|
'pdfFolder.*' => ['file', 'mimes:pdf', 'max:10240'],
|
|
]);
|
|
|
|
$importId = (string) Str::uuid();
|
|
$storedFiles = [];
|
|
|
|
foreach ($this->pdfFolder as $index => $file) {
|
|
$originalName = $file->getClientOriginalName();
|
|
$safeName = Str::slug(pathinfo($originalName, PATHINFO_FILENAME));
|
|
$extension = strtolower($file->getClientOriginalExtension() ?: 'pdf');
|
|
$storedPath = $file->storeAs(
|
|
'bulk-territori-imports/' . $importId,
|
|
str_pad((string) $index, 4, '0', STR_PAD_LEFT) . '-' . $safeName . '.' . $extension,
|
|
'local'
|
|
);
|
|
|
|
$storedFiles[] = [
|
|
'original_name' => $originalName,
|
|
'stored_path' => $storedPath,
|
|
];
|
|
}
|
|
|
|
$this->pdfFolder = [];
|
|
|
|
}
|
|
|
|
public function refreshPdfImportStatus(): void
|
|
{
|
|
if (! $this->currentPdfImportId) {
|
|
return;
|
|
}
|
|
|
|
$state = app(TerritorioPdfImportState::class)->get($this->currentPdfImportId);
|
|
|
|
if (! $state) {
|
|
return;
|
|
}
|
|
|
|
$this->pdfImportStatus = $state['status'] ?? 'idle';
|
|
$this->pdfImportStats = $state['stats'] ?? [];
|
|
$this->pdfImportLogs = $state['logs'] ?? [];
|
|
$this->pdfImportIssues = $state['issues'] ?? [];
|
|
$this->pdfImportLogText = implode(PHP_EOL, $this->pdfImportLogs);
|
|
}
|
|
|
|
protected function dispatchPdfImport(string $importId, array $storedFiles, string $initialLog): void
|
|
{
|
|
$state = app(TerritorioPdfImportDispatcher::class)
|
|
->dispatchStoredFiles($importId, $storedFiles, auth()->id(), $initialLog);
|
|
|
|
$this->currentPdfImportId = $importId;
|
|
$this->pdfImportStatus = $state['status'] ?? 'queued';
|
|
$this->pdfImportStats = $state['stats'] ?? [];
|
|
$this->pdfImportLogs = $state['logs'] ?? [];
|
|
$this->pdfImportIssues = $state['issues'] ?? [];
|
|
$this->refreshPdfImportStatus();
|
|
|
|
session()->flash('success', 'Import PDF avviato in background. I log si aggiorneranno automaticamente.');
|
|
}
|
|
|
|
public function downloadImportLogPdf()
|
|
{
|
|
if (empty($this->importStats)) {
|
|
session()->flash('error', 'Nessun log da scaricare. Esegui prima un import XML.');
|
|
return;
|
|
}
|
|
|
|
$stats = $this->importStats;
|
|
$issues = $this->importIssues;
|
|
$generatedAt = now()->format('d/m/Y H:i:s');
|
|
|
|
$html = view('pdf.import-log', compact('stats', 'issues', 'generatedAt'))->render();
|
|
|
|
return response()->streamDownload(function () use ($html) {
|
|
echo Pdf::loadHTML($html)
|
|
->setPaper('a4', 'portrait')
|
|
->output();
|
|
}, 'import-log-' . now()->format('Ymd-His') . '.pdf', ['Content-Type' => 'application/pdf']);
|
|
}
|
|
|
|
public function exportCurrentAsXml()
|
|
{
|
|
$dataset = $this->currentDataset();
|
|
$xml = $this->datasetToXml($dataset, 'current-app-export');
|
|
|
|
return response()->streamDownload(function () use ($xml) {
|
|
echo $xml;
|
|
}, 'termanager-export.xml', ['Content-Type' => 'application/xml; charset=UTF-8']);
|
|
}
|
|
|
|
public function render()
|
|
{
|
|
return view('livewire.settings.xml-exchange');
|
|
}
|
|
|
|
private function currentDataset(): array
|
|
{
|
|
$settings = Setting::instance();
|
|
|
|
return [
|
|
'settings' => [
|
|
'congregazione_nome' => (string) ($settings->congregazione_nome ?? ''),
|
|
'giorni_giacenza_da_assegnare' => (int) ($settings->giorni_giacenza_da_assegnare ?? 120),
|
|
'giorni_giacenza_prioritari' => (int) ($settings->giorni_giacenza_prioritari ?? 180),
|
|
'giorni_per_smarrito' => (int) ($settings->giorni_per_smarrito ?? 120),
|
|
'home_limit_list' => (int) ($settings->home_limit_list ?? 10),
|
|
'assignment_link_ttl_months' => (int) ($settings->assignment_link_ttl_hours ?? 1),
|
|
'audit_retention_days' => (int) ($settings->audit_retention_days ?? 730),
|
|
],
|
|
'zones' => Zona::query()->orderBy('id')->get(['id', 'nome', 'attivo'])->toArray(),
|
|
'tipologie' => Tipologia::query()->orderBy('id')->get(['id', 'nome', 'attivo'])->toArray(),
|
|
'proclamatori' => Proclamatore::query()->withTrashed()->orderBy('id')->get(['id', 'nome', 'cognome', 'attivo'])->toArray(),
|
|
'territori' => Territorio::query()->withTrashed()->orderBy('id')->get(['id', 'numero', 'zona_id', 'tipologia_id', 'confini', 'note', 'attivo', 'prioritario'])->toArray(),
|
|
'anni_teocratici' => AnnoTeocratico::query()->orderBy('id')->get(['id', 'label', 'start_date', 'end_date'])->toArray(),
|
|
'campagne' => Campagna::query()->orderBy('id')->get(['id', 'descrizione', 'start_date', 'end_date'])->toArray(),
|
|
'assegnazioni' => Assegnazione::query()->orderBy('id')->get(['id', 'territorio_id', 'proclamatore_id', 'anno_teocratico_id', 'campaign_id', 'assigned_at', 'returned_at', 'counted_in_campaign', 'note'])->toArray(),
|
|
];
|
|
}
|
|
|
|
private function legacySqlToDataset(string $sql): array
|
|
{
|
|
$rows = $this->extractInsertRows($sql);
|
|
|
|
$congregazione = $rows['congregazione'][0][1] ?? 'Congregazione';
|
|
$impostazioni = $rows['impostazioni'][0] ?? [1, 120, 10, 120];
|
|
|
|
$settings = [
|
|
'congregazione_nome' => (string) $congregazione,
|
|
'giorni_giacenza_da_assegnare' => (int) ($impostazioni[3] ?? 120),
|
|
'giorni_giacenza_prioritari' => (int) ($impostazioni[1] ?? 180),
|
|
'giorni_per_smarrito' => (int) ($impostazioni[3] ?? 120),
|
|
'home_limit_list' => (int) ($impostazioni[2] ?? 10),
|
|
'assignment_link_ttl_months' => 1,
|
|
'audit_retention_days' => 730,
|
|
];
|
|
|
|
$zones = [];
|
|
foreach (($rows['zona'] ?? []) as $r) {
|
|
$zones[] = [
|
|
'legacy_id' => (string) ($r[0] ?? ''),
|
|
'nome' => (string) ($r[1] ?? ''),
|
|
'attivo' => 1,
|
|
];
|
|
}
|
|
|
|
$tipologie = [];
|
|
foreach (($rows['tipologia'] ?? []) as $r) {
|
|
$tipologie[] = [
|
|
'legacy_id' => (string) ($r[0] ?? ''),
|
|
'nome' => (string) ($r[1] ?? ''),
|
|
'attivo' => 1,
|
|
];
|
|
}
|
|
|
|
$proclamatori = [];
|
|
foreach (($rows['proclamatore'] ?? []) as $r) {
|
|
$proclamatori[] = [
|
|
'legacy_id' => (string) ($r[0] ?? ''),
|
|
'cognome' => (string) ($r[1] ?? ''),
|
|
'nome' => (string) ($r[2] ?? ''),
|
|
'attivo' => ((int) ($r[3] ?? 1)) === 1 ? 1 : 0,
|
|
];
|
|
}
|
|
|
|
$territori = [];
|
|
foreach (($rows['territorio'] ?? []) as $r) {
|
|
$territori[] = [
|
|
'legacy_id' => (string) ($r[0] ?? ''),
|
|
'numero' => (string) ($r[1] ?? ''),
|
|
'legacy_tipologia_id' => (string) ($r[2] ?? ''),
|
|
'legacy_zona_id' => (string) ($r[3] ?? ''),
|
|
'confini' => (string) ($r[4] ?? ''),
|
|
'note' => (string) ($r[5] ?? ''),
|
|
'attivo' => ((int) ($r[8] ?? 1)) === 1 ? 1 : 0,
|
|
'prioritario' => ((int) ($r[11] ?? 0)) > 0 ? 1 : 0,
|
|
];
|
|
}
|
|
|
|
$anni = [];
|
|
foreach (($rows['annoServizio'] ?? []) as $r) {
|
|
$label = (string) ($r[1] ?? '');
|
|
[$startDate, $endDate] = $this->datesFromLegacyAnnoLabel($label);
|
|
$anni[] = [
|
|
'legacy_id' => (string) ($r[0] ?? ''),
|
|
'label' => str_replace(' - ', '-', $label),
|
|
'start_date' => $startDate,
|
|
'end_date' => $endDate,
|
|
];
|
|
}
|
|
|
|
$campagne = [];
|
|
foreach (($rows['campagna'] ?? []) as $r) {
|
|
$campagne[] = [
|
|
'legacy_id' => (string) ($r[0] ?? ''),
|
|
'descrizione' => (string) ($r[1] ?? ''),
|
|
'start_date' => $this->toDateOnly((string) ($r[2] ?? '')),
|
|
'end_date' => $this->toDateOnly((string) ($r[3] ?? '')),
|
|
];
|
|
}
|
|
|
|
$assegnazioni = [];
|
|
foreach (($rows['assegnazione'] ?? []) as $r) {
|
|
$assegnazioni[] = [
|
|
'legacy_id' => (string) ($r[0] ?? ''),
|
|
'legacy_territorio_id' => (string) ($r[1] ?? ''),
|
|
'legacy_proclamatore_id' => (string) ($r[2] ?? ''),
|
|
'legacy_anno_id' => (string) ($r[9] ?? ''),
|
|
'legacy_campagna_id' => $r[8] === null ? '' : (string) $r[8],
|
|
'assigned_at' => $this->toDateOnly((string) ($r[4] ?? '')),
|
|
'returned_at' => $this->toDateOnly((string) ($r[5] ?? '')),
|
|
'counted_in_campaign' => ((int) ($r[7] ?? 0)) === 1 ? 1 : 0,
|
|
'note' => '',
|
|
];
|
|
}
|
|
|
|
return [
|
|
'settings' => $settings,
|
|
'zones' => $zones,
|
|
'tipologie' => $tipologie,
|
|
'proclamatori' => $proclamatori,
|
|
'territori' => $territori,
|
|
'anni_teocratici' => $anni,
|
|
'campagne' => $campagne,
|
|
'assegnazioni' => $assegnazioni,
|
|
];
|
|
}
|
|
|
|
private function extractInsertRows(string $sql): array
|
|
{
|
|
$result = [];
|
|
preg_match_all('/INSERT INTO `([^`]+)` VALUES\s*(.+?);/s', $sql, $matches, PREG_SET_ORDER);
|
|
|
|
foreach ($matches as $match) {
|
|
$table = $match[1];
|
|
$valuesPayload = $match[2];
|
|
$tuples = $this->splitSqlTuples($valuesPayload);
|
|
|
|
foreach ($tuples as $tuple) {
|
|
$result[$table][] = $this->parseSqlTuple($tuple);
|
|
}
|
|
}
|
|
|
|
return $result;
|
|
}
|
|
|
|
private function splitSqlTuples(string $payload): array
|
|
{
|
|
$tuples = [];
|
|
$inString = false;
|
|
$escape = false;
|
|
$depth = 0;
|
|
$current = '';
|
|
|
|
$len = strlen($payload);
|
|
for ($i = 0; $i < $len; $i++) {
|
|
$ch = $payload[$i];
|
|
|
|
if ($inString) {
|
|
$current .= $ch;
|
|
if ($escape) {
|
|
$escape = false;
|
|
continue;
|
|
}
|
|
if ($ch === '\\\\') {
|
|
$escape = true;
|
|
continue;
|
|
}
|
|
if ($ch === "'") {
|
|
$inString = false;
|
|
}
|
|
continue;
|
|
}
|
|
|
|
if ($ch === "'") {
|
|
$inString = true;
|
|
$current .= $ch;
|
|
continue;
|
|
}
|
|
|
|
if ($ch === '(') {
|
|
if ($depth === 0) {
|
|
$current = '';
|
|
}
|
|
$depth++;
|
|
continue;
|
|
}
|
|
|
|
if ($ch === ')') {
|
|
$depth--;
|
|
if ($depth === 0) {
|
|
$tuples[] = $current;
|
|
$current = '';
|
|
continue;
|
|
}
|
|
}
|
|
|
|
if ($depth > 0) {
|
|
$current .= $ch;
|
|
}
|
|
}
|
|
|
|
return $tuples;
|
|
}
|
|
|
|
private function parseSqlTuple(string $tuple): array
|
|
{
|
|
$values = [];
|
|
$inString = false;
|
|
$escape = false;
|
|
$current = '';
|
|
|
|
$len = strlen($tuple);
|
|
for ($i = 0; $i < $len; $i++) {
|
|
$ch = $tuple[$i];
|
|
|
|
if ($inString) {
|
|
$current .= $ch;
|
|
if ($escape) {
|
|
$escape = false;
|
|
continue;
|
|
}
|
|
if ($ch === '\\\\') {
|
|
$escape = true;
|
|
continue;
|
|
}
|
|
if ($ch === "'") {
|
|
$inString = false;
|
|
}
|
|
continue;
|
|
}
|
|
|
|
if ($ch === "'") {
|
|
$inString = true;
|
|
$current .= $ch;
|
|
continue;
|
|
}
|
|
|
|
if ($ch === ',') {
|
|
$values[] = $this->normalizeSqlValue($current);
|
|
$current = '';
|
|
continue;
|
|
}
|
|
|
|
$current .= $ch;
|
|
}
|
|
|
|
if ($current !== '') {
|
|
$values[] = $this->normalizeSqlValue($current);
|
|
}
|
|
|
|
return $values;
|
|
}
|
|
|
|
private function normalizeSqlValue(string $raw)
|
|
{
|
|
$raw = trim($raw);
|
|
if (strcasecmp($raw, 'NULL') === 0) {
|
|
return null;
|
|
}
|
|
|
|
if (str_starts_with($raw, "'") && str_ends_with($raw, "'")) {
|
|
$v = substr($raw, 1, -1);
|
|
$v = str_replace(["\\\\", "\\'", '\\"', '\\n', '\\r', '\\t'], ['\\', "'", '"', "\n", "\r", "\t"], $v);
|
|
return html_entity_decode($v, ENT_QUOTES | ENT_HTML5, 'UTF-8');
|
|
}
|
|
|
|
if (is_numeric($raw)) {
|
|
return str_contains($raw, '.') ? (float) $raw : (int) $raw;
|
|
}
|
|
|
|
return $raw;
|
|
}
|
|
|
|
private function datesFromLegacyAnnoLabel(string $label): array
|
|
{
|
|
if (preg_match('/(\d{4})\s*-\s*(\d{4})/', $label, $m)) {
|
|
return [$m[1] . '-09-01', $m[2] . '-08-31'];
|
|
}
|
|
|
|
$now = Carbon::now();
|
|
return [$now->copy()->startOfYear()->toDateString(), $now->copy()->endOfYear()->toDateString()];
|
|
}
|
|
|
|
private function toDateOnly(string $dateTime): string
|
|
{
|
|
if ($dateTime === '') {
|
|
return '';
|
|
}
|
|
return substr($dateTime, 0, 10);
|
|
}
|
|
|
|
private function normalizeDateForDb(string $raw, bool $nullable): ?string
|
|
{
|
|
$raw = trim($raw);
|
|
if ($raw === '' || $raw === '0000-00-00' || $raw === '0000-00-00 00:00:00') {
|
|
return $nullable ? null : null;
|
|
}
|
|
|
|
try {
|
|
return Carbon::parse($raw)->toDateString();
|
|
} catch (\Throwable $e) {
|
|
return $nullable ? null : null;
|
|
}
|
|
}
|
|
|
|
private function pushImportIssue(string $entity, string $legacyId, string $reason): void
|
|
{
|
|
if (count($this->importIssues) >= 300) {
|
|
return;
|
|
}
|
|
|
|
$this->importIssues[] = [
|
|
'entity' => $entity,
|
|
'legacy_id' => $legacyId !== '' ? $legacyId : '-',
|
|
'reason' => $reason,
|
|
];
|
|
}
|
|
|
|
private function datasetToXml(array $dataset, string $source): string
|
|
{
|
|
$xml = new \SimpleXMLElement('<?xml version="1.0" encoding="UTF-8"?><termanager2/>');
|
|
$xml->addAttribute('version', '1.0');
|
|
$xml->addAttribute('source', $source);
|
|
$xml->addAttribute('generated_at', now()->toIso8601String());
|
|
|
|
$settings = $xml->addChild('settings');
|
|
foreach ($dataset['settings'] as $key => $value) {
|
|
$settings->addChild($key, htmlspecialchars((string) $value, ENT_QUOTES | ENT_XML1, 'UTF-8'));
|
|
}
|
|
|
|
$zonesNode = $xml->addChild('zones');
|
|
foreach ($dataset['zones'] as $zone) {
|
|
$node = $zonesNode->addChild('zone');
|
|
if (isset($zone['legacy_id'])) {
|
|
$node->addAttribute('legacy_id', (string) $zone['legacy_id']);
|
|
}
|
|
$node->addChild('nome', htmlspecialchars((string) ($zone['nome'] ?? ''), ENT_QUOTES | ENT_XML1, 'UTF-8'));
|
|
$node->addChild('attivo', (string) ((int) ($zone['attivo'] ?? 1)));
|
|
}
|
|
|
|
$tipologieNode = $xml->addChild('tipologie');
|
|
foreach ($dataset['tipologie'] as $tipologia) {
|
|
$node = $tipologieNode->addChild('tipologia');
|
|
if (isset($tipologia['legacy_id'])) {
|
|
$node->addAttribute('legacy_id', (string) $tipologia['legacy_id']);
|
|
}
|
|
$node->addChild('nome', htmlspecialchars((string) ($tipologia['nome'] ?? ''), ENT_QUOTES | ENT_XML1, 'UTF-8'));
|
|
$node->addChild('attivo', (string) ((int) ($tipologia['attivo'] ?? 1)));
|
|
}
|
|
|
|
$proclamatoriNode = $xml->addChild('proclamatori');
|
|
foreach ($dataset['proclamatori'] as $proclamatore) {
|
|
$node = $proclamatoriNode->addChild('proclamatore');
|
|
if (isset($proclamatore['legacy_id'])) {
|
|
$node->addAttribute('legacy_id', (string) $proclamatore['legacy_id']);
|
|
}
|
|
$node->addChild('nome', htmlspecialchars((string) ($proclamatore['nome'] ?? ''), ENT_QUOTES | ENT_XML1, 'UTF-8'));
|
|
$node->addChild('cognome', htmlspecialchars((string) ($proclamatore['cognome'] ?? ''), ENT_QUOTES | ENT_XML1, 'UTF-8'));
|
|
$node->addChild('attivo', (string) ((int) ($proclamatore['attivo'] ?? 1)));
|
|
}
|
|
|
|
$territoriNode = $xml->addChild('territori');
|
|
foreach ($dataset['territori'] as $territorio) {
|
|
$node = $territoriNode->addChild('territorio');
|
|
if (isset($territorio['legacy_id'])) {
|
|
$node->addAttribute('legacy_id', (string) $territorio['legacy_id']);
|
|
}
|
|
$node->addChild('numero', htmlspecialchars((string) ($territorio['numero'] ?? ''), ENT_QUOTES | ENT_XML1, 'UTF-8'));
|
|
$node->addChild('legacy_zona_id', (string) ($territorio['legacy_zona_id'] ?? ($territorio['zona_id'] ?? '')));
|
|
$node->addChild('legacy_tipologia_id', (string) ($territorio['legacy_tipologia_id'] ?? ($territorio['tipologia_id'] ?? '')));
|
|
$node->addChild('confini', htmlspecialchars((string) ($territorio['confini'] ?? ''), ENT_QUOTES | ENT_XML1, 'UTF-8'));
|
|
$node->addChild('note', htmlspecialchars((string) ($territorio['note'] ?? ''), ENT_QUOTES | ENT_XML1, 'UTF-8'));
|
|
$node->addChild('attivo', (string) ((int) ($territorio['attivo'] ?? 1)));
|
|
$node->addChild('prioritario', (string) ((int) ($territorio['prioritario'] ?? 0)));
|
|
}
|
|
|
|
$anniNode = $xml->addChild('anni_teocratici');
|
|
foreach ($dataset['anni_teocratici'] as $anno) {
|
|
$node = $anniNode->addChild('anno');
|
|
if (isset($anno['legacy_id'])) {
|
|
$node->addAttribute('legacy_id', (string) $anno['legacy_id']);
|
|
}
|
|
$node->addChild('label', htmlspecialchars((string) ($anno['label'] ?? ''), ENT_QUOTES | ENT_XML1, 'UTF-8'));
|
|
$node->addChild('start_date', (string) ($anno['start_date'] ?? ''));
|
|
$node->addChild('end_date', (string) ($anno['end_date'] ?? ''));
|
|
}
|
|
|
|
$campagneNode = $xml->addChild('campagne');
|
|
foreach ($dataset['campagne'] as $campagna) {
|
|
$node = $campagneNode->addChild('campagna');
|
|
if (isset($campagna['legacy_id'])) {
|
|
$node->addAttribute('legacy_id', (string) $campagna['legacy_id']);
|
|
}
|
|
$node->addChild('descrizione', htmlspecialchars((string) ($campagna['descrizione'] ?? ''), ENT_QUOTES | ENT_XML1, 'UTF-8'));
|
|
$node->addChild('start_date', (string) ($campagna['start_date'] ?? ''));
|
|
$node->addChild('end_date', (string) ($campagna['end_date'] ?? ''));
|
|
}
|
|
|
|
$assegnazioniNode = $xml->addChild('assegnazioni');
|
|
foreach ($dataset['assegnazioni'] as $assegnazione) {
|
|
$node = $assegnazioniNode->addChild('assegnazione');
|
|
if (isset($assegnazione['legacy_id'])) {
|
|
$node->addAttribute('legacy_id', (string) $assegnazione['legacy_id']);
|
|
}
|
|
$node->addChild('legacy_territorio_id', (string) ($assegnazione['legacy_territorio_id'] ?? ($assegnazione['territorio_id'] ?? '')));
|
|
$node->addChild('legacy_proclamatore_id', (string) ($assegnazione['legacy_proclamatore_id'] ?? ($assegnazione['proclamatore_id'] ?? '')));
|
|
$node->addChild('legacy_anno_id', (string) ($assegnazione['legacy_anno_id'] ?? ($assegnazione['anno_teocratico_id'] ?? '')));
|
|
$node->addChild('legacy_campagna_id', (string) ($assegnazione['legacy_campagna_id'] ?? ($assegnazione['campaign_id'] ?? '')));
|
|
$node->addChild('assigned_at', (string) ($assegnazione['assigned_at'] ?? ''));
|
|
$node->addChild('returned_at', (string) ($assegnazione['returned_at'] ?? ''));
|
|
$node->addChild('counted_in_campaign', (string) ((int) ($assegnazione['counted_in_campaign'] ?? 0)));
|
|
$node->addChild('note', htmlspecialchars((string) ($assegnazione['note'] ?? ''), ENT_QUOTES | ENT_XML1, 'UTF-8'));
|
|
}
|
|
|
|
return $xml->asXML() ?: '';
|
|
}
|
|
}
|