Surveillance Intelligente des Espaces Confinés

// ═══════════════════════════════════════════════════════════════════════════
// USE CASE #02 : Surveillance Intelligente Espaces Confinés
// Objectif : Détecter conditions atmosphériques dangereuses temps réel
// Criticité : MAXIMALE - Risque asphyxie, intoxication, explosion
// Normes : OSHA 1910.146 | CNESST Art. 297-310 | CSA Z1006
// ═══════════════════════════════════════════════════════════════════════════

// 🎯 ÉTAPE 1 : IDENTIFICATION DES ESPACES CONFINÉS ACTIFS
MATCH (proj:Project {id: $projectId})
      -[:HAS_SPACE]->(cs:ConfinedSpace)
WHERE cs.status = 'active'
  AND cs.requiresPermit = true

// ─────────────────────────────────────────────────────────────────────────
// 📊 ÉTAPE 2 : ANALYSE ATMOSPHÉRIQUE TEMPS RÉEL (IoT)
// Paramètres critiques surveillés :
//   • O₂ (oxygène)        : 19.5% - 23.5% (OSHA range sécuritaire)
//   • CO (monoxyde)       : < 35 ppm (TWA 8h)
//   • H₂S (sulfure hydrog): < 10 ppm (ceiling limit)
//   • LEL (explosivité)   : < 10% (Lower Explosive Limit)
//   • CH₄ (méthane)       : < 5% volume
// ─────────────────────────────────────────────────────────────────────────
OPTIONAL MATCH (cs)-[:MONITORED_BY]->(sensor:Sensor)
               -[:READS]->(reading:Reading)
WHERE sensor.category IN ['atmospheric', 'gas_detector', 'oxygen_monitor']
  AND reading.timestamp >= datetime() - duration({minutes: $recentMinutes})  // Default: 15 min

// 🚨 Détection des conditions dangereuses
WITH cs, sensor,
     collect(reading) AS readings,
     
     // Compteurs d'alertes atmosphériques
     size([r IN collect(reading) 
          WHERE r.gasType = 'O2' AND (r.value < 19.5 OR r.value > 23.5)]) AS oxygenAlerts,
     
     size([r IN collect(reading) 
          WHERE r.gasType = 'CO' AND r.value > 35]) AS coAlerts,
     
     size([r IN collect(reading) 
          WHERE r.gasType = 'H2S' AND r.value > 10]) AS h2sAlerts,
     
     size([r IN collect(reading) 
          WHERE r.gasType = 'LEL' AND r.value > 10]) AS lelAlerts,
     
     // Agrégation totale des alertes atmosphériques
     size([r IN collect(reading) 
          WHERE (r.gasType = 'O2' AND (r.value < 19.5 OR r.value > 23.5))
             OR (r.gasType = 'CO' AND r.value > 35)
             OR (r.gasType = 'H2S' AND r.value > 10)
             OR (r.gasType = 'LEL' AND r.value > 10)]) AS totalAtmosAlerts

// ─────────────────────────────────────────────────────────────────────────
// 📋 ÉTAPE 3 : VÉRIFICATION PERMIS D'ENTRÉE EN ESPACE CONFINÉ
// Conformité : Permis valide + non expiré + autorisations à jour
// ─────────────────────────────────────────────────────────────────────────
OPTIONAL MATCH (cs)<-[:APPLIES_TO]-(permit:EntryPermit)
WHERE permit.type = 'confined_space_entry'
  AND permit.status = 'active'
  AND permit.expiryTime > datetime()

WITH cs, readings, oxygenAlerts, coAlerts, h2sAlerts, lelAlerts, totalAtmosAlerts,
     count(permit) AS validPermits,
     collect(permit) AS permits

// ─────────────────────────────────────────────────────────────────────────
// 👷 ÉTAPE 4 : DÉTECTION PRÉSENCE & LOCALISATION TRAVAILLEURS
// Tracking : RFID badges, GPS, systèmes d'accès (entry/exit logs)
// ─────────────────────────────────────────────────────────────────────────
OPTIONAL MATCH (cs)<-[:CURRENTLY_IN]-(worker:Worker)
WHERE worker.status = 'active'
  AND worker.lastSeen >= datetime() - duration({minutes: 10})  // Présence récente

// Vérification certifications confined space
OPTIONAL MATCH (worker)-[:HAS_CERTIFICATION]->(cert:Certification)
WHERE cert.type IN ['confined_space_entry', 'gas_detection', 'rescue', 'SCBA']
  AND cert.expiryDate > datetime()

WITH cs, readings, oxygenAlerts, coAlerts, h2sAlerts, lelAlerts, 
     totalAtmosAlerts, validPermits, permits,
     count(DISTINCT worker) AS workersInside,
     collect(DISTINCT worker) AS workerList,
     count(DISTINCT cert) AS certifiedCount

// ─────────────────────────────────────────────────────────────────────────
// 🛡️ ÉTAPE 5 : VÉRIFICATION ÉQUIPEMENTS VENTILATION & SECOURS
// Systèmes critiques : Ventilation forcée, détecteurs portatifs, SCBA
// ─────────────────────────────────────────────────────────────────────────
OPTIONAL MATCH (cs)-[:HAS_VENTILATION]->(vent:Asset)
WHERE vent.category IN ['ventilation', 'air_mover', 'blower']

OPTIONAL MATCH (cs)-[:ASSIGNED_RESCUE]->(rescue:RescueTeam)
WHERE rescue.status = 'available'
  AND rescue.responseTime <= $maxResponseMinutes  // Default: 4 minutes (OSHA)

