vendor/blackbit/data-director/EventListener/AutomaticImportListener.php line 125

Open in your IDE?
  1. <?php
  2. /**
  3.  * Copyright Blackbit digital Commerce GmbH <info@blackbit.de>
  4.  *
  5.  * This program is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation; either version 3 of the License, or (at your option) any later version.
  6.  *
  7.  * This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details.
  8.  *
  9.  * You should have received a copy of the GNU General Public License along with this program; if not, write to the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
  10.  */
  12. namespace Blackbit\DataDirectorBundle\EventListener;
  14. use Blackbit\DataDirectorBundle\Controller\ImportController;
  15. use Blackbit\DataDirectorBundle\lib\Pim\Helper;
  16. use Blackbit\DataDirectorBundle\lib\Pim\Import\CallbackFunction;
  17. use Blackbit\DataDirectorBundle\lib\Pim\Item\ImporterInterface;
  18. use Blackbit\DataDirectorBundle\lib\Pim\Item\ItemMoldBuilder;
  19. use Blackbit\DataDirectorBundle\lib\Pim\RawData\Importer;
  20. use Blackbit\DataDirectorBundle\lib\Pim\Serializer;
  21. use Blackbit\DataDirectorBundle\model\Dataport;
  22. use Blackbit\DataDirectorBundle\model\DataportResource;
  23. use Blackbit\DataDirectorBundle\model\Fieldmapping;
  24. use Blackbit\DataDirectorBundle\model\ImportStatus;
  25. use Blackbit\DataDirectorBundle\model\PimcoreDbRepository;
  26. use Blackbit\DataDirectorBundle\model\Queue;
  27. use Blackbit\DataDirectorBundle\model\RawItem;
  28. use Blackbit\DataDirectorBundle\model\RawItemData;
  29. use Blackbit\DataDirectorBundle\Tools\Installer;
  30. use InvalidArgumentException;
  31. use Pimcore\Db;
  32. use Pimcore\Event\Model\AssetEvent;
  33. use Pimcore\Event\Model\ElementEventInterface;
  34. use Pimcore\Logger;
  35. use Pimcore\Model\AbstractModel;
  36. use Pimcore\Model\Asset;
  37. use Pimcore\Model\DataObject\AbstractObject;
  38. use Pimcore\Model\DataObject\Concrete;
  39. use Pimcore\Model\Element\DirtyIndicatorInterface;
  40. use Pimcore\Model\Element\ElementInterface;
  41. use Pimcore\Model\Element\Service;
  42. use Pimcore\Model\User;
  43. use Pimcore\Model\Version;
  44. use Pimcore\Tool;
  45. use Blackbit\DataDirectorBundle\lib\Pim\Cli;
  46. use Psr\Log\LoggerAwareInterface;
  47. use Psr\Log\LoggerAwareTrait;
  48. use Psr\Log\LoggerInterface;
  49. use Symfony\Component\HttpFoundation\Request;
  51. class AutomaticImportListener implements LoggerAwareInterface
  52. {
  53.     use LoggerAwareTrait;
  55.     private static $processCommandRegistered = [];
  57.     private static $dataports = null;
  59.     private static $hasAutomaticDataports = null;
  61.     /** @var ItemMoldBuilder */
  62.     private $itemMoldBuilder;
  64.     public function __construct(ItemMoldBuilder $itemMoldBuilder)
  65.     {
  66.         $this->itemMoldBuilder = $itemMoldBuilder;
  67.     }
  69.     private static function getDataports() {
  70.         if(self::$dataports === null) {
  71.             self::$dataports = Dataport::getInstance()->find([], 'name');
  72.         }
  74.         return self::$dataports;
  75.     }
  77.     private function hasAutomaticDataports() {
  78.         if(self::$hasAutomaticDataports === null) {
  79.             self::$hasAutomaticDataports = false;
  80.             foreach (self::getDataports() as $dataport) {
  81.                 $sourceConfig = $dataport['sourceconfig'];
  83.                 if (!empty($sourceConfig['autoImport'])) {
  84.                     self::$hasAutomaticDataports = true;
  85.                     break;
  86.                 }
  87.             }
  88.         }
  90.         return self::$hasAutomaticDataports;
  91.     }
  93.     public function startImports(ElementEventInterface $e) {
  94.         try {
  95.             if ($e->getArgument('saveVersionOnly') && $e->getArgument('isAutoSave')) {
  96.                 return;
  97.             }
  98.         } catch (\InvalidArgumentException $exception) {
  99.         }
  101.         if(!$this->hasAutomaticDataports()) {
  102.             return;
  103.         }
  105.         $object = $e->getElement();
  107.         $user = Helper::getUser();
  109.         $queue = Queue::getInstance();
  111.         $savedDraftVersion = false;
  112.         try {
  113.             if ($e->getArgument('saveVersionOnly')) {
  114.                 $savedDraftVersion = true;
  115.             }
  116.         } catch (\InvalidArgumentException $exception) {
  117.         }
  118.         $queue->create([
  119.             'command' => 'data-director:start-automatic-dataports '.$object->getId().' '.Service::getElementType($object).' --user='.$user->getId().($savedDraftVersion ? ' --draft-version':''),
  120.             'triggered_by' => $object->getRealFullPath().' got saved'.(($user instanceof User) ? ' by '.$user->getUsername() : ''),
  121.             'worker_id' => 'check_automatic_run'
  122.         ]);
  123.     }
  125.     public function deleteRawdata(ElementEventInterface $e)
  126.     {
  127.         if (\method_exists($e, 'getArgument')) {
  128.             try {
  129.                 $saveVersionOnly = $e->getArgument('saveVersionOnly');
  130.                 if ($saveVersionOnly) {
  131.                     return;
  132.                 }
  133.             } catch (\InvalidArgumentException $exception) {
  134.             }
  135.         }
  137.         $object = $e->getElement();
  138.         $objectType = Service::getElementType($object);
  139.         $commandPrefix = '"'.Cli::getPhpCli().'" '.realpath(PIMCORE_PROJECT_ROOT.DIRECTORY_SEPARATOR.'bin'.DIRECTORY_SEPARATOR.'console');
  141.         foreach (self::getDataports() as $dataport) {
  142.             $sourceConfig = $dataport['sourceconfig'];
  143.             $targetConfig = $dataport['targetconfig'];
  145.             if (!empty($sourceConfig['autoImport']) && empty($targetConfig['itemClass'])) {
  146.                 $itemMold = $this->itemMoldBuilder->getItemMoldByClassId($sourceConfig['sourceClass'] ?? null);
  147.                 if ($object instanceof $itemMold) {
  148.                     Cli::exec($commandPrefix.' data-director:delete-rawdata --dataport='.$dataport['id'].' --object-id='.$object->getId().' --object-type='.$objectType);
  149.                 }
  150.             }
  151.         }
  152.     }
  153. }