src/mvk/Import/EventListener/DataImporterListener.php line 38

Open in your IDE?
  1. <?php
  3. /**
  4.  * Pimcore
  5.  *
  6.  * This source file is available under two different licenses:
  7.  * - GNU General Public License version 3 (GPLv3)
  8.  * - Pimcore Commercial License (PCL)
  9.  * Full copyright and license information is available in
  10.  * LICENSE.md which is distributed with this source code.
  11.  *
  12.  *  @copyright  Copyright (c) Pimcore GmbH (http://www.pimcore.org)
  13.  *  @license    http://www.pimcore.org/license     GPLv3 and PCL
  14.  */
  16. namespace App\mvk\Import\EventListener;
  18. use Pimcore\Bundle\DataImporterBundle\Event\PostPreparationEvent;
  19. use App\mvk\Import\Messenger\ImportHighPrioHandler;
  20. use App\mvk\Import\Messenger\ImportLowPrioHandler;
  21. use Pimcore\Log\ApplicationLogger;
  22. use Pimcore\Bundle\DataImporterBundle\PimcoreDataImporterBundle;
  23. use Pimcore\Bundle\DataImporterBundle\Processing\ImportProcessingService;
  25. class DataImporterListener
  26. {
  28.     public function __construct(
  29.         protected ImportHighPrioHandler $importHighPrioHandler,
  30.         protected ImportLowPrioHandler $importLowPrioHandler,
  31.         protected ApplicationLogger $applicationLogger,
  32.         protected ImportProcessingService $importProcessingService
  33.     ) {
  34.         $this->applicationLogger = $applicationLogger;
  35.         $this->importProcessingService = $importProcessingService;
  36.     }
  38.     public function importPrepared(PostPreparationEvent $event)
  39.     {
  40.         $configName = $event->getConfigName();
  41.         // add Log Entry with some information about count of changes
  42.         $importStatus = $this->importProcessingService->getImportStatus($configName);
  43.         if (isset($importStatus['isRunning'])) {
  44.             if($importStatus['isRunning'] === false) {
  45.                 $importStatus['isRunning'] = 'NO';
  46.             } else {
  47.                 $importStatus['isRunning'] = 'YES';
  48.             }
  49.         }
  50.         $message = 'Import Status '.$configName.': '.$this->mapped_implode(', ', $importStatus, ' is ');
  51.         $this->applicationLogger->info($message, [
  52.             'component' => PimcoreDataImporterBundle::LOGGER_COMPONENT_PREFIX . $configName,
  53.         ]);
  55.         if (str_contains($configName, 'Relation_') == true) {
  56.             // if the current config is a relation config use low prio messenger transport. Otherwise always use high transport message
  57.             $this->importLowPrioHandler->dispatchMessages($event->getExecutionType());
  58.         } else {
  59.             $this->importHighPrioHandler->dispatchMessages($event->getExecutionType());
  60.         }
  61.     }
  63.     /**
  64.      * helper function to implode the key value pairs from import status return array to a string message for application logger
  65.      */
  66.     function mapped_implode($glue, $array, $symbol = '=') {
  67.         return implode($glue, array_map(
  68.             function($k, $v) use($symbol) { 
  69.                 return $k . $symbol . $v;
  70.             }, 
  71.             array_keys($array), 
  72.             array_values($array)
  73.             )
  74.         );
  75.     }
  76. }