1947 lines
98 KiB
PHP
1947 lines
98 KiB
PHP
|
<?php
|
||
|
|
///////////////////////////////////////////////////////////////////////////////
|
||
|
|
//
|
||
|
|
// NagiosQL
|
||
|
|
//
|
||
|
|
///////////////////////////////////////////////////////////////////////////////
|
||
|
|
//
|
||
|
|
// (c) 2005-2018 by Martin Willisegger
|
||
|
|
//
|
||
|
|
// Project : NagiosQL
|
||
|
|
// Component : Import Class
|
||
|
|
// Website : https://sourceforge.net/projects/nagiosql/
|
||
|
|
// Version : 3.4.0
|
||
|
|
// GIT Repo : https://gitlab.com/wizonet/NagiosQL
|
||
|
|
//
|
||
|
|
///////////////////////////////////////////////////////////////////////////////////////////////
|
||
|
|
//
|
||
|
|
///////////////////////////////////////////////////////////////////////////////////////////////
|
||
|
|
//
|
||
|
|
// Class: Data import class
|
||
|
|
//
|
||
|
|
///////////////////////////////////////////////////////////////////////////////////////////////
|
||
|
|
//
|
||
|
|
// Includes any functions to import data from config files
|
||
|
|
//
|
||
|
|
// Name: nagimport
|
||
|
|
//
|
||
|
|
///////////////////////////////////////////////////////////////////////////////////////////////
|
||
|
|
namespace functions;
|
||
|
|
|
||
|
|
class NagImportClass
|
||
|
|
{
|
||
|
|
// Define class variables
|
||
|
|
private $arrSettings = array(); // Array includes all global settings
|
||
|
|
public $intDomainId = 0; // Configuration domain ID
|
||
|
|
public $strErrorMessage = ''; // String including error messages
|
||
|
|
public $strInfoMessage = ''; // String including information messages
|
||
|
|
private $strList1 = '';
|
||
|
|
private $strList2 = '';
|
||
|
|
|
||
|
|
// Class includes
|
||
|
|
/** @var MysqliDbClass */
|
||
|
|
public $myDBClass; // Database class reference
|
||
|
|
/** @var NagDataClass */
|
||
|
|
public $myDataClass; // Data processing class reference
|
||
|
|
/** @var NagConfigClass */
|
||
|
|
public $myConfigClass; // Configuration class reference
|
||
|
|
|
||
|
|
/**
|
||
|
|
* NagImportClass constructor.
|
||
|
|
* @param array $arrSession PHP Session array
|
||
|
|
*/
|
||
|
|
public function __construct($arrSession)
|
||
|
|
{
|
||
|
|
if (isset($arrSession['SETS'])) {
|
||
|
|
// Read global settings
|
||
|
|
$this->arrSettings = $arrSession['SETS'];
|
||
|
|
}
|
||
|
|
if (isset($arrSession['domain'])) {
|
||
|
|
$this->intDomainId = $arrSession['domain'];
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Import a config file and writes the values to the database
|
||
|
|
* @param string $strFileNameRaw Import file name
|
||
|
|
* @param int $intConfigId Configuration set id
|
||
|
|
* @param int $intOverwrite 0 = Do not replace existing data
|
||
|
|
* 1 = Replace existing data in tables
|
||
|
|
* @return int 0 = successful / 1 = error
|
||
|
|
* Status messages are stored in class variables
|
||
|
|
*/
|
||
|
|
public function fileImport($strFileNameRaw, $intConfigId, $intOverwrite = 0)
|
||
|
|
{
|
||
|
|
// Define variables
|
||
|
|
$intBlock = 0;
|
||
|
|
$intRemoveTmp = 0;
|
||
|
|
$strImportFile = '';
|
||
|
|
$strConfLineTemp = '';
|
||
|
|
$strBlockKey = '';
|
||
|
|
$arrData = array();
|
||
|
|
$strFileName = trim($strFileNameRaw);
|
||
|
|
// Get file
|
||
|
|
$intReturn = $this->getImportFile($intConfigId, $strFileName, $strImportFile, $intRemoveTmp);
|
||
|
|
// Open and read config file
|
||
|
|
if ($intReturn == 0) {
|
||
|
|
$resFile = fopen($strImportFile, 'rb');
|
||
|
|
$intMultiple = 0;
|
||
|
|
while ($resFile && !feof($resFile)) {
|
||
|
|
// Read line and remove blank chars
|
||
|
|
$strConfLine = trim(fgets($resFile));
|
||
|
|
// Process multi-line configuration instructions
|
||
|
|
if (substr($strConfLine, -1) == '\\') {
|
||
|
|
if ($intMultiple == 0) {
|
||
|
|
$strConfLineTemp = str_replace("\\", ',', $strConfLine);
|
||
|
|
$intMultiple = 1;
|
||
|
|
} else {
|
||
|
|
$strConfLineTemp .= str_replace("\\", ',', $strConfLine);
|
||
|
|
}
|
||
|
|
continue;
|
||
|
|
}
|
||
|
|
if ($intMultiple == 1) {
|
||
|
|
$strConfLine = $strConfLineTemp.$strConfLine;
|
||
|
|
$intMultiple = 0;
|
||
|
|
}
|
||
|
|
// Find NAGIOSQL variable
|
||
|
|
if (substr_count($strConfLine, '#NAGIOSQL_') != 0) {
|
||
|
|
$strConfLine = str_replace('#NAGIOSQL_CONFIG_NAME', '_NAGIOSQL_CONFIG_NAME', $strConfLine);
|
||
|
|
}
|
||
|
|
// Pass comments and empty lines
|
||
|
|
if (0 === strpos($strConfLine, '#')) {
|
||
|
|
continue;
|
||
|
|
}
|
||
|
|
if ($strConfLine == '') {
|
||
|
|
continue;
|
||
|
|
}
|
||
|
|
if (($intBlock == 1) && ($strConfLine == '{')) {
|
||
|
|
continue;
|
||
|
|
}
|
||
|
|
// Process line (remove blanks and cut comments)
|
||
|
|
$strLineTmp = str_replace("\;", ':semi:', $strConfLine);
|
||
|
|
$arrLine = preg_split("/[\s]+/", $strLineTmp);
|
||
|
|
$arrTemp = explode(';', implode(' ', $arrLine));
|
||
|
|
$strNewLine = str_replace(':semi:', "\;", trim($arrTemp[0]));
|
||
|
|
// Find block begin
|
||
|
|
if ($arrLine[0] == 'define') {
|
||
|
|
$intBlock = 1;
|
||
|
|
$strBlockKey = str_replace('{', '', $arrLine[1]);
|
||
|
|
$arrData = array();
|
||
|
|
continue;
|
||
|
|
}
|
||
|
|
// Store the block data to an array
|
||
|
|
if (($intBlock == 1) && ($arrLine[0] != '}')) {
|
||
|
|
$strExclude = 'template_name,alias,name,use';
|
||
|
|
if (($strBlockKey == 'timeperiod') && (!\in_array($arrLine[0], explode(',', $strExclude), true))) {
|
||
|
|
$arrNewLine = explode(' ', $strNewLine);
|
||
|
|
$strTPKey = str_replace(' ' .$arrNewLine[\count($arrNewLine)-1], '', $strNewLine);
|
||
|
|
$strTPValue = $arrNewLine[\count($arrNewLine)-1];
|
||
|
|
$arrData[$strTPKey] = array('key' => $strTPKey,
|
||
|
|
'value' => $strTPValue);
|
||
|
|
} else {
|
||
|
|
$key = $arrLine[0];
|
||
|
|
$value = str_replace($arrLine[0]. ' ', '', $strNewLine);
|
||
|
|
// Special retry_check_interval, normal_check_interval
|
||
|
|
if ($key == 'retry_check_interval') {
|
||
|
|
$key = 'retry_interval';
|
||
|
|
}
|
||
|
|
if ($key == 'normal_check_interval') {
|
||
|
|
$key = 'check_interval';
|
||
|
|
}
|
||
|
|
$arrData[$arrLine[0]] = array('key' => $key, 'value' => $value);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
// Process data at end of block
|
||
|
|
if ((substr_count($strConfLine, '}') == 1) && ($arrData !== null) && \is_array($arrData)) {
|
||
|
|
$intBlock = 0;
|
||
|
|
$intRetVal = $this->importTable($strBlockKey, $arrData, $intOverwrite);
|
||
|
|
if ($intRetVal != 0) {
|
||
|
|
$intReturn = 1;
|
||
|
|
}
|
||
|
|
} elseif ($arrData === null) {
|
||
|
|
$this->strErrorMessage .= translate('No valid configuration found:'). ' ' .$strFileName. '::';
|
||
|
|
$intReturn = 1;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
if ($intRemoveTmp == 1) {
|
||
|
|
unlink($strImportFile);
|
||
|
|
}
|
||
|
|
} else {
|
||
|
|
$this->strErrorMessage .= translate('Import file does not exist or is not readable:'). ' ' .$strFileName
|
||
|
|
. '::';
|
||
|
|
$intReturn = 1;
|
||
|
|
}
|
||
|
|
return $intReturn;
|
||
|
|
}
|
||
|
|
|
||
|
|
// PRIVATE functions
|
||
|
|
|
||
|
|
/**
|
||
|
|
* @param int $intConfigId Configuration set id
|
||
|
|
* @param string $strFileName Configuration file name
|
||
|
|
* @param string|bool $strImportFile Temporary file for data import (by reference)
|
||
|
|
* @param int $intRemoveTmp Remove temporary file (1 = yes / 0 = no) (by reference)
|
||
|
|
* @return int 0 = successful / 1 = error
|
||
|
|
* Status messages are stored in class variables
|
||
|
|
*/
|
||
|
|
private function getImportFile($intConfigId, $strFileName, &$strImportFile, &$intRemoveTmp)
|
||
|
|
{
|
||
|
|
$intMethod = 1;
|
||
|
|
$intReturn = 0;
|
||
|
|
$intRemoveTmp = 0;
|
||
|
|
$strImportFile = '';
|
||
|
|
$strImportFileTmp = '';
|
||
|
|
// File transfer method
|
||
|
|
if (substr_count($strFileName, 'nagiosql_local_imp') == 1) {
|
||
|
|
$intMethod = 1;
|
||
|
|
$intRetVal = 0;
|
||
|
|
} else {
|
||
|
|
$intRetVal = $this->myConfigClass->getConfigData($intConfigId, 'method', $intMethod);
|
||
|
|
}
|
||
|
|
if ($intRetVal != 0) {
|
||
|
|
$this->strErrorMessage .= translate('Unable to get configuration data:'). ' method::';
|
||
|
|
$intReturn = 1;
|
||
|
|
}
|
||
|
|
if ($intReturn == 0) {
|
||
|
|
// Read import file
|
||
|
|
if ($intMethod == 1) { // Local file system
|
||
|
|
if (!is_readable($strFileName)) {
|
||
|
|
$this->strErrorMessage .= translate('Cannot open the data file (check the permissions)!'). ' ' .
|
||
|
|
$strFileName. '::';
|
||
|
|
$intReturn = 1;
|
||
|
|
} else {
|
||
|
|
$strImportFileTmp = $strFileName;
|
||
|
|
}
|
||
|
|
} elseif ($intMethod == 2) { // FTP access
|
||
|
|
// Open ftp connection
|
||
|
|
$intRetVal = $this->myConfigClass->getFTPConnection($intConfigId);
|
||
|
|
if ($intRetVal != 0) {
|
||
|
|
$this->strErrorMessage .= $this->myConfigClass->strErrorMessage;
|
||
|
|
$intReturn = 1;
|
||
|
|
} else {
|
||
|
|
// Transfer file from remote server to a local temp file
|
||
|
|
if (isset($this->arrSettings['path']) && isset($this->arrSettings['path']['tempdir'])) {
|
||
|
|
$strConfigFile = tempnam($this->arrSettings['path']['tempdir'], 'nagiosql_imp');
|
||
|
|
} else {
|
||
|
|
$strConfigFile = tempnam(sys_get_temp_dir(), 'nagiosql_imp');
|
||
|
|
}
|
||
|
|
if (!ftp_get($this->myConfigClass->resConnectId, $strConfigFile, $strFileName, FTP_ASCII)) {
|
||
|
|
$this->strErrorMessage .= translate('Cannot receive the configuration file (FTP connection)!').
|
||
|
|
'::';
|
||
|
|
ftp_close($this->myConfigClass->resConnectId);
|
||
|
|
$intReturn = 1;
|
||
|
|
} else {
|
||
|
|
$intRemoveTmp = 1;
|
||
|
|
$strImportFileTmp = $strConfigFile;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
} elseif ($intMethod == 3) { // SSH Access
|
||
|
|
// Open ssh connection
|
||
|
|
$intRetVal = $this->myConfigClass->getSSHConnection($intConfigId);
|
||
|
|
if ($intRetVal != 0) {
|
||
|
|
$this->strErrorMessage .= $this->myConfigClass->strErrorMessage;
|
||
|
|
$intReturn = 1;
|
||
|
|
} else {
|
||
|
|
// Transfer file from remote server to a local temp file
|
||
|
|
if (isset($this->arrSettings['path']) && isset($this->arrSettings['path']['tempdir'])) {
|
||
|
|
$strConfigFile = tempnam($this->arrSettings['path']['tempdir'], 'nagiosql_imp');
|
||
|
|
} else {
|
||
|
|
$strConfigFile = tempnam(sys_get_temp_dir(), 'nagiosql_imp');
|
||
|
|
}
|
||
|
|
if (!ssh2_scp_recv($this->myConfigClass->resConnectId, $strFileName, $strConfigFile)) {
|
||
|
|
$this->strErrorMessage .= translate('Cannot receive the configuration file (SSH connection)!').
|
||
|
|
'::';
|
||
|
|
$intReturn = 1;
|
||
|
|
} else {
|
||
|
|
$intRemoveTmp = 1;
|
||
|
|
$strImportFileTmp = $strConfigFile;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
// Open and read config file
|
||
|
|
if (file_exists($strImportFileTmp) && is_readable($strImportFileTmp)) {
|
||
|
|
$strImportFile = $strImportFileTmp;
|
||
|
|
} else {
|
||
|
|
$intReturn = 1;
|
||
|
|
$intRemoveTmp = 0;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
return $intReturn;
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Writes the block data to the database
|
||
|
|
* @param string $strBlockKey Config key (from define)
|
||
|
|
* @param array $arrImportData Imported block data
|
||
|
|
* @param int $intOverwrite 0 = Do not replace existing data
|
||
|
|
* 1 = Replace existing data in tables
|
||
|
|
* @return int 0 = successful / 1 = error
|
||
|
|
* Status messages are stored in class variables
|
||
|
|
*/
|
||
|
|
private function importTable($strBlockKey, $arrImportData, $intOverwrite)
|
||
|
|
{
|
||
|
|
// Define variables
|
||
|
|
$intIsTemplate = 0;
|
||
|
|
$intExists = 0;
|
||
|
|
$intInsertRelations = 0;
|
||
|
|
$intInsertVariables = 0;
|
||
|
|
$strHash = '';
|
||
|
|
$strConfigName = '';
|
||
|
|
$arrImportRelations = array();
|
||
|
|
$arrFreeVariables = array();
|
||
|
|
$arrRelations = array();
|
||
|
|
// Block data from template or real configuration?
|
||
|
|
if (array_key_exists('name', $arrImportData) && (isset($arrImportData['register']) &&
|
||
|
|
($arrImportData['register']['value'] == 0))) {
|
||
|
|
$intIsTemplate = 1;
|
||
|
|
}
|
||
|
|
// Get table name and key for import
|
||
|
|
$intReturn = $this->getTableData($strBlockKey, $intIsTemplate, $strTable, $strKeyField);
|
||
|
|
if ($intReturn == 0) {
|
||
|
|
// Create an import hash if no key field is available
|
||
|
|
if ($strKeyField == '') {
|
||
|
|
$this->createHash($strTable, $arrImportData, $strHash, $strConfigName);
|
||
|
|
$arrImportData['config_name']['key'] = 'config_name';
|
||
|
|
$arrImportData['config_name']['value'] = $strConfigName;
|
||
|
|
$strKeyField = 'config_name';
|
||
|
|
} else {
|
||
|
|
$strHash = '';
|
||
|
|
}
|
||
|
|
// Get relation data
|
||
|
|
$intRelation = $this->myDataClass->tableRelations($strTable, $arrRelations);
|
||
|
|
// Does this entry already exist?
|
||
|
|
if (($intIsTemplate == 0) && ($strKeyField != '') && isset($arrImportData[$strKeyField])) {
|
||
|
|
if ($strHash == '') {
|
||
|
|
// Special key field values
|
||
|
|
if ($strBlockKey == 'hostextinfo') {
|
||
|
|
$strSQL = 'SELECT `id`FROM `tbl_host` ' .
|
||
|
|
"WHERE `host_name`='".$arrImportData[$strKeyField]['value']."'";
|
||
|
|
$intHost = (int)$this->myDBClass->getFieldData($strSQL);
|
||
|
|
$strSQL = 'SELECT `id` FROM `' .$strTable. '` ' .
|
||
|
|
'WHERE `config_id`=' .$this->intDomainId. ' AND `' .$strKeyField."`='".$intHost."'";
|
||
|
|
} else {
|
||
|
|
$strSQL = 'SELECT `id` FROM `' .$strTable. '` ' .
|
||
|
|
'WHERE `config_id`=' .$this->intDomainId. ' AND ' .
|
||
|
|
'`' .$strKeyField."`='".$arrImportData[$strKeyField]['value']."'";
|
||
|
|
}
|
||
|
|
} else {
|
||
|
|
$strSQL = 'SELECT `id` FROM `' .$strTable. '` ' .
|
||
|
|
'WHERE `config_id`=' .$this->intDomainId." AND `import_hash`='".$strHash."'";
|
||
|
|
}
|
||
|
|
$intExists = $this->myDBClass->getFieldData($strSQL);
|
||
|
|
if ($intExists == false) {
|
||
|
|
$intExists = 0;
|
||
|
|
}
|
||
|
|
} elseif (($intIsTemplate == 1) && ($strKeyField != '') && isset($arrImportData['name'])) {
|
||
|
|
$strSQL = 'SELECT `id` FROM `' .$strTable. '` ' .
|
||
|
|
'WHERE `config_id`=' .$this->intDomainId. ' AND ' .
|
||
|
|
"`template_name`='".$arrImportData['name']['value']."'";
|
||
|
|
$intExists = $this->myDBClass->getFieldData($strSQL);
|
||
|
|
if ($intExists == false) {
|
||
|
|
$intExists = 0;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
// Entry exsists but should not be overwritten
|
||
|
|
if (($intExists != 0) && ($intOverwrite == 0)) {
|
||
|
|
if ($strKeyField == 'config_name') {
|
||
|
|
$strSQLConfig = 'SELECT `config_name` FROM `' .$strTable. '` WHERE `id`=' .$intExists;
|
||
|
|
$arrImportData[$strKeyField]['value'] = $this->myDBClass->getFieldData($strSQLConfig);
|
||
|
|
}
|
||
|
|
$this->strInfoMessage .= translate('Entry'). ' <b class="blackmessage">' .$strKeyField. ' -> ' .
|
||
|
|
$arrImportData[$strKeyField]['value']. '</b> ' .translate('inside'). ' <b class="blackmessage">' .
|
||
|
|
$strTable. '</b> ' .translate('exists and were not overwritten'). '::';
|
||
|
|
} elseif (isset($arrImportData[$strKeyField]) && ($arrImportData[$strKeyField] == '*')) {
|
||
|
|
// Do not write "*" values
|
||
|
|
$this->strInfoMessage .= translate('Entry'). ' <b class="blackmessage">' .$strKeyField. ' -> ' .
|
||
|
|
$arrImportData[$strKeyField]['value']. '</b> ' .translate('inside'). ' <b class="blackmessage">' .
|
||
|
|
$strTable. '</b> ' .translate('were not written'). '::';
|
||
|
|
} else {
|
||
|
|
// Define SQL statement - part 1
|
||
|
|
$this->getSQLPart1(
|
||
|
|
$arrImportData,
|
||
|
|
$strHash,
|
||
|
|
$intExists,
|
||
|
|
$strTable,
|
||
|
|
$strKeyField,
|
||
|
|
$intRelation,
|
||
|
|
$arrRelations,
|
||
|
|
$strSQL1,
|
||
|
|
$strSQL2
|
||
|
|
);
|
||
|
|
// Read command configurations
|
||
|
|
list($strVCValues, $intWriteConfig, $strVIValues, $strRLValues, $strVWValues) =
|
||
|
|
$this->getImportValues($arrImportData, $strKeyField, $strSQL1, $strTable);
|
||
|
|
|
||
|
|
|
||
|
|
// Build value statemets
|
||
|
|
foreach ($arrImportData as $elem) {
|
||
|
|
// Write text values
|
||
|
|
$intCheckVC = $this->writeTextValues(
|
||
|
|
$elem,
|
||
|
|
$strVCValues,
|
||
|
|
$strSQL1,
|
||
|
|
$intIsTemplate,
|
||
|
|
$intExists,
|
||
|
|
$strTable
|
||
|
|
);
|
||
|
|
// Write status values
|
||
|
|
$intCheckVI = $this->writeStatusValues($elem, $strVIValues, $strSQL1);
|
||
|
|
// Write integer values
|
||
|
|
$intCheckVW = $this->writeIntegerValues($elem, $strVWValues, $strSQL1);
|
||
|
|
// Write relations
|
||
|
|
$intCheckRel = $this->writeRelations($elem, $strRLValues, $arrImportRelations, $intInsertRelations);
|
||
|
|
// Write free variables
|
||
|
|
$intCheck = $intCheckVC+$intCheckVI+$intCheckVW+$intCheckRel;
|
||
|
|
if ($intCheck == 0) {
|
||
|
|
$arrTemp = array();
|
||
|
|
$arrTemp['key'] = $elem['key'];
|
||
|
|
$arrTemp['value'] = $elem['value'];
|
||
|
|
$arrFreeVariables[] = $arrTemp;
|
||
|
|
$intInsertVariables = 1;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
$strTemp1 = '';
|
||
|
|
$strTemp2 = '';
|
||
|
|
// Update database
|
||
|
|
if ($intWriteConfig == 1) {
|
||
|
|
$booResult = $this->myDBClass->insertData($strSQL1.$strSQL2);
|
||
|
|
} else {
|
||
|
|
$booResult = false;
|
||
|
|
}
|
||
|
|
if ($strKeyField == '') {
|
||
|
|
$strKey = $strConfigName;
|
||
|
|
} else {
|
||
|
|
$strKey = $strKeyField;
|
||
|
|
}
|
||
|
|
if ($booResult != true) {
|
||
|
|
$this->strErrorMessage .= $this->myDBClass->strErrorMessage;
|
||
|
|
if ($strKeyField != '') {
|
||
|
|
$this->strErrorMessage .= translate('Entry'). ' <b class="blackmessage">' .$strKey. ' -> ' .
|
||
|
|
$arrImportData[$strKeyField]['value']. '</b> ' .translate('inside').
|
||
|
|
' <b class="blackmessage">' .$strTable. '</b> ' .translate('could not be inserted:'). ' ' .
|
||
|
|
$this->myDBClass->strErrorMessage. '::';
|
||
|
|
}
|
||
|
|
if ($strKeyField == '') {
|
||
|
|
$this->strErrorMessage .= translate('Entry'). ' <b class="blackmessage">' .$strTemp1. ' -> ' .
|
||
|
|
$strTemp2.translate('inside'). '</b> ' .$strTable. ' <b class="blackmessage">' .$strTable.
|
||
|
|
'</b> ' .translate('could not be inserted:'). ' ' .$this->myDBClass->strErrorMessage. '::';
|
||
|
|
}
|
||
|
|
return 1;
|
||
|
|
}
|
||
|
|
if ($strKeyField != '') {
|
||
|
|
$this->strInfoMessage .= translate('Entry'). ' <b class="blackmessage">' .$strKey. ' -> ' .
|
||
|
|
$arrImportData[$strKeyField]['value']. '</b> ' .translate('inside').
|
||
|
|
' <b class="blackmessage">' .$strTable. '</b> ' .translate('successfully inserted'). '::';
|
||
|
|
}
|
||
|
|
if ($strKeyField == '') {
|
||
|
|
$this->strInfoMessage .= translate('Entry'). ' <b class="blackmessage">' .$strTemp1. ' -> ' .
|
||
|
|
$strTemp2. '</b> ' .translate('inside'). ' <b class="blackmessage">' .$strTable.
|
||
|
|
'</b> ' .translate('successfully inserted'). '::';
|
||
|
|
}
|
||
|
|
// Define data ID
|
||
|
|
if ($intExists != 0) {
|
||
|
|
$intDataId = $intExists;
|
||
|
|
} else {
|
||
|
|
$intDataId = $this->myDBClass->intLastId;
|
||
|
|
}
|
||
|
|
// Are there any relations to be filled in?
|
||
|
|
if ($intInsertRelations == 1) {
|
||
|
|
foreach ($arrImportRelations as $elem) {
|
||
|
|
foreach ($arrRelations as $reldata) {
|
||
|
|
if ($reldata['fieldName'] == $elem['key']) {
|
||
|
|
$strValue = $elem['value'];
|
||
|
|
$strKey = $elem['key'];
|
||
|
|
if ($elem['key'] == 'check_command') {
|
||
|
|
$this->writeRelation5($strValue, $intDataId, $strTable, $reldata);
|
||
|
|
} elseif ($reldata['type'] == 1) {
|
||
|
|
$this->writeRelation1(
|
||
|
|
$strKey,
|
||
|
|
$strValue,
|
||
|
|
$intDataId,
|
||
|
|
$strTable,
|
||
|
|
$reldata,
|
||
|
|
$arrImportData
|
||
|
|
);
|
||
|
|
} elseif ($reldata['type'] == 2) {
|
||
|
|
$this->writeRelation2($strKey, $strValue, $intDataId, $strTable, $reldata);
|
||
|
|
} elseif ($reldata['type'] == 3) {
|
||
|
|
$this->writeRelation3($strValue, $intDataId, $strTable, $reldata);
|
||
|
|
} elseif ($reldata['type'] == 4) {
|
||
|
|
$this->writeRelation4($strKey, $strValue, $intDataId, $strTable, $reldata);
|
||
|
|
} elseif ($reldata['type'] == 5) {
|
||
|
|
$this->writeRelation6($strValue, $intDataId, $strTable, $reldata);
|
||
|
|
} elseif ($reldata['type'] == 6) {
|
||
|
|
$this->writeRelation7($strValue, $intDataId, $strTable, $reldata);
|
||
|
|
} elseif ($reldata['type'] == 7) {
|
||
|
|
$this->writeRelation8($strValue, $intDataId, $strTable, $reldata);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
// Are there any free variables ore time definitions to be filled in?
|
||
|
|
if ($intInsertVariables == 1) {
|
||
|
|
if ($strTable == 'tbl_timeperiod') {
|
||
|
|
// Remove old values
|
||
|
|
$strSQL = "DELETE FROM `tbl_timedefinition` WHERE `tipId` = $intDataId";
|
||
|
|
$booResult = $this->myDBClass->insertData($strSQL);
|
||
|
|
if ($booResult == false) {
|
||
|
|
$this->strErrorMessage .= $this->myDBClass->strErrorMessage;
|
||
|
|
}
|
||
|
|
foreach ($arrFreeVariables as $elem) {
|
||
|
|
$strSQL = "INSERT INTO `tbl_timedefinition` SET `tipId` = $intDataId, ".
|
||
|
|
"`definition` = '".addslashes($elem['key'])."', ".
|
||
|
|
"`range` = '".addslashes($elem['value'])."'";
|
||
|
|
$booResult = $this->myDBClass->insertData($strSQL);
|
||
|
|
if ($booResult == false) {
|
||
|
|
$this->strErrorMessage .= $this->myDBClass->strErrorMessage;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
} else {
|
||
|
|
foreach ($arrFreeVariables as $elem) {
|
||
|
|
foreach ($arrRelations as $reldata) {
|
||
|
|
if ($reldata['type'] == 4) {
|
||
|
|
$this->writeRelation4(
|
||
|
|
$elem['key'],
|
||
|
|
$elem['value'],
|
||
|
|
$intDataId,
|
||
|
|
$strTable,
|
||
|
|
$reldata
|
||
|
|
);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
// Update Table times
|
||
|
|
$this->myDataClass->updateStatusTable($strTable);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
return $intReturn;
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Get table name and key for import
|
||
|
|
* @param string $strBlockKey Block data key
|
||
|
|
* @param int $intIsTemplate Template data 1 = yes / 0 - no
|
||
|
|
* @param string $strTable Template name
|
||
|
|
* @param string $strKeyField Table key name
|
||
|
|
* @return int 0 = successful / 1 = error
|
||
|
|
*/
|
||
|
|
private function getTableData($strBlockKey, $intIsTemplate, &$strTable, &$strKeyField)
|
||
|
|
{
|
||
|
|
// Define variables
|
||
|
|
$intReturn = 0;
|
||
|
|
$arrTableData['command'] = array('tbl_command', 'command_name');
|
||
|
|
$arrTableData['contactgroup'] = array('tbl_contactgroup', 'contactgroup_name');
|
||
|
|
$arrTableData['contact'] = array('tbl_contact', 'contact_name');
|
||
|
|
$arrTableData['timeperiod'] = array('tbl_timeperiod', 'timeperiod_name');
|
||
|
|
$arrTableData['host'] = array('tbl_host', 'host_name');
|
||
|
|
$arrTableData['service'] = array('tbl_service', '');
|
||
|
|
$arrTableData['hostgroup'] = array('tbl_hostgroup', 'hostgroup_name');
|
||
|
|
$arrTableData['servicegroup'] = array('tbl_servicegroup', 'servicegroup_name');
|
||
|
|
$arrTableData['hostescalation'] = array('tbl_hostescalation', '');
|
||
|
|
$arrTableData['serviceescalation'] = array('tbl_serviceescalation', '');
|
||
|
|
$arrTableData['hostdependency'] = array('tbl_hostdependency', '');
|
||
|
|
$arrTableData['servicedependency'] = array('tbl_servicedependency', '');
|
||
|
|
$arrTableData['hostextinfo'] = array('tbl_hostextinfo', 'host_name');
|
||
|
|
$arrTableData['serviceextinfo'] = array('tbl_serviceextinfo', '');
|
||
|
|
$arrTableData['contactgroup'] = array('tbl_contactgroup', 'contactgroup_name');
|
||
|
|
$arrTableDataTpl['contact'] = array('tbl_contacttemplate', 'name');
|
||
|
|
$arrTableDataTpl['host'] = array('tbl_hosttemplate', 'name');
|
||
|
|
$arrTableDataTpl['service'] = array('tbl_servicetemplate', 'name');
|
||
|
|
|
||
|
|
// Define table name and key
|
||
|
|
if (($intIsTemplate == 0) && isset($arrTableData[$strBlockKey])) {
|
||
|
|
$strTable = $arrTableData[$strBlockKey][0];
|
||
|
|
/** @noinspection MultiAssignmentUsageInspection */
|
||
|
|
$strKeyField = $arrTableData[$strBlockKey][1];
|
||
|
|
} elseif (($intIsTemplate == 1) && isset($arrTableDataTpl[$strBlockKey])) {
|
||
|
|
$strTable = $arrTableDataTpl[$strBlockKey][0];
|
||
|
|
/** @noinspection MultiAssignmentUsageInspection */
|
||
|
|
$strKeyField = $arrTableDataTpl[$strBlockKey][1];
|
||
|
|
} else {
|
||
|
|
$this->strErrorMessage .= translate('Table for import definition').$strBlockKey.
|
||
|
|
translate('is not available!') . '::';
|
||
|
|
$intReturn = 1;
|
||
|
|
}
|
||
|
|
return $intReturn;
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Create a unique data hash from table data
|
||
|
|
* @param $strTable
|
||
|
|
* @param $arrBlockData
|
||
|
|
* @param $strHash
|
||
|
|
* @param $strConfigName
|
||
|
|
*/
|
||
|
|
public function createHash($strTable, $arrBlockData, &$strHash, &$strConfigName)
|
||
|
|
{
|
||
|
|
$strRawString = '';
|
||
|
|
$strConfigName = 'imp_temporary';
|
||
|
|
if ($strTable == 'tbl_service') {
|
||
|
|
// HASH from any host, any hostgroup and service description - step 1
|
||
|
|
if (isset($arrBlockData['host_name'])) {
|
||
|
|
$strRawString .= $arrBlockData['host_name']['value']. ',';
|
||
|
|
}
|
||
|
|
if (isset($arrBlockData['hostgroup_name'])) {
|
||
|
|
$strRawString .= $arrBlockData['hostgroup_name']['value']. ',';
|
||
|
|
}
|
||
|
|
// Replace *, + and ! in HASH raw string
|
||
|
|
$strRawString = str_replace(array('*,', '!', '+'), array('any,', 'not_', ''), $strRawString);
|
||
|
|
// Create configuration name from NagiosQL variable if exists
|
||
|
|
if (isset($arrBlockData['_NAGIOSQL_CONFIG_NAME'])) {
|
||
|
|
$strConfigName = $arrBlockData['_NAGIOSQL_CONFIG_NAME']['value'];
|
||
|
|
} else {
|
||
|
|
// Create configuration name from first two hosts / hostgroups
|
||
|
|
$arrConfig = explode(',', $strRawString);
|
||
|
|
if (isset($arrConfig[0]) && ($arrConfig[0] != '')) {
|
||
|
|
$strConfigName = 'imp_' .$arrConfig[0];
|
||
|
|
}
|
||
|
|
if (isset($arrConfig[1]) && ($arrConfig[1] != '')) {
|
||
|
|
$strConfigName .= '_' .$arrConfig[1];
|
||
|
|
}
|
||
|
|
}
|
||
|
|
// HASH from any host, any hostgroup and service description - step 2
|
||
|
|
if (isset($arrBlockData['service_description'])) {
|
||
|
|
$strRawString .= $arrBlockData['service_description']['value']. ',';
|
||
|
|
}
|
||
|
|
if (isset($arrBlockData['display_name'])) {
|
||
|
|
$strRawString .= $arrBlockData['display_name']['value']. ',';
|
||
|
|
}
|
||
|
|
if (isset($arrBlockData['check_command'])) {
|
||
|
|
$strRawString .= $arrBlockData['check_command']['value']. ',';
|
||
|
|
}
|
||
|
|
}
|
||
|
|
if (($strTable == 'tbl_hostdependency') || ($strTable == 'tbl_servicedependency')) {
|
||
|
|
$strRawString1 = '';
|
||
|
|
$strRawString2 = '';
|
||
|
|
$strRawString3 = '';
|
||
|
|
// HASH from any dependent host and any dependent hostgroup
|
||
|
|
if (isset($arrBlockData['dependent_host_name'])) {
|
||
|
|
$strRawString1 .= $arrBlockData['dependent_host_name']['value']. ',';
|
||
|
|
}
|
||
|
|
if (isset($arrBlockData['dependent_hostgroup_name'])) {
|
||
|
|
$strRawString1 .= $arrBlockData['dependent_hostgroup_name']['value']. ',';
|
||
|
|
}
|
||
|
|
if (isset($arrBlockData['host_name'])) {
|
||
|
|
$strRawString2 .= $arrBlockData['host_name']['value']. ',';
|
||
|
|
}
|
||
|
|
if (isset($arrBlockData['hostgroup_name'])) {
|
||
|
|
$strRawString2 .= $arrBlockData['hostgroup_name']['value']. ',';
|
||
|
|
}
|
||
|
|
if (isset($arrBlockData['dependent_service_description'])) {
|
||
|
|
$strRawString3 .= $arrBlockData['dependent_service_description']['value']. ',';
|
||
|
|
}
|
||
|
|
if (isset($arrBlockData['service_description'])) {
|
||
|
|
$strRawString3 .= $arrBlockData['service_description']['value']. ',';
|
||
|
|
}
|
||
|
|
if (isset($arrBlockData['dependent_servicegroup_name'])) {
|
||
|
|
$strRawString3 .= $arrBlockData['dependent_servicegroup_name']['value']. ',';
|
||
|
|
}
|
||
|
|
if (isset($arrBlockData['servicegroup_name'])) {
|
||
|
|
$strRawString3 .= $arrBlockData['servicegroup_name']['value']. ',';
|
||
|
|
}
|
||
|
|
// Replace *, + and ! in HASH raw string
|
||
|
|
$strRawString1 = str_replace('*,', 'any,', $strRawString1);
|
||
|
|
$strRawString2 = str_replace('*,', 'any,', $strRawString2);
|
||
|
|
$strRawString3 = str_replace('*,', 'any,', $strRawString3);
|
||
|
|
$strRawString1 = str_replace('!', 'not_', $strRawString1);
|
||
|
|
$strRawString2 = str_replace('!', 'not_', $strRawString2);
|
||
|
|
$strRawString3 = str_replace('!', 'not_', $strRawString3);
|
||
|
|
// Create configuration name from NagiosQL variable if exists
|
||
|
|
if (isset($arrBlockData['_NAGIOSQL_CONFIG_NAME'])) {
|
||
|
|
$strConfigName = $arrBlockData['_NAGIOSQL_CONFIG_NAME']['value'];
|
||
|
|
} else {
|
||
|
|
$arrConfig1 = explode(',', $strRawString1);
|
||
|
|
$arrConfig2 = explode(',', $strRawString2);
|
||
|
|
$arrConfig3 = explode(',', $strRawString3);
|
||
|
|
if (isset($arrConfig1[0])) {
|
||
|
|
$strConfigName = 'imp_' .$arrConfig1[0];
|
||
|
|
}
|
||
|
|
if (isset($arrConfig2[0])) {
|
||
|
|
$strConfigName .= '_' .$arrConfig2[0];
|
||
|
|
}
|
||
|
|
if (isset($arrConfig3[0])) {
|
||
|
|
$strConfigName .= '_' .$arrConfig3[0];
|
||
|
|
}
|
||
|
|
$strSQL = 'SELECT * FROM `' .$strTable."` WHERE `config_name`='$strConfigName'";
|
||
|
|
$booRet = $this->myDBClass->hasDataArray($strSQL, $arrData, $intDC);
|
||
|
|
if ($booRet && ($intDC != 0)) {
|
||
|
|
$intCounter = 1;
|
||
|
|
do {
|
||
|
|
$strConfigNameTemp = $strConfigName. '_' .$intCounter;
|
||
|
|
$strSQL = 'SELECT * FROM `' .$strTable."` WHERE `config_name`='$strConfigNameTemp'";
|
||
|
|
$booRet = $this->myDBClass->hasDataArray($strSQL, $arrData, $intDC);
|
||
|
|
$intCounter++;
|
||
|
|
} while ($booRet && ($intDC != 0));
|
||
|
|
$strConfigName = $strConfigNameTemp;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
// HASH string
|
||
|
|
$strRawString = $strRawString1.$strRawString2.$strRawString3;
|
||
|
|
$strRawString = substr($strRawString, 0, -1);
|
||
|
|
}
|
||
|
|
if (($strTable == 'tbl_hostescalation') || ($strTable == 'tbl_serviceescalation')) {
|
||
|
|
$strRawString1 = '';
|
||
|
|
$strRawString2 = '';
|
||
|
|
$strRawString3 = '';
|
||
|
|
// HASH from any host and any hostgroup
|
||
|
|
if (isset($arrBlockData['host_name'])) {
|
||
|
|
$strRawString1 .= $arrBlockData['host_name']['value']. ',';
|
||
|
|
}
|
||
|
|
if (isset($arrBlockData['hostgroup_name'])) {
|
||
|
|
$strRawString1 .= $arrBlockData['hostgroup_name']['value']. ',';
|
||
|
|
}
|
||
|
|
if (isset($arrBlockData['contacts'])) {
|
||
|
|
$strRawString2 .= $arrBlockData['contacts']['value']. ',';
|
||
|
|
}
|
||
|
|
if (isset($arrBlockData['contact_groups'])) {
|
||
|
|
$strRawString2 .= $arrBlockData['contact_groups']['value']. ',';
|
||
|
|
}
|
||
|
|
if (isset($arrBlockData['service_description'])) {
|
||
|
|
$strRawString3 .= $arrBlockData['service_description']['value']. ',';
|
||
|
|
}
|
||
|
|
// Replace *, + and ! in HASH raw string
|
||
|
|
$strRawString1 = str_replace('*,', 'any,', $strRawString1);
|
||
|
|
$strRawString2 = str_replace('*,', 'any,', $strRawString2);
|
||
|
|
$strRawString3 = str_replace('*,', 'any,', $strRawString3);
|
||
|
|
$strRawString1 = str_replace('!', 'not_', $strRawString1);
|
||
|
|
$strRawString2 = str_replace('!', 'not_', $strRawString2);
|
||
|
|
$strRawString3 = str_replace('!', 'not_', $strRawString3);
|
||
|
|
// Create configuration name from NagiosQL variable if exists
|
||
|
|
if (isset($arrBlockData['_NAGIOSQL_CONFIG_NAME'])) {
|
||
|
|
$strConfigName = $arrBlockData['_NAGIOSQL_CONFIG_NAME']['value'];
|
||
|
|
} else {
|
||
|
|
$arrConfig1 = explode(',', $strRawString1);
|
||
|
|
$arrConfig2 = explode(',', $strRawString2);
|
||
|
|
$arrConfig3 = explode(',', $strRawString3);
|
||
|
|
if (isset($arrConfig1[0])) {
|
||
|
|
$strConfigName = 'imp_' .$arrConfig1[0];
|
||
|
|
}
|
||
|
|
if (isset($arrConfig2[0])) {
|
||
|
|
$strConfigName .= '_' .$arrConfig2[0];
|
||
|
|
}
|
||
|
|
if (isset($arrConfig3[0])) {
|
||
|
|
$strConfigName .= '_' .$arrConfig3[0];
|
||
|
|
}
|
||
|
|
$strSQL = 'SELECT * FROM `' .$strTable."` WHERE `config_name`='$strConfigName'";
|
||
|
|
$booRet = $this->myDBClass->hasDataArray($strSQL, $arrData, $intDC);
|
||
|
|
if ($booRet && ($intDC != 0)) {
|
||
|
|
$intCounter = 1;
|
||
|
|
do {
|
||
|
|
$strConfigNameTemp = $strConfigName. '_' .$intCounter;
|
||
|
|
$strSQL = 'SELECT * FROM `' .$strTable."` WHERE `config_name`='$strConfigNameTemp'";
|
||
|
|
$booRet = $this->myDBClass->hasDataArray($strSQL, $arrData, $intDC);
|
||
|
|
$intCounter++;
|
||
|
|
} while ($booRet && ($intDC != 0));
|
||
|
|
$strConfigName = $strConfigNameTemp;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
// HASH string
|
||
|
|
$strRawString = $strRawString1.$strRawString2.$strRawString3;
|
||
|
|
$strRawString = substr($strRawString, 0, -1);
|
||
|
|
}
|
||
|
|
if ($strTable == 'tbl_serviceextinfo') {
|
||
|
|
// HASH from any host, any hostgroup and service description - step 1
|
||
|
|
if (isset($arrBlockData['host_name'])) {
|
||
|
|
$strRawString .= $arrBlockData['host_name']['value']. ',';
|
||
|
|
}
|
||
|
|
if (isset($arrBlockData['service_description'])) {
|
||
|
|
$strRawString .= $arrBlockData['service_description']['value']. ',';
|
||
|
|
}
|
||
|
|
// HASH string
|
||
|
|
$strRawString = substr($strRawString, 0, -1);
|
||
|
|
// Create configuration name from NagiosQL variable if exists
|
||
|
|
if (isset($arrBlockData['_NAGIOSQL_CONFIG_NAME'])) {
|
||
|
|
$strConfigName = $arrBlockData['_NAGIOSQL_CONFIG_NAME']['value'];
|
||
|
|
} else {
|
||
|
|
// Create configuration name from first two items
|
||
|
|
$arrConfig = explode(',', $strRawString);
|
||
|
|
if (isset($arrConfig[0]) && ($arrConfig[0] != '')) {
|
||
|
|
$strConfigName = 'imp_' .$arrConfig[0];
|
||
|
|
}
|
||
|
|
if (isset($arrConfig[1]) && ($arrConfig[1] != '')) {
|
||
|
|
$strConfigName .= '_' .$arrConfig[1];
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
while (substr_count($strRawString, ' ') != 0) {
|
||
|
|
$strRawString = str_replace(' ', '', $strRawString);
|
||
|
|
}
|
||
|
|
// Sort hash string
|
||
|
|
$arrTemp = explode(',', $strRawString);
|
||
|
|
sort($arrTemp);
|
||
|
|
$strRawString = implode(',', $arrTemp);
|
||
|
|
$strHash = sha1($strRawString);
|
||
|
|
//echo "Hash: ".$strRawString." --> ".$strHash."<br>";
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* @param array $arrImportData Imported block data
|
||
|
|
* @param string $strHash Unique data hash
|
||
|
|
* @param int $intExists Does the dataset already exist?
|
||
|
|
* @param string $strTable Table name
|
||
|
|
* @param string $strKeyField Table key file
|
||
|
|
* @param int $intRelation Relation type
|
||
|
|
* @param array $arrRelations Relation array
|
||
|
|
* @param string $strSQL1 SQL statement part 1
|
||
|
|
* @param string $strSQL2 SQL statement part 2
|
||
|
|
*/
|
||
|
|
private function getSQLPart1(
|
||
|
|
$arrImportData,
|
||
|
|
$strHash,
|
||
|
|
$intExists,
|
||
|
|
$strTable,
|
||
|
|
$strKeyField,
|
||
|
|
$intRelation,
|
||
|
|
$arrRelations,
|
||
|
|
&$strSQL1,
|
||
|
|
&$strSQL2
|
||
|
|
) {
|
||
|
|
// Define variables
|
||
|
|
$intActive = 1;
|
||
|
|
$arrData = array();
|
||
|
|
$intDataCount = 0;
|
||
|
|
|
||
|
|
if ($strHash != '') {
|
||
|
|
$strHash = " `import_hash`='" . $strHash . "', ";
|
||
|
|
}
|
||
|
|
if ($intExists != 0) {
|
||
|
|
// Update database
|
||
|
|
$strSQL1 = 'UPDATE `' .$strTable. '` SET ';
|
||
|
|
$strSQL2 = ' `config_id`=' .$this->intDomainId.", $strHash `active`='$intActive', ".
|
||
|
|
"`last_modified`=NOW() WHERE `id`=$intExists";
|
||
|
|
// Keep config name while update
|
||
|
|
if (($strKeyField == 'config_name') && !isset($arrImportData['_NAGIOSQL_CONFIG_NAME'])) {
|
||
|
|
$strSQLConfig = 'SELECT `config_name` FROM `' .$strTable. '` WHERE `id`=' . $intExists;
|
||
|
|
$arrImportData['config_name']['value'] = $this->myDBClass->getFieldData($strSQLConfig);
|
||
|
|
}
|
||
|
|
// Remove free variables
|
||
|
|
if ($intRelation != 0) {
|
||
|
|
foreach ($arrRelations as $relVar) {
|
||
|
|
if ($relVar['type'] == 4) {
|
||
|
|
$strSQL = 'SELECT * FROM `' .$relVar['linkTable']."` WHERE `idMaster`=$intExists";
|
||
|
|
$booReturn = $this->myDBClass->hasDataArray($strSQL, $arrData, $intDataCount);
|
||
|
|
if ($booReturn && ($intDataCount != 0)) {
|
||
|
|
foreach ($arrData as $elem) {
|
||
|
|
$strSQL = 'DELETE FROM `tbl_variabledefinition` WHERE `id`=' .$elem['idSlave'];
|
||
|
|
$this->myDataClass->dataInsert($strSQL, $intInsertId);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
$strSQL = 'DELETE FROM `' .$relVar['linkTable']."` WHERE `idMaster`=$intExists";
|
||
|
|
$this->myDataClass->dataInsert($strSQL, $intInsertId);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
} else {
|
||
|
|
// DB Eintrag einfügen
|
||
|
|
$test='';
|
||
|
|
$strSQL1 = 'INSERT INTO `' .$strTable."` SET $test";
|
||
|
|
$strSQL2 = ' `config_id`=' .$this->intDomainId.", $strHash `active`='$intActive', `last_modified`=NOW()";
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* @param array $arrImportData Imported block data
|
||
|
|
* @param string $strKeyField Table key file
|
||
|
|
* @param string $strSQL1 SQL statement part 1
|
||
|
|
* @param string $strTable Table name
|
||
|
|
* @return array List of import values
|
||
|
|
*/
|
||
|
|
private function getImportValues($arrImportData, $strKeyField, &$strSQL1, $strTable)
|
||
|
|
{
|
||
|
|
// Description for the values
|
||
|
|
// --------------------------
|
||
|
|
// $strVCValues = Simple text values, will be stored as varchar / null = 'null' as text value / empty = ''
|
||
|
|
// $strRLValues = Relations - values with relations to other tables
|
||
|
|
// $strVWValues = Integer values - will be stored as INT values / null = -1, / empty values as NULL
|
||
|
|
// $strVIValues = Decision values 0 = no, 1 = yes, 2 = skip, 3 = null
|
||
|
|
|
||
|
|
// Define variables
|
||
|
|
$strVCValues = '';
|
||
|
|
$strVIValues = '';
|
||
|
|
$strRLValues = '';
|
||
|
|
$strVWValues = '';
|
||
|
|
$intWriteConfig = 0;
|
||
|
|
|
||
|
|
// Read command configurations
|
||
|
|
if ($strKeyField == 'command_name') {
|
||
|
|
$strVCValues = 'command_name,command_line';
|
||
|
|
// Find out command type
|
||
|
|
if (isset($arrImportData['command_line'])) {
|
||
|
|
if ((substr_count($arrImportData['command_line']['value'], 'ARG1') != 0) ||
|
||
|
|
(substr_count($arrImportData['command_line']['value'], 'USER1') != 0)) {
|
||
|
|
$strSQL1 .= '`command_type` = 1,';
|
||
|
|
} else {
|
||
|
|
$strSQL1 .= '`command_type` = 2,';
|
||
|
|
}
|
||
|
|
}
|
||
|
|
$intWriteConfig = 1;
|
||
|
|
|
||
|
|
// Read contact configurations
|
||
|
|
} elseif ($strKeyField == 'contact_name') {
|
||
|
|
$strVCValues = 'contact_name,alias,host_notification_options,service_notification_options,email,';
|
||
|
|
$strVCValues .= 'pager,address1,address2,address3,address4,address5,address6,name';
|
||
|
|
|
||
|
|
$strVWValues = 'minimum_importance';
|
||
|
|
|
||
|
|
$strVIValues = 'host_notifications_enabled,service_notifications_enabled,can_submit_commands,';
|
||
|
|
$strVIValues .= 'retain_status_information,retain_nonstatus_information';
|
||
|
|
|
||
|
|
$strRLValues = 'contactgroups,host_notification_period,service_notification_period,';
|
||
|
|
$strRLValues .= 'host_notification_commands,service_notification_commands,use';
|
||
|
|
$intWriteConfig = 1;
|
||
|
|
|
||
|
|
// Read contactgroup configurations
|
||
|
|
} elseif ($strKeyField == 'contactgroup_name') {
|
||
|
|
$strVCValues = 'contactgroup_name,alias';
|
||
|
|
|
||
|
|
$strRLValues = 'members,contactgroup_members';
|
||
|
|
$intWriteConfig = 1;
|
||
|
|
|
||
|
|
// Read timeperiod configurations
|
||
|
|
} elseif ($strKeyField == 'timeperiod_name') {
|
||
|
|
$strVCValues = 'timeperiod_name,alias,name';
|
||
|
|
|
||
|
|
$strRLValues = 'use,exclude';
|
||
|
|
$intWriteConfig = 1;
|
||
|
|
|
||
|
|
// Read contacttemplate configurations
|
||
|
|
} elseif (($strKeyField == 'name') && ($strTable == 'tbl_contacttemplate')) {
|
||
|
|
$strVCValues = 'contact_name,alias,host_notification_options,service_notification_options,email,';
|
||
|
|
$strVCValues .= 'pager,address1,address2,address3,address4,address5,address6,name';
|
||
|
|
|
||
|
|
$strVWValues = 'minimum_importance';
|
||
|
|
|
||
|
|
$strVIValues = 'host_notifications_enabled,service_notifications_enabled,can_submit_commands,';
|
||
|
|
$strVIValues .= 'retain_status_information,retain_nonstatus_information';
|
||
|
|
|
||
|
|
$strRLValues = 'contactgroups,host_notification_period,service_notification_period,';
|
||
|
|
$strRLValues .= 'host_notification_commands,service_notification_commands,use';
|
||
|
|
$intWriteConfig = 1;
|
||
|
|
|
||
|
|
// Read host configurations
|
||
|
|
} elseif ($strTable == 'tbl_host') {
|
||
|
|
$strVCValues = 'host_name,alias,display_name,address,initial_state,flap_detection_options,';
|
||
|
|
$strVCValues .= 'notification_options,stalking_options,notes,notes_url,action_url,icon_image,';
|
||
|
|
$strVCValues .= 'icon_image_alt,vrml_image,statusmap_image,2d_coords,3d_coords,name';
|
||
|
|
|
||
|
|
$strVWValues = 'max_check_attempts,retry_interval,check_interval,freshness_threshold,low_flap_threshold,';
|
||
|
|
$strVWValues .= 'high_flap_threshold,notification_interval,first_notification_delay,importance';
|
||
|
|
|
||
|
|
$strVIValues = 'active_checks_enabled,passive_checks_enabled,check_freshness,obsess_over_host,';
|
||
|
|
$strVIValues .= 'event_handler_enabled,flap_detection_enabled,process_perf_data,retain_status_information,';
|
||
|
|
$strVIValues .= 'retain_nonstatus_information,notifications_enabled';
|
||
|
|
|
||
|
|
$strRLValues = 'parents,hostgroups,check_command,use,check_period,event_handler,contacts,contact_groups,';
|
||
|
|
$strRLValues .= 'notification_period';
|
||
|
|
$intWriteConfig = 1;
|
||
|
|
|
||
|
|
// Read hosttemplate configurations
|
||
|
|
} elseif (($strKeyField == 'name') && ($strTable == 'tbl_hosttemplate')) {
|
||
|
|
$strVCValues = 'template_name,alias,initial_state,flap_detection_options,notification_options,';
|
||
|
|
$strVCValues .= 'stalking_options,notes,notes_url,action_url,icon_image,icon_image_alt,vrml_image,';
|
||
|
|
$strVCValues .= 'statusmap_image,2d_coords,3d_coords,name';
|
||
|
|
|
||
|
|
$strVWValues = 'max_check_attempts,retry_interval,check_interval,freshness_threshold,low_flap_threshold,';
|
||
|
|
$strVWValues .= 'high_flap_threshold,notification_interval,first_notification_delay,importance';
|
||
|
|
|
||
|
|
$strVIValues = 'active_checks_enabled,passive_checks_enabled,check_freshness,obsess_over_host,';
|
||
|
|
$strVIValues .= 'event_handler_enabled,flap_detection_enabled,process_perf_data,retain_status_information,';
|
||
|
|
$strVIValues .= 'retain_nonstatus_information,notifications_enabled';
|
||
|
|
|
||
|
|
$strRLValues = 'parents,hostgroups,check_command,use,check_period,event_handler,contacts,contact_groups,';
|
||
|
|
$strRLValues .= 'notification_period';
|
||
|
|
$intWriteConfig = 1;
|
||
|
|
|
||
|
|
// Read hostgroup configurations
|
||
|
|
} elseif ($strKeyField == 'hostgroup_name') {
|
||
|
|
$strVCValues = 'hostgroup_name,alias,notes,notes_url,action_url';
|
||
|
|
|
||
|
|
$strRLValues = 'members,hostgroup_members';
|
||
|
|
$intWriteConfig = 1;
|
||
|
|
|
||
|
|
// Read service configurations
|
||
|
|
} elseif ($strTable == 'tbl_service') {
|
||
|
|
$strVCValues = 'service_description,display_name,initial_state,flap_detection_options,stalking_options,';
|
||
|
|
$strVCValues .= 'notes,notes_url,action_url,icon_image,icon_image_alt,name,config_name,';
|
||
|
|
$strVCValues .= 'notification_options';
|
||
|
|
|
||
|
|
$strVWValues = 'max_check_attempts,check_interval,retry_interval,freshness_threshold,low_flap_threshold,';
|
||
|
|
$strVWValues .= 'high_flap_threshold,notification_interval,first_notification_delay,importance';
|
||
|
|
|
||
|
|
$strVIValues = 'is_volatile,active_checks_enabled,passive_checks_enabled,parallelize_check,';
|
||
|
|
$strVIValues .= 'obsess_over_service,check_freshness,event_handler_enabled,flap_detection_enabled,';
|
||
|
|
$strVIValues .= 'process_perf_data,retain_status_information,retain_nonstatus_information,';
|
||
|
|
$strVIValues .= 'notifications_enabled';
|
||
|
|
|
||
|
|
$strRLValues = 'host_name,hostgroup_name,servicegroups,use,check_command,check_period,event_handler,';
|
||
|
|
$strRLValues .= 'notification_period,contacts,contact_groups,parents';
|
||
|
|
$intWriteConfig = 1;
|
||
|
|
|
||
|
|
// Read servicetemplate configurations
|
||
|
|
} elseif (($strKeyField == 'name') && ($strTable == 'tbl_servicetemplate')) {
|
||
|
|
$strVCValues = 'template_name,service_description,display_name,initial_state,flap_detection_options,';
|
||
|
|
$strVCValues .= 'stalking_options,notes,notes_url,action_url,icon_image,icon_image_alt,name,';
|
||
|
|
$strVCValues .= 'notification_options';
|
||
|
|
|
||
|
|
$strVWValues = 'max_check_attempts,check_interval,retry_interval,freshness_threshold,low_flap_threshold,';
|
||
|
|
$strVWValues .= 'high_flap_threshold,notification_interval,first_notification_delay,importance';
|
||
|
|
|
||
|
|
$strVIValues = 'is_volatile,active_checks_enabled,passive_checks_enabled,parallelize_check,';
|
||
|
|
$strVIValues .= 'obsess_over_service,check_freshness,event_handler_enabled,flap_detection_enabled,';
|
||
|
|
$strVIValues .= 'process_perf_data,retain_status_information,retain_nonstatus_information,';
|
||
|
|
$strVIValues .= 'notifications_enabled';
|
||
|
|
|
||
|
|
$strRLValues = 'host_name,hostgroup_name,servicegroups,use,check_command,check_period,event_handler,';
|
||
|
|
$strRLValues .= 'notification_period,contacts,contact_groups,parents';
|
||
|
|
$intWriteConfig = 1;
|
||
|
|
|
||
|
|
// Read servicegroup configurations
|
||
|
|
} elseif ($strKeyField == 'servicegroup_name') {
|
||
|
|
$strVCValues = 'servicegroup_name,alias,notes,notes_url,action_url';
|
||
|
|
|
||
|
|
$strRLValues = 'members,servicegroup_members';
|
||
|
|
$intWriteConfig = 1;
|
||
|
|
|
||
|
|
// Read hostdependency configurations
|
||
|
|
} elseif ($strTable == 'tbl_hostdependency') {
|
||
|
|
$strVCValues = 'config_name,execution_failure_criteria,notification_failure_criteria';
|
||
|
|
|
||
|
|
$strVIValues = 'inherits_parent';
|
||
|
|
|
||
|
|
$strRLValues = 'dependent_host_name,dependent_hostgroup_name,host_name,hostgroup_name,dependency_period';
|
||
|
|
$intWriteConfig = 1;
|
||
|
|
|
||
|
|
// Read hostescalation configurations
|
||
|
|
} elseif ($strTable == 'tbl_hostescalation') {
|
||
|
|
$strVCValues = 'config_name,escalation_options';
|
||
|
|
|
||
|
|
$strVWValues = 'first_notification,last_notification,notification_interval';
|
||
|
|
|
||
|
|
$strRLValues = 'host_name,hostgroup_name,contacts,contact_groups,escalation_period';
|
||
|
|
$intWriteConfig = 1;
|
||
|
|
|
||
|
|
// Read hostextinfo configurations
|
||
|
|
} elseif ($strTable == 'tbl_hostextinfo') {
|
||
|
|
$strVCValues = 'notes,notes_url,action_url,icon_image,icon_image_alt,vrml_image,statusmap_image,';
|
||
|
|
$strVCValues .= '2d_coords,3d_coords';
|
||
|
|
|
||
|
|
$strRLValues = 'host_name';
|
||
|
|
$intWriteConfig = 1;
|
||
|
|
|
||
|
|
// Read servicedependency configurations
|
||
|
|
} elseif ($strTable == 'tbl_servicedependency') {
|
||
|
|
$strVCValues = 'config_name,execution_failure_criteria,notification_failure_criteria';
|
||
|
|
|
||
|
|
$strVIValues = 'inherits_parent';
|
||
|
|
|
||
|
|
$strRLValues = 'dependent_host_name,dependent_hostgroup_name,dependent_service_description,host_name,';
|
||
|
|
$strRLValues .= 'hostgroup_name,dependency_period,service_description,dependent_servicegroup_name,';
|
||
|
|
$strRLValues .= 'servicegroup_name';
|
||
|
|
$intWriteConfig = 1;
|
||
|
|
|
||
|
|
// Read serviceescalation configurations
|
||
|
|
} elseif ($strTable == 'tbl_serviceescalation') {
|
||
|
|
$strVCValues = 'config_name,escalation_options';
|
||
|
|
|
||
|
|
$strVIValues = 'first_notification,last_notification,notification_interval';
|
||
|
|
|
||
|
|
$strRLValues = 'host_name,hostgroup_name,contacts,contact_groups,service_description,escalation_period,';
|
||
|
|
$strRLValues .= 'servicegroup_name';
|
||
|
|
$intWriteConfig = 1;
|
||
|
|
|
||
|
|
// Serviceextinfo configurations
|
||
|
|
} elseif ($strTable == 'tbl_serviceextinfo') {
|
||
|
|
$strVCValues = 'notes,notes_url,action_url,icon_image,icon_image_alt';
|
||
|
|
|
||
|
|
$strRLValues = 'host_name,service_description';
|
||
|
|
$intWriteConfig = 1;
|
||
|
|
}
|
||
|
|
|
||
|
|
// Common values (all configurations)
|
||
|
|
if ($strVWValues == '') {
|
||
|
|
$strVWValues = 'register';
|
||
|
|
} else {
|
||
|
|
$strVWValues .= ',register';
|
||
|
|
}
|
||
|
|
return array($strVCValues, $intWriteConfig, $strVIValues, $strRLValues, $strVWValues);
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* @param $elem
|
||
|
|
* @param $strVCValues
|
||
|
|
* @param $strSQL1
|
||
|
|
* @param $intIsTemplate
|
||
|
|
* @param $intExists
|
||
|
|
* @param $strTable
|
||
|
|
* @return int
|
||
|
|
*/
|
||
|
|
private function writeTextValues($elem, $strVCValues, &$strSQL1, $intIsTemplate, $intExists, $strTable)
|
||
|
|
{
|
||
|
|
$intCheck = 0;
|
||
|
|
if (\in_array($elem['key'], explode(',', $strVCValues), true)) {
|
||
|
|
if (strtolower(trim($elem['value'])) == 'null') {
|
||
|
|
$strSQL1 .= '`' . $elem['key'] . "` = 'null',";
|
||
|
|
} else {
|
||
|
|
$elem['value'] = addslashes($elem['value']);
|
||
|
|
if ($intIsTemplate == 1) {
|
||
|
|
if ($elem['key'] == 'name') {
|
||
|
|
$strSQL1 .= "template_name = '" . $elem['value'] . "',";
|
||
|
|
} elseif (($elem['key'] == 'config_name') && ($intExists != 0)) {
|
||
|
|
// Do not overwrite config_names during an update!
|
||
|
|
$strSQLConfig = 'SELECT `config_name` FROM `' . $strTable . '` WHERE `id`=' . $intExists;
|
||
|
|
$elem['value'] = $this->myDBClass->getFieldData($strSQLConfig);
|
||
|
|
$strSQL1 .= '`' . $elem['key'] . "` = '" . $elem['value'] . "',";
|
||
|
|
} else {
|
||
|
|
$strSQL1 .= '`' . $elem['key'] . "` = '" . $elem['value'] . "',";
|
||
|
|
}
|
||
|
|
} else {
|
||
|
|
$strSQL1 .= '`' . $elem['key'] . "` = '" . $elem['value'] . "',";
|
||
|
|
}
|
||
|
|
}
|
||
|
|
$intCheck = 1;
|
||
|
|
}
|
||
|
|
return $intCheck;
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* @param $elem
|
||
|
|
* @param $strVIValues
|
||
|
|
* @param $strSQL1
|
||
|
|
* @return int
|
||
|
|
*/
|
||
|
|
private function writeStatusValues($elem, $strVIValues, &$strSQL1)
|
||
|
|
{
|
||
|
|
$intCheck = 0;
|
||
|
|
if (\in_array($elem['key'], explode(',', $strVIValues), true)) {
|
||
|
|
if (strtolower(trim($elem['value'])) == 'null') {
|
||
|
|
$strSQL1 .= '`' . $elem['key'] . '` = 3,';
|
||
|
|
} else {
|
||
|
|
$strSQL1 .= '`' . $elem['key'] . "` = '" . $elem['value'] . "',";
|
||
|
|
}
|
||
|
|
$intCheck = 1;
|
||
|
|
}
|
||
|
|
return $intCheck;
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* @param $elem
|
||
|
|
* @param $strVWValues
|
||
|
|
* @param $strSQL1
|
||
|
|
* @return int
|
||
|
|
*/
|
||
|
|
private function writeIntegerValues($elem, $strVWValues, &$strSQL1)
|
||
|
|
{
|
||
|
|
$intCheck = 0;
|
||
|
|
if (\in_array($elem['key'], explode(',', $strVWValues), true)) {
|
||
|
|
if (strtolower(trim($elem['value'])) == 'null') {
|
||
|
|
$strSQL1 .= '`' . $elem['key'] . '` = -1,';
|
||
|
|
} else {
|
||
|
|
$strSQL1 .= '`' . $elem['key'] . "` = '" . $elem['value'] . "',";
|
||
|
|
}
|
||
|
|
$intCheck = 1;
|
||
|
|
}
|
||
|
|
return $intCheck;
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* @param array $elem
|
||
|
|
* @param string $strRLValues
|
||
|
|
* @param array $arrImportRelations
|
||
|
|
* @param $intInsertRelations
|
||
|
|
* @return int
|
||
|
|
*/
|
||
|
|
private function writeRelations(&$elem, $strRLValues, &$arrImportRelations, &$intInsertRelations)
|
||
|
|
{
|
||
|
|
$intCheck = 0;
|
||
|
|
if (($intCheck == 0) && \in_array($elem['key'], explode(',', $strRLValues), true)) {
|
||
|
|
if ($elem['key'] == 'use') {
|
||
|
|
$elem['key'] = 'use_template';
|
||
|
|
}
|
||
|
|
$arrTemp = array();
|
||
|
|
$arrTemp['key'] = $elem['key'];
|
||
|
|
$arrTemp['value'] = $elem['value'];
|
||
|
|
$arrImportRelations[] = $arrTemp;
|
||
|
|
$intInsertRelations = 1;
|
||
|
|
$intCheck = 1;
|
||
|
|
}
|
||
|
|
return $intCheck;
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Inserts a relation type 1 (1:1)
|
||
|
|
* @param string $strKey Data field name
|
||
|
|
* @param string $strValue Data value
|
||
|
|
* @param int $intDataId Data ID
|
||
|
|
* @param string $strDataTable Data table (Master)
|
||
|
|
* @param array $arrRelData Relation data
|
||
|
|
* @param array $arrImportData Import Data
|
||
|
|
*/
|
||
|
|
public function writeRelation1($strKey, $strValue, $intDataId, $strDataTable, $arrRelData, $arrImportData)
|
||
|
|
{
|
||
|
|
// Define variables
|
||
|
|
$intSlaveId = 0;
|
||
|
|
if (strtolower(trim($strValue)) == 'null') {
|
||
|
|
// Update data in master table
|
||
|
|
$strSQL = 'UPDATE `' .$strDataTable. '` SET `' .$arrRelData['fieldName']. '` = -1 WHERE `id` = '
|
||
|
|
.$intDataId;
|
||
|
|
$booResult = $this->myDBClass->insertData($strSQL);
|
||
|
|
if ($booResult == false) {
|
||
|
|
$this->strErrorMessage .= $this->myDBClass->strErrorMessage;
|
||
|
|
}
|
||
|
|
} else {
|
||
|
|
// Decompose data value
|
||
|
|
$arrValues = explode(',', $strValue);
|
||
|
|
// Process data values
|
||
|
|
foreach ($arrValues as $elem) {
|
||
|
|
$strWhere = '';
|
||
|
|
$strLink = '';
|
||
|
|
$strAdd = '';
|
||
|
|
// Special processing for serviceextinfo
|
||
|
|
if (($strDataTable == 'tbl_serviceextinfo') && ($strKey == 'service_description')) {
|
||
|
|
$strLink = 'LEFT JOIN `tbl_lnkServiceToHost` on `tbl_service`.`id`=`idMaster` ' .
|
||
|
|
'LEFT JOIN `tbl_host` ON `idSlave`=`tbl_host`.`id`';
|
||
|
|
$strWhere = "AND `tbl_host`.`host_name`='".$arrImportData['host_name']['value']."'";
|
||
|
|
}
|
||
|
|
// Does the value already exist?
|
||
|
|
$strSQL = 'SELECT `' .$arrRelData['tableName1']. '`.`id` FROM `' .$arrRelData['tableName1'].
|
||
|
|
"` $strLink " . 'WHERE `' .$arrRelData['target1']."` = '".$elem."' $strWhere AND ".
|
||
|
|
'`' .$arrRelData['tableName1']."`.`active`='1' AND ".
|
||
|
|
'`' .$arrRelData['tableName1']. '`.`config_id`=' .$this->intDomainId;
|
||
|
|
$strId = $this->myDBClass->getFieldData($strSQL);
|
||
|
|
if ($strId != '') {
|
||
|
|
$intSlaveId = (int)$strId;
|
||
|
|
}
|
||
|
|
if ($intSlaveId == 0) {
|
||
|
|
// Insert a temporary value
|
||
|
|
if (($strDataTable == 'tbl_serviceextinfo') && ($arrRelData['tableName1'] == 'tbl_service')) {
|
||
|
|
$strAdd = "`config_name`='imp_tmp_by_serviceextinfo',";
|
||
|
|
}
|
||
|
|
$strSQL = 'INSERT INTO `' .$arrRelData['tableName1']. '` ' .
|
||
|
|
'SET `' .$arrRelData['target1']."` = '".$elem."', ".
|
||
|
|
"$strAdd `config_id`=".$this->intDomainId.", `active`='0', ".
|
||
|
|
'`last_modified`=NOW()';
|
||
|
|
$booResult = $this->myDBClass->insertData($strSQL);
|
||
|
|
if ($booResult == false) {
|
||
|
|
$this->strErrorMessage .= $this->myDBClass->strErrorMessage;
|
||
|
|
}
|
||
|
|
$intSlaveId = $this->myDBClass->intLastId;
|
||
|
|
|
||
|
|
// Special processing for serviceextinfo
|
||
|
|
if (($strDataTable == 'tbl_serviceextinfo') && ($strKey == 'service_description')) {
|
||
|
|
$strSQL = 'SELECT `id` FROM `tbl_host` ' .
|
||
|
|
"WHERE `host_name`='".$arrImportData['host_name']['value']."'";
|
||
|
|
$strId = $this->myDBClass->getFieldData($strSQL);
|
||
|
|
if ($strId != '') {
|
||
|
|
$strSQL = 'INSERT INTO `tbl_lnkServiceToHost` ' .
|
||
|
|
"SET `idMaster` = '".$intSlaveId."', `idSlave` = '".$strId."'";
|
||
|
|
$booResult = $this->myDBClass->insertData($strSQL);
|
||
|
|
if ($booResult == false) {
|
||
|
|
$this->strErrorMessage .= $this->myDBClass->strErrorMessage;
|
||
|
|
}
|
||
|
|
$strSQL = "UPDATE `tbl_service` SET `host_name`=0 WHERE `id`='".$intSlaveId."'";
|
||
|
|
$booResult = $this->myDBClass->insertData($strSQL);
|
||
|
|
if ($booResult == false) {
|
||
|
|
$this->strErrorMessage .= $this->myDBClass->strErrorMessage;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
// Update data in master table
|
||
|
|
$strSQL = 'UPDATE `' .$strDataTable. '` SET `' .$arrRelData['fieldName']. '` = ' .$intSlaveId. ' ' .
|
||
|
|
'WHERE `id` = ' .$intDataId;
|
||
|
|
$booResult = $this->myDBClass->insertData($strSQL);
|
||
|
|
if ($booResult == false) {
|
||
|
|
$this->strErrorMessage .= $this->myDBClass->strErrorMessage;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Inserts a relation type 2 (1:n)
|
||
|
|
* @param string $strKey Data field name
|
||
|
|
* @param string $strValue Data value
|
||
|
|
* @param int $intDataId Data ID
|
||
|
|
* @param string $strDataTable Data table (Master)
|
||
|
|
* @param array $arrRelData Relation data
|
||
|
|
*/
|
||
|
|
public function writeRelation2($strKey, $strValue, $intDataId, $strDataTable, $arrRelData)
|
||
|
|
{
|
||
|
|
// Does a tploption field exist?
|
||
|
|
$strSQL = 'SELECT * FROM `' .$strDataTable. '` WHERE `id` = ' .$intDataId;
|
||
|
|
$this->myDBClass->hasSingleDataset($strSQL, $arrDataset);
|
||
|
|
$strFieldName = $arrRelData['fieldName']. '_tploptions';
|
||
|
|
if (isset($arrDataset[$strFieldName])) {
|
||
|
|
$intTplOption = 1;
|
||
|
|
} else {
|
||
|
|
$intTplOption = 0;
|
||
|
|
}
|
||
|
|
// Delete data from link table
|
||
|
|
$strSQL = 'DELETE FROM `' .$arrRelData['linkTable']. '` WHERE `idMaster` = ' .$intDataId;
|
||
|
|
$booResult = $this->myDBClass->insertData($strSQL);
|
||
|
|
if ($booResult == false) {
|
||
|
|
$this->strErrorMessage .= $this->myDBClass->strErrorMessage;
|
||
|
|
}
|
||
|
|
// Define variables
|
||
|
|
if (strtolower(trim($strValue)) == 'null') {
|
||
|
|
// Update data in master table
|
||
|
|
if ($intTplOption == 1) {
|
||
|
|
$strSQL = 'UPDATE `' .$strDataTable. '` SET `' .$arrRelData['fieldName']. '` = 0, ' .
|
||
|
|
'`' .$arrRelData['fieldName']. '_tploptions` = 1 WHERE `id` = ' .$intDataId;
|
||
|
|
} else {
|
||
|
|
$strSQL = 'UPDATE `' .$strDataTable. '` SET `' .$arrRelData['fieldName']. '` = 0 WHERE `id` = ' .
|
||
|
|
$intDataId;
|
||
|
|
}
|
||
|
|
$this->myDBClass->insertData($strSQL);
|
||
|
|
} else {
|
||
|
|
if (0 === strpos(trim($strValue), '+')) {
|
||
|
|
$intOption = 0;
|
||
|
|
$strValue = str_replace('+', '', $strValue);
|
||
|
|
} else {
|
||
|
|
$intOption = 2;
|
||
|
|
}
|
||
|
|
// Decompose data value
|
||
|
|
$arrValues = explode(',', $strValue);
|
||
|
|
// Process data values
|
||
|
|
foreach ($arrValues as $elem) {
|
||
|
|
if ($elem != '*') {
|
||
|
|
$strWhere = '';
|
||
|
|
$strLink = '';
|
||
|
|
// Exclude values
|
||
|
|
if (0 === strpos($elem, '!')) {
|
||
|
|
$intExclude = 1;
|
||
|
|
$elem = substr($elem, 1);
|
||
|
|
} else {
|
||
|
|
$intExclude = 0;
|
||
|
|
}
|
||
|
|
if ((($strDataTable == 'tbl_servicedependency') || ($strDataTable == 'tbl_serviceescalation')) &&
|
||
|
|
(substr_count($strKey, 'service') != 0) && (substr_count($strKey, 'group') == 0)) {
|
||
|
|
if (substr_count($strKey, 'depend') != 0) {
|
||
|
|
$strLink = 'LEFT JOIN `tbl_lnkServiceToHost` on `id`=`idMaster`';
|
||
|
|
$strWhere = 'AND `idSlave` IN (' .substr($this->strList1, 0, -1). ')';
|
||
|
|
} else {
|
||
|
|
$strLink = 'LEFT JOIN `tbl_lnkServiceToHost` on `id`=`idMaster`';
|
||
|
|
$strWhere = 'AND `idSlave` IN (' .substr($this->strList2, 0, -1). ')';
|
||
|
|
}
|
||
|
|
}
|
||
|
|
// Does the entry already exist?
|
||
|
|
$strSQL = 'SELECT `id` FROM `' .$arrRelData['tableName1']."` $strLink ".
|
||
|
|
'WHERE `' .$arrRelData['target1']."` = '".$elem."' $strWhere AND ".
|
||
|
|
'`config_id`=' .$this->intDomainId;
|
||
|
|
$strId = $this->myDBClass->getFieldData($strSQL);
|
||
|
|
if ($strId != '') {
|
||
|
|
$intSlaveId = (int)$strId;
|
||
|
|
} else {
|
||
|
|
$intSlaveId = 0;
|
||
|
|
}
|
||
|
|
if (($intSlaveId == 0) && ($elem != '*')) {
|
||
|
|
// Insert a temporary value to the target table
|
||
|
|
$strSQL = 'INSERT INTO `' .$arrRelData['tableName1']. '` ' .
|
||
|
|
'SET `' .$arrRelData['target1']."`='".$elem."', ".
|
||
|
|
'`config_id`=' .$this->intDomainId.", `active`='0', `last_modified`=NOW()";
|
||
|
|
$booResult = $this->myDBClass->insertData($strSQL);
|
||
|
|
if ($booResult == false) {
|
||
|
|
$this->strErrorMessage .= $this->myDBClass->strErrorMessage;
|
||
|
|
}
|
||
|
|
$intSlaveId = $this->myDBClass->intLastId;
|
||
|
|
}
|
||
|
|
// Insert relations
|
||
|
|
$strSQL = 'INSERT INTO `' .$arrRelData['linkTable']. '` ' .
|
||
|
|
'SET `idMaster` = ' .$intDataId. ', `idSlave` = ' .$intSlaveId. ', `exclude`=' .$intExclude;
|
||
|
|
$booResult = $this->myDBClass->insertData($strSQL);
|
||
|
|
if ($booResult == false) {
|
||
|
|
$this->strErrorMessage .= $this->myDBClass->strErrorMessage;
|
||
|
|
}
|
||
|
|
// Keep values
|
||
|
|
if (($strDataTable == 'tbl_servicedependency') || ($strDataTable == 'tbl_serviceescalation')) {
|
||
|
|
$strTemp = '';
|
||
|
|
if (($strKey == 'dependent_host_name') || ($strKey == 'host_name')) {
|
||
|
|
$strTemp .= $intSlaveId. ',';
|
||
|
|
} elseif (($strKey == 'dependent_hostgroup_name') || ($strKey == 'hostgroup_name')) {
|
||
|
|
$arrDataHostgroups = array();
|
||
|
|
$intDCHostgroups = 0;
|
||
|
|
$strSQL = 'SELECT DISTINCT `id` FROM `tbl_host` ' .
|
||
|
|
'LEFT JOIN `tbl_lnkHostToHostgroup` ON `id`=`tbl_lnkHostToHostgroup`.`idMaster` ' .
|
||
|
|
'LEFT JOIN `tbl_lnkHostgroupToHost` ON `id`=`tbl_lnkHostgroupToHost`.`idSlave` ' .
|
||
|
|
"WHERE (`tbl_lnkHostgroupToHost`.`idMaster` = $intSlaveId ".
|
||
|
|
"OR `tbl_lnkHostToHostgroup`.`idSlave` = $intSlaveId) ".
|
||
|
|
"AND `active`='1' AND `config_id`=".$this->intDomainId;
|
||
|
|
$booReturn = $this->myDBClass->hasDataArray($strSQL, $arrDataHostgroups, $intDCHostgroups);
|
||
|
|
if ($booReturn && ($intDCHostgroups != 0)) {
|
||
|
|
foreach ($arrDataHostgroups as $elem2) {
|
||
|
|
$strTemp .= $elem2['id']. ',';
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
if (substr_count($strKey, 'dependent') != 0) {
|
||
|
|
$this->strList1 .= $strTemp;
|
||
|
|
} else {
|
||
|
|
$this->strList2 .= $strTemp;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
// Update field values in master table
|
||
|
|
if (substr_count($strValue, '*') != 0) {
|
||
|
|
$intRelValue = 2;
|
||
|
|
} else {
|
||
|
|
$intRelValue = 1;
|
||
|
|
}
|
||
|
|
if ($intTplOption == 1) {
|
||
|
|
$strSQL = 'UPDATE `' .$strDataTable. '` SET `' .$arrRelData['fieldName']."`=$intRelValue, ".
|
||
|
|
'`' .$arrRelData['fieldName']. '_tploptions` = ' .$intOption. ' WHERE `id` = ' .$intDataId;
|
||
|
|
} else {
|
||
|
|
$strSQL = 'UPDATE `' .$strDataTable. '` SET `' .$arrRelData['fieldName']."`=$intRelValue ".
|
||
|
|
'WHERE `id` = ' .$intDataId;
|
||
|
|
}
|
||
|
|
$booResult = $this->myDBClass->insertData($strSQL);
|
||
|
|
if ($booResult == false) {
|
||
|
|
$this->strErrorMessage .= $this->myDBClass->strErrorMessage;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Inserts a relation type 3 (templates)
|
||
|
|
* @param string $strValue Data value
|
||
|
|
* @param int $intDataId Data ID
|
||
|
|
* @param string $strDataTable Data table (Master)
|
||
|
|
* @param array $arrRelData Relation data
|
||
|
|
*/
|
||
|
|
public function writeRelation3($strValue, $intDataId, $strDataTable, $arrRelData)
|
||
|
|
{
|
||
|
|
// Define variables
|
||
|
|
$intSlaveId = 0;
|
||
|
|
$intTable = 0;
|
||
|
|
$intSortNr = 1;
|
||
|
|
if (strtolower(trim($strValue)) == 'null') {
|
||
|
|
// Update data in master table
|
||
|
|
$strSQL = 'UPDATE `' .$strDataTable. '` SET `' .$arrRelData['fieldName']. '` = 0, ' .
|
||
|
|
'`' .$arrRelData['fieldName']. '_tploptions` = 1 WHERE `id` = ' .$intDataId;
|
||
|
|
$this->myDBClass->insertData($strSQL);
|
||
|
|
} else {
|
||
|
|
if (0 === strpos(trim($strValue), '+')) {
|
||
|
|
$intOption = 0;
|
||
|
|
$strValue = str_replace('+', '', $strValue);
|
||
|
|
} else {
|
||
|
|
$intOption = 2;
|
||
|
|
}
|
||
|
|
// Remove old relations
|
||
|
|
$strSQL = 'DELETE FROM `' .$arrRelData['linkTable']. '` WHERE `idMaster` = ' .$intDataId;
|
||
|
|
$booResult = $this->myDBClass->insertData($strSQL);
|
||
|
|
if ($booResult == false) {
|
||
|
|
$this->strErrorMessage .= $this->myDBClass->strErrorMessage;
|
||
|
|
}
|
||
|
|
// Decompose data value
|
||
|
|
$arrValues = explode(',', $strValue);
|
||
|
|
// Process data values
|
||
|
|
foreach ($arrValues as $elem) {
|
||
|
|
// Does the template already exist? (table 1)
|
||
|
|
$strSQL = 'SELECT `id` FROM `' .$arrRelData['tableName1']. '` ' .
|
||
|
|
'WHERE `' .$arrRelData['target1']."` = '".$elem."' AND `config_id`=".$this->intDomainId;
|
||
|
|
$strId = $this->myDBClass->getFieldData($strSQL);
|
||
|
|
if ($strId != '') {
|
||
|
|
$intSlaveId = (int)$strId;
|
||
|
|
$intTable = 1;
|
||
|
|
}
|
||
|
|
if ($intSlaveId == 0) {
|
||
|
|
// Does the template already exist? (table 2)
|
||
|
|
$strSQL = 'SELECT `id` FROM `' .$arrRelData['tableName2']. '` ' .
|
||
|
|
'WHERE `' .$arrRelData['target2']."` = '".$elem."' AND `config_id`=".$this->intDomainId;
|
||
|
|
$strId = $this->myDBClass->getFieldData($strSQL);
|
||
|
|
if ($strId != '') {
|
||
|
|
$intSlaveId = (int)$strId;
|
||
|
|
$intTable = 2;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
if ($intSlaveId == 0) {
|
||
|
|
// Insert a temporary value to the target table
|
||
|
|
$strSQL = 'INSERT INTO `' .$arrRelData['tableName1']. '` ' .
|
||
|
|
'SET `' .$arrRelData['target1']."` = '".$elem."', `config_id`=".$this->intDomainId. ', ' .
|
||
|
|
"`active`='0', `last_modified`=NOW()";
|
||
|
|
$booResult = $this->myDBClass->insertData($strSQL);
|
||
|
|
if ($booResult == false) {
|
||
|
|
$this->strErrorMessage .= $this->myDBClass->strErrorMessage;
|
||
|
|
}
|
||
|
|
$intSlaveId = $this->myDBClass->intLastId;
|
||
|
|
$intTable = 1;
|
||
|
|
}
|
||
|
|
// Insert relations
|
||
|
|
$strSQL = 'INSERT INTO `' .$arrRelData['linkTable']. '` ' .
|
||
|
|
'SET `idMaster` = ' .$intDataId. ', `idSlave`=' .$intSlaveId. ', `idSort`=' .$intSortNr. ', ' .
|
||
|
|
'`idTable` = ' .$intTable;
|
||
|
|
$booResult = $this->myDBClass->insertData($strSQL);
|
||
|
|
if ($booResult == false) {
|
||
|
|
$this->strErrorMessage .= $this->myDBClass->strErrorMessage;
|
||
|
|
}
|
||
|
|
$intSortNr++;
|
||
|
|
$intSlaveId = 0;
|
||
|
|
// Update field data in master table
|
||
|
|
$strSQL = 'UPDATE `' .$strDataTable. '` SET `' .$arrRelData['fieldName']. '` = 1, ' .
|
||
|
|
'`' .$arrRelData['fieldName']. '_tploptions` = ' .$intOption. ' WHERE `id` = ' .$intDataId;
|
||
|
|
$booResult = $this->myDBClass->insertData($strSQL);
|
||
|
|
if ($booResult == false) {
|
||
|
|
$this->strErrorMessage .= $this->myDBClass->strErrorMessage;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Inserts a relation type 4 (free variables)
|
||
|
|
* @param string $strKey Data field name
|
||
|
|
* @param string $strValue Data value
|
||
|
|
* @param int $intDataId Data ID
|
||
|
|
* @param string $strDataTable Data table (Master)
|
||
|
|
* @param array $arrRelData Relation data
|
||
|
|
* @return int 0 = successful / 1 = error
|
||
|
|
*/
|
||
|
|
public function writeRelation4($strKey, $strValue, $intDataId, $strDataTable, $arrRelData)
|
||
|
|
{
|
||
|
|
// Define variables
|
||
|
|
$intReturn = 0;
|
||
|
|
// Remove empty variables
|
||
|
|
if (($strKey == '') || ($strValue == '')) {
|
||
|
|
$intReturn = 1;
|
||
|
|
}
|
||
|
|
// Remove NagiosQL variables
|
||
|
|
if ($strKey == '_NAGIOSQL_CONFIG_NAME') {
|
||
|
|
$intReturn = 1;
|
||
|
|
}
|
||
|
|
if ($intReturn == 0) {
|
||
|
|
// Remove old variables
|
||
|
|
$strSQL = 'SELECT * FROM '.$arrRelData['linkTable'].' WHERE idMaster='.$intDataId;
|
||
|
|
$booResult = $this->myDBClass->hasDataArray($strSQL, $arrLinkData, $intLinkCount);
|
||
|
|
if ($booResult && ($intLinkCount != 0)) {
|
||
|
|
/** @var array $arrLinkData */
|
||
|
|
foreach ($arrLinkData as $elem) {
|
||
|
|
$strSQL1 = 'DELETE FROM tbl_variabledefinition WHERE id=' .$elem['idSlave'];
|
||
|
|
$booResult = $this->myDBClass->insertData($strSQL1);
|
||
|
|
if ($booResult == false) {
|
||
|
|
$this->strErrorMessage .= $this->myDBClass->strErrorMessage;
|
||
|
|
}
|
||
|
|
$strSQL2 = 'DELETE FROM '.$arrRelData['linkTable'].' WHERE idMaster='.$elem['idMaster'];
|
||
|
|
$booResult = $this->myDBClass->insertData($strSQL2);
|
||
|
|
if ($booResult == false) {
|
||
|
|
$this->strErrorMessage .= $this->myDBClass->strErrorMessage;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
// Insert values to the table
|
||
|
|
$strSQL = "INSERT INTO `tbl_variabledefinition` SET `name` = '" . addslashes($strKey) . "', " .
|
||
|
|
"`value` = '" . addslashes($strValue) . "', `last_modified`=now()";
|
||
|
|
$booResult = $this->myDBClass->insertData($strSQL);
|
||
|
|
if ($booResult == false) {
|
||
|
|
$this->strErrorMessage .= $this->myDBClass->strErrorMessage;
|
||
|
|
}
|
||
|
|
$intSlaveId = $this->myDBClass->intLastId;
|
||
|
|
// Insert relations to the table
|
||
|
|
$strSQL = 'INSERT INTO `' . $arrRelData['linkTable'] . '` ' .
|
||
|
|
'SET `idMaster` = ' . $intDataId . ', `idSlave` = ' . $intSlaveId;
|
||
|
|
$booResult = $this->myDBClass->insertData($strSQL);
|
||
|
|
if ($booResult == false) {
|
||
|
|
$this->strErrorMessage .= $this->myDBClass->strErrorMessage;
|
||
|
|
}
|
||
|
|
// Update data in master table
|
||
|
|
$strSQL = 'UPDATE `' . $strDataTable . '` SET `use_variables` = 1 WHERE `id` = ' . $intDataId;
|
||
|
|
$booResult = $this->myDBClass->insertData($strSQL);
|
||
|
|
if ($booResult == false) {
|
||
|
|
$this->strErrorMessage .= $this->myDBClass->strErrorMessage;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
return $intReturn;
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Inserts a relation type 5 (1:1 check command)
|
||
|
|
* @param string $strValue Data value
|
||
|
|
* @param int $intDataId Data ID
|
||
|
|
* @param string $strDataTable Data table (Master)
|
||
|
|
* @param array $arrRelData Relation data
|
||
|
|
*/
|
||
|
|
public function writeRelation5($strValue, $intDataId, $strDataTable, $arrRelData)
|
||
|
|
{
|
||
|
|
// Extract data values
|
||
|
|
$arrCommand = explode('!', $strValue);
|
||
|
|
$strValue = $arrCommand[0];
|
||
|
|
// Define variables
|
||
|
|
$intSlaveId = 0;
|
||
|
|
if (strtolower(trim($strValue)) == 'null') {
|
||
|
|
// Update data in master table
|
||
|
|
$strSQL = 'UPDATE `' .$strDataTable. '` SET `' .$arrRelData['fieldName']. '` = -1 WHERE `id` = ' .
|
||
|
|
$intDataId;
|
||
|
|
$booResult = $this->myDBClass->insertData($strSQL);
|
||
|
|
if ($booResult == false) {
|
||
|
|
$this->strErrorMessage .= $this->myDBClass->strErrorMessage;
|
||
|
|
}
|
||
|
|
} else {
|
||
|
|
// Decompose data values
|
||
|
|
$arrValues = explode(',', $strValue);
|
||
|
|
// Process data values
|
||
|
|
foreach ($arrValues as $elem) {
|
||
|
|
// Does the entry already exist?
|
||
|
|
$strSQL = 'SELECT `id` FROM `' .$arrRelData['tableName1']. '` ' .
|
||
|
|
'WHERE `' .$arrRelData['target1']."` = '".$elem."' AND `config_id`=".$this->intDomainId;
|
||
|
|
$strId = $this->myDBClass->getFieldData($strSQL);
|
||
|
|
if ($strId != '') {
|
||
|
|
$intSlaveId = (int)$strId;
|
||
|
|
}
|
||
|
|
if ($intSlaveId == 0) {
|
||
|
|
// Insert a temporary value in target table
|
||
|
|
$strSQL = 'INSERT INTO `' .$arrRelData['tableName1']. '` ' .
|
||
|
|
'SET `' .$arrRelData['target1']."` = '".$elem."', `config_id`=".$this->intDomainId. ', ' .
|
||
|
|
"`active`='0', `last_modified`=NOW()";
|
||
|
|
$booResult = $this->myDBClass->insertData($strSQL);
|
||
|
|
if ($booResult == false) {
|
||
|
|
$this->strErrorMessage .= $this->myDBClass->strErrorMessage;
|
||
|
|
}
|
||
|
|
$intSlaveId = $this->myDBClass->intLastId;
|
||
|
|
}
|
||
|
|
// Update data in master table
|
||
|
|
$arrCommand[0] = $intSlaveId;
|
||
|
|
$strValue = implode('!', $arrCommand);
|
||
|
|
$strSQL = 'UPDATE `' .$strDataTable. '` ' .
|
||
|
|
'SET `' .$arrRelData['fieldName']."`='".$this->myDBClass->realEscape($strValue)."' ".
|
||
|
|
'WHERE `id` = ' .$intDataId;
|
||
|
|
$booResult = $this->myDBClass->insertData($strSQL);
|
||
|
|
if ($booResult == false) {
|
||
|
|
$this->strErrorMessage .= $this->myDBClass->strErrorMessage;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
///////////////////////////////////////////////////////////////////////////////////////////
|
||
|
|
/**
|
||
|
|
* Inserts a relation type 5 (1:n:n service groups)
|
||
|
|
* @param string $strValue Data value
|
||
|
|
* @param int $intDataId Data ID
|
||
|
|
* @param string $strDataTable Data table (Master)
|
||
|
|
* @param array $arrRelData Relation data
|
||
|
|
*/
|
||
|
|
public function writeRelation6($strValue, $intDataId, $strDataTable, $arrRelData)
|
||
|
|
{
|
||
|
|
// Define variables
|
||
|
|
$intSlaveIdH = 0;
|
||
|
|
$intSlaveIdHG = 0;
|
||
|
|
// Decompose data value
|
||
|
|
$arrValues = explode(',', $strValue);
|
||
|
|
// Remove data from link table
|
||
|
|
$strSQL = 'DELETE FROM `' .$arrRelData['linkTable']. '` WHERE `idMaster` = ' .$intDataId;
|
||
|
|
$booResult = $this->myDBClass->insertData($strSQL);
|
||
|
|
if ($booResult == false) {
|
||
|
|
$this->strErrorMessage .= $this->myDBClass->strErrorMessage;
|
||
|
|
}
|
||
|
|
// Check the sum of elements
|
||
|
|
if (\count($arrValues) % 2 != 0) {
|
||
|
|
$this->strErrorMessage .= translate('Error: incorrect number of arguments - cannot import service group ' .
|
||
|
|
'members'). '::';
|
||
|
|
} else {
|
||
|
|
// Process data values
|
||
|
|
$intCounter = 1;
|
||
|
|
foreach ($arrValues as $elem) {
|
||
|
|
if ($intCounter % 2 == 0) {
|
||
|
|
// Does the host entry already exist?
|
||
|
|
$strSQL = 'SELECT `id` FROM `' .$arrRelData['tableName1']. '` ' .
|
||
|
|
'WHERE `' .$arrRelData['target1']."` = '".$strValue."' AND `active`='1' ".
|
||
|
|
'AND `config_id`=' .$this->intDomainId;
|
||
|
|
$strId = $this->myDBClass->getFieldData($strSQL);
|
||
|
|
if ($strId != '') {
|
||
|
|
$intSlaveIdH = (int)$strId;
|
||
|
|
}
|
||
|
|
// Does a hostgroup entry already exist?
|
||
|
|
if ($intSlaveIdH == 0) {
|
||
|
|
$strSQL = "SELECT `id` FROM `tbl_hostgroup` WHERE `hostgroup_name` = '".$strValue."' ".
|
||
|
|
"AND `active`='1' AND `config_id`=".$this->intDomainId;
|
||
|
|
$strId = $this->myDBClass->getFieldData($strSQL);
|
||
|
|
if ($strId != '') {
|
||
|
|
$intSlaveIdHG = (int)$strId;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
if (($intSlaveIdH == 0) && ($intSlaveIdHG == 0)) {
|
||
|
|
// Insert a temporary value in table
|
||
|
|
$strSQL = 'INSERT INTO `' .$arrRelData['tableName1']. '` ' .
|
||
|
|
'SET `' .$arrRelData['target1']."` = '".$strValue."', ".
|
||
|
|
'`config_id`=' .$this->intDomainId.", `active`='0', `last_modified`=NOW()";
|
||
|
|
$booResult = $this->myDBClass->insertData($strSQL);
|
||
|
|
if ($booResult == false) {
|
||
|
|
$this->strErrorMessage .= $this->myDBClass->strErrorMessage;
|
||
|
|
}
|
||
|
|
$intSlaveIdH = $this->myDBClass->intLastId;
|
||
|
|
}
|
||
|
|
// Does the service entry already exist?
|
||
|
|
if ($intSlaveIdH != 0) {
|
||
|
|
$strSQL = 'SELECT `id` FROM `' .$arrRelData['tableName2']. '` ' .
|
||
|
|
'LEFT JOIN `tbl_lnkServiceToHost` ON `id` = `idMaster` ' .
|
||
|
|
'WHERE `' .$arrRelData['target2']."` = '".$elem."' AND `idSlave` = ".$intSlaveIdH. ' ' .
|
||
|
|
'AND `config_id`=' .$this->intDomainId;
|
||
|
|
$strId = $this->myDBClass->getFieldData($strSQL);
|
||
|
|
if ($strId == '') {
|
||
|
|
$strSQL = 'SELECT `id` FROM `' .$arrRelData['tableName2']. '` ' .
|
||
|
|
'LEFT JOIN `tbl_lnkServiceToHostgroup` ON ' .
|
||
|
|
'`id`=`tbl_lnkServiceToHostgroup`.`idMaster` ' .
|
||
|
|
'LEFT JOIN `tbl_lnkHostgroupToHost` ON ' .
|
||
|
|
'`tbl_lnkHostgroupToHost`.`idMaster`=`tbl_lnkServiceToHostgroup`.`idSlave` ' .
|
||
|
|
'WHERE `' .$arrRelData['target2']."` = '".$elem."' AND ".
|
||
|
|
'`tbl_lnkHostgroupToHost`.`idSlave` = ' .$intSlaveIdH. ' AND ' .
|
||
|
|
"`active`='1' AND `config_id`=".$this->intDomainId;
|
||
|
|
$strId = $this->myDBClass->getFieldData($strSQL);
|
||
|
|
}
|
||
|
|
if ($strId == '') {
|
||
|
|
$strSQL = 'SELECT `id` FROM `' .$arrRelData['tableName2']. '` ' .
|
||
|
|
'LEFT JOIN `tbl_lnkServiceToHostgroup` ON ' .
|
||
|
|
'`id` = `tbl_lnkServiceToHostgroup`.`idMaster` ' .
|
||
|
|
'LEFT JOIN `tbl_lnkHostToHostgroup` ON ' .
|
||
|
|
'`tbl_lnkHostToHostgroup`.`idSlave`=`tbl_lnkServiceToHostgroup`.`idSlave` ' .
|
||
|
|
'WHERE `' .$arrRelData['target2']."` = '".$elem."' AND ".
|
||
|
|
'`tbl_lnkHostToHostgroup`.`idMaster` = ' .$intSlaveIdH. ' AND ' .
|
||
|
|
"`active`='1' AND `config_id`=".$this->intDomainId;
|
||
|
|
$strId = $this->myDBClass->getFieldData($strSQL);
|
||
|
|
}
|
||
|
|
} elseif ($intSlaveIdHG != 0) {
|
||
|
|
$strSQL = 'SELECT `id` FROM `' .$arrRelData['tableName2']. '` ' .
|
||
|
|
'LEFT JOIN `tbl_lnkServiceToHostgroup` ON `id` = `idMaster` ' .
|
||
|
|
'WHERE `' .$arrRelData['target2']."` = '".$elem."' AND `idSlave`=".$intSlaveIdHG. ' ' .
|
||
|
|
"AND `active`='1' AND `config_id`=".$this->intDomainId;
|
||
|
|
$strId = $this->myDBClass->getFieldData($strSQL);
|
||
|
|
}
|
||
|
|
if ($strId != '') {
|
||
|
|
$intSlaveIdS = (int)$strId;
|
||
|
|
} else {
|
||
|
|
$intSlaveIdS = 0;
|
||
|
|
}
|
||
|
|
if ($intSlaveIdS == 0) {
|
||
|
|
// Insert a temporary value in table
|
||
|
|
$intHostName = 0;
|
||
|
|
$intHostgroupName = 0;
|
||
|
|
if ($intSlaveIdH != 0) {
|
||
|
|
$intHostName = 1;
|
||
|
|
} elseif ($intSlaveIdHG != 0) {
|
||
|
|
$intHostgroupName = 1;
|
||
|
|
}
|
||
|
|
$strSQL = 'INSERT INTO `' .$arrRelData['tableName2']. '` ' .
|
||
|
|
"SET `config_name`='imp_tmp_by_servicegroup', `host_name`=$intHostName, ".
|
||
|
|
"`hostgroup_name`=$intHostgroupName, `".$arrRelData['target2']."` = '".$elem."', ".
|
||
|
|
'`config_id`=' .$this->intDomainId.", `active`='0', `last_modified`=NOW()";
|
||
|
|
$booResult = $this->myDBClass->insertData($strSQL);
|
||
|
|
if ($booResult == false) {
|
||
|
|
$this->strErrorMessage .= $this->myDBClass->strErrorMessage;
|
||
|
|
}
|
||
|
|
$intSlaveIdS = $this->myDBClass->intLastId;
|
||
|
|
// Make a relation from temp service to host / hostgroup
|
||
|
|
if ($intSlaveIdH != 0) {
|
||
|
|
$strSQL = 'INSERT INTO `tbl_lnkServiceToHost` ' .
|
||
|
|
"SET `idMaster`='".$intSlaveIdS."', `idSlave`=".$intSlaveIdH.", `exclude`='0'";
|
||
|
|
$booResult = $this->myDBClass->insertData($strSQL);
|
||
|
|
if ($booResult == false) {
|
||
|
|
$this->strErrorMessage .= $this->myDBClass->strErrorMessage;
|
||
|
|
}
|
||
|
|
} elseif ($intSlaveIdHG != 0) {
|
||
|
|
$strSQL = 'INSERT INTO `tbl_lnkServiceToHostgroup` ' .
|
||
|
|
"SET `idMaster`='".$intSlaveIdS."', `idSlave`=".$intSlaveIdHG. ', ' .
|
||
|
|
"`exclude`='0'";
|
||
|
|
$booResult = $this->myDBClass->insertData($strSQL);
|
||
|
|
if ($booResult == false) {
|
||
|
|
$this->strErrorMessage .= $this->myDBClass->strErrorMessage;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
// Insert relation
|
||
|
|
$strSQL = 'INSERT INTO `' .$arrRelData['linkTable']. '` ' .
|
||
|
|
'SET `idMaster`=' .$intDataId. ', `idSlaveH`=' .$intSlaveIdH. ', `idSlaveS`=' .$intSlaveIdS;
|
||
|
|
$booResult = $this->myDBClass->insertData($strSQL);
|
||
|
|
if ($booResult == false) {
|
||
|
|
$this->strErrorMessage .= $this->myDBClass->strErrorMessage;
|
||
|
|
}
|
||
|
|
// Update data in master table
|
||
|
|
$strSQL = 'UPDATE `' .$strDataTable. '` ' .
|
||
|
|
'SET `' .$arrRelData['fieldName']. '` = 1 WHERE `id` = ' .$intDataId;
|
||
|
|
$booResult = $this->myDBClass->insertData($strSQL);
|
||
|
|
if ($booResult == false) {
|
||
|
|
$this->strErrorMessage .= $this->myDBClass->strErrorMessage;
|
||
|
|
}
|
||
|
|
} else {
|
||
|
|
$strValue = $elem;
|
||
|
|
}
|
||
|
|
$intCounter++;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Inserts a relation type 6 (1:n:str)
|
||
|
|
* @param string $strValue Data value
|
||
|
|
* @param int $intDataId Data ID
|
||
|
|
* @param string $strDataTable Data table (Master)
|
||
|
|
* @param array $arrRelData Relation data
|
||
|
|
*/
|
||
|
|
public function writeRelation7($strValue, $intDataId, $strDataTable, $arrRelData)
|
||
|
|
{
|
||
|
|
// Delete data from link table
|
||
|
|
$strSQL = 'DELETE FROM `' .$arrRelData['linkTable']. '` WHERE `idMaster` = ' .$intDataId;
|
||
|
|
$booResult = $this->myDBClass->insertData($strSQL);
|
||
|
|
if ($booResult == false) {
|
||
|
|
$this->strErrorMessage .= $this->myDBClass->strErrorMessage;
|
||
|
|
}
|
||
|
|
// Decompose data value
|
||
|
|
$arrValues = explode(',', $strValue);
|
||
|
|
// Process data values
|
||
|
|
foreach ($arrValues as $elem) {
|
||
|
|
if ($elem != '*') {
|
||
|
|
$strWhere = '';
|
||
|
|
// Exclude values
|
||
|
|
if (0 === strpos($elem, '!')) {
|
||
|
|
$intExclude = 1;
|
||
|
|
$elem = substr($elem, 1);
|
||
|
|
} else {
|
||
|
|
$intExclude = 0;
|
||
|
|
}
|
||
|
|
// Does the entry already exist?
|
||
|
|
$strSQL = 'SELECT `id` FROM `' .$arrRelData['tableName1']. '` ' .
|
||
|
|
'WHERE `' .$arrRelData['target1']."`='".$elem."' $strWhere ".
|
||
|
|
'AND `config_id`=' .$this->intDomainId;
|
||
|
|
$strId = $this->myDBClass->getFieldData($strSQL);
|
||
|
|
if ($strId != '') {
|
||
|
|
$intSlaveId = (int)$strId;
|
||
|
|
} else {
|
||
|
|
$intSlaveId = 0;
|
||
|
|
}
|
||
|
|
if (($intSlaveId == 0) && ($elem != '*')) {
|
||
|
|
// Insert a temporary value to the target table
|
||
|
|
$strSQL = 'INSERT INTO `' .$arrRelData['tableName1']. '` ' .
|
||
|
|
'SET `' .$arrRelData['target1']."` = '".$elem."', `host_name`=2, `hostgroup_name`=2, ".
|
||
|
|
"`config_name`='imp_tmp_by_servicedependency', `config_id`=".$this->intDomainId. ', ' .
|
||
|
|
"`active`='0', `last_modified`=NOW()";
|
||
|
|
$booResult = $this->myDBClass->insertData($strSQL);
|
||
|
|
if ($booResult == false) {
|
||
|
|
$this->strErrorMessage .= $this->myDBClass->strErrorMessage;
|
||
|
|
}
|
||
|
|
$intSlaveId = $this->myDBClass->intLastId;
|
||
|
|
}
|
||
|
|
// Insert relations
|
||
|
|
$strSQL = 'INSERT INTO `' .$arrRelData['linkTable']. '` ' .
|
||
|
|
'SET `idMaster` = ' .$intDataId. ', `idSlave` = ' .$intSlaveId.", `strSlave`='".$elem."', ".
|
||
|
|
'`exclude`=' .$intExclude;
|
||
|
|
$booResult = $this->myDBClass->insertData($strSQL);
|
||
|
|
if ($booResult == false) {
|
||
|
|
$this->strErrorMessage .= $this->myDBClass->strErrorMessage;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
// Update field values in master table
|
||
|
|
if (substr_count($strValue, '*') != 0) {
|
||
|
|
$intRelValue = 2;
|
||
|
|
} else {
|
||
|
|
$intRelValue = 1;
|
||
|
|
}
|
||
|
|
$strSQL = 'UPDATE `' .$strDataTable. '` ' .
|
||
|
|
'SET `' .$arrRelData['fieldName']."` = $intRelValue WHERE `id` = ".$intDataId;
|
||
|
|
$booResult = $this->myDBClass->insertData($strSQL);
|
||
|
|
if ($booResult == false) {
|
||
|
|
$this->strErrorMessage .= $this->myDBClass->strErrorMessage;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Inserts a relation type 6 (service and servicetemplate parents - 1:service:host)
|
||
|
|
* @param string $strValue Data value
|
||
|
|
* @param int $intDataId Data ID
|
||
|
|
* @param string $strDataTable Data table (Master)
|
||
|
|
* @param array $arrRelData Relation data
|
||
|
|
*/
|
||
|
|
public function writeRelation8($strValue, $intDataId, $strDataTable, $arrRelData)
|
||
|
|
{
|
||
|
|
// Decompose data value
|
||
|
|
$arrValues = explode(',', $strValue);
|
||
|
|
// Delete data from link table
|
||
|
|
$strSQL = 'DELETE FROM `' .$arrRelData['linkTable']. '` WHERE `idMaster` = ' .$intDataId;
|
||
|
|
$booResult = $this->myDBClass->insertData($strSQL);
|
||
|
|
if ($booResult == false) {
|
||
|
|
$this->strErrorMessage .= $this->myDBClass->strErrorMessage;
|
||
|
|
}
|
||
|
|
// Check the sum of elements
|
||
|
|
/** @noinspection ExplodeMissUseInspection */
|
||
|
|
if (count($arrValues) % 2 != 0) {
|
||
|
|
$this->strErrorMessage .= translate('Error: incorrect number of arguments - cannot import service parent ' .
|
||
|
|
'members'). '::';
|
||
|
|
} else {
|
||
|
|
// Process data values
|
||
|
|
$intCounter = 1;
|
||
|
|
$strHostName = '';
|
||
|
|
foreach ($arrValues as $elem) {
|
||
|
|
if ($intCounter % 2 == 0) {
|
||
|
|
$strServiceName = $elem;
|
||
|
|
if (($strServiceName != '') && ($strHostName != '')) {
|
||
|
|
$strSQL = 'SELECT tbl_service.id AS id_1, C.id AS id_2, D.id AS id_3, E.id AS id_4 '
|
||
|
|
. 'FROM tbl_service '
|
||
|
|
. 'LEFT JOIN tbl_lnkServiceToHost ON tbl_service.id=tbl_lnkServiceToHost.idMaster '
|
||
|
|
. 'LEFT JOIN tbl_lnkServiceToHostgroup '
|
||
|
|
. 'ON tbl_service.id=tbl_lnkServiceToHostgroup.idMaster '
|
||
|
|
. 'LEFT JOIN tbl_lnkHostgroupToHost AS A ON tbl_lnkServiceToHostgroup.idSlave=A.idMaster '
|
||
|
|
. 'LEFT JOIN tbl_lnkHostToHostgroup AS B ON tbl_lnkServiceToHostgroup.idSlave=B.idSlave '
|
||
|
|
. 'LEFT JOIN tbl_host AS C ON A.idSlave=C.id '
|
||
|
|
. 'LEFT JOIN tbl_host AS D ON B.idMaster=D.id '
|
||
|
|
. 'LEFT JOIN tbl_host AS E ON tbl_lnkServiceToHost.idSlave=E.id '
|
||
|
|
. "WHERE tbl_service.service_description='".$strServiceName."' "
|
||
|
|
. "AND (C.host_name='".$strHostName."' OR D.host_name='".$strHostName."' "
|
||
|
|
. "OR E.host_name='".$strHostName."')";
|
||
|
|
$booResult = $this->myDBClass->hasDataArray($strSQL, $arrDataset, $intCount);
|
||
|
|
if ($booResult && ($intCount == 1)) {
|
||
|
|
$intServiceId = 0;
|
||
|
|
$intHostId = 0;
|
||
|
|
$intId1 = $arrDataset[0]['id_1'];
|
||
|
|
$intId2 = $arrDataset[0]['id_2'];
|
||
|
|
$intId3 = $arrDataset[0]['id_3'];
|
||
|
|
$intId4 = $arrDataset[0]['id_4'];
|
||
|
|
if (($intId1!= null) && ($intId1 != 0) && ($intServiceId == 0)) {
|
||
|
|
$intServiceId = (int)$intId1;
|
||
|
|
}
|
||
|
|
$intHostSum = 0;
|
||
|
|
if (($intId2 != null) && ($intId2 != 0) && ($intHostId == 0)) {
|
||
|
|
$intHostId = (int)$intId2;
|
||
|
|
$intHostSum += $intHostId;
|
||
|
|
}
|
||
|
|
if (($intId3 != null) && ($intId3 != 0) && ($intHostId == 0)) {
|
||
|
|
$intHostId = (int)$intId3;
|
||
|
|
$intHostSum += $intHostId;
|
||
|
|
}
|
||
|
|
if (($intId4 != null) && ($intId4 != 0) && ($intHostId == 0)) {
|
||
|
|
$intHostId = (int)$intId4;
|
||
|
|
$intHostSum += $intHostId;
|
||
|
|
}
|
||
|
|
if (($intHostId == $intHostSum) && ($intServiceId != 0) && ($intHostId != 0)) {
|
||
|
|
$strSQL = 'INSERT INTO ' .$arrRelData['linkTable']. ' '
|
||
|
|
. "SET idMaster=$intDataId, idSlave=$intServiceId, idHost=$intHostId";
|
||
|
|
$booResult = $this->myDBClass->insertData($strSQL);
|
||
|
|
if ($booResult == false) {
|
||
|
|
$this->strErrorMessage .= $this->myDBClass->strErrorMessage;
|
||
|
|
}
|
||
|
|
$strSQL = 'UPDATE `' .$strDataTable. '` ' .
|
||
|
|
'SET `' .$arrRelData['fieldName']. '` = 1 WHERE `id` = ' .$intDataId;
|
||
|
|
$booResult = $this->myDBClass->insertData($strSQL);
|
||
|
|
if ($booResult == false) {
|
||
|
|
$this->strErrorMessage .= $this->myDBClass->strErrorMessage;
|
||
|
|
}
|
||
|
|
} else {
|
||
|
|
$this->strErrorMessage .= translate('Error: cannot import the service parent member ')
|
||
|
|
. $strServiceName . '-' . $strHostName . '. '
|
||
|
|
. translate('This combination is not unique!') . '::';
|
||
|
|
}
|
||
|
|
} else {
|
||
|
|
$this->strErrorMessage .= translate('Error: cannot import the service parent member ')
|
||
|
|
. $strServiceName. '-' .$strHostName. '. '
|
||
|
|
. translate('This combination is not unique or does not exist!').'::';
|
||
|
|
}
|
||
|
|
}
|
||
|
|
} else {
|
||
|
|
$strHostName = $elem;
|
||
|
|
}
|
||
|
|
$intCounter++;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|