profileimport.php

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

<?php
namespace Bitrix\Sale\Exchange;
 
use Bitrix\Main;
use Bitrix\Sale;
use Bitrix\Sale\Exchange;
use Bitrix\Sale\Exchange\Entity\UserImportBase;

class ProfileImport extends UserImportBase
{

    public function __construct()
    {
        $this->fields = new Sale\Internals\Fields();
    }

    public function getOwnerTypeId()
    {
        return EntityType::PROFILE;
    }

    public function load(array $fields)
    {
        $result = new Sale\Result();
 
        $r = $this->checkFields($fields);
        if(!$r->isSuccess())
        {
            throw new Main\ArgumentException('XML_ID is not defined');
        }
 
        $profileFields = $this->initFieldsProfile($fields, $arErrors);
 
        if(count($arErrors)>0)
        {
            foreach($arErrors as $error)
            {
                $result->addError(new  Main\Error(str_replace('<br>','', $error['TEXT'])));
            }
        }
 
        if(count($profileFields)>0)
        {
            $profile = new static();
 
            $profile->setFields($profileFields);
 
            $this->setEntity($profile);
        }
 
        return $result;
    }

    public function getPersonalTypeId()
    {
        return $this->getField('PERSON_TYPE_ID');
    }

    public function getUserId()
    {
        return $this->getField('USER_ID');
    }

    public function getId()
    {
        $profile = $this->getEntity();
        return $profile->getField('USER_PROFILE_ID');
    }

    public function profileGetId()
    {
        return $this->getField('USER_PROFILE_ID');
    }

    public function isImportable()
    {
        return $this->settings->isImportableFor($this->getOwnerTypeId());
    }

    public function add(array $params)
    {
        $result = new Sale\Result();

        $profile = $this->getEntity();
 
        $fields = $params["TRAITS"];
        $property = $params["ORDER_PROP"];
 
        $propertyOrders = static::getPropertyOrdersByPersonalTypeId($profile->getPersonalTypeId());
 
        if(is_array($propertyOrders))
        {
            foreach($propertyOrders as $filedsProperty)
            {
                $propertyId = $filedsProperty["ID"];
                if(array_key_exists($propertyId, $property))
                {
                    $propertyByConfigValue = $property[$propertyId];
                    if($profile->profileGetId()<=0)
                    {
                        if(!empty($propertyByConfigValue))
                        {
                            $profileId = \CSaleOrderUserProps::Add(array(
                                "NAME" => $fields["AGENT_NAME"],
                                "USER_ID" => $profile->getUserId(),
                                "PERSON_TYPE_ID" => $profile->getPersonalTypeId(),
                                "XML_ID" => $fields["XML_ID"],
                                "VERSION_1C" => $fields["VERSION_1C"]
                            ));
 
                            $profile->setField("USER_PROFILE_ID", $profileId);
                        }
                    }
 
                    \CSaleOrderUserPropsValue::Add(array(
                        "USER_PROPS_ID" => $profile->profileGetId(),
                        "ORDER_PROPS_ID" => $propertyId,
                        "NAME" => $filedsProperty["NAME"],
                        "VALUE" => $propertyByConfigValue
                    ));
                }
            }
        }
 
        return $result;
    }

