diff --git a/plugin/teksi_wastewater/interlis/interlis_model_mapping/interlis_exporter_to_intermediate_schema.py b/plugin/teksi_wastewater/interlis/interlis_model_mapping/interlis_exporter_to_intermediate_schema.py index e9afe4f48..85e9fba6b 100644 --- a/plugin/teksi_wastewater/interlis/interlis_model_mapping/interlis_exporter_to_intermediate_schema.py +++ b/plugin/teksi_wastewater/interlis/interlis_model_mapping/interlis_exporter_to_intermediate_schema.py @@ -491,6 +491,10 @@ def _export_ag96(self): logger.info("Exporting TWW.einzugsgebiet -> ABWASSER.einzugsgebiet") self._export_einzugsgebiet() + self._check_for_stop() + + logger.info("Exporting TWW.bautenausserhalbbaugebiet -> ABWASSER.bautenausserhalbbaugebiet") + self._export_bautenausserhalbbaugebiet() self._check_for_stop() logger.info("Exporting TWW.ueberlauf_foerderaggregat -> ABWASSER.ueberlauf_foerderaggregat") @@ -652,7 +656,7 @@ def _export_gephaltung(self): def _export_einzugsgebiet(self): query = self.tww_session.query(self.model_classes_tww_ag6496.einzugsgebiet) for row in query: - gephaltung = self.model_classes_interlis.einzugsgebiet( + einzugsgebiet = self.model_classes_interlis.einzugsgebiet( **self.gep_metainformation_common_ag_xx(row,'einzugsgebiet'), abflussbegrenzung_geplant=row.abflussbegrenzung_geplant, abflussbegrenzung_ist=row.abflussbegrenzung_ist, @@ -687,7 +691,33 @@ def _export_einzugsgebiet(self): gepknoten_sw_geplantref=self.get_tid_by_obj_id(row.gepknoten_sw_geplantref), gepknoten_sw_istref=self.get_tid_by_obj_id(row.gepknoten_sw_istref), ) - self.abwasser_session.add(gephaltung) + self.abwasser_session.add(einzugsgebiet) + print(".", end="") + logger.info("done") + self.abwasser_session.flush() + + def _export_bautenausserhalbbaugebiet(self): + query = self.tww_session.query(self.model_classes_tww_ag6496.bautenausserhalbbaugebiet) + for row in query: + bautenausserhalbbaugebiet = self.model_classes_interlis.bautenausserhalbbaugebiet( + **self.gep_metainformation_common_ag_xx(row,'bautenausserhalbbaugebiet'), + anzstaendigeeinwohner=row.anzstaendigeeinwohner, + arealnutzung=row.arealnutzung, + beseitigung_haeusliches_abwasser=row.beseitigung_haeusliches_abwasser, + beseitigung_gewerbliches_abwasser=row.beseitigung_gewerbliches_abwasser, + beseitigung_platzentwaesserung=row.beseitigung_platzentwaesserung, + beseitigung_dachentwaesserung=row.beseitigung_dachentwaesserung, + bezeichnung=self.truncate(self.emptystr_to_null(row.bezeichnung), 20), + eigentuemeradresse=row.eigentuemeradresse, + eigentuemername=row.eigentuemername, + einwohnergleichwert=row.einwohnergleichwert, + lage=row.lage, + nummer=row.nummer, + sanierungsbedarf=row.sanierungsbedarf.capitalize(), + sanierungsdatum=row.sanierungsdatum, + sanierungskonzept=row.sanierungskonzept, + ) + self.abwasser_session.add(bautenausserhalbbaugebiet) print(".", end="") logger.info("done") self.abwasser_session.flush() diff --git a/plugin/teksi_wastewater/interlis/interlis_model_mapping/model_tww_ag6496.py b/plugin/teksi_wastewater/interlis/interlis_model_mapping/model_tww_ag6496.py index c1595f194..9c9b4e342 100644 --- a/plugin/teksi_wastewater/interlis/interlis_model_mapping/model_tww_ag6496.py +++ b/plugin/teksi_wastewater/interlis/interlis_model_mapping/model_tww_ag6496.py @@ -174,6 +174,24 @@ class einzugsgebiet(self.Base): class bautenausserhalbbaugebiet(self.Base): __tablename__ = "bautenausserhalbbaugebiet" obj_id=Column(String, primary_key=True) + anzstaendigeeinwohner = Column(Integer) + arealnutzung = Column(String) + beseitigung_haeusliches_abwasser = Column(String) + beseitigung_gewerbliches_abwasser = Column(String) + beseitigung_platzentwaesserung = Column(String) + beseitigung_dachentwaesserung = Column(String) + bezeichnung = Column(String) + eigentuemeradresse = Column(String) + eigentuemername = Column(String) + einwohnergleichwert = Column(Integer) + lage = Column(Geometry) + nummer = Column(Integer) + sanierungsbedarf = Column(String) + sanierungsdatum = Column(DateTime) + sanierungskonzept = Column(String) + datenbewirtschafter_gep = Column(String) + bemerkung_gep = Column(String) + letzte_aenderung_gep = Column(DateTime) __table_args__ = {"schema": config.TWW_AG_SCHEMA} ModelTwwAG6496.bautenausserhalbbaugebiet = bautenausserhalbbaugebiet