MM-35: Fix issue 'Removed special product price won't sync on Magento side' (#58)

Author: alexandr-parkhomenko

src/Marello/Bundle/Magento2Bundle/EventListener/Doctrine/ProductPriceListener.php

@@ -30,26 +30,36 @@ class ProductPriceListener
     /** @var ProductRepository */
     protected $productRepository;
 
+    /** @var array */
+    protected $trackedPriceTypes;
+
     /**
      * @param ProductChangesByChannelStack $productChangesStack
      * @param TrackedSalesChannelProvider $salesChannelProvider
      * @param ProductRepository $productRepository
+     * @param array $trackedPriceTypes
      */
     public function __construct(
         ProductChangesByChannelStack $productChangesStack,
         TrackedSalesChannelProvider $salesChannelProvider,
-        ProductRepository $productRepository
+        ProductRepository $productRepository,
+        array $trackedPriceTypes
     ) {
         $this->productChangesStack = $productChangesStack;
         $this->salesChannelProvider = $salesChannelProvider;
         $this->productRepository = $productRepository;
+        $this->trackedPriceTypes = $trackedPriceTypes;
     }
 
     /**
      * @param OnFlushEventArgs $args
      */
     public function onFlush(OnFlushEventArgs $args)
     {
+        if (empty($this->trackedPriceTypes)) {
+            return;
+        }
+
         if (false === $this->salesChannelProvider->hasTrackedSalesChannels(false)) {
             return;
         }
@@ -78,9 +88,14 @@ protected function loadRemovedAndCreatedEntities(UnitOfWork $unitOfWork): void
         $salesChannelInfoArray = $this->salesChannelProvider->getSalesChannelsInfoArray();
         $currenciesWSChInfos = $this->salesChannelProvider->getTrackedSalesChannelCurrenciesWithSalesChannelInfos();
         foreach ($entities as $entity) {
-            if (($entity instanceof ProductChannelPrice || $entity instanceof ProductPrice) &&
-                $entity->getProduct()->getId() === null) {
-                continue;
+            if ($entity instanceof ProductChannelPrice || $entity instanceof ProductPrice) {
+                if ($entity->getProduct()->getId() === null) {
+                    continue;
+                }
+
+                if (!\in_array($entity->getType()->getName(), $this->trackedPriceTypes, true)) {
+                    continue;
+                }
             }
 
             if ($entity instanceof ProductChannelPrice) {
@@ -112,6 +127,12 @@ protected function loadUpdatedEntities(UnitOfWork $unitOfWork): void
         $salesChannelInfoArray = $this->salesChannelProvider->getSalesChannelsInfoArray();
         $currenciesWSChInfos = $this->salesChannelProvider->getTrackedSalesChannelCurrenciesWithSalesChannelInfos();
         foreach ($entities as $entity) {
+            if ($entity instanceof ProductChannelPrice || $entity instanceof ProductPrice) {
+                if (!\in_array($entity->getType()->getName(), $this->trackedPriceTypes, true)) {
+                    continue;
+                }
+            }
+
             if ($entity instanceof ProductChannelPrice) {
                 $entityChangeSet = $unitOfWork->getEntityChangeSet($entity);
                 if (\array_key_exists(self::PRICE_CHANNEL_FIELD_NAME, $entityChangeSet)) {

src/Marello/Bundle/Magento2Bundle/Resources/config/services.yml

@@ -60,6 +60,9 @@ services:
             - '@marello_magento2.stack.product_changes_by_channel'
             - '@marello_magento2.provider.tracked_sales_channel'
             - '@marello_product.repository.product'
+            -
+                - !php/const Marello\Bundle\PricingBundle\Model\PriceTypeInterface::DEFAULT_PRICE
+                - !php/const Marello\Bundle\PricingBundle\Model\PriceTypeInterface::SPECIAL_PRICE
         tags:
             - { name: doctrine.event_listener, event: onFlush }