* Group id.
* @param string $mode
* Helps decide how to behave when there are conflicts.
- * A 'safe' value skips the merge if there are any un-resolved conflicts.
- * Does a force merge otherwise.
+ * A 'safe' value skips the merge if there are any un-resolved conflicts, wheras 'aggressive'
+ * mode does a force merge.
* @param bool $autoFlip to let api decide which contact to retain and which to delete.
- * Wether to let api decide which contact to retain and which to delete.
+ * Whether to let api decide which contact to retain and which to delete.
* @param int $batchLimit number of merges to carry out in one batch.
* @param int $isSelected if records with is_selected column needs to be processed.
*
+ * @param array $criteria
+ * Criteria to use in the filter.
+ *
+ * @param bool $checkPermissions
+ * Respect logged in user permissions.
+ *
* @return array|bool
*/
- public static function batchMerge($rgid, $gid = NULL, $mode = 'safe', $autoFlip = TRUE, $batchLimit = 1, $isSelected = 2) {
- $contactType = CRM_Core_DAO::getFieldValue('CRM_Dedupe_DAO_RuleGroup', $rgid, 'contact_type');
- $cacheKeyString = "merge {$contactType}";
- $cacheKeyString .= $rgid ? "_{$rgid}" : '_0';
- $cacheKeyString .= $gid ? "_{$gid}" : '_0';
- $join = "LEFT JOIN civicrm_dedupe_exception de ON ( pn.entity_id1 = de.contact_id1 AND
- pn.entity_id2 = de.contact_id2 )";
+ public static function batchMerge($rgid, $gid = NULL, $mode = 'safe', $autoFlip = TRUE, $batchLimit = 1, $isSelected = 2, $criteria = array(), $checkPermissions = TRUE) {
+ $redirectForPerformance = ($batchLimit > 1) ? TRUE : FALSE;
+ $reloadCacheIfEmpty = (!$redirectForPerformance && $isSelected == 2);
+ $dupePairs = self::getDuplicatePairs($rgid, $gid, $reloadCacheIfEmpty, $batchLimit, $isSelected, '', ($mode == 'aggressive'), $criteria, $checkPermissions);
+
+ $cacheParams = array(
+ 'cache_key_string' => self::getMergeCacheKeyString($rgid, $gid, $criteria, $checkPermissions),
+ // @todo stop passing these parameters in & instead calculate them in the merge function based
+ // on the 'real' params like $isRespectExclusions $batchLimit and $isSelected.
+ 'join' => self::getJoinOnDedupeTable(),
+ 'where' => self::getWhereString($batchLimit, $isSelected),
+ );
+ return CRM_Dedupe_Merger::merge($dupePairs, $cacheParams, $mode, $autoFlip, $redirectForPerformance, $checkPermissions);
+ }
+ /**
+ * Get the string to join the prevnext cache to the dedupe table.
+ *
+ * @return string
+ * The join string to join prevnext cache on the dedupe table.
+ */
+ public static function getJoinOnDedupeTable() {
+ return "
+ LEFT JOIN civicrm_dedupe_exception de
+ ON (
+ pn.entity_id1 = de.contact_id1
+ AND pn.entity_id2 = de.contact_id2 )
+ ";
+ }
+
+ /**
+ * Get where string for dedupe join.
+ *
+ * @param int $batchLimit
+ * @param bool $isSelected
+ *
+ * @return string
+ */
+ protected static function getWhereString($batchLimit, $isSelected) {
$where = "de.id IS NULL";
if ($isSelected === 0 || $isSelected === 1) {
$where .= " AND pn.is_selected = {$isSelected}";
- }// else consider all dupe pairs
- $where .= " LIMIT {$batchLimit}";
-
- $redirectForPerformance = ($batchLimit > 1) ? TRUE : FALSE;
-
- $dupePairs = CRM_Core_BAO_PrevNextCache::retrieve($cacheKeyString, $join, $where);
- if (empty($dupePairs) && !$redirectForPerformance && $isSelected == 2) {
- // If we haven't found any dupes, probably cache is empty.
- // Try filling cache and give another try.
- CRM_Core_BAO_PrevNextCache::refillCache($rgid, $gid, $cacheKeyString);
- $dupePairs = CRM_Core_BAO_PrevNextCache::retrieve($cacheKeyString, $join, $where);
}
-
- $cacheParams = array(
- 'cache_key_string' => $cacheKeyString,
- 'join' => $join,
- 'where' => $where,
- );
- return CRM_Dedupe_Merger::merge($dupePairs, $cacheParams, $mode, $autoFlip, $redirectForPerformance);
+ // else consider all dupe pairs
+ // @todo Adding limit to Where??!!
+ $where .= " LIMIT {$batchLimit}";
+ return $where;
}
public static function updateMergeStats($cacheKeyString, $result = array()) {
CRM_Core_BAO_PrevNextCache::setItem($values);
}
+ /**
+ * Delete information about merges for the given string.
+ *
+ * @param $cacheKeyString
+ */
public static function resetMergeStats($cacheKeyString) {
- return CRM_Core_BAO_PrevNextCache::deleteItem(NULL, "{$cacheKeyString}_stats");
+ CRM_Core_BAO_PrevNextCache::deleteItem(NULL, "{$cacheKeyString}_stats");
}
public static function getMergeStats($cacheKeyString) {
* A 'safe' value skips the merge if there are any un-resolved conflicts.
* Does a force merge otherwise (aggressive mode).
* @param bool $autoFlip to let api decide which contact to retain and which to delete.
- * Wether to let api decide which contact to retain and which to delete.
- *
+ * Whether to let api decide which contact to retain and which to delete.
*
* @param bool $redirectForPerformance
+ * Redirect to a url for batch processing.
+ *
+ * @param bool $checkPermissions
+ * Respect logged in user permissions.
*
* @return array|bool
*/
public static function merge($dupePairs = array(), $cacheParams = array(), $mode = 'safe',
- $autoFlip = TRUE, $redirectForPerformance = FALSE
+ $autoFlip = TRUE, $redirectForPerformance = FALSE, $checkPermissions = TRUE
) {
$cacheKeyString = CRM_Utils_Array::value('cache_key_string', $cacheParams);
$resultStats = array('merged' => array(), 'skipped' => array());
// doNotResetCache flag
$config = CRM_Core_Config::singleton();
$config->doNotResetCache = 1;
+ $deletedContacts = array();
while (!empty($dupePairs)) {
- foreach ($dupePairs as $dupes) {
+ foreach ($dupePairs as $index => $dupes) {
+ if (in_array($dupes['dstID'], $deletedContacts) || in_array($dupes['srcID'], $deletedContacts)) {
+ unset($dupePairs[$index]);
+ continue;
+ }
CRM_Utils_Hook::merge('flip', $dupes, $dupes['dstID'], $dupes['srcID']);
$mainId = $dupes['dstID'];
$otherId = $dupes['srcID'];
// Generate var $migrationInfo. The variable structure is exactly same as
// $formValues submitted during a UI merge for a pair of contacts.
- $rowsElementsAndInfo = CRM_Dedupe_Merger::getRowsElementsAndInfo($mainId, $otherId);
+ $rowsElementsAndInfo = CRM_Dedupe_Merger::getRowsElementsAndInfo($mainId, $otherId, $checkPermissions);
$migrationInfo = &$rowsElementsAndInfo['migration_info'];
// add additional details that we might need to resolve conflicts
$migrationInfo['main_details'] = &$rowsElementsAndInfo['main_details'];
$migrationInfo['other_details'] = &$rowsElementsAndInfo['other_details'];
- $migrationInfo['main_loc_block'] = &$rowsElementsAndInfo['main_loc_block'];
$migrationInfo['rows'] = &$rowsElementsAndInfo['rows'];
// go ahead with merge if there is no conflict
$conflicts = array();
if (!CRM_Dedupe_Merger::skipMerge($mainId, $otherId, $migrationInfo, $mode, $conflicts)) {
- CRM_Dedupe_Merger::moveAllBelongings($mainId, $otherId, $migrationInfo);
+ CRM_Dedupe_Merger::moveAllBelongings($mainId, $otherId, $migrationInfo, $checkPermissions);
$resultStats['merged'][] = array('main_id' => $mainId, 'other_id' => $otherId);
+ $deletedContacts[] = $otherId;
}
else {
$resultStats['skipped'][] = array('main_id' => $mainId, 'other_id' => $otherId);
if ($cacheKeyString && !$redirectForPerformance) {
// retrieve next pair of dupes
+ // @todo call getDuplicatePairs.
$dupePairs = CRM_Core_BAO_PrevNextCache::retrieve($cacheKeyString,
$cacheParams['join'],
- $cacheParams['where']
+ $cacheParams['where'],
+ 0,
+ 0,
+ array(),
+ '',
+ FALSE
);
}
else {
*/
public static function skipMerge($mainId, $otherId, &$migrationInfo, $mode = 'safe', &$conflicts = array()) {
- $migrationData = array(
- 'old_migration_info' => $migrationInfo,
- 'mode' => $mode,
- );
-
- $allLocationTypes = CRM_Core_PseudoConstant::get('CRM_Core_DAO_Address', 'location_type_id');
-
+ $originalMigrationInfo = $migrationInfo;
foreach ($migrationInfo as $key => $val) {
if ($val === "null") {
// Rule: Never overwrite with an empty value (in any mode)
// Rule: If both main-contact, and other-contact have a field with a
// different value, then let $mode decide if to merge it or not
if (
- !empty($migrationInfo['rows'][$key]['main'])
+ (!empty($migrationInfo['rows'][$key]['main'])
+ // For custom fields a 0 (e.g in an int field) could be a true conflict. This
+ // is probably true for other fields too - e.g. 'do_not_email' but
+ // leaving that investigation as a @todo - until tests can be written.
+ // Note the handling of this has test coverage - although the data-typing
+ // of '0' feels flakey we have insurance.
+ || ($migrationInfo['rows'][$key]['main'] === '0' && substr($key, 0, 12) == 'move_custom_')
+ )
&& $migrationInfo['rows'][$key]['main'] != $migrationInfo['rows'][$key]['other']
) {
$fieldName = $locField[2];
$fieldCount = $locField[3];
- // Rule: resolve address conflict if any
+ // Rule: Catch address conflicts (same address type on both contacts)
if ($fieldName == 'address') {
- $mainNewLocTypeId = $migrationInfo['location_blocks'][$fieldName][$fieldCount]['locTypeId'];
- if (!empty($migrationInfo['main_loc_block']) &&
- array_key_exists("main_address_{$mainNewLocTypeId}", $migrationInfo['main_loc_block'])) {
- // main loc already has some address for the loc-type. Its a overwrite situation.
- // look for next available loc-type
- $newTypeId = NULL;
- foreach ($allLocationTypes as $typeId => $typeLabel) {
- if (!array_key_exists("main_address_{$typeId}", $migrationInfo['main_loc_block'])) {
- $newTypeId = $typeId;
- }
+ if (
+ isset($migrationInfo['main_details']['location_blocks']['address']) &&
+ !empty($migrationInfo['main_details']['location_blocks']['address'])
+ ) {
+ $otherAddresses = $migrationInfo['other_details']['location_blocks']['address'];
+ $otherAddressLookup = array();
+ foreach ($otherAddresses as $otherAddressIndex => $otherAddress) {
+ $otherAddressLookup[$otherAddress['location_type_id']] = $otherAddressIndex;
}
- if ($newTypeId) {
- // try insert address at new available loc-type
- $migrationInfo['location_blocks'][$fieldName][$fieldCount]['locTypeId'] = $newTypeId;
- }
- else {
- // note it down & lets wait for response from the hook.
- // For no response $mode will decide if to skip this merge
- $conflicts[$key] = NULL;
+ // Look for this LocTypeId in the results
+ // @todo This can be streamlined using array_column() in PHP 5.5+
+ foreach ($migrationInfo['main_details']['location_blocks']['address'] as $addressKey => $addressRecord) {
+ $otherAddressIndex = CRM_Utils_Array::value($addressRecord['location_type_id'], $otherAddressLookup);
+ $hasMatchingAddress = FALSE;
+ foreach ($otherAddresses as $otherAddress) {
+ if (self::addressIsSame($addressRecord, $otherAddress)) {
+ $hasMatchingAddress = TRUE;
+ }
+ }
+ if ($hasMatchingAddress) {
+ unset($migrationInfo[$key]);
+ }
+ elseif (!empty($otherAddresses[$otherAddressIndex]) && !self::addressIsSame($addressRecord, $otherAddresses[$otherAddressIndex])) {
+ $conflicts[$key] = NULL;
+ break;
+ }
}
}
}
+ // For other locations, don't merge/add if the values are the same
elseif ($migrationInfo['rows'][$key]['main'] == $migrationInfo['rows'][$key]['other']) {
- // for loc blocks other than address like email, phone .. if values are same no point in merging
- // and adding redundant value
unset($migrationInfo[$key]);
}
}
// there's a conflict (to handle "gotchas"). fields_in_conflict could be modified here
// merge happens with new values filled in here. For a particular field / row not to be merged
// field should be unset from fields_in_conflict.
- $migrationData['fields_in_conflict'] = $conflicts;
- $migrationData['merge_mode'] = $mode;
+ $migrationData = array(
+ 'old_migration_info' => $originalMigrationInfo,
+ 'mode' => $mode,
+ 'fields_in_conflict' => $conflicts,
+ 'merge_mode' => $mode,
+ 'migration_info' => $migrationInfo,
+ );
CRM_Utils_Hook::merge('batch', $migrationData, $mainId, $otherId);
$conflicts = $migrationData['fields_in_conflict'];
// allow hook to override / manipulate migrationInfo as well
- $migrationInfo = $migrationData['old_migration_info'];
+ $migrationInfo = $migrationData['migration_info'];
if (!empty($conflicts)) {
foreach ($conflicts as $key => $val) {
return FALSE;
}
+ /**
+ * Compare 2 addresses to see if they are the same.
+ *
+ * @param array $mainAddress
+ * @param array $comparisonAddress
+ *
+ * @return bool
+ */
+ static protected function addressIsSame($mainAddress, $comparisonAddress) {
+ $keysToIgnore = array('id', 'is_primary', 'is_billing', 'manual_geo_code', 'contact_id');
+ foreach ($comparisonAddress as $field => $value) {
+ if (in_array($field, $keysToIgnore)) {
+ continue;
+ }
+ if (!empty($value) && $mainAddress[$field] != $value) {
+ return FALSE;
+ }
+ }
+ return TRUE;
+ }
+
/**
* A function to build an array of information about location blocks that is
* required when merging location fields
* Main contact with whom merge has to happen.
* @param int $otherId
* Duplicate contact which would be deleted after merge operation.
+ * @param bool $checkPermissions
+ * Should the logged in user's permissions be ignore. Setting this to false is
+ * highly risky as it could cause data to be lost due to conflicts not showing up.
+ * OTOH there is a risk a merger might view custom data they do not have permission to.
+ * Hence for now only making this really explicit and making it reflect perms in
+ * an api call.
+ *
+ * @todo review permissions issue!
*
* @return array|bool|int
- * 'main_loc_block' => Stores all location blocks associated with the 'main' contact
+ *
+ * rows => An array of arrays, each is row of merge information for the table
+ * Format: move_fieldname, eg: move_contact_type
+ * main => Value associated with the main contact
+ * other => Value associated with the other contact
+ * title => The title of the field to display in the merge table
+ *
+ * elements => An array of form elements for the merge UI
+ *
+ * rel_table_elements => An array of form elements for the merge UI for
+ * entities related to the contact (eg: checkbox to move 'mailings')
+ *
+ * rel_tables => Stores the tables that have related entities for the contact
+ * for example mailings, groups
+ *
+ * main_details => An array of core contact field values, eg: first_name, etc.
+ * location_blocks => An array of location block data for the main contact
+ * stored as the 'result' of an API call.
+ * eg: main_details['location_blocks']['address'][0]['id']
+ * eg: main_details['location_blocks']['email'][1]['id']
+ *
+ * other_details => As above, but for the 'other' contact
+ *
+ * migration_info => Stores the 'default' merge actions for each field which
+ * is used when programatically merging contacts. It contains instructions
+ * to move all fields from the 'other' contact to the 'main' contact, as
+ * though the form had been submitted with those options.
+ *
+ * @throws \CRM_Core_Exception
+ * @throws \CiviCRM_API3_Exception
+ * @throws \Exception
*/
- public static function getRowsElementsAndInfo($mainId, $otherId) {
+ public static function getRowsElementsAndInfo($mainId, $otherId, $checkPermissions = TRUE) {
$qfZeroBug = 'e8cddb72-a257-11dc-b9cc-0016d3330ee9';
// Fetch contacts
if (empty($result['values'][$cid]['contact_type'])) {
return FALSE;
}
+
+ // CRM-18480: Cancel the process if the contact is already deleted
+ if (isset($result['values'][$cid]['contact_is_deleted']) && !empty($result['values'][$cid]['contact_is_deleted'])) {
+ throw new CRM_Core_Exception(ts('Cannot merge because the \'%1\' contact (ID %2) has been deleted.', array(1 => $moniker, 2 => $cid)));
+ }
+
$$moniker = $result['values'][$cid];
}
'other' => array(),
);
- $mainLocBlock = array();
-
// @todo This could probably be defined and used earlier
$mergeTargets = array(
'main' => $mainId,
foreach ($values['values'] as $index => $value) {
$locations[$moniker][$blockName][$cnt] = $value;
// Fix address display
- $display = '';
if ($blockName == 'address') {
CRM_Core_BAO_Address::fixAddress($value);
- $display = CRM_Utils_Address::format($value);
- $locations[$moniker][$blockName][$cnt]['display'] = $display;
- }
-
- // Add any 'main' contact block values to an array for the JS
- // @todo The JS should just access the main_details to find this info?
- if ($moniker == 'main') {
- if ($blockInfo['hasType']) {
- // Handle websites, no location type ID
- // @todo Remove the need for this specific 'if'
- if ($blockName == 'website') {
- $value['location_type_id'] = 0;
- }
- $mainLocBlock["main_" . $blockName . "_" . $value['location_type_id'] . "_" . $value[$blockInfo['hasType']]]['display'] = $value[$blockInfo['displayField']];
- $mainLocBlock["main_" . $blockName . "_" . $value['location_type_id'] . "_" . $value[$blockInfo['hasType']]]['id'] = $value['id'];
- }
- else {
- // Get the correct display value for addresses
- // @todo Remove the need for this if...
- if ($blockName == 'address') {
- $mainLocBlock["main_" . $blockName . "_" . $value['location_type_id']]['display'] = $display;
- $mainLocBlock["main_" . $blockName . "_" . $value['location_type_id']]['id'] = $value['id'];
- }
- else {
- $mainLocBlock["main_" . $blockName . "_" . $value['location_type_id']]['display'] = $value[$blockInfo['displayField']];
- $mainLocBlock["main_" . $blockName . "_" . $value['location_type_id']]['id'] = $value['id'];
- }
- }
+ $locations[$moniker][$blockName][$cnt]['display'] = CRM_Utils_Address::format($value);
}
$cnt++;
$migrationInfo["move_location_{$blockName}_{$count}"] = 1;
// Add a hidden field to store the ID of the target main contact block
- $elements[] = array('hidden', "location[$blockName][$count][mainContactBlockId]", $mainContactBlockId);
+ $elements[] = array('hidden', "location_blocks[$blockName][$count][mainContactBlockId]", $mainContactBlockId);
// Setup variables
$thisTypeId = FALSE;
// Add the element
$elements[] = array(
'select',
- "location[$blockName][$count][locTypeId]",
+ "location_blocks[$blockName][$count][locTypeId]",
NULL,
$defaultLocId + $tmpIdList,
$js,
// @todo Check this logic out
$migrationInfo['location_blocks'][$blockName][$count]['locTypeId'] = $thisLocId;
if ($blockName != 'address') {
- $elements[] = array('advcheckbox', "location[{$blockName}][$count][operation]", NULL, ts('add new'));
+ $elements[] = array('advcheckbox', "location_blocks[{$blockName}][$count][operation]", NULL, ts('add new'));
// always use add operation
$migrationInfo['location_blocks'][$blockName][$count]['operation'] = 1;
}
// Add the element
$elements[] = array(
'select',
- "location[$blockName][$count][typeTypeId]",
+ "location_blocks[$blockName][$count][typeTypeId]",
NULL,
$defaultTypeId + $tmpIdList,
$js,
);
- // Add the information to the migrationInfo (@todo Why?)
+ // Add the information to the migrationInfo
$migrationInfo['location_blocks'][$blockName][$count]['typeTypeId'] = $thisTypeId;
}
}
// handle custom fields
- $mainTree = CRM_Core_BAO_CustomGroup::getTree($main['contact_type'], CRM_Core_DAO::$_nullObject, $mainId, -1,
- CRM_Utils_Array::value('contact_sub_type', $main)
+ $mainTree = CRM_Core_BAO_CustomGroup::getTree($main['contact_type'], NULL, $mainId, -1,
+ CRM_Utils_Array::value('contact_sub_type', $main), NULL, TRUE, NULL, TRUE, $checkPermissions
);
$otherTree = CRM_Core_BAO_CustomGroup::getTree($main['contact_type'], CRM_Core_DAO::$_nullObject, $otherId, -1,
- CRM_Utils_Array::value('contact_sub_type', $other)
+ CRM_Utils_Array::value('contact_sub_type', $other), NULL, TRUE, NULL, TRUE, $checkPermissions
);
CRM_Core_DAO::freeResult();
'rows' => $rows,
'elements' => $elements,
'rel_table_elements' => $relTableElements,
- 'main_loc_block' => $mainLocBlock,
'rel_tables' => $relTables,
'main_details' => $main,
'other_details' => $other,
*
* @param $migrationInfo
*
+ * @param bool $checkPermissions
+ * Respect logged in user permissions.
+ *
* @return bool
*/
- public static function moveAllBelongings($mainId, $otherId, $migrationInfo) {
+ public static function moveAllBelongings($mainId, $otherId, $migrationInfo, $checkPermissions = TRUE) {
if (empty($migrationInfo)) {
return FALSE;
}
// @todo Tidy this up
$operation = 0;
if ($fieldName != 'website') {
- $operation = CRM_Utils_Array::value('operation', $migrationInfo['location'][$fieldName][$fieldCount]);
+ $operation = CRM_Utils_Array::value('operation', $migrationInfo['location_blocks'][$fieldName][$fieldCount]);
}
// default operation is overwrite.
if (!$operation) {
// Add/update location and type information from the form, if applicable
if ($locationBlocks[$name]['hasLocation']) {
- $locTypeId = CRM_Utils_Array::value('locTypeId', $migrationInfo['location'][$name][$blkCount]);
+ $locTypeId = CRM_Utils_Array::value('locTypeId', $migrationInfo['location_blocks'][$name][$blkCount]);
$otherBlockDAO->location_type_id = $locTypeId;
}
if ($locationBlocks[$name]['hasType']) {
- $typeTypeId = CRM_Utils_Array::value('typeTypeId', $migrationInfo['location'][$name][$blkCount]);
+ $typeTypeId = CRM_Utils_Array::value('typeTypeId', $migrationInfo['location_blocks'][$name][$blkCount]);
$otherBlockDAO->{$locationBlocks[$name]['hasType']} = $typeTypeId;
}
// Get main block ID
- $mainBlockId = CRM_Utils_Array::value('mainContactBlockId', $migrationInfo['location'][$name][$blkCount], 0);
+ $mainBlockId = CRM_Utils_Array::value('mainContactBlockId', $migrationInfo['location_blocks'][$name][$blkCount], 0);
// if main contact already has primary & billing, set the flags to 0.
if ($primaryDAOId) {
$submitted[$key] = CRM_Core_BAO_CustomField::displayValue($value, $fid);
break;
+ case 'Select Date':
+ if ($cFields[$fid]['attributes']['is_view']) {
+ $submitted[$key] = date('YmdHis', strtotime($submitted[$key]));
+ }
+ break;
+
case 'CheckBox':
case 'AdvMulti-Select':
case 'Multi-Select':
CRM_Core_BAO_CustomValueTable::setValues($viewOnlyCustomFields);
}
- if (CRM_Core_Permission::check('merge duplicate contacts') &&
- CRM_Core_Permission::check('delete contacts')
+ if (!$checkPermissions || (CRM_Core_Permission::check('merge duplicate contacts') &&
+ CRM_Core_Permission::check('delete contacts'))
) {
// if ext id is submitted then set it null for contact to be deleted
if (!empty($submitted['external_identifier'])) {
$query = "UPDATE civicrm_contact SET external_identifier = null WHERE id = {$otherId}";
CRM_Core_DAO::executeQuery($query);
}
-
civicrm_api3('contact', 'delete', array('id' => $otherId));
- CRM_Core_BAO_PrevNextCache::deleteItem($otherId);
}
- // FIXME: else part
- // else {
- // CRM_Core_Session::setStatus( ts('Do not have sufficient permission to delete duplicate contact.') );
- // }
// CRM-15681 merge sub_types
if ($other_sub_types = CRM_Utils_array::value('contact_sub_type', $migrationInfo['other_details'])) {
$contactFields = CRM_Contact_DAO_Contact::fields();
$invalidFields = array(
'api_key',
- 'contact_is_deleted',
'created_date',
'display_name',
'hash',
2 => $mainId,
);
$activity = civicrm_api3('activity', 'create', array(
+ 'source_contact_id' => CRM_Core_Session::getLoggedInContactID() ? CRM_Core_Session::getLoggedInContactID() :
+ $mainId,
'subject' => ts('Contact ID %1 has been merged and deleted.', $params),
'target_contact_id' => $mainId,
'activity_type_id' => 'Contact Merged',
));
if (civicrm_api3('Setting', 'getvalue', array('name' => 'contact_undelete', 'group' => 'CiviCRM Preferences'))) {
civicrm_api3('activity', 'create', array(
+ 'source_contact_id' => CRM_Core_Session::getLoggedInContactID() ? CRM_Core_Session::getLoggedInContactID() :
+ $otherId,
'subject' => ts('Contact ID %1 has been merged into Contact ID %2 and deleted.', $params),
'target_contact_id' => $otherId,
'activity_type_id' => 'Contact Deleted by Merge',
}
}
+ /**
+ * Get Duplicate Pairs based on a rule for a group.
+ *
+ * @param int $rule_group_id
+ * @param int $group_id
+ * @param bool $reloadCacheIfEmpty
+ * @param int $batchLimit
+ * @param bool $isSelected
+ * @param array|string $orderByClause
+ * @param bool $includeConflicts
+ * @param array $criteria
+ * Additional criteria to narrow down the merge group.
+ *
+ * @param bool $checkPermissions
+ * Respect logged in user permissions.
+ *
+ * @return array
+ * Array of matches meeting the criteria.
+ */
+ public static function getDuplicatePairs($rule_group_id, $group_id, $reloadCacheIfEmpty, $batchLimit, $isSelected, $orderByClause = '', $includeConflicts = TRUE, $criteria = array(), $checkPermissions = TRUE) {
+ $where = self::getWhereString($batchLimit, $isSelected);
+ $cacheKeyString = self::getMergeCacheKeyString($rule_group_id, $group_id, $criteria, $checkPermissions);
+ $join = self::getJoinOnDedupeTable();
+ $dupePairs = CRM_Core_BAO_PrevNextCache::retrieve($cacheKeyString, $join, $where, 0, 0, array(), $orderByClause, $includeConflicts);
+ if (empty($dupePairs) && $reloadCacheIfEmpty) {
+ // If we haven't found any dupes, probably cache is empty.
+ // Try filling cache and give another try. We don't need to specify include conflicts here are there will not be any
+ // until we have done some processing.
+ CRM_Core_BAO_PrevNextCache::refillCache($rule_group_id, $group_id, $cacheKeyString, $criteria, $checkPermissions);
+ $dupePairs = CRM_Core_BAO_PrevNextCache::retrieve($cacheKeyString, $join, $where, 0, 0, array(), $orderByClause, $includeConflicts);
+ return $dupePairs;
+ }
+ return $dupePairs;
+ }
+
+ /**
+ * Get the cache key string for the merge action.
+ *
+ * @param int $rule_group_id
+ * @param int $group_id
+ * @param array $criteria
+ * Additional criteria to narrow down the merge group.
+ * Currently we are only supporting the key 'contact' within it.
+ *
+ * @param bool $checkPermissions
+ * Respect the users permissions.
+ *
+ * @return string
+ */
+ public static function getMergeCacheKeyString($rule_group_id, $group_id, $criteria = array(), $checkPermissions = TRUE) {
+ $contactType = CRM_Dedupe_BAO_RuleGroup::getContactTypeForRuleGroup($rule_group_id);
+ $cacheKeyString = "merge {$contactType}";
+ $cacheKeyString .= $rule_group_id ? "_{$rule_group_id}" : '_0';
+ $cacheKeyString .= $group_id ? "_{$group_id}" : '_0';
+ $cacheKeyString .= !empty($criteria) ? serialize($criteria) : '_0';
+ if ($checkPermissions) {
+ $contactID = CRM_Core_Session::getLoggedInContactID();
+ if (!$contactID) {
+ // Distinguish between no permission check & no logged in user.
+ $contactID = 'null';
+ }
+ $cacheKeyString .= '_' . $contactID;
+ }
+ else {
+ $cacheKeyString .= '_0';
+ }
+ return $cacheKeyString;
+ }
+
}
projects / civicrm-core.git / blobdiff