new
This commit is contained in:
Johannes Holzwarth | SE-Inno GmbH
@@ -0,0 +1,38 @@
|
|||||||
|
{
|
||||||
|
"elements":
|
||||||
|
[
|
||||||
|
{ "type": "SelectCategory", "name": "ParseNotifyCategoryID", "caption": "Digital-Objects Target ID" },
|
||||||
|
{ "type": "SelectCategory", "name": "ParseAlarmCategoryID", "caption": "Alarm-Objects Target ID" },
|
||||||
|
{ "type": "SelectCategory", "name": "ParseAnalogCategoryID", "caption": "Analog-Objects Target ID" },
|
||||||
|
|
||||||
|
{ "type": "NumberSpinner", "name": "Projectnumber", "caption": "Projectnumber without leading P Character" },
|
||||||
|
{ "type": "ValidationTextBox", "name": "Projectname", "caption": "Projectname" },
|
||||||
|
|
||||||
|
{ "type": "NumberSpinner", "name": "ISP", "caption": "ISP-Number" },
|
||||||
|
{ "type": "SelectInstance", "name": "VisuId", "caption": "Web Visu" },
|
||||||
|
{ "type": "CheckBox", "name": "SendNotification", "caption": "Send Notification" },
|
||||||
|
{ "type": "CheckBox", "name": "LogValues", "caption": "Log Values" },
|
||||||
|
|
||||||
|
{ "type": "Select", "name": "SslHttp", "caption": "SSL ?",
|
||||||
|
"options": [
|
||||||
|
{ "caption": "Normal", "value": "http://" },
|
||||||
|
{ "caption": "SSL", "value": "https://" }
|
||||||
|
]
|
||||||
|
},
|
||||||
|
{ "type": "ValidationTextBox", "name": "InfluxServer", "caption": "Influx Server" },
|
||||||
|
{ "type": "NumberSpinner", "name": "InfluxPort", "caption": "Influx Port" },
|
||||||
|
{ "type": "ValidationTextBox", "name": "InfluxDatabase", "caption": "Influx Database" },
|
||||||
|
|
||||||
|
{ "type": "NumberSpinner", "name": "UpdateintervallValues", "caption": "Updateintervall Values in Seconds" },
|
||||||
|
{ "type": "NumberSpinner", "name": "UpdateintervallAlarms", "caption": "Updateintervall Alarms in Seconds" }
|
||||||
|
|
||||||
|
],
|
||||||
|
"actions":
|
||||||
|
[
|
||||||
|
{ "type": "Button", "label": "Check Connection", "onClick": "SEMS_checkInfluxState($id);" }
|
||||||
|
],
|
||||||
|
"status":
|
||||||
|
[
|
||||||
|
|
||||||
|
]
|
||||||
|
}
|
||||||
@@ -0,0 +1,14 @@
|
|||||||
|
{
|
||||||
|
"id": "{C07DA6C0-41B2-2651-08E8-D8F3CFEC9546}",
|
||||||
|
"name": "Monitoring Server",
|
||||||
|
"type": 3,
|
||||||
|
"vendor": "J.H. Artworks",
|
||||||
|
"aliases":
|
||||||
|
[
|
||||||
|
],
|
||||||
|
"url": "https://jh-artworks.com",
|
||||||
|
"parentRequirements": [],
|
||||||
|
"childRequirements": [],
|
||||||
|
"implemented": [],
|
||||||
|
"prefix": "SEMS"
|
||||||
|
}
|
||||||
@@ -0,0 +1,316 @@
|
|||||||
|
<?
|
||||||
|
|
||||||
|
// Klassendefinition
|
||||||
|
class MonitoringServer extends IPSModule {
|
||||||
|
// Überschreibt die interne IPS_Create($id) Funktion
|
||||||
|
public function Create() {
|
||||||
|
// Diese Zeile nicht löschen.
|
||||||
|
parent::Create();
|
||||||
|
|
||||||
|
$this->RegisterPropertyInteger("ParseNotifyCategoryID","0");
|
||||||
|
$this->RegisterPropertyInteger("ParseAlarmCategoryID","0");
|
||||||
|
$this->RegisterPropertyInteger("ParseAnalogCategoryID","0");
|
||||||
|
|
||||||
|
$this->RegisterPropertyInteger("ISP","1");
|
||||||
|
$this->RegisterPropertyInteger("VisuId","0");
|
||||||
|
|
||||||
|
$this->RegisterPropertyInteger("Projectnumber",123456);
|
||||||
|
$this->RegisterPropertyString("Projectname","Musterprojekt");
|
||||||
|
$this->RegisterPropertyString("InfluxDatabase","monitoring");
|
||||||
|
|
||||||
|
$this->RegisterPropertyBoolean("SendNotification","false");
|
||||||
|
|
||||||
|
$this->RegisterPropertyBoolean("LogValues","true");
|
||||||
|
|
||||||
|
$this->RegisterPropertyString("SslHttp","http://");
|
||||||
|
$this->RegisterPropertyString("InfluxServer","172.16.9.106");
|
||||||
|
$this->RegisterPropertyInteger("InfluxPort",8086);
|
||||||
|
|
||||||
|
|
||||||
|
$this->RegisterPropertyInteger("UpdateintervallValues","30");
|
||||||
|
$this->RegisterPropertyInteger("UpdateintervallAlarms","10");
|
||||||
|
|
||||||
|
|
||||||
|
$this->RegisterTimer("UpdateAlarms", 0, 'SEMS_checkAlarms('.$this->InstanceID.');');
|
||||||
|
$this->RegisterTimer("UpdateValues", 0, 'SEMS_checkValues('.$this->InstanceID.');');
|
||||||
|
|
||||||
|
$this->RegisterVariableInteger("AlarmVarCount", "Number of Alarmvalues", "", 0);
|
||||||
|
$this->RegisterVariableInteger("AlarmActiveCount", "Number of Values in Alarmstate", "", 1);
|
||||||
|
$this->RegisterVariableInteger("AnalogVarCount", "Number of Analogvalues", "", 2);
|
||||||
|
$this->RegisterVariableInteger("DigitalVarCount", "Number of DigitalValues", "", 3);
|
||||||
|
$this->RegisterVariableString("InfluxState", "Influx-DB State", "", 4);
|
||||||
|
$this->RegisterVariableString("InfluxMessage", "Influx-DB Message", "", 5);
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
// Überschreibt die intere IPS_ApplyChanges($id) Funktion
|
||||||
|
public function ApplyChanges() {
|
||||||
|
|
||||||
|
$this->SetTimerInterval("UpdateAlarms", $this->ReadPropertyInteger("UpdateintervallAlarms") * 1000);
|
||||||
|
$this->SetTimerInterval("UpdateValues", $this->ReadPropertyInteger("UpdateintervallValues") * 1000);
|
||||||
|
|
||||||
|
// Diese Zeile nicht löschen
|
||||||
|
parent::ApplyChanges();
|
||||||
|
}
|
||||||
|
/**
|
||||||
|
* 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:
|
||||||
|
*
|
||||||
|
*
|
||||||
|
*/
|
||||||
|
|
||||||
|
public function checkInfluxState(){
|
||||||
|
|
||||||
|
$domain = $this->ReadPropertyString("InfluxServer");
|
||||||
|
$port = $this->ReadPropertyInteger("InfluxPort");
|
||||||
|
|
||||||
|
$starttime = microtime(true);
|
||||||
|
$file = fsockopen ($domain, $port, $errno, $errstr, 10);
|
||||||
|
$stoptime = microtime(true);
|
||||||
|
$status = 0;
|
||||||
|
|
||||||
|
if (!$file) $status = -1; // Site is down
|
||||||
|
else {
|
||||||
|
fclose($file);
|
||||||
|
$status = ($stoptime - $starttime) * 1000;
|
||||||
|
$status = floor($status);
|
||||||
|
}
|
||||||
|
print_r($status);
|
||||||
|
return $status;
|
||||||
|
}
|
||||||
|
|
||||||
|
public function Write2Influx($value, $ssl, $host, $port, $db, $system, $category, $valuename)
|
||||||
|
{
|
||||||
|
$out = $ssl.$host.':'.$port.'/write?db='.$db.'';
|
||||||
|
|
||||||
|
|
||||||
|
$ch = curl_init($out);
|
||||||
|
|
||||||
|
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1 );
|
||||||
|
curl_setopt($ch, CURLOPT_POST, 1 );
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
if (is_bool($value) == true){
|
||||||
|
|
||||||
|
if ($value == true){
|
||||||
|
curl_setopt($ch, CURLOPT_POSTFIELDS, $system.','.$category.'='.$valuename.' value=1');
|
||||||
|
}
|
||||||
|
else{
|
||||||
|
curl_setopt($ch, CURLOPT_POSTFIELDS, $system.','.$category.'='.$valuename.' value=0');
|
||||||
|
}
|
||||||
|
//echo 'es war ein bool ';
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
if (is_integer($value) == true){
|
||||||
|
curl_setopt($ch, CURLOPT_POSTFIELDS, $system.','.$category.'='.$valuename.' value=' .$value);
|
||||||
|
}
|
||||||
|
|
||||||
|
if (is_float($value) == true){
|
||||||
|
curl_setopt($ch, CURLOPT_POSTFIELDS, $system.','.$category.'='.$valuename.' value=' . number_format($value/1,1,'.','') );
|
||||||
|
//echo 'es war ein float ';
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public function checkAlarms() {
|
||||||
|
$catAlarmId = $this->ReadPropertyInteger("ParseAlarmCategoryID");
|
||||||
|
$visuId = $this->ReadPropertyInteger("VisuId");
|
||||||
|
|
||||||
|
$projectnumber = $this->ReadPropertyInteger("Projectnumber");
|
||||||
|
$projectname = $this->ReadPropertyString("Projectname");
|
||||||
|
$ispnumber = $this->ReadPropertyInteger("ISP");
|
||||||
|
|
||||||
|
$sendit = $this->ReadPropertyBoolean("SendNotification");
|
||||||
|
$inalarmcount = 0;
|
||||||
|
$alarmvalues = 0;
|
||||||
|
$catChilds = IPS_GetChildrenIDs($catAlarmId);
|
||||||
|
|
||||||
|
if ($catAlarmId > 0){
|
||||||
|
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);
|
||||||
|
$time = time();
|
||||||
|
$payload = GetValueBoolean($childid);
|
||||||
|
$alarmvalues++;
|
||||||
|
if ($sendit == true){
|
||||||
|
if ($this->notify($childid, $visuId, $catAlarmId, $projectnumber, $projectname, $ispnumber) == true){
|
||||||
|
$inalarmcount++;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
SetValueInteger($this->GetIDForIdent("AlarmVarCount"),$alarmvalues);
|
||||||
|
SetValueInteger($this->GetIDForIdent("AlarmActiveCount"),$inalarmcount);
|
||||||
|
$rootcat = IPS_GetParent($catAlarmId);
|
||||||
|
if ($inalarmcount > 0 && $rootcat >0){
|
||||||
|
IPS_SetIcon($rootcat,"Alert");
|
||||||
|
}else{
|
||||||
|
IPS_SetIcon($rootcat,"");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
public function checkValues() {
|
||||||
|
|
||||||
|
$catNotifyId = $this->ReadPropertyInteger("ParseNotifyCategoryID");
|
||||||
|
$catAnalogId = $this->ReadPropertyInteger("ParseAnalogCategoryID");
|
||||||
|
|
||||||
|
$projectnumber = $this->ReadPropertyInteger("Projectnumber");
|
||||||
|
$projectname = $this->ReadPropertyString("Projectname");
|
||||||
|
$updatetime = $this->ReadPropertyInteger("UpdateintervallValues");
|
||||||
|
$ispnumber = $this->ReadPropertyInteger("ISP");
|
||||||
|
|
||||||
|
$logit = $this->ReadPropertyBoolean("LogValues");
|
||||||
|
|
||||||
|
|
||||||
|
$numberofvalues = 0;
|
||||||
|
|
||||||
|
$ssl = $this->ReadPropertyString("SslHttp");
|
||||||
|
$server = $this->ReadPropertyString("InfluxServer");
|
||||||
|
$port = $this->ReadPropertyInteger("InfluxPort");
|
||||||
|
$db = $this->ReadPropertyString("InfluxDatabase");
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
if ($catAnalogId > 0){
|
||||||
|
|
||||||
|
$catChilds = IPS_GetChildrenIDs($catAnalogId);
|
||||||
|
|
||||||
|
foreach ($catChilds as $catChild) { //for each object in category
|
||||||
|
|
||||||
|
|
||||||
|
$objchildids = IPS_GetChildrenIDs($catChild); //get variables of objects
|
||||||
|
$parname = IPS_GetName($catChild);
|
||||||
|
|
||||||
|
foreach ($objchildids as $objchildid){
|
||||||
|
|
||||||
|
$varInfo = IPS_GetVariable($objchildid);
|
||||||
|
$changedtime = $varInfo["VariableChanged"];
|
||||||
|
$varname = IPS_GetName($objchildid);
|
||||||
|
$time = time();
|
||||||
|
$payload = GetValue($objchildid);
|
||||||
|
if(is_float($payload)) {
|
||||||
|
$payload = round($payload, 2);
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
$numberofvalues++;
|
||||||
|
if($changedtime > $time - $updatetime){
|
||||||
|
|
||||||
|
$parname = str_replace(" ","", $parname);
|
||||||
|
$varname = str_replace(" ","", $varname);
|
||||||
|
|
||||||
|
$system = "P".$projectnumber."_ISP".$ispnumber;
|
||||||
|
$category = "Analog";
|
||||||
|
$valuename = $parname."_".$varname;
|
||||||
|
// if($this->state["status"] == "pass"){ }
|
||||||
|
|
||||||
|
Write2Influx($payload, $ssl, $server, $port, $db, $system, $category, $valuename);
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
SetValueInteger($this->GetIDForIdent("AnalogVarCount"),$numberofvalues);
|
||||||
|
$numberofvalues = 0;
|
||||||
|
|
||||||
|
|
||||||
|
if ($catNotifyId > 0){
|
||||||
|
|
||||||
|
$catChilds = IPS_GetChildrenIDs($catNotifyId);
|
||||||
|
|
||||||
|
foreach ($catChilds as $catChild) { //for each object in category
|
||||||
|
|
||||||
|
|
||||||
|
$objchildids = IPS_GetChildrenIDs($catChild); //get variables of objects
|
||||||
|
$parname = IPS_GetName($catChild);
|
||||||
|
|
||||||
|
foreach ($objchildids as $objchildid){
|
||||||
|
|
||||||
|
$varInfo = IPS_GetVariable($objchildid);
|
||||||
|
$changedtime = $varInfo["VariableChanged"];
|
||||||
|
$varname = IPS_GetName($objchildid);
|
||||||
|
$time = time();
|
||||||
|
$payload = GetValue($objchildid);
|
||||||
|
|
||||||
|
$numberofvalues++;
|
||||||
|
if($changedtime > $time - $updatetime){
|
||||||
|
|
||||||
|
$parname = str_replace(" ","", $parname);
|
||||||
|
$varname = str_replace(" ","", $varname);
|
||||||
|
|
||||||
|
$system = "P".$projectnumber."_ISP".$ispnumber;
|
||||||
|
$category = "Digital";
|
||||||
|
$valuename = $parname."_".$varname;
|
||||||
|
// if($this->state["status"] == "pass"){ }
|
||||||
|
|
||||||
|
Write2Influx($payload, $ssl, $server, $port, $db, $system, $category, $valuename);
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
SetValueInteger($this->GetIDForIdent("DigitalVarCount"),$numberofvalues);
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
private function notify($trigid, $webfrontid, $targetid, $projectnumber, $projectname, $ispnr){
|
||||||
|
|
||||||
|
|
||||||
|
$art = $projectnumber." | ".$projectname. " | ISP ".$ispnr;
|
||||||
|
$ico = "Flame";
|
||||||
|
|
||||||
|
$smname = IPS_GetName(IPS_GetParent($trigid))."_".IPS_GetName($trigid);
|
||||||
|
|
||||||
|
if (GetValueBoolean($trigid) == true && ($this->GetBuffer($smname) == "true")) {
|
||||||
|
|
||||||
|
$this->SetBuffer($smname, "false");
|
||||||
|
|
||||||
|
VISU_PostNotification($webfrontid, $art, $smname, $ico, $targetid);
|
||||||
|
WFC_PushNotification($webfrontid, $art, $smname, "", $targetid);
|
||||||
|
|
||||||
|
|
||||||
|
}
|
||||||
|
elseif (GetValueBoolean($trigid) == false) {
|
||||||
|
$this->SetBuffer($smname, "true");
|
||||||
|
}
|
||||||
|
|
||||||
|
if (GetValueBoolean($trigid) == true){
|
||||||
|
return true;
|
||||||
|
}else{
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
?>
|
||||||
@@ -0,0 +1,40 @@
|
|||||||
|
{
|
||||||
|
"elements":
|
||||||
|
[
|
||||||
|
{ "type": "SelectCategory", "name": "ParseNotifyCategoryID", "caption": "Digital-Objects Target ID" },
|
||||||
|
{ "type": "SelectCategory", "name": "ParseAlarmCategoryID", "caption": "Alarm-Objects Target ID" },
|
||||||
|
{ "type": "SelectCategory", "name": "ParseAnalogCategoryID", "caption": "Analog-Objects Target ID" },
|
||||||
|
|
||||||
|
{ "type": "NumberSpinner", "name": "Projectnumber", "caption": "Projectnumber without leading P Character" },
|
||||||
|
{ "type": "ValidationTextBox", "name": "Projectname", "caption": "Projectname" },
|
||||||
|
{ "type": "ValidationTextBox", "name": "Projectlocation", "caption": "Projectlocation" },
|
||||||
|
{ "type": "ValidationTextBox", "name": "Projecttags", "caption": "Projecttags" },
|
||||||
|
|
||||||
|
{ "type": "NumberSpinner", "name": "ISP", "caption": "ISP-Number" },
|
||||||
|
{ "type": "SelectInstance", "name": "VisuId", "caption": "Web Visu" },
|
||||||
|
{ "type": "CheckBox", "name": "SendNotification", "caption": "Send Notification" },
|
||||||
|
{ "type": "CheckBox", "name": "LogValues", "caption": "Log Values" },
|
||||||
|
|
||||||
|
{ "type": "Select", "name": "SslHttp", "caption": "SSL ?",
|
||||||
|
"options": [
|
||||||
|
{ "caption": "Normal", "value": "http://" },
|
||||||
|
{ "caption": "SSL", "value": "https://" }
|
||||||
|
]
|
||||||
|
},
|
||||||
|
{ "type": "ValidationTextBox", "name": "InfluxServer", "caption": "Influx Server" },
|
||||||
|
{ "type": "NumberSpinner", "name": "InfluxPort", "caption": "Influx Port" },
|
||||||
|
{ "type": "ValidationTextBox", "name": "InfluxToken", "caption": "Influx API Token" },
|
||||||
|
{ "type": "ValidationTextBox", "name": "InfluxOrg", "caption": "Influx Org." },
|
||||||
|
{ "type": "NumberSpinner", "name": "UpdateintervallValues", "caption": "Updateintervall Values in Seconds" },
|
||||||
|
{ "type": "NumberSpinner", "name": "UpdateintervallAlarms", "caption": "Updateintervall Alarms in Seconds" }
|
||||||
|
|
||||||
|
],
|
||||||
|
"actions":
|
||||||
|
[
|
||||||
|
{ "type": "Button", "label": "Check Connection", "onClick": "SEMS2_checkInfluxState($id);" }
|
||||||
|
],
|
||||||
|
"status":
|
||||||
|
[
|
||||||
|
|
||||||
|
]
|
||||||
|
}
|
||||||
@@ -0,0 +1,14 @@
|
|||||||
|
{
|
||||||
|
"id": "{7352D2BC-6E14-3DAB-AF95-F8ED26D5A75C}",
|
||||||
|
"name": "Monitoring Server Influx V2",
|
||||||
|
"type": 3,
|
||||||
|
"vendor": "J.H. Artworks",
|
||||||
|
"aliases":
|
||||||
|
[
|
||||||
|
],
|
||||||
|
"url": "https://jh-artworks.com",
|
||||||
|
"parentRequirements": [],
|
||||||
|
"childRequirements": [],
|
||||||
|
"implemented": [],
|
||||||
|
"prefix": "SEMS2"
|
||||||
|
}
|
||||||
@@ -0,0 +1,262 @@
|
|||||||
|
<?
|
||||||
|
|
||||||
|
declare(strict_types=1);
|
||||||
|
|
||||||
|
include_once __DIR__ . '/../libs/vendor/autoload.php';
|
||||||
|
|
||||||
|
use InfluxDB2\Model\WritePrecision;
|
||||||
|
|
||||||
|
// Klassendefinition
|
||||||
|
class MonitoringServerInfluxV2 extends IPSModule {
|
||||||
|
// Überschreibt die interne IPS_Create($id) Funktion
|
||||||
|
public function Create() {
|
||||||
|
// Diese Zeile nicht löschen.
|
||||||
|
parent::Create();
|
||||||
|
|
||||||
|
$this->RegisterPropertyInteger("ParseNotifyCategoryID","0");
|
||||||
|
$this->RegisterPropertyInteger("ParseAlarmCategoryID","0");
|
||||||
|
$this->RegisterPropertyInteger("ParseAnalogCategoryID","0");
|
||||||
|
|
||||||
|
$this->RegisterPropertyInteger("ISP","1");
|
||||||
|
$this->RegisterPropertyInteger("VisuId","0");
|
||||||
|
|
||||||
|
$this->RegisterPropertyInteger("Projectnumber",123456);
|
||||||
|
$this->RegisterPropertyString("Projectname","Musterprojekt");
|
||||||
|
$this->RegisterPropertyString("Projectlocation","Urbach");
|
||||||
|
$this->RegisterPropertyString("Projecttags","street=Raiffeisenstrasse streetnumber=17");
|
||||||
|
|
||||||
|
$this->RegisterPropertyBoolean("SendNotification","false");
|
||||||
|
|
||||||
|
$this->RegisterPropertyBoolean("LogValues","true");
|
||||||
|
|
||||||
|
$this->RegisterPropertyString("SslHttp","http://");
|
||||||
|
$this->RegisterPropertyString("InfluxServer","172.16.9.xxx");
|
||||||
|
$this->RegisterPropertyInteger("InfluxPort",8086);
|
||||||
|
|
||||||
|
$this->RegisterPropertyString("InfluxToken","");
|
||||||
|
$this->RegisterPropertyString("InfluxOrg","SE-Inno");
|
||||||
|
|
||||||
|
$this->RegisterPropertyInteger("UpdateintervallValues","30");
|
||||||
|
$this->RegisterPropertyInteger("UpdateintervallAlarms","10");
|
||||||
|
|
||||||
|
|
||||||
|
$this->RegisterTimer("UpdateAlarms", 0, 'SEMS_checkAlarms('.$this->InstanceID.');');
|
||||||
|
$this->RegisterTimer("UpdateValues", 0, 'SEMS_checkValues('.$this->InstanceID.');');
|
||||||
|
|
||||||
|
$this->RegisterVariableInteger("AlarmVarCount", "Number of Alarmvalues", "", 0);
|
||||||
|
$this->RegisterVariableInteger("AlarmActiveCount", "Number of Values in Alarmstate", "", 1);
|
||||||
|
$this->RegisterVariableInteger("AnalogVarCount", "Number of Analogvalues", "", 2);
|
||||||
|
$this->RegisterVariableInteger("DigitalVarCount", "Number of DigitalValues", "", 3);
|
||||||
|
$this->RegisterVariableString("InfluxState", "Influx-DB State", "", 4);
|
||||||
|
$this->RegisterVariableString("InfluxMessage", "Influx-DB Message", "", 5);
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
// Überschreibt die intere IPS_ApplyChanges($id) Funktion
|
||||||
|
public function ApplyChanges() {
|
||||||
|
|
||||||
|
$this->SetTimerInterval("UpdateAlarms", $this->ReadPropertyInteger("UpdateintervallAlarms") * 1000);
|
||||||
|
$this->SetTimerInterval("UpdateValues", $this->ReadPropertyInteger("UpdateintervallValues") * 1000);
|
||||||
|
|
||||||
|
// Diese Zeile nicht löschen
|
||||||
|
parent::ApplyChanges();
|
||||||
|
}
|
||||||
|
/**
|
||||||
|
* 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:
|
||||||
|
*
|
||||||
|
*
|
||||||
|
*/
|
||||||
|
|
||||||
|
public $client = "";
|
||||||
|
public $writeApi = "";
|
||||||
|
public $state = "";
|
||||||
|
public function connectInflux(){
|
||||||
|
|
||||||
|
$ssl = $this->ReadPropertyString("SslHttp");
|
||||||
|
$server = $this->ReadPropertyString("InfluxServer");
|
||||||
|
$port = $this->ReadPropertyInteger("InfluxPort");
|
||||||
|
$token = $this->ReadPropertyString("InfluxToken");
|
||||||
|
$org = $this->ReadPropertyString("InfluxOrg");
|
||||||
|
$projectnumber = $this->ReadPropertyInteger("Projectnumber");
|
||||||
|
$ispnumber = $this->ReadPropertyInteger("ISP");
|
||||||
|
|
||||||
|
|
||||||
|
$this->client = new InfluxDB2\Client([
|
||||||
|
"url" => $ssl.$server.":".$port,
|
||||||
|
"token" => $token,
|
||||||
|
"bucket" => "P".$projectnumber."_ISP".$ispnumber,
|
||||||
|
"org" => $org,
|
||||||
|
"precision" => InfluxDB2\Model\WritePrecision::S
|
||||||
|
]);
|
||||||
|
$this->writeApi = $this->client->createWriteApi();
|
||||||
|
|
||||||
|
$this->state = $this->client->health();
|
||||||
|
|
||||||
|
SetValueString($this->GetIDForIdent("InfluxState"),$this->state["status"]);
|
||||||
|
SetValueString($this->GetIDForIdent("InfluxMessage"),$this->state["message"]);
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
public function checkInfluxState(){
|
||||||
|
|
||||||
|
$this->connectInflux();
|
||||||
|
print_r($this->client->health());
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
public function checkAlarms() {
|
||||||
|
$catAlarmId = $this->ReadPropertyInteger("ParseAlarmCategoryID");
|
||||||
|
$visuId = $this->ReadPropertyInteger("VisuId");
|
||||||
|
|
||||||
|
$projectnumber = $this->ReadPropertyInteger("Projectnumber");
|
||||||
|
$projectname = $this->ReadPropertyString("Projectname");
|
||||||
|
$ispnumber = $this->ReadPropertyInteger("ISP");
|
||||||
|
|
||||||
|
$sendit = $this->ReadPropertyBoolean("SendNotification");
|
||||||
|
$inalarmcount = 0;
|
||||||
|
$alarmvalues = 0;
|
||||||
|
$catChilds = IPS_GetChildrenIDs($catAlarmId);
|
||||||
|
|
||||||
|
if ($catAlarmId > 0){
|
||||||
|
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);
|
||||||
|
$time = time();
|
||||||
|
$payload = GetValueBoolean($childid);
|
||||||
|
$alarmvalues++;
|
||||||
|
if ($sendit == true){
|
||||||
|
if ($this->notify($childid, $visuId, $catAlarmId, $projectnumber, $projectname, $ispnumber) == true){
|
||||||
|
$inalarmcount++;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
SetValueInteger($this->GetIDForIdent("AlarmVarCount"),$alarmvalues);
|
||||||
|
SetValueInteger($this->GetIDForIdent("AlarmActiveCount"),$inalarmcount);
|
||||||
|
$rootcat = IPS_GetParent($catAlarmId);
|
||||||
|
if ($inalarmcount > 0 && $rootcat >0){
|
||||||
|
IPS_SetIcon($rootcat,"Alert");
|
||||||
|
}else{
|
||||||
|
IPS_SetIcon($rootcat,"");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
public function checkValues() {
|
||||||
|
|
||||||
|
$catNotifyId = $this->ReadPropertyInteger("ParseNotifyCategoryID");
|
||||||
|
$catAnalogId = $this->ReadPropertyInteger("ParseAnalogCategoryID");
|
||||||
|
|
||||||
|
$projectnumber = $this->ReadPropertyInteger("Projectnumber");
|
||||||
|
$projectname = $this->ReadPropertyString("Projectname");
|
||||||
|
$projectlocation = $this->ReadPropertyString("Projectlocation");
|
||||||
|
$projecttags = $this->ReadPropertyString("Projecttags");
|
||||||
|
$updatetime = $this->ReadPropertyInteger("UpdateintervallValues");
|
||||||
|
$ispnumber = $this->ReadPropertyInteger("ISP");
|
||||||
|
$org = $this->ReadPropertyString("InfluxOrg");
|
||||||
|
|
||||||
|
$logit = $this->ReadPropertyBoolean("LogValues");
|
||||||
|
|
||||||
|
$catChilds = IPS_GetChildrenIDs($catAnalogId);
|
||||||
|
$numberofvalues = 0;
|
||||||
|
|
||||||
|
$this->connectInflux();
|
||||||
|
|
||||||
|
if ($catAnalogId > 0){
|
||||||
|
|
||||||
|
foreach ($catChilds as $catChild) { //for each object in category
|
||||||
|
|
||||||
|
|
||||||
|
$objchildids = IPS_GetChildrenIDs($catChild); //get variables of objects
|
||||||
|
$parname = IPS_GetName($catChild);
|
||||||
|
|
||||||
|
foreach ($objchildids as $objchildid){
|
||||||
|
|
||||||
|
$varInfo = IPS_GetVariable($objchildid);
|
||||||
|
$changedtime = $varInfo["VariableChanged"];
|
||||||
|
$varname = IPS_GetName($objchildid);
|
||||||
|
$time = time();
|
||||||
|
$payload = GetValue($objchildid);
|
||||||
|
if(is_float($payload)) {
|
||||||
|
$payload = round($payload, 2);
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
$numberofvalues++;
|
||||||
|
if($changedtime > $time - $updatetime){
|
||||||
|
|
||||||
|
$parname = str_replace(" ","", $parname);
|
||||||
|
$varname = str_replace(" ","", $varname);
|
||||||
|
|
||||||
|
$dataArray = [
|
||||||
|
'name' => $parname."_".$varname,
|
||||||
|
'tags' => ["projectname=".$projectname." location=".$projectlocation." ".$projecttags],
|
||||||
|
'fields' => ["value" => $payload],
|
||||||
|
'time' => $time
|
||||||
|
];
|
||||||
|
|
||||||
|
if($this->state["status"] == "pass"){
|
||||||
|
$this->writeApi->write($dataArray, WritePrecision::S, "P".$projectnumber."_ISP".$ispnumber, $org);
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
SetValueInteger($this->GetIDForIdent("AnalogVarCount"),$numberofvalues);
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
private function notify($trigid, $webfrontid, $targetid, $projectnumber, $projectname, $ispnr){
|
||||||
|
|
||||||
|
|
||||||
|
$art = $projectnumber." | ".$projectname. " | ISP ".$ispnr;
|
||||||
|
$ico = "Flame";
|
||||||
|
|
||||||
|
$smname = IPS_GetName(IPS_GetParent($trigid))."_".IPS_GetName($trigid);
|
||||||
|
|
||||||
|
if (GetValueBoolean($trigid) == true && ($this->GetBuffer($smname) == "true")) {
|
||||||
|
|
||||||
|
$this->SetBuffer($smname, "false");
|
||||||
|
|
||||||
|
VISU_PostNotification($webfrontid, $art, $smname, $ico, $targetid);
|
||||||
|
WFC_PushNotification($webfrontid, $art, $smname, "", $targetid);
|
||||||
|
|
||||||
|
|
||||||
|
}
|
||||||
|
elseif (GetValueBoolean($trigid) == false) {
|
||||||
|
$this->SetBuffer($smname, "true");
|
||||||
|
}
|
||||||
|
|
||||||
|
if (GetValueBoolean($trigid) == true){
|
||||||
|
return true;
|
||||||
|
}else{
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
?>
|
||||||
Reference in New Issue
Block a user