Wetterstation Ventus W830 parsing mit ESP8266

FatBob

Hallo Zusammen,

Ich beschäftige mich jetzt seit ca. 2 Monaten mit dem ioBroker, habe schon einige Anregungen und Lösungen aus diesem Forum entnommen und habe mich jetzt heute hier angemeldet um vielleicht auch mal eine Lösung beizutragen.

Es geht mal wieder um die Wetterstationen, ich habe mir eine Ventus W830 gekauft, da hier die Diskussion im Gange war und das Shell-Script von @SBorg vorhanden war.

Ich hab das dann eingesetzt und es hat alles gut funktioniert.

Da bei mir der ioBroker aber auf meiner Diskstation in einem Docker Container (und da ist kein bc installiert) läuft , würde der Raspi nur dafür gebraucht und ich brauche den für was anderes.

Also musste eine andere Lösung her.

Nun gibt es diese wunderbaren ESP8266 boards (5 €...)
Langer Rede kurzer Sinn: Kleines Programm drauf, läuft...

Kurz zur Vorgangsweise:

Grundsätzlich setzt das Ganze genau auf die Vorgangsweise von @SBorg auf,
nachzulesen in diesem Thread.

Man braucht genau wie bei der Shell-Script Lösung den RESTful Adapter und die entsprechenden Datenpunkte (anlegen durch das Script von @SBorg , oder manuell).

Es sind oben im Sketch folgende Angaben zu machen:

// Replace with your credentials
const char* ssid     = "YOURSSID";
const char* password = "YOURPASSDWORD";
const char* IPP = "http://xxx.xxx.xxx.xxx:8087" ; //Protocol, IP and Port where RESTful Adapter waiting.
String DP="javascript.0.Wetterparser.";         // Folder where the final datapoints are

ssid und password : Die WLAN-Settings
IPP: IP des ioBroker-Rechners und Port des RESTful Adapters (default:8087)
DP: Der Ordner wo die Datenpunkte liegen, wenn das Originalscript von SBorg genommen wurde, ist das "javascript.0.Wetterstation."

Ein paar allgemeine Hinweise zumEinrichten der Wetterstation mittels App:

in "path" braucht man statt "/weatherstation/updateweatherstation.php?" nur "/" einzugeben.
Der Port ist im Sketch auf 80 gesetzt, das sollte er auch bleiben, weil das Board auch eine kleine Webseite ausgibt, damit man auf die Schnelle überprüfen kann, ob es da ist und die Browser greifen standardmäßig auf 80 zu.
Also in der App auch auf 80 stellen.
Die Felder Station ID und Station Key: hier kann man irgendwas eingeben (sollte aber nicht leer sein), das Sketch holt nur die Daten aus dem String, diese Einträge werden nicht beachtet.

Nun der Code:
(kann ganz einfach in die Arduino-IDE geklatscht werden, Werte anpassen, kompilieren, downloaden und fertig).

/*********
 FatBob
 ioBroker Parser for Weatherstation Ventus W830
 Ver.: 0.1.0 
*********/

// Load Wi-Fi library
#include <ESP8266WiFi.h>
#include <ESP8266HTTPClient.h>

// Replace with your credentials
const char* ssid     = "YOURSSID";
const char* password = "YOURPASSWORD";
const char* IPP = "http://xxx.xxx.xxx.xxx:8087" ; //Protocol, IP and Port where RESTful Adapter waiting.
String DP="javascript.0.Wetterparser.";         // Folder where the final datapoints are

// Set web server port number to 80 to recieve the datastring from Weatherstation
WiFiServer server(80);

bool messagearrived ;

// Variable to store the HTTP request
String header;
const char* headerKeys[] = {"date","server"};
const size_t numberOfHeaders = 2 ;

// Variables to store the values
float values[19];  
String date;                            // hold the date                   

// Conversion functions

float F2C (float F){    //Fahrenheit to Celsius
 float result;
 result = F - 32;
 result = result / 1.8;
 return result;
}

float CP (float p){     //convert Pressure to hPa
 float result;
 result = p * 33864 / 1000;
 return result;
}

String CT (String date){  //Convert Time from weatherstation

 String dateout="";
 String Year, Month, Day, Hour, Minute, Second ;

 Year = date.substring(0,4);
 Month = date.substring (5,7);
 Day = date.substring(8,10);
 Hour = date.substring(13,15);
 Minute = date.substring(16,18);
 Second = date.substring(19,21);

 dateout += Day + ".";
 dateout += Month + ".";
 dateout += Year + "%20";
 dateout += Hour + ":";
 dateout += Minute + ":";
 dateout += Second ;
 return dateout;
 }

// Current time
unsigned long currentTime = millis();
// Previous time
unsigned long previousTime = 0; 
// Define timeout time in milliseconds (example: 2000ms = 2s)
const long timeoutTime = 2000;

void setup() {
 Serial.begin(115200);

 // Connect to Wi-Fi network with SSID and password
 Serial.print("Connecting to ");
 Serial.println(ssid);
 WiFi.begin(ssid, password);
 while (WiFi.status() != WL_CONNECTED) {
   delay(500);
   Serial.print(".");
 }
 // Print local IP address and start web server
 Serial.println("");
 Serial.println("WiFi connected.");
 Serial.println("IP address: ");
 Serial.println(WiFi.localIP());
 server.begin();
}

