Merge remote-tracking branch 'origin/feature-25562/PV21_Datenbankstruktur_fuer_Vertraege_und_Gehaelter' into feature-25562/PV21_Datenbankstruktur_fuer_Vertraege_und_Gehaelter

include/bismeldestichtag.class.php

@@ -0,0 +1,185 @@
+<?php
+/* Copyright (C) 2007 Technikum-Wien
+ *
+ * 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.
+ *
+ * Authors: Alexei Karpenko <karpenko@technikum-wien.at>,
+ */
+require_once(dirname(__FILE__).'/basis_db.class.php');
+require_once(dirname(__FILE__).'/studiensemester.class.php');
+
+class bismeldestichtag extends basis_db
+{
+	//Tabellenspalten
+	public $meldestichtag_id;		// integer
+	public $meldestichtag;			// date
+	public $studiensemester_kurzbz;	// varchar(16)
+	public $insertamum;				// timestamp
+	public $insertvon;				// varchar(32)
+	public $updateamum;				// timestamp
+	public $updatevon;				// varchar(32)
+
+	// ErgebnisArray
+	public $result=array();
+
+	/**
+	 * Konstruktor - Uebergibt die Connection und laedt optional einen Meldestichtag
+	 * @param $meldestichtag_id Stichtag der geladen werden soll (default=null)
+	 */
+	public function __construct($meldestichtag_id=null)
+	{
+		parent::__construct();
+
+		if(!is_null($meldestichtag_id))
+			$this->load($meldestichtag_id);
+	}
+
+	/**
+	 * Laedt Meldestichtag mit der uebergebenen ID
+	 * @param $meldestichtag_id ID des Stichtags der geladen werden soll
+	 */
+	public function load($meldestichtag_id)
+	{
+		$qry = "SELECT * FROM bis.tbl_bismeldestichtag WHERE meldestichtag_id=".$this->db_add_param($meldestichtag_id, FHC_INTEGER);
+
+		if($this->db_query($qry))
+		{
+			if($row = $this->db_fetch_object())
+			{
+				$this->meldestichtag_id = $row->meldestichtag_id;
+				$this->meldestichtag = $row->meldestichtag;
+				$this->studiensemester_kurzbz = $row->studiensemester_kurzbz;
+				$this->insertamum = $row->insertamum;
+				$this->insertvon = $row->insertvon;
+				$this->updateamum = $row->updateamum;
+				$this->updatevon = $row->updatevon;
+				return true;
+			}
+			else
+			{
+				$this->errormsg = 'Kein Eintrag gefunden';
+				return false;
+			}
+		}
+		else
+		{
+			$this->errormsg = "Fehler beim Laden des Stichtags";
+			return false;
+		}
+	}
+
+	/**
+	 * Prueft die Variablen vor dem Speichern
+	 * auf Gueltigkeit.
+	 * @return true wenn ok, false im Fehlerfall
+	 */
+	protected function validate()
+	{
+		return true;
+	}
+
+	/**
+	 * Liefert zuletzt erreichten Meldestichtag
+	 *
+	 * @param $studiensemester_kurzbz
+	 * @return boolean
+	 */
+	public function getLastReachedMeldestichtag($studiensemester_kurzbz = null)
+	{
+		$qry = "SELECT
+					meldestichtag_id, meldestichtag, studiensemester_kurzbz, insertamum, insertvon, updateamum, updatevon
+				FROM
+					bis.tbl_bismeldestichtag
+				WHERE
+					meldestichtag < NOW()";
+
+		if (isset($studiensemester_kurzbz))
+		{
+			$qry .=	"
+				AND
+					studiensemester_kurzbz=".$this->db_add_param($studiensemester_kurzbz);
+		}
+
+		$qry .= "
+				ORDER BY
+					meldestichtag DESC
+				LIMIT 1;";
+
+		if($this->db_query($qry))
+		{
+			while($row = $this->db_fetch_object())
+			{
+				$obj = new bismeldestichtag();
+
+				$obj->meldestichtag_id = $row->meldestichtag_id;
+				$obj->meldestichtag = $row->meldestichtag;
+				$obj->studiensemester_kurzbz = $row->studiensemester_kurzbz;
+				$obj->insertamum = $row->insertamum;
+				$obj->insertvon = $row->insertvon;
+				$obj->updateamum = $row->updateamum;
+				$obj->updatevon = $row->updatevon;
+
+				$this->result[] = $obj;
+			}
+
+			return true;
+		}
+		else
+		{
+			$this->errormsg = 'Meldestichtag konnte nicht geladen werden';
+			return false;
+		}
+	}
+
+	/**
+	 * Prüft, ob Meldestichtag für ein bestimmtes Statusdatum und Studiensemester erreicht ist.
+	 *
+	 * @param $status_datum
+	 * @param $studiensemester_kurzbz
+	 * @return boolean true wenn erreicht, oder false
+	 */
+	public function checkMeldestichtagErreicht($status_datum, $studiensemester_kurzbz = null)
+	{
+		$erreicht = false;
+
+		if (isset($studiensemester_kurzbz))
+		{
+			// Studiensemester ende holen
+			$studiensemester = new studiensemester();
+			if ($studiensemester->load($studiensemester_kurzbz))
+				$studiensemester_ende = new DateTime($studiensemester->ende);
+		}
+
+		// letztes erreichtes Bismeldedatum holen
+		if ($this->getLastReachedMeldestichtag() && isset($this->result[0]))
+			$lastReachedMeldestichtag = new DateTime($this->result[0]->meldestichtag);
+
+		$statusDatum = new DateTime($status_datum);
+
+		// Prüfen, ob Studentstatusdatum oder Studiensemester vor dem Stichtagsdatum liegen
+		if (isset($statusDatum))
+		{
+			if (isset($lastReachedMeldestichtag))
+				$erreicht = $statusDatum < $lastReachedMeldestichtag;
+
+			if (isset($studiensemester_ende))
+				$erreicht = $erreicht || $studiensemester_ende < $lastReachedMeldestichtag;
+
+		}
+
+		return $erreicht;
+	}
+}
+?>

