Ubuntu

coupon_helper = $coupon_helper; $this->job_repository = $job_repository; $this->merchant_center = $merchant_center; $this->notifications_service = $notifications_service; $this->wc = $wc; $this->wp = $wp; } /** * Register a service. */ public function register(): void { // only register the hooks if Merchant Center is set up correctly. if ( ! $this->merchant_center->is_ready_for_syncing() ) { return; } // when a coupon is added / updated, schedule a update job. add_action( 'woocommerce_new_coupon', [ $this, 'update_by_id' ], 90, 2 ); add_action( 'woocommerce_update_coupon', [ $this, 'update_by_id' ], 90, 2 ); add_action( 'woocommerce_gla_bulk_update_coupon', [ $this, 'update_by_id' ], 90 ); // when a coupon is trashed or removed, schedule a delete job. add_action( 'wp_trash_post', [ $this, 'pre_delete' ], 90 ); add_action( 'before_delete_post', [ $this, 'pre_delete' ], 90 ); add_action( 'trashed_post', [ $this, 'delete_by_id' ], 90 ); add_action( 'deleted_post', [ $this, 'delete_by_id' ], 90 ); add_action( 'woocommerce_delete_coupon', [ $this, 'delete_by_id' ], 90, 2 ); add_action( 'woocommerce_trash_coupon', [ $this, 'delete_by_id' ], 90, 2 ); // when a coupon is restored from trash, schedule a update job. add_action( 'untrashed_post', [ $this, 'update_by_id' ], 90 ); // Update coupons when object terms get updated. add_action( 'set_object_terms', [ $this, 'maybe_update_by_id_when_terms_updated' ], 90, 6 ); } /** * Update a coupon by the ID * * @param int $coupon_id */ public function update_by_id( int $coupon_id ) { $coupon = $this->wc->maybe_get_coupon( $coupon_id ); if ( $coupon instanceof WC_Coupon ) { $this->handle_update_coupon( $coupon ); } } /** * Update a coupon by the ID when the terms get updated. * * @param int $object_id The object ID. * @param array $terms An array of object term IDs or slugs. * @param array $tt_ids An array of term taxonomy IDs. * @param string $taxonomy The taxonomy slug. * @param bool $append Whether to append new terms to the old terms. * @param array $old_tt_ids Old array of term taxonomy IDs. */ public function maybe_update_by_id_when_terms_updated( int $object_id, array $terms, array $tt_ids, string $taxonomy, bool $append, array $old_tt_ids ) { $this->handle_update_coupon_when_product_brands_updated( $taxonomy, $tt_ids, $old_tt_ids ); } /** * Delete a coupon by the ID * * @param int $coupon_id */ public function delete_by_id( int $coupon_id ) { $this->handle_delete_coupon( $coupon_id ); } /** * Pre Delete a coupon by the ID * * @param int $coupon_id */ public function pre_delete( int $coupon_id ) { $this->handle_pre_delete_coupon( $coupon_id ); } /** * Handle updating of a coupon. * * @param WC_Coupon $coupon * The coupon being saved. * * @return void */ protected function handle_update_coupon( WC_Coupon $coupon ) { $coupon_id = $coupon->get_id(); if ( $this->notifications_service->is_ready( NotificationsService::DATATYPE_COUPON ) ) { $this->handle_update_coupon_notification( $coupon ); } // Only proceed with coupon syncing if PUSH is enabled for this data type if ( ! $this->merchant_center->is_enabled_for_datatype( NotificationsService::DATATYPE_COUPON ) ) { return; } // Schedule an update job if product sync is enabled. if ( $this->coupon_helper->is_sync_ready( $coupon ) ) { $this->coupon_helper->mark_as_pending( $coupon ); $this->job_repository->get( UpdateCoupon::class )->schedule( [ [ $coupon_id ], ] ); } elseif ( $this->coupon_helper->is_coupon_synced( $coupon ) ) { // Delete the coupon from Google Merchant Center if it's already synced BUT it is not sync ready after the edit. $coupon_to_delete = new DeleteCouponEntry( $coupon_id, $this->get_coupon_to_delete( $coupon ), $this->coupon_helper->get_synced_google_ids( $coupon ) ); $this->job_repository->get( DeleteCoupon::class )->schedule( [ $coupon_to_delete, ] ); do_action( 'woocommerce_gla_debug_message', sprintf( 'Deleting coupon (ID: %s) from Google Merchant Center because it is not ready to be synced.', $coupon->get_id() ), __METHOD__ ); } else { $this->coupon_helper->mark_as_unsynced( $coupon ); } } /** * Create request entries for the coupon (containing its Google ID), * so we can schedule a delete job when it is actually trashed / deleted. * * @param int $coupon_id */ protected function handle_pre_delete_coupon( int $coupon_id ) { $coupon = $this->wc->maybe_get_coupon( $coupon_id ); // Only proceed with coupon deletion if PUSH is enabled for this data type if ( ! $this->merchant_center->is_enabled_for_datatype( NotificationsService::DATATYPE_COUPON ) ) { return; } if ( $coupon instanceof WC_Coupon && $this->coupon_helper->is_coupon_synced( $coupon ) ) { $this->delete_requests_map[ $coupon_id ] = new DeleteCouponEntry( $coupon_id, $this->get_coupon_to_delete( $coupon ), $this->coupon_helper->get_synced_google_ids( $coupon ) ); } } /** * @param WC_Coupon $coupon * * @return WCCouponAdapter */ protected function get_coupon_to_delete( WC_Coupon $coupon ): WCCouponAdapter { $adapted_coupon_to_delete = new WCCouponAdapter( [ 'wc_coupon' => $coupon, ] ); // Promotion stored in Google can only be soft-deleted to keep historical records. // Instead of 'delete', we update the promotion with effective dates expired. // Here we reset an expiring date based on WooCommerce coupon source. $adapted_coupon_to_delete->disable_promotion( $coupon ); return $adapted_coupon_to_delete; } /** * Handle deleting of a coupon. * * @param int $coupon_id */ protected function handle_delete_coupon( int $coupon_id ) { if ( $this->notifications_service->is_ready( NotificationsService::DATATYPE_COUPON ) ) { $this->maybe_send_delete_notification( $coupon_id ); } // Only proceed with coupon deletion if PUSH is enabled for this data type if ( ! $this->merchant_center->is_enabled_for_datatype( NotificationsService::DATATYPE_COUPON ) ) { return; } if ( ! isset( $this->delete_requests_map[ $coupon_id ] ) ) { return; } $coupon_to_delete = $this->delete_requests_map[ $coupon_id ]; if ( ! empty( $coupon_to_delete->get_synced_google_ids() ) && ! $this->is_already_scheduled_to_delete( $coupon_id ) ) { $this->job_repository->get( DeleteCoupon::class )->schedule( [ $coupon_to_delete, ] ); $this->set_already_scheduled_to_delete( $coupon_id ); } } /** * Send the notification for coupon deletion * * @since 2.8.0 * @param int $coupon_id */ protected function maybe_send_delete_notification( int $coupon_id ): void { $coupon = $this->wc->maybe_get_coupon( $coupon_id ); if ( $coupon instanceof WC_Coupon && $this->coupon_helper->should_trigger_delete_notification( $coupon ) ) { $this->coupon_helper->set_notification_status( $coupon, NotificationStatus::NOTIFICATION_PENDING_DELETE ); $this->job_repository->get( CouponNotificationJob::class )->schedule( [ 'item_id' => $coupon->get_id(), 'topic' => NotificationsService::TOPIC_COUPON_DELETED, ] ); } } /** * * @param int $coupon_id * @param string $schedule_type * * @return bool */ protected function is_already_scheduled( int $coupon_id, string $schedule_type ): bool { return isset( $this->already_scheduled[ $coupon_id ] ) && $this->already_scheduled[ $coupon_id ] === $schedule_type; } /** * * @param int $coupon_id * * @return bool */ protected function is_already_scheduled_to_update( int $coupon_id ): bool { return $this->is_already_scheduled( $coupon_id, self::SCHEDULE_TYPE_UPDATE ); } /** * * @param int $coupon_id * * @return bool */ protected function is_already_scheduled_to_delete( int $coupon_id ): bool { return $this->is_already_scheduled( $coupon_id, self::SCHEDULE_TYPE_DELETE ); } /** * * @param int $coupon_id * @param string $schedule_type * * @return void */ protected function set_already_scheduled( int $coupon_id, string $schedule_type ): void { $this->already_scheduled[ $coupon_id ] = $schedule_type; } /** * * @param int $coupon_id * * @return void */ protected function set_already_scheduled_to_update( int $coupon_id ): void { $this->set_already_scheduled( $coupon_id, self::SCHEDULE_TYPE_UPDATE ); } /** * * @param int $coupon_id * * @return void */ protected function set_already_scheduled_to_delete( int $coupon_id ): void { $this->set_already_scheduled( $coupon_id, self::SCHEDULE_TYPE_DELETE ); } /** * Schedules notifications for an updated coupon * * @param WC_Coupon $coupon */ protected function handle_update_coupon_notification( WC_Coupon $coupon ) { if ( $this->coupon_helper->should_trigger_create_notification( $coupon ) ) { $this->coupon_helper->set_notification_status( $coupon, NotificationStatus::NOTIFICATION_PENDING_CREATE ); $this->job_repository->get( CouponNotificationJob::class )->schedule( [ 'item_id' => $coupon->get_id(), 'topic' => NotificationsService::TOPIC_COUPON_CREATED, ] ); } elseif ( $this->coupon_helper->should_trigger_update_notification( $coupon ) ) { $this->coupon_helper->set_notification_status( $coupon, NotificationStatus::NOTIFICATION_PENDING_UPDATE ); $this->job_repository->get( CouponNotificationJob::class )->schedule( [ 'item_id' => $coupon->get_id(), 'topic' => NotificationsService::TOPIC_COUPON_UPDATED, ] ); } elseif ( $this->coupon_helper->should_trigger_delete_notification( $coupon ) ) { $this->coupon_helper->set_notification_status( $coupon, NotificationStatus::NOTIFICATION_PENDING_DELETE ); $this->job_repository->get( CouponNotificationJob::class )->schedule( [ 'item_id' => $coupon->get_id(), 'topic' => NotificationsService::TOPIC_COUPON_DELETED, ] ); } } /** * If product to brands relationship is updated, update the coupons that are related to the brands. * * @param string $taxonomy The taxonomy slug. * @param array $tt_ids An array of term taxonomy IDs. * @param array $old_tt_ids Old array of term taxonomy IDs. */ protected function handle_update_coupon_when_product_brands_updated( string $taxonomy, array $tt_ids, array $old_tt_ids ) { if ( 'product_brand' !== $taxonomy ) { return; } // Convert term taxonomy IDs to integers. $tt_ids = array_map( 'intval', $tt_ids ); $old_tt_ids = array_map( 'intval', $old_tt_ids ); // Find the difference between the new and old term taxonomy IDs. $diff1 = array_diff( $tt_ids, $old_tt_ids ); $diff2 = array_diff( $old_tt_ids, $tt_ids ); $diff = array_merge( $diff1, $diff2 ); if ( empty( $diff ) ) { return; } // Serialize the diff to use in the meta query. // This is needed because the meta value is serialized. $serialized_diff = maybe_serialize( $diff ); $args = [ 'post_type' => 'shop_coupon', 'meta_query' => [ 'relation' => 'OR', [ 'key' => 'product_brands', 'value' => $serialized_diff, 'compare' => 'LIKE', ], [ 'key' => 'exclude_product_brands', 'value' => $serialized_diff, 'compare' => 'LIKE', ], ], ]; // Get coupon posts based on the above query args. $posts = $this->wp->get_posts( $args ); if ( empty( $posts ) ) { return; } foreach ( $posts as $post ) { $this->update_by_id( $post->ID ); } } }