thetool/scripts/addressdb/rml-liezen/import-from-modified-export.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");


$netzgebiet_name_main = "Liezen";
$freigabe_default = json_encode(["order", "reorder"]);


$me = new User(1);

$folder = __DIR__."/import/";
$csvname = "Adressendatensatz_Update-RMLI_2023-01-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 = [];

$l = 0;
$u = 0;
while($csv = fgetcsv($input, 0, ",")) {
  $l++;
  if($l == 1) continue;
  
  $hausnummer = false;
  
  if(!trim($csv[0])) {
    continue;
  }
  
  $hausnummer_id = trim($csv[0]);
  $hausnummer_extref = trim($csv[1]);
  $adrcd = trim($csv[2]);
  $oaid = trim($csv[3]);
  $netzgebiet_extref = trim($csv[4]);
  $netzgebiet_name = trim($csv[5]);
  $gkz = trim($csv[6]);
  $gem_name = trim($csv[7]);
  $okz = trim($csv[8]);
  $ort_name = trim($csv[9]);
  $plz_string = trim($csv[10]);
  $skz = trim($csv[11]);
  $strasse_name = trim($csv[12]);
  $hausnummer_string = trim($csv[13]);
  $grund_nr = trim($csv[14]);
  //gps_long, gps_lat
  $rollout_time = trim($csv[17]);
  $rollout_info = trim($csv[18]);
  //$freigabe = trim($csv[19])
  $unit_count = trim($csv[20]);
  
  
  /*
  $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(!is_numeric($adrcd) || !is_numeric($hausnummer_id)) {
    die("Invalid adrcd or hausnummer_id\n");
  }
  
  if(!strlen($hausnummer_string) || !strlen($strasse_name)) {
    die("!! Hausnummer oder Strasse leer (adrcd $adrcd)\n");
  }
  
  if(!$gem_name || !$plz_string || !$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");
  }

  
  
  $existing_hausnummer = new ADBHausnummer($hausnummer_id);
  if(!$existing_hausnummer->id) {
    echo "$hausnummer_id not found\n";
    continue;
  }
  
  //continue;
  
  $updates = [];
  if($existing_hausnummer->netzgebiet->extref != $netzgebiet_extref) {
    echo "$hausnummer_id: netzgebiet '".$existing_hausnummer->netzgebiet->name."' => '$netzgebiet_name'\n";
    $updates[] = "netzgebiet";
  }
  if($existing_hausnummer->strasse->name != $strasse_name) {
    echo "$hausnummer_id: strasse '".$existing_hausnummer->strasse->name."' => '$strasse_name'\n";
    $updates[] = "strasse";
  }
  if($existing_hausnummer->strasse->gemeinde->name != $gem_name) {
    echo "$hausnummer_id: gemeinde '".$existing_hausnummer->strasse->gemeinde->name."' => '$gem_name'\n";
    $updates[] = "gemeinde";
  }
  if($existing_hausnummer->hausnummer != $hausnummer_string) {
    echo "$hausnummer_id: hausnummer '".$existing_hausnummer->hausnummer."' => '$hausnummer_string'\n";
    $updates[] = "hausnummer";
  }
  if($existing_hausnummer->ortschaft->name != $ort_name) {
    echo "$hausnummer_id: ortschaft '".$existing_hausnummer->ortschaft->name."' => '$ort_name'\n";
    $updates[] = "ortschaft";
  }
  if($existing_hausnummer->plz->plz != $plz_string) {
    echo "$hausnummer_id: plz '".$existing_hausnummer->plz->plz."' => '$plz_string'\n";
    $updates[] = "plz";
  }
  if($existing_hausnummer->rollout != $rollout_time) {
    echo "$hausnummer_id: rollout '".$existing_hausnummer->rollout."' => '$rollout_time'\n";
    $updates[] = "rollout";
  }
  if($existing_hausnummer->rollout_info != $rollout_info) {
    echo "$hausnummer_id: rollout_info '".$existing_hausnummer->rollout_info."' => '$rollout_info'\n";
    $updates[] = "rollout_info";
  }
  if($existing_hausnummer->unit_count != $unit_count) {
    echo "$hausnummer_id: unit_count '".$existing_hausnummer->unit_count."' => '$unit_count'\n";
    $updates[] = "unit_count";
  }
    
  
  if(!count($updates)) {
    continue;
  }
  
  if(in_array("netzgebiet", $updates)) {
    $netzgebiet = ADBNetzgebietModel::getFirst(['extref' => $netzgebiet_extref]);
    if(!$netzgebiet) {
      die("$hausnummer_id: Netzgebiet ($netzgebiet_extref: $netzgebiet_name) nicht gefunden\n");
    }
    $existing_hausnummer->netzgebiet_id = $netzgebiet->id;
    echo "$hausnummer_id: Updating Netzgebiet to ".$netzgebiet->id."\n";
    //$existing_hausnummer->save();
  }
  
  if(in_array("rollout", $updates) || in_array("rollout_info", $updates)) {
    $new_rollout = false;
    $new_rollout_info = false;
    $freigabe = $freigabe_default;
    
    if(is_numeric($rollout_time)) {
      $new_rollout = $rollout_time;
      $new_rollout_info = null;
      $freigabe = $freigabe_default;
    } elseif($rollout_time == "2024/2025") {
      $new_rollout = null;
      $new_rollout_info = "2024/2025";
      $freigabe = json_encode(['reorder']);
    } elseif($rollout_info == "2099") {
      $new_rollout = null;
      $new_rollout_info = "2099";
      $freigabe = json_encode(['reorder']);
    } else {
      $new_rollout = null;
      $new_rollout_info = "unscheduled";
      $freigabe = json_encode([]);
    }
    
    $existing_hausnummer->rollout = $new_rollout;
    $existing_hausnummer->rollout_info = $new_rollout_info;
    $existing_hausnummer->freigabe = $freigabe;
    
    echo "$hausnummer_id: updating rollout/info/freigabe to $new_rollout / $new_rollout_info / $freigabe\n";
    //$existing_hausnummer->save();
  }
  
  $existing_hausnummer->save();
  $u++;
  
  // update GemeindeNetzgebiet if needed
  $netzgebiet = new ADBNetzgebiet($existing_hausnummer->netzgebiet_id);
  $gemeinde = new ADBGemeinde($existing_hausnummer->strasse->gemeinde_id);
  checkGemeindeNetzgebiet($gemeinde, $netzgebiet);
  
  echo "=================================\n";
  
  
}

echo "$l lines processed, $u updated\n";


function checkGemeindeNetzgebiet($gemeinde, $netzgebiet) {
  global $db;
  
  $sql = "SELECT * FROM GemeindeNetzgebiet WHERE gemeinde_id=".$gemeinde->id." AND netzgebiet_id=".$netzgebiet->id;
  $res = $db->query($sql);
  if($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(!$db->query($sql)) {
    die("SQL Query failed: $sql\n ".$db->getLastError());
  }
  
  echo "updated GemeindeNetzgebiet\n";
  
  return true;
}