section.php

См. документацию.

<?php
 
namespace Bitrix\Catalog\Controller;
 
use Bitrix\Catalog\Access\ActionDictionary;
use Bitrix\Iblock\SectionTable;
use Bitrix\Main\Application;
use Bitrix\Main\DB\SqlQueryException;
use Bitrix\Main\Engine\Response\DataType\Page;
use Bitrix\Main\Error;
use Bitrix\Main\ORM\Data\DataManager;
use Bitrix\Main\Result;
use Bitrix\Main\UI\PageNavigation;
 
final class Section extends Controller
{
    //region Actions
    public function getFieldsAction(): array
    {
        return [$this->getServiceItemName() => $this->getViewFields()];
    }

    public function listAction(
        PageNavigation $pageNavigation,
        array $select = [],
        array $filter = [],
        array $order = [],
        bool $__calculateTotalCount = true
    ): ?Page
    {
        $r = $this->checkPermissionIBlockSectionList($filter['IBLOCK_ID']);
        if ($r->isSuccess())
        {
            $result = [];
 
            $select = empty($select) ? ['*'] : $select;
            $order = empty($order) ? ['ID'=>'ASC'] : $order;
 
            if (isset($filter['IBLOCK_SECTION_ID']))
            {
                $filter['SECTION_ID'] = $filter['IBLOCK_SECTION_ID'];
                unset($filter['IBLOCK_SECTION_ID']);
            }
 
            $r = \CIBlockSection::GetList(
                $order,
                $filter,
                false,
                $select,
                self::getNavData($pageNavigation->getOffset())
            );
            while ($l = $r->fetch())
            {
                $result[] = $l;
            }
            unset($l, $r);
 
            return new Page(
                $this->getServiceListName(),
                $result,
                $__calculateTotalCount ? $this->getCount($filter) : 0);
        }
        else
        {
            $this->addErrors($r->getErrors());
 
            return null;
        }
 
    }
 
    public function getAction($id)
    {
        $result = $this->checkPermissionIBlockSectionGet($id);
        if (!$result->isSuccess())
        {
            $this->addErrors($result->getErrors());
 
            return null;
        }
 
        $row = $this->get($id);
        if (!is_array($row))
        {
            $this->addErrorEntityNotExists();
 
            return null;
        }
 
        return [
            $this->getServiceItemName() => $row,
        ];
    }
 
    public function addAction($fields)
    {
        $r = $this->checkPermissionIBlockSectionAdd($fields['IBLOCK_ID']);
 
        $id = 0;
        if ($r->isSuccess())
        {
            if (isset($fields['IBLOCK_SECTION_ID']) && (int)$fields['IBLOCK_SECTION_ID'] > 0)
            {
                $r = $this->checkPermissionIBlockSectionSectionBindUpdate($fields['IBLOCK_SECTION_ID']);
 
                if (!$r->isSuccess())
                {
                    $this->addErrors($r->getErrors());
 
                    return null;
                }
            }
 
            $r = $this->addValidate($fields);
 
            if ($r->isSuccess())
            {
                $section = new \CIBlockSection();
                $connection = Application::getConnection();
                $connection->startTransaction();
                try
                {
                    $id = $section->Add($fields);
                    $error = $section->getLastError();
                }
                catch (SqlQueryException)
                {
                    $error = 'Internal error adding section. Try adding again.';
                }
                if ($error !== '')
                {
                    $connection->rollbackTransaction();
                    $r->addError(new Error($error, 200700300000));
                }
                else
                {
                    $connection->commitTransaction();
                }
                unset(
                    $error,
                    $section,
                );
            }
        }
 
        if ($r->isSuccess())
        {
            return [$this->getServiceItemName() => $this->get($id)];
        }
        else
        {
            $this->addErrors($r->getErrors());
 
            return null;
        }
    }
 
