<?php

namespace RiderApi\Controller;

/**
 * 骑手端订单控制器
 */
class OrderController extends BaseController
{

    /**
     * 获取可接订单列表
     */
    public function getAvailableOrders()
    {
        $riderId = $this->riderId;
        $rider = $this->riderInfo;
        $lat = $this->getRequestParam('lat', 0);
        $lng = $this->getRequestParam('lng', 0);
        $page = $this->getRequestParam('page', 1);
        $limit = $this->getRequestParam('limit', 30);

        if (!$rider || $rider['status'] != 1) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '骑手状态异常'));
        }

        if ($rider['auth_status'] != 2) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '请先完成实名认证'));
        }

        // 获取待接单的订单
        $orderModel = M('rider_order');
        $where = array(
            'ro.order_status' => 0, // 待接单
            'ro.rider_id' => 0
        );

        // 如果骑手绑定了店铺，则只显示该店铺的订单
        if (isset($rider['store_id']) && intval($rider['store_id']) > 0) {
            $where['ro.store_id'] = intval($rider['store_id']);
        }

        $offset = ($page - 1) * $limit;
        $list = $orderModel->alias('ro')
            ->join('LEFT JOIN ls_retail_bill_order bo ON ro.bill_id = bo.id')
            ->field('ro.*, bo.all_money as order_amount')
            ->where($where)
            ->order('ro.add_time DESC')
            ->limit($offset, $limit)
            ->select();

        $total = $orderModel->alias('ro')->where($where)->count();

        // 计算距离（简化处理）
        foreach ($list as &$item) {
            if ($lat && $lng && $item['store_lat'] && $item['store_lng']) {
                $item['distance_to_store'] = $this->calculateDistance($lat, $lng, $item['store_lat'], $item['store_lng']);
            } else {
                $item['distance_to_store'] = 0;
            }

            // 确保order_amount字段存在，如果没有则设为0
            if (!isset($item['order_amount']) || $item['order_amount'] === null) {
                $item['order_amount'] = '0.00';
            }
        }

        $this->ajaxReturn(array(
            'code' => 1,
            'msg' => '获取成功',
            'data' => array(
                'list' => $list,
                'total' => $total,
                'page' => $page,
                'limit' => $limit
            )
        ));
    }

    /**
     * 接受订单
     */
    public function acceptOrder()
    {
        $riderId = $this->riderId;
        $rider = $this->riderInfo;

        $contentType = '';
        if (isset($_SERVER['CONTENT_TYPE'])) {
            $contentType = $_SERVER['CONTENT_TYPE'];
        }

        // 使用统一的参数处理方法
        $orderId = intval($this->getRequestParam('order_id', 0));

        if (empty($orderId)) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '订单ID不能为空'));
        }

        if (!$rider || $rider['status'] != 1) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '骑手状态异常'));
        }

        if ($rider['work_status'] != 1) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '请先上线'));
        }

        // 检查订单状态
        $orderModel = M('rider_order');
        $order = $orderModel->find($orderId);

        if (!$order) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '订单不存在'));
        }

        if ($order['order_status'] != 0) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '订单已被接取'));
        }

        // 生成取餐码
        $pickupCode = $this->generatePickupCode();

        // 更新订单状态
        $data = array(
            'rider_id' => $riderId,
            'order_status' => 1, // 已接单
            'accept_time' => date('Y-m-d H:i:s'),
            'update_time' => date('Y-m-d H:i:s'),
            'pickup_code' => $pickupCode
        );

        $result = $orderModel->where(array('id' => $orderId))->save($data);

        if ($result !== false) {
            $riderModel = M('rider_info');
            // 更新骑手状态为忙碌
            $riderModel->where(array('id' => $riderId))->save(array('work_status' => 2));

            // 同步原始订单状态为已发货
            if (!empty($order['bill_id'])) {
                $billOnlineModel = M('retail_bill_online');
                $billOnline = $billOnlineModel->where(array('bill_id' => $order['bill_id']))->find();
                if ($billOnline && $billOnline['status'] != 2 && $billOnline['status'] != 3) {
                    // 如果订单状态不是已发货也不是已完成，则更新为已发货
                    $billOnlineModel->where(array('bill_id' => $order['bill_id']))->save(array(
                        'status' => 2, // 已发货
                        'send_time' => date('Y-m-d H:i:s'),
                        'update_time' => date('Y-m-d H:i:s')
                    ));
                }
            }

            $this->ajaxReturn(array(
                'code' => 1,
                'msg' => '接单成功',
                'data' => array(
                    'order_id' => $orderId,
                    'order_no' => $order['order_no'],
                    'pickup_code' => $pickupCode
                )
            ));
        } else {
            $this->ajaxReturn(array('code' => 0, 'msg' => '接单失败'));
        }
    }

    /**
     * 自动接单核心逻辑
     */
    public function autoAcceptOrder()
    {
        $riderId = $this->riderId;
        $rider = $this->riderInfo;

        if (!$rider || $rider['status'] != 1) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '骑手状态异常'));
        }

        if ($rider['work_status'] != 1) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '请先上线'));
        }

        // 检查是否开启自动接单
        if ($rider['auto_accept_order'] != 1) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '未开启自动接单'));
        }

        // 检查当前时间是否在自动接单时间段内
        $currentTime = date('H:i');
        $currentWeekday = date('w') ?: 7; // 0为周日，转换为7

        $startTime = $rider['auto_accept_start_time'] ?: '00:00';
        $endTime = $rider['auto_accept_end_time'] ?: '23:59';

        // 从工作时间表获取工作日设置
        $workTimeModel = M('rider_work_time');
        $workTimes = $workTimeModel->where(array('rider_id' => $rider['rider_id']))->select();

        $workDays = array();
        if ($workTimes) {
            foreach ($workTimes as $workTime) {
                if ($workTime['is_work'] == 1) {
                    // 将数据库中的week_day（0-6）转换为标准格式（1-7）
                    $workDays[] = $workTime['week_day'] == 0 ? 7 : $workTime['week_day'];
                }
            }
        }

        // 如果没有设置工作时间，默认全周工作
        if (empty($workDays)) {
            $workDays = array(1, 2, 3, 4, 5, 6, 7);
        }

        if (!in_array($currentWeekday, $workDays)) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '当前不在自动接单工作日内'));
        }

        if ($currentTime < $startTime || $currentTime > $endTime) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '当前不在自动接单时间段内'));
        }

        // 检查当前接单数量是否已达上限
        $orderModel = M('rider_order');
        $currentOrderCount = $orderModel->where(array(
            'rider_id' => $riderId,
            'order_status' => array('in', '1,2,3,4,5') // 已接单到配送中
        ))->count();

        $maxOrders = intval($rider['max_orders_per_time']) ?: 3;
        if ($currentOrderCount >= $maxOrders) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '当前接单数量已达上限'));
        }

        // 获取符合条件的订单
        $suitableOrders = $this->getSuitableOrders($rider);

        if (empty($suitableOrders)) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '暂无符合条件的订单'));
        }

        // 自动接单（选择第一个符合条件的订单）
        $order = $suitableOrders[0];
        $orderId = $order['id'];

        // 更新订单状态
        $data = array(
            'rider_id' => $riderId,
            'order_status' => 1, // 已接单
            'accept_time' => date('Y-m-d H:i:s'),
            'update_time' => date('Y-m-d H:i:s'),
            'auto_accepted' => 1 // 标记为自动接单
        );

        $result = $orderModel->where(array('id' => $orderId))->save($data);

        if ($result !== false) {
            $riderModel = M('rider_info');
            // 更新骑手状态为忙碌
            $riderModel->where(array('id' => $riderId))->save(array('work_status' => 2));

            // 同步原始订单状态为已发货
            if (!empty($order['bill_id'])) {
                $billOnlineModel = M('retail_bill_online');
                $billOnline = $billOnlineModel->where(array('bill_id' => $order['bill_id']))->find();
                if ($billOnline && $billOnline['status'] != 2 && $billOnline['status'] != 3) {
                    // 如果订单状态不是已发货也不是已完成，则更新为已发货
                    $billOnlineModel->where(array('bill_id' => $order['bill_id']))->save(array(
                        'status' => 2, // 已发货
                        'send_time' => date('Y-m-d H:i:s'),
                        'update_time' => date('Y-m-d H:i:s')
                    ));
                }
            }

            $this->ajaxReturn(array(
                'code' => 1,
                'msg' => '自动接单成功',
                'data' => array(
                    'order_id' => $orderId,
                    'order_no' => $order['order_no'],
                    'delivery_fee' => $order['delivery_fee'],
                    'distance' => $order['distance_to_store']
                )
            ));
        } else {
            $this->ajaxReturn(array('code' => 0, 'msg' => '自动接单失败'));
        }
    }

    /**
     * 获取符合自动接单条件的订单
     */
    private function getSuitableOrders($rider)
    {
        $riderId = $rider['id'];
        $lat = $rider['current_lat'] ?: 0;
        $lng = $rider['current_lng'] ?: 0;

        // 基础查询条件
        $orderModel = M('rider_order');
        $where = array(
            'order_status' => 0, // 待接单
            'rider_id' => 0
        );

        // 如果骑手绑定了店铺，则只获取该店铺的订单
        if (isset($rider['store_id']) && intval($rider['store_id']) > 0) {
            $where['store_id'] = intval($rider['store_id']);
        }

        // 获取所有待接单订单
        $orders = $orderModel->where($where)->order('add_time DESC')->select();

        $suitableOrders = array();

        foreach ($orders as $order) {
            // 检查配送费是否符合要求
            $minDeliveryFee = floatval($rider['min_delivery_fee']) ?: 0;
            if ($order['delivery_fee'] < $minDeliveryFee) {
                continue;
            }

            // 检查距离是否符合要求
            if ($lat && $lng && $order['store_lat'] && $order['store_lng']) {
                $distance = $this->calculateDistance($lat, $lng, $order['store_lat'], $order['store_lng']);
                $order['distance_to_store'] = $distance;

                $maxDistance = floatval($rider['max_distance']) ?: 50;
                if ($distance > $maxDistance) {
                    continue;
                }
            } else {
                $order['distance_to_store'] = 0;
            }

            // 检查订单类型是否符合要求
            $acceptOrderTypes = $rider['accept_order_types'] ? explode(',', $rider['accept_order_types']) : array('1', '2', '3');
            if (!in_array($order['order_type'], $acceptOrderTypes)) {
                continue;
            }

            // 检查商家评分是否符合要求
            if ($rider['reject_low_rating_store'] == 1) {
                $minStoreRating = floatval($rider['min_store_rating']) ?: 0;
                if ($order['store_rating'] < $minStoreRating) {
                    continue;
                }
            }

            $suitableOrders[] = $order;
        }

        // 按距离排序，优先接近的订单
        usort($suitableOrders, function ($a, $b) {
            if ($a['distance_to_store'] == $b['distance_to_store']) {
                return 0;
            }
            return ($a['distance_to_store'] < $b['distance_to_store']) ? -1 : 1;
        });

        return $suitableOrders;
    }

    /**
     * 获取骑手当前订单
     */
    public function getCurrentOrder()
    {
        $riderId = $this->riderId;

        $orderModel = M('rider_order');
        $order = $orderModel->where(array(
            'rider_id' => $riderId,
            'order_status' => array('in', '1,2,3,4,5') // 已接单到配送中
        ))->find();

        if (!$order) {
            $this->ajaxReturn(array(
                'code' => 1,
                'msg' => '暂无进行中的订单',
                'data' => null
            ));
        }

        $this->ajaxReturn(array(
            'code' => 1,
            'msg' => '获取成功',
            'data' => $order
        ));
    }

    /**
     * 更新订单状态
     */
    public function updateOrderStatus()
    {
        $riderId = $this->riderId;

        // 初始化变量
        $orderId = 0;
        $status = 0;
        $lat = 0;
        $lng = 0;

        // 使用统一的参数处理方法
        $orderId = intval($this->getRequestParam('order_id', 0));
        $statusParam = $this->getRequestParam('status', '');
        $lat = floatval($this->getRequestParam('lat', 0));
        $lng = floatval($this->getRequestParam('lng', 0));
        
        // 获取送达时的额外参数
        $params = $this->getRequestParam('params', array());
        if (is_string($params)) {
            $params = json_decode($params, true) ?: array();
        }

        // 处理状态参数，支持字符串和数字
        $status = $this->convertStatusToNumber($statusParam);

        if (empty($orderId)) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '订单ID不能为空'));
        }

        if ($status === false || ($status === 0 && empty($statusParam))) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '状态参数无效'));
        }

        // 检查订单归属
        $orderModel = M('rider_order');
        $order = $orderModel->where(array('id' => $orderId, 'rider_id' => $riderId))->find();

        if (!$order || $order['rider_id'] != $riderId) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '订单不存在或无权限'));
        }

        // 检查订单是否已取消
        $currentStatus = intval($order['order_status']);
        if ($currentStatus == 8) {
            // 订单已取消，恢复骑手为在线状态
            $riderModel = M('rider_info');
            $riderModel->where(array('id' => $riderId))->save(array('work_status' => 1));
            
            $this->ajaxReturn(array(
                'code' => -1, // 特殊错误码表示订单已取消
                'msg' => '该订单已被取消，无法继续操作',
                'data' => array(
                    'order_id' => $orderId,
                    'cancel_reason' => $order['cancel_reason'] ?: '订单已取消',
                    'cancel_time' => $order['cancel_time']
                )
            ));
        }

        // 检查订单状态流转是否合法

        if (!$this->isValidStatusTransition($currentStatus, $status)) {
            $statusNames = array(
                0 => '待接单',
                1 => '已接单',
                2 => '前往商家',
                3 => '已到店',
                4 => '已取餐',
                5 => '配送中',
                6 => '已送达',
                7 => '异常',
                8 => '已取消'
            );
            $currentStatusName = isset($statusNames[$currentStatus]) ? $statusNames[$currentStatus] : '未知';
            $targetStatusName = isset($statusNames[$status]) ? $statusNames[$status] : '未知';

            $this->ajaxReturn(array(
                'code' => 0,
                'msg' => "订单当前状态为【{$currentStatusName}】，无法变更为【{$targetStatusName}】"
            ));
        }

        $data = array(
            'order_status' => $status,
            'update_time' => date('Y-m-d H:i:s')
        );

        $statusMsg = '';

        switch ($status) {
            case 2: // 前往商家
                $statusMsg = '前往商家';
                break;
            case 3: // 已到店
                $data['arrive_store_time'] = date('Y-m-d H:i:s');
                $statusMsg = '已到店';
                break;
            case 4: // 已取餐
                // 设置取餐时间
                if (isset($params['pickup_time']) && !empty($params['pickup_time'])) {
                    $data['pickup_time'] = date('Y-m-d H:i:s', strtotime($params['pickup_time']));
                } else {
                    $data['pickup_time'] = date('Y-m-d H:i:s');
                }
                
                // 处理取餐照片
                if (isset($params['pickup_photos']) && !empty($params['pickup_photos'])) {
                    if (is_array($params['pickup_photos'])) {
                        $data['pickup_photos'] = implode(',', $params['pickup_photos']);
                    } else {
                        $data['pickup_photos'] = $params['pickup_photos'];
                    }
                }
                
                // 处理商品核对信息
                if (isset($params['goods_checked']) && !empty($params['goods_checked'])) {
                    $checkedGoods = array();
                    if (is_array($params['goods_checked'])) {
                        foreach ($params['goods_checked'] as $goods) {
                            if (isset($goods['id']) && isset($goods['checked'])) {
                                $checkedGoods[] = array(
                                    'id' => $goods['id'],
                                    'checked' => $goods['checked'] ? 1 : 0
                                );
                            }
                        }
                    }
                    
                    if (!empty($checkedGoods)) {
                        $data['goods_check_result'] = json_encode($checkedGoods);
                    }
                }
                
                $statusMsg = '已取餐';
                break;
            case 5: // 配送中
                $statusMsg = '配送中';
                break;
            case 6: // 已送达
                // 设置送达时间
                if (isset($params['delivery_time']) && !empty($params['delivery_time'])) {
                    $data['delivery_time'] = date('Y-m-d H:i:s', strtotime($params['delivery_time']));
                } else {
                    $data['delivery_time'] = date('Y-m-d H:i:s');
                }
                
                // 处理送达照片
                if (isset($params['delivery_photos']) && !empty($params['delivery_photos'])) {
                    if (is_array($params['delivery_photos'])) {
                        $data['delivery_receipt_photos'] = implode(',', $params['delivery_photos']);
                    } else {
                        $data['delivery_receipt_photos'] = $params['delivery_photos'];
                    }
                }
                
                // 处理送达方式和备注
                if (isset($params['delivery_method']) && !empty($params['delivery_method'])) {
                    $deliveryMethods = array(
                        'hand_delivery' => '面对面交付',
                        'contactless' => '无接触配送',
                        'doorman' => '交给门卫/前台'
                    );
                    $methodText = isset($deliveryMethods[$params['delivery_method']]) 
                        ? $deliveryMethods[$params['delivery_method']] 
                        : $params['delivery_method'];
                    $data['delivery_receipt_remark'] = $methodText;
                }
                
                // 处理支付方式（货到付款）
                if (isset($params['payment_method']) && !empty($params['payment_method'])) {
                    $paymentMethods = array(
                        'cash' => '现金支付',
                        'wechat' => '微信支付',
                        'alipay' => '支付宝支付',
                        'card' => '刷卡支付'
                    );
                    $paymentText = isset($paymentMethods[$params['payment_method']]) 
                        ? $paymentMethods[$params['payment_method']] 
                        : $params['payment_method'];
                    
                    // 如果有支付方式，添加到备注中
                    if (!empty($data['delivery_receipt_remark'])) {
                        $data['delivery_receipt_remark'] .= '，' . $paymentText;
                    } else {
                        $data['delivery_receipt_remark'] = $paymentText;
                    }
                }
                
                // 处理支付确认状态
                if (isset($params['payment_confirmed'])) {
                    $paymentStatus = $params['payment_confirmed'] ? '已收款' : '未收款';
                    if (!empty($data['delivery_receipt_remark'])) {
                        $data['delivery_receipt_remark'] .= '，' . $paymentStatus;
                    } else {
                        $data['delivery_receipt_remark'] = $paymentStatus;
                    }
                }
                
                // 设置凭证上传时间
                if (!empty($data['delivery_receipt_photos']) || !empty($data['delivery_receipt_remark'])) {
                    $data['receipt_upload_time'] = date('Y-m-d H:i:s');
                }
                
                $statusMsg = '已送达';

                // 更新骑手统计
                $this->updateRiderStats($riderId, $order);

                // 更新骑手状态为在线
                $riderModel = M('rider_info');
                $riderModel->where(array('id' => $riderId))->save(array('work_status' => 1));
                
                // 同步原始订单状态为已完成
                if (!empty($order['bill_id'])) {
                    $billOnlineModel = M('retail_bill_online');
                    $billOnline = $billOnlineModel->where(array('bill_id' => $order['bill_id']))->find();
                    if ($billOnline && $billOnline['status'] != 3) {
                        // 将原始订单状态更新为已收货（status=3）
                        $billOnlineModel->where(array('bill_id' => $order['bill_id']))->save(array(
                            'status' => 3, // 已收货/已完成
                            'receipt_time' => !empty($data['delivery_time']) ? $data['delivery_time'] : date('Y-m-d H:i:s'),
                            'update_time' => date('Y-m-d H:i:s')
                        ));
                    }
                }
                break;
            default:
                $this->ajaxReturn(array('code' => 0, 'msg' => '无效的状态'));
        }

        
        $result = $orderModel->where(array('id' => $orderId))->save($data);

        if ($result !== false) {
            // 更新骑手位置
            $updateLat = $lat;
            $updateLng = $lng;
            
            // 如果是送达状态，优先使用送达位置
            if ($status == 6 && isset($params['delivery_latitude']) && isset($params['delivery_longitude'])) {
                $updateLat = floatval($params['delivery_latitude']);
                $updateLng = floatval($params['delivery_longitude']);
            }
            
            if ($updateLat && $updateLng) {
                $this->updateRiderLocation($riderId, $updateLat, $updateLng);
            }

            $this->ajaxReturn(array(
                'code' => 1,
                'msg' => $statusMsg . '成功'
            ));
        } else {
            $this->ajaxReturn(array(
                'code' => 0, 
                'msg' => '状态更新失败'
            ));
        }
    }

    /**
     * 上传送达照片
     */
    public function uploadDeliveryPhoto()
    {
        $riderId = $this->riderId;

        // 检查Content-Type并解析参数
        $contentType = '';
        if (isset($_SERVER['CONTENT_TYPE'])) {
            $contentType = $_SERVER['CONTENT_TYPE'];
        }

        // 初始化变量
        $orderId = 0;
        // 使用统一的参数处理方法
        $orderId = intval($this->getRequestParam('order_id', 0));
        $photo = trim($this->getRequestParam('photo', ''));

        if (empty($orderId)) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '订单ID不能为空'));
        }

        if (empty($photo)) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '照片不能为空'));
        }

        // 检查订单归属
        $orderModel = M('rider_order');
        $order = $orderModel->where(array('id' => $orderId, 'rider_id' => $riderId))->find();

        if (!$order || $order['rider_id'] != $riderId) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '订单不存在或无权限'));
        }

        $data = array(
            'delivery_photo' => $photo
        );

        $result = $orderModel->where(array('id' => $orderId))->save($data);

        if ($result !== false) {
            $this->ajaxReturn(array(
                'code' => 1,
                'msg' => '照片上传成功'
            ));
        } else {
            $this->ajaxReturn(array('code' => 0, 'msg' => '上传失败'));
        }
    }


    /**
     * 获取订单历史
     */
    public function getOrderHistory()
    {
        $riderId = $this->riderId;
        $page = $this->getRequestParam('page', 1);
        $pageSize = $this->getRequestParam('page_size', 10); // 修改参数名为page_size
        $status = $this->getRequestParam('status', '');

        $where = array('rider_id' => $riderId);

        if ($status !== '') {
            // 处理不同的状态值
            if ($status === 'ongoing') {
                // 进行中的订单状态
                $where['order_status'] = array('in', array('accepted', 'to_merchant', 'arrived', 'picked_up', 'delivering'));
            } else {
                $where['order_status'] = $status;
            }
        }

        $orderModel = M('rider_order');
        $offset = ($page - 1) * $pageSize;
        $orders = $orderModel->where($where)
            ->order('add_time DESC')
            ->limit($offset, $pageSize)
            ->select();

        // 格式化订单数据
        if ($orders) {
            foreach ($orders as &$order) {
                // 确保必要字段存在
                $order['id'] = isset($order['id']) ? $order['id'] : '';
                $order['order_no'] = isset($order['order_no']) ? $order['order_no'] : '';
                $order['create_time'] = isset($order['add_time']) ? $order['add_time'] : '';
                $order['status'] = isset($order['order_status']) ? $order['order_status'] : '';
                $order['merchant_name'] = isset($order['merchant_name']) ? $order['merchant_name'] : '';
                $order['merchant_address'] = isset($order['merchant_address']) ? $order['merchant_address'] : '';
                $order['delivery_name'] = isset($order['delivery_name']) ? $order['delivery_name'] : '';
                $order['delivery_phone'] = isset($order['delivery_phone']) ? $order['delivery_phone'] : '';
                $order['delivery_address'] = isset($order['delivery_address']) ? $order['delivery_address'] : '';
                $order['delivery_fee'] = isset($order['delivery_fee']) ? $order['delivery_fee'] : 0;
                $order['distance'] = isset($order['distance']) ? $order['distance'] : 0;
                $order['cancel_reason'] = isset($order['cancel_reason']) ? $order['cancel_reason'] : '';
            }
        }

        $total = $orderModel->where($where)->count();

        $this->ajaxReturn(array(
            'code' => 1, // 修改为code
            'msg' => '获取成功',
            'data' => array(
                'list' => $orders ? $orders : array(), // 修改为list
                'total' => $total,
                'page' => $page,
                'page_size' => $pageSize
            )
        ));
    }

    /**
     * 计算两点间距离（简化版）
     */
    private function calculateDistance($lat1, $lng1, $lat2, $lng2)
    {
        $earthRadius = 6371; // 地球半径，单位：公里

        $lat1Rad = deg2rad($lat1);
        $lng1Rad = deg2rad($lng1);
        $lat2Rad = deg2rad($lat2);
        $lng2Rad = deg2rad($lng2);

        $deltaLat = $lat2Rad - $lat1Rad;
        $deltaLng = $lng2Rad - $lng1Rad;

        $a = sin($deltaLat / 2) * sin($deltaLat / 2) +
            cos($lat1Rad) * cos($lat2Rad) *
            sin($deltaLng / 2) * sin($deltaLng / 2);

        $c = 2 * atan2(sqrt($a), sqrt(1 - $a));

        return round($earthRadius * $c, 2);
    }

    /**
     * 更新骑手位置
     */
    private function updateRiderLocation($riderId, $lat, $lng)
    {
        $locationModel = M('rider_location');
        $data = array(
            'rider_id' => $riderId,
            'lat' => $lat,
            'lng' => $lng,
            'add_time' => date('Y-m-d H:i:s')
        );

        $locationModel->add($data);

        // 更新骑手表中的最后位置
        $riderModel = M('rider_info');
        $riderModel->where(array('id' => $riderId))->save(array(
            'last_location_lat' => $lat,
            'last_location_lng' => $lng
        ));
    }

    /**
     * 更新骑手统计
     */
    private function updateRiderStats($riderId, $order)
    {
        $riderModel = M('rider_info');

        // 更新总订单数和完成订单数
        $riderModel->where(array('id' => $riderId))->setInc('total_orders');
        $riderModel->where(array('id' => $riderId))->setInc('completed_orders');

        // 添加收入记录
        $incomeModel = M('rider_income');
        $incomeData = array(
            'rider_id' => $riderId,
            'order_id' => $order['id'],
            'income_type' => 1, // 配送费
            'amount' => $order['delivery_fee'],
            'description' => '订单配送费',
            'status' => 1, // 已结算
            'settle_time' => date('Y-m-d H:i:s'),
            'add_time' => date('Y-m-d H:i:s')
        );

        $incomeModel->add($incomeData);

        // 获取当前余额
        $currentRider = $riderModel->field('balance, frozen_balance')->find($riderId);
        $balanceBefore = floatval($currentRider['balance']);
        $frozenBefore = floatval($currentRider['frozen_balance']);
        
        // 更新骑手余额
        $riderModel->where(array('id' => $riderId))->setInc('balance', $order['delivery_fee']);
        
        // 记录余额变动日志
        $balanceLog = array(
            'rider_id' => $riderId,
            'type' => 'income_settle',
            'amount' => $order['delivery_fee'],
            'balance_before' => $balanceBefore,
            'balance_after' => $balanceBefore + $order['delivery_fee'],
            'frozen_before' => $frozenBefore,
            'frozen_after' => $frozenBefore,
            'description' => '订单完成，配送费结算到余额',
            'related_id' => $order['id'],
            'operator_id' => 0, // 系统操作
            'add_time' => date('Y-m-d H:i:s')
        );
        M('rider_balance_log')->add($balanceLog);
    }

    /**
     * 获取订单详情
     */
    public function getOrderDetail()
    {
        $riderId = $this->riderId;
        $rider = $this->riderInfo;

        // 获取订单ID参数
        $orderId = $this->getRequestParam('order_id', 0);

        if (empty($orderId)) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '订单ID不能为空'));
        }

        if (!$rider || $rider['status'] != 1) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '骑手状态异常'));
        }

        try {
            $orderModel = M('rider_order');

            // 查询订单基本信息，关联获取订单金额
            $order = $orderModel->alias('ro')
                ->join('LEFT JOIN ls_retail_bill_order bo ON ro.bill_id = bo.id')
                ->field('ro.*, bo.all_money as order_amount')
                ->where(array('ro.id' => $orderId))
                ->find();

            if (!$order) {
                $this->ajaxReturn(array('code' => 0, 'msg' => '订单不存在'));
            }

            // 检查订单权限（只有分配给该骑手的订单或待接单的订单才能查看）
            if ($order['rider_id'] != 0 && $order['rider_id'] != $riderId) {
                $this->ajaxReturn(array('code' => 0, 'msg' => '无权限查看此订单'));
            }
            
            // 如果订单已取消，添加特殊提示
            if ($order['order_status'] == 8) {
                $order['is_cancelled'] = true;
                $order['cancel_warning'] = '该订单已被取消';
            }

            // 获取骑手信息
            if ($order['rider_id']) {
                $riderInfo = M('rider_info')->where(array('id' => $order['rider_id']))->find();
                if ($riderInfo) {
                    $order['rider'] = array(
                        'id' => $riderInfo['id'],
                        'name' => $riderInfo['rider_name'],
                        'phone' => $riderInfo['rider_phone'],
                        'avatar' => $riderInfo['rider_avatar'] ?: '',
                        'rating' => floatval($riderInfo['rating'] ?: 0)
                    );
                } else {
                    $order['rider'] = null;
                }
            } else {
                $order['rider'] = null;
            }

            // 获取商户信息
            if ($order['merchant_id']) {
                $merchant = M('retail_merchant')->where(array('id' => $order['merchant_id']))->find();
                if ($merchant) {
                    $order['merchant'] = array(
                        'id' => $merchant['id'],
                        'name' => $merchant['name'] ?: $order['store_name'],
                        'address' => $merchant['address'] ?: $order['store_address'],
                        'phone' => $merchant['mobile'] ?: $order['store_phone'],
                        'lat' => $order['store_lat'],
                        'lng' => $order['store_lng']
                    );
                } else {
                    // 如果商户信息不存在，使用订单中的商户信息
                    $order['merchant'] = array(
                        'id' => $order['merchant_id'],
                        'name' => $order['store_name'],
                        'address' => $order['store_address'],
                        'phone' => $order['store_phone'],
                        'lat' => $order['store_lat'],
                        'lng' => $order['store_lng']
                    );
                }
            } else {
                $order['merchant'] = array(
                    'id' => 0,
                    'name' => $order['store_name'],
                    'address' => $order['store_address'],
                    'phone' => $order['store_phone'],
                    'lat' => $order['store_lat'],
                    'lng' => $order['store_lng']
                );
            }

            // 获取客户信息
            $order['customer'] = array(
                'name' => $order['customer_name'],
                'phone' => $order['customer_phone'],
                'address' => $order['customer_address'],
                'lat' => $order['customer_lat'],
                'lng' => $order['customer_lng'],
                'remark' => $order['customer_remark']
            );

            // 获取原始订单信息（商品详情等）
            if ($order['bill_id']) {
                $billOrder = M('retail_bill_order')->where(array('id' => $order['bill_id']))->find();
                if ($billOrder) {
                    $order['original_order'] = $billOrder;

                    // 获取在线订单信息
                    $onlineOrder = M('retail_bill_online')->where(array('bill_id' => $order['bill_id']))->find();
                    if ($onlineOrder) {
                        $order['online_order'] = $onlineOrder;
                    }
                }
            }

            // 获取商品列表
            $order['goods_list'] = array();
            if ($order['bill_id']) {
                $sellModel = M('retail_sell');
                $goodsList = $sellModel->alias('rs')
                    ->join('LEFT JOIN ls_retail_goods g ON rs.goods_id = g.id')
                    ->field('rs.*, g.goods_name, g.goods_image')
                    ->where(array(
                        'rs.bill_id' => $order['bill_id'],
                        'rs.sell_type' => 1  // 1为销售，2为退款
                    ))
                    ->select();

                if ($goodsList) {
                    foreach ($goodsList as $goods) {
                        // 处理规格信息 - 优化规格显示逻辑
                        $spec = '';

                        // 首先尝试从关联的商品表获取规格信息
                        if (!empty($goods['sku_json_info'])) {
                            $skuInfo = json_decode($goods['sku_json_info'], true);
                            if (is_array($skuInfo)) {
                                // 尝试多个可能的规格字段
                                if (isset($skuInfo['sku_name']) && !empty($skuInfo['sku_name'])) {
                                    $spec = $skuInfo['sku_name'];
                                } elseif (isset($skuInfo['specifications']) && !empty($skuInfo['specifications'])) {
                                    $spec = $skuInfo['specifications'];
                                } elseif (isset($skuInfo['spec']) && !empty($skuInfo['spec'])) {
                                    $spec = $skuInfo['spec'];
                                }
                            }
                        }

                        // 如果还是没有规格信息，尝试从商品表获取
                        if (empty($spec) && !empty($goods['specifications'])) {
                            $spec = $goods['specifications'];
                        }

                        // 如果规格为空，根据商品类型设置默认规格
                        if (empty($spec)) {
                            $spec = '标准装';
                        }

                        $order['goods_list'][] = array(
                            'id' => $goods['goods_id'],
                            'name' => $goods['goods_name'] ?: '',
                            'spec' => $spec,
                            'quantity' => floatval($goods['num']),
                            'price' => floatval($goods['price']),
                            'image' => $goods['goods_image'] ?: ''
                        );
                    }
                }
            }

            // 格式化数据
            $order['delivery_fee'] = floatval($order['delivery_fee']);
            $order['distance'] = floatval($order['distance']); // 商家到客户的配送距离
            $order['estimated_time'] = intval($order['estimated_time']);
            $order['order_amount'] = isset($order['order_amount']) && $order['order_amount'] !== null ?
                floatval($order['order_amount']) : 0.00;

            // 添加订单总金额字段
            $order['total_amount'] = 0.00;
            if ($order['bill_id'] && isset($order['original_order']) && $order['original_order']) {
                $order['total_amount'] = floatval($order['original_order']['all_money']);
            }

            // 计算骑手当前位置到客户地址的距离
            $order['distance_to_customer'] = $this->calculateRiderToCustomerDistance($riderId, $order);

            // 生成配送记录
            $order['delivery_logs'] = $this->generateDeliveryLogs($order);

            // 订单状态文本映射
            $statusMap = array(
                0 => '待接单',
                1 => '已接单',
                2 => '前往商家',
                3 => '已到店',
                4 => '已取餐',
                5 => '配送中',
                6 => '已送达',
                7 => '异常',
                8 => '已取消'
            );
            $order['status_text'] = isset($statusMap[$order['order_status']]) ?
                $statusMap[$order['order_status']] : '未知状态';

            // 时间格式化
            $order['add_time_formatted'] = $order['add_time'] ? date('Y-m-d H:i:s', strtotime($order['add_time'])) : '';
            $order['accept_time_formatted'] = $order['accept_time'] ? date('Y-m-d H:i:s', strtotime($order['accept_time'])) : '';
            $order['delivery_time_formatted'] = $order['delivery_time'] ? date('Y-m-d H:i:s', strtotime($order['delivery_time'])) : '';

            $this->ajaxReturn(array(
                'code' => 1,
                'msg' => '获取成功',
                'data' => $order
            ));
        } catch (\Exception $e) {
            $this->ajaxReturn(array(
                'code' => 0,
                'msg' => '获取失败：' . $e->getMessage()
            ));
        }
    }

    /**
     * 计算骑手当前位置到客户地址的距离
     * @param int $riderId 骑手ID
     * @param array $order 订单信息
     * @return float 距离(公里)
     */
    private function calculateRiderToCustomerDistance($riderId, $order)
    {
        try {
            // 获取骑手最新位置
            $riderLocationModel = M('rider_location');
            $riderLocation = $riderLocationModel->where(array('rider_id' => $riderId))
                ->order('add_time DESC')
                ->find();
            if (!$riderLocation || !$order['customer_lat'] || !$order['customer_lng']) {
                return 0.00; // 如果没有位置信息，返回0
            }

            // 使用地图API计算路线距离（骑行路线），失败时回退到直线距离
            $deliveryFeeService = new \Retail\Service\DeliveryFeeService($order['merchant_id']);
            $distance = $deliveryFeeService->calculateRouteDistance(
                $riderLocation['lat'],
                $riderLocation['lng'],
                $order['customer_lat'],
                $order['customer_lng'],
                'bicycling' // 骑行路线
            );

            return round($distance, 2);
        } catch (\Exception $e) {
            // 计算失败时返回0
            return 0.00;
        }
    }

    /**
     * 生成配送记录
     * @param array $order 订单信息
     * @return array 配送记录数组
     */
    private function generateDeliveryLogs($order)
    {
        $logs = array();

        // 根据订单状态和时间字段生成配送记录
        $statusLogs = array(
            array(
                'status' => 1,
                'time_field' => 'accept_time',
                'content' => '已接单',
                'description' => '骑手已接受订单'
            ),
            array(
                'status' => 2,
                'time_field' => 'going_time', // 前往商家时间（可能需要从其他地方获取）
                'content' => '前往商家',
                'description' => '骑手正在前往商家'
            ),
            array(
                'status' => 3,
                'time_field' => 'arrive_store_time',
                'content' => '已到店',
                'description' => '骑手已到达商家'
            ),
            array(
                'status' => 4,
                'time_field' => 'pickup_time',
                'content' => '已取餐',
                'description' => '骑手已取餐，离开商家'
            ),
            array(
                'status' => 5,
                'time_field' => 'start_delivery_time', // 开始配送时间（可能需要从其他地方获取）
                'content' => '配送中',
                'description' => '骑手正在配送，前往客户位置'
            ),
            array(
                'status' => 6,
                'time_field' => 'delivery_time',
                'content' => '已送达',
                'description' => '订单已成功送达客户'
            ),
            array(
                'status' => 8,
                'time_field' => 'cancel_time',
                'content' => '已取消',
                'description' => '订单已取消'
            )
        );

        // 遍历状态日志，生成实际的配送记录
        foreach ($statusLogs as $statusLog) {
            // 检查是否有对应的时间字段
            $timeField = $statusLog['time_field'];
            $time = null;

            // 特殊处理一些时间字段
            if ($timeField === 'going_time') {
                // 前往商家时间可能需要从位置记录或其他地方获取
                // 暂时跳过，或者使用接单时间作为估算
                if (!empty($order['accept_time'])) {
                    $time = date('Y-m-d H:i:s', strtotime($order['accept_time']) + 60); // 接单后1分钟
                }
            } elseif ($timeField === 'start_delivery_time') {
                // 开始配送时间，使用取餐时间作为估算
                if (!empty($order['pickup_time'])) {
                    $time = date('Y-m-d H:i:s', strtotime($order['pickup_time']) + 60); // 取餐后1分钟
                }
            } elseif (isset($order[$timeField]) && !empty($order[$timeField])) {
                $time = $order[$timeField];
            }

            // 如果有时间记录，或者是当前状态，则添加到日志中
            if ($time || $order['order_status'] == $statusLog['status']) {
                $log = array(
                    'status' => $statusLog['status'],
                    'content' => $statusLog['content'],
                    'description' => $statusLog['description'],
                    'time' => $time ?: date('Y-m-d H:i:s'), // 如果没有时间，使用当前时间
                    'is_current' => $order['order_status'] == $statusLog['status'],
                    'is_completed' => false // 先设为false，后面统一处理
                );

                // 添加取消原因
                if ($statusLog['status'] == 8 && !empty($order['cancel_reason'])) {
                    $log['description'] = '订单已取消：' . $order['cancel_reason'];
                }

                $logs[] = $log;
            }
        }

        // 按状态顺序排序（按配送流程顺序）
        usort($logs, function ($a, $b) {
            // 首先按状态排序，确保配送流程顺序正确
            if ($a['status'] != $b['status']) {
                return $a['status'] - $b['status'];
            }
            // 状态相同时按时间排序
            return strtotime($a['time']) - strtotime($b['time']);
        });

        // 标记已完成的步骤（当前状态及之前的所有状态都标记为已完成）
        $currentOrderStatus = $order['order_status'];
        foreach ($logs as &$log) {
            // 如果是取消状态(8)，只有取消状态本身标记为完成
            if ($currentOrderStatus == 8) {
                $log['is_completed'] = $log['status'] == 8;
            } else {
                // 正常流程：当前状态及之前的状态都标记为已完成
                // 状态流程：1(已接单) → 2(前往商家) → 3(已到店) → 4(已取餐) → 5(配送中) → 6(已送达)
                $log['is_completed'] = $log['status'] <= $currentOrderStatus && $log['status'] != 8;
            }
        }

        return $logs;
    }

    /**
     * 生成取餐码
     * @return string
     */
    private function generatePickupCode()
    {
        // 生成6位数字取餐码
        $code = '';
        for ($i = 0; $i < 6; $i++) {
            $code .= mt_rand(0, 9);
        }

        // 检查是否重复，如果重复则重新生成
        $orderModel = M('rider_order');
        $exists = $orderModel->where(array('pickup_code' => $code))->find();

        if ($exists) {
            return $this->generatePickupCode(); // 递归重新生成
        }

        return $code;
    }

    /**
     * 上报异常问题
     */
    public function reportProblem()
    {
        $riderId = $this->riderId;
        $rider = $this->riderInfo;

        if (!$rider || $rider['status'] != 1) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '骑手状态异常'));
        }

        // 获取请求参数
        $orderId = intval($this->getRequestParam('order_id', 0));
        $problemType = trim($this->getRequestParam('problem_type', ''));
        $problemDescription = trim($this->getRequestParam('problem_description', ''));
        $evidencePhotos = trim($this->getRequestParam('evidence_photos', ''));
        $contactPhone = trim($this->getRequestParam('contact_phone', ''));
        $submitTime = trim($this->getRequestParam('submit_time', ''));

        // 参数验证
        if (empty($orderId)) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '订单ID不能为空'));
        }

        if (empty($problemType)) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '问题类型不能为空'));
        }

        if (empty($contactPhone)) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '联系电话不能为空'));
        }

        // 问题类型验证
        $allowedTypes = array(
            'missing_items',
            'wrong_items',
            'damaged_package',
            'quality_issue',
            'merchant_delay',
            'address_error',
            'customer_unreachable',
            'weather_issue',
            'vehicle_breakdown',
            'other'
        );

        if (!in_array($problemType, $allowedTypes)) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '无效的问题类型'));
        }

        // 手机号格式验证
        if (!preg_match('/^1[3-9]\d{9}$/', $contactPhone)) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '手机号格式不正确'));
        }

        // 描述长度验证
        if (!empty($problemDescription) && mb_strlen($problemDescription, 'UTF-8') > 500) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '问题描述不能超过500字符'));
        }

        // 验证订单权限
        $orderModel = M('rider_order');
        $order = $orderModel->where(array('id' => $orderId, 'rider_id' => $riderId))->find();

        if (!$order) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '订单不存在或无权限操作'));
        }

        // 检查订单状态是否允许上报异常
        $allowedStatuses = array(1, 2, 3, 4, 5); // 已接单到配送中的状态
        if (!in_array($order['order_status'], $allowedStatuses)) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '当前订单状态不允许上报异常'));
        }

        // 根据问题类型设置优先级
        $priorityMap = array(
            'quality_issue' => 4,        // 紧急 - 食品安全问题
            'damaged_package' => 3,      // 高 - 包装破损
            'weather_issue' => 3,        // 高 - 恶劣天气
            'vehicle_breakdown' => 3,    // 高 - 车辆故障
            'customer_unreachable' => 2, // 中 - 客户联系不上
            'address_error' => 2,        // 中 - 地址错误
            'merchant_delay' => 2,       // 中 - 商家出餐慢
            'missing_items' => 2,        // 中 - 商品缺失
            'wrong_items' => 2,          // 中 - 商品错误
            'other' => 1                 // 低 - 其他问题
        );

        $priority = isset($priorityMap[$problemType]) ? $priorityMap[$problemType] : 1;
        $currentTime = date('Y-m-d H:i:s');

        // 处理提交时间格式
        $formattedSubmitTime = $currentTime;
        if (!empty($submitTime)) {
            // 如果是ISO格式时间，转换为MySQL格式
            if (strpos($submitTime, 'T') !== false) {
                $timestamp = strtotime($submitTime);
                if ($timestamp !== false) {
                    $formattedSubmitTime = date('Y-m-d H:i:s', $timestamp);
                }
            } else {
                $formattedSubmitTime = $submitTime;
            }
        }

        // 构建报告数据
        $reportData = array(
            'order_id' => $orderId,
            'rider_id' => $riderId,
            'problem_type' => $problemType,
            'problem_description' => $problemDescription,
            'evidence_photos' => $evidencePhotos,
            'contact_phone' => $contactPhone,
            'status' => 0, // 待处理
            'priority' => $priority,
            'source' => 'rider_app',
            'ip_address' => $this->getClientIP(),
            'user_agent' => isset($_SERVER['HTTP_USER_AGENT']) ? $_SERVER['HTTP_USER_AGENT'] : '',
            'submit_time' => $formattedSubmitTime,
            'add_time' => $currentTime,
            'update_time' => $currentTime
        );

        try {
            // 保存异常报告
            $reportModel = M('rider_problem_report');
            $reportId = $reportModel->add($reportData);

            if (!$reportId) {
                $this->ajaxReturn(array('code' => 0, 'msg' => '保存异常报告失败'));
            }

            // 记录跟进日志
            $followModel = M('rider_problem_follow');
            $followData = array(
                'report_id' => $reportId,
                'operator_id' => $riderId,
                'operator_type' => 1, // 骑手
                'action_type' => 'submit',
                'content' => '骑手提交异常报告：' . $problemType . ($problemDescription ? "。详细描述：{$problemDescription}" : ''),
                'attachments' => $evidencePhotos, // 添加附件字段
                'add_time' => $currentTime
            );

            $followModel->add($followData);

            // 根据异常类型更新订单状态
            $this->updateOrderStatusByProblem($orderId, $problemType, $currentTime);

            // 发送通知给客服（这里可以集成消息队列、短信、邮件等）
            $this->notifyCustomerService($reportId, $reportData);

            $this->ajaxReturn(array(
                'code' => 1,
                'msg' => '异常报告提交成功',
                'data' => array(
                    'report_id' => $reportId,
                    'status' => 0,
                    'submit_time' => $currentTime
                )
            ));
        } catch (\Exception $e) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '提交失败：' . $e->getMessage()));
        }
    }

    /**
     * 发送通知给客服
     */
    private function notifyCustomerService($reportId, $reportData)
    {
        // 获取问题类型中文名称
        $problemTypeNames = array(
            'missing_items' => '商品缺失',
            'wrong_items' => '商品错误',
            'damaged_package' => '包装破损',
            'quality_issue' => '餐品质量问题',
            'merchant_delay' => '商家出餐慢',
            'address_error' => '地址错误',
            'customer_unreachable' => '客户联系不上',
            'weather_issue' => '恶劣天气',
            'vehicle_breakdown' => '车辆故障',
            'other' => '其他问题'
        );

        $problemTypeName = isset($problemTypeNames[$reportData['problem_type']])
            ? $problemTypeNames[$reportData['problem_type']]
            : '未知问题';

        // 构建通知消息
        $messageData = array(
            'title' => '新的异常报告',
            'content' => "骑手上报了新的异常问题：{$problemTypeName}",
            'type' => 'problem_report',
            'data' => json_encode(array(
                'report_id' => $reportId,
                'order_id' => $reportData['order_id'],
                'problem_type' => $reportData['problem_type'],
                'priority' => $reportData['priority'],
                'contact_phone' => $reportData['contact_phone']
            )),
            'status' => 0, // 未读
            'add_time' => date('Y-m-d H:i:s')
        );

        // 保存到系统消息表（如果存在的话）
        try {
            $notificationModel = M('system_notification');
            if ($notificationModel) {
                $notificationModel->add($messageData);
            }
        } catch (\Exception $e) {
            // 忽略通知发送失败的错误
        }

        // 如果是紧急问题，可以在这里添加更多通知方式
        if ($reportData['priority'] >= 3) {
            // 紧急问题的特殊处理
            // 例如：发送短信、推送通知等
        }
    }

    /**
     * 获取客户端IP地址
     */
    private function getClientIP()
    {
        if (isset($_SERVER['HTTP_X_FORWARDED_FOR']) && $_SERVER['HTTP_X_FORWARDED_FOR']) {
            $ip = $_SERVER['HTTP_X_FORWARDED_FOR'];
        } elseif (isset($_SERVER['HTTP_X_REAL_IP']) && $_SERVER['HTTP_X_REAL_IP']) {
            $ip = $_SERVER['HTTP_X_REAL_IP'];
        } elseif (isset($_SERVER['REMOTE_ADDR'])) {
            $ip = $_SERVER['REMOTE_ADDR'];
        } else {
            $ip = '';
        }

        // 如果是多个IP，取第一个
        if (strpos($ip, ',') !== false) {
            $ip = explode(',', $ip)[0];
        }

        return trim($ip);
    }

    /**
     * 根据异常类型更新订单状态
     */
    private function updateOrderStatusByProblem($orderId, $problemType, $currentTime)
    {
        $orderModel = M('rider_order');

        // 获取问题类型对应的中文名称
        $problemTypeNames = array(
            'missing_items' => '商品缺失',
            'wrong_items' => '商品错误',
            'damaged_package' => '包装破损',
            'quality_issue' => '餐品质量问题',
            'merchant_delay' => '商家出餐慢',
            'address_error' => '地址错误',
            'customer_unreachable' => '客户联系不上',
            'weather_issue' => '恶劣天气',
            'vehicle_breakdown' => '车辆故障',
            'other' => '其他问题'
        );

        $problemName = isset($problemTypeNames[$problemType]) ? $problemTypeNames[$problemType] : $problemType;

        // 获取当前订单信息
        $currentOrder = $orderModel->where(array('id' => $orderId))->find();
        $oldStatus = $currentOrder ? $currentOrder['order_status'] : null;

        // 根据不同异常类型设置不同的订单状态和处理方式
        switch ($problemType) {
            case 'quality_issue':
            case 'damaged_package':
                // 食品安全和包装问题 - 设为异常状态，需要立即处理
                $orderModel->where(array('id' => $orderId))->save(array(
                    'order_status' => 7, // 异常状态
                    'exception_reason' => "骑手上报异常：{$problemName}",
                    'update_time' => $currentTime
                ));
                $this->logOrderStatusChange($orderId, $problemType, $problemName, $oldStatus, 7);
                break;

            case 'weather_issue':
            case 'vehicle_breakdown':
                // 天气和车辆问题 - 设为异常状态，可能需要重新分配
                $orderModel->where(array('id' => $orderId))->save(array(
                    'order_status' => 7, // 异常状态
                    'exception_reason' => "骑手上报异常：{$problemName}",
                    'update_time' => $currentTime
                ));
                $this->logOrderStatusChange($orderId, $problemType, $problemName, $oldStatus, 7);
                break;

            case 'missing_items':
            case 'wrong_items':
                // 商品问题 - 保持当前状态，等待商家处理
                $orderModel->where(array('id' => $orderId))->save(array(
                    'exception_reason' => "骑手上报异常：{$problemName}",
                    'update_time' => $currentTime
                ));
                $this->logOrderStatusChange($orderId, $problemType, $problemName, $oldStatus, $oldStatus);
                break;

            case 'merchant_delay':
                // 商家出餐慢 - 保持当前状态，记录异常原因
                $orderModel->where(array('id' => $orderId))->save(array(
                    'exception_reason' => "骑手上报异常：{$problemName}",
                    'update_time' => $currentTime
                ));
                $this->logOrderStatusChange($orderId, $problemType, $problemName, $oldStatus, $oldStatus);
                break;

            case 'address_error':
            case 'customer_unreachable':
                // 地址和联系问题 - 保持配送中状态，等待客服协调
                $orderModel->where(array('id' => $orderId))->save(array(
                    'exception_reason' => "骑手上报异常：{$problemName}",
                    'update_time' => $currentTime
                ));
                $this->logOrderStatusChange($orderId, $problemType, $problemName, $oldStatus, $oldStatus);
                break;

            case 'other':
            default:
                // 其他问题 - 记录异常原因，保持当前状态
                $orderModel->where(array('id' => $orderId))->save(array(
                    'exception_reason' => "骑手上报异常：{$problemName}",
                    'update_time' => $currentTime
                ));
                $this->logOrderStatusChange($orderId, $problemType, $problemName, $oldStatus, $oldStatus);
                break;
        }
    }

    /**
     * 记录订单状态变更日志
     */
    private function logOrderStatusChange($orderId, $problemType, $problemName, $oldStatus = null, $newStatus = null)
    {
        try {
            // 如果有订单状态同步日志表，记录变更
            $syncLogModel = M('rider_order_sync_log');
            if ($syncLogModel) {
                $logData = array(
                    'bill_id' => 0, // 这里可以根据需要填入相关的bill_id
                    'rider_order_id' => $orderId,
                    'rider_id' => $this->riderId,
                    'operation_type' => 'report_problem',
                    'old_status' => $oldStatus,
                    'new_status' => $newStatus,
                    'sync_result' => 1,
                    'error_msg' => '',
                    'request_data' => json_encode(array(
                        'problem_type' => $problemType,
                        'problem_name' => $problemName,
                        'action' => 'report_exception'
                    )),
                    'response_data' => json_encode(array('success' => true)),
                    'sync_time' => date('Y-m-d H:i:s'),
                    'retry_count' => 0,
                    'add_time' => date('Y-m-d H:i:s'),
                    'update_time' => date('Y-m-d H:i:s')
                );

                $syncLogModel->add($logData);
            }
        } catch (\Exception $e) {
            // 忽略日志记录失败的错误
        }
    }

    /**
     * 将状态字符串转换为数字
     */
    private function convertStatusToNumber($statusParam)
    {
        // 如果已经是数字，直接返回
        if (is_numeric($statusParam)) {
            return intval($statusParam);
        }

        // 字符串状态映射表
        $statusMap = array(
            'pending' => 0,        // 待接单
            'accepted' => 1,       // 已接单
            'to_merchant' => 2,    // 前往商家
            'arrived' => 3,        // 已到店
            'picked' => 4,         // 已取餐
            'delivering' => 5,     // 配送中
            'delivered' => 6,      // 已送达
            'exception' => 7,      // 异常
            'cancelled' => 8,      // 已取消

            // 兼容其他可能的字符串格式
            'arrived_store' => 3,
            'picked_up' => 4,
            'delivery' => 5,
            'arrived_customer' => 6,
            'completed' => 6,
            'finished' => 6
        );

        // 转换为小写进行匹配
        $statusKey = strtolower(trim($statusParam));

        if (isset($statusMap[$statusKey])) {
            return $statusMap[$statusKey];
        }

        // 如果无法识别，返回0（待接单状态）
        return 0;
    }

    /**
     * 检查订单状态流转是否合法
     */
    private function isValidStatusTransition($currentStatus, $targetStatus)
    {
        // 定义合法的状态流转规则（允许跳跃状态）
        $validTransitions = array(
            0 => array(1, 8),                    // 待接单 -> 已接单、已取消
            1 => array(2, 3, 4, 5, 6, 7, 8),    // 已接单 -> 可以跳到任何后续状态
            2 => array(3, 4, 5, 6, 7, 8),       // 前往商家 -> 可以跳到任何后续状态
            3 => array(4, 5, 6, 7, 8),          // 已到店 -> 可以跳到任何后续状态
            4 => array(5, 6, 7, 8),             // 已取餐 -> 可以跳到任何后续状态
            5 => array(6, 7, 8),                // 配送中 -> 已送达、异常、已取消
            6 => array(),                       // 已送达 -> 无法变更（终态）
            7 => array(8),                      // 异常 -> 只能取消
            8 => array()                        // 已取消 -> 无法变更（终态）
        );

        // 检查当前状态是否存在于规则中
        if (!isset($validTransitions[$currentStatus])) {
            return false;
        }

        // 检查目标状态是否在允许的转换列表中
        return in_array($targetStatus, $validTransitions[$currentStatus]);
    }

    /**
     * 上报商家出餐慢
     */
    public function reportSlow()
    {
        $riderId = $this->riderId;
        $rider = $this->riderInfo;

        if (!$rider || $rider['status'] != 1) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '骑手状态异常'));
        }

        // 获取请求参数
        $orderId = $this->getRequestParam('order_id', 0);
        $slowReason = $this->getRequestParam('slow_reason', '');
        $description = $this->getRequestParam('description', '');
        $evidencePhotos = $this->getRequestParam('evidence_photos', '');
        $expectedReadyTime = $this->getRequestParam('expected_ready_time', '');
        $riderLat = $this->getRequestParam('rider_lat', 0);
        $riderLng = $this->getRequestParam('rider_lng', 0);
        $allowBeforeArrive = $this->getRequestParam('allow_before_arrive', false);
        $effectiveArriveTime = $this->getRequestParam('effective_arrive_time', '');

        // 参数验证
        if (!$orderId) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '订单ID不能为空'));
        }

        // 验证订单是否存在且属于当前骑手
        $orderModel = M('rider_order');
        $order = $orderModel->where(array(
            'id' => $orderId,
            'rider_id' => $riderId
        ))->find();

        if (!$order) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '订单不存在或无权限'));
        }

        // 检查订单是否已取消
        if ($order['order_status'] == 8) {
            // 订单已取消，恢复骑手为在线状态
            $riderModel = M('rider_info');
            $riderModel->where(array('id' => $riderId))->save(array('work_status' => 1));
            
            $this->ajaxReturn(array(
                'code' => -1, // 特殊错误码表示订单已取消
                'msg' => '该订单已被取消，无法继续操作',
                'data' => array(
                    'order_id' => $orderId,
                    'cancel_reason' => $order['cancel_reason'] ?: '订单已取消',
                    'cancel_time' => $order['cancel_time']
                )
            ));
        }

        // 检查订单状态
        $allowedStatuses = [3]; // 默认只允许已到店状态(3)

        // 如果前端传递了 allow_before_arrive 参数，放宽状态限制
        if ($allowBeforeArrive) {
            $allowedStatuses = [1, 2, 3, 4, 5]; // 1:已接单, 2:前往商家, 3:已到店, 4:已取餐, 5:配送中
        }

        if (!in_array($order['order_status'], $allowedStatuses)) {
            $statusText = '';
            $errorMsg = '';
            switch ($order['order_status']) {
                case 0:
                    $statusText = '待接单';
                    $errorMsg = '订单尚未接单，无法上报出餐慢。请先接单后再上报。';
                    break;
                case 1:
                    $statusText = '已接单';
                    break;
                case 2:
                    $statusText = '前往商家';
                    break;
                case 3:
                    $statusText = '已到店';
                    break;
                case 4:
                    $statusText = '已取餐';
                    break;
                case 5:
                    $statusText = '配送中';
                    break;
                case 6:
                    $statusText = '已送达';
                    $errorMsg = '订单已送达，无法上报出餐慢。';
                    break;
                case 7:
                    $statusText = '异常';
                    $errorMsg = '订单状态异常，无法上报出餐慢。';
                    break;
                case 8:
                    $statusText = '已取消';
                    $errorMsg = '订单已取消，无法上报出餐慢。';
                    break;
                default:
                    $statusText = '未知状态';
                    $errorMsg = '订单状态异常，无法上报出餐慢。';
            }

            if (!$errorMsg) {
                $errorMsg = "当前订单状态({$statusText})不允许上报出餐慢";
            }

            $this->ajaxReturn(array('code' => 0, 'msg' => $errorMsg));
        }

        // 检查是否已经上报过
        $reportModel = M('rider_merchant_slow_report');
        $existReport = $reportModel->where(array(
            'order_id' => $orderId,
            'rider_id' => $riderId
        ))->find();

        if ($existReport) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '该订单已上报过出餐慢'));
        }

        // 计算等待时长
        $reportTime = time();

        // 优先使用前端传递的有效到达时间，否则使用订单的到店时间
        if ($effectiveArriveTime) {
            $arriveTime = strtotime($effectiveArriveTime);
        } else if ($order['arrive_store_time']) {
            $arriveTime = strtotime($order['arrive_store_time']);
        } else {
            // 如果都没有，使用当前时间作为基准（等待时长为0）
            $arriveTime = $reportTime;
        }

        $waitDuration = max(0, round(($reportTime - $arriveTime) / 60)); // 分钟，最小为0

        // 准备插入数据
        $reportData = array(
            'order_id' => $orderId,
            'rider_id' => $riderId,
            'merchant_id' => $order['merchant_id'],
            'store_id' => $order['store_id'],
            'report_time' => date('Y-m-d H:i:s', $reportTime),
            'arrive_time' => $effectiveArriveTime ? date('Y-m-d H:i:s', strtotime($effectiveArriveTime)) : $order['arrive_store_time'],
            'expected_ready_time' => $expectedReadyTime,
            'wait_duration' => $waitDuration,
            'slow_reason' => $slowReason,
            'description' => $description,
            'evidence_photos' => $evidencePhotos,
            'rider_location_lat' => $riderLat,
            'rider_location_lng' => $riderLng,
            'status' => 0, // 待处理
            'ip_address' => get_client_ip(),
            'add_time' => date('Y-m-d H:i:s'),
            'update_time' => date('Y-m-d H:i:s')
        );

        // 开启事务
        $reportModel->startTrans();

        try {
            // 插入出餐慢记录
            $reportId = $reportModel->add($reportData);

            if (!$reportId) {
                throw new \Exception('插入出餐慢记录失败');
            }

            // 同时在问题上报表中也记录一条
            $problemModel = M('rider_problem_report');
            $problemData = array(
                'order_id' => $orderId,
                'rider_id' => $riderId,
                'problem_type' => 'merchant_delay',
                'problem_description' => "商家出餐慢，等待时长：{$waitDuration}分钟。" . ($description ? "详细描述：{$description}" : ''),
                'evidence_photos' => $evidencePhotos,
                'contact_phone' => $rider['rider_phone'],
                'status' => 0,
                'priority' => 2, // 中等优先级
                'source' => 'rider_app',
                'ip_address' => get_client_ip(),
                'submit_time' => date('Y-m-d H:i:s'),
                'add_time' => date('Y-m-d H:i:s')
            );

            $problemId = $problemModel->add($problemData);

            if (!$problemId) {
                throw new \Exception('插入问题记录失败');
            }

            // 记录跟进日志
            $followModel = M('rider_problem_follow');
            $followData = array(
                'report_id' => $problemId,
                'operator_id' => $riderId,
                'operator_type' => 1, // 骑手
                'action_type' => 'submit',
                'content' => "骑手上报商家出餐慢，等待时长：{$waitDuration}分钟" . ($description ? "。详细描述：{$description}" : ''),
                'attachments' => $evidencePhotos, // 添加附件字段
                'add_time' => date('Y-m-d H:i:s')
            );

            $followModel->add($followData);

            // 提交事务
            $reportModel->commit();

            // 返回成功响应
            $this->ajaxReturn(array(
                'code' => 1,
                'msg' => '上报成功',
                'data' => array(
                    'report_id' => $reportId,
                    'wait_duration' => $waitDuration,
                    'report_time' => date('Y-m-d H:i:s')
                )
            ));
        } catch (\Exception $e) {
            // 回滚事务
            $reportModel->rollback();

            // 记录错误日志
            \Think\Log::record('上报出餐慢失败：' . $e->getMessage(), \Think\Log::ERR);

            $this->ajaxReturn(array('code' => 0, 'msg' => '上报失败，请重试'));
        }
    }
}