im_history.php

См. документацию.

<?
IncludeModuleLangFile(__FILE__);
 
use Bitrix\Im as IM;
 
class CIMHistory
{
    private $user_id = 0;
    private $bHideLink = false;
 
    function __construct($user_id = false, $arParams = Array())
    {
        global $USER;
        $this->user_id = intval($user_id);
        if ($user_id == 0)
            $this->user_id = intval($USER->GetID());
        if (isset($arParams['HIDE_LINK']) && $arParams['HIDE_LINK'] == 'Y')
            $this->bHideLink = true;
    }
 
    function SearchMessage($searchText, $toUserId, $fromUserId = false, $bTimeZone = true)
    {
        global $DB;
 
        $fromUserId = intval($fromUserId);
        if ($fromUserId <= 0)
            $fromUserId = $this->user_id;
 
        $toUserId = intval($toUserId);
        if ($toUserId <= 0)
        {
            $GLOBALS["APPLICATION"]->ThrowException(GetMessage("IM_HISTORY_ERROR_TO_USER_ID"), "ERROR_TO_USER_ID");
            return false;
        }
 
        $searchText = trim($searchText);
        if (mb_strlen($searchText) < 3)
        {
            $GLOBALS["APPLICATION"]->ThrowException(GetMessage("IM_HISTORY_SEARCH_EMPTY"), "ERROR_SEARCH_EMPTY");
            return false;
        }
 
        $chatId = 0;
        $arMessages = Array();
        $arMessageId = Array();
        $arUnreadMessage = Array();
        $arMessageFiles = Array();
        $arUsers = Array();
 
        $limitById = '';
        if ($toUserId == $fromUserId)
        {
            $chat = new CIMChat();
            $chatId = $chat->GetPersonalChat();
            if (!$chatId)
            {
                return false;
            }
            $startId = 0;
        }
        else
        {
            $arRelation = \CIMChat::GetPrivateRelation($fromUserId, $toUserId);
            $chatId = $arRelation['CHAT_ID'];
            $startId = $arRelation['START_ID'];
        }
        if ($chatId > 0)
        {
            $where = [
                '=CHAT_ID'  => $chatId,
                '*%MESSAGE' => $searchText,
            ];
            if ($this->checkFullText($searchText))
            {
                $searchText = \Bitrix\Main\Search\Content::prepareStringToken($searchText);
                $where = [
                    '=CHAT_ID' => $chatId,
                    '*INDEX.SEARCH_CONTENT' => $searchText,
                ];
            }
            if ($startId)
            {
                $where['>=ID'] = intval($startId);
            }
 
            $orm = \Bitrix\Im\Model\MessageTable::getList(
                [
                    'select' => [
                        'ID',
                        'CHAT_ID',
                        'MESSAGE',
                        'AUTHOR_ID',
                        'NOTIFY_EVENT',
                        'DATE_CREATE'
                    ],
                    'filter' => $where,
                    'order' => ['DATE_CREATE' => 'DESC', 'ID' => 'DESC'],
                    'limit' => 1000,
                ]
            );
 
            while ($arRes = $orm->fetch())
            {
                if ($fromUserId == $arRes['AUTHOR_ID'])
                {
                    $arRes['TO_USER_ID'] = $toUserId;
                    $arRes['FROM_USER_ID'] = $fromUserId;
                    $convId = $arRes['TO_USER_ID'];
                }
                else
                {
                    $arRes['TO_USER_ID'] = $fromUserId;
                    $arRes['FROM_USER_ID'] = $toUserId;
                    $convId = $arRes['FROM_USER_ID'];
                }
 
                $arMessages[$arRes['ID']] = Array(
                    'id' => $arRes['ID'],
                    'chatId' => $arRes['CHAT_ID'],
                    'senderId' => $arRes['FROM_USER_ID'],
                    'recipientId' => $arRes['TO_USER_ID'],
                    'date' => $arRes['DATE_CREATE'],
                    'system' => $arRes['NOTIFY_EVENT'] == 'private'? 'N': 'Y',
                    'text' => \Bitrix\Im\Text::parse($arRes['MESSAGE']),
                    'textLegacy' => \Bitrix\Im\Text::parseLegacyFormat($arRes['MESSAGE'])
                );
 
                $arUsers[$convId][] = $arRes['ID'];
                $arMessageId[] = $arRes['ID'];
                $chatId = $arRes['CHAT_ID'];
            }
 
            $params = CIMMessageParam::Get($arMessageId);
            $arFiles = Array();
            foreach ($params as $messageId => $param)
            {
                $arMessages[$messageId]['params'] = $param;
                if (isset($param['FILE_ID']))
                {
                    foreach ($param['FILE_ID'] as $fileId)
                    {
                        $arFiles[$fileId] = $fileId;
                    }
                }
            }
            $arMessageFiles = CIMDisk::GetFiles($chatId, $arFiles);
            $arMessages = CIMMessageLink::prepareShow($arMessages, $params);
        }
 
        return Array('chatId' => $chatId, 'message' => $arMessages, 'unreadMessage' => $arUnreadMessage, 'usersMessage' => $arUsers, 'files' => $arMessageFiles);
    }
 
