topic.php

<?php
namespace Bitrix\Forum;
 
use Bitrix\Main;
use Bitrix\Forum;
use Bitrix\Main\Localization\Loc;
use Bitrix\Main\ORM\Event;
use Bitrix\Main\ORM\Fields\BooleanField;
use Bitrix\Main\ORM\Fields\DatetimeField;
use Bitrix\Main\ORM\Fields\EnumField;
use Bitrix\Main\ORM\Fields\IntegerField;
use Bitrix\Main\ORM\Fields\Relations\Reference;
use Bitrix\Main\ORM\Fields\StringField;
use Bitrix\Main\ORM\Fields\TextField;
use Bitrix\Main\ORM\Query\Join;
use Bitrix\Main\Type\DateTime;
 
class TopicTable extends Main\Entity\DataManager
{
    public static function getTableName()
    {
        return 'b_forum_topic';
    }
 
    public static function getMap()
    {
        return [
            (new IntegerField("ID", ["primary" => true, "autocomplete" => true])),
            (new IntegerField("FORUM_ID", ["required" => true])),
            (new IntegerField("TOPIC_ID")),
            (new StringField("TITLE", ["required" => true, "size" => 255])),
            (new StringField("TITLE_SEO", ["size" => 255])),
            (new StringField("TAGS", ["size" => 255])),
            (new StringField("DESCRIPTION", ["size" => 255])),
            (new StringField("ICON", ["size" => 255])),
            (new EnumField("STATE", ["values" => [Topic::STATE_OPENED, Topic::STATE_CLOSED, Topic::STATE_LINK], "default_value" => Topic::STATE_OPENED])),
            (new BooleanField("APPROVED", ["values" => [Topic::APPROVED_DISAPPROVED, Topic::APPROVED_APPROVED], "default_value" => Topic::APPROVED_APPROVED])),
            (new IntegerField("SORT", ["default_value" => 150])),
            (new IntegerField("VIEWS")),
            (new IntegerField("USER_START_ID")),
            (new StringField("USER_START_NAME", ["required" => true, "size" => 255])),
            (new DatetimeField("START_DATE", ["required" => true, "default_value" => function(){return new DateTime();}])),
            (new IntegerField("POSTS")),
            (new IntegerField("POSTS_SERVICE")),
            (new IntegerField("LAST_POSTER_ID")),
            (new StringField("LAST_POSTER_NAME", ["required" => true, "size" => 255])),
            (new DatetimeField("LAST_POST_DATE", ["required" => true, "default_value" => function(){return new DateTime();}])),
            (new IntegerField("LAST_MESSAGE_ID")),
            (new IntegerField("POSTS_UNAPPROVED", ["default_value" => 0])),
            (new IntegerField("ABS_LAST_POSTER_ID")),
            (new StringField("ABS_LAST_POSTER_NAME", ["size" => 255])),
            (new DatetimeField("ABS_LAST_POST_DATE", ["required" => true, "default_value" => function(){return new DateTime();}])),
            (new IntegerField("ABS_LAST_MESSAGE_ID")),
            (new StringField("XML_ID", ["size" => 255])),
            (new TextField("HTML")),
            (new IntegerField("SOCNET_GROUP_ID")),
            (new IntegerField("OWNER_ID")),
            (new Reference("FORUM", ForumTable::class, Join::on("this.FORUM_ID", "ref.ID")))
        ];
    }
 
    public static function getFilteredFields()
    {
        return [
            "TITLE",
            "TAGS",
            "DESCRIPTION",
            "USER_START_NAME",
            "LAST_POSTER_NAME",
            "ABS_LAST_POSTER_NAME"
        ];
    }
 
