69 lines
2.0 KiB
Dart
69 lines
2.0 KiB
Dart
import 'dart:async';
|
|
|
|
import 'package:cloud_firestore/cloud_firestore.dart';
|
|
import 'package:fcs/vo/announcement.dart';
|
|
import 'package:fcs/vo/shipment.dart';
|
|
|
|
import 'base_model.dart';
|
|
import 'constants.dart';
|
|
import 'firebase_helper.dart';
|
|
|
|
class AnnouncementModel extends BaseModel {
|
|
List<Announcement> announcements = [];
|
|
|
|
List<Shipment> shipments = [
|
|
Shipment(shipDate: DateTime(2020, 4, 23), shipmentNumber: 'A103B',status: 'In progress'),
|
|
Shipment(shipDate: DateTime(2020, 4, 2), shipmentNumber: 'A100A',status: 'Delivered'),
|
|
Shipment(shipDate: DateTime(2020, 4, 2), shipmentNumber: 'A100B',status: 'Delivered')
|
|
];
|
|
|
|
void initUser(user) {
|
|
super.initUser(user);
|
|
_loadAnnouncements();
|
|
}
|
|
|
|
@override
|
|
logout() async {
|
|
announcements = [];
|
|
}
|
|
|
|
Future<void> _loadAnnouncements() async {
|
|
Stream<QuerySnapshot> snapshots = Firestore.instance
|
|
.collection(
|
|
"/$biz_collection/${setting.okEnergyId}/$announcement_collection")
|
|
.snapshots();
|
|
|
|
snapshots.listen((snaps) async {
|
|
announcements = snaps.documents.map((documentSnapshot) {
|
|
var data = Announcement.fromMap(
|
|
documentSnapshot.data, documentSnapshot.documentID);
|
|
return data;
|
|
}).toList();
|
|
|
|
notifyListeners();
|
|
});
|
|
}
|
|
|
|
Future<Announcement> getAnnouncement(String id) async {
|
|
String path =
|
|
"/$biz_collection/${setting.okEnergyId}/$announcement_collection";
|
|
var snap = await getDocSnap(path, id);
|
|
return Announcement.fromMap(snap.data, snap.documentID);
|
|
}
|
|
|
|
Future<void> createAnnouncement(Announcement announcement) async {
|
|
await request("/announcement", "POST",
|
|
payload: announcement.toMap(), token: await getToken());
|
|
}
|
|
|
|
Future<void> updateAnnouncement(Announcement announcement) async {
|
|
await request("/announcement", "PUT",
|
|
payload: announcement.toMap(), token: await getToken());
|
|
}
|
|
|
|
Future<void> deleteAnnouncement(Announcement announcement) async {
|
|
await request("/announcement", "DELETE",
|
|
payload: announcement.toMap(), token: await getToken());
|
|
}
|
|
}
|