会员升级

app/jobs/integral/IntegralJob.php

@@ -22,6 +22,7 @@ class IntegralJob extends BaseJobs
 
     public function dealOrderIntegral($order)
     {
+        Log::debug(date('Y-m-d H:i:s') . '开始处理' . $order['id'] . '积分');
         /** @var UserAwardIntegralServices $awardIntegralService */
         $awardIntegralService = app()->make(UserAwardIntegralServices::class);
         /** @var UserServices $userService */
@@ -86,9 +87,11 @@ class IntegralJob extends BaseJobs
                     $spread = $userService->getUserInfo($spread['spread_uid']);
                 }
                 $this->autoExtract($awardIntegralService->getPrice());
+                Log::debug(date('Y-m-d H:i:s') . '结束处理' . $order['id'] . '积分');
                 return true;
             } catch (\Throwable $e) {
                 Log::error('处理积分奖池失败,失败原因:' . $e->getMessage());
+                Log::debug(date('Y-m-d H:i:s') . '结束处理' . $order['id'] . '积分');
                 return false;
             }
         });

app/jobs/order/OrderJob.php

@@ -79,8 +79,6 @@ class OrderJob extends BaseJobs
             }
         }
 
-        IntegralJob::dispatchDo('dealOrderIntegral', [$order]);
-
         return true;
     }
 

app/listener/order/Delivery.php

@@ -12,6 +12,7 @@
 namespace app\listener\order;
 
 
+use app\jobs\integral\IntegralJob;
 use app\services\order\StoreOrderServices;
 use app\services\order\StoreOrderStatusServices;
 use crmeb\interfaces\ListenerInterface;
@@ -30,6 +31,7 @@ class Delivery implements ListenerInterface
         [$orderInfo, $storeName, $data, $type] = $event;
 		$orderInfo = is_object($orderInfo) ? $orderInfo->toArray() : $orderInfo;
         $storeName = substrUTf8($storeName, 20, 'UTF-8', '');
+        IntegralJob::dispatchDo('dealOrderIntegral', [$orderInfo]);
         switch ($type) {
             case 1://快递发货
                 //用户推送消息事件