feat(command): 添加1688今日商品自动入库命令

- 新增 AlibabaTodayImport.php 命令类实现自动入库功能
- 支持按商户ID、指定日期、批量处理等参数进行商品导入
- 集成分润设置功能，默认配置15%分润比例
- 实现原价计算规则，根据SKU售价阶梯加价策略
- 添加断点续传支持，可通过skip参数跳过已处理商品
- 集成进度显示和错误处理机制
- 在console配置中注册alibaba:today-import命令

app/command/AlibabaTodayImport.php

@@ -0,0 +1,307 @@
+<?php
+
+namespace app\command;
+
+use app\services\ThirdParty\AlibabaAgent\ProductService;
+use think\console\Command;
+use think\console\Input;
+use think\console\Output;
+use think\facade\Db;
+
+/**
+ * 今日1688商品自动入库命令
+ *
+ * 从 alibaba_import_goods 表中获取今日创建的商品，
+ * 调用 ProductService::importToStoreProduct() 进行正式入库到 store_product 表
+ *
+ * 用法:
+ *   php think alibaba:today-import                                          # 默认今天，mer_id=3447
+ *   php think alibaba:today-import --mer_id=3447                            # 指定商户ID
+ *   php think alibaba:today-import --date=2026-05-21                        # 指定日期
+ *   php think alibaba:today-import --mer_id=3447 --date=2026-05-21          # 指定商户+日期
+ *   php think alibaba:today-import --batch=100                              # 每批处理100条（默认50）
+ *   php think alibaba:today-import --skip=10                                # 跳过前10条（断点续传）
+ *
+ * 定时任务配置（每天23:55执行）:
+ *   55 23 * * * php /www/wwwroot/shop/think alibaba:today-import --mer_id=3447 >> /tmp/alibaba_today_import.log 2>&1
+ *
+ * 分润设置（写死）:
+ *   - extension_type: 1（开启分润）
+ *   - concession_pri: 售价 × 15%（商家让利金额）
+ *   - extension_one: 15（SKU级分润比例）
+ *   - plate_mer_profit: 0（平台商户利润）
+ *   - commission: 保持原样（不修改）
+ *
+ * 原价计算规则（根据SKU售价阶梯加价）:
+ *   1-20元    => 固定加5元
+ *   21-50元   => 固定加20元
+ *   51-120元  => 固定加40元
+ *   121-200元 => 固定加45元
+ *   201-300元 => 固定加50元
+ */
+class AlibabaTodayImport extends Command
+{
+    protected function configure()
+    {
+        $this->setName('alibaba:today-import')
+            ->setDescription('从alibaba_import_goods获取今日创建的商品，调用importStore接口正式入库')
+            ->addOption('mer_id', null, \think\console\input\Option::VALUE_OPTIONAL, '商户ID', '3447')
+            ->addOption('date', null, \think\console\input\Option::VALUE_OPTIONAL, '指定日期 (Y-m-d)，默认今天', '')
+            ->addOption('batch', null, \think\console\input\Option::VALUE_OPTIONAL, '每批处理数量', '50')
+            ->addOption('skip', null, \think\console\input\Option::VALUE_OPTIONAL, '跳过前N条（断点续传）', '0');
+    }
+
+    protected function execute(Input $input, Output $output)
+    {
+        // 解除时间限制
+        set_time_limit(0);
+
+        $output->writeln('========================================');
+        $output->writeln(' 1688今日商品自动入库 开始');
+        $output->writeln('========================================');
+
+        // 1. 解析参数
+        $merId = (int)$input->getOption('mer_id');
+        $date  = $input->getOption('date');
+        $batch = (int)$input->getOption('batch');
+        $skip  = (int)$input->getOption('skip');
+
+        if ($batch < 1) $batch = 50;
+        if ($skip < 0) $skip = 0;
+
+        if (empty($date)) {
+            $date = date('Y-m-d');
+        }
+
+        // ============================================================
+        // 分润配置（写死）
+        // ============================================================
+        $profitConfig = [
+            'extension_type'  => 1,      // 1=开启分润
+            'concession_rate' => 0.15,   // 商家让利比例15%（concession_pri = 售价 × 15%）
+            'extension_one'   => 15,     // SKU级分润比例15%
+        ];
+
+        $output->writeln("商户ID:         {$merId}");
+        $output->writeln("查询日期:       {$date}");
+        $output->writeln("每批数量:       {$batch}");
+        $output->writeln("跳过前N条:      {$skip}");
+        $output->writeln('分润设置:');
+        $output->writeln("  extension_type:  {$profitConfig['extension_type']} (开启分润)");
+        $output->writeln("  concession_rate: {$profitConfig['concession_rate']} (售价×{$profitConfig['concession_rate']})");
+        $output->writeln("  extension_one:   {$profitConfig['extension_one']}%");
+
+        // 2. 查询今日创建的 alibaba_import_goods 记录（只查ID，不查全字段，节省内存）
+        $todayStart = $date . ' 00:00:00';
+        $todayEnd   = $date . ' 23:59:59';
+
+        $output->write('正在查询今日待入库商品... ');
+        $allIds = Db::name('alibaba_import_goods')
+            ->where('status', 1)
+            ->where('create_time', '>=', $todayStart)
+            ->where('create_time', '<=', $todayEnd)
+            ->order('id', 'ASC')
+            ->column('id');
+
+        $total = count($allIds);
+        $output->writeln("共 {$total} 条");
+
+        if ($total === 0) {
+            $output->writeln("{$date} 没有需要入库的商品");
+            $output->writeln('========================================');
+            $output->writeln(' 1688今日商品自动入库 结束 (无商品)');
+            $output->writeln('========================================');
+            return;
+        }
+
+        // 3. 应用 skip 跳过已处理的
+        if ($skip > 0) {
+            $allIds = array_slice($allIds, $skip);
+            $output->writeln("跳过前 {$skip} 条，剩余 " . count($allIds) . " 条");
+        }
+
+        // 4. 分批处理
+        /** @var ProductService $productService */
+        $productService = app()->make(ProductService::class);
+
+        $chunks = array_chunk($allIds, $batch);
+        $totalChunks = count($chunks);
+
+        $output->writeln("共分 {$totalChunks} 批执行");
+        $output->writeln('');
+
+        $globalSuccess = 0;
+        $globalFail    = 0;
+        $globalProfitSet = 0;
+        $startTime     = time();
+
+        foreach ($chunks as $chunkIndex => $idBatch) {
+            $batchStartTime = time();
+            $batchNum = $chunkIndex + 1;
+            $processedCount = $skip + ($chunkIndex * $batch) + 1;
+
+            $output->writeln("--- 第 {$batchNum}/{$totalChunks} 批 (已处理 {$processedCount}/{$total}) ---");
+
+            foreach ($idBatch as $importId) {
+                $output->write("  [{$processedCount}/{$total}] import_goods_id={$importId} ... ");
+
+                try {
+                    // 4a. 调用原始入库方法
+                    $result = $productService->importToStoreProduct($importId, $merId);
+
+                    if ($result['code'] === 200) {
+                        $productId = $result['product_id'];
+                        $globalSuccess++;
+
+                        // 4b. 根据SKU售价阶梯计算原价（ot_price）
+                        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'],
+                                ]);
+
+                            $globalProfitSet++;
+                            $output->write("<info>[分润15%已设置]</info> ");
+                        } catch (\Throwable $profitE) {
+                            $output->write("<comment>[分润设置失败: {$profitE->getMessage()}]</comment> ");
+                        }
+
+                        $output->writeln("<info>成功 => product_id={$productId}</info>");
+                    } else {
+                        $globalFail++;
+                        $output->writeln("<comment>跳过: {$result['msg']}</comment>");
+                    }
+                } catch (\Throwable $e) {
+                    $globalFail++;
+                    $output->writeln("<error>异常: {$e->getMessage()}</error>");
+                }
+
+                $processedCount++;
+            }
+
+            // 每批结束后输出当前进度和耗时
+            $batchElapsed = time() - $batchStartTime;
+            $totalElapsed = time() - $startTime;
+            $output->writeln("  本批耗时: {$batchElapsed}s | 累计耗时: {$totalElapsed}s | 累计成功: {$globalSuccess} | 累计失败: {$globalFail} | 分润设置: {$globalProfitSet}");
+            $output->writeln('');
+
+            // 每批之间短暂休眠，避免数据库压力过大
+            if ($chunkIndex < $totalChunks - 1) {
+                $output->writeln("  等待 1 秒后继续下一批...");
+                sleep(1);
+            }
+        }
+
+        // 5. 输出汇总结果
+        $totalElapsed = time() - $startTime;
+        $output->writeln('');
+        $output->writeln('========================================');
+        $output->writeln(' 入库完成');
+        $output->writeln('========================================');
+        $output->writeln("总耗时:         {$totalElapsed}s");
+        $output->writeln("总处理:         {$total} 条");
+        $output->writeln("成功:           {$globalSuccess} 条");
+        $output->writeln("失败:           {$globalFail} 条");
+        $output->writeln("已设置分润15%:  {$globalProfitSet} 条");
+
+        if ($globalFail > 0) {
+            $output->writeln('');
+            $output->writeln('<comment>提示: 失败的商品可以查看 alibaba 日志通道获取详细信息</comment>');
+            $output->writeln("<comment>      重跑时可加 --skip={$skip} 跳过已处理的商品</comment>");
+        }
+
+        $output->writeln('========================================');
+        $output->writeln(' 1688今日商品自动入库 结束');
+        $output->writeln('========================================');
+    }
+
+    /**
+     * 根据售价计算原价（阶梯加价）
+     *
+     * @param float $salePrice SKU售价
+     * @return float 计算后的原价
+     */
+    protected static function calcOtPrice(float $salePrice): float
+    {
+        if ($salePrice <= 0) {
+            return 0;
+        }
+
+        if ($salePrice >= 1 && $salePrice <= 20) {
+            return $salePrice + 5;
+        } elseif ($salePrice >= 21 && $salePrice <= 50) {
+            return $salePrice + 20;
+        } elseif ($salePrice >= 51 && $salePrice <= 120) {
+            return $salePrice + 40;
+        } elseif ($salePrice >= 121 && $salePrice <= 200) {
+            return $salePrice + 45;
+        } else {
+            // 201元以上（含201-300及超过300），统一加50元
+            return $salePrice + 50;
+        }
+    }
+}

config/console.php

@@ -38,5 +38,6 @@ return [
         'productPriceUpdate' => 'app\command\ProductPriceUpdate',
         'deleteApiLog' => 'app\command\DeleteApiLog',
         'sharedOfflineOrderProfitDelete' => 'app\command\SharedOfflineOrderProfitDelete',
+        'alibaba:today-import' => 'app\command\AlibabaTodayImport',
     ],
 ];