kailin/app/Console/Commands/Regiment.php

<?php

namespace App\Console\Commands;

use App\Facades\Servers\Logs\Log;
use App\Models\Orders;
use App\Models\OrdersProduct;
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){
                foreach ($regiment as $v){
                        //虚拟成团
                       if ($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){
                               $regimentRecordListIds = array_column($regimentRecordList,'order_id');
                               //修改订单
                               $res         =   Orders::query()->whereIn('id',$regimentRecordListIds)->update(['status'=>1,'update_time'=>$time]);
                               if (!$res)   Log::error('run_regiment','修改订单失败');
                               $res         =   OrdersProduct::query()->whereIn('order_id',$regimentRecordListIds)->update(['status'=>1]);
                               if (!$res)   Log::error('run_regiment','修改订单产品失败');
                           }
                           //修改状态
                           $res         =   RegimentModel::query()->where('id','=',$v['id'])->update(['status'=>2]);
                           if (!$res)   Log::error('run_regiment','修改团状态失败');
                           $res         =   RegimentRecord::query()->where('regiment_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','修改订单失败');
                               $res         =   OrdersProduct::query()->whereIn('order_id',$regimentRecordListIds)->update(['status'=>11]);
                               if (!$res)   Log::error('run_regiment','修改订单产品失败');
                           }
                       }
                }
            }
            $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','=',1],['end_time','<=',$time]])->get();
        if ($regimentList){
            foreach ($regimentList as $v){
                $activeList = $Model->query()->where('id','=',$v['active_id'])->first();
                //虚拟成团
                if ($activeList['virtually'] == 0 || $activeList['number'] <= $v['people_number']){
                    //修改状态
                    $r = RegimentModel::query()->where('id','=',$v['id'])->update(['status'=>2]);
                    RegimentRecord::query()->where('regiment_id','=',$v['id'])->update(['status'=>2]);
                    //查询记录
                    $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'=>1]);
                        if (!$res)   Log::error('run_regiment','修改订单失败');
                        $res         =   OrdersProduct::query()->whereIn('order_id',$regimentRecordListIds)->update(['status'=>1]);
                        if (!$res)   Log::error('run_regiment','修改订单产品失败');
                    }
                }else{
                    $r = 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();
                    $regimentRecordListIds = array_column($regimentRecordList,'order_id');
                    //修改订单
                    $res         =   Orders::query()->whereIn('id',$regimentRecordListIds)->update(['status'=>11]);
                    if (!$res)   Log::error('run_regiment','修改订单失败');
                    $res         =   OrdersProduct::query()->whereIn('order_id',$regimentRecordListIds)->update(['status'=>11]);
                    if (!$res)   Log::error('run_regiment','修改订单产品失败');
                }
            }
        }
        Log::log('run_regiment','执行完成');
    }

}