Merge pull request #50 from pamil/export-product-command

Implement product export command

Author: lchrusciel

README.md

@@ -58,3 +58,9 @@ Usage
 $ app/console akeneo:batch:create-job "Sylake - Akeneo Producer" sylake_akeneo_producer export sylake_akeneo_producer
 $ app/console akeneo:batch:job sylake_akeneo_producer
 ```
+
+You can also export just one product by its SKU by running:
+
+```bash
+$ app/console sylake:producer:export-product PRODUCT_SKU
+```

src/Command/ExportProductCommand.php

@@ -0,0 +1,68 @@
+<?php
+
+namespace Sylake\AkeneoProducerBundle\Command;
+
+use Pim\Component\Catalog\Model\ProductInterface;
+use Pim\Component\Catalog\Query\ProductQueryBuilderFactoryInterface;
+use Sylake\AkeneoProducerBundle\Connector\Projector\ItemProjector;
+use Symfony\Component\Console\Command\Command;
+use Symfony\Component\Console\Input\InputArgument;
+use Symfony\Component\Console\Input\InputInterface;
+use Symfony\Component\Console\Output\OutputInterface;
+
+final class ExportProductCommand extends Command
+{
+    /** @var ProductQueryBuilderFactoryInterface */
+    private $productQueryBuilderFactory;
+
+    /** @var ItemProjector */
+    private $itemProjector;
+
+    /**
+     * @param ProductQueryBuilderFactoryInterface $productQueryBuilderFactory
+     * @param ItemProjector $itemProjector
+     */
+    public function __construct(ProductQueryBuilderFactoryInterface $productQueryBuilderFactory, ItemProjector $itemProjector)
+    {
+        $this->productQueryBuilderFactory = $productQueryBuilderFactory;
+        $this->itemProjector = $itemProjector;
+
+        parent::__construct('sylake:producer:export-product');
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    protected function configure()
+    {
+        $this
+            ->addArgument('sku', InputArgument::REQUIRED)
+        ;
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    protected function execute(InputInterface $input, OutputInterface $output)
+    {
+        $sku = $input->getArgument('sku');
+
+        $productQueryBuilder = $this->productQueryBuilderFactory->create();
+        $productQueryBuilder->addFilter('sku', '=', $sku);
+
+        $products = $productQueryBuilder->execute();
+
+        if (count($products) === 0) {
+            $output->writeln(sprintf('<error>Could not find product with SKU "%s"!</error>', $sku));
+
+            return 1;
+        }
+
+        /** @var ProductInterface $product */
+        foreach ($products as $product) {
+            $output->writeln(sprintf('Exporting product with SKU "%s".', $sku));
+
+            $this->itemProjector->__invoke($product);
+        }
+    }
+}

src/Resources/config/services.xml

@@ -1,6 +1,7 @@
 <?xml version="1.0" encoding="UTF-8" ?>
 <container xmlns="http://symfony.com/schema/dic/services" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://symfony.com/schema/dic/services http://symfony.com/schema/dic/services/services-1.0.xsd">
     <imports>
+        <import resource="services/command.xml" />
         <import resource="services/export.xml" />
         <import resource="services/listener.xml" />
     </imports>

src/Resources/config/services/command.xml

@@ -0,0 +1,11 @@
+<?xml version="1.0" ?>
+
+<container xmlns="http://symfony.com/schema/dic/services" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://symfony.com/schema/dic/services http://symfony.com/schema/dic/services/services-1.0.xsd">
+    <services>
+        <service class="Sylake\AkeneoProducerBundle\Command\ExportProductCommand">
+            <argument type="service" id="pim_catalog.query.product_query_builder_factory" />
+            <argument type="service" id="sylake_akeneo_producer.connector.item_projector" />
+            <tag name="console.command" />
+        </service>
+    </services>
+</container>