| Server IP : 37.220.80.31 / Your IP : 18.227.81.153 Web Server : Apache/2.4.52 (Ubuntu) System : Linux 3051455-guretool.twc1.net 5.15.0-107-generic #117-Ubuntu SMP Fri Apr 26 12:26:49 UTC 2024 x86_64 User : www-root ( 1010) PHP Version : 7.4.33 Disable Function : pcntl_alarm,pcntl_fork,pcntl_waitpid,pcntl_wait,pcntl_wifexited,pcntl_wifstopped,pcntl_wifsignaled,pcntl_wexitstatus,pcntl_wtermsig,pcntl_wstopsig,pcntl_signal,pcntl_signal_dispatch,pcntl_get_last_error,pcntl_strerror,pcntl_sigprocmask,pcntl_sigwaitinfo,pcntl_sigtimedwait,pcntl_exec,pcntl_getpriority,pcntl_setpriority, MySQL : OFF | cURL : ON | WGET : OFF | Perl : OFF | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : /var/www/www-root/data/www/dev.artlot24.ru/bitrix/modules/socialservices/lib/ |
Upload File : |
<?php
/**
* Bitrix Framework
* @package bitrix
* @subpackage bitrix24
* @copyright 2001-2015 Bitrix
*/
namespace Bitrix\Socialservices;
use Bitrix\Main\Error;
use Bitrix\Main\ErrorCollection;
use Bitrix\Main\Loader;
use Bitrix\Main\Localization\Loc;
use Bitrix\Main\Config\Option;
use Bitrix\Main\Event;
Loc::loadMessages(__FILE__);
/**
* Integration with Bitrix24.Network
* @package bitrix
* @subpackage socialservices
*/
class Network
{
const ERROR_SEARCH_STRING_TO_SHORT = 'ERROR_SEARCH_STRING_TO_SHORT';
const ERROR_SEARCH_USER_NOT_FOUND = 'ERROR_SEARCH_USER_NOT_FOUND';
const ERROR_REGISTER_USER = 'ERROR_REGISTER_USER';
const ERROR_SOCSERV_TRANSPORT = 'ERROR_SOCSERV_TRANSPORT';
const ERROR_NETWORK_IN_NOT_ENABLED = 'ERROR_NETWORK_IN_NOT_ENABLED';
const ERROR_INCORRECT_PARAMS = 'ERROR_INCORRECT_PARAMS';
const EXTERNAL_AUTH_ID = 'replica';
const ADMIN_SESSION_KEY = "SS_B24NET_STATE";
/** @var ErrorCollection */
public $errorCollection = null;
protected static $lastUserStatus = null;
function __construct()
{
$this->errorCollection = new ErrorCollection();
}
/**
* Returns if option is turned on
*
* @return bool
*/
public function isOptionEnabled()
{
return Option::get('socialservices', 'network_enable', 'N') == 'Y';
}
/**
* Returns if network communication is avalable for current user
*
* @return boolean
*/
public function isEnabled()
{
if(Loader::includeModule('bitrix24'))
{
if(method_exists('CBitrix24', 'isEmailConfirmed') && !\CBitrix24::isEmailConfirmed())
{
return false;
}
}
if(Loader::includeModule('socialservices'))
{
if(\CSocServAuthManager::GetAuthorizedServiceId() !== \CSocServBitrix24Net::ID)
{
if(Loader::includeModule('replica'))
{
global $USER;
if(is_object($USER) && $USER->GetID() > 0 && \Bitrix\Replica\Client\User::getGuid($USER->GetID()) === false)
{
return false;
}
}
else
{
return false;
}
}
}
else
{
return false;
}
return $this->isOptionEnabled();
}
/**
* Enables network communication. Returns true on success.
*
* @param boolean $enable Pass true to enable and false to disable.
*
* @return boolean
*/
public function setEnable($enable = true)
{
if ($this->isOptionEnabled() && $enable)
return true;
if (!$this->isOptionEnabled() && !$enable)
return true;
$query = \CBitrix24NetPortalTransport::init();
if (!$query)
{
$this->errorCollection[] = new Error(Loc::getMessage('B24NET_SOCSERV_TRANSPORT_ERROR'), self::ERROR_SOCSERV_TRANSPORT);
return false;
}
$queryResult = $query->call('feature.enable', array(
'FEATURE' => 'replica',
'STATUS' => (bool)$enable,
));
Option::set('socialservices', 'network_enable', $enable ? 'Y': 'N');
return true;
}
/**
* Searches the network for users by email or nickname.
* Returns array on success and null on failure.
* Check errorCollection public member for errors description.
*
* @param string $search Search query string.
* @return array|null
*/
public function searchUser($search)
{
if (!$this->isEnabled())
{
$this->errorCollection[] = new Error(Loc::getMessage('B24NET_NETWORK_IN_NOT_ENABLED'), self::ERROR_NETWORK_IN_NOT_ENABLED);
return null;
}
$search = trim($search);
if (mb_strlen($search) < 3)
{
$this->errorCollection[] = new Error(Loc::getMessage('B24NET_SEARCH_STRING_TO_SHORT'), self::ERROR_SEARCH_STRING_TO_SHORT);
return null;
}
$query = \CBitrix24NetPortalTransport::init();
if (!$query)
{
$this->errorCollection[] = new Error(Loc::getMessage('B24NET_SOCSERV_TRANSPORT_ERROR'), self::ERROR_SOCSERV_TRANSPORT);
return null;
}
$queryResult = $query->call('profile.search', array(
'QUERY' => $search
));
$result = Array();
foreach ($queryResult['result'] as $user)
{
if (!$user = self::formatUserParam($user))
{
continue;
}
$result[] = $user;
}
return $result;
}
public static function sendMobileApplicationLink($phone, $language_id)
{
$query = \CBitrix24NetPortalTransport::init();
if ($query)
{
$query->call('profile.send', array(
'TYPE' => 'mobile_application_link',
'PHONE' => $phone,
'LANGUAGE_ID' => $language_id,
));
}
}
/**
* @return false|array
* @see \Bitrix\B24network\Rest::portalVerifySend()
* @see \Bitrix\B24network\PhoneVerify::sendVerificationCode()
*/
public static function sendPhoneVerificationCode(string $phone, string $language_id)
{
if (! self::isPhoneNumberValid($phone))
{
return ['error' => 'ERROR_CODE_INVALID_NUMBER'];
}
$phone = self::normalizePhoneNumber($phone);
$query = \CBitrix24NetPortalTransport::init();
if ($query)
{
global $USER;
$userId = $USER instanceof \CUser ? $USER->getId() : 0;
return $query->call('portal.verify.send', array(
'PHONE' => $phone,
'LANGUAGE_ID' => $language_id,
'USER_ID' => $userId,
));
}
return false;
}
/**
* Check portal verification code via b24network
*
* @see \Bitrix\B24network\PhoneVerify::checkVerificationCode()
* @see \Bitrix\B24network\Rest::portalVerifyCheck()
*/
public static function checkPhoneVerificationCode(string $phone, int $code)
{
$phone = self::normalizePhoneNumber($phone);
$query = \CBitrix24NetPortalTransport::init();
if ($query)
{
global $USER;
$userId = $USER instanceof \CUser ? $USER->getId() : 0;
return $query->call('portal.verify.check', array(
'PHONE' => $phone,
'CODE' => $code,
'USER_ID' => $userId,
));
}
return false;
}
/**
* @see \Bitrix\B24network\PhoneVerify::isPortalVerified()
* @see \Bitrix\B24network\Rest::portalVerifyStatus()
*/
public static function getPortalVerificationStatus(): bool
{
$query = \CBitrix24NetPortalTransport::init();
if ($query)
{
$result = $query->call('portal.verify.status');
return (bool)$result['result'];
}
return false;
}
/**
* @param integer $networkId
* @param string $lastSearch
*
* @return array|null
*/
public function getUser($networkId, $lastSearch = '')
{
$result = $this->getUsers(Array($networkId), $lastSearch);
return $result && isset($result[$networkId])? $result[$networkId]: null;
}
/**
* @param array $networkIds
* @param string $lastSearch
*
* @return array|null
*/
public function getUsers($networkIds, $lastSearch = '')
{
if (!$this->isEnabled())
{
$this->errorCollection[] = new Error(Loc::getMessage('B24NET_NETWORK_IN_NOT_ENABLED'), self::ERROR_NETWORK_IN_NOT_ENABLED);
return null;
}
$query = \CBitrix24NetPortalTransport::init();
if (!$query)
{
$this->errorCollection[] = new Error(Loc::getMessage('B24NET_SOCSERV_TRANSPORT_ERROR'), self::ERROR_SOCSERV_TRANSPORT);
return null;
}
if (!is_array($networkIds) || empty($networkIds))
{
$this->errorCollection[] = new Error(Loc::getMessage('B24NET_ERROR_INCORRECT_PARAMS'), self::ERROR_INCORRECT_PARAMS);
return null;
}
$queryResult = $query->call('profile.search', array(
'ID' => array_values($networkIds),
'QUERY' => trim($lastSearch)
));
$result = null;
foreach ($queryResult['result'] as $user)
{
if (!$user = self::formatUserParam($user))
{
continue;
}
$result[$user['NETWORK_ID']] = $user;
}
if (!$result)
{
$this->errorCollection[] = new Error(Loc::getMessage('B24NET_SEARCH_USER_NOT_FOUND'), self::ERROR_SEARCH_USER_NOT_FOUND);
return null;
}
return $result;
}
/**
* @param int $networkId
* @param string $lastSearch
*
* @return integer|false
*/
public function addUserById($networkId, $lastSearch = '')
{
$userId = $this->getUserId($networkId);
if ($userId)
{
return $userId;
}
$user = $this->getUser($networkId, $lastSearch);
if (!$user)
{
return false;
}
return $this->addUser($user);
}
/**
* @param array $networkIds
* @param string $lastSearch
*
* @return array|boolean
*/
public function addUsersById($networkIds, $lastSearch = '')
{
$result = Array();
$users = $this->getUsersId($networkIds);
if ($users)
{
foreach ($users as $networkId => $userId)
{
$result[$networkId] = $userId;
}
$networkIds = array_diff($networkIds, array_keys($users));
}
if (!empty($networkIds))
{
$users = $this->getUsers($networkIds, $lastSearch);
if (!$users)
{
return false;
}
foreach ($users as $networkId => $userParams)
{
$userId = $this->addUser($userParams);
if ($userId)
{
$result[$networkId] = $userId;
}
}
}
return $result;
}
/**
* Add new user to b_user table.
* Returns its identifier or false on failure.
*
* @param array $params
*
* @return integer|false
*/
public function addUser($params)
{
$password = md5($params['XML_ID'].'|'.$params['CLIENT_DOMAIN'].'|'.rand(1000,9999).'|'.time().'|'.uniqid());
$photo = \CFile::MakeFileArray($params['PERSONAL_PHOTO_ORIGINAL']);
$groups = Array();
if(Loader::includeModule('extranet'))
{
$groups[] = \CExtranet::GetExtranetUserGroupID();
}
$addParams = Array(
'LOGIN' => $params['NETWORK_USER_ID'].'@'.$params['CLIENT_DOMAIN'],
'NAME' => $params['NAME'],
'EMAIL' => $params['EMAIL'],
'LAST_NAME' => $params['LAST_NAME'],
'SECOND_NAME' => $params['SECOND_NAME'],
'PERSONAL_GENDER' => $params['PERSONAL_GENDER'],
'PERSONAL_PHOTO' => $photo,
'WORK_POSITION' => $params['CLIENT_DOMAIN'],
'XML_ID' => $params['XML_ID'],
'EXTERNAL_AUTH_ID' => self::EXTERNAL_AUTH_ID,
"ACTIVE" => "Y",
"PASSWORD" => $password,
"CONFIRM_PASSWORD" => $password,
"GROUP_ID" => $groups
);
if (isset($params['EMAIL']))
{
$addParams['EMAIL'] = $params['EMAIL'];
}
$user = new \CUser;
$userId = $user->Add($addParams);
if (intval($userId) <= 0)
{
$this->errorCollection[] = new Error($user->LAST_ERROR, self::ERROR_REGISTER_USER);
return false;
}
$event = new Event("socialservices", "OnAfterRegisterUserByNetwork", array($userId, $params['NETWORK_USER_ID'], $params['CLIENT_DOMAIN']));
$event->send();
return $userId;
}
/**
* @param integer $userId
*
* @return integer|null
*/
public static function getNetworkId($userId)
{
$result = \Bitrix\Main\UserTable::getById($userId);
$user = $result->fetch();
if (!$user || $user['EXTERNAL_AUTH_ID'] != self::EXTERNAL_AUTH_ID)
{
return null;
}
list($networkId, ) = explode('|', $user['XML_ID']);
return $networkId;
}
/**
* @param string $networkId
*
* @return integer|null
*/
public static function getUserId($networkId)
{
$result = self::getUsersId(Array($networkId));
return $result && isset($result[$networkId])? $result[$networkId]: null;
}
/**
* @param array $networkIds
*
* @return array|null
*/
public static function getUsersId($networkIds)
{
if (!is_array($networkIds))
return null;
$searchArray = Array();
foreach ($networkIds as $networkId)
{
$searchArray[] = mb_substr($networkId, 0, 1).intval(mb_substr($networkId, 1))."|%";
}
$result = \Bitrix\Main\UserTable::getList(Array(
'select' => Array('ID', 'WORK_PHONE', 'PERSONAL_PHONE', 'PERSONAL_MOBILE', 'UF_PHONE_INNER', 'XML_ID'),
'filter' => Array('=%XML_ID' => $searchArray, '=EXTERNAL_AUTH_ID' => self::EXTERNAL_AUTH_ID),
'order' => 'ID'
));
$users = Array();
while($user = $result->fetch())
{
list($networkId, ) = explode("|", $user['XML_ID']);
$users[$networkId] = $user['ID'];
}
if (empty($users))
{
$users = null;
}
return $users;
}
/**
* @param array $params
*
* @return array|false
*/
public static function formatUserParam($params)
{
if (empty($params['NAME']))
{
if (!empty($params['PUBLIC_NAME']))
{
$params['NAME'] = $params['PUBLIC_NAME'];
}
else if (!empty($params['EMAIL']))
{
$params['NAME'] = $params['EMAIL'];
}
else
{
return false;
}
}
$result = Array(
'LOGIN' => $params['LOGIN'],
'EMAIL' => $params['EMAIL'],
'NAME' => $params['NAME'],
'LAST_NAME' => $params['LAST_NAME'],
'SECOND_NAME' => $params['SECOND_NAME'],
'PUBLIC_NAME' => $params['PUBLIC_NAME'],
'PERSONAL_GENDER' => $params['PERSONAL_GENDER'],
'PERSONAL_PHOTO' => $params['PERSONAL_PHOTO_RESIZE'],
'PERSONAL_PHOTO_ORIGINAL' => $params['PERSONAL_PHOTO'],
'XML_ID' => $params['ID'].'|'.$params['USER_ID'],
'NETWORK_ID' => $params['ID'],
'NETWORK_USER_ID' => $params['USER_ID'],
'REMOTE_USER_ID' => $params['PROFILE_ID'],
'CLIENT_DOMAIN' => $params['CLIENT_DOMAIN'],
);
return $result;
}
/**
* Prepares and shows popup offerring current user to attach bitrix24.net account
*/
public static function displayAdminPopup(array $params = array())
{
global $USER;
if(static::getAdminPopupSession()) // duplicated check, just to be clear
{
$dbRes = UserTable::getList(array(
'filter' => array(
'=USER_ID' => $USER->GetID(),
'=EXTERNAL_AUTH_ID' => \CSocServBitrix24Net::ID
)
));
if(!$dbRes->fetch())
{
static::initAdminPopup($params);
}
else
{
static::setAdminPopupSession();
}
}
}
public static function initAdminPopup(array $params = array())
{
$option = static::getShowOptions();
\CJSCore::registerExt("socialservices_admin", array(
'js' => "/bitrix/js/socialservices/ss_admin.js",
'css' => "/bitrix/js/socialservices/css/ss_admin.css",
'rel' => array("ajax", "window"),
'lang_additional' => array(
"SS_NETWORK_DISPLAY" => $params["SHOW"] ? "Y" : "N",
"SS_NETWORK_URL" => static::getAuthUrl("popup", array("admin")),
"SS_NETWORK_POPUP_TITLE" => Loc::getMessage('B24NET_POPUP_TITLE'),
"SS_NETWORK_POPUP_CONNECT" => Loc::getMessage('B24NET_POPUP_CONNECT'),
"SS_NETWORK_POPUP_TEXT" => Loc::getMessage('B24NET_POPUP_TEXT'),
"SS_NETWORK_POPUP_DONTSHOW" => Loc::getMessage('B24NET_POPUP_DONTSHOW'),
"SS_NETWORK_POPUP_COUNT" => $option["showcount"],
)
));
\CJSCore::init(array("socialservices_admin"));
}
public static function getAuthUrl($mode = "page", $addScope = null)
{
if(Option::get("socialservices", "bitrix24net_id", "") != "")
{
$o = new \CSocServBitrix24Net();
if($addScope !== null)
{
$o->addScope($addScope);
}
return $o->getUrl($mode);
}
return false;
}
public static function setAdminPopupSession()
{
global $USER;
$_SESSION[static::ADMIN_SESSION_KEY] = $USER->GetID();
}
public static function clearAdminPopupSession($userId)
{
global $USER, $CACHE_MANAGER;
$CACHE_MANAGER->Clean("sso_portal_list_".$userId);
if($userId == $USER->GetID())
{
unset($_SESSION[static::ADMIN_SESSION_KEY]);
}
}
protected static function getShowOptions()
{
return \CUserOptions::GetOption("socialservices", "networkPopup", array("dontshow" => "N", "showcount" => 0));
}
public static function getAdminPopupSession()
{
global $USER;
$result = !isset($_SESSION[static::ADMIN_SESSION_KEY]) || $_SESSION[static::ADMIN_SESSION_KEY] !== $USER->GetID();
if($result)
{
$option = static::getShowOptions();
$result = $option["dontshow"] !== "Y";
if(!$result)
{
static::setAdminPopupSession();
}
}
return $result;
}
public static function setRegisterSettings($settings = array())
{
if(isset($settings["REGISTER"]))
{
Option::set("socialservices", "new_user_registration_network", $settings["REGISTER"] == "Y" ? "Y" : "N");
}
if(isset($settings["REGISTER_CONFIRM"]))
{
Option::set("socialservices", "new_user_registration_confirm", $settings["REGISTER_CONFIRM"] == "Y" ? "Y" : "N");
}
if(isset($settings["REGISTER_WHITELIST"]))
{
$value = preg_split("/[^a-z0-9\-\.]+/", ToLower($settings["REGISTER_WHITELIST"]));
Option::set("socialservices", "new_user_registration_whitelist", serialize($value));
}
if(isset($settings["REGISTER_TEXT"]))
{
Option::set("socialservices", "new_user_registration_text", trim($settings["REGISTER_TEXT"]));
}
if(isset($settings["REGISTER_SECRET"]))
{
Option::set("socialservices", "new_user_registration_secret", trim($settings["REGISTER_SECRET"]));
}
static::updateRegisterSettings();
}
public static function getRegisterSettings()
{
return array(
"REGISTER" => Option::get("socialservices", "new_user_registration_network", "N"),
"REGISTER_CONFIRM" => Option::get("socialservices", "new_user_registration_confirm", "N"),
"REGISTER_WHITELIST" => implode(';', unserialize(Option::get("socialservices", "new_user_registration_whitelist", serialize(array())))),
"REGISTER_TEXT" => Option::get("socialservices", "new_user_registration_text", ""),
"REGISTER_SECRET" => Option::get("socialservices", "new_user_registration_secret", ""),
);
}
protected static function updateRegisterSettings()
{
$query = \CBitrix24NetPortalTransport::init();
if($query)
{
$options = static::getRegisterSettings();
$query->call("portal.option.set", array('options' => array(
'REGISTER' => $options["REGISTER"] === "Y",
'REGISTER_TEXT' => $options["REGISTER_TEXT"],
"REGISTER_SECRET" => $options["REGISTER_SECRET"],
)));
}
}
public static function getLastBroadcastCheck()
{
return Option::get("socialservices", "network_last_update_check", 0);
}
public static function setLastBroadcastCheck()
{
Option::set("socialservices", "network_last_update_check", time());
}
public static function checkBroadcastData()
{
$query = \CBitrix24NetPortalTransport::init();
if ($query)
{
$query->call(
"broadcast.check",
array(
"broadcast_last_check" => static::getLastBroadcastCheck()
)
);
}
}
public static function processBroadcastData($data)
{
ContactTable::onNetworkBroadcast($data);
foreach(GetModuleEvents("socialservices", "OnNetworkBroadcast", true) as $eventHandler)
{
ExecuteModuleEventEx($eventHandler, array($data));
}
static::setLastBroadcastCheck();
}
public static function setLastUserStatus($status)
{
static::$lastUserStatus = $status;
}
public static function getLastUserStatus()
{
return static::$lastUserStatus;
}
private static function normalizePhoneNumber(string $number, $defaultCountry = '')
{
$phoneNumber = \Bitrix\Main\PhoneNumber\Parser::getInstance()->parse($number, $defaultCountry);
return $phoneNumber->format(\Bitrix\Main\PhoneNumber\Format::E164);
}
/**
* @param string $value
* @return bool
*/
private static function isPhoneNumberValid(string $number): bool
{
$phoneNumber = \Bitrix\Main\PhoneNumber\Parser::getInstance()->parse($number);
return $phoneNumber->isValid();
}
}