importer.php

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

<?php
namespace Bitrix\Lists;
 
use Bitrix\Main;
use Bitrix\Main\ModuleManager;
 
Main\Loader::includeModule("iblock");
Main\Loader::includeModule("bizproc");

class Importer
{
    const DIRECTION_EXPORT = 0;
    const DIRECTION_IMPORT = 1;
 
    private static $listRuLanguage = array('ua', 'by', 'kz');

    public static function export($iblockId)
    {
        $iblockId = intval($iblockId);
        if ($iblockId <= 0)
            throw new Main\ArgumentNullException("iblockId");
 
        $db = \CIBlock::GetList(Array(), Array("ID" => $iblockId, "CHECK_PERMISSIONS" => "N"));
        $iblock = $db->Fetch();
        if (!$iblock)
            throw new Main\ArgumentOutOfRangeException("iblockId");
 
        if(!$iblock["CODE"])
            throw new Main\ArgumentException("Parameter 'CODE' is required.", "matches");
 
        foreach(\CIBlock::getMessages($iblockId) as $messageKey => $message)
            $iblock[$messageKey] = $message;
 
        $list = new \CList($iblockId);
        $fields = $list->getFields();
        foreach($fields as $fieldId => $field)
        {
            if ($field["TYPE"] == "NAME")
            {
                $iblock["~NAME_FIELD"] = array(
                    "NAME" => $field["NAME"],
                    "SETTINGS" => $field["SETTlINGS"],
                    "DEFAULT_VALUE" => $field["DEFAULT_VALUE"],
                    "SORT" => $field["SORT"],
                );
                break;
            }
        }
 
        $iblock = serialize($iblock);
        $iblockLength = strlen($iblock);
        $datum = str_pad($iblockLength, 10, "0", STR_PAD_LEFT).$iblock;
 
        if (intval($iblock["PICTURE"]) > 0)
        {
            $picture = \CFile::MakeFileArray($iblock["PICTURE"]);
            if (isset($picture["tmp_name"]) && !empty($picture["tmp_name"]))
            {
                $f = fopen($picture["tmp_name"], "rb");
                $pictureData = fread($f, filesize($picture["tmp_name"]));
                fclose($f);
 
                $pictureTypeLength = strlen($picture["type"]);
                $pictureLength = strlen($pictureData);
                $datum .= "P".str_pad($pictureTypeLength, 10, "0", STR_PAD_LEFT).$picture["type"].str_pad($pictureLength, 10, "0", STR_PAD_LEFT).$pictureData;
            }
        }
 
        $documentType = self::getDocumentType($iblock["IBLOCK_TYPE_ID"], $iblockId);
 
        $templatesList = \CBPWorkflowTemplateLoader::GetList(
            array(),
            array("DOCUMENT_TYPE" => $documentType),
            false,
            false,
            array("ID", "AUTO_EXECUTE", "NAME", "DESCRIPTION", "SYSTEM_CODE")
        );
        while ($templatesListItem = $templatesList->Fetch())
        {
            $templatesListItem = serialize($templatesListItem);
            $bpDescrLength = strlen($templatesListItem);
            $datum .= "B".str_pad($bpDescrLength, 10, "0", STR_PAD_LEFT).$templatesListItem;
 
            $bp = \CBPWorkflowTemplateLoader::ExportTemplate($templatesListItem["ID"], false);
            $bpLength = strlen($bp);
            $datum .= str_pad($bpLength, 10, "0", STR_PAD_LEFT).$bp;
        }
 
        if (function_exists("gzcompress"))
            $datum = "compressed".gzcompress($datum, 9);
 
        return $datum;
    }

    public static function getDataProcess($filePath)
    {
        $f = fopen($filePath, "rb");
        $datum = fread($f, filesize($filePath));
        fclose($f);
 
        if (mb_substr($datum, 0, 10) === "compressed")
            $datum = gzuncompress(substr($datum, 10));
 
        $len = intval(substr($datum, 0, 10));
        $dataSerialized = substr($datum, 10, $len);
 
        $data = CheckSerializedData($dataSerialized) ? unserialize($dataSerialized, ["allowed_classes" => false]) : [];
 
        return $data;
    }

