#2863864 - Disable promotions via cron if end date or usage limit hit

modules/promotion/commerce_promotion.module

@@ -79,3 +79,30 @@ function commerce_promotion_entity_base_field_info(EntityTypeInterface $entity_t
     return $fields;
   }
 }
+
+/**
+ * Implements hook_cron()
+ */
+function commerce_promotion_cron() {
+  commerce_promotion_disabled_expired();
+}
+
+/**
+ * Get all expired promotions that are still active and disable them.
+ */
+function commerce_promotion_disabled_expired() {
+  /** @var \Drupal\commerce_promotion\PromotionStorageInterface $promotion_storage */
+  $promotion_storage = \Drupal::service('entity_type.manager')->getStorage('commerce_promotion');
+
+  // Get query for all expired promotions.
+  $promotions = $promotion_storage->loadExpired();
+
+  if ($promotions !== FALSE) {
+    // Disable all expired promotions.
+    foreach ($promotions as $promotion) {
+      $promotion->setEnabled(FALSE);
+      $promotion->save();
+    }
+  }
+}
+

modules/promotion/src/PromotionStorage.php

@@ -106,6 +106,46 @@ public function loadByCoupon(OrderTypeInterface $order_type, StoreInterface $sto
     return reset($promotions);
   }
 
+  /**
+   * Builds a query that will load all promotions that are no longer valid
+   * determined by the base field limiting values.
+   *
+   * @param bool $only_enabled
+   *   Only include currently enabled promotions that have expired.
+   * @return array|bool|\Drupal\Core\Entity\EntityInterface[]
+   *   The expired promotion entities. Returns FALSE if none found.
+   */
+  public function loadExpired($only_enabled = TRUE) {
+    // Subquery to determine the amount of times a coupon has been used.
+    $usage_query = $this->database->select('commerce_promotion_usage', 'cpu');
+    $usage_query->addExpression('COUNT(cpu.promotion_id)', 'count');
+    $usage_query->where('cpu.promotion_id = cpd.promotion_id');
+    $usage_query->groupBy('cpu.promotion_id');
+
+    $query = $this->database->select($this->getDataTable(), 'cpd');
+
+    // We want to get results of queries that have passed their final date or
+    // have met their max usage.
+    $or_condition = $query->orConditionGroup()
+      ->condition('cpd.end_date', gmdate('Y-m-d'), '<=')
+      ->condition('cpd.usage_limit', $usage_query, '<=');
+
+    $query->addField('cpd', 'promotion_id');
+    $query->condition($or_condition);
+
+    if ($only_enabled) {
+      $query->condition('cpd.status', 1);
+    }
+
+    $result = $query->execute()->fetchCol(0);
+
+    if (empty($result)) {
+      return FALSE;
+    }
+
+    return $this->loadMultiple($result);
+  }
+
   /**
    * Builds the base query for loading valid promotions.
    *

modules/promotion/src/PromotionStorageInterface.php

@@ -40,4 +40,15 @@ public function loadValid(OrderTypeInterface $order_type, StoreInterface $store)
    */
   public function loadByCoupon(OrderTypeInterface $order_type, StoreInterface $store, CouponInterface $coupon);
 
+  /**
+   * Builds a query that will load all promotions that are no longer valid
+   * determined by the base field limiting values.
+   *
+   * @param bool $only_enabled
+   *   Only include currently enabled promotions that have expired.
+   * @return array|bool|\Drupal\Core\Entity\EntityInterface[]
+   *   The expired promotion entities. Returns FALSE if none found.
+   */
+  public function loadExpired($only_enabled);
+
 }