refactor providers e basi per spedizioni
This commit is contained in:
@@ -1,137 +1,81 @@
|
||||
import 'package:get_it/get_it.dart';
|
||||
import 'package:supabase_flutter/supabase_flutter.dart';
|
||||
import '../models/provider_model.dart';
|
||||
import '../models/provider_location_model.dart';
|
||||
|
||||
class ProviderRepository {
|
||||
final _supabase = Supabase.instance.client;
|
||||
final _supabase = GetIt.I.get<SupabaseClient>();
|
||||
|
||||
// --- ASSOCIAZIONE PROVIDER <-> STORE ---
|
||||
|
||||
// Aggiunge un provider a un negozio (Attiva mandato)
|
||||
Future<void> associateProviderToStore({
|
||||
required String providerId,
|
||||
required String storeId,
|
||||
}) async {
|
||||
try {
|
||||
await _supabase.from('providers_in_stores').insert({
|
||||
'provider_id': providerId,
|
||||
'store_id': storeId,
|
||||
});
|
||||
} catch (e) {
|
||||
throw Exception('Errore durante l\'associazione provider: $e');
|
||||
}
|
||||
}
|
||||
|
||||
// Rimuove un provider da un negozio (Disattiva mandato)
|
||||
Future<void> disassociateProviderFromStore({
|
||||
required String providerId,
|
||||
required String storeId,
|
||||
}) async {
|
||||
try {
|
||||
await _supabase
|
||||
.from('providers_in_stores')
|
||||
.delete()
|
||||
.eq('provider_id', providerId)
|
||||
.eq('store_id', storeId);
|
||||
} catch (e) {
|
||||
throw Exception('Errore durante la disassociazione provider: $e');
|
||||
}
|
||||
}
|
||||
|
||||
// Recupera tutti i provider di una company (per la lista generale)
|
||||
Future<List<ProviderModel>> fetchAllCompanyProviders(String companyId) async {
|
||||
try {
|
||||
final response = await _supabase
|
||||
.from('provider')
|
||||
.select('''
|
||||
*,
|
||||
associated_stores:providers_in_stores (
|
||||
store (
|
||||
*
|
||||
)
|
||||
// 1. Carica i provider abilitati per uno specifico Store
|
||||
Future<List<ProviderModel>> getProvidersByStore(String storeId) async {
|
||||
final response = await _supabase
|
||||
.from('providers_in_stores')
|
||||
.select('''
|
||||
provider_id,
|
||||
provider:provider (
|
||||
*,
|
||||
provider_locations (*)
|
||||
)
|
||||
''')
|
||||
.eq('company_id', companyId)
|
||||
.order('name');
|
||||
.eq('store_id', storeId)
|
||||
.order('name', referencedTable: 'provider');
|
||||
|
||||
return (response as List).map((m) => ProviderModel.fromMap(m)).toList();
|
||||
} catch (e) {
|
||||
throw 'Errore fetch providers: $e';
|
||||
}
|
||||
// Mappiamo i risultati estraendo l'oggetto 'provider' annidato
|
||||
return (response as List).map((row) {
|
||||
return ProviderModel.fromMap(row['provider'] as Map<String, dynamic>);
|
||||
}).toList();
|
||||
}
|
||||
|
||||
// Recupera gli ID dei provider associati a uno store (utile per le checkbox)
|
||||
Future<List<String>> fetchAssociatedProviderIds(String storeId) async {
|
||||
try {
|
||||
final response = await _supabase
|
||||
.from('providers_in_stores')
|
||||
.select('provider_id')
|
||||
.eq('store_id', storeId);
|
||||
// 2. Carica TUTTI i provider della Company (per la gestione anagrafica)
|
||||
Future<List<ProviderModel>> getAllCompanyProviders() async {
|
||||
final response = await _supabase
|
||||
.from('provider')
|
||||
.select('*, provider_locations (*)')
|
||||
.order('name');
|
||||
|
||||
return (response as List)
|
||||
.map((item) => item['provider_id'].toString())
|
||||
return (response as List)
|
||||
.map((row) => ProviderModel.fromMap(row as Map<String, dynamic>))
|
||||
.toList();
|
||||
}
|
||||
|
||||
// 3. Salvataggio atomico (Upsert) del Provider
|
||||
Future<ProviderModel> saveProvider(
|
||||
ProviderModel provider,
|
||||
List<String> enabledStoreIds,
|
||||
) async {
|
||||
// A. Salva/Aggiorna il Provider principale
|
||||
final savedRow = await _supabase
|
||||
.from('provider')
|
||||
.upsert(provider.toMap())
|
||||
.select()
|
||||
.single();
|
||||
|
||||
final savedProvider = ProviderModel.fromMap(savedRow);
|
||||
|
||||
// B. Sincronizza gli Store (Cancelliamo i vecchi e mettiamo i nuovi per semplicità)
|
||||
// In un'app ad alto traffico faremmo un confronto, qui l'upsert totale è più veloce da scrivere.
|
||||
await _supabase
|
||||
.from('providers_in_stores')
|
||||
.delete()
|
||||
.eq('provider_id', savedProvider.id!);
|
||||
|
||||
if (enabledStoreIds.isNotEmpty) {
|
||||
final storeLinks = enabledStoreIds
|
||||
.map((sId) => {'provider_id': savedProvider.id, 'store_id': sId})
|
||||
.toList();
|
||||
} catch (e) {
|
||||
throw Exception('Errore recupero ID associati: $e');
|
||||
|
||||
await _supabase.from('providers_in_stores').insert(storeLinks);
|
||||
}
|
||||
|
||||
return savedProvider;
|
||||
}
|
||||
|
||||
// --- FUNZIONI STANDARD ---
|
||||
|
||||
// Questa la userai nel Form Servizi: carica solo i provider abilitati per lo store
|
||||
Future<List<ProviderModel>> fetchActiveProvidersForStore(
|
||||
String storeId,
|
||||
) async {
|
||||
try {
|
||||
final response = await _supabase
|
||||
.from('provider')
|
||||
.select('*, providers_in_stores!inner(store_id)')
|
||||
.eq('providers_in_stores.store_id', storeId)
|
||||
.eq('is_active', true);
|
||||
|
||||
return (response as List).map((m) => ProviderModel.fromMap(m)).toList();
|
||||
} catch (e) {
|
||||
throw Exception('Errore fetch provider attivi: $e');
|
||||
}
|
||||
// 4. Gestione Sedi (Locations)
|
||||
Future<void> saveLocation(ProviderLocationModel location) async {
|
||||
await _supabase.from('provider_locations').upsert(location.toMap());
|
||||
}
|
||||
|
||||
// Salva o aggiorna l'anagrafica del Provider
|
||||
Future<ProviderModel> saveProvider(ProviderModel provider) async {
|
||||
try {
|
||||
// .select().single() è fondamentale per farsi restituire
|
||||
// l'oggetto appena creato/aggiornato con l'ID
|
||||
final response = await _supabase
|
||||
.from('provider')
|
||||
.upsert(provider.toMap())
|
||||
.select()
|
||||
.single();
|
||||
|
||||
return ProviderModel.fromMap(response); // <--- DEVE ESSERCI IL RETURN
|
||||
} catch (e) {
|
||||
rethrow; // <--- Rilancia l'errore al Cubit, non ritornare null!
|
||||
}
|
||||
}
|
||||
|
||||
Future<void> syncProviderStores(
|
||||
String providerId,
|
||||
List<String> storeIds,
|
||||
) async {
|
||||
try {
|
||||
// 1. Eliminiamo tutte le associazioni correnti per questo provider
|
||||
await _supabase
|
||||
.from('providers_in_stores')
|
||||
.delete()
|
||||
.eq('provider_id', providerId);
|
||||
|
||||
// 2. Se ci sono nuovi store da associare, li inseriamo
|
||||
if (storeIds.isNotEmpty) {
|
||||
final inserts = storeIds
|
||||
.map((sId) => {'provider_id': providerId, 'store_id': sId})
|
||||
.toList();
|
||||
|
||||
await _supabase.from('providers_in_stores').insert(inserts);
|
||||
}
|
||||
} catch (e) {
|
||||
throw Exception('Errore durante la sincronizzazione store: $e');
|
||||
}
|
||||
Future<void> deleteLocation(String locationId) async {
|
||||
await _supabase.from('provider_locations').delete().eq('id', locationId);
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user