fix(etl): traite les retours de revue du DAG historique

.github/workflows/airflow.yml

@@ -91,11 +91,12 @@ jobs:
           bash -c "cd /opt/ml && env -u VIRTUAL_ENV uv run --no-sync python -m enervision_ml.train --help"
 
       # `--help` sort par argparse avant `get_settings()` : ni base ni secret requis, et
-      # l'import du module prouve que l'environnement /opt/backend est complet. Les deux
+      # l'import des modules prouve que l'environnement /opt/backend est complet.
-      # commandes du DAG `alertes` sont couvertes, `app.cli` tirant tout FastAPI derrière lui.
+      # Les deux commandes du DAG `alertes` et la commande du DAG historique sont couvertes.
-      - name: Vérifie que les deux commandes du DAG alertes s'importent sans réseau
+      - name: Vérifie que les trois commandes backend s'importent sans réseau
         run: >
           docker run --rm --network none enervision-airflow:ci
           bash -c "cd /opt/backend
           && env -u VIRTUAL_ENV uv run --no-sync python -m app.detection.internal_alerts --help
-          && env -u VIRTUAL_ENV uv run --no-sync python -m app.cli generate-recommendations --help"
+          && env -u VIRTUAL_ENV uv run --no-sync python -m app.cli generate-recommendations --help
+          && env -u VIRTUAL_ENV uv run --no-sync python -m app.etl.historical_import --help"

README.md

