LogisticYDSync.php 1.8 KB

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