import request from '@/common/system/request';

/**
 * 获取消息列表
 * @param {number} pageIndex 页码，从1开始
 * @param {number} pageSize 每页数量
 * @param {number} messageType 消息类型：0=全部，1=私信
 * @returns {Promise<Array>}
 */
export const getMessageList = async (pageIndex = 1, pageSize = 20, messageType = 0) => {
    const res = await request.getOrCache(
        "sq/GetMessageList", 
        { pageIndex, pageSize, messageType }, 
        1  // 缓存1秒
    );
    if (res.code == 0) {
        return res.data || [];
    }
    return [];
}

/**
 * 获取未读消息数量
 * @returns {Promise<number>}
 */
export const getUnreadCount = async () => {
    const res = await request.get("sq/GetUnreadCount");
    if (res.code == 0) {
        return res.data?.count || 0;
    }
    return 0;
}

/**
 * 标记所有消息为已读
 * @returns {Promise<boolean>}
 */
export const markAllAsRead = async () => {
    const res = await request.post("sq/MarkAllAsRead");
    if (res.code == 0) {
        return true;
    }
    return false;
}

// 导出消息接口对象
export const messageInterface = {
    getMessageList,
    getUnreadCount,
    markAllAsRead
}

export default messageInterface;