custom/plugins/NetiNextStoreLocator/src/Subscriber/EntitySubscriber.php line 68

Open in your IDE?
  1. <?php
  3. namespace NetInventors\NetiNextStoreLocator\Subscriber;
  5. use NetInventors\NetiNextStoreLocator\Components\EntityFilter;
  6. use NetInventors\NetiNextStoreLocator\Components\GeoLocation\GeoLocation;
  7. use NetInventors\NetiNextStoreLocator\Components\GeoLocation\Struct\Address;
  8. use NetInventors\NetiNextStoreLocator\Core\Content\Store\StoreEntity;
  9. use NetInventors\NetiNextStoreLocator\Storefront\Framework\Seo\SeoUrlRoute\StorePageSeoUrlRoute;
  10. use Psr\Log\LoggerInterface;
  11. use Shopware\Core\Content\Seo\SeoUrlUpdater;
  12. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  15. use Shopware\Core\Framework\Log\LoggingService;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. class EntitySubscriber implements EventSubscriberInterface
  19. {
  20.     /**
  21.      * @var EntityFilter
  22.      */
  23.     private $entityFilter;
  25.     /**
  26.      * @var GeoLocation
  27.      */
  28.     private $geoLocation;
  30.     private $cnt;
  32.     /**
  33.      * @var EntityRepositoryInterface
  34.      */
  35.     private $repository;
  37.     /**
  38.      * @var LoggerInterface
  39.      */
  40.     private $logger;
  42.     /**
  43.      * @var SeoUrlUpdater
  44.      */
  45.     private $seoUrlUpdater;
  47.     public function __construct(
  48.         EntityFilter              $entityFilter,
  49.         GeoLocation               $geoLocation,
  50.         EntityRepositoryInterface $repository,
  51.         LoggerInterface           $logger,
  52.         SeoUrlUpdater             $seoUrlUpdater
  53.     ) {
  54.         $this->entityFilter  = $entityFilter;
  55.         $this->geoLocation   = $geoLocation;
  56.         $this->repository    = $repository;
  57.         $this->logger        = $logger;
  58.         $this->seoUrlUpdater = $seoUrlUpdater;
  59.     }
  61.     public static function getSubscribedEvents(): array
  62.     {
  63.         return [
  64.             'neti_store_locator.written' => 'onWritten',
  65.         ];
  66.     }
  68.     public function onWritten(EntityWrittenEvent $event): void
  69.     {
  70.         $this->seoUrlUpdater->update(StorePageSeoUrlRoute::ROUTE_NAME, $event->getIds());
  72.         $ids = $this->entityFilter->getAffectedIDs($event);
  74.         if (!empty($ids)) {
  75.             /**
  76.              * @psalm-suppress MixedArgumentTypeCoercion
  77.              *
  78.              * This is the correct way to search for a specific ID
  79.              */
  80.             $criteria = new Criteria($ids);
  81.             $entities = $this->repository->search($criteria, $event->getContext());
  82.             $updates  = [];
  84.             /** @var StoreEntity $entity */
  85.             foreach ($entities as $entity) {
  86.                 $address = Address::createFrom($entity);
  88.                 try {
  89.                     $coords   = $this->geoLocation->getCoords($address);
  90.                     $timezone = $this->geoLocation->getTimezone($coords);
  92.                     $updates[] = [
  93.                         'id'            => $entity->getId(),
  94.                         'longitude'     => $coords->getLongitude(),
  95.                         'latitude'      => $coords->getLatitude(),
  96.                         'googlePlaceID' => $coords->getPlaceId(),
  97.                         'timezone'      => $timezone,
  98.                     ];
  99.                 } catch (\Exception $ex) {
  100.                     $this->logger->notice(
  101.                         'Unable to get the coordinates for the address of a store',
  102.                         [
  103.                             'exception' => $ex->getMessage(),
  104.                         ]
  105.                     );
  106.                 }
  107.             }
  109.             if (!empty($updates)) {
  110.                 $this->repository->update($updates, $event->getContext());
  111.             }
  112.         }
  113.     }
  114. }