im_event.php

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

<?
IncludeModuleLangFile(__FILE__);
 
use Bitrix\Im as IM;
use Bitrix\Main\Loader;
use Bitrix\Main\Localization\Loc;
use Bitrix\Socialnetwork\Livefeed;
 
class CIMEvent
{
    public static function OnFileDelete($params)
    {
        if (!in_array($params['MODULE_ID'], ['im', 'imopenlines']))
        {
            return true;
        }
 
        $result = IM\Model\ChatTable::getList([
            'select' => ['ID', 'AUTHOR_ID'],
            'filter' => ['=AVATAR' => $params['ID']]
        ]);
        while ($row = $result->fetch())
        {
            IM\Model\ChatTable::update($row['ID'], ['AVATAR' => null]);
        }
    }
 
    public static function OnBeforeUserSendPassword($params)
    {
        $bots = IM\Bot::getListCache();
        if (empty($bots))
            return true;
 
        if (isset($params['LOGIN']) && !empty($params['LOGIN']))
        {
            if (mb_substr($params['LOGIN'], 0, mb_strlen(IM\Bot::LOGIN_START)) == IM\Bot::LOGIN_START)
            {
                $orm = \Bitrix\Main\UserTable::getList([
                    'filter' => [
                        '=LOGIN' => $params['LOGIN'],
                        '=EXTERNAL_AUTH_ID' => IM\Bot::EXTERNAL_AUTH_ID
                    ]
                ]);
                if ($orm->fetch())
                {
                    $GLOBALS["APPLICATION"]->ThrowException(GetMessage("IM_EVENT_ERROR_CHANGE_PASSWORD_FOR_BOT"), "ERROR_CHANGE_PASSWORD_FOR_BOT");
                    return false;
                }
            }
        }
 
        if (isset($params['EMAIL']) && !empty($params['EMAIL']))
        {
            $orm = \Bitrix\Main\UserTable::getList([
                'filter' => [
                    '=EMAIL' => $params['EMAIL'],
                    '=EXTERNAL_AUTH_ID' => IM\Bot::EXTERNAL_AUTH_ID
                ]
            ]);
            if ($orm->fetch())
            {
                $GLOBALS["APPLICATION"]->ThrowException(GetMessage("IM_EVENT_ERROR_CHANGE_PASSWORD_FOR_BOT"), "ERROR_CHANGE_PASSWORD_FOR_BOT");
                return false;
            }
        }
 
        return true;
    }
 
