From e354dea9e874a4596c48c111d30d2dc08e4debf7 Mon Sep 17 00:00:00 2001 From: Frank Schubert Date: Thu, 17 Nov 2022 13:53:36 +0100 Subject: [PATCH] addressdb import scripts --- .../addressdb_import_bev_adressregister.php | 212 +++++----- .../addressdb_update_buildings.php} | 0 .../gross-st-florian/import/.gitignore | 2 + .../{ => premstaetten}/add_freigabe.php | 0 .../addressdb_home_update.php | 0 .../{ => premstaetten}/addressdb_import.php | 0 .../premstaetten/addressdb_update.php | 370 ++++++++++++++++++ .../addressdb/premstaetten/import/.gitignore | 2 + scripts/addressdb/remove_multiple_streets.php | 50 +++ 9 files changed, 545 insertions(+), 91 deletions(-) rename scripts/addressdb/{addressdb_update.php => gross-st-florian/addressdb_update_buildings.php} (100%) mode change 100755 => 100644 create mode 100644 scripts/addressdb/gross-st-florian/import/.gitignore rename scripts/addressdb/{ => premstaetten}/add_freigabe.php (100%) rename scripts/addressdb/{ => premstaetten}/addressdb_home_update.php (100%) rename scripts/addressdb/{ => premstaetten}/addressdb_import.php (100%) create mode 100755 scripts/addressdb/premstaetten/addressdb_update.php create mode 100644 scripts/addressdb/premstaetten/import/.gitignore create mode 100644 scripts/addressdb/remove_multiple_streets.php diff --git a/scripts/addressdb/addressdb_import_bev_adressregister.php b/scripts/addressdb/addressdb_import_bev_adressregister.php index 9dcb7f2f5..79c645b31 100755 --- a/scripts/addressdb/addressdb_import_bev_adressregister.php +++ b/scripts/addressdb/addressdb_import_bev_adressregister.php @@ -232,6 +232,7 @@ echo "\n".($i-1)." Straßen importiert\n"; $filename = "$folder/ADRESSE.csv"; +//$filename = "$folder/premstaetten_hauptstrasse.csv"; $input = fopen($filename, "r"); $db->query("SET autocommit=0"); @@ -244,7 +245,7 @@ while($csv = fgetcsv($input, 0, ";")) { $i++; if($i == 1) continue; - if($i % 1000 == 0) { + if($i % 1000 == 0) { echo "."; } if($i % 10000 == 0) { @@ -290,96 +291,7 @@ while($csv = fgetcsv($input, 0, ";")) { if($current_skz) { - $gemeinde = getGemeinde($current_gkz); - if(!$gemeinde) { - die("Kann Adresse nicht importieren: Gemeinde nicht gefunden ($gkz)\n"); - } - - $strasse = getStrasse($current_skz); - if(!$strasse) { - die("Kann Adresse nicht importieren: Strasse nicht gefunden ($okz)\n"); - } - - // do database work for all sdata - $hausnummern_filter = []; - - foreach($sdata as $s) { - $plz = getPlz($s["plz"], $gemeinde->id); - if(!$plz) { - $plz = ADBPlzModel::create([ - "gemeinde_id" => $gemeinde->id, - "plz" => $s["plz"], - "plzstring" => $s["plz"] - ]); - if(!$plz->save()) { - die("Cannot create PLZ $plz_string (gemeinde ".$gemeinde->id.")\n"); - } - } - - $hausnummern_filter[] = $s['hausnummer']; - } - - - $hausnummern = ADBHausnummerModel::search(["strasse_id" => $strasse->id, "hausnummer" => $hausnummern_filter]); - $new_hausnummern = []; - - foreach($sdata as $shausnummer => $s) { - $found = false; - $ort = getOrtschaft($s['okz']); - if(!$ort->id) die("Ortschaft nicht gefunden ".$s['okz']); - - foreach($hausnummern as $h) { - if($h->hausnummer == $shausnummer && $h->ortschaft_id = $ort->id) { - //exists already - $found = true; - - // check to update plz - if($h->plz->plz != $s['plz'] ) { - echo "Updating PLZ for Hausnummer ".$h->id." from ".$h->plz->plz." to ".$s["plz"]."\n"; - $plz = getPlz($s['plz'], $gemeinde->id); - $h->plz_id = $plz->id; - $h->save(); - } - - } - } - if(!$found) { - $new_hausnummern[$shausnummer] = $s; - } - } - $new_hausnummern = $sdata; - - - - if(count($new_hausnummern)) { - $insert = "INSERT INTO `Hausnummer` (`netzgebiet_id`, `adrcd`, `ortschaft_id`, `plz_id`, `strasse_id`, `hausnummer`, `create`, `edit`) VALUES "; - foreach($new_hausnummern as $h_string => $s) { - //var_dump($h_string, $s);exit; - //$h_string = $h->hausnummer; - //$s = $sdata[$h_string]; - $acode = $s["adrcd"]; - $strasse_id = $strasse->id; - $plz = getPlz($s['plz'],$gemeinde->id); - if(!$plz) { - var_dump($s);exit; - } - $plz_id = $plz->id; - $ortschaft = getOrtschaft($s["okz"]); - if(!$ortschaft) { - die("Kann Adresse nicht importieren: Ortschaft nicht gefunden (strasse: hausnummer: $h_string, okz: ".$sdata[$h_string]["okz"].")\n"); - } - $ortschaft_id = $ortschaft->id; - // add to INSERT statement - $insert .= "(0, '$acode', $ortschaft_id, $plz_id, $strasse_id,'$h_string', UNIX_TIMESTAMP(), UNIX_TIMESTAMP()),"; - - } - $insert = preg_replace('/,$/', "", $insert); - //echo "$insert\n"; - $db->query($insert); - - } - - + insertUpdateHausnummer($sdata, $current_gkz, $current_skz); } $current_skz = $skz; @@ -396,8 +308,126 @@ while($csv = fgetcsv($input, 0, ";")) { } +insertUpdateHausnummer($sdata, $current_gkz, $current_skz); + + $db->query("COMMIT"); +function insertUpdateHausnummer($sdata, $current_gkz, $current_skz) { + global $db; + + $gemeinde = getGemeinde($current_gkz); + if(!$gemeinde) { + die("Kann Adresse nicht importieren: Gemeinde nicht gefunden ($gkz)\n"); + } + + $strasse = getStrasse($current_skz); + if(!$strasse) { + die("Kann Adresse nicht importieren: Strasse nicht gefunden ($okz)\n"); + } + + // do database work for all sdata + $hausnummern_filter = []; + + foreach($sdata as $s) { + $plz = getPlz($s["plz"], $gemeinde->id); + if(!$plz) { + $plz = ADBPlzModel::create([ + "gemeinde_id" => $gemeinde->id, + "plz" => $s["plz"], + "plzstring" => $s["plz"] + ]); + if(!$plz->save()) { + die("Cannot create PLZ $plz_string (gemeinde ".$gemeinde->id.")\n"); + } + } + + $hausnummern_filter[] = $s['hausnummer']; + } + + + $hausnummern = ADBHausnummerModel::search(["strasse_id" => $strasse->id, "hausnummer" => $hausnummern_filter]); + $new_hausnummern = []; + + foreach($sdata as $shausnummer => $s) { + //echo "Hausnummer $shausnummer (strasse ".$strasse->id.") :\n"; + $found = false; + $ort = getOrtschaft($s['okz']); + if(!$ort->id) die("Ortschaft nicht gefunden ".$s['okz']); + + foreach($hausnummern as $h) { + + /*if($h->hausnummer == $shausnummer) { + echo "if(".$h->hausnummer." == ".$shausnummer." && ".$h->ortschaft_id." == ".$ort->id.") \n"; + }*/ + + if($h->hausnummer == $shausnummer && $h->ortschaft_id == $ort->id) { + //exists already + //echo "found\n"; + $found = true; + + // check to update plz + if($h->plz->plz != $s['plz'] ) { + echo "Updating PLZ for Hausnummer ".$h->id." from ".$h->plz->plz." to ".$s["plz"]."\n"; + $plz = getPlz($s['plz'], $gemeinde->id); + $h->plz_id = $plz->id; + $h->save(); + } + continue; + } + } + if(!$found) { + //echo "not found ($shausnummer)\n"; + $new_hausnummern[$shausnummer] = $s; + } + } + //$new_hausnummern = $sdata; + + + + if(count($new_hausnummern)) { + $insert = "INSERT INTO `Hausnummer` (`netzgebiet_id`, `adrcd`, `ortschaft_id`, `plz_id`, `strasse_id`, `hausnummer`, `freigabe`, `create`, `edit`) VALUES "; + foreach($new_hausnummern as $h_string => $s) { + //var_dump($h_string, $s);exit; + //$h_string = $h->hausnummer; + //$s = $sdata[$h_string]; + $acode = $s["adrcd"]; + $strasse_id = $strasse->id; + $plz = getPlz($s['plz'],$gemeinde->id); + if(!$plz) { + var_dump($s);exit; + } + $plz_id = $plz->id; + $ortschaft = getOrtschaft($s["okz"]); + if(!$ortschaft) { + die("Kann Adresse nicht importieren: Ortschaft nicht gefunden (strasse: hausnummer: $h_string, okz: ".$sdata[$h_string]["okz"].")\n"); + } + $ortschaft_id = $ortschaft->id; + + $freigabe = "NULL"; + $netzgebiet_id = 0; + if($gemeinde->id == 1) { + $netzgebiet_id = 1; + $freigabe = '\'["interest", "provision", "order", "reorder"]\''; + } + + // add to INSERT statement + $insert .= "($netzgebiet_id, '$acode', $ortschaft_id, $plz_id, $strasse_id,'$h_string', $freigabe, UNIX_TIMESTAMP(), UNIX_TIMESTAMP()),"; + if($gemeinde->id === 1) { + echo "Importiere ".$plz->plzstring.", ".$ortschaft->name.", ".$strasse->name." ".$h_string."\n"; + } + + } + $insert = preg_replace('/,$/', "", $insert); + //echo "$insert\n";exit; + $db->query($insert); + + } + + +} + + function makeHausnummer($z1 = false, $z2 = false, $v = false, $b1 = false, $b2 = false) { $h = ""; diff --git a/scripts/addressdb/addressdb_update.php b/scripts/addressdb/gross-st-florian/addressdb_update_buildings.php old mode 100755 new mode 100644 similarity index 100% rename from scripts/addressdb/addressdb_update.php rename to scripts/addressdb/gross-st-florian/addressdb_update_buildings.php diff --git a/scripts/addressdb/gross-st-florian/import/.gitignore b/scripts/addressdb/gross-st-florian/import/.gitignore new file mode 100644 index 000000000..c96a04f00 --- /dev/null +++ b/scripts/addressdb/gross-st-florian/import/.gitignore @@ -0,0 +1,2 @@ +* +!.gitignore \ No newline at end of file diff --git a/scripts/addressdb/add_freigabe.php b/scripts/addressdb/premstaetten/add_freigabe.php similarity index 100% rename from scripts/addressdb/add_freigabe.php rename to scripts/addressdb/premstaetten/add_freigabe.php diff --git a/scripts/addressdb/addressdb_home_update.php b/scripts/addressdb/premstaetten/addressdb_home_update.php similarity index 100% rename from scripts/addressdb/addressdb_home_update.php rename to scripts/addressdb/premstaetten/addressdb_home_update.php diff --git a/scripts/addressdb/addressdb_import.php b/scripts/addressdb/premstaetten/addressdb_import.php similarity index 100% rename from scripts/addressdb/addressdb_import.php rename to scripts/addressdb/premstaetten/addressdb_import.php diff --git a/scripts/addressdb/premstaetten/addressdb_update.php b/scripts/addressdb/premstaetten/addressdb_update.php new file mode 100755 index 000000000..32e8145e4 --- /dev/null +++ b/scripts/addressdb/premstaetten/addressdb_update.php @@ -0,0 +1,370 @@ +#!/usr/bin/php +loadByExtref($netzgebiet_extref); + if(!$netzgebiet->id) { + die("Netzgebiet nicht gefunden: $netzgebiet_extref\n"); + } + //var_dump($netzgebiet);exit; + + $nutzung = trim($csv[9]); + $funktion = trim($csv[20]); + if($nutzung != "Greenfield" && $funktion == "Greenfield") { + $nutzung = "Greenfield"; + } + + $unit_count = $csv[10]; + if(!$unit_count) $unit_count = 1; + + if(!$strasse_hausnummer) continue; + + //echo "strasse: $strasse\n"; + //echo "strasse_building: $strasse_building\n"; + + $strasse_name = ""; + $hausnummer_name = ""; + $addresszusatz = ""; + + $m = []; + // (?:\s+((?:gesch(?:ae|ä)ft|betrieb und wohnungen|paketlogistik|cafe|pavillon|pfarrheim|[^ ]*haus|[^ ]*geb(?:ae|ä)ude|[^ ]*halle)(?:\s+[a-z0-9]+)?))? + if(preg_match('/^(\D+)\s+(\d+[a-z0-9\/&#._-]*)(?:\s+((?:gesch(?:ae|ä)ft|betrieb und wohnungen|stg|paketlogistik|cafe|pavillon|pfarrheim|[^ ]*haus|[^ ]*geb(?:ae|ä)ude|[^ ]*halle)(?:\s+[a-z0-9]+)?))?/i', $strasse_hausnummer, $m)) { + $strasse_name = trim($m[1]); + $hausnummer_name = trim($m[2]); + if(array_key_exists(3, $m)) { + $addresszusatz = trim($m[3]); + } + } elseif(preg_match('/^(.+)\s+(\d+[a-z0-9\/&#._-]*)(.+)?/i', $strasse_hausnummer, $m)) { + $strasse_name = trim($m[1]); + $hausnummer_name = trim($m[2]); + if(array_key_exists(3, $m)) { + $addresszusatz = trim($m[3]); + } + } elseif(preg_match('/^(.+)/i', $strasse_hausnummer, $m)) { + // ignore GST objects + continue; + $strasse_name = trim($m[1]); + } + + if($strasse_name == "Dr.Karl-Renner-Weg") $strasse_name = "Dr.-Karl-Renner-Weg"; + if($strasse_name == "Bierbaumer Strasse") $strasse_name = "Bierbaumerstrasse"; + if($strasse_name == "GST") continue; + if(preg_match('/^L\d+/',$strasse_name)) continue; + + /*if($strasse_name == "Hauptstrasse 103 Geschaeft" && $hausnummer_name == "1") { + $strasse_name = "Hauptstrasse"; + $hausnummer_name = "103"; + $addresszusatz = "Geschaeft 1"; + } + + if($strasse_name == "Hauptstrasse 131 Stg") { + $strasse_name = "Hauptstrasse"; + $addresszusatz = "Stg $hausnummer_name"; + $hausnummer_name = "131"; + }*/ + + if(!$strasse_name && !$nutzung == "Greenfield") { + die("Unbekanntes Adressformat\n"); + } + } + + + + if(!$gem_name || !$plz_name || !$ort_name || !$strasse_name) { + die("!! Konnte Adresse nicht parsen\n"); + } + + if(!$hausnummer_extref) { + die("!!! Keine Hausnummer Extref\n"); + } + + if(!$netzgebiet_extref) { + die("!!! Keine Netzgebiet Extref\n"); + } + if($nutzung == "Greenfield") continue; + //echo "Netzgebiet extref: \033[1m$netzgebiet_extref\033[0m | Hausnummer extref: \033[1m$hausnummer_extref\033[0m | gem: \033[1m$gem_name\033[0m | plz: \033[1m$plz_name\033[0m | ort: \033[1m$ort_name\033[0m | strasse: \033[1m$strasse_name\033[0m | hausnummer: \033[1m$hausnummer_name\033[0m |"; + //echo "Zusatz: \033[1m$addresszusatz\033[0m | (\033[1m$nutzung\033[0m)\n"; + //continue; + // find address in AddressDB and update extrefs + + $strasse_name = $db->escape($strasse_name); + $hausnummer_name = $db->escape($hausnummer_name); + + $strasse_search = [$strasse_name]; + + if(strpos($strasse_name, ' ') !== false) $strasse_search[] = str_replace(' ', '-', $strasse_name); + if(strpos($strasse_name, '-') !== false) $strasse_search[] = str_replace('-', ' ', $strasse_name); + if(strpos($strasse_name, '.') !== false) $strasse_search[] = str_replace('.', '. ', $strasse_name); + if(strpos($strasse_name, '.') !== false) $strasse_search[] = str_replace('.', '.-', $strasse_name); + if(strpos($strasse_name, '. ') !== false) $strasse_search[] = str_replace('. ', '.', $strasse_name); + if(strpos($strasse_name, '. ') !== false) $strasse_search[] = str_replace('. ', '.-', $strasse_name); + if(strpos($strasse_name, '.') !== false) $strasse_search[] = str_replace('.-', '.', $strasse_name); + if(strpos($strasse_name, '.') !== false) $strasse_search[] = str_replace('.-', '. ', $strasse_name); + + foreach($strasse_search as $search) { + if(strpos($search, 'ß') !== false) $strasse_search[] = str_replace('ß', 'ss', $search); + if(strpos($search, 'ä') !== false) $strasse_search[] = str_replace('ä', 'ae', $search); + if(strpos($search, 'ö') !== false) $strasse_search[] = str_replace('ö', 'oe', $search); + if(strpos($search, 'ü') !== false) $strasse_search[] = str_replace('ü', 'ue', $search); + + if(strpos($search, 'ss') !== false) $strasse_search[] = str_replace('ss', 'ß', $search); + if(strpos($search, 'ae') !== false) $strasse_search[] = str_replace('ae', 'ä', $search); + if(strpos($search, 'oe') !== false) $strasse_search[] = str_replace('oe', 'ö', $search); + if(strpos($search, 'ue') !== false) $strasse_search[] = str_replace('ue', 'ü', $search); + } + + + $sql = "SELECT * FROM view_hausnummer WHERE gemeinde_id = 1 AND strasse IN ('". implode("', '", $strasse_search)."') AND hausnummer='$hausnummer_name'"; + /*if(preg_match('/^Tobelbader/i',$strasse_name)) { + echo "$sql\n"; + }*/ + $res = $db->query($sql); + + if(!$db->num_rows($res)) { + // adresse nicht gefunden => anlegen + + if($nutzung == "Greenfield") continue; + if(!$nutzung || $nutzung == "Transmitting station") continue; + + echo "creating $strasse_name $hausnummer_name $ort_name\n"; + + $ort_search = [$ort_name]; + + if(strpos($ort_name, 'ß') !== false) $ort_search[] = str_replace('ß', 'ss', $ort_name); + if(strpos($ort_name, 'ä') !== false) $ort_search[] = str_replace('ä', 'ae', $ort_name); + if(strpos($ort_name, 'ö') !== false) $ort_search[] = str_replace('ö', 'oe', $ort_name); + if(strpos($ort_name, 'ü') !== false) $ort_search[] = str_replace('ü', 'ue', $ort_name); + + if(strpos($ort_name, 'ss') !== false) $ort_search[] = str_replace('ss', 'ß', $ort_name); + if(strpos($ort_name, 'ae') !== false) $ort_search[] = str_replace('ae', 'ä', $ort_name); + if(strpos($ort_name, 'oe') !== false) $ort_search[] = str_replace('oe', 'ö', $ort_name); + if(strpos($ort_name, 'ue') !== false) $ort_search[] = str_replace('ue', 'ü', $ort_name); + + $ortschaft = ADBOrtschaftModel::getFirst(['name' => $ort_search]); + if(!$ortschaft->id) die("Ortschaft nicht gefunden: $ort_name\n"); + + $strasse_id = false; + + $strsql = "SELECT * FROM view_hausnummer WHERE gemeinde_id=1 AND ortschaft IN ('". implode("', '", $ort_search)."') AND strasse IN ('". implode("', '", $strasse_search)."')"; + //echo "$strsql\n";exit; + $strres = $db->query($strsql); + if(!$db->num_rows($strres)) { + echo("Strasse in adressdb nicht gefunden, wird erstellt: $strsql\n"); + + // create strasse + + $strasse_data = [ + 'ortschaft_id' => $ortschaft->id, + 'gemeinde_id' => 1, + 'name' => $strasse_name + ]; + $strasse = ADBStrasseModel::create($strasse_data); + //$strasse_id = $strasse->save(); + //if(!$strasse_id) die("Cannot create strasse: $strasse_name\n"); + } else { + $data = $db->fetch_object($strres); + $strasse_id = $data->strasse_id; + } + /* + if(!$strasse_id) { + die("keine strasse_id"); + }*/ + /* + $plz = ADBPlzModel::getFirst(['plz' => $plz_name]); + if(!$plz) die("PLZ nicht gefunden: $plz_name\n"); + + $hausnummer_data = [ + 'netzgebiet_id' => $netzgebiet->id, + 'extref' => $hausnummer_extref, + 'ortschaft_id' => $ortschaft->id, + 'plz_id' => $plz->id, + 'strasse_id' => $strasse_id, + 'hausnummer' => $hausnummer_name, + 'zusatz' => $addresszusatz, + 'gps_lat' => $lat, + 'gps_long' => $long, + 'freigabe' => 'voll' + ]; + + //var_dump($hausnummer_data);exit; + $hausnummer = ADBHausnummerModel::create($hausnummer_data); + $hausnummer_id = $hausnummer->save(); + + if(!$hausnummer_id) die("Error creating hausnummer"); + */ + } else { + + $data = $db->fetch_object($res); + $hausnummer = new ADBHausnummer($data->hausnummer_id); + + if($hausnummer->netzgebiet_id != $netzgebiet->id) { + $hausnummer->netzgebiet_id = $netzgebiet->id; + $hausnummer->save(); + } + if($hausnummer->extref != $hausnummer_extref) { + $hausnummer->extref = $hausnummer_extref; + $hausnummer->save(); + } + $hausnummer->gps_lat = (float)$lat; + $hausnummer->gps_long = (float)$long; + $hausnummer->freigabe = "voll"; + $hausnummer->save(); + + } + /* + if($hausnummer) { + // create missing wohneinheiten + $new_unit_count = 0; + $last_unit_tuer = 0; + + $units = ADBWohneinheitModel::search(['hausnummer_id' => $hausnummer->id]); + if(count($units)) { + foreach($units as $unit) { + if($unit->tuer > $last_unit_tuer) { + $last_unit_tuer = $unit->tuer; + } + } + } + echo $hausnummer->strasse->name." ".$hausnummer->hausnummer."(".$hausnummer->id."): ".count($units)." vorhanden vs. csv ".$unit_count."\n"; + if(count($units) < $unit_count) { + $new_unit_count = $unit_count - count($units); + } + + if($new_unit_count && count($units) === 1) { + $unit = $units[0]; + if(!$unit->zusatz && !$unit->tuer) { + $unit->tuer = 1; + if(!$unit->save()) { + die("Couldn't set tuer to 1 (wohneinheit ".$unit->id.")"); + } + $last_unit_tuer = 1; + } + } + + if($new_unit_count == 1 && $nutzung != "Transmitting station") { + // create single wohneinheit + echo "Creating single Wohneiheit (".$hausnummer->strasse->name." ".$hausnummer->hausnummer." - hausnummer_id: ".$hausnummer->id.")\n"; + $unit_data = [ + 'hausnummer_id' => $hausnummer->id, + 'num' => 1, + 'nutzung' => "Wohnung" + ]; + if($last_unit_tuer) { + $unit_data['tuer'] = ++$last_unit_tuer; + } + $unit = ADBWohneinheitModel::create($unit_data); + //var_dump($unit);exit; + $unit->save(); + } + + if($new_unit_count > 1) { + echo "Creating $new_unit_count Wohneiheiten (".$hausnummer->strasse->name." ".$hausnummer->hausnummer." - hausnummer_id: ".$hausnummer->id.")\n"; + for($i = 0; $i < $new_unit_count; $i++) { + if($nutzung == "Transmitting station") continue; + + $unit_data = [ + 'hausnummer_id' => $hausnummer->id, + 'num' => 1, + 'tuer' => ++$last_unit_tuer, + 'nutzung' => "Wohnung" + ]; + $unit = ADBWohneinheitModel::create($unit_data); + + $unit->save(); + } + //if($hausnummer->id != 1723 && $nutzung != "Transmitting station") { var_dump($unit);exit; } + } + }*/ + + /* + + $data = $db->fetch_object($res); + $csv_ort = str_replace(['ß','ä','ö','ü'], ['ss','ae','oe','ue'], $ort_name); + $db_ort = str_replace(['ß','ä','ö','ü'], ['ss','ae','oe','ue'], $data->ortschaft); + */ + // update ortschaft if needed + /* + if($csv_ort != $db_ort && $nutzung != "Greenfield") { + + if($strasse_name != "Hauptstrasse" && $hausnummer_name != "133") { + + echo "Netzgebiet extref: \033[1m-------\033[0m | Hausnummer extref: \033[1m--------\033[0m | gem: \033[1m$data->gemeinde\033[0m | plz: \033[1m$data->plz\033[0m | ort: \033[1m$db_ort\033[0m | strasse: \033[1m$data->strasse\033[0m | hausnummer: \033[1m$data->hausnummer\033[0m\n"; + // find ortschaft + + $ortschaft = ADBOrtschaftModel::getFirst(['name' => $ort_name]); + if(!$ortschaft) { + $ort_data = []; + $ort_data['gemeinde_id'] = 1; + $ort_data['name'] = $ort_name; + $ort_data['plz'] = $plz_name; + $ortschaft = ADBOrtschaftModel::create($ort_data); + $ortschaft_id = $ortschaft->save(); + if(!$ortschaft_id) { + die("Konnte Ortschaft ($ort_name) nicht erstellen."); + } + } + + // update ortschaft in hausnummer + $hausnummer = new ADBHausnummer($data->hausnummer_id); + if(!$hausnummer->id) { + die("Hausnummer nicht gefunden für Ort update"); + } + $hausnummer->ortschaft_id = $ortschaft->id; + $hausnummer->save(); + } + }*/ + + //echo "$data->ortschaft, $data->plz, $data->strasse, $data->hausnummer\n"; + + +} \ No newline at end of file diff --git a/scripts/addressdb/premstaetten/import/.gitignore b/scripts/addressdb/premstaetten/import/.gitignore new file mode 100644 index 000000000..c96a04f00 --- /dev/null +++ b/scripts/addressdb/premstaetten/import/.gitignore @@ -0,0 +1,2 @@ +* +!.gitignore \ No newline at end of file diff --git a/scripts/addressdb/remove_multiple_streets.php b/scripts/addressdb/remove_multiple_streets.php new file mode 100644 index 000000000..84a3a6f88 --- /dev/null +++ b/scripts/addressdb/remove_multiple_streets.php @@ -0,0 +1,50 @@ +#!/usr/bin/php + 1]) as $mstrasse) { + $master_strassen[$mstrasse->id] = $mstrasse; +} + +while(count($master_strassen)) { + echo "count master strassen ".count($master_strassen)."\n"; + $strasse = array_shift($master_strassen); + //var_dump($strasse); + $all_strassen = ADBStrasseModel::search(['gemeinde_id' => $strasse->gemeinde_id, "kennziffer" => $strasse->kennziffer]); + if(count($all_strassen) > 1) { + //var_dump($all_strassen); + $orig_strasse = array_shift($all_strassen); + //var_dump($orig_strasse, $all_strassen);exit; + $wrong_strasse_ids = []; + foreach($all_strassen as $rstrasse) { + $wrong_strasse_ids[] = $rstrasse->id; + $rstrasse->delete(); + } + //var_dump($wrong_strasse_ids); + foreach(ADBHausnummerModel::search(['strasse_id' => $wrong_strasse_ids]) as $hausnummer) { + //var_dump($hausnummer);exit; + echo "updating hausnummer ".$hausnummer->id.": strasse_id ".$hausnummer->strasse_id." to ".$orig_strasse->id."\n"; + $hausnummer->strasse_id = $orig_strasse->id; + $hausnummer->save(); + } + foreach($wrong_strasse_ids as $wid) { + unset($master_strassen[$wid]); + } + echo "ecount master strassen ".count($master_strassen)."\n"; + } + $i++; +} +