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

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace NetInventors\NetiNextEasyCoupon\Subscriber;
  7. use NetInventors\NetiNextEasyCoupon\Core\Content\Condition\ConditionCollection;
  8. use NetInventors\NetiNextEasyCoupon\Core\Content\Transaction\TransactionCollection;
  9. use NetInventors\NetiNextEasyCoupon\Service\Account\VoucherTransactionsService;
  10. use NetInventors\NetiNextEasyCoupon\Service\ExportService;
  11. use Psr\Log\LoggerInterface;
  12. use Shopware\Core\Content\ImportExport\Event\ImportExportBeforeExportRecordEvent;
  13. use Shopware\Core\Framework\Context;
  14. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  16. use Shopware\Core\Framework\DataAbstractionLayer\Search\EntitySearchResult;
  17. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  18. use Shopware\Core\Framework\DataAbstractionLayer\Search\Sorting\FieldSorting;
  19. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  21. class ExportSubscriber implements EventSubscriberInterface
  22. {
  23.     /**
  24.      * @var EntityRepositoryInterface
  25.      */
  26.     private $conditionRepository;
  28.     /**
  29.      * @var VoucherTransactionsService
  30.      */
  31.     private                 $voucherTransactionsService;
  34.     private ExportService   $exportService;
  36.     /**
  37.      * ExportSubscriber constructor.
  38.      *
  39.      * @param EntityRepositoryInterface $conditionRepository
  40.      */
  41.     public function __construct(
  42.         EntityRepositoryInterface  $conditionRepository,
  43.         VoucherTransactionsService $voucherTransactionsService,
  44.         ExportService              $exportService
  45.     ) {
  46.         $this->conditionRepository        = $conditionRepository;
  47.         $this->voucherTransactionsService = $voucherTransactionsService;
  48.         $this->exportService              = $exportService;
  49.     }
  51.     public static function getSubscribedEvents()
  52.     {
  53.         return [
  54.             ImportExportBeforeExportRecordEvent::class => 'beforeExport',
  55.         ];
  56.     }
  58.     public function beforeExport(ImportExportBeforeExportRecordEvent $event)
  59.     {
  60.         if (
  61.             'neti_easy_coupon' !== $event->getConfig()->get('sourceEntity')
  62.             || null !== $event->getConfig()->getMapping()->get('_error')
  63.         ) {
  64.             return;
  65.         }
  67.         $record = $event->getRecord();
  68.         if (isset($record['virtual_import']) && $record['virtual_import'] !== '') {
  69.             return;
  70.         }
  72.         /** @var ConditionCollection $conditions */
  73.         $conditions = $this->getCouponConditions($record['id'])->getEntities();
  75.         /** @var TransactionCollection $voucherTransactions */
  76.         $voucherTransactions = $this->voucherTransactionsService->getTransactionsForVouchers([$record['id']])->getEntities();
  77.         $record['virtual_import'] = \json_encode(
  78.             $this->exportService->buildVirtualImport(
  79.                 $conditions,
  80.                 $voucherTransactions,
  81.                 $record
  82.             )
  83.         );
  85.         $this->exportService->handleVoucherValues($record, $voucherTransactions);
  87.         $event->setRecord($record);
  88.     }
  90.     /**
  91.      * @param string $couponId
  92.      *
  93.      * @return EntitySearchResult
  94.      */
  95.     private function getCouponConditions(string $couponId): EntitySearchResult
  96.     {
  97.         $criteria = new Criteria();
  99.         $criteria->addFilter(new EqualsFilter('couponId', $couponId));
  100.         $criteria->addSorting(new FieldSorting('createdAt', FieldSorting::ASCENDING));
  102.         return $this->conditionRepository->search($criteria, Context::createDefaultContext());
  103.     }
  104. }