    public static function OnAddRatingVote($id, $arParams)
    {
        if (!Loader::includeModule("socialnetwork"))
        {
            return true;
        }
 
        $ratingNotifyTag = "RATING|".($arParams['VALUE'] >= 0 ? "" : "DL|").$arParams['ENTITY_TYPE_ID']."|".$arParams['ENTITY_ID'];
        if (!empty($arParams['REACTION']))
        {
            $ratingNotifyTag .= "|".$arParams['REACTION'];
        }
        $ratingMentionNotifyTag = 'RATING_MENTION|' . ($arParams['VALUE'] >= 0 ? '' : 'DL|') . $arParams['ENTITY_TYPE_ID'] . '|' . $arParams['ENTITY_ID'];
 
        $contentId = Livefeed\Provider::getContentId([
            "RATING_TYPE_ID" => $arParams['ENTITY_TYPE_ID'],
            "RATING_ENTITY_ID" => $arParams['ENTITY_ID']
        ]);
 
        if (!empty($contentId['ENTITY_TYPE']))
        {
            $liveFeedEntity = Livefeed\Provider::init([
                'ENTITY_TYPE' => $contentId['ENTITY_TYPE'],
                'ENTITY_ID' => $contentId['ENTITY_ID']
            ]);
 
            if (!$liveFeedEntity)
            {
                return false;
            }
 
            if ($arParams['OWNER_ID'] != $arParams['USER_ID']) // AUX
            {
                $originalText = $liveFeedEntity->getSourceOriginalText();
                $auxData = $liveFeedEntity->getSourceAuxData();
 
                if (
                    $originalText <> ''
                    && !empty($auxData)
                )
                {
                    $handlerManager = new Bitrix\Socialnetwork\CommentAux\HandlerManager();
                    if($handler = $handlerManager->getHandlerByPostText($originalText))
                    {
                        $suffix = '';
                        if ($provider = Livefeed\Provider::getProvider($contentId['ENTITY_TYPE']))
                        {
                            $suffix = $provider->getSuffix();
                        }
 
                        $handler->setOptions([
                            'im' => true,
                            'suffix' => $suffix
                        ]);
                        $handler->sendRatingNotification($auxData, $arParams);
                        return true;
                    }
                }
            }
 
            $title = $liveFeedEntity->getSourceTitle();
            $description = $liveFeedEntity->getSourceDescription();
            $url = $liveFeedEntity->getLiveFeedUrl();
 
            $arMentionedUserID = [];
            if (!empty($description))
            {
                preg_match_all("/\[user\s*=\s*([^\]]*)\](.+?)\[\/user\]/isu", $description, $mention);
                if (!empty($mention))
                {
                    $arMentionedUserID = array_merge($arMentionedUserID, $mention[1]);
                }
            }
            $arMentionedUserID = array_unique($arMentionedUserID);
 
            $title = CTextParser::clearAllTags(\Bitrix\Im\Text::removeBbCodes($title));
            $description = CTextParser::clearAllTags(\Bitrix\Im\Text::removeBbCodes($description));
 
            if (
                $arParams['OWNER_ID'] != $arParams['USER_ID']
                || !empty($arMentionedUserID)
            )
            {
                $arParams["ENTITY_LINK"] = $url;
                $arParams["ENTITY_PARAM"] = '';
 
                if (
                    in_array('photo_photo', $liveFeedEntity->getEventId())
                    || in_array('photo', $liveFeedEntity->getEventId())
                )
                {
                    $arParams["ENTITY_PARAM"] = 'photos'; // it was also 'library' value
                }
                elseif (in_array('wiki', $liveFeedEntity->getEventId()))
                {
                    $arParams["ENTITY_PARAM"] = 'wiki';
                }
 
                $arParams["ENTITY_TITLE"] = trim(strip_tags(str_replace(["\r\n","\n","\r"], ' ', $title)));
                $arParams["ENTITY_MESSAGE"] = trim(strip_tags(str_replace(["\r\n","\n","\r"], ' ', $description)));
                $arParams["ENTITY_BODY"] = preg_replace('/(.+?)(\r|\n)+.*/isu','\\1', $description);
 
                if (
                    (
                        $arParams["ENTITY_TITLE"] <> ''
                        || $arParams["ENTITY_MESSAGE"] <> ''
                    )
                    && $arParams["ENTITY_LINK"] <> ''
                )
                {
                    $originalLink = $arParams["ENTITY_LINK"];
 
                    $bExtranetInstalled = CModule::IncludeModule("extranet");
                    if ($bExtranetInstalled)
                    {
                        $arSites = [];
                        $extranet_site_id = CExtranet::GetExtranetSiteID();
                        $intranet_site_id = CSite::GetDefSite();
                        $dbSite = CSite::GetList("sort", "desc", ["ACTIVE" => "Y"]);
                        while($arSite = $dbSite->Fetch())
                        {
                            $arSites[$arSite["ID"]] = [
                                "DIR" => (trim($arSite["DIR"]) <> '' ? $arSite["DIR"] : "/"),
                                "SERVER_NAME" => (trim($arSite["SERVER_NAME"]) <> '' ? $arSite["SERVER_NAME"] : COption::GetOptionString("main", "server_name", $_SERVER["HTTP_HOST"]))
                            ];
                        }
                    }
                    $bSentToOwner = false;
                    if ($arParams['OWNER_ID'] != $arParams['USER_ID'])
                    {
                        $followValue = CSocNetLogFollow::GetExactValueByRating(
                            intval($arParams['OWNER_ID']),
                            trim($arParams["ENTITY_TYPE_ID"]),
                            intval($arParams["ENTITY_ID"])
                        );
 
                        if ($followValue != "N")
                        {
                            $arParams['ENTITY_LINK'] = self::GetMessageRatingEntityURL(
                                $originalLink,
                                intval($arParams['OWNER_ID']),
                                $arSites,
                                $intranet_site_id,
                                $extranet_site_id
                            );
 
                            $arMessageFields = [
                                "MESSAGE_TYPE" => IM_MESSAGE_SYSTEM,
                                "TO_USER_ID" => intval($arParams['OWNER_ID']),
                                "FROM_USER_ID" => intval($arParams['USER_ID']),
                                "NOTIFY_TYPE" => IM_NOTIFY_FROM,
                                "NOTIFY_MODULE" => "main",
                                "NOTIFY_EVENT" => "rating_vote",
                                "NOTIFY_TAG" => $ratingNotifyTag,
                                "NOTIFY_SUB_TAG" => $ratingNotifyTag.'|'.intval($arParams['OWNER_ID']),
                                "NOTIFY_MESSAGE" => fn (?string $languageId = null) => self::GetMessageRatingVote($arParams, false, $languageId),
                                "NOTIFY_MESSAGE_OUT" => fn (?string $languageId = null) => self::GetMessageRatingVote($arParams, true, $languageId)
                            ];
                            $bSentToOwner = CIMNotify::Add($arMessageFields);
                        }
                    }
 
                    if (is_array($arMentionedUserID))
                    {
                        if (in_array($arParams['ENTITY_TYPE_ID'], ["BLOG_COMMENT", "FORUM_POST"]))
                        {
                            $rsLogComment = CSocNetLogComments::GetList(
                                [],
                                [
                                    "RATING_TYPE_ID" => $arParams['ENTITY_TYPE_ID'],
                                    "RATING_ENTITY_ID" =>  $arParams['ENTITY_ID']
                                ],
                                false,
                                false,
                                ["LOG_ID"]
                            );
                            if ($arLogComment = $rsLogComment->Fetch())
                            {
                                $logId = $arLogComment["LOG_ID"];
                            }
                        }
                        elseif (in_array($arParams['ENTITY_TYPE_ID'], ["BLOG_POST"]))
                        {
                            $rsLog = CSocNetLog::GetList(
                                [],
                                [
                                    "RATING_TYPE_ID" => $arParams['ENTITY_TYPE_ID'],
                                    "RATING_ENTITY_ID" =>  $arParams['ENTITY_ID']
                                ],
                                false,
                                false,
                                ["ID"]
                            );
                            if ($arLog = $rsLog->Fetch())
                            {
                                $logId = $arLog["ID"];
                            }
                        }
 
                        if (intval($logId) > 0)
                        {
                            $arParams["MENTION"] = true; // for self::GetMessageRatingVote()
 
                            foreach ($arMentionedUserID as $mentioned_user_id)
                            {
                                if (
                                    $mentioned_user_id != $arParams['USER_ID']
                                    && ($mentioned_user_id != $arParams['OWNER_ID'] || !$bSentToOwner)
                                    && CSocNetLogRights::CheckForUserOnly($logId, $mentioned_user_id)
                                )
                                {
                                    $followValue = CSocNetLogFollow::GetExactValueByRating(
                                        intval($mentioned_user_id),
                                        trim($arParams["ENTITY_TYPE_ID"]),
                                        intval($arParams["ENTITY_ID"])
                                    );
 
                                    if ($followValue != "N")
                                    {
                                        $arParams['ENTITY_LINK'] = self::GetMessageRatingEntityURL(
                                            $originalLink,
                                            intval($mentioned_user_id),
                                            $arSites,
                                            $intranet_site_id,
                                            $extranet_site_id
                                        );
 
                                        $arMessageFields = [
                                            "MESSAGE_TYPE" => IM_MESSAGE_SYSTEM,
                                            "TO_USER_ID" => intval($mentioned_user_id),
                                            "FROM_USER_ID" => intval($arParams['USER_ID']),
                                            "NOTIFY_TYPE" => IM_NOTIFY_FROM,
                                            "NOTIFY_MODULE" => "main",
                                            "NOTIFY_EVENT" => "rating_vote_mentioned",
                                            "NOTIFY_TAG" => $ratingMentionNotifyTag,
                                            "NOTIFY_SUB_TAG" => $ratingMentionNotifyTag.'|'.intval($mentioned_user_id),
                                            "NOTIFY_MESSAGE" => fn (?string $languageId = null) => self::GetMessageRatingVote($arParams, false, $languageId),
                                            "NOTIFY_MESSAGE_OUT" => fn (?string $languageId = null) => self::GetMessageRatingVote($arParams, true, $languageId),
                                        ];
 
                                        CIMNotify::Add($arMessageFields);
                                    }
                                }
                            }
                        }
                    }
                }
            }
        }
 
        return true;
    }
 
