mpi_3phasen_serie.php

#!/usr/bin/php
<?php

/*****************************************************************************
//  Solaranzeige Projekt             Copyright (C) [2016-2020]  [Ulrich Kunz]
//
//  Dieses Programm ist freie Software. Sie können es unter den Bedingungen
//  der GNU General Public License, wie von der Free Software Foundation
//  veröffentlicht, weitergeben und/oder modifizieren, entweder gemäß
//  Version 3 der Lizenz oder (nach Ihrer Option) jeder späteren Version.
//
//  Die Veröffentlichung dieses Programms erfolgt in der Hoffnung, daß es
//  Ihnen von Nutzen sein wird, aber OHNE IRGENDEINE GARANTIE, sogar ohne
//  die implizite Garantie der MARKTREIFE oder der VERWENDBARKEIT FÜR EINEN
//  BESTIMMTEN ZWECK. Details finden Sie in der GNU General Public License.
//
//  Ein original Exemplar der GNU General Public License finden Sie hier:
//  http://www.gnu.org/licenses/
//
//  Dies ist ein Programmteil des Programms "Solaranzeige"
//
//  Das Auslesen wird hier mit einer Schleife durchgeführt. Wie oft die Daten
//  ausgelesen und gespeichert werden steht in der user.config.php
//
//  Achtung! Der Regler sendet zwischendurch immer wieder asynchrone Daten!
//
*****************************************************************************/
$path_parts = pathinfo($argv[0]);
$Pfad = $path_parts['dirname'];
if (!is_file($Pfad."/1.user.config.php")) {
  // Handelt es sich um ein Multi Regler System?
  require($Pfad."/user.config.php");
}
require_once($Pfad."/phpinc/funktionen.inc.php");

if (!isset($funktionen)) {
  $funktionen = new funktionen();
}

$Tracelevel = 7;  //  1 bis 10  10 = Debug
$Device = "WR"; // WR = Wechselrichter

$RemoteDaten = true;
$Version = "";
$Startzeit = time();  // Timestamp festhalten
$funktionen->log_schreiben("-------------   Start  mpi_3phasen_serie.php   --------------- ","|--",6);

$funktionen->log_schreiben("Zentraler Timestamp: ".$zentralerTimestamp,"   ",8);
$aktuelleDaten = array();
$aktuelleDaten["zentralerTimestamp"] = $zentralerTimestamp;

setlocale(LC_TIME,"de_DE.utf8");


//  Hardware Version ermitteln.
$Teile =  explode(" ",$Platine);
if ($Teile[1] == "Pi") {
  $Version = trim($Teile[2]);
  if ($Teile[3] == "Model") {
    $Version .= trim($Teile[4]);
    if ($Teile[5] == "Plus") {
      $Version .= trim($Teile[5]);
    }
  }
}
$funktionen->log_schreiben("Hardware Version: ".$Version,"o  ",9);

switch($Version) {
  case "2B":
  break;
  case "3B":
  break;
  case "3BPlus":
  break;
  case "4B":
  break;
  default:
  break;
}



$USB1 = $funktionen->openUSB($USBRegler);
if (!is_resource($USB1)) {
  $funktionen->log_schreiben("USB Port kann nicht geöffnet werden. [1]","XX ",7);
  $funktionen->log_schreiben("Exit.... ","XX ",7);
  goto Ausgang;
}


