From e8ad2bd1354254dcabc90672739b5d2c1b8d0be5 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=9D=8E=E9=9D=99?= <lym125@gmail.com>
Date: Fri, 7 Jan 2022 21:56:45 +0800
Subject: [PATCH] Update

---
 .../Distribution/PreIncomeJobCommand.php      | 44 ++++++++++---------
 1 file changed, 24 insertions(+), 20 deletions(-)

diff --git a/app/Console/Commands/Distribution/PreIncomeJobCommand.php b/app/Console/Commands/Distribution/PreIncomeJobCommand.php
index 2f6e3748..cc8939c4 100644
--- a/app/Console/Commands/Distribution/PreIncomeJobCommand.php
+++ b/app/Console/Commands/Distribution/PreIncomeJobCommand.php
@@ -35,24 +35,25 @@ class PreIncomeJobCommand extends Command
      */
     public function handle(DistributionPreIncomeJobService $jobService)
     {
-        DistributionPreIncomeJob::with('jobable')->pending()->chunkById(200, function ($jobs) use ($jobService) {
-            foreach ($jobs as $job) {
-                try {
-                    DB::beginTransaction();
+        while (true) {
+            DistributionPreIncomeJob::with('jobable')->pending()->chunkById(200, function ($jobs) use ($jobService) {
+                foreach ($jobs as $job) {
+                    try {
+                        DB::beginTransaction();
 
-                    $jobService->run($job);
+                        $jobService->run($job);
 
-                    DB::commit();
-                } catch (Throwable $e) {
-                    DB::rollBack();
+                        DB::commit();
+                    } catch (Throwable $e) {
+                        DB::rollBack();
 
-                    report($e);
-                }
+                        report($e);
+                    }
 
-                //发送商家端预收益进帐消息
-                try {
-                    DB::beginTransaction();
-                    switch (get_class($job->jobable)) {
+                    //发送商家端预收益进帐消息
+                    try {
+                        DB::beginTransaction();
+                        switch (get_class($job->jobable)) {
                         case Order::class://如果是订单类型，则发送预收益消息
                             $order = $job->jobable;
                             $incomesLogs = DistributionPreIncome::where('order_id', $order->id)->get();
@@ -66,13 +67,16 @@ class PreIncomeJobCommand extends Command
                         default:
                             break;
                     }
-                    DB::commit();
-                } catch (Throwable $e) {
-                    DB::rollBack();
+                        DB::commit();
+                    } catch (Throwable $e) {
+                        DB::rollBack();
 
-                    report($e);
+                        report($e);
+                    }
                 }
-            }
-        });
+            });
+
+            sleep(5);
+        }
     }
 }