3 +--------------------------------------------------------------------+
4 | CiviCRM version 4.5 |
5 +--------------------------------------------------------------------+
6 | Copyright CiviCRM LLC (c) 2004-2014 |
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-2014
35 class CRM_Contact_Page_DedupeMerge
extends CRM_Core_Page
{
40 * Browse all rule groups
46 $runner = self
::getRunner();
48 // Run Everything in the Queue via the Web.
49 $runner->runAllViaWeb();
51 CRM_Core_Session
::setStatus(ts('Nothing to merge.'));
58 static function getRunner() {
59 $rgid = CRM_Utils_Request
::retrieve('rgid', 'Positive', $this, FALSE, 0);
60 $gid = CRM_Utils_Request
::retrieve('gid', 'Positive', $this, FALSE, 0);
61 $action = CRM_Utils_Request
::retrieve('action', 'String', CRM_Core_DAO
::$_nullObject);
62 $mode = CRM_Utils_Request
::retrieve('mode', 'String', CRM_Core_DAO
::$_nullObject, FALSE, 'safe');
64 $contactType = CRM_Core_DAO
::getFieldValue('CRM_Dedupe_DAO_RuleGroup', $rgid, 'contact_type');
65 $cacheKeyString = "merge {$contactType}";
66 $cacheKeyString .= $rgid ?
"_{$rgid}" : '_0';
67 $cacheKeyString .= $gid ?
"_{$gid}" : '_0';
69 $urlQry = "reset=1&action=update&rgid={$rgid}";
70 $urlQry = $gid ?
($urlQry . "&gid={$gid}") : $urlQry;
72 if ($mode == 'aggressive' && !CRM_Core_Permission
::check('force merge duplicate contacts')) {
73 CRM_Core_Session
::setStatus(ts('You do not have permission to force merge duplicate contact records'), ts('Permission Denied'), 'error');
74 CRM_Utils_System
::redirect(CRM_Utils_System
::url('civicrm/contact/dedupefind', $urlQry));
77 $queue = CRM_Queue_Service
::singleton()->create(array(
78 'name' => $cacheKeyString,
84 if ($action == CRM_Core_Action
::MAP
) {
85 $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, TRUE, 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 * Collect Mailchimp data into temporary working table.
127 static function callBatchMerge(CRM_Queue_TaskContext
$ctx, $rgid, $gid = NULL, $mode = 'safe', $autoFlip = TRUE, $batchLimit = 1, $isSelected = 2) {
128 $result = CRM_Dedupe_Merger
::batchMerge($rgid, $gid, $mode, $autoFlip, $batchLimit, $isSelected);
130 return CRM_Queue_Task
::TASK_SUCCESS
;