newsupernova/vendor/dotmailer/dotmailer-magento2-extension/Model/Sync/Catalog.php

<?php

namespace Dotdigitalgroup\Email\Model\Sync;

/**
 * Sync account TD for catalog.
 */
class Catalog
{
    /**
     * @var \Dotdigitalgroup\Email\Helper\Data
     */
    private $helper;

    /**
     * @var \Magento\Framework\App\Config\ScopeConfigInterface
     */
    private $scopeConfig;

    /**
     * @var mixed
     */
    private $start;

    /**
     * @var int
     */
    private $countProducts = 0;

    /**
     * @var array
     */
    private $productIds = [];

    /**
     * @var \Dotdigitalgroup\Email\Model\ImporterFactory
     */
    private $importerFactory;

    /**
     * @var \Dotdigitalgroup\Email\Model\Connector\ProductFactory
     */
    private $connectorProductFactory;

    /**
     * @var \Dotdigitalgroup\Email\Model\ResourceModel\Catalog\CollectionFactory
     */
    private $catalogCollectionFactory;

    /**
     * @var \Dotdigitalgroup\Email\Model\ResourceModel\CatalogFactory
     */
    public $catalogResourceFactory;

    /**
     * Catalog constructor.
     *
     * @param \Dotdigitalgroup\Email\Model\ResourceModel\Catalog\CollectionFactory $catalogCollection
     * @param \Dotdigitalgroup\Email\Model\Connector\ProductFactory           $connectorProductFactory
     * @param \Dotdigitalgroup\Email\Model\ImporterFactory                    $importerFactory
     * @param \Dotdigitalgroup\Email\Helper\Data                              $helper
     * @param \Magento\Framework\App\Config\ScopeConfigInterface              $scopeConfig
     * @param \Dotdigitalgroup\Email\Model\ResourceModel\CatalogFactory       $catalogResourceFactory
     */
    public function __construct(
        \Dotdigitalgroup\Email\Model\ResourceModel\Catalog\CollectionFactory $catalogCollection,
        \Dotdigitalgroup\Email\Model\Connector\ProductFactory $connectorProductFactory,
        \Dotdigitalgroup\Email\Model\ImporterFactory $importerFactory,
        \Dotdigitalgroup\Email\Helper\Data $helper,
        \Magento\Framework\App\Config\ScopeConfigInterface $scopeConfig,
        \Dotdigitalgroup\Email\Model\ResourceModel\CatalogFactory $catalogResourceFactory
    ) {
        $this->catalogCollectionFactory = $catalogCollection;
        $this->connectorProductFactory  = $connectorProductFactory;
        $this->importerFactory          = $importerFactory;
        $this->helper                   = $helper;
        $this->scopeConfig              = $scopeConfig;
        $this->catalogResourceFactory   = $catalogResourceFactory;
    }

    /**
     * Catalog sync.
     *
     * @return array
     */
    public function sync()
    {
        $response    = ['success' => true, 'message' => 'Done.'];
        $this->start = microtime(true);

        $enabled = $this->helper->isEnabled();
        $catalogSyncEnabled = $this->helper->isCatalogSyncEnabled();
        //api and catalog sync enabled
        if ($enabled && $catalogSyncEnabled) {
            $this->syncCatalog();
        }

        if ($this->countProducts) {
            $message = '----------- Catalog sync ----------- : ' .
                gmdate('H:i:s', microtime(true) - $this->start) .
                ', Total synced = ' . $this->countProducts;
            $this->helper->log($message);
            $response['message'] = $message;
        }

        return $response;
    }

    /**
     * Export catalog.
     *
     * @param int $storeId
     *
     * @return array|bool
     */
    public function exportCatalog($storeId)
    {
        $connectorProducts = [];
        //all products for export
        $products = $this->getProductsToExport($storeId);
        //get products id's
        try {
            if ($products) {
                $this->productIds = array_merge($this->productIds, $products->getColumnValues('entity_id'));

                foreach ($products as $product) {
                    $product->setStoreId($storeId);
                    $connProduct = $this->connectorProductFactory->create()
                        ->setProduct($product);
                    $connectorProducts[] = $connProduct->expose();
                }
            }
        } catch (\Exception $e) {
            $this->helper->debug((string)$e, []);
        }

        return $connectorProducts;
    }

