Shopware_Controllers_Backend_ConnectConfig::getHelper() - Code Metrics - Inspection of "Revert " CON-4896: check if cronPlugin is activate..." - shopware/SwagConnect - Measure and Improve Code Quality continuously with Scrutinizer

Completed
Pull Request — master (#417)

by Jonas
created 2017-11-20 11:58 UTC
getHelper() A

↳ Parent: Shopware_Controllers_Backend_ConnectConfig
Complexity

Conditions	2
Paths	2
Size

Total Lines	8
Code Lines	4
Duplication

Lines	0
Ratio	0 %
Importance

Changes
Metric	Value
dl	0
loc	8
rs	9.4285
c	0
b	0
f	0
cc	2
eloc	4
nc	2
nop	0
<?php
/**
 * (c) shopware AG <[email protected]>
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

use Shopware\Connect\Units;
use ShopwarePlugins\Connect\Components\ConnectExport;
use ShopwarePlugins\Connect\Components\Validator\ProductAttributesValidator\ProductsAttributesValidator;
use ShopwarePlugins\Connect\Components\Utils\UnitMapper;
use ShopwarePlugins\Connect\Components\Logger;
use ShopwarePlugins\Connect\Components\SnHttpClient;
use ShopwarePlugins\Connect\Components\ErrorHandler;
use Shopware\Connect\Gateway\ChangeGateway;
use ShopwarePlugins\Connect\Components\ProductQuery\BaseProductQuery;
use ShopwarePlugins\Connect\Components\ConfigFactory;

/**
 * @category  Shopware
 * @package   Shopware\Plugins\SwagConnect
 * @copyright Copyright (c) 2013, shopware AG (http://www.shopware.de)
 */
class Shopware_Controllers_Backend_ConnectConfig extends Shopware_Controllers_Backend_ExtJs
namespace YourVendor;

class YourClass { }
{
    /** @var \ShopwarePlugins\Connect\Components\Config */
    private $configComponent;

    /**
     * @var \ShopwarePlugins\Connect\Components\ConnectFactory
     */
    private $factory;

    /**
     * @var \ShopwarePlugins\Connect\Components\Utils\UnitMapper
     */
    private $unitMapper;

    /**
     * @var \ShopwarePlugins\Connect\Components\Logger
     */
    private $logger;

    /**
     * @var \Shopware\Components\Model\ModelRepository
     */
    private $customerGroupRepository;

    /**
     * @var \ShopwarePlugins\Connect\Components\PriceGateway
     */
    private $priceGateway;

    /**
     * @var \ShopwarePlugins\Connect\Components\SnHttpClient
     */
    private $snHttpClient;

    /**
     * The getGeneralAction function is an ExtJs event listener method of the
     * connect module. The function is used to load store
     * required in the general config form.
     * @return string
     */
    public function getGeneralAction()
    {
        $generalConfig = $this->getConfigComponent()->getGeneralConfig();

        $this->View()->assign([
            'success' => true,
            'data' => $generalConfig
        ]);
    }

    /**
     * The saveGeneralAction function is an ExtJs event listener method of the
     * connect module. The function is used to save store data.
     * @return string
     */
    public function saveGeneralAction()

    {
        try {
            $data = $this->Request()->getParam('data');
            unset($data['id']);
            $this->getConfigComponent()->setGeneralConfigs($data);

            $this->View()->assign([
                'success' => true
            ]);
        } catch (\Exception $e) {
            $this->View()->assign([
                'success' => false,
                'message' => $e->getMessage()
            ]);
        }
    }

    public function changeLoggingAction()
    {
        try {
            $enableLogging = $this->Request()->getParam('enableLogging');
            $this->getConfigComponent()->setConfig('logRequest', $enableLogging, null, 'general');

            $this->View()->assign([
                'success' => true
            ]);
        } catch (\Exception $e) {
            $this->View()->assign([
                'success' => false,
            ]);
        }
    }

    public function getLoggingEnabledAction()
    {
        $this->View()->assign([
            'success' => true,
            'enableLogging' => $this->getConfigComponent()->getConfig('logRequest', 0),
        ]);
    }

    /**
     * The getImportAction function is an ExtJs event listener method of the
     * connect module. The function is used to load store
     * required in the import config form.
     * @return string
     */
    public function getImportAction()
    {
        $importConfigArray = $this->getConfigComponent()->getImportConfig();

        $this->View()->assign(
            [
                'success' => true,
                'data' => $importConfigArray
            ]
        );
    }

    /**
     * The saveImportAction function is an ExtJs event listener method of the
     * connect module. The function is used to save store data.
     * @return string
     */
    public function saveImportAction()
    {
        $data = $this->Request()->getParam('data');
        $data = !isset($data[0]) ? [$data] : $data;

        $this->getConfigComponent()->setImportConfigs($data);

        $this->View()->assign(
            [
                'success' => true
            ]
        );
    }

    /**
     * The getExportAction function is an ExtJs event listener method of the
     * connect module. The function is used to load store
     * required in the export config form.
     * @return string
     */
    public function getExportAction()
    {
        $exportConfigArray = $this->getConfigComponent()->getExportConfig();
        if (!array_key_exists('exportPriceMode', $exportConfigArray) || $this->isPriceTypeReset()) {
            $exportConfigArray['exportPriceMode'] = [];
        }


        //Resets the exportPriceMode
        if ($this->getSDK()->getPriceType() === \Shopware\Connect\SDK::PRICE_TYPE_NONE) {
            $exportConfigArray['exportPriceMode'] = [];
        }

        if (!array_key_exists(BaseProductQuery::LONG_DESCRIPTION_FIELD, $exportConfigArray)) {
            $exportConfigArray[BaseProductQuery::LONG_DESCRIPTION_FIELD] = true;
        }

        $this->View()->assign(
            [
                'success' => true,
                'data' => $exportConfigArray
            ]
        );
    }

    /**
     * @return bool
     */
    public function isPriceTypeReset()
    {
        return $this->getSDK()->getPriceType() === \Shopware\Connect\SDK::PRICE_TYPE_NONE;
    }

    /**
     * ExtJS uses this action to check is price mapping allowed.
     * If there is at least one exported product to connect,
     * price mapping cannot be changed.
     */
    public function isPricingMappingAllowedAction()
    {
        $isPriceModeEnabled = false;
        $isPurchasePriceModeEnabled = false;
        $isPricingMappingAllowed = $this->isPriceTypeReset();

        if ($isPricingMappingAllowed) {
            $this->View()->assign(
                [
                    'success' => true,
                    'isPricingMappingAllowed' => $isPricingMappingAllowed,
                    'isPriceModeEnabled' => true,
                    'isPurchasePriceModeEnabled' => true,
                ]
            );

            return;
        }

        if ($this->getSDK()->getPriceType() === \Shopware\Connect\SDK::PRICE_TYPE_BOTH
        || $this->getSDK()->getPriceType() === \Shopware\Connect\SDK::PRICE_TYPE_RETAIL) {
            $isPriceModeEnabled = true;
        }

        if ($this->getSDK()->getPriceType() === \Shopware\Connect\SDK::PRICE_TYPE_BOTH
        || $this->getSDK()->getPriceType() === \Shopware\Connect\SDK::PRICE_TYPE_PURCHASE) {
            $isPurchasePriceModeEnabled = true;
        }

        $this->View()->assign(
            [
                'success' => true,
                'isPricingMappingAllowed' => $isPricingMappingAllowed,
                'isPriceModeEnabled' => $isPriceModeEnabled,
                'isPurchasePriceModeEnabled' => $isPurchasePriceModeEnabled,
            ]
        );
    }

    /**
     * The saveExportAction function is an ExtJs event listener method of the
     * connect module. The function is used to save store data.
     * @return string
     */
    public function saveExportAction()
    {
        $data = $this->Request()->getParam('data');
        $exportPrice = in_array('price', $data['exportPriceMode']);
        $exportPurchasePrice = in_array('purchasePrice', $data['exportPriceMode']);

        $isModified = $this->getConfigComponent()->compareExportConfiguration($data);
        $isPriceTypeReset = $this->isPriceTypeReset();

        if ($isModified === false && $this->getSDK()->getPriceType() !== \Shopware\Connect\SDK::PRICE_TYPE_NONE) {
            $data = !isset($data[0]) ? [$data] : $data;
            $this->getConfigComponent()->setExportConfigs($data);
            $this->View()->assign(
                [
                    'success' => true,
                ]
            );

            return;
        }

        if ($exportPrice && $exportPurchasePrice) {
            $priceType = \Shopware\Connect\SDK::PRICE_TYPE_BOTH;
        } elseif ($exportPrice) {
            $priceType = \Shopware\Connect\SDK::PRICE_TYPE_RETAIL;
            unset($data['priceFieldForPurchasePriceExport']);
            unset($data['priceGroupForPurchasePriceExport']);
        } elseif ($exportPurchasePrice) {
            $priceType = \Shopware\Connect\SDK::PRICE_TYPE_PURCHASE;
            unset($data['priceFieldForPriceExport']);
            unset($data['priceGroupForPriceExport']);
        } else {
            $this->View()->assign([
                'success' => false,
                'message' => Shopware()->Snippets()->getNamespace('backend/connect/view/main')->get(
                    'config/export/priceFieldIsNotSupported',
                    'Price field is not maintained. Some of the products have price = 0',
                    true
                )
            ]);

            return;
        }

        if ($priceType == \Shopware\Connect\SDK::PRICE_TYPE_BOTH
            && $data['priceFieldForPurchasePriceExport'] == $data['priceFieldForPriceExport']
            && $data['priceGroupForPurchasePriceExport'] == $data['priceGroupForPriceExport']
        ) {
            $this->View()->assign([
                'success' => false,
                'message' => Shopware()->Snippets()->getNamespace('backend/connect/view/main')->get(
                    'config/export/error/same_price_fields',
                    'Endkunden-VK und Listenverkaufspreis müssen an verschiedene Felder angeschlossen sein',
                    true
                )
            ]);

            return;
        }

        $detailPurchasePrice = method_exists('Shopware\Models\Article\Detail', 'setPurchasePrice');
        if ($exportPurchasePrice && $detailPurchasePrice) {
            $data['priceFieldForPurchasePriceExport'] = 'detailPurchasePrice';
        }

        if ($priceType == \Shopware\Connect\SDK::PRICE_TYPE_BOTH

            || $priceType == \Shopware\Connect\SDK::PRICE_TYPE_RETAIL
        ) {
            /** @var \Shopware\Models\Customer\Group $groupPrice */
            $groupPrice = $this->getCustomerGroupRepository()->findOneBy(['key' => $data['priceGroupForPriceExport']]);
            if (!$groupPrice) {
                $this->View()->assign([
                    'success' => false,
                    'message' => Shopware()->Snippets()->getNamespace('backend/connect/view/main')->get(
                        'config/export/invalid_customer_group',
                        'Ungültige Kundengruppe',
                        true
                    )
                ]);

                return;
            }

            if ($this->getPriceGateway()->countProductsWithConfiguredPrice($groupPrice, $data['priceFieldForPriceExport']) === 0) {
                $this->View()->assign([
                    'success' => false,
                    'message' => Shopware()->Snippets()->getNamespace('backend/connect/view/main')->get(
                        'config/export/priceFieldIsNotSupported',
                        'Price field is not maintained. Some of the products have price = 0',
                        true
                    )
                ]);

                return;
            }
        }

        if ($priceType == \Shopware\Connect\SDK::PRICE_TYPE_BOTH

            || $priceType == \Shopware\Connect\SDK::PRICE_TYPE_PURCHASE
        ) {
            /** @var \Shopware\Models\Customer\Group $groupPurchasePrice */
            $groupPurchasePrice = $this->getCustomerGroupRepository()->findOneBy([
                'key' => $data['priceGroupForPurchasePriceExport']
            ]);
            if (!$groupPurchasePrice && !$detailPurchasePrice) {
                $this->View()->assign([
                    'success' => false,
                    'message' => Shopware()->Snippets()->getNamespace('backend/connect/view/main')->get(
                        'config/export/invalid_customer_group',
                        'Ungültige Kundengruppe',
                        true
                    )
                ]);

                return;
            }

            if ($this->getPriceGateway()->countProductsWithConfiguredPrice($groupPurchasePrice, $data['priceFieldForPurchasePriceExport']) === 0) {
                $this->View()->assign([
                    'success' => false,
                    'message' => Shopware()->Snippets()->getNamespace('backend/connect/view/main')->get(
                        'config/export/priceFieldIsNotSupported',
                        'Price field is not maintained. Some of the products have price = 0',
                        true
                    )
                ]);

                return;
            }
        }

        $connectExport = $this->getConnectExport();

        if ($isPriceTypeReset) {
            //removes all hashes from from sw_connect_product
            //and resets all item status
            $connectExport->clearConnectItems();
        }

        try {
            $data = !isset($data[0]) ? [$data] : $data;
            $response = $this->getSnHttpClient()->sendRequestToConnect(
                'account/settings',
                ['priceType' => $priceType]
            );

            $responseBody = json_decode($response->getBody());
            if (!$responseBody->success) {
                throw new \RuntimeException($responseBody->message);
            }

            $this->getSDK()->verifySdk();
            $this->getConfigComponent()->setExportConfigs($data);

            //todo@sb: check this. Not possible to export all products at the same request.
            $ids = $connectExport->getExportArticlesIds();
            $sourceIds = $this->getHelper()->getArticleSourceIds($ids);
            $errors = $connectExport->export($sourceIds);
        } catch (\RuntimeException $e) {
            $this->getLogger()->write(true, 'Save export settings', $e->getMessage() . $e->getTraceAsString());
            $this->View()->assign([
                    'success' => false,
                    'message' => $e->getMessage()
                ]);

            return;
        }

        if (!empty($errors)) {
            $msg = null;
            foreach ($errors as $type) {
                $msg .= implode("<br>\n", $type);
            }

            $this->View()->assign([
                    'success' => false,
                    'message' => $msg
                ]);

            return;
        }

        $this->View()->assign(
            [
                'success' => true
            ]
        );
    }

    /**
     * @return ConnectExport
     */
    public function getConnectExport()
    {
        return new ConnectExport(
            $this->getHelper(),
            $this->getSDK(),
            $this->getModelManager(),
            new ProductsAttributesValidator(),
            $this->getConfigComponent(),
            new ErrorHandler(),
            $this->container->get('events')
        );
    }

    /**
     * It will make a call to SocialNetwork to reset the price type,
     * if this call return success true, then it will reset the export settings locally
     *
     * @return void
     */
    public function resetPriceTypeAction()
    {
        $response = $this->getSnHttpClient()->sendRequestToConnect('account/reset/price-type');
        $responseBody = json_decode($response->getBody());

        if (!$responseBody->success) {

            $this->View()->assign([
                'success' => false,
                'message' => $responseBody->message
            ]);

            return;
        }

        try {
            $this->resetExportedProducts();
        } catch (\Exception $e) {
            $this->View()->assign([
                'success' => false,
                'message' => $responseBody->message
            ]);

            return;
        }

        $this->View()->assign([
            'success' => true,
        ]);
    }

    /**
     * It will make a call to SocialNetwork to reset the exchange settings,
     * if this call return success true, then it will reset the export settings locally
     *
     * @return void
     */
    public function resetExchangeSettingsAction()
    {
        $response = $this->getSnHttpClient()->sendRequestToConnect('account/reset/exchange-settings');

        $responseBody = json_decode($response->getBody());

        if (!$responseBody->success) {

            $this->View()->assign([
                'success' => false,
                'message' => $responseBody->message
            ]);

            return;
        }

        try {
            $this->resetExportedProducts();

            //remove the existing api key
            $this->getConfigComponent()->setGeneralConfigs(['apiKey' => '']);

            //recreate the register menu
            $this->get('swagconnect.menu_service')->createRegisterMenu();
        } catch (\Exception $e) {
            $this->View()->assign([
                'success' => false,
                'message' => $responseBody->message
            ]);

            return;
        }

        $this->View()->assign([
            'success' => true,
        ]);
    }

    /**
     * WARNING This code remove the current product changes
     * This is a single call operation and its danger one
     */
    private function resetExportedProducts()
    {
        $builder = $this->getModelManager()->getConnection()->createQueryBuilder();
        $builder->delete('sw_connect_change')
            ->where('c_operation IN (:changes)')
            ->setParameter(
                'changes',
                [
                    ChangeGateway::PRODUCT_INSERT,
                    ChangeGateway::PRODUCT_UPDATE,
                    ChangeGateway::PRODUCT_DELETE,
                    ChangeGateway::PRODUCT_STOCK,
                ],
                \Doctrine\DBAL\Connection::PARAM_STR_ARRAY
            );
        $builder->execute();

        $itemRepo = $this->getModelManager()->getRepository('Shopware\CustomModels\Connect\Attribute');
        $itemRepo->resetExportedItemsStatus();

        $streamRepo = $this->getModelManager()->getRepository('Shopware\CustomModels\Connect\ProductStreamAttribute');
        $streamRepo->resetExportedStatus();
    }

    /**
     * @return \ShopwarePlugins\Connect\Components\Helper
     */
    public function getHelper()
    {
        if ($this->factory === null) {
            $this->factory = new \ShopwarePlugins\Connect\Components\ConnectFactory();
        }

        return $this->factory->getHelper();
    }

    /**
     * @return \Shopware\Connect\SDK
     */
    public function getSDK()
    {
        return Shopware()->Container()->get('ConnectSDK');
    }

    /**
     * @return Shopware\Components\Model\ModelManager
     */
    public function getModelManager()
    {
        return Shopware()->Models();
    }

    /**
     * The getStaticPagesAction function is an ExtJs event listener method of the
     * connect module. The function is used to load store
     * required in the general config form for static cms pages combo.
     * @return string
     */
    public function getStaticPagesAction()
    {
        $builder = $this->getModelManager()->createQueryBuilder();
        $builder->select('st.id, st.description AS name');
        $builder->from('Shopware\Models\Site\Site', 'st');

        $query = $builder->getQuery();
        $query->setFirstResult($this->Request()->getParam('start'));
        $query->setMaxResults($this->Request()->getParam('limit'));

        $total = Shopware()->Models()->getQueryCount($query);
        $data = $query->getArrayResult();

        $this->View()->assign([
                'success' => true,
                'data' => $data,
                'total' => $total
            ]);
    }

    /**
     * Helper function to get access on the Config component
     *
     * @return \ShopwarePlugins\Connect\Components\Config
     */
    private function getConfigComponent()
    {
        if ($this->configComponent === null) {
            $this->configComponent = ConfigFactory::getConfigInstance();
        }

        return $this->configComponent;
    }

    /**
     * The getUnitsAction function is an ExtJs event listener method of the
     * connect module. The function is used to load store
     * required in the units mapping.
     * @return string
     */
    public function getUnitsAction()
    {
        $repository = Shopware()->Models()->getRepository('Shopware\Models\Article\Unit');
        $units = $repository->findAll();

        $unitName = Shopware()->Snippets()->getNamespace('backend/connect/view/main')->get(
            'import/unit/take_over_units',
            'Take over unit',
            true
        );

        $unitsMappingArray[] = [
foreach ($collection as $item) {
    $myArray['foo'] = $item->getFoo();

    if ($item->hasBar()) {
        $myArray['bar'] = $item->getBar();
    }

    // do something with $myArray
}
            'shopwareUnitName' => $unitName,
            'shopwareUnitKey' => UnitMapper::ADOPT_UNIT_KEY,
        ];

        foreach ($units as $unit) {
            $unitsMappingArray[] = [
                'shopwareUnitName' => $unit->getName(),
                'shopwareUnitKey' => $unit->getUnit()
            ];
        }

        $this->View()->assign(
            [
                'success' => true,
                'data' => $unitsMappingArray
            ]
        );
    }

    /**
     * The saveUnitsMappingAction function is an ExtJs event listener method of the
     * connect module. The function is used to save units store data.
     * @return string
     */
    public function saveUnitsMappingAction()
    {
        $data = $this->Request()->getParam('data');
        $data = !isset($data[0]) ? [$data] : $data;

        //prepares units for adoption
        $adoptUnitKeys = [];
        foreach ($data as $index => $unit) {
            if ($unit['shopwareUnitKey'] == UnitMapper::ADOPT_UNIT_KEY) {
                $adoptUnitKeys[] = $unit['connectUnit'];
                $data[$index]['shopwareUnitKey'] = $unit['connectUnit'];
            }
        }

        if (!empty($adoptUnitKeys)) {
            $this->getUnitMapper()->createUnits($adoptUnitKeys);
        }

        $this->getConfigComponent()->setUnitsMapping($data);

        // update related products
        $repository = Shopware()->Models()->getRepository('Shopware\Models\Article\Unit');
        foreach ($data as $unit) {
            /** @var \Shopware\Models\Article\Unit $unitModel */
            $unitModel = $repository->findOneBy(['unit' => $unit['shopwareUnitKey']]);
            if (!$unitModel) {
                continue;
            }
            $this->getHelper()->updateUnitInRelatedProducts($unitModel, $unit['connectUnit']);
        }

        $this->View()->assign(
            [
                'success' => true
            ]
        );
    }

    /**
     * The getConnectUnitsAction function is an ExtJs event listener method of the
     * connect module. The function is used to load store
     * required in the units mapping.
     * @return string
     */
    public function getConnectUnitsAction()
    {
        $connectUnits = new Units();
        $connectUnitsArray = $connectUnits->getLocalizedUnits('de');
        $unitsArray = [];
        $hideAssigned = (int) $this->Request()->getParam('hideAssignedUnits', 1);

        foreach ($this->getConfigComponent()->getUnitsMappings() as $connectUnit => $localUnit) {
            if ($hideAssigned == true && strlen($localUnit) > 0) {

                continue;
            }
            $unitsArray[] = [
                'connectUnit' => $connectUnit,
                'name' => $connectUnitsArray[$connectUnit],
                'shopwareUnitKey' => $localUnit
            ];
        }

        $this->View()->assign(
            [
                'success' => true,
                'data' => $unitsArray
            ]
        );
    }

    /**
     * Ask SocialNetwork what time is need to finish the product update
     */
    public function calculateFinishTimeAction()
    {
        $changes = $this->getConnectExport()->getChangesCount();
        $seconds = 0;
        if ($changes > 0) {
            $seconds = $this->getSDK()->calculateFinishTime($changes);
        }

        try {
            $this->View()->assign(
                [
                    'success' => true,
                    'time' => $seconds,
                ]
            );
        } catch (\Exception $e) {
            $this->View()->assign(
                [
                    'success' => false,
                    'message' => $e->getMessage(),
                ]
            );
        }
    }

    public function getMarketplaceAttributesAction()
    {
        try {
            $verified = $this->getConfigComponent()->getConfig('apiKeyVerified', false);
class A
{
    function getObject()
    {
        return null;
    }

}

$a = new A();
$object = $a->getObject();

            if ($verified) {
                $marketplaceAttributes = $this->getSDK()->getMarketplaceProductAttributes();

                $attributes = [];
                foreach ($marketplaceAttributes as $attributeKey => $attributeLabel) {
                    $attributes[] = [
                        'attributeKey' => $attributeKey,
                        'attributeLabel' => $attributeLabel,
                        'shopwareAttributeKey' => ''
                    ];
                }
            } else {
                $attributes = [];
            }
        } catch (\Exception $e) {
            // ignore this exception because sometimes
            // connect plugin is not configured and tries to
            // read marketplace attributes
            $attributes = [];
        }

        $this->View()->assign(
            [
                'success' => true,
                'data' => $attributes
            ]
        );
    }

    public function saveProductAttributesMappingAction()
    {
        try {
            $data = $this->Request()->getParam('data');
            $data = !isset($data[0]) ? [$data] : $data;
            $marketplaceGateway = $this->getFactory()->getMarketplaceGateway();
            $marketplaceGateway->setMarketplaceMapping($data);

            $this->View()->assign(['success' => true]);
        } catch (\Exception $e) {
            $this->View()->assign(
                [
                    'success' => false,
                    'message' => $e->getMessage()
                ]
            );
        }
    }

    public function getProductAttributesMappingAction()
    {
        $marketplaceGateway = $this->getFactory()->getMarketplaceGateway();

        $mappings = array_map(function ($attribute) use ($marketplaceGateway) {
            return [
                    'shopwareAttributeKey' => $attribute->getName(),
                    'shopwareAttributeLabel' => $attribute->getLabel(),
                    'attributeKey' => $marketplaceGateway->findMarketplaceMappingFor($attribute->getName()),
                ];
        }, array_values(
                array_filter(
                    Shopware()->Models()->getRepository('Shopware\Models\Article\Element')->findAll(),
                    function ($attribute) {
                        return $attribute->getName() != 'connectProductDescription';
                    }
                )
            )
        );

        $this->View()->assign(
            [
                'success' => true,
                'data' => $mappings
            ]
        );
    }

    /**
     * Loads all customer groups
     *
     * @throws Zend_Db_Statement_Exception
     */
    public function getExportCustomerGroupsAction()
    {
        $builder = $this->getCustomerGroupRepository()->createQueryBuilder('groups');
        $builder->select([
            'groups.id as id',
            'groups.key as key',
            'groups.name as name',
            'groups.tax as tax',
            'groups.taxInput as taxInput',
            'groups.mode as mode'
        ]);

        $query = $builder->getQuery();

        //get total result of the query
        $total = Shopware()->Models()->getQueryCount($query);

        $data = $query->getArrayResult();

        //return the data and total count
        $this->View()->assign(
            [
                'success' => true,
                'data' => $data,
                'total' => $total,
            ]
        );
    }

    /**
     * Loads all price groups where at least
     * one product with price greater than 0 exists
     *
     * @throws Zend_Db_Statement_Exception
     */
    public function getExportPriceGroupsAction()
    {
        $groups = [];

        $customerGroupKey = $this->Request()->getParam('customerGroup', 'EK');
        $priceExportMode = $this->Request()->getParam('priceExportMode');
        /** @var \Shopware\Models\Customer\Group $customerGroup */
        $customerGroup = $this->getCustomerGroupRepository()->findOneBy(['key' => $customerGroupKey]);
        if (!$customerGroup) {
            $this->View()->assign(
                [
                    'success' => true,
                    'data' => $groups,
                    'total' => count($groups),
                ]
            );

            return;
        }

        $exportConfigArray = $this->getConfigComponent()->getExportConfig();

        if (array_key_exists('exportPriceMode', $exportConfigArray)
            && count($exportConfigArray['exportPriceMode']) > 0
            && $this->getSDK()->getPriceType() != \Shopware\Connect\SDK::PRICE_TYPE_NONE
        ) {
            $groups[] = $this->getConfigComponent()->collectExportPrice($priceExportMode, $customerGroupKey);
        } else {
            $productCount = $this->getPriceGateway()->countProducts($customerGroup);
            $priceConfiguredProducts = $this->getPriceGateway()->countProductsWithConfiguredPrice($customerGroup, 'price');
            $basePriceConfiguredProducts = $this->getPriceGateway()->countProductsWithConfiguredPrice($customerGroup, 'baseprice');
            $pseudoPriceConfiguredProducts = $this->getPriceGateway()->countProductsWithConfiguredPrice($customerGroup, 'pseudoprice');

            $groups[] = [
                'price' => false,
                'priceAvailable' => $priceConfiguredProducts > 0,
                'priceConfiguredProducts' => $priceConfiguredProducts,
                'basePrice' => false,
                'basePriceAvailable' => $basePriceConfiguredProducts > 0,
                'basePriceConfiguredProducts' => $basePriceConfiguredProducts,
                'pseudoPrice' => false,
                'pseudoPriceAvailable' => $pseudoPriceConfiguredProducts > 0,
                'pseudoPriceConfiguredProducts' => $pseudoPriceConfiguredProducts,
                'productCount' => $productCount
            ];
        }

        $this->View()->assign(
            [
                'success' => true,
                'data' => $groups,
                'total' => count($groups),
            ]
        );
    }

    public function adoptUnitsAction()
    {
        $connection = $this->getModelManager()->getConnection();
        $connection->beginTransaction();

        try {
            $units = array_filter($this->getConfigComponent()->getUnitsMappings(), function ($unit) {
                return strlen($unit) == 0;
            });

            $models = $this->getUnitMapper()->createUnits(array_keys($units));
            foreach ($models as $unit) {
                $this->getHelper()->updateUnitInRelatedProducts($unit, $unit->getUnit());
            }
            $connection->commit();
        } catch (\Exception $e) {
            $connection->rollBack();
            $this->getLogger()->write(true, $e->getMessage(), $e);
            $this->View()->assign(
                [
                    'success' => false,
                ]
            );

            return;
        }

        $this->View()->assign(
            [
                'success' => true,
            ]
        );
    }

    /**
     * @return \ShopwarePlugins\Connect\Components\ConnectFactory
     */
    public function getFactory()
    {
        if ($this->factory === null) {
            $this->factory = new \ShopwarePlugins\Connect\Components\ConnectFactory();
        }

        return $this->factory;
    }

    /**
     * @return UnitMapper
     */
    private function getUnitMapper()
    {
        if (!$this->unitMapper) {
            $this->unitMapper = new UnitMapper(
                $this->getConfigComponent(),
                $this->getModelManager()
            );
        }

        return $this->unitMapper;
    }

    /**
     * @return Logger
     */
    private function getLogger()
    {
        if (!$this->logger) {
            $this->logger = new Logger(Shopware()->Db());
        }

        return $this->logger;
    }

    /**
     * @return \Shopware\Components\Model\ModelRepository
     */
    private function getCustomerGroupRepository()
    {
        if (!$this->customerGroupRepository) {
            $this->customerGroupRepository = Shopware()->Models()->getRepository('Shopware\Models\Customer\Group');
        }

        return $this->customerGroupRepository;
    }

    private function getPriceGateway()
    {
        if (!$this->priceGateway) {
            $this->priceGateway = new \ShopwarePlugins\Connect\Components\PriceGateway(
                Shopware()->Db()
            );
        }

        return $this->priceGateway;
    }

    private function getSnHttpClient()

    {
        if (!$this->snHttpClient) {
            $this->snHttpClient = new SnHttpClient(
                $this->get('http_client'),
                new \Shopware\Connect\Gateway\PDO(Shopware()->Db()->getConnection()),
                $this->getConfigComponent()
            );
        }

        return $this->snHttpClient;
    }
}

shopware / SwagConnect

Pull Request — master (#417)

getHelper() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like
