<?php

/**
 * TODO: How to handle NULL values/records?
 * Class CRM_Dedupe_BAO_QueryBuilder_IndividualSupervised
 */
class CRM_Dedupe_BAO_QueryBuilder_IndividualSupervised extends CRM_Dedupe_BAO_QueryBuilder {

  /**
   * Record - what do I do.
   *
   * @param object $rg
   *
   * @return array
   */
  public static function record($rg) {

    $civicrm_contact = CRM_Utils_Array::value('civicrm_contact', $rg->params, array());
    $civicrm_email = CRM_Utils_Array::value('civicrm_email', $rg->params, array());

    $params = array(
      1 => array(
        CRM_Utils_Array::value('first_name', $civicrm_contact, ''),
        'String',
      ),
      2 => array(
        CRM_Utils_Array::value('last_name', $civicrm_contact, ''),
        'String',
      ),
      3 => array(
        CRM_Utils_Array::value('email', $civicrm_email, ''),
        'String',
      ),
    );

    return array(
      "civicrm_contact.{$rg->name}.{$rg->threshold}" => CRM_Core_DAO::composeQuery("
                SELECT contact.id as id1, {$rg->threshold} as weight
                FROM civicrm_contact as contact
                  JOIN civicrm_email as email ON email.contact_id=contact.id
                WHERE contact_type = 'Individual'
                  AND first_name = %1
                  AND last_name = %2
                  AND email = %3", $params, TRUE),
    );
  }

  /**
   * Internal - what do I do.
   *
   * @param object $rg
   *
   * @return array
   */
  public static function internal($rg) {
    $query = "
            SELECT contact1.id as id1, contact2.id as id2, {$rg->threshold} as weight
            FROM civicrm_contact as contact1
              JOIN civicrm_email as email1 ON email1.contact_id=contact1.id
              JOIN civicrm_contact as contact2 ON
                contact1.first_name = contact2.first_name AND
                contact1.last_name = contact2.last_name
              JOIN civicrm_email as email2 ON
                email2.contact_id=contact2.id AND
                email1.email=email2.email
            WHERE contact1.contact_type = 'Individual'
              AND " . self::internalFilters($rg);
    return array(
      "civicrm_contact.{$rg->name}.{$rg->threshold}" => $query,
    );
  }

}