<?php
namespace Retail\Controller;
use Think\Controller;
use Exception;

/**
 * 骑手订单管理控制器
 */
class RiderOrderController extends Controller {
    
    /**
     * 订单管理首页
     */
    public function index() {
        $this->display();
    }
    
    /**
     * 获取订单列表
     */
    public function getOrderList() {
        $page = I('page', 1, 'intval');
        $pageSize = I('pageSize', 20, 'intval');
        $keyword = I('keyword', '', 'trim');
        $status = I('status', '', 'trim');
        $riderId = I('riderId', 0, 'intval');
        $startDate = I('startDate', '', 'trim');
        $endDate = I('endDate', '', 'trim');
        
        try {
            $where = array();
            
            // 关键词搜索（订单号/客户名）
            if (!empty($keyword)) {
                $where['_string'] = "(order_no LIKE '%{$keyword}%' OR customer_name LIKE '%{$keyword}%')";
            }
            
            // 状态筛选（将前端传入的文案映射到数值状态）
            if (!empty($status)) {
                $statusMap = array(
                    'pending' => 0,
                    'accepted' => 1,
                    'picking_up' => array('in', array(2,3,4)),
                    'delivering' => 5,
                    'completed' => 6,
                    'cancelled' => 8
                );
                if (isset($statusMap[$status])) {
                    $where['order_status'] = $statusMap[$status];
                }
            }
            
            // 骑手筛选
            if (!empty($riderId)) {
                $where['rider_id'] = $riderId;
            }
            
            // 日期筛选
            if (!empty($startDate) && !empty($endDate)) {
                $where['add_time'] = array('between', array($startDate, $endDate));
            }
            
            // 使用骑手订单表
            $orderModel = M('rider_order');
            
            // 获取总数
            $totalCount = $orderModel->where($where)->count();
            
            // 获取列表数据
            $offset = ($page - 1) * $pageSize;
            $orders = $orderModel
                ->where($where)
                ->order('add_time DESC')
                ->limit($offset, $pageSize)
                ->select();
            
            // 处理订单数据
            foreach ($orders as &$order) {
                // 获取骑手信息
                if ($order['rider_id']) {
                    $rider = M('RiderInfo')->where(array('id' => $order['rider_id']))->find();
                    $order['rider'] = array(
                        'id' => $rider['id'],
                        'name' => $rider['rider_name'],
                        'phone' => $rider['rider_phone'],
                        'avatar' => $rider['rider_avatar'] ?: '',
                        'rating' => floatval($rider['rating'])
                    );
                } else {
                    $order['rider'] = null;
                }
                
                // 商户/门店信息（优先使用订单自带字段以避免额外查询）
                $order['merchant'] = array(
                    'name' => isset($order['store_name']) ? $order['store_name'] : '',
                    'address' => isset($order['store_address']) ? $order['store_address'] : '',
                    'phone' => isset($order['store_phone']) ? $order['store_phone'] : ''
                );
                
                // 获取客户信息
                $order['customer'] = array(
                    'name' => $order['customer_name'],
                    'address' => $order['customer_address'],
                    'phone' => $order['customer_phone']
                );
                
                // 订单商品（当前库未定义该表，保持空数组）
                $order['items'] = array();
                
                // 格式化数据
                $order['deliveryFee'] = floatval($order['delivery_fee']);
                $order['distance'] = floatval($order['distance']);
                $order['estimatedTime'] = intval($order['estimated_time']);
                // 映射状态文案，兼容前端
                $order['status'] = $this->mapOrderStatus(intval($order['order_status']));
                // 兼容 created_at 字段
                $order['created_at'] = isset($order['add_time']) ? $order['add_time'] : '';
            }
            
            $this->ajaxReturn(array(
                'code' => 1,
                'msg' => '获取成功',
                'data' => array(
                    'list' => $orders,
                    'totalCount' => $totalCount,
                    'currentPage' => $page,
                    'pageSize' => $pageSize
                )
            ));
            
        } catch (Exception $e) {
            $this->ajaxReturn(array(
                'code' => 0,
                'msg' => '获取失败：' . $e->getMessage()
            ));
        }
    }
    
