Subir archivos a "controladores"
This commit is contained in:
@@ -1,6 +1,6 @@
|
|||||||
<?php
|
<?php
|
||||||
session_start();
|
session_start();
|
||||||
require_once $_SERVER['DOCUMENT_ROOT'] . '/includes/conexionBD.php';
|
require_once __DIR__ . '/../includes/conexionBD.php';
|
||||||
|
|
||||||
header('Content-Type: application/json; charset=utf-8');
|
header('Content-Type: application/json; charset=utf-8');
|
||||||
|
|
||||||
@@ -26,7 +26,7 @@ if (is_array($conexion)) {
|
|||||||
switch ($orden) {
|
switch ($orden) {
|
||||||
case 'comprobarEstado':
|
case 'comprobarEstado':
|
||||||
try {
|
try {
|
||||||
// Contar jugadores totales apuntados en los equipos de esta partida
|
// 1. Contar cuántos jugadores hay asignados en esta partida
|
||||||
$stmt = $conexion->prepare("
|
$stmt = $conexion->prepare("
|
||||||
SELECT COUNT(exu.idUsuario) AS total_jugadores
|
SELECT COUNT(exu.idUsuario) AS total_jugadores
|
||||||
FROM equipoxpartida exp
|
FROM equipoxpartida exp
|
||||||
@@ -38,7 +38,7 @@ switch ($orden) {
|
|||||||
|
|
||||||
$preguntasTotalesEsperadas = $totalJugadores * 10;
|
$preguntasTotalesEsperadas = $totalJugadores * 10;
|
||||||
|
|
||||||
// Contar respuestas dadas en la partida
|
// 2. Contar cuántas respuestas reales se han guardado
|
||||||
$stmtRespuestas = $conexion->prepare("
|
$stmtRespuestas = $conexion->prepare("
|
||||||
SELECT COUNT(*)
|
SELECT COUNT(*)
|
||||||
FROM respuestaalmacenada ra
|
FROM respuestaalmacenada ra
|
||||||
@@ -50,17 +50,16 @@ switch ($orden) {
|
|||||||
|
|
||||||
$terminada = ($respuestasRespondidas >= $preguntasTotalesEsperadas && $preguntasTotalesEsperadas > 0);
|
$terminada = ($respuestasRespondidas >= $preguntasTotalesEsperadas && $preguntasTotalesEsperadas > 0);
|
||||||
|
|
||||||
// Cuando la partida finaliza, se actualizan los históricos
|
// 3. Si ha terminado, guardamos los datos históricos una sola vez
|
||||||
if ($terminada && !isset($_SESSION['partidas_procesadas'][$idPartida])) {
|
if ($terminada && !isset($_SESSION['partidas_procesadas'][$idPartida])) {
|
||||||
|
|
||||||
$conexion->beginTransaction();
|
$conexion->beginTransaction();
|
||||||
|
|
||||||
// CÁLCULO DE VELOCIDAD PREGUNTA A PREGUNTA EN SESIÓN
|
// --- CÁLCULO DE VELOCIDAD ---
|
||||||
if (!isset($_SESSION['primeros_en_acertar'][$idPartida])) {
|
if (!isset($_SESSION['primeros_en_acertar'][$idPartida])) {
|
||||||
$_SESSION['primeros_en_acertar'][$idPartida] = [];
|
$_SESSION['primeros_en_acertar'][$idPartida] = [];
|
||||||
}
|
}
|
||||||
|
|
||||||
// Vemos quién fue el primero
|
|
||||||
$stmtVelocidad = $conexion->prepare("
|
$stmtVelocidad = $conexion->prepare("
|
||||||
SELECT ra.idPartidaxPregunta, ra.idUsuario
|
SELECT ra.idPartidaxPregunta, ra.idUsuario
|
||||||
FROM respuestaalmacenada ra
|
FROM respuestaalmacenada ra
|
||||||
@@ -81,8 +80,7 @@ switch ($orden) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// Actualizamos la base de datos
|
// Consulta de aciertos
|
||||||
// Buscamos los aciertos de cada jugador en la partida actual
|
|
||||||
$stmtAciertos = $conexion->prepare("
|
$stmtAciertos = $conexion->prepare("
|
||||||
SELECT ra.idUsuario, exu.idEquipo, COUNT(*) as aciertos_partida
|
SELECT ra.idUsuario, exu.idEquipo, COUNT(*) as aciertos_partida
|
||||||
FROM respuestaalmacenada ra
|
FROM respuestaalmacenada ra
|
||||||
@@ -90,12 +88,12 @@ switch ($orden) {
|
|||||||
INNER JOIN respuesta r ON ra.idRespuesta = r.idRespuesta
|
INNER JOIN respuesta r ON ra.idRespuesta = r.idRespuesta
|
||||||
INNER JOIN equipoxusuario exu ON ra.idUsuario = exu.idUsuario
|
INNER JOIN equipoxusuario exu ON ra.idUsuario = exu.idUsuario
|
||||||
WHERE pxp.idPartida = :idPartida AND r.correcta = 1
|
WHERE pxp.idPartida = :idPartida AND r.correcta = 1
|
||||||
GROUP BY ra.idUsuario
|
GROUP BY ra.idUsuario, exu.idEquipo
|
||||||
");
|
");
|
||||||
$stmtAciertos->execute([':idPartida' => $idPartida]);
|
$stmtAciertos->execute([':idPartida' => $idPartida]);
|
||||||
$jugadoresPartida = $stmtAciertos->fetchAll(PDO::FETCH_ASSOC);
|
$jugadoresPartida = $stmtAciertos->fetchAll(PDO::FETCH_ASSOC);
|
||||||
|
|
||||||
$updateAciertosGlobales = $conexion->prepare("
|
$updateAciertos = $conexion->prepare("
|
||||||
UPDATE usuario
|
UPDATE usuario
|
||||||
SET aciertos = aciertos + :nuevos_aciertos
|
SET aciertos = aciertos + :nuevos_aciertos
|
||||||
WHERE idUsuario = :idUsuario
|
WHERE idUsuario = :idUsuario
|
||||||
@@ -107,7 +105,6 @@ switch ($orden) {
|
|||||||
$idE = (int)$jp['idEquipo'];
|
$idE = (int)$jp['idEquipo'];
|
||||||
$nuevosAciertos = (int)$jp['aciertos_partida'];
|
$nuevosAciertos = (int)$jp['aciertos_partida'];
|
||||||
|
|
||||||
// Sumamos los aciertos al perfil del usuario
|
|
||||||
$updateAciertos->execute([
|
$updateAciertos->execute([
|
||||||
':nuevos_aciertos' => $nuevosAciertos,
|
':nuevos_aciertos' => $nuevosAciertos,
|
||||||
':idUsuario' => $idU
|
':idUsuario' => $idU
|
||||||
@@ -119,34 +116,42 @@ switch ($orden) {
|
|||||||
$puntosEquipos[$idE] += $nuevosAciertos;
|
$puntosEquipos[$idE] += $nuevosAciertos;
|
||||||
}
|
}
|
||||||
|
|
||||||
// Determinamos qué equipo ha obtenido más aciertos en la partida
|
if (!empty($puntosEquipos)) {
|
||||||
arsort($puntosEquipos);
|
arsort($puntosEquipos);
|
||||||
$idEquipoGanador = key($puntosEquipos);
|
$idEquipoGanador = key($puntosEquipos);
|
||||||
|
|
||||||
// Obtenemos todos los usuarios de la partida para asignar victorias/derrotas
|
$stmtMiembros = $conexion->prepare("
|
||||||
$stmtMiembros = $conexion->prepare("
|
SELECT exu.idUsuario, exu.idEquipo
|
||||||
SELECT exu.idUsuario, exu.idEquipo
|
FROM equipoxpartida exp
|
||||||
FROM equipoxpartida exp
|
INNER JOIN equipoxusuario exu ON exp.idEquipo = exu.idEquipo
|
||||||
INNER JOIN equipoxusuario exu ON exp.idEquipo = exu.idEquipo
|
WHERE exp.idPartida = :idPartida
|
||||||
WHERE exp.idPartida = :idPartida
|
");
|
||||||
");
|
$stmtMiembros->execute([':idPartida' => $idPartida]);
|
||||||
$stmtMiembros->execute([':idPartida' => $idPartida]);
|
$todosLosMiembros = $stmtMiembros->fetchAll(PDO::FETCH_ASSOC);
|
||||||
$todosLosMiembros = $stmtMiembros->fetchAll(PDO::FETCH_ASSOC);
|
|
||||||
|
|
||||||
$updateVictoria = $conexion->prepare("UPDATE usuario SET victorias = victorias + 1 WHERE idUsuario = :idUsuario");
|
$updateVictoria = $conexion->prepare("UPDATE usuario SET victorias = victorias + 1 WHERE idUsuario = :idUsuario");
|
||||||
$updateDerrota = $conexion->prepare("UPDATE usuario SET derrotas = derrotas + 1 WHERE idUsuario = :idUsuario");
|
$updateDerrota = $conexion->prepare("UPDATE usuario SET derrotas = derrotas + 1 WHERE idUsuario = :idUsuario");
|
||||||
|
|
||||||
foreach ($todosLosMiembros as $miembro) {
|
foreach ($todosLosMiembros as $miembro) {
|
||||||
$idU = (int)$miembro['idUsuario'];
|
$idU = (int)$miembro['idUsuario'];
|
||||||
$idE = (int)$miembro['idEquipo'];
|
$idE = (int)$miembro['idEquipo'];
|
||||||
|
|
||||||
if ($idE === $idEquipoGanador) {
|
if ($idE === $idEquipoGanador) {
|
||||||
$updateVictoria->execute([':idUsuario' => $idU]);
|
$updateVictoria->execute([':idUsuario' => $idU]);
|
||||||
} else {
|
} else {
|
||||||
$updateDerrota->execute([':idUsuario' => $idU]);
|
$updateDerrota->execute([':idUsuario' => $idU]);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Marcar fecha fin de la partida para los históricos globales del grupo
|
||||||
|
$stmtFinalizar = $conexion->prepare("
|
||||||
|
UPDATE partida
|
||||||
|
SET fechaFin = NOW()
|
||||||
|
WHERE idPartida = :idPartida AND fechaFin IS NULL
|
||||||
|
");
|
||||||
|
$stmtFinalizar->execute([':idPartida' => $idPartida]);
|
||||||
|
|
||||||
$conexion->commit();
|
$conexion->commit();
|
||||||
$_SESSION['partidas_procesadas'][$idPartida] = true;
|
$_SESSION['partidas_procesadas'][$idPartida] = true;
|
||||||
}
|
}
|
||||||
@@ -160,7 +165,70 @@ switch ($orden) {
|
|||||||
}
|
}
|
||||||
break;
|
break;
|
||||||
|
|
||||||
default:
|
case 'registrarSalidaUsuario':
|
||||||
echo json_encode(['error' => 'Acción no permitida']);
|
try {
|
||||||
|
$idUsuario = (int)$_SESSION['idUsuario'];
|
||||||
|
$conexion->beginTransaction();
|
||||||
|
|
||||||
|
// A. LIBERACIÓN INMEDIATA DEL JUGADOR ACTUAL: Lo borramos de su equipo
|
||||||
|
$stmtSalir = $conexion->prepare("DELETE FROM equipoxusuario WHERE idUsuario = :idUsuario");
|
||||||
|
$stmtSalir->execute([':idUsuario' => $idUsuario]);
|
||||||
|
|
||||||
|
// B. CONTADOR DE ALUMNOS QUEDAN: Contamos cuántas personas quedan en los equipos de esta partida
|
||||||
|
$stmtContarQuedan = $conexion->prepare("
|
||||||
|
SELECT COUNT(exu.idUsuario)
|
||||||
|
FROM equipoxpartida exp
|
||||||
|
INNER JOIN equipoxusuario exu ON exp.idEquipo = exu.idEquipo
|
||||||
|
WHERE exp.idPartida = :idPartida
|
||||||
|
");
|
||||||
|
$stmtContarQuedan->execute([':idPartida' => $idPartida]);
|
||||||
|
$jugadoresRestantes = (int)$stmtContarQuedan->fetchColumn();
|
||||||
|
|
||||||
|
// C. DESTRUCCIÓN EN CADENA AUTOMÁTICA ATÓMICA (Si da 0, somos los últimos en salir)
|
||||||
|
if ($jugadoresRestantes === 0) {
|
||||||
|
// 1. Limpiar las respuestas almacenadas
|
||||||
|
$stmtBorrarRespuestas = $conexion->prepare("
|
||||||
|
DELETE ra FROM respuestaalmacenada ra
|
||||||
|
INNER JOIN partidaxpregunta pxp ON ra.idPartidaxPregunta = pxp.idPartidaxPregunta
|
||||||
|
WHERE pxp.idPartida = :idPartida
|
||||||
|
");
|
||||||
|
$stmtBorrarRespuestas->execute([':idPartida' => $idPartida]);
|
||||||
|
|
||||||
|
// 2. Limpiar las preguntas vinculadas a la partida
|
||||||
|
$stmtBorrarPreguntas = $conexion->prepare("DELETE FROM partidaxpregunta WHERE idPartida = :idPartida");
|
||||||
|
$stmtBorrarPreguntas->execute([':idPartida' => $idPartida]);
|
||||||
|
|
||||||
|
// 3. NUEVO: Obtener los IDs de los dos equipos que jugaban en esta partida antes de borrar la relación
|
||||||
|
$stmtObtenerEquipos = $conexion->prepare("SELECT idEquipo FROM equipoxpartida WHERE idPartida = :idPartida");
|
||||||
|
$stmtObtenerEquipos->execute([':idPartida' => $idPartida]);
|
||||||
|
$equiposDeLaPartida = $stmtObtenerEquipos->fetchAll(PDO::FETCH_COLUMN);
|
||||||
|
|
||||||
|
// 4. Limpiar la relación de equipos de la partida (tabla intermedia)
|
||||||
|
$stmtBorrarEquiposPartida = $conexion->prepare("DELETE FROM equipoxpartida WHERE idPartida = :idPartida");
|
||||||
|
$stmtBorrarEquiposPartida = $conexion->prepare("DELETE FROM equipoxpartida WHERE idPartida = :idPartida");
|
||||||
|
$stmtBorrarEquiposPartida->execute([':idPartida' => $idPartida]);
|
||||||
|
|
||||||
|
// 5. NUEVO: Borrar físicamente los equipos de la tabla 'equipo' si existen
|
||||||
|
if (!empty($equiposDeLaPartida)) {
|
||||||
|
// Creamos los marcadores (?, ?) de forma dinámica según los equipos que devuelva
|
||||||
|
$inQuery = implode(',', array_fill(0, count($equiposDeLaPartida), '?'));
|
||||||
|
$stmtBorrarEquiposFisicos = $conexion->prepare("DELETE FROM equipo WHERE idEquipo IN ($inQuery)");
|
||||||
|
$stmtBorrarEquiposFisicos->execute($equiposDeLaPartida);
|
||||||
|
}
|
||||||
|
|
||||||
|
// 6. Borrar físicamente la fila de la partida principal
|
||||||
|
$stmtBorrarSala = $conexion->prepare("DELETE FROM partida WHERE idPartida = :idPartida");
|
||||||
|
$stmtBorrarSala->execute([':idPartida' => $idPartida]);
|
||||||
|
}
|
||||||
|
|
||||||
|
$conexion->commit();
|
||||||
|
echo json_encode(['exito' => true, 'usuarios_quedan' => $jugadoresRestantes]);
|
||||||
|
} catch (PDOException $e) {
|
||||||
|
if ($conexion->inTransaction()) {
|
||||||
|
$conexion->rollBack();
|
||||||
|
}
|
||||||
|
echo json_encode(['error' => $e->getMessage()]);
|
||||||
|
}
|
||||||
break;
|
break;
|
||||||
}
|
|
||||||
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user