diff --git a/models/Movie.php b/models/Movie.php index 323c3bb..b25f5ee 100644 --- a/models/Movie.php +++ b/models/Movie.php @@ -10,10 +10,31 @@ class Movie { } public function add($userId, $tmdbId, $title, $poster, $type) { + // 1. On insère le film $stmt = $this->db->prepare("INSERT INTO movies (user_id, tmdb_id, title, poster_path, media_type, is_common) VALUES (?, ?, ?, ?, ?, 0)"); - return $stmt->execute([$userId, $tmdbId, $title, $poster, $type]); + $stmt->execute([$userId, $tmdbId, $title, $poster, $type]); + + // 2. On récupère l'ID du partenaire (supposons que tu as une table 'users' avec un champ 'partner_id') + $stmt = $this->db->prepare("SELECT partner_id FROM users WHERE id = ?"); + $stmt->execute([$userId]); + $partnerId = $stmt->fetchColumn(); + + // 3. Si un partenaire existe, on cherche s'il a déjà ce film + if ($partnerId) { + $stmt = $this->db->prepare("SELECT id FROM movies WHERE user_id = ? AND tmdb_id = ? AND is_common = 0"); + $stmt->execute([$partnerId, $tmdbId]); + $partnerMovie = $stmt->fetch(); + + // 4. Si le partenaire a le film, on bascule les DEUX en "common" + if ($partnerMovie) { + $stmt = $this->db->prepare("UPDATE movies SET is_common = 1 WHERE tmdb_id = ? AND (user_id = ? OR user_id = ?)"); + $stmt->execute([$tmdbId, $userId, $partnerId]); + } } + return true; +} + public function share($movieId, $userId) { $stmt = $this->db->prepare("UPDATE movies SET is_common = 1 WHERE id = ? AND user_id = ?"); return $stmt->execute([$movieId, $userId]);