From aa60ef4afc1f2fb32ec156fd70cf70be96560653 Mon Sep 17 00:00:00 2001 From: Nick Zeng Date: Wed, 11 Feb 2026 10:11:00 +0800 Subject: [PATCH] update refund comsumer --- backend/app/Platform/RefundConsumer.php | 141 +++++++++++++++++++++--- 1 file changed, 125 insertions(+), 16 deletions(-) diff --git a/backend/app/Platform/RefundConsumer.php b/backend/app/Platform/RefundConsumer.php index 118c85e..86fc70d 100644 --- a/backend/app/Platform/RefundConsumer.php +++ b/backend/app/Platform/RefundConsumer.php @@ -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,25 +89,20 @@ 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); - } - - 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); + // 无父级退款，直接使用平台售后单的情况， 比如 Tmall + if(!$parse->hasParentRefund){ + goto PROCESS_REFUND_ITEMS; } + // 有父退款，且要处理退款子项的情况 + $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); + } + } }