import 'package:fikoyt_akcali_v1/apps/finans/core/models/finans.model.dart' as semalar;
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_akcali_v1/apps/finans/core/services/para_birimleri_service.dart';
import 'package:fikoyt_ui/fikoyt_ui.dart';
import 'package:isar/isar.dart';

class HesaplarService extends GetxService {
  Isar? isar;
  RxBool guncelle = RxBool(false);
  ParaBirimleriService? logicParaBirimi;
  Rx<semalar.Hesap> hesap = Rx<semalar.Hesap>(semalar.Hesap());
  FinansServis? finansServis;

  Rx<List<semalar.Hesap>> hesaplar = Rx<List<semalar.Hesap>>([]);

  Stream get hesaplarStream => isar!.hesaps.where().watch(fireImmediately: true);

  RxInt sayfa = RxInt(0);
  RxInt limit = RxInt(3);
  RxInt sayi = RxInt(3);

  @override
  void onInit() async {
    super.onInit();
    finansServis = FikoYTCoreService.servisler.getServis<FinansServis>();
    logicParaBirimi = Get.put<ParaBirimleriService>(ParaBirimleriService());
    isar = finansServis?.isar;
    // TODO: implement onInit
    await listeAl(page: 0, lim: 3);
  }

  Future<List<semalar.Hesap>> listeAl({int? page, int? lim}) async {
    sayfa.value = page ?? 0;
    limit.value = lim ?? 0;
    final hesaplarQuery = finansServis?.aktifKullanici.value?.hesaplar
        .filter()
        .offset(sayfa.value * limit.value)
        .limit(limit.value);
    final hesaplarList = await hesaplarQuery?.findAll() ?? [];
    print(finansServis?.aktifKullanici.value);
    hesaplar.value = hesaplarList;
    return hesaplarList;
  }

  List<semalar.Hesap> listeAlSync({int? page, int? lim}) {
    sayfa.value = page ?? 0;
    limit.value = lim ?? 0;
    hesaplar.value =
        finansServis?.aktifKullanici.value?.hesaplar
            .filter()
            .offset(sayfa.value * limit.value)
            .limit(limit.value)
            .findAllSync() ??
        [];
    return hesaplar.value;
  }

  Future<semalar.Hesap?> hesapById(int hesapId) async {
    return finansServis?.aktifKullanici.value?.hesaplar.filter().idEqualTo(hesapId).findFirst();
  }

  semalar.Hesap? hesapByIdSync(int hesapId) {
    return finansServis?.aktifKullanici.value?.hesaplar.filter().idEqualTo(hesapId).findFirstSync();
  }

  Future<int?> kaydet({semalar.Hesap? hsp, semalar.IHesapTipi hesapTipi = semalar.IHesapTipi.nakit}) async {
    hsp ??= hesap.value;

    return isar?.writeTxn(() async {
      hsp!.hesapTipi = hesapTipi;
      hsp.sahibi.add(finansServis!.aktifKullanici.value!);
      int? id = await isar?.hesaps.put(hsp);
      hsp.sahibi.save();
      hsp.paraBirimi.save();
      hesap.value = semalar.Hesap();

      return id;
    });
  }

  Future<bool?> hesapSilById(int hesapId) async {
    return await isar?.hesaps
        .where()
        .filter()
        .sahibi((q) => q.idEqualTo(finansServis?.aktifKullanici.value?.id ?? -1))
        .idEqualTo(hesapId)
        .deleteFirst();
  }

  bool? hesapSilByIdSync(int hesapId) {
    return isar?.hesaps
        .where()
        .filter()
        .sahibi((q) => q.idEqualTo(finansServis?.aktifKullanici.value?.id ?? -1))
        .idEqualTo(hesapId)
        .deleteFirstSync();
  }
}


class HesapService extends IsarFullService<semalar.Hesap> {
  @override
  Isar getIsar() => FikoYTCoreService.servisler.getServis<FinansServis>()!.isar!;

  @override
  IsarCollection<semalar.Hesap> get koleksiyon => isar.hesaps;

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

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