thetool/scripts/addressdb/lieboch/import_from_gemeinde_gwr.php

#!/usr/bin/php
<?php

//require 'vendor/autoload.php';
require("../../../config/config.php");

define('FRONKDB_SQLDEBUG',false);
error_reporting(E_ALL & ~(E_NOTICE | E_STRICT | E_DEPRECATED));

require_once(LIBDIR."/mvcfronk/mfRouter/mfRouter.php");
require_once(LIBDIR."/mvcfronk/mfBase/mfBaseModel.php");
require_once(LIBDIR."/mvcfronk/mfBase/mfBaseController.php");


$freigabe_default = json_encode(["interest", "provision", "order", "reorder"]);

$me = new User(1);

$folder = __DIR__."/import/";
$csvname = "GWR_Lieboch_gesamt.csv";
$filename = $folder.$csvname;

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

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

$h_extrefs = [];


$gem_kz = "";
$gem_name = "";
$ort_kz = "";
$plz_name = "";
$ort_name = "";
$strasse_hausnummer = "";
$strasse_building = "";
$strasse_name = "";
$strasse = "";
$addresszusatz = "";
$adrcd = "";
$hausnummer_name = "";
$hausnummer_extref = "";

// netzgebiet Lieboch
$netzgebiet = new ADBNetzgebiet(30);

$l = 0;
$u = 0;
$i = 0;
while($csv = fgetcsv($input, 0, ",")) {
  $i++;
  if($i == 1) continue;

  //var_dump($csv);exit;
  

  if(trim($csv[0])) {
    $gem_kz = trim($csv[0]);
    $gem_name = trim($csv[1]);
    $ort_kz = "14994";
    $plz_name = "8501";
    $ort_name = "Lieboch";
    $strasse_hausnummer = trim($csv[4]);
    //$strasse_name = trim($csv[13]);
    $adrcd = trim($csv[8]);
    $hausnummer_extref = trim($csv[12]);
    //echo "strasse: $strasse\n";
    //echo "strasse_building: $strasse_building\n";

    $strasse_name = "";
    $hausnummer_name = "";
    $addresszusatz = "";
    
    //echo $strasse_hausnummer."\n";
    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]);
      }
    }
    //echo "$strasse_name $hausnummer_name\n";
  }
  
  if(!$strasse_name || !$hausnummer_name) {
    echo "no strasse_name ($strasse_name) or hausnummer_name ($hausnummer_name)\n";
    continue;
  }
  
  $strasse_we = trim($csv[13]);
  //$nutzung = trim($csv[8]);
  $we_num = trim($csv[17]);

  if(!$strasse_we) {
    echo "Adresse Wohneinheit fehlt.\n";
    continue;
  }

  //echo "strasse_we: $strasse_we\n";
  if($strasse_hausnummer == $strasse_we) {
    $addresszusatz = "";
  } else {
    $addresszusatz = preg_replace('/^'.$strasse_hausnummer.'\s+/', "", $strasse_we);
  }
  
  
  
  $hausnummer_zusatz = ADBWohneinheit::parseHausnummerZusatz($addresszusatz);
  //var_dump($hausnummer_zusatz);
  
  echo "Gemeinde: $gem_name | PLZ: $plz_name | Ort: $ort_name | Strasse: $strasse_name | Hausnummer: $hausnummer_name |  Zusatz: ";
  
  foreach($hausnummer_zusatz as $key => $value) {
    if($value) {
      if($key == "zusatz") {
        echo $value;
        continue;
      }
      echo ucfirst($key)." ".$value;
    }
  }
  echo "\n";
  
  //continue;
  
  $gemeinde = ADBGemeindeModel::getFirst(['kennziffer' => $gem_kz]);
  if(!$gemeinde) {
    die("Gemeinde $gem_kz nicht gefunden\n");
    /*$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) {
    die("Ortschaft $ort_kz nicht gefunden\n");
    /*$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(['plz' => $plz_name]);
  if(!$plz) {
    die("PLZ $plz_name nicht gefunden\n");
    /*$plz = new ADBPlz();
    $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, 'name' => $strasse_name]);
  if(!$strasse) {
    die("Strasse $strasse_name nicht gefunden\n");
    /*$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(['adrcd' => $adrcd]);
  
  if(!$hausnummer) {
    $hausnummer = ADBHausnummerModel::getFirst(['strasse_id' => $strasse->id, 'hausnummer' => $hausnummer_name]);
  }
  
  if(!$hausnummer) {
    $hausnummer = new ADBHausnummer();
    $hausnummer->adrcd = $adrcd;
    $hausnummer->plz_id = $plz->id;
    $hausnummer->strasse_id = $strasse->id;
    $hausnummer->ortschaft_id = $ort->id;
    $hausnummer->hausnummer = $hausnummer_name;
  }
  
  $hausnummer->netzgebiet_id = $netzgebiet->id;
  $hausnummer->extref = $hausnummer_extref;
  $hausnummer->freigabe = $freigabe_default;
  
  $hausnummer_id = $hausnummer->save();
  if(!$hausnummer_id) {
    die("error creating Hausnummer $strasse_name $hausnummer_name\n");
  }
  $hausnummer->oaid = $hausnummer->getNewOAID();
  if(!$hausnummer->save()) {
    die("Cannot save oaid $strasse_name $hausnummer_name\n");
  }
  //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'],
  ];

  $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));
    }
    $wohneinheit->oaid = $wohneinheit->getNewOAID();
    if(!$wohneinheit->save()) {
      die("cannot save oaid $strasse_name $hausnummer_name\n" . print_r($wohneinheit,true));
    }
  } else {
    echo "XXXX wohneinheit gibts schon: $strasse_name $hausnummer_name ".implode(", ", $hausnummer_zusatz)."\n\n";
  }


  /*if($i > 10) {
    exit;
  }*/
}