Initial Release

Author: domoticsduino

platformio.ini

@@ -0,0 +1,18 @@
+; PlatformIO Project Configuration File
+;
+;   Build options: build flags, source filter
+;   Upload options: custom upload port, speed and extra flags
+;   Library options: dependencies, extra library storages
+;   Advanced options: extra scripting
+;
+; Please visit documentation for the other options and examples
+; https://docs.platformio.org/page/projectconf.html
+
+[env:esp12e]
+platform = espressif8266
+board = esp12e
+framework = arduino
+lib_deps = 
+	bblanchon/ArduinoJson@5.13.4
+	knolleary/PubSubClient@^2.8
+	olehs/PZEM004T@^1.1.5

src/config.h

@@ -0,0 +1,35 @@
+/* 1.0.0 VERSION */
+
+#ifndef config_h
+#define config_h
+
+// USER SETTINGS
+#include "user-config.h"
+
+// GENERAL SETTINGS
+#define READ_INTERVAL 2000 //ms
+#define MAX_SAMPLES 30
+#define DIFF_POWER_TRIGGER 2 //W
+#define LEDSTATUSPIN 2 //BUILTIN
+#define SERIAL_BAUDRATE 9600
+
+// PZEM SETTINGS
+#define PZEMPIN1 4 // PZEM PIN SERIAL IN
+#define PZEMPIN2 5 // PZEM PIN SERIAL OUT
+
+// WIFI SETTINGS (see user-config.h)
+const char *ssid = USER_SETTINGS_WIFI_SSID;
+const char *password = USER_SETTINGS_WIFI_PASSWORD;
+const char *wifihostname = USER_SETTINGS_WIFI_HOSTNAME;
+
+// MQTT SETTINGS (see user-config.h)
+const char MQTT_HOST[] = USER_SETTINGS_MQTT_HOST;
+int MQTT_PORT = USER_SETTINGS_MQTT_PORT;
+const char TOPIC_P[] = USER_SETTINGS_MQTT_TOPIC_P;
+const char TOPIC_S[] = USER_SETTINGS_MQTT_TOPIC_S;
+const char DEVICE[] = USER_SETTINGS_MQTT_DEVICE;
+const char MQTT_USER[] = USER_SETTINGS_MQTT_USER;
+const char MQTT_PWD[] = USER_SETTINGS_MQTT_PWD;
+int MQTT_QOS = USER_SETTINGS_MQTT_QOS;
+
+#endif

src/main.cpp

@@ -0,0 +1,102 @@
+/* 1.0.0 VERSION */
+
+#include <Arduino.h>
+#include <ArduinoJson.h>
+
+#include "config.h"
+
+#include <ddcommon.h>
+#include <ddwifi.h>
+#include <ddmqtt.h>
+#include <ddpzem004t.h>
+
+//Wifi
+DDWifi wifi(ssid, password, wifihostname, LEDSTATUSPIN);
+
+//MQTT
+DDMqtt clientMqtt(DEVICE, MQTT_HOST, MQTT_PORT, MQTT_USER, MQTT_PWD, TOPIC_S, MQTT_QOS, LEDSTATUSPIN);
+
+//PZEM
+DDPzem004t pzemWrapper(LEDSTATUSPIN);
+
+PZEM004T pzemPower = PZEM004T(PZEMPIN1, PZEMPIN2);
+IPAddress ipPower = IPAddress(192, 168, 1, 1);
+float lastPowerTriggerValue;
+
+//JSON
+DynamicJsonBuffer jsonBuffer;
+JsonObject& configRoot = jsonBuffer.createObject();
+JsonObject& root = jsonBuffer.createObject();
+
+unsigned long startMillis;
+
+void createJsonConfig(){
+    configRoot["readInterval"] = READ_INTERVAL;
+    configRoot["maxSamples"] = MAX_SAMPLES;
+}
+
+void printDebugPowerData(DDPZEM004TVal values){
+    writeToSerial("POWER READ Success = ", false);
+    writeToSerial(values.success ? "True" : "False", true);
+    if(values.success){
+        writeToSerial("Voltage: ", false);
+        writeToSerial(values.voltage, false);
+        writeToSerial(" V ", true);
+        writeToSerial("Current: ", false);
+        writeToSerial(values.current, false);
+        writeToSerial(" A ", true);
+        writeToSerial("Power: ", false);
+        writeToSerial(values.power, false);
+        writeToSerial(" W ", true);
+        writeToSerial("Energy: ", false);
+        writeToSerial(values.energy, false);
+        writeToSerial(" Wh ", true);
+    }
+}   
+
+String generateJsonMessage(DDPZEM004TVal values){
+    root["voltage"] = values.voltage;
+    root["current"] = values.current;
+    root["power"] = values.power;
+    root["energy"] = values.energy;
+    String json;
+    root.printTo(json);
+    return json;
+}
+
+void setup() {
+    createJsonConfig();    
+    pinMode(LEDSTATUSPIN, OUTPUT);
+    digitalWrite(LEDSTATUSPIN, LOW);
+    if(SERIAL_ENABLED)
+        Serial.begin(SERIAL_BAUDRATE);
+    writeToSerial("ESP8266MCU12 Booting...", true);
+
+    // WIFI
+    wifi.connect();
+
+    //MQTT
+    clientMqtt.reconnectMQTT(&startMillis);
+
+    //PZEM
+    pzemWrapper.init(&pzemPower, ipPower);
+
+    lastPowerTriggerValue = -999.0;
+    startMillis = millis();
+}
+
+void loop() {
+
+    // Wait a few seconds between measurements.
+    if(myDelay(configRoot["readInterval"], &startMillis)){
+        clientMqtt.loop();
+        DDPZEM004TVal values = pzemWrapper.getValues(&pzemPower, ipPower);
+        printDebugPowerData(values);
+        writeToSerial("lastPowerTriggerValue ", false);
+        writeToSerial(lastPowerTriggerValue, true);
+        if(abs(lastPowerTriggerValue - values.power) >= DIFF_POWER_TRIGGER || (lastPowerTriggerValue != values.power && values.power == 0)){
+            clientMqtt.sendMessage(TOPIC_P, generateJsonMessage(values), &startMillis);
+            lastPowerTriggerValue = values.power;
+        }
+    }
+}

src/user-config-template.h

@@ -0,0 +1,21 @@
+/* 1.0.0 VERSION */
+
+#ifndef user_config_h
+#define user_config_h
+
+// WIFI SETTINGS
+#define USER_SETTINGS_WIFI_SSID "X"
+#define USER_SETTINGS_WIFI_PASSWORD "X"
+#define USER_SETTINGS_WIFI_HOSTNAME "X"
+
+// MQTT SETTINGS
+#define USER_SETTINGS_MQTT_HOST "X"
+#define USER_SETTINGS_MQTT_PORT 1833
+#define USER_SETTINGS_MQTT_TOPIC_P "X"
+#define USER_SETTINGS_MQTT_TOPIC_S "X" // not used
+#define USER_SETTINGS_MQTT_DEVICE "X"
+#define USER_SETTINGS_MQTT_USER "X"
+#define USER_SETTINGS_MQTT_PWD "X"
+#define USER_SETTINGS_MQTT_QOS 1
+
+#endif