kailin/app/Console/Commands/Regiment.php

<?php

namespace App\Console\Commands;

use App\Models\Orders;
use Illuminate\Console\Command;
use App\Facades\Servers\Redis\RedisLock;
use App\Facades\Servers\WechatWork\ExternalContact;
use App\Models\RegimentActive as Model;
use App\Models\Regiment as  RegimentModel;
use App\Models\RegimentRecord;

class Regiment extends Command
{
    /**
     * 任务名称
     *
     * @var string
     */
    protected $signature = 'regiment';

    /**
     * 任务描述
     *
     * @var string
     */
    protected $description = '拼团活动时间到期';

    /**
     * Create a new command instance.
     *
     * @return void
     */
    public function __construct()
    {
        parent::__construct();
    }

    /**
     * Execute the console command.
     *
     * @return int
     */
    public function handle()
    {
        // 执行任务
        $this->run_task();
        return 0;
    }

    /**
     * 执行任务
     *
     * */
    public function run_task(){
        // 实例化
        $Model          = New Model();
        $time           = time();
        // 活动结束
        $activeList     =  $Model->query()->where([['end_time','<=',time()],['status','=',1]])->get();
        $activeList     =  array_column($activeList,null,'id');
        if ($activeList){
            $activeIds  =   array_column($activeList,'id');
            $regiment   =   RegimentModel::query()->where('status','=',1)->whereIn('id',$activeIds)->get();
            if ($regiment){
                foreach ($regiment as $v){
                        //虚拟成团
                       if ($activeList[$v['active_id']]['virtually'] == 2){
                           //修改状态
                           RegimentModel::query()->where('id','=',$v['id'])->update(['status'=>3]);
                           RegimentRecord::query()->where('regiment_id','=',$v['id'])->update(['status'=>2]);
                           //查询记录
                           $regimentRecordList  =   regimentRecord::query()->where('regiment_id','=',$v['id'])->get();
                           $regimentRecordListIds = array_column($regimentRecordList,'id');
                           //修改订单
                           $res         =   Orders::query()->whereIn('id',$regimentRecordListIds)->get();
                       }else{
                           RegimentModel::query()->where('id','=',$v['id'])->update(['status'=>2]);
                           RegimentRecord::query()->where('regiment_id','=',$v['id'])->update(['status'=>3]);
                       }
                }
            }
        }

    }

}