Skip to content
  • Home
  • Aktuell
  • Tags
  • 0 Ungelesen 0
  • Kategorien
  • Unreplied
  • Beliebt
  • GitHub
  • Docu
  • Hilfe
Skins
  • Light
  • Brite
  • Cerulean
  • Cosmo
  • Flatly
  • Journal
  • Litera
  • Lumen
  • Lux
  • Materia
  • Minty
  • Morph
  • Pulse
  • Sandstone
  • Simplex
  • Sketchy
  • Spacelab
  • United
  • Yeti
  • Zephyr
  • Dark
  • Cyborg
  • Darkly
  • Quartz
  • Slate
  • Solar
  • Superhero
  • Vapor

  • Standard: (Kein Skin)
  • Kein Skin
Einklappen
ioBroker Logo

Community Forum

donate donate
  1. ioBroker Community Home
  2. Deutsch
  3. Praktische Anwendungen (Showcase)
  4. Wetterstation Ventus W830 parsing mit ESP8266

NEWS

  • Jahresrückblick 2025 – unser neuer Blogbeitrag ist online! ✨
    BluefoxB
    Bluefox
    16
    1
    1.9k

  • Neuer Blogbeitrag: Monatsrückblick - Dezember 2025 🎄
    BluefoxB
    Bluefox
    13
    1
    911

  • Weihnachtsangebot 2025! 🎄
    BluefoxB
    Bluefox
    25
    1
    2.2k

Wetterstation Ventus W830 parsing mit ESP8266

Geplant Angeheftet Gesperrt Verschoben Praktische Anwendungen (Showcase)
13 Beiträge 4 Kommentatoren 2.0k Aufrufe 6 Watching
  • Älteste zuerst
  • Neuste zuerst
  • Meiste Stimmen
Antworten
  • In einem neuen Thema antworten
Anmelden zum Antworten
Dieses Thema wurde gelöscht. Nur Nutzer mit entsprechenden Rechten können es sehen.
  • SBorgS 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 ;)

    F Offline
    F Offline
    FatBob
    schrieb am zuletzt editiert von
    #3

    @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

    SBorgS 1 Antwort Letzte Antwort
    0
    • F 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

      SBorgS Offline
      SBorgS Offline
      SBorg
      Forum Testing Most Active
      schrieb am zuletzt editiert von
      #4

      @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.

      LG SBorg ( SBorg auf GitHub)
      Projekte: Lebensmittelwarnung.de | WLAN-Wetterstation | PimpMyStation

      F 1 Antwort Letzte Antwort
      0
      • SBorgS 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.

        F Offline
        F Offline
        FatBob
        schrieb am zuletzt editiert von
        #5

        @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

        SBorgS 1 Antwort Letzte Antwort
        0
        • F 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

          SBorgS Offline
          SBorgS Offline
          SBorg
          Forum Testing Most Active
          schrieb am zuletzt editiert von
          #6

          @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 :)

          LG SBorg ( SBorg auf GitHub)
          Projekte: Lebensmittelwarnung.de | WLAN-Wetterstation | PimpMyStation

          F 1 Antwort Letzte Antwort
          0
          • F 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... :grin:

            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 :grinning:

            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 :grinning:

            Wenn Fragen auftauchen, gerne in diesem Thread fragen.

            Beste Grüße

            Bob

            Edit: Hier gibts was neues :

            GlasfaserG Offline
            GlasfaserG Offline
            Glasfaser
            schrieb am zuletzt editiert von
            #7

            @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.

            Synology 918+ 16GB - ioBroker in Docker v9 , VISO auf Trekstor Primebook C13 13,3" , Hikvision Domkameras mit Surveillance Station .. CCU RaspberryMatic in Synology VM .. Zigbee CC2538+CC2592 .. Sonoff .. KNX .. Modbus ..

            F 1 Antwort Letzte Antwort
            0
            • GlasfaserG 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.

              F Offline
              F Offline
              FatBob
              schrieb am zuletzt editiert von
              #8

              @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

              F 1 Antwort Letzte Antwort
              0
              • F 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

                F Offline
                F Offline
                FatBob
                schrieb am zuletzt editiert von
                #9

                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

                GlasfaserG 1 Antwort Letzte Antwort
                1
                • F 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

                  GlasfaserG Offline
                  GlasfaserG Offline
                  Glasfaser
                  schrieb am zuletzt editiert von
                  #10

                  @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 !!

                  Synology 918+ 16GB - ioBroker in Docker v9 , VISO auf Trekstor Primebook C13 13,3" , Hikvision Domkameras mit Surveillance Station .. CCU RaspberryMatic in Synology VM .. Zigbee CC2538+CC2592 .. Sonoff .. KNX .. Modbus ..

                  1 Antwort Letzte Antwort
                  0
                  • SBorgS 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 :)

                    F Offline
                    F Offline
                    FatBob
                    schrieb am zuletzt editiert von FatBob
                    #11

                    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 :grimacing: :-) .

                    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

                    F 1 Antwort Letzte Antwort
                    0
                    • F 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 :grimacing: :-) .

                      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

                      F Offline
                      F Offline
                      FatBob
                      schrieb am zuletzt editiert von
                      #12

                      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:


                      iobroker_log.JPG

                      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

                      1 Antwort Letzte Antwort
                      0
                      • FoggF Offline
                        FoggF Offline
                        Fogg
                        schrieb am zuletzt editiert von
                        #13

                        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

                        1 Antwort Letzte Antwort
                        0
                        Antworten
                        • In einem neuen Thema antworten
                        Anmelden zum Antworten
                        • Älteste zuerst
                        • Neuste zuerst
                        • Meiste Stimmen


                        Support us

                        ioBroker
                        Community Adapters
                        Donate

                        780

                        Online

                        32.6k

                        Benutzer

                        82.2k

                        Themen

                        1.3m

                        Beiträge
                        Community
                        Impressum | Datenschutz-Bestimmungen | Nutzungsbedingungen | Einwilligungseinstellungen
                        ioBroker Community 2014-2025
                        logo
                        • Anmelden

                        • Du hast noch kein Konto? Registrieren

                        • Anmelden oder registrieren, um zu suchen
                        • Erster Beitrag
                          Letzter Beitrag
                        0
                        • Home
                        • Aktuell
                        • Tags
                        • Ungelesen 0
                        • Kategorien
                        • Unreplied
                        • Beliebt
                        • GitHub
                        • Docu
                        • Hilfe