<?php

class Prestudent_model extends DB_Model
{
	/**
	 * Constructor
	 */
	public function __construct()
	{
		parent::__construct();
		$this->dbTable = 'public.tbl_prestudent';
		$this->pk = 'prestudent_id';

		$this->load->model('crm/prestudentstatus_model', 'PrestudentstatusModel');
	}

	/**
	 * getLastStatuses
	 */
	public function getLastStatuses($person_id, $studiensemester_kurzbz = null, $studiengang_kz = null, $status_kurzbz = null)
	{
		$query = 'SELECT *
					FROM public.tbl_prestudent p
					JOIN (
							SELECT DISTINCT ON(prestudent_id) *
							  FROM public.tbl_prestudentstatus
							 WHERE prestudent_id IN (SELECT prestudent_id FROM public.tbl_prestudent WHERE person_id = ?)
						  ORDER BY prestudent_id, datum desc, insertamum desc
						) ps USING(prestudent_id)
					JOIN public.tbl_status USING(status_kurzbz)
				   WHERE ps.ausbildungssemester = 1';

		$parametersArray = array($person_id);

		if ($studiensemester_kurzbz != '')
		{
			array_push($parametersArray, $studiensemester_kurzbz);
			$query .= ' AND ps.studiensemester_kurzbz = ?';
		}

		if (isset($studiengang_kz))
		{
			array_push($parametersArray, $studiengang_kz);
			$query .= ' AND p.studiengang_kz = ?';
		}

		if ($status_kurzbz != '')
		{
			array_push($parametersArray, $status_kurzbz);
			$query .= ' AND ps.status_kurzbz = ?';
		}

		return $this->execQuery($query, $parametersArray);
	}

	/**
	 * updateAufnahmegruppe
	 */
	public function updateAufnahmegruppe($prestudentIdArray, $aufnahmegruppe)
	{
		return $this->execQuery(
			'UPDATE public.tbl_prestudent
				SET aufnahmegruppe_kurzbz = ?
			  WHERE prestudent_id IN ?',
			array(
				$aufnahmegruppe,
				$prestudentIdArray
			)
        );
	}

	/**
	 * Returns a list of prestudent with additional information:
	 *	- person_id
	 *	- name, surname, gender and birthday
	 *	- email
	 *	- studiengang and orgform
	 *	- studienplan
	 *	- stufe and aufnahmegruppe
	 *	- reihungstest score
	 */
	public function getPrestudentMultiAssign(
		$studiengang = null, $studiensemester = null, $gruppe = null, $reihungstest = null, $stufe = null
	)
	{
		$this->addSelect(
			'p.person_id,
			prestudent_id,
			p.nachname,
			p.vorname,
			p.geschlecht,
			p.gebdatum,
			k.kontakt AS email,
			sg.kurzbzlang,
			sg.bezeichnung,
			sg.orgform_kurzbz,
			sgt.bezeichnung AS typ,
			s.bezeichnung AS studienplan,
			ps.rt_stufe,
			aufnahmegruppe_kurzbz,
			SUM(rtp.punkte) AS punkte'
		);

		$this->addJoin('public.tbl_person p', 'person_id', 'LEFT');
		$this->addJoin(
			'(
					SELECT DISTINCT ON(person_id) person_id,
						   kontakt
					  FROM public.tbl_kontakt
					 WHERE zustellung = TRUE
					   AND kontakttyp = \'email\'
				  ORDER BY person_id, kontakt_id DESC
			) k',
			'person_id',
			'LEFT'
		);
		$this->addJoin('public.tbl_prestudentstatus ps', 'prestudent_id');
		$this->addJoin('lehre.tbl_studienplan s', 's.studienplan_id = ps.studienplan_id');
		$this->addJoin('lehre.tbl_studienordnung so', 'studienordnung_id');
		$this->addJoin('public.tbl_studiengang sg', 'sg.studiengang_kz = so.studiengang_kz');
		$this->addJoin('public.tbl_studiengangstyp sgt', 'typ');

		$this->addJoin('public.tbl_rt_person rtp', 'rtp.person_id = p.person_id AND rtp.studienplan_id = s.studienplan_id', 'LEFT');

