drupalISMI: relation_processor/nodes.inc comparison

comparison relation_processor/nodes.inc @ 5:1c73c660c2f2

new relation_processor

author	Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
date	Wed, 17 Jun 2015 18:55:14 +0200
parents	124ef8f3b22d
children	bdf91a4a40ff

comparison

equal deleted inserted replaced

-:124ef8f3b22d
+:1c73c660c2f2
 /**
 * Search by CITEKEY.
 */
 define('FEEDS_ENTITY_SEARCH_TERM_CITEKEY', 3);
+dpm("RELATION_include");
 /**
 * Implements hook_feeds_parser_sources_alter().
 */
-function entity_feeds_parser_sources_alter(&$sources, $content_type) {
+function relation_feeds_parser_sources_alter(&$sources, $content_type) {
 if (!empty($content_type)) {
 $sources['sources'] = array(
 'name' => t('Feed node: Entity'),
 'description' => t('Entites  from feed node.'),
 /**
 * Callback, returns taxonomy from feed node.
 */
-function entity_feeds_get_source(FeedsSource $source, FeedsParserResult $result, $key) {
+function relation_feeds_get_source(FeedsSource $source, FeedsParserResult $result, $key) {
 /*if ($node = node_load($source->feed_nid)) {
 $terms = taxonomy_feeds_node_get_terms($node);
 $vocabularies = taxonomy_vocabulary_load_multiple(array(), array('machine_name' => str_replace('parent:taxonomy:', '', $key)));
 $vocabulary = array_shift($vocabularies);
 $result = array();
 }
 /**
 * Implements hook_feeds_processor_targets_alter().
 */
-function entity_feeds_processor_targets_alter(&$targets, $entity_type, $bundle_name) {
+function relation_feeds_processor_targets_alter(&$targets, $entity_type, $bundle_name) {
 /*foreach (field_info_instances($entity_type, $bundle_name) as $name => $instance) {
 $info = field_info_field($name);
 if ($info['type'] == 'taxonomy_term_reference') {
 $targets[$name] = array(
 'name' => check_plain($instance['label']),
 if ($entity_type == "relation"){
 $targets["source_id"]=  array(
 'name' => 'Source Field',
-'callback' => 'entity_feeds_set_target',
+'callback' => 'relation_feeds_set_target',
 'description' => t('The guid of the entity.'),
-'summary_callback' => 'entity_feeds_summary_callback',
+'summary_callback' => 'relation_feeds_summary_callback',
-'form_callback' => 'entity_feeds_form_callback',
+'form_callback' => 'relation_feeds_form_callback',
 );
 $targets["target_id"]=  array(
 'name' => 'Target Field',
-'callback' => 'entity_feeds_set_target',
+'callback' => 'relation_feeds_set_target',
 'description' => t('The guid of the entity.'),
-'summary_callback' => 'entity_feeds_summary_callback',
+'summary_callback' => 'relation_feeds_summary_callback',
-'form_callback' => 'entity_feeds_form_callback',
+'form_callback' => 'relation_feeds_form_callback',
 );
 $targets["relation_name"]=  array(
 'name' => 'Relation Type',
-'callback' => 'entity_feeds_set_relation_type',
+'callback' => 'relation_feeds_set_relation_type',
 );
 }
 /*callback for relation_types
 *
 *
 */
-function entity_feeds_set_relation_type($source, $entity, $target, $terms, $mapping = array()) {
+function relation_feeds_set_relation_type($source, $entity, $target, $terms, $mapping = array()) {
 if (empty($terms)) {
 return;
 }
 // don't Handle non-multiple values.
 if (is_array($terms)) {
 return;
 }
+dpm("CHECK: TYPE");
+dpm($terms);
 $types=relation_get_types(array($terms));
 if(sizeof($types)==0){ //typ gibt es nicht dann erzeuge mit defualt werten #TODO konfigurierbar?
-dpm("CREATE RELATION TYPE:" . $terms);
 $info = array();
 $info['relation_type']=$terms;
 $info['directional']=TRUE;
 $info['source_bundles'][]="node:*";
 $info['target_bundles'][]="node:*";
 $info['reverse_label']="invOf_" . $terms;
 $rel_type = relation_type_create($info);
 relation_type_save($rel_type);
 }
 $entity->relation_type=$terms;
+if ( _relation_feeds_checkRelationComplete($entity)){
+$entity->is_new=FALSE;
+}
 relation_update($entity);
+}
+function _relation_feeds_checkRelationComplete($relation){
+//einer der Endpunkte existiert nicht
+if (count($relation->endpoints['und'][0]) == 0)
+return false;
+if (!isset($relation->endpoints['und'][1]))
+	return false;
+if (count($relation->endpoints['und'][1]) == 0)
+return false;
+if ($relation->relation_type == "generic")
+return false;
+return true;
+}
+function _relation_feeds_checkEndpointsComplete($relation){
+//einer der Endpunkte existiert nicht
+if (count($relation->endpoints['und'][0]) == 0)
+return false;
+if (!isset($relation->endpoints['und'][1]))
+	return false;
+if (count($relation->endpoints['und'][1]) == 0)
+return false;
+return true;
 }
 /**
 * Callback for mapping. Here is where the actual mapping happens.
 *
 * @todo Do not create new terms for non-autotag fields.
 */
-function entity_feeds_set_target($source, $entity, $target, $terms, $mapping = array()) {
+function relation_feeds_set_target($source, $entity, $target, $terms, $mapping = array()) {
 // Allow mapping the string '0' to a term name.
 if (empty($terms) && $terms != 0) {
 return;
 }
 break;
 // Lookup by GUID.
 case FEEDS_ENTITY_SEARCH_TERM_GUID:
-$tid = entity_feeds_entity_lookup_entity_by_guid($term);
+$tid = relation_feeds_entity_lookup_entity_by_guid($term);
 break;
 case FEEDS_ENTITY_SEARCH_TERM_CITEKEY:
 $tid = _searchEntityByBiblioValue("biblio","citekey",$term);
 }
 }
 $eps = $entity->endpoints[LANGUAGE_NONE];
 if (!isset($entity->endpoints[LANGUAGE_NONE])){ // noch nicht existent
 $entity->endpoints[LANGUAGE_NONE][]=array();
 $entity->endpoints[LANGUAGE_NONE][]=array();
 }
 switch ($target){
 case "source_id":
 // source is immer der erste eintrag
 $entity->endpoints[LANGUAGE_NONE][0]=array('entity_type' => 'node', 'entity_id' => $tid);
 break;
 case "target_id":
 //target können mehrere existieren, hinten anfügen.
 $entity->endpoints[LANGUAGE_NONE][]=array('entity_type' => 'node', 'entity_id' => $tid);
 }
-//dpm($entity);
+if ( _relation_feeds_checkRelationComplete($entity)){
-//if ($target=="target_id"){
-relation_update($entity);
+$entity->is_new=FALSE;
+relation_update($entity);
+}
-if  (sizeof($entity->endpoints[LANGUAGE_NONE])>1){ // WENN ZWEI ENDPUNKTE VORHANDEN DANN abspeichern
-$entity->is_new=FALSE;
+if ( _relation_feeds_checkEndpointsComplete($entity)){
-}
+relation_update($entity);
+}
+# if ($target=="source_id"){
+#   relation_update($entity);
+# }
+#if  (sizeof($entity->endpoints[LANGUAGE_NONE])>1){ // WENN ZWEI ENDPUNKTE VORHANDEN DANN abspeichern
+//$entity->is_new=FALSE;
+#}
 // }
 }
 /**
 * Finds all terms associated with the given node, within one vocabulary.
 *   Term id extracted from $item.
 *
 * @see taxonomy_feeds_node_get_terms()
 * @see field_get_items()
 */
-function _entity_feeds_extract_tid($item) {
+function _relation_feeds_extract_tid($item) {
 return $item['tid'];
 }
 /**
 * Looks up a term by GUID, assumes SQL storage backend.
 *   The Feeds GUID to compare against.
 *
 * @return int|FALSE
 *   The term id, or FALSE if one was not found.
 */
-function entity_feeds_entity_lookup_entity_by_guid($guid) {
+function relation_feeds_entity_lookup_entity_by_guid($guid) {
 $res = db_select('feeds_item')
 ->fields('feeds_item', array('entity_id'))
 //->condition('feed_nid', $source->feed_nid)
 *   Returns, as a string that may contain HTML, the summary to display while
 *   the full form isn't visible.
 *   If the return value is empty, no summary and no option to view the form
 *   will be displayed.
 */
-function entity_feeds_summary_callback($mapping, $target, $form, $form_state) {
+function relation_feeds_summary_callback($mapping, $target, $form, $form_state) {
-$options = _entity_feeds_form_callback_options();
+$options = _relation_feeds_form_callback_options();
 if (empty($mapping['term_search'])) {
 return t('Search Entity terms by: <strong>@search</strong>', array('@search' => $options[FEEDS_ENTITY_SEARCH_TERM_NAME]));
 }
 return t('Search Entity terms by: <strong>@search</strong>', array('@search' => $options[$mapping['term_search']]));
 }
 *
 * @return array
 *   The per mapping configuration form. Once the form is saved, $mapping will
 *   be populated with the form values.
 */
-function entity_feeds_form_callback($mapping, $target, $form, $form_state) {
+function relation_feeds_form_callback($mapping, $target, $form, $form_state) {
 return array(
 'term_search' => array(
 '#type' => 'select',
 '#title' => t('Search Entity  by'),
-'#options' => _entity_feeds_form_callback_options(),
+'#options' => _relation_feeds_form_callback_options(),
 '#default_value' => !empty($mapping['term_search']) ? $mapping['term_search'] : FEEDS_ENTITY_SEARCH_TERM_NAME,
 ),
 );
 }
 * Returns the list of available term search methods.
 *
 * @return array
 *   An array of taxonomy search option titles.
 */
-function _entity_feeds_form_callback_options() {
+function _relation_feeds_form_callback_options() {
 return array(
 FEEDS_ENTITY_SEARCH_TERM_NAME => 'Entity name',
 FEEDS_ENTITY_SEARCH_TERM_ID => 'Entity ID',
 FEEDS_ENTITY_SEARCH_TERM_GUID => 'GUID',
 FEEDS_ENTITY_SEARCH_TERM_CITEKEY => 'CITEKEY'

Mercurial > hg > drupalISMI

comparison relation_processor/nodes.inc @ 5:1c73c660c2f2