122 lines
3.8 KiB
Dart
122 lines
3.8 KiB
Dart
import 'package:flux/features/master_data/staff/models/staff_member_model.dart';
|
|
import 'package:flux/features/master_data/store/models/store_model.dart';
|
|
import 'package:get_it/get_it.dart';
|
|
import 'package:supabase_flutter/supabase_flutter.dart';
|
|
|
|
class StaffRepository {
|
|
final SupabaseClient _supabase = GetIt.I.get<SupabaseClient>();
|
|
|
|
// --- ANAGRAFICA PURA ---
|
|
|
|
// Prende tutto lo staff della Company (per l'Hub Anagrafiche)
|
|
Future<List<StaffMemberModel>> getStaffMembers(String companyId) async {
|
|
final response = await _supabase
|
|
.from('staff_member')
|
|
.select()
|
|
.eq('company_id', companyId)
|
|
.order('name', ascending: true);
|
|
|
|
return (response as List).map((s) => StaffMemberModel.fromMap(s)).toList();
|
|
}
|
|
|
|
Future<StaffMemberModel> saveStaffMember(StaffMemberModel member) async {
|
|
final response = await _supabase
|
|
.from('staff_member')
|
|
.upsert(member.toMap())
|
|
.select()
|
|
.single();
|
|
|
|
return StaffMemberModel.fromMap(response);
|
|
}
|
|
|
|
// --- LOGICA DI INVITO (Tramite Edge Function) ---
|
|
|
|
Future<String> inviteStaffMember(StaffMemberModel newMember) async {
|
|
if (newMember.email == null || newMember.email!.isEmpty) {
|
|
throw Exception(
|
|
"L'indirizzo email è obbligatorio per invitare un collega.",
|
|
);
|
|
}
|
|
|
|
try {
|
|
final response = await _supabase.functions.invoke(
|
|
'invite_staff',
|
|
body: newMember.toMap(),
|
|
);
|
|
|
|
if (response.status != 200) {
|
|
throw Exception("Errore dal server: ${response.data}");
|
|
}
|
|
|
|
// La funzione ci restituisce l'ID fresco di database!
|
|
final responseData = response.data as Map<String, dynamic>;
|
|
return responseData['user_id'] as String;
|
|
} on FunctionException catch (e) {
|
|
throw Exception(
|
|
"Errore di comunicazione con il server: ${e.reasonPhrase}",
|
|
);
|
|
} catch (e) {
|
|
throw Exception("Impossibile invitare il collega: $e");
|
|
}
|
|
}
|
|
|
|
// --- LOGICA DI GIUNZIONE (Staff <-> Store) ---
|
|
|
|
// Recupera i membri assegnati a uno specifico negozio
|
|
// Qui facciamo una JOIN per avere i dati del membro partendo dalla tabella di giunzione
|
|
Future<List<StaffMemberModel>> getStaffMembersInStore(String storeId) async {
|
|
final response = await _supabase
|
|
.from('staff_in_stores')
|
|
.select(
|
|
'staff_member (*)',
|
|
) // Prende tutti i campi della tabella staff_member collegata
|
|
.eq('store_id', storeId);
|
|
|
|
return (response as List)
|
|
.map((item) => StaffMemberModel.fromMap(item['staff_member']))
|
|
.toList();
|
|
}
|
|
|
|
// Recupera i negozi assegnati a uno specifico membro
|
|
// Qui facciamo una JOIN per avere i dati del membro partendo dalla tabella di giunzione
|
|
Future<List<StoreModel>> getStaffMemberStore(String staffId) async {
|
|
final response = await _supabase
|
|
.from('staff_in_stores')
|
|
.select(
|
|
'store (*)',
|
|
) // Prende tutti i campi della tabella store collegata
|
|
.eq('staff_member_id', staffId);
|
|
|
|
return (response as List)
|
|
.map((item) => StoreModel.fromMap(item['store']))
|
|
.toList();
|
|
}
|
|
|
|
// Assegna un membro a un negozio
|
|
Future<void> assignStaffToStore(String staffId, String storeId) async {
|
|
await _supabase.from('staff_in_stores').insert({
|
|
'staff_member_id': staffId,
|
|
'store_id': storeId,
|
|
});
|
|
}
|
|
|
|
// Rimuove l'assegnazione
|
|
Future<void> removeStaffFromStore(String staffId, String storeId) async {
|
|
await _supabase
|
|
.from('staff_in_stores')
|
|
.delete()
|
|
.eq('staff_member_id', staffId)
|
|
.eq('store_id', storeId);
|
|
}
|
|
|
|
// Nel StaffRepository
|
|
|
|
// Utility per pulire le assegnazioni esistenti prima di riscriverle
|
|
Future<void> clearStoreAssignments(String staffId) async {
|
|
await _supabase
|
|
.from('staff_in_stores')
|
|
.delete()
|
|
.eq('staff_member_id', staffId);
|
|
}
|
|
}
|