custom/plugins/GbmedEnev/src/Subscriber/ImportExport.php line 52

Open in your IDE?
  1. <?php declare(strict_types=1);
  2. /**
  3.  * gb media
  4.  * All Rights Reserved.
  5.  *
  6.  * Unauthorized copying of this file, via any medium is strictly prohibited.
  7.  * The content of this file is proprietary and confidential.
  8.  *
  9.  * @category       Shopware
  10.  * @package        Shopware_Plugins
  11.  * @subpackage     GbmedEnev
  12.  * @copyright      Copyright (c) 2019, gb media
  13.  * @license        proprietary
  14.  * @author         Giuseppe Bottino
  15.  * @link           http://www.gb-media.biz
  16.  */
  18. namespace Gbmed\Enev\Subscriber;
  20. use Gbmed\Enev\Core\Content\Enev\EnevDefinition;
  21. use Gbmed\Enev\Service\ImportExport as ImportExportService;
  22. use Shopware\Core\Content\ImportExport\Event\ImportExportBeforeExportRecordEvent;
  23. use Shopware\Core\Content\ImportExport\Event\ImportExportBeforeImportRecordEvent;
  24. use Shopware\Core\Framework\Context;
  25. use Shopware\Core\Framework\Uuid\Uuid;
  26. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  28. class ImportExport implements EventSubscriberInterface
  29. {
  30.     private ImportExportService $productService;
  32.     /**
  33.      * @param ImportExportService $productService
  34.      */
  35.     public function __construct(
  36.         ImportExportService $productService
  37.     ) {
  38.         $this->productService = $productService;
  39.     }
  41.     public static function getSubscribedEvents(): array
  42.     {
  43.         return [
  44.             ImportExportBeforeExportRecordEvent::class => 'onExportRecord',
  45.             ImportExportBeforeImportRecordEvent::class => 'onImportRecord',
  46.         ];
  47.     }
  49.     /**
  50.      * @param ImportExportBeforeExportRecordEvent $event
  51.      */
  52.     public function onExportRecord(ImportExportBeforeExportRecordEvent $event): void
  53.     {
  54.         if($event->getConfig()->get('sourceEntity') !== EnevDefinition::ENTITY_NAME){
  55.             return;
  56.         }
  58.         $record = $event->getRecord();
  59.         $context = Context::createDefaultContext();
  60.         $product = $this->productService->findProductById($record['product'], $context);
  62.         if ($product) {
  63.             $record['product'] = $product->getProductNumber();
  64.         }
  66.         $event->setRecord($record);
  67.     }
  69.     /**
  70.      * @param ImportExportBeforeImportRecordEvent $event
  71.      */
  72.     public function onImportRecord(ImportExportBeforeImportRecordEvent $event): void
  73.     {
  74.         if($event->getConfig()->get('sourceEntity') !== EnevDefinition::ENTITY_NAME){
  75.             return;
  76.         }
  78.         $context = $event->getContext();
  79.         $row = $event->getRow();
  80.         $record = array_merge(
  81.             $event->getRecord(),
  82.             [
  83.                 'productId' => $row['product'],
  84.                 'mediaId' => $row['media'],
  85.                 'datasheetId' => $row['datasheet'],
  86.                 'iconId' => $row['icon'],
  87.             ]
  88.         );
  89.         $record = $this->productService->getMedias($record, $context);
  90.         $product = $this->productService->findProductByNumber($record['productId'], $context);
  92.         if ($product) {
  93.             $record['productId'] = $product->getId();
  94.         }
  96.         $event->setRecord($this->productService->prepareData($record));
  97.     }
  98. }