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

Open in your IDE?
  1. <?php
  3. /**
  4.  * This file is part of the Pimcore X Installation by
  5.  * ercas GmbH & CO. KG <https://www.ercasdieagentur.de>
  6.  *
  7.  *  @license GPLv3
  8.  */
  10. namespace App\mvk\Import\EventListener;
  12. use App\mvk\Import\Messenger\ImportHighPrioHandler;
  13. use App\mvk\Import\Messenger\ImportLowPrioHandler;
  14. use App\mvk\Import\Messenger\ImportSpecialPrioHandler;
  15. use Pimcore\Bundle\DataImporterBundle\Event\PostPreparationEvent;
  16. use Pimcore\Bundle\DataImporterBundle\PimcoreDataImporterBundle;
  17. use Pimcore\Bundle\DataImporterBundle\Processing\ImportProcessingService;
  18. use Pimcore\Log\ApplicationLogger;
  20. class DataImporterListener
  21. {
  22.     public function __construct(
  23.         protected ImportHighPrioHandler $importHighPrioHandler,
  24.         protected ImportLowPrioHandler $importLowPrioHandler,
  25.         protected ImportSpecialPrioHandler $importSpecialPrioHandler,
  26.         protected ApplicationLogger $applicationLogger,
  27.         protected ImportProcessingService $importProcessingService
  28.     ) {
  29.         $this->applicationLogger = $applicationLogger;
  30.         $this->importProcessingService = $importProcessingService;
  31.     }
  33.     public function importPrepared(PostPreparationEvent $event)
  34.     {
  35.         $configName = $event->getConfigName();
  36.         // add Log Entry with some information about count of changes
  37.         $importStatus = $this->importProcessingService->getImportStatus($configName);
  38.         if (isset($importStatus['isRunning'])) {
  39.             if ($importStatus['isRunning'] === false) {
  40.                 $importStatus['isRunning'] = 'NO';
  41.             } else {
  42.                 $importStatus['isRunning'] = 'YES';
  43.             }
  44.         }
  45.         $message = 'Import Status '.$configName.': '.$this->mapped_implode(', ', $importStatus, ' is ');
  46.         $this->applicationLogger->info($message, [
  47.             'component' => PimcoreDataImporterBundle::LOGGER_COMPONENT_PREFIX . $configName,
  48.         ]);
  50.         if (str_contains($configName, 'Relation_') == true) {
  51.             if ($configName=='Relation_Agent_Policy') {
  52.                 $this->importSpecialPrioHandler->dispatchMessages($event->getExecutionType());
  53.             } else {
  54.                 // if the current config is a relation config use low prio messenger transport. Otherwise always use high transport message
  55.                 $this->importLowPrioHandler->dispatchMessages($event->getExecutionType());
  56.             }
  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.     public function mapped_implode($glue, $array, $symbol = '=')
  67.     {
  68.         return implode($glue, array_map(
  69.             function ($k, $v) use ($symbol) {
  70.                 return $k . $symbol . $v;
  71.             },
  72.             array_keys($array),
  73.             array_values($array)
  74.         )
  75.         );
  76.     }
  77. }