micord/ervu-dashboard-etl
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

ERVU-505: fix

Browse source
This commit is contained in:
adel.ka 2025-07-24 15:36:19 +03:00
parent bca40fc614
commit c7ce734706
14 changed files with 135 additions and 94 deletions
Download patch file Download diff file Expand all files Collapse all files

2
mappings_new/info_recruits/citizen_tables/passport/branching_passport.hpl
View file

@ -119,13 +119,11 @@
</partitioning>
<fields>
<field>
<default_value/>
<field_name>pipeline</field_name>
<variable_name>PIPE</variable_name>
<variable_type>PARENT_WORKFLOW</variable_type>
</field>
<field>
<default_value/>
<field_name>status</field_name>
<variable_name>STATUS</variable_name>
<variable_type>PARENT_WORKFLOW</variable_type>

10
mappings_new/info_recruits/citizen_tables/passport/checkpoints/checkpoint_job_passport.hpl
View file

@ -64,7 +64,6 @@
</partitioning>
<abort_option>ABORT_WITH_ERROR</abort_option>
<always_log_rows>Y</always_log_rows>
<message/>
<row_threshold>0</row_threshold>
<attributes/>
<GUI>
@ -98,7 +97,6 @@
<value>
<isnull>N</isnull>
<length>-1</length>
<mask/>
<name>constant</name>
<precision>-1</precision>
<text>passport_flow1</text>
@ -147,7 +145,6 @@
<value>
<isnull>N</isnull>
<length>-1</length>
<mask/>
<name>constant</name>
<precision>-1</precision>
<text>passport_flow2</text>
@ -196,7 +193,6 @@
<value>
<isnull>N</isnull>
<length>-1</length>
<mask/>
<name>constant</name>
<precision>-1</precision>
<text>passport_flow3</text>
@ -245,7 +241,6 @@
<value>
<isnull>N</isnull>
<length>-1</length>
<mask/>
<name>constant</name>
<precision>-1</precision>
<text>passport_flow4</text>
@ -294,7 +289,6 @@
<value>
<isnull>N</isnull>
<length>-1</length>
<mask/>
<name>constant</name>
<precision>-1</precision>
<text>passport_flow5</text>
@ -601,7 +595,7 @@
<defaultPathLeafToNull>Y</defaultPathLeafToNull>
<rownum_field/>
<file>
<name>${PROJECT_HOME}/info_recruits/citizen_tables/child/checkpoints/state_passport_flow4.json</name>
<name>${PROJECT_HOME}/info_recruits/citizen_tables/passport/checkpoints/state_passport_flow4.json</name>
<filemask/>
<exclude_filemask/>
<file_required>N</file_required>
@ -676,7 +670,7 @@
<defaultPathLeafToNull>Y</defaultPathLeafToNull>
<rownum_field/>
<file>
<name>${PROJECT_HOME}/info_recruits/citizen_tables/child/checkpoints/state_passport_flow5.json</name>
<name>${PROJECT_HOME}/info_recruits/citizen_tables/passport/checkpoints/state_passport_flow5.json</name>
<filemask/>
<exclude_filemask/>
<file_required>N</file_required>

5
mappings_new/info_recruits/citizen_tables/passport/checkpoints/checkpoint_passport_error.hpl
View file

