OrderHandleJob.php 1.2 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152
  1. <?php
  2. namespace App\Jobs;
  3. use App\Models\Order;
  4. use App\Services\OrderService;
  5. use Illuminate\Bus\Queueable;
  6. use Illuminate\Contracts\Queue\ShouldQueue;
  7. use Illuminate\Foundation\Bus\Dispatchable;
  8. use Illuminate\Queue\InteractsWithQueue;
  9. use Illuminate\Queue\SerializesModels;
  10. class OrderHandleJob implements ShouldQueue
  11. {
  12. use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
  13. protected $order;
  14. /**
  15. * Create a new job instance.
  16. *
  17. * @return void
  18. */
  19. public function __construct($tradeNo)
  20. {
  21. $this->onQueue('order_handle');
  22. $this->order = Order::where('trade_no', $tradeNo)
  23. ->lockForUpdate()
  24. ->first();
  25. }
  26. /**
  27. * Execute the job.
  28. *
  29. * @return void
  30. */
  31. public function handle()
  32. {
  33. if (!$this->order) return;
  34. $orderService = new OrderService($this->order);
  35. switch ($this->order->status) {
  36. // cancel
  37. case 0:
  38. if ($this->order->created_at <= (time() - 1800)) {
  39. $orderService->cancel();
  40. }
  41. break;
  42. case 1:
  43. $orderService->open();
  44. break;
  45. }
  46. }
  47. }