baoshi-was/app/Jobs/LogisticAliJiSuSync.php

<?php

namespace App\Jobs;

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

class LogisticAliJiSuSync implements ShouldQueue
{
    public $tries = 2;
    public $timeout = 10;

    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    /**
     * @var $logisticAliJiSuApiService LogisticAliJiSuApiService
     * @var $orderPackageReceivedSyncService OrderPackageReceivedSyncService
     * @var $logistic_number string
     */

    protected $logistic_number;
    protected $logisticAliJiSuApiService;
    protected $orderPackageReceivedSyncService;

    /**
     * Create a new job instance.
     *
     * @param $logistic_number
     */
    public function __construct($logistic_number)
    {
        $this->logistic_number=$logistic_number;
    }

    /**
     * Execute the job.
     *
     * @return void
     */
    public function handle()
    {
        LogService::log(LogisticAliJiSuSync::class, "{$this->logistic_number}-JOB-AliJiSu", '');
        //标记上有同步的操作
        OrderPackage::query()->where('logistic_number', $this->logistic_number)->update(['sync_routes_flag'=> true]);

        $this->logisticAliJiSuApiService = app('LogisticAliJiSuApiService');
        try {
            $response = $this->logisticAliJiSuApiService->query($this->logistic_number);
            if ($response && $response->status==0){
                $format = $this->logisticAliJiSuApiService->format($response);
                $this->orderPackageReceivedSyncService = app('OrderPackageReceivedSyncService');
                if (count($format)>0 && $format['logistic_number']??false) $this->orderPackageReceivedSyncService->update([$format]);
            }
        } catch (\Exception $e) {
            app('LogService')->log(__METHOD__, __FUNCTION__, "阿里极速数据同步快递数据 ERROR " . ' || ' . json_encode($this->logistic_number) . ' || ' . json_encode($e->getMessage()) . ' || ' . json_encode($e->getTraceAsString()));
        }
    }
}