gwadaking/radarsargasses
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: ForecastController avec filtres bbox+horizon — polygones par horizon sur la carte

Browse Source
This commit is contained in:
Gwadaking
2026-04-03 19:38:22 -04:00
parent 878174404e
commit 492ed02b6f
2 changed files with 96 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

95
backend/src/Controller/ForecastController.php Normal file
View File

@@ -0,0 +1,95 @@
<?php
namespace App\Controller;
use Doctrine\DBAL\Connection;
use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
use Symfony\Component\HttpFoundation\JsonResponse;
use Symfony\Component\HttpFoundation\Request;
use Symfony\Component\Routing\Attribute\Route;
#[Route('/api/forecasts', name: 'api_forecasts_')]
class ForecastController extends AbstractController
{
public function __construct(private Connection $connection) {}
/**
* GET /api/forecasts
*
* Paramètres optionnels :
* ?bbox=minLon,minLat,maxLon,maxLat filtre spatial PostGIS
* ?horizon=6 filtre sur time_horizon (6, 12, 24, 48)
*/
#[Route('', name: 'collection', methods: ['GET'])]
public function collection(Request $request): JsonResponse
{
$sql = <<<SQL
SELECT
f.id,
f.time_horizon AS "timeHorizon",
f.valid_at AS "validAt",
f.computed_at AS "computedAt",
f.model_version AS "modelVersion",
f.confidence,
f.source_observation_id AS "sourceObservationId",
ST_AsGeoJSON(f.geometry)::json AS geometry
FROM sargassum_forecast f
WHERE 1=1
SQL;
$params = [];
$bboxParam = $request->query->get('bbox');
if ($bboxParam !== null) {
$parts = array_map('floatval', explode(',', $bboxParam));
if (count($parts) === 4) {
[$minLon, $minLat, $maxLon, $maxLat] = $parts;
$sql .= ' AND ST_Intersects(f.geometry, ST_MakeEnvelope(:minLon, :minLat, :maxLon, :maxLat, 4326))';
$params['minLon'] = $minLon;
$params['minLat'] = $minLat;
$params['maxLon'] = $maxLon;
$params['maxLat'] = $maxLat;
}
}
$horizonParam = $request->query->get('horizon');
if ($horizonParam !== null && in_array((int) $horizonParam, [6, 12, 24, 48], true)) {
$sql .= ' AND f.time_horizon = :horizon';
$params['horizon'] = (int) $horizonParam;
}
$sql .= ' ORDER BY f.valid_at DESC LIMIT 50';
$rows = $this->connection->fetchAllAssociative($sql, $params);
foreach ($rows as &$row) {
$row['geometry'] = $row['geometry'] ? json_decode($row['geometry'], true) : null;
}
return $this->json(['items' => $rows, 'total' => count($rows)]);
}
/**
* GET /api/forecasts/{id}
*/
#[Route('/{id}', name: 'item', methods: ['GET'])]
public function item(string $id): JsonResponse
{
$row = $this->connection->fetchAssociative(
'SELECT f.id, f.time_horizon AS "timeHorizon", f.valid_at AS "validAt",
f.computed_at AS "computedAt", f.model_version AS "modelVersion",
f.confidence, f.source_observation_id AS "sourceObservationId",
ST_AsGeoJSON(f.geometry)::json AS geometry
FROM sargassum_forecast f WHERE f.id = :id',
['id' => $id]
);
if ($row === false) {
return $this->json(['error' => 'Forecast not found'], 404);
}
$row['geometry'] = $row['geometry'] ? json_decode($row['geometry'], true) : null;
return $this->json($row);
}
}

11
backend/src/Entity/SargassumForecast.php
View File

@@ -2,9 +2,6 @@
namespace App\Entity;
use ApiPlatform\Metadata\ApiResource;
use ApiPlatform\Metadata\Get;
use ApiPlatform\Metadata\GetCollection;
use App\Repository\SargassumForecastRepository;
use Doctrine\ORM\Mapping as ORM;
use Symfony\Bridge\Doctrine\Types\UuidType;
@@ -13,13 +10,7 @@ use Symfony\Component\Uid\Uuid;
#[ORM\Entity(repositoryClass: SargassumForecastRepository::class)]
#[ORM\Index(columns: ['valid_at'], name: 'idx_forecast_valid_at')]
#[ORM\Index(columns: ['time_horizon'], name: 'idx_forecast_horizon')]
#[ApiResource(
shortName: 'Forecast',
operations: [
new GetCollection(),
new Get(),
]
)]
// Routes gérées par ForecastController (filtres bbox + horizon)
class SargassumForecast
{
#[ORM\Id]