diff --git a/scripts/adb-rimo-import/rimo-import.php b/scripts/adb-rimo-import/rimo-import.php index 479395b4a..3f3bccba4 100755 --- a/scripts/adb-rimo-import/rimo-import.php +++ b/scripts/adb-rimo-import/rimo-import.php @@ -4,6 +4,7 @@ namespace ADBRimoImport; use ADBRimoImport\ADBAddressHelper; +//use ADBRimoImport\importer\CitycomImporter; //require 'vendor/autoload.php'; require("../../config/config.php"); @@ -44,6 +45,7 @@ if ($argc > 1) { } } +$valid_adb_sources = ["rimo-rest-api", "citycom-oan-api"]; //$netowners = ["estmk", "rml"]; $netowners = ["estmk", "rml", "sbidi"]; //$netowners = ["sbidi"]; @@ -112,7 +114,19 @@ foreach ($netowners as $apiOwner) { foreach ($clustersResponse->item as $cluster) { $cluster_data = ["apiOwner" => $apiOwner, "apiKey" => $apiToken, "apiUrl" => $apiUrl, "cluster" => $cluster]; - $clusters[] = $cluster_data; + $clusters[$cluster->id] = $cluster_data; + } +} + +// add Netzgebiete not from rimo +foreach(\ADBNetzgebietModel::getAll() as $adb_cluster) { + if(!in_array($adb_cluster->source, $valid_adb_sources)) { + echo "Cluster ".$adb_cluster->name." not found in rimo\n"; + continue; + } + + if(!array_key_exists($adb_cluster->source_id, $clusters)) { + //$clusters[$adb_cluster->source_id] = ["apiOwner" => "", "apiKey" => "", "apiUrl" => "", "cluster" => $adb_cluster]; } } @@ -137,6 +151,18 @@ foreach ($clusters as $cluster_data) { continue; } + /* + * import non-rimo clusters + */ + if($adb_netzgebiet->source == "citycom-oan-api" ) { + // load and run citycom importer + /* + $citycom_importer = new CitycomImporter(["db" => $adb, "log" => $log, "netzgebiet" => $adb_netzgebiet]); + $citycom_importer->runImport(); + */ + continue; + } + $addressErrors = []; if ($command == "cluster_only" && $request_cluster) { @@ -280,6 +306,14 @@ foreach ($clusters as $cluster_data) { $hausnummer = new \ADBHausnummer($hausnummer_id); } + if($b_operationalstate_id == "99" && $b_executionstate_id == "1") { + if($hausnummer->rollout_info != "unscheduled" || $hausnummer->rollout !== null) { + $hausnummer->rollout = null; + $hausnummer->rollout_info = "unscheduled"; + $hausnummer->save(); + } + } + \mfValuecache::singleton()->set("adbhausnummer-save-nesting-level-".$hausnummer->id, 0); // update Preorders