Aimeos\Controller\Common\Product\Import\Csv\Processor\Catalog\Standard::process()

Complexity

Conditions	9
Paths	68

Size

Total Lines	89
Code Lines	40

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
	public function process( \Aimeos\MShop\Product\Item\Iface $product, array $data )
	{
		$context = $this->getContext();
		$manager = \Aimeos\MShop\Factory::createManager( $context, 'catalog' );
		$listManager = \Aimeos\MShop\Factory::createManager( $context, 'catalog/lists' );

		/** controller/common/product/import/csv/separator
		 * Single separator character for multiple entries in one field of the import file
		 *
		 * The product importer is able split the content of a field from the import
		 * file into several entries based on the given separator character. Thus,
		 * you can create more compact import files and handle a variable range
		 * of entries better. The default separator character is a new line.
		 *
		 * '''Caution:''' The separator character must not be part of any entry
		 * in the field. Otherwise, you will get invalid entries and the importer
		 * may fail!
		 *
		 * @param string Single separator character
		 * @since 2015.07
		 * @category User
		 * @category Developer
		 * @see controller/common/product/import/csv/domains
		 */
		$separator = $context->getConfig()->get( 'controller/common/product/import/csv/separator', "\n" );

		$manager->begin();

		try
		{
			$listMap = array();
			$prodid = $product->getId();
			$map = $this->getMappedChunk( $data );
			$listItems = $this->getListItems( $prodid, $this->listTypes );

			foreach( $listItems as $listItem ) {
				$listMap[ $listItem->getParentId() ][ $listItem->getType() ] = $listItem;
			}

			foreach( $map as $pos => $list )
			{
				if( $this->checkEntry( $list ) === false ) {
					continue;
				}

				$codes = explode( $separator, $list['catalog.code'] );
				$type = ( isset( $list['catalog.lists.type'] ) ? $list['catalog.lists.type'] : 'default' );

				foreach( $codes as $code )
				{
					if( ( $catid = $this->cache->get( $code ) ) === null )
					{
						$msg = 'No category for code "%1$s" available when importing product with code "%2$s"';
						throw new \Aimeos\Controller\Jobs\Exception( sprintf( $msg, $code, $product->getCode() ) );
					}

					$list['catalog.lists.typeid'] = $this->getTypeId( 'catalog/lists/type', 'product', $type );
					$list['catalog.lists.parentid'] = $catid;
					$list['catalog.lists.refid'] = $prodid;
					$list['catalog.lists.domain'] = 'product';

					if( isset( $listMap[$catid][$type] ) )
					{
						$listItem = $listMap[$catid][$type];
						unset( $listItems[ $listItem->getId() ] );
					}
					else
					{
						$listItem = $listManager->createItem();
					}

					$listItem->fromArray( $this->addListItemDefaults( $list, $pos++ ) );
					$listManager->saveItem( $listItem );
				}
			}

			$listManager->deleteItems( array_keys( $listItems ) );
			$remaining = $this->getObject()->process( $product, $data );

			$manager->commit();
		}
		catch( \Exception $e )
		{
			$manager->rollback();
			throw $e;
		}

		return $remaining;
	}