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

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\ImportExportAfterImportRecordEvent;
  8. use Shopware\Core\Content\ImportExport\Event\ImportExportBeforeExportRecordEvent;
  9. use Shopware\Core\Content\ImportExport\Event\ImportExportBeforeImportRecordEvent;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\ContainsFilter;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\MultiFilter;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\NotFilter;
  13. use \Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. use Virgin\SystemIntegration\Services\Import\Product\ProductImporter;
  16. class ProductImportExportSubscriber implements EventSubscriberInterface
  17. {
  18. const VIRGIN_SUBSCRIPTION_PROFILE = 'virgin_subscription';
  20. /** @var ProductImporter */
  21. private $productImporter;
  23. /** @var string */
  24. private $salesChannelId;
  26. public function __construct(
  27. ProductImporter $productImporter
  28. ) {
  29. $this->productImporter = $productImporter;
  30. $this->salesChannelId = $productImporter->getSalesChannelId();
  31. }
  33. /**
  34. * @inheritDoc
  35. */
  36. public static function getSubscribedEvents(): array
  37. {
  38. return [
  39. ImportExportBeforeImportRecordEvent::class => 'beforeImportRecord',
  40. ImportExportBeforeExportRecordEvent::class => 'beforeExportRecord',
  41. ImportExportAfterImportRecordEvent::class => 'afterImportRecord',
  42. EnrichExportCriteriaEvent::class => 'enrichExportCriteria'
  43. ];
  44. }
  46. public function afterImportRecord(ImportExportAfterImportRecordEvent $event): void
  47. {
  48. if ($event->getConfig()->get('sourceEntity') !== 'product') {
  49. return;
  50. }
  52. $record = $event->getRecord();
  53. $row = $event->getRow();
  54. $context = $event->getContext();
  56. $productId = $record['id'] ?? null;
  58. if ($productId === null) {
  59. return;
  60. }
  62. $translationData = [
  63. 'meta_title_eng' => $row['Meta title eng'] ?? null,
  64. 'meta_title_ita' => $row['Meta title ita'] ?? null,
  65. 'meta_title_deu' => $row['Meta title deu'] ?? null,
  66. 'meta_description_eng' => $row['Meta description eng'] ?? null,
  67. 'meta_description_ita' => $row['Meta description ita'] ?? null,
  68. 'meta_description_deu' => $row['Meta description deu'] ?? null,
  69. ];
  71. $this->productImporter->upsertProductTranslations($productId, $record['name'], $translationData, $context);
  72. }
  74. /**
  75. * @param ImportExportBeforeImportRecordEvent $event
  76. * @throws Exception
  77. */
  78. public function beforeImportRecord(ImportExportBeforeImportRecordEvent $event): void
  79. {
  80. if ($event->getConfig()->get('sourceEntity') !== 'product') {
  81. return;
  82. }
  84. $context = $event->getContext();
  85. $row = $event->getRow();
  86. $record = [];
  87. foreach ($event->getConfig()->getMapping()->getElements() as $element){
  88. $record[$element->getKey()] = $row[$element->getMappedKey()];
  89. }
  91. try {
  92. if ($event->getConfig()->get('profileName') === self::VIRGIN_SUBSCRIPTION_PROFILE) {
  93. $record = $this->productImporter->convertSubscriptionToProduct($record, $this->salesChannelId);
  94. }
  95. } catch (\Exception $e){
  96. $record['_error'] = $e;
  97. }
  99. $event->setRecord($record);
  100. }
  102. /**
  103. * @param ImportExportBeforeExportRecordEvent $event
  104. * @return void
  105. * @throws Exception
  106. */
  107. public function beforeExportRecord(ImportExportBeforeExportRecordEvent $event): void
  108. {
  109. if ($event->getConfig()->get('sourceEntity') !== 'product') {
  110. return;
  111. }
  113. $record = $event->getRecord();
  115. if (isset($record['_error'])){
  116. return;
  117. }
  118. $originalRecord = $event->getOriginalRecord();
  120. if ($event->getConfig()->get('profileName') == self::VIRGIN_SUBSCRIPTION_PROFILE) {
  121. $record = $this->productImporter->convertProductToSubscription($originalRecord, $record);
  122. }
  124. $event->setRecord($record);
  125. }
  127. public function enrichExportCriteria(EnrichExportCriteriaEvent $event)
  128. {
  129. $criteria = $event->getCriteria();
  131. if ($event->getLogEntity()->getProfile()->getName() == self::VIRGIN_SUBSCRIPTION_PROFILE && $event->getLogEntity()->getActivity() == "export") {
  132. $criteria->addFilter(new NotFilter(MultiFilter::CONNECTION_AND, [new ContainsFilter('productNumber', 'SW')]));
  133. }
  135. $event->setCriteria($criteria);
  136. }
  137. }