Tests\ShopwarePlugins\Connect\ConnectTestHelper

Complexity

Total Complexity

34

Size/Duplication

Total Lines	459
Duplicated Lines	4.58 %

Coupling/Cohesion

Components	2
Dependencies	14

Importance

Changes

0

<?php
class ConnectTestHelper extends \Enlight_Components_Test_Plugin_TestCase
{
    const IMAGE_PROVIDER_URL = 'http://www.shopware.de/ShopwareCommunityCenter/img/logo.png';

    public function setUp()
    {
        parent::setUp();

        set_error_handler(null);
        set_exception_handler(null);
    }

    /**
     * @return \ShopwarePlugins\Connect\Components\ConnectFactory
     */
    public function getConnectFactory()
    {
        if (!$this->connectFactory) {
            $this->connectFactory = new ConnectFactory();
        }

        return $this->connectFactory;
    }

    /**
     * @return \Shopware\Connect\SDK
     */
    public function getSDK()
    {
        if (!$this->sdk) {
            $this->sdk = $this->getConnectFactory()->createSdk();
        }

        return $this->sdk;
    }

    /**
     * @return int
     */
    public function getConnectProductArticleId($sourceId, $shopId=3)
    {
        $id = Shopware()->Db()->fetchOne(
            'SELECT article_id FROM s_plugin_connect_items WHERE source_id = ? and shop_id =  ? LIMIT 1',
            array($sourceId, $shopId)
        );
        return $id;
    }

    public function getExternalProductSourceId()
    {
        $sql = 'SELECT source_id FROM s_plugin_connect_items WHERE shop_id IS NOT NULL';
        $sourceId = Shopware()->Db()->fetchOne($sql);

        return $sourceId;
    }

    /**
     * @return \ShopwarePlugins\Connect\Components\Helper
     */
    public function getHelper()
    {
        return Shopware()->Plugins()->Backend()->SwagConnect()->getHelper();
    }


    public function callPrivate($class, $method, $args)
    {
        $method = new \ReflectionMethod(
            $class, $method
        );

        $method->setAccessible(true);

        return call_user_func(array($method, 'invoke', $args));
    }

    /**
     * @return ConnectExport
     */
    public function getConnectExport()
    {
        return new ConnectExport(
            $this->getHelper(),
            $this->getSDK(),
            Shopware()->Models(),
            new ProductsAttributesValidator(),
            new Config(Shopware()->Models()),
            new ErrorHandler(),
            Shopware()->Container()->get('events')
        );
    }


    /**
     * @return ImageImport
     */
    public function getImageImport()
    {
        return new ImageImport(
            Shopware()->Models(),
            $this->getHelper(),
            Shopware()->Container()->get('thumbnail_manager'),
            new Logger(Shopware()->Db())
        );
    }

    public function changeCategoryConnectMappingForCategoryTo($categoryId, $mapping)
    {
        $modelManager = Shopware()->Models();
        $categoryRepository = $modelManager->getRepository('Shopware\Models\Category\Category');
        $category = $categoryRepository->find($categoryId);

        if (!$category) {
            $this->fail('Could not find category with ID ' . $categoryId);
        }

        $attribute = $category->getAttribute() ?: new \Shopware\Models\Attribute\Category();
        $attribute->setConnectImportMapping($mapping);
        $attribute->setConnectExportMapping($mapping);
        $category->setAttribute($attribute);
        $attribute->setCategory($category);

        $modelManager->persist($category);
        $modelManager->persist($attribute);

        $modelManager->flush();
    }

    public static function dispatchRpcCall($service, $command, array $args)
    {
        $sdk = Shopware()->Container()->get('ConnectSDK');
        $refl = new \ReflectionObject($sdk);
        $property = $refl->getProperty('dependencies');
        $property->setAccessible(true);
        $deps = $property->getValue($sdk);
        $serviceRegistry = $deps->getServiceRegistry();
        $callable = $serviceRegistry->getService($service, $command);

        return call_user_func_array(array($callable['provider'], $callable['command']), $args);
    }

