280 lines
8.6 KiB
Dart
280 lines
8.6 KiB
Dart
import 'dart:async';
|
|
|
|
import 'package:flutter/services.dart';
|
|
import 'package:flutter/widgets.dart';
|
|
import 'package:rasadyar_chicken/features/common/data/datasources/local/chicken_local.dart';
|
|
import 'package:rasadyar_chicken/data/di/chicken_di.dart';
|
|
=
|
|
import 'package:rasadyar_chicken/features/common/data/model/local/widely_used_local_model.dart';
|
|
import 'package:rasadyar_chicken/features/common/data/model/response/inventory/inventory_model.dart';
|
|
import 'package:rasadyar_chicken/features/common/data/model/response/iran_province_city/iran_province_city_model.dart';
|
|
import 'package:rasadyar_chicken/features/common/data/model/response/roles_products/roles_products.dart';
|
|
import 'package:rasadyar_chicken/features/steward/data/model/response/steward_remain_weight/steward_remain_weight.dart';
|
|
import 'package:rasadyar_chicken/features/steward/data/model/response/steward_sales_info_dashboard/steward_sales_info_dashboard.dart';
|
|
import 'package:rasadyar_chicken/features/steward/data/model/response/waiting_arrival/waiting_arrival.dart'
|
|
hide ProductModel;
|
|
import 'package:rasadyar_chicken/features/common/data/repositories/common/common_repository.dart';
|
|
import 'package:rasadyar_chicken/features/steward/data/repositories/steward_repository.dart';
|
|
import 'package:rasadyar_chicken/features/common/presentation/page/profile/view.dart';
|
|
import 'package:rasadyar_chicken/features/steward/presentation/pages/buy/view.dart';
|
|
import 'package:rasadyar_chicken/features/steward/presentation/pages/home/view.dart';
|
|
import 'package:rasadyar_chicken/features/steward/presentation/pages/sale/view.dart';
|
|
import 'package:rasadyar_chicken/features/steward/presentation/pages/segmentation/view.dart';
|
|
import 'package:rasadyar_chicken/features/steward/presentation/routes/routes.dart';
|
|
import 'package:rasadyar_chicken/presentation/routes/routes.dart';
|
|
import 'package:rasadyar_chicken/presentation/utils/nested_keys_utils.dart';
|
|
import 'package:rasadyar_chicken/presentation/utils/utils.dart';
|
|
import 'package:rasadyar_core/core.dart';
|
|
|
|
enum ErrorLocationType { serviceDisabled, permissionDenied, none }
|
|
|
|
class StewardRootLogic extends GetxController {
|
|
DateTime? _lastBackPressed;
|
|
RxInt currentPage = 2.obs;
|
|
List<Widget> pages = [
|
|
BuyPage(),
|
|
SalePage(),
|
|
HomePage(),
|
|
SegmentationPage(),
|
|
ProfilePage(),
|
|
];
|
|
|
|
final defaultRoutes = <int, String>{
|
|
=
|
|
0: StewardRoutes.buySteward,
|
|
1: StewardRoutes.saleSteward,
|
|
};
|
|
RxList<ProductModel> rolesProductsModel = RxList<ProductModel>();
|
|
Rxn<WidelyUsedLocalModel> widelyUsedList = Rxn<WidelyUsedLocalModel>();
|
|
Rxn<StewardSalesInfoDashboard> stewardSalesInfoDashboard =
|
|
Rxn<StewardSalesInfoDashboard>();
|
|
Rxn<StewardRemainWeight> stewardRemainWeight = Rxn<StewardRemainWeight>();
|
|
|
|
late DioRemote dioRemote;
|
|
var tokenService = Get.find<TokenStorageService>();
|
|
late CommonRepository commonRepository;
|
|
late StewardRepository stewardRepository;
|
|
late ChickenLocalDataSource localDatasource;
|
|
|
|
RxList<ErrorLocationType> errorLocationType = RxList();
|
|
RxMap<int, dynamic> inventoryExpandedList = RxMap();
|
|
Rxn<ProductModel> inventoryModel = Rxn<ProductModel>();
|
|
RxList<IranProvinceCityModel> provinces = <IranProvinceCityModel>[].obs;
|
|
|
|
// Cancel tokens for API calls
|
|
CancelToken? _inventoryCancelToken;
|
|
CancelToken? _provincesCancelToken;
|
|
|
|
@override
|
|
void onInit() {
|
|
super.onInit();
|
|
localDatasource = diChicken.get<ChickenLocalDataSource>();
|
|
commonRepository = diChicken.get<CommonRepository>();
|
|
stewardRepository = diChicken.get<StewardRepository>();
|
|
}
|
|
|
|
@override
|
|
void onReady() {
|
|
super.onReady();
|
|
|
|
if (provinces.isEmpty) {
|
|
getProvinces();
|
|
}
|
|
if (inventoryModel.value == null) {
|
|
getRolesProduct();
|
|
}
|
|
if (rolesProductsModel.isEmpty) {
|
|
getRolesProducts();
|
|
}
|
|
getStewardSaleDashboard();
|
|
getStewardRemainWeightData();
|
|
|
|
if (widelyUsedList.value?.hasInit != true) {
|
|
//TODO
|
|
localDatasource.initWidleyUsed().then(
|
|
(value) => localDatasource.getAllWidely(),
|
|
);
|
|
}
|
|
}
|
|
|
|
@override
|
|
void onClose() {
|
|
// Cancel any ongoing requests when controller is disposed
|
|
_inventoryCancelToken?.cancel();
|
|
_provincesCancelToken?.cancel();
|
|
super.onClose();
|
|
}
|
|
|
|
Future<void> onRefresh() async {
|
|
await Future.wait([
|
|
getRolesProduct(),
|
|
getRolesProducts(),
|
|
getStewardSaleDashboard(),
|
|
getStewardRemainWeightData(),
|
|
getProvinces(),
|
|
getStewardRemainWeightData(),
|
|
]);
|
|
}
|
|
|
|
void toggleExpanded(int index) {
|
|
if (inventoryExpandedList.keys.contains(index)) {
|
|
inventoryExpandedList.remove(index);
|
|
} else {
|
|
inventoryExpandedList[index] = false;
|
|
}
|
|
}
|
|
|
|
Future<void> getRolesProduct() async {
|
|
// Cancel previous request if still running
|
|
_inventoryCancelToken?.cancel();
|
|
_inventoryCancelToken = CancelToken();
|
|
|
|
=
|
|
await safeCall<List<InventoryModel>?>(
|
|
call: () async => await commonRepository.getInventory(
|
|
token: tokenService.accessToken.value!,
|
|
cancelToken: _inventoryCancelToken,
|
|
queryParameters: buildRawQueryParams(role: 'Steward'),
|
|
),
|
|
onSuccess: (result) {
|
|
if (result != null) {
|
|
inventoryModel.value = result.first;
|
|
}
|
|
},
|
|
onError: (error, stackTrace) {
|
|
if (error is DioException && error.type == DioExceptionType.cancel) {
|
|
// Request was cancelled, ignore the error
|
|
return;
|
|
}
|
|
},
|
|
);
|
|
}
|
|
|
|
void rootErrorHandler(DioException error) {
|
|
handleGeneric(error, () {
|
|
tokenService.deleteModuleTokens(Module.chicken);
|
|
});
|
|
}
|
|
|
|
void changePage(int index) {
|
|
currentPage.value = index;
|
|
}
|
|
|
|
Future<void> getProvinces() async {
|
|
// Cancel previous request if still running
|
|
_provincesCancelToken?.cancel();
|
|
_provincesCancelToken = CancelToken();
|
|
|
|
try {
|
|
=
|
|
final res = await commonRepository.getProvince(
|
|
cancelToken: _provincesCancelToken,
|
|
);
|
|
if (res != null) {
|
|
provinces.clear();
|
|
provinces.value = res;
|
|
}
|
|
} catch (e) {
|
|
if (e is DioException && e.type == DioExceptionType.cancel) {
|
|
// Request was cancelled, ignore the error
|
|
return;
|
|
}
|
|
provinces.clear();
|
|
}
|
|
}
|
|
|
|
Future<void> getRolesProducts() async {
|
|
safeCall(
|
|
=
|
|
call: () async => await commonRepository.getRolesProducts(
|
|
token: tokenService.accessToken.value!,
|
|
),
|
|
onSuccess: (result) {
|
|
if (result != null) {
|
|
rolesProductsModel.value = result;
|
|
}
|
|
},
|
|
onError: (error, stacktrace) {},
|
|
);
|
|
}
|
|
|
|
Future<void> getStewardSaleDashboard() async {
|
|
safeCall(
|
|
call: () async => await stewardRepository.getStewardSalesInfoDashboard(
|
|
token: tokenService.accessToken.value!,
|
|
queryParameters: buildRawQueryParams(role: 'Steward'),
|
|
),
|
|
onSuccess: (result) {
|
|
if (result != null) {
|
|
stewardSalesInfoDashboard.value = result;
|
|
}
|
|
},
|
|
onError: (error, stacktrace) {},
|
|
);
|
|
}
|
|
|
|
Future<void> getStewardRemainWeightData() async {
|
|
safeCall(
|
|
=
|
|
call: () async => await stewardRepository.getStewardRemainWeight(
|
|
token: tokenService.accessToken.value!,
|
|
),
|
|
onSuccess: (result) {
|
|
if (result != null) {
|
|
stewardRemainWeight.value = result;
|
|
}
|
|
},
|
|
onError: (error, stacktrace) {},
|
|
);
|
|
}
|
|
|
|
int getNestedKey() {
|
|
switch (currentPage.value) {
|
|
case 0:
|
|
return stewardFirstKey;
|
|
case 1:
|
|
return stewardSecondKey;
|
|
case 2:
|
|
return stewardThirdKey;
|
|
|
|
case 3:
|
|
return stewardFourthKey;
|
|
|
|
case 4:
|
|
return stewardFourthKey;
|
|
|
|
default:
|
|
return stewardThirdKey;
|
|
}
|
|
}
|
|
|
|
void onPopScopTaped() async {
|
|
final nestedKeyId = getNestedKey();
|
|
GlobalKey<NavigatorState>? currentNestedKey = Get.nestedKey(nestedKeyId);
|
|
|
|
if (currentNestedKey?.currentState?.canPop() == true) {
|
|
iLog(currentNestedKey?.currentState?.canPop());
|
|
iLog(currentNestedKey?.currentContext);
|
|
currentNestedKey?.currentState?.popUntil((route) => route.isFirst);
|
|
} else {
|
|
final now = DateTime.now();
|
|
if (_lastBackPressed == null ||
|
|
now.difference(_lastBackPressed!) > Duration(seconds: 2)) {
|
|
_lastBackPressed = now;
|
|
Get.snackbar(
|
|
'خروج از برنامه',
|
|
'برای خروج دوباره بازگشت را بزنید',
|
|
snackPosition: SnackPosition.TOP,
|
|
duration: Duration(seconds: 2),
|
|
backgroundColor: AppColor.warning,
|
|
);
|
|
} else {
|
|
await SystemNavigator.pop();
|
|
}
|
|
}
|
|
}
|
|
|
|
bool isKillHouse(WaitingArrivalModel model) =>
|
|
model.allocationType?.split("_")[0].toLowerCase() == "killhouse";
|
|
}
|