src/EventSubscriber/MeterReading/MeterReadingSubscriber.php line 46

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber\MeterReading;
  5. use App\Entity\IndexUpdate;
  6. use App\Manager\ContractManager;
  7. use App\Entity\User;
  8. use App\Event\MeterReading\IndexUpdatedEvent;
  9. use App\EventSubscriber\AbstractEmailSubscriber;
  10. use App\Manager\Mailer;
  11. use App\Manager\MailTypeInterface;
  12. use App\Repository\Scp\ContactRepository;
  13. use App\ScpExport\Strategy\IndexUpdateScpExportStrategy;
  14. use Symfony\Contracts\Translation\TranslatorInterface;
  15. use Twig\Environment;
  17. class MeterReadingSubscriber extends AbstractEmailSubscriber
  18. {
  19.     private const ENABLE_CENTER_EMAIL = false;
  21.     protected $contactRepository;
  22.     protected $exportStrategy;
  23.     protected $contractManager;
  25.     public function __construct(
  26.         Mailer $mailer,
  27.         Environment $templating,
  28.         TranslatorInterface $translator,
  29.         ContactRepository $contactRepository,
  30.         IndexUpdateScpExportStrategy $exportStrategy,
  31.         ContractManager $contractManager
  32.     ) {
  33.         parent::__construct($mailer, $templating, $translator);
  34.         $this->contactRepository = $contactRepository;
  35.         $this->exportStrategy = $exportStrategy;
  36.         $this->contractManager = $contractManager;
  37.     }
  39.     public static function getSubscribedEvents(): array
  40.     {
  41.         return [
  42.             IndexUpdatedEvent::class => 'onIndexUpdated',
  43.         ];
  44.     }
  46.     public function onIndexUpdated(IndexUpdatedEvent $event): void
  47.     {
  48.         $index = $event->getIndex();
  49.         $user = $event->getUser();
  50.         $this->sendCustomerEmail($user, $index);
  52.         if (self::ENABLE_CENTER_EMAIL && null !== $index->getPicture()) {
  53.             $this->sendCenterEmail($user, $index);
  54.         }
  55.     }
  57.     protected function sendCenterEmail(User $user, IndexUpdate $index): void
  58.     {
  59.         $technicalContact = $this->contactRepository->findOneByDeliveryStationAndType($index->getStationId(), ContactRepository::TYPE_TECHNICAL, $index->getCustomerNumber());
  60.         if (null === $technicalContact) {
  61.             return;
  62.         }
  63.         $contract = $this->contractManager->getContractByPostNumber($index->getStationId(), $user);
  64.         $reperage = $contract['Reperage'];
  65.         $subject = $this->transEmail('meter_reading.index_updated_center.subject');
  66.         $message = $this->templating->render('email/meter_reading/index_updated_center.html.twig', [
  67.             'customer' => $user,
  68.             'index'    => $index,
  69.             'reperage'    => $reperage,
  70.         ]);
  71.         $picturePath = $this->exportStrategy->getExportPath($index).DIRECTORY_SEPARATOR.$index->getPicture();
  73.         $this->mailer->sendMail(
  74.             [$technicalContact['Email']],
  75.             $subject,
  76.             $message,
  77.             MailTypeInterface::METER_READING_INDEX_UPDATED_SCP,
  78.             [\Swift_Attachment::fromPath($picturePath)]
  79.         );
  80.     }
  82.     protected function sendCustomerEmail(User $user, IndexUpdate $index): void
  83.     {
  84.         $subject = $this->transEmail('meter_reading.index_updated.subject');
  86.         $contract = $this->contractManager->getContractByPostNumber($index->getStationId(), $user);
  87.         $reperage = $contract['Reperage'];
  88.         $message = $this->templating->render('email/meter_reading/index_updated.html.twig', [
  89.             'customer' => $user,
  90.             'index'    => $index,
  91.             'reperage'    => $reperage,
  92.         ]);
  94.         $this->mailer->sendMail([$user->getEmail()], $subject, $message, MailTypeInterface::METER_READING_INDEX_UPDATED_USER);
  95.     }
  96. }