LogisticAliJiSuSync.php 2.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263
  1. <?php
  2. namespace App\Jobs;
  3. use App\OrderPackage;
  4. use App\Services\LogisticAliJiSuApiService;
  5. use App\Services\LogService;
  6. use App\Services\OrderPackageReceivedSyncService;
  7. use Illuminate\Bus\Queueable;
  8. use Illuminate\Contracts\Queue\ShouldQueue;
  9. use Illuminate\Foundation\Bus\Dispatchable;
  10. use Illuminate\Queue\InteractsWithQueue;
  11. use Illuminate\Queue\SerializesModels;
  12. /**
  13. * @Deprecated 快递路由-阿里极速
  14. */
  15. class LogisticAliJiSuSync implements ShouldQueue
  16. {
  17. public $tries = 2;
  18. public $timeout = 10;
  19. use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
  20. /** @var $logistic_number string */
  21. protected $logistic_number;
  22. /** @var $logisticAliJiSuApiService LogisticAliJiSuApiService */
  23. protected $logisticAliJiSuApiService;
  24. /** @var $orderPackageReceivedSyncService OrderPackageReceivedSyncService */
  25. protected $orderPackageReceivedSyncService;
  26. /**
  27. * Create a new job instance.
  28. *
  29. * @param $logistic_number
  30. */
  31. public function __construct($logistic_number)
  32. {
  33. $this->logistic_number = $logistic_number;
  34. }
  35. /**
  36. * Execute the job.
  37. *
  38. * @return void
  39. */
  40. public function handle()
  41. {
  42. LogService::log(LogisticAliJiSuSync::class, "{$this->logistic_number}-JOB-AliJiSu", '');
  43. //标记上有同步的操作
  44. OrderPackage::query()->where('logistic_number', $this->logistic_number)->update(['sync_routes_flag'=> true]);
  45. $this->logisticAliJiSuApiService = app('LogisticAliJiSuApiService');
  46. $response = $this->logisticAliJiSuApiService->query($this->logistic_number);
  47. $format = $this->logisticAliJiSuApiService->format($response,$this->logistic_number);
  48. try {
  49. $this->orderPackageReceivedSyncService = app('OrderPackageReceivedSyncService');
  50. if (count($format) > 0 && $format['logistic_number'] ?? false) $this->orderPackageReceivedSyncService->update([$format]);
  51. } catch (\Exception $e) {
  52. app('LogService')->log(__METHOD__, __FUNCTION__, "阿里极速数据同步快递数据 ERROR " . ' || ' . json_encode($this->logistic_number) . ' || ' . json_encode($e->getMessage()) . ' || ' . json_encode($e->getTraceAsString()));
  53. }
  54. }
  55. }