score.js

//Funciones relacionadas con la puntuación de los jugadores.
var db = require("./mysql").baseP;
var util = require("./utility");
var puzzle = require("./case");
const { logError } = require("./debug");

/**
 * Devuelve los 10 jugadores con más puntuación hasta la fecha
 */
async function Top10(idCaso)
{
    let consulta = "";
    if(idCaso < 0)
        consulta = "SELECT p.nickname, sum(ps.score) as score FROM scores as ps INNER JOIN players as p ON ps.player_id = p.id GROUP BY player_id ORDER BY sum(score) DESC limit 10";
    else 
        consulta ="SELECT p.nickname, ps.score as score FROM scores as ps INNER JOIN players as p ON ps.player_id = p.id WHERE ps.case_id = "+idCaso+" ORDER BY score DESC limit 10";
    try{
        let [rows,fields] = await db.query(consulta);
        return {info:"Correcto", res:rows};
    }
    catch(err){
        logError("Error de consulta en Top10: "+err, 'score');
        return {info:"Error..."};
    }
}

/**
 * Devuelve un array (de hasta 1024 valores) con las puntuaciones de los jugadores en esa dificultad
 * @param {Number} dif dificulty or case_id depending on the value of 'tipo'
 * @param {Number} tipo
 */
async function Score(idCaso, dif, tipo)
{
    if(util.AntiInjectionNumberField(dif,"score") &&
        util.AntiInjectionNumberField(tipo,"score"))
    {
        dif = parseInt(dif);
        idCaso = parseInt(idCaso);
        tipo = parseInt(tipo);
        var consulta = "";
        switch(tipo)
        {
            case 0: //Puntuación (dificultad especifica)
                consulta = "SELECT score FROM scores WHERE difficulty = "+dif+" ORDER BY score ASC limit 1024";
                break;
            case 1: //Consultas Usadas (dificultad especifica)
                consulta = "SELECT used_queries FROM scores WHERE difficulty = "+dif+" ORDER BY used_queries ASC limit 1024";
                break;
            case 2: //Tiempo empleado (dificultad especifica)
                consulta = "SELECT time_spent FROM scores WHERE difficulty = "+dif+" ORDER BY time_spent ASC limit 1024";
                break;
            case 3: //Todo (dificultad especifica)
                consulta = "SELECT player_id, score, used_queries, time_spent FROM scores WHERE difficulty = "+dif+" ORDER BY score ASC limit 1024";
                break;
            case 4: //Todo (caso específico)
                consulta = "SELECT player_id, score, used_queries, time_spent FROM scores WHERE case_id = "+idCaso+" ORDER BY score ASC limit 1024";
                break;
            case 5: //Eficiente (Todo menos player)
                consulta = "SELECT score AS S, used_queries AS Q, time_spent AS T FROM scores WHERE case_id = "+idCaso+" ORDER BY score ASC limit 1024";
                break;
        }

        try{
            let [rows,fields] = await db.query(consulta);
            return {info:"Correcto", res:rows};
        }
        catch(err){
            logError("Error de consulta en Score: "+err,'score');
            return {info:"Error..."};
        }
    }
    else return {info:"Incorrecto", res:"K COÑO ESTÁS INTENTANTO JOPUTA"};
}

/**
 * Guarda en la BD los datos de la puntuación indicada
 * @param {Number} id ID del jugador
 * @param {Number} caso
 * @param {Number} punt 
 * @param {Number} dif 
 * @param {Number} used
 * @param {Number} time
 */
 async function SaveScore(id,caso,punt,dif,used,time)
 {
    if(util.AntiInjectionNumberField(dif,'score') && 
        util.AntiInjectionNumberField(id,'score') &&
        util.AntiInjectionNumberField(punt,'score') &&
        util.AntiInjectionNumberField(used,'score') && 
        util.AntiInjectionNumberField(time,'score') &&
        util.AntiInjectionNumberField(caso,'score'))
    {
        let c = parseInt(caso);
        let d = parseInt(dif);
        let p = parseInt(punt);
        let u = parseInt(used);
        let t = parseFloat(time);

        //TODO: Comprobar si ya hay una score del jugador en ese caso, si lo es, 
        //      simplemente actualizar en vez de insertar
        let qComprobar = "SELECT score FROM scores WHERE player_id = "+id+" AND case_id = "+c;
        try{
            let [rows,fields] = await db.query(qComprobar);
            
            var consulta;
            if(rows.length <= 0) //Hay que insertar
                consulta = "INSERT INTO scores (player_id, case_id, difficulty, score, used_queries, time_spent) VALUES ("+id+","+c+","+d+","+p+","+u+","+t+")";
            else{ //Sólo actualizar
                var oldP = parseInt(rows[0]["score"]); //Recemos
                if( p > oldP){
                    consulta = "UPDATE scores SET score = "+p+" WHERE player_id = "+id+" AND case_id = "+c;
                }
                else{
                    return {info:"Correcto", res:"No ha hehco falta guardarlo :v"};
                }
            }
            
            try{
                await db.query(consulta);
                return {info:"Correcto", res:"Puntuación guardada correctamente."};
            }
            catch(err){
                logError("Error de consulta en SaveScore: "+err, 'score');
                return {info:"Error..."};
            }

        }catch(err){
            logError("Error de consulta en SaveScore al comprobar puntuacion: "+err, 'score');
            return {info:"Error..."};
        }
    }
    else return {info:"Incorrecto", res:"Faltan datos o son incorrectos."};
 }