    function SearchDateMessage($searchDate, $toUserId, $fromUserId = false, $bTimeZone = true)
    {
        global $DB;
 
        $fromUserId = intval($fromUserId);
        if ($fromUserId <= 0)
            $fromUserId = $this->user_id;
 
        $toUserId = intval($toUserId);
        if ($toUserId <= 0)
        {
            $GLOBALS["APPLICATION"]->ThrowException(GetMessage("IM_HISTORY_ERROR_TO_USER_ID"), "ERROR_TO_USER_ID");
            return false;
        }
 
        $sqlHelper = Bitrix\Main\Application::getInstance()->getConnection()->getSqlHelper();
 
        try
        {
            $dateStart = \Bitrix\Main\Type\DateTime::createFromUserTime($searchDate);
            $sqlDateStart = $sqlHelper->getCharToDateFunction($dateStart->format("Y-m-d H:i:s"));
 
            $dateEnd = $dateStart->add('1 DAY');
            $sqlDateEnd = $sqlHelper->getCharToDateFunction($dateEnd->format("Y-m-d H:i:s"));
        }
        catch(\Bitrix\Main\ObjectException $e)
        {
            $GLOBALS["APPLICATION"]->ThrowException(GetMessage("IM_HISTORY_SEARCH_DATE_EMPTY"), "ERROR_SEARCH_EMPTY");
            return false;
        }
 
        $chatId = 0;
        $arMessages = Array();
        $arMessageId = Array();
        $arUnreadMessage = Array();
        $arMessageFiles = Array();
        $arUsers = Array();
 
        $limitById = '';
        if ($toUserId == $fromUserId)
        {
            $chat = new CIMChat();
            $chatId = $chat->GetPersonalChat();
            if (!$chatId)
            {
                return false;
            }
            $startId = 0;
        }
        else
        {
            $arRelation = \CIMChat::GetPrivateRelation($fromUserId, $toUserId);
            $chatId = $arRelation['CHAT_ID'];
            $startId = $arRelation['START_ID'];
        }
        if ($chatId > 0)
        {
            if ($startId > 0)
            {
                $limitById = 'AND M.ID >= '.intval($startId);
            }
 
            if (!$bTimeZone)
                CTimeZone::Disable();
            $strSql = "
                SELECT
                    M.ID,
                    M.CHAT_ID,
                    M.MESSAGE,
                    ".$DB->DatetimeToTimestampFunction('M.DATE_CREATE')." as DATE_CREATE,
                    M.AUTHOR_ID,
                    ".$fromUserId." as R1_USER_ID,
                    ".$toUserId." as R2_USER_ID,
                    M.NOTIFY_EVENT
                FROM b_im_message M
                WHERE
                    M.CHAT_ID = ".$chatId."
                AND M.DATE_CREATE >= ".$sqlDateStart." AND M.DATE_CREATE <=  ".$sqlDateEnd."
                    ".$limitById."
                ORDER BY M.DATE_CREATE DESC, M.ID DESC
            ";
            if (!$bTimeZone)
                CTimeZone::Enable();
            $dbRes = $DB->Query($strSql);
 
            while ($arRes = $dbRes->Fetch())
            {
                if ($fromUserId == $arRes['AUTHOR_ID'])
                {
                    $arRes['TO_USER_ID'] = $arRes['R2_USER_ID'];
                    $arRes['FROM_USER_ID'] = $arRes['R1_USER_ID'];
                    $convId = $arRes['TO_USER_ID'];
                }
                else
                {
                    $arRes['TO_USER_ID'] = $arRes['R1_USER_ID'];
                    $arRes['FROM_USER_ID'] = $arRes['R2_USER_ID'];
                    $convId = $arRes['FROM_USER_ID'];
                }
 
                $arMessages[$arRes['ID']] = Array(
                    'id' => $arRes['ID'],
                    'chatId' => $arRes['CHAT_ID'],
                    'senderId' => $arRes['FROM_USER_ID'],
                    'recipientId' => $arRes['TO_USER_ID'],
                    'date' => \Bitrix\Main\Type\DateTime::createFromTimestamp($arRes['DATE_CREATE']),
                    'system' => $arRes['NOTIFY_EVENT'] == 'private' ? 'N' : 'Y',
                    'text' => \Bitrix\Im\Text::parse($arRes['MESSAGE']),
                    'textLegacy' => \Bitrix\Im\Text::parseLegacyFormat($arRes['MESSAGE'])
                );
 
                $arUsers[$convId][] = $arRes['ID'];
                $arMessageId[] = $arRes['ID'];
                $chatId = $arRes['CHAT_ID'];
            }
 
            $params = CIMMessageParam::Get($arMessageId);
            $arFiles = Array();
            foreach ($params as $messageId => $param)
            {
                $arMessages[$messageId]['params'] = $param;
                if (isset($param['FILE_ID']))
                {
                    foreach ($param['FILE_ID'] as $fileId)
                    {
                        $arFiles[$fileId] = $fileId;
                    }
                }
            }
            $arMessageFiles = CIMDisk::GetFiles($chatId, $arFiles);
            $arMessages = CIMMessageLink::prepareShow($arMessages, $params);
        }
 
        return Array('chatId' => $chatId, 'message' => $arMessages, 'unreadMessage' => $arUnreadMessage, 'usersMessage' => $arUsers, 'files' => $arMessageFiles);
    }
 
