add cartion filter and search

This commit is contained in:
tzw
2024-02-07 17:26:29 +06:30
parent 2d4cdb9620
commit caf20f4e67
39 changed files with 1274 additions and 1181 deletions

View File

@@ -4,26 +4,24 @@ import 'package:cloud_firestore/cloud_firestore.dart';
import 'package:fcs/data/services/services.dart';
import 'package:fcs/domain/constants.dart';
import 'package:fcs/domain/entities/carton.dart';
import 'package:fcs/domain/entities/fcs_shipment.dart';
import 'package:fcs/pages/main/model/base_model.dart';
import 'package:fcs/pagination/paginator_listener.dart';
import 'package:logging/logging.dart';
import '../../../domain/entities/user.dart';
class CartonModel extends BaseModel {
final log = Logger('CartonModel');
PaginatorListener<Carton>? cartonsByFilter;
PaginatorListener<Carton>? getBoxes;
int selectedIndex = 1;
int _selectedIndexFilter = 1;
bool isLoading = false;
String? filterByStatus;
User? filterBySender;
User? filterByConsingee;
FcsShipment? shipment;
List<String> cartonTypes = [
carton_from_packages,
carton_from_cartons,
carton_mix_box
];
List<String> mixBoxTypes = [mix_delivery, mix_pickup];
List<String> cartonTypesInfo = [
carton_from_packages,
carton_from_cartons,
@@ -32,15 +30,6 @@ class CartonModel extends BaseModel {
carton_small_bag
];
int get selectedIndexFilter => _selectedIndexFilter;
set selectedIndexFilter(int index) {
_selectedIndexFilter = index;
_loadPaginationCartons(
_selectedIndexFilter == 1 ? "carton_weight" : "user_name");
notifyListeners();
}
@override
void privilegeChanged() {
if (user != null || !user!.hasCarton()) {
@@ -60,34 +49,83 @@ class CartonModel extends BaseModel {
Future<void> _initData() async {
logout();
_selectedIndexFilter = 1;
_loadPaginationCartons(
_selectedIndexFilter == 1 ? "carton_weight" : "user_name");
_loadPaginationCartons();
}
onChanged(int index) {
selectedIndex = index;
loadPaginationBoxes(selectedIndex);
filterCarton(User? consignee, User? sender, String? status) async {
filterByStatus = status;
if (status == all_status) {
filterByStatus = null;
} else {
filterByStatus = status;
}
if (consignee?.id == all) {
filterByConsingee = null;
} else {
filterByConsingee = consignee;
}
if (sender?.id == all) {
filterBySender = null;
} else {
filterBySender = sender;
}
loadPaginationCartons();
notifyListeners();
}
Future<void> loadPaginationBoxes(int index) async {
filterCartonByShipment(FcsShipment? fcsShipment) {
if (fcsShipment?.id == all) {
shipment = null;
} else {
shipment = fcsShipment;
}
loadPaginationCartons();
notifyListeners();
}
clearFilterSender() async {
filterBySender = null;
loadPaginationCartons();
notifyListeners();
}
clearFilterConsignee() async {
filterByConsingee = null;
loadPaginationCartons();
notifyListeners();
}
Future<void> loadPaginationCartons() async {
if (user == null || !user!.hasCarton()) return;
String path = "/$cartons_collection";
Query col = FirebaseFirestore.instance.collection(path);
Query pageQuery = FirebaseFirestore.instance.collection(path);
if (index == 1) {
col = col.where("status",
whereIn: [carton_packed_status, carton_shipped_status]);
pageQuery = pageQuery.where("status",
whereIn: [carton_packed_status, carton_shipped_status]);
if (filterByConsingee != null) {
col = col.where("user_id", isEqualTo: filterByConsingee!.id);
pageQuery = pageQuery.where("user_id", isEqualTo: filterByConsingee!.id);
}
if (index == 2) {
col = col.where("is_delivered", isEqualTo: true);
pageQuery = pageQuery.where("is_delivered", isEqualTo: true);
if (filterBySender != null) {
col = col.where("sender_id", isEqualTo: filterBySender!.id);
pageQuery = pageQuery.where("sender_id", isEqualTo: filterBySender!.id);
}
if (filterByStatus != null) {
col = col.where("status", isEqualTo: filterByStatus);
pageQuery = pageQuery.where("status", isEqualTo: filterByStatus);
}
if (shipment != null) {
col = col.where("fcs_shipment_id", isEqualTo: shipment!.id);
pageQuery = pageQuery.where("fcs_shipment_id", isEqualTo: shipment!.id);
}
pageQuery = pageQuery.orderBy("created_at", descending: true);
@@ -98,21 +136,23 @@ class CartonModel extends BaseModel {
rowPerLoad: 30);
}
_loadPaginationCartons(String orderName) {
_loadPaginationCartons() {
if (user == null || !user!.hasCarton()) return null;
String path = "/$cartons_collection";
Query col = FirebaseFirestore.instance.collection(path).where("carton_type",
whereIn: [
carton_from_packages,
carton_from_cartons
]).where("status", isEqualTo: carton_packed_status);
Query col = FirebaseFirestore.instance.collection(path);
// .where("carton_type",
// whereIn: [
// carton_from_packages,
// carton_from_cartons
// ]).where("status", isEqualTo: carton_packed_status)
// ;
Query pageQuery = FirebaseFirestore.instance
.collection(path)
.where("carton_type",
whereIn: [carton_from_packages, carton_from_cartons])
.where("status", isEqualTo: carton_packed_status)
.orderBy(orderName, descending: true);
// .where("carton_type",
// whereIn: [carton_from_packages, carton_from_cartons])
// .where("status", isEqualTo: carton_packed_status)
.orderBy("created_at", descending: true);
cartonsByFilter?.close();
cartonsByFilter = PaginatorListener<Carton>(

View File

@@ -0,0 +1,132 @@
import 'dart:async';
import 'package:cloud_firestore/cloud_firestore.dart';
import 'package:logging/logging.dart';
import '../../../domain/constants.dart';
import '../../../domain/entities/user.dart';
import '../../main/model/base_model.dart';
class ConsigneeSelectionModel extends BaseModel {
final log = Logger("ConsigneeSearchModel");
// for search
String query = "";
int offset = 0;
bool reachEnd = false;
List<User> _consignees = [];
List<User> get getConsginees {
var users = new List<User>.from(_consignees);
return users..insert(0, User(id: all, name: "All"));
}
bool isLoading = false;
// for default user
DocumentSnapshot? _lastDocument;
bool ended = false;
Timer? t;
search(String term, {bool imm = false}) async {
query = term;
_consignees.clear();
offset = 0;
reachEnd = false;
t?.cancel();
t = Timer(Duration(milliseconds: imm ? 0 : 800), () async {
await loadMoreSearch(term: term);
});
}
Future<void> loadMoreSearch({required String term}) async {
if (term == "") {
await _refresh();
return;
}
// int rowPerPage = 21;
// List<Carton> list = [];
// SearchPara searchPara = SearchPara(filters: [], term: term);
// isLoading = true;
// var path =
// "/search/$cartons_collection/${searchPara.escapeTerm}/$rowPerPage/$offset/${searchPara.escapeFilters}";
// var result = await requestAPI(path, "GET",
// token: await getToken(), url: Config.instance.searchURL);
// if (result != null) {
// for (var row in result) {
// var item = ArtistExt.fromMapForSearch(row);
// list.add(item);
// }
// }
// for (var p in list) {
// selectedArtistList.contains(p)
// ? p.isSelected = true
// : p.isSelected = false;
// }
// artists.addAll(list);
// offset += rowPerPage;
// if (list.length < rowPerPage) {
// reachEnd = true;
// }
notifyListeners();
}
addDefaultConsginees() async {
_consignees.clear();
await _refresh();
}
Future<void> _refresh() async {
_consignees.clear();
_lastDocument = null;
ended = false;
await loadMoreData();
notifyListeners();
}
Future<void> loadMoreData() async {
int rowPerPage = 20;
try {
isLoading = true;
String path = "/$user_collection";
Query query = FirebaseFirestore.instance
.collection(path)
.where("is_sys_admin", isEqualTo: false)
.where("is_deleted", isEqualTo: false)
.orderBy("message_time", descending: true);
if (_lastDocument != null) {
query = query.startAfterDocument(_lastDocument!);
}
QuerySnapshot querySnap = await query.limit(rowPerPage).get();
if (querySnap.docs.isEmpty) return;
_lastDocument = querySnap.docs[querySnap.docs.length - 1];
List<User> list = querySnap.docs.map((documentSnapshot) {
var p = User.fromMap(documentSnapshot.data() as Map<String, dynamic>,
documentSnapshot.id);
return p;
}).toList();
_consignees.addAll(list);
if (list.length < rowPerPage) ended = true;
notifyListeners();
} catch (e) {
log.warning("error:$e");
} finally {
isLoading = false;
}
}
clear() {
_consignees.clear();
query = "";
}
}

View File

@@ -0,0 +1,132 @@
import 'dart:async';
import 'package:cloud_firestore/cloud_firestore.dart';
import 'package:logging/logging.dart';
import '../../../domain/constants.dart';
import '../../../domain/entities/user.dart';
import '../../main/model/base_model.dart';
class SenderSelectionModel extends BaseModel {
final log = Logger("SenderSelectionModel");
// for search
String query = "";
int offset = 0;
bool reachEnd = false;
List<User> _senders = [];
List<User> get getSenders {
var users = new List<User>.from(_senders);
return users..insert(0, User(id: all, name: "All"));
}
bool isLoading = false;
// for default user
DocumentSnapshot? _lastDocument;
bool ended = false;
Timer? t;
search(String term, {bool imm = false}) async {
query = term;
_senders.clear();
offset = 0;
reachEnd = false;
t?.cancel();
t = Timer(Duration(milliseconds: imm ? 0 : 800), () async {
await loadMoreSearch(term: term);
});
}
Future<void> loadMoreSearch({required String term}) async {
if (term == "") {
await _refresh();
return;
}
// int rowPerPage = 21;
// List<Carton> list = [];
// SearchPara searchPara = SearchPara(filters: [], term: term);
// isLoading = true;
// var path =
// "/search/$cartons_collection/${searchPara.escapeTerm}/$rowPerPage/$offset/${searchPara.escapeFilters}";
// var result = await requestAPI(path, "GET",
// token: await getToken(), url: Config.instance.searchURL);
// if (result != null) {
// for (var row in result) {
// var item = ArtistExt.fromMapForSearch(row);
// list.add(item);
// }
// }
// for (var p in list) {
// selectedArtistList.contains(p)
// ? p.isSelected = true
// : p.isSelected = false;
// }
// artists.addAll(list);
// offset += rowPerPage;
// if (list.length < rowPerPage) {
// reachEnd = true;
// }
notifyListeners();
}
addDefaultSenders() async {
_senders.clear();
await _refresh();
}
Future<void> _refresh() async {
_senders.clear();
_lastDocument = null;
ended = false;
await loadMoreData();
notifyListeners();
}
Future<void> loadMoreData() async {
int rowPerPage = 20;
try {
isLoading = true;
String path = "/$user_collection";
Query query = FirebaseFirestore.instance
.collection(path)
.where("is_sys_admin", isEqualTo: false)
.where("is_deleted", isEqualTo: false)
.orderBy("message_time", descending: true);
if (_lastDocument != null) {
query = query.startAfterDocument(_lastDocument!);
}
QuerySnapshot querySnap = await query.limit(rowPerPage).get();
if (querySnap.docs.isEmpty) return;
_lastDocument = querySnap.docs[querySnap.docs.length - 1];
List<User> list = querySnap.docs.map((documentSnapshot) {
var p = User.fromMap(documentSnapshot.data() as Map<String, dynamic>,
documentSnapshot.id);
return p;
}).toList();
_senders.addAll(list);
if (list.length < rowPerPage) ended = true;
notifyListeners();
} catch (e) {
log.warning("error:$e");
} finally {
isLoading = false;
}
}
clear() {
_senders.clear();
query = "";
}
}