    /**
     * Export in single.
     *
     * @param int $storeId
     * @param string $collectionName
     * @param int $websiteId
     *
     * @return null
     */
    public function exportInSingle($storeId, $collectionName, $websiteId)
    {
        $productIds = [];
        $products         = $this->getProductsToExport($storeId, true);
        if (! empty($products)) {
            foreach ($products as $product) {
                $connectorProduct = $this->connectorProductFactory->create();
                $product->setStoreId($storeId);
                $connectorProduct->setProduct($product);
                $this->helper->log(
                    '---------- Start catalog single sync ----------'
                );

                //register in queue with importer
                $check = $this->importerFactory->create()
                    ->registerQueue(
                        $collectionName,
                        $connectorProduct->expose(),
                        \Dotdigitalgroup\Email\Model\Importer::MODE_SINGLE,
                        $websiteId
                    );
                if ($check) {
                    $productIds[] = $product->getId();
                } else {
                    $pid = $product->getId();
                    $msg = "Failed to register with IMPORTER. Type(Catalog) / Scope(Single) / Product Ids($pid)";
                    $this->helper->log($msg);
                }
            }
        }

        if (! empty($productIds)) {
            $this->setImported($productIds, true);
            $this->countProducts += count($productIds);
        }
    }

    /**
     * Get product collection to export.
     *
     * @param \Magento\Store\Model\Store|int $store
     * @param bool $modified
     *
     * @return mixed
     */
    public function getProductsToExport($store, $modified = false)
    {
        $limit = $this->helper->getWebsiteConfig(
            \Dotdigitalgroup\Email\Helper\Config::XML_PATH_CONNECTOR_TRANSACTIONAL_DATA_SYNC_LIMIT
        );
        return $this->catalogCollectionFactory->create()
            ->getProductsToExportByStore($store, $limit, $modified);
    }

    /**
     * Set imported in bulk query. If modified true then set modified to null in bulk query.
     *
     * @param array $ids
     * @param bool $modified
     *
     * @return null
     */
    public function setImported($ids, $modified = false)
    {
        $this->catalogResourceFactory->create()
            ->setImportedByIds($ids, $modified);
    }

    /**
     * @return null
     */
    public function syncCatalog()
    {
        try {
            //remove product with product id set and no product
            $this->catalogResourceFactory->create()
                ->removeOrphanProducts();
            $scope = $this->scopeConfig->getValue(
                \Dotdigitalgroup\Email\Helper\Config::XML_PATH_CONNECTOR_SYNC_CATALOG_VALUES
            );

            if ($scope == 1) {
                $this->batchDefaultLevelValues();
            } elseif ($scope == 2) {
                $this->batchStoreLevelValues();
            }
        } catch (\Exception $e) {
            $this->helper->debug((string)$e, []);
        }
    }

    /**
     * Batch default level values for catalog
     */
    private function batchDefaultLevelValues()
    {
        $products = $this->exportCatalog(\Magento\Store\Model\Store::DEFAULT_STORE_ID);
        if (! empty($products)) {
            //register in queue with importer
            $check = $this->importerFactory->create()
                ->registerQueue(
                    'Catalog_Default',
                    $products,
                    \Dotdigitalgroup\Email\Model\Importer::MODE_BULK,
                    \Magento\Store\Model\Store::DEFAULT_STORE_ID
                );

            if ($check) {
                //set imported
                $this->setImported($this->productIds);

                //set number of product imported
                $this->countProducts += count($products);
            } else {
                $pid = implode(",", $this->productIds);
                $msg = "Failed to register with IMPORTER. Type(Catalog) / Scope(Bulk) / Product Ids($pid)";
                $this->helper->log($msg);
            }
        }

        //using single api
        $this->exportInSingle(
            \Magento\Store\Model\Store::DEFAULT_STORE_ID,
            'Catalog_Default',
            \Magento\Store\Model\Store::DEFAULT_STORE_ID
        );
    }

    /**
     * Batch store level values for catalog
     */
    private function batchStoreLevelValues()
    {
        $stores = $this->helper->getStores();

        foreach ($stores as $store) {
            $websiteCode = $store->getWebsite()->getCode();
            $storeCode = $store->getCode();
            $products = $this->exportCatalog($store->getId());
            if (! empty($products)) {
                //register in queue with importer
                $check = $this->importerFactory->create()
                    ->registerQueue(
                        'Catalog_' . $websiteCode . '_'
                        . $storeCode,
                        $products,
                        \Dotdigitalgroup\Email\Model\Importer::MODE_BULK,
                        $store->getWebsiteId()
                    );

                if (! $check) {
                    $pid = implode(",", $this->productIds);
                    $msg = "Failed to register with IMPORTER. Type(Catalog) / Scope(Bulk) / Store($store) 
                            / Product Ids($pid)";
                    $this->helper->log($msg);
                }
            }
            //using single api
            $this->exportInSingle(
                $store->getId(),
                'Catalog_' . $websiteCode . '_' . $storeCode,
                $store->getWebsiteId()
            );
        }

        if (! empty($this->productIds)) {
            //set imported
            $this->setImported(array_unique($this->productIds));

            //set number of product imported
            $this->countProducts += count($this->productIds);
        }
    }
}