命令行-修复拉取微唯宝商品逻辑

app/command/WiwibaoProductSync.php

@@ -4,10 +4,14 @@ declare (strict_types=1);
 namespace app\command;
 
 use app\common\enum\douhuomall\DouhuomallEnum;
+use app\common\enum\store\ProductEnum;
 use app\traits\GongApiRequest;
 use think\console\Command;
 use think\console\Input;
 use think\console\Output;
+use think\db\exception\DataNotFoundException;
+use think\db\exception\DbException;
+use think\db\exception\ModelNotFoundException;
 use think\facade\Db;
 use think\facade\Log;
 
@@ -20,7 +24,7 @@ class WiwibaoProductSync extends Command
     protected $config = [
         'page_size' => 100,      // 每页拉取数量
         'max_pages' => 0,       // 最大页数限制
-        'price_change_rate' => 0.1, // 价格变动比率阈值（10%）
+        'price_change_rate' => 0.0, // 价格变动比率阈值（10%）
     ];
 
     protected function configure()
@@ -337,8 +341,8 @@ class WiwibaoProductSync extends Command
             // 检查是否有已下架的商品
             $count = Db::name('store_product')
                 ->where('spu_id', $newData['spu_id'])
-                ->where('is_show', 0)
-                ->where('is_status', 0)
+                ->where('is_show', ProductEnum::IS_SHOW['No']['code'])
+                ->where('is_status', ProductEnum::IS_STATUS['Automatic']['code'])
                 ->count();
 
             return $count > 0;
@@ -355,8 +359,8 @@ class WiwibaoProductSync extends Command
         Db::name('store_product')
             ->where('spu_id', $spuId)
             ->update([
-                'is_show' => 0,
-                'status' => 1
+                'is_show' => ProductEnum::IS_SHOW['No']['code'],
+                'status' => ProductEnum::STATUS['Approved']['code']
             ]);
 
         Log::info("恢复商品上架（恢复到仓库中）状态: spu_id={$spuId}");
