feat:解决微信支付异步回调里emitter(PaySuccessState())报错问题

吴启风
1 parent caec5687
Showing 3 changed files with 30 additions and 24 deletions
lib/common/request/dao/shop_dao.dart
lib/pages/shopping/bloc.dart
lib/pages/shopping/event.dart
@@ -8,20 +8,20 @@ class ShopDao {
   }
   ///创建订单
-  static Future createOrder(ProductEntity productEntity) async {
+  static Future<Map<String, dynamic>?> createOrder(ProductEntity productEntity) async {
     return await requestClient
-        .post<Map<String, dynamic>>(Apis.createOrder, data: {'courseComboId': productEntity.id});
+        .post<Map<String, dynamic>?>(Apis.createOrder, data: {'courseComboId': productEntity.id});
   }
   ///获取alipay支付订单信息
-  static Future getAliPayToken(String orderNo) async {
+  static Future<Map<String, dynamic>?> getAliPayToken(String orderNo) async {
     return await requestClient
-        .post<Map<String, dynamic>>(Apis.getAliPayToken, data: {'orderNo': orderNo});
+        .post<Map<String, dynamic>?>(Apis.getAliPayToken, data: {'orderNo': orderNo});
   }
   ///获取weixin支付订单信息
-  static Future getWxPayToken(String orderNo) async {
+  static Future<Map<String, dynamic>?> getWxPayToken(String orderNo) async {
     return await requestClient
-        .post<Map<String, dynamic>>(Apis.getWxPayToken, data: {'orderNo': orderNo});
+        .post<Map<String, dynamic>?>(Apis.getWxPayToken, data: {'orderNo': orderNo});
   }
 }
@@ -36,6 +36,9 @@ class ShoppingBloc extends Bloc&lt;ShoppingEvent, ShoppingState&gt; {
     on<InitEvent>(_init);
     on<ChangePaymentChannelEvent>(_changePaymentChannel);
     on<DoPayEvent>(_startPay);
+    on<WxPaySuccessEvent>((event, emit) {
+      emit(PaySuccessState());
+    });
   }
   void _init(InitEvent event, Emitter<ShoppingState> emit) async {
@@ -55,7 +58,6 @@ class ShoppingBloc extends Bloc&lt;ShoppingEvent, ShoppingState&gt; {
   void _startPay(DoPayEvent event,
       Emitter<ShoppingState> emitter) async {
-    Log.d("开始支付 ${event.productEntity} ${event.paymentChannel}");
     //如果event.productEntity为空，中断流程并toast提示
     if (event.productEntity == null) {
       showToast("商品信息为空");
@@ -64,29 +66,31 @@ class ShoppingBloc extends Bloc&lt;ShoppingEvent, ShoppingState&gt; {
     final productEntitySafely = event.productEntity!;
     try {
       await loading(() async {
-        final Map<String, dynamic> orderInfo = await ShopDao.createOrder(productEntitySafely);
-        Log.d("orderInfo $orderInfo");
-        final String? orderNo = orderInfo.getOrNull("orderNo");
+        final Map<String, dynamic>? orderInfo = await ShopDao.createOrder(productEntitySafely);
+        final String? orderNo = orderInfo?.getOrNull("orderNo");
         if (orderNo == null) {
           showToast("订单创建失败");
           return;
         }
-        Log.d("orderNo $orderNo");
         if (event.paymentChannel == PaymentChannel.wechatPay) {
           if (_isWxPayListenerInitialized == false) {
             _isWxPayListenerInitialized = true;
             fluwx = Fluwx();
-            fluwx?.registerApi(appId: "wx365e5a79956a450a",
+            await fluwx?.registerApi(appId: "wx365e5a79956a450a",
                 universalLink: "https://app-api.wowenglish.com.cn/app/");
             wxPayResponseListener = (WeChatResponse response) {
-              Log.d("wxPayResponseListener $response");
+              debugPrint("WqfPay wxPayResponseListener $response");
               if (response is WeChatPaymentResponse) {
                 if (response.errCode == 0) {
-                  Log.d("wxPayResponseListener response=${response.errCode}");
+                  debugPrint("WqfPay wxPayResponseListener response=${response.errCode}");
                   showToast("支付成功");
                   // Log.d("emitter isDone=${emitter.isDone}");
+
+                  /// 报错!_isCompleted  emit was called after an event handler completed normally
                   // emitter(PaySuccessState());
+
+                  add(WxPaySuccessEvent());
                 } else {
                   showToast("支付失败");
                 }
@@ -103,10 +107,8 @@ class ShoppingBloc extends Bloc&lt;ShoppingEvent, ShoppingState&gt; {
             return;
           }
-          final Map<String, dynamic> wxPayOrderInfo = await ShopDao.getWxPayToken(orderNo);
-          Log.d("wxPayOrderInfo=$wxPayOrderInfo type=${wxPayOrderInfo.runtimeType}");
-          final String? wxPayInfo = wxPayOrderInfo.getOrNull("appId");
-          if (wxPayInfo == null) {
+          final Map<String, dynamic>? wxPayOrderInfo = await ShopDao.getWxPayToken(orderNo);
+          if (wxPayOrderInfo == null) {
             showToast("微信订单创建失败");
             return;
           }
@@ -122,18 +124,18 @@ class ShoppingBloc extends Bloc&lt;ShoppingEvent, ShoppingState&gt; {
                 sign: wxPayOrderInfo['sign'].toString(),
               ));
         } else {
-          final Map<String, dynamic> aliPayOrderInfo = await ShopDao.getAliPayToken(orderNo);
-          Log.d("aliPayOrderInfo=$aliPayOrderInfo type=${aliPayOrderInfo.runtimeType}");
-          final String? aliPayInfo = aliPayOrderInfo.getOrNull("token");
+          final Map<String, dynamic>? aliPayOrderInfo = await ShopDao.getAliPayToken(orderNo);
+          debugPrint("aliPayOrderInfo=$aliPayOrderInfo type=${aliPayOrderInfo?.runtimeType}");
+          final String? aliPayInfo = aliPayOrderInfo?.getOrNull("token");
           if (aliPayInfo == null) {
             showToast("支付宝订单创建失败");
             return;
           }
-          Log.d("aliPayInfo=$aliPayInfo");
+          debugPrint("aliPayInfo=$aliPayInfo");
           ///打印aliPayOrderInfo的type
           Tobias tobias = Tobias();
           final Map aliPayResult = await tobias.pay(aliPayInfo);
-          Log.d("aliPayResult=$aliPayResult");
+          debugPrint("aliPayResult=$aliPayResult");
           // 判断resultStatus 为9000则代表支付成功
           if (aliPayResult.getOrNull("resultStatus") == "9000") {
             showToast("支付成功");
@@ -19,4 +19,8 @@ class DoPayEvent extends ShoppingEvent {
   final PaymentChannel paymentChannel;
   DoPayEvent(this.productEntity, this.paymentChannel);
-}
 \ No newline at end of file
+}
+
+// 微信由于是异步回调方式通知支付状态，在异步回调里emitter(PaySuccessState())时报错
+// !_isCompleted  emit was called after an event handler completed normally
+class WxPaySuccessEvent extends ShoppingEvent {}
 \ No newline at end of file