article.dao.php

Aller à la documentation de ce fichier.

<?php
 
namespace ComusParty\Models;
 
 
use ComusParty\App\Exceptions\NotFoundException;
use DateMalformedStringException;
use DateTime;
use Exception;
use PDO;

class ArticleDAO
{
    private ?PDO $pdo;
 

    public function __construct(?PDO $pdo)
    {
        $this->pdo = $pdo;
    }

    public function getPdo(): ?PDO
    {
        return $this->pdo;
    }

    public function setPdo(?PDO $pdo): void
    {
        $this->pdo = $pdo;
    }

    public function findArticlesByInvoiceId(?int $invoiceId): ?array
    {
        $stmt = $this->pdo->prepare(
            'SELECT *
          FROM ' . DB_PREFIX . 'invoice i
          JOIN ' . DB_PREFIX . 'player p ON i.player_uuid = p.uuid
          WHERE i.id = :id AND p.uuid = :uuid');
        $stmt->bindParam(':id', $invoiceId);
        $stmt->bindParam(':uuid', $_SESSION['uuid']);
        $stmt->execute();
        $stmt->setFetchMode(PDO::FETCH_ASSOC);
        $invoice = $stmt->fetch();
        if ($invoice === false) {
            throw new NotFoundException('Cette facture n\'existe pas.');
        }
 
        $stmt = $this->pdo->prepare(
            'SELECT a.*
            FROM ' . DB_PREFIX . 'article a
            JOIN ' . DB_PREFIX . 'invoice_row ir ON a.id = ir.article_id
            WHERE ir.invoice_id = :invoice_id');
        $stmt->bindParam(':invoice_id', $invoiceId);
        $stmt->execute();
        $stmt->setFetchMode(PDO::FETCH_ASSOC);
        $articles = $stmt->fetchAll();
        if ($articles === false) {
            return null;
        }
        return $this->hydrateMany($articles);
    }

    public function hydrateMany(array $data): array
    {
        $articles = [];
        foreach ($data as $article) {
            $articles[] = $this->hydrate($article);
        }
        return $articles;
    }

    public function hydrate(array $data): Article
    {
        $article = new Article();
        $article->setId($data['id']);
        $article->setName($data['name']);
 
        if ($data['type'] == 'pfp') {
            $type = ArticleType::ProfilePicture;
        } elseif ($data['type'] == 'banner') {
            $type = ArticleType::Banner;
        }
 
        $article->setType($type);
        $article->setDescription($data['description']);
        $article->setPricePoint($data['price_point']);
        $article->setPriceEuro($data['price_euro']);
 
        $article->setCreatedAt(new DateTime($data['created_at']));
        $article->setUpdatedAt(new DateTime($data['updated_at']));
        $article->setFilePath($data['file_path']);
 
        return $article;
    }

    public function findAllPfpsOwnedByPlayer(string $uuid): ?array
    {
        $stmt = $this->pdo->prepare(
            'SELECT a.*
            FROM ' . DB_PREFIX . 'article a
            JOIN ' . DB_PREFIX . 'invoice_row ir ON a.id = ir.article_id
            JOIN ' . DB_PREFIX . 'invoice i ON ir.invoice_id = i.id
            WHERE i.player_uuid = :uuid AND type = "pfp" ');
        $stmt->bindParam(':uuid', $uuid);
        $stmt->execute();
        $stmt->setFetchMode(PDO::FETCH_ASSOC);
        $articles = $stmt->fetchAll();
        return $this->hydrateMany($articles);
    }

    public function findAllBannersOwnedByPlayer(string $uuid): ?array
    {
        $stmt = $this->pdo->prepare(
            'SELECT a.*
            FROM ' . DB_PREFIX . 'article a
            JOIN ' . DB_PREFIX . 'invoice_row ir ON a.id = ir.article_id
            JOIN ' . DB_PREFIX . 'invoice i ON ir.invoice_id = i.id
            WHERE i.player_uuid = :uuid AND type = "banner" ');
        $stmt->bindParam(':uuid', $uuid);
        $stmt->execute();
        $stmt->setFetchMode(PDO::FETCH_ASSOC);
        $articles = $stmt->fetchAll();
        return $this->hydrateMany($articles);
    }
 

 
    public function findAll(): ?array
    {
        $stmt = $this->pdo->query(
            'SELECT *
            FROM ' . DB_PREFIX . 'article');
        $stmt->setFetchMode(PDO::FETCH_ASSOC);
        $tabArticles = $stmt->fetchAll();
        if ($tabArticles === false) {
            return null;
        }
        return $this->hydrateMany($tabArticles);
    }

    function findArticlesWithIds(array $ids): ?array
    {
 
        if (!empty($ids)) {
            $idsString = implode(',', $ids);
 
            $stmt = $this->pdo->query('SELECT * FROM ' . DB_PREFIX . 'article WHERE id IN (' . $idsString . ')');
            $stmt->setFetchMode(PDO::FETCH_ASSOC);
 
            $tabArticles = $stmt->fetchAll();
 
            if ($tabArticles === false) {
                return null;
            }
            return $this->hydrateMany($tabArticles);
        }
        return null;
    }

 
    public function findAllPfps(): ?array
    {
        $stmt = $this->pdo->query("SELECT *
        FROM " . DB_PREFIX . "article
        WHERE type = 'pfp'");
 
        $stmt->setFetchMode(PDO::FETCH_ASSOC);
        $tabPfps = $stmt->fetchAll();
 
        if ($tabPfps === false) {
            return null;
        }
        return $this->hydrateMany($tabPfps);
    }

    public function findAllBanners(): ?array
    {
        $stmt = $this->pdo->query("SELECT *
        FROM " . DB_PREFIX . "article
        WHERE type = 'banner'");
        $stmt->setFetchMode(PDO::FETCH_ASSOC);
        $tabBanners = $stmt->fetchAll();
        if ($tabBanners === false) {
            return null;
        }
        return $this->hydrateMany($tabBanners);
 
    }

    public function updateActiveArticle(string $uuid, string $idArticle, string $typeArticle)
    {
        if ($typeArticle == "ProfilePicture") {
            $pfpActive = $this->findActivePfpByPlayerUuid($uuid);
            // Si pfp déjà équipé
            if ($pfpActive != null) {
                $idPfpActive = $pfpActive->getId();
                $stmt = $this->pdo->prepare(
                    'UPDATE ' . DB_PREFIX . 'invoice_row ir
        JOIN ' . DB_PREFIX . 'invoice i ON ir.invoice_id = i.id
        JOIN ' . DB_PREFIX . 'article a ON ir.article_id = a.id
        SET ir.active = 0
        WHERE i.player_uuid = :uuid AND ir.article_id = :idArticleActif');
                $stmt->bindParam(':uuid', $uuid);
                $stmt->bindParam(':idArticleActif', $idPfpActive);
                $stmt->execute();
 
            }
 
// Mettre en active la pfp choisie
            $stmt = $this->pdo->prepare(
                'UPDATE ' . DB_PREFIX . 'invoice_row ir
        JOIN ' . DB_PREFIX . 'invoice i ON ir.invoice_id = i.id
        JOIN ' . DB_PREFIX . 'article a ON ir.article_id = a.id
        SET ir.active = 1
        WHERE i.player_uuid = :uuid AND ir.article_id = :idArticle'
            );
            $stmt->bindParam(':uuid', $uuid);
            $stmt->bindParam(':idArticle', $idArticle);
            $ok = $stmt->execute();
            $pfp = $this->findById($idArticle);
            if ($pfp != null) {
                $_SESSION['pfpPath'] = $pfp->getFilePath();
            }
            return $ok;
        }
 
        if ($typeArticle == "Banner") {
            $bannerActive = $this->findActiveBannerByPlayerUuid($uuid);
 
            //Si banner déjà équipé
            if ($bannerActive != null) {
                $idBannerActive = $bannerActive->getId();
                $stmt = $this->pdo->prepare(
                    'UPDATE ' . DB_PREFIX . 'invoice_row ir
        JOIN ' . DB_PREFIX . 'invoice i ON ir.invoice_id = i.id
        JOIN ' . DB_PREFIX . 'article a ON ir.article_id = a.id
        SET ir.active = 0
        WHERE i.player_uuid = :uuid AND ir.article_id = :idArticleActif');
                $stmt->bindParam(':uuid', $uuid);
                $stmt->bindParam(':idArticleActif', $idBannerActive);
                $ok = $stmt->execute();
 
            }
 
            //Met en active la bannière choisie
            $stmt = $this->pdo->prepare(
                'UPDATE ' . DB_PREFIX . 'invoice_row ir
        JOIN ' . DB_PREFIX . 'invoice i ON ir.invoice_id = i.id
        JOIN ' . DB_PREFIX . 'article a ON ir.article_id = a.id
        SET ir.active = 1
        WHERE i.player_uuid = :uuid AND ir.article_id = :idArticle'
            );
            $stmt->bindParam(':uuid', $uuid);
            $stmt->bindParam(':idArticle', $idArticle);
            $ok = $stmt->execute();
            $banner = $this->findById($idArticle);
            if ($banner != null) {
                $_SESSION['bannerPath'] = $banner->getFilePath();
            }
            return $ok;
 
        }
    }

    public function findActivePfpByPlayerUuid(string $uuid): ?Article
    {
        $stmt = $this->pdo->prepare(
            'SELECT a.*
            FROM ' . DB_PREFIX . 'article a
            JOIN ' . DB_PREFIX . 'invoice_row ir ON a.id = ir.article_id
            JOIN ' . DB_PREFIX . 'invoice i ON ir.invoice_id = i.id
            WHERE i.player_uuid = :uuid AND a.type = "pfp" AND ir.active = 1');
        $stmt->bindParam(':uuid', $uuid);
        $stmt->execute();
        $stmt->setFetchMode(PDO::FETCH_ASSOC);
        $pfp = $stmt->fetch();
        if ($pfp === false) {
            return null;
        }
        return $this->hydrate($pfp);
    }

    public function findById(string $id): ?Article
    {
        $stmt = $this->pdo->prepare(
            'SELECT *
            FROM ' . DB_PREFIX . 'article
            WHERE id = :id');
        $stmt->bindParam(':id', $id);
        $stmt->execute();
        $stmt->setFetchMode(PDO::FETCH_ASSOC);
        $article = $stmt->fetch();
        if ($article === false) {
            return null;
        }
        return $this->hydrate($article);
    }

    public function findActiveBannerByPlayerUuid(string $uuid): ?Article
    {
        $stmt = $this->pdo->prepare(
            'SELECT a.*
            FROM ' . DB_PREFIX . 'article a
            JOIN ' . DB_PREFIX . 'invoice_row ir ON a.id = ir.article_id
            JOIN ' . DB_PREFIX . 'invoice i ON ir.invoice_id = i.id
            WHERE i.player_uuid = :uuid AND a.type = "banner" AND ir.active = 1');
        $stmt->bindParam(':uuid', $uuid);
        $stmt->execute();
        $stmt->setFetchMode(PDO::FETCH_ASSOC);
        $banner = $stmt->fetch();
        if ($banner === false) {
            return null;
        }
        return $this->hydrate($banner);
    }

    public function deleteActiveArticleForPfp(string $uuid): void
    {
        $stmt = $this->pdo->prepare(
            'SELECT p.*
            FROM ' . DB_PREFIX . 'player p
            WHERE p.uuid = :uuid');
        $stmt->bindParam(':uuid', $uuid);
        $stmt->execute();
        if ($stmt->rowCount() === 0) {
            // Gérer le cas où aucune ligne n'est affectée
            throw new NotFoundException('No player found for the given UUID');
        } else {
            $stmt = $this->pdo->prepare(
                'UPDATE ' . DB_PREFIX . 'invoice_row ir
        JOIN ' . DB_PREFIX . 'invoice i ON ir.invoice_id = i.id
        JOIN ' . DB_PREFIX . 'article a ON ir.article_id = a.id
        SET ir.active = 0 
        WHERE i.player_uuid = :uuid AND a.type = "pfp"');
            $stmt->bindParam(':uuid', $uuid);
            $stmt->execute();
        }
 
 
    }

    public function deleteActiveArticleForBanner(string $uuid): void
    {
        $stmt = $this->pdo->prepare(
            'UPDATE ' . DB_PREFIX . 'invoice_row ir
        JOIN ' . DB_PREFIX . 'invoice i ON ir.invoice_id = i.id
        JOIN ' . DB_PREFIX . 'article a ON ir.article_id = a.id
        SET ir.active = 0 
        WHERE i.player_uuid = :uuid AND a.type = "banner"');
        $stmt->bindParam(':uuid', $uuid);
        $stmt->execute();
    }
}