add citizen_kolledzh_once.hpl, citizen_school_once.hpl? citizen_vuz_education_once.hpl
fix copy_punishment_and_deferment_once.hwf
This commit is contained in:
parent
cef67c1ace
commit
e44f43c6d8
5 changed files with 1855 additions and 19 deletions
|
|
@ -0,0 +1,251 @@
|
|||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<pipeline>
|
||||
<info>
|
||||
<name>citizen_kolledzh_once</name>
|
||||
<name_sync_with_filename>Y</name_sync_with_filename>
|
||||
<description/>
|
||||
<extended_description/>
|
||||
<pipeline_version/>
|
||||
<pipeline_type>Normal</pipeline_type>
|
||||
<parameters>
|
||||
</parameters>
|
||||
<capture_transform_performance>N</capture_transform_performance>
|
||||
<transform_performance_capturing_delay>1000</transform_performance_capturing_delay>
|
||||
<transform_performance_capturing_size_limit>100</transform_performance_capturing_size_limit>
|
||||
<created_user>-</created_user>
|
||||
<created_date>2025/04/28 19:08:50.902</created_date>
|
||||
<modified_user>-</modified_user>
|
||||
<modified_date>2025/04/28 19:08:50.902</modified_date>
|
||||
</info>
|
||||
<notepads>
|
||||
</notepads>
|
||||
<order>
|
||||
<hop>
|
||||
<from>Table input</from>
|
||||
<to>Table output</to>
|
||||
<enabled>Y</enabled>
|
||||
</hop>
|
||||
</order>
|
||||
<transform>
|
||||
<name>Table input</name>
|
||||
<type>TableInput</type>
|
||||
<description/>
|
||||
<distribute>Y</distribute>
|
||||
<custom_distribution/>
|
||||
<copies>1</copies>
|
||||
<partitioning>
|
||||
<method>none</method>
|
||||
<schema_name/>
|
||||
</partitioning>
|
||||
<connection>ervu_person_registry</connection>
|
||||
<execute_each_row>N</execute_each_row>
|
||||
<limit>0</limit>
|
||||
<sql>select ri.recruit_id,
|
||||
kolledzh_item->'svedOrg'->>'inn' as inn,
|
||||
kolledzh_item->'svedOrg'->>'kpp' as kpp,
|
||||
coalesce(kolledzh_item->'svedOrg'->>'ogrn', kolledzh_item->'svedOrg'->>'ogrnip') as ogrn,
|
||||
kolledzh_item->'svedOrg'->>'naimOrg' as educational_institution_name,
|
||||
kolledzh_item->'svedOrg'->>'adresOrg' as educational_institution_address,
|
||||
kolledzh_item->'svedOrg'->>'kodTipOrg' as educational_institution_type_code,
|
||||
kolledzh_item->>'kodStatus' as education_status_code,
|
||||
kolledzh_item->'svedVosst'->>'dataVosst' as recovery_date,
|
||||
kolledzh_item->'svedVosst'->>'nomPrikazVosst' as recovery_order_date,
|
||||
kolledzh_item->'svedVosst'->>'nomPrikazVosstnomPrikazVosst' recovery_order_number,
|
||||
kolledzh_item->>'kodUrovObr' as education_level_code,
|
||||
kolledzh_item->>'nomerKursa' as grade_number,
|
||||
kolledzh_item->'svedOtpusk'->0->>'dataNach' as leave_start_date,
|
||||
kolledzh_item->'svedOtpusk'->0->>'dataOkonch' as leave_end_date,
|
||||
kolledzh_item->'svedOtpusk'->0->>'kodPrichOtpusk' as leave_reason_code,
|
||||
kolledzh_item->>'dataZachisl' as admission_date,
|
||||
kolledzh_item->>'prPervObuch' = '1' as first_education,
|
||||
kolledzh_item->'svedObrProg'->>'prVUSpecz' = '1' as vus_spec,
|
||||
kolledzh_item->'svedObrProg'->>'dataNachObuch' as education_start_date,
|
||||
kolledzh_item->'svedObrProg'->>'kodFormaObuch' as education_form_code,
|
||||
kolledzh_item->'svedObrProg'->>'planDataOkonch' as planned_education_end_date,
|
||||
kolledzh_item->'svedObrProg'->'svedSpeczMinobr'->>'kodSpecz' as minobr_spec_code,
|
||||
kolledzh_item->'svedObrProg'->'svedSpeczMinprosv'->>'kodSpecz' as minprosv_spec_code,
|
||||
kolledzh_item->'svedObrProg'->'svedOtchisl'->>'dataOtchisl' as expulsion_date,
|
||||
kolledzh_item->'svedObrProg'->'svedOtchisl'->>'nomPrikazOtchisl' as expulsion_order_date,
|
||||
kolledzh_item->'svedObrProg'->'svedOtchisl'->>'dataPrikazOtchisl' as expulsion_order_number,
|
||||
kolledzh_item->'svedVoenObuch'->>'dataNach' as military_education_start_date,
|
||||
kolledzh_item->'svedVoenObuch'->>'dataOkonch' as military_education_end_date,
|
||||
kolledzh_item->>'nomPrikazZachisl' as admission_order_date,
|
||||
kolledzh_item->>'dataPrikazZachisl' as admission_order_number
|
||||
from recruits_info ri,
|
||||
jsonb_array_elements(info->'svedFL'->'svedKolledzh'->'kolledzh') as kolledzh_item
|
||||
join recruits r
|
||||
ON ri.recruit_id = r.id
|
||||
and '${RCRT_C}' IN (r.target_recruitment_id, r.current_recruitment_id)
|
||||
where info->'svedFL'->'svedKolledzh'->'kolledzh' != 'null';</sql>
|
||||
<variables_active>Y</variables_active>
|
||||
<attributes/>
|
||||
<GUI>
|
||||
<xloc>384</xloc>
|
||||
<yloc>192</yloc>
|
||||
</GUI>
|
||||
</transform>
|
||||
<transform>
|
||||
<name>Table output</name>
|
||||
<type>TableOutput</type>
|
||||
<description/>
|
||||
<distribute>Y</distribute>
|
||||
<custom_distribution/>
|
||||
<copies>1</copies>
|
||||
<partitioning>
|
||||
<method>none</method>
|
||||
<schema_name/>
|
||||
</partitioning>
|
||||
<commit>20000</commit>
|
||||
<connection>ervu-dashboard</connection>
|
||||
<fields>
|
||||
<field>
|
||||
<column_name>recruit_id</column_name>
|
||||
<stream_name>recruit_id</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>inn</column_name>
|
||||
<stream_name>inn</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>kpp</column_name>
|
||||
<stream_name>kpp</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>ogrn</column_name>
|
||||
<stream_name>ogrn</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>educational_institution_name</column_name>
|
||||
<stream_name>educational_institution_name</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>educational_institution_address</column_name>
|
||||
<stream_name>educational_institution_address</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>educational_institution_type_code</column_name>
|
||||
<stream_name>educational_institution_type_code</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>education_status_code</column_name>
|
||||
<stream_name>education_status_code</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>recovery_date</column_name>
|
||||
<stream_name>recovery_date</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>recovery_order_date</column_name>
|
||||
<stream_name>recovery_order_date</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>recovery_order_number</column_name>
|
||||
<stream_name>recovery_order_number</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>education_level_code</column_name>
|
||||
<stream_name>education_level_code</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>grade_number</column_name>
|
||||
<stream_name>grade_number</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>leave_start_date</column_name>
|
||||
<stream_name>leave_start_date</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>leave_end_date</column_name>
|
||||
<stream_name>leave_end_date</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>leave_reason_code</column_name>
|
||||
<stream_name>leave_reason_code</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>admission_date</column_name>
|
||||
<stream_name>admission_date</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>first_education</column_name>
|
||||
<stream_name>first_education</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>vus_spec</column_name>
|
||||
<stream_name>vus_spec</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>education_start_date</column_name>
|
||||
<stream_name>education_start_date</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>education_form_code</column_name>
|
||||
<stream_name>education_form_code</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>planned_education_end_date</column_name>
|
||||
<stream_name>planned_education_end_date</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>minobr_spec_code</column_name>
|
||||
<stream_name>minobr_spec_code</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>minprosv_spec_code</column_name>
|
||||
<stream_name>minprosv_spec_code</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>expulsion_date</column_name>
|
||||
<stream_name>expulsion_date</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>expulsion_order_date</column_name>
|
||||
<stream_name>expulsion_order_date</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>expulsion_order_number</column_name>
|
||||
<stream_name>expulsion_order_number</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>military_education_start_date</column_name>
|
||||
<stream_name>military_education_start_date</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>military_education_end_date</column_name>
|
||||
<stream_name>military_education_end_date</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>admission_order_date</column_name>
|
||||
<stream_name>admission_order_date</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>admission_order_number</column_name>
|
||||
<stream_name>admission_order_number</stream_name>
|
||||
</field>
|
||||
</fields>
|
||||
<ignore_errors>N</ignore_errors>
|
||||
<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>ervu_dashboard</schema>
|
||||
<specify_fields>Y</specify_fields>
|
||||
<table>citizen_education</table>
|
||||
<tablename_field/>
|
||||
<tablename_in_field>N</tablename_in_field>
|
||||
<tablename_in_table>Y</tablename_in_table>
|
||||
<truncate>N</truncate>
|
||||
<use_batch>Y</use_batch>
|
||||
<attributes/>
|
||||
<GUI>
|
||||
<xloc>560</xloc>
|
||||
<yloc>192</yloc>
|
||||
</GUI>
|
||||
</transform>
|
||||
<transform_error_handling>
|
||||
</transform_error_handling>
|
||||
<attributes/>
|
||||
</pipeline>
|
||||
|
|
@ -0,0 +1,161 @@
|
|||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<pipeline>
|
||||
<info>
|
||||
<name>citizen_school_once</name>
|
||||
<name_sync_with_filename>Y</name_sync_with_filename>
|
||||
<description/>
|
||||
<extended_description/>
|
||||
<pipeline_version/>
|
||||
<pipeline_type>Normal</pipeline_type>
|
||||
<parameters>
|
||||
</parameters>
|
||||
<capture_transform_performance>N</capture_transform_performance>
|
||||
<transform_performance_capturing_delay>1000</transform_performance_capturing_delay>
|
||||
<transform_performance_capturing_size_limit>100</transform_performance_capturing_size_limit>
|
||||
<created_user>-</created_user>
|
||||
<created_date>2025/04/28 19:08:48.700</created_date>
|
||||
<modified_user>-</modified_user>
|
||||
<modified_date>2025/04/28 19:08:48.700</modified_date>
|
||||
</info>
|
||||
<notepads>
|
||||
</notepads>
|
||||
<order>
|
||||
<hop>
|
||||
<from>Table input</from>
|
||||
<to>Table output</to>
|
||||
<enabled>Y</enabled>
|
||||
</hop>
|
||||
</order>
|
||||
<transform>
|
||||
<name>Table input</name>
|
||||
<type>TableInput</type>
|
||||
<description/>
|
||||
<distribute>Y</distribute>
|
||||
<custom_distribution/>
|
||||
<copies>1</copies>
|
||||
<partitioning>
|
||||
<method>none</method>
|
||||
<schema_name/>
|
||||
</partitioning>
|
||||
<connection>ervu_person_registry</connection>
|
||||
<execute_each_row>N</execute_each_row>
|
||||
<limit>0</limit>
|
||||
<sql>select ri.recruit_id,
|
||||
shkola_item->'svedOrg'->>'inn' as inn,
|
||||
shkola_item->'svedOrg'->>'kpp' as kpp,
|
||||
coalesce(shkola_item->'svedOrg'->>'ogrn', shkola_item->'svedOrg'->>'ogrnip') as ogrn,
|
||||
shkola_item->'svedOrg'->>'naimOrg' as educational_institution_name,
|
||||
shkola_item->'svedOrg'->>'adresOrg' as educational_institution_address,
|
||||
shkola_item->>'kodStatus' as education_status_code,
|
||||
'9' as education_level_code, -- костыль
|
||||
shkola_item->>'klass' as grade_number,
|
||||
shkola_item->>'dataPostup' as admission_date,
|
||||
shkola_item->>'dataOkonch' as planned_education_end_date,
|
||||
shkola_item->>'nomPrikazZachisl' as admission_order_date,
|
||||
shkola_item->>'dataPrikazZachisl' as admission_order_number
|
||||
from recruits_info ri,
|
||||
jsonb_array_elements(info->'svedFL'->'svedSHkola'->'shkola') as shkola_item
|
||||
join recruits r
|
||||
ON ri.recruit_id = r.id
|
||||
and '${RCRT_C}' IN (r.target_recruitment_id, r.current_recruitment_id)
|
||||
where info->'svedFL'->'svedSHkola'->'shkola' != 'null';</sql>
|
||||
<variables_active>Y</variables_active>
|
||||
<attributes/>
|
||||
<GUI>
|
||||
<xloc>352</xloc>
|
||||
<yloc>208</yloc>
|
||||
</GUI>
|
||||
</transform>
|
||||
<transform>
|
||||
<name>Table output</name>
|
||||
<type>TableOutput</type>
|
||||
<description/>
|
||||
<distribute>Y</distribute>
|
||||
<custom_distribution/>
|
||||
<copies>1</copies>
|
||||
<partitioning>
|
||||
<method>none</method>
|
||||
<schema_name/>
|
||||
</partitioning>
|
||||
<commit>20000</commit>
|
||||
<connection>ervu-dashboard</connection>
|
||||
<fields>
|
||||
<field>
|
||||
<column_name>recruit_id</column_name>
|
||||
<stream_name>recruit_id</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>inn</column_name>
|
||||
<stream_name>inn</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>kpp</column_name>
|
||||
<stream_name>kpp</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>ogrn</column_name>
|
||||
<stream_name>ogrn</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>educational_institution_name</column_name>
|
||||
<stream_name>educational_institution_name</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>educational_institution_address</column_name>
|
||||
<stream_name>educational_institution_address</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>education_status_code</column_name>
|
||||
<stream_name>education_status_code</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>education_level_code</column_name>
|
||||
<stream_name>education_level_code</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>grade_number</column_name>
|
||||
<stream_name>grade_number</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>admission_date</column_name>
|
||||
<stream_name>admission_date</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>planned_education_end_date</column_name>
|
||||
<stream_name>planned_education_end_date</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>admission_order_date</column_name>
|
||||
<stream_name>admission_order_date</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>admission_order_number</column_name>
|
||||
<stream_name>admission_order_number</stream_name>
|
||||
</field>
|
||||
</fields>
|
||||
<ignore_errors>N</ignore_errors>
|
||||
<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>ervu_dashboard</schema>
|
||||
<specify_fields>Y</specify_fields>
|
||||
<table>citizen_education</table>
|
||||
<tablename_field/>
|
||||
<tablename_in_field>N</tablename_in_field>
|
||||
<tablename_in_table>Y</tablename_in_table>
|
||||
<truncate>N</truncate>
|
||||
<use_batch>Y</use_batch>
|
||||
<attributes/>
|
||||
<GUI>
|
||||
<xloc>528</xloc>
|
||||
<yloc>208</yloc>
|
||||
</GUI>
|
||||
</transform>
|
||||
<transform_error_handling>
|
||||
</transform_error_handling>
|
||||
<attributes/>
|
||||
</pipeline>
|
||||
|
|
@ -0,0 +1,252 @@
|
|||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<pipeline>
|
||||
<info>
|
||||
<name>citizen_vuz_education_once</name>
|
||||
<name_sync_with_filename>Y</name_sync_with_filename>
|
||||
<description/>
|
||||
<extended_description/>
|
||||
<pipeline_version/>
|
||||
<pipeline_type>Normal</pipeline_type>
|
||||
<parameters>
|
||||
</parameters>
|
||||
<capture_transform_performance>N</capture_transform_performance>
|
||||
<transform_performance_capturing_delay>1000</transform_performance_capturing_delay>
|
||||
<transform_performance_capturing_size_limit>100</transform_performance_capturing_size_limit>
|
||||
<created_user>-</created_user>
|
||||
<created_date>2025/04/27 19:55:49.026</created_date>
|
||||
<modified_user>-</modified_user>
|
||||
<modified_date>2025/04/27 19:55:49.026</modified_date>
|
||||
</info>
|
||||
<notepads>
|
||||
</notepads>
|
||||
<order>
|
||||
<hop>
|
||||
<from>vuz_input</from>
|
||||
<to>Table output</to>
|
||||
<enabled>Y</enabled>
|
||||
</hop>
|
||||
</order>
|
||||
<transform>
|
||||
<name>Table output</name>
|
||||
<type>TableOutput</type>
|
||||
<description/>
|
||||
<distribute>Y</distribute>
|
||||
<custom_distribution/>
|
||||
<copies>1</copies>
|
||||
<partitioning>
|
||||
<method>none</method>
|
||||
<schema_name/>
|
||||
</partitioning>
|
||||
<commit>20000</commit>
|
||||
<connection>ervu-dashboard</connection>
|
||||
<fields>
|
||||
<field>
|
||||
<column_name>recruit_id</column_name>
|
||||
<stream_name>recruit_id</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>inn</column_name>
|
||||
<stream_name>inn</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>kpp</column_name>
|
||||
<stream_name>kpp</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>ogrn</column_name>
|
||||
<stream_name>ogrn</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>educational_institution_name</column_name>
|
||||
<stream_name>educational_institution_name</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>educational_institution_address</column_name>
|
||||
<stream_name>educational_institution_address</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>educational_institution_type_code</column_name>
|
||||
<stream_name>educational_institution_type_code</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>education_status_code</column_name>
|
||||
<stream_name>education_status_code</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>recovery_date</column_name>
|
||||
<stream_name>recovery_date</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>recovery_order_date</column_name>
|
||||
<stream_name>recovery_order_date</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>recovery_order_number</column_name>
|
||||
<stream_name>recovery_order_number</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>education_level_code</column_name>
|
||||
<stream_name>education_level_code</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>grade_number</column_name>
|
||||
<stream_name>grade_number</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>leave_start_date</column_name>
|
||||
<stream_name>leave_start_date</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>leave_end_date</column_name>
|
||||
<stream_name>leave_end_date</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>leave_reason_code</column_name>
|
||||
<stream_name>leave_reason_code</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>admission_date</column_name>
|
||||
<stream_name>admission_date</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>first_education</column_name>
|
||||
<stream_name>first_education</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>vus_spec</column_name>
|
||||
<stream_name>vus_spec</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>education_start_date</column_name>
|
||||
<stream_name>education_start_date</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>education_form_code</column_name>
|
||||
<stream_name>education_form_code</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>planned_education_end_date</column_name>
|
||||
<stream_name>planned_education_end_date</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>minobr_spec_code</column_name>
|
||||
<stream_name>minobr_spec_code</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>minprosv_spec_code</column_name>
|
||||
<stream_name>minprosv_spec_code</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>expulsion_date</column_name>
|
||||
<stream_name>expulsion_date</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>expulsion_order_date</column_name>
|
||||
<stream_name>expulsion_order_date</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>expulsion_order_number</column_name>
|
||||
<stream_name>expulsion_order_number</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>military_education_start_date</column_name>
|
||||
<stream_name>military_education_start_date</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>military_education_end_date</column_name>
|
||||
<stream_name>military_education_end_date</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>admission_order_date</column_name>
|
||||
<stream_name>admission_order_date</stream_name>
|
||||
</field>
|
||||
<field>
|
||||
<column_name>admission_order_number</column_name>
|
||||
<stream_name>admission_order_number</stream_name>
|
||||
</field>
|
||||
</fields>
|
||||
<ignore_errors>N</ignore_errors>
|
||||
<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>ervu_dashboard</schema>
|
||||
<specify_fields>Y</specify_fields>
|
||||
<table>citizen_education</table>
|
||||
<tablename_field/>
|
||||
<tablename_in_field>N</tablename_in_field>
|
||||
<tablename_in_table>Y</tablename_in_table>
|
||||
<truncate>N</truncate>
|
||||
<use_batch>Y</use_batch>
|
||||
<attributes/>
|
||||
<GUI>
|
||||
<xloc>480</xloc>
|
||||
<yloc>304</yloc>
|
||||
</GUI>
|
||||
</transform>
|
||||
<transform>
|
||||
<name>vuz_input</name>
|
||||
<type>TableInput</type>
|
||||
<description/>
|
||||
<distribute>Y</distribute>
|
||||
<custom_distribution/>
|
||||
<copies>1</copies>
|
||||
<partitioning>
|
||||
<method>none</method>
|
||||
<schema_name/>
|
||||
</partitioning>
|
||||
<connection>ervu_person_registry</connection>
|
||||
<execute_each_row>N</execute_each_row>
|
||||
<limit>0</limit>
|
||||
<sql>select ri.recruit_id,
|
||||
vuz_item->'svedOrg'->>'inn' as inn,
|
||||
vuz_item->'svedOrg'->>'kpp' as kpp,
|
||||
coalesce(vuz_item->'svedOrg'->>'ogrn', vuz_item->'svedOrg'->>'ogrnip') as ogrn,
|
||||
vuz_item->'svedOrg'->>'naimOrg' as educational_institution_name,
|
||||
vuz_item->'svedOrg'->>'adresOrg' as educational_institution_address,
|
||||
vuz_item->'svedOrg'->>'kodTipOrg' as educational_institution_type_code,
|
||||
vuz_item->>'kodStatus' as education_status_code,
|
||||
vuz_item->'svedVosst'->>'dataVosst' as recovery_date,
|
||||
vuz_item->'svedVosst'->>'nomPrikazVosst' as recovery_order_date,
|
||||
vuz_item->'svedVosst'->>'nomPrikazVosstnomPrikazVosst' recovery_order_number,
|
||||
vuz_item->>'kodUrovObr' as education_level_code,
|
||||
vuz_item->>'nomerKursa' as grade_number,
|
||||
vuz_item->'svedOtpusk'->0->>'dataNach' as leave_start_date,
|
||||
vuz_item->'svedOtpusk'->0->>'dataOkonch' as leave_end_date,
|
||||
vuz_item->'svedOtpusk'->0->>'kodPrichOtpusk' as leave_reason_code,
|
||||
vuz_item->>'dataZachisl' as admission_date,
|
||||
vuz_item->>'prPervObuch' = '1' as first_education,
|
||||
vuz_item->'svedObrProg'->>'prVUSpecz' = '1' as vus_spec,
|
||||
vuz_item->'svedObrProg'->>'dataNachObuch' as education_start_date,
|
||||
vuz_item->'svedObrProg'->>'kodFormaObuch' as education_form_code,
|
||||
vuz_item->'svedObrProg'->>'planDataOkonch' as planned_education_end_date,
|
||||
vuz_item->'svedObrProg'->'svedSpeczMinobr'->>'kodSpecz' as minobr_spec_code,
|
||||
vuz_item->'svedObrProg'->'svedSpeczMinprosv'->>'kodSpecz' as minprosv_spec_code,
|
||||
vuz_item->'svedObrProg'->'svedOtchisl'->>'dataOtchisl' as expulsion_date,
|
||||
vuz_item->'svedObrProg'->'svedOtchisl'->>'nomPrikazOtchisl' as expulsion_order_date,
|
||||
vuz_item->'svedObrProg'->'svedOtchisl'->>'dataPrikazOtchisl' as expulsion_order_number,
|
||||
vuz_item->'svedVoenObuch'->>'dataNach' as military_education_start_date,
|
||||
vuz_item->'svedVoenObuch'->>'dataOkonch' as military_education_end_date,
|
||||
vuz_item->>'nomPrikazZachisl' as admission_order_date,
|
||||
vuz_item->>'dataPrikazZachisl' as admission_order_number
|
||||
from recruits_info ri,
|
||||
jsonb_array_elements(info->'svedFL'->'svedVUZ'->'vuz') as vuz_item
|
||||
join recruits r
|
||||
ON ri.recruit_id = r.id
|
||||
and '${RCRT_C}' IN (r.target_recruitment_id, r.current_recruitment_id)
|
||||
where info->'svedFL'->'svedVUZ'->'vuz' != 'null';
|
||||
</sql>
|
||||
<variables_active>Y</variables_active>
|
||||
<attributes/>
|
||||
<GUI>
|
||||
<xloc>304</xloc>
|
||||
<yloc>304</yloc>
|
||||
</GUI>
|
||||
</transform>
|
||||
<transform_error_handling>
|
||||
</transform_error_handling>
|
||||
<attributes/>
|
||||
</pipeline>
|
||||
|
|
@ -57,14 +57,11 @@
|
|||
<create_parent_folder>N</create_parent_folder>
|
||||
<exec_per_row>Y</exec_per_row>
|
||||
<filename>${PROJECT_HOME}/jobs_once_a_day/punishment_once.hpl</filename>
|
||||
<logext/>
|
||||
<logfile/>
|
||||
<loglevel>Basic</loglevel>
|
||||
<parameters>
|
||||
<parameter>
|
||||
<name>RCRT_C</name>
|
||||
<stream_name>RECRUITMENT_CITIZEN</stream_name>
|
||||
<value/>
|
||||
</parameter>
|
||||
<pass_all_parameters>Y</pass_all_parameters>
|
||||
</parameters>
|
||||
|
|
@ -380,8 +377,6 @@ delete from ervu_dashboard.citizen_deferment;
|
|||
<create_parent_folder>N</create_parent_folder>
|
||||
<exec_per_row>N</exec_per_row>
|
||||
<filename>${PROJECT_HOME}\jobs_once_a_day\children_flags.hpl</filename>
|
||||
<logext/>
|
||||
<logfile/>
|
||||
<loglevel>Basic</loglevel>
|
||||
<parameters>
|
||||
<pass_all_parameters>Y</pass_all_parameters>
|
||||
|
|
@ -590,14 +585,11 @@ delete from ervu_dashboard.citizen_deferment;
|
|||
<create_parent_folder>N</create_parent_folder>
|
||||
<exec_per_row>Y</exec_per_row>
|
||||
<filename>${PROJECT_HOME}\jobs_once_a_day\id_ern_once.hpl</filename>
|
||||
<logext/>
|
||||
<logfile/>
|
||||
<loglevel>Basic</loglevel>
|
||||
<parameters>
|
||||
<parameter>
|
||||
<name>RCRT_C</name>
|
||||
<stream_name>RECRUITMENT_CITIZEN</stream_name>
|
||||
<value/>
|
||||
</parameter>
|
||||
<pass_all_parameters>Y</pass_all_parameters>
|
||||
</parameters>
|
||||
|
|
@ -623,8 +615,6 @@ delete from ervu_dashboard.citizen_deferment;
|
|||
<create_parent_folder>N</create_parent_folder>
|
||||
<exec_per_row>N</exec_per_row>
|
||||
<filename>${PROJECT_HOME}\jobs_once_a_day\recruitment_code_once.hpl</filename>
|
||||
<logext/>
|
||||
<logfile/>
|
||||
<loglevel>Basic</loglevel>
|
||||
<parameters>
|
||||
<pass_all_parameters>Y</pass_all_parameters>
|
||||
|
|
@ -671,8 +661,6 @@ delete from ervu_dashboard.citizen_deferment;
|
|||
<create_parent_folder>N</create_parent_folder>
|
||||
<exec_per_row>N</exec_per_row>
|
||||
<filename>${PROJECT_HOME}/jobs_once_a_day/recruit_ervu_status_once.hpl</filename>
|
||||
<logext/>
|
||||
<logfile/>
|
||||
<loglevel>Basic</loglevel>
|
||||
<parameters>
|
||||
<pass_all_parameters>Y</pass_all_parameters>
|
||||
|
|
@ -697,6 +685,133 @@ delete from ervu_dashboard.citizen_deferment;
|
|||
<yloc>912</yloc>
|
||||
<attributes_hac/>
|
||||
</action>
|
||||
<action>
|
||||
<name>education_constants_once.hpl</name>
|
||||
<description/>
|
||||
<type>PIPELINE</type>
|
||||
<attributes/>
|
||||
<add_date>N</add_date>
|
||||
<add_time>N</add_time>
|
||||
<clear_files>N</clear_files>
|
||||
<clear_rows>N</clear_rows>
|
||||
<create_parent_folder>N</create_parent_folder>
|
||||
<exec_per_row>N</exec_per_row>
|
||||
<filename>${PROJECT_HOME}/jobs_once_a_day/education_constants_once.hpl</filename>
|
||||
<logext/>
|
||||
<logfile/>
|
||||
<loglevel>Basic</loglevel>
|
||||
<parameters>
|
||||
<pass_all_parameters>Y</pass_all_parameters>
|
||||
</parameters>
|
||||
<params_from_previous>N</params_from_previous>
|
||||
<run_configuration>local</run_configuration>
|
||||
<set_append_logfile>N</set_append_logfile>
|
||||
<set_logfile>N</set_logfile>
|
||||
<wait_until_finished>Y</wait_until_finished>
|
||||
<parallel>N</parallel>
|
||||
<xloc>656</xloc>
|
||||
<yloc>608</yloc>
|
||||
<attributes_hac/>
|
||||
</action>
|
||||
<action>
|
||||
<name>citizen_vuz_education_once.hpl</name>
|
||||
<description/>
|
||||
<type>PIPELINE</type>
|
||||
<attributes/>
|
||||
<add_date>N</add_date>
|
||||
<add_time>N</add_time>
|
||||
<clear_files>N</clear_files>
|
||||
<clear_rows>N</clear_rows>
|
||||
<create_parent_folder>N</create_parent_folder>
|
||||
<exec_per_row>Y</exec_per_row>
|
||||
<filename>${PROJECT_HOME}/jobs_once_a_day/citizen_vuz_education_once.hpl</filename>
|
||||
<logext/>
|
||||
<logfile/>
|
||||
<loglevel>Basic</loglevel>
|
||||
<parameters>
|
||||
<parameter>
|
||||
<name>RCRT_C</name>
|
||||
<stream_name>RECRUITMENT_CITIZEN</stream_name>
|
||||
<value/>
|
||||
</parameter>
|
||||
<pass_all_parameters>Y</pass_all_parameters>
|
||||
</parameters>
|
||||
<params_from_previous>N</params_from_previous>
|
||||
<run_configuration>local</run_configuration>
|
||||
<set_append_logfile>N</set_append_logfile>
|
||||
<set_logfile>N</set_logfile>
|
||||
<wait_until_finished>Y</wait_until_finished>
|
||||
<parallel>N</parallel>
|
||||
<xloc>880</xloc>
|
||||
<yloc>608</yloc>
|
||||
<attributes_hac/>
|
||||
</action>
|
||||
<action>
|
||||
<name>citizen_kolledzh_once.hpl</name>
|
||||
<description/>
|
||||
<type>PIPELINE</type>
|
||||
<attributes/>
|
||||
<add_date>N</add_date>
|
||||
<add_time>N</add_time>
|
||||
<clear_files>N</clear_files>
|
||||
<clear_rows>N</clear_rows>
|
||||
<create_parent_folder>N</create_parent_folder>
|
||||
<exec_per_row>Y</exec_per_row>
|
||||
<filename>${PROJECT_HOME}/jobs_once_a_day/citizen_kolledzh_once.hpl</filename>
|
||||
<logext/>
|
||||
<logfile/>
|
||||
<loglevel>Basic</loglevel>
|
||||
<parameters>
|
||||
<parameter>
|
||||
<name>RCRT_C</name>
|
||||
<stream_name>RECRUITMENT_CITIZEN</stream_name>
|
||||
<value/>
|
||||
</parameter>
|
||||
<pass_all_parameters>Y</pass_all_parameters>
|
||||
</parameters>
|
||||
<params_from_previous>N</params_from_previous>
|
||||
<run_configuration>local</run_configuration>
|
||||
<set_append_logfile>N</set_append_logfile>
|
||||
<set_logfile>N</set_logfile>
|
||||
<wait_until_finished>Y</wait_until_finished>
|
||||
<parallel>N</parallel>
|
||||
<xloc>1104</xloc>
|
||||
<yloc>608</yloc>
|
||||
<attributes_hac/>
|
||||
</action>
|
||||
<action>
|
||||
<name>citizen_school_once.hpl</name>
|
||||
<description/>
|
||||
<type>PIPELINE</type>
|
||||
<attributes/>
|
||||
<add_date>N</add_date>
|
||||
<add_time>N</add_time>
|
||||
<clear_files>N</clear_files>
|
||||
<clear_rows>N</clear_rows>
|
||||
<create_parent_folder>N</create_parent_folder>
|
||||
<exec_per_row>Y</exec_per_row>
|
||||
<filename>${PROJECT_HOME}/jobs_once_a_day/citizen_school_once.hpl</filename>
|
||||
<logext/>
|
||||
<logfile/>
|
||||
<loglevel>Basic</loglevel>
|
||||
<parameters>
|
||||
<parameter>
|
||||
<name>RCRT_C</name>
|
||||
<stream_name>RECRUITMENT_CITIZEN</stream_name>
|
||||
<value/>
|
||||
</parameter>
|
||||
<pass_all_parameters>Y</pass_all_parameters>
|
||||
</parameters>
|
||||
<params_from_previous>N</params_from_previous>
|
||||
<run_configuration>local</run_configuration>
|
||||
<set_append_logfile>N</set_append_logfile>
|
||||
<set_logfile>N</set_logfile>
|
||||
<wait_until_finished>Y</wait_until_finished>
|
||||
<parallel>N</parallel>
|
||||
<xloc>1312</xloc>
|
||||
<yloc>608</yloc>
|
||||
<attributes_hac/>
|
||||
</action>
|
||||
</actions>
|
||||
<hops>
|
||||
<hop>
|
||||
|
|
@ -737,7 +852,7 @@ delete from ervu_dashboard.citizen_deferment;
|
|||
<hop>
|
||||
<from>Start</from>
|
||||
<to>SQL.citizen_criminal_liability_fz53</to>
|
||||
<enabled>Y</enabled>
|
||||
<enabled>N</enabled>
|
||||
<evaluation>Y</evaluation>
|
||||
<unconditional>Y</unconditional>
|
||||
</hop>
|
||||
|
|
@ -751,7 +866,7 @@ delete from ervu_dashboard.citizen_deferment;
|
|||
<hop>
|
||||
<from>Start</from>
|
||||
<to>SQL.citizen_appealing_violations_fz53</to>
|
||||
<enabled>Y</enabled>
|
||||
<enabled>N</enabled>
|
||||
<evaluation>Y</evaluation>
|
||||
<unconditional>Y</unconditional>
|
||||
</hop>
|
||||
|
|
@ -765,7 +880,7 @@ delete from ervu_dashboard.citizen_deferment;
|
|||
<hop>
|
||||
<from>recruitment_rows.hpl</from>
|
||||
<to>SQL.punishment</to>
|
||||
<enabled>Y</enabled>
|
||||
<enabled>N</enabled>
|
||||
<evaluation>Y</evaluation>
|
||||
<unconditional>N</unconditional>
|
||||
</hop>
|
||||
|
|
@ -786,7 +901,7 @@ delete from ervu_dashboard.citizen_deferment;
|
|||
<hop>
|
||||
<from>recruitment_rows.hpl</from>
|
||||
<to>SQL.citizen_deferments</to>
|
||||
<enabled>Y</enabled>
|
||||
<enabled>N</enabled>
|
||||
<evaluation>Y</evaluation>
|
||||
<unconditional>N</unconditional>
|
||||
</hop>
|
||||
|
|
@ -814,7 +929,7 @@ delete from ervu_dashboard.citizen_deferment;
|
|||
<hop>
|
||||
<from>Start</from>
|
||||
<to>SQL.citizen_liability_fz53</to>
|
||||
<enabled>Y</enabled>
|
||||
<enabled>N</enabled>
|
||||
<evaluation>Y</evaluation>
|
||||
<unconditional>Y</unconditional>
|
||||
</hop>
|
||||
|
|
@ -884,7 +999,7 @@ delete from ervu_dashboard.citizen_deferment;
|
|||
<hop>
|
||||
<from>Start</from>
|
||||
<to>recruitment_code_once.hpl</to>
|
||||
<enabled>Y</enabled>
|
||||
<enabled>N</enabled>
|
||||
<evaluation>Y</evaluation>
|
||||
<unconditional>Y</unconditional>
|
||||
</hop>
|
||||
|
|
@ -912,7 +1027,7 @@ delete from ervu_dashboard.citizen_deferment;
|
|||
<hop>
|
||||
<from>Start</from>
|
||||
<to>recruit_ervu_status_once.hpl</to>
|
||||
<enabled>Y</enabled>
|
||||
<enabled>N</enabled>
|
||||
<evaluation>Y</evaluation>
|
||||
<unconditional>Y</unconditional>
|
||||
</hop>
|
||||
|
|
@ -923,6 +1038,34 @@ delete from ervu_dashboard.citizen_deferment;
|
|||
<evaluation>Y</evaluation>
|
||||
<unconditional>N</unconditional>
|
||||
</hop>
|
||||
<hop>
|
||||
<from>recruitment_rows.hpl</from>
|
||||
<to>education_constants_once.hpl</to>
|
||||
<enabled>Y</enabled>
|
||||
<evaluation>Y</evaluation>
|
||||
<unconditional>N</unconditional>
|
||||
</hop>
|
||||
<hop>
|
||||
<from>education_constants_once.hpl</from>
|
||||
<to>citizen_vuz_education_once.hpl</to>
|
||||
<enabled>Y</enabled>
|
||||
<evaluation>N</evaluation>
|
||||
<unconditional>Y</unconditional>
|
||||
</hop>
|
||||
<hop>
|
||||
<from>citizen_vuz_education_once.hpl</from>
|
||||
<to>citizen_kolledzh_once.hpl</to>
|
||||
<enabled>Y</enabled>
|
||||
<evaluation>N</evaluation>
|
||||
<unconditional>Y</unconditional>
|
||||
</hop>
|
||||
<hop>
|
||||
<from>citizen_kolledzh_once.hpl</from>
|
||||
<to>citizen_school_once.hpl</to>
|
||||
<enabled>Y</enabled>
|
||||
<evaluation>N</evaluation>
|
||||
<unconditional>Y</unconditional>
|
||||
</hop>
|
||||
</hops>
|
||||
<notepads>
|
||||
</notepads>
|
||||
|
|
|
|||
File diff suppressed because it is too large
Load diff
Loading…
Add table
Add a link
Reference in a new issue