import { query } from '../sql/query'; // 确保路径是正确的

class ServerModel {
    //获取
    async getServerList(tag: any) {
        return await query(`SELECT id,status,name,ip,port,tips,white_list FROM game_server WHERE tag = ?`, [tag])
    }
    async getServerListById(tag: any, id: any) {
        return await query(`SELECT *  FROM game_enter_server WHERE  id = ? `, [id])
    }
    async getAllServerList(tag: any) {
        const rows = await query(`SELECT id,status,name,ip,port,tips FROM game_server WHERE tag = ?`, [tag])
        const resultArray = (rows as any[]).map(row => {
            return {
                sid: row.id,
                id: row.id,
                name: row.name,
                server: `ws://${row.ip}:${row.port}`,
                status: row.status,
            };
        });
        return resultArray
    }

    async checkEnterServerByUid(uid: any, server_id: any) {
        return await query(`SELECT * FROM game_enter_server where uid  = ? and server_id  = ?`, [uid, server_id])
    }

    async getEnterServerListByUid(uid: any) {
        return await query(`SELECT ges.id, ges.uid, ges.server_id, ges.create_time as last_login_time , gs.ip, gs.port,gs.status,gs.name FROM game_enter_server as ges left join game_server as gs on ges.server_id = gs.id WHERE ges.uid = ? order by ges.create_time desc `, [uid])
    }

    //记录进区
    async enterServer(
        uid: any,
        server_id: any,
        create_time: string
    ) {
        return await query(`INSERT INTO game_enter_server(uid,server_id,create_time) VALUES('${uid}','${server_id}', '${create_time}')`, [])
    }

    //更新进区
    async updateEnterServer(
        id: any,
        create_time: string
    ) {
        const sql = 'UPDATE game_enter_server SET create_time = ? WHERE id = ?';
        return await query(sql, [create_time,id])
    }
}

module.exports = new ServerModel()