Setup Coda d'Import CSV

🎯 Panoramica

La Coda d'Import è il sistema centrale per gestire i CSV che arrivano dalle macchine Industria 4.0. Permette di:

Scansionare cartelle per nuovi CSV
Validare CSV contro profili
Elaborare CSV (import dati)
Gestire errori e retry
Monitorare stato elaborazioni

Modalità: MANUALE (Ora)

---

📊 Database

Tabella: `csv_imports`

Traccia ogni CSV dal momento dell'arrivo fino al completamento (o fallimento).

Campi Principali:

machine_id, profile_id - Associazioni
filename, file_path, file_hash - Info file
source_channel - Provenienza (upload, api, watch_folder...)
status - pending→validating→validated→processing→completed
is_valid - Risultato validazione (NULL/TRUE/FALSE)
rows_total, rows_processed, rows_failed - Statistiche
retry_count - Numero tentativi
validated_by, processed_by - Chi ha eseguito (NULL = automatico)

Installazione

``bash mysql -u root -p capera_sartupDB < database/sql/create_csv_imports_table.sql`

---

`🏗️ Architettura`

`Services (Business Logic)`

CsvScannerService

php
scanForNewCsvs()           // Scansiona tutte le cartelle
scanMachinePath($machine)  // Scansiona path specifico
registerCsv($file, ...)    // Registra CSV in database
getScanStats()             // Statistiche scansione

Cosa fa: Trova CSV nelle cartelle connettore_I40/csv_I40_X_Y/ e li registra in csv_imports.

CsvValidatorService

php
validate($csvImport): ValidationResult

Cosa fa: 1. Verifica file esista 2. Legge CSV con League\Csv 3. Verifica colonne corrispondano al profilo 4. Conta righe 5. RestituisceValidationResult (isValid, errors, rowsCount)

⭐ RIUSABILE: Chiamato sia da Controller (manuale) che da Job (futuro automatico)

CsvProcessorService

php
process($csvImport): ProcessingResult

Cosa fa: 1. Legge CSV validato 2. Elabora riga per riga 3. Importa dati (TODO: definire destinazione) 4. RestituisceProcessingResult (success, rowsProcessed, rowsFailed)

⭐ RIUSABILE: Chiamato sia da Controller (manuale) che da Job (futuro automatico)

---

`🎮 Controller`

CsvImportsController

</h3></p><p>| Metodo | Route | Descrizione |
|--------|-------|-------------|
| </code>index()<code> | GET </code>/csv-imports<code> | Lista CSV con filtri |
| </code>scanNewCsvs()<code> | POST </code>/csv-imports/scan<code> | Scansiona manualmente |
| </code>show($id)<code> | GET </code>/csv-imports/{id}<code> | Dettagli JSON |
| </code>validate($id)<code> | POST </code>/csv-imports/{id}/validate<code> | Valida CSV |
| </code>process($id)<code> | POST </code>/csv-imports/{id}/process<code> | Elabora CSV |
| </code>pause($id)<code> | POST </code>/csv-imports/{id}/pause<code> | Metti in pausa |
| </code>resume($id)<code> | POST </code>/csv-imports/{id}/resume<code> | Riprendi |
| </code>retry($id)<code> | POST </code>/csv-imports/{id}/retry<code> | Riprova |
| </code>destroy($id)<code> | DELETE </code>/csv-imports/{id}<code> | Elimina |</p><p>---</p><p><h2>🎨 Vista</h2></p><p><h3>Layout</h3></p><p></code>`<code>
┌─────────────────────────────────────────────────────────────┐
│  [🔍 Scansiona Nuovi CSV] [⚙️ Configurazione]              │
├─────────────────────────────────────────────────────────────┤
│  📊 [In Attesa: 12] [Validati: 45] [Pausa: 3] [Falliti: 2]│
├─────────────────────────────────────────────────────────────┤
│  Filtri: [Macchina ▼] [Stato ▼] [Canale ▼]                │
├─────────────────────────────────────────────────────────────┤
│  📋 Tabella CSV                                             │
└─────────────────────────────────────────────────────────────┘