    /**
     * 获取订单统计数据
     */
    public function getStatistics() {
        try {
            $orderModel = M('rider_order');
            
            // 总订单数
            $totalOrders = $orderModel->count();
            
            // 待分配订单数
            $pendingOrders = $orderModel->where(array('order_status' => 0))->count();
            
            // 配送中订单数（在途：取货中+配送中）
            import('Common.Business.OrderStatusUtil');
            $deliveringOrders = $orderModel->where(array('order_status' => array('in', \Common\Business\OrderStatusUtil::getInTransitStatuses())))->count();
            
            // 已完成订单数
            $completedOrders = $orderModel->where(array('order_status' => 6))->count();
            
            // 今日订单数
            $today = date('Y-m-d');
            $todayOrders = $orderModel->where(array('add_time' => array('like', $today . '%')))->count();
            
            // 今日收入
            $todayRevenue = $orderModel
                ->where(array(
                    'order_status' => 6,
                    'delivery_time' => array('like', $today . '%')
                ))
                ->sum('delivery_fee');
            
            $this->ajaxReturn(array(
                'code' => 1,
                'msg' => '获取成功',
                'data' => array(
                    'totalOrders' => intval($totalOrders),
                    'pendingOrders' => intval($pendingOrders),
                    'deliveringOrders' => intval($deliveringOrders),
                    'completedOrders' => intval($completedOrders),
                    'todayOrders' => intval($todayOrders),
                    'todayRevenue' => floatval($todayRevenue)
                )
            ));
            
        } catch (Exception $e) {
            $this->ajaxReturn(array(
                'code' => 0,
                'msg' => '获取失败：' . $e->getMessage()
            ));
        }
    }
    
    /**
     * 分配骑手
     */
    public function assignRider() {
        $orderId = I('orderId', 0, 'intval');
        $riderId = I('riderId', 0, 'intval');
        $remark = I('remark', '', 'trim');
        
        if (empty($orderId) || empty($riderId)) {
            $this->ajaxReturn(array(
                'code' => 0,
                'msg' => '参数错误'
            ));
            return;
        }
        
        try {
            $orderModel = M('rider_order');
            
            // 检查订单状态
            $order = $orderModel->where(array('id' => $orderId))->find();
            if (!$order) {
                $this->ajaxReturn(array(
                    'code' => 0,
                    'msg' => '订单不存在'
                ));
                return;
            }
            
            if (intval($order['order_status']) !== 0) {
                $this->ajaxReturn(array(
                    'code' => 0,
                    'msg' => '订单状态不允许分配'
                ));
                return;
            }
            
            // 检查骑手状态
            $rider = M('RiderInfo')->where(array('id' => $riderId))->find();
            if (!$rider) {
                $this->ajaxReturn(array(
                    'code' => 0,
                    'msg' => '骑手不存在'
                ));
                return;
            }
            
            if (intval($rider['work_status']) !== 1 || intval($rider['auth_status']) !== 2) {
                $this->ajaxReturn(array(
                    'code' => 0,
                    'msg' => '骑手不在线或未认证，无法分配'
                ));
                return;
            }
            
            // 更新订单
            $updateData = array(
                'rider_id' => $riderId,
                'order_status' => 1,
                'accept_time' => date('Y-m-d H:i:s')
            );
            
            $result = $orderModel->where(array('id' => $orderId))->save($updateData);
            
            if ($result !== false) {
                // 记录操作日志
                $this->addOrderLog($orderId, 'assigned', "分配给骑手：{$rider['rider_name']}");
                
                // 发送通知给骑手（这里可以集成推送服务）
                $this->notifyRider($riderId, $orderId, 'new_order');
                
                $this->ajaxReturn(array(
                    'code' => 1,
                    'msg' => '分配成功'
                ));
            } else {
                $this->ajaxReturn(array(
                    'code' => 0,
                    'msg' => '分配失败'
                ));
            }
            
        } catch (Exception $e) {
            $this->ajaxReturn(array(
                'code' => 0,
                'msg' => '分配失败：' . $e->getMessage()
            ));
        }
    }
    
