update shopee refund parse

2026-02-11 10:52:01 +08:00
parent d0d72ca812
commit 066066b2ac
1 changed files with 130 additions and 38 deletions
@@ -8,6 +8,7 @@ use App\Constants\RefundStatus;
 use App\Constants\RefundType;
 use App\Platform\Shopee\Constants\ReturnStatus as ShopeeReturnStatus;
 use App\Model\Company;
+use App\Model\Order;
 use App\Model\Store;
 use App\Entity\Parse\EntityParse;
 use Carbon\Carbon;
@@ -22,6 +23,12 @@ use InvalidArgumentException;
 */
 class Refund extends EntityParse
 {
+    /**
+     * 缓存 entityMap 中查询到的订单日期映射，供 formatRefundItemsFromRaw 复用
+     * [store_id:platform_order_id => ['order_created_date' => ..., 'order_paid_date' => ...]]
+     */
+    protected array $orderDatesMap = [];
+
    /**
     * 公司作用域匹配
     *
@@ -82,44 +89,47 @@ class Refund extends EntityParse
     */
    public function entityMap(array $raw_data): LazyCollection
    {
-        return LazyCollection::make(function () use ($raw_data) {
-            $records = isset($raw_data[0]) ? $raw_data : [$raw_data];
-            $tz = $this->getStore()->getTimezoneString();
+        $records = isset($raw_data[0]) ? $raw_data : [$raw_data];
+        $tz = $this->getStore()->getTimezoneString();
+        $mapped = [];

-            foreach ($records as $record) {
-                $raw = \json_encode($record);
-                $refund_amount = (float) ($record['refund_amount'] ?? 0);
+        foreach ($records as $record) {
+            $raw = \json_encode($record);
+            $refund_amount = (float) ($record['refund_amount'] ?? 0);

-                yield [
-                    'company_id' => $this->getCompany()->id,
-                    'platform_id' => $this->getPlatform()->id,
-                    'store_id' => $this->getStore()->id,
-                    'order_id' => $record['t_order_id'] ?? null,
-                    'platform_order_id' => $record['order_sn'],
-                    'platform_refund_id' => $record['return_sn'],
-                    'refund_status_id' => $this->getRefundStatusId($record['status']),
-                    'refund_type_id' => $this->getRefundTypeId($record),
-                    'reason' => $record['text_reason'] ?? $record['reason'] ?? null,
-                    'refund_amount' => $refund_amount,
-                    'freight_refund' => 0,
-                    'refund_total' => $refund_amount,
-                    'currency' => $record['currency'] ?? 'USD',
-                    'buyer_user_id' => $record['user']['username'] ?? null,
-                    'order_created_date' => Carbon::createFromTimestamp($record['create_time'], $tz)->format('Y-m-d H:i:sP'),
-                    'order_paid_date' => Carbon::createFromTimestamp($record['create_time'], $tz)->format('Y-m-d H:i:sP'),
-                    'created_date' => Carbon::createFromTimestamp($record['create_time'], $tz)->format('Y-m-d H:i:sP'),
-                    'updated_date' => isset($record['update_time']) ? Carbon::createFromTimestamp($record['update_time'], $tz)->format('Y-m-d H:i:sP') : null,
-                    'completed_date' => ($record['status'] === 'CLOSED' || $record['status'] === 'ACCEPTED') && isset($record['update_time'])
-                        ? Carbon::createFromTimestamp($record['update_time'], $tz)->format('Y-m-d H:i:sP')
-                        : null,
-                    'raw' => $raw,
-                    'ext' => null,
-                    'hash' => \md5($raw),
-                    'created_at' => Carbon::now()->format('Y-m-d H:i:sP'),
-                    'updated_at' => Carbon::now()->format('Y-m-d H:i:sP'),
-                ];
-            }
-        });
+            $mapped[] = [
+                'company_id' => $this->getCompany()->id,
+                'platform_id' => $this->getPlatform()->id,
+                'store_id' => $this->getStore()->id,
+                'order_id' => $record['t_order_id'] ?? null,
+                'platform_order_id' => $record['order_sn'],
+                'platform_refund_id' => $record['return_sn'],
+                'refund_status_id' => $this->getRefundStatusId($record['status']),
+                'refund_type_id' => $this->getRefundTypeId($record),
+                'reason' => $record['text_reason'] ?? $record['reason'] ?? null,
+                'refund_amount' => $refund_amount,
+                'freight_refund' => 0,
+                'refund_total' => $refund_amount,
+                'currency' => $record['currency'] ?? 'USD',
+                'buyer_user_id' => $record['user']['username'] ?? null,
+                'order_created_date' => null,
+                'order_paid_date' => null,
+                'created_date' => Carbon::createFromTimestamp($record['create_time'], $tz)->format('Y-m-d H:i:sP'),
+                'updated_date' => isset($record['update_time']) ? Carbon::createFromTimestamp($record['update_time'], $tz)->format('Y-m-d H:i:sP') : null,
+                'completed_date' => ($record['status'] === 'CLOSED' || $record['status'] === 'ACCEPTED') && isset($record['update_time'])
+                    ? Carbon::createFromTimestamp($record['update_time'], $tz)->format('Y-m-d H:i:sP')
+                    : null,
+                'raw' => $raw,
+                'ext' => null,
+                'hash' => \md5($raw),
+                'created_at' => Carbon::now()->format('Y-m-d H:i:sP'),
+                'updated_at' => Carbon::now()->format('Y-m-d H:i:sP'),
+            ];
+        }
+
+        $mapped = $this->fillOrderDates($mapped);
+
+        return LazyCollection::make($mapped);
    }

    /**
@@ -148,6 +158,8 @@ class Refund extends EntityParse
            'freight_refund',
            'refund_total',
            'buyer_user_id',
+            'order_created_date',
+            'order_paid_date',
            'updated_date',
            'completed_date',
            'raw',
@@ -198,8 +210,8 @@ class Refund extends EntityParse
                    'platform_product_id' => strval($item['item_id']),
                    'quantity' => $item['amount'] ?? 0,
                    'refund_amount' => (float) ($item['refund_amount'] ?? 0),
-                    'order_created_date' => Carbon::createFromTimestamp($record['create_time'], $tz)->format('Y-m-d H:i:sP'),
-                    'order_paid_date' => Carbon::createFromTimestamp($record['create_time'], $tz)->format('Y-m-d H:i:sP'),
+                    'order_created_date' => $this->orderDatesMap[$this->getStore()->id . ':' . $record['order_sn']]['order_created_date'] ?? null,
+                    'order_paid_date' => $this->orderDatesMap[$this->getStore()->id . ':' . $record['order_sn']]['order_paid_date'] ?? null,
                    'created_date' => Carbon::createFromTimestamp($record['create_time'], $tz)->format('Y-m-d H:i:sP'),
                    'updated_date' => isset($record['update_time']) ? Carbon::createFromTimestamp($record['update_time'], $tz)->format('Y-m-d H:i:sP') : null,
                    'completed_date' => ($record['status'] === 'CLOSED' || $record['status'] === 'ACCEPTED') && isset($record['update_time'])
@@ -216,6 +228,86 @@ class Refund extends EntityParse
        return $items;
    }

+    /**
+     * 根据退款子项的 store_id + platform_order_id 查询订单，
+     * 将 order_created_date 和 order_paid_date 填入 $items 数组
+     *
+     * @param array $items 数据数组（refunds 或 refund_items）
+     * @return array 填充了订单日期的数组
+     */
+    protected function fillOrderDates(array $items): array
+    {
+        // 收集尚未缓存的 lookup 条件
+        $lookups = [];
+        foreach ($items as $item) {
+            $key = $item['store_id'] . ':' . $item['platform_order_id'];
+            if (!isset($this->orderDatesMap[$key]) && !isset($lookups[$key])) {
+                $lookups[$key] = [
+                    'store_id' => $item['store_id'],
+                    'platform_order_id' => $item['platform_order_id'],
+                    'created_date' => $item['created_date'],
+                ];
+            }
+        }
+
+        // 仅查询未缓存的部分
+        if (!empty($lookups)) {
+            $newDates = $this->queryOrderDates($lookups);
+            $this->orderDatesMap = array_merge($this->orderDatesMap, $newDates);
+            dump("Matched " . count($newDates) . " orders for " . count($lookups) . " refund item lookups");
+        }
+
+        foreach ($items as &$item) {
+            $key = $item['store_id'] . ':' . $item['platform_order_id'];
+            if (isset($this->orderDatesMap[$key])) {
+                $item['order_created_date'] = $this->orderDatesMap[$key]['order_created_date'];
+                $item['order_paid_date'] = $this->orderDatesMap[$key]['order_paid_date'];
+            }
+        }
+        unset($item);
+
+        return $items;
+    }
+
+    /**
+     * 根据 store_id + platform_order_id 批量查询订单的创建时间和付款时间
+     *
+     * shopee 平台订单周期长，搜索周期改为 4 个月
+     * 订单搜索范围：[退款 created_date - 4个月, 退款 created_date]
+     *
+     * @param array $lookups [key => ['store_id', 'platform_order_id', 'created_date']]
+     * @return array [store_id:platform_order_id => ['order_created_date' => ..., 'order_paid_date' => ...]]
+     */
+    protected function queryOrderDates(array $lookups): array
+    {
+        $orders = Order::query()
+            ->where(function ($query) use ($lookups) {
+                foreach ($lookups as $lookup) {
+                    $createdDate = Carbon::parse($lookup['created_date']);
+                    $query->orWhere(function ($q) use ($lookup, $createdDate) {
+                        $q->where('store_id', $lookup['store_id'])
+                          ->where('platform_order_id', $lookup['platform_order_id'])
+                          ->whereBetween('created_date', [
+                              $createdDate->copy()->subMonths(4),
+                              $createdDate,
+                          ]);
+                    });
+                }
+            })
+            ->get(['store_id', 'platform_order_id', 'created_date', 'paid_date']);
+
+        $map = [];
+        foreach ($orders as $order) {
+            $key = $order->store_id . ':' . $order->platform_order_id;
+            $map[$key] = [
+                'order_created_date' => $order->created_date,
+                'order_paid_date' => $order->paid_date,
+            ];
+        }
+
+        return $map;
+    }
+
    /**
     * 将 Shopee 退款状态映射为系统退款状态 ID
     *