include/konto.class.php

@@ -965,17 +965,16 @@ class konto extends basis_db
 		}
 	}
 
-	public function checkDoppelteBuchung($person_ids, $stsem, $typ)
+	public function checkDoppelteBuchung($person_ids, $stsem, $typen)
 	{
 		$qry = "SELECT person.vorname, person.nachname
 				FROM public.tbl_konto konto
 					JOIN public.tbl_person person USING(person_id)
 				WHERE konto.person_id IN (".$this->implode4SQL(array_filter($person_ids)).")
 					AND studiensemester_kurzbz = ".$this->db_add_param($stsem)."
-					AND buchungstyp_kurzbz = ".$this->db_add_param($typ)."
+					AND buchungstyp_kurzbz IN (".$this->implode4SQL($typen) .")
 				GROUP BY person.vorname, person.nachname
 				ORDER BY person.nachname, person.vorname";
-
 		if ($result = $this->db_query($qry))
 		{
 			$persons = array();

include/organisationseinheit.class.php

@@ -977,6 +977,36 @@ class organisationseinheit extends basis_db
 		}
 	}
 	
-	
+	public function getRoots()
+	{
+		$qry = "SELECT *
+				FROM public.tbl_organisationseinheit
+				WHERE oe_parent_kurzbz IS NULL AND aktiv
+				ORDER BY organisationseinheittyp_kurzbz, bezeichnung";
+		
+		if($this->db_query($qry))
+		{
+			while($row = $this->db_fetch_object())
+			{
+				$obj = new organisationseinheit();
+				
+				$obj->oe_kurzbz = $row->oe_kurzbz;
+				$obj->oe_parent_kurzbz = $row->oe_parent_kurzbz;
+				$obj->bezeichnung = $row->bezeichnung;
+				$obj->organisationseinheittyp_kurzbz = $row->organisationseinheittyp_kurzbz;
+				$obj->aktiv = $this->db_parse_bool($row->aktiv);
+				$obj->mailverteiler = $this->db_parse_bool($row->mailverteiler);
+				$obj->lehre = $this->db_parse_bool($row->lehre);
+				
+				$this->result[] = $obj;
+			}
+			return true;
+		}
+		else
+		{
+			$this->errormsg = 'Fehler beim Laden der Organisationseinheiten';
+			return false;
+		}
+	}
 }
 ?>

