custom/static-plugins/HbHAlphaplanCustoms/src/Subscriber/ProductSubscriber.php line 66

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace HbHAlphaplanCustoms\Subscriber;
  5. use Shopware\Core\Content\Product\ProductEntity;
  6. use Shopware\Core\Framework\Context;
  7. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  10. use Shopware\Core\Framework\Struct\ArrayEntity;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityLoadedEvent;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. use Shopware\Core\Content\Product\ProductEvents;
  14. use Symfony\Component\HttpKernel\Event\RequestEvent;
  15. use Symfony\Component\HttpKernel\KernelEvents;
  17. class ProductSubscriber implements EventSubscriberInterface
  18. {
  19.     public EntityRepository $cvsKProductRepository;
  21.     public function __construct(EntityRepository $cvsKProductRepository)
  22.     {
  23.         $this->cvsKProductRepository = $cvsKProductRepository;
  24.     }
  26.     public static function getSubscribedEvents(): array
  27.     {
  28.         return [
  29.             ProductEvents::PRODUCT_LOADED_EVENT => 'onProductsLoaded',
  30.             KernelEvents::REQUEST => 'onKernelRequest'
  31.         ];
  32.     }
  34.     public function onKernelRequest(RequestEvent $event)
  35.     {
  36.         $request = $event->getRequest();
  37.         $controller = $request->attributes->get('_controller');
  38.         $params = explode('::',$controller);
  40.         if($request->getMethod() === "POST" && stripos($params[0], 'SyncController') !== false){
  42.             $content = json_decode($request->getContent(), true);
  44.             if(
  45.                 isset($content[0]['payload'][0]['manufacturerId']) &&
  46.                 $content[0]['payload'][0]['manufacturerId'] === "0" &&
  47.                 $content[0]['entity'] === 'product' &&
  48.                 $content[0]['action'] === 'upsert' &&
  49.                 $content[0]['key'] === 'write'
  50.             ){
  51.                 $content[0]['payload'][0]['manufacturerId'] = null;
  53.                 $request->initialize(
  54.                     $request->query->all(),
  55.                     $request->request->all(),
  56.                     $request->attributes->all(),
  57.                     $request->cookies->all(),
  58.                     $request->files->all(),
  59.                     $request->server->all(),
  60.                     json_encode($content)
  61.                 );
  62.             }
  63.         }
  64.     }
  66.     public function onProductsLoaded(EntityLoadedEvent $event): void
  67.     {
  68.         /** @var ProductEntity $productEntity */
  69.         foreach ($event->getEntities() as $productEntity) {
  71.             $data = $this->getData($productEntity->getId(), $event->getContext());
  72.             if($data !== null){
  73.                 $productEntity->addExtension('cvs_product_extension', new ArrayEntity(['K_ArzneimittelPflichtText' => $data->getKArzneimittelPflichtText()]));
  74.             }
  75.         }
  76.     }
  78.     private function getData($productId, Context $context){
  80.         $criteria = new Criteria();
  81.         $criteria->addFilter(new EqualsFilter("productId", $productId));
  83.         $result = $this->cvsKProductRepository->search($criteria, $context);
  85.         return $result->getEntities()->first();
  86.     }
  87. }