src/Contact/EventSubscriber/AddCompanyContactPersonSubscriber.php line 55

  1. <?php
  3. declare(strict_types=1);
  4. /**
  5.  * Copyright (c) 2023 TECLA Consulting Group oü.
  6.  * All rights reserved.
  7.  *
  8.  * This unpublished material is proprietary to TECLA Consulting Group oü.
  9.  * All rights reserved. The methods and
  10.  * techniques described herein are considered trade secrets
  11.  * and/or confidential. Reproduction or distribution, in whole
  12.  * or in part, is forbidden except by express written permission
  13.  * of TECLA Consulting Group oü.
  14.  *
  15.  * @author    Matúš Sýkorjak <matus@tecla.no>
  16.  * @copyright 2023 TECLA Consulting Group oü
  17.  */
  19. namespace App\Contact\EventSubscriber;
  21. use App\Contact\Event\ContactAccess;
  22. use App\Contact\Event\Relationship\Ownership;
  23. use App\Contact\Form\Dto\Factory\ContactRelationshipCompanyContactPersonCreateDtoFactoryInterface;
  24. use App\Contact\Model\ContactInterface;
  25. use App\Contact\Query\ContactRelationshipCompanyContactPerson\FindOneByCompanyAndContactPersonQueryInterface;
  26. use App\Contact\Service\ContactRelationshipCompanyContactPersonServiceInterface;
  27. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  29. final class AddCompanyContactPersonSubscriber implements EventSubscriberInterface
  30. {
  31.     private FindOneByCompanyAndContactPersonQueryInterface $findByUniqueKeyQuery;
  33.     private ContactRelationshipCompanyContactPersonCreateDtoFactoryInterface $contactPersonDtoFactory;
  35.     private ContactRelationshipCompanyContactPersonServiceInterface $contactPersonService;
  37.     public function __construct(
  38.         FindOneByCompanyAndContactPersonQueryInterface $findByUniqueKeyQuery,
  39.         ContactRelationshipCompanyContactPersonCreateDtoFactoryInterface $contactPersonDtoFactory,
  40.         ContactRelationshipCompanyContactPersonServiceInterface $contactPersonService
  41.     ) {
  42.         $this->findByUniqueKeyQuery = $findByUniqueKeyQuery;
  43.         $this->contactPersonDtoFactory = $contactPersonDtoFactory;
  44.         $this->contactPersonService = $contactPersonService;
  45.     }
  47.     public static function getSubscribedEvents(): array
  48.     {
  49.         return [
  50.             ContactAccess\CreatedEvent::class => 'onContactAccessCreated',
  51.             Ownership\CreatedEvent::class => 'onOwnershipCreated',
  52.         ];
  53.     }
  55.     public function onContactAccessCreated(ContactAccess\CreatedEvent $event): void
  56.     {
  57.         $contactAccess = $event->getContactAccess();
  59.         $this->addContactPersonIfNotExists(
  60.             $contactAccess->getContact(),
  61.             $contactAccess->getAccessor()
  62.         );
  63.     }
  65.     public function onOwnershipCreated(Ownership\CreatedEvent $event): void
  66.     {
  67.         $ownership = $event->getRelationship();
  69.         $this->addContactPersonIfNotExists(
  70.             $ownership->getCompany(),
  71.             $ownership->getOwner()
  72.         );
  73.     }
  75.     private function addContactPersonIfNotExists(ContactInterface $company, ContactInterface $person): void
  76.     {
  77.         if (ContactInterface::TYPE_COMPANY !== $company->getType()) {
  78.             return;
  79.         }
  81.         if (ContactInterface::TYPE_PERSON !== $person->getType()) {
  82.             return;
  83.         }
  85.         if ($this->findByUniqueKeyQuery->execute($company->getId(), $person->getId())) {
  86.             return;
  87.         }
  89.         $contactPersonDto = $this->contactPersonDtoFactory->create(
  90.             $company,
  91.             $person,
  92.             $person->getContactEmail()?->getEmail(),
  93.             $person->getPhone()
  94.         );
  96.         $this->contactPersonService->createFromRelationshipContactPersonCreateDto($contactPersonDto);
  97.     }
  98. }