push_text(1009,'标题','内容'); dd($rs);*/ (new RechargeJob(124))->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); } }*/ //recharge /*public function plantask(){ $map = [ ['table_name' ,'=', 'gold_recharge'], ['order_status' ,'=', 1], ['plantask_status' ,'=', 0], ]; $list = DB::table('mt_pay_order')->where($map)->orderBy('id','asc')->get()->toArray(); //dd($list); if(!empty($list)){ foreach($list as $key => $val){ $msg_id = $val->id; dispatch((new RechargeJob($msg_id))->delay(0));//加入队列 } //更新 $ids = array_column($list,'id'); $update = [ 'plantask_status' => 1, ]; DB::table('mt_pay_order')->whereIn('id',$ids)->update($update); } }*/ }