huahuibao/console/controllers/ProductController.php

<?php

namespace console\controllers;

use biz\item\classes\PtItemClass;
use biz\product\classes\ProductClass;
use biz\product\models\Product;
use biz\shop\classes\ShopClass;
use bizGhs\item\classes\ItemClass;
use bizGhs\item\models\Item;
use common\components\stringUtil;
use common\components\util;
use yii\console\Controller;
use Yii;

class ProductController extends Controller
{

    //复制花材 ssh 20240422
    public function actionClone()
    {
        ini_set('memory_limit', '5045M');
        set_time_limit(0);

        if (getenv('YII_ENV') == 'production') {
            $shopId = 23580;
        } else {
            $shopId = 36523;
        }
        $shop = ShopClass::getById($shopId, true);
        if (empty($shop)) {
            util::stop();
        }
        $mainId = $shop->mainId ?? 0;
        $productList = ProductClass::getAllByCondition(['mainId' => $mainId, 'classId' => ['in', [64848, 64849, 64850, 64851, 64852, 64853, 64854, 64855, 64856, 64857, 64858, 64859, 64860, 64861, 64862, 64863, 64865, 64866]]], null, '*');
        if (!empty($productList)) {
            foreach ($productList as $post) {
                $post['copy'] = 1;
                $post['auth'] = 0;
                $post['skPrice'] = $post['price'];
                $post['hjPrice'] = $post['price'];
                $post['sjId'] = $shop->sjId ?? 0;
                unset($post['viewNum']);
                unset($post['actualSold']);
                unset($post['itemId']);
                unset($post['id']);
                unset($post['delStatus']);

                $a = $post;
                $a['name'] = $a['name'] . ' A级';
                $a['py'] = stringUtil::py($a['name']);
                \bizGhs\product\classes\ProductClass::addProduct($a, $shop);

                $b = $post;
                $b['name'] = $b['name'] . ' B级';
                $b['py'] = stringUtil::py($b['name']);
                \bizGhs\product\classes\ProductClass::addProduct($b, $shop);

                $ab = $post;
                $ab['name'] = $ab['name'] . ' AB级';
                $ab['py'] = stringUtil::py($ab['name']);
                \bizGhs\product\classes\ProductClass::addProduct($ab, $shop);

//                $c = $post;
//                $c['name'] = $c['name'] . ' C级';
//                $c['py'] = stringUtil::py($c['name']);
//                \bizGhs\product\classes\ProductClass::addProduct($c, $shop);
//
//                $d = $post;
//                $d['name'] = $d['name'] . ' D级';
//                $d['py'] = stringUtil::py($d['name']);
//                \bizGhs\product\classes\ProductClass::addProduct($d, $shop);

//                $e = $post;
//                $e['name'] = $e['name'] . ' E级';
//                $e['py'] = stringUtil::py($e['name']);
//                \bizGhs\product\classes\ProductClass::addProduct($e, $shop);
            }
        }
    }

    public function actionChangeSk()
    {
        ini_set('memory_limit', '2045M');
        set_time_limit(0);

        //$id = 36523;
        $id = 520;
        $shop = ShopClass::getById($id, true);
        $mainId = $shop->mainId ?? 0;

        $sjId = $shop->sjId ?? 0;
        $chainShopList = ShopClass::getAllByCondition(['sjId' => $sjId, 'join' => 0], null, '*', null, true);

        $default = $shop->default ?? 0;

        $productList = ProductClass::getAllByCondition(['mainId' => $mainId], null, '*', 'id', true);

        if (!empty($productList)) {
            foreach ($productList as $product) {
                $price = $product->price ?? 0;
                $skPrice = bcadd(floatval($price), 3, 0);
                $product->skPrice = $skPrice;
                $product->save();
                $ptItemId = $product->itemId ?? 0;
                if ($default == 1) {
                    foreach ($chainShopList as $chain) {
                        if ($chain->id == $shop->id) {
                            continue;
                        }
                        $chainMainId = $chain->mainId ?? 0;
                        $chainProduct = ProductClass::getByCondition(['mainId' => $chainMainId, 'itemId' => $ptItemId], true);
                        if (!empty($chainProduct)) {
                            $chainProduct->skPrice = $skPrice;
                            $chainProduct->save();
                        }
                    }
                }
            }
        }


    }

