Controller.php 1.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657
  1. <?php
  2. namespace App\Http\Controllers;
  3. use Illuminate\Foundation\Auth\Access\AuthorizesRequests;
  4. use Illuminate\Foundation\Bus\DispatchesJobs;
  5. use Illuminate\Foundation\Validation\ValidatesRequests;
  6. use Illuminate\Routing\Controller as BaseController;
  7. //
  8. use Illuminate\Support\Facades\DB;
  9. use App\Jobs\GiftJob;
  10. use App\Jobs\GrabgiftJob;
  11. use Illuminate\Http\Request;
  12. class Controller extends BaseController
  13. {
  14. use AuthorizesRequests, DispatchesJobs, ValidatesRequests;
  15. public function grabgift(Request $request){
  16. $params = $request->all();
  17. dispatch((new GrabgiftJob($params))->delay(3));//加入队列
  18. }
  19. public function test(){
  20. /*$easemob = new Easemob();
  21. $rs = $easemob->push_text(1009,'标题','内容');
  22. dd($rs);*/
  23. (new GiftJob(8343))->handle();
  24. }
  25. public function plantask(){
  26. $list = DB::table('hx_gift_user_party')->where('new_task_status',0)->orderBy('id','asc')->get()->toArray();
  27. //dd($list);
  28. //
  29. if(!empty($list)){
  30. foreach($list as $key => $val){
  31. $msg_id = $val->id;
  32. dispatch((new GiftJob($msg_id))->delay(0));//加入队列
  33. }
  34. }
  35. //更新
  36. $ids = array_column($list,'id');
  37. $update = [
  38. 'new_task_status' => 1,
  39. ];
  40. DB::table('hx_gift_user_party')->whereIn('id',$ids)->update($update);
  41. }
  42. }