void loop(){

 WiFiClient client = server.available();   // Listen for incoming clients

 if (client) {                             // If a new client connects,
   Serial.println("New Client.");          // print a message out in the serial port
   String currentLine = "";                // make a String to hold incoming data from the client
   currentTime = millis();
   previousTime = currentTime;
   while (client.connected() && currentTime - previousTime <= timeoutTime) { // loop while the client's connected
     currentTime = millis();         
     if (client.available()) {             // if there's bytes to read from the client,
       char c = client.read();             // read a byte, then
       Serial.write(c);                    // print it out the serial monitor
       header += c;
       if (c == '\n') {                    // if the byte is a newline character
         // if the current line is blank, you got two newline characters in a row.
         // that's the end of the client HTTP request, so send a response:
         if (currentLine.length() == 0) {
           // HTTP headers always start with a response code (e.g. HTTP/1.1 200 OK)
           // and a content-type so the client knows what's coming, then a blank line:
           client.println("HTTP/1.1 200 OK");
           client.println("Content-type:text/html");
           client.println("Connection: close");
           client.println();
           messagearrived = true;
           
           //disassemble message
           String message = "";                    // make a String to hold pure message
           String singlevalue;                     // make a string to hold single value           
           int j = 0;                              // counter for Arryindex
           
           
           message = header.substring(0,header.indexOf("&softwaretype"));  // cut the string after the interesting data

           //loop to extract the single values
           
           for (int i = 0; i <= message.length(); i++) {
                if (message.charAt(i) == '&'){
                   
                   
                   singlevalue = message.substring(i+1,message.indexOf('&',i+1));
                   singlevalue = singlevalue.substring(singlevalue.indexOf('=',0)+1);
                   
                   if (j < 18){
                   values[j] = singlevalue.toFloat();
                   }
    
                   if (j == 18){                   // 2020-02-18%2012:22:53 steckt in "singlevalue"

                           date = CT(singlevalue);
                           
                         }
                   j++;
                         }
                   }              
         
           
           // Display a HTML web page
           client.println("<!DOCTYPE html><html>");
           client.println("<head></head>");
           
           // Web Page Heading
           client.println("<body><h1>Weather Station Parser</h1>");
           
           // Display current version 
           client.println("<p>Ver.: 0.1.0</p>");
           client.println("</body></html>");
           
           // The HTTP response ends with another blank line
           client.println();
           // Break out of the while loop
           break;
         } else { // if you got a newline, then clear currentLine
           currentLine = "";
         }
       } else if (c != '\r') {  // if you got anything else but a carriage return character,
         currentLine += c;      // add it to the end of the currentLine
       }
     }
   }
   // Clear the header variable
   header = "";
   // Close the connection
   client.stop();
   Serial.println("Client disconnected.");
   Serial.println("");
 }

 if (messagearrived) {
          
       //Build REST String for ioBroker RESTful simple Adapter

              String restmessage = "";

              restmessage = IPP;
              restmessage += "/setBulk?";
              restmessage += DP + "Innentemperatur=" + String (F2C(values[1])) + "&"; //indoortempf
              restmessage += DP + "Aussentemperatur=" + String (F2C(values[2])) + "&"; //tempf
              restmessage += DP + "Taupunkt=" + String (F2C(values[3])) + "&"; //dewptf
              restmessage += DP + "Chillfaktor=" + String (F2C(values[4])) + "&"; //windchillf
              restmessage += DP + "Innenfeuchtigkeit=" + String (values[5]) + "&"; //indoorhumidity
              restmessage += DP + "Aussenfeuchtigkeit=" + String (values[6]) + "&"; //humidity
              restmessage += DP + "Wind=" + String (1.61*(values[7])) + "&"; //windspeedmph
              restmessage += DP + "Wind_max=" + String (1.61*(values[8])) + "&"; //windgustmph
              restmessage += DP + "Windrichtung=" + String (values[9]) + "&"; //winddir
              restmessage += DP + "Druck_absolut=" + String (CP(values[10])) + "&"; //absbaromin
              restmessage += DP + "Druck_relativ=" + String (CP(values[11])) + "&"; //baromin
              restmessage += DP + "Regen_aktuell=" + String (25.4*(values[12])) + "&"; //rainin
              restmessage += DP + "Regen_Tag=" + String (25.4*values[13]) + "&"; //dailyrainin
              restmessage += DP + "Regen_Woche=" + String (25.4*values[14]) + "&"; //weeklyrainin
              restmessage += DP + "Regen_Monat=" + String (25.4*values[15]) + "&"; //monthlyrainin
              restmessage += DP + "Sonnenstrahlung=" + String (values[16]) + "&"; //solarradiation
              restmessage += DP + "UV_Index=" + String (values[17]) + "&"; //UV
              restmessage += DP + "Zeitstempel=" + date + "&"; //dateutc
              restmessage += "prettyPrint";

  Serial.println("Send REST message:");
  Serial.println(restmessage);

  // initialize http client
     HTTPClient http;
  // send message
      http.begin(restmessage); 

  // http.collectHeaders(headerKeys, numberOfHeaders), check for errors;

   int httpCode = http.GET();

   if (httpCode > 0) {

     Serial.println("--- successfully sent ---");

   }else{
     Serial.println("An error occurred sending the request");
   }

   http.end();

   messagearrived = false;
     }
 

 
}

