Пошаговая обработка скриптов

//Инициализация скрипта

$documentRoot = (!isset($_SERVER['DOCUMENT_ROOT']) || empty($_SERVER['DOCUMENT_ROOT'])) ? realpath(

   __DIR__ . '/../..'

) : $_SERVER['DOCUMENT_ROOT'];//Устанавливаем путь к корневой папке сайта

$moduleDir = 'local';//bitrix - установка папки с утсановленным модулем

$pathToModule = $documentRoot . '/' . $moduleDir . '/modules./wizard.scriptbysteps';//путь до модуля

$pathToModuleInclude = $pathToModule. '/include';//путь до папки с include

//Подключаем пролог с установленными переменными

$path = $pathToModuleInclude . '/startAjax.php';

if (file_exists($path))

   require_once($path);

else

   die();

unset($path, $documentRoot);



\Bitrix\Main\Loader::includeSharewareModule('wizard.scriptbysteps');

\Bitrix\Main\Loader::includeSharewareModule('wizard.additional');



//Инициализация логгера

$logger = new Wizard\Additional\Logger;

$logger->activate();

$logger->setType('normalize');



//Шаги выполнения, расположенные по порядку

$arSteps = [

   'unzip',//Распаковка архива

   'reindex',//Переиндексация

   //'updateFacet',//Обновление фасеты

   'clearCache',//Очистка кеша

];

//Инициализация параметров для пошаговых скриптов - не обязательно - но это то что будет доступно в скриптах

$arParams = [

   'IBLOCK_ID'        => 4,

   //Инфоблок товаров

   'OFFER_IBLOCK_ID'  => 6,

   //Инфорблок торговых предложений

   'EXEC_DELETE_FILE' => $_SERVER['DOCUMENT_ROOT'] . '/wizard/files/execDelete.data',

   //Путь к файлу для запуска удаления

   'BLOCK_PARTIAL'    => $_SERVER['DOCUMENT_ROOT'] . '/wizard/files/blockPartial.data',

   //Путь к блокирующему файлу частичной выгрузки

   'ARCHIVE_FILE'     => $_SERVER['DOCUMENT_ROOT'] . '/upload/images/123.zip',

   //Путь к файлу с архивом

   'BEGIN_STEP'       => 'unzip',

   //Начальный шаг, обязательный параметр

   'PATH_TO_MODULE'   => $pathToModule

   //Путь к модулю

];

//Параметры прерывания, устанавливается если есть дополнительное условие на прерывание всей обработки или шага

//доступны параметры begin и step

$arStepParams = [

   'cancel' => [

      'begin' => (bool)!file_exists($arParams['ARCHIVE_FILE'])

   ]

];

//Инициализация скрипта

$obScriptBySteps = \Wizard\ScriptBySteps::getInstance();

$obScriptBySteps->setOperationCode('normalize');//Установка типа обработки обычно совпадает с названием файла и обязан совпадать с название папки

$obScriptBySteps->setScriptFilesFolder(__DIR__);//Устанавливаем раздел где будет искаться папка с пошаговыми скриптами

if (is_object($logger))

   $obScriptBySteps->setLogger($logger);//Устанавливаем логгер чтобы он был доступен в пошаговых скриптах

$obScriptBySteps->setTimeLimit(60);//Устанавливаем ограничение шага по времени

$obScriptBySteps->setElementLimit(2000);//Устанавливаем ограничение шага по элементам

if (isset($arSteps) && is_array($arSteps) && !empty($arSteps)) {

   $obScriptBySteps->setSteps($arSteps);//Устанавливаем шаги

   unset($arSteps);

   if (isset($arParams) && is_array($arParams) && !empty($arParams)) {

      $obScriptBySteps->setParams((array)$arParams);//Устанавливаем параметры

      unset($arParams);

      $obScriptBySteps->setMainScriptFile(__FILE__);//Устанавливаем основной файл запуска

      $obScriptBySteps->execute($arStepParams);//запускаем, запуск может быть без параметров

      unset($arStepParams);

   }

}



//Завершение скрипта

