root/modules/branches/2.7/timeconditions/install.php

<?php /* $Id: install.php $ */

if (!function_exists("timeconditions_timegroups_add_group_timestrings")) {
  function timeconditions_timegroups_add_group_timestrings($description,$timestrings) {
    global $db;

    $sql = "insert timegroups_groups(description) VALUES ('$description')";
    $db->query($sql);
    $timegroup=mysql_insert_id();
    timeconditions_timegroups_edit_timestrings($timegroup,$timestrings);
    return $timegroup;
  }
}

if (!function_exists("timeconditions_timegroups_get_times")) {
  function timeconditions_timegroups_get_times($timegroup) {
    global $db;

    $sql = "select id, time from timegroups_details where timegroupid = $timegroup";
    $results = $db->getAll($sql);
    if(DB::IsError($results)) {
      $results = null;
    }
    foreach ($results as $val) {
      $tmparray[] = array($val[0], $val[1]);
    }
    return $tmparray;
  }
}

if (!function_exists("timeconditions_timegroups_edit_timestrings")) {
  function timeconditions_timegroups_edit_timestrings($timegroup,$timestrings) {
    global $db;

    $sql = "delete from timegroups_details where timegroupid = $timegroup";
    $db->query($sql);
    foreach ($timestrings as $key=>$val) {
      $time = $val;
      if (isset($time) && $time != '' && $time <> '*|*|*|*') {
        $sql = "insert timegroups_details (timegroupid, time) values ($timegroup, '$time')";
        $db->query($sql);
      }
    }
  }
}

if (! function_exists("out")) {
  function out($text) {
    echo $text."<br />";
  }
}

if (! function_exists("outn")) {
  function outn($text) {
    echo $text;
  }
}

if($amp_conf["AMPDBENGINE"] == "sqlite3")  {
  $sql = "
  CREATE TABLE IF NOT EXISTS timeconditions (
    `timeconditions_id` INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
    `displayname` VARCHAR( 50 ) ,
    `time` INT( 11 ) ,
    `truegoto` VARCHAR( 50 ) ,
    `falsegoto` VARCHAR( 50 ),
    `deptname` VARCHAR( 50 )
  )
  ";
}
else  {
  $sql = "
  CREATE TABLE IF NOT EXISTS timeconditions (
    `timeconditions_id` INTEGER NOT NULL PRIMARY KEY AUTO_INCREMENT,
    `displayname` VARCHAR( 50 ) ,
    `time` INT( 11 ) ,
    `truegoto` VARCHAR( 50 ) ,
    `falsegoto` VARCHAR( 50 ),
    `deptname` VARCHAR( 50 )
  )
  ";
}
$check = $db->query($sql);
if(DB::IsError($check)) {
    die_freepbx("Can not create `timeconditions` table: " .  $check->getMessage() .  "\n");
}
if($amp_conf["AMPDBENGINE"] == "sqlite3")  {

  $sql = "
  CREATE TABLE IF NOT EXISTS `timegroups_groups` (
    `id` INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
    `description` varchar(50) NOT NULL default '',
    UNIQUE (`description`)
  ) 
  ";
}
else  {
  $sql = "
  CREATE TABLE IF NOT EXISTS `timegroups_groups` (
      `id` int(11) NOT NULL PRIMARY KEY AUTO_INCREMENT,
      `description` varchar(50) NOT NULL default '',
     UNIQUE KEY `display` (`description`)
  ) AUTO_INCREMENT = 1 
  ";
}
$check = $db->query($sql);
if(DB::IsError($check)) {
  die_freepbx("Can not create `timeconditions` table: " .  $check->getMessage() .  "\n");
}

if($amp_conf["AMPDBENGINE"] == "sqlite3")  {

  $sql = "
  CREATE TABLE IF NOT EXISTS `timegroups_details` (
    `id` INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
    `timegroupid` int(11) NOT NULL default '0',
    `time` varchar(100) NOT NULL default ''
  ) 
  ";
}
else  {
  $sql = "
  CREATE TABLE IF NOT EXISTS `timegroups_details` (
    `id` int(11) NOT NULL PRIMARY KEY AUTO_INCREMENT,
    `timegroupid` int(11) NOT NULL default '0',
    `time` varchar(100) NOT NULL default ''
  )
  ";
}
$check = $db->query($sql);
if(DB::IsError($check)) {
  die_freepbx("Can not create `timeconditions` table: " .  $check->getMessage() .  "\n");
}

