triviagmatico/clases/ClaseEquipoxUsuario.php

<?php
require_once __DIR__ . '/../includes/conexionBD.php';


class EquipoxUsuario
{
    public $idEquipoxUsuario;
    public $idUsuario;
    public $idEquipo;

    public function __construct($idEquipoxUsuario = null, $idUsuario = null, $idEquipo = null)
    {
        $this->idEquipoxUsuario = $idEquipoxUsuario;
        $this->idUsuario = $idUsuario;
        $this->idEquipo = $idEquipo;
    }

    public function registrarUsuarioEnEquipo()
    {
        $conexion = conexionBD();
        if (is_array($conexion)) return $conexion;

        try {
            $sql = "INSERT INTO equipoxusuario (idUsuario, idEquipo) VALUES (:idUsuario, :idEquipo)";
            $consulta = $conexion->prepare($sql);
            $consulta->bindParam(':idUsuario', $this->idUsuario);
            $consulta->bindParam(':idEquipo', $this->idEquipo);
            $consulta->execute();

            return [
                'exito' => 'Usuario vinculado al equipo correctamente.',
                'exito_tecnico' => $conexion->lastInsertId()
            ];
        } catch (PDOException $error) {
            return [
                'error' => 'Ocurrió un error al unir al usuario con el equipo.',
                'error_tecnico' => $error->getMessage()
            ];
        }
    }

    public static function listarUsuariosPorEquipo($idEquipo)
    {
        $conexion = conexionBD();
        if (is_array($conexion)) return $conexion;

        try {
            $sql = "SELECT u.* FROM equipoxusuario exu 
                    INNER JOIN usuario u ON exu.idUsuario = u.idUsuario 
                    WHERE exu.idEquipo = :idEquipo";
            $consulta = $conexion->prepare($sql);
            $consulta->bindParam(':idEquipo', $idEquipo);
            $consulta->execute();

            return $consulta->fetchAll(PDO::FETCH_ASSOC);
        } catch (PDOException $error) {
            return [
                'error' => 'Ocurrió un error al obtener los miembros del equipo.',
                'error_tecnico' => $error->getMessage()
            ];
        }
    }
    public function obtenerSalaUsuario($idUsuario)
    {
        $conexion = conexionBD();

        if (is_array($conexion)) {
            return $conexion;
        }

        try {

            $sql = "
            SELECT
                exu.idEquipo,
                exp.idPartida
            FROM equipoxusuario exu

            INNER JOIN equipoxpartida exp
                ON exu.idEquipo = exp.idEquipo

            WHERE exu.idUsuario = :idUsuario

            LIMIT 1
        ";

            $consulta = $conexion->prepare($sql);

            $consulta->bindParam(
                ':idUsuario',
                $idUsuario,
                PDO::PARAM_INT
            );

            $consulta->execute();

            $resultado = $consulta->fetch(PDO::FETCH_ASSOC);

            if (!$resultado) {

                return [
                    'asociado' => false
                ];
            }

            return [
                'asociado' => true,
                'idEquipo' => $resultado['idEquipo'],
                'idPartida' => $resultado['idPartida']
            ];
        } catch (PDOException $error) {

            return [
                'error' => 'Ocurrió un error al obtener la sala del usuario.',
                'error_tecnico' => $error->getMessage()
            ];
        }
    }

