section.php

<?php
namespace Bitrix\Iblock\Copy\Stepper;
 
use Bitrix\Main\Application;
use Bitrix\Main\Loader;
 
class Section extends Entity
{
    protected $queueName = "SectionGroupQueue";
    protected $checkerName = "SectionGroupChecker_";
    protected $baseName = "SectionGroupStepper_";
    protected $errorName = "SectionGroupError_";
 
    public function execute(array &$option)
    {
        if (!Loader::includeModule(self::$moduleId))
        {
            return false;
        }
 
        try
        {
            $queue = $this->getQueue();
            $this->setQueue($queue);
            $queueOption = $this->getQueueOption();
            if (empty($queueOption))
            {
                $this->deleteQueueOption();
                return !$this->isQueueEmpty();
            }
 
            $sectionId = ($queueOption["sectionId"] ?: 0);
            $copiedSectionId = ($queueOption["copiedSectionId"] ?: 0);
            $errorOffset = ($queueOption["errorOffset"] ?: 0);
 
            $limit = 5;
            $offset = $this->getOffset($copiedSectionId) + $errorOffset;
 
            $enumRatio = ($queueOption["enumRatio"] ?: []);
            $sectionsRatio = ($queueOption["sectionsRatio"] ?: []);
            $mapIdsCopiedElements = ($queueOption["mapIdsCopiedElements"] ?: []);
 
            if ($sectionId)
            {
                list($elementIds, $selectedRowsCount) = $this->getElementIds($sectionId, $limit, $offset);
 
                $elementCopier = $this->getElementCopier();
                $containerCollection = $this->getContainerCollection($elementIds, $sectionsRatio, $enumRatio);
                $result = $elementCopier->copy($containerCollection);
                if (!$result->isSuccess())
                {
                    $queueOption["errorOffset"] += $this->getErrorOffset($elementCopier);
                }
 
                $mapIdsCopiedElements = $elementCopier->getMapIdsCopiedEntity() + $mapIdsCopiedElements;
                $queueOption["mapIdsCopiedElements"] = $mapIdsCopiedElements;
                $this->saveQueueOption($queueOption);
 
                if ($selectedRowsCount < $limit)
                {
                    $this->deleteQueueOption();
                    return !$this->isQueueEmpty();
                }
                else
                {
                    $option["steps"] = $offset;
                    return true;
                }
            }
            else
            {
                $this->deleteQueueOption();
                return !$this->isQueueEmpty();
            }
        }
        catch (\Exception $exception)
        {
            $this->writeToLog($exception);
            $this->deleteQueueOption();
            return false;
        }
    }
 
    private function getElementIds(int $sectionId, int $limit, int $offset): array
    {
        $elementIds = [];
 
        $connection = Application::getInstance()->getConnection();
        $sqlHelper = $connection->getSqlHelper();
 
        $queryObject = $connection->query("SELECT ID FROM `b_iblock_element` WHERE `IBLOCK_SECTION_ID` = '".
            $sqlHelper->forSql($sectionId)."' ORDER BY ID ASC LIMIT ".$limit." OFFSET ".$offset);
        $selectedRowsCount = $queryObject->getSelectedRowsCount();
        while ($element = $queryObject->fetch())
        {
            $elementIds[] = $element["ID"];
        }
 
        return [$elementIds, $selectedRowsCount];
    }
 
    private function getOffset(int $copiedSectionId): int
    {
        $elementIds = [];
 
        $connection = Application::getInstance()->getConnection();
        $sqlHelper = $connection->getSqlHelper();
 
        $queryObject = $connection->query("SELECT ID FROM `b_iblock_element` WHERE `IBLOCK_SECTION_ID` = '".
            $sqlHelper->forSql($copiedSectionId)."' ORDER BY ID");
        while ($element = $queryObject->fetch())
        {
            $elementIds[] = $element["ID"];
        }
 
        return count($elementIds);
    }
}