Added import scripts for gross st. florian

This commit is contained in:
Frank Schubert
2022-11-24 12:37:26 +01:00
parent 0779c29830
commit 778df63a80
3 changed files with 304 additions and 309 deletions

View File

@@ -34,9 +34,7 @@ class FronkDB {
//echo "new FronkDB instance $instance_name\n";
$c = __CLASS__;
self::$instances[$instance_name] = new $c($host,$user,$pass,$db);
} else {
//echo "existing FronkDB instance $instance_name\n";
}
}
return self::$instances[$instance_name];
}

View File

@@ -0,0 +1,123 @@
#!/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/C03080_sbidi_Ortskern_Homes_221025.csv";
$db = FronkDB::singleton(ADDRESSDB_DBHOST, ADDRESSDB_DBUSER, ADDRESSDB_DBPASS, ADDRESSDB_DBNAME);
$log = mfLoghandler::singleton();
$input = fopen($filename, "r");
$hausnummer_extref_trans = [
"25138081" => "25138353",
"25138090" => "25138402",
"25138104" => "25138399",
"25138112" => "25138285",
"25138116" => "25138401",
"25138172" => "25138384",
"25138229" => "25138283",
"25138246" => "25138346",
"25138249" => "25151924",
"25138261" => "25138413",
"25138282" => "25138388",
"25138284" => "25138391",
"25151923" => "25151924",
"25138547" => "25138605",
"25138576" => "25138603",
"25138578" => "25138599",
"25138427" => "25138493",
"25138431" => "25138494",
"25138480" => "25138532",
"25138507" => "25138479"
];
$wohnextref_zusatz = [
"SDIHome_92719443457_1666705401" => "Pfarrheim",
"SDIHome_92718863105_1666705401" => "Ölmühle",
"SDIHome_92718862081_1666705401" => "Ölmühle",
"SDIHome_92718073089_1666705401" => "Hinterhofgebäude",
"SDIHome_92718072065_1666705401" => "Hinterhofgebäude",
"SDIHome_92718071041_1666705401" => "Hinterhofgebäude",
"SDIHome_92718077185_1666705401" => "Lagerhalle und Werkstatt",
"SDIHome_92718076161_1666705401" => "Lagerhalle und Werkstatt",
"SDIHome_92719454721_1666705401" => "Zubau Musikheim",
"SDIHome_92719358977_1666705401" => "Firma",
"SDIHome_92719222273_1666705401" => "Wohnhaus",
"SDIHome_92719249921_1666705401" => "Wohnung",
"SDIBuilding_104216715265_1659686456" => "a",
"SDIHome_92719070465_1666705401" => "Nebengebäude"
];
$i = 0;
while($csv = fgetcsv($input, 0, ";")) {
$i++;
if($i == 1) continue;
if(!trim($csv[0])) {
continue;
}
$zusatz = false;
$wohneinheit_extref = trim($csv[0]);
$hausnummer_extref = trim($csv[1]);
$adresse = trim($csv[7]);
if(array_key_exists($hausnummer_extref, $hausnummer_extref_trans)) {
$hausnummer_extref = $hausnummer_extref_trans[$hausnummer_extref];
}
$hausnummer = ADBHausnummerModel::getFirst(['extref' => $hausnummer_extref]);
if(!$hausnummer) {
if(preg_match('/GST /', $adresse)) continue;
die("Hausnummer $hausnummer_extref nicht gefunden\n");
}
if(array_key_exists($wohneinheit_extref, $wohnextref_zusatz)) {
$zusatz = $wohnextref_zusatz[$wohneinheit_extref];
}
// get last wohneinheit
$num = 0;
$last_we = getLastWohneinheit($hausnummer->id);
if($last_we) {
$num = ($last_we->num) ? $last_we->num : 0;
}
$num++;
$wohneinheit_data = [
'extref' => $wohneinheit_extref,
'hausnummer_id' => $hausnummer->id,
'num' => $num,
'zusatz' => ($zusatz) ? $zusatz : null
];
$wohneinheit = ADBWohneinheitModel::create($wohneinheit_data);
//continue;
//var_dump($wohneinheit);exit;
$wohneinheit->save();
}
function getLastWohneinheit($hausnummer_id) {
global $db;
$sql = "SELECT * FROM Wohneinheit WHERE hausnummer_id = $hausnummer_id ORDER BY num DESC LIMIT 1";
$res = $db->query($sql);
if($db->num_rows($res)) {
return new ADBWohneinheit($db->fetch_object($res));
}
return false;
}

View File