    public static function onBeforeAdd(Event $event)
    {
        $result = new Main\ORM\EventResult();
        $data = $event->getParameter("fields");
        if (Main\Config\Option::get("forum", "FILTER", "Y") == "Y")
        {
            $filteredFields = self::getFilteredFields();
            foreach ($filteredFields as $key)
            {
                $res[$key] = $val = array_key_exists($key, $data) ? $data[$key] : "";
                if (!empty($val))
                {
                    $res[$key] = \CFilterUnquotableWords::Filter($val);
                    if (empty($res[$key]))
                    {
                        $res[$key] = "*";
                    }
                }
            }
            $data["HTML"] = serialize($res);
        }
 
        $data["TITLE_SEO"] = array_key_exists("TITLE_SEO", $data) ? trim($data["TITLE_SEO"], " -") : "";
        if (empty($data["TITLE_SEO"]))
        {
            $data["TITLE_SEO"] = \CUtil::translit($data["TITLE"], LANGUAGE_ID, array("max_len"=>255, "safe_chars"=>".", "replace_space" => '-'));
        }
 
        if ($data != $event->getParameter("fields"))
        {
            $result->modifyFields($data);
        }
 
        return self::modifyData($event, $result);
    }
 
    public static function onBeforeUpdate(Main\ORM\Event $event)
    {
        $result = new Main\ORM\EventResult();
        $data = $event->getParameter("fields");
        $id = $event->getParameter("id");
        $id = $id["ID"];
        $topic = TopicTable::getById($id)->fetch();
 
        if (Main\Config\Option::get("forum", "FILTER", "Y") == "Y")
        {
            $filteredFields = self::getFilteredFields();
            if (!empty(array_intersect($filteredFields, array_keys($data))))
            {
                $res = [];
                foreach ($filteredFields as $key)
                {
                    $res[$key] = $val = array_key_exists($key, $data) ? $data[$key] : $topic[$key];
                    if (!empty($val))
                    {
                        $res[$key] = \CFilterUnquotableWords::Filter($val);
                        if (empty($res[$key]))
                        {
                            $res[$key] = "*";
                        }
                    }
                }
                $data["HTML"] = serialize($res);
            }
        }
        if (array_key_exists("TITLE_SEO", $data) || array_key_exists("TITLE", $data))
        {
            $data["TITLE_SEO"] = trim($data["TITLE_SEO"], " -");
            if ($data["TITLE_SEO"] == '')
            {
                $title = array_key_exists("TITLE", $data) ? $data["TITLE"] : $topic["TITLE"];
                $data["TITLE_SEO"] = \CUtil::translit($title, LANGUAGE_ID, array("max_len"=>255, "safe_chars"=>".", "replace_space" => '-'));
            }
        }
        if ($data != $event->getParameter("fields"))
        {
            $result->modifyFields($data);
        }
        return self::modifyData($event, $result);
    }
 
    public static function onAfterUpdate(Main\ORM\Event $event)
    {
        $id = $event->getParameter("id");
        $id = $id["ID"];
        $fields = $event->getParameter("fields");
        if (array_key_exists("FORUM_ID", $fields))
        {
            $connection = Main\Application::getInstance()->getConnection();
            $connection->queryExecute("UPDATE " . FileTable::getTableName() . " SET FORUM_ID={$fields["FORUM_ID"]} WHERE TOPIC_ID={$id}");
            $connection->queryExecute("UPDATE " . MessageTable::getTableName() . " SET FORUM_ID={$fields["FORUM_ID"]} WHERE TOPIC_ID={$id}");
            $connection->queryExecute("UPDATE " . SubscribeTable::getTableName() . " SET FORUM_ID={$fields["FORUM_ID"]} WHERE TOPIC_ID={$id}");
        }
    }
    private static function modifyData(Main\ORM\Event $event, Main\ORM\EventResult $result)
    {
        $data = array_merge($event->getParameter("fields"), $result->getModified());
        $fields = [];
 
        //region check image
        $key = array_key_exists("VIEWS", $data) ? "VIEWS" : (array_key_exists("=VIEWS", $data) ? "=VIEWS" : null);
        if ($key !== null && str_replace(" ", "", $data[$key]) === "VIEWS+1")
        {
            unset($data[$key]);
            $fields["VIEWS"] = new Main\DB\SqlExpression('?# + 1', 'VIEWS');
        }
        //endregion
        if (!empty($fields))
        {
            $result->modifyFields(array_merge($result->getModified(), $fields));
        }
        return $result;
    }
}
 
