@ -55,6 +55,11 @@ float solarProduction = 0.0; // Production solaire en Watts
float powerConsumption = 0.0 ; // Consommation électrique en Watts
float powerConsumption = 0.0 ; // Consommation électrique en Watts
int heaterPower = 0 ; // Puissance de chauffe du chauffe-eau en % (0-100)
int heaterPower = 0 ; // Puissance de chauffe du chauffe-eau en % (0-100)
float waterTemperature = 0.0 ; // Température de l'eau du chauffe-eau en °C
float waterTemperature = 0.0 ; // Température de l'eau du chauffe-eau en °C
// Flag pour l'état de la connexion Enphase
bool enphaseConnectionError = false ;
// Configuration GPIO
# define HEATER_GPIO 12 // GPIO12 pour contrôle chauffe-eau
// Configuration GPIO
// Configuration GPIO
# define HEATER_GPIO 12 // GPIO12 pour contrôle chauffe-eau
# define HEATER_GPIO 12 // GPIO12 pour contrôle chauffe-eau
@ -63,6 +68,9 @@ float waterTemperature = 0.0; // Température de l'eau du chauffe-eau en °C
bool otaRebootPending = false ; bool otaRebootPending = false ;
unsigned long otaRebootTime = 0 ; unsigned long otaRebootTime = 0 ;
// Variable pour le mode JOUR - mémoriser si la température max a été atteinte aujourd'hui
bool maxTempReachedToday = false ;
// Variables pour la gestion PWM avec timer (période 1s)
// Variables pour la gestion PWM avec timer (période 1s)
const unsigned long PWM_PERIOD = 1000 ; // Période de 1 seconde en ms
const unsigned long PWM_PERIOD = 1000 ; // Période de 1 seconde en ms
volatile unsigned long pwmCycleCount = 0 ; // Compteur de cycles PWM
volatile unsigned long pwmCycleCount = 0 ; // Compteur de cycles PWM
@ -409,50 +417,38 @@ void IRAM_ATTR onTimerISR() {
void fetchEnphaseData ( ) { void fetchEnphaseData ( ) {
if ( enphaseGatewayIP . length ( ) = = 0 | | enphaseToken . length ( ) = = 0 ) { if ( enphaseGatewayIP . length ( ) = = 0 | | enphaseToken . length ( ) = = 0 ) {
Serial . println ( " Configuration Enphase manquante " ) ; Serial . println ( " Configuration Enphase manquante " ) ;
enphaseConnectionError = true ;
return ; return ;
} }
WiFiClientSecure client ; WiFiClientSecure client ;
client . setInsecure ( ) ; // Ignorer la vérification du certificat SSL
client . setInsecure ( ) ; // Ignorer la vérification du certificat SSL
HTTPClient http ; HTTPClient http ;
String url = " https:// " + enphaseGatewayIP + " /ivp/meters/reports/consumption " ; String url = " https:// " + enphaseGatewayIP + " /ivp/meters/reports/consumption " ;
http . begin ( client , url ) ; http . begin ( client , url ) ;
http . addHeader ( " Accept " , " application/json " ) ; http . addHeader ( " Accept " , " application/json " ) ;
http . addHeader ( " Authorization " , " Bearer " + enphaseToken ) ; http . addHeader ( " Authorization " , " Bearer " + enphaseToken ) ;
http . setFollowRedirects ( HTTPC_STRICT_FOLLOW_REDIRECTS ) ; // Suivre les redirections
http . setFollowRedirects ( HTTPC_STRICT_FOLLOW_REDIRECTS ) ; // Suivre les redirections
int httpCode = http . GET ( ) ; int httpCode = http . GET ( ) ;
if ( httpCode = = HTTP_CODE_OK ) { if ( httpCode = = HTTP_CODE_OK ) {
String payload = http . getString ( ) ; String payload = http . getString ( ) ;
JsonDocument doc ; JsonDocument doc ;
DeserializationError error = deserializeJson ( doc , payload ) ; DeserializationError error = deserializeJson ( doc , payload ) ;
if ( ! error & & doc . is < JsonArray > ( ) & & doc . size ( ) > = 2 ) { if ( ! error & & doc . is < JsonArray > ( ) & & doc . size ( ) > = 2 ) {
// Selon le code Python:
// json[0]['cumulative']['currW'] = total (consommation totale)
// json[1]['cumulative']['currW'] = net (réseau Enedis)
// panneaux = total - net (production solaire)
float total = doc [ 0 ] [ " cumulative " ] [ " currW " ] . as < float > ( ) ; float total = doc [ 0 ] [ " cumulative " ] [ " currW " ] . as < float > ( ) ;
float net = doc [ 1 ] [ " cumulative " ] [ " currW " ] . as < float > ( ) ; float net = doc [ 1 ] [ " cumulative " ] [ " currW " ] . as < float > ( ) ;
solarProduction = round ( total - net ) ; // Production des panneaux arrondie
solarProduction = round ( total - net ) ; // Production des panneaux arrondie
powerConsumption = round ( total ) ; // Consommation totale arrondie
powerConsumption = round ( total ) ; // Consommation totale arrondie
Serial . printf ( " Enphase - Total: %.1fW, Panneaux: %.1fW, Net: %.1fW \n " , Serial . printf ( " Enphase - Total: %.1fW, Panneaux: %.1fW, Net: %.1fW \n " ,
total , solarProduction , net ) ; total , solarProduction , net ) ;
enphaseConnectionError = false ;
} else { } else {
Serial . println ( " Erreur parsing JSON Enphase " ) ; Serial . println ( " Erreur parsing JSON Enphase " ) ;
enphaseConnectionError = true ;
} }
} else { } else {
Serial . printf ( " Erreur HTTP Enphase: %d \n " , httpCode ) ; Serial . printf ( " Erreur HTTP Enphase: %d \n " , httpCode ) ;
enphaseConnectionError = true ;
} }
http . end ( ) ; http . end ( ) ;
} }
@ -482,6 +478,23 @@ void calculateHeaterPower() {
isNightPeriod = ( currentHour > = nightStartHour | | currentHour < nightEndHour ) ; isNightPeriod = ( currentHour > = nightStartHour | | currentHour < nightEndHour ) ;
} }
// Vérifier si on est dans la période jour (entre lever et coucher du soleil)
bool isDayPeriod = false ;
if ( sunriseTime ! = " --:-- " & & sunsetTime ! = " --:-- " ) {
// Parser les heures de lever et coucher
int sunriseHour = sunriseTime . substring ( 0 , 2 ) . toInt ( ) ;
int sunriseMinute = sunriseTime . substring ( 3 , 5 ) . toInt ( ) ;
int sunsetHour = sunsetTime . substring ( 0 , 2 ) . toInt ( ) ;
int sunsetMinute = sunsetTime . substring ( 3 , 5 ) . toInt ( ) ;
// Convertir en minutes depuis minuit pour faciliter la comparaison
int currentTimeInMinutes = currentHour * 60 + currentMinute ;
int sunriseTimeInMinutes = sunriseHour * 60 + sunriseMinute ;
int sunsetTimeInMinutes = sunsetHour * 60 + sunsetMinute ;
isDayPeriod = ( currentTimeInMinutes > = sunriseTimeInMinutes & & currentTimeInMinutes < = sunsetTimeInMinutes ) ;
}
// Calculer l'excédent solaire et ajuster le pourcentage de chauffe
// Calculer l'excédent solaire et ajuster le pourcentage de chauffe
float solarExcess = solarProduction - powerConsumption ; float solarExcess = solarProduction - powerConsumption ;
int calculatedHeaterPowerJour , calculatedHeaterPowerSoleil = 0 ; int calculatedHeaterPowerJour , calculatedHeaterPowerSoleil = 0 ;
@ -511,40 +524,50 @@ void calculateHeaterPower() {
} }
} else if ( modeSOLEIL | | modeJOUR ) { } else if ( modeSOLEIL | | modeJOUR ) {
if ( modeJOUR ) { if ( modeJOUR & & isDayPeriod ) {
// Mode JOUR: calculer selon la formule
// Mode JOUR: calculer selon la formule (uniquement pendant la journée)
// calculatedHeaterPowerJour = 100 * CoeffJour * (max_water_temp - water_temperature) / (secondes_restantes)
// calculatedHeaterPowerJour = 100 * CoeffJour * (max_water_temp - water_temperature) / (secondes_restantes)
// Calculer le temps actuel en secondes depuis minuit
// Vérifier si la température max a déjà été atteinte aujourd'hui
int currentTimeInSeconds = currentHour * 3600 + currentMinute * 60 + currentSecond ; if ( waterTemperature > = maxWaterTemp ) {
maxTempReachedToday = true ;
// Calculer l'heure cible en secondes depuis minuit
}
int targetTimeInSeconds = targetMaxWaterTempHour * 3600 ;
// Calculer les secondes restantes
int secondsRemaining = targetTimeInSeconds - currentTimeInSeconds ;
// // Si on est après l'heure cible ou à l'heure cible, calculer jusqu'au lendemain
// if (secondsRemaining < 0) {
// secondsRemaining = 86400 + secondsRemaining; // 86400 = 24h en secondes
// }
float tempDiff = maxWaterTemp - waterTemperature ;
if ( tempDiff > 0 & & secondsRemaining > 0 ) { if ( maxTempReachedToday ) {
calculatedHeaterPowerJour = ( int ) ( 100.0 * coeffJour * tempDiff / secondsRemaining ) ; // La température max a été atteinte aujourd'hui, ne pas chauffer
if ( calculatedHeaterPowerJour > 100 ) calculatedHeaterPowerJour = 100 ;
if ( calculatedHeaterPowerJour < 0 ) calculatedHeaterPowerJour = 0 ;
// Afficher avec les heures et minutes pour la lisibilité
// int hoursDisplay = secondsRemaining / 3600;
// int minutesDisplay = (secondsRemaining % 3600) / 60;
// Serial.printf("[JOUR] TempDiff: %.1f°C, Temps restant: %dh%02dm, Chauffe: %d%%\n",
// tempDiff, hoursDisplay, minutesDisplay, calculatedHeaterPowerJour);
} else {
calculatedHeaterPowerJour = 0 ; calculatedHeaterPowerJour = 0 ;
// Serial.printf("[JOUR] Température atteinte ou dépassée: %.1f°C >= %.1f°C\n",
} else {
// waterTemperature, maxWaterTemp);
// Calculer le temps actuel en secondes depuis minuit
int currentTimeInSeconds = currentHour * 3600 + currentMinute * 60 + currentSecond ;
// Calculer l'heure cible en secondes depuis minuit
int targetTimeInSeconds = targetMaxWaterTempHour * 3600 ;
// Calculer les secondes restantes
int secondsRemaining = targetTimeInSeconds - currentTimeInSeconds ;
// // Si on est après l'heure cible ou à l'heure cible, calculer jusqu'au lendemain
// if (secondsRemaining < 0) {
// secondsRemaining = 86400 + secondsRemaining; // 86400 = 24h en secondes
// }
float tempDiff = maxWaterTemp - waterTemperature ;
if ( tempDiff > 0 & & secondsRemaining > 0 ) {
calculatedHeaterPowerJour = ( int ) ( 100.0 * coeffJour * tempDiff / secondsRemaining ) ;
if ( calculatedHeaterPowerJour > 100 ) calculatedHeaterPowerJour = 100 ;
if ( calculatedHeaterPowerJour < 0 ) calculatedHeaterPowerJour = 0 ;
// Afficher avec les heures et minutes pour la lisibilité
// int hoursDisplay = secondsRemaining / 3600;
// int minutesDisplay = (secondsRemaining % 3600) / 60;
// Serial.printf("[JOUR] TempDiff: %.1f°C, Temps restant: %dh%02dm, Chauffe: %d%%\n",
// tempDiff, hoursDisplay, minutesDisplay, calculatedHeaterPowerJour);
} else {
calculatedHeaterPowerJour = 0 ;
// Serial.printf("[JOUR] Température atteinte ou dépassée: %.1f°C >= %.1f°C\n",
// waterTemperature, maxWaterTemp);
}
} }
} }
@ -774,12 +797,17 @@ void setup() {
// API POST /api/settings
// API POST /api/settings
server . on ( " /api/settings " , HTTP_POST , server . on ( " /api/settings " , HTTP_POST ,
[ ] ( AsyncWebServerRequest * request ) { [ ] ( AsyncWebServerRequest * request ) {
Serial . println ( " [SETTINGS] POST /api/settings appelé " ) ;
// Handler appelé quand la requête est complète
// Handler appelé quand la requête est complète
if ( ! checkAuthentication ( request ) ) { if ( ! checkAuthentication ( request ) ) {
Serial . println ( " [SETTINGS] Authentification échouée " ) ;
request - > send ( 401 , " text/plain " , " Non autorisé " ) ; request - > send ( 401 , " text/plain " , " Non autorisé " ) ;
return ; return ;
} }
Serial . println ( " [SETTINGS] Authentification OK " ) ;
// Récupérer le body depuis _tempObject
// Récupérer le body depuis _tempObject
if ( request - > _tempObject = = NULL ) { if ( request - > _tempObject = = NULL ) {
Serial . println ( " [SETTINGS] Erreur: Pas de body reçu " ) ; Serial . println ( " [SETTINGS] Erreur: Pas de body reçu " ) ;
@ -852,16 +880,22 @@ void setup() {
if ( requestDoc [ " wifi " ] [ " ssid " ] & & requestDoc [ " wifi " ] [ " ssid " ] . as < String > ( ) . length ( ) > 0 ) { if ( requestDoc [ " wifi " ] [ " ssid " ] & & requestDoc [ " wifi " ] [ " ssid " ] . as < String > ( ) . length ( ) > 0 ) {
String newSSID = requestDoc [ " wifi " ] [ " ssid " ] . as < String > ( ) ; String newSSID = requestDoc [ " wifi " ] [ " ssid " ] . as < String > ( ) ;
configDoc [ " wifi " ] [ " ssid " ] = newSSID ; if ( newSSID ! = wifiSSID ) {
wifiSSID = newSSID ; configDoc [ " wifi " ] [ " ssid " ] = newSSID ;
wifiChanged = true ; wifiSSID = newSSID ;
wifiChanged = true ;
Serial . println ( " [SETTINGS] SSID modifié, redémarrage nécessaire " ) ;
}
} }
if ( requestDoc [ " wifi " ] [ " password " ] & & requestDoc [ " wifi " ] [ " password " ] . as < String > ( ) . length ( ) > 0 ) { if ( requestDoc [ " wifi " ] [ " password " ] & & requestDoc [ " wifi " ] [ " password " ] . as < String > ( ) . length ( ) > 0 ) {
String newWifiPass = requestDoc [ " wifi " ] [ " password " ] . as < String > ( ) ; String newWifiPass = requestDoc [ " wifi " ] [ " password " ] . as < String > ( ) ;
configDoc [ " wifi " ] [ " password " ] = newWifiPass ; if ( newWifiPass ! = wifiPassword ) {
wifiPassword = newWifiPass ; configDoc [ " wifi " ] [ " password " ] = newWifiPass ;
wifiChanged = true ; wifiPassword = newWifiPass ;
wifiChanged = true ;
Serial . println ( " [SETTINGS] Mot de passe WiFi modifié, redémarrage nécessaire " ) ;
}
} }
if ( requestDoc [ " wifi " ] [ " ap_password " ] & & requestDoc [ " wifi " ] [ " ap_password " ] . as < String > ( ) . length ( ) > 0 ) { if ( requestDoc [ " wifi " ] [ " ap_password " ] & & requestDoc [ " wifi " ] [ " ap_password " ] . as < String > ( ) . length ( ) > 0 ) {
@ -988,6 +1022,7 @@ void setup() {
JsonDocument responseDoc ; JsonDocument responseDoc ;
responseDoc [ " success " ] = true ; responseDoc [ " success " ] = true ;
responseDoc [ " restart " ] = wifiChanged ;
if ( wifiChanged ) { if ( wifiChanged ) {
responseDoc [ " message " ] = " Paramètres sauvegardés. Redémarrage pour appliquer les changements WiFi... " ; responseDoc [ " message " ] = " Paramètres sauvegardés. Redémarrage pour appliquer les changements WiFi... " ;
@ -1013,12 +1048,21 @@ void setup() {
if ( index = = 0 ) { if ( index = = 0 ) {
// Premier chunk: créer le buffer
// Premier chunk: créer le buffer
Serial . printf ( " [SETTINGS] Réception body: %d bytes total \n " , total ) ; Serial . printf ( " [SETTINGS] Réception body: %d bytes total \n " , total ) ;
if ( total > 8192 ) {
Serial . println ( " [SETTINGS] ERREUR: Body trop grand! " ) ;
return ;
}
request - > _tempObject = malloc ( total + 1 ) ; request - > _tempObject = malloc ( total + 1 ) ;
if ( request - > _tempObject = = NULL ) {
Serial . println ( " [SETTINGS] ERREUR: Échec allocation mémoire! " ) ;
return ;
}
} }
if ( request - > _tempObject ! = NULL ) { if ( request - > _tempObject ! = NULL ) {
// Copier ce chunk
// Copier ce chunk
memcpy ( ( uint8_t * ) request - > _tempObject + index , data , len ) ; memcpy ( ( uint8_t * ) request - > _tempObject + index , data , len ) ;
Serial . printf ( " [SETTINGS] Chunk reçu: index=%d len=%d total=%d \n " , index , len , total ) ;
if ( index + len = = total ) { if ( index + len = = total ) {
// Dernier chunk: terminer la chaîne
// Dernier chunk: terminer la chaîne
@ -1043,7 +1087,7 @@ void setup() {
doc [ " sunrise_time " ] = sunriseTime ; doc [ " sunrise_time " ] = sunriseTime ;
doc [ " sunset_time " ] = sunsetTime ; doc [ " sunset_time " ] = sunsetTime ;
doc [ " timestamp " ] = millis ( ) ; doc [ " timestamp " ] = millis ( ) ;
doc [ " enphase_connection_error " ] = enphaseConnectionError ;
String response ; String response ;
serializeJson ( doc , response ) ; serializeJson ( doc , response ) ;
request - > send ( 200 , " application/json " , response ) ; request - > send ( 200 , " application/json " , response ) ;
@ -1412,5 +1456,8 @@ void loop() {
if ( timeinfo . tm_mday ! = lastDay ) { if ( timeinfo . tm_mday ! = lastDay ) {
lastDay = timeinfo . tm_mday ; lastDay = timeinfo . tm_mday ;
calculateSunriseSunset ( ) ; calculateSunriseSunset ( ) ;
// Réinitialiser le flag de température max atteinte pour le nouveau jour
maxTempReachedToday = false ;
Serial . println ( " [JOUR] Nouveau jour - réinitialisation du flag température max " ) ;
} }
} }
