Refactor Store management: implement save and sync functionality for providers and staff; create StoreCard and StoreForm components

This commit is contained in:
2026-04-17 14:58:29 +02:00
parent 08a521c21c
commit f4d59a2f4f
7 changed files with 537 additions and 346 deletions

View File

@@ -1,3 +1,5 @@
import 'package:flux/features/master_data/providers/models/provider_model.dart';
import 'package:flux/features/master_data/staff/models/staff_member_model.dart';
import 'package:get_it/get_it.dart';
import 'package:supabase_flutter/supabase_flutter.dart';
import '../models/store_model.dart';
@@ -17,6 +19,66 @@ class StoreRepository {
}
}
Future<StoreModel> saveStore(StoreModel store) async {
try {
final response = await _supabase
.from('store')
.upsert(store.toMap())
.select()
.single();
return StoreModel.fromMap(response);
} on PostgrestException catch (e) {
throw e.message;
} catch (e) {
throw 'Errore imprevisto durante il salvataggio del negozio: $e';
}
}
Future<void> syncStoreProviders(
String storeId,
List<ProviderModel> providers,
) async {
try {
// 1. Eliminiamo tutte le associazioni correnti per questo negozio
await _supabase
.from('providers_in_stores')
.delete()
.eq('store_id', storeId);
// 2. Se ci sono nuovi provider da associare, li inseriamo
if (providers.isNotEmpty) {
final inserts = providers
.map((p) => {'store_id': storeId, 'provider_id': p.id})
.toList();
await _supabase.from('providers_in_stores').insert(inserts);
}
} catch (e) {
throw 'Errore durante la sincronizzazione provider: $e';
}
}
Future<void> syncStoreStaff(
String storeId,
List<StaffMemberModel> staffMembers,
) async {
try {
// 1. Eliminiamo tutte le associazioni correnti per questo negozio
await _supabase.from('staff_in_stores').delete().eq('store_id', storeId);
// 2. Se ci sono nuovi dipendenti da associare, li inseriamo
if (staffMembers.isNotEmpty) {
final inserts = staffMembers
.map((s) => {'store_id': storeId, 'staff_id': s.id})
.toList();
await _supabase.from('staff_in_stores').insert(inserts);
}
} catch (e) {
throw 'Errore durante la sincronizzazione staff: $e';
}
}
/// Recupera tutti i negozi di una determinata compagnia
Future<List<StoreModel>> fetchAllCompanyStores(String companyId) async {
try {
@@ -43,4 +105,33 @@ class StoreRepository {
throw 'Errore nel recupero dei negozi: $e';
}
}
Future<void> associateStoreToProvider({
required String storeId,
required String providerId,
}) async {
try {
await _supabase.from('providers_in_stores').insert({
'store_id': storeId,
'provider_id': providerId,
});
} catch (e) {
throw 'Errore durante l\'associazione del negozio al provider: $e';
}
}
Future<void> removeStoreFromProvider({
required String storeId,
required String providerId,
}) async {
try {
await _supabase
.from('providers_in_stores')
.delete()
.eq('store_id', storeId)
.eq('provider_id', providerId);
} catch (e) {
throw 'Errore durante la rimozione del negozio dal provider: $e';
}
}
}