@@ -368,73 +372,57 @@ class WiwibaoProductSync extends Command
     protected function checkAndProcessOnlineProduct($spuId, $syncData)
     {
         // 检查商品是否已上架
-        $product = Db::name('store_product')
-            ->where('spu_id', $spuId)
-            ->find();
-
-        if (!$product) {
-            return;
-        }
-
-        // 获取本地商品价格信息
-        $localPrices = $this->getLocalProductPrices($product['product_id']);
-
-        // 解析同步数据中的价格
-        $syncSkuInfo = $syncData['skuId_info'];
-        $syncPrices = $this->extractPricesFromSkuInfo($syncSkuInfo);
-
-        // 比较价格，判断是否需要下架
-        $priceChanged = $this->checkPriceChange($localPrices, $syncPrices);
+        try {
+            $productList = Db::name('store_product')
+                ->where('is_show', ProductEnum::IS_SHOW['Yes']['code'])
+                ->where('spu_id', $spuId)
+                ->select()
+                ->toArray();
+
+            if (empty($productList)) {
+                return;
+            }
 
-        if ($priceChanged) {
-            // 价格变动超过阈值，下架商品并记录
-            $this->offlineProductWithRecord($product, $syncData, $localPrices, $syncPrices);
-        } else {
-            // 价格未变动或变动很小，只更新图片
-            $this->updateProductImages($spuId);
-        }
-    }
+            // 解析同步数据中的价格
+            $syncPrices = [];
+            foreach ($syncData['skuId_info'] as $sku) {
+                $syncPrices[] = [
+                    'sku_id' => $sku['sku_id'] ?? '',
+                    'market_price' => $sku['market_price'] ?? 0,
+                    'cost_price' => $sku['cost_price'] ?? 0,
+                    'retail_price' => $sku['retail_price'] ?? 0
+                ];
+            }
 
-    /**
-     * 获取本地商品价格信息
-     */
-    protected function getLocalProductPrices($productId)
-    {
-        $product = Db::name('store_product')
-            ->where('product_id', $productId)
-            ->field('price, cost, ot_price')
-            ->find();
+            foreach ($productList as $product) {
+                // 获取本地商品价格信息
+                // 获取SKU价格
+                $skus = Db::name('store_product_attr_value')
+                    ->where('product_id', $product['product_id'])
+                    ->field('sku, price, cost')
+                    ->select()
+                    ->toArray();
+                $localPrices = [
+                    'product_price' => $product['price'] ?? 0,
+                    'product_cost' => $product['cost'] ?? 0,
+                    'product_ot_price' => $product['ot_price'] ?? 0,
+                    'skus' => $skus
+                ];
 
-        // 获取SKU价格
-        $skus = Db::name('store_product_attr_value')
-            ->where('product_id', $productId)
-            ->field('sku, price, cost')
-            ->select()
-            ->toArray();
+                // 比较价格，判断是否需要下架
+                $priceChanged = $this->checkPriceChange($localPrices, $syncPrices);
 
-        return [
-            'product_price' => $product['price'] ?? 0,
-            'product_cost' => $product['cost'] ?? 0,
-            'product_ot_price' => $product['ot_price'] ?? 0,
-            'skus' => $skus
-        ];
-    }
+                if ($priceChanged) {
+                    // 价格变动超过阈值，下架商品并记录
+                    $this->offlineProductWithRecord($product, $syncData, $localPrices, $syncPrices);
+                } else {
+                    // 价格未变动或变动很小，只更新图片
+                    $this->updateProductImages($spuId);
+                }
+            }
+        } catch (DataNotFoundException|ModelNotFoundException|DbException $e) {
 
-    /**
-     * 从SKU信息中提取价格
-     */
-    protected function extractPricesFromSkuInfo($skuInfo)
-    {
-        $prices = [];
-        foreach ($skuInfo as $sku) {
-            $prices[] = [
-                'sku_id' => $sku['sku_id'] ?? '',
-                'market_price' => $sku['market_price'] ?? 0,
-                'cost_price' => $sku['cost_price'] ?? 0,
-                'retail_price' => $sku['retail_price'] ?? 0
-            ];
         }
-        return $prices;
     }
 
     /**
@@ -515,9 +503,9 @@ class WiwibaoProductSync extends Command
         Db::name('store_product')
             ->where('product_id', $productId)
             ->update([
-                'is_show' => 0,
-                'status' => -2,
-                'is_status' => 0
+                'is_show' => ProductEnum::IS_SHOW['No']['code'],
+                'status' => ProductEnum::STATUS['Withdrawn']['code'],
+                'is_status' => ProductEnum::IS_STATUS['Automatic']['code']
             ]);
 
         // 3. 收集变动后数据
@@ -638,22 +626,15 @@ class WiwibaoProductSync extends Command
 
         foreach ($products as $product) {
             // 记录下架前数据
-            $beforeData = [
-                'product_id' => $product['product_id'],
-                'spu_id' => $spuId,
-                'title' => $product['store_name'] ?? '',
-                'status' => $product['is_show'] ?? 0,
-                'price' => $product['price'] ?? 0,
-                'record_time' => date('Y-m-d H:i:s')
-            ];
+            $beforeData = $product;
 
             // 下架商品
             Db::name('store_product')
                 ->where('product_id', $product['product_id'])
                 ->update([
-                    'is_show' => 0,
-                    'status' => -2,
-                    'is_status' => 0
+                    'is_show' => ProductEnum::IS_SHOW['No']['code'],
+                    'status' => ProductEnum::STATUS['Withdrawn']['code'],
+                    'is_status' => ProductEnum::IS_STATUS['Automatic']['code']
                 ]);
 
             // 记录日志

app/common/enum/store/ProductEnum.php

@@ -36,4 +36,9 @@ class ProductEnum extends CommonEnum
         'No' => ['code' => 0, 'name' => '否'],
         'Yes' => ['code' => 1, 'name' => '是']
     ];
+
+    const IS_STATUS = [
+        'Automatic' => ['code' => 0, 'name' => '系统自动操作'],
+        'Triggered' => ['code' => 1, 'name' => '人为触发操作']
+    ];
 }