baokan/app/Console/Commands/Regiment.php

<?php

namespace App\Console\Commands;

use App\Facades\Servers\Logs\Log;
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_regiment();
        return 0;
    }

    /**
     * 执行任务
     *
     * */
    public function run_regiment(){
        // 实例化
        Log::log('run_regiment','执行开始');
        $Model          = New Model();
        $time           = time();
        // 活动结束
        $activeList     =  $Model->query()->where([['end_time','<=',time()],['status','=',1]])->get()->toArray();
        if ($activeList){
            $activeList =  array_column($activeList,null,'id');
            $activeIds  =   array_column($activeList,'id');
            $regiment   =   RegimentModel::query()->where('status','=',0)->whereIn('active_id',$activeIds)->get()->toArray();
            if ($regiment){
                $this->regiment($regiment,$activeList);
            }
            $res    =   $Model->query()->whereIn('id',$activeIds)->update(['status'=>2,'update_time'=>$time]);
            if (!$res)   Log::error('run_regiment','修改团活动失败'.json_encode($activeIds));
        }
        //团过期
        $regimentList   =   RegimentModel::query()->where([['status','=',0],['end_time','<=',$time]])->get();
        if ($regimentList){
            $this->regiment($regimentList,$activeList);
        }
        Log::log('run_regiment','执行完成');
    }
    public function regiment($regiment,$activeList)
    {
        $time   = time();
        foreach ($regiment as $v){
            $orders         =   Orders::query()->where(['status'=>10,'regiment_id'=>$v['id']])->first();
            //虚拟成团
            if ($orders && ($activeList[$v['active_id']]['virtually'] == 0 || $activeList[$v['active_id']]['number'] <= $v['people_number'])){
                //查询记录
                $regimentRecordList  =   regimentRecord::query()->where('regiment_id','=',$v['id'])->get()->toArray();
                if ($regimentRecordList){
                    foreach ($regimentRecordList as $record){
                        $ordersInfo         =   Orders::query()->where([['id','=',$record['order_id']]])->first();
                        if ($ordersInfo['status'] == 10){
                            //修改订单
                            $res         =   Orders::query()->where([['id','=',$record['order_id']],['status','=',10]])->update(['status'=>2,'update_time'=>$time]);
                            if (!$res)   Log::error('run_regiment','修改订单失败');
                            $res         =   RegimentRecord::query()->where('regiment_id','=',$v['id'])->update(['status'=>2]);
                            if (!$res)   Log::error('run_regiment','修改团记录失败');
                        }else{
                            //修改订单
                            $res         =   Orders::query()->where([['id','=',$record['order_id']],['status','=',10]])->update(['status'=>11,'update_time'=>$time]);
                            if (!$res)   Log::error('run_regiment','修改订单失败');
                            $res         =   RegimentRecord::query()->where('regiment_id','=',$v['id'])->update(['status'=>3]);
                            if (!$res)   Log::error('run_regiment','修改团记录失败');
                        }
                    }

                }
                //修改状态
                $res         =   RegimentModel::query()->where('id','=',$v['id'])->update(['status'=>2]);
                if (!$res)   Log::error('run_regiment','修改团状态失败');
            }else{
                RegimentModel::query()->where('id','=',$v['id'])->update(['status'=>3]);
                RegimentRecord::query()->where('regiment_id','=',$v['id'])->update(['status'=>3]);
                //查询记录
                $regimentRecordList  =   regimentRecord::query()->where('regiment_id','=',$v['id'])->get()->toArray();
                if ($regimentRecordList){
                    $regimentRecordListIds = array_column($regimentRecordList,'order_id');
                    //修改订单
                    $res         =   Orders::query()->whereIn('id',$regimentRecordListIds)->update(['status'=>11]);
                    if (!$res)   Log::error('run_regiment','修改团记录失败');
                }
            }
        }
    }
}