UserCollection.php

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

<?php
 
namespace Bitrix\Im\V2\Entity\User;
 
use Bitrix\Im\Model\StatusTable;
use Bitrix\Im\V2\Entity\EntityCollection;
use Bitrix\Main\ORM\Fields\Relations\Reference;
use Bitrix\Main\ORM\Query\Join;
use Bitrix\Main\UserTable;

class UserCollection extends EntityCollection
{
    public function __construct(array $usersIds = [])
    {
        parent::__construct();
 
        foreach ($usersIds as $userId)
        {
            $this[] = User::getInstance($userId);
        }
    }
 
    public function fillOnlineData(bool $withStatus = false): void
    {
        $idsUsersWithoutOnlineData = [];
 
        foreach ($this as $user)
        {
            if (!$user->isOnlineDataFilled($withStatus))
            {
                $idsUsersWithoutOnlineData[] = $user->getId();
            }
        }
 
        $idsUsersWithoutOnlineData = array_unique($idsUsersWithoutOnlineData);
 
        if (empty($idsUsersWithoutOnlineData))
        {
            return;
        }
 
        $select = $withStatus ? User::ONLINE_DATA_SELECTED_FIELDS : User::ONLINE_DATA_SELECTED_FIELDS_WITHOUT_STATUS;
        $query = UserTable::query()
            ->setSelect($select)
            ->whereIn('ID', $idsUsersWithoutOnlineData)
        ;
        if ($withStatus)
        {
            $query->registerRuntimeField(
                new Reference(
                    'STATUS',
                    StatusTable::class,
                    Join::on('this.ID', 'ref.USER_ID'),
                    ['join_type' => Join::TYPE_LEFT]
                )
            );
        }
        $statusesData = $query->fetchAll() ?: [];
 
        foreach ($statusesData as $statusData)
        {
            $this->getById((int)$statusData['USER_ID'])->setOnlineData($statusData, $withStatus);
        }
    }
 
    public static function filterUserIds(array $userIds, callable $predicate, ?int $limit = null): array
    {
        $filteredUserIds = [];
        foreach ($userIds as $userId)
        {
            if ($limit !== null && count($filteredUserIds) >= $limit)
            {
                return $filteredUserIds;
            }
 
            $user = User::getInstance((int)$userId);
            if ($predicate($user))
            {
                $filteredUserIds[(int)$userId] = (int)$userId;
            }
        }
 
        return $filteredUserIds;
    }
 
    public static function hasUserByType(array $userIds, UserType $type): bool
    {
        $filter = static fn (User $user) => $user->getType() === $type;
        $firstUserByType = static::filterUserIds($userIds, $filter, 1);
 
        return !empty($firstUserByType);
    }
 
    public function toRestFormat(array $option = []): array
    {
        $this->fillOnlineData();
 
        return parent::toRestFormat($option);
    }
 
    public static function getRestEntityName(): string
    {
        return 'users';
    }

    public function offsetSet($offset, $value): void
    {
        if (!$value->isExist())
        {
            return;
        }
 
        parent::offsetSet($offset, $value);
    }
}