custom/plugins/IwvDatevV6/src/Subscriber/OrderPaymentStateChangeListener.php line 60

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Iwv\IwvDatevV6\Subscriber;
  5. use Iwv\IwvDatevV6\Core\Content\IwvDatevPayment\IwvDatevPaymentDefinition;
  6. use Iwv\IwvDatevV6\Service\VariablesExporterExt\VariablesExporterConfig;
  7. use Iwv\IwvDatevV6\Service\VariablesExporterService;
  8. use Psr\Log\LoggerInterface;
  9. use Shopware\Core\Framework\Context;
  10. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Search\Sorting\FieldSorting;
  13. use Shopware\Core\Framework\Uuid\Uuid;
  14. use Shopware\Core\System\StateMachine\Event\StateMachineStateChangeEvent;
  15. use Shopware\Core\System\SystemConfig\SystemConfigService;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. class OrderPaymentStateChangeListener implements EventSubscriberInterface
  19. {
  20.     /** @var EntityRepositoryInterface */
  21.     private $datevPaymentsRepository;
  23.     /** @var EntityRepositoryInterface */
  24.     private $transactionRepository;
  26.     /** @var VariablesExporterService */
  27.     private $variablesExporterService;
  29.     /** @var SystemConfigService */
  30.     private $systemConfigService;
  32.     /**  @var LoggerInterface $logger */
  33.     private $logger;
  35.     public function __construct(
  36.         EntityRepositoryInterface $datevPaymentsRepository,
  37.         EntityRepositoryInterface $transactionRepository,
  38.         VariablesExporterService $variablesExporterService,
  39.         SystemConfigService $systemConfigService,
  40.         LoggerInterface $logger
  41.     ) {
  42.         $this->datevPaymentsRepository = $datevPaymentsRepository;
  43.         $this->transactionRepository = $transactionRepository;
  44.         $this->variablesExporterService = $variablesExporterService;
  45.         $this->systemConfigService = $systemConfigService;
  46.         $this->logger = $logger;
  47.     }
  49.     public static function getSubscribedEvents(): array
  50.     {
  51.         return [
  52.             'state_machine.order_transaction.state_changed' => 'onOrderPaymentStateChange',
  53.         ];
  54.     }
  56.     /**
  57.      * @param StateMachineStateChangeEvent $event
  58.      * @return void
  59.      */
  60.     public function onOrderPaymentStateChange(StateMachineStateChangeEvent $event): void
  61.     {
  62.         if ($event->getTransitionSide() !== 'state_enter' || !in_array($event->getStateName(), ['paid', 'paid_partially', 'refunded', 'refunded_partially'])) {
  63.             return;
  64.         }
  65.         try {
  66.             $orderTransactionId = $event->getTransition()->getEntityId();
  68.             $criteria = new Criteria([$orderTransactionId]);
  69.             $criteria->addAssociation('order.documents.documentType');
  70.             $criteria->getAssociation('order.documents')->addSorting(new FieldSorting('createdAt', FieldSorting::DESCENDING));
  72.             /** @var \Shopware\Core\Checkout\Order\Aggregate\OrderTransaction\OrderTransactionEntity $orderTransactionDB */
  73.             $orderTransactionDB = $this->transactionRepository
  74.                 ->search($criteria, $event->getContext())
  75.                 ->first();
  77.             /** @var \Shopware\Core\Checkout\Order\OrderEntity $orderDB */
  78.             $orderDB = $orderTransactionDB->getOrder();
  79.             if ($orderDB) {
  80.                 $this->variablesExporterService->loadLatestOrders(new Criteria([$orderDB->getId()]), new VariablesExporterConfig(), $event->getContext());
  81.                 $variables = $this->variablesExporterService->getLatestOrderVariables($orderDB->getId(), []);
  82.                 $timezone = $this->systemConfigService->get('IwvDatevV6.config.exportTimezone', $orderDB->getCurrencyId()) ?: 'Europe/Berlin';
  83.                 $paymentEntryData = [
  84.                     'id' => Uuid::randomHex(),
  85.                     'orderId' => $orderDB->getId(),
  86.                     'orderVersionId' => $orderDB->getVersionId(),
  87.                     'paymentDate' => (new \DateTime)->setTimezone(new \DateTimeZone($timezone))->format('Y-m-d'),
  88.                     'amount' => $orderDB->getAmountTotal() * (in_array($event->getStateName(), ['refunded', 'refunded_partially']) ? -1 : 1),
  89.                     'currencyId' => $orderDB->getCurrencyId(),
  90.                     'paymentMethodId' => $orderTransactionDB->getPaymentMethodId(),
  91.                     'paymentReference' => $variables['{order_transaction_id}'],
  92.                     'isSystem' => true
  93.                 ];
  94.                 $profiles = (array)$this->systemConfigService->get('IwvDatevV6.config.' . ($paymentEntryData['amount'] < 0 ? 'creditNoteProfileDocuments' : 'invoiceProfileDocuments'));
  95.                 if (isset($profiles[0]) && $profiles[0] === 'credit_note,storno') {
  96.                     $profiles = ['credit_note', 'storno'];
  97.                 }
  98.                 foreach ($orderDB->getDocuments() as $documentDB) {
  99.                     if (in_array($documentDB->getDocumentType()->getTechnicalName(), $profiles)) {
  100.                         $paymentEntryData['documentId'] = $documentDB->getId();
  101.                         break 1;
  102.                     }
  103.                 }
  105.                 $event->getContext()->scope(Context::SYSTEM_SCOPE, function (Context $context) use ($paymentEntryData): void {
  106.                     $this->datevPaymentsRepository->create([$paymentEntryData], $context);
  107.                 });
  108.             }
  109.         } catch (\Throwable $ex) {
  110.             $this->logger->error('Error on creating DATEV Payment: ' . $ex->getMessage() . ' ' . basename($ex->getFile()) . ':' . $ex->getLine());
  111.         }
  112.     }
  114. }