update refund comsumer

2026-02-11 10:11:00 +08:00
parent 7d8204cdab
commit aa60ef4afc
1 changed files with 125 additions and 16 deletions
@@ -5,6 +5,7 @@ declare(strict_types=1);
 namespace App\Platform;

 use App\Entity\Parse\EntityParseFactory;
+use App\Entity\Parse\EntityParseInterface;
 use App\Utils\Log;
 use Hyperf\Amqp\Annotation\Consumer;
 use Hyperf\Amqp\Builder\QueueBuilder;
@@ -13,7 +14,9 @@ use Hyperf\Amqp\Result;
 use Hyperf\Amqp\Producer;
 use PhpAmqpLib\Message\AMQPMessage;
 use Hyperf\DbConnection\Db;
+use App\Model\Order;
 use App\Model\RefundItem;
+use Carbon\Carbon;
 use Exception;
 use Hyperf\Context\ApplicationContext;
 use Throwable;
@@ -70,6 +73,8 @@ class RefundConsumer extends ConsumerMessage
        try {
            $parse = EntityParseFactory::createFromMessage($message);

+            $this->parseValidate($parse);
+
            $meta = $data['meta'] ?? [];
            $metadata = [
                'company_id' => $meta['company_id'] ?? null,
@@ -84,24 +89,19 @@ class RefundConsumer extends ConsumerMessage
            $entity_map_result = $parse->entityMap($raw_data);
            $data_to_upsert = $entity_map_result->all();

-            if (empty($data_to_upsert)) {
-                dump('No data to process');
-                return Result::ACK;
+            // 退款信息为空且有父退款，直接返回 ACK
+
+            if (empty($data_to_upsert) && $parse->hasParentRefund) {
+                    dump('No data to process');
+                    return Result::ACK;
            }

-            dump("Processing " . count($data_to_upsert) . " refund(s) with batch upsert");
-
-            if (!method_exists($parse, 'formatRefundItemsFromRaw')) {
-                throw new Exception('formatRefundItemsFromRaw method must be implemented in ' . $parse::class);
+            // 无父级退款，直接使用平台售后单的情况， 比如 Tmall
+            if(!$parse->hasParentRefund){
+                goto PROCESS_REFUND_ITEMS;
            }

-            if (!method_exists($parse, 'getRefundStatusId')) {
-                throw new Exception('getRefundStatusId method must be implemented in ' . $parse::class);
-            }
-
-            if (!method_exists($parse, 'getRefundTypeId')) {
-                throw new Exception('getRefundTypeId method must be implemented in ' . $parse::class);
-            }
+            // 有父退款，且要处理退款子项的情况
            
            $refunds_data = $data_to_upsert;
            $unique_by = $parse->getUniqueBy();
@@ -131,6 +131,8 @@ class RefundConsumer extends ConsumerMessage

            dump("ID mapping: " . count($platform_refund_id_to_local_refund_id_map) . " refunds");

+            PROCESS_REFUND_ITEMS:
+
            // 3. 格式化退款子项（传入 ID 映射，使子项能获取正确的 refund_id）
            $items = $parse->formatRefundItemsFromRaw($raw_data, $platform_refund_id_to_local_refund_id_map);

@@ -140,7 +142,6 @@ class RefundConsumer extends ConsumerMessage
            Db::commit();

            return Result::ACK;
-
        } catch (Throwable $error) {
            Log::get()->error('Refund consumer processing failed', [
                'error' => $error->getMessage(),
@@ -246,6 +247,9 @@ class RefundConsumer extends ConsumerMessage
            return;
        }

+        // 在 upsert 之前，批量查询订单日期并填入 $items
+        $items = $this->fillOrderDates($items);
+
        dump("Upserting " . count($items) . " refund items");

        RefundItem::query()->upsert(
@@ -265,6 +269,8 @@ class RefundConsumer extends ConsumerMessage
                'platform_product_id',
                'quantity',
                'refund_amount',
+                'order_created_date',
+                'order_paid_date',
                'updated_date',
                'completed_date',
                'raw',
@@ -275,4 +281,107 @@ class RefundConsumer extends ConsumerMessage

        dump("Refund items processing completed");
    }
+
+    /**
+     * 根据退款子项的 store_id + platform_order_id 查询订单，
+     * 将 order_created_date 和 order_paid_date 填入 $items 数组
+     *
+     * 订单搜索范围：[退款 created_date - 3个月, 退款 created_date]
+     *
+     * @param array $items 退款子项数据数组
+     * @return array 填充了订单日期的退款子项数组
+     */
+    protected function fillOrderDates(array $items): array
+    {
+        // 收集需要查询的 store_id + platform_order_id 组合及对应的 created_date
+        $lookups = [];
+        foreach ($items as $item) {
+            $key = $item['store_id'] . ':' . $item['platform_order_id'];
+            if (!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)) {
+            return $items;
+        }
+
+        // 批量查询匹配订单的日期信息
+        $orderDatesMap = $this->queryOrderDates($lookups);
+
+        dump("Matched " . count($orderDatesMap) . " orders for " . count($lookups) . " refund item lookups");
+
+        // 将订单日期填入 $items 中对应的退款子项
+        foreach ($items as &$item) {
+            $key = $item['store_id'] . ':' . $item['platform_order_id'];
+            if (isset($orderDatesMap[$key])) {
+                $item['order_created_date'] = $orderDatesMap[$key]['order_created_date'];
+                $item['order_paid_date'] = $orderDatesMap[$key]['order_paid_date'];
+            }
+        }
+        unset($item);
+
+        return $items;
+    }
+
+    /**
+     * 根据 store_id + platform_order_id 批量查询订单的创建时间和付款时间
+     *
+     * 订单搜索范围：[退款 created_date - 3个月, 退款 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(3),
+                              $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;
+    }
+
+    protected function parseValidate(EntityParseInterface $parse): void
+    {
+        if (!method_exists($parse, 'hasParentRefund')) {
+            throw new Exception('hasParentRefund method must be implemented in ' . $parse::class);
+        }
+
+        if (!method_exists($parse, 'formatRefundItemsFromRaw')) {
+            throw new Exception('formatRefundItemsFromRaw method must be implemented in ' . $parse::class);
+        }
+
+        if (!method_exists($parse, 'getRefundStatusId')) {
+            throw new Exception('getRefundStatusId method must be implemented in ' . $parse::class);
+        }
+
+        if (!method_exists($parse, 'getRefundTypeId')) {
+            throw new Exception('getRefundTypeId method must be implemented in ' . $parse::class);
+        }
+    }
 }