topichandler.php

<?php
namespace Bitrix\Forum\Replica;
 
use Bitrix\Main\Loader;
 
if (Loader::includeModule('replica'))
{
    class TopicHandler extends \Bitrix\Replica\Client\BaseHandler
    {
        protected $tasksForumId = 0;
 
        protected $tableName = "b_forum_topic";
        protected $moduleId = "forum";
 
        protected $primary = array(
            "ID" => "auto_increment",
        );
        protected $predicates = array(
        );
        protected $translation = array(
            "ID" => "b_forum_topic.ID",
            "USER_START_ID" => "b_user.ID",
            "LAST_POSTER_ID" => "b_user.ID",
            //"LAST_MESSAGE_ID" => "b_forum_message.ID", //TODO
            "ABS_LAST_POSTER_ID" => "b_user.ID",
            //"ABS_LAST_MESSAGE_ID" => "b_forum_message.ID", //TODO
            "RESPONSIBLE_ID" => "b_user.ID",
            "OWNER_ID" => "b_user.ID",
        );
        protected $children = array(
            "ID" => "b_forum_message.TOPIC_ID",
        );
 
        public function __construct()
        {
            if (\Bitrix\Main\Loader::includeModule('tasks'))
            {
                $this->tasksForumId = (int)\CTasksTools::GetForumIdForIntranet();
            }
        }
 
        public function onAfterTopicAdd($id, &$data)
        {
            \Bitrix\Replica\Db\Operation::writeInsert($this->tableName, array('ID'), array('ID' => $id));
        }
 
        public function onAfterTopicUpdate($id, $newTopic, $oldTopic)
        {
            \Bitrix\Replica\Db\Operation::writeUpdate($this->tableName, array('ID'), array('ID' => $id));
        }
 
        public function onAfterTopicDelete(&$id, $topic)
        {
            \Bitrix\Replica\Db\Operation::writeDelete($this->tableName, array('ID'), array('ID' => $id));
        }
 
        public function beforeInsertTrigger(array &$newRecord)
        {
            unset($newRecord["SOCNET_GROUP_ID"]);
            if ($this->tasksForumId > 0 && $newRecord['FORUM_ID'] === 'tasks_forum')
            {
                $newRecord['FORUM_ID'] = $this->tasksForumId;
                if (preg_match("/^TASK_(.+)\$/", $newRecord["XML_ID"], $match))
                {
                    $mapper = \Bitrix\Replica\Mapper::getInstance();
                    $taskId = $mapper->resolveLogGuid(false, 'b_tasks.ID', $match[1]);
                    if ($taskId)
                    {
                        $newRecord['XML_ID'] = 'TASK_'.$taskId;
                    }
                }
            }
            return null;
        }
 
        public function beforeUpdateTrigger(array $oldRecord, array &$newRecord)
        {
            unset($newRecord["SOCNET_GROUP_ID"]);
 
            if ($this->tasksForumId > 0 && $newRecord['FORUM_ID'] === 'tasks_forum')
            {
                $newRecord['FORUM_ID'] = $this->tasksForumId;
                if (preg_match("/^TASK_(.+)\$/", $newRecord["XML_ID"], $match))
                {
                    $mapper = \Bitrix\Replica\Mapper::getInstance();
                    $taskId = $mapper->resolveLogGuid(false, 'b_tasks.ID', $match[1]);
                    if ($taskId)
                    {
                        $newRecord['XML_ID'] = 'TASK_'.$taskId;
                    }
                }
            }
        }
 
        public function beforeLogInsert(array $record)
        {
            if ($this->tasksForumId > 0 && $record['FORUM_ID'] == $this->tasksForumId)
            {
                return true;
            }
            else
            {
                return false;
            }
        }
 
        public function beforeLogFormat(array &$record)
        {
            if ($this->tasksForumId > 0 && $record['FORUM_ID'] == $this->tasksForumId)
            {
                $record['FORUM_ID'] = 'tasks_forum';
                if (preg_match("/^TASK_([0-9]+)\$/", $record["XML_ID"], $match))
                {
                    $mapper = \Bitrix\Replica\Mapper::getInstance();
                    $guid = $mapper->getLogGuid("b_tasks.ID", $match[1]);
                    if ($guid)
                        $record['XML_ID'] = 'TASK_'.$guid;
                }
            }
        }
    }
}