/************************************************************************************
//  Sollen Befehle an den Wechselrichter gesendet werden?
//
************************************************************************************/
if (file_exists($Pfad."/../pipe/".$GeraeteNummer.".befehl.steuerung")) {

  $funktionen->log_schreiben("Steuerdatei '".$GeraeteNummer.".befehl.steuerung' vorhanden----","|- ",5);
  $Inhalt = file_get_contents($Pfad."/../pipe/".$GeraeteNummer.".befehl.steuerung");
  $Befehle = explode("\n",trim($Inhalt));
  $funktionen->log_schreiben("Befehle: ".print_r($Befehle,1),"|- ",9);

  for ($i = 0; $i < count($Befehle); $i++) {

    if ($i > 10) {
      //  Es werden nur maximal 10 Befehle pro Datei verarbeitet!
      break;
    }
    /*********************************************************************************
    //  In der Datei "befehle.ini.php" müssen alle gültigen Befehle aufgelistet
    //  werden, die man benutzen möchte.
    //  Achtung! Genau darauf achten, dass der Befehl richtig geschrieben wird,
    //  damit das Gerät keinen Schaden nimmt.
    //  QPI ist nur zum Testen ...
    //  Siehe Dokument:  Befehle_senden.pdf
    *********************************************************************************/
    if (file_exists($Pfad."/befehle.ini.php")) {

      $funktionen->log_schreiben("Die Befehlsliste 'befehle.ini.php' ist vorhanden----","|- ",9);
      $INI_File =  parse_ini_file($Pfad.'/befehle.ini.php', true);
      $Regler9 = $INI_File["Regler9"];
      $funktionen->log_schreiben("Befehlsliste: ".print_r($Regler9,1),"|- ",10);
      $Subst = $Befehle[$i];

      foreach ($Regler9 as $Template) {
        $Subst = $Befehle[$i];
        $l = strlen($Template);
        for ($p = 1; $p < $l; ++$p) {
          if ($Template[$p] == "#") {
            $Subst[$p] = "#";
          }
        }
        if ($Template == $Subst) {
          break;
        }
      }
      if ($Template != $Subst) {
        $funktionen->log_schreiben("Dieser Befehl ist nicht zugelassen. ".$Befehle[$i],"|o ",3);
        $funktionen->log_schreiben("Die Verarbeitung der Befehle wird abgebrochen.","|o ",3);
        break;
      }
    }
    else {
      $funktionen->log_schreiben("Die Befehlsliste 'befehle.ini.php' ist nicht vorhanden----","|- ",3);
      break;
    }

    $Wert = false;
    $Antwort = "";
    /************************************************************************
    //  Ab hier wird der Befehl gesendet.
    ************************************************************************/


    $Befehle[$i] = "^S".sprintf("%03X",strlen($Befehle[$i])+1).$Befehle[$i];

    $funktionen->log_schreiben("Befehl zur Ausführung:".$Befehle[$i],"|- ",3);
    $RAW_daten = $funktionen->mpi_usb_lesen($USB1, $Befehle[$i]);
    if ($RAW_daten === false) {
      $funktionen->log_schreiben("Befehl nicht ausgeführt: ".$Befehle[$i],"o  ",5);
      $funktionen->log_schreiben("Der Befehl wurde abgelehnt.","o  ",5);
      $funktionen->log_schreiben("Befehlsausführung abgebrochen","o  ",5);
      break;
    }
    else {
      $funktionen->log_schreiben("Befehl ".$Befehle[$i]." erfolgreich gesendet!","    ",9);
      $funktionen->log_schreiben("Antwort: ".$RAW_daten,"    ",5);
    }
  }
  $rc = unlink($Pfad."/../pipe/".$GeraeteNummer.".befehl.steuerung");
  if ($rc) {
    $funktionen->log_schreiben("Datei  /pipe/".$GeraeteNummer.".befehl.steuerung  gelöscht.","    ",8);
  }
}
else {
  $funktionen->log_schreiben("Steuerdatei '".$GeraeteNummer.".befehl.steuerung' nicht vorhanden----","|- ",9);
}

/*******************************************************************************
//
//  Befehle senden Ende
//
//  Hier beginnt das Auslesen der Daten
//
*******************************************************************************/


