network.php

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

<?php
 
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__);

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";

    public $errorCollection = null;
 
    protected static $lastUserStatus = null;
 
    function __construct()
    {
        $this->errorCollection = new ErrorCollection();
    }

    public function isOptionEnabled()
    {
        return false;
    }

    public function isEnabled()
    {
        return false;
    }

    public function setEnable($enable = true)
    {
        if ($this->isOptionEnabled() && $enable)
            return true;
 
        if (!$this->isOptionEnabled() && !$enable)
            return true;
 
        $this->errorCollection[] = new Error(Loc::getMessage('B24NET_NETWORK_IN_NOT_ENABLED_MSGVER_1'), self::ERROR_NETWORK_IN_NOT_ENABLED);
 
        return false;
    }

    public function searchUser($search)
    {
        $this->errorCollection[] = new Error(Loc::getMessage('B24NET_NETWORK_IN_NOT_ENABLED_MSGVER_1'), self::ERROR_NETWORK_IN_NOT_ENABLED);
        return null;
    }

    public function getUser($networkId, $lastSearch = '')
    {
        $result = $this->getUsers(Array($networkId), $lastSearch);
 
        return $result && isset($result[$networkId])? $result[$networkId]: null;
    }

    public function getUsers($networkIds, $lastSearch = '')
    {
        if (!$this->isEnabled())
        {
            $this->errorCollection[] = new Error(Loc::getMessage('B24NET_NETWORK_IN_NOT_ENABLED_MSGVER_1'), self::ERROR_NETWORK_IN_NOT_ENABLED);
            return null;
        }
 
        $query = \CBitrix24NetPortalTransport::init();
        if (!$query)
        {
            $this->errorCollection[] = new Error(Loc::getMessage('B24NET_SOCSERV_TRANSPORT_ERROR_MSGVER_1'), 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;
    }

    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);
    }

    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;
    }

    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;
    }

    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;
    }

    public static function getUserId($networkId)
    {
        $result = self::getUsersId(Array($networkId));
 
        return $result && isset($result[$networkId])? $result[$networkId]: 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;
    }

    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;
    }
 
    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 = !isset($option["dontshow"]) || $option["dontshow"] !== "Y";
            if(!$result)
            {
                static::setAdminPopupSession();
            }
        }
 
        return $result;
    }
 
    public static function setLastUserStatus($status)
    {
        static::$lastUserStatus = $status;
    }
 
    public static function getLastUserStatus()
    {
        return static::$lastUserStatus;
    }
}