Refactor product issues

src/API/Google/MerchantReport.php

@@ -98,6 +98,7 @@ public function get_product_view_report( $next_page_token = null ): array {
 				}
 
 				$product_view_data['statuses'][ $wc_product_id ] = [
+					'mc_id'           => $product_view->getId(),
 					'product_id'      => $wc_product_id,
 					'status'          => $mc_product_status,
 					'expiration_date' => $this->convert_shopping_content_date( $product_view->getExpirationDate() ),

src/DB/Table/MerchantIssueTable.php

@@ -61,6 +61,17 @@
 		$this->wpdb->query( $this->wpdb->prepare( $query, $created_before->format( 'Y-m-d H:i:s' ) ) ); // phpcs:ignore WordPress.DB.PreparedSQL
 	}
 
+	/**
+	 * Delete product issues for specific products and source.
+	 *
+	 * @param array  $products_ids Array of product IDs to delete issues for.
+	 * @param string $source       The source of the issues. Default is 'mc'.
+	 */
+	public function delete_specific_product_issues( array $products_ids, string $source = 'mc' ) {
+		$placeholder = '(' . implode( ',', array_fill( 0, count( $products_ids ), '%d' ) ) . ')';
+		$this->wpdb->query( $this->wpdb->prepare( "DELETE FROM `{$this->get_sql_safe_name()}` WHERE `product_id` IN {$placeholder} AND `source` = %s", array_merge( $products_ids, [ $source ] ) ) ); // phpcs:ignore WordPress.DB.PreparedSQL
+	}
+
 	/**
 	 * Get the columns for the table.
 	 *

src/Jobs/UpdateMerchantProductStatuses.php

@@ -88,8 +88,7 @@ public function process_items( array $items ) {
 
 			// Clear the cache if we're starting from the beginning.
 			if ( ! $next_page_token ) {
-				$this->merchant_statuses->clear_cache();
-				$this->merchant_statuses->delete_product_statuses_count_intermediate_data();
+				$this->merchant_statuses->clear_product_statuses_cache_and_issues();
 			}
 
 			$results         = $this->merchant_report->get_product_view_report( $next_page_token );