@@ -21,7 +21,7 @@ Ce que la documentation apporte à chacun : [docs/architecture/00-vue-ensemble.m
 | Backend    | FastAPI, Python 3.14                | `apps/backend`      | Initialise    |
 | Frontend   | Angular 22, Node 24 LTS             | `apps/frontend`     | Tableau de bord |
 | Base       | PostgreSQL 17 + TimescaleDB         | `db`                | Initialise    |
-| ETL        | Apache Airflow                      | `etl/airflow`       | Trois DAGs    |
+| ETL        | Apache Airflow                      | `etl/airflow`       | Quatre DAGs   |
 | Infra      | Terraform (k3s single-node)         | `infra/terraform`   | Initialise    |
 | Reverse proxy | Nginx, TLS                       | `infra/proxy`       | En place      |
 | CI/CD      | GitHub Actions                      | `.github/workflows` | Backend en place |
@@ -48,7 +48,7 @@ L'etat detaille de chaque brique et les vues d'architecture sont dans
 │   ├── migrations/     Migrations SQL versionnees
 │   └── seeds/          Jeux de donnees de reference
 ├── etl/airflow/
-│   ├── dags/           DAGs d'orchestration (pipeline ML, alertes)
+│   ├── dags/           DAGs d'orchestration (pipeline ML, alertes, import historique)
 │   ├── plugins/        Operateurs et hooks maison
 │   ├── include/        Requetes SQL et ressources des DAGs
 │   └── tests/          Tests d'integrite des DAGs

apps/frontend/TESTING.md

@@ -1,4 +1,4 @@
-# Conventions de tests unitaires : Frontend
+# Conventions de tests unitaires — Frontend
 
 ## Outil
 Vitest (intégré nativement à Angular CLI, pas d'installation à faire).
@@ -83,6 +83,3 @@ describe('MonComposant', () => {
 ## Lancer les tests
 - Développement (mode watch) : `npm test`
 - Rapport de couverture (CI) : `npm run test:ci -- --coverage`, puis ouvrir `coverage/index.html`
-- Un fichier ou un dossier seulement :
-  `npx ng test --watch=false --coverage=false --include=src/app/core/services/alerts.service.spec.ts`
-  (répéter `--include` pour plusieurs cibles ; un dossier joue tous ses specs)

apps/frontend/src/app/app.routes.ts

@@ -1,36 +1,21 @@
 import { Routes } from '@angular/router';
-import { authGuard } from './core/guards/auth-guard';
+import {authGuard} from './core/guards/auth-guard';
 
 export const routes: Routes = [
   { path: '', redirectTo: 'dashboard', pathMatch: 'full' },
-  {
+  { path: 'login', loadComponent: () => import('./features/auth/login/login').then(m => m.Login) },
-    path: 'login',
+  { path: 'change-password', loadComponent: () => import('./features/auth/change-password/change-password').then(m => m.ChangePassword) },
-    loadComponent: () => import('./features/auth/login/login').then((m) => m.Login),
+  { path: 'forgot-password', loadComponent: () => import('./features/auth/forgot-password/forgot-password').then(m => m.ForgotPassword) },
-  },
+  { path: 'reset-password', loadComponent: () => import('./features/auth/reset-password/reset-password').then(m => m.ResetPassword) },
-  {
-    path: 'change-password',
-    loadComponent: () =>
-      import('./features/auth/change-password/change-password').then((m) => m.ChangePassword),
-  },
-  {
-    path: 'forgot-password',
-    loadComponent: () =>
-      import('./features/auth/forgot-password/forgot-password').then((m) => m.ForgotPassword),
-  },
-  {
-    path: 'reset-password',
-    loadComponent: () =>
-      import('./features/auth/reset-password/reset-password').then((m) => m.ResetPassword),
-  },
   {
     path: 'dashboard',
     canActivate: [authGuard],
-    loadComponent: () => import('./features/dashboard/dashboard').then((m) => m.Dashboard),
+    loadComponent: () => import('./features/dashboard/dashboard').then(m => m.Dashboard),
   },
   {
     path: 'sites',
     canActivate: [authGuard],
-    loadComponent: () => import('./features/sites/site-list/site-list').then((m) => m.SiteList),
+    loadComponent: () => import('./features/sites/site-list/site-list').then(m => m.SiteList),
   },
   {
     path: 'sites/:siteId',
@@ -38,12 +23,6 @@ export const routes: Routes = [
     loadComponent: () =>
       import('./features/sites/site-detail/site-detail').then((m) => m.SiteDetail),
   },
-  {
-    path: 'recommendations',
-    canActivate: [authGuard],
-    loadComponent: () =>
-      import('./features/recommendations/recommendations').then((m) => m.RecommendationsView),
-  },
   {
     path: 'monitoring/sensors',
     canActivate: [authGuard],

apps/frontend/src/app/core/mocks/alerts.fixture.ts

@@ -2,63 +2,53 @@ import { Alert } from '../../shared/models/alert.model';
 
 export const ALERTS_FIXTURE: Alert[] = [
   {
-    alert_id: 5,
+    alert_id: 'ALR-SITE002-1718458320',
+    timestamp: '2026-09-15T11:12:00',
     site_id: 'SITE002',
-    timestamp: '2026-09-15T11:12:00Z',
-    type: 'threshold',
     severity: 'critical',
-    message: 'Puissance appelée 812.5 kW au-dessus de la capacité du site (720.0 kW)',
+    type: 'outage',
+    message: 'Risque de surcharge sur Usine Lyon Vénissieux',
     value: 812.5,
     threshold: 720.0,
-    metric: 'consumption_kw',
-    prediction_id: null,
   },
   {
-    alert_id: 4,
+    alert_id: 'ALR-SITE003-1718458321',
+    timestamp: '2026-09-15T11:05:00',
     site_id: 'SITE003',
-    timestamp: '2026-09-15T11:05:00Z',
-    type: 'outage',
     severity: 'critical',
-    message: 'Aucune lecture depuis 5:00:00 (dernière lecture : 2026-09-15T06:05:00+00:00)',
-    value: null,
-    threshold: null,
-    metric: null,
-    prediction_id: null,
-  },
-  {
-    alert_id: 3,
-    site_id: 'SITE005',
-    timestamp: '2026-09-15T10:47:00Z',
-    type: 'spike',
-    severity: 'high',
-    message: 'Variation brutale entre deux lectures consécutives (260.0 kW -> 410.0 kW)',
-    value: 410.0,
-    threshold: 260.0,
-    metric: 'consumption_kw',
-    prediction_id: null,
-  },
-  {
-    alert_id: 2,
-    site_id: 'SITE006',
-    timestamp: '2026-09-15T10:30:00Z',
     type: 'sensor',
-    severity: 'medium',
+    message: 'Perte réseau totale sur Data Center Marseille',
-    message: 'Qualité de mesure degraded (capteur hors ligne, valeur nulle)',
+    value: 0,
-    value: null,
+    threshold: 0,
-    threshold: null,
-    metric: null,
-    prediction_id: null,
   },
   {
-    alert_id: 1,
+    alert_id: 'ALR-SITE005-1718458322',
+    timestamp: '2026-09-15T10:47:00',
+    site_id: 'SITE005',
+    severity: 'high',
+    type: 'threshold',
+    message: 'Usine Toulouse approche de son seuil de capacité',
+    value: 410.0,
+    threshold: 480.0,
+  },
+  {
+    alert_id: 'ALR-SITE006-1718458323',
+    timestamp: '2026-09-15T10:30:00',
+    site_id: 'SITE006',
+    severity: 'medium',
+    type: 'sensor',
+    message: 'Capteur de température défaillant sur Bureau Lille',
+    value: 0,
+    threshold: 0,
+  },
+  {
+    alert_id: 'ALR-SITE004-1718458324',
+    timestamp: '2026-09-15T09:58:00',
     site_id: 'SITE004',
-    timestamp: '2026-09-15T09:58:00Z',
-    type: 'anomaly',
     severity: 'low',
-    message: 'Écart de 13% entre la consommation mesurée (62.0 kWh) et la prévision (55.0 kWh)',
+    type: 'anomaly',
+    message: 'Comportement de consommation inhabituel sur Bureau Bordeaux',
     value: 62.0,
     threshold: 55.0,
-    metric: 'consumption_kwh',
-    prediction_id: 42,
   },
 ];

apps/frontend/src/app/core/services/alerts.service.spec.ts

@@ -3,20 +3,6 @@ import { provideHttpClient } from '@angular/common/http';
 import { provideHttpClientTesting, HttpTestingController } from '@angular/common/http/testing';
 import { AlertsService } from './alerts.service';
 import { environment } from '../../../environments/environment';
-import { Alert } from '../../shared/models/alert.model';
-
-const ALERT_API: Alert = {
-  alert_id: 1,
-  site_id: 'site-1',
-  timestamp: '2026-09-16T00:00:00Z',
-  type: 'threshold',
-  severity: 'high',
-  message: 'Dépassement du seuil configuré',
-  value: 812.5,
-  threshold: 720.0,
-  metric: 'consumption_kw',
-  prediction_id: null,
-};
 
 describe('AlertsService', () => {
   let service: AlertsService;
@@ -32,35 +18,26 @@ describe('AlertsService', () => {
 
   afterEach(() => httpMock.verify());
 
-  it("appelle le bon endpoint sans paramètre et retourne un tableau d'alertes", () => {
+  it("appelle le bon endpoint et retourne un tableau d'alertes", () => {
-    let result: Alert[] = [];
+    let result: unknown;
     service.getAlerts().subscribe((r) => (result = r));
 
-    const req = httpMock.expectOne(
+    const req = httpMock.expectOne(`${environment.apiUrl}/alerts`);
-      (r) => r.url === `${environment.apiUrl}/alerts` && r.method === 'GET',
+    expect(req.request.method).toBe('GET');
-    );
-    expect(req.request.params.keys()).toEqual([]);
-    req.flush([ALERT_API]);
 
-    expect(result.length).toBe(1);
+    req.flush([
-    expect(result[0].alert_id).toBe(1);
+      {
-    expect(result[0].prediction_id).toBeNull();
+        alert_id: 'ALR-TEST-1',
-  });
+        timestamp: '2026-09-15T12:00:00',
+        site_id: 'SITE001',
+        severity: 'high',
+        type: 'threshold',
+        message: 'Test',
+        value: 100,
+        threshold: 90,
+      },
+    ]);
 
-  it('transmet les filtres site_id et severity en paramètres de requête', () => {
+    expect((result as unknown[]).length).toBe(1);
-    service.getAlerts({ site_id: 'SITE001', severity: 'high' }).subscribe();
-
-    const req = httpMock.expectOne((r) => r.url === `${environment.apiUrl}/alerts`);
-    expect(req.request.params.get('site_id')).toBe('SITE001');
-    expect(req.request.params.get('severity')).toBe('high');
-    req.flush([]);
-  });
-
-  it('ne pose pas de paramètre pour un filtre omis', () => {
-    service.getAlerts({ site_id: 'SITE001' }).subscribe();
-
-    const req = httpMock.expectOne((r) => r.url === `${environment.apiUrl}/alerts`);
-    expect(req.request.params.has('severity')).toBe(false);
-    req.flush([]);
   });
 });

apps/frontend/src/app/core/services/alerts.service.ts

@@ -1,25 +1,13 @@
 import { Service, inject } from '@angular/core';
-import { HttpClient, HttpParams } from '@angular/common/http';
+import { HttpClient } from '@angular/common/http';
 import { environment } from '../../../environments/environment';
-import { Alert, AlertSeverity } from '../../shared/models/alert.model';
+import { Alert } from '../../shared/models/alert.model';
-
-export interface AlertFilters {
-  site_id?: string;
-  severity?: AlertSeverity;
-}
 
 @Service()
 export class AlertsService {
   private http = inject(HttpClient);
 
-  getAlerts(filters: AlertFilters = {}) {
+  getAlerts() {
-    let params = new HttpParams();
+    return this.http.get<Alert[]>(`${environment.apiUrl}/alerts`);
-    if (filters.site_id) {
-      params = params.set('site_id', filters.site_id);
-    }
-    if (filters.severity) {
-      params = params.set('severity', filters.severity);
-    }
-    return this.http.get<Alert[]>(`${environment.apiUrl}/alerts`, { params });
   }
 }

apps/frontend/src/app/core/services/recommendations.service.spec.ts

@@ -1,74 +0,0 @@
-import { TestBed } from '@angular/core/testing';
-import { provideHttpClient } from '@angular/common/http';
-import { provideHttpClientTesting, HttpTestingController } from '@angular/common/http/testing';
-import { RecommendationsService } from './recommendations.service';
-import { environment } from '../../../environments/environment';
-import { Recommendation } from '../../shared/models/recommendation.model';
-
-const RECOMMANDATION_API: Recommendation = {
-  recommendation_id: 1,
-  alert_id: 1,
-  action: 'Vérifier la consommation',
-  explanation: 'Pic détecté',
-  rule_reference: 'spike-v1',
-  created_at: '2024-01-01T00:00:00Z',
-};
-
-describe('RecommendationsService', () => {
-  let service: RecommendationsService;
-  let httpMock: HttpTestingController;
-
-  beforeEach(() => {
-    TestBed.configureTestingModule({
-      providers: [provideHttpClient(), provideHttpClientTesting()],
-    });
-    service = TestBed.inject(RecommendationsService);
-    httpMock = TestBed.inject(HttpTestingController);
-  });
-
-  afterEach(() => httpMock.verify());
-
-  it('liste les recommandations depuis le bon endpoint', () => {
-    let result: Recommendation[] = [];
-    service.getRecommendations().subscribe((r) => (result = r));
-
-    const req = httpMock.expectOne(`${environment.apiUrl}/recommendations`);
-    expect(req.request.method).toBe('GET');
-    req.flush([RECOMMANDATION_API]);
-
-    expect(result.length).toBe(1);
-    expect(result[0].alert_id).toBe(1);
-  });
-
-  it('décrit une recommandation par son identifiant', () => {
-    service.getRecommendation(42).subscribe();
-
-    const req = httpMock.expectOne(`${environment.apiUrl}/recommendations/42`);
-    expect(req.request.method).toBe('GET');
-    req.flush({ ...RECOMMANDATION_API, recommendation_id: 42 });
-  });
-
-  it('déclenche la génération en POST avec le site en paramètre de requête', () => {
-    let result: unknown;
-    service.generate('SITE001').subscribe((r) => (result = r));
-
-    const req = httpMock.expectOne(
-      (r) => r.url === `${environment.apiUrl}/recommendations/generate` && r.method === 'POST',
-    );
-    expect(req.request.params.get('site_id')).toBe('SITE001');
-    expect(req.request.body).toBeNull();
-    req.flush({ alerts_examined: 2, recommendations_created: 3, already_present: 1 });
-
-    expect(result).toEqual({ alerts_examined: 2, recommendations_created: 3, already_present: 1 });
-  });
-
-  it('génère pour tout le parc quand aucun site n’est donné', () => {
-    service.generate().subscribe();
-
-    const req = httpMock.expectOne(
-      (r) => r.url === `${environment.apiUrl}/recommendations/generate` && r.method === 'POST',
-    );
-    expect(req.request.params.has('site_id')).toBe(false);
-    req.flush({ alerts_examined: 0, recommendations_created: 0, already_present: 0 });
-  });
-});

apps/frontend/src/app/core/services/recommendations.service.ts

@@ -1,34 +0,0 @@
-import { Service, inject } from '@angular/core';
-import { HttpClient, HttpParams } from '@angular/common/http';
-import { environment } from '../../../environments/environment';
-import {
-  Recommendation,
-  RecommendationGenerationReport,
-} from '../../shared/models/recommendation.model';
-
-@Service()
-export class RecommendationsService {
-  private http = inject(HttpClient);
-
-  getRecommendations() {
-    return this.http.get<Recommendation[]>(`${environment.apiUrl}/recommendations`);
-  }
-
-  getRecommendation(recommendationId: number) {
-    return this.http.get<Recommendation>(
-      `${environment.apiUrl}/recommendations/${recommendationId}`,
-    );
-  }
-
-  generate(siteId?: string) {
-    let params = new HttpParams();
-    if (siteId) {
-      params = params.set('site_id', siteId);
-    }
-    return this.http.post<RecommendationGenerationReport>(
-      `${environment.apiUrl}/recommendations/generate`,
-      null,
-      { params },
-    );
-  }
-}

apps/frontend/src/app/features/dashboard/dashboard.html

@@ -14,7 +14,6 @@
         <a routerLink="/monitoring/sensors" class="ev-link">Supervision des capteurs</a>
       }
       <a routerLink="/sites" class="ev-link">Voir les sites</a>
-      <a routerLink="/recommendations" class="ev-link">Recommandations</a>
       <ev-button
         class="logout-button"
         variant="secondary"

apps/frontend/src/app/features/recommendations/recommendations.html

@@ -1,58 +0,0 @@
-<div class="recommendations">
-  <nav class="ev-breadcrumb">
-    <a routerLink="/dashboard">Tableau de bord</a>
-  </nav>
-
-  <header class="recommendations__header">
-    <a routerLink="/dashboard" class="ev-brand-link">
-      <ev-brand class="recommendations__logo" />
-    </a>
-    <div>
-      <h1>Recommandations</h1>
-      <p class="recommendations__subtitle">
-        Actions proposées par le moteur de règles à partir des alertes
-      </p>
-    </div>
-  </header>
-
-  <div class="recommendations__toolbar">
-    <label class="recommendations__filter">
-      <span class="form-label">Site</span>
-      <select class="form-select" data-testid="site-filter" (change)="onSiteChange($event)">
-        <option value="" [selected]="!siteFilter()">Tous les sites</option>
-        @for (site of sites(); track site.site_id) {
-          <option [value]="site.site_id" [selected]="site.site_id === siteFilter()">
-            {{ site.site_name }}
-          </option>
-        }
-      </select>
-    </label>
-    @if (isAdmin()) {
-      <ev-button
-        variant="secondary"
-        [fullWidth]="false"
-        [disabled]="generating()"
-        data-testid="generate"
-        (click)="onGenerate()"
-      >
-        {{ generating() ? 'Génération en cours…' : 'Générer les recommandations' }}
-      </ev-button>
-    }
-  </div>
-
-  @if (generationReport(); as report) {
-    <ev-alert severity="success" class="recommendations__banner">{{ bilan(report) }}.</ev-alert>
-  }
-  @if (generationError(); as message) {
-    <ev-alert severity="danger" class="recommendations__banner">{{ message }}</ev-alert>
-  }
-
-  @if (alertId(); as id) {
-    <p class="recommendations__focus">
-      Alerte n° {{ id }} ·
-      <a routerLink="/recommendations" class="ev-link">Toutes les recommandations</a>
-    </p>
-  }
-
-  <app-recommendation-list [siteId]="siteFilter()" [alertId]="alertId()" [sites]="sites()" />
-</div>

apps/frontend/src/app/features/recommendations/recommendations.scss

@@ -1,59 +0,0 @@
-:host {
-  display: block;
-  color: var(--color-text);
-  padding: 2.5rem 2rem;
-  max-width: 1100px;
-  margin: 0 auto;
-}
-
-.recommendations__header {
-  display: flex;
-  align-items: center;
-  gap: 0.85rem;
-  margin-bottom: 2rem;
-
-  h1 {
-    margin: 0;
-    font-size: 1.75rem;
-    font-weight: 700;
-  }
-}
-
-.recommendations__logo {
-  font-size: 1.3rem;
-}
-
-.recommendations__subtitle {
-  margin: 0.25rem 0 0;
-  color: var(--color-text-muted);
-}
-
-.recommendations__toolbar {
-  display: flex;
-  flex-wrap: wrap;
-  align-items: flex-end;
-  justify-content: space-between;
-  gap: var(--space-3);
-  margin-bottom: var(--space-4);
-}
-
-.recommendations__filter {
-  display: flex;
-  flex-direction: column;
-  min-width: 14rem;
-
-  .form-label {
-    margin-top: 0;
-  }
-}
-
-.recommendations__banner {
-  display: block;
-  margin-bottom: var(--space-3);
-}
-
-.recommendations__focus {
-  margin: 0 0 var(--space-3);
-  font-size: 0.9rem;
-  color: var(--color-text-muted);
-}

apps/frontend/src/app/features/recommendations/recommendations.spec.ts

@@ -1,169 +0,0 @@
-import { TestBed } from '@angular/core/testing';
-import { By } from '@angular/platform-browser';
-import { ActivatedRoute, convertToParamMap, provideRouter } from '@angular/router';
-import { vi } from 'vitest';
-import { BehaviorSubject, of, throwError } from 'rxjs';
-import { RecommendationsView, parseAlertId } from './recommendations';
-import { RecommendationList } from '../../shared/components/recommendation-list/recommendation-list';
-import { SitesService } from '../../core/services/sites.service';
-import { AlertsService } from '../../core/services/alerts.service';
-import { RecommendationsService } from '../../core/services/recommendations.service';
-import { AuthService } from '../../core/services/auth.service';
-
-const SITES = [
-  {
-    site_id: 'SITE001',
-    site_name: 'Usine Nantes',
-    site_type: 'industriel',
-    location: 'Nantes',
-    capacity_kw: 500,
-    status: 'actif',
-  },
-];
-
-const BILAN = { alerts_examined: 2, recommendations_created: 3, already_present: 1 };
-
-function setup(options: { query?: Record<string, string>; role?: string } = {}) {
-  const query = options.query ?? {};
-  const queryParamMap = new BehaviorSubject(convertToParamMap(query));
-  const generate = vi.fn().mockReturnValue(of(BILAN));
-  const getRecommendations = vi.fn().mockReturnValue(of([]));
-  const getAlerts = vi.fn().mockReturnValue(of([]));
-  TestBed.configureTestingModule({
-    imports: [RecommendationsView],
-    providers: [
-      provideRouter([]),
-      {
-        provide: ActivatedRoute,
-        useValue: { queryParamMap, snapshot: { queryParamMap: convertToParamMap(query) } },
-      },
-      { provide: SitesService, useValue: { getSites: vi.fn().mockReturnValue(of(SITES)) } },
-      { provide: AlertsService, useValue: { getAlerts } },
-      { provide: RecommendationsService, useValue: { getRecommendations, generate } },
-      {
-        provide: AuthService,
-        useValue: { principal: vi.fn().mockReturnValue({ role: options.role ?? 'lecteur' }) },
-      },
-    ],
-  });
-  const fixture = TestBed.createComponent(RecommendationsView);
-  fixture.detectChanges();
-  fixture.detectChanges();
-  return { fixture, queryParamMap, generate, getRecommendations, getAlerts };
-}
-
-function listeEnfant(fixture: ReturnType<typeof setup>['fixture']): RecommendationList {
-  return fixture.debugElement.query(By.directive(RecommendationList)).componentInstance;
-}
-
-describe('parseAlertId', () => {
-  it("n'accepte qu'un entier strictement positif", () => {
-    expect(parseAlertId('12')).toBe(12);
-    expect(parseAlertId('0')).toBeNull();
-    expect(parseAlertId('-3')).toBeNull();
-    expect(parseAlertId('abc')).toBeNull();
-    expect(parseAlertId('12abc')).toBeNull();
-    expect(parseAlertId(null)).toBeNull();
-  });
-});
-
-describe('RecommendationsView', () => {
-  it("cible l'alerte donnée par ?alert= et la transmet à la liste", () => {
-    const { fixture } = setup({ query: { alert: '12' } });
-
-    expect(fixture.componentInstance.alertId()).toBe(12);
-    expect(listeEnfant(fixture).alertId()).toBe(12);
-    expect(fixture.nativeElement.textContent).toContain('Alerte n° 12');
-    expect(fixture.nativeElement.querySelector('a[href="/recommendations"]')).not.toBeNull();
-  });
-
-  it('ignore un paramètre alert invalide', () => {
-    const { fixture } = setup({ query: { alert: 'abc' } });
-
-    expect(fixture.componentInstance.alertId()).toBeNull();
-    expect(fixture.nativeElement.textContent).not.toContain('Alerte n°');
-  });
-
-  it('applique le site donné par ?site= au filtre et à la liste', () => {
-    const { fixture, getAlerts } = setup({ query: { site: 'SITE001' } });
-
-    expect(getAlerts).toHaveBeenCalledWith({ site_id: 'SITE001' });
-    const option = fixture.nativeElement.querySelector(
-      'option[value="SITE001"]',
-    ) as HTMLOptionElement;
-    expect(option.selected).toBe(true);
-  });
-
-  it('relance la liste sur le site choisi dans le filtre', () => {
-    const { fixture, getAlerts } = setup();
-    const select = fixture.nativeElement.querySelector(
-      '[data-testid="site-filter"]',
-    ) as HTMLSelectElement;
-
-    select.value = 'SITE001';
-    select.dispatchEvent(new Event('change'));
-    fixture.detectChanges();
-    fixture.detectChanges();
-
-    expect(getAlerts).toHaveBeenLastCalledWith({ site_id: 'SITE001' });
-    expect(listeEnfant(fixture).siteId()).toBe('SITE001');
-  });
-
-  it('cache le bouton de génération aux lecteurs', () => {
-    const { fixture } = setup({ role: 'lecteur' });
-
-    expect(fixture.nativeElement.querySelector('[data-testid="generate"]')).toBeNull();
-  });
-
-  it('permet à un admin de générer pour le site filtré, affiche le bilan et recharge la liste', () => {
-    const { fixture, generate, getRecommendations } = setup({
-      role: 'admin',
-      query: { site: 'SITE001' },
-    });
-
-    fixture.nativeElement.querySelector('[data-testid="generate"]').click();
-    fixture.detectChanges();
-    fixture.detectChanges();
-
-    expect(generate).toHaveBeenCalledWith('SITE001');
-    expect(fixture.nativeElement.textContent).toContain(
-      '3 recommandations créées, 1 déjà présente, 2 alertes examinées.',
-    );
-    expect(getRecommendations).toHaveBeenCalledTimes(2);
-    expect(fixture.componentInstance.generating()).toBe(false);
-  });
-
-  it('génère pour tout le parc quand aucun site n’est filtré', () => {
-    const { fixture, generate } = setup({ role: 'admin' });
-
-    fixture.componentInstance.onGenerate();
-
-    expect(generate).toHaveBeenCalledWith(undefined);
-  });
-
-  it("signale l'échec de la génération sans casser la page", () => {
-    const { fixture, generate } = setup({ role: 'admin' });
-    generate.mockReturnValue(throwError(() => new Error('403')));
-
-    fixture.componentInstance.onGenerate();
-    fixture.detectChanges();
-
-    expect(fixture.componentInstance.generationError()).not.toBeNull();
-    expect(fixture.nativeElement.textContent).toContain(
-      'La génération des recommandations a échoué',
-    );
-    expect(fixture.componentInstance.generating()).toBe(false);
-  });
-
-  it('accorde le bilan au singulier', () => {
-    const { fixture } = setup();
-
-    expect(
-      fixture.componentInstance.bilan({
-        alerts_examined: 1,
-        recommendations_created: 1,
-        already_present: 0,
-      }),
-    ).toBe('1 recommandation créée, 0 déjà présente, 1 alerte examinée');
-  });
-});

apps/frontend/src/app/features/recommendations/recommendations.ts

@@ -1,85 +0,0 @@
-import { Component, computed, inject, signal, viewChild } from '@angular/core';
-import { toSignal } from '@angular/core/rxjs-interop';
-import { ActivatedRoute, RouterLink } from '@angular/router';
-import { catchError, map, of } from 'rxjs';
-import { SitesService } from '../../core/services/sites.service';
-import { RecommendationsService } from '../../core/services/recommendations.service';
-import { AuthService } from '../../core/services/auth.service';
-import { Site } from '../../shared/models/site.model';
-import { RecommendationGenerationReport } from '../../shared/models/recommendation.model';
-import { RecommendationList } from '../../shared/components/recommendation-list/recommendation-list';
-import { Alert as EvAlert } from '../../shared/components/ui/alert/alert';
-import { Brand } from '../../shared/components/ui/brand/brand';
-import { Button } from '../../shared/components/ui/button/button';
-
-const GENERATION_FAILED_MESSAGE =
-  'La génération des recommandations a échoué, réessayez plus tard.';
-
-export function parseAlertId(raw: string | null): number | null {
-  return raw !== null && /^[1-9]\d*$/.test(raw) ? Number(raw) : null;
-}
-
-function pluriel(nombre: number, singulier: string, plurielForme: string): string {
-  return `${nombre} ${nombre > 1 ? plurielForme : singulier}`;
-}
-
-@Component({
-  selector: 'app-recommendations',
-  standalone: true,
-  imports: [RouterLink, RecommendationList, EvAlert, Brand, Button],
-  templateUrl: './recommendations.html',
-  styleUrl: './recommendations.scss',
-})
-export class RecommendationsView {
-  private route = inject(ActivatedRoute);
-  private sitesService = inject(SitesService);
-  private recommendationsService = inject(RecommendationsService);
-  private auth = inject(AuthService);
-
-  alertId = toSignal(
-    this.route.queryParamMap.pipe(map((params) => parseAlertId(params.get('alert')))),
-    { initialValue: null },
-  );
-  siteFilter = signal<string | null>(this.route.snapshot.queryParamMap.get('site'));
-  sites = toSignal(this.sitesService.getSites().pipe(catchError(() => of([] as Site[]))), {
-    initialValue: [] as Site[],
-  });
-
-  list = viewChild.required(RecommendationList);
-
-  isAdmin = computed(() => this.auth.principal()?.role === 'admin');
-  generating = signal(false);
-  generationReport = signal<RecommendationGenerationReport | null>(null);
-  generationError = signal<string | null>(null);
-
-  onSiteChange(event: Event): void {
-    this.siteFilter.set((event.target as HTMLSelectElement).value || null);
-  }
-
-  onGenerate(): void {
-    if (this.generating()) {
-      return;
-    }
-    this.generating.set(true);
-    this.generationError.set(null);
-    this.recommendationsService.generate(this.siteFilter() ?? undefined).subscribe({
-      next: (report) => {
-        this.generating.set(false);
-        this.generationReport.set(report);
-        this.list().reload();
-      },
-      error: () => {
-        this.generating.set(false);
-        this.generationError.set(GENERATION_FAILED_MESSAGE);
-      },
-    });
-  }
-
-  bilan(report: RecommendationGenerationReport): string {
-    return [
-      pluriel(report.recommendations_created, 'recommandation créée', 'recommandations créées'),
-      pluriel(report.already_present, 'déjà présente', 'déjà présentes'),
-      pluriel(report.alerts_examined, 'alerte examinée', 'alertes examinées'),
-    ].join(', ');
-  }
-}

apps/frontend/src/app/features/sites/site-detail/site-detail.html

@@ -81,16 +81,5 @@
     }
   }
 
-  <section class="recommendations-section">
-    <h2>Recommandations</h2>
-    <app-recommendation-list [siteId]="siteId() ?? null" [sites]="siteAsList()" />
-    <a
-      routerLink="/recommendations"
-      [queryParams]="{ site: siteId() }"
-      class="ev-link recommendations-section__link"
-      >Voir dans la vue recommandations</a
-    >
-  </section>
-
   <a routerLink="/sites" class="ev-link">Retour aux sites</a>
 </div>

apps/frontend/src/app/features/sites/site-detail/site-detail.scss

@@ -117,12 +117,3 @@ h2 {
 .chart-section {
   margin-bottom: 2rem;
 }
-
-.recommendations-section {
-  margin: 2.5rem 0 1.5rem;
-}
-
-.recommendations-section__link {
-  display: inline-block;
-  margin-top: 1rem;
-}

apps/frontend/src/app/features/sites/site-detail/site-detail.spec.ts

@@ -5,8 +5,6 @@ import { BehaviorSubject, of, throwError } from 'rxjs';
 import { SiteDetail } from './site-detail';
 import { SitesService } from '../../../core/services/sites.service';
 import { ReadingsService } from '../../../core/services/readings.service';
-import { AlertsService } from '../../../core/services/alerts.service';
-import { RecommendationsService } from '../../../core/services/recommendations.service';
 
 const SITE = {
   site_id: 'SITE001',
@@ -71,7 +69,6 @@ function setup(
   readingsMock: Partial<ReadingsService>,
 ) {
   const paramMap = new BehaviorSubject(convertToParamMap({ siteId }));
-  const getAlerts = vi.fn().mockReturnValue(of([]));
   TestBed.configureTestingModule({
     imports: [SiteDetail],
     providers: [
@@ -79,14 +76,9 @@ function setup(
       { provide: ActivatedRoute, useValue: { paramMap } },
       { provide: SitesService, useValue: sitesMock },
       { provide: ReadingsService, useValue: readingsMock },
-      { provide: AlertsService, useValue: { getAlerts } },
-      {
-        provide: RecommendationsService,
-        useValue: { getRecommendations: vi.fn().mockReturnValue(of([])) },
-      },
     ],
   });
-  return { fixture: TestBed.createComponent(SiteDetail), paramMap, getAlerts };
+  return { fixture: TestBed.createComponent(SiteDetail), paramMap };
 }
 
 describe('SiteDetail', () => {
@@ -269,27 +261,6 @@ describe('SiteDetail', () => {
     );
   });
 
-  it('demande les recommandations du site consulté à travers ses alertes', () => {
-    const { fixture, getAlerts } = setup(
-      'SITE001',
-      {
-        getSite: vi.fn().mockReturnValue(of(SITE)),
-        getCurrent: vi.fn().mockReturnValue(of(CURRENT_COMPLET)),
-      },
-      { getHistory: vi.fn().mockReturnValue(of([])) },
-    );
-
-    fixture.detectChanges();
-    fixture.detectChanges();
-
-    expect(getAlerts).toHaveBeenCalledWith({ site_id: 'SITE001' });
-    expect(fixture.nativeElement.querySelector('app-recommendation-list')).not.toBeNull();
-    expect(fixture.nativeElement.textContent).toContain('Recommandations');
-    expect(
-      fixture.nativeElement.querySelector('a[href="/recommendations?site=SITE001"]'),
-    ).not.toBeNull();
-  });
-
   it("annonce l'absence de mesure sans interroger l'historique quand timestamp est null", () => {
     const getHistory = vi.fn().mockReturnValue(of([]));
     const { fixture } = setup(

apps/frontend/src/app/features/sites/site-detail/site-detail.ts

@@ -13,7 +13,6 @@ import { Badge, BadgeTone } from '../../../shared/components/ui/badge/badge';
 import { Brand } from '../../../shared/components/ui/brand/brand';
 import { ConsumptionGauge } from '../../../shared/components/consumption-gauge/consumption-gauge';
 import { ReadingHistoryChart } from '../../../shared/components/reading-history-chart/reading-history-chart';
-import { RecommendationList } from '../../../shared/components/recommendation-list/recommendation-list';
 
 const UNAVAILABLE_MESSAGE = 'Détail du site indisponible, réessayez plus tard.';
 const NO_MEASUREMENT_MESSAGE = 'Aucune mesure remontée pour ce site.';
@@ -97,16 +96,7 @@ export interface MetricView {
 @Component({
   selector: 'app-site-detail',
   standalone: true,
-  imports: [
+  imports: [RouterLink, Card, Alert, Badge, Brand, ConsumptionGauge, ReadingHistoryChart],
-    RouterLink,
-    Card,
-    Alert,
-    Badge,
-    Brand,
-    ConsumptionGauge,
-    ReadingHistoryChart,
-    RecommendationList,
-  ],
   templateUrl: './site-detail.html',
   styleUrl: './site-detail.scss',
 })
@@ -127,11 +117,6 @@ export class SiteDetail {
 
   hasMeasurement = computed(() => this.current()?.timestamp != null);
 
-  siteAsList = computed<Site[]>(() => {
-    const site = this.site();
-    return site ? [site] : [];
-  });
-
   consumptionKw = computed(() => this.current()?.consumption_kw ?? null);
 
   consumptionLabel = computed(() => {

apps/frontend/src/app/shared/components/recommendation-list/recommendation-list.html

@@ -1,48 +0,0 @@
-@if (error(); as message) {
-  <ev-alert severity="danger" class="reco-list__banner">{{ message }}</ev-alert>
-} @else if (loading() && !hasData()) {
-  <p class="reco-list__state" aria-live="polite">Chargement des recommandations…</p>
-} @else if (visibleGroups().length === 0) {
-  <ev-alert severity="success" class="reco-list__banner">{{ emptyMessage() }}</ev-alert>
-}
-
-<div class="reco-list" [attr.aria-busy]="loading()">
-  @for (group of visibleGroups(); track group.alert.alert_id) {
-    <ev-card
-      class="reco-group"
-      [class.reco-group--focus]="group.alert.alert_id === alertId()"
-      [id]="'alerte-' + group.alert.alert_id"
-    >
-      <header class="reco-group__alert">
-        <div class="reco-group__meta">
-          <ev-badge [tone]="toneFor(group.alert.severity)">{{
-            severityLabel(group.alert.severity)
-          }}</ev-badge>
-          <span class="reco-group__type">{{ typeLabel(group.alert.type) }}</span>
-          @if (!siteId()) {
-            <a [routerLink]="['/sites', group.alert.site_id]" class="ev-link">{{
-              group.siteName
-            }}</a>
-          }
-          <time [attr.datetime]="group.alert.timestamp">{{
-            group.alert.timestamp | date: 'dd/MM/yyyy HH:mm'
-          }}</time>
-        </div>
-        <p class="reco-group__message">{{ group.alert.message }}</p>
-      </header>
-      <ol class="reco-group__items">
-        @for (reco of group.recommendations; track reco.recommendation_id) {
-          <li class="reco">
-            <div class="reco__head">
-              <strong class="reco__action">{{ reco.action }}</strong>
-              <ev-badge [tone]="ruleTone(reco.rule_reference)">{{
-                ruleLabel(reco.rule_reference)
-              }}</ev-badge>
-            </div>
-            <p class="reco__explanation">{{ reco.explanation }}</p>
-          </li>
-        }
-      </ol>
-    </ev-card>
-  }
-</div>

apps/frontend/src/app/shared/components/recommendation-list/recommendation-list.scss

@@ -1,94 +0,0 @@
-:host {
-  display: block;
-}
-
-.reco-list__banner {
-  display: block;
-  margin-bottom: var(--space-3);
-}
-
-.reco-list__state {
-  margin: 0 0 var(--space-3);
-  font-size: 0.9rem;
-  color: var(--color-text-muted);
-}
-
-.reco-list {
-  display: flex;
-  flex-direction: column;
-  gap: var(--space-3);
-}
-
-.reco-group {
-  padding: var(--space-4);
-  gap: var(--space-3);
-}
-
-.reco-group--focus {
-  border-color: var(--color-primary);
-  box-shadow: 0 0 0 3px var(--color-primary-light);
-}
-
-.reco-group__alert {
-  display: flex;
-  flex-direction: column;
-  gap: var(--space-1);
-  padding-bottom: var(--space-3);
-  border-bottom: 1px solid var(--color-border-light);
-}
-
-.reco-group__meta {
-  display: flex;
-  flex-wrap: wrap;
-  align-items: center;
-  gap: var(--space-2);
-  font-size: 0.8rem;
-  color: var(--color-text-muted);
-}
-
-.reco-group__type {
-  font-weight: 600;
-  color: var(--color-text);
-}
-
-.reco-group__message {
-  margin: 0;
-  font-size: 0.9rem;
-}
-
-.reco-group__items {
-  list-style: none;
-  margin: 0;
-  padding: 0;
-  display: flex;
-  flex-direction: column;
-  gap: var(--space-2);
-}
-
-.reco {
-  display: flex;
-  flex-direction: column;
-  gap: 0.25rem;
-  padding: var(--space-2) var(--space-3);
-  border-radius: var(--radius-sm);
-  background: var(--color-bg);
-  border-left: 3px solid var(--color-primary);
-}
-
-.reco__head {
-  display: flex;
-  flex-wrap: wrap;
-  align-items: center;
-  justify-content: space-between;
-  gap: var(--space-2);
-}
-
-.reco__action {
-  font-size: 0.95rem;
-}
-
-.reco__explanation {
-  margin: 0;
-  font-size: 0.85rem;
-  color: var(--color-text-muted);
-}

apps/frontend/src/app/shared/components/recommendation-list/recommendation-list.spec.ts

@@ -1,244 +0,0 @@
-import { ComponentFixture, TestBed } from '@angular/core/testing';
-import { provideRouter } from '@angular/router';
-import { vi } from 'vitest';
-import { NEVER, of, throwError } from 'rxjs';
-import { RecommendationList, joinByAlert } from './recommendation-list';
-import { AlertsService } from '../../../core/services/alerts.service';
-import { RecommendationsService } from '../../../core/services/recommendations.service';
-import { Alert } from '../../models/alert.model';
-import { Recommendation } from '../../models/recommendation.model';
-import { Site } from '../../models/site.model';
-
-const SITES: Site[] = [
-  {
-    site_id: 'SITE001',
-    site_name: 'Usine Nantes',
-    site_type: 'industriel',
-    location: 'Nantes',
-    capacity_kw: 500,
-    status: 'actif',
-  },
-  {
-    site_id: 'SITE002',
-    site_name: 'Bureau Lille',
-    site_type: 'bureau',
-    location: 'Lille',
-    capacity_kw: 80,
-    status: 'actif',
-  },
-];
-
-function alerte(surcharges: Partial<Alert>): Alert {
-  return {
-    alert_id: 1,
-    site_id: 'SITE001',
-    timestamp: '2026-09-15T09:00:00Z',
-    type: 'threshold',
-    severity: 'high',
-    message: 'Puissance appelée au-dessus de la capacité du site',
-    value: 812.5,
-    threshold: 720,
-    metric: 'consumption_kw',
-    prediction_id: null,
-    ...surcharges,
-  };
-}
-
-function reco(surcharges: Partial<Recommendation>): Recommendation {
-  return {
-    recommendation_id: 1,
-    alert_id: 1,
-    action: 'Ramener la puissance appelée sous le seuil contractuel',
-    explanation: 'Seuil de consommation dépassé sur le site SITE001.',
-    rule_reference: 'threshold-reduction-v1',
-    created_at: '2026-09-15T09:05:00Z',
-    ...surcharges,
-  };
-}
-
-const ALERTES: Alert[] = [
-  alerte({ alert_id: 1, site_id: 'SITE001', timestamp: '2026-09-15T09:00:00Z' }),
-  alerte({
-    alert_id: 2,
-    site_id: 'SITE002',
-    timestamp: '2026-09-15T11:00:00Z',
-    severity: 'critical',
-    type: 'spike',
-    message: 'Variation brutale entre deux lectures consécutives',
-  }),
-  alerte({ alert_id: 3, site_id: 'SITE001', timestamp: '2026-09-15T10:00:00Z', severity: 'low' }),
-];
-
-const RECOMMANDATIONS: Recommendation[] = [
-  reco({
-    recommendation_id: 3,
-    alert_id: 2,
-    action: "Escalader à l'astreinte sous une heure",
-    rule_reference: 'escalade-astreinte-v1',
-  }),
-  reco({ recommendation_id: 1, alert_id: 1 }),
-  reco({
-    recommendation_id: 2,
-    alert_id: 2,
-    action: 'Délester les équipements non prioritaires sur le créneau du pic',
-    rule_reference: 'spike-delestage-v1',
-  }),
-  reco({ recommendation_id: 4, alert_id: 99, rule_reference: 'orpheline-v1' }),
-];
-
-function setup(
-  alertsMock: { getAlerts: ReturnType<typeof vi.fn> },
-  recosMock: { getRecommendations: ReturnType<typeof vi.fn> },
-  inputs: Record<string, unknown> = {},
-) {
-  TestBed.configureTestingModule({
-    imports: [RecommendationList],
-    providers: [
-      provideRouter([]),
-      { provide: AlertsService, useValue: alertsMock },
-      { provide: RecommendationsService, useValue: recosMock },
-    ],
-  });
-  const fixture = TestBed.createComponent(RecommendationList);
-  for (const [nom, valeur] of Object.entries(inputs)) {
-    fixture.componentRef.setInput(nom, valeur);
-  }
-  return fixture;
-}
-
-function rendre(fixture: ComponentFixture<RecommendationList>) {
-  fixture.detectChanges();
-  fixture.detectChanges();
-}
-
-function texte(fixture: ComponentFixture<RecommendationList>): string {
-  return (fixture.nativeElement as HTMLElement).textContent ?? '';
-}
-
-const recosOk = () => ({ getRecommendations: vi.fn().mockReturnValue(of(RECOMMANDATIONS)) });
-
-describe('joinByAlert', () => {
-  it('groupe par alerte, du plus récent au plus ancien, recommandations par identifiant', () => {
-    const groupes = joinByAlert(ALERTES, RECOMMANDATIONS, new Map([['SITE001', 'Usine Nantes']]));
-
-    expect(groupes.map((g) => g.alert.alert_id)).toEqual([2, 1]);
-    expect(groupes[0].recommendations.map((r) => r.recommendation_id)).toEqual([2, 3]);
-    expect(groupes[1].siteName).toBe('Usine Nantes');
-    expect(groupes[0].siteName).toBe('SITE002');
-  });
-
-  it('ignore les alertes sans recommandation et les recommandations orphelines', () => {
-    const groupes = joinByAlert(ALERTES, RECOMMANDATIONS, new Map());
-
-    expect(groupes.some((g) => g.alert.alert_id === 3)).toBe(false);
-    expect(groupes.flatMap((g) => g.recommendations).some((r) => r.alert_id === 99)).toBe(false);
-  });
-});
-
-describe('RecommendationList', () => {
-  it('charge alertes et recommandations puis affiche les groupes avec leur contexte', () => {
-    const getAlerts = vi.fn().mockReturnValue(of(ALERTES));
-    const fixture = setup({ getAlerts }, recosOk(), { sites: SITES });
-
-    rendre(fixture);
-
-    expect(getAlerts).toHaveBeenCalledWith({});
-    expect(fixture.nativeElement.querySelectorAll('.reco-group').length).toBe(2);
-    const contenu = texte(fixture);
-    expect(contenu).toContain('Usine Nantes');
-    expect(contenu).toContain('Bureau Lille');
-    expect(contenu).toContain('Critique');
-    expect(contenu).toContain('Pic de consommation');
-    expect(contenu).toContain('Escalade astreinte');
-    expect(contenu).toContain('Délester les équipements');
-    expect(contenu).toContain('15/09/2026');
-    expect(fixture.nativeElement.querySelector('a[href="/sites/SITE002"]')).not.toBeNull();
-    expect(fixture.componentInstance.total()).toBe(3);
-    expect(fixture.componentInstance.error()).toBeNull();
-  });
-
-  it('filtre les alertes du site côté API et masque le lien vers le site', () => {
-    const getAlerts = vi.fn().mockReturnValue(of(ALERTES.filter((a) => a.site_id === 'SITE001')));
-    const fixture = setup({ getAlerts }, recosOk(), { siteId: 'SITE001', sites: SITES });
-
-    rendre(fixture);
-
-    expect(getAlerts).toHaveBeenCalledWith({ site_id: 'SITE001' });
-    expect(fixture.nativeElement.querySelectorAll('.reco-group').length).toBe(1);
-    expect(fixture.nativeElement.querySelector('a[href^="/sites/"]')).toBeNull();
-  });
-
-  it("ne garde que le groupe de l'alerte ciblée et le met en évidence", () => {
-    const fixture = setup({ getAlerts: vi.fn().mockReturnValue(of(ALERTES)) }, recosOk(), {
-      alertId: 2,
-    });
-
-    rendre(fixture);
-
-    const groupes = fixture.nativeElement.querySelectorAll('.reco-group');
-    expect(groupes.length).toBe(1);
-    expect(groupes[0].classList.contains('reco-group--focus')).toBe(true);
-    expect(groupes[0].id).toBe('alerte-2');
-  });
-
-  it("annonce l'absence de recommandation pour une alerte inconnue", () => {
-    const fixture = setup({ getAlerts: vi.fn().mockReturnValue(of(ALERTES)) }, recosOk(), {
-      alertId: 123,
-    });
-
-    rendre(fixture);
-
-    expect(texte(fixture)).toContain('Aucune recommandation pour cette alerte.');
-  });
-
-  it("annonce l'absence de recommandation pour le site consulté", () => {
-    const fixture = setup(
-      { getAlerts: vi.fn().mockReturnValue(of([])) },
-      { getRecommendations: vi.fn().mockReturnValue(of([])) },
-      { siteId: 'SITE001' },
-    );
-
-    rendre(fixture);
-
-    expect(texte(fixture)).toContain('Aucune recommandation pour ce site.');
-  });
-
-  it("signale l'indisponibilité et n'affiche aucun groupe si un des deux appels échoue", () => {
-    const fixture = setup(
-      { getAlerts: vi.fn().mockReturnValue(of(ALERTES)) },
-      { getRecommendations: vi.fn().mockReturnValue(throwError(() => new Error('nope'))) },
-    );
-
-    rendre(fixture);
-
-    expect(fixture.componentInstance.error()).not.toBeNull();
-    expect(fixture.componentInstance.groups()).toEqual([]);
-    expect(texte(fixture)).toContain('Recommandations indisponibles');
-    expect(fixture.nativeElement.querySelectorAll('.reco-group').length).toBe(0);
-  });
-
-  it('annonce le chargement tant que la réponse ne vient pas', () => {
-    const fixture = setup(
-      { getAlerts: vi.fn().mockReturnValue(NEVER) },
-      { getRecommendations: vi.fn().mockReturnValue(NEVER) },
-    );
-
-    rendre(fixture);
-
-    expect(fixture.componentInstance.loading()).toBe(true);
-    expect(texte(fixture)).toContain('Chargement des recommandations');
-  });
-
-  it('recharge les deux flux à la demande', () => {
-    const getAlerts = vi.fn().mockReturnValue(of(ALERTES));
-    const recos = recosOk();
-    const fixture = setup({ getAlerts }, recos);
-    rendre(fixture);
-
-    fixture.componentInstance.reload();
-    rendre(fixture);
-
-    expect(getAlerts).toHaveBeenCalledTimes(2);
-    expect(recos.getRecommendations).toHaveBeenCalledTimes(2);
-  });
-});

apps/frontend/src/app/shared/components/recommendation-list/recommendation-list.ts

@@ -1,163 +0,0 @@
-import { Component, DestroyRef, computed, inject, input, signal } from '@angular/core';
-import { takeUntilDestroyed, toObservable } from '@angular/core/rxjs-interop';
-import { DatePipe } from '@angular/common';
-import { RouterLink } from '@angular/router';
-import { catchError, EMPTY, forkJoin, Observable, switchMap, tap } from 'rxjs';
-import { AlertsService } from '../../../core/services/alerts.service';
-import { RecommendationsService } from '../../../core/services/recommendations.service';
-import { Alert, AlertSeverity, AlertType } from '../../models/alert.model';
-import { Recommendation } from '../../models/recommendation.model';
-import { Site } from '../../models/site.model';
-import {
-  LIBELLE_PAR_SEVERITE,
-  LIBELLE_PAR_TYPE,
-  TON_PAR_SEVERITE,
-} from '../../models/alert-presentation';
-import { libelleRegle, tonRegle } from '../../models/recommendation-presentation';
-import { Card } from '../ui/card/card';
-import { Badge, BadgeTone } from '../ui/badge/badge';
-import { Alert as EvAlert } from '../ui/alert/alert';
-
-const UNAVAILABLE_MESSAGE = 'Recommandations indisponibles, réessayez plus tard.';
-
-export interface RecommendedAlertView {
-  alert: Alert;
-  siteName: string;
-  recommendations: Recommendation[];
-}
-
-interface Chargement {
-  alerts: Alert[];
-  recommendations: Recommendation[];
-}
-
-// Pourquoi : une recommandation ne porte que alert_id, jamais site_id, et /recommendations n'a
-// aucun filtre ; la jointure se fait ici, en O(alertes), acceptable à la taille du jeu de données.
-export function joinByAlert(
-  alerts: Alert[],
-  recommendations: Recommendation[],
-  siteNames: Map<string, string>,
-): RecommendedAlertView[] {
-  const parAlerte = new Map<number, Recommendation[]>();
-  for (const recommandation of recommendations) {
-    const liste = parAlerte.get(recommandation.alert_id) ?? [];
-    liste.push(recommandation);
-    parAlerte.set(recommandation.alert_id, liste);
-  }
-  return alerts
-    .filter((alert) => parAlerte.has(alert.alert_id))
-    .map((alert) => ({
-      alert,
-      siteName: siteNames.get(alert.site_id) ?? alert.site_id,
-      recommendations: [...(parAlerte.get(alert.alert_id) ?? [])].sort(
-        (a, b) => a.recommendation_id - b.recommendation_id,
-      ),
-    }))
-    .sort((a, b) => Date.parse(b.alert.timestamp) - Date.parse(a.alert.timestamp));
-}
-
-@Component({
-  selector: 'app-recommendation-list',
-  standalone: true,
-  imports: [DatePipe, RouterLink, Card, Badge, EvAlert],
-  templateUrl: './recommendation-list.html',
-  styleUrl: './recommendation-list.scss',
-})
-export class RecommendationList {
-  private alertsService = inject(AlertsService);
-  private recommendationsService = inject(RecommendationsService);
-  private destroyRef = inject(DestroyRef);
-
-  siteId = input<string | null>(null);
-  alertId = input<number | null>(null);
-  sites = input<Site[]>([]);
-
-  private data = signal<Chargement | null>(null);
-  private reloadTick = signal(0);
-  loading = signal(true);
-  error = signal<string | null>(null);
-
-  private trigger = computed(() => ({ siteId: this.siteId(), tick: this.reloadTick() }));
-
-  private siteNameById = computed(
-    () => new Map(this.sites().map((site) => [site.site_id, site.site_name])),
-  );
-
-  hasData = computed(() => this.data() !== null);
-
-  groups = computed<RecommendedAlertView[]>(() => {
-    const data = this.data();
-    return data ? joinByAlert(data.alerts, data.recommendations, this.siteNameById()) : [];
-  });
-
-  visibleGroups = computed(() => {
-    const alertId = this.alertId();
-    const groups = this.groups();
-    return alertId === null ? groups : groups.filter((group) => group.alert.alert_id === alertId);
-  });
-
-  total = computed(() =>
-    this.visibleGroups().reduce((somme, group) => somme + group.recommendations.length, 0),
-  );
-
-  emptyMessage = computed(() => {
-    if (this.alertId() !== null) {
-      return 'Aucune recommandation pour cette alerte.';
-    }
-    return this.siteId()
-      ? 'Aucune recommandation pour ce site.'
-      : 'Aucune recommandation pour le moment.';
-  });
-
-  constructor() {
-    toObservable(this.trigger)
-      .pipe(
-        tap(() => this.loading.set(true)),
-        switchMap(({ siteId }) =>
-          forkJoin({
-            alerts: this.alertsService.getAlerts(siteId ? { site_id: siteId } : {}),
-            recommendations: this.recommendationsService.getRecommendations(),
-          }).pipe(catchError(() => this.reportUnavailable())),
-        ),
-        takeUntilDestroyed(this.destroyRef),
-      )
-      .subscribe((data) => {
-        this.loading.set(false);
-        this.error.set(null);
-        this.data.set(data);
-      });
-  }
-
-  reload(): void {
-    this.reloadTick.update((tick) => tick + 1);
-  }
-
-  toneFor(severity: AlertSeverity): BadgeTone {
-    return TON_PAR_SEVERITE[severity];
-  }
-
-  severityLabel(severity: AlertSeverity): string {
-    return LIBELLE_PAR_SEVERITE[severity];
-  }
-
-  typeLabel(type: AlertType): string {
-    return LIBELLE_PAR_TYPE[type];
-  }
-
-  ruleLabel(reference: string): string {
-    return libelleRegle(reference);
-  }
-
-  ruleTone(reference: string): BadgeTone {
-    return tonRegle(reference);
-  }
-
-  // Piège : vider les données avec l'erreur ; une demi-jointure (alertes sans recommandations,
-  // ou l'inverse) afficherait des groupes faux plutôt que rien.
-  private reportUnavailable(): Observable<never> {
-    this.loading.set(false);
-    this.error.set(UNAVAILABLE_MESSAGE);
-    this.data.set(null);
-    return EMPTY;
-  }
-}

apps/frontend/src/app/shared/models/alert-presentation.spec.ts

@@ -1,37 +0,0 @@
-import {
-  LIBELLE_PAR_SEVERITE,
-  LIBELLE_PAR_TYPE,
-  SEVERITES,
-  TON_PAR_SEVERITE,
-  TYPES_ALERTE,
-  UNITE_PAR_METRIQUE,
-} from './alert-presentation';
-
-describe('alert-presentation', () => {
-  it('distingue le ton des sévérités high et critical', () => {
-    expect(TON_PAR_SEVERITE.high).toBe('danger');
-    expect(TON_PAR_SEVERITE.critical).toBe('critical');
-    expect(TON_PAR_SEVERITE.high).not.toBe(TON_PAR_SEVERITE.critical);
-  });
-
-  it("n'affiche pas une alerte faible avec le ton de succès", () => {
-    expect(TON_PAR_SEVERITE.low).toBe('neutral');
-    expect(TON_PAR_SEVERITE.medium).toBe('warning');
-  });
-
-  it('donne un libellé français à chaque sévérité et à chaque type', () => {
-    for (const severite of SEVERITES) {
-      expect(LIBELLE_PAR_SEVERITE[severite]).toBeTruthy();
-    }
-    for (const type of TYPES_ALERTE) {
-      expect(LIBELLE_PAR_TYPE[type]).toBeTruthy();
-    }
-    expect(SEVERITES.length).toBe(4);
-    expect(TYPES_ALERTE.length).toBe(5);
-  });
-
-  it('associe une unité à chaque métrique du contrat', () => {
-    expect(UNITE_PAR_METRIQUE.consumption_kw).toBe('kW');
-    expect(UNITE_PAR_METRIQUE.consumption_kwh).toBe('kWh');
-  });
-});

apps/frontend/src/app/shared/models/alert-presentation.ts

@@ -1,41 +0,0 @@
-import { BadgeTone } from '../components/ui/badge/badge';
-import { AlertMetric, AlertSeverity, AlertType } from './alert.model';
-
-// Pourquoi : `low` en neutre plutôt qu'en vert, une alerte faible reste une alerte ; le vert se
-// lisait comme « tout va bien » à côté des rouges.
-export const TON_PAR_SEVERITE: Record<AlertSeverity, BadgeTone> = {
-  low: 'neutral',
-  medium: 'warning',
-  high: 'danger',
-  critical: 'critical',
-};
-
-export const LIBELLE_PAR_SEVERITE: Record<AlertSeverity, string> = {
-  low: 'Faible',
-  medium: 'Moyenne',
-  high: 'Élevée',
-  critical: 'Critique',
-};
-
-export const LIBELLE_PAR_TYPE: Record<AlertType, string> = {
-  spike: 'Pic de consommation',
-  threshold: 'Seuil dépassé',
-  anomaly: 'Anomalie',
-  outage: 'Coupure',
-  sensor: 'Capteur',
-};
-
-export const UNITE_PAR_METRIQUE: Record<AlertMetric, string> = {
-  consumption_kw: 'kW',
-  consumption_kwh: 'kWh',
-};
-
-export const SEVERITES: readonly AlertSeverity[] = ['low', 'medium', 'high', 'critical'];
-
-export const TYPES_ALERTE: readonly AlertType[] = [
-  'spike',
-  'threshold',
-  'anomaly',
-  'outage',
-  'sensor',
-];

apps/frontend/src/app/shared/models/alert.model.ts

@@ -1,16 +1,13 @@
 export type AlertSeverity = 'low' | 'medium' | 'high' | 'critical';
 export type AlertType = 'spike' | 'threshold' | 'anomaly' | 'outage' | 'sensor';
-export type AlertMetric = 'consumption_kw' | 'consumption_kwh';
 
 export interface Alert {
-  alert_id: number;
+  alert_id: string;
-  site_id: string;
   timestamp: string;
-  type: AlertType;
+  site_id: string;
   severity: AlertSeverity;
+  type: AlertType;
   message: string;
-  value: number | null;
+  value: number;
-  threshold: number | null;
+  threshold: number;
-  metric: AlertMetric | null;
-  prediction_id: number | null;
 }

apps/frontend/src/app/shared/models/recommendation-presentation.spec.ts

@@ -1,23 +0,0 @@
-import { libelleRegle, tonRegle } from './recommendation-presentation';
-
-describe('recommendation-presentation', () => {
-  it('traduit les sept règles connues du moteur', () => {
-    expect(libelleRegle('spike-delestage-v1')).toBe('Délestage');
-    expect(libelleRegle('threshold-reduction-v1')).toBe('Réduction de puissance');
-    expect(libelleRegle('outage-secours-v1')).toBe('Alimentation de secours');
-    expect(libelleRegle('sensor-maintenance-v1')).toBe('Maintenance capteur');
-    expect(libelleRegle('anomaly-verification-v1')).toBe('Vérification');
-    expect(libelleRegle('escalade-astreinte-v1')).toBe('Escalade astreinte');
-    expect(libelleRegle('contrat-puissance-v1')).toBe('Contrat de puissance');
-  });
-
-  it('affiche telle quelle une référence de règle inconnue', () => {
-    expect(libelleRegle('spike-delestage-v2')).toBe('spike-delestage-v2');
-  });
-
-  it("réserve le ton critique à l'escalade vers l'astreinte", () => {
-    expect(tonRegle('escalade-astreinte-v1')).toBe('critical');
-    expect(tonRegle('spike-delestage-v1')).toBe('neutral');
-    expect(tonRegle('inconnue-v9')).toBe('neutral');
-  });
-});

apps/frontend/src/app/shared/models/recommendation-presentation.ts

@@ -1,23 +0,0 @@
-import { BadgeTone } from '../components/ui/badge/badge';
-
-// Contrainte : une règle dont le sens change reçoit un suffixe -v2 côté backend (ADR 0006) ;
-// une référence inconnue s'affiche donc telle quelle plutôt que de casser la vue.
-const LIBELLE_PAR_REGLE: Record<string, string> = {
-  'spike-delestage-v1': 'Délestage',
-  'threshold-reduction-v1': 'Réduction de puissance',
-  'outage-secours-v1': 'Alimentation de secours',
-  'sensor-maintenance-v1': 'Maintenance capteur',
-  'anomaly-verification-v1': 'Vérification',
-  'escalade-astreinte-v1': 'Escalade astreinte',
-  'contrat-puissance-v1': 'Contrat de puissance',
-};
-
-const REGLE_ESCALADE = 'escalade-astreinte-v1';
-
-export function libelleRegle(reference: string): string {
-  return LIBELLE_PAR_REGLE[reference] ?? reference;
-}
-
-export function tonRegle(reference: string): BadgeTone {
-  return reference === REGLE_ESCALADE ? 'critical' : 'neutral';
-}

apps/frontend/src/app/shared/models/recommendation.model.ts

@@ -1,14 +0,0 @@
-export interface Recommendation {
-  recommendation_id: number;
-  alert_id: number;
-  action: string;
-  explanation: string;
-  rule_reference: string;
-  created_at: string;
-}
-
-export interface RecommendationGenerationReport {
-  alerts_examined: number;
-  recommendations_created: number;
-  already_present: number;
-}

apps/frontend/src/styles/_forms.scss

@@ -29,18 +29,3 @@
   color: var(--color-disabled);
   margin-top: 0.25rem;
 }
-
-// Piège : le chevron est un SVG en data URI, où aucun token CSS n'est lisible ; sa couleur
-// reprend en dur la valeur de --color-text-muted.
-.form-select {
-  @extend .form-input;
-  padding-right: 2.25rem;
-  color: var(--color-text);
-  background-color: var(--color-surface);
-  background-image: url("data:image/svg+xml,%3Csvg xmlns='http://www.w3.org/2000/svg' viewBox='0 0 20 20' fill='none' stroke='%236b7280' stroke-width='1.5' stroke-linecap='round' stroke-linejoin='round'%3E%3Cpath d='M6 8l4 4 4-4'/%3E%3C/svg%3E");
-  background-repeat: no-repeat;
-  background-position: right 0.6rem center;
-  background-size: 1rem;
-  appearance: none;
-  cursor: pointer;
-}

apps/frontend/tsconfig.json

@@ -3,7 +3,6 @@
 {
   "compileOnSave": false,
   "compilerOptions": {
-    "strict": true,
     "noImplicitOverride": true,
     "noPropertyAccessFromIndexSignature": true,
     "noImplicitReturns": true,

docker-compose.yml

@@ -36,6 +36,7 @@ x-airflow-common: &airflow-common
   volumes:
     - ./etl/airflow/dags:/opt/airflow/dags
     - ./etl/airflow/plugins:/opt/airflow/plugins
+    - ./data/raw:/opt/data/raw:ro
     - airflow_logs:/opt/airflow/logs
     - airflow_ml_state:/opt/ml/state
   restart: unless-stopped

docs/architecture/00-vue-ensemble.md

@@ -70,10 +70,11 @@ Le lien `front -.-> api` reste en pointillé : le frontend appelle bien une API,
 intercepteur répond à sa place tant que les endpoints n'existent pas. Voir
 [30-frontend.md](30-frontend.md).
 
-Le lien `airflow --> db` est maintenant en trait plein : trois DAGs tournent, deux pour
+Le lien `airflow --> db` est maintenant en trait plein : quatre DAGs tournent, deux pour
 l'entraînement et le scoring du modèle ML (issue #115), un pour la détection d'alertes et la
-génération des recommandations (issue #116), cf. plus bas et [20-backend.md](20-backend.md). Le
+génération des recommandations (issue #116), et `historical_import` pour l'ingestion du dataset
-reste du périmètre Airflow envisagé (ingestion, issues #15/#16) reste en pointillé, non construit.
+historique (issue #119). L'orchestration de l'import API Mock et la réconciliation globale des
+deux sources restent à compléter dans l'issue #15.
 
 Le lien `prom -.-> api` de même : l'API expose bien `/metrics` au format Prometheus, mais aucun
 collecteur ne vient le lire.
@@ -88,7 +89,7 @@ collecteur ne vient le lire.
 | ML | LightGBM, MLflow | `ml` | `En cours` | Pipeline d'entraînement et de scoring (`enervision_ml.train`/`.score`, features par lags/moyennes glissantes partagées entre les deux, baseline de persistance saisonnière, suivi MLflow local), exposé en lecture via `GET /predictions`, orchestré par Airflow (`ml_train`/`ml_score`). Voir [ADR 0005](../adr/0005-modele-prediction-lightgbm.md) et [ML-START.md](../ML-START.md). Surveillance de dérive (EC06, #44/#45) pas encore construite |
 | Infra | Docker Compose, Nginx, Terraform, k3s single-node | `infra`, `docker-compose.prod.yml` | `En cours` | Reverse proxy et overlay de déploiement écrits et validés, jamais lancés sur le serveur ([ADR 0007](../adr/0007-terminaison-tls-et-reverse-proxy-nginx.md)). Module d'installation k3s jamais appliqué, aucune ressource Kubernetes déclarée |
 | Monitoring | Prometheus, Grafana, Alertmanager | `monitoring` | `Cible` | Rien, hors le `/metrics` exposé par l'API |
-| ETL | Apache Airflow | `etl/airflow` | `En cours` | Webserver + scheduler (LocalExecutor) tournent via docker-compose, base de métadonnées Postgres dédiée. Trois DAGs en sous-processus `uv run` : `ml_train` manuel et `ml_score` `@hourly` pour le pipeline ML (issue #115), `alertes` à `15 * * * *` pour la détection et les recommandations (issue #116, [ADR 0008](../adr/0008-airflow-execute-le-code-du-backend.md)). L'ingestion (issues #15/#16) n'a pas encore de DAG |
+| ETL | Apache Airflow | `etl/airflow` | `En cours` | Webserver + scheduler (LocalExecutor) tournent via docker-compose, base de métadonnées Postgres dédiée. Quatre DAGs en sous-processus `uv run` : `ml_train`, `ml_score`, `alertes` et `historical_import`. Le DAG historique orchestre `app.etl.historical_import` et charge `dataset`, `site` et `reading`. L'orchestration API Mock reste à compléter dans #15 |
 | CI/CD | GitHub Actions | `.github/workflows` | `En cours` | 5 workflows, 16 jobs : lint, typage, tests avec seuil de couverture bloquant, tests d'intégration sur TimescaleDB réel, audit de dépendances, SAST Bandit, quality gate SonarCloud, intégrité des DAGs Airflow. Détail dans [50-cicd.md](50-cicd.md). **Aucun job de déploiement** (#21) |
 
 ## Flux bout en bout

docs/architecture/10-infra.md

@@ -51,7 +51,7 @@ Trois pièges sont documentés en tête du `docker-compose.yml`, ils ne se devin
 - `LocalExecutor` exécute les tâches comme sous-processus du **scheduler**, jamais du webserver :
   c'est le scheduler qui a besoin du volume `airflow_ml_state` (modèle, magasin MLflow).
 
-### Airflow (issues #115 et #116)
+### Airflow (issues #115, #116 et #119)
 
 Trois services, `docker compose profiles` non utilisés (démarrage explicite via `make
 airflow-up`, pas dans `make dev`) :
@@ -75,6 +75,12 @@ l'[ADR 0008](../adr/0008-airflow-execute-le-code-du-backend.md).
 | `ml_train` | manuelle | `enervision_ml.train`, dans `/opt/ml/.venv` |
 | `ml_score` | `0 * * * *` | `enervision_ml.score`, dans `/opt/ml/.venv` |
 | `alertes` | `15 * * * *` | `app.detection.internal_alerts` puis `app.cli generate-recommendations`, dans `/opt/backend/.venv` |
+| `historical_import` | manuelle | `app.etl.historical_import`, dans `/opt/backend/.venv` ; les fichiers de `data/raw` sont montés en lecture seule dans `/opt/data/raw` |
+
+Le DAG `historical_import` réutilise le pipeline historique existant sans dupliquer sa logique.
+Il reste manuel, car le dataset sert à initialiser l'environnement. Le montage
+`./data/raw:/opt/data/raw:ro` permet au scheduler de lire les fichiers CSV/JSON sans pouvoir les
+modifier.
 
 **Pourquoi `alertes` tourne à la quinzième minute.** Sa règle `anomaly` compare une lecture à la
 `prediction` du même instant, que `ml_score` écrit à l'heure pile. Le décalage laisse le scoring

docs/architecture/30-frontend.md

@@ -146,29 +146,6 @@ Compose.
 
 Conventions et gabarits : [`apps/frontend/TESTING.md`](../../apps/frontend/TESTING.md).
 
-## Recommandations
-
-Statut : `Fait`. La vue `/recommendations` (`features/recommendations`, derrière `authGuard`, tous
-rôles) présente les recommandations du moteur de règles groupées par alerte, du plus récent au plus
-ancien, avec le contexte de l'alerte (sévérité, type, site, horodatage, message) puis chaque action,
-son explication et la règle qui l'a produite.
-
-- **Jointure côté client.** Une recommandation ne porte que `alert_id`, jamais `site_id`, et
-  `GET /recommendations` n'a aucun filtre. `app-recommendation-list` (`shared/components/`) charge
-  donc en parallèle `GET /alerts` (filtré par `site_id` quand un site est fixé) et
-  `GET /recommendations`, puis les joint par `alert_id` (`joinByAlert`, fonction pure testée à
-  part). Les recommandations dont l'alerte n'est pas dans le jeu chargé sont ignorées : c'est ainsi
-  que le filtre site s'applique. `/alerts` n'étant pas paginé, un seul appel suffit.
-- **Paramètres d'URL.** `?site=<site_id>` présélectionne le filtre site ; `?alert=<alert_id>`
-  réduit la vue à une alerte et la met en évidence (entier strictement positif, sinon ignoré).
-- **Génération.** Le bouton « Générer les recommandations » n'apparaît que pour le rôle `admin`
-  (`POST /recommendations/generate?site_id=`, réservé admin côté API) et affiche le bilan renvoyé
-  (créées, déjà présentes, alertes examinées) avant de recharger la liste. La voie normale reste le
-  DAG Airflow `alertes` ([ADR 0008](../adr/0008-airflow-execute-le-code-du-backend.md)).
-- **Entrées.** Lien « Recommandations » dans l'en-tête du tableau de bord ; section
-  « Recommandations » sur la vue détail d'un site (liste restreinte au site, lien vers la vue
-  complète préfiltrée).
-
 ## Questions ouvertes
 
 - **Gestion d'état** : les signaux suffisent aujourd'hui, la question se reposera quand plusieurs

docs/architecture/32-design-systeme-frontend.md

@@ -24,13 +24,12 @@ seule fois dans `src/styles.scss`. Disponibles partout sans import supplémentai
 | `--shadow-card` | Ombre portée des cartes |
 | `--space-1` à `--space-5` | Échelle d'espacement (0.35rem à 2.5rem) |
 
-Les classes de formulaire partagées (`.form-label`, `.form-input`, `.form-select`, `.form-hint`)
+Les classes de formulaire partagées (`.form-label`, `.form-input`, `.form-hint`) sont dans
-sont dans `apps/frontend/src/styles/_forms.scss`, importées globalement de la même façon. Elles
+`apps/frontend/src/styles/_forms.scss`, importées globalement de la même façon. Elles
-s'appliquent directement à des `<label>`/`<input>`/`<select>` natifs, liés par `formControlName` ou
+s'appliquent directement à des `<label>`/`<input>` natifs liés par `formControlName` : pas de
-par un simple `(change)` : pas de composant `ControlValueAccessor` dédié, le gain n'en vaut pas la
+composant `ControlValueAccessor` dédié, le gain n'en vaut pas la complexité pour des formulaires
-complexité pour des formulaires aussi simples que ceux de ce projet. `.form-select` habille un
+aussi simples que ceux de ce projet. Les erreurs de formulaire, elles, s'affichent via
-`<select>` natif avec la bordure et le focus de `.form-input`, plus un chevron. Les erreurs de
+`<ev-alert severity="danger">`, pas une classe dédiée.
-formulaire, elles, s'affichent via `<ev-alert severity="danger">`, pas une classe dédiée.
 
 La classe `.auth-page` (`apps/frontend/src/styles/_auth-page.scss`, importée globalement) porte
 le fond dégradé et le centrage commun aux pages d'authentification (`login`, `change-password`,

etl/README.md

@@ -663,8 +663,16 @@ mock_api_import.py
 
 La logique d'extraction, de transformation et de chargement est donc disponible pour les deux sources de données du MVP.
 
-Airflow tourne désormais réellement (`etl/airflow/`, `make airflow-up`) et orchestre le pipeline ML (`ml_train`/`ml_score`, issue #115) ainsi que la détection d'alertes et la génération des recommandations (`alertes`, issue #116). Il n'orchestre pas encore ces deux imports : `historical_import.py` et `mock_api_import.py` (normalisation et chargement micro-batch, issues #15/#16) restent à faire.
+Airflow tourne désormais réellement (`etl/airflow/`, `make airflow-up`) et orchestre le pipeline
+ML (`ml_train`/`ml_score`, issue #115), la détection d'alertes et la génération des
+recommandations (`alertes`, issue #116), ainsi que l'import historique
+(`historical_import`, issue #119).
 
-Airflow permet de planifier les traitements, gérer leur ordre d'exécution, suivre leur état et remonter les erreurs. Il ne remplace pas la logique ETL Python existante : les scripts actuels restent responsables de l'extraction, de la validation, de la transformation et du chargement. `etl/airflow/dags/ml_train.py`, `ml_score.py` et `alertes.py` montrent le patron retenu (des `BashOperator` qui invoquent le script tel quel, dans l'environnement `uv` que l'image embarque pour lui).
+Le DAG `historical_import` est déclenché manuellement. Il exécute
+`app.etl.historical_import` avec les fichiers montés en lecture seule depuis `data/raw` vers
+`/opt/data/raw`. L'orchestration de l'import API Mock et la réconciliation globale des deux
+sources restent couvertes par l'issue #15.
+
+Airflow permet de planifier les traitements, gérer leur ordre d'exécution, suivre leur état et remonter les erreurs. Il ne remplace pas la logique ETL Python existante : les scripts actuels restent responsables de l'extraction, de la validation, de la transformation et du chargement. `etl/airflow/dags/ml_train.py`, `ml_score.py` et `alertes.py` et `historical_import.py` montrent le patron retenu (des `BashOperator` qui invoquent le script tel quel, dans l'environnement `uv` que l'image embarque pour lui).
 
 Le pipeline Data servira ensuite à préparer les données nécessaires au modèle de Machine Learning.

etl/airflow/dags/historical_import.py

@@ -0,0 +1,45 @@
+"""DAG d'import du dataset historique EnerVision (issue #119).
+
+Orchestre le pipeline existant `app.etl.historical_import` sans dupliquer sa logique ETL.
+Le dataset historique sert à initialiser l'environnement : le DAG reste donc manuel.
+
+Le backend est exécuté dans l'environnement `/opt/backend` embarqué dans l'image Airflow,
+sur le même patron que le DAG `alertes` (ADR 0008).
+"""
+
+from __future__ import annotations
+
+from datetime import datetime, timedelta
+
+from airflow.models.dag import DAG
+from airflow.operators.bash import BashOperator
+
+COMMANDE_BACKEND = "cd /opt/backend && env -u VIRTUAL_ENV uv run --no-sync python -m"
+
+CSV_PATH = "/opt/data/raw/all_sites_combined.csv"
+METADATA_PATH = "/opt/data/raw/dataset_metadata.json"
+SOURCE_TIMEZONE = "UTC"
+BATCH_SIZE = 1000
+
+with DAG(
+    dag_id="historical_import",
+    description="Importe le dataset historique CSV/JSON dans dataset, site et reading.",
+    schedule=None,
+    start_date=datetime(2026, 1, 1),
+    catchup=False,
+    max_active_runs=1,
+    tags=["etl", "historical"],
+) as dag:
+    BashOperator(
+        task_id="import_historical",
+        bash_command=(
+            f"{COMMANDE_BACKEND} app.etl.historical_import "
+            f"--csv {CSV_PATH} "
+            f"--metadata {METADATA_PATH} "
+            "--source-timezone UTC "
+            "--batch-size 1000"
+        ),
+        retries=1,
+        retry_delay=timedelta(minutes=2),
+        execution_timeout=timedelta(minutes=30),
+    )

etl/airflow/tests/test_dags.py

@@ -10,12 +10,13 @@ from airflow.models.dagbag import DagBag
 
 DAGS_FOLDER = Path(__file__).resolve().parent.parent / "dags"
 
-DAG_IDS = ["ml_train", "ml_score", "alertes"]
+DAG_IDS = ["ml_train", "ml_score", "alertes", "historical_import"]
 TACHES = [
     ("ml_train", "train"),
     ("ml_score", "score"),
     ("alertes", "detection"),
     ("alertes", "recommandations"),
+    ("historical_import", "import_historical"),
 ]
 
 
@@ -47,6 +48,10 @@ def test_alertes_runs_after_the_hourly_scoring(dagbag: DagBag) -> None:
     assert dagbag.dags["alertes"].timetable.summary == "15 * * * *"
 
 
+def test_historical_import_has_no_schedule(dagbag: DagBag) -> None:
+    assert dagbag.dags["historical_import"].timetable.summary == "None"
+
+
 def test_ml_train_task_calls_the_training_module(dagbag: DagBag) -> None:
     tache = dagbag.dags["ml_train"].get_task("train")
     assert "enervision_ml.train" in tache.bash_command
@@ -67,12 +72,29 @@ def test_alertes_recommendation_task_calls_the_backend_cli(dagbag: DagBag) -> No
     assert "app.cli generate-recommendations" in tache.bash_command
 
 
+def test_historical_import_calls_the_existing_backend_module(dagbag: DagBag) -> None:
+    tache = dagbag.dags["historical_import"].get_task("import_historical")
+    assert "app.etl.historical_import" in tache.bash_command
+
+
+def test_historical_import_uses_the_expected_source_files(dagbag: DagBag) -> None:
+    commande = dagbag.dags["historical_import"].get_task("import_historical").bash_command
+
+    assert "--csv /opt/data/raw/all_sites_combined.csv" in commande
+    assert "--metadata /opt/data/raw/dataset_metadata.json" in commande
+
+
 @pytest.mark.parametrize("task_id", ["detection", "recommandations"])
 def test_alertes_tasks_run_in_the_backend_environment(dagbag: DagBag, task_id: str) -> None:
     # Le backend a son propre venv dans l'image, distinct de celui de ml/ (ADR 0008).
     assert "/opt/backend" in dagbag.dags["alertes"].get_task(task_id).bash_command
 
 
+def test_historical_import_runs_in_the_backend_environment(dagbag: DagBag) -> None:
+    commande = dagbag.dags["historical_import"].get_task("import_historical").bash_command
+    assert "/opt/backend" in commande
+
+
 def test_alertes_generates_recommendations_after_detecting(dagbag: DagBag) -> None:
     # `recommendation.alert_id` est une cle etrangere `NOT NULL` : la generation n'a rien a lire
     # tant que la detection n'a pas ecrit.
@@ -133,6 +155,10 @@ def test_alertes_retries_after_a_transient_failure(dagbag: DagBag, task_id: str)
     assert dagbag.dags["alertes"].get_task(task_id).retries >= 1
 
 
+def test_historical_import_retries_after_a_transient_failure(dagbag: DagBag) -> None:
+    assert dagbag.dags["historical_import"].get_task("import_historical").retries >= 1
+
+
 @pytest.mark.parametrize(("dag_id", "task_id"), TACHES)
 def test_tasks_never_resync_the_baked_environment(
     dagbag: DagBag, dag_id: str, task_id: str