From 17a1b57e7763982e26914280ff8fb722e96c2331 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=9D=8E=E9=9D=99?= <lym125@gmail.com>
Date: Tue, 1 Feb 2022 19:58:57 +0800
Subject: [PATCH] =?UTF-8?q?=E7=BB=93=E7=AE=97=E5=B7=B2=E6=94=B6=E8=B4=A7?=
 =?UTF-8?q?=E8=AE=A2=E5=8D=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../Commands/Dealer/OrderSettleCommand.php    | 120 ++++++++++++++++++
 1 file changed, 120 insertions(+)
 create mode 100644 app/Console/Commands/Dealer/OrderSettleCommand.php

diff --git a/app/Console/Commands/Dealer/OrderSettleCommand.php b/app/Console/Commands/Dealer/OrderSettleCommand.php
new file mode 100644
index 00000000..d59f817f
--- /dev/null
+++ b/app/Console/Commands/Dealer/OrderSettleCommand.php
@@ -0,0 +1,120 @@
+<?php
+
+namespace App\Console\Commands\Dealer;
+
+use App\Enums\DealerOrderSettleState;
+use App\Enums\DealerOrderStatus;
+use App\Models\DealerChannelSubsidyLog;
+use App\Models\DealerEarning;
+use App\Models\DealerManagerSalesLog;
+use App\Models\DealerManageSubsidyLog;
+use App\Models\DealerOrder;
+use App\Models\DealerPurchaseLog;
+use Illuminate\Console\Command;
+use Illuminate\Support\Facades\DB;
+use Throwable;
+
+class OrderSettleCommand extends Command
+{
+    /**
+     * The name and signature of the console command.
+     *
+     * @var string
+     */
+    protected $signature = 'dealer:order-settle';
+
+    /**
+     * The console command description.
+     *
+     * @var string
+     */
+    protected $description = '将可自动完成的订单标记为已完成';
+
+    /**
+     * Execute the console command.
+     *
+     * @return int
+     */
+    public function handle()
+    {
+        DealerOrder::where(
+            'status',
+            DealerOrderStatus::Completed
+        )->where(
+            'settle_state',
+            DealerOrderSettleState::Processed
+        )->whereNotNull('shippinged_time')->chunkById(200, function ($orders) {
+            foreach ($orders as $order) {
+                try {
+                    DB::beginTransaction();
+
+                    $this->handleDealerOrder($order);
+
+                    DB::commit();
+                } catch (Throwable $e) {
+                    DB::rollBack();
+
+                    report($e);
+                }
+            }
+        });
+
+        return 0;
+    }
+
+    /**
+     * 处理经销商订单
+     *
+     * @param \App\Models\DealerOrder $dealerOrder
+     * @return void
+     */
+    protected function handleDealerOrder(DealerOrder $dealerOrder)
+    {
+        $this->handleManagerSalesLogs($dealerOrder);
+
+        $this->handleManageSubsidyLogs($dealerOrder);
+
+        $this->handleChannelSubsidyLogs($dealerOrder);
+
+        $this->handlePurchaseLogs($dealerOrder);
+
+        // 将订单标记为已完成
+        $dealerOrder->forceFill([
+            'settle_state' => DealerOrderSettleState::Completed,
+        ])->save();
+    }
+
+    protected function handleManagerSalesLogs(DealerOrder $dealerOrder)
+    {
+        DealerManagerSalesLog::where('order_id', $dealerOrder->id)->update([
+            'order_completed_at' => $dealerOrder->shippinged_time,
+        ]);
+    }
+
+    protected function handleManageSubsidyLogs(DealerOrder $dealerOrder)
+    {
+        DealerManageSubsidyLog::where('order_id', $dealerOrder->id)->update([
+            'order_completed_at' => $dealerOrder->shippinged_time,
+        ]);
+    }
+
+    protected function handleChannelSubsidyLogs(DealerOrder $dealerOrder)
+    {
+        $channelSubsidyLogIds = DealerChannelSubsidyLog::where('order_id', $dealerOrder->id)->get('id')->toArray();
+
+        DealerChannelSubsidyLog::whereIn('id', $channelSubsidyLogIds)->update([
+            'order_completed_at' => $dealerOrder->shippinged_time,
+        ]);
+
+        DealerEarning::where('earningable_type', 'dealer_channel_subsidy_log')->whereIn('earningable_id', $channelSubsidyLogIds)->update([
+            'settle_at' => now(),
+        ]);
+    }
+
+    protected function handlePurchaseLogs(DealerOrder $dealerOrder)
+    {
+        DealerPurchaseLog::where('order_id', $dealerOrder->id)->update([
+            'order_completed_at' => $dealerOrder->shippinged_time,
+        ]);
+    }
+}