Ich weiß nicht, ob man sowas "Parser" nennen darf, ich tu es einfach

Das sollte auf jedem ESP8266 Board laufen, ich hab hier das NodeMCU Lua Lolin V3 Module ESP8266 ESP-12E in Verwendung.

Noch etwas:
Mir gefällt die Zeitkonvertierung in dem Sketch auch noch nicht so ganz, da die Wetterstation immer die Greenwich Mean time ausgibt, ich bin aber noch nicht draufgekommen, wie man das anständig konvertiert. Es ist mir aber egal, weil die Daten den richtigen Zeitstempel sowieso erst beim Loggen bekommen.

Überflüssig zu sagen: Der Einsatz des Sketches erfolgt auf eigene Gefahr, es gibt keinerlei Garantie oder Gewährleistung

Wenn Fragen auftauchen, gerne in diesem Thread fragen.

Beste Grüße

Bob

Edit: Hier gibts was neues :

SBorg

@FatBob Nice

So aus dem Kopf heraus müsste die Konvertierung auch mittels NTP klappen. Dann hättest du auf dem ESP auch gleich immer die korrekte Zeit

FatBob

@SBorg

Konvertierung ist vielleicht zuviel gesagt.

In deinem Shell.Script machst Du das:

MESSWERTE[$i]=$(echo ${MESSWERTE[$i]}|sed -e 's/%20/ /')
MESSWERTE[$i]=$(date --date="${MESSWERTE[$i]} UTC" +'%d.%m.%Y %H:%M:%S')

Du scheinst hier das Leerzeichen rauszuschneiden und dann dem Adapter mitzuteilen, dass jetzt eine UTC im danach eingegebenen Format kommt.
Der ioBroker zeigt dann im entsprechenden Feld die richtige, lokale Zeit an, oder ?
Leider hab ich von Linux, ausser Raspi-Gebastel, nicht viel Ahnung, daher kann ich das Script nicht ganz entziffern...

Wie muss denn der fertige String aussehen, damit das funktioniert ?

beste Grüße

Bob

SBorg

@FatBob sagte in Wetterstation Ventus W830 parsing mit ESP8266:

@SBorg
Du scheinst hier das Leerzeichen rauszuschneiden und dann dem Adapter mitzuteilen, dass jetzt eine UTC im danach eingegebenen Format kommt.

Nicht ganz
Von der Station kommt: dateutc=2020-01-30%2023:58:28
#1 schneidet nicht das Leerzeichen heraus, sondern ersetzt %20 (Maskierung des Leerzeichens in HTTP-Strings) durch ein [space]: 2020-01-30 23:58:28
#2 funktioniert auch etwas anders als du gerade denkst. Ich sage damit, formatiere 2020-01-30 23:58:28 welches in UTC vorliegt nach DD.MM.YYYY HH:MM:SS : 30.01.2020 23:58:28
Praktischerweise konvertiert der "date"-Befehl dabei gleich auf die passende Zeitzone. Damit erreiche ich, dass zB. auch CET/CEST völlig egal ist. Er rechnet immer korrekt solange der Host auf die korrekte Zeitzone/Sommer-/Winterzeit eingestellt ist. Praktisch, falls, oder wenn überhaupt, und wann, wir ev. permanente Winter- oder Sommerzeit haben, oder ggf. doch weiter umstellen ^^
Und genau diesen String schicke ich dann an den ioB: 31.01.2020 00:58:28 (jetzt als aktuell CET umgesetzt)

...und genau diese UTC --> CET/CEST Konvertierung müsste die Library des NTP hergeben.

FatBob

@SBorg

Ahh, alles klar,mal sehen ob ich das mit NTP umsetzten werde, scheint mir ein wenig aufwändig, für eine Zeitangabe, die man eigentlich nicht nutzt...

br

Bob

SBorg

@FatBob Ob das Teil noch "lebt" kann man auch notfalls über die ts/lc der Datenpunkte erkennen. Allerdings brauche ich den genauen Zeitpunkt, da ich in der neusten Version die Jahresregenmenge noch berechne. Die Tagesmenge wird 0:00 UTC genullt.

...zumnindest die Lib TimeZone kann es, die wurde extra dafür geschrieben

Glasfaser

@FatBob

Habe mein WLAN versteckt ( Sinn und Zweck sei dahingestellt ),
das Problem ist ,das er mit deinem Script nicht dann mein WLAN findet bzw. ein Verbindung aufbaut.

Wie und was muss an deinem Code angepasst werden , damit mein verstecktes SSID (hidden) mit deinem Code funktioniert.

FatBob

@Glasfaser

Eigentlich sollte es für das Sketch keine Rolle spielen, ob das Netzwerk versteckt ist, schließlich wird direkt über SSID angebunden.

Ich werde das nächste Woche mal simulieren, am WE bin ich in den Bergen und habe keine Zeit dafür

