FHC-Core/application/models/person/Notiz_model.php

<?php

class Notiz_model extends DB_Model
{
	/**
	 * Constructor
	 */
	public function __construct()
	{
		parent::__construct();
		$this->dbTable = 'public.tbl_notiz';
		$this->pk = 'notiz_id';
	}
	
	// ------------------------------------------------------------------------------------------------------
	/**
	 * Get a specialization for a prestudent
	 */
	public function getSpecialization($prestudent_id, $titel)
	{
		// Join with the table public.tbl_notizzuordnung using notiz_id
		$this->addJoin('public.tbl_notizzuordnung', 'notiz_id');
		
		return $this->NotizModel->loadWhere(array('prestudent_id' => $prestudent_id, 'titel' => $titel));
	}
	
	/**
	 * Remove a specialization
	 */
	public function rmSpecialization($notiz_id)
	{
		// Loads model Notizzuordnung_model
		$this->load->model('person/Notizzuordnung_model', 'NotizzuordnungModel');
		
		// Start DB transaction
		$this->db->trans_start(false);
		
		$result = $this->delete(array('notiz_id' => $notiz_id));
		if (isSuccess($result))
		{
			$result = $this->NotizzuordnungModel->delete(array('notiz_id' => $notiz_id));
		}
		
		// Transaction complete!
		$this->db->trans_complete();
		
		// Check if everything went ok during the transaction
		if ($this->db->trans_status() === false || isError($result))
		{
			$this->db->trans_rollback();
			$result = error($result->msg, EXIT_ERROR);
		}
		else
		{
			$this->db->trans_commit();
			$result = success('Specialization successfully removed');
		}
		
		return $result;
	}

	/**
	 * Add a specialization for a prestudent
	 */
	public function addSpecialization($prestudent_id, $titel, $text)
	{
		// Loads model Notizzuordnung_model
		$this->load->model('person/Notizzuordnung_model', 'NotizzuordnungModel');
		
		// Start DB transaction
		$this->db->trans_start(false);
		
		$result = $this->insert(array('titel' => $titel, 'text' => $text, 'erledigt' => true));
		$notiz_id = $result->retval;
		if (isSuccess($result))
		{
			$result = $this->NotizzuordnungModel->insert(array('notiz_id' => $notiz_id, 'prestudent_id' => $prestudent_id));
		}
		
		// Transaction complete!
		$this->db->trans_complete();
		
		// Check if everything went ok during the transaction
		if ($this->db->trans_status() === false || isError($result))
		{
			$this->db->trans_rollback();
			$result = error($result->msg, EXIT_ERROR);
		}
		else
		{
			$this->db->trans_commit();
			$result = success($notiz_id);
		}
		
		return $result;
	}

	/**
	 * Add a Notiz for a given person
	 */
	public function addNotizForPerson($person_id, $titel, $text, $erledigt, $verfasser_uid)
	{
		// Loads model Notizzuordnung_model
		$this->load->model('person/Notizzuordnung_model', 'NotizzuordnungModel');

		// Start DB transaction
		$this->db->trans_start(false);

		$result = $this->insert(array('titel' => $titel, 'text' => $text, 'erledigt' => $erledigt, 'verfasser_uid' => $verfasser_uid,
			"insertvon" => $verfasser_uid));

		if (isSuccess($result))
		{
			$notiz_id = $result->retval;
			$result = $this->NotizzuordnungModel->insert(array('notiz_id' => $notiz_id, 'person_id' => $person_id));
		}

		// Transaction complete!
		$this->db->trans_complete();

		// Check if everything went ok during the transaction
		if ($this->db->trans_status() === false || isError($result))
		{
			$this->db->trans_rollback();
			$result = error($result->msg, EXIT_ERROR);
		}
		else
		{
			$this->db->trans_commit();
			$result = success($notiz_id);
		}

		return $result;
	}

