Manufacturer.php

<?php

/**
 * @copyright 2010-2013 JTL-Software GmbH
 * @package jtl\Connector\Shopware\Controller
 */

namespace jtl\Connector\Shopware\Mapper;

use jtl\Connector\Model\Manufacturer as ManufacturerModel;
use Shopware\Components\Api\Exception as ApiException;
use jtl\Connector\Model\Identity;
use Shopware\Models\Article\Supplier as ManufacturerSW;
use jtl\Connector\Core\Utilities\Language as LanguageUtil;
use jtl\Connector\Shopware\Utilities\Locale as LocaleUtil;
use jtl\Connector\Shopware\Utilities\Mmc;
use jtl\Connector\Shopware\Utilities\Shop as ShopUtil;

class Manufacturer extends DataMapper
{
    public function find($id)
    {
        return (\intval($id) == 0) ? null : $this->Manager()->find('Shopware\Models\Article\Supplier', $id);
    }

    public function findOneBy(array $kv)
    {
        return $this->Manager()->getRepository('Shopware\Models\Article\Supplier')->findOneBy($kv);
    }

    public function findAll($limit = 100, $count = false)
    {
        $query = $this->Manager()->createQueryBuilder()->select(
            'supplier',
            'attribute'
        )
            //->from('Shopware\Models\Article\Supplier', 'supplier')
            //->leftJoin('jtl\Connector\Shopware\Model\ConnectorLink', 'link',
            // \Doctrine\ORM\Query\Expr\Join::WITH, 'supplier.id = link.endpointId AND link.type = 41')
            ->from('jtl\Connector\Shopware\Model\Linker\Manufacturer', 'supplier')
            ->leftJoin('supplier.linker', 'linker')
            ->leftJoin('supplier.attribute', 'attribute')
            ->where('linker.hostId IS NULL')
            ->andWhere('supplier.name != :name')
            ->setParameter('name', '_')
            ->setFirstResult(0)
            ->setMaxResults($limit)
            //->getQuery();
            ->getQuery()->setHydrationMode(\Doctrine\ORM\AbstractQuery::HYDRATE_ARRAY);

        $paginator = new \Doctrine\ORM\Tools\Pagination\Paginator($query, $fetchJoinCollection = true);

        if ($count) {
            return $paginator->count();
        }

        $manufacturers = \iterator_to_array($paginator);

        $shopMapper = Mmc::getMapper('Shop');
        $shops      = $shopMapper->findAll(null, null);

        $translationService = ShopUtil::translationService();
        for ($i = 0; $i < \count($manufacturers); $i++) {
            foreach ($shops as $shop) {
                $translation = $translationService->read($shop['id'], 'supplier', $manufacturers[$i]['id']);
                if (!empty($translation)) {
                    $translation['shopId']                                        = $shop['id'];
                    $manufacturers[$i]['translations'][$shop['locale']['locale']] = $translation;
                }
            }
        }

        return $manufacturers;
    }

    public function fetchCount($limit = 100)
    {
        return $this->findAll($limit, true);
    }

    public function deleteSuperfluous()
    {
        return \Shopware()->Db()->query('DELETE s
                                        FROM s_articles_supplier s
                                        LEFT JOIN s_articles a ON a.supplierID = s.id
                                        WHERE a.id IS NULL');
    }

    public function delete(ManufacturerModel $manufacturer)
    {
        $result = new ManufacturerModel();

        $this->deleteManufacturerData($manufacturer);

        // Result
        $result->setId(new Identity('', $manufacturer->getId()->getHost()));

        return $result;
    }

    public function save(ManufacturerModel $manufacturer)
    {
        $manufacturerSW = null;
        $result         = new ManufacturerModel();

        $this->prepareManufacturerAssociatedData($manufacturer, $manufacturerSW);
        $this->prepareI18nAssociatedData($manufacturer, $manufacturerSW);

        $violations = $this->Manager()->validate($manufacturerSW);
        if ($violations->count() > 0) {
            throw new ApiException\ValidationException($violations);
        }

        $this->Manager()->persist($manufacturerSW);
        $this->flush();

        $this->saveTranslatation($manufacturer, $manufacturerSW);

        // Result
        $result->setId(new Identity($manufacturerSW->getId(), $manufacturer->getId()->getHost()));

        return $result;
    }

    public function saveTranslatation(ManufacturerModel $manufacturer, ManufacturerSW $manufacturerSW)
    {
        foreach ($manufacturer->getI18ns() as $i18n) {
            if (ShopUtil::isShopwareDefaultLanguage($i18n->getLanguageISO()) !== false) {
                $iso      = $i18n->getLanguageISO();
                $locale   = LanguageUtil::map(null, null, $iso);
                $language = LocaleUtil::extractLanguageIsoFromLocale($locale);

                $translationService = ShopUtil::translationService();
                $shopMapper         = Mmc::getMapper('Shop');
                $shops              = $shopMapper->findByLanguageIso($language);

                foreach ($shops as $shop) {
                    $translationService->delete($shop->getId(), 'supplier', $manufacturerSW->getId());
                    $translationService->write(
                        $shop->getId(),
                        'supplier',
                        $manufacturerSW->getId(),
                        array(
                            'metaTitle' => $i18n->getTitleTag(),
                            'description' => $i18n->getDescription(),
                            'metaDescription' => $i18n->getMetaDescription(),
                            'metaKeywords' => $i18n->getMetaKeywords()
                        )
                    );
                }
            }
        }
    }

    public function deleteTranslation(ManufacturerSW $manufacturerSW)
    {
        ShopUtil::translationService()->deleteAll('supplier', $manufacturerSW->getId());
    }

    protected function deleteManufacturerData(ManufacturerModel $manufacturer)
    {
        $manufacturerId = (\strlen($manufacturer->getId()->getEndpoint()) > 0)
            ? (int) $manufacturer->getId()->getEndpoint()
            : null;

        if ($manufacturerId !== null && $manufacturerId > 0) {
            $manufacturerSW = $this->find((int) $manufacturerId);
            if ($manufacturerSW !== null) {
                $this->deleteTranslation($manufacturerSW);

                $this->Manager()->remove($manufacturerSW);
                $this->Manager()->flush($manufacturerSW);
            }
        }
    }

    protected function prepareManufacturerAssociatedData(
        ManufacturerModel &$manufacturer,
        ManufacturerSW &$manufacturerSW = null
    ) {
        $manufacturerId = (\strlen($manufacturer->getId()->getEndpoint()) > 0)
            ? (int)$manufacturer->getId()->getEndpoint()
            : null;

        if ($manufacturerId !== null && $manufacturerId > 0) {
            $manufacturerSW = $this->find($manufacturerId);
        }

        if ($manufacturerSW === null) {
            $manufacturerSW = new ManufacturerSW();
        }

        $manufacturerSW->setName($manufacturer->getName())
            ->setLink($manufacturer->getWebsiteUrl());
    }

    protected function prepareI18nAssociatedData(ManufacturerModel &$manufacturer, ManufacturerSW &$manufacturerSW)
    {
        foreach ($manufacturer->getI18ns() as $i18n) {
            if (ShopUtil::isShopwareDefaultLanguage($i18n->getLanguageISO())) {
                $manufacturerSW->setDescription($i18n->getDescription());
                $manufacturerSW->setMetaTitle($i18n->getTitleTag());
                $manufacturerSW->setMetaDescription($i18n->getMetaDescription());
                $manufacturerSW->setMetaKeywords($i18n->getMetaKeywords());
            }
        }
    }
}