baoshi-was/app/Jobs/LogisticSFSync.php

<?php

namespace App\Jobs;

use App\OrderPackage;
use App\Services\LogisticSFService;
use App\Services\LogService;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;

class LogisticSFSync implements ShouldQueue
{
    public $tries = 2;

    public $timeout = 10;

    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    public $logistic_number;

    /**
     * @var LogisticSFService $logisticSFService
     */
    public $logisticSFService;
    public $orderPackageReceivedSyncService;

    /**
     * LogisticSFSync constructor.
     * @param $logistic_number
     */
    public function __construct($logistic_number)
    {
        $this->logistic_number = $logistic_number;
    }


    /**
     * Execute the job.
     *
     * @return void
     * @throws \Exception
     */
    public function handle()
    {
        LogService::log(LogisticSFSync::class, "JOB-SF", $this->logistic_number);
        //标记上有同步的操作
        OrderPackage::query()->where('logistic_number', $this->logistic_number)->update(['sync_routes_flag'=> true]);
        $this->logisticSFService = app('LogisticSFService');
        $formedData = $this->logisticSFService->get([$this->logistic_number]);
        $this->orderPackageReceivedSyncService = app('OrderPackageReceivedSyncService');
        $this->orderPackageReceivedSyncService->update($formedData);
    }
}