259 lines
8.5 KiB
Dart
259 lines
8.5 KiB
Dart
import 'dart:async';
|
|
import 'dart:io';
|
|
import 'dart:typed_data';
|
|
|
|
import 'package:cloud_firestore/cloud_firestore.dart';
|
|
import 'package:path/path.dart' as Path;
|
|
import 'package:fcs/fcs/common/helpers/api_helper.dart';
|
|
import 'package:fcs/model/constants.dart';
|
|
import 'package:fcs/pages/do/do_files.dart';
|
|
import 'package:fcs/vo/do.dart';
|
|
import 'package:fcs/vo/popup_menu.dart';
|
|
|
|
import 'base_model.dart';
|
|
import 'firebase_helper.dart';
|
|
|
|
class DOModel extends BaseModel {
|
|
StreamSubscription<QuerySnapshot> listener;
|
|
|
|
List<DOSubmission> dos = [];
|
|
PopupMenu popupMenu = new PopupMenu(index: 0);
|
|
int dateIndex = 0;
|
|
DateTime selectedDate = DateTime.now();
|
|
int timber = 0;
|
|
|
|
void initUser(user) async {
|
|
super.initUser(user);
|
|
_loadDOs();
|
|
}
|
|
|
|
@override
|
|
logout() async {
|
|
if (listener != null) await listener.cancel();
|
|
dos = [];
|
|
}
|
|
|
|
Future<void> _loadDOs() async {
|
|
String path;
|
|
if (user.hasDO() || user.isOwnerAndAbove()) {
|
|
path = "/$biz_collection/${setting.okEnergyId}/$dos_collection";
|
|
}
|
|
if (user.isBuyer()) {
|
|
path =
|
|
"/$biz_collection/${setting.okEnergyId}/$buyer_collection/${user.docID}/$dos_collection";
|
|
}
|
|
var startDate = new DateTime(
|
|
selectedDate.year, selectedDate.month, selectedDate.day, 0, 0, 0);
|
|
var endDate = new DateTime(
|
|
selectedDate.year, selectedDate.month, selectedDate.day, 23, 59, 59);
|
|
|
|
listener =
|
|
getFilterDateSnapshot(path, 'do_date', startDate, endDate, 'do_number')
|
|
.listen((snaps) async {
|
|
dos.clear();
|
|
snaps.documents.forEach((d) {
|
|
dos.add(DOSubmission.fromMap(d.data, d.documentID));
|
|
});
|
|
notifyListeners();
|
|
});
|
|
}
|
|
|
|
Future<DOSubmission> loadDOPOLines(DOSubmission doSub) async {
|
|
String path =
|
|
"/$biz_collection/${setting.okEnergyId}/$dos_collection/${doSub.id}/$do_po_lines_collection";
|
|
if (user.isBuyer()) {
|
|
path =
|
|
"/$biz_collection/${setting.okEnergyId}/$buyer_collection/${user.docID}/$dos_collection/${doSub.id}/$do_po_lines_collection";
|
|
}
|
|
var snaps = await getSnapshot(path);
|
|
doSub.dopoLies =
|
|
snaps.documents.map((s) => DOPOLine.fromMap(s.data)).toList();
|
|
return doSub;
|
|
}
|
|
|
|
Future<DOSubmission> getDO(String id) async {
|
|
String path = "/$biz_collection/${setting.okEnergyId}/$dos_collection";
|
|
if (user.isBuyer()) {
|
|
path =
|
|
"/$biz_collection/${setting.okEnergyId}/$buyer_collection/${user.docID}/$dos_collection";
|
|
}
|
|
var doSnap = await getDocSnap(path, id);
|
|
return DOSubmission.fromMap(doSnap.data, doSnap.documentID);
|
|
}
|
|
|
|
Future<void> createDO(DOSubmission doSubmission, DOFiles files) async {
|
|
doSubmission.userID = user.docID;
|
|
String path = Path.join(do_files_path, user.docID);
|
|
|
|
if (files.storageChargeFile != null) {
|
|
String url = await uploadStorage(path, files.storageChargeFile);
|
|
doSubmission.storageReceiptUrl = url;
|
|
}
|
|
if (files.licenseFile != null) {
|
|
String url = await uploadStorage(path, files.licenseFile);
|
|
doSubmission.driverLicenceUrl = url;
|
|
}
|
|
|
|
await request("/do", "POST",
|
|
payload: doSubmission.toMap(), token: await getToken());
|
|
}
|
|
|
|
Future<void> updateDO(DOSubmission doSubmission, DOFiles files) async {
|
|
String path = Path.join(do_files_path, user.docID);
|
|
if (files.storageFileChanged) {
|
|
if (doSubmission.storageReceiptUrl != null &&
|
|
doSubmission.storageReceiptUrl != '') {
|
|
await deleteStorageFromUrl(doSubmission.storageReceiptUrl);
|
|
}
|
|
doSubmission.storageReceiptUrl = null;
|
|
String url = await uploadStorage(path, files.storageChargeFile);
|
|
doSubmission.storageReceiptUrl = url;
|
|
}
|
|
|
|
if (files.licenseFileChanged) {
|
|
if (doSubmission.driverLicenceUrl != null &&
|
|
doSubmission.driverLicenceUrl != '') {
|
|
await deleteStorageFromUrl(doSubmission.driverLicenceUrl);
|
|
}
|
|
doSubmission.driverLicenceUrl = null;
|
|
String url = await uploadStorage(path, files.licenseFile);
|
|
doSubmission.driverLicenceUrl = url;
|
|
}
|
|
await request("/do", "PUT",
|
|
payload: doSubmission.toMap(), token: await getToken());
|
|
}
|
|
|
|
Future<void> approveDO(DOSubmission doObj) async {
|
|
await request("/do/approved", "POST",
|
|
payload: doObj.toMap(), token: await getToken());
|
|
}
|
|
|
|
Future<void> rejectDO(DOSubmission doObj) async {
|
|
await request("/do/rejected", "POST",
|
|
payload: doObj.toMap(), token: await getToken());
|
|
}
|
|
|
|
Future<void> cancelDO(DOSubmission doObj) async {
|
|
await request("/do/canceled", "POST",
|
|
payload: doObj.toMap(), token: await getToken());
|
|
}
|
|
|
|
Future<void> initDelivery(DOSubmission doObj) async {
|
|
String path = Path.join(do_files_path, user.docID);
|
|
String imgUrl =
|
|
await uploadStorage(path, doObj.driverImg, fileName: doObj.id);
|
|
doObj.driverImgUrl = imgUrl;
|
|
await request("/do/initiated", "POST",
|
|
payload: doObj.toMap(), token: await getToken());
|
|
}
|
|
|
|
Future<void> startDelivery(DOSubmission doObj) async {
|
|
await request("/do/started", "POST",
|
|
payload: doObj.toMap(), token: await getToken());
|
|
}
|
|
|
|
Future<void> endDelivery(DOSubmission doObj, Uint8List img) async {
|
|
String path = Path.join(do_files_path, user.docID);
|
|
String imgUrl = await uploadStorageData(path, img, fileName: doObj.id);
|
|
doObj.doReceiptUrl = imgUrl;
|
|
await request("/do/ended", "POST",
|
|
payload: doObj.toMap(), token: await getToken());
|
|
}
|
|
|
|
void filterData(
|
|
String status, DateTime dateTime, int _selectedIndex, int _dateIndex) {
|
|
dos.clear();
|
|
if (listener != null) {
|
|
listener.cancel();
|
|
}
|
|
|
|
this.popupMenu.index = _selectedIndex;
|
|
this.dateIndex = _dateIndex;
|
|
this.selectedDate = dateTime == null
|
|
? new DateTime(
|
|
selectedDate.year, selectedDate.month, selectedDate.day, 0, 0, 0)
|
|
: dateTime;
|
|
|
|
String path = "/$biz_collection/${setting.okEnergyId}/$dos_collection";
|
|
if (user.isBuyer()) {
|
|
path =
|
|
"/$biz_collection/${setting.okEnergyId}/$buyer_collection/${user.docID}/$dos_collection";
|
|
}
|
|
|
|
if (status != null && dateTime == null) {
|
|
listener = getFilterStatusSnapshot(path, status, 'do_number')
|
|
.listen((snaps) async {
|
|
dos.clear();
|
|
snaps.documents.forEach((d) {
|
|
dos.add(DOSubmission.fromMap(d.data, d.documentID));
|
|
});
|
|
notifyListeners();
|
|
});
|
|
} else if (dateTime != null && status == null) {
|
|
var endDate =
|
|
new DateTime(dateTime.year, dateTime.month, dateTime.day, 23, 59, 59);
|
|
listener =
|
|
getFilterDateSnapshot(path, 'do_date', dateTime, endDate, 'do_number')
|
|
.listen((snaps) async {
|
|
dos.clear();
|
|
snaps.documents.forEach((d) {
|
|
dos.add(DOSubmission.fromMap(d.data, d.documentID));
|
|
});
|
|
notifyListeners();
|
|
});
|
|
} else if (status != null && dateTime != null) {
|
|
var endDate =
|
|
new DateTime(dateTime.year, dateTime.month, dateTime.day, 23, 59, 59);
|
|
listener = getFilterDataSnapshot(
|
|
path, status, 'do_date', dateTime, endDate, 'do_number')
|
|
.listen((snaps) async {
|
|
dos.clear();
|
|
snaps.documents.forEach((d) {
|
|
dos.add(DOSubmission.fromMap(d.data, d.documentID));
|
|
});
|
|
notifyListeners();
|
|
});
|
|
} else {
|
|
listener =
|
|
getQuerySnapshotByOrder(path, 'do_number').listen((snaps) async {
|
|
dos.clear();
|
|
snaps.documents.forEach((d) {
|
|
dos.add(DOSubmission.fromMap(d.data, d.documentID));
|
|
});
|
|
notifyListeners();
|
|
});
|
|
}
|
|
}
|
|
|
|
addTimber(int count) {
|
|
timber = count;
|
|
notifyListeners();
|
|
}
|
|
|
|
Future<List<DOSubmission>> getDOForDelivery(DateTime dateTime) async {
|
|
List<DOSubmission> dos = [];
|
|
|
|
String path = "/$biz_collection/${setting.okEnergyId}/$dos_collection";
|
|
if (user.isBuyer()) {
|
|
path =
|
|
"/$biz_collection/${setting.okEnergyId}/$buyer_collection/${user.docID}/$dos_collection";
|
|
}
|
|
DateTime date = DateTime(dateTime.year, dateTime.month, dateTime.day);
|
|
DateTime dateAddOne = date.add(Duration(days: 1));
|
|
|
|
QuerySnapshot snapshots = await Firestore.instance
|
|
.collection(path)
|
|
.where("status", isEqualTo: do_approved_status)
|
|
.where("delivery_date", isGreaterThanOrEqualTo: date)
|
|
.where("delivery_date", isLessThan: dateAddOne)
|
|
.orderBy("delivery_date")
|
|
.orderBy("user_name")
|
|
.limit(100)
|
|
.getDocuments();
|
|
snapshots.documents.forEach((d) {
|
|
dos.add(DOSubmission.fromMap(d.data, d.documentID));
|
|
});
|
|
return dos;
|
|
}
|
|
}
|