From 36b8b5f31aeb6f1741168553415069f86964ec9e Mon Sep 17 00:00:00 2001
From: priyankakaran26 <priyanka.karan26@gmail.com>
Date: Thu, 4 Sep 2014 18:05:01 +0100
Subject: [PATCH] cascade update based on mode / cascade-type

---
 CRM/Core/BAO/RecurringEntity.php  | 58 ++++++++++++++++++++++---------
 CRM/Core/DAO/RecurringEntity.php  |  8 ++---
 CRM/Core/Form/RecurringEntity.php |  4 ++-
 3 files changed, 49 insertions(+), 21 deletions(-)

diff --git a/CRM/Core/BAO/RecurringEntity.php b/CRM/Core/BAO/RecurringEntity.php
index 144cfd54d1..99959d0bcf 100644
--- a/CRM/Core/BAO/RecurringEntity.php
+++ b/CRM/Core/BAO/RecurringEntity.php
@@ -77,22 +77,46 @@ class CRM_Core_BAO_RecurringEntity extends CRM_Core_DAO_RecurringEntity {
     return self::add($params);
   }
 
-  static public function getEntitiesForParent($parentId, $entityTable, $includeParent = TRUE) {
+  // MODE = 3 (ALL)
+  static public function getEntitiesForParent($parentId, $entityTable, $includeParent = TRUE, $mode = 3, $initiatorId = NULL) {
     $entities = array();
 
+    if (!$initiatorId) {
+      $initiatorId = $parentId;
+    } 
+
+    $queryParams = array(
+      1 => array($parentId,    'Integer'),
+      2 => array($entityTable, 'String'),
+      3 => array($initiatorId, 'Integer'),
+    );
+
+    if (!$mode) {
+      $mode = CRM_Core_DAO::singleValueQuery("SELECT cascade_type FROM civicrm_recurring_entity WHERE entity_id = %3 AND entity_table = %2", $queryParams);
+    }
+
     $query = "SELECT *
       FROM civicrm_recurring_entity
       WHERE parent_id = %1 AND entity_table = %2";
     if (!$includeParent) {
-      $query .= " AND entity_id != %1";
+      $query .= " AND entity_id != " . ($initiatorId ? "%3" : "%1");
+    }
+
+    if ($mode == '1') { // MODE = SINGLE
+      $query .= " AND entity_id = %3";
+    } else if ($mode == '2') { // MODE = FUTURE
+      $recurringEntityID = CRM_Core_DAO::singleValueQuery("SELECT id FROM civicrm_recurring_entity WHERE entity_id = %3 AND entity_table = %2", $queryParams);
+      if ($recurringEntityID) {
+        $query .= $includeParent ? " AND id >= %4" : " AND id > %4";
+        $query .= " ORDER BY id ASC"; // FIXME: change to order by dates  
+        $queryParams[4] = array($recurringEntityID, 'Integer');
+      } else {
+        // something wrong, return empty
+        return array();
+      }
     }
-    $dao = CRM_Core_DAO::executeQuery($query, 
-      array(
-        1 => array($parentId, 'Integer'),
-        2 => array($entityTable, 'String'),
-      )
-    );
 
+    $dao = CRM_Core_DAO::executeQuery($query, $queryParams);
     while ($dao->fetch()) {
       $entities["{$dao->entity_table}_{$dao->entity_id}"]['table'] = $dao->entity_table;
       $entities["{$dao->entity_table}_{$dao->entity_id}"]['id'] = $dao->entity_id;
@@ -100,10 +124,10 @@ class CRM_Core_BAO_RecurringEntity extends CRM_Core_DAO_RecurringEntity {
     return $entities;
   }
 
-  static public function getEntitiesFor($entityId, $entityTable, $includeParent = TRUE) {
+  static public function getEntitiesFor($entityId, $entityTable, $includeParent = TRUE, $mode = 3) {
     $parentId = self::getParentFor($entityId, $entityTable);
     if ($parentId) {
-      return self::getEntitiesForParent($parentId, $entityTable, $includeParent);
+      return self::getEntitiesForParent($parentId, $entityTable, $includeParent, $mode, $entityId);
     }
     return array();
   }
@@ -156,15 +180,18 @@ class CRM_Core_BAO_RecurringEntity extends CRM_Core_DAO_RecurringEntity {
     }
 
     // get related entities
-    $repeatingEntities = self::getEntitiesFor($obj->id, $obj->__table, FALSE);
+    $repeatingEntities = self::getEntitiesFor($obj->id, $obj->__table, FALSE, NULL);
     if (empty($repeatingEntities)) {
       // return if its not a recurring entity parent
       return NULL;
     }
-    // mark processed
+    // mark being processed
     $processedEntities[$key] = 1;
 
-    foreach ($repeatingEntities as $key => $val) {
+    // to make sure we not copying to source itself
+    unset($repeatingEntities[$key]);
+
+    foreach($repeatingEntities as $key => $val) {
       $entityID = $val['id'];
       $entityTable = $val['table'];
 
@@ -173,14 +200,13 @@ class CRM_Core_BAO_RecurringEntity extends CRM_Core_DAO_RecurringEntity {
       if (array_key_exists($entityTable, self::$_tableDAOMapper)) {
         $daoName = self::$_tableDAOMapper[$entityTable];
 
-        $fromId  = self::getParentFor($entityID, $entityTable);
-
         // FIXME: generalize me
         $skipData = array('start_date' => NULL, 
           'end_date' => NULL,
         );
 
-        $updateDAO = CRM_Core_DAO::cascadeUpdate($daoName, $fromId, $entityID, $skipData);
+        $updateDAO = CRM_Core_DAO::cascadeUpdate($daoName, $obj->id, $entityID, $skipData);
+        CRM_Core_DAO::freeResult();
       }
     }
     // done with processing. lets unset static var.
diff --git a/CRM/Core/DAO/RecurringEntity.php b/CRM/Core/DAO/RecurringEntity.php
index a371ef2b31..bd19e139c4 100644
--- a/CRM/Core/DAO/RecurringEntity.php
+++ b/CRM/Core/DAO/RecurringEntity.php
@@ -1,9 +1,9 @@
 <?php
 /*
 +--------------------------------------------------------------------+
-| CiviCRM version 4.4                                                |
+| CiviCRM version 4.5                                                |
 +--------------------------------------------------------------------+
-| Copyright CiviCRM LLC (c) 2004-2013                                |
+| Copyright CiviCRM LLC (c) 2004-2014                                |
 +--------------------------------------------------------------------+
 | This file is a part of CiviCRM.                                    |
 |                                                                    |
@@ -27,10 +27,10 @@
 /**
  *
  * @package CRM
- * @copyright CiviCRM LLC (c) 2004-2013
+ * @copyright CiviCRM LLC (c) 2004-2014
  *
  * Generated from xml/schema/CRM/Core/RecurringEntity.xml
- * DO NOT EDIT.  Generated by GenCode.php
+ * DO NOT EDIT.  Generated by CRM_Core_CodeGen
  */
 require_once 'CRM/Core/DAO.php';
 require_once 'CRM/Utils/Type.php';
diff --git a/CRM/Core/Form/RecurringEntity.php b/CRM/Core/Form/RecurringEntity.php
index 1de931fa34..5156d6c87d 100644
--- a/CRM/Core/Form/RecurringEntity.php
+++ b/CRM/Core/Form/RecurringEntity.php
@@ -314,6 +314,9 @@ class CRM_Core_Form_RecurringEntity {
         $parent_event_id = $currEntityID;
       }
 
+      // add first entry just for parent
+      CRM_Core_BAO_RecurringEntity::quickAdd($parent_event_id, $parent_event_id, 'civicrm_event');
+
       foreach ($recursionResult as $key => $value) {
         $newEventObj = CRM_Core_BAO_RecurringEntity::copyCreateEntity('civicrm_event', 
         array('id' => $parent_event_id), 
@@ -361,7 +364,6 @@ class CRM_Core_Form_RecurringEntity {
           )
         );
       }
-      CRM_Core_BAO_RecurringEntity::quickAdd($parent_event_id, $parent_event_id, 'civicrm_event');
     }
   }
   
-- 
2.25.1