custom/plugins/FTBPlugin/src/Subscriber/FTBSubscriber.php line 41

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace FTBPlugin\Subscriber;
  5. use Monolog\Logger;
  6. use Shopware\Core\Checkout\Customer\CustomerEvents;
  7. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\RangeFilter;
  11. use Shopware\Storefront\Page\Search\SearchPageLoadedEvent;
  12. use Shopware\Storefront\Page\Suggest\SuggestPageLoadedEvent;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. class FTBSubscriber implements EventSubscriberInterface
  16. {
  18.     private $search_notfound_repository;
  19.     private $logger;
  21.     public function __construct(Logger $logger, EntityRepositoryInterface $dreiwm_search_notfound_repo)
  22.     {
  23.         $this->logger = $logger;
  24.         $this->search_notfound_repository = $dreiwm_search_notfound_repo;
  25.     }
  27.     public static function getSubscribedEvents(): array
  28.     {
  29.         return [
  30.             SuggestPageLoadedEvent::class => 'onSearch',
  31.             SearchPageLoadedEvent::class => 'onSearchPage',
  32.             CustomerEvents:: CUSTOMER_REGISTER_EVENT => 'customerRegistered',
  33.         ];
  34.     }
  36.     /**
  37.      * Suche (Ergebniss-Seite):
  38.      * Wenn bei einer Suche keine Ergebnisse gefunden werden, soll der String, nach dem gesucht wird,
  39.      * in die DB gespeichert werden
  40.      */
  41.     public function onSearchPage(SearchPageLoadedEvent $event)
  42.     {
  43.         if ($event->getPage()->getListing()->getTotal() === 0) {
  44.             $this->saveSearchTerm(
  45.                 $event->getPage()->getSearchTerm(),
  46.                 $event->getContext()
  47.             );
  48.         }
  49.     }
  51.     /**
  52.      * Ajax-Suche (Live):
  53.      * Wenn bei einer Suche keine Ergebnisse gefunden werden, soll der String, nach dem gesucht wird,
  54.      * in die DB gespeichert werden
  55.      */
  56.     public function onSearch(SuggestPageLoadedEvent $event)
  57.     {
  58.         if ($event->getPage()->getSearchResult()->getTotal() === 0) {
  59.             $this->saveSearchTerm(
  60.                 $event->getPage()->getSearchTerm(),
  61.                 $event->getContext()
  62.             );
  63.         }
  64.     }
  66.     /**
  67.      * schreiben den Searchterm in die DB
  68.      */
  69.     private function saveSearchTerm($as_searchTerm, $context)
  70.     {
  71.         $sessionId = session_id();
  72.         try {
  73.             if ($this->searchTermNotWritten($as_searchTerm, $sessionId, $context)) {
  75.                 $this->search_notfound_repository
  76.                     ->create([
  77.                         [
  78.                             'searchTerm' => strip_tags($as_searchTerm),
  79.                             'session' => $sessionId ?: '',
  80.                             'date' => new \DateTime()
  81.                         ]
  82.                     ], $context);
  83.             }
  84.         } catch (\Exception $e) {
  85.             $this->logger->error($e->getMessage(), ['exception' => $e]);
  86.         }
  87.     }
  89.     /**
  90.      * Return true, wenn es bereits nicht geschrieben wurde
  91.      * retunr false, wenn es bereits min einen Eintrag gibt.
  92.      * @param $as_searchTerm
  93.      * @param $as_sessionId
  94.      * @param $context
  95.      * @return bool
  96.      */
  97.     private function searchTermNotWritten($as_searchTerm, $as_sessionId, $context)
  98.     {
  99.         $criteria = new Criteria([]);
  100.         $criteria->addFilter(new EqualsFilter('session', $as_sessionId));
  101.         $criteria->addFilter(new EqualsFilter('searchTerm', $as_searchTerm));
  102.         $criteria->addFilter(new RangeFilter('date', [
  103.             RangeFilter::GTE => date('Y-m-d H:i:s', strtotime('now -2min')),
  104.         ]));
  106.         $res = $this->search_notfound_repository->search($criteria, $context);
  107.         return $res->count() === 0;
  108.     }
  109. }