- added reservierungen

- added updatemails
- added reservierungssync
- updated status kurzbz
- reservierung renderer for tempus

application/controllers/system/MigrateKalender.php

@@ -16,28 +16,45 @@ class MigrateKalender extends Auth_Controller
 	 */
 	public function __construct()
 	{
-		parent::__construct(array('index' => ['admin:rw']));
-
+		parent::__construct(array(
+			'migrateStundenplan' => ['admin:rw'],
+			'migrateReservierung' => ['admin:rw'],
+		));
 		$this->load->model('ressource/Kalender_model', 'KalenderModel');
 		$this->load->model('ressource/Kalender_Lehreinheit_model', 'KalenderLehreinheitModel');
 		$this->load->model('ressource/Kalender_Ort_model', 'KalenderOrtModel');
 		$this->load->model('ressource/Stundenplandev_Kalender_model', 'SyncModel');
+		$this->load->model('ressource/Reservierung_Kalender_model', 'SyncReservierungModel');
+		$this->load->model('ressource/Kalender_Event_Teilnehmer_model', 'KalenderEventTeilnehmerModel');
+		$this->load->model('ressource/Kalender_Event_model', 'KalenderEventModel');
+		$this->load->model('organisation/Studiensemester_model', 'StudiensemesterModel');
+		$this->load->model('person/Benutzer_model', 'BenutzerModel');
 	}
 
 	/**
 	 * Everything has a beginning
 	 */