    function GetMoreMessage($pageId, $toUserId, $fromUserId = false, $bTimeZone = true)
    {
        global $DB;
 
        $iNumPage = 1;
        if (intval($pageId) > 0)
            $iNumPage = intval($pageId);
 
        $fromUserId = intval($fromUserId);
        if ($fromUserId <= 0)
            $fromUserId = $this->user_id;
 
        $toUserId = intval($toUserId);
        if ($toUserId <= 0)
        {
            $GLOBALS["APPLICATION"]->ThrowException(GetMessage("IM_HISTORY_ERROR_TO_USER_ID"), "ERROR_TO_USER_ID");
            return false;
        }
 
        $chatId = 0;
        $arMessages = Array();
        $arMessageId = Array();
        $arUnreadMessage = Array();
        $arMessageFiles = Array();
        $arUsers = Array();
 
        $limitById = '';
 
        if ($toUserId == $fromUserId)
        {
            $chat = new CIMChat();
            $chatId = $chat->GetPersonalChat();
            if (!$chatId)
            {
                return false;
            }
            $startId = 0;
        }
        else
        {
            $arRelation = \CIMChat::GetPrivateRelation($fromUserId, $toUserId);
            $chatId = $arRelation['CHAT_ID'] ?? null;
            $startId = $arRelation['START_ID'];
        }
 
        if ($chatId > 0)
        {
            if ($startId > 0)
            {
                $limitById = 'AND M.ID >= '.intval($startId);
            }
            $sqlStr = "
                SELECT COUNT(M.ID) as CNT
                FROM b_im_message M
                WHERE M.CHAT_ID = ".$chatId."
                ".$limitById."
            ";
            $res_cnt = $DB->Query($sqlStr);
            $res_cnt = $res_cnt->Fetch();
            $cnt = $res_cnt["CNT"];
 
            if ($cnt > 0 && ceil($cnt/30) >= $iNumPage)
            {
                if (!$bTimeZone)
                    CTimeZone::Disable();
                $strSql ="
                    SELECT
                        M.ID,
                        M.CHAT_ID,
                        M.MESSAGE,
                        ".$DB->DatetimeToTimestampFunction('M.DATE_CREATE')." DATE_CREATE,
                        M.AUTHOR_ID,
                        M.NOTIFY_EVENT,
                        ".$fromUserId." R1_USER_ID,
                        ".$toUserId." R2_USER_ID
                    FROM b_im_message M
                    WHERE
                        M.CHAT_ID = ".$chatId."
                        ".$limitById."
                    ORDER BY M.DATE_CREATE DESC, M.ID DESC
                ";
                if (!$bTimeZone)
                    CTimeZone::Enable();
                $dbRes = new CDBResult();
                $dbRes->NavQuery($strSql, $cnt, Array('iNumPage' => $iNumPage, 'nPageSize' => 30));
 
                while ($arRes = $dbRes->Fetch())
                {
                    if ($fromUserId == $arRes['AUTHOR_ID'])
                    {
                        $arRes['TO_USER_ID'] = $arRes['R2_USER_ID'];
                        $arRes['FROM_USER_ID'] = $arRes['R1_USER_ID'];
                        $convId = $arRes['TO_USER_ID'];
                    }
                    else
                    {
                        $arRes['TO_USER_ID'] = $arRes['R1_USER_ID'];
                        $arRes['FROM_USER_ID'] = $arRes['R2_USER_ID'];
                        $convId = $arRes['FROM_USER_ID'];
                    }
                    $arMessages[$arRes['ID']] = Array(
                        'id' => $arRes['ID'],
                        'chatId' => $arRes['CHAT_ID'],
                        'senderId' => $arRes['FROM_USER_ID'],
                        'recipientId' => $arRes['TO_USER_ID'],
                        'date' => \Bitrix\Main\Type\DateTime::createFromTimestamp($arRes['DATE_CREATE']),
                        'system' => $arRes['NOTIFY_EVENT'] == 'private'? 'N': 'Y',
                        'text' => \Bitrix\Im\Text::parse($arRes['MESSAGE']),
                        'textLegacy' => \Bitrix\Im\Text::parseLegacyFormat($arRes['MESSAGE'])
                    );
                    $arUsers[$convId][] = $arRes['ID'];
                    $arMessageId[] = $arRes['ID'];
                    $chatId = $arRes['CHAT_ID'];
                }
 
                $params = CIMMessageParam::Get($arMessageId);
                $arFiles = Array();
                foreach ($params as $messageId => $param)
                {
                    $arMessages[$messageId]['params'] = $param;
                    if (isset($param['FILE_ID']))
                    {
                        foreach ($param['FILE_ID'] as $fileId)
                        {
                            $arFiles[$fileId] = $fileId;
                        }
                    }
                }
                $arMessageFiles = CIMDisk::GetFiles($chatId, $arFiles);
                $arMessages = CIMMessageLink::prepareShow($arMessages, $params);
            }
        }
 
 
        return Array('chatId' => $chatId, 'message' => $arMessages, 'usersMessage' => $arUsers, 'files' => $arMessageFiles);
    }
 
    function RemoveMessage($messageId)
    {
        global $DB;
 
        return false;
    }
 
    function RemoveAllMessage($userId)
    {
        global $DB;
 
        $userId = intval($userId);
 
        if ($this->user_id == $userId)
        {
            return false;
        }
 
        $strSql ="
            SELECT
                MAX(M.ID)+1 as MAX_ID,
                M.CHAT_ID,
                R1.ID as R1_ID,
                R1.START_ID as R1_START_ID,
                R2.ID as R2_ID,
                R2.START_ID as R2_START_ID
            FROM b_im_relation R1
            INNER JOIN b_im_relation R2 on R2.CHAT_ID = R1.CHAT_ID
            INNER JOIN b_im_message M ON M.ID >= R1.START_ID AND M.CHAT_ID = R1.CHAT_ID
            WHERE
                R1.USER_ID = ".$this->user_id."
            AND R2.USER_ID = ".$userId."
            AND R1.MESSAGE_TYPE = '".IM_MESSAGE_PRIVATE."'
            GROUP BY M.CHAT_ID, R1.ID, R1.START_ID, R2.ID, R2.START_ID
        ";
        $dbRes = $DB->Query($strSql);
        if ($arRes = $dbRes->Fetch())
        {
            $strSql = "UPDATE b_im_relation SET START_ID = ".intval($arRes['MAX_ID'])." WHERE ID = ".intval($arRes['R1_ID']);
            $DB->Query($strSql);
 
            $counterService = new IM\V2\Message\CounterService($this->user_id);
 
            $counterService->deleteByChatId((int)$arRes['CHAT_ID']);
 
            if ($arRes['MAX_ID'] >= $arRes['R2_START_ID'] && $arRes['R2_START_ID'] > 0)
            {
                $messages = IM\Model\MessageTable::getList(array(
                                                               'select' => array('ID'),
                                                               'filter' => array(
                                                                   '<ID' => $arRes['R2_START_ID'],
                                                                   '=CHAT_ID' => $arRes['CHAT_ID'],
                                                               ),
                                                           ));
                while ($messageInfo = $messages->fetch())
                {
                    IM\Model\MessageTable::delete($messageInfo['ID']);
                }
            }
 
            $primaryKey = ['USER_ID' => $this->user_id, 'ITEM_TYPE' => IM_MESSAGE_PRIVATE, 'ITEM_ID' => $userId];
            IM\Model\RecentTable::update($primaryKey, ['ITEM_MID' => 0]);
        }
 
        return true;
    }
 
