Added AdressDB + AddressDB API
This commit is contained in:
Frank Schubert
@@ -1,111 +1,209 @@
|
||||
<?php
|
||||
|
||||
class AddressDB {
|
||||
private $log;
|
||||
private $db;
|
||||
private $log;
|
||||
|
||||
public $data;
|
||||
|
||||
public function __contruct() {
|
||||
|
||||
public function __construct() {
|
||||
$this->db = FronkDB::singleton(ADDRESSDB_DBHOST, ADDRESSDB_DBUSER, ADDRESSDB_DBPASS, ADDRESSDB_DBNAME);
|
||||
$this->log = mfLoghandler::singleton();
|
||||
}
|
||||
|
||||
public function findAddress($search) {
|
||||
if(!is_array($search)) {
|
||||
public function import($input) {
|
||||
if(!$input) {
|
||||
return false;
|
||||
}
|
||||
|
||||
$gemeinde_name = $search['gemeinde_name'];
|
||||
$ort_name = $search['ort_name'];
|
||||
$plz = $search['plz'];
|
||||
$strasse_name = $search['strasse_name'];
|
||||
$hausnummer = $search['hausnummer'];
|
||||
$block = $search['block'];
|
||||
$stiege = $search['stiege'];
|
||||
$stock = $search['stock'];
|
||||
$tuer = $search['tuee'];
|
||||
|
||||
/*
|
||||
if($gemeinde_id < 1 || $strasse_id < 1 || !$hausnummer
|
||||
|| $gemeinde_id > pow(2, 30) || $strasse_id > pow(2, 30) || strlen($hausnummer) > 32) {
|
||||
$this->redirect('Check','',['status' => 'error']);
|
||||
}*/
|
||||
|
||||
$hausnummerMatch = true;
|
||||
|
||||
$gemeinde = new Gemeinde($gemeinde_id);
|
||||
$strasse = new Strasse($strasse_id);
|
||||
|
||||
// try exact hausnummer
|
||||
$res = $this->db()->select("view_adresseProvider", "*", "gemeinde = '".$gemeinde->name."' AND strasse = '".$strasse->name."' AND hausnummer = '$hausnummer'");
|
||||
if(!$this->db()->num_rows($res)) {
|
||||
$hausnummerMatch = false;
|
||||
// check for anschlüsse in the same street
|
||||
$res = $this->db()->select("view_adresseProvider", "*", "gemeinde = '".$gemeinde->name."' AND strasse = '".$strasse->name."'");
|
||||
if(!$this->db()->num_rows($res)) {
|
||||
// XXX: if breitband stmk
|
||||
$this->layout()->setTemplate("Check/Result/Fail");
|
||||
|
||||
// xdsl anzeigen
|
||||
return $this->checkVull($request);
|
||||
if(is_string($input)) {
|
||||
if(!file_exists($input)) {
|
||||
return false;
|
||||
}
|
||||
$file = fopen($input, "r");
|
||||
if(!$file) {
|
||||
return false;
|
||||
}
|
||||
|
||||
$input = $file;
|
||||
}
|
||||
|
||||
// if multiple hausnummern, anschluss in street available, or multiple providers
|
||||
if($this->db()->num_rows($res)) {
|
||||
$addresses = [];
|
||||
$providers = [];
|
||||
$homeProvider = false;
|
||||
$multipleAddress = false;
|
||||
|
||||
while($data = $this->db()->fetch_object($res)) {
|
||||
$addresses[] = new Hausnummer($data->id);
|
||||
if($data->provider_id == HOME_PROVIDER_ID) {
|
||||
$homeProvider = true;
|
||||
}
|
||||
if(!in_array($data->provider, $providers)) {
|
||||
$providers[$data->provider_id] = $data->provider;
|
||||
}
|
||||
if($data->hausnummer != $hausnummer) {
|
||||
$multipleAddress = true;
|
||||
}
|
||||
}
|
||||
|
||||
$pc = new ProductController();
|
||||
|
||||
if($homeProvider && $multipleAddress) {
|
||||
$this->layout()->set("debug", "multi hausnummern, homeprovider");
|
||||
$this->layout()->setTemplate("Check/Result/Street");
|
||||
return true;
|
||||
}
|
||||
if($homeProvider) {
|
||||
$this->layout()->set("debug", "single hausnummer, homeprovider");
|
||||
$this->layout()->setTemplate("Check/Result/Success");
|
||||
$this->layout()->set("productsPrivate", $pc->getProducts(1, "fiber", "privat"));
|
||||
$this->layout()->set("productsBusiness", $pc->getProducts(1, "fiber", "business"));
|
||||
if($data->status == 1) {
|
||||
$this->layout()->set("debug", "single hausnummer, homeprovider, rohr am grundstück");
|
||||
$this->layout()->setTemplate("Check/Result/Street");
|
||||
}
|
||||
return true;
|
||||
}
|
||||
if(!$homeProvider) {
|
||||
$this->layout()->set("providers", $providers);
|
||||
$this->layout()->set("debug", "single hausnummer, partner provider");
|
||||
$this->layout()->setTemplate("Check/Result/SuccessPartner");
|
||||
return true;
|
||||
}
|
||||
|
||||
return true;
|
||||
} /*elseif($this->db()->num_rows($res) == 1 && $hausnummerMatch) {
|
||||
// exactly 1 match
|
||||
$data = $this->db()->fetch_object($res);
|
||||
$address = new Hausnummer($data->id);
|
||||
$this->layout()->set("adresse", $address);
|
||||
$this->layout()->set("debug", "single address, only homeprovider");
|
||||
$this->layout()->setTemplate("Check/Result/Success");
|
||||
return true;
|
||||
}*/
|
||||
if(!is_resource($input)) {
|
||||
return false;
|
||||
}
|
||||
|
||||
|
||||
$gem_kz = "";
|
||||
$gem_name = "";
|
||||
$ort_kz = "";
|
||||
$plz_name = "";
|
||||
$ort_name = "";
|
||||
$strasse_building = "";
|
||||
$strasse = "";
|
||||
$hausnummer_name = "";
|
||||
|
||||
$i = 0;
|
||||
while($csv = fgetcsv($input, 0, ";")) {
|
||||
$i++;
|
||||
if($i == 1) continue;
|
||||
|
||||
//var_dump($csv);
|
||||
|
||||
|
||||
if(trim($csv[0])) {
|
||||
$gem_kz = trim($csv[0]);
|
||||
$gem_name = trim($csv[1]);
|
||||
$ort_kz = trim($csv[2]);
|
||||
$plz_name = trim($csv[3]);
|
||||
$ort_name = trim($csv[4]);
|
||||
$strasse_building = trim($csv[5]);
|
||||
$strasse_name = trim($csv[6]);
|
||||
|
||||
//echo "strasse: $strasse\n";
|
||||
//echo "strasse_building: $strasse_building\n";
|
||||
|
||||
$hausnummer_name = preg_replace('/^'.$strasse_name.'\s+/', "", $strasse_building);
|
||||
//echo "$strasse_name $hausnummer_name\n";
|
||||
}
|
||||
|
||||
$strasse_we = trim($csv[7]);
|
||||
$nutzung = trim($csv[8]);
|
||||
$we_num = trim($csv[11]);
|
||||
|
||||
if(!$strasse_we) {
|
||||
echo "Adresse Wohneinheit fehlt.\n";
|
||||
continue;
|
||||
}
|
||||
|
||||
//echo "strasse_we: $strasse_we\n";
|
||||
if($strasse_building == $strasse_we) {
|
||||
$addresszusatz = "";
|
||||
} else {
|
||||
$addresszusatz = preg_replace('/^'.$strasse_building.'\s+/', "", $strasse_we);
|
||||
}
|
||||
|
||||
|
||||
|
||||
$hausnummer_zusatz = ADBWohneinheit::parseHausnummerZusatz($addresszusatz);
|
||||
//var_dump($hausnummer_zusatz);
|
||||
|
||||
echo "$gem_name $plz_name $ort_name $strasse_name $hausnummer_name ";
|
||||
foreach($hausnummer_zusatz as $key => $value) {
|
||||
if($value) {
|
||||
if($key == "zusatz") {
|
||||
echo $value;
|
||||
continue;
|
||||
}
|
||||
echo ucfirst($key)." ".$value;
|
||||
}
|
||||
}
|
||||
echo " ($nutzung)\n";
|
||||
|
||||
$gemeinde = ADBGemeindeModel::getFirst(['kennziffer' => $gem_kz]);
|
||||
if(!$gemeinde) {
|
||||
$gemeinde = new ADBGemeinde();
|
||||
$gemeinde->kennziffer = $gem_kz;
|
||||
$gemeinde->code = $gem_kz;
|
||||
$gemeinde->name = $gem_name;
|
||||
$gemeinde_id = $gemeinde->save();
|
||||
if(!$gemeinde_id) {
|
||||
|
||||
}
|
||||
}
|
||||
|
||||
$ort = ADBOrtschaftModel::getFirst(['kennziffer' => $ort_kz]);
|
||||
if(!$ort) {
|
||||
$ort = new ADBOrtschaft();
|
||||
$ort->gemeinde_id = $gemeinde->id;
|
||||
$ort->kennziffer = $ort_kz;
|
||||
$ort->name = $ort_name;
|
||||
$ort->plz = $plz_name;
|
||||
$ort_id = $ort->save();
|
||||
if(!$ort_id) {
|
||||
die("Error creating Ortschaft $ort_kz $ort_name!\n");
|
||||
}
|
||||
}
|
||||
|
||||
$plz = ADBPlzModel::getFirst(['gemeinde_id' => $gemeinde->id, 'plz' => $plz_name]);
|
||||
if(!$plz) {
|
||||
$plz = new ADBPlz();
|
||||
$plz->gemeinde_id = $gemeinde->id;
|
||||
$plz->plz = $plz_name;
|
||||
$plz->plzstring = $plz_name;
|
||||
$plz_id = $plz->save();
|
||||
if(!$plz) {
|
||||
die("Error creating Plz $plz_name!\n");
|
||||
}
|
||||
}
|
||||
|
||||
//var_dump($plz);exit;
|
||||
|
||||
$strasse = ADBStrasseModel::getFirst(['gemeinde_id' => $gemeinde->id, 'ortschaft_id' => $ort->id, 'name' => $strasse_name]);
|
||||
if(!$strasse) {
|
||||
$strasse = new ADBStrasse();
|
||||
$strasse->ortschaft_id = $ort->id;
|
||||
$strasse->gemeinde_id = $gemeinde->id;
|
||||
$strasse->name = $strasse_name;
|
||||
$strasse_id = $strasse->save();
|
||||
if(!$strasse_id) {
|
||||
die("error creating Strasse $strasse_name (gemeinde ".$gemeinde->id.", ort ".$ort->id.")");
|
||||
}
|
||||
}
|
||||
|
||||
//var_dump($strasse);exit;
|
||||
|
||||
$hausnummer = ADBHausnummerModel::getFirst(['strasse_id' => $strasse->id, 'hausnummer' => $hausnummer_name]);
|
||||
if(!$hausnummer) {
|
||||
$hausnummer = new ADBHausnummer();
|
||||
$hausnummer->strasse_id = $strasse->id;
|
||||
$hausnummer->hausnummer = $hausnummer_name;
|
||||
$hausnummer_id = $hausnummer->save();
|
||||
if(!$hausnummer_id) {
|
||||
die("error creating Hausnummer $strasse_name $hausnummer_name");
|
||||
}
|
||||
}
|
||||
//var_dump($hausnummer);exit;
|
||||
|
||||
$we_search = [
|
||||
'hausnummer_id' => $hausnummer->id,
|
||||
'num' => $we_num,
|
||||
'block' => $hausnummer_zusatz['block'],
|
||||
'stiege' => $hausnummer_zusatz['stiege'],
|
||||
'stock' => $hausnummer_zusatz['stock'],
|
||||
'tuer' => $hausnummer_zusatz['tuer'],
|
||||
'zusatz' => $hausnummer_zusatz['zusatz'],
|
||||
'nutzung' => $nutzung
|
||||
];
|
||||
|
||||
/*if($hausnummer_name == "12a") {
|
||||
var_dump($we_search);exit;
|
||||
}*/
|
||||
|
||||
$wohneinheit = ADBWohneinheitModel::getFirst($we_search);
|
||||
if(!$wohneinheit) {
|
||||
$wohneinheit = new ADBWohneinheit();
|
||||
$wohneinheit->hausnummer_id = $hausnummer->id;
|
||||
$wohneinheit->num = $we_num;
|
||||
$wohneinheit->block = ($hausnummer_zusatz['block']) ? $hausnummer_zusatz['block'] : null;
|
||||
$wohneinheit->stiege = ($hausnummer_zusatz['stiege']) ? $hausnummer_zusatz['stiege'] : null;
|
||||
$wohneinheit->stock = ($hausnummer_zusatz['stock']) ? $hausnummer_zusatz['stock'] : null;
|
||||
$wohneinheit->tuer = ($hausnummer_zusatz['tuer']) ? $hausnummer_zusatz['tuer'] : null;
|
||||
$wohneinheit->zusatz = ($hausnummer_zusatz['zusatz']) ? $hausnummer_zusatz['zusatz'] : null;
|
||||
$wohneinheit->nutzung = $nutzung;
|
||||
$wohneinheit_id = $wohneinheit->save();
|
||||
if(!$wohneinheit_id) {
|
||||
die("error creating Wohneinheit $strasse_name $hausnummer_name ".implode(", ", $hausnummer_zusatz));
|
||||
}
|
||||
} else {
|
||||
echo "XXXX wohneinheit gibts schon: $strasse_name $hausnummer_name ".implode(", ", $hausnummer_zusatz)."\n\n";
|
||||
}
|
||||
|
||||
|
||||
/*if($i > 10) {
|
||||
exit;
|
||||
}*/
|
||||
}
|
||||
|
||||
return true;
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
Reference in New Issue
Block a user