String funken, die Tausendste.

/* Generic ESP8266 Modul

   aus BasicHTTPClient.ino

   Created on: 27.03.2024

   liest den Status aus Shelly 3EM, filtert nach "POWER",ermittelt den Strom eines Moduls,

   schaltet die notwendige/zulässige Anzahl Module zu oder ab,

   und funkt das Ergebnis an einen ESP01 zur Anzeige am Monitor.

*/

#include <ESP8266WiFi.h>

#include <ESP8266WiFiMulti.h>

#include <ESP8266HTTPClient.h>

#include <WiFiClient.h>

#include <espnow.h>

ESP8266WiFiMulti WiFiMulti;

// REPLACE WITH RECEIVER MAC Address (ESP01:E1)

//uint8_t broadcastAddress[] = { 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF };

//uint8_t broadcastAddress[] = { 0xDC, 0x4F, 0x22, 0x26, 0x28, 0xA1 };//E2

//uint8_t broadcastAddress[] = { 0xC8, 0x2B, 0x96, 0x20, 0x85, 0x33 };//E5

uint8_t broadcastAddress[] = { 0x48, 0x3F, 0xDA, 0x4A, 0x27, 0x27 };  //Eb

//********

//01 11 21 22

String Verteil[11] = { "0000", "1000", "0100", "0010", "0001", "0110", "1110", "0011", "1011", "0111", "1111" };

//  00      10      11      21      22      23      33      34      44      54      55

//   0       1       1       2       2       3       3       4       4       5       5

//********

// Structure example to send data

// Must match the receiver structure

typedef struct struct_message 

{

  String d;

} struct_message;

struct_message myData;  //Create a struct_message called myData

String payload = "";

String x1;

String Ausgabe;

String Strom = "";

int Summe;

int Schwelle;

int Laststufe = 0;

int Limit;

float Ampere;

int s;

String inputString;

//*******************************

void setup() 

{

  pinMode(12, OUTPUT);

  pinMode(13, OUTPUT);

  pinMode(14, OUTPUT);

  pinMode(16, OUTPUT);

  WiFi.mode(WIFI_STA);

  WiFiMulti.addAP("shellyem3-3494547B8D61", "");

  Serial.begin(115200);  // Init Serial Monitor

  if (esp_now_init() != 0)  // Init ESP-NOW

  {Serial.println("Error initializing ESP-NOW"); return;}

  esp_now_set_self_role(ESP_NOW_ROLE_CONTROLLER);                      // Once ESPNow is successfully Init,

  esp_now_register_send_cb(OnDataSent);                                //  we will register for Send CB

                                                                       //toget the status of Trasnmitted packet

  esp_now_add_peer(broadcastAddress, ESP_NOW_ROLE_SLAVE, 1, NULL, 0);  // Register peer

}

//*******************************

void loop() {

  if ((WiFiMulti.run() == WL_CONNECTED)) {

    WiFiClient client;

    HTTPClient http;

    if (http.begin(client, "http://192.168.33.1/status")) {

      int httpCode = http.GET();  // start connection and send HTTP header

      if (httpCode > 0) {

        if (httpCode == HTTP_CODE_OK || httpCode == HTTP_CODE_MOVED_PERMANENTLY) {

          String payload = http.getString();

          Summe = 0;

          Ausgabe = "";

          for (s = 400; s < 750; s++)  // zwischen Stelle 400 und 750 stehen die Werte für die 3 Phasen

          {

            String A = payload.substring(s, s + 5);

            if (A == "power") {

              s = s + 7;

              //**************************

              x1 = payload.substring(s, s + 10);

              Ausgabe += "   ";

              Ausgabe += x1.toInt();

              Summe = Summe + x1.toInt();

              s = s + 10;

              //**************************

            }

          }

          Auswertung();

          Ausgabe = Verteil[Laststufe] + " " + Strom + " " + Ampere + " " + Limit + "       " + Summe + " " + Schwelle + Ausgabe;

          //myData.d = Ausgabe;

          //strcpy(myData.d,  Ausgabe);    // Set values to send

           //strcpy(myData.d, (char*) &Ausgabe);

          Serial.println(Ausgabe);

          esp_now_send(broadcastAddress, (uint8_t *)&Ausgabe, sizeof(Ausgabe));

          delay(1000);

        }

      }

    }

  }

}

//***************************************

void Auswertung() {

  Strom = analogRead(A0);

  Ampere = ((Strom.toInt() - 512) / 512.000 * 60);  // ADC-Ausgabe umgerechnet in Ampere

  if (Ampere < .01) { Ampere = .01; }

  Limit = 2 * 16 / Ampere;

  if (Limit > 10) { Limit = 10; }

  Schwelle = (Schwelle * 3 + Summe) / 4;

  if (Schwelle <= 0 and Laststufe > 0) { Laststufe -= 1; }

  if (Schwelle >= 200 and Laststufe < 10) { Laststufe += 1; }

  if (Laststufe > Limit) { Laststufe = Limit; }

  //Schalten: (LOW: MODUL abgeklemmt, HIGH: MODUL zugeschaltet)

  if (Verteil[Laststufe].substring(0, 1) == "0") { digitalWrite(12, LOW); }

  if (Verteil[Laststufe].substring(1, 2) == "0") { digitalWrite(13, LOW); }

  if (Verteil[Laststufe].substring(2, 3) == "0") { digitalWrite(14, LOW); }

  if (Verteil[Laststufe].substring(3, 4) == "0") { digitalWrite(16, LOW); }

  if (Verteil[Laststufe].substring(0, 1) != "0") { digitalWrite(12, HIGH); }

  if (Verteil[Laststufe].substring(1, 2) != "0") { digitalWrite(13, HIGH); }

  if (Verteil[Laststufe].substring(2, 3) != "0") { digitalWrite(14, HIGH); }

  if (Verteil[Laststufe].substring(3, 4) != "0") { digitalWrite(16, HIGH); }

}

//*************************************

void OnDataSent(uint8_t *mac_addr, uint8_t sendStatus)  // Callback when data is sent

{

  if (sendStatus == 0) 

  { 

    Serial.println("Last Packet Send Status: Delivery success");

  } 

  else                 

  {

    Serial.println("Last Packet Send Status: Delivery fail");

  }

}