    public static function import($iblockType, $datum, $siteId = null)
    {
        if (empty($datum))
            throw new Main\ArgumentNullException("datum");
 
        if (mb_substr($datum, 0, 10) === "compressed")
            $datum = gzuncompress(substr($datum, 10));
 
        $len = intval(substr($datum, 0, 10));
        $iblockSerialized = substr($datum, 10, $len);
        $datum = substr($datum, $len + 10);
 
        $marker = substr($datum, 0, 1);
        $picture = null;
        $pictureType = null;
        if ($marker == "P")
        {
            $len = intval(substr($datum, 1, 10));
            $pictureType = substr($datum, 11, $len);
            $datum = substr($datum, $len + 11);
 
            $len = intval(substr($datum, 0, 10));
            $picture = substr($datum, 10, $len);
            $datum = substr($datum, $len + 10);
 
            $marker = substr($datum, 0, 1);
        }
 
        $iblock = CheckSerializedData($iblockSerialized) ? unserialize($iblockSerialized, ['allowed_classes' => false]) : [];
        $iblockId = static::createIBlock($iblockType, $iblock, $pictureType, $picture, $siteId);
 
        if ($iblockId > 0)
        {
            $documentType = self::getDocumentType($iblockType, $iblockId);
 
            while (!empty($datum))
            {
                if ($marker == "B")
                {
                    $len = intval(substr($datum, 1, 10));
                    $bpDescr = substr($datum, 11, $len);
                    $datum = substr($datum, $len + 11);
 
                    $bpDescr = CheckSerializedData($bpDescr) ? unserialize($bpDescr, ["allowed_classes" => false]) : [];
 
                    $len = intval(substr($datum, 0, 10));
                    $bp = substr($datum, 10, $len);
                    $datum = substr($datum, $len + 10);
 
                    static::importTemplate($documentType, $bpDescr, $bp);
                }
                else
                {
 
                }
 
                if (empty($datum))
                    break;
 
                $marker = substr($datum, 0, 1);
            }
        }
    }
 
    private static function importTemplate($documentType, $bpDescr, $bp)
    {
        $id = 0;
 
        $db = \CBPWorkflowTemplateLoader::GetList(
            array(),
            array("DOCUMENT_TYPE" => $documentType, "SYSTEM_CODE" => $bpDescr["SYSTEM_CODE"]),
            false,
            false,
            array("ID", "IS_MODIFIED")
        );
        if ($res = $db->Fetch())
        {
            if ($res["IS_MODIFIED"] == "Y")
                return;
 
            $id = $res["ID"];
        }
 
        try
        {
            \CBPWorkflowTemplateLoader::ImportTemplate(
                $id,
                $documentType,
                $bpDescr["AUTO_EXECUTE"],
                $bpDescr["NAME"],
                $bpDescr["DESCRIPTION"],
                $bp,
                $bpDescr["SYSTEM_CODE"],
                true
            );
        }
        catch (\Exception $e)
        {
        }
    }
 
    private static function createIBlock($iblockType, $iblock, $pictureType, $picture, $siteId = null)
    {
        if (is_null($siteId))
            $siteId = \CSite::GetDefSite();
 
        $db = \CIBlock::GetList(
            array(),
            array("IBLOCK_TYPE_ID" => $iblockType, "CODE" => $iblock["CODE"], "CHECK_PERMISSIONS" => "N", "SITE_ID" => $siteId)
        );
        if ($res = $db->Fetch())
            return $res["ID"];
 
        $fields = array(
            "NAME" => $iblock["NAME"],
            "DESCRIPTION" => $iblock["DESCRIPTION"],
            "IBLOCK_TYPE_ID" => $iblockType,
            "SORT" => $iblock["SORT"],
            "CODE" => $iblock["CODE"],
            "WORKFLOW" => "N",
            "ELEMENTS_NAME" => $iblock["ELEMENTS_NAME"],
            "ELEMENT_NAME" => $iblock["ELEMENT_NAME"],
            "ELEMENT_ADD" => $iblock["ELEMENT_ADD"] ?? null,
            "ELEMENT_EDIT" => $iblock["ELEMENT_EDIT"] ?? null,
            "ELEMENT_DELETE" => $iblock["ELEMENT_DELETE"] ?? null,
            "SECTIONS_NAME" => $iblock["SECTIONS_NAME"] ?? null,
            "SECTION_NAME" => $iblock["SECTION_NAME"] ?? null,
            "SECTION_ADD" => $iblock["SECTION_ADD"] ?? null,
            "SECTION_EDIT" => $iblock["SECTION_EDIT"] ?? null,
            "SECTION_DELETE" => $iblock["SECTION_DELETE"] ?? null,
            "BIZPROC" => "Y",
            "SITE_ID" => array($siteId),
            "RIGHTS_MODE" => "E",
        );
 
        if ($iblock["SOCNET_GROUP_ID"])
        {
            $fields["SOCNET_GROUP_ID"] = $iblock["SOCNET_GROUP_ID"];
        }
 
        static $exts = array(
            "image/jpeg" => "jpg",
            "image/png" => "png",
            "image/gif" => "gif",
        );
        if (!empty($picture) && isset($exts[$pictureType]))
        {
            $fn = \CTempFile::GetFileName();
            Main\IO\Directory::createDirectory($fn);
 
            $fn .= md5(mt_rand()).".".$exts[$pictureType];
 
            $f = fopen($fn, "wb");
            fwrite($f, $picture);
            fclose($f);
 
            $fields["PICTURE"] = \CFile::MakeFileArray($fn/*, $pictureType*/);
        }
 
        $ob = new \CIBlock;
        $res = $ob->Add($fields);
        if ($res)
        {
            self::createIBlockRights($res);
 
            $list = new \CList($res);
 
            if (isset($iblock["~NAME_FIELD"]))
                $list->UpdateField("NAME", $iblock["~NAME_FIELD"]);
 
            $list->Save();
 
            \CLists::setLiveFeed(1, $res);
 
            return $res;
        }
 
        return 0;
    }
 
