<?php
namespace RiderApi\Controller;

/**
 * 骑手端消息控制器
 */
class MessageController extends BaseController {
    
    /**
     * 获取消息列表
     */
    public function getMessageList() {
        $riderId = $this->riderId;
        $page = $this->getRequestParam('page', 1);
        $limit = $this->getRequestParam('limit', 10);
        $type = $this->getRequestParam('type', ''); // 消息类型
        $isRead = $this->getRequestParam('is_read', ''); // 是否已读
        
        $where = array('rider_id' => $riderId);
        
        if ($type !== '') {
            $where['type'] = $type;
        }
        
        if ($isRead !== '') {
            $where['is_read'] = $isRead;
        }
        
        $messageModel = M('rider_message');
        $offset = ($page - 1) * $limit;
        $messages = $messageModel->where($where)
                                ->order('add_time DESC')
                                ->limit($offset, $limit)
                                ->select();
        
        $total = $messageModel->where($where)->count();
        
        // 格式化数据
        foreach ($messages as &$message) {
            $message['type_text'] = $this->getMessageTypeText($message['type']);
            $message['add_time_format'] = $this->formatTime($message['add_time']);
        }
        
        $this->ajaxReturn(array(
            'code' => 1,
            'msg' => '获取成功',
            'data' => array(
                'messages' => $messages,
                'total' => $total,
                'page' => $page,
                'limit' => $limit
            )
        ));
    }
    
    /**
     * 获取未读消息数量
     */
    public function getUnreadCount() {
        $riderId = $this->riderId;
        
        $messageModel = M('rider_message');
        $count = $messageModel->where(array(
            'rider_id' => $riderId,
            'is_read' => 0
        ))->count();
        
        $this->ajaxReturn(array(
            'code' => 1,
            'msg' => '获取成功',
            'data' => array(
                'unread_count' => intval($count)
            )
        ));
    }
    
