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

no message

Browse Source
This commit is contained in:
Daniel Häfliger
2025-11-13 08:04:40 +01:00
parent c2161abb34
commit b223f944b8
3 changed files with 51 additions and 52 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
Int_VGT/form.json
View File

@@ -1,11 +1,5 @@
{
"elements": [
{
"type": "SelectInstance",
"name": "MQTTServer",
"caption": "MQTT Server",
"filter": "moduleID:{043EA491-84DA-4DFD-B9D4-44B4E63F23D1}"
},
{
"type": "ValidationTextBox",
"name": "DeviceID",
@@ -15,7 +9,7 @@
"actions": [
{
"type": "Label",
"label": "Dieses Modul erzeugt automatisch MQTT Server Devices für die beiden Topics:"
"label": "Dieses Modul registriert automatisch die MQTT Topics:"
},
{
"type": "Label",

2
Int_VGT/module.json
View File

@@ -5,7 +5,7 @@
"vendor": "",
"aliases": ["INT VGT Integration"],
"parentRequirements": [
"{7F8A48DD-F8AD-4F9C-8E6B-9E4D92DDB8F9}"
"{7F8A48DD-F8AD-4F9C-8E6B-9E4D92DDB8F9}"
],
"childRequirements": [],
"implemented": [],

93
Int_VGT/module.php
View File

@@ -8,18 +8,15 @@ class Int_VGT extends IPSModule
{
parent::Create();
// Properties
$this->RegisterPropertyInteger("MQTTServer", 0);
$this->RegisterPropertyString("DeviceID", "");
// Create script handler only once
// Create handler script
if (!@$this->GetIDForIdent("ReceiveScript")) {
$scriptID = IPS_CreateScript(0);
IPS_SetName($scriptID, "INTVGT_ReceiveHandler");
IPS_SetIdent($scriptID, "ReceiveScript");
IPS_SetParent($scriptID, $this->InstanceID);
IPS_SetScriptContent($scriptID, $this->GenerateReceiveScript());
$id = IPS_CreateScript(0);
IPS_SetName($id, "INTVGT_ReceiveHandler");
IPS_SetIdent($id, "ReceiveScript");
IPS_SetParent($id, $this->InstanceID);
IPS_SetScriptContent($id, $this->GenerateReceiveScript());
}
}
@@ -27,84 +24,92 @@ class Int_VGT extends IPSModule
{
parent::ApplyChanges();
$mqttServer = $this->ReadPropertyInteger("MQTTServer");
$deviceId = $this->ReadPropertyString("DeviceID");
$gatewayID = $this->GetGatewayID();
$deviceID = $this->ReadPropertyString("DeviceID");
if ($mqttServer == 0 || $deviceId == "") {
$this->SetStatus(104); // missing config
if ($gatewayID == 0 || $deviceID == "") {
$this->SetStatus(104);
return;
}
// Create MQTT Server Devices
$this->RegisterMQTTDevice("FeedbackRequest", "feedback-request/" . $deviceId);
$this->RegisterMQTTDevice("RemoteControlResponse", "remote-control-response/" . $deviceId);
// Create MQTT devices
$this->RegisterMQTTDevice("FeedbackRequest",
"feedback-request/" . $deviceID);
$this->RegisterMQTTDevice("RemoteControlResponse",
"remote-control-response/" . $deviceID);
$this->SetStatus(102);
}
private function RegisterMQTTDevice(string $ident, string $topic)
{
$instanceID = @$this->GetIDForIdent($ident);
$guidMQTTDevice = "{043EA491-84DA-4DFD-B9D4-44B4E63F23D1}";
if ($instanceID === false) {
$instanceID = IPS_CreateInstance("{058A5647-0C2F-4D7D-9F4B-50A28C7D83BA}"); // MQTT Server Device
IPS_SetParent($instanceID, $this->InstanceID);
IPS_SetIdent($instanceID, $ident);
IPS_SetName($instanceID, "MQTT Device: " . $ident);
$id = @$this->GetIDForIdent($ident);
if ($id === false) {
$id = IPS_CreateInstance($guidMQTTDevice);
IPS_SetParent($id, $this->InstanceID);
IPS_SetIdent($id, $ident);
IPS_SetName($id, "MQTT Device: " . $ident);
}
IPS_SetProperty($instanceID, "Topic", $topic);
IPS_SetProperty($instanceID, "Server", $this->ReadPropertyInteger("MQTTServer"));
IPS_SetProperty($instanceID, "Script", $this->GetIDForIdent("ReceiveScript"));
IPS_ApplyChanges($instanceID);
IPS_SetProperty($id, "Active", true);
IPS_SetProperty($id, "Topic", $topic);
IPS_SetProperty($id, "Script", $this->GetIDForIdent("ReceiveScript"));
IPS_ApplyChanges($id);
return $instanceID;
return $id;
}
private function GetGatewayID(): int
{
$instance = IPS_GetInstance($this->InstanceID);
return $instance['ConnectionID'];
}
/** Script to be executed when MQTT message is received */
private function GenerateReceiveScript(): string
{
return <<<SCR
return <<<PHP
<?php
\$parent = IPS_GetParent(\$_IPS['SELF']);
IPS_RequestAction(\$parent, "OnReceive", json_encode([
"Topic" => \$_IPS['Topic'],
"Value" => \$_IPS['VALUE']
]));
SCR;
PHP;
}
/** Called by ReceiveScript */
public function RequestAction($ident, $value)
{
if ($ident == "OnReceive") {
if ($ident === "OnReceive") {
$data = json_decode($value, true);
$this->OnReceiveMQTT($data["Topic"], $data["Value"]);
}
}
/** THIS IS YOUR CALLBACK FOR INCOMING MQTT MESSAGES */
private function OnReceiveMQTT(string $topic, string $value)
{
IPS_LogMessage("Int_VGT", "Received on $topic: $value");
IPS_LogMessage("Int_VGT", "Received: $topic -> $value");
// Here you implement later your handling logic
// Example: respond to feedback-request
$mqttServer = $this->ReadPropertyInteger("MQTTServer");
$gatewayID = $this->GetGatewayID();
// Auto responses (you can modify later)
if (str_contains($topic, "feedback-request")) {
$response = json_encode([
"status" => "ok",
"timestamp" => time()
]);
MQTT_Publish($mqttServer, str_replace("request", "response", $topic), $response, 0, false);
MQTT_Publish($gatewayID,
str_replace("request", "response", $topic),
json_encode(["status" => "ok"])
);
}
if (str_contains($topic, "remote-control-response")) {
// Echo back the same payload
MQTT_Publish($mqttServer, str_replace("response", "feedback", $topic), $value, 0, false);
MQTT_Publish($gatewayID,
str_replace("response", "feedback", $topic),
$value
);
}
}
}