download-monitor / download-monitor

src/Shop/Order/WordPressRepository.php

Spacing +102 added lines, -102 removed lines

@@ -20,23 +20,23 @@ 
 	 *
 	 * @return string
 	 */
-	private function prep_where_statement( $filters ) {
+	private function prep_where_statement($filters) {
 		global $wpdb;
 		// setup where statements
-		$where = array( "WHERE 1=1" );
-		foreach ( $filters as $filter ) {
-			$operator = ( ! empty( $filter['operator'] ) ) ? esc_sql( $filter['operator'] ) : "=";
-			if ( 'IN' == $operator && is_array( $filter['value'] ) ) {
-				array_walk( $filter['value'], 'esc_sql' );
-				$value_str = implode( "','", $filter['value'] );
-				$where[]   = "AND `" . esc_sql( $filter['key'] ) . "` " . $operator . " ('" . $value_str . "')";
+		$where = array("WHERE 1=1");
+		foreach ($filters as $filter) {
+			$operator = ( ! empty($filter['operator'])) ? esc_sql($filter['operator']) : "=";
+			if ('IN' == $operator && is_array($filter['value'])) {
+				array_walk($filter['value'], 'esc_sql');
+				$value_str = implode("','", $filter['value']);
+				$where[]   = "AND `" . esc_sql($filter['key']) . "` " . $operator . " ('" . $value_str . "')";
 			} else {
-				$where[] = $wpdb->prepare( "AND `" . esc_sql( $filter['key'] ) . "` " . $operator . " '%s'", $filter['value'] );
+				$where[] = $wpdb->prepare("AND `" . esc_sql($filter['key']) . "` " . $operator . " '%s'", $filter['value']);
 			}
 		}
 		$where_str = "";
-		if ( count( $where ) > 1 ) {
-			$where_str = implode( " ", $where );
+		if (count($where) > 1) {
+			$where_str = implode(" ", $where);
 		}
 
 		return $where_str;
@@ -49,30 +49,30 @@ 
 	 *
 	 * @return Order
 	 */
-	private function add_order_items_to_order( $order ) {
+	private function add_order_items_to_order($order) {
 		global $wpdb;
 
 		/** Fetch order items */
 		$order_items = array();
-		$db_items    = $wpdb->get_results( $wpdb->prepare( "SELECT * FROM `" . $wpdb->prefix . "dlm_order_item` WHERE `order_id` = %d ORDER BY `id` ASC ;", $order->get_id() ) );
-		if ( count( $db_items ) > 0 ) {
-			foreach ( $db_items as $db_item ) {
+		$db_items    = $wpdb->get_results($wpdb->prepare("SELECT * FROM `" . $wpdb->prefix . "dlm_order_item` WHERE `order_id` = %d ORDER BY `id` ASC ;", $order->get_id()));
+		if (count($db_items) > 0) {
+			foreach ($db_items as $db_item) {
 				$order_item = new OrderItem();
 
-				$order_item->set_id( $db_item->id );
-				$order_item->set_label( $db_item->label );
-				$order_item->set_qty( $db_item->qty );
-				$order_item->set_download_id( $db_item->download_id );
-				$order_item->set_subtotal( $db_item->subtotal );
-				$order_item->set_tax_class( $db_item->tax_class );
-				$order_item->set_tax_total( $db_item->tax_total );
-				$order_item->set_total( $db_item->total );
+				$order_item->set_id($db_item->id);
+				$order_item->set_label($db_item->label);
+				$order_item->set_qty($db_item->qty);
+				$order_item->set_download_id($db_item->download_id);
+				$order_item->set_subtotal($db_item->subtotal);
+				$order_item->set_tax_class($db_item->tax_class);
+				$order_item->set_tax_total($db_item->tax_total);
+				$order_item->set_total($db_item->total);
 
 				$order_items[] = $order_item;
 			}
 		}
 
-		$order->set_items( $order_items );
+		$order->set_items($order_items);
 
 		return $order;
 	}
@@ -84,38 +84,38 @@ 
 	 *
 	 * @return Order
 	 */
-	private function add_transactions_to_order( $order ) {
+	private function add_transactions_to_order($order) {
 		global $wpdb;
 
 		/** Fetch transactions */
 		$order_transactions = array();
-		$db_items           = $wpdb->get_results( $wpdb->prepare( "SELECT * FROM `" . $wpdb->prefix . "dlm_order_transaction` WHERE `order_id` = %d ORDER BY `id` ASC ;", $order->get_id() ) );
-		if ( count( $db_items ) > 0 ) {
-			foreach ( $db_items as $db_item ) {
+		$db_items           = $wpdb->get_results($wpdb->prepare("SELECT * FROM `" . $wpdb->prefix . "dlm_order_transaction` WHERE `order_id` = %d ORDER BY `id` ASC ;", $order->get_id()));
+		if (count($db_items) > 0) {
+			foreach ($db_items as $db_item) {
 				$order_transaction = new Transaction\OrderTransaction();
 
-				$order_transaction->set_id( $db_item->id );
+				$order_transaction->set_id($db_item->id);
 
-				if ( ! empty( $db_item->date_created ) ) {
-					$order_transaction->set_date_created( new \DateTimeImmutable( $db_item->date_created ) );
+				if ( ! empty($db_item->date_created)) {
+					$order_transaction->set_date_created(new \DateTimeImmutable($db_item->date_created));
 				}
 
-				if ( ! empty( $db_item->date_modified ) ) {
-					$order_transaction->set_date_modified( new \DateTimeImmutable( $db_item->date_modified ) );
+				if ( ! empty($db_item->date_modified)) {
+					$order_transaction->set_date_modified(new \DateTimeImmutable($db_item->date_modified));
 				}
 
-				$order_transaction->set_amount( $db_item->amount );
-				$order_transaction->set_status( Services::get()->service( 'order_transaction_factory' )->make_status( $db_item->status ) );
-				$order_transaction->set_processor( $db_item->processor );
-				$order_transaction->set_processor_nice_name( $db_item->processor_nice_name );
-				$order_transaction->set_processor_transaction_id( $db_item->processor_transaction_id );
-				$order_transaction->set_processor_status( $db_item->processor_status );
+				$order_transaction->set_amount($db_item->amount);
+				$order_transaction->set_status(Services::get()->service('order_transaction_factory')->make_status($db_item->status));
+				$order_transaction->set_processor($db_item->processor);
+				$order_transaction->set_processor_nice_name($db_item->processor_nice_name);
+				$order_transaction->set_processor_transaction_id($db_item->processor_transaction_id);
+				$order_transaction->set_processor_status($db_item->processor_status);
 
 				$order_transactions[] = $order_transaction;
 			}
 		}
 
-		$order->set_transactions( $order_transactions );
+		$order->set_transactions($order_transactions);
 
 		return $order;
 	}
@@ -134,18 +134,18 @@ 
 	 *
 	 * @throws \Exception
 	 */
-	public function retrieve( $filters = array(), $limit = 0, $offset = 0, $order_by = 'id', $order = 'DESC' ) {
+	public function retrieve($filters = array(), $limit = 0, $offset = 0, $order_by = 'id', $order = 'DESC') {
 		global $wpdb;
 
 		// prep order
-		$order_by = ( empty( $order_by ) ) ? 'id' : esc_sql( $order_by );
-		$order    = strtoupper( $order );
-		if ( ! in_array( $order, array( 'ASC', 'DESC' ) ) ) {
+		$order_by = (empty($order_by)) ? 'id' : esc_sql($order_by);
+		$order    = strtoupper($order);
+		if ( ! in_array($order, array('ASC', 'DESC'))) {
 			$order = 'DESC';
 		}
 
 		// prep where statement
-		$where_str = $this->prep_where_statement( $filters );
+		$where_str = $this->prep_where_statement($filters);
 
 		$sql = "
 		SELECT O.*, C.* 
@@ -154,49 +154,49 @@ 
 		" . $where_str . "
 		ORDER BY O.`" . $order_by . "` " . $order;
 
-		$limit  = absint( $limit );
-		$offset = absint( $offset );
+		$limit  = absint($limit);
+		$offset = absint($offset);
 
-		if ( $limit > 0 ) {
+		if ($limit > 0) {
 			$sql .= " LIMIT " . $limit;
 		}
 
-		if ( $offset > 0 ) {
+		if ($offset > 0) {
 			$sql .= " OFFSET " . $offset;
 		}
 
 		$sql .= ";";
 
 		// try to fetch session from database
-		$results = $wpdb->get_results( $sql );
+		$results = $wpdb->get_results($sql);
 
 		// check if result if found
-		if ( null === $results ) {
-			throw new \Exception( 'SQL error while fetching order' );
+		if (null === $results) {
+			throw new \Exception('SQL error while fetching order');
 		}
 
 		// array that will hold all order objects
 		$orders = array();
 
-		foreach ( $results as $result ) {
+		foreach ($results as $result) {
 
 			$order = new Order();
 
-			$order->set_id( $result->id );
-			$order->set_status( Services::get()->service( 'order_status_factory' )->make( $result->status ) );
-			$order->set_currency( $result->currency );
-			$order->set_hash( $result->hash );
+			$order->set_id($result->id);
+			$order->set_status(Services::get()->service('order_status_factory')->make($result->status));
+			$order->set_currency($result->currency);
+			$order->set_hash($result->hash);
 
-			if ( ! empty( $result->date_created ) ) {
-				$order->set_date_created( new \DateTimeImmutable( $result->date_created ) );
+			if ( ! empty($result->date_created)) {
+				$order->set_date_created(new \DateTimeImmutable($result->date_created));
 			}
 
-			if ( ! empty( $result->date_modified ) ) {
-				$order->set_date_modified( new \DateTimeImmutable( $result->date_modified ) );
+			if ( ! empty($result->date_modified)) {
+				$order->set_date_modified(new \DateTimeImmutable($result->date_modified));
 			}
 
 			// create and set customer
-			$order->set_customer( new OrderCustomer(
+			$order->set_customer(new OrderCustomer(
 				$result->first_name,
 				$result->last_name,
 				$result->company,
@@ -209,13 +209,13 @@ 
 				$result->email,
 				$result->phone,
 				$result->ip_address
-			) );
+			));
 
 			// add order items to order object
-			$order = $this->add_order_items_to_order( $order );
+			$order = $this->add_order_items_to_order($order);
 
 			// add transactions to order object
-			$order = $this->add_transactions_to_order( $order );
+			$order = $this->add_transactions_to_order($order);
 
 			// add new order object to array
 			$orders[] = $order;
@@ -235,10 +235,10 @@ 
 	 *
 	 * @throws \Exception
 	 */
-	public function retrieve_single( $id ) {
-		$orders = $this->retrieve( array( array( 'key' => 'id', 'value' => $id, 'operator' => '=' ) ), 1 );
-		if ( 0 === count( $orders ) ) {
-			throw new \Exception( 'Order not found' );
+	public function retrieve_single($id) {
+		$orders = $this->retrieve(array(array('key' => 'id', 'value' => $id, 'operator' => '=')), 1);
+		if (0 === count($orders)) {
+			throw new \Exception('Order not found');
 		}
 
 		return $orders[0];
@@ -251,15 +251,15 @@ 
 	 *
 	 * @return int
 	 */
-	public function num_rows( $filters = array() ) {
+	public function num_rows($filters = array()) {
 		global $wpdb;
 
 		// prep where statement
-		$where_str = $this->prep_where_statement( $filters );
+		$where_str = $this->prep_where_statement($filters);
 
-		$num = $wpdb->get_var( "SELECT COUNT(id) FROM `" . $wpdb->prefix . "dlm_order` {$where_str} " );
+		$num = $wpdb->get_var("SELECT COUNT(id) FROM `" . $wpdb->prefix . "dlm_order` {$where_str} ");
 
-		if ( null === $num ) {
+		if (null === $num) {
 			$num = 0;
 		}
 
@@ -275,17 +275,17 @@ 
 	 *
 	 * @return bool
 	 */
-	public function persist( $order ) {
+	public function persist($order) {
 		global $wpdb;
 
 		$date_created = '';
-		if ( null !== $order->get_date_created() ) {
-			$date_created = $order->get_date_created()->format( 'Y-m-d H:i:s' );
+		if (null !== $order->get_date_created()) {
+			$date_created = $order->get_date_created()->format('Y-m-d H:i:s');
 		}
 
 		$date_modified = '';
-		if ( null !== $order->get_date_modified() ) {
-			$date_modified = $order->get_date_modified()->format( 'Y-m-d H:i:s' );
+		if (null !== $order->get_date_modified()) {
+			$date_modified = $order->get_date_modified()->format('Y-m-d H:i:s');
 		}
 
 		$order_id = $order->get_id();
@@ -293,7 +293,7 @@ 
 		$customer = $order->get_customer();
 
 		// check if it's a new order or if we need to update an existing one
-		if ( empty( $order_id ) ) {
+		if (empty($order_id)) {
 			// new order
 
 			// insert order
@@ -316,7 +316,7 @@ 
 			);
 
 			// set the new id as order id
-			$order->set_id( $wpdb->insert_id );
+			$order->set_id($wpdb->insert_id);
 
 			// insert customer record
 			$wpdb->insert(
@@ -356,21 +356,21 @@ 
 		} else {
 
 			// update an existing order
-			$wpdb->update( $wpdb->prefix . 'dlm_order',
+			$wpdb->update($wpdb->prefix . 'dlm_order',
 				array(
 					'status'        => $order->get_status()->get_key(),
-					'date_modified' => current_time( 'mysql', 1 ),
+					'date_modified' => current_time('mysql', 1),
 					'currency'      => $order->get_currency(),
 					'hash'          => $order->get_hash()
 				),
-				array( 'id' => $order_id ),
+				array('id' => $order_id),
 				array(
 					'%s',
 					'%s',
 					'%s',
 					'%s'
 				),
-				array( '%d' )
+				array('%d')
 			);
 
 			// update customer record
@@ -391,7 +391,7 @@ 
 					'ip_address' => $customer->get_ip_address(),
 					'order_id'   => $order->get_id()
 				),
-				array( 'order_id' => $order_id ),
+				array('order_id' => $order_id),
 				array(
 					'%s',
 					'%s',
@@ -407,19 +407,19 @@ 
 					'%s',
 					'%d'
 				),
-				array( '%d' )
+				array('%d')
 			);
 
 		}
 
 		// handle order items
 		$order_items = $order->get_items();
-		if ( ! empty( $order_items ) ) {
-			foreach ( $order_items as $order_item ) {
+		if ( ! empty($order_items)) {
+			foreach ($order_items as $order_item) {
 
 				// check if this order item exists in DB already
 				$order_item_id = $order_item->get_id();
-				if ( empty( $order_item_id ) ) {
+				if (empty($order_item_id)) {
 
 					// insert new order item
 					$wpdb->insert(
@@ -446,7 +446,7 @@ 
 						)
 					);
 
-					$order_item->set_id( $wpdb->insert_id );
+					$order_item->set_id($wpdb->insert_id);
 				} else {
 
 					// update existing order item record
@@ -462,7 +462,7 @@ 
 							'subtotal'    => $order_item->get_subtotal(),
 							'total'       => $order_item->get_total()
 						),
-						array( 'id' => $order_item_id ),
+						array('id' => $order_item_id),
 						array(
 							'%d',
 							'%s',
@@ -473,7 +473,7 @@ 
 							'%d',
 							'%d',
 						),
-						array( '%d' )
+						array('%d')
 					);
 
 				}
@@ -482,25 +482,25 @@ 
 
 		// handle transactions
 		$transactions = $order->get_transactions();
-		if ( ! empty( $transactions ) ) {
+		if ( ! empty($transactions)) {
 
 			/** @var Transaction\OrderTransaction $transaction */
-			foreach ( $transactions as $transaction ) {
+			foreach ($transactions as $transaction) {
 
 				$transaction_id = $transaction->get_id();
 
 				$transaction_date_created = null;
-				if ( null !== $transaction->get_date_created() ) {
-					$transaction_date_created = $transaction->get_date_created()->format( 'Y-m-d H:i:s' );
+				if (null !== $transaction->get_date_created()) {
+					$transaction_date_created = $transaction->get_date_created()->format('Y-m-d H:i:s');
 				}
 
 				$transaction_date_modified = null;
-				if ( null !== $transaction->get_date_modified() ) {
-					$transaction_date_modified = $transaction->get_date_modified()->format( 'Y-m-d H:i:s' );
+				if (null !== $transaction->get_date_modified()) {
+					$transaction_date_modified = $transaction->get_date_modified()->format('Y-m-d H:i:s');
 				}
 
 				// check if it's a new transaction or an existing one
-				if ( empty( $transaction_id ) ) {
+				if (empty($transaction_id)) {
 
 					// it's a new transaction
 
@@ -531,7 +531,7 @@ 
 					);
 
 
-					$transaction->set_id( $wpdb->insert_id );
+					$transaction->set_id($wpdb->insert_id);
 
 				} else {
 
@@ -550,7 +550,7 @@ 
 							'processor_transaction_id' => $transaction->get_processor_transaction_id(),
 							'processor_status'         => $transaction->get_processor_status()
 						),
-						array( 'id' => $transaction_id ),
+						array('id' => $transaction_id),
 						array(
 							'%d',
 							'%s',
@@ -562,7 +562,7 @@ 
 							'%s',
 							'%s'
 						),
-						array( '%d' )
+						array('%d')
 					);
 
 				}