Finished create/update AddressDB records

application/AddressDB/AddressDB.php

@@ -70,4 +70,182 @@ class AddressDB {
     }
   }
   
+  /*
+   * methods to create or update an Address from strings
+   */
+  
+  public function createUpdateHausnummer($data) {
+    $netzgebiet = null;
+    $gemeinde = null;
+    $ortschaft = null;
+    $strasse = null;
+    $plz = null;
+    $hausnummer = null;
+    
+    //var_dump($data);exit;
+    
+    if(!array_key_exists("netzgebiet_id", $data)) {
+      return false;
+    }
+    
+    foreach(["gemeinde", "ortschaft", "strasse", "plz"] as $field) {
+      $classname = "ADB".ucfirst($field);
+      $idfield = $field."_id";
+      if(!array_key_exists($field."_id", $data)) continue;
+      $$field = new $classname($data[$idfield]);
+      if(!${$field}->id) {
+        $$field = null;
+      }
+    }
+    
+    
+    $netzgebiet = new ADBNetzgebiet($data['netzgebiet_id']);
+    if(!$netzgebiet->id) {
+      $this->log->debug(__CLASS__."::".__METHOD__.": Missing netzgebiet_id");
+      return false;
+    }
+    
+    if(!$gemeinde) {
+      // dont allow creating Gemeinden
+      $this->log->debug(__CLASS__."::".__METHOD__.": Missing Gemeinde");
+      return false;
+    }
+    
+    if(!$ortschaft) {
+      // search by kennziffer
+      if(array_key_exists("ortschaft_kennziffer", $data) && $data['ortschaft_kennziffer']) {
+        $ortschaft = ADBOrtschaftModel::getFirst(['kennziffer' => $data['ortschaft_kennziffer']]);
+      }
+      
+      if(!$ortschaft) {
+        // search by name
+        if(!array_key_exists("ortschaft", $data) || !$data['ortschaft']) return false;
+        $ortschaft = ADBOrtschaftModel::getFirst(['gemeinde_id' => $gemeinde->id, 'name' => $data['ortschaft']]);
+      }
+      
+      if(!$ortschaft) {
+        // create Ortschaft
+        $ortschaft = ADBOrtschaftModel::create([
+          'gemeinde_id' => $gemeinde->id,
+          'kennziffer' => ($data['ortschaft_kennziffer']) ? $data['ortschaft_kennziffer'] : null,
+          'name' => $data['ortschaft']
+        ]);
+        if(!$ortschaft->save()) {
+          $this->log->debug(__CLASS__."::".__METHOD__.": Cannot save Ortschaft");
+          return false;
+        }
+      }
+    }
+    
+    if(!$strasse) {
+      // search by kennziffer
+      if(array_key_exists("strasse_kennziffer", $data) && $data['strasse_kennziffer']) {
+        $strasse = ADBStrasseModel::getFirst(['kennziffer' => $data['strasse_kennziffer']]);
+      }
+      
+      if(!$strasse) {
+        // search by name
+        if(!array_key_exists("strasse", $data) || !$data['strasse']) return false;
+        $strasse = ADBStrasseModel::getFirst(['gemeinde_id' => $gemeinde->id, 'name' => $data['strasse']]);
+      }
+      
+      if(!$strasse) {
+        // create Strasse
+        if(!array_key_exists("strasse", $data) || !$data['strasse']) return false;
+        $strasse = ADBStrasseModel::create([
+          'gemeinde_id' => $gemeinde->id,
+          'kennziffer' => ($data['strasse_kennziffer']) ? $data['strasse_kennziffer'] : null,
+          'name' => $data['strasse']
+        ]);
+        if(!$strasse->save()) {
+          $this->log->debug(__CLASS__."::".__METHOD__.": Cannot save Strasse");
+          return false;
+        }
+      }
+    }
+    
+    if(!$plz) {
+      // search by plz
+      if(!array_key_exists("plz", $data) || !$data['plz']) return false;
+      $plz = ADBPlzModel::getFirst(['gemeinde_id' => $gemeinde->id, 'plz' => $data['plz']]);
+      if(!$plz) {
+        // create PLZ
+        $plz = ADBPlzModel::create([
+          'gemeinde_id' => $gemeinde->id,
+          'plz' => $data['plz'],
+          'plzstring' => $data['plz']
+        ]);
+        if(!$plz->save()) {
+          $this->log->debug(__CLASS__."::".__METHOD__.": Cannot save PLZ");
+          return false;
+        }
+      }
+    }
+    
+    if(array_key_exists("hausnummer_id", $data)) {
+      // if hausnummer_id is set but empty => fail
+      if(!$data['hausnummer_id']) return false;
+      $hausnummer = new ADBHausnummer($data['hausnummer_id']);
+      if(!$hausnummer->id) {
+        return false;
+      }
+    }
+    
+    $me = new User();
+    $me->loadMe();
+    
+    // build hausnummer data
+    //$hausnummer_data['oaid'] = (array_key_exists("oaid", $data) && $data['oaid']) ? $data['oaid'] : null;
+    $hausnummer_data['adrcd'] = ($data['adrcd']) ? $data['adrcd'] : null;
+    $hausnummer_data['extref'] = ($data['extref']) ? $data['extref'] : null;
+    $hausnummer_data['netzgebiet_id'] = $netzgebiet->id;
+    $hausnummer_data['ortschaft_id'] = $ortschaft->id;
+    $hausnummer_data['plz_id'] = $plz->id;
+    $hausnummer_data['strasse_id'] = $strasse->id;
+    $hausnummer_data['hausnummer'] = $data['hausnummer'];
+    $hausnummer_data['grund_nr'] = $data['grund_nr'];
+    $hausnummer_data['gps_lat'] = ($data['gps_lat']) ? str_replace(",", ".", $data['gps_lat']) : null;
+    $hausnummer_data['gps_long'] = ($data['gps_long']) ? str_replace(",", ".", $data['gps_long']) : null;
+    $hausnummer_data['rollout'] = (trim($data['rollout'])) ? trim($data['rollout']) : null;
+    $hausnummer_data['rollout_info'] = (trim($data['rollout_info'])) ? trim($data['rollout_info']) : null;
+    $hausnummer_data['freigabe'] = json_encode($data['freigabe']);
+    $hausnummer_data['manual_add'] = date('U');
+    $hausnummer_data['manual_add_by'] = $me->id;
+    $hausnummer_data['manual_add_info'] = "thetool user ".$me->username." via AddressDB";
+    $hausnummer_data['manual_update'] = date('U');
+    $hausnummer_data['manual_update_by'] = $me->id;
+    $hausnummer_data['manual_update_info'] = "thetool user ".$me->username." via AddressDB";
+    
+    //var_dump($hausnummer_data, $hausnummer);exit;
+    
+    if(!$hausnummer) {
+      // create hausnummer
+      $hausnummer = ADBHausnummerModel::create($hausnummer_data);
+    } else {
+      // update hausnummer
+      $hausnummer->update($hausnummer_data);
+    }
+    
+    $hausnummer_id = $hausnummer->save();
+    if(!$hausnummer_id) {
+      $this->log->debug(__CLASS__."::".__METHOD__.": Cannot save Hausnummer");
+      return false;
+    }
+    
+    // create OAID
+    if(!$hausnummer->oaid) {
+      $hausnummer->oaid = $hausnummer->getNewOAID();
+      if(!$hausnummer->save()) {
+        $this->log->debug(__CLASS__."::".__METHOD__.": Cannot save Hausnummer OAID");
+      }
+    }
+    
+    
+    return $hausnummer_id;
+  }
+  
+  public function updateHausnummer($hausnummer_id, $data) {
+    
+  }
+  
 }