Fork 7.x-2.x-dev from drupal.org.

2017-02-18 18:52:44 -06:00
commit 0e1cd66d2d
9 changed files with 1718 additions and 0 deletions
--- a/uc_stripe.drush.inc
+++ b/uc_stripe.drush.inc
@ -0,0 +1,99 @@
+<?php
+
+/**
+ * @file
+ *   Delete legacy uc_stripe subscriptions that were created by v1.
+ */
+
+/**
+ * Implements hook_drush_command().
+ *
+ *
+ * @return
+ *   An associative array describing your command(s).
+ */
+function uc_stripe_drush_command() {
+  $items = array();
+
+  $items['subscription-cancel'] = array(
+    'description' => "Delete subscriptions created by uc_stripe v1 and existing in uc_recurring_stripe table.",
+    'arguments' => array(
+      'order_id' => 'Order ID from uc_stripe_recurring table',
+    ),
+    'options' => array(
+      'dry-run' => 'Dry run - does not actually execute, but show what would be done',
+    ),
+    'examples' => array(
+      'drush subscription-cancel',
+      'drush subscription-cancel --dry-run',
+      'drush subscription-cancel <order_id>',
+    ),
+    'aliases' => array('subcancel'),
+  );
+
+  return $items;
+}
+
+
+/**
+ * Command callback
+ *
+ * Delete active subscriptions found in uc_recurring_stripe table.
+ */
+function drush_uc_stripe_subscription_cancel($order_id = 'all') {
+
+  $dry_run = drush_get_option('dry-run');
+
+  if (!db_table_exists('uc_recurring_stripe')) {
+    drush_print('No uc_recurring_stripe table exists, exiting.');
+    return;
+  }
+
+  $library = libraries_load('stripe');
+  $info = libraries_info('stripe');
+  if (!$library['loaded'] || !array_key_exists(\Stripe\Stripe::VERSION, $info['versions'])) {
+    drush_print("Failed to load one of the supported Stripe PHP library versions: " . join(', ', array_keys($info['versions'])));
+    return;
+  }
+
+  if ($dry_run) {
+    drush_print('dry-run is set so not deleting any subscriptions');
+  }
+  _uc_stripe_prepare_api();
+  $query = db_select('uc_recurring_stripe', 'urs', array('fetch' => PDO::FETCH_ASSOC))
+    ->fields('urs', array('uid', 'customer_id', 'order_id' ));
+
+  if ($order_id != 'all') {
+    $query->condition('order_id', ':id');
+  }
+  $result = $query->execute();
+
+  foreach ($result as $item) {
+    $customer = NULL;
+    $account = user_load($item['uid']);
+
+    try {
+      $customer = \Stripe\Customer::retrieve($item['customer_id']);
+      $subscriptions = $customer->subscriptions->all();
+    } catch (Exception $e) {
+      drush_print("Failed to retrieve customer subscriptions for {$item['customer_id']} (user:$account->name}. Message: {$e->getMessage()}");
+      continue;
+    }
+
+    $count = count($subscriptions['data']);
+
+    $msg = "Retrieved Stripe Customer with $count subscriptions,  uid:{$item['uid']} username:{$account->name} order:{$item['order_id']} stripe customer id:{$item['customer_id']}";
+    drush_print($msg);
+    foreach ($subscriptions['data'] as $sub) {
+      drush_print("   Subscription: {$sub->id} {$sub->status} {$sub->plan->name} {$sub->plan->id}");
+      if (empty($dry_run) && drush_confirm('Are you sure you want to cancel this subscription?')) {
+        try {
+          $sub->cancel();
+          drush_print("    Cancelled subscription {$sub->id}");
+        } catch (Exception $e) {
+          drush_print("    FAILED to cancel subscription {$sub->id} Message: {$e->getMessage()}");
+        }
+      }
+    }
+  }
+}