custom/plugins/AgiqonOci/src/Services/DataResolverService.php line 43

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace AgiqonOci\Services;
  5. use AgiqonOci\Models\OciSession;
  6. use Shopware\Core\Checkout\Cart\Cart;
  7. use Shopware\Core\Checkout\Cart\LineItem\LineItemCollection;
  8. use Shopware\Core\Checkout\Cart\Price\Struct\CalculatedPrice;
  9. use Shopware\Core\Content\Product\ProductEntity;
  10. use Shopware\Core\Framework\Context;
  11. use Shopware\Core\Checkout\Cart\LineItem\LineItem;
  12. use Shopware\Core\Framework\DataAbstractionLayer\EntityCollection;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  14. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Search\EntitySearchResult;
  16. use Shopware\Core\System\Currency\CurrencyEntity;
  17. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  18. use Shopware\Core\System\SystemConfig\SystemConfigService;
  19. use Symfony\Component\HttpFoundation\Session\Session;
  20. use Symfony\Component\Security\Core\Exception\SessionUnavailableException;
  22. class DataResolverService
  23. {
  24.     protected ?OciSession $session;
  25.     protected EntityRepository $productRepository;
  26.     protected EntityRepository $currencyRepository;
  27.     protected SystemConfigService $configService;
  28.     protected Cart $cart;
  29.     protected Context $context;
  30.     protected ?array $config;
  31.     protected LineItemCollection $lineItems;
  32.     protected EntitySearchResult $products;
  33.     protected CalculatedPrice $shippingCosts;
  34.     protected $shippingCostsRate;
  35.     protected ?CurrencyEntity $currency;
  38.     public function __construct(Session             $session,
  39.                                 EntityRepository    $productRepository,
  40.                                 EntityRepository    $currencyRepository,
  41.                                 SystemConfigService $configService)
  42.     {
  43.         $this->session = $session->get(OciSession::OCI_SESSION_NAME);
  44.         $this->productRepository = $productRepository;
  45.         $this->currencyRepository = $currencyRepository;
  46.         $this->configService = $configService;
  47.     }
  49.     /**
  50.      * Resolves all needed data for OciSession
  51.      *
  52.      * @param Cart $cart
  53.      * @param Context $context
  54.      */
  55.     public function resolveOciData(Cart $cart, SalesChannelContext $context)
  56.     {
  57.         if (!$this->session) {
  58.             throw new SessionUnavailableException(OciSession::OCI_SESSION_NAME . ' not found!');
  59.         }
  61.         $this->cart = $cart;
  62.         $this->context = $context->getContext();
  63.         $this->setConfig($context->getSalesChannelId());
  64.         $this->setLineItems();
  65.         $this->setProducts();
  66.         $this->setShippingCosts();
  67.         $this->setShippingCostsRate();
  68.         $this->setCurrency();
  69.     }
  71.     public function getSession()
  72.     {
  73.         return $this->session;
  74.     }
  76.     private function setConfig(?string $salesChannelId = null): void
  77.     {
  78.         $this->config = $this->configService->get('AgiqonOci.config', $salesChannelId);
  79.     }
  81.     public function getConfig(): ?array
  82.     {
  83.         return $this->config;
  84.     }
  86.     public function getConfigValue(string $key): string
  87.     {
  88.         return $this->config[$key] ?? '';
  89.     }
  91.     private function setLineItems(): void
  92.     {
  93.         $this->lineItems = $this->cart->getLineItems();
  94.     }
  96.     public function getLineItems()
  97.     {
  98.         return $this->lineItems;
  99.     }
  101.     private function setProducts(): void
  102.     {
  103.         $productIds = [];
  105.         foreach ($this->cart->getLineItems() as $lineItem) {
  106.             if ($lineItem->getType() === LineItem::PRODUCT_LINE_ITEM_TYPE ) {
  107.                 $productIds[] = $lineItem->getReferencedId();
  108.             }
  109.             if($lineItem->getType() === 'customized-products'){
  110.                 $customizedProduct = $lineItem->getChildren()->getElements();
  111.                 $customizedProductID = array_values($customizedProduct)[0]->getReferencedId();
  112.                 $productIds[] = $customizedProductID;
  113.             }
  114.         }
  116.         $criteria = new Criteria($productIds);
  117.         $criteria->addAssociation('tax');
  119.         $this->products = $this->productRepository->search($criteria, $this->context);
  120.     }
  122.     public function getProducts(): ?EntityCollection
  123.     {
  124.         return $this->products;
  125.     }
  127.     public function getProductById($productId): ?ProductEntity
  128.     {
  129.         return $this->products->get($productId);
  130.     }
  132.     private function setShippingCosts()
  133.     {
  134.         $this->shippingCosts = $this->cart->getDeliveries()->getShippingCosts()->sum();
  135.     }
  137.     public function getShippingCosts(): ?CalculatedPrice
  138.     {
  139.         return $this->shippingCosts;
  140.     }
  142.     public function setShippingCostsRate()
  143.     {
  144.        $this->shippingCostsRate = $this->cart->getDeliveries()->getShippingCosts()->getTaxRules()->first() ? $this->cart->getDeliveries()->getShippingCosts()->getTaxRules()->first()->getTaxRate() : 0;
  145.     }
  147.     public function getShippingCostsRate(): float
  148.     {
  149.         return $this->shippingCostsRate;
  150.     }
  152.     private function setCurrency()
  153.     {
  154.         $criteria = new Criteria([$this->context->getCurrencyId()]);
  155.         $this->currency = $this->currencyRepository->search($criteria, $this->context)->first();
  156.     }
  158.     public function getCurrency(): ?CurrencyEntity
  159.     {
  160.         return $this->currency;
  161.     }
  162. }