refactor(command): 重构1688商品导入命令的原价和分润更新逻辑

- 引入 ProductRepository 依赖进行统一的数据更新操作
- 新增 updateProductData 方法封装完整的商品数据组装和更新流程
- 将原有的直接数据库操作改为通过仓库模式进行更新
- 移除硬编码的分润设置逻辑，统一在仓库层处理
- 更新控制台输出信息，反映新的更新状态
- 优化注释文档，明确方法职责和参数说明
- 调整价格阶梯计算逻辑，确保原价和分润设置准确无误

app/command/AlibabaTodayImport.php

@@ -2,6 +2,7 @@
 
 namespace app\command;
 
+use app\common\repositories\store\product\ProductRepository;
 use app\services\ThirdParty\AlibabaAgent\ProductService;
 use think\console\Command;
 use think\console\Input;
@@ -12,7 +13,8 @@ use think\facade\Db;
  * 今日1688商品自动入库命令
  *
  * 从 alibaba_import_goods 表中获取今日创建的商品，
- * 调用 ProductService::importToStoreProduct() 进行正式入库到 store_product 表
+ * 调用 ProductService::importToStoreProduct() 进行正式入库到 store_product 表，
+ * 然后通过 ProductRepository::update() 更新原价和分润设置
  *
  * 用法:
  *   php think alibaba:today-import                                          # 默认今天，mer_id=3447
@@ -29,7 +31,6 @@ use think\facade\Db;
  *   - extension_type: 1（开启分润）
  *   - concession_pri: 售价 × 15%（商家让利金额）
  *   - extension_one: 15（SKU级分润比例）
- *   - plate_mer_profit: 0（平台商户利润）
  *   - commission: 保持原样（不修改）
  *
  * 原价计算规则（根据SKU售价阶梯加价）:
@@ -37,7 +38,7 @@ use think\facade\Db;
  *   21-50元   => 固定加20元
  *   51-120元  => 固定加40元
  *   121-200元 => 固定加45元
