huahuibao/common/components/delivery/platform/shunfeng/CallBackHandler.php

<?php
namespace common\components\delivery\platform\shunfeng;

use bizGhs\express\classes\DeliveryAuthTokenClass;
use bizGhs\express\classes\GhsDeliveryOrderClass;
use bizHd\express\classes\HdDeliveryOrderClass;
use bizGhs\order\classes\OrderClass;
use bizHd\order\classes\OrderClass as HdOrderClass;
use bizHd\purchase\classes\PurchaseClass;
use common\components\util;
use Yii;

/**
 * 顺丰同城回调处理类
 * 处理顺丰平台的各种回调通知
 * 
 * Class CallBackHandler
 * @package common\components\delivery\platform\shunfeng
 */
class CallBackHandler
{
    /**
     * 处理顺丰回调
     * 根据 url_index 参数判断回调类型并分发到对应的处理方法
     * 
     * @param array $data 回调数据
     * @return bool 处理结果
     */
    public function handle($data)
    {
        try {
            // 记录回调原始数据
            Yii::info('顺丰同城回调 - 原始数据: ' . json_encode($data, JSON_UNESCAPED_UNICODE), 'shunfeng-callback');
            
            // 验证必要参数
            if (empty($data['url_index'])) {
                Yii::error('顺丰回调缺少 url_index 参数: ' . json_encode($data, JSON_UNESCAPED_UNICODE), 'shunfeng-callback');
                return false;
            }
            
            $urlIndex = $data['url_index'];
            
            // 根据回调类型分发处理
            switch ($urlIndex) {
                case 'rider_status':
                    // 配送状态更改回调
                    return $this->handleRiderStatus($data);
                    
                case 'order_complete':
                    // 订单完成回调
                    return $this->handleOrderComplete($data);
                    
                case 'sf_cancel':
                    // 顺丰原因取消回调
                    return $this->handleSfCancel($data);
                    
                case 'rider_exception':
                    // 订单异常回调
                    return $this->handleRiderException($data);
                    
                case 'rider_recall':
                    // 骑士撤单回调
                    return $this->handleRiderRecall($data);

                case 'bindnotify':
                    // 授权状态回调
                    return $this->handleBindNotify($data);

                case 'cancelbindnotify':
                    // 取消授权状态回调
                    return $this->handleCancelBindNotify($data);
                    
                default:
                    Yii::warning('未知的顺丰回调类型: ' . $urlIndex, 'shunfeng-callback');
                    return false;
            }
            
        } catch (\Exception $e) {
            Yii::error('顺丰回调处理异常: ' . $e->getMessage() . ' | ' . $e->getTraceAsString(), 'shunfeng-callback');
            return false;
        }
    }
    
    /**
     * 通用订单回调处理逻辑
     * 
     * @param array $data 回调数据
     * @param string $logDesc 日志描述
     * @param string $orderIdField 订单ID字段名
     * @param callable|null $extraHandler 额外处理逻辑，参数为 ($order, $sendStatus, $isGhs)
     * @return bool
     */
    private function processOrderCallback($data, $logDesc, $orderIdField = 'sf_order_id', $extraHandler = null)
    {
        Yii::info($logDesc . ': ' . json_encode($data, JSON_UNESCAPED_UNICODE), 'shunfeng-callback');

        if (empty($data[$orderIdField]) || !isset($data['order_status'])) {
            Yii::error($logDesc . '参数不完整: ' . json_encode($data, JSON_UNESCAPED_UNICODE), 'shunfeng-callback');
            return false;
        }

        $orderId = $data[$orderIdField];
        
        // 查找配送订单
        $deliveryOrder = $this->getDeliveryOrder($orderId);
        if (!$deliveryOrder) {
            Yii::error('顺丰配送订单不存在: ' . $orderIdField . '=' . $orderId, 'shunfeng-callback');
            return false;
        }

        $sendStatus = $this->convertOrderSendStatus($data['order_status']);
        $orderStatus = $this->convertOrderStatus($data['order_status']);

        if ($sendStatus === null) {
            Yii::error('顺丰订单状态转换失败: ' . $data['order_status'], 'shunfeng-callback');
            return false;
        }

        // 更新配送订单
        $deliveryOrder->orderStatus = $sendStatus;
        $deliveryOrder->save();

        // 更新主订单
        if (isset($deliveryOrder->ghsOrderId)) { // 批发
            util::checkRepeatCommit('ghs_' . $deliveryOrder->ghsOrderId . '_' . $sendStatus, 2);
            $order = OrderClass::getById($deliveryOrder->ghsOrderId, true);
            if ($order) {
                $order->sendStatus = $sendStatus;
                $order->status = $orderStatus;
                $order->save();

                if ($extraHandler) {
                    call_user_func($extraHandler, $order, $sendStatus, true);
                }
            }
        } elseif (isset($deliveryOrder->hdOrderId)) { // 零售
            util::checkRepeatCommit('hd_' . $deliveryOrder->hdOrderId . '_' . $sendStatus, 2);
            $order = HdOrderClass::getById($deliveryOrder->hdOrderId, true);
            if ($order) {
                $order->sendStatus = $sendStatus;
                $order->status = $orderStatus;
                $order->save();
                
                if ($extraHandler) {
                    call_user_func($extraHandler, $order, $sendStatus, false);
                }
            }
        }
        
        return true;
    }