    /**
     * 取消订单
     */
    public function cancelOrder() {
        $orderId = I('orderId', 0, 'intval');
        $reason = I('reason', '', 'trim');
        
        if (empty($orderId)) {
            $this->ajaxReturn(array(
                'code' => 0,
                'msg' => '参数错误'
            ));
            return;
        }
        
        try {
            $orderModel = M('rider_order');
            
            // 检查订单状态
            $order = $orderModel->where(array('id' => $orderId))->find();
            if (!$order) {
                $this->ajaxReturn(array(
                    'code' => 0,
                    'msg' => '订单不存在'
                ));
                return;
            }
            
            if (!in_array(intval($order['order_status']), array(0, 1))) {
                $this->ajaxReturn(array(
                    'code' => 0,
                    'msg' => '订单状态不允许取消'
                ));
                return;
            }
            
            // 更新订单状态
            $updateData = array(
                'order_status' => 8,
                'cancel_time' => date('Y-m-d H:i:s'),
                'cancel_reason' => $reason
            );
            
            $result = $orderModel->where(array('id' => $orderId))->save($updateData);
            
            if ($result !== false) {
                // 记录操作日志
                $this->addOrderLog($orderId, 'cancelled', "订单已取消，原因：{$reason}");
                
                // 如果已分配骑手，通知骑手
                if ($order['rider_id']) {
                    $this->notifyRider($order['rider_id'], $orderId, 'order_cancelled');
                }
                
                $this->ajaxReturn(array(
                    'code' => 1,
                    'msg' => '取消成功'
                ));
            } else {
                $this->ajaxReturn(array(
                    'code' => 0,
                    'msg' => '取消失败'
                ));
            }
            
        } catch (Exception $e) {
            $this->ajaxReturn(array(
                'code' => 0,
                'msg' => '取消失败：' . $e->getMessage()
            ));
        }
    }
    
    /**
     * 获取订单详情
     */
    public function getOrderDetail() {
        // 兼容前端可能传递的不同参数键：优先使用 orderId，其次尝试 id
        $orderId = I('orderId', 0, 'intval');
        if (empty($orderId)) {
            $orderId = I('id', 0, 'intval');
        }
        
        if (empty($orderId)) {
            $this->ajaxReturn(array(
                'code' => 0,
                'msg' => '参数错误'
            ));
            return;
        }
        
        try {
            $orderModel = M('rider_order');
            $order = $orderModel->where(array('id' => $orderId))->find();
            
            if (!$order) {
                $this->ajaxReturn(array(
                    'code' => 0,
                    'msg' => '订单不存在'
                ));
                return;
            }
            
            // 获取骑手信息
            if ($order['rider_id']) {
                $rider = M('RiderInfo')->where(array('id' => $order['rider_id']))->find();
                $order['rider'] = array(
                    'id' => $rider['id'],
                    'name' => $rider['rider_name'],
                    'phone' => $rider['rider_phone'],
                    'avatar' => $rider['rider_avatar'] ?: '',
                    'rating' => floatval($rider['rating'])
                );
            } else {
                $order['rider'] = null;
            }
            
            // 获取商户信息（修正为零售商户表）
            $merchant = M('retail_merchant')->where(array('id' => $order['merchant_id']))->find();
            $order['merchant'] = array(
                'name' => isset($merchant['name']) ? $merchant['name'] : '',
                'address' => isset($merchant['address']) ? $merchant['address'] : '',
                // ls_retail_merchant 表使用 mobile 字段作为联系方式
                'phone' => isset($merchant['mobile']) ? $merchant['mobile'] : ''
            );
            
            // 获取客户信息
            $order['customer'] = array(
                'name' => $order['customer_name'],
                'address' => $order['customer_address'],
                'phone' => $order['customer_phone']
            );
            
            // 订单商品/日志（当前库未定义对应表，保持空数组）
            $order['items'] = array();
            $order['logs'] = array();
            
            // 格式化数据
            $order['deliveryFee'] = floatval($order['delivery_fee']);
            $order['distance'] = floatval($order['distance']);
            $order['estimatedTime'] = intval($order['estimated_time']);
            $order['status'] = $this->mapOrderStatus(intval($order['order_status']));
            $order['created_at'] = isset($order['add_time']) ? $order['add_time'] : '';
            
            $this->ajaxReturn(array(
                'code' => 1,
                'msg' => '获取成功',
                'data' => $order
            ));
            
        } catch (Exception $e) {
            $this->ajaxReturn(array(
                'code' => 0,
                'msg' => '获取失败：' . $e->getMessage()
            ));
        }
    }
    