    /* CHAT */
    function HideAllChatMessage($chatId)
    {
        global $DB;
        $chatId = intval($chatId);
 
        $limitById = '';
        $ar = \CIMChat::GetRelationById($chatId, $this->user_id, true, false);
        if ($ar && $ar['START_ID'] > 0)
        {
            $limitById = 'AND M.ID >= '.intval($ar['START_ID']);
        }
 
        $strSql ="
            SELECT
                MAX(M.ID)+1 as MAX_ID,
                R1.ID as R1_ID
            FROM b_im_relation R1
            INNER JOIN b_im_message M ON M.CHAT_ID = R1.CHAT_ID
            WHERE
                R1.CHAT_ID = ".$chatId."
                AND R1.USER_ID = ".$this->user_id."
                ".$limitById."
            GROUP BY M.CHAT_ID, R1.ID
        ";
        $dbRes = $DB->Query($strSql);
        if ($arRes = $dbRes->Fetch())
        {
            $strSql = "UPDATE b_im_relation SET START_ID = ".intval($arRes['MAX_ID'])." WHERE ID = ".intval($arRes['R1_ID']);
            $dbRes = $DB->Query($strSql);
 
            $counterService = new IM\V2\Message\CounterService($this->user_id);
 
            $counterService->deleteByChatId((int)$arRes['CHAT_ID']);
 
            $chatType = $ar ? $ar['MESSAGE_TYPE'] : IM_MESSAGE_CHAT;
            $primaryKey = ['USER_ID' => $this->user_id, 'ITEM_TYPE' => $chatType, 'ITEM_ID' => $chatId];
            IM\Model\RecentTable::update($primaryKey, ['ITEM_MID' => 0]);
        }
 
        return true;
    }
 
    function SearchChatMessage($searchText, $chatId, $bTimeZone = true)
    {
        $chatId = intval($chatId);
        $searchText = trim($searchText);
 
        if ($searchText == '')
        {
            $GLOBALS["APPLICATION"]->ThrowException(GetMessage("IM_HISTORY_SEARCH_EMPTY"), "ERROR_SEARCH_EMPTY");
            return false;
        }
 
        if (!\Bitrix\Im\Dialog::hasAccess('chat'.$chatId, $this->user_id))
        {
            return false;
        }
 
        $where = Array(
            '=CHAT_ID' => $chatId,
            '*%MESSAGE' => $searchText,
        );
 
        if($this->checkFullText($searchText))
        {
            $where = Array(
                '=CHAT_ID' => $chatId,
                '*INDEX.SEARCH_CONTENT' => \Bitrix\Main\Search\Content::prepareStringToken($searchText),
            );
        }
 
        $ar = \CIMChat::GetRelationById($chatId, $this->user_id, true, false);
        if ($ar && $ar['START_ID'] > 0)
        {
            $where['>=ID'] = intval($ar['START_ID']);
        }
 
        $orm = \Bitrix\Im\Model\MessageTable::getList(
            [
                'select' => [
                    'ID',
                    'CHAT_ID',
                    'MESSAGE',
                    'AUTHOR_ID',
                    'DATE_CREATE'
                ],
                'filter' => $where,
                'order' => ['DATE_CREATE' => 'DESC', 'ID' => 'DESC'],
                'limit' => 1000,
            ]
        );
 
        $arMessages = Array();
        $arMessageId = Array();
        $arUnreadMessage = Array();
        $usersMessage = Array();
 
        while ($arRes = $orm->fetch())
        {
            $arMessages[$arRes['ID']] = Array(
                'id' => $arRes['ID'],
                'chatId' => $arRes['CHAT_ID'],
                'senderId' => $arRes['AUTHOR_ID'],
                'recipientId' => $arRes['CHAT_ID'],
                'date' => $arRes['DATE_CREATE'],
                'text' => \Bitrix\Im\Text::parse($arRes['MESSAGE']),
                'textLegacy' => \Bitrix\Im\Text::parseLegacyFormat($arRes['MESSAGE'])
            );
 
            $usersMessage[$arRes['CHAT_ID']][] = $arRes['ID'];
            $arMessageId[] = $arRes['ID'];
        }
 
        $params = CIMMessageParam::Get($arMessageId);
        $arFiles = Array();
        foreach ($params as $messageId => $param)
        {
            $arMessages[$messageId]['params'] = $param;
            if (isset($param['FILE_ID']))
            {
                foreach ($param['FILE_ID'] as $fileId)
                {
                    $arFiles[$fileId] = $fileId;
                }
            }
        }
        $arMessageFiles = CIMDisk::GetFiles($chatId, $arFiles);
        $arMessages = CIMMessageLink::prepareShow($arMessages, $params);
 
        return Array('chatId' => $chatId, 'message' => $arMessages, 'unreadMessage' => $arUnreadMessage, 'usersMessage' => $usersMessage, 'files' => $arMessageFiles);
    }
 
    function SearchDateChatMessage($searchDate, $chatId, $bTimeZone = true)
    {
        global $DB;
 
        $chatId = intval($chatId);
 
        $sqlHelper = Bitrix\Main\Application::getInstance()->getConnection()->getSqlHelper();
        try
        {
            $dateStart = \Bitrix\Main\Type\DateTime::createFromUserTime($searchDate);
            $sqlDateStart = $sqlHelper->getCharToDateFunction($dateStart->format("Y-m-d H:i:s"));
 
            $dateEnd = $dateStart->add('1 DAY');
            $sqlDateEnd = $sqlHelper->getCharToDateFunction($dateEnd->format("Y-m-d H:i:s"));
        }
        catch(\Bitrix\Main\ObjectException $e)
        {
            $GLOBALS["APPLICATION"]->ThrowException(GetMessage("IM_HISTORY_SEARCH_DATE_EMPTY"), "ERROR_SEARCH_EMPTY");
            return false;
        }
 
        $limitById = '';
        $ar = \CIMChat::GetRelationById($chatId, $this->user_id, true, false);
        if ($ar && $ar['START_ID'] > 0)
        {
            $limitById = 'AND M.ID >= '.intval($ar['START_ID']);
        }
 
        if (!$bTimeZone)
            CTimeZone::Disable();
        $strSql ="
            SELECT
                M.ID,
                M.CHAT_ID,
                M.MESSAGE,
                ".$DB->DatetimeToTimestampFunction('M.DATE_CREATE')." as DATE_CREATE,
                M.AUTHOR_ID
            FROM b_im_relation R1
            INNER JOIN b_im_message M ON M.CHAT_ID = R1.CHAT_ID
            WHERE
                R1.CHAT_ID = ".$chatId."
                AND R1.USER_ID = ".$this->user_id."
                AND M.DATE_CREATE >= ".$sqlDateStart." 
                AND M.DATE_CREATE <=  ".$sqlDateEnd."
                ".$limitById."
            ORDER BY M.DATE_CREATE DESC, M.ID DESC
        ";
        if (!$bTimeZone)
            CTimeZone::Enable();
        $dbRes = $DB->Query($strSql);
 
        $arMessages = Array();
        $arMessageId = Array();
        $arUnreadMessage = Array();
        $usersMessage = Array();
 
        while ($arRes = $dbRes->Fetch())
        {
            $arMessages[$arRes['ID']] = Array(
                'id' => $arRes['ID'],
                'chatId' => $arRes['CHAT_ID'],
                'senderId' => $arRes['AUTHOR_ID'],
                'recipientId' => $arRes['CHAT_ID'],
                'date' => \Bitrix\Main\Type\DateTime::createFromTimestamp($arRes['DATE_CREATE']),
                'text' => \Bitrix\Im\Text::parse($arRes['MESSAGE']),
                'textLegacy' => \Bitrix\Im\Text::parseLegacyFormat($arRes['MESSAGE'])
            );
 
            $usersMessage[$arRes['CHAT_ID']][] = $arRes['ID'];
            $arMessageId[] = $arRes['ID'];
        }
        $params = CIMMessageParam::Get($arMessageId);
        $arFiles = Array();
        foreach ($params as $messageId => $param)
        {
            $arMessages[$messageId]['params'] = $param;
            if (isset($param['FILE_ID']))
            {
                foreach ($param['FILE_ID'] as $fileId)
                {
                    $arFiles[$fileId] = $fileId;
                }
            }
        }
        $arMessageFiles = CIMDisk::GetFiles($chatId, $arFiles);
        $arMessages = CIMMessageLink::prepareShow($arMessages, $params);
 
        return Array('chatId' => $chatId, 'message' => $arMessages, 'unreadMessage' => $arUnreadMessage, 'usersMessage' => $usersMessage, 'files' => $arMessageFiles);
    }