class Topic extends \Bitrix\Forum\Internals\Entity
{
    use \Bitrix\Forum\Internals\EntityFabric;
 
    public const STATE_LINK = "L";
    public const STATE_CLOSED = "N";
    public const STATE_OPENED = "Y";
    public const APPROVED_APPROVED = "Y";
    public const APPROVED_DISAPPROVED = "N";
 
    public function __construct($id)
    {
        if ($id <= 0)
        {
            throw new Main\ArgumentNullException("Topic id");
        }
        parent::__construct($id);
    }
 
    protected function init()
    {
        if (!($this->data = TopicTable::getById($this->id)->fetch()))
        {
            throw new Main\ObjectNotFoundException(Loc::getMessage("F_ERROR_TID_IS_LOST", ["#id#" => $this->id]));
        }
        $this->authorId = intval($this->data["USER_START_ID"]);
        $this->data["~TITLE_SEO"] = $this->data["TITLE_SEO"];
        $this->data["TITLE_SEO"] = implode("-", [$this->data["ID"], $this->data["TITLE_SEO"]]);
    }
 
    public function moveToForum(int $forumId)
    {
        $result = new Main\Result();
        if ($forumId == $this->forum->getId())
        {
            return $result;
        }
        $newForum = \Bitrix\Forum\Forum::getById($forumId);
        TopicTable::update($this->getId(), ["FORUM_ID" => $newForum->getId()]);
        $this->forum->calculateStatistic();
        $newForum->calculateStatistic();
 
        \Bitrix\Forum\Integration\Search\Topic::reindex($this->getId());
        return $result;
    }
 
    public function open()
    {
        $result = new Main\Result();
        if ($this->data["STATE"] === self::STATE_CLOSED)
        {
            if (Forum\TopicTable::update($this->getId(), ["STATE" => self::STATE_OPENED])->isSuccess())
            {
                $this->data["STATE"] = self::STATE_OPENED;
                \CForumEventLog::Log("topic", "open", $this->getId(), serialize($this->data));
                $result->setData(["STATE" => self::STATE_OPENED]);
                (new Main\Event("forum", "onTopicOpen", [$this->getId(), $this->data]))->send();
            }
            else
            {
                $result->addError(new Main\Error("Topic is not opened."));
            }
        }
        return $result;
    }
 
    public function close()
    {
        $result = new Main\Result();
        if ($this->data["STATE"] === self::STATE_OPENED)
        {
            if (Forum\TopicTable::update($this->getId(), ["STATE" => self::STATE_CLOSED])->isSuccess())
            {
                $this->data["STATE"] = self::STATE_CLOSED;
                \CForumEventLog::Log("topic", "close", $this->getId(), serialize($this->data));
                $result->setData(["STATE" => self::STATE_CLOSED]);
                (new Main\Event("forum", "onTopicClose", [$this->getId(), $this->data]))->send();
            }
            else
            {
                $result->addError(new Main\Error("Topic is not closed."));
            }
        }
        return $result;
    }
 
    public function disapprove()
    {
        $result = new Main\Result();
        if ($this->data["APPROVED"] === self::APPROVED_APPROVED)
        {
            $this->data["APPROVED"] = self::APPROVED_DISAPPROVED;
            TopicTable::update($this->getId(), ["APPROVED" => self::APPROVED_DISAPPROVED]);
 
            // region 1. Change rights for search indexes
            if (Main\Loader::includeModule("search") && $this->forum["INDEXATION"] == "Y")
            {
                $res = $this->forum->getPermissions();
                $groups = [1];
                foreach ($res as $group => $permission)
                {
                    if ($permission >= Permission::CAN_MODERATE)
                    {
                        $groups[] = $group;
                    }
                }
                \CSearch::ChangePermission("forum", $groups, false, $this->forum["ID"], $this->getId());
            }
            //endregion
            //region 2. Update MessageTable & Forum Statistic
            $connection = Main\Application::getInstance()->getConnection();
            $connection->queryExecute("UPDATE " . MessageTable::getTableName() . " SET APPROVED='" . Message::APPROVED_DISAPPROVED . "' WHERE TOPIC_ID={$this->getId()}");
            $this->forum->calculateStatistic();
            Forum\Statistic\User::runForTopic($this->getId());
            //endregion\
 
            \CForumEventLog::Log("topic", "disapprove", $this->getId(), serialize($this->data));
            $event = new Main\Event("forum", "onTopicModerate", [$this->getId(), $this->data]);
            $event->send();
            $result->setData(["APPROVED" => self::APPROVED_DISAPPROVED]);
        }
        return $result;
    }
 
