refactor(product): 重构商品价格更新命令逻辑

- 移除无用的共享繁荣合作伙伴消费更新日志和推荐配置仓库依赖
- 添加商品仓库依赖以使用标准的数据访问层
- 新增商户ID常量用于商品更新操作
- 重构价格更新方法，使用商品仓库的更新方法替代直接数据库操作
- 更新商品属性值和内容数据的处理方式
- 移除事务处理逻辑并清理旧的数据库直写代码
- 注释掉原有的旧实现代码以备参考

app/command/ProductPriceUpdate.php

@@ -2,8 +2,7 @@
 
 namespace app\command;
 
-use app\common\model\shared\SharedProsperityPartnerConsumeUpdateLog;
-use app\common\repositories\shared\SharedProsperityRecommendConfigRepository;
+use app\common\repositories\store\product\ProductRepository;
 use think\console\Command;
 use think\console\Input;
 use think\console\Output;
@@ -16,6 +15,8 @@ class ProductPriceUpdate extends Command
 
     const PRODUCT_IDS = [31053, 32171];
 
+    const MER_ID = 3447;
+
     protected function configure()
     {
         // 指令配置
@@ -34,32 +35,87 @@ class ProductPriceUpdate extends Command
 
     private function priceUpdate()
     {
-        // 获取当前数据
-        $productData = Db::name('store_product')->where(['product_id' => self::PRODUCT_IDS])->field('product_id,price')->select()->toArray();
-        $attrData = Db::name('store_product_attr_value')->where(['product_id' => self::PRODUCT_IDS])->field('product_id,price')->select()->toArray();
-        Db::startTrans();
-        try {
-            foreach ($productData as $product) {
-                $log = [
-                    'product_id' => $product['product_id'],
-                    'old_price' => $product['price'],
-                    'number' => self::NUMBER,
-                    'new_price' => $product['price'] + self::NUMBER,
-                ];
-                Db::name('product_price_update_log')->insert($log);
-
-                Db::name('store_product')->where(['product_id' => $product['product_id']])->inc('price', self::NUMBER)->update();
-                Db::name('store_product_attr_value')->where(['product_id' => $product['product_id']])->inc('price', self::NUMBER)->update();
-            }
-
-;
-            Db::commit();
-            return true;
-        } catch (\Exception $e) {
-            Db::rollback();
-            throw $e;
+        // 获取商品数据
+        $productData = Db::name('store_product')->where(['product_id' => self::PRODUCT_IDS])->select()->toArray();
+
+
+        /** @var ProductRepository $repository */
+        $repository = app()->make(ProductRepository::class);
+        foreach ($productData as $product) {
+            $log = [
+                'product_id' => $product['product_id'],
+                'old_price' => $product['price'],
+                'number' => self::NUMBER,
+                'new_price' => $product['price'] + self::NUMBER,
+            ];
+            Db::name('product_price_update_log')->insert($log);
+
+            $attrValue = Db::name('store_product_attr_value')->where(['product_id' => $product['product_id']])->select()->toArray();
+            $attrValue[0]['price'] = $attrValue[0]['price'] + self::NUMBER;
+            $content = Db::name('store_product_content')->where(['product_id' => $product['product_id']])->field('content')->find();
+
+            $update = [
+                'attr' => [],
+                'attrValue' => $attrValue,
+                'brand_id' => $product['brand_id'],
+                'cate_id' => $product['cate_id'],
+                'commission' => $product['commission'],
+                'content' => $content['content'],
+                'couponData' => [],
+                'extension_type' => $product['extension_type'],
+                'ficti' => $product['ficti'],
+                'give_coupon_ids' => [],
+                'icon_type' => [],
+                'image' => $product['image'],
+                'is_gift_bag' => $product['is_gift_bag'],
+                'is_good' => $product['is_good'],
+                'keyword' => $product['keyword'],
+                'mer_cate_id' => [],
+                'pension' => $product['pension'],
+                'pension_is' => $product['pension_is'],
+                'share_is' => $product['share_is'],
+                'slider_image' => explode(',',$product['slider_image']),
+                'sort' => $product['sort'],
+                'spec_type' => $product['spec_type'],
+                'store_info' => $product['store_info'],
+                'store_name' => $product['store_name'],
+                'temp_id' => $product['temp_id'],
+                'type' => $product['type'],
+                'unit_name' => $product['unit_name'],
+                'volunteer' => $product['volunteer']
+            ];
+            $repository->update($product['product_id'],$update,self::MER_ID);
+            Db::name('product_share')->where('product_id',$product['product_id'])->where('share_channel',1)->update(['url'=>'']);
         }
 
+
+
+        // // 获取当前数据
+        // $productData = Db::name('store_product')->where(['product_id' => self::PRODUCT_IDS])->field('product_id,price')->select()->toArray();
+        // $attrData = Db::name('store_product_attr_value')->where(['product_id' => self::PRODUCT_IDS])->field('product_id,price')->select()->toArray();
+        // Db::startTrans();
+        // try {
+        //     foreach ($productData as $product) {
+        //         $log = [
+        //             'product_id' => $product['product_id'],
+        //             'old_price' => $product['price'],
+        //             'number' => self::NUMBER,
+        //             'new_price' => $product['price'] + self::NUMBER,
+        //         ];
+        //         Db::name('product_price_update_log')->insert($log);
+        //
+        //         Db::name('store_product')->where(['product_id' => $product['product_id']])->inc('price', self::NUMBER)->update();
+        //         Db::name('store_product_attr_value')->where(['product_id' => $product['product_id']])->inc('price', self::NUMBER)->update();
+        //     }
+        //
+        //     ;
+        //     Db::commit();
+        //     return true;
+        // } catch (\Exception $e) {
+        //     Db::rollback();
+        //     throw $e;
+        // }
+
     }
 
 }