    public static function OnCancelRatingVote($id, $arParams)
    {
        CIMNotify::DeleteByTag("RATING|".$arParams['ENTITY_TYPE_ID']."|".$arParams['ENTITY_ID'], $arParams['USER_ID']);
    }
 
    public static function GetMessageRatingVote($arParams, $bForMail = false, ?string $languageId = null)
    {
        static $intranetInstalled = null;
 
        if ($intranetInstalled === null)
        {
            $intranetInstalled = \Bitrix\Main\ModuleManager::isModuleInstalled('intranet');
        }
 
        $like = (
            $arParams['VALUE'] >= 0
                ? ($intranetInstalled ? '_REACT' : '_LIKE')
                : '_DISLIKE'
        );
 
        foreach(\Bitrix\Main\EventManager::getInstance()->findEventHandlers("im", "OnGetMessageRatingVote") as $event)
        {
            ExecuteModuleEventEx($event, [&$arParams, &$bForMail]);
        }
 
        if(isset($arParams['MESSAGE'])) // message was generated manually inside OnGetMessageRatingVote
        {
            return $arParams['MESSAGE'];
        }
 
        $genderSuffix = '';
        if (
            $like == '_REACT'
            && !empty($arParams['USER_ID'])
            && intval($arParams['USER_ID']) > 0
        )
        {
            $res = \Bitrix\Main\UserTable::getList([
                'filter' => [
                    'ID' => intval($arParams['USER_ID'])
                ],
                'select' => ['PERSONAL_GENDER']
            ]);
            if ($userFields = $res->fetch())
            {
                switch ($userFields['PERSONAL_GENDER'])
                {
                    case "M":
                    case "F":
                        $genderSuffix = '_'.$userFields['PERSONAL_GENDER'];
                        break;
                    default:
                        $genderSuffix = '';
                }
            }
            $like .= $genderSuffix;
        }
 
        if (!isset($CCTP))
        {
            $CCTP = new CTextParser();
        }
 
        if (
            $arParams['ENTITY_TYPE_ID'] == 'FORUM_POST'
            || $arParams['ENTITY_TYPE_ID'] == 'BLOG_COMMENT'
        )
        {
            $stripped = $CCTP->strip_words($arParams["ENTITY_MESSAGE"], 199);
            $arParams["ENTITY_MESSAGE"] = $stripped.(mb_strlen($stripped) != mb_strlen($arParams["ENTITY_MESSAGE"]) ? '...' : '');
        }
        else
        {
            $stripped = $CCTP->strip_words($arParams["ENTITY_TITLE"], 199);
            $arParams["ENTITY_TITLE"] = $stripped.(mb_strlen($stripped) != mb_strlen($arParams["ENTITY_TITLE"]) ? '...' : '');
        }
 
        if ($bForMail)
        {
            if ($arParams['ENTITY_TYPE_ID'] == 'BLOG_POST')
            {
                $message = str_replace('#LINK#', $arParams["ENTITY_TITLE"], Loc::getMessage('IM_EVENT_RATING_BLOG_POST'.($arParams['MENTION'] ? '_MENTION' : '').$like, null, $languageId));
            }
            elseif ($arParams['ENTITY_TYPE_ID'] == 'BLOG_COMMENT')
            {
                $message = str_replace(['#TITLE#', '#A_START#', '#A_END#'], [$arParams["ENTITY_MESSAGE"], '', ''], Loc::getMessage('IM_EVENT_RATING_COMMENT'.($arParams['MENTION'] ? '_MENTION' : '').$like, null, $languageId));
            }
            elseif ($arParams['ENTITY_TYPE_ID'] == 'FORUM_TOPIC')
            {
                $message = str_replace('#LINK#', $arParams["ENTITY_TITLE"], Loc::getMessage('IM_EVENT_RATING_FORUM_TOPIC'.$like, null, $languageId));
            }
            elseif ($arParams['ENTITY_TYPE_ID'] == 'FORUM_POST')
            {
                $message = str_replace(['#TITLE#', '#A_START#', '#A_END#'], [$arParams["ENTITY_MESSAGE"], '', ''], Loc::getMessage('IM_EVENT_RATING_COMMENT'.($arParams['MENTION'] ? '_MENTION' : '').$like, null, $languageId));
            }
            elseif (
                $arParams['ENTITY_TYPE_ID'] == 'IBLOCK_SECTION'
                && $arParams['ENTITY_PARAM'] == 'photos'
            )
            {
                if (isset($arParams["ENTITY_BODY"]))
                {
                    $message = str_replace(['#TITLE#', '#A_START#', '#A_END#'], [$arParams["ENTITY_BODY"], '', ''], Loc::getMessage('IM_EVENT_RATING_PHOTO_ALBUM'.$like, null, $languageId));
                }
                elseif (is_numeric($arParams["ENTITY_TITLE"]))
                {
                    $message = str_replace(['#A_START#', '#A_END#'], ['', ''], Loc::getMessage('IM_EVENT_RATING_PHOTO_ALBUM1'.$like, null, $languageId));
                }
                else
                {
                    $message = str_replace(['#TITLE#', '#A_START#', '#A_END#'], [$arParams["ENTITY_TITLE"], '', ''], Loc::getMessage('IM_EVENT_RATING_PHOTO_ALBUM'.$like, null, $languageId));
                }
            }
            elseif (
                $arParams['ENTITY_TYPE_ID'] == 'IBLOCK_ELEMENT'
                && $arParams['ENTITY_PARAM'] == 'library'
            )
            {
                $message = str_replace(['#TITLE#', '#A_START#', '#A_END#'], [$arParams["ENTITY_TITLE"], '', ''], Loc::getMessage('IM_EVENT_RATING_FILE'.$like, null, $languageId));
            }
            elseif (
                $arParams['ENTITY_TYPE_ID'] == 'IBLOCK_ELEMENT'
                && $arParams['ENTITY_PARAM'] == 'wiki'
            )
            {
                $message = str_replace(['#TITLE#', '#A_START#', '#A_END#'], [$arParams["ENTITY_TITLE"], '', ''], Loc::getMessage('IM_EVENT_RATING_WIKI'.$like, null, $languageId));
            }
            elseif (
                $arParams['ENTITY_TYPE_ID'] == 'IBLOCK_ELEMENT'
                && $arParams['ENTITY_PARAM'] == 'photos'
            )
            {
                if (isset($arParams["ENTITY_BODY"]))
                {
                    $message = str_replace(['#TITLE#', '#A_START#', '#A_END#'], [$arParams["ENTITY_BODY"], '', ''], Loc::getMessage('IM_EVENT_RATING_PHOTO'.$like, null, $languageId));
                }
                elseif (is_numeric($arParams["ENTITY_TITLE"]))
                {
                    $message = str_replace(['#A_START#', '#A_END#'], ['', ''], Loc::getMessage('IM_EVENT_RATING_PHOTO1'.$like, null, $languageId));
                }
                else
                {
                    $message = str_replace(['#TITLE#', '#A_START#', '#A_END#'], [$arParams["ENTITY_TITLE"], '', ''], Loc::getMessage('IM_EVENT_RATING_PHOTO'.$like, null, $languageId));
                }
            }
            elseif ($arParams['ENTITY_TYPE_ID'] == 'LOG_COMMENT')
            {
                $message = str_replace(['#TITLE#', '#A_START#', '#A_END#'], [$arParams["ENTITY_TITLE"], '', ''], Loc::getMessage('IM_EVENT_RATING_COMMENT'.($arParams['MENTION'] ? '_MENTION' : '').$like, null, $languageId));
            }
            elseif ($arParams['ENTITY_TYPE_ID'] == 'LISTS_NEW_ELEMENT')
            {
                $message = str_replace(
                    [
                        '#TITLE#',
                        '#A_START#',
                        '#A_END#'
                    ],
                    [
                        $arParams["ENTITY_TITLE"],
                        '',
                        ''
                    ],
                    Loc::getMessage('IM_EVENT_RATING_LISTS_NEW_ELEMENT_LIKE'.$like, null, $languageId)
                );
            }
            else
            {
                $message = str_replace('#LINK#', $arParams["ENTITY_TITLE"], Loc::getMessage('IM_EVENT_RATING_ELSE'.$like, null, $languageId));
            }
 
            if ($arParams['ENTITY_LINK'] <> '')
            {
                $message .= ' ('.$arParams['ENTITY_LINK'].')';
            }
        }
        else
        {
            if ($arParams['ENTITY_TYPE_ID'] == 'BLOG_POST')
            {
                $message = str_replace('#LINK#', '<a href="'.$arParams['ENTITY_LINK'].'" class="bx-notifier-item-action">'.$arParams["ENTITY_TITLE"].'</a>', Loc::getMessage('IM_EVENT_RATING_BLOG_POST'.($arParams['MENTION'] ? '_MENTION' : '').$like, null, $languageId));
            }
            elseif ($arParams['ENTITY_TYPE_ID'] == 'BLOG_COMMENT')
            {
                $message = str_replace(['#TITLE#', '#A_START#', '#A_END#'], [$arParams["ENTITY_MESSAGE"], '<a href="'.$arParams['ENTITY_LINK'].'" class="bx-notifier-item-action">', '</a>'], Loc::getMessage('IM_EVENT_RATING_COMMENT'.($arParams['MENTION'] ? '_MENTION' : '').$like, null, $languageId));
            }
            elseif ($arParams['ENTITY_TYPE_ID'] == 'FORUM_TOPIC')
            {
                $message = str_replace('#LINK#', '<a href="'.$arParams['ENTITY_LINK'].'" class="bx-notifier-item-action">'.$arParams["ENTITY_TITLE"].'</a>', Loc::getMessage('IM_EVENT_RATING_FORUM_TOPIC'.$like, null, $languageId));
            }
            elseif ($arParams['ENTITY_TYPE_ID'] == 'FORUM_POST')
            {
                $message = str_replace(['#TITLE#', '#A_START#', '#A_END#'], [$arParams["ENTITY_MESSAGE"], '<a href="'.$arParams['ENTITY_LINK'].'" class="bx-notifier-item-action">', '</a>'], Loc::getMessage('IM_EVENT_RATING_COMMENT'.($arParams['MENTION'] ? '_MENTION' : '').$like, null, $languageId));
            }
            elseif (
                $arParams['ENTITY_TYPE_ID'] == 'IBLOCK_ELEMENT'
                && $arParams['ENTITY_PARAM'] == 'library'
            )
            {
                $message = str_replace(['#TITLE#', '#A_START#', '#A_END#'], [$arParams["ENTITY_TITLE"], '<a href="'.$arParams['ENTITY_LINK'].'" class="bx-notifier-item-action">', '</a>'], Loc::getMessage('IM_EVENT_RATING_FILE'.$like, null, $languageId));
            }
            elseif (
                $arParams['ENTITY_TYPE_ID'] == 'IBLOCK_ELEMENT'
                && $arParams['ENTITY_PARAM'] == 'wiki'
            )
            {
                $message = str_replace(['#TITLE#', '#A_START#', '#A_END#'], [$arParams["ENTITY_TITLE"], '<a href="'.$arParams['ENTITY_LINK'].'" class="bx-notifier-item-action">', '</a>'], Loc::getMessage('IM_EVENT_RATING_WIKI'.$like, null, $languageId));
            }
            elseif (
                $arParams['ENTITY_TYPE_ID'] == 'IBLOCK_SECTION'
                && $arParams['ENTITY_PARAM'] == 'photos'
            )
            {
                if (isset($arParams["ENTITY_BODY"]))
                {
                    $message = str_replace(['#TITLE#', '#A_START#', '#A_END#'], [$arParams["ENTITY_BODY"], '<a href="'.$arParams['ENTITY_LINK'].'" class="bx-notifier-item-action">', '</a>'], Loc::getMessage('IM_EVENT_RATING_PHOTO_ALBUM'.$like, null, $languageId));
                }
                elseif (is_numeric($arParams["ENTITY_TITLE"]))
                {
                    $message = str_replace(['#A_START#', '#A_END#'], ['<a href="'.$arParams['ENTITY_LINK'].'" class="bx-notifier-item-action">', '</a>'], Loc::getMessage('IM_EVENT_RATING_PHOTO_ALBUM1'.$like, null, $languageId));
                }
                else
                {
                    $message = str_replace(['#TITLE#', '#A_START#', '#A_END#'], [$arParams["ENTITY_TITLE"], '<a href="'.$arParams['ENTITY_LINK'].'" class="bx-notifier-item-action">', '</a>'], Loc::getMessage('IM_EVENT_RATING_PHOTO_ALBUM'.$like, null, $languageId));
                }
            }
            elseif (
                $arParams['ENTITY_TYPE_ID'] == 'IBLOCK_ELEMENT'
                && $arParams['ENTITY_PARAM'] == 'photos'
            )
            {
                if (isset($arParams["ENTITY_BODY"]))
                {
                    $message = str_replace(['#TITLE#', '#A_START#', '#A_END#'], [$arParams["ENTITY_BODY"], '<a href="'.$arParams['ENTITY_LINK'].'" class="bx-notifier-item-action">', '</a>'], Loc::getMessage('IM_EVENT_RATING_PHOTO'.$like, null, $languageId));
                }
                elseif (is_numeric($arParams["ENTITY_TITLE"]))
                {
                    $message = str_replace(['#A_START#', '#A_END#'], ['<a href="'.$arParams['ENTITY_LINK'].'" class="bx-notifier-item-action">', '</a>'], Loc::getMessage('IM_EVENT_RATING_PHOTO1'.$like));
                }
                else
                {
                    $message = str_replace(['#TITLE#', '#A_START#', '#A_END#'], [$arParams["ENTITY_TITLE"], '<a href="'.$arParams['ENTITY_LINK'].'" class="bx-notifier-item-action">', '</a>'], Loc::getMessage('IM_EVENT_RATING_PHOTO'.$like, null, $languageId));
                }
            }
            elseif ($arParams['ENTITY_TYPE_ID'] == 'LOG_COMMENT')
            {
                $message = str_replace(['#TITLE#', '#A_START#', '#A_END#'], [$arParams["ENTITY_TITLE"], '<a href="'.$arParams['ENTITY_LINK'].'" class="bx-notifier-item-action">', '</a>'], Loc::getMessage('IM_EVENT_RATING_COMMENT'.($arParams['MENTION'] ? '_MENTION' : '').$like, null, $languageId));
            }
            elseif ($arParams['ENTITY_TYPE_ID'] == 'LISTS_NEW_ELEMENT')
            {
                $message = str_replace(
                    [
                        '#TITLE#',
                        '#A_START#',
                        '#A_END#'
                    ],
                    [
                        $arParams["ENTITY_TITLE"],
                        '<a href="'.$arParams['ENTITY_LINK'].'" class="bx-notifier-item-action">',
                        '</a>'
                    ],
                    Loc::getMessage('IM_EVENT_RATING_LISTS_NEW_ELEMENT'.$like, null, $languageId)
                );
            }
            else
            {
                $message = str_replace('#LINK#', $arParams['ENTITY_LINK'] <> ''?'<a href="'.$arParams['ENTITY_LINK'].'" class="bx-notifier-item-action">'.$arParams["ENTITY_TITLE"].'</a>': '<i>'.$arParams["ENTITY_TITLE"].'</i>', Loc::getMessage('IM_EVENT_RATING_ELSE'.$like, null, $languageId));
            }
 
            if ($intranetInstalled)
            {
                $message .= "\n".str_replace("#REACTION#", \CRatingsComponentsMain::getRatingLikeMessage(!empty($arParams['REACTION']) ? $arParams['REACTION'] : ''), Bitrix\Main\Localization\Loc::getMessage("IM_EVENT_RATING_REACTION", null, $languageId));
            }
        }
 
        return $message;
    }
 
