Aimeos\Controller\Jobs\Catalog\Import\Csv\Standard::run()

Complexity

Conditions	9
Paths	23

Size

Total Lines	72
Code Lines	44

Duplication

Lines	0
Ratio	0 %

Importance

Changes	2
Bugs	0	Features	0

<?php
	public function run()
	{
		if( file_exists( $this->location() ) === false ) {
			return;
		}

		$total = $errors = 0;
		$logger = $this->context()->logger();

		try
		{
			$mappings = $this->mapping();
			$codePos = $this->getCodePosition( $mappings['item'] );
			$processor = $this->getProcessors( $mappings );
			$catalogMap = $this->getCatalogMap( $this->domains() );
			$container = $this->getContainer();
			$path = $container->getName();

			$maxcnt = $this->max();
			$strict = $this->strict();
			$skiplines = $this->skip();

			$msg = sprintf( 'Started catalog import from "%1$s" (%2$s)', $path, __CLASS__ );
			$logger->notice( $msg, 'import/csv/catalog' );

			foreach( $container as $content )
			{
				$name = $content->getName();

				for( $i = 0; $i < $skiplines; $i++ ) {
					$content->next();
				}

				while( ( $data = $this->getData( $content, $maxcnt, $codePos ) ) !== [] )
				{
					$errcnt = $this->import( $catalogMap, $data, $mappings['item'], $processor, $strict );
					$chunkcnt = count( $data );

					$str = 'Imported catalog lines from "%1$s": %2$d/%3$d (%4$s)';
					$msg = sprintf( $str, $name, $chunkcnt - $errcnt, $chunkcnt, __CLASS__ );
					$logger->notice( $msg, 'import/csv/catalog' );

					$errors += $errcnt;
					$total += $chunkcnt;
					unset( $data );
				}
			}

			$container->close();
		}
		catch( \Exception $e )
		{
			$logger->error( 'Catalog import error: ' . $e->getMessage() . "\n" . $e->getTraceAsString(), 'import/csv/catalog' );
			$this->mail( 'Catalog CSV import error', $e->getMessage() . "\n" . $e->getTraceAsString() );
			throw new \Aimeos\Controller\Jobs\Exception( $e->getMessage() );
		}

		$str = 'Finished catalog import from "%1$s": %2$d successful, %3$s errors, %4$s total (%5$s)';
		$msg = sprintf( $str, $path, $total - $errors, $errors, $total, __CLASS__ );
		$logger->notice( $msg, 'import/csv/catalog' );

		if( $errors > 0 )
		{
			$msg = sprintf( 'Invalid catalog lines in "%1$s": %2$d/%3$d', $path, $errors, $total );
			$this->mail( 'Catalog CSV import error', $msg );
			throw new \Aimeos\Controller\Jobs\Exception( $msg );
		}

		if( !empty( $backup = $this->backup() ) && @rename( $path, $backup = \Aimeos\Base\Str::strtime( $backup ) ) === false )
		{
			$msg = sprintf( 'Unable to move imported file "%1$s" to "%2$s"', $path, $backup );
			throw new \Aimeos\Controller\Jobs\Exception( $msg );
		}