Plus d'accès aux données de la passerelle Enphase Envoy

Code :
void LectureEnphase() {

  // 1. Définition du filtre pour économiser la RAM

  StaticJsonDocument<2048> filter;

  filter[0]["activePower"] = true; // Production

  for(int i=0; i<3; i++) {

    filter[1]["channels"][i]["activePower"] = true;

    filter[1]["channels"][i]["apparentPower"] = true;

    filter[1]["channels"][i]["voltage"] = true;

    filter[1]["channels"][i]["current"] = true;

    filter[1]["channels"][i]["freq"] = true;

    filter[1]["channels"][i]["actEnergyDlvd"] = true;

    filter[1]["channels"][i]["actEnergyRcvd"] = true;

  }



  // 2. Préparation du client réseau

  WiFiClientSecure client;

  client.setInsecure();

  IPAddress ip( (RMSextIP >> 24) & 0xFF, (RMSextIP >> 16) & 0xFF, (RMSextIP >> 8) & 0xFF, RMSextIP & 0xFF );

  

  if (!client.connect(ip, 443)) {

    TelnetPrintln("Erreur connexion Envoy");

    return;

  }



  // 3. Envoi de la requête

  client.println("GET /ivp/meters/readings HTTP/1.1");

  client.println("Host: " + String(ip.toString()));

  client.println("Authorization: Bearer " + TokenEnphase);

  client.println("Connection: close");

  client.println();



  if (!client.find("\r\n\r\n")) {

    TelnetPrintln("Erreur headers");

    return;

  }



  // 4. Désérialisation

  DynamicJsonDocument doc(20000); 

  DeserializationError error = deserializeJson(doc, client, DeserializationOption::Filter(filter));

  client.stop();



  if (error) {

    TelnetPrintln("JSON ERR: " + String(error.c_str()));

    return;

  }



  // 5. Calcul des valeurs triphasées

  PactProd = doc[0]["activePower"] | 0.0f;

  

  float PactReseau = 0.0f;

  float PvaReseau = 0.0f;

  float Tension_Tmp = 0.0f;

  float Intensite_Tmp = 0.0f;

  double whDlvdTotal = 0.0;

  double whRcvdTotal = 0.0;



  if (doc[1].containsKey("channels")) {

    for(int i = 0; i < 3; i++) {

      PactReseau   += (float)(doc[1]["channels"][i]["activePower"] | 0.0f);

      PvaReseau    += (float)(doc[1]["channels"][i]["apparentPower"] | 0.0f);

      whDlvdTotal  += (double)(doc[1]["channels"][i]["actEnergyDlvd"] | 0.0);

      whRcvdTotal  += (double)(doc[1]["channels"][i]["actEnergyRcvd"] | 0.0);

      Tension_Tmp  += (float)(doc[1]["channels"][i]["voltage"] | 0.0f);

      Intensite_Tmp += (float)(doc[1]["channels"][i]["current"] | 0.0f);

    }

    

    PactConso_M   = (int)(PactReseau + PactProd);

    Tension_M     = Tension_Tmp / 3.0f;

    Intensite_M   = Intensite_Tmp;

    Frequence     = doc[1]["channels"][0]["freq"] | 50.0f;



    // 6. Correction du calcul de puissance avec signe (Logique demandée)

    // On suppose que PfloatMax est une macro ou fonction locale existante

    PactReseau = PfloatMax(PactReseau); 

    PvaReseau  = PfloatMax(PvaReseau);



    if (PactReseau < 0) {

      PuissanceS_M_inst = 0;

      PuissanceI_M_inst = int(-PactReseau);

      PVAS_M_inst = 0;

      PVAI_M_inst = int(PvaReseau);

    } else {

      PuissanceI_M_inst = 0;

      PuissanceS_M_inst = int(PactReseau);

      PVAI_M_inst = 0;

      PVAS_M_inst = int(PvaReseau);

    }

    Pva_valide = true;



    // 7. Calcul des deltas pour votre routeur

    static long LastwhDlvdCum = 0L;

    static long LastwhRcvdCum = 0L;

    

    long currentDlvd = (long)whDlvdTotal;

    long currentRcvd = (long)whRcvdTotal;



    if (LastwhDlvdCum != 0) {

       DeltaWhSoutire = currentDlvd - LastwhDlvdCum;

       DeltaWhInjecte = currentRcvd - LastwhRcvdCum;

    }

    

    LastwhDlvdCum = currentDlvd;

    LastwhRcvdCum = currentRcvd;

  }

}