LogisticYDSync.php 1.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657
  1. <?php
  2. namespace App\Jobs;
  3. use App\Services\LogisticYDService;
  4. use App\Services\OrderPackageReceivedSyncService;
  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 LogisticYDSync implements ShouldQueue
  11. {
  12. use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
  13. /**
  14. * @var $logisticYDService LogisticYDService
  15. * @var $orderPackageReceivedSyncService OrderPackageReceivedSyncService
  16. * @var $orderPackageReceivedSyncService OrderPackageReceivedSyncService
  17. * @var $logistic_number string
  18. */
  19. protected $logistic_number;
  20. protected $logisticYDService;
  21. protected $orderPackageReceivedSyncService;
  22. /**
  23. * LogisticYDSync constructor.
  24. * @param $logistic_number
  25. */
  26. public function __construct($logistic_number)
  27. {
  28. $this->logistic_number = $logistic_number;
  29. }
  30. /**
  31. * Execute the job.
  32. *
  33. * @return void
  34. */
  35. public function handle()
  36. {
  37. ini_set('max_execution_time', 60);
  38. $this->logisticYDService = app('LogisticYDService');
  39. //先订阅订单
  40. $this->logisticYDService->registerApi([$this->logistic_number]);
  41. //查询订单路由信息
  42. $nativeResponse = $this->logisticYDService->query($this->logistic_number);
  43. //格式化信息
  44. $formattedData = $this->logisticYDService->format($nativeResponse);
  45. $this->orderPackageReceivedSyncService = app('OrderPackageReceivedSyncService');
  46. //更新数据
  47. $this->orderPackageReceivedSyncService->update([$formattedData]);
  48. }
  49. }