aimeos / ai-controller-jobs

controller/jobs/src/Controller/Jobs/Order/Export/Csv/Standard.php

Spacing +60 added lines, -60 removed lines

@@ -28,7 +28,7 @@ 
 	 */
 	public function getName()
 	{
-		return $this->getContext()->getI18n()->dt( 'controller/jobs', 'Order export CSV' );
+		return $this->getContext()->getI18n()->dt('controller/jobs', 'Order export CSV');
 	}
 
 
@@ -39,7 +39,7 @@ 
 	 */
 	public function getDescription()
 	{
-		return $this->getContext()->getI18n()->dt( 'controller/jobs', 'Exports orders to CSV file' );
+		return $this->getContext()->getI18n()->dt('controller/jobs', 'Exports orders to CSV file');
 	}
 
 
@@ -73,7 +73,7 @@ 
 		 * @category Developer
 		 * @see controller/common/order/export/csv/max-size
 		 */
-		$mappings = $config->get( 'controller/common/order/export/csv/mapping', $mappings );
+		$mappings = $config->get('controller/common/order/export/csv/mapping', $mappings);
 
 		/** controller/jobs/order/export/csv/mapping
 		 * List of mappings between the position in the CSV file and item keys
@@ -88,7 +88,7 @@ 
 		 * @category Developer
 		 * @see controller/common/order/export/csv/max-size
 		 */
-		$mappings = $config->get( 'controller/jobs/order/export/csv/mapping', $mappings );
+		$mappings = $config->get('controller/jobs/order/export/csv/mapping', $mappings);
 
 
 		/** controller/common/order/export/csv/max-size
@@ -106,29 +106,29 @@ 
 		 * @category Developer
 		 * @see controller/common/order/export/csv/mapping
 		 */
-		$maxcnt = (int) $config->get( 'controller/common/order/export/csv/max-size', 1000 );
+		$maxcnt = (int) $config->get('controller/common/order/export/csv/max-size', 1000);
 
 
-		$processors = $this->getProcessors( $mappings );
-		$mq = $context->getMessageQueueManager()->get( 'mq-admin' )->getQueue( 'order-export' );
+		$processors = $this->getProcessors($mappings);
+		$mq = $context->getMessageQueueManager()->get('mq-admin')->getQueue('order-export');
 
-		while( ( $msg = $mq->get() ) !== null )
+		while (($msg = $mq->get()) !== null)
 		{
 			try
 			{
-				if( ( $data = json_decode( $msg->getBody(), true ) ) === null ) {
-					throw new \Aimeos\Controller\Jobs\Exception( sprintf( 'Invalid message: %2$s', $msg->getBody() ) );
+				if (($data = json_decode($msg->getBody(), true)) === null) {
+					throw new \Aimeos\Controller\Jobs\Exception(sprintf('Invalid message: %2$s', $msg->getBody()));
 				}
 
-				$this->export( $processors, $data, $maxcnt );
+				$this->export($processors, $data, $maxcnt);
 			}
-			catch( \Exception $e )
+			catch (\Exception $e)
 			{
-				$logger->log( 'Order export error: ' . $e->getMessage() );
-				$logger->log( $e->getTraceAsString() );
+				$logger->log('Order export error: ' . $e->getMessage());
+				$logger->log($e->getTraceAsString());
 			}
 
-			$mq->del( $msg );
+			$mq->del($msg);
 		}
 	}
 
@@ -139,15 +139,15 @@ 
 	 * @param \Aimeos\MShop\Context\Item\Iface $context Context item
 	 * @param string $path Absolute path to the exported file
 	 */
-	protected function addJob( $context, $path )
+	protected function addJob($context, $path)
 	{
-		$manager = \Aimeos\MAdmin\Factory::createManager( $context, 'job' );
+		$manager = \Aimeos\MAdmin\Factory::createManager($context, 'job');
 
 		$item = $manager->createItem();
-		$item->setResult( ['file' => $path] );
-		$item->setLabel( $path );
+		$item->setResult(['file' => $path]);
+		$item->setLabel($path);
 
-		$manager->saveItem( $item, false );
+		$manager->saveItem($item, false);
 	}
 
 
