Merge branch 'master' into feature-35768/Studstatus_Status_Abgebrochen_fuer_Wiederholerdeadline_verwenden

application/models/education/Pruefung_model.php

@@ -211,7 +211,7 @@ class Pruefung_model extends DB_Model
 		$this->db->where('ps.prestudent_id', $prestudent_id);
 
 		if ($max_date !== null) {
-			$this->db->where('p.datum <', $max_date);
+			$this->db->where('p.datum <=', $max_date);
 		}
 		if ($studiensemester_kurzbz !== null) {
 			$this->db->where('le.studiensemester_kurzbz', $studiensemester_kurzbz);

application/models/education/Studierendenantrag_model.php

@@ -54,7 +54,7 @@ class Studierendenantrag_model extends DB_Model
 		$this->addJoin('public.tbl_person', 'person_id');
 		$this->addJoin('public.tbl_studiengang stg', 'p.studiengang_kz=stg.studiengang_kz');
 		$this->addJoin('public.tbl_studiensemester ss', 'studiensemester_kurzbz');
-		$this->addJoin('public.tbl_prestudentstatus ps', 'ps.prestudent_id=p.prestudent_id AND ps.studiensemester_kurzbz=ss.studiensemester_kurzbz AND ps.status_kurzbz=get_rolle_prestudent(p.prestudent_id, ss.studiensemester_kurzbz)');
+		$this->addJoin('public.tbl_prestudentstatus ps', 'ps.prestudent_id=p.prestudent_id AND ps.studiensemester_kurzbz=ss.studiensemester_kurzbz AND ps.status_kurzbz=get_rolle_prestudent(p.prestudent_id, ss.studiensemester_kurzbz)', 'LEFT');
 		$this->addJoin('lehre.tbl_studienplan plan', 'studienplan_id', 'LEFT');
 		$this->addJoin('bis.tbl_orgform of', 'of.orgform_kurzbz=COALESCE(plan.orgform_kurzbz, ps.orgform_kurzbz, stg.orgform_kurzbz)');
 		$this->addJoin(

application/models/person/Benutzerfunktion_model.php

@@ -180,4 +180,60 @@ class Benutzerfunktion_model extends DB_Model
 
         return $this->execQuery($query, $parameters_array);
     }
+
+
+	public function insertBenutzerfunktion($Json)
+	{
+		unset($Json['benutzerfunktion_id']);
+        unset($Json['updateamum']);
+        $Json['insertvon'] = getAuthUID();
+        $Json['insertamum'] = $this->escape('NOW()');
+
+		if ($Json['datum_bis']=='')
+		{
+			unset($Json['datum_bis']);
+		}
+
+        $result = $this->insert($Json);
+
+        if (isError($result))
+        {
+            return error($result->msg, EXIT_ERROR);
+        }
+
+        $record = $this->load($result->retval);
+
+        return $record;
+	}
+
+	function updateBenutzerfunktion($funktionJson)
+    {
+        $funktionJson['updatevon'] = getAuthUID();
+        $funktionJson['updateamum'] = $this->escape('NOW()');
+
+        $result = $this->update($funktionJson['benutzerfunktion_id'], $funktionJson);
+
+        if (isError($result))
+        {
+            return error($result->msg, EXIT_ERROR);
+        }
+
+        $result = $this->load($funktionJson['benutzerfunktion_id']);
+
+        return $result;
+    }
+	
+	function deleteBenutzerfunktion($funktionJson)
+    {
+        $result = $this->delete($funktionJson);
+
+        if (isError($result))
+        {
+            return error($result->msg, EXIT_ERROR);
+        }
+
+        return success($funktionJson);
+    }
+
+
 }

application/models/person/Person_model.php

@@ -1,5 +1,22 @@
 <?php
 
