baoshi-was/app/Jobs/LogisticZopSync.php

<?php

namespace App\Jobs;


use App\OrderPackage;
use App\Services\LogisticZopService;
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 LogisticZopSync implements ShouldQueue
{
    public $tries = 2;
    public $timeout = 10;

    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    /**
     * @var string $logistic_number
     */
    protected $logistic_number;
    /**@var LogisticZopService $logistic_zop_service * */
    protected $logistic_zop_service;
    /**
     * @var  OrderPackageReceivedSyncService $order_package_received_sync_service
     */
    protected $order_package_received_sync_service;

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

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