		$this->addOrder('p.person_id', 'ASC');
		$this->addOrder('prestudent_id', 'ASC');

		$parametersArray = array('p.aktiv' => true, 'ps.status_kurzbz' => 'Interessent');

		if ($studiengang != null)
		{
			$parametersArray['public.tbl_prestudent.studiengang_kz'] = $studiengang;
		}

		if ($studiensemester != null)
		{
			$parametersArray['ps.studiensemester_kurzbz'] = $studiensemester;
		}

		if ($gruppe != null)
		{
			$parametersArray['aufnahmegruppe_kurzbz'] = $gruppe;
		}

		if ($reihungstest != null)
		{
			$parametersArray['rtp.rt_id'] = $reihungstest;
		}

		if ($stufe != null)
		{
			$parametersArray['ps.rt_stufe'] = $stufe;
		}

		$this->addGroupBy(
			array(
				'p.person_id',
				'prestudent_id',
				'p.nachname',
				'p.vorname',
				'p.geschlecht',
				'p.gebdatum',
				'k.kontakt',
				'sg.kurzbzlang',
				'sg.bezeichnung',
				'sg.orgform_kurzbz',
				'sgt.bezeichnung',
				's.bezeichnung',
				'ps.rt_stufe',
				'aufnahmegruppe_kurzbz'
			)
		);

