vendor/store.shopware.com/premsindividualoffer6/src/Core/Offer/Storefront/OfferService.php line 718

Open in your IDE?
  1. <?php declare(strict_types=1);
  2. /**
  3.  * PremSoft
  4.  * Copyright © 2020 Premsoft - Sven Mittreiter
  5.  *
  6.  * @copyright  Copyright (c) 2020, premsoft - Sven Mittreiter (http://www.premsoft.de)
  7.  * @author     Sven Mittreiter <info@premsoft.de>
  8.  */
  9. namespace Prems\Plugin\PremsIndividualOffer6\Core\Offer\Storefront;
  11. use Prems\Plugin\PremsIndividualOffer6\Core\Entity\Offer\Aggregate\OfferItem\OfferItemEntity;
  12. use Prems\Plugin\PremsIndividualOffer6\Core\Entity\Offer\OfferDefinition;
  13. use Prems\Plugin\PremsIndividualOffer6\Core\Entity\Offer\OfferEntity;
  14. use Prems\Plugin\PremsIndividualOffer6\Core\Media\MediaService;
  15. use Prems\Plugin\PremsIndividualOffer6\Event\OfferCreatedEvent;
  16. use Prems\Plugin\PremsIndividualOffer6\PremsIndividualOffer6;
  17. use Shopware\Core\Checkout\Cart\Cart;
  18. use Shopware\Core\Checkout\Cart\Error\ErrorCollection;
  19. use Shopware\Core\Checkout\Cart\LineItem\LineItem;
  20. use Shopware\Core\Checkout\Cart\LineItemFactoryHandler\CustomLineItemFactory;
  21. use Shopware\Core\Checkout\Cart\Price\Struct\QuantityPriceDefinition;
  22. use Shopware\Core\Checkout\Cart\SalesChannel\CartService;
  23. use Shopware\Core\Checkout\Customer\CustomerEntity;
  24. use Shopware\Core\Content\Product\Cart\ProductLineItemFactory;
  25. use Shopware\Core\Content\Product\SalesChannel\Detail\AbstractProductDetailRoute;
  26. use Shopware\Core\Content\Product\SalesChannel\SalesChannelProductEntity;
  27. use Shopware\Core\Content\Product\ProductEntity;
  28. use Shopware\Core\Framework\Context;
  29. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  30. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenContainerEvent;
  31. use Shopware\Core\Framework\DataAbstractionLayer\Exception\InconsistentCriteriaIdsException;
  32. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  33. use Shopware\Core\Framework\DataAbstractionLayer\Search\EntitySearchResult;
  34. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\AndFilter;
  35. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  36. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\MultiFilter;
  37. use Shopware\Core\Framework\DataAbstractionLayer\Search\Sorting\FieldSorting;
  38. use Shopware\Core\Framework\Struct\ArrayEntity;
  39. use Shopware\Core\Framework\Uuid\Uuid;
  40. use Shopware\Core\System\NumberRange\ValueGenerator\NumberRangeValueGeneratorInterface;
  41. use Shopware\Core\System\SalesChannel\Entity\SalesChannelRepositoryInterface;
  42. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  43. use Shopware\Core\Checkout\Customer\Aggregate\CustomerGroup\CustomerGroupEntity;
  44. use Symfony\Component\HttpFoundation\Session\Session;
  45. use Symfony\Component\HttpKernel\Exception\NotFoundHttpException;
  46. use Symfony\Component\HttpFoundation\Request;
  47. use Shopware\Core\Framework\Struct\ArrayStruct;
  48. use Symfony\Contracts\EventDispatcher\EventDispatcherInterface;
  50. class OfferService
  51. {
  52.     /**
  53.      * @var EntityRepositoryInterface
  54.      */
  55.     private $offerRepository;
  57.     /**
  58.      * @var EntityRepositoryInterface
  59.      */
  60.     private $offerItemRepository;
  62.     /**
  63.      * @var EntityRepositoryInterface
  64.      */
  65.     private $offerMessageRepository;
  67.     /**
  68.      * @var SalesChannelRepositoryInterface
  69.      */
  70.     private $productRepository;
  72.     /**
  73.      * @var CartService
  74.      */
  75.     private $cartService;
  77.     /**
  78.      * @var NumberRangeValueGeneratorInterface
  79.      */
  80.     private $numberRangeValueGenerator;
  82.     /**
  83.      * @var ProductLineItemFactory
  84.      */
  85.     private $productLineItemFactory;
  87.     /**
  88.      * @var ConfigService
  89.      */
  90.     private $configService;
  92.     /**
  93.      * @var AbstractProductDetailRoute
  94.      */
  95.     private $productLoader;
  97.     /**
  98.      * @var Session $session
  99.      */
  100.     private $session;
  102.     private OfferStateService $offerStateService;
  104.     /** @var MediaService $mediaService */
  105.     private $mediaService;
  106.     private EventDispatcherInterface $eventDispatcher;
  108.     public function __construct(
  109.         EntityRepositoryInterface $offerRepository,
  110.         EntityRepositoryInterface $offerItemRepository,
  111.         EntityRepositoryInterface $offerMessageRepository,
  112.         SalesChannelRepositoryInterface $productRepository,
  113.         CartService $cartService,
  114.         NumberRangeValueGeneratorInterface $numberRangeValueGenerator,
  115.         ProductLineItemFactory $productLineItemFactory,
  116.         ConfigService $configService,
  117.         AbstractProductDetailRoute $productLoader,
  118.         OfferStateService $offerStateService,
  119.         MediaService $mediaService,
  120.         Session $session,
  121.         EventDispatcherInterface $eventDispatcher
  122.     ) {
  123.         $this->offerRepository = $offerRepository;
  124.         $this->offerItemRepository = $offerItemRepository;
  125.         $this->offerMessageRepository = $offerMessageRepository;
  126.         $this->productRepository = $productRepository;
  127.         $this->cartService = $cartService;
  128.         $this->numberRangeValueGenerator = $numberRangeValueGenerator;
  129.         $this->productLineItemFactory = $productLineItemFactory;
  130.         $this->configService = $configService;
  131.         $this->productLoader = $productLoader;
  132.         $this->session = $session;
  133.         $this->offerStateService = $offerStateService;
  134.         $this->mediaService = $mediaService;
  135.         $this->eventDispatcher = $eventDispatcher;
  136.     }
  138.     /**
  139.      * Return all offers for an user
  140.      *
  141.      * @param SalesChannelContext $salesChannelContext
  142.      * @param Request $request
  143.      *
  144.      * @return EntitySearchResult
  145.      *
  146.      * @throws InconsistentCriteriaIdsException
  147.      */
  148.     public function getOffersForUser(SalesChannelContext $salesChannelContext, Request $request)
  149.     {
  150.         $criteria = (new Criteria())
  151.             ->addFilter(new AndFilter([
  152.                 new EqualsFilter('prems_individual_offer.customerId', $salesChannelContext->getCustomer()->getId()),
  153.                 new EqualsFilter('prems_individual_offer.salesChannelId', $salesChannelContext->getSalesChannelId())
  154.             ]))
  155.             ->addAssociation('items')
  156.             ->addAssociation('items.product')
  157.             ->addAssociation('items.product.cover')
  158.             ->addAssociation('items.product.prices')
  159.             ->addSorting(new FieldSorting('createdAt', FieldSorting::DESCENDING));
  161.         $filters = [];
  163.         if ($request->query->get('openRequest')) {
  164.             $filters[] = new EqualsFilter('prems_individual_offer.offered', 0);
  165.         }
  167.         if ($request->query->get('received')) {
  168.             $filters[] = new MultiFilter(
  169.                 MultiFilter::CONNECTION_AND,
  170.                 [
  171.                     new EqualsFilter('prems_individual_offer.offered', 1),
  172.                     new EqualsFilter('prems_individual_offer.accepted', 0),
  173.                     new EqualsFilter('prems_individual_offer.declined', 0)
  174.                 ]
  175.             );
  176.         }
  178.         if ($request->query->get('ordered')) {
  179.             $filters[] = new MultiFilter(
  180.                 MultiFilter::CONNECTION_AND,
  181.                 [
  182.                     new EqualsFilter('prems_individual_offer.offered', 1),
  183.                     new EqualsFilter('prems_individual_offer.accepted', 1),
  184.                     new EqualsFilter('prems_individual_offer.declined', 0)
  185.                 ]
  186.             );
  187.         }
  189.         if ($request->query->get('declined')) {
  190.             $filters[] = new EqualsFilter('prems_individual_offer.declined', 1);
  191.         }
  193.         if (!empty($filters)) {
  194.             $criteria->addFilter(new MultiFilter(MultiFilter::CONNECTION_OR, $filters));
  195.         }
  197.         $offers = $this->offerRepository->search($criteria, $salesChannelContext->getContext());
  199.         if (!empty($offers)) {
  200.             foreach ($offers as $offer) {
  201.                 $currentDate = date('Y-m-d H:i:s');
  202.                 $offerDays = (int) $offer->getOfferDaysValid();
  203.                 $offerDate = date('Y-m-d H:i:s', strtotime($offer->getUpdatedAtDateTime() . " +{$offerDays} day"));
  204.                 if (($offer->getOfferDaysValid() !== null && $offer->getOfferDaysValid() !== '') &&
  205.                     $offer->getUpdatedAtDateTime() !== null &&
  206.                     $offerDate <= $currentDate &&
  207.                     ($offer->isOffered() && !$offer->isAccepted() && !$offer->isDeclined())
  208.                 ) {
  209.                     $offer->setDeclined(true);
  210.                     $this->offerRepository->update([[
  211.                         'id' => $offer->getId(),
  212.                         'declined' => $offer->isDeclined(),
  213.                         'updated_at' => $offer->getUpdatedAtDateTime()
  214.                     ]], $salesChannelContext->getContext());
  215.                 }
  216.             }
  217.         }
  219.         $offers = $this->offerRepository->search($criteria, $salesChannelContext->getContext());
  221.         if (!empty($offers)) {
  222.             foreach ($offers as $offer) {
  223.                 $criteriaMessages = (new Criteria())
  224.                     ->addFilter(new EqualsFilter('prems_individual_offer_messages.offerId', $offer->getId()))
  225.                     ->addFilter(new EqualsFilter('prems_individual_offer_messages.customerId', $salesChannelContext->getCustomer()->getId()))
  226.                     ->addAssociation('user')
  227.                     ->addAssociation('customer')
  228.                     ->addSorting(new FieldSorting('prems_individual_offer_messages.createdAt', FieldSorting::DESCENDING));
  230.                 $messages = $this->offerMessageRepository->search($criteriaMessages, $salesChannelContext->getContext())->getEntities();
  231.                 $offer->setMessages($messages);
  232.             }
  233.         }
  235.         return $offers;
  236.     }
  238.     /**
  239.      * @param Context $context
  240.      */
  241.     public function updateOffersStatus(Context $context)
  242.     {
  243.         $criteria = new Criteria();
  244.         $offers = $this->offerRepository->search($criteria, $context);
  246.         if (!empty($offers)) {
  247.             foreach ($offers as $offer) {
  248.                 $currentDate = date('Y-m-d H:i:s');
  249.                 $offerDays = (int) $offer->getOfferDaysValid();
  250.                 $offerDate = date('Y-m-d H:i:s', strtotime($offer->getUpdatedAtDateTime() . " +{$offerDays} day"));
  251.                 if(($offer->getOfferDaysValid() !== null && $offer->getOfferDaysValid() !== '') &&
  252.                     $offer->getUpdatedAtDateTime() !== null &&
  253.                     $offerDate <= $currentDate &&
  254.                     ($offer->isOffered() && !$offer->isAccepted() && !$offer->isDeclined())
  255.                 ) {
  256.                     $offer->setDeclined(true);
  257.                     $this->offerRepository->update([[
  258.                         'id' => $offer->getId(),
  259.                         'declined' => $offer->isDeclined(),
  260.                         'updated_at' => $offer->getUpdatedAtDateTime()
  261.                     ]], $context);
  262.                 }
  263.             }
  264.         }
  266.         return $offers;
  267.     }
  269.     /**
  270.      * @param CustomerEntity $customer
  271.      * @param Context $context
  272.      * @return int
  273.      */
  274.     public function getOpenRequestCount(CustomerEntity $customer, Context $context)
  275.     {
  276.         $criteria = (new Criteria())
  277.             ->addFilter(new EqualsFilter('prems_individual_offer.customerId', $customer->getId()))
  278.             ->addAssociation('items')
  279.             ->addAssociation('items.product')
  280.             ->addAssociation('items.product.cover')
  281.             ->addAssociation('items.product.prices')
  282.             ->addFilter(new EqualsFilter('prems_individual_offer.offered', 0));
  284.         return $this->offerRepository->search($criteria, $context)->getTotal();
  285.     }
  287.     /**
  288.      * @param CustomerEntity $customer
  289.      * @param Context $context
  290.      * @return int
  291.      */
  292.     public function getReceivedCount(CustomerEntity $customer, Context $context)
  293.     {
  294.         $criteria = (new Criteria())
  295.             ->addFilter(new EqualsFilter('prems_individual_offer.customerId', $customer->getId()))
  296.             ->addAssociation('items')
  297.             ->addAssociation('items.product')
  298.             ->addAssociation('items.product.cover')
  299.             ->addAssociation('items.product.prices')
  300.             ->addFilter(new MultiFilter(
  301.         MultiFilter::CONNECTION_AND,
  302.                 [
  303.                     new EqualsFilter('prems_individual_offer.offered', 1),
  304.                     new EqualsFilter('prems_individual_offer.accepted', 0),
  305.                     new EqualsFilter('prems_individual_offer.declined', 0)
  306.                 ]
  307.             ));
  309.         return $this->offerRepository->search($criteria, $context)->getTotal();
  310.     }
  312.     /**
  313.      * @param CustomerEntity $customer
  314.      * @param Context $context
  315.      * @return int
  316.      */
  317.     public function getOrderedCount(CustomerEntity $customer, Context $context)
  318.     {
  319.         $criteria = (new Criteria())
  320.             ->addFilter(new EqualsFilter('prems_individual_offer.customerId', $customer->getId()))
  321.             ->addAssociation('items')
  322.             ->addAssociation('items.product')
  323.             ->addAssociation('items.product.cover')
  324.             ->addAssociation('items.product.prices')
  325.             ->addFilter(new MultiFilter(
  326.                 MultiFilter::CONNECTION_AND,
  327.                 [
  328.                     new EqualsFilter('prems_individual_offer.offered', 1),
  329.                     new EqualsFilter('prems_individual_offer.accepted', 1),
  330.                     new EqualsFilter('prems_individual_offer.declined', 0)
  331.                 ]
  332.             ));
  334.         return $this->offerRepository->search($criteria, $context)->getTotal();
  335.     }
  337.     /**
  338.      * @param CustomerEntity $customer
  339.      * @param Context $context
  340.      * @return int
  341.      */
  342.     public function getDeclinedCount(CustomerEntity $customer, Context $context)
  343.     {
  344.         $criteria = (new Criteria())
  345.             ->addFilter(new EqualsFilter('prems_individual_offer.customerId', $customer->getId()))
  346.             ->addAssociation('items')
  347.             ->addAssociation('items.product')
  348.             ->addAssociation('items.product.cover')
  349.             ->addAssociation('items.product.prices')
  350.             ->addFilter(new EqualsFilter('prems_individual_offer.declined', 1));
  352.         return $this->offerRepository->search($criteria, $context)->getTotal();
  353.     }
  355.     /**
  356.      * Get on offer by offer ID
  357.      * @param string $offerId
  358.      * @param Context $context
  359.      * @param CustomerEntity|null $customer
  360.      * @return OfferEntity
  361.      */
  362.     public function getOfferById(string $offerId, Context $context, CustomerEntity $customer = null)
  363.     {
  364.         $criteria = new Criteria([ $offerId ]);
  366.         if ($customer) {
  367.             $criteria->addFilter(new EqualsFilter('prems_individual_offer.customerId', $customer->getId()));
  368.         }
  370.         $criteria
  371.             ->addAssociation('items')
  372.             ->addAssociation('items.product')
  373.             ->addAssociation('items.product.prices')
  374.             ->addAssociation('items.product.cover')
  375.             ->addAssociation('customer')
  376.             ->addAssociation('customer.salutation')
  377.             ->addAssociation('customer.defaultBillingAddress')
  378.             ->addAssociation('customer.activeBillingAddress')
  379.             ->addAssociation('customer.defaultBillingAddress.country')
  380.             ->addAssociation('customer.activeBillingAddress.country')
  381.             ->addAssociation('shippingMethod.tax')
  382.             ->addAssociation('currency')
  383.             ->addAssociation('salesChannel.domains')
  384.             ->addAssociation('salesChannel.mailHeaderFooter')
  385.             ->addAssociation('language.locale');
  387.         $offer = $this->offerRepository->search($criteria, $context)->first();
  389.         if ($offer && $customer != null) {
  390.             $criteriaMessages = (new Criteria())
  391.                 ->addFilter(new EqualsFilter('prems_individual_offer_messages.offerId', $offer->getId()))
  392.                 ->addFilter(new EqualsFilter('prems_individual_offer_messages.customerId', $customer->getId()))
  393.                 ->addAssociation('user')
  394.                 ->addAssociation('customer')
  395.                 ->addSorting(new FieldSorting('prems_individual_offer_messages.createdAt', FieldSorting::DESCENDING));
  397.             $messages = $this->offerMessageRepository->search($criteriaMessages, $context)->getEntities();
  398.             $offer->setMessages($messages);
  399.         }
  401.         return $offer;
  402.     }
  404.     /**
  405.      * Get on product by product ID
  406.      * @param string $productId
  407.      * @param Context $context
  408.      * @return ProductEntity
  409.      */
  410.     public function getProductById(string $productId, SalesChannelContext $context)
  411.     {
  412.         $criteria = new Criteria([$productId]);
  413.         $criteria->addAssociation('cover');
  414.         $criteria->addAssociation('prices');
  416.         $product = $this->productRepository->search($criteria, $context)->first();
  418.         return $product;
  419.     }
  421.     /**
  422.      * @param OfferEntity $offer
  423.      * @param ProductEntity $product
  424.      * @param Context $context
  425.      */
  426.     public function addOfferItem(OfferEntity $offer, ProductEntity $product, Context $context)
  427.     {
  428.         $criteria = new Criteria();
  429.         $criteria->addFilter(new EqualsFilter('offerId', $offer->getId()));
  430.         $offerItemsCount = $this->offerItemRepository->search($criteria, $context)->getTotal();
  431.         $oldPrice = $offer->getTaxStatus() == OfferEntity::TAX_STATUS_NET ? $product->getPrice()->first()->getNet() : $product->getPrice()->first()->getGross();
  432.         $price = $offer->getTaxStatus() == OfferEntity::TAX_STATUS_NET ? $product->getPrice()->first()->getNet() : $product->getPrice()->first()->getGross();
  433.         $quantity = 1;
  434.         $data = [
  435.             'oldPrice' =>  $oldPrice,
  436.             'price' => $price,
  437.             'totalPrice' => $price * $quantity,
  438.             'quantity' => $quantity,
  439.             'position' => $offerItemsCount + 1,
  440.             //'lineItem' => \base64_encode(\serialize($product)),
  441.             'itemOption' => null,
  442.             'productId' => $product->getId(),
  443.             'offerId' => $offer->getId(),
  444.             //'itemType' => 'swag-customized-products'
  445.         ];
  447.         return $this->offerItemRepository->create([
  448.             $data
  449.         ], $context);
  450.     }
  452.     /**
  453.      * Get and return items of an offer
  454.      * @param $offerId
  455.      * @param $customerId
  456.      * @param SalesChannelContext $context
  457.      * @return null|\Prems\Plugin\PremsIndividualOffer6\Core\Entity\Offer\Aggregate\OfferItem\OfferItemCollection
  458.      * @throws InconsistentCriteriaIdsException
  459.      */
  460.     public function getItemsFromOffer($offerId, $customerId, SalesChannelContext $context)
  461.     {
  462.         $criteria = new Criteria();
  463.         $criteria->addFilter(new EqualsFilter('id', $offerId))
  464.             ->addFilter(new EqualsFilter('prems_individual_offer.customerId', $customerId))
  465.             ->addAssociation('items')
  466.             ->addAssociation('customer')
  467.             //->addAssociation('items.product.prices')
  468.             /**->addAssociation('items.product')
  469.             ->addAssociation('items.product.cover')
  470.             ->addAssociation('items.product.prices')*/;
  472.         /** @var OfferEntity|null $offer */
  473.         $offer = $this->offerRepository->search($criteria, $context->getContext())->first();
  474.         if (!$offer instanceof OfferEntity) {
  475.             throw new NotFoundHttpException();
  476.         }
  477.         $nestedItems = $offer->getNestedItems();
  479.         $elements = $nestedItems->getElements();
  480.         $productCriteria = new Criteria();
  481.         $productCriteria->addAssociation('options.group');
  483.         /** @var OfferItemEntity $element */
  484.         foreach($elements as $element) {
  485.             $clonedCriteria = clone $productCriteria;
  486.             /** @var SalesChannelProductEntity|null $product */
  487.             if (!$element->getProductId()) {
  488.                 continue;
  489.             }
  490.             $result = $this->productLoader->load($element->getProductId(), new Request(), $context, $clonedCriteria);
  491.             /** @var SalesChannelProductEntity|null $product */
  492.             $product = $result->getProduct();
  493.             if ($product) {
  494.                 $element->setProduct($product);
  495.                 $element->setPriceNet();
  496.             }
  497.         }
  499.         return $nestedItems;
  500.     }
  502.     /**
  503.      * Determine if a offer request is generally allowed (Plugin activated for saleschannel, cart amount high enough)
  504.      * @param SalesChannelContext $context
  505.      *
  506.      * @return bool
  507.      */
  508.     public function isOfferRequestAllowed(SalesChannelContext $context)
  509.     {
  510.         $offerSettings = $this->configService->getConfig($context);
  511.         $settings = $offerSettings->getVars();
  513.         if ($settings['disallowedCustomerGroups'] && is_array($settings['disallowedCustomerGroups'])) {
  514.             $customerGroup = $context->getCurrentCustomerGroup();
  515.             if (in_array($customerGroup->getId(), $settings['disallowedCustomerGroups'])) {
  516.                 return false;
  517.             }
  518.         }
  520.         if ($settings['offerMinValueReached'] == true) {
  521.             return true;
  522.         }
  523.         return false;
  524.     }
  526.     /**
  527.      * Creates an offer request for a customer
  528.      * @param CustomerEntity $customer
  529.      * @param CustomerGroupEntity
  530.      * @param SalesChannelContext $context
  531.      *
  532.      * @throws \Exception
  533.      * @return EntityWrittenContainerEvent
  534.      */
  535.     public function createOfferRequest(CustomerEntity $customer, CustomerGroupEntity $customerGroup, SalesChannelContext $context)
  536.     {
  537.         $items = [];
  538.         $cart = $this->cartService->getCart($context->getToken(), $context);
  539.         $lineItems = $cart->getLineItems()->filter(
  540.             function (LineItem $lineItem) {
  541.                 return in_array($lineItem->getType(), [LineItem::PRODUCT_LINE_ITEM_TYPE, 'customized-products', LineItem::PROMOTION_LINE_ITEM_TYPE]);
  542.             }
  543.         );
  544.         $currencySymbol = $context->getCurrency()->getSymbol();
  546.         if ($lineItems) {
  547.             //echo "<pre>"; print_R($lineItems); echo "</pre>";die();
  548.             $i = 0;
  549.             foreach($lineItems as $lineItem) {
  550.                 $i++;
  551.                 //$products[] = ['id' => $lineItem->getId()];
  553.                 $data = [
  554.                     'productId' => $lineItem->getId(),
  555.                     'oldPrice' => $lineItem->getPrice()->getUnitPrice(),
  556.                     'price' => $lineItem->getPrice()->getUnitPrice(),
  557.                     'totalPrice' => $lineItem->getPrice()->getTotalPrice(),
  558.                     'quantity' => $lineItem->getQuantity(),
  559.                     'position' => $i,
  560.                     'lineItem' => \base64_encode(\serialize($lineItem)),
  561.                 ];
  563.                 // Possibility to use referencedID instead of productId for third party vendors
  564.                 if ($lineItem->hasPayloadValue('prems_individual_offer_use_reference_id_instead_of_product_id')) {
  565.                     $data['productId'] = $lineItem->getReferencedId();
  566.                 }
  567.                 if($lineItem->getType() == LineItem::PROMOTION_LINE_ITEM_TYPE) {
  568.                     $data['productId'] = null;
  569.                     $data['itemType'] = LineItem::PROMOTION_LINE_ITEM_TYPE;
  570.                 }
  571.                 if ($lineItem->getType() == 'customized-products') {
  572.                     $productId = 0;
  573.                     $children = $lineItem->getChildren();
  575.                     $itemOption = [];
  577.                     foreach($children as $child) {
  578.                         if ($child->getType() == LineItem::PRODUCT_LINE_ITEM_TYPE) {
  579.                             $productId = $child->getReferencedId();
  580.                         }
  581.                         if ($child->getType() == 'customized-products-option') {
  582.                             $quantity = '';
  583.                             $price = '';
  584.                             $payloadValue = '';
  586.                             if ($child->getQuantity() > 1) {
  587.                                 $quantity = $child->getQuantity() . ' x ';
  588.                             }
  590.                             if ($child->hasChildren()) {
  591.                                 $subChildren = $child->getChildren();
  593.                                 $optionValues = [];
  594.                                 foreach($subChildren as $subChild) {
  595.                                     if ($subChild->getPrice()->getTotalPrice() > 0) {
  596.                                         $price = ' '.$subChild->getPrice()->getTotalPrice() . ' ' . $currencySymbol;
  597.                                     }
  599.                                     $optionValues[] = $subChild->getLabel();
  600.                                 }
  601.                                 $itemOption[] = $quantity.$child->getLabel() . ' (' . implode('; ', $optionValues) . ')'.$payloadValue.$price;
  602.                             } else {
  603.                                 if ($child->getPrice()->getTotalPrice() > 0) {
  604.                                     $price = ' '.$child->getPrice()->getTotalPrice() . ' ' . $currencySymbol;
  605.                                 }
  606.                                 $payload = $child->getPayload();
  607.                                 if ($payload && array_key_exists('value', $payload) && !is_array($payload['value'])) {
  608.                                     $payloadValue = ': '.$payload['value'];
  609.                                 }
  610.                                 if ($payload && array_key_exists('media', $payload) && is_array($payload['media'])) {
  611.                                     $media = $this->mediaService->getMediaById($payload['media']['0']['mediaId'], $context->getContext());
  612.                                     $payloadValue = ': '.$media->getUrl();
  613.                                 }
  614.                                 $itemOption[] = $quantity.$child->getLabel().$payloadValue.$price ;
  615.                             }
  616.                         }
  617.                     }
  619.                     //$data['itemOption'] = implode('<br>',$itemOption);
  620.                     $data['itemOption'] = json_encode($itemOption);
  621.                     $data['productId'] = $productId;
  622.                     $data['itemType'] = 'swag-customized-products';
  623.                 }
  625.                 $items[] = $data;
  626.             }
  627.         }
  628.         //$this->numberRangeValueGenerator->previewPattern(OfferDefinition::ENTITY_NAME, '{n}', 1);
  630.         if ($customerGroup->getDisplayGross()) {
  631.             $taxStatus = 'gross';
  632.         } else {
  633.             $taxStatus = 'net';
  634.         }
  636.         $cart->setErrors(new ErrorCollection());
  637.         $cart->setData(null);
  639.         $offerId = Uuid::randomHex();
  640.         $offerData =             [
  641.             'id' => $offerId,
  642.             'customerId' => $customer->getId(),
  643.             'taxStatus' => $taxStatus,
  644.             'offerNumber' => $this->numberRangeValueGenerator->getValue(
  645.                 OfferDefinition::ENTITY_NAME,
  646.                 $context->getContext(),
  647.                 $context->getSalesChannel()->getId()
  648.             ),
  649.             'pdfComment' => $this->configService->getConfig($context)->getDefaultPdfComment(),
  650.             'currencyFactor' => $context->getContext()->getCurrencyFactor(),
  651.             'currencyId' => $context->getContext()->getCurrencyId(),
  652.             'languageId' => $context->getContext()->getLanguageId(),
  653.             'salesChannelId' => $context->getSalesChannel()->getId(),
  654.             'cart' => \base64_encode(\serialize($cart)),
  655.             'items' => $items,
  656.         ];
  657.         if ($this->configService->getConfig($context)->getDefaultOfferDaysValid() > 0) {
  658.             $offerData['offer_days_valid'] = (int) $this->configService->getConfig($context)->getDefaultOfferDaysValid();
  659.             $offerData['offerExpiration'] = $this->calculateOfferExpirationDate($offerData['offer_days_valid']);
  660.         }
  662.         $offerCreation = $this->offerRepository->create([
  663.             $offerData
  664.         ], $context->getContext());
  666.         $this->eventDispatcher->dispatch(new OfferCreatedEvent($offerId, $context));
  668.         return $offerCreation;
  669.     }
  671.     /**
  672.      * Determine if an offer is orderable
  673.      * @param OfferEntity $offer
  674.      * @return bool
  675.      */
  676.     public function isOfferOrderable(OfferEntity $offer): bool
  677.     {
  678.         if ($offer->isOffered() && !$offer->isAccepted() && !$offer->isDeclined()) {
  679.             return true;
  680.         }
  681.         return false;
  682.     }
  684.     /**
  685.      * Determine if an offer is declineable
  686.      * @param OfferEntity $offer
  687.      * @return bool
  688.      */
  689.     public function isOfferDeclineable(OfferEntity $offer): bool
  690.     {
  691.         if ($offer->isOffered() && !$offer->isAccepted() && !$offer->isDeclined()) {
  692.             return true;
  693.         }
  694.         return false;
  695.     }
  697.     /**
  698.      * Determine if customer is allowed to access an offer
  699.      * @param OfferEntity $offer
  700.      * @param CustomerEntity $customer
  701.      * @return bool
  702.      */
  703.     public function hasAccessToOffer(OfferEntity $offer, CustomerEntity $customer): bool
  704.     {
  705.         $customerIsOwner = $customer->getId() === $offer->getCustomer()->getId();
  706.         return $customerIsOwner;
  707.     }
  709.     /**
  710.      * Determine if basket is in offer mode and then return offer mode
  711.      * @param SalesChannelContext $context
  712.      * @return string
  713.      */
  714.     public function getOfferMode($context): string
  715.     {
  716.         // compatibility mode for older version with session value. If there is an entry then cancel offer mode.
  717.         // Code will be removed in newer versions
  718.         if ($this->session->has('prems_individual_offer')) {
  719.             $this->session->remove('prems_individual_offer');
  720.             $this->cancelOfferMode($context);
  721.         }
  723.         $cart = $this->cartService->getCart($context->getToken(), $context);
  725.         //echo "<pre>"; print_R($cart->getExtensions()); die();
  727.         if (!$cart->hasExtension('offer_mode_active')) {
  728.             return '';
  729.         }
  730.         $offerMode = $cart->getExtension('offer_mode_active');
  731.         if (!$offerMode || !$offerMode->getId()) {
  732.             return '';
  733.         }
  735.         return $offerMode->getId();
  736.     }
  738.     /**
  739.      * Set flag that basket is in offer mode
  740.      *
  741.      * @param SalesChannelContext $context
  742.      * @param string $offerId
  743.      */
  744.     public function activateOfferMode($context, $offerId):void
  745.     {
  746.         $cart = $this->cartService->getCart($context->getToken(), $context);
  747.         $cart->addExtension(PremsIndividualOffer6::OFFER_MODE_EXTENSION_NAME, new ArrayEntity(['id' => $offerId]));
  748.     }
  750.     /**
  751.      * Set flag that basket is no longer in offer mode
  752.      */
  753.     public function disableOfferMode($context):void
  754.     {
  755.         $cart = $this->cartService->getCart($context->getToken(), $context);
  756.         // compatibility mode for older version with session value.
  757.         if ($cart->hasExtension(PremsIndividualOffer6::OFFER_MODE_EXTENSION_NAME)) {
  758.             $cart->removeExtension(PremsIndividualOffer6::OFFER_MODE_EXTENSION_NAME);
  759.         }
  760.     }
  762.     /**
  763.      * @param SalesChannelContext $context
  764.      */
  765.     public function cancelOfferMode($context): void
  766.     {
  767.         $this->disableOfferMode($context);
  768.         $context->removeState(PremsIndividualOffer6::OFFER_MODE_STATE);
  769.         $this->cartService->deleteCart($context);
  770.     }
  772.     /**
  773.      * Add an offer to basket and set basket to offer mode
  774.      * @param $offer
  775.      * @param SalesChannelContext $context
  776.      */
  777.     public function addOfferToBasket($offer, $context)
  778.     {
  779.         // Empty cart
  780.         $cart = $this->cartService->getCart($context->getToken(), $context);
  781.         $items = $cart->getLineItems();
  782.         foreach($items as $item) {
  783.             $this->cartService->remove($cart, $item->getId(), $context);
  784.         }
  785.         $products = [];
  786.         /** @var OfferItemEntity $item */
  787.         foreach ($offer->getItems() as $item) {
  788.             // Swag Custom Product found?
  789.             if ($item->getItemType() == 'swag-customized-products') {
  790.                 $product = \unserialize(base64_decode((string)$item->getLineItem()));
  791.                 if ($product && $product instanceof LineItem) {
  792.                     $product->setStackable(true);
  793.                     $product->setQuantity($item->getQuantity());
  794.                     $product->setRemovable(false);
  795.                     $product->setStackable(false);
  796.                     $product->addExtension('prems', new ArrayStruct(['originalId' => $item->getId(), 'price' => $product->getPrice()]));
  797.                 } else {
  798.                     continue;
  799.                 }
  800.             } elseif($item->getItemType() == LineItem::PROMOTION_LINE_ITEM_TYPE) {
  801.                 $row = \unserialize(base64_decode((string) $item->getLineItem()));
  802.                 $product = new LineItem(Uuid::randomHex(), LineItem::CUSTOM_LINE_ITEM_TYPE);
  803.                 $product->assign($row->getVars());
  804.                 $product->setType(LineItem::CUSTOM_LINE_ITEM_TYPE);
  805.                 $product->setPriceDefinition(new QuantityPriceDefinition($product->getPrice()->getTotalPrice(), $product->getPrice()->getTaxRules()));
  806.                 $product->setGood(true);
  807.                 $product->setRemovable(false);
  808.                 $product->addExtension('prems', new ArrayStruct(['originalId' => $item->getId(), 'price' => $product->getPrice()]));
  809.             } else {
  810.                 $product = \unserialize(base64_decode((string) $item->getLineItem()));
  811.                 if (!$product || !is_object($product)) {
  812.                     $product = $this->productLineItemFactory->create($item->getProductId());
  813.                 }
  814.                 $product->setStackable(true);
  815.                 $product->setRemovable(false);
  816.                 $product->setQuantity($item->getQuantity());
  817.                 $product->setStackable(false);
  818.                 $product->addExtension('prems', new ArrayStruct(['originalId' => $item->getId(), 'price' => $product->getPrice()]));
  819.             }
  820.             $products[] = $product;
  821.         }
  823.         $this->cartService->add($cart, $products, $context);
  824.     }
  826.     /**
  827.      * Declines an offer
  828.      * @param OfferEntity $offer
  829.      * @param Context $context
  830.      * @param int|null $offer_days_valid
  831.      *
  832.      * @return EntityWrittenContainerEvent
  833.      * @throws \Exception
  834.      */
  835.     public function declineOffer(OfferEntity $offer, Context $context, $offer_days_valid = null)
  836.     {
  837.         $offer->setDeclined(true);
  838.         return $this->offerRepository->update([[
  839.           'id' => $offer->getId(),
  840.           'declined' => $offer->isDeclined(),
  841.           'offer_days_valid' => $offer_days_valid,
  842.           'offerExpiration' => $this->calculateOfferExpirationDate($offer_days_valid, $offer->getUpdatedAt())
  843.         ]], $context);
  844.     }
  846.     /**
  847.      * Accept an offer
  848.      * @param OfferEntity $offer
  849.      * @param Context $context
  850.      *
  851.      * @return EntityWrittenContainerEvent
  852.      */
  853.     public function acceptOffer(OfferEntity $offer, Context $context)
  854.     {
  855.         $offer->setAccepted(true);
  856.         return $this->offerRepository->update([[
  857.             'id' => $offer->getId(),
  858.             'accepted' => $offer->isAccepted()
  859.         ]], $context);
  860.     }
  862.     /**
  863.      * Creates an offer
  864.      * @param OfferEntity $offer
  865.      * @param Context $context
  866.      * @param int|null $offer_days_valid
  867.      *
  868.      * @return EntityWrittenContainerEvent
  869.      * @throws \Exception
  870.      */
  871.     public function createOffer(OfferEntity $offer, Context $context, $offer_days_valid = null)
  872.     {
  873.         $offer->setOffered(true);
  874.         $offer->setAccepted(false);
  875.         $offer->setDeclined(false);
  876.         return $this->offerRepository->update([[
  877.             'id' => $offer->getId(),
  878.             'offered' => $offer->isOffered(),
  879.             'accepted' => $offer->isAccepted(),
  880.             'declined' => $offer->isDeclined(),
  881.             'offer_days_valid' => $offer_days_valid,
  882.             'offerExpiration' => $this->calculateOfferExpirationDate($offer_days_valid, $offer->getUpdatedAt()),
  883.             'admin_updated_at' => date("Y-m-d H:i:s")
  884.         ]], $context);
  885.     }
  887.     /**
  888.      * Change days an offer
  889.      * @param OfferEntity $offer
  890.      * @param Context $context
  891.      * @param int|null $offer_days_valid
  892.      *
  893.      * @return EntityWrittenContainerEvent
  894.      * @throws \Exception
  895.      */
  896.     public function changeOfferDays(OfferEntity $offer, Context $context, $offer_days_valid = null)
  897.     {
  898.         $offer->setOffered(true);
  899.         return $this->offerRepository->update([[
  900.             'id' => $offer->getId(),
  901.             'offer_days_valid' => $offer_days_valid ?? null,
  902.             'offerExpiration' => $this->calculateOfferExpirationDate($offer_days_valid, $offer->getUpdatedAt())
  903.         ]], $context);
  904.     }
  906.     public function setOffered(string $offerId, Context $context): bool
  907.     {
  908.         $this->offerRepository->update([['id' => $offerId, 'offered' => true]], $context);
  910.         return true;
  911.     }
  913.     /**
  914.      * Adds Line items to cart
  915.      * @param Cart $cart
  916.      * @param $items
  917.      * @param SalesChannelContext $context
  918.      * @return Cart
  919.      */
  920.     public function addCartItems(Cart $cart, $items, SalesChannelContext $context): Cart
  921.     {
  922.         $cart = $this->cartService->add($cart, $items, $context);
  923.         return $cart;
  924.     }
  926.     /**
  927.      * @param Cart $cart
  928.      * @param string $id
  929.      * @param SalesChannelContext $context
  930.      * @return Cart
  931.      */
  932.     public function removeCartItem(Cart $cart, string $id, SalesChannelContext $context): Cart
  933.     {
  934.         $cart = $this->cartService->remove($cart, $id, $context);
  935.         return $cart;
  936.     }
  938.     /**
  939.      * @param array $items
  940.      * @param Context $context
  941.      * @return EntityWrittenContainerEvent
  942.      */
  943.     public function updateOfferItems(array $items, Context $context): EntityWrittenContainerEvent
  944.     {
  945.         return $this->offerItemRepository->update($items, $context);
  946.     }
  948.     /**
  949.      * @param $days
  950.      * @param $date
  951.      * @throws \Exception
  952.      * @return \DateTimeImmutable
  953.      */
  954.     public function calculateOfferExpirationDate($days, $date = null): \DateTimeImmutable
  955.     {
  956.         if (!$date) {
  957.             $date = new \DateTimeImmutable(date("Y-m-d H:i:s", time()));
  958.         }
  960.         if (is_string($date)) {
  961.             $date = new \DateTimeImmutable($date);
  962.         }
  964.         $interval = \DateInterval::createFromDateString("{$days} day");
  965.         return $date->add($interval);
  966.     }
  967. }