Added Premsteatten Sued Home import

This commit is contained in:
Frank Schubert
2023-10-11 15:56:08 +02:00
parent cc89a778ef
commit bbfb4f67c1
28 changed files with 1968 additions and 0 deletions
@@ -0,0 +1,310 @@
#!/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_PremNord_20230808.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(2);
$default_plz = "8141";
$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[1])) {
continue;
}
//echo implode(", ", $csv)."\n";
$gem_kz = trim($csv[61]);
$gem_name = trim($csv[60]);
//$ort_kz = trim($csv[2]);
$plz_name = trim($csv[89]);
if(!$plz_name) {
$plz_name = $default_plz;
}
$ort_name = trim($csv[32]);
$strasse_hausnummer = trim($csv[23]);
$hausnummer_extref = trim($csv[65]);
if(in_array($hausnummer_extref, $h_extrefs)) {
die("Hausnummer extref doppelt!\n");
}
$h_extrefs[] = $hausnummer_extref;
$lat = str_replace(",",".",trim($csv[10]));
$long = str_replace(",",".",trim($csv[11]));
//var_dump($netzgebiet);exit;
$nutzung = trim($csv[31]);
//$funktion = trim($csv[6]);
/*if($nutzung != "Greenfield" && $funktion == "Greenfield") {
$nutzung = "Greenfield";
}*/
$unit_count = $csv[79];
if(!$unit_count) $unit_count = 1;
$adrcd = false;
$adr = trim($csv[47]);
$adr_parts = explode("-", $adr);
if(count($adr_parts)) {
$adrcd = $adr_parts[0];
}
if($adr == "5854606-2" || $adr == "5854601-3" || $adr == "5854601-4") {
$adrcd = false;
}
$fcp_name = $csv[50];
$rimo_id = $csv[97];
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($hausnummer_extref == "25158424") $hausnummer_extref = "25010770";
if($hausnummer_extref == "25013230") continue; // ziegelstraße 32 doppelt
if($hausnummer_extref == "25012523") continue; // Hauptstrasse 134 doppelt
if($strasse_name == "Schweizerweg") continue;
if($strasse_name == "Am Seegrund Parz.") continue;
if($strasse_name == "Seering Parz.") {
$strasse_name = "Seering";
$hausnummer_name = "Parz. $hausnummer_name";
}
if($strasse_name == "Dr.Karl-Renner-Weg") $strasse_name = "Dr.-Karl-Renner-Weg";
if($strasse_name == "Doktor-Karl-Renner-Weg") $strasse_name = "Dr.-Karl-Renner-Weg";
if($strasse_name == "Bierbaumer Strasse") $strasse_name = "Bierbaumerstrasse";
if(!$ort_name && $adrcd == "7571478") $ort_name = "Hautzendorf";
if($strasse_name == "GST" && !$adrcd) continue;
if(preg_match('/^L\d+/',$strasse_name) && !$adrcd) continue;
if(!$strasse_name && $nutzung != "Greenfield") {
die("Unbekanntes Adressformat\n");
}
if($ort_name == "Oberpremstaetten") $ort_name = "Oberpremstätten";
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");
}
$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\n");
$ortschaft = ADBOrtschaftModel::getFirst(["gemeinde_id" => $gemeinde_id, "name" => $ort_name]);
if(!$ortschaft) die("$strasse_hausnummer: ortschaft $ort_name nicht gefunden\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();
}
}
//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();
}
}
}
@@ -0,0 +1,295 @@
#!/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__ PremNord_20230526.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(2);
$default_plz = "8141";
$default_freigabe = json_encode(["interest", "provision", "order", "reorder"]);
$hu = 0;
$c = 0;
$w = 0;
$i = 0;
while($csv = fgetcsv($input, 0, ";")) {
$i++;
if($i == 1) continue;
$hausnummer = false;
if(!trim($csv[1])) {
continue;
}
//echo implode(", ", $csv)."\n";
$gem_kz = trim($csv[61]);
$gem_name = trim($csv[60]);
//$ort_kz = trim($csv[2]);
$plz_name = trim($csv[89]);
if(!$plz_name) {
$plz_name = $default_plz;
}
$ort_name = trim($csv[32]);
$strasse_hausnummer = trim($csv[23]);
$hausnummer_extref = trim($csv[65]);
if(in_array($hausnummer_extref, $h_extrefs)) {
die("Hausnummer extref doppelt!\n");
}
$h_extrefs[] = $hausnummer_extref;
$lat = str_replace(",",".",trim($csv[10]));
$long = str_replace(",",".",trim($csv[11]));
//var_dump($netzgebiet);exit;
$nutzung = trim($csv[31]);
//$funktion = trim($csv[6]);
/*if($nutzung != "Greenfield" && $funktion == "Greenfield") {
$nutzung = "Greenfield";
}*/
$unit_count = $csv[79];
if(!$unit_count) $unit_count = 1;
$adrcd = false;
$adr = trim($csv[47]);
$adr_parts = explode("-", $adr);
if(count($adr_parts)) {
$adrcd = $adr_parts[0];
}
if($adr == "5854606-2" || $adr == "5854601-3" || $adr == "5854601-4") {
$adrcd = false;
}
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 == "Doktor-Karl-Renner-Weg") $strasse_name = "Dr.-Karl-Renner-Weg";
if($strasse_name == "Bierbaumer Strasse") $strasse_name = "Bierbaumerstrasse";
if(!$ort_name && $adrcd == "7571478") $ort_name = "Hautzendorf";
if($strasse_name == "GST" && !$adrcd) continue;
if(preg_match('/^L\d+/',$strasse_name) && !$adrcd) continue;
if(!$strasse_name && $nutzung != "Greenfield") {
die("Unbekanntes Adressformat\n");
}
if($ort_name == "Oberpremstaetten") $ort_name = "Oberpremstätten";
if(!$gem_name || !$plz_name || !$ort_name || !$strasse_name) {
die("!! Konnte Adresse nicht parsen (zeile $i: $gem_name || $plz_name || $ort_name || $strasse_name)\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\n");
$ortschaft = ADBOrtschaftModel::getFirst(["gemeinde_id" => $gemeinde_id, "name" => $ort_name]);
if(!$ortschaft) die("$strasse_hausnummer: ortschaft $ort_name nicht gefunden\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,
];
$hausnummer = ADBHausnummerModel::create($hausnummer_data);
//var_dump($hausnummer);exit;
$hausnummer->save();
$c++;
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;
}
$hausnummer->freigabe = $default_freigabe;
$hausnummer->save();
$hu++;
$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();
$w++;
}
}
}
echo "Created $c Haunusmmern, updated $hu Hausnummern, created $w Wohneinheiten\n";
@@ -0,0 +1,187 @@
#!/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/SDIHome__Homes_PremNord_20231002.csv";
$db = FronkDB::singleton(ADDRESSDB_DBHOST, ADDRESSDB_DBUSER, ADDRESSDB_DBPASS, ADDRESSDB_DBNAME);
$log = mfLoghandler::singleton();
$input = fopen($filename, "r");
$hausnummer_extref_trans = [
"25010593" => "25012203",
"25010595" => "25012618",
"25011458" => "25012618",
"25010631" => "25011862",
"25010646" => "25137021",
"25012279" => "25012281",
"25012280" => "25012281",
"25010665" => "25012281",
"25010712" => "25011459",
"25010755" => "25013165",
"25012153" => "25012159",
"25012155" => "25012159",
"25012157" => "25012159",
"25012262" => "25012676",
];
$hausnummer_extref_ignore = [
"25010649",
"25012523"
];
$wohnextref_zusatz = [
"SDIHome_92719443457_1666705401" => "Pfarrheim",
];
$current_wohneinheit_nums = [];
$i = 0;
while($csv = fgetcsv($input, 0, ";")) {
$i++;
if($i == 1) continue;
if(!trim($csv[1])) {
continue;
}
$zusatz = false;
$wohneinheit_extref = trim($csv[37]);
$hausnummer_extref = trim($csv[35]);
$building_string = trim($csv[25]);
$adresse = "";
$m = [];
if(preg_match('/\[([^\]]+)\]/', $building_string, $m)) {
$adresse = $m[1];
}
if(array_key_exists($hausnummer_extref, $hausnummer_extref_trans)) {
$hausnummer_extref = $hausnummer_extref_trans[$hausnummer_extref];
}
if(in_array($hausnummer_extref, $hausnummer_extref_ignore)) continue;
$hausnummer = ADBHausnummerModel::getFirst(['extref' => $hausnummer_extref]);
if(!$hausnummer) {
if(preg_match('/(GST |^L\d)/', $adresse)) continue;
if($adresse) {
die("Hausnummer $hausnummer_extref nicht gefunden\n");
} else {
continue;
}
}
if(array_key_exists($wohneinheit_extref, $wohnextref_zusatz)) {
$zusatz = $wohnextref_zusatz[$wohneinheit_extref];
}
if(array_key_exists($hausnummer_extref, $current_wohneinheit_nums)) {
$current_wohneinheit_nums[$hausnummer_extref]++;
} else {
$current_wohneinheit_nums[$hausnummer_extref] = 1;
}
// get last wohneinheit
$num = $current_wohneinheit_nums[$hausnummer_extref];
$unit_count = ADBWohneinheitModel::count(["hausnummer_id" => $hausnummer->id]);
if($num > $unit_count) {
$last_we = getLastWohneinheit($hausnummer->id);
if($last_we) {
$num = ($last_we->num) ? $last_we->num + 1 : 1;
}
//var_dump($current_wohneinheit_nums[$hausnummer_extref]);
$wohneinheit_data = [
'extref' => $wohneinheit_extref,
'hausnummer_id' => $hausnummer->id,
'num' => $num,
'zusatz' => ($zusatz) ? $zusatz : null
];
$wohneinheit = ADBWohneinheitModel::create($wohneinheit_data);
$wohneinheit->save();
//echo "+ ".$wohneinheit->extref."\n";
} else {
$wohneinheit = ADBWohneinheitModel::getFirst(['hausnummer_id' => $hausnummer->id, "extref" => $wohneinheit_extref]);
if($wohneinheit) continue; // unit with extref exists so continue
if($hausnummer_extref == "25012281") {
$zusatz = "Haus ".(ceil($num / 12))." Top $num";
//echo "$num: $zusatz\n";
$wohneinheit = ADBWohneinheitModel::getFirst(['hausnummer_id' => $hausnummer->id, "zusatz" => $zusatz]);
if(!$wohneinheit) {
echo "top not found\n";
}
}
if($hausnummer_extref == "25012159") {
$m = [];
if(preg_match('/^Hauptstr.+Stg (\d+)/',$adresse, $m)) {
$stiege = $m[1];
if(!$stiege) die("Stiege nicht gefunden\n");
$wohneinheit = ADBWohneinheitModel::getFirst(['hausnummer_id' => $hausnummer->id, "zusatz" => "Stg. $stiege %", "extref" => null]);
$wohneinheit->stiege = $stiege;
} else {
die("no match: $adresse\n");
}
}
if(!$wohneinheit) {
// get unit with num
$wohneinheit = ADBWohneinheitModel::getFirst(['hausnummer_id' => $hausnummer->id, "num" => $num]);
}
// else get unit without num nor extref
if(!$wohneinheit) {
$wohneinheit = ADBWohneinheitModel::getFirst(['hausnummer_id' => $hausnummer->id, "num" => null, "extref" => null]);
}
}
if(!$wohneinheit) {
echo "Keine passende Wohneinheit gefunden für $hausnummer_extref ($num)\n";
exit;
}
if(!$wohneinheit->extref) {
$wohneinheit->extref = $wohneinheit_extref;
//var_dump("UPDATE UNIT",$wohneinheit);exit;
//echo "u ".$wohneinheit->extref."\n";
$wohneinheit->save();
//exit;
}
//continue;
//var_dump($wohneinheit);exit;
}
echo "\n";
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;
}
@@ -0,0 +1,26 @@
#!/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");
$netzgebiet_name_main = "Liezen";
$freigabe_default = json_encode(["interest", "provision", "order", "reorder"]);
$me = new User(1);
$log = mfLoghandler::singleton();
$premstaetten_netzgebiete = [];
foreach(PreorderModel::search([]) as $preorder) {
}
+29
View File
@@ -0,0 +1,29 @@
#!/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);
foreach(ADBHausnummerModel::search(['netzgebiet_id' => [1,2]]) as $hausnummer) {
foreach(['interest','provision','order','reorder'] as $type) {
$freigabe = ADBHausnummerFreigabeModel::getFirst(['hausnummer_id' => $hausnummer->id, 'freigabe' => $type]);
if(!$freigabe) {
$freigabe = ADBHausnummerFreigabeModel::create([
'hausnummer_id' => $hausnummer->id,
'freigabe' => $type
]);
if(!$freigabe->save()) {
die("Error saving HausnummerFreigabe (".$hausnummer->id.", $type)\n");
}
}
}
}
@@ -0,0 +1,96 @@
#!/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 = BASEDIR."/scripts/import/premstaetten_homes.csv";
$db = FronkDB::singleton(ADDRESSDB_DBHOST, ADDRESSDB_DBUSER, ADDRESSDB_DBPASS, ADDRESSDB_DBNAME);
$log = mfLoghandler::singleton();
$input = fopen($filename, "r");
$h_extrefs = [];
$updated = 0;
$current_home_count = 0;
$current_building_extref = "";
$i = 0;
while($csv = fgetcsv($input, 0, ";")) {
$i++;
if($i == 1) continue;
if(!trim($csv[0])) {
continue;
} else {
$building_extref = $csv[1];
$wohneinheit_extref = $csv[0];
if($current_building_extref != $building_extref) {
// check how many homes we imported for this building
$hausnummer = ADBHausnummerModel::getFirst(['extref' => $current_building_extref]);
if($hausnummer) {
$units = ADBWohneinheitModel::search(['hausnummer_id' => $hausnummer->id]);
if(count($units) < $current_home_count) {
echo "Weniger Homes vorhanden, als importiert (hausnummer extref: ".$hausnummer->extref.") building_extref $building_extref\n";
}
}
$current_home_count = 0;
}
$current_home_count++;
$current_building_extref = $building_extref;
$hausnummer = ADBHausnummerModel::getFirst(['extref' => $building_extref]);
if(!$hausnummer) {
echo "Hausnummer nicht gefunden: $building_extref\n";
continue;
}
$existing_units = ADBWohneinheitModel::search(['hausnummer_id' => $hausnummer->id]);
$current_unit = $existing_units[$current_home_count -1];
if(!$current_unit) {
// transmission stations may not have been created
//echo "unit for $wohneinheit_extref not found\n";
continue;
}
$current_unit->extref = $wohneinheit_extref;
$current_unit->save();
$updated++;
/*if($current_home_count > count($existing_units)) {
echo "creating unit $wohneinheit_extref (hausnummer $building_extref)\n";
$unit_data = [
'extref' => $wohneinheit_extref,
'hausnummer_id' => $hausnummer->id,
'num' => $current_home_count,
'tuer' => $current_home_count,
'nutzung' => "Wohnung"
];
$unit = ADBWohneinheitModel::create($unit_data);
//var_dump($unit);exit;
//if(!$unit->save()) {
// die("Error saving new unit\n");
//}
}*/
}
}
echo "Updated $updated units\n";
+19
View File
@@ -0,0 +1,19 @@
#!/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 = BASEDIR."/scripts/import/agwr_premstaetten_sample_v2.csv";
$adb = new AddressDB();
$adb->import($filename);
+370
View File
@@ -0,0 +1,370 @@
#!/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 = BASEDIR."/scripts/import/premstaetten_buildings.csv";
$db = FronkDB::singleton(ADDRESSDB_DBHOST, ADDRESSDB_DBUSER, ADDRESSDB_DBPASS, ADDRESSDB_DBNAME);
$log = mfLoghandler::singleton();
$input = fopen($filename, "r");
$h_extrefs = [];
$i = 0;
while($csv = fgetcsv($input, 0, ";")) {
$i++;
if($i == 1) continue;
$hausnummer = false;
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");
}
}
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";
}
@@ -0,0 +1,356 @@
#!/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");
$freigabe_default = json_encode(["interest", "provision", "order", "reorder"]);
$me = new User(1);
$folder = __DIR__."/import/";
$csvname = "SDIBuilding__Locations_FTTx__Nord-update-2023-03-29.csv";
$filename = $folder.$csvname;
$db = FronkDB::singleton(ADDRESSDB_DBHOST, ADDRESSDB_DBUSER, ADDRESSDB_DBPASS, ADDRESSDB_DBNAME);
$log = mfLoghandler::singleton();
$input = fopen($filename, "r");
$h_extrefs = [];
$c = 0;
$l = 0;
$u = 0;
$w = 0;
while($csv = fgetcsv($input, 0, ";")) {
$l++;
if($l == 1) continue;
$hausnummer = false;
if(!trim($csv[0])) {
continue;
}
$hausnummer_extref = trim($csv[64]);
$adrcd_subcd = trim($csv[46]);
$netzgebiet_extref = trim($csv[54]);
$grund_nr = trim($csv[73]);
$lat = str_replace(",",".",trim($csv[9]));
$long = str_replace(",",".",trim($csv[10]));
//$rollout_time = trim($csv[17]);
//$rollout_info = trim($csv[18]);
//$freigabe = trim($csv[19])
$unit_count = trim($csv[78]);
$gdaeigenschaft = trim($csv[66]);
$fcp_name = trim($csv[49]);
$execution_state = trim($csv[8]);
$btype = trim($csv[30]);
if(!$netzgebiet_extref) {
continue;
}
$netzgebiet = ADBNetzgebietModel::getFirst(["extref" => $netzgebiet_extref]);
if(!$netzgebiet) {
echo "netzgebiet not found\n";
exit;
}
if($execution_state == "Canceled") {
continue;
}
if($btype == "Greenfield") {
continue;
}
$adrcd = false;
if($adrcd_subcd) {
$adrparts = explode("-", $adrcd_subcd);
$adrcd = $adrparts[0];
}
$gem_kz = trim($csv[60]);
$gem_name = trim($csv[59]);
$plz_string = trim($csv[88]);
$ort_name = trim($csv[31]);
$strasse_hausnummer = trim($csv[22]);
$strasse_name = "";
$hausnummer_name = "";
if(!$strasse_hausnummer) {
continue;
}
$m = [];
if(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]);
}
}
if($strasse_name == "Dr.Karl-Renner-Weg") $strasse_name = "Dr.-Karl-Renner-Weg";
if($strasse_name == "Doktor-Karl-Renner-Weg") $strasse_name = "Dr.-Karl-Renner-Weg";
/*
$adrcd = trim($csv[0]);
$gem_kz = trim($csv[2]);
$gem_name = trim($csv[3]);
$ort_kz = trim($csv[5]);
$plz_string = trim($csv[4]);
$ort_name = trim($csv[6]);
$skz = trim($csv[7]);
$strasse_name = trim($csv[8]);
$hausnummer_string = trim($csv[9]);
$hausnummer_extref = trim($csv[0]);
if(in_array($hausnummer_extref, $h_extrefs)) {
die("Hausnummer extref doppelt! $hausnummer_extref\n");
}
$h_extrefs[] = $hausnummer_extref;
*/
//$lat = str_replace(",",".",trim($csv[7]));
//$long = str_replace(",",".",trim($csv[8]));
/*if(!$adrcd) {
continue;
}*/
if($adrcd && !is_numeric($adrcd)) {
echo "Invalid adrcd ($adrcd)\n";
continue;
}
if(!$hausnummer_extref) {
die("!!! Keine Hausnummer Extref\n");
}
if($hausnummer_extref == "25012262") {
$unit_count = 45;
}
if($hausnummer_extref == "25012676") {
continue;
}
if($hausnummer_extref == "25012153" || $hausnummer_extref == "25012155" || $hausnummer_extref == "25012157") {
continue;
}
if($hausnummer_extref == "25012159") {
$unit_count = 61;
}
if($hausnummer_extref == "25010649") {
continue;
}
if($hausnummer_extref == "25010723" || $hausnummer_extref == "25010816") {
continue;
}
$existing_hausnummer = ADBHausnummerModel::getFirst(["extref" => $hausnummer_extref]);
if($adrcd && !$existing_hausnummer) {
$existing_hausnummer = ADBHausnummerModel::getFirst(["adrcd" => $adrcd]);
}
if(!$existing_hausnummer) {
//echo "$hausnummer_extref not found $strasse_name $hausnummer_name\n";
//continue;
// find hausnummer
//echo "$strasse_name $hausnummer_name\n";
if($strasse_name == "Toepferring") $strasse_name = "Töpferring";
if($strasse_name == "Foehrenweg") $strasse_name = "Föhrenweg";
$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'";
$res = $db->query($sql);
if($db->num_rows($res)) {
$data = $db->fetch_object($res);
$existing_hausnummer = new ADBHausnummer($data->hausnummer_id);
if($existing_hausnummer->netzgebiet_id != $netzgebiet->id) {
echo "Updating Netzgebiet from ".$existing_hausnummer->netzgebiet_id." to ".$netzgebiet->id."\n";
}
$existing_hausnummer->netzgebiet_id = $netzgebiet->id;
if(!$existing_hausnummer->adrcd) {
$existing_hausnummer->adrcd = $adrcd;
}
$existing_hausnummer->extref = $hausnummer_extref;
$existing_hausnummer->grund_nr = $grund_nr;
$existing_hausnummer->gdaeigenschaft = $gdaeigenschaft;
$existing_hausnummer->rimo_fcp_name = $fcp_name;
if(!$existing_hausnummer->oaid) {
$existing_hausnummer->oaid = $existing_hausnummer->getNewOAID();
}
$existing_hausnummer->save();
$u++;
} else {
echo "Address not found (straße: $strasse_name ($strasse_hausnummer), hausnummer: $hausnummer_name, adrcd: $adrcd, extref: $hausnummer_extref, unit_count: $unit_count)\n";
// create new adress
$gemeinde = ADBGemeindeModel::getFirst(['kennziffer' => $gem_kz]);
if(!$gemeinde) {
die("Gemeinde nicht gefunden\n");
}
$ort = ADBOrtschaftModel::getFirst(['name' => $ort_name, "gemeinde_id" => $gemeinde->id]);
if(!$ort) {
die("Ort $ort_name nicht gefunden\n");
}
$plz = ADBPlzModel::getFirst(['plz' => $plz_string, 'gemeinde_id' => $gemeinde->id]);
if(!$plz) {
die("PLZ nicht gefunden");
}
$strasse = ADBStrasseModel::getFirst(['gemeinde_id' => $gemeinde->id, 'name' => $strasse_name]);
if(!$strasse) {
if(preg_match('/^(GST\s|L\d+\s)/', $strasse_hausnummer)) {
continue;
}
die("Strase nicht gefunden\n");
}
$hausnummer_data = [
"netzgebiet_id" => $netzgebiet->id,
"extref" => $hausnummer_extref,
"ortschaft_id" => $ort->id,
"plz_id" => $plz->id,
"strasse_id" => $strasse->id,
"hausnummer" => $hausnummer_name,
"zusatz" => ($addresszusatz) ? : null,
"gps_lat" => $lat,
"gps_long" => $long,
"grund_nr" => $grund_nr,
"gdaeigenschaft" => $gdaeigenschaft,
"rimo_fcp_name" => $fcp_name,
"freigabe" => $freigabe_default,
];
$existing_hausnummer = ADBHausnummerModel::create($hausnummer_data);
if(!$existing_hausnummer->oaid) {
$existing_hausnummer->oaid = $existing_hausnummer->getNewOAID();
}
$existing_hausnummer->save();
$c++;
}
} else {
// found hausnummer
if($existing_hausnummer->netzgebiet_id != $netzgebiet->id) {
echo "Updating Netzgebiet from ".$existing_hausnummer->netzgebiet_id." to ".$netzgebiet->id."\n";
}
$existing_hausnummer->netzgebiet_id = $netzgebiet->id;
if(!$existing_hausnummer->adrcd) {
$existing_hausnummer->adrcd = $adrcd;
}
$existing_hausnummer->extref = $hausnummer_extref;
$existing_hausnummer->grund_nr = $grund_nr;
$existing_hausnummer->gdaeigenschaft = $gdaeigenschaft;
$existing_hausnummer->rimo_fcp_name = $fcp_name;
if(!$existing_hausnummer->oaid) {
$existing_hausnummer->oaid = $existing_hausnummer->getNewOAID();
}
$existing_hausnummer->save();
$u++;
}
//continue;
// add new units
$existing_units_count = ADBWohneinheitModel::count(['hausnummer_id' => $existing_hausnummer->id]);
if($existing_units_count != $unit_count) {
/*if(($existing_units_count - $unit_count) > 1) {
echo "========================================================================\n";
echo "=============== [".$existing_hausnummer->id."] Need to delete ".($existing_units_count - $unit_count)." units\n";
echo "========================================================================\n";
}*/
if($existing_units_count < $unit_count) {
echo "=============== Adding ".($unit_count - $existing_units_count)." units\n";
$new_units_count = $unit_count - $existing_units_count;
$last_unit_num = 0;
foreach(ADBWohneinheitModel::search(['hausnummer_id' => $existing_hausnummer->id]) as $tmp_unit) {
if($tmp_unit->num > $last_unit_num) {
$last_unit_num = $tmp_unit->num;
}
}
// create wohneinheiten
for($i = 1; $i <= $new_units_count; $i++) {
$num = $last_unit_num + $i;
//echo "$existing_units_count create wohneinheit $num\n";
$unit_data = [
'hausnummer_id' => $existing_hausnummer->id,
'num' => $num,
];
$wohneinheit = ADBWohneinheitModel::create($unit_data);
$wohneinheit_id = $wohneinheit->save();
if(!$wohneinheit_id) {
die("Cannot save Wohneinheit\n");
}
$wohneinheit->oaid = $wohneinheit->getNewOAID();
if(!$wohneinheit->oaid) {
die("Error generating OAID for wohneinheit ".$wohneinheit->id);
}
//var_dump($wohneinheit);
$wohneinheit->save();
$w++;
}
}
}
//echo "$hausnummer_extref: $adrcd, $netzgebiet_extref, $grund_nr, $unit_count, $gdaeigenschaft\n";
}
echo "$c Buildings created, $u Buildings updated, $w Wohneinheiten angelegt\n";
@@ -0,0 +1,287 @@
#!/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");
$freigabe_default = json_encode(["interest", "provision", "order", "reorder"]);
$me = new User(1);
$folder = __DIR__."/import/";
$csvname = "SDIBuilding__Locations__FTTx_premstaetten_2023-03-07.csv";
$filename = $folder.$csvname;
$db = FronkDB::singleton(ADDRESSDB_DBHOST, ADDRESSDB_DBUSER, ADDRESSDB_DBPASS, ADDRESSDB_DBNAME);
$log = mfLoghandler::singleton();
$input = fopen($filename, "r");
$h_extrefs = [];
$l = 0;
$u = 0;
while($csv = fgetcsv($input, 0, ";")) {
$l++;
if($l == 1) continue;
$hausnummer = false;
if(!trim($csv[0])) {
continue;
}
$hausnummer_extref = trim($csv[64]);
$adrcd_subcd = trim($csv[46]);
$netzgebiet_extref = trim($csv[54]);
$grund_nr = trim($csv[73]);
//gps_long, gps_lat
//$rollout_time = trim($csv[17]);
//$rollout_info = trim($csv[18]);
//$freigabe = trim($csv[19])
$unit_count = trim($csv[78]);
$gdaeigenschaft = trim($csv[66]);
$fcp_name = trim($csv[49]);
$execution_state = trim($csv[8]);
$btype = trim($csv[30]);
if(!$netzgebiet_extref) {
continue;
}
$netzgebiet = ADBNetzgebietModel::getFirst(["extref" => $netzgebiet_extref]);
if(!$netzgebiet) {
echo "netzgebiet not found\n";
exit;
}
if($execution_state == "Canceled") {
continue;
}
if($btype == "Greenfield") {
continue;
}
$adrcd = false;
if($adrcd_subcd) {
$adrparts = explode("-", $adrcd_subcd);
$adrcd = $adrparts[0];
}
$gem_name = trim($csv[59]);
$plz_string = trim($csv[88]);
$ort_name = trim($csv[31]);
$strasse_hausnummer = trim($csv[22]);
$strasse_name = "";
$hausnummer_name = "";
$m = [];
if(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]);
}
}
/*
$adrcd = trim($csv[0]);
$gem_kz = trim($csv[2]);
$gem_name = trim($csv[3]);
$ort_kz = trim($csv[5]);
$plz_string = trim($csv[4]);
$ort_name = trim($csv[6]);
$skz = trim($csv[7]);
$strasse_name = trim($csv[8]);
$hausnummer_string = trim($csv[9]);
$hausnummer_extref = trim($csv[0]);
if(in_array($hausnummer_extref, $h_extrefs)) {
die("Hausnummer extref doppelt! $hausnummer_extref\n");
}
$h_extrefs[] = $hausnummer_extref;
*/
//$lat = str_replace(",",".",trim($csv[7]));
//$long = str_replace(",",".",trim($csv[8]));
if(!$adrcd) {
continue;
}
if(!is_numeric($adrcd)) {
echo "Invalid adrcd ($adrcd)\n";
continue;
}
if(!$hausnummer_extref) {
die("!!! Keine Hausnummer Extref\n");
}
if($hausnummer_extref == "25012262") {
$unit_count = 45;
}
if($hausnummer_extref == "25012676") {
continue;
}
if($hausnummer_extref == "25012153" || $hausnummer_extref == "25012155" || $hausnummer_extref == "25012157") {
continue;
}
if($hausnummer_extref == "25012159") {
$unit_count = 61;
}
if($hausnummer_extref == "25010649") {
continue;
}
if($hausnummer_extref == "25010723" || $hausnummer_extref == "25010816") {
continue;
}
$existing_hausnummer = ADBHausnummerModel::getFirst(["extref" => $hausnummer_extref]);
if(!$existing_hausnummer) {
$existing_hausnummer = ADBHausnummerModel::getFirst(["adrcd" => $adrcd]);
}
if(!$existing_hausnummer) {
//echo "$hausnummer_extref not found $strasse_name $hausnummer_name\n";
//continue;
// find hausnummer
//echo "$strasse_name $hausnummer_name\n";
if($strasse_name == "Toepferring") $strasse_name = "Töpferring";
if($strasse_name == "Foehrenweg") $strasse_name = "Föhrenweg";
$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'";
$res = $db->query($sql);
if($db->num_rows($res)) {
$data = $db->fetch_object($res);
$existing_hausnummer = new ADBHausnummer($data->hausnummer_id);
$existing_hausnummer->netzgebiet_id = $netzgebiet->id;
if(!$existing_hausnummer->adrcd) {
$existing_hausnummer->adrcd = $adrcd;
}
$existing_hausnummer->extref = $hausnummer_extref;
$existing_hausnummer->grund_nr = $grund_nr;
$existing_hausnummer->gdaeigenschaft = $gdaeigenschaft;
$existing_hausnummer->rimo_fcp_name = $fcp_name;
if(!$existing_hausnummer->oaid) {
$existing_hausnummer->oaid = $existing_hausnummer->getNewOAID();
}
$existing_hausnummer->save();
} else {
echo "Address not found (straße: $strasse_name, hausnummer: $hausnummer_name, adrcd: $adrcd, extref: $hausnummer_extref, unit_count: $unit_count)\n";
}
} else {
// found hausnummer
$existing_hausnummer->netzgebiet_id = $netzgebiet->id;
if(!$existing_hausnummer->adrcd) {
$existing_hausnummer->adrcd = $adrcd;
}
$existing_hausnummer->extref = $hausnummer_extref;
$existing_hausnummer->grund_nr = $grund_nr;
$existing_hausnummer->gdaeigenschaft = $gdaeigenschaft;
$existing_hausnummer->rimo_fcp_name = $fcp_name;
if(!$existing_hausnummer->oaid) {
$existing_hausnummer->oaid = $existing_hausnummer->getNewOAID();
}
$existing_hausnummer->save();
}
continue;
// add new units
$existing_units_count = ADBWohneinheitModel::count(['hausnummer_id' => $existing_hausnummer->id]);
if($existing_units_count != $unit_count) {
/*if(($existing_units_count - $unit_count) > 1) {
echo "========================================================================\n";
echo "=============== [".$existing_hausnummer->id."] Need to delete ".($existing_units_count - $unit_count)." units\n";
echo "========================================================================\n";
}*/
if($existing_units_count < $unit_count) {
echo "=============== Adding ".($unit_count - $existing_units_count)." units\n";
$new_units_count = $unit_count - $existing_units_count;
$last_unit_num = 0;
foreach(ADBWohneinheitModel::search(['hausnummer_id' => $existing_hausnummer->id]) as $tmp_unit) {
if($tmp_unit->num > $last_unit_num) {
$last_unit_num = $tmp_unit->num;
}
}
// create wohneinheiten
for($i = 1; $i <= $new_units_count; $i++) {
$num = $last_unit_num + $i;
//echo "$existing_units_count create wohneinheit $num\n";
$unit_data = [
'hausnummer_id' => $existing_hausnummer->id,
'num' => $num,
];
$wohneinheit = ADBWohneinheitModel::create($unit_data);
$wohneinheit_id = $wohneinheit->save();
if(!$wohneinheit_id) {
die("Cannot save Wohneinheit\n");
}
$wohneinheit->oaid = $wohneinheit->getNewOAID();
if(!$wohneinheit->oaid) {
die("Error generating OAID for wohneinheit ".$wohneinheit->id);
}
//var_dump($wohneinheit);
$wohneinheit->save();
$w++;
}
}
}
//echo "$hausnummer_extref: $adrcd, $netzgebiet_extref, $grund_nr, $unit_count, $gdaeigenschaft\n";
}
File diff suppressed because it is too large Load Diff
File diff suppressed because it is too large Load Diff
File diff suppressed because it is too large Load Diff
File diff suppressed because it is too large Load Diff
File diff suppressed because it is too large Load Diff
File diff suppressed because it is too large Load Diff
File diff suppressed because it is too large Load Diff
File diff suppressed because it is too large Load Diff
File diff suppressed because it is too large Load Diff
File diff suppressed because it is too large Load Diff