groupstepper.php

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

<?php
namespace Bitrix\Lists\Copy\Integration;
 
use Bitrix\Iblock\Copy\Manager;
use Bitrix\Lists\Copy\Implement\Children\Field;
use Bitrix\Lists\Copy\Implement\Children\Workflow;
use Bitrix\Lists\Copy\Implement\Iblock;
use Bitrix\Main\Config\Option;
use Bitrix\Main\Loader;
use Bitrix\Main\Update\Stepper;
 
class GroupStepper extends Stepper
{
    protected static $moduleId = "lists";
 
    protected $queueName = "ListsGroupQueue";
    protected $checkerName = "ListsGroupChecker_";
    protected $baseName = "ListsGroupStepper_";
    protected $errorName = "ListsGroupError_";

    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();
            }
 
            $groupId = ($queueOption["groupId"] ?: 0);
            $copiedGroupId = ($queueOption["copiedGroupId"] ?: 0);
            $iblockTypeId = ($queueOption["iblockTypeId"] ?: "");
            $errorOffset = ($queueOption["errorOffset"] ?: 0);
 
            $limit = 5;
            $offset = $this->getOffset($iblockTypeId, $copiedGroupId) + $errorOffset;
 
            $iblockIds = $this->getIblockIdsToCopy($iblockTypeId, $groupId);
            $count = count($iblockIds);
            $iblockIds = array_slice($iblockIds, $offset, $limit);
            $features = ($queueOption["features"] ?: []);
 
            if ($iblockIds)
            {
                $option["count"] = $count;
 
                $copyManager = new Manager($iblockTypeId, $iblockIds, $groupId);
                $copyManager->setTargetLocation($iblockTypeId, $copiedGroupId);
                $copyManager->setIblockImplementer(new Iblock());
                $copyManager->setFieldImplementer(new Field());
                $copyManager->setWorkflowImplementer(new Workflow($iblockTypeId));
 
                if (!in_array("field", $features))
                {
                    $copyManager->removeFeature("field");
                }
                if (!in_array("section", $features))
                {
                    $copyManager->removeFeature("section");
                }
                if (!in_array("element", $features))
                {
                    $copyManager->removeFeature("element");
                }
                if (!in_array("workflow", $features))
                {
                    $copyManager->removeFeature("workflow");
                }
 
                $result = $copyManager->startCopy();
                if (!$result->isSuccess())
                {
                    $queueOption["errorOffset"] += $this->getErrorOffset($copyManager);
                    $this->saveQueueOption($queueOption);
                }
 
                $option["steps"] = $offset;
 
                return true;
            }
            else
            {
                $this->deleteQueueOption();
                return !$this->isQueueEmpty();
            }
        }
        catch (\Exception $exception)
        {
            $this->writeToLog($exception);
            $this->deleteQueueOption();
            return false;
        }
    }
 
    private function getIblockIdsToCopy($iblockTypeId, $groupId)
    {
        $iblockIds = [];
 
        $filter = [
            "ACTIVE" => "Y",
            "TYPE" => $iblockTypeId,
            "CHECK_PERMISSIONS" => "N",
            "=SOCNET_GROUP_ID" => $groupId
        ];
 
        $queryObject = \CIBlock::getList([], $filter);
        while ($iblock = $queryObject->fetch())
        {
            $iblockIds[] = $iblock["ID"];
        }
 
        return $iblockIds;
    }
 
    private function getOffset(string $iblockTypeId, int $copiedGroupId): int
    {
        $iblockIds = $this->getIblockIdsToCopy($iblockTypeId, $copiedGroupId);
        return count($iblockIds);
    }
 
    private function getErrorOffset(Manager $copyManager): int
    {
        $numberIds = count($copyManager->getMapIdsCopiedEntity());
        $numberSuccessIds = count(array_filter($copyManager->getMapIdsCopiedEntity()));
        return $numberIds - $numberSuccessIds;
    }
 
    protected function getQueue(): array
    {
        return $this->getOptionData($this->queueName);
    }
 
    protected function setQueue(array $queue): void
    {
        $queueId = (string) current($queue);
        $this->checkerName = (mb_strpos($this->checkerName, $queueId) === false ?
            $this->checkerName.$queueId : $this->checkerName);
        $this->baseName = (mb_strpos($this->baseName, $queueId) === false ?
            $this->baseName.$queueId : $this->baseName);
        $this->errorName = (mb_strpos($this->errorName, $queueId) === false ?
            $this->errorName.$queueId : $this->errorName);
    }
 
    protected function getQueueOption()
    {
        return $this->getOptionData($this->baseName);
    }
 
    protected function saveQueueOption(array $data)
    {
        Option::set(static::$moduleId, $this->baseName, serialize($data));
    }
 
    protected function deleteQueueOption()
    {
        $queue = $this->getQueue();
        $this->setQueue($queue);
        $this->deleteCurrentQueue($queue);
        Option::delete(static::$moduleId, ["name" => $this->checkerName]);
        Option::delete(static::$moduleId, ["name" => $this->baseName]);
    }
 
    protected function deleteCurrentQueue(array $queue): void
    {
        $queueId = current($queue);
        $currentPos = array_search($queueId, $queue);
        if ($currentPos !== false)
        {
            unset($queue[$currentPos]);
            Option::set(static::$moduleId, $this->queueName, serialize($queue));
        }
    }
 
    protected function isQueueEmpty()
    {
        $queue = $this->getOptionData($this->queueName);
        return empty($queue);
    }
 
    protected function getOptionData($optionName)
    {
        $option = Option::get(static::$moduleId, $optionName);
        $option = ($option !== "" ? unserialize($option) : []);
        return (is_array($option) ? $option : []);
    }
 
    protected function deleteOption($optionName)
    {
        Option::delete(static::$moduleId, ["name" => $optionName]);
    }
}