ticket migration
This commit is contained in:
@@ -1,4 +1,9 @@
|
||||
import 'dart:convert';
|
||||
|
||||
import 'package:cloud_firestore/cloud_firestore.dart';
|
||||
import 'package:flutter/material.dart';
|
||||
import 'package:flux/core/blocs/session/session_cubit.dart';
|
||||
import 'package:get_it/get_it.dart';
|
||||
import 'package:supabase_flutter/supabase_flutter.dart';
|
||||
|
||||
Future<void> migrateCustomersToSupabase() async {
|
||||
@@ -147,125 +152,185 @@ Future<void> migrateModelsToSupabase() async {
|
||||
}
|
||||
}
|
||||
|
||||
Future<void> migrateTicketsToSupabase() async {
|
||||
final String myRealCompanyId = '6c4b2323-2a60-4d33-bf21-c5a8eb6b4a5b';
|
||||
final String myRealStoreId = '782a4638-1c03-40af-9060-9ef214a3e238';
|
||||
class TicketMigrationScript {
|
||||
final SupabaseClient supabase = Supabase.instance.client;
|
||||
final String companyId = GetIt.I.get<SessionCubit>().state.company!.id!;
|
||||
final String storeId = GetIt.I.get<SessionCubit>().state.currentStore!.id!;
|
||||
|
||||
try {
|
||||
print("Inizio migrazione Ticket...");
|
||||
/// Esegui questa funzione passandole la stringa JSON grezza (es. copiata da un file)
|
||||
/// e l'ID della tua Company su Supabase (visto che Firebase non lo aveva).
|
||||
Future<void> runMigration(String jsonString) async {
|
||||
debugPrint('🚀 INIZIO MIGRAZIONE TICKET...');
|
||||
|
||||
// ==========================================================
|
||||
// FASE 1: CREAZIONE DEL DIZIONARIO DI TRADUZIONE (LA MAGIA)
|
||||
// ==========================================================
|
||||
print("Scarico i Brand da Supabase per tradurre gli ID...");
|
||||
try {
|
||||
// 1. Parsing del JSON
|
||||
final Map<String, dynamic> decoded = jsonDecode(jsonString);
|
||||
// Scendiamo al piano di sotto, direttamente nella "pancia" dei dati!
|
||||
final Map<String, dynamic> rawData = decoded['data'];
|
||||
|
||||
// Chiediamo a Supabase solo 2 colonne: il nuovo UUID e il vecchio ID di Firebase
|
||||
final List<dynamic> customerResponse = await Supabase.instance.client
|
||||
.from('customer')
|
||||
.select('id, legacy_id');
|
||||
|
||||
// Creiamo la mappa: la chiave è il vecchio ID, il valore è il nuovo UUID
|
||||
Map<String, String> customerTranslationMap = {};
|
||||
for (var b in customerResponse) {
|
||||
if (b['legacy_id'] != null) {
|
||||
customerTranslationMap[b['legacy_id']] = b['id'];
|
||||
}
|
||||
}
|
||||
|
||||
final List<dynamic> modelResponse = await Supabase.instance.client
|
||||
.from('model')
|
||||
.select('id, legacy_id');
|
||||
|
||||
Map<String, String> modelTranslationMap = {};
|
||||
for (var b in modelResponse) {
|
||||
if (b['legacy_id'] != null) {
|
||||
modelTranslationMap[b['legacy_id']] = b['id'];
|
||||
}
|
||||
}
|
||||
|
||||
print(
|
||||
"Dizionario pronto! Trovati ${customerTranslationMap.length} clienti e ${modelTranslationMap.length} modelli.",
|
||||
);
|
||||
|
||||
// ==========================================================
|
||||
// FASE 2: SCARICAMENTO E TRADUZIONE DEI MODELLI
|
||||
// ==========================================================
|
||||
final snapshot = await FirebaseFirestore.instance
|
||||
.collection('schedeRiparazione')
|
||||
.get(); // Controlla il nome esatto della collection!
|
||||
|
||||
if (snapshot.docs.isEmpty) {
|
||||
print("Nessun scheda trovato su Firebase!");
|
||||
return;
|
||||
}
|
||||
|
||||
List<Map<String, dynamic>> supabaseTickets = [];
|
||||
|
||||
for (var doc in snapshot.docs) {
|
||||
final data = doc.data();
|
||||
|
||||
// 1. Prendiamo il vecchio ID del brand salvato su Firebase
|
||||
String? oldFirebaseCustomerId = data['idCliente'];
|
||||
String? oldFirebaseModelId = data['idModello'];
|
||||
|
||||
// 2. TRADUZIONE ISTANTANEA! Cerchiamo il nuovo UUID nel nostro dizionario
|
||||
String? newSupabaseCustomerUuid;
|
||||
if (oldFirebaseCustomerId != null) {
|
||||
newSupabaseCustomerUuid = customerTranslationMap[oldFirebaseCustomerId];
|
||||
}
|
||||
|
||||
String? newSupabaseModelUuid;
|
||||
if (oldFirebaseModelId != null) {
|
||||
newSupabaseModelUuid = modelTranslationMap[oldFirebaseModelId];
|
||||
}
|
||||
|
||||
// 3. Controllo di sicurezza: se il brand non esiste su Supabase, saltiamo il record o mettiamo null?
|
||||
// Se nella tua tabella 'model' il 'brand_id' NON PUÒ essere null, devi per forza avere un match!
|
||||
if (newSupabaseCustomerUuid == null &&
|
||||
newSupabaseModelUuid == null &&
|
||||
oldFirebaseCustomerId != null &&
|
||||
oldFirebaseModelId != null) {
|
||||
print(
|
||||
"ATTENZIONE: La scheda di riparazione${data['numeroScheda']} ha un customer_id ($oldFirebaseCustomerId) o un model_id ($oldFirebaseModelId) che non esiste su Supabase. Salto o metto null.",
|
||||
debugPrint('Trovati ${rawData.length} elementi alla radice.');
|
||||
if (rawData.isNotEmpty) {
|
||||
debugPrint(
|
||||
'Il primo elemento contiene: ${rawData.entries.first.value}',
|
||||
);
|
||||
continue; // Decommenta questo se vuoi saltare i modelli orfani
|
||||
}
|
||||
|
||||
// Creiamo la riga per Supabase
|
||||
supabaseTickets.add({
|
||||
'legacy_id': doc.id,
|
||||
// 2. CREAZIONE DELLA CACHE (IL TRUCCO PER NON IMPAZZIRE CON LE JOIN)
|
||||
debugPrint('📥 Scarico le mappe dei legacy_id da Supabase...');
|
||||
|
||||
'customer_id': newSupabaseCustomerUuid,
|
||||
final customersRes = await supabase
|
||||
.from('customer')
|
||||
.select('id, legacy_id')
|
||||
.not('legacy_id', 'is', null);
|
||||
|
||||
// Mappa gli altri campi
|
||||
'created_at':
|
||||
(data['dataCreazione'] as Timestamp?)?.toDate().toIso8601String() ??
|
||||
DateTime.now().toIso8601String(),
|
||||
'company_id': myRealCompanyId,
|
||||
'store_id': myRealStoreId,
|
||||
'ticket_type': 'repair',
|
||||
'target_model_id': newSupabaseModelUuid,
|
||||
'returned_at': (data['dataRiconsegnaCliente'] as Timestamp?)
|
||||
?.toDate()
|
||||
.toIso8601String(),
|
||||
'request': (data['guasto'] as String?)?.toLowerCase().trim(),
|
||||
'public_notes': data['note'],
|
||||
'internal_notes': data['noteInterne'],
|
||||
'reference_number': data['numeroScheda'],
|
||||
});
|
||||
final modelsRes = await supabase
|
||||
.from('model')
|
||||
.select('id, legacy_id')
|
||||
.not('legacy_id', 'is', null);
|
||||
|
||||
// Creiamo i dizionari: chiave = legacy_id (Firebase), valore = uuid (Supabase)
|
||||
final Map<String, String> customerMap = {
|
||||
for (var row in customersRes)
|
||||
if (row['legacy_id'] != null)
|
||||
row['legacy_id'].toString(): row['id'].toString(),
|
||||
};
|
||||
|
||||
final Map<String, String> modelMap = {
|
||||
for (var row in modelsRes)
|
||||
if (row['legacy_id'] != null)
|
||||
row['legacy_id'].toString(): row['id'].toString(),
|
||||
};
|
||||
|
||||
debugPrint(
|
||||
'✅ Mappe pronte: ${customerMap.length} clienti, ${modelMap.length} modelli.',
|
||||
);
|
||||
|
||||
// 3. MAPPATURA DEI DATI
|
||||
List<Map<String, dynamic>> ticketsToInsert = [];
|
||||
|
||||
for (var entry in rawData.entries) {
|
||||
final data = entry.value as Map<String, dynamic>;
|
||||
|
||||
// Recuperiamo le relazioni usando i nostri dizionari
|
||||
final String? customerId = customerMap[data['idCliente']];
|
||||
final String? modelId = modelMap[data['idModello']];
|
||||
|
||||
// Se non troviamo il cliente o il modello, magari loggiamo e saltiamo (o mettiamo null)
|
||||
// Per ora li mettiamo null, ma almeno non spacca il DB
|
||||
|
||||
// Risoluzione Date
|
||||
DateTime? createdAt = _parseFirebaseDate(data['dataAperturaScheda']);
|
||||
//DateTime? closedAt = _parseFirebaseDate(data['dataChiusuraScheda']);
|
||||
//DateTime? returnedAt = _parseFirebaseDate(data['dataRiconsegnaCliente']);
|
||||
|
||||
// Costruzione del Ticket
|
||||
ticketsToInsert.add({
|
||||
'legacy_id': data['fsId'], // Il vecchio ID del doc Firebase
|
||||
'company_id': companyId,
|
||||
'store_id': storeId,
|
||||
'customer_id': customerId,
|
||||
'target_model_id': modelId,
|
||||
'target_sn': data['seriale'] ?? '',
|
||||
'customer_price': data['costoTotaleCliente'] ?? 0.0,
|
||||
'internal_cost': data['costoTotaleNostro'] ?? 0.0,
|
||||
'created_at':
|
||||
createdAt?.toUtc().toIso8601String() ??
|
||||
DateTime.now().toUtc().toIso8601String(),
|
||||
|
||||
//'closed_at': closedAt?.toUtc().toIso8601String(),
|
||||
//'returned_at': returnedAt?.toUtc().toIso8601String(),
|
||||
'request': (data['guasto']?.toString() ?? ''),
|
||||
'included_accessories': data['accessoriConsegnati'],
|
||||
|
||||
'public_notes': data['note'],
|
||||
'internal_notes': data['noteInterne'],
|
||||
'resolution_notes':
|
||||
data['operazioneEffettuata'], // Il nuovo campo di cui parlavamo!
|
||||
|
||||
'alternative_phone_number': data['recapitoCliente'],
|
||||
'has_courtesy_device': data['prestatoMuletto'] ?? false,
|
||||
|
||||
// Mappatura Enums
|
||||
'ticket_type': _mapTicketType(data),
|
||||
'ticket_status': _mapTicketStatus(data),
|
||||
'ticket_result': _mapTicketResult(data['risultato']),
|
||||
|
||||
// 'warranty_type': _mapWarranty(data['nomeTipoGaranzia']), // De-commenta se hai la logica pronta
|
||||
});
|
||||
}
|
||||
|
||||
// 4. INSERIMENTO BATCH (A botte di 100 per non far arrabbiare Postgres)
|
||||
debugPrint(
|
||||
'🚀 Inizio inserimento di ${ticketsToInsert.length} ticket su Supabase...',
|
||||
);
|
||||
|
||||
const int batchSize = 100;
|
||||
for (int i = 0; i < ticketsToInsert.length; i += batchSize) {
|
||||
final end = (i + batchSize < ticketsToInsert.length)
|
||||
? i + batchSize
|
||||
: ticketsToInsert.length;
|
||||
final batch = ticketsToInsert.sublist(i, end);
|
||||
|
||||
await supabase.from('ticket').insert(batch);
|
||||
debugPrint('✅ Inseriti ticket da $i a $end');
|
||||
}
|
||||
|
||||
debugPrint('🎉 MIGRAZIONE COMPLETATA CON SUCCESSO!');
|
||||
} catch (e, stacktrace) {
|
||||
debugPrint('❌ ERRORE DURANTE LA MIGRAZIONE: $e');
|
||||
debugPrint(stacktrace.toString());
|
||||
}
|
||||
}
|
||||
|
||||
// --- FUNZIONI DI AIUTO (PARSER E MAPPER) ---
|
||||
|
||||
/// Estrae la data dalla fastidiosa struttura {"__time__": "..."} di Firestore export
|
||||
DateTime? _parseFirebaseDate(dynamic dateData) {
|
||||
if (dateData == null) return null;
|
||||
if (dateData is Map && dateData.containsKey('__time__')) {
|
||||
return DateTime.tryParse(dateData['__time__'].toString());
|
||||
}
|
||||
if (dateData is String) {
|
||||
return DateTime.tryParse(dateData);
|
||||
}
|
||||
return null;
|
||||
}
|
||||
|
||||
/// Converte i boolean di Firebase nel tuo Enum TicketType
|
||||
String _mapTicketType(Map<String, dynamic> data) {
|
||||
if (data['tipoLavorazionePassaggioDati'] == true) return 'data_transfer';
|
||||
if (data['tipoLavorazioneRiparazione'] == true) return 'repair';
|
||||
if (data['tipoLavorazioneConfigurazione'] == true) return 'software_setup';
|
||||
return 'other'; // Include tipoLavorazioneAltro o fallback
|
||||
}
|
||||
|
||||
/// Converte la logica di stato di Firebase nel tuo Enum TicketStatus
|
||||
String _mapTicketStatus(Map<String, dynamic> data) {
|
||||
// Se è stato riconsegnato al cliente o ritirato, è chiuso/consegnato
|
||||
if (data['riconsegnato'] == true ||
|
||||
data['nomeStatoScheda'] == 'Ritirato da cliente') {
|
||||
return 'closed'; // o 'closed', in base alla tua logica
|
||||
}
|
||||
|
||||
// ==========================================================
|
||||
// FASE 3: INVIO A SUPABASE
|
||||
// ==========================================================
|
||||
print("Sto per inviare ${supabaseTickets.length} tickets a Supabase...");
|
||||
// Altrimenti valutiamo le stringhe
|
||||
final String statoFirebase =
|
||||
data['nomeStatoScheda']?.toString().toLowerCase() ?? '';
|
||||
|
||||
await Supabase.instance.client
|
||||
.from('ticket')
|
||||
.upsert(supabaseTickets, onConflict: 'legacy_id');
|
||||
if (statoFirebase.contains('accettazione')) return 'open';
|
||||
if (statoFirebase.contains('da inviare centro esterno'))
|
||||
return 'waiting_for_shipping';
|
||||
if (statoFirebase.contains('attesa ricambi')) return 'waiting_for_parts';
|
||||
if (statoFirebase.contains('pronto')) return 'ready';
|
||||
if (data['daLavorare'] == true) return 'in_progress';
|
||||
|
||||
print("BOOM! Migrazione ticket completata con successo! 🚀");
|
||||
} catch (e) {
|
||||
print("Errore durante la migrazione dei ticket: $e");
|
||||
return 'closed'; // Fallback
|
||||
}
|
||||
|
||||
String? _mapTicketResult(dynamic risultato) {
|
||||
if (risultato == null || risultato.toString().isEmpty) return null;
|
||||
final r = risultato.toString().toUpperCase();
|
||||
if (r == 'OK') return 'success';
|
||||
if (r == 'KO' || r == 'NON RIPARATO') return 'failure';
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user