+/**
+ * Copyright (C) 2023 fhcomplete.org
+ *
+ * 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 3 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, see <https://www.gnu.org/licenses/>.
+ */
+
 class Person_model extends DB_Model
 {
 	/**
@@ -8,6 +25,7 @@ class Person_model extends DB_Model
 	public function __construct()
 	{
 		parent::__construct();
+
 		$this->dbTable = 'public.tbl_person';
 		$this->pk = 'person_id';
 
@@ -70,7 +88,7 @@ class Person_model extends DB_Model
 		if (isset($person['svnr']) && $person['svnr'] != '')
 		{
 			$this->PersonModel->addOrder('svnr', 'DESC');
-			$result =  $this->PersonModel->loadWhere(array(
+			$result = $this->PersonModel->loadWhere(array(
 				'person_id != ' => $person['person_id'],
 				'SUBSTRING(svnr FROM 1 FOR 10) = ' => $person['svnr'])
 			);
@@ -138,7 +156,8 @@ class Person_model extends DB_Model
 			'lower(nachname) like '.$this->db->escape('%'.$filter.'%')."
 			OR lower(vorname) like ".$this->db->escape('%'.$filter.'%')."
 			OR lower(nachname || ' ' || vorname) like ".$this->db->escape('%'.$filter.'%')."
-			OR lower(vorname || ' ' || nachname) like ".$this->db->escape('%'.$filter.'%'));
+			OR lower(vorname || ' ' || nachname) like ".$this->db->escape('%'.$filter.'%')
+		);
 
 		return $result;
 	}
@@ -152,8 +171,12 @@ class Person_model extends DB_Model
 	 */
 	public function getPersonStammdaten($person_id, $zustellung_only = false)
 	{
-		$this->addSelect('public.tbl_person.*, tbl_person.staatsbuergerschaft AS staatsbuergerschaft_code, tbl_person.geburtsnation AS geburtsnation_code, 
-		s.kurztext as staatsbuergerschaft, g.kurztext as geburtsnation');
+		$this->addSelect('public.tbl_person.*,
+			tbl_person.staatsbuergerschaft AS staatsbuergerschaft_code,
+			tbl_person.geburtsnation AS geburtsnation_code, 
+			s.kurztext as staatsbuergerschaft,
+			g.kurztext as geburtsnation'
+		);
 		$this->addJoin('bis.tbl_nation s', 'public.tbl_person.staatsbuergerschaft = s.nation_code', 'LEFT');
 		$this->addJoin('bis.tbl_nation g', 'public.tbl_person.geburtsnation = g.nation_code', 'LEFT');
 
@@ -258,7 +281,8 @@ class Person_model extends DB_Model
 	 */
 	public function getFullName($uid)
 	{
-		if (!$result = getData($this->getByUid($uid))[0])
+		$result = getData($this->getByUid($uid))[0];
+		if (!$result)
 		{
 			show_error('Failed loading person');
 		}
@@ -351,3 +375,4 @@ class Person_model extends DB_Model
 		]);
 	}
 }
+

application/models/ressource/Mitarbeiter_model.php

@@ -144,10 +144,15 @@ class Mitarbeiter_model extends DB_Model
 	 * Checks if alias exists
 	 * @param $kurzbz
 	 */
