diff --git a/mappings_old/country/job_recruitments_country.kjb b/mappings_old/country/job_recruitments_country.kjb index 392df85..bc20c2d 100644 --- a/mappings_old/country/job_recruitments_country.kjb +++ b/mappings_old/country/job_recruitments_country.kjb @@ -1039,7 +1039,7 @@ SQL - DELETE FROM main_dashboard.appeals where recording_date = current_date and schema in ('Ministry', 'Country') + DELETE FROM main_dashboard.appeals where recording_date = current_date and schema = 'Ministry' F F @@ -1057,7 +1057,7 @@ SQL - DELETE FROM main_dashboard.recruitment_campaign where recording_date = current_date and schema in ('Ministry', 'Country') + DELETE FROM main_dashboard.recruitment_campaign where recording_date = current_date and schema = 'Ministry' F F @@ -1075,7 +1075,7 @@ SQL - DELETE FROM main_dashboard.total_registered where recording_date = current_date and schema in ('Ministry', 'Country') + DELETE FROM main_dashboard.total_registered where recording_date = current_date and schema = 'Ministry' F F @@ -1093,7 +1093,7 @@ SQL - DELETE FROM main_dashboard.waiting_registration where recording_date = current_date and schema in ('Ministry', 'Country') + DELETE FROM main_dashboard.waiting_registration where recording_date = current_date and schema = 'Ministry' F F @@ -1111,7 +1111,7 @@ SQL - DELETE FROM recruitment_campaign.subpoenas where recording_date = current_date and schema in ('Ministry', 'Country') + DELETE FROM recruitment_campaign.subpoenas where recording_date = current_date and schema = 'Ministry' F F @@ -1129,7 +1129,7 @@ SQL - DELETE FROM total_registered.reg_mil_cat where recording_date = current_date and schema in ('Ministry', 'Country') + DELETE FROM total_registered.reg_mil_cat where recording_date = current_date and schema = 'Ministry' F F @@ -1147,7 +1147,7 @@ SQL - DELETE FROM total_registered.removed_registry where recording_date = current_date and schema in ('Ministry', 'Country') + DELETE FROM total_registered.removed_registry where recording_date = current_date and schema = 'Ministry' F F @@ -1165,7 +1165,7 @@ SQL - DELETE FROM total_registered.subpoenas where recording_date = current_date and schema in ('Ministry', 'Country') + DELETE FROM total_registered.subpoenas where recording_date = current_date and schema = 'Ministry' F F @@ -1243,7 +1243,7 @@ SQL - DELETE FROM total_registered.marital_status where recording_date = current_date and schema in ('Ministry', 'Country') + DELETE FROM total_registered.marital_status where recording_date = current_date and schema = 'Ministry' F F @@ -1261,7 +1261,7 @@ SQL - DELETE FROM total_registered.child_minor where recording_date = current_date and schema in ('Ministry', 'Country') + DELETE FROM total_registered.child_minor where recording_date = current_date and schema = 'Ministry' F F @@ -1279,7 +1279,7 @@ SQL - DELETE FROM total_registered.age where recording_date = current_date and schema in ('Ministry', 'Country') + DELETE FROM total_registered.age where recording_date = current_date and schema = 'Ministry' F F @@ -1297,7 +1297,7 @@ SQL - DELETE FROM total_registered.driver_license where recording_date = current_date and schema in ('Ministry', 'Country') + DELETE FROM total_registered.driver_license where recording_date = current_date and schema = 'Ministry' F F @@ -1375,7 +1375,7 @@ SQL - DELETE FROM total_registered.education_level where recording_date = current_date and schema in ('Ministry', 'Country') + DELETE FROM total_registered.education_level where recording_date = current_date and schema = 'Ministry' F F @@ -1453,7 +1453,7 @@ SQL - DELETE FROM total_registered.busyness where recording_date = current_date and schema in ('Ministry', 'Country') + DELETE FROM total_registered.busyness where recording_date = current_date and schema = 'Ministry' F F @@ -1531,7 +1531,7 @@ SQL - DELETE FROM recruitment_campaign.appeals where recording_date = current_date and schema in ('Ministry', 'Country') + DELETE FROM recruitment_campaign.appeals where recording_date = current_date and schema = 'Ministry' F F diff --git a/mappings_old/job_recruitments_all.kjb b/mappings_old/job_recruitments_all.kjb index 35405f8..5000d7e 100644 --- a/mappings_old/job_recruitments_all.kjb +++ b/mappings_old/job_recruitments_all.kjb @@ -435,7 +435,7 @@ Y 0 1024 - 352 + 96 @@ -533,7 +533,53 @@ Y 0 1216 - 352 + 96 + + + + Job + + JOB + + filename + + + + + N + N + N + N + + + N + N + Nothing + + Y + N + N + N + N + + N + N + Y + 0 + 1232 + 320 + + + + Success + + SUCCESS + + N + Y + 0 + 1440 + 320 @@ -565,15 +611,6 @@ Y N - - job_recruitments_mil_com - job_recruitments_country - 0 - 0 - Y - N - Y - Start job_recruitments_mil_com @@ -592,6 +629,33 @@ Y N + + Start + job_recruitments_country + 0 + 0 + Y + Y + Y + + + Job + Success + 0 + 0 + Y + Y + N + + + job_recruitments_region + Job + 0 + 0 + Y + Y + N + diff --git a/mappings_old/mil_com/select_recruitments_milcom(m_c).ktr b/mappings_old/mil_com/select_recruitments_milcom(m_c).ktr index 4cae234..7c1c297 100644 --- a/mappings_old/mil_com/select_recruitments_milcom(m_c).ktr +++ b/mappings_old/mil_com/select_recruitments_milcom(m_c).ktr @@ -542,11 +542,11 @@ WHEN schema = 'Department' THEN 'Department' WHEN schema = 'Organization' THEN 'REG_LVL' WHEN schema = 'Region' THEN 'MD_LVL' - WHEN schema = 'Ministry' THEN 'Country' ELSE schema -- на случай, если появится неизвестное значение END AS SCHEMA FROM - ervu_dashboard.recruitment; + ervu_dashboard.recruitment +WHERE schema = 'Department OR WHEN schema = 'Organization' OR schema = 'Region' N diff --git a/mappings_old/ratings/job_ratings.kjb b/mappings_old/ratings/job_ratings.kjb new file mode 100644 index 0000000..d0dc3a4 --- /dev/null +++ b/mappings_old/ratings/job_ratings.kjb @@ -0,0 +1,757 @@ + + + job_ratings + + + + 0 + / + - + 2024/12/25 11:26:51.530 + - + 2024/12/25 11:26:51.530 + + + REG_ID + + + + + VK_ARRAY + + + + + + ervu-dashboard + dashboard-dbhost + POSTGRESQL + Native + dashboard-dbname + 1111 + dashboard-dbuser + Encrypted 2daf9dca008c89396af54aa72ce93bcc9 + + + + + + EXTRA_OPTION_POSTGRESQL.stringtype + unspecified + + + FORCE_IDENTIFIERS_TO_LOWERCASE + N + + + FORCE_IDENTIFIERS_TO_UPPERCASE + N + + + IS_CLUSTERED + N + + + PORT_NUMBER + 1111 + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + SUPPORTS_BOOLEAN_DATA_TYPE + Y + + + SUPPORTS_TIMESTAMP_DATA_TYPE + N + + + USE_POOLING + N + + + + + + + + + + + + + + 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 + 384 + 352 + + + + Transformation + + TRANS + + filename + + + + N + N + N + N + N + N + + + N + N + Basic + N + + N + Y + N + N + N + + N + Y + 0 + 544 + 352 + + + + ratings.appear_subpoena.ktr + + TRANS + + filename + + ${Internal.Entry.Current.Directory}/ratings.appear_subpoena.ktr + + N + Y + Y + N + N + N + + + N + N + Basic + N + + N + Y + N + N + N + Pentaho local + + Y + + VK_ARRAY + VK_ARRAY_ID + + + + REG_ID + RECRUITMENT_REG_ID + + + + N + Y + 0 + 1024 + 224 + + + + ratings.conscription_info.ktr + + TRANS + + filename + + ${Internal.Entry.Current.Directory}/ratings.conscription_info.ktr + + N + Y + Y + N + N + N + + + N + N + Basic + N + + N + Y + N + N + N + Pentaho local + + Y + + VK_ARRAY + VK_ARRAY_ID + + + + REG_ID + RECRUITMENT_REG_ID + + + + N + Y + 0 + 1024 + 352 + + + + ratings.consideration_complaint.ktr + + TRANS + + filename + + ${Internal.Entry.Current.Directory}/ratings.consideration_complaint.ktr + + N + Y + Y + N + N + N + + + N + N + Basic + N + + N + Y + N + N + N + Pentaho local + + Y + + VK_ARRAY + VK_ARRAY_ID + + + + REG_ID + RECRUITMENT_REG_ID + + + + N + Y + 0 + 1024 + 480 + + + + SQL ratings.appear_subppoena + + SQL + + delete from ratings.appear_subppoena where recording_date = current_date + F + F + + F + ervu-dashboard + N + Y + 0 + 704 + 224 + + + + SQL ratings.conscription_info + + SQL + + delete from ratings.conscription_info where recording_date = current_date + F + F + + F + ervu-dashboard + N + Y + 0 + 704 + 352 + + + + SQL ratings.consideration_complaint + + SQL + + delete from ratings.consideration_complaint where recording_date = current_date + F + F + + F + ervu-dashboard + N + Y + 0 + 704 + 480 + + + + Success + + SUCCESS + + N + Y + 0 + 1264 + 224 + + + + Success 2 + + SUCCESS + + N + Y + 0 + 1264 + 352 + + + + Success 3 + + SUCCESS + + N + Y + 0 + 1264 + 480 + + + + + + Start + Transformation + 0 + 0 + Y + Y + Y + + + Transformation + SQL ratings.appear_subppoena + 0 + 0 + Y + Y + N + + + Transformation + SQL ratings.conscription_info + 0 + 0 + N + Y + N + + + Transformation + SQL ratings.consideration_complaint + 0 + 0 + Y + Y + N + + + SQL ratings.appear_subppoena + ratings.appear_subpoena.ktr + 0 + 0 + Y + Y + N + + + SQL ratings.conscription_info + ratings.conscription_info.ktr + 0 + 0 + Y + Y + N + + + SQL ratings.consideration_complaint + ratings.consideration_complaint.ktr + 0 + 0 + Y + Y + N + + + ratings.appear_subpoena.ktr + Success + 0 + 0 + Y + Y + N + + + ratings.conscription_info.ktr + Success 2 + 0 + 0 + Y + Y + N + + + ratings.consideration_complaint.ktr + Success 3 + 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/ratings/ratings.appear_subpoena.ktr b/mappings_old/ratings/ratings.appear_subpoena.ktr new file mode 100644 index 0000000..c1d4e44 --- /dev/null +++ b/mappings_old/ratings/ratings.appear_subpoena.ktr @@ -0,0 +1,759 @@ + + + + ratingsappear_subpoena + + + + 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/25 11:29:51.642 + - + 2024/12/25 11:29:51.642 + + N + + + + + ervu-dashboard + dashboard-dbhost + POSTGRESQL + Native + dashboard-dbname + 1111 + dashboard-dbuser + Encrypted 2daf9dca008c89396af54aa72ce93bcc9 + + + + + + EXTRA_OPTION_POSTGRESQL.stringtype + unspecified + + + FORCE_IDENTIFIERS_TO_LOWERCASE + N + + + FORCE_IDENTIFIERS_TO_UPPERCASE + N + + + IS_CLUSTERED + N + + + PORT_NUMBER + 1111 + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + SUPPORTS_BOOLEAN_DATA_TYPE + Y + + + SUPPORTS_TIMESTAMP_DATA_TYPE + N + + + USE_POOLING + N + + + + + postgres.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 + 5555 + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + SUPPORTS_BOOLEAN_DATA_TYPE + N + + + SUPPORTS_TIMESTAMP_DATA_TYPE + N + + + USE_POOLING + N + + + + + + Table input + Get variables + Y + + + Get variables + Select values + Y + + + Select values + Insert / update + Y + + + + Table input + TableInput + + Y + + 1 + + none + + + postgres.subpoena + WITH +total AS ( + SELECT + ss.code, + s.department_id + FROM public.subpoena s + JOIN subpoena_status ss + ON s.status_id = ss.id + WHERE ('${VK_ARRAY}' IS NULL + OR '${VK_ARRAY}' = '' + OR s.department_id = ANY ( + string_to_array( + trim(both '{}' FROM replace('${VK_ARRAY}', ' ', '')), ',' + )::uuid[] + ) + ) +) +SELECT + '${REG_ID}' AS region_id, + COUNT(*) FILTER (WHERE tt.code IN ('4.1', '4.2', '4')) AS appear_mil_com, + ROUND( + COUNT(*) FILTER (WHERE tt.code IN ('4.1', '4.2', '4'))::NUMERIC / NULLIF(COUNT(*), 0) * 100, 2 + ) AS appear_mil_com_percent +FROM total tt; + 0 + + N + Y + N + + + + + + + + + + 368 + 352 + Y + + + + Insert / update + InsertUpdate + + Y + + 1 + + none + + + ervu-dashboard + 100 + N + + ratings +
appear_subppoena
+ + REG_ID + id_region + = + + + + appear_mil_com + appear_mil_com + Y + + + appear_mil_com_percent + appear_mil_com_percent + Y + + + id_region + region_id + N + + + + + + + + + + + + 1008 + 352 + Y + + + + Select values + SelectValues + + Y + + 1 + + none + + + + N + + REG_ID + REG_ID + String + -2 + -2 + + false + + + false + + + + + + + + + + + + + + + + + 768 + 352 + Y + + + + Get variables + GetVariable + + Y + + 1 + + none + + + + + REG_ID + + String + + + + + -1 + -1 + none + + + + + + + + + + + + 576 + 352 + Y + + + + + + + N + + diff --git a/mappings_old/ratings/ratings.conscription_info.ktr b/mappings_old/ratings/ratings.conscription_info.ktr new file mode 100644 index 0000000..cb48495 --- /dev/null +++ b/mappings_old/ratings/ratings.conscription_info.ktr @@ -0,0 +1,446 @@ + + + + ratingsconscription_info + + + + 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/25 11:30:24.715 + - + 2024/12/25 11:30:24.715 + + N + + + + + + + + + + N + + diff --git a/mappings_old/ratings/ratings.consideration_complaint.ktr b/mappings_old/ratings/ratings.consideration_complaint.ktr new file mode 100644 index 0000000..6215187 --- /dev/null +++ b/mappings_old/ratings/ratings.consideration_complaint.ktr @@ -0,0 +1,757 @@ + + + + ratingsconsideration_complaint + + + + 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/25 11:31:04.516 + - + 2024/12/25 11:31:04.516 + + N + + + + + ervu-dashboard + dashboard-dbhost + POSTGRESQL + Native + dashboard-dbname + 1111 + dashboard-dbuser + Encrypted 2daf9dca008c89396af54aa72ce93bcc9 + + + + + + EXTRA_OPTION_POSTGRESQL.stringtype + unspecified + + + FORCE_IDENTIFIERS_TO_LOWERCASE + N + + + FORCE_IDENTIFIERS_TO_UPPERCASE + N + + + IS_CLUSTERED + N + + + PORT_NUMBER + 1111 + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + SUPPORTS_BOOLEAN_DATA_TYPE + Y + + + SUPPORTS_TIMESTAMP_DATA_TYPE + N + + + USE_POOLING + N + + + + + postgres.appeal-document-service + appeal-dbhost + POSTGRESQL + Native + appeal-dbname + 2222 + appeal-dbuser + Encrypted 2be98afa91ad79785a754aa72ce93bcc9 + + + + + + FORCE_IDENTIFIERS_TO_LOWERCASE + N + + + FORCE_IDENTIFIERS_TO_UPPERCASE + N + + + IS_CLUSTERED + N + + + PORT_NUMBER + 2222 + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + SUPPORTS_BOOLEAN_DATA_TYPE + N + + + SUPPORTS_TIMESTAMP_DATA_TYPE + N + + + USE_POOLING + N + + + + + + Table input + Get variables + Y + + + Get variables + Select values + Y + + + Select values + Insert / update + Y + + + + Get variables + GetVariable + + Y + + 1 + + none + + + + + REG_ID + + String + + + + + -1 + -1 + none + + + + + + + + + + + + 544 + 368 + Y + + + + Select values + SelectValues + + Y + + 1 + + none + + + + N + + REG_ID + REG_ID + String + -2 + -2 + + false + + + false + + + + + + + + + + + + + + + + + 784 + 368 + Y + + + + Insert / update + InsertUpdate + + Y + + 1 + + none + + + ervu-dashboard + 100 + N + + ratings +
consideration_complaint
+ + REG_ID + id_region + = + + + + consideration_complaint + consideration_complaint + Y + + + consideration_complaint_percent + consideration_complaint_percent + Y + + + id_region + region_id + N + + + + + + + + + + + + 1024 + 368 + Y + + + + Table input + TableInput + + Y + + 1 + + none + + + postgres.appeal-document-service + -- '1' - Удовлетворена, '2' - Частично удовлетворена, '3' - Отказано в удовлетворении +WITH total AS ( + SELECT * + FROM public.appeal_document ad + WHERE extra_info->>'result' IN ('1', '2', '3') + AND ( + '${VK_ARRAY}' IS NULL + OR '${VK_ARRAY}' = '' + OR ad.vk_id = ANY ( + string_to_array( + trim(both '{}' FROM replace('${VK_ARRAY}', ' ', '')), ',' + )::uuid[] + ) + ) +) +SELECT + '${REG_ID}' AS region_id, + COUNT(*) FILTER (WHERE tt.extra_info->>'result' IN ('1', '2')) AS consideration_complaint, + ROUND( + COUNT(*) FILTER (WHERE tt.extra_info->>'result' IN ('1', '2'))::NUMERIC / NULLIF(COUNT(*), 0) * 100, 2 + ) AS consideration_complaint_percent +FROM total tt; + 0 + + N + Y + N + + + + + + + + + + 320 + 368 + Y + + + + + + + N + +