3 +--------------------------------------------------------------------+
4 | CiviCRM version 4.7 |
5 +--------------------------------------------------------------------+
6 | Copyright CiviCRM LLC (c) 2004-2018 |
7 +--------------------------------------------------------------------+
8 | This file is a part of CiviCRM. |
10 | CiviCRM is free software; you can copy, modify, and distribute it |
11 | under the terms of the GNU Affero General Public License |
12 | Version 3, 19 November 2007 and the CiviCRM Licensing Exception. |
14 | CiviCRM is distributed in the hope that it will be useful, but |
15 | WITHOUT ANY WARRANTY; without even the implied warranty of |
16 | MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. |
17 | See the GNU Affero General Public License for more details. |
19 | You should have received a copy of the GNU Affero General Public |
20 | License and the CiviCRM Licensing Exception along |
21 | with this program; if not, contact CiviCRM LLC |
22 | at info[AT]civicrm[DOT]org. If you have questions about the |
23 | GNU Affero General Public License or the licensing of CiviCRM, |
24 | see the CiviCRM license FAQ at http://civicrm.org/licensing |
25 +--------------------------------------------------------------------+
31 * @copyright CiviCRM LLC (c) 2004-2018
33 class CRM_Contact_Page_DedupeMerge
extends CRM_Core_Page
{
38 * Browse batch merges.
40 public function run() {
41 $runner = self
::getRunner();
43 $runner->runAllViaWeb();
46 CRM_Core_Session
::setStatus(ts('Nothing to merge.'));
52 * Build a queue of tasks by dividing dupe pairs in batches.
54 public static function getRunner() {
55 $rgid = CRM_Utils_Request
::retrieveValue('rgid', 'Positive');
56 $gid = CRM_Utils_Request
::retrieveValue('gid', 'Positive');
57 $limit = CRM_Utils_Request
::retrieveValue('limit', 'Positive');
58 $action = CRM_Utils_Request
::retrieveValue('action', 'String');
59 $mode = CRM_Utils_Request
::retrieveValue('mode', 'String', 'safe');
61 $cacheKeyString = CRM_Dedupe_Merger
::getMergeCacheKeyString($rgid, $gid);
71 if ($mode == 'aggressive' && !CRM_Core_Permission
::check('force merge duplicate contacts')) {
72 CRM_Core_Session
::setStatus(ts('You do not have permission to force merge duplicate contact records'), ts('Permission Denied'), 'error');
73 CRM_Utils_System
::redirect(CRM_Utils_System
::url('civicrm/contact/dedupefind', $urlQry));
76 $queue = CRM_Queue_Service
::singleton()->create(array(
77 'name' => $cacheKeyString,
83 if ($action == CRM_Core_Action
::MAP
) {
84 $where = "pn.is_selected = 1";
92 $total = CRM_Core_BAO_PrevNextCache
::getCount($cacheKeyString, NULL, $where);
95 CRM_Utils_System
::redirect(CRM_Utils_System
::url('civicrm/contact/dedupefind', $urlQry));
98 // reset merge stats, so we compute new stats
99 CRM_Dedupe_Merger
::resetMergeStats($cacheKeyString);
101 for ($i = 1; $i <= ceil($total / self
::BATCHLIMIT
); $i++
) {
102 $task = new CRM_Queue_Task(
103 array('CRM_Contact_Page_DedupeMerge', 'callBatchMerge'),
104 array($rgid, $gid, $mode, self
::BATCHLIMIT
, $isSelected),
105 "Processed " . $i * self
::BATCHLIMIT
. " pair of duplicates out of " . $total
108 // Add the Task to the Queue
109 $queue->createItem($task);
113 $urlQry['context'] = "conflicts";
114 $runner = new CRM_Queue_Runner(array(
115 'title' => ts('Merging Duplicates..'),
117 'errorMode' => CRM_Queue_Runner
::ERROR_ABORT
,
118 'onEndUrl' => CRM_Utils_System
::url('civicrm/contact/dedupefind', $urlQry, TRUE, NULL, FALSE),
125 * Carry out batch merges.
127 * @param \CRM_Queue_TaskContext $ctx
130 * @param string $mode
131 * 'safe' mode or 'force' mode.
132 * @param int $batchLimit
133 * @param int $isSelected
137 public static function callBatchMerge(CRM_Queue_TaskContext
$ctx, $rgid, $gid, $mode = 'safe', $batchLimit, $isSelected) {
138 CRM_Dedupe_Merger
::batchMerge($rgid, $gid, $mode, $batchLimit, $isSelected);
139 return CRM_Queue_Task
::TASK_SUCCESS
;