    protected static function getIBlockType()
    {
        $iblockType = Main\Config\Option::get("lists", "livefeed_iblock_type_id", "bitrix_processes");
        if (empty($iblockType))
            $iblockType = "bitrix_processes";
 
        return $iblockType;
    }
 
    protected static function getDocumentType($iblockType, $iblockId)
    {
        if ($iblockType == static::getIBlockType())
            $documentType = array('lists', 'BizprocDocument', 'iblock_'.$iblockId);
        else
            $documentType = array('lists', 'Bitrix\Lists\BizprocDocumentLists', 'iblock_'.$iblockId);
 
        return $documentType;
    }

    private static function createIBlockRights($iblockId)
    {
        $rightObject = new \CIBlockRights($iblockId);
        $rights = $rightObject->getRights();
        $rightsList = $rightObject->getRightsList(false);
 
        $rightId = array_search('iblock_full', $rightsList);
        $rights['n0'] = array('GROUP_CODE' => "G1", 'TASK_ID' => $rightId);
        $rights['n1'] = array('GROUP_CODE' => "U1", 'TASK_ID' => $rightId);
 
        $rightId = array_search('iblock_element_add', $rightsList);
        $rights['n2'] = array('GROUP_CODE' => "G2", 'TASK_ID' => $rightId);
 
        $rightObject->setRights($rights);
    }
 
    const PATH = "/bitrix/modules/lists/install/bizproc/process/";
    const PATH_USER_PROCESSES = "/bitrix/lists/processes/";

    public static function installProcesses($lang, $siteId = null)
    {
        if (empty($lang))
            throw new Main\ArgumentNullException("lang");
 
        if (! Main\Loader::includeModule("bizproc"))
            return;
 
        $iblockType = static::getIBlockType();
 
        $db = \CIBlockType::GetList(array(), array("=ID" => $iblockType));
        $res = $db->Fetch();
        if (!$res)
            static::createIBlockType();
 
        if(in_array($lang, self::$listRuLanguage))
            $lang = 'ru';
 
        if ($lang === 'co')
        {
            $lang = 'la';
        }
 
        $dir = new Main\IO\Directory(Main\Loader::getDocumentRoot() . static::PATH . $lang . "/");
        if(!$dir->isExists())
            $dir = new Main\IO\Directory(Main\Loader::getDocumentRoot() . static::PATH . "en/");
 
        if ($dir->isExists())
        {
            $children = $dir->getChildren();
            foreach ($children as $child)
            {
                if ($child->isFile() && ($child->getExtension() == "prc"))
                {
                    static::import($iblockType, $child->getContents(), $siteId);
                }
            }
        }
    }

    public static function installProcess($path, $siteId = null)
    {
        if (empty($path))
            throw new Main\ArgumentNullException("path");
 
        if (!Main\Loader::includeModule("bizproc"))
            return;
 
        $path = Main\Loader::getDocumentRoot() . $path;
        $iblockType = static::getIBlockType();
 
        $db = \CIBlockType::GetList(array(), array("=ID" => $iblockType));
        $res = $db->Fetch();
        if (!$res)
            static::createIBlockType();
 
        $file = new Main\IO\File($path);
        if($file->isExists() && $file->getExtension() == "prc")
        {
            static::import($iblockType, $file->getContents(), $siteId);
        }
    }

