no message
This commit is contained in:
belevo\mh
0
VGT_Sub/README.md
Normal file
0
VGT_Sub/README.md
Normal file
9
VGT_Sub/form.json
Normal file
9
VGT_Sub/form.json
Normal file
@@ -0,0 +1,9 @@
|
|||||||
|
{
|
||||||
|
"elements": [
|
||||||
|
{
|
||||||
|
"type": "ValidationTextBox",
|
||||||
|
"name": "DeviceID",
|
||||||
|
"caption": "Device ID"
|
||||||
|
}
|
||||||
|
]
|
||||||
|
}
|
||||||
17
VGT_Sub/module.json
Normal file
17
VGT_Sub/module.json
Normal file
@@ -0,0 +1,17 @@
|
|||||||
|
{
|
||||||
|
"id": "{0F001E51-E914-6444-B635-D46DDE0C3810}",
|
||||||
|
"name": "VGT_Sub",
|
||||||
|
"type": 3,
|
||||||
|
"vendor": "Belevo",
|
||||||
|
"aliases": [
|
||||||
|
"VGT MQTT-Client"
|
||||||
|
],
|
||||||
|
"prefix": "VGT",
|
||||||
|
"parentRequirements": [
|
||||||
|
"{043EA491-0325-4ADD-8FC2-A30C8EEB4D3F}"
|
||||||
|
],
|
||||||
|
"childRequirements": [],
|
||||||
|
"implemented": [
|
||||||
|
"{7F7632D9-FA40-4F38-8DEA-C83CD4325A32}"
|
||||||
|
]
|
||||||
|
}
|
||||||
227
VGT_Sub/module.php
Normal file
227
VGT_Sub/module.php
Normal file
@@ -0,0 +1,227 @@
|
|||||||
|
<?php
|
||||||
|
|
||||||
|
declare(strict_types=1);
|
||||||
|
|
||||||
|
class VGT_Sub extends IPSModule
|
||||||
|
{
|
||||||
|
public function Create()
|
||||||
|
{
|
||||||
|
parent::Create();
|
||||||
|
|
||||||
|
$this->RegisterPropertyString('DeviceID', '');
|
||||||
|
|
||||||
|
/** -------------------------------------------
|
||||||
|
* STATUS Variablen (schreibbar)
|
||||||
|
* ------------------------------------------*/
|
||||||
|
|
||||||
|
$this->RegisterVariableInteger('PowerProduction', 'Power Production', '', 10);
|
||||||
|
$this->EnableAction('PowerProduction');
|
||||||
|
|
||||||
|
$this->RegisterVariableBoolean('IsReady', 'Is Ready', '', 11);
|
||||||
|
$this->EnableAction('IsReady');
|
||||||
|
|
||||||
|
$this->RegisterVariableBoolean('IsRunning', 'Is Running', '', 12);
|
||||||
|
$this->EnableAction('IsRunning');
|
||||||
|
|
||||||
|
$this->RegisterVariableInteger('StateOfCharge', 'State of Charge', '', 13);
|
||||||
|
$this->EnableAction('StateOfCharge');
|
||||||
|
|
||||||
|
$this->RegisterVariableInteger('MinSOC', 'Min SOC', '', 14);
|
||||||
|
$this->EnableAction('MinSOC');
|
||||||
|
|
||||||
|
$this->RegisterVariableInteger('MaxSOC', 'Max SOC', '', 15);
|
||||||
|
$this->EnableAction('MaxSOC');
|
||||||
|
|
||||||
|
|
||||||
|
/** -------------------------------------------
|
||||||
|
* REMOTE CONTROL Variablen (read-only)
|
||||||
|
* ------------------------------------------*/
|
||||||
|
|
||||||
|
$this->RegisterVariableInteger('PowerSetpoint', 'Power Setpoint', '', 20);
|
||||||
|
$this->RegisterVariableString('Strategy', 'Strategy', '', 21);
|
||||||
|
|
||||||
|
// Debug
|
||||||
|
$this->RegisterVariableString('RemoteControlPayload', 'Remote Control Payload', '', 30);
|
||||||
|
|
||||||
|
|
||||||
|
/** -------------------------------------------
|
||||||
|
* FEEDBACK REQUEST Variablen (read-only)
|
||||||
|
* ------------------------------------------*/
|
||||||
|
$this->RegisterVariableString('FeedbackRequestPayload', 'Feedback Request Payload', '', 40);
|
||||||
|
|
||||||
|
// WICHTIG: Kein ConnectParent mehr hier -> Modul ist nur Client/Device
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
public function ApplyChanges()
|
||||||
|
{
|
||||||
|
parent::ApplyChanges();
|
||||||
|
|
||||||
|
// Kein ConnectParent mehr -> Parent wird in der Konsole verknüpft
|
||||||
|
// (MQTT Server ODER MQTT Client Gateway)
|
||||||
|
|
||||||
|
$device = $this->ReadPropertyString('DeviceID');
|
||||||
|
if ($device === '') {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
// READ: Topics abonnieren
|
||||||
|
$this->Subscribe("feedback-request/$device");
|
||||||
|
|
||||||
|
// WRITE: Remote-Control-Requests ebenfalls abonnieren
|
||||||
|
$this->Subscribe("remote-control-request/$device");
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
/** -------------------------------------------
|
||||||
|
* VARIABLE WRITE SUPPORT
|
||||||
|
* ------------------------------------------*/
|
||||||
|
public function RequestAction($Ident, $Value)
|
||||||
|
{
|
||||||
|
$this->SetValue($Ident, $Value);
|
||||||
|
|
||||||
|
// Optional: Hier könntest du auch direkt publizieren,
|
||||||
|
// wenn eine Variable geändert wird.
|
||||||
|
// Beispiel (auskommentiert, nur als Vorlage):
|
||||||
|
|
||||||
|
$device = $this->ReadPropertyString('DeviceID');
|
||||||
|
if ($device !== '') {
|
||||||
|
switch ($Ident) {
|
||||||
|
case 'PowerProduction':
|
||||||
|
case 'IsReady':
|
||||||
|
case 'IsRunning':
|
||||||
|
case 'StateOfCharge':
|
||||||
|
case 'MinSOC':
|
||||||
|
case 'MaxSOC':
|
||||||
|
$payload = json_encode([
|
||||||
|
'power_production' => $this->GetValue('PowerProduction'),
|
||||||
|
'is_ready' => $this->GetValue('IsReady'),
|
||||||
|
'is_running' => $this->GetValue('IsRunning'),
|
||||||
|
'state_of_charge' => $this->GetValue('StateOfCharge'),
|
||||||
|
'min_soc' => $this->GetValue('MinSOC'),
|
||||||
|
'max_soc' => $this->GetValue('MaxSOC')
|
||||||
|
]);
|
||||||
|
$this->Publish("status/$device", $payload);
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
/** -------------------------------------------
|
||||||
|
* MQTT SUBSCRIBE
|
||||||
|
* ------------------------------------------*/
|
||||||
|
private function Subscribe(string $topic): void
|
||||||
|
{
|
||||||
|
$packet = [
|
||||||
|
'PacketType' => 8, // SUBSCRIBE
|
||||||
|
'QualityOfService' => 0,
|
||||||
|
'Retain' => false,
|
||||||
|
'Topic' => $topic,
|
||||||
|
'Payload' => ''
|
||||||
|
];
|
||||||
|
|
||||||
|
$this->SendDataToParent(json_encode([
|
||||||
|
'DataID' => '{043EA491-0325-4ADD-8FC2-A30C8EEB4D3F}'
|
||||||
|
] + $packet));
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
/** -------------------------------------------
|
||||||
|
* MQTT PUBLISH
|
||||||
|
* ------------------------------------------*/
|
||||||
|
private function Publish(string $topic, string $payload): void
|
||||||
|
{
|
||||||
|
$packet = [
|
||||||
|
'PacketType' => 3, // PUBLISH
|
||||||
|
'QualityOfService' => 0,
|
||||||
|
'Retain' => false,
|
||||||
|
'Topic' => $topic,
|
||||||
|
'Payload' => $payload
|
||||||
|
];
|
||||||
|
|
||||||
|
$this->SendDataToParent(json_encode([
|
||||||
|
'DataID' => '{043EA491-0325-4ADD-8FC2-A30C8EEB4D3F}'
|
||||||
|
] + $packet));
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
/** -------------------------------------------
|
||||||
|
* RECEIVE DATA
|
||||||
|
* ------------------------------------------*/
|
||||||
|
public function ReceiveData($JSONString)
|
||||||
|
{
|
||||||
|
$data = json_decode($JSONString, true);
|
||||||
|
if (!is_array($data)) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
$topic = $data['Topic'] ?? '';
|
||||||
|
$payload = $data['Payload'] ?? '';
|
||||||
|
|
||||||
|
$device = $this->ReadPropertyString('DeviceID');
|
||||||
|
if ($device === '') {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
/** -------------------------------------------
|
||||||
|
* 1️⃣ FEEDBACK REQUEST
|
||||||
|
* request: feedback-request/deviceId
|
||||||
|
* response: feedback-response/deviceId
|
||||||
|
* ------------------------------------------*/
|
||||||
|
if ($topic === "feedback-request/$device") {
|
||||||
|
|
||||||
|
// 1. Payload speichern
|
||||||
|
$this->SetValue('FeedbackRequestPayload', $payload);
|
||||||
|
|
||||||
|
// 2. JSON interpretieren (falls vorhanden)
|
||||||
|
$json = json_decode($payload, true);
|
||||||
|
if (!is_array($json)) {
|
||||||
|
$json = [];
|
||||||
|
}
|
||||||
|
|
||||||
|
// 3. Antwort-Mix erstellen (Payload + Status)
|
||||||
|
$response = array_merge($json, [
|
||||||
|
"power_production" => $this->GetValue('PowerProduction'),
|
||||||
|
"is_ready" => $this->GetValue('IsReady'),
|
||||||
|
"is_running" => $this->GetValue('IsRunning'),
|
||||||
|
"state_of_charge" => $this->GetValue('StateOfCharge'),
|
||||||
|
"min_soc" => $this->GetValue('MinSOC'),
|
||||||
|
"max_soc" => $this->GetValue('MaxSOC')
|
||||||
|
]);
|
||||||
|
|
||||||
|
// 4. Antwort senden
|
||||||
|
$this->Publish("feedback-response/$device", json_encode($response));
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
/** -------------------------------------------
|
||||||
|
* 2️⃣ REMOTE CONTROL REQUEST
|
||||||
|
* request: remote-control-request/deviceId
|
||||||
|
* response: remote-control-response/deviceId
|
||||||
|
* ------------------------------------------*/
|
||||||
|
if ($topic === "remote-control-request/$device") {
|
||||||
|
|
||||||
|
// 1. Payload speichern
|
||||||
|
$this->SetValue('RemoteControlPayload', $payload);
|
||||||
|
|
||||||
|
$json = json_decode($payload, true);
|
||||||
|
if (is_array($json)) {
|
||||||
|
|
||||||
|
if (array_key_exists('power_setpoint', $json)) {
|
||||||
|
$this->SetValue('PowerSetpoint', (int)$json['power_setpoint']);
|
||||||
|
}
|
||||||
|
|
||||||
|
if (array_key_exists('strategy', $json)) {
|
||||||
|
$this->SetValue('Strategy', (string)$json['strategy']);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// 2. Echo Response
|
||||||
|
$this->Publish("remote-control-response/$device", $payload);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
Reference in New Issue
Block a user