Added Uebelbach GWR import

scripts/addressdb/uebelbach-gwr/01-addressdb_update_buildings.php

@@ -0,0 +1,308 @@
+#!/usr/bin/php
+<?php
+
+//require 'vendor/autoload.php';
+require("../../../config/config.php");
+
+define('FRONKDB_SQLDEBUG',false);
+error_reporting(E_ALL & ~(E_NOTICE | E_STRICT | E_DEPRECATED));
+
+require_once(LIBDIR."/mvcfronk/mfRouter/mfRouter.php");
+require_once(LIBDIR."/mvcfronk/mfBase/mfBaseModel.php");
+require_once(LIBDIR."/mvcfronk/mfBase/mfBaseController.php");
+
+$me = new User(1);
+
+$filename = __DIR__."/import/GWR_Uebelbach_20231016.csv";
+
+$db = FronkDB::singleton(ADDRESSDB_DBHOST, ADDRESSDB_DBUSER, ADDRESSDB_DBPASS, ADDRESSDB_DBNAME);
+$log = mfLoghandler::singleton();
+
+$input = fopen($filename, "r");
+
+$h_extrefs = [];
+
+$gemeinde_id = 1471;
+$netzgebiet = new ADBNetzgebiet(42);
+$default_plz = "8124";
+$default_freigabe = json_encode(["interest", "provision", "order", "reorder"]);
+
+$gem_kz = "";
+$gem_name = "";
+$plz_name = "";
+$strasse_hausnummer = "";
+$adrcd = "";
+
+
+$i = 0;
+while($csv = fgetcsv($input, 0)) {
+  $i++;
+  if($i == 1) continue;
+  
+  //var_dump($csv);exit;
+  $hausnummer = false;
+  
+  if(!trim($csv[8])) {
+    continue;
+  }
+  
+  if(trim($csv[0])) {
+   $gem_kz = trim($csv[0]);
+   $gem_name = trim($csv[1]);
+   $strasse_hausnummer = trim($csv[4]);
+   $plz_name = $default_plz;
+   $adrcd = trim($csv[8]);
+   
+   $unit_index = 0;
+  }
+  
+  $unit_index++;
+  $unit_num = trim($csv[16]);
+  $unit_tuer = trim($csv[15]);
+  $unit_zusatz = trim($csv[9]);
+  
+  
+  if(!$strasse_hausnummer) {
+    echo "Strasse Hausnummer leer!\n";
+  }
+
+  //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|werkstatt|betrieb und wohnungen|stg|paketlogistik|cafe|pavillon|pfarrheim|[^ ]*haus|[^ ]*geb(?:ae|ä)ude|[^ ]*halle|[^ ]*schule|Öhlmühle)(?:\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(preg_match('/GST(\s+\.)?$/', $strasse_name) && !$adrcd) continue;
+  if(preg_match('/^L\d+/',$strasse_name) && !$adrcd) continue;
+  if($strasse_name == "L" && !$adrcd) continue;
+  if(preg_match('/^BP/',$strasse_name) && !$adrcd) 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");
+  }
+  */
+  
+  //$ort_tries = [];
+  
+
+  
+  
+  if(!$gem_name || !$plz_name || !$strasse_name) {
+    die("!! Konnte Adresse nicht parsen\n");  
+  }
+  
+  /*if(!$hausnummer_extref) {
+    die("!!! Keine Hausnummer Extref\n");
+  }*/
+
+  
+  $gemeinde = ADBGemeindeModel::getFirst(["kennziffer" => $gem_kz]);
+  if(!$gemeinde) {
+    echo "Gemeinde $gem_name $gem_kz nicht gefunden\n";
+    continue;
+  }
+  $gemeinde_id = $gemeinde->id;
+  
+  //if($nutzung == "Greenfield") continue;
+  
+  //continue;
+  // find address in AddressDB and update extrefs
+
+ 
+  $strasse_name = $db->escape($strasse_name);
+  $hausnummer_name = $db->escape($hausnummer_name);
+  
+  if($adrcd) {
+    // get Hausnummer to update
+    $hausnummer = ADBHausnummerModel::getFirst(['adrcd' => $adrcd]);
+    /*if(!$hausnummer) {
+      echo "Hausnummer adrcd $adrcd not found\n";
+    }*/
+  }
+  
+  if(!$hausnummer) {
+    // search Hausnummer
+    $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 = $gemeinde_id AND strasse IN ('". implode("', '", $strasse_search)."') AND hausnummer='$hausnummer_name'";
+    //echo "$sql\n";
+    /*if(preg_match('/^Tobelbader/i',$strasse_name)) {
+      echo "$sql\n";
+    }*/
+    $res = $db->query($sql);
+
+    if($db->num_rows($res)) {
+      // get Hausnummer to update
+      //echo "Hausnummer per Suche gefunden\n";
+      $data = $db->fetch_object($res);
+      $hausnummer = new ADBHausnummer($data->hausnummer_id);
+    } else {
+      // hausnummer anlegen
+      echo "hausnummer anlegen $strasse_hausnummer\n";
+      
+      
+      
+      $strasse = ADBStrasseModel::getFirst(["gemeinde_id" => $gemeinde_id, "name" => $strasse_name]);
+      if(!$strasse) die("Strasse $strasse_name (gemeinde_id $gemeinde_id; gem_kz $gem_kz) nicht gefunden\n");
+      
+      $plz = ADBPlzModel::getFirst(["gemeinde_id" => $gemeinde_id, "plz" => $plz_name]);
+      if(!$plz) die("PLZ $plz_name nicht gefunden\n");
+      
+      /*$ortschaft = ADBOrtschaftModel::getFirst(["gemeinde_id" => $gemeinde_id, "name" => $ort_name]);
+      if(!$ortschaft) {
+        foreach($ort_tries as $search_ort_name) {
+          $ortschaft = ADBOrtschaftModel::getFirst(["gemeinde_id" => $gemeinde_id, "name" => $search_ort_name]);
+          if($ortschaft) break;
+        }
+      }*/
+      
+      // try to find ortschaft other hausnummern with samefrom strasse_id
+      $res = $db->select("Hausnummer", "ortschaft_id", "strasse_id=".$strasse->id." AND ortschaft_id > 0 LIMIT 1");
+      if(!$db->num_rows($res)) {
+        echo "Ortschaft zu $strasse_hausnummer nicht gefunden\n";
+        exit;
+      }
+      $ortschaft_data = $db->fetch_object($res);
+      $ortschaft = new ADBOrtschaft($ortschaft_data->ortschaft_id);
+      
+      if(!$ortschaft) {
+        die("ortschaft $ort_name ($strasse_name $hausnummer_name, $gem_name) nicht gefunden\n");
+      }
+      
+      $hausnummer_data = [
+        "netzgebiet_id" => $netzgebiet->id,
+        "adrcd" => ($adrcd) ? $adrcd : null,
+        "ortschaft_id" => $ortschaft->id,
+        "plz_id" => $plz->id,
+        "strasse_id" => $strasse->id,
+        "hausnummer" => $hausnummer_name,
+        "zusatz" => ($addresszusatz) ? $addresszusatz : null,
+        "unit_count" => 1,
+        "freigabe" => $default_freigabe,
+      ];
+      //var_dump($hausnummer_data);exit;
+      $hausnummer = ADBHausnummerModel::create($hausnummer_data);
+      //var_dump($hausnummer);exit;
+      $hausnummer->save();
+    }
+    
+  }
+  
+  
+  
+  //echo "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) | ADRCD: \033[1m$adrcd\033[0m\n";
+
+  //var_dump($hausnummer);exit;
+  //continue;
+  if($hausnummer->netzgebiet_id != $netzgebiet->id) {
+    $hausnummer->netzgebiet_id = $netzgebiet->id;
+    //$hausnummer->save();
+  }
+  /*if($hausnummer->extref != $hausnummer_extref) {
+    $hausnummer->extref = $hausnummer_extref;
+    //$hausnummer->save();
+  }*/
+  /*if($lat && $long) {
+    $hausnummer->gps_lat = (float)$lat;
+    $hausnummer->gps_long = (float)$long;
+  }*/
+  $hausnummer->freigabe = $default_freigabe;
+  
+  //var_dump($hausnummer);exit;
+  
+  $hausnummer->save();
+  
+
+  
+  $existing_units_count = ADBWohneinheitModel::count(["hausnummer_id" => $hausnummer->id]);
+  //echo "$existing_units_count\n";
+  
+  
+  
+  if($existing_units_count < $unit_index) {
+    // create unit
+    $num = intval($unit_num);
+    $tuer = null;
+    
+    $m = [];
+    if(preg_match('@^/(?:(Tür|Top|\d. ST|\s*unde)\s+)?(\d+|EH)@i', $unit_tuer, $m)) {
+      $tuer = $m[2];
+    }
+    
+    $wohneinheit_data = [
+      'hausnummer_id' => $hausnummer->id,
+      'num' => $num,
+      'tuer' => $tuer,
+      'zusatz' => ($unit_zusatz) ? $unit_zusatz : null
+    ];
+    //var_dump($unit_index, $wohneinheit_data);exit;
+    
+    $wohneinheit = ADBWohneinheitModel::create($wohneinheit_data);
+    $wohneinheit->save();
+  }
+  
+  
+  
+}