custom/plugins/EasyCreditRatenkauf/src/Subscriber/InterestRemover.php line 50

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  4. /*
  5.  * (c) NETZKOLLEKTIV GmbH <kontakt@netzkollektiv.com>
  6.  * For the full copyright and license information, please view the LICENSE
  7.  * file that was distributed with this source code.
  8.  */
  10. namespace Netzkollektiv\EasyCredit\Subscriber;
  12. use Netzkollektiv\EasyCredit\Cart\Processor;
  13. use Doctrine\DBAL\Connection;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. use Shopware\Core\Checkout\Cart\Event\CheckoutOrderPlacedEvent;
  16. use Shopware\Core\Framework\Uuid\Uuid;
  17. use Netzkollektiv\EasyCredit\Api\Storage;
  18. use Netzkollektiv\EasyCredit\Setting\Service\SettingsServiceInterface;
  19. use Psr\Log\LoggerInterface;
  21. class InterestRemover implements EventSubscriberInterface
  22. {
  23.     private SettingsServiceInterface $settings;
  25.     private $connection;
  27.     private Storage $storage;
  29.     private $logger;
  31.     public function __construct(
  32.         SettingsServiceInterface $settingsService,
  33.         Connection $connection,
  34.         Storage $storage,
  35.         LoggerInterface $logger
  36.     ) {
  37.         $this->settings = $settingsService;
  38.         $this->connection = $connection;
  39.         $this->storage = $storage;
  40.         $this->logger = $logger;
  41.     }
  43.     public static function getSubscribedEvents(): array
  44.     {
  45.         return [
  46.             CheckoutOrderPlacedEvent::class => 'removeInterest',
  47.         ];
  48.     }
  50.     public function removeInterest(CheckoutOrderPlacedEvent $event): void
  51.     {
  52.         $order = $event->getOrder();
  54.         $interestLineItem = $order->getLineItems()
  55.             ->filterByType(Processor::LINE_ITEM_TYPE)
  56.             ->first();
  58.         $isEnabled = $this->settings
  59.             ->getSettings($event->getSalesChannelId(), false)
  60.             ->getRemoveInterest();
  62.         if (!$isEnabled || !$interestLineItem) {
  63.             return;
  64.         }
  66.         $this->connection->beginTransaction();
  67.         try {
  68.             $this->connection->executeStatement("
  69.                 UPDATE order_transaction ot
  70.                 INNER JOIN order_line_item ol ON ol.order_id = ot.order_id AND ol.type = 'easycredit-interest'
  71.                     Set ot.amount = JSON_REPLACE(ot.amount,
  72.                         '$.unitPrice', ROUND(json_extract(ot.amount, '$.unitPrice') - ol.total_price, 2),
  73.                         '$.totalPrice', ROUND(json_extract(ot.amount, '$.totalPrice') - ol.total_price, 2)
  74.                     )
  75.                 WHERE ot.order_id = ?;
  76.             ", [
  77.                 Uuid::fromHexToBytes($order->getId())
  78.             ]);
  80.             $this->connection->executeStatement("
  81.                 UPDATE `order` o
  82.                 INNER JOIN order_line_item ol ON ol.order_id = o.id AND ol.type = 'easycredit-interest'
  83.                 Set 
  84.                     o.price = JSON_REPLACE(o.price, 
  85.                         '$.netPrice', ROUND(o.amount_net - ol.total_price, 2),
  86.                         '$.totalPrice', ROUND(o.amount_total - ol.total_price, 2), 
  87.                         '$.positionPrice', ROUND(o.position_price - ol.total_price, 2)
  88.                     )
  89.                 WHERE o.id = ?;
  90.             ", [
  91.                 Uuid::fromHexToBytes($order->getId())
  92.             ]);
  94.             $this->connection->executeStatement("
  95.                 DELETE order_line_item FROM order_line_item
  96.                 INNER JOIN `order` o ON order_line_item.order_id = o.id
  97.                 WHERE 
  98.                     o.id = ?
  99.                     AND order_line_item.type = 'easycredit-interest';
  100.             ", [
  101.                 Uuid::fromHexToBytes($order->getId()),
  102.             ]);
  104.             $this->storage->set('interest_amount', null)->persist();
  105.             $this->connection->commit();
  106.         } catch (\Throwable $e) {
  107.             $this->logger->error($e->getMessage());
  108.             $this->connection->rollBack();
  109.         }
  110.     }
  111. }