Modules/devices/devices search inc php
Материал из MajorDoMo инфо
ᐂ В корневой раздел ᐃ В директорию расположения файла
<?php
/*
* @version 0.1 (wizard)
*/
// Глобальная переменная $session используется для хранения данных сессии.
global $session;
// Проверяем, является ли текущий объект панелью управления.
// Если это так, то устанавливаем флаг CONTROLPANEL в 1, что может быть использовано для определения,
// нужно ли отображать элементы управления панелью.
if ($this->owner->name == 'panel') {
$out['CONTROLPANEL'] = 1;
}
// Инициализируем запрос с условием, что все записи должны быть выбраны.
// Значение "1" в SQL означает, что условие всегда истинно, и запрос будет выбирать все записи.
$qry = "1";
// Фильтры поиска.
// Здесь предполагается, что будут добавлены дополнительные условия для фильтрации результатов поиска.
// Получаем тип устройства из запроса.
// Функция gr('type') предположительно извлекает параметр 'type' из запроса.
$type = gr('type');
// Если тип устройства указан, добавляем его в запрос.
// Это позволяет фильтровать результаты поиска по типу устройства.
if ($type != '') {
// Добавляем условие в запрос, чтобы выбрать только устройства с указанным типом.
// Функция DBSafe($type) предположительно очищает входные данные от потенциально вредоносного кода.
$qry .= " AND devices.TYPE='" . DBSafe($type) . "'";
// Сохраняем тип устройства в массиве $out для дальнейшего использования.
$out['TYPE'] = $type;
}
// Получаем ID местоположения из запроса.
// Функция gr('location_id') предположительно извлекает параметр 'location_id' из запроса.
$location_id = gr('location_id');
// Проверяем, указан ли параметр управления местоположениями.
// Если параметр равен 'manage_locations', перенаправляем пользователя на страницу управления местоположениями.
if ($location_id == 'manage_locations') {
$this->redirect("?(panel:{action=locations})");
} elseif ($location_id) {
// Если указан ID местоположения, добавляем его в запрос.
// Приведение к типу int гарантирует, что ID будет числом, что необходимо для корректного SQL-запроса.
$out['LOCATION_ID'] = (int)$location_id;
// Добавляем условие в запрос, чтобы выбрать только устройства с указанным ID местоположения.
$qry .= " AND devices.LOCATION_ID=" . $out['LOCATION_ID'];
}
// Получаем имя группы устройств из запроса.
// Функция gr('group_name') предположительно извлекает параметр 'group_name' из запроса.
$group_name = gr('group_name');
// Проверяем, указан ли параметр управления группами.
// Если параметр равен 'manage_groups', перенаправляем пользователя на страницу управления группами.
if ($group_name == 'manage_groups') {
$this->redirect("?view_mode=manage_groups");
} elseif ($group_name == 'is:archived') {
// Если указан параметр архивированных устройств, добавляем его в запрос.
// Это позволяет фильтровать результаты поиска, отображая только архивированные устройства.
$qry .= " AND devices.ARCHIVED=1";
} elseif ($group_name == 'is:system') {
// Если указан параметр системных устройств, добавляем его в запрос.
// Это позволяет фильтровать результаты поиска, отображая только системные устройства.
$qry .= " AND devices.SYSTEM_DEVICE=1";
} elseif ($group_name == 'is:inactive') {
// Получаем имена объектов, которые не активны (например, устройства, не отвечающие на запросы).
$object_names = getObjectsByProperty('alive');
if (!is_array($object_names)) {
$object_names = array(0);
}
$total = count($object_names);
if ($total > 0) {
for ($i = 0; $i < $total; $i++) {
// Проверяем, является ли объект активным.
$val = getGlobal($object_names[$i].'.alive');
if (!$val) {
// Если объект не активен, добавляем его в список для фильтрации.
$res_object_names[] = "'" . $object_names[$i] . "'";
}
}
// Добавляем условие в запрос для фильтрации по именам неактивных объектов.
$qry .= " AND devices.LINKED_OBJECT IN (" . implode(',', $res_object_names) . ")";
} else {
// Если список объектов пуст, добавляем условие, которое не позволит выбрать ни одного устройства.
$qry .= " AND 0";
}
} elseif ($group_name == 'is:battery') {
// Получаем имена объектов, работающих от батареи.
// Функция getObjectsByProperty('batteryOperated', 1) предположительно возвращает список объектов,
// которые работают от батареи.
$object_names = getObjectsByProperty('batteryOperated', 1);
if (!is_array($object_names)) {
$object_names = array(0);
}
$total = count($object_names);
if ($total > 0) {
for ($i = 0; $i < $total; $i++) {
$object_names[$i] = "'" . $object_names[$i] . "'";
}
// Добавляем имена объектов в запрос, чтобы фильтровать результаты поиска по объектам,
// работающим от батареи.
$qry .= " AND devices.LINKED_OBJECT IN (" . implode(',', $object_names) . ")";
} else {
// Если список объектов пуст, добавляем условие, которое не позволит выбрать ни одного устройства.
$qry .= " AND 0";
}
} elseif ($group_name == 'is:battery_low') {
// Получаем имена объектов с низким уровнем заряда батареи.
// Функция getObjectsByProperty('batteryWarning', 1) предположительно возвращает список объектов,
// у которых уровень заряда батареи низкий.
$object_names = getObjectsByProperty('batteryWarning', 1);
if (!is_array($object_names)) {
$object_names = array(0);
}
$total = count($object_names);
if ($total > 0) {
for ($i = 0; $i < $total; $i++) {
$object_names[$i] = "'" . $object_names[$i] . "'";
}
// Добавляем имена объектов в запрос, чтобы фильтровать результаты поиска по объектам,
// у которых уровень заряда батареи низкий.
$qry .= " AND devices.LINKED_OBJECT IN (" . implode(',', $object_names) . ")";
} else {
$qry .= " AND 0";
}
} elseif ($group_name) {
// Получаем имена объектов по имени группы.
// Функция getObjectsByProperty('group' . $group_name, 1) предположительно возвращает список объектов,
// соответствующих указанному имени группы.
$object_names = getObjectsByProperty('group' . $group_name, 1);
if (!is_array($object_names)) {
$object_names = array(0);
}
$total = count($object_names);
if ($total > 0) {
for ($i = 0; $i < $total; $i++) {
$object_names[$i] = "'" . $object_names[$i] . "'";
}
// Добавляем имена объектов в запрос, чтобы фильтровать результаты поиска по объектам,
// соответствующим указанному имени группы.
$qry .= " AND devices.LINKED_OBJECT IN (" . implode(',', $object_names) . ")";
} else {
$qry .= " AND 0";
}
}
// Сохраняем имя группы устройств в массиве $out для дальнейшего использования.
$out['GROUP_NAME'] = $group_name;
// Если не указан параметр архивированных устройств, добавляем условие выбора неархивированных устройств.
// Это условие гарантирует, что в результатах поиска будут отображаться только устройства, которые не были помечены как архивированные.
if ($group_name != 'is:archived') {
$qry .= " AND devices.ARCHIVED=0";
}
// QUERY READY//Запрос к базе данных готов к выполнению
// Глобальная переменная $save_qry используется для определения, следует ли сохранять текущий запрос или использовать сохраненный.
global $save_qry;
// Если установлено сохранение запроса, используем сохраненный запрос.
// Это может быть полезно для сохранения состояния фильтрации между различными запросами.
if ($save_qry) {
$qry = $session->data['devices_qry'];
} else {
// Иначе сохраняем текущий запрос в сессии для возможного использования в будущем.
$session->data['devices_qry'] = $qry;
}
// Если запрос пуст, устанавливаем его как "1" для выбора всех записей.
// Это обеспечивает, что в любом случае будет выполнен запрос, даже если не было указано никаких фильтров.
if (!$qry) $qry = "1";
// Получаем общее количество устройств, не архивированных.
// Это делается для отображения общего количества доступных устройств в пользовательском интерфейсе.
$tmp = SQLSelectOne("SELECT COUNT(*) AS TOTAL FROM devices WHERE devices.ARCHIVED!=1");
$out['TOTAL'] = (int)$tmp['TOTAL'];
$loc_title = '';
// Сортировка результатов по приоритету местоположения, названию местоположения, ID местоположения, типу устройства и названию устройства
$sortby_devices = "locations.PRIORITY DESC, locations.TITLE, devices.LOCATION_ID, devices.TYPE, devices.TITLE";
$out['SORTBY'] = $sortby_devices;
// РЕЗУЛЬТАТЫ ПОИСКА
// Выполняем SQL-запрос для получения результатов поиска устройств, включая информацию о местоположении каждого устройства.
// Запрос сортируется по заданным критериям сортировки.
$res = SQLSelect("SELECT devices.*, locations.TITLE as LOCATION_TITLE FROM devices LEFT JOIN locations ON devices.LOCATION_ID=locations.ID WHERE $qry ORDER BY " . $sortby_devices);
// Проверяем, есть ли результаты поиска.
if (isset($res[0])) {
//paging($res, 100, $out); // search result paging
// Подсчитываем общее количество найденных устройств.
$total = count($res);
$out['TOTAL_FOUND'] = $total;
// Обрабатываем каждый результат поиска.
for ($i = 0; $i < $total; $i++) {
// Если название местоположения изменилось, устанавливаем флаг NEW_LOCATION.
if ($res[$i]['LOCATION_TITLE'] != $loc_title) {
$res[$i]['NEW_LOCATION'] = 1;
$loc_title = $res[$i]['LOCATION_TITLE'];
}
// Если у устройства есть связанный объект, обрабатываем его.
if ($res[$i]['LINKED_OBJECT']) {
// Обработка устройства в зависимости от его типа.
if ($res[$i]['TYPE'] == 'camera' || $res[$i]['TYPE'] == 'mark') {
$processed = $this->processDevice($res[$i]['ID'], 'list');
} else {
$processed = $this->processDevice($res[$i]['ID']);
}
// Добавляем HTML-представление устройства.
$res[$i]['HTML'] = $processed['HTML'];
// Получаем свойства связанного объекта.
$object_rec = SQLSelectOne("SELECT ID FROM objects WHERE TITLE='" . $res[$i]['LINKED_OBJECT'] . "'");
if ($object_rec['ID']) {
$properties = SQLSelect("SELECT pvalues.*, properties.TITLE as PROPERTY FROM pvalues LEFT JOIN properties ON properties.ID=pvalues.PROPERTY_ID WHERE pvalues.OBJECT_ID=" . $object_rec['ID'] . " AND pvalues.LINKED_MODULES!='' ORDER BY UPDATED");
$totalp = count($properties);
if ($totalp > 0) {
// Обрабатываем свойства, связанные с модулями.
$linked_modules = array();
for ($ip = 0; $ip < $totalp; $ip++) {
$tmp = explode(',', $properties[$ip]['LINKED_MODULES']);
$tmp = array_map('trim', $tmp);
foreach ($tmp as $linked_module) {
$linked_modules[$linked_module] = array('OBJECT' => $res[$i]['LINKED_OBJECT'], 'PROPERTY' => $properties[$ip]['PROPERTY']);
}
}
foreach ($linked_modules as $k => $v) {
$v['MODULE'] = $k;
$res[$i]['LINKED_MODULES'][] = $v;
}
}
}
}
// Добавляем название типа устройства.
$res[$i]['TYPE_TITLE'] = $this->device_types[$res[$i]['TYPE']]['TITLE'];
// Получаем количество связанных устройств.
$linked = SQLSelectOne("SELECT COUNT(*) AS TOTAL FROM devices_linked WHERE (DEVICE1_ID=" . $res[$i]['ID'] . " OR DEVICE2_ID=" . $res[$i]['ID'] . ")");
if ($linked['TOTAL']) {
$res[$i]['LINKED'] = $linked['TOTAL'];
}
// Получаем количество методов устройства.
$methods = SQLSelectOne("SELECT COUNT(*) AS TOTAL FROM methods WHERE CODE!='' AND OBJECT_ID=".(int)$object_rec['ID']);
if ($methods['TOTAL']) {
$res[$i]['METHODS'] = $methods['TOTAL'];
}
}
// Сохраняем результаты поиска в массиве $out.
$out['RESULT'] = $res;
}
// Подготовка к формированию списка типов устройств.
$types = array();
// Формирование списка типов устройств
// Проходим по всем типам устройств, определенным в $this->device_types.
foreach ($this->device_types as $k => $v) {
// Проверяем, установлено ли название для типа устройства.
if (isset($v['TITLE'])) {
// Создаем запись для типа устройства с его названием и именем.
$type_rec = array('NAME' => $k, 'TITLE' => $v['TITLE']);
// Выполняем запрос к базе данных для подсчета количества устройств данного типа, которые не архивированы.
$tmp = SQLSelectOne("SELECT COUNT(*) AS TOTAL FROM devices WHERE TYPE='" . $k . "' AND ARCHIVED!=1");
// Сохраняем количество устройств в записи типа устройства.
$type_rec['TOTAL'] = (int)$tmp['TOTAL'];
// Если количество устройств больше нуля, добавляем запись типа устройства в список.
if ($type_rec['TOTAL'] > 0) {
$types[] = $type_rec;
}
}
}
// Сортируем список типов устройств по названию.
usort($types, function ($a, $b) {
return strcmp($a["TITLE"], $b["TITLE"]);
});
// Сохраняем отсортированный список типов устройств в массиве $out.
$out['TYPES'] = $types;
// Получение списка местоположений
// Выполняем запрос к базе данных для получения списка местоположений.
$locations = SQLSelect("SELECT ID, TITLE FROM locations ORDER BY TITLE+0");
$total = count($locations);
// Получение количества устройств для каждого местоположения
// Проходим по всем местоположениям и выполняем запрос к базе данных для подсчета количества устройств в каждом местоположении.
for ($i = 0; $i < $total; $i++) {
$tmp = SQLSelectOne("SELECT COUNT(*) AS TOTAL FROM devices WHERE LOCATION_ID='" . $locations[$i]['ID'] . "'");
// Сохраняем количество устройств в записи местоположения.
$locations[$i]['TOTAL'] = (int)$tmp['TOTAL'];
}
// Сохраняем список местоположений с количеством устройств в массиве $out.
$out['LOCATIONS'] = $locations;
// Получение списка групп устройств
// Выполняем запрос к базе данных для получения списка групп устройств.
$groups = SQLSelect("SELECT * FROM devices_groups ORDER BY TITLE");
// Добавляем системные группы в список групп.
$groups[] = array('SYS_NAME' => 'Eco', 'TITLE' => LANG_DEVICES_GROUP_ECO);
$groups[] = array('SYS_NAME' => 'EcoOn', 'TITLE' => LANG_DEVICES_GROUP_ECO_ON);
$groups[] = array('SYS_NAME' => 'Sunrise', 'TITLE' => LANG_DEVICES_GROUP_SUNRISE);
$groups[] = array('SYS_NAME' => 'Sunset', 'TITLE' => LANG_DEVICES_GROUP_SUNSET);
$groups[] = array('SYS_NAME' => 'Night', 'TITLE' => LANG_DEVICES_GROUP_NIGHT);
// Сохраняем список групп устройств в массиве $out.
$out['GROUPS'] = $groups;
