src/EventSubscriber/Api/EstimateAddressSubscriber.php line 41

Open in your IDE?
  1. <?php
  3. // api/src/EventSubscriber/BookMailSubscriber.php
  5. namespace App\EventSubscriber\Api;
  7. use ApiPlatform\Core\EventListener\EventPriorities;
  8. use App\Entity\Legacy\Estimate;
  9. use App\Entity\Legacy\EstimateAddress;
  10. use App\Repository\EstimateAddressRepository;
  11. use Doctrine\ORM\EntityManagerInterface;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. use Symfony\Component\HttpKernel\Event\ViewEvent;
  14. use Symfony\Component\HttpKernel\KernelEvents;
  16. final class EstimateAddressSubscriber implements EventSubscriberInterface
  17. {
  18. /**
  19. * @var EntityManagerInterface
  20. */
  21. protected $entityManager;
  23. /**
  24. * @var EstimateAddressRepository
  25. */
  26. private $estimateAddressRepository;
  28. public function __construct(EntityManagerInterface $entityManager, EstimateAddressRepository $estimateAddressRepository)
  29. {
  30. $this->entityManager = $entityManager;
  31. $this->estimateAddressRepository = $estimateAddressRepository;
  32. }
  34. public static function getSubscribedEvents()
  35. {
  36. return [
  37. KernelEvents::VIEW => ['validate', EventPriorities::PRE_VALIDATE],
  38. ];
  39. }
  41. public function validate(\Symfony\Component\HttpKernel\Event\ViewEvent $event)
  42. {
  43. if (!$event->getControllerResult() instanceof Estimate) {
  44. return;
  45. }
  47. /** @var Estimate $estimate */
  48. $estimate = $event->getControllerResult();
  50. $this->updateCustomerAddress($estimate);
  51. $this->updateCarpenterAddresses($estimate);
  53. $this->entityManager->flush();
  54. }
  56. /**
  57. * @param Estimate $estimate
  58. */
  59. protected function updateCustomerAddress(Estimate $estimate)
  60. {
  61. $sourceName = 'estimate_customer';
  62. $address = $this->estimateAddressRepository->findOneBy(
  63. [
  64. 'estimate' => $estimate,
  65. 'source' => $sourceName,
  66. ]
  67. );
  68. if (!$address) {
  69. $address = new EstimateAddress();
  70. $address
  71. ->setEstimate($estimate)
  72. ->setSource($sourceName);
  74. $this->entityManager->persist($address);
  75. }
  77. $address
  78. ->setOwner($estimate->getOwner())
  79. ->setCustomer($estimate->getCustomer())
  80. ->setAddress($estimate->getAddress())
  81. ->setContactPerson($estimate->getContactPerson())
  82. ->setIsHidden($estimate->getHideAddressInSelector());
  83. }
  85. /**
  86. * @param Estimate $estimate
  87. */
  88. protected function updateCarpenterAddresses(Estimate $estimate)
  89. {
  90. $sourceName = 'estimate_item_carpenter';
  92. foreach ($estimate->getItems() as $item) {
  93. if (!isset($item['carpenterCompany']) || empty($item['carpenterCompany'])) {
  94. continue;
  95. }
  97. $address = $this->estimateAddressRepository->findOneBy(['itemShortcode' => $item['shortcode']]);
  99. if (!$address) {
  100. $address = new EstimateAddress();
  101. $address
  102. ->setEstimate($estimate)
  103. ->setSource($sourceName)
  104. ->setItemShortcode($item['shortcode']);
  106. $this->entityManager->persist($address);
  107. }
  109. $address
  110. ->setOwner($estimate->getOwner())
  111. ->setCustomer($item['carpenterCompany'])
  112. ->setAddress($item['carpenterAddress'])
  113. ->setContactPerson($estimate->getContactPerson())
  114. ->setIsHidden($estimate->getHideAddressInSelector());
  115. }
  116. }
  117. }