forkbb/app/Models/Topic/Model.php

<?php

namespace ForkBB\Models\Topic;

use ForkBB\Models\DataModel;
use PDO;
use RuntimeException;

class Model extends DataModel
{
    /**
     * Получение родительского раздела
     *
     * @throws RuntimeException
     *
     * @return Forum
     */
    protected function getparent()
    {
        if ($this->forum_id < 1) {
            throw new RuntimeException('Parent is not defined');
        }

        return $this->c->forums->get($this->forum_id);
    }

    /**
     * Статус возможности ответа в теме
     *
     * @return bool
     */
    protected function getcanReply()
    {
        if ($this->c->user->isAdmin) {
            return true;
        } elseif ($this->closed || $this->c->user->isBot) {
            return false;
        } elseif ($this->parent->post_replies == '1'
            || (null === $this->parent->post_replies && $this->c->user->g_post_replies == '1')
            || $this->c->user->isModerator($this)
        ) {
            return true;
        } else {
            return false;
        }
    }

    /**
     * Ссылка на тему
     *
     * @return string
     */
    protected function getlink()
    {
        return $this->c->Router->link('Topic', ['id' => $this->moved_to ?: $this->id, 'name' => \ForkBB\cens($this->subject)]);
    }

    /**
     * Ссылка для ответа в теме
     *
     * @return string
     */
    protected function getlinkReply()
    {
        return $this->c->Router->link('NewReply', ['id' => $this->id]);
    }

    /**
     * Ссылка для перехода на последнее сообщение темы
     *
     * @return null|string
     */
    protected function getlinkLast()
    {
        if ($this->moved_to) {
            return null;
        } else {
            return $this->c->Router->link('ViewPost', ['id' => $this->last_post_id]);
        }
    }

    /**
     * Ссылка для перехода на первое новое сообщение в теме
     *
     * @return string
     */
    protected function getlinkNew()
    {
        return $this->c->Router->link('TopicViewNew', ['id' => $this->id]);
    }

    /**
     * Ссылка для перехода на первое не прочитанное сообщение в теме
     */
    protected function getlinkUnread()
    {
        return $this->c->Router->link('TopicViewUnread', ['id' => $this->id]);
    }

    /**
     * Статус наличия новых сообщений в теме
     *
     * @return false|int
     */
    protected function gethasNew()
    {
        if ($this->c->user->isGuest || $this->moved_to) {
            return false;
        }

        $time = \max(
            (int) $this->c->user->u_mark_all_read,
            (int) $this->parent->mf_mark_all_read,
            (int) $this->c->user->last_visit,
            (int) $this->mt_last_visit
        );

        return $this->last_post > $time ? $time : false;
    }

    /**
     * Статус наличия непрочитанных сообщений в теме
     *
     * @return false|int
     */
    protected function gethasUnread()
    {
        if ($this->c->user->isGuest || $this->moved_to) {
            return false;
        }

        $time = \max(
            (int) $this->c->user->u_mark_all_read,
            (int) $this->parent->mf_mark_all_read,
            (int) $this->mt_last_read
        );

        return $this->last_post > $time ? $time : false;
    }

    /**
     * Номер первого нового сообщения в теме
     *
     * @return int
     */
    protected function getfirstNew()
    {
        if (false === $this->hasNew) {
            return 0;
        }

        $vars = [
            ':tid'   => $this->id,
            ':visit' => $this->hasNew,
        ];
        $sql = 'SELECT MIN(p.id) FROM ::posts AS p WHERE p.topic_id=?i:tid AND p.posted>?i:visit';

        $pid = $this->c->DB->query($sql, $vars)->fetchColumn();

        return $pid ?: 0;
    }

    /**
     * Номер первого не прочитанного сообщения в теме
     *
     * @return int
     */
    protected function getfirstUnread()
    {
        if (false === $this->hasUnread) {
            return 0;
        }

        $vars = [
            ':tid'   => $this->id,
            ':visit' => $this->hasUnread,
        ];
        $sql = 'SELECT MIN(p.id) FROM ::posts AS p WHERE p.topic_id=?i:tid AND p.posted>?i:visit';

        $pid = $this->c->DB->query($sql, $vars)->fetchColumn();

        return $pid ?: 0;
    }

    /**
     * Количество страниц в теме
     *
     * @throws RuntimeException
     *
     * @return int
     */
    protected function getnumPages()
    {
        if (null === $this->num_replies) {
            throw new RuntimeException('The model does not have the required data');
        }

        return (int) \ceil(($this->num_replies + 1) / $this->c->user->disp_posts);
    }

    /**
     * Массив страниц темы
     *
     * @return array
     */
    protected function getpagination()
    {
        $page = (int) $this->page;

        if ($page < 1 && $this->numPages === 1) {
            // 1 страницу в списке тем раздела не отображаем
            return [];
        } else { //????
            return $this->c->Func->paginate($this->numPages, $page, 'Topic', ['id' => $this->id, 'name' => \ForkBB\cens($this->subject)]);
        }
    }