Br

FB

FatBob

Also ich habe jetzt in meinem Ubiquiti netzwerk eines mit hidden SSID aufgesetzt.
Das Board meldet sich problemlos an...

Ich hab dann ein wenig herumgeforscht..

Offensichtlich gibts ein Problem mit manchen ESP8266/Routerkonfigurationen, eine richtige Lösung hab ich nicht gefunden, leider zu wenig Zeit.

Es gibt hier als Ausgangspunkt einen Thread auf Github.

Es kommt wohl auf den mode des accesspoints an..

BR

FB

Glasfaser

@FatBob

Danke ... das du dir die Zeit genommen hast .

Habe eine Fritzbox 6490 (bald eine 6591 )

Dann wird es das gleiche sein wie bei Tasmota .. da kann ich auch nicht mehr die neusten Versionen nehmen , wegen hidden SSID.

Aber das Thema ist hier OT , deshalb schließe ich hier ab .
DANKE !!

FatBob

Hallo nochmal.

Ich hab das jetzt ein wenig erweitert, es wird jetzt die TimeZone Lib verwendet, also wird
die korrekte Zeit (Standard und Sommerzeit geht automatisch) eruiert.

@SBorg
Die NTP-Funktionalität ist mE problematisch weil:

Die Wetterstation hat selbst keine NTP-Funktion und auch keine Funkuhr, zumindest musste ich bei meiner Datum/Uhrzeit händisch einstellen.
Wenn man sich nun beim Loggen auf eine NTP-Zeit verlässt, kann man, wenn man zu spät dran ist (weil die Wetterstation "vorgeht") die Nullung der Regenmenge verpassen und die Daten verlieren.
Also ist es mE besser nur mittels Timezone die UTC der Wetterstation auf lokale Zeit umzusetzen.
Man muss sich dann beim Loggen auf jeden Fall auf die so errechnete Zeit stützen und nicht auf die Zeit des IO-Brokers.
Wie ich allerdings punktgenau ein Logging ausserhalb des sql-Adapters auslöse, weiß ich noch nicht .

Hier der Code:

/*********
 FatBob
 ioBroker Parser for Weatherstation Ventus W830
 Ver.: 0.1.1
*********/

// Load Wi-Fi libraries
#include <ESP8266WiFi.h>
#include <ESP8266HTTPClient.h>

// Load Time libraries
#include <Time.h>
#include <TimeLib.h>
#include <Timezone.h>


//#######################  Replace with your credentials  ###########################################

// Network environment

const char* ssid     = "YOURSSID";
const char* password = "YOURPASSWORD";
const char* IPP = "http://xxx.xxx.xxx.xxx:8087" ; //Protocol, IP and Port where RESTful Adapter waiting.
String DP="javascript.0.Wetterparser.";         // Folder where the final datapoints are

// TimeConversion rules

TimeChangeRule euCET = {"CET", Fourth, Sun, Mar, 2, +120};  //UTC + 2 hours (in minutes), set your credentials here for daylight saving time
TimeChangeRule euCEST = {"CEST", Fourth, Sun, Oct, 2, +60};   //UTC + 1 hours (in minutes), set your credentials here for standard time

//###################################################################################################

// Set web server port number to 80 to recieve the datastring from Weatherstation
WiFiServer server(80);
bool messagearrived ;

// Variable to store the HTTP request
String header;
const char* headerKeys[] = {"date","server"};
const size_t numberOfHeaders = 2 ;

// Variables to store the values
float values[19];  
String date;                            // hold the date     
time_t t;                                 //hold time

// Conversion functions

float F2C (float F){    //Fahrenheit to Celsius
 float result;
 result = F - 32;
 result = result / 1.8;
 return result;
}

float CP (float p){     //convert Pressure to hPa
 float result;
 result = p * 33864 / 1000;
 return result;
}

String CT (String date){  //Convert Time from weatherstation

 char tdate[10], ttime[8];
 String dateout="";
 String Year, Month, Day, Hour, Minute, Second ;
 time_t central, utc;
 Timezone euCentral(euCET, euCEST);

 Year = date.substring(0,4);
 Month = date.substring (5,7);
 Day = date.substring(8,10);
 Hour = date.substring(13,15);
 Minute = date.substring(16,18);
 Second = date.substring(19,21);

 setTime(Hour.toInt(),Minute.toInt(),Second.toInt(),Day.toInt(),Month.toInt(),Year.toInt()); // set system time to what came from weatherstation
 utc = now();  
 central = euCentral.toLocal(utc); // change time as declared in rules
 setTime(central); // set system time to converted local time
 
 sprintf(tdate, "%02u.%02u.%4u",day(),month(),year());  //leading zero !
 sprintf(ttime, "%02u:%02u:%02u",hour(),minute(),second()); // leading zero !!

 
 for (int i = 0; i <= 9; i++) {      //put date in dateout-string

 dateout += tdate[i];
 }
 
 dateout += "%20";                 // put (url)space in dateout-string
 
 for (int i = 0; i <= 7; i++) {    // put time in dateout-string

 dateout += ttime[i];    
 }
 Serial.println("Local datetime: " + dateout);
 return dateout;
 
 }

