vendor/blackbit/data-director/EventListener/ClassChangedListener.php line 86

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\lib\Pim\Item\ItemMoldBuilder;
  15. use Blackbit\DataDirectorBundle\model\Dataport;
  16. use Blackbit\DataDirectorBundle\model\PimcoreDbRepository;
  17. use Blackbit\DataDirectorBundle\Tools\Installer;
  18. use Pimcore\Event\Model\DataObject\ClassDefinitionEvent;
  19. use Pimcore\Model\DataObject\ClassDefinition\Data\Localizedfields;
  20. use Pimcore\Tool;
  22. class ClassChangedListener
  23. {
  24.     /** @var ItemMoldBuilder */
  25.     private $itemMoldBuilder;
  27.     public function __construct(ItemMoldBuilder $itemMoldBuilder)
  28.     {
  29.         $this->itemMoldBuilder = $itemMoldBuilder;
  30.     }
  32.     public function removeCompiledDataQuerySelectors(ClassDefinitionEvent $e) {
  33.         try {
  34.             $dummyObject = $this->itemMoldBuilder->getItemMoldByClassname($e->getClassDefinition()->getName());
  35.             $classFqn = \get_class($dummyObject);
  36.         } catch (\Exception $classNotFoundException) {
  37.             $classFqn = 'Pimcore\\Model\\DataObject\\'.$e->getClassDefinition()->getName();
  38.         }
  40.         $directoryIterator = new \DirectoryIterator(Installer::getCachePath());
  41.         $fileNamePrefix = preg_replace('/\W+/', '_', $classFqn.' ');
  42.         $filterIterator = new \CallbackFilterIterator($directoryIterator, static function (\SplFileInfo $fileInfo) use ($fileNamePrefix) {
  43.             return strpos($fileInfo->getFilename(), $fileNamePrefix) === 0 || strpos($fileInfo->getFilename(), 'Dao_'.$fileNamePrefix) === 0 || strpos($fileInfo->getFilename(), 'Listing_'.$fileNamePrefix) === 0;
  44.         });
  45.         /** @var \SplFileInfo $compiledFileInfo */
  46.         foreach ($filterIterator as $compiledFile) {
  47.             unlink($compiledFile->getPathname());
  48.         }
  49.     }
  51.     public function removeAllCompiledDataQuerySelectors() {
  52.         /** @var \SplFileInfo $compiledFileInfo */
  53.         foreach(new \DirectoryIterator(Installer::getCachePath()) as $compiledFileInfo) {
  54.             if (!$compiledFileInfo->isDot()) {
  55.                 @unlink($compiledFileInfo->getPathname());
  56.             }
  57.         }
  58.     }
  60.     public function createStoreView(ClassDefinitionEvent $e)
  61.     {
  62.         if ($e->getClassDefinition()->getAllowInherit()) {
  63.             foreach (Tool::getValidLanguages() as $language) {
  64.                 $hasLocalizedFields = false;
  65.                 foreach($e->getClassDefinition()->getFieldDefinitions() as $fieldDefinition) {
  66.                     if($fieldDefinition instanceof Localizedfields) {
  67.                         $hasLocalizedFields = true;
  68.                         break;
  69.                     }
  70.                 }
  72.                 $query = 'CREATE OR REPLACE VIEW `object_localized_store_'.$e->getClassDefinition()->getId().'_'.$language.'` AS SELECT * FROM `object_store_'.$e->getClassDefinition()->getId().'` JOIN `objects` ON `objects`.`o_id` = `object_store_'.$e->getClassDefinition()->getId().'`.`oo_id`';
  73.                 $parameters = [];
  74.                 if($hasLocalizedFields) {
  75.                     $query .= ' JOIN `object_localized_data_'.$e->getClassDefinition()->getId().'` ON `object_store_'.$e->getClassDefinition()->getId().'`.oo_id=`object_localized_data_'.$e->getClassDefinition()->getId().'`.ooo_id AND language=?';
  76.                     $parameters[] = $language;
  77.                 }
  79.                 PimcoreDbRepository::getInstance()->execute($query, $parameters);
  80.             }
  81.         } else {
  82.             $this->removeStoreView($e);
  83.         }
  84.     }
  86.     public function removeStoreView(ClassDefinitionEvent $e)
  87.     {
  88.         foreach (Tool::getValidLanguages() as $language) {
  89.             PimcoreDbRepository::getInstance()->execute('DROP VIEW IF EXISTS `object_localized_store_'.$e->getClassDefinition()->getId().'_'.$language.'`');
  90.         }
  91.     }
  92. }