    /**
     * 处理配送状态更改回调
     * 状态包括：10-配送员接单/改派；12-配送员到店；15-配送员配送中
     * 
     * @param array $data 回调数据
     * @return bool 处理结果
     */
    private function handleRiderStatus($data)
    {
        return $this->processOrderCallback($data, '顺丰配送状态更改回调', 'sf_order_id', function($order, $sendStatus, $isGhs) {
            if ($isGhs) {
                $cg = PurchaseClass::getById($order->purchaseId, true, 'id,sendStatus');
                $cg->sendStatus = $sendStatus;
                $cg->save();
            }
        });
    }
    
    /**
     * 处理订单完成回调
     * 订单状态：17-配送员点击完成
     * 
     * @param array $data 回调数据
     * @return bool 处理结果
     */
    private function handleOrderComplete($data)
    {
        return $this->processOrderCallback($data, '顺丰订单完成回调', 'sf_order_id', function($order, $sendStatus, $isGhs) {
            if ($isGhs && $sendStatus == 5) {
                OrderClass::confirmReach($order, ['staffId' => 0, 'staffName' => '']);
            }
        });
    }
    
    /**
     * 处理顺丰原因取消回调
     * 订单状态：2-订单取消
     * 
     * @param array $data 回调数据
     * @return bool 处理结果
     */
    private function handleSfCancel($data)
    {
        return $this->processOrderCallback($data, '顺丰取消订单回调', 'sf_order_id', function($order, $sendStatus, $isGhs) {
            if ($isGhs && $sendStatus == -1) {
                OrderClass::cancelOrderSend($order, ['staffId' => 0, 'staffName' => '']);
            }
        });
    }
    
    /**
     * 处理订单异常回调
     * 订单状态：91-骑士上报异常
     * 
     * @param array $data 回调数据
     * @return bool 处理结果
     */
    private function handleRiderException($data)
    {
        return $this->processOrderCallback($data, '顺丰订单异常回调', 'sf_order_id', function($order, $sendStatus, $isGhs) {
            if ($isGhs && $sendStatus == -2) {
                OrderClass::cancelOrderSend($order, ['staffId' => 0, 'staffName' => '']);
            }
        });
    }
    
    /**
     * 处理骑士撤单回调
     * 订单状态：22-配送员撤单
     * 
     * @param array $data 回调数据
     * @return bool 处理结果
     */
    private function handleRiderRecall($data)
    {
        return $this->processOrderCallback($data, '顺丰骑士撤单回调', 'shop_order_id');
    }

    /**
     * 处理顺丰授权成功回调
     *
     * @param array $data
     * @return bool
     */
    private function handleBindNotify($data)
    {
        $sign = Yii::$app->request->get('sign');
        Yii::info('顺丰授权状态回调(sign=' . ($sign ?? '') . '): ' . json_encode($data, JSON_UNESCAPED_UNICODE), 'shunfeng-callback');

        $mainId = isset($data['out_shop_id']) ? (int)$data['out_shop_id'] : 0;
        $shopId = isset($data['shop_id']) ? $data['shop_id'] : '';

        if ($shopId === '') {
            Yii::error('顺丰授权状态回调参数缺失: ' . json_encode($data, JSON_UNESCAPED_UNICODE), 'shunfeng-callback');
            return false;
        }

        $payload = [
            'mainId' => $mainId,
            'platform' => 'shunfeng',
            'shopId' => $shopId,
            'authType' => 'all_store',
            'accessToken' => $data['access_token'] ?? '',
            'refreshToken' => $data['refresh_token'] ?? '',
            'expiresAt' => time() + (100 * 86400 * 365),
        ];

        $existing = DeliveryAuthTokenClass::getByCondition(
            ['mainId' => $mainId, 'platform' => 'shunfeng'],
            false,
            false,
            'id'
        );

        if ($existing && isset($existing['id'])) {
            DeliveryAuthTokenClass::updateById($existing['id'], [
                'shopId' => $payload['shopId'],
                'authType' => $payload['authType'],
                'accessToken' => $payload['accessToken'],
                'refreshToken' => $payload['refreshToken'],
                'expiresAt' => $payload['expiresAt'],
            ]);
        } else {
            DeliveryAuthTokenClass::add($payload);
        }

        return true;
    }