    public function approve()
    {
        $result = new Main\Result();
        if ($this->data["APPROVED"] !== self::APPROVED_APPROVED)
        {
            $this->data["APPROVED"] = self::APPROVED_APPROVED;
            TopicTable::update($this->getId(), ["APPROVED" => self::APPROVED_APPROVED]);
 
            // region 1. Change rights for search indexes
            if (Main\Loader::includeModule("search") && $this->forum["INDEXATION"] == "Y")
            {
                $res = $this->forum->getPermissions();
                $groups = [];
                foreach ($res as $group => $permission)
                {
                    if ($permission > Permission::ACCESS_DENIED)
                    {
                        $groups[] = $group;
                    }
                }
                \CSearch::ChangePermission("forum", $groups, false, $this->forum["ID"], $this->getId());
            }
            //endregion
            //region 2. Update MessageTable & Forum Statistic
            $connection = Main\Application::getInstance()->getConnection();
            $connection->queryExecute("UPDATE " . MessageTable::getTableName() . " SET APPROVED='" . Message::APPROVED_APPROVED . "' WHERE TOPIC_ID={$this->getId()}");
            $this->forum->calculateStatistic();
            \Bitrix\Forum\Statistic\User::runForTopic($this->getId());
            //endregion\
 
            \CForumEventLog::Log("topic", "approve", $this->getId(), serialize($this->data));
            $event = new Main\Event("forum", "onTopicModerate", [$this->getId(), $this->data]);
            $event->send();
            $result->setData(["APPROVED" => self::APPROVED_APPROVED]);
        }
        return $result;
    }
 
