custom/plugins/EnetCredit/src/Subscriber/OrderPlacedSubscriber.php line 41

Open in your IDE?
  1. <?php
  3. namespace EnetCredit\Subscriber;
  5. use Shopware\Core\Checkout\Order\Aggregate\OrderLineItem\OrderLineItemEntity;
  6. use Shopware\Core\Checkout\Order\OrderEvents;
  7. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. class OrderPlacedSubscriber implements EventSubscriberInterface
  13. {
  14.     /** @var EntityRepository $orderRepository */
  15.     private $orderRepository;
  17.     /** @var EntityRepository $customerRepository */
  18.     private $customerRepository;
  20.     /** @var EntityRepository $orderTransactionRepository */
  21.     private $orderTransactionRepository;
  23.     public function __construct(EntityRepository $orderRepository, EntityRepository $orderTransactionRepository, EntityRepository $customerRepository)
  24.     {
  25.         $this->orderRepository = $orderRepository;
  26.         $this->customerRepository = $customerRepository;
  27.         $this->orderTransactionRepository = $orderTransactionRepository;
  28.     }
  31.     public static function getSubscribedEvents()
  32.     {
  33.         return [
  34. //            OrderEvents::ORDER_WRITTEN_EVENT => 'onOrderPlaced',
  35.             // TODO: dieses event nutzen, das triggered wenn der paymentstatus sich ändern
  36.             OrderEvents::ORDER_TRANSACTION_WRITTEN_EVENT => 'onOrderPlaced',
  38.         ];
  39.     }
  40.     // TODO: den bezahlstatus auf true setzen
  41.     public function onOrderPlaced(EntityWrittenEvent $event)
  42.     {
  43.         if ($writeResults = $event->getWriteResults()) {
  44.             $context = $event->getContext();
  46.             if (isset($writeResults[0])) {
  47.                 $payload = $writeResults[0]->getPayload();
  48.                 // check for payload existence
  49.                 // when using PayPal the first statusChange has no stateId in payload
  50.                 if(!isset($payload['stateId'])) {
  51.                     return;
  52.                 }
  53.                 // TODO: get status by technical name, not the id!
  54.                 if($payload['stateId'] !== '5f96feede9e94ffbaa98b60c8dfac558') { // paid
  55.                     return;
  56.                 }
  58.                 $orderEntity = $this->getOrder($payload, $context);
  59.                 $lineItem = $orderEntity->getLineItems();
  60.                 $orderCustomerEntity = $orderEntity->getOrderCustomer();
  62.                 if(count($lineItem->getElements()) > 0) {
  63.                     foreach($lineItem->getElements() as $lineItemEntity) {
  64.                         $product = $lineItemEntity->getProduct();
  65.                         $customFields = $product->getCustomFields();
  67.                         if(isset($customFields['enet_credit_product']) && $customFields['enet_credit_product'] === true) {
  68.                             $bonus = floatval($customFields['enet_credit_bonus']);
  69.                             $quantity = $lineItemEntity->getQuantity();
  70.                             $totalPrice = $lineItemEntity->getTotalPrice();
  71.                             $customerAvailCredit = $this->getCustomerAvailCredit($orderCustomerEntity, $context);
  73.                             $newCreditValue = $totalPrice + ($bonus * $quantity) + $customerAvailCredit;
  75.                             $this->customerRepository->update(
  76.                                 [
  77.                                     [
  78.                                         'id' => $orderCustomerEntity->getCustomerId(),
  79.                                         'customFields' => ['enet_credit_value' => $newCreditValue]
  80.                                     ]
  81.                                 ],
  82.                                 $context
  83.                             );
  84.                         }
  85.                     }
  86.                 }
  87.             }
  88.         }
  89.     }
  92.     private function getCustomerAvailCredit($orderCustomerEntity, $context)
  93.     {
  94.         $orderCustomerId = $orderCustomerEntity->getCustomerId();
  95.         $criteria = new Criteria([$orderCustomerId]);
  97.         $customerEntity = $this->customerRepository->search($criteria, $context)->first();
  98.         $creditValue = $customerEntity->getCustomFields();
  100.         if(isset($creditValue['enet_credit_value']) && $creditValue['enet_credit_value']) {
  101.             return floatval($creditValue['enet_credit_value']);
  102.         }
  103.         return 0;
  104.     }
  106.     private function getOrder($payload, $context)
  107.     {
  108.         $criteria = new Criteria([$payload['id']]);
  109.         $criteria->addAssociation('order');
  110.         $criteria->addAssociation('order.lineItems');
  111.         $criteria->addAssociation('order.lineItems.product');
  112.         $criteria->addAssociation('order.transactions');
  114.         $orderTransactionResult = $this->orderTransactionRepository->search(
  115.             $criteria,
  116.             $context
  117.         );
  119.         return $orderTransactionResult->getElements()[
  120.             array_keys($orderTransactionResult->getElements())[0]
  121.         ]->getOrder();
  122.     }
  123. }