@ -112,7 +112,7 @@ flow_ranges AS (
recr_inf AS (
SELECT DISTINCT COALESCE(cit.recruitment_id, cit.target_recruitment_id) AS idm_id
FROM ervu_dashboard.citizen cit
join ervu_dashboard.citizen_child ch on ch.recruit_id = cit.recruit_id
join ervu_dashboard.passport ps on ps.recruit_id = cit.recruit_id
),
flow_data AS (
SELECT
@ -252,11 +252,14 @@ select * from for_checkpoints</sql>
<only_when_have_rows>N</only_when_have_rows>
<partitioning_daily>N</partitioning_daily>
<partitioning_enabled>N</partitioning_enabled>
<partitioning_field/>
<partitioning_monthly>Y</partitioning_monthly>
<return_field/>
<return_keys>N</return_keys>
<schema>public</schema>
<specify_fields>N</specify_fields>
<table>etl_checkpoints</table>
<tablename_field/>
<tablename_in_field>N</tablename_in_field>
<tablename_in_table>Y</tablename_in_table>
<truncate>N</truncate>

24
mappings_new/info_recruits/citizen_tables/passport/delta_passport.hpl
View file

@ -46,6 +46,12 @@
<name>recruit_id</name>
<name2/>
</key>
<key>
<condition>=</condition>
<field>actual</field>
<name>actual</name>
<name2/>
</key>
<schema>ervu_dashboard</schema>
<table>passport</table>
<value>
@ -116,18 +122,20 @@
WHEN NULLIF(p.passport_data->>'kodStatus', '') = '1' THEN TRUE
ELSE FALSE
END AS actual
FROM ervu_person_registry_raw.recruits_info ri
FROM recruits_info ri
JOIN ervu_dashboard.citizen r
ON r.recruit_id = ri.recruit_id --AND '${ID_F1}' != '' -- Проверка на пустую строку
--AND COALESCE(ri.current_recruitment_id, ri.target_recruitment_id) = '${ID_F1}'
AND '${M_R_CR_DATE}'::timestamp >= r.system_create_date
AND r.system_update_date >= '${M_R_UP_DATE}'::timestamp
AND '${M_R_CR_DATE}'::timestamp >= r.recruit_create_date
AND r.update_date >= '${M_R_UP_DATE}'::timestamp
JOIN LATERAL (
VALUES
(ri.info->'svedFL'->'svedBS'->'pasportRF'->'aktPasportRF'),
(ri.info->'svedFL'->'svedBS'->'pasportRF'->'predPasportRF')
) AS p(passport_data)
ON p.passport_data IS NOT NULL
SELECT passport_data
FROM UNNEST(ARRAY[
ri.info->'svedFL'->'svedBS'->'pasportRF'->'aktPasportRF',
ri.info->'svedFL'->'svedBS'->'pasportRF'->'aktPasportRF'
]) AS passport_data
WHERE passport_data IS NOT NULL AND passport_data::text &lt;&gt; 'null'
) AS p ON TRUE
</sql>
<variables_active>Y</variables_active>
<attributes/>

55
mappings_new/info_recruits/citizen_tables/passport/job_passport.hwf
View file

@ -108,7 +108,7 @@
<clear_files>N</clear_files>
<clear_rows>N</clear_rows>
<create_parent_folder>N</create_parent_folder>
<exec_per_row>N</exec_per_row>
<exec_per_row>Y</exec_per_row>
<filename>${PROJECT_HOME}/info_recruits/citizen_tables/passport/parallel/passport_flow1.hpl</filename>
<loglevel>Basic</loglevel>
<parameters>
@ -118,7 +118,7 @@
</parameter>
<pass_all_parameters>Y</pass_all_parameters>
</parameters>
<params_from_previous>N</params_from_previous>
<params_from_previous>Y</params_from_previous>
<run_configuration>local</run_configuration>
<set_append_logfile>N</set_append_logfile>
<set_logfile>N</set_logfile>
@ -138,7 +138,7 @@
<clear_files>N</clear_files>
<clear_rows>N</clear_rows>
<create_parent_folder>N</create_parent_folder>
<exec_per_row>N</exec_per_row>
<exec_per_row>Y</exec_per_row>
<filename>${PROJECT_HOME}/info_recruits/citizen_tables/passport/parallel/passport_flow2.hpl</filename>
<loglevel>Basic</loglevel>
<parameters>
@ -148,7 +148,7 @@
</parameter>
<pass_all_parameters>Y</pass_all_parameters>
</parameters>
<params_from_previous>N</params_from_previous>
<params_from_previous>Y</params_from_previous>
<run_configuration>local</run_configuration>
<set_append_logfile>N</set_append_logfile>
<set_logfile>N</set_logfile>
@ -168,7 +168,7 @@
<clear_files>N</clear_files>
<clear_rows>N</clear_rows>
<create_parent_folder>N</create_parent_folder>
<exec_per_row>N</exec_per_row>
<exec_per_row>Y</exec_per_row>
<filename>${PROJECT_HOME}/info_recruits/citizen_tables/passport/parallel/passport_flow3.hpl</filename>
<loglevel>Basic</loglevel>
<parameters>
@ -178,7 +178,7 @@
</parameter>
<pass_all_parameters>Y</pass_all_parameters>
</parameters>
<params_from_previous>N</params_from_previous>
<params_from_previous>Y</params_from_previous>
<run_configuration>local</run_configuration>
<set_append_logfile>N</set_append_logfile>
<set_logfile>N</set_logfile>
@ -198,7 +198,7 @@
<clear_files>N</clear_files>
<clear_rows>N</clear_rows>
<create_parent_folder>N</create_parent_folder>
<exec_per_row>N</exec_per_row>
<exec_per_row>Y</exec_per_row>
<filename>${PROJECT_HOME}/info_recruits/citizen_tables/passport/parallel/passport_flow4.hpl</filename>
<loglevel>Basic</loglevel>
<parameters>
@ -208,7 +208,7 @@
</parameter>
<pass_all_parameters>Y</pass_all_parameters>
</parameters>
<params_from_previous>N</params_from_previous>
<params_from_previous>Y</params_from_previous>
<run_configuration>local</run_configuration>
<set_append_logfile>N</set_append_logfile>
<set_logfile>N</set_logfile>
@ -228,7 +228,7 @@
<clear_files>N</clear_files>
<clear_rows>N</clear_rows>
<create_parent_folder>N</create_parent_folder>
<exec_per_row>N</exec_per_row>
<exec_per_row>Y</exec_per_row>
<filename>${PROJECT_HOME}/info_recruits/citizen_tables/passport/parallel/passport_flow5.hpl</filename>
<loglevel>Basic</loglevel>
<parameters>
@ -238,7 +238,7 @@
</parameter>
<pass_all_parameters>Y</pass_all_parameters>
</parameters>
<params_from_previous>N</params_from_previous>
<params_from_previous>Y</params_from_previous>
<run_configuration>local</run_configuration>
<set_append_logfile>N</set_append_logfile>
<set_logfile>N</set_logfile>
@ -569,11 +569,7 @@
<type>SIMPLE_EVAL</type>
<attributes/>
<comparevalue>SUCCESS</comparevalue>
<fieldname/>
<fieldtype>string</fieldtype>
<mask/>
<maxvalue/>
<minvalue/>
<successbooleancondition>true</successbooleancondition>
<successcondition>equal</successcondition>
<successnumbercondition>equal</successnumbercondition>
@ -591,7 +587,11 @@
<type>SIMPLE_EVAL</type>
<attributes/>
<comparevalue>ERROR</comparevalue>
<fieldname/>
<fieldtype>string</fieldtype>
<mask/>
<maxvalue/>
<minvalue/>
<successbooleancondition>true</successbooleancondition>
<successcondition>equal</successcondition>
<successnumbercondition>equal</successnumbercondition>
@ -676,7 +676,7 @@
<clear_files>N</clear_files>
<clear_rows>N</clear_rows>
<create_parent_folder>N</create_parent_folder>
<exec_per_row>N</exec_per_row>
<exec_per_row>Y</exec_per_row>
<filename>${PROJECT_HOME}/info_recruits/citizen_tables/passport/parallel/passport_flow1.hpl</filename>
<loglevel>Basic</loglevel>
<parameters>
@ -686,7 +686,7 @@
</parameter>
<pass_all_parameters>Y</pass_all_parameters>
</parameters>
<params_from_previous>N</params_from_previous>
<params_from_previous>Y</params_from_previous>
<run_configuration>local</run_configuration>
<set_append_logfile>N</set_append_logfile>
<set_logfile>N</set_logfile>
@ -706,7 +706,7 @@
<clear_files>N</clear_files>
<clear_rows>N</clear_rows>
<create_parent_folder>N</create_parent_folder>
<exec_per_row>N</exec_per_row>
<exec_per_row>Y</exec_per_row>
<filename>${PROJECT_HOME}/info_recruits/citizen_tables/passport/parallel/passport_flow2.hpl</filename>
<loglevel>Basic</loglevel>
<parameters>
@ -716,7 +716,7 @@
</parameter>
<pass_all_parameters>Y</pass_all_parameters>
</parameters>
<params_from_previous>N</params_from_previous>
<params_from_previous>Y</params_from_previous>
<run_configuration>local</run_configuration>
<set_append_logfile>N</set_append_logfile>
<set_logfile>N</set_logfile>
@ -736,7 +736,7 @@
<clear_files>N</clear_files>
<clear_rows>N</clear_rows>
<create_parent_folder>N</create_parent_folder>
<exec_per_row>N</exec_per_row>
<exec_per_row>Y</exec_per_row>
<filename>${PROJECT_HOME}/info_recruits/citizen_tables/passport/parallel/passport_flow3.hpl</filename>
<loglevel>Basic</loglevel>
<parameters>
@ -746,7 +746,7 @@
</parameter>
<pass_all_parameters>Y</pass_all_parameters>
</parameters>
<params_from_previous>N</params_from_previous>
<params_from_previous>Y</params_from_previous>
<run_configuration>local</run_configuration>
<set_append_logfile>N</set_append_logfile>
<set_logfile>N</set_logfile>
@ -766,7 +766,7 @@
<clear_files>N</clear_files>
<clear_rows>N</clear_rows>
<create_parent_folder>N</create_parent_folder>
<exec_per_row>N</exec_per_row>
<exec_per_row>Y</exec_per_row>
<filename>${PROJECT_HOME}/info_recruits/citizen_tables/passport/parallel/passport_flow4.hpl</filename>
<loglevel>Basic</loglevel>
<parameters>
@ -776,7 +776,7 @@
</parameter>
<pass_all_parameters>Y</pass_all_parameters>
</parameters>
<params_from_previous>N</params_from_previous>
<params_from_previous>Y</params_from_previous>
<run_configuration>local</run_configuration>
<set_append_logfile>N</set_append_logfile>
<set_logfile>N</set_logfile>
@ -796,7 +796,7 @@
<clear_files>N</clear_files>
<clear_rows>N</clear_rows>
<create_parent_folder>N</create_parent_folder>
<exec_per_row>N</exec_per_row>
<exec_per_row>Y</exec_per_row>
<filename>${PROJECT_HOME}/info_recruits/citizen_tables/passport/parallel/passport_flow5.hpl</filename>
<loglevel>Basic</loglevel>
<parameters>
@ -806,7 +806,7 @@
</parameter>
<pass_all_parameters>Y</pass_all_parameters>
</parameters>
<params_from_previous>N</params_from_previous>
<params_from_previous>Y</params_from_previous>
<run_configuration>local</run_configuration>
<set_append_logfile>N</set_append_logfile>
<set_logfile>N</set_logfile>
@ -1122,13 +1122,10 @@
<create_parent_folder>N</create_parent_folder>
<exec_per_row>N</exec_per_row>
<filename>${PROJECT_HOME}/info_recruits/citizen_tables/passport/delta_passport.hpl</filename>
<logext/>
<logfile/>
<loglevel>Basic</loglevel>
<parameters>
<parameter>
<name>M_R_UP_DATE</name>
<stream_name/>
<value>${M_R_UP_DATE}</value>
</parameter>
<pass_all_parameters>Y</pass_all_parameters>
@ -1468,8 +1465,8 @@
<from>Simple passport WHERE ERROR</from>
<to>checkpoint_passport_error.hpl</to>
<enabled>Y</enabled>
<evaluation>N</evaluation>
<unconditional>Y</unconditional>
<evaluation>Y</evaluation>
<unconditional>N</unconditional>
</hop>
<hop>
<from>branching_passport.hpl</from>

2
mappings_new/info_recruits/citizen_tables/passport/job_recruit_last_update_date.hwf
View file

@ -41,7 +41,7 @@
<clear_rows>N</clear_rows>
<create_parent_folder>N</create_parent_folder>
<exec_per_row>N</exec_per_row>
<filename>${PROJECT_HOME}/info_recruits/raw_data/info_recruits/recruit_update_date_ervu_dashboard.hpl</filename>
<filename>${PROJECT_HOME}/info_recruits/citizen_tables/passport/recruit_update_date_ervu_dashboard.hpl</filename>
<logext/>
<logfile/>
<loglevel>Basic</loglevel>

28
mappings_new/info_recruits/citizen_tables/passport/parallel/passport_flow1.hpl
View file

@ -50,10 +50,6 @@
</partitioning>
<fields>
<field>
<currency/>
<decimal/>
<format/>
<group/>
<length>-1</length>
<name>recruitment_id</name>
<precision>-1</precision>
@ -88,6 +84,12 @@
<name>recruit_id</name>
<name2/>
</key>
<key>
<condition>=</condition>
<field>actual</field>
<name>actual</name>
<name2/>
</key>
<schema>ervu_dashboard</schema>
<table>passport</table>
<value>
@ -195,18 +197,20 @@
WHEN NULLIF(p.passport_data->>'kodStatus', '') = '1' THEN TRUE
ELSE FALSE
END AS actual
FROM ervu_person_registry_raw.recruits_info ri
FROM recruits_info ri
JOIN ervu_dashboard.citizen r
ON r.recruit_id = ri.recruit_id
AND '${ID_F1}' != ''
AND COALESCE(ri.current_recruitment_id, ri.target_recruitment_id) = '${ID_F2}'
AND '${M_R_CR_DATE}'::timestamp >= r.system_create_date
AND COALESCE(ri.current_recruitment_id, ri.target_recruitment_id) = '${ID_F1}'
AND '${M_R_CR_DATE}'::timestamp >= r.recruit_create_date
JOIN LATERAL (
VALUES
(ri.info->'svedFL'->'svedBS'->'pasportRF'->'aktPasportRF'),
(ri.info->'svedFL'->'svedBS'->'pasportRF'->'predPasportRF')
) AS p(passport_data)
ON p.passport_data IS NOT NULL
SELECT passport_data
FROM UNNEST(ARRAY[
ri.info->'svedFL'->'svedBS'->'pasportRF'->'aktPasportRF',
ri.info->'svedFL'->'svedBS'->'pasportRF'->'aktPasportRF'
]) AS passport_data
WHERE passport_data IS NOT NULL AND passport_data::text &lt;&gt; 'null'
) AS p ON TRUE
</sql>
<variables_active>Y</variables_active>
<attributes/>