    public function remove()
    {
        Forum\Statistic\User::runForTopic($this->getId());
        if (self::delete($this->getId())->isSuccess())
        {
            Forum\Integration\Search\Topic::deleteIndex($this);
            Forum\Forum::getById($this->getForumId())->calculateStatistic();
            $this->destroy();
        }
    }
    public static function create($parentObject, array $fields)
    {
        global $USER_FIELD_MANAGER;
 
        $forum = Forum\Forum::getInstance($parentObject);
        $date = new Main\Type\DateTime($fields["START_DATE"] ?: $fields["POST_DATE"]);
        $author = [
            "ID" => $fields["USER_START_ID"] ?: $fields["AUTHOR_ID"],
            "NAME" => $fields["USER_START_NAME"] ?: $fields["AUTHOR_NAME"]
        ];
 
        $topicData = [
            "TITLE" => $fields["TITLE"],
            "TITLE_SEO" => (array_key_exists("TITLE_SEO", $fields) ? $fields["TITLE_SEO"] : ""),
            "TAGS" => $fields["TAGS"],
            "DESCRIPTION" => $fields["DESCRIPTION"],
            "ICON" => $fields["ICON"],
            "STATE" => $fields["STATE"] ?: Topic::STATE_OPENED,
            "APPROVED" => $fields["APPROVED"],
 
            "POSTS" => 0,
            "POSTS_SERVICE" => 0,
            "POSTS_UNAPPROVED" => 0,
 
            "USER_START_ID" => $author["ID"],
            "USER_START_NAME" => $author["NAME"],
            "START_DATE" => $date,
 
            "LAST_POSTER_ID" =>  $author["ID"],
            "LAST_POSTER_NAME" => $author["NAME"],
            "LAST_POST_DATE" => $date,
            "LAST_MESSAGE_ID" => 0,
 
            "ABS_LAST_POSTER_ID" => $author["ID"],
            "ABS_LAST_POSTER_NAME" => $author["NAME"],
            "ABS_LAST_POST_DATE" => $date,
            "ABS_LAST_MESSAGE_ID" => 0,
 
            "XML_ID" => $fields["TOPIC_XML_ID"],
 
            "OWNER_ID" => $fields["OWNER_ID"] ?: null,
            "SOCNET_GROUP_ID" => $fields["SOCNET_GROUP_ID"] ?: null
        ];
        $result = Topic::add($forum, $topicData);
        if ($result->isSuccess())
        {
            $messageData = array(
                "NEW_TOPIC" => "Y",
                "APPROVED" => $topicData["APPROVED"],
 
                "USE_SMILES" => $fields["USE_SMILES"],
                "POST_DATE" => $date,
                "POST_MESSAGE" => $fields["POST_MESSAGE"],
 
                "ATTACH_IMG" => $fields["ATTACH_IMG"],
                "FILES" => $fields["FILES"],
 
                "PARAM1" => $fields["PARAM1"],
                "PARAM2" => $fields["PARAM2"],
 
                "AUTHOR_ID" => $author["ID"],
                "AUTHOR_NAME" => $author["NAME"],
                "AUTHOR_EMAIL" => $fields["AUTHOR_EMAIL"],
 
                "AUTHOR_IP" => $fields["AUTHOR_IP"] ?? null,
                "AUTHOR_REAL_IP" =>  $fields["AUTHOR_REAL_IP"] ?? null,
                "GUEST_ID" =>  $fields["GUEST_ID"] ?? null,
            );
 
            $messageData += array_intersect_key($fields, $USER_FIELD_MANAGER->getUserFields(MessageTable::getUfId()));
 
            $topic = Topic::getById($result->getId());
            $result = Message::add($topic, $messageData);
 
            if ($result->isSuccess())
            {
                $result->setData(["MESSAGE_ID" => $result->getId(), "TOPIC_ID" => $topic->getId()]);
                $message = MessageTable::getDataById($result->getId());
                //region Update statistic & Seacrh
                TopicTable::update($topic->getId(), ["LAST_MESSAGE_ID" => $message["ID"], "ABS_LAST_MESSAGE_ID" => $message["ID"]]);
                User::getById($message["AUTHOR_ID"])->incrementStatistic($message);
                $forum->incrementStatistic($message);
                \Bitrix\Forum\Integration\Search\Message::index($forum, $topic, $message);
                //endregion
            }
            else
            {
                TopicTable::delete($topic->getId());
                $topic->destroy();
            }
        }
 
        return $result;
    }
 
    public static function add(Forum\Forum $forum, array &$data)
    {
        $data['FORUM_ID'] = $forum->getId();
        $result = new Main\ORM\Data\AddResult();
        if (($events = GetModuleEvents("forum", "onBeforeTopicAdd", true)) && !empty($events))
        {
            global $APPLICATION;
            foreach ($events as $ev)
            {
                $APPLICATION->ResetException();
 
                if (ExecuteModuleEventEx($ev, array(&$data)) === false)
                {
                    $errorMessage = Loc::getMessage("FORUM_EVENT_BEFORE_TOPIC_ADD");
                    if (($ex = $APPLICATION->GetException()) && ($ex instanceof \CApplicationException))
                    {
                        $errorMessage = $ex->getString();
                    }
 
                    $result->addError(new Main\Error($errorMessage, "onBeforeTopicAdd"));
                    return $result;
                }
            }
        }
 
        $dbResult = TopicTable::add($data);
 
        if (!$dbResult->isSuccess())
        {
            $result->addErrors($dbResult->getErrors());
        }
        else
        {
            $id = $dbResult->getId();
            $result->setId($id);
            foreach (GetModuleEvents("forum", "onAfterTopicAdd", true) as $event)
            {
                ExecuteModuleEventEx($event, [$id, $data]);
            }
        }
 
        return $result;
    }
 
