diff --git a/crontab b/crontab index 231623b..e079d84 100644 --- a/crontab +++ b/crontab @@ -1,2 +1,3 @@ */10 * * * * bash -c ". /root/.env.sh; /opt/pentaho-di/data-integration/kitchen.sh /file:////opt/pentaho-di/mappings_old/job_general.kjb > /proc/1/fd/1 2>&1" +5,15,25,35,45,55 * * * * bash -c ". /root/.env.sh; /opt/pentaho-di/data-integration/kitchen.sh /file:////opt/pentaho-di/mappings_old/metrics/job_metr.kjb > /proc/1/fd/1 2>&1" 0 1 * * * bash -c ". /root/.env.sh; /opt/pentaho-di/data-integration/kitchen.sh /file:////opt/pentaho-di/mappings_old/info_recruits/job_info_recruits.kjb > /proc/1/fd/1 2>&1" diff --git a/db.env b/db.env index 86d80b9..3c9b66b 100644 --- a/db.env +++ b/db.env @@ -1,6 +1,6 @@ DB_DASHBOARD_HOST=10.10.31.119 DB_DASHBOARD_PORT=5432 -DB_DASHBOARD_NAME=ervu-dashboard +DB_DASHBOARD_NAME=ervu-dashboard-copy DB_DASHBOARD_USERNAME=ervu-dashboard DB_DASHBOARD_PASSWORD=ervu-dashboard @@ -12,18 +12,30 @@ DB_APPEAL_PASSWORD=ervu DB_DECISION_HOST=10.10.31.118 DB_DECISION_PORT=5432 -DB_DECISION_NAME=decision-document-service +DB_DECISION_NAME=ervu-decision-document-service DB_DECISION_USERNAME=ervu DB_DECISION_PASSWORD=ervu -DB_PERSON_HOST=10.10.31.119 +DB_PERSON_HOST=10.10.31.118 DB_PERSON_PORT=5432 -DB_PERSON_NAME=ervu_person_registry -DB_PERSON_USERNAME=ervu-dashboard -DB_PERSON_PASSWORD=ervu-dashboard +DB_PERSON_NAME=ervu-person-registry +DB_PERSON_USERNAME=ervu +DB_PERSON_PASSWORD=ervu DB_SUBPOENA_HOST=10.10.31.118 DB_SUBPOENA_PORT=5432 -DB_SUBPOENA_NAME=subpoena +DB_SUBPOENA_NAME=ervu-subpoena-registry DB_SUBPOENA_USERNAME=ervu DB_SUBPOENA_PASSWORD=ervu + +DB_JOURNAL_HOST=10.10.31.118 +DB_JOURNAL_PORT=5432 +DB_JOURNAL_NAME=journal_dev +DB_JOURNAL_USERNAME=ervu +DB_JOURNAL_PASSWORD=ervu + +DB_METRICS_HOST=10.10.31.119 +DB_METRICS_PORT=5432 +DB_METRICS_NAME=ervu-dashboard-copy +DB_METRICS_USERNAME=ervu_business_metrics +DB_METRICS_PASSWORD=ervu_business_metrics diff --git a/entrypoint.sh b/entrypoint.sh index cecf664..af7210d 100755 --- a/entrypoint.sh +++ b/entrypoint.sh @@ -41,6 +41,18 @@ for F in $(find . -type f); do sed -i "s/subpoena-dbname/$DB_SUBPOENA_NAME/g" $F sed -i "s/subpoena-dbuser/$DB_SUBPOENA_USERNAME/g" $F sed -i "s/Encrypted 2beebdaaa1ac8978aaa54aa72ce93bcc9/$DB_SUBPOENA_PASSWORD/g" $F + + sed -i "s/6666/$DB_JOURNAL_PORT/g" $F + sed -i "s/journal-dbhost/$DB_JOURNAL_HOST/g" $F + sed -i "s/journal-dbname/$DB_JOURNAL_NAME/g" $F + sed -i "s/journal-dbuser/$DB_JOURNAL_USERNAME/g" $F + sed -i "s/Encrypted 2beebdaaa1ac8978aaa54aa72ce93bcc9/$DB_JOURNAL_PASSWORD/g" $F + + sed -i "s/7777/$DB_METRICS_PORT/g" $F + sed -i "s/metrics-dbhost/$DB_METRICS_HOST/g" $F + sed -i "s/metrics-dbname/$DB_METRICS_NAME/g" $F + sed -i "s/metrics-dbuser/$DB_METRICS_USERNAME/g" $F + sed -i "s/Encrypted 657276755ddceddca104c281979414ab64cc9bacc9/$DB_METRICS_PASSWORD/g" $F done; #Запускаем job один раз при старте контейнера @@ -50,6 +62,8 @@ bash -c ". /root/.env.sh; /opt/pentaho-di/data-integration/kitchen.sh /file:/// if [ $RUNONCE == true ]; then echo "---- Run job_general.kjb ----" bash -c ". /root/.env.sh; /opt/pentaho-di/data-integration/kitchen.sh /file:////opt/pentaho-di/mappings_old/job_general.kjb > /proc/1/fd/1 2>&1" + echo "---- Run job_metr.kjb ----" + bash -c ". /root/.env.sh; /opt/pentaho-di/data-integration/kitchen.sh /file:////opt/pentaho-di/mappings_old/metrics/job_metr.kjb > /proc/1/fd/1 2>&1" exit $? else cat /root/crontab | crontab - diff --git a/mappings_old/metrics/Cancellation_Timely_measures.ktr b/mappings_old/metrics/Cancellation_Timely_measures.ktr new file mode 100644 index 0000000..e5fc18a --- /dev/null +++ b/mappings_old/metrics/Cancellation_Timely_measures.ktr @@ -0,0 +1,677 @@ + + + + Cancellation_Timely_measures + + + + 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/09 10:22:50.530 + - + 2024/12/09 10:22:50.530 + + 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 + 5432 + + + 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 2beebdaaa1ac8978aaa54aa72ce93bcc9 + + + + + + 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 + + + subpoena + ---- На данные момент это костыль в recruitment_id + +SELECT + 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 (301) THEN 21 + ELSE NULL + END AS summonses_reason_id, + TO_CHAR(NOW() - INTERVAL '1 day', 'YYYY-MM-DD') AS info_dat, + '300cee57-2ce7-4b82-847b-bfbe14d6c7ea' AS recruitment_id, + COALESCE(COUNT(s.id) FILTER (WHERE rec.system_pgs_status IN ('8.7')), 0) AS count_for_sign, + COALESCE(COUNT(s.id) FILTER (WHERE rec.system_pgs_status IN ('10.3')), 0) AS count_signed, + COALESCE(COUNT(s.id) FILTER (WHERE rdi.status_applied IS NOT NULL AND rdi.status_canceled IS NOT NULL AND rdi.foiv_code != 1), 0) AS count_removed +FROM public.subpoena s +LEFT JOIN public.recruits rec ON rec.id = s.recruit_id +LEFT JOIN public.subpoena_reason sr ON s.reason_id = sr.id +LEFT JOIN public.restriction_document rd ON s.id = rd.subpoena_id +JOIN public.restriction_document_item rdi ON rd.id = rdi.restriction_document_create_id +GROUP BY summonses_reason_id; + 0 + + N + N + N + + + + + + + + + + 352 + 256 + Y + + + + Table output + TableOutput + + Y + + 1 + + none + + + metrics + summonses_list +
remove_tmp_measures
+ 1000 + N + N + Y + Y + N + + N + Y + N + + Y + N + + + + recruitment_id + recruitment_id + + + info_date + info_dat + + + summonses_reason_id + summonses_reason_id + + + count_for_sign + count_for_sign + + + count_signed + count_signed + + + count_removed + count_removed + + + + + + + + + + + + 528 + 256 + Y + + + + + + + N + + diff --git a/mappings_old/metrics/Reesr_visit.ktr b/mappings_old/metrics/Reesr_visit.ktr new file mode 100644 index 0000000..e64b610 --- /dev/null +++ b/mappings_old/metrics/Reesr_visit.ktr @@ -0,0 +1,685 @@ + + + + Reesr_visit + + + + 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/06 14:54:15.320 + - + 2024/12/06 14:54:15.320 + 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 + 5432 + + + 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 2beebdaaa1ac8978aaa54aa72ce93bcc9 + + + + + + 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 + + + subpoena + ---- На данные момент это костыль в recruitment_id + +SELECT + 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 (301) THEN 21 + ELSE NULL + END AS summonses_reason_id, + TO_CHAR(NOW() - INTERVAL '1 day', 'YYYY-MM-DD') AS info_dat, + '300cee57-2ce7-4b82-847b-bfbe14d6c7ea' AS recruitment_id, + COALESCE(COUNT(s.id) FILTER (WHERE ss.code LIKE '4%'), 0) AS count_visit, + COALESCE(COUNT(s.id) FILTER (WHERE ss.code = '5'), 0) AS count_not_visit, + COALESCE(COUNT(s.id) FILTER (WHERE ss.code = '5.1'), 0) AS count_valid_reason, + COALESCE(COUNT(s.id) FILTER (WHERE ss.code = '5.2'),0) AS count_not_need, + COALESCE(COUNT(s.id) FILTER (WHERE ss.code = '3.8'),0) AS count_hand_over_not_need +FROM public.subpoena s +LEFT JOIN public.subpoena_status ss ON ss.id = s.status_id +LEFT JOIN public.subpoena_reason sr ON s.reason_id = sr.id +GROUP BY summonses_reason_id; + 0 + + N + N + N + + + + + + + + + + 160 + 176 + Y + + + + Table output + TableOutput + + Y + + 1 + + none + + + metrics + summonses_list +
recruit_office_visit
+ 1000 + N + N + Y + Y + N + + N + Y + N + + Y + N + + + + recruitment_id + recruitment_id + + + info_date + info_dat + + + summonses_reason_id + summonses_reason_id + + + count_visit + count_visit + + + count_not_visit + count_not_visit + + + count_valid_reason + count_valid_reason + + + count_not_need + count_not_need + + + count_hand_over_not_need + count_hand_over_not_need + + + + + + + + + + + + 432 + 192 + Y + + + + + + + N + + diff --git a/mappings_old/metrics/Timely_measures.ktr b/mappings_old/metrics/Timely_measures.ktr new file mode 100644 index 0000000..05c05ff --- /dev/null +++ b/mappings_old/metrics/Timely_measures.ktr @@ -0,0 +1,677 @@ + + + + Timely_measures + + + + 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/09 13:18:43.055 + - + 2024/12/09 13:18:43.055 + + 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 + 5432 + + + 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 2beebdaaa1ac8978aaa54aa72ce93bcc9 + + + + + + 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 + + + subpoena + ---- На данные момент это костыль в recruitment_id + +SELECT + 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 (301) THEN 21 + ELSE NULL + END AS summonses_reason_id, + TO_CHAR(NOW() - INTERVAL '1 day', 'YYYY-MM-DD') AS info_dat, + '300cee57-2ce7-4b82-847b-bfbe14d6c7ea' AS recruitment_id, + COALESCE(COUNT(s.id) FILTER (WHERE rec.system_pgs_status IN ('8.10')), 0) AS count_for_sign, + COALESCE(COUNT(s.id) FILTER (WHERE rec.system_pgs_status IN ('10.4', '11.6')), 0) AS count_apply, + COALESCE(COUNT(s.id) FILTER (WHERE rdi.status_applied IS NOT NULL AND rdi.status_canceled IS NULL AND rdi.foiv_code != 1), 0) AS count_enter +FROM public.subpoena s +LEFT JOIN public.recruits rec ON rec.id = s.recruit_id +LEFT JOIN public.subpoena_reason sr ON s.reason_id = sr.id +LEFT JOIN public.restriction_document rd ON s.id = rd.subpoena_id +JOIN public.restriction_document_item rdi ON rd.id = rdi.restriction_document_create_id +GROUP BY summonses_reason_id; + 0 + + N + N + N + + + + + + + + + + 224 + 304 + Y + + + + Table output + TableOutput + + Y + + 1 + + none + + + metrics + summonses_list +
imposition_tmp_measures
+ 1000 + N + N + Y + Y + N + + N + Y + N + + Y + N + + + + recruitment_id + recruitment_id + + + info_date + info_dat + + + summonses_reason_id + summonses_reason_id + + + count_for_sign + count_for_sign + + + count_apply + count_apply + + + count_enter + count_enter + + + + + + + + + + + + 416 + 304 + Y + + + + + + + N + + diff --git a/mappings_old/metrics/convert_info_common_results.ktr b/mappings_old/metrics/convert_info_common_results.ktr new file mode 100644 index 0000000..9dae5ea --- /dev/null +++ b/mappings_old/metrics/convert_info_common_results.ktr @@ -0,0 +1,683 @@ + + + + convert_info_common_results + + + + 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/09 15:16:58.642 + - + 2024/12/09 15:16:58.642 + 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 + 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 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 + + + ervu-person-registry + +---- На данные момент это костыль в recruitment_id + +SELECT + + TO_CHAR(NOW() - INTERVAL '1 day', 'YYYY-MM-DD') AS info_date, + '300cee57-2ce7-4b82-847b-bfbe14d6c7ea' AS recruitment_id, + -- Записей, подтвержденных при конвертации + (SELECT COUNT(*) + FROM system_document_dto + WHERE status = 'formed' AND type = '1') AS count_confirmed, + + -- Записей, подписанных УКЭП ВК + (SELECT COUNT(*) + FROM system_document_dto + WHERE status = 'signed' AND type = '1') AS count_signed, + + -- Записей, отклоненных ВК + (SELECT COUNT(*) + FROM system_document_dto + WHERE (status = 'signed' OR status = 'formed') AND type = '2') AS count_canceled, + + -- Записей по результатам ручной конвертации + (SELECT COUNT(*) + FROM recruits_history + WHERE status IN ('12.2', '12.7')) AS count_manual_convert; + + 0 + + N + N + N + + + + + + + + + + 288 + 240 + Y + + + + Table output + TableOutput + + Y + + 1 + + none + + + metrics + metrics +
convert_info_common_results
+ 1000 + N + N + Y + Y + N + + N + Y + N + + Y + N + + + + recruitment_id + recruitment_id + + + info_date + info_date + + + count_confirmed + count_confirmed + + + count_signed + count_signed + + + count_manual_convert + count_manual_convert + + + count_canceled + count_canceled + + + + + + + + + + + + 464 + 240 + Y + + + + + + + N + + diff --git a/mappings_old/metrics/convert_info_loaded_records.ktr b/mappings_old/metrics/convert_info_loaded_records.ktr new file mode 100644 index 0000000..e8b0788 --- /dev/null +++ b/mappings_old/metrics/convert_info_loaded_records.ktr @@ -0,0 +1,682 @@ + + + + convert_info_loaded_records + + + + 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/09 15:35:49.472 + - + 2024/12/09 15:35:49.472 + 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 + 5432 + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + SUPPORTS_BOOLEAN_DATA_TYPE + Y + + + SUPPORTS_TIMESTAMP_DATA_TYPE + Y + + + USE_POOLING + N + + + + + ervu-journal + journal-dbhost + POSTGRESQL + Native + journal-dbname + 6666 + journal-dbuser + Encrypted 2beebdaaa1ac8978aaa54aa72ce93bcc9 + + + + + + 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 + + + ervu-journal + ---- На данные момент это костыль в recruitment_id +SELECT + TO_CHAR(NOW() - INTERVAL '1 day', 'YYYY-MM-DD') AS info_date, + '300cee57-2ce7-4b82-847b-bfbe14d6c7ea' AS recruitment_id, + COALESCE(COUNT(r.id) FILTER ( + WHERE r.result = 'Импортирован' + AND EXISTS ( + SELECT 1 + FROM jsonb_array_elements_text(r.extra_info::jsonb) AS elem + WHERE elem IN ( + 'Отсутствует информация о документе, удостоверяющем личность', + 'Отсутствуют адреса по месту регистрации, пребывания', + 'Отсутствуют сведения об образовании', + 'Не соответствует код ВУС', + 'Отсутствует код ВУС' + ) + ) + ), 0) AS count_success, + COALESCE(COUNT(r.id) FILTER ( + WHERE r.result = 'Импортирован' + AND NOT EXISTS ( + SELECT 1 + FROM jsonb_array_elements_text(r.extra_info::jsonb) AS elem + WHERE elem IN ( + 'Отсутствует информация о документе, удостоверяющем личность', + 'Отсутствуют адреса по месту регистрации, пребывания', + 'Отсутствуют сведения об образовании', + 'Не соответствует код ВУС', + 'Отсутствует код ВУС' + ) + ) + ), 0) AS count_error +FROM + import_results r; + 0 + + N + N + N + + + + + + + + + + 320 + 144 + Y + + + + Table output + TableOutput + + Y + + 1 + + none + + + metrics + metrics +
convert_info_loaded_records
+ 1000 + N + N + Y + Y + N + + N + Y + N + + Y + N + + + + recruitment_id + recruitment_id + + + info_date + info_date + + + count_success + count_success + + + count_error + count_error + + + + + + + + + + + + 512 + 144 + Y + + + + + + + N + + diff --git a/mappings_old/metrics/convert_info_records_from_easu.ktr b/mappings_old/metrics/convert_info_records_from_easu.ktr new file mode 100644 index 0000000..7a6ae3b --- /dev/null +++ b/mappings_old/metrics/convert_info_records_from_easu.ktr @@ -0,0 +1,660 @@ + + + + convert_info_records_from_easu + + + + 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/09 16:05:01.990 + - + 2024/12/09 16:05:01.990 + 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 + 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 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 + + + ervu-person-registry + SELECT + TO_CHAR(NOW() - INTERVAL '1 day', 'YYYY-MM-DD') AS info_date, + '300cee57-2ce7-4b82-847b-bfbe14d6c7ea' AS recruitment_id, + coalesce(COUNT(hist.id) filter(WHERE res.code in('created','duplicate_updated')), 0) as count_all, + coalesce(COUNT(hist.id) filter(WHERE res.code in('created')), 0) as count_unique, + coalesce(COUNT(hist.id) filter(WHERE res.code in( 'flk_error', 'duplicate_ignored', 'duplicate_already_processed')), 0) as count_flk_and_duplicate +from recruit_association_download_history hist +join recruit_association_download_result res on hist.recruit_association_download_result_id = res.id + 0 + + N + N + N + + + + + + + + + + 336 + 336 + Y + + + + Table output + TableOutput + + Y + + 1 + + none + + + metrics + metrics +
convert_info_records_from_easu
+ 1000 + N + N + Y + Y + N + + N + Y + N + + Y + N + + + + recruitment_id + recruitment_id + + + info_date + info_date + + + count_unique + count_unique + + + count_flk_and_duplicate + count_flk_and_duplicate + + + count_all + count_all + + + + + + + + + + + + 512 + 336 + Y + + + + + + + N + + diff --git a/mappings_old/metrics/convert_info_sent_to_lk_epgu.ktr b/mappings_old/metrics/convert_info_sent_to_lk_epgu.ktr new file mode 100644 index 0000000..229184d --- /dev/null +++ b/mappings_old/metrics/convert_info_sent_to_lk_epgu.ktr @@ -0,0 +1,698 @@ + + + + convert_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/09 16:10:38.209 + - + 2024/12/09 16:10:38.209 + 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 + 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 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 + + + 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 in('1', '1.2') +) +SELECT + TO_CHAR(NOW() - INTERVAL '1 day', 'YYYY-MM-DD') AS info_date, + '300cee57-2ce7-4b82-847b-bfbe14d6c7ea' AS recruitment_id, + COALESCE(COUNT(rec.id) FILTER (WHERE rec.system_pgs_status in ('16.1', '16.2', '16.4', '16.6')), 0) AS count_status_formed, + COALESCE(COUNT(rec.id) FILTER (WHERE rec.system_pgs_status in ('16.1', '16.2', '16.4')), 0) AS count_sended, + COALESCE(COUNT(rec.id) FILTER (WHERE rec.system_pgs_status in ( '16.2', '16.4' )), 0) AS count_delivered, + COALESCE(COUNT(rec.id) FILTER (WHERE rec.system_pgs_status in ( '16.3' )), 0) AS count_error, + COALESCE(COUNT(rec.id) FILTER (WHERE rec.system_pgs_status in ( '16.4' )), 0) AS count_viewed, + COALESCE(COUNT(rec.id) FILTER (WHERE rec.system_pgs_status in ( '16.2' )), 0) AS count_not_viewed, + COALESCE(COUNT(rec.id) FILTER (WHERE rec.system_pgs_status in ( '16.5' )), 0) AS count_status_not_formed +FROM recruits rec +JOIN target_status on rec.id = recruit_id + 0 + + N + N + N + + + + + + + + + + 176 + 304 + Y + + + + Table output + TableOutput + + Y + + 1 + + none + + + metrics + metrics +
convert_info_sent_to_lk_epgu
+ 1000 + N + N + Y + Y + N + + N + Y + N + + Y + N + + + + recruitment_id + recruitment_id + + + info_date + info_date + + + 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 + + + + + + + + + + + + 336 + 304 + Y + + + + + + + N + + diff --git a/mappings_old/metrics/criminal_administrative_liability.ktr b/mappings_old/metrics/criminal_administrative_liability.ktr new file mode 100644 index 0000000..24c5fb1 --- /dev/null +++ b/mappings_old/metrics/criminal_administrative_liability.ktr @@ -0,0 +1,659 @@ + + + + criminal_administrative_liability + + + + 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/09 16:28:01.868 + - + 2024/12/09 16:28:01.868 + 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 + 5432 + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + SUPPORTS_BOOLEAN_DATA_TYPE + Y + + + SUPPORTS_TIMESTAMP_DATA_TYPE + Y + + + USE_POOLING + N + + + + + ervu-decision-document-service + decision-dbhost + POSTGRESQL + Native + decision-dbname + 3333 + decision-dbuser + Encrypted 2befccaab03d49b8ba554aa72ce93bcc9 + + + + + + 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 + + + ervu-decision-document-service + SELECT + TO_CHAR(NOW() - INTERVAL '1 day', 'YYYY-MM-DD') AS info_date, + '300cee57-2ce7-4b82-847b-bfbe14d6c7ea' AS recruitment_id, + COALESCE(count(id),0) as count_all, + COALESCE(count(id) FILTER(WHERE type = 'ADMINISTRATIVE' and hidden = 'false'),0) as count_administrative, + COALESCE(count(id) FILTER(WHERE type = 'CRIMINAL' and hidden = 'false'),0) as count_criminal +From infringement + 0 + + N + N + N + + + + + + + + + + 288 + 272 + Y + + + + Table output + TableOutput + + Y + + 1 + + none + + + metrics + metrics +
criminal_administrative_liability
+ 1000 + N + N + Y + Y + N + + N + Y + N + + Y + N + + + + recruitment_id + recruitment_id + + + info_date + info_date + + + count_administrative + count_administrative + + + count_criminal + count_criminal + + + count_all + count_all + + + + + + + + + + + + 480 + 272 + Y + + + + + + + N + + diff --git a/mappings_old/metrics/csv_xml.ktr b/mappings_old/metrics/csv_xml.ktr new file mode 100644 index 0000000..8a2761e --- /dev/null +++ b/mappings_old/metrics/csv_xml.ktr @@ -0,0 +1,659 @@ + + + + csv_xml + + + + 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/09 14:23:05.719 + - + 2024/12/09 14:23:05.719 + 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 + 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 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 + + + ervu-person-registry + ---- На данные момент это костыль в recruitment_id + + + +SELECT + '300cee57-2ce7-4b82-847b-bfbe14d6c7ea' AS recruitment_id, + TO_CHAR(NOW() - INTERVAL '1 day', 'YYYY-MM-DD') AS info_date, + coalesce(COUNT(ra.id) filter(WHERE ras.code in('created', 'processed')), 0) as count_csv_formed, + coalesce(COUNT(ra.id) filter(WHERE ras.code in( 'processed')), 0) as count_xml_formed +FROM recruit_association ra +JOIN recruit_association_status ras on ra.recruit_association_status_id = ras.id + 0 + + N + N + N + + + + + + + + + + 176 + 224 + Y + + + + Table output + TableOutput + + Y + + 1 + + none + + + metrics + metrics +
convert_info_comparison_csv_xml
+ 1000 + N + N + Y + Y + N + + N + Y + N + + Y + N + + + + recruitment_id + recruitment_id + + + info_date + info_date + + + count_xml_formed + count_xml_formed + + + count_csv_formed + count_csv_formed + + + + + + + + + + + + 352 + 224 + Y + + + + + + + N + + diff --git a/mappings_old/metrics/info_lk.ktr b/mappings_old/metrics/info_lk.ktr new file mode 100644 index 0000000..183ca51 --- /dev/null +++ b/mappings_old/metrics/info_lk.ktr @@ -0,0 +1,4776 @@ + + + + info_lk + + + + 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/09 13:25:14.716 + - + 2024/12/09 13:25:14.716 + + 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 + 5432 + + + 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 2beebdaaa1ac8978aaa54aa72ce93bcc9 + + + + + + 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 + + + + + ervu-person-registry + person-dbhost + POSTGRESQL + Native + person-dbname + 4444 + person-dbuser + 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 2 + Merge join + Y + + + Table input 3 + Merge join + Y + + + 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 + + N + + 1 + + none + + + FULL OUTER + Table input 2 + Table input 3 + + recruit_id + + + recruit_id + + + + + + + + + + + 288 + 960 + Y + + + + Table input 2 + TableInput + + Y + + 1 + + none + + + subpoena + SELECT + 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 (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 +LEFT JOIN public.subpoena_reason sr ON s.reason_id = sr.id + 0 + + N + N + N + + + + + + + + + + 112 + 976 + Y + + + + Table input 3 + TableInput + + Y + + 1 + + none + + + 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' +) +SELECT recruit_id, +rec.system_pgs_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') + 0 + + N + N + Y + + + + + + + + + + 128 + 736 + Y + + + + Сфоримировано ув по 1 причине + FilterRows + + Y + + 1 + + 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 + + + + + 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 + + + + + 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 + + + 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 + + + + + + + + + + + + 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 + Y + + + + + + + N + + diff --git a/mappings_old/metrics/job_metr.kjb b/mappings_old/metrics/job_metr.kjb new file mode 100644 index 0000000..b77a724 --- /dev/null +++ b/mappings_old/metrics/job_metr.kjb @@ -0,0 +1,1148 @@ + + + job_metr + + + + / + - + 2024/12/09 16:35:23.882 + - + 2024/12/09 16:35:23.882 + + + + + + + + + + + + + ID_JOB + Y + ID_JOB + + + CHANNEL_ID + Y + CHANNEL_ID + + + JOBNAME + Y + JOBNAME + + + 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 + + + START_JOB_ENTRY + N + START_JOB_ENTRY + + + CLIENT + N + CLIENT + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + JOBNAME + Y + TRANSNAME + + + JOBENTRYNAME + Y + STEPNAME + + + 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 + + + RESULT + Y + RESULT + + + NR_RESULT_ROWS + Y + NR_RESULT_ROWS + + + NR_RESULT_FILES + Y + NR_RESULT_FILES + + + LOG_FIELD + N + LOG_FIELD + + + COPY_NR + N + COPY_NR + + + + + +
+ + + 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 + + + N + + + + Start + + SPECIAL + + Y + N + N + 0 + 0 + 60 + 12 + 0 + 1 + 1 + N + Y + 0 + 160 + 880 + + + + Cancellation_Timely_measures + + TRANS + + filename + + ${Internal.Entry.Current.Directory}/\Cancellation_Timely_measures.ktr + + N + N + N + N + N + N + + + N + N + Basic + N + + N + Y + N + N + N + Pentaho local + + Y + + N + Y + 0 + 704 + 144 + + + + Success + + SUCCESS + + N + Y + 0 + 896 + 144 + + + + convert_info_common_results + + TRANS + + filename + + ${Internal.Entry.Current.Directory}/\convert_info_common_results.ktr + + N + N + N + N + N + N + + + N + N + Basic + N + + N + Y + N + N + N + Pentaho local + + Y + + N + Y + 0 + 704 + 240 + + + + Success 2 + + SUCCESS + + N + Y + 0 + 896 + 240 + + + + convert_info_loaded_records + + TRANS + + filename + + ${Internal.Entry.Current.Directory}/\convert_info_loaded_records.ktr + + N + N + N + N + N + N + + + N + N + Basic + N + + N + Y + N + N + N + Pentaho local + + Y + + N + Y + 0 + 704 + 336 + + + + Success 3 + + SUCCESS + + N + Y + 0 + 896 + 336 + + + + convert_info_records_from_easu + + TRANS + + filename + + ${Internal.Entry.Current.Directory}/\convert_info_records_from_easu.ktr + + N + N + N + N + N + N + + + N + N + Basic + N + + N + Y + N + N + N + Pentaho local + + Y + + N + Y + 0 + 704 + 416 + + + + Success 4 + + SUCCESS + + N + Y + 0 + 896 + 416 + + + + convert_info_sent_to_lk_epgu + + TRANS + + filename + + ${Internal.Entry.Current.Directory}/\convert_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 + 512 + + + + Success 5 + + SUCCESS + + N + Y + 0 + 896 + 512 + + + + criminal_administrative_liability + + TRANS + + filename + + ${Internal.Entry.Current.Directory}/\criminal_administrative_liability.ktr + + N + N + N + N + N + N + + + N + N + Basic + N + + N + Y + N + N + N + Pentaho local + + Y + + N + Y + 0 + 704 + 592 + + + + Success 6 + + SUCCESS + + N + Y + 0 + 896 + 592 + + + + csv_xml + + TRANS + + filename + + ${Internal.Entry.Current.Directory}/\csv_xml.ktr + + N + N + N + N + N + N + + + N + N + Basic + N + + N + Y + N + N + N + Pentaho local + + Y + + N + Y + 0 + 704 + 672 + + + + Success 7 + + SUCCESS + + N + Y + 0 + 896 + 672 + + + + info_lk + + TRANS + + filename + + ${Internal.Entry.Current.Directory}/\info_lk.ktr + + N + N + N + N + N + N + + + N + N + Basic + N + + N + Y + N + N + N + Pentaho local + + Y + + N + Y + 0 + 704 + 768 + + + + Success 8 + + SUCCESS + + N + Y + 0 + 896 + 768 + + + + Reesr_visit + + TRANS + + filename + + ${Internal.Entry.Current.Directory}/\Reesr_visit.ktr + + N + N + N + N + N + N + + + N + N + Basic + N + + N + Y + N + N + N + Pentaho local + + Y + + N + Y + 0 + 704 + 848 + + + + Success 9 + + SUCCESS + + N + Y + 0 + 896 + 848 + + + + reest_formed + + TRANS + + filename + + ${Internal.Entry.Current.Directory}/\reest_formed.ktr + + N + N + N + N + N + N + + + N + N + Basic + N + + N + Y + N + N + N + Pentaho local + + Y + + N + Y + 0 + 704 + 928 + + + + Success 10 + + SUCCESS + + N + Y + 0 + 896 + 928 + + + + Timely_measures + + TRANS + + filename + + ${Internal.Entry.Current.Directory}/\Timely_measures.ktr + + N + N + N + N + N + N + + + N + N + Basic + N + + N + Y + N + N + N + Pentaho local + + Y + + N + Y + 0 + 704 + 1008 + + + + Success 11 + + SUCCESS + + N + Y + 0 + 896 + 1008 + + + + main_blok + + TRANS + + filename + + ${Internal.Entry.Current.Directory}/\main_blok.ktr + + N + N + N + N + N + N + + + N + N + Basic + N + + N + Y + N + N + N + Pentaho local + + Y + + N + Y + 0 + 704 + 1088 + + + + Success 12 + + SUCCESS + + N + Y + 0 + 896 + 1088 + + + + + + Start + Cancellation_Timely_measures + 0 + 0 + Y + Y + Y + + + Cancellation_Timely_measures + Success + 0 + 0 + Y + Y + N + + + Start + convert_info_common_results + 0 + 0 + Y + Y + Y + + + convert_info_common_results + Success 2 + 0 + 0 + Y + Y + N + + + convert_info_loaded_records + Success 3 + 0 + 0 + Y + Y + N + + + Start + convert_info_loaded_records + 0 + 0 + Y + Y + Y + + + Start + convert_info_records_from_easu + 0 + 0 + Y + Y + Y + + + convert_info_records_from_easu + Success 4 + 0 + 0 + Y + Y + N + + + Start + convert_info_sent_to_lk_epgu + 0 + 0 + Y + Y + Y + + + convert_info_sent_to_lk_epgu + Success 5 + 0 + 0 + Y + Y + N + + + Start + criminal_administrative_liability + 0 + 0 + Y + Y + Y + + + criminal_administrative_liability + Success 6 + 0 + 0 + Y + Y + N + + + csv_xml + Success 7 + 0 + 0 + Y + Y + N + + + Start + csv_xml + 0 + 0 + Y + Y + Y + + + info_lk + Success 8 + 0 + 0 + Y + Y + N + + + Start + info_lk + 0 + 0 + Y + Y + Y + + + Reesr_visit + Success 9 + 0 + 0 + Y + Y + N + + + Start + Reesr_visit + 0 + 0 + Y + Y + Y + + + Start + reest_formed + 0 + 0 + Y + Y + Y + + + reest_formed + Success 10 + 0 + 0 + Y + Y + N + + + Timely_measures + Success 11 + 0 + 0 + Y + Y + N + + + Start + Timely_measures + 0 + 0 + Y + Y + Y + + + Start + main_blok + 0 + 0 + Y + Y + Y + + + main_blok + Success 12 + 0 + 0 + Y + Y + N + + + + + + + METASTORE.pentaho + + Default Run Configuration + {"namespace":"pentaho","id":"Default Run Configuration","name":"Default Run Configuration","description":"Defines a default run configuration","metaStoreName":null} + + + + {"_":"Embedded MetaStore Elements","namespace":"pentaho","type":"Default Run Configuration"} + + Pentaho local + {"children":[{"children":[],"id":"server","value":null},{"children":[],"id":"clustered","value":"N"},{"children":[],"id":"name","value":"Pentaho local"},{"children":[],"id":"description","value":null},{"children":[],"id":"pentaho","value":"N"},{"children":[],"id":"readOnly","value":"Y"},{"children":[],"id":"sendResources","value":"N"},{"children":[],"id":"logRemoteExecutionLocally","value":"N"},{"children":[],"id":"remote","value":"N"},{"children":[],"id":"local","value":"Y"},{"children":[],"id":"showTransformations","value":"N"}],"id":"Pentaho local","value":null,"name":"Pentaho local","owner":null,"ownerPermissionsList":[]} + + + + diff --git a/mappings_old/metrics/main_blok.ktr b/mappings_old/metrics/main_blok.ktr new file mode 100644 index 0000000..daa1b3f --- /dev/null +++ b/mappings_old/metrics/main_blok.ktr @@ -0,0 +1,805 @@ + + + + fd + + + + 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/05 10:19:42.709 + - + 2024/12/05 10:19:42.709 + 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 + 5432 + + + 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 2beebdaaa1ac8978aaa54aa72ce93bcc9 + + + + + + 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 + + + + + + Get system info + Calculator + N + + + Calculator + Select values + N + + + Select values + Table output + N + + + Table input + Get system info + N + + + Table input + Table output + Y + + + + Calculator + Calculator + + Y + + 1 + + none + + + Y + + date + ADD_DAYS + info_date + -1 + + Date + -1 + -1 + N + MM-dd-yy + + + + + + + + + + + + + + 304 + 240 + Y + + + + Get system info + SystemInfo + + Y + + 1 + + none + + + + + info_date + system date (fixed) + + + + + + + + + + + + 208 + 240 + Y + + + + Select values + SelectValues + + Y + + 1 + + none + + + + N + + info_date + info_date + Date + -2 + -2 + yyyy-MM-dd + false + + + false + + + + + + + + + + + + + + + + + 416 + 240 + Y + + + + Table input + TableInput + + Y + + 1 + + none + + + subpoena + ---- На данные момент это костыль в recruitment_id + +SELECT + '300cee57-2ce7-4b82-847b-bfbe14d6c7ea' AS recruitment_id, + COUNT(CASE WHEN CAST(sr.code AS INTEGER) = 101 THEN 1 END) AS count_init_registration, + COUNT(CASE WHEN CAST(sr.code AS INTEGER) IN (201, 202, 203, 204, 205, 206, 207, 208, 209, 210, 211) THEN 1 END) AS count_draft_company, + COUNT(CASE WHEN CAST(sr.code AS INTEGER) IN (102, 103, 104, 105, 106, 107) THEN 1 END) AS count_management_military_registration, + COUNT(CASE WHEN CAST(sr.code AS INTEGER) = 301 THEN 1 END) AS count_mobilization, + TO_CHAR(NOW() - INTERVAL '1 day', 'YYYY-MM-DD') AS info_date +FROM public.subpoena s +LEFT JOIN public.subpoena_reason sr ON s.reason_id = sr.id +WHERE sr.code ~ '^[0-9]+$' + 0 + + N + N + N + + + + + + + + + + 80 + 144 + Y + + + + Table output + TableOutput + + Y + + 1 + + none + + + metrics + summonses_list +
all_summonses
+ 1000 + N + N + Y + Y + N + + N + Y + N + + Y + N + + + + recruitment_id + recruitment_id + + + count_init_registration + count_init_registration + + + count_draft_company + count_draft_company + + + count_management_military_registration + count_management_military_registration + + + count_mobilization + count_draft_company + + + info_date + info_date + + + + + + + + + + + + 512 + 144 + Y + + + + + + + N + + diff --git a/mappings_old/metrics/reest_formed.ktr b/mappings_old/metrics/reest_formed.ktr new file mode 100644 index 0000000..59b83f9 --- /dev/null +++ b/mappings_old/metrics/reest_formed.ktr @@ -0,0 +1,689 @@ + + + + reest_formed + + + + 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/06 10:00:36.115 + - + 2024/12/06 10:00:36.115 + 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 + 5432 + + + 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 2beebdaaa1ac8978aaa54aa72ce93bcc9 + + + + + + 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 + + + subpoena + SELECT + 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 (301) THEN 21 + ELSE NULL + END AS summonses_reason_id, + TO_CHAR(NOW() - INTERVAL '1 day', 'YYYY-MM-DD') AS info_dat, + '300cee57-2ce7-4b82-847b-bfbe14d6c7ea' AS recruitment_id, + COALESCE(COUNT(s.id) FILTER (WHERE ss.code IN ('3.7', '3.14', '3', '3.1')), 0) AS count_formed, + COALESCE(COUNT(s.id) FILTER (WHERE ss.code IN ('3.14', '3', '3.1')), 0) AS count_signed, + COALESCE(COUNT(s.id) FILTER (WHERE ss.code IN ('3.71', '3.72')), 0) AS count_refused, + COALESCE(COUNT(s.id) FILTER (WHERE ss.code IN ('3', '3.1')), 0) AS count_sent, + COALESCE(COUNT(s.id) FILTER (WHERE ss.code = '3.1' AND (delivery_info->>'deliveryType' = '14')), 0) AS count_delivered_on_hands, + COALESCE(COUNT(s.id) FILTER (WHERE ss.code = '3.1' AND (delivery_info->>'deliveryType' = '15')), 0) AS count_delivered_by_letter, + COALESCE(COUNT(s.id) FILTER (WHERE ss.code = '3.1' AND (delivery_info->>'autoDelivery' = 'true')), 0) AS count_auto_7_days +FROM public.subpoena s +LEFT JOIN public.subpoena_status ss ON ss.id = s.status_id +LEFT JOIN public.subpoena_reason sr ON s.reason_id = sr.id +GROUP BY summonses_reason_id; + 0 + + N + N + N + + + + + + + + + + 208 + 192 + Y + + + + Table output + TableOutput + + Y + + 1 + + none + + + metrics + summonses_list +
formed_summonses
+ 1000 + N + N + Y + Y + N + + N + Y + N + + Y + N + + + + info_date + info_dat + + + count_formed + count_formed + + + count_signed + count_signed + + + count_sent + count_sent + + + count_delivered_on_hands + count_delivered_on_hands + + + count_delivered_by_letter + count_delivered_by_letter + + + count_auto_7_days + count_auto_7_days + + + summonses_reason_id + summonses_reason_id + + + recruitment_id + recruitment_id + + + + + + + + + + + + 464 + 192 + Y + + + + + + + N + +