This commit is contained in:
José Valdiviesso 2020-08-20 00:26:55 +01:00
parent 99db005d4c
commit 49b1e9c35f
1 changed files with 23 additions and 12 deletions

View File

@ -1,4 +1,5 @@
#include <Arduino.h> #include <Arduino.h>
#include <HardwareSerial.h>
#include "WiFi.h" #include "WiFi.h"
#include "WiFiMulti.h" #include "WiFiMulti.h"
#include "src/InfluxDB-Client-for-Arduino/src/InfluxDbClient.h" #include "src/InfluxDB-Client-for-Arduino/src/InfluxDbClient.h"
@ -10,7 +11,7 @@ InfluxDBClient client(INFLUXDB_URL, INFLUXDB_DB_NAME);
PZEM004Tv30 pzem(&Serial2); PZEM004Tv30 pzem(&Serial2);
// Data point // Data point
Point sensor("solar_status"); Point sensor("Solar_1");
void ConnectToWiFiMulti() { void ConnectToWiFiMulti() {
WiFi.mode(WIFI_STA); WiFi.mode(WIFI_STA);
@ -27,7 +28,7 @@ void ConnectToWiFiMulti() {
void ConnectToInflux() { void ConnectToInflux() {
// Add constant tags - only once // Add constant tags - only once
sensor.addTag("Phase", "Solar 1"); sensor.addTag("device", "ESP32-Solar");
// Check server connection // Check server connection
if (client.validateConnection()) { if (client.validateConnection()) {
@ -43,53 +44,63 @@ void setup() {
Serial.begin(115200); Serial.begin(115200);
ConnectToWiFiMulti(); ConnectToWiFiMulti();
ConnectToInflux(); ConnectToInflux();
// Add constant tags - only once
sensor.addTag("device", "ESP32-Solar");
} }
void loop() { void loop() {
float voltage = pzem.voltage(); sensor.clearFields();
sensor.addField("wifi-rssi", WiFi.RSSI());
float voltage = pzem.voltage();
if(!isnan(voltage)){ if(!isnan(voltage)){
sensor.addField("voltage", voltage);
Serial.print("Voltage: "); Serial.print(voltage); Serial.println("V"); Serial.print("Voltage: "); Serial.print(voltage); Serial.println("V");
} else { } else {
Serial.println("Error reading voltage"); Serial.println("Error reading voltage");
} }
float current = pzem.current(); float current = pzem.current();
if(!isnan(current)){ if(!isnan(current)){
sensor.addField("current", current);
Serial.print("Current: "); Serial.print(current); Serial.println("A"); Serial.print("Current: "); Serial.print(current); Serial.println("A");
} else { } else {
Serial.println("Error reading current"); Serial.println("Error reading current");
} }
float power = pzem.power(); float power = pzem.power();
if(!isnan(power)){ if(!isnan(power)){
sensor.addField("power", power);
Serial.print("Power: "); Serial.print(power); Serial.println("W"); Serial.print("Power: "); Serial.print(power); Serial.println("W");
} else { } else {
Serial.println("Error reading power"); Serial.println("Error reading power");
} }
float energy = pzem.energy(); float energy = pzem.energy();
if(!isnan(energy)){ if(!isnan(energy)){
sensor.addField("energy", energy);
Serial.print("Energy: "); Serial.print(energy,3); Serial.println("kWh"); Serial.print("Energy: "); Serial.print(energy,3); Serial.println("kWh");
} else { } else {
Serial.println("Error reading energy"); Serial.println("Error reading energy");
} }
float frequency = pzem.frequency(); float frequency = pzem.frequency();
if(!isnan(frequency)){ if(!isnan(frequency)){
sensor.addField("freq", frequency);
Serial.print("Frequency: "); Serial.print(frequency, 1); Serial.println("Hz"); Serial.print("Frequency: "); Serial.print(frequency, 1); Serial.println("Hz");
} else { } else {
Serial.println("Error reading frequency"); Serial.println("Error reading frequency");
} }
float pf = pzem.pf(); float pf = pzem.pf();
if(!isnan(pf)){ if(!isnan(pf)){
sensor.addField("power-factor", pf);
Serial.print("PF: "); Serial.println(pf); Serial.print("PF: "); Serial.println(pf);
} else { } else {
Serial.println("Error reading power factor"); Serial.println("Error reading power factor");
} }
Serial.println(); // If no Wifi signal, try to reconnect it
delay(2000); if ((WiFi.RSSI() == 0) && (WiFiMulti.run() != WL_CONNECTED))
Serial.println("Wifi connection lost");
// Write point
if (!client.writePoint(sensor)) {
Serial.print("InfluxDB write failed: ");
Serial.println(client.getLastErrorMessage());
}
//Wait 5s
Serial.println("Wait 5s");
delay(5000);
} }