Skip to content
  • Aktuell
  • Tags
  • 0 Ungelesen 0
  • Kategorien
  • Unreplied
  • Beliebt
  • GitHub
  • Docu
  • Hilfe
Skins
  • Light
  • Brite
  • Cerulean
  • Cosmo
  • Flatly
  • Journal
  • Litera
  • Lumen
  • Lux
  • Materia
  • Minty
  • Morph
  • Pulse
  • Sandstone
  • Simplex
  • Sketchy
  • Spacelab
  • United
  • Yeti
  • Zephyr
  • Dark
  • Cyborg
  • Darkly
  • Quartz
  • Slate
  • Solar
  • Superhero
  • Vapor

  • Standard: (Kein Skin)
  • Kein Skin
Einklappen
ioBroker Logo
  1. ioBroker Community Home
  2. Deutsch
  3. Praktische Anwendungen (Showcase)
  4. [Tutorial] PZEM-004T 3 Phasen Überwachung

NEWS

  • UPDATE 31.10.: Amazon Alexa - ioBroker Skill läuft aus ?
    apollon77A
    apollon77
    48
    3
    8.1k

  • Monatsrückblick – September 2025
    BluefoxB
    Bluefox
    13
    1
    1.8k

  • Neues Video "KI im Smart Home" - ioBroker plus n8n
    BluefoxB
    Bluefox
    15
    1
    2.1k

[Tutorial] PZEM-004T 3 Phasen Überwachung

Geplant Angeheftet Gesperrt Verschoben Praktische Anwendungen (Showcase)
pzem-004t-v30monitoringüberwachungmessunghow-totutorial
283 Beiträge 37 Kommentatoren 79.0k Aufrufe 41 Watching
  • Älteste zuerst
  • Neuste zuerst
  • Meiste Stimmen
Antworten
  • In einem neuen Thema antworten
