src/Controller/Api/CsvDownload/CsvDownloadController.php line 10

Open in your IDE?
  1. <?php
  3. namespace App\Controller\Api\CsvDownload;
  5. use Symfony\Component\HttpFoundation\BinaryFileResponse;
  6. use Symfony\Component\HttpFoundation\ResponseHeaderBag;
  7. use Symfony\Component\HttpKernel\Exception\NotFoundHttpException;
  8. use Symfony\Component\HttpFoundation\Request;
  10. class CsvDownloadController
  11. {
  12.     private string $baseDir;
  14.     public function __construct(string $dataOperatorDirectory)
  15.     {
  16.         $this->baseDir = realpath($dataOperatorDirectory);
  17.     }
  19.     public function __invoke(Request $request, string $entity, int $cpv): BinaryFileResponse
  20.     {
  21.         $codeCluster = $request->query->get('codeCluster', null);
  22.         $codeInsee = $request->query->get('codeInsee', null);
  23.         $codeIris = $request->query->get('codeIris', null);
  24.         $subDir = '';
  26.         if (strtoupper($entity) === 'PRODUCTION' || strtoupper($entity) === 'PRISES_PARC' || strtoupper($entity) === 'MOBILE') {
  27.             $subDir = "dataSFR/processed/" . strtoupper($entity) . "/csv_by_cpv";
  28.             if ($codeIris) {
  29.                 $subDir = "dataSFR/processed/" . strtoupper($entity) . "/csv_by_cod_iris";
  30.             }
  31.         } else {
  32.             throw new NotFoundHttpException('Type d\'entité non reconnu.');
  33.         }
  35.         $fullBasePath = $this->baseDir . DIRECTORY_SEPARATOR . $subDir;
  36.         $fullBasePath = realpath($fullBasePath);
  38.         if (!$fullBasePath || !str_starts_with($fullBasePath, $this->baseDir)) {
  39.             throw new NotFoundHttpException('Répertoire inaccessible ou invalide.');
  40.         }
  42.         // Lister les sous-dossiers
  43.         $folders = array_filter(glob($fullBasePath . '/*'), 'is_dir');
  45.         // Trier par date décroissante
  46.         usort($folders, fn($a, $b) => filemtime($b) <=> filemtime($a));
  48.         foreach ($folders as $folder) {
  49.             $files = glob("$folder/{$cpv}_*.csv");
  50.             if (strtoupper($entity) === 'PRISES_PARC') {
  51.                 $files = glob("$folder/{$cpv}/{$cpv}_*.csv");
  52.             }
  53.             if ($codeCluster) {
  54.                 $files = glob("$folder/{$cpv}/{$codeCluster}/{$codeCluster}*.csv");
  55.                 if ($codeInsee) {
  56.                     $files = glob("$folder/{$cpv}/{$codeCluster}/{$codeInsee}*.csv");
  57.                 }
  58.             }
  59.             if ($codeIris) {
  60.                 $files = glob("$folder/{$codeIris}/{$codeIris}*.csv");
  61.             }
  62.             if (!empty($files)) {
  63.                 $filePath = realpath($files[0]);
  65.                 // Vérification finale
  66.                 if ($filePath && str_starts_with($filePath, $this->baseDir) && is_file($filePath)) {
  67.                     $response = new BinaryFileResponse($filePath);
  68.                     $response->setContentDisposition(
  69.                         ResponseHeaderBag::DISPOSITION_ATTACHMENT,
  70.                         basename($filePath)
  71.                     );
  72.                     return $response;
  73.                 }
  74.             }
  75.         }
  77.         // Aucun fichier trouvé
  78.         throw new NotFoundHttpException('Fichier correspondant non trouvé.');
  79.     }
  80. }