- *   201-300元 => 固定加50元
+ *   201元以上 => 固定加50元
  */
 class AlibabaTodayImport extends Command
 {
@@ -153,81 +154,13 @@ class AlibabaTodayImport extends Command
                         $productId = $result['product_id'];
                         $globalSuccess++;
 
-                        // 4b. 根据SKU售价阶梯计算原价（ot_price）
+                        // 4b. 组装数据，调用 ProductRepository::update() 更新原价和分润
                         try {
-                            // 获取所有SKU的售价（用 unique 字段唯一标识每个SKU）
-                            $skuValues = Db::name('store_product_attr_value')
-                                ->where('product_id', $productId)
-                                ->field('unique, price')
-                                ->select()
-                                ->toArray();
-
-                            $skuPrices = [];
-                            $skuOtPrices = [];
-                            foreach ($skuValues as $sku) {
-                                $salePrice = (float)$sku['price'];
-                                $skuPrices[] = $salePrice;
-
-                                // 根据售价区间计算原价
-                                $otPrice = self::calcOtPrice($salePrice);
-                                $skuOtPrices[] = $otPrice;
-
-                                // 通过 unique 字段更新当前SKU的 ot_price
-                                Db::name('store_product_attr_value')
-                                    ->where('unique', $sku['unique'])
-                                    ->update(['ot_price' => $otPrice]);
-                            }
-
-                            // 更新 store_product 表的 price（最低售价）和 ot_price（最高原价）
-                            $minPrice = !empty($skuPrices) ? min($skuPrices) : 0;
-                            $maxOtPrice = !empty($skuOtPrices) ? max($skuOtPrices) : 0;
-                            Db::name('store_product')
-                                ->where('product_id', $productId)
-                                ->update([
-                                    'price'    => $minPrice,
-                                    'ot_price' => $maxOtPrice,
-                                ]);
-
-                            $output->write("<info>[原价已计算]</info> ");
-                        } catch (\Throwable $priceE) {
-                            $output->write("<comment>[原价计算失败: {$priceE->getMessage()}]</comment> ");
-                        }
-
-                        // 4c. 设置分润（写死15%）
-                        try {
-                            // 获取商品最低售价
-                            $storeProduct = Db::name('store_product')
-                                ->where('product_id', $productId)
-                                ->field('price')
-                                ->find();
-
-                            $salePrice = $storeProduct ? (float)$storeProduct['price'] : 0;
-
-                            // 计算 concession_pri = 售价 × 15%，使用 bc 函数保留两位小数
-                            $concessionPri = '0.00';
-                            if ($salePrice > 0) {
-                                $concessionPri = bcmul((string)$salePrice, (string)$profitConfig['concession_rate'], 2);
-                            }
-
-                            // 更新 store_product 表的分润字段（commission保持原样不修改）
-                            Db::name('store_product')
-                                ->where('product_id', $productId)
-                                ->update([
-                                    'extension_type' => $profitConfig['extension_type'],
-                                    'concession_pri' => $concessionPri,
-                                ]);
-
-                            // 更新 store_product_attr_value 表的 SKU 分润比例
-                            Db::name('store_product_attr_value')
-                                ->where('product_id', $productId)
-                                ->update([
-                                    'extension_one' => $profitConfig['extension_one'],
-                                ]);
-
+                            self::updateProductData($productId, $merId, $profitConfig);
                             $globalProfitSet++;
-                            $output->write("<info>[分润15%已设置]</info> ");
-                        } catch (\Throwable $profitE) {
-                            $output->write("<comment>[分润设置失败: {$profitE->getMessage()}]</comment> ");
+                            $output->write("<info>[原价+分润已更新]</info> ");
+                        } catch (\Throwable $updateE) {
+                            $output->write("<comment>[更新失败: {$updateE->getMessage()}]</comment> ");
                         }
 
                         $output->writeln("<info>成功 => product_id={$productId}</info>");
@@ -246,7 +179,7 @@ class AlibabaTodayImport extends Command
             // 每批结束后输出当前进度和耗时
             $batchElapsed = time() - $batchStartTime;
             $totalElapsed = time() - $startTime;
-            $output->writeln("  本批耗时: {$batchElapsed}s | 累计耗时: {$totalElapsed}s | 累计成功: {$globalSuccess} | 累计失败: {$globalFail} | 分润设置: {$globalProfitSet}");
+            $output->writeln("  本批耗时: {$batchElapsed}s | 累计耗时: {$totalElapsed}s | 累计成功: {$globalSuccess} | 累计失败: {$globalFail} | 更新: {$globalProfitSet}");
             $output->writeln('');
 
             // 每批之间短暂休眠，避免数据库压力过大
@@ -266,7 +199,7 @@ class AlibabaTodayImport extends Command
         $output->writeln("总处理:         {$total} 条");
         $output->writeln("成功:           {$globalSuccess} 条");
         $output->writeln("失败:           {$globalFail} 条");
-        $output->writeln("已设置分润15%:  {$globalProfitSet} 条");
+        $output->writeln("已更新原价+分润: {$globalProfitSet} 条");
 
         if ($globalFail > 0) {
             $output->writeln('');
@@ -280,6 +213,169 @@ class AlibabaTodayImport extends Command
     }
 
     /**
+     * 组装数据并调用 ProductRepository::update() 更新商品
+     *
+     * 从数据库查询商品完整信息，组装成 update 接口所需的格式，
+     * 修改 ot_price（按阶梯计算）和 extension_one（15），
+     * 然后调用 ProductRepository::update() 执行更新。
+     *
+     * @param int   $productId
+     * @param int   $merId
+     * @param array $profitConfig
+     * @throws \Throwable
+     */
+    protected static function updateProductData(int $productId, int $merId, array $profitConfig): void
+    {
+        // 1. 查询 store_product 表获取商品基本信息
+        $product = Db::name('store_product')
+            ->where('product_id', $productId)
+            ->find();
+
+        if (!$product) {
+            throw new \RuntimeException("商品不存在 product_id={$productId}");
+        }
+
+        // 2. 查询 store_product_attr_value 表获取所有SKU
+        $skuValues = Db::name('store_product_attr_value')
+            ->where('product_id', $productId)
+            ->select()
+            ->toArray();
+
+        if (empty($skuValues)) {
+            throw new \RuntimeException("商品SKU数据为空 product_id={$productId}");
+        }
+
+        // 3. 查询 store_product_attr 表获取规格属性
+        $attrList = Db::name('store_product_attr')
+            ->where('product_id', $productId)
+            ->select()
+            ->toArray();
+
+        // 4. 查询 store_product_content 表获取商品详情
+        $content = Db::name('store_product_content')
+            ->where('product_id', $productId)
+            ->value('content');
+
+        // 5. 组装 attrValue 数据（参考 detail 接口返回格式）
+        $attrValue = [];
+        $skuPrices = [];
+        foreach ($skuValues as $sku) {
+            $salePrice = (float)$sku['price'];
+            $skuPrices[] = $salePrice;
+
+            // 根据售价区间计算原价
+            $otPrice = self::calcOtPrice($salePrice);
+
+            // detail 字段（规格明细）
+            $detail = [];
+            if (!empty($sku['detail'])) {
+                $detail = is_string($sku['detail']) ? json_decode($sku['detail'], true) : $sku['detail'];
+            }
+
+            $attrValue[] = [
+                'product_id'       => $productId,
+                'detail'           => $detail,
+                'sku'              => $sku['sku'] ?? '',
+                'stock'            => $sku['stock'] ?? 0,
+                'sales'            => $sku['sales'] ?? 0,
+                'image'            => $sku['image'] ?? '',
+                'bar_code'         => $sku['bar_code'] ?? '',
+                'cost'             => (string)($sku['cost'] ?? 0),
+                'ot_price'         => (string)$otPrice,
+                'price'            => (string)($sku['price'] ?? 0),
+                'volume'           => (string)($sku['volume'] ?? 0),
+                'weight'           => (string)($sku['weight'] ?? 0),
+                'type'             => $sku['type'] ?? 0,
+                'extension_one'    => (string)$profitConfig['extension_one'],
+                'extension_two'    => $sku['extension_two'] ?? null,
+                'unique'           => $sku['unique'] ?? '',
+                'dacang_price'     => (string)($sku['dacang_price'] ?? 0),
+                'cost_price'       => $sku['cost_price'] ?? null,
+                'gong_sku_id'      => $sku['gong_sku_id'] ?? null,
+                'gong_mer_profit'  => (string)($sku['gong_mer_profit'] ?? 0),
+                'gong_pension'     => $sku['gong_pension'] ?? null,
+                'gong_market_price'=> (string)($sku['gong_market_price'] ?? 0),
+                'plate_mer_profit' => (string)($sku['plate_mer_profit'] ?? 0),
+                'pension_num'      => (string)($sku['pension_num'] ?? 0),
+                'share_num'        => (string)($sku['share_num'] ?? 0),
+                'stock_num'        => (string)($sku['stock_num'] ?? 0),
+                'shares_num'       => (string)($sku['shares_num'] ?? 0),
+                'is_usable'        => $sku['is_usable'] ?? 0,
+                'sku_id'           => $sku['sku_id'] ?? '',
+                'spec_id'          => $sku['spec_id'] ?? '',
+                'value0'           => $sku['value0'] ?? ($sku['sku'] ?? ''),
+                'dacang_cost_price'=> (string)($sku['dacang_cost_price'] ?? 0),
+                'no_dacang_cost_price'=> (string)($sku['no_dacang_cost_price'] ?? 0),
+            ];
+        }
+
+        // 6. 组装 attr 数据（规格属性）
+        $attr = [];
+        foreach ($attrList as $attrItem) {
+            $detail = !empty($attrItem['attr_values'])
+                ? explode('-!-', $attrItem['attr_values'])
+                : [];
+            $attr[] = [
+                'value'  => $attrItem['attr_name'],
+                'detail' => $detail,
+            ];
+        }
+
+        // 7. 计算商品级价格
+        $minPrice = !empty($skuPrices) ? min($skuPrices) : 0;
+        $maxOtPrice = self::calcOtPrice($minPrice);
+        // 取所有SKU中最大的ot_price
+        foreach ($skuPrices as $p) {
+            $ot = self::calcOtPrice($p);
+            if ($ot > $maxOtPrice) {
+                $maxOtPrice = $ot;
+            }
+        }
+
+        // 8. 组装完整数据（参考 detail 接口返回 + update 接口所需字段）
+        $sliderImages = !empty($product['slider_image'])
+            ? (is_string($product['slider_image']) ? explode(',', $product['slider_image']) : $product['slider_image'])
+            : [];
+
+        $updateData = [
+            'volunteer'       => $product['volunteer'] ?? 0,
+            'image'           => $product['image'] ?? '',
+            'slider_image'    => $sliderImages,
+            'store_name'      => $product['store_name'] ?? '',
+            'store_info'      => $product['store_info'] ?? '',
+            'keyword'         => $product['keyword'] ?? '',
+            'brand_id'        => $product['brand_id'] ?? null,
+            'cate_id'         => $product['cate_id'] ?? 0,
+            'mer_cate_id'     => [], // 商户分类，保持空数组
+            'unit_name'       => $product['unit_name'] ?? '件',
+            'sort'            => $product['sort'] ?? 0,
+            'is_good'         => $product['is_good'] ?? 0,
+            'temp_id'         => $product['temp_id'] ?? 0,
+            'attr'            => $attr,
+            'content'         => $content ?? '',
+            'spec_type'       => $product['spec_type'] ?? 1,
+            'extension_type'  => $profitConfig['extension_type'],
+            'give_coupon_ids' => [],
+            'is_gift_bag'     => $product['is_gift_bag'] ?? 0,
+            'type'            => $product['type'] ?? 1,
+            'commission'      => $product['commission'] ?? '',
+            'pension'         => (string)($product['pension'] ?? '0.00'),
+            'pension_is'      => $product['pension_is'] ?? 0,
+            'share_is'        => $product['share_is'] ?? 0,
+            'ficti'           => $product['ficti'] ?? 0,
+            'icon_type'       => !empty($product['icon_type'])
+                ? (is_string($product['icon_type']) ? json_decode($product['icon_type'], true) : $product['icon_type'])
+                : [],
+            'attrValue'       => $attrValue,
+        ];
+
+        // 9. 调用 ProductRepository::update() 执行更新
+        /** @var ProductRepository $productRepository */
+        $productRepository = app()->make(ProductRepository::class);
+        $productRepository->update($productId, $updateData, $merId);
+    }
+
+    /**
      * 根据售价计算原价（阶梯加价）
      *
      * @param float $salePrice SKU售价