// Merge old findmefollow destinations to extension
//
$results = array();
$sql = "SELECT timeconditions_id, truegoto, falsegoto FROM timeconditions";
$results = $db->getAll($sql, DB_FETCHMODE_ASSOC);
if (!DB::IsError($results)) { // error - table must not be there
  foreach ($results as $result) {
    $old_false_dest    = $result['falsegoto'];
    $old_true_dest     = $result['truegoto'];
    $timeconditions_id = $result['timeconditions_id'];

    $new_false_dest = merge_ext_followme(trim($old_false_dest));
    $new_true_dest  = merge_ext_followme(trim($old_true_dest));
    if (($new_true_dest != $old_true_dest) || ($new_false_dest != $old_false_dest)) {
      $sql = "UPDATE timeconditions SET truegoto = '$new_true_dest', falsegoto = '$new_false_dest' WHERE timeconditions_id = $timeconditions_id  AND truegoto = '$old_true_dest' AND falsegoto ='$old_false_dest'";
      $results = $db->query($sql);
      if(DB::IsError($results)) {
        die_freepbx($results->getMessage());
      }
    }
  }
}

/* Upgrade to 2.5
 * Migrate time conditions to new time conditions groups
 */
timeconditions_updatedb();

/* Alter the time field to int now that it refernces the id field in groups
 */
// sqlite3 support as of 2.5 has correct table structure built into the CREATE
if($amp_conf["AMPDBENGINE"] != "sqlite3")  {
  outn(_("converting timeconditions time field to int.."));
  $sql = "ALTER TABLE `timeconditions` CHANGE `time` `time` INT (11)";
  $results = $db->query($sql);
  if(DB::IsError($results)) {
    out(_("ERROR: failed to convert field ").$results->getMessage());
  } else {
    out(_("OK"));
  }
}

// bring db up to date on install/upgrade
//
function timeconditions_updatedb() {
  $modinfo = module_getinfo('timeconditions');
  if (is_array($modinfo)) {
    $ver = $modinfo['timeconditions']['dbversion'];

    // If previous version was older than 2.5 then migrate the timeconditions to groups
    //
    if (version_compare_freepbx($ver,'2.5','lt')) { 
      outn(_("Checking for old timeconditions to upgrade.."));
      $upgradelist = timeconditions_list_forupgrade();
      if (isset($upgradelist)) { 
        // we have old conditions to upgrade
        //
        out(_("starting migration"));
        foreach($upgradelist as $upgrade) {
          $times[] = $upgrade['time'];
          $newid = timeconditions_timegroups_add_group_timestrings('migrated-'.$upgrade['displayname'],$times);
          timeconditions_set_timegroupid($upgrade['timeconditions_id'],$newid);
          $newtimes = timeconditions_timegroups_get_times($newid);
          out(sprintf(_("Upgraded %s and created group %s"), $upgrade['displayname'], 'migrated-'.$upgrade['displayname']));
          if (!is_array($newtimes)) {
            out(sprintf(_("%sWARNING:%s No time defined for this condition, please review"),"<font color='red'>","</font>"));
          }
          unset($times);
        }
      } else {
        out(_("no upgrade needed"));
      }
    }
  }
}

function timeconditions_list_forupgrade() {
  $results = sql("SELECT * FROM timeconditions","getAll",DB_FETCHMODE_ASSOC);
  if(is_array($results)){
    foreach($results as $result){
      $list[] = $result;
    }
  }
  if (isset($list)) {
    return $list;
  } else { 
    return null;
  }
}

function timeconditions_set_timegroupid($id, $timegroup) {
  sql("UPDATE timeconditions SET time = $timegroup WHERE timeconditions_id = $id;");
}
?>