115 lines
		
	
	
		
			4.6 KiB
		
	
	
	
		
			PHP
		
	
	
	
	
	
			
		
		
	
	
			115 lines
		
	
	
		
			4.6 KiB
		
	
	
	
		
			PHP
		
	
	
	
	
	
<?php
 | 
						|
 | 
						|
/*
 | 
						|
 * This file is part of the package thucke/th-rating.
 | 
						|
 *
 | 
						|
 * For the full copyright and license information, please read the
 | 
						|
 * LICENSE file that was distributed with this source code.
 | 
						|
 */
 | 
						|
 | 
						|
namespace WapplerSystems\BookmarksLikesRatings\Domain\Repository;
 | 
						|
 | 
						|
use WapplerSystems\BookmarksLikesRatings\Domain\Model\Ratingobject;
 | 
						|
use WapplerSystems\BookmarksLikesRatings\Domain\Validator\RatingobjectValidator;
 | 
						|
use WapplerSystems\BookmarksLikesRatings\Exception\RecordNotFoundException;
 | 
						|
use WapplerSystems\BookmarksLikesRatings\Service\ExtensionHelperService;
 | 
						|
use TYPO3\CMS\Extbase\Configuration\ConfigurationManagerInterface;
 | 
						|
use TYPO3\CMS\Extbase\Persistence\Repository;
 | 
						|
use TYPO3\CMS\Extbase\Utility\LocalizationUtility;
 | 
						|
 | 
						|
/**
 | 
						|
 * A repository for rating objects
 | 
						|
 */
 | 
						|
class RatingobjectRepository extends Repository
 | 
						|
{
 | 
						|
    /**
 | 
						|
     * Defines name for function parameter
 | 
						|
     */
 | 
						|
    public const ADD_IF_NOT_FOUND = true;
 | 
						|
 | 
						|
    /**
 | 
						|
     * @var \WapplerSystems\BookmarksLikesRatings\Service\ExtensionHelperService
 | 
						|
     */
 | 
						|
    protected $extensionHelperService;
 | 
						|
 | 
						|
    /**
 | 
						|
     * @param \WapplerSystems\BookmarksLikesRatings\Service\ExtensionHelperService $extensionHelperService
 | 
						|
     */
 | 
						|
    public function injectExtensionHelperService(ExtensionHelperService $extensionHelperService): void
 | 
						|
    {
 | 
						|
        $this->extensionHelperService = $extensionHelperService;
 | 
						|
    }
 | 
						|
 | 
						|
    /**
 | 
						|
     * @var \TYPO3\CMS\Extbase\Configuration\ConfigurationManagerInterface
 | 
						|
     */
 | 
						|
    protected $configurationManager;
 | 
						|
    /**
 | 
						|
     * @param \TYPO3\CMS\Extbase\Configuration\ConfigurationManagerInterface $configurationManager
 | 
						|
     */
 | 
						|
    public function injectConfigurationManager(ConfigurationManagerInterface $configurationManager): void
 | 
						|
    {
 | 
						|
        $this->configurationManager = $configurationManager;
 | 
						|
    }
 | 
						|
 | 
						|
    /**
 | 
						|
     * Finds the specific ratingobject by giving table and fieldname
 | 
						|
     *
 | 
						|
     * @param string $ratetable The tablename of the ratingobject
 | 
						|
     * @param string $ratefield The fieldname of the ratingobject
 | 
						|
     * @param bool $addIfNotFound Set to true if new objects should instantly be added
 | 
						|
     * @return \WapplerSystems\BookmarksLikesRatings\Domain\Model\Ratingobject The ratingobject
 | 
						|
     * @throws RecordNotFoundException
 | 
						|
     * @throws \TYPO3\CMS\Extbase\Persistence\Exception\IllegalObjectTypeException
 | 
						|
     */
 | 
						|
    public function findMatchingTableAndField(string $ratetable, string $ratefield, bool $addIfNotFound = false): Ratingobject
 | 
						|
    {
 | 
						|
        /** @var \WapplerSystems\BookmarksLikesRatings\Domain\Model\Ratingobject $foundRow */
 | 
						|
        $foundRow = $this->objectManager->get(Ratingobject::class);
 | 
						|
 | 
						|
        $query = $this->createQuery();
 | 
						|
 | 
						|
        $query->matching($query->logicalAnd([
 | 
						|
            $query->equals('ratetable', $ratetable),
 | 
						|
            $query->equals('ratefield', $ratefield),
 | 
						|
        ]))->setLimit(1);
 | 
						|
 | 
						|
        /*$queryParser = $this->objectManager->get(\TYPO3\CMS\Extbase\Persistence\Generic\Storage\Typo3DbQueryParser::class);
 | 
						|
        \TYPO3\CMS\Extbase\Utility\DebuggerUtility::var_dump($queryParser->convertQueryToDoctrineQueryBuilder($query)->getSQL(), get_class($this).' SQL');
 | 
						|
        \TYPO3\CMS\Extbase\Utility\DebuggerUtility::var_dump($queryParser->convertQueryToDoctrineQueryBuilder($query)->getParameters(), get_class($this).' SQL Parameter');*/
 | 
						|
 | 
						|
        /** @var \TYPO3\CMS\Extbase\Persistence\QueryResultInterface $queryResult */
 | 
						|
        $queryResult = $query->execute();
 | 
						|
 | 
						|
        if ($queryResult->count() > 0) {
 | 
						|
            $foundRow = $queryResult->getFirst();
 | 
						|
        } elseif ($addIfNotFound) {
 | 
						|
            $foundRow->setRatetable($ratetable);
 | 
						|
            $foundRow->setRatefield($ratefield);
 | 
						|
 | 
						|
            if (!$this->objectManager->get(RatingobjectValidator::class)->validate($foundRow)->hasErrors()) {
 | 
						|
                $this->add($foundRow);
 | 
						|
            }
 | 
						|
            $this->extensionHelperService->persistRepository(self::class, $foundRow);
 | 
						|
            $foundRow = $this->findMatchingTableAndField($ratetable, $ratefield);
 | 
						|
        } else {
 | 
						|
            throw new RecordNotFoundException(LocalizationUtility::translate('recordNotFound', 'ThRating'), 1567962473);
 | 
						|
        }
 | 
						|
        return $foundRow;
 | 
						|
    }
 | 
						|
 | 
						|
    /**
 | 
						|
     * Finds the specific ratingobject by giving table and fieldname
 | 
						|
     *
 | 
						|
     * @param bool   Switch to fetch ALL entries regardless of their pid
 | 
						|
     * @return \TYPO3\CMS\Extbase\Persistence\QueryResultInterface|array All ratingobjects of the site
 | 
						|
     */
 | 
						|
    /** @noinspection PhpMissingParentCallCommonInspection */
 | 
						|
    public function findAll($ignoreStoragePage = false)
 | 
						|
    {
 | 
						|
        $query = $this->createQuery();
 | 
						|
        $query->getQuerySettings()->setRespectStoragePage(!$ignoreStoragePage);
 | 
						|
        return $query->execute();
 | 
						|
    }
 | 
						|
}
 |