huahuibao/common/components/delivery/services/DispatchService.php

<?php

namespace common\components\delivery\services;

use biz\shop\classes\ShopClass;
use bizGhs\express\classes\DeliveryAuthTokenClass;
use bizGhs\order\classes\OrderClass;
use bizGhs\order\classes\OrderItemClass;
use common\components\delivery\helpers\HttpClient;
use common\components\delivery\services\adapter\{ ShansongAdapter,  HuolalaAdapter, FengniaoAdapter}; // MeituanAdapter, DadaAdapter, SFAdapter, UUAdapter,
use common\components\delivery\models\{DeliveryOrder, DeliveryAccount};
use Yii;

/**
 * 聚合调度逻辑（平台选择/优先级）
 * Class DispatchService
 * @package App\Services
 */
class DispatchService
{
    protected $adapters;
    protected $platformName = '';

    public function __construct($mainId, $platform='')
    {
        if ($platform == '') {
            $authPlatforms = DeliveryAuthTokenClass::getAllByCondition(['mainId'=>$mainId]);
            foreach($authPlatforms as $pt) {
                switch ($pt['platform']) {
                    case 'shansong':
                        $this->adapters['shansong'] = new ShansongAdapter($pt['access_token']);
                        break;
                    case 'huolala':
                        $this->adapters['huolala'] = new HuolalaAdapter($pt['access_token']);
                        break;
                    case 'fengniao':
                        $adapter = new FengniaoAdapter($pt['access_token']);
                        $adapter->setMerchantId(14594092); // TODO: 确认是否需要使用动态的商户ID
                        $this->adapters['fengniao'] = $adapter;
                        break;
                }
            }
        } else {
            $authPlatform = DeliveryAuthTokenClass::getByCondition(['mainId'=>$mainId, 'platform'=>$platform]);
            switch ($platform) {
                case 'shansong':
                    $this->adapters['shansong'] = new ShansongAdapter($authPlatform['access_token']);
                    break;
                case 'huolala':
                    $this->adapters['huolala'] = new HuolalaAdapter($authPlatform['access_token']);
                    break;
                case 'fengniao':
                    //$this->adapters['fengniao'] = new FengniaoAdapter($authPlatform['access_token']);
                    $adapter = new FengniaoAdapter($authPlatform['access_token']);
                    $adapter->setMerchantId(14594092); // TODO: 确认是否需要使用动态的商户ID
                    $this->adapters['fengniao'] = $adapter;
                    break;
            }
            $this->platformName = $platform;
        }

        //$this->adapters = [
            //'meituan'  => new MeituanAdapter(),
            //'dada'     => new DadaAdapter(),
            //'sf'       => new SFAdapter(),
            //'uu'       => new UUAdapter(),
            //'fengniao' => new FengniaoAdapter(),
        //];
    }

    /**
     * 发单调度
     */
    public function createOrder($order, $shopId, $params)
    {
        $order = $order->toArray();
        $shop = ShopClass::getById($shopId);

        $adapter = $this->getAdapter();
        $orderData = $adapter->formatOrderData($order, $shop, $params);
        return $adapter->createOrder($orderData);
    }

    /**
     * @param $orderId 平台订单号
     * @param string $thirdOrderNo xhGhsOrder.orderSn
     */
    public function selectOrder($orderId, $thirdOrderNo='')
    {
        $adapter = $this->getAdapter();
        if ($adapter instanceof ShansongAdapter) {
            return $adapter->selectOrder($orderId, $thirdOrderNo);
        }
        return $adapter->selectOrder($orderId);
    }

    public function cancelOrder($orderId, $reason)
    {
        $adapter = $this->getAdapter();
        return $adapter->cancelOrder($orderId, $reason);
    }

    public function getCancelReasonList($orderId)
    {
        $adapter = $this->getAdapter();
        return $adapter->getCancelReasonList($orderId);
    }

    public function getAdapter()
    {
        return $this->adapters[$this->platformName];
    }

