* @copyright Since 2007 PrestaShop SA and Contributors * @license https://opensource.org/licenses/OSL-3.0 Open Software License (OSL 3.0) */ declare(strict_types=1); namespace PrestaShop\PrestaShop\Adapter\Feature\Repository; use Doctrine\DBAL\Connection; use Doctrine\DBAL\Query\QueryBuilder; use PrestaShop\PrestaShop\Core\Domain\Feature\Exception\FeatureNotFoundException; use PrestaShop\PrestaShop\Core\Domain\Feature\ValueObject\FeatureId; use PrestaShop\PrestaShop\Core\Exception\CoreException; use PrestaShop\PrestaShop\Core\Repository\AbstractObjectModelRepository; /** * Methods to access data storage for FeatureValue */ class FeatureRepository extends AbstractObjectModelRepository { /** * @var Connection */ protected $connection; /** * @var string */ protected $dbPrefix; /** * @param Connection $connection * @param string $dbPrefix */ public function __construct( Connection $connection, string $dbPrefix ) { $this->connection = $connection; $this->dbPrefix = $dbPrefix; } /** * @param FeatureId $featureId * * @throws FeatureNotFoundException * @throws CoreException */ public function assertExists(FeatureId $featureId): void { $this->assertObjectModelExists( (int) $featureId->getValue(), 'feature', FeatureNotFoundException::class ); } /** * @param int $langId * * @return array> */ public function getFeaturesByLang(int $langId): array { $qb = $this->getFeaturesQueryBuilder(['id_lang' => $langId]) ->leftJoin('f', $this->dbPrefix . 'feature_lang', 'fl', 'fl.id_feature = f.id_feature AND fl.id_lang = :languageId') ->setParameter('languageId', $langId) ->select('f.*, fl.*') ->addOrderBy('fl.name', 'ASC') ; return $this->formatResult($qb->execute()->fetchAllAssociative()); } /** * @param int|null $limit * @param int|null $offset * @param array|null $filters * * @return array> */ public function getFeatures(?int $limit = null, ?int $offset = null, ?array $filters = []): array { $qb = $this->getFeaturesQueryBuilder($filters) ->select('f.*, fl.*') ->addOrderBy('f.position', 'ASC') ->setFirstResult($offset) ->setMaxResults($limit) ; return $this->formatResult($qb->execute()->fetchAllAssociative()); } /** * @param array|null $filters * * @return int */ public function getFeaturesCount(?array $filters = []): int { $qb = $this->getFeaturesQueryBuilder($filters) ->select('COUNT(f.id_feature_value) AS total_feature_values') ->addGroupBy('f.id_feature_value') ; return (int) $qb->execute()->fetch()['total_feature_values']; } private function formatResult(array $results): array { $localizedNames = []; $featuresById = []; foreach ($results as $result) { $featureId = (int) $result['id_feature']; $localizedNames[$featureId][(int) $result['id_lang']] = $result['name']; $featuresById[$featureId] = [ 'id_feature' => $featureId, 'position' => (int) $result['position'], ]; } $features = []; foreach ($featuresById as $featureById) { $features[] = [ 'id_feature' => $featureById['id_feature'], 'position' => $featureById['position'], 'localized_names' => $localizedNames[$featureById['id_feature']], ]; } return $features; } /** * @param array|null $filters * * @return QueryBuilder */ private function getFeaturesQueryBuilder(?array $filters): QueryBuilder { // Filters not handled yet $qb = $this->connection->createQueryBuilder(); $qb->from($this->dbPrefix . 'feature', 'f'); return $qb; } }