add customers and staffs

lib/fcs/common/pages/staff/model/staff_model.dart

@@ -0,0 +1,88 @@
+import 'package:cloud_firestore/cloud_firestore.dart';
+import 'package:fcs/fcs/common/domain/constants.dart';
+import 'package:fcs/fcs/common/domain/entities/role.dart';
+import 'package:fcs/fcs/common/domain/entities/user.dart';
+import 'package:fcs/fcs/common/helpers/firebase_helper.dart';
+import 'package:fcs/fcs/common/pages/model/base_model.dart';
+import 'package:fcs/fcs/common/services/services.dart';
+import 'package:logging/logging.dart';
+
+class StaffModel extends BaseModel {
+  final log = Logger('StaffModel');
+
+  List<User> employees = [];
+  List<Privilege> privileges = [];
+
+  void initUser(user) async {
+    super.initUser(user);
+    _loadPrivileges();
+    _loadEmployees();
+  }
+
+  @override
+  logout() async {
+    employees = [];
+  }
+
+  Future<void> _loadEmployees() async {
+    if (user == null || !user.hasStaffs()) return;
+
+    try {
+      Firestore.instance
+          .collection("/$user_collection")
+          .where("is_employee", isEqualTo: true)
+          .where("is_sys_admin", isEqualTo: false)
+          .snapshots()
+          .listen((QuerySnapshot snapshot) {
+        employees.clear();
+        employees = snapshot.documents.map((documentSnapshot) {
+          var user =
+              User.fromMap(documentSnapshot.data, documentSnapshot.documentID);
+          return user;
+        }).toList();
+        notifyListeners();
+      }).onError((e) {
+        log.warning("Error! $e");
+      });
+    } catch (e) {
+      log.warning("Error!! $e");
+    }
+  }
+
+  Future<void> _loadPrivileges() async {
+    if (user == null || !user.hasStaffs()) return;
+
+    try {
+      Firestore.instance
+          .collection("/$privilege_collection")
+          .snapshots()
+          .listen((QuerySnapshot snapshot) {
+        privileges.clear();
+        privileges = snapshot.documents.map((documentSnapshot) {
+          var privilege = Privilege.fromMap(
+              documentSnapshot.data, documentSnapshot.documentID);
+          return privilege;
+        }).toList();
+        notifyListeners();
+      }).onError((e) {
+        log.warning("Error! $e");
+      });
+    } catch (e) {
+      log.warning("Error!! $e");
+    }
+  }
+
+  Future<void> updatePrivileges(String userID, List<String> privileges) async {
+    try {
+      await request("/employee/privileges", "PUT",
+          payload: {"id": userID, "privileges": privileges},
+          token: await getToken());
+    } catch (e) {
+      throw Exception(e);
+    }
+  }
+
+  Future<User> findUser(String phoneNumber) {
+    return Services.instance.userService.findUser(phoneNumber);
+  }
+}