import 'package:pocketbase/pocketbase.dart';
import '../../../core/api/pocketbase_client.dart';
import '../../../core/services/finance_service.dart';
import '../../../models/finance_entry.dart';

class LabFinanceRepository {
  LabFinanceRepository._();
  static final instance = LabFinanceRepository._();

  PocketBase get _pb => PocketBaseClient.instance.pb;

  Future<List<FinanceEntry>> listEntries(
    String tenantId, {
    String? status,
    int page = 1,
    int limit = 30,
  }) async {
    final filterParts = ['tenant_id = "$tenantId"', 'type = "receivable"'];
    if (status == FinanceStatus.pending.value) {
      filterParts.add('(status = "pending" || status = "reported")');
    } else if (status != null) {
      filterParts.add('status = "$status"');
    }

    final result = await _pb.collection('finance_entries').getList(
          page: page,
          perPage: limit,
          filter: filterParts.join(' && '),
          expand: 'job_id',
        );
    return (result.items.map((r) => FinanceEntry.fromJson(r.toJson())).toList()
      ..sort((a, b) => (b.dateCreated ?? '').compareTo(a.dateCreated ?? '')));
  }

  Future<Map<String, double>> summary(String tenantId) async {
    final all = await listEntries(tenantId, limit: 200);
    double pending = 0, paid = 0;
    for (final e in all) {
      if (e.status.isOpen) {
        pending += e.amount;
      } else {
        paid += e.amount;
      }
    }
    return {'pending': pending, 'paid': paid};
  }

  Future<List<CounterpartyFinanceSummary>> byCounterparty(
      String tenantId) async {
    final entries = await listEntries(tenantId, limit: 300);
    final map = <String, CounterpartyFinanceSummary>{};

    for (final entry in entries) {
      final key =
          entry.counterpartyTenantId ?? entry.counterpartyName ?? 'unknown';
      final current = map[key];
      final pending = (current?.pendingAmount ?? 0) +
          (entry.status.isOpen ? entry.amount : 0);
      final paid = (current?.paidAmount ?? 0) +
          (entry.status == FinanceStatus.paid ? entry.amount : 0);
      map[key] = CounterpartyFinanceSummary(
        counterpartyTenantId: entry.counterpartyTenantId,
        counterpartyName: entry.counterpartyName ?? 'Karşı Taraf',
        currency: entry.currency,
        pendingAmount: pending,
        paidAmount: paid,
        entryCount: (current?.entryCount ?? 0) + 1,
      );
    }

    final list = map.values.toList();
    list.sort((a, b) => b.pendingAmount.compareTo(a.pendingAmount));
    return list;
  }

  Future<void> confirmPayment(String entryId) async {
    final record = await _pb.collection('finance_entries').getOne(entryId);
    final jobId = record.data['job_id']?.toString();
    if (jobId == null || jobId.isEmpty) {
      await _pb.collection('finance_entries').update(entryId, body: {
        'status': 'paid',
        'paid_at': DateTime.now().toIso8601String(),
      });
      return;
    }
    await FinanceService.instance.confirmJobPayment(jobId);
  }
}