// Current time for timeout
unsigned long currentTime = millis();
// Previous time for timeout
unsigned long previousTime = 0; 
// Define timeout time in milliseconds (example: 2000ms = 2s)
const long timeoutTime = 2000;

void setup() {
 Serial.begin(115200);

 // Connect to Wi-Fi network with SSID and password
 Serial.print("Connecting to ");
 Serial.println(ssid);
 WiFi.begin(ssid, password);
 while (WiFi.status() != WL_CONNECTED) {
   delay(500);
   Serial.print(".");
 }
 // Print local IP address and start web server
 Serial.println("");
 Serial.println("WiFi connected.");
 Serial.println("IP address: ");
 Serial.println(WiFi.localIP());
 server.begin();
}

void loop(){

 WiFiClient client = server.available();   // Listen for incoming clients

 if (client) {                             // If a new client connects,
   Serial.println("New Client.");          // print a message out in the serial port
   String currentLine = "";                // make a String to hold incoming data from the client
   currentTime = millis();
   previousTime = currentTime;
   while (client.connected() && currentTime - previousTime <= timeoutTime) { // loop while the client's connected
     currentTime = millis();         
     if (client.available()) {             // if there's bytes to read from the client,
       char c = client.read();             // read a byte, then
       Serial.write(c);                    // print it out the serial monitor
       header += c;
       if (c == '\n') {                    // if the byte is a newline character
         // if the current line is blank, you got two newline characters in a row.
         // that's the end of the client HTTP request, so send a response:
         if (currentLine.length() == 0) {
           // HTTP headers always start with a response code (e.g. HTTP/1.1 200 OK)
           // and a content-type so the client knows what's coming, then a blank line:
           client.println("HTTP/1.1 200 OK");
           client.println("Content-type:text/html");
           client.println("Connection: close");
           client.println();
           messagearrived = true;
           
           //disassemble message
           String message = "";                    // make a String to hold pure message
           String singlevalue;                     // make a string to hold single value           
           int j = 0;                              // counter for Arryindex
           
           
           message = header.substring(0,header.indexOf("&softwaretype"));  // cut the string after the interesting data

           //loop to extract the single values
           
           for (int i = 0; i <= message.length(); i++) {
                if (message.charAt(i) == '&'){
                   
                   
                   singlevalue = message.substring(i+1,message.indexOf('&',i+1));
                   singlevalue = singlevalue.substring(singlevalue.indexOf('=',0)+1);
                   
                   if (j < 18){
                   values[j] = singlevalue.toFloat();
                   }
    
                   if (j == 18){                   // 2020-02-18%2012:22:53 steckt in "singlevalue"

                           date = CT(singlevalue);
                           
                         }
                   j++;
                         }
                   }              
         
           
           // Display a HTML web page
           client.println("<!DOCTYPE html><html>");
           client.println("<head></head>");
           
           // Web Page Heading
           client.println("<body><h1>Weather Station Parser</h1>");
           
           // Display current version 
           client.println("<p>Ver.: 0.1.1</p>");
           client.println("</body></html>");
           
           // The HTTP response ends with another blank line
           client.println();
           // Break out of the while loop
           break;
         } else { // if you got a newline, then clear currentLine
           currentLine = "";
         }
       } else if (c != '\r') {  // if you got anything else but a carriage return character,
         currentLine += c;      // add it to the end of the currentLine
       }
     }
   }
   // Clear the header variable
   header = "";
   // Close the connection
   client.stop();
   Serial.println("Client disconnected.");
   Serial.println("");
 }

 if (messagearrived) {
          
       //Build REST String for ioBroker RESTful simple Adapter

              String restmessage = "";

              restmessage = IPP;
              restmessage += "/setBulk?";
              restmessage += DP + "Innentemperatur=" + String (F2C(values[1])) + "&"; //indoortempf
              restmessage += DP + "Aussentemperatur=" + String (F2C(values[2])) + "&"; //tempf
              restmessage += DP + "Taupunkt=" + String (F2C(values[3])) + "&"; //dewptf
              restmessage += DP + "Chillfaktor=" + String (F2C(values[4])) + "&"; //windchillf
              restmessage += DP + "Innenfeuchtigkeit=" + String (values[5]) + "&"; //indoorhumidity
              restmessage += DP + "Aussenfeuchtigkeit=" + String (values[6]) + "&"; //humidity
              restmessage += DP + "Wind=" + String (1.61*(values[7])) + "&"; //windspeedmph
              restmessage += DP + "Wind_max=" + String (1.61*(values[8])) + "&"; //windgustmph
              restmessage += DP + "Windrichtung=" + String (values[9]) + "&"; //winddir
              restmessage += DP + "Druck_absolut=" + String (CP(values[10])) + "&"; //absbaromin
              restmessage += DP + "Druck_relativ=" + String (CP(values[11])) + "&"; //baromin
              restmessage += DP + "Regen_aktuell=" + String (25.4*(values[12])) + "&"; //rainin
              restmessage += DP + "Regen_Tag=" + String (25.4*values[13]) + "&"; //dailyrainin
              restmessage += DP + "Regen_Woche=" + String (25.4*values[14]) + "&"; //weeklyrainin
              restmessage += DP + "Regen_Monat=" + String (25.4*values[15]) + "&"; //monthlyrainin
              restmessage += DP + "Sonnenstrahlung=" + String (values[16]) + "&"; //solarradiation
              restmessage += DP + "UV_Index=" + String (values[17]) + "&"; //UV
              restmessage += DP + "Zeitstempel=" + date + "&"; //dateutc
              restmessage += "prettyPrint";

  Serial.println("Send REST message:");
  Serial.println(restmessage);

  // initialize http client
     HTTPClient http;
  // send message
      http.begin(restmessage); 

  // http.collectHeaders(headerKeys, numberOfHeaders), check for errors;

   int httpCode = http.GET();

   if (httpCode > 0) {

     Serial.println("--- successfully sent ---");

   }else{
     Serial.println("An error occurred sending the request");
   }

   http.end();

   messagearrived = false;
     }
 

 
}

