<?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, $dokument_kurzbz = null, $archiv = null, $signiert = null, $stud_selfservice = null)
	{
		return $this->_get(
			$akte_id,
			null, // person_id
			$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 getByPersonId($person_id, $dokument_kurzbz = null, $archiv = null, $signiert = null, $stud_selfservice = null)
	{
		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)
	{
		return $this->_remove($akte_id, null, null);
	}

	/**
	 * Removes Akte by $person_id and $dms_id, removes all associated dms entries and versions, and deletes all associated files
	 * Returns success with removed version numbers or error
	 */
	public function removeByPersonIdAndDmsId($person_id, $dms_id)
	{
		return $this->_remove(null, $person_id, $dms_id);
	}

	/**
	 *
	 */
	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_numeric($akte_id) || is_array($akte_id))
		{
			$paramArray[] = $akte_id;
			if (is_numeric($akte_id)) $query .= ' AND akte_id = ?';
			if (is_array($akte_id)) $query .= ' AND akte_id IN ?';
		}

		// person_id
		if (is_numeric($person_id) || is_array($person_id))
		{
			$paramArray[] = $person_id;
			if (is_numeric($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 = ?';
		}

		// If no parameters has been provided exit
		if (isEmptyArray($paramArray)) return error('Called without giving any parameter');

		// 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');

			// set dms properties
			if (hasData($dmsResult))
			{
				$dmsData = getData($dmsResult)[0];

				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));
	}

	/**
	 * Removes Akte by akte Id, person id and/or dms id
	 * Removes all associated dms entries and versions, and deletes all associated files
	 * Returns success with removed version numbers or error
	 */
	private function _remove($akte_id = null, $person_id = null, $dms_id = null)
	{
		// Get dms_id for akte
		$this->_ci->AkteModel->addSelect('akte_id');
		$this->_ci->AkteModel->addSelect('dms_id');

		$paramArray = array();

		if (is_numeric($akte_id)) $paramArray['akte_id'] = $akte_id;
		if (is_numeric($person_id)) $paramArray['person_id'] = $person_id;
		if (is_numeric($dms_id)) $paramArray['dms_id'] = $dms_id;

		$akteResult = $this->_ci->AkteModel->loadWhere($paramArray);

		if (isError($akteResult)) return $akteResult;

		if (!hasData($akteResult)) return error('Akte not found');

		// Delete Akte
		$deleteResult = $this->_ci->AkteModel->delete(getData($akteResult)[0]->akte_id);

		if (isError($deleteResult)) return $deleteResult;

		// Remove all dms entry for dms of the akte
		$removeAllResult = $this->_ci->dmslib->removeAll(getData($akteResult)[0]->dms_id);

		return $removeAllResult;
	}
}