| Server IP : 80.87.202.40 / Your IP : 216.73.216.169 Web Server : Apache System : Linux rospirotorg.ru 5.14.0-539.el9.x86_64 #1 SMP PREEMPT_DYNAMIC Thu Dec 5 22:26:13 UTC 2024 x86_64 User : bitrix ( 600) PHP Version : 8.2.27 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /home/bitrix/ext_www/rospirotorg.ru/bitrix/modules/im/classes/general/ |
Upload File : |
<?
IncludeModuleLangFile(__FILE__);
use Bitrix\Im as IM;
use Bitrix\Im\V2\Chat;
use Bitrix\Im\V2\Sync;
use Bitrix\Main\Engine\Response\Converter;
class CAllIMContactList
{
private $user_id = 0;
const NETWORK_AUTH_ID = 'replica';
function __construct($user_id = false)
{
global $USER;
$user_id = intval($user_id);
if ($user_id == 0)
$user_id = intval($USER->GetID());
$this->user_id = $user_id;
}
private function getDepartments(): array
{
if (CModule::IncludeModule('extranet') && !CExtranet::IsIntranetUser())
{
return [];
}
$departments = [];
$departmentService = IM\V2\Integration\HumanResources\Department\Department::getInstance();
foreach ($departmentService->getList() as $department)
{
$departmentName = $department->name;
if (
$department->depthLevel > 0
&& isset($departments[$department->parent]['name'])
)
{
$departmentName .= ' / ' . $departments[$department->parent]['name'];
}
$departments[$department->id] = [
'id' => $department->id,
'name' => $departmentName,
];
}
return $departments;
}
function GetList($arParams = Array())
{
global $USER, $CACHE_MANAGER;
$bLoadUsers = isset($arParams['LOAD_USERS']) && $arParams['LOAD_USERS'] == 'N'? false: true;
$bLoadChats = isset($arParams['LOAD_CHATS']) && $arParams['LOAD_CHATS'] == 'N'? false: true;
$arGroups = [];
if(defined("BX_COMP_MANAGED_CACHE"))
$ttl = 2592000;
else
$ttl = 600;
$bBusShowAll = !IsModuleInstalled('intranet') && COption::GetOptionInt('im', 'contact_list_show_all_bus');
$bIntranetEnable = false;
if(CModule::IncludeModule('intranet'))
{
$bIntranetEnable = true;
$arGroups = $this->getDepartments();
}
$arUserSG = array();
$arUsers = array();
$arUserInGroup = array();
$arExtranetUsers = array();
$groups = \Bitrix\Im\Integration\Socialnetwork\Extranet::getGroup(Array(), $this->user_id);
if (is_array($groups))
{
foreach ($groups as $groupId => $group)
{
$arUserInGroup[$groupId] = Array('id' => $groupId, 'users' => $group['USERS']);
foreach ($group['USERS'] as $groupUserId)
{
$arExtranetUsers[$groupUserId] = $groupUserId;
}
$arUserSG[$groupId] = array(
'id' => $groupId,
'status' => 'open',
'name' => $group['NAME']
);
$arGroups[$groupId] = $arUserSG[$groupId];
}
}
$bFriendEnable = false;
if ((!CModule::IncludeModule('extranet') || !CExtranet::IsExtranetSite()) && CModule::IncludeModule('socialnetwork') && CSocNetUser::IsFriendsAllowed())
{
$bFriendEnable = true;
$dbFriends = CSocNetUserRelations::GetList(array(),array("USER_ID" => $USER->GetID(), "RELATION" => SONET_RELATIONS_FRIEND), false, false, array("ID", "FIRST_USER_ID", "SECOND_USER_ID", "DATE_CREATE", "DATE_UPDATE", "INITIATED_BY"));
if ($dbFriends)
{
while ($arFriends = $dbFriends->GetNext(true, false))
{
$friendId = $pref = (intval($USER->GetID()) == $arFriends["FIRST_USER_ID"]) ? $arFriends["SECOND_USER_ID"] : $arFriends["FIRST_USER_ID"];
$arFriendUsers[$friendId] = $friendId;
/*
if (isset($arUserInGroup["friends"]))
$arUserInGroup["friends"]['users'][] = $friendId;
else
$arUserInGroup["friends"] = Array('id' => "friends", 'users' => Array($friendId));
*/
}
}
/*
$arGroups['friends'] = array(
'id' => 'friends',
'status' => (isset($arGroupStatus['friends']) && $arGroupStatus['friends'] == 'close'? 'close': 'open'),
'name' => GetMessage('IM_CL_GROUP_FRIENDS')
);
*/
}
$filter = array(
'=ACTIVE' => 'Y',
'=CONFIRM_CODE' => false,
'!=EXTERNAL_AUTH_ID' => \Bitrix\Im\Model\UserTable::filterExternalUserTypes([\Bitrix\Im\Bot::EXTERNAL_AUTH_ID])
);
if (CModule::IncludeModule('extranet'))
{
if(!CExtranet::IsIntranetUser())
{
$filter['=ID'] = array_merge(Array($USER->GetId()), $arExtranetUsers);
}
}
if ($bLoadUsers)
{
if ($bFriendEnable)
{
if (!$bIntranetEnable && !$bBusShowAll)
{
$filter['=ID'][] = $USER->GetId();
if (!empty($arFriendUsers))
{
$filter['=ID'] = array_merge($filter['=ID'], $arFriendUsers);
}
if (!empty($arExtranetUsers))
{
$filter['=ID'] = array_merge($filter['=ID'], $arExtranetUsers);
}
}
}
$bCLCacheEnable = false;
if ($bIntranetEnable && (!$bFriendEnable || $bBusShowAll))
$bCLCacheEnable = true;
if ($bCLCacheEnable && CModule::IncludeModule('extranet') && !CExtranet::IsIntranetUser())
$bCLCacheEnable = false;
$bVoximplantEnable = CModule::IncludeModule('voximplant');
$bColorEnabled = IM\Color::isEnabled();
$bOpenChatEnabled = CIMMessenger::CheckEnableOpenChat();
$nameTemplate = self::GetUserNameTemplate(SITE_ID);
$nameTemplateSite = CSite::GetNameFormat(false);
$cache_id = 'im_contact_list_v29_'.$nameTemplate.'_'.$nameTemplateSite.(!empty($arExtranetUsers)? '_'.$USER->GetID(): '').$bVoximplantEnable.$bColorEnabled.$bOpenChatEnabled;
$obCLCache = new CPHPCache;
$cache_dir = '/bx/imc/contact';
$arUsersToGroup = array();
$arUserInGroupStructure = array();
$arPhones = Array();
if($bCLCacheEnable && $obCLCache->InitCache($ttl, $cache_id, $cache_dir))
{
$tmpVal = $obCLCache->GetVars();
$arUsers = $tmpVal['USERS'];
$arPhones = $tmpVal['PHONES'];
$arUsersToGroup = $tmpVal['USER_TO_GROUP'];
$arUserInGroupStructure = $tmpVal['USER_IN_GROUP'];
unset($tmpVal);
$arOnline = CIMStatus::GetList();
foreach ($arUsers as $userId => $value)
{
/*$arUsers[$userId]['status'] = isset($arOnline['users'][$userId])? $arOnline['users'][$userId]['status']: 'offline';
$arUsers[$userId]['idle'] = isset($arOnline['users'][$userId])? $arOnline['users'][$userId]['idle']: false;
$arUsers[$userId]['mobile_last_date'] = isset($arOnline['users'][$userId])? $arOnline['users'][$userId]['mobile_last_date']: false;
$arUsers[$userId]['desktop_last_date'] = $arOnline['users'][$userId]['desktop_last_date'] ?? false;*/
$arUsers[$userId]['status'] = 'online';
$arUsers[$userId]['idle'] = false;
$arUsers[$userId]['mobile_last_date'] = false;
$arUsers[$userId]['desktop_last_date'] = false;
$arUsers[$userId]['last_activity_date'] = isset($arOnline['users'][$userId])? $arOnline['users'][$userId]['last_activity_date']: false;
$arUsers[$userId]['absent'] = self::formatAbsentResult($userId);
if (isset($arOnline['users'][$userId]['color']) && $arOnline['users'][$userId]['color'])
{
$arUsers[$userId]['color'] = $arOnline['users'][$userId]['color'];
}
}
}
else
{
$select = array(
"ID", "LAST_NAME", "NAME", "LOGIN", "PERSONAL_PHOTO", "SECOND_NAME", "PERSONAL_BIRTHDAY", "WORK_POSITION", "PERSONAL_GENDER", "EXTERNAL_AUTH_ID", "WORK_PHONE", "PERSONAL_PHONE", "PERSONAL_MOBILE", "TIME_ZONE_OFFSET", "ACTIVE", "LAST_ACTIVITY_DATE",
"COLOR" => "ST.COLOR", "STATUS" => "ST.STATUS", "IDLE" => "ST.IDLE", "MOBILE_LAST_DATE" => "ST.MOBILE_LAST_DATE", "DESKTOP_LAST_DATE" => "ST.DESKTOP_LAST_DATE",
);
if($bIntranetEnable)
{
$select[] = 'UF_ZOOM';
$select[] = 'UF_SKYPE';
$select[] = 'UF_SKYPE_LINK';
$select[] = 'UF_PHONE_INNER';
$select[] = 'UF_DEPARTMENT';
}
if ($bVoximplantEnable)
{
$select[] = 'UF_VI_PHONE';
}
$orm = \Bitrix\Main\UserTable::getList(Array(
'select' => $select,
'filter' => $filter,
'runtime' => Array(
new \Bitrix\Main\Entity\ReferenceField(
'ST',
'\Bitrix\Im\Model\StatusTable',
array(
"=ref.USER_ID" => "this.ID",
),
array("join_type"=>"LEFT")
)
),
'order' => Array('LAST_NAME' => 'ASC')
));
$bots = \Bitrix\Im\Bot::getListCache();
while ($arUser = $orm->fetch())
{
$arUser = CIMStatus::prepareLastDate($arUser);
$skipUser = false;
if(is_array($arUser["UF_DEPARTMENT"]) && !empty($arUser["UF_DEPARTMENT"]))
{
foreach($arUser["UF_DEPARTMENT"] as $dep_id)
{
if (isset($arUserInGroupStructure[$dep_id]))
$arUserInGroupStructure[$dep_id]['users'][] = $arUser["ID"];
else
$arUserInGroupStructure[$dep_id] = Array('id' => $dep_id, 'users' => Array($arUser["ID"]));
}
}
/*
else if ($bBusShowAll)
{
$skipUser = false;
if (isset($arUserInGroup['all']))
$arUserInGroup['all']['users'][] = $arUser["ID"];
else
$arUserInGroup['all'] = Array('id' => 'all', 'users' => Array($arUser["ID"]));
}*/
else
{
$skipUser = true;
if ($arUser['EXTERNAL_AUTH_ID'] == \Bitrix\Im\Bot::EXTERNAL_AUTH_ID)
$skipUser = false;
else if (isset($arExtranetUsers[$arUser["ID"]]))
$skipUser = false;
elseif (isset($arFriendUsers[$arUser["ID"]]))
$skipUser = false;
elseif ($arUser["ID"] == $USER->GetID())
$skipUser = false;
}
if (!$skipUser)
{
foreach ($arUser as $key => $value)
{
$arUser[$key] = !is_array($value) && !is_object($value)? htmlspecialcharsEx($value): $value;
}
$color = self::GetUserColor($arUser["ID"], $arUser['PERSONAL_GENDER'] == 'M'? 'M': 'F');
if (isset($arUser['COLOR']) && $arUser['COLOR'] <> '')
{
$color = IM\Color::getColor($arUser['COLOR']);
}
if (!$color)
{
$color = self::GetUserColor($arUser["ID"], $arUser['PERSONAL_GENDER'] == 'M'? 'M': 'F');
}
$arUsersToGroup[$arUser['ID']] = $arUser["UF_DEPARTMENT"];
$arUser['PERSONAL_BIRTHDAY'] = $arUser['PERSONAL_BIRTHDAY'] instanceof \Bitrix\Main\Type\Date? $arUser['PERSONAL_BIRTHDAY']->format('d-m'): false;
$arUser['LAST_ACTIVITY_DATE'] = $arUser['LAST_ACTIVITY_DATE'] instanceof \Bitrix\Main\Type\DateTime? $arUser['LAST_ACTIVITY_DATE']: false;
$userExternalAuthId = $arUser['EXTERNAL_AUTH_ID'] ?? 'default';
$userItemId = $arUser["ITEM_ID"] ?? null;
$userById = $arUser["ID"] ?? null;
$botByUserItemId = $bots[$userItemId] ?? null;
$botByUserId = $bots[$userById] ?? null;
$botClassName = $botByUserItemId['CLASS'] ?? null;
$botType = $botByUserId['TYPE'] ?? null;
if (
$userExternalAuthId == \Bitrix\Im\Bot::EXTERNAL_AUTH_ID
&& $botType == \Bitrix\Im\Bot::TYPE_NETWORK
&& (
$botClassName === \Bitrix\ImBot\Bot\Support24::class
|| $botClassName === \Bitrix\ImBot\Bot\Partner24::class
|| $botClassName === \Bitrix\ImBot\Bot\SaleSupport24::class
)
)
{
$userExternalAuthId = 'support24';
}
$arUsers[$arUser["ID"]] = Array(
'id' => $arUser["ID"],
'name' => \Bitrix\Im\User::formatFullNameFromDatabase($arUser),
'active' => $arUser['ACTIVE'] == 'Y',
'first_name' => \Bitrix\Im\User::formatNameFromDatabase($arUser),
'last_name' => $arUser['LAST_NAME'],
'work_position' => $arUser['WORK_POSITION'],
'color' => $color,
'avatar' => CIMChat::GetAvatarImage($arUser["PERSONAL_PHOTO"]),
'birthday' => $arUser['PERSONAL_BIRTHDAY'],
'gender' => $arUser['PERSONAL_GENDER'] == 'F'? 'F': 'M',
'phone_device' => $bVoximplantEnable && $arUser['UF_VI_PHONE'] == 'Y',
'extranet' => self::IsExtranet($arUser),
'tz_offset' => intval($arUser['TIME_ZONE_OFFSET']),
'network' => ($userExternalAuthId === self::NETWORK_AUTH_ID) || ($userExternalAuthId === \Bitrix\Im\Bot::EXTERNAL_AUTH_ID) && ($botType === \Bitrix\Im\Bot::TYPE_NETWORK),
'bot' => $userExternalAuthId === \Bitrix\Im\Bot::EXTERNAL_AUTH_ID,
'profile' => CIMContactList::GetUserPath($arUser["ID"]),
'external_auth_id' => $userExternalAuthId,
/*'status' => $arUser['STATUS'],
'idle' => $arUser['IDLE'],*/
'status' => 'online',
'idle' => false,
'last_activity_date' => $arUser['LAST_ACTIVITY_DATE'],
/*'mobile_last_date' => $arUser['MOBILE_LAST_DATE'],
'desktop_last_date' => $arUser['DESKTOP_LAST_DATE'],*/
'mobile_last_date' => false,
'desktop_last_date' => false,
'absent' => self::formatAbsentResult($arUser["ID"]),
);
$services = [];
if (!empty($arUser['UF_ZOOM']))
{
$services['zoom'] = $arUser['UF_ZOOM'];
}
if (!empty($arUser['UF_SKYPE_LINK']))
{
$services['skype'] = $arUser['UF_SKYPE_LINK'];
}
else if (!empty($arUser['UF_SKYPE']))
{
$services['skype'] = 'skype://'.$arUser['UF_SKYPE'];
}
$arUsers[$arUser["ID"]]['services'] = empty($services)? null: array_change_key_case($services, CASE_LOWER);
if ($bVoximplantEnable)
{
$result = CVoxImplantPhone::Normalize($arUser["WORK_PHONE"]);
if ($result)
{
$arPhones[$arUser["ID"]]['WORK_PHONE'] = $arUser['WORK_PHONE'];
}
$result = CVoxImplantPhone::Normalize($arUser["PERSONAL_MOBILE"]);
if ($result)
{
$arPhones[$arUser["ID"]]['PERSONAL_MOBILE'] = $arUser['PERSONAL_MOBILE'];
}
$result = CVoxImplantPhone::Normalize($arUser["PERSONAL_PHONE"]);
if ($result)
{
$arPhones[$arUser["ID"]]['PERSONAL_PHONE'] = $arUser['PERSONAL_PHONE'];
}
$result = preg_replace("/[^0-9\#\*]/i", "", $arUser["UF_PHONE_INNER"]);
if ($result)
{
$arPhones[$arUser["ID"]]['INNER_PHONE'] = $result;
}
}
else
{
$arPhones[$arUser["ID"]]['WORK_PHONE'] = $arUser['WORK_PHONE'];
$arPhones[$arUser["ID"]]['PERSONAL_MOBILE'] = $arUser['PERSONAL_MOBILE'];
$arPhones[$arUser["ID"]]['PERSONAL_PHONE'] = $arUser['PERSONAL_PHONE'];
$arPhones[$arUser["ID"]]['INNER_PHONE'] = $arUser['UF_PHONE_INNER'];
}
}
}
if ($bCLCacheEnable)
{
if(defined("BX_COMP_MANAGED_CACHE"))
{
$CACHE_MANAGER->StartTagCache($cache_dir);
$CACHE_MANAGER->RegisterTag("IM_CONTACT_LIST");
$CACHE_MANAGER->RegisterTag($bVoximplantEnable? "USER_CARD": "USER_NAME");
$CACHE_MANAGER->EndTagCache();
}
if($obCLCache->StartDataCache())
{
$obCLCache->EndDataCache(array(
'USERS' => $arUsers,
'USER_TO_GROUP' => $arUsersToGroup,
'USER_IN_GROUP' => $arUserInGroupStructure,
'PHONES' => $arPhones
)
);
}
}
}
if (is_array($arUsersToGroup[$USER->GetID()]))
{
foreach($arUsersToGroup[$USER->GetID()] as $dep_id)
{
if (isset($arGroups[$dep_id]))
{
$arGroups[$dep_id]['status'] = 'open';
}
}
}
foreach ($arUserInGroupStructure as $key => $val)
{
$arUserInGroup[$key] = $val;
}
unset($arUsersToGroup, $arUserInGroupStructure);
}
$arChats = Array();
if ($bLoadChats)
{
$bColorEnabled = IM\Color::isEnabled();
$bOpenChatEnabled = CIMMessenger::CheckEnableOpenChat();
$cache_id = 'im_chats_v10_'.$USER->GetID().'_'.$bColorEnabled.'_'.$bOpenChatEnabled;
$obCLCache = new CPHPCache;
$cache_dir = '/bx/imc/chats';
if($obCLCache->InitCache($ttl, $cache_id, $cache_dir))
{
$tmpVal = $obCLCache->GetVars();
$arChats = $tmpVal['CHATS'];
unset($tmpVal);
}
else
{
$arChats = CIMChat::GetChatData(Array(
'SKIP_PRIVATE' => 'Y',
'GET_LIST' => 'Y',
'USER_ID' => $USER->GetID()
));
if (CIMMessenger::CheckEnableOpenChat() && !IM\User::getInstance($USER->GetID())->isExtranet())
{
$chatsOpen = CIMChat::GetOpenChatData(Array(
'USER_ID' => $USER->GetID()
));
foreach ($chatsOpen['chat'] as $key => $value)
{
$arChats['chat'][$key] = $value;
}
foreach ($chatsOpen['userInChat'] as $key => $value)
{
$arChats['userInChat'][$key] = $value;
}
foreach ($chatsOpen['userCallStatus'] as $key => $value)
{
$arChats['userCallStatus'][$key] = $value;
}
foreach ($chatsOpen['userChatBlockStatus'] as $key => $value)
{
$arChats['userChatBlockStatus'][$key] = $value;
}
}
if($obCLCache->StartDataCache())
{
$obCLCache->EndDataCache(array(
'CHATS' => $arChats,
));
}
}
}
$arContactList = Array('users' => $arUsers, 'groups' => $arGroups, 'chats' => $arChats['chat'], 'lines' => $arChats['lines'], 'phones' => $arPhones, 'userInGroup' => $arUserInGroup);
foreach(GetModuleEvents("im", "OnAfterContactListGetList", true) as $arEvent)
ExecuteModuleEventEx($arEvent, array(&$arContactList));
return $arContactList;
}
public static function CleanChatCache($userId)
{
$bColorEnabled = IM\Color::isEnabled();
$bOpenChatEnabled = CIMMessenger::CheckEnableOpenChat();
$cache_id = 'im_chats_v10_'.$userId.'_'.$bColorEnabled.'_'.$bOpenChatEnabled;
$cache_dir = '/bx/imc/chats';
$obCLCache = new CPHPCache;
$obCLCache->Clean($cache_id, $cache_dir);
IM\LastSearch::clearCache($userId);
}
public static function CleanAllChatCache()
{
$cache_dir = '/bx/imc/chats';
$obCache = new CPHPCache();
$obCache->CleanDir($cache_dir);
}
function SearchUsers($searchText)
{
$searchText = trim($searchText);
if (mb_strlen($searchText) < 3)
{
$GLOBALS["APPLICATION"]->ThrowException(GetMessage("IM_CL_SEARCH_EMPTY"), "ERROR_SEARCH_EMPTY");
return false;
}
$nameTemplate = self::GetUserNameTemplate(SITE_ID);
$nameTemplateSite = CSite::GetNameFormat(false);
$filter = \Bitrix\Main\UserUtils::getUserSearchFilter(Array('FIND'=> $searchText));
$filter["=ACTIVE"] = "Y";
$filter["=CONFIRM_CODE"] = false;
$filter["=IS_REAL_USER"] = "Y";
$bIntranetEnable = IsModuleInstalled('intranet');
$bVoximplantEnable = IsModuleInstalled('voximplant');
if (!$bIntranetEnable)
{
$arSettings = CIMSettings::GetDefaultSettings(CIMSettings::SETTINGS);
if ($arSettings[CIMSettings::PRIVACY_SEARCH] == CIMSettings::PRIVACY_RESULT_ALL)
$filter['!=UF_IM_SEARCH'] = CIMSettings::PRIVACY_RESULT_CONTACT;
else
$filter['=UF_IM_SEARCH'] = CIMSettings::PRIVACY_RESULT_ALL;
}
$select = Array(
"ID", "LAST_NAME", "NAME", "SECOND_NAME", "LOGIN", "PERSONAL_PHOTO", "PERSONAL_BIRTHDAY", "WORK_POSITION", "PERSONAL_GENDER", "EXTERNAL_AUTH_ID", "TIME_ZONE_OFFSET", "ACTIVE", "UF_IM_SEARCH", "LAST_ACTIVITY_DATE",
"COLOR" => "ST.COLOR", "STATUS" => "ST.STATUS", "IDLE" => "ST.IDLE", "MOBILE_LAST_DATE" => "ST.MOBILE_LAST_DATE", "DESKTOP_LAST_DATE" => "ST.DESKTOP_LAST_DATE",
);
if($bIntranetEnable)
$select[] = 'UF_DEPARTMENT';
if ($bVoximplantEnable)
$select[] = 'UF_VI_PHONE';
$bots = \Bitrix\Im\Bot::getListCache();
$orm = \Bitrix\Main\UserTable::getList(Array(
'select' => $select,
'filter' => $filter,
'runtime' => Array(
new \Bitrix\Main\Entity\ReferenceField(
'ST',
'\Bitrix\Im\Model\StatusTable',
array(
"=ref.USER_ID" => "this.ID",
),
array("join_type"=>"LEFT")
)
),
'order' => Array('LAST_NAME' => 'ASC')
));
$arUsers = Array();
while ($arUser = $orm->fetch())
{
$arUser['PERSONAL_BIRTHDAY'] = $arUser['PERSONAL_BIRTHDAY'] instanceof \Bitrix\Main\Type\Date? $arUser['PERSONAL_BIRTHDAY']->format('d-m'): false;
$arUser['LAST_ACTIVITY_DATE'] = $arUser['LAST_ACTIVITY_DATE'] instanceof \Bitrix\Main\Type\DateTime? $arUser['LAST_ACTIVITY_DATE']: false;
$arUser = CIMStatus::prepareLastDate($arUser);
$userExternalAuthId = $arUser['EXTERNAL_AUTH_ID']? $arUser['EXTERNAL_AUTH_ID']: 'default';
if (
$userExternalAuthId == \Bitrix\Im\Bot::EXTERNAL_AUTH_ID
&& $bots[$arUser["ID"]]['TYPE'] == \Bitrix\Im\Bot::TYPE_NETWORK
&& (
$bots[$arUser["ITEM_ID"]]['CLASS'] == \Bitrix\ImBot\Bot\Support24::class
|| $bots[$arUser["ITEM_ID"]]['CLASS'] == \Bitrix\ImBot\Bot\Partner24::class
|| $bots[$arUser["ITEM_ID"]]['CLASS'] == \Bitrix\ImBot\Bot\SaleSupport24::class
)
)
{
$userExternalAuthId = 'support24';
}
$arUsers[$arUser["ID"]] = Array(
'id' => $arUser["ID"],
'name' => \Bitrix\Im\User::formatFullNameFromDatabase($arUser),
'active' => $arUser['ACTIVE'] == 'Y',
'first_name' => \Bitrix\Im\User::formatNameFromDatabase($arUser),
'last_name' => $arUser['LAST_NAME'],
'work_position' => $arUser['WORK_POSITION'],
'color' => self::GetUserColor($arUser["ID"], $arUser['PERSONAL_GENDER'] == 'M'? 'M': 'F'),
'avatar' => CIMChat::GetAvatarImage($arUser["PERSONAL_PHOTO"]),
'birthday' => $arUser['PERSONAL_BIRTHDAY'],
'gender' => $arUser['PERSONAL_GENDER'] == 'F'? 'F': 'M',
'phone_device' => $bVoximplantEnable && $arUser['UF_VI_PHONE'] == 'Y',
'extranet' => self::IsExtranet($arUser),
'network' => $arUser['EXTERNAL_AUTH_ID'] == self::NETWORK_AUTH_ID || $arUser['EXTERNAL_AUTH_ID'] == \Bitrix\Im\Bot::EXTERNAL_AUTH_ID && $bots[$arUser["ID"]]['TYPE'] == \Bitrix\Im\Bot::TYPE_NETWORK,
'bot' => $arUser['EXTERNAL_AUTH_ID'] == \Bitrix\Im\Bot::EXTERNAL_AUTH_ID,
'tz_offset' => intval($arUser['TIME_ZONE_OFFSET']),
'profile' => CIMContactList::GetUserPath($arUser["ID"]),
'search_mark' => $searchText,
'external_auth_id' => $userExternalAuthId,
/*'status' => $arUser['STATUS'],
'idle' => $arUser['IDLE'],*/
'status' => 'online',
'idle' => false,
'last_activity_date' => $arUser['LAST_ACTIVITY_DATE'],
/*'mobile_last_date' => $arUser['MOBILE_LAST_DATE'],
'desktop_last_date' => $arUser['DESKTOP_LAST_DATE'],*/
'mobile_last_date' => false,
'desktop_last_date' => false,
'absent' => self::formatAbsentResult($arUser["ID"]),
);
}
if (CModule::IncludeModule('imbot'))
{
$result = \Bitrix\ImBot\Bot\Network::search($searchText);
if ($result)
{
foreach ($result as $arLine)
{
$id = 'networkLines'.$arLine["CODE"];
$arUsers[$id] = Array(
'id' => $id,
'name' => htmlspecialcharsbx($arLine["LINE_NAME"]),
'work_position' => $arLine["LINE_DESC"]? htmlspecialcharsbx($arLine["LINE_DESC"]): GetMessage('IM_SEARCH_OL'),
'color' => IM\Color::getColor('GRAY'),
'avatar' => empty($arLine['LINE_AVATAR'])? '/bitrix/js/im/images/blank.gif': $arLine['LINE_AVATAR'],
'birthday' => false,
'gender' => 'M',
'phone_device' => false,
'tz_offset' => 0,
'extranet' => true,
'network' => true,
'bot' => true,
'profile' => '',
'select' => 'Y',
'network_id' => $arLine["CODE"],
'search_mark' => $searchText,
'external_auth_id' => 'network',
'status' => 'online',
'idle' => false,
'last_activity_date' => false,
'mobile_last_date' => false,
'desktop_last_date' => false,
'absent' => false,
);
}
}
}
return Array('users' => $arUsers);
}
static function AllowToSend($arParams)
{
$bResult = false;
if (isset($arParams['TO_USER_ID']))
{
global $USER;
$toUserId = intval($arParams['TO_USER_ID']);
$bResult = true;
if(IsModuleInstalled('intranet') && CModule::IncludeModule('extranet') && !CExtranet::IsIntranetUser())
{
$bResult = false;
if (CModule::IncludeModule("socialnetwork"))
{
global $USER, $CACHE_MANAGER;
if(defined("BX_COMP_MANAGED_CACHE"))
$ttl = 2592000;
else
$ttl = 600;
$cache_id = 'im_user_sg_'.$USER->GetID();
$obSGCache = new CPHPCache;
$cache_dir = '/bx/imc/sonet';
if($obSGCache->InitCache($ttl, $cache_id, $cache_dir))
{
$tmpVal = $obSGCache->GetVars();
$bResult = in_array($toUserId, $tmpVal['EXTRANET_USERS']);
}
else
{
if(defined("BX_COMP_MANAGED_CACHE"))
$CACHE_MANAGER->StartTagCache($cache_dir);
$dbUsersInGroup = CSocNetUserToGroup::GetList(
array(),
array(
"USER_ID" => $USER->GetID(),
"<=ROLE" => SONET_ROLES_USER,
"GROUP_SITE_ID" => CExtranet::GetExtranetSiteID(),
"GROUP_ACTIVE" => "Y",
"GROUP_CLOSED" => "N"
),
false,
false,
array("ID", "GROUP_ID", "GROUP_NAME")
);
$arUserSocNetGroups = Array();
$arUserSG = Array();
while ($ar = $dbUsersInGroup->GetNext(true, false))
{
$arUserSocNetGroups[] = $ar["GROUP_ID"];
$arUserSG['SG'.$ar['GROUP_ID']] = array(
'id' => 'SG'.$ar['GROUP_ID'],
'status' => 'close',
'name' => GetMessage('IM_CL_GROUP_SG').$ar['GROUP_NAME']
);
if(defined("BX_COMP_MANAGED_CACHE"))
{
$CACHE_MANAGER->RegisterTag('sonet_group_'.$ar['GROUP_ID']);
$CACHE_MANAGER->RegisterTag('sonet_user2group_G'.$ar['GROUP_ID']);
}
}
$arExtranetUsers = Array();
$arUserInGroup = Array();
if (count($arUserSocNetGroups) > 0)
{
$dbUsersInGroup = CSocNetUserToGroup::GetList(
array(),
array(
"GROUP_ID" => $arUserSocNetGroups,
"<=ROLE" => SONET_ROLES_USER,
"USER_ACTIVE" => "Y",
"USER_CONFIRM_CODE" => false
),
false,
false,
array("ID", "USER_ID", "GROUP_ID")
);
while ($ar = $dbUsersInGroup->GetNext(true, false))
{
if($USER->GetID() != $ar["USER_ID"])
{
$arExtranetUsers[$ar["USER_ID"]] = $ar["USER_ID"];
if (isset($arUserInGroup["SG".$ar["GROUP_ID"]]))
$arUserInGroup["SG".$ar["GROUP_ID"]]['users'][] = $ar["USER_ID"];
else
$arUserInGroup["SG".$ar["GROUP_ID"]] = Array('id' => "SG".$ar["GROUP_ID"], 'users' => Array($ar["USER_ID"]));
}
}
}
if(defined("BX_COMP_MANAGED_CACHE"))
$CACHE_MANAGER->EndTagCache();
if($obSGCache->StartDataCache())
{
$obSGCache->EndDataCache(array(
'USER_SG' => $arUserSG,
'EXTRANET_USERS' => $arExtranetUsers,
'USER_IN_GROUP' => $arUserInGroup
));
}
$bResult = in_array($toUserId, $arExtranetUsers);
}
unset($obSGCache);
}
}
else if (!IsModuleInstalled('intranet'))
{
if (CIMSettings::GetPrivacy(CIMSettings::PRIVACY_MESSAGE) == CIMSettings::PRIVACY_RESULT_CONTACT && CModule::IncludeModule('socialnetwork') && CSocNetUser::IsFriendsAllowed() && !CSocNetUserRelations::IsFriends($USER->GetID(), $arParams['TO_USER_ID']))
{
$bResult = false;
}
else if (CIMSettings::GetPrivacy(CIMSettings::PRIVACY_MESSAGE, $arParams['TO_USER_ID']) == CIMSettings::PRIVACY_RESULT_CONTACT && CModule::IncludeModule('socialnetwork') && CSocNetUser::IsFriendsAllowed() && !CSocNetUserRelations::IsFriends($USER->GetID(), $arParams['TO_USER_ID']))
{
$bResult = false;
}
}
}
else if (isset($arParams['TO_CHAT_ID']))
{
global $DB, $USER;
$toChatId = intval($arParams['TO_CHAT_ID']);
$fromUserId = intval($USER->GetID());
$groupTypes = CIMChat::implodeTypesForQuery(CIMChat::getGroupTypes());
$strSql = "
SELECT R.CHAT_ID
FROM b_im_relation R
WHERE R.USER_ID = ".$fromUserId."
AND R.MESSAGE_TYPE IN ({$groupTypes})
AND R.CHAT_ID = ".$toChatId."";
$dbRes = $DB->Query($strSql);
if ($arRes = $dbRes->Fetch())
$bResult = true;
else
$bResult = false;
}
return $bResult;
}
static function GetUserData($arParams = Array())
{
$paramsDepartment = $arParams['DEPARTMENT'] ?? null;
$paramsHrPhoto = $arParams['HR_PHOTO'] ?? null;
$paramsPhones = $arParams['PHONES'] ?? null;
$paramsUseCache = $arParams['USE_CACHE'] ?? null;
$paramsShowOnline = $arParams['SHOW_ONLINE'] ?? null;
$paramsExtraFields = $arParams['EXTRA_FIELDS'] ?? null;
$paramsCacheTtl = $arParams['CACHE_TTL'] ?? null;
$getDepartment = !($paramsDepartment === 'N');
$getHrPhoto = $paramsHrPhoto === 'Y';
$getPhones = $paramsPhones === 'Y' && IsModuleInstalled('intranet');
$useCache = !($paramsUseCache === 'N');
$showOnline = !($paramsShowOnline === 'N');
$extraFields = $paramsExtraFields === 'Y';
$arFilter = Array();
if (isset($arParams['ID']) && is_array($arParams['ID']) && !empty($arParams['ID']))
{
foreach ($arParams['ID'] as $key => $value)
{
if (intval($value) > 0)
{
$arParams['ID'][$key] = intval($value);
}
}
$arFilter['=ID'] = $arParams['ID'];
}
else if (isset($arParams['ID']) && intval($arParams['ID']) > 0)
{
$arFilter['=ID'] = Array(intval($arParams['ID']));
}
if (empty($arFilter))
return false;
$nameTemplate = self::GetUserNameTemplate(SITE_ID);
$nameTemplateSite = CSite::GetNameFormat(false);
$bIntranetEnable = false;
if(IsModuleInstalled('intranet') && CModule::IncludeModule('intranet'))
$bIntranetEnable = true;
$bVoximplantEnable = IsModuleInstalled('voximplant');
$bColorEnabled = IM\Color::isEnabled();
if ($useCache)
{
$obCache = new \CPHPCache;
$cache_ttl = (int)$paramsCacheTtl;
if ($cache_ttl <= 0)
{
$cache_ttl = defined("BX_COMP_MANAGED_CACHE") ? 18144000 : 1800;
}
$uid = md5(implode('|', $arFilter['=ID']));
$cache_id = 'user_data_v40_'.$uid.'_'.$nameTemplate.'_'.$nameTemplateSite.'_'.$extraFields.'_'.$getPhones.'_'.$getDepartment.'_'.$bIntranetEnable.'_'.$bVoximplantEnable.'_'.LANGUAGE_ID.'_'.$bColorEnabled;
$cache_dir = '/bx/imc/userdata/' . mb_substr($uid, 0, 2) . '/' . mb_substr($uid, 2, 2) . '/' . $uid;
if ($obCache->initCache($cache_ttl, $cache_id, $cache_dir))
{
$arCacheResult = $obCache->getVars();
if ($showOnline)
{
$onlineUserId = array_keys(array_filter($arCacheResult['users'], function($user) {
return !$user['bot'];
}));
if (!empty($onlineUserId))
{
$arOnline = CIMStatus::GetList(Array('ID' => $onlineUserId));
}
}
foreach ($arCacheResult['users'] as $userId => $value)
{
if ($showOnline)
{
/* $arCacheResult['users'][$userId]['status'] = isset($arOnline['users'][$userId])? $arOnline['users'][$userId]['status']: 'offline';
$arCacheResult['users'][$userId]['idle'] = isset($arOnline['users'][$userId])? $arOnline['users'][$userId]['idle']: false;
$arCacheResult['users'][$userId]['mobile_last_date'] = isset($arOnline['users'][$userId])? $arOnline['users'][$userId]['mobile_last_date']: false;
$arCacheResult['users'][$userId]['desktop_last_date'] = $arOnline['users'][$userId]['desktop_last_date'] ?? false;*/
$arCacheResult['users'][$userId]['status'] = 'online';
$arCacheResult['users'][$userId]['idle'] = false;
$arCacheResult['users'][$userId]['mobile_last_date'] = false;
$arCacheResult['users'][$userId]['desktop_last_date'] = false;
$arCacheResult['users'][$userId]['last_activity_date'] = isset($arOnline['users'][$userId])? $arOnline['users'][$userId]['last_activity_date']: false;
$arCacheResult['users'][$userId]['absent'] = isset($arOnline['users'][$userId])? $arOnline['users'][$userId]['absent']: false;
}
if ($getHrPhoto && !isset($arCacheResult['hrphoto']))
{
$arCacheResult['hrphoto'][$userId] = $arCacheResult['users'][$userId]['avatar'];
}
if ($value['bot'])
{
$converter = new Converter(Converter::TO_SNAKE | Converter::TO_LOWER | Converter::KEYS);
$botData = \Bitrix\Im\V2\Entity\User\Data\BotData::getInstance((int)$userId)->toRestFormat();
$arCacheResult['users'][$userId]['bot_data'] = !empty($botData)
? $converter->process($botData)
: null
;
}
else
{
$arCacheResult['users'][$userId]['bot_data'] = null;
}
}
return $arCacheResult;
}
}
$arSelect = array("ID", "LAST_NAME", "NAME", "EMAIL", "LOGIN", "PERSONAL_PHOTO", "SECOND_NAME", "PERSONAL_BIRTHDAY", "WORK_POSITION", "PERSONAL_GENDER", "EXTERNAL_AUTH_ID", "TIME_ZONE_OFFSET", "PERSONAL_WWW", "ACTIVE", "LAST_ACTIVITY_DATE"); // TODO , "TIME_ZONE_OFFSET"
if ($getPhones)
{
$arSelect[] = 'WORK_PHONE';
$arSelect[] = 'PERSONAL_PHONE';
$arSelect[] = 'PERSONAL_MOBILE';
}
if($bIntranetEnable)
{
$arSelect[] = 'UF_ZOOM';
$arSelect[] = 'UF_SKYPE';
$arSelect[] = 'UF_SKYPE_LINK';
$arSelect[] = 'UF_PHONE_INNER';
$arSelect[] = 'UF_DEPARTMENT';
}
if ($bVoximplantEnable)
{
$arSelect[] = 'UF_VI_PHONE';
}
$arUsers = array();
$arUserInGroup = array();
$arPhones = array();
$arHrPhoto = array();
$arSource = array();
$query = new \Bitrix\Main\Entity\Query(\Bitrix\Main\UserTable::getEntity());
$query->registerRuntimeField('', new \Bitrix\Main\Entity\ReferenceField('ref', 'Bitrix\Im\Model\StatusTable', array('=this.ID' => 'ref.USER_ID')));
$query->addSelect('ref.COLOR', 'COLOR')
->addSelect('ref.STATUS', 'STATUS')
->addSelect('ref.IDLE', 'IDLE')
->addSelect('ref.MOBILE_LAST_DATE', 'MOBILE_LAST_DATE')
->addSelect('ref.DESKTOP_LAST_DATE', 'DESKTOP_LAST_DATE');
foreach ($arSelect as $value)
{
$query->addSelect($value);
}
foreach ($arFilter as $key => $value)
{
$query->addFilter($key, $value);
}
$resultQuery = $query->exec();
$bots = \Bitrix\Im\Bot::getListCache();
while ($arUser = $resultQuery->fetch())
{
$arUser = CIMStatus::prepareLastDate($arUser);
foreach ($arUser as $key => $value)
{
$arUser[$key] = !is_array($value) && !is_object($value)? htmlspecialcharsEx($value): $value;
}
$arSource[$arUser["ID"]]["PERSONAL_PHOTO"] = $arUser["PERSONAL_PHOTO"];
$color = self::GetUserColor($arUser["ID"], $arUser['PERSONAL_GENDER'] == 'M'? 'M': 'F');
if (isset($arUser['COLOR']) && $arUser['COLOR'] <> '')
{
$color = IM\Color::getColor($arUser['COLOR']);
}
if (!$color)
{
$color = self::GetUserColor($arUser["ID"], $arUser['PERSONAL_GENDER'] == 'M'? 'M': 'F');
}
$arUser['PERSONAL_BIRTHDAY'] = $arUser['PERSONAL_BIRTHDAY'] instanceof \Bitrix\Main\Type\Date? $arUser['PERSONAL_BIRTHDAY']->format('d-m'): false;
$arUser['LAST_ACTIVITY_DATE'] = $arUser['LAST_ACTIVITY_DATE'] instanceof \Bitrix\Main\Type\DateTime? $arUser['LAST_ACTIVITY_DATE']: false;
$userExternalAuthId = $arUser['EXTERNAL_AUTH_ID']? $arUser['EXTERNAL_AUTH_ID']: 'default';
if (
$userExternalAuthId == \Bitrix\Im\Bot::EXTERNAL_AUTH_ID
&& $bots[$arUser["ID"]]['TYPE'] == \Bitrix\Im\Bot::TYPE_NETWORK
&& (
$bots[$arUser["ID"]]['CLASS'] == \Bitrix\ImBot\Bot\Support24::class
|| $bots[$arUser["ID"]]['CLASS'] == \Bitrix\ImBot\Bot\Partner24::class
|| $bots[$arUser["ID"]]['CLASS'] == \Bitrix\ImBot\Bot\SaleSupport24::class
)
)
{
$userExternalAuthId = 'support24';
}
$userV2 = IM\V2\Entity\User\User::getInstance((int)$arUser["ID"]);
$arUsers[$arUser["ID"]] = Array(
'id' => $arUser["ID"],
'name' => \Bitrix\Im\User::formatFullNameFromDatabase($arUser),
'active' => $arUser['ACTIVE'] == 'Y',
'first_name' => \Bitrix\Im\User::formatNameFromDatabase($arUser),
'last_name' => $arUser['LAST_NAME'],
'work_position' => $arUser['WORK_POSITION'],
'color' => $color,
'avatar' => CIMChat::GetAvatarImage($arUser["PERSONAL_PHOTO"]),
'avatar_id' => $arUser["PERSONAL_PHOTO"],
'birthday' => $arUser['PERSONAL_BIRTHDAY'],
'gender' => $arUser['PERSONAL_GENDER'] == 'F'? 'F': 'M',
'phone_device' => $bVoximplantEnable && $arUser['UF_VI_PHONE'] == 'Y',
'phones' => $bVoximplantEnable && $arUser['UF_VI_PHONE'] == 'Y',
'extranet' => self::IsExtranet($arUser),
'tz_offset' => intval($arUser['TIME_ZONE_OFFSET']),
'network' => $arUser['EXTERNAL_AUTH_ID'] == self::NETWORK_AUTH_ID || $arUser['EXTERNAL_AUTH_ID'] == \Bitrix\Im\Bot::EXTERNAL_AUTH_ID && $bots[$arUser["ID"]]['TYPE'] == \Bitrix\Im\Bot::TYPE_NETWORK,
'bot' => $arUser['EXTERNAL_AUTH_ID'] == \Bitrix\Im\Bot::EXTERNAL_AUTH_ID,
'connector' => $arUser['EXTERNAL_AUTH_ID'] == "imconnector",
'profile' => CIMContactList::GetUserPath($arUser["ID"]),
'external_auth_id' => $userExternalAuthId,
/*'status' => $arUser['STATUS'],
'idle' => $arUser['IDLE']?: false,*/
'status' => 'online',
'idle' => false,
'last_activity_date' => $arUser['LAST_ACTIVITY_DATE']?: false,
/*'mobile_last_date' => $arUser['MOBILE_LAST_DATE']?: false,
'desktop_last_date' => $arUser['DESKTOP_LAST_DATE']?: false,*/
'mobile_last_date' => false,
'desktop_last_date' => false,
'departments' => $getDepartment && !empty($arUser["UF_DEPARTMENT"]) && is_array($arUser["UF_DEPARTMENT"])? array_values($arUser["UF_DEPARTMENT"]): Array(),
'absent' => self::formatAbsentResult($arUser["ID"]),
'type' => $userV2->getType()->value,
);
$services = [];
if (!empty($arUser['UF_ZOOM']))
{
$services['zoom'] = $arUser['UF_ZOOM'];
}
if (!empty($arUser['UF_SKYPE_LINK']))
{
$services['skype'] = $arUser['UF_SKYPE_LINK'];
}
else if (!empty($arUser['UF_SKYPE']))
{
$services['skype'] = 'skype://'.$arUser['UF_SKYPE'];
}
$arUsers[$arUser["ID"]]['services'] = empty($services)? null: array_change_key_case($services, CASE_LOWER);
if ($extraFields)
{
$arUsers[$arUser["ID"]]['website'] = $arUser['PERSONAL_WWW'];
$arUsers[$arUser["ID"]]['email'] = $arUser['EMAIL'];
}
foreach($arUsers[$arUser["ID"]]["departments"] as $dep_id)
{
if (isset($arUserInGroup[$dep_id]))
$arUserInGroup[$dep_id]['users'][] = $arUser["ID"];
else
$arUserInGroup[$dep_id] = Array('id' => $dep_id, 'users' => Array($arUser["ID"]));
}
if ($getHrPhoto)
{
$arHrPhoto[$arUser["ID"]] = $arUsers[$arUser["ID"]]['avatar'];
}
if ($getPhones)
{
if (CModule::IncludeModule('voximplant'))
{
$result = CVoxImplantPhone::Normalize($arUser["WORK_PHONE"]);
if ($result)
{
$arPhones[$arUser["ID"]]['WORK_PHONE'] = $arUser['WORK_PHONE'];
}
$result = CVoxImplantPhone::Normalize($arUser["PERSONAL_MOBILE"]);
if ($result)
{
$arPhones[$arUser["ID"]]['PERSONAL_MOBILE'] = $arUser['PERSONAL_MOBILE'];
}
$result = CVoxImplantPhone::Normalize($arUser["PERSONAL_PHONE"]);
if ($result)
{
$arPhones[$arUser["ID"]]['PERSONAL_PHONE'] = $arUser['PERSONAL_PHONE'];
}
$result = preg_replace("/[^0-9\#\*]/i", "", $arUser["UF_PHONE_INNER"]);
if ($result)
{
$arPhones[$arUser["ID"]]['INNER_PHONE'] = $result;
}
}
else
{
$arPhones[$arUser["ID"]]['WORK_PHONE'] = $arUser['WORK_PHONE'];
$arPhones[$arUser["ID"]]['PERSONAL_MOBILE'] = $arUser['PERSONAL_MOBILE'];
$arPhones[$arUser["ID"]]['PERSONAL_PHONE'] = $arUser['PERSONAL_PHONE'];
$arPhones[$arUser["ID"]]['INNER_PHONE'] = $arUser['UF_PHONE_INNER'];
}
if (isset($arPhones[$arUser["ID"]]))
{
$arUsers[$arUser["ID"]]['phones'] = array_change_key_case($arPhones[$arUser["ID"]], CASE_LOWER);
}
}
}
$result = array('users' => $arUsers, 'hrphoto' => $arHrPhoto, 'userInGroup' => $arUserInGroup, 'phones' => $arPhones, 'source' => $arSource);
if($useCache)
{
$cacheTag = array();
if($obCache->StartDataCache())
{
if(defined("BX_COMP_MANAGED_CACHE"))
{
global $CACHE_MANAGER;
$CACHE_MANAGER->StartTagCache($cache_dir);
if(is_array($arParams['ID']))
{
foreach ($arParams['ID'] as $id)
{
$tag = 'USER_NAME_'.intval($id);
if(!in_array($tag, $cacheTag))
{
$cacheTag[] = $tag;
$CACHE_MANAGER->RegisterTag($tag);
}
}
}
elseif (isset($arParams['ID']) && intval($arParams['ID']) > 0)
{
$tag = 'USER_NAME_'.intval($arParams['ID']);
$CACHE_MANAGER->RegisterTag($tag);
}
$CACHE_MANAGER->EndTagCache();
}
$obCache->EndDataCache($result);
unset($cacheTag);
}
}
unset($result['source']);
foreach ($result['users'] as $userId => $user)
{
if ($user['bot'])
{
$converter = new Converter(Converter::TO_SNAKE | Converter::TO_LOWER | Converter::KEYS);
$botData = \Bitrix\Im\V2\Entity\User\Data\BotData::getInstance((int)$userId)->toRestFormat();
$result['users'][$userId]['bot_data'] = (!empty($botData)) ? $converter->process($botData) : null;
}
else
{
$result['users'][$userId]['bot_data'] = null;
}
}
return $result;
}
public static function SetOnline($userId = null, $cache = true)
{
return CUser::SetLastActivityDate($userId, $cache);
}
public static function SetOffline($userId = null)
{
global $USER, $DB;
$userId = \Bitrix\Im\Common::getUserId($userId);
if (!$userId)
{
return false;
}
$connection = \Bitrix\Main\Application::getInstance()->getConnection();
$helper = $connection->getSqlHelper();
$sqlDateFunction = 'NULL';
if ($DB->type == "MSSQL")
{
$sqlDateFunction = "dateadd(SECOND, -120, getdate())";
}
elseif ($DB->type == "ORACLE")
{
$sqlDateFunction = "SYSDATE-(1/24/60/60*120)";
}
else
{
$sqlDateFunction = $helper->addSecondsToDateTime(-120);
}
$connection->queryExecute("UPDATE b_user SET LAST_ACTIVITY_DATE = ".$sqlDateFunction." WHERE ID = ".$userId);
if ($userId == $USER->GetId())
{
unset($_SESSION['IM_LAST_ONLINE'], $_SESSION['USER_LAST_ONLINE_'.$userId]);
}
$USER->Logout();
return true;
}
public static function SetCurrentTab($userId)
{
return true;
}
public static function InRecent($userId, $type, $itemId)
{
$userId = intval($userId);
if ($userId <= 0)
return false;
$messageId = false;
$result = \Bitrix\Im\Model\RecentTable::getList(Array(
'filter' => Array(
'=USER_ID' => $userId,
'=ITEM_TYPE' => $type,
'=ITEM_ID' => $itemId,
)
))->fetch();
if ($result)
{
$messageId = $result['ITEM_MID'];
}
return $messageId;
}
public static function SetRecentForNewUser($userId)
{
$userId = intval($userId);
if ($userId <= 0)
{
return false;
}
$colleagues = \Bitrix\Im\Department::getColleagues($userId);
foreach ($colleagues as $uid)
{
self::SetRecent(Array(
'ENTITY_ID' => $uid,
'USER_ID' => $userId
));
}
return true;
}
public static function SetRecent($arParams)
{
$messageDateParam = $arParams['MESSAGE_DATE'] ?? null;
$userId = (int)($arParams['USER_ID'] ?? 0);
$itemId = (int)($arParams['ENTITY_ID'] ?? 0);
$chatId = (int)($arParams['CHAT_ID'] ?? 0);
$relationId = (int)($arParams['RELATION_ID'] ?? 0);
$sessionId = (int)($arParams['SESSION_ID'] ?? 0);
$pinned = isset($arParams['PINNED']) && $arParams['PINNED'] === 'Y' ? 'Y': 'N';
$messageId = (int)($arParams['MESSAGE_ID'] ?? 0);
$dateMessage = $messageDateParam instanceof \Bitrix\Main\Type\DateTime ? $messageDateParam : new \Bitrix\Main\Type\DateTime();
$dateUpdate = new \Bitrix\Main\Type\DateTime();
$arParams['ENTITY_TYPE'] = $arParams['CHAT_TYPE'] ?? $arParams['ENTITY_TYPE'] ?? IM_MESSAGE_PRIVATE;
if (in_array($arParams['ENTITY_TYPE'], CIMChat::getGroupTypes(), true))
{
$itemType = $arParams['ENTITY_TYPE'];
}
else
{
$itemType = IM_MESSAGE_PRIVATE;
}
if ($itemId <= 0)
{
return false;
}
if (
$sessionId
&& $itemType === IM\V2\Chat::IM_TYPE_OPEN_LINE
&& class_exists('\Bitrix\ImOpenLines\Recent')
&& \Bitrix\ImOpenLines\Recent::recentAvailable($sessionId)
)
{
$session = \Bitrix\ImOpenLines\Model\SessionTable::getByPrimary($sessionId)->fetch();
$config = \Bitrix\ImOpenLines\Model\ConfigTable::getByPrimary($session['CONFIG_ID'])->fetch();
if (
$config['QUEUE_TYPE'] === \Bitrix\ImOpenLines\Config::QUEUE_TYPE_ALL
|| \Bitrix\ImOpenLines\Recent::isCurrentRecent($userId, $chatId)
)
{
\Bitrix\ImOpenLines\Recent::setRecent($userId, $chatId, $messageId, $sessionId);
}
}
else
{
$connection = \Bitrix\Main\Application::getInstance()->getConnection();
// $isUserAlreadyInRecent = $connection->queryScalar("SELECT 1 FROM b_im_recent WHERE USER_ID = ".$userId);
$merge = $connection->getSqlHelper()->prepareMerge(
"b_im_recent",
['USER_ID', 'ITEM_TYPE', 'ITEM_ID'],
[
'USER_ID' => $userId,
'ITEM_TYPE' => $itemType,
'ITEM_ID' => $itemId,
'ITEM_MID' => $messageId,
'ITEM_CID' => $chatId,
'ITEM_RID' => $relationId,
'ITEM_OLID' => $sessionId,
'PINNED' => $pinned,
'DATE_MESSAGE' => $dateMessage,
'DATE_UPDATE' => $dateUpdate,
'DATE_LAST_ACTIVITY' => $dateMessage,
],
[
'ITEM_MID' => $messageId,
'ITEM_CID' => $chatId,
'ITEM_RID' => $relationId,
'ITEM_OLID' => $sessionId,
'DATE_MESSAGE' => $dateMessage,
'DATE_UPDATE' => $dateUpdate,
'DATE_LAST_ACTIVITY' => $dateMessage,
]
);
if ($merge && $merge[0] != "")
{
$connection->query($merge[0]);
}
}
// if (isset($isUserAlreadyInRecent) && !$isUserAlreadyInRecent)
// {
// $event = new \Bitrix\Main\Event("im", "OnAfterRecentAdd", array(
// "user_id" => $userId,
// ));
// $event->send();
// }
return true;
}
public static function DeleteRecent($entityId, $isChat = false, $userId = false, $withoutRead = false)
{
global $DB;
if (is_array($entityId))
{
foreach ($entityId as $key => $value)
{
$entityId[$key] = (int)$value;
}
$entityId = array_slice($entityId, 0, 1000);
$sqlEntityId = 'ITEM_ID IN ('.implode(',', $entityId).')';
}
else if ((int)$entityId > 0)
{
$sqlEntityId = 'ITEM_ID = '.(int)$entityId;
}
else
{
return false;
}
if ((int)$userId <= 0)
{
if ($GLOBALS['USER'] instanceof \CUser && $GLOBALS['USER']->getId() > 0)
{
$userId = $GLOBALS['USER']->getId();
}
else
{
return false;
}
}
if ($isChat)
{
$itemType = "ITEM_TYPE IN ('".implode("','", \Bitrix\Im\Chat::getTypes())."')";
}
else
{
$itemType = "ITEM_TYPE = '".IM_MESSAGE_PRIVATE."'";
}
/*$strSQL = "
UPDATE b_im_relation R
INNER JOIN b_im_recent RC
ON R.ID = RC.ITEM_RID
SET
R.STATUS = '".IM_STATUS_READ."'
, R.UNREAD_ID = 0
, R.MESSAGE_STATUS = '".IM_MESSAGE_STATUS_RECEIVED."'
, R.COUNTER = 0
, R.LAST_READ = NOW()
WHERE
RC.USER_ID = {$userId}
AND RC.{$itemType}
AND RC.{$sqlEntityId}
";
$DB->Query($strSQL);*/
if ($isChat)
{
$chat = IM\V2\Chat::getInstance((int)$entityId);
}
else
{
$chat = IM\V2\Entity\User\User::getInstance($userId)->getChatWith($entityId, false);
}
$lineRemoveComplete = false;
if (
$isChat
&& $chat->getChatId()
&& $chat->getType() === IM\V2\Chat::IM_TYPE_OPEN_LINE
&& class_exists('\Bitrix\ImOpenLines\Recent')
)
{
$lineRemoveResult = \Bitrix\ImOpenLines\Recent::removeRecent((int)$userId, $chat->getChatId());
$lineRemoveComplete = $lineRemoveResult->isSuccess();
}
$strSQL = "DELETE FROM b_im_recent WHERE USER_ID = {$userId} AND {$itemType} AND {$sqlEntityId}";
$DB->Query($strSQL);
if (!$withoutRead && $chat !== null && !($chat instanceof IM\V2\Chat\NullChat) && $chat->getChatId())
{
$chat = $chat->withContextUser($userId);
if ($chat instanceof IM\V2\Chat\OpenLineChat)
{
$chat->read(false, false, true);
}
else
{
$chat->read();
}
Sync\Logger::getInstance()->add(
new Sync\Event(Sync\Event::DELETE_EVENT, Sync\Event::CHAT_ENTITY, $chat->getChatId()),
$userId,
$chat
);
}
if ($isChat && \Bitrix\Main\Loader::includeModule('pull'))
{
if (is_array($entityId))
{
foreach ($entityId as $value)
{
\CPullWatch::delete($userId, 'IM_PUBLIC_'.(int)$value);
}
}
else
{
\CPullWatch::delete($userId, 'IM_PUBLIC_'.(int)$entityId);
if ($chat->getType() === Chat::IM_TYPE_CHANNEL)
{
\CPullWatch::delete($userId, 'IM_PUBLIC_COMMENT_'.(int)$entityId);
}
}
}
//\Bitrix\Im\Counter::clearCache($userId);
$strSQL = $DB->TopSql("SELECT 1 FROM b_im_recent WHERE USER_ID = ".$userId, 1);
$rs = $DB->Query($strSQL);
if (!$rs->Fetch() || $lineRemoveComplete)
{
$event = new \Bitrix\Main\Event("im", "OnAfterRecentDelete", array(
"user_id" => $userId,
));
$event->send();
}
return true;
}
public static function DialogHide($dialogId, $userId = null)
{
$userId = \Bitrix\Im\Common::getUserId($userId);
if (!$userId)
{
return false;
}
$pullInclude = \Bitrix\Main\Loader::includeModule("pull");
$lines = false;
if (mb_substr($dialogId, 0, 4) == 'chat')
{
$chatId = (int)mb_substr($dialogId, 4);
$lines = Chat::getInstance($chatId)->getType() === Chat::IM_TYPE_OPEN_LINE;
self::deleteRecent($chatId, true, $userId);
}
else
{
$dialogId = (int)$dialogId;
$chatId = null;
$chat = IM\V2\Entity\User\User::getInstance($userId)->getChatWith($dialogId, false);
if ($chat !== null)
{
$chatId = $chat->getId();
}
self::deleteRecent($dialogId, false, $userId);
}
if ($pullInclude)
{
\Bitrix\Pull\Event::add($userId, Array(
'module_id' => 'im',
'command' => 'chatHide',
'expiry' => 3600,
'params' => Array(
'dialogId' => $dialogId,
'chatId' => $chatId,
'lines' => $lines,
),
'extra' => \Bitrix\Im\Common::getPullExtra()
));
}
return true;
}
public static function ClearRecentCache($userId = null)
{
}
public static function GetRecentList($arParams = Array())
{
global $DB, $USER;
$bLoadUnreadMessage = isset($arParams['LOAD_UNREAD_MESSAGE']) && $arParams['LOAD_UNREAD_MESSAGE'] == 'Y'? true: false;
$bTimeZone = isset($arParams['USE_TIME_ZONE']) && $arParams['USE_TIME_ZONE'] == 'N'? false: true;
$bSmiles = isset($arParams['USE_SMILES']) && $arParams['USE_SMILES'] == 'N'? false: true;
$userId = isset($arParams['USER_ID'])? $arParams['USER_ID']: $USER->GetId();
if ($userId <= 0)
{
return false;
}
$arRecent = Array();
$arUsers = Array();
$generalChatId = CIMChat::GetGeneralChatId();
$isOperator = \Bitrix\Im\Integration\Imopenlines\User::isOperator();
if (!$bTimeZone)
CTimeZone::Disable();
$strSql = "
SELECT
R.ITEM_TYPE,
R.ITEM_ID,
R.PINNED,
R.ITEM_MID as M_ID,
M.AUTHOR_ID as M_AUTHOR_ID,
M.ID as M_ID,
M.CHAT_ID as M_CHAT_ID,
M.MESSAGE as M_MESSAGE,
".$DB->DatetimeToTimestampFunction('R.DATE_UPDATE')." as M_DATE_CREATE,
C.TITLE as C_TITLE,
C.AUTHOR_ID as C_OWNER_ID,
C.ENTITY_TYPE as CHAT_ENTITY_TYPE,
C.ENTITY_ID as CHAT_ENTITY_ID,
C.ENTITY_DATA_1 as CHAT_ENTITY_DATA_1,
C.ENTITY_DATA_2 as CHAT_ENTITY_DATA_2,
C.ENTITY_DATA_3 as CHAT_ENTITY_DATA_3,
C.AVATAR as C_AVATAR,
C.CALL_NUMBER as C_CALL_NUMBER,
C.EXTRANET as CHAT_EXTRANET,
C.COLOR as CHAT_COLOR,
C.TYPE as CHAT_TYPE,
U.LOGIN,
U.NAME,
U.LAST_NAME,
U.PERSONAL_PHOTO,
U.SECOND_NAME,
".$DB->DatetimeToTimestampFunction('U.PERSONAL_BIRTHDAY')." as PERSONAL_BIRTHDAY,
".$DB->DatetimeToTimestampFunction('U.LAST_ACTIVITY_DATE')." as LAST_ACTIVITY_DATE,
U.PERSONAL_GENDER,
U.EXTERNAL_AUTH_ID,
U.WORK_POSITION,
U.TIME_ZONE_OFFSET,
U.ACTIVE,
ST.COLOR,
ST.STATUS,
".$DB->DatetimeToTimestampFunction('ST.IDLE')." as IDLE,
".$DB->DatetimeToTimestampFunction('ST.MOBILE_LAST_DATE')." as MOBILE_LAST_DATE,
".$DB->DatetimeToTimestampFunction('ST.DESKTOP_LAST_DATE')." as DESKTOP_LAST_DATE,
C1.USER_ID as RID,
C1.NOTIFY_BLOCK as RELATION_NOTIFY_BLOCK,
C1.USER_ID as RELATION_USER_ID
".($isOperator? ", S.ID as LINES_ID, S.STATUS as LINES_STATUS": "")."
FROM
b_im_recent R
LEFT JOIN b_user U ON R.ITEM_TYPE = '".IM_MESSAGE_PRIVATE."' AND R.ITEM_ID = U.ID
LEFT JOIN b_im_status ST ON R.ITEM_TYPE = '".IM_MESSAGE_PRIVATE."' AND R.ITEM_ID = ST.USER_ID
LEFT JOIN b_im_chat C ON R.ITEM_TYPE != '".IM_MESSAGE_PRIVATE."' AND R.ITEM_ID = C.ID
LEFT JOIN b_im_message M ON R.ITEM_MID = M.ID
LEFT JOIN b_im_relation C1 ON C1.CHAT_ID = C.ID AND C1.USER_ID = ".$userId."
".($isOperator? "LEFT JOIN b_imopenlines_session S ON R.ITEM_OLID > 0 AND S.ID = R.ITEM_OLID": "")."
WHERE R.USER_ID = ".$userId;
if (!$bTimeZone)
CTimeZone::Enable();
$enableOpenChat = CIMMessenger::CheckEnableOpenChat();
$bots = \Bitrix\Im\Bot::getListCache();
$arMessageId = Array();
$dbRes = $DB->Query($strSql);
$counters = (new IM\V2\Message\CounterService($userId))->getForEachChat();
while ($arRes = $dbRes->GetNext(true, false))
{
$arRes['ITEM_TYPE'] = trim($arRes['ITEM_TYPE']);
$arRes['CHAT_TYPE'] = trim($arRes['CHAT_TYPE']);
$arRes['CHAT_EXTRANET'] = trim($arRes['CHAT_EXTRANET']);
if ($arRes['ITEM_TYPE'] == IM_MESSAGE_OPEN)
{
if (!$enableOpenChat)
{
continue;
}
else if (intval($arRes['RID']) <= 0 && IM\User::getInstance($userId)->isExtranet())
{
continue;
}
}
else if (in_array($arRes['ITEM_TYPE'], CIMChat::getGroupTypes()))
{
if (intval($arRes['RID']) <= 0)
{
continue;
}
}
$arMessageId[] = $arRes['M_ID'];
if ($arRes['M_ID'] > 0 && $arRes['M_DATE_CREATE']+2592000 < time())
{
continue;
}
$itemId = $arRes['ITEM_ID'];
$item = Array(
'TYPE' => $arRes['ITEM_TYPE'],
'MESSAGE' => Array(
'id' => $arRes['M_ID'],
'chatId' => $arRes['M_CHAT_ID'],
'senderId' => $arRes['M_AUTHOR_ID'],
'date' => \Bitrix\Main\Type\DateTime::createFromTimestamp($arRes['M_DATE_CREATE']),
'text' => \Bitrix\Im\Text::parse($arRes['M_MESSAGE'], Array('CUT_STRIKE' => 'Y', 'SMILES' => 'N', 'SAFE' => 'N')),
'pinned' => $arRes['PINNED'] == 'Y',
),
'COUNTER' => $counters[(int)$arRes['M_CHAT_ID']],
);
$item['MESSAGE']['text'] = preg_replace('#\-{54}.+?\-{54}#s', " [".GetMessage('IM_QUOTE')."] ", strip_tags(str_replace(array("<br>","<br/>","<br />", "#BR#"), Array(" "," ", " ", " "), $item['MESSAGE']['text']), "<img>"));
if ($arRes['ITEM_TYPE'] == IM_MESSAGE_PRIVATE)
{
$arUsers[] = $arRes['ITEM_ID'];
$arRes['PERSONAL_BIRTHDAY'] = $arRes['PERSONAL_BIRTHDAY']? \Bitrix\Main\Type\DateTime::createFromTimestamp($arRes['PERSONAL_BIRTHDAY'])->format('d-m'): false;
$arRes['LAST_ACTIVITY_DATE'] = $arRes['LAST_ACTIVITY_DATE']? \Bitrix\Main\Type\DateTime::createFromTimestamp($arRes['LAST_ACTIVITY_DATE']): false;
$arRes = CIMStatus::prepareLastDate($arRes);
$userExternalAuthId = $arRes['EXTERNAL_AUTH_ID']? $arRes['EXTERNAL_AUTH_ID']: 'default';
if (
$userExternalAuthId == \Bitrix\Im\Bot::EXTERNAL_AUTH_ID
&& $bots[$arRes["ITEM_ID"]]['TYPE'] == \Bitrix\Im\Bot::TYPE_NETWORK
&& (
$bots[$arRes["ITEM_ID"]]['CLASS'] == \Bitrix\ImBot\Bot\Support24::class
|| $bots[$arRes["ITEM_ID"]]['CLASS'] == \Bitrix\ImBot\Bot\Partner24::class
|| $bots[$arRes["ITEM_ID"]]['CLASS'] == \Bitrix\ImBot\Bot\SaleSupport24::class
)
)
{
$userExternalAuthId = 'support24';
}
$item['USER'] = Array(
'id' => $arRes['ITEM_ID'],
'name' => \Bitrix\Im\User::formatFullNameFromDatabase($arRes),
'active' => $arRes['ACTIVE'] == 'Y',
'first_name' => \Bitrix\Im\User::formatNameFromDatabase($arRes),
'last_name' => $arRes['LAST_NAME'],
'work_position' => $arRes['WORK_POSITION'],
'color' => self::GetUserColor($arRes["ID"], $arRes['PERSONAL_GENDER'] == 'M'? 'M': 'F'),
'avatar' => CIMChat::GetAvatarImage($arRes["PERSONAL_PHOTO"]),
'birthday' => $arRes['PERSONAL_BIRTHDAY'],
'gender' => $arRes['PERSONAL_GENDER'] == 'F'? 'F': 'M',
'extranet' => false,
'network' => $arRes['EXTERNAL_AUTH_ID'] == self::NETWORK_AUTH_ID || $arRes['EXTERNAL_AUTH_ID'] == \Bitrix\Im\Bot::EXTERNAL_AUTH_ID && $bots[$arRes["ITEM_ID"]]['TYPE'] == \Bitrix\Im\Bot::TYPE_NETWORK,
'bot' => $arRes['EXTERNAL_AUTH_ID'] == \Bitrix\Im\Bot::EXTERNAL_AUTH_ID,
'tz_offset' => intval($arRes['TIME_ZONE_OFFSET']),
'phone_device' => false,
'profile' => CIMContactList::GetUserPath($arRes["ITEM_ID"]),
'external_auth_id' => $userExternalAuthId,
'status' => $arRes['STATUS'],
'idle' => $arRes['IDLE'],
'last_activity_date' => $arRes['LAST_ACTIVITY_DATE'],
'mobile_last_date' => $arRes['MOBILE_LAST_DATE'],
'desktop_last_date' => $arRes['DESKTOP_LAST_DATE'],
'absent' => self::formatAbsentResult($arRes["ITEM_ID"]),
);
if (!$item['MESSAGE']['text'])
{
$item['MESSAGE']['text'] = $arRes['WORK_POSITION'];
}
}
else
{
$chatType = \Bitrix\Im\Chat::getType($arRes);
if ($arRes["CHAT_ENTITY_TYPE"] == 'LINES')
{
if ($isOperator)
{
$item['LINES'] = Array(
'ID' => $arRes['LINES_ID'],
'STATUS' => $arRes['LINES_STATUS']
);
}
}
else if ($generalChatId == $arRes['M_CHAT_ID'])
{
$arRes["CHAT_ENTITY_TYPE"] = 'GENERAL';
}
$muteList = Array();
if ($arRes['RELATION_NOTIFY_BLOCK'] == 'Y')
{
$muteList = Array($arRes['RELATION_USER_ID'] => true);
}
$itemId = 'chat'.$itemId;
$item['CHAT'] = Array(
'id' => $arRes['ITEM_ID'],
'name' => \Bitrix\Im\Text::decodeEmoji($arRes["C_TITLE"]),
'color' => $arRes["CHAT_COLOR"] == ""? IM\Color::getColorByNumber($arRes['ITEM_ID']): IM\Color::getColor($arRes['CHAT_COLOR']),
'avatar' => CIMChat::GetAvatarImage($arRes["C_AVATAR"]),
'extranet' => $arRes["CHAT_EXTRANET"] == ""? "": ($arRes["CHAT_EXTRANET"] == "Y"? true: false),
'owner' => $arRes["C_OWNER_ID"],
'type' => $chatType,
'entity_type' => $arRes["CHAT_ENTITY_TYPE"],
'entity_id' => $arRes["CHAT_ENTITY_ID"],
'entity_data_1' => trim($arRes["CHAT_ENTITY_DATA_1"]),
'entity_data_2' => trim($arRes["CHAT_ENTITY_DATA_2"]),
'entity_data_3' => trim($arRes["CHAT_ENTITY_DATA_3"]),
'mute_list' => $muteList,
'message_type' => $arRes['CHAT_TYPE'],
'call_number' => $arRes["C_CALL_NUMBER"]
);
}
$arRecent[$itemId] = $item;
}
$params = CIMMessageParam::Get($arMessageId);
foreach ($arRecent as $key => $value)
{
if (isset($params[$value['MESSAGE']['id']]) && is_array($params[$value['MESSAGE']['id']]['FILE_ID']))
{
if (count($params[$value['MESSAGE']['id']]['FILE_ID']) > 0 && trim($arRecent[$key]['MESSAGE']['text']) == '')
{
$arRecent[$key]['MESSAGE']['text'] = "[".GetMessage('IM_FILE')."]";
}
}
$arRecent[$key]['MESSAGE']['params'] = $params[$value['MESSAGE']['id']];
}
$bIntranetEnable = IsModuleInstalled('intranet');
$bVoximplantEnable = IsModuleInstalled('voximplant');
if ($bIntranetEnable || $bVoximplantEnable)
{
$arUserPhone = Array();
$arUserDepartment = Array();
$arSelectParams = Array();
if ($bIntranetEnable)
$arSelectParams[] = 'UF_DEPARTMENT';
if ($bVoximplantEnable)
$arSelectParams[] = 'UF_VI_PHONE';
$dbUsers = CUser::GetList(['last_name'=>'asc'], '', Array('ID' => $userId."|".implode('|', $arUsers)), Array('FIELDS' => Array("ID"), 'SELECT' => $arSelectParams));
while ($arUser = $dbUsers->GetNext(true, false))
{
$arUserPhone[$arUser['ID']] = $arUser['UF_VI_PHONE'] == 'Y';
$arUserDepartment[$arUser['ID']] = self::IsExtranet($arUser);
}
foreach ($arRecent as $key => $value)
{
if (isset($value['USER']))
{
$arRecent[$key]['USER']['extranet'] = $arUserDepartment[$value['USER']['id']];
$arRecent[$key]['USER']['phone_device'] = $arUserPhone[$value['USER']['id']];
}
}
}
if ($bLoadUnreadMessage)
{
$CIMMessage = new CIMMessage(false, Array(
'HIDE_LINK' => 'Y'
));
$ar = $CIMMessage->GetUnreadMessage(Array(
'LOAD_DEPARTMENT' => 'N',
'ORDER' => 'ASC',
'GROUP_BY_CHAT' => 'Y',
'USE_TIME_ZONE' => $bTimeZone? 'Y': 'N',
'USE_SMILES' => $bSmiles? 'Y': 'N'
));
foreach ($ar['message'] as $data)
{
if (!isset($arRecent[$data['senderId']]))
{
$arRecent[$data['senderId']] = Array(
'TYPE' => IM_MESSAGE_PRIVATE,
'USER' => $ar['users'][$data['senderId']]
);
}
$arRecent[$data['senderId']]['MESSAGE'] = Array(
'id' => $data['id'],
'senderId' => $data['senderId'],
'date' => $data['date'],
'text' => preg_replace('#\-{54}.+?\-{54}#s', " [".GetMessage('IM_QUOTE')."] ", strip_tags(str_replace(array("<br>","<br/>","<br />", "#BR#"), Array(" ", " ", " ", " "), $data['text']), "<img>"))
);
$arRecent[$data['senderId']]['COUNTER'] = $data['counter'];
}
$CIMChat = new CIMChat(false, Array(
'HIDE_LINK' => 'Y'
));
$ar = $CIMChat->GetUnreadMessage(Array(
'ORDER' => 'ASC',
'GROUP_BY_CHAT' => 'Y',
'USER_LOAD' => 'N',
'FILE_LOAD' => 'N',
'USE_SMILES' => $bSmiles? 'Y': 'N',
'USE_TIME_ZONE' => $bTimeZone? 'Y': 'N'
));
foreach ($ar['message'] as $data)
{
if (!isset($arRecent['chat'.$data['recipientId']]))
{
$arRecent['chat'.$data['recipientId']] = Array(
'TYPE' => $ar['messageType']? $ar['messageType']: IM_MESSAGE_CHAT,
'CHAT' => $ar['chat']
);
}
$arRecent['chat'.$data['recipientId']]['MESSAGE'] = Array(
'id' => $data['id'],
'senderId' => $data['senderId'],
'date' => $data['date'],
'text' => $data['text']
);
$arRecent['chat'.$data['recipientId']]['COUNTER'] = $data['counter'];
}
}
if (!empty($arRecent))
{
sortByColumn(
$arRecent,
array(
'COUNTER' => array(SORT_NUMERIC, SORT_DESC),
'MESSAGE' => array(SORT_NUMERIC, SORT_DESC)
),
array(
'COUNTER' => array(__CLASS__, 'GetRecentListSortCounter'),
'MESSAGE' => array(__CLASS__, 'GetRecentListSortMessage'),
),
null, true
);
}
return $arRecent;
}
public static function GetRecentListSortCounter($counter)
{
return !is_null($counter);
}
public static function GetRecentListSortMessage($recent)
{
return $recent['date'];
}
public static function IsExtranet($arUser)
{
$result = false;
if (!IsModuleInstalled('intranet'))
{
return false;
}
if (($arUser['EXTERNAL_AUTH_ID'] ?? null) === \Bitrix\Im\Bot::EXTERNAL_AUTH_ID)
{
return false;
}
if (!\Bitrix\Main\Loader::includeModule('humanresources'))
{
return false;
}
try
{
return !\Bitrix\HumanResources\Service\Container::getUserService()->isEmployee((int)$arUser['ID']);
}
catch (\Exception $exception)
{
return false;
}
}
public static function GetUserPath($userId = false)
{
static $extranetSiteID = false;
$userId = intval($userId);
if (
$extranetSiteID === false
&& CModule::IncludeModule("extranet")
)
{
$extranetSiteID = CExtranet::GetExtranetSiteID();
}
if (IsModuleInstalled('intranet'))
{
$strPathTemplate = COption::GetOptionString(
"socialnetwork",
"user_page",
SITE_DIR.'company/personal/',
(CModule::IncludeModule('extranet') && !CExtranet::IsIntranetUser() ? $extranetSiteID : SITE_ID)
)."user/#user_id#/";
}
else
{
$strPathTemplate = COption::GetOptionString(
"im",
"path_to_user_profile",
"/club/user/#user_id#/",
SITE_ID
);
}
if ($userId <= 0)
{
return $strPathTemplate;
}
else
{
return CComponentEngine::MakePathFromTemplate(
$strPathTemplate,
array("user_id" => $userId)
);
}
}
public static function GetUserNameTemplate($siteId = false, $langId = false, $getDefault = false)
{
if (!$langId && defined('LANGUAGE_ID'))
{
$langId = LANGUAGE_ID;
}
if (in_array($langId, Array('ru', 'kz', 'by', 'ua')))
{
$template = "#LAST_NAME# #NAME#";
}
else
{
$template = "#LAST_NAME#, #NAME#";
}
return $getDefault? $template: COption::GetOptionString("im", "user_name_template", $template, $siteId);
}
public static function GetUserColor($id, $gender)
{
$code = IM\Color::getCodeByNumber($id);
if ($gender == 'M')
{
$replaceColor = IM\Color::getReplaceColors();
if (isset($replaceColor[$code]))
{
$code = $replaceColor[$code];
}
}
return IM\Color::getColor($code);
}
public static function PrepareUserId($id, $searchMark = '')
{
$result = self::PrepareUserIds(Array($id), $searchMark);
return $result[$id];
}
public static function formatAbsentResult($userId)
{
if (!CModule::IncludeModule('intranet'))
{
return false;
}
$result = \Bitrix\Intranet\UserAbsence::isAbsentOnVacation($userId, true);
if ($result)
{
$result = \Bitrix\Main\Type\DateTime::createFromTimestamp($result['DATE_TO_TS']+86400);
}
else
{
$result = false;
}
return $result;
}
public static function PrepareUserIds($userIds, $searchMark = '')
{
$portalId = Array();
$networkId = Array();
$structureId = Array();
foreach ($userIds as $userId)
{
if (mb_substr($userId, 0, 7) == 'network')
{
$networkId[$userId] = mb_substr($userId, 7);
}
elseif (mb_substr($userId, 0, 10) == 'department')
{
$sid = intval(mb_substr($userId, 10));
if ($sid > 0)
{
$structureId[$userId] = $sid;
}
}
elseif (mb_substr($userId, 0, 9) == 'structure')
{
$sid = intval(mb_substr($userId, 9));
if ($sid > 0)
{
$structureId[$userId] = $sid;
}
}
else
{
$userId = intval($userId);
if ($userId > 0)
{
$portalId[$userId] = $userId;
}
}
}
if (!empty($networkId) && CModule::IncludeModule('socialservices'))
{
$network = new \Bitrix\Socialservices\Network();
$networkEnabled = $network->isEnabled();
if ($networkEnabled)
{
$users = $network->addUsersById($networkId, $searchMark);
if ($users)
{
foreach ($users as $networkId => $userId)
{
$portalId['network'.$networkId] = $userId;
}
}
}
}
if (!empty($structureId) && CModule::IncludeModule('intranet'))
{
$orm = \Bitrix\Main\UserTable::getList(Array(
'select' => Array('ID', 'UF_DEPARTMENT'),
'filter' => Array('=ACTIVE' => 'Y', '=UF_DEPARTMENT' => array_values($structureId))
));
while ($row = $orm->fetch())
{
$portalId[$row['ID']] = $row['ID'];
}
}
return $portalId;
}
}
?>