133 lines
4.0 KiB
Dart
133 lines
4.0 KiB
Dart
import 'package:isar/isar.dart';
|
|
|
|
import '../Entities/recurring_transaction.dart';
|
|
import '../Entities/time_frame_enum.dart';
|
|
import '../Services/isar_service.dart';
|
|
|
|
/// Funktionen zum interagieren mit der Datenbank für die Transaktionen
|
|
class RecurringTransactionRepository {
|
|
final IsarService _isarService = IsarService();
|
|
|
|
/// Fügt eine neue wiederkehrende Transaktion zur Datenbank hinzu
|
|
Future<RecurringTransaction?> add(
|
|
final RecurringTransaction recurringTransaction,
|
|
) async {
|
|
final Isar isar = await _isarService.getDatabase();
|
|
|
|
final int id = await isar.writeTxn(
|
|
() => isar.recurringTransactions.put(recurringTransaction),
|
|
);
|
|
|
|
return find(id);
|
|
}
|
|
|
|
/// Entfernt eine wiederkehrende Transaktion aus der Datenbank
|
|
Future<bool> remove(final RecurringTransaction recurringTransaction) async {
|
|
final Isar isar = await _isarService.getDatabase();
|
|
return isar.writeTxn(
|
|
() => isar.recurringTransactions.delete(recurringTransaction.id),
|
|
);
|
|
}
|
|
|
|
/// Sucht eine wiederkehrende Transaktion anhand seiner Id aus der Datenbank
|
|
Future<RecurringTransaction?> find(final int id) async {
|
|
final Isar isar = await _isarService.getDatabase();
|
|
|
|
return isar.recurringTransactions.get(id);
|
|
}
|
|
|
|
/// Sucht wiederkehrende Transaktionen anhand der gegebenen Parameter
|
|
/// aus der Datenbank
|
|
/// Sucht wiederkehrende Transaktionen anhand der gegebenen Parameter
|
|
Future<List<RecurringTransaction>> findBy({
|
|
final int? id,
|
|
final String? name,
|
|
|
|
final DateTime? startDate,
|
|
final DateTime? startDateBefore,
|
|
final DateTime? startDateAfter,
|
|
final DateTime? startDateFrom,
|
|
final DateTime? startDateTo,
|
|
|
|
final TimeFrameEnum? timeFrame,
|
|
|
|
final double? amount,
|
|
final double? amountMin,
|
|
final double? amountMax,
|
|
|
|
final String? orderBy,
|
|
}) async {
|
|
final Isar isar = await _isarService.getDatabase();
|
|
|
|
final QueryBuilder<
|
|
RecurringTransaction,
|
|
RecurringTransaction,
|
|
QAfterFilterCondition
|
|
>
|
|
baseQuery = isar.recurringTransactions
|
|
.filter()
|
|
.optional(id != null, (final q) => q.idEqualTo(id!))
|
|
.optional(
|
|
name != null && name.isNotEmpty,
|
|
(final q) => q.nameMatches('*$name*', caseSensitive: false),
|
|
)
|
|
// --- StartDate Filter ---
|
|
.optional(startDate != null, (final q) => q.startDateEqualTo(startDate))
|
|
.optional(
|
|
startDateAfter != null,
|
|
(final q) => q.startDateGreaterThan(startDateAfter),
|
|
)
|
|
.optional(
|
|
startDateBefore != null,
|
|
(final q) => q.startDateLessThan(startDateBefore),
|
|
)
|
|
.optional(
|
|
startDateFrom != null && startDateTo != null,
|
|
(final q) => q.startDateBetween(startDateFrom, startDateTo),
|
|
)
|
|
// --- TimeFrame ---
|
|
.optional(
|
|
timeFrame != null,
|
|
(final q) => q.timeFrameEqualTo(timeFrame!),
|
|
)
|
|
// --- Amount Filter ---
|
|
.optional(amount != null, (final q) => q.amountEqualTo(amount!))
|
|
.optional(
|
|
amountMin != null && amountMax == null,
|
|
(final q) => q.amountGreaterThan(amountMin!),
|
|
)
|
|
.optional(
|
|
amountMin == null && amountMax != null,
|
|
(final q) => q.amountLessThan(amountMax!),
|
|
)
|
|
.optional(
|
|
amountMin != null && amountMax != null,
|
|
(final q) => q.amountBetween(amountMin!, amountMax!),
|
|
);
|
|
|
|
// --- Sortierung ---
|
|
switch (orderBy) {
|
|
case 'nameAsc':
|
|
return baseQuery.sortByName().findAll();
|
|
|
|
case 'nameDesc':
|
|
return baseQuery.sortByNameDesc().findAll();
|
|
|
|
case 'amountAsc':
|
|
return baseQuery.sortByAmount().findAll();
|
|
|
|
case 'amountDesc':
|
|
return baseQuery.sortByAmountDesc().findAll();
|
|
|
|
case 'startDateAsc':
|
|
return baseQuery.sortByStartDate().findAll();
|
|
|
|
case 'startDateDesc':
|
|
return baseQuery.sortByStartDateDesc().findAll();
|
|
|
|
default:
|
|
return baseQuery.findAll();
|
|
}
|
|
}
|
|
}
|