    function GetMoreChatMessage($pageId, $chatId, $bTimeZone = true)
    {
        global $DB;
 
        $iNumPage = 1;
        if (intval($pageId) > 0)
            $iNumPage = intval($pageId);
 
        $chatId = intval($chatId);
 
        $orm = IM\Model\ChatTable::getById($chatId);
        if (!($chatData = $orm->fetch()))
        {
            $GLOBALS["APPLICATION"]->ThrowException(GetMessage("IM_ERROR_CHAT_NOT_EXISTS"), "ERROR_CHAT_NOT_EXISTS");
            return false;
        }
 
        $limitById = '';
        $ar = \CIMChat::GetRelationById($chatId, $this->user_id, true, false);
        if ($ar && $ar['START_ID'] > 0)
        {
            $limitById = 'AND M.ID >= '.intval($ar['START_ID']);
        }
 
        if (!$bTimeZone)
        {
            CTimeZone::Disable();
        }
 
        $lineId = 0;
        if (
            $chatData['TYPE'] == IM_MESSAGE_OPEN_LINE
            && \Bitrix\Main\Loader::includeModule('imopenlines')
        )
        {
            $lineId = \Bitrix\ImOpenLines\Chat::parseLinesChatEntityId($chatData['ENTITY_ID'])['lineId'];
        }
 
        if ($chatData['TYPE'] == IM_MESSAGE_OPEN)
        {
            $strCountSql ="
                SELECT COUNT(M.ID) as CNT
                FROM b_im_message M
                INNER JOIN b_im_chat C ON C.ID = M.CHAT_ID AND C.TYPE = '".IM_MESSAGE_OPEN."'
                WHERE M.CHAT_ID = ".$chatId." ".$limitById."
            ";
 
            $strResultSql ="
                SELECT
                    M.ID,
                    M.CHAT_ID,
                    M.MESSAGE,
                    ".$DB->DatetimeToTimestampFunction('M.DATE_CREATE')." DATE_CREATE,
                    M.AUTHOR_ID,
                    C.ENTITY_TYPE CHAT_ENTITY_TYPE
                FROM b_im_message M
                INNER JOIN b_im_chat C ON C.ID = M.CHAT_ID AND C.TYPE = '".IM_MESSAGE_OPEN."'
                LEFT JOIN b_im_relation R ON R.CHAT_ID = M.CHAT_ID AND R.USER_ID = ".$this->user_id."
                WHERE 
                    M.CHAT_ID = ".$chatId."
                    ".$limitById."
                ORDER BY M.DATE_CREATE DESC, M.ID DESC
            ";
        }
        elseif (
            $chatData['TYPE'] == IM_MESSAGE_OPEN_LINE
            && \Bitrix\Main\Loader::includeModule('imopenlines')
            && \Bitrix\ImOpenLines\Config::canJoin($lineId)
        )
        {
            $strCountSql ="
                SELECT COUNT(M.ID) as CNT
                FROM b_im_message M
                INNER JOIN b_im_chat C ON C.ID = M.CHAT_ID AND C.TYPE = '".IM_MESSAGE_OPEN_LINE."'
                WHERE M.CHAT_ID = ".$chatId." ".$limitById."
            ";
 
            $strResultSql ="
                SELECT
                    M.ID,
                    M.CHAT_ID,
                    M.MESSAGE,
                    ".$DB->DatetimeToTimestampFunction('M.DATE_CREATE')." DATE_CREATE,
                    M.AUTHOR_ID,
                    C.ENTITY_TYPE CHAT_ENTITY_TYPE
                FROM b_im_message M
                INNER JOIN b_im_chat C ON C.ID = M.CHAT_ID AND C.TYPE = '".IM_MESSAGE_OPEN_LINE."'
                LEFT JOIN b_im_relation R ON R.CHAT_ID = M.CHAT_ID AND R.USER_ID = ".$this->user_id."
                WHERE 
                    M.CHAT_ID = ".$chatId."
                    ".$limitById."
                ORDER BY M.DATE_CREATE DESC, M.ID DESC
            ";
        }
        else
        {
            $strCountSql ="
                SELECT COUNT(M.ID) as CNT
                FROM b_im_message M
                INNER JOIN b_im_relation R1 ON M.CHAT_ID = R1.CHAT_ID
                WHERE R1.CHAT_ID = ".$chatId." AND R1.USER_ID = ".$this->user_id." ".$limitById."
            ";
 
            $strResultSql ="
                SELECT
                    M.ID,
                    M.CHAT_ID,
                    M.MESSAGE,
                    ".$DB->DatetimeToTimestampFunction('M.DATE_CREATE')." as DATE_CREATE,
                    M.AUTHOR_ID,
                    C.ENTITY_TYPE as CHAT_ENTITY_TYPE
                FROM b_im_message M
                LEFT JOIN b_im_chat C ON M.CHAT_ID = C.ID
                WHERE 
                    M.CHAT_ID = ".$chatId."
                    ".$limitById."
                ORDER BY M.DATE_CREATE DESC, M.ID DESC
            ";
        }
        if (!$bTimeZone)
            CTimeZone::Enable();
 
        $res_cnt = $DB->Query($strCountSql);
        $res_cnt = $res_cnt->Fetch();
        $cnt = $res_cnt["CNT"];
 
        $arMessages = Array();
        $arMessageFiles = Array();
        $arMessageId = Array();
        $usersMessage = Array();
        if ($cnt > 0 && ceil($cnt/30) >= $iNumPage)
        {
            $dbRes = new CDBResult();
            $dbRes->NavQuery($strResultSql, $cnt, Array('iNumPage' => $iNumPage, 'nPageSize' => 30));
 
            while ($arRes = $dbRes->Fetch())
            {
                if ($arRes['CHAT_ENTITY_TYPE'] != 'LIVECHAT' && \Bitrix\Im\User::getInstance($this->user_id)->isConnector())
                {
                    return false;
                }
                $arMessages[$arRes['ID']] = Array(
                    'id' => $arRes['ID'],
                    'chatId' => $arRes['CHAT_ID'],
                    'senderId' => $arRes['AUTHOR_ID'],
                    'recipientId' => $arRes['CHAT_ID'],
                    'date' => \Bitrix\Main\Type\DateTime::createFromTimestamp($arRes['DATE_CREATE']),
                    'system' => $arRes['AUTHOR_ID'] > 0? 'N': 'Y',
                    'text' => \Bitrix\Im\Text::parse($arRes['MESSAGE']),
                    'textLegacy' => \Bitrix\Im\Text::parseLegacyFormat($arRes['MESSAGE'])
                );
 
                $usersMessage[$arRes['CHAT_ID']][] = $arRes['ID'];
                $arMessageId[] = $arRes['ID'];
                $arUsersIds[] = $arRes['AUTHOR_ID'];
            }
 
            $params = CIMMessageParam::Get($arMessageId);
            $arFiles = Array();
            foreach ($params as $messageId => $param)
            {
                $arMessages[$messageId]['params'] = $param;
                if (isset($param['FILE_ID']))
                {
                    foreach ($param['FILE_ID'] as $fileId)
                    {
                        $arFiles[$fileId] = $fileId;
                    }
                }
            }
            $arMessageFiles = CIMDisk::GetFiles($chatId, $arFiles);
            $arMessages = CIMMessageLink::prepareShow($arMessages, $params);
 
        }
 
        $users = CIMContactList::GetUserData(array(
             'ID' => $arUsersIds,
             'DEPARTMENT' => 'Y',
             'USE_CACHE' => 'N',
             'PHONES' => IsModuleInstalled('voximplant')? 'Y': 'N'
         ));
 
        return Array(
            'chatId' => $chatId,
            'message' => $arMessages,
            'usersMessage' => $usersMessage,
            'users' => $users['users'],
            'userInGroup' => $users['userInGroup'],
            'phones' => $users['phones'],
            'files' => $arMessageFiles
        );
    }
 
 
    /* COMMON */
    public function GetMessagesByDate($chatId, $date, $messageStart = 0, $timezone = true)
    {
        $chatId = intval($chatId);
        $messageStart = intval($messageStart);
 
        if ($date instanceof \Bitrix\Main\Type\DateTime)
        {
            $checkDate = $date;
            $dateSql = $checkDate->format("Y-m-d H:i:s");
        }
        else
        {
            $checkDate = new \Bitrix\Main\Type\DateTime($date, "Y-m-d H:i:s");
            $dateSql = $checkDate->format("Y-m-d H:i:s");
            if ($dateSql != $date)
            {
                return false;
            }
        }
 
        $chatData = CIMChat::GetChatData(Array('ID' => $chatId, 'USER_ID' => $this->user_id));
        if (empty($chatData['chat']))
            return false;
 
        $dialogId = 0;
        $chatType = IM_MESSAGE_CHAT;
        if ($chatData['chat'][$chatId]['type'] == 'private')
        {
            $chatType = IM_MESSAGE_PRIVATE;
            foreach ($chatData['userInChat'][$chatId] as $userId)
            {
                if ($userId != $this->user_id)
                {
                    $dialogId = $userId;
                    break;
                }
            }
            if (!$dialogId)
            {
                return false;
            }
        }
        else
        {
            $dialogId = 'chat'.$chatId;
        }
 
        $chatSql = str_pad($chatId, 11, '0', STR_PAD_LEFT);
 
        global $DB;
 
        if (!$timezone)
            CTimeZone::Disable();
 
        $sql = "
            SELECT 
                CASE WHEN M.ID > 0 THEN 'Y' ELSE 'N' END AS MESSAGE_EXISTS, 
                CASE WHEN M.ID > R.LAST_ID THEN 'N' ELSE 'Y' END AS MESSAGE_READ,
                C.TYPE as CHAT_TYPE,
                MS.MESSAGE_ID as ID,
                M.CHAT_ID,
                M.MESSAGE,
                ".$DB->DatetimeToTimestampFunction('M.DATE_CREATE')." as DATE_CREATE,
                M.AUTHOR_ID
            FROM b_im_message_param MS
            LEFT JOIN b_im_message M ON M.ID = MS.MESSAGE_ID
            LEFT JOIN b_im_relation R ON R.CHAT_ID = M.CHAT_ID and R.USER_ID = ".$this->user_id."
            LEFT JOIN b_im_chat C ON C.ID = M.CHAT_ID
            WHERE 
                MS.PARAM_NAME='TS' and 
                MS.PARAM_VALUE between '".$chatSql." ".$dateSql."' and '".$chatSql." 9999-99-99 99:99:99'
                ".($messageStart > 0? 'MS.MESSAGE_ID >= '.$messageStart: "")."
        ";
 
        if (!$timezone)
            CTimeZone::Enable();
 
        $result = $DB->Query($sql);
 
        $arMessages = Array();
        $arMessageUnread = Array();
        $arMessageDelete = Array();
        $arMessageId = Array();
        $usersMessage = Array();
        $arUsersIds = Array();
 
        while ($message = $result->Fetch())
        {
            if ($message['MESSAGE_EXISTS'] == 'N')
            {
                $arMessageDelete[] = $message['ID'];
                continue;
            }
            if ($message['MESSAGE_READ'] == 'N')
            {
                $arMessageUnread[$dialogId][] = $message['ID'];
            }
            if ($message['CHAT_TYPE'] == IM_MESSAGE_PRIVATE)
            {
                $recipientId = $message['AUTHOR_ID'] == $this->user_id? $dialogId: $this->user_id;
            }
            else
            {
                $recipientId = $message['CHAT_ID'];
            }
            $arMessages[$message['ID']] = Array(
                'id' => $message['ID'],
                'chatId' => $message['CHAT_ID'],
                'senderId' => $message['AUTHOR_ID'],
                'recipientId' => $recipientId,
                'date' => \Bitrix\Main\Type\DateTime::createFromTimestamp($message['DATE_CREATE']),
                'system' => $message['AUTHOR_ID'] > 0? 'N': 'Y',
                'text' => \Bitrix\Im\Text::parse($message['MESSAGE']),
                'textLegacy' => \Bitrix\Im\Text::parseLegacyFormat($arRes['MESSAGE'])
            );
 
            $usersMessage[$dialogId][] = $message['ID'];
            $arMessageId[] = $message['ID'];
            $arUsersIds[] = $message['AUTHOR_ID'];
        }
 
        $params = CIMMessageParam::Get($arMessageId);
        $arFiles = Array();
        foreach ($params as $messageId => $param)
        {
            $arMessages[$messageId]['params'] = $param;
            if (isset($param['FILE_ID']))
            {
                foreach ($param['FILE_ID'] as $fileId)
                {
                    $arFiles[$fileId] = $fileId;
                }
            }
        }
        $arMessageFiles = CIMDisk::GetFiles($chatId, $arFiles);
        $arMessages = CIMMessageLink::prepareShow($arMessages, $params);
 
        $users = CIMContactList::GetUserData(array(
             'ID' => $arUsersIds,
             'DEPARTMENT' => 'Y',
             'USE_CACHE' => 'N',
             'PHONES' => IsModuleInstalled('voximplant')? 'Y': 'N'
         ));
 
        return Array(
            'chatId' => $chatId,
            'dialogId' => $dialogId,
            'message' => $arMessages,
            'usersMessage' => $usersMessage,
            'unreadMessage' => $arMessageUnread,
            'messageDelete' => $arMessageDelete,
            'files' => $arMessageFiles,
            'users' => $users['users'],
            'userInGroup' => $users['userInGroup'],
            'phones' => $users['phones'],
            'lines' => $chatType == IM_MESSAGE_PRIVATE? Array(): $chatData['lines'],
            'chat' => $chatType == IM_MESSAGE_PRIVATE? Array(): $chatData['chat'],
            'userInChat' => $chatType == IM_MESSAGE_PRIVATE? Array(): $chatData['userInChat'],
            'userCallStatus' => $chatType == IM_MESSAGE_PRIVATE? Array(): $chatData['userCallStatus'],
            'userChatBlockStatus' => $chatType == IM_MESSAGE_PRIVATE? Array(): $chatData['userChatBlockStatus'],
        );
    }
 
