Quellcode durchsuchen

更改投递地方

tgz vor 2 Jahren
Ursprung
Commit
d769a7b381
1 geänderte Dateien mit 7 neuen und 3 gelöschten Zeilen
  1. 7 3
      app/Modules/Trade/Pay/OrderPaySuccess.php

+ 7 - 3
app/Modules/Trade/Pay/OrderPaySuccess.php

@@ -27,6 +27,13 @@ class OrderPaySuccess
         if ($order) {
             if ($order->status == 'PAID') {
                 myLog('pay_notify')->info('has_pay:' . $trade_no);
+                try {
+                    //添加异步任务队列
+                    $job = new QappOrder($trade_no);
+                    dispatch($job->onConnection('redis')->onQueue('qapp_order_pay_success'));
+                } catch (Exception $e) {
+                    sendNotice($e->getMessage());
+                }
                 return true;
             }
             if ($order->order_type == 'YEAR') {
@@ -48,9 +55,6 @@ class OrderPaySuccess
             }
             self::freeBookStats($order->from_bid,$order->price,$order->uid);
 
-            //添加异步任务队列
-            $job = new QappOrder($trade_no);
-            dispatch($job->onConnection('redis')->onQueue('qapp_order_pay_success'));
             return $status;
         } else {
             return false;