25
mappings_new/info_recruits/citizen_tables/passport/parallel/passport_flow2.hpl
View file

@ -44,6 +44,13 @@
<condition>=</condition>
<field>recruit_id</field>
<name>recruit_id</name>
<name2/>
</key>
<key>
<condition>=</condition>
<field>actual</field>
<name>actual</name>
<name2/>
</key>
<schema>ervu_dashboard</schema>
<table>passport</table>
@ -115,18 +122,20 @@
WHEN NULLIF(p.passport_data->>'kodStatus', '') = '1' THEN TRUE
ELSE FALSE
END AS actual
FROM ervu_person_registry_raw.recruits_info ri
FROM recruits_info ri
JOIN ervu_dashboard.citizen r
ON r.recruit_id = ri.recruit_id
AND '${ID_F1}' != ''
AND '${ID_F2}' != ''
AND COALESCE(ri.current_recruitment_id, ri.target_recruitment_id) = '${ID_F2}'
AND '${M_R_CR_DATE}'::timestamp >= r.system_create_date
AND '${M_R_CR_DATE}'::timestamp >= r.recruit_create_date
JOIN LATERAL (
VALUES
(ri.info->'svedFL'->'svedBS'->'pasportRF'->'aktPasportRF'),
(ri.info->'svedFL'->'svedBS'->'pasportRF'->'predPasportRF')
) AS p(passport_data)
ON p.passport_data IS NOT NULL
SELECT passport_data
FROM UNNEST(ARRAY[
ri.info->'svedFL'->'svedBS'->'pasportRF'->'aktPasportRF',
ri.info->'svedFL'->'svedBS'->'pasportRF'->'aktPasportRF'
]) AS passport_data
WHERE passport_data IS NOT NULL AND passport_data::text &lt;&gt; 'null'
) AS p ON TRUE
</sql>
<variables_active>Y</variables_active>
<attributes/>

