thetool/scripts/addressdb/lebring/01-addressdb_update_buildings.php

#!/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/SDIBuilding__Locations__FTTx__ Lebring_20230713.csv";

$db = FronkDB::singleton(ADDRESSDB_DBHOST, ADDRESSDB_DBUSER, ADDRESSDB_DBPASS, ADDRESSDB_DBNAME);
$log = mfLoghandler::singleton();

$input = fopen($filename, "r");

$h_extrefs = [];

//$gemeinde_id = 1448;
$netzgebiet = new ADBNetzgebiet(39);
$default_plz = "8403";
$default_freigabe = json_encode(["interest", "provision", "order", "reorder"]);

$i = 0;
while($csv = fgetcsv($input, 0, ";")) {
  $i++;
  if($i == 1) continue;
  
  
  $hausnummer = false;
  
  if(!trim($csv[0])) {
    continue;
  }
  
  //echo implode(", ", $csv)."\n";
  $gem_kz = trim($csv[60]);
  $gem_name = trim($csv[59]);
  //$ort_kz = trim($csv[2]);
  $plz_name = trim($csv[88]);
  if(!$plz_name) {
    $plz_name = $default_plz;
  }
  $ort_name = trim($csv[31]);
  $strasse_hausnummer = trim($csv[22]);
  $hausnummer_extref = trim($csv[64]);
  if(in_array($hausnummer_extref, $h_extrefs)) {
    die("Hausnummer extref doppelt!\n");
  }
  $h_extrefs[] = $hausnummer_extref;

  $lat = str_replace(",",".",trim($csv[9]));
  $long = str_replace(",",".",trim($csv[10]));


  //var_dump($netzgebiet);exit;

  $nutzung = trim($csv[30]);
  //$funktion = trim($csv[6]);
  /*if($nutzung != "Greenfield" && $funktion == "Greenfield") {
    $nutzung = "Greenfield";
  }*/

  $unit_count = $csv[78];
  if(!$unit_count) $unit_count = 1;
  
  $adrcd = false;
  $adr = trim($csv[46]);
  $adr_parts = explode("-", $adr);
  if(count($adr_parts)) {
    $adrcd = $adr_parts[0];
  }
  
  $fcp_name = $csv[49];
  $rimo_id = $csv[96];
  
  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|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(!$strasse_name && $nutzung != "Greenfield") {
    die("Unbekanntes Adressformat\n");
  }
  
  if($strasse_name == "GST") continue;
  if($strasse_name == "Maräckerweg BP") continue;

  if($strasse_name == "Philips-Straße") $strasse_name = "Philipsstraße";
  if($strasse_name == "Maräckerweg" && $ort_name == "Leibnitz") {
    $ort_name = "Sankt Margarethen bei Lebring";
  } 
  if($strasse_name == "Klein-Stangersdorfer Straße") $strasse_name = "Klein Stangersdorfer Straße";
  if($strasse_name == "Klein Stangersdorfer Straße" && $ort_name == "Leibnitz") {
    $ort_name = "Lebring";
    $gem_name = "Lebring-Sankt Margarethen";
    $gem_kz = "61021";
  }
  if($strasse_name == "Trattenweg" && $hausnummer_name == "5") {
    $plz_name = 8403;
  }
  if(preg_match('/Lebring.+Margarethen/', $ort_name)) {
    $ort_name = "Lebring";
  }
  if($strasse_name == "BP GST.:") continue;
  /*if($strasse_name == "Trattenweg" && $ort_name != "Lebring") {
    $ort_name = "Lebring";
  }*/
  
  if(!$gem_name || !$plz_name || !$ort_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";
    } else {
      //echo "Hausnummer adrcd $adrcd gefunden!\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\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 (gemeinde_id $gemeinde_id; gem_kz $gem_kz; strasse $strasse_name, hausnummer $hausnummer_name)\n");
      
      $ortschaft = ADBOrtschaftModel::getFirst(["gemeinde_id" => $gemeinde_id, "name" => $ort_name]);
      if(!$ortschaft) die("$strasse_hausnummer: ortschaft $ort_name nicht gefunden (gemeinde_id $gemeinde_id; gem_kz $gem_kz; strasse $strasse_name, hausnummer $hausnummer_name)\n");
      
      $hausnummer_data = [
        "netzgebiet_id" => $netzgebiet->id,
        "adrcd" => ($adrcd) ? $adrcd : null,
        "extref" => $hausnummer_extref,
        "ortschaft_id" => $ortschaft->id,
        "plz_id" => $plz->id,
        "strasse_id" => $strasse->id,
        "hausnummer" => $hausnummer_name,
        "zusatz" => ($addresszusatz) ? $addresszusatz : null,
        "gps_lat" => $lat,
        "gps_long" => $long,
        "unit_count" => ($unit_count) ? $unit_count : 1,
        "freigabe" => $default_freigabe,
        "rimo_id" => $rimo_id,
        "rimo_fcp_name" => $fcp_name
      ];
      $hausnummer = ADBHausnummerModel::create($hausnummer_data);
      //var_dump($hausnummer);exit;
      $hausnummer->save();
      continue;
    }
    
  }
  
  //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;
  }
  if($rimo_id) $hausnummer->rimo_id = $rimo_id;
  if($fcp_name) $hausnummer->rimo_fcp_name = $fcp_name;
  $hausnummer->freigabe = $default_freigabe;
  $hausnummer->save();
  

  
  $existing_units_count = ADBWohneinheitModel::count(["hausnummer_id" => $hausnummer->id]);
  //echo "$existing_units_count\n";
  
  if(!$existing_units_count) {
    $hausnummer->unit_count = $unit_count;
    // create units
    
    for($u = 0; $u < $unit_count; $u++) {
      $num = $u + 1;

      $wohneinheit_data = [
        'hausnummer_id' => $hausnummer->id,
        'num' => $num,
        'tuer' => ($unit_count > 1) ? $num : null
      ];

      $wohneinheit = ADBWohneinheitModel::create($wohneinheit_data);
      //continue;
      $wohneinheit->save();
    }
  }
  
  
  
}