</p><p><h3>Azioni per Stato</h3></p><p>| Stato | Azioni Disponibili |
|-------|--------------------|
| </code>pending<code> | 👁️ Dettagli, ✓ Valida, ⏸️ Pausa, 🗑️ Elimina |
|

validated

| 👁️ Dettagli, ▶️ Elabora, ⏸️ Pausa, 🗑️ Elimina |
|

paused

 | 👁️ Dettagli, ▶️ Riprendi, 🗑️ Elimina |
|

failed

 | 👁️ Dettagli, 🔄 Riprova, 🗑️ Elimina |
|

completed

 | 👁️ Dettagli, 🗑️ Elimina |
---
🔄 Stati del CSV

pending → validating → validated → processing → completed
   ↓          ↓            ↓           ↓
 failed ← failed      paused ←   failed
   ↑                    ↓           ↑
   └─── retry ─────── resume ─── retry


Descrizione Stati:
1. pending - Appena trovato, in attesa validazione
2. validating - Validazione in corso
3. validated - Validato OK, pronto per elaborazione
4. paused - Messo in pausa dall'utente
5. processing - Elaborazione in corso
6. completed - Elaborazione completata con successo
7. failed - Validazione o elaborazione fallita
---
🚀 Workflow Utente
1. Scansiona Nuovi CSV

`Click "Scansiona Nuovi CSV" ↓ Sistema cerca in tutte le cartelle csv_I40_X_Y/ ↓ Registra nuovi CSV trovati (status: pending) ↓ Toast: "Trovati X nuovi CSV!"`

</p><p><h3>2. Valida CSV</h3></p><p></code>`<code>
Click ✓ su riga CSV pending
    ↓
CsvValidatorService::validate()
    ├─ Verifica colonne
    ├─ Conta righe
    └─ Cerca errori
    ↓
Status: validated (OK) o failed (KO)
    ↓
Toast: &quot;CSV validato!&quot; o &quot;Validazione fallita: X errori&quot;

</p><p><h3>3. Elabora CSV</h3></p><p></code>`<code>
Click ▶️ su riga CSV validated
    ↓
CsvProcessorService::process()
    ├─ Legge righe
    ├─ Importa dati (TODO)
    └─ Traccia successi/fallimenti
    ↓
Status: completed (OK) o failed (KO)
    ↓
Toast: &quot;Elaborazione completata! X righe importate&quot;

</p><p><h3>4. Gestione Errori</h3></p><p></code>`<code>
Se failed:
    ├─ Click 👁️ → Vedi errori dettagliati
    ├─ Correggi CSV manualmente
    ├─ Click 🔄 Riprova
    └─ Oppure 🗑️ Elimina


---
📋 Installazione
1. Database

bash
mysql -u root -p capera_sartupDB < database/sql/create_csv_imports_table.sql


2. Voce Menù

sql
UPDATE menu_items 
SET route_name = 'admin.i40.csv-imports.index'
WHERE label = 'Coda d\'import' 
  AND parent_id = (SELECT id FROM (SELECT id FROM menu_items WHERE label = 'Industria 4.0') AS tmp);


3. Test


/admin/i40/csv-imports


---
🧪 Test Manuale
Prepara CSV di Test

`bash

`1. Trova una cartella CSV esistente`


ls -la storage/app/connettore_I40/
2. Copia un CSV di test
cp test.csv storage/app/connettore_I40/csv_I40_1_1/sample.csv


Testa Workflow

1. Vai a /admin/i40/csv-imports2. Click "Scansiona Nuovi CSV" 3. Dovresti vederesample.csvin coda (status: pending) 4. Click ✓ per validare 5. Se OK: Click ▶️ per elaborare 6. Click 👁️ per vedere dettagli

