function sf_prematch_export in Salesforce Suite 6.2

Same name and namespace in other branches

1. 7 sf_prematch/sf_prematch.main.inc \sf_prematch_export()
2. 7.2 sf_prematch/sf_prematch.main.inc \sf_prematch_export()

Use prematch rule to find a salesforce object to match the node.

Parameters

string $object_type:

stdObject $drupal_object:

array $map:

array $match_by:

Return value

string sfid

1 call to sf_prematch_export()

sf_prematch_sf_find_match in sf_prematch/sf_prematch.module

Implement hook_sf_find_match

File

sf_prematch/sf_prematch.main.inc, line 18

Import/Export functions for sf_prematch module.

Code

function sf_prematch_export($object_type, $drupal_object, $map, $match_by) {
  if (empty($drupal_object) || empty($map->drupal) || empty($match_by)) {
    return;
  }

  // Get information to allow using handlers to get values of Drupal fields.
  $drupal_object_info = salesforce_api_fieldmap_objects_load('drupal', $map->drupal);
  $drupal_fields_info = $drupal_object_info['fields'];
  $sf_object_info = salesforce_api_fieldmap_objects_load('salesforce', $map->salesforce);
  $values = array();
  $safe_fields = array();
  foreach ($map->fields as $key => $value) {
    if (is_array($value)) {
      continue;
    }
    $safe_fields[$key] = $value;
  }
  $map->fields = $safe_fields + array(
    'Id' => '',
  );
  $drupal_to_salesforce_fieldmap = array_flip($map->fields);

  // Create $values array allowing easy mapping from match_by fields to query fields and values.
  // Also build out SOQL select clause to include all match by sf fields.
  foreach ($match_by as $match_by_field => $drupal_field_name) {
    if ($match_by_field == 'fieldmap' || $match_by_field == 'rule' || !$drupal_to_salesforce_fieldmap[$drupal_field_name]) {
      continue;
    }

    // If a handler is specified for retrieving a value for the source field...
    $drupal_value = NULL;
    if (isset($drupal_fields_info[$drupal_field_name]['export'])) {
      $drupal_field_definition = $drupal_fields_info[$drupal_field_name];
      $sf_field_definition = $sf_object_info['fields'][$drupal_to_salesforce_fieldmap[$drupal_field_name]];

      // Get the value for the field from the handler function.
      $function = $drupal_fields_info[$drupal_field_name]['export'];
      $drupal_value = $function($drupal_object, $drupal_field_name, $drupal_field_definition, $sf_field_definition);
    }
    elseif (isset($drupal_object->{$drupal_field_name})) {
      $drupal_value = $drupal_object->{$drupal_field_name};
    }
    if (!empty($drupal_value)) {
      $values[$match_by_field]['drupal_value'] = $drupal_value;
      $values[$match_by_field]['salesforce_field_name'] = $drupal_to_salesforce_fieldmap[$drupal_field_name];
      $values[$match_by_field]['salesforce_type'] = $sf_field_definition['salesforce']['type'];
    }
  }

  // If no values were found for the fields found, then we have nothing to match on
  if (empty($values)) {
    return;
  }
  foreach ($values as $key => $value) {
    switch ($value['salesforce_type']) {
      case 'boolean':
      case 'time':
      case 'date':
      case 'datetime':
      case 'percent':
      case 'currency':
      case 'int':
      case 'double':

        // no quotes around SOQL field expressions for dates and numbers
        break;
      default:

        // single quotes around SOQL field expressions for all others
        $values[$key]['drupal_value'] = "'" . $values[$key]['drupal_value'] . "'";
        break;
    }
  }

  // Use match by rule to build out where clause.
  $where_clause = '';
  switch ($match_by['rule']) {
    case SF_PREMATCH_PRIMARY_SECONDARY_AND_TERTIARY:
      $where_clause .= $values['tertiary_field']['salesforce_field_name'] . " = " . $values['tertiary_field']['drupal_value'] . " AND ";

    // no break;
    case SF_PREMATCH_PRIMARY_AND_SECONDARY:
      $where_clause .= $values['secondary_field']['salesforce_field_name'] . " = " . $values['secondary_field']['drupal_value'] . " AND ";

    // no break;
    case SF_PREMATCH_PRIMARY:
      $where_clause .= $values['primary_field']['salesforce_field_name'] . " = " . $values['primary_field']['drupal_value'];
      break;
    default:

      // no prematch is set
      return;
  }
  $query = 'SELECT Id FROM ' . $map->salesforce . ' WHERE ' . $where_clause . ' ORDER BY CreatedDate ASC';

  // Run the SOQL query against the Salesforce API
  if ($sf = salesforce_api_connect()) {
    try {
      $result = $sf->client
        ->query($query);
    } catch (Exception $e) {
      salesforce_api_log(SALESFORCE_LOG_SOME, 'Exception in sf_prematch stage: ' . $e
        ->getMessage(), array(), WATCHDOG_ALERT);
      return;
    }
    switch ($result->size) {
      case 0:
        return;
      case 1:
      default:
        return $result->records[0]->Id;
        break;
    }
  }
}