Zusätzlich zu den Netzwerksettings müssen nun die Konvertierungsregeln eingegeben werden, hier in der EU:

Last: letzte Woche // Hier wurde editiert, da zunächst falscher Eintrag
Sun: Sonntag
Mar/Oct: März/Oktober
2: 02:00 Uhr
+120/+60: CET/CEST in Minuten zur UTC. (Hier im deutschsprachigen Raum).

Wiederum einfach die Werte anpassen, kompillieren, runterladen, fertig.
Ach ja, bei mir kommt beim kompilieren immer eine Warnung, dass die Lib Time-Master möglicherweise nicht kompatibel zum neuen ESP8266 Board ist,
ich hab aber keine Probleme hier...

BR

FatBob

FatBob

Hallo Zusammen,

Hier nochmal eine Erweiterung:

Nachdem ich mir über das Loggen in der Datenbank Gedanken gemacht habe, bin ich für mich
zu folgender Lösung gekommen:

Anlegen von 4 neuen Datenpunkten (alle Boolean), das ESP-board setzt diese Datenpunkte je nach Message von der Wetterstation auf true.

ddlw - wird täglich um 23:58:xx für 2 min "true" (do daily work)
dwlw - wird jeden Samstag um 23:58:xx für 2 min "true" (do weekly work) - (Wetterstation nullt um 00:00 Samstag/Sonntag)
dmlw - wird am letzten Tag jeden Monats (Schaltjahre sind berücksichtigt) um 23:58:xx für 2 min "true" (do monthly work)
dylw - wird am 31.12.xxxx um 23:58:xx für 2 min "true" (do yearly work)

Diese Datenpunkte können dann mittels Script zum Loggen der gewünschten Werte oder zum Kumulieren verwendet werden.

Warum gerade so ?
Nun, die Systemzeit der Wetterstation ist händisch eingestellt, da könnten Daten verloren gehen, wenn die Zeitquelle zum loggen von wo anders kommt.

Diese 4 Datenpunkte heissen also " jetzt kommen meine letzten Werte, in 1-2 Minuten sind sie weg".

Ich habs dann für mich im Script dann so gelöst, dass ich mir eigene Datenpunkte fürs loggen angelegt habe, diese im sql-Adapter auf "nur bei Änderung loggen" gesetzt habe und zur Logzeit diese mit den frischen Werten überschreibe, so kriege ich möglichst wenige Logs (ich will nicht bei jeder Bewegung der Regenwippe einen Log) und verliere auch nichts.

Die neuen Datenpunkte:

Der neue Code:

/*********
FatBob
ioBroker Parser for Weatherstation Ventus W830
Ver.: 0.2.0
*********/

// Load Wi-Fi libraries
#include <ESP8266WiFi.h>
#include <ESP8266HTTPClient.h>

// Load Time libraries
#include <Time.h>
#include <TimeLib.h>
#include <Timezone.h>


//#######################  Replace with your credentials  ###########################################

// Network environment

const char* ssid     = "YOURSSID";
const char* password = "YOURPASSWORD";
const char* IPP = "http://xxx.xxx.xxx.xxx:8087" ; //Protocol, IP and Port where RESTful Adapter waiting.
String DP="javascript.0.Wetterparser.";         // Folder where the final datapoints are

// TimeConversion rules

TimeChangeRule euCET = {"CET", Fourth, Sun, Mar, 2, +120};  //UTC + 2 hours (in minutes), set your credentials here for daylight saving time
TimeChangeRule euCEST = {"CEST", Fourth, Sun, Oct, 2, +60};   //UTC + 1 hours (in minutes), set your credentials here for standard time

//###################################################################################################

// Set web server port number to 80 to recieve the datastring from Weatherstation
WiFiServer server(80);
bool messagearrived ;

// Variable to store the HTTP request
String header;
const char* headerKeys[] = {"date","server"};
const size_t numberOfHeaders = 2 ;

// Variables to store the values
float values[19];  
String date;                            // hold the date     
time_t t;                                 //hold time

// Conversion functions

float F2C (float F){    //Fahrenheit to Celsius
float result;
result = F - 32;
result = result / 1.8;
return result;
}

float CP (float p){     //convert Pressure to hPa
float result;
result = p * 33864 / 1000;
return result;
}

