goods_surprise_controller.dart 3.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126
  1. import 'dart:async';
  2. import 'package:flutter_smart_dialog/flutter_smart_dialog.dart';
  3. import 'package:injectable/injectable.dart';
  4. import 'package:get/get.dart';
  5. import 'package:keyboard/module/store/suprise/surprise_dialog.dart';
  6. import '../../../base/base_controller.dart';
  7. import '../../../data/bean/goods_info.dart';
  8. import '../../../data/repository/store_repository.dart';
  9. import '../../../utils/async_util.dart';
  10. import '../../../utils/error_handler.dart';
  11. import 'package:keyboard/utils/atmob_log.dart';
  12. // 这里控制两个弹窗的数据
  13. @injectable
  14. class GoodsSurpriseController extends BaseController {
  15. final tag = 'GoodsSurpriseController';
  16. static const int countdownTime = 10 * 60 * 100; // 10分钟(毫秒单位,10ms 为 1 计数)
  17. final RxInt timeLeft = countdownTime.obs; // 剩余时间(10ms 为单位)
  18. Timer? _timer;
  19. final StoreRepository storeRepository;
  20. CancelableFuture? _storeDataFuture;
  21. RxList<GoodsInfo> get goodsInfoList =>
  22. storeRepository.newDiscountGoodsInfoList;
  23. final Rxn<GoodsInfo> _firstAmount = Rxn<GoodsInfo>();
  24. GoodsInfo? get firstAmount => _firstAmount.value;
  25. final Rxn<GoodsInfo> _secondAmount = Rxn<GoodsInfo>();
  26. GoodsInfo? get secondAmount => _secondAmount.value;
  27. GoodsSurpriseController(this.storeRepository);
  28. @override
  29. void onInit() {
  30. startCountdown();
  31. if (goodsInfoList.isEmpty) {
  32. return;
  33. }
  34. if (goodsInfoList.length < 2) {
  35. AtmobLog.e(tag,"商品列表少于2个,无法处理");
  36. return;
  37. }
  38. // 第一个直接拿第一个
  39. _firstAmount.value = goodsInfoList.first;
  40. // 第二个找一个 code 不一样的
  41. _secondAmount.value = goodsInfoList.firstWhereOrNull(
  42. (item) => item.code != _firstAmount.value?.code,
  43. );
  44. // 打印
  45. print('qqq firstAmount: ${_firstAmount.value?.toJson()}');
  46. print('qqq secondAmount: ${_secondAmount.value?.toJson()}');
  47. if (_secondAmount.value == null) {
  48. // 如果没有找到不同的 code,默认取第二个
  49. _secondAmount.value = goodsInfoList[1];
  50. }
  51. super.onInit();
  52. }
  53. @override
  54. void onReady() {
  55. super.onReady();
  56. }
  57. void startCountdown() {
  58. _timer = Timer.periodic(const Duration(milliseconds: 10), (timer) {
  59. if (timeLeft.value > 0) {
  60. timeLeft.value--;
  61. } else {
  62. timer.cancel();
  63. SmartDialog.dismiss();
  64. }
  65. });
  66. }
  67. void onCountdownEnd() {
  68. SmartDialog.dismiss(tag: SurpriseDialog.tag);
  69. }
  70. @override
  71. void onClose() {
  72. _timer?.cancel();
  73. super.onClose();
  74. _storeDataFuture?.cancel();
  75. }
  76. Future<void> getItemRetention() async {
  77. storeRepository.getItemRetention();
  78. }
  79. void refreshStoreData() {
  80. _storeDataFuture?.cancel();
  81. _storeDataFuture = AsyncUtil.retryWithExponentialBackoff(
  82. () => _requestGoodsInfoList(),
  83. 4,
  84. );
  85. _storeDataFuture?.catchError((error) {
  86. ErrorHandler.toastError(error);
  87. });
  88. }
  89. Future<void> _requestGoodsInfoList() async {
  90. try {
  91. final response = await storeRepository.getItemRetention();
  92. if (response.firstAmount != null) {
  93. _firstAmount.value = response.firstAmount;
  94. print('firstAmount: ${response.firstAmount?.toJson()}');
  95. }
  96. if (response.secondAmount != null) {
  97. _secondAmount.value = response.secondAmount;
  98. print('secondAmount: ${response.secondAmount?.toJson()}');
  99. }
  100. } catch (e) {
  101. AtmobLog.e(tag, e.toString());
  102. }
  103. }
  104. }