    public function GetRelatedMessages($messageId, $previous = 10, $next = 10, $timezone = true, $textParser = true)
    {
        $message = \Bitrix\Im\Model\MessageTable::getList(Array(
            'select' => Array(
                'ID','DATE_CREATE', 'CHAT_ID', 'AUTHOR_ID',
                'CHAT_TYPE' => 'CHAT.TYPE',
                'CHAT_ENTITY_TYPE' => 'CHAT.ENTITY_TYPE',
                'CHAT_ENTITY_ID' => 'CHAT.ENTITY_ID',
                'CHAT_ENTITY_DATA_1' => 'CHAT.ENTITY_DATA_1',
            ),
            'filter' => Array(
                '=ID' => $messageId
            ))
        )->fetch();
        if (!$message)
        {
            return false;
        }
 
        $relations = CIMChat::GetRelationById($message['CHAT_ID'], false, true, false);
        if (!isset($relations[$this->user_id]))
        {
            if (
                $message['CHAT_ENTITY_TYPE'] == 'LINES'
                && \Bitrix\Main\Loader::includeModule('imopenlines')
            )
            {
                $explodeData = explode('|', $message['CHAT_ENTITY_DATA_1']);
                $crmEntityType = ($explodeData[0] == 'Y') ? $explodeData[1] : null;
                $crmEntityId = ($explodeData[0] == 'Y') ? intval($explodeData[2]) : null;
 
                $lineId = \Bitrix\ImOpenLines\Chat::parseLinesChatEntityId($message['CHAT_ENTITY_ID'])['lineId'];
 
                if (!\Bitrix\ImOpenLines\Config::canJoin($lineId, $crmEntityType, $crmEntityId))
                {
                    return false;
                }
            }
            else
            {
                return false;
            }
        }
        elseif ((int)$messageId < (int)$relations[$this->user_id]['START_ID'])
        {
            return false;
        }
 
        $dialogId = 0;
        if ($message['CHAT_TYPE'] == IM_MESSAGE_PRIVATE)
        {
            if($message['CHAT_ENTITY_TYPE'] == IM_CHAT_TYPE_PERSONAL)
            {
                $dialogId = $this->user_id;
            }
            if ($message['AUTHOR_ID'] != $this->user_id)
            {
                $dialogId = $message['AUTHOR_ID'];
            }
            else
            {
                foreach ($relations as $userId => $data)
                {
                    if ($userId != $this->user_id)
                    {
                        $dialogId = $userId;
                        break;
                    }
                }
                if (!$dialogId)
                {
                    return false;
                }
            }
        }
        else
        {
            $dialogId = 'chat'.$message['CHAT_ID'];
        }
 
        $previousMessages = $this->GetPreviousMessages($messageId, $message['CHAT_ID'], $message['DATE_CREATE'], $previous, $timezone);
        $nextMessages = $this->GetNextMessages($messageId, $message['CHAT_ID'], $message['DATE_CREATE'], $next, $timezone);
 
        $startId = (int)($relations[$this->user_id]['START_ID'] ?? 0);
        if ($startId > 0)
        {
            $previousMessages = array_filter($previousMessages, static fn (array $message) => (int)$message['ID'] >= $startId);
        }
 
        $messages = array_replace($previousMessages, $nextMessages);
 
        $chatId = $message['CHAT_ID'];
 
        $arMessages = Array();
        $arMessageFiles = Array();
        $arMessageId = Array();
        $usersMessage = Array();
        $arUsersIds = Array();
 
        foreach ($messages as $mess)
        {
            if ($message['CHAT_TYPE'] == IM_MESSAGE_PRIVATE)
            {
                $recipientId = $mess['AUTHOR_ID'] == $this->user_id? $dialogId: $this->user_id;
            }
            else
            {
                $recipientId = $mess['CHAT_ID'];
            }
            $arMessages[$mess['ID']] = Array(
                'id' => $mess['ID'],
                'chatId' => $mess['CHAT_ID'],
                'senderId' => $mess['AUTHOR_ID'],
                'recipientId' => $recipientId,
                'date' => \Bitrix\Main\Type\DateTime::createFromTimestamp($mess['DATE_CREATE']),
                'system' => $mess['AUTHOR_ID'] > 0? 'N': 'Y',
                'text' => $textParser? \Bitrix\Im\Text::parse($mess['MESSAGE']): $mess['MESSAGE'],
                'textLegacy' => $textParser? \Bitrix\Im\Text::parseLegacyFormat($mess['MESSAGE']): $mess['MESSAGE']
            );
 
            $usersMessage[$dialogId][] = $mess['ID'];
            $arMessageId[] = $mess['ID'];
            $arUsersIds[] = $mess['AUTHOR_ID'];
        }
 
        $params = CIMMessageParam::Get($arMessageId);
        $arFiles = Array();
        foreach ($params as $messageId => $param)
        {
            $arMessages[$messageId]['params'] = $param;
            if (isset($param['FILE_ID']))
            {
                foreach ($param['FILE_ID'] as $fileId)
                {
                    $arFiles[$fileId] = $fileId;
                }
            }
        }
        $arMessageFiles = CIMDisk::GetFiles($chatId, $arFiles);
        $arMessages = CIMMessageLink::prepareShow($arMessages, $params);
 
        $users = CIMContactList::GetUserData(array(
                                                 'ID' => $arUsersIds,
                                                 'DEPARTMENT' => 'Y',
                                                 'USE_CACHE' => 'N',
                                                 'PHONES' => IsModuleInstalled('voximplant')? 'Y': 'N'
                                             ));
 
        return Array(
            'chatId' => $chatId,
            'dialogId' => $dialogId,
            'message' => $arMessages,
            'usersMessage' => $usersMessage,
            'files' => $arMessageFiles,
            'users' => $users['users'],
            'userInGroup' => $users['userInGroup'],
            'phones' => $users['phones'],
        );
    }
 
