MDEE-376: create repository for reading exported orders and extract exporter.

Author: obarcelonap

SalesOrdersDataExporter/Console/Command/ExportOnDemand.php

@@ -22,6 +22,7 @@
 
 /**
  * Command export orders since certain time in the past
+ * @deprecated will be removed
  */
 class ExportOnDemand extends Command
 {

SalesOrdersDataExporter/Model/OnDemandExportOrdersRepository.php

@@ -0,0 +1,69 @@
+<?php
+/**
+ * Copyright © Magento, Inc. All rights reserved.
+ * See COPYING.txt for license details.
+ */
+declare(strict_types=1);
+
+namespace Magento\SalesOrdersDataExporter\Model;
+
+use Generator;
+use Magento\DataExporter\Model\Indexer\FeedIndexMetadata;
+use Magento\Framework\App\ResourceConnection;
+
+class OnDemandExportOrdersRepository
+{
+    private FeedIndexMetadata $metadata;
+    private ResourceConnection $resourceConnection;
+    private BatchIteratorFactory $batchIteratorFactory;
+
+    public function __construct(
+        FeedIndexMetadata    $metadata,
+        ResourceConnection   $resourceConnection,
+        BatchIteratorFactory $batchIteratorFactory
+    ) {
+        $this->metadata = $metadata;
+        $this->resourceConnection = $resourceConnection;
+        $this->batchIteratorFactory = $batchIteratorFactory;
+    }
+
+    public function countOrders(): int
+    {
+        $tableName = $this->resourceConnection->getTableName($this->metadata->getFeedTableName());
+        $connection = $this->resourceConnection->getConnection();
+
+        $select = $connection->select()
+            ->from(
+                ['order' => $tableName],
+                ['count' => 'COUNT(*)']
+            );
+        $row = $connection->fetchRow($select);
+        return $row['count'];
+    }
+
+    public function fetchOrders(int $batchSize = 100): Generator
+    {
+        $tableName = $this->resourceConnection->getTableName($this->metadata->getFeedTableName());
+        $connection = $this->resourceConnection->getConnection();
+
+        $select = $connection->select()
+            ->from(
+                ['order' => $tableName],
+                ['id', 'feed_data']
+            );
+
+        $iterator = $this->batchIteratorFactory->create(
+            [
+                'select' => $select,
+                'batchSize' => $batchSize,
+                'correlationName' => 'order',
+                'rangeField' => 'id',
+                'rangeFieldAlias' => 'id',
+            ]
+        );
+
+        foreach ($iterator as $batchSelect) {
+            yield $connection->fetchAll($batchSelect);
+        }
+    }
+}

SalesOrdersDataExporter/Model/OnDemandOrdersExporter.php

@@ -0,0 +1,58 @@
+<?php
+/**
+ * Copyright © Magento, Inc. All rights reserved.
+ * See COPYING.txt for license details.
+ */
+declare(strict_types=1);
+
+namespace Magento\SalesOrdersDataExporter\Model;
+
+use DateTime;
+use DateTimeInterface;
+use Magento\DataExporter\Model\Indexer\FeedIndexMetadata;
+use Magento\DataExporter\Model\Logging\CommerceDataExportLoggerInterface;
+use Magento\Framework\Console\Cli;
+use Magento\SalesOrdersDataExporter\Console\Command\Link;
+use Magento\SalesOrdersDataExporter\Model\Indexer\DateTimeRangeOrderProcessor;
+use Symfony\Component\Console\Output\NullOutput;
+use Symfony\Component\Console\Output\OutputInterface;
+
+class OnDemandOrdersExporter
+{
+    private CommerceDataExportLoggerInterface $logger;
+    private FeedIndexMetadata $metadata;
+    private DateTimeRangeOrderProcessor $processor;
+    private Link $linkCommand;
+
+    public function __construct(
+        CommerceDataExportLoggerInterface $logger,
+        FeedIndexMetadata                 $metadata,
+        DateTimeRangeOrderProcessor       $processor,
+        Link $linkCommand
+    ) {
+        $this->logger = $logger;
+        $this->metadata = $metadata;
+        $this->processor = $processor;
+        $this->linkCommand = $linkCommand;
+    }
+
+    public function export(DateTime $from, DateTime $to, OutputInterface $output = null): void
+    {
+        $output = $output ?? new NullOutput();
+        $this->ensureAssignedUuids($from, $to, $output);
+        $this->processor->fullReindex($this->metadata, $from, $to);
+    }
+
+    private function ensureAssignedUuids(DateTime $from, DateTime $to, OutputInterface $output): void
+    {
+        $returnCode = $this->linkCommand->prepareForExport(
+            $this->metadata->getBatchSize(),
+            $output,
+            $from->format(DateTimeInterface::W3C),
+            $to->format(DateTimeInterface::W3C)
+        );
+        if ($returnCode != Cli::RETURN_SUCCESS) {
+            $this->logger->error('Command "commerce-data-export:orders:link" failed.');
+        }
+    }
+}