baoshi-was/app/Services/OrderPackageReceivedSyncService.php

<?php


namespace App\Services;


use App\OrderPackage;
use Carbon\Carbon;
use Exception;
use Illuminate\Database\Eloquent\Collection;

class OrderPackageReceivedSyncService
{
    protected $logisticSFService;
    protected $logisticZopService;

    /**
     *同步快递信息
     * @throws Exception
     */
    public function syncLogisticRoute()
    {
        $this->update($this->getLogisticRoutes($this->getLogisticNumbers()));
    }

    /**
     * 获取快件揽收信息
     * @param array $request [
     * 'SF' => ['SF1038651915891', 'SF1038651413847', 'SF1038611050071'],
     * 'ZT'=>['75424148714142','548464120822', '75424147834290']
     * ]
     * @return array
     * @throws Exception
     */
    public function getLogisticRoutes(array $request): array
    {
        $this->logisticSFService = new LogisticSFService();
        $this->logisticZopService = new LogisticZopService();
        $resultSF = [];
        $resultZT = [];
        $resultYD = [];
        $resultYT = [];
        $resultOther = [];
        foreach ($request as $key => $logisticNums) {
            switch ($key) {
                case "SF":
                    $resultSF = $this->logisticSFService->get($logisticNums);
                    break;
                case "ZTO":
//                    $resultZT = $this->logisticZopService->get($logisticNums);
                    $resultZT = [];
                    break;
                case "YD":
                    $resultYD = [];
                    break;
                case "YT":
                    $resultYT = [];
                    break;
                default:
                    $resultOther = [];
                    break;
            }
        }
        return array_merge($resultSF, $resultYD, $resultYT, $resultZT, $resultOther);
    }

    public function update(array $orderPackages)
    {
        foreach ($orderPackages as $data) {
            $orderPackage = OrderPackage::query()->where('logistic_number',$data['logistic_number'])->first();
            if (isset($data['status'])) $orderPackage->status = $data['status'];
            if (isset($data['received_at'])) $orderPackage->received_at = $data['received_at'];
            if (isset($data['exception'])) $orderPackage->exception = $data['exception'];
            if (isset($data['transfer_status'])) $orderPackage->transfer_status = $data['transfer_status'];
            $orderPackage->save();
        }
    }

    /**
     * 查询当前日期前的快递单号并按照承运商分类
     */
    public function getLogisticNumbers(): array
    {
        $initDate = Carbon::parse(config('api_logistic.init_date'));
        $data = [];
        $query = OrderPackage::query()
            ->with(['order' => function ($query) {
                return $query->with('logistic');
            }]);
        if (Carbon::now()->gt($initDate)) {
            $query = $query->where('created_at', '>=', $initDate->toDateTimeString()); //大于初始化时间的全部快递单号
        } else {
            $query = $query->where('created_at', '>=', $initDate->subMonths(1)->toDateTimeString()); //初始化查询一个月的数据
        }
        $query = $query
            ->where('exception', '否')
            ->whereNull('received_at');
        return $this->buildData($query->get(), $data);
    }

    /**
     * 将orderPackage集合分类并摘取指定数据
     * @param Collection $orderPackages
     * @param array $data
     * @return array
     */
    private function buildData(Collection $orderPackages, array $data): array
    {
        foreach ($orderPackages as $orderPackage) {
            try {
                $logisticCode = $orderPackage->order->logistic->code;
            } catch (Exception $e) {
                continue;
            }
            $key = config('api_logistic.logistic.' . $logisticCode);
            if (!isset($data[$key])) {
                $data[$key] = [];
            } else {
                $data[$key][] = $orderPackage->logistic_number;
            }
        }
        return $data;
    }
}