@@ -177,7 +177,7 @@ 
 		 * @see controller/jobs/order/export/csv/container/content
 		 * @see controller/jobs/order/export/csv/container/options
 		 */
-		$location = $config->get( 'controller/jobs/order/export/csv/location', sys_get_temp_dir() );
+		$location = $config->get('controller/jobs/order/export/csv/location', sys_get_temp_dir());
 
 		/** controller/jobs/order/export/csv/container/type
 		 * Nave of the container type to read the data from
@@ -200,7 +200,7 @@ 
 		 * @see controller/jobs/order/export/csv/container/content
 		 * @see controller/jobs/order/export/csv/container/options
 		 */
-		$container = $config->get( 'controller/jobs/order/export/csv/container/type', 'Directory' );
+		$container = $config->get('controller/jobs/order/export/csv/container/type', 'Directory');
 
 		/** controller/jobs/order/export/csv/container/content
 		 * Name of the content type inside the container to read the data from
@@ -221,7 +221,7 @@ 
 		 * @see controller/jobs/order/export/csv/container/type
 		 * @see controller/jobs/order/export/csv/container/options
 		 */
-		$content = $config->get( 'controller/jobs/order/export/csv/container/content', 'CSV' );
+		$content = $config->get('controller/jobs/order/export/csv/container/content', 'CSV');
 
 		/** controller/jobs/order/export/csv/container/options
 		 * List of file container options for the order export files
@@ -239,9 +239,9 @@ 
 		 * @see controller/jobs/order/export/csv/container/content
 		 * @see controller/jobs/order/export/csv/container/type
 		 */
-		$options = $config->get( 'controller/jobs/order/export/csv/container/options', [] );
+		$options = $config->get('controller/jobs/order/export/csv/container/options', []);
 
-		return \Aimeos\MW\Container\Factory::getContainer( $location, $container, $content, $options );
+		return \Aimeos\MW\Container\Factory::getContainer($location, $container, $content, $options);
 	}
 
 
@@ -253,56 +253,56 @@ 
 	 * @param integer $maxcnt Maximum number of retrieved orders at once
 	 * @return string Path of the file containing the exported data
 	 */