    public static function GetMessageRatingEntityURL($url, $user_id = false, $arSites = false, $intranet_site_id = false, $extranet_site_id = false)
    {
        static $arSiteData = false;
 
        if (
            !$arSiteData
            && IsModuleInstalled('intranet')
            && CModule::IncludeModule('socialnetwork')
        )
        {
            $arSiteData = CSocNetLogTools::GetSiteData();
        }
 
        if (
            $arSiteData
            && count($arSiteData) > 1
        )
        {
            foreach($arSiteData as $siteId => $arUrl)
            {
                $url = str_replace($arUrl["USER_PATH"], "#USER_PATH#", $url);
            }
 
            $arTmp = CSocNetLogTools::ProcessPath(
                [
                    "URL" => $url
                ],
                $user_id
            );
 
            $url = $arTmp["URLS"]["URL"];
            $url = (
                mb_strpos($url, "http://") === 0
                || mb_strpos($url, "https://") === 0
                    ? ""
                    : (
                        isset($arTmp["SERVER_NAME"])
                        && !empty($arTmp["SERVER_NAME"])
                            ? $arTmp["SERVER_NAME"]
                            : ""
                    )
            ).$arTmp["URLS"]["URL"];
        }
        else
        {
            if (
                is_array($arSites)
                && intval($user_id) > 0
                && $extranet_site_id <> ''
                && $intranet_site_id <> ''
            )
            {
                $bExtranetUser = false;
                if ($arSites[$extranet_site_id])
                {
                    $bExtranetUser = true;
                    $rsUser = CUser::GetByID(intval($user_id));
                    if ($arUser = $rsUser->Fetch())
                    {
                        if (intval($arUser["UF_DEPARTMENT"][0]) > 0)
                        {
                            $bExtranetUser = false;
                        }
                    }
                }
 
                if ($bExtranetUser)
                {
                    $link = $url;
                    if (mb_substr($link, 0, mb_strlen($arSites[$extranet_site_id]['DIR'])) == $arSites[$extranet_site_id]['DIR'])
                    {
                        $link = mb_substr($link, mb_strlen($arSites[$extranet_site_id]['DIR']));
                    }
 
                    $SiteServerName = $arSites[$extranet_site_id]['SERVER_NAME'].$arSites[$extranet_site_id]['DIR'].ltrim($link, "/");
                }
                else
                {
                    $link = $url;
                    if (mb_substr($link, 0, mb_strlen($arSites[$intranet_site_id]['DIR'])) == $arSites[$intranet_site_id]['DIR'])
                    {
                        $link = mb_substr($link, mb_strlen($arSites[$intranet_site_id]['DIR']));
                    }
 
                    $SiteServerName = $arSites[$intranet_site_id]['SERVER_NAME'].$arSites[$intranet_site_id]['DIR'].ltrim($link, "/");
                }
 
                $url = (CMain::IsHTTPS() ? "https" : "http")."://".$SiteServerName;
            }
            else
            {
                $SiteServerName = (defined('SITE_SERVER_NAME') && SITE_SERVER_NAME <> '' ? SITE_SERVER_NAME : COption::GetOptionString("main", "server_name", $_SERVER['SERVER_NAME']));
                if ($SiteServerName <> '')
                {
                    $url = (CMain::IsHTTPS() ? "https" : "http")."://".$SiteServerName.$url;
                }
            }
        }
 
        return $url;
    }
 
