import 'package:flutter/material.dart';
import 'package:supabase_flutter/supabase_flutter.dart';
import '../models/service_model.dart';

class ServicesRepository {
  final _supabase = Supabase.instance.client;

  // --- RECUPERO PAGINATO CON FILTRI E JOIN ---
  Future<List<ServiceModel>> fetchServices({
    required String companyId,
    required int offset,
    int limit = 50,
    String? searchTerm,
    DateTimeRange? dateRange,
  }) async {
    try {
      // Nota: 'customer(name, surname)' serve per il display name nella card
      var query = _supabase
          .from('service')
          .select('''
            *,
            customer(name, surname), 
            energy_service(*),
            fin_service(*),
            entertainment_service(*)
          ''')
          .eq('company_id', companyId);

      // Filtro Range Date
      if (dateRange != null) {
        query = query
            .gte('created_at', dateRange.start.toIso8601String())
            .lte('created_at', dateRange.end.toIso8601String());
      }

      if (searchTerm != null && searchTerm.isNotEmpty) {
        // Filtra sui campi della tabella principale O su quelli della tabella joinata
        query = query.or(
          'number.ilike.%$searchTerm%,note.ilike.%$searchTerm%,customer.name.ilike.%$searchTerm%,customer.surname.ilike.%$searchTerm%',
        );
      }

      final response = await query
          .order('created_at', ascending: false)
          .range(offset, offset + limit - 1);

      return (response as List)
          .map((map) => ServiceModel.fromMap(map))
          .toList();
    } catch (e) {
      throw Exception('Errore nel caricamento servizi: $e');
    }
  }

  // --- SALVATAGGIO COMPLETO (PRIMA PADRE, POI FIGLI) ---
  Future<void> saveFullService(ServiceModel service) async {
    try {
      // 1. Inseriamo il record principale
      // Se service.id è null, Supabase fa INSERT. Se c'è, fa UPDATE (grazie all'upsert o gestione manuale)
      final serviceData = await _supabase
          .from('service')
          .upsert(service.toMap())
          .select()
          .single();

      final String newId = serviceData['id'];

      // 2. Pulizia vecchi record figli (necessaria se è una MODIFICA)
      // Se stiamo modificando, cancelliamo i vecchi per reinserire i nuovi (più semplice)
      if (service.id != null) {
        await _supabase.from('energy_service').delete().eq('service_id', newId);
        await _supabase.from('fin_service').delete().eq('service_id', newId);
        await _supabase
            .from('entertainment_service')
            .delete()
            .eq('service_id', newId);
      }

      // 3. Inserimento EnergyServices
      if (service.energyServices.isNotEmpty) {
        final List<Map<String, dynamic>> toInsert = [];
        for (var item in service.energyServices) {
          toInsert.add(item.copyWith(serviceId: newId).toMap());
        }
        await _supabase.from('energy_service').insert(toInsert);
      }

      // 4. Inserimento FinServices
      if (service.finServices.isNotEmpty) {
        final List<Map<String, dynamic>> toInsert = [];
        for (var item in service.finServices) {
          toInsert.add(item.copyWith(serviceId: newId).toMap());
        }
        await _supabase.from('fin_service').insert(toInsert);
      }

      // 5. Inserimento EntertainmentServices
      if (service.entertainmentServices.isNotEmpty) {
        final List<Map<String, dynamic>> toInsert = [];
        for (var item in service.entertainmentServices) {
          toInsert.add(item.copyWith(serviceId: newId).toMap());
        }
        await _supabase.from('entertainment_service').insert(toInsert);
      }
    } catch (e) {
      throw Exception('Errore durante il salvataggio: $e');
    }
  }

  // --- ELIMINAZIONE ---
  Future<void> deleteService(String id) async {
    try {
      await _supabase.from('service').delete().eq('id', id);
    } catch (e) {
      throw Exception('Errore durante l\'eliminazione: $e');
    }
  }
}