/[drupal]/contributions/modules/demexp/demexp.module

Diff of /contributions/modules/demexp/demexp.module

Parent Directory | Revision Log | View Revision Graph Revision Graph | View Patch Patch

-revision 1.25,
Fri Oct 13 10:18:03 2006 UTC
+revision 1.26,
Sat Oct 14 09:56:08 2006 UTC
 Line 1
  <?php
  /*************************************
   * Demexp module for a Drupal demexp client
-  * $Id: demexp.module,v 1.24 2006/10/13 04:38:23 augustin Exp $
+  * $Id: demexp.module,v 1.25 2006/10/13 10:18:03 augustin Exp $
   * Copyright Augustin Masquilier, 2006.
   * This module is released under the terms of the GPL.
   *************************************/
 Line 710 
 function activate_demexp_account_form_su
   *
   *************************************/
  function demexp_cron() {
    // check if there are new tags to retrieve.
    $demexp_max_tag_id = variable_get('demexp_max_tag_id', 0);
    echo '<p>' . $demexp_max_tag_id . 'last tag retrieved <br />';
    $ds_max_tag_id = _contact_demexp_server('max_tag_id', 0);
    echo $ds_max_tag_id . 'server max<p>';
-   // connection failed or syntax problem. Aborting cron.
+   // connection failed. Aborting cron.
    if ($ds_max_tag_id === FALSE) {
      echo "bye";
      return FALSE;
 Line 735 
 function demexp_cron() {
      $ds_tags = _contact_demexp_server('tag_info', 0,  $demexp_max_tag_id, $nb);
      _demexp_update_tags($ds_tags);
      variable_set('demexp_max_tag_id', $demexp_max_tag_id + $nb);
      // all the tags are supposed to be imported before the questions can be imported,
      // so that the questions' tags can be set properly.
      if ($demexp_max_tag_id + $nb < $ds_max_tag_id) {
        return;
      }
    }
    // check if there are new questions to retrieve.
    $demexp_max_question_id = variable_get('demexp_max_question_id', 0);
    echo $demexp_max_question_id . 'last retrieved <br />';
    $ds_max_question_id = _contact_demexp_server('max_question_id', 0);
    echo $ds_max_question_id . 'server max';
    // $demexp_max_question_id is never supposed to be superior to $ds_max_question_id ;
    if ($ds_max_question_id != $demexp_max_question_id) {
 Line 764 
 function demexp_cron() {
      _demexp_update_question_node($ds_questions);
      variable_set('demexp_max_question_id', $demexp_max_question_id + $nb);
    }
    // get the timestamps to check for updates:
    // TODO: use get_timestamps() instead of get_timestamps_decoded().
    $ds_timestamps = _contact_demexp_server('get_timestamps_decoded', 0);
 Line 807 
 function _demexp_update_tags($ds_tags, $
    if ($update) {
      foreach ($ds_tags AS $tag) {
+       // demexp tags come in the form "abc: economy". "abc" is the key, designing the hierarchy, and "economy" is the tag proper.
+       $key = preg_replace_callback('/^([a-z]*):(.*)$/', create_function('$matches', 'return $matches[1];'), $tag['a_tag_label']);
+       $len = strlen($key);
+       $tag['a_tag_label'] = substr($tag['a_tag_label'], $len+2);
        $tid = db_result(db_query('SELECT tid FROM {demexp_tags} WHERE ds_a_tag_id = %d', $tag['a_tag_id']));
        db_query('UPDATE {term_data} SET name = "%s" WHERE tid = %d', $tag['a_tag_label'], $tid);
+       db_query("UPDATE {demexp_tags} SET tag_hierarchy = '%s' WHERE ds_a_tag_id = %d", $key, $tag['a_tag_id']);
+       _demexp_tag_hierarchy($tid, $key);
      }
    }
    else {
      foreach ($ds_tags AS $tag) {
+       // see similar code above.
+       $key = preg_replace_callback('/^([a-z]*):(.*)$/', create_function('$matches', 'return $matches[1];'), $tag['a_tag_label']);
+       $len = strlen($key);
+       $tag['a_tag_label'] = substr($tag['a_tag_label'], $len+2);
        $values = array();
        $values['name'] = $tag['a_tag_label'];
        drupal_execute('taxonomy_form_term', $values, 2);
        // http://drupal.org/node/84068 programmatically submitting form: drupal_execute should return useful data.
        $tid = db_result(db_query('SELECT tid FROM {term_data} WHERE vid = 2 AND name = "%s" ORDER BY tid DESC', $tag['a_tag_label']));
-       db_query('INSERT INTO {demexp_tags} (ds_a_tag_id, tid, ds_a_tag_timestamp) VALUES (%d, %d, %d)', $tag['a_tag_id'], $tid, $tag['a_tag_timestamp']);
+       db_query("INSERT INTO {demexp_tags} (ds_a_tag_id, tid, ds_a_tag_timestamp, tag_hierarchy) VALUES (%d, %d, %d, '%s')", $tag['a_tag_id'], $tid, $tag['a_tag_timestamp'], $key);
+       _demexp_tag_hierarchy($tid, $key);
      }
    }
  }
+ /*************************************
+  * Update the hierarchy between tags.
+  * Official demexp tags have a single hierarchy.
+  *
+  *************************************/
+ function _demexp_tag_hierarchy($tid, $key) {
+   $len = strlen($key);
+   // update the parent first.
+   if ($len > 1) {
+     $parent_key = substr($key, $len - 1);
+     $parent_tid = db_result(db_query("SELECT tid FROM {demexp_tags} WHERE tag_hierarchy = '%s'", $parent_key));
+     // make sure the the parent is up to date:
+     // 1- remove the old one, if any (there should only be one row with the same tid in the table.
+     // 2 - and put back the new relationship.
+     db_query('DELETE FROM {term_hierarchy} WHERE tid = %d ', $tid);
+     db_query('INSERT INTO {term_hierarchy} (tid, parent) VALUES (%d, %d)', $tid, $parent_tid);
+   }
+   // update the children.
+   $result = db_query("SELECT * FROM {demexp_tags} WHERE LEFT(tag_hierarchy, %d) = '%s' AND LENGTH(tag_hierarchy) = %d", $len, $key, $len +1);
+   while($child = db_fetch_object($result)) {
+     db_query('DELETE FROM {term_hierarchy} WHERE tid = %d ', $child->tid);
+     db_query('INSERT INTO {term_hierarchy} (tid, parent) VALUES (%d, %d)', $child->tid, $tid);
+   }
+ }
  /*************************************
   * Function to theme the body of a question node.

 Legend:



Removed from v.1.25
 


changed lines


 
Added in v.1.26
 Legend:



Removed from v.1.25
 


changed lines


 
Added in v.1.26
-Removed from v.1.25
+Added in v.1.26

	ViewVC Help
Powered by ViewVC 1.1.2