String CT (String date){  //Convert Time from weatherstation

char tdate[10], ttime[8];
String dateout="";
String Year, Month, Day, Hour, Minute, Second ;
time_t central, utc;
Timezone euCentral(euCET, euCEST);

Year = date.substring(0,4);
Month = date.substring (5,7);
Day = date.substring(8,10);
Hour = date.substring(13,15);
Minute = date.substring(16,18);
Second = date.substring(19,21);

setTime(Hour.toInt(),Minute.toInt(),Second.toInt(),Day.toInt(),Month.toInt(),Year.toInt()); // set system time to what came from weatherstation
utc = now();  
central = euCentral.toLocal(utc); // change time as declared in rules
setTime(central); // set system time to converted local time

sprintf(tdate, "%02u.%02u.%4u",day(),month(),year());  //leading zero !
sprintf(ttime, "%02u:%02u:%02u",hour(),minute(),second()); // leading zero !!


for (int i = 0; i <= 9; i++) {      //put date in dateout-string

dateout += tdate[i];
}

dateout += "%20";                 // put (url)space in dateout-string

for (int i = 0; i <= 7; i++) {    // put time in dateout-string

dateout += ttime[i];    
}
Serial.println("Local datetime: " + dateout);
return dateout;
//setTime(utc);    uncomment this, if your weatherstation deletes its values following "UTC"
}

// Current time for timeout
unsigned long currentTime = millis();
// Previous time for timeout
unsigned long previousTime = 0; 
// Define timeout time in milliseconds (example: 2000ms = 2s)
const long timeoutTime = 2000;

void setup() {
Serial.begin(115200);

// Connect to Wi-Fi network with SSID and password
Serial.print("Connecting to ");
Serial.println(ssid);
WiFi.begin(ssid, password);
while (WiFi.status() != WL_CONNECTED) {
  delay(500);
  Serial.print(".");
}
// Print local IP address and start web server
Serial.println("");
Serial.println("WiFi connected.");
Serial.println("IP address: ");
Serial.println(WiFi.localIP());
server.begin();
}

