Aimeos\MShop\Index\Manager\Supplier\Standard::rebuild()

Complexity

Conditions	11
Paths	19

Size

Total Lines	88
Code Lines	33

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
	public function rebuild( iterable $items = [] ) : \Aimeos\MShop\Index\Manager\Iface
	{
		if( ( $items = map( $items ) )->isEmpty() ) { return $this; }

		$items->implements( \Aimeos\MShop\Product\Item\Iface::class, true );

		$date = date( 'Y-m-d H:i:s' );
		$context = $this->context();
		$siteid = $context->locale()->getSiteId();
		$conn = $context->db( $this->getResourceName() );

			/** mshop/index/manager/supplier/insert/mysql
			 * Inserts a new supplier record into the product index database
			 *
			 * @see mshop/index/manager/supplier/insert/ansi
			 */

			/** mshop/index/manager/supplier/insert/ansi
			 * Inserts a new supplier record into the product index database
			 *
			 * During the product index rebuild, categories related to a
			 * product will be stored in the index for this product. All
			 * records are deleted before the new ones are inserted.
			 *
			 * The SQL statement must be a string suitable for being used as
			 * prepared statement. It must include question marks for binding
			 * the values from the order item to the statement before they are
			 * sent to the database server. The number of question marks must
			 * be the same as the number of columns listed in the INSERT
			 * statement. The order of the columns must correspond to the
			 * order in the rebuild() method, so the correct values are
			 * bound to the columns.
			 *
			 * The SQL statement should conform to the ANSI standard to be
			 * compatible with most relational database systems. This also
			 * includes using double quotes for table and column names.
			 *
			 * @param string SQL statement for inserting records
			 * @since 2018.07
			 * @category Developer
			 * @see mshop/index/manager/supplier/cleanup/ansi
			 * @see mshop/index/manager/supplier/delete/ansi
			 * @see mshop/index/manager/supplier/search/ansi
			 * @see mshop/index/manager/supplier/count/ansi
			 */
			$stmt = $this->getCachedStatement( $conn, 'mshop/index/manager/supplier/insert' );

			foreach( $items as $id => $item )
			{
				foreach( $item->getListItems( 'supplier' ) as $listItem )
				{
					if( ( $supplier = $listItem->getRefItem() ) === null ) {
						continue;
					}

					$pairs = $supplier->getAddressItems()->map( function( $addr ) {
						return $addr->getLatitude() !== null && $addr->getLongitude() !== null
							? ['lat' => $addr->getLatitude(), 'lon' => $addr->getLongitude()]
							: null;
					} )->filter();

					if( $pairs->isEmpty() ) {
						$pairs = [['lat' => null, 'lon' => null]];
					}

					foreach( $pairs as $pair )
					{
						$stmt->bind( 1, $listItem->getParentId(), \Aimeos\Base\DB\Statement\Base::PARAM_INT );
						$stmt->bind( 2, $listItem->getRefId(), \Aimeos\Base\DB\Statement\Base::PARAM_INT );
						$stmt->bind( 3, $listItem->getType() );
						$stmt->bind( 4, $listItem->getPosition(), \Aimeos\Base\DB\Statement\Base::PARAM_INT );
						$stmt->bind( 5, $pair['lat'] ?? null, \Aimeos\Base\DB\Statement\Base::PARAM_FLOAT );
						$stmt->bind( 6, $pair['lon'] ?? null, \Aimeos\Base\DB\Statement\Base::PARAM_FLOAT );
						$stmt->bind( 7, $date ); //mtime
						$stmt->bind( 8, $siteid );

						try {
							$stmt->execute()->finish();
						} catch( \Aimeos\Base\DB\Exception $e ) { ; } // Ignore duplicates
					}
				}
			}

		foreach( $this->getSubManagers() as $submanager ) {
			$submanager->rebuild( $items );
		}

		return $this;
	}