Server : Apache System : Linux server2.corals.io 4.18.0-348.2.1.el8_5.x86_64 #1 SMP Mon Nov 15 09:17:08 EST 2021 x86_64 User : corals ( 1002) PHP Version : 7.4.33 Disable Function : exec,passthru,shell_exec,system Directory :  /home/corals/old/vendor/magento/module-customer/Model/ResourceModel/Address/

Upload File : current_dir [ Writeable ] document_root [ Writeable ]

<?php
/**
 * Copyright © Magento, Inc. All rights reserved.
 * See COPYING.txt for license details.
 */
declare(strict_types=1);

namespace Magento\Customer\Model\ResourceModel\Address;

use Magento\Customer\Api\Data\CustomerInterface;
use Magento\Customer\Model\Address;
use Magento\Customer\Model\Customer;
use Magento\Customer\Model\CustomerFactory;
use Magento\Customer\Model\CustomerRegistry;
use Magento\Framework\Model\AbstractModel;
use Magento\Framework\Model\ResourceModel\Db\VersionControl\RelationInterface;

/**
 * Class represents save operations for customer address relations
 */
class Relation implements RelationInterface
{
    /**
     * @var CustomerFactory
     */
    protected $customerFactory;

    /**
     * @var CustomerRegistry
     */
    private $customerRegistry;

    /**
     * @param CustomerFactory $customerFactory
     * @param CustomerRegistry $customerRegistry
     */
    public function __construct(
        CustomerFactory $customerFactory,
        CustomerRegistry $customerRegistry
    ) {
        $this->customerFactory = $customerFactory;
        $this->customerRegistry = $customerRegistry;
    }

    /**
     * Process object relations
     *
     * @param AbstractModel $object
     * @return void
     */
    public function processRelation(AbstractModel $object): void
    {
        /** @var $object Address */
        if (!$object->getIsCustomerSaveTransaction() && $object->getId()) {
            $customer = $this->customerFactory->create()->load($object->getCustomerId());

            $changedAddresses = [];
            $changedAddresses = $this->getDefaultBillingChangedAddress($object, $customer, $changedAddresses);
            $changedAddresses = $this->getDefaultShippingChangedAddress($object, $customer, $changedAddresses);

            if ($changedAddresses) {
                $customer->getResource()->getConnection()->update(
                    $customer->getResource()->getTable('customer_entity'),
                    $changedAddresses,
                    $customer->getResource()->getConnection()->quoteInto('entity_id = ?', $customer->getId())
                );
                $this->updateCustomerRegistry($customer, $changedAddresses);
            }
        }
    }

    /**
     * Get default billing changed address
     *
     * @param Address $object
     * @param Customer $customer
     * @param array $changedAddresses
     * @return array
     */
    private function getDefaultBillingChangedAddress(
        Address $object,
        Customer $customer,
        array $changedAddresses
    ): array {
        if ($object->getIsDefaultBilling()) {
            $changedAddresses[CustomerInterface::DEFAULT_BILLING] = $object->getId();
        } elseif ($customer->getDefaultBillingAddress()
            && $object->getIsDefaultBilling() === false
            && (int)$customer->getDefaultBillingAddress()->getId() === (int)$object->getId()
        ) {
            $changedAddresses[CustomerInterface::DEFAULT_BILLING] = null;
        }

        return $changedAddresses;
    }

    /**
     * Get default shipping changed address
     *
     * @param Address $object
     * @param Customer $customer
     * @param array $changedAddresses
     * @return array
     */
    private function getDefaultShippingChangedAddress(
        Address $object,
        Customer $customer,
        array $changedAddresses
    ): array {
        if ($object->getIsDefaultShipping()) {
            $changedAddresses[CustomerInterface::DEFAULT_SHIPPING] = $object->getId();
        } elseif ($customer->getDefaultShippingAddress()
            && $object->getIsDefaultShipping() === false
            && (int)$customer->getDefaultShippingAddress()->getId() === (int)$object->getId()
        ) {
            $changedAddresses[CustomerInterface::DEFAULT_SHIPPING] = null;
        }

        return $changedAddresses;
    }

    /**
     * Push updated customer entity to the registry.
     *
     * @param Customer $customer
     * @param array $changedAddresses
     * @return void
     */
    private function updateCustomerRegistry(Customer $customer, array $changedAddresses): void
    {
        if (array_key_exists(CustomerInterface::DEFAULT_BILLING, $changedAddresses)) {
            $customer->setDefaultBilling($changedAddresses[CustomerInterface::DEFAULT_BILLING]);
        }

        if (array_key_exists(CustomerInterface::DEFAULT_SHIPPING, $changedAddresses)) {
            $customer->setDefaultShipping($changedAddresses[CustomerInterface::DEFAULT_SHIPPING]);
        }

        $this->customerRegistry->push($customer);
    }

    /**
     * Checks if address has chosen as default and has had an id
     *
     * @deprecated 102.0.1 Is not used anymore due to changes in logic of save of address.
     *             If address was default and becomes not default than default address id for customer must be
     *             set to null
     * @param AbstractModel $object
     * @return bool
     */
    protected function isAddressDefault(AbstractModel $object)
    {
        return $object->getId() && ($object->getIsDefaultBilling() || $object->getIsDefaultShipping());
    }
}