    public static function salirDeSala($idUsuario)
    {
        $conexion = conexionBD();

        if (is_array($conexion)) {
            return $conexion;
        }

        try {

            // 1. Averiguamos el equipo y la partida del usuario
            $sql = "
            SELECT exu.idEquipo, exp.idPartida, p.idUsuario AS idHost FROM equipoxusuario exu INNER JOIN equipoxpartida exp ON exu.idEquipo = exp.idEquipo INNER JOIN partida p ON exp.idPartida = p.idPartida WHERE exu.idUsuario = :idUsuario LIMIT 1";

            $consulta = $conexion->prepare($sql);
            $consulta->bindParam(
                ':idUsuario',
                $idUsuario,
                PDO::PARAM_INT
            );
            $consulta->execute();

            $datosSala = $consulta->fetch(PDO::FETCH_ASSOC);

            // El usuario no pertenece a ninguna sala
            if (!$datosSala) {
                return [
                    'error' => 'No perteneces a ninguna sala.'
                ];
            }

            $idEquipo = (int)$datosSala['idEquipo'];
            $idPartida = (int)$datosSala['idPartida'];
            $idHost = (int)$datosSala['idHost'];

            // Comenzamos una transacción
            $conexion->beginTransaction();

            /*
         * 2. Comprobamos si quien abandona es el HOST
         */
            if ($idUsuario === $idHost) {

                /*
             * Obtenemos todos los equipos pertenecientes
             * a esta partida.
             */
                $sqlEquipos = "
                SELECT idEquipo
                FROM equipoxpartida
                WHERE idPartida = :idPartida
            ";

                $consultaEquipos = $conexion->prepare($sqlEquipos);
                $consultaEquipos->bindParam(
                    ':idPartida',
                    $idPartida,
                    PDO::PARAM_INT
                );
                $consultaEquipos->execute();

                $equipos = $consultaEquipos->fetchAll(PDO::FETCH_COLUMN);

                /*
             * 3. Eliminamos los jugadores de esos equipos
             * de la tabla equipoxusuario.
             */
                if (!empty($equipos)) {

                    $placeholders = implode(
                        ',',
                        array_fill(0, count($equipos), '?')
                    );

                    $sqlUsuarios = "
                    DELETE FROM equipoxusuario
                    WHERE idEquipo IN ($placeholders)
                ";

                    $consultaUsuarios = $conexion->prepare($sqlUsuarios);
                    $consultaUsuarios->execute($equipos);
                }

                /*
             * 4. Eliminamos las relaciones
             * entre equipos y partida.
             */
                $sqlEquipoxPartida = "
                DELETE FROM equipoxpartida
                WHERE idPartida = :idPartida
            ";

                $consultaEquipoxPartida = $conexion->prepare(
                    $sqlEquipoxPartida
                );

                $consultaEquipoxPartida->bindParam(
                    ':idPartida',
                    $idPartida,
                    PDO::PARAM_INT
                );

                $consultaEquipoxPartida->execute();

                /*
             * 5. Eliminamos los equipos.
             *
             * Los equipos ya no tienen relaciones con
             * usuarios ni con la partida.
             */
                if (!empty($equipos)) {

                    $placeholders = implode(
                        ',',
                        array_fill(0, count($equipos), '?')
                    );

                    $sqlEliminarEquipos = "
                    DELETE FROM equipo
                    WHERE idEquipo IN ($placeholders)
                ";

                    $consultaEliminarEquipos =
                        $conexion->prepare($sqlEliminarEquipos);

                    $consultaEliminarEquipos->execute($equipos);
                }

                /*
             * 6. Finalmente eliminamos la partida.
             */
                $sqlPartida = "
                DELETE FROM partida
                WHERE idPartida = :idPartida
            ";

                $consultaPartida = $conexion->prepare($sqlPartida);

                $consultaPartida->bindParam(
                    ':idPartida',
                    $idPartida,
                    PDO::PARAM_INT
                );

                $consultaPartida->execute();

                // Todo ha ido correctamente
                $conexion->commit();

                return [
                    'exito' => true,
                    'salaEliminada' => true,
                    'mensaje' => 'La sala ha sido eliminada correctamente.'
                ];
            }

            /*
         * 7. Si NO es el host, simplemente abandona
         * su relación con el equipo.
         */
            $sqlSalir = "
            DELETE FROM equipoxusuario
            WHERE idUsuario = :idUsuario
        ";

            $consultaSalir = $conexion->prepare($sqlSalir);

            $consultaSalir->bindParam(
                ':idUsuario',
                $idUsuario,
                PDO::PARAM_INT
            );

            $consultaSalir->execute();

            $conexion->commit();

            return [
                'exito' => true,
                'salaEliminada' => false,
                'mensaje' => 'Has abandonado la sala correctamente.'
            ];
        } catch (PDOException $error) {

            // Si había una transacción activa, la deshacemos
            if ($conexion->inTransaction()) {
                $conexion->rollBack();
            }

            return [
                'error' => 'Ocurrió un error al abandonar la sala.',
                'error_tecnico' => $error->getMessage()
            ];
        }
    }
}