include/prestudent.class.php

@@ -906,6 +906,45 @@ class prestudent extends person
 							AND tbl_reihungstest.studiensemester_kurzbz=".$this->db_add_param($studiensemester_kurzbz)."
 					)";
 				break;
+			case "bewerberrtangemeldetteilgenommen":
+				$qry.=" AND a.rolle='Bewerber'
+					AND EXISTS (
+						SELECT
+							1
+						FROM
+							public.tbl_rt_person
+							JOIN public.tbl_reihungstest ON (rt_id = reihungstest_id)
+						WHERE
+							person_id=a.person_id
+							AND studienplan_id IN (
+								SELECT studienplan_id FROM lehre.tbl_studienplan
+								JOIN lehre.tbl_studienordnung USING(studienordnung_id)
+								WHERE tbl_studienordnung.studiengang_kz=a.studiengang_kz
+							)
+							AND tbl_reihungstest.studiensemester_kurzbz=".$this->db_add_param($studiensemester_kurzbz)."
+					)
+					AND reihungstestangetreten = true";
+				break;
+			case "bewerberrtangemeldetnichtteilgenommen":
+				$qry.=" AND a.rolle='Bewerber'
+					AND EXISTS (
+						SELECT
+							1
+						FROM
+							public.tbl_rt_person
+							JOIN public.tbl_reihungstest ON (rt_id = reihungstest_id)
+						WHERE
+							person_id=a.person_id
+							AND studienplan_id IN (
+								SELECT studienplan_id FROM lehre.tbl_studienplan
+								JOIN lehre.tbl_studienordnung USING(studienordnung_id)
+								WHERE tbl_studienordnung.studiengang_kz=a.studiengang_kz
+							)
+							AND tbl_reihungstest.studiensemester_kurzbz=".$this->db_add_param($studiensemester_kurzbz)."
+					)
+					AND reihungstestangetreten = false
+					";
+				break;
 			case "zgv":
 				$stg_obj = new studiengang();
 				$stg_obj->load($studiengang_kz);

include/stundensatz.class.php

@@ -19,9 +19,10 @@ class stundensatz extends basis_db
 	public $insertvon;				// varchar(16)
 	public $updateamum;				// timestamp
 	public $updatevon;				// varchar(16)
-	
 
-	
+	public $oe_bezeichnung;
+	public $stundensatztyp_bezeichnung;
+
 	public function __construct($stundensatz_id = null)
 	{
 		parent::__construct();
@@ -78,5 +79,211 @@ class stundensatz extends basis_db
 			return false;
 		}
 	}
