custom/plugins/mmeesSlackNotifier/src/Subscriber/orderSubscriber.php line 84

Open in your IDE?
  1. <?php
  2. /**
  3.  * Subscriber to listen to order events
  4.  *
  5.  * @copyright Copyright © 2020 e-mmer. All rights reserved.
  6.  * @author    maurits@e-mmer.nl
  7.  */
  8. declare(strict_types=1);
  10. namespace Mmeester\SlackNotifier\Subscriber;
  12. use Mmeester\SlackNotifier\Entity\Order\OrderRepository;
  13. use Mmeester\SlackNotifier\Helper\CurrencyHelper;
  14. use Mmeester\SlackNotifier\Helper\SettingsHelper;
  15. use Mmeester\SlackNotifier\Helper\SlackHelper;
  17. use Shopware\Core\Checkout\Cart\Event\CheckoutOrderPlacedEvent;
  19. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  20. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  21. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  24. class orderSubscriber implements EventSubscriberInterface
  25. {
  26.     /**
  27.      * @var Client
  28.      */
  29.     private $client;
  31.     /**
  32.      * @var EntityRepositoryInterface
  33.      */
  34.     private $orderRepository;
  36.     /**
  37.      * @var CurrencyHelper
  38.      */
  39.     private $currency;
  41.     /**
  42.      * @var Slack
  43.      */
  44.     private $slack;
  46.     /**
  47.      * @var SettingsHelper
  48.      */
  49.     private $settings;
  51.     /**
  52.      * orderSubscriber constructor.
  53.      *
  54.      * @param OrderRepository $orderRepository
  55.      * @param CurrencyHelper  $currency
  56.      * @param SlackHelper           $slack
  57.      */
  58.     public function __construct(
  59.         OrderRepository $orderRepository,
  60.         CurrencyHelper $currency,
  61.         SlackHelper $slack,
  62.         SettingsHelper $settings
  63.     )
  64.     {
  65.         $this->orderRepository = $orderRepository;
  66.         $this->currency = $currency;
  67.         $this->slack = $slack;
  68.         $this->settings = $settings;
  69.     }
  71.     /**
  72.      * @return array|string[]
  73.      */
  74.     public static function getSubscribedEvents()
  75.     {
  76.         return [
  77.             CheckoutOrderPlacedEvent::class => 'onOrderPlaced'
  78.         ];
  79.     }
  81.     /**
  82.      * @param CheckoutOrderPlacedEvent $event
  83.      */
  84.     public function onOrderPlaced(CheckoutOrderPlacedEvent $event)
  85.     {
  86.         $salesChannelId =  $event->getSalesChannelId();
  88.         if($this->settings->isOrderNotification("orderPlaced", $salesChannelId) === true) {
  89.             $order = $event->getOrder();
  90.             if ($order) {
  91.                 $shipment = null;
  93.                 $customer = $order->getOrderCustomer();
  94.                 $shipments = $order->getDeliveries()->getShippingMethods()->getElements();
  96.                 foreach($shipments as $ship) {
  97.                     $shipment = $ship;
  98.                     break;
  99.                 }
  101.                 $slackItems = "";
  102.                 $items = $order->getLineItems();
  103.                 foreach($items as $item) {
  104.                     $slackItems .= $item->getQuantity(). "x ".$item->getLabel()."\n";
  105.                 }
  107.                 if($shipment !== null) {
  108.                     $slackMsg = [
  109.                         "blocks" => [
  110.                             [
  111.                                 "type" => "section",
  112.                                 "text" => [
  113.                                     "type" => "mrkdwn",
  114.                                     "text" => "*New order (" . $order->getOrderNumber() . ") placed*\nCustomer *" . $customer->getFirstName() . " " . $customer->getLastName() . "* <" . $customer->getEmail() . ">"
  115.                                 ]
  116.                             ],
  117.                             [
  118.                                 "type" => "section",
  119.                                 "fields" => [
  120.                                     [
  121.                                         "type" => "mrkdwn",
  122.                                         "text" => "*Order:*\n" . $slackItems
  123.                                     ],
  124.                                 ]
  125.                             ],
  126.                             [
  127.                                 "type" => "section",
  128.                                 "fields" => [
  129.                                     [
  130.                                         "type" => "mrkdwn",
  131.                                         "text" => "*Total:*\n" . $this->currency->formatForSlack($order->getAmountTotal(),
  132.                                                 'EUR')
  133.                                     ],
  134.                                     [
  135.                                         "type" => "mrkdwn",
  136.                                         "text" => "*Shipment:*\n" . $shipment->getName()
  137.                                     ]
  138.                                 ]
  139.                             ],
  140.                             [
  141.                                 "type" => "actions",
  142.                                 "elements" => [
  143.                                     [
  144.                                         "type" => "button",
  145.                                         "style" => "primary",
  146.                                         "text" => [
  147.                                             "type" => "plain_text",
  148.                                             "text" => "View order"
  149.                                         ],
  150.                                         "url" => "https://" . $_SERVER['SERVER_NAME'] . "/admin#/sw/order/detail/" . $order->getId()
  151.                                     ]
  152.                                 ]
  153.                             ]
  154.                         ]
  155.                     ];
  156.                     $this->slack->sendMessage($slackMsg, $salesChannelId);
  157.                 }
  158.             }
  159.         }
  160.     }
  162. }