function sf_prematch_export in Salesforce Suite 7.2
Same name and namespace in other branches
- 6.2 sf_prematch/sf_prematch.main.inc \sf_prematch_export()
- 7 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 - Implements 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($entity_name, $bundle_name, $drupal_object, $map, $match_by) {
if (empty($drupal_object) || empty($map->drupal_entity) || empty($map->drupal_bundle) || 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_entity, $map->drupal_bundle);
$drupal_fields_info = $drupal_object_info['fields'];
$sf_object_info = salesforce_api_fieldmap_objects_load('salesforce', 'salesforce', $map->salesforce);
$values = array();
$select_clause = "SELECT ";
$fields_list = "";
$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') {
continue;
}
$values[$match_by_field] = array();
// If a handler is specified for retrieving a value for the source field...
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};
}
else {
$drupal_value = NULL;
}
$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 there's a salesforce field to match by, include it in the select clause.
if ($values[$match_by_field]['salesforce_field_name'] && !empty($drupal_value)) {
if (!empty($fields_list)) {
$fields_list .= ', ';
}
$fields_list .= $values[$match_by_field]['salesforce_field_name'];
}
}
// If no values were found for the fields found, then we have nothing to match on
if (empty($fields_list)) {
return;
}
$sf_class = $map->salesforce;
$from_where_clause = " FROM {$sf_class} WHERE ";
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.
switch ($match_by['rule']) {
case SF_PREMATCH_PRIMARY_SECONDARY_AND_TERTIARY:
$from_where_clause .= $values['tertiary_field']['salesforce_field_name'] . " = " . $values['tertiary_field']['drupal_value'] . " AND ";
// no break;
case SF_PREMATCH_PRIMARY_AND_SECONDARY:
$from_where_clause .= $values['secondary_field']['salesforce_field_name'] . " = " . $values['secondary_field']['drupal_value'] . " AND ";
// no break;
case SF_PREMATCH_PRIMARY:
$from_where_clause .= $values['primary_field']['salesforce_field_name'] . " = " . $values['primary_field']['drupal_value'];
break;
default:
// no prematch is set
return;
}
// Make sure that Id is in SELECT clause, since that's the data we're returning from the query
if (!preg_match('/\\bId\\b/', $fields_list)) {
$fields_list .= ', Id ';
}
$query = $select_clause . ' ' . $fields_list . $from_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;
}
}
}