    public function updateAction($id, array $fields)
    {
        $r = $this->exists($id);
 
        if ($r->isSuccess())
        {
            $r = $this->checkPermissionIBlockSectionUpdate($id);
 
            if (!$r->isSuccess())
            {
                $this->addErrors($r->getErrors());
 
                return null;
            }
 
            if (isset($fields['IBLOCK_SECTION_ID']) && (int)$fields['IBLOCK_SECTION_ID'] > 0)
            {
                $r = $this->checkPermissionIBlockSectionSectionBindUpdate($fields['IBLOCK_SECTION_ID']);
 
                if (!$r->isSuccess())
                {
                    $this->addErrors($r->getErrors());
 
                    return null;
                }
            }
 
            $r = $this->updateValidate($fields + ['ID' => $id]);
 
            if ($r->isSuccess())
            {
                $section = new \CIBlockSection();
                $connection = Application::getConnection();
                $connection->startTransaction();
                try
                {
                    $section->Update($id, $fields);
                    $error = $section->getLastError();
                }
                catch (SqlQueryException)
                {
                    $error = 'Internal error updating section. Try updating again.';
                }
                if ($error !== '')
                {
                    $connection->rollbackTransaction();
                    $r->addError(new Error($error, 200700300010));
                }
                else
                {
                    $connection->commitTransaction();
                }
                unset(
                    $error,
                    $section,
                );
            }
        }
 
        if ($r->isSuccess())
        {
            return [$this->getServiceItemName() => $this->get($id)];
        }
        else
        {
            $this->addErrors($r->getErrors());
 
            return null;
        }
    }
 
    public function deleteAction($id)
    {
        $r = $this->checkPermissionIBlockSectionDelete($id);
 
        if ($r->isSuccess())
        {
            $r = $this->exists($id);
 
            if ($r->isSuccess())
            {
                $connection = Application::getConnection();
                $connection->startTransaction();
                try
                {
                    if (!\CIBlockSection::Delete($id))
                    {
                        if ($ex = self::getApplication()->GetException())
                        {
                            $r->addError(new Error($ex->GetString(), $ex->GetId()));
                        }
                        else
                        {
                            $r->addError(new Error('delete section error', 200700300020));
                        }
                    }
                }
                catch (SqlQueryException)
                {
                    $r->addError(new Error('Internal error deleting section. Try deleting again.', 200700300020));
                }
                if ($r->isSuccess())
                {
                    $connection->commitTransaction();
                }
                else
                {
                    $connection->rollbackTransaction();
                }
            }
        }
 
        if ($r->isSuccess())
        {
            return true;
        }
        else
        {
            $this->addErrors($r->getErrors());
 
            return null;
        }
    }
    //endregion
 
    protected function exists($id)
    {
        $result = new Result();
 
        $iterator = \CIBlockSection::GetList(
            [],
            ['ID' => (int)$id],
            false,
            ['ID']
        );
        $row = $iterator->Fetch();
        unset($iterator);
        if (empty($row))
        {
            $result->addError($this->getErrorEntityNotExists());
        }
 
        return $result;
    }
 
    protected function get($id)
    {
        return \CIBlockSection::GetByID($id)->Fetch();
    }
 
    protected function getErrorCodeEntityNotExists(): string
    {
        return ErrorCode::SECTION_ENTITY_NOT_EXISTS;
    }
 
    protected function addValidate($fields): Result
    {
        $r = new Result();
 
        if (isset($fields['CODE']))
        {
            $isCodeUnique = $this->isCodeUnique($fields);
 
            if (!$isCodeUnique->isSuccess())
            {
                $r->addError($isCodeUnique->getErrors()[0]);
            }
        }
 
        return $r;
    }
 
    protected function updateValidate($fields): Result
    {
        $r = new Result();
 
        if (isset($fields['CODE']))
        {
            $isCodeUnique = $this->isCodeUnique($fields);
 
            if (!$isCodeUnique->isSuccess())
            {
                $r->addError($isCodeUnique->getErrors()[0]);
            }
        }
 
        return $r;
    }
 
    private function isCodeUnique(array $fields): Result
    {
        $r = new Result();
 
        $iblock = \CIBlock::GetArrayByID($fields['IBLOCK_ID']);
 
        if (isset($iblock['FIELDS']['SECTION_CODE']['DEFAULT_VALUE']))
        {
            if (
                $iblock['FIELDS']['SECTION_CODE']['DEFAULT_VALUE']['TRANSLITERATION'] === 'Y'
                && $iblock['FIELDS']['SECTION_CODE']['DEFAULT_VALUE']['UNIQUE'] === 'Y'
            )
            {
                $filter = [
                    '=IBLOCK_ID' => $fields['IBLOCK_ID'],
                    '=CODE' => $fields['CODE'],
                ];
 
                if (isset($fields['ID']))
                {
                    $filter['!=ID'] = $fields['ID'];
                }
 
                $existsResult = $this->existsByFilter($filter);
 
                if ($existsResult->isSuccess())
                {
                    $r->addError($this->getErrorDublicateFieldCode());
                }
            }
        }
 
        return $r;
    }
 
    private function getErrorDublicateFieldCode(): Error
    {
        return new Error('Duplicate entry for key [code]', 200700300040);
    }
 
    protected function getEntityTable(): DataManager
    {
        return new SectionTable();
    }
 
