custom/plugins/SystemIntegration/src/Subscribers/ProductImportExportSubscriber.php line 48

Open in your IDE?
  1. <?php
  3. namespace Virgin\SystemIntegration\Subscribers;
  5. use Exception;
  6. use Shopware\Core\Content\ImportExport\Event\EnrichExportCriteriaEvent;
  7. use Shopware\Core\Content\ImportExport\Event\ImportExportBeforeExportRecordEvent;
  8. use Shopware\Core\Content\ImportExport\Event\ImportExportBeforeImportRecordEvent;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\ContainsFilter;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\MultiFilter;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\NotFilter;
  12. use \Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. use Virgin\SystemIntegration\Services\Import\Product\ProductImporter;
  15. class ProductImportExportSubscriber implements EventSubscriberInterface
  16. {
  17. const VIRGIN_SUBSCRIPTION_PROFILE = 'virgin_subscription';
  19. /** @var ProductImporter */
  20. private $productImporter;
  22. /** @var string */
  23. private $salesChannelId;
  25. public function __construct(
  26. ProductImporter $productImporter
  27. ) {
  28. $this->productImporter = $productImporter;
  29. $this->salesChannelId = $productImporter->getSalesChannelId();
  30. }
  32. /**
  33. * @inheritDoc
  34. */
  35. public static function getSubscribedEvents(): array
  36. {
  37. return [
  38. ImportExportBeforeImportRecordEvent::class => 'beforeImportRecord',
  39. ImportExportBeforeExportRecordEvent::class => 'beforeExportRecord',
  40. EnrichExportCriteriaEvent::class => 'enrichExportCriteria'
  41. ];
  42. }
  44. /**
  45. * @param ImportExportBeforeImportRecordEvent $event
  46. * @throws Exception
  47. */
  48. public function beforeImportRecord(ImportExportBeforeImportRecordEvent $event): void
  49. {
  50. if ($event->getConfig()->get('sourceEntity') !== 'product') {
  51. return;
  52. }
  54. $row = $event->getRow();
  55. $record = [];
  56. foreach ($event->getConfig()->getMapping()->getElements() as $element){
  57. $record[$element->getKey()] = $row[$element->getMappedKey()];
  58. }
  60. try {
  61. if ($event->getConfig()->get('profileName') === self::VIRGIN_SUBSCRIPTION_PROFILE) {
  62. $record = $this->productImporter->convertSubscriptionToProduct($record, $this->salesChannelId);
  63. }
  64. } catch (\Exception $e){
  65. $record['_error'] = $e;
  66. }
  68. $event->setRecord($record);
  69. }
  71. /**
  72. * @param ImportExportBeforeExportRecordEvent $event
  73. * @return void
  74. * @throws Exception
  75. */
  76. public function beforeExportRecord(ImportExportBeforeExportRecordEvent $event): void
  77. {
  78. if ($event->getConfig()->get('sourceEntity') !== 'product') {
  79. return;
  80. }
  82. $record = $event->getRecord();
  84. if (isset($record['_error'])){
  85. return;
  86. }
  87. $originalRecord = $event->getOriginalRecord();
  89. if ($event->getConfig()->get('profileName') == self::VIRGIN_SUBSCRIPTION_PROFILE) {
  90. $record = $this->productImporter->convertProductToSubscription($originalRecord, $record);
  91. }
  93. $event->setRecord($record);
  94. }
  96. public function enrichExportCriteria(EnrichExportCriteriaEvent $event)
  97. {
  98. $criteria = $event->getCriteria();
  100. if ($event->getLogEntity()->getProfile()->getName() == self::VIRGIN_SUBSCRIPTION_PROFILE && $event->getLogEntity()->getActivity() == "export") {
  101. $criteria->addFilter(new NotFilter(MultiFilter::CONNECTION_AND, [new ContainsFilter('productNumber', 'SW')]));
  102. }
  104. $event->setCriteria($criteria);
  105. }
  106. }