usertag.php

<?php
namespace Bitrix\Socialnetwork;
 
use Bitrix\Main\Entity;
use Bitrix\Main\NotImplementedException;
 
 
class UserTagTable extends Entity\DataManager
{
    public static function getTableName()
    {
        return 'b_sonet_user_tag';
    }
 
    public static function getMap()
    {
        $fieldsMap = array(
            'USER_ID' => array(
                'data_type' => 'integer',
                'primary' => true
            ),
            'USER' => array(
                'data_type' => 'Bitrix\Main\UserTable',
                'reference' => array('=this.USER_ID' => 'ref.ID'),
            ),
            'NAME' => array(
                'data_type' => 'string',
                'primary' => true,
                'save_data_modification' => function() {
                    return array(
                        function ($text)
                        {
                            return ToLower($text);
                        }
                    );
                },
                'fetch_data_modification' => function() {
                    return array(
                        function ($text)
                        {
                            return ToLower($text);
                        }
                    );
                }
            )
        );
 
        return $fieldsMap;
    }
 
    public static function add(array $data)
    {
        try
        {
            $result = parent::add($data);
        }
        catch(\Exception $e)
        {
            $result = false;
        }
 
        return $result;
    }
 
    public static function getUserTagCountData($params = array())
    {
        global $DB;
 
        $connection = \Bitrix\Main\HttpApplication::getConnection();
 
        $result = array();
 
        $userId = (
            !empty($params['userId'])
                ? intval($params['userId'])
                : false
        );
 
        $params['tagName'] = $params['tagName'] ?? null;
 
        $tagName = (
            (is_array($params['tagName']) && !empty($params['tagName']))
            || (!is_array($params['tagName']) && $params['tagName'] <> '')
                ? $params['tagName']
                : false
        );
 
        $nameFilter = (
            $tagName !== false
                ? (is_array($tagName)) ? " IN (".implode(',', array_map(function($val) use ($DB) { return "'".$DB->forSql($val)."'"; }, $tagName)).")" : " = '".$DB->forSql($tagName)."'"
                : ($userId ? ' IN (SELECT NAME FROM '.self::getTableName().' WHERE USER_ID = '.$userId.')' : '')
        );
 
        $whereClause = "WHERE U.ACTIVE='Y' ".(!empty($nameFilter) ? 'AND UT.NAME '.$nameFilter : '');
 
        $sql = '
            SELECT CASE WHEN (MIN(USER_ID) = 0) THEN COUNT(USER_ID)-1 ELSE COUNT(USER_ID) END AS CNT, UT.NAME AS NAME
            FROM '.self::getTableName().' UT 
            INNER JOIN b_user U ON U.ID=UT.USER_ID '.
            $whereClause.' 
            GROUP BY UT.NAME
        ';
 
        $res = $connection->query($sql);
        while ($tagData = $res->fetch())
        {
            $result[$tagData['NAME']] = $tagData['CNT'];
        }
 
        return $result;
    }
 
