import 'package:fikoyt_akcali_v1/apps/finans/core/models/finans.model.dart';
import 'package:fikoyt_akcali_v1/apps/finans/core/services/finans.servis.dart';
import 'package:fikoyt_akcali_v1/apps/finans/core/services/kok.servis.dart';
import 'package:fikoyt_ui/fikoyt_ui.dart';
import 'package:isar/isar.dart';

class KategorilerService111 extends GetxService {
  Rx<Kategori?> kayit = Rx<Kategori?>(Kategori());
  Rx<bool> kayitEkleGoster = Rx<bool>(false);
  Rx<bool> guncelle = Rx<bool>(false);
  FinansServis? finansServis = FikoYTCoreService.servisler.getServis<FinansServis>();
  Isar? isar = FikoYTCoreService.servisler.getServis<FinansServis>()?.isar;

  kayitKontrol() {
    kayit.value?.ismi != "";
  }

  kaydet({required Kategori kyt, Kategori? ustKyt}) {
    isar?.writeTxn(() async {
      if (kyt.aciklama == "") {
        kyt.aciklama = null;
      }
      kyt.sahibi.value = finansServis?.aktifKullanici.value;
      kyt.ustKategori.value = ustKyt;
      await isar?.kategoris.put(kyt);
      await kyt.sahibi.save();
      await kyt.ustKategori.save();
      kayit.value = Kategori();
      kayitEkleGoster.value = false;
      kayitEkleGoster.refresh();
      kayit.refresh();
      guncelle.refresh();
    });
  }

  sil({required Kategori kyt}) {
    isar?.writeTxn(() async {
      await isar?.kategoris.delete(kyt.id);
      kayit.value = Kategori();
      kayitEkleGoster.value = false;
      kayitEkleGoster.refresh();
      kayit.refresh();
      guncelle.refresh();
    });
  }

  Future<List<Kategori>> listeAl(int page, int limit, {Kategori? ustKyt}) async {
    if (ustKyt != null) {
      return await isar?.kategoris
              .where()
              .filter()
              .sahibi((q) => q.idEqualTo(finansServis?.aktifKullanici.value?.id ?? -1))
              .ustKategori((q) => q.idEqualTo(ustKyt.id))
              .sortByIsmi()
              .offset(page * limit)
              .limit(limit)
              .findAll() ??
          [];
    } else {
      return await isar?.kategoris
              .where()
              .filter()
              .sahibi((q) => q.idEqualTo(finansServis?.aktifKullanici.value?.id ?? -1))
              .ustKategoriIsNull()
              .sortByIsmi()
              .offset(page * limit)
              .limit(limit)
              .findAll() ??
          [];
    }
  }

  List<Kategori> listeAlSync(int page, int limit, {Kategori? ustKyt}) {
    if (ustKyt != null) {
      return isar?.kategoris
              .where()
              .filter()
              .sahibi((q) => q.idEqualTo(finansServis?.aktifKullanici.value?.id ?? -1))
              .ustKategori((q) => q.idEqualTo(ustKyt.id))
              .sortByIsmi()
              .offset(page * limit)
              .limit(limit)
              .findAllSync() ??
          [];
    } else {
      return isar?.kategoris
              .where()
              .filter()
              .sahibi((q) => q.idEqualTo(finansServis?.aktifKullanici.value?.id ?? -1))
              .ustKategoriIsNull()
              .sortByIsmi()
              .offset(page * limit)
              .limit(limit)
              .findAllSync() ??
          [];
    }
  }

  Future<Kategori?> byId(int id) async {
    return await isar?.kategoris
        .where()
        .filter()
        .sahibi((q) => q.idEqualTo(finansServis?.aktifKullanici.value?.id ?? -1))
        .idEqualTo(id)
        .findFirst();
  }

  Kategori? byIdSync(int id) {
    return isar?.kategoris
        .where()
        .filter()
        .sahibi((q) => q.idEqualTo(finansServis?.aktifKullanici.value?.id ?? -1))
        .idEqualTo(id)
        .findFirstSync();
  }
}

class KategorilerService extends IsarFullService<Kategori> {
  Rx<Kategori?> ustKategori = Rx<Kategori?>(null);

  @override
  Isar getIsar() => FikoYTCoreService.servisler.getServis<FinansServis>()!.isar!;

  @override
  IsarCollection<Kategori> get koleksiyon => isar.kategoris;

  @override
  QueryBuilder<Kategori, Kategori, QAfterFilterCondition> getQuery() {
    final aktif = FikoYTCoreService.servisler.getServis<FinansServis>()?.aktifKullanici.value;
    ustKategori.value?.ustKategori.loadSync();
    return koleksiyon.where().filter().sahibi((q) => q.idEqualTo(aktif?.id ?? -1)).and().ustKategori((q) {
      return  q.ustKategoriIsNull();
    });
  }

  // @override
  // QueryBuilder<Kategori, Kategori, QAfterFilterCondition> applyAramaFiltre(
  //   QueryBuilder<Kategori, Kategori, QAfterFilterCondition> q,
  //   String arama,
  // ) {
  //   // TODO: implement applyAramaFiltre
  //   if (arama.isEmpty) {
  //     return q;
  //   }
  //   return q.ismiStartsWith(arama, caseSensitive: false);
  // }

  @override
  Future<void> iliskileriYukle(List<Kategori> liste) async {
    for (var h in liste) {
      await h.ustKategori.load();
      await h.sahibi.load();
    }
  }

  @override
  Future<dynamic> beforeEkle(Kategori item) async {
    item.sahibi.value = FikoYTCoreService.servisler.getServis<FinansServis>()!.aktifKullanici.value;
    return item;
  }

  @override
  Future<void> afterEkle(Kategori item) async {
    await item.sahibi.save();
    await item.ustKategori.save();
  }
}