You cannot select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
cloudsolutions-atoms/lib/controllers/providers/api/all_requests_provider.dart

725 lines
23 KiB
Dart

import 'dart:convert';
import 'package:flutter/widgets.dart';
import 'package:http/http.dart';
import 'package:test_sa/controllers/api_routes/api_manager.dart';
import 'package:test_sa/controllers/api_routes/urls.dart';
import 'package:test_sa/extensions/context_extension.dart';
import 'package:test_sa/models/all_requests_and_count_model.dart';
import 'package:test_sa/models/enums/user_types.dart';
import 'package:test_sa/models/ppm/recurrent_wo.dart';
import 'package:test_sa/models/timer_model.dart';
import '../../../models/search_all_requests_model.dart';
class AllRequestsProvider extends ChangeNotifier {
bool isAllLoading = false;
bool isOpenLoading = false;
bool isInProgressLoading = false;
bool isCompleteLoading = false;
bool isOverdueLoading = false;
bool isHighPriorityLoading = false;
bool isCalendarLoading = false;
bool isLoading = false;
bool _isFilterRequestLoading = false;
bool _isRequestCategoryLoading = false;
int _status = 0;
int get status => _status;
set status(int value) {
_status = value;
notifyListeners();
}
int _currentListIndex = 0;
int get currentListIndex => _currentListIndex;
set currentListIndex(int value) {
_currentListIndex = value;
notifyListeners();
}
int? stateCode;
AllRequestsAndCount? _allRequestsAndCount;
AllRequestsAndCount? _openRequests;
AllRequestsAndCount? _inProgressRequests;
AllRequestsAndCount? _completedRequests;
AllRequestsAndCount? _filterRequest;
AllRequestsAndCount? _requestDetailList;
AllRequestsAndCount? get allRequestsAndCount => _allRequestsAndCount;
AllRequestsAndCount? get highPriorityRequests => _highPriorityRequests;
AllRequestsAndCount? get overdueRequests => _overdueRequests;
// AllRequestsAndCount? get openRequests => _openRequests;
// AllRequestsAndCount? get completedRequests => _completedRequests;
AllRequestsAndCount? get requestDetailList => _requestDetailList;
RecurrentWoData? _recurrentWoData = RecurrentWoData();
RecurrentWoData? get recurrentWoData => _recurrentWoData;
set recurrentWoData(RecurrentWoData? value) {
_recurrentWoData = value;
notifyListeners();
}
set requestDetailList(AllRequestsAndCount? value) {
_requestDetailList = value;
notifyListeners();
}
AllRequestsAndCount? _selectedRequestCategory;
bool get isRequestCategoryLoading => _isRequestCategoryLoading;
set isRequestCategoryLoading(bool value) {
_isRequestCategoryLoading = value;
notifyListeners();
} // overdue,high priority, new , completed
AllRequestsAndCount? _overdueRequests;
AllRequestsAndCount? _highPriorityRequests;
bool isLoadingList = false;
updateIsLoadingList(value) {
isLoadingList = value;
notifyListeners();
}
AllRequestsAndCount? calendarRequests;
final pageItemNumber = 10;
int pageNum = 1;
bool nextPage = true;
void reset() {
_allRequestsAndCount?.requestsDetails?.clear();
_allRequestsAndCount = null;
pageNum = 1;
nextPage = true;
stateCode = null;
}
void resetRequestsApiData() {
_highPriorityRequests = null;
_overdueRequests = null;
openRequests = null;
inProgressRequests = null;
completedRequests = null;
pageNum = 1;
nextPage = true;
stateCode = null;
}
Future<void> getRequests() async {
resetRequestsApiData();
getOpenRequests(pagination: true);
getInProgressRequests(pagination: true);
getCompletedRequests(pagination: true);
getHighPriorityRequests(pagination: true);
getOverdueRequests(pagination: true);
}
SearchAllRequestsModel? searchedModel;
List<int> getStatues(BuildContext context) {
List<int> list = [1, 2, 3, 4];
if (context.userProvider.user!.type != UsersTypes.normal_user) {
list.add(5);
}
list.add(6); // task module
if (context.settingProvider.isUserFlowMedical && context.userProvider.user!.type != UsersTypes.normal_user) {
list.add(7); // task mod
}
if (context.userProvider.user!.type != UsersTypes.normal_user) {
list.add(8); //
}
if (context.userProvider.user!.type == UsersTypes.normal_user) {
list.add(9); //
}
return list;
}
Future<int> getAllRequests(BuildContext context, {int? typeTransaction, SearchAllRequestsModel? search}) async {
if (isAllLoading == true) return -2;
isAllLoading = true;
if (_allRequestsAndCount == null) notifyListeners();
Response response;
try {
if (search != null) {
searchedModel = search;
} else {
searchedModel = null;
}
final type = typeTransaction == null
? search?.typeTransaction == null || (search?.typeTransaction?.isEmpty ?? false)
? [1, 2, 3, 4, 5, 6, 7]
: search!.typeTransaction
: [typeTransaction];
List<int> status = (search?.statuses == null || (search?.statuses?.isEmpty ?? false)) ? (((search?.isArchived ?? false) ? [3] : [1, 2, 4])) : search!.statuses!;
Map<String, dynamic> body = {
"typeTransaction": type,
"statusTransaction": status,
"priority": [],
"displayData": [],
"pageNumber": pageNum++,
"pageSize": pageItemNumber,
if (search?.requestNumber?.value?.isNotEmpty ?? false) "requestNumber": search!.requestNumber!.value,
if (search?.assetName?.value?.isNotEmpty ?? false) "assetName": search!.assetName!.value,
if (search?.assetNo?.value?.isNotEmpty ?? false) "assetNumber": search!.assetNo!.value,
if (search?.sn?.value?.isNotEmpty ?? false) "assetSerialNo": search!.sn!.value,
if (search?.model?.value?.isNotEmpty ?? false) "model": search!.model!.value,
if (search?.manufacture?.value?.isNotEmpty ?? false) "manufacturer": search!.manufacture!.value,
if (search?.startDate != null) "from": search!.startDate!.toIso8601String(),
if (search?.endDate != null) "to": search!.endDate!.toIso8601String(),
};
response = await ApiManager.instance.post(URLs.getAllRequestsAndCount, body: body);
stateCode = response.statusCode;
if (response.statusCode >= 200 && response.statusCode < 300) {
if (_allRequestsAndCount == null) {
_allRequestsAndCount = (await AllRequestsAndCount.fromJson(json.decode(response.body)["data"][0]));
} else {
_allRequestsAndCount!.requestsDetails!.addAll((await AllRequestsAndCount.fromJson(json.decode(response.body)["data"][0])).requestsDetails!);
}
if (_allRequestsAndCount!.requestsDetails!.length >= pageItemNumber) {
nextPage = true;
} else {
nextPage = false;
}
notifyListeners();
} else {
_allRequestsAndCount = null;
}
isAllLoading = false;
notifyListeners();
return response.statusCode;
} catch (error) {
isAllLoading = false;
stateCode = -1;
notifyListeners();
return -1;
}
}
Future<int> getRecurrentWoById({required int id}) async {
isLoading = true;
Response response;
try {
response = await ApiManager.instance.get(URLs.getRecurrentPlanByIdUrl + "?planRecurrentTaskId=$id");
stateCode = response.statusCode;
if (response.statusCode >= 200 && response.statusCode < 300) {
recurrentWoData = RecurrentWoData.fromJson(json.decode(response.body)["data"]);
recurrentWoData?.planRecurrentMedicalTaskRooms?.forEach((element) {
element.planRecurrentMedicalTaskRoomTabs?.forEach((tabs) {
tabs.planRecurrentMedicalTaskRoomTabAttributes?.forEach((attribute) {
if (attribute.attribute?.type == "bool" && attribute.attributeValue == null) {
attribute.attributeValue = "true";
}
});
});
});
notifyListeners();
}
isLoading = false;
notifyListeners();
return response.statusCode;
} catch (error) {
isLoading = false;
stateCode = -1;
notifyListeners();
return -1;
}
}
Future<bool> updateRecurrentWo({required int status}) async {
isLoading = true;
Response response;
try {
response = await ApiManager.instance.post(URLs.updateRecurrentPlanUrl, body: recurrentWoData!.toJson(status: status));
stateCode = response.statusCode;
isLoading = false;
notifyListeners();
if (stateCode == 200) {
return true;
}
return false;
} catch (error) {
isLoading = false;
stateCode = -1;
notifyListeners();
return false;
}
}
void updateRecurrentWoTimer({TimerModel? timer}) {
recurrentWoData?.recurrentWoTimerModel = timer;
if (timer?.startAt != null && timer?.endAt != null) {
recurrentWoData?.timerModelList = recurrentWoData?.timerModelList ?? [];
recurrentWoData?.timerModelList!.add(timer!);
}
notifyListeners();
}
Future<int> getCalendarRequests({required DateTime from, DateTime? to}) async {
if (isCalendarLoading == true) return -2;
isCalendarLoading = true;
notifyListeners();
Response response;
try {
Map<String, dynamic> body = {
"typeTransaction": [1, 2, 3, 4],
"statusTransaction": [1, 2, 3, 4],
"priority": [0, 1],
"displayData": [],
"from": from.toIso8601String(),
"to": to?.toIso8601String() ?? from.toIso8601String(),
};
response = await ApiManager.instance.post(URLs.getAllRequestsAndCount, body: body);
stateCode = response.statusCode;
if (response.statusCode >= 200 && response.statusCode < 300) {
calendarRequests = (await AllRequestsAndCount.fromJson(json.decode(response.body)["data"][0]));
notifyListeners();
}
isCalendarLoading = false;
notifyListeners();
return response.statusCode;
} catch (error) {
isCalendarLoading = false;
stateCode = -1;
notifyListeners();
return -1;
}
}
Future<int> getHighPriorityRequests({bool pagination = false}) async {
if (isHighPriorityLoading == true) return -2;
if (_highPriorityRequests == null || pagination) {
isHighPriorityLoading = true;
// notifyListeners();
}
Response response;
try {
Map<String, dynamic> body = {
"typeTransaction": [1],
"statusTransaction": [1, 2, 4],
"priority": [1],
"displayData": []
};
if (pagination) {
body["pageNumber"] = 0;
body["pageSize"] = 0;
} else {
body["pageNumber"] = pageNum++;
body["pageSize"] = pageItemNumber;
}
response = await ApiManager.instance.post(URLs.getAllRequestsAndCount, body: body);
stateCode = response.statusCode;
if (response.statusCode >= 200 && response.statusCode < 300) {
if (_highPriorityRequests == null) {
_highPriorityRequests = (await AllRequestsAndCount.fromJson(json.decode(response.body)["data"][0]));
} else {
_highPriorityRequests!.requestsDetails!.addAll((await AllRequestsAndCount.fromJson(json.decode(response.body)["data"][0])).requestsDetails!);
}
if (_highPriorityRequests!.requestsDetails!.length >= pageItemNumber) {
nextPage = true;
} else {
nextPage = false;
}
notifyListeners();
} else {
_allRequestsAndCount = null;
}
isHighPriorityLoading = false;
notifyListeners();
return response.statusCode;
} catch (error) {
isHighPriorityLoading = false;
stateCode = -1;
notifyListeners();
return -1;
}
}
Future<int> getOverdueRequests({bool pagination = false}) async {
if (isOverdueLoading == true) return -2;
if (_overdueRequests == null || pagination) {
isOverdueLoading = true;
notifyListeners();
}
Response response;
try {
Map<String, dynamic> body = {
"typeTransaction": [1, 2, 3, 4],
"statusTransaction": [1, 2, 4],
"priority": [],
"displayData": [1]
};
if (pagination) {
body["pageNumber"] = 0;
body["pageSize"] = 0;
} else {
body["pageNumber"] = pageNum++;
body["pageSize"] = pageItemNumber;
}
response = await ApiManager.instance.post(URLs.getAllRequestsAndCount, body: body);
stateCode = response.statusCode;
if (response.statusCode >= 200 && response.statusCode < 300) {
if (_overdueRequests == null) {
_overdueRequests = (await AllRequestsAndCount.fromJson(json.decode(response.body)["data"][0]));
} else {
_overdueRequests!.requestsDetails!.addAll((await AllRequestsAndCount.fromJson(json.decode(response.body)["data"][0])).requestsDetails!);
}
if (_overdueRequests!.requestsDetails!.length >= pageItemNumber) {
nextPage = true;
} else {
nextPage = false;
}
notifyListeners();
} else {
_allRequestsAndCount = null;
}
isOverdueLoading = false;
notifyListeners();
return response.statusCode;
} catch (error) {
isOverdueLoading = false;
stateCode = -1;
notifyListeners();
return -1;
}
}
Future<int> getOpenRequests({bool pagination = false, bool reset = false}) async {
if (isOpenLoading == true) return -2;
if (reset) {
openRequests = null;
pageNum = 1;
}
if (openRequests == null || pagination) {
isOpenLoading = true;
notifyListeners();
}
Response response;
try {
bool isEngineer = ApiManager.instance.user!.type == UsersTypes.engineer;
Map<String, dynamic> body = {
"typeTransaction": [1, 2, 3, 4],
"statusTransaction": [isEngineer ? 2 : 1],
"priority": [],
"displayData": []
};
if (pagination) {
body["pageNumber"] = 0;
body["pageSize"] = 0;
} else {
body["pageNumber"] = pageNum++;
body["pageSize"] = pageItemNumber;
}
response = await ApiManager.instance.post(URLs.getAllRequestsAndCount, body: body);
stateCode = response.statusCode;
if (response.statusCode >= 200 && response.statusCode < 300) {
if (openRequests == null) {
openRequests = (await AllRequestsAndCount.fromJson(json.decode(response.body)["data"][0]));
} else {
openRequests!.requestsDetails!.addAll((await AllRequestsAndCount.fromJson(json.decode(response.body)["data"][0])).requestsDetails!);
}
if (openRequests!.requestsDetails!.length >= pageItemNumber) {
nextPage = true;
} else {
nextPage = false;
}
notifyListeners();
} else {
_allRequestsAndCount = null;
}
isOpenLoading = false;
notifyListeners();
return response.statusCode;
} catch (error) {
isOpenLoading = false;
stateCode = -1;
notifyListeners();
return -1;
}
}
Future<int> getInProgressRequests({bool pagination = false, bool reset = false}) async {
if (isInProgressLoading == true) return -2;
if (reset) {
inProgressRequests = null;
pageNum = 1;
}
if (inProgressRequests == null || pagination) {
isInProgressLoading = true;
notifyListeners();
}
Response response;
try {
Map<String, dynamic> body = {
"typeTransaction": [1, 2, 3, 4],
"statusTransaction": [2],
"priority": [],
"displayData": []
};
if (pagination) {
body["pageNumber"] = 0;
body["pageSize"] = 0;
} else {
body["pageNumber"] = pageNum++;
body["pageSize"] = pageItemNumber;
}
response = await ApiManager.instance.post(URLs.getAllRequestsAndCount, body: body);
stateCode = response.statusCode;
if (response.statusCode >= 200 && response.statusCode < 300) {
if (inProgressRequests == null) {
inProgressRequests = (await AllRequestsAndCount.fromJson(json.decode(response.body)["data"][0]));
notifyListeners();
} else {
inProgressRequests!.requestsDetails!.addAll((await AllRequestsAndCount.fromJson(json.decode(response.body)["data"][0])).requestsDetails!);
notifyListeners();
}
if (inProgressRequests!.requestsDetails!.length >= pageItemNumber) {
nextPage = true;
} else {
nextPage = false;
}
notifyListeners();
} else {
_allRequestsAndCount = null;
}
isInProgressLoading = false;
notifyListeners();
return response.statusCode;
} catch (error) {
isInProgressLoading = false;
stateCode = -1;
notifyListeners();
return -1;
}
}
Future<int> getFilterRequests({bool showLoader = true, required int status}) async {
// if (filterRequest == null || pagination) {
// isFilterRequestLoading = true;
// notifyListeners();
// }
isFilterRequestLoading = showLoader;
Response response;
try {
Map<String, dynamic> body = {
"typeTransaction": [1, 2, 3, 4],
"statusTransaction": [status],
"priority": [],
"displayData": [],
"pageNumber": pageNum,
"pageSize": pageItemNumber,
};
response = await ApiManager.instance.post(URLs.getAllRequestsAndCount, body: body);
stateCode = response.statusCode;
if (response.statusCode >= 200 && response.statusCode < 300) {
if (filterRequest == null) {
filterRequest = (await AllRequestsAndCount.fromJson(json.decode(response.body)["data"][0]));
isFilterRequestLoading = false;
notifyListeners();
} else {
filterRequest!.requestsDetails!.addAll((await AllRequestsAndCount.fromJson(json.decode(response.body)["data"][0])).requestsDetails!);
isFilterRequestLoading = false;
notifyListeners();
}
if (filterRequest!.requestsDetails!.length >= pageItemNumber) {
nextPage = true;
} else {
nextPage = false;
}
notifyListeners();
} else {
filterRequest = null;
}
isFilterRequestLoading = false;
notifyListeners();
return response.statusCode;
} catch (error) {
isFilterRequestLoading = false;
stateCode = -1;
notifyListeners();
return -1;
}
}
Future<int> getSelectedRequestCategory({required RequestQueryModel requestQueryModel}) async {
isRequestCategoryLoading = requestQueryModel.showLoader;
Response response;
try {
response = await ApiManager.instance.post(URLs.getAllRequestsAndCount, body: requestQueryModel.toJson());
stateCode = response.statusCode;
if (response.statusCode >= 200 && response.statusCode < 300) {
if (selectedRequestCategory == null) {
selectedRequestCategory = (await AllRequestsAndCount.fromJson(json.decode(response.body)["data"][0]));
isRequestCategoryLoading = false;
notifyListeners();
} else {
selectedRequestCategory!.requestsDetails!.addAll((await AllRequestsAndCount.fromJson(json.decode(response.body)["data"][0])).requestsDetails!);
isRequestCategoryLoading = false;
notifyListeners();
}
} else {
filterRequest = null;
}
isRequestCategoryLoading = false;
notifyListeners();
return response.statusCode;
} catch (error) {
isRequestCategoryLoading = false;
stateCode = -1;
notifyListeners();
return -1;
}
}
Future<int> getCompletedRequests({bool pagination = false, bool reset = false}) async {
if (isCompleteLoading == true) return -2;
if (reset) {
completedRequests = null;
pageNum = 1;
}
if (completedRequests == null || pagination) {
isCompleteLoading = true;
notifyListeners();
}
Response response;
try {
Map<String, dynamic> body = {
"typeTransaction": [1, 2, 3, 4],
"statusTransaction": [4],
"priority": [],
"displayData": []
};
if (pagination) {
body["pageNumber"] = 0;
body["pageSize"] = 0;
} else {
body["pageNumber"] = pageNum++;
body["pageSize"] = pageItemNumber;
}
response = await ApiManager.instance.post(URLs.getAllRequestsAndCount, body: body);
stateCode = response.statusCode;
if (response.statusCode >= 200 && response.statusCode < 300) {
if (completedRequests == null) {
completedRequests = (await AllRequestsAndCount.fromJson(json.decode(response.body)["data"][0]));
} else {
completedRequests!.requestsDetails!.addAll((await AllRequestsAndCount.fromJson(json.decode(response.body)["data"][0])).requestsDetails!);
}
if (completedRequests!.requestsDetails!.length >= pageItemNumber) {
nextPage = true;
} else {
nextPage = false;
}
notifyListeners();
} else {
_allRequestsAndCount = null;
}
isCompleteLoading = false;
notifyListeners();
return response.statusCode;
} catch (error) {
isCompleteLoading = false;
stateCode = -1;
notifyListeners();
return -1;
}
}
AllRequestsAndCount? get inProgressRequests => _inProgressRequests;
set inProgressRequests(AllRequestsAndCount? value) {
_inProgressRequests = value;
notifyListeners();
}
AllRequestsAndCount? get completedRequests => _completedRequests;
set completedRequests(AllRequestsAndCount? value) {
_completedRequests = value;
notifyListeners();
}
AllRequestsAndCount? get openRequests => _openRequests;
set openRequests(AllRequestsAndCount? value) {
_openRequests = value;
notifyListeners();
}
AllRequestsAndCount? get filterRequest => _filterRequest;
set filterRequest(AllRequestsAndCount? value) {
_filterRequest = value;
notifyListeners();
}
bool get isFilterRequestLoading => _isFilterRequestLoading;
set isFilterRequestLoading(bool value) {
_isFilterRequestLoading = value;
notifyListeners();
}
AllRequestsAndCount? get selectedRequestCategory => _selectedRequestCategory;
set selectedRequestCategory(AllRequestsAndCount? value) {
_selectedRequestCategory = value;
notifyListeners();
}
// Future<int> getCloseRequests() async {
// if (isCloseLoading == true) return -2;
// isCloseLoading = true;
// if (closeRequests == null) notifyListeners();
// Response response;
// try {
// Map<String, dynamic> body = {
// "typeTransaction": [1, 2, 3, 4],
// "statusTransaction": [4],
// "priority": [],
// "displayData": []
// };
// response = await ApiManager.instance.post(URLs.getAllRequestsAndCount, body: body);
//
// stateCode = response.statusCode;
// if (response.statusCode >= 200 && response.statusCode < 300) {
// closeRequests = AllRequestsAndCount.fromJson(json.decode(response.body)["data"]);
// notifyListeners();
// }
// isCloseLoading = false;
// notifyListeners();
// return response.statusCode;
// } catch (error) {
// isCloseLoading = false;
// stateCode = -1;
// notifyListeners();
// return -1;
// }
// }
}