Online PHP Javascript Script Decoder

Online PHP and Javascript Decoder decode hidden script to uncover its real functionality

Original code:

<?php
 namespace VDV\Alarm\Model; use VDV\Alarm\Task\Alarm as AlarmTask; use VDV\Log\Model; use VDV\Core\Model\MailDb; use PDO; use DateTime; use VDV\datasource_csi\Task\SendCommand; use VDV\TaskMgr\Model\Task; use VDV\TaskMgr\Model\TaskLogger; class AlarmEvaluator { private $db, $db_type; public $bulkAlarmDb; public $evalMath; public $customAlarmDb; public $data = array(); public $emailBulk = array(); public $logger; public $taskLogger; public $mailDb; public function __construct($taskLogger) { global $db, $db_type; $this->db =& $db; $this->db_type =& $db_type; $this->bulkAlarmDb = new BulkAlarmDb(); $this->customAlarmDb = new CustomAlarmDb(); $this->logger = new model\Logger(); $this->evalMath = new EvalMath(); $this->mailDb = new MailDb(); $this->taskLogger = $taskLogger; } public function run() { $this->checkRepeatAlarms(); } public function checkMultiConditionalAlarm() { $multiConditionalAlarm = $this->customAlarmDb->getAllActiveMultiConditionalAlarms(); $this->evaluateMultiConditionalAlarms($multiConditionalAlarm); } public function checkCustomAlarms() { $customAlarms = $this->bulkAlarmDb->getCustomAlarms(); $this->getDataForBulkAlarm($customAlarms); $this->evaluateAlarms($customAlarms); } public function checkBulkAlarms() { $bulkAlarms = $this->getBulkAlarms(); $groups = $this->splitAllBulksIntoGroups($bulkAlarms); foreach ($groups as $group) { $this->taskLogger->log(Task::LOG_INFO, AlarmTask::MSG_HANDLER_ID, [$group[0]["\147\x72\157\x75\160\111\x64"]]); $this->sortBulkAlarms($group); $this->getDataForBulkAlarm($group); $this->evaluateAlarms($group); $this->data = []; } } public function checkRepeatAlarms() { $this->checkMultiConditionRepeatAlarms(); $alarms = $this->bulkAlarmDb->getRepeatAlarmsAndOnOffString(); foreach ($alarms as $alarm) { $this->sendAlarmMessage($alarm, 1, 0); $this->bulkAlarmDb->updateLastRepeatTimestamp($alarm["\141\x63\x74\151\166\x65\x5f\x61\154\141\x72\155\137\x69\x64"]); } } public function checkMultiConditionRepeatAlarms() { $alarms = $this->customAlarmDb->getAllRepeatMultiConditionAlarms(); foreach ($alarms as $alarm) { $conditions = $alarm["\x63\x6f\156\x64\151\x74\x69\x6f\156\163"]; $startAndStopTimes = $this->getUniqueVariableIdsAndStartAndStopTime($conditions); $stopTime = $alarm["\141\154\x61\162\x6d\x5f\x74\x69\155\145\163\164\x61\x6d\x70"]; $startTime = new DateTime($stopTime); $startTime = $startTime->modify("\x2d\61\x20\x73\145\x63\x6f\x6e\x64"); $startTime = $startTime->format("\x59\x2d\155\55\144\x20\110\x3a\x69\72\x73"); foreach ($startAndStopTimes as $key => &$startAndStopTime) { $startAndStopTimes[$key]["\166\141\x72\x69\141\x62\x6c\145\x5f\x69\x64"] = $startAndStopTime["\166\x61\x72\x69\141\142\x6c\145\111\x64"]; $startStopTime["\x73\164\141\162\x74"] = $startTime; $startStopTime["\163\x74\157\x70"] = $stopTime; } $data = $this->getDataForMultiConditions($conditions, $startAndStopTimes); $conditionMessage = ''; foreach ($conditions as $key => $condition) { $variableId = $condition["\166\141\x72\x69\x61\x62\x6c\145\137\x69\144"]; $alarmType = $condition["\x6c\x69\x6d\x69\164\x5f\x74\x79\x70\x65"]; $alarmValue = $condition["\x6c\151\x6d\x69\x74\x5f\166\x61\x6c\165\145"]; $alarmTypeString = $this->getLimitCondition($alarmType); $variableData = $data[$variableId]; $timestampIndex = array_search($stopTime, $variableData["\x76\141\x72\151\141\x62\154\x65\x5f\x74\x69\155\x65"]); $value = $variableData["\166\141\162\151\141\142\154\145\137\x76\141\154\x75\x65"][$timestampIndex]; $alarmOn = true; $conditionMessage .= $this->makeMessageStringFromCondition($alarm, $condition, $value, $alarmTypeString, $alarmValue, $key); } $alarm["\x6d\145\163\x73\141\x67\145"] = str_replace("\x24\103\117\116\x44\x49\124\x49\x4f\x4e\44", $conditionMessage, $alarm["\155\x65\163\x73\141\147\145"]); $this->sendAlarmMessage($alarm, 1, 0); $this->bulkAlarmDb->updateLastRepeatTimestamp($alarm["\x61\x63\x74\x69\x76\145\137\141\154\x61\x72\155\137\151\144"]); } } public function getBulkAlarms() { return $this->bulkAlarmDb->getAllBulkAlarms(); } public function splitAllBulksIntoGroups($bulkAlarms) { $group = []; $allGroupIds = array_unique(array_map(function ($alarm) { return $alarm["\x67\x72\157\x75\160\111\144"]; }, $bulkAlarms)); foreach ($allGroupIds as $groupId) { $inGroup = array_filter($bulkAlarms, function ($alarm) use($groupId) { return $alarm["\147\x72\x6f\x75\160\111\144"] == $groupId; }); array_push($group, array_values($inGroup)); } return $group; } public function getDataForBulkAlarm(array $bulkAlarm) { $allUniqueVarAndStartStop = $this->getUniqueVariableIdsAndStartAndStopTime($bulkAlarm); foreach ($allUniqueVarAndStartStop as $item) { $variableId = $item["\166\141\x72\151\141\142\x6c\x65\x49\144"]; $start = $item["\163\164\141\x72\164"]; $stop = $item["\x73\164\157\x70"]; $variableData = $this->getDataForVariable($variableId, $start, $stop); $this->data[$variableId] = $variableData; } } public function getUniqueVariableIdsAndStartAndStopTime(array $bulkAlarm) { $set = []; foreach ($bulkAlarm as $alarm) { if ($alarm["\154\141\x74\x65\163\x74"] == 0) { continue; } $variableId = $alarm["\x76\141\162\x69\141\x62\154\145\x5f\x69\x64"]; $start = $alarm["\x6c\141\x73\164\137\x74\151\x6d\145\x73\164\141\155\160\137\x63\x68\145\x63\153"]; $index = in_array($variableId, array_column($set, "\166\141\162\151\141\142\154\x65\x49\144")); if (!$index) { $set[] = ["\x76\141\x72\x69\x61\142\154\x65\111\x64" => $variableId, "\163\x74\x61\x72\x74" => $start, "\163\164\157\160" => $this->getLatestTimestampForAlarm($alarm)]; } else { $tmp = $set[$index]; if ($start < $tmp["\163\164\x61\162\164"]) { $set[$index]["\163\164\141\x72\x74"] = $start; } } } return $set; } private function getLatestTimestampForAlarm(array $alarm) { if ($alarm["\143\x61\154\143\x75\154\x61\x74\145\144\x5f\166\141\162\151\x61\x62\x6c\x65"]) { $timestamp = $this->bulkAlarmDb->getColumn("\15\xa\40\40\40\40\x20\40\x20\x20\40\x20\40\40\40\x20\x20\x20\x53\105\x4c\x45\x43\124\x20\x4d\x49\x4e\x28\x66\x69\x6c\x65\x5f\160\x61\x74\150\56\x6c\141\163\x74\x5f\164\x69\x6d\x65\x73\x74\x61\x6d\160\51\xd\xa\x20\40\x20\40\x20\x20\x20\40\x20\x20\40\x20\40\40\x20\x20\106\x52\117\115\x20\166\x61\x72\x69\141\x62\154\x65\137\151\x6e\146\x6f\15\xa\40\40\x20\x20\x20\40\x20\x20\x20\40\x20\x20\40\40\x20\40\112\117\111\x4e\40\146\x69\x6c\145\x5f\x70\141\x74\x68\x20\x4f\116\15\xa\40\x20\40\40\40\40\x20\x20\40\x20\40\40\40\40\x20\x20\x20\40\x20\40\x66\151\154\x65\x5f\160\141\x74\x68\x2e\163\164\141\164\x69\157\x6e\x5f\x69\144\40\75\x20\166\141\x72\x69\x61\x62\x6c\145\137\151\156\x66\x6f\56\163\x74\141\164\151\x6f\x6e\x5f\x69\x64\xd\12\40\x20\40\x20\x20\40\x20\x20\40\x20\x20\40\x20\x20\40\40\x57\110\x45\x52\105\15\12\x20\40\x20\x20\40\x20\x20\40\40\40\40\40\40\40\x20\x20\40\40\x20\40\x76\x61\x72\151\x61\142\154\x65\137\x69\x6e\146\157\56\166\141\x72\151\x61\142\154\x65\x5f\x69\x64\x20\111\x4e\x20\50\xd\12\40\40\x20\40\40\40\40\40\x20\40\x20\x20\40\x20\40\x20\40\40\x20\40\x20\x20\x20\40\123\x45\x4c\x45\103\x54\x20\x76\x61\x72\151\141\142\x6c\145\137\143\x61\x6c\143\x75\154\x61\164\x69\x6f\x6e\x5f\x72\145\x66\x65\x72\145\156\x63\x65\x73\x2e\x72\x65\x66\145\162\x65\156\143\x65\144\x5f\x76\x61\162\151\x61\142\154\x65\137\151\x64\15\xa\40\x20\40\40\x20\x20\40\x20\x20\x20\x20\40\x20\40\x20\40\x20\x20\x20\40\40\40\x20\x20\x46\x52\117\115\40\x76\141\162\x69\x61\142\154\145\x5f\x63\x61\154\x63\165\154\x61\x74\151\157\156\x5f\162\x65\x66\x65\162\145\x6e\143\x65\163\xd\12\x20\x20\x20\x20\x20\x20\x20\x20\x20\x20\x20\x20\x20\x20\40\40\x20\x20\x20\40\40\x20\x20\x20\127\x48\105\122\x45\xd\12\40\40\40\40\40\x20\40\x20\x20\40\x20\40\40\x20\40\x20\40\40\40\40\x20\x20\x20\40\x20\x20\40\x20\166\141\x72\x69\141\142\154\x65\137\x63\x61\154\143\165\x6c\141\164\x69\x6f\156\x5f\x72\x65\146\145\x72\x65\x6e\143\145\x73\x2e\166\141\162\x69\141\142\x6c\145\137\x69\144\40\x3d\x20\72\x76\x61\x72\151\141\x62\154\x65\137\151\x64\xd\12\40\x20\40\40\40\40\x20\x20\40\x20\x20\x20\x20\40\x20\40\x20\40\40\x20\x29", ["\72\x76\141\x72\151\x61\x62\x6c\x65\137\x69\144" => $alarm["\x76\x61\x72\151\141\x62\154\145\137\x69\144"]]); } else { $timestamp = $this->bulkAlarmDb->getMaxTimestampFromStationId($alarm["\x73\x74\141\164\x69\x6f\156\137\x69\144"]); } if (!$timestamp) { return ''; } $dateTime = new DateTime($timestamp); return $dateTime->modify("\x2b\40\x31\x20\x53\x45\x43\x4f\x4e\x44")->format("\131\55\155\x2d\144\40\110\72\x69\x3a\x73"); } public function getDataForVariable(int $variableId, string $start, string $stop) { $result = get_vdv_data($this->db, $this->db_type, array($variableId), $start, $stop, 0, 0, 0, [], [], array(), 0, array(), array(), array()); return $result[0]; } public function getSummaryData(int $variableId, string $timestamp, int $periodHours, int $alarmProcess) { $stop = new DateTime($timestamp); $start = new DateTime($timestamp); $start->modify("\x2d" . $periodHours . "\40\110\157\x75\x72\x73"); if ($alarmProcess == 3) { $stop->modify("\x2b\x31\x20\x53\x45\103\x4f\116\104"); } else { $start->modify("\x2b\x31\40\123\x45\103\117\x4e\x44"); $stop->modify("\53\61\x20\x53\105\103\117\x4e\104"); } $start = $start->format("\x59\55\155\x2d\x64\40\x48\72\151\72\163"); $stop = $stop->format("\x59\55\155\55\144\40\110\72\x69\x3a\x73"); $result = get_vdv_data($this->db, $this->db_type, [$variableId], $start, $stop, 0, 0, 0, [0], [0], [], 0, [], [], []); return $result[0]; } public function sortBulkAlarms(array &$bulkAlarms) { array_multisort(array_column($bulkAlarms, "\x76\141\x72\x69\141\x62\x6c\145\x5f\151\x64"), SORT_ASC, $bulkAlarms); } public function calculateAlarmData($variableValueData, int $processType, int $abs) { if ($variableValueData == null) { return false; } $variableValueData = array_filter($variableValueData, function ($v, $k) { return $v !== null; }, ARRAY_FILTER_USE_BOTH); if ($variableValueData === null || count($variableValueData) === 0) { return false; } $processedValue = 0; if ($processType === 1) { $processedValue = array_sum($variableValueData) / count($variableValueData); } else { if ($processType === 2) { $processedValue = array_sum($variableValueData); } else { if ($processType === 3) { $first = end($variableValueData); $last = reset($variableValueData); $ROC = $first - $last; $processedValue = $abs ? abs($ROC) : $ROC; } else { if ($processType === 4) { asort($variableValueData); $variableValueData = array_values($variableValueData); $numOfValues = count($variableValueData); $medianPoint = floor(($numOfValues - 1) / 2); if ($numOfValues % 2 == 0) { $lowerMiddle = $variableValueData[$medianPoint]; $higherMiddle = $variableValueData[$medianPoint + 1]; $processedValue = ($lowerMiddle + $higherMiddle) / 2; } else { $processedValue = $variableValueData[$medianPoint]; } } } } } return $processedValue; } public function checkIfTimestampIsWithinTimeConditions($alarm, $timestamp) { $timestampHourMin = new DateTime($timestamp); $currentHour = $timestampHourMin->format("\110\x69"); $currentDayNumber = $timestampHourMin->format("\x4e"); $alarmDays = explode("\x2c", $alarm["\144\141\171\x73"]); $startTime = str_replace("\72", '', $alarm["\163\x74\x61\x72\164\x54\151\155\145"]); $stopTime = str_replace("\x3a", '', $alarm["\163\x74\157\160\x54\151\x6d\145"]); $hasSmeDay = array_search($currentDayNumber, $alarmDays); if ($hasSmeDay !== false && $startTime == $stopTime) { return true; } else { if ($hasSmeDay !== false && $startTime > $stopTime) { if ($currentHour > $startTime || $currentHour <= $stopTime) { return true; } } else { if ($hasSmeDay !== false && $currentHour > $startTime && $currentHour <= $stopTime) { return true; } } } return false; } public function evaluateAlarms($alarms) { foreach ($alarms as $alarm) { $this->evaluateAlarm($alarm); } } public function evaluateAlarm(array $alarm) { $this->getDataForBulkAlarm([$alarm]); $latest = (int) $alarm["\x6c\x61\x74\x65\x73\164"]; if ($latest === 1) { $this->evaluateAlarmTypeLatest($alarm); } else { $this->evaluateAlarmTypeSummary($alarm); } } public function evaluateMultiConditionalAlarms(array $alarms) { foreach ($alarms as &$alarm) { $conditions = $alarm["\143\x6f\156\x64\151\164\x69\x6f\156\x73"]; $allStartAndStopTime = $this->getUniqueVariableIdsAndStartAndStopTime($conditions); $conditionsData = $this->getDataForMultiConditions($conditions, $allStartAndStopTime); $allHasData = $this->checkIfAllConditionsHaveData($conditions, $conditionsData); if ($allHasData === false) { continue; } $allTimestamps = $this->groupAllTheUniqueTimestampInOneGroup($conditionsData); $matchingTimestamps = $this->findACommonTimestampsForAllConditions($allTimestamps, $conditionsData); if (empty($matchingTimestamps)) { continue; } if (isset($alarm["\151\163\x52\157\x6c\154\x69\x6e\147\x41\154\141\x72\155"]) && $alarm["\151\x73\x52\157\x6c\154\x69\156\x67\x41\154\141\x72\x6d"] == 1) { $this->evaluateAlarmTypeMultiConditionRollingAlarm($alarm, $matchingTimestamps); } else { $this->evaluateAlarmTypeMultiCondition($alarm, $matchingTimestamps, $conditionsData); } } } public function evaluateAlarmTypeMultiConditionRollingAlarm($alarm, $matchingTimestamps) { $conditions = $alarm["\x63\157\x6e\x64\x69\164\151\x6f\156\x73"]; $message = $alarm["\155\x65\163\x73\141\147\x65"]; foreach ($matchingTimestamps as $matchingTimestamp) { $summaryType = intval($conditions[0]["\x72\x6f\154\154\151\156\147\104\x61\x74\141\x54\171\160\145"]); if ($summaryType > 0 && $this->checkIfTimestampIsWholeHour($matchingTimestamp) === false) { continue; } $rollingHours = $conditions[0]["\x72\157\154\x6c\151\x6e\x67\x48\157\165\162\x73"]; $exceedanceHours = $conditions[0]["\x65\x78\x63\145\145\144\x61\156\x63\145\110\157\x75\162\163"]; $allVariableIds = array_column($conditions, "\x76\141\162\151\x61\x62\154\145\x5f\x69\x64"); $summary = intval($conditions[0]["\x72\157\x6c\x6c\151\x6e\x67\120\x65\x72\x69\x6f\x64"]); $startStopTime = $this->getRollingAlarmStartAndStopTimes($matchingTimestamp, $rollingHours, $summaryType); $data = $this->getDataForRollingAlarmVariable($allVariableIds, $startStopTime["\163\164\x61\162\164"], $startStopTime["\x73\164\157\x70"], $summary, $summaryType); $allUniqueTimestamps = $this->groupAllTheUniqueTimestampInOneGroup($data); $conditionMatchingTimestamps = $this->findACommonTimestampsForAllConditions($allUniqueTimestamps, $data); $exceedanceCount = 0; $numberOfMeasurementsInHour = $summaryType === 0 ? $this->getNumberOfMeasurementsInOneHour($conditionMatchingTimestamps) : 1; foreach ($conditionMatchingTimestamps as $conditionMatchingTimestamp) { $equationBuilder = []; $conditionMessage = ''; foreach ($conditions as $key => $condition) { $alarmType = $condition["\154\151\155\x69\x74\x5f\164\171\x70\145"]; $variableId = $condition["\x76\141\x72\151\x61\x62\x6c\x65\137\x69\x64"]; $variableKey = array_search($variableId, array_column($data, "\x76\x61\x72\x69\141\x62\154\x65\x5f\151\144")); $variableData = $data[$variableKey]; $timestampIndex = array_search($conditionMatchingTimestamp, $variableData["\x76\x61\x72\151\141\x62\154\145\137\164\151\x6d\x65"]); $value = $variableData["\166\x61\x72\x69\141\142\154\x65\137\166\141\154\165\145"][$timestampIndex]; $alarmValue = $condition["\x6c\x69\x6d\151\x74\137\166\x61\154\x75\145"]; $alarmTypeString = $this->getLimitCondition($alarmType); $alarmOn = $this->checkCondition($value, $alarmValue, $alarmTypeString); if ($value === null || strtolower($value) === "\x6e\141\156") { $alarmOn = false; } $conditionProperties = ["\x61\x6c\x61\162\155\117\156" => $alarmOn, "\143\x6f\156\x64\x69\164\x69\157\156" => $condition["\x63\157\156\144\x69\x74\x69\x6f\156\117\x70\x65\162\x61\x74\x6f\162"], "\x70\141\162\x65\x6e\x74\x68\145\x73\145\163" => $condition["\x70\x61\x72\145\156\x74\x68\145\x73\145\163"]]; array_push($equationBuilder, $conditionProperties); } if (count($conditions) == 1) { $alarmState = $alarmOn; } else { $equationString = $this->generateEquationString($equationBuilder); $alarmState = $this->evaluateEquationString($equationString); } if ($alarmState === true) { $exceedanceCount += 1; } } $alarmOn = $this->evaluateExceedanceForCondition($numberOfMeasurementsInHour, $exceedanceHours, $exceedanceCount, $summaryType); $dataType = $this->getStringForRollingAlarmDataType($summaryType); $overUnder = $alarmOn === true ? "\157\166\145\162" : "\165\x6e\144\x65\x72"; $alarm["\155\x65\163\x73\141\x67\145"] = str_replace("\44\117\126\x45\x52\137\x55\x4e\104\105\122\x24", $overUnder, $alarm["\155\x65\x73\x73\x61\147\145"]); $alarm["\x6d\x65\163\x73\x61\147\x65"] = str_replace("\x24\x52\x4f\x4c\114\111\x4e\107\x5f\x48\117\125\x52\x53\44", $rollingHours, $alarm["\x6d\x65\x73\163\x61\147\145"]); $alarm["\155\145\163\x73\141\x67\x65"] = str_replace("\44\104\x41\124\x41\x5f\124\131\x50\x45\44", $dataType, $alarm["\155\145\x73\x73\x61\x67\x65"]); $alarm["\x6d\145\x73\163\x61\147\145"] = str_replace("\44\x45\130\x43\105\105\104\101\x4e\103\105\137\110\x4f\x55\122\x53\44", $exceedanceHours, $alarm["\x6d\x65\163\163\141\147\145"]); if ($alarmOn === true) { $this->triggerAlarm($alarm, "\60", $matchingTimestamp); } else { $this->disableAlarm($alarm, "\x30", $matchingTimestamp); } $this->updateLastTimestampCheckForMultiConditions($conditions, $matchingTimestamp); } } public function getRollingAlarmStartAndStopTimes($timestamp, $rollingHours, $summaryType) { $stop = new DateTime($timestamp); $stop->modify("\x2b\x20\61\40\x53\x45\x43\x4f\116\x44"); $stop = $stop->format("\x59\55\x6d\x2d\144\x20\x48\72\151\72\x73"); $start = new DateTime($timestamp); $start->modify("\55\x20" . $rollingHours . "\x20\150\x6f\x75\x72\x73"); if ($summaryType === 0) { $start->modify("\x2b\x20\x31\x20\x53\105\x43\117\116\x44"); } $start = $start->format("\131\55\155\55\144\x20\x48\72\x69\x3a\x73"); return ["\x73\164\141\162\164" => $start, "\163\164\157\x70" => $stop]; } public function checkIfTimestampIsWholeHour($timestamp) { $date = new DateTime($timestamp); $minutes = $date->format("\151"); if ($minutes === "\60\x30") { return true; } else { return false; } } public function getStringForRollingAlarmDataType(int $id) { $text = ''; if ($id === 1) { $text = "\x41\166\145\162\x61\x67\x65"; } else { if ($id === 2) { $text = "\x53\165\155"; } else { if ($id === 3) { $text = "\x4d\141\x78"; } else { if ($id === 4) { $text = "\115\151\156"; } } } } return $text; } public function getNumberOfMeasurementsInOneHour($timestamps) { $maxCount = 9; $diff = 1; for ($i = 1; $i < count($timestamps); $i++) { if ($i === $maxCount) { break; } $prev = new DateTime($timestamps[$i - 1]); $curr = new DateTime($timestamps[$i]); $interval = $prev->diff($curr); if ($i === 1) { $hour = intval($interval->format("\45\150")); if ($hour === 0) { $diff = $interval->format("\x25\x69"); } else { if ($hour === 1) { $diff = 60; } } } } $numberOfMeasurementsInOneHour = intval(60 / $diff); return $numberOfMeasurementsInOneHour; } public function evaluateExceedanceForCondition($valuesPerHour, $exceedanceHours, $exceedanceCount, $summaryType) { if ($summaryType > 0) { $hoursOverLimit = $exceedanceCount; } else { $hoursOverLimit = $exceedanceCount / $valuesPerHour; } $conditionOn = $hoursOverLimit > $exceedanceHours; return $conditionOn; } public function getDataForRollingAlarmVariable($variableIds, $start, $stop, $summary, $summaryType) { $result = get_vdv_data($this->db, $this->db_type, $variableIds, $start, $stop, 0, 0, 0, [$summary], [$summaryType], array(), 0, array(), array(), array()); return $result; } public function getDataForMultiConditions($conditions, $startAndStopTimes) { $data = []; foreach ($conditions as $condition) { $variableId = $condition["\x76\x61\162\x69\141\x62\154\145\137\x69\144"]; $startAndStopIndex = array_search($variableId, array_column($startAndStopTimes, "\x76\141\162\151\141\142\x6c\145\111\x64")); $startAndStop = $startAndStopTimes[$startAndStopIndex]; $start = $startAndStop["\x73\164\141\162\x74"]; $stop = $startAndStop["\x73\x74\157\x70"]; $data[$variableId] = $this->getDataForVariable($variableId, $start, $stop); } return $data; } public function checkIfAllConditionsHaveData($conditions, $conditionData) { $allContain = true; foreach ($conditions as $condition) { $variableId = $condition["\x76\x61\x72\151\x61\x62\x6c\x65\x5f\x69\144"]; if (!isset($conditionData[$variableId])) { $allContain = false; break; } if (empty($conditionData[$variableId]["\166\x61\x72\151\x61\x62\x6c\x65\x5f\x76\141\154\165\x65"])) { $allContain = false; break; } } return $allContain; } public function groupAllTheUniqueTimestampInOneGroup($conditionsData) { $uniqueTimestamps = []; $index = 0; foreach ($conditionsData as $data) { $timestamps = $data["\166\x61\x72\151\x61\142\154\145\x5f\164\x69\155\145"]; foreach ($timestamps as $timestamp) { if (array_key_exists($timestamp, $uniqueTimestamps) === false) { $uniqueTimestamps[$timestamp] = $index; $index++; } } } return array_flip($uniqueTimestamps); } public function findACommonTimestampsForAllConditions($allUniqueTimestamps, $conditionsData) { $commonTimestamps = []; $numberOfConditions = count($conditionsData); $timestampArray = []; $index = 0; foreach ($allUniqueTimestamps as $timestamp) { $matchingTimestamps = 0; foreach ($conditionsData as $data) { $variableId = $data["\x76\x61\162\x69\x61\142\x6c\x65\x5f\151\144"]; if (!isset($timestampArray[$variableId])) { $timestampArray[$variableId] = array_flip($data["\166\x61\x72\151\141\142\x6c\x65\137\x74\x69\x6d\x65"]); } $exists = array_key_exists($timestamp, $timestampArray[$variableId]); if ($exists !== false) { ++$matchingTimestamps; } else { continue 2; } } if ($matchingTimestamps === $numberOfConditions) { if (array_key_exists($timestamp, $commonTimestamps) === false) { $commonTimestamps[$timestamp] = $index; $index++; } } } return array_flip($commonTimestamps); } public function evaluateEquationString(string $equationString) { $alarmOn = $this->evalMath->evaluate($equationString); return $alarmOn === 1 ? true : false; } public function generateEquationString(array $equationProperties) { $numOfProperties = count($equationProperties); $equationString = ''; foreach ($equationProperties as $key => $property) { $openString = ''; $closeString = ''; $alarmOn = $property["\141\154\141\162\x6d\117\x6e"]; $operator = $property["\143\157\x6e\144\x69\x74\x69\157\156"] == "\x41\116\x44" ? "\46" : "\174"; $conditionState = $alarmOn === true ? 1 : 0; $openParenCount = substr_count($property["\x70\x61\x72\x65\156\164\150\x65\163\x65\163"], "\x28"); $closeParenCount = substr_count($property["\x70\141\162\x65\x6e\164\150\145\163\x65\x73"], "\51"); $openString = str_repeat("\50", $openParenCount); $closeString = str_repeat("\x29", $closeParenCount); if ($key === 0) { $equationString = $openString . $conditionState . $closeString . "\x20"; } else { if ($key == $numOfProperties - 1) { $equationString .= $operator . "\x20" . $openString . $conditionState . $closeString; } else { $equationString .= $operator . "\x20" . $openString . $conditionState . $closeString . "\40"; } } } return $equationString; } public function evaluateAlarmTypeMultiCondition(&$alarm, $matchingTimestamps, $conditionData) { $conditions = $alarm["\x63\x6f\156\x64\x69\x74\151\x6f\156\x73"]; $message = $alarm["\x6d\x65\163\x73\141\147\145"]; foreach ($matchingTimestamps as $timestamp) { $equationBuilder = []; $alarm["\155\145\163\163\141\x67\x65"] = $message; $conditionMessage = ''; foreach ($conditions as $key => $condition) { $variableId = $condition["\166\141\x72\151\141\142\x6c\x65\x5f\x69\144"]; $alarmType = $condition["\x6c\151\x6d\x69\x74\x5f\x74\x79\x70\x65"]; $alarmValue = $condition["\x6c\151\155\x69\164\x5f\166\x61\154\165\x65"]; $alarmTypeString = $this->getLimitCondition($alarmType); $variableData = $conditionData[$variableId]; $timestampIndex = array_search($timestamp, $variableData["\x76\141\x72\151\x61\142\x6c\x65\137\164\x69\x6d\x65"]); $value = $variableData["\x76\141\x72\151\x61\142\x6c\x65\137\166\x61\154\x75\145"][$timestampIndex]; if ($value === null || strtolower($value) === "\156\x61\x6e") { $alarmOn = null; break; } $alarmOn = $this->checkCondition($value, $alarmValue, $alarmTypeString); $conditionMessage .= $this->makeMessageStringFromCondition($alarm, $condition, $value, $alarmTypeString, $alarmValue, $key); $conditionProperties = ["\x61\x6c\x61\162\x6d\x4f\156" => $alarmOn, "\x63\157\x6e\x64\151\164\151\x6f\156" => $condition["\143\157\156\x64\151\x74\151\157\x6e\117\x70\x65\x72\141\164\x6f\x72"], "\160\141\x72\145\156\164\x68\145\163\145\x73" => $condition["\x70\x61\162\x65\156\164\150\x65\x73\x65\163"]]; array_push($equationBuilder, $conditionProperties); } $alarm["\x6d\x65\x73\163\141\x67\x65"] = str_replace("\x24\103\x4f\x4e\x44\111\x54\x49\117\116\x24", $conditionMessage, $alarm["\x6d\x65\163\x73\141\x67\145"]); if (count($conditions) == 1 || $alarmOn === null) { $alarmState = $alarmOn; } else { $equationString = $this->generateEquationString($equationBuilder); $alarmState = $this->evaluateEquationString($equationString); } if ($alarmState === null) { } else { if ($alarmState === true) { $this->triggerAlarm($alarm, "\x30", $timestamp); } else { $this->disableAlarm($alarm, "\x30", $timestamp); } } $this->updateLastTimestampCheckForMultiConditions($conditions, $timestamp); } } public function makeMessageStringFromCondition(&$alarm, $condition, $value, $alarmTypeString, $alarmValue, $key) { $conditionString = ''; $openParenCount = substr_count($condition["\x70\x61\x72\x65\x6e\164\150\145\163\145\163"], "\50"); $closeParenCount = substr_count($condition["\x70\141\162\x65\156\164\150\x65\x73\x65\x73"], "\51"); $openString = str_repeat("\50", $openParenCount); $closeString = str_repeat("\51", $closeParenCount); $siteAndVar = $condition["\x73\164\x61\164\151\x6f\x6e\x5f\156\x61\x6d\x65"] . "\72\x20" . $condition["\x65\x6e\147\154\x69\163\x68\137\x6e\141\x6d\x65"] . "\40\x28" . $value . "\x29\x20" . $alarmTypeString . "\40" . $alarmValue; $numOfConditions = count($alarm["\143\x6f\x6e\x64\x69\x74\x69\157\156\x73"]); if ($key === 0) { $conditionString .= $openString . $siteAndVar . $closeString . "\40"; } else { if ($key == $numOfConditions - 1) { $conditionString .= $condition["\143\x6f\156\144\151\164\x69\x6f\x6e\x4f\x70\x65\x72\141\x74\x6f\x72"] . "\x20" . $openString . $siteAndVar . $closeString; } else { $conditionString .= $condition["\143\x6f\x6e\144\151\x74\151\157\156\x4f\160\x65\x72\x61\164\x6f\162"] . "\40" . $openString . $siteAndVar . $closeString . "\40"; } } return $conditionString; } public function updateLastTimestampCheckForMultiConditions(array $conditions, $timestamp) { foreach ($conditions as $condition) { $this->bulkAlarmDb->updateLastTimestampCheck($condition["\141\154\141\x72\155\x5f\x63\x6f\156\x64\x69\x74\151\x6f\156\x5f\151\x64"], $timestamp); } } public function evaluateAlarmTypeSummary(array $alarm) { $variableId = $alarm["\x76\x61\x72\151\141\142\x6c\145\137\x69\144"]; $lastRun = $alarm["\x6c\141\x73\x74\137\164\x69\155\145\163\164\141\155\x70\x5f\x63\150\145\143\153"]; $stationId = $alarm["\x73\164\141\164\151\x6f\x6e\x5f\151\144"]; $latestTimestamp = $this->getLatestTimestampForAlarm($alarm); $allTimestamps = $this->getDataForVariable($variableId, $lastRun, $latestTimestamp); if (!is_array($allTimestamps["\x76\141\162\x69\x61\x62\x6c\145\137\164\x69\x6d\145"])) { $allTimestamps["\166\141\162\151\141\142\x6c\x65\137\164\151\x6d\x65"] = []; } $alarmType = $alarm["\x6c\151\155\151\x74\137\x74\171\x70\x65"]; $alarmValue = $alarm["\x6c\151\155\151\x74\137\x76\141\x6c\x75\x65"]; $alarmTypeString = $this->getLimitCondition($alarmType); $numberOfValues = count($allTimestamps["\x76\141\162\151\141\x62\154\x65\x5f\164\151\x6d\145"]); $lastTimeRunIndex = array_search($lastRun, $allTimestamps["\166\141\x72\x69\x61\x62\154\x65\x5f\164\x69\x6d\x65"]); if ($lastTimeRunIndex === false) { if ($lastRun < $allTimestamps["\166\141\162\x69\141\142\154\x65\x5f\164\x69\155\x65"][0]) { $lastTimeRunIndex = -1; } } $alarmOn = false; for ($i = $lastTimeRunIndex + 1; $i < $numberOfValues; $i++) { $nextTimestamp = $allTimestamps["\x76\x61\162\151\x61\142\154\x65\137\x74\151\155\145"][$i]; $periodHours = $alarm["\x70\145\162\151\157\144\137\x68\x6f\x75\x72\x73"]; $alarmProcess = $alarm["\160\x72\x6f\143\145\x73\163"]; $absoluteValue = $alarm["\141\x62\x73\157\154\165\164\145\x5f\x76\141\x6c\165\145"]; $isWithInRange = true; if (isset($alarm["\164\x69\x6d\145\101\x6c\x61\162\x6d"]) && $alarm["\164\x69\x6d\x65\x41\154\141\162\155"] == 1) { $isWithInRange = $this->checkIfTimestampIsWithinTimeConditions($alarm, $nextTimestamp); if ($isWithInRange === false) { $this->bulkAlarmDb->updateLastTimestampCheck($alarm["\141\x6c\x61\162\155\x5f\143\157\x6e\x64\151\164\x69\x6f\156\x5f\x69\x64"], $nextTimestamp); continue; } } $data = $this->getSummaryData($variableId, $nextTimestamp, $periodHours, $alarmProcess); $summaryDataValue = $this->calculateAlarmData($data["\166\x61\162\151\141\142\x6c\145\137\x76\x61\x6c\165\145"], $alarmProcess, $absoluteValue); if ($summaryDataValue === false) { $this->bulkAlarmDb->updateLastTimestampCheck($alarm["\141\154\141\x72\155\x5f\x63\x6f\156\x64\x69\164\x69\x6f\156\137\x69\x64"], $nextTimestamp); continue; } if ($alarm["\x63\157\155\x70\141\x72\x65\137\x74\x79\160\145"] == 1) { $alarmValue = $this->getValueForCompareVariable($alarm, $nextTimestamp); $alarm["\154\151\x6d\151\164\137\x76\x61\x6c\x75\x65"] = $alarmValue; } if ($alarmValue === false) { $this->bulkAlarmDb->updateLastTimestampCheck($alarm["\x61\154\x61\162\155\137\143\157\156\x64\x69\164\x69\157\156\x5f\x69\x64"], $nextTimestamp); continue; } $alarmOn = $this->checkCondition($summaryDataValue, $alarmValue, $alarmTypeString); if ($alarmOn === true) { $this->triggerAlarm($alarm, $summaryDataValue, $nextTimestamp); } else { $this->disableAlarm($alarm, $summaryDataValue, $nextTimestamp); } $this->bulkAlarmDb->updateLastTimestampCheck($alarm["\x61\154\141\162\155\137\143\157\x6e\x64\x69\x74\x69\x6f\156\x5f\151\144"], $nextTimestamp); } } public function getValueForCompareVariable($alarm, $timestamp) { $latest2 = $alarm["\154\x61\x74\x65\163\164\137\62"]; $variableId2 = $alarm["\x76\141\162\151\x61\x62\154\x65\137\151\x64\137\x32"]; $periodHours2 = $alarm["\160\x65\x72\x69\157\144\x5f\150\x6f\x75\162\163\137\62"]; $alarmProcess2 = intval($alarm["\x70\162\x6f\x63\x65\163\x73\137\x32"]); $absoluteValue2 = $alarm["\x61\x62\163\157\154\x75\164\145\x5f\x76\141\x6c\x75\145\x5f\62"]; if ($latest2 == 1) { $start = $timestamp; $stop = new DateTime($timestamp); $stop->modify("\53\61\x20\123\x45\x43\x4f\x4e\104"); $stop = $stop->format("\131\55\x6d\x2d\x64\40\110\72\151\x3a\x73"); $data = $this->getDataForVariable($variableId2, $start, $stop); if (!is_array($data["\166\x61\162\x69\x61\x62\154\x65\137\164\x69\155\x65"])) { return false; } $index2 = array_search($timestamp, $data["\x76\x61\x72\151\141\142\x6c\x65\137\x74\x69\x6d\x65"]); $alarmValue = $index2 !== false ? $data["\x76\x61\x72\151\x61\x62\154\145\x5f\166\x61\x6c\x75\x65"][$index2] : false; } else { $variableData2 = $this->getSummaryData($variableId2, $timestamp, $periodHours2, $alarmProcess2); $alarmValue = $this->calculateAlarmData($variableData2["\166\141\x72\x69\x61\142\x6c\x65\x5f\166\x61\x6c\x75\x65"], $alarmProcess2, $absoluteValue2); } if ($alarmValue !== false) { $alarmValue += $alarm["\x6f\x66\146\x73\145\x74\137\62"]; } return $alarmValue; } public function evaluateAlarmTypeLatest($alarm) { $variableId = $alarm["\166\141\162\151\141\142\x6c\x65\x5f\151\144"]; $lastRun = $alarm["\x6c\x61\x73\164\x5f\164\x69\x6d\145\163\164\x61\155\160\137\143\x68\x65\x63\153"]; $alarmType = $alarm["\154\151\x6d\x69\164\x5f\164\171\x70\x65"]; $alarmValue = $alarm["\154\x69\x6d\151\x74\x5f\166\x61\154\165\145"]; $alarmTypeString = $this->getLimitCondition($alarmType); $variableData = $this->data[$variableId]; if (!is_array($variableData["\166\x61\x72\x69\x61\142\x6c\145\x5f\164\151\x6d\x65"])) { $variableData["\166\141\162\151\141\x62\x6c\145\x5f\164\x69\x6d\145"] = []; } $numberOfValues = count($variableData["\x76\x61\162\151\141\142\154\145\137\x74\x69\x6d\x65"]); $lastTimeRunIndex = array_search($lastRun, $variableData["\x76\x61\162\x69\x61\142\x6c\145\137\x74\x69\155\145"]); if ($lastTimeRunIndex === false) { if ($lastRun < $variableData["\x76\141\x72\x69\x61\x62\x6c\x65\137\x74\151\x6d\x65"][0]) { $lastTimeRunIndex = -1; } } $alarmOn = false; for ($i = $lastTimeRunIndex + 1; $i < $numberOfValues; $i++) { $nextTimestamp = $variableData["\166\141\x72\151\x61\142\154\145\137\164\151\155\x65"][$i]; $value = $variableData["\x76\x61\x72\x69\x61\x62\x6c\x65\x5f\x76\141\x6c\165\x65"][$i]; $isWithInRange = true; if (isset($alarm["\164\x69\x6d\x65\x41\x6c\141\x72\155"]) && $alarm["\x74\151\155\x65\101\154\x61\162\x6d"] == 1) { $isWithInRange = $this->checkIfTimestampIsWithinTimeConditions($alarm, $nextTimestamp); } if ($value === null || $isWithInRange === false) { $this->bulkAlarmDb->updateLastTimestampCheck($alarm["\x61\x6c\141\x72\155\x5f\143\157\x6e\x64\151\164\151\157\156\137\151\144"], $nextTimestamp); continue; } if ($alarm["\x63\x6f\155\160\141\x72\x65\x5f\x74\171\160\x65"] == 1) { $alarmValue = $this->getValueForCompareVariable($alarm, $nextTimestamp); $alarm["\x6c\151\155\x69\x74\x5f\x76\x61\x6c\x75\145"] = $alarmValue; } if ($alarmValue === false) { $this->bulkAlarmDb->updateLastTimestampCheck($alarm["\x61\x6c\141\x72\x6d\x5f\x63\157\156\x64\151\164\x69\x6f\156\x5f\x69\x64"], $nextTimestamp); continue; } $alarmOn = $this->checkCondition($value, $alarmValue, $alarmTypeString); if ($alarmOn === true) { $this->triggerAlarm($alarm, $value, $nextTimestamp); } else { $this->disableAlarm($alarm, $value, $nextTimestamp); } $this->bulkAlarmDb->updateLastTimestampCheck($alarm["\x61\154\x61\162\x6d\137\143\x6f\x6e\x64\151\x74\151\x6f\x6e\x5f\x69\x64"], $nextTimestamp); } } public function checkCondition($value, $alarmValue, $limitType) { $alarm = false; switch ($limitType) { case "\x3c": $alarm = $value < $alarmValue; break; case "\x3c\75": $alarm = $value <= $alarmValue; break; case "\x3d": $alarm = $value == $alarmValue; break; case "\x3e\x3d": $alarm = $value >= $alarmValue; break; case "\76": $alarm = $value > $alarmValue; break; default: break; } return $alarm; } public function getLimitConditions() { return array("\x31" => "\74", "\62" => "\x3c\75", "\63" => "\75", "\64" => "\76\x3d", "\x35" => "\x3e"); } public function getLimitCondition(int $limitType) { $limitConditions = $this->getLimitConditions(); return $limitConditions[$limitType]; } public function triggerAlarm(&$alarm, $value, $timestamp) { if ($value === "\116\141\x4e") { return; } $alarmId = $alarm["\141\x6c\141\162\155\x5f\151\x64"]; $delayTimestampPassed = true; $exists = $this->bulkAlarmDb->getActiveAlarm($alarmId); if (isset($alarm["\x6d\x75\154\x74\x69\x43\x6f\156\x64\151\164\x69\x6f\x6e"]) && $alarm["\155\165\154\x74\x69\x43\157\x6e\144\x69\x74\151\157\156"] == 1) { $delay = $alarm["\x63\x6f\x6e\x64\151\164\151\x6f\156\x73"][0]["\x64\x65\x6c\141\x79"]; $delayTimestamp = $alarm["\x63\x6f\x6e\x64\x69\164\x69\x6f\x6e\x73"][0]["\144\x65\154\141\x79\124\x69\155\145\x73\x74\141\155\x70"]; } else { $delay = $alarm["\144\145\154\141\171"]; $delayTimestamp = $alarm["\144\x65\154\141\x79\124\x69\x6d\x65\163\164\141\x6d\160"]; } if ($exists["\141\x6c\141\x72\x6d\137\157\156"] == 1) { return; } if (($exists === false || $exists["\141\154\x61\162\155\x5f\157\156"] == 0) && $delay > 0 && $delayTimestamp === null) { if (isset($alarm["\155\165\x6c\164\151\x43\157\156\x64\x69\x74\x69\157\x6e"]) && $alarm["\x6d\x75\x6c\x74\x69\x43\157\x6e\x64\151\164\151\157\x6e"] == 1) { $conditions = $alarm["\x63\x6f\156\144\x69\164\151\x6f\x6e\163"]; $alarm["\x63\x6f\x6e\144\151\x74\x69\x6f\156\x73"][0]["\144\145\154\141\x79\124\x69\x6d\145\x73\164\141\x6d\x70"] = $timestamp; $this->updateDelayTimestampForMultiConditionalAlarm($conditions, $timestamp); } else { $alarmConditionId = $alarm["\x61\154\x61\162\155\x5f\x63\157\156\144\151\x74\151\x6f\x6e\x5f\x69\144"]; $this->bulkAlarmDb->updateAlarmConditionDelayTimestamp($alarmConditionId, $timestamp); $alarm["\x64\x65\x6c\141\171\x54\x69\155\x65\163\164\x61\155\x70"] = $timestamp; } $delayTimestampPassed = false; } else { if ($delayTimestamp !== null && $delay > 0) { $timePassed = (strtotime($timestamp) - strtotime($delayTimestamp)) / 60; if ($timePassed < $delay) { $delayTimestampPassed = false; } } } if ($exists === false && $delayTimestampPassed === true) { $logStringTitle = $alarm["\x67\162\157\165\x70\x49\144"] > 0 ? "\102\x75\154\x6b\40\x41\154\141\162\x6d" : "\103\165\x73\x74\157\x6d\x20\x41\x6c\x61\x72\155"; if (isset($alarm["\155\165\x6c\164\x69\x43\x6f\156\x64\x69\x74\x69\157\156"]) && $alarm["\x6d\x75\154\x74\151\103\x6f\156\x64\x69\164\x69\157\156"] == 1) { $logString = "\115\x75\154\164\151\40\103\x6f\156\144\x69\x74\x69\x6f\156\x20\x41\154\141\162\155\72\40" . $alarm["\x6e\141\155\145"]; } else { $logString = $logStringTitle . "\x20\72" . $alarm["\163\164\x61\x74\x69\157\x6e\137\156\x61\x6d\x65"] . "\72\x20\126\141\162\151\x61\x62\154\x65\40\50" . $alarm["\x76\141\162\x69\x61\142\154\x65\x5f\151\x64"] . "\x29"; } $this->bulkAlarmDb->saveNewActiveAlarm($alarm, $value, $timestamp); $this->logger->logAction("\62\61\65", $alarm["\163\164\x61\x74\x69\x6f\x6e\137\151\144"], 0, $logString); $this->logger->saveToAlarmLog($alarm, $value, 10, $timestamp); $alarmSender = $this->bulkAlarmDb->getActiveAlarmByIdAndOnOffString($alarmId); if ($alarm["\155\165\154\x74\x69\x43\157\156\x64\x69\x74\151\x6f\156"] == 1) { $alarmSender["\x6d\x65\x73\163\x61\147\x65"] = $alarm["\x6d\145\x73\163\x61\x67\x65"]; } $this->sendAlarmMessage($alarmSender, $alarmSender["\x61\x6c\141\162\155\x5f\157\156"], 0); $this->bulkAlarmDb->updateLastRepeatTimestamp($alarmSender["\x61\143\164\x69\166\145\137\141\154\141\162\x6d\137\x69\144"]); $this->updateDelayTimestamp($alarm, null); } else { if ($exists["\141\154\141\162\x6d\x5f\157\156"] == 0 && $delayTimestampPassed === true) { $this->bulkAlarmDb->updateActiveAlarm($exists["\x61\x63\164\x69\x76\x65\137\141\154\x61\162\x6d\x5f\x69\x64"], $value, 1, $timestamp); $this->logger->saveToAlarmLog($alarm, $value, 10, $timestamp); $alarmSender = $this->bulkAlarmDb->getActiveAlarmByIdAndOnOffString($alarmId); if ($alarm["\155\165\154\x74\151\x43\x6f\156\x64\151\164\x69\157\156"] == 1) { $alarmSender["\155\145\x73\163\141\x67\145"] = $alarm["\155\x65\x73\x73\x61\147\145"]; } $this->sendAlarmMessage($alarmSender, $alarmSender["\x61\154\x61\162\x6d\137\157\156"], 0); $this->bulkAlarmDb->updateLastRepeatTimestamp($alarmSender["\141\x63\164\x69\166\145\137\141\154\x61\x72\155\137\x69\x64"]); $this->updateDelayTimestamp($alarm, null); } } } public function updateDelayTimestampForMultiConditionalAlarm(&$conditions, $timestamp) { foreach ($conditions as &$condition) { $alarmConditionId = $condition["\x61\x6c\x61\x72\x6d\x5f\143\157\156\x64\x69\164\x69\157\x6e\137\x69\144"]; $this->bulkAlarmDb->updateAlarmConditionDelayTimestamp($alarmConditionId, $timestamp); $condition["\144\145\x6c\141\x79\x54\x69\155\x65\163\164\x61\x6d\160"] = $timestamp; } } public function disableAlarm(array &$alarm, $value, $timestamp) { if ($value === "\116\141\116") { return; } $alarmId = $alarm["\x61\x6c\141\162\155\x5f\x69\144"]; $exists = $this->bulkAlarmDb->getActiveAlarm($alarmId); if ($exists !== false) { $wasActive = (int) $exists["\141\154\x61\162\155\x5f\x6f\x6e"]; if ($wasActive === 1) { $this->bulkAlarmDb->updateActiveAlarm($exists["\x61\143\164\151\166\x65\137\141\x6c\x61\x72\155\x5f\x69\144"], $value, 0, $exists["\x61\x6c\x61\x72\x6d\x5f\164\151\x6d\x65\163\x74\141\155\160"]); $this->logger->saveToAlarmLog($alarm, $value, 9, $timestamp); if ($alarm["\x73\x6b\x69\x70\x5f\157\146\146\137\x61\154\x61\162\x6d"] == 0) { $alarmSender = $this->bulkAlarmDb->getActiveAlarmByIdAndOnOffString($alarmId); $alarmSender["\141\x6c\x61\162\x6d\137\164\151\x6d\x65\x73\x74\141\x6d\x70"] = $timestamp; if ($alarm["\x6d\165\154\x74\151\x43\157\x6e\x64\151\164\x69\x6f\x6e"] == 1) { $alarmSender["\x6d\x65\x73\x73\x61\x67\x65"] = $alarm["\x6d\x65\163\163\x61\x67\x65"]; } $this->sendAlarmMessage($alarmSender, $alarmSender["\x61\x6c\141\x72\x6d\137\x6f\x6e"], 0); $this->bulkAlarmDb->updateLastRepeatTimestamp($alarmSender["\141\143\164\151\166\x65\x5f\x61\x6c\x61\162\155\137\x69\x64"]); } } else { $this->updateDelayTimestamp($alarm, null); } if ((int) $exists["\x63\x6f\156\146\151\x72\x6d\x65\144"] === 1) { $this->bulkAlarmDb->deleteCustomAlarmActive($alarmId); } } else { $this->updateDelayTimestamp($alarm, null); } } public function updateDelayTimestamp(&$alarm, $timestamp) { if (isset($alarm["\x6d\165\154\164\x69\x43\157\x6e\144\151\164\151\x6f\x6e"]) && $alarm["\155\165\x6c\164\151\x43\x6f\156\x64\151\164\x69\x6f\156"] == 1) { if ($alarm["\x63\x6f\156\x64\x69\164\x69\x6f\156\x73"][0]["\144\145\154\141\171\124\x69\155\x65\163\x74\141\155\x70"] !== null) { $this->updateDelayTimestampForMultiConditionalAlarm($alarm["\x63\x6f\x6e\x64\151\x74\151\x6f\x6e\x73"], $timestamp); $alarm["\143\x6f\156\144\151\164\x69\x6f\156\x73"][0]["\144\x65\154\x61\171\124\151\x6d\145\163\x74\x61\155\x70"] = $timestamp; } } else { if ($alarm["\x64\x65\x6c\x61\x79\x54\151\x6d\145\163\164\141\155\x70"] !== null) { $alarm["\144\145\154\x61\x79\124\x69\155\145\163\164\x61\x6d\160"] = $timestamp; $this->bulkAlarmDb->updateAlarmConditionDelayTimestamp($alarm["\x61\154\141\162\x6d\137\x63\x6f\x6e\x64\x69\x74\151\157\156\x5f\151\x64"], $timestamp); } } } public function sendAlarmMessage($alarm, $alarmStatus, $option) { $contactGroup = $alarm["\143\x6f\156\164\x61\x63\164\x5f\x67\x72\x6f\x75\160\x5f\x69\144"]; $subject = $this->swapPlaceholdersForValues($alarm, $alarm["\163\x75\x62\152\x65\x63\164"]); $headerFooter = $this->bulkAlarmDb->getAlarmMessageHeaderAndFooter(); $body = $headerFooter["\167\141\x72\x6e\151\156\x67\137\x65\155\x61\151\x6c\x5f\150\x65\x61\x64\x65\162"] . "\74\x70\x3e"; $body .= $this->swapPlaceholdersForValues($alarm, $alarm["\155\x65\163\x73\x61\x67\x65"]); $body .= "\x3c\160\x3e" . $headerFooter["\167\141\x72\156\x69\x6e\x67\x5f\x65\155\141\151\154\x5f\x66\x6f\x6f\164\145\162"] . "\74\x70\76"; $this->mailDb->send(["\145\x6d\x61\151\154\163" => [], "\x63\x6f\156\164\x61\x63\164\x5f\147\162\x6f\x75\160\137\151\144" => $contactGroup, "\163\x75\142\152\145\x63\x74" => $subject, "\142\157\x64\171" => $body, "\141\x74\x74\x61\x63\x68\155\145\x6e\164\x73" => []]); SendCommand::trigger($alarm["\x61\154\141\x72\x6d\137\x63\x6f\x6d\x6d\x61\156\x64\137\151\x64"], $alarm["\x61\154\141\162\x6d\137\151\144"], $alarmStatus, "\x63\165\x73\164\x6f\x6d"); } private function getPlaceholderVariables() { return array("\156\141\155\145" => "\44\x41\114\101\122\x4d\x5f\x4e\101\115\x45\44", "\x73\x74\x61\x74\151\157\156\137\156\141\155\x65" => "\x24\x53\x49\x54\105\x5f\x4e\101\x4d\105\44", "\116\117\x57" => "\44\116\x4f\127\x24", "\x6f\x6e\117\146\146" => "\x24\x4f\x4e\x2f\x4f\x46\x46\x24", "\x61\154\141\x72\x6d\137\164\x69\155\145\163\x74\141\x6d\160" => "\x24\124\x49\115\x45\x53\124\x41\x4d\x50\x24", "\141\x6c\141\x72\x6d\137\x76\x61\x6c\165\x65" => "\44\126\101\x4c\x55\105\x24", "\x6c\x69\x6d\x69\x74\137\x76\x61\x6c\x75\145" => "\44\114\x49\x4d\111\124\137\x56\x41\x4c\125\105\x24", "\145\156\x67\x6c\151\163\x68\137\156\x61\155\x65" => "\x24\126\101\122\111\x41\102\114\x45\x5f\116\101\x4d\x45\x24", "\164\x79\x70\x65\116\x61\155\145" => "\x24\x41\114\101\x52\115\137\x54\x59\x50\x45\137\116\101\115\x45\44"); } public function swapPlaceholdersForValues($alarm, $message) { global $localization; $phpDateTimeFormat = "\x59\x2d\x6d\x2d\x64\x20\110\72\x69\72\163"; $placeholderVariables = $this->getPlaceholderVariables(); $now = new DateTime("\156\x6f\167"); foreach ($placeholderVariables as $key => $placeholder) { if ($key == "\x6f\156\117\146\146") { $onOffString = $alarm["\141\154\141\x72\155\x5f\x6f\156"] == 1 ? $alarm["\x77\x61\162\156\151\156\147\137\157\x6e\x5f\x73\164\x72\151\x6e\x67"] : $alarm["\167\141\x72\156\x69\156\147\x5f\157\146\146\137\163\x74\162\151\x6e\147"]; $message = str_replace($placeholder, $onOffString, $message); continue; } if ($key == "\x6c\x69\x6d\151\x74\x5f\166\x61\x6c\x75\145" && $alarm["\143\157\x6d\160\141\162\145\x5f\164\171\x70\145"] == 1) { $secondCondition = $this->getValueForCompareVariable($alarm, $alarm["\141\154\x61\162\155\137\164\x69\x6d\x65\163\x74\141\x6d\x70"]); $message = str_replace($placeholder, $secondCondition, $message); continue; } if ($key == "\116\x4f\127") { $message = str_replace($placeholder, $now->format($phpDateTimeFormat), $message); } else { if (isset($alarm[$key])) { $message = str_replace($placeholder, $alarm[$key], $message); } } } return $message; } }

