vendor/store.shopware.com/hatslogicswsearchkeywordhistory/src/Subscriber/SearchSubscriber.php line 53

Open in your IDE?
  1. <?php declare(strict_types=1);
  2. /**
  3.  * (c) 2Hats Logic Solutions <info@2hatslogic.com>
  4.  */
  6. namespace Hatslogic\Sw\SearchKeywordHistory\Subscriber;
  8. use Shopware\Core\Defaults;
  9. use Doctrine\DBAL\Connection;
  10. use Shopware\Core\Framework\Context;
  11. use Shopware\Core\Framework\Uuid\Uuid;
  12. use Symfony\Component\Routing\RouterInterface;
  13. use Shopware\Storefront\Page\Search\SearchPageLoadedEvent;
  14. use Symfony\Component\DependencyInjection\ContainerInterface;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  17. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  19. class SearchSubscriber implements EventSubscriberInterface
  20. {
  21.    /**
  22.      * @var ContainerInterface
  23.      */
  24.     protected $container;
  26.     /**
  27.      * @var Connection
  28.      */
  29.     private $connection;
  31.     /**
  32.      * @var RouterInterface
  33.      */
  34.     private $router;
  36.     public function __construct(
  37.         ContainerInterface $container, 
  38.         Connection $connection,
  39.         RouterInterface $router
  40.     ) {
  41.         $this->container = $container;
  42.         $this->connection = $connection;
  43.         $this->router = $router;
  44.     }
  46.     public static function getSubscribedEvents(): array
  47.     {
  48.         return [
  49.             SearchPageLoadedEvent::class => 'onSearchPageLoaded'
  50.         ];
  51.     }
  53.     public function onSearchPageLoaded(SearchPageLoadedEvent $event)
  54.     {
  55.         $request = $event->getRequest();
  57.         $searchKeyword = $request->get('search');
  59.         if(empty($searchKeyword))
  60.         {
  61.             return;
  62.         }
  64.         $keywordAlreadyExist = $this->getDetailsByKeyWord($searchKeyword);
  66.         if($keywordAlreadyExist)
  67.         {
  68.             //Update count and last search date
  69.             $params = [
  70.                 'id'           => $keywordAlreadyExist->getId(),
  71.                 'searchCount'  => $keywordAlreadyExist->getSearchCount() + 1,
  72.                 'lastSearchAt' => (new \DateTime())->format(Defaults::STORAGE_DATE_TIME_FORMAT)
  73.             ];
  75.             $this->updateCountAndLastSearchDate($params);
  76.         } else {
  77.             // Save
  78.             $params = [
  79.                 'id'           => Uuid::randomHex(),
  80.                 'keyword'      => $searchKeyword,
  81.                 'searchCount'  => 1,
  82.                 'lastSearchAt' => (new \DateTime())->format(Defaults::STORAGE_DATE_TIME_FORMAT)
  83.             ];
  85.             $this->saveSearchKeyWord($params);
  86.         }
  88.         return;
  89.     }
  91.     public function saveSearchKeyWord($params)
  92.     {
  93.         if(empty($params))
  94.         {
  95.             return;
  96.         }
  98.         $this->container->get('s_plugin_hatslogic_search_keywords.repository')
  99.             ->create([$params], Context::createDefaultContext());
  101.         return;
  102.     }
  104.     public function getDetailsByKeyWord($keyword)
  105.     {
  106.         $criteria = (new Criteria())
  107.             ->addFilter(new EqualsFilter(
  108.             's_plugin_hatslogic_search_keywords.keyword', $keyword));
  110.         $result = $this->container->get('s_plugin_hatslogic_search_keywords.repository')->search($criteria, Context::createDefaultContext());
  112.         $searchKeyWordDetails = $result->first();
  114.         return ($searchKeyWordDetails) ? $searchKeyWordDetails: null;
  115.     }
  117.     public function updateCountAndLastSearchDate($params)
  118.     {
  119.         if(empty($params))
  120.         {
  121.             return;
  122.         }
  124.         $this->container->get('s_plugin_hatslogic_search_keywords.repository')->update(
  125.             [
  126.                 [
  127.                     'id'           => $params['id'],
  128.                     'searchCount'  => $params['searchCount'],
  129.                     'lastSearchAt' => $params['lastSearchAt']
  130.                 ],
  131.             ],
  132.             Context::createDefaultContext()
  133.         );
  135.         return true;
  136.     }
  137. }