    public static function loadDataProcesses($lang, $systemProcesses = true, &$fileData, $path = null)
    {
        if (empty($lang))
            throw new Main\ArgumentNullException("lang");
 
        if(in_array($lang, self::$listRuLanguage))
            $lang = 'ru';
 
        if(!empty($path))
        {
            $path = rtrim($path, "/");
            $path = $path."/";
        }
        else
        {
            $path = self::getPathToProcesses($lang, $systemProcesses);
        }
 
        $dir = new Main\IO\Directory($path);
        if (!$dir->isExists() && $lang === 'en')
        {
            return;
        }
 
        if ($dir->isExists())
        {
            $children = $dir->getChildren();
            foreach ($children as $key => $child)
            {
                if ($child->isFile() && ($child->getExtension() == "prc"))
                {
                    $data = self::getDataProcess($path.$child->getName());
                    $fileData[$data['CODE']]['FILE_NAME'] = $child->getName();
                    $fileData[$data['CODE']]['FILE_PATH'] = str_replace(Main\Loader::getDocumentRoot(), '', $child->getPath());
                    $fileData[$data['CODE']]['NAME'] = $data['NAME'];
                    $fileData[$data['CODE']]['DESCRIPTION'] = $data['DESCRIPTION'];
                    $fileData[$data['CODE']]['CODE'] = $data['CODE'];
                    $fileData[$data['CODE']]['IBLOCK_TYPE_ID'] = $data['IBLOCK_TYPE_ID'];
                    $fileData[$data['CODE']]['DIRECTORY_NAME'] = $child->getDirectory()->getName();
                }
                elseif($child->isDirectory())
                {
                    self::loadDataProcesses($lang, $systemProcesses, $fileData, $child->getPath());
                }
            }
        }
        else
        {
            $path = self::getPathToProcesses("en", $systemProcesses);
            self::loadDataProcesses('en', $systemProcesses, $fileData, $path);
        }
    }
 
    private static function getPathToProcesses($lang, $systemProcesses = true)
    {
        if($systemProcesses)
        {
            $path = Main\Loader::getDocumentRoot() . static::PATH . $lang . "/";
        }
        else
        {
            $path = Main\Loader::getDocumentRoot() . static::PATH_USER_PROCESSES . $lang . "/";
        }
 
        return $path;
    }
 
    protected static function createIBlockType()
    {
        $iblockType = array(
            'ID' => 'bitrix_processes',
            'SECTIONS' => 'Y',
            'SORT' => 500,
            'LANG' => array(),
        );
 
        $langList = \CLanguage::GetList('lid', 'asc', array("ACTIVE" => "Y"));
        while ($lang = $langList->Fetch())
            $iblockType['LANG'][$lang['LID']]['NAME'] = "Processes";
 
        $iblockTypeList = \CIBlockType::GetList(array(), array('=ID' => $iblockType['ID']));
        $res = $iblockTypeList->fetch();
        if (!$res)
        {
            $iblockTypeObject = new \CIBlockType;
            $iblockTypeObject->add($iblockType);
 
            $con = Main\Application::getConnection();
            $con->queryExecute("
                insert into b_lists_permission (IBLOCK_TYPE_ID, GROUP_ID)
                select 'bitrix_processes', p.GROUP_ID
                from
                    b_lists_permission p
                    left join b_lists_permission p2 on p2.GROUP_ID = p.GROUP_ID and p2.IBLOCK_TYPE_ID = 'bitrix_processes'
                where
                    p.IBLOCK_TYPE_ID = 'lists'
                    and p2.IBLOCK_TYPE_ID is null
            ");
 
            global $CACHE_MANAGER;
            $CACHE_MANAGER->Clean("b_lists_permission");
        }
 
        Main\Config\Option::set("lists", "livefeed_iblock_type_id", "bitrix_processes");
    }

    public static function onAgent($lang)
    {
        if (ModuleManager::isModuleInstalled("bizproc"))
        {
            self::installProcesses($lang);
            return "";
        }
        else
        {
            return '\Bitrix\Lists\Importer::onAgent("'.$lang.'");';
        }
    }
 
    public static function migrateList($id)
    {
        $id = intval($id);
        if ($id <= 0)
            throw new Main\ArgumentNullException("id");
 
        $db = \CIBlock::GetList(
            array(),
            array("ID" => $id, "IBLOCK_TYPE_ID" => "lists", "CHECK_PERMISSIONS" => "N")
        );
        $iblock = $db->Fetch();
        if (!$iblock)
            throw new Main\ArgumentOutOfRangeException("id");
 
        $iblockType = static::getIBlockType();
 
        $ob = new \CIBlock;
        $res = $ob->Update($id, array("IBLOCK_TYPE_ID" => $iblockType));
        if ($res)
        {
            \CLists::setLiveFeed(1, $id);
        }
 
        \CBPDocument::MigrateDocumentType(
            array("lists", 'Bitrix\Lists\BizprocDocumentLists', "iblock_".$id),
            array("lists", "BizprocDocument", "iblock_".$id)
        );
    }
}