167 lines
4.8 KiB
PHP
167 lines
4.8 KiB
PHP
<?php
|
|
|
|
declare(strict_types=1);
|
|
|
|
class VGT_Sub extends IPSModule
|
|
{
|
|
public function Create()
|
|
{
|
|
parent::Create();
|
|
|
|
// Device ID
|
|
$this->RegisterPropertyString("DeviceID", "");
|
|
|
|
// Editable response values
|
|
$this->RegisterVariableFloat("PowerProduction", "Power Production", "", 10);
|
|
$this->EnableAction("PowerProduction");
|
|
|
|
$this->RegisterVariableFloat("StateOfCharge", "State of Charge", "", 20);
|
|
$this->EnableAction("StateOfCharge");
|
|
|
|
$this->RegisterVariableBoolean("IsRunning", "Is Running", "", 30);
|
|
$this->EnableAction("IsRunning");
|
|
|
|
$this->RegisterVariableBoolean("IsReady", "Is Ready", "", 40);
|
|
$this->EnableAction("IsReady");
|
|
|
|
$this->RegisterVariableInteger("MinSOC", "Min SOC", "", 50);
|
|
$this->EnableAction("MinSOC");
|
|
|
|
$this->RegisterVariableInteger("MaxSOC", "Max SOC", "", 60);
|
|
$this->EnableAction("MaxSOC");
|
|
|
|
|
|
// Remote-Control incoming values (read-only)
|
|
$this->RegisterVariableFloat("RC_PowerSetpoint", "RC Power Setpoint", "", 70);
|
|
$this->RegisterVariableString("RC_Strategy", "RC Strategy", "", 80);
|
|
|
|
// Connect to MQTT client splitter
|
|
$this->ConnectParent('{F7A0DD2E-7684-95C0-64C2-D2A9DC47577B}');
|
|
}
|
|
|
|
|
|
public function ApplyChanges()
|
|
{
|
|
parent::ApplyChanges();
|
|
|
|
$this->ConnectParent('{F7A0DD2E-7684-95C0-64C2-D2A9DC47577B}');
|
|
|
|
$device = $this->ReadPropertyString("DeviceID");
|
|
|
|
// Subscribe to both incoming topics
|
|
$topics = [
|
|
"feedback-request/" . $device,
|
|
"remote-control-request/" . $device
|
|
];
|
|
|
|
foreach ($topics as $t) {
|
|
$this->SendDataToParent(json_encode([
|
|
"DataID" => "{043E0F88-B2B0-4DF4-B1A6-64FB1C385D3C}",
|
|
"PacketType" => 8, // SUBSCRIBE
|
|
"Topic" => $t
|
|
]));
|
|
}
|
|
}
|
|
|
|
|
|
// Handle UI actions
|
|
public function RequestAction($Ident, $Value)
|
|
{
|
|
SetValue($this->GetIDForIdent($Ident), $Value);
|
|
}
|
|
|
|
|
|
// MQTT RECEIVE
|
|
public function ReceiveData($JSONString)
|
|
{
|
|
$data = json_decode($JSONString);
|
|
|
|
if (!isset($data->Topic) || !isset($data->Payload)) {
|
|
return;
|
|
}
|
|
|
|
$topic = $data->Topic;
|
|
$payload = $data->Payload;
|
|
|
|
$device = $this->ReadPropertyString("DeviceID");
|
|
|
|
if ($topic === "feedback-request/" . $device) {
|
|
$this->HandleFeedbackRequest();
|
|
}
|
|
|
|
if ($topic === "remote-control-request/" . $device) {
|
|
$this->HandleRemoteControlRequest($payload);
|
|
}
|
|
}
|
|
|
|
|
|
// FEEDBACK REQUEST → reply with state JSON
|
|
private function HandleFeedbackRequest()
|
|
{
|
|
$response = [
|
|
"power_production" => GetValue($this->GetIDForIdent("PowerProduction")),
|
|
"state_of_charge" => GetValue($this->GetIDForIdent("StateOfCharge")),
|
|
"is_running" => GetValue($this->GetIDForIdent("IsRunning")),
|
|
"is_ready" => GetValue($this->GetIDForIdent("IsReady")),
|
|
"min_soc" => GetValue($this->GetIDForIdent("MinSOC")),
|
|
"max_soc" => GetValue($this->GetIDForIdent("MaxSOC"))
|
|
];
|
|
|
|
$topic = "feedback-response/" . $this->ReadPropertyString("DeviceID");
|
|
$this->SendToMQTT($topic, json_encode($response));
|
|
}
|
|
|
|
|
|
// REMOTE CONTROL REQUEST → write values + respond
|
|
private function HandleRemoteControlRequest(string $payload)
|
|
{
|
|
$data = json_decode($payload, true);
|
|
if (!is_array($data)) {
|
|
return;
|
|
}
|
|
|
|
if (isset($data["power_setpoint"])) {
|
|
SetValue($this->GetIDForIdent("RC_PowerSetpoint"), $data["power_setpoint"]);
|
|
}
|
|
|
|
if (isset($data["strategy"])) {
|
|
SetValue($this->GetIDForIdent("RC_Strategy"), $data["strategy"]);
|
|
}
|
|
|
|
// Respond with same payload
|
|
$topic = "remote-control-response/" . $this->ReadPropertyString("DeviceID");
|
|
$this->SendToMQTT($topic, json_encode($data));
|
|
}
|
|
|
|
|
|
// MQTT SEND
|
|
private function SendToMQTT(string $topic, string $payload)
|
|
{
|
|
$packet = [
|
|
"DataID" => "{043E0F88-B2B0-4DF4-B1A6-64FB1C385D3C}",
|
|
"PacketType" => 3, // PUBLISH
|
|
"QualityOfService" => 0,
|
|
"Retain" => false,
|
|
"Topic" => $topic,
|
|
"Payload" => $payload
|
|
];
|
|
|
|
$this->SendDataToParent(json_encode($packet));
|
|
}
|
|
|
|
|
|
// CONFIG FORM
|
|
public function GetConfigurationForm()
|
|
{
|
|
return json_encode([
|
|
"elements" => [
|
|
[
|
|
"type" => "ValidationTextBox",
|
|
"name" => "DeviceID",
|
|
"caption" => "Device ID"
|
|
]
|
|
]
|
|
]);
|
|
}
|
|
}
|
|
?>
|