    /**
     * 获取可用骑手列表
     */
    public function getAvailableRiders() {
        try {
            $riders = M('RiderInfo')
                ->where(array('work_status' => 1, 'auth_status' => 2))
                ->field('id, rider_name, rider_phone, rider_avatar, rating, work_status')
                ->order('rating DESC')
                ->select();
            
            $this->ajaxReturn(array(
                'code' => 1,
                'msg' => '获取成功',
                'data' => $riders ?: array()
            ));
            
        } catch (Exception $e) {
            $this->ajaxReturn(array(
                'code' => 0,
                'msg' => '获取失败：' . $e->getMessage()
            ));
        }
    }
    
    /**
     * 导出订单数据
     */
    public function exportOrders() {
        $this->ajaxReturn(array(
            'code' => 410,
            'msg' => '导出功能已下线'
        ));
        return;
    }
    
    /**
     * 手动同步订单
     */
    public function syncOrder() {
        $this->ajaxReturn(array(
            'code' => 410,
            'msg' => '订单同步功能已下线'
        ));
        return;
    }
    
    /**
     * 批量同步订单
     */
    public function batchSyncOrders() {
        $this->ajaxReturn(array(
            'code' => 410,
            'msg' => '批量同步功能已下线'
        ));
        return;
    }
    
    /**
     * 获取可同步的订单列表
     */
    public function getSyncableOrders() {
        $this->ajaxReturn(array(
            'code' => 410,
            'msg' => '同步候选订单接口已下线'
        ));
        return;
    }
    
    /**
     * 获取同步统计信息
     */
    public function getSyncStatistics() {
        $this->ajaxReturn(array(
            'code' => 410,
            'msg' => '同步统计接口已下线'
        ));
        return;
    }
    
    /**
     * 记录操作日志
     */
    private function addOrderLog($orderId, $action, $remark = '') {
        // 当前系统未定义统一的订单操作日志表，暂不写库，避免因缺表报错
        return true;
    }
    
    /**
     * 发送通知给骑手
     */
    private function notifyRider($riderId, $orderId, $type) {
        // 这里可以集成推送服务，如极光推送、个推等
        // 暂时只记录日志
        $this->addOrderLog($orderId, 'notify_rider', "通知骑手ID：{$riderId}，类型：{$type}");
    }
    
    /**
     * 获取状态文本
     */
    private function getStatusText($status) {
        $statusTexts = array(
            'pending' => '待分配',
            'accepted' => '已接单',
            'picking_up' => '取货中',
            'delivering' => '配送中',
            'completed' => '已完成',
            'cancelled' => '已取消'
        );
        
        return isset($statusTexts[$status]) ? $statusTexts[$status] : '未知';
    }

    /**
     * 数值状态到文案映射
     */
    private function mapOrderStatus($code) {
        switch (intval($code)) {
            case 0: return 'pending';
            case 1: return 'accepted';
            case 2:
            case 3:
            case 4: return 'picking_up';
            case 5: return 'delivering';
            case 6: return 'completed';
            case 8: return 'cancelled';
            case 7: return 'exception';
            default: return 'pending';
        }
    }
}
?>