flux/lib/features/services/data/services_repository.dart

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 SINGOLO SERVIZIO CON JOIN COMPLETO ---
  Future<ServiceModel> fetchServiceById(String id) async {
    try {
      final response = await _supabase
          .from('service')
          .select('''
            *,
            customer(nome), 
            energy_service(*),
            fin_service(*),
            entertainment_service(*)
          ''')
          .eq('id', id)
          .single();

      return ServiceModel.fromMap(response);
    } catch (e) {
      throw Exception('Errore nel caricamento del servizio: $e');
    }
  }

  // --- 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(nome), 
            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.nome.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. Upsert del record principale
      final serviceData = await _supabase
          .from('service')
          .upsert(service.toMap())
          .select()
          .single();

      final String newId = serviceData['id'];

      // 2. MODIFICA: Pulizia atomica dei figli
      // Se stiamo modificando (id != null), resettiamo le tabelle collegate
      if (service.id != null) {
        await Future.wait([
          _supabase.from('energy_service').delete().eq('service_id', newId),
          _supabase.from('fin_service').delete().eq('service_id', newId),
          _supabase
              .from('entertainment_service')
              .delete()
              .eq('service_id', newId),
          // Aggiungi qui eventuali altre tabelle pivot o file
        ]);
      }

      // 3. Inserimento dei moduli in parallelo per velocità
      final List<Future> insertTasks = [];

      if (service.energyServices.isNotEmpty) {
        insertTasks.add(
          _supabase
              .from('energy_service')
              .insert(
                service.energyServices
                    .map((item) => item.copyWith(serviceId: newId).toMap())
                    .toList(),
              ),
        );
      }

      if (service.finServices.isNotEmpty) {
        insertTasks.add(
          _supabase
              .from('fin_service')
              .insert(
                service.finServices
                    .map((item) => item.copyWith(serviceId: newId).toMap())
                    .toList(),
              ),
        );
      }

      if (service.entertainmentServices.isNotEmpty) {
        insertTasks.add(
          _supabase
              .from('entertainment_service')
              .insert(
                service.entertainmentServices
                    .map((item) => item.copyWith(serviceId: newId).toMap())
                    .toList(),
              ),
        );
      }

      if (insertTasks.isNotEmpty) {
        await Future.wait(insertTasks);
      }
    } catch (e) {
      // Qui potresti aggiungere una logica di "rollback manuale" se necessario
      throw Exception('Errore durante il salvataggio corazzato: $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');
    }
  }

  // --- RECUPERO TIPI CONTENUTI PIÙ FREQUENTI PER AUTOCOMPLETE ---
  Future<List<String>> fetchTopEntertainmentTypes(String companyId) async {
    try {
      // Cerchiamo i tipi più frequenti associati ai servizi di questa company
      // Nota: dobbiamo passare attraverso la tabella 'service' per filtrare per company_id
      final response = await _supabase
          .from('entertainment_service')
          .select('type, service!inner(store!inner(company_id))')
          .eq('service.store.company_id', companyId)
          .limit(100); // Prendiamo un campione

      // Logica rapida per contare le occorrenze e prendere i primi 5
      final Map<String, int> counts = {};
      for (var item in (response as List)) {
        final type = item['type'] as String;
        counts[type] = (counts[type] ?? 0) + 1;
      }

      var sortedKeys = counts.keys.toList()
        ..sort((a, b) => counts[b]!.compareTo(counts[a]!));

      return sortedKeys.take(5).toList();
    } catch (e) {
      return [
        "Netflix",
        "DAZN",
        "Disney+",
        "Sky",
      ]; // Fallback se non c'è ancora storia
    }
  }
}