diff --git a/mappings/country/job_recruitments_country.kjb b/mappings/country/job_recruitments_country.kjb index 828b05a..8cfe99e 100644 --- a/mappings/country/job_recruitments_country.kjb +++ b/mappings/country/job_recruitments_country.kjb @@ -1316,6 +1316,74 @@ 992 + + recruitment_campaign.appeals + + TRANS + + filename + + ${Internal.Entry.Current.Directory}/recruitment_campaign.appeals.ktr + + N + Y + N + N + N + N + + + N + N + Basic + N + + N + Y + N + N + N + Pentaho local + + Y + + N + Y + 0 + 960 + 1056 + + + + Success 16 + + SUCCESS + + N + Y + 0 + 1136 + 1056 + + + + SQL.reccam.app + + SQL + + DELETE FROM recruitment_campaign.appeals where recruitment_id = '00' + F + F + + F + ervu-dashboard + N + Y + 0 + 768 + 1056 + + @@ -1696,6 +1764,33 @@ Y N + + SQL.reccam.app + recruitment_campaign.appeals + 0 + 0 + Y + Y + N + + + recruitment_campaign.appeals + Success 16 + 0 + 0 + Y + Y + N + + + Start + SQL.reccam.app + 0 + 0 + Y + Y + Y + diff --git a/mappings/country/main_dashboard.recruitment_campaign.ktr b/mappings/country/main_dashboard.recruitment_campaign.ktr index c67da70..fc9fbfa 100644 --- a/mappings/country/main_dashboard.recruitment_campaign.ktr +++ b/mappings/country/main_dashboard.recruitment_campaign.ktr @@ -799,7 +799,8 @@ rdi.applied_date AS ap_date, rdi.id AS rdi_id, ssi.delivery_code AS d_code, - ROW_NUMBER() OVER (PARTITION BY s.id ORDER BY sh.date_time DESC) AS rn -- добавляем строку для получения последнего статуса + s.recruit_id, -- Добавляем recruit_id, если оно существует в таблице s (subpoena) + ROW_NUMBER() OVER (PARTITION BY s.id ORDER BY sh.date_time DESC) AS rn FROM public.subpoena s JOIN public.subpoena_history AS sh ON sh.subpoena_id = s.id JOIN public.subpoena_status AS ss ON ss.id = s.status_id @@ -808,15 +809,14 @@ LEFT JOIN public.restriction_document AS rd ON rd.subpoena_id = s.id LEFT JOIN public.restriction_document_item AS rdi ON rdi.restriction_document_create_id = rd.id LEFT JOIN public.subpoena_send_info AS ssi ON ssi.subpoena_id = s.id - WHERE sr.type = '1' -- от 18 до 30 лет и нет отсрочки (нужны эти условия), резделение весна/осень + WHERE sr.type = '1' + AND EXTRACT(YEAR FROM AGE(s.date_birth)) BETWEEN 18 AND 30 ), --- фильтруем только последние статусы для каждой повестки last_status AS ( SELECT * FROM subpoena_data - WHERE rn = 1 -- выбираем только последнюю запись для каждой повестки + WHERE rn = 1 ), --- Подсчет различных метрик t1 AS ( SELECT COUNT(DISTINCT subpoena_id) AS count_subpoena FROM last_status @@ -825,12 +825,16 @@ t1 AS ( t2 AS ( SELECT COUNT(DISTINCT subpoena_id) AS count_appeared FROM last_status - WHERE sub_stat_hist = '4.1' OR sub_stat_hist = '4.2' + WHERE sub_stat_hist IN ('4.1', '4.2') ), t3 AS ( SELECT COUNT(DISTINCT subpoena_id) AS count_not_appeared FROM last_status WHERE sub_stat_hist = '5' +), +t4 AS ( + SELECT COUNT(DISTINCT recruit_id) AS new_recruits + FROM subpoena_data ) SELECT t1.count_subpoena, @@ -838,17 +842,18 @@ SELECT t3.count_not_appeared, ROUND(count_appeared * 100.0 / NULLIF(count_subpoena, 0), 2) AS appeared_on_subpoenas_percent, ROUND(count_not_appeared * 100.0 / NULLIF(count_subpoena, 0), 2) AS not_appeared_on_subpoenas_percent, - 0 as new_recruits, - 0 as postponement_have_right, - 0 as postponement_granted, - 0 as postponement_have_right_percent, - 0 as postponement_granted_percent, - 'Весна' as spring_autumn, + t4.new_recruits, + 0 AS postponement_have_right, + 0 AS postponement_granted, + 0 AS postponement_have_right_percent, + 0 AS postponement_granted_percent, + 'Весна' AS spring_autumn, '00' AS recruitment_id, 1 AS org FROM t1 -FULL OUTER JOIN t2 ON 1 = 1 -FULL OUTER JOIN t3 ON 1 = 1; +JOIN t2 ON true +JOIN t3 ON true +JOIN t4 ON true; 0 N @@ -892,7 +897,8 @@ FULL OUTER JOIN t3 ON 1 = 1; rdi.applied_date AS ap_date, rdi.id AS rdi_id, ssi.delivery_code AS d_code, - ROW_NUMBER() OVER (PARTITION BY s.id ORDER BY sh.date_time DESC) AS rn -- добавляем строку для получения последнего статуса + s.recruit_id, -- Добавляем recruit_id, если оно существует в таблице s (subpoena) + ROW_NUMBER() OVER (PARTITION BY s.id ORDER BY sh.date_time DESC) AS rn FROM public.subpoena s JOIN public.subpoena_history AS sh ON sh.subpoena_id = s.id JOIN public.subpoena_status AS ss ON ss.id = s.status_id @@ -901,15 +907,14 @@ FULL OUTER JOIN t3 ON 1 = 1; LEFT JOIN public.restriction_document AS rd ON rd.subpoena_id = s.id LEFT JOIN public.restriction_document_item AS rdi ON rdi.restriction_document_create_id = rd.id LEFT JOIN public.subpoena_send_info AS ssi ON ssi.subpoena_id = s.id - WHERE sr.type = '1' -- от 18 до 30 лет и нет отсрочки (нужны эти условия), резделение весна/осень + WHERE sr.type = '1' + AND EXTRACT(YEAR FROM AGE(s.date_birth)) BETWEEN 18 AND 30 ), --- фильтруем только последние статусы для каждой повестки last_status AS ( SELECT * FROM subpoena_data - WHERE rn = 1 -- выбираем только последнюю запись для каждой повестки + WHERE rn = 1 ), --- Подсчет различных метрик t1 AS ( SELECT COUNT(DISTINCT subpoena_id) AS count_subpoena FROM last_status @@ -918,12 +923,16 @@ t1 AS ( t2 AS ( SELECT COUNT(DISTINCT subpoena_id) AS count_appeared FROM last_status - WHERE sub_stat_hist = '4.1' OR sub_stat_hist = '4.2' + WHERE sub_stat_hist IN ('4.1', '4.2') ), t3 AS ( SELECT COUNT(DISTINCT subpoena_id) AS count_not_appeared FROM last_status WHERE sub_stat_hist = '5' +), +t4 AS ( + SELECT COUNT(DISTINCT recruit_id) AS new_recruits + FROM subpoena_data ) SELECT t1.count_subpoena, @@ -931,17 +940,18 @@ SELECT t3.count_not_appeared, ROUND(count_appeared * 100.0 / NULLIF(count_subpoena, 0), 2) AS appeared_on_subpoenas_percent, ROUND(count_not_appeared * 100.0 / NULLIF(count_subpoena, 0), 2) AS not_appeared_on_subpoenas_percent, - 0 as new_recruits, - 0 as postponement_have_right, - 0 as postponement_granted, - 0 as postponement_have_right_percent, - 0 as postponement_granted_percent, - 'Осень' as spring_autumn, + t4.new_recruits, + 0 AS postponement_have_right, + 0 AS postponement_granted, + 0 AS postponement_have_right_percent, + 0 AS postponement_granted_percent, + 'Осень' AS spring_autumn, '00' AS recruitment_id, 1 AS org FROM t1 -FULL OUTER JOIN t2 ON 1 = 1 -FULL OUTER JOIN t3 ON 1 = 1; +JOIN t2 ON true +JOIN t3 ON true +JOIN t4 ON true; 0 N diff --git a/mappings/country/main_dashboard.total_registered.ktr b/mappings/country/main_dashboard.total_registered.ktr index b5700a3..b3b26c1 100644 --- a/mappings/country/main_dashboard.total_registered.ktr +++ b/mappings/country/main_dashboard.total_registered.ktr @@ -645,8 +645,8 @@ - 1008 - 512 + 864 + 368 Y @@ -662,21 +662,39 @@ postgres.person_registry - SELECT - COUNT(*) AS total_count, - COUNT(*) FILTER (WHERE gender = 'MALE') AS male_count, - COUNT(*) FILTER (WHERE gender = 'FEMALE') AS female_count, + WITH recruit_data AS ( + SELECT + COUNT(*) AS total_count, + COUNT(*) FILTER (WHERE gender = 'MALE') AS male_count, + COUNT(*) FILTER (WHERE gender = 'FEMALE') AS female_count, + COUNT(*) FILTER ( + WHERE (EXTRACT(YEAR FROM AGE(NOW(), birth_date)) BETWEEN 18 AND 70 + AND gender = 'MALE') + OR + (EXTRACT(YEAR FROM AGE(NOW(), birth_date)) BETWEEN 18 AND 45 + AND gender = 'FEMALE') + ) AS mobilization_criterion, + COUNT(*) FILTER ( + WHERE EXTRACT(YEAR FROM AGE(NOW(), birth_date)) BETWEEN 18 AND 30 + AND gender = 'MALE' + ) AS volunteer_criterion + FROM public.recruits r + WHERE r.vu_current_info ->> 'isMilitaryRegistered' = 'true' + AND r.current_recruitment_id IS NOT NULL + AND r.target_recruitment_id IS NOT NULL +) +SELECT + total_count, + male_count, + female_count, '00' AS recruitment_id, - 0 AS mobilization_criterion, - 0 AS volunteer_criterion, + mobilization_criterion, + volunteer_criterion, 0 AS contract_criterion, - 0 AS mobilization_criterion_percent, - 0 AS volunteer_criterion_percent, + ROUND(mobilization_criterion::NUMERIC / total_count * 100, 2) AS mobilization_criterion_percent, + ROUND(volunteer_criterion::NUMERIC / total_count * 100, 2) AS volunteer_criterion_percent, -- неправильный критерий 0 AS contract_criterion_percent -FROM public.recruits r -WHERE r.vu_current_info ->> 'isMilitaryRegistered' = 'true' - AND r.current_recruitment_id IS NOT NULL - AND r.target_recruitment_id IS NOT NULL; +FROM recruit_data; 0 N @@ -691,8 +709,8 @@ WHERE r.vu_current_info ->> 'isMilitaryRegistered' = 'true' - 672 - 512 + 528 + 368 Y diff --git a/mappings/country/main_dashboard.waiting_registration.ktr b/mappings/country/main_dashboard.waiting_registration.ktr index 3f2e115..26dead1 100644 --- a/mappings/country/main_dashboard.waiting_registration.ktr +++ b/mappings/country/main_dashboard.waiting_registration.ktr @@ -667,22 +667,40 @@ postgres.person_registry - SELECT - COUNT(*) AS waiting_count, - COUNT(*) FILTER (WHERE gender = 'MALE') AS male_count, - COUNT(*) FILTER (WHERE gender = 'FEMALE') AS female_count, + WITH recruit_data AS ( + SELECT + COUNT(*) AS waiting_count, + COUNT(*) FILTER (WHERE gender = 'MALE') AS male_count, + COUNT(*) FILTER (WHERE gender = 'FEMALE') AS female_count, + COUNT(*) FILTER ( + WHERE (EXTRACT(YEAR FROM AGE(NOW(), birth_date)) BETWEEN 18 AND 70 + AND gender = 'MALE') + OR + (EXTRACT(YEAR FROM AGE(NOW(), birth_date)) BETWEEN 18 AND 45 + AND gender = 'FEMALE') + ) AS mobilization_criterion, + COUNT(*) FILTER ( + WHERE EXTRACT(YEAR FROM AGE(NOW(), birth_date)) BETWEEN 18 AND 30 + AND gender = 'MALE' + ) AS volunteer_criterion + FROM public.recruits r + WHERE r.vu_current_info ->> 'isMilitaryRegistered' = 'false' + AND r.current_recruitment_id IS NOT NULL + AND r.target_recruitment_id IS NOT NULL +) +SELECT + waiting_count, + male_count, + female_count, '00' AS recruitment_id, - 0 AS mobilization_criterion, - 0 AS volunteer_criterion, + mobilization_criterion, + volunteer_criterion, 0 AS contract_criterion, - 0 AS mobilization_criterion_percent, - 0 AS volunteer_criterion_percent, + ROUND(mobilization_criterion::NUMERIC / waiting_count * 100, 2) AS mobilization_criterion_percent, + ROUND(volunteer_criterion::NUMERIC / waiting_count * 100, 2) AS volunteer_criterion_percent, 0 AS contract_criterion_percent, - ROUND(COALESCE((COUNT(*)::DECIMAL / NULLIF((SELECT COUNT(*) FROM public.recruits), 0) * 100), 0), 2) AS waiting_percent -FROM public.recruits r -WHERE r.vu_current_info ->> 'isMilitaryRegistered' = 'false' - AND r.current_recruitment_id IS NOT NULL - AND r.target_recruitment_id IS NOT NULL; + ROUND(COALESCE((waiting_count::DECIMAL / NULLIF((SELECT COUNT(*) FROM public.recruits), 0) * 100), 0), 2) AS waiting_percent +FROM recruit_data; 0 N diff --git a/mappings/country/ratings.consideration_complaint.ktr b/mappings/country/ratings.consideration_complaint.ktr new file mode 100644 index 0000000..b7c7e6c --- /dev/null +++ b/mappings/country/ratings.consideration_complaint.ktr @@ -0,0 +1,665 @@ + + + + ratings.consideration_complaint + + + + Normal + 0 + / + + + + + + + + + + + + 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 + + + + + + + local + localhost + 8888 + + cluster + Encrypted 2be98afc86aa7f2e4cb1aa265cd86aac8 + + + + Y + N + + + + + - + 2024/08/02 11:56:22.507 + - + 2024/08/02 11:56:22.507 + H4sIAAAAAAAAAAMAAAAAAAAAAAA= + N + + + + + ervu-dashboard + dashboard-dbhost + POSTGRESQL + Native + dashboard-dbname + 1111 + dashboard-dbuser + Encrypted 2daf9dca008c89396af54aa72ce93bcc9 + + + + + + EXTRA_OPTION_POSTGRESQL.stringtype + unspecified + + + FORCE_IDENTIFIERS_TO_LOWERCASE + N + + + FORCE_IDENTIFIERS_TO_UPPERCASE + N + + + IS_CLUSTERED + N + + + PORT_NUMBER + 1111 + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + SUPPORTS_BOOLEAN_DATA_TYPE + N + + + SUPPORTS_TIMESTAMP_DATA_TYPE + N + + + USE_POOLING + N + + + + + postgres.appeal-document-service + appeal-dbhost + POSTGRESQL + Native + appeal-dbname + 2222 + appeal-dbuser + Encrypted 2be98afa91ad79785a754aa72ce93bcc9 + + + + + + FORCE_IDENTIFIERS_TO_LOWERCASE + N + + + FORCE_IDENTIFIERS_TO_UPPERCASE + N + + + IS_CLUSTERED + N + + + PORT_NUMBER + 2222 + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + SUPPORTS_BOOLEAN_DATA_TYPE + N + + + SUPPORTS_TIMESTAMP_DATA_TYPE + N + + + USE_POOLING + N + + + + + + Table input (appeal_document) РФ + Insert / update (main_dashboard.appeals) + Y + + + + Insert / update (main_dashboard.appeals) + InsertUpdate + + Y + + 1 + + none + + + ervu-dashboard + 100 + N + + main_dashboard +
appeals
+ + recruitment_id + recruitment_id + = + + + + total_appeals + total_appeals + Y + + + recruitment_id + recruitment_id + N + + + + + + + + + + + + 752 + 176 + Y + + + + Table input (appeal_document) РФ + TableInput + + Y + + 1 + + none + + + postgres.appeal-document-service + WITH +t1 AS ( + SELECT COUNT(*) AS total_appeals + FROM public.appeal_document +) -- нет причин обжалований +SELECT + t1.total_appeals, + '00' AS recruitment_id, + 0 AS incorrect_inf, + 0 AS no_data, + 0 AS other, + 0 AS incorrect_inf_percent, + 0 AS no_data_percent, + 0 AS other_percent +FROM t1; + 0 + + N + N + N + + + + + + + + + + 400 + 176 + Y + + + + + + + N + + diff --git a/mappings/country/total_registered.removed_registry.ktr b/mappings/country/total_registered.removed_registry.ktr index d16c443..239a8db 100644 --- a/mappings/country/total_registered.removed_registry.ktr +++ b/mappings/country/total_registered.removed_registry.ktr @@ -935,7 +935,7 @@ WHERE r.system_pgs_status = '1.3' - 192 + 208 192 Y diff --git a/mappings/info_recruits/deputy.ktr b/mappings/info_recruits/deputy.ktr new file mode 100644 index 0000000..9b5728c --- /dev/null +++ b/mappings/info_recruits/deputy.ktr @@ -0,0 +1,726 @@ + + + + deputy + + + + 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/08/15 14:02:51.713 + - + 2024/08/15 14:02:51.713 + H4sIAAAAAAAAAAMAAAAAAAAAAAA= + N + + + + + ervu-dashboard + dashboard-dbhost + POSTGRESQL + Native + dashboard-dbname + 1111 + dashboard-dbuser + Encrypted 2daf9dca008c89396af54aa72ce93bcc9 + + + + + + EXTRA_OPTION_POSTGRESQL.stringtype + unspecified + + + FORCE_IDENTIFIERS_TO_LOWERCASE + N + + + FORCE_IDENTIFIERS_TO_UPPERCASE + N + + + IS_CLUSTERED + N + + + PORT_NUMBER + 1111 + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + SUPPORTS_BOOLEAN_DATA_TYPE + N + + + SUPPORTS_TIMESTAMP_DATA_TYPE + N + + + USE_POOLING + N + + + + + ervu_person_registry + person-dbhost + POSTGRESQL + Native + person-dbname + 4444 + person-dbuser + Encrypted 2be98afb80fd5818ba554aa72ce93bcc9 + + + + + + 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 + N + + + SUPPORTS_TIMESTAMP_DATA_TYPE + N + + + USE_POOLING + N + + + + + + Table input + Table output + Y + + + Table input 2 + Table output 2 + Y + + + + Table input + TableInput + + Y + + 1 + + none + + + ervu_person_registry + select r.id recruit_id, +ri.info->'svedDeputat'->'deputat'->>'srokiPolnomochii' period_office, +to_date(ri.info->'svedDeputat'->'deputat'->>'dataDosrochPrekr', 'YYYY-MM-DD') end_date, +ri.info->'svedDeputat'->'deputat'->>'svedIzbrDeputatom' information +from public.recruits_info ri +join public.recruits r ON ri.recruit_id = r.id +where ri.info->'svedDeputat'->'deputat'->>'svedIzbrDeputatom' is not null; + 0 + + N + N + N + + + + + + + + + + 432 + 224 + Y + + + + Table input 2 + TableInput + + Y + + 1 + + none + + + ervu_person_registry + select r.id recruit_id, +to_date(ri.info->'svedKandidat'->'kandidat'->>'dataSnyatiyaKandidatury', 'YYYY-MM-DD') end_date, +ri.info->'svedKandidat'->'kandidat'->>'svedRegKandidata' information, +false deputy +from public.recruits_info ri +join public.recruits r ON ri.recruit_id = r.id +where ri.info->'svedKandidat'->'kandidat'->>'svedRegKandidata' is not null; + 0 + + N + N + N + + + + + + + + + + 432 + 320 + Y + + + + Table output + TableOutput + + Y + + 1 + + none + + + ervu-dashboard + ervu_dashboard +
deputy
+ 1000 + N + N + Y + N + N + + N + Y + N + + Y + N + + + + + + + + + + + + + 800 + 224 + Y + + + + Table output 2 + TableOutput + + Y + + 1 + + none + + + ervu-dashboard + ervu_dashboard + deputy
+ 1000 + N + N + Y + N + N + + N + Y + N + + Y + N + + + + + + + + + + + + + 800 + 320 + Y + + + + + + + N + + diff --git a/mappings/info_recruits/job_info_recruits.kjb b/mappings/info_recruits/job_info_recruits.kjb index 9c37edc..4d450b4 100644 --- a/mappings/info_recruits/job_info_recruits.kjb +++ b/mappings/info_recruits/job_info_recruits.kjb @@ -360,8 +360,8 @@ N Y 0 - 192 - 320 + 320 + 432 @@ -372,8 +372,8 @@ N Y 0 - 880 - 320 + 1008 + 432 @@ -410,8 +410,8 @@ N Y 0 - 608 - 96 + 736 + 112 @@ -428,8 +428,8 @@ N Y 0 - 464 - 96 + 592 + 112 @@ -446,8 +446,8 @@ N Y 0 - 464 - 16 + 592 + 48 @@ -464,7 +464,7 @@ N Y 0 - 464 + 592 176 @@ -482,8 +482,8 @@ N Y 0 - 464 - 256 + 592 + 240 @@ -520,8 +520,8 @@ N Y 0 - 608 - 16 + 736 + 48 @@ -558,7 +558,7 @@ N Y 0 - 608 + 736 176 @@ -596,8 +596,8 @@ N Y 0 - 608 - 256 + 736 + 240 @@ -614,8 +614,8 @@ N Y 0 - 464 - 320 + 592 + 304 @@ -652,8 +652,8 @@ N Y 0 - 608 - 320 + 736 + 304 @@ -670,8 +670,8 @@ N Y 0 - 464 - 384 + 592 + 368 @@ -708,8 +708,8 @@ N Y 0 - 608 - 384 + 736 + 368 @@ -726,8 +726,8 @@ N Y 0 - 464 - 448 + 592 + 432 @@ -764,8 +764,8 @@ N Y 0 - 608 - 448 + 736 + 432 @@ -782,8 +782,8 @@ N Y 0 - 464 - 512 + 592 + 496 @@ -820,8 +820,8 @@ N Y 0 - 608 - 512 + 736 + 496 @@ -838,8 +838,8 @@ N Y 0 - 464 - 576 + 592 + 560 @@ -876,8 +876,8 @@ N Y 0 - 608 - 576 + 736 + 560 @@ -894,8 +894,8 @@ N Y 0 - 464 - 640 + 592 + 624 @@ -932,8 +932,8 @@ N Y 0 - 608 - 640 + 736 + 624 @@ -950,8 +950,8 @@ N Y 0 - 464 - 704 + 592 + 688 @@ -988,8 +988,232 @@ N Y 0 - 608 - 704 + 736 + 688 + + + + SQL.deputy + + SQL + + delete from ervu_dashboard.deputy + F + F + + F + ervu-dashboard + N + Y + 0 + 592 + 752 + + + + deputy + + TRANS + + filename + + ${Internal.Entry.Current.Directory}/deputy.ktr + + N + N + N + Y + N + N + + + N + N + Basic + N + + N + Y + N + N + N + Pentaho local + + Y + + N + Y + 0 + 736 + 752 + + + + SQL.prosecution + + SQL + + delete from ervu_dashboard.prosecution + F + F + + F + ervu-dashboard + N + Y + 0 + 592 + 816 + + + + prosecution + + TRANS + + filename + + ${Internal.Entry.Current.Directory}/prosecution.ktr + + N + N + N + Y + N + N + + + N + N + Basic + N + + N + Y + N + N + N + Pentaho local + + Y + + N + Y + 0 + 736 + 816 + + + + SQL.punishment + + SQL + + delete from ervu_dashboard.punishment + F + F + + F + ervu-dashboard + N + Y + 0 + 592 + 880 + + + + punishment + + TRANS + + filename + + ${Internal.Entry.Current.Directory}/punishment.ktr + + N + N + N + Y + N + N + + + N + N + Basic + N + + N + Y + N + N + N + Pentaho local + + Y + + N + Y + 0 + 736 + 880 + + + + SQL.passport + + SQL + + delete from ervu_dashboard.passport + F + F + + F + ervu-dashboard + N + Y + 0 + 592 + 944 + + + + passport + + TRANS + + filename + + ${Internal.Entry.Current.Directory}/passport.ktr + + N + N + N + Y + N + N + + + N + N + Basic + N + + N + Y + N + N + N + Pentaho local + + Y + + N + Y + 0 + 736 + 944 @@ -1291,6 +1515,114 @@ Y Y + + SQL.deputy + deputy + 0 + 0 + Y + Y + N + + + deputy + Success + 0 + 0 + Y + Y + N + + + Start + SQL.deputy + 0 + 0 + Y + Y + Y + + + SQL.prosecution + prosecution + 0 + 0 + Y + Y + N + + + Start + SQL.prosecution + 0 + 0 + Y + Y + Y + + + prosecution + Success + 0 + 0 + Y + Y + N + + + SQL.punishment + punishment + 0 + 0 + Y + Y + N + + + Start + SQL.punishment + 0 + 0 + Y + Y + Y + + + punishment + Success + 0 + 0 + Y + Y + N + + + Start + SQL.passport + 0 + 0 + Y + Y + Y + + + SQL.passport + passport + 0 + 0 + Y + Y + N + + + passport + Success + 0 + 0 + Y + Y + N + diff --git a/mappings/info_recruits/passport.ktr b/mappings/info_recruits/passport.ktr new file mode 100644 index 0000000..c8f0a78 --- /dev/null +++ b/mappings/info_recruits/passport.ktr @@ -0,0 +1,736 @@ + + + + passport + + + + 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/08/15 14:02:51.713 + - + 2024/08/15 14:02:51.713 + H4sIAAAAAAAAAAMAAAAAAAAAAAA= + N + + + + + ervu-dashboard + dashboard-dbhost + POSTGRESQL + Native + dashboard-dbname + 1111 + dashboard-dbuser + Encrypted 2daf9dca008c89396af54aa72ce93bcc9 + + + + + + EXTRA_OPTION_POSTGRESQL.stringtype + unspecified + + + FORCE_IDENTIFIERS_TO_LOWERCASE + N + + + FORCE_IDENTIFIERS_TO_UPPERCASE + N + + + IS_CLUSTERED + N + + + PORT_NUMBER + 1111 + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + SUPPORTS_BOOLEAN_DATA_TYPE + N + + + SUPPORTS_TIMESTAMP_DATA_TYPE + N + + + USE_POOLING + N + + + + + ervu_person_registry + person-dbhost + POSTGRESQL + Native + person-dbname + 4444 + person-dbuser + Encrypted 2be98afb80fd5818ba554aa72ce93bcc9 + + + + + + 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 + N + + + SUPPORTS_TIMESTAMP_DATA_TYPE + N + + + USE_POOLING + N + + + + + + Table input + Table output + Y + + + Table input 2 + Table output 2 + Y + + + + Table input + TableInput + + Y + + 1 + + none + + + ervu_person_registry + select r.id recruit_id, +ri.info->'pasportRF'->'aktPasportRF'->>'nomDok' passport_number, +ri.info->'pasportRF'->'aktPasportRF'->>'serDok' passport_series, +ri.info->'pasportRF'->'aktPasportRF'->>'vydDok' organization_name, +ri.info->'pasportRF'->'aktPasportRF'->>'kodVydDok' unit_code, +to_date(ri.info->'pasportRF'->'aktPasportRF'->>'dataDok', 'YYYY-MM-DD') issue_date, +case when ri.info->'pasportRF'->'aktPasportRF'->>'kodStatus'='1' then true +else false +end actual +from public.recruits_info ri +join public.recruits r ON ri.recruit_id = r.id +where ri.info->'pasportRF'->'aktPasportRF'->>'nomDok' is not null; + 0 + + N + N + N + + + + + + + + + + 208 + 208 + Y + + + + Table input 2 + TableInput + + Y + + 1 + + none + + + ervu_person_registry + select r.id recruit_id, +ri.info->'pasportRF'->'predPasportRF'->>'nomDok' passport_number, +ri.info->'pasportRF'->'predPasportRF'->>'serDok' passport_series, +ri.info->'pasportRF'->'predPasportRF'->>'vydDok' organization_name, +ri.info->'pasportRF'->'predPasportRF'->>'kodVydDok' unit_code, +to_date(ri.info->'pasportRF'->'predPasportRF'->>'dataDok', 'YYYY-MM-DD') issue_date, +case when ri.info->'pasportRF'->'predPasportRF'->>'kodStatus'='1' then true +else false +end actual +from public.recruits_info ri +join public.recruits r ON ri.recruit_id = r.id +where ri.info->'pasportRF'->'predPasportRF'->>'nomDok' is not null; + 0 + + N + N + N + + + + + + + + + + 208 + 304 + Y + + + + Table output + TableOutput + + Y + + 1 + + none + + + ervu-dashboard + ervu_dashboard +
passport
+ 1000 + N + N + Y + N + N + + N + Y + N + + Y + N + + + + + + + + + + + + + 672 + 208 + Y + + + + Table output 2 + TableOutput + + Y + + 1 + + none + + + ervu-dashboard + ervu_dashboard + passport
+ 1000 + N + N + Y + N + N + + N + Y + N + + Y + N + + + + + + + + + + + + + 672 + 304 + Y + + + + + + + N + + diff --git a/mappings/info_recruits/prosecution.ktr b/mappings/info_recruits/prosecution.ktr new file mode 100644 index 0000000..f6df857 --- /dev/null +++ b/mappings/info_recruits/prosecution.ktr @@ -0,0 +1,647 @@ + + + + prosecution + + + + 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/08/15 14:02:51.713 + - + 2024/08/15 14:02:51.713 + H4sIAAAAAAAAAAMAAAAAAAAAAAA= + N + + + + + ervu-dashboard + dashboard-dbhost + POSTGRESQL + Native + dashboard-dbname + 1111 + dashboard-dbuser + Encrypted 2daf9dca008c89396af54aa72ce93bcc9 + + + + + + EXTRA_OPTION_POSTGRESQL.stringtype + unspecified + + + FORCE_IDENTIFIERS_TO_LOWERCASE + N + + + FORCE_IDENTIFIERS_TO_UPPERCASE + N + + + IS_CLUSTERED + N + + + PORT_NUMBER + 1111 + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + SUPPORTS_BOOLEAN_DATA_TYPE + N + + + SUPPORTS_TIMESTAMP_DATA_TYPE + N + + + USE_POOLING + N + + + + + ervu_person_registry + person-dbhost + POSTGRESQL + Native + person-dbname + 4444 + person-dbuser + Encrypted 2be98afb80fd5818ba554aa72ce93bcc9 + + + + + + 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 + N + + + SUPPORTS_TIMESTAMP_DATA_TYPE + N + + + USE_POOLING + N + + + + + + Table input + Table output + Y + + + + Table input + TableInput + + Y + + 1 + + none + + + ervu_person_registry + with ugol as +(select jsonb_array_elements(ri.info->'svedUgolovPresl'->'faktyUgolovPresl') u, + ri.recruit_id +from public.recruits_info ri +where jsonb_typeof(ri.info->'svedUgolovPresl'->'faktyUgolovPresl') = 'array') +select + r.id recruit_id, + u->>'vidPreslNaim' kind, + to_date(u->>'dataSved', 'YYYY-MM-DD') create_date, + to_date(u->>'dataPrekrashh', 'YYYY-MM-DD') close_date, + u->>'naimOrgan' authority_name, + u->>'ugolovZakon' law_point, + u->>'osnovPrekrashh' termination_basis +from public.recruits r +join ugol on r.id = ugol.recruit_id; + 0 + + N + N + N + + + + + + + + + + 528 + 304 + Y + + + + Table output + TableOutput + + Y + + 1 + + none + + + ervu-dashboard + ervu_dashboard +
prosecution
+ 1000 + N + N + Y + N + N + + N + Y + N + + Y + N + + + + + + + + + + + + + 736 + 304 + Y + + + + + + + N + + diff --git a/mappings/info_recruits/punishment.ktr b/mappings/info_recruits/punishment.ktr new file mode 100644 index 0000000..683edcb --- /dev/null +++ b/mappings/info_recruits/punishment.ktr @@ -0,0 +1,652 @@ + + + + punishment + + + + 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/08/15 14:02:51.713 + - + 2024/08/15 14:02:51.713 + H4sIAAAAAAAAAAMAAAAAAAAAAAA= + N + + + + + ervu-dashboard + dashboard-dbhost + POSTGRESQL + Native + dashboard-dbname + 1111 + dashboard-dbuser + Encrypted 2daf9dca008c89396af54aa72ce93bcc9 + + + + + + EXTRA_OPTION_POSTGRESQL.stringtype + unspecified + + + FORCE_IDENTIFIERS_TO_LOWERCASE + N + + + FORCE_IDENTIFIERS_TO_UPPERCASE + N + + + IS_CLUSTERED + N + + + PORT_NUMBER + 1111 + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + SUPPORTS_BOOLEAN_DATA_TYPE + N + + + SUPPORTS_TIMESTAMP_DATA_TYPE + N + + + USE_POOLING + N + + + + + ervu_person_registry + person-dbhost + POSTGRESQL + Native + person-dbname + 4444 + person-dbuser + Encrypted 2be98afb80fd5818ba554aa72ce93bcc9 + + + + + + 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 + N + + + SUPPORTS_TIMESTAMP_DATA_TYPE + N + + + USE_POOLING + N + + + + + + Table input + Table output + Y + + + + Table input + TableInput + + Y + + 1 + + none + + + ervu_person_registry + with ugol as +(select jsonb_array_elements(ri.info->'svedSudim'->'sudim'->'osuzhdenie') u, + ri.recruit_id +from public.recruits_info ri +where jsonb_typeof(ri.info->'svedSudim'->'sudim'->'osuzhdenie') = 'array') +select + r.id recruit_id, + u->>'naimSuda' authority_name, + u->>'srokNakaz' sentence, + u->>'adresNakaz' sentence_place, + u->>'kodVidNakaz' punishment_code, + u->>'izmSrokNakaz' sentence_changed, + u->>'naimVidNakaz' punishment_type, + to_date(u->>'dataNachSrok', 'YYYY-MM-DD') start_date, + to_date(u->>'dataOsvobozhd', 'YYYY-MM-DD') release_date, + to_date(u->>'dataOsuzhd', 'YYYY-MM-DD') sentense_date, + u->>'ugolovZakon' law_point, + u->>'osnovOsvobozhd' release_reason +from public.recruits r +join ugol on r.id = ugol.recruit_id; + 0 + + N + N + N + + + + + + + + + + 528 + 304 + Y + + + + Table output + TableOutput + + Y + + 1 + + none + + + ervu-dashboard + ervu_dashboard +
punishment
+ 1000 + N + N + Y + N + N + + N + Y + N + + Y + N + + + + + + + + + + + + + 736 + 304 + Y + + + + + + + N + + diff --git a/mappings/region/job_recruitments_region.kjb b/mappings/region/job_recruitments_region.kjb index 1a3e8a6..1f65c74 100644 --- a/mappings/region/job_recruitments_region.kjb +++ b/mappings/region/job_recruitments_region.kjb @@ -1994,7 +1994,7 @@ SQL.reccam.appeals(reg) 0 0 - N + Y Y N