Описание модулей подсистемы связи с СУБД

Имя модуля	Связанные процедуры в API СУБД
DataSet_DelayNotifications	get_input_monitoring_prefs, set_input_monitoring_prefs
DataSet_OPR_Stop	add_data_request, get_request_receivers, get_data_request_attr
DataSet_RequestResponce_List	add_data_request, update_data_requests_state, rem_data_request, get_request_receivers
DataSet_EventNotifications_SharedLists	get_lists_wells, get_lists_wells_set
DataSet_EventNotifications	get_active_lists_wells, get_events, upd_active_events_status
DataSet_EventNotifications_Lists	get_lists_wells, del_lists_wells, add_lists_wells, upd_lists_wells, upd_lists_wells_set_note, add_lists_wells_set, del_lists_wells_set, get_lists_wells_set

 

Разработанные модули обеспечивают обмен данными между Подсистемой и API СУБД. Помимо взаимодействия с API СУБД модули обеспечивают контроль данных для снижения количества ошибок пользователя.

API СУБД

Для доступа к данным были разработаны и внесены в ИС «ЭПОС» хранимые процедуры:

· get_input_monitoring_prefs – вызов параметров для контроля за задержкой ввода данных;

· get_active_lists_wells – запрос данных для оповещения по Событиям;

· get_events – запрос данных по событию, выбранной скважины;

· get_data_request_attr – получение данных по запросу;

· del_lists_wells – удаление группы из подписки;

· del_lists_wells_set – удаление скважины из группы подписки;

· upd_lists_wells – обновление значений параметров подписки на События;

· get_data_request – формирование заявок на коррекцию и дополнение данных;

· add_data_request – добавление заявок на коррекцию и дополнение данных;

· add_lists_wells – добавление группы скважин;

· add_lists_wells_set – добавление скважины в группу подписок;

· update_data_requests_state – обновление статуса запроса;

· upd_lists_wells_set_note – обновление параметров скважин в подписке;

· upd_active_events_status – обновление статуса оповещения по Событиям;

· get_request_receivers – получение списка запросов;

· rem_data_request – удаление запроса;

· get_lists_wells – запрос данных по подписке;

· copy_lists_wells – копирование общую группу в список личных групп;

· set_input_monitoring_prefs – обновление параметров для настройки подписки на оповещение по задержкам ввода данных;

· get_data_requests_count – возвращает количество необработанных запросов;

· get_lists_wells_set – управление общими группами подписок.

Разработанные хранимые процедуры обеспечивают операции над данными, хранящимися на сервере СУБД. Подробно хранимые процедуры описаны в таблице 9.

Таблица 9

Описание хранимых процедур

Имя процедуры	Параметр	Описание
set_input_monitoring_prefs	IS_MONITORING_ENABLE (входной параметр)	Включение оповещения о задержках ввода данных
CRITICAL_DELAY_PERIOD (входной параметр)	Допустимая задержка ввода данных
MONITOR_OPERATION_TYPE_IDS (входной параметр)	Электронная почта пользователя
get_data_requests_count	CNT (выходной параметр)	Количество необработанных запросов
get_new_events_count	CNT (выходной параметр)	Количество новых Событий

Продолжение табл. 9

Имя процедуры	Параметр	Описание
get_input_monitoring_prefs	IS_MONYTORING_ENABLE (выходной параметр)	Включение оповещения о задержках ввода данных
CRITICAL_DELAY_PERIOD (выходной параметр)	Допустимая задержка ввода данных
EMAIL (выходной параметр)	Электронная почта пользователя
OPERATION_TYPES (выходной параметр)	Список типов операций для подписки
upd_active_events_status	EVENT_ID (входной параметр)	Идентификатор События
STATUS_ID (входной параметр)	Идентификатор нового статуса
get_active_lists_wells	ACTIVE_LISTS (выходной параметр)	Список подписанных групп
del_lists_wells_set	LISTS_ID (входной параметр)	Идентификатор группы
WELL_ID (входной параметр)	Идентификатор удаляемой из группы скважины
add_lists_wells_set	LISTS_ID (входной параметр)	Идентификатор группы
WELL_ID (входной параметр)	Идентификатор новой в группе скважине
NOTE (входной параметр)	Комментарий
get_events	FROM_DATE (входной параметр)	Дата «после»
TO_DATE (входной параметр)	Дата «до»
LISTS_IDS (входной параметр)	Идентификатор подписанной группы
IS_HISTORY (входной параметр)	Признак архивных данных
EVENTS (выходной параметр)	Список Событий

