133 lines
3.5 KiB
Dart
133 lines
3.5 KiB
Dart
import 'dart:async';
|
|
|
|
import 'package:cloud_firestore/cloud_firestore.dart';
|
|
import 'package:fcs/data/services/services.dart';
|
|
import 'package:fcs/constants.dart';
|
|
import 'package:fcs/domain/entities/discount.dart';
|
|
import 'package:fcs/helpers/paginator.dart';
|
|
import 'package:fcs/pages/main/model/base_model.dart';
|
|
import 'package:logging/logging.dart';
|
|
|
|
class DiscountModel extends BaseModel {
|
|
final log = Logger('DiscountModel');
|
|
|
|
StreamSubscription<QuerySnapshot>? listener;
|
|
|
|
List<Discount> _discounts = [];
|
|
List<Discount> get discounts => _selectedIndex == 1
|
|
? _discounts
|
|
: List<Discount>.from(_used?.values ?? []);
|
|
|
|
Paginator? _used;
|
|
bool isLoading = false;
|
|
int _selectedIndex = 1;
|
|
set selectedIndex(int index) {
|
|
_selectedIndex = index;
|
|
notifyListeners();
|
|
}
|
|
|
|
int get selectedIndex => _selectedIndex;
|
|
|
|
initData() {
|
|
_selectedIndex = 1;
|
|
_load();
|
|
if (_getUsed() != null) _used = _getUsed();
|
|
_used?.load();
|
|
}
|
|
|
|
void initUser(user) {
|
|
super.initUser(user);
|
|
_load();
|
|
}
|
|
|
|
_load() {
|
|
if (listener != null) listener!.cancel();
|
|
try {
|
|
listener = FirebaseFirestore.instance
|
|
.collection("/$discounts_collection")
|
|
.orderBy("code", descending: false)
|
|
.snapshots()
|
|
.listen((snaps) {
|
|
_discounts.clear();
|
|
snaps.docs.forEach((d) {
|
|
_discounts.add(Discount.fromMap(d.data(), d.id));
|
|
});
|
|
notifyListeners();
|
|
});
|
|
} catch (e) {
|
|
log.warning("error:$e");
|
|
}
|
|
}
|
|
|
|
Paginator? _getUsed() {
|
|
if (user == null || !user!.hasFcsShipments()) throw "No Privilege";
|
|
|
|
var pageQuery = FirebaseFirestore.instance
|
|
.collection("/$discounts_collection")
|
|
.where("status", isEqualTo: fcs_shipment_shipped_status)
|
|
.orderBy("code", descending: false);
|
|
var paginator = new Paginator(pageQuery, rowPerLoad: 20, toObj: (data, id) {
|
|
return Discount.fromMap(data, id);
|
|
});
|
|
return paginator;
|
|
}
|
|
|
|
Future<List<Discount?>?> getDiscount(String userID) async {
|
|
String path = "/$discounts_collection";
|
|
try {
|
|
var q = FirebaseFirestore.instance
|
|
.collection("$path")
|
|
.where("customer_id", isEqualTo: userID)
|
|
.where("status", isEqualTo: "available");
|
|
var snaps = await q.get(const GetOptions(source: Source.server));
|
|
var discounts = snaps.docs.map((snap) {
|
|
if (snap.exists) {
|
|
var s = Discount.fromMap(snap.data(), snap.id);
|
|
return s;
|
|
}
|
|
}).toList();
|
|
return discounts;
|
|
} catch (e) {
|
|
log.warning("Error!! $e");
|
|
}
|
|
return null;
|
|
}
|
|
|
|
Future<void> loadMore() async {
|
|
if (_used!.ended || _selectedIndex == 1) return;
|
|
isLoading = true;
|
|
notifyListeners();
|
|
await _used!.load(onFinished: () {
|
|
isLoading = false;
|
|
notifyListeners();
|
|
});
|
|
}
|
|
|
|
Future<void> refresh() async {
|
|
if (_selectedIndex == 1) return;
|
|
await _used!.refresh(onFinished: () {
|
|
notifyListeners();
|
|
});
|
|
}
|
|
|
|
@override
|
|
logout() async {
|
|
if (listener != null) await listener!.cancel();
|
|
if (_used != null) _used!.close();
|
|
|
|
_discounts = [];
|
|
}
|
|
|
|
Future<void> addDiscount(Discount discount) async {
|
|
return Services.instance.commonService.createDiscount(discount);
|
|
}
|
|
|
|
Future<void> updateDiscount(Discount discount) async {
|
|
return Services.instance.commonService.updateDiscount(discount);
|
|
}
|
|
|
|
Future<void> deleteDiscount(Discount discount) async {
|
|
return Services.instance.commonService.deleteDiscount(discount.id!);
|
|
}
|
|
}
|