app-demo/app/Console/Kernel.php

<?php

namespace App\Console;

use App\Models\Address;
use App\Models\Express;
use App\Models\Ordertest;
use App\Models\User;
use Carbon\Carbon;
use Illuminate\Console\Scheduling\Schedule;
use Illuminate\Support\Facades\DB;
use Laravel\Lumen\Console\Kernel as ConsoleKernel;
use Illuminate\Support\Facades\Log;
use mysql_xdevapi\Exception;

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->call(function (){
//            $Address=Address::where('is_deleted',0)->groupBy('mobile','province','address','user_id')->get();
//            foreach ($Address as $k=>$v){
//                $re=Address::where('mobile',$v->mobile)->where('address',$v->address)->orderByDesc('created_at')->where('is_deleted',0)->get(['id'])->toArray();
////                if (count($re)>1){
////                    for ($i=1;$i<count($re);$i++){
////                        Address::where('id',$re[$i]['id'])->update(['is_deleted'=>1]);
////                        Log::error($re[$i]);
////                    }
////                    Log::error(json_encode($re));
////                }
//                Log::error(json_encode($re));
//            }
//        })->everyMinute();

        $schedule->call(function (){
//            DB::table('users')->where('id','>',33249)->whereIn('cert_status',[3,6])->update(['level'=>1]);
//           $data=User::whereIn('cert_status',[3,6])->where('agent_id',null)->get();
//           foreach ($data as $k=>$v){
//              if ($v->level==1){
//                  $level=User::where('id',$v->recom_id)->first();
//                  if ($level->level==1){
//                      DB::table('users')->where('id',$v->id)->update(['agent_id'=>$level->agent_id]);
//                  }else{
//                      DB::table('users')->where('id',$v->id)->update(['agent_id'=>$level->id]);
//                  }
//              }
//           }
//           Log::error('{---处理完成----}');
            $data=User::whereNotIn('level',[0,3])->whereIn('status',[3,6])->get();
            $i=0;
            foreach ($data as $k=>$v){
                if ($v->recom_user->level>$v->level){
                    if ($v->recom_id!=$v->agent_id){
                        $i++;
                        Log::error('____上级不正确___'.$v->mobile);
                    }
                }elseif ($v->recom_user->level=$v->level){
                    if ($v->agent_id!=$v->recom_user->agent_id){
                        Log::error('____上级dengji不正确___'.$v->mobile);
                    }
                }
            }
            Log::error('{--名称-处理完成----}'.$i);
        })->dailyAt('14:52');

        $schedule->call(function (){
           $data=Express::with(['get_order'])->get();
           foreach ($data as $k=>$v){
               $re=Express::find($v->id);
               $re->user_id=$v->get_order->user_id;
               $re->save();
           }
        })->everyMinute();

//        $schedule->call(function (){
//            Log::error('q');
//            $order=Ordertest::where('is_deleted',0)->with(['order_detail','get_pay'=>function($q){
//                $q->whereIn('type',[1,2]);
//            }])->get();
//            foreach ($order as $k=>$v){
//                $money=0;
//                $pay=0;
//                foreach ($v->order_detail as $ke=>$va){
//                    $money+=$va->money;
//                }
//                foreach ($v->get_pay as $ke=>$value){
//                    if ($value->type==1){
//                        $pay+=$value->pay_money;
//                    }else{
//                        $pay-=$value->pay_money;
//                    }
//
//                }
//                if ($pay!=0){
//                    if ($money!=$pay){
//                        if ($pay!=$v->pay_money){
//                            Log::error($v->order_num);
//                        }
//
//                    }
//                }
//
//            }
//        })->everyMinute();

//        $schedule->call(function (){
//            Log::error('{------开始----}');
////
////            $user=DB::table('users')->where('id','>',58)->get();
////            foreach ($user as $k=>$v) {
////                DB::table('users')->where('id',$v->id)->update(['password'=>md5($v->mobile)]);
////            }
////
////            DB::select("truncate table users_copy1");
////            DB::table('users_copy1')->insert(['mobile'=>'15220141101','name'=>'公司-company','nickname'=>'公司-company','level'=>0,'status'=>1,'cert_status'=>6]);
//            $data=DB::table('users')->where('id','>',31076)->get();
////            $data=DB::select("select recom_code FROM users_copy1 GROUP BY recom_code HAVING COUNT(recom_code)>1;");
////            $data=DB::table('app_user')->whereIn('id',['26536'])->get();
////            DB::table('users_copy1')->update(['recom_id'=>null]);
////            $data=DB::table('app_user_copy1')
////                ->where('id','>',61828)
////                ->get();
//            foreach ($data as $k=>$v){
////                Log::error($v->nickanme);
////                $re=DB::table('user_mai')->where('mobile',$v->cellphone)->value('recom_mobile');
////                if ($re){
//                    $phone=DB::table('app_user_copy1_copy1')->where('cellphone',$v->mobile)->value('upper_cellphone');
//                    if ($phone){
//                        $id=DB::table('users')->where('mobile',$phone)->value('id');
//                        if ($id){
//                            DB::table('users')->where('id',$v->id)->update(['agent_id'=>$id]);
//                        }
//                    }
//
//                $phones=DB::table('app_user_copy1_copy1')->where('cellphone',$v->mobile)->value('recom_phone');
//                if ($phones){
//                    $ids=DB::table('users')->where('mobile',$phones)->value('id');
//                    if ($ids){
//                        DB::table('users')->where('id',$v->id)->update(['recom_id'=>$ids]);
//                    }
//                }
////                    if ($id){
////                        DB::table('users_copy1')->where('mobile',$v->cellphone)->update(['recom_id'=>$id]);
////                    }else{
////                        Log::error('{--users--不存在----}'.$v->id);
////                    }
////                }else{
////                    Log::error('{--recom--不存在----}'.$v->id);
////                }
////                if (!$re){
////                    Log::error('{----不存在----}'.$v->id);
////                }
////                $re=DB::table('users_copy1')->where('recom_code',$v->recom_code)->get();
////                foreach ($re as $key=>$val){
////                    $res=code($val->mobile);
////                    DB::table('users_copy1')->where('id',$val->id)->update(['recom_code'=>$res]);
////                }
////                $phone=DB::table('user_mai')->where('mobile','=',$v->upper_cellphone)->value('recom_mobile');
////                if ($phone){
////                    $mobile=DB::table('users_demo')->where('id',$up_phone)->value('mobile');
////                    if ($mobile){
////                        $id=DB::table('users_copy1')->where('mobile',$v->upper_cellphone)->value('id');
////                        if ($id){
////                            DB::table('users_copy1')->where('id',$v->id)->update(['agent_id'=>$id]);
////                        }else{
////                            Log::error('{-------不存在-user_copy1---}'.$v->id);
////                        }
//////                    }
//////                }else{
//////                    Log::error('{-------不存在--user_mai--}'.$v->id);
//////                }
////
////
////////                try {
////                    $re['name']=$v->name;
////                    $re['nickname']=$v->nickname;
////                    $re['realname']=$v->name;
////                    $re['mobile']=$v->cellphone;
////                    $re['cre_num']=$v->identity;
////                    $re['level']=judge_level_name($v->level_name);
//////                    if ($v->level_name=='皇冠代理'){
//////                        $re['agent_id']=1;
//////                    }else{
//////
//////                    }
////                    $re['status']=0;
////                    $re['cert_status']=6;
////                    $re['recom_code']=$this->code($v->cellphone);
////                    $re['province']=$v->province;
////                    $re['city']=$v->city;
////                    $re['country']=$v->area;
////                    $re['headimgurl']='https://img.bosszhipin.com/beijin/mcs/chatphoto/20181102/e0e8b50969101987a84f1643716b41ffcfcd208495d565ef66e7dff9f98764da.jpg';
////                    $re['auth_code']=$this->auth_code($v->cellphone);
//////                    $re['recom_code']=$this->code($v->cellphone);
////                    $re['password']=md5($v->cellphone);
////                    $re['auth_startime']=Carbon::now()->firstOfMonth()->toDateTimeString();
////                    $re['auth_endtime']=Carbon::now()->addYear('1')->firstOfMonth()->toDateTimeString();
////                    if ($v->activation_time){
////                        $re['created_at']=date('Y-m-d H:i:s',strtotime($v->activation_time));
////                        $re['updated_at']=date('Y-m-d H:i:s',strtotime($v->activation_time));
////                    }else{
////                        $re['created_at']=Carbon::now()->toDateTimeString();
////                        $re['updated_at']=Carbon::now()->toDateTimeString();
////                    }
////                $res=DB::table('users')->where('mobile',$v->mobile)->first();
////                if (!$res){
////                    $re['name']=$v->name;
////                    $re['nickname']=$v->nickname;
////                    $re['realname']=$v->realname;
////                    $re['mobile']=$v->mobile;
////                    $re['cre_num']=$v->cre_num;
////                    $re['level']=$v->level;
//////                    if ($v->level_name=='皇冠代理'){
//////                        $re['agent_id']=1;
//////                    }else{
//////
//////                    }
////                    $re['status']=0;
////                    $re['cert_status']=6;
////                    $re['recom_code']=$this->code($v->recom_code);
////                    $re['province']=$v->province;
////                    $re['city']=$v->city;
////                    $re['country']=$v->country;
////                    $re['headimgurl']='https://img.bosszhipin.com/beijin/mcs/chatphoto/20181102/e0e8b50969101987a84f1643716b41ffcfcd208495d565ef66e7dff9f98764da.jpg';
////                    $re['auth_code']=$this->auth_code($v->mobile);
//////                    $re['recom_code']=$this->code($v->cellphone);
////                    $re['password']=$v->password;
////                    $re['auth_startime']=Carbon::now()->firstOfMonth()->toDateTimeString();
////                    $re['auth_endtime']=Carbon::now()->addYear('1')->firstOfMonth()->toDateTimeString();
////                    $re['created_at']=Carbon::now()->toDateTimeString();
////                    $re['updated_at']=Carbon::now()->toDateTimeString();
////                    DB::table('users')->insert($re);
////                }
//
////                    DB::commit();
////                }catch (\Exception $exception){
//////                    DB::rollBack();
////                    Log::error('{-----出错-----}'.$v->id);
////                }
//
//            }
//            Log::error('{----结束----}');
//        })->dailyAt('15:56');
    }

    public function code($phone){
        $data=code($phone);
        $re=DB::table('users')->where('recom_code',$data)->first();
        if ($re){
            $data=$this->code($phone);
            return $data;
        }
        return $data;
    }
    public function auth_code($phone){
        $code_1=str_pad(random_int(1, 999), 3, 0, STR_PAD_LEFT);
        $code_2=mb_substr($phone,1,3);
        $code_3=str_pad(random_int(100, 99999), 6, 0, STR_PAD_LEFT);
        $code_4=mb_substr(time(),8,2);
        $code='DWBS00'.$code_1.date('ymd',time()).$code_2.$code_3.$code_4;
        $re=DB::table('users')->where('auth_code',$code)->first();
        if ($re){
            $code=$this->auth_code($phone);
            return $code;
        }
        return $code;
    }
}