-	protected function export( array $processors, $msg, $maxcnt )
+	protected function export(array $processors, $msg, $maxcnt)
 	{
-		$lcontext = $this->getLocaleContext( $msg );
+		$lcontext = $this->getLocaleContext($msg);
 		$baseRef = ['order/base/address', 'order/base/coupon', 'order/base/product', 'order/base/service'];
 
-		$manager = \Aimeos\MShop\Factory::createManager( $lcontext, 'order' );
-		$baseManager = \Aimeos\MShop\Factory::createManager( $lcontext, 'order/base' );
+		$manager = \Aimeos\MShop\Factory::createManager($lcontext, 'order');
+		$baseManager = \Aimeos\MShop\Factory::createManager($lcontext, 'order/base');
 
 		$container = $this->getContainer();
-		$content = $container->create( 'order-export_' . date( 'Y-m-d_H-i-s' ) );
-		$search = $this->initCriteria( $manager->createSearch()->setSlice( 0, 0x7fffffff ), $msg );
+		$content = $container->create('order-export_' . date('Y-m-d_H-i-s'));
+		$search = $this->initCriteria($manager->createSearch()->setSlice(0, 0x7fffffff), $msg);
 		$start = 0;
 
 		do
 		{
 			$baseIds = [];
-			$search->setSlice( $start, $maxcnt );
-			$items = $manager->searchItems( $search );
+			$search->setSlice($start, $maxcnt);
+			$items = $manager->searchItems($search);
 
-			foreach( $items as $item ) {
+			foreach ($items as $item) {
 				$baseIds[] = $item->getBaseId();
 			}
 
 			$baseSearch = $baseManager->createSearch();
-			$baseSearch->setConditions( $baseSearch->compare( '==', 'order.base.id', $baseIds ) );
-			$baseSearch->setSlice( 0, count( $baseIds ) );
+			$baseSearch->setConditions($baseSearch->compare('==', 'order.base.id', $baseIds));
+			$baseSearch->setSlice(0, count($baseIds));
 
-			$baseItems = $baseManager->searchItems( $baseSearch, $baseRef );
+			$baseItems = $baseManager->searchItems($baseSearch, $baseRef);
 
-			foreach( $items as $id => $item )
+			foreach ($items as $id => $item)
 			{
-				foreach( $processors as $type => $processor )
+				foreach ($processors as $type => $processor)
 				{
-					foreach( $processor->process( $item, $baseItems[$item->getBaseId()] ) as $line ) {
-						$content->add( [0 => $type, 1 => $id] + $line );
+					foreach ($processor->process($item, $baseItems[$item->getBaseId()]) as $line) {
+						$content->add([0 => $type, 1 => $id] + $line);
 					}
 				}
 			}
 
-			$count = count( $items );
+			$count = count($items);
 			$start += $count;
 		}
-		while( $count === $search->getSliceSize() );
+		while ($count === $search->getSliceSize());
 
 		$path = $content->getResource();
-		$container->add( $content );
+		$container->add($content);
 		$container->close();
 
-		$path = $this->moveFile( $lcontext, $path );
-		$this->addJob( $lcontext, $path );
+		$path = $this->moveFile($lcontext, $path);
+		$this->addJob($lcontext, $path);
 	}
 
 
@@ -312,15 +312,15 @@ 
 	 * @param array $msg Message data including a "sitecode" value
 	 * @return \Aimeos\MShop\Context\Item\Iface New context item with updated locale
 	 */
-	protected function getLocaleContext( array $msg )
+	protected function getLocaleContext(array $msg)
 	{
 		$lcontext = clone $this->getContext();
-		$manager = \Aimeos\MShop\Factory::createManager( $lcontext, 'locale' );
+		$manager = \Aimeos\MShop\Factory::createManager($lcontext, 'locale');
 
-		$sitecode = ( isset( $msg['sitecode'] ) ? $msg['sitecode'] : 'default' );
-		$localeItem = $manager->bootstrap( $sitecode, '', '', false, \Aimeos\MShop\Locale\Manager\Base::SITE_ONE );
+		$sitecode = (isset($msg['sitecode']) ? $msg['sitecode'] : 'default');
+		$localeItem = $manager->bootstrap($sitecode, '', '', false, \Aimeos\MShop\Locale\Manager\Base::SITE_ONE);
 
-		return $lcontext->setLocale( $localeItem );
+		return $lcontext->setLocale($localeItem);
 	}
 
 
@@ -331,14 +331,14 @@ 
 	 * @param array $msg Message data
 	 * @return \Aimeos\MW\Criteria\Iface Initialized criteria object
 	 */
-	protected function initCriteria( \Aimeos\MW\Criteria\Iface $criteria, array $msg )
+	protected function initCriteria(\Aimeos\MW\Criteria\Iface $criteria, array $msg)
 	{
-		if( isset( $msg['filter'] ) ) {
-			$criteria->setConditions( $criteria->toConditions( $msg['filter'] ) );
+		if (isset($msg['filter'])) {
+			$criteria->setConditions($criteria->toConditions($msg['filter']));
 		}
 
-		if( isset( $msg['sort'] ) ) {
-			$criteria->setSortations( $criteria->toSortations( $msg['sort'] ) );
+		if (isset($msg['sort'])) {
+			$criteria->setSortations($criteria->toSortations($msg['sort']));
 		}
 
 		return $criteria;
@@ -352,12 +352,12 @@ 
 	 * @param string $path Absolute path to the exported file
 	 * @return string Relative path of the file in the storage
 	 */
-	protected function moveFile( $context, $path )
+	protected function moveFile($context, $path)
 	{
-		$filename = basename( $path );
-		$context->getFileSystemManager()->get( 'fs-admin' )->writef( $filename, $path );
+		$filename = basename($path);
+		$context->getFileSystemManager()->get('fs-admin')->writef($filename, $path);
 
-		unlink( $path );
+		unlink($path);
 		return $filename;
 	}
 }

controller/jobs/tests/Controller/Jobs/Order/Export/Csv/StandardTest.php

Spacing +54 added lines, -54 removed lines

@@ -20,109 +20,109 @@
 		$this->context = \TestHelperJobs::getContext();
 		$aimeos = \TestHelperJobs::getAimeos();
 
-		$this->object = new \Aimeos\Controller\Jobs\Order\Export\Csv\Standard( $this->context, $aimeos );
+		$this->object = new \Aimeos\Controller\Jobs\Order\Export\Csv\Standard($this->context, $aimeos);
 	}
 
 
 	protected function tearDown()
 	{
-		unset( $this->object, $this->context );
+		unset($this->object, $this->context);
 	}
 
 
 	public function testGetName()
 	{
-		$this->assertEquals( 'Order export CSV', $this->object->getName() );
+		$this->assertEquals('Order export CSV', $this->object->getName());
 	}
 
 
 	public function testGetDescription()
 	{
-		$this->assertEquals( 'Exports orders to CSV file', $this->object->getDescription() );
+		$this->assertEquals('Exports orders to CSV file', $this->object->getDescription());
 	}
 
 
 	public function testRun()
 	{
-		$mqmStub = $this->getMockBuilder( '\\Aimeos\\MW\\MQueue\\Manager\\Standard' )
-			->setConstructorArgs( [$this->context->getConfig()] )
-			->setMethods( ['get'] )
+		$mqmStub = $this->getMockBuilder('\\Aimeos\\MW\\MQueue\\Manager\\Standard')
+			->setConstructorArgs([$this->context->getConfig()])
+			->setMethods(['get'])
 			->getMock();
 
-		$mqStub = $this->getMockBuilder( '\\Aimeos\\MW\\MQueue\\Standard' )
+		$mqStub = $this->getMockBuilder('\\Aimeos\\MW\\MQueue\\Standard')
 			->disableOriginalConstructor()
-			->setMethods( ['getQueue'] )
+			->setMethods(['getQueue'])
 			->getMock();
 
-		$queueStub = $this->getMockBuilder( '\\Aimeos\\MW\\MQueue\\Queue\\Standard' )
+		$queueStub = $this->getMockBuilder('\\Aimeos\\MW\\MQueue\\Queue\\Standard')
 			->disableOriginalConstructor()
-			->setMethods( ['del', 'get'] )
+			->setMethods(['del', 'get'])
 			->getMock();
 
-		$msgStub = $this->getMockBuilder( '\\Aimeos\\MW\\MQueue\\Message\\Standard' )
+		$msgStub = $this->getMockBuilder('\\Aimeos\\MW\\MQueue\\Message\\Standard')
 			->disableOriginalConstructor()
-			->setMethods( ['getBody'] )
+			->setMethods(['getBody'])
 			->getMock();
 
 
-		$this->context->setMessageQueueManager( $mqmStub );
+		$this->context->setMessageQueueManager($mqmStub);
 
 
-		$mqmStub->expects( $this->once() )->method( 'get' )
-			->will( $this->returnValue( $mqStub ) );
+		$mqmStub->expects($this->once())->method('get')
+			->will($this->returnValue($mqStub));
 
-		$mqStub->expects( $this->once() )->method( 'getQueue' )
-			->will( $this->returnValue( $queueStub ) );
+		$mqStub->expects($this->once())->method('getQueue')
+			->will($this->returnValue($queueStub));
 
-		$queueStub->expects( $this->exactly( 2 ) )->method( 'get' )
-			->will( $this->onConsecutiveCalls( $msgStub, null ) );
+		$queueStub->expects($this->exactly(2))->method('get')
+			->will($this->onConsecutiveCalls($msgStub, null));
 
-		$queueStub->expects( $this->once() )->method( 'del' );
+		$queueStub->expects($this->once())->method('del');
 
-		$msgStub->expects( $this->once() )->method( 'getBody' )
-			->will( $this->returnValue( '{"sitecode":"unittest"}' ) );
+		$msgStub->expects($this->once())->method('getBody')
+			->will($this->returnValue('{"sitecode":"unittest"}'));
 
 
 		$this->object->run();
 
 
-		$jobManager = \Aimeos\MAdmin\Factory::createManager( $this->context, 'job' );
+		$jobManager = \Aimeos\MAdmin\Factory::createManager($this->context, 'job');
 		$jobSearch = $jobManager->createSearch();
-		$jobSearch->setConditions( $jobSearch->compare( '=~', 'job.label', 'order-export_' ) );
-		$jobItems = $jobManager->searchItems( $jobSearch );
-		$jobManager->deleteItems( array_keys( $jobItems ) );
+		$jobSearch->setConditions($jobSearch->compare('=~', 'job.label', 'order-export_'));
+		$jobItems = $jobManager->searchItems($jobSearch);
+		$jobManager->deleteItems(array_keys($jobItems));
 
-		$this->assertEquals( 1, count( $jobItems ) );
+		$this->assertEquals(1, count($jobItems));
 
 
-		$filename = dirname( dirname( dirname( dirname( dirname( __DIR__ ) ) ) ) ) . '/tmp/' . reset( $jobItems )->getLabel();
-		$fp = fopen( $filename, 'r' );
+		$filename = dirname(dirname(dirname(dirname(dirname(__DIR__))))) . '/tmp/' . reset($jobItems)->getLabel();
+		$fp = fopen($filename, 'r');
 
-		$invoice = fgetcsv( $fp );
-		$address1 = fgetcsv( $fp );
-		$address2 = fgetcsv( $fp );
-		$service1 = fgetcsv( $fp );
-		$service2 = fgetcsv( $fp );
+		$invoice = fgetcsv($fp);
+		$address1 = fgetcsv($fp);
+		$address2 = fgetcsv($fp);
+		$service1 = fgetcsv($fp);
+		$service2 = fgetcsv($fp);
 		$coupon1 = fgetcsv($fp);
 		$coupon2 = fgetcsv($fp);
-		$product1 = fgetcsv( $fp );
-		$product2 = fgetcsv( $fp );
-		$product3 = fgetcsv( $fp );
-		$product4 = fgetcsv( $fp );
-
-		fclose( $fp );
-		unlink( $filename );
-
-		$this->assertEquals( 'invoice', $invoice[0] );
-		$this->assertEquals( 'address', $address1[0] );
-		$this->assertEquals( 'address', $address2[0] );
-		$this->assertEquals( 'service', $service1[0] );
-		$this->assertEquals( 'service', $service2[0] );
-		$this->assertEquals( 'coupon', $coupon1[0]);
-		$this->assertEquals( 'coupon', $coupon2[0]);
-		$this->assertEquals( 'product', $product1[0] );
-		$this->assertEquals( 'product', $product2[0] );
-		$this->assertEquals( 'product', $product3[0] );
-		$this->assertEquals( 'product', $product4[0] );
+		$product1 = fgetcsv($fp);
+		$product2 = fgetcsv($fp);
+		$product3 = fgetcsv($fp);
+		$product4 = fgetcsv($fp);
+
+		fclose($fp);
+		unlink($filename);
+
+		$this->assertEquals('invoice', $invoice[0]);
+		$this->assertEquals('address', $address1[0]);
+		$this->assertEquals('address', $address2[0]);
+		$this->assertEquals('service', $service1[0]);
+		$this->assertEquals('service', $service2[0]);
+		$this->assertEquals('coupon', $coupon1[0]);
+		$this->assertEquals('coupon', $coupon2[0]);
+		$this->assertEquals('product', $product1[0]);
+		$this->assertEquals('product', $product2[0]);
+		$this->assertEquals('product', $product3[0]);
+		$this->assertEquals('product', $product4[0]);
 	}
 }