		return $this->loadWhere($parametersArray);
	}

	/**
	 * getOrganisationunits
	 */
	public function getOrganisationunits($prestudent_id)
	{
		$query = 'SELECT p.prestudent_id, s.oe_kurzbz
					FROM public.tbl_prestudent p
			  INNER JOIN public.tbl_studiengang s USING(studiengang_kz)
				   WHERE prestudent_id %s ?';

		return $this->execQuery(sprintf($query, is_array($prestudent_id) ? 'IN' : '='), array($prestudent_id));
	}

	/**
	 * gets extended zgv data (with zgv bezeichnung) for a prestudent
	 * includes last status, Studiengang, zgv, zgv master
	 * @param $prestudent_id
	 */
	public function getPrestudentWithZgv($prestudent_id)
	{
		$this->addSelect('tbl_prestudent.*, tbl_studiengang.studiengang_kz, tbl_studiengang.kurzbzlang as studiengang, tbl_studiengang.bezeichnung as studiengangbezeichnung, tbl_studiengang.english as studiengangenglish,
		tbl_studiengang.email as studiengangmail, tbl_studiengang.typ as studiengangtyp, tbl_studiengangstyp.bezeichnung as studiengangtyp_bez,
		tbl_zgv.zgv_code, tbl_zgv.zgv_bez, tbl_prestudent.zgvnation as zgvnation_code, zgvnat.kurztext as zgvnation_kurzbez, zgvnat.langtext as zgvnation_bez, zgvnat.engltext as zgvnation_englbez, zgvnat.nationengruppe_kurzbz as zgvnation_nationengruppe,
		tbl_zgvmaster.zgvmas_code, tbl_zgvmaster.zgvmas_bez, tbl_prestudent.zgvmanation as zgvmanation_code, zgvmanat.kurztext as zgvmanation_kurzbez, zgvmanat.langtext as zgvmanation_bez, zgvmanat.engltext as zgvmanation_englbez');
		$this->addJoin('public.tbl_studiengang', 'studiengang_kz', 'LEFT');
		$this->addJoin('public.tbl_studiengangstyp', 'typ', 'LEFT');
		$this->addJoin('bis.tbl_zgv', 'zgv_code', 'LEFT');
		$this->addJoin('bis.tbl_zgvmaster', 'zgvmas_code', 'LEFT');
		$this->addJoin('bis.tbl_nation zgvnat', 'zgvnation = zgvnat.nation_code', 'LEFT');
		$this->addJoin('bis.tbl_nation zgvmanat', 'zgvmanation = zgvmanat.nation_code', 'LEFT');

		$prestudent = $this->load($prestudent_id);
		if (!hasData($prestudent))
			return error('prestudent could not be loaded');

		$prestudentdata = getData($prestudent);
		$prestudentdata = $prestudentdata[0];

		//Prestudentstatus
		$lastStatus = $this->PrestudentstatusModel->getLastStatus($prestudent_id);

		if (isError($lastStatus))
		{
			return $lastStatus;
		}

		if (hasData($lastStatus))
		{
			$lastStatusData = getData($lastStatus);
			$lastStatusData = $lastStatusData[0];
			//get Studiengangname from Studienplan and -ordnung
			$studienordnung = $this->PrestudentstatusModel->getStudienordnungFromPrestudent($prestudent_id);
			if (isError($studienordnung))
				return $studienordnung;

			if (hasData($studienordnung))
			{
				$studienordnungdata = getData($studienordnung);
				$studienordnungdata = $studienordnungdata[0];

				$lastStatusData->studiengang_kz = $studienordnungdata->studiengang_kz;
				$lastStatusData->studiengangkurzbzlang = $studienordnungdata->studiengangkurzbzlang;
				$lastStatusData->studiengangbezeichnung = $studienordnungdata->studiengangbezeichnung;
				$lastStatusData->studiengangbezeichnung_englisch = $studienordnungdata->studiengangbezeichnung_englisch;
				$lastStatusData->regelstudiendauer = $studienordnungdata->regelstudiendauer;
			}

			//get Sprache
			$this->load->model('system/sprache_model', 'SpracheModel');
			$this->SpracheModel->addSelect('sprache, locale, bezeichnung');
			$language = $this->SpracheModel->load($lastStatusData->sprache);

			if (isError($language))
				return $language;

			if (hasData($language))
			{
				$languagedata = getData($language);
				$languagedata = $languagedata[0];
				$lastStatusData->sprachedetails = $languagedata;
			}

			//get Bewerbungsfrist
			$this->load->model('crm/bewerbungstermine_model', 'BewerbungstermineModel');
			$this->BewerbungstermineModel->addSelect('ende, nachfrist_ende');
			$this->BewerbungstermineModel->addOrder('updateamum', 'DESC');
			$this->BewerbungstermineModel->addOrder('insertamum', 'DESC');
			$this->BewerbungstermineModel->addOrder('ende');
			$this->BewerbungstermineModel->addLimit(1);

			$fristparams = array(
                'studienplan_id' => $lastStatusData->studienplan_id,
                'studiensemester_kurzbz' => $lastStatusData->studiensemester_kurzbz,
                'studiengang_kz' => $prestudentdata->studiengang_kz
            );

			if (isset($prestudentdata->zgvnation_nationengruppe))
			    $fristparams['nationengruppe_kurzbz'] = $prestudentdata->zgvnation_nationengruppe;

            $bewerbungstermin = $this->BewerbungstermineModel->loadWhere(
				$fristparams
			);

			if (isError($bewerbungstermin))
				return $bewerbungstermin;

			if (hasData($bewerbungstermin))
			{
				$bewerbungstermindata = getData($bewerbungstermin);
				$bewerbungstermindata = $bewerbungstermindata[0];
				$lastStatusData->bewerbungstermin = $bewerbungstermindata->ende;
				$lastStatusData->bewerbungsnachfrist = $bewerbungstermindata->nachfrist_ende;
			}

			$prestudentdata->prestudentstatus = $lastStatusData;


			if ($this->udfsExistAndDefined())
			{
				$prestudentdata->prestudentUdfs = $this->getUDFs($prestudent_id);
			}
		}

		return success($prestudentdata);
	}

	/**
	 * gets the prestudent edited last.
	 * if no updateamum, sort by insertamum
	 * @param $person_id
	 * @param bool $withzgv if true, only prestudenten with zgv_code are taken
	 * @return array|null
	 */
	public function getLastPrestudent($person_id, $withzgv = false)
	{
		$qry = 'SELECT * FROM public.tbl_prestudent ps
				%s
				WHERE ps.person_id = ?
				ORDER BY updateamum DESC NULLS LAST, insertamum DESC NULLS LAST
				LIMIT 1';

		$zgvwhere = '';
		if ($withzgv === true)
		{
			$zgvwhere = '
				LEFT JOIN (
					SELECT ps2.zgvmas_code,
						ps2.zgvmanation,
						ps2.zgvmadatum,
						ps2.zgvmaort,
						ps2.zgvmas_erfuellt,
						ps2.person_id
					FROM tbl_prestudent ps2
					WHERE zgvmas_code IS NOT NULL
					ORDER BY updateamum DESC NULLS LAST, insertamum DESC NULLS LAST
				) zgvmas ON zgvmas.person_id = ps.person_id
				LEFT JOIN (
					SELECT ps2.zgv_code,
						ps2.zgvnation,
						ps2.zgvdatum,
						ps2.zgvort,
						ps2.zgv_erfuellt,
						ps2.person_id
					FROM tbl_prestudent ps2
					WHERE zgv_code IS NOT NULL
					ORDER BY updateamum DESC NULLS LAST, insertamum DESC NULLS LAST
				)zgv ON zgv.person_id = ps.person_id';
		}

		$qry = sprintf($qry, $zgvwhere);

		$parametersArray = array($person_id);

		return $this->execQuery($qry, $parametersArray);
	}

	/**
	 * Returns a list with Bewerbungen (applications)
	 * @param $person_id person who sent application(s)
	 * @param string $studiensemester_kurzbz
	 * @param bool $abgeschickt optional, wether application was filled out and sent
	 * @param bool $bestaetigt optional, wether application was confirmed by infocenter
	 * @return array with Bewerber
	 */
	public function getBewerbungen($person_id, $studiensemester_kurzbz = null, $abgeschickt = null, $bestaetigt = null)
	{
		$bewerbungen = array();
		$prestudents = $this->loadWhere(array('person_id' => $person_id));

		if (!hasData($prestudents))
			return $bewerbungen;

		foreach ($prestudents->retval as $prestudent)
		{
			$lastStatus = $this->PrestudentstatusModel->getLastStatus($prestudent->prestudent_id, $studiensemester_kurzbz);

			if (!hasData($lastStatus))
				continue;

			$lastStatus = $lastStatus->retval[0];

			if ($lastStatus->status_kurzbz !== 'Interessent')
				continue;

			$bewerbung_abgeschicktamum = $lastStatus->bewerbung_abgeschicktamum;
			$bestaetigtam = $lastStatus->bestaetigtam;

			$abgeschicktcond = true;
			if (($abgeschickt === false && isset($bewerbung_abgeschicktamum)) || ($abgeschickt === true && !isset($bewerbung_abgeschicktamum)))
				$abgeschicktcond = false;

			$bestaetigtcond = true;
			if (($bestaetigt === false && isset($bestaetigtam)) || ($bestaetigt === true && !isset($bestaetigtam)))
				$bestaetigtcond = false;

			if ($bestaetigtcond && $abgeschicktcond)
			{
				$prestudent->lastStatus = $lastStatus;
				$bewerbungen[] = $prestudent;
			}
		}

		return $bewerbungen;
	}

	/**
	 * Checks if application priority can be changed for a prestudent
	 * @param $prestudent_id
	 * @param $studiensemester Semester in which Prestudent applied
	 * @param $change increase priority (< 0) or decrease priority (> 0)
	 * @return bool wether priority can be changed
	 */
	public function checkPrioChange($prestudent_id, $studiensemester, $change)
	{
		if (!is_numeric($change))
			return false;

		$this->addSelect('person_id, priorisierung');
		$prestudent = $this->load($prestudent_id);

		if (!hasData($prestudent))
			return false;

		$person_id = $prestudent->retval[0]->person_id;

		$bewerberarr = $this->getBewerbungen($person_id, $studiensemester);

		//Prio can be added when prio is null and there is only one prestudent
		if (count($bewerberarr) === 1 && !isset($prestudent->retval[0]->priorisierung) && $change < 0)
			return true;

		if (count($bewerberarr) <= 1)
			return false;

		if (!isset($prestudent->retval[0]->priorisierung))
		{
			if ($change < 0)
				return true; //null values can be changed to priority numbers (prority increase)
			else
				return false;
		}

		$priomin = 0;
		$priomax = PHP_INT_MAX;
		$currprio = intval($prestudent->retval[0]->priorisierung);

		foreach ($bewerberarr as $bewerber)
		{
			if (is_numeric($bewerber->priorisierung))
			{
				$bewprio = intval($bewerber->priorisierung);
				if ($bewprio < $priomax)
					$priomax = $bewprio;

				if ($bewprio > $priomin)
					$priomin = $bewprio;
			}
		}

		//no prio change when prestudent has max or min prio
		if (($currprio === $priomax && $change < 0) || ($currprio === $priomin && $change > 0))
		{
			return false;
		}

		return true;
	}

	/**
	 * Changes application priority for a prestudent
	 * Swaps priorities with nearest neighbour (nearest bewerber/prestudent)
	 * for the same studiensemester in order to move priority up/down
	 * @param $prestudent_id
	 * @param $change increase priority (< 0) or decrease priority (> 0)
	 * @return bool wether change of priority was sucessfull
	 */
	public function changePrio($prestudent_id, $change)
	{
		$this->addSelect('person_id, priorisierung');
		$prestudent = $this->load($prestudent_id);

		if (!hasData($prestudent))
			return false;

		$lastStatus = $this->PrestudentstatusModel->getLastStatus($prestudent_id, null, 'Interessent');

		if (!hasData($lastStatus))
			return false;

		$studiensemester_kurzbz = $lastStatus->retval[0]->studiensemester_kurzbz;

		if (!$this->checkPrioChange($prestudent_id, $studiensemester_kurzbz, $change))
			return false;

		$person_id = $prestudent->retval[0]->person_id;
		$currprio = intval($prestudent->retval[0]->priorisierung);

		$difftonext = PHP_INT_MAX;
		$neighbour = null;

		$bewerberarr = $this->getBewerbungen($person_id, $studiensemester_kurzbz );

		foreach ($bewerberarr as $bewerber)
		{
			if (is_numeric($bewerber->priorisierung))
			{
				$bewprio = intval($bewerber->priorisierung);

				$diff = 0;
				if ($change < 0 && ($bewprio < $currprio || is_null($prestudent->retval[0]->priorisierung))) //prio up
				{
					$diff = $currprio - $bewprio;
				}
				elseif ($change > 0 && $bewprio > $currprio)
				{
					$diff = $bewprio - $currprio;
				}

				if ($diff !== 0 && $diff < $difftonext)
				{
					$difftonext = $diff;
					$neighbour = $bewerber;
				}
			}
		}

		if (is_null($prestudent->retval[0]->priorisierung))
		{
			//if null value, add as prio 1
			$newprio = isset($neighbour->priorisierung) ? intval($neighbour->priorisierung) + 1 : 1;

			$result = $this->PrestudentModel->update(
				$prestudent_id,
				array(
					'priorisierung' => $newprio
				)
			);

			if (isError($result))
			{
				return false;
			}
			else
			{
				return true;
			}
		}
		else
		{
			$this->db->trans_start(false);
			//prio swap
			$resultFirst = $this->PrestudentModel->update(
				$prestudent_id,
				array(
					'priorisierung' => intval($neighbour->priorisierung)
				)
			);


			$resultSecond = $this->PrestudentModel->update(
				$neighbour->prestudent_id,
				array(
					'priorisierung' => $currprio
				)
			);

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

			// Check if everything went ok during the transaction
			if ($this->db->trans_status() === false || isError($resultFirst) || isError($resultSecond))
			{
				$this->db->trans_rollback();
				return false;
			}
			else
			{
				$this->db->trans_commit();
				return true;
			}
		}
	}

	/**
	 * Get organisation units for all the prestudents of a person
	 */
	public function getOrganisationunitsByPersonId($person_id)
	{
		$query = 'SELECT DISTINCT o.oe_kurzbz,
						o.bezeichnung,
						(CASE
							WHEN sg.typ = \'b\' THEN ps.prestudent_id
							WHEN sg.typ = \'m\' THEN mps.prestudent_id
            				ELSE NULL
       					END) AS prestudent_id,
       					sg.typ
					FROM public.tbl_prestudent p
			  		JOIN public.tbl_studiengang sg USING(studiengang_kz)
					JOIN public.tbl_organisationseinheit o USING(oe_kurzbz)
			   LEFT JOIN (
				   			SELECT prestudent_id
							  FROM public.tbl_prestudentstatus
							 WHERE status_kurzbz = \'Bewerber\'
						) ps USING(prestudent_id)
				LEFT JOIN (
					SELECT prestudent_id
					FROM public.tbl_prestudentstatus
					WHERE status_kurzbz = \'Interessent\' AND bestaetigtam IS NOT NULL
				) mps ON p.prestudent_id = mps.prestudent_id
				   WHERE p.person_id = ?
				GROUP BY o.oe_kurzbz,
						o.bezeichnung,
						sg.typ,
						ps.prestudent_id,
						mps.prestudent_id,
						p.prestudent_id
				ORDER BY o.bezeichnung';

		return $this->execQuery($query, array($person_id));
	}

	/**
	 * Get latest ZGV Bezeichnung of Prestudent.
	 *
	 * @param $prestudent_id
	 */
	public function getLatestZGVBezeichnung($prestudent_id)
	{
		if (!is_numeric($prestudent_id))
		{
			show_error('Prestudent_id is not numeric.');
		}

		$language_index = getUserLanguage() == 'German' ? 0 : 1;

		$this->addSelect('
			COALESCE(
				array_to_json(zgvmaster.bezeichnung::varchar[])->>' . $language_index . ',
				array_to_json(zgv.bezeichnung::varchar[])->>' . $language_index . '
			) AS bezeichnung'
		);

		$this->addJoin('bis.tbl_zgv zgv', 'zgv_code', 'LEFT');
		$this->addJoin('bis.tbl_zgvmaster zgvmaster', 'zgvmas_code', 'LEFT');

		return $this->loadWhere(array(
			'prestudent_id' => $prestudent_id
		));
	}

	public function getPrestudentByStudiengangAndPerson($studiengang, $person, $studienSemester, $abgeschickt)
	{
		$query = "SELECT ps.prestudent_id
					FROM public.tbl_prestudentstatus pss
					JOIN public.tbl_prestudent ps USING(prestudent_id)
					JOIN public.tbl_studiengang sg USING(studiengang_kz)
					JOIN lehre.tbl_studienplan sp USING(studienplan_id)
					JOIN lehre.tbl_studienordnung so USING(studienordnung_id)
					WHERE ps.person_id = ?
					AND UPPER(so.studiengangkurzbzlang || ':' || sp.orgform_kurzbz) = ?
					AND pss.studiensemester_kurzbz = ?
					AND";

		if ($abgeschickt === 'true')
			$query .= " EXISTS";
		else
			$query .= " NOT EXISTS";

		$query .= " (SELECT 1 FROM public.tbl_prestudentstatus spss
					JOIN public.tbl_prestudent sps USING(prestudent_id)
					WHERE sps.prestudent_id = ps.prestudent_id
					AND spss.bewerbung_abgeschicktamum IS NOT NULL)";

		return $this->execQuery($query, array($person, $studiengang, $studienSemester));
	}

	/**
	 * Gets förderrelevant flag for a prestudent, from prestudent, or, if not set on prestudent level, from studiengang
	 * @param int $prestudent_id
	 * @return object
	 */
	public function getFoerderrelevant($prestudent_id)
	{
		$query = 'SELECT COALESCE (ps.foerderrelevant, stg.foerderrelevant) AS foerderrelevant
					FROM public.tbl_prestudent ps
					LEFT JOIN public.tbl_studiengang stg USING (studiengang_kz)
					WHERE prestudent_id = ?';

		return $this->execQuery($query, array($prestudent_id));
	}

	/**
	 * Gets bis standort_code for a prestudent, from prestudent, or, if not set on prestudent level, from studiengang
	 * @param int $prestudent_id
	 * @return object
	 */
	public function getStandortCode($prestudent_id)
	{
		$query = 'SELECT COALESCE (ps.standort_code, stg.standort_code) AS standort_code
					FROM public.tbl_prestudent ps
					LEFT JOIN public.tbl_studiengang stg USING (studiengang_kz)
					WHERE prestudent_id = ?';

		return $this->execQuery($query, array($prestudent_id));
	}

}