custom/plugins/DvsnBundle/src/Subscriber/Core/Content/Bundle/BundleWrittenSubscriber.php line 97

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. /**
  4.  * digitvision
  5.  *
  6.  * @category  digitvision
  7.  * @package   Shopware\Plugins\DvsnBundle
  8.  * @copyright (c) 2021 digitvision
  9.  */
  11. namespace Dvsn\Bundle\Subscriber\Core\Content\Bundle;
  13. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  14. use Shopware\Core\Framework\DataAbstractionLayer\EntityWriteResult;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  16. use Shopware\Core\Framework\DataAbstractionLayer\Write\EntityExistence;
  17. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. use Symfony\Component\HttpFoundation\RequestStack;
  20. class BundleWrittenSubscriber implements EventSubscriberInterface
  21. {
  22.     /**
  23.      * ...
  24.      *
  25.      * @var EntityRepositoryInterface
  26.      */
  27.     protected $bundleRepository;
  29.     /**
  30.      * ...
  31.      *
  32.      * @var EntityRepositoryInterface
  33.      */
  34.     protected $bundleProductRepository;
  36.     /**
  37.      * ...
  38.      *
  39.      * @var RequestStack
  40.      */
  41.     protected $requestStack;
  43.     /**
  44.      * ...
  45.      *
  46.      * @param EntityRepositoryInterface $bundleRepository
  47.      * @param EntityRepositoryInterface $bundleProductRepository
  48.      * @param RequestStack $requestStack
  49.      */
  50.     public function __construct(
  51.         EntityRepositoryInterface $bundleRepository,
  52.         EntityRepositoryInterface $bundleProductRepository,
  53.         RequestStack $requestStack
  54.     ) {
  55.         // set params
  56.         $this->bundleRepository = $bundleRepository;
  57.         $this->bundleProductRepository = $bundleProductRepository;
  58.         $this->requestStack = $requestStack;
  59.     }
  61.     /**
  62.      * {@inheritDoc}
  63.      */
  64.     public static function getSubscribedEvents(): array
  65.     {
  66.         return [
  67.             'dvsn_bundle.written' => 'onBundleWritten',
  68.             'dvsn_bundle.deleted' => 'onBundleDeleted',
  69.             'dvsn_bundle_product.written' => 'onBundleProductWritten',
  70.             'dvsn_bundle_product.deleted' => 'onBundleProductDeleted',
  71.         ];
  72.     }
  74.     /**
  75.      * ...
  76.      *
  77.      * @param EntityWrittenEvent $event
  78.      */
  79.     public function onBundleWritten(EntityWrittenEvent $event)
  80.     {
  81.     }
  83.     /**
  84.      * ...
  85.      *
  86.      * @param EntityWrittenEvent $event
  87.      */
  88.     public function onBundleDeleted(EntityWrittenEvent $event)
  89.     {
  90.     }
  92.     /**
  93.      * ...
  94.      *
  95.      * @param EntityWrittenEvent $event
  96.      */
  97.     public function onBundleProductWritten(EntityWrittenEvent $event)
  98.     {
  99.         // loop every entity
  100.         foreach ($event->getWriteResults() as $writeResult) {
  101.             // has to be valid
  102.             if (!$writeResult->getExistence() instanceof EntityExistence) {
  103.                 // ignore
  104.                 continue;
  105.             }
  107.             // switch if we created or updated an answer
  108.             switch ($writeResult->getOperation()) {
  109.                 case EntityWriteResult::OPERATION_UPDATE:
  110.                     // get the payload
  111.                     $payload = $writeResult->getPayload();
  113.                     // get the request
  114.                     $request = $this->requestStack->getCurrentRequest();
  116.                     // do we even have valid products in the request?
  117.                     if (!$request->request->has('products')) {
  118.                         // we dont
  119.                         break;
  120.                     }
  122.                     // get them
  123.                     $products = (array) $request->request->get('products');
  125.                     // the request params for our product
  126.                     $params = null;
  128.                     // find the request for our product
  129.                     foreach ($products as $product) {
  130.                         if ($product['id'] === $payload['id']) {
  131.                             $params = $product;
  132.                             break;
  133.                         }
  134.                     }
  136.                     // not found?
  137.                     if (!is_array($params)) {
  138.                         // weird...
  139.                         break;
  140.                     }
  142.                     // if we set bundle id to null, we want to delete our product
  143.                     $hasBundleId = false;
  144.                     $bundleId = null;
  146.                     // find the id
  147.                     foreach ($params as $key => $value) {
  148.                         if ($key === 'bundleId') {
  149.                             $hasBundleId = true;
  150.                             $bundleId = $value;
  151.                         }
  152.                     }
  154.                     // are we removing the bundle id?! this means we want to remove the product
  155.                     if ($hasBundleId === true && $bundleId === null) {
  156.                         try {
  157.                             // delete it
  158.                             $this->bundleProductRepository->delete([
  159.                                 ['id' => $payload['id']]
  160.                             ], $event->getContext());
  161.                         } catch (\Exception $exception) {}
  162.                     }
  164.                     // done
  165.                     break;
  166.             }
  167.         }
  168.     }
  170.     /**
  171.      * ...
  172.      *
  173.      * @param EntityWrittenEvent $event
  174.      */
  175.     public function onBundleProductDeleted(EntityWrittenEvent $event)
  176.     {
  177.     }
  178. }