src/WellCommerce/Bundle/OrderBundle/EventListener/OrderStatusHistorySubscriber.php line 40

Open in your IDE?
  1. <?php
  3. declare(strict_types=0);
  4. /*
  5.  * WellCommerce Foundation
  6.  *
  7.  * This file is part of the WellCommerce package.
  8.  *
  9.  * (c) Adam Piotrowski <adam@wellcommerce.org>, Adrian Potepa <adrian@wellcommerce.org>
  10.  *
  11.  * For the full copyright and license information,
  12.  * please view the LICENSE file that was distributed with this source code.
  13.  */
  15. namespace WellCommerce\Bundle\OrderBundle\EventListener;
  17. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. use Symfony\Component\Messenger\Stamp\DelayStamp;
  19. use WellCommerce\Bundle\AppBundle\Entity\Client;
  20. use WellCommerce\Bundle\AppBundle\Entity\User;
  21. use WellCommerce\Bundle\CoreBundle\DependencyInjection\AbstractServiceSubscriber;
  22. use WellCommerce\Bundle\CoreBundle\Doctrine\Event\EntityEvent;
  23. use WellCommerce\Bundle\OrderBundle\Entity\OrderStatusHistory;
  24. use WellCommerce\Bundle\OrderBundle\Service\Messenger\OrderReviewMessage;
  26. /**
  27.  * Class OrderStatusHistorySubscriber
  28.  *
  29.  * @author  Adam Piotrowski <adam@wellcommerce.org>
  30.  */
  31. class OrderStatusHistorySubscriber extends AbstractServiceSubscriber implements EventSubscriberInterface
  32. {
  33.     public static function getSubscribedEvents(): array
  34.     {
  35.         return [
  36.             'order_status_history.pre_create' => ['onOrderStatusHistoryPreCreate', 0],
  37.         ];
  38.     }
  40.     public function onOrderStatusHistoryPreCreate(EntityEvent $event)
  41.     {
  42.         $history = $event->getEntity();
  44.         if ($history instanceof OrderStatusHistory) {
  45.             $order   = $history->getOrder();
  46.             $locale  = $order->getLocale();
  47.             $shop    = $order->getShop();
  48.             $status  = $history->getOrderStatus();
  49.             $comment = $history->getComment();
  50.             $user    = $this->getSecurityHelper()->getCurrentAdmin();
  52.             $this->getEntityManager()->getFilters()->enable('locale')->setParameter('locale', $order->getLocale());
  53.             $this->getTranslatorHelper()->forceLocale($locale);
  55.             if ($user instanceof User) {
  56.                 $history->setAuthor($user->getFirstName() . ' ' . $user->getLastName());
  57.             }
  59.             if (empty($comment)) {
  60.                 $history->setComment($status->translate($locale)->getDefaultComment());
  61.             }
  63.             if ($history->isNotify()) {
  64.                 $this->getThemeStorage()->setCurrentTheme($order->getShop()->getTheme());
  65.                 if ($this->getMailerHelper()->isEmailValid($order->getContactDetails()->getEmail())) {
  66.                     $title    = $this->getTranslatorHelper()->trans('order_status_history.email.status_changed');
  67.                     $template = 'WellCommerceOrderBundle:Email:order_status_change.html.twig';
  68.                     $search   = ['%number%', '%id%'];
  69.                     $replace  = [$order->getNumber(), $order->getId()];
  71.                     if (!empty($status->getEmailTitle())) {
  72.                         $title = str_replace($search, $replace, $status->getEmailTitle());
  73.                     }
  75.                     if (!empty($status->translate($locale)->getTranslatedEmailTitle())) {
  76.                         $title = str_replace($search, $replace, $status->translate()->getTranslatedEmailTitle($locale));
  77.                     }
  79.                     if (null !== $status->getEmailTemplate() && '' !== $status->getEmailTemplate()) {
  80.                         $template = 'WellCommerceOrderBundle:Email:' . $status->getEmailTemplate();
  81.                     }
  83.                     $this->getMailerHelper()->sendEmail([
  84.                         'recipient'     => $order->getContactDetails()->getEmail(),
  85.                         'bcc'           => [],
  86.                         'subject'       => $title,
  87.                         'template'      => $template,
  88.                         'locale'        => $order->getLocale(),
  89.                         'parameters'    => [
  90.                             'history' => $history,
  91.                             'order'   => $order,
  92.                             'status'  => $status,
  93.                         ],
  94.                         'configuration' => $shop->getMailerConfiguration(),
  95.                     ]);
  97.                     if ($shop->isBeamsEnabled() && $order->getClient() instanceof Client) {
  98.                         $user    = $order->getClient()->getToken();
  99.                         $users   = [];
  100.                         $users[] = $user;
  102.                         $this->getPusherHelper()->publishToUsers(
  103.                             $users,
  104.                             'Zmiana statusu Twojego zamówienia ' . $order->getNumber(),
  105.                             'Nowy status ' . $status->translate()->getName()
  106.                         );
  107.                     }
  109.                     if (false === $shop->getOrderReviewStatuses()->isEmpty()) {
  110.                         if ($shop->getOrderReviewStatuses()->contains($status)) {
  111.                             $this->getMessageBus()->dispatch(new OrderReviewMessage($order->getId()), [
  112.                                 new DelayStamp(5000),
  113.                             ]);
  114.                         }
  115.                     }
  116.                 }
  117.             }
  119.             $order->setCurrentStatus($history->getOrderStatus());
  120.         }
  121.     }
  122. }