CRM/Dedupe/BAO/QueryBuilder/IndividualSupervised.php

   1 <?php
   2
   3 // TODO: How to handle NULL values/records?
   4 /**
   5  * Class CRM_Dedupe_BAO_QueryBuilder_IndividualSupervised
   6  */
   7 class CRM_Dedupe_BAO_QueryBuilder_IndividualSupervised extends CRM_Dedupe_BAO_QueryBuilder {
   8
   9   static function record($rg) {
  10
  11     $civicrm_contact = CRM_Utils_Array::value('civicrm_contact', $rg->params, array());
  12     $civicrm_email = CRM_Utils_Array::value('civicrm_email', $rg->params, array());
  13
  14     $params = array(
  15       1 => array(CRM_Utils_Array::value('first_name', $civicrm_contact, ''), 'String'),
  16       2 => array(CRM_Utils_Array::value('last_name', $civicrm_contact, ''), 'String'),
  17       3 => array(CRM_Utils_Array::value('email', $civicrm_email, ''), 'String'),
  18     );
  19
  20     return array(
  21       "civicrm_contact.{$rg->name}.{$rg->threshold}" => CRM_Core_DAO::composeQuery("
  22                 SELECT contact.id as id1, {$rg->threshold} as weight
  23                 FROM civicrm_contact as contact
  24                   JOIN civicrm_email as email ON email.contact_id=contact.id
  25                 WHERE contact_type = 'Individual'
  26                   AND first_name = %1
  27                   AND last_name = %2
  28                   AND email = %3", $params, TRUE),
  29     );
  30   }
  31
  32   static function internal($rg) {
  33     $query = "
  34             SELECT contact1.id as id1, contact2.id as id2, {$rg->threshold} as weight
  35             FROM civicrm_contact as contact1
  36               JOIN civicrm_email as email1 ON email1.contact_id=contact1.id
  37               JOIN civicrm_contact as contact2 ON
  38                 contact1.first_name = contact2.first_name AND
  39                 contact1.last_name = contact2.last_name
  40               JOIN civicrm_email as email2 ON
  41                 email2.contact_id=contact2.id AND
  42                 email1.email=email2.email
  43             WHERE contact1.contact_type = 'Individual'
  44               AND " . self::internalFilters($rg);
  45     return array("civicrm_contact.{$rg->name}.{$rg->threshold}" => $query);
  46   }
  47 };
  48
  49
  50