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

<?php
/*
 * LiveStreet CMS
 * Copyright © 2013 OOO "ЛС-СОФТ"
 *
 * ------------------------------------------------------
 *
 * Official site: www.livestreetcms.com
 * Contact e-mail: office@livestreetcms.com
 *
 * GNU General Public License, version 2:
 * http://www.gnu.org/licenses/old-licenses/gpl-2.0.html
 *
 * ------------------------------------------------------
 *
 * @link http://www.livestreetcms.com
 * @copyright 2013 OOO "ЛС-СОФТ"
 * @author Maxim Mzhelskiy <rus.engine@gmail.com>
 *
 */

/**
 * Модуль Wall - записи на стене профиля пользователя
 *
 * @package application.modules.wall
 * @since 1.0
 */
class ModuleWall extends Module
{
    /**
     * Объект маппера
     *
     * @var ModuleWall_MapperWall
     */
    protected $oMapper;
    /**
     * Объект текущего пользователя
     *
     * @var ModuleUser_EntityUser|null
     */
    protected $oUserCurrent;

    /**
     * Инициализация
     *
     */
    public function Init()
    {
        $this->oMapper = Engine::GetMapper(__CLASS__);
        $this->oUserCurrent = $this->User_GetUserCurrent();
    }

    /**
     * Добавление записи на стену
     *
     * @param ModuleWall_EntityWall $oWall Объект записи на стене
     * @return bool|ModuleWall_EntityWall
     */
    public function AddWall($oWall)
    {
        if (!$oWall->getDateAdd()) {
            $oWall->setDateAdd(date("Y-m-d H:i:s"));
        }
        if (!$oWall->getIp()) {
            $oWall->setIp(func_getIp());
        }
        if ($iId = $this->oMapper->AddWall($oWall)) {
            $oWall->setId($iId);
            /**
             * Обновляем данные у родительской записи
             */
            if ($oPidWall = $oWall->GetPidWall()) {
                $this->UpdatePidWall($oPidWall);
            }
            return $oWall;
        }
        return false;
    }

    /**
     * Обновление записи
     *
     * @param ModuleWall_EntityWall $oWall Объект записи на стене
     * @return bool
     */
    public function UpdateWall($oWall)
    {
        return $this->oMapper->UpdateWall($oWall);
    }

    /**
     * Получение списка записей по фильтру
     *
     * @param array $aFilter Фильтр
     * @param array $aOrder Сортировка
     * @param int $iCurrPage Номер страницы
     * @param int $iPerPage Количество элементов на страницу
     * @param array $aAllowData Список типов дополнительных данных для подгрузки в сообщения стены
     * @return array('collection'=>array,'count'=>int)
     */
    public function GetWall($aFilter, $aOrder, $iCurrPage = 1, $iPerPage = 10, $aAllowData = null)
    {
        $aResult = array(
            'collection' => $this->oMapper->GetWall($aFilter, $aOrder, $iCount, $iCurrPage, $iPerPage),
            'count'      => $iCount
        );
        $aResult['collection'] = $this->GetWallAdditionalData($aResult['collection'], $aAllowData);
        return $aResult;
    }

    /**
     * Возвращает число сообщений на стене по фильтру
     *
     * @param array $aFilter Фильтр
     * @return int
     */
    public function GetCountWall($aFilter)
    {
        return $this->oMapper->GetCountWall($aFilter);
    }

    /**
     * Получение записей по ID, без дополнительных данных
     *
     * @param array $aWallId Список ID сообщений
     * @return array
     */
    public function GetWallsByArrayId($aWallId)
    {
        if (!is_array($aWallId)) {
            $aWallId = array($aWallId);
        }
        $aWallId = array_unique($aWallId);
        $aWalls = array();
        $aResult = $this->oMapper->GetWallsByArrayId($aWallId);
        foreach ($aResult as $oWall) {
            $aWalls[$oWall->getId()] = $oWall;
        }
        return $aWalls;
    }

