vendor/lnb/shopware6-lnb-review-mail/src/Flow/Action/SendReviewMailAction.php line 42

Open in your IDE?
  1. <?php
  3. namespace Lnb\Shopware6\LnbReviewMail\Flow\Action;
  5. use Psr\Log\LoggerInterface;
  6. use Shopware\Core\Content\Flow\Dispatching\Action\FlowAction;
  7. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  10. use Shopware\Core\Framework\Event\FlowEvent;
  11. use Shopware\Core\Framework\Event\OrderAware;
  13. class SendReviewMailAction extends FlowAction
  14. {
  15.     private EntityRepository $reviewMailRepository;
  17.     private LoggerInterface $logger;
  19.     public function __construct(EntityRepository $reviewMailRepository, LoggerInterface $logger)
  20.     {
  21.         $this->reviewMailRepository = $reviewMailRepository;
  22.         $this->logger = $logger;
  23.     }
  25.     public static function getName(): string
  26.     {
  27.         return 'lnbReviewMail.action.send.review.mail';
  28.     }
  30.     public static function getSubscribedEvents(): array
  31.     {
  32.         return [
  33.             self::getName() => 'handle',
  34.         ];
  35.     }
  37.     public function requirements(): array
  38.     {
  39.         return [OrderAware::class];
  40.     }
  42.     public function handle(FlowEvent $event): void
  43.     {
  44.         if (! $event->getEvent() instanceof OrderAware) {
  45.             return; //flow is not supported
  46.         }
  48.         $orderId = $event->getEvent()->getOrderId();
  50.         $config = $event->getConfig();
  52.         if (! isset($config['days'])) {
  53.             $this->logger->critical(sprintf('Missing required parameter "days" for flow "%s" in action sendReviewMailAction', $event->getEvent()->getName()));
  54.             throw new \InvalidArgumentException('Missing required parameter "days"');
  55.         }
  57.         if (! isset($config['mailTemplateId'])) {
  58.             $this->logger->critical(sprintf('Missing required parameter "mailTemplateId" for flow "%s" in action sendReviewMailAction', $event->getEvent()->getName()));
  59.             throw new \InvalidArgumentException('Missing required parameter "mailTemplateId"');
  60.         }
  62.         if ($this->delayedMailAlreadyExists($orderId)) {
  63.             return;
  64.         }
  66.         try {
  67.             $this->reviewMailRepository->create([
  68.                 [
  69.                     'orderId' => $orderId,
  70.                     'mailTemplateId' => $config['mailTemplateId'],
  71.                     'status' => 'pending',
  72.                     'days' => $config['days'],
  73.                     'dueDate' => $this->getDueDate($config['days']),
  74.                 ],
  75.             ], $event->getContext());
  76.         } catch (\Throwable $e) {
  77.             $this->logger->error('Could not create review mail', [
  78.                 'orderId' => $orderId,
  79.                 'mailTemplateId' => $config['mailTemplateId'],
  80.                 'days' => $config['days'],
  81.                 'dueDate' => $this->getDueDate($config['days']),
  82.                 'error' => $e->getMessage(),
  83.                 'trace' => $e->getTraceAsString(),
  84.             ]);
  85.         }
  86.     }
  88.     private function getDueDate(int $days): \DateTimeInterface
  89.     {
  90.         return (new \DateTime())->modify(sprintf('+%d days', $days));
  91.     }
  93.     private function delayedMailAlreadyExists(string $orderId): bool
  94.     {
  95.         $criteria = new Criteria();
  96.         $criteria->addFilter(new EqualsFilter('orderId', $orderId));
  98.         $result = $this->reviewMailRepository->search($criteria, \Shopware\Core\Framework\Context::createDefaultContext());
  100.         return $result->getTotal() > 0;
  101.     }
  102. }