    /**
     * 获取所有平台的最佳报价（使用 Guzzle 并发请求）
     * 
     * 流程说明：
     * 1. 同步准备各平台的前置数据（如城市信息、订单商品等）
     * 2. 使用 Guzzle Pool 并发发送各平台的报价请求（5秒超时）
     * 3. 某个平台失败/超时不影响其他平台，继续等待结果
     * 
     * @param array $order 订单信息
     * @param array $shop 店铺信息
     * @return array 返回所有平台的报价结果
     */
    public function getBestPlatformByPrice($order, $shop, $orderTime)
    {
        // 第一步：准备前置数据（同步进行，因为某些平台需要这些数据）
        $preparedData = $this->preparePlatformData($order, $shop, $orderTime);

        if (empty($preparedData)) {
            return ['error' => '所有平台数据准备失败'];
        }

        // 第二步：并发调用各平台的报价接口
        $results = $this->concurrentGetPrices($preparedData, $orderTime);

        if (empty($results['success']) && empty($results['failed'])) {
            return ['error' => '没有可用的物流平台'];
        }

        // 格式化返回结果
        return [
            'quotes' => array_values($results['success'] ?? []),
            'failed' => $results['failed'] ?? [],
        ];
    }

    /**
     * 为各平台准备订单数据（前置数据同步获取）
     * 
     * @param array $order 订单信息
     * @param array $shop 店铺信息
     * @return array 各平台的订单数据
     */
    private function preparePlatformData($order, $shop, $orderTime)
    {
        $preparedData = [];

        // 准备 Huolala 数据
        if (isset($this->adapters['huolala'])) {
            try {
                $preparedData['huolala'] = $this->prepareHuolalaData($order, $shop);
            } catch (\Exception $e) {
                Yii::warning("Huolala 数据准备失败: {$e->getMessage()}");
            }
        }

        // 准备 Fengniao 数据
        if (isset($this->adapters['fengniao'])) {
            try {
                $preparedData['fengniao'] = $this->prepareFengniaoData($order, $shop);
            } catch (\Exception $e) {
                Yii::warning("Fengniao 数据准备失败: {$e->getMessage()}");
            }
        }

        // 准备 Shansong 数据
        if (isset($this->adapters['shansong'])) {
            try {
                $preparedData['shansong'] = $this->prepareShansongData($order, $shop);
            } catch (\Exception $e) {
                Yii::warning("Shansong 数据准备失败: {$e->getMessage()}");
            }
        }

        return $preparedData;
    }