-	public function index($von = null, $bis = null)
+	public function migrateStundenplan($von = null, $bis = null, $studiengang_kz = null)
 	{
-
 		$db = new DB_Model();
 
 		$stpldevsql = '
 			WITH eindeutige_stunden AS (
 				SELECT DISTINCT unr, datum, stunde
 				FROM lehre.tbl_stundenplandev
-				WHERE datum >= ? AND datum <= ?
-			),
+				WHERE datum >= ? AND datum <= ?';
+
+		$params = [$von, $bis];
+
+		if (!is_null($studiengang_kz))
+		{
+			$stpldevsql .= ' AND studiengang_kz = ?';
+
+			$params[] = $studiengang_kz;
+		}
+
+		$stpldevsql .= '),
+			
 			block_keys AS (
 				SELECT
 					unr,
@@ -82,11 +99,11 @@ class MigrateKalender extends Auth_Controller
 				JOIN lehre.tbl_stunde stundebis ON stundebis.stunde = b.stunde_bis
 			ORDER BY b.datum, b.unr, b.block_nr;';
 
-	    $stpldev = $db->execReadOnlyQuery($stpldevsql, array($von, $bis, $von, $bis));
-
+		array_push($params, $von, $bis);
+		$stpldev = $db->execReadOnlyQuery($stpldevsql, $params);
 
 		if (hasData($stpldev))
-	    {
+		{
 			// Pruefen ob der Eintrag schon in Sync Tabelle vorhanden ist
 			// Wenn neuere Änderungen vorhanden dann Update
 			// Wenn keine Änderungen seit leztem Sync dann Ueberspringen
@@ -97,12 +114,15 @@ class MigrateKalender extends Auth_Controller
 			$data = getData($stpldev);
 			foreach($data as $block)
 			{
-				$this->SyncModel->db->where_in('stundenplandev_id', $block->stundenplandev_ids);
+				$ids = is_array($block->stundenplandev_ids) ? $block->stundenplandev_ids : explode(',', $block->stundenplandev_ids);
+				/*$ids = array_map('intval', $ids);*/
+
+				$this->SyncModel->db->where('stundenplandev_id IN (' . implode(',', $ids) . ')');
 				$sync_result = $this->SyncModel->load();
 
 				if (!hasData($sync_result))
 				{
-					$kalender_id = $this->_insertKalender($block);
+					$kalender_id = $this->_insertKalender($block, 'lehreinheit');
 					if ($kalender_id)
 					{
 						$this->_insertSync($block->stundenplandev_ids, $kalender_id);
@@ -139,7 +159,7 @@ class MigrateKalender extends Auth_Controller
 					$von = $rowstpl->datum.' '.$rowstpl->beginn;
 					$bis = $rowstpl->datum.' '.$rowstpl->ende;
 					$typ = 'lehreinheit';
-					$status = 'visible_student';
+					$status = 'live';
 					$insertamum = $rowstpl->insertamum;
 					$insertvon = $rowstpl->insertvon;
 					$updateamum = $rowstpl->updateamum;
@@ -191,19 +211,175 @@ class MigrateKalender extends Auth_Controller
 		}
 	}
 
+	public function migrateReservierung($von = null, $bis = null, $ort_kurzbz = null)
+	{
+		$db = new DB_Model();
 
-	private function _insertKalender($block)
+		$qry = "WITH eindeutige_stunden AS (
+					SELECT DISTINCT titel, beschreibung, datum, stunde
+					FROM campus.tbl_reservierung
+					WHERE datum >= ? AND datum <= ?";
+
+		$params = array($von, $bis);
+
+		if (!is_null($ort_kurzbz))
+		{
+			$qry .= " AND ort_kurzbz = ?";
+			$params[] = $ort_kurzbz;
+		}
+
+		$qry .=	"),
+					 block_keys AS (
+						 SELECT
+							 titel, beschreibung, datum, stunde,
+							 stunde - ROW_NUMBER() OVER (PARTITION BY titel, beschreibung, datum ORDER BY stunde) AS block_nr
+						 FROM eindeutige_stunden
+					 ),
+					 blocks AS (
+						 SELECT
+							 bk.titel,
+							 bk.beschreibung,
+							 bk.datum,
+							 bk.block_nr,
+							 MIN(bk.stunde) AS stunde_von,
+							 MAX(bk.stunde) AS stunde_bis,
+							 array_agg(DISTINCT r.reservierung_id::text) AS reservierung_ids,
+							 array_agg(DISTINCT r.uid) AS uids,
+							 array_agg(DISTINCT r.gruppe_kurzbz) AS gruppen_kurzbz,
+							 array_agg(DISTINCT ROW(r.semester, r.verband, r.gruppe)::text) AS svg_kombis,
+							 MIN(r.ort_kurzbz) AS ort_kurzbz,
+							 MIN(r.studiengang_kz) AS studiengang_kz,
+							 MIN(r.veranstaltung_id) AS veranstaltung_id,
+							 MIN(r.reservierung_id) AS reservierung_id,
+							 MAX(r.insertamum) AS insertamum,
+							 (array_agg(r.insertvon ORDER BY r.insertamum ASC))[1] AS insertvon
+						 FROM block_keys bk
+								  JOIN campus.tbl_reservierung r
+									   ON r.titel = bk.titel AND r.beschreibung = bk.beschreibung AND r.datum = bk.datum AND r.stunde = bk.stunde
+						 WHERE r.datum >= ? AND r.datum <= ?
+						 GROUP BY bk.titel, bk.beschreibung, bk.datum, bk.block_nr
+					 )
+				SELECT
+					b.*,
+					(b.datum + s_von.beginn) AS von,
+					(b.datum + s_bis.ende)   AS bis
+				FROM blocks b
+						 JOIN lehre.tbl_stunde s_von ON s_von.stunde = b.stunde_von
+						 JOIN lehre.tbl_stunde s_bis ON s_bis.stunde = b.stunde_bis
+				ORDER BY b.reservierung_id DESC;";
+		/*$qry = "WITH per_stunde AS (
+					SELECT
+						datum,
+						titel,
+						beschreibung, ort_kurzbz, studiengang_kz, stunde,
+						veranstaltung_id,
+						array_agg(DISTINCT uid) AS uids,
+						array_agg(DISTINCT reservierung_id::text) AS reservierung_ids,
+						array_agg(DISTINCT ROW(semester, verband, gruppe)::text) AS svg_kombis,
+						array_agg(DISTINCT gruppe_kurzbz) AS gruppen_kurzbz,
+						MIN(reservierung_id) AS reservierung_id,
+						MAX(insertamum) AS insertamum,
+						MAX(insertvon) AS insertvon
+					FROM campus.tbl_reservierung
+					WHERE datum >= ? AND datum <= ?
+					GROUP BY datum, titel, beschreibung, ort_kurzbz, studiengang_kz, stunde, veranstaltung_id
+				),
+				numbered AS (
+					SELECT
+						per_stunde.*,
+						stunde - ROW_NUMBER() OVER (PARTITION BY datum, titel, beschreibung, ort_kurzbz, studiengang_kz, veranstaltung_id ORDER BY stunde) AS grp
+					FROM per_stunde
+				),
+				grouped AS (
+					SELECT
+						MIN(reservierung_id) AS reservierung_id,
+						ort_kurzbz, studiengang_kz, datum,
+						MIN(stunde) AS stunde_von,
+						MAX(stunde) AS stunde_bis,
+						titel, beschreibung,
+						array_agg(DISTINCT gruppe_kurzbz_elem) AS gruppen_kurzbz,
+						array_agg(DISTINCT uid_elem) AS uids,
+						array_agg(DISTINCT res_id) AS reservierung_ids,
+						array_agg(DISTINCT svg_elem) AS svg_kombis,
+						veranstaltung_id,
+						MAX(insertamum) AS insertamum,
+						MAX(insertvon) AS insertvon
+					FROM numbered,
+						unnest(uids) AS uid_elem,
+						unnest(reservierung_ids) AS res_id,
+						unnest(gruppen_kurzbz) AS gruppe_kurzbz_elem,
+						unnest(svg_kombis) AS svg_elem
+					GROUP BY datum, titel, beschreibung, ort_kurzbz, studiengang_kz, veranstaltung_id, grp
+				)
+				SELECT
+					grouped.*,
+					(datum + s_von.beginn) AS von,
+					(datum + s_bis.ende) AS bis
+				FROM grouped
+					JOIN lehre.tbl_stunde s_von ON s_von.stunde = grouped.stunde_von
+					JOIN lehre.tbl_stunde s_bis ON s_bis.stunde = grouped.stunde_bis
+				ORDER BY grouped.reservierung_id DESC";*/
+
+		array_push($params, $von, $bis);
+		$reservierung_data = $db->execReadOnlyQuery($qry, $params);
+
+
+		if (hasData($reservierung_data))
+		{
+			$data = getData($reservierung_data);
+
+			foreach($data as $block)
+			{
+
+				$ids = is_array($block->reservierung_ids) ? $block->reservierung_ids : explode(',', $block->reservierung_ids);
+
+				$this->SyncReservierungModel->db->where('reservierung_id IN (' . implode(',', $ids) . ')');
+				$sync_result = $this->SyncReservierungModel->load();
+
+				if (!hasData($sync_result))
+				{
+					$kalender_id = $this->_insertKalender($block, 'reservierung');
+					if ($kalender_id)
+					{
+						$this->_insertReservierungSync($block->reservierung_ids, $kalender_id);
+					}
+				}
+				else
+				{
+					$syncData = getData($sync_result);
+					$kalender_id = $syncData[0]->kalender_id;
+					$last_sync = $syncData[0]->lastupdate;
+					$synced_ids = array_column($syncData, 'reservierung_id');
+
+					if ($block->insertamum > $last_sync)
+					{
+						$this->_updateKalender($kalender_id, $block);
+						$this->_updateReservierungSync($synced_ids, $kalender_id);
+					}
+
+					$fehlende = array_diff($block->reservierung_ids, $synced_ids);
+					if (!empty($fehlende))
+					{
+						$this->_insertReservierungSync($fehlende, $kalender_id);
+					}
+				}
+			}
+		}
+	}
+
+
+	private function _insertKalender($block, $typ)
 	{
 		$result = $this->KalenderModel->insert(
 			array (
 				'von' => $block->von,
 				'bis' => $block->bis,
-				'typ' => 'lehreinheit',
-				'status_kurzbz'=> 'visible_student',
+				'typ' => $typ,
+				'status_kurzbz'=> 'live',
 				'insertamum' => $block->insertamum,
 				'insertvon' => $block->insertvon,
-				'updateamum' => $block->updateamum,
-				'updatevon' => $block->updatevon
+				'updateamum' => $block->updateamum ?? null,
+				'updatevon' => $block->updatevon ?? null
 			)
 		);
 		if(!isSuccess($result))
@@ -211,12 +387,94 @@ class MigrateKalender extends Auth_Controller
 
 		$kalender_id = getData($result);
 
-		$this->KalenderLehreinheitModel->insert(
-			array (
+		if ($typ === 'lehreinheit')
+		{
+			$this->KalenderLehreinheitModel->insert(
+				array (
+					'kalender_id' => $kalender_id,
+					'lehreinheit_id'=> $block->lehreinheit_id
+				)
+			);
+		}
+		else if ($typ === 'reservierung')
+		{
+			$this->KalenderEventModel->insert(array(
 				'kalender_id' => $kalender_id,
-				'lehreinheit_id'=> $block->lehreinheit_id
-			)
-		);
+				'titel' => $block->titel,
+				'beschreibung' => $block->beschreibung
+			));
+
+
+			if ($block->insertvon)
+			{
+				$user = $this->BenutzerModel->load(array('uid' => $block->insertvon));
+
+				if (hasData($user))
+				{
+					$this->KalenderEventTeilnehmerModel->insert(array(
+						'kalender_id' => $kalender_id,
+						'uid' => getData($user)[0]->uid,
+						'rolle_kurzbz' => 'organisator'
+					));
+				}
+			}
+
+			$uids = is_array($block->uids) ? $block->uids : explode(',', $block->uids);
+			foreach ($uids as $uid)
+			{
+				$this->KalenderEventTeilnehmerModel->insert(array(
+					'kalender_id' => $kalender_id,
+					'uid' => $uid,
+					'rolle_kurzbz' => 'teilnehmer'
+				));
+			}
+
+			$semester_range = $this->StudiensemesterModel->getByDateRange($block->von, $block->bis);
+			if (isError($semester_range)) return $semester_range;
+			$studiensemester_kurzbz = getData($semester_range)[0]->studiensemester_kurzbz ?? null;
+
+			$gruppen = is_array($block->gruppen_kurzbz) ? $block->gruppen_kurzbz : explode(',', $block->gruppen_kurzbz ?? '');
+
+			foreach ($gruppen as $gruppe_kurzbz)
+			{
+				$gruppe_kurzbz = trim($gruppe_kurzbz);
+				if (!empty($gruppe_kurzbz))
+				{
+					$this->KalenderEventTeilnehmerModel->insert(array(
+						'kalender_id' => $kalender_id,
+						'gruppe_kurzbz' => $gruppe_kurzbz,
+						'studiengang_kz' => $block->studiengang_kz,
+						'studiensemester_kurzbz' => $studiensemester_kurzbz,
+						'rolle_kurzbz' => 'teilnehmer'
+					));
+				}
+			}
+
+			foreach ($block->svg_kombis as $kombi_str)
+			{
+				$kombi_str = trim($kombi_str, '()');
+				list($sem, $verb, $grp) = explode(',', $kombi_str);
+
+				$sem = trim($sem) === '' ? null : trim($sem);
+				$verb = trim($verb) === '' ? null : trim($verb);
+				$grp = trim($grp) === '' ? null : trim($grp);
+
+				if (is_null($sem) && is_null($verb) && is_null($grp))
+					continue;
+
+				$this->KalenderEventTeilnehmerModel->insert(array(
+					'kalender_id' => $kalender_id,
+					'studiengang_kz' => $block->studiengang_kz,
+					'semester' => $sem,
+					'verband' => $verb,
+					'gruppe' => $grp,
+					'studiensemester_kurzbz' => $studiensemester_kurzbz,
+					'rolle_kurzbz' => 'teilnehmer'
+				));
+			}
+		}
+
+
 		$this->KalenderOrtModel->insert(
 			array (
 				'kalender_id' => $kalender_id,
@@ -240,6 +498,20 @@ class MigrateKalender extends Auth_Controller
 			);
 		}
 	}
+	private function _insertReservierungSync($ids, $kalender_id)
+	{
+
+		foreach($ids as $id)
+		{
+			$this->SyncReservierungModel->insert(
+				array (
+					'reservierung_id' => $id,
+					'kalender_id' => $kalender_id,
+					'lastupdate' => date('Y-m-d H:i:s')
+				)
+			);
+		}
+	}
 
 	private function _updateKalender($kalender_id, $block)
 	{
@@ -271,4 +543,20 @@ class MigrateKalender extends Auth_Controller
 			);
 		}
 	}
+
+	private function _updateReservierungSync($ids, $kalender_id)
+	{
+		foreach($ids as $id)
+		{
+			$this->SyncReservierungModel->update(
+				array (
+					'reservierung_id' => $id,
+					'kalender_id' => $kalender_id
+				),
+				array (
+					'lastupdate' => date('Y-m-d H:i:s')
+				)
+			);
+		}
+	}
 }