qimall/addons/Bargain/console/controllers/BargainController.php

<?php

namespace addons\Bargain\console\controllers;

use addons\Bargain\common\enums\BargainEnum;
use addons\Bargain\common\models\BargainActive;
use yii\console\Controller;
use common\models\mall\Mall;
use yii\console\ExitCode;
use Yii;

class BargainController extends Controller
{
    /**
     * 砍价开启活动定时任务
     *
     * @return int
     */
    public function actionOpenActive()
    {
        try {
            $mall_list = Mall::getEnableMallList(true);
            $mall_ids = array_column($mall_list, 'id');
            if (empty($mall_ids)) {
                echo '没有可用商城，不做处理 ... ' . PHP_EOL;
                return ExitCode::UNSPECIFIED_ERROR;
            }
            $res = BargainActive::updateAll(
                ['active_status' => BargainEnum::ACTIVE_HANDING],
                [
                    'and',
                    ['active_status' => BargainEnum::NOT_STARTED],
                    ['<', 'begin_time', time()],
                ]
            );
            return ExitCode::OK;
        } catch (\Exception $e) {
            Yii::error('砍价活动开始检查,任务处理出错：' . $e->getMessage() . PHP_EOL);
            return ExitCode::UNSPECIFIED_ERROR;
        }
    }

    /**
     * 砍价关闭活动定时任务
     *
     * @return int
     */
    public function actionCloseActive()
    {
        try {
            $mall_list = Mall::getEnableMallList(true);
            $mall_ids = array_column($mall_list, 'id');
            if (empty($mall_ids)) {
                echo '没有可用商城，不做处理 ... ' . PHP_EOL;
                return ExitCode::UNSPECIFIED_ERROR;
            }
            $res = BargainActive::updateAll(
                ['active_status' => BargainEnum::ACTIVE_FINISH],
                [
                    'and',
                    ['active_status' => BargainEnum::ACTIVE_HANDING],
                    ['<', 'end_time', time()],
                ]
            );
            return ExitCode::OK;
        } catch (\Exception $e) {
            Yii::error('砍价活动关闭检查,任务处理出错：' . $e->getMessage() . PHP_EOL);
            return ExitCode::UNSPECIFIED_ERROR;
        }
    }
}