    public static function getUserTagTopData($params = array())
    {
        global $USER, $DB;
 
        $result = array();
 
        $userId = (
            !empty($params['userId'])
                ? intval($params['userId'])
                : false
        );
 
        $topCount = (
            isset($params['topCount'])
                ? intval($params['topCount'])
                : 0
        );
 
        if ($topCount <= 0)
        {
            $topCount = 2;
        }
 
        if ($topCount > 5)
        {
            $topCount = 5;
        }
 
        $avatarSize = (
            isset($params['avatarSize'])
                ? intval($params['avatarSize'])
                : 100
        );
 
        $connection = \Bitrix\Main\Application::getConnection();
        $connection->queryExecute('SET @user_rank = 0');
        $connection->queryExecute('SET @current_entity_id = 0');
 
        $params['tagName'] = $params['tagName'] ?? null;
 
        $tagName = (
            (is_array($params['tagName']) && !empty($params['tagName']))
            || (!is_array($params['tagName']) && $params['tagName'] <> '')
                ? $params['tagName']
                : false
        );
 
        $nameFilter = (
            $tagName !== false
                ? (is_array($tagName)) ? " NAME IN (".implode(',', array_map(function($val) use ($DB) { return "'".$DB->forSql($val)."'"; }, $tagName)).")" : " NAME = '".$DB->forSql($tagName)."'"
                : ($userId ? " USER_ID = ".$userId : "")
        );
 
        $whereClause = (!empty($nameFilter) ? 'WHERE '.$nameFilter : '');
 
        $tagsSql = 'SELECT NAME FROM '.self::getTableName().' '.$whereClause;
 
        if (\Bitrix\Main\ModuleManager::isModuleInstalled('intranet'))
        {
            $ratingId = \CRatings::getAuthorityRating();
            if (intval($ratingId) <= 0)
            {
                return $result;
            }
 
            $res = $connection->query("SELECT /*+ NO_DERIVED_CONDITION_PUSHDOWN() */
                @user_rank := IF(
                    @current_name = tmp.NAME,
                    @user_rank + 1,
                    1
                ) as USER_RANK,
                @current_name := tmp.NAME,
                tmp.USER_ID as USER_ID,
                tmp.NAME as NAME,
                tmp.WEIGHT as WEIGHT
            FROM (
                SELECT /*+ NO_DERIVED_CONDITION_PUSHDOWN() */
                    @rownum := @rownum + 1 as ROWNUM,
                    RS1.ENTITY_ID as USER_ID,
                    UT1.NAME as NAME,
                    MAX(RS1.VOTES) as WEIGHT
                FROM
                    b_rating_subordinate RS1,
                    ".self::getTableName()." UT1
                INNER JOIN b_user U ON U.ID = UT1.USER_ID
                WHERE
                    RS1.RATING_ID = ".intval($ratingId)."
                    AND RS1.ENTITY_ID = UT1.USER_ID
                    AND UT1.NAME IN (".$tagsSql.")
                    AND U.ACTIVE = 'Y'
                GROUP BY
                    UT1.NAME, RS1.ENTITY_ID
                ORDER BY
                    UT1.NAME,
                    WEIGHT DESC
            ) tmp");
        }
        else
        {
            $res = $connection->query("SELECT /*+ NO_DERIVED_CONDITION_PUSHDOWN() */
                @user_rank := IF(
                    @current_name = tmp.NAME,
                    @user_rank + 1,
                    1
                ) as USER_RANK,
                tmp.USER_ID as USER_ID,
                tmp.NAME as NAME,
                1 as WEIGHT
            FROM (
                SELECT /*+ NO_DERIVED_CONDITION_PUSHDOWN() */
                    @rownum := @rownum + 1 as ROWNUM,
                    UT1.USER_ID as USER_ID,
                    UT1.NAME as NAME
                FROM
                    ".self::getTableName()." UT1
                INNER JOIN b_user U ON U.ID = UT1.USER_ID
                WHERE
                    UT1.NAME IN (".$tagsSql.")
                    AND U.ACTIVE = 'Y'
                ORDER BY
                    UT1.NAME
            ) tmp");
        }
 
        $userWeightData = $tagUserData = array();
 
        $currentTagName = false;
        $hasMine = false;
 
        while ($resultFields = $res->fetch())
        {
            if (
                !$hasMine
                && $resultFields['USER_ID'] == $USER->getId()
            )
            {
                $hasMine = true;
            }
 
            if ($resultFields['NAME'] != $currentTagName)
            {
                $cnt = 0;
                $hasMine = false;
                $tagUserData[$resultFields['NAME']] = array();
            }
 
            $currentTagName = $resultFields['NAME'];
            $cnt++;
 
            if ($cnt > ($hasMine ? $topCount+1 : $topCount))
            {
                continue;
            }
 
            $tagUserData[$resultFields['NAME']][] = $resultFields['USER_ID'];
            if (!isset($userWeightData[$resultFields['USER_ID']]))
            {
                $userWeightData[$resultFields['USER_ID']] = floatval($resultFields['WEIGHT']);
            }
        }
 
        $userData = \Bitrix\Socialnetwork\Item\UserTag::getUserData([
            'userIdList' => array_keys($userWeightData),
            'avatarSize' => $avatarSize
        ]);
 
        foreach($tagUserData as $tagName => $userIdList)
        {
            $result[$tagName] = array();
 
            foreach($userIdList as $userId)
            {
                $result[$tagName][] = array(
                    'ID' => $userId,
                    'NAME_FORMATTED' => $userData[$userId]['NAME_FORMATTED'],
                    'PERSONAL_PHOTO' => $userData[$userId]['PERSONAL_PHOTO']['ID'],
                    'PERSONAL_PHOTO_SRC' => $userData[$userId]['PERSONAL_PHOTO']['SRC'],
                    'PERSONAL_GENDER' => $userData[$userId]['PERSONAL_GENDER'],
                    'WEIGHT' => $userWeightData[$userId]
                );
            }
        }
 
        foreach($result as $tagName => $data)
        {
            usort(
                $data,
                function($a, $b)
                {
                    if ($a['WEIGHT'] == $b['WEIGHT'])
                    {
                        return 0;
                    }
                    return ($a['WEIGHT'] > $b['WEIGHT']) ? -1 : 1;
                }
            );
            $result[$tagName] = $data;
        }
 
        return $result;
    }
 
    public static function update($primary, array $data)
    {
        throw new NotImplementedException("Use add() method of the class.");
    }
}