$i = 1;
do {
  $funktionen->log_schreiben("Die Daten werden ausgelesen...","+  ",9);

  /****************************************************************************
  //  Ab hier wird der Regler ausgelesen.
  //
  //  Ergebniswerte:
  //  $aktuelleDaten["Firmware"]                Nummer
  //  $aktuelleDaten["Produkt"]                 Text
  //  $aktuelleDaten["Objekt"]                  Text
  //  $aktuelleDaten["Batteriespannung"]
  //  $aktuelleDaten["Batterieentladestrom"]
  //  $aktuelleDaten["Batterieladestrom"]
  //  $aktuelleDaten["Ladestatus"]
  //  $aktuelleDaten["Solarstrom"]
  //  $aktuelleDaten["Solarspannung"]
  //  $aktuelleDaten["Solarleistung"]
  //  $aktuelleDaten["WattstundenGesamt"]
  //  $aktuelleDaten["WattstundenGesamtHeute"]
  //  $aktuelleDaten["WattstundenGesamtGestern"]
  //  $aktuelleDaten["maxWattHeute"]
  //  $aktuelleDaten["maxAmpHeute"]
  //  $aktuelleDaten["Temperatur"]
  //  $aktuelleDaten["Optionen"]
  //  $aktuelleDaten["ErrorCodes"]
  //
  ****************************************************************************/

  //
  //  Dummy Einträge solange noch keine Daten vom Wechselrichter geliefert werden.
  //
  $aktuelleDaten["WattstundenGesamtHeute"] = 0;
  $aktuelleDaten["WattstundenGesamtMonat"] = 0;
  $aktuelleDaten["WattstundenGesamtJahr"]  = 0;

  for ($k = 1; $k < 3; $k++) {
    $Befehl = "^P003PI";  //  Auslesen der Protokoll Nummer
    $RAW_daten = $funktionen->mpi_usb_lesen($USB1, $Befehl);
    if ($RAW_daten === false) {
      $funktionen->log_schreiben("Continue: ".$Befehl,"o  ",8);
      continue;
    }
    $aktuelleDaten = array_merge($aktuelleDaten, $funktionen->mpi_entschluesseln(substr($Befehl,5),$RAW_daten));
    break;
  }
  $funktionen->log_schreiben($RAW_daten,"   ",9);

  for ($k = 1; $k < 3; $k++) {
    $Befehl = "^P003GS";  //  Auslesen Stromwerte
    $RAW_daten = $funktionen->mpi_usb_lesen($USB1, $Befehl);
    if ($RAW_daten === false) {
      $funktionen->log_schreiben("Continue: ".$Befehl,"o  ",8);
      continue;
    }
    $aktuelleDaten = array_merge($aktuelleDaten, $funktionen->mpi_entschluesseln(substr($Befehl,5),$RAW_daten));
    break;
  }
  $funktionen->log_schreiben($RAW_daten,"   ",9);

  for ($k = 1; $k < 3; $k++) {
    $Befehl = "^P003PS";  //  Auslesen Power Status
    $RAW_daten = $funktionen->mpi_usb_lesen($USB1, $Befehl);
    if ($RAW_daten === false) {
      $funktionen->log_schreiben("Continue: ".$Befehl,"o  ",8);
      continue;
    }
    $aktuelleDaten = array_merge($aktuelleDaten, $funktionen->mpi_entschluesseln(substr($Befehl,5),$RAW_daten));
    break;
  }
  $funktionen->log_schreiben($RAW_daten,"   ",9);

  for ($k = 1; $k < 3; $k++) {
    $Befehl = "^P004CFS";  //  Auslesen Fehlercodes
    $RAW_daten = $funktionen->mpi_usb_lesen($USB1, $Befehl);
    if ($RAW_daten === false) {
      $funktionen->log_schreiben("Continue: ".$Befehl,"o  ",8);
      continue;
    }
    $aktuelleDaten = array_merge($aktuelleDaten, $funktionen->mpi_entschluesseln(substr($Befehl,5),$RAW_daten));
    break;
  }
  $funktionen->log_schreiben($RAW_daten,"   ",9);

  for ($k = 1; $k < 3; $k++) {
    $Befehl = "^P004MOD";  //  Auslesen Modus
    $RAW_daten = $funktionen->mpi_usb_lesen($USB1, $Befehl);
    if ($RAW_daten === false) {
      $funktionen->log_schreiben("Continue: ".$Befehl,"o  ",8);
      continue;
    }
    $aktuelleDaten = array_merge($aktuelleDaten, $funktionen->mpi_entschluesseln(substr($Befehl,5),$RAW_daten));
    break;
  }
  $funktionen->log_schreiben($RAW_daten,"   ",9);

  for ($k = 1; $k < 3; $k++) {
    $Befehl = "^P003WS";  //  Auslesen Warnungen
    $RAW_daten = $funktionen->mpi_usb_lesen($USB1, $Befehl);
    if ($RAW_daten === false) {
      $funktionen->log_schreiben("Continue: ".$Befehl,"o  ",8);
      continue;
    }
    $aktuelleDaten = array_merge($aktuelleDaten, $funktionen->mpi_entschluesseln(substr($Befehl,5),$RAW_daten));
    break;
  }
  $funktionen->log_schreiben($RAW_daten,"   ",9);



  for ($k = 1; $k < 3; $k++) {
    //  Achtung! Die Gesamtleistung kann nur ausgelesen werden, wenn Datum und Zeit
    //  im Gerät richtig eingegeben sind. Die Routine funktioniert! 9.12.2018
    $Summe = 0;
    $Befehl = "^P014ED".date("Ymd");  //  Auslesen der WattstundenGesamtHeute (aktueller Tag!)
    for ($n = 0; $n < strlen($Befehl); $n++) {
      $Summe = $Summe + ord($Befehl[$n]);
    }
    $hex = substr("00".hexdec(substr(dechex($Summe),-2)),-3);
    $RAW_daten = $funktionen->mpi_usb_lesen($USB1, $Befehl.$hex);
    if ($RAW_daten === false) {
      $funktionen->log_schreiben("Continue: ".$Befehl,"o  ",8);
      continue;
    }
    $aktuelleDaten = array_merge($aktuelleDaten, $funktionen->mpi_entschluesseln(substr($Befehl,5),$RAW_daten));
    break;
  }
  $funktionen->log_schreiben($RAW_daten,"   ",9);



  for ($k = 1; $k < 3; $k++) {
    //  Achtung! Die Gesamtleistung kann nur ausgelesen werden, wenn Datum und Zeit
    //  im Gerät richtig eingegeben sind. Die Routine funktioniert! 9.12.2018
    $Summe = 0;
    $Befehl = "^P012EM".date("Ym",strtotime("-1 month"));  //  Auslesen der WattstundenGesamtMonat
    for ($n = 0; $n < strlen($Befehl); $n++) {             //  nur Vormonat möglich! Aktueller Monat nicht.
      $Summe = $Summe + ord($Befehl[$n]);
    }
    $hex = substr("00".hexdec(substr(dechex($Summe),-2)),-3);
    $RAW_daten = $funktionen->mpi_usb_lesen($USB1, $Befehl.$hex);
    if ($RAW_daten === false) {
      $funktionen->log_schreiben("Continue: ".$Befehl,"o  ",8);
      continue;
    }
    $aktuelleDaten = array_merge($aktuelleDaten, $funktionen->mpi_entschluesseln(substr($Befehl,5),$RAW_daten));
    break;
  }
  $funktionen->log_schreiben($RAW_daten,"   ",9);


  for ($k = 1; $k < 3; $k++) {
    //  Achtung! Die Gesamtleistung kann nur ausgelesen werden, wenn Datum und Zeit
    //  im Gerät richtig eingegeben sind. Die Routine funktioniert! 9.12.2018
    $Summe = 0;

    $Befehl = "^P010EY".date("Y",strtotime("-1 year"));  //  Auslesen der WattstundenGesamtJahr
    for ($n = 0; $n < strlen($Befehl); $n++) {           //  Nur Vorjahr möglich! Aktuelles Jahr nicht.
      $Summe = $Summe + ord($Befehl[$n]);
    }
    $hex = substr("00".hexdec(substr(dechex($Summe),-2)),-3);
    $RAW_daten = $funktionen->mpi_usb_lesen($USB1, $Befehl.$hex);
    if ($RAW_daten === false) {
      $funktionen->log_schreiben("Continue: ".$Befehl,"o  ",8);
      continue;
    }
    $aktuelleDaten = array_merge($aktuelleDaten, $funktionen->mpi_entschluesseln(substr($Befehl,5),$RAW_daten));
    break;
  }
  $funktionen->log_schreiben($RAW_daten,"   ",9);


  for ($k = 1; $k < 3; $k++) {
    $Befehl = "^P003DM";  //  Auslesen Produkt
    $RAW_daten = $funktionen->mpi_usb_lesen($USB1, $Befehl);
    if ($RAW_daten === false) {
      $funktionen->log_schreiben("Continue: ".$Befehl,"o  ",8);
      continue;
    }
    $aktuelleDaten = array_merge($aktuelleDaten, $funktionen->mpi_entschluesseln(substr($Befehl,5),$RAW_daten));
    break;
  }
  $funktionen->log_schreiben($RAW_daten,"   ",9);

  for ($k = 1; $k < 3; $k++) {
    $Befehl = "^P003ET";  //  Auslesen Gesamte kWh seit Geräteherstellung
    $RAW_daten = $funktionen->mpi_usb_lesen($USB1, $Befehl);
    if ($RAW_daten === false) {
      $funktionen->log_schreiben("Continue: ".$Befehl,"o  ",8);
      $aktuelleDaten["KiloWattstundenTotal"] = 0;
      continue;
    }
    $aktuelleDaten = array_merge($aktuelleDaten, $funktionen->mpi_entschluesseln(substr($Befehl,5),$RAW_daten));
    break;
  }
  $funktionen->log_schreiben($RAW_daten,"   ",9);



  $Befehl = "^P005HECS";  //  Auslesen Energy control status
  $RAW_daten = $funktionen->mpi_usb_lesen($USB1, $Befehl);
  if ($RAW_daten === false) {
    $funktionen->log_schreiben("Befehl nicht ausgeführt: ".$Befehl,"o  ",8);
  }
  $funktionen->log_schreiben($RAW_daten,"   ",9);


  /****************************************************************************
  //  ENDE REGLER AUSLESEN      ENDE REGLER AUSLESEN      ENDE REGLER AUSLESEN
  ****************************************************************************/


  $funktionen->log_schreiben(var_export($aktuelleDaten,1),"   ",10);

  /**************************************************************************
  //  Falls ein ErrorCode vorliegt, wird er hier in einen lesbaren
  //  Text umgewandelt, sodass er als Fehlermeldung gesendet werden kann.
  //  Die Funktion ist noch nicht überall implementiert.
  **************************************************************************/
  $FehlermeldungText = "";


  /****************************************************************************
  //  Die Daten werden für die Speicherung vorbereitet.
  ****************************************************************************/
  $aktuelleDaten["Regler"] = $Regler;
  $aktuelleDaten["Objekt"] = $Objekt;
  if (empty($aktuelleDaten["Batterieleistung"])) {
    $aktuelleDaten["Batterieleistung"]  = 0;
  }

  /**************************************************************************
  //  Alle ausgelesenen Daten werden hier bei Bedarf als mqtt Messages
  //  an den mqtt-Broker Mosquitto gesendet.
  //  Achtung! Die Übertragung dauert ca. 30 Sekunden!
  **************************************************************************/
  if ($MQTT and $i == 1) {
    $funktionen->log_schreiben("MQTT Daten zum [ $MQTTBroker ] senden.","   ",1);
    require($Pfad."/mqtt_senden.php");
  }

  /****************************************************************************
  //  Zeit und Datum
  ****************************************************************************/
  //  Der Regler hat keine interne Uhr! Deshalb werden die Daten vom Raspberry benutzt.
  $aktuelleDaten["Timestamp"] = time();
  $aktuelleDaten["Monat"]     = date("n");
  $aktuelleDaten["Woche"]     = date("W");
  $aktuelleDaten["Wochentag"] = strftime("%A",time());
  $aktuelleDaten["Datum"]     = date("d.m.Y");
  $aktuelleDaten["Uhrzeit"]      = date("H:i:s");
  $aktuelleDaten["zentralerTimestamp"] = ($aktuelleDaten["zentralerTimestamp"]+10);



  /****************************************************************************
  //  InfluxDB  Zugangsdaten ...stehen in der user.config.php
  //  falls nicht, sind das hier die default Werte.
  ****************************************************************************/
  $aktuelleDaten["InfluxAdresse"] = $InfluxAdresse;
  $aktuelleDaten["InfluxPort"] = $InfluxPort;
  $aktuelleDaten["InfluxUser"] =  $InfluxUser;
  $aktuelleDaten["InfluxPassword"] = $InfluxPassword;
  $aktuelleDaten["InfluxDBName"] = $InfluxDBName;
  $aktuelleDaten["InfluxDaylight"] = $InfluxDaylight;
  $aktuelleDaten["InfluxDBLokal"] = $InfluxDBLokal;
  $aktuelleDaten["InfluxSSL"] = $InfluxSSL;
  $aktuelleDaten["Demodaten"] = false;


  $aktuelleDaten["Solarleistung"] = ($aktuelleDaten["Solarleistung1"] + $aktuelleDaten["Solarleistung2"]);
  $aktuelleDaten["Solarstrom"] = ($aktuelleDaten["Solarstrom1"] + $aktuelleDaten["Solarstrom2"]);



  if ($aktuelleDaten["Warnungen"] > 0 or $aktuelleDaten["ErrorCodes"] > 0) {
    $funktionen->log_schreiben("Fehlercode. ".$aktuelleDaten["ErrorCodes"]." Warnung: ".$aktuelleDaten["Warnungen"],"   ",7);
  }


  $funktionen->log_schreiben(print_r($aktuelleDaten,1),"*- ",9);



  /*********************************************************************
  //  Daten werden in die Influx Datenbank gespeichert.
  //  Lokal und Remote bei Bedarf.
  *********************************************************************/
  if ($InfluxDB_remote) {
    // Test ob die Remote Verbindung zur Verfügung steht.
    if ($RemoteDaten) {
      $rc = $funktionen->influx_remote_test();
      if ($rc) {
        $rc = $funktionen->influx_remote($aktuelleDaten);
        if ($rc) {
          $RemoteDaten = false;
        }
      }
      else {
        $RemoteDaten = false;
      }
    }
    if ($InfluxDB_local) {
      $rc = $funktionen->influx_local($aktuelleDaten);
    }
  }
  else {
    $rc = $funktionen->influx_local($aktuelleDaten);
  }




  if (is_file($Pfad."/1.user.config.php")) {
    $Zeitspanne = (9 - (time() - $Startzeit));
    $funktionen->log_schreiben("Multi-Regler-Ausgang. ".$Zeitspanne,"   ",2);
    if ($Zeitspanne > 0) {
      sleep($Zeitspanne);
    }
    break;
  }
  else {
    $funktionen->log_schreiben("Schleife: ".($i)." Zeitspanne: ".(floor((54 - (time() - $Startzeit))/($Wiederholungen-$i+1))),"   ",9);
    sleep(floor((54 - (time() - $Startzeit))/($Wiederholungen-$i+1)));
  }
  if ($Wiederholungen <= $i or $i >= 6) {
    $funktionen->log_schreiben("OK. Daten gelesen.","   ",9);
    $funktionen->log_schreiben("Schleife ".$i." Ausgang...","   ",8);
    break;
  }

  $i++;
} while (($Startzeit + 54) > time());




if (isset($aktuelleDaten["Firmware"]) and isset($aktuelleDaten["Regler"])) {


  /*********************************************************************
  //  Jede Minute werden bei Bedarf einige Werte zur Homematic Zentrale
  //  übertragen.
  *********************************************************************/
  if (isset($Homematic) and $Homematic == true) {
    $aktuelleDaten["Solarspannung"] = $aktuelleDaten["Solarspannung1"];
    $funktionen->log_schreiben("Daten werden zur HomeMatic übertragen...","   ",8);
    require($Pfad."/homematic.php");
  }

  /*********************************************************************
  //  Sollen Nachrichten an einen Messenger gesendet werden?
  //
  *********************************************************************/
  if (isset($Messenger) and $Messenger == true) {
    $funktionen->log_schreiben("Nachrichten versenden...","   ",8);
    require($Pfad."/meldungen_senden.php");
  }

  $funktionen->log_schreiben("OK. Datenübertragung erfolgreich.","   ",7);
}
else {
  $funktionen->log_schreiben("Keine gültigen Daten empfangen.","!! ",6);
}


Ausgang:

$funktionen->log_schreiben("-------------   Stop   mpi_3phasen_serie.php   --------------- ","|--",6);

return;






?>