Export Infrastrukturhaltung (#23)

teksi · Mar 20, 2024 · db6fe66 · db6fe66
1 parent 43a9044
commit db6fe66
Show file tree

Hide file tree

Showing 2 changed files with 30 additions and 11 deletions.
diff --git a/...si_wastewater/interlis/interlis_model_mapping/interlis_exporter_to_intermediate_schema.py b/...si_wastewater/interlis/interlis_model_mapping/interlis_exporter_to_intermediate_schema.py
@@ -476,6 +476,10 @@ def _export_ag64(self):
         self._export_infrastrukturknoten()
         self._check_for_stop()
 
+        logger.info("Exporting TWW.gephaltung -> ABWASSER.infrastrukturhaltung")
+        self._export_infrastrukturhaltung()
+        self._check_for_stop()
+
     def _export_ag96(self):
         logger.info("Exporting TWW.organisation -> ABWASSER.organisation")
         self._export_organisation()
@@ -666,15 +670,27 @@ def _export_gephaltung(self):
             gephaltung = self.model_classes_interlis.haltung(
                 **self.gep_metainformation_common_ag_xx(row,'gephaltung'),
                 **self.haltung_common_ag_xx(row),
+                gepmassnahmeref=self.get_tid_by_obj_id(row.gepmassnahmeref),
                 hydraulischebelastung=row.hydraulischebelastung,
                 lichte_breite_ist=row.lichte_breite_ist,
                 lichte_breite_geplant=row.lichte_breite_geplant,
                 lichte_hoehe_geplant=row.lichte_hoehe_geplant,
                 nutzungsartag_geplant=row.nutzungsartag_geplant,
-                wiederbeschaffungswert=row.wiederbeschaffungswert,
-                startknoten=self.get_tid_by_obj_id(row.startknoten),
-                endknoten=self.get_tid_by_obj_id(row.endknoten),
-                gepmassnahmeref=self.get_tid_by_obj_id(row.gepmassnahmeref),
+            )
+            self.abwasser_session.add(gephaltung)
+            print(".", end="")
+        logger.info("done")
+        self.abwasser_session.flush()
+
+    def _export_infrastrukturhaltung(self):
+        query = self.tww_session.query(self.model_classes_tww_ag6496.gephaltung)
+        for row in query:
+            gephaltung = self.model_classes_interlis.haltung(
+                **self.haltung_common_ag_xx(row),
+                obj_id= row.obj_id,
+                t_ili_tid= row.obj_id,
+                t_id= self.get_tid(row),
+                lichte_breite=row.lichte_breite_ist,
             )
             self.abwasser_session.add(gephaltung)
             print(".", end="")
@@ -2994,7 +3010,11 @@ def haltung_common_ag_xx(self, row):
             "baulicherzustand": row.baulicherzustand,
             "bauwerkstatus": row.bauwerkstatus,
             "bemerkung_wi": self.truncate(self.emptystr_to_null(row.bemerkung_wi), 80),
+            "betreiber": self.get_tid_by_obj_id(row.betreiber),
             "bezeichnung": self.truncate(self.emptystr_to_null(row.bezeichnung), 20),
+            "datenbewirtschafter_wi": self.get_tid_by_obj_id(row.datenbewirtschafter_wi),
+            "eigentuemer": self.get_tid_by_obj_id(row.eigentuemer),
+            "endknoten":self.get_tid_by_obj_id(row.endknoten),
             "finanzierung": row.finanzierung,
             "funktionhierarchisch": row.funktionhierarchisch,
             "funktionhydraulisch": row.funktionhydraulisch,
@@ -3003,22 +3023,21 @@ def haltung_common_ag_xx(self, row):
             "jahr_zustandserhebung": row.jahr_zustandserhebung,
             "kote_beginn": row.kote_beginn,
             "kote_ende": row.kote_ende,
+            "laengeeffektiv": row.laengeeffektiv,
             "letzte_aenderung_wi": row.letzte_aenderung_wi,
             "lichte_hoehe_ist": row.lichte_hoehe_ist,
-            "laengeeffektiv": row.laengeeffektiv,
             "material": row.material,
-            "profiltyp": row.profiltyp,
             "nutzungsartag_ist": row.nutzungsartag_ist,
+            "profiltyp": row.profiltyp,
             "reliner_art": row.reliner_art,
             "reliner_bautechnik": row.reliner_bautechnik,
             "reliner_material": row.reliner_material,
             "reliner_nennweite": row.reliner_nennweite,
             "sanierungsbedarf": row.sanierungsbedarf,
+            "startknoten":self.get_tid_by_obj_id(row.startknoten),
             "verlauf": row.verlauf,
             "wbw_basisjahr": row.wbw_basisjahr,
-            "betreiber": self.get_tid_by_obj_id(row.betreiber),
-            "datenbewirtschafter_wi": self.get_tid_by_obj_id(row.datenbewirtschafter_wi),
-            "eigentuemer": self.get_tid_by_obj_id(row.eigentuemer),
+            "wiederbeschaffungswert": row.wiederbeschaffungswert,
         }
 
     def ueberlauf_foerderaggregat_common_ag_xx(self, row):

diff --git a/plugin/teksi_wastewater/interlis/interlis_model_mapping/model_interlis_ag64.py b/plugin/teksi_wastewater/interlis/interlis_model_mapping/model_interlis_ag64.py
@@ -17,12 +17,12 @@ class organisation(self.Base):
 
         ModelInterlisAG64.organisation = organisation
 
-        class infrastrukturhaltung(self.Base):
+        class haltung(self.Base):
             __tablename__ = "infrastrukturhaltung"
             __table_args__ = {"schema":config.ABWASSER_SCHEMA}
 
         # Nomenklatur .haltung, damit es für den Label-Export mit VSA-DSS übereinstimmt
-        ModelInterlisAG64.haltung = infrastrukturhaltung
+        ModelInterlisAG64.haltung = haltung
 
         class abwasserbauwerk(self.Base):
             __tablename__ = "infrastrukturknoten"