    //修改散客比批发价格贵 ssh 20220609
    public function actionSkMore()
    {
        $query = new \yii\db\Query();
        $query->from(Item::tableName());
        $query->where(['>', 'id', 0]);
        foreach ($query->batch() as $batchItem) {
            foreach ($batchItem as $item) {
                $addPrice = $item['addPrice'] ?? 0;
                $id = $item['id'] ?? 0;
                $skAddPrice = $item['skAddPrice'] ?? 0;
                if ($skAddPrice > $addPrice) {
                    $add = bcsub($skAddPrice, $addPrice, 2);
                    ItemClass::updateById($id, ['skMore' => $add]);
                } else {
                    echo "零售加价小于批发加价 {$id}\n";
                }
            }
        }
    }

    //更新纯彩花艺的价格 ./yii product/update-price ssh 20211020
    public function actionUpdatePrice()
    {
        $list = ProductClass::getAllByCondition(['shopId' => 10], null, '*', null, true);
        if (!empty($list)) {
            foreach ($list as $key => $item) {
                $price = $item->price ?? 0;
                $addPrice = $item->addPrice ?? 0;
                $skAddPrice = $item->skAddPrice ?? 0;
                $hjAddPrice = $item->hjAddPrice ?? 0;
                $zsAddPrice = $item->zsAddPrice ?? 0;

                $skDiff = bcsub($addPrice, $skAddPrice, 2);
                $skPrice = bcsub($price, $skDiff, 2);
                $hjDiff = bcsub($addPrice, $hjAddPrice, 2);
                $hkPrice = bcsub($price, $hjDiff, 2);
                $zsDiff = bcsub($addPrice, $zsAddPrice, 2);
                $zsPrice = bcsub($price, $zsDiff, 2);
                $item->skPrice = $skPrice;
                $item->hjPrice = $hkPrice;
                $item->zsPrice = $zsPrice;
                $item->save();
            }
        }
    }

    // ./yii product/reset-cover
    public function actionResetCover()
    {
        $sql = "SELECT * FROM `" . Product::tableName() . "` WHERE cover not like '%.%'";
        $command = Yii::$app->db->createCommand($sql);
        $data = $command->queryAll();
        if (empty($data)) {
            return false;
        }
        foreach ($data as $item) {
            $id = $item['id'] ?? 0;
            $ptItemId = $item['itemId'] ?? 0;
            $preCover = $item['cover'] ?? '';
            $ptItem = PtItemClass::getById($ptItemId, true);
            $cover = $ptItem->cover ?? '';
            if (!empty($cover)) {
                ProductClass::updateById($id, ['cover' => $cover]);
                echo "productId:" . $id . "原图：{$preCover}， 恢复图片：" . $cover . "\n";
            } else {
                echo "productId:" . $id . " 恢复图片没有成功-----------------\n";
            }
        }
    }

    // ./yii product/sk-price
    public function actionSkPrice()
    {
        ini_set('memory_limit', '2045M');
        set_time_limit(0);

        $list = ProductClass::getAllByCondition([], null, '*', null, true);
        if (empty($list)) {
            return false;
        }
        foreach ($list as $key => $item) {
            $price = $item->price ?? 0;
            $skAddPrice = $item->skAddPrice ?? 0;
            $addPrice = $item->addPrice ?? 0;
            $diff = bcsub($skAddPrice, $addPrice, 2);
            $currentPrice = $price;
            if ($diff > 0) {
                $currentPrice = bcadd($price, $diff, 2);
            }
            $item->skPrice = $currentPrice;
            $item->save();
        }
    }