    private static function GetMessageRatingLogCommentURL($arComment, $user_id = false, $arSites = false, $intranet_site_id = false, $extranet_site_id = false)
    {
        $url = false;
 
        if (
            !is_array($arComment)
            || !isset($arComment["ENTITY_TYPE"]) || $arComment["ENTITY_TYPE"] == ''
            || !isset($arComment["ID"]) || intval($arComment["ID"]) <= 0
            || !isset($arComment["LOG_ID"]) || intval($arComment["LOG_ID"]) <= 0
        )
        {
            return false;
        }
 
        if (
            is_array($arSites)
            && intval($user_id) > 0
            && $extranet_site_id <> ''
            && $intranet_site_id <> ''
        )
        {
            $bExtranetUser = false;
            if ($arSites[$extranet_site_id])
            {
                $bExtranetUser = true;
                $rsUser = CUser::GetByID($user_id);
                if ($arUser = $rsUser->Fetch())
                {
                    if (intval($arUser["UF_DEPARTMENT"][0]) > 0)
                    {
                        $bExtranetUser = false;
                    }
                }
            }
 
            $user_site_id = ($bExtranetUser ? $extranet_site_id : $intranet_site_id);
 
            $url = (in_array($arComment["ENTITY_TYPE"], ["CRMLEAD", "CRMCONTACT", "CRMCOMPANY", "CRMDEAL", "CRMACTIVITY"]) ? $arSites[$user_site_id]["DIR"]."crm/stream?log_id=#log_id#" : COption::GetOptionString("socialnetwork", "log_entry_page", $arSites[$user_site_id]["DIR"]."company/personal/log/#log_id#/", $user_site_id));
            $url = str_replace("#log_id#", $arComment["LOG_ID"], $url);
            $url .= (mb_strpos($url, "?") !== false ? "&" : "?")."commentId=".$arComment["ID"]."#com".$arComment["ID"];
            $url = (CMain::IsHTTPS() ? "https" : "http")."://".$arSites[$user_site_id]['SERVER_NAME'].$url;
        }
        else
        {
            $url = (in_array($arComment["ENTITY_TYPE"], ["CRMLEAD", "CRMCONTACT", "CRMCOMPANY", "CRMDEAL", "CRMACTIVITY"]) ? SITE_DIR."crm/stream?log_id=#log_id#" : COption::GetOptionString("socialnetwork", "log_entry_page", SITE_DIR."company/personal/log/#log_id#/", SITE_ID));
            $url = str_replace("#log_id#", $arComment["LOG_ID"], $url);
            $url .= (mb_strpos($url, "?") !== false ? "&" : "?")."commentId=".$arComment["ID"]."#com".$arComment["ID"];
 
            $SiteServerName = (defined('SITE_SERVER_NAME') && SITE_SERVER_NAME <> '' ? SITE_SERVER_NAME : COption::GetOptionString("main", "server_name", $_SERVER['SERVER_NAME']));
            if ($SiteServerName <> '')
            {
                $url = (CMain::IsHTTPS() ? "https" : "http")."://".$SiteServerName.$url;
            }
        }
 
        return $url;
    }
 
