ifhub.club/application/classes/modules/wall/mapper/Wall.mapper.class.php

<?php
/*-------------------------------------------------------
*
*   LiveStreet Engine Social Networking
*   Copyright © 2008 Mzhelskiy Maxim
*
*--------------------------------------------------------
*
*   Official site: www.livestreet.ru
*   Contact e-mail: rus.engine@gmail.com
*
*   GNU General Public License, version 2:
*   http://www.gnu.org/licenses/old-licenses/gpl-2.0.html
*
---------------------------------------------------------
*/

/**
 * Маппер для работы с БД
 *
 * @package modules.wall
 * @since 1.0
 */
class ModuleWall_MapperWall extends Mapper {
	/**
	 * Добавление записи на стену
	 *
	 * @param ModuleWall_EntityWall $oWall	Объект записи на стене
	 * @return bool|int
	 */
	public function AddWall($oWall) {
		$sql = "INSERT INTO ".Config::Get('db.table.wall')." SET ?a ";
		if ($iId=$this->oDb->query($sql,$oWall->_getData())) {
			return $iId;
		}
		return false;
	}
	/**
	 * Обновление записи
	 *
	 * @param ModuleWall_EntityWall $oWall	Объект записи на стене
	 * @return bool
	 */
	public function UpdateWall($oWall) {
		$sql = "UPDATE ".Config::Get('db.table.wall')."
			SET 
			 	count_reply = ?d,
			 	last_reply = ?
			WHERE id = ?d
		";
		$res=$this->oDb->query($sql,$oWall->getCountReply(),
								 $oWall->getLastReply(),
								 $oWall->getId());
		return $this->IsSuccessful($res);
	}
	/**
	 * Удаление записи
	 *
	 * @param int $iId ID записи
	 * @return bool
	 */
	public function DeleteWallById($iId) {
		$sql = "DELETE FROM ".Config::Get('db.table.wall')." WHERE id = ?d ";
		$res=$this->oDb->query($sql,$iId);
		return $this->IsSuccessful($res);
	}
	/**
	 * @param int $iPid	ID родительской записи
	 * @return bool
	 */
	public function DeleteWallsByPid($iPid) {
		$sql = "DELETE FROM ".Config::Get('db.table.wall')." WHERE pid = ?d ";
		$res=$this->oDb->query($sql,$iPid);
		return $this->IsSuccessful($res);
	}
	/**
	 * Получение списка записей по фильтру
	 *
	 * @param array $aFilter	Фильтр
	 * @param array $aOrder	Сортировка
	 * @param int $iCount	Возвращает общее количество элементов
	 * @param int $iCurrPage	Номер страницы
	 * @param int $iPerPage	Количество элементов на страницу
	 * @return array
	 */
	public function GetWall($aFilter,$aOrder,&$iCount,$iCurrPage,$iPerPage) {
		$aOrderAllow=array('id','date_add');
		$sOrder='';
		foreach ($aOrder as $key=>$value) {
			if (!in_array($key,$aOrderAllow)) {
				unset($aOrder[$key]);
			} elseif (in_array($value,array('asc','desc'))) {
				$sOrder.=" {$key} {$value},";
			}
		}
		$sOrder=trim($sOrder,',');
		if ($sOrder=='') {
			$sOrder=' id desc ';
		}


		$sql = "SELECT
					id
				FROM
					".Config::Get('db.table.wall')."
				WHERE
					1 = 1
					{ AND pid = ?d }
					{ AND pid IS NULL AND 1 = ?d }
					{ AND wall_user_id = ?d }
					{ AND user_id = ?d }
					{ AND ip = ? }
					{ AND id = ?d }
					{ AND id < ?d }
					{ AND id > ?d }
				ORDER by {$sOrder}
				LIMIT ?d, ?d ;
					";
		$aResult=array();
		if ($aRows=$this->oDb->selectPage($iCount,$sql,
										  (isset($aFilter['pid']) and !is_null($aFilter['pid'])) ? $aFilter['pid'] : DBSIMPLE_SKIP,
										  (array_key_exists('pid',$aFilter) and is_null($aFilter['pid'])) ? 1 : DBSIMPLE_SKIP,
										  isset($aFilter['wall_user_id']) ? $aFilter['wall_user_id'] : DBSIMPLE_SKIP,
										  isset($aFilter['user_id']) ? $aFilter['user_id'] : DBSIMPLE_SKIP,
										  isset($aFilter['ip']) ? $aFilter['ip'] : DBSIMPLE_SKIP,
										  isset($aFilter['id']) ? $aFilter['id'] : DBSIMPLE_SKIP,
										  isset($aFilter['id_less']) ? $aFilter['id_less'] : DBSIMPLE_SKIP,
										  isset($aFilter['id_more']) ? $aFilter['id_more'] : DBSIMPLE_SKIP,
										  ($iCurrPage-1)*$iPerPage, $iPerPage
		)) {
			foreach ($aRows as $aRow) {
				$aResult[]=$aRow['id'];
			}
		}
		return $aResult;
	}
	/**
	 * Возвращает число сообщений на стене по фильтру
	 *
	 * @param array $aFilter	Фильтр
	 * @return int
	 */
	public function GetCountWall($aFilter) {
		$sql = "SELECT
					count(*) as c
				FROM
					".Config::Get('db.table.wall')."
				WHERE
					1 = 1
					{ AND pid = ?d }
					{ AND pid IS NULL AND 1 = ?d }
					{ AND wall_user_id = ?d }
					{ AND ip = ? }
					{ AND id = ?d }
					{ AND id < ?d }
					{ AND id > ?d };
					";
		if ($aRow=$this->oDb->selectRow($sql,
										(isset($aFilter['pid']) and !is_null($aFilter['pid'])) ? $aFilter['pid'] : DBSIMPLE_SKIP,
										(array_key_exists('pid',$aFilter) and is_null($aFilter['pid'])) ? 1 : DBSIMPLE_SKIP,
										isset($aFilter['wall_user_id']) ? $aFilter['wall_user_id'] : DBSIMPLE_SKIP,
										isset($aFilter['ip']) ? $aFilter['ip'] : DBSIMPLE_SKIP,
										isset($aFilter['id']) ? $aFilter['id'] : DBSIMPLE_SKIP,
										isset($aFilter['id_less']) ? $aFilter['id_less'] : DBSIMPLE_SKIP,
										isset($aFilter['id_more']) ? $aFilter['id_more'] : DBSIMPLE_SKIP
		)) {
			return $aRow['c'];
		}
		return 0;
	}
	/**
	 * Получение записей по ID, без дополнительных данных
	 *
	 * @param array $aArrayId	Список ID сообщений
	 * @return array
	 */
	public function GetWallsByArrayId($aArrayId) {
		if (!is_array($aArrayId) or count($aArrayId)==0) {
			return array();
		}

		$sql = "SELECT
					*
				FROM
					".Config::Get('db.table.wall')."
				WHERE
					id IN(?a)
				ORDER BY FIELD(id,?a) ";
		$aResult=array();
		if ($aRows=$this->oDb->select($sql,$aArrayId,$aArrayId)) {
			foreach ($aRows as $aRow) {
				$aResult[]=Engine::GetEntity('Wall',$aRow);
			}
		}
		return $aResult;
	}
}