LogisticSFSync.php 1.6 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758
  1. <?php
  2. namespace App\Jobs;
  3. use App\OrderPackage;
  4. use App\Services\LogisticSFService;
  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. class LogisticSFSync implements ShouldQueue
  13. {
  14. public $tries = 2;
  15. public $timeout = 10;
  16. use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
  17. public $logistic_number;
  18. /**
  19. * @var LogisticSFService $logisticSFService
  20. */
  21. public $logisticSFService;
  22. /** @var $orderPackageReceivedSyncService OrderPackageReceivedSyncService */
  23. public $orderPackageReceivedSyncService;
  24. /**
  25. * LogisticSFSync constructor.
  26. * @param $logistic_number
  27. */
  28. public function __construct($logistic_number)
  29. {
  30. $this->logistic_number = $logistic_number;
  31. }
  32. /**
  33. * Execute the job.
  34. *
  35. * @return void
  36. * @throws \Exception
  37. */
  38. public function handle()
  39. {
  40. LogService::log(LogisticSFSync::class, "JOB-SF", $this->logistic_number);
  41. //标记上有同步的操作
  42. OrderPackage::query()->where('logistic_number', $this->logistic_number)->update(['sync_routes_flag'=> true]);
  43. $this->logisticSFService = app('LogisticSFService');
  44. $formedData = $this->logisticSFService->get([$this->logistic_number]);
  45. $this->orderPackageReceivedSyncService = app('OrderPackageReceivedSyncService');
  46. $this->orderPackageReceivedSyncService->update($formedData);
  47. }
  48. }