    private function getCount(array $filter): \Closure
    {
        return function() use ($filter)
        {
            return \CIBlockSection::GetCount($filter);
        };
    }
 
    //region checkPermissionController
    protected function checkModifyPermissionEntity()
    {
        return $this->checkReadPermissionEntity();
    }
 
    protected function checkReadPermissionEntity()
    {
        $r = new Result();
 
        if (
            !$this->accessController->check(ActionDictionary::ACTION_CATALOG_READ)
            && !$this->accessController->check(ActionDictionary::ACTION_CATALOG_VIEW)
        )
        {
            $r->addError($this->getErrorReadAccessDenied());
        }
 
        return $r;
    }
    //endregion
 
    //region checkPermissionIBlock
    protected function checkPermissionIBlockSectionAdd($iblockId)
    {
        return $this->checkPermissionIBlockSectionModify($iblockId, 0);
    }
 
    protected function checkPermissionIBlockSectionUpdate($sectionId)
    {
        $iblockId = $this->getIBlockBySectionId($sectionId);
 
        return $this->checkPermissionIBlockSectionModify($iblockId, $sectionId);
    }
 
    protected function checkPermissionIBlockSectionModify($iblockId, $sectionId)
    {
        $r = new Result();
 
        $iblock = \CIBlock::GetArrayByID($iblockId);
        $isBadIblock = false;
 
        if ($iblock)
        {
            $isBadIblock = !\CIBlockSectionRights::UserHasRightTo($iblockId, $sectionId, self::IBLOCK_EDIT);
        }
        else
        {
            $r->addError(new Error('Iblock is not exists', 200700300050));
        }
 
        if ($isBadIblock)
        {
            $r->addError(new Error('Access Denied', 200040300040));
        }
 
        return $r;
    }
 
    protected function checkPermissionIBlockSectionSectionBindModify($iblockId, $iblockSectionId)
    {
        $r = new Result();
 
        $iblock = \CIBlock::GetArrayByID($iblockId);
        $isBadIblock = false;
 
        if ($iblock)
        {
            $isBadIblock = !\CIBlockSectionRights::UserHasRightTo($iblockId, $iblockSectionId, self::IBLOCK_SECTION_SECTION_BIND); //access update
        }
        else
        {
            $r->addError(new Error('Iblock is not exists', 200700300050));
        }
 
        if ($isBadIblock)
        {
            $r->addError(new Error('Access Denied', 200040300050));
        }
 
        return $r;
    }
 
    protected function checkPermissionIBlockSectionSectionBindUpdate($iblockSectionId)
    {
        $iblockId = $this->getIBlockBySectionId($iblockSectionId);
 
        return $this->checkPermissionIBlockSectionModify($iblockId, $iblockSectionId);
    }
 
    protected function checkPermissionIBlockSectionDelete($sectionId)
    {
        $r = new Result();
        $iblockId = \CIBlockElement::GetIBlockByID($sectionId);
        $isBadIblock = !\CIBlockElementRights::UserHasRightTo($iblockId, $sectionId, self::IBLOCK_SECTION_DELETE); //access delete
 
        if ($isBadIblock)
        {
            $r->addError(new Error('Access Denied', 200040300050));
        }
 
        return $r;
    }
 
    protected function checkPermissionIBlockSectionGet($sectionId)
    {
        $r = new Result();
 
        $iblockId = $this->getIBlockBySectionId($sectionId);
        $isBadIblock = !\CIBlockSectionRights::UserHasRightTo($iblockId, $sectionId, self::IBLOCK_SECTION_READ);
 
        if ($isBadIblock)
        {
            $r->addError(new Error('Access Denied', 200040300040));
        }
 
        return $r;
    }
 
    protected function checkPermissionIBlockSectionList($iblockId)
    {
        $r = new Result();
 
        $iblock = \CIBlock::GetArrayByID($iblockId);
        $isBadIblock = false;
 
        if ($iblock)
        {
            $isBadIblock = !\CIBlockRights::UserHasRightTo($iblockId, $iblockId, self::IBLOCK_READ);
        }
        else
        {
            $r->addError(new Error('Iblock is not exists', 200700300050));
        }
 
        if ($isBadIblock)
        {
            $r->addError(new Error('Access Denied', 200040300030));
        }
 
        return $r;
    }
 
    protected function getIBlockBySectionId($id)
    {
        $iblockId = 0;
 
        $section = \CIBlockSection::GetByID($id);
        if ($res = $section->GetNext())
        {
            $iblockId = $res["IBLOCK_ID"];
        }
 
        return $iblockId;
    }
    //endregion
}