    /**
     * 处理顺丰取消授权回调
     *
     * @param array $data
     * @return bool
     */
    private function handleCancelBindNotify($data)
    {
        $sign = Yii::$app->request->get('sign');
        Yii::info('顺丰取消授权状态回调(sign=' . ($sign ?? '') . '): ' . json_encode($data, JSON_UNESCAPED_UNICODE), 'shunfeng-callback');

        $shopId = isset($data['shop_id']) ? $data['shop_id'] : '';
        if ($shopId === '') {
            Yii::error('顺丰授权状态回调参数缺失: ' . json_encode($data, JSON_UNESCAPED_UNICODE), 'shunfeng-callback');
            return false;
        }

        if (!empty($data['app_id'])) {
            $auth = new Auth();
            if ((string)$auth->getAppKey() !== (string)$data['app_id']) {
                Yii::warning('顺丰取消授权回调 app_id 不匹配: ' . json_encode($data, JSON_UNESCAPED_UNICODE), 'shunfeng-callback');
                return false;
            }
        }

        $condition = [
            'platform' => 'shunfeng',
            'shopId' => $shopId
        ];
        $deleted = DeliveryAuthTokenClass::deleteByCondition($condition);
        if ($deleted === 0) {
            Yii::warning('顺丰取消授权回调未删除任何记录: ' . json_encode($data, JSON_UNESCAPED_UNICODE), 'shunfeng-callback');
        }

        return true;
    }
    
    /**
     * 转换顺丰订单状态到系统配送状态
     * 
     * 顺丰状态说明：
     * - 10: 配送员接单/配送员改派
     * - 12: 配送员到店
     * - 15: 配送员配送中
     * - 17: 配送员点击完成
     * - 2:  订单取消
     * - 22: 配送员撤单
     * - 91: 骑士上报异常
     * 
     * 系统状态说明：
     * - 0:  订单生成
     * - 1:  系统已接单
     * - 2:  派单中
     * - 3:  待取货
     * - 4:  配送中
     * - 5:  已送达
     * - -1: 已取消
     * - -2: 异常
     * - 10: 改派中
     * - 20: 已分配骑手
     * - 30: 骑手已到店
     * - 40: 申请取消中
     * - 50: 客服介入处理中
     * 
     * @param int $sfOrderStatus 顺丰订单状态
     * @return int|null 系统配送状态，null表示不需要更新主订单状态
     */
    private function convertOrderSendStatus($sfOrderStatus)
    {
        // 顺丰状态映射到系统配送状态
        $statusMap = [
            10 => 20,  // 配送员接单/改派 -> 已分配骑手
            12 => 30,  // 配送员到店 -> 骑手已到店
            15 => 4,   // 配送员配送中 -> 配送中
            17 => 5,   // 配送完成 -> 已送达
            2  => -1,  // 订单取消 -> 已取消
            22 => 2,   // 配送员撤单 -> 派单中（重新派单）
            91 => -2,  // 骑士上报异常 -> 异常
        ];
        
        return $statusMap[$sfOrderStatus] ?? null;
    }

    /**
     * 转换顺丰订单状态到系统订单状态
     * 
     * @param int $sfOrderStatus 顺丰订单状态
     * @return int|null 系统订单状态，null表示不需要更新主订单状态
     */
    private function convertOrderStatus($sfOrderStatus)
    {
        // 顺丰状态映射到系统订单状态
        // 系统订单状态: 1待付款 2待配送 3配送中 4已完成 5已取消
        $statusMap = [
            10 => 3,  // 配送员接单/改派  -> 配送中
            12 => 3,  // 配送员到店      -> 配送中
            15 => 3,  // 配送员配送中    -> 配送中
            17 => 4,  // 配送完成 -> 已完成
            2  => 2,  // 订单取消 -> 待配送（配送的取消不等于订单的取消，由于 status 带有配送状态，所以改为：待配送）
            22 => 3,  // 配送员撤单      -> 配送中
            91 => 3,  // 骑士上报异常 -> 配送中
        ];
        
        return $statusMap[$sfOrderStatus] ?? null;
    }

    /**
     * 根据顺丰订单号查找配送订单
     * 
     * @param string $orderId
     * @return object|null
     */
    private function getDeliveryOrder($orderId)
    {
        // 查找批发配送订单
        $deliveryOrder = GhsDeliveryOrderClass::getByCondition([
            'deliveryId' => 'shunfeng',
            'orderId' => $orderId
        ], true);

        if ($deliveryOrder) {
            return $deliveryOrder;
        }

        // 查找零售配送订单
        return HdDeliveryOrderClass::getByCondition([
            'deliveryId' => 'shunfeng',
            'orderId' => $orderId
        ], true);
    }
}