/**
 * Devuelve la puntuación correspondiente de los datos de la consulta dada.
 * @param {Number} casoID
 * @param {String} consultaEvaluada 
 * @param {Number} consultasUsadas 
 * @param {Number} tiempoEmpleado 
 * @param {Boolean} casoExamen 
 * @param {Number} retos 
 * @param {Number} dificultad 
 * @returns 
 */
async function CalcularScore(casoID, consultaEvaluada, consultasUsadas, tiempoEmpleado, casoExamen, retos, dificultad)
{
    //1º Comprobar éxito
    let exito = await puzzle.ResolverCaso(casoID, consultaEvaluada);
    if(exito["info"] != "Correcto") return exito;
    let continuar = exito["res"];
    if(!continuar) return {info:"Incorrecto",res:"La consulta no soluciona el caso."};
    
    //2º Obtener datos de EXPLAIN ANALYZE
    let datos = await util.parseExplain(casoID,consultaEvaluada);
    //datos-> "cost", "rows", "time"
    
    //3º Calcular fórmulas
    let a=1.85, b=10;
    let puntConsulta = b/(b+a*(consultasUsadas-1)*(consultasUsadas-1));

    a=0.36; b = 40;
    //La única forma de terminar un caso antes de los 10 segundos es el copia y pega consultas, algo a evitar...
    let tSensible = Math.max(0,tiempoEmpleado-10);
    let puntTiempo = b/(b+a*(tSensible));

    let puntEfic;
    if(datos["cost"] >= 0)
        puntEfic = 2*dificultad/(2*dificultad+datos["cost"]*datos["cost"]);
    else puntEfic = 1;

    let puntuacion = (100*puntConsulta + 100*puntTiempo)*dificultad + 20*puntEfic;
    if(casoExamen) puntuacion+=100;
    puntuacion+=50*retos;
    //Puntuación máxima = (100+100)*dificultad + 20 + 100 + 50*retos
    //Puntuación mínima (teórica) = 0
    //Para un caso de los primeros suponiendo 4 consultas usadas y 4 minutos para resolverlo:
    // (37.5+32.6)*1 + 20*0? + 0 + 50*0 = 70.1 -> 70 es la puntuación mínima razonable.

    puntuacion = parseInt(puntuacion);
    return {info:"Correcto", res:puntuacion, otros:datos};
}

/**
 * Devuelve la puntuación completa del jugador indicado, es decir,
 * la suma de las puntuaciones de cada caso completado
 * @param {*} id ID del jugador
 * @returns 
 */
async function CompleteScore(id)
{
    if(util.AntiInjectionNumberField(id,'score'))
    {
        id = parseInt(id);
        var consulta = "SELECT SUM(score) FROM scores WHERE player_id = "+id+" GROUP BY player_id";
        
        try{
            let [rows,fields] = await db.query(consulta);
            if (rows.length == 0) return {info:"Correcto", res:0};
            return {info:"Correcto", res:rows[0]["SUM(score)"]};
        }
        catch(err){
            logError("Error de consulta en CompleteScore: "+err,'score');
            return {info:"Error..."};
        }
    }
    else return {info:"Incorrecto", res:"Casi cuela."};
}

module.exports.Top10 = Top10;
module.exports.Score = Score;
module.exports.SaveScore = SaveScore;
module.exports.CalcularScore = CalcularScore;
module.exports.CompleteScore = CompleteScore;