23
mappings_new/info_recruits/citizen_tables/passport/parallel/passport_flow3.hpl
View file

@ -44,6 +44,13 @@
<condition>=</condition>
<field>recruit_id</field>
<name>recruit_id</name>
<name2/>
</key>
<key>
<condition>=</condition>
<field>actual</field>
<name>actual</name>
<name2/>
</key>
<schema>ervu_dashboard</schema>
<table>passport</table>
@ -115,18 +122,20 @@
WHEN NULLIF(p.passport_data->>'kodStatus', '') = '1' THEN TRUE
ELSE FALSE
END AS actual
FROM ervu_person_registry_raw.recruits_info ri
FROM recruits_info ri
JOIN ervu_dashboard.citizen r
ON r.recruit_id = ri.recruit_id
AND '${ID_F3}' != ''
AND COALESCE(ri.current_recruitment_id, ri.target_recruitment_id) = '${ID_F3}'
AND '${M_R_CR_DATE}'::timestamp >= r.system_create_date
AND '${M_R_CR_DATE}'::timestamp >= r.recruit_create_date
JOIN LATERAL (
VALUES
(ri.info->'svedFL'->'svedBS'->'pasportRF'->'aktPasportRF'),
(ri.info->'svedFL'->'svedBS'->'pasportRF'->'predPasportRF')
) AS p(passport_data)
ON p.passport_data IS NOT NULL
SELECT passport_data
FROM UNNEST(ARRAY[
ri.info->'svedFL'->'svedBS'->'pasportRF'->'aktPasportRF',
ri.info->'svedFL'->'svedBS'->'pasportRF'->'aktPasportRF'
]) AS passport_data
WHERE passport_data IS NOT NULL AND passport_data::text &lt;&gt; 'null'
) AS p ON TRUE
</sql>
<variables_active>Y</variables_active>
<attributes/>