    /**
     * Получение записей по ID с дополнительные связаными данными
     *
     * @param array $aWallId Список ID сообщений
     * @param array $aAllowData Список типов дополнительных данных для подгрузки в сообщения стены
     * @return array
     */
    public function GetWallAdditionalData($aWallId, $aAllowData = null)
    {
        if (is_null($aAllowData)) {
            $aAllowData = array('user' => array(), 'wall_user' => array(), 'reply');
        }
        func_array_simpleflip($aAllowData);
        if (!is_array($aWallId)) {
            $aWallId = array($aWallId);
        }

        $aWalls = $this->GetWallsByArrayId($aWallId);
        /**
         * Формируем ID дополнительных данных, которые нужно получить
         */
        $aUserId = array();
        $aWallUserId = array();
        $aWallReplyId = array();
        foreach ($aWalls as $oWall) {
            if (isset($aAllowData['user'])) {
                $aUserId[] = $oWall->getUserId();
            }
            if (isset($aAllowData['wall_user'])) {
                $aWallUserId[] = $oWall->getWallUserId();
            }
            /**
             * Список последних записей хранится в строке через запятую
             */
            if (isset($aAllowData['reply']) and is_null($oWall->getPid()) and $oWall->getLastReply()) {
                $aReply = explode(',', trim($oWall->getLastReply()));
                $aWallReplyId = array_merge($aWallReplyId, $aReply);
            }
        }
        /**
         * Получаем дополнительные данные
         */
        $aUsers = isset($aAllowData['user']) && is_array($aAllowData['user']) ? $this->User_GetUsersAdditionalData($aUserId,
            $aAllowData['user']) : $this->User_GetUsersAdditionalData($aUserId);
        $aWallUsers = isset($aAllowData['wall_user']) && is_array($aAllowData['wall_user']) ? $this->User_GetUsersAdditionalData($aWallUserId,
            $aAllowData['wall_user']) : $this->User_GetUsersAdditionalData($aWallUserId);
        $aWallReply = array();
        if (isset($aAllowData['reply']) and count($aWallReplyId)) {
            $aWallReply = $this->GetWallAdditionalData($aWallReplyId, array('user' => array()));
        }
        /**
         * Добавляем данные к результату
         */
        foreach ($aWalls as $oWall) {
            if (isset($aUsers[$oWall->getUserId()])) {
                $oWall->setUser($aUsers[$oWall->getUserId()]);
            } else {
                $oWall->setUser(null); // или $oWall->setUser(new ModuleUser_EntityUser());
            }
            if (isset($aWallUsers[$oWall->getWallUserId()])) {
                $oWall->setWallUser($aWallUsers[$oWall->getWallUserId()]);
            } else {
                $oWall->setWallUser(null);
            }
            $aReply = array();
            if ($oWall->getLastReply()) {
                $aReplyId = explode(',', trim($oWall->getLastReply()));
                foreach ($aReplyId as $iReplyId) {
                    if (isset($aWallReply[$iReplyId])) {
                        $aReply[] = $aWallReply[$iReplyId];
                    }
                }
            }
            $oWall->setLastReplyWall($aReply);
        }
        return $aWalls;
    }

    /**
     * Получение записи по ID
     *
     * @param int $iId ID сообщения/записи
     * @return ModuleWall_EntityWall
     */
    public function GetWallById($iId)
    {
        if (!is_numeric($iId)) {
            return null;
        }
        $aResult = $this->GetWallAdditionalData($iId);
        if (isset($aResult[$iId])) {
            return $aResult[$iId];
        }
        return null;
    }

    /**
     * Обновляет родительские данные у записи - количество ответов и ID последних ответов
     *
     * @param ModuleWall_EntityWall $oWall Объект записи на стене
     * @param null|int $iLimit
     */
    public function UpdatePidWall($oWall, $iLimit = null)
    {
        if (is_null($iLimit)) {
            $iLimit = Config::Get('module.wall.count_last_reply');
        }

        $aResult = $this->GetWall(array('pid' => $oWall->getId()), array('id' => 'desc'), 1, $iLimit, array());
        if ($aResult['count']) {
            $oWall->setCountReply($aResult['count']);
            $aKeys = array_keys($aResult['collection']);
            sort($aKeys, SORT_NUMERIC);
            $oWall->setLastReply(join(',', $aKeys));
        } else {
            $oWall->setCountReply(0);
            $oWall->setLastReply('');
        }
        $this->UpdateWall($oWall);
    }

    /**
     * Удаление сообщения
     *
     * @param ModuleWall_EntityWall $oWall Объект записи на стене
     */
    public function DeleteWall($oWall)
    {
        $this->oMapper->DeleteWallsByPid($oWall->getId());
        $this->oMapper->DeleteWallById($oWall->getId());
        if ($oWallParent = $oWall->GetPidWall()) {
            $this->UpdatePidWall($oWallParent);
        }
    }

    /**
     * Уведомление при ответе на сообщение на стене
     *
     * @param ModuleWall_EntityWall $oWallParent Объект сообщения на стене, на которое отвечаем
     * @param ModuleWall_EntityWall $oWall Объект нового сообщения на стене
     * @param ModuleUser_EntityUser $oUser Объект пользователя
     */
    public function SendNotifyWallReply(
        ModuleWall_EntityWall $oWallParent,
        ModuleWall_EntityWall $oWall,
        ModuleUser_EntityUser $oUser
    ) {
        $this->Notify_Send(
            $oWallParent->getUser(),
            'wall.reply.tpl',
            $this->Lang_Get('emails.wall_reply.subject'),
            array(
                'oWallParent' => $oWallParent,
                'oUserTo'     => $oWallParent->getUser(),
                'oWall'       => $oWall,
                'oUser'       => $oUser,
                'oUserWall'   => $oWall->getWallUser(), // кому принадлежит стена
            )
        );
    }

    /**
     * Уведомление о новом сообщение на стене
     *
     * @param ModuleWall_EntityWall $oWall Объект нового сообщения на стене
     * @param ModuleUser_EntityUser $oUser Объект пользователя
     */
    public function SendNotifyWallNew(ModuleWall_EntityWall $oWall, ModuleUser_EntityUser $oUser)
    {
        $this->Notify_Send(
            $oWall->getWallUser(),
            'wall.new.tpl',
            $this->Lang_Get('emails.wall_new.subject'),
            array(
                'oUserTo'   => $oWall->getWallUser(),
                'oWall'     => $oWall,
                'oUser'     => $oUser,
                'oUserWall' => $oWall->getWallUser(), // кому принадлежит стена
            )
        );
    }
}