You are here

class BatchSyncOrders in Mailchimp E-Commerce 8

Same name in this branch
  1. 8 modules/mailchimp_ecommerce_ubercart/src/BatchSyncOrders.php \Drupal\mailchimp_ecommerce_ubercart\BatchSyncOrders
  2. 8 modules/mailchimp_ecommerce_commerce/src/BatchSyncOrders.php \Drupal\mailchimp_ecommerce_commerce\BatchSyncOrders

Batch process handler for syncing order data to Mailchimp.

Hierarchy

Expanded class hierarchy of BatchSyncOrders

File

modules/mailchimp_ecommerce_commerce/src/BatchSyncOrders.php, line 11

Namespace

Drupal\mailchimp_ecommerce_commerce
View source
class BatchSyncOrders {

  /**
   * Batch processor for order sync.
   *
   * @param array $order_ids
   *   IDs of orders to sync.
   * @param array $context
   *   Batch process context; stores progress data.
   */
  public static function syncOrders($order_ids, &$context) {
    if (!isset($context['sandbox']['progress'])) {
      $context['sandbox']['progress'] = 0;
      $context['sandbox']['total'] = count($order_ids);
      $context['results']['order_ids'] = $order_ids;
    }
    $config = \Drupal::config('mailchimp.settings');
    $batch_limit = $config
      ->get('batch_limit');
    $batch = array_slice($context['results']['order_ids'], $context['sandbox']['progress'], $batch_limit);

    /** @var \Drupal\mailchimp_ecommerce\CustomerHandler $customer_handler */
    $customer_handler = \Drupal::service('mailchimp_ecommerce.customer_handler');

    /** @var \Drupal\mailchimp_ecommerce\CartHandler $cart_handler */
    $cart_handler = \Drupal::service('mailchimp_ecommerce.cart_handler');

    /** @var \Drupal\mailchimp_ecommerce\OrderHandler $order_handler */
    $order_handler = \Drupal::service('mailchimp_ecommerce.order_handler');
    foreach ($batch as $order_id) {
      $order = Order::load($order_id);
      $customer = [];
      $order_state = $order
        ->get('state')->value;
      $customer['email_address'] = $order
        ->getEmail();
      if (!empty($customer['email_address'])) {
        $billing_profile = $order
          ->getBillingProfile();
        $customer = $customer_handler
          ->buildCustomer($customer, $billing_profile);
        $customer_handler
          ->addOrUpdateCustomer($customer);
      }
      $order_data = $order_handler
        ->buildOrder($order, $customer);

      // Add cart item price to order data.
      if (!isset($order_data['currency_code'])) {
        if ($price = $order
          ->getTotalPrice()) {
          $order_data['currency_code'] = $price
            ->getCurrencyCode();
          $order_data['order_total'] = $price
            ->getNumber();
        }
        else {
          $order_data['currency_code'] = $order
            ->getStore()
            ->getDefaultCurrency()
            ->getCurrencyCode();
          $order_data['order_total'] = 0;
        }
      }
      $order_data['checkout_url'] = Url::fromRoute('commerce_checkout.form', [
        'commerce_order' => $order
          ->id(),
      ], [
        'absolute' => TRUE,
      ])
        ->toString();
      $cart_handler
        ->addOrUpdateCart($order
        ->id(), $customer, $order_data);
      if ($order_state == 'completed') {
        $cart_handler
          ->deleteCart($order
          ->id());

        // Update the customer's total order count and total amount spent.
        $customer_handler
          ->incrementCustomerOrderTotal($customer['email_address'], $order_data['order_total']);

        // Email address should always be available on checkout completion.
        $customer['email_address'] = $order
          ->getEmail();
        $billing_profile = $order
          ->getBillingProfile();
        $customer = $customer_handler
          ->buildCustomer($customer, $billing_profile);
        $order_data = $order_handler
          ->buildOrder($order, $customer);

        // Add or update existing order.
        $existing_order = $order_handler
          ->getOrder($order
          ->id());
        if (!empty($existing_order)) {
          $order_handler
            ->updateOrder($order
            ->id(), $order_data);
        }
        else {
          $order_handler
            ->addOrder($order
            ->id(), $customer, $order_data);
        }
      }
      $context['sandbox']['progress']++;
      $context['message'] = t('Sent @count of @total orders to Mailchimp', [
        '@count' => $context['sandbox']['progress'],
        '@total' => $context['sandbox']['total'],
      ]);
      $context['finished'] = $context['sandbox']['progress'] / $context['sandbox']['total'];
    }
  }

}

Members

Namesort descending Modifiers Type Description Overrides
BatchSyncOrders::syncOrders public static function Batch processor for order sync.