    protected function getProduct($withImage = false, $withVariantImages = false)
    {
        $purchasePrice = 6.99;
        $offerValidUntil = time() + 1 * 365 * 24 * 60 * 60; // One year
        $number = rand(1, 999999999);
        $product =  new \Shopware\Connect\Struct\Product(array(
            'shopId' => 3,
            'revisionId' => time(),
            'sourceId' => $number,
            'ean' => $number,
            'sku' => 'sku#' . $number,
            'url' => 'http://shopware.de',
            'title' => 'MassImport #'. $number,
            'shortDescription' => 'Ein Produkt aus shopware Connect',
            'longDescription' => 'Ein Produkt aus shopware Connect',
            'additionalDescription' => 'Ein Produkt aus shopware Connect',
            'vendor' => array(
                'url' => 'http://connect.shopware.de/',
                'name' => 'shopware Connect',
                'logo_url' => self::IMAGE_PROVIDER_URL,
                'page_title' => 'shopware Connect title',
                'description' => 'shopware Connect description'
            ),
            'stream' => 'Awesome products',
            'price' => 9.99,
            'purchasePrice' => $purchasePrice,
            'purchasePriceHash' => hash_hmac(
                'sha256',
                sprintf('%.3F %d', $purchasePrice, $offerValidUntil), '54642546-0001-48ee-b4d0-4f54af66d822'
            ),
            'offerValidUntil' => $offerValidUntil,
            'availability' => 100,
            'categories' => array(
                '/bücher' => 'Bücher',
            ),
            'translations' => array(
                'en' => new Translation(array(
                    'title' => 'MassImport #'. $number . ' EN',
                    'longDescription' => 'Ein Produkt aus shopware Connect EN',
                    'shortDescription' => 'Ein Produkt aus shopware Connect short EN',
                    'additionalDescription' => 'Ein Produkt aus shopware Verbinden Sie mit zusätzlicher Beschreibung EN',
                    'url' => 'http://shopware.de',
                ))
            )
        ));

        if ($withImage) {
            $product->images = array(self::IMAGE_PROVIDER_URL . '?' . $number);
        }

        if ($withVariantImages) {
            $product->variantImages = array(self::IMAGE_PROVIDER_URL . '?' . $number . '-variantImage');
        }

        return $product;
    }

    protected function getProperties()
    {
        return array(
            new Property(array(
                'groupName' => 'Nike',
                'comparable' => false,
                'sortMode' => 1,
                'option' => 'color',
                'filterable' => false,
                'value' => 'red'
            )),
            new Property(array(
                'groupName' => 'Nike',
                'comparable' => false,
                'sortMode' => 1,
                'option' => 'size',
                'filterable' => false,
                'value' => 'XXL',
                'valuePosition' => 1
            )),
            new Property(array(
                'groupName' => 'Nike',
                'comparable' => false,
                'sortMode' => 1,
                'option' => 'size',
                'filterable' => false,
                'value' => '3XL'
            ))
        );
    }

    protected function getProducts($number = 10, $withImage = false, $withVariantImages = false)
    {
        $products = array();
        for($i=0; $i<$number; $i++) {
            $products[] = $this->getProduct($withImage, $withVariantImages);
        }
        return $products;
    }

    protected function getVariants()
    {
        $number = $groupId = rand(1, 999999999);
        $color = array(
            array('de' => 'Weiss-Blau' . $number, 'en' => 'White-Blue'),
            array('de' => 'Weiss-Rot' . $number, 'en' => 'White-Red'),
            array('de' => 'Blau-Rot' . $number, 'en' => 'Blue-Red'),
            array('de' => 'Schwarz-Rot' . $number, 'en' => 'Black-Red'),
        );

        $variants = array();
        $mainVariant = $this->getProduct(true);
        $mainVariantColor = array_pop($color);
        $mainVariant->variant['Farbe'] = $mainVariantColor['de'];
        $mainVariant->groupId = $groupId;
        $variants[] = $mainVariant;

        //add translations
        $mainVariant->translations['en']->variantLabels = array(
            'Farbe' => 'Color',
        );
        $mainVariant->translations['en']->variantValues = array(
            $mainVariantColor['de'] => $mainVariantColor['en'],
        );

        for ($i = 0; $i < 4 - 1; $i++) {
            $variant = $this->getProduct(true);
            $variantSourceId = $mainVariant->sourceId . '-' . $i;
            $variant->title = 'MassImport #' . $variantSourceId;
            $variant->sourceId = $variantSourceId;
            $variant->ean = $variantSourceId;
            $variantColor = array_pop($color);
            $variant->variant['Farbe'] = $variantColor['de'];
            $variant->groupId = $groupId;
            $variant->translations = array(
                'en' => new Translation(array(
                    'title' => 'MassImport #' . $variantSourceId . ' EN',
                    'longDescription' => $mainVariant->longDescription . ' EN',
                    'shortDescription' => $mainVariant->shortDescription . ' EN',
                    'variantLabels' => array(
                        'Farbe' => 'Color',
                    ),
                    'variantValues' => array(
                        $variantColor['de'] => $variantColor['en'],
                    ),
                )),
            );

            $variants[] = $variant;
        }

        return $variants;
    }

