diff --git a/includes/class-initializer.php b/includes/class-initializer.php index 2734ee34..816bfe26 100644 --- a/includes/class-initializer.php +++ b/includes/class-initializer.php @@ -51,6 +51,7 @@ public static function init() { Synchronize_All::init(); Data_Backfill::init(); + Misc::init(); Membership_Dedupe::init(); Woocommerce_Memberships\Admin::init(); diff --git a/includes/cli/class-misc.php b/includes/cli/class-misc.php new file mode 100644 index 00000000..6c14a12b --- /dev/null +++ b/includes/cli/class-misc.php @@ -0,0 +1,820 @@ + [ // phpcs:ignore WordPress.DB.SlowDBQuery.slow_db_query_meta_query + 'relation' => 'OR', + [ + 'key' => 'wp_capabilities', + 'compare' => 'NOT EXISTS', + ], + [ + 'key' => 'wp_capabilities', + 'value' => 'a:0:{}', + 'compare' => '=', + ], + ], + ] + ); + } + WP_CLI::line( 'Got ' . count( $users_to_update ) . ' users to update.' ); + WP_CLI::line( '' ); + + foreach ( $users_to_update as $user ) { + // If read from CSV, find the user by email. + if ( is_array( $user ) ) { + $user_email = $user['user_email']; + $user = get_user_by( 'email', $user_email ); + if ( $user === false ) { + WP_CLI::warning( 'User not found by email: ' . $user_email ); + continue; + } + } + $user_id = $user->ID; + $role = 'subscriber'; + // If the user has the newspack_remote_site meta, it's a network user. + $remote_site = get_user_meta( $user_id, \Newspack_Network\Utils\Users::USER_META_REMOTE_SITE, true ); + if ( $remote_site ) { + $role = NEWSPACK_NETWORK_READER_ROLE; + } + if ( $live ) { + $user->set_role( $role ); + WP_CLI::line( "šŸ‘‰ Assigned '$role' role to user $user->user_email (#$user_id)." ); + } else { + WP_CLI::line( "šŸ‘‰ In live mode, would assign '$role' role to user $user->user_email (#$user_id)." ); + } + } + + WP_CLI::line( '' ); + } + + /** + * Get user memberships. + * + * @param array $args Indexed array of args. + * @param array $assoc_args Associative array of args. + * @return void + * + * ## EXAMPLES + * + * wp newspack-network get-user-memberships member-name@example.com + */ + public static function get_user_memberships( array $args, array $assoc_args ) { + WP_CLI::line( '' ); + + $email_address = isset( $args[0] ) ? $args[0] : false; + if ( ! $email_address ) { + WP_CLI::error( 'Please provide an email address.' ); + } + + $memberships = \wc_memberships_get_user_memberships( get_user_by( 'email', $email_address ) ); + foreach ( $memberships as $membership ) { + $plan_name = $membership->get_plan()->get_name(); + $plan_network_id = get_post_meta( $membership->get_plan()->get_id(), \Newspack_Network\Woocommerce_Memberships\Admin::NETWORK_ID_META_KEY, true ); + if ( $plan_network_id ) { + $plan_name .= ' (Network ID: ' . $plan_network_id . ')'; + } + + WP_CLI::line( 'āž” Membership ID: ' . $membership->get_id() . ', status: ' . $membership->get_status() . ', plan: ' . $plan_name ); + $subscription = ( new \WC_Memberships_Integration_Subscriptions_User_Membership( $membership->post ) )->get_subscription(); + if ( $subscription ) { + WP_CLI::line( sprintf( ' āž” linked with %s subscription #%d for amount: %d', $subscription->get_status(), $subscription->get_id(), $subscription->get_total() ) ); + } + } + + WP_CLI::line( '' ); + } + + /** + * Fix registration-based memberships. All registered users should have a membership if it's + * set to be created on registration. + * + * @param array $args Indexed array of args. + * @param array $assoc_args Associative array of args. + * @return void + * + * ## OPTIONS + * + * [--live] + * : Run the command in live mode, updating the users. + * + * [--verbose] + * : More output. + * + * ## EXAMPLES + * + * wp newspack-network fix-registration-based-memberships + */ + public static function fix_registration_based_memberships( array $args, array $assoc_args ) { + WP_CLI::line( '' ); + + $live = isset( $assoc_args['live'] ) ? true : false; + $verbose = isset( $assoc_args['verbose'] ) ? true : false; + if ( $live ) { + WP_CLI::line( 'Live mode ā€“ memberships will be created.' ); + } else { + WP_CLI::line( 'Dry run ā€“ memberships will not be created. Use --live flag to run in live mode.' ); + } + WP_CLI::line( '' ); + + global $wpdb; + $user_emails_with_ids = $wpdb->get_results( 'SELECT ID, user_email FROM wp_users WHERE user_email != ""' ); // phpcs:ignore WordPress.DB.DirectDatabaseQuery.DirectQuery, WordPress.DB.DirectDatabaseQuery.NoCaching + // Turn it into an associative array, keyed by email. + $user_emails_with_ids = array_combine( + array_map( + function( $user ) { + return $user->user_email; + }, + $user_emails_with_ids + ), + array_map( + function( $user ) { + return $user->ID; + }, + $user_emails_with_ids + ) + ); + $user_emails = array_keys( $user_emails_with_ids ); + + WP_CLI::line( 'Found ' . count( $user_emails ) . ' users.' ); + WP_CLI::line( '' ); + + // Get the registration-based memberships. + $plans = \wc_memberships_get_membership_plans(); + foreach ( $plans as $plan ) { + if ( $plan->get_access_method() === 'signup' ) { + $memberships = $plan->get_memberships(); + + WP_CLI::line( 'Found ' . count( $memberships ) . ' memberships for plan ' . $plan->get_name() . '.' ); + + // Get email addresses of all members. + foreach ( $memberships as $membership ) { + $user_id = $membership->get_user_id(); + // Get user email directly from the DB for performance reasons. + $user_email = $wpdb->get_var( // phpcs:ignore WordPress.DB.DirectDatabaseQuery.DirectQuery, WordPress.DB.DirectDatabaseQuery.NoCaching + $wpdb->prepare( + 'SELECT user_email FROM wp_users WHERE ID = %d', + $user_id + ) + ); + if ( $user_email ) { + // Remove this user from the list of all users. + $key = array_search( $user_email, $user_emails ); + if ( $key !== false ) { + unset( $user_emails[ $key ] ); + } + } + } + + if ( count( $user_emails ) > 0 ) { + if ( $live ) { + WP_CLI::line( 'Will create memberships for the ' . count( $user_emails ) . ' missing users.' ); + } else { + WP_CLI::line( 'Would create memberships for the ' . count( $user_emails ) . ' missing users in live mode.' ); + } + WP_CLI::line( '' ); + foreach ( $user_emails as $email ) { + // Create the membership for the user. + $user_id = $user_emails_with_ids[ $email ]; + if ( $verbose ) { + if ( $live ) { + WP_CLI::line( "Creating membership for user $email (#$user_id)." ); + } else { + WP_CLI::line( "Would create membership for user $email (#$user_id)." ); + } + } + if ( $live ) { + wc_memberships_create_user_membership( + [ + 'plan_id' => $plan->get_id(), + 'user_id' => $user_id, + ] + ); + } + } + } + } + } + + WP_CLI::line( '' ); + } + + /** + * Fix membership discrepancies. + * + * @param array $args Indexed array of args. + * @param array $assoc_args Associative array of args. + * @return void + * + * ## OPTIONS + * + * [--live] + * : Run the command in live mode, updating the users. + * + * ## EXAMPLES + * + * wp newspack-network fix-membership-discrepancies + */ + public static function fix_membership_discrepancies( array $args, array $assoc_args ) { + WP_CLI::line( '' ); + + $live = isset( $assoc_args['live'] ) ? true : false; + if ( $live ) { + WP_CLI::line( 'Live mode ā€“ memberships will be updated or created.' ); + } else { + WP_CLI::line( 'Dry run ā€“ memberships will not be updated. Use --live flag to run in live mode.' ); + } + + $membership_plans_from_network_data = \Newspack_Network\Hub\Admin\Membership_Plans::get_membership_plans_from_network(); + if ( ! isset( $membership_plans_from_network_data['discrepancies_emails'] ) ) { + WP_CLI::error( 'Missing discrepancies emails in network memberships data.' ); + } + WP_CLI::line( sprintf( 'Found %d discrepant email(s).', count( $membership_plans_from_network_data['discrepancies_emails'] ) ) ); + $by_origin_site = []; + foreach ( $membership_plans_from_network_data['discrepancies_emails'] as $email_address ) { + $user = get_user_by( 'email', $email_address ); + if ( ! $user ) { + WP_CLI::warning( 'User not found by email: ' . $email_address ); + continue; + } + $origin_site = get_user_meta( $user->ID, \Newspack_Network\Utils\Users::USER_META_REMOTE_SITE, true ); + if ( ! $origin_site ) { + $origin_site = 'hub'; + } + if ( isset( $by_origin_site[ $origin_site ] ) ) { + $by_origin_site[ $origin_site ][] = $email_address; + } else { + $by_origin_site[ $origin_site ] = [ $email_address ]; + } + } + + WP_CLI::line( '' ); + foreach ( $by_origin_site as $site_url => $user_emails ) { + WP_CLI::line( sprintf( 'Found %d user(s) originating from site %s', count( $user_emails ), $site_url ) ); + + foreach ( $user_emails as $user_email ) { + WP_CLI::line( sprintf( 'Fixing %sā€¦', $user_email ) ); + + if ( $site_url === 'hub' ) { + $found_memberships = \Newspack_Network\Woocommerce_Memberships\Admin::get_memberships_by_user_email_with_plan_network_id( $user_email ); + } else { + $found_memberships = \Newspack_Network\Hub\Admin\Membership_Plans::fetch_collection_from_api( + \Newspack_Network\Hub\Nodes::get_node_by_url( $site_url ), + 'wc/v2/memberships/members', + 'memberships', + [ + 'customer' => urlencode( $user_email ), + ] + ); + } + + if ( ! $found_memberships ) { + WP_CLI::warning( 'Could not retrieve any user memberships.' ); + continue; + } + foreach ( $found_memberships as $membership ) { + if ( ! $membership->plan_network_id ) { + continue; + } + WP_CLI::line( sprintf( 'Found membership #%d with status %s.', $membership->id, $membership->status ) ); + $membership_data = [ + 'email' => $user_email, + 'user_id' => $membership->customer_id, + 'plan_network_id' => $membership->plan_network_id, + 'membership_id' => $membership->id, + 'new_status' => $membership->status, + ]; + $timestamp = false; + switch ( $membership->status ) { + case 'paused': + $timestamp = strtotime( $membership->paused_date ); + break; + case 'cancelled': + $timestamp = strtotime( $membership->cancelled_date ); + break; + case 'expired': + $timestamp = strtotime( $membership->end_date ); + break; + } + + if ( ! $timestamp ) { + $timestamp = strtotime( $membership->start_date ); + } + + $event = new \Newspack_Network\Incoming_Events\Woocommerce_Membership_Updated( $site_url, $membership_data, $timestamp ); + + if ( $live ) { + if ( Site_Role::is_hub() ) { + $event->process_in_hub(); + if ( $event->is_persisted ) { + WP_CLI::success( 'Created and processed event.' ); + } else { + WP_CLI::warning( 'Event not persisted, possibly a duplicate.' ); + } + Data_Backfill::increment_results_counter( $event->get_action_name(), $event->is_persisted ? 'processed' : 'duplicate' ); + } else { + \Newspack\Data_Events\Webhooks::handle_dispatch( $event->get_action_name(), $event->get_timestamp(), $event->get_data() ); + WP_CLI::success( 'Dispatched webhook.' ); + } + } else { + WP_CLI::line( 'Would create and process the event in live mode.' ); + } + } + } + WP_CLI::line( '' ); + } + + WP_CLI::line( '' ); + } + + /** + * Display user discrepancies. + * + * @param array $args Indexed array of args. + * @param array $assoc_args Associative array of args. + * @return void + * + * ## EXAMPLES + * + * wp newspack-network display-user-discrepancies + */ + public static function display_user_discrepancies( array $args, array $assoc_args ) { + WP_CLI::line( '' ); + + if ( ! Site_Role::is_hub() ) { + WP_CLI::error( 'This command can only be run on the Hub.' ); + } + + $user_emails_on_hub = \Newspack_Network\Utils\Users::get_synchronized_users_emails(); + WP_CLI::line( sprintf( 'Found %d synchronizable user(s) on the Hub.', count( $user_emails_on_hub ) ) ); + $user_not_synced_emails_on_hub = \Newspack_Network\Utils\Users::get_not_synchronized_users_emails(); + WP_CLI::line( sprintf( 'Found %d synchronizable user(s) on the Hub.', count( $user_not_synced_emails_on_hub ) ) ); + $no_role_users_emails = \Newspack_Network\Utils\Users::get_no_role_users_emails(); + WP_CLI::line( sprintf( 'Found %d no-role user(s) on the Hub.', count( $no_role_users_emails ) ) ); + + WP_CLI::line( '' ); + + $nodes = \Newspack_Network\Hub\Nodes::get_all_nodes(); + $users_by_site = [ + 'hub' => [ + 'not_synced' => $user_not_synced_emails_on_hub, + 'no_role' => $no_role_users_emails, + 'synced' => $user_emails_on_hub, + ], + ]; + $all_discrepant_emails = []; + foreach ( $nodes as $node ) { + $url = $node->get_url(); + + $site_info = $node->get_site_info(); + if ( $site_info === null ) { + WP_CLI::warning( 'Missing user data for site ' . $url ); + WP_CLI::line( '' ); + continue; + } + + $users_by_site[ $url ] = [ + 'not_synced' => $site_info->not_sync_users_emails, + 'no_role' => $site_info->no_role_users_emails, + 'synced' => $site_info->sync_users_emails, + ]; + + // Users who are on the Hub but not on the Node. + $not_on_node = array_diff( $user_emails_on_hub, $site_info->sync_users_emails ); + // Users who are not on the Node but are on the Hub. + $not_on_hub = array_diff( $site_info->sync_users_emails, $user_emails_on_hub ); + WP_CLI::line( 'Site: ' . $url ); + WP_CLI::line( + sprintf( '%1$d on the Hub only, %2$d on Node only', count( $not_on_hub ), count( $not_on_node ) ) + ); + WP_CLI::line( sprintf( 'Found %d no-role user(s).', count( $site_info->no_role_users_emails ) ) ); + + $unique_synced_email_addresses = array_unique( $site_info->sync_users_emails ); + WP_CLI::line( sprintf( 'Found %d synced email addresses (%d unique).', count( $site_info->sync_users_emails ), count( $unique_synced_email_addresses ) ) ); + if ( in_array( '', $site_info->sync_users_emails ) ) { + WP_CLI::warning( 'Empty email address found.' ); + } + if ( count( $unique_synced_email_addresses ) !== count( $site_info->sync_users_emails ) ) { + $counts = array_count_values( $site_info->sync_users_emails ); + foreach ( $counts as $email => $count ) { + if ( $count > 1 ) { + WP_CLI::warning( 'Duplicate email address: ' . $email ); + } + } + } + + $all_discrepant_emails = array_unique( array_merge( $all_discrepant_emails, $not_on_node, $not_on_hub ) ); + + WP_CLI::line( '' ); + } + + WP_CLI::line( 'Unique discrepant emails in total: ' . count( $all_discrepant_emails ) ); + WP_CLI::line( '' ); + + $users_to_handle = $all_discrepant_emails; + + // For each user, check who they are on all sites. + foreach ( $users_to_handle as $email_address ) { + if ( ! $email_address ) { + continue; + } + $user_record = []; + foreach ( $users_by_site as $site_url => $email_groups ) { + foreach ( $email_groups as $key => $users ) { + if ( in_array( $email_address, $users ) ) { + $user_record[ $site_url ] = $key; + } + } + } + $user_sites = array_keys( $user_record ); + $all_states = array_unique( array_values( $user_record ) ); + $wp_user = get_user_by( 'email', $email_address ); + $user_identification = $email_address; + if ( $wp_user ) { + $origin_site = get_user_meta( $wp_user->ID, \Newspack_Network\Utils\Users::USER_META_REMOTE_SITE, true ); + if ( $origin_site ) { + $user_identification = sprintf( '%s (%s)', $email_address, $origin_site ); + } + } + + if ( empty( $user_record ) ) { + WP_CLI::warning( sprintf( 'User %s is not present on any site.', $user_identification ) ); + WP_CLI::line( '' ); + } elseif ( ! in_array( 'synced', $all_states ) ) { + WP_CLI::line( sprintf( 'User %s is not synced on any site, they won\'t cause discrepancies.', $user_identification ) ); + WP_CLI::line( '' ); + } elseif ( count( $user_sites ) === 1 ) { + WP_CLI::success( sprintf( 'User %s is synced on a single site only (%s).', $user_identification, $user_sites[0] ) ); + WP_CLI::line( '' ); + } else { + if ( count( $user_sites ) === 8 ) { + WP_CLI::success( sprintf( 'User %s is synced on all sites.', $user_identification ) ); + } else { + WP_CLI::success( sprintf( 'User %s is present on the following sites:', $user_identification ) ); + } + foreach ( $user_record as $url => $key ) { + WP_CLI::line( sprintf( '%s on site %s', $key, $url ) ); + } + WP_CLI::line( '' ); + } + } + + WP_CLI::line( '' ); + } + + + /** + * Deduplicate users on a site. + * + * @param array $args Indexed array of args. + * @param array $assoc_args Associative array of args. + * @return void + * + * ## OPTIONS + * + * [--live] + * : Run the command in live mode, updating the users. + * + * ## EXAMPLES + * + * wp newspack-network deduplicate-users + */ + public static function deduplicate_users( array $args, array $assoc_args ) { + WP_CLI::line( '' ); + + $live = isset( $assoc_args['live'] ) ? true : false; + if ( $live ) { + WP_CLI::line( 'Live mode ā€“ users will be deleted.' ); + } else { + WP_CLI::line( 'Dry run ā€“ users will not be deleted. Use --live flag to run in live mode.' ); + } + + global $wpdb; + $duplicate_users_result = $wpdb->get_results( // phpcs:ignore WordPress.DB.DirectDatabaseQuery.DirectQuery, WordPress.DB.DirectDatabaseQuery.NoCaching + 'SELECT user_email, ID, COUNT(user_email) as count FROM wp_users GROUP BY user_email HAVING count > 1' + ); + WP_CLI::line( sprintf( 'Found %d duplicated user(s)', count( $duplicate_users_result ) ) ); + WP_CLI::line( '' ); + foreach ( $duplicate_users_result as $key => $result ) { + if ( empty( $result->user_email ) ) { + WP_CLI::warning( 'No email address for user #' . $result->ID ); + WP_CLI::line( '' ); + continue; + } + WP_CLI::line( 'Email address: ' . $result->user_email ); + $user_ids_results = $wpdb->get_results( // phpcs:ignore WordPress.DB.DirectDatabaseQuery.DirectQuery, WordPress.DB.DirectDatabaseQuery.NoCaching + $wpdb->prepare( + 'SELECT id FROM wp_users WHERE user_email = %s', + $result->user_email + ) + ); + $users = []; + foreach ( $user_ids_results as $key => $result ) { + $users[] = get_user_by( 'id', $result->id ); + } + $by_user = []; + foreach ( $users as $user ) { + $memberships = \wc_memberships_get_user_memberships( $user ); + $by_user[ $user->ID ] = [ + 'memberships' => $memberships, + 'user' => $user, + ]; + if ( count( $memberships ) === 0 ) { + WP_CLI::line( sprintf( 'User %d has no memberships', $user->ID ) ); + } else { + $statuses = array_map( + function( $membership ) { + return $membership->status; + }, + $memberships + ); + $plan_ids = array_map( + function( $membership ) { + return $membership->plan_id; + }, + $memberships + ); + WP_CLI::line( sprintf( 'User %d has %d membership(s) (plans: %s) (statuses: %s)', $user->ID, count( $memberships ), implode( ', ', $plan_ids ), implode( ', ', $statuses ) ) ); + } + } + + // Get the user with the least memberships. + $min_memberships = PHP_INT_MAX; + $min_user_id = null; + foreach ( $by_user as $user_id => $user_data ) { + $memberships = $user_data['memberships']; + if ( count( $memberships ) < $min_memberships ) { + $min_memberships = count( $memberships ); + $min_user_id = $user_id; + } + } + if ( $live ) { + WP_CLI::line( 'Removing user #' . $min_user_id ); + // If removing duplicates, the user-deleted event should not be handled. Otherwise, + // the "original" user would be removed from the network. + add_filter( 'newspack_network_process_user_deleted', '__return_false' ); + $result = wp_delete_user( $min_user_id ); + remove_filter( 'newspack_network_process_user_deleted', '__return_false' ); + if ( $result ) { + WP_CLI::success( 'Deleted user ' . $min_user_id ); + } else { + WP_CLI::warning( 'Failed to delete user ' . $min_user_id ); + } + } else { + WP_CLI::line( 'Would remove user #' . $min_user_id ); + } + + WP_CLI::line( '' ); + } + } + + /** + * Deduplicate subscriptions. + * + * @param array $args Indexed array of args. + * @param array $assoc_args Associative array of args. + * @return void + * + * ## OPTIONS + * + * [--live] + * : Run the command in live mode, updating the subscriptions. + * + * [--fix-memberships] + * : Fix mismatch between active subscriptions and active memberships. + * + * ## EXAMPLES + * + * wp newspack-network fix-subscriptions + */ + public static function fix_subscriptions( array $args, array $assoc_args ) { + WP_CLI::line( '' ); + + $live = isset( $assoc_args['live'] ) ? true : false; + $fix_memberships = isset( $assoc_args['fix-memberships'] ) ? true : false; + + if ( $live ) { + WP_CLI::line( 'Live mode ā€“ data will be updated.' ); + } else { + WP_CLI::line( 'Dry run ā€“ data will not be updated. Use --live flag to run in live mode.' ); + } + WP_CLI::line( '' ); + + global $wpdb; + if ( $fix_memberships ) { + // Query for all subscriptions, regardless of status. + $subscriptions_per_user_results = $wpdb->get_results( // phpcs:ignore WordPress.DB.DirectDatabaseQuery.DirectQuery, WordPress.DB.DirectDatabaseQuery.NoCaching + "SELECT customer_id, COUNT(customer_id) as count FROM wp_wc_orders WHERE type = 'shop_subscription' GROUP BY customer_id HAVING count > 1" + ); + WP_CLI::line( sprintf( 'Found %d user(s) with multiple subscriptions', count( $subscriptions_per_user_results ) ) ); + } else { + // Query for active subscriptions only. + $subscriptions_per_user_results = $wpdb->get_results( // phpcs:ignore WordPress.DB.DirectDatabaseQuery.DirectQuery, WordPress.DB.DirectDatabaseQuery.NoCaching + "SELECT customer_id, COUNT(customer_id) as count FROM wp_wc_orders WHERE type = 'shop_subscription' AND status = 'wc-active' GROUP BY customer_id HAVING count > 1" + ); + WP_CLI::line( sprintf( 'Found %d user(s) with multiple active subscriptions', count( $subscriptions_per_user_results ) ) ); + } + WP_CLI::line( '' ); + + foreach ( $subscriptions_per_user_results as $result ) { + $user = get_user_by( 'id', $result->customer_id ); + if ( $user ) { + // Compare to user's memberships. + $active_memberships = \wc_memberships_get_user_memberships( $user->ID, [ 'status' => [ 'active' ] ] ); + if ( $fix_memberships ) { + WP_CLI::line( sprintf( 'User %s (#%d) has %d subscriptions and %d active memberships.', $user->user_email, $result->customer_id, $result->count, count( $active_memberships ) ) ); + } else { + WP_CLI::line( sprintf( 'User %s (#%d) has %d active subscriptions and %d active memberships.', $user->user_email, $result->customer_id, $result->count, count( $active_memberships ) ) ); + } + $memberships_subscriptions_delta = $result->count - count( $active_memberships ); + if ( $memberships_subscriptions_delta > 0 ) { + if ( $fix_memberships ) { + $active_subscription_ids = []; + $subscription_amounts = []; + $user_subscriptions = \wcs_get_users_subscriptions( $user->ID ); + foreach ( $user_subscriptions as $subscription ) { + WP_CLI::line( sprintf( 'Subscription #%d (amount: $%d, started %s) has status "%s"', $subscription->get_id(), $subscription->get_total(), $subscription->get_date( 'start' ), $subscription->get_status() ) ); + $subscription_amounts[] = $subscription->get_total(); + if ( $subscription->get_status() === 'active' ) { + $active_subscription_ids[] = $subscription->get_id(); + } + } + // If all subscription amounts are the same, this might be a mistake. + if ( count( $user_subscriptions ) !== count( array_unique( $subscription_amounts ) ) ) { + WP_CLI::warning( 'Found subscriptions with the same amount, this might be a mistake!' ); + } + + if ( empty( $active_subscription_ids ) && ! empty( $active_memberships ) ) { + WP_CLI::warning( 'No active subscriptions, but has active membership(s)!' ); + } + + if ( empty( $active_memberships ) ) { + WP_CLI::line( sprintf( 'User %s (#%d) has %d subscriptions and no active memberships.', $user->user_email, $result->customer_id, $result->count ) ); + WP_CLI::line( '' ); + continue; + } + + foreach ( $active_memberships as $membership ) { + $membership_subscription = $membership->get_subscription(); + WP_CLI::line( sprintf( 'Membership #%d is tied to subscription #%d', $membership->get_id(), $membership_subscription ? $membership_subscription->get_id() : 0 ) ); + if ( $membership_subscription && ! in_array( $membership_subscription->get_id(), $active_subscription_ids ) ) { + if ( empty( $active_subscription_ids ) ) { + WP_CLI::warning( 'No active subscriptions, cannot fix the membership!' ); + continue; + } + if ( $live ) { + $membership->set_subscription_id( $active_subscription_ids[0] ); + $membership->set_end_date(); // CLear end date so membership is tied to subscription. + $membership->update_status( 'wcm-active' ); + WP_CLI::success( sprintf( 'The subscription (%d) tied to the active membership is not an active subscription. It has been linked to an active subscription (%d).', $membership_subscription->get_id(), $active_subscription_ids[0] ) ); + } else { + WP_CLI::warning( sprintf( 'The subscription (%d) tied to the active membership is not an active subscription.', $membership_subscription->get_id() ) ); + } + } + } + } + } + } else { + WP_CLI::line( sprintf( '%d active subscriptions are assigned to user #%d (no user found)', $result->count, $result->customer_id ) ); + } + WP_CLI::line( '' ); + } + + WP_CLI::line( '' ); + } + + /** + * Reprocess specified events from the event log. + * + * @param array $args Indexed array of args. + * @param array $assoc_args Associative array of args. + * @return void + * + * ## OPTIONS + * + * [--live] + * : Run the command in live mode, updating the subscriptions. + * + * ## EXAMPLES + * + * wp newspack-network reprocess-events 123 42 + */ + public static function reprocess_events( array $args, array $assoc_args ) { + WP_CLI::line( '' ); + if ( ! Site_Role::is_hub() ) { + WP_CLI::error( 'This command can only be run on the Hub site.' ); + } + $event_ids = $args; + if ( empty( $event_ids ) ) { + WP_CLI::error( 'Please provide event IDs to reprocess.' ); + } + + $live = isset( $assoc_args['live'] ) ? true : false; + + global $wpdb; + $table_name = \Newspack_Network\Hub\Database\Event_Log::get_table_name(); + $query = "SELECT * FROM $table_name WHERE id IN (" . implode( ',', $event_ids ) . ')'; + $results = $wpdb->get_results( $query ); //phpcs:ignore + if ( empty( $results ) ) { + WP_CLI::error( 'No events found with the provided IDs.' ); + } + foreach ( $results as $event ) { + $incoming_event_class = 'Newspack_Network\\Incoming_Events\\' . Accepted_Actions::ACTIONS[ $event->action_name ]; + $incoming_event = new $incoming_event_class( false, json_decode( $event->data ), $event->timestamp ); + if ( $live ) { + WP_CLI::line( sprintf( 'Reprocessing event #%d of action: %s.', $event->id, $event->action_name ) ); + $incoming_event->post_process_in_hub(); + } else { + WP_CLI::line( sprintf( 'Would reprocess event #%d of action: %s.', $event->id, $event->action_name ) ); + } + } + WP_CLI::line( '' ); + } +} diff --git a/includes/utils/class-users.php b/includes/utils/class-users.php index c4baeaa1..72f9acd2 100644 --- a/includes/utils/class-users.php +++ b/includes/utils/class-users.php @@ -198,6 +198,9 @@ public static function get_no_role_users_emails() { /** * Get synchronized users. * + * Note that if a user has duplicate entries for the `wp_capabilities` meta in the `wp_usermeta` table, + * this function will return the user multiple times. + * * @param array $fields Fields to return. */ public static function get_synchronized_users( $fields = [] ) { diff --git a/includes/woocommerce-memberships/class-admin.php b/includes/woocommerce-memberships/class-admin.php index 4ea5cf16..6189a505 100644 --- a/includes/woocommerce-memberships/class-admin.php +++ b/includes/woocommerce-memberships/class-admin.php @@ -142,6 +142,24 @@ public static function add_data_to_wc_user_membership_response( $response, $user return $response; } + /** + * Get memberships from the site, with the network plan ID. + * + * @param string $email The email of the user. + */ + public static function get_memberships_by_user_email_with_plan_network_id( $email ) { + if ( ! function_exists( '\wc_memberships_get_user_memberships' ) ) { + return []; + } + $found_memberships = \wc_memberships_get_user_memberships( get_user_by( 'email', $email ) ); + foreach ( $found_memberships as $membership ) { + $membership->customer_id = $membership->get_user_id(); + $membership->start_date = $membership->get_local_start_date( 'Y-m-d\TH:i:s' ); + $membership->plan_network_id = get_post_meta( $membership->plan_id, self::NETWORK_ID_META_KEY, true ); + } + return $found_memberships; + } + /** * Adds a meta box to the membership plan edit screen. */