import 'package:drift/drift.dart';
import '../database.dart';

class ScadenzeDao {
  final AppDatabase db;
  ScadenzeDao(this.db);

  Future<List<Scadenza>> getScadenzeCliente(int idCliente) {
    return (db.select(db.scadenze)..where((t) => t.idCliente.equals(idCliente)))
        .get();
  }

  Future<List<VScadenzeData>> getScadenzePerAgente(int idAgente) {
    return (db.select(db.vScadenze)
          ..where((t) =>
              t.idAgente.equals(idAgente) &
              (t.flgSoppressa.equals(0) | t.flgSoppressa.isNull())))
        .get();
  }

  Future<void> removeDeleted() {
    return (db.delete(db.scadenze)..where((t) => t.stato.equals('X'))).go();
  }

  Future<int> insertScadenza(Scadenza s) {
    return db.into(db.scadenze).insert(s);
  }

  Future<void> clearAll() {
    return db.delete(db.scadenze).go();
  }

  Future<void> markAllAsDeleted(int idAgente) async {
    final sql =
        "update scadenze set stato='X' where idcliente in (select idcliente from clienti_Agente where idagente=$idAgente)";
    await db.executor.runCustom(sql);
  }
}