From 4f542096908641ab807fb511c61f303310341ad1 Mon Sep 17 00:00:00 2001
From: Cedric <cedric.chagnaud@gmail.com>
Date: Mon, 22 Jun 2026 15:13:32 +0200
Subject: [PATCH] Actualiser api.php

---
 api.php | 19 +++++++++++++------
 1 file changed, 13 insertions(+), 6 deletions(-)

diff --git a/api.php b/api.php
index bdfa5fd..0b7a1e0 100644
--- a/api.php
+++ b/api.php
@@ -16,7 +16,7 @@ try {
     ]);
     $pdo->exec("CREATE TABLE IF NOT EXISTS users (id INT PRIMARY KEY, username VARCHAR(50) NOT NULL, password_hash VARCHAR(255) NOT NULL)");
     $pdo->exec("CREATE TABLE IF NOT EXISTS config (key_name VARCHAR(50) PRIMARY KEY, key_value TEXT NOT NULL)");
-    $pdo->exec("CREATE TABLE IF NOT EXISTS critiques (id BIGINT PRIMARY KEY, title VARCHAR(255) NOT NULL, year VARCHAR(10), director VARCHAR(255), poster TEXT, rating DECIMAL(3,1) DEFAULT 3.0, review TEXT, streaming VARCHAR(255))");
+    $pdo->exec("CREATE TABLE IF NOT EXISTS critiques (id BIGINT PRIMARY KEY, title VARCHAR(255) NOT NULL, year VARCHAR(10), director VARCHAR(255), poster TEXT, rating DECIMAL(3,1) DEFAULT NULL, review TEXT, streaming VARCHAR(255))");
     $pdo->exec("CREATE TABLE IF NOT EXISTS videotheque (id BIGINT PRIMARY KEY, title VARCHAR(255) NOT NULL, year VARCHAR(10), director VARCHAR(255), poster TEXT, format VARCHAR(50), length VARCHAR(50), publisher VARCHAR(255), ean_isbn13 VARCHAR(50), number_of_discs INT DEFAULT 1, aspect_ratio VARCHAR(50), description TEXT)");
     $pdo->exec("CREATE TABLE IF NOT EXISTS cache_api (cache_key VARCHAR(120) PRIMARY KEY, data TEXT NOT NULL, source VARCHAR(20) NOT NULL, created_at INT NOT NULL)");
 } catch (\PDOException $e) { echo json_encode(["error" => "Erreur BDD : " . $e->getMessage()]); exit; }
@@ -208,6 +208,7 @@ switch ($action) {
         $type = $data['type'] ?? 'videotheque';
         $tmdbApiKey = getTmdbApiKey($pdo);
         $imported = 0;
+        try {
         $pdo->beginTransaction();
         foreach ($items as $rowData) {
             $title = $rowData['title'] ?? $rowData['Name'] ?? $rowData['Title'] ?? 'Sans titre';
@@ -216,16 +217,17 @@ switch ($action) {
             $id = makeStableId($type, $title, $year);
             
             if ($type === 'critique') {
-                $rating = isset($rowData['Rating']) && $rowData['Rating'] !== '' ? (float)$rowData['Rating'] : (isset($rowData['rating']) ? (float)$rowData['rating'] : 3.0);
+                $ratingRaw = $rowData['Rating'] ?? $rowData['rating'] ?? '';
+                $rating = ($ratingRaw !== '' && $ratingRaw !== null) ? (float)$ratingRaw : null;
                 $review = $rowData['Review'] ?? $rowData['review'] ?? '';
-                $director = ''; $poster = '';
+                $director = ''; $poster = ''; $streaming = '';
                 if ($tmdbApiKey && !empty($title)) {
                     $tmdbData = fetchTMDBFull($title, $year, $tmdbApiKey, $pdo);
-                    if ($tmdbData) { $director = $tmdbData['director']; $poster = $tmdbData['poster']; if(empty($year)) $year = $tmdbData['year']; }
+                    if ($tmdbData) { $director = $tmdbData['director']; $poster = $tmdbData['poster']; $streaming = $tmdbData['streaming']; if(empty($year)) $year = $tmdbData['year']; }
                 }
-                $sql = "INSERT INTO critiques (id, title, year, director, poster, rating, review, streaming) VALUES (?, ?, ?, ?, ?, ?, ?, ?) ON DUPLICATE KEY UPDATE rating=VALUES(rating), review=IF(VALUES(review)!='',VALUES(review),review), director=IF(VALUES(director)!='',VALUES(director),director), poster=IF(VALUES(poster)!='',VALUES(poster),poster)";
+                $sql = "INSERT INTO critiques (id, title, year, director, poster, rating, review, streaming) VALUES (?, ?, ?, ?, ?, ?, ?, ?) ON DUPLICATE KEY UPDATE rating=VALUES(rating), review=IF(VALUES(review)!='',VALUES(review),review), director=IF(VALUES(director)!='',VALUES(director),director), poster=IF(VALUES(poster)!='',VALUES(poster),poster), streaming=IF(VALUES(streaming)!='',VALUES(streaming),streaming)";
                 $stmt = $pdo->prepare($sql);
-                $stmt->execute([$id, $title, $year, $director, $poster, $rating, $review, '']);
+                $stmt->execute([$id, $title, $year, $director, $poster, $rating, $review, $streaming]);
             } else {
                 $firstName = $rowData['first_name'] ?? ''; $lastName = $rowData['last_name'] ?? ''; $creators = $rowData['creators'] ?? '';
                 $director = !empty($firstName) && !empty($lastName) ? trim("$firstName $lastName") : $creators;
@@ -241,5 +243,10 @@ switch ($action) {
         }
         $pdo->commit();
         echo json_encode(["success" => true, "imported" => $imported]);
+        } catch (\Exception $e) {
+            $pdo->rollBack();
+            http_response_code(500);
+            echo json_encode(["success" => false, "error" => "Erreur import : " . $e->getMessage()]);
+        }
         break;
 }
\ No newline at end of file