	/**
	 * gets all Notizen for a person
	 * @param $person_id
	 */
	public function getNotiz($person_id)
	{
		$this->addSelect('public.tbl_notiz.*');
		$this->addJoin('public.tbl_notizzuordnung', 'notiz_id');

		return $this->loadWhere(array('person_id' => $person_id, 'tbl_notiz.typ' => NULL));
	}

	/**
	 * gets all Notizen with Documententries for a certain type and type_id
	 * @param String type of id eg. person_id, prestudent_id, mitarbeiter_uid, projekt_kurzbz, projektphase_id, projekttask_id,
	 *         bestellung_id, lehreinheit_id, anrechnung_id, uid)
	 * @param $id the corresponding id, part of public.tbl_notizzuordnung
	 */
	public function getNotizWithDocEntries($id, $type, $withoutTags = true)
	{
			$qry = "
				SELECT
						n.*, 
						  CASE
							WHEN person_verfasser.vorname IS NOT NULL AND person_verfasser.vorname != ''
							  OR person_verfasser.nachname IS NOT NULL AND person_verfasser.nachname != ''
							THEN CONCAT(person_verfasser.vorname, ' ', person_verfasser.nachname)
							ELSE NULL
						  END AS verfasser,
						  CASE
							WHEN person_bearbeiter.vorname IS NOT NULL AND person_bearbeiter.vorname != ''
							  OR person_bearbeiter.nachname IS NOT NULL AND person_bearbeiter.nachname != ''
							THEN CONCAT(person_bearbeiter.vorname, ' ', person_bearbeiter.nachname)
							ELSE NULL
						  END AS bearbeiter,
						count(dms_id) as countDoc, z.notizzuordnung_id,
						(CASE
							WHEN n.updateamum >= n.insertamum THEN n.updateamum 
							ELSE n.insertamum
						END) AS lastUpdate,
						regexp_replace(n.text, '<[^>]*>', '', 'g') as text_stripped,
						TO_CHAR(n.start::timestamp, 'DD.MM.YYYY') AS start_format,
						TO_CHAR(n.ende::timestamp, 'DD.MM.YYYY') AS ende_format,
						z.notiz_id, z.person_id as id, ? as type_id
						
				FROM
						public.tbl_notiz n
				JOIN 
							public.tbl_notizzuordnung z USING (notiz_id)
				LEFT JOIN 
							public.tbl_notiz_dokument dok USING (notiz_id)
				LEFT JOIN 
							campus.tbl_dms_version USING (dms_id)
				LEFT JOIN 
						      public.tbl_benutzer p_verfasser ON (p_verfasser.uid = n.verfasser_uid)
  				LEFT JOIN 
						      public.tbl_person person_verfasser ON (person_verfasser.person_id = p_verfasser.person_id)
  				LEFT JOIN 
						      public.tbl_benutzer p_bearbeiter ON (p_bearbeiter.uid = n.bearbeiter_uid)
				LEFT JOIN 
						      public.tbl_person person_bearbeiter ON (person_bearbeiter.person_id = p_bearbeiter.person_id)
				WHERE 
				   z.$type  = ?";

		if ($withoutTags)
			$qry .= " AND n.typ IS NULL ";

			$qry .= "GROUP BY 
					notiz_id, z.notizzuordnung_id,
 					person_verfasser.vorname, person_verfasser.nachname,
					person_bearbeiter.vorname, person_bearbeiter.nachname
			";

		return $this->execQuery($qry, array($type, $id));
	}


	/**
	 * gets all Notizen for a person with a specific title
	 * @param $person_id
	 * @param $titel
	 */
	public function getNotizByTitel($person_id, $titel)
	{
		$this->addSelect('public.tbl_notiz.insertamum as insertnotiz, *');
		// Join with the table public.tbl_notizzuordnung using notiz_id
		$this->addJoin('public.tbl_notizzuordnung', 'notiz_id');
		$this->addJoin('public.tbl_prestudent', 'prestudent_id', 'LEFT');
		$this->addJoin('public.tbl_studiengang', 'studiengang_kz', 'LEFT');
		$this->addOrder('public.tbl_notiz.insertamum', 'DESC');

		return $this->loadWhere(array('public.tbl_notizzuordnung.person_id' => $person_id, 'titel LIKE' => $titel));
	}
	