22
mappings_new/info_recruits/citizen_tables/passport/parallel/passport_flow4.hpl
View file

@ -46,6 +46,12 @@
<name>recruit_id</name>
<name2/>
</key>
<key>
<condition>=</condition>
<field>actual</field>
<name>actual</name>
<name2/>
</key>
<schema>ervu_dashboard</schema>
<table>passport</table>
<value>
@ -116,18 +122,20 @@
WHEN NULLIF(p.passport_data->>'kodStatus', '') = '1' THEN TRUE
ELSE FALSE
END AS actual
FROM ervu_person_registry_raw.recruits_info ri
FROM recruits_info ri
JOIN ervu_dashboard.citizen r
ON r.recruit_id = ri.recruit_id
AND '${ID_F4}' != ''
AND COALESCE(ri.current_recruitment_id, ri.target_recruitment_id) = '${ID_F4}'
AND '${M_R_CR_DATE}'::timestamp >= r.system_create_date
AND '${M_R_CR_DATE}'::timestamp >= r.recruit_create_date
JOIN LATERAL (
VALUES
(ri.info->'svedFL'->'svedBS'->'pasportRF'->'aktPasportRF'),
(ri.info->'svedFL'->'svedBS'->'pasportRF'->'predPasportRF')
) AS p(passport_data)
ON p.passport_data IS NOT NULL
SELECT passport_data
FROM UNNEST(ARRAY[
ri.info->'svedFL'->'svedBS'->'pasportRF'->'aktPasportRF',
ri.info->'svedFL'->'svedBS'->'pasportRF'->'aktPasportRF'
]) AS passport_data
WHERE passport_data IS NOT NULL AND passport_data::text &lt;&gt; 'null'
) AS p ON TRUE
</sql>
<variables_active>Y</variables_active>
<attributes/>

