custom/plugins/NetiNextEasyCoupon/src/Subscriber/ExportSubscriber.php line 41

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace NetInventors\NetiNextEasyCoupon\Subscriber;
  7. use NetInventors\NetiNextEasyCoupon\Core\Content\Condition\ConditionEntity;
  8. use Shopware\Core\Content\ImportExport\Event\ImportExportBeforeExportRecordEvent;
  9. use Shopware\Core\Framework\Context;
  10. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Search\EntitySearchResult;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\Sorting\FieldSorting;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. class ExportSubscriber implements EventSubscriberInterface
  18. {
  19.     /**
  20.      * @var EntityRepositoryInterface
  21.      */
  22.     private $conditionRepository;
  24.     /**
  25.      * ExportSubscriber constructor.
  26.      *
  27.      * @param EntityRepositoryInterface $conditionRepository
  28.      */
  29.     public function __construct(EntityRepositoryInterface $conditionRepository)
  30.     {
  31.         $this->conditionRepository = $conditionRepository;
  32.     }
  34.     public static function getSubscribedEvents()
  35.     {
  36.         return [
  37.             ImportExportBeforeExportRecordEvent::class => 'beforeExport',
  38.         ];
  39.     }
  41.     public function beforeExport(ImportExportBeforeExportRecordEvent $event)
  42.     {
  43.         if ('neti_easy_coupon' !== $event->getConfig()->get('sourceEntity')) {
  44.             return;
  45.         }
  47.         $record          = $event->getRecord();
  48.         $conditions      = $this->getCouponConditions($record['id']);
  49.         $conditionsArray = [];
  51.         if ($conditions->getElements() !== []) {
  52.             /** @var ConditionEntity $condition */
  53.             foreach ($conditions->getElements() as $condition) {
  54.                 $conditionArray             = [];
  55.                 $conditionArray['id']       = $condition->getId();
  56.                 $conditionArray['couponId'] = $condition->getCouponId();
  57.                 $conditionArray['parentId'] = $condition->getParentId();
  58.                 $conditionArray['value']    = $condition->getValue();
  59.                 $conditionArray['position'] = $condition->getPosition();
  61.                 //getType crashes if the return value not a string, for some reason we also save a null value
  62.                 // there for a dirty solution is needed
  63.                 try {
  64.                     $conditionArray['type'] = $condition->getType();
  65.                 } catch (\TypeError $exception) {
  66.                     $conditionArray['type'] = null;
  67.                 }
  68.                 $conditionsArray[] = $conditionArray;
  69.             }
  70.         }
  72.         $jsonConditions       = json_encode($conditionsArray);
  73.         $record['conditions'] = $jsonConditions;
  75.         $event->setRecord($record);
  76.     }
  78.     /**
  79.      * @param string $couponId
  80.      *
  81.      * @return EntitySearchResult
  82.      */
  83.     private function getCouponConditions(string $couponId): EntitySearchResult
  84.     {
  85.         $criteria = new Criteria();
  87.         $criteria->addFilter(new EqualsFilter('couponId', $couponId));
  88.         $criteria->addSorting(new FieldSorting('createdAt', FieldSorting::ASCENDING));
  90.         return $this->conditionRepository->search($criteria, Context::createDefaultContext());
  91.     }
  92. }