src/BricomanBundle/EventListener/ActivePaginatorListener.php line 41

Open in your IDE?
  1. <?php
  2. /**
  3.  * Active Publishing - Creative Common CC BY 4.0
  4.  *   Full copyright and license information is available in
  5.  *   LICENSE.md which is distributed with this source code.
  6.  *
  7.  * @copyright Copyright (c) Active Publishing (https://activepublishing.fr)
  8.  * @license Creative Common CC BY 4.0
  9.  * @author Active Publishing <contact@active-publishing.fr>
  10.  */
  12. namespace BricomanBundle\EventListener;
  14. use BricomanBundle\BricomanBundle;
  15. use ActivePublishing\Tool\ApTool;
  16. use BricomanBundle\Model\DataObject\ActivePaginatorChapters;
  17. use Pimcore\Db;
  18. use Pimcore\Event\Model\ElementEventInterface;
  19. use Pimcore\Event\Model\DataObjectEvent;
  20. use Pimcore\Model\DataObject;
  21. use Pimcore\Model\Document;
  22. use Pimcore\Model\Element\ValidationException;
  23. use Pimcore\Model\Property;
  24. use Pimcore\Model\User;
  25. use Symfony\Component\Serializer\Encoder\JsonDecode;
  27. /**
  28.  * Class ActivePaginatorListener
  29.  * @package BricomanBundle\EventListener
  30.  */
  31. class ActivePaginatorListener
  32. {
  33.     // -----------------------------------------------------------------------------------------------------------------
  34.     // LISTENERS
  35.     // -----------------------------------------------------------------------------------------------------------------
  37.     /**
  38.      * @param ElementEventInterface $e
  39.      * @throws \Exception
  40.      */
  41.     public function onPostUpdate (ElementEventInterface $e)
  42.     {
  43.         if ($e instanceof DataObjectEvent)
  44.         {
  45.             $object = $e->getObject();
  47.             // Update when a ActivePaginator object is saved
  48.             if ($object instanceof DataObject\ActivePaginator)
  49.             {
  50.                 // Update properties of document\printcontainer
  51.                 $dependencies = $object->getDependencies();
  52.                 $requiredBy = $dependencies->getRequiredBy();
  54.                 if (!empty($requiredBy))
  55.                 {
  56.                     foreach ($requiredBy as $item) {
  57.                         if ($item['type'] == "document")
  58.                         {
  59.                             $document = Document::getById($item['id']);
  60.                             $NamespaceCatalog = [
  61.                                 "@AP\ActiveWireframeBundle\Controller\CatalogController",
  62.                                 "@ActiveWireframeBundle\Controller\CatalogController",
  63.                                 "catalog"
  64.                             ];
  66.                             if (in_array($document->getController(), $NamespaceCatalog))
  67.                             {
  68.                                 $document->save();
  69.                             }
  70.                         }
  71.                     }
  72.                 }
  74.                 // Update chapter (In case or the config for recover product data has changed)
  75.                 if ($object->hasChildren())
  76.                 {
  77.                     foreach ($object->getChildren() as $activePaginatorChapters)
  78.                     {
  79.                         if ($activePaginatorChapters instanceof ActivePaginatorChapters)
  80.                         {
  81.                             $activePaginatorChapters->save();
  82.                         }
  83.                     }
  84.                 }
  86.                 // Update declinaison data if saving a "master" ActivePaginator object
  87.                 if (!$object->hasProperty("active_paginator_master_link"))
  88.                 {
  89.                     $this->updateDeclinaison($object);
  90.                 }
  92.             }
  94.             // Update when a ActivePaginatorChapter object is saved
  95.             if ($object instanceof DataObject\ActivePaginatorChapters)
  96.             {
  98.                 $activePaginator = $object->getParent();
  100.                 if ($activePaginator instanceof DataObject\ActivePaginator
  101.                     && !$activePaginator->hasProperty("active_paginator_master_link")
  102.                 ) {
  103.                     $this->updateDeclinaison($activePaginator);
  104.                 }
  105.             }
  106.         }
  107.     }
  109.     /**
  110.      * @param ElementEventInterface $e
  111.      * @throws \Exception
  112.      */
  113.     public function onPreUpdate (ElementEventInterface $e)
  114.     {
  115.         if ($e instanceof DataObjectEvent)
  116.         {
  117.             $object = $e->getObject();
  119.             // Update RecoverItem before saving Chapter
  120.             if ($object instanceof DataObject\ActivePaginatorChapters)
  121.             {
  122.                 $riOldData = $this->getRiOldData($object);
  124.                 $riChangeData = [];
  125.                 $jsonDecode = new JsonDecode(true);
  126.                 if (array_key_exists('data', $_POST) && is_json($_POST['data']))
  127.                 {
  128.                     $riChangeData = $this->getRiChangeData($object, $jsonDecode->decode($_POST['data'], 'json'));
  129.                 }
  131.                 $recoverItems = [];
  132.                 $items = $object->getItems();
  133.                 $parent = $object->getParent();
  135.                 $translator = \Pimcore::getContainer()->get('translator');
  137.                 if ($parent instanceof DataObject\ActivePaginator) {
  139.                     foreach ($parent->getProperties() as $property) {
  140.                         if ($property->getName() == 'bricoman_date_pub_obj' || $property->getName() == 'bricoman_date_ref_obj') {
  141.                             if (empty($property->getData())) {
  142.                                 // Si l'Active paginator parent n'est pas sauvegardé au préalable
  143.                                 throw new ValidationException($translator->trans('bricoman_active_paginator_not_save_msg'));
  144.                             }
  145.                         }
  146.                     }
  147.                 }
  149.                 if (!empty($items) && !is_null($items) && $parent instanceof DataObject\ActivePaginator)
  150.                 {
  151.                     $targetObjectData = $parent->getBlocTarget();
  152.                     $targetObjectArray = [];
  154.                     if (!empty($targetObjectData)) {
  155.                         foreach ($targetObjectData as $targetObject) {
  156.                             $targetObjectArray[] = $targetObject['targetObject']->getData();
  157.                         }
  158.                     }
  160.                     $elsMetadata = ['wi' => [], 'oi' => []];
  161.                     $recoverItemsData = $this->getRi($items, $riOldData, $riChangeData, $targetObjectArray, $elsMetadata);
  162.                     ksort($recoverItemsData['wi']);
  163.                     $recoverItems = $recoverItemsData['wi'] + $recoverItemsData['oi'];
  164.                 }
  166.                 $object->setRecoverItems($recoverItems);
  167.             }
  169.             // Updating list in chapter config if a object is added or deleted
  170.             if ($object instanceof DataObject\ITNomenclature)
  171.             {
  172.                 if ($object->getDependencies())
  173.                 {
  174.                     $arrayRequiredBy = $object->getDependencies()->getRequiredBy();
  176.                     if ($arrayRequiredBy)
  177.                     {
  178.                         foreach ($arrayRequiredBy as $node)
  179.                         {
  180.                             if ($node['type'] == 'object')
  181.                             {
  182.                                 $objectRequiredBy = DataObject::getById($node['id']);
  183.                                 if ($objectRequiredBy instanceof DataObject\ActivePaginatorChapters)
  184.                                 {
  185.                                     $objectRequiredBy->save();
  186.                                 }
  187.                             }
  188.                         }
  189.                     }
  190.                 }
  191.             }
  193.             if ($object instanceof DataObject\ActivePaginator)
  194.             {
  195.                 // Gestion des propriétés
  196.                 $this->addProperties($object);
  198.             }
  200.         }
  201.     }
  203.     // -----------------------------------------------------------------------------------------------------------------
  204.     // HELP FUNCTIONS
  205.     // -----------------------------------------------------------------------------------------------------------------
  207.     /**
  208.      * @param $items
  209.      * @param $riOldData
  210.      * @param $riChangeData
  211.      * @param $targetObjectArray
  212.      * @param array $elsMetadata
  213.      * @return array
  214.      */
  215.     private function getRi($items, $riOldData, $riChangeData, $targetObjectArray, $elsMetadata = [])
  216.     {
  217.         try {
  218.             foreach ($items as $item) {
  219.                 if ($item instanceof DataObject\Concrete) {
  220.                     if (property_exists($item, 'products')) {
  221.                         $products = $item->getProducts();
  223.                         if (!empty($products)) {
  224.                             foreach ($products as $product) {
  225.                                 if (in_array($product->getClassName(), $targetObjectArray)) {
  226.                                     if (array_key_exists($product->getId(), $riChangeData)) {
  227.                                         $index = $riChangeData[$product->getId()]['index'];
  228.                                         $elsMetadata['wi'][$index] = $this->createElementMetadata(
  229.                                             $product, $riOldData, $riChangeData
  230.                                         );
  231.                                     } else {
  232.                                         $elsMetadata['oi'][] = $this->createElementMetadata(
  233.                                             $product, $riOldData, $riChangeData
  234.                                         );
  235.                                     }
  236.                                 }
  237.                             }
  238.                         }
  239.                     } else if (in_array($item->getClassName(), $targetObjectArray)) {
  240.                         if (array_key_exists($item->getId(), $riChangeData)) {
  241.                             $index = $riChangeData[$item->getId()]['index'];
  242.                             $elsMetadata['wi'][$index] = $this->createElementMetadata($item, $riOldData, $riChangeData);
  243.                         } else {
  244.                             $elsMetadata['oi'][] = $this->createElementMetadata($item, $riOldData, $riChangeData);
  245.                         }
  246.                     }
  247.                 }
  249.                 if ($item->hasChildren()) {
  250.                     $elsMetadata = $this->getRi(
  251.                         $item->getChildren(), $riOldData, $riChangeData, $targetObjectArray, $elsMetadata
  252.                     );
  253.                 }
  254.             }
  255.         } catch (\Exception $ex) {
  256.             ApTool::log(BricomanBundle::BUNDLE_ID, $ex->getTraceAsString());
  257.         }
  259.         return $elsMetadata;
  260.     }
  262.     /**
  263.      * @param $object
  264.      * @param array $riChangeData
  265.      * @return array
  266.      */
  267.     private function getRiChangeData ($object, $riChangeData = [])
  268.     {
  269.         $data = [];
  271.         if (array_key_exists('recoverItems', $riChangeData)) {
  272.             if (!empty($riChangeData['recoverItems'])) {
  273.                 foreach ($riChangeData['recoverItems'] as $dataIndex => $dataItem) {
  274.                     $data[$dataItem['id']] = [
  275.                         'publish' => (bool) $dataItem['publish'],
  276.                         'index' => intval($dataIndex)
  277.                     ];
  278.                 }
  279.             }
  280.         } else {
  281.             $database = Db::get();
  282.             $cid = trim($object->getClassId());
  283.             $oid = trim($object->getId());
  285.             if (($cid != "") && ($oid != "")) {
  286.                 $faObjectApc = $database->fetchAll("SELECT * FROM `object_$cid` WHERE oo_id = $oid");
  287.                 if (!empty($faObjectApc)) {
  288.                     foreach ($faObjectApc as $dataObjectApc) {
  289.                         $recoverItemsArray = explode(",", $dataObjectApc['recoverItems']);
  290.                         if (!empty($recoverItemsArray)) {
  291.                             foreach ($recoverItemsArray as $dataIndex => $recoverItemString) {
  292.                                 if ($recoverItemString != "") {
  293.                                     $recoverItemId = str_replace("object|", "", $recoverItemString);
  294.                                     $faObjectMetaApc = $database->fetchAll(
  295.                                         "SELECT * FROM `object_metadata_$cid` WHERE o_id = $oid AND dest_id = $recoverItemId"
  296.                                         . " AND `fieldname` = 'recoverItems' AND `column` = 'publish'"
  297.                                     );
  299.                                     if (!empty($faObjectMetaApc)) {
  300.                                         $data[$recoverItemId] = [
  301.                                             'publish' => $faObjectMetaApc[0]['data'],
  302.                                             'index' => intval($dataIndex)
  303.                                         ];
  304.                                     }
  305.                                 }
  306.                             }
  307.                         }
  308.                     }
  309.                 }
  310.             }
  311.         }
  313.         return $data;
  314.     }
  316.     /**
  317.      * @param DataObject\Concrete $object
  318.      * @return array
  319.      */
  320.     private function getRiOldData (DataObject\Concrete $object)
  321.     {
  322.         $database = Db::get();
  323.         $cid = $object->getClassId();
  324.         $oid = $object->getId();
  325.         $data = [];
  327.         if (($cid != "") && ($oid != "")) {
  328.             $fetchAll = $database->fetchAll(
  329.                 "SELECT * FROM `object_metadata_$cid` WHERE o_id = $oid"
  330.                 . " AND `fieldname` = 'recoverItems' AND `column` = 'publish'"
  331.             );
  333.             if (!empty($fetchAll)) {
  334.                 foreach ($fetchAll as $dataItem) {
  335.                     $data[$dataItem['dest_id']] = [
  336.                         'publish' => (bool)$dataItem['data']
  337.                     ];
  338.                 }
  339.             }
  340.         }
  342.         return $data;
  343.     }
  345.     /**
  346.      * @param DataObject\Concrete $object
  347.      * @param $riOldData
  348.      * @param $riChangeData
  349.      * @return bool|DataObject\Data\ElementMetadata
  350.      */
  351.     private function createElementMetadata (DataObject\Concrete $object, $riOldData, $riChangeData)
  352.     {
  353.         try {
  354.             $publish = true;
  356.             // Get AllData
  357.             if (array_key_exists($object->getId(), $riOldData)) {
  358.                 $publish = (bool) $riOldData[$object->getId()]['publish'];
  359.             }
  360.             // Get New Data
  361.             if (array_key_exists($object->getId(), $riChangeData)) {
  362.                 $publish = (bool) $riChangeData[$object->getId()]['publish'];
  363.             }
  365.             $elementMetadata = new DataObject\Data\ElementMetadata('recoverItems', [
  366.                 'publish',
  367.                 'incoming',
  368.                 'outgoing',
  369.                 'ispublishable',
  370.                 'modificationdatepim',
  371.                 'rang'
  372.             ], $object);
  374.             $elementMetadata->setPublish($publish);
  375.             return $elementMetadata;
  377.         } catch (\Exception $ex) {
  378.             ApTool::log(BricomanBundle::BUNDLE_ID, $ex->getTraceAsString());
  379.         }
  381.         return false;
  382.     }
  384.     /**
  385.      * @param DataObject\ActivePaginator $masterConfig
  386.      * @throws \Exception
  387.      */
  388.     private function updateDeclinaison (DataObject\ActivePaginator $masterConfig)
  389.     {
  390.         $rootFolder = $masterConfig->getParent();
  391.         $doService = new DataObject\Service(User::getById(0));
  393.         if ($rootFolder instanceof DataObject\Folder && $rootFolder->hasChildren() && $masterConfig->hasChildren())
  394.         {
  395.             foreach ($rootFolder->getChildren() as $configChild)
  396.             {
  397.                 if ($configChild instanceof DataObject\ActivePaginator)
  398.                 {
  399.                     $propertyMasterLink = $configChild->hasProperty("active_paginator_master_link")
  400.                         ? $configChild->getProperty("active_paginator_master_link")
  401.                         : null;
  403.                     // Only ActivePaginator declinaison
  404.                     if ($configChild->hasChildren() && $propertyMasterLink instanceof DataObject\ActivePaginator)
  405.                     {
  406.                         // For each chapter in master object
  407.                         foreach ($masterConfig->getChildren() as $masterChapter)
  408.                         {
  409.                             if ($masterChapter instanceof ActivePaginatorChapters)
  410.                             {
  411.                                 $chapterChildPath = $configChild->getFullPath() . "/" . $masterChapter->getKey();
  413.                                 // Chapter already exist
  414.                                 if (DataObject\Service::pathExists($chapterChildPath))
  415.                                 {
  416.                                     $chapterChild = DataObject::getByPath($chapterChildPath);
  417.                                     if ($chapterChild instanceof ActivePaginatorChapters)
  418.                                     {
  419.                                         $chapterChild->setItems($masterChapter->getItems());
  420.                                         $chapterChild->setPublished($masterChapter->isPublished());
  421.                                         $chapterChild->save();
  422.                                     }
  423.                                 }
  424.                                 else // Chapter not exist
  425.                                 {
  426.                                     $doService->copyAsChild($configChild, $masterChapter);
  427.                                 }
  428.                             }
  429.                         }
  430.                     }
  431.                 }
  432.             }
  433.         }
  434.     }
  437.     /**
  438.      * Add properties if not exist :
  439.      * <ul>
  440.      * <li>bricoman_date_pub_obj</li>
  441.      * <li>bricoman_date_referent_obj</li>
  442.      * </ul>
  443.      *
  444.      * @param DataObject\ActivePaginator $object
  445.      */
  446.     private function addProperties(DataObject\ActivePaginator $object)
  447.     {
  448.         $propertiesToAdd = [
  449.             'bricoman_date_pub_obj' => 'bricoman_date_pub_obj',
  450.             'bricoman_date_referent_obj' => 'bricoman_date_referent_obj'
  451.         ];
  453.         $properties = array();
  455.         // If properties already exist no need to add them
  457.         if ($object->getProperties()) {
  459.             // Si l'objet a déjà les propriété crées
  461.             $regex_data = "/^([12]\d{3}-(0[1-9]|1[0-2])-(0[1-9]|[12]\d|3[01]))$/";
  462.             $error_msg = "";
  464.             /** @var Property $p */
  465.             foreach($object->getProperties() as $p) {
  467.                 if(in_array($p->getName(), $propertiesToAdd))
  468.                 {
  469.                     $translator = \Pimcore::getContainer()->get('translator');
  472.                     if (!preg_match($regex_data,  $p->getData()))
  473.                     {
  474.                         // Si les valeurs des propriétés ne sont pas sous le format "YYYY-MM-dd", on arrête le script
  475.                         if ($p->getName() == 'bricoman_date_pub_obj') {
  476.                             throw new ValidationException($translator->trans('bricoman_date_pub_obj_no_valid_msg'));
  477.                         } else if ($p->getName() == 'bricoman_date_referent_obj') {
  478.                             throw new ValidationException($translator->trans('bricoman_date_referent_obj_no_valid_msg'));
  479.                         }
  480.                     } else {
  481.                         $properties[$p->getName()] = $p;
  482.                     }
  485.                 }
  486.             }
  487.         } else {
  489.             // Lors du premier save, on vient créer les deux propriétés
  491.             foreach($propertiesToAdd as $key => $p) {
  492.                 $predifinedProperty = Property\Predefined::getByKey($p);
  493.                 $property = new Property();
  494.                 $property->setType($predifinedProperty->getType());
  495.                 $property->setCtype($predifinedProperty->getCtype());
  496.                 $property->setName($predifinedProperty->getKey());
  497.                 $property->setInheritable($predifinedProperty->getInheritable());
  498.                 $property->setData("");
  499.                 $properties[$p] = $property;
  500.             }
  501.         }
  503.         // Adding properties to the object
  504.         $object->setProperties($properties);
  505.     }
  506. }