    /**
     * Статус наличия установленной страницы в теме
     *
     * @return bool
     */
    public function hasPage()
    {
        return $this->page > 0 && $this->page <= $this->numPages;
    }

    /**
     * Возвращает массив сообщений с установленной страницы
     *
     * @throws InvalidArgumentException
     *
     * @return array
     */
    public function pageData()
    {
        if (! $this->hasPage()) {
            throw new InvalidArgumentException('Bad number of displayed page');
        }

        $vars = [
            ':tid'    => $this->id,
            ':offset' => ($this->page - 1) * $this->c->user->disp_posts,
            ':rows'   => $this->c->user->disp_posts,
        ];
        $sql = 'SELECT p.id
                FROM ::posts AS p
                WHERE p.topic_id=?i:tid
                ORDER BY p.id
                LIMIT ?i:offset, ?i:rows';
        $list = $this->c->DB->query($sql, $vars)->fetchAll(PDO::FETCH_COLUMN);

        if (! empty($list) && ($this->stick_fp || $this->poll_type) && ! \in_array($this->first_post_id, $list)) {
            \array_unshift($list, $this->first_post_id);
        }

        $this->idsList = $list;

        return empty($this->idsList) ? [] : $this->c->posts->view($this);
    }

    /**
     * Возвращает массив сообщений обзора темы
     *
     * @return array
     */
    public function review()
    {
        if ($this->c->config->o_topic_review < 1) {
            return [];
        }

        $this->page = 1;

        $vars = [
            ':tid'    => $this->id,
            ':rows'   => $this->c->config->o_topic_review,
        ];
        $sql = 'SELECT p.id
                FROM ::posts AS p
                WHERE p.topic_id=?i:tid
                ORDER BY p.id DESC
                LIMIT 0, ?i:rows';
        $this->idsList = $this->c->DB->query($sql, $vars)->fetchAll(PDO::FETCH_COLUMN);

        return empty($this->idsList) ? [] : $this->c->posts->view($this, true);
    }

    /**
     * Вычисляет страницу темы на которой находится данное сообщение
     *
     * @param int $pid
     */
    public function calcPage($pid)
    {
        $vars = [
            ':tid' => $this->id,
            ':pid' => $pid,
        ];
        $sql = 'SELECT COUNT(p.id) AS num, j.id AS flag
                FROM ::posts AS p
                INNER JOIN ::posts AS j ON (j.topic_id=?i:tid AND j.id=?i:pid)
                WHERE p.topic_id=?i:tid AND p.id<?i:pid';

        $result = $this->c->DB->query($sql, $vars)->fetch();

        $this->page = empty($result['flag']) ? null : (int) \ceil(($result['num'] + 1) / $this->c->user->disp_posts);
    }

    /**
     * Статус показа/подсчета просмотров темы
     *
     * @return bool
     */
    protected function getshowViews()
    {
        return $this->c->config->o_topic_views == '1';
    }

    /**
     * Увеличивает на 1 количество просмотров темы
     */
    public function incViews()
    {
        $vars = [
            ':tid' => $this->id,
        ];
        $sql = 'UPDATE ::topics SET num_views=num_views+1 WHERE id=?i:tid';

        $this->c->DB->query($sql, $vars);
    }

    /**
     * Обновление меток последнего визита и последнего прочитанного сообщения
     */
    public function updateVisits()
    {
        if ($this->c->user->isGuest) {
            return;
        }

        $vars = [
            ':uid'   => $this->c->user->id,
            ':tid'   => $this->id,
            ':read'  => $this->mt_last_read,
            ':visit' => $this->mt_last_visit,
        ];
        $flag = false;

        if (false !== $this->hasNew) {
            $flag = true;
            $vars[':visit'] = $this->last_post;
        }
        if (false !== $this->hasUnread && $this->timeMax > $this->hasUnread) {
            $flag = true;
            $vars[':read'] = $this->timeMax;
            $vars[':visit'] = $this->last_post;
        }

        if ($flag) {
            if (empty($this->mt_last_read) && empty($this->mt_last_visit)) {
                $sql = 'INSERT INTO ::mark_of_topic (uid, tid, mt_last_visit, mt_last_read)
                        SELECT ?i:uid, ?i:tid, ?i:visit, ?i:read
                        FROM ::groups
                        WHERE NOT EXISTS (SELECT 1
                                          FROM ::mark_of_topic
                                          WHERE uid=?i:uid AND tid=?i:tid)
                        LIMIT 1';
            } else {
                $sql = 'UPDATE ::mark_of_topic
                        SET mt_last_visit=?i:visit, mt_last_read=?i:read
                        WHERE uid=?i:uid AND tid=?i:tid';
            }
            $this->c->DB->exec($sql, $vars);
        }
    }
}