    public function edit(array $fields)
    {
        $fieldsBefore = $this->data;
        //region update Message table and topic table
        if (!($m = MessageTable::getList([
            "select" => ["*"],
            "filter" => ["TOPIC_ID" => $this->getId(), "NEW_TOPIC" => "Y"],
            "limit" => 1
        ])->fetch()))
        {
            throw new Main\ObjectException(Loc::getMessage("FORUM_ERROR_FIRST_POST_WAS_NOT_FOUND"));
        }
        $result = Message::update($m["ID"], $fields);
        if ($result->isSuccess())
        {
            $topicData = array_intersect_key(
                $fields,
                array_flip([
                    "TITLE",
                    "TITLE_SEO",
                    "TAGS",
                    "DESCRIPTION",
                    "ICON",
                    "USER_START_NAME"
                ])
            );
            if (array_key_exists("AUTHOR_NAME", $fields))
            {
                $topicData["USER_START_NAME"] = $fields["AUTHOR_NAME"];
            }
 
            if (!empty($topicData))
            {
                $result = Topic::update($this->getId(), $topicData);
                if ($result->isSuccess())
                {
                    $this->data = TopicTable::getById($this->getId())->fetch();
                }
            }
        }
 
        if (!$result->isSuccess())
        {
            return $result;
        }
        //endregion
 
        $fieldsAfter = $this->data;
 
        $result->setPrimary(["ID" => $m["ID"]]);
        $result->setData(["MESSAGE_ID" => $m["ID"], "TOPIC_ID" => $this->getId()]);
 
        //region Search indexation
        $forum = \Bitrix\Forum\Forum::getById($this->getForumId());
        if ($forum["INDEXATION"] === "Y" && $fieldsBefore !== $fieldsAfter)
        {
            $searchKeys = ["TITLE", "TITLE_SEO", "TAGS", "DESCRIPTION"];
            $diffData = array_intersect_key(
                array_diff_assoc($fieldsAfter, $fieldsBefore),
                array_flip($searchKeys)
            );
            if (array_key_exists('TITLE', $diffData)
                || array_key_exists('TITLE_SEO', $diffData))
            {
                Forum\Integration\Search\Topic::reindex($this->getId());
            }
            else
            {
                Forum\Integration\Search\Message::index(
                    Forum\Forum::getById($this->getForumId()),
                    $this,
                    Forum\MessageTable::getById($m["ID"])->fetch()
                );
            }
        }
        //endregion
        $fieldsAfter += Forum\MessageTable::getDataById($m["ID"]);
        $log = array_diff_assoc(
            array_intersect_key($fieldsBefore + $m, $fields),
            $fieldsAfter
        );
        array_walk($log,
            function (&$item, $key, $fieldsAfter)
            {
                $item = [
                    'before' => $item,
                    'after' => $fieldsAfter[$key]
                ];
            }, $fieldsAfter);
        unset($log["HTML"]);
        unset($log["EDIT_DATE"]);
        \CForumEventLog::Log("topic", "edit", $this->getId(), serialize($log));
 
        return $result;
    }
 
    public static function update(int $id, array &$data)
    {
        unset($data["FORUM_ID"]);
 
        $topic = Forum\TopicTable::getById($id)->fetch();
 
        $result = new Main\ORM\Data\UpdateResult();
        $result->setPrimary(["ID" => $id]);
 
        if (($events = GetModuleEvents("forum", "onBeforeTopicUpdate", true)) && !empty($events))
        {
            global $APPLICATION;
            foreach ($events as $ev)
            {
                $APPLICATION->ResetException();
 
                if (ExecuteModuleEventEx($ev, array($id, &$data, $topic)) === false)
                {
                    $errorMessage = Loc::getMessage("FORUM_EVENT_BEFORE_TOPIC_UPDATE_ERROR");
                    if (($ex = $APPLICATION->GetException()) && ($ex instanceof \CApplicationException))
                    {
                        $errorMessage = $ex->getString();
                    }
                    $result->addError(new Main\Error($errorMessage, "onBeforeTopicAdd"));
                    return $result;
                }
            }
        }
 
        $dbResult = TopicTable::update($id, $data);
 
        if (!$dbResult->isSuccess())
        {
            $result->addErrors($dbResult->getErrors());
        }
        else
        {
            foreach (GetModuleEvents("forum", "onAfterTopicUpdate", true) as $event)
            {
                ExecuteModuleEventEx($event, [$id, $data, []]);
            }
        }
        return $result;
    }
 