Продолжение табл. 9

Имя процедуры	Параметр	Описание
upd_lists_wells_set_note	LISTS_ID (входной параметр)	Идентификатор группы
WELL_ID (входной параметр)	Идентификатор изменяемой скважины
NOTE (входной параметр)	Новое значение комментариев
IS_ACTIVE (входной параметр)	Новое значение «подписана»
del_lists_wells	LISTS_ID (входной параметр)	Идентификатор удаляемой группы
add_lists_wells	LISTS_ID (выходной параметр)	Идентификатор новой группы
LISTS_NAME (входной параметр)	Название новой группы
upd_lists_wells	LISTS_ID (входной параметр)	Идентификатор обновляемой группы
LISTS_NAME (входной параметр)	Новое имя группы
CDS_STOP (входной параметр)	Новое значение подписки на события остановки скважины
EPOS_DEMOUNT (входной параметр)	Новое значение подписки демонтаж скважины
EPOS_DISASM (входной параметр)	Новое значение подписки разбора скважины
SHARED (входной параметр)	Новое значение «общая группа»
copy_lists_wells	SRC_LISTS_ID (входной параметр)	Идентификатор группы из источника
DST_LISTS_NAME (входной параметр)	Имя группы
DST_LISTS_ID (входной\выходной параметр)	Новый идентификатор группы
NAME_EXISTS (выходной параметр)	Сигнал о совпадении идентификаторов группы

Окончание табл. 9

Имя процедуры	Параметр	Описание
get_data_requests	quality_day_rec_id (входной параметр)	Идентификатор дня качества
data_requests (выходной параметр)	Список запросов
get_lists_wells	IS_OWNER (входной параметр)	Является ли пользователь автором подписки
ALL_SHARED (входной параметр)	Только общие группы
LIST_WELLS (выходной параметр)	Список групп скважин
get_lists_wells_set	LISTS_ID (входной параметр)	Идентификатор группы
LISTS_WELL (выходной параметр)	Список скважин из группы
add_data_request	DATA_REQUEST_ID (выходной параметр)	Идентификатор созданного запроса
QUALITY_DAY_REC_ID (входной параметр)	Идентификатор протокола «Дня качества»
SERVICE_ENTERPRISE_ID (входной параметр)	Идентификатор сервисного предприятия
REQUEST_TYPE_ID (входной параметр)	Идентификатор типа запроса
REQUEST_COMMENT (входной параметр)	Комментарий к запросу
update_data_requests_state	DATA_REQUEST_IDS (входной параметр)	Идентификатор изменяемого запроса
REQUEST_STATE_ID (входной параметр)	Идентификатор нового статуса запроса
rem_data_request	DATA_REQUEST_ID (входной параметр)	Идентификатор удаляемого запроса
get_request_receivers	RESULT (выходной параметр)	Список запросов
SERVICE_ENTERPRISE_ID (входной параметр)	Идентификатор сервисного предприятия

Использование хранимых процедур позволяет снизить нагрузку на компьютерную сеть и упрощает разработку клиентских приложений[8].

Модуль опроса базы данных

Для автоматического опроса базы данных разработан модуль опроса базы данных. Модуль в соответствии с параметрами, приходящими из модулей формирования подписки и модуля формирования запроса, периодически опрашивает сервер о наличии новых оповещений. В случае, когда появляются новые оповещения, модуль дает сигнал в модуль оперативного оповещения о том, что необходимо оповестить пользователя. Модуль содержит класс IdleHandler_MessageNotifications. Класс по созданному в подсистеме связи с СУБД соединению опрашивает каждую минуту сервер базы данных через хранимую процедуру get_data_requests_count о количестве необработанных запросов на коррекцию или дополнение данных и через хранимую процедуру get_new_events_count о новых Событиях. Если возвращаемое той или иной процедурой значение больше нуля, то отправляется соответствующий сигнал в модуль оперативного оповещения.