| Server IP : 37.220.80.31 / Your IP : 3.12.41.136 Web Server : Apache/2.4.52 (Ubuntu) System : Linux 3051455-guretool.twc1.net 5.15.0-107-generic #117-Ubuntu SMP Fri Apr 26 12:26:49 UTC 2024 x86_64 User : www-root ( 1010) PHP Version : 7.4.33 Disable Function : pcntl_alarm,pcntl_fork,pcntl_waitpid,pcntl_wait,pcntl_wifexited,pcntl_wifstopped,pcntl_wifsignaled,pcntl_wexitstatus,pcntl_wtermsig,pcntl_wstopsig,pcntl_signal,pcntl_signal_dispatch,pcntl_get_last_error,pcntl_strerror,pcntl_sigprocmask,pcntl_sigwaitinfo,pcntl_sigtimedwait,pcntl_exec,pcntl_getpriority,pcntl_setpriority, MySQL : OFF | cURL : ON | WGET : OFF | Perl : OFF | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : /var/www/www-root/data/www/dev.artlot24.ru/bitrix/modules/forum/lib/ |
Upload File : |
<?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 MessageTable
*
* Fields:
* <ul>
* <li> ID int mandatory
* <li> FORUM_ID int mandatory
* <li> TOPIC_ID int
* <li> TITLE string(255) mandatory
* <li> TITLE_SEO string(255)
* <li> TAGS string(255)
* <li> DESCRIPTION string(255)
* <li> ICON string(255)
* <li> STATE bool optional default 'Y'
* <li> APPROVED bool optional default 'Y'
* <li> SORT int mandatory default '150'
* <li> VIEWS mandatory default '0'
* <li> USER_START_ID int
* <li> USER_START_NAME string(255),
* <li> START_DATE datetime mandatory
* <li> POSTS int mandatory default '0'
* <li> POSTS_SERVICE int mandatory default '0'
* <li> LAST_POSTER_ID int(10)
* <li> LAST_POSTER_NAME string(255) mandatory
* <li> LAST_POST_DATE datetime mandatory
* <li> LAST_MESSAGE_ID int
* <li> POSTS_UNAPPROVED int mandatory default '0'
* <li> ABS_LAST_POSTER_ID int
* <li> ABS_LAST_POSTER_NAME string(255)
* <li> ABS_LAST_POST_DATE datetime
* <li> ABS_LAST_MESSAGE_ID int
* <li> XML_ID string(255)
* <li> HTML text
* <li> SOCNET_GROUP_ID int
* <li> OWNER_ID int
* </ul>
*
* @package Bitrix\Forum
*
* DO NOT WRITE ANYTHING BELOW THIS
*
* <<< ORMENTITYANNOTATION
* @method static EO_Topic_Query query()
* @method static EO_Topic_Result getByPrimary($primary, array $parameters = array())
* @method static EO_Topic_Result getById($id)
* @method static EO_Topic_Result getList(array $parameters = array())
* @method static EO_Topic_Entity getEntity()
* @method static \Bitrix\Forum\EO_Topic createObject($setDefaultValues = true)
* @method static \Bitrix\Forum\EO_Topic_Collection createCollection()
* @method static \Bitrix\Forum\EO_Topic wakeUpObject($row)
* @method static \Bitrix\Forum\EO_Topic_Collection wakeUpCollection($rows)
*/
class TopicTable extends Main\Entity\DataManager
{
/**
* Returns DB table name for entity.
*
* @return string
*/
public static function getTableName()
{
return 'b_forum_topic';
}
/**
* Returns entity map definition.
*
* @return array
*/
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();
/** @var array $data */
$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);
}
/**
* @param Main\ORM\Event $event
* @return Main\ORM\EventResult|void
* @throws Main\ObjectException
*/
public static function onBeforeUpdate(Main\ORM\Event $event)
{
$result = new Main\ORM\EventResult();
/** @var array $data */
$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);
}
/**
* @param Main\ORM\Event $event
* @return void
*/
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}");
}
}
/**
* @param Main\ORM\Event $event
* @param Main\ORM\EventResult $result
* @return Main\ORM\EventResult
* @throws Main\ObjectException
*/
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]);
}
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]);
}
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();
}
}
/**
* @param Forum\Forum $parentObject
* @param array $fields
*/
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"],
);
$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;
}
/**
* @param array $fields
*/
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);
Forum\FileTable::deleteBatch(['TOPIC_ID' => $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')]);
}
}