    public function getLocalArticle()
    {
        $number = rand(1, 999999999);

        $article = new Article();
        $article->fromArray(array(
            'name' => 'LocalArticle #'. $number,
            'active' => true,
        ));
        $tax = Shopware()->Models()->getRepository('Shopware\Models\Tax\Tax')->find(1);
        $article->setTax($tax);

        $supplier = Shopware()->Models()->getRepository('Shopware\Models\Article\Supplier')->find(1);
        $article->setSupplier($supplier);

        Shopware()->Models()->persist($article);
        Shopware()->Models()->flush();

        $mainDetail = new Detail();
        $mainDetail->fromArray(array(
            'number' => $number,
            'inStock' => 30,
            'article' => $article
        ));
        $article->setMainDetail($mainDetail);
        $detailAtrribute = new \Shopware\Models\Attribute\Article();
        $detailAtrribute->fromArray(array(
            'article' => $article,
            'articleDetail' => $mainDetail,
        ));

        /** @var \Shopware\Models\Customer\Group $customerGroup */
        $customerGroup = Shopware()->Models()->getRepository('Shopware\Models\Customer\Group')->findOneByKey('EK');

        $connectAttribute = new Attribute();
        $connectAttribute->fromArray(array(
            'isMainVariant' => true,
            'article' => $article,
            'articleDetail' => $article->getMainDetail(),
            'sourceId' => $article->getId(),
            'category' => '/bücher',
            'fixedPrice' => false,
            'purchasePriceHash' => '',
            'offerValidUntil' => 0,
            'stream' => '',
        ));

        Shopware()->Models()->persist($mainDetail);
        Shopware()->Models()->persist($detailAtrribute);
        Shopware()->Models()->persist($connectAttribute);
        Shopware()->Models()->flush();

        // set price via plain SQL because shopware throws exception
        // undefined index: key when error handler is disabled
        Shopware()->Db()->executeQuery(
            'INSERT INTO `s_articles_prices`(`pricegroup`, `from`, `to`, `articleID`, `articledetailsID`, `price`, `baseprice`)
          VALUES (?, 1, "beliebig", ?, ?, ?, ?)
          ', [$customerGroup->getKey(), $article->getId(), $mainDetail->getId(), 8.99, 3.99]);

        return $article;
    }

    public function getProductToShop()
    {
        $manager = Shopware()->Models();
        return new ProductToShop(
            $this->getHelper(),
            Shopware()->Models(),
            $this->getImageImport(),
            new Config(Shopware()->Models()),
            new VariantConfigurator(
                $manager,
                new PdoProductTranslationsGateway(Shopware()->Db())
            ),
            new MarketplaceGateway($manager),
            new PdoProductTranslationsGateway(Shopware()->Db()),
            new DefaultCategoryResolver(
                $manager,
                $manager->getRepository('Shopware\CustomModels\Connect\RemoteCategory'),
                $manager->getRepository('Shopware\CustomModels\Connect\ProductToRemoteCategory')
            ),
            new PDO(Shopware()->Db()->getConnection()),
            Shopware()->Container()->get('events')
        );
    }

    protected function insertOrUpdateProducts($number, $withImage, $withVariantImages)
    {
        $commands = array();
        foreach ($this->getProducts($number, $withImage, $withVariantImages) as $product) {
            $commands[$product->sourceId] = new \Shopware\Connect\Struct\Change\ToShop\InsertOrUpdate(array(
                'product' => $product,
                'revision' => time(),
            ));
        }

        $this->dispatchRpcCall('products', 'toShop', array(
            $commands
        ));

        return array_keys($commands);
    }

    protected function getRandomUser()
    {
        $user = Shopware()->Db()->fetchRow("SELECT * FROM s_user WHERE id = 1 LIMIT 1");

        $billing = Shopware()->Db()->fetchRow(
            "SELECT * FROM s_user_billingaddress WHERE userID = :id",
            array(':id' => $user['id'])
        );
        $billing['stateID'] = isset($billing['stateId'])?$billing['stateID']:'1';
        $shipping = Shopware()->Db()->fetchRow(
            "SELECT * FROM s_user_shippingaddress WHERE userID = :id",
            array(':id' => $user['id'])
        );
        $shipping['stateID'] = isset($shipping['stateId'])?$shipping['stateID']:'1';
        $country = Shopware()->Db()->fetchRow(
            "SELECT * FROM s_core_countries WHERE id = :id",
            array(':id' => $billing['countryID'])
        );
        $state = Shopware()->Db()->fetchRow(
            "SELECT * FROM s_core_countries_states WHERE id = :id",
            array(':id' => $billing['stateID'])
        );
        $countryShipping = Shopware()->Db()->fetchRow(
            "SELECT * FROM s_core_countries WHERE id = :id",
            array(':id' => $shipping['countryID'])
        );
        $payment = Shopware()->Db()->fetchRow(
            "SELECT * FROM s_core_paymentmeans WHERE id = :id",
            array(':id' => $user['paymentID'])
        );
        $customerGroup = Shopware()->Db()->fetchRow(
            "SELECT * FROM s_core_customergroups WHERE groupkey = :key",
            array(':key' => $user['customergroup'])
        );

        $taxFree = (bool) ($countryShipping['taxfree']);
        if ($countryShipping['taxfree_ustid']) {
            if ($countryShipping['id'] == $country['id'] && $billing['ustid']) {
                $taxFree = true;
            }
        }

        if ($taxFree) {
            $customerGroup['tax'] = 0;
        }

        Shopware()->Session()->sUserGroupData = $customerGroup;

        return array(
            'user' => $user,
            'billingaddress' => $billing,
            'shippingaddress' => $shipping,
            'customerGroup' => $customerGroup,
            'additional' => array(
                'country' => $country,
                'state'   => $state,
                'user'    => $user,
                'countryShipping' => $countryShipping,
                'payment' => $payment,
                'charge_vat' => !$taxFree
            )
        );
    }
}