void loop(){

WiFiClient client = server.available();   // Listen for incoming clients

if (client) {                             // If a new client connects,
  Serial.println("New Client.");          // print a message out in the serial port
  String currentLine = "";                // make a String to hold incoming data from the client
  currentTime = millis();
  previousTime = currentTime;
  while (client.connected() && currentTime - previousTime <= timeoutTime) { // loop while the client's connected
    currentTime = millis();         
    if (client.available()) {             // if there's bytes to read from the client,
      char c = client.read();             // read a byte, then
      Serial.write(c);                    // print it out the serial monitor
      header += c;
      if (c == '\n') {                    // if the byte is a newline character
        // if the current line is blank, you got two newline characters in a row.
        // that's the end of the client HTTP request, so send a response:
        if (currentLine.length() == 0) {
          // HTTP headers always start with a response code (e.g. HTTP/1.1 200 OK)
          // and a content-type so the client knows what's coming, then a blank line:
          client.println("HTTP/1.1 200 OK");
          client.println("Content-type:text/html");
          client.println("Connection: close");
          client.println();
          messagearrived = true;
          
          //disassemble message
          String message = "";                    // make a String to hold pure message
          String singlevalue;                     // make a string to hold single value           
          int j = 0;                              // counter for Arryindex
          
          
          message = header.substring(0,header.indexOf("&softwaretype"));  // cut the string after the interesting data

          //loop to extract the single values
          
          for (int i = 0; i <= message.length(); i++) {
               if (message.charAt(i) == '&'){
                  
                  
                  singlevalue = message.substring(i+1,message.indexOf('&',i+1));
                  singlevalue = singlevalue.substring(singlevalue.indexOf('=',0)+1);
                  
                  if (j < 18){
                  values[j] = singlevalue.toFloat();
                  }
   
                  if (j == 18){                   // 2020-02-18%2012:22:53 steckt in "singlevalue"

                          date = CT(singlevalue);
                          
                        }
                  j++;
                        }
                  }              
        
          
          // Display a HTML web page
          client.println("<!DOCTYPE html><html>");
          client.println("<head></head>");
          
          // Web Page Heading
          client.println("<body><h1>Weather Station Parser</h1>");
          
          // Display current version 
          client.println("<p>Ver.: 0.2.0</p>");
          client.println("</body></html>");
          
          // The HTTP response ends with another blank line
          client.println();
          // Break out of the while loop
          break;
        } else { // if you got a newline, then clear currentLine
          currentLine = "";
        }
      } else if (c != '\r') {  // if you got anything else but a carriage return character,
        currentLine += c;      // add it to the end of the currentLine
      }
    }
  }
  // Clear the header variable
  header = "";
  // Close the connection
  client.stop();
  Serial.println("Client disconnected.");
  Serial.println("");
}

if (messagearrived) {

//################################  Logging? #######################################
      
    int monthHasDays[] = {0,31,28,31,30,31,30,31,31,30,31,30,31}; 
    bool ly, ddlw, dwlw, dmlw, dylw; 

     
         // Leap year ?

      int x =0, y=0, z=0;
      
      x = year()% 4;
      y = year()% 100;
      z = year()% 400;

      if (((x==0) & (y!=0)) || (z==0)){
       ly =true;
       monthHasDays[2] = 29;
      }else {ly =false;}

      

      if ((hour()>=23) && (minute() >=58)){

         ddlw = true;    // do daily work
      }else{ddlw = false;}

      if ((weekday() == 7) && (ddlw == true)){

         dwlw = true;    // do weekly work
      }else{dwlw = false;}

      if ((day() == monthHasDays[month()]) && (ddlw == true)){

         dmlw = true;    // do monthly work
         
      }else{dmlw = false;}

      if ((day()==31) & (month()==12) & (ddlw == true)){

       dylw = true;     //do yearly work
       
      }else{dylw = false;}
      
      
//##########################  Build REST String for ioBroker RESTful simple Adapter  ################################

             String restmessage = "";

             restmessage = IPP;
             restmessage += "/setBulk?";
             restmessage += DP + "Innentemperatur=" + String (F2C(values[1])) + "&"; //indoortempf
             restmessage += DP + "Aussentemperatur=" + String (F2C(values[2])) + "&"; //tempf
             restmessage += DP + "Taupunkt=" + String (F2C(values[3])) + "&"; //dewptf
             restmessage += DP + "Chillfaktor=" + String (F2C(values[4])) + "&"; //windchillf
             restmessage += DP + "Innenfeuchtigkeit=" + String (values[5]) + "&"; //indoorhumidity
             restmessage += DP + "Aussenfeuchtigkeit=" + String (values[6]) + "&"; //humidity
             restmessage += DP + "Wind=" + String (1.61*(values[7])) + "&"; //windspeedmph
             restmessage += DP + "Wind_max=" + String (1.61*(values[8])) + "&"; //windgustmph
             restmessage += DP + "Windrichtung=" + String (values[9]) + "&"; //winddir
             restmessage += DP + "Druck_absolut=" + String (CP(values[10])) + "&"; //absbaromin
             restmessage += DP + "Druck_relativ=" + String (CP(values[11])) + "&"; //baromin
             restmessage += DP + "Regen_aktuell=" + String (25.4*(values[12])) + "&"; //rainin
             restmessage += DP + "Regen_Tag=" + String (25.4*values[13]) + "&"; //dailyrainin
             restmessage += DP + "Regen_Woche=" + String (25.4*values[14]) + "&"; //weeklyrainin
             restmessage += DP + "Regen_Monat=" + String (25.4*values[15]) + "&"; //monthlyrainin
             restmessage += DP + "Sonnenstrahlung=" + String (values[16]) + "&"; //solarradiation
             restmessage += DP + "UV_Index=" + String (values[17]) + "&"; //UV
             restmessage += DP + "Zeitstempel=" + date + "&"; //dateutc
             restmessage += DP + "ddlw=" + String(ddlw) + "&"; //do daily work
             restmessage += DP + "dwlw=" + String(dwlw) + "&"; //do weekly work
             restmessage += DP + "dmlw=" + String(dmlw) + "&"; //do monthly work
             restmessage += DP + "dylw=" + String(dylw) + "&"; //do yearly work
             restmessage += "prettyPrint";

 Serial.println("Send REST message:");
 Serial.println(restmessage);

 // initialize http client
    HTTPClient http;
 // send message
     http.begin(restmessage); 

 // http.collectHeaders(headerKeys, numberOfHeaders), check for errors;

  int httpCode = http.GET();

  if (httpCode > 0) {

    Serial.println("--- successfully sent ---");

  }else{
    Serial.println("An error occurred sending the request");
  }

  http.end();

  messagearrived = false;
    }



}

Wer den Code liest, wird feststellen, dass die Datenpunkte zur lokalen Zeit ausgelöst werden.
Ich habe bei meiner Wetterstation festgestellt, dass sie zur lokalen Zeit um 00:00 nullt.
Im Thread zum ShellScript habe ich gesehen, dass bei anderen zur UTC genullt wird, warum das verschieden sein sollte, weiss ich nicht.
Wer sich sicher ist, dass seine Wetterstation bei UTC nullt, kann die Auskommentierung in Zeile 99 entfernen, dann wird nach dem Ausgeben der lokalen
Zeit (für den Datenpunkt "Zeitstempel") die Systemzeit wieder auf UTC gestellt.

Ich werde das jetzt mal so lassen, keine weiteren Ideen...

Falls wer noch Anregungen hat, immer her damit...

BR

Bob

Fogg

So als kleine Zusatzinfo, ich baue gerade einen Adapter für die WS980Wifi, ist wohl die gleiche Software drauf wie hier Von daher sollte mein Adapter dann auch hier funktionieren. Hier das Thema dazu:

https://forum.iobroker.net/topic/32599/wetterstation-ws980wifi-von-elv-neuer-adapter

NEWS

Wetterstation Ventus W830 parsing mit ESP8266

Support us

443
Online

31.9k
Users

80.1k
Topics

1.3m
Posts

NEWS

Wetterstation Ventus W830 parsing mit ESP8266

Support us

443Online

31.9kUsers

80.1kTopics

1.3mPosts

443
Online

31.9k
Users

80.1k
Topics

1.3m
Posts