feat(refund): 添加1688订单售后功能

- 新增1688订单提交售后接口 refund/submitAli
- 实现168售后原因查询功能
- 集成1688退款状态变更通知处理
- 添加1688订单售后API服务方法
- 实现售后申请提交及状态同步逻辑
- 创建售后记录存储表结构支持

app/controller/admin/order/RefundOrder.php

@@ -90,6 +90,93 @@ class RefundOrder extends BaseController
         return app('json')->success($result);
     }
 
+    /**
+     * 提交1688售后申请
+     *
+     * 接收前端传入的1688售后参数，直接调用 alibaba.trade.createRefund 接口提交，
+     * 并将提交记录保存到 store_refund_alibaba 表
+     *
+     * @return \think\Response
+     */
+    public function submitAli()
+    {
+        $data = $this->request->params([
+            'orderId',
+            'orderEntryIds',
+            'disputeRequest',
+            'description',
+            'applyPayment',
+            'applyCarriage',
+            'applyReasonId',
+            'goodsStatus',
+            'refund_order_id',
+        ]);
+
+        // 参数校验（所有参数均为必填）
+        $requiredFields = ['orderId', 'orderEntryIds', 'disputeRequest', 'description', 'applyPayment', 'applyCarriage', 'applyReasonId', 'goodsStatus'];
+        foreach ($requiredFields as $field) {
+            if (empty($data[$field])) {
+                return app('json')->fail('缺少必填参数: ' . $field);
+            }
+        }
+
+        $orderService = new OrderService();
+
+        // 构建1688接口参数（前端 disputeRequest 映射为 1688 接口的 disputeReasonId）
+        $params = [
+            'orderId'         => (string)$data['orderId'],
+            'orderEntryIds'   => $data['orderEntryIds'],
+            'disputeReasonId' => (string)$data['disputeRequest'],
+            'description'     => (string)$data['description'],
+            'applyPayment'    => (string)$data['applyPayment'] * 100,
+            'applyCarriage'   => (string)$data['applyCarriage'] * 100,
+            'applyReasonId'   => (string)$data['applyReasonId'],
+            'goodsStatus'     => (string)$data['goodsStatus'],
+        ];
+
+        // 调用1688 API提交售后申请
+        $result = $orderService->createRefund($params);
+
+        // 记录到 store_refund_alibaba 表（不管成功与否都保存原始数据）
+        $insertData = [
+            'refund_order_id'   => (int)($data['refund_order_id'] ?? 0),
+            'alibaba_order_id'  => (string)$data['orderId'],
+            'order_entry_ids'   => $data['orderEntryIds'],
+            'dispute_reason_id' => (string)$data['disputeRequest'],
+            'description'       => (string)$data['description'],
+            'goods_status'      => (string)$data['goodsStatus'],
+            'apply_payment'     => (string)$data['applyPayment'],
+            'apply_carriage'    => (string)$data['applyCarriage'],
+            'result_data'       => json_encode($result['rawData'] ?? [], JSON_UNESCAPED_UNICODE),
+        ];
+
+        if ($result['success']) {
+            // 提交成功
+            $insertData['status'] = 1;
+            $insertData['alibaba_refund_id'] = $result['refundId'] ?? '';
+            $insertData['alibaba_status'] = $result['status'] ?? '';
+            Db::name('store_refund_alibaba')->insert($insertData);
+
+            // 更新退款单的 after_sn 字段为1688售后单ID
+            if (!empty($data['refund_order_id']) && !empty($result['refundId'])) {
+                Db::name('store_refund_order')
+                    ->where('refund_order_id', (int)$data['refund_order_id'])
+                    ->update(['after_sn' => $result['refundId']]);
+            }
+
+            return app('json')->success([
+                'alibaba_refund_id' => $result['refundId'] ?? '',
+                'alibaba_status'    => $result['status'] ?? '',
+            ], '提交1688售后申请成功');
+        } else {
+            // 提交失败
+            $insertData['status'] = 2;
+            $insertData['fail_message'] = $result['status'] ?? '1688接口调用失败';
+            Db::name('store_refund_alibaba')->insert($insertData);
+            return app('json')->fail($result['status'] ?? '提交1688售后申请失败');
+        }
+    }
+
     public function detail($id)
     {
         $data=$this->repository->getOne($id);

app/controller/api/AlibabaNotify.php

@@ -54,6 +54,9 @@ class AlibabaNotify
             switch ($type) {
                 case 'ORDER_BUYER_VIEW_ANNOUNCE_SENDGOODS':
                     return $this->handleOrderSendGoods($message);
+                case 'ORDER_BUYER_VIEW_ORDER_BUYER_REFUND_IN_SALES':
+                case 'ORDER_BUYER_VIEW_ORDER_REFUND_AFTER_SALES':
+                    return $this->handleRefundInSales($message);
                 default:
                     Log::channel('alibaba')->warning('[订阅消息通知] 未知消息类型, type:' . $type);
                     return response('success: unknown type');
@@ -167,4 +170,70 @@ class AlibabaNotify
 
         return response('success');
     }
+
+    /**
+     * 处理售中退款状态变更通知
+     *
+     * 订阅消息类型: ORDER_BUYER_VIEW_ORDER_BUYER_REFUND_IN_SALES
+     *
+     * 消息内容示例:
+     * {
+     *   "data": {
+     *     "buyerMemberId": "b2b-...",
+     *     "orderId": 111,
+     *     "currentStatus": "refundsuccess",
+     *     "refundAction": "SYSTEM_AGREE_REFUND_PROTOCOL",
+     *     "sellerMemberId": "b2b-...",
+     *     "msgSendTime": "2018-05-30 19:30:13",
+     *     "operator": "system",
+     *     "refundId": "1234556"
+     *   },
+     *   "gmtBorn": 1778296872365,
+     *   "msgId": 189206085626,
+     *   "type": "ORDER_BUYER_VIEW_ORDER_BUYER_REFUND_IN_SALES",
+     *   "userInfo": "b2b-..."
+     * }
+     *
+     * 处理流程:
+     * 1. 根据 data.refundId 查询 rrx_store_refund_alibaba 表
+     * 2. 更新 alibaba_status 为当前状态
+     *
+     * @param array $message 消息内容
+     * @return \think\Response
+     */
+    protected function handleRefundInSales(array $message)
+    {
+        $data = $message['data'] ?? [];
+        $refundId = $data['refundId'] ?? '';
+        $currentStatus = $data['currentStatus'] ?? '';
+        $orderId = $data['orderId'] ?? 0;
+
+        if (empty($refundId)) {
+            Log::channel('alibaba')->error('[退款通知] data.refundId为空, message:' . json_encode($message, JSON_UNESCAPED_UNICODE));
+            return response('fail: refundId is empty');
+        }
+
+        Log::channel('alibaba')->info('[退款通知] 开始处理, refundId:' . $refundId . ', orderId:' . $orderId . ', currentStatus:' . $currentStatus);
+
+        // 查询 rrx_store_refund_alibaba 表
+        $refundRecord = Db::name('store_refund_alibaba')
+            ->where('alibaba_refund_id', (string)$refundId)
+            ->find();
+
+        if (empty($refundRecord)) {
+            Log::channel('alibaba')->warning('[退款通知] 未找到匹配的退款记录, refundId:' . $refundId);
+            return response('success: refund record not found locally');
+        }
+
+        // 更新 alibaba_status
+        Db::name('store_refund_alibaba')
+            ->where('id', $refundRecord['id'])
+            ->update([
+                'alibaba_status' => $currentStatus,
+            ]);
+
+        Log::channel('alibaba')->info('[退款通知] 退款状态更新成功, id:' . $refundRecord['id'] . ', refundId:' . $refundId . ', status:' . $currentStatus);
+
+        return response('success');
+    }
 }