	/**
	 * Add a Notiz for a given Anrechnung
	 * @param $anrechnung_id
	 * @param $titel
	 * @param $text
	 * @param $verfasser_uid
	 * @return array
	 */
	public function addNotizForAnrechnung($anrechnung_id, $titel, $text, $verfasser_uid)
	{
		// Loads model Notizzuordnung_model
		$this->load->model('person/Notizzuordnung_model', 'NotizzuordnungModel');
		
		// Start DB transaction
		$this->db->trans_start(false);
		
		$result = $this->insert(array(
			'titel' => $titel,
			'text' => $text,
			'erledigt' => true,
			'verfasser_uid' => $verfasser_uid,
			"insertvon" => $verfasser_uid
		));
		
		if (isSuccess($result))
		{
			$notiz_id = $result->retval;
			$result = $this->NotizzuordnungModel->insert(array('notiz_id' => $notiz_id, 'anrechnung_id' => $anrechnung_id));
		}
		
		// Transaction complete!
		$this->db->trans_complete();
		
		// Check if everything went ok during the transaction
		if ($this->db->trans_status() === false || isError($result))
		{
			$this->db->trans_rollback();
			$result = error($result->msg, EXIT_ERROR);
		}
		else
		{
			$this->db->trans_commit();
			$result = success($notiz_id);
		}
		
		return $result;
	}
	
	/**
	 * Get Notizen by Anrechnung and title ordered last first
	 *
	 * @param $anrechnung_id
	 * @return array
	 */
	public function getNotizByAnrechnung($anrechnung_id, $titel = null)
	{
		$this->addJoin('public.tbl_notizzuordnung', 'notiz_id');
		$this->addOrder('insertamum', 'DESC');
		
		if (is_string($titel))
		{
			return $this->loadWhere(array(
				'anrechnung_id' => $anrechnung_id,
				'titel'         => $titel
			));
		}
		
		return $this->loadWhere(array('anrechnung_id' => $anrechnung_id));
	}

	/**
	 * check if a given Tag for a certain notizzuordnung id is valid
	 *
	 * @param $tag typ_kurzbz to check
	 * @param $typeId typeId to check
	 * @param $id id to check
	 * @param $von start of time period or NULL
	 * @param $bis end of time period or NULL
 *
	 * @return array
	 */
	public function checkIfExistingTag($tag, $typeId, $id, $von=null, $bis=null)
	{
		$query = "
			SELECT *
			FROM public.tbl_notiz
			JOIN public.tbl_notizzuordnung nz USING (notiz_id)
			WHERE typ = ?
			AND {$typeId} = ?
			AND (
				start IS NULL
				OR ende IS NULL
				OR (start <= ? AND ende >= ?)
			)
		";

		return $this->execQuery($query, [$tag, $id, $bis, $von]);
	}

	/**
	 * returns all existing tags of a certain tag within a time period
	 *
	 * @param $tag typ_kurzbz of tag
	 * @param $von start of time period or NULL
	 * @param $bis end of time period or NULL
	 *
	 * @return array
	 */
	public function getAllTags($tag, $von=null, $bis=null)
	{
		$query = "
			SELECT *
			FROM public.tbl_notiz
			JOIN public.tbl_notizzuordnung nz USING (notiz_id)
			WHERE typ = ?
			AND (
				start IS NULL
				OR ende IS NULL
				OR (start <= ? AND ende >= ?)
			);
		";

		return $this->execQuery($query, array($tag, $bis, $von));
	}
}