---

`🔧 Troubleshooting`

`CSV Non Trovati dalla Scansione`

Verifica:`bash

`1. Cartelle esistono?`


ls -la storage/app/connettore_I40/
2. CSV presenti?
find storage/app/connettore_I40/ -name "*.csv"
3. Permessi corretti?
chmod -R 755 storage/app/connettore_I40/


Validazione Sempre Fallisce
Verifica:
Profilo ha colonne definite?

CSV ha header se has_header = 1?


Delimitatore corretto nel profilo?
Encoding corretto?

Debug:`php // In CsvValidatorService, aggiungi: Log::debug('CSV Headers: ' . json_encode($csvHeaders)); Log::debug('Expected: ' . json_encode($expectedColumns));`

---

`📂 File Implementati`

`Backend`

✅ app/Models/I40/CsvImport.php

✅ app/Services/I40/CsvScannerService.php

✅ app/Services/I40/CsvValidatorService.php

✅ app/Services/I40/CsvProcessorService.php

✅ app/Http/Controllers/Admin/I40/CsvImportsController.php

`Routes`

✅ routes/i40.php (gruppo csv-imports)

`Views`

✅ resources/views/admin/i40/csv-imports/index.blade.php

`Database`

✅ database/sql/create_csv_imports_table.sql

---

`🚀 Prossimi Sviluppi`

`Fase 1 (Completata): Gestione Manuale ✅`


Scansione manuale
Validazione manuale
Elaborazione manuale
Fase 2 (Futuro): Upload Web
Form upload CSV diretto
Selezione macchina/profilo
Salvataggio automatico in cartella corretta
Fase 3 (Futuro): Automazione
Jobs per elaborazione background
Queue Worker
Scheduler per scansione automatica
Fase 4 (Futuro): Logica Import
Definire dove vanno i dati elaborati