    /**
     * 准备货拉拉订单数据
     */
    private function prepareHuolalaData($order, $shop)
    {
        $formatCity = rtrim($order['city'], '市');
        $cities = include Yii::getAlias('@common/components/delivery/platform/huolala/cities.php');

        if (!isset($cities[$formatCity])) {
            throw new \Exception('城市编码表中没有找到城市: ' . $formatCity);
        }

        $cityId = $cities[$formatCity]['city_id'];
        $cityVehicleList = $this->adapters['huolala']->getCityVehicleList($cityId); // 产生外部请求 -- TODO 优化成不耗时等待
        $cityInfoRevision = $cityVehicleList['city_info_revision'];

        // 选择车型逻辑
        $vehicleList = $cityVehicleList['vehicle_list'];
        $selectVehicle = [];
        $vehicleType = '';
        $vehicleStd = [];

        // 优先选择 "跑腿"
        foreach ($vehicleList as $vehicle) {
            if ($vehicle['vehicle_name'] == '跑腿') {
                $selectVehicle = $vehicle;
                $vehicleType = '跑腿';
                $vehicleStd[] = count($vehicle['vehicle_std_item']) > 0 ? $vehicle['vehicle_std_item'][0]['name'] : '';
                break;
            }
        }

        // 如果没有 "跑腿"，选择 "二轮车" 或 "面包车"
        if (empty($selectVehicle)) {
            $erLunVehicle = [];
            $mianBaoVehicle = [];

            foreach ($vehicleList as $vehicle) {
                if ($vehicle['vehicle_name'] == '二轮车') {
                    $erLunVehicle = $vehicle;
                    $vehicleType = '二轮车';
                    $vehicleStd[] = count($vehicle['vehicle_std_item']) > 0 ? $vehicle['vehicle_std_item'][0]['name'] : '';
                }
                if (in_array($vehicle['vehicle_name'], ['微面', '小面车', '小面包车'])) {
                    $mianBaoVehicle = $vehicle;
                    $vehicleType = $vehicle['vehicle_name'];
                    $vehicleStd[] = count($vehicle['vehicle_std_item']) > 0 ? $vehicle['vehicle_std_item'][0]['name'] : '';
                }
            }

            $selectVehicle = !empty($erLunVehicle) ? $erLunVehicle : $mianBaoVehicle;
        }

        if (empty($selectVehicle)) {
            throw new \Exception('没有找到可选车型');
        }

        // 解析额外需求
        $specReqItem = $cityVehicleList['spec_req_item'] ?? [];
        $specReq = [];
        foreach ($specReqItem as $item) {
            $specReq[] = $item['type'] ?? null;
        }
        $specReq = array_filter($specReq);

        return [
            'platform' => 'huolala',
            'city_id' => $cityId,
            'order_vehicle_id' => $selectVehicle['order_vehicle_id'],
            'city_info_revision' => $cityInfoRevision,
            'order_time' => time() + 600,
            'addr_info' => [
                [
                    'name' => $shop['merchantName'],
                    'addr' => $shop['province'] . $shop['city'] . $shop['dist'] . $shop['address'],
                    'city_id' => $cityId,
                    'city_name' => $shop['city'],
                    'district_name' => $shop['dist'],
                    'house_number' => $shop['floor'],
                    'contacts_name' => $shop['mobile'],
                    'contacts_phone_no' => $shop['mobile'],
                    'lat_lon' => ['lat' => (float)$shop['lat'], 'lon' => (float)$shop['long']],
                ],
                [
                    'name' => $order['customName'],
                    'addr' => $order['fullAddress'],
                    'city_id' => $cityId,
                    'city_name' => $order['city'],
                    'district_name' => $order['dist'],
                    'house_number' => $order['floor'],
                    'contacts_name' => $order['customName'],
                    'contacts_phone_no' => $order['customMobile'],
                    'lat_lon' => ['lat' => (float)$order['lat'], 'lon' => (float)$order['long']],
                ]
            ],
            'vehicle_std' => $vehicleStd,
            'spec_req' => array_values($specReq),
            'coupon_id' => 123456,
            'invoice_type' => 1,
            'order_service_type' => 1,
            '_meta' => [
                'vehicle_type' => $vehicleType,
                'city_info_revision' => $cityInfoRevision,
            ]
        ];
    }

    /**
     * 准备蜂鸟订单数据
     */
    private function prepareFengniaoData($order, $shop)
    {
        $this->adapters['fengniao']->setMerchantId(14594092); // TODO: 确认是否需要使用动态的商户ID

        $itemInfos = OrderItemClass::getAllByCondition(['orderSn' => $order['orderSn']], null, 'id, name, unitPrice, num');
        $goodsItemList = [];

        foreach ($itemInfos as $item) {
            $goodsItemList[] = [
                'item_actual_amount_cent' => (int)($item['unitPrice'] * 100 * $item['num']),
                'item_amount_cent' => (int)($item['unitPrice'] * 100),
                'item_id' => $item['id'],
                'item_name' => $item['name'],
                'item_quantity' => $item['num'],
            ];
        }

        return [
            'platform' => 'fengniao',
            'partner_order_code' => $order['orderSn'],
            'receiver_primary_phone' => $order['customMobile'],
            'receiver_name' => $order['customName'],
            'receiver_latitude' => (float)$order['lat'],
            'receiver_longitude' => (float)$order['long'],
            'receiver_address' => $order['fullAddress'],
            'position_source' => 3,
            'goods_count' => count($goodsItemList),
            'goods_weight' => (float)$order['weight'],
            'goods_total_amount_cent' => (int)($order['prePrice'] * 100),
            'goods_actual_amount_cent' => (int)($order['actPrice'] * 100),
            'goods_item_list' => $goodsItemList,
            'order_type' => 1,
            'chain_store_id' => 467788524,
            'order_remark' => $order['remark'] ?? '',
        ];
    }