app/services/ThirdParty/AlibabaAgent/OrderService.php

@@ -674,4 +674,146 @@ class OrderService extends AlibabaAgentBaseService
             'reasons'       => $reasons,
         ];
     }
+
+    /**
+     * 提交售后申请
+     *
+     * API: com.alibaba.trade:alibaba.trade.createRefund-1
+     *
+     * 接口文档: https://open.1688.com/api/apidocdetail.htm?id=com.alibaba.trade%3Aalibaba.trade.createRefund-1
+     *
+     * 请求参数:
+     *   - orderId:        主订单ID（必填）
+     *   - orderEntryIds:  子订单ID列表，格式 "[123,456]"（必填）
+     *   - disputeReasonId: 退款原因ID（必填，从 getRefundReasonList 获取）
+     *   - description:    退款说明（必填）
+     *   - goodsStatus:    货物状态（必填）
+     *   - applyPayment:   退款金额，单位分（必填）
+     *   - applyCarriage:  退运费，单位分（可选，默认0）
+     *   - voucher:        凭证图片列表，格式 "[{url:'http://...'}]"（可选）
+     *   - applyReason:    退款原因描述（可选）
+     *
+     * 返回示例:
+     * {
+     *   "result": {
+     *     "result": {
+     *       "refundId": "RF123456",
+     *       "status": "refundWaitSellerSend"
+     *     },
+     *     "success": true
+     *   }
+     * }
+     *
+     * @param array $params 请求参数
+     * @return array|false
+     */
+    public function createRefund(array $params = [])
+    {
+        // --- 参数校验 ---
+        $requiredFields = ['orderId', 'orderEntryIds', 'disputeReasonId', 'description', 'goodsStatus', 'applyPayment', 'applyCarriage', 'applyReasonId'];
+        foreach ($requiredFields as $field) {
+            if (!isset($params[$field])) {
+                Log::channel('alibaba')->error('[提交售后申请] 缺少必填参数: ' . $field);
+                return [
+                    'success'  => false,
+                    'refundId' => '',
+                    'status'   => 'param_missing',
+                    'rawData'  => ['error' => '缺少必填参数: ' . $field],
+                ];
+            }
+        }
+
+        $businessParams = [
+            'orderId'         => (string)$params['orderId'],
+            'orderEntryIds'   => $params['orderEntryIds'],
+            'disputeRequest'  => (string)$params['disputeReasonId'],
+            'applyPayment'    => (string)$params['applyPayment'],
+            'applyCarriage'   => (string)$params['applyCarriage'],
+            'applyReasonId'   => (string)$params['applyReasonId'],
+            'description'     => (string)$params['description'],
+            'goodsStatus'     => (string)$params['goodsStatus'],
+        ];
+
+        // 可选参数
+        if (!empty($params['voucher'])) {
+            $businessParams['voucher'] = $params['voucher'];
+        }
+
+        Log::channel('alibaba')->info('[提交售后申请] 准备请求, params:' . json_encode($businessParams, JSON_UNESCAPED_UNICODE));
+
+        // --- 调用API ---
+        $result = $this->executeParam2(
+            self::NAMESPACE,
+            'alibaba.trade.createRefund',
+            1,
+            $businessParams
+        );
+
+        // 不管API调用是否成功，都返回格式化的结果（包含原始数据）
+        if ($result === false) {
+            Log::channel('alibaba')->error('[提交售后申请] API请求失败, params:' . json_encode($businessParams, JSON_UNESCAPED_UNICODE));
+            return [
+                'success'  => false,
+                'refundId' => '',
+                'status'   => 'api_failed',
+                'rawData'  => ['error' => 'API请求失败'],
+            ];
+        }
+
+        Log::channel('alibaba')->info('[提交售后申请] API请求成功, result:' . json_encode($result, JSON_UNESCAPED_UNICODE));
+
+        return $this->formatCreateRefundResult($result);
+    }
+
+    /**
+     * 格式化提交售后申请返回结果
+     *
+     * 成功返回数据结构:
+     * {
+     *   "result": {
+     *     "result": {
+     *       "refundId": "RF123456",
+     *       "status": "refundWaitSellerSend"
+     *     },
+     *     "success": true
+     *   }
+     * }
+     *
+     * 失败返回数据结构:
+     * {
+     *   "result": {
+     *     "code": "5000",
+     *     "message": "错误描述",
+     *     "success": false
+     *   }
+     * }
+     *
+     * @param array $result API原始返回数据
+     * @return array
+     */
+    protected function formatCreateRefundResult(array $result): array
+    {
+        // 检查 result 层是否存在
+        $resultData = $result['result'] ?? $result;
+        $success = $resultData['success'] ?? false;
+
+        if ($success) {
+            // 成功：result.result 中包含 refundId 和 status
+            $refundResult = $resultData['result'] ?? [];
+            return [
+                'success'  => true,
+                'refundId' => $refundResult['refundId'] ?? '',
+                'status'   => $refundResult['status'] ?? '',
+                'rawData'  => $result,
+            ];
+        }
+
+        // 失败：result 中包含 code 和 message
+        return [
+            'success'  => false,
+            'refundId' => '',
+            'status'   => $resultData['message'] ?? ($resultData['code'] ?? 'api_error'),
+            'rawData'  => $result,
+        ];
+    }
 }

route/admin.php

@@ -1004,8 +1004,10 @@ Route::group(config('admin.api_admin_prefix') . '/', function () {
             Route::get('refund/express/:id', 'RefundOrder/express')->name('systemStoreRefundExpress');//查询用户退货物流
 
 
-            // 1688订单售后
+            // 1688订单售后原因
             Route::get('refundReasonList','RefundOrder/refundReasonList');
+            // 1688订单提交售后
+            Route::post('refund/submitAli', 'RefundOrder/submitAli')->name('systemStoreRefundOrderSubmitAli');
 
             Route::get('dhm_list/lst', 'RefundOrder/dhm_list')->name('systemRefundOrderDhmLst');
             Route::get('dhm_status', 'RefundOrder/dhm_status')->name('systemRefundOrderDhmStatus');