OroCRM\Bundle\MagentoBundle\Manager\CustomerAddressManager

Complexity

Total Complexity

13

Size/Duplication

Total Lines	124
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	7

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	8	1
B	copyToContact()	0	38	6
A	contactHasAddress()	0	11	3
A	isEqualAddresses()	0	11	3

<?php

namespace OroCRM\Bundle\MagentoBundle\Manager;

use Doctrine\ORM\EntityManager;

use Psr\Log\LoggerAwareInterface;
use Psr\Log\LoggerAwareTrait;

use Symfony\Component\PropertyAccess\PropertyAccess;
use Symfony\Component\PropertyAccess\PropertyAccessor;

use OroCRM\Bundle\ContactBundle\Entity\Contact;
use OroCRM\Bundle\ContactBundle\Entity\ContactAddress;
use OroCRM\Bundle\MagentoBundle\Entity\Customer;
use OroCRM\Bundle\MagentoBundle\Manager\CustomerAddress\ConvertAddressToContactAdress;

class CustomerAddressManager implements LoggerAwareInterface
{
    use LoggerAwareTrait;

    /** @var EntityManager */
    protected $em;

    /** @var PropertyAccessor */
    protected $accessor;

    /** @var ConvertAddressToContactAdress */
    protected $convertAddressToContactAddress;

    /** @var array */
    protected $baseAddressProperties = [
        'label',
        'street',
        'street2',
        'city',
        'postalCode',
        'country',
        'organization',
        'region',
        'regionText',
        'namePrefix',
        'firstName',
        'middleName',
        'lastName',
        'nameSuffix'
    ];

    /**
     * @param EntityManager $em
     * @param ConvertAddressToContactAdress $convertAddressToContactAdress
     */
    public function __construct(
        EntityManager $em,

You have injected the EntityManager via parameter $em. This is generally not recommended as it might get closed and become unusable. Instead, it is recommended to inject the ManagerRegistry and retrieve the EntityManager via getManager() each time you need it.

        ConvertAddressToContactAdress $convertAddressToContactAdress
    ) {
        $this->em = $em;
        $this->convertAddressToContactAddress = $convertAddressToContactAdress;
        $this->accessor = PropertyAccess::createPropertyAccessor();
    }

    /**
     * @param int[]|null $customersIds
     * @param int[]|null $integrationIds
     * @param int $batchSize
     */
    public function copyToContact($customersIds = null, $integrationIds = null, $batchSize = 25)
    {
        $i = 0;
        $this->logger->info(sprintf('Start process'));
        $repository = $this->em->getRepository('OroCRMMagentoBundle:Customer');

        $iterator = $repository->getIteratorByIdsAndIntegrationIds($customersIds, $integrationIds);
        $iterator->setBufferSize($batchSize);
        $customerCount = $iterator->count();

        $iterator->setPageCallback(function () use (&$i, $customerCount) {
            $this->em->flush();
            $this->logger->info(sprintf('Processed %s customers from %s', $i, $customerCount));
        });

        /** @var Customer $customer */
        foreach ($iterator as $customer) {
            $i++;
            $contact = $customer->getContact();
            if ($contact) {
                $addresses = $customer->getAddresses();
                if ($addresses->count() > 0) {
                    foreach ($addresses as $address) {
                        $newContactAddress = $this->convertAddressToContactAddress->convert($address);
                        if (!$this->contactHasAddress($contact, $newContactAddress)) {
                            $contact->addAddress($newContactAddress);
                            $message = 'Customer address with id=%s was copied in contact with id=%s';
                            $this->logger->info(sprintf($message, $address->getId(), $contact->getId()));
                        }
                    }
                    $this->em->persist($contact);
                }
            }
        }

        $this->em->flush();
        $this->logger->info(sprintf('Finish process'));
    }

    /**
     * @param Contact $contact
     * @param ContactAddress $contactAddress
     *
     * @return bool
     */
    protected function contactHasAddress(Contact $contact, ContactAddress $contactAddress)
    {
        $addresses = $contact->getAddresses();
        foreach ($addresses as $address) {
            if ($this->isEqualAddresses($address, $contactAddress)) {
                return true;
            }
        }

        return false;
    }

    /**
     * @param ContactAddress $address1
     * @param ContactAddress $address2
     *
     * @return bool
     */
    protected function isEqualAddresses(ContactAddress $address1, ContactAddress $address2)
    {
        $countEqualProperty = 0;
        foreach ($this->baseAddressProperties as $property) {
            if ($this->accessor->getValue($address1, $property) === $this->accessor->getValue($address2, $property)) {
                $countEqualProperty++;
            }
        }

        return $countEqualProperty === count($this->baseAddressProperties);
    }
}