feat: Add Segment.is_on_uebertragungsdatei_level to AHB(esser) View (the aggregated instead of only the bare data model) (#134)

Author: hf-kklein

src/fundamend/sqlmodels/ahbtabellen_view.py

@@ -52,6 +52,7 @@ class AhbTabellenLine(SQLModel, table=True):
     segment_code: str | None = Field()
     data_element: str | None = Field()
     qualifier: str | None = Field()
+    is_on_uebertragungsdatei_level: bool | None = Field()  #: !=null as soon as at least one segment is part of the path
     line_ahb_status: str | None = Field()
     line_name: str | None = Field()
     line_type: str | None = Field()  # 'code' or 'dataelement' or 'segment' or 'segmentgroup' or 'dataelementgroup'

src/fundamend/sqlmodels/ahbview.py

@@ -212,6 +212,7 @@ class AhbHierarchyMaterialized(SQLModel, table=True):
     segment_number: Optional[str] = Field(default=None, index=True)
     segment_ahb_status: Optional[str] = Field(default=None)
     segment_position: Optional[int] = Field(default=None, index=True)
+    is_on_uebertragungsdatei_level: Optional[bool] = Field(default=None, index=False)  #: null for SG only (no segment)
 
     # Data Element Group
     dataelementgroup_id: Optional[str] = Field(default=None, index=True)

src/fundamend/sqlmodels/create_ahbtabellen_view.sql

@@ -16,6 +16,7 @@ WITH consolidated_ahm AS (SELECT id,
                                  beschreibung,
                                  segmentgroup_id,
                                  segment_id,
+                                 is_on_uebertragungsdatei_level,
                                  dataelement_id,
                                  code_value,
                                  sort_path,
@@ -39,12 +40,13 @@ SELECT c.id                                  as id,
        c.segmentgroup_id                     as segmentgroup_key, -- eg 'SG6'
        c.segment_id                          as segment_code,     -- e.g 'NAD'
        c.dataelement_id                      as data_element,     -- e.g 'D_3035'
+       c.is_on_uebertragungsdatei_level      as is_on_uebertragungsdatei_level, -- true for UNA/UNB+UNZ, not for UNH
        --CASE
        --    WHEN dataelement_id IS NOT NULL THEN SUBSTR(dataelement_id, 3)
        --    END                                                                                              AS dataelement_without_leading_d_, -- e.g '3035'
        c.code_value                          as qualifier,
-       c.line_ahb_status                     as line_ahb_status,  -- e.g. 'Muss [28] ∧ [64]'
-       c.line_name                           as line_name,        -- e.g. 'Datums- oder Uhrzeit- oder Zeitspannen-Format, Code' or 'Produkt-Daten für Lieferant relevant'
+       c.line_ahb_status                     as line_ahb_status,                -- e.g. 'Muss [28] ∧ [64]'
+       c.line_name                           as line_name,                      -- e.g. 'Datums- oder Uhrzeit- oder Zeitspannen-Format, Code' or 'Produkt-Daten für Lieferant relevant'
        c.line_type                           as line_type,
        c.sort_path                           as sort_path,
        NULLIF(ahe.node_texts, '')            as bedingung,

src/fundamend/sqlmodels/materialize_ahb_view.sql

@@ -25,7 +25,8 @@ WITH RECURSIVE
                              af.beschreibung,
                              af.kommunikation_von,
                              ah.edifact_format_version,
-                             af.anwendungshandbuch_primary_key
+                             af.anwendungshandbuch_primary_key,
+                             null            as is_on_uebertragungsdatei_level
                       FROM segmentgroup sg
                                JOIN anwendungsfall af ON sg.anwendungsfall_primary_key = af.primary_key
                                JOIN anwendungshandbuch ah ON af.anwendungshandbuch_primary_key = ah.primary_key
@@ -34,8 +35,8 @@ WITH RECURSIVE
 
                       SELECT s.primary_key,
                              s.position,
-                             'segment' AS type,
-                             s.id      AS root_id_text,
+                             'segment'                        AS type,
+                             s.id                             AS root_id_text,
                              s.name,
                              s.ahb_status,
                              s.anwendungsfall_primary_key,
@@ -48,7 +49,8 @@ WITH RECURSIVE
                              af.beschreibung,
                              af.kommunikation_von,
                              ah.edifact_format_version,
-                             af.anwendungshandbuch_primary_key
+                             af.anwendungshandbuch_primary_key,
+                             s.is_on_uebertragungsdatei_level as is_on_uebertragungsdatei_level
                       FROM segment s
                                JOIN anwendungsfall af ON s.anwendungsfall_primary_key = af.primary_key
                                JOIN anwendungshandbuch ah ON af.anwendungshandbuch_primary_key = ah.primary_key
@@ -83,7 +85,7 @@ WITH RECURSIVE
                               o.kommunikation_von,
                               o.edifact_format_version,
                               o.anwendungshandbuch_primary_key,
-
+                              o.is_on_uebertragungsdatei_level,
                               CASE WHEN o.type = 'segment_group' THEN o.root_id_text ELSE NULL END AS segmentgroup_id,
                               CASE WHEN o.type = 'segment_group' THEN o.name ELSE NULL END         AS segmentgroup_name,
                               CASE WHEN o.type = 'segment_group' THEN o.ahb_status ELSE NULL END   AS segmentgroup_ahb_status,
@@ -142,6 +144,7 @@ WITH RECURSIVE
                          h.kommunikation_von,
                          h.edifact_format_version,
                          h.anwendungshandbuch_primary_key,
+                         h.is_on_uebertragungsdatei_level,
 
                          'SG' || child.id,
                          child.name,
@@ -199,7 +202,7 @@ WITH RECURSIVE
                          h.kommunikation_von,
                          h.edifact_format_version,
                          h.anwendungshandbuch_primary_key,
-
+                         s.is_on_uebertragungsdatei_level,
                          h.segmentgroup_id,
                          h.segmentgroup_name,
                          h.segmentgroup_ahb_status,
@@ -255,7 +258,7 @@ WITH RECURSIVE
                          h.kommunikation_von,
                          h.edifact_format_version,
                          h.anwendungshandbuch_primary_key,
-
+                         h.is_on_uebertragungsdatei_level,
                          h.segmentgroup_id,
                          h.segmentgroup_name,
                          h.segmentgroup_ahb_status,
@@ -311,7 +314,7 @@ WITH RECURSIVE
                          h.kommunikation_von,
                          h.edifact_format_version,
                          h.anwendungshandbuch_primary_key,
-
+                         h.is_on_uebertragungsdatei_level,
                          h.segmentgroup_id,
                          h.segmentgroup_name,
                          h.segmentgroup_ahb_status,
@@ -368,7 +371,7 @@ WITH RECURSIVE
                          h.kommunikation_von,
                          h.edifact_format_version,
                          h.anwendungshandbuch_primary_key,
-
+                         h.is_on_uebertragungsdatei_level,
                          h.segmentgroup_id,
                          h.segmentgroup_name,
                          h.segmentgroup_ahb_status,
@@ -424,7 +427,7 @@ WITH RECURSIVE
                          h.kommunikation_von,
                          h.edifact_format_version,
                          h.anwendungshandbuch_primary_key,
-
+                         h.is_on_uebertragungsdatei_level,
                          h.segmentgroup_id,
                          h.segmentgroup_name,
                          h.segmentgroup_ahb_status,