ESP32-SolarPowerMonitor/ESP32-SolarPowerMonitor.ino

107 lines
3.0 KiB
Arduino
Raw Permalink Normal View History

#include <Arduino.h>
2020-08-20 00:26:55 +01:00
#include <HardwareSerial.h>
#include "WiFi.h"
2020-06-24 19:06:09 +01:00
#include "WiFiMulti.h"
#include "src/InfluxDB-Client-for-Arduino/src/InfluxDbClient.h"
2020-08-19 18:17:31 +01:00
#include "src/PZEM-004T-v30/PZEM004Tv30.h"
#include "config.h"
2020-06-24 19:06:09 +01:00
WiFiMulti WiFiMulti;
InfluxDBClient client(INFLUXDB_URL, INFLUXDB_DB_NAME);
2020-08-19 18:17:31 +01:00
PZEM004Tv30 pzem(&Serial2);
2020-06-24 19:06:09 +01:00
// Data point
2020-08-20 00:26:55 +01:00
Point sensor("Solar_1");
2020-06-24 19:06:09 +01:00
2020-08-19 18:10:35 +01:00
void ConnectToWiFiMulti() {
WiFi.mode(WIFI_STA);
2020-06-24 19:06:09 +01:00
WiFiMulti.addAP(SSID, WiFiPassword);
Serial.println("Connecting Wifi...");
2020-08-19 18:10:35 +01:00
while (WiFiMulti.run() != WL_CONNECTED) {
2020-06-24 19:06:09 +01:00
delay(100);
}
2020-06-24 19:06:09 +01:00
Serial.println("");
Serial.println("WiFi connected");
Serial.println("IP address: ");
Serial.println(WiFi.localIP());
}
2020-08-19 18:10:35 +01:00
void ConnectToInflux() {
2020-06-24 19:06:09 +01:00
// Add constant tags - only once
2020-08-20 00:26:55 +01:00
sensor.addTag("device", "ESP32-Solar");
2020-06-24 19:06:09 +01:00
// Check server connection
if (client.validateConnection()) {
Serial.print("Connected to InfluxDB: ");
Serial.println(client.getServerUrl());
} else {
Serial.print("InfluxDB connection failed: ");
Serial.println(client.getLastErrorMessage());
}
}
void setup() {
Serial.begin(115200);
2020-06-24 19:06:09 +01:00
ConnectToWiFiMulti();
ConnectToInflux();
}
void loop() {
2020-08-20 00:26:55 +01:00
sensor.clearFields();
sensor.addField("wifi-rssi", WiFi.RSSI());
float voltage = pzem.voltage();
2020-08-19 18:17:31 +01:00
if(!isnan(voltage)){
2020-08-20 00:26:55 +01:00
sensor.addField("voltage", voltage);
2020-08-19 18:17:31 +01:00
Serial.print("Voltage: "); Serial.print(voltage); Serial.println("V");
} else {
Serial.println("Error reading voltage");
}
float current = pzem.current();
if(!isnan(current)){
2020-08-20 00:26:55 +01:00
sensor.addField("current", current);
2020-08-19 18:17:31 +01:00
Serial.print("Current: "); Serial.print(current); Serial.println("A");
} else {
Serial.println("Error reading current");
}
float power = pzem.power();
if(!isnan(power)){
2020-08-20 00:26:55 +01:00
sensor.addField("power", power);
2020-08-19 18:17:31 +01:00
Serial.print("Power: "); Serial.print(power); Serial.println("W");
} else {
Serial.println("Error reading power");
}
float energy = pzem.energy();
if(!isnan(energy)){
2020-08-20 00:26:55 +01:00
sensor.addField("energy", energy);
2020-08-19 18:17:31 +01:00
Serial.print("Energy: "); Serial.print(energy,3); Serial.println("kWh");
} else {
Serial.println("Error reading energy");
}
float frequency = pzem.frequency();
if(!isnan(frequency)){
2020-08-20 00:26:55 +01:00
sensor.addField("freq", frequency);
2020-08-19 18:17:31 +01:00
Serial.print("Frequency: "); Serial.print(frequency, 1); Serial.println("Hz");
} else {
Serial.println("Error reading frequency");
}
float pf = pzem.pf();
if(!isnan(pf)){
2020-08-20 00:26:55 +01:00
sensor.addField("power-factor", pf);
2020-08-19 18:17:31 +01:00
Serial.print("PF: "); Serial.println(pf);
} else {
Serial.println("Error reading power factor");
}
2020-08-20 00:26:55 +01:00
// If no Wifi signal, try to reconnect it
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);
}