vendor/pimcore/pimcore/bundles/AdminBundle/Controller/Admin/DataObject/DataObjectController.php line 373

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 Pimcore\Bundle\AdminBundle\Controller\Admin\DataObject;
  18. use Pimcore\Bundle\AdminBundle\Controller\Admin\ElementControllerBase;
  19. use Pimcore\Bundle\AdminBundle\Controller\Traits\AdminStyleTrait;
  20. use Pimcore\Bundle\AdminBundle\Controller\Traits\ApplySchedulerDataTrait;
  21. use Pimcore\Bundle\AdminBundle\Helper\GridHelperService;
  22. use Pimcore\Bundle\AdminBundle\Security\CsrfProtectionHandler;
  23. use Pimcore\Controller\KernelControllerEventInterface;
  24. use Pimcore\Controller\Traits\ElementEditLockHelperTrait;
  25. use Pimcore\Db;
  26. use Pimcore\Event\Admin\ElementAdminStyleEvent;
  27. use Pimcore\Event\AdminEvents;
  28. use Pimcore\Localization\LocaleServiceInterface;
  29. use Pimcore\Logger;
  30. use Pimcore\Model;
  31. use Pimcore\Model\DataObject;
  32. use Pimcore\Model\DataObject\ClassDefinition\Data\ManyToManyObjectRelation;
  33. use Pimcore\Model\DataObject\ClassDefinition\Data\Relations\AbstractRelations;
  34. use Pimcore\Model\DataObject\ClassDefinition\Data\ReverseObjectRelation;
  35. use Pimcore\Model\Element;
  36. use Pimcore\Model\Schedule\Task;
  37. use Pimcore\Model\Version;
  38. use Pimcore\Tool;
  39. use Symfony\Component\EventDispatcher\GenericEvent;
  40. use Symfony\Component\HttpFoundation\JsonResponse;
  41. use Symfony\Component\HttpFoundation\RedirectResponse;
  42. use Symfony\Component\HttpFoundation\Request;
  43. use Symfony\Component\HttpFoundation\Response;
  44. use Symfony\Component\HttpFoundation\Session\Attribute\AttributeBagInterface;
  45. use Symfony\Component\HttpKernel\Event\ControllerEvent;
  46. use Symfony\Component\Routing\Annotation\Route;
  47. use Symfony\Contracts\EventDispatcher\EventDispatcherInterface;
  49. /**
  50.  * @Route("/object", name="pimcore_admin_dataobject_dataobject_")
  51.  *
  52.  * @internal
  53.  */
  54. class DataObjectController extends ElementControllerBase implements KernelControllerEventInterface
  55. {
  56.     use AdminStyleTrait;
  57.     use ElementEditLockHelperTrait;
  58.     use ApplySchedulerDataTrait;
  59.     use DataObjectActionsTrait;
  61.     /**
  62.      * @var DataObject\Service
  63.      */
  64.     protected DataObject\Service $_objectService;
  66.     /**
  67.      * @var array
  68.      */
  69.     private array $objectData = [];
  71.     /**
  72.      * @var array
  73.      */
  74.     private array $metaData = [];
  76.     /**
  77.      * @Route("/tree-get-childs-by-id", name="treegetchildsbyid", methods={"GET"})
  78.      *
  79.      * @param Request $request
  80.      * @param EventDispatcherInterface $eventDispatcher
  81.      *
  82.      * @return JsonResponse
  83.      */
  84.     public function treeGetChildsByIdAction(Request $request, EventDispatcherInterface $eventDispatcher)
  85.     {
  86.         $allParams = array_merge($request->request->all(), $request->query->all());
  87.         $filter = $request->get('filter');
  88.         $object = DataObject::getById((int) $request->get('node'));
  89.         $objectTypes = [DataObject::OBJECT_TYPE_OBJECT, DataObject::OBJECT_TYPE_FOLDER];
  90.         $objects = [];
  91.         $cv = false;
  92.         $offset = $total = $limit = $filteredTotalCount = 0;
  94.         if ($object instanceof DataObject\Concrete) {
  95.             $class = $object->getClass();
  96.             if ($class->getShowVariants()) {
  97.                 $objectTypes = DataObject::$types;
  98.             }
  99.         }
  101.         if ($object->hasChildren($objectTypes)) {
  102.             $offset = (int)$request->get('start');
  103.             $limit = (int)$request->get('limit', 100000000);
  104.             if ($view = $request->get('view', false)) {
  105.                 $cv = Element\Service::getCustomViewById($request->get('view'));
  106.             }
  108.             if (!is_null($filter)) {
  109.                 if (substr($filter, -1) != '*') {
  110.                     $filter .= '*';
  111.                 }
  112.                 $filter = str_replace('*', '%', $filter);
  113.                 $limit = 100;
  114.             }
  116.             $childrenList = new DataObject\Listing();
  117.             $childrenList->setCondition($this->buildChildrenCondition($object, $filter, $view));
  118.             $childrenList->setLimit($limit);
  119.             $childrenList->setOffset($offset);
  121.             if ($object->getChildrenSortBy() === 'index') {
  122.                 $childrenList->setOrderKey('objects.o_index ASC', false);
  123.             } else {
  124.                 $childrenList->setOrderKey(
  125.                     sprintf(
  126.                         'CAST(objects.o_%s AS CHAR CHARACTER SET utf8) COLLATE utf8_general_ci %s',
  127.                         $object->getChildrenSortBy(), $object->getChildrenSortOrder()
  128.                     ),
  129.                     false
  130.                 );
  131.             }
  132.             $childrenList->setObjectTypes($objectTypes);
  134.             Element\Service::addTreeFilterJoins($cv, $childrenList);
  136.             $beforeListLoadEvent = new GenericEvent($this, [
  137.                 'list' => $childrenList,
  138.                 'context' => $allParams,
  139.             ]);
  140.             $eventDispatcher->dispatch($beforeListLoadEvent, AdminEvents::OBJECT_LIST_BEFORE_LIST_LOAD);
  142.             /** @var DataObject\Listing $childrenList */
  143.             $childrenList = $beforeListLoadEvent->getArgument('list');
  145.             $children = $childrenList->load();
  146.             $filteredTotalCount = $childrenList->getTotalCount();
  148.             foreach ($children as $child) {
  149.                 $objectTreeNode = $this->getTreeNodeConfig($child);
  150.                 // this if is obsolete since as long as the change with #11714 about list on line 175-179 are working fine, we already filter the list=1 there
  151.                 if ($objectTreeNode['permissions']['list'] == 1) {
  152.                     $objects[] = $objectTreeNode;
  153.                 }
  154.             }
  156.             //pagination for custom view
  157.             $total = $cv
  158.                 ? $filteredTotalCount
  159.                 : $object->getChildAmount(null, $this->getAdminUser());
  160.         }
  162.         //Hook for modifying return value - e.g. for changing permissions based on object data
  163.         //data need to wrapped into a container in order to pass parameter to event listeners by reference so that they can change the values
  164.         $event = new GenericEvent($this, [
  165.             'objects' => $objects,
  166.         ]);
  167.         $eventDispatcher->dispatch($event, AdminEvents::OBJECT_TREE_GET_CHILDREN_BY_ID_PRE_SEND_DATA);
  169.         $objects = $event->getArgument('objects');
  171.         if ($limit) {
  172.             return $this->adminJson([
  173.                 'offset' => $offset,
  174.                 'limit' => $limit,
  175.                 'total' => $total,
  176.                 'overflow' => !is_null($filter) && ($filteredTotalCount > $limit),
  177.                 'nodes' => $objects,
  178.                 'fromPaging' => (int)$request->get('fromPaging'),
  179.                 'filter' => $request->get('filter') ? $request->get('filter') : '',
  180.                 'inSearch' => (int)$request->get('inSearch'),
  181.             ]);
  182.         }
  184.         return $this->adminJson($objects);
  185.     }
  187.     /**
  188.      * @param DataObject\AbstractObject $object
  189.      * @param string|null $filter
  190.      * @param string|null $view
  191.      *
  192.      * @return string
  193.      */
  194.     private function buildChildrenCondition(DataObject\AbstractObject $object, ?string $filter, ?string $view): string
  195.     {
  196.         $condition = "objects.o_parentId = '" . $object->getId() . "'";
  198.         // custom views start
  199.         if ($view) {
  200.             $cv = Element\Service::getCustomViewById($view);
  202.             if (!empty($cv['classes'])) {
  203.                 $cvConditions = [];
  204.                 $cvClasses = $cv['classes'];
  205.                 foreach ($cvClasses as $key => $cvClass) {
  206.                     $cvConditions[] = "objects.o_classId = '" . $key . "'";
  207.                 }
  209.                 $cvConditions[] = "objects.o_type = 'folder'";
  210.                 $condition .= ' AND (' . implode(' OR ', $cvConditions) . ')';
  211.             }
  212.         }
  213.         // custom views end
  215.         if (!$this->getAdminUser()->isAdmin()) {
  216.             $userIds = $this->getAdminUser()->getRoles();
  217.             $currentUserId = $this->getAdminUser()->getId();
  218.             $userIds[] = $currentUserId;
  220.             $inheritedPermission = $object->getDao()->isInheritingPermission('list', $userIds);
  222.             $anyAllowedRowOrChildren = 'EXISTS(SELECT list FROM users_workspaces_object uwo WHERE userId IN (' . implode(',', $userIds) . ') AND list=1 AND LOCATE(CONCAT(objects.o_path,objects.o_key),cpath)=1 AND
  223.                 NOT EXISTS(SELECT list FROM users_workspaces_object WHERE userId =' . $currentUserId . '  AND list=0 AND cpath = uwo.cpath))';
  224.             $isDisallowedCurrentRow = 'EXISTS(SELECT list FROM users_workspaces_object WHERE userId IN (' . implode(',', $userIds) . ')  AND cid = objects.o_id AND list=0)';
  226.             $condition .= ' AND IF(' . $anyAllowedRowOrChildren . ',1,IF(' . $inheritedPermission . ', ' . $isDisallowedCurrentRow . ' = 0, 0)) = 1';
  227.         }
  229.         if (!is_null($filter)) {
  230.             $db = Db::get();
  231.             $condition .= ' AND CAST(objects.o_key AS CHAR CHARACTER SET utf8) COLLATE utf8_general_ci LIKE ' . $db->quote($filter);
  232.         }
  234.         return $condition;
  235.     }
  237.     /**
  238.      * @param DataObject\AbstractObject $element
  239.      *
  240.      * @return array
  241.      *
  242.      * @throws \Exception
  243.      */
  244.     protected function getTreeNodeConfig($element): array
  245.     {
  246.         $child = $element;
  248.         $tmpObject = [
  249.             'id' => $child->getId(),
  250.             'idx' => (int)$child->getIndex(),
  251.             'key' => $child->getKey(),
  252.             'sortBy' => $child->getChildrenSortBy(),
  253.             'sortOrder' => $child->getChildrenSortOrder(),
  254.             'text' => htmlspecialchars($child->getKey()),
  255.             'type' => $child->getType(),
  256.             'path' => $child->getRealFullPath(),
  257.             'basePath' => $child->getRealPath(),
  258.             'elementType' => 'object',
  259.             'locked' => $child->isLocked(),
  260.             'lockOwner' => $child->getLocked() ? true : false,
  261.         ];
  263.         $allowedTypes = [DataObject::OBJECT_TYPE_OBJECT, DataObject::OBJECT_TYPE_FOLDER];
  264.         if ($child instanceof DataObject\Concrete && $child->getClass()->getShowVariants()) {
  265.             $allowedTypes[] = DataObject::OBJECT_TYPE_VARIANT;
  266.         }
  268.         $hasChildren = $child->getDao()->hasChildren($allowedTypes, null, $this->getAdminUser());
  270.         $tmpObject['allowDrop'] = false;
  272.         $tmpObject['isTarget'] = true;
  273.         if ($tmpObject['type'] != DataObject::OBJECT_TYPE_VARIANT) {
  274.             $tmpObject['allowDrop'] = true;
  275.         }
  277.         $tmpObject['allowChildren'] = true;
  278.         $tmpObject['leaf'] = !$hasChildren;
  279.         $tmpObject['cls'] = 'pimcore_class_icon ';
  281.         if ($child instanceof DataObject\Concrete) {
  282.             $tmpObject['published'] = $child->isPublished();
  283.             $tmpObject['className'] = $child->getClass()->getName();
  285.             if (!$child->isPublished()) {
  286.                 $tmpObject['cls'] .= 'pimcore_unpublished ';
  287.             }
  289.             $tmpObject['allowVariants'] = $child->getClass()->getAllowVariants();
  290.         }
  292.         $this->addAdminStyle($child, ElementAdminStyleEvent::CONTEXT_TREE, $tmpObject);
  294.         $tmpObject['expanded'] = !$hasChildren;
  295.         $tmpObject['permissions'] = $child->getUserPermissions($this->getAdminUser());
  297.         if ($child->isLocked()) {
  298.             $tmpObject['cls'] .= 'pimcore_treenode_locked ';
  299.         }
  300.         if ($child->getLocked()) {
  301.             $tmpObject['cls'] .= 'pimcore_treenode_lockOwner ';
  302.         }
  304.         if ($tmpObject['leaf']) {
  305.             $tmpObject['expandable'] = false;
  306.             $tmpObject['leaf'] = false; //this is required to allow drag&drop
  307.             $tmpObject['expanded'] = true;
  308.             $tmpObject['loaded'] = true;
  309.         }
  311.         return $tmpObject;
  312.     }
  314.     /**
  315.      * @Route("/get-id-path-paging-info", name="getidpathpaginginfo", methods={"GET"})
  316.      *
  317.      * @param Request $request
  318.      *
  319.      * @return JsonResponse
  320.      */
  321.     public function getIdPathPagingInfoAction(Request $request): JsonResponse
  322.     {
  323.         $path = $request->get('path');
  324.         $pathParts = explode('/', $path);
  325.         $id = (int) array_pop($pathParts);
  327.         $limit = $request->get('limit');
  329.         if (empty($limit)) {
  330.             $limit = 30;
  331.         }
  333.         $data = [];
  335.         $targetObject = DataObject::getById($id);
  336.         $object = $targetObject;
  338.         while ($parent = $object->getParent()) {
  339.             $list = new DataObject\Listing();
  340.             $list->setCondition('o_parentId = ?', $parent->getId());
  341.             $list->setUnpublished(true);
  342.             $total = $list->getTotalCount();
  344.             $info = [
  345.                 'total' => $total,
  346.             ];
  348.             if ($total > $limit) {
  349.                 $idList = $list->loadIdList();
  350.                 $position = array_search($object->getId(), $idList);
  351.                 $info['position'] = $position + 1;
  352.                 $info['page'] = ceil($info['position'] / $limit);
  353.             }
  355.             $data[$parent->getId()] = $info;
  357.             $object = $parent;
  358.         }
  360.         return $this->adminJson($data);
  361.     }
  363.     /**
  364.      * @Route("/get", name="get", methods={"GET"})
  365.      *
  366.      * @param Request $request
  367.      * @param EventDispatcherInterface $eventDispatcher
  368.      *
  369.      * @return JsonResponse
  370.      *
  371.      * @throws \Exception
  372.      */
  373.     public function getAction(Request $request, EventDispatcherInterface $eventDispatcher): JsonResponse
  374.     {
  375.         $objectId = (int)$request->get('id');
  376.         $objectFromDatabase = DataObject\Concrete::getById($objectId);
  377.         if ($objectFromDatabase === null) {
  378.             return $this->adminJson(['success' => false, 'message' => 'element_not_found'], JsonResponse::HTTP_NOT_FOUND);
  379.         }
  380.         $objectFromDatabase = clone $objectFromDatabase;
  382.         // set the latest available version for editmode
  383.         $draftVersion = null;
  384.         $object = $this->getLatestVersion($objectFromDatabase, $draftVersion);
  386.         // check for lock
  387.         if ($object->isAllowed('save') || $object->isAllowed('publish') || $object->isAllowed('unpublish') || $object->isAllowed('delete')) {
  388.             if (Element\Editlock::isLocked($objectId, 'object')) {
  389.                 return $this->getEditLockResponse($objectId, 'object');
  390.             }
  392.             Element\Editlock::lock($request->get('id'), 'object');
  393.         }
  395.         // we need to know if the latest version is published or not (a version), because of lazy loaded fields in $this->getDataForObject()
  396.         $objectFromVersion = $object !== $objectFromDatabase;
  398.         if ($object->isAllowed('view')) {
  399.             $objectData = [];
  401.             /** -------------------------------------------------------------
  402.              *   Load some general data from published object (if existing)
  403.              *  ------------------------------------------------------------- */
  404.             $objectData['idPath'] = Element\Service::getIdPath($objectFromDatabase);
  406.             $previewGenerator = $objectFromDatabase->getClass()->getPreviewGenerator();
  407.             $linkGeneratorReference = $objectFromDatabase->getClass()->getLinkGeneratorReference();
  409.             $objectData['hasPreview'] = false;
  410.             if ($objectFromDatabase->getClass()->getPreviewUrl() || $linkGeneratorReference || $previewGenerator) {
  411.                 $objectData['hasPreview'] = true;
  412.             }
  414.             if ($draftVersion && $objectFromDatabase->getModificationDate() < $draftVersion->getDate()) {
  415.                 $objectData['draft'] = [
  416.                     'id' => $draftVersion->getId(),
  417.                     'modificationDate' => $draftVersion->getDate(),
  418.                     'isAutoSave' => $draftVersion->isAutoSave(),
  419.                 ];
  420.             }
  422.             $objectData['general'] = [];
  424.             $allowedKeys = ['o_published', 'o_key', 'o_id', 'o_creationDate', 'o_classId', 'o_className', 'o_type', 'o_parentId', 'o_userOwner'];
  425.             foreach ($objectFromDatabase->getObjectVars() as $key => $value) {
  426.                 if (in_array($key, $allowedKeys)) {
  427.                     $objectData['general'][$key] = $value;
  428.                 }
  429.             }
  430.             $objectData['general']['fullpath'] = $objectFromDatabase->getRealFullPath();
  431.             $objectData['general']['o_locked'] = $objectFromDatabase->isLocked();
  432.             $objectData['general']['php'] = [
  433.                 'classes' => array_merge([get_class($objectFromDatabase)], array_values(class_parents($objectFromDatabase))),
  434.                 'interfaces' => array_values(class_implements($objectFromDatabase)),
  435.             ];
  436.             $objectData['general']['allowInheritance'] = $objectFromDatabase->getClass()->getAllowInherit();
  437.             $objectData['general']['allowVariants'] = $objectFromDatabase->getClass()->getAllowVariants();
  438.             $objectData['general']['showVariants'] = $objectFromDatabase->getClass()->getShowVariants();
  439.             $objectData['general']['showAppLoggerTab'] = $objectFromDatabase->getClass()->getShowAppLoggerTab();
  440.             $objectData['general']['showFieldLookup'] = $objectFromDatabase->getClass()->getShowFieldLookup();
  441.             if ($objectFromDatabase instanceof DataObject\Concrete) {
  442.                 $objectData['general']['linkGeneratorReference'] = $linkGeneratorReference;
  443.                 if ($previewGenerator) {
  444.                     $objectData['general']['previewConfig'] = $previewGenerator->getPreviewConfig($objectFromDatabase);
  445.                 }
  446.             }
  448.             $objectData['layout'] = $objectFromDatabase->getClass()->getLayoutDefinitions();
  449.             $objectData['userPermissions'] = $objectFromDatabase->getUserPermissions($this->getAdminUser());
  450.             $objectVersions = Element\Service::getSafeVersionInfo($objectFromDatabase->getVersions());
  451.             $objectData['versions'] = array_splice($objectVersions, -1, 1);
  452.             $objectData['scheduledTasks'] = array_map(
  453.                 static function (Task $task) {
  454.                     return $task->getObjectVars();
  455.                 },
  456.                 $objectFromDatabase->getScheduledTasks()
  457.             );
  459.             $objectData['childdata']['id'] = $objectFromDatabase->getId();
  460.             $objectData['childdata']['data']['classes'] = $this->prepareChildClasses($objectFromDatabase->getDao()->getClasses());
  461.             $objectData['childdata']['data']['general'] = $objectData['general'];
  462.             /** -------------------------------------------------------------
  463.              *   Load remaining general data from latest version
  464.              *  ------------------------------------------------------------- */
  465.             $allowedKeys = ['o_modificationDate', 'o_userModification'];
  466.             foreach ($object->getObjectVars() as $key => $value) {
  467.                 if (in_array($key, $allowedKeys)) {
  468.                     $objectData['general'][$key] = $value;
  469.                 }
  470.             }
  472.             $this->getDataForObject($object, $objectFromVersion);
  473.             $objectData['data'] = $this->objectData;
  474.             $objectData['metaData'] = $this->metaData;
  475.             $objectData['properties'] = Element\Service::minimizePropertiesForEditmode($object->getProperties());
  477.             // this used for the "this is not a published version" hint
  478.             // and for adding the published icon to version overview
  479.             $objectData['general']['versionDate'] = $objectFromDatabase->getModificationDate();
  480.             $objectData['general']['versionCount'] = $objectFromDatabase->getVersionCount();
  482.             $this->addAdminStyle($object, ElementAdminStyleEvent::CONTEXT_EDITOR, $objectData['general']);
  484.             $currentLayoutId = $request->get('layoutId');
  486.             $validLayouts = DataObject\Service::getValidLayouts($object);
  488.             //Fallback if $currentLayoutId is not set or empty string
  489.             //Uses first valid layout instead of admin layout when empty
  490.             $ok = false;
  491.             foreach ($validLayouts as $layout) {
  492.                 if ($currentLayoutId == $layout->getId()) {
  493.                     $ok = true;
  494.                 }
  495.             }
  497.             if (!$ok) {
  498.                 $currentLayoutId = null;
  499.             }
  501.             //master layout has id 0 so we check for is_null()
  502.             if ($currentLayoutId === null && !empty($validLayouts)) {
  503.                 if (count($validLayouts) === 1) {
  504.                     $firstLayout = reset($validLayouts);
  505.                     $currentLayoutId = $firstLayout->getId();
  506.                 } else {
  507.                     foreach ($validLayouts as $checkDefaultLayout) {
  508.                         if ($checkDefaultLayout->getDefault()) {
  509.                             $currentLayoutId = $checkDefaultLayout->getId();
  510.                         }
  511.                     }
  512.                 }
  513.             }
  515.             if ($currentLayoutId === null && count($validLayouts) > 0) {
  516.                 $currentLayoutId = $validLayouts[0]->getId();
  517.             }
  519.             if (!empty($validLayouts)) {
  520.                 $objectData['validLayouts'] = [];
  522.                 foreach ($validLayouts as $validLayout) {
  523.                     $objectData['validLayouts'][] = ['id' => $validLayout->getId(), 'name' => $validLayout->getName()];
  524.                 }
  526.                 $user = Tool\Admin::getCurrentUser();
  528.                 if ($currentLayoutId == -1 && $user->isAdmin()) {
  529.                     $layout = DataObject\Service::getSuperLayoutDefinition($object);
  530.                     $objectData['layout'] = $layout;
  531.                 } elseif (!empty($currentLayoutId)) {
  532.                     $objectData['layout'] = $validLayouts[$currentLayoutId]->getLayoutDefinitions();
  533.                 }
  535.                 $objectData['currentLayoutId'] = $currentLayoutId;
  536.             }
  538.             //Hook for modifying return value - e.g. for changing permissions based on object data
  539.             //data need to wrapped into a container in order to pass parameter to event listeners by reference so that they can change the values
  540.             $event = new GenericEvent($this, [
  541.                 'data' => $objectData,
  542.                 'object' => $object,
  543.             ]);
  545.             DataObject\Service::enrichLayoutDefinition($objectData['layout'], $object);
  546.             $eventDispatcher->dispatch($event, AdminEvents::OBJECT_GET_PRE_SEND_DATA);
  547.             $data = $event->getArgument('data');
  549.             DataObject\Service::removeElementFromSession('object', $object->getId());
  551.             return $this->adminJson($data);
  552.         }
  554.         throw $this->createAccessDeniedHttpException();
  555.     }
  557.     /**
  558.      * @param DataObject\Concrete $object
  559.      * @param bool $objectFromVersion
  560.      */
  561.     private function getDataForObject(DataObject\Concrete $object, $objectFromVersion = false)
  562.     {
  563.         foreach ($object->getClass()->getFieldDefinitions(['object' => $object]) as $key => $def) {
  564.             $this->getDataForField($object, $key, $def, $objectFromVersion);
  565.         }
  566.     }
  568.     /**
  569.      * gets recursively attribute data from parent and fills objectData and metaData
  570.      *
  571.      * @param DataObject\Concrete $object
  572.      * @param string $key
  573.      * @param DataObject\ClassDefinition\Data $fielddefinition
  574.      * @param bool $objectFromVersion
  575.      * @param int $level
  576.      */
  577.     private function getDataForField($object, $key, $fielddefinition, $objectFromVersion, $level = 0)
  578.     {
  579.         $parent = DataObject\Service::hasInheritableParentObject($object);
  580.         $getter = 'get' . ucfirst($key);
  582.         // Editmode optimization for lazy loaded relations (note that this is just for AbstractRelations, not for all
  583.         // LazyLoadingSupportInterface types. It tries to optimize fetching the data needed for the editmode without
  584.         // loading the entire target element.
  585.         // ReverseObjectRelation should go in there anyway (regardless if it a version or not),
  586.         // so that the values can be loaded.
  587.         if (
  588.             (!$objectFromVersion && $fielddefinition instanceof AbstractRelations)
  589.             || $fielddefinition instanceof ReverseObjectRelation
  590.         ) {
  591.             $refId = null;
  593.             if ($fielddefinition instanceof ReverseObjectRelation) {
  594.                 $refKey = $fielddefinition->getOwnerFieldName();
  595.                 $refClass = DataObject\ClassDefinition::getByName($fielddefinition->getOwnerClassName());
  596.                 if ($refClass) {
  597.                     $refId = $refClass->getId();
  598.                 }
  599.             } else {
  600.                 $refKey = $key;
  601.             }
  603.             $relations = $object->getRelationData($refKey, !$fielddefinition instanceof ReverseObjectRelation, $refId);
  605.             if ($fielddefinition->supportsInheritance() && empty($relations) && !empty($parent)) {
  606.                 $this->getDataForField($parent, $key, $fielddefinition, $objectFromVersion, $level + 1);
  607.             } else {
  608.                 $data = [];
  610.                 if ($fielddefinition instanceof DataObject\ClassDefinition\Data\ManyToOneRelation) {
  611.                     if (isset($relations[0])) {
  612.                         $data = $relations[0];
  613.                         $data['published'] = (bool)$data['published'];
  614.                     } else {
  615.                         $data = null;
  616.                     }
  617.                 } elseif (
  618.                     ($fielddefinition instanceof DataObject\ClassDefinition\Data\OptimizedAdminLoadingInterface && $fielddefinition->isOptimizedAdminLoading())
  619.                     || ($fielddefinition instanceof ManyToManyObjectRelation && !$fielddefinition->getVisibleFields() && !$fielddefinition instanceof DataObject\ClassDefinition\Data\AdvancedManyToManyObjectRelation)
  620.                 ) {
  621.                     foreach ($relations as $rkey => $rel) {
  622.                         $index = $rkey + 1;
  623.                         $rel['fullpath'] = $rel['path'];
  624.                         $rel['classname'] = $rel['subtype'];
  625.                         $rel['rowId'] = $rel['id'] . AbstractRelations::RELATION_ID_SEPARATOR . $index . AbstractRelations::RELATION_ID_SEPARATOR . $rel['type'];
  626.                         $rel['published'] = (bool)$rel['published'];
  627.                         $data[] = $rel;
  628.                     }
  629.                 } else {
  630.                     $fieldData = $object->$getter();
  631.                     $data = $fielddefinition->getDataForEditmode($fieldData, $object, ['objectFromVersion' => $objectFromVersion]);
  632.                 }
  633.                 $this->objectData[$key] = $data;
  634.                 $this->metaData[$key]['objectid'] = $object->getId();
  635.                 $this->metaData[$key]['inherited'] = $level != 0;
  636.             }
  637.         } else {
  638.             $fieldData = $object->$getter();
  639.             $isInheritedValue = false;
  641.             if ($fielddefinition instanceof DataObject\ClassDefinition\Data\CalculatedValue) {
  642.                 $fieldData = new DataObject\Data\CalculatedValue($fielddefinition->getName());
  643.                 $fieldData->setContextualData('object', null, null, null, null, null, $fielddefinition);
  644.                 $value = $fielddefinition->getDataForEditmode($fieldData, $object, ['objectFromVersion' => $objectFromVersion]);
  645.             } else {
  646.                 $value = $fielddefinition->getDataForEditmode($fieldData, $object, ['objectFromVersion' => $objectFromVersion]);
  647.             }
  649.             // following some exceptions for special data types (localizedfields, objectbricks)
  650.             if ($value && ($fieldData instanceof DataObject\Localizedfield || $fieldData instanceof DataObject\Classificationstore)) {
  651.                 // make sure that the localized field participates in the inheritance detection process
  652.                 $isInheritedValue = $value['inherited'];
  653.             }
  654.             if ($fielddefinition instanceof DataObject\ClassDefinition\Data\Objectbricks && is_array($value)) {
  655.                 // make sure that the objectbricks participate in the inheritance detection process
  656.                 foreach ($value as $singleBrickData) {
  657.                     if (!empty($singleBrickData['inherited'])) {
  658.                         $isInheritedValue = true;
  659.                     }
  660.                 }
  661.             }
  663.             if ($fielddefinition->isEmpty($fieldData) && !empty($parent)) {
  664.                 $this->getDataForField($parent, $key, $fielddefinition, $objectFromVersion, $level + 1);
  665.                 // exception for classification store. if there are no items then it is empty by definition.
  666.                 // consequence is that we have to preserve the metadata information
  667.                 // see https://github.com/pimcore/pimcore/issues/9329
  668.                 if ($fielddefinition instanceof DataObject\ClassDefinition\Data\Classificationstore && $level == 0) {
  669.                     $this->objectData[$key]['metaData'] = $value['metaData'] ?? [];
  670.                     $this->objectData[$key]['inherited'] = true;
  671.                 }
  672.             } else {
  673.                 $isInheritedValue = $isInheritedValue || ($level != 0);
  674.                 $this->metaData[$key]['objectid'] = $object->getId();
  676.                 $this->objectData[$key] = $value;
  677.                 $this->metaData[$key]['inherited'] = $isInheritedValue;
  679.                 if ($isInheritedValue && !$fielddefinition->isEmpty($fieldData) && !$fielddefinition->supportsInheritance()) {
  680.                     $this->objectData[$key] = null;
  681.                     $this->metaData[$key]['inherited'] = false;
  682.                     $this->metaData[$key]['hasParentValue'] = true;
  683.                 }
  684.             }
  685.         }
  686.     }
  688.     /**
  689.      * @Route("/get-folder", name="getfolder", methods={"GET"})
  690.      *
  691.      * @param Request $request
  692.      * @param EventDispatcherInterface $eventDispatcher
  693.      *
  694.      * @return JsonResponse
  695.      */
  696.     public function getFolderAction(Request $request, EventDispatcherInterface $eventDispatcher)
  697.     {
  698.         $objectId = (int)$request->get('id');
  699.         $object = DataObject::getById($objectId);
  701.         if (!$object) {
  702.             throw $this->createNotFoundException();
  703.         }
  705.         if ($object->isAllowed('view')) {
  706.             $objectData = [];
  708.             $objectData['general'] = [];
  709.             $objectData['idPath'] = Element\Service::getIdPath($object);
  710.             $objectData['type'] = $object->getType();
  711.             $allowedKeys = ['o_published', 'o_key', 'o_id', 'o_type', 'o_path', 'o_modificationDate', 'o_creationDate', 'o_userOwner', 'o_userModification'];
  712.             foreach ($object->getObjectVars() as $key => $value) {
  713.                 if (strstr($key, 'o_') && in_array($key, $allowedKeys)) {
  714.                     $objectData['general'][$key] = $value;
  715.                 }
  716.             }
  717.             $objectData['general']['fullpath'] = $object->getRealFullPath();
  719.             $objectData['general']['o_locked'] = $object->isLocked();
  721.             $objectData['properties'] = Element\Service::minimizePropertiesForEditmode($object->getProperties());
  722.             $objectData['userPermissions'] = $object->getUserPermissions($this->getAdminUser());
  723.             $objectData['classes'] = $this->prepareChildClasses($object->getDao()->getClasses());
  725.             // grid-config
  726.             $configFile = PIMCORE_CONFIGURATION_DIRECTORY . '/object/grid/' . $object->getId() . '-user_' . $this->getAdminUser()->getId() . '.psf';
  727.             if (is_file($configFile)) {
  728.                 $gridConfig = Tool\Serialize::unserialize(file_get_contents($configFile));
  729.                 if ($gridConfig) {
  730.                     $selectedClassId = $gridConfig['classId'];
  732.                     foreach ($objectData['classes'] as $class) {
  733.                         if ($class['id'] == $selectedClassId) {
  734.                             $objectData['selectedClass'] = $selectedClassId;
  736.                             break;
  737.                         }
  738.                     }
  739.                 }
  740.             }
  742.             //Hook for modifying return value - e.g. for changing permissions based on object data
  743.             //data need to wrapped into a container in order to pass parameter to event listeners by reference so that they can change the values
  744.             $event = new GenericEvent($this, [
  745.                 'data' => $objectData,
  746.                 'object' => $object,
  747.             ]);
  748.             $eventDispatcher->dispatch($event, AdminEvents::OBJECT_GET_PRE_SEND_DATA);
  749.             $objectData = $event->getArgument('data');
  751.             return $this->adminJson($objectData);
  752.         }
  754.         throw $this->createAccessDeniedHttpException();
  755.     }
  757.     /**
  758.      * @param DataObject\ClassDefinition[] $classes
  759.      *
  760.      * @return array
  761.      */
  762.     protected function prepareChildClasses(array $classes): array
  763.     {
  764.         $reduced = [];
  765.         foreach ($classes as $class) {
  766.             $reduced[] = [
  767.                 'id' => $class->getId(),
  768.                 'name' => $class->getName(),
  769.                 'inheritance' => $class->getAllowInherit(),
  770.             ];
  771.         }
  773.         return $reduced;
  774.     }
  776.     /**
  777.      * @Route("/add", name="add", methods={"POST"})
  778.      *
  779.      * @param Request $request
  780.      * @param Model\FactoryInterface $modelFactory
  781.      *
  782.      * @return JsonResponse
  783.      */
  784.     public function addAction(Request $request, Model\FactoryInterface $modelFactory): JsonResponse
  785.     {
  786.         $message = '';
  787.         $parent = DataObject::getById((int) $request->get('parentId'));
  789.         if (!$parent->isAllowed('create')) {
  790.             $message = 'prevented adding object because of missing permissions';
  791.             Logger::debug($message);
  792.         }
  794.         $intendedPath = $parent->getRealFullPath() . '/' . $request->get('key');
  795.         if (DataObject\Service::pathExists($intendedPath)) {
  796.             $message = 'prevented creating object because object with same path+key already exists';
  797.             Logger::debug($message);
  798.         }
  800.         //return false if missing permissions or path+key already exists
  801.         if (!empty($message)) {
  802.             return $this->adminJson([
  803.                 'success' => false,
  804.                 'message' => $message,
  805.             ]);
  806.         }
  808.         $className = 'Pimcore\\Model\\DataObject\\' . ucfirst($request->get('className'));
  809.         /** @var DataObject\Concrete $object */
  810.         $object = $modelFactory->build($className);
  811.         $object->setOmitMandatoryCheck(true); // allow to save the object although there are mandatory fields
  812.         $object->setClassId($request->get('classId'));
  814.         if ($request->get('variantViaTree')) {
  815.             $parentId = $request->get('parentId');
  816.             $parent = DataObject\Concrete::getById($parentId);
  817.             $object->setClassId($parent->getClass()->getId());
  818.         }
  820.         $object->setClassName($request->get('className'));
  821.         $object->setParentId($request->get('parentId'));
  822.         $object->setKey($request->get('key'));
  823.         $object->setCreationDate(time());
  824.         $object->setUserOwner($this->getAdminUser()->getId());
  825.         $object->setUserModification($this->getAdminUser()->getId());
  826.         $object->setPublished(false);
  828.         $objectType = $request->get('objecttype');
  829.         if (in_array($objectType, [DataObject::OBJECT_TYPE_OBJECT, DataObject::OBJECT_TYPE_VARIANT])) {
  830.             $object->setType($objectType);
  831.         }
  833.         try {
  834.             $object->save();
  835.             $return = [
  836.                 'success' => true,
  837.                 'id' => $object->getId(),
  838.                 'type' => $object->getType(),
  839.                 'message' => $message,
  840.             ];
  841.         } catch (\Exception $e) {
  842.             $return = [
  843.                 'success' => false,
  844.                 'message' => $e->getMessage(),
  845.             ];
  846.         }
  848.         return $this->adminJson($return);
  849.     }
  851.     /**
  852.      * @Route("/add-folder", name="addfolder", methods={"POST"})
  853.      *
  854.      * @param Request $request
  855.      *
  856.      * @return JsonResponse
  857.      */
  858.     public function addFolderAction(Request $request)
  859.     {
  860.         $success = false;
  862.         $parent = DataObject::getById((int) $request->get('parentId'));
  863.         if ($parent->isAllowed('create')) {
  864.             if (!DataObject\Service::pathExists($parent->getRealFullPath() . '/' . $request->get('key'))) {
  865.                 $folder = DataObject\Folder::create([
  866.                     'o_parentId' => $request->get('parentId'),
  867.                     'o_creationDate' => time(),
  868.                     'o_userOwner' => $this->getAdminUser()->getId(),
  869.                     'o_userModification' => $this->getAdminUser()->getId(),
  870.                     'o_key' => $request->get('key'),
  871.                     'o_published' => true,
  872.                 ]);
  874.                 try {
  875.                     $folder->save();
  876.                     $success = true;
  877.                 } catch (\Exception $e) {
  878.                     return $this->adminJson(['success' => false, 'message' => $e->getMessage()]);
  879.                 }
  880.             }
  881.         } else {
  882.             Logger::debug('prevented creating object id because of missing permissions');
  883.         }
  885.         return $this->adminJson(['success' => $success]);
  886.     }
  888.     /**
  889.      * @Route("/delete", name="delete", methods={"DELETE"})
  890.      *
  891.      * @param Request $request
  892.      *
  893.      * @return JsonResponse
  894.      *
  895.      * @throws \Exception
  896.      */
  897.     public function deleteAction(Request $request)
  898.     {
  899.         $type = $request->get('type');
  901.         if ($type === 'childs') {
  902.             trigger_deprecation(
  903.                 'pimcore/pimcore',
  904.                 '10.4',
  905.                 'Type childs is deprecated. Use children instead'
  906.             );
  907.             $type = 'children';
  908.         }
  909.         if ($type === 'children') {
  910.             $parentObject = DataObject::getById((int) $request->get('id'));
  912.             $list = new DataObject\Listing();
  913.             $list->setCondition('o_path LIKE ' . $list->quote($list->escapeLike($parentObject->getRealFullPath()) . '/%'));
  914.             $list->setLimit((int)$request->get('amount'));
  915.             $list->setOrderKey('LENGTH(o_path)', false);
  916.             $list->setOrder('DESC');
  918.             $deletedItems = [];
  919.             foreach ($list as $object) {
  920.                 $deletedItems[$object->getId()] = $object->getRealFullPath();
  921.                 if ($object->isAllowed('delete') && !$object->isLocked()) {
  922.                     $object->delete();
  923.                 }
  924.             }
  926.             return $this->adminJson(['success' => true, 'deleted' => $deletedItems]);
  927.         }
  928.         if ($id = $request->get('id')) {
  929.             $object = DataObject::getById((int) $id);
  930.             if ($object) {
  931.                 if (!$object->isAllowed('delete')) {
  932.                     throw $this->createAccessDeniedHttpException();
  933.                 }
  934.                 if ($object->isLocked()) {
  935.                     return $this->adminJson(['success' => false, 'message' => 'prevented deleting object, because it is locked: ID: ' . $object->getId()]);
  936.                 }
  937.                 $object->delete();
  938.             }
  940.             // return true, even when the object doesn't exist, this can be the case when using batch delete incl. children
  941.             return $this->adminJson(['success' => true]);
  942.         }
  944.         return $this->adminJson(['success' => false]);
  945.     }
  947.     /**
  948.      * @Route("/change-children-sort-by", name="changechildrensortby", methods={"PUT"})
  949.      *
  950.      * @param Request $request
  951.      *
  952.      * @return JsonResponse
  953.      *
  954.      * @throws \Exception
  955.      */
  956.     public function changeChildrenSortByAction(Request $request)
  957.     {
  958.         $object = DataObject::getById((int) $request->get('id'));
  959.         if ($object) {
  960.             $sortBy = $request->get('sortBy');
  961.             $sortOrder = $request->get('childrenSortOrder');
  962.             if (!\in_array($sortOrder, ['ASC', 'DESC'])) {
  963.                 $sortOrder = 'ASC';
  964.             }
  966.             $currentSortBy = $object->getChildrenSortBy();
  968.             $object->setChildrenSortBy($sortBy);
  969.             $object->setChildrenSortOrder($sortOrder);
  971.             if ($currentSortBy != $sortBy) {
  972.                 $user = Tool\Admin::getCurrentUser();
  974.                 if (!$user->isAdmin() && !$user->isAllowed('objects_sort_method')) {
  975.                     return $this->json(['success' => false, 'message' => 'Changing the sort method is only allowed for admin users']);
  976.                 }
  978.                 if ($sortBy == 'index') {
  979.                     $this->reindexBasedOnSortOrder($object, $sortOrder);
  980.                 }
  981.             }
  983.             $object->save();
  985.             return $this->json(['success' => true]);
  986.         }
  988.         return $this->json(['success' => false, 'message' => 'Unable to change a sorting way of children items.']);
  989.     }
  991.     /**
  992.      * @Route("/update", name="update", methods={"PUT"})
  993.      *
  994.      * @param Request $request
  995.      *
  996.      * @return JsonResponse
  997.      *
  998.      * @throws \Exception
  999.      */
  1000.     public function updateAction(Request $request)
  1001.     {
  1002.         $values = $this->decodeJson($request->get('values'));
  1004.         $ids = $this->decodeJson($request->get('id'));
  1006.         if (is_array($ids)) {
  1007.             $return = ['success' => true];
  1008.             foreach ($ids as $id) {
  1009.                 $object = DataObject::getById((int)$id);
  1010.                 $return = $this->executeUpdateAction($object, $values);
  1011.                 if (!$return['success']) {
  1012.                     return $this->adminJson($return);
  1013.                 }
  1014.             }
  1015.         } else {
  1016.             $object = DataObject::getById((int)$ids);
  1017.             $return = $this->executeUpdateAction($object, $values);
  1018.         }
  1020.         return $this->adminJson($return);
  1021.     }
  1023.     /**
  1024.      * @return array{success: bool, message?: string}
  1025.      *
  1026.      * @throws \Exception
  1027.      */
  1028.     private function executeUpdateAction(DataObject $object, mixed $values): array
  1029.     {
  1030.         $success = false;
  1032.         if ($object instanceof DataObject\Concrete) {
  1033.             $object->setOmitMandatoryCheck(true);
  1034.         }
  1036.         // this prevents the user from renaming, relocating (actions in the tree) if the newest version isn't the published one
  1037.         // the reason is that otherwise the content of the newer not published version will be overwritten
  1038.         if ($object instanceof DataObject\Concrete) {
  1039.             $latestVersion = $object->getLatestVersion();
  1040.             if ($latestVersion && $latestVersion->getData()->getModificationDate() != $object->getModificationDate()) {
  1041.                 return ['success' => false, 'message' => "You can't rename or relocate if there's a newer not published version"];
  1042.             }
  1043.         }
  1045.         $key = $values['key'] ?? null;
  1047.         if ($object->isAllowed('settings')) {
  1048.             if ($key) {
  1049.                 if ($object->isAllowed('rename')) {
  1050.                     $object->setKey($key);
  1051.                 } elseif ($key !== $object->getKey()) {
  1052.                     Logger::debug('prevented renaming object because of missing permissions ');
  1053.                 }
  1054.             }
  1056.             if (!empty($values['parentId'])) {
  1057.                 $parent = DataObject::getById($values['parentId']);
  1059.                 //check if parent is changed
  1060.                 if ($object->getParentId() != $parent->getId()) {
  1061.                     if (!$parent->isAllowed('create')) {
  1062.                         throw new \Exception('Prevented moving object - no create permission on new parent ');
  1063.                     }
  1065.                     $objectWithSamePath = DataObject::getByPath($parent->getRealFullPath() . '/' . $object->getKey());
  1067.                     if ($objectWithSamePath != null) {
  1068.                         return ['success' => false, 'message' => 'prevented creating object because object with same path+key already exists'];
  1069.                     }
  1071.                     if ($object->isLocked()) {
  1072.                         return ['success' => false, 'message' => 'prevented moving object, because it is locked: ID: ' . $object->getId()];
  1073.                     }
  1075.                     $object->setParentId($values['parentId']);
  1076.                 }
  1077.             }
  1079.             if (array_key_exists('locked', $values)) {
  1080.                 $object->setLocked($values['locked']);
  1081.             }
  1083.             $object->setModificationDate(time());
  1084.             $object->setUserModification($this->getAdminUser()->getId());
  1086.             try {
  1087.                 $isIndexUpdate = isset($values['indices']);
  1089.                 if ($isIndexUpdate) {
  1090.                     // Ensure the update sort index is already available in the postUpdate eventListener
  1091.                     $indexUpdate = is_int($values['indices']) ? $values['indices'] : $values['indices'][$object->getId()];
  1092.                     $object->setIndex($indexUpdate);
  1093.                 }
  1095.                 $object->save();
  1097.                 if ($isIndexUpdate) {
  1098.                     $this->updateIndexesOfObjectSiblings($object, $indexUpdate);
  1099.                 }
  1101.                 $success = true;
  1102.             } catch (\Exception $e) {
  1103.                 Logger::error((string) $e);
  1105.                 return ['success' => false, 'message' => $e->getMessage()];
  1106.             }
  1107.         } elseif ($key && $object->isAllowed('rename')) {
  1108.             return $this->renameObject($object, $key);
  1109.         } else {
  1110.             Logger::debug('prevented update object because of missing permissions.');
  1111.         }
  1113.         return ['success' => $success];
  1114.     }
  1116.     private function executeInsideTransaction(callable $fn)
  1117.     {
  1118.         $maxRetries = 5;
  1119.         for ($retries = 0; $retries < $maxRetries; $retries++) {
  1120.             try {
  1121.                 Db::get()->beginTransaction();
  1123.                 $fn();
  1125.                 Db::get()->commit();
  1127.                 break;
  1128.             } catch (\Exception $e) {
  1129.                 Db::get()->rollBack();
  1131.                 // we try to start the transaction $maxRetries times again (deadlocks, ...)
  1132.                 if ($retries < ($maxRetries - 1)) {
  1133.                     $run = $retries + 1;
  1134.                     $waitTime = rand(1, 5) * 100000; // microseconds
  1135.                     Logger::warn('Unable to finish transaction (' . $run . ". run) because of the following reason '" . $e->getMessage() . "'. --> Retrying in " . $waitTime . ' microseconds ... (' . ($run + 1) . ' of ' . $maxRetries . ')');
  1137.                     usleep($waitTime); // wait specified time until we restart the transaction
  1138.                 } else {
  1139.                     // if the transaction still fail after $maxRetries retries, we throw out the exception
  1140.                     Logger::error('Finally giving up restarting the same transaction again and again, last message: ' . $e->getMessage());
  1142.                     throw $e;
  1143.                 }
  1144.             }
  1145.         }
  1146.     }
  1148.     /**
  1149.      * @param DataObject\AbstractObject $parentObject
  1150.      * @param string $currentSortOrder
  1151.      */
  1152.     protected function reindexBasedOnSortOrder(DataObject\AbstractObject $parentObject, string $currentSortOrder)
  1153.     {
  1154.         $fn = function () use ($parentObject, $currentSortOrder) {
  1155.             $list = new DataObject\Listing();
  1157.             $db = Db::get();
  1158.             $result = $db->executeStatement(
  1159.                 'UPDATE '.$list->getDao()->getTableName().' o,
  1160.                     (
  1161.                     SELECT newIndex, o_id FROM (
  1162.                         SELECT @n := @n +1 AS newIndex, o_id
  1163.                         FROM '.$list->getDao()->getTableName().',
  1164.                                 (SELECT @n := -1) variable
  1165.                                  WHERE o_parentId = ? ORDER BY o_key ' . $currentSortOrder
  1166.                                .') tmp
  1167.                     ) order_table
  1168.                     SET o.o_index = order_table.newIndex
  1169.                     WHERE o.o_id=order_table.o_id',
  1170.                 [
  1171.                     $parentObject->getId(),
  1172.                 ]
  1173.             );
  1175.             $db = Db::get();
  1176.             $children = $db->fetchAllAssociative(
  1177.                 'SELECT o_id, o_modificationDate, o_versionCount FROM objects'
  1178.                 .' WHERE o_parentId = ? ORDER BY o_index ASC',
  1179.                 [$parentObject->getId()]
  1180.             );
  1181.             $index = 0;
  1183.             foreach ($children as $child) {
  1184.                 $this->updateLatestVersionIndex($child['o_id'], $child['o_modificationDate']);
  1185.                 $index++;
  1187.                 DataObject::clearDependentCacheByObjectId($child['o_id']);
  1188.             }
  1189.         };
  1191.         $this->executeInsideTransaction($fn);
  1192.     }
  1194.     private function updateLatestVersionIndex($objectId, $newIndex)
  1195.     {
  1196.         $object = DataObject\Concrete::getById($objectId);
  1198.         if (
  1199.             $object &&
  1200.             $object->getType() != DataObject::OBJECT_TYPE_FOLDER &&
  1201.             $latestVersion = $object->getLatestVersion()
  1202.         ) {
  1203.             // don't renew references (which means loading the target elements)
  1204.             // Not needed as we just save a new version with the updated index
  1205.             $object = $latestVersion->loadData(false);
  1206.             if ($newIndex !== $object->getIndex()) {
  1207.                 $object->setIndex($newIndex);
  1208.             }
  1209.             $latestVersion->save();
  1210.         }
  1211.     }
  1213.     /**
  1214.      * @param DataObject\AbstractObject $updatedObject
  1215.      * @param int $newIndex
  1216.      */
  1217.     protected function updateIndexesOfObjectSiblings(DataObject\AbstractObject $updatedObject, $newIndex)
  1218.     {
  1219.         $fn = function () use ($updatedObject, $newIndex) {
  1220.             $list = new DataObject\Listing();
  1221.             $updatedObject->saveIndex($newIndex);
  1223.             // The cte and the limit are needed to order the data before the newIndex is set
  1224.             $db = Db::get();
  1225.             $db->executeStatement(
  1226.                 'UPDATE '.$list->getDao()->getTableName().' o,
  1227.                     (
  1228.                         SELECT newIndex, o_id
  1229.                         FROM (
  1230.                             With cte As (SELECT o_index, o_id FROM ' . $list->getDao()->getTableName() . ' WHERE o_parentId = ? AND o_id != ? AND o_type IN (\''.implode(
  1231.                     "','", [
  1232.                         DataObject::OBJECT_TYPE_OBJECT,
  1233.                         DataObject::OBJECT_TYPE_VARIANT,
  1234.                         DataObject::OBJECT_TYPE_FOLDER,
  1235.                     ]
  1236.                 ).'\') ORDER BY o_index LIMIT '. $updatedObject->getParent()->getChildAmount() .')
  1237.                             SELECT @n := IF(@n = ? - 1,@n + 2,@n + 1) AS newIndex, o_id
  1238.                             FROM cte,
  1239.                             (SELECT @n := -1) variable
  1240.                         ) tmp
  1241.                     ) order_table
  1242.                     SET o.o_index = order_table.newIndex
  1243.                     WHERE o.o_id=order_table.o_id',
  1244.                 [
  1245.                     $updatedObject->getParentId(),
  1246.                     $updatedObject->getId(),
  1247.                     $newIndex,
  1248.                 ]
  1249.             );
  1251.             $siblings = $db->fetchAllAssociative(
  1252.                 'SELECT o_id, o_modificationDate, o_versionCount, o_key, o_index FROM objects'
  1253.                 ." WHERE o_parentId = ? AND o_id != ? AND o_type IN ('object', 'variant','folder') ORDER BY o_index ASC",
  1254.                 [$updatedObject->getParentId(), $updatedObject->getId()]
  1255.             );
  1256.             $index = 0;
  1258.             foreach ($siblings as $sibling) {
  1259.                 if ($index == $newIndex) {
  1260.                     $index++;
  1261.                 }
  1263.                 $this->updateLatestVersionIndex($sibling['o_id'], $index);
  1264.                 $index++;
  1266.                 DataObject::clearDependentCacheByObjectId($sibling['o_id']);
  1267.             }
  1268.         };
  1270.         $this->executeInsideTransaction($fn);
  1271.     }
  1273.     /**
  1274.      * @Route("/save", name="save", methods={"POST", "PUT"})
  1275.      *
  1276.      * @param Request $request
  1277.      *
  1278.      * @return JsonResponse
  1279.      *
  1280.      * @throws \Exception
  1281.      */
  1282.     public function saveAction(Request $request)
  1283.     {
  1284.         $objectFromDatabase = DataObject\Concrete::getById((int) $request->get('id'));
  1286.         if (!$objectFromDatabase instanceof DataObject\Concrete) {
  1287.             return $this->adminJson(['success' => false, 'message' => 'Could not find object']);
  1288.         }
  1290.         // set the latest available version for editmode
  1291.         $object = $this->getLatestVersion($objectFromDatabase);
  1292.         $object->setUserModification($this->getAdminUser()->getId());
  1294.         $objectFromVersion = $object !== $objectFromDatabase;
  1295.         $originalModificationDate = $objectFromVersion ? $object->getModificationDate() : $objectFromDatabase->getModificationDate();
  1296.         if ($objectFromVersion) {
  1297.             if (method_exists($object, 'getLocalizedFields')) {
  1298.                 /** @var DataObject\Localizedfield $localizedFields */
  1299.                 $localizedFields = $object->getLocalizedFields();
  1300.                 $localizedFields->setLoadedAllLazyData();
  1301.             }
  1302.         }
  1304.         // data
  1305.         $data = [];
  1306.         if ($request->get('data')) {
  1307.             $data = $this->decodeJson($request->get('data'));
  1308.             foreach ($data as $key => $value) {
  1309.                 $fd = $object->getClass()->getFieldDefinition($key);
  1310.                 if ($fd) {
  1311.                     if ($fd instanceof DataObject\ClassDefinition\Data\Localizedfields) {
  1312.                         $user = Tool\Admin::getCurrentUser();
  1313.                         if (!$user->getAdmin()) {
  1314.                             $allowedLanguages = DataObject\Service::getLanguagePermissions($object, $user, 'lEdit');
  1315.                             if (!is_null($allowedLanguages)) {
  1316.                                 $allowedLanguages = array_keys($allowedLanguages);
  1317.                                 $submittedLanguages = array_keys($data[$key]);
  1318.                                 foreach ($submittedLanguages as $submittedLanguage) {
  1319.                                     if (!in_array($submittedLanguage, $allowedLanguages)) {
  1320.                                         unset($value[$submittedLanguage]);
  1321.                                     }
  1322.                                 }
  1323.                             }
  1324.                         }
  1325.                     }
  1327.                     if ($fd instanceof ReverseObjectRelation) {
  1328.                         $remoteClass = DataObject\ClassDefinition::getByName($fd->getOwnerClassName());
  1329.                         $relations = $object->getRelationData($fd->getOwnerFieldName(), false, $remoteClass->getId());
  1330.                         $toAdd = $this->detectAddedRemoteOwnerRelations($relations, $value);
  1331.                         $toDelete = $this->detectDeletedRemoteOwnerRelations($relations, $value);
  1332.                         if (count($toAdd) > 0 || count($toDelete) > 0) {
  1333.                             $this->processRemoteOwnerRelations($object, $toDelete, $toAdd, $fd->getOwnerFieldName());
  1334.                         }
  1335.                     } else {
  1336.                         $object->setValue($key, $fd->getDataFromEditmode($value, $object, ['objectFromVersion' => $objectFromVersion]));
  1337.                     }
  1338.                 }
  1339.             }
  1340.         }
  1342.         // general settings
  1343.         // @TODO: IS THIS STILL NECESSARY?
  1344.         if ($request->get('general')) {
  1345.             $general = $this->decodeJson($request->get('general'));
  1347.             // do not allow all values to be set, will cause problems (eg. icon)
  1348.             if (is_array($general) && count($general) > 0) {
  1349.                 foreach ($general as $key => $value) {
  1350.                     if (!in_array($key, ['o_id', 'o_classId', 'o_className', 'o_type', 'icon', 'o_userOwner', 'o_userModification', 'o_modificationDate'])) {
  1351.                         $object->setValue($key, $value);
  1352.                     }
  1353.                 }
  1354.             }
  1355.         }
  1357.         $this->assignPropertiesFromEditmode($request, $object);
  1358.         $this->applySchedulerDataToElement($request, $object);
  1360.         if (($request->get('task') === 'unpublish' && !$object->isAllowed('unpublish')) || ($request->get('task') === 'publish' && !$object->isAllowed('publish'))) {
  1361.             throw $this->createAccessDeniedHttpException();
  1362.         }
  1364.         if ($request->get('task') == 'unpublish') {
  1365.             $object->setPublished(false);
  1366.         }
  1368.         if ($request->get('task') == 'publish') {
  1369.             $object->setPublished(true);
  1370.         }
  1372.         // unpublish and save version is possible without checking mandatory fields
  1373.         if (in_array($request->get('task'), ['unpublish', 'version', 'autoSave'])) {
  1374.             $object->setOmitMandatoryCheck(true);
  1375.         }
  1377.         if (($request->get('task') == 'publish') || ($request->get('task') == 'unpublish')) {
  1378.             // disabled for now: see different approach [Elements] Show users who are working on the same element #9381
  1379.             // https://github.com/pimcore/pimcore/issues/9381
  1380.             //            if ($data) {
  1381.             //                if (!$this->performFieldcollectionModificationCheck($request, $object, $originalModificationDate, $data)) {
  1382.             //                    return $this->adminJson(['success' => false, 'message' => 'Could be that someone messed around with the fieldcollection in the meantime. Please reload and try again']);
  1383.             //                }
  1384.             //            }
  1386.             $object->save();
  1387.             $treeData = $this->getTreeNodeConfig($object);
  1389.             $newObject = DataObject::getById($object->getId(), ['force' => true]);
  1391.             if ($request->get('task') == 'publish') {
  1392.                 $object->deleteAutoSaveVersions($this->getAdminUser()->getId());
  1393.             }
  1395.             return $this->adminJson([
  1396.                 'success' => true,
  1397.                 'general' => ['o_modificationDate' => $object->getModificationDate(),
  1398.                     'versionDate' => $newObject->getModificationDate(),
  1399.                     'versionCount' => $newObject->getVersionCount(),
  1400.                 ],
  1401.                 'treeData' => $treeData,
  1402.             ]);
  1403.         } elseif ($request->get('task') == 'session') {
  1404.             //TODO https://github.com/pimcore/pimcore/issues/9536
  1405.             DataObject\Service::saveElementToSession($object, '', false);
  1407.             return $this->adminJson(['success' => true]);
  1408.         } elseif ($request->get('task') == 'scheduler') {
  1409.             if ($object->isAllowed('settings')) {
  1410.                 $object->saveScheduledTasks();
  1412.                 return $this->adminJson(['success' => true]);
  1413.             }
  1414.         } elseif ($object->isAllowed('save') || $object->isAllowed('publish')) {
  1415.             $isAutoSave = $request->get('task') == 'autoSave';
  1416.             $draftData = [];
  1418.             if ($object->isPublished() || $isAutoSave) {
  1419.                 $version = $object->saveVersion(true, true, null, $isAutoSave);
  1420.                 $draftData = [
  1421.                     'id' => $version->getId(),
  1422.                     'modificationDate' => $version->getDate(),
  1423.                     'isAutoSave' => $version->isAutoSave(),
  1424.                 ];
  1425.             } else {
  1426.                 $object->save();
  1427.             }
  1429.             if ($request->get('task') == 'version') {
  1430.                 $object->deleteAutoSaveVersions($this->getAdminUser()->getId());
  1431.             }
  1433.             $treeData = $this->getTreeNodeConfig($object);
  1435.             $newObject = DataObject::getById($object->getId(), ['force' => true]);
  1437.             return $this->adminJson([
  1438.                 'success' => true,
  1439.                 'general' => ['o_modificationDate' => $object->getModificationDate(),
  1440.                     'versionDate' => $newObject->getModificationDate(),
  1441.                     'versionCount' => $newObject->getVersionCount(),
  1442.                 ],
  1443.                 'draft' => $draftData,
  1444.                 'treeData' => $treeData,
  1445.             ]);
  1446.         }
  1448.         throw $this->createAccessDeniedHttpException();
  1449.     }
  1451.     /**
  1452.      * @param Request $request
  1453.      * @param DataObject\Concrete $object
  1454.      * @param int $originalModificationDate
  1455.      * @param array $data
  1456.      *
  1457.      * @return bool
  1458.      *
  1459.      * @throws \Exception
  1460.      */
  1461.     protected function performFieldcollectionModificationCheck(Request $request, DataObject\Concrete $object, $originalModificationDate, $data)
  1462.     {
  1463.         $modificationDate = $request->get('modificationDate');
  1464.         if ($modificationDate != $originalModificationDate) {
  1465.             $fielddefinitions = $object->getClass()->getFieldDefinitions();
  1466.             foreach ($fielddefinitions as $fd) {
  1467.                 if ($fd instanceof DataObject\ClassDefinition\Data\Fieldcollections) {
  1468.                     if (isset($data[$fd->getName()])) {
  1469.                         $allowedTypes = $fd->getAllowedTypes();
  1470.                         foreach ($allowedTypes as $type) {
  1471.                             /** @var DataObject\Fieldcollection\Definition $fdDef */
  1472.                             $fdDef = DataObject\Fieldcollection\Definition::getByKey($type);
  1473.                             $childDefinitions = $fdDef->getFieldDefinitions();
  1474.                             foreach ($childDefinitions as $childDef) {
  1475.                                 if ($childDef instanceof DataObject\ClassDefinition\Data\Localizedfields) {
  1476.                                     return false;
  1477.                                 }
  1478.                             }
  1479.                         }
  1480.                     }
  1481.                 }
  1482.             }
  1483.         }
  1485.         return true;
  1486.     }
  1488.     /**
  1489.      * @Route("/save-folder", name="savefolder", methods={"PUT"})
  1490.      *
  1491.      * @param Request $request
  1492.      *
  1493.      * @return JsonResponse
  1494.      */
  1495.     public function saveFolderAction(Request $request)
  1496.     {
  1497.         $object = DataObject::getById((int) $request->get('id'));
  1499.         if (!$object) {
  1500.             throw $this->createNotFoundException('Object not found');
  1501.         }
  1503.         if ($object->isAllowed('publish')) {
  1504.             try {
  1505.                 // general settings
  1506.                 $general = $this->decodeJson($request->get('general'));
  1507.                 $object->setValues($general);
  1508.                 $object->setUserModification($this->getAdminUser()->getId());
  1510.                 $this->assignPropertiesFromEditmode($request, $object);
  1512.                 $object->save();
  1514.                 return $this->adminJson(['success' => true]);
  1515.             } catch (\Exception $e) {
  1516.                 return $this->adminJson(['success' => false, 'message' => $e->getMessage()]);
  1517.             }
  1518.         }
  1520.         throw $this->createAccessDeniedHttpException();
  1521.     }
  1523.     /**
  1524.      * @param Request $request
  1525.      * @param DataObject\AbstractObject $object
  1526.      */
  1527.     protected function assignPropertiesFromEditmode(Request $request, $object)
  1528.     {
  1529.         if ($request->get('properties')) {
  1530.             $properties = [];
  1531.             // assign inherited properties
  1532.             foreach ($object->getProperties() as $p) {
  1533.                 if ($p->isInherited()) {
  1534.                     $properties[$p->getName()] = $p;
  1535.                 }
  1536.             }
  1538.             $propertiesData = $this->decodeJson($request->get('properties'));
  1540.             if (is_array($propertiesData)) {
  1541.                 foreach ($propertiesData as $propertyName => $propertyData) {
  1542.                     $value = $propertyData['data'];
  1544.                     try {
  1545.                         $property = new Model\Property();
  1546.                         $property->setType($propertyData['type']);
  1547.                         $property->setName($propertyName);
  1548.                         $property->setCtype('object');
  1549.                         $property->setDataFromEditmode($value);
  1550.                         $property->setInheritable($propertyData['inheritable']);
  1552.                         $properties[$propertyName] = $property;
  1553.                     } catch (\Exception $e) {
  1554.                         Logger::err("Can't add " . $propertyName . ' to object ' . $object->getRealFullPath());
  1555.                     }
  1556.                 }
  1557.             }
  1558.             $object->setProperties($properties);
  1559.         }
  1560.     }
  1562.     /**
  1563.      * @Route("/publish-version", name="publishversion", methods={"POST"})
  1564.      *
  1565.      * @param Request $request
  1566.      *
  1567.      * @return JsonResponse
  1568.      */
  1569.     public function publishVersionAction(Request $request)
  1570.     {
  1571.         $version = Model\Version::getById((int) $request->get('id'));
  1572.         if (!$version) {
  1573.             throw $this->createNotFoundException();
  1574.         }
  1575.         $object = $version->loadData();
  1577.         $currentObject = DataObject::getById($object->getId());
  1578.         if ($currentObject->isAllowed('publish')) {
  1579.             $object->setPublished(true);
  1580.             $object->setUserModification($this->getAdminUser()->getId());
  1582.             try {
  1583.                 $object->save();
  1585.                 $this->addAdminStyle($object, ElementAdminStyleEvent::CONTEXT_TREE, $treeData);
  1587.                 return $this->adminJson(
  1588.                     [
  1589.                         'success' => true,
  1590.                         'general' => ['o_modificationDate' => $object->getModificationDate() ],
  1591.                         'treeData' => $treeData, ]
  1592.                 );
  1593.             } catch (\Exception $e) {
  1594.                 return $this->adminJson(['success' => false, 'message' => $e->getMessage()]);
  1595.             }
  1596.         }
  1598.         throw $this->createAccessDeniedHttpException();
  1599.     }
  1601.     /**
  1602.      * @Route("/preview-version", name="previewversion", methods={"GET"})
  1603.      *
  1604.      * @param Request $request
  1605.      *
  1606.      * @throws \Exception
  1607.      *
  1608.      * @return Response
  1609.      */
  1610.     public function previewVersionAction(Request $request)
  1611.     {
  1612.         DataObject::setDoNotRestoreKeyAndPath(true);
  1614.         $id = (int)$request->get('id');
  1615.         $version = Model\Version::getById($id);
  1616.         $object = $version->loadData();
  1618.         if (method_exists($object, 'getLocalizedFields')) {
  1619.             /** @var DataObject\Localizedfield $localizedFields */
  1620.             $localizedFields = $object->getLocalizedFields();
  1621.             $localizedFields->setLoadedAllLazyData();
  1622.         }
  1624.         DataObject::setDoNotRestoreKeyAndPath(false);
  1626.         if ($object) {
  1627.             if ($object->isAllowed('versions')) {
  1628.                 return $this->render('@PimcoreAdmin/Admin/DataObject/DataObject/previewVersion.html.twig',
  1629.                     [
  1630.                         'object' => $object,
  1631.                         'versionNote' => $version->getNote(),
  1632.                         'validLanguages' => Tool::getValidLanguages(),
  1633.                     ]);
  1634.             }
  1636.             throw $this->createAccessDeniedException('Permission denied, version id [' . $id . ']');
  1637.         }
  1639.         throw $this->createNotFoundException('Version with id [' . $id . "] doesn't exist");
  1640.     }
  1642.     /**
  1643.      * @Route("/diff-versions/from/{from}/to/{to}", name="diffversions", methods={"GET"})
  1644.      *
  1645.      * @param Request $request
  1646.      * @param int $from
  1647.      * @param int $to
  1648.      *
  1649.      * @return Response
  1650.      *
  1651.      * @throws \Exception
  1652.      */
  1653.     public function diffVersionsAction(Request $request, $from, $to)
  1654.     {
  1655.         DataObject::setDoNotRestoreKeyAndPath(true);
  1657.         $id1 = (int)$from;
  1658.         $id2 = (int)$to;
  1660.         $version1 = Model\Version::getById($id1);
  1661.         $object1 = $version1->loadData();
  1663.         if (method_exists($object1, 'getLocalizedFields')) {
  1664.             /** @var DataObject\Localizedfield $localizedFields1 */
  1665.             $localizedFields1 = $object1->getLocalizedFields();
  1666.             $localizedFields1->setLoadedAllLazyData();
  1667.         }
  1669.         $version2 = Model\Version::getById($id2);
  1670.         $object2 = $version2->loadData();
  1672.         if (method_exists($object2, 'getLocalizedFields')) {
  1673.             /** @var DataObject\Localizedfield $localizedFields2 */
  1674.             $localizedFields2 = $object2->getLocalizedFields();
  1675.             $localizedFields2->setLoadedAllLazyData();
  1676.         }
  1678.         DataObject::setDoNotRestoreKeyAndPath(false);
  1680.         if ($object1 && $object2) {
  1681.             if ($object1->isAllowed('versions') && $object2->isAllowed('versions')) {
  1682.                 return $this->render('@PimcoreAdmin/Admin/DataObject/DataObject/diffVersions.html.twig',
  1683.                     [
  1684.                         'object1' => $object1,
  1685.                         'versionNote1' => $version1->getNote(),
  1686.                         'object2' => $object2,
  1687.                         'versionNote2' => $version2->getNote(),
  1688.                         'validLanguages' => Tool::getValidLanguages(),
  1689.                     ]);
  1690.             }
  1692.             throw $this->createAccessDeniedException('Permission denied, version ids [' . $id1 . ', ' . $id2 . ']');
  1693.         }
  1695.         throw $this->createNotFoundException('Version with ids [' . $id1 . ', ' . $id2 . "] doesn't exist");
  1696.     }
  1698.     /**
  1699.      * @Route("/grid-proxy", name="gridproxy", methods={"GET", "POST", "PUT"})
  1700.      *
  1701.      * @param Request $request
  1702.      * @param EventDispatcherInterface $eventDispatcher
  1703.      * @param GridHelperService $gridHelperService
  1704.      * @param LocaleServiceInterface $localeService
  1705.      * @param CsrfProtectionHandler $csrfProtection
  1706.      *
  1707.      * @return JsonResponse
  1708.      */
  1709.     public function gridProxyAction(
  1710.         Request $request,
  1711.         EventDispatcherInterface $eventDispatcher,
  1712.         GridHelperService $gridHelperService,
  1713.         LocaleServiceInterface $localeService,
  1714.         CsrfProtectionHandler $csrfProtection
  1715.     ): JsonResponse {
  1716.         $allParams = array_merge($request->request->all(), $request->query->all());
  1717.         if (isset($allParams['context']) && $allParams['context']) {
  1718.             $allParams['context'] = json_decode($allParams['context'], true);
  1719.         } else {
  1720.             $allParams['context'] = [];
  1721.         }
  1723.         $filterPrepareEvent = new GenericEvent($this, [
  1724.             'requestParams' => $allParams,
  1725.         ]);
  1726.         $eventDispatcher->dispatch($filterPrepareEvent, AdminEvents::OBJECT_LIST_BEFORE_FILTER_PREPARE);
  1728.         $allParams = $filterPrepareEvent->getArgument('requestParams');
  1730.         $csrfProtection->checkCsrfToken($request);
  1732.         $result = $this->gridProxy(
  1733.             $allParams,
  1734.             DataObject::OBJECT_TYPE_OBJECT,
  1735.             $request,
  1736.             $eventDispatcher,
  1737.             $gridHelperService,
  1738.             $localeService
  1739.         );
  1741.         return $this->adminJson($result);
  1742.     }
  1744.     /**
  1745.      * @Route("/copy-info", name="copyinfo", methods={"GET"})
  1746.      *
  1747.      * @param Request $request
  1748.      *
  1749.      * @return JsonResponse
  1750.      */
  1751.     public function copyInfoAction(Request $request)
  1752.     {
  1753.         $transactionId = time();
  1754.         $pasteJobs = [];
  1756.         Tool\Session::useSession(function (AttributeBagInterface $session) use ($transactionId) {
  1757.             $session->set((string) $transactionId, ['idMapping' => []]);
  1758.         }, 'pimcore_copy');
  1760.         if ($request->get('type') == 'recursive' || $request->get('type') == 'recursive-update-references') {
  1761.             $object = DataObject::getById((int) $request->get('sourceId'));
  1763.             // first of all the new parent
  1764.             $pasteJobs[] = [[
  1765.                 'url' => $this->generateUrl('pimcore_admin_dataobject_dataobject_copy'),
  1766.                 'method' => 'POST',
  1767.                 'params' => [
  1768.                     'sourceId' => $request->get('sourceId'),
  1769.                     'targetId' => $request->get('targetId'),
  1770.                     'type' => 'child',
  1771.                     'transactionId' => $transactionId,
  1772.                     'saveParentId' => true,
  1773.                 ],
  1774.             ]];
  1776.             if ($object->hasChildren(DataObject::$types)) {
  1777.                 // get amount of children
  1778.                 $list = new DataObject\Listing();
  1779.                 $list->setCondition('o_path LIKE ' . $list->quote($list->escapeLike($object->getRealFullPath()) . '/%'));
  1780.                 $list->setOrderKey('LENGTH(o_path)', false);
  1781.                 $list->setOrder('ASC');
  1782.                 $list->setObjectTypes(DataObject::$types);
  1783.                 $childIds = $list->loadIdList();
  1785.                 if (count($childIds) > 0) {
  1786.                     foreach ($childIds as $id) {
  1787.                         $pasteJobs[] = [[
  1788.                             'url' => $this->generateUrl('pimcore_admin_dataobject_dataobject_copy'),
  1789.                             'method' => 'POST',
  1790.                             'params' => [
  1791.                                 'sourceId' => $id,
  1792.                                 'targetParentId' => $request->get('targetId'),
  1793.                                 'sourceParentId' => $request->get('sourceId'),
  1794.                                 'type' => 'child',
  1795.                                 'transactionId' => $transactionId,
  1796.                             ],
  1797.                         ]];
  1798.                     }
  1799.                 }
  1801.                 // add id-rewrite steps
  1802.                 if ($request->get('type') == 'recursive-update-references') {
  1803.                     for ($i = 0; $i < (count($childIds) + 1); $i++) {
  1804.                         $pasteJobs[] = [[
  1805.                             'url' => $this->generateUrl('pimcore_admin_dataobject_dataobject_copyrewriteids'),
  1806.                             'method' => 'PUT',
  1807.                             'params' => [
  1808.                                 'transactionId' => $transactionId,
  1809.                                 '_dc' => uniqid(),
  1810.                             ],
  1811.                         ]];
  1812.                     }
  1813.                 }
  1814.             }
  1815.         } elseif ($request->get('type') == 'child' || $request->get('type') == 'replace') {
  1816.             // the object itself is the last one
  1817.             $pasteJobs[] = [[
  1818.                 'url' => $this->generateUrl('pimcore_admin_dataobject_dataobject_copy'),
  1819.                 'method' => 'POST',
  1820.                 'params' => [
  1821.                     'sourceId' => $request->get('sourceId'),
  1822.                     'targetId' => $request->get('targetId'),
  1823.                     'type' => $request->get('type'),
  1824.                     'transactionId' => $transactionId,
  1825.                 ],
  1826.             ]];
  1827.         }
  1829.         return $this->adminJson([
  1830.             'pastejobs' => $pasteJobs,
  1831.         ]);
  1832.     }
  1834.     /**
  1835.      * @Route("/copy-rewrite-ids", name="copyrewriteids", methods={"PUT"})
  1836.      *
  1837.      * @param Request $request
  1838.      *
  1839.      * @return JsonResponse
  1840.      *
  1841.      * @throws \Exception
  1842.      */
  1843.     public function copyRewriteIdsAction(Request $request)
  1844.     {
  1845.         $transactionId = $request->get('transactionId');
  1847.         $idStore = Tool\Session::useSession(function (AttributeBagInterface $session) use ($transactionId) {
  1848.             return $session->get($transactionId);
  1849.         }, 'pimcore_copy');
  1851.         if (!array_key_exists('rewrite-stack', $idStore)) {
  1852.             $idStore['rewrite-stack'] = array_values($idStore['idMapping']);
  1853.         }
  1855.         $id = array_shift($idStore['rewrite-stack']);
  1856.         $object = DataObject::getById($id);
  1858.         // create rewriteIds() config parameter
  1859.         $rewriteConfig = ['object' => $idStore['idMapping']];
  1861.         $object = DataObject\Service::rewriteIds($object, $rewriteConfig);
  1863.         $object->setUserModification($this->getAdminUser()->getId());
  1864.         $object->save();
  1866.         // write the store back to the session
  1867.         Tool\Session::useSession(function (AttributeBagInterface $session) use ($transactionId, $idStore) {
  1868.             $session->set($transactionId, $idStore);
  1869.         }, 'pimcore_copy');
  1871.         return $this->adminJson([
  1872.             'success' => true,
  1873.             'id' => $id,
  1874.         ]);
  1875.     }
  1877.     /**
  1878.      * @Route("/copy", name="copy", methods={"POST"})
  1879.      *
  1880.      * @param Request $request
  1881.      *
  1882.      * @return JsonResponse
  1883.      */
  1884.     public function copyAction(Request $request)
  1885.     {
  1886.         $message = '';
  1887.         $sourceId = (int)$request->get('sourceId');
  1888.         $source = DataObject::getById($sourceId);
  1890.         $session = Tool\Session::get('pimcore_copy');
  1891.         $sessionBag = $session->get($request->get('transactionId'));
  1893.         $targetId = (int)$request->get('targetId');
  1894.         if ($request->get('targetParentId')) {
  1895.             $sourceParent = DataObject::getById((int) $request->get('sourceParentId'));
  1897.             // this is because the key can get the prefix "_copy" if the target does already exists
  1898.             if ($sessionBag['parentId']) {
  1899.                 $targetParent = DataObject::getById($sessionBag['parentId']);
  1900.             } else {
  1901.                 $targetParent = DataObject::getById((int) $request->get('targetParentId'));
  1902.             }
  1904.             $targetPath = preg_replace('@^' . preg_quote($sourceParent->getRealFullPath(), '@') . '@', $targetParent . '/', $source->getRealPath());
  1905.             $target = DataObject::getByPath($targetPath);
  1906.         } else {
  1907.             $target = DataObject::getById($targetId);
  1908.         }
  1910.         if ($target->isAllowed('create')) {
  1911.             $source = DataObject::getById($sourceId);
  1912.             if ($source != null) {
  1913.                 if ($source instanceof DataObject\Concrete && $latestVersion = $source->getLatestVersion()) {
  1914.                     $source = $latestVersion->loadData();
  1915.                     $source->setPublished(false); //as latest version is used which is not published
  1916.                 }
  1918.                 if ($request->get('type') == 'child') {
  1919.                     $newObject = $this->_objectService->copyAsChild($target, $source);
  1921.                     $sessionBag['idMapping'][(int)$source->getId()] = (int)$newObject->getId();
  1923.                     // this is because the key can get the prefix "_copy" if the target does already exists
  1924.                     if ($request->get('saveParentId')) {
  1925.                         $sessionBag['parentId'] = $newObject->getId();
  1926.                     }
  1927.                 } elseif ($request->get('type') == 'replace') {
  1928.                     $this->_objectService->copyContents($target, $source);
  1929.                 }
  1931.                 $session->set($request->get('transactionId'), $sessionBag);
  1932.                 Tool\Session::writeClose();
  1934.                 return $this->adminJson(['success' => true, 'message' => $message]);
  1935.             } else {
  1936.                 Logger::error("could not execute copy/paste, source object with id [ $sourceId ] not found");
  1938.                 return $this->adminJson(['success' => false, 'message' => 'source object not found']);
  1939.             }
  1940.         } else {
  1941.             throw $this->createAccessDeniedHttpException();
  1942.         }
  1943.     }
  1945.     /**
  1946.      * @Route("/preview", name="preview", methods={"GET"})
  1947.      *
  1948.      * @param Request $request
  1949.      *
  1950.      * @return Response|RedirectResponse
  1951.      */
  1952.     public function previewAction(Request $request)
  1953.     {
  1954.         $id = $request->get('id');
  1955.         $object = DataObject\Service::getElementFromSession('object', $id);
  1957.         if ($object instanceof DataObject\Concrete) {
  1958.             $url = $object->getClass()->getPreviewUrl();
  1959.             if ($url) {
  1960.                 // replace named variables
  1961.                 $vars = $object->getObjectVars();
  1962.                 foreach ($vars as $key => $value) {
  1963.                     if (!empty($value) && \is_scalar($value)) {
  1964.                         $url = str_replace('%' . $key, urlencode($value), $url);
  1965.                     } else {
  1966.                         if (strpos($url, '%' . $key) !== false) {
  1967.                             return new Response('No preview available, please ensure that all fields which are required for the preview are filled correctly.');
  1968.                         }
  1969.                     }
  1970.                 }
  1971.                 $url = str_replace('%_locale', $this->getAdminUser()->getLanguage(), $url);
  1972.             } elseif ($previewService = $object->getClass()->getPreviewGenerator()) {
  1973.                 $url = $previewService->generatePreviewUrl($object, array_merge(['preview' => true, 'context' => $this], $request->query->all()));
  1974.             } elseif ($linkGenerator = $object->getClass()->getLinkGenerator()) {
  1975.                 $url = $linkGenerator->generate($object, ['preview' => true, 'context' => $this]);
  1976.             }
  1978.             if (!$url) {
  1979.                 return new Response("Preview not available, it seems that there's a problem with this object.");
  1980.             }
  1982.             // replace all remainaing % signs
  1983.             $url = str_replace('%', '%25', $url);
  1985.             $urlParts = parse_url($url);
  1987.             return $this->redirect($urlParts['path'] . '?pimcore_object_preview=' . $id . '&_dc=' . time() . (isset($urlParts['query']) ? '&' . $urlParts['query'] : ''));
  1988.         } else {
  1989.             return new Response("Preview not available, it seems that there's a problem with this object.");
  1990.         }
  1991.     }
  1993.     /**
  1994.      * @param  DataObject\Concrete $object
  1995.      * @param  array $toDelete
  1996.      * @param  array $toAdd
  1997.      * @param  string $ownerFieldName
  1998.      */
  1999.     protected function processRemoteOwnerRelations($object, $toDelete, $toAdd, $ownerFieldName)
  2000.     {
  2001.         $getter = 'get' . ucfirst($ownerFieldName);
  2002.         $setter = 'set' . ucfirst($ownerFieldName);
  2004.         foreach ($toDelete as $id) {
  2005.             $owner = DataObject::getById($id);
  2006.             //TODO: lock ?!
  2007.             if (method_exists($owner, $getter)) {
  2008.                 $currentData = $owner->$getter();
  2009.                 if (is_array($currentData)) {
  2010.                     for ($i = 0; $i < count($currentData); $i++) {
  2011.                         if ($currentData[$i]->getId() == $object->getId()) {
  2012.                             unset($currentData[$i]);
  2013.                             $owner->$setter($currentData);
  2015.                             break;
  2016.                         }
  2017.                     }
  2018.                 } else {
  2019.                     if ($currentData->getId() == $object->getId()) {
  2020.                         $owner->$setter(null);
  2021.                     }
  2022.                 }
  2023.             }
  2024.             $owner->setUserModification($this->getAdminUser()->getId());
  2025.             $owner->save();
  2026.             Logger::debug('Saved object id [ ' . $owner->getId() . ' ] by remote modification through [' . $object->getId() . '], Action: deleted [ ' . $object->getId() . " ] from [ $ownerFieldName]");
  2027.         }
  2029.         foreach ($toAdd as $id) {
  2030.             $owner = DataObject::getById($id);
  2031.             //TODO: lock ?!
  2032.             if (method_exists($owner, $getter)) {
  2033.                 $currentData = $owner->$getter();
  2034.                 if (is_array($currentData)) {
  2035.                     $currentData[] = $object;
  2036.                 } else {
  2037.                     $currentData = $object;
  2038.                 }
  2039.                 $owner->$setter($currentData);
  2040.                 $owner->setUserModification($this->getAdminUser()->getId());
  2041.                 $owner->save();
  2042.                 Logger::debug('Saved object id [ ' . $owner->getId() . ' ] by remote modification through [' . $object->getId() . '], Action: added [ ' . $object->getId() . " ] to [ $ownerFieldName ]");
  2043.             }
  2044.         }
  2045.     }
  2047.     /**
  2048.      * @param  array $relations
  2049.      * @param  array $value
  2050.      *
  2051.      * @return array
  2052.      */
  2053.     protected function detectDeletedRemoteOwnerRelations($relations, $value)
  2054.     {
  2055.         $originals = [];
  2056.         $changed = [];
  2057.         foreach ($relations as $r) {
  2058.             $originals[] = $r['dest_id'];
  2059.         }
  2060.         if (is_array($value)) {
  2061.             foreach ($value as $row) {
  2062.                 $changed[] = $row['id'];
  2063.             }
  2064.         }
  2065.         $diff = array_diff($originals, $changed);
  2067.         return $diff;
  2068.     }
  2070.     /**
  2071.      * @param  array $relations
  2072.      * @param  array $value
  2073.      *
  2074.      * @return array
  2075.      */
  2076.     protected function detectAddedRemoteOwnerRelations($relations, $value)
  2077.     {
  2078.         $originals = [];
  2079.         $changed = [];
  2080.         foreach ($relations as $r) {
  2081.             $originals[] = $r['dest_id'];
  2082.         }
  2083.         if (is_array($value)) {
  2084.             foreach ($value as $row) {
  2085.                 $changed[] = $row['id'];
  2086.             }
  2087.         }
  2088.         $diff = array_diff($changed, $originals);
  2090.         return $diff;
  2091.     }
  2093.     /**
  2094.      * @template T of DataObject\Concrete
  2095.      *
  2096.      * @param T $object
  2097.      * @param null|Version $draftVersion
  2098.      *
  2099.      * @return T
  2100.      */
  2101.     protected function getLatestVersion(DataObject\Concrete $object, &$draftVersion = null): ?DataObject\Concrete
  2102.     {
  2103.         $latestVersion = $object->getLatestVersion($this->getAdminUser()->getId());
  2104.         if ($latestVersion) {
  2105.             $latestObj = $latestVersion->loadData();
  2106.             if ($latestObj instanceof DataObject\Concrete) {
  2107.                 $draftVersion = $latestVersion;
  2109.                 return $latestObj;
  2110.             }
  2111.         }
  2113.         return $object;
  2114.     }
  2116.     /**
  2117.      * @param ControllerEvent $event
  2118.      */
  2119.     public function onKernelControllerEvent(ControllerEvent $event)
  2120.     {
  2121.         if (!$event->isMainRequest()) {
  2122.             return;
  2123.         }
  2125.         // check permissions
  2126.         $this->checkPermission('objects');
  2128.         $this->_objectService = new DataObject\Service($this->getAdminUser());
  2129.     }
  2130. }