22
mappings_new/info_recruits/citizen_tables/passport/parallel/passport_flow5.hpl
View file

@ -46,6 +46,12 @@
<name>recruit_id</name>
<name2/>
</key>
<key>
<condition>=</condition>
<field>actual</field>
<name>actual</name>
<name2/>
</key>
<schema>ervu_dashboard</schema>
<table>passport</table>
<value>
@ -116,18 +122,20 @@
WHEN NULLIF(p.passport_data->>'kodStatus', '') = '1' THEN TRUE
ELSE FALSE
END AS actual
FROM ervu_person_registry_raw.recruits_info ri
FROM recruits_info ri
JOIN ervu_dashboard.citizen r
ON r.recruit_id = ri.recruit_id
AND '${ID_F5}' != ''
AND COALESCE(ri.current_recruitment_id, ri.target_recruitment_id) = '${ID_F5}'
AND '${M_R_CR_DATE}'::timestamp >= r.system_create_date
AND '${M_R_CR_DATE}'::timestamp >= r.recruit_create_date
JOIN LATERAL (
VALUES
(ri.info->'svedFL'->'svedBS'->'pasportRF'->'aktPasportRF'),
(ri.info->'svedFL'->'svedBS'->'pasportRF'->'predPasportRF')
) AS p(passport_data)
ON p.passport_data IS NOT NULL
SELECT passport_data
FROM UNNEST(ARRAY[
ri.info->'svedFL'->'svedBS'->'pasportRF'->'aktPasportRF',
ri.info->'svedFL'->'svedBS'->'pasportRF'->'aktPasportRF'
]) AS passport_data
WHERE passport_data IS NOT NULL AND passport_data::text &lt;&gt; 'null'
) AS p ON TRUE
</sql>
<variables_active>Y</variables_active>
<attributes/>