    //二个空间问题
    public function actionSame()
    {
        ini_set('memory_limit', '5045M');
        set_time_limit(0);
        if (getenv('YII_ENV') == 'production') {
            $mainId = 8164;
        } else {
            $mainId = 644;
        }
        $list = ProductClass::getAllByCondition(['mainId' => $mainId], null, '*', null);
        if (!empty($list)) {
            $ids = array_column($list, 'itemId');
            $ptInfo = PtItemClass::getByIds($ids, null, 'id');
            foreach ($list as $item) {
                $id = $item['id'] ?? 0;
                $name = $item['name'] ?? '';
                $ptItemId = $item['itemId'] ?? 0;
                $pt = $ptInfo[$ptItemId];
                $ptName = $pt['name'] ?? '';
                if ($name != $ptName) {
                    echo $id . ' ' . $name . ' ' . $ptName . "\n";
                }
            }
        }
    }

    //二个空间问题
    public function actionEmpty()
    {
        ini_set('memory_limit', '5045M');
        set_time_limit(0);
        $list = PtItemClass::getAllByCondition(['delStatus' => 0], null, '*', null, true);
        if (!empty($list)) {
            foreach ($list as $item) {
                $name = $item->name ?? '';
                $name = trim($name);
                $name = str_replace("   ", " ", $name);
                $name = str_replace("  ", " ", $name);
                $item->name = $name;
                $item->save();
            }
        }
    }

    //恢复花材初始名称 ssh 20250213
    public function actionRecover()
    {
        ini_set('memory_limit', '5045M');
        set_time_limit(0);
        if (getenv('YII_ENV') == 'production') {
            $mainId = 26374;
        } else {
            $mainId = 644;
        }
        $list = ProductClass::getAllByCondition(['mainId' => $mainId], null, '*', null);
        if (!empty($list)) {
            $ids = array_column($list, 'itemId');
            $ptInfo = PtItemClass::getByIds($ids, null, 'id');
            foreach ($list as $item) {
                $id = $item['id'] ?? 0;
                $name = $item['name'] ?? '';
                $ptItemId = $item['itemId'] ?? 0;
                $pt = $ptInfo[$ptItemId];
                $ptName = $pt['name'] ?? '';
                if (!empty($ptName)) {
                    $ptPy = stringUtil::py($ptName);
                    ProductClass::updateById($id, ['name' => $ptName, 'py' => $ptPy]);
                }
            }
        }
    }

    //预售到期自动取消
    public function actionCancelPresell()
    {
        try{
            $now = time(); //注意脚本执行时间要在凌晨0点之后，否则会出问题
            $redis = Yii::$app->redis;
            $cursor = '0';
            do {
                $scanResult = $redis->executeCommand('SCAN', [$cursor, 'MATCH', 'product_presell:*', 'COUNT', 500]);
                $cursor = $scanResult[0] ?? '0';
                $keys = $scanResult[1] ?? [];
                if (empty($keys)) {
                    continue;
                }
                foreach ($keys as $key) {
                    $firstDate = (int)$redis->get($key);
                    if ($firstDate >= $now) {
                        continue;
                    }
                    $id = (int)str_replace('product_presell:', '', $key);
                    if ($id <= 0) {
                        $redis->del($key);
                        continue;
                    }
                    $item = ProductClass::getById($id, true);
                    if (empty($item)) {
                        $redis->del($key);
                        continue;
                    }
                    if ((int)$item->presell !== 1) {
                        $redis->del($key);
                        continue;
                    }
                    $item->presell = 0;
                    $item->presellDate = '';
                    $item->save();
                    $redis->del($key);
                }
            } while ($cursor !== '0');

            Yii::info('预售到期自动取消脚本成功执行');
        }catch(\Exception $e){
            Yii::error('预售到期自动取消脚本执行失败：' . $e->getMessage());
        }
    }
}