From 20b2dfccf01e02443100d7490c660f5c93417bd8 Mon Sep 17 00:00:00 2001 From: Timur Date: Sun, 29 Dec 2024 12:25:16 +0300 Subject: [PATCH] added --- .../actual_change_data_from_gir_vu.ktr | 714 +++ ...actual_change_data_from_gir_vu_citizen.ktr | 656 +++ .../metrics/actual_info_sent_to_lk_epgu.ktr | 806 ++++ .../metrics/change_data_from_gir_vu.ktr | 765 +++ .../metrics/change_info_sent_to_lk_epgu.ktr | 809 ++++ .../metrics/imposition_tmp_measures_fin.ktr | 614 +++ .../metrics/imposition_tmp_measures_start.ktr | 787 +++ mappings_old/metrics/info_lk.ktr | 4204 +---------------- mappings_old/metrics/info_lk_fin.ktr | 634 +++ mappings_old/metrics/job_metr.kjb | 794 +++- mappings_old/metrics/personal_info_stat.ktr | 664 +++ .../metrics/records_about_citizen.ktr | 656 +++ mappings_old/metrics/summonses_sign_fin.ktr | 624 +++ mappings_old/metrics/summonses_sign_start.ktr | 795 ++++ 14 files changed, 9427 insertions(+), 4095 deletions(-) create mode 100644 mappings_old/metrics/actual_change_data_from_gir_vu.ktr create mode 100644 mappings_old/metrics/actual_change_data_from_gir_vu_citizen.ktr create mode 100644 mappings_old/metrics/actual_info_sent_to_lk_epgu.ktr create mode 100644 mappings_old/metrics/change_data_from_gir_vu.ktr create mode 100644 mappings_old/metrics/change_info_sent_to_lk_epgu.ktr create mode 100644 mappings_old/metrics/imposition_tmp_measures_fin.ktr create mode 100644 mappings_old/metrics/imposition_tmp_measures_start.ktr create mode 100644 mappings_old/metrics/info_lk_fin.ktr create mode 100644 mappings_old/metrics/personal_info_stat.ktr create mode 100644 mappings_old/metrics/records_about_citizen.ktr create mode 100644 mappings_old/metrics/summonses_sign_fin.ktr create mode 100644 mappings_old/metrics/summonses_sign_start.ktr diff --git a/mappings_old/metrics/actual_change_data_from_gir_vu.ktr b/mappings_old/metrics/actual_change_data_from_gir_vu.ktr new file mode 100644 index 0000000..4a1b19a --- /dev/null +++ b/mappings_old/metrics/actual_change_data_from_gir_vu.ktr @@ -0,0 +1,714 @@ + + + + actual_change_data_from_gir_vu + + + + Normal + / + + + + + + + + + + + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + TRANSNAME + Y + TRANSNAME + + + STATUS + Y + STATUS + + + LINES_READ + Y + LINES_READ + + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + + LINES_UPDATED + Y + LINES_UPDATED + + + + LINES_INPUT + Y + LINES_INPUT + + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + + LINES_REJECTED + Y + LINES_REJECTED + + + + ERRORS + Y + ERRORS + + + STARTDATE + Y + STARTDATE + + + ENDDATE + Y + ENDDATE + + + LOGDATE + Y + LOGDATE + + + DEPDATE + Y + DEPDATE + + + REPLAYDATE + Y + REPLAYDATE + + + LOG_FIELD + Y + LOG_FIELD + + + EXECUTING_SERVER + N + EXECUTING_SERVER + + + EXECUTING_USER + N + EXECUTING_USER + + + CLIENT + N + CLIENT + + + + + +
+ + + + ID_BATCH + Y + ID_BATCH + + + SEQ_NR + Y + SEQ_NR + + + LOGDATE + Y + LOGDATE + + + TRANSNAME + Y + TRANSNAME + + + STEPNAME + Y + STEPNAME + + + STEP_COPY + Y + STEP_COPY + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + INPUT_BUFFER_ROWS + Y + INPUT_BUFFER_ROWS + + + OUTPUT_BUFFER_ROWS + Y + OUTPUT_BUFFER_ROWS + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + LOGGING_OBJECT_TYPE + Y + LOGGING_OBJECT_TYPE + + + OBJECT_NAME + Y + OBJECT_NAME + + + OBJECT_COPY + Y + OBJECT_COPY + + + REPOSITORY_DIRECTORY + Y + REPOSITORY_DIRECTORY + + + FILENAME + Y + FILENAME + + + OBJECT_ID + Y + OBJECT_ID + + + OBJECT_REVISION + Y + OBJECT_REVISION + + + PARENT_CHANNEL_ID + Y + PARENT_CHANNEL_ID + + + ROOT_CHANNEL_ID + Y + ROOT_CHANNEL_ID + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + TRANSNAME + Y + TRANSNAME + + + STEPNAME + Y + STEPNAME + + + STEP_COPY + Y + STEP_COPY + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + LOG_FIELD + N + LOG_FIELD + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + METRICS_DATE + Y + METRICS_DATE + + + METRICS_CODE + Y + METRICS_CODE + + + METRICS_DESCRIPTION + Y + METRICS_DESCRIPTION + + + METRICS_SUBJECT + Y + METRICS_SUBJECT + + + METRICS_TYPE + Y + METRICS_TYPE + + + METRICS_VALUE + Y + METRICS_VALUE + + + + + +
+ + 0.0 + 0.0 + + 10000 + 50 + 50 + N + Y + 50000 + Y + + N + 1000 + 100 + + + + + + + + + - + 2024/12/28 15:01:17.120 + - + 2024/12/28 15:01:17.120 + + N + + + + + ervu-journal + journal-dbhost + POSTGRESQL + Native + journal-dbname + 5432 + journal-dbuser + Encrypted 2be98afc86aa7f2e4cb79ce10db80b9cf + + + + + + FORCE_IDENTIFIERS_TO_LOWERCASE + N + + + FORCE_IDENTIFIERS_TO_UPPERCASE + N + + + IS_CLUSTERED + N + + + PORT_NUMBER + 5432 + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + SUPPORTS_BOOLEAN_DATA_TYPE + Y + + + SUPPORTS_TIMESTAMP_DATA_TYPE + Y + + + USE_POOLING + N + + + + + metrics + metrics-dbhost + POSTGRESQL + Native + metrics-dbname + 7777 + metrics-dbuser + Encrypted 657276755ddceddca104c281979414ab64cc9bacc9 + + + + + + EXTRA_OPTION_POSTGRESQL.stringtype + unspecified + + + FORCE_IDENTIFIERS_TO_LOWERCASE + N + + + FORCE_IDENTIFIERS_TO_UPPERCASE + N + + + IS_CLUSTERED + N + + + PORT_NUMBER + 7777 + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + SUPPORTS_BOOLEAN_DATA_TYPE + Y + + + SUPPORTS_TIMESTAMP_DATA_TYPE + Y + + + USE_POOLING + N + + + + + + Table input + Table output + Y + + + + Table input + TableInput + + Y + + 1 + + none + + + ervu-journal + WITH extracted_data AS ( + SELECT + id, + jsonb_array_elements(diff_by_internal->'updated') AS elem + FROM public.object_history + WHERE jsonb_typeof(diff_by_internal->'updated') = 'array' AND diff_by_internal->'updated' @> '[{"newValue": "1"}]' +), +categorized_updates AS ( + SELECT + id, + CASE + WHEN elem->>'path' ~* '.*svedSemPolozh.*sourceUpdate.*' THEN 'marital_status' -- семейное положение + WHEN elem->>'path' ~* '.*rabotodat.*sourceUpdate.*' OR elem->>'path' ~* '.*trud.*sourceUpdate.*' THEN 'job_information' -- сведения о работе + WHEN elem->>'path' ~* '.*aktRegMZHMVD.*sourceUpdate.*' THEN 'place_of_residence' -- сведения о месте жительства + WHEN elem->>'path' ~* '.*aktRegMPMVD.*sourceUpdate.*' THEN 'stay_details' -- сведения о месте прибывания + WHEN elem->>'path' ~* '.*kolledzh.*sourceUpdate.*' OR elem->>'path' ~* '.*vuz.*sourceUpdate.*' THEN 'study_information' -- сведения о месте учебы + WHEN elem->>'path' ~* '.*robr.*sourceUpdate.*' OR elem->>'path' ~* '.*inobr.*sourceUpdate.*' THEN 'diplon' -- сведения о дипломах + WHEN elem->>'path' ~* '.*sostZdorov.*sourceUpdate.*' THEN 'health_status' -- сведения о состаяний здоровья + WHEN elem->>'path' ~* '.*bs.*sourceUpdate.*' THEN 'FIO' -- сведения о ФИО + ELSE 'other' -- Прочее + END AS update_type + FROM extracted_data + WHERE elem->>'path' ~* '.*sourceUpdate.*' AND elem->>'newValue' = '1' +) + +SELECT + TO_CHAR(NOW() - INTERVAL '1 day', 'YYYY-MM-DD') AS info_date, + '300cee57-2ce7-4b82-847b-bfbe14d6c7ea' AS recruitment_id, + COUNT(*) FILTER (WHERE update_type = 'marital_status') AS marital_status, -- семейное положение + COUNT(*) FILTER (WHERE update_type = 'job_information') AS job_information,-- сведения о работе + COUNT(*) FILTER (WHERE update_type = 'place_of_residence') AS place_of_residence, -- сведения о месте жительства + COUNT(*) FILTER (WHERE update_type = 'stay_details') AS stay_details, -- сведения о месте прибывания + COUNT(*) FILTER (WHERE update_type = 'study_information') AS study_information, -- сведения о месте учебы + COUNT(*) FILTER (WHERE update_type = 'diplon') AS diplon, -- сведения о дипломах + COUNT(*) FILTER (WHERE update_type = 'health_status') AS health_status, -- сведения о состаяний здоровья + COUNT(*) FILTER (WHERE update_type = 'FIO') AS FIO, -- сведения о ФИО + COUNT(*) FILTER (WHERE update_type = 'other') AS other_status -- Прочее +FROM categorized_updates; + 0 + + N + N + N + + + + + + + + + + 224 + 320 + Y + + + + Table output + TableOutput + + Y + + 1 + + none + + + metrics + actualization +
change_data_from_gir_vu
+ 1000 + N + N + Y + Y + N + + N + Y + N + + Y + N + + + + recruitment_id + recruitment_id + + + info_date + info_date + + + count_reg_address + place_of_residence + + + count_place_of_stay + stay_details + + + count_work + job_information + + + count_place_of_study + study_information + + + count_family_status + marital_status + + + count_education + diplon + + + count_renaming + fio + + + count_med_info + health_status + + + count_other + other_status + + + + + + + + + + + + 384 + 320 + Y + + + + + + + N + + diff --git a/mappings_old/metrics/actual_change_data_from_gir_vu_citizen.ktr b/mappings_old/metrics/actual_change_data_from_gir_vu_citizen.ktr new file mode 100644 index 0000000..4e03d11 --- /dev/null +++ b/mappings_old/metrics/actual_change_data_from_gir_vu_citizen.ktr @@ -0,0 +1,656 @@ + + + + actual_change_data_from_gir_vu_citizen + + + + Normal + / + + + + + + + + + + + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + TRANSNAME + Y + TRANSNAME + + + STATUS + Y + STATUS + + + LINES_READ + Y + LINES_READ + + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + + LINES_UPDATED + Y + LINES_UPDATED + + + + LINES_INPUT + Y + LINES_INPUT + + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + + LINES_REJECTED + Y + LINES_REJECTED + + + + ERRORS + Y + ERRORS + + + STARTDATE + Y + STARTDATE + + + ENDDATE + Y + ENDDATE + + + LOGDATE + Y + LOGDATE + + + DEPDATE + Y + DEPDATE + + + REPLAYDATE + Y + REPLAYDATE + + + LOG_FIELD + Y + LOG_FIELD + + + EXECUTING_SERVER + N + EXECUTING_SERVER + + + EXECUTING_USER + N + EXECUTING_USER + + + CLIENT + N + CLIENT + + + + + +
+ + + + ID_BATCH + Y + ID_BATCH + + + SEQ_NR + Y + SEQ_NR + + + LOGDATE + Y + LOGDATE + + + TRANSNAME + Y + TRANSNAME + + + STEPNAME + Y + STEPNAME + + + STEP_COPY + Y + STEP_COPY + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + INPUT_BUFFER_ROWS + Y + INPUT_BUFFER_ROWS + + + OUTPUT_BUFFER_ROWS + Y + OUTPUT_BUFFER_ROWS + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + LOGGING_OBJECT_TYPE + Y + LOGGING_OBJECT_TYPE + + + OBJECT_NAME + Y + OBJECT_NAME + + + OBJECT_COPY + Y + OBJECT_COPY + + + REPOSITORY_DIRECTORY + Y + REPOSITORY_DIRECTORY + + + FILENAME + Y + FILENAME + + + OBJECT_ID + Y + OBJECT_ID + + + OBJECT_REVISION + Y + OBJECT_REVISION + + + PARENT_CHANNEL_ID + Y + PARENT_CHANNEL_ID + + + ROOT_CHANNEL_ID + Y + ROOT_CHANNEL_ID + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + TRANSNAME + Y + TRANSNAME + + + STEPNAME + Y + STEPNAME + + + STEP_COPY + Y + STEP_COPY + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + LOG_FIELD + N + LOG_FIELD + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + METRICS_DATE + Y + METRICS_DATE + + + METRICS_CODE + Y + METRICS_CODE + + + METRICS_DESCRIPTION + Y + METRICS_DESCRIPTION + + + METRICS_SUBJECT + Y + METRICS_SUBJECT + + + METRICS_TYPE + Y + METRICS_TYPE + + + METRICS_VALUE + Y + METRICS_VALUE + + + + + +
+ + 0.0 + 0.0 + + 10000 + 50 + 50 + N + Y + 50000 + Y + + N + 1000 + 100 + + + + + + + + + - + 2024/12/28 15:49:50.896 + - + 2024/12/28 15:49:50.896 + + N + + + + + ervu-journal + journal-dbhost + POSTGRESQL + Native + journal-dbname + 5432 + journal-dbuser + Encrypted 2be98afc86aa7f2e4cb79ce10db80b9cf + + + + + + FORCE_IDENTIFIERS_TO_LOWERCASE + N + + + FORCE_IDENTIFIERS_TO_UPPERCASE + N + + + IS_CLUSTERED + N + + + PORT_NUMBER + 5432 + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + SUPPORTS_BOOLEAN_DATA_TYPE + Y + + + SUPPORTS_TIMESTAMP_DATA_TYPE + Y + + + USE_POOLING + N + + + + + metrics + metrics-dbhost + POSTGRESQL + Native + metrics-dbname + 7777 + metrics-dbuser + Encrypted 657276755ddceddca104c281979414ab64cc9bacc9 + + + + + + EXTRA_OPTION_POSTGRESQL.stringtype + unspecified + + + FORCE_IDENTIFIERS_TO_LOWERCASE + N + + + FORCE_IDENTIFIERS_TO_UPPERCASE + N + + + IS_CLUSTERED + N + + + PORT_NUMBER + 7777 + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + SUPPORTS_BOOLEAN_DATA_TYPE + Y + + + SUPPORTS_TIMESTAMP_DATA_TYPE + Y + + + USE_POOLING + N + + + + + + Table input + Table output + Y + + + + Table input + TableInput + + Y + + 1 + + none + + + ervu-journal + WITH extracted_data AS ( + SELECT + id, + jsonb_array_elements(diff_by_internal->'updated') AS elem + FROM public.object_history + WHERE jsonb_typeof(diff_by_internal->'updated') = 'array' AND diff_by_internal->'updated' @> '[{"newValue": "1"}]' +) +SELECT + TO_CHAR(NOW() - INTERVAL '1 day', 'YYYY-MM-DD') AS info_date, + '300cee57-2ce7-4b82-847b-bfbe14d6c7ea' AS recruitment_id, + COUNT(*) FILTER (WHERE elem->>'path' ~* '.*sourceLastUpdate.*' AND elem->>'newValue' = '1') AS coint -- изменения из ГИР ВУ +FROM extracted_data; + 0 + + N + N + N + + + + + + + + + + 176 + 352 + Y + + + + Table output + TableOutput + + Y + + 1 + + none + + + metrics + actualization +
change_data_from_gir_vu_citizen
+ 1000 + N + N + Y + Y + N + + N + Y + N + + Y + N + + + + recruitment_id + recruitment_id + + + info_date + info_date + + + count_unique_records + coint + + + + + + + + + + + + 368 + 352 + Y + + + + + + + N + + diff --git a/mappings_old/metrics/actual_info_sent_to_lk_epgu.ktr b/mappings_old/metrics/actual_info_sent_to_lk_epgu.ktr new file mode 100644 index 0000000..6db5c68 --- /dev/null +++ b/mappings_old/metrics/actual_info_sent_to_lk_epgu.ktr @@ -0,0 +1,806 @@ + + + + actual_info_sent_to_lk_epgu + + + + Normal + / + + + + + + + + + + + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + TRANSNAME + Y + TRANSNAME + + + STATUS + Y + STATUS + + + LINES_READ + Y + LINES_READ + + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + + LINES_UPDATED + Y + LINES_UPDATED + + + + LINES_INPUT + Y + LINES_INPUT + + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + + LINES_REJECTED + Y + LINES_REJECTED + + + + ERRORS + Y + ERRORS + + + STARTDATE + Y + STARTDATE + + + ENDDATE + Y + ENDDATE + + + LOGDATE + Y + LOGDATE + + + DEPDATE + Y + DEPDATE + + + REPLAYDATE + Y + REPLAYDATE + + + LOG_FIELD + Y + LOG_FIELD + + + EXECUTING_SERVER + N + EXECUTING_SERVER + + + EXECUTING_USER + N + EXECUTING_USER + + + CLIENT + N + CLIENT + + + + + +
+ + + + ID_BATCH + Y + ID_BATCH + + + SEQ_NR + Y + SEQ_NR + + + LOGDATE + Y + LOGDATE + + + TRANSNAME + Y + TRANSNAME + + + STEPNAME + Y + STEPNAME + + + STEP_COPY + Y + STEP_COPY + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + INPUT_BUFFER_ROWS + Y + INPUT_BUFFER_ROWS + + + OUTPUT_BUFFER_ROWS + Y + OUTPUT_BUFFER_ROWS + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + LOGGING_OBJECT_TYPE + Y + LOGGING_OBJECT_TYPE + + + OBJECT_NAME + Y + OBJECT_NAME + + + OBJECT_COPY + Y + OBJECT_COPY + + + REPOSITORY_DIRECTORY + Y + REPOSITORY_DIRECTORY + + + FILENAME + Y + FILENAME + + + OBJECT_ID + Y + OBJECT_ID + + + OBJECT_REVISION + Y + OBJECT_REVISION + + + PARENT_CHANNEL_ID + Y + PARENT_CHANNEL_ID + + + ROOT_CHANNEL_ID + Y + ROOT_CHANNEL_ID + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + TRANSNAME + Y + TRANSNAME + + + STEPNAME + Y + STEPNAME + + + STEP_COPY + Y + STEP_COPY + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + LOG_FIELD + N + LOG_FIELD + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + METRICS_DATE + Y + METRICS_DATE + + + METRICS_CODE + Y + METRICS_CODE + + + METRICS_DESCRIPTION + Y + METRICS_DESCRIPTION + + + METRICS_SUBJECT + Y + METRICS_SUBJECT + + + METRICS_TYPE + Y + METRICS_TYPE + + + METRICS_VALUE + Y + METRICS_VALUE + + + + + +
+ + 0.0 + 0.0 + + 10000 + 50 + 50 + N + Y + 50000 + Y + + N + 1000 + 100 + + + + + + + + + - + 2024/12/28 16:17:51.558 + - + 2024/12/28 16:17:51.558 + + N + + + + + ervu-person-registry + person-dbhost + POSTGRESQL + Native + person-dbname + 4444 + person-dbuser + Encrypted 2be98afc86aa7f2e4cb79ce10db80b9cf + + + + + + FORCE_IDENTIFIERS_TO_LOWERCASE + N + + + FORCE_IDENTIFIERS_TO_UPPERCASE + N + + + IS_CLUSTERED + N + + + PORT_NUMBER + 4444 + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + SUPPORTS_BOOLEAN_DATA_TYPE + Y + + + SUPPORTS_TIMESTAMP_DATA_TYPE + Y + + + USE_POOLING + N + + + + + metrics + metrics-dbhost + POSTGRESQL + Native + metrics-dbname + 7777 + metrics-dbuser + Encrypted 657276755ddceddca104c281979414ab64cc9bacc9 + + + + + + EXTRA_OPTION_POSTGRESQL.stringtype + unspecified + + + FORCE_IDENTIFIERS_TO_LOWERCASE + N + + + FORCE_IDENTIFIERS_TO_UPPERCASE + N + + + IS_CLUSTERED + N + + + PORT_NUMBER + 7777 + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + SUPPORTS_BOOLEAN_DATA_TYPE + Y + + + SUPPORTS_TIMESTAMP_DATA_TYPE + Y + + + USE_POOLING + N + + + + + + Table input + Table output + Y + + + + Table input + TableInput + + Y + + 1 + + none + + + ervu-person-registry + /* +статусы решений +1 - решение сформировано +2 - решение подписано +3 - проект решения отклонен +*/ + + + + +WITH +latest_status AS ( + SELECT + rh.recruit_id, + rh.status, + ROW_NUMBER() OVER (PARTITION BY rh.recruit_id ORDER BY rh.date_time DESC) AS rn, -- последнее изменение статуса + r.source_last_update + FROM public.recruits_history rh + JOIN public.recruit_ervu_status res + ON res.code = rh.status + JOIN public.recruits r + ON r.id = rh.recruit_id + WHERE rh.status IN ( + '16.2', -- Доставлено уведомление в ЛК ЕПГУ + '16.3', -- Ошибка отправки уведомления в ЛК ЕПГУ + '16.4', -- Просмотрено уведомлений в ЛК ЕПГУ + '16.1', -- Отправлено уведомление в ЛК ЕПГУ + '16.5', -- null //value уведомление не сформировано + '16.6', -- null //value уведомление сформировано + '16.7', -- null //value превышено время ожидания отправки уведомления + '16.8' -- null //value превышено время ожидания доставки уведомления + ) + AND r.source_last_update IN ( + '1', -- ГИР ВУ + '2', -- Ручной ввод + '3' -- Заявление с ЕПГУ + -- '4' -- Личный прием + ) +), +main_data AS ( + SELECT + recruit_id, + status, + source_last_update + FROM latest_status + WHERE rn = 1 -- Берем только последнюю запись для каждого recruit_id +), + +gir_vu AS ( + SELECT + COALESCE(COUNT(md.recruit_id) FILTER (WHERE md.status IN ('16.1', '16.2', '16.3', '16.4', '16.6', '16.7', '16.8') AND md.source_last_update = '1'), 0) AS count_status_form, --"Сфоримировано уведомлений в ЛК гражданина" + COALESCE(COUNT(md.recruit_id) FILTER (WHERE md.status IN ('16.1', '16.2', '16.4', '16.8') AND md.source_last_update = '1'), 0) AS count_sended, -- "Отправлено" + COALESCE(COUNT(md.recruit_id) FILTER (WHERE md.status IN ('16.2', '16.4') AND md.source_last_update = '1'), 0) AS count_delivered, -- "Доставлено" + COALESCE(COUNT(md.recruit_id) FILTER (WHERE md.status IN ('16.3') AND md.source_last_update = '1'), 0) AS count_error, -- "Ошибка отправки уведомления" + COALESCE(COUNT(md.recruit_id) FILTER (WHERE md.status IN ('16.4') AND md.source_last_update = '1'), 0) AS count_viewed, -- "Просмотрено", + COALESCE(COUNT(md.recruit_id) FILTER (WHERE md.status IN ('16.2') AND md.source_last_update = '1'), 0) AS count_not_viewed, -- "Не просмотрено", + COALESCE(COUNT(md.recruit_id) FILTER (WHERE md.status IN ('16.5') AND md.source_last_update = '1'), 0) AS count_status_not_formed, -- "Не сформировано" + 'GIR_VU' AS info_source, + TO_CHAR(NOW() - INTERVAL '1 day', 'YYYY-MM-DD') AS info_date, + '300cee57-2ce7-4b82-847b-bfbe14d6c7ea' AS recruitment_id + -- ГИР ВУ + FROM main_data md +), + +epgu AS ( + SELECT + COALESCE(COUNT(md.recruit_id) FILTER (WHERE md.status IN ('16.1', '16.2', '16.3', '16.4', '16.6', '16.7', '16.8') AND md.source_last_update = '3'), 0) AS count_status_form, --"Сфоримировано уведомлений в ЛК гражданина" + COALESCE(COUNT(md.recruit_id) FILTER (WHERE md.status IN ('16.1', '16.2', '16.4', '16.8') AND md.source_last_update = '3'), 0) AS count_sended, -- "Отправлено" + COALESCE(COUNT(md.recruit_id) FILTER (WHERE md.status IN ('16.2', '16.4') AND md.source_last_update = '3'), 0) AS count_delivered, -- "Доставлено" + COALESCE(COUNT(md.recruit_id) FILTER (WHERE md.status IN ('16.3') AND md.source_last_update = '3'), 0) AS count_error, -- "Ошибка отправки уведомления" + COALESCE(COUNT(md.recruit_id) FILTER (WHERE md.status IN ('16.4') AND md.source_last_update = '3'), 0) AS count_viewed, -- "Просмотрено", + COALESCE(COUNT(md.recruit_id) FILTER (WHERE md.status IN ('16.2') AND md.source_last_update = '3'), 0) AS count_not_viewed, -- "Не просмотрено", + COALESCE(COUNT(md.recruit_id) FILTER (WHERE md.status IN ('16.5') AND md.source_last_update = '3'), 0) AS count_status_not_formed, -- "Не сформировано" + 'EPGU' AS info_source, + TO_CHAR(NOW() - INTERVAL '1 day', 'YYYY-MM-DD') AS info_date, + '300cee57-2ce7-4b82-847b-bfbe14d6c7ea' AS recruitment_id + -- ЕПГУ + FROM main_data md +), + +p_v AS ( + SELECT + COALESCE(COUNT(md.recruit_id) FILTER (WHERE md.status IN ('16.1', '16.2', '16.3', '16.4', '16.6', '16.7', '16.8') AND md.source_last_update = '2'), 0) AS count_status_form, --"Сфоримировано уведомлений в ЛК гражданина" + COALESCE(COUNT(md.recruit_id) FILTER (WHERE md.status IN ('16.1', '16.2', '16.4', '16.8') AND md.source_last_update = '2'), 0) AS count_sended, -- "Отправлено" + COALESCE(COUNT(md.recruit_id) FILTER (WHERE md.status IN ('16.2', '16.4') AND md.source_last_update = '2'), 0) AS count_delivered, -- "Доставлено" + COALESCE(COUNT(md.recruit_id) FILTER (WHERE md.status IN ('16.3') AND md.source_last_update = '2'), 0) AS count_error, -- "Ошибка отправки уведомления" + COALESCE(COUNT(md.recruit_id) FILTER (WHERE md.status IN ('16.4') AND md.source_last_update = '2'), 0) AS count_viewed, -- "Просмотрено", + COALESCE(COUNT(md.recruit_id) FILTER (WHERE md.status IN ('16.2') AND md.source_last_update = '2'), 0) AS count_not_viewed, -- "Не просмотрено", + COALESCE(COUNT(md.recruit_id) FILTER (WHERE md.status IN ('16.5') AND md.source_last_update = '2'), 0) AS count_status_not_formed, -- "Не сформировано" + 'PERSONAL_VISIT' AS info_source, + TO_CHAR(NOW() - INTERVAL '1 day', 'YYYY-MM-DD') AS info_date, + '300cee57-2ce7-4b82-847b-bfbe14d6c7ea' AS recruitment_id + -- Ручной ввод (личное посещение) + FROM main_data md +) + +SELECT + info_date, + recruitment_id, + info_source, + count_status_form, + count_sended, + count_delivered, + count_error, + count_viewed, + count_not_viewed, + count_status_not_formed +FROM gir_vu +UNION ALL +SELECT + info_date, + recruitment_id, + info_source, + count_status_form, + count_sended, + count_delivered, + count_error, + count_viewed, + count_not_viewed, + count_status_not_formed +FROM epgu +UNION ALL +SELECT + info_date, + recruitment_id, + info_source, + count_status_form, + count_sended, + count_delivered, + count_error, + count_viewed, + count_not_viewed, + count_status_not_formed +FROM p_v + 0 + + N + N + N + + + + + + + + + + 192 + 192 + Y + + + + Table output + TableOutput + + Y + + 1 + + none + + + metrics + actualization +
info_sent_to_lk_epgu
+ 1000 + N + N + Y + Y + N + + N + Y + N + + Y + N + + + + recruitment_id + recruitment_id + + + info_date + info_date + + + info_source + info_source + + + count_status_formed + count_status_form + + + count_sended + count_sended + + + count_delivered + count_delivered + + + count_error + count_error + + + count_viewed + count_viewed + + + count_not_viewed + count_not_viewed + + + count_status_not_formed + count_status_not_formed + + + + + + + + + + + + 336 + 192 + Y + + + + + + + N + + diff --git a/mappings_old/metrics/change_data_from_gir_vu.ktr b/mappings_old/metrics/change_data_from_gir_vu.ktr new file mode 100644 index 0000000..4955251 --- /dev/null +++ b/mappings_old/metrics/change_data_from_gir_vu.ktr @@ -0,0 +1,765 @@ + + + + change_data_from_gir_vu + + + + Normal + / + + + + + + + + + + + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + TRANSNAME + Y + TRANSNAME + + + STATUS + Y + STATUS + + + LINES_READ + Y + LINES_READ + + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + + LINES_UPDATED + Y + LINES_UPDATED + + + + LINES_INPUT + Y + LINES_INPUT + + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + + LINES_REJECTED + Y + LINES_REJECTED + + + + ERRORS + Y + ERRORS + + + STARTDATE + Y + STARTDATE + + + ENDDATE + Y + ENDDATE + + + LOGDATE + Y + LOGDATE + + + DEPDATE + Y + DEPDATE + + + REPLAYDATE + Y + REPLAYDATE + + + LOG_FIELD + Y + LOG_FIELD + + + EXECUTING_SERVER + N + EXECUTING_SERVER + + + EXECUTING_USER + N + EXECUTING_USER + + + CLIENT + N + CLIENT + + + + + +
+ + + + ID_BATCH + Y + ID_BATCH + + + SEQ_NR + Y + SEQ_NR + + + LOGDATE + Y + LOGDATE + + + TRANSNAME + Y + TRANSNAME + + + STEPNAME + Y + STEPNAME + + + STEP_COPY + Y + STEP_COPY + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + INPUT_BUFFER_ROWS + Y + INPUT_BUFFER_ROWS + + + OUTPUT_BUFFER_ROWS + Y + OUTPUT_BUFFER_ROWS + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + LOGGING_OBJECT_TYPE + Y + LOGGING_OBJECT_TYPE + + + OBJECT_NAME + Y + OBJECT_NAME + + + OBJECT_COPY + Y + OBJECT_COPY + + + REPOSITORY_DIRECTORY + Y + REPOSITORY_DIRECTORY + + + FILENAME + Y + FILENAME + + + OBJECT_ID + Y + OBJECT_ID + + + OBJECT_REVISION + Y + OBJECT_REVISION + + + PARENT_CHANNEL_ID + Y + PARENT_CHANNEL_ID + + + ROOT_CHANNEL_ID + Y + ROOT_CHANNEL_ID + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + TRANSNAME + Y + TRANSNAME + + + STEPNAME + Y + STEPNAME + + + STEP_COPY + Y + STEP_COPY + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + LOG_FIELD + N + LOG_FIELD + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + METRICS_DATE + Y + METRICS_DATE + + + METRICS_CODE + Y + METRICS_CODE + + + METRICS_DESCRIPTION + Y + METRICS_DESCRIPTION + + + METRICS_SUBJECT + Y + METRICS_SUBJECT + + + METRICS_TYPE + Y + METRICS_TYPE + + + METRICS_VALUE + Y + METRICS_VALUE + + + + + +
+ + 0.0 + 0.0 + + 10000 + 50 + 50 + N + Y + 50000 + Y + + N + 1000 + 100 + + + + + + + + + - + 2024/12/28 10:49:28.840 + - + 2024/12/28 10:49:28.840 + + N + + + + + business_metrics_connection + 10.10.31.119 + POSTGRESQL + Native + ervu_business_metrics + 5432 + ervu_business_metrics + Encrypted 657276755ddceddca104c281979414ab64cc9bacc9 + + + + + + EXTRA_OPTION_POSTGRESQL.stringtype + unspecified + + + FORCE_IDENTIFIERS_TO_LOWERCASE + N + + + FORCE_IDENTIFIERS_TO_UPPERCASE + N + + + IS_CLUSTERED + N + + + PORT_NUMBER + 5432 + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + SUPPORTS_BOOLEAN_DATA_TYPE + Y + + + SUPPORTS_TIMESTAMP_DATA_TYPE + Y + + + USE_POOLING + N + + + + + prerson_registry + 10.10.31.118 + POSTGRESQL + Native + ervu-person-registry + 5432 + postgres + Encrypted 2be98afc86aa7f2e4b11ba562feabf7eb + + + + + + FORCE_IDENTIFIERS_TO_LOWERCASE + N + + + FORCE_IDENTIFIERS_TO_UPPERCASE + N + + + IS_CLUSTERED + N + + + PORT_NUMBER + 5432 + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + SUPPORTS_BOOLEAN_DATA_TYPE + Y + + + SUPPORTS_TIMESTAMP_DATA_TYPE + Y + + + USE_POOLING + N + + + + + + Table input + Table output + Y + + + + Table input + TableInput + + Y + + 1 + + none + + + prerson_registry + WITH document_counts AS ( + -- Объединяем все подсчеты для system_document_dto + SELECT + type, + status, + COUNT(*) as count + FROM system_document_dto + WHERE (type = '6' AND status IN ('formed', 'signed')) OR + (type = '5' AND status = 'signed') + GROUP BY type, status +), +decision_counts AS ( + -- Объединяем все подсчеты для decision + SELECT + status->>'code' as status_code, + COUNT(*) as count + FROM decision + WHERE type->>'code' = '7' + AND status->>'code' IN ('1', '2') + GROUP BY status->>'code' +), +requested_files_count AS ( + -- Подсчет для recruit_private_file + SELECT + rfs.code, + COUNT(*) as count + FROM recruit_private_file rpf + JOIN recruit_private_file_status rfs + ON rpf.recruit_private_file_status_id = rfs.id + WHERE rfs.code IN ('requested', 'nonrequested') + AND rpf.extra_info->>'applicationId' IS NULL + GROUP BY rfs.code +) +SELECT + TO_CHAR(NOW() - INTERVAL '1 day', 'YYYY-MM-DD') AS info_date, + '300cee57-2ce7-4b82-847b-bfbe14d6c7ea' AS recruitment_id, + + + -- Базовое количество nonrequested + суммы всех остальных метрик + ( + (SELECT COALESCE(count, 0) FROM requested_files_count WHERE code = 'nonrequested') + + (SELECT COALESCE(count, 0) FROM requested_files_count WHERE code = 'requested') + + (SELECT COALESCE(count, 0) FROM decision_counts WHERE status_code = '1') + + (SELECT COALESCE(count, 0) FROM decision_counts WHERE status_code = '2') + + (SELECT COALESCE(count, 0) FROM document_counts WHERE type = '6' AND status = 'formed') + + (SELECT COALESCE(count, 0) FROM document_counts WHERE type = '6' AND status = 'signed') + + (SELECT COALESCE(count, 0) FROM document_counts WHERE type = '5' AND status = 'signed') + ) AS count_all, + + -- Количество файлов requested с пустым applicationId + ( + (SELECT COALESCE(count, 0) FROM requested_files_count + WHERE code = 'requested')+ + (SELECT COALESCE(count, 0) FROM decision_counts WHERE status_code = '1') + + (SELECT COALESCE(count, 0) FROM decision_counts WHERE status_code = '2') + + (SELECT COALESCE(count, 0) FROM document_counts WHERE type = '6' AND status = 'formed') + + (SELECT COALESCE(count, 0) FROM document_counts WHERE type = '6' AND status = 'signed') + + (SELECT COALESCE(count, 0) FROM document_counts WHERE type = '5' AND status = 'signed') + ) AS requested_files_count, + + -- Количество сформированных решений о направлении + ((SELECT COALESCE(count, 0) FROM decision_counts WHERE status_code = '1') + + (SELECT COALESCE(count, 0) FROM decision_counts WHERE status_code = '2') + + (SELECT COALESCE(count, 0) FROM document_counts WHERE type = '6' AND status = 'formed') + + (SELECT COALESCE(count, 0) FROM document_counts WHERE type = '6' AND status = 'signed') + + (SELECT COALESCE(count, 0) FROM document_counts WHERE type = '5' AND status = 'signed')) AS formed_directions_count, + + + -- Количество подписанных решений о направлении + ((SELECT COALESCE(count, 0) FROM decision_counts WHERE status_code = '1') + + (SELECT COALESCE(count, 0) FROM decision_counts WHERE status_code = '2') + + (SELECT COALESCE(count, 0) FROM document_counts + WHERE type = '6' AND status = 'signed')) AS signed_directions_count, + + -- Количество сформированных и подписанных решений об отклонении + ( SELECT COALESCE(count, 0) FROM document_counts WHERE type = '5' AND status = 'signed') AS rejection_decisions_count, + + + +-- Количество выгруженных дел + 0 as download, + + + -- Количество сформированных решений о постановке + ((SELECT COALESCE(count, 0) FROM decision_counts + WHERE status_code = '1') + + (SELECT COALESCE(count, 0) FROM decision_counts + WHERE status_code = '2')) AS formed_decisions_count, + + -- Количество подписанных решений о постановке + (SELECT COALESCE(count, 0) FROM decision_counts + WHERE status_code = '2') AS signed_decisions_count; + + 0 + + N + N + N + + + + + + + + + + 160 + 352 + Y + + + + Table output + TableOutput + + Y + + 1 + + none + + + business_metrics_connection + registration_change_address +
change_data_from_gir_vu
+ 1000 + N + N + Y + Y + N + + N + Y + N + + Y + N + + + + info_date + info_date + + + recruitment_id + recruitment_id + + + count_all + count_all + + + count_requested_to_send + requested_files_count + + + count_accepted_to_send_from_first + formed_directions_count + + + count_solution_send_signed + signed_directions_count + + + count_unloaded + download + + + count_solutions_registration_formed + formed_decisions_count + + + count_solutions_registration_signed + signed_decisions_count + + + count_denied_requests + rejection_decisions_count + + + + + + + + + + + + 352 + 352 + Y + + + + + + + N + + diff --git a/mappings_old/metrics/change_info_sent_to_lk_epgu.ktr b/mappings_old/metrics/change_info_sent_to_lk_epgu.ktr new file mode 100644 index 0000000..f80898f --- /dev/null +++ b/mappings_old/metrics/change_info_sent_to_lk_epgu.ktr @@ -0,0 +1,809 @@ + + + + change_info_sent_to_lk_epgu + + + + Normal + / + + + + + + + + + + + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + TRANSNAME + Y + TRANSNAME + + + STATUS + Y + STATUS + + + LINES_READ + Y + LINES_READ + + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + + LINES_UPDATED + Y + LINES_UPDATED + + + + LINES_INPUT + Y + LINES_INPUT + + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + + LINES_REJECTED + Y + LINES_REJECTED + + + + ERRORS + Y + ERRORS + + + STARTDATE + Y + STARTDATE + + + ENDDATE + Y + ENDDATE + + + LOGDATE + Y + LOGDATE + + + DEPDATE + Y + DEPDATE + + + REPLAYDATE + Y + REPLAYDATE + + + LOG_FIELD + Y + LOG_FIELD + + + EXECUTING_SERVER + N + EXECUTING_SERVER + + + EXECUTING_USER + N + EXECUTING_USER + + + CLIENT + N + CLIENT + + + + + +
+ + + + ID_BATCH + Y + ID_BATCH + + + SEQ_NR + Y + SEQ_NR + + + LOGDATE + Y + LOGDATE + + + TRANSNAME + Y + TRANSNAME + + + STEPNAME + Y + STEPNAME + + + STEP_COPY + Y + STEP_COPY + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + INPUT_BUFFER_ROWS + Y + INPUT_BUFFER_ROWS + + + OUTPUT_BUFFER_ROWS + Y + OUTPUT_BUFFER_ROWS + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + LOGGING_OBJECT_TYPE + Y + LOGGING_OBJECT_TYPE + + + OBJECT_NAME + Y + OBJECT_NAME + + + OBJECT_COPY + Y + OBJECT_COPY + + + REPOSITORY_DIRECTORY + Y + REPOSITORY_DIRECTORY + + + FILENAME + Y + FILENAME + + + OBJECT_ID + Y + OBJECT_ID + + + OBJECT_REVISION + Y + OBJECT_REVISION + + + PARENT_CHANNEL_ID + Y + PARENT_CHANNEL_ID + + + ROOT_CHANNEL_ID + Y + ROOT_CHANNEL_ID + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + TRANSNAME + Y + TRANSNAME + + + STEPNAME + Y + STEPNAME + + + STEP_COPY + Y + STEP_COPY + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + LOG_FIELD + N + LOG_FIELD + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + METRICS_DATE + Y + METRICS_DATE + + + METRICS_CODE + Y + METRICS_CODE + + + METRICS_DESCRIPTION + Y + METRICS_DESCRIPTION + + + METRICS_SUBJECT + Y + METRICS_SUBJECT + + + METRICS_TYPE + Y + METRICS_TYPE + + + METRICS_VALUE + Y + METRICS_VALUE + + + + + +
+ + 0.0 + 0.0 + + 10000 + 50 + 50 + N + Y + 50000 + Y + + N + 1000 + 100 + + + + + + + + + - + 2024/12/28 03:47:02.160 + - + 2024/12/28 03:47:02.160 + + N + + + + + ervu-person-registry + person-dbhost + POSTGRESQL + Native + person-dbname + 4444 + person-dbuser + Encrypted 2be98afc86aa7f2e4cb79ce10db80b9cf + + + + + + FORCE_IDENTIFIERS_TO_LOWERCASE + N + + + FORCE_IDENTIFIERS_TO_UPPERCASE + N + + + IS_CLUSTERED + N + + + PORT_NUMBER + 4444 + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + SUPPORTS_BOOLEAN_DATA_TYPE + Y + + + SUPPORTS_TIMESTAMP_DATA_TYPE + Y + + + USE_POOLING + N + + + + + metrics + metrics-dbhost + POSTGRESQL + Native + metrics-dbname + 7777 + metrics-dbuser + Encrypted 657276755ddceddca104c281979414ab64cc9bacc9 + + + + + + EXTRA_OPTION_POSTGRESQL.stringtype + unspecified + + + FORCE_IDENTIFIERS_TO_LOWERCASE + N + + + FORCE_IDENTIFIERS_TO_UPPERCASE + N + + + IS_CLUSTERED + N + + + PORT_NUMBER + 7777 + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + SUPPORTS_BOOLEAN_DATA_TYPE + Y + + + SUPPORTS_TIMESTAMP_DATA_TYPE + Y + + + USE_POOLING + N + + + + + + Table input + Table output + Y + + + + Table input + TableInput + + Y + + 1 + + none + + + ervu-person-registry + WITH +latest_status AS ( + SELECT + rh.recruit_id, + rh.status, + ROW_NUMBER() OVER (PARTITION BY rh.recruit_id ORDER BY rh.date_time DESC) AS rn, -- последнее изменение статуса + ROW_NUMBER() OVER (PARTITION BY rh.recruit_id ORDER BY d.decision_date DESC) AS rnd, -- последнее решение + r.source, + d.type->>'code' AS dtype + FROM public.recruits_history rh + JOIN public.recruit_ervu_status res + ON res.code = rh.status + JOIN public.recruits r + ON r.id = rh.recruit_id + JOIN public.sources_recruit sr + ON r.source = sr.code + JOIN public.decision d + ON d.recruit_id = r.id + WHERE rh.status IN ( + '16.2', -- Доставлено уведомление в ЛК ЕПГУ + '16.3', -- Ошибка отправки уведомления в ЛК ЕПГУ + '16.4', -- Просмотрено уведомлений в ЛК ЕПГУ + '16.1', -- Отправлено уведомление в ЛК ЕПГУ + '16.5', -- null //value уведомление не сформировано + '16.6', -- null //value уведомление сформировано + '16.7', -- null //value превышено время ожидания отправки уведомления + '16.8' -- null //value превышено время ожидания доставки уведомления + ) + AND d.status->>'code' = '2' -- статус подписанного решения + AND d.type->>'code' IN ( + -- '9' -- Решение о снятии с учета + '7' -- Постановка на учет при смене адреса + ) + AND r.source IN ( + '1', -- ГИР ВУ + '2', -- Ручной ввод + '3' -- Заявление с ЕПГУ + -- '4' -- Личный прием + ) +), +main_data AS ( + SELECT + recruit_id, + status, + source, + dtype + FROM latest_status + WHERE rn = 1 -- Берем только последнюю запись для каждого recruit_id + AND rnd = 1 +), + +gir_vu AS ( + SELECT + COALESCE(COUNT(md.recruit_id) FILTER (WHERE md.status IN ('16.1', '16.2', '16.3', '16.4', '16.6', '16.7', '16.8') AND md.source = '1'), 0) AS count_status_form, --"Сфоримировано уведомлений в ЛК гражданина" + COALESCE(COUNT(md.recruit_id) FILTER (WHERE md.status IN ('16.1', '16.2', '16.4', '16.8') AND md.source = '1'), 0) AS count_sended, -- "Отправлено" + COALESCE(COUNT(md.recruit_id) FILTER (WHERE md.status IN ('16.2', '16.4') AND md.source = '1'), 0) AS count_delivered, -- "Доставлено" + COALESCE(COUNT(md.recruit_id) FILTER (WHERE md.status IN ('16.3') AND md.source = '1'), 0) AS count_error, -- "Ошибка отправки уведомления" + COALESCE(COUNT(md.recruit_id) FILTER (WHERE md.status IN ('16.4') AND md.source = '1'), 0) AS count_viewed, -- "Просмотрено", + COALESCE(COUNT(md.recruit_id) FILTER (WHERE md.status IN ('16.2') AND md.source = '1'), 0) AS count_not_viewed, -- "Не просмотрено", + COALESCE(COUNT(md.recruit_id) FILTER (WHERE md.status IN ('16.5') AND md.source = '1'), 0) AS count_status_not_formed, -- "Не сформировано" + 'GIR_VU' AS info_source, + TO_CHAR(NOW() - INTERVAL '1 day', 'YYYY-MM-DD') AS info_date, + '300cee57-2ce7-4b82-847b-bfbe14d6c7ea' AS recruitment_id + -- ГИР ВУ + FROM main_data md +), + +epgu AS ( + SELECT + COALESCE(COUNT(md.recruit_id) FILTER (WHERE md.status IN ('16.1', '16.2', '16.3', '16.4', '16.6', '16.7', '16.8') AND md.source = '3'), 0) AS count_status_form, --"Сфоримировано уведомлений в ЛК гражданина" + COALESCE(COUNT(md.recruit_id) FILTER (WHERE md.status IN ('16.1', '16.2', '16.4', '16.8') AND md.source = '3'), 0) AS count_sended, -- "Отправлено" + COALESCE(COUNT(md.recruit_id) FILTER (WHERE md.status IN ('16.2', '16.4') AND md.source = '3'), 0) AS count_delivered, -- "Доставлено" + COALESCE(COUNT(md.recruit_id) FILTER (WHERE md.status IN ('16.3') AND md.source = '3'), 0) AS count_error, -- "Ошибка отправки уведомления" + COALESCE(COUNT(md.recruit_id) FILTER (WHERE md.status IN ('16.4') AND md.source = '3'), 0) AS count_viewed, -- "Просмотрено", + COALESCE(COUNT(md.recruit_id) FILTER (WHERE md.status IN ('16.2') AND md.source = '3'), 0) AS count_not_viewed, -- "Не просмотрено", + COALESCE(COUNT(md.recruit_id) FILTER (WHERE md.status IN ('16.5') AND md.source = '3'), 0) AS count_status_not_formed, -- "Не сформировано" + 'EPGU' AS info_source, + TO_CHAR(NOW() - INTERVAL '1 day', 'YYYY-MM-DD') AS info_date, + '300cee57-2ce7-4b82-847b-bfbe14d6c7ea' AS recruitment_id + -- ЕПГУ + FROM main_data md +), + +p_v AS ( + SELECT + COALESCE(COUNT(md.recruit_id) FILTER (WHERE md.status IN ('16.1', '16.2', '16.3', '16.4', '16.6', '16.7', '16.8') AND md.source = '2'), 0) AS count_status_form, --"Сфоримировано уведомлений в ЛК гражданина" + COALESCE(COUNT(md.recruit_id) FILTER (WHERE md.status IN ('16.1', '16.2', '16.4', '16.8') AND md.source = '2'), 0) AS count_sended, -- "Отправлено" + COALESCE(COUNT(md.recruit_id) FILTER (WHERE md.status IN ('16.2', '16.4') AND md.source = '2'), 0) AS count_delivered, -- "Доставлено" + COALESCE(COUNT(md.recruit_id) FILTER (WHERE md.status IN ('16.3') AND md.source = '2'), 0) AS count_error, -- "Ошибка отправки уведомления" + COALESCE(COUNT(md.recruit_id) FILTER (WHERE md.status IN ('16.4') AND md.source = '2'), 0) AS count_viewed, -- "Просмотрено", + COALESCE(COUNT(md.recruit_id) FILTER (WHERE md.status IN ('16.2') AND md.source = '2'), 0) AS count_not_viewed, -- "Не просмотрено", + COALESCE(COUNT(md.recruit_id) FILTER (WHERE md.status IN ('16.5') AND md.source = '2'), 0) AS count_status_not_formed, -- "Не сформировано" + 'PERSONAL_VISIT' AS info_source, + TO_CHAR(NOW() - INTERVAL '1 day', 'YYYY-MM-DD') AS info_date, + '300cee57-2ce7-4b82-847b-bfbe14d6c7ea' AS recruitment_id + -- Ручной ввод (личное посещение) + FROM main_data md +) + +SELECT + info_date, + recruitment_id, + info_source, + count_status_form, + count_sended, + count_delivered, + count_error, + count_viewed, + count_not_viewed, + count_status_not_formed +FROM gir_vu +UNION ALL +SELECT + info_date, + recruitment_id, + info_source, + count_status_form, + count_sended, + count_delivered, + count_error, + count_viewed, + count_not_viewed, + count_status_not_formed +FROM epgu +UNION ALL +SELECT + info_date, + recruitment_id, + info_source, + count_status_form, + count_sended, + count_delivered, + count_error, + count_viewed, + count_not_viewed, + count_status_not_formed +FROM p_v + 0 + + N + N + N + + + + + + + + + + 160 + 288 + Y + + + + Table output + TableOutput + + Y + + 1 + + none + + + metrics + registration_change_address +
info_sent_to_lk_epgu
+ 1000 + N + N + Y + Y + N + + N + Y + N + + Y + N + + + + recruitment_id + recruitment_id + + + info_date + info_date + + + info_source + info_source + + + count_status_formed + count_status_form + + + count_sended + count_sended + + + count_delivered + count_delivered + + + count_error + count_error + + + count_viewed + count_viewed + + + count_not_viewed + count_not_viewed + + + count_status_not_formed + count_status_not_formed + + + + + + + + + + + + 304 + 288 + Y + + + + + + + N + + diff --git a/mappings_old/metrics/imposition_tmp_measures_fin.ktr b/mappings_old/metrics/imposition_tmp_measures_fin.ktr new file mode 100644 index 0000000..4618f30 --- /dev/null +++ b/mappings_old/metrics/imposition_tmp_measures_fin.ktr @@ -0,0 +1,614 @@ + + + + imposition_tmp_measures_fin + + + + Normal + / + + + + + + + + + + + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + TRANSNAME + Y + TRANSNAME + + + STATUS + Y + STATUS + + + LINES_READ + Y + LINES_READ + + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + + LINES_UPDATED + Y + LINES_UPDATED + + + + LINES_INPUT + Y + LINES_INPUT + + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + + LINES_REJECTED + Y + LINES_REJECTED + + + + ERRORS + Y + ERRORS + + + STARTDATE + Y + STARTDATE + + + ENDDATE + Y + ENDDATE + + + LOGDATE + Y + LOGDATE + + + DEPDATE + Y + DEPDATE + + + REPLAYDATE + Y + REPLAYDATE + + + LOG_FIELD + Y + LOG_FIELD + + + EXECUTING_SERVER + N + EXECUTING_SERVER + + + EXECUTING_USER + N + EXECUTING_USER + + + CLIENT + N + CLIENT + + + + + +
+ + + + ID_BATCH + Y + ID_BATCH + + + SEQ_NR + Y + SEQ_NR + + + LOGDATE + Y + LOGDATE + + + TRANSNAME + Y + TRANSNAME + + + STEPNAME + Y + STEPNAME + + + STEP_COPY + Y + STEP_COPY + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + INPUT_BUFFER_ROWS + Y + INPUT_BUFFER_ROWS + + + OUTPUT_BUFFER_ROWS + Y + OUTPUT_BUFFER_ROWS + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + LOGGING_OBJECT_TYPE + Y + LOGGING_OBJECT_TYPE + + + OBJECT_NAME + Y + OBJECT_NAME + + + OBJECT_COPY + Y + OBJECT_COPY + + + REPOSITORY_DIRECTORY + Y + REPOSITORY_DIRECTORY + + + FILENAME + Y + FILENAME + + + OBJECT_ID + Y + OBJECT_ID + + + OBJECT_REVISION + Y + OBJECT_REVISION + + + PARENT_CHANNEL_ID + Y + PARENT_CHANNEL_ID + + + ROOT_CHANNEL_ID + Y + ROOT_CHANNEL_ID + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + TRANSNAME + Y + TRANSNAME + + + STEPNAME + Y + STEPNAME + + + STEP_COPY + Y + STEP_COPY + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + LOG_FIELD + N + LOG_FIELD + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + METRICS_DATE + Y + METRICS_DATE + + + METRICS_CODE + Y + METRICS_CODE + + + METRICS_DESCRIPTION + Y + METRICS_DESCRIPTION + + + METRICS_SUBJECT + Y + METRICS_SUBJECT + + + METRICS_TYPE + Y + METRICS_TYPE + + + METRICS_VALUE + Y + METRICS_VALUE + + + + + +
+ + 0.0 + 0.0 + + 10000 + 50 + 50 + N + Y + 50000 + Y + + N + 1000 + 100 + + + + + + + + + - + 2024/12/28 03:05:44.136 + - + 2024/12/28 03:05:44.136 + + N + + + + + metrics + metrics-dbhost + POSTGRESQL + Native + metrics-dbname + 7777 + metrics-dbuser + Encrypted 657276755ddceddca104c281979414ab64cc9bacc9 + + + + + + EXTRA_OPTION_POSTGRESQL.stringtype + unspecified + + + FORCE_IDENTIFIERS_TO_LOWERCASE + N + + + FORCE_IDENTIFIERS_TO_UPPERCASE + N + + + IS_CLUSTERED + N + + + PORT_NUMBER + 7777 + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + SUPPORTS_BOOLEAN_DATA_TYPE + Y + + + SUPPORTS_TIMESTAMP_DATA_TYPE + Y + + + USE_POOLING + N + + + + + + Table input + Table output + Y + + + + Table input + TableInput + + Y + + 1 + + none + + + metrics + WITH sources AS ( + SELECT '1' AS source_last_update, 'GIR_VU' AS info_source +) +SELECT + TO_CHAR(NOW() - INTERVAL '1 day', 'YYYY-MM-DD') AS info_date, + stm.recruitment_id as recruitment_id, + s.info_source, + COALESCE(COUNT(stm.support_tmp_meas_id) FILTER ( + WHERE stm.status_applied IN ('11', '10') + ), 0) AS tm_accepted, + COALESCE(COUNT(stm.support_tmp_meas_id) FILTER ( + WHERE stm.status_applied = '10.2' + ), 0) AS tm_cancel +FROM sources s +LEFT JOIN registration_change_address.support_tmp_meas stm + ON stm.source_last_update = s.source_last_update +GROUP BY s.info_source, recruitment_id; + 0 + + N + N + N + + + + + + + + + + 256 + 352 + Y + + + + Table output + TableOutput + + Y + + 1 + + none + + + metrics + registration_change_address +
imposition_tmp_measures
+ 1000 + N + N + Y + Y + N + + N + Y + N + + Y + N + + + + recruitment_id + recruitment_id + + + info_date + info_date + + + count_accepted_in_second + tm_accepted + + + count_refused_in_second + tm_cancel + + + + + + + + + + + + 368 + 352 + Y + + + + + + + N + + diff --git a/mappings_old/metrics/imposition_tmp_measures_start.ktr b/mappings_old/metrics/imposition_tmp_measures_start.ktr new file mode 100644 index 0000000..2bf7413 --- /dev/null +++ b/mappings_old/metrics/imposition_tmp_measures_start.ktr @@ -0,0 +1,787 @@ + + + + imposition_tmp_measures_start + + + + Normal + / + + + + + + + + + + + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + TRANSNAME + Y + TRANSNAME + + + STATUS + Y + STATUS + + + LINES_READ + Y + LINES_READ + + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + + LINES_UPDATED + Y + LINES_UPDATED + + + + LINES_INPUT + Y + LINES_INPUT + + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + + LINES_REJECTED + Y + LINES_REJECTED + + + + ERRORS + Y + ERRORS + + + STARTDATE + Y + STARTDATE + + + ENDDATE + Y + ENDDATE + + + LOGDATE + Y + LOGDATE + + + DEPDATE + Y + DEPDATE + + + REPLAYDATE + Y + REPLAYDATE + + + LOG_FIELD + Y + LOG_FIELD + + + EXECUTING_SERVER + N + EXECUTING_SERVER + + + EXECUTING_USER + N + EXECUTING_USER + + + CLIENT + N + CLIENT + + + + + +
+ + + + ID_BATCH + Y + ID_BATCH + + + SEQ_NR + Y + SEQ_NR + + + LOGDATE + Y + LOGDATE + + + TRANSNAME + Y + TRANSNAME + + + STEPNAME + Y + STEPNAME + + + STEP_COPY + Y + STEP_COPY + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + INPUT_BUFFER_ROWS + Y + INPUT_BUFFER_ROWS + + + OUTPUT_BUFFER_ROWS + Y + OUTPUT_BUFFER_ROWS + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + LOGGING_OBJECT_TYPE + Y + LOGGING_OBJECT_TYPE + + + OBJECT_NAME + Y + OBJECT_NAME + + + OBJECT_COPY + Y + OBJECT_COPY + + + REPOSITORY_DIRECTORY + Y + REPOSITORY_DIRECTORY + + + FILENAME + Y + FILENAME + + + OBJECT_ID + Y + OBJECT_ID + + + OBJECT_REVISION + Y + OBJECT_REVISION + + + PARENT_CHANNEL_ID + Y + PARENT_CHANNEL_ID + + + ROOT_CHANNEL_ID + Y + ROOT_CHANNEL_ID + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + TRANSNAME + Y + TRANSNAME + + + STEPNAME + Y + STEPNAME + + + STEP_COPY + Y + STEP_COPY + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + LOG_FIELD + N + LOG_FIELD + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + METRICS_DATE + Y + METRICS_DATE + + + METRICS_CODE + Y + METRICS_CODE + + + METRICS_DESCRIPTION + Y + METRICS_DESCRIPTION + + + METRICS_SUBJECT + Y + METRICS_SUBJECT + + + METRICS_TYPE + Y + METRICS_TYPE + + + METRICS_VALUE + Y + METRICS_VALUE + + + + + +
+ + 0.0 + 0.0 + + 10000 + 50 + 50 + N + Y + 50000 + Y + + N + 1000 + 100 + + + + + + + + + - + 2024/12/28 02:14:59.427 + - + 2024/12/28 02:14:59.427 + + N + + + + + ervu-person-registry + person-dbhost + POSTGRESQL + Native + person-dbname + 4444 + person-dbuser + Encrypted 2be98afc86aa7f2e4cb79ce10db80b9cf + + + + + + FORCE_IDENTIFIERS_TO_LOWERCASE + N + + + FORCE_IDENTIFIERS_TO_UPPERCASE + N + + + IS_CLUSTERED + N + + + PORT_NUMBER + 4444 + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + SUPPORTS_BOOLEAN_DATA_TYPE + Y + + + SUPPORTS_TIMESTAMP_DATA_TYPE + Y + + + USE_POOLING + N + + + + + metrics + metrics-dbhost + POSTGRESQL + Native + metrics-dbname + 7777 + metrics-dbuser + Encrypted 657276755ddceddca104c281979414ab64cc9bacc9 + + + + + + EXTRA_OPTION_POSTGRESQL.stringtype + unspecified + + + FORCE_IDENTIFIERS_TO_LOWERCASE + N + + + FORCE_IDENTIFIERS_TO_UPPERCASE + N + + + IS_CLUSTERED + N + + + PORT_NUMBER + 7777 + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + SUPPORTS_BOOLEAN_DATA_TYPE + Y + + + SUPPORTS_TIMESTAMP_DATA_TYPE + Y + + + USE_POOLING + N + + + + + subpoena + subpoena-dbhost + POSTGRESQL + Native + subpoena-dbname + 5555 + subpoena-dbuser + Encrypted 2be98afc86aa7f2e4cb79ce10db80b9cf + + + + + + FORCE_IDENTIFIERS_TO_LOWERCASE + N + + + FORCE_IDENTIFIERS_TO_UPPERCASE + N + + + IS_CLUSTERED + N + + + PORT_NUMBER + 5555 + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + SUPPORTS_BOOLEAN_DATA_TYPE + Y + + + SUPPORTS_TIMESTAMP_DATA_TYPE + Y + + + USE_POOLING + N + + + + + + Table input + Merge join + Y + + + Table input 2 + Merge join + Y + + + Merge join + Table output + Y + + + + Table input + TableInput + + Y + + 1 + + none + + + ervu-person-registry + Select + '300cee57-2ce7-4b82-847b-bfbe14d6c7ea' AS recruitment_id, + r.id as id, + source_last_update + -- target_recruitment_id + -- current_recruitment_id +FROM recruits r +JOIN decision d ON d.recruit_id = r.id +WHERE source_last_update in ('1') and type ->> 'code' = '7' and status ->> 'code' = '2' + 0 + + N + N + N + + + + + + + + + + 208 + 144 + Y + + + + Table output + TableOutput + + Y + + 1 + + none + + + metrics + registration_change_address +
support_tmp_meas
+ 1000 + Y + N + Y + Y + N + + N + Y + N + + Y + N + + + + source_last_update + source_last_update + + + status_applied + status_applied + + + recruitment_id + recruitment_id + + + + + + + + + + + + 448 + 224 + Y + + + + Table input 2 + TableInput + + Y + + 1 + + none + + + subpoena + SELECT + s.recruit_id, + status_applied +FROM subpoena s +JOIN subpoena_status ss on ss.id = s.status_id +JOIN restriction_document rd on rd.subpoena_id = s.id +JOIN restriction_document_item rdi on rdi.restriction_document_create_id = rd.id +WHERE status_applied in ('11', '10', '10.2') + 0 + + N + N + N + + + + + + + + + + 208 + 288 + Y + + + + Merge join + MergeJoin + + Y + + 1 + + none + + + LEFT OUTER + Table input + Table input 2 + + id + + + recruit_id + + + + + + + + + + + 336 + 224 + Y + + + + + + + N + + diff --git a/mappings_old/metrics/info_lk.ktr b/mappings_old/metrics/info_lk.ktr index 8ba9c52..470c232 100644 --- a/mappings_old/metrics/info_lk.ktr +++ b/mappings_old/metrics/info_lk.ktr @@ -430,11 +430,62 @@ 2024/12/09 13:25:14.716 - 2024/12/09 13:25:14.716 - + H4sIAAAAAAAAAAMAAAAAAAAAAAA= N + + ervu-person-registry + person-dbhost + POSTGRESQL + Native + person-dbname + 4444 + person-dbuser + Encrypted 2be98afc86aa7f2e4cb79ce10db80b9cf + + + + + + FORCE_IDENTIFIERS_TO_LOWERCASE + N + + + FORCE_IDENTIFIERS_TO_UPPERCASE + N + + + IS_CLUSTERED + N + + + PORT_NUMBER + 4444 + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + SUPPORTS_BOOLEAN_DATA_TYPE + Y + + + SUPPORTS_TIMESTAMP_DATA_TYPE + Y + + + USE_POOLING + N + + + metrics metrics-dbhost @@ -466,7 +517,7 @@ PORT_NUMBER - 5432 + 7777 PRESERVE_RESERVED_WORD_CASE @@ -517,58 +568,7 @@ PORT_NUMBER - 5432 - - - PRESERVE_RESERVED_WORD_CASE - Y - - - QUOTE_ALL_FIELDS - N - - - SUPPORTS_BOOLEAN_DATA_TYPE - Y - - - SUPPORTS_TIMESTAMP_DATA_TYPE - Y - - - USE_POOLING - N - - - - - ervu-person-registry - person-dbhost - POSTGRESQL - Native - person-dbname - 4444 - person-dbuser - Encrypted 2be98afc86aa7f2e4cb79ce10db80b9cf - - - - - - FORCE_IDENTIFIERS_TO_LOWERCASE - N - - - FORCE_IDENTIFIERS_TO_UPPERCASE - N - - - IS_CLUSTERED - N - - - PORT_NUMBER - 5432 + 5555 PRESERVE_RESERVED_WORD_CASE @@ -605,506 +605,10 @@ Merge join - Сфоримировано ув по 1 причине - Y - - - Merge join - Ошибка отправки уведомления по 1 причине - Y - - - Merge join - Просмотрено - Y - - - Merge join - Не просмотрено - Y - - - Merge join - Не сформировано - Y - - - Merge join - Сфоримировано ув по 2 причине - Y - - - Merge join - Сфоримировано ув по 14 причине - Y - - - Merge join - Сфоримировано ув по 21 причине - Y - - - Merge join - Отправлено по1 причине - Y - - - Merge join - Отправлено по 2 причине - Y - - - Merge join - Отправлено по 14 причине - Y - - - Merge join - Отправлено по 21 причине - Y - - - Merge join - Доставлено по 1 причине - Y - - - Merge join - Доставлено по 2 причине - Y - - - Merge join - Доставлено по 14 причине - Y - - - Merge join - Доставлено по 21 причине - Y - - - Merge join - Ошибка отправки уведомления по 2 причине - Y - - - Merge join - Ошибка отправки уведомления по 14 причине - Y - - - Merge join - Ошибка отправки уведомления по 21 причине 2 - Y - - - Merge join - Просмотрено 2 - Y - - - Merge join - Просмотрено 2 2 - Y - - - Merge join - Просмотрено 2 2 2 - Y - - - Merge join - Не просмотрено 2 - Y - - - Merge join - Не просмотрено 3 - Y - - - Merge join - Не сформировано 2 - Y - - - Merge join - Не сформировано 3 - Y - - - Merge join - Не сформировано 4 - Y - - - Просмотрено - Group by 2 2 2 2 - Y - - - Просмотрено 2 - Group by 2 2 2 2 - Y - - - Просмотрено 2 2 - Group by 2 2 2 2 - Y - - - Просмотрено 2 2 2 - Group by 2 2 2 2 - Y - - - Merge join - Не просмотрено 3 2 - Y - - - Не просмотрено - Group by 2 2 2 2 2 - Y - - - Не просмотрено 2 - Group by 2 2 2 2 2 - Y - - - Не просмотрено 3 - Group by 2 2 2 2 2 - Y - - - Не просмотрено 3 2 - Group by 2 2 2 2 2 - Y - - - Не сформировано - Group by 2 2 2 2 2 2 - Y - - - Не сформировано 2 - Group by 2 2 2 2 2 2 - Y - - - Не сформировано 3 - Group by 2 2 2 2 2 2 - Y - - - Не сформировано 4 - Group by 2 2 2 2 2 2 - Y - - - Group by - Merge join 2 - Y - - - Group by 2 - Merge join 2 - Y - - - Сфоримировано ув по 1 причине - Sort rows - Y - - - Sort rows - Group by - Y - - - Сфоримировано ув по 2 причине - Sort rows 2 - Y - - - Sort rows 2 - Group by - Y - - - Сфоримировано ув по 14 причине - Sort rows 3 - Y - - - Sort rows 3 - Group by - Y - - - Сфоримировано ув по 21 причине - Sort rows 4 - Y - - - Sort rows 4 - Group by - Y - - - Отправлено по1 причине - Sort rows 5 - Y - - - Sort rows 5 - Group by 2 - Y - - - Отправлено по 2 причине - Sort rows 6 - Y - - - Sort rows 6 - Group by 2 - Y - - - Отправлено по 14 причине - Sort rows 7 - Y - - - Sort rows 7 - Group by 2 - Y - - - Отправлено по 21 причине - Sort rows 8 - Y - - - Sort rows 8 - Group by 2 - Y - - - Доставлено по 1 причине - Sort rows 9 - Y - - - Sort rows 9 - Group by 2 2 - Y - - - Доставлено по 2 причине - Sort rows 10 - Y - - - Sort rows 10 - Group by 2 2 - Y - - - Доставлено по 14 причине - Sort rows 11 - Y - - - Sort rows 11 - Group by 2 2 - Y - - - Доставлено по 21 причине - Sort rows 12 - Y - - - Sort rows 12 - Group by 2 2 - Y - - - Ошибка отправки уведомления по 1 причине - Sort rows 13 - Y - - - Sort rows 13 - Group by 2 2 2 - Y - - - Ошибка отправки уведомления по 2 причине - Sort rows 14 - Y - - - Sort rows 14 - Group by 2 2 2 - Y - - - Ошибка отправки уведомления по 14 причине - Sort rows 15 - Y - - - Sort rows 15 - Group by 2 2 2 - Y - - - Ошибка отправки уведомления по 21 причине 2 - Sort rows 16 - Y - - - Sort rows 16 - Group by 2 2 2 - Y - - - Group by 2 2 - Merge join 2 2 - Y - - - Group by 2 2 2 - Merge join 2 2 - Y - - - Group by 2 2 2 2 - Merge join 2 2 2 - Y - - - Group by 2 2 2 2 2 - Merge join 2 2 2 - Y - - - Merge join 2 2 2 - Merge join 2 2 3 - Y - - - Group by 2 2 2 2 2 2 - Merge join 2 2 3 - Y - - - Merge join 2 - Merge join 2 2 4 - Y - - - Merge join 2 2 - Merge join 2 2 4 - Y - - - Merge join 2 2 3 - Merge join 2 2 5 - Y - - - Merge join 2 2 4 - Merge join 2 2 5 - Y - - - Merge join 2 2 5 Table output Y - - Table output - TableOutput - - Y - - 1 - - none - - - metrics - summonses_list - info_sent_to_lk_epgu
- 1000 - N - N - Y - Y - N - - N - Y - N - - Y - N - - - - recruitment_id - recruitment_id_2_1 - - - count_delivered - count_delivered - - - summonses_reason_id - summonses_reason_id_3 - - - count_status_formed - count_status_formed - - - count_sended - count_sended - - - count_delivered - count_delivered - - - count_error - count_error - - - count_viewed - count_viewed - - - - - - - - - - - - 1568 - 1088 - Y - - Merge join MergeJoin @@ -1116,7 +620,7 @@ none - FULL OUTER + LEFT OUTER Table input 2 Table input 3 @@ -1134,8 +638,8 @@ - 288 - 960 + 336 + 128 Y @@ -1155,12 +659,28 @@ s.recruit_id, CASE WHEN CAST(sr.code AS INTEGER) IN (101) THEN 1 - WHEN CAST(sr.code AS INTEGER) IN (201, 202, 203, 204, 205, 206, 207, 208, 209, 210, 211) THEN 2 - WHEN CAST(sr.code AS INTEGER) IN (102, 103, 104, 105, 106, 107) THEN 14 + -- WHEN CAST(sr.code AS INTEGER) IN (201, 202, 203, 204, 205, 206, 207, 208, 209, 210, 211) THEN 2 + WHEN CAST(sr.code AS INTEGER) IN (201) THEN 3 + WHEN CAST(sr.code AS INTEGER) IN (202) THEN 4 + WHEN CAST(sr.code AS INTEGER) IN (203) THEN 5 + WHEN CAST(sr.code AS INTEGER) IN (204) THEN 6 + WHEN CAST(sr.code AS INTEGER) IN (205) THEN 7 + WHEN CAST(sr.code AS INTEGER) IN (206) THEN 8 + WHEN CAST(sr.code AS INTEGER) IN (207) THEN 9 + WHEN CAST(sr.code AS INTEGER) IN (208) THEN 10 + WHEN CAST(sr.code AS INTEGER) IN (209) THEN 11 + WHEN CAST(sr.code AS INTEGER) IN (210) THEN 12 + WHEN CAST(sr.code AS INTEGER) IN (211) THEN 13 + -- WHEN CAST(sr.code AS INTEGER) IN (102, 103, 104, 105, 106, 107) THEN 14 + WHEN CAST(sr.code AS INTEGER) IN (102) THEN 15 + WHEN CAST(sr.code AS INTEGER) IN (103) THEN 16 + WHEN CAST(sr.code AS INTEGER) IN (104) THEN 17 + WHEN CAST(sr.code AS INTEGER) IN (105) THEN 18 + WHEN CAST(sr.code AS INTEGER) IN (106) THEN 19 + WHEN CAST(sr.code AS INTEGER) IN (107) THEN 20 WHEN CAST(sr.code AS INTEGER) IN (301) THEN 21 ELSE NULL END AS summonses_reason_id, - TO_CHAR(NOW() - INTERVAL '1 day', 'YYYY-MM-DD') AS info_date, '300cee57-2ce7-4b82-847b-bfbe14d6c7ea' AS recruitment_id FROM public.subpoena s LEFT JOIN public.subpoena_status ss ON ss.id = s.status_id @@ -1179,8 +699,8 @@ LEFT JOIN public.subpoena_reason sr ON s.reason_id = sr.id - 112 - 976 + 208 + 192 Y @@ -1196,30 +716,26 @@ LEFT JOIN public.subpoena_reason sr ON s.reason_id = sr.id ervu-person-registry - -with ordered_status AS ( - select - rh.recruit_id as recruit_id, - rh.status as status, - rh.date_time, - LAG(rh.status) over( - PARTITION BY rh.recruit_id - ORDER BY rh.date_time - ) as prev_status - from recruits_history rh -), -target_status AS ( - SELECT - recruit_id - from ordered_status - WHERE status LIKE '16.%' - AND prev_status = '3' + WITH ordered_status AS ( + SELECT + rh.recruit_id AS recruit_id, + rh.status AS status, + rh.date_time, + ROW_NUMBER() OVER ( + PARTITION BY rh.recruit_id + ORDER BY rh.date_time DESC + ) AS row_num + FROM recruits_history rh + WHERE rh.status IN ('16.1', '16.2', '16.3', '16.4', '16.5', '16.6') ) -SELECT recruit_id, -rec.system_pgs_status +SELECT + rec.id as recruit_id, + os.status AS last_status FROM recruits rec -JOIN target_status on rec.id = recruit_id -WHERE rec.system_pgs_status in ('16.1', '16.2','16.3','16.4', '16.5','16.6') +JOIN ordered_status os ON rec.id = os.recruit_id +WHERE os.row_num = 1 + AND rec.system_pgs_status IN ('3', '3.1'); + 0 N @@ -1234,14 +750,14 @@ WHERE rec.system_pgs_status in ('16.1', '16.2','16.3','16.4', '16.5','16.6') - 128 - 736 + 224 + 32 Y - Сфоримировано ув по 1 причине - FilterRows + Table output + TableOutput Y @@ -1250,2733 +766,35 @@ WHERE rec.system_pgs_status in ('16.1', '16.2','16.3','16.4', '16.5','16.6')none - Sort rows - - - - N - - - N - AND - summonses_reason_id - = - - - constant - Integer - 1 - -1 - 0 - N - ####0;-####0 - - - - N - AND - - - N - system_pgs_status - = - - - constant - String - 16.1 - -1 - -1 - N - - - - - N - OR - system_pgs_status - = - - - constant - String - 16.2 - -1 - -1 - N - - - - - N - OR - system_pgs_status - = - - - constant - String - 16.4 - -1 - -1 - N - - - - - N - OR - system_pgs_status - = - - - constant - String - 16.6 - -1 - -1 - N - ####0;-####0 - - - - - - - - - - - - - - - - - 368 - 320 - Y - - - - Ошибка отправки уведомления по 1 причине - FilterRows - - Y - - 1 - - none - - - Sort rows 13 - - - - N - - - N - system_pgs_status - = - - - constant - String - 16.3 - -1 - -1 - N - - - - - N - AND - summonses_reason_id - = - - - constant - Integer - 1 - -1 - 0 - N - ####0;-####0 - - - - - - - - - - - - - - - 672 - 992 - Y - - - - Просмотрено - FilterRows - - Y - - 1 - - none - - - Group by 2 2 2 2 - - - - N - - - N - system_pgs_status - = - - - constant - String - 16.4 - -1 - -1 - N - # - - - - N - AND - summonses_reason_id - = - - - constant - Integer - 1 - -1 - 0 - N - ####0;-####0 - - - - - - - - - - - - - - - 544 - 1232 - Y - - - - Не просмотрено - FilterRows - - Y - - 1 - - none - - - Group by 2 2 2 2 2 - - - - N - - - N - system_pgs_status - = - - - constant - String - 16.2 - -1 - -1 - N - - - - - N - AND - summonses_reason_id - = - - - constant - Integer - 1 - -1 - 0 - N - ####0;-####0 - - - - - - - - - - - - - - - 672 - 1520 - Y - - - - Не сформировано - FilterRows - - Y - - 1 - - none - - - Group by 2 2 2 2 2 2 - - - - N - - - N - summonses_reason_id - = - - - constant - Integer - 1 - -1 - 0 - N - # - - - - N - AND - system_pgs_status - = - - - constant - String - 16.5 - -1 - -1 - N - - - - - - - - - - - - - - - - 592 - 1776 - Y - - - - Сфоримировано ув по 2 причине - FilterRows - - Y - - 1 - - none - - - Sort rows 2 - - - - N - - - N - AND - summonses_reason_id - = - - - constant - Integer - 2 - -1 - 0 - N - ####0;-####0 - - - - N - AND - - - N - system_pgs_status - = - - - constant - String - 16.1 - -1 - -1 - N - - - - - N - OR - system_pgs_status - = - - - constant - String - 16.2 - -1 - -1 - N - - - - - N - OR - system_pgs_status - = - - - constant - String - 16.4 - -1 - -1 - N - - - - - N - OR - system_pgs_status - = - - - constant - String - 16.6 - -1 - -1 - N - ####0;-####0 - - - - - - - - - - - - - - - - - 384 - 384 - Y - - - - Сфоримировано ув по 14 причине - FilterRows - - Y - - 1 - - none - - - Sort rows 3 - - - - N - - - N - AND - summonses_reason_id - = - - - constant - Integer - 14 - -1 - 0 - N - ####0;-####0 - - - - N - AND - - - N - system_pgs_status - = - - - constant - String - 16.1 - -1 - -1 - N - - - - - N - OR - system_pgs_status - = - - - constant - String - 16.2 - -1 - -1 - N - - - - - N - OR - system_pgs_status - = - - - constant - String - 16.4 - -1 - -1 - N - - - - - N - OR - system_pgs_status - = - - - constant - String - 16.6 - -1 - -1 - N - ####0;-####0 - - - - - - - - - - - - - - - - - 384 - 432 - Y - - - - Сфоримировано ув по 21 причине - FilterRows - - Y - - 1 - - none - - - Sort rows 4 - - - - N - - - N - AND - summonses_reason_id - = - - - constant - Integer - 21 - -1 - 0 - N - ####0;-####0 - - - - N - AND - - - N - system_pgs_status - = - - - constant - String - 16.1 - -1 - -1 - N - - - - - N - OR - system_pgs_status - = - - - constant - String - 16.2 - -1 - -1 - N - - - - - N - OR - system_pgs_status - = - - - constant - String - 16.4 - -1 - -1 - N - - - - - N - OR - system_pgs_status - = - - - constant - String - 16.6 - -1 - -1 - N - ####0;-####0 - - - - - - - - - - - - - - - - - 384 - 496 - Y - - - - Отправлено по1 причине - FilterRows - - Y - - 1 - - none - - - Sort rows 5 - - - - N - - - N - AND - summonses_reason_id - = - - - constant - Integer - 1 - -1 - 0 - N - ####0;-####0 - - - - N - AND - - - N - system_pgs_status - = - - - constant - String - 16.1 - -1 - -1 - N - - - - - N - OR - system_pgs_status - = - - - constant - String - 16.2 - -1 - -1 - N - - - - - N - OR - system_pgs_status - = - - - constant - String - 16.4 - -1 - -1 - N - - - - - - - - - - - - - - - - - - 592 - 480 - Y - - - - Отправлено по 2 причине - FilterRows - - Y - - 1 - - none - - - Sort rows 6 - - - - N - - - N - AND - summonses_reason_id - = - - - constant - Integer - 2 - -1 - 0 - N - ####0;-####0 - - - - N - AND - - - N - system_pgs_status - = - - - constant - String - 16.1 - -1 - -1 - N - - - - - N - OR - system_pgs_status - = - - - constant - String - 16.2 - -1 - -1 - N - - - - - N - OR - system_pgs_status - = - - - constant - String - 16.4 - -1 - -1 - N - - - - - - - - - - - - - - - - - - 592 - 544 - Y - - - - Отправлено по 14 причине - FilterRows - - Y - - 1 - - none - - - Sort rows 7 - - - - N - - - N - AND - summonses_reason_id - = - - - constant - Integer - 14 - -1 - 0 - N - ####0;-####0 - - - - N - AND - - - N - system_pgs_status - = - - - constant - String - 16.1 - -1 - -1 - N - - - - - N - OR - system_pgs_status - = - - - constant - String - 16.2 - -1 - -1 - N - - - - - N - OR - system_pgs_status - = - - - constant - String - 16.4 - -1 - -1 - N - - - - - - - - - - - - - - - - - - 592 - 592 - Y - - - - Отправлено по 21 причине - FilterRows - - Y - - 1 - - none - - - Sort rows 8 - - - - N - - - N - AND - summonses_reason_id - = - - - constant - Integer - 21 - -1 - 0 - N - ####0;-####0 - - - - N - AND - - - N - system_pgs_status - = - - - constant - String - 16.1 - -1 - -1 - N - - - - - N - OR - system_pgs_status - = - - - constant - String - 16.2 - -1 - -1 - N - - - - - N - OR - system_pgs_status - = - - - constant - String - 16.4 - -1 - -1 - N - - - - - - - - - - - - - - - - - - 592 - 640 - Y - - - - Доставлено по 1 причине - FilterRows - - Y - - 1 - - none - - - Sort rows 9 - - - - N - - - N - AND - summonses_reason_id - = - - - constant - Integer - 1 - -1 - 0 - N - ####0;-####0 - - - - N - AND - - - N - OR - system_pgs_status - = - - - constant - String - 16.2 - -1 - -1 - N - - - - - N - OR - system_pgs_status - = - - - constant - String - 16.4 - -1 - -1 - N - - - - - - - - - - - - - - - - - - 528 - 752 - Y - - - - Доставлено по 2 причине - FilterRows - - Y - - 1 - - none - - - Sort rows 10 - - - - N - - - N - AND - summonses_reason_id - = - - - constant - Integer - 2 - -1 - 0 - N - ####0;-####0 - - - - N - AND - - - N - OR - system_pgs_status - = - - - constant - String - 16.2 - -1 - -1 - N - - - - - N - OR - system_pgs_status - = - - - constant - String - 16.4 - -1 - -1 - N - - - - - - - - - - - - - - - - - - 528 - 816 - Y - - - - Доставлено по 14 причине - FilterRows - - Y - - 1 - - none - - - Sort rows 11 - - - - N - - - N - AND - summonses_reason_id - = - - - constant - Integer - 14 - -1 - 0 - N - ####0;-####0 - - - - N - AND - - - N - OR - system_pgs_status - = - - - constant - String - 16.2 - -1 - -1 - N - - - - - N - OR - system_pgs_status - = - - - constant - String - 16.4 - -1 - -1 - N - - - - - - - - - - - - - - - - - - 528 - 880 - Y - - - - Доставлено по 21 причине - FilterRows - - Y - - 1 - - none - - - Sort rows 12 - - - - N - - - N - AND - summonses_reason_id - = - - - constant - Integer - 21 - -1 - 0 - N - ####0;-####0 - - - - N - AND - - - N - OR - system_pgs_status - = - - - constant - String - 16.2 - -1 - -1 - N - - - - - N - OR - system_pgs_status - = - - - constant - String - 16.4 - -1 - -1 - N - - - - - - - - - - - - - - - - - - 528 - 928 - Y - - - - Ошибка отправки уведомления по 2 причине - FilterRows - - Y - - 1 - - none - - - Sort rows 14 - - - - N - - - N - system_pgs_status - = - - - constant - String - 16.3 - -1 - -1 - N - - - - - N - AND - summonses_reason_id - = - - - constant - Integer - 2 - -1 - 0 - N - ####0;-####0 - - - - - - - - - - - - - - - 672 - 1072 - Y - - - - Ошибка отправки уведомления по 14 причине - FilterRows - - Y - - 1 - - none - - - Sort rows 15 - - - - N - - - N - system_pgs_status - = - - - constant - String - 16.3 - -1 - -1 - N - - - - - N - AND - summonses_reason_id - = - - - constant - Integer - 14 - -1 - 0 - N - ####0;-####0 - - - - - - - - - - - - - - - 672 - 1152 - Y - - - - Ошибка отправки уведомления по 21 причине 2 - FilterRows - - Y - - 1 - - none - - - Sort rows 16 - - - - N - - - N - system_pgs_status - = - - - constant - String - 16.3 - -1 - -1 - N - - - - - N - AND - summonses_reason_id - = - - - constant - Integer - 21 - -1 - 0 - N - ####0;-####0 - - - - - - - - - - - - - - - 672 - 1216 - Y - - - - Просмотрено 2 - FilterRows - - Y - - 1 - - none - - - Group by 2 2 2 2 - - - - N - - - N - system_pgs_status - = - - - constant - String - 16.4 - -1 - -1 - N - # - - - - N - AND - summonses_reason_id - = - - - constant - Integer - 2 - -1 - 0 - N - ####0;-####0 - - - - - - - - - - - - - - - 544 - 1296 - Y - - - - Просмотрено 2 2 - FilterRows - - Y - - 1 - - none - - - Group by 2 2 2 2 - - - - N - - - N - system_pgs_status - = - - - constant - String - 16.4 - -1 - -1 - N - # - - - - N - AND - summonses_reason_id - = - - - constant - Integer - 14 - -1 - 0 - N - ####0;-####0 - - - - - - - - - - - - - - - 544 - 1360 - Y - - - - Просмотрено 2 2 2 - FilterRows - - Y - - 1 - - none - - - Group by 2 2 2 2 - - - - N - - - N - system_pgs_status - = - - - constant - String - 16.4 - -1 - -1 - N - # - - - - N - AND - summonses_reason_id - = - - - constant - Integer - 14 - -1 - 0 - N - ####0;-####0 - - - - - - - - - - - - - - - 544 - 1424 - Y - - - - Не просмотрено 2 - FilterRows - - Y - - 1 - - none - - - Group by 2 2 2 2 2 - - - - N - - - N - system_pgs_status - = - - - constant - String - 16.2 - -1 - -1 - N - - - - - N - AND - summonses_reason_id - = - - - constant - Integer - 2 - -1 - 0 - N - ####0;-####0 - - - - - - - - - - - - - - - 672 - 1600 - Y - - - - Не просмотрено 3 - FilterRows - - Y - - 1 - - none - - - Group by 2 2 2 2 2 - - - - N - - - N - system_pgs_status - = - - - constant - String - 16.2 - -1 - -1 - N - - - - - N - AND - summonses_reason_id - = - - - constant - Integer - 14 - -1 - 0 - N - ####0;-####0 - - - - - - - - - - - - - - - 672 - 1664 - Y - - - - Не сформировано 2 - FilterRows - - Y - - 1 - - none - - - Group by 2 2 2 2 2 2 - - - - N - - - N - summonses_reason_id - = - - - constant - Integer - 2 - -1 - 0 - N - # - - - - N - AND - system_pgs_status - = - - - constant - String - 16.5 - -1 - -1 - N - - - - - - - - - - - - - - - - 592 - 1840 - Y - - - - Не сформировано 3 - FilterRows - - Y - - 1 - - none - - - Group by 2 2 2 2 2 2 - - - - N - - - N - summonses_reason_id - = - - - constant - Integer - 14 - -1 - 0 - N - # - - - - N - AND - system_pgs_status - = - - - constant - String - 16.5 - -1 - -1 - N - - - - - - - - - - - - - - - - 592 - 1904 - Y - - - - Не сформировано 4 - FilterRows - - Y - - 1 - - none - - - Group by 2 2 2 2 2 2 - - - - N - - - N - summonses_reason_id - = - - - constant - Integer - 21 - -1 - 0 - N - # - - - - N - AND - system_pgs_status - = - - - constant - String - 16.5 - -1 - -1 - N - - - - - - - - - - - - - - - - 592 - 1968 - Y - - - - Group by - GroupBy - - Y - - 1 - - none - - - N - N - - %%java.io.tmpdir%% - grp - N - - N - - - summonses_reason_id - - - recruitment_id - - + metrics + summonses_list + support_lk
+ 1000 + Y + N + Y + Y + N + + N + Y + N + + Y + N + - count_status_formed - recruit_id - COUNT_ANY - 0 - - - - - - - - - - - - 672 - 416 - Y - - - - Group by 2 - GroupBy - - Y - - 1 - - none - - - N - N - - %%java.io.tmpdir%% - grp - N - - N - - - summonses_reason_id + recruitment_id + recruitment_id - recruitment_id - - - - - count_sended - recruit_id - COUNT_ANY - 0 - - - - - - - - - - - - 768 - 672 - Y - - - - Group by 2 2 - GroupBy - - N - - 1 - - none - - - N - N - - %%java.io.tmpdir%% - grp - N - - N - - - summonses_reason_id + summonses_reason_id + summonses_reason_id - recruitment_id - - - - - count_delivered - recruit_id - COUNT_ANY - 0 - - - - - - - - - - - - 736 - 848 - Y - - - - Group by 2 2 2 - GroupBy - - Y - - 1 - - none - - - N - N - - %%java.io.tmpdir%% - grp - N - - N - - - summonses_reason_id - - - recruitment_id - - - - - count_error - recruit_id - COUNT_ANY - 0 - - - - - - - - - - - - 880 - 1120 - Y - - - - Group by 2 2 2 2 - GroupBy - - Y - - 1 - - none - - - N - N - - %%java.io.tmpdir%% - grp - N - - N - - - summonses_reason_id - - - recruitment_id - - - - - count_viewed - recruit_id - COUNT_ANY - 0 - - - - - - - - - - - - 848 - 1312 - Y - - - - Group by 2 2 2 2 2 - GroupBy - - Y - - 1 - - none - - - N - N - - %%java.io.tmpdir%% - grp - N - - N - - - summonses_reason_id - - - recruitment_id - - - - - count_not_viewed - recruit_id - COUNT_ANY - 0 - - - - - - - - - - - - 848 - 1536 - Y - - - - Не просмотрено 3 2 - FilterRows - - Y - - 1 - - none - - - Group by 2 2 2 2 2 - - - - N - - - N - system_pgs_status - = - - - constant - String - 16.2 - -1 - -1 - N - - - - - N - AND - summonses_reason_id - = - - - constant - Integer - 14 - -1 - 0 - N - ####0;-####0 - - - - - - - - - - - - - - - 672 - 1728 - Y - - - - Group by 2 2 2 2 2 2 - GroupBy - - Y - - 1 - - none - - - N - N - - %%java.io.tmpdir%% - grp - N - - N - - - summonses_reason_id - - - - - count_status_not_formed - recruit_id - COUNT_ANY - 0 - - - - - - - - - - - - 768 - 1888 - Y - - - - Merge join 2 - MergeJoin - - Y - - 1 - - none - - - FULL OUTER - Group by - Group by 2 - - recruitment_id - - - recruitment_id - - - - - - - - - - - 1024 - 800 - Y - - - - Sort rows - SortRows - - Y - - 1 - - none - - - %%java.io.tmpdir%% - out - 1000000 - - N - - N - - - summonses_reason_id - Y - N - N - 0 - N - - - recruitment_id - Y - N - N - 0 - N - - - - - - - - - - - - 496 - 320 - Y - - - - Sort rows 2 - SortRows - - Y - - 1 - - none - - - %%java.io.tmpdir%% - out - 1000000 - - N - - N - - - summonses_reason_id - Y - N - N - 0 - N - - - recruitment_id - Y - N - N - 0 - N + system_pgs_status + last_status @@ -3989,781 +807,7 @@ WHERE rec.system_pgs_status in ('16.1', '16.2','16.3','16.4', '16.5','16.6') 480 - 384 - Y - - - - Sort rows 3 - SortRows - - Y - - 1 - - none - - - %%java.io.tmpdir%% - out - 1000000 - - N - - N - - - summonses_reason_id - Y - N - N - 0 - N - - - recruitment_id - Y - N - N - 0 - N - - - - - - - - - - - - 496 - 416 - Y - - - - Sort rows 4 - SortRows - - Y - - 1 - - none - - - %%java.io.tmpdir%% - out - 1000000 - - N - - N - - - summonses_reason_id - Y - N - N - 0 - N - - - recruitment_id - Y - N - N - 0 - N - - - - - - - - - - - - 480 - 464 - Y - - - - Sort rows 5 - SortRows - - Y - - 1 - - none - - - %%java.io.tmpdir%% - out - 1000000 - - N - - N - - - recruit_id - Y - N - N - 0 - N - - - - - - - - - - - - 688 - 528 - Y - - - - Sort rows 6 - SortRows - - Y - - 1 - - none - - - %%java.io.tmpdir%% - out - 1000000 - - N - - N - - - recruit_id - Y - N - N - 0 - N - - - - - - - - - - - - 688 - 576 - Y - - - - Sort rows 7 - SortRows - - Y - - 1 - - none - - - %%java.io.tmpdir%% - out - 1000000 - - N - - N - - - recruit_id - Y - N - N - 0 - N - - - - - - - - - - - - 688 - 624 - Y - - - - Sort rows 8 - SortRows - - Y - - 1 - - none - - - %%java.io.tmpdir%% - out - 1000000 - - N - - N - - - recruit_id - Y - N - N - 0 - N - - - - - - - - - - - - 688 - 672 - Y - - - - Sort rows 9 - SortRows - - Y - - 1 - - none - - - %%java.io.tmpdir%% - out - 1000000 - - N - - N - - - recruit_id - Y - N - N - 0 - N - - - - - - - - - - - - 624 - 752 - Y - - - - Sort rows 10 - SortRows - - Y - - 1 - - none - - - %%java.io.tmpdir%% - out - 1000000 - - N - - N - - - recruit_id - Y - N - N - 0 - N - - - - - - - - - - - - 624 - 800 - Y - - - - Sort rows 11 - SortRows - - Y - - 1 - - none - - - %%java.io.tmpdir%% - out - 1000000 - - N - - N - - - recruit_id - Y - N - N - 0 - N - - - - - - - - - - - - 624 - 848 - Y - - - - Sort rows 12 - SortRows - - Y - - 1 - - none - - - %%java.io.tmpdir%% - out - 1000000 - - N - - N - - - recruit_id - Y - N - N - 0 - N - - - - - - - - - - - - 624 - 896 - Y - - - - Sort rows 13 - SortRows - - Y - - 1 - - none - - - %%java.io.tmpdir%% - out - 1000000 - - N - - N - - - recruit_id - Y - N - N - 0 - N - - - - - - - - - - - - 768 - 1040 - Y - - - - Sort rows 14 - SortRows - - Y - - 1 - - none - - - %%java.io.tmpdir%% - out - 1000000 - - N - - N - - - recruit_id - Y - N - N - 0 - N - - - - - - - - - - - - 768 - 1088 - Y - - - - Sort rows 15 - SortRows - - Y - - 1 - - none - - - %%java.io.tmpdir%% - out - 1000000 - - N - - N - - - recruit_id - Y - N - N - 0 - N - - - - - - - - - - - - 752 - 1136 - Y - - - - Sort rows 16 - SortRows - - Y - - 1 - - none - - - %%java.io.tmpdir%% - out - 1000000 - - N - - N - - - recruit_id - Y - N - N - 0 - N - - - - - - - - - - - - 768 - 1168 - Y - - - - Merge join 2 2 - MergeJoin - - Y - - 1 - - none - - - FULL OUTER - Group by 2 2 - Group by 2 2 2 - - recruitment_id - - - recruitment_id - - - - - - - - - - - 1056 - 976 - Y - - - - Merge join 2 2 2 - MergeJoin - - Y - - 1 - - none - - - FULL OUTER - Group by 2 2 2 2 - Group by 2 2 2 2 2 - - recruitment_id - - - recruitment_id - - - - - - - - - - - 1040 - 1424 - Y - - - - Merge join 2 2 3 - MergeJoin - - Y - - 1 - - none - - - FULL OUTER - Merge join 2 2 2 - Group by 2 2 2 2 2 2 - - recruitment_id_1 - - - recruitment_id - - - - - - - - - - - 1296 - 1280 - Y - - - - Merge join 2 2 4 - MergeJoin - - Y - - 1 - - none - - - FULL OUTER - Merge join 2 - Merge join 2 2 - - recruitment_id_1 - - - recruitment_id_1 - - - - - - - - - - - 1280 - 960 - Y - - - - Merge join 2 2 5 - MergeJoin - - Y - - 1 - - none - - - FULL OUTER - Merge join 2 2 3 - Merge join 2 2 4 - - recruitment_id_1 - - - recruitment_id_2 - - - - - - - - - - - 1423 - 1105 + 128 Y diff --git a/mappings_old/metrics/info_lk_fin.ktr b/mappings_old/metrics/info_lk_fin.ktr new file mode 100644 index 0000000..8363081 --- /dev/null +++ b/mappings_old/metrics/info_lk_fin.ktr @@ -0,0 +1,634 @@ + + + + info_lk_fin + + + + Normal + / + + + + + + + + + + + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + TRANSNAME + Y + TRANSNAME + + + STATUS + Y + STATUS + + + LINES_READ + Y + LINES_READ + + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + + LINES_UPDATED + Y + LINES_UPDATED + + + + LINES_INPUT + Y + LINES_INPUT + + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + + LINES_REJECTED + Y + LINES_REJECTED + + + + ERRORS + Y + ERRORS + + + STARTDATE + Y + STARTDATE + + + ENDDATE + Y + ENDDATE + + + LOGDATE + Y + LOGDATE + + + DEPDATE + Y + DEPDATE + + + REPLAYDATE + Y + REPLAYDATE + + + LOG_FIELD + Y + LOG_FIELD + + + EXECUTING_SERVER + N + EXECUTING_SERVER + + + EXECUTING_USER + N + EXECUTING_USER + + + CLIENT + N + CLIENT + + + + + +
+ + + + ID_BATCH + Y + ID_BATCH + + + SEQ_NR + Y + SEQ_NR + + + LOGDATE + Y + LOGDATE + + + TRANSNAME + Y + TRANSNAME + + + STEPNAME + Y + STEPNAME + + + STEP_COPY + Y + STEP_COPY + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + INPUT_BUFFER_ROWS + Y + INPUT_BUFFER_ROWS + + + OUTPUT_BUFFER_ROWS + Y + OUTPUT_BUFFER_ROWS + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + LOGGING_OBJECT_TYPE + Y + LOGGING_OBJECT_TYPE + + + OBJECT_NAME + Y + OBJECT_NAME + + + OBJECT_COPY + Y + OBJECT_COPY + + + REPOSITORY_DIRECTORY + Y + REPOSITORY_DIRECTORY + + + FILENAME + Y + FILENAME + + + OBJECT_ID + Y + OBJECT_ID + + + OBJECT_REVISION + Y + OBJECT_REVISION + + + PARENT_CHANNEL_ID + Y + PARENT_CHANNEL_ID + + + ROOT_CHANNEL_ID + Y + ROOT_CHANNEL_ID + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + TRANSNAME + Y + TRANSNAME + + + STEPNAME + Y + STEPNAME + + + STEP_COPY + Y + STEP_COPY + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + LOG_FIELD + N + LOG_FIELD + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + METRICS_DATE + Y + METRICS_DATE + + + METRICS_CODE + Y + METRICS_CODE + + + METRICS_DESCRIPTION + Y + METRICS_DESCRIPTION + + + METRICS_SUBJECT + Y + METRICS_SUBJECT + + + METRICS_TYPE + Y + METRICS_TYPE + + + METRICS_VALUE + Y + METRICS_VALUE + + + + + +
+ + 0.0 + 0.0 + + 10000 + 50 + 50 + N + Y + 50000 + Y + + N + 1000 + 100 + + + + + + + + + - + 2024/12/27 17:35:44.219 + - + 2024/12/27 17:35:44.219 + H4sIAAAAAAAAAAMAAAAAAAAAAAA= + N + + + + + metrics + metrics-dbhost + POSTGRESQL + Native + metrics-dbname + 7777 + metrics-dbuser + Encrypted 657276755ddceddca104c281979414ab64cc9bacc9 + + + + + + EXTRA_OPTION_POSTGRESQL.stringtype + unspecified + + + FORCE_IDENTIFIERS_TO_LOWERCASE + N + + + FORCE_IDENTIFIERS_TO_UPPERCASE + N + + + IS_CLUSTERED + N + + + PORT_NUMBER + 7777 + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + SUPPORTS_BOOLEAN_DATA_TYPE + Y + + + SUPPORTS_TIMESTAMP_DATA_TYPE + Y + + + USE_POOLING + N + + + + + + Table input + Table output + Y + + + + Table input + TableInput + + Y + + 1 + + none + + + metrics + SELECT + summonses_reason_id, + TO_CHAR(NOW() - INTERVAL '1 day', 'YYYY-MM-DD') AS info_date, + recruitment_id, + COALESCE(COUNT(support_lk_id) FILTER (WHERE system_pgs_status in ('16.1', '16.2', '16.4', '16.6')), 0) AS count_status_formed, + COALESCE(COUNT(support_lk_id) FILTER (WHERE system_pgs_status in ('16.1', '16.2', '16.4')), 0) AS count_sended, + COALESCE(COUNT(support_lk_id) FILTER (WHERE system_pgs_status in ( '16.2', '16.4' )), 0) AS count_delivered, + COALESCE(COUNT(support_lk_id) FILTER (WHERE system_pgs_status in ( '16.3' )), 0) AS count_error, + COALESCE(COUNT(support_lk_id) FILTER (WHERE system_pgs_status in ( '16.4' )), 0) AS count_viewed, + COALESCE(COUNT(support_lk_id) FILTER (WHERE system_pgs_status in ( '16.2' )), 0) AS count_not_viewed, + COALESCE(COUNT(support_lk_id) FILTER (WHERE system_pgs_status in ( '16.5' )), 0) AS count_status_not_formed +FROM summonses_list.support_lk +GROUP BY summonses_reason_id, recruitment_id; + 0 + + N + N + N + + + + + + + + + + 208 + 288 + Y + + + + Table output + TableOutput + + Y + + 1 + + none + + + metrics + summonses_list +
info_sent_to_lk_epgu
+ 1000 + N + N + Y + Y + N + + N + Y + N + + Y + N + + + + recruitment_id + recruitment_id + + + info_date + info_date + + + summonses_reason_id + summonses_reason_id + + + count_status_formed + count_status_formed + + + count_sended + count_sended + + + count_delivered + count_delivered + + + count_error + count_error + + + count_viewed + count_viewed + + + count_not_viewed + count_not_viewed + + + count_status_not_formed + count_status_not_formed + + + + + + + + + + + + 368 + 288 + Y + + + + + + + N + + diff --git a/mappings_old/metrics/job_metr.kjb b/mappings_old/metrics/job_metr.kjb index b28a74e..4d51e07 100644 --- a/mappings_old/metrics/job_metr.kjb +++ b/mappings_old/metrics/job_metr.kjb @@ -359,8 +359,8 @@ N Y 0 - 112 - 1072 + 128 + 1488 @@ -759,7 +759,7 @@ N Y 0 - 896 + 1024 768 @@ -1063,7 +1063,18 @@ DELETE FROM metrics.fz_53_appeals; DELETE FROM deregistration.info_sent_to_lk_epgu; DELETE FROM deregistration.solutions; DELETE FROM deregistration.data_from_gir_vu; -DELETE FROM deregistration.removal_registration; +DELETE FROM deregistration.removal_registration; +DELETE FROM registration_change_address.imposition_tmp_measures; +DELETE FROM registration_change_address.info_sent_to_lk_epgu; +DELETE FROM registration_change_address.summonses_sign; +DELETE FROM registration_change_address.personal_info_stat; +DELETE FROM actualization.info_sent_to_lk_epgu; +DELETE FROM actualization.change_data_from_gir_vu; +DELETE FROM actualization.change_data_from_gir_vu_citizen; +DELETE FROM actualization.records_about_citizen; +DELETE FROM registration_change_address.change_data_from_gir_vu; + + F F @@ -1072,8 +1083,8 @@ DELETE FROM deregistration.removal_registration; N Y 0 - 240 - 1072 + 336 + 1968 @@ -1576,6 +1587,570 @@ DELETE FROM deregistration.removal_registration; 1840 + + info_lk_fin + + TRANS + + filename + + ${Internal.Entry.Current.Directory}/info_lk_fin.ktr + + N + N + N + N + N + N + + + N + N + Basic + N + + N + Y + N + N + N + Pentaho local + + Y + + N + Y + 0 + 896 + 768 + + + + imposition_tmp_measures_start + + TRANS + + filename + + ${Internal.Entry.Current.Directory}/imposition_tmp_measures_start.ktr + + N + N + N + N + N + N + + + N + N + Basic + N + + N + Y + N + N + N + Pentaho local + + Y + + N + Y + 0 + 704 + 1920 + + + + imposition_tmp_measures_fin + + TRANS + + filename + + ${Internal.Entry.Current.Directory}/imposition_tmp_measures_fin.ktr + + N + N + N + N + N + N + + + N + N + Basic + N + + N + Y + N + N + N + Pentaho local + + Y + + N + Y + 0 + 896 + 1920 + + + + Success 23 + + SUCCESS + + N + Y + 0 + 1040 + 1920 + + + + change_info_sent_to_lk_epgu + + TRANS + + filename + + ${Internal.Entry.Current.Directory}/change_info_sent_to_lk_epgu.ktr + + N + N + N + N + N + N + + + N + N + Basic + N + + N + Y + N + N + N + Pentaho local + + Y + + N + Y + 0 + 704 + 2000 + + + + Success 24 + + SUCCESS + + N + Y + 0 + 896 + 2000 + + + + summonses_sign_start + + TRANS + + filename + + ${Internal.Entry.Current.Directory}/summonses_sign_start.ktr + + N + N + N + N + N + N + + + N + N + Basic + N + + N + Y + N + N + N + Pentaho local + + Y + + N + Y + 0 + 704 + 2080 + + + + summonses_sign_fin + + TRANS + + filename + + ${Internal.Entry.Current.Directory}/summonses_sign_fin.ktr + + N + N + N + N + N + N + + + N + N + Basic + N + + N + Y + N + N + N + Pentaho local + + Y + + N + Y + 0 + 896 + 2080 + + + + Success 25 + + SUCCESS + + N + Y + 0 + 1040 + 2080 + + + + personal_info_stat + + TRANS + + filename + + ${Internal.Entry.Current.Directory}/personal_info_stat.ktr + + N + N + N + N + N + N + + + N + N + Basic + N + + N + Y + N + N + N + Pentaho local + + Y + + N + Y + 0 + 704 + 2160 + + + + Success 26 + + SUCCESS + + N + Y + 0 + 896 + 2160 + + + + actual_info_sent_to_lk_epgu + + TRANS + + filename + + ${Internal.Entry.Current.Directory}/actual_info_sent_to_lk_epgu.ktr + + N + N + N + N + N + N + + + N + N + Basic + N + + N + Y + N + N + N + Pentaho local + + Y + + N + Y + 0 + 704 + 2240 + + + + Success 27 + + SUCCESS + + N + Y + 0 + 896 + 2240 + + + + actual_change_data_from_gir_vu + + TRANS + + filename + + ${Internal.Entry.Current.Directory}/actual_change_data_from_gir_vu.ktr + + N + N + N + N + N + N + + + N + N + Basic + N + + N + Y + N + N + N + Pentaho local + + Y + + N + Y + 0 + 704 + 2320 + + + + Success 28 + + SUCCESS + + N + Y + 0 + 896 + 2320 + + + + actual_change_data_from_gir_vu_citizen + + TRANS + + filename + + ${Internal.Entry.Current.Directory}/actual_change_data_from_gir_vu_citizen.ktr + + N + N + N + N + N + N + + + N + N + Basic + N + + N + Y + N + N + N + Pentaho local + + Y + + N + Y + 0 + 704 + 2400 + + + + Success 29 + + SUCCESS + + N + Y + 0 + 896 + 2400 + + + + records_about_citizen + + TRANS + + filename + + ${Internal.Entry.Current.Directory}/records_about_citizen.ktr + + N + N + N + N + N + N + + + N + N + Basic + N + + N + Y + N + N + N + Pentaho local + + Y + + N + Y + 0 + 704 + 2480 + + + + Success 30 + + SUCCESS + + N + Y + 0 + 896 + 2480 + + + + change_data_from_gir_vu + + TRANS + + filename + + ${Internal.Entry.Current.Directory}/change_data_from_gir_vu.ktr + + N + N + N + N + N + N + + + N + N + Basic + N + + N + Y + N + N + N + Pentaho local + + Y + + N + Y + 0 + 704 + 2544 + + + + Success 31 + + SUCCESS + + N + Y + 0 + 896 + 2544 + + @@ -1641,15 +2216,6 @@ DELETE FROM deregistration.removal_registration; Y N - - info_lk - Success 8 - 0 - 0 - Y - Y - N - Reesr_visit Success 9 @@ -1983,6 +2549,204 @@ DELETE FROM deregistration.removal_registration; Y N + + info_lk + info_lk_fin + 0 + 0 + Y + Y + N + + + info_lk_fin + Success 8 + 0 + 0 + Y + Y + N + + + SQL + imposition_tmp_measures_start + 0 + 0 + Y + N + Y + + + imposition_tmp_measures_start + imposition_tmp_measures_fin + 0 + 0 + Y + Y + N + + + imposition_tmp_measures_fin + Success 23 + 0 + 0 + Y + Y + N + + + SQL + change_info_sent_to_lk_epgu + 0 + 0 + Y + N + Y + + + change_info_sent_to_lk_epgu + Success 24 + 0 + 0 + Y + Y + N + + + SQL + summonses_sign_start + 0 + 0 + Y + N + Y + + + summonses_sign_start + summonses_sign_fin + 0 + 0 + Y + Y + N + + + summonses_sign_fin + Success 25 + 0 + 0 + Y + Y + N + + + SQL + personal_info_stat + 0 + 0 + Y + N + Y + + + personal_info_stat + Success 26 + 0 + 0 + Y + Y + N + + + SQL + actual_info_sent_to_lk_epgu + 0 + 0 + Y + N + Y + + + actual_info_sent_to_lk_epgu + Success 27 + 0 + 0 + Y + Y + N + + + actual_change_data_from_gir_vu + Success 28 + 0 + 0 + Y + Y + N + + + SQL + actual_change_data_from_gir_vu + 0 + 0 + Y + N + Y + + + SQL + actual_change_data_from_gir_vu_citizen + 0 + 0 + Y + N + Y + + + actual_change_data_from_gir_vu_citizen + Success 29 + 0 + 0 + Y + Y + N + + + records_about_citizen + Success 30 + 0 + 0 + Y + Y + N + + + SQL + records_about_citizen + 0 + 0 + Y + N + Y + + + SQL + change_data_from_gir_vu + 0 + 0 + Y + N + Y + + + change_data_from_gir_vu + Success 31 + 0 + 0 + Y + Y + N + diff --git a/mappings_old/metrics/personal_info_stat.ktr b/mappings_old/metrics/personal_info_stat.ktr new file mode 100644 index 0000000..57ed592 --- /dev/null +++ b/mappings_old/metrics/personal_info_stat.ktr @@ -0,0 +1,664 @@ + + + + personal_info_stat + + + + Normal + / + + + + + + + + + + + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + TRANSNAME + Y + TRANSNAME + + + STATUS + Y + STATUS + + + LINES_READ + Y + LINES_READ + + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + + LINES_UPDATED + Y + LINES_UPDATED + + + + LINES_INPUT + Y + LINES_INPUT + + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + + LINES_REJECTED + Y + LINES_REJECTED + + + + ERRORS + Y + ERRORS + + + STARTDATE + Y + STARTDATE + + + ENDDATE + Y + ENDDATE + + + LOGDATE + Y + LOGDATE + + + DEPDATE + Y + DEPDATE + + + REPLAYDATE + Y + REPLAYDATE + + + LOG_FIELD + Y + LOG_FIELD + + + EXECUTING_SERVER + N + EXECUTING_SERVER + + + EXECUTING_USER + N + EXECUTING_USER + + + CLIENT + N + CLIENT + + + + + +
+ + + + ID_BATCH + Y + ID_BATCH + + + SEQ_NR + Y + SEQ_NR + + + LOGDATE + Y + LOGDATE + + + TRANSNAME + Y + TRANSNAME + + + STEPNAME + Y + STEPNAME + + + STEP_COPY + Y + STEP_COPY + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + INPUT_BUFFER_ROWS + Y + INPUT_BUFFER_ROWS + + + OUTPUT_BUFFER_ROWS + Y + OUTPUT_BUFFER_ROWS + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + LOGGING_OBJECT_TYPE + Y + LOGGING_OBJECT_TYPE + + + OBJECT_NAME + Y + OBJECT_NAME + + + OBJECT_COPY + Y + OBJECT_COPY + + + REPOSITORY_DIRECTORY + Y + REPOSITORY_DIRECTORY + + + FILENAME + Y + FILENAME + + + OBJECT_ID + Y + OBJECT_ID + + + OBJECT_REVISION + Y + OBJECT_REVISION + + + PARENT_CHANNEL_ID + Y + PARENT_CHANNEL_ID + + + ROOT_CHANNEL_ID + Y + ROOT_CHANNEL_ID + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + TRANSNAME + Y + TRANSNAME + + + STEPNAME + Y + STEPNAME + + + STEP_COPY + Y + STEP_COPY + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + LOG_FIELD + N + LOG_FIELD + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + METRICS_DATE + Y + METRICS_DATE + + + METRICS_CODE + Y + METRICS_CODE + + + METRICS_DESCRIPTION + Y + METRICS_DESCRIPTION + + + METRICS_SUBJECT + Y + METRICS_SUBJECT + + + METRICS_TYPE + Y + METRICS_TYPE + + + METRICS_VALUE + Y + METRICS_VALUE + + + + + +
+ + 0.0 + 0.0 + + 10000 + 50 + 50 + N + Y + 50000 + Y + + N + 1000 + 100 + + + + + + + + + - + 2024/12/28 10:39:23.010 + - + 2024/12/28 10:39:23.010 + + N + + + + + ervu-person-registry + person-dbhost + POSTGRESQL + Native + person-dbname + 4444 + person-dbuser + Encrypted 2be98afc86aa7f2e4cb79ce10db80b9cf + + + + + + FORCE_IDENTIFIERS_TO_LOWERCASE + N + + + FORCE_IDENTIFIERS_TO_UPPERCASE + N + + + IS_CLUSTERED + N + + + PORT_NUMBER + 4444 + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + SUPPORTS_BOOLEAN_DATA_TYPE + Y + + + SUPPORTS_TIMESTAMP_DATA_TYPE + Y + + + USE_POOLING + N + + + + + metrics + metrics-dbhost + POSTGRESQL + Native + metrics-dbname + 7777 + metrics-dbuser + Encrypted 657276755ddceddca104c281979414ab64cc9bacc9 + + + + + + EXTRA_OPTION_POSTGRESQL.stringtype + unspecified + + + FORCE_IDENTIFIERS_TO_LOWERCASE + N + + + FORCE_IDENTIFIERS_TO_UPPERCASE + N + + + IS_CLUSTERED + N + + + PORT_NUMBER + 7777 + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + SUPPORTS_BOOLEAN_DATA_TYPE + Y + + + SUPPORTS_TIMESTAMP_DATA_TYPE + Y + + + USE_POOLING + N + + + + + + Table input + Table output + Y + + + + Table input + TableInput + + Y + + 1 + + none + + + ervu-person-registry + SELECT + TO_CHAR(NOW() - INTERVAL '1 day', 'YYYY-MM-DD') AS info_date, + '300cee57-2ce7-4b82-847b-bfbe14d6c7ea' AS recruitment_id, + count(DISTINCT rpf.id) FILTER (WHERE fst.code in ('requested','accepted')) count_unloaded, -- Сформировано/Подписано + count(DISTINCT rpf.id) FILTER (WHERE fst.code in ('cancelled','rejected')) count_refused, -- Отменено/Отклонено + count(DISTINCT rpf.id) FILTER (WHERE fst.code in ('sended','finished')) count_accepted_to_send -- Отправлено по запросу/Обработано +FROM public.recruits rec +JOIN public.recruit_private_file rpf on rec.id = rpf.recruit_id +JOIN public.recruit_private_file_status fst ON fst.id = rpf.recruit_private_file_status_id +JOIN application app ON (rpf.extra_info->>'applicationId')::uuid = app.id -- Отнесение к ЕПГУ определяется наличием заявления +WHERE 1=1 +AND app.reason_code = 'changeVK' -- тип заявления + 0 + + N + N + N + + + + + + + + + + 272 + 320 + Y + + + + Table output + TableOutput + + Y + + 1 + + none + + + metrics + registration_change_address +
personal_info_stat
+ 1000 + N + N + Y + Y + N + + N + Y + N + + Y + N + + + + recruitment_id + recruitment_id + + + info_date + info_date + + + count_refused + count_refused + + + count_unloaded + count_unloaded + + + count_accepted_to_send + count_accepted_to_send + + + + + + + + + + + + 432 + 320 + Y + + + + + + + N + + diff --git a/mappings_old/metrics/records_about_citizen.ktr b/mappings_old/metrics/records_about_citizen.ktr new file mode 100644 index 0000000..919aaac --- /dev/null +++ b/mappings_old/metrics/records_about_citizen.ktr @@ -0,0 +1,656 @@ + + + + records_about_citizen + + + + Normal + / + + + + + + + + + + + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + TRANSNAME + Y + TRANSNAME + + + STATUS + Y + STATUS + + + LINES_READ + Y + LINES_READ + + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + + LINES_UPDATED + Y + LINES_UPDATED + + + + LINES_INPUT + Y + LINES_INPUT + + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + + LINES_REJECTED + Y + LINES_REJECTED + + + + ERRORS + Y + ERRORS + + + STARTDATE + Y + STARTDATE + + + ENDDATE + Y + ENDDATE + + + LOGDATE + Y + LOGDATE + + + DEPDATE + Y + DEPDATE + + + REPLAYDATE + Y + REPLAYDATE + + + LOG_FIELD + Y + LOG_FIELD + + + EXECUTING_SERVER + N + EXECUTING_SERVER + + + EXECUTING_USER + N + EXECUTING_USER + + + CLIENT + N + CLIENT + + + + + +
+ + + + ID_BATCH + Y + ID_BATCH + + + SEQ_NR + Y + SEQ_NR + + + LOGDATE + Y + LOGDATE + + + TRANSNAME + Y + TRANSNAME + + + STEPNAME + Y + STEPNAME + + + STEP_COPY + Y + STEP_COPY + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + INPUT_BUFFER_ROWS + Y + INPUT_BUFFER_ROWS + + + OUTPUT_BUFFER_ROWS + Y + OUTPUT_BUFFER_ROWS + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + LOGGING_OBJECT_TYPE + Y + LOGGING_OBJECT_TYPE + + + OBJECT_NAME + Y + OBJECT_NAME + + + OBJECT_COPY + Y + OBJECT_COPY + + + REPOSITORY_DIRECTORY + Y + REPOSITORY_DIRECTORY + + + FILENAME + Y + FILENAME + + + OBJECT_ID + Y + OBJECT_ID + + + OBJECT_REVISION + Y + OBJECT_REVISION + + + PARENT_CHANNEL_ID + Y + PARENT_CHANNEL_ID + + + ROOT_CHANNEL_ID + Y + ROOT_CHANNEL_ID + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + TRANSNAME + Y + TRANSNAME + + + STEPNAME + Y + STEPNAME + + + STEP_COPY + Y + STEP_COPY + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + LOG_FIELD + N + LOG_FIELD + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + METRICS_DATE + Y + METRICS_DATE + + + METRICS_CODE + Y + METRICS_CODE + + + METRICS_DESCRIPTION + Y + METRICS_DESCRIPTION + + + METRICS_SUBJECT + Y + METRICS_SUBJECT + + + METRICS_TYPE + Y + METRICS_TYPE + + + METRICS_VALUE + Y + METRICS_VALUE + + + + + +
+ + 0.0 + 0.0 + + 10000 + 50 + 50 + N + Y + 50000 + Y + + N + 1000 + 100 + + + + + + + + + - + 2024/12/28 16:03:30.443 + - + 2024/12/28 16:03:30.443 + + N + + + + + ervu-journal + journal-dbhost + POSTGRESQL + Native + journal-dbname + 5432 + journal-dbuser + Encrypted 2be98afc86aa7f2e4cb79ce10db80b9cf + + + + + + FORCE_IDENTIFIERS_TO_LOWERCASE + N + + + FORCE_IDENTIFIERS_TO_UPPERCASE + N + + + IS_CLUSTERED + N + + + PORT_NUMBER + 5432 + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + SUPPORTS_BOOLEAN_DATA_TYPE + Y + + + SUPPORTS_TIMESTAMP_DATA_TYPE + Y + + + USE_POOLING + N + + + + + metrics + metrics-dbhost + POSTGRESQL + Native + metrics-dbname + 7777 + metrics-dbuser + Encrypted 657276755ddceddca104c281979414ab64cc9bacc9 + + + + + + EXTRA_OPTION_POSTGRESQL.stringtype + unspecified + + + FORCE_IDENTIFIERS_TO_LOWERCASE + N + + + FORCE_IDENTIFIERS_TO_UPPERCASE + N + + + IS_CLUSTERED + N + + + PORT_NUMBER + 7777 + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + SUPPORTS_BOOLEAN_DATA_TYPE + Y + + + SUPPORTS_TIMESTAMP_DATA_TYPE + Y + + + USE_POOLING + N + + + + + + Table input + Table output + Y + + + + Table input + TableInput + + Y + + 1 + + none + + + ervu-journal + WITH extracted_data AS ( + SELECT + id, + jsonb_array_elements(diff_by_internal->'updated') AS elem + FROM public.object_history + WHERE jsonb_typeof(diff_by_internal->'updated') = 'array' AND diff_by_internal->'updated' @> '[{"newValue": "6"}]' +) +SELECT + TO_CHAR(NOW() - INTERVAL '1 day', 'YYYY-MM-DD') AS info_date, + '300cee57-2ce7-4b82-847b-bfbe14d6c7ea' AS recruitment_id, + COUNT(*) FILTER (WHERE elem->>'path' ~* '.*sourceLastUpdate.*' AND elem->>'newValue' = '6') AS coint -- изменения вручную +FROM extracted_data; + 0 + + N + N + N + + + + + + + + + + 256 + 224 + Y + + + + Table output + TableOutput + + Y + + 1 + + none + + + metrics + actualization +
records_about_citizen
+ 1000 + N + N + Y + Y + N + + N + Y + N + + Y + N + + + + recruitment_id + recruitment_id + + + info_date + info_date + + + count_records_edit + coint + + + + + + + + + + + + 416 + 224 + Y + + + + + + + N + + diff --git a/mappings_old/metrics/summonses_sign_fin.ktr b/mappings_old/metrics/summonses_sign_fin.ktr new file mode 100644 index 0000000..f242fbe --- /dev/null +++ b/mappings_old/metrics/summonses_sign_fin.ktr @@ -0,0 +1,624 @@ + + + + summonses_sign_fin + + + + Normal + / + + + + + + + + + + + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + TRANSNAME + Y + TRANSNAME + + + STATUS + Y + STATUS + + + LINES_READ + Y + LINES_READ + + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + + LINES_UPDATED + Y + LINES_UPDATED + + + + LINES_INPUT + Y + LINES_INPUT + + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + + LINES_REJECTED + Y + LINES_REJECTED + + + + ERRORS + Y + ERRORS + + + STARTDATE + Y + STARTDATE + + + ENDDATE + Y + ENDDATE + + + LOGDATE + Y + LOGDATE + + + DEPDATE + Y + DEPDATE + + + REPLAYDATE + Y + REPLAYDATE + + + LOG_FIELD + Y + LOG_FIELD + + + EXECUTING_SERVER + N + EXECUTING_SERVER + + + EXECUTING_USER + N + EXECUTING_USER + + + CLIENT + N + CLIENT + + + + + +
+ + + + ID_BATCH + Y + ID_BATCH + + + SEQ_NR + Y + SEQ_NR + + + LOGDATE + Y + LOGDATE + + + TRANSNAME + Y + TRANSNAME + + + STEPNAME + Y + STEPNAME + + + STEP_COPY + Y + STEP_COPY + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + INPUT_BUFFER_ROWS + Y + INPUT_BUFFER_ROWS + + + OUTPUT_BUFFER_ROWS + Y + OUTPUT_BUFFER_ROWS + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + LOGGING_OBJECT_TYPE + Y + LOGGING_OBJECT_TYPE + + + OBJECT_NAME + Y + OBJECT_NAME + + + OBJECT_COPY + Y + OBJECT_COPY + + + REPOSITORY_DIRECTORY + Y + REPOSITORY_DIRECTORY + + + FILENAME + Y + FILENAME + + + OBJECT_ID + Y + OBJECT_ID + + + OBJECT_REVISION + Y + OBJECT_REVISION + + + PARENT_CHANNEL_ID + Y + PARENT_CHANNEL_ID + + + ROOT_CHANNEL_ID + Y + ROOT_CHANNEL_ID + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + TRANSNAME + Y + TRANSNAME + + + STEPNAME + Y + STEPNAME + + + STEP_COPY + Y + STEP_COPY + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + LOG_FIELD + N + LOG_FIELD + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + METRICS_DATE + Y + METRICS_DATE + + + METRICS_CODE + Y + METRICS_CODE + + + METRICS_DESCRIPTION + Y + METRICS_DESCRIPTION + + + METRICS_SUBJECT + Y + METRICS_SUBJECT + + + METRICS_TYPE + Y + METRICS_TYPE + + + METRICS_VALUE + Y + METRICS_VALUE + + + + + +
+ + 0.0 + 0.0 + + 10000 + 50 + 50 + N + Y + 50000 + Y + + N + 1000 + 100 + + + + + + + + + - + 2024/12/28 09:49:45.164 + - + 2024/12/28 09:49:45.164 + + N + + + + + metrics + metrics-dbhost + POSTGRESQL + Native + metrics-dbname + 7777 + metrics-dbuser + Encrypted 657276755ddceddca104c281979414ab64cc9bacc9 + + + + + + EXTRA_OPTION_POSTGRESQL.stringtype + unspecified + + + FORCE_IDENTIFIERS_TO_LOWERCASE + N + + + FORCE_IDENTIFIERS_TO_UPPERCASE + N + + + IS_CLUSTERED + N + + + PORT_NUMBER + 7777 + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + SUPPORTS_BOOLEAN_DATA_TYPE + Y + + + SUPPORTS_TIMESTAMP_DATA_TYPE + Y + + + USE_POOLING + N + + + + + + Table input + Table output + Y + + + + Table input + TableInput + + Y + + 1 + + none + + + metrics + WITH sources AS ( + SELECT '1' AS source_last_update, 'GIR_VU' AS info_source + UNION ALL + SELECT '3' AS source_last_update, 'EPGU' AS info_source +) +SELECT + TO_CHAR(NOW() - INTERVAL '1 day', 'YYYY-MM-DD') AS info_date, + '300cee57-2ce7-4b82-847b-bfbe14d6c7ea' AS recruitment_id, + s.info_source, + COALESCE(COUNT(ss.support_summ_sing_id) FILTER ( + WHERE ss.code = '3.14' AND ss.progress = true AND ss.change_rec = false + ), 0) AS summonses_sign_first_vk, + COALESCE(COUNT(ss.support_summ_sing_id) FILTER ( + WHERE ss.code = '3.14' AND ss.progress = true AND ss.change_rec = true + ), 0) AS summonses_sign_secon_vk, + COALESCE(COUNT(ss.support_summ_sing_id) FILTER ( + WHERE ss.code = '3.8' AND ss.progress = true AND ss.change_rec = true + ), 0) AS not_visit +FROM sources s +LEFT JOIN registration_change_address.support_summ_sing ss + ON ss.source_last_update = s.source_last_update +GROUP BY s.info_source, recruitment_id; + + 0 + + N + N + N + + + + + + + + + + 240 + 272 + Y + + + + Table output + TableOutput + + Y + + 1 + + none + + + metrics + registration_change_address +
summonses_sign
+ 1000 + N + N + Y + Y + N + + N + Y + N + + Y + N + + + + recruitment_id + recruitment_id + + + info_date + info_date + + + info_source + info_source + + + count_refused_in_second + summonses_sign_secon_vk + + + count_accepted_in_second + not_visit + + + + + + + + + + + + 368 + 272 + Y + + + + + + + N + + diff --git a/mappings_old/metrics/summonses_sign_start.ktr b/mappings_old/metrics/summonses_sign_start.ktr new file mode 100644 index 0000000..ee9bda8 --- /dev/null +++ b/mappings_old/metrics/summonses_sign_start.ktr @@ -0,0 +1,795 @@ + + + + summonses_sign_start + + + + Normal + / + + + + + + + + + + + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + TRANSNAME + Y + TRANSNAME + + + STATUS + Y + STATUS + + + LINES_READ + Y + LINES_READ + + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + + LINES_UPDATED + Y + LINES_UPDATED + + + + LINES_INPUT + Y + LINES_INPUT + + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + + LINES_REJECTED + Y + LINES_REJECTED + + + + ERRORS + Y + ERRORS + + + STARTDATE + Y + STARTDATE + + + ENDDATE + Y + ENDDATE + + + LOGDATE + Y + LOGDATE + + + DEPDATE + Y + DEPDATE + + + REPLAYDATE + Y + REPLAYDATE + + + LOG_FIELD + Y + LOG_FIELD + + + EXECUTING_SERVER + N + EXECUTING_SERVER + + + EXECUTING_USER + N + EXECUTING_USER + + + CLIENT + N + CLIENT + + + + + +
+ + + + ID_BATCH + Y + ID_BATCH + + + SEQ_NR + Y + SEQ_NR + + + LOGDATE + Y + LOGDATE + + + TRANSNAME + Y + TRANSNAME + + + STEPNAME + Y + STEPNAME + + + STEP_COPY + Y + STEP_COPY + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + INPUT_BUFFER_ROWS + Y + INPUT_BUFFER_ROWS + + + OUTPUT_BUFFER_ROWS + Y + OUTPUT_BUFFER_ROWS + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + LOGGING_OBJECT_TYPE + Y + LOGGING_OBJECT_TYPE + + + OBJECT_NAME + Y + OBJECT_NAME + + + OBJECT_COPY + Y + OBJECT_COPY + + + REPOSITORY_DIRECTORY + Y + REPOSITORY_DIRECTORY + + + FILENAME + Y + FILENAME + + + OBJECT_ID + Y + OBJECT_ID + + + OBJECT_REVISION + Y + OBJECT_REVISION + + + PARENT_CHANNEL_ID + Y + PARENT_CHANNEL_ID + + + ROOT_CHANNEL_ID + Y + ROOT_CHANNEL_ID + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + TRANSNAME + Y + TRANSNAME + + + STEPNAME + Y + STEPNAME + + + STEP_COPY + Y + STEP_COPY + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + LOG_FIELD + N + LOG_FIELD + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + METRICS_DATE + Y + METRICS_DATE + + + METRICS_CODE + Y + METRICS_CODE + + + METRICS_DESCRIPTION + Y + METRICS_DESCRIPTION + + + METRICS_SUBJECT + Y + METRICS_SUBJECT + + + METRICS_TYPE + Y + METRICS_TYPE + + + METRICS_VALUE + Y + METRICS_VALUE + + + + + +
+ + 0.0 + 0.0 + + 10000 + 50 + 50 + N + Y + 50000 + Y + + N + 1000 + 100 + + + + + + + + + - + 2024/12/28 09:08:36.969 + - + 2024/12/28 09:08:36.969 + + N + + + + + ervu-person-registry + person-dbhost + POSTGRESQL + Native + person-dbname + 4444 + person-dbuser + Encrypted 2be98afc86aa7f2e4cb79ce10db80b9cf + + + + + + FORCE_IDENTIFIERS_TO_LOWERCASE + N + + + FORCE_IDENTIFIERS_TO_UPPERCASE + N + + + IS_CLUSTERED + N + + + PORT_NUMBER + 4444 + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + SUPPORTS_BOOLEAN_DATA_TYPE + Y + + + SUPPORTS_TIMESTAMP_DATA_TYPE + Y + + + USE_POOLING + N + + + + + metrics + metrics-dbhost + POSTGRESQL + Native + metrics-dbname + 7777 + metrics-dbuser + Encrypted 657276755ddceddca104c281979414ab64cc9bacc9 + + + + + + EXTRA_OPTION_POSTGRESQL.stringtype + unspecified + + + FORCE_IDENTIFIERS_TO_LOWERCASE + N + + + FORCE_IDENTIFIERS_TO_UPPERCASE + N + + + IS_CLUSTERED + N + + + PORT_NUMBER + 7777 + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + SUPPORTS_BOOLEAN_DATA_TYPE + Y + + + SUPPORTS_TIMESTAMP_DATA_TYPE + Y + + + USE_POOLING + N + + + + + subpoena + subpoena-dbhost + POSTGRESQL + Native + subpoena-dbname + 5555 + subpoena-dbuser + Encrypted 2be98afc86aa7f2e4cb79ce10db80b9cf + + + + + + FORCE_IDENTIFIERS_TO_LOWERCASE + N + + + FORCE_IDENTIFIERS_TO_UPPERCASE + N + + + IS_CLUSTERED + N + + + PORT_NUMBER + 5555 + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + SUPPORTS_BOOLEAN_DATA_TYPE + Y + + + SUPPORTS_TIMESTAMP_DATA_TYPE + Y + + + USE_POOLING + N + + + + + + Table input + Merge join + Y + + + Table input 2 + Merge join + Y + + + Merge join + Table output + Y + + + + Table input + TableInput + + Y + + 1 + + none + + + ervu-person-registry + Select + '300cee57-2ce7-4b82-847b-bfbe14d6c7ea' AS recruitment_id, + r.id as id, + type ->> 'code' = '7' as progress, + status ->> 'code' = '2' as change_rec, + source_last_update + -- target_recruitment_id + -- current_recruitment_id +FROM recruits r +JOIN decision d ON d.recruit_id = r.id +WHERE source_last_update in ('1','3') + 0 + + N + N + N + + + + + + + + + + 256 + 256 + Y + + + + Table output + TableOutput + + Y + + 1 + + none + + + metrics + registration_change_address +
support_summ_sing
+ 1000 + Y + N + Y + Y + N + + N + Y + N + + Y + N + + + + progress + progress + + + change_rec + change_rec + + + code + code + + + source_last_update + source_last_update + + + recruitment_id + recruitment_id + + + + + + + + + + + + 512 + 320 + Y + + + + Table input 2 + TableInput + + Y + + 1 + + none + + + subpoena + SELECT +s.recruit_id, +ss.code as code +FROM subpoena s +JOIN subpoena_status ss on ss.id = s.status_id +WHERE ss.code in ('3.8', '3.14') + 0 + + N + N + N + + + + + + + + + + 256 + 384 + Y + + + + Merge join + MergeJoin + + Y + + 1 + + none + + + LEFT OUTER + Table input + Table input 2 + + id + + + recruit_id + + + + + + + + + + + 384 + 320 + Y + + + + + + + N + +