    private function GetPreviousMessages($messageId, $chatId = null, $dateCreate = null, $limit = 10, $timezone = true)
    {
        global $DB;
 
        if (is_null($chatId) || !is_object($dateCreate))
        {
            $message = \Bitrix\Im\Model\MessageTable::getList(Array('select' => Array('DATE_CREATE', 'CHAT_ID'), 'filter' => Array('=ID' => $messageId)))->fetch();
            if (!$message)
                return false;
 
            $chatId = $message['CHAT_ID'];
            $dateCreate = $message['DATE_CREATE'];
        }
        else
        {
            $chatId = intval($chatId);
        }
 
        $limit = intval($limit)+1;
 
        if (!$timezone)
            CTimeZone::Disable();
 
        $sql =
            "SELECT 
                ID,
                CHAT_ID,
                MESSAGE,
                ".$DB->DatetimeToTimestampFunction('DATE_CREATE')." as DATE_CREATE,
                AUTHOR_ID
            FROM b_im_message
            WHERE
                CHAT_ID = ".$chatId." 
                and DATE_CREATE <= '".$dateCreate->format('Y-m-d H:i:s')."'
            ORDER BY CHAT_ID, DATE_CREATE desc 
            LIMIT ".$limit;
 
        if (!$timezone)
            CTimeZone::Enable();
 
        $result = $DB->Query($sql);
 
        $messages = array();
        while ($message = $result->Fetch())
        {
            $messages[$message['ID']] = $message;
        }
        asort($messages);
 
        return $messages;
    }
 
