anxinliao_newlavarel/app/Http/Controllers/Controller.php

<?php

namespace App\Http\Controllers;

use Illuminate\Foundation\Auth\Access\AuthorizesRequests;
use Illuminate\Foundation\Bus\DispatchesJobs;
use Illuminate\Foundation\Validation\ValidatesRequests;
use Illuminate\Routing\Controller as BaseController;

//
use Illuminate\Support\Facades\DB;
use App\Jobs\AudioJob;
use App\Jobs\VideoJob;
use App\Jobs\TypingJob;
use App\Jobs\GiftJob;

class Controller extends BaseController
{
    use AuthorizesRequests, DispatchesJobs, ValidatesRequests;

    public function test(){
        /*$easemob = new Easemob();
        $rs = $easemob->push_text(1009,'标题','内容');
        dd($rs);*/
        (new GiftJob(3))->handle();
    }



    //audio
    /*public function plantask(){

        $map = [
            ['plantask_status', '=' ,0],
            ['updatetime'     , '<' ,time()-300],
        ];
        $list = DB::table('mt_user_match_audio_log')->where($map)->orderBy('id','asc')->get()->toArray();
        //dd($list);

        if(!empty($list)){
            foreach($list as $key => $val){
                $msg_id = $val->id;
                dispatch((new AudioJob($msg_id))->delay(0));//加入队列
            }

            //更新
            $ids = array_column($list,'id');

            $update = [
                'plantask_status' => 1,
            ];

            DB::table('mt_user_match_audio_log')->whereIn('id',$ids)->update($update);
        }

    }*/

    //video
    /*public function plantask(){

        $map = [
            ['plantask_status', '=' ,0],
            ['updatetime'     , '<' ,time()-300],
        ];
        $list = DB::table('mt_user_match_video_log')->where($map)->orderBy('id','asc')->get()->toArray();
        //dd($list);

        if(!empty($list)){
            foreach($list as $key => $val){
                $msg_id = $val->id;
                dispatch((new VideoJob($msg_id))->delay(0));//加入队列
            }

            //更新
            $ids = array_column($list,'id');

            $update = [
                'plantask_status' => 1,
            ];

            DB::table('mt_user_match_video_log')->whereIn('id',$ids)->update($update);
        }

    }*/

    //typing
    /*public function plantask()
    {
        $map = [
            ['plantask_status', '=' ,0]
        ];
        $list = DB::table('mt_user_match_typing_log')->where($map)->orderBy('id','asc')->get()->toArray();
        //dd($list);

        if(!empty($list)){
            foreach($list as $key => $val){
                $msg_id = $val->id;
                dispatch((new TypingJob($msg_id))->delay(0));//加入队列
            }

            //更新
            $ids = array_column($list,'id');

            $update = [
                'plantask_status' => 1,
            ];

            DB::table('mt_user_match_typing_log')->whereIn('id',$ids)->update($update);
        }


    }*/

    //gift
    public function plantask(){
        $map = [
            ['plantask_status', '=' ,0]
        ];
        $list = DB::table('mt_gift_user_typing')->where($map)->orderBy('id','asc')->get()->toArray();
        //dd($list);

        if(!empty($list)){
            foreach($list as $key => $val){
                $msg_id = $val->id;
                dispatch((new GiftJob($msg_id))->delay(0));//加入队列
            }

            //更新
            $ids = array_column($list,'id');

            $update = [
                'plantask_status' => 1,
            ];

            DB::table('mt_gift_user_typing')->whereIn('id',$ids)->update($update);
        }

    }
}