PinCollection.php

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

<?php
 
namespace Bitrix\Im\V2\Link\Pin;
 
use Bitrix\Im\Model\EO_LinkPin_Collection;
use Bitrix\Im\Model\LinkPinTable;
use Bitrix\Im\V2\Common\SidebarFilterProcessorTrait;
use Bitrix\Im\V2\Entity\File\FilePopupItem;
use Bitrix\Im\V2\Entity\User\UserPopupItem;
use Bitrix\Im\V2\Link\BaseLinkCollection;
use Bitrix\Im\V2\Link\Reminder\ReminderPopupItem;
use Bitrix\Im\V2\Message\AdditionalMessagePopupItem;
use Bitrix\Im\V2\MessageCollection;
use Bitrix\Im\V2\Rest\PopupData;
use Bitrix\Im\V2\Service\Context;
use Bitrix\Im\V2\Service\Locator;
use Bitrix\Main\ORM\Query\Query;

class PinCollection extends BaseLinkCollection
{
    use SidebarFilterProcessorTrait;
 
    public static function find(
        array $filter,
        array $order = ['ID' => 'DESC'],
        ?int $limit = null,
        ?Context $context = null
    ): self
    {
        $context = $context ?? Locator::getContext();
 
        $pinOrder = ['ID' => 'DESC'];
 
        if (isset($order['ID']))
        {
            $pinOrder['ID'] = $order['ID'];
        }
 
        $query = LinkPinTable::query()
            ->setSelect(['ID', 'CHAT_ID', 'AUTHOR_ID', 'DATE_CREATE', 'MESSAGE_ID'])
            ->setOrder($pinOrder)
        ;
        if (isset($limit))
        {
            $query->setLimit($limit);
        }
 
        static::processFilters($query, $filter, $pinOrder);
 
        return static::initByEntityCollection($query->fetchCollection());
    }
 
    public static function initByEntityCollection(EO_LinkPin_Collection $entityCollection): self
    {
        $pinCollection = new static();
 
        foreach ($entityCollection as $entity)
        {
            $pinCollection[] = PinItem::initByEntity($entity);
        }
 
        return $pinCollection;
    }
 
    public static function getByMessages(MessageCollection $messages): self
    {
        $entities = LinkPinTable::query()
            ->setSelect(['ID', 'CHAT_ID', 'AUTHOR_ID', 'DATE_CREATE', 'MESSAGE_ID'])
            ->whereIn('MESSAGE_ID', $messages->getIds())
            ->fetchCollection()
        ;
 
        if ($entities === null)
        {
            return new static();
        }
 
        $links = static::initByEntityCollection($entities);
 
        foreach ($links as $link)
        {
            $messageId = $link->getMessageId();
 
            if (!isset($messageId))
            {
                continue;
            }
 
            $link->setEntity($messages[$messageId]);
        }
 
        return $links;
    }
 
    public static function getCollectionElementClass(): string
    {
        return PinItem::class;
    }
 
    public static function getRestEntityName(): string
    {
        return 'pins';
    }
 
    protected static function processFilters(Query $query, array $filter, array $order): void
    {
        static::processSidebarFilters($query, $filter, $order);
    }
 
    public function getAuthorIds(): array
    {
        $authorIds = [];
        foreach ($this as $item)
        {
            $authorIds[$item->getAuthorId()] = $item->getAuthorId();
        }
 
        return $authorIds;
    }
 
    public function getMessageIds(): array
    {
        $messageIds = [];
        foreach ($this as $item)
        {
            $messageIds[$item->getMessageId()] = $item->getMessageId();
        }
 
        return $messageIds;
    }
}