Anmelden zum Antworten
Dieses Thema wurde gelöscht. Nur Nutzer mit entsprechenden Rechten können es sehen.
  • B backfisch88

    @OpenSourceNomad
    Ja finde das auch seltsam. Aber wenn’s so funktioniert ist es auch ok. 2,5 Tage schon am Stück

    HomeZeckeH Offline
    HomeZeckeH Offline
    HomeZecke
    schrieb am zuletzt editiert von
    #99

    Hallo,

    mal ein kleines Update meiner Firmware.

    Wifi optimiert und hostname auf "PZEM-Powermeter" gesetzt. Updates dann über: "http://pzem-powermeter.local/update"
    Zählerstand wird jetzt erhalten nach einem reset oder Wlan bzw Strom Ausfall.
    Neuer Datenpunkt "Befehl". Dort können Steuerbefehle an den Wemos gesendet werden. Im Moment sind das:
    "sys-reset" : Wemos resetten
    "pzem-reset" : resetten der PZEM Zählerstände
    Der Datenpunkt "PZEM-Reset" fällt damit weg.
    MQTT user und passwort hinzugefügt. Wenn nicht benötigt einfach leer lassen. (Danke @spaceduck)

    Alles weitere bitte weiter oben nachlesen

    //####################################################################################
    //####################################################################################
    //
    //    PZEM Energiemessgeräterfassung mit WEMOS von HomeZecke     v1.2 stand 04.08.2020
    //    --------------------------------------------------------------------------
    //     v 1.0      Testphase first release 			     -05.03.2020
    //
    //     v 1.1      Zählerstartwert kann festgelegt werden 	     -30.03.2020
    //
    //     v 1.2      Wifi optimiert, hostname auf "PZEM-Powermeter"     -04.08.2020
    //                gesetzt. Updates jetzt über:
    //                "http://pzem-powermeter.local/update"
    //                Zählerstand wird jetzt erhalten nach     
    //                reset oder Wlan Ausfall.
    //                Neuer Datenpunkt "Befehl". Dort können Steuer-
    //                befehle an den Wemos gesendet werden:
    //                "sys-reset"  : Wemos resetten
    //                "pzem-reset" : resetten der PZEM Zählerstände
    //                Der Datenpunkt "PZEM-Reset" fällt damit weg.
    //                MQTT user und passwort -Abfrage hinzugef. Wenn nicht
    //                benötigt leer lassen. (Danke @spaceduck)
    //                
    //				 
    //     ToDo:      Online Config für Wlan / MQTT usw. hinzuf.
    //
    //     	
    //			  
    //####################################################################################
    //####################################################################################
    
    #include <Arduino.h>
    #include <EEPROM.h>
    #include <ESP8266WiFi.h>
    #include <WiFiClient.h>
    #include <ESP8266WebServer.h>
    #include <ESP8266mDNS.h>
    #include <ESP8266HTTPUpdateServer.h>
    #include <Ticker.h>
    #include <PubSubClient.h>
    #include <PZEM004Tv30.h>
    
    
    //Hier die persönlichen Daten eintragen!
    //---------------------------------------------
    const char* SSID = "WLAN-SSID";
    const char* PSK =  "PASSWORT";
    const char* MQTTserver = "192.168.0.0";
    const uint16_t port = 1883;
    const char* mqttUser = "";
    const char* mqttPassword = "";
    //---------------------------------------------
    const char* Hostname = "PZEM-Powermeter";
    const int STATUS_LED = 13;  //D7 (Wemos D1 Mini)
    
    typedef struct //Datenstruktur für Eprom config
      {
        float counter_startwert;
        float diff_verbrauch;
      } configdata_typ;
    
    configdata_typ config; //config variable deklarieren 
    
    
    float start_verbrauch = 0;
    float diff_verbrauch = 0;
    float old_spannung_pzem1;
    float old_frequenz_pzem1;
    float old_stromstaerke_pzem1;
    float old_verbrauch_pzem1;
    float old_leistung_pzem1;
    float old_pf_pzem1;
    float old_spannung_pzem2;
    float old_frequenz_pzem2;
    float old_stromstaerke_pzem2;
    float old_verbrauch_pzem2;
    float old_leistung_pzem2;
    float old_pf_pzem2;
    float old_spannung_pzem3;
    float old_frequenz_pzem3;
    float old_stromstaerke_pzem3;
    float old_verbrauch_pzem3;
    float old_leistung_pzem3;
    float old_pf_pzem3;
    float old_spannung_gesamt;
    float old_stromstaerke_gesamt;
    float old_leistung_gesamt;
    float old_verbrauch_gesamt;
    float old_frequenz_gesamt;
    float old_pf_gesamt;
    float old_PZEM_verbrauch;
    
    
    //---functions / callbacks
    void MQTTcallback(char* topic, byte* payload, unsigned int length);
    void pzem_reset();
    void pzem_read();
    void set_counter(float counterStart);
    
    
    //-Klassen definieren
    ESP8266WebServer httpServer(80);
    ESP8266HTTPUpdateServer httpUpdater;
    
    WiFiClient MY_NETClient_1;
    PubSubClient MQTTClient(MY_NETClient_1);
    
    Ticker myTimer1(pzem_read,5000);
    
    PZEM004Tv30 pzem_1(5, 4);    //D1,D2 Grün / Orange Wemos D1 Mini L1
    PZEM004Tv30 pzem_2(2, 0);    //D4,D3                             L2
    PZEM004Tv30 pzem_3(14, 12);  //D5,D6                             L3 
    
    
    
    // #####################################################################################################
    // #####################################################################################################
    // Funktionen
    // #####################################################################################################
    // #####################################################################################################
    
    
    
    //=======================================================================================================================
    //Config ins EPROM speichern
    //=======================================================================================================================
    void saveConfig() {
     
      EEPROM.begin(4095);
      EEPROM.put( 0, config );
      delay(200);
      EEPROM.commit();                    
      EEPROM.end();  
    
    }
    
    
    //=======================================================================================================================
    //Config vom EPROM laden
    //=======================================================================================================================
    void loadConfig() {
     
      EEPROM.begin(4095);
      EEPROM.get( 0, config );
      EEPROM.end();
    }
    
    
    //=======================================================================================================================
    //MQTT CallBack
    //=======================================================================================================================
    void MQTTcallback(char* topic, byte* payload, unsigned int length)
    {
     
      char my_payload[length+1];  // nen string machen, länge eins mehr wegen nullterminierung
      float counter_start;
      
      Serial.print(topic);
      Serial.print(" : ");
      
    
      // Topic Verbrauchs-Startwert------------------------------------------------------------------------------
      if (strcmp(topic,"Energie/Verbrauchs-Startwert") == 0 )
          {
            
              for (unsigned int i = 0; i < length; i++)  // jedes einzelne byte in einen buchstaben umwandeln
                {              
                   my_payload[i] = (char)payload[i];   // (char)100 wäre zb ein "d"
                };
    
              my_payload[length] = '\0';              // nullterminierung
              Serial.println(my_payload);
              counter_start = atof(my_payload);    // nen float aus der payload machen
              
              if (counter_start != start_verbrauch)
                {
                  start_verbrauch = counter_start;
                  config.counter_startwert = start_verbrauch;
                  saveConfig();
                  set_counter(counter_start); // func set_couter zum setzen aufrufen
                }
    
             
    
            
          } 
    
    
    // Topic Befehl------------------------------------------------------------------------------
      if (strcmp(topic,"Energie/Befehl") == 0 )
          {
            
              for (unsigned int i = 0; i < length; i++)  // jedes einzelne byte in einen buchstaben umwandeln
                {              
                   my_payload[i] = (char)payload[i];   // (char)100 wäre zb ein "d"
                };
    
              my_payload[length] = '\0';              // nullterminierung
              Serial.println(my_payload);
              counter_start = atof(my_payload);    // nen float aus der payload machen
              
              if (strcmp(my_payload,"pzem-reset") == 0)
                {
                    pzem_reset();                //Energie an den PZEM's resetten
                }
    
              if (strcmp(my_payload,"sys-reset") == 0)
                {
                   MQTTClient.publish ( "Energie/Befehl", "");
                   delay(1000);
                   ESP.restart();                //Wemos resetten
                }
    
    
                   
          MQTTClient.publish ( "Energie/Befehl", "");
             
    
            
          }                 
    
    }
    
    //=======================================================================================================================
    //WLan -Verbindung aufbauen
    //=======================================================================================================================
    void initWiFi()
    {
        static int wifiRetryCounter;
    
        Serial.println("");
        Serial.print("Wifi connect...");
        WiFi.persistent(false);
        WiFi.begin(SSID, PSK);
        WiFi.hostname(Hostname);
        WiFi.begin(SSID, PSK);
    
        while (WiFi.status() != WL_CONNECTED)
          {
            ++wifiRetryCounter;
            if (wifiRetryCounter > 90)
              {
                ESP.restart();
              }
            digitalWrite(STATUS_LED,!digitalRead(STATUS_LED));
            Serial.print(".");   
            delay(700);
          };
    
        Serial.print("Verbunden!");
        WiFi.mode(WIFI_STA);    
        wifiRetryCounter = 0;
    
    }
    
    
    
    //=======================================================================================================================
    //MQTT -Verbindung aufbauen
    //=======================================================================================================================
    void initMQTT(){
    
       
        MQTTClient.setServer(MQTTserver,port);
        MQTTClient.setCallback(MQTTcallback);
    
        Serial.println("");
        Serial.print("MQTT verbinden...");
    
        //--Verbindungsloop
        while( !MQTTClient.connect("Energie_PZEM", mqttUser, mqttPassword))   
          {
            digitalWrite(STATUS_LED,!digitalRead(STATUS_LED));
            Serial.print("*");  
            delay(100);
          };
    
        digitalWrite(STATUS_LED,false);   
        Serial.print("MQTT ist verbunden!"); 
    
        //--Topics abbonieren---------------------------------------------------- 
        if (MQTTClient.subscribe("Energie/PZEM-Reset"))
          {
                Serial.println("MQTT : Energie: Reset aboniert"); 
          };
    
        if (MQTTClient.subscribe("Energie/Verbrauchs-Startwert"))
          {
                Serial.println("MQTT : Energie/Verbrauchs-Startwert aboniert"); 
          }; 
    
        if (MQTTClient.subscribe("Energie/Befehl"))
          {
                Serial.println("MQTT : Energie/Befehl aboniert"); 
          }; 
    
    }
    
    
    
    //=======================================================================================================================
    //PZEM Module auslesen und publishen
    //=======================================================================================================================
    void pzem_read(){
    
      float spannung_gesamt;
      float stromstaerke_gesamt;
      float leistung_gesamt;
      float verbrauch_gesamt;
      float frequenz_gesamt;
      float pf_gesamt;
      float PZEM_verbrauch = 0;
    
      float spannung_pzem1 = pzem_1.voltage();
    	float stromstaerke_pzem1 = pzem_1.current();
    	float leistung_pzem1 = pzem_1.power();
    	float verbrauch_pzem1 = pzem_1.energy();
    	float frequenz_pzem1 = pzem_1.frequency();
    	float pf_pzem1 = pzem_1.pf();
    	
    	float spannung_pzem2 = pzem_2.voltage();
    	float stromstaerke_pzem2 = pzem_2.current();
    	float leistung_pzem2 = pzem_2.power();
    	float verbrauch_pzem2 = pzem_2.energy();
    	float frequenz_pzem2 = pzem_2.frequency();
    	float pf_pzem2 = pzem_2.pf();
    	
    	float spannung_pzem3 = pzem_3.voltage();
    	float stromstaerke_pzem3 = pzem_3.current();
    	float leistung_pzem3 = pzem_3.power();
    	float verbrauch_pzem3 = pzem_3.energy();
    	float frequenz_pzem3 = pzem_3.frequency();
    	float pf_pzem3 = pzem_3.pf();	
    
     // char* Temp_String = "           ";
      char Temp_String[12];
    
      if(!isnan(spannung_pzem1) && old_spannung_pzem1 != spannung_pzem1)
        { 
          dtostrf(spannung_pzem1,5 , 2, Temp_String);
          MQTTClient.publish ("Energie/L1/SpannungL1", Temp_String);
          old_spannung_pzem1 = spannung_pzem1;
        }
    
      if(!isnan(spannung_pzem2) && old_spannung_pzem2 != spannung_pzem2)
        { 
          dtostrf(spannung_pzem2,5 , 2, Temp_String);
          MQTTClient.publish ("Energie/L2/SpannungL2", Temp_String);
          old_spannung_pzem2 = spannung_pzem2;
        }
    
      if(!isnan(spannung_pzem3) && old_spannung_pzem3 != spannung_pzem3)
        { 
          dtostrf(spannung_pzem3,5 , 2, Temp_String);
          MQTTClient.publish ("Energie/L3/SpannungL3", Temp_String);
          old_spannung_pzem3 = spannung_pzem3;
        }
    
      if(!isnan(stromstaerke_pzem1) && old_stromstaerke_pzem1 != stromstaerke_pzem1)
        { 
          dtostrf(stromstaerke_pzem1,5 , 2, Temp_String);
          MQTTClient.publish ("Energie/L1/StromstaerkeL1", Temp_String);
          old_stromstaerke_pzem1 = stromstaerke_pzem1;
        }
    
      if(!isnan(stromstaerke_pzem2) && old_stromstaerke_pzem2 != stromstaerke_pzem2)
        { 
          dtostrf(stromstaerke_pzem2,5 , 2, Temp_String);
          MQTTClient.publish ("Energie/L2/StromstaerkeL2", Temp_String);
          old_stromstaerke_pzem2 = stromstaerke_pzem2;
        }
    
      if(!isnan(stromstaerke_pzem3) && old_stromstaerke_pzem3 != stromstaerke_pzem3)
        { 
          dtostrf(stromstaerke_pzem3,5 , 2, Temp_String);
          MQTTClient.publish ("Energie/L3/StromstaerkeL3", Temp_String);
          old_stromstaerke_pzem3 = stromstaerke_pzem3;
        }
    
      if(!isnan(leistung_pzem1) && old_leistung_pzem1 != leistung_pzem1)
        { 
          dtostrf(leistung_pzem1,5 , 2, Temp_String);
          MQTTClient.publish ("Energie/L1/LeistungL1", Temp_String);
          old_leistung_pzem1 = leistung_pzem1;
        }
    
      if(!isnan(leistung_pzem2) && old_leistung_pzem2 != leistung_pzem2)
        { 
          dtostrf(leistung_pzem2,5 , 2, Temp_String);
          MQTTClient.publish ("Energie/L2/LeistungL2", Temp_String);
          old_leistung_pzem2 = leistung_pzem2;
        }
    
      if(!isnan(leistung_pzem3) && old_leistung_pzem3 != leistung_pzem3)
        { 
          dtostrf(leistung_pzem3,5 , 2, Temp_String);
          MQTTClient.publish ("Energie/L3/LeistungL3", Temp_String);
          old_leistung_pzem3 = leistung_pzem3;
        }
    
      if(!isnan(verbrauch_pzem1) && old_verbrauch_pzem1 != verbrauch_pzem1)
        { 
          dtostrf(verbrauch_pzem1,5 , 2, Temp_String);
          MQTTClient.publish ("Energie/L1/VerbrauchL1", Temp_String);
          old_verbrauch_pzem1 = verbrauch_pzem1;
        }
    
      if(!isnan(verbrauch_pzem2) && old_verbrauch_pzem2 != verbrauch_pzem2)
        { 
          dtostrf(verbrauch_pzem2,5 , 2, Temp_String);
          MQTTClient.publish ("Energie/L2/VerbrauchL2", Temp_String);
          old_verbrauch_pzem2 = verbrauch_pzem2;
        }
    
      if(!isnan(verbrauch_pzem3) && old_verbrauch_pzem3 != verbrauch_pzem3)
        { 
          dtostrf(verbrauch_pzem3,5 , 2, Temp_String);
          MQTTClient.publish ("Energie/L3/VerbrauchL3", Temp_String);
          old_verbrauch_pzem3 = verbrauch_pzem3;
        }
    
      if(!isnan(frequenz_pzem1) && old_frequenz_pzem1 != frequenz_pzem1)
        { 
          dtostrf(frequenz_pzem1,5 , 2, Temp_String);
          MQTTClient.publish ("Energie/L1/FrequenzL1", Temp_String);
          old_frequenz_pzem1 = frequenz_pzem1;
        } 
    
      if(!isnan(frequenz_pzem2) && old_frequenz_pzem1 != frequenz_pzem2)
        { 
          dtostrf(frequenz_pzem2,5 , 2, Temp_String);
          MQTTClient.publish ("Energie/L2/FrequenzL2", Temp_String);
          old_frequenz_pzem2 = frequenz_pzem2;
        } 
    
      if(!isnan(frequenz_pzem3) && old_frequenz_pzem3 != frequenz_pzem3)
        { 
          dtostrf(frequenz_pzem3,5 , 2, Temp_String);
          MQTTClient.publish ("Energie/L3/FrequenzL3", Temp_String);
          old_frequenz_pzem3 = frequenz_pzem3;
        } 
    
     if(!isnan(pf_pzem1) && old_pf_pzem1 != pf_pzem1)
        { 
          dtostrf(pf_pzem1,5 , 2, Temp_String);
          MQTTClient.publish ("Energie/L1/PowerFactorL1", Temp_String);
          old_pf_pzem1 = pf_pzem1;
        }  
    
     if(!isnan(pf_pzem2) && old_pf_pzem2 != pf_pzem2)
        { 
          dtostrf(pf_pzem2,5 , 2, Temp_String);
          MQTTClient.publish ("Energie/L2/PowerFactorL2", Temp_String);
          old_pf_pzem2 = pf_pzem2;
        }   
    
     if(!isnan(pf_pzem3) && old_pf_pzem3 != pf_pzem3)
      { 
        dtostrf(pf_pzem3,5 , 2, Temp_String);
        MQTTClient.publish ("Energie/L3/PowerFactorL3", Temp_String);
        old_pf_pzem3 = pf_pzem3;
      }
    
    
     if(!isnan(spannung_pzem1) && !isnan(spannung_pzem2) && !isnan(spannung_pzem3))
      {
        spannung_gesamt = (spannung_pzem1 + spannung_pzem2 + spannung_pzem3) / 3   ;
      }
     else
      {
        spannung_gesamt = 0;
      }
         
     
     if(!isnan(stromstaerke_pzem1) && !isnan(stromstaerke_pzem2) && !isnan(stromstaerke_pzem3))
      {
        stromstaerke_gesamt = stromstaerke_pzem1 + stromstaerke_pzem2 + stromstaerke_pzem3 ;
      }
     else
      {
        stromstaerke_gesamt = 0;
      } 
    
     if(!isnan(leistung_pzem1) && !isnan(leistung_pzem2) && !isnan(leistung_pzem3))
      {
        leistung_gesamt = leistung_pzem1 + leistung_pzem2 + leistung_pzem3 ;
      }
     else
      {
        leistung_gesamt = 0;
      } 
    
     if(!isnan(verbrauch_pzem1) && !isnan(verbrauch_pzem2) && !isnan(verbrauch_pzem3))
      {
        verbrauch_gesamt = verbrauch_pzem1 + verbrauch_pzem2 + verbrauch_pzem3 ;
        PZEM_verbrauch   = verbrauch_gesamt;
        verbrauch_gesamt = start_verbrauch + verbrauch_gesamt - diff_verbrauch;
      }
     else
      {
        verbrauch_gesamt = 0;
      }
    
     if(!isnan(frequenz_pzem1) && !isnan(frequenz_pzem2) && !isnan(frequenz_pzem3))
      {
        frequenz_gesamt = (frequenz_pzem1 + frequenz_pzem2 + frequenz_pzem3) / 3;
      }
     else
      {
        frequenz_gesamt = 0;
      } 
    
     if(!isnan(pf_pzem1) && !isnan(pf_pzem2) && !isnan(pf_pzem3))
      {
        pf_gesamt = (pf_pzem1 + pf_pzem2 + pf_pzem3) / 3 ;
      }
     else
      {
        pf_gesamt = 0;
      }    
    
      if (old_spannung_gesamt != spannung_gesamt)
        {
          dtostrf(spannung_gesamt,5 , 2, Temp_String);
          MQTTClient.publish("Energie/Spannung",Temp_String);  
          old_spannung_gesamt = spannung_gesamt;
        }
    
      if (old_stromstaerke_gesamt != stromstaerke_gesamt)
        {
          dtostrf(stromstaerke_gesamt,5 , 2, Temp_String);
          MQTTClient.publish("Energie/Stromstaerke",Temp_String);
          old_stromstaerke_gesamt = stromstaerke_gesamt;  
        }
      
      if (old_leistung_gesamt != leistung_gesamt)
        {
          dtostrf(leistung_gesamt,5 , 2, Temp_String);
          MQTTClient.publish("Energie/Leistung",Temp_String);    
          old_leistung_gesamt = leistung_gesamt;  
        }
    
      if (old_verbrauch_gesamt != verbrauch_gesamt)
        {
          dtostrf(verbrauch_gesamt,5 , 2, Temp_String);
          MQTTClient.publish("Energie/Verbrauch",Temp_String); 
          old_verbrauch_gesamt = verbrauch_gesamt;     
        } 
    
      if (old_frequenz_gesamt != frequenz_gesamt)
        {
          dtostrf(frequenz_gesamt,5 , 2, Temp_String);
          MQTTClient.publish("Energie/Frequenz",Temp_String);
          old_frequenz_gesamt = frequenz_gesamt;      
        } 
     
      if (old_pf_gesamt != pf_gesamt)
        {
          dtostrf(pf_gesamt,5 , 2, Temp_String);
          MQTTClient.publish("Energie/PowerFactor",Temp_String); 
          old_pf_gesamt = pf_gesamt;     
        } 
    
      if (old_PZEM_verbrauch != PZEM_verbrauch)
      {
          dtostrf(PZEM_verbrauch,5 , 2, Temp_String);
          MQTTClient.publish("Energie/PZEM-Verbrauch",Temp_String); 
          old_PZEM_verbrauch = PZEM_verbrauch; 
      }
         
    
      digitalWrite(STATUS_LED,true);
      delay(50);
      digitalWrite(STATUS_LED,false);  
    
    };
    
    
    
    //=======================================================================================================================
    //Energieverbrauch in pzem Modulen zurücksetzen
    //=======================================================================================================================
    void pzem_reset()
    {
    
      myTimer1.pause();
      Serial.println("Energieverbrauch wird zurückgesetzt..!");
      
      pzem_1.resetEnergy();
    	pzem_2.resetEnergy();
    	pzem_3.resetEnergy();
      delay(1000);
     
      myTimer1.resume();
    	
    }
    
    
    //=======================================================================================================================
    //Startwert für Verbrauchszähler setzen
    //=======================================================================================================================
    void set_counter(float counterStart){
    
      myTimer1.pause();
      
      float verbrauch_pzem1 = pzem_1.energy();
      float verbrauch_pzem2 = pzem_2.energy();
      float verbrauch_pzem3 = pzem_3.energy();
    
      float verbrauch_gesamt = verbrauch_pzem1 + verbrauch_pzem2 + verbrauch_pzem3;
      diff_verbrauch = verbrauch_gesamt;
    
      config.diff_verbrauch = diff_verbrauch; // ins eprom speichern
      saveConfig();
    
      myTimer1.resume();
    
    
    
    }
    
    // #####################################################################################################
    // #####################################################################################################
    // Die SETUP Routine
    // #####################################################################################################
    // #####################################################################################################
    void setup()
    {
    
      pinMode(STATUS_LED,OUTPUT);
      digitalWrite(STATUS_LED,LOW);
      
      Serial.begin(9600);
      delay(100);
      Serial.println("");
      Serial.println("PZEM 3-Phasen-Reader");  
      
      Serial.println(version);
      Serial.println("");
    
      loadConfig();
      start_verbrauch = config.counter_startwert;
      diff_verbrauch  = config.diff_verbrauch;
    
    
      initWiFi();
      initMQTT();
    
      MQTTClient.publish("Energie/Info",version);
      MQTTClient.publish( "Energie/Befehl", "");
    
    
      //--OTA Over the Air update einrichten
      MDNS.begin(Hostname);
      httpUpdater.setup(&httpServer);
      httpServer.begin();
      MDNS.addService("http", "tcp", 80);
      Serial.printf("HTTPUpdateServer ready! Open http://%s.local/update in your browser\n", Hostname);
      
     
      //--Timer für PZEM lesen und senden starten
      myTimer1.start();
     
    }
    
    
    // #####################################################################################################
    // #####################################################################################################
    // Die Haupt-  LOOP Routine
    // #####################################################################################################
    // #####################################################################################################
    void loop(){
    
      //--Wifi verloren? dann neu aufbauen
      if (WiFi.status() != WL_CONNECTED)
        {
          initWiFi();
        };
    
      //--MQTT Verbindung verloren? dann neu aufbauen
      if (MQTTClient.state() != MQTT_CONNECTED) 
        {
          initMQTT();
        };
    
      MQTTClient.loop();
      httpServer.handleClient();
      MDNS.update();
      myTimer1.update();
    
    
      delay(10);
    
    
    
    }
    
    S 2 Antworten Letzte Antwort
    1
    • HomeZeckeH HomeZecke

      Hallo,

      mal ein kleines Update meiner Firmware.

      Wifi optimiert und hostname auf "PZEM-Powermeter" gesetzt. Updates dann über: "http://pzem-powermeter.local/update"
      Zählerstand wird jetzt erhalten nach einem reset oder Wlan bzw Strom Ausfall.
      Neuer Datenpunkt "Befehl". Dort können Steuerbefehle an den Wemos gesendet werden. Im Moment sind das:
      "sys-reset" : Wemos resetten
      "pzem-reset" : resetten der PZEM Zählerstände
      Der Datenpunkt "PZEM-Reset" fällt damit weg.
      MQTT user und passwort hinzugefügt. Wenn nicht benötigt einfach leer lassen. (Danke @spaceduck)

      Alles weitere bitte weiter oben nachlesen

      //####################################################################################
      //####################################################################################
      //
      //    PZEM Energiemessgeräterfassung mit WEMOS von HomeZecke     v1.2 stand 04.08.2020
      //    --------------------------------------------------------------------------
      //     v 1.0      Testphase first release 			     -05.03.2020
      //
      //     v 1.1      Zählerstartwert kann festgelegt werden 	     -30.03.2020
      //
      //     v 1.2      Wifi optimiert, hostname auf "PZEM-Powermeter"     -04.08.2020
      //                gesetzt. Updates jetzt über:
      //                "http://pzem-powermeter.local/update"
      //                Zählerstand wird jetzt erhalten nach     
      //                reset oder Wlan Ausfall.
      //                Neuer Datenpunkt "Befehl". Dort können Steuer-
      //                befehle an den Wemos gesendet werden:
      //                "sys-reset"  : Wemos resetten
      //                "pzem-reset" : resetten der PZEM Zählerstände
      //                Der Datenpunkt "PZEM-Reset" fällt damit weg.
      //                MQTT user und passwort -Abfrage hinzugef. Wenn nicht
      //                benötigt leer lassen. (Danke @spaceduck)
      //                
      //				 
      //     ToDo:      Online Config für Wlan / MQTT usw. hinzuf.
      //
      //     	
      //			  
      //####################################################################################
      //####################################################################################
      
      #include <Arduino.h>
      #include <EEPROM.h>
      #include <ESP8266WiFi.h>
      #include <WiFiClient.h>
      #include <ESP8266WebServer.h>
      #include <ESP8266mDNS.h>
      #include <ESP8266HTTPUpdateServer.h>
      #include <Ticker.h>
      #include <PubSubClient.h>
      #include <PZEM004Tv30.h>
      
      
      //Hier die persönlichen Daten eintragen!
      //---------------------------------------------
      const char* SSID = "WLAN-SSID";
      const char* PSK =  "PASSWORT";
      const char* MQTTserver = "192.168.0.0";
      const uint16_t port = 1883;
      const char* mqttUser = "";
      const char* mqttPassword = "";
      //---------------------------------------------
      const char* Hostname = "PZEM-Powermeter";
      const int STATUS_LED = 13;  //D7 (Wemos D1 Mini)
      
      typedef struct //Datenstruktur für Eprom config
        {
          float counter_startwert;
          float diff_verbrauch;
        } configdata_typ;
      
      configdata_typ config; //config variable deklarieren 
      
      
      float start_verbrauch = 0;
      float diff_verbrauch = 0;
      float old_spannung_pzem1;
      float old_frequenz_pzem1;
      float old_stromstaerke_pzem1;
      float old_verbrauch_pzem1;
      float old_leistung_pzem1;
      float old_pf_pzem1;
      float old_spannung_pzem2;
      float old_frequenz_pzem2;
      float old_stromstaerke_pzem2;
      float old_verbrauch_pzem2;
      float old_leistung_pzem2;
      float old_pf_pzem2;
      float old_spannung_pzem3;
      float old_frequenz_pzem3;
      float old_stromstaerke_pzem3;
      float old_verbrauch_pzem3;
      float old_leistung_pzem3;
      float old_pf_pzem3;
      float old_spannung_gesamt;
      float old_stromstaerke_gesamt;
      float old_leistung_gesamt;
      float old_verbrauch_gesamt;
      float old_frequenz_gesamt;
      float old_pf_gesamt;
      float old_PZEM_verbrauch;
      
      
      //---functions / callbacks
      void MQTTcallback(char* topic, byte* payload, unsigned int length);
      void pzem_reset();
      void pzem_read();
      void set_counter(float counterStart);
      
      
      //-Klassen definieren
      ESP8266WebServer httpServer(80);
      ESP8266HTTPUpdateServer httpUpdater;
      
      WiFiClient MY_NETClient_1;
      PubSubClient MQTTClient(MY_NETClient_1);
      
      Ticker myTimer1(pzem_read,5000);
      
      PZEM004Tv30 pzem_1(5, 4);    //D1,D2 Grün / Orange Wemos D1 Mini L1
      PZEM004Tv30 pzem_2(2, 0);    //D4,D3                             L2
      PZEM004Tv30 pzem_3(14, 12);  //D5,D6                             L3 
      
      
      
      // #####################################################################################################
      // #####################################################################################################
      // Funktionen
      // #####################################################################################################
      // #####################################################################################################
      
      
      
      //=======================================================================================================================
      //Config ins EPROM speichern
      //=======================================================================================================================
      void saveConfig() {
       
        EEPROM.begin(4095);
        EEPROM.put( 0, config );
        delay(200);
        EEPROM.commit();                    
        EEPROM.end();  
      
      }
      
      
      //=======================================================================================================================
      //Config vom EPROM laden
      //=======================================================================================================================
      void loadConfig() {
       
        EEPROM.begin(4095);
        EEPROM.get( 0, config );
        EEPROM.end();
      }
      
      
      //=======================================================================================================================
      //MQTT CallBack
      //=======================================================================================================================
      void MQTTcallback(char* topic, byte* payload, unsigned int length)
      {
       
        char my_payload[length+1];  // nen string machen, länge eins mehr wegen nullterminierung
        float counter_start;
        
        Serial.print(topic);
        Serial.print(" : ");
        
      
        // Topic Verbrauchs-Startwert------------------------------------------------------------------------------
        if (strcmp(topic,"Energie/Verbrauchs-Startwert") == 0 )
            {
              
                for (unsigned int i = 0; i < length; i++)  // jedes einzelne byte in einen buchstaben umwandeln
                  {              
                     my_payload[i] = (char)payload[i];   // (char)100 wäre zb ein "d"
                  };
      
                my_payload[length] = '\0';              // nullterminierung
                Serial.println(my_payload);
                counter_start = atof(my_payload);    // nen float aus der payload machen
                
                if (counter_start != start_verbrauch)
                  {
                    start_verbrauch = counter_start;
                    config.counter_startwert = start_verbrauch;
                    saveConfig();
                    set_counter(counter_start); // func set_couter zum setzen aufrufen
                  }
      
               
      
              
            } 
      
      
      // Topic Befehl------------------------------------------------------------------------------
        if (strcmp(topic,"Energie/Befehl") == 0 )
            {
              
                for (unsigned int i = 0; i < length; i++)  // jedes einzelne byte in einen buchstaben umwandeln
                  {              
                     my_payload[i] = (char)payload[i];   // (char)100 wäre zb ein "d"
                  };
      
                my_payload[length] = '\0';              // nullterminierung
                Serial.println(my_payload);
                counter_start = atof(my_payload);    // nen float aus der payload machen
                
                if (strcmp(my_payload,"pzem-reset") == 0)
                  {
                      pzem_reset();                //Energie an den PZEM's resetten
                  }
      
                if (strcmp(my_payload,"sys-reset") == 0)
                  {
                     MQTTClient.publish ( "Energie/Befehl", "");
                     delay(1000);
                     ESP.restart();                //Wemos resetten
                  }
      
      
                     
            MQTTClient.publish ( "Energie/Befehl", "");
               
      
              
            }                 
      
      }
      
      //=======================================================================================================================
      //WLan -Verbindung aufbauen
      //=======================================================================================================================
      void initWiFi()
      {
          static int wifiRetryCounter;
      
          Serial.println("");
          Serial.print("Wifi connect...");
          WiFi.persistent(false);
          WiFi.begin(SSID, PSK);
          WiFi.hostname(Hostname);
          WiFi.begin(SSID, PSK);
      
          while (WiFi.status() != WL_CONNECTED)
            {
              ++wifiRetryCounter;
              if (wifiRetryCounter > 90)
                {
                  ESP.restart();
                }
              digitalWrite(STATUS_LED,!digitalRead(STATUS_LED));
              Serial.print(".");   
              delay(700);
            };
      
          Serial.print("Verbunden!");
          WiFi.mode(WIFI_STA);    
          wifiRetryCounter = 0;
      
      }
      
      
      
      //=======================================================================================================================
      //MQTT -Verbindung aufbauen
      //=======================================================================================================================
      void initMQTT(){
      
         
          MQTTClient.setServer(MQTTserver,port);
          MQTTClient.setCallback(MQTTcallback);
      
          Serial.println("");
          Serial.print("MQTT verbinden...");
      
          //--Verbindungsloop
          while( !MQTTClient.connect("Energie_PZEM", mqttUser, mqttPassword))   
            {
              digitalWrite(STATUS_LED,!digitalRead(STATUS_LED));
              Serial.print("*");  
              delay(100);
            };
      
          digitalWrite(STATUS_LED,false);   
          Serial.print("MQTT ist verbunden!"); 
      
          //--Topics abbonieren---------------------------------------------------- 
          if (MQTTClient.subscribe("Energie/PZEM-Reset"))
            {
                  Serial.println("MQTT : Energie: Reset aboniert"); 
            };
      
          if (MQTTClient.subscribe("Energie/Verbrauchs-Startwert"))
            {
                  Serial.println("MQTT : Energie/Verbrauchs-Startwert aboniert"); 
            }; 
      
          if (MQTTClient.subscribe("Energie/Befehl"))
            {
                  Serial.println("MQTT : Energie/Befehl aboniert"); 
            }; 
      
      }
      
      
      
      //=======================================================================================================================
      //PZEM Module auslesen und publishen
      //=======================================================================================================================
      void pzem_read(){
      
        float spannung_gesamt;
        float stromstaerke_gesamt;
        float leistung_gesamt;
        float verbrauch_gesamt;
        float frequenz_gesamt;
        float pf_gesamt;
        float PZEM_verbrauch = 0;
      
        float spannung_pzem1 = pzem_1.voltage();
      	float stromstaerke_pzem1 = pzem_1.current();
      	float leistung_pzem1 = pzem_1.power();
      	float verbrauch_pzem1 = pzem_1.energy();
      	float frequenz_pzem1 = pzem_1.frequency();
      	float pf_pzem1 = pzem_1.pf();
      	
      	float spannung_pzem2 = pzem_2.voltage();
      	float stromstaerke_pzem2 = pzem_2.current();
      	float leistung_pzem2 = pzem_2.power();
      	float verbrauch_pzem2 = pzem_2.energy();
      	float frequenz_pzem2 = pzem_2.frequency();
      	float pf_pzem2 = pzem_2.pf();
      	
      	float spannung_pzem3 = pzem_3.voltage();
      	float stromstaerke_pzem3 = pzem_3.current();
      	float leistung_pzem3 = pzem_3.power();
      	float verbrauch_pzem3 = pzem_3.energy();
      	float frequenz_pzem3 = pzem_3.frequency();
      	float pf_pzem3 = pzem_3.pf();	
      
       // char* Temp_String = "           ";
        char Temp_String[12];
      
        if(!isnan(spannung_pzem1) && old_spannung_pzem1 != spannung_pzem1)
          { 
            dtostrf(spannung_pzem1,5 , 2, Temp_String);
            MQTTClient.publish ("Energie/L1/SpannungL1", Temp_String);
            old_spannung_pzem1 = spannung_pzem1;
          }
      
        if(!isnan(spannung_pzem2) && old_spannung_pzem2 != spannung_pzem2)
          { 
            dtostrf(spannung_pzem2,5 , 2, Temp_String);
            MQTTClient.publish ("Energie/L2/SpannungL2", Temp_String);
            old_spannung_pzem2 = spannung_pzem2;
          }
      
        if(!isnan(spannung_pzem3) && old_spannung_pzem3 != spannung_pzem3)
          { 
            dtostrf(spannung_pzem3,5 , 2, Temp_String);
            MQTTClient.publish ("Energie/L3/SpannungL3", Temp_String);
            old_spannung_pzem3 = spannung_pzem3;
          }
      
        if(!isnan(stromstaerke_pzem1) && old_stromstaerke_pzem1 != stromstaerke_pzem1)
          { 
            dtostrf(stromstaerke_pzem1,5 , 2, Temp_String);
            MQTTClient.publish ("Energie/L1/StromstaerkeL1", Temp_String);
            old_stromstaerke_pzem1 = stromstaerke_pzem1;
          }
      
        if(!isnan(stromstaerke_pzem2) && old_stromstaerke_pzem2 != stromstaerke_pzem2)
          { 
            dtostrf(stromstaerke_pzem2,5 , 2, Temp_String);
            MQTTClient.publish ("Energie/L2/StromstaerkeL2", Temp_String);
            old_stromstaerke_pzem2 = stromstaerke_pzem2;
          }
      
        if(!isnan(stromstaerke_pzem3) && old_stromstaerke_pzem3 != stromstaerke_pzem3)
          { 
            dtostrf(stromstaerke_pzem3,5 , 2, Temp_String);
            MQTTClient.publish ("Energie/L3/StromstaerkeL3", Temp_String);
            old_stromstaerke_pzem3 = stromstaerke_pzem3;
          }
      
        if(!isnan(leistung_pzem1) && old_leistung_pzem1 != leistung_pzem1)
          { 
            dtostrf(leistung_pzem1,5 , 2, Temp_String);
            MQTTClient.publish ("Energie/L1/LeistungL1", Temp_String);
            old_leistung_pzem1 = leistung_pzem1;
          }
      
        if(!isnan(leistung_pzem2) && old_leistung_pzem2 != leistung_pzem2)
          { 
            dtostrf(leistung_pzem2,5 , 2, Temp_String);
            MQTTClient.publish ("Energie/L2/LeistungL2", Temp_String);
            old_leistung_pzem2 = leistung_pzem2;
          }
      
        if(!isnan(leistung_pzem3) && old_leistung_pzem3 != leistung_pzem3)
          { 
            dtostrf(leistung_pzem3,5 , 2, Temp_String);
            MQTTClient.publish ("Energie/L3/LeistungL3", Temp_String);
            old_leistung_pzem3 = leistung_pzem3;
          }
      
        if(!isnan(verbrauch_pzem1) && old_verbrauch_pzem1 != verbrauch_pzem1)
          { 
            dtostrf(verbrauch_pzem1,5 , 2, Temp_String);
            MQTTClient.publish ("Energie/L1/VerbrauchL1", Temp_String);
            old_verbrauch_pzem1 = verbrauch_pzem1;
          }
      
        if(!isnan(verbrauch_pzem2) && old_verbrauch_pzem2 != verbrauch_pzem2)
          { 
            dtostrf(verbrauch_pzem2,5 , 2, Temp_String);
            MQTTClient.publish ("Energie/L2/VerbrauchL2", Temp_String);
            old_verbrauch_pzem2 = verbrauch_pzem2;
          }
      
        if(!isnan(verbrauch_pzem3) && old_verbrauch_pzem3 != verbrauch_pzem3)
          { 
            dtostrf(verbrauch_pzem3,5 , 2, Temp_String);
            MQTTClient.publish ("Energie/L3/VerbrauchL3", Temp_String);
            old_verbrauch_pzem3 = verbrauch_pzem3;
          }
      
        if(!isnan(frequenz_pzem1) && old_frequenz_pzem1 != frequenz_pzem1)
          { 
            dtostrf(frequenz_pzem1,5 , 2, Temp_String);
            MQTTClient.publish ("Energie/L1/FrequenzL1", Temp_String);
            old_frequenz_pzem1 = frequenz_pzem1;
          } 
      
        if(!isnan(frequenz_pzem2) && old_frequenz_pzem1 != frequenz_pzem2)
          { 
            dtostrf(frequenz_pzem2,5 , 2, Temp_String);
            MQTTClient.publish ("Energie/L2/FrequenzL2", Temp_String);
            old_frequenz_pzem2 = frequenz_pzem2;
          } 
      
        if(!isnan(frequenz_pzem3) && old_frequenz_pzem3 != frequenz_pzem3)
          { 
            dtostrf(frequenz_pzem3,5 , 2, Temp_String);
            MQTTClient.publish ("Energie/L3/FrequenzL3", Temp_String);
            old_frequenz_pzem3 = frequenz_pzem3;
          } 
      
       if(!isnan(pf_pzem1) && old_pf_pzem1 != pf_pzem1)
          { 
            dtostrf(pf_pzem1,5 , 2, Temp_String);
            MQTTClient.publish ("Energie/L1/PowerFactorL1", Temp_String);
            old_pf_pzem1 = pf_pzem1;
          }  
      
       if(!isnan(pf_pzem2) && old_pf_pzem2 != pf_pzem2)
          { 
            dtostrf(pf_pzem2,5 , 2, Temp_String);
            MQTTClient.publish ("Energie/L2/PowerFactorL2", Temp_String);
            old_pf_pzem2 = pf_pzem2;
          }   
      
       if(!isnan(pf_pzem3) && old_pf_pzem3 != pf_pzem3)
        { 
          dtostrf(pf_pzem3,5 , 2, Temp_String);
          MQTTClient.publish ("Energie/L3/PowerFactorL3", Temp_String);
          old_pf_pzem3 = pf_pzem3;
        }
      
      
       if(!isnan(spannung_pzem1) && !isnan(spannung_pzem2) && !isnan(spannung_pzem3))
        {
          spannung_gesamt = (spannung_pzem1 + spannung_pzem2 + spannung_pzem3) / 3   ;
        }
       else
        {
          spannung_gesamt = 0;
        }
           
       
       if(!isnan(stromstaerke_pzem1) && !isnan(stromstaerke_pzem2) && !isnan(stromstaerke_pzem3))
        {
          stromstaerke_gesamt = stromstaerke_pzem1 + stromstaerke_pzem2 + stromstaerke_pzem3 ;
        }
       else
        {
          stromstaerke_gesamt = 0;
        } 
      
       if(!isnan(leistung_pzem1) && !isnan(leistung_pzem2) && !isnan(leistung_pzem3))
        {
          leistung_gesamt = leistung_pzem1 + leistung_pzem2 + leistung_pzem3 ;
        }
       else
        {
          leistung_gesamt = 0;
        } 
      
       if(!isnan(verbrauch_pzem1) && !isnan(verbrauch_pzem2) && !isnan(verbrauch_pzem3))
        {
          verbrauch_gesamt = verbrauch_pzem1 + verbrauch_pzem2 + verbrauch_pzem3 ;
          PZEM_verbrauch   = verbrauch_gesamt;
          verbrauch_gesamt = start_verbrauch + verbrauch_gesamt - diff_verbrauch;
        }
       else
        {
          verbrauch_gesamt = 0;
        }
      
       if(!isnan(frequenz_pzem1) && !isnan(frequenz_pzem2) && !isnan(frequenz_pzem3))
        {
          frequenz_gesamt = (frequenz_pzem1 + frequenz_pzem2 + frequenz_pzem3) / 3;
        }
       else
        {
          frequenz_gesamt = 0;
        } 
      
       if(!isnan(pf_pzem1) && !isnan(pf_pzem2) && !isnan(pf_pzem3))
        {
          pf_gesamt = (pf_pzem1 + pf_pzem2 + pf_pzem3) / 3 ;
        }
       else
        {
          pf_gesamt = 0;
        }    
      
        if (old_spannung_gesamt != spannung_gesamt)
          {
            dtostrf(spannung_gesamt,5 , 2, Temp_String);
            MQTTClient.publish("Energie/Spannung",Temp_String);  
            old_spannung_gesamt = spannung_gesamt;
          }
      
        if (old_stromstaerke_gesamt != stromstaerke_gesamt)
          {
            dtostrf(stromstaerke_gesamt,5 , 2, Temp_String);
            MQTTClient.publish("Energie/Stromstaerke",Temp_String);
            old_stromstaerke_gesamt = stromstaerke_gesamt;  
          }
        
        if (old_leistung_gesamt != leistung_gesamt)
          {
            dtostrf(leistung_gesamt,5 , 2, Temp_String);
            MQTTClient.publish("Energie/Leistung",Temp_String);    
            old_leistung_gesamt = leistung_gesamt;  
          }
      
        if (old_verbrauch_gesamt != verbrauch_gesamt)
          {
            dtostrf(verbrauch_gesamt,5 , 2, Temp_String);
            MQTTClient.publish("Energie/Verbrauch",Temp_String); 
            old_verbrauch_gesamt = verbrauch_gesamt;     
          } 
      
        if (old_frequenz_gesamt != frequenz_gesamt)
          {
            dtostrf(frequenz_gesamt,5 , 2, Temp_String);
            MQTTClient.publish("Energie/Frequenz",Temp_String);
            old_frequenz_gesamt = frequenz_gesamt;      
          } 
       
        if (old_pf_gesamt != pf_gesamt)
          {
            dtostrf(pf_gesamt,5 , 2, Temp_String);
            MQTTClient.publish("Energie/PowerFactor",Temp_String); 
            old_pf_gesamt = pf_gesamt;     
          } 
      
        if (old_PZEM_verbrauch != PZEM_verbrauch)
        {
            dtostrf(PZEM_verbrauch,5 , 2, Temp_String);
            MQTTClient.publish("Energie/PZEM-Verbrauch",Temp_String); 
            old_PZEM_verbrauch = PZEM_verbrauch; 
        }
           
      
        digitalWrite(STATUS_LED,true);
        delay(50);
        digitalWrite(STATUS_LED,false);  
      
      };
      
      
      
      //=======================================================================================================================
      //Energieverbrauch in pzem Modulen zurücksetzen
      //=======================================================================================================================
      void pzem_reset()
      {
      
        myTimer1.pause();
        Serial.println("Energieverbrauch wird zurückgesetzt..!");
        
        pzem_1.resetEnergy();
      	pzem_2.resetEnergy();
      	pzem_3.resetEnergy();
        delay(1000);
       
        myTimer1.resume();
      	
      }
      
      
      //=======================================================================================================================
      //Startwert für Verbrauchszähler setzen
      //=======================================================================================================================
      void set_counter(float counterStart){
      
        myTimer1.pause();
        
        float verbrauch_pzem1 = pzem_1.energy();
        float verbrauch_pzem2 = pzem_2.energy();
        float verbrauch_pzem3 = pzem_3.energy();
      
        float verbrauch_gesamt = verbrauch_pzem1 + verbrauch_pzem2 + verbrauch_pzem3;
        diff_verbrauch = verbrauch_gesamt;
      
        config.diff_verbrauch = diff_verbrauch; // ins eprom speichern
        saveConfig();
      
        myTimer1.resume();
      
      
      
      }
      
      // #####################################################################################################
      // #####################################################################################################
      // Die SETUP Routine
      // #####################################################################################################
      // #####################################################################################################
      void setup()
      {
      
        pinMode(STATUS_LED,OUTPUT);
        digitalWrite(STATUS_LED,LOW);
        
        Serial.begin(9600);
        delay(100);
        Serial.println("");
        Serial.println("PZEM 3-Phasen-Reader");  
        
        Serial.println(version);
        Serial.println("");
      
        loadConfig();
        start_verbrauch = config.counter_startwert;
        diff_verbrauch  = config.diff_verbrauch;
      
      
        initWiFi();
        initMQTT();
      
        MQTTClient.publish("Energie/Info",version);
        MQTTClient.publish( "Energie/Befehl", "");
      
      
        //--OTA Over the Air update einrichten
        MDNS.begin(Hostname);
        httpUpdater.setup(&httpServer);
        httpServer.begin();
        MDNS.addService("http", "tcp", 80);
        Serial.printf("HTTPUpdateServer ready! Open http://%s.local/update in your browser\n", Hostname);
        
       
        //--Timer für PZEM lesen und senden starten
        myTimer1.start();
       
      }
      
      
      // #####################################################################################################
      // #####################################################################################################
      // Die Haupt-  LOOP Routine
      // #####################################################################################################
      // #####################################################################################################
      void loop(){
      
        //--Wifi verloren? dann neu aufbauen
        if (WiFi.status() != WL_CONNECTED)
          {
            initWiFi();
          };
      
        //--MQTT Verbindung verloren? dann neu aufbauen
        if (MQTTClient.state() != MQTT_CONNECTED) 
          {
            initMQTT();
          };
      
        MQTTClient.loop();
        httpServer.handleClient();
        MDNS.update();
        myTimer1.update();
      
      
        delay(10);
      
      
      
      }
      
      S Offline
      S Offline
      spaceduck
      schrieb am zuletzt editiert von
      #100

      @HomeZecke

      Im Code fehlt ein:

      const char* version = "Version 1.2";
      

      sonst meckert der Compiler. Danke für das Update!

      HP Gen8 16GB / Ubuntu Server 20.04 LTS - Nein, ein Server braucht keine GUI…;-)

      1 Antwort Letzte Antwort
      0
      • HomeZeckeH HomeZecke

        Hallo,

        mal ein kleines Update meiner Firmware.

        Wifi optimiert und hostname auf "PZEM-Powermeter" gesetzt. Updates dann über: "http://pzem-powermeter.local/update"
        Zählerstand wird jetzt erhalten nach einem reset oder Wlan bzw Strom Ausfall.
        Neuer Datenpunkt "Befehl". Dort können Steuerbefehle an den Wemos gesendet werden. Im Moment sind das:
        "sys-reset" : Wemos resetten
        "pzem-reset" : resetten der PZEM Zählerstände
        Der Datenpunkt "PZEM-Reset" fällt damit weg.
        MQTT user und passwort hinzugefügt. Wenn nicht benötigt einfach leer lassen. (Danke @spaceduck)

        Alles weitere bitte weiter oben nachlesen

        //####################################################################################
        //####################################################################################
        //
        //    PZEM Energiemessgeräterfassung mit WEMOS von HomeZecke     v1.2 stand 04.08.2020
        //    --------------------------------------------------------------------------
        //     v 1.0      Testphase first release 			     -05.03.2020
        //
        //     v 1.1      Zählerstartwert kann festgelegt werden 	     -30.03.2020
        //
        //     v 1.2      Wifi optimiert, hostname auf "PZEM-Powermeter"     -04.08.2020
        //                gesetzt. Updates jetzt über:
        //                "http://pzem-powermeter.local/update"
        //                Zählerstand wird jetzt erhalten nach     
        //                reset oder Wlan Ausfall.
        //                Neuer Datenpunkt "Befehl". Dort können Steuer-
        //                befehle an den Wemos gesendet werden:
        //                "sys-reset"  : Wemos resetten
        //                "pzem-reset" : resetten der PZEM Zählerstände
        //                Der Datenpunkt "PZEM-Reset" fällt damit weg.
        //                MQTT user und passwort -Abfrage hinzugef. Wenn nicht
        //                benötigt leer lassen. (Danke @spaceduck)
        //                
        //				 
        //     ToDo:      Online Config für Wlan / MQTT usw. hinzuf.
        //
        //     	
        //			  
        //####################################################################################
        //####################################################################################
        
        #include <Arduino.h>
        #include <EEPROM.h>
        #include <ESP8266WiFi.h>
        #include <WiFiClient.h>
        #include <ESP8266WebServer.h>
        #include <ESP8266mDNS.h>
        #include <ESP8266HTTPUpdateServer.h>
        #include <Ticker.h>
        #include <PubSubClient.h>
        #include <PZEM004Tv30.h>
        
        
        //Hier die persönlichen Daten eintragen!
        //---------------------------------------------
        const char* SSID = "WLAN-SSID";
        const char* PSK =  "PASSWORT";
        const char* MQTTserver = "192.168.0.0";
        const uint16_t port = 1883;
        const char* mqttUser = "";
        const char* mqttPassword = "";
        //---------------------------------------------
        const char* Hostname = "PZEM-Powermeter";
        const int STATUS_LED = 13;  //D7 (Wemos D1 Mini)
        
        typedef struct //Datenstruktur für Eprom config
          {
            float counter_startwert;
            float diff_verbrauch;
          } configdata_typ;
        
        configdata_typ config; //config variable deklarieren 
        
        
        float start_verbrauch = 0;
        float diff_verbrauch = 0;
        float old_spannung_pzem1;
        float old_frequenz_pzem1;
        float old_stromstaerke_pzem1;
        float old_verbrauch_pzem1;
        float old_leistung_pzem1;
        float old_pf_pzem1;
        float old_spannung_pzem2;
        float old_frequenz_pzem2;
        float old_stromstaerke_pzem2;
        float old_verbrauch_pzem2;
        float old_leistung_pzem2;
        float old_pf_pzem2;
        float old_spannung_pzem3;
        float old_frequenz_pzem3;
        float old_stromstaerke_pzem3;
        float old_verbrauch_pzem3;
        float old_leistung_pzem3;
        float old_pf_pzem3;
        float old_spannung_gesamt;
        float old_stromstaerke_gesamt;
        float old_leistung_gesamt;
        float old_verbrauch_gesamt;
        float old_frequenz_gesamt;
        float old_pf_gesamt;
        float old_PZEM_verbrauch;
        
        
        //---functions / callbacks
        void MQTTcallback(char* topic, byte* payload, unsigned int length);
        void pzem_reset();
        void pzem_read();
        void set_counter(float counterStart);
        
        
        //-Klassen definieren
        ESP8266WebServer httpServer(80);
        ESP8266HTTPUpdateServer httpUpdater;
        
        WiFiClient MY_NETClient_1;
        PubSubClient MQTTClient(MY_NETClient_1);
        
        Ticker myTimer1(pzem_read,5000);
        
        PZEM004Tv30 pzem_1(5, 4);    //D1,D2 Grün / Orange Wemos D1 Mini L1
        PZEM004Tv30 pzem_2(2, 0);    //D4,D3                             L2
        PZEM004Tv30 pzem_3(14, 12);  //D5,D6                             L3 
        
        
        
        // #####################################################################################################
        // #####################################################################################################
        // Funktionen
        // #####################################################################################################
        // #####################################################################################################
        
        
        
        //=======================================================================================================================
        //Config ins EPROM speichern
        //=======================================================================================================================
        void saveConfig() {
         
          EEPROM.begin(4095);
          EEPROM.put( 0, config );
          delay(200);
          EEPROM.commit();                    
          EEPROM.end();  
        
        }
        
        
        //=======================================================================================================================
        //Config vom EPROM laden
        //=======================================================================================================================
        void loadConfig() {
         
          EEPROM.begin(4095);
          EEPROM.get( 0, config );
          EEPROM.end();
        }
        
        
        //=======================================================================================================================
        //MQTT CallBack
        //=======================================================================================================================
        void MQTTcallback(char* topic, byte* payload, unsigned int length)
        {
         
          char my_payload[length+1];  // nen string machen, länge eins mehr wegen nullterminierung
          float counter_start;
          
          Serial.print(topic);
          Serial.print(" : ");
          
        
          // Topic Verbrauchs-Startwert------------------------------------------------------------------------------
          if (strcmp(topic,"Energie/Verbrauchs-Startwert") == 0 )
              {
                
                  for (unsigned int i = 0; i < length; i++)  // jedes einzelne byte in einen buchstaben umwandeln
                    {              
                       my_payload[i] = (char)payload[i];   // (char)100 wäre zb ein "d"
                    };
        
                  my_payload[length] = '\0';              // nullterminierung
                  Serial.println(my_payload);
                  counter_start = atof(my_payload);    // nen float aus der payload machen
                  
                  if (counter_start != start_verbrauch)
                    {
                      start_verbrauch = counter_start;
                      config.counter_startwert = start_verbrauch;
                      saveConfig();
                      set_counter(counter_start); // func set_couter zum setzen aufrufen
                    }
        
                 
        
                
              } 
        
        
        // Topic Befehl------------------------------------------------------------------------------
          if (strcmp(topic,"Energie/Befehl") == 0 )
              {
                
                  for (unsigned int i = 0; i < length; i++)  // jedes einzelne byte in einen buchstaben umwandeln
                    {              
                       my_payload[i] = (char)payload[i];   // (char)100 wäre zb ein "d"
                    };
        
                  my_payload[length] = '\0';              // nullterminierung
                  Serial.println(my_payload);
                  counter_start = atof(my_payload);    // nen float aus der payload machen
                  
                  if (strcmp(my_payload,"pzem-reset") == 0)
                    {
                        pzem_reset();                //Energie an den PZEM's resetten
                    }
        
                  if (strcmp(my_payload,"sys-reset") == 0)
                    {
                       MQTTClient.publish ( "Energie/Befehl", "");
                       delay(1000);
                       ESP.restart();                //Wemos resetten
                    }
        
        
                       
              MQTTClient.publish ( "Energie/Befehl", "");
                 
        
                
              }                 
        
        }
        
        //=======================================================================================================================
        //WLan -Verbindung aufbauen
        //=======================================================================================================================
        void initWiFi()
        {
            static int wifiRetryCounter;
        
            Serial.println("");
            Serial.print("Wifi connect...");
            WiFi.persistent(false);
            WiFi.begin(SSID, PSK);
            WiFi.hostname(Hostname);
            WiFi.begin(SSID, PSK);
        
            while (WiFi.status() != WL_CONNECTED)
              {
                ++wifiRetryCounter;
                if (wifiRetryCounter > 90)
                  {
                    ESP.restart();
                  }
                digitalWrite(STATUS_LED,!digitalRead(STATUS_LED));
                Serial.print(".");   
                delay(700);
              };
        
            Serial.print("Verbunden!");
            WiFi.mode(WIFI_STA);    
            wifiRetryCounter = 0;
        
        }
        
        
        
        //=======================================================================================================================
        //MQTT -Verbindung aufbauen
        //=======================================================================================================================
        void initMQTT(){
        
           
            MQTTClient.setServer(MQTTserver,port);
            MQTTClient.setCallback(MQTTcallback);
        
            Serial.println("");
            Serial.print("MQTT verbinden...");
        
            //--Verbindungsloop
            while( !MQTTClient.connect("Energie_PZEM", mqttUser, mqttPassword))   
              {
                digitalWrite(STATUS_LED,!digitalRead(STATUS_LED));
                Serial.print("*");  
                delay(100);
              };
        
            digitalWrite(STATUS_LED,false);   
            Serial.print("MQTT ist verbunden!"); 
        
            //--Topics abbonieren---------------------------------------------------- 
            if (MQTTClient.subscribe("Energie/PZEM-Reset"))
              {
                    Serial.println("MQTT : Energie: Reset aboniert"); 
              };
        
            if (MQTTClient.subscribe("Energie/Verbrauchs-Startwert"))
              {
                    Serial.println("MQTT : Energie/Verbrauchs-Startwert aboniert"); 
              }; 
        
            if (MQTTClient.subscribe("Energie/Befehl"))
              {
                    Serial.println("MQTT : Energie/Befehl aboniert"); 
              }; 
        
        }
        
        
        
        //=======================================================================================================================
        //PZEM Module auslesen und publishen
        //=======================================================================================================================
        void pzem_read(){
        
          float spannung_gesamt;
          float stromstaerke_gesamt;
          float leistung_gesamt;
          float verbrauch_gesamt;
          float frequenz_gesamt;
          float pf_gesamt;
          float PZEM_verbrauch = 0;
        
          float spannung_pzem1 = pzem_1.voltage();
        	float stromstaerke_pzem1 = pzem_1.current();
        	float leistung_pzem1 = pzem_1.power();
        	float verbrauch_pzem1 = pzem_1.energy();
        	float frequenz_pzem1 = pzem_1.frequency();
        	float pf_pzem1 = pzem_1.pf();
        	
        	float spannung_pzem2 = pzem_2.voltage();
        	float stromstaerke_pzem2 = pzem_2.current();
        	float leistung_pzem2 = pzem_2.power();
        	float verbrauch_pzem2 = pzem_2.energy();
        	float frequenz_pzem2 = pzem_2.frequency();
        	float pf_pzem2 = pzem_2.pf();
        	
        	float spannung_pzem3 = pzem_3.voltage();
        	float stromstaerke_pzem3 = pzem_3.current();
        	float leistung_pzem3 = pzem_3.power();
        	float verbrauch_pzem3 = pzem_3.energy();
        	float frequenz_pzem3 = pzem_3.frequency();
        	float pf_pzem3 = pzem_3.pf();	
        
         // char* Temp_String = "           ";
          char Temp_String[12];
        
          if(!isnan(spannung_pzem1) && old_spannung_pzem1 != spannung_pzem1)
            { 
              dtostrf(spannung_pzem1,5 , 2, Temp_String);
              MQTTClient.publish ("Energie/L1/SpannungL1", Temp_String);
              old_spannung_pzem1 = spannung_pzem1;
            }
        
          if(!isnan(spannung_pzem2) && old_spannung_pzem2 != spannung_pzem2)
            { 
              dtostrf(spannung_pzem2,5 , 2, Temp_String);
              MQTTClient.publish ("Energie/L2/SpannungL2", Temp_String);
              old_spannung_pzem2 = spannung_pzem2;
            }
        
          if(!isnan(spannung_pzem3) && old_spannung_pzem3 != spannung_pzem3)
            { 
              dtostrf(spannung_pzem3,5 , 2, Temp_String);
              MQTTClient.publish ("Energie/L3/SpannungL3", Temp_String);
              old_spannung_pzem3 = spannung_pzem3;
            }
        
          if(!isnan(stromstaerke_pzem1) && old_stromstaerke_pzem1 != stromstaerke_pzem1)
            { 
              dtostrf(stromstaerke_pzem1,5 , 2, Temp_String);
              MQTTClient.publish ("Energie/L1/StromstaerkeL1", Temp_String);
              old_stromstaerke_pzem1 = stromstaerke_pzem1;
            }
        
          if(!isnan(stromstaerke_pzem2) && old_stromstaerke_pzem2 != stromstaerke_pzem2)
            { 
              dtostrf(stromstaerke_pzem2,5 , 2, Temp_String);
              MQTTClient.publish ("Energie/L2/StromstaerkeL2", Temp_String);
              old_stromstaerke_pzem2 = stromstaerke_pzem2;
            }
        
          if(!isnan(stromstaerke_pzem3) && old_stromstaerke_pzem3 != stromstaerke_pzem3)
            { 
              dtostrf(stromstaerke_pzem3,5 , 2, Temp_String);
              MQTTClient.publish ("Energie/L3/StromstaerkeL3", Temp_String);
              old_stromstaerke_pzem3 = stromstaerke_pzem3;
            }
        
          if(!isnan(leistung_pzem1) && old_leistung_pzem1 != leistung_pzem1)
            { 
              dtostrf(leistung_pzem1,5 , 2, Temp_String);
              MQTTClient.publish ("Energie/L1/LeistungL1", Temp_String);
              old_leistung_pzem1 = leistung_pzem1;
            }
        
          if(!isnan(leistung_pzem2) && old_leistung_pzem2 != leistung_pzem2)
            { 
              dtostrf(leistung_pzem2,5 , 2, Temp_String);
              MQTTClient.publish ("Energie/L2/LeistungL2", Temp_String);
              old_leistung_pzem2 = leistung_pzem2;
            }
        
          if(!isnan(leistung_pzem3) && old_leistung_pzem3 != leistung_pzem3)
            { 
              dtostrf(leistung_pzem3,5 , 2, Temp_String);
              MQTTClient.publish ("Energie/L3/LeistungL3", Temp_String);
              old_leistung_pzem3 = leistung_pzem3;
            }
        
          if(!isnan(verbrauch_pzem1) && old_verbrauch_pzem1 != verbrauch_pzem1)
            { 
              dtostrf(verbrauch_pzem1,5 , 2, Temp_String);
              MQTTClient.publish ("Energie/L1/VerbrauchL1", Temp_String);
              old_verbrauch_pzem1 = verbrauch_pzem1;
            }
        
          if(!isnan(verbrauch_pzem2) && old_verbrauch_pzem2 != verbrauch_pzem2)
            { 
              dtostrf(verbrauch_pzem2,5 , 2, Temp_String);
              MQTTClient.publish ("Energie/L2/VerbrauchL2", Temp_String);
              old_verbrauch_pzem2 = verbrauch_pzem2;
            }
        
          if(!isnan(verbrauch_pzem3) && old_verbrauch_pzem3 != verbrauch_pzem3)
            { 
              dtostrf(verbrauch_pzem3,5 , 2, Temp_String);
              MQTTClient.publish ("Energie/L3/VerbrauchL3", Temp_String);
              old_verbrauch_pzem3 = verbrauch_pzem3;
            }
        
          if(!isnan(frequenz_pzem1) && old_frequenz_pzem1 != frequenz_pzem1)
            { 
              dtostrf(frequenz_pzem1,5 , 2, Temp_String);
              MQTTClient.publish ("Energie/L1/FrequenzL1", Temp_String);
              old_frequenz_pzem1 = frequenz_pzem1;
            } 
        
          if(!isnan(frequenz_pzem2) && old_frequenz_pzem1 != frequenz_pzem2)
            { 
              dtostrf(frequenz_pzem2,5 , 2, Temp_String);
              MQTTClient.publish ("Energie/L2/FrequenzL2", Temp_String);
              old_frequenz_pzem2 = frequenz_pzem2;
            } 
        
          if(!isnan(frequenz_pzem3) && old_frequenz_pzem3 != frequenz_pzem3)
            { 
              dtostrf(frequenz_pzem3,5 , 2, Temp_String);
              MQTTClient.publish ("Energie/L3/FrequenzL3", Temp_String);
              old_frequenz_pzem3 = frequenz_pzem3;
            } 
        
         if(!isnan(pf_pzem1) && old_pf_pzem1 != pf_pzem1)
            { 
              dtostrf(pf_pzem1,5 , 2, Temp_String);
              MQTTClient.publish ("Energie/L1/PowerFactorL1", Temp_String);
              old_pf_pzem1 = pf_pzem1;
            }  
        
         if(!isnan(pf_pzem2) && old_pf_pzem2 != pf_pzem2)
            { 
              dtostrf(pf_pzem2,5 , 2, Temp_String);
              MQTTClient.publish ("Energie/L2/PowerFactorL2", Temp_String);
              old_pf_pzem2 = pf_pzem2;
            }   
        
         if(!isnan(pf_pzem3) && old_pf_pzem3 != pf_pzem3)
          { 
            dtostrf(pf_pzem3,5 , 2, Temp_String);
            MQTTClient.publish ("Energie/L3/PowerFactorL3", Temp_String);
            old_pf_pzem3 = pf_pzem3;
          }
        
        
         if(!isnan(spannung_pzem1) && !isnan(spannung_pzem2) && !isnan(spannung_pzem3))
          {
            spannung_gesamt = (spannung_pzem1 + spannung_pzem2 + spannung_pzem3) / 3   ;
          }
         else
          {
            spannung_gesamt = 0;
          }
             
         
         if(!isnan(stromstaerke_pzem1) && !isnan(stromstaerke_pzem2) && !isnan(stromstaerke_pzem3))
          {
            stromstaerke_gesamt = stromstaerke_pzem1 + stromstaerke_pzem2 + stromstaerke_pzem3 ;
          }
         else
          {
            stromstaerke_gesamt = 0;
          } 
        
         if(!isnan(leistung_pzem1) && !isnan(leistung_pzem2) && !isnan(leistung_pzem3))
          {
            leistung_gesamt = leistung_pzem1 + leistung_pzem2 + leistung_pzem3 ;
          }
         else
          {
            leistung_gesamt = 0;
          } 
        
         if(!isnan(verbrauch_pzem1) && !isnan(verbrauch_pzem2) && !isnan(verbrauch_pzem3))
          {
            verbrauch_gesamt = verbrauch_pzem1 + verbrauch_pzem2 + verbrauch_pzem3 ;
            PZEM_verbrauch   = verbrauch_gesamt;
            verbrauch_gesamt = start_verbrauch + verbrauch_gesamt - diff_verbrauch;
          }
         else
          {
            verbrauch_gesamt = 0;
          }
        
         if(!isnan(frequenz_pzem1) && !isnan(frequenz_pzem2) && !isnan(frequenz_pzem3))
          {
            frequenz_gesamt = (frequenz_pzem1 + frequenz_pzem2 + frequenz_pzem3) / 3;
          }
         else
          {
            frequenz_gesamt = 0;
          } 
        
         if(!isnan(pf_pzem1) && !isnan(pf_pzem2) && !isnan(pf_pzem3))
          {
            pf_gesamt = (pf_pzem1 + pf_pzem2 + pf_pzem3) / 3 ;
          }
         else
          {
            pf_gesamt = 0;
          }    
        
          if (old_spannung_gesamt != spannung_gesamt)
            {
              dtostrf(spannung_gesamt,5 , 2, Temp_String);
              MQTTClient.publish("Energie/Spannung",Temp_String);  
              old_spannung_gesamt = spannung_gesamt;
            }
        
          if (old_stromstaerke_gesamt != stromstaerke_gesamt)
            {
              dtostrf(stromstaerke_gesamt,5 , 2, Temp_String);
              MQTTClient.publish("Energie/Stromstaerke",Temp_String);
              old_stromstaerke_gesamt = stromstaerke_gesamt;  
            }
          
          if (old_leistung_gesamt != leistung_gesamt)
            {
              dtostrf(leistung_gesamt,5 , 2, Temp_String);
              MQTTClient.publish("Energie/Leistung",Temp_String);    
              old_leistung_gesamt = leistung_gesamt;  
            }
        
          if (old_verbrauch_gesamt != verbrauch_gesamt)
            {
              dtostrf(verbrauch_gesamt,5 , 2, Temp_String);
              MQTTClient.publish("Energie/Verbrauch",Temp_String); 
              old_verbrauch_gesamt = verbrauch_gesamt;     
            } 
        
          if (old_frequenz_gesamt != frequenz_gesamt)
            {
              dtostrf(frequenz_gesamt,5 , 2, Temp_String);
              MQTTClient.publish("Energie/Frequenz",Temp_String);
              old_frequenz_gesamt = frequenz_gesamt;      
            } 
         
          if (old_pf_gesamt != pf_gesamt)
            {
              dtostrf(pf_gesamt,5 , 2, Temp_String);
              MQTTClient.publish("Energie/PowerFactor",Temp_String); 
              old_pf_gesamt = pf_gesamt;     
            } 
        
          if (old_PZEM_verbrauch != PZEM_verbrauch)
          {
              dtostrf(PZEM_verbrauch,5 , 2, Temp_String);
              MQTTClient.publish("Energie/PZEM-Verbrauch",Temp_String); 
              old_PZEM_verbrauch = PZEM_verbrauch; 
          }
             
        
          digitalWrite(STATUS_LED,true);
          delay(50);
          digitalWrite(STATUS_LED,false);  
        
        };
        
        
        
        //=======================================================================================================================
        //Energieverbrauch in pzem Modulen zurücksetzen
        //=======================================================================================================================
        void pzem_reset()
        {
        
          myTimer1.pause();
          Serial.println("Energieverbrauch wird zurückgesetzt..!");
          
          pzem_1.resetEnergy();
        	pzem_2.resetEnergy();
        	pzem_3.resetEnergy();
          delay(1000);
         
          myTimer1.resume();
        	
        }
        
        
        //=======================================================================================================================
        //Startwert für Verbrauchszähler setzen
        //=======================================================================================================================
        void set_counter(float counterStart){
        
          myTimer1.pause();
          
          float verbrauch_pzem1 = pzem_1.energy();
          float verbrauch_pzem2 = pzem_2.energy();
          float verbrauch_pzem3 = pzem_3.energy();
        
          float verbrauch_gesamt = verbrauch_pzem1 + verbrauch_pzem2 + verbrauch_pzem3;
          diff_verbrauch = verbrauch_gesamt;
        
          config.diff_verbrauch = diff_verbrauch; // ins eprom speichern
          saveConfig();
        
          myTimer1.resume();
        
        
        
        }
        
        // #####################################################################################################
        // #####################################################################################################
        // Die SETUP Routine
        // #####################################################################################################
        // #####################################################################################################
        void setup()
        {
        
          pinMode(STATUS_LED,OUTPUT);
          digitalWrite(STATUS_LED,LOW);
          
          Serial.begin(9600);
          delay(100);
          Serial.println("");
          Serial.println("PZEM 3-Phasen-Reader");  
          
          Serial.println(version);
          Serial.println("");
        
          loadConfig();
          start_verbrauch = config.counter_startwert;
          diff_verbrauch  = config.diff_verbrauch;
        
        
          initWiFi();
          initMQTT();
        
          MQTTClient.publish("Energie/Info",version);
          MQTTClient.publish( "Energie/Befehl", "");
        
        
          //--OTA Over the Air update einrichten
          MDNS.begin(Hostname);
          httpUpdater.setup(&httpServer);
          httpServer.begin();
          MDNS.addService("http", "tcp", 80);
          Serial.printf("HTTPUpdateServer ready! Open http://%s.local/update in your browser\n", Hostname);
          
         
          //--Timer für PZEM lesen und senden starten
          myTimer1.start();
         
        }
        
        
        // #####################################################################################################
        // #####################################################################################################
        // Die Haupt-  LOOP Routine
        // #####################################################################################################
        // #####################################################################################################
        void loop(){
        
          //--Wifi verloren? dann neu aufbauen
          if (WiFi.status() != WL_CONNECTED)
            {
              initWiFi();
            };
        
          //--MQTT Verbindung verloren? dann neu aufbauen
          if (MQTTClient.state() != MQTT_CONNECTED) 
            {
              initMQTT();
            };
        
          MQTTClient.loop();
          httpServer.handleClient();
          MDNS.update();
          myTimer1.update();
        
        
          delay(10);
        
        
        
        }
        
        S Offline
        S Offline
        spaceduck
        schrieb am zuletzt editiert von
        #101

        @HomeZecke

        Mal ne Frage: Hast Du in Deinem Aufbau Levelshifter zwischen ESP und PZEM drin? Stichwort 3,3V <-> 5V Signale...

        HP Gen8 16GB / Ubuntu Server 20.04 LTS - Nein, ein Server braucht keine GUI…;-)

        OpenSourceNomadO 1 Antwort Letzte Antwort
        0
        • S spaceduck

          @HomeZecke

          Mal ne Frage: Hast Du in Deinem Aufbau Levelshifter zwischen ESP und PZEM drin? Stichwort 3,3V <-> 5V Signale...

          OpenSourceNomadO Offline
          OpenSourceNomadO Offline
          OpenSourceNomad
          Most Active
          schrieb am zuletzt editiert von
          #102

          @spaceduck said in [Tutorial] PZEM-004T 3 Phasen Überwachung:

          Levelshifter zwischen ESP und PZEM

          Alle esp8266 haben eine eingebaute Sicherung welche auf allen GPIO Pins aktiv ist. Die snap back current beträgt um die 6V, sprich 5V Signale sind kein Problem.

          alt text

          Wer jetzt noch level shiftet hat nichts verstanden oder benutzt einen esp32 😉

          „Das Widerlegen von Schwachsinn erfordert eine Größenordnung mehr Energie als dessen Produktion.“ - Alberto Brandolini (Bullshit-Asymmetrie-Prinzip)

          S 1 Antwort Letzte Antwort
          0
          • OpenSourceNomadO OpenSourceNomad

            @spaceduck said in [Tutorial] PZEM-004T 3 Phasen Überwachung:

            Levelshifter zwischen ESP und PZEM

            Alle esp8266 haben eine eingebaute Sicherung welche auf allen GPIO Pins aktiv ist. Die snap back current beträgt um die 6V, sprich 5V Signale sind kein Problem.

            alt text

            Wer jetzt noch level shiftet hat nichts verstanden oder benutzt einen esp32 😉

            S Offline
            S Offline
            spaceduck
            schrieb am zuletzt editiert von spaceduck
            #103

            @OpenSourceNomad said in [Tutorial] PZEM-004T 3 Phasen Überwachung:

            Wer jetzt noch level shiftet hat nichts verstanden...

            Naja, ganz so pauschal würde ich das mit dem verstehen jetzt nicht sehen, denn es gibt auch noch die Gegenrichtung. Das die PZEM empfangsseitig mit 3,3V Pegel klarkommen ist schön, von daher kann man sich den Levelshifter dann natürlich sparen.

            HP Gen8 16GB / Ubuntu Server 20.04 LTS - Nein, ein Server braucht keine GUI…;-)

            -cs-- 1 Antwort Letzte Antwort
            0
            • S spaceduck

              @OpenSourceNomad said in [Tutorial] PZEM-004T 3 Phasen Überwachung:

              Wer jetzt noch level shiftet hat nichts verstanden...

              Naja, ganz so pauschal würde ich das mit dem verstehen jetzt nicht sehen, denn es gibt auch noch die Gegenrichtung. Das die PZEM empfangsseitig mit 3,3V Pegel klarkommen ist schön, von daher kann man sich den Levelshifter dann natürlich sparen.

              -cs-- Offline
              -cs-- Offline
              -cs-
              schrieb am zuletzt editiert von -cs-
              #104

              Hallo,

              da ich hier diejenigen am besten antreffe, welche es evtl. am meisten Interessiert:

              Leider ergeben sich viele Sachen anders als gedacht, deshalb möchte ich mein Set
              bestehend aus 3x PZEM-004T, D1Mini und weitere Kleinteile, welches noch nie im Einsatz war abgeben. Der D1Mini wurde mit Tasmota geflasht und ist nicht weiter eingerichtet.

              Ebay Kleinanzeigen Anzeigennr.: 1537920068

              Falls Interesse besteht, kurze PN hier mach ich 25.-€ inkl. Versand DLH innerhalb D.

              Chris

              B 1 Antwort Letzte Antwort
              0
              • Basti97B Offline
                Basti97B Offline
                Basti97
                Most Active
                schrieb am zuletzt editiert von
                #105

                Nun bin ich auch beim Planen des Projektes Pzem004 Messung.
                Nun sind mir ein paar Fragen aufgetreten.

                1. Braucht man die Diode unbedingt wenn ja für was.
                2. Für was ist der Widerstand an TX.
                3. Die Gpios des ESP sind ja nur 3V Tolerant und der pzem hat ja eine Spannung von 5V dadurch müsste ich doch ein Levelshifter dazwischen geschalten werden oder?
                  Gruß Basti

                Iobroker läuft als VM auf Proxmoxserver x folgende Hersteller im Einsatz Sonoff, Gosund, Siemens x Aofo über Tasmota x Zigbee x das Smarthome wächst und wächst

                OpenSourceNomadO 2 Antworten Letzte Antwort
                0
                • Basti97B Basti97

                  Nun bin ich auch beim Planen des Projektes Pzem004 Messung.
                  Nun sind mir ein paar Fragen aufgetreten.

                  1. Braucht man die Diode unbedingt wenn ja für was.
                  2. Für was ist der Widerstand an TX.
                  3. Die Gpios des ESP sind ja nur 3V Tolerant und der pzem hat ja eine Spannung von 5V dadurch müsste ich doch ein Levelshifter dazwischen geschalten werden oder?
                    Gruß Basti
                  OpenSourceNomadO Offline
                  OpenSourceNomadO Offline
                  OpenSourceNomad
                  Most Active
                  schrieb am zuletzt editiert von OpenSourceNomad
                  #106

                  @Basti97 said in [Tutorial] PZEM-004T 3 Phasen Überwachung:

                  Braucht man die Diode unbedingt wenn ja für was.

                  Kannst auch einfach mal ohne probieren, kaputt wird nichts dabei gehen...

                  Für was ist der Widerstand an TX.

                  Damit du mehr als einen pzem004t auf dem gleichen Bus benutzen kannst..

                  Die Gpios des ESP sind ja nur 3V Tolerant und der pzem hat ja eine Spannung von 5V dadurch müsste ich doch ein Levelshifter dazwischen geschalten werden oder?

                  Nur bei wenn du einen esp32 benutzen willst.

                  Die esp82xx sind schon wie zigfach erwähnt (z.B. drei posts über deinem ⚠ ) in der Lage 5V Signale auf den gpio's ohne Einschränkungen zu verarbeiten.

                  „Das Widerlegen von Schwachsinn erfordert eine Größenordnung mehr Energie als dessen Produktion.“ - Alberto Brandolini (Bullshit-Asymmetrie-Prinzip)

                  Johannes BauerstatterJ Basti97B 2 Antworten Letzte Antwort
                  0
                  • OpenSourceNomadO OpenSourceNomad

                    @Basti97 said in [Tutorial] PZEM-004T 3 Phasen Überwachung:

                    Braucht man die Diode unbedingt wenn ja für was.

                    Kannst auch einfach mal ohne probieren, kaputt wird nichts dabei gehen...

                    Für was ist der Widerstand an TX.

                    Damit du mehr als einen pzem004t auf dem gleichen Bus benutzen kannst..

                    Die Gpios des ESP sind ja nur 3V Tolerant und der pzem hat ja eine Spannung von 5V dadurch müsste ich doch ein Levelshifter dazwischen geschalten werden oder?

                    Nur bei wenn du einen esp32 benutzen willst.

                    Die esp82xx sind schon wie zigfach erwähnt (z.B. drei posts über deinem ⚠ ) in der Lage 5V Signale auf den gpio's ohne Einschränkungen zu verarbeiten.

                    Johannes BauerstatterJ Offline
                    Johannes BauerstatterJ Offline
                    Johannes Bauerstatter
                    schrieb am zuletzt editiert von Johannes Bauerstatter
                    #107

                    @Basti97 Ich nutze einen Wemos D1 Mini und habe die Dioden eingebaut. Den Widerstand habe ich nicht und es funktioniert in 3 Verteiler. Adressierung habe ich mittels PZEM - Tool gemacht. Ohne Diode hatte ich komische Werte.

                    Basti97B 1 Antwort Letzte Antwort
                    0
                    • OpenSourceNomadO OpenSourceNomad

                      @Malaus Ich mach das auch mittels Grafana:

                      alt text

                      Bei mir laufen die pzem-004t's mit esphome und reportieren jetzt im 5 Sekunden Takt (hatte es vorher auch schon erfolgreich mit 0,5 Sekunden am laufen, jedoch vor der Menge an zu speichernden bits vorerst kapituliert 😉 )

                      H Offline
                      H Offline
                      homecineplexx
                      schrieb am zuletzt editiert von
                      #108

                      @OpenSourceNomad hi
                      sag mal, wie hast du das mit der Unterteilung gemacht?

                      6e132ca8-8d60-40ee-b27d-8d98ce37d776-image.png

                      OpenSourceNomadO 1 Antwort Letzte Antwort
                      0
                      • H homecineplexx

                        @OpenSourceNomad hi
                        sag mal, wie hast du das mit der Unterteilung gemacht?

                        6e132ca8-8d60-40ee-b27d-8d98ce37d776-image.png

                        OpenSourceNomadO Offline
                        OpenSourceNomadO Offline
                        OpenSourceNomad
                        Most Active
                        schrieb am zuletzt editiert von OpenSourceNomad
                        #109

                        @homecineplexx said in [Tutorial] PZEM-004T 3 Phasen Überwachung:

                        sag mal, wie hast du das mit der Unterteilung gemacht?
                        alt text

                        Das sind teilweise Erfassungen von einzelnen Geräten, meist Großverbrauchern (z.B mittels Pow R2 oder anderen esphomatized Zwischensteckern) sowie auch von pzem004t's welche an bestimmten Stromkreisen hängen.

                        Dadurch habe ich genau im Blick wo und wie viel Strom läuft. Quasi so etwas wie sense versucht, nur mit dem kleinen Unterschied das es auch funktioniert 😆 und trotz mehr Hardware deutlich günstiger ist als diese teure, unnütze Box in diesem schönen Orange:

                        192a84a8-0a79-43b0-95b6-82f2c9a05583-image.png

                        „Das Widerlegen von Schwachsinn erfordert eine Größenordnung mehr Energie als dessen Produktion.“ - Alberto Brandolini (Bullshit-Asymmetrie-Prinzip)

                        H 1 Antwort Letzte Antwort
                        0
                        • D Offline
                          D Offline
                          da.phreak
                          schrieb am zuletzt editiert von
                          #110

                          Ist es wirklich nötig, zum Setzen der Adresse 230V anzuschließen? Sprich die 5V vom USB/TTL Wandler reichen nicht? Ich versuche es grad und bekommen einfach keine Verbindung, auf dem Wandler ist ein CH340. Der nächste Schritt wäre dann, 230V anzuklemmen. Wäre natürlich schöner, wenn man zum probieren ohne gefährlich Spannung testen kann.

                          D 1 Antwort Letzte Antwort
                          0
                          • OpenSourceNomadO OpenSourceNomad

                            @homecineplexx said in [Tutorial] PZEM-004T 3 Phasen Überwachung:

                            sag mal, wie hast du das mit der Unterteilung gemacht?
                            alt text

                            Das sind teilweise Erfassungen von einzelnen Geräten, meist Großverbrauchern (z.B mittels Pow R2 oder anderen esphomatized Zwischensteckern) sowie auch von pzem004t's welche an bestimmten Stromkreisen hängen.

                            Dadurch habe ich genau im Blick wo und wie viel Strom läuft. Quasi so etwas wie sense versucht, nur mit dem kleinen Unterschied das es auch funktioniert 😆 und trotz mehr Hardware deutlich günstiger ist als diese teure, unnütze Box in diesem schönen Orange:

                            192a84a8-0a79-43b0-95b6-82f2c9a05583-image.png

                            H Offline
                            H Offline
                            homecineplexx
                            schrieb am zuletzt editiert von
                            #111

                            @OpenSourceNomad ja das ist mir schon klar, was das aussagen soll und ich hab ja auch einige dieser Pow, aber ich schaff es nicht die Balken in Grafana zu erstellen, wo quasi ein Teil anzeigt was verbraucht wird, und der andere quasi zeigt wieviel erzeugt wird (zb)

                            OpenSourceNomadO 1 Antwort Letzte Antwort
                            0
                            • H homecineplexx

                              @OpenSourceNomad ja das ist mir schon klar, was das aussagen soll und ich hab ja auch einige dieser Pow, aber ich schaff es nicht die Balken in Grafana zu erstellen, wo quasi ein Teil anzeigt was verbraucht wird, und der andere quasi zeigt wieviel erzeugt wird (zb)

                              OpenSourceNomadO Offline
                              OpenSourceNomadO Offline
                              OpenSourceNomad
                              Most Active
                              schrieb am zuletzt editiert von
                              #112

                              @homecineplexx dann guck mal hier vorbei. Das ist die Vorlage die ich verwendet habe, sollte alles drin sein soweit um das in wenigen Minuten nachzubauen. 🌟

                              „Das Widerlegen von Schwachsinn erfordert eine Größenordnung mehr Energie als dessen Produktion.“ - Alberto Brandolini (Bullshit-Asymmetrie-Prinzip)

                              1 Antwort Letzte Antwort
                              1
                              • D da.phreak

                                Ist es wirklich nötig, zum Setzen der Adresse 230V anzuschließen? Sprich die 5V vom USB/TTL Wandler reichen nicht? Ich versuche es grad und bekommen einfach keine Verbindung, auf dem Wandler ist ein CH340. Der nächste Schritt wäre dann, 230V anzuklemmen. Wäre natürlich schöner, wenn man zum probieren ohne gefährlich Spannung testen kann.

                                D Offline
                                D Offline
                                da.phreak
                                schrieb am zuletzt editiert von
                                #113

                                @da-phreak said in [Tutorial] PZEM-004T 3 Phasen Überwachung:

                                Ist es wirklich nötig, zum Setzen der Adresse 230V anzuschließen? Sprich die 5V vom USB/TTL Wandler reichen nicht? Ich versuche es grad und bekommen einfach keine Verbindung, auf dem Wandler ist ein CH340. Der nächste Schritt wäre dann, 230V anzuklemmen. Wäre natürlich schöner, wenn man zum probieren ohne gefährlich Spannung testen kann.

                                Ich beantworte mir die Frage mal selbst: Ja muß man. Ich denke mal ein Teil der Elektronik wird über die anliegenden 230V versorgt. Es heißt ja auch, daß nur die USB-Schnittstelle galvanisch getrennt ist, also macht das schon Sinn.

                                Basti97B 1 Antwort Letzte Antwort
                                0
                                • OpenSourceNomadO OpenSourceNomad

                                  @Basti97 said in [Tutorial] PZEM-004T 3 Phasen Überwachung:

                                  Braucht man die Diode unbedingt wenn ja für was.

                                  Kannst auch einfach mal ohne probieren, kaputt wird nichts dabei gehen...

                                  Für was ist der Widerstand an TX.

                                  Damit du mehr als einen pzem004t auf dem gleichen Bus benutzen kannst..

                                  Die Gpios des ESP sind ja nur 3V Tolerant und der pzem hat ja eine Spannung von 5V dadurch müsste ich doch ein Levelshifter dazwischen geschalten werden oder?

                                  Nur bei wenn du einen esp32 benutzen willst.

                                  Die esp82xx sind schon wie zigfach erwähnt (z.B. drei posts über deinem ⚠ ) in der Lage 5V Signale auf den gpio's ohne Einschränkungen zu verarbeiten.

                                  Basti97B Offline
                                  Basti97B Offline
                                  Basti97
                                  Most Active
                                  schrieb am zuletzt editiert von
                                  #114

                                  @opensourcenomad Danke Ich wollte das PZEM Modul direkt nutzen (ESP12 Modul) ohne Wemos oder der gleichen. Deshalb Frage ich 🙂

                                  Iobroker läuft als VM auf Proxmoxserver x folgende Hersteller im Einsatz Sonoff, Gosund, Siemens x Aofo über Tasmota x Zigbee x das Smarthome wächst und wächst

                                  OpenSourceNomadO 1 Antwort Letzte Antwort
                                  0
                                  • Johannes BauerstatterJ Johannes Bauerstatter

                                    @Basti97 Ich nutze einen Wemos D1 Mini und habe die Dioden eingebaut. Den Widerstand habe ich nicht und es funktioniert in 3 Verteiler. Adressierung habe ich mittels PZEM - Tool gemacht. Ohne Diode hatte ich komische Werte.

                                    Basti97B Offline
                                    Basti97B Offline
                                    Basti97
                                    Most Active
                                    schrieb am zuletzt editiert von
                                    #115

                                    @johannes-bauerstatter Danke hast du die Dioden an die Kabel angelötet oder direkt auf die Leiterplatte.

                                    Iobroker läuft als VM auf Proxmoxserver x folgende Hersteller im Einsatz Sonoff, Gosund, Siemens x Aofo über Tasmota x Zigbee x das Smarthome wächst und wächst

                                    Johannes BauerstatterJ 1 Antwort Letzte Antwort
                                    0
                                    • D da.phreak

                                      @da-phreak said in [Tutorial] PZEM-004T 3 Phasen Überwachung:

                                      Ist es wirklich nötig, zum Setzen der Adresse 230V anzuschließen? Sprich die 5V vom USB/TTL Wandler reichen nicht? Ich versuche es grad und bekommen einfach keine Verbindung, auf dem Wandler ist ein CH340. Der nächste Schritt wäre dann, 230V anzuklemmen. Wäre natürlich schöner, wenn man zum probieren ohne gefährlich Spannung testen kann.

                                      Ich beantworte mir die Frage mal selbst: Ja muß man. Ich denke mal ein Teil der Elektronik wird über die anliegenden 230V versorgt. Es heißt ja auch, daß nur die USB-Schnittstelle galvanisch getrennt ist, also macht das schon Sinn.

                                      Basti97B Offline
                                      Basti97B Offline
                                      Basti97
                                      Most Active
                                      schrieb am zuletzt editiert von
                                      #116

                                      @da-phreak Also nutzt du das auch direkt ohne Pegelwandler. Da ich noch ein bisschen vorsichtig bin.

                                      Iobroker läuft als VM auf Proxmoxserver x folgende Hersteller im Einsatz Sonoff, Gosund, Siemens x Aofo über Tasmota x Zigbee x das Smarthome wächst und wächst

                                      D Johannes BauerstatterJ 2 Antworten Letzte Antwort
                                      0
                                      • Basti97B Basti97

                                        @johannes-bauerstatter Danke hast du die Dioden an die Kabel angelötet oder direkt auf die Leiterplatte.

                                        Johannes BauerstatterJ Offline
                                        Johannes BauerstatterJ Offline
                                        Johannes Bauerstatter
                                        schrieb am zuletzt editiert von
                                        #117

                                        @basti97 angelötet

                                        1 Antwort Letzte Antwort
                                        0
                                        • M Offline
                                          M Offline
                                          MichaelH
                                          schrieb am zuletzt editiert von
                                          #118

                                          Moin !

                                          Ich hab nen ESP32 mit drei PZEM-004t v3.
                                          An welche Pins kann ich beim ESP32 gehen ?
                                          Wie muss Tasmota eingestellt werden damit das klappt? Ich habe das Template vom How-to genutzt, danach ist der ESP nicht mehr gestartet.
                                          Irgendwie komm ich nicht weiter. Anscheinend hat noch niemand eine 3-Phasen Überwachung mit nem ESP32 gemacht. Ich hatte vor die Hardware UART zu nutzen. Also wie ich das verstanden habe PZEM 1 GPIO 1-3 , PZEM2 GPIO 17-16 , PZEM3 GPIO 9-10 .
                                          kann mir jemand weiterhelfen?

                                          Basti97B 1 Antwort Letzte Antwort
                                          0
                                          Antworten
                                          • In einem neuen Thema antworten
                                          Anmelden zum Antworten
                                          • Älteste zuerst
                                          • Neuste zuerst
                                          • Meiste Stimmen


                                          Support us

                                          ioBroker
                                          Community Adapters
                                          Donate

                                          373

                                          Online

                                          32.4k

                                          Benutzer

                                          81.4k

                                          Themen

                                          1.3m

                                          Beiträge
                                          Community
                                          Impressum | Datenschutz-Bestimmungen | Nutzungsbedingungen
                                          ioBroker Community 2014-2025
                                          logo
                                          • Anmelden

                                          • Du hast noch kein Konto? Registrieren

                                          • Anmelden oder registrieren, um zu suchen
                                          • Erster Beitrag
                                            Letzter Beitrag
                                          0
                                          • Aktuell
                                          • Tags
                                          • Ungelesen 0
                                          • Kategorien
                                          • Unreplied
                                          • Beliebt
                                          • GitHub
                                          • Docu
                                          • Hilfe