order_ids_recurring_totals = $this->get_data();
$total_renewal_revenue = 0;
$total_renewal_count = 0;
foreach ( $this->order_ids_recurring_totals as $r ) {
$subscription_ids = explode( ',', $r->subscription_ids );
$billing_intervals = explode( ',', $r->billing_intervals );
$billing_periods = explode( ',', $r->billing_periods );
$scheduled_ends = explode( ',', $r->scheduled_ends );
$subscription_totals = explode( ',', $r->subscription_totals );
// Loop through each returned subscription ID and check if there are any more renewals in this period.
foreach ( $subscription_ids as $key => $subscription_id ) {
$next_payment_timestamp = strtotime( $r->scheduled_date );
//Remove the time part of the end date, if there is one
if ( '0' !== $scheduled_ends[ $key ] ) {
$scheduled_ends[ $key ] = date( 'Y-m-d', strtotime( $scheduled_ends[ $key ] ) );
}
// Keep calculating all the new payments until we hit the end date of the search
do {
$next_payment_timestamp = wcs_add_time( $billing_intervals[ $key ], $billing_periods[ $key ], $next_payment_timestamp );
// If there are more renewals add them to the existing object or create a new one
if ( $next_payment_timestamp <= $this->end_date && isset( $scheduled_ends[ $key ] ) && ( 0 == $scheduled_ends[ $key ] || $next_payment_timestamp < strtotime( $scheduled_ends[ $key ] ) ) ) {
$update_key = date( 'Y-m-d', $next_payment_timestamp );
if ( $next_payment_timestamp >= $this->start_date ) {
if ( ! isset( $this->order_ids_recurring_totals[ $update_key ] ) ) {
$this->order_ids_recurring_totals[ $update_key ] = new stdClass();
$this->order_ids_recurring_totals[ $update_key ]->scheduled_date = $update_key;
$this->order_ids_recurring_totals[ $update_key ]->recurring_total = 0;
$this->order_ids_recurring_totals[ $update_key ]->total_renewals = 0;
}
$this->order_ids_recurring_totals[ $update_key ]->total_renewals += 1;
$this->order_ids_recurring_totals[ $update_key ]->recurring_total += $subscription_totals[ $key ];
}
}
} while ( $next_payment_timestamp <= $this->end_date && isset( $scheduled_ends[ $key ] ) && ( 0 == $scheduled_ends[ $key ] || $next_payment_timestamp < strtotime( $scheduled_ends[ $key ] ) ) );
}
}
// Sum up the total revenue and total renewal count separately to avoid adding up multiple times.
foreach ( $this->order_ids_recurring_totals as $r ) {
if ( strtotime( $r->scheduled_date ) >= $this->start_date && strtotime( $r->scheduled_date ) <= $this->end_date ) {
$total_renewal_revenue += $r->recurring_total;
$total_renewal_count += $r->total_renewals;
}
}
$legend = array();
$this->average_sales = ( 0 != $total_renewal_count ? $total_renewal_revenue / $total_renewal_count : 0 );
$legend[] = array(
// translators: %s: formatted amount.
'title' => sprintf( __( '%s renewal income in this period', 'woocommerce-subscriptions' ), '' . wc_price( $total_renewal_revenue ) . '' ),
'placeholder' => __( 'The sum of all the upcoming renewal orders, including items, fees, tax and shipping, for currently active subscriptions.', 'woocommerce-subscriptions' ),
'color' => $this->chart_colours['renewals_amount'],
'highlight_series' => 1,
);
$legend[] = array(
// translators: %s: renewal count.
'title' => sprintf( __( '%s renewal orders', 'woocommerce-subscriptions' ), '' . $total_renewal_count . '' ),
'placeholder' => __( 'The number of upcoming renewal orders, for currently active subscriptions.', 'woocommerce-subscriptions' ),
'color' => $this->chart_colours['renewals_count'],
'highlight_series' => 0,
);
$legend[] = array(
// translators: %s: formatted amount.
'title' => sprintf( __( '%s average renewal amount', 'woocommerce-subscriptions' ), '' . wc_price( $this->average_sales ) . '' ),
'color' => $this->chart_colours['renewals_average'],
);
return $legend;
}
/**
* Get report data.
* @return stdClass
*/
public function get_data( $args = array() ) {
global $wpdb;
$default_args = array(
'no_cache' => false,
);
$args = apply_filters( 'wcs_reports_upcoming_recurring_revenue_args', $args );
$args = wp_parse_args( $args, $default_args );
// Query based on whole days, not minutes/hours so that we can cache the query for at least 24 hours
$base_query = $wpdb->prepare(
"SELECT
DATE(ms.meta_value) as scheduled_date,
SUM(mo.meta_value) as recurring_total,
COUNT(mo.meta_value) as total_renewals,
group_concat(p.ID) as subscription_ids,
group_concat(mi.meta_value) as billing_intervals,
group_concat(mp.meta_value) as billing_periods,
group_concat(me.meta_value) as scheduled_ends,
group_concat(mo.meta_value) as subscription_totals
FROM {$wpdb->prefix}posts p
LEFT JOIN {$wpdb->prefix}postmeta ms
ON p.ID = ms.post_id
LEFT JOIN {$wpdb->prefix}postmeta mo
ON p.ID = mo.post_id
LEFT JOIN {$wpdb->prefix}postmeta mi
ON p.ID = mi.post_id
LEFT JOIN {$wpdb->prefix}postmeta mp
ON p.ID = mp.post_id
LEFT JOIN {$wpdb->prefix}postmeta me
ON p.ID = me.post_id
WHERE p.post_type = 'shop_subscription'
AND p.post_status = 'wc-active'
AND mo.meta_key = '_order_total'
AND ms.meta_key = '_schedule_next_payment'
AND ( ( ms.meta_value < '%s' AND me.meta_value = 0 ) OR ( me.meta_value > '%s' AND ms.meta_value < '%s' ) )
AND mi.meta_key = '_billing_interval'
AND mp.meta_key = '_billing_period'
AND me.meta_key = '_schedule_end '
GROUP BY {$this->group_by_query}
ORDER BY ms.meta_value ASC",
date( 'Y-m-d', strtotime( '+1 DAY', $this->end_date ) ),
date( 'Y-m-d', $this->start_date ),
date( 'Y-m-d', strtotime( '+1 DAY', $this->end_date ) )
);
$cached_results = get_transient( strtolower( get_class( $this ) ) );
$query_hash = md5( $base_query );
// Set a default value for cached results for PHP 8.2+ compatibility.
if ( empty( $cached_results ) ) {
$cached_results = [];
}
if ( $args['no_cache'] || ! isset( $cached_results[ $query_hash ] ) ) {
$wpdb->query( 'SET SESSION SQL_BIG_SELECTS=1' );
$cached_results[ $query_hash ] = apply_filters( 'wcs_reports_upcoming_recurring_revenue_data', $wpdb->get_results( $base_query, OBJECT_K ), $args );
set_transient( strtolower( get_class( $this ) ), $cached_results, WEEK_IN_SECONDS );
}
return $cached_results[ $query_hash ];
}
/**
* Output the report
*/
public function output_report() {
$ranges = array(
'year' => __( 'Next 12 Months', 'woocommerce-subscriptions' ),
'month' => __( 'Next 30 Days', 'woocommerce-subscriptions' ),
'last_month' => __( 'Next Month', 'woocommerce-subscriptions' ), // misnomer to match historical reports keys, handy for caching
'7day' => __( 'Next 7 Days', 'woocommerce-subscriptions' ),
);
$this->chart_colours = array(
'renewals_amount' => '#1abc9c',
'renewals_count' => '#e67e22',
'renewals_average' => '#d4d9dc',
);
$current_range = $this->get_current_range();
$this->calculate_current_range( $current_range );
include( WC()->plugin_path() . '/includes/admin/views/html-report-by-date.php' );
}
/**
* Output an export link
*/
public function get_export_button() {
?>
prepare_chart_data( $this->order_ids_recurring_totals, 'scheduled_date', 'recurring_total', $this->chart_interval, $this->start_date, $this->chart_groupby );
$renewal_counts = $this->prepare_chart_data( $this->order_ids_recurring_totals, 'scheduled_date', 'total_renewals', $this->chart_interval, $this->start_date, $this->chart_groupby );
$chart_data = array(
'renewal_amounts' => array_values( $renewal_amounts ),
'renewal_counts' => array_values( $renewal_counts ),
);
?>
start_date = strtotime( sanitize_text_field( $_GET['start_date'] ) );
$this->end_date = strtotime( 'midnight', strtotime( sanitize_text_field( $_GET['end_date'] ) ) );
if ( ! $this->end_date ) {
$this->end_date = current_time( 'timestamp' );
}
$interval = 0;
$min_date = $this->start_date;
while ( ( $min_date = wcs_add_months( $min_date, '1' ) ) <= $this->end_date ) {
$interval ++;
}
// 3 months max for day view
if ( $interval >= 3 ) {
$this->chart_groupby = 'month';
} else {
$this->chart_groupby = 'day';
}
break;
case 'year':
$this->start_date = strtotime( 'now', current_time( 'timestamp' ) );
$this->end_date = strtotime( 'last day', strtotime( '+1 YEAR', current_time( 'timestamp' ) ) );
$this->chart_groupby = 'month';
break;
case 'last_month': // misnomer to match historical reports keys, handy for caching
$this->start_date = strtotime( date( 'Y-m-01', wcs_add_months( current_time( 'timestamp' ), '1' ) ) );
$this->end_date = strtotime( date( 'Y-m-t', $this->start_date ) );
$this->chart_groupby = 'day';
break;
case 'month':
$this->start_date = strtotime( 'now', current_time( 'timestamp' ) );
$this->end_date = wcs_add_months( current_time( 'timestamp' ), '1' );
$this->chart_groupby = 'day';
break;
case '7day':
$this->start_date = strtotime( 'now', current_time( 'timestamp' ) );
$this->end_date = strtotime( '+7 days', current_time( 'timestamp' ) );
$this->chart_groupby = 'day';
break;
}
// Group by
switch ( $this->chart_groupby ) {
case 'day':
$this->group_by_query = 'YEAR(ms.meta_value), MONTH(ms.meta_value), DAY(ms.meta_value)';
$this->chart_interval = ceil( max( 0, ( $this->end_date - $this->start_date ) / ( 60 * 60 * 24 ) ) );
$this->barwidth = 60 * 60 * 24 * 1000;
break;
case 'month':
$this->group_by_query = 'YEAR(ms.meta_value), MONTH(ms.meta_value), DAY(ms.meta_value)';
$this->chart_interval = 0;
$min_date = $this->start_date;
while ( ( $min_date = wcs_add_months( $min_date, '1' ) ) <= $this->end_date ) {
$this->chart_interval ++;
}
$this->barwidth = 60 * 60 * 24 * 7 * 4 * 1000;
break;
}
}
/**
* Helper function to get the report's current range
*/
protected function get_current_range() {
$current_range = ! empty( $_GET['range'] ) ? sanitize_text_field( $_GET['range'] ) : '7day';
if ( ! in_array( $current_range, array( 'custom', 'year', 'month', 'last_month', '7day' ) ) ) {
$current_range = '7day';
}
return $current_range;
}
/**
* Clears the cached query results.
*
* @since 3.0.10
*/
public function clear_cache() {
delete_transient( strtolower( get_class( $this ) ) );
}
}