348 lines
11 KiB
PHP
348 lines
11 KiB
PHP
<?php
|
|
|
|
class OpenAccessId extends mfBaseModel {
|
|
private $owner;
|
|
private $adb_wohneinheit;
|
|
private $termination;
|
|
|
|
public function loadRandomUnassigned($attributes = []) {
|
|
$where = "active = 1 AND assigned = 0 AND adb_wohneinheit_id IS NULL AND termination_id IS NULL AND exported = 0 AND exported_to IS NULL";
|
|
|
|
if(array_key_exists("owner_id", $attributes) && $attributes['owner_id']) {
|
|
$owner_id = (int)$attributes['owner_id'];
|
|
if(!$owner_id) {
|
|
throw new Exception("Besitzer muss eine Zahl sein");
|
|
}
|
|
$where .= " AND owner_id = $owner_id";
|
|
}
|
|
|
|
if(array_key_exists("origin", $attributes) && $attributes['origin']) {
|
|
$origin = $attributes['origin'];
|
|
if(!OpenAccessIdModel::getFirst(["origin" => $origin])) {
|
|
throw new Exception("Origin '$origin' not found!");
|
|
}
|
|
$where .= " AND origin = '$origin'";
|
|
}
|
|
|
|
if(array_key_exists("origin_id", $attributes) && $attributes['origin_id']) {
|
|
$origin_id = $attributes['origin_id'];
|
|
if(!OpenAccessIdModel::getFirst(["origin_id" => $origin_id])) {
|
|
throw new Exception("OAID Set '$origin_id' not found!");
|
|
}
|
|
$where .= " AND origin_id = '$origin_id'";
|
|
}
|
|
|
|
//var_dump($where);exit;
|
|
$res = $this->db->select("OpenAccessId", "*", "$where ORDER BY RAND() LIMIT 1");
|
|
|
|
if(!$this->db->num_rows($res)) {
|
|
throw new Exception("Konnte keine zufällige freie OAID laden!");
|
|
}
|
|
$data = $this->db->fetch_object($res);
|
|
$this->load($data);
|
|
return true;
|
|
}
|
|
|
|
|
|
public function exportToRimoAndAssignFtu() {
|
|
// XXX for now only support ADB Addresses
|
|
if(!$this->adb_wohneinheit_id) {
|
|
return true;
|
|
}
|
|
|
|
if(!$this->id) {
|
|
return false;
|
|
}
|
|
|
|
/***********************************************************************
|
|
* check Wohneinheit external data for FTU id (SDMMaterial_), or fetch it from RIMO
|
|
*/
|
|
|
|
$wohneinheit = new ADBWohneinheit($this->adb_wohneinheit_id);
|
|
if(!$wohneinheit->id || !$wohneinheit->extref) {
|
|
return false;
|
|
}
|
|
|
|
$fetch_ftu = true;
|
|
$unit_extdata = new StdClass();
|
|
|
|
if($wohneinheit->external_data) {
|
|
$extdata = json_decode($wohneinheit->external_data);
|
|
|
|
if(is_object($extdata)) {
|
|
$unit_extdata = $extdata;
|
|
}
|
|
|
|
if(is_object($extdata) && isset($extdata->rimo) && isset($extdata->rimo->ftu->id)) {
|
|
//var_dump($extdata);exit;
|
|
$fetch_ftu = false;
|
|
}
|
|
}
|
|
|
|
if($fetch_ftu) {
|
|
// query Home to get FTU data from RIMO - GET /queryHomeWithId
|
|
$params['apiKey'] = RIMO_API_JSON_APIKEY;
|
|
$params["homeId"] = $wohneinheit->extref;
|
|
|
|
$ctx_opts = [
|
|
'http' => [
|
|
'method' => 'GET',
|
|
'header' => 'accept: application/json'
|
|
]
|
|
];
|
|
|
|
$qs = http_build_query($params);
|
|
//echo $qs."\n";
|
|
|
|
$createOrderEp = RIMO_API_JSON_URL.RIMO_API_JSON_EP_QUERY_HOME;
|
|
$get_url = $createOrderEp."?".$qs;
|
|
$ctx = stream_context_create($ctx_opts);
|
|
$this->log->debug(__METHOD__.": Getting Home to fetch FTU: $get_url");
|
|
//exit;
|
|
$response = file_get_contents($get_url, false, $ctx);
|
|
|
|
if($response === false) {
|
|
$this->log->error("Fehler beim auslesen der FTU ".$this->oaid."\n");
|
|
return false;
|
|
}
|
|
//$preorder->workorder_export_date = date('U');
|
|
//$preorder->workorder_export_data = $response;
|
|
//$preorder->save();
|
|
$resp_data = json_decode($response);
|
|
if(!is_object($resp_data)) {
|
|
$this->log->error(__METHOD__.": OAID ".$this->oaid.": Cannot fetch Home from RIMO! Invalid Response!");
|
|
return false;
|
|
}
|
|
|
|
if(!is_array($resp_data->ftus->item) || !count($resp_data->ftus->item)) {
|
|
$this->log->warning(__METHOD__.": Homes ftus object has no items ".$this->oaid);
|
|
return false;
|
|
}
|
|
|
|
$ftu_data = new StdClass();
|
|
$ftu_data->id = $resp_data->ftus->item[0]->id;
|
|
$ftu_data->name = $resp_data->ftus->item[0]->name;
|
|
|
|
if(!isset($unit_extdata->rimo)) {
|
|
$unit_extdata->rimo = new StdClass();
|
|
}
|
|
|
|
$unit_extdata->rimo->ftu = $ftu_data;
|
|
$wohneinheit->external_data = json_encode($unit_extdata);
|
|
$wohneinheit->save();
|
|
} else { // $fetch_ftu == true
|
|
$this->log->debug(__METHOD__.": OAID ".$this->oaid.": Home FTU id known already");
|
|
}
|
|
|
|
/***************************************************************************
|
|
* check if we have RIMO OAID data or create OAID in RIMO - POST /v1/oaid-management/oaids
|
|
*/
|
|
|
|
$existing_rimo_export_data = $this->getExportData("rimo");
|
|
if(!is_object($existing_rimo_export_data) || !isset($existing_rimo_export_data->oaid_id) || !isset($existing_rimo_export_data->name)) {
|
|
$params = [];
|
|
$params['apiKey'] = RIMO_API_JSON_APIKEY;
|
|
$params['oaidName'] = $this->oaid;
|
|
|
|
$ctx_opts = [
|
|
'http' => [
|
|
'method' => 'POST',
|
|
'header' => 'accept: application/json'
|
|
]
|
|
];
|
|
|
|
$qs = http_build_query($params);
|
|
//echo $qs."\n";
|
|
|
|
$createOrderEp = RIMO_API_JSON_URL.RIMO_API_JSON_EP_CREATE_OAID;
|
|
$post_url = $createOrderEp."?".$qs;
|
|
$ctx = stream_context_create($ctx_opts);
|
|
$this->log->debug(__METHOD__.": Creating OAID in Rimo: $post_url");
|
|
$response = file_get_contents($post_url, false, $ctx);
|
|
//var_dump($response);exit;
|
|
if($response === false) {
|
|
$this->log->error("Fehler beim Erstellen der OAID in RIMO ".$this->oaid."\n");
|
|
$workorders_failed++;
|
|
return false;
|
|
}
|
|
|
|
$resp_data = json_decode($response);
|
|
if(!$resp_data->id || !$resp_data->name) {
|
|
$this->log->warning(__METHOD__.": Create OAID returned no ID or oaid name ".$this->oaid);
|
|
return false;
|
|
}
|
|
|
|
// mark OAID as exported
|
|
$oaid_export_data = new StdClass();
|
|
if($this->export_data) {
|
|
$oaid_export_data = json_decode($this->export_data);
|
|
}
|
|
if(!isset($oaid_export_data->rimo)) {
|
|
$oaid_export_data->rimo = new StdClass();
|
|
}
|
|
$oaid_export_data->rimo->oaid_id = $resp_data->id;
|
|
$oaid_export_data->rimo->name = $resp_data->name;
|
|
$oaid_export_data->rimo->ftu_id = null;
|
|
$this->exported_to = "rimo";
|
|
$this->exported = date('U');
|
|
$this->export_data = json_encode($oaid_export_data);
|
|
$this->save();
|
|
} else {
|
|
$this->log->debug(__METHOD__.": OAID ".$this->oaid.": Already created in RIMO");
|
|
}
|
|
|
|
/*************************************************************************
|
|
* assign OAID to FTU - POST /v1/oaid-management/oaids/{oaidName}/ftu/{ftuExternalId}
|
|
*/
|
|
|
|
// check if we assigned the OAID to a RIMO FTU already
|
|
$existing_rimo_export_data = $this->getExportData("rimo");
|
|
if(!is_object($existing_rimo_export_data) || !isset($existing_rimo_export_data->oaid_id) || !isset($existing_rimo_export_data->ftu_id)) {
|
|
$params = [];
|
|
$params['apiKey'] = RIMO_API_JSON_APIKEY;
|
|
|
|
$ctx_opts = [
|
|
'http' => [
|
|
'method' => 'POST',
|
|
'header' => 'accept: application/json'
|
|
]
|
|
];
|
|
|
|
$qs = http_build_query($params);
|
|
//echo $qs."\n";
|
|
|
|
$createOrderEp = RIMO_API_JSON_URL.RIMO_API_JSON_EP_ASSIGN_OAID_TO_FTU;
|
|
$createOrderEp = str_replace("{oaidName}", $this->oaid, $createOrderEp);
|
|
$createOrderEp = str_replace("{ftuExternalId}", $unit_extdata->rimo->ftu->id, $createOrderEp);
|
|
$post_url = $createOrderEp."?".$qs;
|
|
|
|
$ctx = stream_context_create($ctx_opts);
|
|
$this->log->debug(__METHOD__.": Assigning OAID to FTU in Rimo: $post_url");
|
|
|
|
$response = file_get_contents($post_url, false, $ctx);
|
|
|
|
if($response === false) {
|
|
$this->log->error("Fehler beim Zuweisen der OAID '".$this->oaid."' zu RIMO FTU '".$unit_extdata->rimo->ftu->id."'\n");
|
|
$workorders_failed++;
|
|
return false;
|
|
}
|
|
|
|
// add FTU id to external_data
|
|
$oaid_export_data = new StdClass();
|
|
if($this->export_data) {
|
|
$oaid_export_data = json_decode($this->export_data);
|
|
}
|
|
if(!isset($oaid_export_data->rimo)) {
|
|
$oaid_export_data->rimo = new StdClass();
|
|
}
|
|
|
|
$oaid_export_data->rimo->ftu_id = $unit_extdata->rimo->ftu->id;
|
|
$oaid_export_data->rimo->ftu_name = $unit_extdata->rimo->ftu->name;
|
|
$oaid_export_data->rimo->ftu_assigned_date = date('U');
|
|
$this->export_data = json_encode($oaid_export_data);
|
|
$this->save();
|
|
} else {
|
|
$this->log->debug(__METHOD__.": OAID ".$this->oaid.": Already assigned to FTU in Rimo");
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
public function importFromCSV(File $file, $attributes = []) {
|
|
$active = (int)$attributes['active'];
|
|
$origin = $attributes['origin'];
|
|
$origin_id = $attributes['origin_id'];
|
|
$owner_id = (int)$attributes['owner_id'];
|
|
|
|
|
|
try {
|
|
$import_count = 0;
|
|
$i = 0;
|
|
$filename = $file->getFullPath();
|
|
$input = fopen($filename, "r");
|
|
while($csv = fgetcsv($input, 0, ";")) {
|
|
$i++;
|
|
if($i == 1) continue;
|
|
|
|
if(!trim($csv[0])) {
|
|
continue;
|
|
}
|
|
|
|
$name = trim($csv[0]);
|
|
|
|
if(!$name) {
|
|
$this->log->warning(__FILE__."::importFromCSV(): Name missing");
|
|
continue;
|
|
}
|
|
|
|
$oaid = OpenAccessIdModel::getFirst(["oaid" => $name]);
|
|
if($oaid) continue;
|
|
|
|
$oaid = OpenAccessIdModel::create([
|
|
"oaid" => $name,
|
|
"active" => $active,
|
|
"origin" => $origin,
|
|
"origin_id" => ($origin_id) ? $origin_id : null,
|
|
"owner_id" => $owner_id
|
|
]);
|
|
if(!$oaid->save()) {
|
|
$this->log->error(__FILE__."::importFromCSV(): Fehler beim Speichern OAID $name");
|
|
continue;
|
|
}
|
|
$import_count++;
|
|
|
|
}
|
|
return $import_count;
|
|
|
|
|
|
} catch(Exception $e) {
|
|
echo $e->getCode().": ".$e->getMessage();exit;
|
|
return false;
|
|
}
|
|
}
|
|
|
|
public function getExportData($key) {
|
|
if(!$this->export_data) {
|
|
return [];
|
|
} else {
|
|
$exdata = json_decode($this->export_data);
|
|
if(!is_object($exdata)) {
|
|
return [];
|
|
}
|
|
if(isset($exdata->$key)) {
|
|
return $exdata->$key;
|
|
}
|
|
}
|
|
}
|
|
|
|
public function getProperty($name) {
|
|
if($this->$name == null) {
|
|
|
|
if(!$this->id) {
|
|
return null;
|
|
}
|
|
|
|
if($name == "owner") {
|
|
$this->owner = new Address($this->owner_id);
|
|
return $this->owner;
|
|
}
|
|
|
|
if($name == "adb_wohneinheit") {
|
|
$this->adb_wohneinheit = new ADBWohneinheit($this->adb_wohneinheit_id);
|
|
return $this->adb_wohneinheit;
|
|
}
|
|
|
|
$classname = ucfirst($name);
|
|
$idfield = $name."_id";
|
|
$this->$name = new $classname($this->$idfield);
|
|
|
|
if($this->$name->id) {
|
|
return $this->$name;
|
|
} else {
|
|
return null;
|
|
}
|
|
}
|
|
|
|
return $this->$name;
|
|
}
|
|
} |