custom/plugins/WbfkExtensions/src/Subscriber/DocumentEntitySubscriber.php line 32

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace WbfkExtensions\Subscriber;
  7. use Shopware\Core\Framework\Context;
  8. use Shopware\Core\Framework\DataAbstractionLayer\EntityWriteResult;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. use WbfkExtensions\Service\InvoiceStateMachineService;
  13. class DocumentEntitySubscriber implements EventSubscriberInterface
  14. {
  15.     public const INVOICE_DOCUMENT_TYPE_ID = '7ebec1ff1f57459684dd3d040a5f87d1';
  16.     public const STORNO_DOCUMENT_TYPE_ID = '4c7238b29af340cda90b2ba1e084698a';
  18.     public function __construct(
  19.         private readonly InvoiceStateMachineService $invoiceStateMachineService,
  20.     ) {
  21.     }
  24.     public static function getSubscribedEvents(): array
  25.     {
  26.         return [
  27.             'document.written' => 'onDocumentWritten',
  28.         ];
  29.     }
  32.     public function onDocumentWritten(EntityWrittenEvent $event): void
  33.     {
  34.         array_map(function (EntityWriteResult $result) use ($event) {
  35.             if ($result->getOperation() !== EntityWriteResult::OPERATION_INSERT) {
  36.                 return;
  37.             }
  38.             match ($result->getPayload()['documentTypeId']) {
  39.                 self::INVOICE_DOCUMENT_TYPE_ID => $this->setInvoiceStateInvoiced($result, $event->getContext()),
  40.                 self::STORNO_DOCUMENT_TYPE_ID => $this->setInvoiceStateOpen($result, $event->getContext()),
  41.                 default => null,
  42.             };
  43.         }, $event->getWriteResults());
  44.     }
  46.     private function setInvoiceStateInvoiced(EntityWriteResult $result, Context $context): void
  47.     {
  48.         $this->invoiceStateMachineService->invoiceStateTransition(
  49.             $result->getPayload()['orderId'],
  50.             'invoice',
  51.             $context
  52.         );
  53.     }
  55.     private function setInvoiceStateOpen(EntityWriteResult $result, Context $context): void
  56.     {
  57.         $this->invoiceStateMachineService->invoiceStateTransition(
  58.             $result->getPayload()['orderId'],
  59.             'cancel_invoice',
  60.             $context
  61.         );
  62.     }
  63. }