FRW-10578: Publish performance improvements (#11653)

FRW-10578 Publish performance improvements.

Author: vol4onok

composer.json

@@ -18,7 +18,7 @@
         "spryker/store": "^1.7.0",
         "spryker/symfony": "^3.0.0",
         "spryker/synchronization": "^0.2.0 || ^1.0.0",
-        "spryker/synchronization-behavior": "^1.0.0",
+        "spryker/synchronization-behavior": "^1.13.0",
         "spryker/synchronization-extension": "^1.0.0",
         "spryker/transfer": "^3.27.0",
         "spryker/url": "^3.3.0",

src/Spryker/Zed/ProductStorage/Business/Storage/ProductAbstractStorageWriter.php

@@ -15,9 +15,12 @@
 use Spryker\Zed\ProductStorage\Dependency\Facade\ProductStorageToStoreFacadeInterface;
 use Spryker\Zed\ProductStorage\Persistence\ProductStorageQueryContainerInterface;
 use Spryker\Zed\ProductStorage\Persistence\ProductStorageRepositoryInterface;
+use Spryker\Zed\Propel\Persistence\BatchProcessor\ActiveRecordBatchProcessorTrait;
 
 class ProductAbstractStorageWriter implements ProductAbstractStorageWriterInterface
 {
+    use ActiveRecordBatchProcessorTrait;
+
     /**
      * @var string
      */
@@ -157,6 +160,7 @@ public function publish(array $productAbstractIds)
         }
 
         $this->storeData($productAbstractLocalizedEntities, $productAbstractStorageEntities);
+        $this->commit();
     }
 
     /**
@@ -169,6 +173,7 @@ public function unpublish(array $productAbstractIds)
         $spyProductStorageEntities = $this->findProductAbstractStorageEntities($productAbstractIds);
 
         $this->deleteProductAbstractStorageEntities($spyProductStorageEntities);
+        $this->commit();
     }
 
     /**
@@ -179,19 +184,19 @@ public function unpublish(array $productAbstractIds)
     protected function deleteProductAbstractStorageEntities(array $productAbstractStorageEntities)
     {
         foreach ($productAbstractStorageEntities as $productAbstractStorageEntity) {
-            $productAbstractStorageEntity->delete();
+            $this->remove($productAbstractStorageEntity);
         }
     }
 
     /**
-     * @param \Orm\Zed\ProductStorage\Persistence\SpyProductAbstractStorage $productAbstractStorage
+     * @param \Orm\Zed\ProductStorage\Persistence\SpyProductAbstractStorage $productAbstractStorageEntity
      *
      * @return void
      */
-    protected function deleteProductAbstractStorageEntity(SpyProductAbstractStorage $productAbstractStorage)
+    protected function deleteProductAbstractStorageEntity(SpyProductAbstractStorage $productAbstractStorageEntity)
     {
-        if (!$productAbstractStorage->isNew()) {
-            $productAbstractStorage->delete();
+        if (!$productAbstractStorageEntity->isNew()) {
+            $this->remove($productAbstractStorageEntity);
         }
     }
 
@@ -397,8 +402,9 @@ protected function storeProductAbstractStorageEntity(
             ->setData($productAbstractStorageTransfer->toArray())
             ->setStore($storeName)
             ->setLocale($localeName)
-            ->setIsSendingToQueue($this->isSendingToQueue)
-            ->save();
+            ->setIsSendingToQueue($this->isSendingToQueue);
+
+        $this->persist($spyProductStorageEntity);
     }
 
     /**

src/Spryker/Zed/ProductStorage/Business/Storage/ProductConcreteStorageWriter.php

@@ -12,9 +12,12 @@
 use Orm\Zed\ProductStorage\Persistence\SpyProductConcreteStorage;
 use Spryker\Zed\ProductStorage\Dependency\Facade\ProductStorageToProductInterface;
 use Spryker\Zed\ProductStorage\Persistence\ProductStorageQueryContainerInterface;
+use Spryker\Zed\Propel\Persistence\BatchProcessor\ActiveRecordBatchProcessorTrait;
 
 class ProductConcreteStorageWriter implements ProductConcreteStorageWriterInterface
 {
+    use ActiveRecordBatchProcessorTrait;
+
     /**
      * @var string
      */
@@ -130,6 +133,7 @@ public function publish(array $productIds)
         }
 
         $this->storeData($productConcreteLocalizedEntities, $productConcreteStorageEntities);
+        $this->commit();
     }
 
     /**
@@ -142,6 +146,7 @@ public function unpublish(array $productIds)
         $productConcreteStorageEntities = $this->findProductConcreteStorageEntities($productIds);
 
         $this->deleteProductConcreteStorageEntities($productConcreteStorageEntities);
+        $this->commit();
     }
 
     /**
@@ -152,7 +157,7 @@ public function unpublish(array $productIds)
     protected function deleteProductConcreteStorageEntities(array $productConcreteStorageEntities)
     {
         foreach ($productConcreteStorageEntities as $productConcreteStorageEntity) {
-            $productConcreteStorageEntity->delete();
+            $this->remove($productConcreteStorageEntity);
         }
     }
 
@@ -164,7 +169,7 @@ protected function deleteProductConcreteStorageEntities(array $productConcreteSt
     protected function deletedProductConcreteSorageEntity(SpyProductConcreteStorage $productConcreteStorageEntity)
     {
         if (!$productConcreteStorageEntity->isNew()) {
-            $productConcreteStorageEntity->delete();
+            $this->remove($productConcreteStorageEntity);
         }
     }
 
@@ -325,8 +330,9 @@ protected function storeProductConcreteStorageEntity(
             ->setFkProduct($productConcreteStorageTransfer->getIdProductConcrete())
             ->setData($productConcreteStorageTransfer->toArray())
             ->setLocale($localeName)
-            ->setIsSendingToQueue($this->isSendingToQueue)
-            ->save();
+            ->setIsSendingToQueue($this->isSendingToQueue);
+
+        $this->persist($productConcreteStorageEntity);
     }
 
     /**