WITH cs, readings, oxygenAlerts, coAlerts, h2sAlerts, lelAlerts,
     totalAtmosAlerts, validPermits, workersInside, workerList, certifiedCount,
     count(vent) AS ventilationUnits,
     size([v IN collect(vent) WHERE v.status = 'operational']) AS operationalVent,
     count(rescue) AS rescueTeamsAvailable

// ─────────────────────────────────────────────────────────────────────────
// 🚨 ÉTAPE 6 : CALCUL DU SCORE DE CRITICITÉ MULTI-FACTORIEL
// Algorithme pondéré basé sur :
//   • Alertes atmosphériques    : × 5.0  (danger mortel immédiat)
//   • Travailleurs exposés       : × 3.0  (vies en danger)
//   • Défaillance ventilation    : × 4.0  (aggravation rapide)
//   • Absence permis valide      : × 2.0  (non-conformité critique)
//   • Absence équipe secours     : × 2.5  (capacité rescue compromise)
// ─────────────────────────────────────────────────────────────────────────
WITH cs, readings, oxygenAlerts, coAlerts, h2sAlerts, lelAlerts,
     totalAtmosAlerts, validPermits, workersInside, workerList,
     ventilationUnits, operationalVent, rescueTeamsAvailable,
     
     // 🧮 Calcul score de criticité
     (totalAtmosAlerts * 5.0) +
     (workersInside * 3.0) +
     (CASE WHEN operationalVent = 0 THEN 4.0 ELSE 0 END) +
     (CASE WHEN validPermits = 0 THEN 2.0 ELSE 0 END) +
     (CASE WHEN rescueTeamsAvailable = 0 THEN 2.5 ELSE 0 END) 
     AS criticalityScore

WHERE criticalityScore >= $minCriticalityThreshold  // Default: 5.0

// ─────────────────────────────────────────────────────────────────────────
// 🎯 ÉTAPE 7 : STRUCTURATION ET PRIORISATION DES RÉSULTATS
// Classification urgence : IMMÉDIATE (≥20) | CRITIQUE (≥12) | ÉLEVÉE (≥6)
// ─────────────────────────────────────────────────────────────────────────
RETURN
  // 📍 Identification espace confiné
  cs.id AS spaceId,
  cs.name AS spaceName,
  cs.type AS spaceType,  // tank, silo, sewer, vault, etc.
  cs.volume AS volumeCubicMeters,
  cs.location AS coordinates,
  
  // 🚨 Score et classification urgence
  round(criticalityScore, 2) AS criticalityScore,
  CASE
    WHEN criticalityScore >= 20 THEN 'IMMÉDIATE'    // 🔴 Évacuation NOW
    WHEN criticalityScore >= 12 THEN 'CRITIQUE'     // 🟠 Surveillance max
    WHEN criticalityScore >= 6 THEN 'ÉLEVÉE'       // 🟡 Attention soutenue
    ELSE 'ATTENTION'                          // 🔵 Monitoring standard
  END AS urgencyLevel,
  
  // 📊 Détails alertes atmosphériques
  totalAtmosAlerts,
  oxygenAlerts AS oxygenDeficiency,
  coAlerts AS carbonMonoxideAlerts,
  h2sAlerts AS hydrogenSulfideAlerts,
  lelAlerts AS explosiveAtmosphereAlerts,
  
  // 👷 Personnel exposé
  workersInside,
  [w IN workerList | {
    id: w.id, 
    name: w.name, 
    entryTime: w.entryTimestamp,
    durationInside: duration.between(w.entryTimestamp, datetime()).minutes
  }] AS workersAtRisk,
  
  // 📋 Conformité permis
  validPermits,
  CASE WHEN validPermits > 0 THEN true ELSE false END AS hasValidPermit,
  
  // 🛡️ État systèmes protection
  ventilationUnits,
  operationalVent,
  CASE WHEN operationalVent > 0 THEN true ELSE false END AS ventilationOperational,
  rescueTeamsAvailable,
  
  // ⏰ Horodatage analyse
  datetime() AS analysisTimestamp,
  
  // 🎯 Actions recommandées immédiates
  CASE
    WHEN criticalityScore >= 20 THEN ['ÉVACUATION IMMÉDIATE', 'ALERTER RESCUE TEAM', 'BLOQUER ACCÈS']
    WHEN criticalityScore >= 12 THEN ['SURVEILLANCE CONTINUE', 'PRÉPA ÉVACUATION', 'VENTILATION MAX']
    WHEN criticalityScore >= 6 THEN ['INTENSIFIER MONITORING', 'VÉRIFIER ÉQUIPEMENTS', 'BRIEFING SÉCURITÉ']
    ELSE ['CONTINUER SURVEILLANCE', 'LOGS ATMOSPHÉRIQUES']
  END AS recommendedActions

// 🎯 Tri par criticité décroissante
ORDER BY criticalityScore DESC, workersInside DESC
LIMIT $maxResults

// ═══════════════════════════════════════════════════════════════════════════
// 📌 RÉSULTAT : Espaces confinés critiques nécessitant intervention immédiate
// 🔄 FRÉQUENCE : Exécution en temps réel (1-2 minutes) ou déclenchée par IoT
// 🤖 AGENTS CIBLES : AtmosphereAI, RescueAI, PermitAI, EmergencyAI
// 📡 INTÉGRATIONS : Systèmes d'alarme, protocoles évacuation, dispatch secours
// ═══════════════════════════════════════════════════════════════════════════