Mercurial > hg > drupalISMI
annotate relation_processor/nodes.inc @ 29:1a1877812757
include normalized attributes in neo4j with prefix "_n_"
| author | casties |
|---|---|
| date | Thu, 10 Dec 2015 12:11:25 -0500 |
| parents | bdf91a4a40ff |
| children |
| rev | line source |
|---|---|
| 0 | 1 <?php |
| 2 | |
| 3 /** | |
| 4 * @file | |
| 5 * On behalf implementation of Feeds mapping API for taxonomy.module. | |
| 6 */ | |
| 7 | |
| 8 /** | |
| 9 * Search by term name. | |
| 10 */ | |
| 11 define('FEEDS_ENTITY_SEARCH_TERM_NAME', 0); | |
| 12 | |
| 13 /** | |
| 14 * Search by term id. | |
| 15 */ | |
| 16 define('FEEDS_ENTITY_SEARCH_TERM_ID', 1); | |
| 17 | |
| 18 /** | |
| 19 * Search by GUID. | |
| 20 */ | |
| 21 define('FEEDS_ENTITY_SEARCH_TERM_GUID', 2); | |
| 22 | |
| 23 | |
| 24 /** | |
| 25 * Search by CITEKEY. | |
| 26 */ | |
| 27 define('FEEDS_ENTITY_SEARCH_TERM_CITEKEY', 3); | |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
28 dpm("RELATION_include"); |
| 0 | 29 /** |
| 30 * Implements hook_feeds_parser_sources_alter(). | |
| 31 */ | |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
32 function relation_feeds_parser_sources_alter(&$sources, $content_type) { |
| 0 | 33 |
| 34 if (!empty($content_type)) { | |
| 35 $sources['sources'] = array( | |
| 36 'name' => t('Feed node: Entity'), | |
| 37 'description' => t('Entites from feed node.'), | |
| 38 'callback' => 'entites_feeds_get_source', | |
| 39 ); | |
| 40 } | |
| 41 } | |
| 42 | |
| 43 | |
| 44 /** | |
| 45 * Callback, returns taxonomy from feed node. | |
| 46 */ | |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
47 function relation_feeds_get_source(FeedsSource $source, FeedsParserResult $result, $key) { |
| 0 | 48 /*if ($node = node_load($source->feed_nid)) { |
| 49 $terms = taxonomy_feeds_node_get_terms($node); | |
| 50 $vocabularies = taxonomy_vocabulary_load_multiple(array(), array('machine_name' => str_replace('parent:taxonomy:', '', $key))); | |
| 51 $vocabulary = array_shift($vocabularies); | |
| 52 $result = array(); | |
| 53 foreach ($terms as $tid => $term) { | |
| 54 if ($term->vid == $vocabulary->vid) { | |
| 55 $result[] = new FeedsTermElement($term); | |
| 56 } | |
| 57 }*/ | |
| 58 | |
| 59 return $result; | |
| 60 //} | |
| 61 } | |
| 62 | |
| 63 /** | |
| 64 * Implements hook_feeds_processor_targets_alter(). | |
| 65 */ | |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
66 function relation_feeds_processor_targets_alter(&$targets, $entity_type, $bundle_name) { |
| 0 | 67 /*foreach (field_info_instances($entity_type, $bundle_name) as $name => $instance) { |
| 68 $info = field_info_field($name); | |
| 69 if ($info['type'] == 'taxonomy_term_reference') { | |
| 70 $targets[$name] = array( | |
| 71 'name' => check_plain($instance['label']), | |
| 72 'callback' => 'taxonomy_feeds_set_target', | |
| 73 'description' => t('The @label field of the entity.', array('@label' => $instance['label'])), | |
| 74 'summary_callback' => 'taxonomy_feeds_summary_callback', | |
| 75 'form_callback' => 'taxonomy_feeds_form_callback', | |
| 76 ); | |
| 77 } | |
| 78 }*/ | |
| 79 | |
| 80 | |
| 81 if ($entity_type == "relation"){ | |
| 82 | |
| 83 $targets["source_id"]= array( | |
| 84 'name' => 'Source Field', | |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
85 'callback' => 'relation_feeds_set_target', |
| 0 | 86 'description' => t('The guid of the entity.'), |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
87 'summary_callback' => 'relation_feeds_summary_callback', |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
88 'form_callback' => 'relation_feeds_form_callback', |
| 0 | 89 ); |
| 90 | |
| 91 $targets["target_id"]= array( | |
| 92 'name' => 'Target Field', | |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
93 'callback' => 'relation_feeds_set_target', |
| 0 | 94 'description' => t('The guid of the entity.'), |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
95 'summary_callback' => 'relation_feeds_summary_callback', |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
96 'form_callback' => 'relation_feeds_form_callback', |
| 0 | 97 ); |
| 98 | |
| 99 $targets["relation_name"]= array( | |
| 100 'name' => 'Relation Type', | |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
101 'callback' => 'relation_feeds_set_relation_type', |
| 0 | 102 |
| 103 ); | |
| 104 | |
| 105 } | |
| 106 | |
| 107 } | |
| 108 | |
| 109 | |
| 110 | |
| 111 /*callback for relation_types | |
| 112 * | |
| 113 * | |
| 114 */ | |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
115 function relation_feeds_set_relation_type($source, $entity, $target, $terms, $mapping = array()) { |
| 20 | 116 |
| 0 | 117 if (empty($terms)) { |
| 118 return; | |
| 119 } | |
| 120 | |
| 20 | 121 // assume array has only one term |
| 0 | 122 if (is_array($terms)) { |
| 20 | 123 $terms = $terms[0]; |
| 0 | 124 } |
| 125 | |
| 126 | |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
127 |
| 0 | 128 $types=relation_get_types(array($terms)); |
| 129 | |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
130 |
| 0 | 131 if(sizeof($types)==0){ //typ gibt es nicht dann erzeuge mit defualt werten #TODO konfigurierbar? |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
132 |
| 0 | 133 $info = array(); |
| 134 $info['relation_type']=$terms; | |
| 135 $info['directional']=TRUE; | |
| 136 $info['source_bundles'][]="node:*"; | |
| 137 $info['target_bundles'][]="node:*"; | |
| 138 $info['reverse_label']="invOf_" . $terms; | |
| 139 $rel_type = relation_type_create($info); | |
| 140 relation_type_save($rel_type); | |
| 141 } | |
| 142 | |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
143 |
| 0 | 144 $entity->relation_type=$terms; |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
145 |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
146 if ( _relation_feeds_checkRelationComplete($entity)){ |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
147 |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
148 $entity->is_new=FALSE; |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
149 } |
| 0 | 150 relation_update($entity); |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
151 |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
152 } |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
153 |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
154 |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
155 function _relation_feeds_checkRelationComplete($relation){ |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
156 //einer der Endpunkte existiert nicht |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
157 |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
158 if (count($relation->endpoints['und'][0]) == 0) |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
159 return false; |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
160 if (!isset($relation->endpoints['und'][1])) |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
161 return false; |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
162 if (count($relation->endpoints['und'][1]) == 0) |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
163 return false; |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
164 |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
165 if ($relation->relation_type == "generic") |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
166 return false; |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
167 return true; |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
168 |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
169 } |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
170 |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
171 function _relation_feeds_checkEndpointsComplete($relation){ |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
172 //einer der Endpunkte existiert nicht |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
173 |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
174 |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
175 if (count($relation->endpoints['und'][0]) == 0) |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
176 return false; |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
177 if (!isset($relation->endpoints['und'][1])) |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
178 return false; |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
179 if (count($relation->endpoints['und'][1]) == 0) |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
180 return false; |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
181 |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
182 return true; |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
183 |
| 0 | 184 } |
| 185 | |
| 186 /** | |
| 187 * Callback for mapping. Here is where the actual mapping happens. | |
| 188 * | |
| 189 * @todo Do not create new terms for non-autotag fields. | |
| 190 */ | |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
191 function relation_feeds_set_target($source, $entity, $target, $terms, $mapping = array()) { |
| 0 | 192 |
| 193 // Allow mapping the string '0' to a term name. | |
| 194 if (empty($terms) && $terms != 0) { | |
| 195 return; | |
| 196 } | |
| 197 | |
| 198 // Handle non-multiple values. | |
| 199 if (!is_array($terms)) { | |
| 200 $terms = array($terms); | |
| 201 } | |
| 202 | |
| 203 // Add in default values. | |
| 204 $mapping += array( | |
| 205 'term_search' => FEEDS_ENTITY_SEARCH_TERM_NAME, | |
| 206 'autocreate' => FALSE, | |
| 207 ); | |
| 208 | |
| 209 | |
| 210 $cache = &drupal_static(__FUNCTION__); | |
| 211 | |
| 212 | |
| 213 //$query = new EntityFieldQuery(); | |
| 214 //$query->entityCondition('entity_type', 'node') | |
| 215 // ->range(0, 1); | |
| 216 | |
| 217 | |
| 218 | |
| 219 | |
| 220 | |
| 221 | |
| 222 // Iterate over all values. | |
| 223 | |
| 224 | |
| 225 #$mapping['term_search']=FEEDS_ENTITY_SEARCH_TERM_GUID; | |
| 226 foreach ($terms as $term) { | |
| 227 //dpm($term); | |
| 228 | |
| 229 | |
| 230 $tid = FALSE; | |
| 231 | |
| 232 switch ($mapping['term_search']){ | |
| 233 // Lookup by name. | |
| 234 case FEEDS_ENTITY_SEARCH_TERM_NAME: | |
| 235 $name_query = clone $query; | |
| 236 if ($tids = $name_query->propertyCondition('name', $term)->execute()) { | |
| 237 $tid = key($tids['taxonomy_term']); | |
| 238 } | |
| 239 | |
| 240 // Lookup by tid. | |
| 241 case FEEDS_ENTITY_SEARCH_TERM_ID: | |
| 242 if (is_numeric($term)) { | |
| 243 $tid = $term; | |
| 244 } | |
| 245 break; | |
| 246 | |
| 247 // Lookup by GUID. | |
| 248 case FEEDS_ENTITY_SEARCH_TERM_GUID: | |
| 249 | |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
250 |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
251 $tid = relation_feeds_entity_lookup_entity_by_guid($term); |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
252 |
| 0 | 253 break; |
| 254 | |
| 255 case FEEDS_ENTITY_SEARCH_TERM_CITEKEY: | |
| 256 $tid = _searchEntityByBiblioValue("biblio","citekey",$term); | |
| 257 } | |
| 258 } | |
| 259 | |
| 260 | |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
261 |
| 0 | 262 $eps = $entity->endpoints[LANGUAGE_NONE]; |
| 263 if (!isset($entity->endpoints[LANGUAGE_NONE])){ // noch nicht existent | |
| 264 $entity->endpoints[LANGUAGE_NONE][]=array(); | |
| 265 } else if (sizeof($entity->endpoints[LANGUAGE_NONE])<1) { // nicht mindestens ein eintrag | |
| 266 $entity->endpoints[LANGUAGE_NONE][]=array(); | |
| 267 } | |
| 268 | |
| 269 switch ($target){ | |
| 270 case "source_id": | |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
271 |
| 0 | 272 // source is immer der erste eintrag |
| 273 $entity->endpoints[LANGUAGE_NONE][0]=array('entity_type' => 'node', 'entity_id' => $tid); | |
| 274 break; | |
| 275 | |
| 276 case "target_id": | |
| 277 //target können mehrere existieren, hinten anfügen. | |
| 278 $entity->endpoints[LANGUAGE_NONE][]=array('entity_type' => 'node', 'entity_id' => $tid); | |
| 279 } | |
| 280 | |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
281 |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
282 |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
283 if ( _relation_feeds_checkRelationComplete($entity)){ |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
284 |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
285 $entity->is_new=FALSE; |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
286 relation_update($entity); |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
287 } |
| 0 | 288 |
| 289 | |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
290 if ( _relation_feeds_checkEndpointsComplete($entity)){ |
| 0 | 291 |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
292 relation_update($entity); |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
293 } |
| 0 | 294 |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
295 # if ($target=="source_id"){ |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
296 # relation_update($entity); |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
297 # } |
| 0 | 298 |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
299 #if (sizeof($entity->endpoints[LANGUAGE_NONE])>1){ // WENN ZWEI ENDPUNKTE VORHANDEN DANN abspeichern |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
300 |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
301 //$entity->is_new=FALSE; |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
302 |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
303 #} |
| 0 | 304 // } |
| 305 } | |
| 306 | |
| 307 /** | |
| 308 * Finds all terms associated with the given node, within one vocabulary. | |
| 309 */ | |
| 310 | |
| 311 /* | |
| 312 function taxonomy_feeds_node_get_terms($node, $key = 'tid') { | |
| 313 $terms = &drupal_static(__FUNCTION__); | |
| 314 | |
| 315 if (!isset($terms[$node->nid][$key])) { | |
| 316 // Get tids from all taxonomy_term_reference fields. | |
| 317 $tids = array(); | |
| 318 $fields = field_info_fields(); | |
| 319 foreach ($fields as $field_name => $field) { | |
| 320 if ($field['type'] == 'taxonomy_term_reference' && field_info_instance('node', $field_name, $node->type)) { | |
| 321 if (($items = field_get_items('node', $node, $field_name)) && is_array($items)) { | |
| 322 $tids = array_merge($tids, array_map('_taxonomy_feeds_extract_tid', $items)); | |
| 323 } | |
| 324 } | |
| 325 } | |
| 326 | |
| 327 // Load terms and cache them in static var. | |
| 328 $curr_terms = taxonomy_term_load_multiple($tids); | |
| 329 $terms[$node->nid][$key] = array(); | |
| 330 foreach ($curr_terms as $term) { | |
| 331 $terms[$node->nid][$key][$term->$key] = $term; | |
| 332 } | |
| 333 } | |
| 334 return $terms[$node->nid][$key]; | |
| 335 } | |
| 336 | |
| 337 */ | |
| 338 | |
| 339 /** | |
| 340 * Extracts tid from array item returned by field_get_items(). | |
| 341 * | |
| 342 * @param array $item | |
| 343 * Tid information in the form of a single element array | |
| 344 * (key == 'tid', value == tid we're looking for) | |
| 345 * | |
| 346 * @return int | |
| 347 * Term id extracted from $item. | |
| 348 * | |
| 349 * @see taxonomy_feeds_node_get_terms() | |
| 350 * @see field_get_items() | |
| 351 */ | |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
352 function _relation_feeds_extract_tid($item) { |
| 0 | 353 return $item['tid']; |
| 354 } | |
| 355 | |
| 356 /** | |
| 357 * Looks up a term by GUID, assumes SQL storage backend. | |
| 358 * | |
| 359 * @param string $guid | |
| 360 * The Feeds GUID to compare against. | |
| 361 * | |
| 362 * @return int|FALSE | |
| 363 * The term id, or FALSE if one was not found. | |
| 364 */ | |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
365 function relation_feeds_entity_lookup_entity_by_guid($guid) { |
| 0 | 366 |
| 367 | |
| 368 $res = db_select('feeds_item') | |
| 369 ->fields('feeds_item', array('entity_id')) | |
| 370 //->condition('feed_nid', $source->feed_nid) | |
| 371 //->condition('entity_type', $this->entityType()) | |
| 372 //->condition('id', $source->id); | |
| 373 ->condition('guid', $guid) | |
| 374 ->execute() | |
| 375 ->fetchField(); | |
| 376 | |
| 377 | |
| 378 return $res; | |
| 379 /* return db_select('feeds_item') | |
| 380 ->fields('feeds_item', array('entity_id')) | |
| 381 ->condition('entity_type', 'taxonomy_term') | |
| 382 ->condition('guid', $guid) | |
| 383 ->execute() | |
| 384 ->fetchField();*/ | |
| 385 } | |
| 386 | |
| 387 /** | |
| 388 * Mapping configuration summary for taxonomy.module. | |
| 389 * | |
| 390 * @param array $mapping | |
| 391 * Associative array of the mapping settings. | |
| 392 * @param array $target | |
| 393 * Array of target settings, as defined by the processor or | |
| 394 * hook_feeds_processor_targets_alter(). | |
| 395 * @param array $form | |
| 396 * The whole mapping form. | |
| 397 * @param array $form_state | |
| 398 * The form state of the mapping form. | |
| 399 * | |
| 400 * @return string | |
| 401 * Returns, as a string that may contain HTML, the summary to display while | |
| 402 * the full form isn't visible. | |
| 403 * If the return value is empty, no summary and no option to view the form | |
| 404 * will be displayed. | |
| 405 */ | |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
406 function relation_feeds_summary_callback($mapping, $target, $form, $form_state) { |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
407 $options = _relation_feeds_form_callback_options(); |
| 0 | 408 if (empty($mapping['term_search'])) { |
| 409 return t('Search Entity terms by: <strong>@search</strong>', array('@search' => $options[FEEDS_ENTITY_SEARCH_TERM_NAME])); | |
| 410 } | |
| 411 return t('Search Entity terms by: <strong>@search</strong>', array('@search' => $options[$mapping['term_search']])); | |
| 412 } | |
| 413 | |
| 414 /** | |
| 415 * Settings form callback. | |
| 416 * | |
| 417 * @return array | |
| 418 * The per mapping configuration form. Once the form is saved, $mapping will | |
| 419 * be populated with the form values. | |
| 420 */ | |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
421 function relation_feeds_form_callback($mapping, $target, $form, $form_state) { |
| 0 | 422 return array( |
| 423 'term_search' => array( | |
| 424 '#type' => 'select', | |
| 425 '#title' => t('Search Entity by'), | |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
426 '#options' => _relation_feeds_form_callback_options(), |
| 0 | 427 '#default_value' => !empty($mapping['term_search']) ? $mapping['term_search'] : FEEDS_ENTITY_SEARCH_TERM_NAME, |
| 428 ), | |
| 429 ); | |
| 430 } | |
| 431 | |
| 432 /** | |
| 433 * Returns the list of available term search methods. | |
| 434 * | |
| 435 * @return array | |
| 436 * An array of taxonomy search option titles. | |
| 437 */ | |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
438 function _relation_feeds_form_callback_options() { |
| 0 | 439 return array( |
| 440 FEEDS_ENTITY_SEARCH_TERM_NAME => 'Entity name', | |
| 441 FEEDS_ENTITY_SEARCH_TERM_ID => 'Entity ID', | |
| 442 FEEDS_ENTITY_SEARCH_TERM_GUID => 'GUID', | |
| 443 FEEDS_ENTITY_SEARCH_TERM_CITEKEY => 'CITEKEY' | |
| 444 ); | |
| 445 } | |
| 446 | |
| 447 | |
| 448 | |
| 449 /* sucht nach entity vom typ mit Wert von Feld (fieldname) = term */ | |
| 450 function _searchEntityByBiblioValue($bundle,$fieldName,$term){ | |
| 451 | |
| 452 $fc = module_load_include('inc', 'biblio', 'includes/biblio.pages'); | |
| 453 if ($fc==FALSE){ | |
| 454 dpm("FEHLER: cann't find biblio module!"); | |
| 455 return; | |
| 456 } | |
| 457 $arglist = array ( | |
| 458 "f" => array( $fieldName => $term) | |
| 459 ); | |
| 460 $res = biblio_build_query($arglist); | |
| 461 $nid = $res[0][0]; | |
| 462 | |
| 463 | |
| 464 return $nid; | |
| 465 } | |
| 466 | |
| 467 function _searchEntityByFieldValue($bundle,$fieldName,$term){ | |
| 468 | |
| 469 $query = new EntityFieldQuery(); | |
| 470 $query->entityCondition('entity_type', 'node') | |
| 471 ->entityCondition('bundle', $bundle) | |
| 472 ->fieldCondition($fieldName, 'value',$term, '='); | |
| 473 | |
| 474 $result = $query->execute(); | |
| 475 if (isset($result['node'])) { | |
| 476 $news_items_nids = array_keys($result['node']); | |
| 477 $news_items = entity_load('node', $news_items_nids); | |
| 478 return $news_items[0]; | |
| 479 } | |
| 480 } |