    /**
     * 标记消息为已读
     */
    public function markAsRead() {
        $riderId = $this->riderId;
        
        // 检查Content-Type并解析参数
        $contentType = isset($_SERVER['CONTENT_TYPE']) ? $_SERVER['CONTENT_TYPE'] : '';
        if (strpos($contentType, 'application/json') !== false) {
            $input = json_decode(file_get_contents('php://input'), true);
            $messageId = isset($input['message_id']) ? intval($input['message_id']) : 0;
        } else {
            $messageId = $this->getRequestParam('message_id', 0);
        }
        
        if (empty($messageId)) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '消息ID不能为空'));
        }
        
        $messageModel = M('rider_message');
        $result = $messageModel->where(array(
            'id' => $messageId,
            'rider_id' => $riderId
        ))->save(array(
            'is_read' => 1,
            'read_time' => date('Y-m-d H:i:s')
        ));
        
        if ($result !== false) {
            $this->ajaxReturn(array(
                'code' => 1,
                'msg' => '标记成功'
            ));
        } else {
            $this->ajaxReturn(array('code' => 0, 'msg' => '标记失败'));
        }
    }
    
    /**
     * 标记所有消息为已读
     */
    public function markAllAsRead() {
        $riderId = $this->riderId;
        
        $messageModel = M('rider_message');
        $result = $messageModel->where(array(
            'rider_id' => $riderId,
            'is_read' => 0
        ))->save(array(
            'is_read' => 1,
            'read_time' => date('Y-m-d H:i:s')
        ));
        
        if ($result !== false) {
            $this->ajaxReturn(array(
                'code' => 1,
                'msg' => '标记成功'
            ));
        } else {
            $this->ajaxReturn(array('code' => 0, 'msg' => '标记失败'));
        }
    }
    
    /**
     * 删除消息
     */
    public function deleteMessage() {
        $riderId = $this->riderId;
        
        // 检查Content-Type并解析参数
        $contentType = isset($_SERVER['CONTENT_TYPE']) ? $_SERVER['CONTENT_TYPE'] : '';
        if (strpos($contentType, 'application/json') !== false) {
            $input = json_decode(file_get_contents('php://input'), true);
            $messageId = isset($input['message_id']) ? intval($input['message_id']) : 0;
        } else {
            $messageId = $this->getRequestParam('message_id', 0);
        }
        
        if (empty($messageId)) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '消息ID不能为空'));
        }
        
        $messageModel = M('rider_message');
        $result = $messageModel->where(array(
            'id' => $messageId,
            'rider_id' => $riderId
        ))->delete();
        
        if ($result) {
            $this->ajaxReturn(array(
                'code' => 1,
                'msg' => '删除成功'
            ));
        } else {
            $this->ajaxReturn(array('code' => 0, 'msg' => '删除失败'));
        }
    }
    
    /**
     * 发送系统消息（管理员调用）
     */
    public function sendSystemMessage() {
        // 检查Content-Type并解析参数
        $contentType = isset($_SERVER['CONTENT_TYPE']) ? $_SERVER['CONTENT_TYPE'] : '';
        if (strpos($contentType, 'application/json') !== false) {
            $input = json_decode(file_get_contents('php://input'), true);
            $riderId = isset($input['rider_id']) ? intval($input['rider_id']) : 0;
            $title = isset($input['title']) ? trim($input['title']) : '';
            $content = isset($input['content']) ? trim($input['content']) : '';
            $type = isset($input['type']) ? intval($input['type']) : 1;
        } else {
            $riderId = $this->getRequestParam('rider_id', 0);
            $title = $this->getRequestParam('title', '');
            $content = $this->getRequestParam('content', '');
            $type = $this->getRequestParam('type', 1);
        }
        
        if (empty($title)) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '标题不能为空'));
        }
        
        if (empty($content)) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '内容不能为空'));
        }
        
        $messageModel = M('rider_message');
        
        // 如果指定了骑手ID，发送给指定骑手
        if ($riderId) {
            $messageData = array(
                'rider_id' => $riderId,
                'title' => $title,
                'content' => $content,
                'type' => $type,
                'is_read' => 0,
                'add_time' => date('Y-m-d H:i:s')
            );
            
            $result = $messageModel->add($messageData);
        } else {
            // 发送给所有骑手
            $riderModel = M('rider_info');
            $riders = $riderModel->field('id')->select();
            
            $messageData = array();
            foreach ($riders as $rider) {
                $messageData[] = array(
                    'rider_id' => $rider['id'],
                    'title' => $title,
                    'content' => $content,
                    'type' => $type,
                    'is_read' => 0,
                    'add_time' => date('Y-m-d H:i:s')
                );
            }
            
            $result = $messageModel->addAll($messageData);
        }
        
        if ($result) {
            $this->ajaxReturn(array(
                'code' => 1,
                'msg' => '发送成功'
            ));
        } else {
            $this->ajaxReturn(array('code' => 0, 'msg' => '发送失败'));
        }
    }
    
    /**
     * 发送订单相关消息
     */
    public function sendOrderMessage() {
        // 检查Content-Type并解析参数
        $contentType = isset($_SERVER['CONTENT_TYPE']) ? $_SERVER['CONTENT_TYPE'] : '';
        if (strpos($contentType, 'application/json') !== false) {
            $input = json_decode(file_get_contents('php://input'), true);
            $riderId = isset($input['rider_id']) ? intval($input['rider_id']) : 0;
            $orderId = isset($input['order_id']) ? intval($input['order_id']) : 0;
            $type = isset($input['type']) ? intval($input['type']) : 2; // 订单消息
            $action = isset($input['action']) ? trim($input['action']) : ''; // 动作类型：new_order, order_timeout, order_cancel
        } else {
            $riderId = $this->getRequestParam('rider_id', 0);
            $orderId = $this->getRequestParam('order_id', 0);
            $type = $this->getRequestParam('type', 2); // 订单消息
            $action = $this->getRequestParam('action', ''); // 动作类型：new_order, order_timeout, order_cancel
        }
        
        if (empty($riderId)) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '骑手ID不能为空'));
        }
        
        if (empty($orderId)) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '订单ID不能为空'));
        }
        
        if (empty($action)) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '动作类型不能为空'));
        }
        
        // 获取订单信息
        $orderModel = M('rider_order');
        $order = $orderModel->find($orderId);
        
        if (!$order) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '订单不存在'));
        }
        
        $title = '';
        $content = '';
        
        switch ($action) {
            case 'new_order':
                $title = '新订单通知';
                $content = "您有新的订单：{$order['order_no']}，请及时处理";
                break;
            case 'order_timeout':
                $title = '订单超时提醒';
                $content = "订单：{$order['order_no']} 即将超时，请尽快处理";
                break;
            case 'order_cancel':
                $title = '订单取消通知';
                $content = "订单：{$order['order_no']} 已被取消";
                break;
            default:
                $this->ajaxReturn(array('code' => 0, 'msg' => '无效的动作类型'));
        }
        
        $messageModel = M('rider_message');
        $messageData = array(
            'rider_id' => $riderId,
            'title' => $title,
            'content' => $content,
            'type' => $type,
            'order_id' => $orderId,
            'is_read' => 0,
            'add_time' => date('Y-m-d H:i:s')
        );
        
        $result = $messageModel->add($messageData);
        
        if ($result) {
            $this->ajaxReturn(array(
                'code' => 1,
                'msg' => '发送成功'
            ));
        } else {
            $this->ajaxReturn(array('code' => 0, 'msg' => '发送失败'));
        }
    }
    
    /**
     * 获取消息详情
     */
    public function getMessageDetail() {
        $riderId = $this->riderId;
        $messageId = $this->getRequestParam('message_id', 0);
        
        if (empty($messageId)) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '消息ID不能为空'));
        }
        
        $messageModel = M('rider_message');
        $message = $messageModel->where(array(
            'id' => $messageId,
            'rider_id' => $riderId
        ))->find();
        
        if (!$message) {
            $this->ajaxReturn(array('code' => 0, 'msg' => '消息不存在'));
        }
        
        // 自动标记为已读
        if ($message['is_read'] == 0) {
            $messageModel->where(array('id' => $messageId))->save(array(
                'is_read' => 1,
                'read_time' => date('Y-m-d H:i:s')
            ));
            $message['is_read'] = 1;
            $message['read_time'] = date('Y-m-d H:i:s');
        }
        
        $message['type_text'] = $this->getMessageTypeText($message['type']);
        $message['add_time_format'] = $this->formatTime($message['add_time']);
        
        $this->ajaxReturn(array(
            'code' => 1,
            'msg' => '获取成功',
            'data' => $message
        ));
    }
    
    /**
     * 获取消息类型文本
     */
    private function getMessageTypeText($type) {
        $types = array(
            1 => '系统消息',
            2 => '订单消息',
            3 => '收入消息',
            4 => '活动消息',
            5 => '其他消息'
        );
        
        return isset($types[$type]) ? $types[$type] : '未知';
    }
    
    /**
     * 格式化时间
     */
    private function formatTime($time) {
        $timestamp = strtotime($time);
        $now = time();
        $diff = $now - $timestamp;
        
        if ($diff < 60) {
            return '刚刚';
        } elseif ($diff < 3600) {
            return floor($diff / 60) . '分钟前';
        } elseif ($diff < 86400) {
            return floor($diff / 3600) . '小时前';
        } elseif ($diff < 604800) {
            return floor($diff / 86400) . '天前';
        } else {
            return date('Y-m-d H:i', $timestamp);
        }
    }
}