3 +--------------------------------------------------------------------+
4 | CiviCRM version 4.7 |
5 +--------------------------------------------------------------------+
6 | Copyright CiviCRM LLC (c) 2004-2017 |
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-2017
33 class CRM_Contact_Page_DedupeFind
extends CRM_Core_Page_Basic
{
34 protected $_cid = NULL;
36 protected $_mainContacts;
46 public function getBAOName() {
47 return 'CRM_Dedupe_BAO_RuleGroup';
53 public function &links() {
57 * Browse all rule groups.
59 public function run() {
60 $gid = CRM_Utils_Request
::retrieve('gid', 'Positive', $this, FALSE, 0);
61 $action = CRM_Utils_Request
::retrieve('action', 'String', $this, FALSE, 0);
62 $context = CRM_Utils_Request
::retrieve('context', 'String', $this);
63 $limit = CRM_Utils_Request
::retrieve('limit', 'Integer', $this);
64 $rgid = CRM_Utils_Request
::retrieve('rgid', 'Positive');
71 $this->assign('urlQuery', implode('&', $urlQry));
73 $session = CRM_Core_Session
::singleton();
74 $contactIds = $session->get('selectedSearchContactIds');
75 if ($context == 'search' ||
!empty($contactIds)) {
77 $this->assign('backURL', $session->readUserContext());
80 if ($action & CRM_Core_Action
::RENEW
) {
84 CRM_Core_BAO_PrevNextCache
::deleteItem(NULL, CRM_Dedupe_Merger
::getMergeCacheKeyString($rgid, $gid));
86 $urlQry['action'] = 'update';
87 CRM_Utils_System
::redirect(CRM_Utils_System
::url('civicrm/contact/dedupefind', $urlQry));
89 elseif ($action & CRM_Core_Action
::MAP
) {
90 // do a batch merge if requested
91 $result = CRM_Dedupe_Merger
::batchMerge($rgid, $gid, 'safe', TRUE, 75);
93 $skippedCount = CRM_Utils_Request
::retrieve('skipped', 'Positive', $this, FALSE, 0);
94 $skippedCount = $skippedCount +
count($result['skipped']);
95 $mergedCount = CRM_Utils_Request
::retrieve('merged', 'Positive', $this, FALSE, 0);
96 $mergedCount = $mergedCount +
count($result['merged']);
98 if (empty($result['merged']) && empty($result['skipped'])) {
100 if ($mergedCount >= 1) {
101 $message = ts("%1 pairs of duplicates were merged", array(1 => $mergedCount));
103 if ($skippedCount >= 1) {
104 $message = $message ?
"{$message} and " : '';
105 $message .= ts("%1 pairs of duplicates were skipped due to conflict",
106 array(1 => $skippedCount)
109 $message .= ts(" during the batch merge process with safe mode.");
110 CRM_Core_Session
::setStatus($message, ts('Merge Complete'), 'success');
111 $urlQry['action'] = 'update';
112 CRM_Utils_System
::redirect(CRM_Utils_System
::url('civicrm/contact/dedupefind', $urlQry));
115 $urlQry['action'] = 'map';
116 $urlQry['skipped'] =$skippedCount;
117 $urlQry['merged'] = $mergedCount;
118 CRM_Utils_System
::jsRedirect(
119 CRM_Utils_System
::url('civicrm/contact/dedupefind', $urlQry),
120 ts('Batch Merge Task in progress'),
121 ts('The batch merge task is still in progress. This page will be refreshed automatically.')
126 if ($action & CRM_Core_Action
::UPDATE ||
127 $action & CRM_Core_Action
::BROWSE
129 $cid = CRM_Utils_Request
::retrieve('cid', 'Positive', $this, FALSE, 0);
130 $this->action
= CRM_Core_Action
::UPDATE
;
132 $urlQry['snippet'] = 4;
133 if ($context == 'conflicts') {
134 $urlQry['selected'] = 1;
137 $this->assign('sourceUrl', CRM_Utils_System
::url('civicrm/ajax/dedupefind', $urlQry, FALSE, NULL, FALSE));
139 //reload from cache table
140 $cacheKeyString = CRM_Dedupe_Merger
::getMergeCacheKeyString($rgid, $gid);
142 $stats = CRM_Dedupe_Merger
::getMergeStatsMsg($cacheKeyString);
144 CRM_Core_Session
::setStatus($stats);
145 // reset so we not displaying same message again
146 CRM_Dedupe_Merger
::resetMergeStats($cacheKeyString);
148 $join = CRM_Dedupe_Merger
::getJoinOnDedupeTable();
149 $where = "de.id IS NULL";
150 if ($context == 'conflicts') {
151 $where .= " AND pn.is_selected = 1";
153 $this->_mainContacts
= CRM_Core_BAO_PrevNextCache
::retrieve($cacheKeyString, $join, $where);
154 if (empty($this->_mainContacts
)) {
155 if ($context == 'conflicts') {
156 // if the current screen was intended to list only selected contacts, move back to full dupe list
157 $urlQry['action'] = 'update';
158 unset($urlQry['snippet']);
159 CRM_Utils_System
::redirect(CRM_Utils_System
::url(CRM_Utils_System
::currentPath(), $urlQry));
162 $foundDupes = $this->get("dedupe_dupes_$gid");
164 $foundDupes = CRM_Dedupe_Finder
::dupesInGroup($rgid, $gid, $limit);
166 $this->set("dedupe_dupes_$gid", $foundDupes);
168 elseif (!empty($contactIds)) {
169 $foundDupes = $this->get("search_dedupe_dupes_$gid");
171 $foundDupes = CRM_Dedupe_Finder
::dupes($rgid, $contactIds);
173 $this->set("search_dedupe_dupes_$gid", $foundDupes);
176 $foundDupes = $this->get('dedupe_dupes');
178 $foundDupes = CRM_Dedupe_Finder
::dupes($rgid, array(), TRUE, $limit);
180 $this->set('dedupe_dupes', $foundDupes);
183 $ruleGroup = new CRM_Dedupe_BAO_RuleGroup();
184 $ruleGroup->id
= $rgid;
185 $ruleGroup->find(TRUE);
187 $session = CRM_Core_Session
::singleton();
188 $session->setStatus(ts('No possible duplicates were found using %1 rule.', array(1 => $ruleGroup->name
)), ts('None Found'), 'info');
189 $url = CRM_Utils_System
::url('civicrm/contact/deduperules', 'reset=1');
190 if ($context == 'search') {
191 $url = $session->readUserContext();
193 CRM_Utils_System
::redirect($url);
196 $mainContacts = CRM_Dedupe_Finder
::parseAndStoreDupePairs($foundDupes, $cacheKeyString);
204 $this->_rgid
= $rgid;
205 $this->_mainContacts
= $mainContacts;
207 $session = CRM_Core_Session
::singleton();
208 $urlQry['action'] = 'update';
210 $urlQry['cid'] = $this->_cid
;
211 $session->pushUserContext(CRM_Utils_System
::url('civicrm/contact/deduperules',
216 $session->pushUserContext(CRM_Utils_System
::url('civicrm/contact/dedupefind',
229 $this->_rgid
= $rgid;
232 $this->assign('action', $this->action
);
236 $this->action
= CRM_Core_Action
::UPDATE
;
237 $this->edit($this->action
);
238 $this->assign('action', $this->action
);
240 $this->assign('context', $context);
243 return parent
::run();
247 * Browse all rule groups.
249 public function browse() {
250 $this->assign('main_contacts', $this->_mainContacts
);
253 $this->assign('cid', $this->_cid
);
255 if (isset($this->_gid
) ||
$this->_gid
) {
256 $this->assign('gid', $this->_gid
);
258 $this->assign('rgid', $this->_rgid
);
262 * Get name of edit form.
265 * classname of edit form
267 public function editForm() {
268 return 'CRM_Contact_Form_DedupeFind';
272 * Get edit form name.
277 public function editName() {
289 public function userContext($mode = NULL) {
290 return 'civicrm/contact/dedupefind';