    public static function OnAfterUserAdd($arParams)
    {
        return true;
    }
 
    public static function OnAfterUserUpdate($arParams)
    {
        $chat = new CIMChat(0);
        $user = IM\V2\Entity\User\User::getInstance((int)$arParams["ID"]);
        IM\V2\Entity\User\UserFactory::getInstance()->clearCache((int)$arParams["ID"]);
 
        IM\V2\Message\CounterService::onAfterUserUpdate($arParams);
        IM\V2\Chat\User\OwnerService::onAfterUserUpdate($arParams);
 
        $commonChatId = CIMChat::GetGeneralChatId();
        if ($commonChatId > 0 && (isset($arParams['ACTIVE']) || isset($arParams['UF_DEPARTMENT'])))
        {
            if ($arParams['ACTIVE'] == 'N')
            {
                //CIMMessage::SetReadMessageAll($arParams['ID']);
 
                if ($commonChatId && CIMChat::GetRelationById($commonChatId, $arParams["ID"], true, false))
                {
                    $chat->DeleteUser($commonChatId, $arParams["ID"], false);
                }
            }
            else
            {
                $commonChatId = CIMChat::GetGeneralChatId();
                if ($commonChatId)
                {
                    if ($user->isBot())
                    {
                        return true;
                    }
 
                    if ($arParams['ACTIVE'] != 'Y' && !$user->isActive())
                    {
                        return true;
                    }
 
                    $userInChat = CIMChat::GetRelationById($commonChatId, $arParams["ID"], true, false);
                    $userCanJoin = CIMChat::CanJoinGeneralChatId($arParams["ID"]);
 
                    if ($userInChat && !$userCanJoin)
                    {
                        $chat->DeleteUser($commonChatId, $arParams["ID"], false);
                    }
                    else if (!$userInChat && $userCanJoin)
                    {
                        $chat->AddUser($commonChatId, [$arParams["ID"]], false, true, true);
                    }
                }
            }
        }
 
        if (isset($arParams['ACTIVE']))
        {
            self::updateChatUserCounter($arParams["ID"]);
        }
    }
 
