src/Infrastructure/Repository/AbstractRepository.php - develop - AleksWork/diary_plants

src/Infrastructure/Repository/AbstractRepository.php

91 строка2 KB

AlexeySerov

Make change Entiti repository for n+1 requests solution

18 мар 2026, 17:21

18 мар 2026, 17:21836faac

<?php

namespace App\Infrastructure\Repository;

use Doctrine\ORM\QueryBuilder;
use Doctrine\ORM\EntityManagerInterface;
use Doctrine\ORM\Exception\ORMException;
use App\Domain\Entity\Interfaces\EntityInterface;
use Doctrine\ORM\Tools\Pagination\Paginator as DoctrinePaginator;

/**
 * @template T
 */
abstract class AbstractRepository
{
    public function __construct(
        protected readonly EntityManagerInterface $entityManager
    ) {
    }

    /**
     * Получает данные с пагинацией.
     *
     * @param QueryBuilder $queryBuilder
     * @param int $page
     * @param int $perPage
     * @param bool $fetchJoinCollection,
     * @param bool $useOutputWalkers,
     * @return array{plants: object[], pagination: array}
     * @throws \Exception
     */
    protected function getPaginatedResults(
        QueryBuilder $queryBuilder,
        int $page,
        int $perPage,
        bool $fetchJoinCollection = false,
        bool $useOutputWalkers = false,
    ): array {
        $offset = ($page - 1) * $perPage;

        $queryBuilder->setFirstResult($offset)
                        ->setMaxResults($perPage);

        $doctrinePaginator = new DoctrinePaginator($queryBuilder, $fetchJoinCollection);

        $doctrinePaginator->setUseOutputWalkers($useOutputWalkers);

        $totalItems = count($doctrinePaginator);
        $totalPages = (int) ceil($totalItems / $perPage);

        $items = iterator_to_array($doctrinePaginator->getIterator());

        return [
            'items' => $items,
            'pagination' => [
                'first' => $totalItems > 0 ? $offset + 1 : 0,
                'last' => min($offset + $perPage, $totalItems),
                'total' => $totalItems,
                'current' => $page,
                'pages' => $totalPages,
                'count' => $perPage,
            ]
        ];
    }

    protected function flush(): void
    {
        $this->entityManager->flush();
    }

    /**
     * @param EntityInterface $entity
     * @return int
     */
    protected function store(EntityInterface $entity): int
    {
        $this->entityManager->persist($entity);
        $this->flush();

        return $entity->getId();
    }

    /**
     * @param EntityInterface $entity
     * @throws ORMException
     */
    public function refresh(EntityInterface $entity): void
    {
        $this->entityManager->refresh($entity);
    }
}