Mercurial > hg > drupalISMI
annotate 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 |
| 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()) { |
| 0 | 116 if (empty($terms)) { |
| 117 return; | |
| 118 } | |
| 119 | |
| 120 // don't Handle non-multiple values. | |
| 121 if (is_array($terms)) { | |
| 122 return; | |
| 123 } | |
| 124 | |
| 125 | |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
126 dpm("CHECK: TYPE"); |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
127 dpm($terms); |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
128 |
| 0 | 129 $types=relation_get_types(array($terms)); |
| 130 | |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
131 |
| 0 | 132 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
|
133 |
| 0 | 134 $info = array(); |
| 135 $info['relation_type']=$terms; | |
| 136 $info['directional']=TRUE; | |
| 137 $info['source_bundles'][]="node:*"; | |
| 138 $info['target_bundles'][]="node:*"; | |
| 139 $info['reverse_label']="invOf_" . $terms; | |
| 140 $rel_type = relation_type_create($info); | |
| 141 relation_type_save($rel_type); | |
| 142 } | |
| 143 | |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
144 |
| 0 | 145 $entity->relation_type=$terms; |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
146 |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
147 if ( _relation_feeds_checkRelationComplete($entity)){ |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
148 |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
149 $entity->is_new=FALSE; |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
150 } |
| 0 | 151 relation_update($entity); |
|
5
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 |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
156 function _relation_feeds_checkRelationComplete($relation){ |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
157 //einer der Endpunkte existiert nicht |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
158 |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
159 if (count($relation->endpoints['und'][0]) == 0) |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
160 return false; |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
161 if (!isset($relation->endpoints['und'][1])) |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
162 return false; |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
163 if (count($relation->endpoints['und'][1]) == 0) |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
164 return false; |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
165 |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
166 if ($relation->relation_type == "generic") |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
167 return false; |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
168 return true; |
|
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 |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
172 function _relation_feeds_checkEndpointsComplete($relation){ |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
173 //einer der Endpunkte existiert nicht |
|
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 |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
176 if (count($relation->endpoints['und'][0]) == 0) |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
177 return false; |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
178 if (!isset($relation->endpoints['und'][1])) |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
179 return false; |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
180 if (count($relation->endpoints['und'][1]) == 0) |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
181 return false; |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
182 |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
183 return true; |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
184 |
| 0 | 185 } |
| 186 | |
| 187 /** | |
| 188 * Callback for mapping. Here is where the actual mapping happens. | |
| 189 * | |
| 190 * @todo Do not create new terms for non-autotag fields. | |
| 191 */ | |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
192 function relation_feeds_set_target($source, $entity, $target, $terms, $mapping = array()) { |
| 0 | 193 |
| 194 // Allow mapping the string '0' to a term name. | |
| 195 if (empty($terms) && $terms != 0) { | |
| 196 return; | |
| 197 } | |
| 198 | |
| 199 // Handle non-multiple values. | |
| 200 if (!is_array($terms)) { | |
| 201 $terms = array($terms); | |
| 202 } | |
| 203 | |
| 204 // Add in default values. | |
| 205 $mapping += array( | |
| 206 'term_search' => FEEDS_ENTITY_SEARCH_TERM_NAME, | |
| 207 'autocreate' => FALSE, | |
| 208 ); | |
| 209 | |
| 210 | |
| 211 $cache = &drupal_static(__FUNCTION__); | |
| 212 | |
| 213 | |
| 214 //$query = new EntityFieldQuery(); | |
| 215 //$query->entityCondition('entity_type', 'node') | |
| 216 // ->range(0, 1); | |
| 217 | |
| 218 | |
| 219 | |
| 220 | |
| 221 | |
| 222 | |
| 223 // Iterate over all values. | |
| 224 | |
| 225 | |
| 226 #$mapping['term_search']=FEEDS_ENTITY_SEARCH_TERM_GUID; | |
| 227 foreach ($terms as $term) { | |
| 228 //dpm($term); | |
| 229 | |
| 230 | |
| 231 $tid = FALSE; | |
| 232 | |
| 233 switch ($mapping['term_search']){ | |
| 234 // Lookup by name. | |
| 235 case FEEDS_ENTITY_SEARCH_TERM_NAME: | |
| 236 $name_query = clone $query; | |
| 237 if ($tids = $name_query->propertyCondition('name', $term)->execute()) { | |
| 238 $tid = key($tids['taxonomy_term']); | |
| 239 } | |
| 240 | |
| 241 // Lookup by tid. | |
| 242 case FEEDS_ENTITY_SEARCH_TERM_ID: | |
| 243 if (is_numeric($term)) { | |
| 244 $tid = $term; | |
| 245 } | |
| 246 break; | |
| 247 | |
| 248 // Lookup by GUID. | |
| 249 case FEEDS_ENTITY_SEARCH_TERM_GUID: | |
| 250 | |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
251 |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
252 $tid = relation_feeds_entity_lookup_entity_by_guid($term); |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
253 |
| 0 | 254 break; |
| 255 | |
| 256 case FEEDS_ENTITY_SEARCH_TERM_CITEKEY: | |
| 257 $tid = _searchEntityByBiblioValue("biblio","citekey",$term); | |
| 258 } | |
| 259 } | |
| 260 | |
| 261 | |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
262 |
| 0 | 263 $eps = $entity->endpoints[LANGUAGE_NONE]; |
| 264 if (!isset($entity->endpoints[LANGUAGE_NONE])){ // noch nicht existent | |
| 265 $entity->endpoints[LANGUAGE_NONE][]=array(); | |
| 266 } else if (sizeof($entity->endpoints[LANGUAGE_NONE])<1) { // nicht mindestens ein eintrag | |
| 267 $entity->endpoints[LANGUAGE_NONE][]=array(); | |
| 268 } | |
| 269 | |
| 270 switch ($target){ | |
| 271 case "source_id": | |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
272 |
| 0 | 273 // source is immer der erste eintrag |
| 274 $entity->endpoints[LANGUAGE_NONE][0]=array('entity_type' => 'node', 'entity_id' => $tid); | |
| 275 break; | |
| 276 | |
| 277 case "target_id": | |
| 278 //target können mehrere existieren, hinten anfügen. | |
| 279 $entity->endpoints[LANGUAGE_NONE][]=array('entity_type' => 'node', 'entity_id' => $tid); | |
| 280 } | |
| 281 | |
|
5
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 |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
284 if ( _relation_feeds_checkRelationComplete($entity)){ |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
285 |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
286 $entity->is_new=FALSE; |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
287 relation_update($entity); |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
288 } |
| 0 | 289 |
| 290 | |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
291 if ( _relation_feeds_checkEndpointsComplete($entity)){ |
| 0 | 292 |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
293 relation_update($entity); |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
294 } |
| 0 | 295 |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
296 # if ($target=="source_id"){ |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
297 # relation_update($entity); |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
298 # } |
| 0 | 299 |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
300 #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
|
301 |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
302 //$entity->is_new=FALSE; |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
303 |
|
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
304 #} |
| 0 | 305 // } |
| 306 } | |
| 307 | |
| 308 /** | |
| 309 * Finds all terms associated with the given node, within one vocabulary. | |
| 310 */ | |
| 311 | |
| 312 /* | |
| 313 function taxonomy_feeds_node_get_terms($node, $key = 'tid') { | |
| 314 $terms = &drupal_static(__FUNCTION__); | |
| 315 | |
| 316 if (!isset($terms[$node->nid][$key])) { | |
| 317 // Get tids from all taxonomy_term_reference fields. | |
| 318 $tids = array(); | |
| 319 $fields = field_info_fields(); | |
| 320 foreach ($fields as $field_name => $field) { | |
| 321 if ($field['type'] == 'taxonomy_term_reference' && field_info_instance('node', $field_name, $node->type)) { | |
| 322 if (($items = field_get_items('node', $node, $field_name)) && is_array($items)) { | |
| 323 $tids = array_merge($tids, array_map('_taxonomy_feeds_extract_tid', $items)); | |
| 324 } | |
| 325 } | |
| 326 } | |
| 327 | |
| 328 // Load terms and cache them in static var. | |
| 329 $curr_terms = taxonomy_term_load_multiple($tids); | |
| 330 $terms[$node->nid][$key] = array(); | |
| 331 foreach ($curr_terms as $term) { | |
| 332 $terms[$node->nid][$key][$term->$key] = $term; | |
| 333 } | |
| 334 } | |
| 335 return $terms[$node->nid][$key]; | |
| 336 } | |
| 337 | |
| 338 */ | |
| 339 | |
| 340 /** | |
| 341 * Extracts tid from array item returned by field_get_items(). | |
| 342 * | |
| 343 * @param array $item | |
| 344 * Tid information in the form of a single element array | |
| 345 * (key == 'tid', value == tid we're looking for) | |
| 346 * | |
| 347 * @return int | |
| 348 * Term id extracted from $item. | |
| 349 * | |
| 350 * @see taxonomy_feeds_node_get_terms() | |
| 351 * @see field_get_items() | |
| 352 */ | |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
353 function _relation_feeds_extract_tid($item) { |
| 0 | 354 return $item['tid']; |
| 355 } | |
| 356 | |
| 357 /** | |
| 358 * Looks up a term by GUID, assumes SQL storage backend. | |
| 359 * | |
| 360 * @param string $guid | |
| 361 * The Feeds GUID to compare against. | |
| 362 * | |
| 363 * @return int|FALSE | |
| 364 * The term id, or FALSE if one was not found. | |
| 365 */ | |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
366 function relation_feeds_entity_lookup_entity_by_guid($guid) { |
| 0 | 367 |
| 368 | |
| 369 $res = db_select('feeds_item') | |
| 370 ->fields('feeds_item', array('entity_id')) | |
| 371 //->condition('feed_nid', $source->feed_nid) | |
| 372 //->condition('entity_type', $this->entityType()) | |
| 373 //->condition('id', $source->id); | |
| 374 ->condition('guid', $guid) | |
| 375 ->execute() | |
| 376 ->fetchField(); | |
| 377 | |
| 378 | |
| 379 return $res; | |
| 380 /* return db_select('feeds_item') | |
| 381 ->fields('feeds_item', array('entity_id')) | |
| 382 ->condition('entity_type', 'taxonomy_term') | |
| 383 ->condition('guid', $guid) | |
| 384 ->execute() | |
| 385 ->fetchField();*/ | |
| 386 } | |
| 387 | |
| 388 /** | |
| 389 * Mapping configuration summary for taxonomy.module. | |
| 390 * | |
| 391 * @param array $mapping | |
| 392 * Associative array of the mapping settings. | |
| 393 * @param array $target | |
| 394 * Array of target settings, as defined by the processor or | |
| 395 * hook_feeds_processor_targets_alter(). | |
| 396 * @param array $form | |
| 397 * The whole mapping form. | |
| 398 * @param array $form_state | |
| 399 * The form state of the mapping form. | |
| 400 * | |
| 401 * @return string | |
| 402 * Returns, as a string that may contain HTML, the summary to display while | |
| 403 * the full form isn't visible. | |
| 404 * If the return value is empty, no summary and no option to view the form | |
| 405 * will be displayed. | |
| 406 */ | |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
407 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
|
408 $options = _relation_feeds_form_callback_options(); |
| 0 | 409 if (empty($mapping['term_search'])) { |
| 410 return t('Search Entity terms by: <strong>@search</strong>', array('@search' => $options[FEEDS_ENTITY_SEARCH_TERM_NAME])); | |
| 411 } | |
| 412 return t('Search Entity terms by: <strong>@search</strong>', array('@search' => $options[$mapping['term_search']])); | |
| 413 } | |
| 414 | |
| 415 /** | |
| 416 * Settings form callback. | |
| 417 * | |
| 418 * @return array | |
| 419 * The per mapping configuration form. Once the form is saved, $mapping will | |
| 420 * be populated with the form values. | |
| 421 */ | |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
422 function relation_feeds_form_callback($mapping, $target, $form, $form_state) { |
| 0 | 423 return array( |
| 424 'term_search' => array( | |
| 425 '#type' => 'select', | |
| 426 '#title' => t('Search Entity by'), | |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
427 '#options' => _relation_feeds_form_callback_options(), |
| 0 | 428 '#default_value' => !empty($mapping['term_search']) ? $mapping['term_search'] : FEEDS_ENTITY_SEARCH_TERM_NAME, |
| 429 ), | |
| 430 ); | |
| 431 } | |
| 432 | |
| 433 /** | |
| 434 * Returns the list of available term search methods. | |
| 435 * | |
| 436 * @return array | |
| 437 * An array of taxonomy search option titles. | |
| 438 */ | |
|
5
1c73c660c2f2
new relation_processor
Dirk Wintergruen <dwinter@mpiwg-berlin.mpg.de>
parents:
0
diff
changeset
|
439 function _relation_feeds_form_callback_options() { |
| 0 | 440 return array( |
| 441 FEEDS_ENTITY_SEARCH_TERM_NAME => 'Entity name', | |
| 442 FEEDS_ENTITY_SEARCH_TERM_ID => 'Entity ID', | |
| 443 FEEDS_ENTITY_SEARCH_TERM_GUID => 'GUID', | |
| 444 FEEDS_ENTITY_SEARCH_TERM_CITEKEY => 'CITEKEY' | |
| 445 ); | |
| 446 } | |
| 447 | |
| 448 | |
| 449 | |
| 450 /* sucht nach entity vom typ mit Wert von Feld (fieldname) = term */ | |
| 451 function _searchEntityByBiblioValue($bundle,$fieldName,$term){ | |
| 452 | |
| 453 $fc = module_load_include('inc', 'biblio', 'includes/biblio.pages'); | |
| 454 if ($fc==FALSE){ | |
| 455 dpm("FEHLER: cann't find biblio module!"); | |
| 456 return; | |
| 457 } | |
| 458 $arglist = array ( | |
| 459 "f" => array( $fieldName => $term) | |
| 460 ); | |
| 461 $res = biblio_build_query($arglist); | |
| 462 $nid = $res[0][0]; | |
| 463 | |
| 464 | |
| 465 return $nid; | |
| 466 } | |
| 467 | |
| 468 function _searchEntityByFieldValue($bundle,$fieldName,$term){ | |
| 469 | |
| 470 $query = new EntityFieldQuery(); | |
| 471 $query->entityCondition('entity_type', 'node') | |
| 472 ->entityCondition('bundle', $bundle) | |
| 473 ->fieldCondition($fieldName, 'value',$term, '='); | |
| 474 | |
| 475 $result = $query->execute(); | |
| 476 if (isset($result['node'])) { | |
| 477 $news_items_nids = array_keys($result['node']); | |
| 478 $news_items = entity_load('node', $news_items_nids); | |
| 479 return $news_items[0]; | |
| 480 } | |
| 481 } |