@@ -2,7 +2,7 @@
<?php
//require 'vendor/autoload.php';
require("../config/config.php");
require("../../../config/config.php");
define('FRONKDB_SQLDEBUG',false);
error_reporting(E_ALL & ~(E_NOTICE | E_STRICT | E_DEPRECATED));
@@ -13,7 +13,7 @@ require_once(LIBDIR."/mvcfronk/mfBase/mfBaseController.php");
$me = new User(1);
$filename = BASEDIR."/scripts/import/premstaetten_buildings.csv";
$filename = __DIR__."/import/C03080_sbidi_Ortskern_Locations_221025.csv";
$db = FronkDB::singleton(ADDRESSDB_DBHOST, ADDRESSDB_DBUSER, ADDRESSDB_DBPASS, ADDRESSDB_DBNAME);
$log = mfLoghandler::singleton();
@@ -22,6 +22,11 @@ $input = fopen($filename, "r");
$h_extrefs = [];
$gemeinde_id = 1446;
$netzgebiet = new ADBNetzgebiet(4);
$default_plz = "8522";
$default_freigabe = json_encode(["interest", "provision", "order", "reorder"]);
$i = 0;
while($csv = fgetcsv($input, 0, ";")) {
$i++;
@@ -32,91 +37,96 @@ while($csv = fgetcsv($input, 0, ";")) {
if(!trim($csv[0])) {
continue;
} else {
//echo implode(", ", $csv)."\n";
$gem_kz = trim($csv[17]);
$gem_name = trim($csv[18]);
//$ort_kz = trim($csv[2]);
$plz_name = trim($csv[5]);
$ort_name = trim($csv[6]);
$strasse_hausnummer = trim($csv[4]);
$hausnummer_extref = trim($csv[1]);
if(in_array($hausnummer_extref, $h_extrefs)) {
die("Hausnummer extref doppelt!\n");
}
$h_extrefs[] = $hausnummer_extref;
$lat = str_replace(",",".",trim($csv[7]));
$long = str_replace(",",".",trim($csv[8]));
$netzgebiet_extref = trim($csv[14]);
if(!$netzgebiet_extref) continue;
$netzgebiet = new ADBNetzgebiet();
$netzgebiet->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");
}
}
//echo implode(", ", $csv)."\n";
$gem_kz = trim($csv[6]);
$gem_name = trim($csv[5]);
//$ort_kz = trim($csv[2]);
$plz_name = trim($csv[16]);
if(!$plz_name) {
$plz_name = $default_plz;
}
$ort_name = trim($csv[17]);
$strasse_hausnummer = trim($csv[15]);
$hausnummer_extref = trim($csv[1]);
if(in_array($hausnummer_extref, $h_extrefs)) {
die("Hausnummer extref doppelt!\n");
}
$h_extrefs[] = $hausnummer_extref;
$lat = str_replace(",",".",trim($csv[19]));
$long = str_replace(",",".",trim($csv[18]));
//var_dump($netzgebiet);exit;
$nutzung = trim($csv[7]);
$funktion = trim($csv[20]);
if($nutzung != "Greenfield" && $funktion == "Greenfield") {
$nutzung = "Greenfield";
}
$unit_count = $csv[13];
if(!$unit_count) $unit_count = 1;
$adrcd = false;
$adr = trim($csv[21]);
$adr_parts = explode("-", $adr);
if(count($adr_parts)) {
$adrcd = $adr_parts[0];
}
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 == "Dr.Karl-Renner-Weg") $strasse_name = "Dr.-Karl-Renner-Weg";
if($strasse_name == "Bierbaumer Strasse") $strasse_name = "Bierbaumerstrasse";*/
if(preg_match('/GST(\s+\.)?$/', $strasse_name) && !$adrcd) 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");
}
@@ -128,241 +138,105 @@ while($csv = fgetcsv($input, 0, ";")) {
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";
//if($nutzung == "Greenfield") continue;
//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($adrcd) {
// get Hausnummer to update
$hausnummer = ADBHausnummerModel::getFirst(['adrcd' => $adrcd]);
if(!$hausnummer) {
die("Hausnummer adrcd $adrcd not found\n");
}
/*
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");
*/
//echo "Hausnummer mit adrcd gefunden\n";
} 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();
// 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);
}
if($hausnummer->extref != $hausnummer_extref) {
$hausnummer->extref = $hausnummer_extref;
$sql = "SELECT * FROM view_hausnummer WHERE gemeinde_id = $gemeinde_id 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)) {
// 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 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) die("ortschaft $ortschaft nicht gefunden\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) ? : null,
"gps_lat" => $lat,
"gps_long" => $long,
"freigabe" => $default_freigabe,
];
$hausnummer = ADBHausnummerModel::create($hausnummer_data);
//var_dump($hausnummer);exit;
$hausnummer->save();
continue;
}
$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; }
}
}*/
/*
//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";
$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();
}
}*/
//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();
}
$hausnummer->gps_lat = (float)$lat;
$hausnummer->gps_long = (float)$long;
$hausnummer->freigabe = $default_freigabe;
$hausnummer->save();
//echo "$data->ortschaft, $data->plz, $data->strasse, $data->hausnummer\n";