    public function update(array $params)
    {
        $result = new Sale\Result();

        $profile = $this->getEntity();
 
        $criterion = $this->getCurrentCriterion($profile);
 
        $fields = $params["TRAITS"];
        $property = $params["ORDER_PROP"];
 
        if($criterion->equals($fields))
        {
            $fieldsProfileUpdate = array(
                "VERSION_1C" => $fields["VERSION_1C"],
                "NAME" => $fields["AGENT_NAME"],
                "USER_ID" => $profile->getUserId()
            );
 
            \CSaleOrderUserProps::Update($profile->profileGetId(), $fieldsProfileUpdate);
 
 
            $profileFields = static::getFieldsUserProfile($profile->profileGetId());
            foreach($profileFields as $fieldsProfile)
            {
                $fieldsProfileByProperty[$fieldsProfile["ORDER_PROPS_ID"]] = array("ID" => $fieldsProfile["ID"], "VALUE" => $fieldsProfile["VALUE"]);
            }
 
            $propertyOrders = static::getPropertyOrdersByPersonalTypeId($profile->getPersonalTypeId());
            foreach($propertyOrders as $filedsProperty)
            {
                $propertyId = $filedsProperty["ID"];
                if(array_key_exists($propertyId, $property))
                {
                    $propertyByConfigValue = $property[$propertyId];
                    if(!empty($propertyByConfigValue))
                    {
                        $fields = array(
                            "USER_PROPS_ID" => $profile->getField("USER_PROFILE_ID"),
                            "ORDER_PROPS_ID" => $propertyId,
                            "NAME" => $filedsProperty["NAME"],
                            "VALUE" => $propertyByConfigValue
                        );
 
                        if(empty($fieldsProfileByProperty[$propertyId]))
                        {
                            \CSaleOrderUserPropsValue::Add($fields);
                        }
                        elseif($fieldsProfileByProperty[$propertyId]["VALUE"] != $propertyByConfigValue)
                        {
                            \CSaleOrderUserPropsValue::Update($fieldsProfileByProperty[$propertyId]["ID"], $fields);
                        }
                    }
                }
            }
        }
        return $result;
    }

    public function delete(array $params = null)
    {
        return new Sale\Result();
    }

    protected function checkFields(array $fields)
    {
        $result = new Sale\Result();
 
        if(empty($fields['XML_ID']))
        {
            $result->addError(new Main\Error('XML_ID is not defined',''));
        }
 
        return $result;
    }

    public static function getUserProfile(array $fields)
    {
        $result = array();
 
        $r = \CSaleOrderUserProps::GetList(array(),
            array("XML_ID" => $fields["XML_ID"]),
            false,
            false,
            array("ID", "NAME", "USER_ID", "PERSON_TYPE_ID", "XML_ID", "VERSION_1C")
        );
        if ($ar = $r->Fetch())
            $result = $ar;
 
        return $result;
    }

    public static function getFieldsUserProfile($profileId)
    {
        $result = array();
 
        if(intval($profileId) <= 0)
            return false;
 
        $r = \CSaleOrderUserPropsValue::GetList(array(), array("USER_PROPS_ID" => $profileId));
        while ($ar = $r->Fetch())
        {
            //$result[$ar["ORDER_PROPS_ID"]] = $ar["VALUE"];
            $result[] = $ar;
        }
 
        return $result;
    }

    public function initFieldsProfile(array $fields, &$arErrors)
    {
        static $profiles = null;
 
        if($profiles[$fields['XML_ID']] === null)
        {
            $result = array();
            $profile = static::getUserProfile(array('XML_ID'=>$fields['XML_ID']));
 
            if(!empty($profile))
            {
                $result['USER_ID'] = $profile['USER_ID'];
                $result['PERSON_TYPE_ID'] = $profile['PERSON_TYPE_ID'];
 
                $result['USER_PROFILE_ID'] = $profile['ID'];
                $result['USER_PROFILE_VERSION'] = $profile['VERSION_1C'];
 
                $profileFields = static::getFieldsUserProfile($profile['ID']);
                if(!empty($profileFields))
                {
                    foreach($profileFields as $profileField)
                    {
                        $result['USER_PROPS'][$profileField["ORDER_PROPS_ID"]] = $profileField["VALUE"];
                    }
                }
            }
            elseif($this->isImportable())
            {
                $result['PERSON_TYPE_ID'] = $this->resolvePersonTypeId($fields);
 
                $user = static::getUserByCode($fields['XML_ID']);
                if(!empty($user))
                    $result['USER_ID'] = $user['ID'];
                else
                    $result['USER_ID'] = $this->registerUser($fields, $arErrors);
 
                $result['USER_PROFILE_ID'] = null;
                $result['USER_PROFILE_VERSION'] = null;
                $result['USER_PROPS'] = null;
            }
 
            if(count($arErrors)>0)
                return $result;
            else
                $profiles[$fields['XML_ID']] = $result;
        }
 
        return $profiles[$fields['XML_ID']];
    }

    public static function getUserByCode($code)
    {
        return Exchange\Entity\UserProfileImportLoader::getUserByCode($code);
    }

    public static function getFieldExternalId()
    {
        return 'XML_ID';
    }

    public function refreshData(array $fields)
    {
    }
}