    private static function updateChatUserCounter($userId): void
    {
        global $DB;
        $sql = "
            UPDATE b_im_chat C
            INNER JOIN b_im_relation R ON C.ID = R.CHAT_ID
            SET C.USER_COUNT = (
                SELECT COUNT(1)
                FROM b_im_relation R1
                INNER JOIN b_user U ON R1.USER_ID = U.ID
                WHERE R1.CHAT_ID = C.ID AND U.ACTIVE = 'Y'
            )
            WHERE R.MESSAGE_TYPE NOT IN ('".IM_MESSAGE_SYSTEM."','".IM_MESSAGE_PRIVATE."')
            AND R.USER_ID = ".$userId."
        ";
        $DB->Query($sql, true);
    }
 
    public static function OnUserDelete($ID)
    {
        $ID = intval($ID);
        if ($ID <= 0)
        {
            return false;
        }
 
        global $DB;
 
        $isRecentExists = \Bitrix\Im\Model\RecentTable::getList([
            'filter' => [
                '=ITEM_TYPE' => IM_MESSAGE_PRIVATE,
                '=ITEM_ID' => $ID,
            ]
        ])->fetch();
 
        $arChat = [];
        $strSQL = "
            SELECT R.CHAT_ID
            FROM b_im_chat C, b_im_relation R
            WHERE R.USER_ID = ".$ID." and R.MESSAGE_TYPE IN ('".IM_MESSAGE_PRIVATE."', '".IM_MESSAGE_SYSTEM."') and R.CHAT_ID = C.ID
        ";
        $dbRes = $DB->Query($strSQL, true);
        while ($arRes = $dbRes->Fetch())
        {
            $arChat[$arRes['CHAT_ID']] = $arRes['CHAT_ID'];
        }
 
        $accessProvider = new \Bitrix\Im\Access\ChatAuthProvider;
        $accessProvider->deleteByUser($ID);
 
        if (count($arChat) > 0)
        {
            $strSQL = "DELETE FROM b_im_chat WHERE ID IN (".implode(',', $arChat).")";
            $DB->Query($strSQL, true);
 
            $strSQL = "DELETE FROM b_im_message WHERE CHAT_ID IN (".implode(',', $arChat).")";
            $DB->Query($strSQL, true);
 
            $strSQL = "DELETE FROM b_im_relation WHERE CHAT_ID IN (".implode(',', $arChat).")";
            $DB->Query($strSQL, true);
 
            IM\V2\Link\Url\UrlCollection::deleteByChatsIds($arChat);
            foreach ($arChat as $id)
            {
                IM\V2\Chat::cleanCache((int)$id);
            }
        }
        else
        {
            $strSQL = "DELETE FROM b_im_message WHERE AUTHOR_ID = ".$ID;
            $DB->Query($strSQL, true);
 
            $strSQL = "DELETE FROM b_im_relation WHERE USER_ID =".$ID;
            $DB->Query($strSQL, true);
 
            IM\V2\Link\Url\UrlCollection::deleteByAuthorsIds([$ID]);
        }
 
        \Bitrix\Im\Bot::unRegister(['BOT_ID' => $ID]);
 
        $strSQL = "DELETE FROM b_im_recent WHERE USER_ID = ".$ID;
        $DB->Query($strSQL, true);
 
        $strSQL = "DELETE FROM b_im_recent WHERE ITEM_TYPE = '".IM_MESSAGE_PRIVATE."' AND ITEM_ID = ".$ID;
        $DB->Query($strSQL, true);
 
        $strSQL = "DELETE FROM b_im_status WHERE USER_ID = ".$ID;
        $DB->Query($strSQL, true);
 
        $strSQL = "DELETE FROM b_im_recent WHERE ITEM_TYPE = '".IM_MESSAGE_PRIVATE."' and ITEM_ID = ".$ID;
        $DB->Query($strSQL, true);
 
        if ($isRecentExists && CModule::IncludeModule('pull'))
        {
            $users = \Bitrix\Im\Helper::getOnlineIntranetUsers();
 
            \Bitrix\Pull\Event::add($users, [
                'module_id' => 'im',
                'command' => 'chatHide',
                'expiry' => 3600,
                'params' => [
                    'dialogId' => $ID,
                    'chatId' => null,
                    'lines' => false,
                ],
                'extra' => \Bitrix\Im\Common::getPullExtra()
            ]);
        }
 
        return true;
    }
 
    public static function OnGetDependentModule()
    {
        return [
            'MODULE_ID' => "im",
            'USE' => ["PUBLIC_SECTION"]
        ];
    }
}
 
class DesktopApplication extends Bitrix\Main\Authentication\Application
{
    protected $validUrls = [
        "/",
    ];
 
    public static function OnApplicationsBuildList()
    {
        return [
            "ID" => "desktop",
            "NAME" => GetMessage('DESKTOP_APPLICATION_NAME'),
            "DESCRIPTION" => GetMessage("DESKTOP_APPLICATION_DESC"),
            "SORT" => 80,
            "CLASS" => "DesktopApplication",
        ];
    }
}
?>