Model/Sync/Catalog/StoreCatalogSyncer.php
public function syncByStore($storeId, $websiteId, $limit, $importType)
    {
        $products = $this->exporter->exportCatalog($storeId, $limit);

        $success = $this->importerFactory->create()
            ->registerQueue(
                $importType,
                $products,
                \Dotdigitalgroup\Email\Model\Importer::MODE_BULK,
                $websiteId
            );

        if ($success) {
            return $products;
        } else {
            $pid = implode(",", array_keys($products));
            $msg = "Failed to register with IMPORTER. Type(Catalog) / Scope(Bulk) / Store($storeId) / Product Ids($pid)";
            $this->helper->log($msg);
        }

        return [];
    }
public function syncByStore($storeId, $websiteId, $limit, $importType)
    {
        $products = $this->exporter->exportCatalog($storeId, $limit);

        $success = $this->importerFactory->create()
            ->registerQueue(
                $importType,
                $products,
                \Dotdigitalgroup\Email\Model\Importer::MODE_BULK,
                $websiteId
            );

        if ($success) {
            return $products;
        } else {
            $pid = implode(",", array_keys($products));
            $msg = "Failed to register with IMPORTER. Type(Catalog) / Scope(Bulk) / Store($storeId) / Product Ids($pid)";
            $this->helper->log($msg);
        }

        return [];
    }
public function syncByStore ( $ storeId , $ websiteId , $ limit , $ importType ) { $ products = $ this -> exporter -> exportCatalog ( $ storeId , $ limit ) ; $ success = $ this -> importerFactory -> create ( ) -> registerQueue ( $ importType , $ products , \ Dotdigitalgroup \ Email \ Model \ Importer :: MODE_BULK , $ websiteId ) ; if ( $ success ) { return $ products ; } else { $ pid = implode ( "," , array_keys ( $ products ) ) ; $ msg = "Failed to register with IMPORTER. Type(Catalog) / Scope(Bulk) / Store($storeId) / Product Ids($pid)" ; $ this -> helper -> log ( $ msg ) ; } return [ ] ; }
Sync by store

@param int|null $storeId
@param int $websiteId
@param int $limit
@param string $importType

@return array
Sync by store