FHC-Core/application/models/content/Ampel_model.php

<?php
class Ampel_model extends DB_Model
{
	/**
	 * Constructor
	 */
	public function __construct()
	{
		parent::__construct();
		$this->dbTable = 'public.tbl_ampel';
		$this->pk = 'ampel_id';
	}

	/**
	 * Returns all active Ampeln, that are actually:
	 * 1. not after the deadline date
	 * 2. not before the vorlaufszeit
	 * @param bool $email If true, then only ampeln are retrieved that are marked to be sent by mail.
	 * @return stdClass Returns array of objects.
	 */
	public function active($email = false, $uid = null)
	{
		$userLanguage = getUserLanguage();
		$selectStatement='*,beschreibung[('.$this->getLanguageIndex($this->escape($userLanguage)).')] as beschreibung_trans, buttontext[('.$this->getLanguageIndex($this->escape($userLanguage)).')] as buttontext_trans';
		
		if($uid != null ){
			$selectStatement .= ',
				COALESCE((
				SELECT true
			  	FROM public.tbl_ampel_benutzer_bestaetigt a
			 	WHERE a.ampel_id = ' . $this->dbTable . '.ampel_id
			   	AND uid = ' . $this->escape($uid) . ' LIMIT 1), false) as bestaetigt';
		}

		$this->addSelect($selectStatement);
		$whereStatement='';

		if ($email === true) {
			$whereStatement .= ' email = '.$this->escape($email).' AND';
		}

		$whereStatement .=
		'(
			(
				(NOW()<(deadline+(COALESCE(verfallszeit,0) || \' days\')::interval)::date)
				OR (verfallszeit IS NULL)
			)
			AND 
			(
				(NOW()>(deadline-(COALESCE(vorlaufzeit,0) || \' days\')::interval)::date)
			    OR (vorlaufzeit IS NULL AND NOW() < deadline)
			)
			)';
		
		$this->addOrder('deadline', 'DESC');
		return $this->loadWhere($whereStatement);

	}

	public function openActive($uid, $email = false)
	{
		$userLanguage = getUserLanguage();
		$selectStatement = '*,beschreibung[(' . $this->getLanguageIndex($this->escape($userLanguage)) . ')] as beschreibung_trans, buttontext[(' . $this->getLanguageIndex($this->escape($userLanguage)) . ')] as buttontext_trans';

		
		$selectStatement .= ',
			COALESCE((
			SELECT true
			FROM public.tbl_ampel_benutzer_bestaetigt a
			WHERE a.ampel_id = ' . $this->dbTable . '.ampel_id
			AND uid = ' . $this->escape($uid) . ' LIMIT 1), false) as bestaetigt';

		$this->addSelect($selectStatement);
		$whereStatement = '';

		if ($email === true) {
			$whereStatement .= ' email = ' . $this->escape($email) . ' AND';
		}

		$whereStatement .=
			'
			(COALESCE((
			SELECT true
			FROM public.tbl_ampel_benutzer_bestaetigt a
			WHERE a.ampel_id = ' . $this->dbTable . '.ampel_id
			AND uid = ' . $this->escape($uid) . ' LIMIT 1), false) = FALSE) AND 
			(
			(
				(NOW()<(deadline+(COALESCE(verfallszeit,0) || \' days\')::interval)::date)
				OR (verfallszeit IS NULL)
			)
			AND 
			(
				(NOW()>(deadline-(COALESCE(vorlaufzeit,0) || \' days\')::interval)::date)
			    OR (vorlaufzeit IS NULL AND NOW() < deadline)
			)
			)';

		$this->addOrder('deadline', 'DESC');
		return $this->loadWhere($whereStatement);

	}

	/**
	 * Returns all Ampel-receiver of a specific Ampel.
	 * @param string $benutzer_select SQL Statement which defines the Ampel-receiver.
	 * @return stdClass Returns array of objects with property 'uid'.
	 */
	public function execBenutzerSelect($benutzer_select)
	{
		if (!isEmptyString($benutzer_select))
		{
			return $this->execQuery($benutzer_select);
		}
	}

	/**
	 * Checks if Ampel was confirmed by the user.
	 * @param int $ampel_id Ampel-ID
	 * @param string $uid UID
	 * @return bool
	 */
	public function isConfirmed($ampel_id, $uid)
	{
		$result = null;
		$query = '
			SELECT 1
			  FROM public.tbl_ampel_benutzer_bestaetigt
			 WHERE ampel_id = ?
			   AND uid = ?';

		if (isset($ampel_id, $uid))
		{
			$result = $this->execQuery($query, array($ampel_id, $uid));
		}

		if ($result)
		{
			if (count($result->retval) > 0)
			{
				return true;
			}
			else
			{
				return false;
			}
		}
		else
			return $result; //will contain the error-msg from execQuery
	}

	/**
	 * checks if a user is assigned to an ampel
	 * @param string $uid userID
	 * @param string $benutzer_select the select query which gets all the user that are assigned to an ampel
	 * @return stdClass 
	 */
	public function isZugeteilt($uid, $benutzer_select){
		$zugeteilt = $this->execReadOnlyQuery("
			SELECT 
				CASE WHEN ? IN (".$benutzer_select.") 
					THEN true 
					ELSE false
				END as zugeteilt	
			", [$uid]);

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

		$zugeteilt = getData($zugeteilt);

		return success(current($zugeteilt)->zugeteilt);
	}

	// THIS FUNCTION IS NOT IN USE
	// fetches all ampeln that were assigned to the user after the working start_date
	function alleAmpeln($uid){
		$userLanguage = getUserLanguage();

		$zugeteile_ampeln = [];
		
		$datum = new datum();
		$now = $datum->mktime_fromdate(date('Y-m-d'));

		// start date of user
		$benutzerStartDate = $this->execReadOnlyQuery("
			SELECT insertamum FROM public.tbl_benutzer WHERE uid = ?", [$uid]);
		$benutzerStartDate = $datum->mktime_fromdate(date(current(getData($benutzerStartDate))->insertamum));

		$allAmpeln = $this->execReadOnlyQuery("
			SELECT *, beschreibung[(".$this->getLanguageIndex($this->escape($userLanguage)).")] as beschreibung_trans, buttontext[(".$this->getLanguageIndex($this->escape($userLanguage)).")] as buttontext_trans FROM 
			public.tbl_ampel");
		
		if(isError($allAmpeln)) return error(getError($allAmpeln));

		$allAmpeln = getData($allAmpeln);
		foreach($allAmpeln as $ampel){

			// check if the ampel is assigned to the user
			$zugeteilt = $this->execReadOnlyQuery("
			SELECT 
				CASE WHEN ? IN (".$ampel->benutzer_select.") 
					THEN true 
					ELSE false
				END as zugeteilt	
			", [$uid]);
			
			if(isError($zugeteilt)) return error(getError($zugeteilt));

			$zugeteilt = current(getData($zugeteilt))->zugeteilt;
			
			
			// abgelaufen check
			// $now > strtotime('+' . $ampel->verfallszeit . ' day', $ampel->deadline)

			if(
				// aktuelles datum liegt vor der Vorlaufzeit der Ampel
				(isset($ampel->vorlaufzeit) && $now < strtotime('-' .  $ampel->vorlaufzeit . ' day', $datum->mktime_fromdate($ampel->deadline)))
				||
				// ampel ist vor Arbeitsstart abgelaufen
				(isset($ampel->verfallszeit) && $benutzerStartDate > strtotime('+' . $ampel->verfallszeit . ' day', $datum->mktime_fromdate($ampel->deadline)))
				||
				// ampel ist vor Arbeitsstart abgelaufen (verfallszeit nicht vorhanden)
				($benutzerStartDate > strtotime('+' . $ampel->verfallszeit . ' day', $datum->mktime_fromdate($ampel->deadline)))
			){
				// continue iteration if ampel is expired before work start or shouldn't be visible yet
				continue;
			}

			$ampel->zugeteilt = $zugeteilt;

			if($zugeteilt) $zugeteile_ampeln[] = $ampel; 
			   
		}

		return success($zugeteile_ampeln);
	}

	private function getLanguageIndex($userLanguage)
	{
		return "
			SELECT index 
			FROM public.tbl_sprache 
			WHERE sprache = " . $userLanguage;
	}

}