src/WellCommerce/Bundle/OrderBundle/EventListener/InvoiceSubscriber.php line 59

Open in your IDE?
  1. <?php
  3. declare(strict_types=0);
  5. /*
  6.  * WellCommerce Foundation
  7.  *
  8.  * This file is part of the WellCommerce package.
  9.  *
  10.  * (c) Adam Piotrowski <adam@wellcommerce.org>, Adrian Potepa <adrian@wellcommerce.org>
  11.  *
  12.  * For the full copyright and license information,
  13.  * please view the LICENSE file that was distributed with this source code.
  14.  */
  16. namespace WellCommerce\Bundle\OrderBundle\EventListener;
  18. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  19. use Symfony\Component\Messenger\Stamp\DelayStamp;
  20. use WellCommerce\Bundle\AppBundle\Entity\Shop;
  21. use WellCommerce\Bundle\CoreBundle\DependencyInjection\AbstractServiceSubscriber;
  22. use WellCommerce\Bundle\CoreBundle\Doctrine\Event\EntityEvent;
  23. use WellCommerce\Bundle\OrderBundle\Entity\Invoice;
  24. use WellCommerce\Bundle\OrderBundle\Service\Invoice\Processor\InvoiceProcessorCollection;
  25. use WellCommerce\Bundle\OrderBundle\Service\Invoice\Processor\InvoiceProcessorInterface;
  26. use WellCommerce\Bundle\OrderBundle\Service\Messenger\InvoiceMessage;
  27. use WellCommerce\Component\Form\Event\FormEvent;
  29. /**
  30.  * Class InvoiceSubscriber
  31.  *
  32.  * @author  Adam Piotrowski <adam@wellcommerce.org>
  33.  */
  34. class InvoiceSubscriber extends AbstractServiceSubscriber implements EventSubscriberInterface
  35. {
  36.     public static function getSubscribedEvents()
  37.     {
  38.         return [
  39.             'admin.shop.pre_form_init' => ['onShopFormAdminInit'],
  40.             'invoice.post_create'      => ['onInvoicePostCreate'],
  41.         ];
  42.     }
  44.     public function onInvoicePostCreate(EntityEvent $entityEvent)
  45.     {
  46.         $invoice = $entityEvent->getEntity();
  47.         if ($invoice instanceof Invoice) {
  48.             $enabled = (bool) $this->getKernel()->getContainer()->getParameter('messenger_invoice_message_enabled');
  49.             $delay   = $this->getKernel()->getContainer()->getParameter('messenger_invoice_message_delay');
  51.             if (true === $enabled) {
  52.                 $this->getMessageBus()->dispatch(new InvoiceMessage($invoice->getId()), [
  53.                     new DelayStamp($delay),
  54.                 ]);
  55.             }
  56.         }
  57.     }
  59.     public function onShopFormAdminInit(FormEvent $event)
  60.     {
  61.         $resource = $event->getResource();
  62.         if ($resource instanceof Shop) {
  63.             $form    = $event->getForm();
  64.             $builder = $event->getFormBuilder();
  66.             $invoiceData = $form->addChild($builder->getElement('nested_fieldset', [
  67.                 'name'  => 'invoice_data',
  68.                 'label' => 'invoice.fieldset.settings',
  69.             ]));
  71.             $invoiceData->addChild($builder->getElement('text_field', [
  72.                 'name'    => 'invoiceMaturity',
  73.                 'label'   => 'invoice.label.maturity',
  74.                 'default' => 7,
  75.             ]));
  77.             $options       = [];
  78.             $processors    = $this->locator->get('invoice_processor.collection');
  79.             $processorKeys = $processors->getKeys();
  81.             /** @var InvoiceProcessorInterface $processor */
  82.             foreach ($processors as $processor) {
  83.                 $processorName           = $processor->getAlias();
  84.                 $options[$processorName] = $processorName;
  85.             }
  87.             $defaultProcessor = reset($processorKeys);
  89.             $invoiceData->addChild($builder->getElement('select', [
  90.                 'name'    => 'invoiceProcessor',
  91.                 'label'   => 'invoice.label.processor',
  92.                 'default' => $defaultProcessor,
  93.                 'options' => $options,
  94.             ]));
  95.         }
  96.     }
  98.     public static function getSubscribedServices()
  99.     {
  100.         return array_merge(parent::getSubscribedServices(), [
  101.             'invoice_processor.collection' => InvoiceProcessorCollection::class,
  102.         ]);
  103.     }
  104. }