api-szy-demo/app/Console/Kernel.php

<?php

namespace App\Console;

use App\Models\Activity;
use App\Models\AuthRole;
use App\Models\Code;
use App\Models\Enroll;
use App\Models\FormUser;
use App\Models\User;
use Carbon\Carbon;
use GuzzleHttp\Client;
use Illuminate\Console\Scheduling\Schedule;
use Illuminate\Foundation\Console\Kernel as ConsoleKernel;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;
use Overtrue\EasySms\EasySms;
use Overtrue\LaravelWeChat\Facade as EasyCaht;

class Kernel extends ConsoleKernel
{
    /**
     * The Artisan commands provided by your application.
     *
     * @var array
     */
    protected $commands = [
        //
    ];

    /**
     * Define the application's command schedule.
     *
     * @param  \Illuminate\Console\Scheduling\Schedule  $schedule
     * @return void
     */
    protected function schedule(Schedule $schedule)
    {
        // $schedule->command('inspire')
        //          ->hourly();
        $schedule->call(function (EasyCaht $facade){
            $avtive=Activity::where('is_new',1)->first();
            $enroll=Enroll::where('season',$avtive->season)->where('time_expire','<',Carbon::now()->toDateTimeString())->where('is_deleted',0)->where('is_pay',0)->get();
//            Log::error(json_encode($enroll));
            foreach ($enroll as $k=>$v){
                Log::error($v->id);
                $res=Enroll::find($v->id);
                $re=$facade->payment()->order->queryByOutTradeNumber($res->enroll_no);
                if (isset($re['transaction_id'])){
                    $res->is_pay=1;
                    $res->trade_no=$re->trade_no;
                    $res->save();
                }else{
                    $res->is_deleted=1;
                    $res->save();
                }
                Log::error('11');
            }
        })->everyMinute();
//        $schedule->call(function (){
//            $data=Enroll::where('is_pay',1)->where('season',45)->where('is_refund',0)->get();
//            $i=1;
//            foreach ($data as $k=>$v){
//                $da[$k]['auth_role']=0;
//                if ($k%10==0){
//                    $i++;
//                }
//                $da[$k]['group']=$i;
//                $da[$k]['user_id']=$v->user_id;
//                $da[$k]['season']=$v->season;
//                $da[$k]['type']=$v->type;
//                $da[$k]['group_name']='第'.$i.'组';
//                $da[$k]['created_at']=Carbon::now();
//                $da[$k]['updated_at']=Carbon::now();
//            }
//            AuthRole::insert($da);
//        })->everyMinute();
//        $schedule->command('RankCommand')->everyFiveMinutes();
//        $schedule->command('LogCommand')->everyMinute();
//        $schedule->command('SendMessageCommand')->everyMinute();

        $schedule->call(function (){
            $data=Enroll::where('is_pay',1)->select('user_id')->groupBy('user_id')->get();
            foreach ($data as $k=>$v){
                $status=false;
                $id_code=FormUser::where('user_id',$v->user_id)->where('form_name','like','%身份证%')->first();
                if ($id_code){
                    $datas[$k]['id_code']=json_decode($id_code->value);
                    $rex="/^[1-9]\d{5}[1-9]\d{3}((0\d)|(1[0-2]))(([0|1|2]\d)|3[0-1])\d{3}([0-9]|X)$/i";
                    if (preg_match($rex,$datas[$k]['id_code'])){
                        $status=true;
                    }
                }
                $datas[$k]['where']='';
                $where=FormUser::where('user_id',$v->user_id)->where('form_name','like','%来自%')->first();
                if ($where){
                    $datas[$k]['where']=json_decode($where->value);
                }
                $datas[$k]['sex']='';
                $sex=FormUser::where('user_id',$v->user_id)->where('form_name','like','%性别%')->first();
                if ($sex){
                    $datas[$k]['sex']=json_decode($sex->value);
                }
                if ($status){
                    if ($datas[$k]['where'] && $datas[$k]['sex']){
                        DB::table('user_copy1')->where('id',$v->user_id)->update(['fill_province'=>$datas[$k]['where'][0],'fill_city'=>$datas[$k]['where'][1],'fill_area'=>$datas[$k]['where'][2],'fill_detail'=>$datas[$k]['where'][3],'fill_sex'=>$datas[$k]['sex'],'fill_code'=>$datas[$k]['id_code']]);
                    }

                }
            }
        })->everyMinute();

    }

    /**
     * Register the commands for the application.
     *
     * @return void
     */
    protected function commands()
    {
        $this->load(__DIR__.'/Commands');

        require base_path('routes/console.php');
    }
}