+	
+	public function getAllStundensaetze($uid)
+	{
+		$qry = "SELECT
+					tbl_stundensatz.*,
+					tbl_organisationseinheit.bezeichnung AS oe_bezeichnung,
+					hr.tbl_stundensatztyp.bezeichnung AS stundensatztyp_bezeichnung,
+					tbl_organisationseinheit.oe_kurzbz
+				FROM
+					hr.tbl_stundensatz
+					LEFT JOIN
+						public.tbl_organisationseinheit ON tbl_stundensatz.oe_kurzbz = tbl_organisationseinheit.oe_kurzbz
+					JOIN hr.tbl_stundensatztyp USING(stundensatztyp)
+				WHERE
+					uid = ". $this->db_add_param($uid);
+
+		if ($result = $this->db_query($qry))
+		{
+			while ($row = $this->db_fetch_object($result))
+			{
+				$obj = new stundensatz();
+				$obj->stundensatz_id = $row->stundensatz_id;
+				$obj->uid = $row->uid;
+				$obj->stundensatztyp = $row->stundensatztyp;
+				$obj->stundensatz = $row->stundensatz;
+				$obj->oe_kurzbz = $row->oe_kurzbz;
+				$obj->gueltig_von = $row->gueltig_von;
+				$obj->gueltig_bis = $row->gueltig_bis;
+				$obj->insertamum = $row->insertamum;
+				$obj->insertvon = $row->insertvon;
+				$obj->updateamum = $row->updateamum;
+				$obj->updatevon = $row->updatevon;
+				$obj->oe_bezeichnung = $row->oe_bezeichnung;
+				$obj->stundensatztyp_bezeichnung = $row->stundensatztyp_bezeichnung;
+
+				$this->result[] = $obj;
+			}
+			
+			return true;
+		}
+		else
+		{
+			$this->errormsg = 'Fehler beim Laden der Daten';
+			return false;
+		}
+	}
+	
+	public function load($stundensatz_id)
+	{
+		$qry = "SELECT
+					tbl_stundensatz.*,
+					tbl_organisationseinheit.bezeichnung AS oe_bezeichnung,
+					hr.tbl_stundensatztyp.bezeichnung AS stundensatztyp_bezeichnung,
+					tbl_organisationseinheit.oe_kurzbz
+				FROM
+					hr.tbl_stundensatz
+					LEFT JOIN public.tbl_organisationseinheit ON tbl_stundensatz.oe_kurzbz = tbl_organisationseinheit.oe_kurzbz
+					JOIN hr.tbl_stundensatztyp USING(stundensatztyp)
+				WHERE
+					stundensatz_id = ".$this->db_add_param($stundensatz_id).";";
+		
+		if($this->db_query($qry))
+		{
+			if ($row = $this->db_fetch_object())
+			{
+				$this->stundensatz_id = $row->stundensatz_id;
+				$this->uid = $row->uid;
+				$this->stundensatztyp = $row->stundensatztyp;
+				$this->stundensatz = $row->stundensatz;
+				$this->oe_kurzbz = $row->oe_kurzbz;
+				$this->gueltig_von = $row->gueltig_von;
+				$this->gueltig_bis = $row->gueltig_bis;
+				$this->insertamum = $row->insertamum;
+				$this->insertvon = $row->insertvon;
+				$this->updateamum = $row->updateamum;
+				$this->updatevon = $row->updatevon;
+				$this->oe_bezeichnung = $row->oe_bezeichnung;
+				$this->stundensatztyp_bezeichnung = $row->stundensatztyp_bezeichnung;
+			}
+			return true;
+		}
+		else
+		{
+			$this->errormsg = 'Fehler beim Laden des Datensatzes';
+			return false;
+		}
+	}
+	
+	public function save($new = null)
+	{
+		if (!$this->validate())
+			return false;
+		
+		if(is_null($new))
+			$new = $this->new;
+		
+		if ($new)
+		{
+			
+			$qry = "BEGIN;INSERT INTO hr.tbl_stundensatz
+				(
+					uid,
+					stundensatz,
+					gueltig_von,
+					gueltig_bis,
+					oe_kurzbz,
+					stundensatztyp,
+					insertamum,
+					insertvon
+				)
+				VALUES
+				(" .
+					$this->db_add_param($this->uid) . "," .
+					$this->db_add_param($this->stundensatz, FHC_INTEGER) . "," .
+					$this->db_add_param($this->gueltig_von) . "," .
+					$this->db_add_param($this->gueltig_bis) . "," .
+					$this->db_add_param($this->oe_kurzbz) . "," .
+					$this->db_add_param($this->stundensatztyp) . "," .
+					$this->db_add_param($this->insertamum) . "," .
+					$this->db_add_param($this->insertvon) .
+				");";
+		}
+		else
+		{
+			$qry = "UPDATE hr.tbl_stundensatz SET " .
+				"stundensatz = " . $this->db_add_param($this->stundensatz, FHC_INTEGER) .",".
+				"oe_kurzbz = " . $this->db_add_param($this->oe_kurzbz) .",".
+				"stundensatztyp = " . $this->db_add_param($this->stundensatztyp) .",".
+				"gueltig_von = " . $this->db_add_param($this->gueltig_von) .",".
+				"gueltig_bis = " . $this->db_add_param($this->gueltig_bis) .",".
+				"updatevon = " . $this->db_add_param($this->updatevon) .",".
+				"updateamum = " . $this->db_add_param($this->updateamum).
+				" WHERE stundensatz_id = " . $this->db_add_param($this->stundensatz_id, FHC_INTEGER).';';
+		}
+		
+		if($this->db_query($qry))
+		{
+			if ($new)
+			{
+				$qry = "SELECT currval('hr.tbl_stundensatz_stundensatz_id_seq') as id;";
+				if ($this->db_query($qry))
+				{
+					if ($row = $this->db_fetch_object())
+					{
+						$this->stundensatz_id = $row->id;
+						$this->db_query('COMMIT');
+						return true;
+					} else
+					{
+						$this->db_query('ROLLBACK');
+						$this->errormsg = "Fehler beim Auslesen der Sequence";
+						return false;
+					}
+				} else
+				{
+					$this->db_query('ROLLBACK');
+					$this->errormsg = 'Fehler beim Auslesen der Sequence';
+					return false;
+				}
+			}
+			else
+			{
+				return true;
+			}
+		}
+		else
+		{
+			$this->errormsg = 'Fehler beim Zuteilen des Eintrages';
+			return false;
+		}
+	}
+	
+	public function delete($stundensatz_id)
+	{
+		$qry = "DELETE FROM hr.tbl_stundensatz WHERE stundensatz_id = ".$this->db_add_param($stundensatz_id, FHC_INTEGER);
+		
+		if($this->db_query($qry))
+			return true;
+		else
+		{
+			$this->errormsg = 'Fehler beim Löschen des Stundensatzes';
+			return false;
+		}
+	}
+	
+	public function validate()
+	{
+		if (!is_numeric($this->stundensatz))
+		{
+			$this->errormsg = "Stundensatz ungueltig";
+			return false;
+		}
+		
+		if (is_null($this->oe_kurzbz))
+		{
+			$this->errormsg = "Unternehmen ungueltig";
+			return false;
+		}
+		
+		if ($this->insertamum === '')
+		{
+			$this->errormsg = "Datum ungueltig";
+			return false;
+		}
+		return true;
+	}
 }
 ?>