    private function GetNextMessages($messageId, $chatId = null, $dateCreate = null, $limit = 10, $timezone = true)
    {
        global $DB;
 
        if (is_null($chatId) || !is_object($dateCreate))
        {
            $message = \Bitrix\Im\Model\MessageTable::getList(Array('select' => Array('DATE_CREATE', 'CHAT_ID'), 'filter' => Array('=ID' => $messageId)))->fetch();
            if (!$message)
                return false;
 
            $chatId = $message['CHAT_ID'];
            $dateCreate = $message['DATE_CREATE'];
        }
        else
        {
            $chatId = intval($chatId);
        }
 
        $limit = intval($limit)+1;
 
        if (!$timezone)
            CTimeZone::Disable();
 
        $sql =
            "SELECT 
                ID,
                CHAT_ID,
                MESSAGE,
                ".$DB->DatetimeToTimestampFunction('DATE_CREATE')." as DATE_CREATE,
                AUTHOR_ID
            FROM b_im_message
            WHERE
                CHAT_ID = ".$chatId." 
                and DATE_CREATE >= '".$dateCreate->format('Y-m-d H:i:s')."'
            ORDER BY CHAT_ID, DATE_CREATE asc 
            LIMIT ".$limit;
 
        if (!$timezone)
            CTimeZone::Enable();
 
        $result = $DB->Query($sql);
 
        $messages = array();
        while ($message = $result->Fetch())
        {
            $messages[$message['ID']] = $message;
        }
 
        return $messages;
    }
 
    private function checkFullText($searchText): bool
    {
        $indexEnabled = \Bitrix\Main\Config\Option::get('im', 'message_history_index');
 
        if (
            $indexEnabled
            && \Bitrix\Main\Search\Content::canUseFulltextSearch($searchText)
        )
        {
            return true;
        }
 
        return false;
    }
}