123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657 |
- <?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\GiftJob;
- use App\Jobs\GrabgiftJob;
- use Illuminate\Http\Request;
- class Controller extends BaseController
- {
- use AuthorizesRequests, DispatchesJobs, ValidatesRequests;
- public function grabgift(Request $request){
- $params = $request->all();
- dispatch((new GrabgiftJob($params))->delay(3));//加入队列
- }
- public function test(){
- /*$easemob = new Easemob();
- $rs = $easemob->push_text(1009,'标题','内容');
- dd($rs);*/
- (new GiftJob(8343))->handle();
- }
- public function plantask(){
- $list = DB::table('hx_gift_user_party')->where('new_task_status',0)->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 = [
- 'new_task_status' => 1,
- ];
- DB::table('hx_gift_user_party')->whereIn('id',$ids)->update($update);
- }
- }
|