include/stundensatztyp.class.php

@@ -0,0 +1,77 @@
+<?php
+
+require_once(dirname(__FILE__).'/basis_db.class.php');
+
+class stundensatzzyp extends basis_db
+{
+	public $result = array();
+	
+	public $stundensatztyp;
+	public $bezeichnung;
+	public $aktiv;
+
+	public function __construct($stundensatztyp=null)
+	{
+		parent::__construct();
+		
+		if($stundensatztyp!=null)
+			$this->load($stundensatztyp);
+	}
+
+	public function load($stundensatzzyp)
+	{
+		$qry = "SELECT *
+				FROM hr.tbl_stundensatztyp
+				WHERE stundensatztyp=". $this->db_add_param($stundensatzzyp);
+		
+		if($this->db_query($qry))
+		{
+			if($row = $this->db_fetch_object())
+			{
+				$this->stundensatztyp = $row->stundensatztyp;
+				$this->bezeichnung = $row->bezeichnung;
+				$this->aktiv = $this->db_parse_bool($row->aktiv);
+			}
+		}
+		else
+		{
+			$this->errormsg ="Fehler bei der Abfrage aufgetreten";
+			return false;
+		}
+	}
+	
+	public function getAll($onlyAktiv = true, $order = 'aktiv DESC, bezeichnung')
+	{
+		$qry = "SELECT *
+				FROM hr.tbl_stundensatztyp";
+		
+		if ($onlyAktiv)
+		{
+			$qry .= " WHERE aktiv";
+		}
+		
+		if($order !== '')
+			$qry .= " ORDER BY ".$order;
+		
+		if($this->db_query($qry))
+		{
+			while($row = $this->db_fetch_object())
+			{
+				$obj = new stundensatzzyp();
+				
+				$obj->stundensatztyp = $row->stundensatztyp;
+				$obj->bezeichnung = $row->bezeichnung;
+				$obj->aktiv = $this->db_parse_bool($row->aktiv);
+				
+				$this->result[] = $obj;
+			}
+			return true;
+		}
+		else 
+		{
+			$this->errormsg = 'Fehler beim Laden der Daten';
+			return false;
+		}
+	}
+}
+?>