7
mappings_new/info_recruits/citizen_tables/passport/recruit_update_date_ervu_dashboard.hpl
View file

@ -45,8 +45,8 @@
updated_at AS system_update_date,
current_timestamp AS record_created,
'job_recruits_info' AS workflow
FROM ervu_person_registry_raw.recruits_info
WHERE updated_at = (SELECT MAX(updated_at) FROM ervu_person_registry_raw.recruits_info)
FROM recruits_info
WHERE updated_at = (SELECT MAX(updated_at) FROM recruits_info)
limit 1</sql>
<variables_active>N</variables_active>
<attributes/>
@ -74,11 +74,14 @@ limit 1</sql>
<only_when_have_rows>N</only_when_have_rows>
<partitioning_daily>N</partitioning_daily>
<partitioning_enabled>N</partitioning_enabled>
<partitioning_field/>
<partitioning_monthly>Y</partitioning_monthly>
<return_field/>
<return_keys>N</return_keys>
<schema>public</schema>
<specify_fields>N</specify_fields>
<table>recruit_create</table>
<tablename_field/>
<tablename_in_field>N</tablename_in_field>
<tablename_in_table>Y</tablename_in_table>
<truncate>N</truncate>

2
mappings_new/info_recruits/citizen_tables/passport/recruitment_rows_five_flow_if_error.hpl
View file

@ -82,7 +82,7 @@ flow_ranges AS (
recr_inf AS (
SELECT DISTINCT COALESCE(cit.recruitment_id, cit.target_recruitment_id) AS idm_id
FROM ervu_dashboard.citizen cit
join ervu_dashboard.citizen_child ch on ch.recruit_id = cit.recruit_id
join ervu_dashboard.passport ps on ps.recruit_id = cit.recruit_id
),
flow_data AS (

2
mappings_new/info_recruits/supportive_jobs/recruitment_rows_five_flow_passport.hpl
View file

@ -1,7 +1,7 @@
<?xml version="1.0" encoding="UTF-8"?>
<pipeline>
<info>
<name>recruitment_rows_five_flow_child</name>
<name>recruitment_rows_five_flow_passport</name>
<name_sync_with_filename>Y</name_sync_with_filename>
<description/>
<extended_description/>