2009-09-09 20:39:26 +03:00
|
|
|
|
<?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
|
|
|
|
|
*
|
|
|
|
|
---------------------------------------------------------
|
|
|
|
|
*/
|
|
|
|
|
|
2012-06-24 13:47:34 +03:00
|
|
|
|
/**
|
|
|
|
|
* Маппер для работы с БД
|
|
|
|
|
*
|
|
|
|
|
* @package modules.notify
|
|
|
|
|
* @since 1.0
|
|
|
|
|
*/
|
|
|
|
|
class ModuleNotify_MapperNotify extends Mapper {
|
|
|
|
|
/**
|
|
|
|
|
* Добавляет задание
|
|
|
|
|
*
|
|
|
|
|
* @param ModuleNotify_EntityTask $oNotifyTask Объект задания
|
|
|
|
|
* @return bool
|
|
|
|
|
*/
|
2010-05-27 18:16:20 +03:00
|
|
|
|
public function AddTask(ModuleNotify_EntityTask $oNotifyTask) {
|
2009-09-09 20:39:26 +03:00
|
|
|
|
$sql = "
|
|
|
|
|
INSERT INTO ".Config::Get('db.table.notify_task')."
|
|
|
|
|
( user_login, user_mail, notify_subject, notify_text, date_created, notify_task_status )
|
|
|
|
|
VALUES
|
|
|
|
|
( ?, ?, ?, ?, ?, ?d )
|
|
|
|
|
";
|
2012-06-24 13:47:34 +03:00
|
|
|
|
|
2009-09-09 20:39:26 +03:00
|
|
|
|
if ($this->oDb->query(
|
|
|
|
|
$sql,
|
|
|
|
|
$oNotifyTask->getUserLogin(),
|
|
|
|
|
$oNotifyTask->getUserMail(),
|
|
|
|
|
$oNotifyTask->getNotifySubject(),
|
|
|
|
|
$oNotifyTask->getNotifyText(),
|
|
|
|
|
$oNotifyTask->getDateCreated(),
|
2012-06-24 13:47:34 +03:00
|
|
|
|
$oNotifyTask->getTaskStatus()
|
2009-09-09 20:39:26 +03:00
|
|
|
|
)===0) {
|
|
|
|
|
return true;
|
2012-06-24 13:47:34 +03:00
|
|
|
|
}
|
2009-09-09 20:39:26 +03:00
|
|
|
|
return false;
|
|
|
|
|
}
|
2012-06-24 13:47:34 +03:00
|
|
|
|
/**
|
|
|
|
|
* Добавляет задания списком
|
|
|
|
|
*
|
|
|
|
|
* @param array $aTasks Список объектов заданий
|
|
|
|
|
* @return bool
|
|
|
|
|
*/
|
2009-09-09 20:39:26 +03:00
|
|
|
|
public function AddTaskArray($aTasks) {
|
|
|
|
|
if(!is_array($aTasks)&&count($aTasks)==0) {
|
|
|
|
|
return false;
|
|
|
|
|
}
|
2012-06-24 13:47:34 +03:00
|
|
|
|
|
2009-09-09 20:39:26 +03:00
|
|
|
|
$aValues=array();
|
|
|
|
|
foreach ($aTasks as $oTask) {
|
2012-06-24 13:47:34 +03:00
|
|
|
|
$aValues[]="(".implode(',',
|
|
|
|
|
array(
|
|
|
|
|
$this->oDb->escape($oTask->getUserLogin()),
|
|
|
|
|
$this->oDb->escape($oTask->getUserMail()),
|
|
|
|
|
$this->oDb->escape($oTask->getNotifySubject()),
|
|
|
|
|
$this->oDb->escape($oTask->getNotifyText()),
|
|
|
|
|
$this->oDb->escape($oTask->getDateCreated()),
|
|
|
|
|
$this->oDb->escape($oTask->getTaskStatus())
|
|
|
|
|
)
|
2009-09-09 20:39:26 +03:00
|
|
|
|
).")";
|
|
|
|
|
}
|
|
|
|
|
$sql = "
|
|
|
|
|
INSERT INTO ".Config::Get('db.table.notify_task')."
|
|
|
|
|
( user_login, user_mail, notify_subject, notify_text, date_created, notify_task_status )
|
|
|
|
|
VALUES
|
2012-06-24 13:47:34 +03:00
|
|
|
|
".implode(', ', $aValues);
|
2009-09-09 20:39:26 +03:00
|
|
|
|
|
|
|
|
|
return $this->oDb->query($sql);
|
|
|
|
|
}
|
2012-06-24 13:47:34 +03:00
|
|
|
|
/**
|
|
|
|
|
* Удаляет задание
|
|
|
|
|
*
|
|
|
|
|
* @param ModuleNotify_EntityTask $oNotifyTask Объект задания
|
|
|
|
|
* @return bool
|
|
|
|
|
*/
|
2010-05-27 18:16:20 +03:00
|
|
|
|
public function DeleteTask(ModuleNotify_EntityTask $oNotifyTask) {
|
2009-09-09 20:39:26 +03:00
|
|
|
|
$sql = "
|
|
|
|
|
DELETE FROM ".Config::Get('db.table.notify_task')."
|
|
|
|
|
WHERE
|
|
|
|
|
notify_task_id = ?d
|
2012-06-24 13:47:34 +03:00
|
|
|
|
";
|
2013-07-10 10:39:15 +03:00
|
|
|
|
$res=$this->oDb->query($sql,$oNotifyTask->getTaskId());
|
|
|
|
|
return $res===false or is_null($res) ? false : true;
|
2009-09-09 20:39:26 +03:00
|
|
|
|
}
|
2012-06-24 13:47:34 +03:00
|
|
|
|
/**
|
|
|
|
|
* Удаляет отложенные Notify-задания по списку идентификаторов
|
|
|
|
|
*
|
|
|
|
|
* @param array $aTaskId Список ID заданий на отправку
|
|
|
|
|
* @return bool
|
|
|
|
|
*/
|
2009-09-09 20:39:26 +03:00
|
|
|
|
public function DeleteTaskByArrayId($aTaskId) {
|
|
|
|
|
$sql = "
|
|
|
|
|
DELETE FROM ".Config::Get('db.table.notify_task')."
|
|
|
|
|
WHERE
|
|
|
|
|
notify_task_id IN(?a)
|
2012-06-24 13:47:34 +03:00
|
|
|
|
";
|
2013-07-10 10:39:15 +03:00
|
|
|
|
$res=$this->oDb->query($sql,$aTaskId);
|
|
|
|
|
return $res===false or is_null($res) ? false : true;
|
2009-09-09 20:39:26 +03:00
|
|
|
|
}
|
2012-06-24 13:47:34 +03:00
|
|
|
|
/**
|
|
|
|
|
* Получает массив заданий на публикацию из базы с указанным количественным ограничением (выборка FIFO)
|
|
|
|
|
*
|
|
|
|
|
* @param int $iLimit Количество
|
|
|
|
|
* @return array
|
|
|
|
|
*/
|
2009-09-09 20:39:26 +03:00
|
|
|
|
public function GetTasks($iLimit) {
|
2009-09-10 21:51:58 +03:00
|
|
|
|
$sql = "SELECT *
|
|
|
|
|
FROM ".Config::Get('db.table.notify_task')."
|
|
|
|
|
ORDER BY date_created ASC
|
|
|
|
|
LIMIT ?d";
|
|
|
|
|
$aTasks=array();
|
|
|
|
|
if ($aRows=$this->oDb->select($sql,$iLimit)) {
|
|
|
|
|
foreach ($aRows as $aTask) {
|
|
|
|
|
$aTasks[]=Engine::GetEntity('Notify_Task',$aTask);
|
|
|
|
|
}
|
2012-06-24 13:47:34 +03:00
|
|
|
|
}
|
|
|
|
|
return $aTasks;
|
2009-09-09 20:39:26 +03:00
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
?>
|