.-.-.-.-.-

<?
namespace Bitrix\Socialservices;

use \Bitrix\Main\Entity\DataManager;
use \Bitrix\Socialservices\UserTable as SocservUserTable;

class UserLinkTable extends DataManager
{
	public static function getFilePath()
	{
		return __FILE__;
	}

public static function getTableName()
	{
		return 'b_socialservices_user_link';
	}

public static function getMap()
	{
		$fieldsMap = array(
			'ID' => array(
				'data_type' => 'integer',
				'primary' => true,
				'autocomplete' => true,
			),
			'USER_ID' => array(
				'data_type' => 'integer',
				'required' => true,
			),
			'SOCSERV_USER_ID' => array(
				'data_type' => 'integer',
				'required' => true,
			),
			'LINK_USER_ID' => array(
				'data_type' => 'integer',
			),
			'LINK_UID' => array(
				'data_type' => 'string',
				'required' => true,
			),
			'LINK_NAME' => array(
				'data_type' => 'string',
			),
			'LINK_LAST_NAME' => array(
				'data_type' => 'string',
			),
			'LINK_PICTURE' => array(
				'data_type' => 'string',
			),
			'USER' => array(
				'data_type' => 'Bitrix\Main\UserTable',
				'reference' => array('=this.USER_ID' => 'ref.ID'),
			),
			'SOCSERV_USER' => array(
				'data_type' => 'Bitrix\Socialservices\UserTable',
				'reference' => array('=this.SOCSERV_USER_ID' => 'ref.ID'),
			),
			'LINK_USER' => array(
				'data_type' => 'Bitrix\Main\UserTable',
				'reference' => array('=this.LINK_USER_ID' => 'ref.ID'),
			),
		);

return $fieldsMap;
	}

public static function deleteBySocserv($userId, $socservProfileId)
	{
		$connection = \Bitrix\Main\Application::getConnection();
		$query = $connection->query("
DELETE
FROM ".self::getTableName()."
WHERE USER_ID='".intval($userId)."' AND SOCSERV_USER_ID='".intval($socservProfileId)."'
");
	}

public static function compareUserLinks($userId, $socservUserId, $links)
	{
		$dbRes = static::getList(array(
			'filter' => array(
				//'USER_ID' => $userId, // link USER_ID doesn't update with socserv_user
				'=SOCSERV_USER_ID' => $socservUserId,
			),
			'select' => array('ID', 'LINK_UID')
		));

$currentList = array();
		while($linkInfo = $dbRes->fetch())
		{
			$currentList[$linkInfo['LINK_UID']] = $linkInfo['ID'];
		}

foreach($links as $key => $link)
		{
			if(array_key_exists($link['uid'], $currentList))
			{
				unset($currentList[$link['uid']]);
				unset($links[$key]);
			}
		}

foreach($currentList as $linkId)
		{
			static::delete($linkId);
		}

foreach($links as $link)
		{
			static::add(array(
				'USER_ID' => $userId,
				'SOCSERV_USER_ID' => $socservUserId,
				'LINK_USER_ID' => null, // !!!!!!
				'LINK_UID' => $link['uid'],
				'LINK_NAME' => $link['first_name'],
				'LINK_LAST_NAME' => $link['last_name'],
				'LINK_PICTURE' => $link['picture'],
			));
		}
	}

public static function checkUserLinks($socservUserId)
	{
		$dbRes = UserTable::getByPrimary($socservUserId);
		$socservUserInfo = $dbRes->fetch();
		if($socservUserInfo)
		{
			$connection = \Bitrix\Main\Application::getConnection();
			$sqlHelper = $connection->getSqlHelper();

$sql = "
SELECT sul.ID, su_link.USER_ID
FROM ".static::getTableName()." sul
LEFT JOIN ".SocservUserTable::getTableName()." su_link ON sul.LINK_UID=su_link.XML_ID
WHERE (1=1)
AND sul.SOCSERV_USER_ID='".intval($socservUserInfo['ID'])."'
AND su_link.EXTERNAL_AUTH_ID='".$sqlHelper->forSql($socservUserInfo['EXTERNAL_AUTH_ID'])."'
AND sul.LINK_USER_ID IS NULL
";

return $connection->query($sql);
		}
		else
		{
			return false;
		}
	}
}

/var/./files/need-2-delete/mini-borishof.ru1/bitrix/modules/socialservices/./lib/userlink.php