- $mapping = new CRM_Core_DAO_ActionMapping();
- $mapping->id = $mappingID;
- $mapping->find(TRUE);
-
- // note: $where - this filtering applies for both
- // 'limit to' and 'addition to' options
- // $limitWhere - this filtering applies only for
- // 'limit to' option
- $select = $join = $where = $limitWhere = array();
- $selectColumns = "contact_id, entity_id, entity_table, action_schedule_id";
- $limitTo = $actionSchedule->limit_to;
- $value = explode(CRM_Core_DAO::VALUE_SEPARATOR,
- trim($actionSchedule->entity_value, CRM_Core_DAO::VALUE_SEPARATOR)
- );
- $value = implode(',', $value);
-
- $status = explode(CRM_Core_DAO::VALUE_SEPARATOR,
- trim($actionSchedule->entity_status, CRM_Core_DAO::VALUE_SEPARATOR)
- );
- $status = implode(',', $status);
-
- $anniversary = FALSE;
-
- if (!CRM_Utils_System::isNull($mapping->entity_recipient)) {
- if ($mapping->entity_recipient == 'event_contacts') {
- $recipientOptions = CRM_Core_OptionGroup::values($mapping->entity_recipient, FALSE, FALSE, FALSE, NULL, 'name', TRUE, FALSE, 'name');
- }
- else {
- $recipientOptions = CRM_Core_OptionGroup::values($mapping->entity_recipient, FALSE, FALSE, FALSE, NULL, 'name');
- }
- }
- $from = "{$mapping->entity} e";
-
- if ($mapping->entity == 'civicrm_activity') {
- $contactField = 'r.contact_id';
- $table = 'civicrm_activity e';
- $activityContacts = CRM_Core_OptionGroup::values('activity_contacts', FALSE, FALSE, FALSE, NULL, 'name');
- $sourceID = CRM_Utils_Array::key('Activity Source', $activityContacts);
- $assigneeID = CRM_Utils_Array::key('Activity Assignees', $activityContacts);
- $targetID = CRM_Utils_Array::key('Activity Targets', $activityContacts);
-
- if (!is_null($limitTo)) {
- if ($limitTo == 0) {
- // including the activity target contacts if 'in addition' is defined
- $join[] = "INNER JOIN civicrm_activity_contact r ON r.activity_id = e.id AND record_type_id = {$targetID}";
- }
- else {
- switch (CRM_Utils_Array::value($actionSchedule->recipient, $recipientOptions)) {
- case 'Activity Assignees':
- $join[] = "INNER JOIN civicrm_activity_contact r ON r.activity_id = e.id AND record_type_id = {$assigneeID}";
- break;
-
- case 'Activity Source':
- $join[] = "INNER JOIN civicrm_activity_contact r ON r.activity_id = e.id AND record_type_id = {$sourceID}";
- break;
-
- default:
- case 'Activity Targets':
- $join[] = "INNER JOIN civicrm_activity_contact r ON r.activity_id = e.id AND record_type_id = {$targetID}";
- break;
- }
- }
- }
- // build where clause
- if (!empty($value)) {
- $where[] = "e.activity_type_id IN ({$value})";
- }
- else {
- $where[] = "e.activity_type_id IS NULL";
- }
- if (!empty($status)) {
- $where[] = "e.status_id IN ({$status})";
- }
- $where[] = ' e.is_current_revision = 1 ';
- $where[] = ' e.is_deleted = 0 ';
-
- $dateField = 'e.activity_date_time';
- }
-
- if ($mapping->entity == 'civicrm_participant') {
- $table = 'civicrm_event r';
- $contactField = 'e.contact_id';
- $join[] = 'INNER JOIN civicrm_event r ON e.event_id = r.id';
- if ($actionSchedule->recipient_listing && $limitTo) {
- $rList = explode(CRM_Core_DAO::VALUE_SEPARATOR,
- trim($actionSchedule->recipient_listing, CRM_Core_DAO::VALUE_SEPARATOR)
- );
- $rList = implode(',', $rList);
-
- switch (CRM_Utils_Array::value($actionSchedule->recipient, $recipientOptions)) {
- case 'participant_role':
- $where[] = "e.role_id IN ({$rList})";
- break;
-
- default:
- break;
- }
- }
-
- // build where clause
- if (!empty($value)) {
- $where[] = ($mapping->entity_value == 'event_type') ? "r.event_type_id IN ({$value})" : "r.id IN ({$value})";
- }
- else {
- $where[] = ($mapping->entity_value == 'event_type') ? "r.event_type_id IS NULL" : "r.id IS NULL";
- }
-
- // participant status criteria not to be implemented
- // for additional recipients
- if (!empty($status)) {
- $limitWhere[] = "e.status_id IN ({$status})";
- }
-
- $where[] = 'r.is_active = 1';
- $where[] = 'r.is_template = 0';
- $dateField = str_replace('event_', 'r.', $actionSchedule->start_action_date);
- }
-
- $notINClause = '';
- if ($mapping->entity == 'civicrm_membership') {
- $contactField = 'e.contact_id';
- $table = 'civicrm_membership e';
- // build where clause
- if ($status == 2) {
- //auto-renew memberships
- $where[] = "e.contribution_recur_id IS NOT NULL ";
- }
- elseif ($status == 1) {
- $where[] = "e.contribution_recur_id IS NULL ";
- }
-
- // build where clause
- if (!empty($value)) {
- $where[] = "e.membership_type_id IN ({$value})";
- }
- else {
- $where[] = "e.membership_type_id IS NULL";
- }
-
- $where[] = "( e.is_override IS NULL OR e.is_override = 0 )";
- $dateField = str_replace('membership_', 'e.', $actionSchedule->start_action_date);
- $notINClause = self::permissionedRelationships($contactField);
-
- $membershipStatus = CRM_Member_PseudoConstant::membershipStatus(NULL, "(is_current_member = 1 OR name = 'Expired')", 'id');
- $mStatus = implode(',', $membershipStatus);
- $where[] = "e.status_id IN ({$mStatus})";
-
- // We are not tracking the reference date for 'repeated' schedule reminders,
- // for further details please check CRM-15376
- if ($actionSchedule->start_action_date && $actionSchedule->is_repeat == FALSE) {
- $select[] = $dateField;
- $selectColumns = "reference_date, " . $selectColumns;
- }
- }
-
- if ($mapping->entity == 'civicrm_contact') {
- $contactFields = array(
- 'birth_date',
- 'created_date',
- 'modified_date',
- );
- if (in_array($value, $contactFields)) {
- $dateDBField = $value;
- $table = 'civicrm_contact e';
- $contactField = 'e.id';
- $where[] = 'e.is_deleted = 0';
- $where[] = 'e.is_deceased = 0';
- }
- else {
- //custom field
- $customFieldParams = array('id' => substr($value, 7));
- $customGroup = $customField = array();
- CRM_Core_BAO_CustomField::retrieve($customFieldParams, $customField);
- $dateDBField = $customField['column_name'];
- $customGroupParams = array('id' => $customField['custom_group_id'], $customGroup);
- CRM_Core_BAO_CustomGroup::retrieve($customGroupParams, $customGroup);
- $from = $table = "{$customGroup['table_name']} e";
- $contactField = 'e.entity_id';
- $where[] = '1'; // possible to have no "where" in this case
- }
-
- $status_ = explode(',', $status);
- if (in_array(2, $status_)) {
- // anniversary mode:
- $dateField = 'DATE_ADD(e.' . $dateDBField . ', INTERVAL ROUND(DATEDIFF(DATE(' . $now . '), e.' . $dateDBField . ') / 365) YEAR)';
- $anniversary = TRUE;
- }
- else {
- // regular mode:
- $dateField = 'e.' . $dateDBField;
- }
- }
-
- // CRM-13577 Introduce Smart Groups Handling
- if ($actionSchedule->group_id) {
-
- // Need to check if its a smart group or not
- // Then decide which table to join onto the query
- $group = CRM_Contact_DAO_Group::getTableName();
-
- // Get the group information
- $sql = "
-SELECT $group.id, $group.cache_date, $group.saved_search_id, $group.children
-FROM $group
-WHERE $group.id = {$actionSchedule->group_id}
-";
-
- $groupDAO = CRM_Core_DAO::executeQuery($sql);
- $isSmartGroup = FALSE;
- if (
- $groupDAO->fetch() &&
- !empty($groupDAO->saved_search_id)
- ) {
- // Check that the group is in place in the cache and up to date
- CRM_Contact_BAO_GroupContactCache::check($actionSchedule->group_id);
- // Set smart group flag
- $isSmartGroup = TRUE;
- }
- }
- // CRM-13577 End Introduce Smart Groups Handling
-
- if ($limitTo) {
- if ($actionSchedule->group_id) {
- // CRM-13577 If smart group then use Cache table
- if ($isSmartGroup) {
- $join[] = "INNER JOIN civicrm_group_contact_cache grp ON {$contactField} = grp.contact_id";
- $where[] = "grp.group_id IN ({$actionSchedule->group_id})";
- }
- else {
- $join[] = "INNER JOIN civicrm_group_contact grp ON {$contactField} = grp.contact_id AND grp.status = 'Added'";
- $where[] = "grp.group_id IN ({$actionSchedule->group_id})";
- }
- }
- elseif (!empty($actionSchedule->recipient_manual)) {
- $rList = CRM_Utils_Type::escape($actionSchedule->recipient_manual, 'String');
- $where[] = "{$contactField} IN ({$rList})";
- }
- }
- elseif (!is_null($limitTo)) {
- $addGroup = $addWhere = '';
- if ($actionSchedule->group_id) {
- // CRM-13577 If smart group then use Cache table
- if ($isSmartGroup) {
- $addGroup = " INNER JOIN civicrm_group_contact_cache grp ON c.id = grp.contact_id";
- $addWhere = " grp.group_id IN ({$actionSchedule->group_id})";
- }
- else {
- $addGroup = " INNER JOIN civicrm_group_contact grp ON c.id = grp.contact_id AND grp.status = 'Added'";
- $addWhere = " grp.group_id IN ({$actionSchedule->group_id})";
- }
- }
- if (!empty($actionSchedule->recipient_manual)) {
- $rList = CRM_Utils_Type::escape($actionSchedule->recipient_manual, 'String');
- $addWhere = "c.id IN ({$rList})";
- }
- }
-
- $select[] = "{$contactField} as contact_id";
- $select[] = 'e.id as entity_id';
- $select[] = "'{$mapping->entity}' as entity_table";
- $select[] = "{$actionSchedule->id} as action_schedule_id";
- $reminderJoinClause = "civicrm_action_log reminder ON reminder.contact_id = {$contactField} AND
-reminder.entity_id = e.id AND
-reminder.entity_table = '{$mapping->entity}' AND
-reminder.action_schedule_id = %1";
-
- if ($anniversary) {
- // only consider reminders less than 11 months ago
- $reminderJoinClause .= " AND reminder.action_date_time > DATE_SUB({$now}, INTERVAL 11 MONTH)";
- }
-
- if ($table != 'civicrm_contact e') {
- $join[] = "INNER JOIN civicrm_contact c ON c.id = {$contactField} AND c.is_deleted = 0 AND c.is_deceased = 0 ";
- }
-
- if ($actionSchedule->start_action_date) {
- $startDateClause = array();
- $op = ($actionSchedule->start_action_condition == 'before' ? '<=' : '>=');
- $operator = ($actionSchedule->start_action_condition == 'before' ? 'DATE_SUB' : 'DATE_ADD');
- $date = $operator . "({$dateField}, INTERVAL {$actionSchedule->start_action_offset} {$actionSchedule->start_action_unit})";
- $startDateClause[] = "'{$now}' >= {$date}";
- if ($mapping->entity == 'civicrm_participant') {
- $startDateClause[] = $operator . "({$now}, INTERVAL 1 DAY ) {$op} " . $dateField;
- }
- else {
- $startDateClause[] = "DATE_SUB({$now}, INTERVAL 1 DAY ) <= {$date}";
- }
-
- $startDate = implode(' AND ', $startDateClause);
- }
- elseif ($actionSchedule->absolute_date) {
- $startDate = "DATEDIFF(DATE('{$now}'),'{$actionSchedule->absolute_date}') = 0";
- }
-
- // ( now >= date_built_from_start_time ) OR ( now = absolute_date )
- $dateClause = "reminder.id IS NULL AND {$startDate}";
-
- // start composing query
- $selectClause = 'SELECT ' . implode(', ', $select);
- $fromClause = "FROM $from";
- $joinClause = !empty($join) ? implode(' ', $join) : '';
- $whereClause = 'WHERE ' . implode(' AND ', $where);
- $limitWhereClause = '';
- if (!empty($limitWhere)) {
- $limitWhereClause = ' AND ' . implode(' AND ', $limitWhere);
- }
-
- $query = "
-INSERT INTO civicrm_action_log ({$selectColumns})
-{$selectClause}
-{$fromClause}
-{$joinClause}
-LEFT JOIN {$reminderJoinClause}
-{$whereClause} {$limitWhereClause} AND {$dateClause} {$notINClause}
-";
-
- // In some cases reference_date got outdated due to many reason e.g. In Membership renewal end_date got extended
- // which means reference date mismatches with the end_date where end_date may be used as the start_action_date
- // criteria for some schedule reminder so in order to send new reminder we INSERT new reminder with new reference_date
- // value via UNION operation
- if (strpos($selectColumns, 'reference_date') !== FALSE) {
- $dateClause = str_replace('reminder.id IS NULL', 'reminder.id IS NOT NULL', $dateClause);
- $referenceQuery = "
-INSERT INTO civicrm_action_log ({$selectColumns})
-{$selectClause}
-{$fromClause}
-{$joinClause}
- LEFT JOIN {$reminderJoinClause}
-{$whereClause} {$limitWhereClause} {$notINClause} AND {$dateClause} AND
- reminder.action_date_time IS NOT NULL AND
- reminder.reference_date IS NOT NULL
-GROUP BY reminder.id, reminder.reference_date
-HAVING reminder.id = MAX(reminder.id) AND reminder.reference_date <> {$dateField}
-";
- }
-
- CRM_Core_DAO::executeQuery($query, array(1 => array($actionSchedule->id, 'Integer')));
-
- if (!empty($referenceQuery)) {
- CRM_Core_DAO::executeQuery($referenceQuery, array(1 => array($actionSchedule->id, 'Integer')));
- }
-
- $isSendToAdditionalContacts = (!is_null($limitTo) && $limitTo == 0 && (!empty($addGroup) || !empty($addWhere))) ? TRUE : FALSE;
- if ($isSendToAdditionalContacts) {
- $contactTable = "civicrm_contact c";
- $addSelect = "SELECT c.id as contact_id, c.id as entity_id, 'civicrm_contact' as entity_table, {$actionSchedule->id} as action_schedule_id";
- $additionReminderClause = "civicrm_action_log reminder ON reminder.contact_id = c.id AND
- reminder.entity_id = c.id AND
- reminder.entity_table = 'civicrm_contact' AND
- reminder.action_schedule_id = {$actionSchedule->id}";
- $addWhereClause = '';
- if ($addWhere) {
- $addWhereClause = "AND {$addWhere}";
- }
- $insertAdditionalSql = "
-INSERT INTO civicrm_action_log (contact_id, entity_id, entity_table, action_schedule_id)
-{$addSelect}
-FROM ({$contactTable})
-LEFT JOIN {$additionReminderClause}
-{$addGroup}
-WHERE c.is_deleted = 0 AND c.is_deceased = 0
-{$addWhereClause}
-
-AND c.id NOT IN (
- SELECT rem.contact_id
- FROM civicrm_action_log rem INNER JOIN {$mapping->entity} e ON rem.entity_id = e.id
- WHERE rem.action_schedule_id = {$actionSchedule->id}
- AND rem.entity_table = '{$mapping->entity}'
- )
-GROUP BY c.id
-";
- CRM_Core_DAO::executeQuery($insertAdditionalSql);
- }
- // if repeat is turned ON:
- if ($actionSchedule->is_repeat) {
- $repeatEvent = ($actionSchedule->end_action == 'before' ? 'DATE_SUB' : 'DATE_ADD') . "({$dateField}, INTERVAL {$actionSchedule->end_frequency_interval} {$actionSchedule->end_frequency_unit})";
-
- if ($actionSchedule->repetition_frequency_unit == 'day') {
- $interval = "{$actionSchedule->repetition_frequency_interval} DAY";
- }
- elseif ($actionSchedule->repetition_frequency_unit == 'week') {
- $interval = "{$actionSchedule->repetition_frequency_interval} WEEK";
- }
- elseif ($actionSchedule->repetition_frequency_unit == 'month') {
- $interval = "{$actionSchedule->repetition_frequency_interval} MONTH";
- }
- elseif ($actionSchedule->repetition_frequency_unit == 'year') {
- $interval = "{$actionSchedule->repetition_frequency_interval} YEAR";
- }
- else {
- $interval = "{$actionSchedule->repetition_frequency_interval} HOUR";
- }
-
- // (now <= repeat_end_time )
- $repeatEventClause = "'{$now}' <= {$repeatEvent}";
- // diff(now && logged_date_time) >= repeat_interval
- $havingClause = "HAVING TIMESTAMPDIFF(HOUR, latest_log_time, CAST({$now} AS datetime)) >= TIMESTAMPDIFF(HOUR, latest_log_time, DATE_ADD(latest_log_time, INTERVAL $interval))";
- $groupByClause = 'GROUP BY reminder.contact_id, reminder.entity_id, reminder.entity_table';
- $selectClause .= ', MAX(reminder.action_date_time) as latest_log_time';
- //CRM-15376 - do not send our reminders if original criteria no longer applies
- // the first part of the startDateClause array is the earliest the reminder can be sent. If the
- // event (e.g membership_end_date) has changed then the reminder may no longer apply
- // @todo - this only handles events that get moved later. Potentially they might get moved earlier
- $originalEventStartDateClause = empty($startDateClause) ? '' : 'AND' . $startDateClause[0];
- $sqlInsertValues = "{$selectClause}
-{$fromClause}
-{$joinClause}
-INNER JOIN {$reminderJoinClause}
-{$whereClause} {$limitWhereClause} AND {$repeatEventClause} {$originalEventStartDateClause} {$notINClause}
-{$groupByClause}
-{$havingClause}";
-
- $valsqlInsertValues = CRM_Core_DAO::executeQuery($sqlInsertValues, array(
- 1 => array(
- $actionSchedule->id,
- 'Integer',
- ),
- )
- );
-
- $arrValues = array();
- while ($valsqlInsertValues->fetch()) {
- $arrValues[] = "( {$valsqlInsertValues->contact_id}, {$valsqlInsertValues->entity_id}, '{$valsqlInsertValues->entity_table}',{$valsqlInsertValues->action_schedule_id} )";
- }
-
- $valString = implode(',', $arrValues);
-
- if ($valString) {
- $query = '
- INSERT INTO civicrm_action_log (contact_id, entity_id, entity_table, action_schedule_id) VALUES ' . $valString;
- CRM_Core_DAO::executeQuery($query, array(1 => array($actionSchedule->id, 'Integer')));
- }
-
- if ($isSendToAdditionalContacts) {
- $addSelect .= ', MAX(reminder.action_date_time) as latest_log_time';
- $sqlEndEventCheck = "
-SELECT * FROM {$table}
-{$whereClause} AND {$repeatEventClause} LIMIT 1";
-
- $daoCheck = CRM_Core_DAO::executeQuery($sqlEndEventCheck);
- if ($daoCheck->fetch()) {
- $valSqlAdditionInsert = "
-{$addSelect}
-FROM {$contactTable}
-{$addGroup}
-INNER JOIN {$additionReminderClause}
-WHERE {$addWhere} AND c.is_deleted = 0 AND c.is_deceased = 0
-GROUP BY reminder.contact_id
-{$havingClause}
-";
- $daoForVals = CRM_Core_DAO::executeQuery($valSqlAdditionInsert);
- $addValues = array();
- while ($daoForVals->fetch()) {
- $addValues[] = "( {$daoForVals->contact_id}, {$daoForVals->entity_id}, '{$daoForVals->entity_table}',{$daoForVals->action_schedule_id} )";
- }
- $valString = implode(',', $addValues);
-
- if ($valString) {
- $query = '
- INSERT INTO civicrm_action_log (contact_id, entity_id, entity_table, action_schedule_id) VALUES ' . $valString;
- CRM_Core_DAO::executeQuery($query);
- }
- }
- }
- }