@@ -26,6 +26,7 @@ use Symfony\Component\Serializer\Normalizer\ObjectNormalizer;

 use Symfony\Component\Serializer\Serializer;

 use Symfony\Component\Serializer\SerializerInterface;

 use vonRotenberg\ShopwareApiBundle\API\Shopware;

+use vonRotenberg\ShopwareApiBundle\Helper\ShopwareMappings;

 use vonRotenberg\WmfgoCevisioBundle\Model\Import\ProductModel;

 class ShopwareImportProductsJob extends AbstractController

@@ -36,9 +37,12 @@ class ShopwareImportProductsJob extends AbstractController

     /** @var SerializerInterface */

     private $serializer;

-    /** @var SerializerInterface */

+    /** @var Shopware */

     private $shopware;

+    /** @var ShopwareMappings */

+    private $mappings;

+

     private $csvContext = [];

     /** @var Finder */

@@ -53,12 +57,13 @@ class ShopwareImportProductsJob extends AbstractController

      */

     private $rdb;

-    public function __construct(Finder $finder, Shopware $shopware, Connection $db, LoggerInterface $logger)

+    public function __construct(Finder $finder, Shopware $shopware, ShopwareMappings $mappings, Connection $db, LoggerInterface $logger)

     {

         $this->finder = $finder;

         $this->db = $db;

         $this->logger = $logger;

         $this->shopware = $shopware;

+        $this->mappings = $mappings;

         $encoder      = [new CsvEncoder()];

         $normalizer   = [new ObjectNormalizer()];

@@ -102,7 +107,149 @@ class ShopwareImportProductsJob extends AbstractController

                 $Product = $this->serializer->denormalize($row,ProductModel::class);

                 $arrData = [

+                    'productNumber' => $Product->getSku(),

                     'taxId' => '018e65c0485071508949c072f8dc18bd',

+                    'stock' => 999999,

+                    'name' => 'vrImport2__'.$Product->getName(),

+                    'active' => (bool) $Product->getPublished(),

+                    'isCloseout' => true,

+                    'purchaseUnit' => (float) $Product->getBaseprice(),

+                    'referenceUnit' => 1,

+                    'unitId' => $this->mappings->getUnitIdByName('Liter')

+                ];

+

+                if ($Product->getEan()) $arrData['ean'] = $Product->getEan();

+                if ($Product->getShipping_weight()) $arrData['weight'] = $Product->getShipping_weight();

+                if ($Product->getBesonderheit()) $arrData['description'] = $Product->getBesonderheit();

+

+                // Custom fields handling

+                $arrCustomFields = [];

+                if (($customFieldVal = $Product->GetJahrgang())) {

+                    $arrCustomFields['custom_wine_attributes_jahrgang'] = $customFieldVal;

+                }

+

+                if (($customFieldVal = $Product->getAlkohol())) {

+                    $arrCustomFields['custom_wine_attributes_alkohol'] = $customFieldVal;

+                }

+

+                if (($customFieldVal = $Product->getSaeure())) {

+                    $arrCustomFields['custom_wine_attributes_saeure'] = $customFieldVal;

+                }

+

+                if (($customFieldVal = $Product->getrestzucker())) {

+                    $arrCustomFields['custom_wine_attributes_restzucker'] = $customFieldVal;

+                }

+

+                if (($customFieldVal = $Product->getZusatz())) {

+                    $arrCustomFields['custom_wine_attributes_zusatz'] = $customFieldVal;

+                }

+

+                if (($customFieldVal = $Product->getAllergene())) {

+                    $arrCustomFields['custom_wine_attributes_allergene'] = $customFieldVal;

+                }

+

+                if (($customFieldVal = $Product->getTrinktemperatur())) {

+                    $arrCustomFields['custom_wine_attributes_trinktemperatur'] = $customFieldVal;

+                }

+

+                if (($customFieldVal = $Product->getSpeiseempfehlung())) {

+                    $arrCustomFields['custom_wine_attributes_speiseempfehlung'] = $customFieldVal;

+                }

+

+                if (stripos($Product->getErzeuger(),'weinmanufaktur')) {

+                    $arrCustomFields['custom_wine_attributes_erzeuger'] = 'WMFGO';

+                }

+

+                if (stripos($Product->getAnbauregion(),'Baden')) {

+                    $arrCustomFields['custom_wine_attributes_anbauregion'] = 'Baden';

+                }

+

+                if (stripos($Product->getUrsprungsland(),'weinmanufaktur')) {

+                    $arrCustomFields['custom_wine_attributes_ursprungsland'] = 'DE';

+                }

+

+                if (count($arrCustomFields))

+                {

+                    $arrData['customFields'] = $arrCustomFields;

+                }

+

+                // Properties handling

+                $arrProperties = [];

+

+                if (

+                    ($propertyVal = $Product->getLage())

+                    && ($propertyGroupId = $this->mappings->getPropertyGroupIdByName('Einzellage')) !== null)

+                {

+                    $arrProperties[] = [

+                        'id' => $this->mappings->getPropertyIdByNameAndGroup($propertyVal,$propertyGroupId, true),

+                        'groupId' => $propertyGroupId,

+                        'name' => $propertyVal

+                    ];

+                }

+

+                if (

+                    ($propertyVal = $Product->getQualitaet())

+                    && ($propertyGroupId = $this->mappings->getPropertyGroupIdByName('Qualität')) !== null

+                    && ($propertyId = $this->mappings->getPropertyIdByNameAndGroup($propertyVal,$propertyGroupId, true)) !== null)

+                {

+                    $arrProperties[] = [

+                        'id' => $propertyId,

+                        'groupId' => $propertyGroupId,

+                        'name' => $propertyVal

+                    ];

+                }

+

+                if (

+                    ($propertyVal = $Product->getFarbe())

+                    && ($propertyGroupId = $this->mappings->getPropertyGroupIdByName('Farbe')) !== null)

+                {

+                    $arrProperties[] = [

+                        'id' => $this->mappings->getPropertyIdByNameAndGroup($propertyVal,$propertyGroupId, true),

+                        'groupId' => $propertyGroupId,

+                        'name' => $propertyVal

+                    ];

+                }

+

+                if (

+                    ($propertyVal = $Product->getGeschmack())

+                    && ($propertyGroupId = $this->mappings->getPropertyGroupIdByName('Geschmack')) !== null)

+                {

+                    $arrProperties[] = [

+                        'id' => $this->mappings->getPropertyIdByNameAndGroup($propertyVal,$propertyGroupId, true),

+                        'groupId' => $propertyGroupId,

+                        'name' => $propertyVal

+                    ];

+                }

+

+                if (

+                    ($propertyVal = $Product->getRebsorte())

+                    && ($propertyGroupId = $this->mappings->getPropertyGroupIdByName('Rebsorte')) !== null)

+                {

+                    $arrProperties[] = [

+                        'id' => $this->mappings->getPropertyIdByNameAndGroup($propertyVal,$propertyGroupId, true),

+                        'groupId' => $propertyGroupId,

+                        'name' => $propertyVal

+                    ];

+                }

+

+                if (

+                    ($propertyVal = $Product->getWeinlinie())

+                    && ($propertyGroupId = $this->mappings->getPropertyGroupIdByName('Weinlinie')) !== null)

+                {

+                    $arrProperties[] = [

+                        'id' => $this->mappings->getPropertyIdByNameAndGroup($propertyVal,$propertyGroupId, true),

+                        'groupId' => $propertyGroupId,

+                        'name' => $propertyVal

+                    ];

+                }

+

+                if (count($arrProperties))

+                {

+                    $arrData['properties'] = $arrProperties;

+                }

+

+

+/*

                     'ean' => $Product->getEan(),

                     'price' => [

                         [

@@ -112,22 +259,29 @@ class ShopwareImportProductsJob extends AbstractController

                             'linked' => true

                         ]

                     ],

-                    'stock' => 9999999,

-                    'name' => 'vrImport__'.$Product->getName(),

                     'customFields' => [

                         'custom_wine_attributes_jahrgang' => $Product->getJahrgang()

+                    ],

+                    'properties' => [

+                        [

+                            'id' => $this->mappings->getPropertyIdByNameAndGroup($Product->getLage(),'Einzellage'),

+                            'groupId' => $this->mappings->getPropertyGroupIdByName('Einzellage'),

+                            'name' => $Product->getLage()

+                        ]

                     ]

                 ];

-

+*/

                 if (!$this->shopware->addOrUpdateProductBySku($Product->getSku(), $arrData))

                 {

                     if ($isCli) $io->error('Could not update/import Product ' . $Product->getSku());

+                    dump($arrData);

                 }

                 if ($isCli)

                 {

                     $io->progressAdvance();

                 }

+                return;

             }

             if ($isCli) $io->progressFinish();

         }