772 lines
31 KiB
PHP
772 lines
31 KiB
PHP
<?php
|
|
|
|
namespace ADBRimoImport\ADBAddressHelper;
|
|
|
|
use ADBGemeindeModel;
|
|
use ADBHausnummer;
|
|
use ADBHausnummerModel;
|
|
use ADBOrtschaftModel;
|
|
use ADBPlzModel;
|
|
use ADBStrasseModel;
|
|
|
|
class AddressHelper
|
|
{
|
|
private $log;
|
|
private $db;
|
|
private $netzgebiet;
|
|
private $NetworkHelper;
|
|
public $find_address_error;
|
|
|
|
public function __construct($dependencies = [])
|
|
{
|
|
foreach (["log", "db", "netzgebiet"] as $type) {
|
|
if (array_key_exists($type, $dependencies)) {
|
|
$this->$type = $dependencies[$type];
|
|
}
|
|
}
|
|
|
|
// load network helper
|
|
if ($this->netzgebiet && $this->netzgebiet->extref) {
|
|
// get netzgebiet extref and make classname
|
|
$network_extref = $this->netzgebiet->extref;
|
|
$network_id = preg_replace('/[^a-zA-Z0-9]/', '_', $network_extref);
|
|
$network_helper_name = "ADBRimoImport\\ADBAddressHelper\\Network\\Network_$network_id";
|
|
|
|
// find network helper class
|
|
$network_helper_dir = __DIR__ . "/Network";
|
|
$network_helper_filename = "Network-$network_extref";
|
|
|
|
|
|
$dir = opendir($network_helper_dir);
|
|
while ($filename = readdir($dir)) {
|
|
if (preg_match('/^' . $network_helper_filename . '-/', $filename)) {
|
|
require_once($network_helper_dir . "/$filename");
|
|
}
|
|
}
|
|
|
|
if (class_exists($network_helper_name)) {
|
|
$network_helper = new $network_helper_name();
|
|
$this->NetworkHelper = $network_helper;
|
|
}
|
|
|
|
} else {
|
|
die("Netzgebiet hat keine extref (" . $this->netzgebiet->id . ": " . $this->netzgebiet->name . ")");
|
|
}
|
|
|
|
}
|
|
|
|
|
|
public function splitStreetHausnummer($strasse_hausnummer)
|
|
{
|
|
$strasse_name = "";
|
|
$hausnummer_name = "";
|
|
$addresszusatz = "";
|
|
|
|
$m = [];
|
|
// Lantschern GST 1/5
|
|
|
|
if (preg_match('/^(.+)\s+((?:GNR|GST)\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('/^(.+)\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('/^(\D+)\s+(\d+[a-z0-9\/&#._-]*)(?:\s+((?:gesch(?:ae|ä)ft|werkstatt|schmiede|[^ ]*garage|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]);
|
|
}
|
|
} else {
|
|
return false;
|
|
} /* elseif(preg_match('/^(.+)/i', $strasse_hausnummer, $m)) {
|
|
// ignore GST objects
|
|
return false;
|
|
$strasse_name = trim($m[1]);
|
|
}*/
|
|
|
|
// explicitly test for addresszusatz, but only if that regex matches the same street and hausnummer
|
|
if(!$addresszusatz) {
|
|
$test_addresszusatz = "";
|
|
if (preg_match('/^(.+)\s+(\d+[a-z0-9\/&#._-]*)(.+)?/i', $strasse_hausnummer, $m)) {
|
|
$test_strasse_name = trim($m[1]);
|
|
$test_hausnummer_name = trim($m[2]);
|
|
if (array_key_exists(3, $m)) {
|
|
$test_addresszusatz = trim($m[3]);
|
|
}
|
|
|
|
if($test_addresszusatz && $test_hausnummer_name == $hausnummer_name && $test_strasse_name == $strasse_name) {
|
|
$addresszusatz = $test_addresszusatz;
|
|
}
|
|
}
|
|
}
|
|
|
|
return [$strasse_name, $hausnummer_name, $addresszusatz];
|
|
}
|
|
|
|
public function findUpdateAddressFromCitycomLocation($location) {
|
|
$create_address_parts = false;
|
|
$update_freigabe = false;
|
|
$update_address = true;
|
|
if ($this->netzgebiet) {
|
|
$create_address_parts = $this->netzgebiet->getOption("create_address_parts");
|
|
$update_freigabe = $this->netzgebiet->getOption("update_freigabe");
|
|
$option_update_address = $this->netzgebiet->getOption("update_address");
|
|
if($option_update_address !== null) {
|
|
$update_address = $option_update_address;
|
|
}
|
|
}
|
|
|
|
$cc_id = $location->id;
|
|
$strasse_name = $location->street;
|
|
$hausnummer_name = $location->number;
|
|
$plz_name = $location->zip;
|
|
$gem_name = $location->city;
|
|
$stag = $location->stag;
|
|
|
|
if($gem_name == "Raaba") {
|
|
$gem_name = "Raaba-Grambach";
|
|
}
|
|
|
|
$addresszusatz = false;
|
|
|
|
$addr_dbg_str = "gem_name: $gem_name | plz_name: $plz_name | cc-id: $cc_id";
|
|
|
|
$extref = $this->citycomIdToHausnummerExtref($cc_id);
|
|
|
|
// get Gemeinde
|
|
$gemeinde = ADBGemeindeModel::getFirst(["name" => $gem_name]);
|
|
if (!$gemeinde) {
|
|
//$this->log->warning("[EE] Gemeinde $gem_name $gem_kz nicht gefunden ($addr_dbg_str)");
|
|
$this->logFindAddressError("[EE] Gemeinde '$gem_name' nicht gefunden ($addr_dbg_str)");
|
|
return false;
|
|
}
|
|
$gemeinde_id = $gemeinde->id;
|
|
|
|
|
|
// find by Extref
|
|
$hausnummer = ADBHausnummerModel::getFirst(["extref" => $extref]);
|
|
if(!$hausnummer) {
|
|
// find by address
|
|
$hausnummer = $this->findHausnummerByStreet($strasse_name, $hausnummer_name, $gemeinde_id);
|
|
}
|
|
if(!$hausnummer) {
|
|
// hausnummer anlegen
|
|
$plz = ADBPlzModel::getFirst(["gemeinde_id" => $gemeinde_id, "plz" => $plz_name]);
|
|
if (!$plz) {
|
|
$this->logFindAddressError("[EE] PLZ '$plz_name' nicht gefunden ($addr_dbg_str)");
|
|
return false;
|
|
}
|
|
|
|
$strasse = ADBStrasseModel::getFirst(["gemeinde_id" => $gemeinde_id, "name" => $strasse_name]);
|
|
|
|
if (!$strasse && $create_address_parts) {
|
|
$strasse = $this->createStreet($gemeinde_id, $strasse_name);
|
|
}
|
|
|
|
if (!$strasse) {
|
|
$this->logFindAddressError("[EE] Konnte Strasse '$strasse_name' in Gemeinde '$gemeinde_id' nicht finden bzw. anlegen ($addr_dbg_str)");
|
|
return false;
|
|
}
|
|
|
|
$hausnummer_data = [
|
|
"netzgebiet_id" => $this->netzgebiet->id,
|
|
"extref" => $extref,
|
|
"plz_id" => $plz->id,
|
|
"strasse_id" => $strasse->id,
|
|
"hausnummer" => $hausnummer_name,
|
|
"zusatz" => ($addresszusatz) ? $addresszusatz : null,
|
|
];
|
|
$hausnummer = ADBHausnummerModel::create($hausnummer_data);
|
|
//var_dump($hausnummer);exit;
|
|
//echo "----------------------\ncreating hausnummer:\n";
|
|
//print_r($hausnummer);
|
|
if(!$hausnummer->save()) {
|
|
$this->logFindAddressError("[EE] Error saving new Hausnummer ($addr_dbg_str)");
|
|
return false;
|
|
}
|
|
}
|
|
|
|
if(!$hausnummer->id) {
|
|
$this->logFindAddressError("[EE] Unable to find or create Hausnummer ($addr_dbg_str)");
|
|
return false;
|
|
}
|
|
|
|
|
|
$this->checkGemeindeNetzgebiet($gemeinde, $this->netzgebiet);
|
|
|
|
// update hausnummer
|
|
if ($hausnummer->netzgebiet_id != $this->netzgebiet->id) {
|
|
// only if overwriting netzgebiet_id is allowed in old netzgebiet
|
|
$dont_overwrite_netzgbiet = $hausnummer->netzgebiet->getOption("hausnummer_dont_overwrite_netzgebiet");
|
|
if (!$dont_overwrite_netzgbiet) {
|
|
$hausnummer->netzgebiet_id = $this->netzgebiet->id;
|
|
if(!$hausnummer->save()) {
|
|
$this->logFindAddressError("[EE] Error saving Hausnummer ($addr_dbg_str)");
|
|
return false;
|
|
}
|
|
}
|
|
}
|
|
|
|
if($update_address) {
|
|
if ($strasse_name != $hausnummer->strasse->name) {
|
|
$new_strasse = ADBStrasseModel::getFirst(["gemeinde_id" => $gemeinde_id, "name" => $strasse_name]);
|
|
if ($new_strasse) {
|
|
$this->logFindAddressError("[II] Updating Strasse from " . $hausnummer->strasse->name . " to " . $new_strasse->name . " ($addr_dbg_str)");
|
|
$hausnummer->strasse_id = $new_strasse->id;
|
|
if(!$hausnummer->save()) {
|
|
$this->logFindAddressError("[EE] Error saving Hausnummer ($addr_dbg_str)");
|
|
return false;
|
|
}
|
|
} else {
|
|
$this->logFindAddressError("[WW] Cannot update Strasse from " . $hausnummer->strasse->name . " to " . $strasse_name . " because not found ($addr_dbg_str)");
|
|
}
|
|
}
|
|
|
|
if ($hausnummer_name != $hausnummer->hausnummer) {
|
|
$this->logFindAddressError("[II] Updating Hausnummer from " . $hausnummer->hausnummer . " to " . $hausnummer_name . " ($addr_dbg_str)");
|
|
$hausnummer->hausnummer = $hausnummer_name;
|
|
if(!$hausnummer->save()) {
|
|
$this->logFindAddressError("[EE] Error saving Hausnummer ($addr_dbg_str)");
|
|
return false;
|
|
}
|
|
}
|
|
|
|
if ($plz_name != $hausnummer->plz->plz) {
|
|
$new_plz = ADBPlzModel::getFirst(["gemeinde_id" => $gemeinde_id, "plz" => $plz_name]);
|
|
if ($new_plz) {
|
|
$this->logFindAddressError("[II] Updating PLZ from " . $hausnummer->plz->plz . " to " . $new_plz->plz . " ($addr_dbg_str)");
|
|
$hausnummer->plz_id = $new_plz->id;
|
|
if(!$hausnummer->save()) {
|
|
$this->logFindAddressError("[EE] Error saving Hausnummer ($addr_dbg_str)");
|
|
return false;
|
|
}
|
|
} else {
|
|
$this->logFindAddressError("[WW] Cannot update PLZ from " . $hausnummer->plz->plz . " to " . $plz_name . " because not found ($addr_dbg_str)");
|
|
}
|
|
}
|
|
}
|
|
|
|
if ($hausnummer->extref != $extref) {
|
|
$hausnummer->extref = $extref;
|
|
if(!$hausnummer->save()) {
|
|
$this->logFindAddressError("[EE] Error saving Hausnummer ($addr_dbg_str)");
|
|
return false;
|
|
}
|
|
}
|
|
if($hausnummer->vlan_stag != $stag) {
|
|
$hausnummer->vlan_stag = $stag;
|
|
$hausnummer->save();
|
|
}
|
|
|
|
return $hausnummer;
|
|
|
|
}
|
|
|
|
public function citycomIdToHausnummerExtref($id) {
|
|
if(!$id) return false;
|
|
return "citycom-$id";
|
|
}
|
|
|
|
public function hausnummerExtrefToCitycomId($extref) {
|
|
if(!$extref) return false;
|
|
return str_replace("citycom-", "", $extref);
|
|
}
|
|
|
|
public function findUpdateAddressFromRimoBuilding($building)
|
|
{
|
|
$hausnummer = false;
|
|
|
|
//echo "===================================\n";
|
|
|
|
$rimo_id = trim($building->id);
|
|
|
|
if (!$rimo_id) {
|
|
return false;
|
|
}
|
|
|
|
$create_address_parts = false;
|
|
$update_freigabe = false;
|
|
$update_address = true;
|
|
if ($this->netzgebiet) {
|
|
$create_address_parts = $this->netzgebiet->getOption("create_address_parts");
|
|
$update_freigabe = $this->netzgebiet->getOption("update_freigabe");
|
|
$option_update_address = $this->netzgebiet->getOption("update_address");
|
|
if($option_update_address !== null) {
|
|
$update_address = $option_update_address;
|
|
}
|
|
}
|
|
|
|
$name = $this->trimExtra($building->name);
|
|
$strasse_hausnummer = trim($this->trimExtra($building->address->name));
|
|
$split_result = $this->splitStreetHausnummer($strasse_hausnummer);
|
|
|
|
if (!$split_result) {
|
|
$this->logFindAddressError("[EE] Hausnummer nicht gefunden in '$strasse_hausnummer' ($rimo_id)");
|
|
return false;
|
|
}
|
|
|
|
$strasse_name = $this->db->escape($split_result[0]);
|
|
$hausnummer_name = $this->db->escape($split_result[1]);
|
|
$addresszusatz = $this->db->escape($split_result[2]);
|
|
|
|
$gem_kz = $this->db->escape($this->trimExtra($building->municipality->name));
|
|
$gem_name = $this->db->escape($this->trimExtra($building->municipality->userLabel));
|
|
|
|
$ort_name = $this->db->escape($this->trimExtra($building->address->city));
|
|
$plz_name = $this->db->escape($this->trimExtra($building->address->zipCode));
|
|
|
|
$lat = ($building->address->latitude) ? $this->truncateFloat($building->address->latitude, 14) : null;
|
|
$long = ($building->address->longitude) ? $this->truncateFloat($building->address->longitude, 14) : null;
|
|
//$lat = $building->address->latitude;
|
|
//$long = $building->address->longitude;
|
|
$unit_count = $building->homesCount;
|
|
$lot_num = $this->trimExtra($building->address->lotNumber);
|
|
//$fcp_name = false;
|
|
|
|
$adrcd = false;
|
|
$subcd = false;
|
|
$adr = trim($building->foreignId2);
|
|
$adr_parts = explode("-", $adr);
|
|
if (count($adr_parts)) {
|
|
$adrcd = $adr_parts[0];
|
|
if (array_key_exists(1, $adr_parts)) {
|
|
$subcd = $adr_parts[1];
|
|
}
|
|
}
|
|
|
|
if(!is_numeric($subcd)) {
|
|
$subcd = false;
|
|
}
|
|
|
|
$execution_state_id = $building->executionState->name;
|
|
$execution_state_label = $building->executionState->userLabel;
|
|
|
|
$addr_dbg_str = "strasse_hausnummer: $strasse_hausnummer | zusatz: $addresszusatz | gemkz: $gem_kz | gem_name: $gem_name | ort_name: $ort_name | plz_name: $plz_name | adrcd: $adr | $rimo_id";
|
|
|
|
// try to find by rimo_id
|
|
$hausnummer = ADBHausnummerModel::getFirst(["rimo_id" => $rimo_id]);
|
|
|
|
if (!$hausnummer && (!$hausnummer_name || !$gem_name || !$plz_name || !$ort_name || !$strasse_name)) {
|
|
$this->logFindAddressError("[WW] Adressbestandteil fehlt ($addr_dbg_str)");
|
|
return false;
|
|
}
|
|
|
|
// pass variables by ref, so they can be manipulated directly
|
|
if ($this->NetworkHelper) {
|
|
$continue = $this->NetworkHelper->checkAddress([
|
|
"name" => &$name,
|
|
"strasse_name" => &$strasse_name,
|
|
"hausnummer_name" => &$hausnummer_name,
|
|
"addresszusatz" => &$addresszusatz,
|
|
"gem_kz" => &$gem_kz,
|
|
"gem_name" => &$gem_name,
|
|
"ort_name" => &$ort_name,
|
|
"plz_name" => &$plz_name
|
|
]);
|
|
|
|
if (!$continue) {
|
|
echo "[II] ($addr_dbg_str) Wurde aussortiert\n";
|
|
return false;
|
|
}
|
|
}
|
|
|
|
$gemeinde = ADBGemeindeModel::getFirst(["kennziffer" => $gem_kz]);
|
|
if (!$gemeinde) {
|
|
//$this->log->warning("[EE] Gemeinde $gem_name $gem_kz nicht gefunden ($addr_dbg_str)");
|
|
$this->logFindAddressError("[EE] Gemeinde '$gem_name' / '$gem_kz' nicht gefunden ($addr_dbg_str)");
|
|
return false;
|
|
}
|
|
$gemeinde_id = $gemeinde->id;
|
|
|
|
$force_subcd = false;
|
|
$force_no_subcd = false;
|
|
|
|
if ($adrcd && !$hausnummer) {
|
|
// get Hausnummer to update
|
|
if ($subcd > 1) {
|
|
$hausnummer = ADBHausnummerModel::getFirst(['adrcd' => $adrcd, "subcd" => $subcd]);
|
|
// particular adrcd with subcd not found, so needs to be created
|
|
if (!$hausnummer) {
|
|
$force_subcd = true;
|
|
}
|
|
} else {
|
|
$hausnummer = ADBHausnummerModel::getFirst(['adrcd' => $adrcd, "subcd" => "1"]);
|
|
if (!$hausnummer) {
|
|
$hausnummer = ADBHausnummerModel::getFirst(['adrcd' => $adrcd, "subcd" => null]);
|
|
}
|
|
if(!$hausnummer_name) {
|
|
$force_no_subcd = true;
|
|
}
|
|
}
|
|
|
|
if($hausnummer && $hausnummer->rimo_id) {
|
|
$hausnummer = null;
|
|
}
|
|
|
|
/*if(!$hausnummer) {
|
|
//echo "Hausnummer adrcd $adrcd not found\n";
|
|
} else {
|
|
echo "found hausnummer from adrcd $adrcd\n";
|
|
//echo "Hausnummer adrcd $adrcd gefunden!\n";
|
|
}*/
|
|
}
|
|
|
|
if (!$hausnummer) {
|
|
//if(!$force_subcd) {
|
|
$hausnummer = $this->findHausnummerByStreet($strasse_name, $hausnummer_name, $gemeinde_id);
|
|
if($hausnummer && $subcd && $hausnummer->subcd != $subcd) {
|
|
$hausnummer = null;
|
|
}
|
|
if($hausnummer && $adrcd && $hausnummer->adrcd != $adrcd) {
|
|
$hausnummer = null;
|
|
}
|
|
|
|
if($hausnummer && $hausnummer->rimo_id) {
|
|
$hausnummer = null;
|
|
}
|
|
//}
|
|
if (!$hausnummer) {
|
|
// dont create Hausnummer if Canceled in Rimo
|
|
if($execution_state_id == "99") {
|
|
$this->logFindAddressError("[==] Not importing because execution state $execution_state_id ($execution_state_label) ($addr_dbg_str)");
|
|
return false;
|
|
}
|
|
|
|
// hausnummer anlegen
|
|
|
|
$plz = ADBPlzModel::getFirst(["gemeinde_id" => $gemeinde_id, "plz" => $plz_name]);
|
|
if (!$plz) {
|
|
$this->logFindAddressError("[EE] PLZ '$plz_name' nicht gefunden ($addr_dbg_str)");
|
|
return false;
|
|
}
|
|
|
|
$ortschaft = ADBOrtschaftModel::getFirst(["gemeinde_id" => $gemeinde_id, "name" => $ort_name]);
|
|
if (!$ortschaft && $create_address_parts) {
|
|
// anlegen
|
|
$ortschaft = $this->createOrtschaft($gemeinde->id, $ort_name);
|
|
}
|
|
if (!$ortschaft) {
|
|
$this->logFindAddressError("[EE] Ortschaft '$ort_name' nicht gefunden ($addr_dbg_str)");
|
|
return false;
|
|
}
|
|
|
|
|
|
$strasse = ADBStrasseModel::getFirst(["gemeinde_id" => $gemeinde_id, "name" => $strasse_name]);
|
|
if (!$strasse) {
|
|
// try finding strasse with ortschaft prefix
|
|
$prefix = ($ortschaft->name) ? $ortschaft->name : $gemeinde->name;
|
|
|
|
/*if(!$prefix) {
|
|
echo "[EE] ----------- Kein Prefix\n"; // should not happen
|
|
return false;
|
|
}*/
|
|
|
|
if ($prefix && strpos($strasse_name, "$prefix ") === 0) {
|
|
$strasse_name_sansprefix = substr($strasse_name, strlen($prefix) + 1);
|
|
if (!$strasse_name_sansprefix) {
|
|
$this->logFindAddressError("[EE] Fehler beim prefix entfernen von strasse_name $strasse_name");
|
|
return false;
|
|
}
|
|
|
|
$strasse = ADBStrasseModel::getFirst(["gemeinde_id" => $gemeinde_id, "name" => "$strasse_name_sansprefix"]);
|
|
/*if($strasse) {
|
|
echo "Found strasse '$strasse_name' without prefix '$prefix' (gemeinde_id => $gemeinde_id, name => $strasse_name_sansprefix) ($rimo_id)\n";
|
|
}*/
|
|
}
|
|
}
|
|
|
|
if (!$strasse && $create_address_parts) {
|
|
$strasse = $this->createStreet($gemeinde_id, $strasse_name);
|
|
}
|
|
|
|
if (!$strasse) {
|
|
$this->logFindAddressError("[EE] Konnte Strasse '$strasse_name' in Gemeinde '$gemeinde_id' nicht finden bzw. anlegen ($addr_dbg_str)");
|
|
return false;
|
|
}
|
|
|
|
|
|
$hausnummer_data = [
|
|
"netzgebiet_id" => $this->netzgebiet->id,
|
|
"adrcd" => ($adrcd) ? $adrcd : null,
|
|
"subcd" => ($subcd) ? $subcd : null,
|
|
"extref" => $name,
|
|
"ortschaft_id" => $ortschaft->id,
|
|
"plz_id" => $plz->id,
|
|
"strasse_id" => $strasse->id,
|
|
"hausnummer" => $hausnummer_name,
|
|
"zusatz" => ($addresszusatz) ? $addresszusatz : null,
|
|
"grund_nr" => ($lot_num) ? $lot_num : null,
|
|
"gps_lat" => (float)$lat,
|
|
"gps_long" => $long,
|
|
"unit_count" => ($unit_count) ? $unit_count : 1,
|
|
"freigabe" => $this->netzgebiet->freigabe,
|
|
"rimo_id" => $rimo_id,
|
|
//"rimo_fcp_name" => ($fcp_name) ? $fcp_name : null
|
|
];
|
|
$hausnummer = ADBHausnummerModel::create($hausnummer_data);
|
|
//var_dump($hausnummer);exit;
|
|
//echo "----------------------\ncreating hausnummer:\n";
|
|
//print_r($hausnummer);
|
|
if(!$hausnummer->save()) {
|
|
$this->logFindAddressError("[EE] Error saving new Hausnummer ($addr_dbg_str)");
|
|
return false;
|
|
}
|
|
|
|
if($force_subcd) {
|
|
$this->logFindAddressError("[CC] Neues Gebäude erstellt (forced subcd) ($addr_dbg_str)");
|
|
} elseif($force_no_subcd) {
|
|
$this->logFindAddressError("[CC] Neues Gebäude erstellt (forced no subcd) ($addr_dbg_str)");
|
|
} else {
|
|
$this->logFindAddressError("[CC] Neues Gebäude erstellt ($addr_dbg_str)");
|
|
}
|
|
|
|
}
|
|
}
|
|
|
|
if(!$hausnummer->id) {
|
|
$this->logFindAddressError("[EE] Unable to find or create Hausnummer ($addr_dbg_str)");
|
|
return false;
|
|
}
|
|
|
|
|
|
|
|
if($execution_state_id == "99" && !$hausnummer->netzgebiet_id) {
|
|
// don't import Hausnummer if Canceled in Rimo
|
|
echo "== not setting netzgebite_id because execution state $execution_state_id ($execution_state_label)\n";
|
|
return false;
|
|
}
|
|
|
|
$this->checkGemeindeNetzgebiet($gemeinde, $this->netzgebiet);
|
|
|
|
// update hausnummer
|
|
if ($hausnummer->netzgebiet_id != $this->netzgebiet->id) {
|
|
// only if overwriting netzgebiet_id is allowed in old netzgebiet
|
|
$dont_overwrite_netzgbiet = $hausnummer->netzgebiet->getOption("hausnummer_dont_overwrite_netzgebiet");
|
|
if (!$dont_overwrite_netzgbiet) {
|
|
$hausnummer->netzgebiet_id = $this->netzgebiet->id;
|
|
if(!$hausnummer->save()) {
|
|
$this->logFindAddressError("[EE] Error saving Hausnummer ($addr_dbg_str)");
|
|
return false;
|
|
}
|
|
}
|
|
}
|
|
|
|
if($update_address) {
|
|
if ($strasse_name != $hausnummer->strasse->name) {
|
|
$new_strasse = ADBStrasseModel::getFirst(["gemeinde_id" => $gemeinde_id, "name" => $strasse_name]);
|
|
if ($new_strasse) {
|
|
$this->logFindAddressError("[II] Updating Strasse from " . $hausnummer->strasse->name . " to " . $new_strasse->name . " ($addr_dbg_str)");
|
|
$hausnummer->strasse_id = $new_strasse->id;
|
|
if(!$hausnummer->save()) {
|
|
$this->logFindAddressError("[EE] Error saving Hausnummer ($addr_dbg_str)");
|
|
return false;
|
|
}
|
|
} else {
|
|
$this->logFindAddressError("[WW] Cannot update Strasse from " . $hausnummer->strasse->name . " to " . $strasse_name . " because not found ($addr_dbg_str)");
|
|
}
|
|
}
|
|
|
|
if ($hausnummer_name != $hausnummer->hausnummer) {
|
|
$this->logFindAddressError("[II] Updating Hausnummer from " . $hausnummer->hausnummer . " to " . $hausnummer_name . " ($addr_dbg_str)");
|
|
$hausnummer->hausnummer = $hausnummer_name;
|
|
if(!$hausnummer->save()) {
|
|
$this->logFindAddressError("[EE] Error saving Hausnummer ($addr_dbg_str)");
|
|
return false;
|
|
}
|
|
}
|
|
|
|
if ($plz_name != $hausnummer->plz->plz) {
|
|
$new_plz = ADBPlzModel::getFirst(["gemeinde_id" => $gemeinde_id, "plz" => $plz_name]);
|
|
if ($new_plz) {
|
|
$this->logFindAddressError("[II] Updating PLZ from " . $hausnummer->plz->plz . " to " . $new_plz->plz . " ($addr_dbg_str)");
|
|
$hausnummer->plz_id = $new_plz->id;
|
|
if(!$hausnummer->save()) {
|
|
$this->logFindAddressError("[EE] Error saving Hausnummer ($addr_dbg_str)");
|
|
return false;
|
|
}
|
|
} else {
|
|
$this->logFindAddressError("[WW] Cannot update PLZ from " . $hausnummer->plz->plz . " to " . $plz_name . " because not found ($addr_dbg_str)");
|
|
}
|
|
}
|
|
}
|
|
|
|
if ($hausnummer->extref != $name) {
|
|
$hausnummer->extref = $name;
|
|
if(!$hausnummer->save()) {
|
|
$this->logFindAddressError("[EE] Error saving Hausnummer ($addr_dbg_str)");
|
|
return false;
|
|
}
|
|
}
|
|
if ($lat && $long) {
|
|
$hausnummer->gps_lat = (float)$lat;
|
|
$hausnummer->gps_long = (float)$long;
|
|
if(!$hausnummer->save()) {
|
|
$this->logFindAddressError("[EE] Error saving Hausnummer ($addr_dbg_str)");
|
|
return false;
|
|
}
|
|
}
|
|
if ($hausnummer->rimo_id != $rimo_id) {
|
|
$hausnummer->rimo_id = $rimo_id;
|
|
if(!$hausnummer->save()) {
|
|
$this->logFindAddressError("[EE] Error saving Hausnummer ($addr_dbg_str)");
|
|
return false;
|
|
}
|
|
}
|
|
|
|
/*if ($fcp_name && $hausnummer->rimo_fcp_name != $fcp_name) {
|
|
$hausnummer->rimo_fcp_name = $fcp_name;
|
|
if(!$hausnummer->save()) {
|
|
$this->logFindAddressError("[EE] Error saving Hausnummer ($addr_dbg_str)");
|
|
return false;
|
|
}
|
|
}*/
|
|
if($update_freigabe && $hausnummer->freigabe != $this->netzgebiet->freigabe) {
|
|
$hausnummer->freigabe = $this->netzgebiet->freigabe;
|
|
if(!$hausnummer->save()) {
|
|
$this->logFindAddressError("[EE] Error saving Hausnummer ($addr_dbg_str)");
|
|
return false;
|
|
}
|
|
}
|
|
|
|
if(!$hausnummer->oaid && $this->netzgebiet->unit_create_oaid) {
|
|
$hausnummer->getNewOAID();
|
|
}
|
|
|
|
|
|
//echo ">>>>>>>>>>>>>>>>>>>\nupdating hausnummer:\n";
|
|
//print_r($hausnummer);exit;
|
|
return $hausnummer;
|
|
|
|
}
|
|
|
|
|
|
public function findHausnummerByStreet($strasse_name, $hausnummer_name, $gemeinde_id)
|
|
{
|
|
$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 = $this->db->query($sql);
|
|
|
|
if ($this->db->num_rows($res)) {
|
|
// get Hausnummer to update
|
|
//echo "Hausnummer per Suche gefunden\n";
|
|
$data = $this->db->fetch_object($res);
|
|
//echo "found by strasse/hausnummer/gemeinde\n";
|
|
return new ADBHausnummer($data->hausnummer_id);
|
|
}
|
|
return false;
|
|
}
|
|
|
|
private function createStreet($gemeinde_id, $strasse_name)
|
|
{
|
|
if (!$gemeinde_id || !$strasse_name) return null;
|
|
|
|
$strasse = ADBStrasseModel::create([
|
|
"gemeinde_id" => $gemeinde_id,
|
|
"name" => $strasse_name
|
|
]);
|
|
|
|
if (!$strasse->save()) {
|
|
return null;
|
|
}
|
|
return $strasse;
|
|
|
|
}
|
|
|
|
private function createOrtschaft($gemeinde_id, $ortschaft_name)
|
|
{
|
|
if (!$gemeinde_id || !$ortschaft_name) return false;
|
|
|
|
$ortschaft = ADBOrtschaftModel::create([
|
|
"gemeinde_id" => $gemeinde_id,
|
|
"name" => $ortschaft_name
|
|
]);
|
|
|
|
if (!$ortschaft->save()) {
|
|
return false;
|
|
}
|
|
|
|
return $ortschaft;
|
|
}
|
|
|
|
public function createHausnummer($hausnummer_data = [])
|
|
{
|
|
$hausnummer = ADBHausnummerModel::create($hausnummer_data);
|
|
//var_dump($hausnummer);exit;
|
|
return $hausnummer->save();
|
|
}
|
|
|
|
private function checkGemeindeNetzgebiet($gemeinde, $netzgebiet)
|
|
{
|
|
$sql = "SELECT * FROM GemeindeNetzgebiet WHERE gemeinde_id=" . $gemeinde->id . " AND netzgebiet_id=" . $netzgebiet->id;
|
|
$res = $this->db->query($sql);
|
|
if ($this->db->num_rows($res)) {
|
|
return true;
|
|
}
|
|
|
|
$sql = "INSERT INTO GemeindeNetzgebiet (gemeinde_id, netzgebiet_id, `create`, `edit`) VALUES (" . $gemeinde->id . ", " . $netzgebiet->id . ", UNIX_TIMESTAMP(), UNIX_TIMESTAMP())";
|
|
if (!$this->db->query($sql)) {
|
|
die("SQL Query failed: $sql\n " . $this->db->getLastError());
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
public function truncateFloat($number, $digits = 10) {
|
|
if(!$number) return null;
|
|
if(!is_numeric($number)) return null;
|
|
if(strpos($number, ".") === false) return $number;
|
|
|
|
list ($num_part, $dec_part) = explode(".", $number);
|
|
if(strlen($dec_part) > $digits) {
|
|
$dec_part = substr($dec_part, 0, $digits);
|
|
}
|
|
|
|
$new_number_str = (string)$num_part . "." . (string)$dec_part;
|
|
return (float)$new_number_str;
|
|
|
|
}
|
|
|
|
private function logFindAddressError($text)
|
|
{
|
|
$logtext = trim($text);
|
|
$this->find_address_error = $logtext;
|
|
echo $logtext . "\n";
|
|
}
|
|
|
|
public function trimExtra($string) {
|
|
return preg_replace(['/\\\r+/', '/\\\n+/', '/\\\t+/'], "", trim($string));
|
|
}
|
|
} |