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

Complexity

Conditions	8
Paths	48

Size

Total Lines	90
Code Lines	40

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

<?php
	public function process( \Aimeos\MShop\Product\Item\Iface $product, array $data ) : array
	{
		$context = $this->getContext();
		$manager = \Aimeos\MShop::create( $context, 'supplier' );
		$listManager = \Aimeos\MShop::create( $context, 'supplier/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 2020.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 = [];
			$prodid = $product->getId();
			$map = $this->getMappedChunk( $data, $this->getMapping() );
			$listItems = $this->getListItems( $prodid, $this->listTypes );

It seems like $this->listTypes can also be of type null; however, parameter $types of Aimeos\Controller\Common\Product\Import\Csv\Processor\Supplier\Standard::getListItems() does only seem to accept array, maybe add an additional type check?

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

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

				$codes = explode( $separator, $this->getValue( $list, 'supplier.code', '' ) );
				$listtype = $this->getValue( $list, 'supplier.lists.type', 'default' );
				$this->addType( 'supplier/lists/type', 'product', $listtype );

				foreach( $codes as $code )
				{
					$code = trim( $code );

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

					$list['supplier.lists.parentid'] = $catid;
					$list['supplier.lists.refid'] = $prodid;
					$list['supplier.lists.domain'] = 'product';

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

					$listItem = $listItem->setPosition( $pos++ )->fromArray( $list, true );
					$listManager->saveItem( $listItem, false );
				}
			}

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

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

		return $data;
	}