vendor/pimcore/pimcore/models/DataObject/AbstractObject/Dao.php line 39

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\Model\DataObject\AbstractObject;
  18. use Pimcore\Db;
  19. use Pimcore\Db\Helper;
  20. use Pimcore\Logger;
  21. use Pimcore\Model;
  22. use Pimcore\Model\DataObject;
  23. use Pimcore\Model\User;
  25. /**
  26.  * @internal
  27.  *
  28.  * @property \Pimcore\Model\DataObject\AbstractObject $model
  29.  */
  30. class Dao extends Model\Element\Dao
  31. {
  32.     /**
  33.      * Get the data for the object from database for the given id
  34.      *
  35.      * @param int $id
  36.      *
  37.      * @throws Model\Exception\NotFoundException
  38.      */
  39.     public function getById($id)
  40.     {
  41.         $data = $this->db->fetchAssociative("SELECT objects.*, tree_locks.locked as o_locked FROM objects
  42.             LEFT JOIN tree_locks ON objects.o_id = tree_locks.id AND tree_locks.type = 'object'
  43.                 WHERE o_id = ?", [$id]);
  45.         if (!empty($data['o_id'])) {
  46.             $this->assignVariablesToModel($data);
  47.         } else {
  48.             throw new Model\Exception\NotFoundException('Object with the ID ' . $id . " doesn't exists");
  49.         }
  50.     }
  52.     /**
  53.      * Get the data for the object from database for the given path
  54.      *
  55.      * @param string $path
  56.      *
  57.      * @throws Model\Exception\NotFoundException
  58.      */
  59.     public function getByPath($path)
  60.     {
  61.         $params = $this->extractKeyAndPath($path);
  62.         $data = $this->db->fetchAssociative('SELECT o_id FROM objects WHERE o_path = :path AND `o_key` = :key', $params);
  64.         if (!empty($data['o_id'])) {
  65.             $this->assignVariablesToModel($data);
  66.         } else {
  67.             throw new Model\Exception\NotFoundException("object doesn't exist");
  68.         }
  69.     }
  71.     /**
  72.      * Create a new record for the object in database
  73.      */
  74.     public function create()
  75.     {
  76.         $this->db->insert('objects', [
  77.             'o_key' => $this->model->getKey(),
  78.             'o_path' => $this->model->getRealPath(),
  79.         ]);
  80.         $this->model->setId((int) $this->db->lastInsertId());
  82.         if (!$this->model->getKey() && !is_numeric($this->model->getKey())) {
  83.             $this->model->setKey($this->db->lastInsertId());
  84.         }
  85.     }
  87.     /**
  88.      * @param bool|null $isUpdate
  89.      *
  90.      * @throws \Exception
  91.      */
  92.     public function update($isUpdate = null)
  93.     {
  94.         $object = $this->model->getObjectVars();
  96.         $data = [];
  97.         $validTableColumns = $this->getValidTableColumns('objects');
  99.         foreach ($object as $key => $value) {
  100.             if (in_array($key, $validTableColumns)) {
  101.                 if (is_bool($value)) {
  102.                     $value = (int)$value;
  103.                 }
  104.                 $data[$key] = $value;
  105.             }
  106.         }
  108.         // check the type before updating, changing the type or class of an object is not possible
  109.         $checkColumns = ['o_type', 'o_classId', 'o_className'];
  110.         $existingData = $this->db->fetchAssociative('SELECT ' . implode(',', $checkColumns) . ' FROM objects WHERE o_id = ?', [$this->model->getId()]);
  111.         foreach ($checkColumns as $column) {
  112.             if ($column == 'o_type' && in_array($data[$column], [DataObject::OBJECT_TYPE_VARIANT, DataObject::OBJECT_TYPE_OBJECT]) && (isset($existingData[$column]) && in_array($existingData[$column], [DataObject::OBJECT_TYPE_VARIANT, DataObject::OBJECT_TYPE_OBJECT]))) {
  113.                 // type conversion variant <=> object should be possible
  114.                 continue;
  115.             }
  117.             if (!empty($existingData[$column]) && $data[$column] != $existingData[$column]) {
  118.                 throw new \Exception('Unable to save object: type, classId or className mismatch');
  119.             }
  120.         }
  122.         Helper::insertOrUpdate($this->db, 'objects', $data);
  124.         // tree_locks
  125.         $this->db->delete('tree_locks', ['id' => $this->model->getId(), 'type' => 'object']);
  126.         if ($this->model->getLocked()) {
  127.             $this->db->insert('tree_locks', [
  128.                 'id' => $this->model->getId(),
  129.                 'type' => 'object',
  130.                 'locked' => $this->model->getLocked(),
  131.             ]);
  132.         }
  133.     }
  135.     /**
  136.      * Deletes object from database
  137.      *
  138.      * @return void
  139.      */
  140.     public function delete()
  141.     {
  142.         $this->db->delete('objects', ['o_id' => $this->model->getId()]);
  143.     }
  145.     public function updateWorkspaces()
  146.     {
  147.         $this->db->update('users_workspaces_object', [
  148.             'cpath' => $this->model->getRealFullPath(),
  149.         ], [
  150.             'cid' => $this->model->getId(),
  151.         ]);
  152.     }
  154.     /**
  155.      * Updates the paths for children, children's properties and children's permissions in the database
  156.      *
  157.      * @internal
  158.      *
  159.      * @param string $oldPath
  160.      *
  161.      * @return null|array
  162.      */
  163.     public function updateChildPaths($oldPath)
  164.     {
  165.         if ($this->hasChildren(DataObject::$types, true)) {
  166.             //get objects to empty their cache
  167.             $objects = $this->db->fetchFirstColumn('SELECT o_id FROM objects WHERE o_path LIKE ?', [Helper::escapeLike($oldPath) . '%']);
  169.             $userId = '0';
  170.             if ($user = \Pimcore\Tool\Admin::getCurrentUser()) {
  171.                 $userId = $user->getId();
  172.             }
  174.             //update object child paths
  175.             // we don't update the modification date here, as this can have side-effects when there's an unpublished version for an element
  176.             $this->db->executeQuery('update objects set o_path = replace(o_path,' . $this->db->quote($oldPath . '/') . ',' . $this->db->quote($this->model->getRealFullPath() . '/') . "), o_userModification = '" . $userId . "' where o_path like " . $this->db->quote(Helper::escapeLike($oldPath) . '/%') . ';');
  178.             //update object child permission paths
  179.             $this->db->executeQuery('update users_workspaces_object set cpath = replace(cpath,' . $this->db->quote($oldPath . '/') . ',' . $this->db->quote($this->model->getRealFullPath() . '/') . ') where cpath like ' . $this->db->quote(Helper::escapeLike($oldPath) . '/%') . ';');
  181.             //update object child properties paths
  182.             $this->db->executeQuery('update properties set cpath = replace(cpath,' . $this->db->quote($oldPath . '/') . ',' . $this->db->quote($this->model->getRealFullPath() . '/') . ') where cpath like ' . $this->db->quote(Helper::escapeLike($oldPath) . '/%') . ';');
  184.             return $objects;
  185.         }
  187.         return null;
  188.     }
  190.     /**
  191.      * deletes all properties for the object from database
  192.      *
  193.      * @return void
  194.      */
  195.     public function deleteAllProperties()
  196.     {
  197.         $this->db->delete('properties', ['cid' => $this->model->getId(), 'ctype' => 'object']);
  198.     }
  200.     /**
  201.      * @return string retrieves the current full object path from DB
  202.      */
  203.     public function getCurrentFullPath()
  204.     {
  205.         $path = null;
  207.         try {
  208.             $path = $this->db->fetchOne('SELECT CONCAT(o_path,`o_key`) as o_path FROM objects WHERE o_id = ?', [$this->model->getId()]);
  209.         } catch (\Exception $e) {
  210.             Logger::error('could not get current object path from DB');
  211.         }
  213.         return $path;
  214.     }
  216.     /**
  217.      * @return int
  218.      */
  219.     public function getVersionCountForUpdate(): int
  220.     {
  221.         if (!$this->model->getId()) {
  222.             return 0;
  223.         }
  225.         $versionCount = (int) $this->db->fetchOne('SELECT o_versionCount FROM objects WHERE o_id = ? FOR UPDATE', [$this->model->getId()]);
  227.         if ($this->model instanceof DataObject\Concrete) {
  228.             $versionCount2 = (int) $this->db->fetchOne("SELECT MAX(versionCount) FROM versions WHERE cid = ? AND ctype = 'object'", [$this->model->getId()]);
  229.             $versionCount = max($versionCount, $versionCount2);
  230.         }
  232.         return (int) $versionCount;
  233.     }
  235.     /**
  236.      * Get the properties for the object from database and assign it
  237.      *
  238.      * @param bool $onlyInherited
  239.      *
  240.      * @return array
  241.      */
  242.     public function getProperties($onlyInherited = false)
  243.     {
  244.         $properties = [];
  246.         // collect properties via parent - ids
  247.         $parentIds = $this->getParentIds();
  248.         $propertiesRaw = $this->db->fetchAllAssociative('SELECT name, type, data, cid, inheritable, cpath FROM properties WHERE ((cid IN (' . implode(',', $parentIds) . ") AND inheritable = 1) OR cid = ? ) AND ctype='object'", [$this->model->getId()]);
  250.         // because this should be faster than mysql
  251.         usort($propertiesRaw, function ($left, $right) {
  252.             return strcmp($left['cpath'], $right['cpath']);
  253.         });
  255.         foreach ($propertiesRaw as $propertyRaw) {
  256.             try {
  257.                 $property = new Model\Property();
  258.                 $property->setType($propertyRaw['type']);
  259.                 $property->setCid($this->model->getId());
  260.                 $property->setName($propertyRaw['name']);
  261.                 $property->setCtype('object');
  262.                 $property->setDataFromResource($propertyRaw['data']);
  263.                 $property->setInherited(true);
  264.                 if ($propertyRaw['cid'] == $this->model->getId()) {
  265.                     $property->setInherited(false);
  266.                 }
  267.                 $property->setInheritable(false);
  268.                 if ($propertyRaw['inheritable']) {
  269.                     $property->setInheritable(true);
  270.                 }
  272.                 if ($onlyInherited && !$property->getInherited()) {
  273.                     continue;
  274.                 }
  276.                 $properties[$propertyRaw['name']] = $property;
  277.             } catch (\Exception $e) {
  278.                 Logger::error("can't add property " . $propertyRaw['name'] . ' to object ' . $this->model->getRealFullPath());
  279.             }
  280.         }
  282.         // if only inherited then only return it and dont call the setter in the model
  283.         if ($onlyInherited) {
  284.             return $properties;
  285.         }
  287.         $this->model->setProperties($properties);
  289.         return $properties;
  290.     }
  292.     /**
  293.      * Quick test if there are children
  294.      *
  295.      * @param array $objectTypes
  296.      * @param bool|null $includingUnpublished
  297.      * @param Model\User $user
  298.      *
  299.      * @return bool
  300.      */
  301.     public function hasChildren($objectTypes = [DataObject::OBJECT_TYPE_OBJECT, DataObject::OBJECT_TYPE_FOLDER], $includingUnpublished = null, $user = null)
  302.     {
  303.         if (!$this->model->getId()) {
  304.             return false;
  305.         }
  307.         $sql = 'SELECT 1 FROM objects o WHERE o_parentId = ? ';
  308.         if ($user && !$user->isAdmin()) {
  309.             $roleIds = $user->getRoles();
  310.             $currentUserId = $user->getId();
  311.             $permissionIds = array_merge($roleIds, [$currentUserId]);
  313.             //gets the permission of the ancestors, since it would be the same for each row with same o_parentId, it is done once outside the query to avoid extra subquery.
  314.             $inheritedPermission = $this->isInheritingPermission('list', $permissionIds);
  316.             // $anyAllowedRowOrChildren checks for nested elements that are `list`=1. This is to allow the folders in between from current parent to any nested elements and due the "additive" permission on the element itself, we can simply ignore list=0 children
  317.             // unless for the same rule found is list=0 on user specific level, in that case it nullifies that entry.
  318.             $anyAllowedRowOrChildren = 'EXISTS(SELECT list FROM users_workspaces_object uwo WHERE userId IN (' . implode(',', $permissionIds) . ') AND list=1 AND LOCATE(CONCAT(o.o_path,o.o_key),cpath)=1 AND
  319.             NOT EXISTS(SELECT list FROM users_workspaces_object WHERE userId =' . $currentUserId . '  AND list=0 AND cpath = uwo.cpath))';
  321.             // $allowedCurrentRow checks if the current row is blocked, if found a match it "removes/ignores" the entry from object table, doesn't need to check if is list=1 on user level, since it is done in $anyAllowedRowOrChildren (NB: equal or longer cpath) so we are safe to deduce that there are no valid list=1 rules
  322.             $isDisallowedCurrentRow = 'EXISTS(SELECT list FROM users_workspaces_object uworow WHERE userId IN (' . implode(',', $permissionIds) . ')  AND cid = o_id AND list=0)';
  324.             //If no children with list=1 (with no user-level list=0) is found, we consider the inherited permission rule
  325.             //if $inheritedPermission=0 then everything is disallowed (or doesn't specify any rule) for that row, we can skip $isDisallowedCurrentRow
  326.             //if $inheritedPermission=1, then we are allowed unless the current row is specifically disabled, already knowing from $anyAllowedRowOrChildren that there are no list=1(without user permission list=0),so this "blocker" is the highest cpath available for this row if found
  328.             $sql .= ' AND IF(' . $anyAllowedRowOrChildren . ',1,IF(' . $inheritedPermission . ', ' . $isDisallowedCurrentRow . ' = 0, 0)) = 1';
  329.         }
  331.         if ((isset($includingUnpublished) && !$includingUnpublished) || (!isset($includingUnpublished) && Model\Document::doHideUnpublished())) {
  332.             $sql .= ' AND o_published = 1';
  333.         }
  335.         if (!empty($objectTypes)) {
  336.             $sql .= " AND o_type IN ('" . implode("','", $objectTypes) . "')";
  337.         }
  339.         $sql .= ' LIMIT 1';
  340.         $c = $this->db->fetchOne($sql, [$this->model->getId()]);
  342.         return (bool)$c;
  343.     }
  345.     /**
  346.      * Quick test if there are siblings
  347.      *
  348.      * @param array $objectTypes
  349.      * @param bool|null $includingUnpublished
  350.      *
  351.      * @return bool
  352.      */
  353.     public function hasSiblings($objectTypes = [DataObject::OBJECT_TYPE_OBJECT, DataObject::OBJECT_TYPE_FOLDER], $includingUnpublished = null)
  354.     {
  355.         if (!$this->model->getParentId()) {
  356.             return false;
  357.         }
  359.         $sql = 'SELECT 1 FROM objects WHERE o_parentId = ?';
  360.         $params = [$this->model->getParentId()];
  362.         if ($this->model->getId()) {
  363.             $sql .= ' AND o_id != ?';
  364.             $params[] = $this->model->getId();
  365.         }
  367.         if ((isset($includingUnpublished) && !$includingUnpublished) || (!isset($includingUnpublished) && Model\Document::doHideUnpublished())) {
  368.             $sql .= ' AND o_published = 1';
  369.         }
  371.         $sql .= " AND o_type IN ('" . implode("','", $objectTypes) . "') LIMIT 1";
  373.         $c = $this->db->fetchOne($sql, $params);
  375.         return (bool)$c;
  376.     }
  378.     /**
  379.      * returns the amount of directly children (not recursivly)
  380.      *
  381.      * @param array|null $objectTypes
  382.      * @param Model\User $user
  383.      *
  384.      * @return int
  385.      */
  386.     public function getChildAmount($objectTypes = [DataObject::OBJECT_TYPE_OBJECT, DataObject::OBJECT_TYPE_FOLDER], $user = null)
  387.     {
  388.         if (!$this->model->getId()) {
  389.             return 0;
  390.         }
  392.         $query = 'SELECT COUNT(*) AS count FROM objects o WHERE o_parentId = ?';
  394.         if (!empty($objectTypes)) {
  395.             $query .= sprintf(' AND o_type IN (\'%s\')', implode("','", $objectTypes));
  396.         }
  398.         if ($user && !$user->isAdmin()) {
  399.             $roleIds = $user->getRoles();
  400.             $currentUserId = $user->getId();
  401.             $permissionIds = array_merge($roleIds, [$currentUserId]);
  403.             $inheritedPermission = $this->isInheritingPermission('list', $permissionIds);
  405.             $anyAllowedRowOrChildren = 'EXISTS(SELECT list FROM users_workspaces_object uwo WHERE userId IN (' . implode(',', $permissionIds) . ') AND list=1 AND LOCATE(CONCAT(o.o_path,o.o_key),cpath)=1 AND
  406.             NOT EXISTS(SELECT list FROM users_workspaces_object WHERE userId ='.$currentUserId.'  AND list=0 AND cpath = uwo.cpath))';
  407.             $isDisallowedCurrentRow = 'EXISTS(SELECT list FROM users_workspaces_object uworow WHERE userId IN (' . implode(',', $permissionIds) . ')  AND cid = o_id AND list=0)';
  409.             $query .= ' AND IF(' . $anyAllowedRowOrChildren . ',1,IF(' . $inheritedPermission . ', ' . $isDisallowedCurrentRow . ' = 0, 0)) = 1';
  410.         }
  412.         return (int) $this->db->fetchOne($query, [$this->model->getId()]);
  413.     }
  415.     /**
  416.      * @param int $id
  417.      *
  418.      * @return array
  419.      *
  420.      * @throws Model\Exception\NotFoundException
  421.      */
  422.     public function getTypeById($id)
  423.     {
  424.         $t = $this->db->fetchAssociative('SELECT o_type,o_className,o_classId FROM objects WHERE o_id = ?', [$id]);
  426.         if (!$t) {
  427.             throw new Model\Exception\NotFoundException('object with ID ' . $id . ' not found');
  428.         }
  430.         return $t;
  431.     }
  433.     /**
  434.      * @return bool
  435.      */
  436.     public function isLocked()
  437.     {
  438.         // check for an locked element below this element
  439.         $belowLocks = $this->db->fetchOne("SELECT tree_locks.id FROM tree_locks INNER JOIN objects ON tree_locks.id = objects.o_id WHERE objects.o_path LIKE ? AND tree_locks.type = 'object' AND tree_locks.locked IS NOT NULL AND tree_locks.locked != '' LIMIT 1", [Helper::escapeLike($this->model->getRealFullPath()) . '/%']);
  441.         if ($belowLocks > 0) {
  442.             return true;
  443.         }
  445.         $parentIds = $this->getParentIds();
  446.         $inhertitedLocks = $this->db->fetchOne('SELECT id FROM tree_locks WHERE id IN (' . implode(',', $parentIds) . ") AND type='object' AND locked = 'propagate' LIMIT 1");
  448.         if ($inhertitedLocks > 0) {
  449.             return true;
  450.         }
  452.         return false;
  453.     }
  455.     /**
  456.      * @return array
  457.      */
  458.     public function unlockPropagate()
  459.     {
  460.         $lockIds = $this->db->fetchFirstColumn('SELECT o_id from objects WHERE o_path LIKE ' . $this->db->quote(Helper::escapeLike($this->model->getRealFullPath()) . '/%') . ' OR o_id = ' . $this->model->getId());
  461.         $this->db->executeStatement("DELETE FROM tree_locks WHERE type = 'object' AND id IN (" . implode(',', $lockIds) . ')');
  463.         return $lockIds;
  464.     }
  466.     /**
  467.      * @return DataObject\ClassDefinition[]
  468.      */
  469.     public function getClasses()
  470.     {
  471.         $path = $this->model->getRealFullPath();
  472.         if (!$this->model->getId() || $this->model->getId() == 1) {
  473.             $path = '';
  474.         }
  476.         $classIds = [];
  477.         do {
  478.             $classId = $this->db->fetchOne(
  479.                 "SELECT o_classId FROM objects WHERE o_path LIKE ? AND o_type = 'object'".($classIds ? ' AND o_classId NOT IN ('.rtrim(str_repeat('?,', count($classIds)), ',').')' : '').' LIMIT 1',
  480.                 array_merge([Helper::escapeLike($path).'/%'], $classIds));
  481.             if ($classId) {
  482.                 $classIds[] = $classId;
  483.             }
  484.         } while ($classId);
  486.         $classes = [];
  487.         foreach ($classIds as $classId) {
  488.             if ($class = DataObject\ClassDefinition::getById($classId)) {
  489.                 $classes[] = $class;
  490.             }
  491.         }
  493.         return $classes;
  494.     }
  496.     /**
  497.      * @return int[]
  498.      */
  499.     protected function collectParentIds()
  500.     {
  501.         $parentIds = $this->getParentIds();
  502.         if ($id = $this->model->getId()) {
  503.             $parentIds[] = $id;
  504.         }
  506.         return $parentIds;
  507.     }
  509.     /**
  510.      * @param string $type
  511.      * @param array $userIds
  512.      *
  513.      * @return int
  514.      *
  515.      * @throws \Doctrine\DBAL\Exception
  516.      */
  517.     public function isInheritingPermission(string $type, array $userIds)
  518.     {
  519.         return $this->InheritingPermission($type, $userIds, 'object');
  520.     }
  522.     /**
  523.      * @param string $type
  524.      * @param Model\User $user
  525.      *
  526.      * @return bool
  527.      */
  528.     public function isAllowed($type, $user)
  529.     {
  530.         $parentIds = $this->collectParentIds();
  532.         $userIds = $user->getRoles();
  533.         $userIds[] = $user->getId();
  535.         try {
  536.             $permissionsParent = $this->db->fetchOne('SELECT ' . $this->db->quoteIdentifier($type) . ' FROM users_workspaces_object WHERE cid IN (' . implode(',', $parentIds) . ') AND userId IN (' . implode(',', $userIds) . ') ORDER BY LENGTH(cpath) DESC, FIELD(userId, ' . $user->getId() . ') DESC, ' . $this->db->quoteIdentifier($type) . ' DESC LIMIT 1');
  538.             if ($permissionsParent) {
  539.                 return true;
  540.             }
  542.             // exception for list permission
  543.             if (empty($permissionsParent) && $type === 'list') {
  544.                 // check for children with permissions
  545.                 $path = $this->model->getRealFullPath() . '/';
  546.                 if ($this->model->getId() == 1) {
  547.                     $path = '/';
  548.                 }
  550.                 $permissionsChildren = $this->db->fetchOne('SELECT list FROM users_workspaces_object WHERE cpath LIKE ? AND userId IN (' . implode(',', $userIds) . ') AND list = 1 LIMIT 1', [Helper::escapeLike($path) . '%']);
  551.                 if ($permissionsChildren) {
  552.                     return true;
  553.                 }
  554.             }
  555.         } catch (\Exception $e) {
  556.             Logger::warn('Unable to get permission ' . $type . ' for object ' . $this->model->getId());
  557.         }
  559.         return false;
  560.     }
  562.     /**
  563.      * @param array $columns
  564.      * @param User $user
  565.      *
  566.      * @return array<string, int>
  567.      *
  568.      */
  569.     public function areAllowed(array $columns, User $user)
  570.     {
  571.         return $this->permissionByTypes($columns, $user, 'object');
  572.     }
  574.     /**
  575.      * @param string|null $type
  576.      * @param Model\User $user
  577.      * @param bool $quote
  578.      *
  579.      * @return array|null
  580.      */
  581.     public function getPermissions($type, $user, $quote = true)
  582.     {
  583.         $parentIds = $this->collectParentIds();
  585.         $userIds = $user->getRoles();
  586.         $userIds[] = $user->getId();
  588.         try {
  589.             if ($type && $quote) {
  590.                 $queryType = '`' . $type . '`';
  591.             } else {
  592.                 $queryType = '*';
  593.             }
  595.             $commaSeparated = in_array($type, ['lView', 'lEdit', 'layouts']);
  597.             if ($commaSeparated) {
  598.                 $allPermissions = $this->db->fetchAllAssociative('SELECT ' . $queryType . ',cid,cpath FROM users_workspaces_object WHERE cid IN (' . implode(',', $parentIds) . ') AND userId IN (' . implode(',', $userIds) . ') ORDER BY LENGTH(cpath) DESC, FIELD(userId, ' . $user->getId() . ') DESC, `' . $type . '` DESC');
  599.                 if (!$allPermissions) {
  600.                     return null;
  601.                 }
  603.                 if (count($allPermissions) == 1) {
  604.                     return $allPermissions[0];
  605.                 }
  607.                 $firstPermission = $allPermissions[0];
  608.                 $firstPermissionCid = $firstPermission['cid'];
  609.                 $mergedPermissions = [];
  611.                 foreach ($allPermissions as $permission) {
  612.                     $cid = $permission['cid'];
  613.                     if ($cid != $firstPermissionCid) {
  614.                         break;
  615.                     }
  617.                     $permissionValues = $permission[$type];
  618.                     if (!$permissionValues) {
  619.                         $firstPermission[$type] = null;
  621.                         return $firstPermission;
  622.                     }
  624.                     $permissionValues = explode(',', $permissionValues);
  625.                     foreach ($permissionValues as $permissionValue) {
  626.                         $mergedPermissions[$permissionValue] = $permissionValue;
  627.                     }
  628.                 }
  630.                 $firstPermission[$type] = implode(',', $mergedPermissions);
  632.                 return $firstPermission;
  633.             }
  635.             $orderByType = $type ? ', `' . $type . '` DESC' : '';
  636.             $permissions = $this->db->fetchAssociative('SELECT ' . $queryType . ' FROM users_workspaces_object WHERE cid IN (' . implode(',', $parentIds) . ') AND userId IN (' . implode(',', $userIds) . ') ORDER BY LENGTH(cpath) DESC, FIELD(userId, ' . $user->getId() . ') DESC' . $orderByType . ' LIMIT 1');
  638.             return $permissions;
  639.         } catch (\Exception $e) {
  640.             Logger::warn('Unable to get permission ' . $type . ' for object ' . $this->model->getId());
  641.         }
  643.         return null;
  644.     }
  646.     /**
  647.      * @param string|null $type
  648.      * @param Model\User $user
  649.      * @param bool $quote
  650.      *
  651.      * @return array
  652.      */
  653.     public function getChildPermissions($type, $user, $quote = true)
  654.     {
  655.         $userIds = $user->getRoles();
  656.         $userIds[] = $user->getId();
  657.         $permissions = [];
  659.         try {
  660.             if ($type && $quote) {
  661.                 $type = '`' . $type . '`';
  662.             } else {
  663.                 $type = '*';
  664.             }
  666.             $cid = $this->model->getId();
  667.             $sql = 'SELECT ' . $type . ' FROM users_workspaces_object WHERE cid != ' . $cid . ' AND cpath LIKE ' . $this->db->quote(Helper::escapeLike($this->model->getRealFullPath()) . '%') . ' AND userId IN (' . implode(',', $userIds) . ') ORDER BY LENGTH(cpath) DESC';
  668.             $permissions = $this->db->fetchAllAssociative($sql);
  669.         } catch (\Exception $e) {
  670.             Logger::warn('Unable to get permission ' . $type . ' for object ' . $this->model->getId());
  671.         }
  673.         return $permissions;
  674.     }
  676.     /**
  677.      * @param int $index
  678.      */
  679.     public function saveIndex($index)
  680.     {
  681.         $this->db->update('objects', [
  682.             'o_index' => $index,
  683.         ], [
  684.             'o_id' => $this->model->getId(),
  685.         ]);
  686.     }
  688.     /**
  689.      * @return bool
  690.      */
  691.     public function __isBasedOnLatestData()
  692.     {
  693.         $data = $this->db->fetchAssociative('SELECT o_modificationDate, o_versionCount  from objects WHERE o_id = ?', [$this->model->getId()]);
  695.         return $data
  696.             && $data['o_modificationDate'] == $this->model->__getDataVersionTimestamp()
  697.             && $data['o_versionCount'] == $this->model->getVersionCount();
  698.     }
  699. }