feat(api): 更新测试控制器实现1688商品分类追溯功能

- 新增 UserAddressRepository 导入
- 移除原有的测试代码和注释掉的功能代码
- 实现1688商品分类层级追溯功能，包括商品详情查询、分类ID追溯和顶级分类保存
- 添加数据库操作用于将追溯到的顶级分类保存到 store_category 表并更新商品分类ID
- 增加分步骤执行逻辑，包括读取本地商品、查询1688商品详情、追溯分类层级和保存分类数据
- 优化代码结构，移除过时的支付和退款相关测试代码

app/controller/api/Test.php

@@ -5,6 +5,7 @@ namespace app\controller\api;
 use app\common\enum\CommonEnum;
 use app\common\repositories\merchant\order\OrderMerchantRepository;
 use app\common\repositories\shared\SharedProsperityRecommendConfigRepository;
+use app\common\repositories\user\UserAddressRepository;
 use app\common\repositories\user\UserRepository;
 use app\services\ThirdParty\AlibabaAgent\OrderService;
 use app\services\ThirdParty\AlibabaAgent\ProductService;
@@ -34,282 +35,216 @@ class Test
      */
     public function test()
     {
-
-        $json = [
-            'created_time' => '1775884033',
-            'data' => [
-                'app_id' => 'app_44108546-d27a-48ee-88c1-84b45b75114f',
-                'business_mode' => '00',
-                'created_time' => '20260411130713',
-                'description' => '',
-                'end_time' => '20260411130724',
-                'expend' => [
-                    'buyer_logon_id' => '131****9459',
-                    'cashPayAmt' => '298.00',
-                    'open_id' => '2088702188085230',
-                    'sub_open_id' => '2088702188085230',
-                ],
-                'fee_amt' => '1.13',
-                'id' => '002212026041113071210888906215589441536',
-                'order_no' => 'ALI177588403255323243_466',
-                'out_trans_id' => '2026041123001485231459472633',
-                'party_order_id' => '02232604114723298914940',
-                'pay_amt' => '298.00',
-                'pay_channel' => 'alipay_pub',
-                'real_amt' => '298.00',
-                'status' => 'succeeded',
-                'trans_response_add_info' => [
-                    'fund_bill_list' => [
-                        [
-                            'amount' => '298.00',
-                            'fund_channel' => 'ALIPAYACCOUNT',
-                        ],
-                    ],
-                ],
-            ],
-            'prod_mode' => 'true',
-            'sign' => 'fgbSc95NQDor1/jH3/L0G55l3XB7wl+sDt45Mtig/8eSvLIVo0uoyyD+jWaLkXV5xY2iAV3w8W4tiyVUcMQwVvwDIt9zQ44HTo05ng0e6CHCXLxFQbg/SHsjmK/3hin/2t6HkEjlitJYVikcPxMA0vnlR+lL/xMOYqNMDuq9oQQ=',
-            'id' => '002210888906265044500480',
-            'type' => 'HF',
-            'app_id' => 'app_44108546-d27a-48ee-88c1-84b45b75114f',
-            'object' => 'payment',
-        ];
-
-        /** @var OrderMerchantRepository $orderMerchantRepository */
-        $orderMerchantRepository = app()->make(OrderMerchantRepository::class);
-        $res = $orderMerchantRepository->doNotifyHF($json['data']);
-
-        dd($res);
-
-        die;
-
-        $orderService = new OrderService();
-        //
-        //
-        // $orderId = '3298535043727138963';
-        // $payRes = $orderService->prepareProtocolPay(['orderId'=>$orderId]);
-        // dd($payRes);
-
-        $cargoParamList = '{"offerId":"1045816431082","specId":"2fc39c573acfab640d10bcb1b533f041","quantity":1}';
-        $addressParam = '{"fullName":"测试","mobile":"17756507016","provinceText":"河北省","cityText":"廊坊市","areaText":"三河市","address":"兴远高科产业园23号楼2层210"}';
-
-
-        $cargoParamList = json_decode($cargoParamList,true);
-        $addressParam = json_decode($addressParam,true);
-        $flow = 'general';
-
-        $res = $orderService->previewOrder(['cargoParamList' => $cargoParamList, 'addressParam' => $addressParam,'flow'=>$flow]);
-        dd($res);
-
-
-
-
-
-        /** @var SharedProsperityRecommendConfigRepository $sharedProsperityRecommendConfigRepository */
-        $sharedProsperityRecommendConfigRepository = app()->make(SharedProsperityRecommendConfigRepository::class);
-        // 共富配置--获取最大的直推奖比例
-        $sharedProsperityRecommendConfigEntityByMaxRewardRatio = $sharedProsperityRecommendConfigRepository->getSharedProsperityRecommendConfigEntityByMaxRewardRatio();
-        // 共富配置--获取最大的分享奖比例
-        $sharedProsperityRecommendConfigEntityByMaxShareRewardRatio = $sharedProsperityRecommendConfigRepository->getSharedProsperityRecommendConfigEntityByMaxShareRatio();
-        // 利润 减去 顶格的直推奖，剩下的是PV值
-        $sharPveRate = bcadd($sharedProsperityRecommendConfigEntityByMaxRewardRatio->getRewardRatio(),$sharedProsperityRecommendConfigEntityByMaxShareRewardRatio->getShareRatio(), CommonEnum::DECIMAL_PLACES_OF_THE_AMOUNT);
-        $pvProportion = bcsub('1', bcdiv($sharPveRate, '100', 4), 2);
-
-        dd($pvProportion);
-
-        $orderShareUid = 6;
-        $ShareUser = Db::name('shared_prosperity_user')->where(["user_id" => $orderShareUid])->find();
-        if ($ShareUser) {
-            $rate = Db::name('shared_prosperity_recommend_config')->where(["level" => $ShareUser['partner_level']])->value("share_ratio");
-            $rate = $rate / 100;
-        }else{
-            // 计算 佣金
-            $user_group_share_rate = Db::name("system_config_value")->where(["config_key" => "user_group_share_rate"])->value("value");
-            $user_group_share_rate = json_decode($user_group_share_rate, true);
-            $user_group_share_rate = array_column($user_group_share_rate, 'rate', 'user_groub');
-
-            /** @var UserRepository $userRepository */
-            $userRepository = app()->make(UserRepository::class);
-            $userEntityByShareUserEntity = $userRepository->getUserEntityByUid($orderShareUid);
-            $userGroup = $userEntityByShareUserEntity->getUserGroup();
-            $rate = ($user_group_share_rate[$userGroup] ?? 0) / 100;
-        }
-
-
-        dd($rate);
-
-
-        die;
-        $data = [
-            'orderId' => '123', // 1688订单号，接口里
-            'orderEntryIds' => '123',// 1688子订单号，接口里
-            'disputeRequest' => 'refund', // 单选
-            'description' => '不想要了', // 填写的
-            'applyPayment' => '4.82', // 退款金额，接口里
-            'applyCarriage' => '0', // 运费金额，接口里
-            'applyReasonId' => '20006', // 退款原因，选的
-            'goodsStatus' => 'refundWaitBuyerReceive', // 货物状态，接口里
-            'refund_order_id' => 33 // 列表的refund_order_id
-        ];
-
-        $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']]);
+        // ============================================================
+        // 功能：从本地 store_product 表读取 is_alibaba=1 的商品
+        //       → 根据 spu_id（1688商品ID）查询1688商品详情
+        //       → 获取分类ID → 重复调用1688分类接口向上追溯
+        //       → 直到 parentIDs=[0]（顶级分类）
+        //       → 将顶级分类保存到 store_category 表（按 alibaba_cate_id 去重）
+        //       → 更新商品的 cate_id
+        // ============================================================
+        try {
+            /** @var ProductService $productService */
+            $productService = app()->make(ProductService::class);
+            $productService->setAccessToken('ce15fc70-b462-43bf-acc3-f87e43c858ba');
+
+            // ============================================================
+            // 第一步：从 store_product 表读取 is_alibaba=1 的商品
+            // ============================================================
+            echo "========== 第一步：读取本地1688商品列表 ==========\n";
+
+            $productList = Db::name('store_product')
+                ->where('is_alibaba', 1)
+                ->where('cate_id', 0)
+                ->where('is_del', 0)
+                ->field('product_id, store_name, spu_id, image, price, is_alibaba')
+                ->limit(50)
+                ->select()
+                ->toArray();
+
+            if (empty($productList)) {
+                echo "没有找到 is_alibaba=1 的商品\n";
+                die;
             }
 
-            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售后申请失败');
-        }
-
-        // $alibabaOrderId = '3300284931845138963';
-
-        // $orderService = new OrderService();
-        // $result = $orderService->getRefundReasonList(['orderId' => $alibabaOrderId]);
-
-// dd($result);
-
-        die;
-
-        // $id = $this->request->params(['pid'])['pid'];
-        $id = request()->params(['pid'])['pid'];
-        if (!$id) {
-            return app('json')->fail('参数不正确');
-        }
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-        dd(request());
-        $appid = 'wx9082e5ac2fdb513f';
-        $sessionKey =str_replace(' ','+', 'AIXeWyu4hRRg0EkD8Z23JA==');
-        $encryptedData=str_replace(' ','+','7OCmD5\/4xylVdxYswuTrA6TKzmXNkDymIpdyx9GZIBS+qCIcsBpUnJ5U5GXOTn0JvfQYic9e+0idCTP7QJyJkjjlGWNwwiE0\/WnhBvhAWYlo+Hkh+v3ioiSvqJ7zC4bEJ3GWDNyts5fEX\/u+tL25DySDuUoDoCJs6k+ThlVO5NiecPIcgnmfrLG6nV4Xh3y9H6p\/loj71LRJ47hywX9OQg==');
-        $iv =str_replace(' ','+', 'NbjIV0k1DyDWxU7JSSF44w==');
-        $pc = new WXBizDataCrypt($appid, $sessionKey);
-        $errCode = $pc->decryptData($encryptedData, $iv, $data );
-dd($errCode);
-        die;
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+            echo "共找到 " . count($productList) . " 个1688商品\n\n";
 
+            foreach ($productList as $i => $product) {
+                echo ($i + 1) . ". {$product['store_name']}\n";
+                echo "   本地商品ID: {$product['product_id']}\n";
+                echo "   1688商品ID(spu_id): {$product['spu_id']}\n";
+                echo "   价格: ¥{$product['price']}\n\n";
+            }
 
+            // ============================================================
+            // 第二步+第三步+第四步：遍历商品，查询详情 → 追溯分类层级 → 保存顶级分类
+            // ============================================================
+            echo "========== 第二步：查询1688商品详情，获取分类ID ==========\n\n";
 
+            foreach ($productList as $product) {
+                $spuId = $product['spu_id'];
+                $productId = $product['product_id'];
+                $storeName = $product['store_name'];
 
+                if (empty($spuId)) {
+                    echo "商品 {$productId} 的 spu_id 为空，跳过\n\n";
+                    continue;
+                }
 
-        die;
-        // ============================================================
-        // 通过 ProductService 调用 1688 分销商品列表
-        // ============================================================
-        try {
-            /** @var ProductService $productService */
-            $productService = app()->make(ProductService::class);
+                echo "--- 查询商品: {$storeName} (spu_id: {$spuId}) ---\n";
 
-            // 设置 access_token（由用户提供或通过OAuth获取）
-            $productService->setAccessToken('dc8eab20-f10f-4688-9e45-9ebfa182c7c2');
+                // ---- 第二步：获取商品详情，提取分类ID ----
+                $detail = $productService->getProductDetail($spuId);
 
-            // 搜索参数
-            $params = [
-                'page'     => 1,      // 页码
-                'limit'    => 50,     // 每页条数（最大50）
-            ];
+                if ($detail === false || empty($detail)) {
+                    echo "   获取1688商品详情失败\n\n";
+                    continue;
+                }
 
-            $result = $productService->searchProducts($params);
+                $categoryId = $detail['categoryId'] ?? 0;
+                $categoryName = $detail['categoryName'] ?? '';
+
+                echo "   商品标题: {$detail['title']}\n";
+                echo "   分类ID: {$categoryId}\n";
+                echo "   分类名称: {$categoryName}\n";
+                echo "   价格区间: ¥{$detail['minPrice']} ~ ¥{$detail['maxPrice']}\n\n";
+
+                // ---- 第三步：追溯完整分类层级（直到顶级分类） ----
+                echo "========== 第三步：追溯完整分类层级（直到顶级分类） ==========\n";
+
+                $categoryPath = []; // 从叶子到根的顺序存储
+                $categoryPathReversed = []; // 从根到叶子的顺序
+
+                if (!empty($categoryId)) {
+                    $currentCategoryId = $categoryId;
+                    $maxLevels = 10;
+                    $level = 0;
+
+                    while ($currentCategoryId > 0 && $level < $maxLevels) {
+                        $level++;
+                        echo "  第{$level}层: 查询分类ID [{$currentCategoryId}]...\n";
+
+                        $categoryInfoList = $productService->getCategories((string)$currentCategoryId);
+
+                        if ($categoryInfoList === false || empty($categoryInfoList)) {
+                            echo "   分类ID [{$currentCategoryId}] 查询失败或无数据，停止追溯\n";
+                            break;
+                        }
+
+                        // 查找与当前分类ID匹配的分类信息
+                        $currentCategoryInfo = null;
+                        foreach ($categoryInfoList as $cat) {
+                            if (($cat['categoryID'] ?? 0) == $currentCategoryId) {
+                                $currentCategoryInfo = $cat;
+                                break;
+                            }
+                        }
+
+                        if ($currentCategoryInfo === null) {
+                            $currentCategoryInfo = $categoryInfoList[0] ?? null;
+                        }
+
+                        if ($currentCategoryInfo === null) {
+                            echo "   无法获取分类信息，停止追溯\n";
+                            break;
+                        }
+
+                        $catId = $currentCategoryInfo['categoryID'] ?? 0;
+                        $catName = $currentCategoryInfo['name'] ?? '';
+                        $parentIDs = $currentCategoryInfo['parentIDs'] ?? [];
+                        $isLeaf = $currentCategoryInfo['isLeaf'] ?? false;
+
+                        $categoryPath[] = [
+                            'category_id'   => $catId,
+                            'category_name' => $catName,
+                            'is_leaf'       => $isLeaf,
+                            'parent_ids'    => $parentIDs,
+                        ];
+
+                        echo "   当前分类: [{$catId}] {$catName}, parentIDs: [" . implode(',', $parentIDs) . "], isLeaf: " . ($isLeaf ? '是' : '否') . "\n";
+
+                        if (empty($parentIDs) || in_array(0, $parentIDs, true) || in_array('0', $parentIDs, true)) {
+                            echo "   → 已到达顶级分类，追溯完成\n";
+                            break;
+                        }
+
+                        $currentCategoryId = (int)$parentIDs[0];
+                    }
+
+                    if ($level >= $maxLevels) {
+                        echo "   警告：达到最大追溯层数 {$maxLevels}，可能存在循环\n";
+                    }
+
+                    // 输出完整分类层级（从顶级到叶子）
+                    $categoryPathReversed = array_reverse($categoryPath);
+                    $pathStr = '';
+                    foreach ($categoryPathReversed as $i => $cat) {
+                        if ($i > 0) $pathStr .= ' → ';
+                        $pathStr .= "[{$cat['category_id']}] {$cat['category_name']}";
+                    }
+                    echo "\n   完整分类层级: {$pathStr}\n\n";
+
+                } else {
+                    echo "   分类ID为空，无法追溯分类层级\n\n";
+                }
 
-            if ($result === false) {
-                echo "请求失败，请查看日志获取详细信息。\n";
-            } else {
-                echo "=== 1688分销商品列表 ===\n";
-                echo "总数: {$result['total']}\n";
-                echo "页码: {$result['page']}\n";
-                echo "每页: {$result['pageSize']}\n";
-                echo "商品数: " . count($result['list']) . "\n\n";
-
-                foreach ($result['list'] as $i => $product) {
-                    echo ($i + 1) . ". {$product['title']}\n";
-                    echo "   商品ID: {$product['productId']}\n";
-                    echo "   价格: ¥{$product['minPrice']} ~ ¥{$product['maxPrice']}\n";
-                    echo "   月销: {$product['monthSales']}\n";
-                    echo "   主图: {$product['mainImage']}\n\n";
+                // ---- 第四步：将顶级分类保存到 store_category 表，并更新商品 cate_id ----
+                echo "========== 第四步：保存顶级分类到 store_category 表 ==========\n";
+
+                if (!empty($categoryPathReversed)) {
+                    $topCategory = $categoryPathReversed[0];
+                    $alibabaCateId = $topCategory['category_id'];
+                    $alibabaCateName = $topCategory['category_name'];
+
+                    echo "  顶级分类: [{$alibabaCateId}] {$alibabaCateName}\n";
+
+                    // 按 alibaba_cate_id 查重
+                    $existingCategory = Db::name('store_category')
+                        ->where('alibaba_cate_id', $alibabaCateId)
+                        ->find();
+
+                    if ($existingCategory) {
+                        $storeCategoryId = $existingCategory['store_category_id'];
+                        echo "  分类已存在 (store_category_id: {$storeCategoryId})，跳过创建\n";
+                    } else {
+                        $insertData = [
+                            'pid'             => 564,
+                            'cate_name'       => $alibabaCateName,
+                            'path'            => '',
+                            'sort'            => 0,
+                            'pic'             => '',
+                            'is_show'         => 1,
+                            'level'           => 2,
+                            'mer_id'          => 0,
+                            'create_time'     => date('Y-m-d H:i:s'),
+                            'alibaba_cate_id' => $alibabaCateId,
+                        ];
+
+                        $storeCategoryId = Db::name('store_category')->insertGetId($insertData);
+
+                        if ($storeCategoryId) {
+                            $path = '/563/564/';
+                            Db::name('store_category')
+                                ->where('store_category_id', $storeCategoryId)
+                                ->update(['path' => $path]);
+                            echo "  顶级分类创建成功! store_category_id: {$storeCategoryId}, path: {$path}\n";
+                        } else {
+                            echo "  顶级分类创建失败\n";
+                        }
+                    }
+
+                    // 更新商品 cate_id
+                    if (!empty($storeCategoryId)) {
+                        Db::name('store_product')
+                            ->where('product_id', $productId)
+                            ->update(['cate_id' => $storeCategoryId]);
+                        echo "  已更新商品(product_id: {$productId}) 的 cate_id 为 {$storeCategoryId}\n";
+                    }
+                } else {
+                    echo "  未找到顶级分类数据\n";
                 }
+
+                echo "\n";
             }
 
         } catch (\Throwable $e) {
@@ -325,7 +260,6 @@ dd($errCode);
 
 
 
-
         $sessionKey = request()->post(['sessionKey']);
         $encryptedData = request()->post(['encryptedData']);
         $iv = request()->post(['iv']);