Implementare CsvProcessorService::importRow()`
Gestione transazioni

---

Ultimo aggiornamento: 17 Ottobre 2025

Analisi Codice

Blocco 1 bash

mysql -u root -p capera_sartupDB < database/sql/create_csv_imports_table.sql

Blocco 2 php

scanForNewCsvs()           // Scansiona tutte le cartelle
scanMachinePath($machine)  // Scansiona path specifico
registerCsv($file, ...)    // Registra CSV in database
getScanStats()             // Statistiche scansione

Blocco 3 php

validate($csvImport): ValidationResult

Blocco 4 php

process($csvImport): ProcessingResult

Blocco 5

┌─────────────────────────────────────────────────────────────┐
│  [🔍 Scansiona Nuovi CSV] [⚙️ Configurazione]              │
├─────────────────────────────────────────────────────────────┤
│  📊 [In Attesa: 12] [Validati: 45] [Pausa: 3] [Falliti: 2]│
├─────────────────────────────────────────────────────────────┤
│  Filtri: [Macchina ▼] [Stato ▼] [Canale ▼]                │
├─────────────────────────────────────────────────────────────┤
│  📋 Tabella CSV                                             │
└─────────────────────────────────────────────────────────────┘

Blocco 6

pending → validating → validated → processing → completed
   ↓          ↓            ↓           ↓
 failed ← failed      paused ←   failed
   ↑                    ↓           ↑
   └─── retry ─────── resume ─── retry

Blocco 7

Click "Scansiona Nuovi CSV"
    ↓
Sistema cerca in tutte le cartelle csv_I40_X_Y/
    ↓
Registra nuovi CSV trovati (status: pending)
    ↓
Toast: "Trovati X nuovi CSV!"

Blocco 8

Click ✓ su riga CSV pending
    ↓
CsvValidatorService::validate()
    ├─ Verifica colonne
    ├─ Conta righe
    └─ Cerca errori
    ↓
Status: validated (OK) o failed (KO)
    ↓
Toast: "CSV validato!" o "Validazione fallita: X errori"

Blocco 9

Click ▶️ su riga CSV validated
    ↓
CsvProcessorService::process()
    ├─ Legge righe
    ├─ Importa dati (TODO)
    └─ Traccia successi/fallimenti
    ↓
Status: completed (OK) o failed (KO)
    ↓
Toast: "Elaborazione completata! X righe importate"

Blocco 10

Se failed:
    ├─ Click 👁️ → Vedi errori dettagliati
    ├─ Correggi CSV manualmente
    ├─ Click 🔄 Riprova
    └─ Oppure 🗑️ Elimina

Blocco 11 bash

mysql -u root -p capera_sartupDB < database/sql/create_csv_imports_table.sql

Blocco 12 sql

UPDATE menu_items 
SET route_name = 'admin.i40.csv-imports.index'
WHERE label = 'Coda d\'import' 
  AND parent_id = (SELECT id FROM (SELECT id FROM menu_items WHERE label = 'Industria 4.0') AS tmp);

Blocco 13

/admin/i40/csv-imports

Blocco 14 bash

# 1. Trova una cartella CSV esistente
ls -la storage/app/connettore_I40/

# 2. Copia un CSV di test
cp test.csv storage/app/connettore_I40/csv_I40_1_1/sample.csv

Blocco 15 bash

# 1. Cartelle esistono?
ls -la storage/app/connettore_I40/

# 2. CSV presenti?
find storage/app/connettore_I40/ -name "*.csv"

# 3. Permessi corretti?
chmod -R 755 storage/app/connettore_I40/

Blocco 16 php

// In CsvValidatorService, aggiungi:
Log::debug('CSV Headers: ' . json_encode($csvHeaders));
Log::debug('Expected: ' . json_encode($expectedColumns));

Indice

Info Documento

Setup Coda d'Import CSV

Setup Coda d'Import CSV

🎯 Panoramica

Modalità: MANUALE (Ora)

📊 Database

Tabella: csv_imports

Campi Principali:

Installazione

🏗️ Architettura

Services (Business Logic)

CsvScannerService

CsvValidatorService

CsvProcessorService

🎮 Controller

🔄 Stati del CSV

Descrizione Stati:

🚀 Workflow Utente

1. Scansiona Nuovi CSV

📋 Installazione

1. Database

2. Voce Menù

3. Test

🧪 Test Manuale

Prepara CSV di Test

1. Trova una cartella CSV esistente

2. Copia un CSV di test

Testa Workflow

🔧 Troubleshooting

CSV Non Trovati dalla Scansione

1. Cartelle esistono?

2. CSV presenti?

3. Permessi corretti?

Validazione Sempre Fallisce

📂 File Implementati

Backend

Routes

Views

Database

🚀 Prossimi Sviluppi

Fase 1 (Completata): Gestione Manuale ✅

Fase 2 (Futuro): Upload Web

Fase 3 (Futuro): Automazione

Fase 4 (Futuro): Logica Import

Analisi Codice

Blocco 1 bash

Blocco 2 php

Blocco 3 php

Blocco 4 php

Blocco 5

Blocco 6

Blocco 7

Blocco 8

Blocco 9

Blocco 10

Blocco 11 bash

Blocco 12 sql

Blocco 13

Blocco 14 bash

Blocco 15 bash

Blocco 16 php

Documenti Correlati

Indice

Info Rapide

Documenti Correlati

Screenshot

Tabella: `csv_imports`

`🏗️ Architettura`

`Services (Business Logic)`

`🎮 Controller`

`1. Trova una cartella CSV esistente`

`🔧 Troubleshooting`

`CSV Non Trovati dalla Scansione`

`1. Cartelle esistono?`

`📂 File Implementati`

`Backend`

`Routes`

`Views`

`Database`

`🚀 Prossimi Sviluppi`

`Fase 1 (Completata): Gestione Manuale ✅`