fix spouse, passport

mappings/info_recruits/citizen_tables/citizen_spouse/parallel/citizen_spouse_flow_delta.hpl

@@ -255,6 +255,24 @@ and recruitment_id = '${IDM_ID}';</sql>
       <yloc>80</yloc>
     </GUI>
   </transform>
+  <transform>
+    <name>Identify last row in a stream</name>
+    <type>DetectLastRow</type>
+    <description/>
+    <distribute>Y</distribute>
+    <custom_distribution/>
+    <copies>1</copies>
+    <partitioning>
+      <method>none</method>
+      <schema_name/>
+    </partitioning>
+    <resultfieldname>last_row</resultfieldname>
+    <attributes/>
+    <GUI>
+      <xloc>768</xloc>
+      <yloc>272</yloc>
+    </GUI>
+  </transform>
   <transform>
     <name>Insert / update</name>
     <type>InsertUpdate</type>
@@ -456,7 +474,7 @@ WHERE
     '${IDM_ID}' != ''
     AND COALESCE(ri.current_recruitment_id, ri.target_recruitment_id) = '${IDM_ID}'
     AND '${M_R_CR_DATE}'::timestamp >= r.recruit_create_date
-    AND c.update_date >= '${M_R_UP_DATE}'::timestamp;
+    AND r.update_date >= '${M_R_UP_DATE}'::timestamp;
 </sql>
     <variables_active>Y</variables_active>
     <attributes/>
@@ -490,24 +508,6 @@ WHERE
       <yloc>384</yloc>
     </GUI>
   </transform>
-  <transform>
-    <name>Identify last row in a stream</name>
-    <type>DetectLastRow</type>
-    <description/>
-    <distribute>Y</distribute>
-    <custom_distribution/>
-    <copies>1</copies>
-    <partitioning>
-      <method>none</method>
-      <schema_name/>
-    </partitioning>
-    <resultfieldname>last_row</resultfieldname>
-    <attributes/>
-    <GUI>
-      <xloc>768</xloc>
-      <yloc>272</yloc>
-    </GUI>
-  </transform>
   <transform_error_handling>
     <error>
       <source_transform>Insert / update</source_transform>

mappings/info_recruits/citizen_tables/passport/parallel/passport_flow.hpl

@@ -292,7 +292,9 @@ JOIN LATERAL (
     ]) AS passport_data
     WHERE passport_data IS NOT NULL AND passport_data::text <> 'null'
 ) AS p ON TRUE
-</sql>
+WHERE LENGTH(REGEXP_REPLACE(p.passport_data->>'serDok', '[^0-9]', '', 'g')) = 4 and
+
+LENGTH(REGEXP_REPLACE(p.passport_data->>'nomDok', '[^0-9]', '', 'g')) = 6</sql>
     <variables_active>Y</variables_active>
     <attributes/>
     <GUI>

mappings/info_recruits/citizen_tables/passport/parallel/passport_flow_delta.hpl

@@ -365,6 +365,9 @@ JOIN LATERAL (
     ]) AS passport_data
     WHERE passport_data IS NOT NULL AND passport_data::text <> 'null'
 ) AS p ON TRUE
+WHERE LENGTH(REGEXP_REPLACE(p.passport_data->>'serDok', '[^0-9]', '', 'g')) = 4 and
+
+LENGTH(REGEXP_REPLACE(p.passport_data->>'nomDok', '[^0-9]', '', 'g')) = 6
 </sql>
     <variables_active>Y</variables_active>
     <attributes/>

mappings/info_recruits/citizen_tables/passport/parallel/passport_flow_repeat.hpl

@@ -378,6 +378,9 @@ JOIN LATERAL (
     ]) AS passport_data
     WHERE passport_data IS NOT NULL AND passport_data::text <> 'null'
 ) AS p ON TRUE
+WHERE LENGTH(REGEXP_REPLACE(p.passport_data->>'serDok', '[^0-9]', '', 'g')) = 4 and
+
+LENGTH(REGEXP_REPLACE(p.passport_data->>'nomDok', '[^0-9]', '', 'g')) = 6
 </sql>
     <variables_active>Y</variables_active>
     <attributes/>