dh/Symcon_Belevo_Energiemanagement
1
0
Fork 0
Code Issues 4 Pull Requests Actions Packages Projects Releases Wiki Activity

Version 2.0.0 Beta

Browse Source
This commit is contained in:
Daniel Häfliger
2025-04-29 07:20:42 +02:00
parent 51de28b1c0
commit b7bb55b7fa
37 changed files with 3557 additions and 164 deletions
Download Patch File Download Diff File Expand all files Collapse all files

303
Manager/module.php
View File

@@ -11,23 +11,51 @@ class Manager extends IPSModule
$this->RegisterPropertyInteger("Ueberschussleistung", 0);
$this->RegisterPropertyInteger("Netzbezug", 0); // Initialisierung mit 0
$this->RegisterPropertyString("Verbraucher_Liste", "[]");
$this->RegisterPropertyBoolean("HauptmanagerAktiv", false); // Initialisierung mit 0
$this->RegisterPropertyInteger("ManagerID", 0); // Initialisierung mit 0
$this->RegisterPropertyInteger("DatenHoch", 0); // Initialisierung mit 0
$this->RegisterPropertyInteger("DatenZuruck", 0); // Initialisierung mit 0
$this->RegisterPropertyInteger("Interval", 2); // Recheninterval
// Timer registrieren
$this->RegisterTimer("Timer_DistributeEnergy",5000,"IPS_RequestAction(" .$this->InstanceID .', "DistributeEnergy", "");');
// Timer registrieren
$this->RegisterTimer("Timer_DistributeEnergy",$this->ReadPropertyInteger("Interval")*1000,"IPS_RequestAction(" .$this->InstanceID .', "DistributeEnergy", "");');
}
public function ApplyChanges()
{
parent::ApplyChanges();
//Liste aller Verbraucher einlesen
$Verbraucher_Liste = $this->ReadPropertyString("Verbraucher_Liste");
$this->SetTimerInterval("Timer_DistributeEnergy",$this->ReadPropertyInteger("Interval")*1000);
}
public function RequestAction($Ident, $Value)
{
switch ($Ident) {
case "DistributeEnergy":
if($this->ReadPropertyBoolean("HauptmanagerAktiv")==true ){
$data = json_decode(GetValue($this->ReadPropertyInteger("DatenZuruck")), true);
IPS_LogMessage("Manager", print_r($data));
IPS_LogMessage("Manager", $data["timestamp"]);
if (isset($data["timestamp"])) {
$timestamp = $data["timestamp"];
$currentTime = time();
IPS_LogMessage("Manager", ($currentTime - $timestamp));
if (($currentTime - $timestamp) < 3600) {
$this->DistributeEnergy_Extern();
}
} else {
$this->DistributeEnergy();
}
}else{
$this->DistributeEnergy();
}
break;
case "ApplyChanges":
$this->ApplyChanges();
@@ -52,6 +80,7 @@ class Manager extends IPSModule
$remainingPower = $Peakleistung - $Netzbezug;
$Is_Peak_Shaving = true;
}
IPS_LogMessage("Manag anfang", $remainingPower);
// Alle Energieverbraucher auslesen und dekodieren
$Verbraucher_Liste = json_decode($this->ReadPropertyString("Verbraucher_Liste"), true);
@@ -80,18 +109,18 @@ class Manager extends IPSModule
foreach ($Verbraucher_Liste as $user) {
if (!IPS_InstanceExists($user["Verbraucher"])) {
IPS_LogMessage("Manager", "aufgerufen komisch");
continue;
}
// Werte direkt von der Verbraucher-Instanz abrufen
$Aktuelle_Leistung = GetValue(IPS_GetObjectIDByIdent("Aktuelle_Leistung", $user["Verbraucher"]));
$Aktuelle_Leistung = GetValue(IPS_GetObjectIDByIdent("Power", $user["Verbraucher"])); // Aktuelle Leistung durch Power ersetzt
$Bezogene_Energie = GetValue(IPS_GetObjectIDByIdent("Bezogene_Energie", $user["Verbraucher"]));
$PV_Prio = GetValue(IPS_GetObjectIDByIdent("PV_Prio", $user["Verbraucher"]));
$Sperre_Prio = GetValue(IPS_GetObjectIDByIdent("Sperre_Prio", $user["Verbraucher"]));
$idle = GetValue(IPS_GetObjectIDByIdent("Idle", $user["Verbraucher"]));
$powerStepsJson = GetValue(IPS_GetObjectIDByIdent("PowerSteps", $user["Verbraucher"]));
$powerSteps = json_decode($powerStepsJson, true);
$delta = GetValue(IPS_GetObjectIDByIdent("Leistung_Delta", $user["Verbraucher"]));
// Verbraucher-Daten zum gefilterten Array hinzufügen
$filteredVerbraucher[] = [
@@ -103,6 +132,7 @@ class Manager extends IPSModule
"Sperre_Prio" => $Sperre_Prio,
"Idle" => $idle,
"PowerSteps" => $powerSteps,
"Leistung_Delta" => $delta
];
// Überprüfen, ob alle Benutzer Idle = true sind, wenn einer nicht ist, wird später verworfen...
@@ -111,13 +141,18 @@ class Manager extends IPSModule
IPS_LogMessage("Manager", "nciht idle");
}
if(in_array(0, $powerSteps, true)){
// Addiere die aktuell bereits verwendete Leistung auf, um sie bei der verteilung zu berücksichtigen
$totalAktuelle_Leistung += $Aktuelle_Leistung;
$totalAktuelle_Leistung += ($Aktuelle_Leistung-$delta);
}
}
// Berücksichtigung der bereits verteilten Leistungen (nachher kann dafür wieder bei 0 begonnen werden zu verteilen)
$remainingPower += $totalAktuelle_Leistung;
// Abbrechen wenn es keine gefilterten User gibt
if (empty($filteredVerbraucher)) {
return;
@@ -140,14 +175,13 @@ class Manager extends IPSModule
$primaryKey = $Is_Peak_Shaving ? "Sperre_Prio" : "PV_Prio";
// Wenn die Prio geleich ist, sortiere danach welcher verbraucher bisher am wenigsten Energie bekommen hat.
if ($a[$primaryKey] == $b[$primaryKey]) {
return $a["Bezogene_Energie"] <=> $b["Bezogene_Energie"];
return round($a["Bezogene_Energie"]/2000) <=> round($b["Bezogene_Energie"]/2000);
}
return $a[$primaryKey] <=> $b[$primaryKey];
});
// Primärschlüssel für die Priorität basierend auf dem Parameter auswählen (für sortierung in gruppen anschliessend)
$priorityKey = $Is_Peak_Shaving ? "Sperre_Prio" : "PV_Prio";
// Schleife durch alle Prioritäten
$priorities = array_unique(
array_column($filteredVerbraucher, $priorityKey)
@@ -177,7 +211,7 @@ class Manager extends IPSModule
$withoutZero = [];
// Verbraucher die nicht 0 Annhemen können, bekommen einfach den tiefsten wert
foreach ($samePriorityUsers as $entry) {
if (in_array(0, $entry["PowerSteps"])) {
if (min($entry["PowerSteps"]) <= 0) {
$withZero[] = $entry;
} else {
$withoutZero[] = $entry;
@@ -190,69 +224,149 @@ class Manager extends IPSModule
$minPowerStep = min($entry["PowerSteps"]);
IPS_RequestAction($instanceID,"SetAktuelle_Leistung",$minPowerStep);
$remainingPower -= $entry["Aktuelle_Leistung"];
//$remainingPower -= $entry["Aktuelle_Leistung"];
}
}
// Nun die verteilen, die 0 erhalten können.
$samePriorityUsers = $withZero;
// Array für die verteilte Energie pro User erstellen
$userEnergyProv = [];
$userEnergyProv = array_fill_keys(array_column($samePriorityUsers, "InstanceID"), 0); // Initialisierung für jeden Benutzer auf 0 setzen
// Alle Schritte der Benutzer in einem Array sammeln
$allSteps = [];
foreach ($samePriorityUsers as $user) {
foreach ($user["PowerSteps"] as $step) {
$allSteps[] = [
"user" => $user["InstanceID"],
"step" => $step,
];
IPS_LogMessage("Manag", $remainingPower);
if($remainingPower>=0){
// Alle Schritte der Benutzer in einem Array sammeln
$allSteps = [];
foreach ($samePriorityUsers as $user) {
foreach ($user["PowerSteps"] as $step) {
if($step>=0){
$allSteps[] = [
"user" => $user["InstanceID"],
//"Leistung_Delta" => $user["Leistung_Delta"],
"step" => $step,
];}
}
}
// Sortiere die Schritte nach Größe
usort($allSteps, function ($a, $b) {
return $a["step"] <=> $b["step"];
});
//if remaining power >0
// Iteriere durch alle Schritte
foreach ($allSteps as $entry) {
$user = $entry["user"];
$powerstep = $entry["step"];
// Überprüfe, ob noch genügend verbleibende Energie für den nächsten Schritt vorhanden ist
if ($remainingPower >= $powerstep - $userEnergyProv[$user]) { // oder bedingung testen
// Aktualisiere die verbleibende Energie und die bereitgestellte Energie für den Benutzer
$remainingPower -= $powerstep - $userEnergyProv[$user];
$userEnergyProv[$user] = $powerstep;
}
}
//else
// mache invertierte verteilung
// Prüfen, dass jeder User mindestens seinen minimalwert an Leistung bekommt
foreach ($userEnergyProv as $userInstanceID => $leistung) {
$minimalleitsung = min(
array_column(
array_filter($allSteps, function ($entry) use (
$userInstanceID
) {
return $entry["user"] == $userInstanceID;
}),
"step"
)
);
// Jedem user den höheren der beiden werte aus minimalwert oder vergebenem zuteilen
$leistung = max($leistung, $minimalleitsung);
// Methode SetAktuelle_Leistung für jeden Verbraucher mit der entsprechenden Energie aufrufen
if (IPS_InstanceExists($userInstanceID)) {
IPS_RequestAction($userInstanceID,"SetAktuelle_Leistung",$leistung);
IPS_LogMessage("Manager", "aufgerufen setleistung if". $leistung);
}
}
}
else{
// Alle Schritte der Benutzer in einem Array sammeln
$allSteps = [];
foreach ($samePriorityUsers as $user) {
foreach ($user["PowerSteps"] as $step) {
if($step<=0){
$allSteps[] = [
"user" => $user["InstanceID"],
"Leistung_Delta" => $user["Leistung_Delta"],
"step" => -1*$step,
];}
}
}
// Sortiere die Schritte nach Größe
usort($allSteps, function ($a, $b) {
return $a["step"] <=> $b["step"];
});
$remainingPower = $remainingPower *-1;
// Iteriere durch alle Schritte
foreach ($allSteps as $entry) {
$user = $entry["user"];
$powerstep = $entry["step"];
// Überprüfe, ob noch genügend verbleibende Energie für den nächsten Schritt vorhanden ist
if ($remainingPower >= $powerstep - $userEnergyProv[$user]) { // oder bedingung testen
// Aktualisiere die verbleibende Energie und die bereitgestellte Energie für den Benutzer
$remainingPower -= $powerstep - $userEnergyProv[$user];
$userEnergyProv[$user] = $powerstep;
}
}
$remainingPower = $remainingPower *-1;
// Prüfen, dass jeder User mindestens seinen minimalwert an Leistung bekommt
foreach ($userEnergyProv as $userInstanceID => $leistung) {
$minimalleitsung = min(
array_column(
array_filter($allSteps, function ($entry) use (
$userInstanceID
) {
return $entry["user"] == $userInstanceID;
}),
"step"
)
);
// Jedem user den höheren der beiden werte aus minimalwert oder vergebenem zuteilen
$schreibleistung = max($leistung, $minimalleitsung)*-1;
// Methode SetAktuelle_Leistung für jeden Verbraucher mit der entsprechenden Energie aufrufen
if (IPS_InstanceExists($userInstanceID)) {
IPS_RequestAction($userInstanceID,"SetAktuelle_Leistung",$schreibleistung);
IPS_LogMessage("Manager", "aufgerufen setleistung else ".$schreibleistung);
}
}
}
// Sortiere die Schritte nach Größe
usort($allSteps, function ($a, $b) {
return $a["step"] <=> $b["step"];
});
// Iteriere durch alle Schritte
foreach ($allSteps as $entry) {
$user = $entry["user"];
$powerstep = $entry["step"];
// Überprüfe, ob noch genügend verbleibende Energie für den nächsten Schritt vorhanden ist
if ($remainingPower >= $powerstep - $userEnergyProv[$user]) {
// Aktualisiere die verbleibende Energie und die bereitgestellte Energie für den Benutzer
$remainingPower -= $powerstep - $userEnergyProv[$user];
$userEnergyProv[$user] = $powerstep;
}
}
// Prüfen, dass jeder User mindestens seinen minimalwert an Leistung bekommt
foreach ($userEnergyProv as $userInstanceID => $leistung) {
$minimalleitsung = min(
array_column(
array_filter($allSteps, function ($entry) use (
$userInstanceID
) {
return $entry["user"] == $userInstanceID;
}),
"step"
)
);
// Jedem user den höheren der beiden werte aus minimalwert oder vergebenem zuteilen
$leistung = max($leistung, $minimalleitsung);
// Methode SetAktuelle_Leistung für jeden Verbraucher mit der entsprechenden Energie aufrufen
if (IPS_InstanceExists($userInstanceID)) {
IPS_RequestAction($userInstanceID,"SetAktuelle_Leistung",$leistung);
IPS_LogMessage("Manager", "aufgerufen setleistung normal");
}
}
}
@@ -260,5 +374,72 @@ class Manager extends IPSModule
}
public function DistributeEnergy_Extern()
{
// Systemvariablen abrufen
$Netzbezug = GetValue($this->ReadPropertyInteger("Netzbezug"));
$Verbraucher_Liste = json_decode($this->ReadPropertyString("Verbraucher_Liste"), true);
$filteredVerbraucher = [];
// Fülle das Array mit allen entsprechenden Werten der Verbraucher ab
foreach ($Verbraucher_Liste as $user) {
// Werte direkt von der Verbraucher-Instanz abrufen
$Aktuelle_Leistung = GetValue(IPS_GetObjectIDByIdent("Aktuelle_Leistung", $user["Verbraucher"]));
$Bezogene_Energie = GetValue(IPS_GetObjectIDByIdent("Bezogene_Energie", $user["Verbraucher"]));
$PV_Prio = GetValue(IPS_GetObjectIDByIdent("PV_Prio", $user["Verbraucher"]));
$Sperre_Prio = GetValue(IPS_GetObjectIDByIdent("Sperre_Prio", $user["Verbraucher"]));
$idle = GetValue(IPS_GetObjectIDByIdent("Idle", $user["Verbraucher"]));
$powerStepsJson = GetValue(IPS_GetObjectIDByIdent("PowerSteps", $user["Verbraucher"]));
$delta = GetValue(IPS_GetObjectIDByIdent("Leistung_Delta", $user["Verbraucher"]));
$powerSteps = json_decode($powerStepsJson, true);
// Verbraucher-Daten zum gefilterten Array hinzufügen
$filteredVerbraucher[] = [
"Verbraucher" => $user["Verbraucher"],
"InstanceID" => $user["Verbraucher"],
"Aktuelle_Leistung" => $Aktuelle_Leistung,
"Bezogene_Energie" => $Bezogene_Energie,
"PV_Prio" => $PV_Prio,
"Sperre_Prio" => $Sperre_Prio,
"Idle" => $idle,
"PowerSteps" => $powerSteps,
"Leistung_Delta" => $delta,
"ParentManager" => $this->ReadPropertyInteger("ManagerID")
];
}
$sendarray = [];
$sendarray = [
"Users" => $filteredVerbraucher,
"Netzbezug" => $Netzbezug,
"Timestamp" => time()
];
RequestAction($this->ReadPropertyInteger("DatenHoch"), json_encode($sendarray));
$answerArray = json_decode(GetValue($this->ReadPropertyInteger("DatenZuruck")), true);
foreach($answerArray["User"] as $user){
IPS_RequestAction($user["InstanceID"],"GetCurrentData", $answerArray["Is_Peak_Shaving"]);
IPS_RequestAction($user["InstanceID"],"SetAktuelle_Leistung",$user["Set_Leistung"]);
}
}
}
?>