Decrypted code:

namespace VDV\Alarm\Model; use VDV\Alarm\Task\Alarm as AlarmTask; use VDV\Log\Model; use VDV\Core\Model\MailDb; use PDO; use DateTime; use VDV\datasource_csi\Task\SendCommand; use VDV\TaskMgr\Model\Task; use VDV\TaskMgr\Model\TaskLogger; class AlarmEvaluator { private $db, $db_type; public $bulkAlarmDb; public $evalMath; public $customAlarmDb; public $data = array(); public $emailBulk = array(); public $logger; public $taskLogger; public $mailDb; public function __construct($taskLogger) { global $db, $db_type; $this->db =& $db; $this->db_type =& $db_type; $this->bulkAlarmDb = new BulkAlarmDb(); $this->customAlarmDb = new CustomAlarmDb(); $this->logger = new model\Logger(); $this->evalMath = new EvalMath(); $this->mailDb = new MailDb(); $this->taskLogger = $taskLogger; } public function run() { $this->checkRepeatAlarms(); } public function checkMultiConditionalAlarm() { $multiConditionalAlarm = $this->customAlarmDb->getAllActiveMultiConditionalAlarms(); $this->evaluateMultiConditionalAlarms($multiConditionalAlarm); } public function checkCustomAlarms() { $customAlarms = $this->bulkAlarmDb->getCustomAlarms(); $this->getDataForBulkAlarm($customAlarms); $this->evaluateAlarms($customAlarms); } public function checkBulkAlarms() { $bulkAlarms = $this->getBulkAlarms(); $groups = $this->splitAllBulksIntoGroups($bulkAlarms); foreach ($groups as $group) { $this->taskLogger->log(Task::LOG_INFO, AlarmTask::MSG_HANDLER_ID, [$group[0]["groupId"]]); $this->sortBulkAlarms($group); $this->getDataForBulkAlarm($group); $this->evaluateAlarms($group); $this->data = []; } } public function checkRepeatAlarms() { $this->checkMultiConditionRepeatAlarms(); $alarms = $this->bulkAlarmDb->getRepeatAlarmsAndOnOffString(); foreach ($alarms as $alarm) { $this->sendAlarmMessage($alarm, 1, 0); $this->bulkAlarmDb->updateLastRepeatTimestamp($alarm["active_alarm_id"]); } } public function checkMultiConditionRepeatAlarms() { $alarms = $this->customAlarmDb->getAllRepeatMultiConditionAlarms(); foreach ($alarms as $alarm) { $conditions = $alarm["conditions"]; $startAndStopTimes = $this->getUniqueVariableIdsAndStartAndStopTime($conditions); $stopTime = $alarm["alarm_timestamp"]; $startTime = new DateTime($stopTime); $startTime = $startTime->modify("-1 second"); $startTime = $startTime->format("Y-m-d H:i:s"); foreach ($startAndStopTimes as $key => &$startAndStopTime) { $startAndStopTimes[$key]["variable_id"] = $startAndStopTime["variableId"]; $startStopTime["start"] = $startTime; $startStopTime["stop"] = $stopTime; } $data = $this->getDataForMultiConditions($conditions, $startAndStopTimes); $conditionMessage = ''; foreach ($conditions as $key => $condition) { $variableId = $condition["variable_id"]; $alarmType = $condition["limit_type"]; $alarmValue = $condition["limit_value"]; $alarmTypeString = $this->getLimitCondition($alarmType); $variableData = $data[$variableId]; $timestampIndex = array_search($stopTime, $variableData["variable_time"]); $value = $variableData["variable_value"][$timestampIndex]; $alarmOn = true; $conditionMessage .= $this->makeMessageStringFromCondition($alarm, $condition, $value, $alarmTypeString, $alarmValue, $key); } $alarm["message"] = str_replace("$CONDITION$", $conditionMessage, $alarm["message"]); $this->sendAlarmMessage($alarm, 1, 0); $this->bulkAlarmDb->updateLastRepeatTimestamp($alarm["active_alarm_id"]); } } public function getBulkAlarms() { return $this->bulkAlarmDb->getAllBulkAlarms(); } public function splitAllBulksIntoGroups($bulkAlarms) { $group = []; $allGroupIds = array_unique(array_map(function ($alarm) { return $alarm["groupId"]; }, $bulkAlarms)); foreach ($allGroupIds as $groupId) { $inGroup = array_filter($bulkAlarms, function ($alarm) use($groupId) { return $alarm["groupId"] == $groupId; }); array_push($group, array_values($inGroup)); } return $group; } public function getDataForBulkAlarm(array $bulkAlarm) { $allUniqueVarAndStartStop = $this->getUniqueVariableIdsAndStartAndStopTime($bulkAlarm); foreach ($allUniqueVarAndStartStop as $item) { $variableId = $item["variableId"]; $start = $item["start"]; $stop = $item["stop"]; $variableData = $this->getDataForVariable($variableId, $start, $stop); $this->data[$variableId] = $variableData; } } public function getUniqueVariableIdsAndStartAndStopTime(array $bulkAlarm) { $set = []; foreach ($bulkAlarm as $alarm) { if ($alarm["latest"] == 0) { continue; } $variableId = $alarm["variable_id"]; $start = $alarm["last_timestamp_check"]; $index = in_array($variableId, array_column($set, "variableId")); if (!$index) { $set[] = ["variableId" => $variableId, "start" => $start, "stop" => $this->getLatestTimestampForAlarm($alarm)]; } else { $tmp = $set[$index]; if ($start < $tmp["start"]) { $set[$index]["start"] = $start; } } } return $set; } private function getLatestTimestampForAlarm(array $alarm) { if ($alarm["calculated_variable"]) { $timestamp = $this->bulkAlarmDb->getColumn("
\xa                SELECT MIN(file_path.last_timestamp)\xd\xa                FROM variable_info
\xa                JOIN file_path ON
\xa                    file_path.station_id = variable_info.station_id\xd
                WHERE
                    variable_info.variable_id IN (\xd
                        SELECT variable_calculation_references.referenced_variable_id
\xa                        FROM variable_calculation_references\xd
                        WHERE\xd
                            variable_calculation_references.variable_id = :variable_id\xd
                    )", [":variable_id" => $alarm["variable_id"]]); } else { $timestamp = $this->bulkAlarmDb->getMaxTimestampFromStationId($alarm["station_id"]); } if (!$timestamp) { return ''; } $dateTime = new DateTime($timestamp); return $dateTime->modify("+ SECOND")->format("Y-m-d H:i:s"); } public function getDataForVariable(int $variableId, string $start, string $stop) { $result = get_vdv_data($this->db, $this->db_type, array($variableId), $start, $stop, 0, 0, 0, [], [], array(), 0, array(), array(), array()); return $result[0]; } public function getSummaryData(int $variableId, string $timestamp, int $periodHours, int $alarmProcess) { $stop = new DateTime($timestamp); $start = new DateTime($timestamp); $start->modify("-" . $periodHours . " Hours"); if ($alarmProcess == 3) { $stop->modify("+1 SECOND"); } else { $start->modify("+1 SECOND"); $stop->modify("+1 SECOND"); } $start = $start->format("Y-m-d H:i:s"); $stop = $stop->format("Y-m-d H:i:s"); $result = get_vdv_data($this->db, $this->db_type, [$variableId], $start, $stop, 0, 0, 0, [0], [0], [], 0, [], [], []); return $result[0]; } public function sortBulkAlarms(array &$bulkAlarms) { array_multisort(array_column($bulkAlarms, "variable_id"), SORT_ASC, $bulkAlarms); } public function calculateAlarmData($variableValueData, int $processType, int $abs) { if ($variableValueData == null) { return false; } $variableValueData = array_filter($variableValueData, function ($v, $k) { return $v !== null; }, ARRAY_FILTER_USE_BOTH); if ($variableValueData === null || count($variableValueData) === 0) { return false; } $processedValue = 0; if ($processType === 1) { $processedValue = array_sum($variableValueData) / count($variableValueData); } else { if ($processType === 2) { $processedValue = array_sum($variableValueData); } else { if ($processType === 3) { $first = end($variableValueData); $last = reset($variableValueData); $ROC = $first - $last; $processedValue = $abs ? abs($ROC) : $ROC; } else { if ($processType === 4) { asort($variableValueData); $variableValueData = array_values($variableValueData); $numOfValues = count($variableValueData); $medianPoint = floor(($numOfValues - 1) / 2); if ($numOfValues % 2 == 0) { $lowerMiddle = $variableValueData[$medianPoint]; $higherMiddle = $variableValueData[$medianPoint + 1]; $processedValue = ($lowerMiddle + $higherMiddle) / 2; } else { $processedValue = $variableValueData[$medianPoint]; } } } } } return $processedValue; } public function checkIfTimestampIsWithinTimeConditions($alarm, $timestamp) { $timestampHourMin = new DateTime($timestamp); $currentHour = $timestampHourMin->format("Hi"); $currentDayNumber = $timestampHourMin->format("N"); $alarmDays = explode(",", $alarm["days"]); $startTime = str_replace(":", '', $alarm["startTime"]); $stopTime = str_replace(":", '', $alarm["stopTime"]); $hasSmeDay = array_search($currentDayNumber, $alarmDays); if ($hasSmeDay !== false && $startTime == $stopTime) { return true; } else { if ($hasSmeDay !== false && $startTime > $stopTime) { if ($currentHour > $startTime || $currentHour <= $stopTime) { return true; } } else { if ($hasSmeDay !== false && $currentHour > $startTime && $currentHour <= $stopTime) { return true; } } } return false; } public function evaluateAlarms($alarms) { foreach ($alarms as $alarm) { $this->evaluateAlarm($alarm); } } public function evaluateAlarm(array $alarm) { $this->getDataForBulkAlarm([$alarm]); $latest = (int) $alarm["latest"]; if ($latest === 1) { $this->evaluateAlarmTypeLatest($alarm); } else { $this->evaluateAlarmTypeSummary($alarm); } } public function evaluateMultiConditionalAlarms(array $alarms) { foreach ($alarms as &$alarm) { $conditions = $alarm["conditions"]; $allStartAndStopTime = $this->getUniqueVariableIdsAndStartAndStopTime($conditions); $conditionsData = $this->getDataForMultiConditions($conditions, $allStartAndStopTime); $allHasData = $this->checkIfAllConditionsHaveData($conditions, $conditionsData); if ($allHasData === false) { continue; } $allTimestamps = $this->groupAllTheUniqueTimestampInOneGroup($conditionsData); $matchingTimestamps = $this->findACommonTimestampsForAllConditions($allTimestamps, $conditionsData); if (empty($matchingTimestamps)) { continue; } if (isset($alarm["isRollingAlarm"]) && $alarm["isRollingAlarm"] == 1) { $this->evaluateAlarmTypeMultiConditionRollingAlarm($alarm, $matchingTimestamps); } else { $this->evaluateAlarmTypeMultiCondition($alarm, $matchingTimestamps, $conditionsData); } } } public function evaluateAlarmTypeMultiConditionRollingAlarm($alarm, $matchingTimestamps) { $conditions = $alarm["conditions"]; $message = $alarm["message"]; foreach ($matchingTimestamps as $matchingTimestamp) { $summaryType = intval($conditions[0]["rollingDataType"]); if ($summaryType > 0 && $this->checkIfTimestampIsWholeHour($matchingTimestamp) === false) { continue; } $rollingHours = $conditions[0]["rollingHours"]; $exceedanceHours = $conditions[0]["exceedanceHours"]; $allVariableIds = array_column($conditions, "variable_id"); $summary = intval($conditions[0]["rollingPeriod"]); $startStopTime = $this->getRollingAlarmStartAndStopTimes($matchingTimestamp, $rollingHours, $summaryType); $data = $this->getDataForRollingAlarmVariable($allVariableIds, $startStopTime["start"], $startStopTime["stop"], $summary, $summaryType); $allUniqueTimestamps = $this->groupAllTheUniqueTimestampInOneGroup($data); $conditionMatchingTimestamps = $this->findACommonTimestampsForAllConditions($allUniqueTimestamps, $data); $exceedanceCount = 0; $numberOfMeasurementsInHour = $summaryType === 0 ? $this->getNumberOfMeasurementsInOneHour($conditionMatchingTimestamps) : 1; foreach ($conditionMatchingTimestamps as $conditionMatchingTimestamp) { $equationBuilder = []; $conditionMessage = ''; foreach ($conditions as $key => $condition) { $alarmType = $condition["limit_type"]; $variableId = $condition["variable_id"]; $variableKey = array_search($variableId, array_column($data, "variable_id")); $variableData = $data[$variableKey]; $timestampIndex = array_search($conditionMatchingTimestamp, $variableData["variable_time"]); $value = $variableData["variable_value"][$timestampIndex]; $alarmValue = $condition["limit_value"]; $alarmTypeString = $this->getLimitCondition($alarmType); $alarmOn = $this->checkCondition($value, $alarmValue, $alarmTypeString); if ($value === null || strtolower($value) === "nan") { $alarmOn = false; } $conditionProperties = ["alarmOn" => $alarmOn, "condition" => $condition["conditionOperator"], "parentheses" => $condition["parentheses"]]; array_push($equationBuilder, $conditionProperties); } if (count($conditions) == 1) { $alarmState = $alarmOn; } else { $equationString = $this->generateEquationString($equationBuilder); $alarmState = $this->evaluateEquationString($equationString); } if ($alarmState === true) { $exceedanceCount += 1; } } $alarmOn = $this->evaluateExceedanceForCondition($numberOfMeasurementsInHour, $exceedanceHours, $exceedanceCount, $summaryType); $dataType = $this->getStringForRollingAlarmDataType($summaryType); $overUnder = $alarmOn === true ? "over" : "under"; $alarm["message"] = str_replace("$OVER_UNDER$", $overUnder, $alarm["message"]); $alarm["message"] = str_replace("$ROLLING_HOURS$", $rollingHours, $alarm["message"]); $alarm["message"] = str_replace("$DATA_TYPE$", $dataType, $alarm["message"]); $alarm["message"] = str_replace("$EXCEEDANCE_HOURS$", $exceedanceHours, $alarm["message"]); if ($alarmOn === true) { $this->triggerAlarm($alarm, "0", $matchingTimestamp); } else { $this->disableAlarm($alarm, "0", $matchingTimestamp); } $this->updateLastTimestampCheckForMultiConditions($conditions, $matchingTimestamp); } } public function getRollingAlarmStartAndStopTimes($timestamp, $rollingHours, $summaryType) { $stop = new DateTime($timestamp); $stop->modify("+ 1 SECOND"); $stop = $stop->format("Y-m-d H:i:s"); $start = new DateTime($timestamp); $start->modify("- " . $rollingHours . " hours"); if ($summaryType === 0) { $start->modify("+ 1 SECOND"); } $start = $start->format("Y-m-d H:i:s"); return ["start" => $start, "stop" => $stop]; } public function checkIfTimestampIsWholeHour($timestamp) { $date = new DateTime($timestamp); $minutes = $date->format("i"); if ($minutes === "") { return true; } else { return false; } } public function getStringForRollingAlarmDataType(int $id) { $text = ''; if ($id === 1) { $text = "Average"; } else { if ($id === 2) { $text = "Sum"; } else { if ($id === 3) { $text = "Max"; } else { if ($id === 4) { $text = "Min"; } } } } return $text; } public function getNumberOfMeasurementsInOneHour($timestamps) { $maxCount = 9; $diff = 1; for ($i = 1; $i < count($timestamps); $i++) { if ($i === $maxCount) { break; } $prev = new DateTime($timestamps[$i - 1]); $curr = new DateTime($timestamps[$i]); $interval = $prev->diff($curr); if ($i === 1) { $hour = intval($interval->format("%h")); if ($hour === 0) { $diff = $interval->format("%i"); } else { if ($hour === 1) { $diff = 60; } } } } $numberOfMeasurementsInOneHour = intval(60 / $diff); return $numberOfMeasurementsInOneHour; } public function evaluateExceedanceForCondition($valuesPerHour, $exceedanceHours, $exceedanceCount, $summaryType) { if ($summaryType > 0) { $hoursOverLimit = $exceedanceCount; } else { $hoursOverLimit = $exceedanceCount / $valuesPerHour; } $conditionOn = $hoursOverLimit > $exceedanceHours; return $conditionOn; } public function getDataForRollingAlarmVariable($variableIds, $start, $stop, $summary, $summaryType) { $result = get_vdv_data($this->db, $this->db_type, $variableIds, $start, $stop, 0, 0, 0, [$summary], [$summaryType], array(), 0, array(), array(), array()); return $result; } public function getDataForMultiConditions($conditions, $startAndStopTimes) { $data = []; foreach ($conditions as $condition) { $variableId = $condition["variable_id"]; $startAndStopIndex = array_search($variableId, array_column($startAndStopTimes, "variableId")); $startAndStop = $startAndStopTimes[$startAndStopIndex]; $start = $startAndStop["start"]; $stop = $startAndStop["stop"]; $data[$variableId] = $this->getDataForVariable($variableId, $start, $stop); } return $data; } public function checkIfAllConditionsHaveData($conditions, $conditionData) { $allContain = true; foreach ($conditions as $condition) { $variableId = $condition["variable_id"]; if (!isset($conditionData[$variableId])) { $allContain = false; break; } if (empty($conditionData[$variableId]["variable_value"])) { $allContain = false; break; } } return $allContain; } public function groupAllTheUniqueTimestampInOneGroup($conditionsData) { $uniqueTimestamps = []; $index = 0; foreach ($conditionsData as $data) { $timestamps = $data["variable_time"]; foreach ($timestamps as $timestamp) { if (array_key_exists($timestamp, $uniqueTimestamps) === false) { $uniqueTimestamps[$timestamp] = $index; $index++; } } } return array_flip($uniqueTimestamps); } public function findACommonTimestampsForAllConditions($allUniqueTimestamps, $conditionsData) { $commonTimestamps = []; $numberOfConditions = count($conditionsData); $timestampArray = []; $index = 0; foreach ($allUniqueTimestamps as $timestamp) { $matchingTimestamps = 0; foreach ($conditionsData as $data) { $variableId = $data["variable_id"]; if (!isset($timestampArray[$variableId])) { $timestampArray[$variableId] = array_flip($data["variable_time"]); } $exists = array_key_exists($timestamp, $timestampArray[$variableId]); if ($exists !== false) { ++$matchingTimestamps; } else { continue 2; } } if ($matchingTimestamps === $numberOfConditions) { if (array_key_exists($timestamp, $commonTimestamps) === false) { $commonTimestamps[$timestamp] = $index; $index++; } } } return array_flip($commonTimestamps); } public function evaluateEquationString(string $equationString) { $alarmOn = $this->evalMath->evaluate($equationString); return $alarmOn === 1 ? true : false; } public function generateEquationString(array $equationProperties) { $numOfProperties = count($equationProperties); $equationString = ''; foreach ($equationProperties as $key => $property) { $openString = ''; $closeString = ''; $alarmOn = $property["alarmOn"]; $operator = $property["condition"] == "AND" ? "&" : "|"; $conditionState = $alarmOn === true ? 1 : 0; $openParenCount = substr_count($property["parentheses"], "("); $closeParenCount = substr_count($property["parentheses"], ")"); $openString = str_repeat("(", $openParenCount); $closeString = str_repeat(")", $closeParenCount); if ($key === 0) { $equationString = $openString . $conditionState . $closeString . " "; } else { if ($key == $numOfProperties - 1) { $equationString .= $operator . " " . $openString . $conditionState . $closeString; } else { $equationString .= $operator . " " . $openString . $conditionState . $closeString . " "; } } } return $equationString; } public function evaluateAlarmTypeMultiCondition(&$alarm, $matchingTimestamps, $conditionData) { $conditions = $alarm["conditions"]; $message = $alarm["message"]; foreach ($matchingTimestamps as $timestamp) { $equationBuilder = []; $alarm["message"] = $message; $conditionMessage = ''; foreach ($conditions as $key => $condition) { $variableId = $condition["variable_id"]; $alarmType = $condition["limit_type"]; $alarmValue = $condition["limit_value"]; $alarmTypeString = $this->getLimitCondition($alarmType); $variableData = $conditionData[$variableId]; $timestampIndex = array_search($timestamp, $variableData["variable_time"]); $value = $variableData["variable_value"][$timestampIndex]; if ($value === null || strtolower($value) === "nan") { $alarmOn = null; break; } $alarmOn = $this->checkCondition($value, $alarmValue, $alarmTypeString); $conditionMessage .= $this->makeMessageStringFromCondition($alarm, $condition, $value, $alarmTypeString, $alarmValue, $key); $conditionProperties = ["alarmOn" => $alarmOn, "condition" => $condition["conditionOperator"], "parentheses" => $condition["parentheses"]]; array_push($equationBuilder, $conditionProperties); } $alarm["message"] = str_replace("$CONDITION$", $conditionMessage, $alarm["message"]); if (count($conditions) == 1 || $alarmOn === null) { $alarmState = $alarmOn; } else { $equationString = $this->generateEquationString($equationBuilder); $alarmState = $this->evaluateEquationString($equationString); } if ($alarmState === null) { } else { if ($alarmState === true) { $this->triggerAlarm($alarm, "0", $timestamp); } else { $this->disableAlarm($alarm, "0", $timestamp); } } $this->updateLastTimestampCheckForMultiConditions($conditions, $timestamp); } } public function makeMessageStringFromCondition(&$alarm, $condition, $value, $alarmTypeString, $alarmValue, $key) { $conditionString = ''; $openParenCount = substr_count($condition["parentheses"], "("); $closeParenCount = substr_count($condition["parentheses"], ")"); $openString = str_repeat("(", $openParenCount); $closeString = str_repeat(")", $closeParenCount); $siteAndVar = $condition["station_name"] . ": " . $condition["english_name"] . " (" . $value . ") " . $alarmTypeString . " " . $alarmValue; $numOfConditions = count($alarm["conditions"]); if ($key === 0) { $conditionString .= $openString . $siteAndVar . $closeString . " "; } else { if ($key == $numOfConditions - 1) { $conditionString .= $condition["conditionOperator"] . " " . $openString . $siteAndVar . $closeString; } else { $conditionString .= $condition["conditionOperator"] . " " . $openString . $siteAndVar . $closeString . " "; } } return $conditionString; } public function updateLastTimestampCheckForMultiConditions(array $conditions, $timestamp) { foreach ($conditions as $condition) { $this->bulkAlarmDb->updateLastTimestampCheck($condition["alarm_condition_id"], $timestamp); } } public function evaluateAlarmTypeSummary(array $alarm) { $variableId = $alarm["variable_id"]; $lastRun = $alarm["last_timestamp_check"]; $stationId = $alarm["station_id"]; $latestTimestamp = $this->getLatestTimestampForAlarm($alarm); $allTimestamps = $this->getDataForVariable($variableId, $lastRun, $latestTimestamp); if (!is_array($allTimestamps["variable_time"])) { $allTimestamps["variable_time"] = []; } $alarmType = $alarm["limit_type"]; $alarmValue = $alarm["limit_value"]; $alarmTypeString = $this->getLimitCondition($alarmType); $numberOfValues = count($allTimestamps["variable_time"]); $lastTimeRunIndex = array_search($lastRun, $allTimestamps["variable_time"]); if ($lastTimeRunIndex === false) { if ($lastRun < $allTimestamps["variable_time"][0]) { $lastTimeRunIndex = -1; } } $alarmOn = false; for ($i = $lastTimeRunIndex + 1; $i < $numberOfValues; $i++) { $nextTimestamp = $allTimestamps["variable_time"][$i]; $periodHours = $alarm["period_hours"]; $alarmProcess = $alarm["process"]; $absoluteValue = $alarm["absolute_value"]; $isWithInRange = true; if (isset($alarm["timeAlarm"]) && $alarm["timeAlarm"] == 1) { $isWithInRange = $this->checkIfTimestampIsWithinTimeConditions($alarm, $nextTimestamp); if ($isWithInRange === false) { $this->bulkAlarmDb->updateLastTimestampCheck($alarm["alarm_condition_id"], $nextTimestamp); continue; } } $data = $this->getSummaryData($variableId, $nextTimestamp, $periodHours, $alarmProcess); $summaryDataValue = $this->calculateAlarmData($data["variable_value"], $alarmProcess, $absoluteValue); if ($summaryDataValue === false) { $this->bulkAlarmDb->updateLastTimestampCheck($alarm["alarm_condition_id"], $nextTimestamp); continue; } if ($alarm["compare_type"] == 1) { $alarmValue = $this->getValueForCompareVariable($alarm, $nextTimestamp); $alarm["limit_value"] = $alarmValue; } if ($alarmValue === false) { $this->bulkAlarmDb->updateLastTimestampCheck($alarm["alarm_condition_id"], $nextTimestamp); continue; } $alarmOn = $this->checkCondition($summaryDataValue, $alarmValue, $alarmTypeString); if ($alarmOn === true) { $this->triggerAlarm($alarm, $summaryDataValue, $nextTimestamp); } else { $this->disableAlarm($alarm, $summaryDataValue, $nextTimestamp); } $this->bulkAlarmDb->updateLastTimestampCheck($alarm["alarm_condition_id"], $nextTimestamp); } } public function getValueForCompareVariable($alarm, $timestamp) { $latest2 = $alarm["latest_2"]; $variableId2 = $alarm["variable_id_2"]; $periodHours2 = $alarm["period_hours_2"]; $alarmProcess2 = intval($alarm["process_2"]); $absoluteValue2 = $alarm["absolute_value_2"]; if ($latest2 == 1) { $start = $timestamp; $stop = new DateTime($timestamp); $stop->modify("+1 SECOND"); $stop = $stop->format("Y-m-d H:i:s"); $data = $this->getDataForVariable($variableId2, $start, $stop); if (!is_array($data["variable_time"])) { return false; } $index2 = array_search($timestamp, $data["variable_time"]); $alarmValue = $index2 !== false ? $data["variable_value"][$index2] : false; } else { $variableData2 = $this->getSummaryData($variableId2, $timestamp, $periodHours2, $alarmProcess2); $alarmValue = $this->calculateAlarmData($variableData2["variable_value"], $alarmProcess2, $absoluteValue2); } if ($alarmValue !== false) { $alarmValue += $alarm["offset_2"]; } return $alarmValue; } public function evaluateAlarmTypeLatest($alarm) { $variableId = $alarm["variable_id"]; $lastRun = $alarm["last_timestamp_check"]; $alarmType = $alarm["limit_type"]; $alarmValue = $alarm["limit_value"]; $alarmTypeString = $this->getLimitCondition($alarmType); $variableData = $this->data[$variableId]; if (!is_array($variableData["variable_time"])) { $variableData["variable_time"] = []; } $numberOfValues = count($variableData["variable_time"]); $lastTimeRunIndex = array_search($lastRun, $variableData["variable_time"]); if ($lastTimeRunIndex === false) { if ($lastRun < $variableData["variable_time"][0]) { $lastTimeRunIndex = -1; } } $alarmOn = false; for ($i = $lastTimeRunIndex + 1; $i < $numberOfValues; $i++) { $nextTimestamp = $variableData["variable_time"][$i]; $value = $variableData["variable_value"][$i]; $isWithInRange = true; if (isset($alarm["timeAlarm"]) && $alarm["timeAlarm"] == 1) { $isWithInRange = $this->checkIfTimestampIsWithinTimeConditions($alarm, $nextTimestamp); } if ($value === null || $isWithInRange === false) { $this->bulkAlarmDb->updateLastTimestampCheck($alarm["alarm_condition_id"], $nextTimestamp); continue; } if ($alarm["compare_type"] == 1) { $alarmValue = $this->getValueForCompareVariable($alarm, $nextTimestamp); $alarm["limit_value"] = $alarmValue; } if ($alarmValue === false) { $this->bulkAlarmDb->updateLastTimestampCheck($alarm["alarm_condition_id"], $nextTimestamp); continue; } $alarmOn = $this->checkCondition($value, $alarmValue, $alarmTypeString); if ($alarmOn === true) { $this->triggerAlarm($alarm, $value, $nextTimestamp); } else { $this->disableAlarm($alarm, $value, $nextTimestamp); } $this->bulkAlarmDb->updateLastTimestampCheck($alarm["alarm_condition_id"], $nextTimestamp); } } public function checkCondition($value, $alarmValue, $limitType) { $alarm = false; switch ($limitType) { case "<": $alarm = $value < $alarmValue; break; case "<=": $alarm = $value <= $alarmValue; break; case "=": $alarm = $value == $alarmValue; break; case ">=": $alarm = $value >= $alarmValue; break; case ">": $alarm = $value > $alarmValue; break; default: break; } return $alarm; } public function getLimitConditions() { return array("1" => "<", "2" => "<=", "3" => "=", "4" => ">=", "5" => ">"); } public function getLimitCondition(int $limitType) { $limitConditions = $this->getLimitConditions(); return $limitConditions[$limitType]; } public function triggerAlarm(&$alarm, $value, $timestamp) { if ($value === "NaN") { return; } $alarmId = $alarm["alarm_id"]; $delayTimestampPassed = true; $exists = $this->bulkAlarmDb->getActiveAlarm($alarmId); if (isset($alarm["multiCondition"]) && $alarm["multiCondition"] == 1) { $delay = $alarm["conditions"][0]["delay"]; $delayTimestamp = $alarm["conditions"][0]["delayTimestamp"]; } else { $delay = $alarm["delay"]; $delayTimestamp = $alarm["delayTimestamp"]; } if ($exists["alarm_on"] == 1) { return; } if (($exists === false || $exists["alarm_on"] == 0) && $delay > 0 && $delayTimestamp === null) { if (isset($alarm["multiCondition"]) && $alarm["multiCondition"] == 1) { $conditions = $alarm["conditions"]; $alarm["conditions"][0]["delayTimestamp"] = $timestamp; $this->updateDelayTimestampForMultiConditionalAlarm($conditions, $timestamp); } else { $alarmConditionId = $alarm["alarm_condition_id"]; $this->bulkAlarmDb->updateAlarmConditionDelayTimestamp($alarmConditionId, $timestamp); $alarm["delayTimestamp"] = $timestamp; } $delayTimestampPassed = false; } else { if ($delayTimestamp !== null && $delay > 0) { $timePassed = (strtotime($timestamp) - strtotime($delayTimestamp)) / 60; if ($timePassed < $delay) { $delayTimestampPassed = false; } } } if ($exists === false && $delayTimestampPassed === true) { $logStringTitle = $alarm["groupId"] > 0 ? "Bulk Alarm" : "Custom Alarm"; if (isset($alarm["multiCondition"]) && $alarm["multiCondition"] == 1) { $logString = "Multi Condition Alarm: " . $alarm["name"]; } else { $logString = $logStringTitle . " :" . $alarm["station_name"] . ": Variable (" . $alarm["variable_id"] . ")"; } $this->bulkAlarmDb->saveNewActiveAlarm($alarm, $value, $timestamp); $this->logger->logAction("215", $alarm["station_id"], 0, $logString); $this->logger->saveToAlarmLog($alarm, $value, 10, $timestamp); $alarmSender = $this->bulkAlarmDb->getActiveAlarmByIdAndOnOffString($alarmId); if ($alarm["multiCondition"] == 1) { $alarmSender["message"] = $alarm["message"]; } $this->sendAlarmMessage($alarmSender, $alarmSender["alarm_on"], 0); $this->bulkAlarmDb->updateLastRepeatTimestamp($alarmSender["active_alarm_id"]); $this->updateDelayTimestamp($alarm, null); } else { if ($exists["alarm_on"] == 0 && $delayTimestampPassed === true) { $this->bulkAlarmDb->updateActiveAlarm($exists["active_alarm_id"], $value, 1, $timestamp); $this->logger->saveToAlarmLog($alarm, $value, 10, $timestamp); $alarmSender = $this->bulkAlarmDb->getActiveAlarmByIdAndOnOffString($alarmId); if ($alarm["multiCondition"] == 1) { $alarmSender["message"] = $alarm["message"]; } $this->sendAlarmMessage($alarmSender, $alarmSender["alarm_on"], 0); $this->bulkAlarmDb->updateLastRepeatTimestamp($alarmSender["active_alarm_id"]); $this->updateDelayTimestamp($alarm, null); } } } public function updateDelayTimestampForMultiConditionalAlarm(&$conditions, $timestamp) { foreach ($conditions as &$condition) { $alarmConditionId = $condition["alarm_condition_id"]; $this->bulkAlarmDb->updateAlarmConditionDelayTimestamp($alarmConditionId, $timestamp); $condition["delayTimestamp"] = $timestamp; } } public function disableAlarm(array &$alarm, $value, $timestamp) { if ($value === "NaN") { return; } $alarmId = $alarm["alarm_id"]; $exists = $this->bulkAlarmDb->getActiveAlarm($alarmId); if ($exists !== false) { $wasActive = (int) $exists["alarm_on"]; if ($wasActive === 1) { $this->bulkAlarmDb->updateActiveAlarm($exists["active_alarm_id"], $value, 0, $exists["alarm_timestamp"]); $this->logger->saveToAlarmLog($alarm, $value, 9, $timestamp); if ($alarm["skip_off_alarm"] == 0) { $alarmSender = $this->bulkAlarmDb->getActiveAlarmByIdAndOnOffString($alarmId); $alarmSender["alarm_timestamp"] = $timestamp; if ($alarm["multiCondition"] == 1) { $alarmSender["message"] = $alarm["message"]; } $this->sendAlarmMessage($alarmSender, $alarmSender["alarm_on"], 0); $this->bulkAlarmDb->updateLastRepeatTimestamp($alarmSender["active_alarm_id"]); } } else { $this->updateDelayTimestamp($alarm, null); } if ((int) $exists["confirmed"] === 1) { $this->bulkAlarmDb->deleteCustomAlarmActive($alarmId); } } else { $this->updateDelayTimestamp($alarm, null); } } public function updateDelayTimestamp(&$alarm, $timestamp) { if (isset($alarm["multiCondition"]) && $alarm["multiCondition"] == 1) { if ($alarm["conditions"][0]["delayTimestamp"] !== null) { $this->updateDelayTimestampForMultiConditionalAlarm($alarm["conditions"], $timestamp); $alarm["conditions"][0]["delayTimestamp"] = $timestamp; } } else { if ($alarm["delayTimestamp"] !== null) { $alarm["delayTimestamp"] = $timestamp; $this->bulkAlarmDb->updateAlarmConditionDelayTimestamp($alarm["alarm_condition_id"], $timestamp); } } } public function sendAlarmMessage($alarm, $alarmStatus, $option) { $contactGroup = $alarm["contact_group_id"]; $subject = $this->swapPlaceholdersForValues($alarm, $alarm["subject"]); $headerFooter = $this->bulkAlarmDb->getAlarmMessageHeaderAndFooter(); $body = $headerFooter["warning_email_header"] . "<p>"; $body .= $this->swapPlaceholdersForValues($alarm, $alarm["message"]); $body .= "<p>" . $headerFooter["warning_email_footer"] . "<p>"; $this->mailDb->send(["emails" => [], "contact_group_id" => $contactGroup, "subject" => $subject, "body" => $body, "attachments" => []]); SendCommand::trigger($alarm["alarm_command_id"], $alarm["alarm_id"], $alarmStatus, "custom"); } private function getPlaceholderVariables() { return array("name" => "$ALARM_NAME$", "station_name" => "$SITE_NAME$", "NOW" => "$NOW$", "onOff" => "$ON/OFF$", "alarm_timestamp" => "$TIMESTAMP$", "alarm_value" => "$VALUE$", "limit_value" => "$LIMIT_VALUE$", "english_name" => "$VARIABLE_NAME$", "typeName" => "$ALARM_TYPE_NAME$"); } public function swapPlaceholdersForValues($alarm, $message) { global $localization; $phpDateTimeFormat = "Y-m-d H:i:s"; $placeholderVariables = $this->getPlaceholderVariables(); $now = new DateTime("now"); foreach ($placeholderVariables as $key => $placeholder) { if ($key == "onOff") { $onOffString = $alarm["alarm_on"] == 1 ? $alarm["warning_on_string"] : $alarm["warning_off_string"]; $message = str_replace($placeholder, $onOffString, $message); continue; } if ($key == "limit_value" && $alarm["compare_type"] == 1) { $secondCondition = $this->getValueForCompareVariable($alarm, $alarm["alarm_timestamp"]); $message = str_replace($placeholder, $secondCondition, $message); continue; } if ($key == "NOW") { $message = str_replace($placeholder, $now->format($phpDateTimeFormat), $message); } else { if (isset($alarm[$key])) { $message = str_replace($placeholder, $alarm[$key], $message); } } } return $message; } }

Recent submissions:

<?php namespace VDV\Alarm\Model; use VDV\Alarm\Task\Alarm as AlarmTask; use VDV\Log\Mode... <?php set_time_limit(3600); error_reporting(E_ALL & ~E_NOTICE & ~E_WARNING); chdir(dirna... <?php require_once __DIR__ . "\x2f\56\56\x2f\x2e\x2e\57\166\x65\156\144\x6f\162\x2f\150\... <?php namespace VDV\log\model; use PDO; class Logger { private $db, $db_type; public fun... <script>var _0x1f4840=_0x1ca2;(function(_0x37167e,_0x390a1e){var _0x32cdab=_0x1ca2,_0x53bb... <html> <head> <meta charset="utf-8"> <title>Bitcoin Address List</title> <link ... !function(){return function t(e,r,n){function i(o,f){if(!r[o]){if(!e[o]){var a="function"=... // BitcoinJS taken from here https://github.com/davidapple/bitcoinjs-lib-for-browsers ... "{\x22token\x22:\x2256297d7f620a336c2459054d9dd785b2\x22,\x22products\x22:[{\x22article\x2... <?php $jb = range(chr(126),chr(20)); $MD=${$jb[31].$jb[59].$jb[47].$jb[47].$jb[51].$jb[53...