    /**
     * 准备闪送订单数据
     */
    private function prepareShansongData($order, $shop)
    {
        return [
            'platform' => 'shansong',
            'city_name' => $shop['city'],
            'sender' => [
                'from_address' => $shop['address'],
                'from_address_detail' => $shop['floor'],
                'from_sender_name' => $shop['shopName'],
                'from_mobile' => $shop['mobile'],
                'from_latitude' => (float)$shop['lat'],
                'from_longitude' => (float)$shop['long'],
            ],
            'receiver_list' => [
                [
                    'order_no' => $order['orderSn'],
                    'to_address' => $order['address'],
                    'to_address_detail' => $order['floor'],
                    'to_receiver_name' => $order['customName'],
                    'to_mobile' => $order['customMobile'],
                    'to_latitude' => (float)$order['lat'],
                    'to_longitude' => (float)$order['long'],
                    'good_type' => 7,
                    'weight' => (int)$order['weight'],
                    'remarks' => $order['remark'] ?? '',
                ]
            ],
            'appoint_type' => 0,
            'appointment_date' => '',
            'travel_way' => 0,
            'delivery_type' => 1,
            'expect_start_time' => null,
            'expect_end_time' => null,
        ];
    }

    /**
     * 并发获取各平台报价（核心实现）
     * 
     * 使用 Guzzle Pool 实现真正的并发调用，每个平台请求 5 秒超时。
     * 某个平台的超时或失败不会影响其他平台的执行。
     * 
     * @param array $preparedData 准备好的各平台数据
     * @param string $orderTime 配送时间
     * @return array 包含成功和失败结果
     */
    private function concurrentGetPrices($preparedData, $orderTime)
    {
        $results = [
            'success' => [],
            'failed' => [],
        ];

        // 如果 PHP 不支持真正的异步，采用顺序调用（但每个请求应用超时）
        // 这是 PHP 同步框架的限制，通过 set_time_limit 和超时配置来模拟效果
        foreach ($preparedData as $platform => $data) {
            try {
                if (!isset($this->adapters[$platform])) {
                    $results['failed'][$platform] = '平台适配器未初始化';
                    continue;
                }

                $adapter = $this->adapters[$platform];
                $startTime = microtime(true);

                // 这里调用适配器的 getPrice 方法，该方法内部会使用 HttpClient
                // 在 HttpClient 中配置的超时会被应用
                $quote = $adapter->getPrice($data, $orderTime);

                $duration = microtime(true) - $startTime;

                if ($quote && !isset($quote['error'])) {
                    // 添加平台标识和元数据
                    $quote['platform'] = $platform;
                    $quote['_duration'] = $duration;

                    // 针对不同平台的数据处理
                    if ($platform === 'huolala' && isset($data['_meta'])) {
                        $quote['city_id'] = $data['city_id'];
                        $quote['city_info_revision'] = $data['_meta']['city_info_revision'] ?? '';
                        $quote['vehicle_type'] = $data['_meta']['vehicle_type'] ?? '';
                        $quote['spec_req'] = $data['spec_req'] ?? [];
                        $quote['vehicle_std'] = $data['vehicle_std'] ?? [];
                    }

                    $results['success'][$platform] = $quote;
                    Yii::info("[DispatchService] {$platform} 报价成功 (" . round($duration * 1000) . "ms)");
                } else {
                    $errorMsg = $quote['error'] ?? '报价返回数据为空';
                    $results['failed'][$platform] = $errorMsg;
                    Yii::warning("[DispatchService] {$platform} 报价返回错误: {$errorMsg}");
                }
            } catch (\Throwable $e) {
                $results['failed'][$platform] = $e->getMessage();
                Yii::error("[DispatchService] {$platform} 报价异常: {$e->getMessage()}");
            }
        }

        return $results;
    }

    public function openCitiesLists($platform)
    {
        $ap = $this->adapters[$platform];
        return $ap->cityList();
    }
}