Fix incorrect product statistics count

src/Jobs/DeleteProducts.php

@@ -37,11 +37,6 @@ public function get_name(): string {
 	 * @throws ProductSyncerException If an error occurs. The exception will be logged by ActionScheduler.
 	 */
 	public function process_items( array $product_id_map ) {
-		$ready_ids = $this->product_repository->find_delete_product_ids( $product_id_map );
-
-		// Exclude any ID's which are not ready to delete.
-		$product_id_map = array_intersect( $product_id_map, $ready_ids );
-
 		$product_entries = BatchProductIDRequestEntry::create_from_id_map( new ProductIDMap( $product_id_map ) );
 		$this->product_syncer->delete_by_batch_requests( $product_entries );
 	}

src/MerchantCenter/MerchantStatuses.php

@@ -350,7 +350,7 @@ protected function filter_valid_statuses( array $google_ids ): array {
 				continue;
 			}
 
-			$wc_product = get_post( $wc_product_id );
+			$wc_product = $product_helper->get_wc_product_by_wp_post( $wc_product_id );
 			if ( ! $wc_product || 'product' !== substr( $wc_product->post_type, 0, 7 ) ) {
 				// Should never reach here since the products IDS are retrieved from postmeta.
 				do_action(
@@ -599,24 +599,67 @@ protected function sum_status_counts( array $validated_mc_statuses ): void {
 	}
 
 	/**
-	 * Calculate the product status statistics and update the transient.
+	 * Calculate the synced product status statistics. It will group
+	 * the variations for the same parent.
+	 *
+	 * For the case that one variation is approved and the other disapproved:
+	 * 1. Give each status a priority.
+	 * 2. Store the last highest priority status in `$parent_statuses`.
+	 * 3. Compare if a higher priority status is found for that variable product.
+	 * 4. Loop through the `$parent_statuses` array at the end to add the final status counts.
+	 *
+	 * @return array Product status statistics.
 	 */
-	protected function update_mc_statuses() {
+	protected function calculate_synced_product_statistics(): array {
 		$product_statistics = [
 			MCStatus::APPROVED           => 0,
 			MCStatus::PARTIALLY_APPROVED => 0,
 			MCStatus::EXPIRING           => 0,
 			MCStatus::PENDING            => 0,
 			MCStatus::DISAPPROVED        => 0,
-			MCSTATUS::NOT_SYNCED         => 0,
+			MCStatus::NOT_SYNCED         => 0,
+		];
+
+		$product_statistics_priority = [
+			MCStatus::APPROVED           => 6,
+			MCStatus::PARTIALLY_APPROVED => 5,
+			MCStatus::EXPIRING           => 4,
+			MCStatus::PENDING            => 3,
+			MCStatus::DISAPPROVED        => 2,
+			MCStatus::NOT_SYNCED         => 1,
 		];
 
-		foreach ( $this->product_statuses['products'] as $statuses ) {
+		$parent_statuses = [];
+
+		foreach ( $this->product_statuses['products'] as $product_id => $statuses ) {
 			foreach ( $statuses as $status => $num_products ) {
-				$product_statistics[ $status ] += $num_products;
+				$parent_id = $this->product_data_lookup[ $product_id ]['parent_id'];
+				if ( ! $parent_id ) {
+					$product_statistics[ $status ] += $num_products;
+				} elseif ( ! isset( $parent_statuses[ $parent_id ] ) ) {
+					$parent_statuses[ $parent_id ] = $status;
+				} else {
+					$current_parent_status = $parent_statuses[ $parent_id ];
+					if ( $product_statistics_priority[ $status ] < $product_statistics_priority[ $current_parent_status ] ) {
+						$parent_statuses[ $parent_id ] = $status;
+					}
+				}
 			}
 		}
 
+		foreach ( $parent_statuses as $parent_status ) {
+			$product_statistics[ $parent_status ] += 1;
+		}
+
+		return $product_statistics;
+	}
+
+	/**
+	 * Calculate the product status statistics and update the transient.
+	 */
+	protected function update_mc_statuses() {
+		$product_statistics = $this->calculate_synced_product_statistics();
+
 		/** @var ProductRepository $product_repository */
 		$product_repository                         = $this->container->get( ProductRepository::class );
 		$product_statistics[ MCStatus::NOT_SYNCED ] = count( $product_repository->find_mc_not_synced_product_ids() );

src/Product/ProductHelper.php

@@ -14,6 +14,7 @@
 use Google\Service\ShoppingContent\Product as GoogleProduct;
 use WC_Product;
 use WC_Product_Variation;
+use WP_Post;
 
 defined( 'ABSPATH' ) || exit;
 
@@ -289,6 +290,17 @@ public function get_wc_product( int $product_id ): WC_Product {
 		return $this->wc->get_product( $product_id );
 	}
 
+	/**
+	 * Get WooCommerce product by WP get_post
+	 *
+	 * @param int $product_id
+	 *
+	 * @return WP_Post
+	 */
+	public function get_wc_product_by_wp_post( int $product_id ): WP_Post {
+		return get_post( $product_id );
+	}
+
 	/**
 	 * @param WC_Product $product
 	 *

src/Product/ProductRepository.php

@@ -6,7 +6,7 @@
 use Automattic\WooCommerce\GoogleListingsAndAds\Infrastructure\Service;
 use Automattic\WooCommerce\GoogleListingsAndAds\PluginHelper;
 use Automattic\WooCommerce\GoogleListingsAndAds\Value\ChannelVisibility;
-use Automattic\WooCommerce\GoogleListingsAndAds\Value\MCStatus;
+use Automattic\WooCommerce\GoogleListingsAndAds\Value\SyncStatus;
 use WC_Product;
 
 defined( 'ABSPATH' ) || exit;
@@ -81,12 +81,13 @@ public function find_ids( array $args = [], int $limit = -1, int $offset = 0 ):
 	 * Find and return an array of WooCommerce product objects based on the provided product IDs.
 	 *
 	 * @param int[] $ids    Array of WooCommerce product IDs
+	 * @param array $args   Array of WooCommerce args (except 'return'), and product metadata.
 	 * @param int   $limit  Maximum number of results to retrieve or -1 for unlimited.
 	 * @param int   $offset Amount to offset product results.
 	 *
 	 * @return WC_Product[] Array of WooCommerce product objects
 	 */
-	public function find_by_ids( array $ids, int $limit = -1, int $offset = 0 ): array {
+	public function find_by_ids( array $ids, array $args = [], int $limit = -1, int $offset = 0 ): array {
 		$args['include'] = $ids;
 
 		return $this->find( $args, $limit, $offset );
@@ -163,7 +164,8 @@ public function find_sync_ready_products( array $args = [], int $limit = - 1, in
 	 * @return array
 	 */
 	public function find_delete_product_ids( array $ids, int $limit = - 1, int $offset = 0 ): array {
-		$results = $this->find_by_ids( $ids, $limit, $offset );
+		$args    = [ 'status' => 'trash' ];
+		$results = $this->find_by_ids( $ids, $args, $limit, $offset );
 		return $this->product_filter->filter_products_for_delete( $results )->get_product_ids();
 	}
 
@@ -264,9 +266,9 @@ public function find_mc_not_synced_product_ids( int $limit = -1, int $offset = 0
 			'type'       => $types,
 			'meta_query' => [
 				[
-					'key'     => ProductMetaHandler::KEY_MC_STATUS,
-					'compare' => '=',
-					'value'   => MCStatus::NOT_SYNCED,
+					'key'     => ProductMetaHandler::KEY_SYNC_STATUS,
+					'compare' => '!=',
+					'value'   => SyncStatus::SYNCED,
 				],
 			],
 		];