feat(console): 添加商品价格更新命令

- 在控制台配置中注册新的 ProductPriceUpdate 命令
- 创建 ProductPriceUpdate 类实现价格更新功能
- 实现对指定商品ID的价格递增更新逻辑
- 添加数据库事务确保更新操作的原子性
- 实现价格变更日志记录功能
- 配置命令描述为"商品价格更新"

app/command/ProductPriceUpdate.php

@@ -0,0 +1,65 @@
+<?php
+
+namespace app\command;
+
+use app\common\model\shared\SharedProsperityPartnerConsumeUpdateLog;
+use app\common\repositories\shared\SharedProsperityRecommendConfigRepository;
+use think\console\Command;
+use think\console\Input;
+use think\console\Output;
+use think\facade\Db;
+
+class ProductPriceUpdate extends Command
+{
+    // 变更数量
+    const NUMBER = 5;
+
+    const PRODUCT_IDS = [31053, 32171];
+
+    protected function configure()
+    {
+        // 指令配置
+        $this->setName('ProductPriceUpdate')
+            ->setDescription('商品价格更新');
+    }
+
+    protected function execute(Input $input, Output $output)
+    {
+        $output->writeln('定时任务执行中...');
+
+        $this->priceUpdate();
+
+        $output->writeln('定时任务执行完成');
+    }
+
+    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;
+        }
+
+    }
+
+}

config/console.php

@@ -35,5 +35,6 @@ return [
         'repair_fzone_pay_type' => 'app\command\repairFzonePayType',
         'wiwibaoproductsync' => 'app\command\WiwibaoProductSync',
         'sharedPartnerConsumeUpdate' => 'app\command\SharedPartnerConsumeUpdate',
+        'productPriceUpdate' => 'app\command\ProductPriceUpdate',
     ],
 ];