mirror of
https://github.com/FH-Complete/FHC-Core.git
synced 2026-06-01 20:29:29 +00:00
Paolo
368 lines
9.8 KiB
PHP
368 lines
9.8 KiB
PHP
<?php
|
|
|
|
/* Copyright (C) 2025 fhcomplete.net
|
|
*
|
|
* This program is free software; you can redistribute it and/or modify
|
|
* it under the terms of the GNU General Public License as
|
|
* published by the Free Software Foundation; either version 2 of the
|
|
* License, or (at your option) any later version.
|
|
*
|
|
* This program is distributed in the hope that it will be useful,
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
* GNU General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU General Public License
|
|
* along with this program; if not, write to the Free Software
|
|
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307, USA.
|
|
*
|
|
*/
|
|
|
|
if (! defined('BASEPATH')) exit('No direct script access allowed');
|
|
|
|
class AkteLib
|
|
{
|
|
const AKTE_KATEGORIE_KURZBZ = 'Akte'; // kategorie_kurzbz of dms when inserting for akte
|
|
|
|
private $_ci; // Code igniter instance
|
|
private $_who; // who added this document
|
|
|
|
/**
|
|
* Object initialization
|
|
*/
|
|
public function __construct($params = null)
|
|
{
|
|
$this->_ci =& get_instance();
|
|
|
|
// Set the the _who property
|
|
$this->_who = 'Akte system'; // default
|
|
// It is possible to set it using the who parameter
|
|
if (!isEmptyArray($params) && isset($params['who']) && !isEmptyString($params['who'])) $this->_who = $params['who'];
|
|
|
|
$this->_ci->load->model('crm/Akte_model', 'AkteModel');
|
|
$this->_ci->load->model('content/DmsFS_model', 'DmsFSModel');
|
|
|
|
$this->_ci->load->library('DmsLib');
|
|
}
|
|
|
|
/**
|
|
* Writes a new file, adds a new dms entry with given akte data,
|
|
* adds a new dms version 0 for the written file, and adds Akte if dms add was successfull
|
|
* Returns success with inserted akte id or error
|
|
*/
|
|
public function add(
|
|
$person_id, $dokument_kurzbz, $titel, $mimetype, $fileHandle, // Required parameters
|
|
$bezeichnung = null, $archiv = false, $signiert = false, $stud_selfservice = false
|
|
)
|
|
{
|
|
// add new dms entry and new dms version for the Akte, using Akte data (title, mimetype, file content as handle)
|
|
$dmsAddResult = $this->_ci->dmslib->add($titel, $mimetype, $fileHandle, self::AKTE_KATEGORIE_KURZBZ, $dokument_kurzbz, $bezeichnung);
|
|
|
|
if (isError($dmsAddResult)) return $dmsAddResult;
|
|
|
|
if (!hasData($dmsAddResult)) return error("Dms document could not be added");
|
|
|
|
$dmsAddData = getData($dmsAddResult);
|
|
|
|
// insert the Akte
|
|
return $this->_ci->AkteModel->insert(
|
|
array(
|
|
'person_id' => $person_id,
|
|
'dokument_kurzbz' => $dokument_kurzbz,
|
|
'titel' => $titel,
|
|
'mimetype' => $mimetype,
|
|
'bezeichnung' => $bezeichnung,
|
|
'erstelltam' => date('Y-m-d'),
|
|
'dms_id' => $dmsAddData->dms_id,
|
|
'archiv' => $archiv,
|
|
'signiert' => $signiert,
|
|
'stud_selfservice' => $stud_selfservice,
|
|
'insertamum' => date('Y-m-d H:i:s'),
|
|
'insertvon' => $this->_who
|
|
)
|
|
);
|
|
}
|
|
|
|
/**
|
|
* Writes a new file, adds a new dms version 0 for the written file, and updates Akte if dms version add was successfull
|
|
* Returns success with updated akte id or error
|
|
*/
|
|
public function update($akte_id, $titel, $mimetype, $fileHandle, $bezeichnung = null, $archiv = false, $signiert = false, $stud_selfservice = false)
|
|
{
|
|
// check if Akte with dms exists
|
|
$this->_ci->AkteModel->addSelect('dms_id');
|
|
$akteResult = $this->_ci->AkteModel->load($akte_id);
|
|
|
|
if (isError($akteResult)) return $akteResult;
|
|
|
|
if (!hasData($akteResult)) return error("Akte not found");
|
|
|
|
$dms_id = getData($akteResult)[0]->dms_id;
|
|
|
|
if (isEmptyString($dms_id)) return error("Akte has no dms document");
|
|
|
|
// if Akte with dms found, update the last dms version
|
|
$dmsUpdateResult = $this->_ci->dmslib->updateLastVersion($dms_id, $fileHandle, $titel, $mimetype, $bezeichnung);
|
|
|
|
if (isError($dmsUpdateResult)) return $dmsUpdateResult;
|
|
|
|
if (!hasData($dmsUpdateResult)) return error("Dms document could not be updated");
|
|
|
|
// update the Akte
|
|
return $this->_ci->AkteModel->update(
|
|
$akte_id,
|
|
array(
|
|
'titel' => $titel,
|
|
'mimetype' => $mimetype,
|
|
'bezeichnung' => $bezeichnung,
|
|
'erstelltam' => date('Y-m-d'),
|
|
'dms_id' => $dms_id,
|
|
'archiv' => $archiv,
|
|
'signiert' => $signiert,
|
|
'stud_selfservice' => $stud_selfservice,
|
|
'updateamum' => date('Y-m-d H:i:s'),
|
|
'updatevon' => $this->_who
|
|
)
|
|
);
|
|
}
|
|
|
|
/**
|
|
* Gets akte data and associated dms data by akte Id
|
|
* Returns success with akte and dms data or error
|
|
*/
|
|
public function getByAkteId($akte_id, $archiv = null, $signiert = null, $stud_selfservice = null)
|
|
{
|
|
return $this->_get(
|
|
$akte_id,
|
|
null, // person_id
|
|
null, // dokument_kurzbz
|
|
$archiv,
|
|
$signiert,
|
|
$stud_selfservice
|
|
);
|
|
}
|
|
|
|
/**
|
|
* Gets Akte data and associated dms data by person Id
|
|
* Returns success with result array with akte and dms data or error
|
|
*/
|
|
public function getByPersonId($person_id, $archiv = null, $signiert = null, $stud_selfservice = null)
|
|
{
|
|
return $this->_get(
|
|
null, // akte_id
|
|
$person_id,
|
|
null, // dokument_kurzbz
|
|
$archiv,
|
|
$signiert,
|
|
$stud_selfservice
|
|
);
|
|
}
|
|
|
|
/**
|
|
* Gets Akte data and associated dms data by person Id and dokument_kurzbz
|
|
* Returns success with result array with akte and dms data or error
|
|
*/
|
|
public function getByPersonIdAndDocumentType($person_id, $dokument_kurzbz)
|
|
{
|
|
return $this->_get(
|
|
null, // akte_id
|
|
$person_id,
|
|
$dokument_kurzbz,
|
|
$archiv,
|
|
$signiert,
|
|
$stud_selfservice
|
|
);
|
|
}
|
|
|
|
/**
|
|
* Removes Akte by akte Id, removes all associated dms entries and versions, and deletes all associated files
|
|
* Returns success with removed version numbers or error
|
|
*/
|
|
public function remove($akte_id)
|
|
{
|
|
// get dms_id for akte
|
|
$this->_ci->AkteModel->addSelect('dms_id');
|
|
$akteResult = $this->_ci->AkteModel->load($akte_id);
|
|
|
|
if (isError($akteResult)) return $akteResult;
|
|
|
|
if (!hasData($akteResult)) return error("Akte not found");
|
|
|
|
$dms_id = getData($akteResult)[0]->dms_id;
|
|
$error = null;
|
|
|
|
// Start DB transaction to avoid deleting only part of the data
|
|
$this->_ci->db->trans_begin();
|
|
|
|
// delete Akte
|
|
$deleteResult = $this->_ci->AkteModel->delete($akte_id);
|
|
|
|
if (isError($deleteResult))
|
|
{
|
|
$error = $deleteResult;
|
|
}
|
|
else
|
|
{
|
|
// remove all dms entry for dms of the akte
|
|
$removeAllResult = $this->_ci->dmslib->removeAll($dms_id);
|
|
|
|
if (isError($removeAllResult))
|
|
$error = $removeAllResult;
|
|
}
|
|
|
|
// Transaction complete!
|
|
$this->_ci->db->trans_complete();
|
|
|
|
// Check if everything went ok during the transaction
|
|
if ($this->_ci->db->trans_status() === false || isset($error))
|
|
{
|
|
$this->_ci->db->trans_rollback();
|
|
|
|
// return occured error
|
|
if (isset($error))
|
|
return $error;
|
|
else
|
|
return error("Error occured when deleting, rolled back");
|
|
}
|
|
else
|
|
{
|
|
$this->_ci->db->trans_commit();
|
|
|
|
// return removed dms entry data
|
|
return $removeAllResult;
|
|
}
|
|
}
|
|
|
|
/**
|
|
*
|
|
*/
|
|
private function _get($akte_id = null, $person_id = null, $dokument_kurzbz = null, $archiv = null, $signiert = null, $stud_selfservice = null)
|
|
{
|
|
$dbModel = new DB_Model();
|
|
|
|
$query = 'SELECT akte_id,
|
|
person_id,
|
|
dokument_kurzbz,
|
|
inhalt,
|
|
CASE WHEN inhalt is not null THEN true ELSE false END as inhalt_vorhanden,
|
|
mimetype,
|
|
erstelltam,
|
|
gedruckt,
|
|
titel,
|
|
bezeichnung,
|
|
updateamum,
|
|
updatevon,
|
|
insertamum,
|
|
insertvon,
|
|
uid,
|
|
dms_id,
|
|
nachgereicht,
|
|
anmerkung,
|
|
titel_intern,
|
|
anmerkung_intern,
|
|
nachgereicht_am,
|
|
ausstellungsnation,
|
|
formal_geprueft_amum,
|
|
archiv,
|
|
signiert,
|
|
stud_selfservice,
|
|
akzeptiertamum
|
|
FROM public.tbl_akte
|
|
WHERE TRUE';
|
|
|
|
// Query parameters
|
|
$paramArray = array();
|
|
|
|
// akte_id
|
|
if (is_int($akte_id) || is_array($akte_id))
|
|
{
|
|
$paramArray[] = $akte_id;
|
|
if (is_int($akte_id)) $query .= ' AND akte_id = ?';
|
|
if (is_array($akte_id)) $query .= ' AND akte_id IN ?';
|
|
}
|
|
|
|
// person_id
|
|
if (is_int($person_id) || is_array($person_id))
|
|
{
|
|
$paramArray[] = $person_id;
|
|
if (is_int($person_id)) $query .= ' AND person_id = ?';
|
|
if (is_array($person_id)) $query .= ' AND person_id IN ?';
|
|
}
|
|
|
|
// dokument_kurzbz
|
|
if (!isEmptyString($dokument_kurzbz))
|
|
{
|
|
$paramArray[] = $dokument_kurzbz;
|
|
$query .= ' AND dokument_kurzbz = ?';
|
|
}
|
|
|
|
// archiv
|
|
if (is_bool($archiv))
|
|
{
|
|
$paramArray[] = $archiv;
|
|
$query .= ' AND archiv = ?';
|
|
}
|
|
|
|
// signiert
|
|
if (is_bool($signiert))
|
|
{
|
|
$paramArray[] = $signiert;
|
|
$query .= ' AND signiert = ?';
|
|
}
|
|
|
|
// stud_selfservice
|
|
if (is_bool($stud_selfservice))
|
|
{
|
|
$paramArray[] = $stud_selfservice;
|
|
$query .= ' AND stud_selfservice = ?';
|
|
}
|
|
|
|
// Loads data from DB
|
|
$akteResult = $dbModel->execReadOnlyQuery($query, $paramArray);
|
|
|
|
// If error or data not found then exit
|
|
if (isError($akteResult)) return $akteResult;
|
|
if (!hasData($akteResult)) return error('Akte not found');
|
|
|
|
// For each record from the akte
|
|
foreach (getData($akteResult) as $resultObject)
|
|
{
|
|
// get dms data
|
|
$dmsResult = $this->_ci->dmslib->getLastVersion($resultObject->dms_id);
|
|
|
|
if (isError($dmsResult)) return $dmsResult;
|
|
|
|
// properties to retrieve from dms
|
|
$dmsProperties = array('version', 'filename', 'mimetype', 'name', 'beschreibung', 'cis_suche', 'schlagworte', DmsLib::FILE_CONTENT_PROPERTY);
|
|
|
|
// set dms properties
|
|
if (hasData($dmsResult))
|
|
{
|
|
$dmsData = getData($dmsResult);
|
|
|
|
foreach ($dmsProperties as $dmsProperty)
|
|
{
|
|
// If the property is _not_ 'mimetype' _or_
|
|
// If the mimetype from the akte table is null then overwrite it with the one from the DMS
|
|
if ($dmsProperty != 'mimetype' || ($dmsProperty == 'mimetype' && $resultObject->{$dmsProperty} == null))
|
|
{
|
|
$resultObject->{$dmsProperty} = $dmsData->{$dmsProperty};
|
|
}
|
|
}
|
|
}
|
|
else
|
|
{
|
|
// set null if no dms result found
|
|
foreach ($dmsProperties as $dmsProperty)
|
|
{
|
|
if ($dmsProperty != 'mimetype') $resultObject->{$dmsProperty} = null;
|
|
}
|
|
}
|
|
}
|
|
|
|
// return the object containing akte and dms data
|
|
return success(getData($akteResult));
|
|
}
|
|
}
|
|
|