    public static function delete(int $id)
    {
        $result = new Main\Orm\Data\DeleteResult();
        if (!($topicData = Forum\TopicTable::getById($id)->fetch()))
        {
            return $result;
        }
 
        /***************** Event onBeforeTopicDelete ***********************/
        foreach (GetModuleEvents("forum", "onBeforeTopicDelete", true) as $arEvent)
        {
            if (ExecuteModuleEventEx($arEvent, [$id, $topicData]) === false)
            {
                global $APPLICATION;
                $errorMessage = 'onBeforeTopicDelete';
                if (($ex = $APPLICATION->GetException()) && ($ex instanceof \CApplicationException))
                {
                    $errorMessage = $ex->getString();
                }
                $result->addError(new Main\Error($errorMessage, 'onBeforeTopicDelete'));
                return $result;
            }
        }
        /***************** /Event ******************************************/
 
        Forum\Internals\MessageCleaner::runForTopic($id);
        Main\Application::getConnection()->queryExecute("DELETE FROM b_forum_subscribe WHERE TOPIC_ID = ".$id);
        Main\Application::getConnection()->queryExecute("DELETE FROM b_forum_message WHERE TOPIC_ID = ".$id);
        Main\Application::getConnection()->queryExecute("DELETE FROM b_forum_user_topic WHERE TOPIC_ID = ".$id);
        Main\Application::getConnection()->queryExecute("DELETE FROM b_forum_topic WHERE ID = ".$id);
        Main\Application::getConnection()->queryExecute("DELETE FROM b_forum_topic WHERE TOPIC_ID = ".$id);
        Main\Application::getConnection()->queryExecute("DELETE FROM b_forum_stat WHERE TOPIC_ID = ".$id);
 
        /***************** Event onAfterTopicDelete ************************/
        foreach(GetModuleEvents("forum", "onAfterTopicDelete", true) as $arEvent)
        {
            ExecuteModuleEventEx($arEvent, [&$id, &$topicData]);
        }
        /***************** /Event ******************************************/
        return $result;
    }
 
    public function incrementStatistic(array $message)
    {
        $fields = array(
            "ABS_LAST_POSTER_ID" => $message["AUTHOR_ID"],
            "ABS_LAST_POSTER_NAME" => $message["AUTHOR_NAME"],
            "ABS_LAST_POST_DATE" => $message["POST_DATE"],
            "ABS_LAST_MESSAGE_ID" => $message["ID"]
        );
        $this->data = array_merge($this->data, $fields);
        if ($message["APPROVED"] == "Y")
        {
            $fields += [
                "APPROVED" => "Y",
                "LAST_POSTER_ID" => $message["AUTHOR_ID"],
                "LAST_POSTER_NAME" => $message["AUTHOR_NAME"],
                "LAST_POST_DATE" => $message["POST_DATE"],
                "LAST_MESSAGE_ID" => $message["ID"]
            ];
            $this->data = array_merge($this->data, $fields);
            if ($message["NEW_TOPIC"] != "Y")
            {
                $fields["POSTS"] = new Main\DB\SqlExpression('?# + 1', "POSTS");
                $this->data["POSTS"]++;
            }
            if (!empty($message["SERVICE_TYPE"]))
            {
                $fields["POSTS_SERVICE"] = new Main\DB\SqlExpression('?# + 1', "POSTS_SERVICE");
                $this->data["POSTS_SERVICE"]++;
            }
        }
        else
        {
            $fields["POSTS_UNAPPROVED"] = new Main\DB\SqlExpression('?# + 1', "POSTS_UNAPPROVED");
            $this->data["POSTS_UNAPPROVED"]++;
        }
        return TopicTable::update($this->getId(), $fields);
    }
 
