<?php
require_once __DIR__ . '/Database.php';
class ProjetDocumentLink {
private $db;
public function __construct() {
$this->db = Database::getInstance()->getConnection();
$this->ensureSchema();
}
private function ensureSchema(): void {
$this->db->exec("CREATE TABLE IF NOT EXISTS projet_document_links (
id INT AUTO_INCREMENT PRIMARY KEY,
projet_id INT NOT NULL,
entity_type VARCHAR(32) NOT NULL,
entity_id INT NOT NULL,
created_at DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
updated_at DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
UNIQUE KEY uq_entity (entity_type, entity_id),
KEY idx_project (projet_id),
KEY idx_project_entity (projet_id, entity_type)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4");
}
public function getForEntity(string $entityType, int $entityId): ?array {
$stmt = $this->db->prepare('SELECT l.*, p.titre AS projet_titre FROM projet_document_links l LEFT JOIN projets p ON p.id = l.projet_id WHERE l.entity_type = ? AND l.entity_id = ? LIMIT 1');
$stmt->execute([$entityType, $entityId]);
$row = $stmt->fetch(PDO::FETCH_ASSOC);
return $row !== false ? $row : null;
}
public function getByProjectId(int $projectId): array {
$stmt = $this->db->prepare('SELECT * FROM projet_document_links WHERE projet_id = ? ORDER BY created_at DESC, id DESC');
$stmt->execute([$projectId]);
return $stmt->fetchAll(PDO::FETCH_ASSOC) ?: [];
}
public function assign(?int $projectId, string $entityType, int $entityId): bool {
if ($entityId <= 0 || trim($entityType) === '') {
return false;
}
if (!$projectId || $projectId <= 0) {
return $this->deleteByEntity($entityType, $entityId);
}
$sql = 'INSERT INTO projet_document_links (projet_id, entity_type, entity_id) VALUES (?, ?, ?) ON DUPLICATE KEY UPDATE projet_id = VALUES(projet_id), updated_at = CURRENT_TIMESTAMP';
$stmt = $this->db->prepare($sql);
return $stmt->execute([$projectId, $entityType, $entityId]);
}
public function deleteByEntity(string $entityType, int $entityId): bool {
$stmt = $this->db->prepare('DELETE FROM projet_document_links WHERE entity_type = ? AND entity_id = ?');
return $stmt->execute([$entityType, $entityId]);
}
public function deleteByProjectId(int $projectId): bool {
$stmt = $this->db->prepare('DELETE FROM projet_document_links WHERE projet_id = ?');
return $stmt->execute([$projectId]);
}
}