custom/plugins/WbfkExtensions/src/Subscriber/LogOrderChanges.php line 39

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace WbfkExtensions\Subscriber;
  7. use Doctrine\DBAL\Connection;
  8. use Doctrine\DBAL\Exception;
  9. use Psr\Log\LoggerInterface;
  10. use Shopware\Core\Checkout\Order\OrderCollection;
  11. use Shopware\Core\Checkout\Order\OrderDefinition;
  12. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Event\BeforeDeleteEvent;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  16. use Shopware\Core\Framework\DataAbstractionLayer\Write\Validation\PreWriteValidationEvent;
  17. use Shopware\Core\System\SystemConfig\SystemConfigService;
  18. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  20. class LogOrderChanges implements EventSubscriberInterface
  21. {
  22.     public function __construct(
  23.         private readonly SystemConfigService $systemConfigService,
  24.         private readonly LoggerInterface $logger,
  25.         private readonly EntityRepositoryInterface $orderRepository,
  26.         private readonly Connection $connection,
  27.     ) {
  28.     }
  30.     public static function getSubscribedEvents(): array
  31.     {
  32.         return [
  33.             // BeforeDeleteEvent::class => 'beforeDelete',
  34.             // OrderEvents::ORDER_WRITTEN_EVENT => 'onOrderWritten',
  35.             PreWriteValidationEvent::class => 'preWriteValidation',
  36.         ];
  37.     }
  39.     public function preWriteValidation(PreWriteValidationEvent $event): void
  40.     {
  41.         if (!$this->systemConfigService->get('WbfkExtensions.config.loggingOrder')) {
  42.             return;
  43.         }
  45.         $ctxExt = $event->getContext()->getExtension(self::class);
  46.         if (isset($ctxExt['allowToOpen']) && $ctxExt['allowToOpen']) {
  47.             return;
  48.         }
  50.         foreach ($event->getCommands() as $command) {
  51.             if ($command->getEntityName() === 'order') {
  52.                 $payloads = $command->getPayload();
  53.                 $exist = $command->getEntityExistence();
  55.                 if ($exist->exists() && isset($payloads['state_id']) && $payloads['state_id'] === hex2bin('d50aa676dd7049a39bbef1dd9ac2fdcb')) {
  56.                     if ($this->getOrderState($command->getPrimaryKey()) === 'd50aa676dd7049a39bbef1dd9ac2fdcb') {
  57.                         // Check old state. If it is also "open" than it is OK
  58.                         return;
  59.                     }
  61.                     $this->logger->error('Prevent Order State to be set to OPEN', [
  62.                         'payloads' => $payloads,
  63.                         '$_SERVER' => $_SERVER,
  64.                         'apache_request_headers' => apache_request_headers(),
  65.                         'stack_trace' => debug_backtrace(DEBUG_BACKTRACE_IGNORE_ARGS),
  66.                     ]);
  67.                     $event->getExceptions()->add(new \Exception('Prevent Order State to be set to OPEN'));
  68.                 }
  69.             }
  70.         }
  71.     }
  73.     private function getOrderState($primaryKeys): ?string
  74.     {
  75.         try {
  76.             $res = $this->connection->executeQuery('SELECT state_id FROM `order` WHERE id = :id and version_id = :version_id', $primaryKeys);
  77.             $retArray = $res->fetchAssociative();
  79.             return bin2hex($retArray['state_id']);
  80.         } catch (Exception|\Doctrine\DBAL\Driver\Exception) {
  81.         }
  83.         return null;
  84.     }
  86.     public function onOrderWritten(EntityWrittenEvent $event): void
  87.     {
  88.         if (!$this->systemConfigService->get('WbfkExtensions.config.loggingOrder')) {
  89.             return;
  90.         }
  92.         $payloads = $event->getPayloads();
  93.         $ids = implode(', ', $event->getIds());
  94.         $this->logger->info('Written: '.$ids, [
  95.             'payloads' => $payloads,
  96.             '$_SERVER' => $_SERVER,
  97.             'apache_request_headers' => apache_request_headers(),
  98.         ]);
  99.     }
  101.     public function beforeDelete(BeforeDeleteEvent $event): void
  102.     {
  103.         if (!$this->systemConfigService->get('WbfkExtensions.config.loggingOrder')) {
  104.             return;
  105.         }
  107.         $context = $event->getContext();
  109.         $ids = $event->getIds(OrderDefinition::ENTITY_NAME);
  111.         if (empty($ids)) {
  112.             return;
  113.         }
  115.         $orderCriteria = new Criteria($ids);
  116.         $orderCriteria->addAssociation('orderCustomer');
  117.         $orderCriteria->addAssociation('billingAddress');
  118.         $orderCriteria->addAssociation('deliveries');
  119.         $orderCriteria->addAssociation('lineItems');
  120.         $orderCriteria->addAssociation('transactions');
  121.         $orderCriteria->addAssociation('tags');
  123.         /** @var OrderCollection $orders */
  124.         $orders = $this->orderRepository->search($orderCriteria, $context);
  126.         $event->addSuccess(function () use ($orders): void {
  127.             $this->logger->alert('Deleted: '.implode(', ', $orders->getIds()), [
  128.                 'orders' => $orders,
  129.                 '$_SERVER' => $_SERVER,
  130.                 'apache_request_headers' => apache_request_headers(),
  131.             ]);
  132.         });
  133.     }
  135. }