Hannes/SeMonitoring
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Delete Monitoring Client directory

Browse Source
This commit is contained in:
J.H. Artworks
2024-01-04 13:26:26 +01:00
committed by GitHub
parent f8c26830b1
commit 452c2f8cae
3 changed files with 0 additions and 188 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Monitoring Client/form.json
-20
View File
@@ -1,20 +0,0 @@
{
"elements":
[
{ "type": "SelectCategory", "name": "ParseCategoryID", "caption": "Target" },
{ "type": "SelectObject", "name": "MqttCLientID", "caption": "MQTT-Client" },
{ "type": "ValidationTextBox", "name": "Projectnumber", "caption": "Projectnumber" },
{ "type": "ValidationTextBox", "name": "Projectname", "caption": "Projectname" },
{ "type": "NumberSpinner", "name": "ISP", "caption": "ISP-Number" },
{ "type": "NumberSpinner", "name": "Updatetime", "caption": "Updatetime","suffix": "seconds","minimum ": "10" }
],
"actions":
[
],
"status":
[
]
}
Monitoring Client/module.json
-14
View File
@@ -1,14 +0,0 @@
{
"id": "{12369413-F10C-57D1-FB84-5BA243EFEE5C}",
"name": "Monitoring Client",
"type": 3,
"vendor": "J.H. Artworks",
"aliases":
[
],
"url": "https://jh-artworks.com",
"parentRequirements": [],
"childRequirements": [],
"implemented": [],
"prefix": "SEMC"
}
Monitoring Client/module.php
-154
View File
@@ -1,154 +0,0 @@
<?
// Klassendefinition
class MonitoringClient extends IPSModule {
// Überschreibt die interne IPS_Create($id) Funktion
public function Create() {
// Diese Zeile nicht löschen.
parent::Create();
$this->RegisterPropertyInteger("ParseCategoryID","0");
$this->RegisterPropertyInteger("MqttCLientID","0");
$this->RegisterPropertyString("Projectnumber","");
$this->RegisterPropertyString("Projectname","");
$this->RegisterPropertyInteger("ISP","1");
$this->RegisterPropertyInteger("Updatetime","20");
$this->RegisterTimer("Update", 0, 'SEMC_SendTopic('.$this->InstanceID.');');
}
// Überschreibt die intere IPS_ApplyChanges($id) Funktion
public function ApplyChanges() {
// Diese Zeile nicht löschen
parent::ApplyChanges();
$this->SetTimerInterval("Update", $this->ReadPropertyInteger("Updatetime") * 1000);
}
/**
* Die folgenden Funktionen stehen automatisch zur Verfügung, wenn das Modul über die "Module Control" eingefügt wurden.
* Die Funktionen werden, mit dem selbst eingerichteten Prefix, in PHP und JSON-RPC wiefolgt zur Verfügung gestellt:
*
* DWM_SendMessage($id);
*
*/
/* Publish a given payload over a MQTT server under
a given topic without having to manually create a
MQTT server device */
public function MqttPublish($server_id, $topic, $payload, $retain) {
// ensure server instance exists
if(!IPS_InstanceExists($server_id)) {
return false;
}
// convert array structure to json string
if(is_array($payload)) $payload = json_encode($payload);
// determine data type
if(is_string($payload)) {
$ips_var_type = 3;
} else if(is_float($payload)) {
$ips_var_type = 2;
} else if(is_int($payload)) {
$ips_var_type = 1;
} else if(is_bool($payload)) {
$ips_var_type = 0;
} else { // unsupported
return false;
}
$module_id = "{01C00ADD-D04E-452E-B66A-D253278743FE}" /* Module ID of MQTT Server Device */;
$ident = "TempMQTTDevice";
// enter semaphore to ensure the temporary device gets used by one thread at a time
if(IPS_SemaphoreEnter($ident, 100)) {
// get temporary MQTT Server Device or create if needed
$id = @IPS_GetObjectIDByIdent($ident, $_IPS['SELF']);
if($id === false) {
$id = @IPS_CreateInstance($module_id);
if($id === false) {
return false;
}
IPS_SetParent($id, $_IPS['SELF']);
IPS_SetIdent($id, $ident);
}
// ensure the specified server instance is actually compatible
if(!IPS_IsInstanceCompatible($id, $server_id)) {
return false;
}
// ensure that the temporary device is actually connected to the correct server instance
$inst_config = IPS_GetInstance($id);
if($inst_config["ConnectionID"] != $server_id) {
IPS_DisconnectInstance($id);
if(!@IPS_ConnectInstance($id, $server_id)) {
return false;
}
}
// name object to help with debugging
IPS_SetName($id, "Temporary MQTT Server Device for topic " . $topic);
// configure temporary device
$config_arr = array(
"Retain" => $retain,
"Topic" => $topic,
"Type" => $ips_var_type
);
$config_str = json_encode($config_arr);
IPS_SetConfiguration($id, $config_str);
IPS_ApplyChanges($id);
// get Value variable and use it to publish the payload
$var_id = @IPS_GetObjectIDByIdent("Value", $id);
RequestAction($var_id, $payload);
IPS_SemaphoreLeave($ident);
} else { // semaphore timeout
return false;
}
return true;
} // MQTT_Publish
public function SendTopic() {
// Discord webhook URL
$catId = $this->ReadPropertyInteger("ParseCategoryID");
$mqttId = $this->ReadPropertyInteger("MqttCLientID");
$projectnumber = $this->ReadPropertyString("Projectnumber");
$projectname = $this->ReadPropertyString("Projectname");
$ispnumber = $this->ReadPropertyInteger("ISP");
$updatetime = $this->ReadPropertyInteger("Updatetime");
$catChilds = IPS_GetChildrenIDs($catId);
foreach ($catChilds as $catChild) {
$childids = IPS_GetChildrenIDs($catChild);
$parname = IPS_GetName($catChild);
foreach ($childids as $childid){
$varInfo = IPS_GetVariable($childid);
$changedtime = $varInfo["VariableChanged"];
$varname = IPS_GetName($childid);
$topic = $projectnumber. "/ISP" .$ispnumber. "/". $parname."_".$varname;
$time = time();
$payload = getvalue($childid);
if($changedtime > time() - $updatetime){
SEMC_MqttPublish($this->InstanceID,$mqttId, $topic, $payload, false);
}
}
}
}
}
?>