-	public function kurzbzExists($kurzbz)
+	public function kurzbzExists($kurzbz, $uid=null)
 	{
 		$this->addSelect('1');
-		$result = $this->loadWhere(array('kurzbz' => $kurzbz));
+		$where = array('kurzbz' => $kurzbz);
+		if ($uid != null)
+		{
+			$where['mitarbeiter_uid<>'] = $uid;
+		}
+		$result = $this->loadWhere($where);
 
 		if (isSuccess($result))
 		{
@@ -171,7 +176,6 @@ class Mitarbeiter_model extends DB_Model
 	 */
 	public function generateKurzbz($uid)
 	{
-		$kurzbz = '';
 		$this->addLimit(1);
 		$this->addSelect('vorname, nachname');
 		$this->addJoin('public.tbl_benutzer', 'tbl_mitarbeiter.mitarbeiter_uid = tbl_benutzer.uid');
@@ -181,25 +185,35 @@ class Mitarbeiter_model extends DB_Model
 		if (hasData($nameresult))
 		{
 			$kurzbzdata = getData($nameresult);
-			$nachname_clean = sanitizeProblemChars($kurzbzdata[0]->nachname);
-			$vorname_clean = sanitizeProblemChars($kurzbzdata[0]->vorname);
+			$genKurzbz = $this->generateKurzbzHelper($kurzbzdata[0]->vorname, $kurzbzdata[0]->nachname);
 
-			for ($nn = 6, $vn = 2; $nn != 0; $nn--, $vn++)
-			{
-				$kurzbz = mb_substr($nachname_clean, 0, $nn);
-				$kurzbz .= mb_substr($vorname_clean, 0, $vn);
+			return $genKurzbz;
+		}
+		return error('No Kurzbezeichnung could be generated');
+	}
 
-				$kurzbzexists = $this->kurzbzExists($kurzbz);
+	public function generateKurzbzHelper($vorname, $nachname)
+	{
+		$nachname_clean = sanitizeProblemChars($nachname);
+		$vorname_clean = sanitizeProblemChars($vorname);
+		$kurzbz = '';
 
-				if (hasData($kurzbzexists) && !getData($kurzbzexists)[0])
-					break;
-			}
+		for ($nn = 6, $vn = 2; $nn != 0; $nn--, $vn++)
+		{
+			$kurzbz = mb_substr($nachname_clean, 0, $nn);
+			$kurzbz .= mb_substr($vorname_clean, 0, $vn);
 
 			$kurzbzexists = $this->kurzbzExists($kurzbz);
 
-			if (hasData($kurzbzexists) && getData($kurzbzexists)[0])
-				return error('No Kurzbezeichnung could be generated');
+			if (hasData($kurzbzexists) && !getData($kurzbzexists)[0])
+				break;
 		}
+
+		$kurzbzexists = $this->kurzbzExists($kurzbz);
+
+		if (hasData($kurzbzexists) && getData($kurzbzexists)[0])
+			return error('No Kurzbezeichnung could be generated');
+	
 		return success($kurzbz);
 	}
 }

application/models/ressource/Stundensatz_model.php

@@ -0,0 +1,17 @@
+<?php
+
+class Stundensatz_model extends DB_Model
+{
+	
+	/**
+	 * Constructor
+	 */
+	public function __construct()
+	{
+		parent::__construct();
+		$this->dbTable = 'hr.tbl_stundensatz';
+		$this->pk = 'stundensatz_id';
+		$this->hasSequence = true;
+	}
+	
+}

application/models/ressource/Stundensatztyp_model.php

@@ -0,0 +1,16 @@
+<?php
+
+class Stundensatztyp_model extends DB_Model
+{
+	
+	/**
+	 * Constructor
+	 */
+	public function __construct()
+	{
+		parent::__construct();
+		$this->dbTable = 'hr.tbl_stundensatztyp';
+		$this->pk = 'stundensatztyp';
+	}
+	
+}

application/models/system/PersonLog_model.php

@@ -1,5 +1,22 @@
 <?php
 
+/**
+ * Copyright (C) 2023 fhcomplete.org
+ *
+ * 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 3 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, see <https://www.gnu.org/licenses/>.
+ */
+
 class PersonLog_model extends DB_Model
 {
 	/**
@@ -17,7 +34,7 @@ class PersonLog_model extends DB_Model
 	 * @param array $data Data of Log Entry to save.
 	 * @return success object if true
 	 */
-	public function insert($data)
+	public function insert($data, $encryptedColumns = null)
 	{
 		$result = $this->db->insert($this->dbTable, $data);
 		if ($result)

application/models/vertragsbestandteil/Dienstverhaeltnis_model.php

@@ -0,0 +1,176 @@
+<?php
+
+class Dienstverhaeltnis_model extends DB_Model
+{
+
+    public function __construct()
+	{
+		parent::__construct();
+		$this->dbTable = 'hr.tbl_dienstverhaeltnis';
+		$this->pk = 'dienstverhaeltnis_id';
+	}
+
+    /**
+     * @return list of DV
+     */
+    public function getDVByPersonUID($uid, $oe_kurzbz=null, $datum=null)
+    {
+        $result = null;
+
+		$qry = "
+        SELECT 
+            dv.dienstverhaeltnis_id,
+            tbl_benutzer.uid,
+            tbl_mitarbeiter.personalnummer,
+            tbl_mitarbeiter.kurzbz,
+            tbl_mitarbeiter.lektor,
+            tbl_mitarbeiter.fixangestellt,
+            tbl_person.person_id,
+            tbl_benutzer.alias,
+            org.oe_kurzbz,
+            org.bezeichnung oe_bezeichnung,
+            dv.von,
+            dv.bis,     
+            dv.vertragsart_kurzbz,       
+            dv.updateamum,
+            dv.updatevon
+        FROM tbl_mitarbeiter
+            JOIN tbl_benutzer ON tbl_mitarbeiter.mitarbeiter_uid::text = tbl_benutzer.uid::text
+            JOIN tbl_person USING (person_id)
+            JOIN hr.tbl_dienstverhaeltnis dv ON(tbl_benutzer.uid::text = dv.mitarbeiter_uid::text)
+            JOIN public.tbl_organisationseinheit org USING(oe_kurzbz)
+        WHERE tbl_benutzer.uid=?";
+		$data = array($uid);
+
+		if(!is_null($oe_kurzbz))
+		{
+			$qry.=" AND oe_kurzbz=?";
+			$data[] = $oe_kurzbz;
+		}
+
+		if (!is_null($datum))
+		{
+			$qry.=" AND ? BETWEEN dv.von AND COALESCE(dv.bis, '2999-12-31')";
+			$data[] = $datum;
+		}
+
+		$qry .="
+        ORDER BY dv.von desc
+        ";
+
+        return $this->execQuery($qry, $data);
+		
+    }
+
+    public function getDVByID($dvid) {
+        $this->addSelect('hr.tbl_dienstverhaeltnis.*, public.tbl_organisationseinheit.bezeichnung as unternehmen');
+		$this->addJoin('public.tbl_organisationseinheit', 'hr.tbl_dienstverhaeltnis.oe_kurzbz = public.tbl_organisationseinheit.oe_kurzbz');
+		$result = $this->load($dvid); 
+
+		if (hasData($result)) {
+            return $result;
+        }
+        return error('could not fetch DV by ID');
+    }
+
+
+    public function getCurrentDVByPersonUID($uid, $dateAsUnixTS)
+    {
+
+        $date = DateTime::createFromFormat( 'U', $dateAsUnixTS );
+        $datestring = $date->format("Y-m-d");
+
+		$qry = "
+        SELECT 
+            dv.dienstverhaeltnis_id,
+            tbl_benutzer.uid,
+            tbl_mitarbeiter.personalnummer,
+            tbl_mitarbeiter.kurzbz,
+            tbl_mitarbeiter.lektor,
+            tbl_mitarbeiter.fixangestellt,
+            tbl_person.person_id,
+            tbl_benutzer.alias,
+            dv.von,
+            dv.bis,
+            dv.vertragsart_kurzbz,
+            dv.updateamum,
+            dv.updatevon
+        FROM tbl_mitarbeiter
+            JOIN tbl_benutzer ON tbl_mitarbeiter.mitarbeiter_uid::text = tbl_benutzer.uid::text
+            JOIN tbl_person USING (person_id)
+            JOIN hr.tbl_dienstverhaeltnis dv ON(tbl_benutzer.uid::text = dv.mitarbeiter_uid::text)
+        WHERE tbl_benutzer.uid=? and (dv.von<=? and (dv.bis is null OR dv.bis>=?))
+        ORDER BY dv.von desc
+        ";
+
+        return $this->execQuery($qry, array($uid, $datestring, $datestring));
+    }
+
+	public function isOverlappingExistingDV($mitarbeiter_uid, $oe_kurzbz, $von, $bis, $dvid=null)
+	{
+		$params = array($mitarbeiter_uid, $oe_kurzbz, $von, $bis, $von, $bis);
+		$dvidclause = '';
+		if (intval($dvid) > 0)
+		{
+			$params = array_merge($params, array($dvid, $dvid));
+			$dvidclause = <<<EODVIDC
+            AND (
+				SELECT 
+					COUNT(*) AS karenzen 
+				FROM 
+					hr.tbl_vertragsbestandteil vb 
+				WHERE 
+					vb.dienstverhaeltnis_id = ?
+				AND 
+					vb.vertragsbestandteiltyp_kurzbz = 'karenz' 
+				AND 
+					dv.von::date >= COALESCE(vb.von, '1970-01-01'::date) 
+				AND 
+					COALESCE(dv.bis::date, '2170-12-31'::date) <= COALESCE(vb.bis, '2170-12-31') 
+			) = 0
+			AND dv.dienstverhaeltnis_id != ?
+EODVIDC;
+		
+		}
+		
+		$query = <<<EOSQL
+			SELECT 
+				count(*) AS dvcount
+			FROM
+				hr.tbl_dienstverhaeltnis dv
+			WHERE
+				dv.mitarbeiter_uid = ?
+			AND
+				dv.oe_kurzbz = ?
+			AND 
+				dv.vertragsart_kurzbz != 'werkvertrag' 
+			AND
+				?::date <= COALESCE(dv.bis, '2170-12-31'::date)
+			AND 
+				COALESCE(?::date, '2170-12-31'::date) >= dv.von 
+			AND (
+				SELECT 
+					COUNT(*) AS karenzen 
+				FROM 
+					hr.tbl_vertragsbestandteil vb 
+				WHERE 
+					vb.dienstverhaeltnis_id = dv.dienstverhaeltnis_id
+				AND 
+					vb.vertragsbestandteiltyp_kurzbz = 'karenz' 
+				AND 
+					?::date >= COALESCE(vb.von, '1970-01-01'::date) 
+				AND 
+					COALESCE(?::date, '2170-12-31'::date) <= COALESCE(vb.bis, '2170-12-31') 
+			) = 0 
+			{$dvidclause}
+EOSQL;
+		
+		$ret = $this->execReadOnlyQuery($query, $params);
+		
+		if( ($dvcount = getData($ret)) && ($dvcount[0]->dvcount > 0) ) {
+			return true;
+		}
+		
+		return false;	
+	}
+}

application/models/vertragsbestandteil/Gehaltsbestandteil_model.php

@@ -0,0 +1,147 @@
+<?php
+require_once __DIR__ . '/IEncryption.php';
+
+use vertragsbestandteil\Gehaltsbestandteil;
+
+class Gehaltsbestandteil_model extends DB_Model implements IEncryption
+{
+
+    public function __construct()
+	{
+		parent::__construct();
+		$this->dbTable = 'hr.tbl_gehaltsbestandteil';
+		$this->pk = 'gehaltsbestandteil_id';
+	}
+
+    public function getEncryptedColumns(): array
+    {
+		return array(
+			'grundbetrag' => array(
+				DB_Model::CRYPT_CAST => 'numeric',
+				DB_Model::CRYPT_PASSWORD_NAME => 'ENCRYPTIONKEYGEHALT'
+			),
+			'betrag_valorisiert' => array(
+				DB_Model::CRYPT_CAST => 'numeric',
+				DB_Model::CRYPT_PASSWORD_NAME => 'ENCRYPTIONKEYGEHALT'
+			)
+		);
+    }
+
+    public function getCurrentGBTByDV($dienstverhaeltnis_id, $dateAsUnixTS)
+    {
+		$date = DateTime::createFromFormat( 'U', $dateAsUnixTS );
+        $datestring = $date->format("Y-m-d");
+
+		$qry = "
+        SELECT
+            gehaltsbestandteil_id,
+            gbt.von,
+            gbt.bis,
+            gbt.anmerkung,
+            gbt.dienstverhaeltnis_id,
+            gehaltstyp_kurzbz,
+            valorisierungssperre,
+            gbt.valorisierung,
+            grundbetrag as grund_betrag_decrypted,
+            betrag_valorisiert as betrag_val_decrypted,
+            gt.bezeichnung as gehaltstyp_bezeichnung,
+			vb.vertragsbestandteiltyp_kurzbz,
+			bf.funktion_kurzbz,
+			bf.oe_kurzbz,
+			fkt.beschreibung as fkt_beschreibung,
+			fb.bezeichnung as fb_bezeichnung,
+			org.bezeichnung as org_bezeichnung,
+			freitext.freitexttyp_kurzbz,
+			freitext.titel as freitext_titel
+        FROM hr.tbl_gehaltsbestandteil gbt LEFT JOIN hr.tbl_gehaltstyp gt using(gehaltstyp_kurzbz)
+			LEFT JOIN hr.tbl_vertragsbestandteil vb using(vertragsbestandteil_id)
+			LEFT JOIN hr.tbl_vertragsbestandteil_funktion vbf using(vertragsbestandteil_id)
+			LEFT JOIN public.tbl_benutzerfunktion bf using(benutzerfunktion_id)
+			LEFT JOIN public.tbl_funktion fkt using(funktion_kurzbz)
+			LEFT JOIN public.tbl_fachbereich fb using(fachbereich_kurzbz)
+			LEFT JOIN public.tbl_organisationseinheit org on (bf.oe_kurzbz=org.oe_kurzbz)
+			LEFT JOIN hr.tbl_vertragsbestandteil_freitext freitext on(vb.vertragsbestandteil_id=freitext.vertragsbestandteil_id)
+        WHERE gbt.dienstverhaeltnis_id=? AND
+			(gbt.von<=? and (gbt.bis is null OR gbt.bis>=?))
+        ORDER BY gt.sort
+        ";
+
+        return $this->execQuery($qry,
+			array($dienstverhaeltnis_id, $datestring, $datestring),
+			$this->getEncryptedColumns());
+    }
+
+	public function getGBTChartDataByDV_old($dienstverhaeltnis_id)
+    {		
+
+		$qry = "
+        WITH gbt as
+			(select von,bis,grundbetrag as grund_betrag_decrypted  from hr.tbl_gehaltsbestandteil where dienstverhaeltnis_id=?)
+			select von,bis, (select sum(gbt.grund_betrag_decrypted) as sum_betrag
+			from gbt where gbt.von<=gbtmeta.von and (gbt.bis is null or gbt.bis>=gbtmeta.von)
+			) as summe from gbt as gbtmeta order by von,bis
+        ";
+
+        return $this->execQuery($qry,
+			array($dienstverhaeltnis_id),
+			$this->getEncryptedColumns());
+    }
+
+	
+	public function getGehaltsbestandteile($dienstverhaeltnis_id, $stichtag=null, $includefuture=false)
+	{
+		$stichtagclause = '';
+		if( !is_null($stichtag) )
+		{
+			$date = strftime('%Y-%m-%d', strtotime($stichtag));
+			$stichtagclause = 'AND (' . $this->escape($date)
+				. ' BETWEEN COALESCE(von, \'1970-01-01\'::date)'
+				. ' AND COALESCE(bis, \'2170-01-01\'::date)';
+			if( $includefuture ) 
+			{
+				$stichtagclause .= ' OR COALESCE(von, \'1970-01-01\'::date) > ' 
+					. $this->escape($date);
+			}
+			$stichtagclause .= ')';
+		}
+
+		$this->addSelect('*');
+		$where = <<<EOSQL
+				dienstverhaeltnis_id = {$this->escape($dienstverhaeltnis_id)} 
+				{$stichtagclause}
+EOSQL;
+
+		$query = $this->loadWhere(
+			$where,
+			$this->getEncryptedColumns()
+		);
+
+		$gehaltsbestandteile = array(); 
+		if( null !== ($rows = getData($query)) )
+		{
+			foreach( $rows as $row ) {
+				$tmpgb = new Gehaltsbestandteil();
+				$tmpgb->hydrateByStdClass($row, true);
+				$gehaltsbestandteile[] = $tmpgb;
+			}
+		}
+
+		return $gehaltsbestandteile;
+	}
+
+
+	public function getGehaltsbestandteil($id)
+	{	
+		$this->addSelect('*');
+		$query = $this->load($id, $this->getEncryptedColumns());
+		$gehaltsbestandteil = null;
+		
+		if( null !== ($row = getData($query)) )
+		{
+			$gehaltsbestandteil = new Gehaltsbestandteil();
+			$gehaltsbestandteil->hydrateByStdClass($row[0], true);
+		}
+
+		return $gehaltsbestandteil;
+	}
+}

application/models/vertragsbestandteil/IEncryption.php

@@ -0,0 +1,7 @@
+<?php
+
+interface IEncryption {
+ 
+    public function getEncryptedColumns(): array;
+
+}

application/models/vertragsbestandteil/VertragsbestandteilFreitext_model.php

@@ -0,0 +1,51 @@
+<?php
+
+class VertragsbestandteilFreitext_model extends DB_Model
+{
+
+	public function __construct()
+	{
+		parent::__construct();
+		$this->dbTable = 'hr.tbl_vertragsbestandteil_freitext';
+		$this->pk = 'vertragsbestandteil_id';
+	}
+	
+	public function countOverlappingVBFreitextsOfSameType(vertragsbestandteil\VertragsbestandteilFreitext $vbft)
+	{
+		$notselfclause = (intval($vbft->getVertragsbestandteil_id()) > 0) 
+			? 'AND v.vertragsbestandteil_id <> ' . $this->escape($vbft->getVertragsbestandteil_id()) 
+			: '';
+		$sql = <<<EOSQL
+			SELECT
+				count(*) AS overlappingvbs
+			FROM
+				hr.tbl_vertragsbestandteil v
+			JOIN
+				hr.tbl_vertragsbestandteil_freitext vbft USING(vertragsbestandteil_id)
+			WHERE
+				v.dienstverhaeltnis_id = ? 
+			AND 
+				v.vertragsbestandteiltyp_kurzbz = ? 
+			AND
+				vbft.freitexttyp_kurzbz = ?
+			AND 
+				COALESCE(?::date, '2170-12-31'::date) >= COALESCE(v.von, '1970-01-01'::date) 
+			AND 
+				?::date <= COALESCE(v.bis, '2170-12-31')
+			{$notselfclause}
+EOSQL;
+		$ret = $this->execReadOnlyQuery($sql, array(
+			$vbft->getDienstverhaeltnis_id(), 
+			$vbft->getVertragsbestandteiltyp_kurzbz(), 
+			$vbft->getFreitexttypKurzbz(),
+			$vbft->getBis(), 
+			$vbft->getVon()
+		));
+		
+		if( null === ($vbcount = getData($ret)) ) {
+			throw new Exception('failed to fetch overlappingvbs count');
+		}
+		
+		return $vbcount[0]->overlappingvbs;
+	}
+}

application/models/vertragsbestandteil/VertragsbestandteilFreitexttyp_model.php

@@ -0,0 +1,12 @@
+<?php
+
+class VertragsbestandteilFreitexttyp_model extends DB_Model
+{
+
+	public function __construct()
+	{
+		parent::__construct();
+		$this->dbTable = 'hr.tbl_vertragsbestandteil_freitexttyp';
+		$this->pk = 'freitexttyp_kurzbz';
+	}
+}

application/models/vertragsbestandteil/VertragsbestandteilFunktion_model.php

@@ -0,0 +1,35 @@
+<?php
+/**
+ * Description of VertragsbestandteilFunktion_model
+ *
+ * @author bambi
+ */
+class VertragsbestandteilFunktion_model extends DB_Model
+{
+	/**
+	 * Constructor
+	 */
+	public function __construct()
+	{
+		parent::__construct();
+		$this->dbTable = 'hr.tbl_vertragsbestandteil_funktion';
+		$this->pk = 'vertragsbestandteil_id';
+	}
+	
+	public function isBenutzerfunktionAlreadyAttachedToAnotherVB($benutzerfunktion_id, $vertragsbestandteil_id)
+	{
+		$where = array('benutzerfunktion_id' => $benutzerfunktion_id);
+		if( intval($vertragsbestandteil_id) > 0 ) 
+		{
+			$where['vertragsbestandteil_id != '] = $vertragsbestandteil_id;
+		}
+		$this->addSelect('count(*) AS vbscount');
+		$res = $this->loadWhere($where);
+		if(isError($res)) 
+		{
+			throw new Exception('failed to check if benutzerfunktionid is already attached to another vertragsbestanteil');
+		}
+		$count = (getData($res))[0]->vbscount;
+		return $count > 0;
+	}
+}

application/models/vertragsbestandteil/VertragsbestandteilKarenz_model.php

@@ -0,0 +1,14 @@
+<?php
+
+class VertragsbestandteilKarenz_model extends DB_Model
+{
+	/**
+	 * Constructor
+	 */
+	public function __construct()
+	{
+		parent::__construct();
+		$this->dbTable = 'hr.tbl_vertragsbestandteil_karenz';
+		$this->pk = 'vertragsbestandteil_id';
+	}
+}

application/models/vertragsbestandteil/VertragsbestandteilKuendigungsfrist_model.php

@@ -0,0 +1,14 @@
+<?php
+
+class VertragsbestandteilKuendigungsfrist_model extends DB_Model
+{
+	/**
+	 * Constructor
+	 */
+	public function __construct()
+	{
+		parent::__construct();
+		$this->dbTable = 'hr.tbl_vertragsbestandteil_kuendigungsfrist';
+		$this->pk = 'vertragsbestandteil_id';
+	}
+}

application/models/vertragsbestandteil/VertragsbestandteilStunden_model.php

@@ -0,0 +1,18 @@
+<?php
+/**
+ * Description of VertragsbestandteilStunden_model
+ *
+ * @author bambi
+ */
+class VertragsbestandteilStunden_model extends DB_Model
+{
+	/**
+	 * Constructor
+	 */
+	public function __construct()
+	{
+		parent::__construct();
+		$this->dbTable = 'hr.tbl_vertragsbestandteil_stunden';
+		$this->pk = 'vertragsbestandteil_id';
+	}
+}

application/models/vertragsbestandteil/VertragsbestandteilTyp_model.php

@@ -0,0 +1,12 @@
+<?php
+
+class VertragsbestandteilTyp_model extends DB_Model
+{
+
+	public function __construct()
+	{
+		parent::__construct();
+		$this->dbTable = 'hr.tbl_vertragsbestandteiltyp';
+		$this->pk = 'vertragsbestandteiltyp_kurzbz';
+	}
+}

application/models/vertragsbestandteil/VertragsbestandteilUrlaubsanspruch_model.php

@@ -0,0 +1,11 @@
+<?php
+
+class VertragsbestandteilUrlaubsanspruch_model extends DB_Model
+{
+	public function __construct()
+	{
+		parent::__construct();
+		$this->dbTable = 'hr.tbl_vertragsbestandteil_urlaubsanspruch';
+		$this->pk = 'vertragsbestandteil_id';
+	}
+}

application/models/vertragsbestandteil/VertragsbestandteilZeitaufzeichnung_model.php

@@ -0,0 +1,12 @@
+<?php
+
+class VertragsbestandteilZeitaufzeichnung_model extends DB_Model
+{
+
+	public function __construct()
+	{
+		parent::__construct();
+		$this->dbTable = 'hr.tbl_vertragsbestandteil_zeitaufzeichnung';
+		$this->pk = 'vertragsbestandteil_id';
+	}
+}

application/models/vertragsbestandteil/Vertragsbestandteil_model.php

@@ -0,0 +1,181 @@
+<?php
+use vertragsbestandteil\VertragsbestandteilFactory;
+/**
+ * Description of Vertragsbestandteil_model
+ *
+ * @author bambi
+ */
+class Vertragsbestandteil_model extends DB_Model
+{
+	/**
+	 * Constructor
+	 */
+	public function __construct()
+	{
+		parent::__construct();
+		$this->dbTable = 'hr.tbl_vertragsbestandteil';
+		$this->pk = 'vertragsbestandteil_id';
+	}
+
+	protected function getVertragsbestandteilSQL()
+	{
+		$sql = <<<EOSQL
+		SELECT
+				v.*,
+				bf.funktion_kurzbz, bf.uid AS mitarbeiter_uid, 
+				funktion.beschreibung AS funktion_bezeichnung, 			    
+				oe.oe_kurzbz, oe.bezeichnung AS oe_bezeichnung, sap.oe_kurzbz_sap,
+				oet.organisationseinheittyp_kurzbz AS oe_typ_kurzbz, oet.bezeichnung AS oe_typ_bezeichnung,
+				ft.freitexttyp_kurzbz, ft.titel, ft.anmerkung,
+				f.benutzerfunktion_id,
+				k.karenztyp_kurzbz, k.geplanter_geburtstermin, k.tatsaechlicher_geburtstermin,
+				kf.arbeitgeber_frist, kf.arbeitnehmer_frist,
+				s.wochenstunden, s.teilzeittyp_kurzbz,
+				u.tage,
+				z.zeitaufzeichnung, z.azgrelevant, z.homeoffice
+			FROM
+				hr.tbl_vertragsbestandteil v
+			LEFT JOIN
+				hr.tbl_vertragsbestandteil_freitext ft USING(vertragsbestandteil_id)
+			LEFT JOIN
+				hr.tbl_vertragsbestandteil_funktion f USING(vertragsbestandteil_id)
+			LEFT JOIN 
+				public.tbl_benutzerfunktion bf USING(benutzerfunktion_id)
+			LEFT JOIN
+				public.tbl_funktion funktion USING(funktion_kurzbz)
+			LEFT JOIN
+				public.tbl_organisationseinheit oe USING(oe_kurzbz)
+			LEFT JOIN
+				public.tbl_organisationseinheittyp oet USING(organisationseinheittyp_kurzbz)
+			LEFT JOIN
+				sync.tbl_sap_organisationsstruktur sap USING(oe_kurzbz)
+			LEFT JOIN
+				hr.tbl_vertragsbestandteil_karenz k USING(vertragsbestandteil_id)
+			LEFT JOIN
+				hr.tbl_vertragsbestandteil_kuendigungsfrist kf USING(vertragsbestandteil_id)
+			LEFT JOIN
+				hr.tbl_vertragsbestandteil_stunden s USING(vertragsbestandteil_id)
+			LEFT JOIN
+				hr.tbl_vertragsbestandteil_urlaubsanspruch u USING(vertragsbestandteil_id)
+			LEFT JOIN
+				hr.tbl_vertragsbestandteil_zeitaufzeichnung z USING(vertragsbestandteil_id)
+EOSQL;
+		return $sql;
+	}
+
+	public function getVertragsbestandteile($dienstverhaeltnis_id, $stichtag=null, $includefuture=false)
+	{
+		$stichtagclause = '';
+		if( !is_null($stichtag) )
+		{
+			$date = strftime('%Y-%m-%d', strtotime($stichtag));
+			$stichtagclause = 'AND (' . $this->escape($date)
+				. ' BETWEEN COALESCE(v.von, \'1970-01-01\'::date)'
+				. ' AND COALESCE(v.bis, \'2170-01-01\'::date)';
+			if( $includefuture ) 
+			{
+				$stichtagclause .= ' OR COALESCE(v.von, \'1970-01-01\'::date) > ' 
+					. $this->escape($date);
+			}
+			$stichtagclause .= ')';
+		}
+
+		$sql = <<<EOSQL
+			{$this->getVertragsbestandteilSQL()}
+			WHERE
+				v.dienstverhaeltnis_id = {$this->escape($dienstverhaeltnis_id)}
+				{$stichtagclause}
+			;
+EOSQL;
+
+		// echo $sql . "\n\n";
+		$query = $this->execReadOnlyQuery($sql);   // TODO add decryption
+		$data = getData($query);
+
+		if ($data == null)
+		{
+			return array();
+		}
+
+		$vertragsbestandteile = array();
+		foreach( $data as $row ) {
+			try
+			{
+				$vertragsbestandteile[] = VertragsbestandteilFactory::getVertragsbestandteil($row, true);
+			}
+			catch (Exception $ex)
+			{
+				echo $ex->getMessage() . "\n";
+			}
+		}
+
+		$dummy = json_encode($vertragsbestandteile);
+		return $vertragsbestandteile;
+	}
+
+
+	public function getVertragsbestandteil($id)
+	{	
+
+		$sql = <<<EOSQL
+			{$this->getVertragsbestandteilSQL()}
+			WHERE
+				v.vertragsbestandteil_id = {$this->escape($id)}
+			;
+EOSQL;
+
+		$query = $this->execReadOnlyQuery($sql);		
+		
+		$vertragsbestandteil = null;
+		
+		if( hasData($query) ) 
+		{
+			$data = getData($query)[0];
+			try
+			{
+				$vertragsbestandteil = VertragsbestandteilFactory::getVertragsbestandteil($data, true);  // TODO add decryption
+			}
+			catch (Exception $ex)
+			{
+				echo $ex->getMessage() . "\n";
+			}
+		}
+		
+		return $vertragsbestandteil;
+		
+	}
+	
+	public function countOverlappingVBsOfSameType(vertragsbestandteil\Vertragsbestandteil $vb)
+	{
+		$notselfclause = (intval($vb->getVertragsbestandteil_id()) > 0) 
+			? 'AND v.vertragsbestandteil_id <> ' . $this->escape($vb->getVertragsbestandteil_id()) 
+			: '';
+		$sql = <<<EOSQL
+			SELECT
+				count(*) AS overlappingvbs
+			FROM
+				hr.tbl_vertragsbestandteil v
+			WHERE
+				v.dienstverhaeltnis_id = ? 
+			AND 
+				v.vertragsbestandteiltyp_kurzbz = ? 
+			AND 
+				COALESCE(?::date, '2170-12-31'::date) >= COALESCE(v.von, '1970-01-01'::date) 
+			AND 
+				?::date <= COALESCE(v.bis, '2170-12-31')
+			{$notselfclause}
+EOSQL;
+		$ret = $this->execReadOnlyQuery($sql, array(
+			$vb->getDienstverhaeltnis_id(), 
+			$vb->getVertragsbestandteiltyp_kurzbz(), 
+			$vb->getBis(), 
+			$vb->getVon()
+		));
+		
+		if( null === ($vbcount = getData($ret)) ) {
+			throw new Exception('failed to fetch overlappingvbs count');
+		}
+		
+		return $vbcount[0]->overlappingvbs;
+	}
+}