import request from '../utils/request';
import { UPLOAD_URL } from '../utils/request';

/**
 * 获取消息列表 (系统通知/投递进度等)
 * @param {Object} params - { type, pageNum, pageSize }
 */
export function getMessageList(params) {
    return request({
        url: '/miniapp/message/list',
        method: 'GET',
        params: params
    });
}

/**
 * 标记全部消息为已读
 */
export function readAllMessages() {
    return request({
        url: '/miniapp/message/read-all',
        method: 'POST'
    });
}

/**
 * 标记单条消息为已读
 */
export function readMessage(id) {
    return request({
        url: `/miniapp/message/read/${id}`,
        method: 'PUT'
    });
}

/**
 * 获取未读消息数量
 */
export function getUnreadCount() {
    return request({
        url: '/miniapp/message/unread-count',
        method: 'GET'
    });
}

/**
 * 创建或获取会话
 * @param {Object} data - { sessionType, fromUserId, fromUserName, fromUserAvatar }
 */
export function createOrGetSession(data) {
    return request({
        url: '/main/session/create',
        method: 'POST',
        data: data
    });
}

/**
 * 获取聊天历史记录
 * @param {Object} params - { sessionId, beforeMsgId, pageNum, pageSize }
 */
export function getChatHistory(params) {
    return request({
        url: '/main/message/history',
        method: 'GET',
        params: params
    });
}

/**
 * 发送文本消息
 * @param {Object} data - { sessionId, content, type }
 */
export function sendTextMessage(data) {
    return request({
        url: '/main/message/send/text',
        method: 'POST',
        data: data
    });
}

/**
 * 标记聊天消息已读
 * @param {Object} data - { sessionId, lastReadMsgId }
 */
export function markChatRead(data) {
    return request({
        url: '/main/message/read',
        method: 'PUT',
        data: data
    });
}

/**
 * 支付结算单（已废弃，使用 createOrderByOrderCard + 微信支付）
 * @param {Long} orderCardId 
 * @param {Long} userId 
 */
export function payOrderCard(orderCardId, userId) {
    return request({
        url: `/main/order-card/${orderCardId}/pay`,
        method: 'POST',
        params: { userId }
    });
}

/**
 * 测评咨询时自动创建结算单
 * @param {Object} data - { sessionId, studentId, orderName, orderPrice, orderType }
 */
export function autoCreateOrderCard(data) {
    return request({
        url: '/main/order-card/auto-create',
        method: 'POST',
        params: data
    });
}

/**
 * 发起微信支付
 * @param {Object} data - { orderCardId, userId }
 */
export function createWxPayOrder(orderCardId, userId) {
    return request({
        url: `/main/order-card/${orderCardId}/create-order`,
        method: 'POST',
        params: { userId }
    });
}

/**
 * 根据结算单创建正式订单
 * @param {Long} orderCardId
 * @param {Long} userId
 */
export function createOrderByOrderCard(orderCardId, userId) {
    return request({
        url: `/main/order-card/${orderCardId}/create-order`,
        method: 'POST',
        params: { userId }
    });
}

/**
 * 查询结算单状态
 * @param {Long} orderCardId 
 */
export function getOrderCardStatus(orderCardId) {
    return request({
        url: `/main/order-card/${orderCardId}`,
        method: 'GET'
    });
}

/**
 * 上传并发送图片
 * @param {Object} data - { sessionId, msgNo, senderId, filePath }
 */
export function sendImageMessage(data) {
    return new Promise((resolve, reject) => {
        const token = uni.getStorageSync('token');
        // 与 request.js 保持一致的后端地址
        const BASE_URL = UPLOAD_URL;
        uni.uploadFile({
            url: BASE_URL + '/main/message/send/image',
            filePath: data.filePath,
            name: 'file',
            formData: {
                sessionId: data.sessionId,
                msgNo: data.msgNo,
                senderId: data.senderId
            },
            header: {
                'Authorization': token ? `Bearer ${token}` : '',
                'clientid': 'e5cd7e4891bf95d1d19206ce24a7b32e'
            },
            success: (res) => {
                const result = JSON.parse(res.data);
                if (result.code === 200) {
                    resolve(result);
                } else {
                    reject(result);
                }
            },
            fail: (err) => reject(err)
        });
    });
}