viewtopic.php?t=16100
Generalnie do tego urządzenia mam podpięty tylko czujnik ds18 który mierzy temperaturę w słońcu, dht22 mierzący temp i wilgotność w kuchni, czujnik deszczu i czujnik wiatru.
Jako, że chciałem przedstawiać odczyty czujników na stronie www, zainteresowałem się serwisami aqi.eco i weathercloud.
Na starcie serwis aqi przegrał, bo tam każde urządzenie wysyłające musi przesyłać też dane z czujnika jakości powietrza. U mnie to odpadało bo za komplet odczytów odpowiada kilka esp. Na jednym mam PMS5003, na kolejnym zewnętrzną wilgotność i ciśnienie z BME(P)280, temperaturę chciałem wziąć tą przy gruncie do wyświetlenia, więc kolejny esp tym razem esp32, no i wreszcie ten esp od wiatru, deszczu.
Więc uznałem, że będę przesyłał na weathercloud.
Po wgryzieniu się w temat, opisywany też tutaj:
https://forbot.pl/forum/topic/24726-dar ... /#comments
oraz tutaj, ale o tym później:
viewtopic.php?t=14698&start=200
okazało się, że na weathercloud owszem można wysyłać na jedno konto dane z kilku urządzeń ale żeby wyświetlać dane z czujnika jakości powietrza trzeba wykupić plan za prawie 50 euro rocznie.
W międzyczasie narodził się pomysł by pobierać potrzebne dane z clouda Supli na jedno esp, a następnie całą paczkę wysyłać na aqi i weatherclouda. Tak też zrobiłem w tym szkicu.
Pobieram przez linki bezpośrednie aktualny stan interesujących mnie czujników, dodaję odczyty z wiatru i deszczu i wysyłam na serwery www.
Dodatkowo dla weatherclouda liczę jeszcze jakieś indeky ciepła, punkt rosy i temperaturę odczuwalną.
Po wymianie kilku maili z Tomkiem od aqi.eco, któremu bardzo dziękuję za pomoc w zaznajomieniu się z aqi i wychwycenie kilku błędów, udało mi się go namówić na dodanie do aqi.eco wyświetlanie prędkości wiatru i ilości opadów. Wszystko macie w szkicu.
Ostatnia sprawa, wyszedł babol z opadami deszczu w KPOP , a dokładnie z odpowiednim ich wyświetlaniem na wykresach Supli. Okazało się, że wykresy w Supli dla mniejszej rozdzielczości danych niż minutowa, uśredniają odczyty. Czyli jeśli wysyłamy dane np przez godzinę, ale tylko w jednym przesyle był pomiar deszczu większy niż zero, to na wykresach będzie to uśrednione dla godziny/ilość zapisów. Czyli wykres godzinowy, dzienny będzie pokazywał bzdury dla odczytu ilości opadów, jedynie wykres minutowy pokazuje prawdę. Teoretycznie da się to podobno jakoś obejść modyfikując kod KLOPa, lub modyfikując kod ImpulseCounter, tak by do każdego impulsu dało się przypisać ilość mniejszą niż 1, ale ja nie potrafię. Może kolega @klew coś podziała. Póki co zostawiam dla odczytu deszczu KPOPa, pamiętając o tym by przeglądając wykresy mieć ustawiony tryb minutowy.
Poniżej szkic, napisany w prosty sposób, na pewno można by go jeszcze bardziej zrobić czytelnym, ale jak pisałem powstawał w sposób ewolucyjny. Komentarzy w szkicu mało, jakby coś było nieczytelne to pytajcie. Wszelkie "xxx" wiadomo do wypełnienia Waszymi unikalnymi danymi.
Code: Select all
#include <SuplaDevice.h>
#include <Timers.h>
#include <supla/sensor/DHT.h>
#include <supla/sensor/DS18B20.h>
#include <supla/network/esp_wifi.h>
#include <supla/sensor/general_purpose_measurement.h>
#include <ESP8266HTTPClient.h>
#include <ArduinoJson.h>
String jsonBuffer;
Supla::ESPWifi wifi("xxx", "xxx);
char server [] = "https://api.weathercloud.net";
char IDKryry [] = "xxx";
char KeyKryry [] = "xxx";
#define dsPin 14 //D5
#define dhtPin 5 //D1
#define windPin 12 //D6
#define rainPin 2 //D4
Timer minuta;
Timer sekund1;
Timer sekund6;
Timer minut10;
int rai=0;
bool r=0;
float mmM2=0;
int WCpressure = 0;
int WChumidity = 0;
int WCgruntTemp = 0;
int WCpm25 = 0;
int WCpm10 = 0;
int WCpm1 = 0;
int WCaverage_kmh = 0;
float punkt_rosy; // dew point (C)
float heatIndex;
float t_odczuwal;
#define c1 (-42.379)
#define c2 (2.04901523)
#define c3 (10.14333127)
#define c4 (-0.22475541)
#define c5 (-0.00683783)
#define c6 (-0.05481717)
#define c7 (0.00122874)
#define c8 (0.00085282)
#define c9 (-0.00000199)
volatile int half_revolutions_time = 2; //Utworzenie zmiennej połowa pełnego obrotu (half revolutions)
volatile int rpm = 0;
unsigned long static last_event = 0;
unsigned long static last_event1 = 0;
int sample = 0;
float moment_kmh;
float temp_kmh;
float correct_moment_kmh;
float average_kmh;
float pressure =0;
float gruntTemp =0;
Supla::Sensor::GeneralPurposeMeasurement *moment_wind = nullptr;
Supla::Sensor::GeneralPurposeMeasurement *average_wind = nullptr;
Supla::Sensor::GeneralPurposeMeasurement *rain = nullptr;
void ICACHE_RAM_ATTR rn(){// wektor przerwania deszczomierza
unsigned long static last_event1 = 0;
if (millis() - last_event1 < 50) { //debouncing
return;
}
rai++;
last_event1 = millis();
}
void ICACHE_RAM_ATTR rpm_fan() { //funkcja rpm_fan
if (millis() - last_event < 5) { //debouncing
return;
}
half_revolutions_time = (millis() - last_event);
last_event = millis();
}
void temporaryRPM(){
noInterrupts();
if((last_event + 2000) < millis()){
rpm=0;
moment_kmh = 0;
correct_moment_kmh = 0;
}
else{
rpm = (30000 / half_revolutions_time) ;
moment_kmh = 6.28 * 0.075 * rpm/60.0 * 3.6;// pi x promień czujnika x rpm/60s x ms->km/h
if(moment_kmh < 10){
correct_moment_kmh = moment_kmh * 2.8;
}
else if((moment_kmh >= 10) && (moment_kmh < 25)){
correct_moment_kmh = moment_kmh * 2.7;
}
else if(moment_kmh >= 25){
correct_moment_kmh = moment_kmh * 2.8;
}
}
if(sekund6.available()){
temp_kmh = temp_kmh + correct_moment_kmh;
sample++;
sekund6.restart();
}
if(sample==10){
average_kmh = temp_kmh / 10;
temp_kmh = 0;
sample=0;
sekund6.restart();
}
interrupts() ; //Przywróć przerwania
}
void setup() {
Serial.begin(9600);
// Replace the falowing GUID with value that you can retrieve from https://www.supla.org/arduino/get-guid
char GUID[SUPLA_GUID_SIZE] = {xxx};
// Replace the following AUTHKEY with value that you can retrieve from: https://www.supla.org/arduino/get-authkey
char AUTHKEY[SUPLA_AUTHKEY_SIZE] = {xxx};
new Supla::Sensor::DS18B20(dsPin);
new Supla::Sensor::DHT(dhtPin, DHT22);
moment_wind = new Supla::Sensor::GeneralPurposeMeasurement();
average_wind = new Supla::Sensor::GeneralPurposeMeasurement();
rain = new Supla::Sensor::GeneralPurposeMeasurement();
pinMode(windPin,INPUT_PULLUP);
pinMode(rainPin,INPUT_PULLUP);
attachInterrupt(digitalPinToInterrupt(rainPin), rn, RISING);
attachInterrupt(digitalPinToInterrupt(windPin), rpm_fan, FALLING);
minuta.begin(59999);
sekund6.begin(6000);
sekund1.begin(1000);
minut10.begin(610000);
last_event = millis();
last_event1 = millis();
SuplaDevice.begin(GUID, // Global Unique Identifier
"sxxx.supla.org", // SUPLA server address
"xxx", // Email address used to login to Supla Cloud
AUTHKEY); // Authorization key
}
void loop() {
SuplaDevice.iterate();
temporaryRPM();
sendToAll();
}
void sendToAll(){
if(sekund1.available()){
moment_wind->setValue(correct_moment_kmh);
sekund1.restart();
}
if(minuta.available()){
average_wind->setValue(average_kmh);
minuta.restart();
}
if(minut10.available()){
mmM2=rai*0.15; // dwa przerwnia na jedną kolebkę, więc 0.15
rain->setValue(mmM2);
rai=0;
weathercloud();
minut10.restart();
}
}
void weathercloud(){
int WCmmM2 = mmM2 *10;
///////////////////////////////////////////////////////////////////////////////
WCaverage_kmh = (average_kmh * 10) / 3.6; //km/h->m/s
String serverPathPM_pm1 = "https://svrxx.supla.org/direct/xxx/xxx/read?format=json";
String serverPathPM_pm25 = "https://svrxx.supla.org/direct/xxx/xxxx/read?format=json";
String serverPathPM_pm10 = "https://svrxx.supla.org/direct/xxx/xxx/read?format=json";
String serverPathGRUNT_temp = "https://svrxx.supla.org/direct/xxx/xxx/read?format=json";
String serverPathZEW_press = "https://svrxx.supla.org/direct/xxx/xxx/read?format=json";
String serverPathZEW_hum = "https://svrxx.supla.org/direct/xxx/xxxxread?format=json";
punkt_rosy = (dewPoint(gruntTemp, WChumidity))*10;
heatindex();
windchill();
String serverPathWC = String(server) + "/v01/set/wid/" + String(IDKryry) + "/key/" + String(KeyKryry)
+ "/temp/" + String(WCgruntTemp) + "/hum/" + String(WChumidity)
+ "/bar/" + String(WCpressure) + "/wspd/" + String(WCaverage_kmh) + "/heat/" + String(heatIndex)
+ "/rainrate/" + String(WCmmM2) + "/dew/" + String(punkt_rosy) + "/chill/" + String(t_odczuwal);
// + "/pm25/" + String(WCpm25) + "/pm10/" + String(WCpm10);
String serverPath_aqi = "https://api.aqi.eco/update/xxx";
jsonBuffer = httpGET_PM_pm1(serverPathPM_pm1.c_str());
jsonBuffer = httpGET_PM_pm25(serverPathPM_pm25.c_str());
jsonBuffer = httpGET_PM_pm10(serverPathPM_pm10.c_str());
jsonBuffer = httpGET_GRUNT_temp(serverPathGRUNT_temp.c_str());
jsonBuffer = httpGET_ZEW_hum(serverPathZEW_hum.c_str());
jsonBuffer = httpGET_ZEW_press(serverPathZEW_press.c_str());
jsonBuffer = httpGETWC(serverPathWC.c_str());
jsonBuffer = httpPOSTaqi(serverPath_aqi.c_str());
Serial.println(jsonBuffer);
}
String httpGET_PM_pm1(const char* serverName) {
WiFiClientSecure client1;
HTTPClient http1;
client1.setInsecure();
http1.begin(client1, serverName);
// Send HTTP POST request
int httpResponseCode = http1.GET();
String payload = "{}";
if (httpResponseCode>0) {
Serial.print("HTTP Response code: ");
Serial.println(httpResponseCode);
payload = http1.getString();
DynamicJsonDocument doc(1024);
deserializeJson(doc, payload);
WCpm1 = doc["value"];
Serial.print("pm1: ");
Serial.println(WCpm1);
}
else {
Serial.print("Error code: ");
Serial.println(httpResponseCode);
}
http1.end();
return payload;
}
String httpGET_PM_pm25(const char* serverName) {
WiFiClientSecure client1;
HTTPClient http1;
client1.setInsecure();
http1.begin(client1, serverName);
// Send HTTP POST request
int httpResponseCode = http1.GET();
String payload = "{}";
if (httpResponseCode>0) {
Serial.print("HTTP Response code: ");
Serial.println(httpResponseCode);
payload = http1.getString();
DynamicJsonDocument doc(1024);
deserializeJson(doc, payload);
WCpm25 = doc["value"];
Serial.print("pm2,5: ");
Serial.println(WCpm25);
}
else {
Serial.print("Error code: ");
Serial.println(httpResponseCode);
}
http1.end();
return payload;
}
String httpGET_PM_pm10(const char* serverName) {
WiFiClientSecure client1;
HTTPClient http1;
client1.setInsecure();
http1.begin(client1, serverName);
// Send HTTP POST request
int httpResponseCode = http1.GET();
String payload = "{}";
if (httpResponseCode>0) {
Serial.print("HTTP Response code: ");
Serial.println(httpResponseCode);
payload = http1.getString();
DynamicJsonDocument doc(1024);
deserializeJson(doc, payload);
WCpm10 = doc["value"];
Serial.print("pm10: ");
Serial.println(WCpm10);
}
else {
Serial.print("Error code: ");
Serial.println(httpResponseCode);
}
http1.end();
return payload;
}
String httpGET_GRUNT_temp(const char* serverName) {
WiFiClientSecure client1;
HTTPClient http1;
client1.setInsecure();
http1.begin(client1, serverName);
// Send HTTP POST request
int httpResponseCode = http1.GET();
String payload = "{}";
if (httpResponseCode>0) {
Serial.print("HTTP Response code: ");
Serial.println(httpResponseCode);
payload = http1.getString();
DynamicJsonDocument doc(1024);
deserializeJson(doc, payload);
gruntTemp = doc["temperature"];
if(gruntTemp > -273){
WCgruntTemp = gruntTemp *10;
}
Serial.print("tempGrunt: ");
Serial.println(gruntTemp);
Serial.print("tempGruntWC: ");
Serial.println(WCgruntTemp);
}
else {
Serial.print("Error code: ");
Serial.println(httpResponseCode);
}
http1.end();
return payload;
}
String httpGET_ZEW_hum(const char* serverName) {
WiFiClientSecure client1;
HTTPClient http1;
client1.setInsecure();
http1.begin(client1, serverName);
// Send HTTP POST request
int httpResponseCode = http1.GET();
String payload = "{}";
if (httpResponseCode>0) {
Serial.print("HTTP Response code: ");
Serial.println(httpResponseCode);
payload = http1.getString();
DynamicJsonDocument doc(1024);
deserializeJson(doc, payload);
WChumidity = doc["humidity"];
Serial.print("humidityZewWC: ");
Serial.println(WChumidity);
}
else {
Serial.print("Error code: ");
Serial.println(httpResponseCode);
}
http1.end();
return payload;
}
String httpGET_ZEW_press(const char* serverName) {
WiFiClientSecure client1;
HTTPClient http1;
client1.setInsecure();
http1.begin(client1, serverName);
// Send HTTP POST request
int httpResponseCode = http1.GET();
String payload = "{}";
if (httpResponseCode>0) {
Serial.print("HTTP Response code: ");
Serial.println(httpResponseCode);
payload = http1.getString();
DynamicJsonDocument doc(1024);
deserializeJson(doc, payload);
pressure = doc["value"];
WCpressure = pressure *10;
Serial.print("pressureWC: ");
Serial.println(WCpressure);
}
else {
Serial.print("Error code: ");
Serial.println(httpResponseCode);
}
http1.end();
return payload;
}
String httpGETWC(const char* serverName) {
WiFiClientSecure client1;
HTTPClient http1;
client1.setInsecure();
http1.begin(client1, serverName);
// Send HTTP POST request
int httpResponseCode = http1.GET();
String payload = "{}";
if (httpResponseCode>0) {
Serial.print("HTTP Response code: ");
Serial.println(httpResponseCode);
payload = http1.getString();
}
else {
Serial.print("Error code: ");
Serial.println(httpResponseCode);
}
http1.end();
return payload;
}
String httpPOSTaqi(const char* serverName) {
float AQIpressure = pressure*100;
WiFiClientSecure client1;
HTTPClient http1;
client1.setInsecure();
http1.begin(client1, serverName);
http1.addHeader("Content-Type", "application/json");
int httpResponseCode = http1.POST("{\"esp8266id\": \"123123123\",\"sensordatavalues\":[{\"value_type\":\"PMS_P0\",\"value\":" + String(WCpm1) + "},{\"value_type\":\"PMS_P2\",\"value\":" + String(WCpm25) + "}, {\"value_type\":\"PMS_P1\",\"value\":" + String(WCpm10) + "},{\"value_type\":\"BME280_temperature\",\"value\":" + String(gruntTemp) + "},{\"value_type\":\"BME280_humidity\",\"value\":" + String(WChumidity) + "},{\"value_type\":\"wind_speed\",\"value\":" + String(WCaverage_kmh) + "},{\"value_type\":\"rainfall\",\"value\":" + String(mmM2) + "},{\"value_type\":\"BME280_pressure\",\"value\":" + String(AQIpressure) + "}]}");
String payload = "{}";
if (httpResponseCode>0) {
Serial.print("HTTP Response code: ");
Serial.println(httpResponseCode);
payload = http1.getString();
}
else {
Serial.print("Error code: ");
Serial.println(httpResponseCode);
}
http1.end();
return payload;
}
double dewPoint(double tempc_min, double humidity){
double RATIO = 373.15 / (273.15 + tempc_min); // RATIO was originally named A0, possibly confusing in Arduino context
double SUM = -7.90298 * (RATIO - 1);
SUM += 5.02808 * log10(RATIO);
SUM += -1.3816e-7 * (pow(10, (11.344 * (1 - 1/RATIO ))) - 1) ;
SUM += 8.1328e-3 * (pow(10, (-3.49149 * (RATIO - 1))) - 1) ;
SUM += log10(1013.246);
double VP = pow(10, SUM - 3) * humidity;
double T = log(VP/0.61078); // temp var
return (241.88 * T) / (17.558 - T);
}
void heatindex(){
float temp_f = (gruntTemp*1.8)+32;
if (temp_f > 80.0) //The heat index only works for temperatures above 80°F
{
float heat_f = c1+c2*(temp_f)+c3*(WChumidity)+c4*(temp_f)*(WChumidity)+c5*(pow(temp_f,2))+c6*(pow(WChumidity,2))+c7*(pow(temp_f, 2))*(WChumidity)+c8*(temp_f)*(pow(WChumidity, 2))+c9*(pow(temp_f, 2))*(pow(WChumidity, 2));
heatIndex = ((heat_f - 32)*5/9)*10; // converting to C and x10 to WC
}
else
{
heatIndex = gruntTemp*10;
}
}
void windchill(){
float temp_f = (gruntTemp*1.8)+32;
if ((temp_f <50.0) && (average_kmh > 3.6)) //The wind chill only works for temperatures below 50°F and wind speed above 3 mph. (10°C , 1 m/s)
{
float chill_f =35.74+0.6215*temp_f-35.75*pow(average_kmh,0.16)+0.4275*temp_f*pow(average_kmh,0.16);
t_odczuwal = ((chill_f - 32)*5/9)*10; // converting to C
}
else
{
t_odczuwal = gruntTemp*10;
}
}