Cedric/mon-petit-cinema
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Actualiser api.php

Browse Source
This commit is contained in:
Cedric
2026-06-21 14:44:49 +02:00
parent 80147a31c9
commit 6fb9896c8e
1 changed files with 94 additions and 280 deletions
Download Patch File Download Diff File Expand all files Collapse all files
api.php
+89 -275
View File
@@ -6,10 +6,7 @@ header("Access-Control-Allow-Headers: Content-Type, Authorization");
header("Cache-Control: no-store, no-cache, must-revalidate, max-age=0");
header("Pragma: no-cache");
if ($_SERVER['REQUEST_METHOD'] === 'OPTIONS') {
http_response_code(200);
exit;
}
if ($_SERVER['REQUEST_METHOD'] === 'OPTIONS') { http_response_code(200); exit; }
define('ENCRYPTION_KEY', 'MaCleSecreteSuperRobuste123!');
@@ -18,27 +15,12 @@ try {
PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC
]);
$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 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("ALTER TABLE critiques MODIFY COLUMN rating DECIMAL(3,1) DEFAULT 3.0;");
$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
)");
} catch (\PDOException $e) {
echo json_encode(["error" => "Erreur BDD : " . $e->getMessage()]);
exit;
}
$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)");
} catch (\PDOException $e) { echo json_encode(["error" => "Erreur BDD : " . $e->getMessage()]); exit; }
function makeStableId($title, $year) {
$key = strtolower(trim($title ?? '')) . '|' . trim($year ?? '');
@@ -53,11 +35,7 @@ function checkAuth($pdo) {
$headers = apache_request_headers();
$token = $headers['Authorization'] ?? $headers['authorization'] ?? '';
}
if ($token !== md5(ENCRYPTION_KEY . 'session')) {
http_response_code(403);
echo json_encode(["error" => "Accès interdit."]);
exit;
}
if ($token !== md5(ENCRYPTION_KEY . 'session')) { http_response_code(403); echo json_encode(["error" => "Accès interdit."]); exit; }
}
function encryptData($data) {
@@ -69,11 +47,7 @@ function encryptData($data) {
function decryptData($encryptedStr) {
$decoded = base64_decode($encryptedStr);
if (strpos($decoded, '::') !== false) {
list($encData, $iv) = explode('::', $decoded, 2);
} else {
return null;
}
if (strpos($decoded, '::') !== false) { list($encData, $iv) = explode('::', $decoded, 2); } else { return null; }
$key = hash('sha256', ENCRYPTION_KEY, true);
$iv = substr($iv, 0, 16);
return openssl_decrypt($encData, 'AES-256-CBC', $key, OPENSSL_RAW_DATA, $iv);
@@ -87,140 +61,81 @@ function getTmdbApiKey($pdo) {
return decryptData($row['key_value']);
}
// ── FONCTION HTTP UNIFIÉE (cURL ou file_get_contents) ──
function httpGet($url, $timeout = 8) {
if (function_exists('curl_init')) {
$ch = curl_init($url);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
curl_setopt($ch, CURLOPT_TIMEOUT, $timeout);
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
curl_setopt($ch, CURLOPT_USERAGENT, 'MonCinema/1.0');
$res = curl_exec($ch);
curl_close($ch);
return $res ?: null;
}
$ctx = stream_context_create(['http' => ['timeout' => $timeout, 'user_agent' => 'MonCinema/1.0']]);
return @file_get_contents($url, false, $ctx);
}
// ── RÉCUPÉRATION IMAGE VIA EAN (Open Library API) ──
// ── RÉCUPÉRATION IMAGE VIA EAN (Jaquettes DVD/Blu-ray via Open Library) ──
function fetchImageByEAN($ean) {
if (empty($ean) || strlen($ean) < 10) return null;
// Open Library API (gratuit, sans clé)
$url = "https://openlibrary.org/api/books?bibkeys=ISBN:{$ean}&jscmd=data&format=json";
$res = httpGet($url, 5);
$ctx = stream_context_create(['http' => ['timeout' => 6, 'user_agent' => 'MonCinema/1.0']]);
$res = @file_get_contents($url, false, $ctx);
if (!$res && function_exists('curl_init')) {
$ch = curl_init($url); curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); curl_setopt($ch, CURLOPT_TIMEOUT, 6); $res = curl_exec($ch); curl_close($ch);
}
if ($res) {
$data = json_decode($res, true);
$key = "ISBN:{$ean}";
if (isset($data[$key])) {
// Priorité : cover (grande image) > thumbnail
if (!empty($data[$key]['cover']['large'])) {
return $data[$key]['cover']['large'];
}
if (!empty($data[$key]['cover']['medium'])) {
return $data[$key]['cover']['medium'];
}
if (!empty($data[$key]['cover']['small'])) {
return $data[$key]['cover']['small'];
}
if (!empty($data[$key]['cover']['large'])) return $data[$key]['cover']['large'];
if (!empty($data[$key]['cover']['medium'])) return $data[$key]['cover']['medium'];
}
}
// Fallback : Google Books API
$url = "https://www.googleapis.com/books/v1/volumes?q=isbn:{$ean}&maxResults=1";
$res = httpGet($url, 5);
if ($res) {
$data = json_decode($res, true);
if (!empty($data['items'][0]['volumeInfo']['imageLinks']['thumbnail'])) {
return str_replace('http:', 'https:', $data['items'][0]['volumeInfo']['imageLinks']['thumbnail']);
}
}
return null;
}
// ── RÉCUPÉRATION DONNÉES TMDB ──
// ── DÉTECTION FORMAT & ANNÉE ──
function detectFormat($title) {
$t = strtoupper($title);
if (strpos($t, '4K') !== false || strpos($t, 'UHD') !== false) return 'Blu-ray 4K';
if (strpos($t, 'BLU-RAY') !== false || strpos($t, 'BLURAY') !== false) return 'Blu-ray';
if (strpos($t, 'DVD') !== false) return 'DVD';
if (strpos($t, 'VHS') !== false) return 'VHS';
if (strpos($t, 'COFFRET') !== false || strpos($t, 'TRILOGIE') !== false) return 'Coffret';
return 'DVD';
}
function extractYear($dateStr) {
if (preg_match('/(\d{4})/', $dateStr, $matches)) return $matches[1];
return '';
}
// ── TMDB (Pour les affiches de films et critiques) ──
function fetchTmdbData($title, $year, $apiKey) {
if (empty($apiKey) || empty($title)) return null;
// Nettoyage du titre (enlever [Blu-ray], [Édition Collector], etc.)
$cleanTitle = preg_replace('/\s*\[.*?\]\s*/', '', $title);
$cleanTitle = trim($cleanTitle);
$searchUrl = "https://api.themoviedb.org/3/search/movie?api_key={$apiKey}&query=" . urlencode($cleanTitle) . "&year={$year}&language=fr-FR";
$searchRes = httpGet($searchUrl, 8);
$searchUrl = "https://api.themoviedb.org/3/search/movie?api_key={$apiKey}&query=" . urlencode($title) . "&year={$year}&language=fr-FR";
$ctx = stream_context_create(['http' => ['timeout' => 6, 'user_agent' => 'MonCinema/1.0']]);
$searchRes = @file_get_contents($searchUrl, false, $ctx);
if (!$searchRes && function_exists('curl_init')) { $ch = curl_init($searchUrl); curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); curl_setopt($ch, CURLOPT_TIMEOUT, 6); $searchRes = curl_exec($ch); curl_close($ch); }
if (!$searchRes) return null;
$searchData = json_decode($searchRes, true);
if (empty($searchData['results'])) return null;
$movie = $searchData['results'][0];
$movieId = $movie['id'];
$poster = !empty($movie['poster_path']) ? "https://image.tmdb.org/t/p/w500" . $movie['poster_path'] : '';
// Récupération Réalisateur
$creditsUrl = "https://api.themoviedb.org/3/movie/{$movieId}/credits?api_key={$apiKey}&language=fr-FR";
$creditsRes = httpGet($creditsUrl, 8);
$creditsRes = @file_get_contents($creditsUrl, false, $ctx);
$director = '';
if ($creditsRes) {
$creditsData = json_decode($creditsRes, true);
if (!empty($creditsData['crew'])) {
foreach ($creditsData['crew'] as $crew) {
if ($crew['job'] === 'Director') {
$director = $crew['name'];
break;
}
}
}
if (!empty($creditsData['crew'])) { foreach ($creditsData['crew'] as $crew) { if ($crew['job'] === 'Director') { $director = $crew['name']; break; } } }
}
// Récupération Streaming (France)
$streaming = '';
$watchUrl = "https://api.themoviedb.org/3/movie/{$movieId}/watch/providers?api_key={$apiKey}";
$watchRes = httpGet($watchUrl, 8);
$watchRes = @file_get_contents($watchUrl, false, $ctx);
if ($watchRes) {
$watchData = json_decode($watchRes, true);
$frProviders = $watchData['results']['FR'] ?? [];
$platforms = [];
if (!empty($frProviders['flatrate'])) {
foreach ($frProviders['flatrate'] as $p) $platforms[] = $p['provider_name'];
}
if (!empty($frProviders['flatrate'])) { foreach ($frProviders['flatrate'] as $p) $platforms[] = $p['provider_name']; }
if (empty($platforms)) {
if (!empty($frProviders['rent'])) {
foreach ($frProviders['rent'] as $p) $platforms[] = $p['provider_name'] . ' (loc.)';
}
if (!empty($frProviders['buy'])) {
foreach ($frProviders['buy'] as $p) $platforms[] = $p['provider_name'] . ' (achat)';
}
if (!empty($frProviders['rent'])) { foreach ($frProviders['rent'] as $p) $platforms[] = $p['provider_name'] . ' (loc.)'; }
if (!empty($frProviders['buy'])) { foreach ($frProviders['buy'] as $p) $platforms[] = $p['provider_name'] . ' (achat)'; }
}
if (!empty($platforms)) $streaming = implode(', ', array_unique($platforms));
}
return ['director' => $director, 'poster' => $poster, 'streaming' => $streaming];
}
// ── PARSING DU FORMAT (Blu-ray, DVD, etc.) depuis le titre ──
function detectFormat($title, $description = '') {
$text = strtoupper($title . ' ' . $description);
if (strpos($text, '4K') !== false || strpos($text, 'UHD') !== false) return 'Blu-ray 4K';
if (strpos($text, 'BLU-RAY') !== false || strpos($text, 'BLURAY') !== false) return 'Blu-ray';
if (strpos($text, 'DVD') !== false) return 'DVD';
if (strpos($text, 'VHS') !== false) return 'VHS';
if (strpos($text, 'COFFRET') !== false || strpos($text, 'TRILOGIE') !== false || strpos($text, 'INTEGRALE') !== false) return 'Coffret DVD';
return 'DVD';
}
// ── EXTRACTION ANNÉE depuis publish_date ──
function extractYear($publishDate) {
if (empty($publishDate)) return '';
if (preg_match('/(\d{4})/', $publishDate, $matches)) {
return $matches[1];
}
return '';
}
// ── ROUTEUR PRINCIPAL ─
// ── ROUTEUR PRINCIPAL ──
$action = $_GET['action'] ?? '';
$data = json_decode(file_get_contents('php://input'), true) ?? [];
@@ -229,230 +144,129 @@ switch ($action) {
$stmt = $pdo->query("SELECT COUNT(*) FROM users");
echo json_encode(["is_blank" => ($stmt->fetchColumn() == 0)]);
break;
case 'login':
$stmt = $pdo->query("SELECT COUNT(*) FROM users");
if ($stmt->fetchColumn() == 0) {
echo json_encode(["success" => true, "token" => md5(ENCRYPTION_KEY . 'session'), "blank" => true]);
} else {
if ($stmt->fetchColumn() == 0) { echo json_encode(["success" => true, "token" => md5(ENCRYPTION_KEY . 'session'), "blank" => true]); }
else {
$stmt = $pdo->prepare("SELECT password_hash FROM users WHERE username = 'admin'");
$stmt->execute();
$user = $stmt->fetch();
if ($user && password_verify($data['password'] ?? '', $user['password_hash'])) {
echo json_encode(["success" => true, "token" => md5(ENCRYPTION_KEY . 'session'), "blank" => false]);
} else {
http_response_code(401);
echo json_encode(["error" => "Mot de passe incorrect."]);
}
$stmt->execute(); $user = $stmt->fetch();
if ($user && password_verify($data['password'] ?? '', $user['password_hash'])) { echo json_encode(["success" => true, "token" => md5(ENCRYPTION_KEY . 'session'), "blank" => false]); }
else { http_response_code(401); echo json_encode(["error" => "Mot de passe incorrect."]); }
}
break;
case 'setup_admin':
case 'update_password':
case 'setup_admin': case 'update_password':
checkAuth($pdo);
$pwd = $data['password'] ?? $data['new_password'] ?? '';
$stmt = $pdo->prepare("REPLACE INTO users (id, username, password_hash) VALUES (1, 'admin', :pass)");
$stmt->execute([':pass' => password_hash($pwd, PASSWORD_BCRYPT)]);
echo json_encode(["success" => true]);
break;
case 'save_config':
checkAuth($pdo);
$keyName = $data['key_name'] ?? '';
$keyValue = $data['key_value'] ?? '';
$keyName = $data['key_name'] ?? ''; $keyValue = $data['key_value'] ?? '';
if ($keyName === 'tmdb_api_key' && !empty($keyValue)) {
$encryptedValue = encryptData($keyValue);
$stmt = $pdo->prepare("REPLACE INTO config (key_name, key_value) VALUES (?, ?)");
$stmt->execute([$keyName, $encryptedValue]);
$stmt->execute([$keyName, encryptData($keyValue)]);
echo json_encode(["success" => true]);
} else {
http_response_code(400);
echo json_encode(["error" => "Données invalides."]);
}
} else { http_response_code(400); echo json_encode(["error" => "Données invalides."]); }
break;
case 'get_films':
$crit = $pdo->query("SELECT *, 'critique' AS type FROM critiques ORDER BY id DESC")->fetchAll();
$video = $pdo->query("SELECT *, 'videotheque' AS type FROM videotheque ORDER BY id DESC")->fetchAll();
echo json_encode(array_merge($crit, $video));
break;
case 'save_film':
checkAuth($pdo);
$type = $data['type'] ?? 'critique';
$id = !empty($data['id']) ? $data['id'] : makeStableId($data['title'] ?? '', $data['year'] ?? '0000');
if (empty($data['director']) || empty($data['poster'])) {
$apiKey = getTmdbApiKey($pdo);
$tmdbData = fetchTmdbData($data['title'] ?? '', $data['year'] ?? '', $apiKey);
if ($tmdbData) {
if (empty($data['director'])) $data['director'] = $tmdbData['director'];
if (empty($data['poster'])) $data['poster'] = $tmdbData['poster'];
}
$tmdbData = fetchTmdbData($data['title'] ?? '', $data['year'] ?? '', getTmdbApiKey($pdo));
if ($tmdbData) { if (empty($data['director'])) $data['director'] = $tmdbData['director']; if (empty($data['poster'])) $data['poster'] = $tmdbData['poster']; }
}
if ($type === 'critique') {
$sql = "INSERT INTO critiques (id, title, year, director, poster, rating, review, streaming)
VALUES (?, ?, ?, ?, ?, ?, ?, ?)
ON DUPLICATE KEY UPDATE title=VALUES(title), year=VALUES(year), director=VALUES(director),
poster=VALUES(poster), rating=VALUES(rating), review=VALUES(review), streaming=VALUES(streaming)";
$sql = "INSERT INTO critiques (id, title, year, director, poster, rating, review, streaming) VALUES (?, ?, ?, ?, ?, ?, ?, ?) ON DUPLICATE KEY UPDATE title=VALUES(title), year=VALUES(year), director=VALUES(director), poster=VALUES(poster), rating=VALUES(rating), review=VALUES(review), streaming=VALUES(streaming)";
$stmt = $pdo->prepare($sql);
$stmt->execute([
$id, $data['title'] ?? '', $data['year'] ?? '', $data['director'] ?? '',
$data['poster'] ?? '', $data['rating'] ?? 3.0, $data['review'] ?? '', $data['streaming'] ?? ''
]);
$stmt->execute([$id, $data['title'] ?? '', $data['year'] ?? '', $data['director'] ?? '', $data['poster'] ?? '', $data['rating'] ?? 3.0, $data['review'] ?? '', $data['streaming'] ?? '']);
} else {
$sql = "INSERT INTO videotheque (id, title, year, director, poster, format, length, publisher, ean_isbn13, number_of_discs, aspect_ratio, description)
VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
ON DUPLICATE KEY UPDATE title=VALUES(title), year=VALUES(year), director=VALUES(director),
poster=VALUES(poster), format=VALUES(format), length=VALUES(length), publisher=VALUES(publisher),
ean_isbn13=VALUES(ean_isbn13), number_of_discs=VALUES(number_of_discs),
aspect_ratio=VALUES(aspect_ratio), description=VALUES(description)";
$sql = "INSERT INTO videotheque (id, title, year, director, poster, format, length, publisher, ean_isbn13, number_of_discs, aspect_ratio, description) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) ON DUPLICATE KEY UPDATE title=VALUES(title), year=VALUES(year), director=VALUES(director), poster=VALUES(poster), format=VALUES(format), length=VALUES(length), publisher=VALUES(publisher), ean_isbn13=VALUES(ean_isbn13), number_of_discs=VALUES(number_of_discs), aspect_ratio=VALUES(aspect_ratio), description=VALUES(description)";
$stmt = $pdo->prepare($sql);
$stmt->execute([
$id, $data['title'] ?? '', $data['year'] ?? '', $data['director'] ?? '',
$data['poster'] ?? '', $data['format'] ?? '', $data['length'] ?? '',
$data['publisher'] ?? '', $data['ean_isbn13'] ?? '', $data['number_of_discs'] ?? 1,
$data['aspect_ratio'] ?? '', $data['description'] ?? ''
]);
$stmt->execute([$id, $data['title'] ?? '', $data['year'] ?? '', $data['director'] ?? '', $data['poster'] ?? '', $data['format'] ?? '', $data['length'] ?? '', $data['publisher'] ?? '', $data['ean_isbn13'] ?? '', $data['number_of_discs'] ?? 1, $data['aspect_ratio'] ?? '', $data['description'] ?? '']);
}
echo json_encode(["success" => true]);
break;
case 'delete_film':
checkAuth($pdo);
$type = $_GET['type'] ?? 'critique';
$table = ($type === 'videotheque') ? 'videotheque' : 'critiques';
$type = $_GET['type'] ?? 'critique'; $table = ($type === 'videotheque') ? 'videotheque' : 'critiques';
$id = $_GET['id'] ?? null;
if (!$id) { http_response_code(400); echo json_encode(["error" => "ID manquant."]); break; }
$stmt = $pdo->prepare("DELETE FROM $table WHERE id = ?");
$stmt->execute([$id]);
$stmt = $pdo->prepare("DELETE FROM $table WHERE id = ?"); $stmt->execute([$id]);
echo json_encode(["success" => true]);
break;
case 'bulk_delete':
checkAuth($pdo);
$ids = $data['ids'] ?? [];
$type = $data['type'] ?? 'critique';
$table = ($type === 'videotheque') ? 'videotheque' : 'critiques';
if (!empty($ids)) {
$placeholders = implode(',', array_fill(0, count($ids), '?'));
$stmt = $pdo->prepare("DELETE FROM $table WHERE id IN ($placeholders)");
$stmt->execute($ids);
echo json_encode(["success" => true]);
} else {
http_response_code(400);
echo json_encode(["success" => false, "error" => "Aucun élément sélectionné."]);
}
$ids = $data['ids'] ?? []; $type = $data['type'] ?? 'critique'; $table = ($type === 'videotheque') ? 'videotheque' : 'critiques';
if (!empty($ids)) { $placeholders = implode(',', array_fill(0, count($ids), '?')); $stmt = $pdo->prepare("DELETE FROM $table WHERE id IN ($placeholders)"); $stmt->execute($ids); echo json_encode(["success" => true]); }
else { http_response_code(400); echo json_encode(["success" => false, "error" => "Aucun élément sélectionné."]); }
break;
// ── IMPORT PAR LOTS (Depuis le JS) ──
case 'import_batch':
checkAuth($pdo);
$items = $data['items'] ?? [];
$type = $data['type'] ?? 'videotheque';
$tmdbApiKey = getTmdbApiKey($pdo);
$imported = 0;
$results = [];
foreach ($items as $rowData) {
// ── MAPPING FLEXIBLE DES COLONNES (adapté à votre CSV) ──
$title = $rowData['title'] ?? $rowData['Name'] ?? $rowData['Title'] ?? 'Sans titre';
$year = extractYear($rowData['publish_date'] ?? $rowData['Year'] ?? $rowData['year'] ?? '');
$director = $rowData['director'] ?? $rowData['Director'] ?? '';
$poster = $rowData['poster'] ?? $rowData['Poster'] ?? $rowData['image'] ?? '';
$ean = $rowData['ean_isbn13'] ?? $rowData['EAN'] ?? $rowData['ean'] ?? '';
$publisher = $rowData['publisher'] ?? $rowData['Publisher'] ?? '';
$description = $rowData['description'] ?? $rowData['Description'] ?? '';
$length = $rowData['length'] ?? $rowData['Length'] ?? '';
$discs = $rowData['number_of_discs'] ?? $rowData['Number of Discs'] ?? 1;
$aspect = $rowData['aspect_ratio'] ?? $rowData['Aspect Ratio'] ?? '';
$creators = $rowData['creators'] ?? $rowData['Creators'] ?? '';
// Mapping universel pour votre CSV
$title = $rowData['title'] ?? $rowData['Name'] ?? 'Sans titre';
$firstName = $rowData['first_name'] ?? '';
$lastName = $rowData['last_name'] ?? '';
$director = (!empty($firstName) && !empty($lastName)) ? trim("$firstName $lastName") : ($rowData['creators'] ?? $rowData['Director'] ?? '');
// Si pas de réalisateur, essayer first_name + last_name
if (empty($director) && !empty($firstName) && !empty($lastName)) {
$director = trim($firstName . ' ' . $lastName);
}
$publishDate = $rowData['publish_date'] ?? $rowData['Year'] ?? '';
$year = extractYear($publishDate);
// Détection automatique du format
$format = $rowData['format'] ?? $rowData['Format'] ?? detectFormat($title, $description);
$ean = $rowData['ean_isbn13'] ?? $rowData['EAN'] ?? '';
$description = $rowData['description'] ?? $rowData['Description'] ?? $rowData['Review'] ?? '';
$publisher = $rowData['publisher'] ?? $rowData['Publisher'] ?? '';
$length = $rowData['length'] ?? $rowData['Length'] ?? '';
$discs = $rowData['number_of_discs'] ?? 1;
$aspect = $rowData['aspect_ratio'] ?? '';
$format = $rowData['format'] ?? $rowData['Format'] ?? detectFormat($title);
// ── RÉCUPÉRATION IMAGE (priorité : EAN > TMDB) ──
$imageRetrieved = false;
// 1. Essayer via EAN (jaquette DVD/Blu-ray)
// ── RÉCUPÉRATION IMAGE (Priorité EAN pour jaquette physique, sinon TMDB) ──
$poster = $rowData['poster'] ?? $rowData['Poster'] ?? '';
if (empty($poster) && !empty($ean)) {
$eanImage = fetchImageByEAN($ean);
if ($eanImage) {
$poster = $eanImage;
$imageRetrieved = true;
}
$poster = fetchImageByEAN($ean); // Récupère la jaquette DVD/Blu-ray
}
// 2. Si pas d'image EAN, essayer TMDB (affiche du film)
if (empty($poster) && $tmdbApiKey) {
if (empty($poster)) {
$tmdbData = fetchTmdbData($title, $year, $tmdbApiKey);
if ($tmdbData) {
if (empty($director)) $director = $tmdbData['director'];
if (!empty($tmdbData['poster'])) {
$poster = $tmdbData['poster'];
$imageRetrieved = true;
}
if (!empty($tmdbData['poster'])) $poster = $tmdbData['poster'];
}
}
$id = makeStableId($title, $year);
if ($type === 'critique') {
$rating = isset($rowData['Rating']) && $rowData['Rating'] !== '' ? (float)$rowData['Rating'] : 3.0;
$review = $rowData['Review'] ?? $rowData['review'] ?? $description;
$streaming = $rowData['Streaming'] ?? $rowData['streaming'] ?? 'Disponible en support physique ou Cinéma';
// ─ IMPORT CRITIQUES (Strictement conservé) ──
$rating = isset($rowData['rating']) && $rowData['rating'] !== '' ? (float)$rowData['rating'] : (isset($rowData['Rating']) ? (float)$rowData['Rating'] : 3.0);
$review = $rowData['review'] ?? $rowData['Review'] ?? $description;
$streaming = $rowData['streaming'] ?? $rowData['Streaming'] ?? (!empty($tmdbData['streaming']) ? $tmdbData['streaming'] : 'Disponible en support physique ou Cinéma');
$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)";
$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, $streaming]);
} else {
$sql = "INSERT INTO videotheque (id, title, year, director, poster, format, length, publisher, ean_isbn13, number_of_discs, aspect_ratio, description)
VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
ON DUPLICATE KEY UPDATE director=IF(VALUES(director)!='',VALUES(director),director),
poster=IF(VALUES(poster)!='',VALUES(poster),poster),
format=IF(VALUES(format)!='',VALUES(format),format),
length=IF(VALUES(length)!='',VALUES(length),length),
publisher=IF(VALUES(publisher)!='',VALUES(publisher),publisher),
ean_isbn13=IF(VALUES(ean_isbn13)!='',VALUES(ean_isbn13),ean_isbn13),
number_of_discs=IF(VALUES(number_of_discs)!=1,VALUES(number_of_discs),number_of_discs),
aspect_ratio=IF(VALUES(aspect_ratio)!='',VALUES(aspect_ratio),aspect_ratio),
description=IF(VALUES(description)!='',VALUES(description),description)";
// ── IMPORT VIDÉOTHÈQUE ──
$sql = "INSERT INTO videotheque (id, title, year, director, poster, format, length, publisher, ean_isbn13, number_of_discs, aspect_ratio, description) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) ON DUPLICATE KEY UPDATE director=IF(VALUES(director)!='',VALUES(director),director), poster=IF(VALUES(poster)!='',VALUES(poster),poster), format=IF(VALUES(format)!='',VALUES(format),format), length=IF(VALUES(length)!='',VALUES(length),length), publisher=IF(VALUES(publisher)!='',VALUES(publisher),publisher), ean_isbn13=IF(VALUES(ean_isbn13)!='',VALUES(ean_isbn13),ean_isbn13), number_of_discs=IF(VALUES(number_of_discs)!=1,VALUES(number_of_discs),number_of_discs), aspect_ratio=IF(VALUES(aspect_ratio)!='',VALUES(aspect_ratio),aspect_ratio), description=IF(VALUES(description)!='',VALUES(description),description)";
$stmt = $pdo->prepare($sql);
$stmt->execute([$id, $title, $year, $director, $poster, $format, $length, $publisher, $ean, $discs, $aspect, $description]);
}
$imported++;
$results[] = [
'title' => $title,
'poster' => !empty($poster),
'ean' => $ean,
'image_source' => $imageRetrieved ? ($ean ? 'EAN' : 'TMDB') : 'none'
];
}
echo json_encode(["success" => true, "imported" => $imported, "details" => $results]);
break;
case 'test_image_ean':
// Endpoint de test pour vérifier la récupération d'image par EAN
$ean = $_GET['ean'] ?? '';
if (empty($ean)) {
echo json_encode(["error" => "EAN requis"]);
break;
}
$image = fetchImageByEAN($ean);
echo json_encode(["ean" => $ean, "image" => $image]);
echo json_encode(["success" => true, "imported" => $imported]);
break;
}