//define('HAS_WORK_WITH_COOKIE', true); //ставить парметр если используем Куки

$path = $pathToModuleInclude . '/endAjax.php';

if (file_exists($path))

   require_once($path); 

$obScriptBySteps = \Wizard\ScriptBySteps::getInstance();

$arParams = $obScriptBySteps->getParams();//Получаем параметры если нужны

$stepParams = $obScriptBySteps->getStepParams();//получаем значение шага если нужно

$logger = $obScriptBySteps->getLogger();//получаем логгер



//Выполняем необходимые действия



\Bitrix\Main\Loader::includeModule('iblock');

if (!\Bitrix\Main\Loader::includeModule('search')) {

   if (is_object($logger)) {

      $logger->write('Модуль поиска не установлен');

   }

   //Завершение скрипта - досрочное, т.е. идет полное прерывае скрипта, если нужно пропустить шаг то нужно просто поставить параметр bHaveEls=false

   $obScriptBySteps->finishExecute();

   die();

}



if (is_object($logger)) {

   $logger->activate();

}



//Установка начального времени 5мин + 3секунды

$importTimeBegin = \ConvertTimeStamp(START_SCRIPT_TIME - $arParams['MINUTES'] * 60 + 3, "FULL");

//Получение времени последнего обновления или установка начального времени

$lastUpdate = \Bitrix\Main\Config\Option::get('main', 'last_update_normalizePartial', $importTimeBegin);

if (intval($lastUpdate) == 0) {

   $lastUpdate = $importTimeBegin;

}

$lastUpdate = \Bitrix\Main\Type\DateTime::createFromTimestamp($lastUpdate);

//Получение элементов начиная с определенного времени

$arFilter = [

   '>TIMESTAMP_X'       => $lastUpdate,

   'IBLOCK_ID'          => $arParams['IBLOCK_ID'],

   '!IBLOCK_SECTION_ID' => $arParams['OMEGA_SECTION_ID'],

   'ACTIVE'             => 'Y'

];



$arSelectFields = ["ID"];

$elementLimit = $obScriptBySteps->getElementLimit();//Получение ограничения по количеству, так же можно получить ограничение по времени

$params = [

   'select' => $arSelectFields,

   'filter' => $arFilter,

   'limit'  => $elementLimit

];

if ($stepParams['iNumPage'] > 1) {

   $params['offset'] = $elementLimit * ($stepParams['iNumPage'] - 1);

}

$rsElements = \Bitrix\Iblock\ElementTable::getList($params);



//Переиндексация

$arItems = [];

while ($arElement = $rsElements->fetch()) {

   $arItems[] = $arElement['ID'];

}

unset($rsElements);

$countItems = count($arItems);



if ($countItems > 0) {

   if ($stepParams['iNumPage'] <= 1) {

      $logger->write('Переиндексация элементов начата');

   }

   //Переиндексация по элементам

   $totalEls = 0;

   if (!empty($arItems)) {

      foreach ($arItems as $id) {

         $totalEls++;

         //Обновление обычного индекса

         \CIBlockElement::UpdateSearch($id, false);

         //Обновление фасетного индекса элемента

         \Bitrix\Iblock\PropertyIndex\Manager::updateElementIndex($arParams['IBLOCK_ID'], $id);

      }

   }

   //if (is_object($logger)){

   //$logger->write('Переиндексировано '.$totalEls.' элементов за '.(time() - START_SCRIPT_TIME).'с');

   //$logger->writeEndLine();

   //}



   //Установка следующего шага

   $paramsStep = [

      'bHaveEls' => true//параметр true означает что будет запущен этот же шаг повторно но с наращивание счетчика шага

   ];

   $obScriptBySteps->setNewStep($paramsStep);

} else {

   if ($stepParams['iNumPage'] <= 1) {

      $obScriptBySteps->finishExecute();

      die();

   } else {

      //Установка следующего шага

      $paramsStep = [

         'bHaveEls' => false//переход на следующий шаг

      ];

      $obScriptBySteps->setNewStep($paramsStep);

      $logger->write('Переиндексация элементов завершена');

      $logger->writeEndLine();

   }

}