mall/jobs/ConsumptionGrowthValueJob.php

<?php
/**
 * ConsumptionGrowthValueJob.php
 * todo 文件描述
 * Created on 2025/4/19 10:19
 * @author: hankaige
 */

namespace app\jobs;

use app\models\Level;
use app\models\Store;
use app\models\User;
use app\models\UserGrowthValueLog;
use yii\base\BaseObject;
use yii\queue\JobInterface;

class ConsumptionGrowthValueJob extends BaseObject implements JobInterface
{

    public function execute($queue)
    {
        $store_list = Store::find()->where(['is_delete' => 0])->select('id, name')->all();
        foreach($store_list as $store) {
            try {
                // 获取当前商城的会员等级 且升级条件是成长值的
                $levels = Level::find()->where(['store_id' => $store->id,'status' => Level::STATUS_TRUE,'is_delete'=>Level::NOT_DELETE,'upgrade_conditions' => Level::UPGRADE_CONDITIONS_GROWTH])->andWhere(['>','growth_refund_value',0])->all();
                // 查询当前会员等级的所有用户
                foreach($levels as $level){
                    $userList = User::find()->where(['store_id' => $store->id, 'level' => $level->level, 'is_delete' => User::USER_NOT_DELETE])->all();
                    // 扣除对应会员等级用户的成长值
                    foreach($userList as $user){
                        if($user->growth_value > 0){
                            UserGrowthValueLog::setLog($store->id, $user->id, UserGrowthValueLog::LOG_TYPE_SUB, $level->growth_refund_value,UserGrowthValueLog::TYPE_CON,"每日消耗{$level->growth_refund_value}成长值");
                        }
                    }
                }
            }catch (\Exception $e){

            }
        }
    }
}