elementvalues.php

<?php
namespace Bitrix\Iblock\InheritedProperty;
 
class ElementValues extends BaseValues
{
    protected $sectionId = 0;
    protected $elementId = 0;
 
    public function __construct($iblockId, $elementId)
    {
        parent::__construct($iblockId);
        $this->elementId = (int)$elementId;
        $this->queue->addElement($this->iblockId, $this->elementId);
    }
 
    public function getValueTableName()
    {
        return "b_iblock_section_iprop";
    }
 
    public function getType()
    {
        return "E";
    }
 
    public function getId()
    {
        return $this->elementId;
    }
 
    public function  createTemplateEntity()
    {
        return new \Bitrix\Iblock\Template\Entity\Element($this->elementId);
    }
 
    public function setParents($sectionId)
    {
        if (is_array($sectionId))
        {
            if (!empty($sectionId))
            {
                $sectionId = array_map("intval", $sectionId);
                $this->sectionId = min($sectionId);
            }
        }
        else
        {
            $this->sectionId = (int)$sectionId;
        }
    }
 
    public function getParents()
    {
        $parents = array();
        if ($this->elementId > 0)
        {
            $elementList = \Bitrix\Iblock\ElementTable::getList(array(
                "select" => array("IBLOCK_SECTION_ID"),
                "filter" => array("=ID" => $this->elementId),
            ));
            $element = $elementList->fetch();
            if ($element && $element["IBLOCK_SECTION_ID"] > 0)
                $parents[] = new SectionValues($this->iblockId, $element["IBLOCK_SECTION_ID"]);
            else
                $parents[] = new IblockValues($this->iblockId);
        }
        elseif ($this->sectionId > 0)
        {
            $parents[] = new SectionValues($this->iblockId, $this->sectionId);
        }
        else
        {
            $parents[] = new IblockValues($this->iblockId);
        }
        return $parents;
    }
 
    public function queryValues()
    {
        $connection = \Bitrix\Main\Application::getConnection();
        $result = array();
        if ($this->hasTemplates())
        {
            if ($this->queue->getElement($this->iblockId, $this->elementId) === false)
            {
                $ids = $this->queue->get($this->iblockId);
                $query = $connection->query("
                    SELECT
                        P.ID
                        ,P.CODE
                        ,P.TEMPLATE
                        ,P.ENTITY_TYPE
                        ,P.ENTITY_ID
                        ,IP.VALUE
                        ,IP.ELEMENT_ID
                    FROM
                        b_iblock_element_iprop IP
                        INNER JOIN b_iblock_iproperty P ON P.ID = IP.IPROP_ID
                    WHERE
                        IP.IBLOCK_ID = ".$this->iblockId."
                        AND IP.ELEMENT_ID in (".implode(", ", $ids).")
                ");
                $result = array();
                while ($row = $query->fetch())
                {
                    $result[$row["ELEMENT_ID"]][$row["CODE"]] = $row;
                }
                $this->queue->set($this->iblockId, $result);
            }
            $result = $this->queue->getElement($this->iblockId, $this->elementId);
 
            if (empty($result))
            {
                $result = parent::queryValues();
                if (!empty($result))
                {
                    $sqlHelper = $connection->getSqlHelper();
                    $elementList = \Bitrix\Iblock\ElementTable::getList(array(
                        "select" => array("IBLOCK_SECTION_ID"),
                        "filter" => array("=ID" => $this->elementId),
                    ));
                    $element = $elementList->fetch();
                    $element['IBLOCK_SECTION_ID'] = (int)$element['IBLOCK_SECTION_ID'];
 
                    $fields = array(
                        "IBLOCK_ID",
                        "SECTION_ID",
                        "ELEMENT_ID",
                        "IPROP_ID",
                        "VALUE",
                    );
                    $rows = array();
                    foreach ($result as $CODE => $row)
                    {
                        $rows[] = array(
                            $this->iblockId,
                            $element["IBLOCK_SECTION_ID"],
                            $this->elementId,
                            $row["ID"],
                            $sqlHelper->forSql($row["VALUE"]),
                        );
                    }
                    $this->insertValues("b_iblock_element_iprop", $fields, $rows);
                }
            }
        }
        return $result;
    }
 
    function clearValues()
    {
        $connection = \Bitrix\Main\Application::getConnection();
        $connection->query("
            DELETE FROM b_iblock_element_iprop
            WHERE IBLOCK_ID = ".$this->iblockId."
            AND ELEMENT_ID = ".$this->elementId."
        ");
        $this->queue->deleteElement($this->iblockId, $this->elementId);
    }
}