    public function decrementStatistic(array $message)
    {
        $fields = [];
        if ($message['APPROVED'] == 'Y')
        {
            $fields['POSTS'] = new Main\DB\SqlExpression('CASE WHEN ?# > 0 THEN ?# - 1 ELSE 0 END', 'POSTS', 'POSTS');
            $this->data['POSTS']--;
            if (!empty($message["SERVICE_TYPE"]))
            {
                $fields["POSTS_SERVICE"] = new Main\DB\SqlExpression('?# - 1', "POSTS_SERVICE");
                $this->data["POSTS_SERVICE"]--;
            }
        }
        else
        {
            $fields['POSTS_UNAPPROVED'] = new Main\DB\SqlExpression('?# - 1', 'POSTS_UNAPPROVED');
            $this->data['POSTS_UNAPPROVED']--;
        }
 
        if ($message['NEW_TOPIC'] === 'Y' && ($firstMessage = MessageTable::getList([
                'select' => ['*'],
                'filter' => ['TOPIC_ID' => $this->getId()],
                'order' => ['ID' => 'ASC'],
                'limit' => 1
            ])->fetch()))
        {
            $fields['USER_START_ID'] = $firstMessage['AUTHOR_ID'];
            $fields['USER_START_NAME'] = $firstMessage['AUTHOR_NAME'];
            $fields['START_DATE'] = $firstMessage['POST_DATE'];
            if ($this->data['APPROVED'] === 'Y' && $firstMessage['APPROVED'] !== 'Y' && $this->data['POSTS'] < 0)
            {
                $fields['APPROVED'] = 'N';
            }
        }
        else if ($message['ID'] >= $this->data['LAST_MESSAGE_ID'])
        {
            if ($message['ID'] === $this->data['LAST_MESSAGE_ID']
                &&
                ($lastMessage = Forum\MessageTable::getList([
                    'select' => ['ID', 'AUTHOR_ID', 'AUTHOR_NAME', 'POST_DATE'],
                    'filter' => [
                        'TOPIC_ID' => $this->getId(),
                        'APPROVED' => Forum\Message::APPROVED_APPROVED
                    ],
                    'order' => ['ID' => 'DESC'],
                    'limit' => 1
                ])->fetch())
            )
            {
                $fields += [
                    'LAST_POSTER_ID' => $lastMessage['AUTHOR_ID'],
                    'LAST_POSTER_NAME' => $lastMessage['AUTHOR_NAME'],
                    'LAST_POST_DATE' => $lastMessage['POST_DATE'],
                    'LAST_MESSAGE_ID' => $lastMessage['ID']
                ];
            }
 
            if ($message['ID'] === $this->data['ABS_LAST_MESSAGE_ID']
                &&
                ($lastMessage = Forum\MessageTable::getList([
                    'select' => ['ID', 'AUTHOR_ID', 'AUTHOR_NAME', 'POST_DATE'],
                    'filter' => ['TOPIC_ID' => $this->getId()],
                    'order' => ['ID' => 'DESC'],
                    'limit' => 1
                ])->fetch())
            )
            {
                $fields += [
                    'ABS_LAST_POSTER_ID' => $lastMessage['AUTHOR_ID'],
                    'ABS_LAST_POSTER_NAME' => $lastMessage['AUTHOR_NAME'],
                    'ABS_LAST_POST_DATE' => $lastMessage['POST_DATE'],
                    'ABS_LAST_MESSAGE_ID' => $lastMessage['ID']
                ];
            }
        }
        if (!empty($fields))
        {
            $this->data = array_merge($this->data, array_filter($fields, function($item) {
                return !($item instanceof Main\DB\SqlExpression);
            }));
            $result = TopicTable::update($this->getId(), $fields);
        }
        else
        {
            $result = new Main\ORM\Data\UpdateResult;
        }
        if (isset($firstMessage) && $firstMessage)
        {
            $result->setData($firstMessage);
        }
        return $result;
    }
 
    public function incrementViews()
    {
        TopicTable::update($this->getId(), ['VIEWS' => new Main\DB\SqlExpression('?# + 1', 'VIEWS')]);
    }
}