Solaranzeige / PV-Monitor

Code: Alles auswählen

  /**************************************************************************
  //  Daten in die lokale Influx Datenbank schreiben
  //
  //
  **************************************************************************/
  function influx_local( $daten ) {
    $query = "";
    if (!isset($daten["InfluxDBLokal"])) {
      $daten["InfluxDBLokal"] = "solaranzeige";
    }
    if (!isset($daten["zentralerTimestamp"])) {
      $daten["zentralerTimestamp"] = time( );
    }
    //  Jetzt müssen die Daten in die lokale InfluxDB übertragen werden.
    //
    //  Zuerst die Statistikdaten übertragen. Einmal am Tage um 23:58 Uhr.
    if (date( "i" ) == '00' or date( "i" ) == '10' or date( "i" ) == '20' or date( "i" ) == '30' or date( "i" ) == '40' or date( "i" ) == '50') {
      // if (1 == 1) {
      //$this->log_schreiben("Aktuelle Statistik:\n".print_r($daten,1),"   ",9);
      
      $this->log_schreiben( "Alle 10 Minuten werden die Statistikdaten übertragen.", "   ", 5 );
      $query = "Statistik Bezeichnung=\"WhTag\",Datum=\"".$daten['Datum']."\",Woche=".$daten['Woche'].",Monat=".$daten['Monat'];
      $query .= ",Wert=".$daten["WattstundenGesamtHeute"].",Wochentag=\"".$daten['Wochentag']."\"";
      $query .= ",Heute_TS=".mktime( 0, 0, 0, date( "m" ), date( "d" ), date( "Y" ))."000000000";
      $query .= ",Gestern_TS=".mktime( 0, 0, 0, date( "m" ), date( "d" ) - 1, date( "Y" ))."000000000";
      $query .= ",DiesesJahr_TS=".mktime( 0, 0, 0, 1, 1, date( "Y" ))."000000000";
      $query .= ",LetztesJahr_TS=".mktime( 0, 0, 0, 1, 1, date( "Y" ) - 1 )."000000000";
      $query .= ",DieserMonat_TS=".mktime( 0, 0, 0, date( "m" ), 1, date( "Y" ))."000000000";
      $query .= ",LetzterMonat_TS=".mktime( 0, 0, 0, date( "m" ) - 1, 1, date( "Y" ))."000000000";
      $query .= ",DieseWoche_TS=".strtotime( "last monday", strtotime( "tomorrow" ))."000000000";
      $query .= ",LetzteWoche_TS=".strtotime( "last monday -7 days", strtotime( "tomorrow" ))."000000000";
      $query .= ",HeuteVJ_TS=".mktime( 0, 0, 0, date( "m" ), date( "d" ), date( "Y" ) - 1 )."000000000";
      $query .= ",TagImMonat=".date( "j" );
      $query .= ",TagImJahr=".(date( "z" ) + 1);
      $query .= ",Jahr=".date( "Y" );
      $query .= ",Stunde=".date( "G" );




      // Monatskorrektur für Jahresübersicht
      $ix = date("n") + 1;
      $i = 1;
      do {
        if ($i < $ix) {
           $query .= ",Korr".$i."=0"; 
          }
          else {
           $query .= ",Korr".$i."=1"; 
        }   
        $i++;
      } while ($i < 13);      



      $query .= "  ".$daten["zentralerTimestamp"];