IncludeModuleLangFile(__FILE__);
use Bitrix\Im as IM;
use Bitrix\Main\Loader;
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' => '']);
}
}
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();
/** @var bool|object $handler */
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\]/is".BX_UTF_PCRE_MODIFIER, $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)+.*/is'.BX_UTF_PCRE_MODIFIER,'\\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" => self::GetMessageRatingVote($arParams),
"NOTIFY_MESSAGE_OUT" => self::GetMessageRatingVote($arParams, true)
];
$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" => self::GetMessageRatingVote($arParams),
"NOTIFY_MESSAGE_OUT" => self::GetMessageRatingVote($arParams, true)
];
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)
{
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"], GetMessage('IM_EVENT_RATING_BLOG_POST'.($arParams['MENTION'] ? '_MENTION' : '').$like));
}
elseif ($arParams['ENTITY_TYPE_ID'] == 'BLOG_COMMENT')
{
$message = str_replace(['#TITLE#', '#A_START#', '#A_END#'], [$arParams["ENTITY_MESSAGE"], '', ''], GetMessage('IM_EVENT_RATING_COMMENT'.($arParams['MENTION'] ? '_MENTION' : '').$like));
}
elseif ($arParams['ENTITY_TYPE_ID'] == 'FORUM_TOPIC')
{
$message = str_replace('#LINK#', $arParams["ENTITY_TITLE"], GetMessage('IM_EVENT_RATING_FORUM_TOPIC'.$like));
}
elseif ($arParams['ENTITY_TYPE_ID'] == 'FORUM_POST')
{
$message = str_replace(['#TITLE#', '#A_START#', '#A_END#'], [$arParams["ENTITY_MESSAGE"], '', ''], GetMessage('IM_EVENT_RATING_COMMENT'.($arParams['MENTION'] ? '_MENTION' : '').$like));
}
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"], '', ''], GetMessage('IM_EVENT_RATING_PHOTO_ALBUM'.$like));
}
elseif (is_numeric($arParams["ENTITY_TITLE"]))
{
$message = str_replace(['#A_START#', '#A_END#'], ['', ''], GetMessage('IM_EVENT_RATING_PHOTO_ALBUM1'.$like));
}
else
{
$message = str_replace(['#TITLE#', '#A_START#', '#A_END#'], [$arParams["ENTITY_TITLE"], '', ''], GetMessage('IM_EVENT_RATING_PHOTO_ALBUM'.$like));
}
}
elseif (
$arParams['ENTITY_TYPE_ID'] == 'IBLOCK_ELEMENT'
&& $arParams['ENTITY_PARAM'] == 'library'
)
{
$message = str_replace(['#TITLE#', '#A_START#', '#A_END#'], [$arParams["ENTITY_TITLE"], '', ''], GetMessage('IM_EVENT_RATING_FILE'.$like));
}
elseif (
$arParams['ENTITY_TYPE_ID'] == 'IBLOCK_ELEMENT'
&& $arParams['ENTITY_PARAM'] == 'wiki'
)
{
$message = str_replace(['#TITLE#', '#A_START#', '#A_END#'], [$arParams["ENTITY_TITLE"], '', ''], GetMessage('IM_EVENT_RATING_WIKI'.$like));
}
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"], '', ''], GetMessage('IM_EVENT_RATING_PHOTO'.$like));
}
elseif (is_numeric($arParams["ENTITY_TITLE"]))
{
$message = str_replace(['#A_START#', '#A_END#'], ['', ''], GetMessage('IM_EVENT_RATING_PHOTO1'.$like));
}
else
{
$message = str_replace(['#TITLE#', '#A_START#', '#A_END#'], [$arParams["ENTITY_TITLE"], '', ''], GetMessage('IM_EVENT_RATING_PHOTO'.$like));
}
}
elseif ($arParams['ENTITY_TYPE_ID'] == 'LOG_COMMENT')
{
$message = str_replace(['#TITLE#', '#A_START#', '#A_END#'], [$arParams["ENTITY_TITLE"], '', ''], GetMessage('IM_EVENT_RATING_COMMENT'.($arParams['MENTION'] ? '_MENTION' : '').$like));
}
elseif ($arParams['ENTITY_TYPE_ID'] == 'LISTS_NEW_ELEMENT')
{
$message = str_replace(
[
'#TITLE#',
'#A_START#',
'#A_END#'
],
[
$arParams["ENTITY_TITLE"],
'',
''
],
GetMessage('IM_EVENT_RATING_LISTS_NEW_ELEMENT_LIKE'.$like)
);
}
else
{
$message = str_replace('#LINK#', $arParams["ENTITY_TITLE"], GetMessage('IM_EVENT_RATING_ELSE'.$like));
}
if ($arParams['ENTITY_LINK'] <> '')
{
$message .= ' ('.$arParams['ENTITY_LINK'].')';
}
}
else
{
if ($arParams['ENTITY_TYPE_ID'] == 'BLOG_POST')
{
$message = str_replace('#LINK#', ''.$arParams["ENTITY_TITLE"].'', GetMessage('IM_EVENT_RATING_BLOG_POST'.($arParams['MENTION'] ? '_MENTION' : '').$like));
}
elseif ($arParams['ENTITY_TYPE_ID'] == 'BLOG_COMMENT')
{
$message = str_replace(['#TITLE#', '#A_START#', '#A_END#'], [$arParams["ENTITY_MESSAGE"], '', ''], GetMessage('IM_EVENT_RATING_COMMENT'.($arParams['MENTION'] ? '_MENTION' : '').$like));
}
elseif ($arParams['ENTITY_TYPE_ID'] == 'FORUM_TOPIC')
{
$message = str_replace('#LINK#', ''.$arParams["ENTITY_TITLE"].'', GetMessage('IM_EVENT_RATING_FORUM_TOPIC'.$like));
}
elseif ($arParams['ENTITY_TYPE_ID'] == 'FORUM_POST')
{
$message = str_replace(['#TITLE#', '#A_START#', '#A_END#'], [$arParams["ENTITY_MESSAGE"], '', ''], GetMessage('IM_EVENT_RATING_COMMENT'.($arParams['MENTION'] ? '_MENTION' : '').$like));
}
elseif (
$arParams['ENTITY_TYPE_ID'] == 'IBLOCK_ELEMENT'
&& $arParams['ENTITY_PARAM'] == 'library'
)
{
$message = str_replace(['#TITLE#', '#A_START#', '#A_END#'], [$arParams["ENTITY_TITLE"], '', ''], GetMessage('IM_EVENT_RATING_FILE'.$like));
}
elseif (
$arParams['ENTITY_TYPE_ID'] == 'IBLOCK_ELEMENT'
&& $arParams['ENTITY_PARAM'] == 'wiki'
)
{
$message = str_replace(['#TITLE#', '#A_START#', '#A_END#'], [$arParams["ENTITY_TITLE"], '', ''], GetMessage('IM_EVENT_RATING_WIKI'.$like));
}
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"], '', ''], GetMessage('IM_EVENT_RATING_PHOTO_ALBUM'.$like));
}
elseif (is_numeric($arParams["ENTITY_TITLE"]))
{
$message = str_replace(['#A_START#', '#A_END#'], ['', ''], GetMessage('IM_EVENT_RATING_PHOTO_ALBUM1'.$like));
}
else
{
$message = str_replace(['#TITLE#', '#A_START#', '#A_END#'], [$arParams["ENTITY_TITLE"], '', ''], GetMessage('IM_EVENT_RATING_PHOTO_ALBUM'.$like));
}
}
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"], '', ''], GetMessage('IM_EVENT_RATING_PHOTO'.$like));
}
elseif (is_numeric($arParams["ENTITY_TITLE"]))
{
$message = str_replace(['#A_START#', '#A_END#'], ['', ''], GetMessage('IM_EVENT_RATING_PHOTO1'.$like));
}
else
{
$message = str_replace(['#TITLE#', '#A_START#', '#A_END#'], [$arParams["ENTITY_TITLE"], '', ''], GetMessage('IM_EVENT_RATING_PHOTO'.$like));
}
}
elseif ($arParams['ENTITY_TYPE_ID'] == 'LOG_COMMENT')
{
$message = str_replace(['#TITLE#', '#A_START#', '#A_END#'], [$arParams["ENTITY_TITLE"], '', ''], GetMessage('IM_EVENT_RATING_COMMENT'.($arParams['MENTION'] ? '_MENTION' : '').$like));
}
elseif ($arParams['ENTITY_TYPE_ID'] == 'LISTS_NEW_ELEMENT')
{
$message = str_replace(
[
'#TITLE#',
'#A_START#',
'#A_END#'
],
[
$arParams["ENTITY_TITLE"],
'',
''
],
GetMessage('IM_EVENT_RATING_LISTS_NEW_ELEMENT'.$like)
);
}
else
{
$message = str_replace('#LINK#', $arParams['ENTITY_LINK'] <> ''?''.$arParams["ENTITY_TITLE"].'': ''.$arParams["ENTITY_TITLE"].'', GetMessage('IM_EVENT_RATING_ELSE'.$like));
}
if ($intranetInstalled)
{
$message .= "\n".str_replace("#REACTION#", \CRatingsComponentsMain::getRatingLikeMessage(!empty($arParams['REACTION']) ? $arParams['REACTION'] : ''), Bitrix\Main\Localization\Loc::getMessage("IM_EVENT_RATING_REACTION"));
}
}
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)
{
if(($arParams["ID"] ?? 0) <= 0)
{
return false;
}
if ($arParams['ACTIVE'] == 'N')
{
return false;
}
if (IsModuleInstalled('intranet') && !CIMContactList::IsExtranet($arParams))
{
$commonChatId = CIMChat::GetGeneralChatId();
if ($commonChatId <= 0)
{
return true;
}
if (\Bitrix\Im\User::getInstance($arParams["ID"])->isBot())
{
return true;
}
if (!CIMChat::CanJoinGeneralChatId($arParams["ID"]))
{
return true;
}
$CIMChat = new CIMChat(0);
$CIMChat->AddUser($commonChatId, [$arParams["ID"]], null, true);
}
return true;
}
public static function OnAfterUserUpdate($arParams)
{
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))
{
$CIMChat = new CIMChat($arParams["ID"]);
$CIMChat->DeleteUser($commonChatId, $arParams["ID"]);
}
}
else
{
$commonChatId = CIMChat::GetGeneralChatId();
if ($commonChatId)
{
if (\Bitrix\Im\User::getInstance($arParams["ID"])->isBot())
{
return true;
}
if ($arParams['ACTIVE'] != 'Y' && !\Bitrix\Im\User::getInstance($arParams["ID"])->isActive())
{
return true;
}
$userInChat = CIMChat::GetRelationById($commonChatId, $arParams["ID"], true, false);
$userCanJoin = CIMChat::CanJoinGeneralChatId($arParams["ID"]);
if ($userInChat && !$userCanJoin)
{
$CIMChat = new CIMChat($arParams["ID"]);
$CIMChat->DeleteUser($commonChatId, $arParams["ID"]);
}
else if (!$userInChat && $userCanJoin)
{
$CIMChat = new CIMChat(0);
$CIMChat->AddUser($commonChatId, [$arParams["ID"]], null, 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, "File: ".__FILE__."
Line: ".__LINE__);
}
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, "File: ".__FILE__."
Line: ".__LINE__);
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, "File: ".__FILE__."
Line: ".__LINE__);
$strSQL = "DELETE FROM b_im_message WHERE CHAT_ID IN (".implode(',', $arChat).")";
$DB->Query($strSQL, true, "File: ".__FILE__."
Line: ".__LINE__);
$strSQL = "DELETE FROM b_im_relation WHERE CHAT_ID IN (".implode(',', $arChat).")";
$DB->Query($strSQL, true, "File: ".__FILE__."
Line: ".__LINE__);
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, "File: ".__FILE__."
Line: ".__LINE__);
$strSQL = "DELETE FROM b_im_relation WHERE USER_ID =".$ID;
$DB->Query($strSQL, true, "File: ".__FILE__."
Line: ".__LINE__);
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, "File: ".__FILE__."
Line: ".__LINE__);
$strSQL = "DELETE FROM b_im_recent WHERE ITEM_TYPE = '".IM_MESSAGE_PRIVATE."' AND ITEM_ID = ".$ID;
$DB->Query($strSQL, true, "File: ".__FILE__."
Line: ".__LINE__);
$strSQL = "DELETE FROM b_im_status WHERE USER_ID = ".$ID;
$DB->Query($strSQL, true, "File: ".__FILE__."
Line: ".__LINE__);
$strSQL = "DELETE FROM b_im_recent WHERE ITEM_TYPE = '".IM_MESSAGE_PRIVATE."' and ITEM_ID = ".$ID;
$DB->Query($strSQL, true, "File: ".__FILE__."
Line: ".__LINE__);
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
],
'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",
];
}
}
?>