root/contributed_modules/modules/cdrcost/functions.inc.php

<?php /* $Id */
//Copyright (C) 2006 Lenux Inc. (info@lenux.eu)
//
//This program is free software; you can redistribute it and/or
//modify it under the terms of the GNU General Public License
//as published by the Free Software Foundation; either version 2
//of the License, or (at your option) any later version.
//
//This program is distributed in the hope that it will be useful,
//but WITHOUT ANY WARRANTY; without even the implied warranty of
//MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
//GNU General Public License for more details.


function configpageinit($mydisplay, $mytype) {
  global $currentcomponent;
  if ( $currentcomponent->isequal($mydisplay, $mytype) ) {
    $currentcomponent->addguifunc('cdrcost_'.$mydisplay.'_configpageload');
    $currentcomponent->addprocessfunc('cdrcost_'.$mydisplay.'_configprocess');
    return true;
  }
  return false;
}

function configpageload($menu) {
  global $currentcomponent;
  extract($_REQUEST);
  //error_log(date("H:i:s").": configpageload menu: ".$menu." action: ".$action." extdisplay: ".$extdisplay."\n",3,"/tmp/php.log");
  if ( $action == 'del' ) { // Deleted
    $currentcomponent->addguielem('_top', new gui_subheading('del', $extdisplay.' '._("deleted"), false));
    return false;
  } else {
    if ( $extdisplay == '' ) { // Adding
      $currentcomponent->addguielem('_top', new gui_pageheading('title', 'Add '.$menu, false), 0);
      $currentcomponent->addguielem('_top', new gui_hidden('action', 'add'));
    } elseif ( is_string($extdisplay) ) { // Editing
      $currentcomponent->addguielem('_top', new gui_pageheading('title', "$menu: $extdisplay", false), 0);
      $currentcomponent->addguielem('_top', new gui_hidden('action', 'edit'));
      $delURL = $_SERVER['PHP_SELF'].'?'.$_SERVER['QUERY_STRING'].'&action=del';
      $currentcomponent->addguielem('_top', new gui_link('del', _("Delete ")." $menu $extdisplay", $delURL, true, false), 0);
    }
    $currentcomponent->addguielem('_top', new gui_hidden('extdisplay', $extdisplay));
    return true;
  }
}

function cdrcost_configprocess($addfun, $delfun, $editfun) {
  extract($_REQUEST);
  switch ($action) {
    case "add":
      $addfun($_REQUEST);
      //needreload();
      break;
    case "del":
      $delfun($extdisplay);
      //needreload();
      break;
    case "edit":
      $editfun($extdisplay,$_REQUEST);
      //needreload();
      break;
  }
}

// returns a associative arrays with keys 'destination' and 'description'
function cdrcost_destinations() {
  return null;
}

/*  Generates dialplan for conferences
We call this with retrieve_conf
*/
function cdrcost_get_config($engine) {
  global $ext;  // is this the best way to pass this?
  switch($engine) {
    case "asterisk":
    break;
  }
  sql("SET CHARACTER SET utf8","query");
}

/* begin page.zonegroup.php functions */

function cdrcost_zonegroup_add($vars) {
  extract($vars);
  $sql = "INSERT INTO call_zone_group (name) VALUES ('".$name."');";
  sql($sql,"query");
}

function cdrcost_zonegroup_del($id) {
error_log(date("H:i:s").": torol id: ".$id."\n",3,"/tmp/php.log");
  $sql = "DELETE FROM call_zone_group WHERE id = '".$id."'";
  sql($sql,"query");
}

function cdrcost_zonegroup_edit($id,$vars) {
  extract($vars);
  $sql = "UPDATE call_zone_group SET name = '".$name."' WHERE id = '".$id."'";
  sql($sql,"query");
}

function cdrcost_zonegroup_get($id) {
  $sql = "SELECT * FROM call_zone_group WHERE id = '".$id."'";
  return sql($sql,"getAll",DB_FETCHMODE_ASSOC);
}

function cdrcost_zonegroup_list() {
  $sql = "SELECT id, name FROM call_zone_group ORDER BY name";
  return sql($sql,"getAll");
}

function cdrcost_zonegroup_configpageinit($dispnum) {
  configpageinit('zonegroup', 'tool');
}

function cdrcost_zonegroup_configpageload() {
  global $currentcomponent;
  extract($_REQUEST);
  $disppart = 'Zone Group';
  if ( configpageload($disppart) ) {
    $zonegroup = cdrcost_zonegroup_get($extdisplay);
    if ( is_array($zonegroup) && count($zonegroup) == 1 )
      extract($zonegroup[0], EXTR_PREFIX_ALL, 'zonegroup');
    $section = $disppart.' Options';
    $currentcomponent->addguielem($section, new gui_textbox('name', $zonegroup_name, 'Name', 'The name of this Zone Group.', 'isEmpty()', 'Please enter a valid Name'));
  }
}

function cdrcost_zonegroup_configprocess() {
  cdrcost_configprocess(cdrcost_zonegroup_add, cdrcost_zonegroup_del, cdrcost_zonegroup_edit);
}

/* end page.zonegroup.php functions */

/* begin page.zone.php functions */

function cdrcost_zone_add($vars) {
  extract($vars);
  $sql = "INSERT INTO call_zone (group_id, name, pattern) VALUES (";
  $sql .= "'".$group_id."',";
  $sql .= "'".$name."',";
  $sql .= "'".$pattern."');";
  sql($sql,"query");
}

function cdrcost_zone_del($id) {
  $sql = "DELETE FROM call_zone WHERE id = '".$id."'";
  sql($sql,"query");
}

function cdrcost_zone_edit($id,$vars) {
  extract($vars);
  $sql = "UPDATE call_zone SET group_id = '".$group_id."', name = '".$name."', pattern = '".$pattern."' WHERE id = '".$id."'";
  sql($sql,"query");
}

function cdrcost_zone_get($id) {
  $sql = "SELECT * FROM call_zone WHERE id = '".$id."'";
  return sql($sql,"getAll",DB_FETCHMODE_ASSOC);
}

function cdrcost_zone_list() {
  $sql = "SELECT id, name FROM call_zone ORDER BY name";
  return sql($sql,"getAll");
}

function cdrcost_zone_configpageinit($dispnum) {
  global $currentcomponent;
  if ( configpageinit('zone', 'tool') ) {
    $item = 'grouplist';
    $currentcomponent->addoptlist($item, false);
    $list = cdrcost_zonegroup_list();
    if (is_array($list) && count($list) > 0) {
      foreach ($list as $temp) {
        $currentcomponent->addoptlistitem($item, $temp[0], $temp[1]);
      }
    }
  }
}

function cdrcost_zone_configpageload() {
  global $currentcomponent;
  extract($_REQUEST);
  $disppart = 'Zone';
  if ( configpageload($disppart) ) {
    $zone = cdrcost_zone_get($extdisplay);
    if ( is_array($zone) && count($zone) == 1 )
      extract($zone[0], EXTR_PREFIX_ALL, 'zone');
    $section = $disppart.' Options';
    $currentcomponent->addguielem($section, new gui_textbox('name', $zone_name, 'Name', 'The name of this Zone.', 'isEmpty()', 'Please enter a valid Name'));
    $currentcomponent->addguielem($section, new gui_selectbox('group_id', $currentcomponent->getoptlist('grouplist'), $zone_group_id, 'Group', 'The group of this zone', false));
    $currentcomponent->addguielem($section, new gui_textbox('pattern', $zone_pattern, 'Pattern', 'The regex pattern of this Zone.', 'isEmpty()', 'Please enter a valid Pattern'));
  }
}

function cdrcost_zone_configprocess() {
  cdrcost_configprocess(cdrcost_zone_add, cdrcost_zone_del, cdrcost_zone_edit);
}

/* end page.zone.php functions */

/* begin page.schedule.php functions */

function cdrcost_schedule_add($vars) {
  extract($vars);
  $sql = "INSERT INTO call_schedule (name) VALUES ('".$name."');";
  sql($sql,"query");
}

function cdrcost_schedule_del($id) {
  $sql = "DELETE FROM call_schedule WHERE id = '".$id."'";
  sql($sql,"query");
}

function cdrcost_schedule_edit($id,$vars) {
  extract($vars);
  $sql = "UPDATE call_schedule SET name = '".$name."' WHERE id = '".$id."'";
  sql($sql,"query");
}

function cdrcost_schedule_get($id) {
  $sql = "SELECT * FROM call_schedule WHERE id = '".$id."'";
  return sql($sql,"getAll",DB_FETCHMODE_ASSOC);
}

function cdrcost_schedule_list() {
  $sql = "SELECT id, name FROM call_schedule ORDER BY name";
  return sql($sql,"getAll");
}

function cdrcost_schedule_configpageinit($dispnum) {
  configpageinit('schedule', 'tool');
}

function cdrcost_schedule_configpageload() {
  global $currentcomponent;
  extract($_REQUEST);
  $disppart = 'Schedule';
  if ( configpageload($disppart) ) {
    $schedule = cdrcost_schedule_get($extdisplay);
    if ( is_array($schedule) && count($schedule) == 1 )
      extract($schedule[0], EXTR_PREFIX_ALL, 'schedule');
    $section = $disppart.' Options';
    $currentcomponent->addguielem($section, new gui_textbox('name', $schedule_name, 'Name', 'The name of this Schedule.', 'isEmpty()', 'Please enter a valid Name'));
  }
}

function cdrcost_schedule_configprocess() {
  cdrcost_configprocess(cdrcost_schedule_add, cdrcost_schedule_del, cdrcost_schedule_edit);
}

/* end page.schedule.php functions */

/* begin page.schedulepart.php functions */

function cdrcost_schedulepart_add($vars) {
  extract($vars);
  $sql = "INSERT INTO call_schedule_part (name, schedule_id, weekday, begin, end) VALUES (";
  $sql .= "'".$name."',";
  $sql .= "'".$schedule_id."',";
  $sql .= "'".$weekday."',";
  $sql .= "'".$begin."',";
  $sql .= "'".$end."');";
  sql($sql,"query");
}

function cdrcost_schedulepart_del($id) {
  $sql = "DELETE FROM call_schedule_part WHERE id = '".$id."'";
  sql($sql,"query");
}

function cdrcost_schedulepart_edit($id,$vars) {
  extract($vars);
  $sql = "UPDATE call_schedule_part SET ";
  $sql .= "name = '".$name;
  $sql .= "', schedule_id = '".$schedule_id;
  $sql .= "', weekday = '".$weekday;
  $sql .= "', begin = '".$begin;
  $sql .= "', end = '".$end."' WHERE id = '".$id."'";
  sql($sql,"query");
}

function cdrcost_schedulepart_get($id) {
  $sql = "SELECT * FROM call_schedule_part WHERE id = '".$id."'";
  return sql($sql,"getAll",DB_FETCHMODE_ASSOC);
}

function cdrcost_schedulepart_list() {
  $sql = "SELECT id, name FROM call_schedule_part ORDER BY name";
  return sql($sql,"getAll");
}

function cdrcost_schedulepart_configpageinit($dispnum) {
  global $currentcomponent;
  if ( configpageinit('schedulepart', 'tool') ) {
    $item = 'schedulelist';
    $currentcomponent->addoptlist($item, false);
    $list = cdrcost_schedule_list();
    if (is_array($list) && count($list) > 0) {
      foreach ($list as $temp) {
        $currentcomponent->addoptlistitem($item, $temp[0], $temp[1]);
      }
    }
  }
}

function cdrcost_schedulepart_configpageload() {
  global $currentcomponent;
  extract($_REQUEST);
  $disppart = 'Schedule Part';
  if ( configpageload($disppart) ) {
    $schedulepart_weekday = -1;
    $schedulepart_begin = '00:00:00';
    $schedulepart_end   = '23:59:59';
    $schedulepart = cdrcost_schedulepart_get($extdisplay);
    if ( is_array($schedulepart) && count($schedulepart) == 1 )
      extract($schedulepart[0], EXTR_PREFIX_ALL, 'schedulepart');
    $section = $disppart.' Options';
    $currentcomponent->addguielem($section, new gui_textbox('name', $schedulepart_name, 'Name', 'The name of this Schedule part.', 'isEmpty()', 'Please enter a valid Name'));
    $currentcomponent->addguielem($section, new gui_selectbox('schedule_id', $currentcomponent->getoptlist('schedulelist'), $schedulepart_schedule_id, 'Schedule', 'The schedule for this part belong to.', false));
    $currentcomponent->addguielem($section, new gui_textbox('weekday', $schedulepart_weekday, 'Weekday', 'On which weekday this part valid (0 and 7 is sunday, negativ value means always.', '!checkNumber()', 'Please enter a valid value'));
    $currentcomponent->addguielem($section, new gui_textbox('begin', $schedulepart_begin, 'From', 'From which time this part valid (format is: hh:mm:ss.', 'isEmpty()', 'Please enter a valid from'));
    $currentcomponent->addguielem($section, new gui_textbox('end', $schedulepart_end, 'To', 'Until which time this part valid (format is: hh:mm:ss.', 'isEmpty()', 'Please enter a valid to'));
  }
}

function cdrcost_schedulepart_configprocess() {
  cdrcost_configprocess(cdrcost_schedulepart_add, cdrcost_schedulepart_del, cdrcost_schedulepart_edit);
}

/* end page.schedule_part.php functions */

/* begin page.rate.php functions */

function cdrcost_rate_add($vars) {
  extract($vars);
  $sql = "INSERT INTO call_rate (";
  $sql .= "accountcode, name, begin, end, trunk, zone_id, rate, min_duration, block_size, connect, disconnect, schedule_id";
  $sql .= ") VALUES (";
  $sql .= "'".$accountcode."',";
  $sql .= "'".$name."',";
  $sql .= "'".$begin."',";
  $sql .= "'".$end."',";
  $sql .= "'".$trunk."',";
  $sql .= "'".$zone_id."',";
  $sql .= "'".$rate."',";
  $sql .= "'".$min_duration."',";
  $sql .= "'".$block_size."',";
  $sql .= "'".$connect."',";
  $sql .= "'".$disconnect."',";
  $sql .= "'".$schedule_id."');";
  sql($sql,"query");
}

function cdrcost_rate_del($id) {
  $sql = "DELETE FROM call_rate WHERE id = '".$id."'";
  sql($sql,"query");
}

function cdrcost_rate_edit($id,$vars) {
  extract($vars);
  $sql = "UPDATE call_rate SET ";
  $sql .= "accountcode = '".$accountcode."', ";
  $sql .= "name = '".$name."', ";
  $sql .= "begin = '".$begin."', ";
  $sql .= "end = '".$end."', ";
  $sql .= "trunk = '".$trunk."', ";
  $sql .= "zone_id = '".$zone_id."', ";
  $sql .= "rate = '".$rate."', ";
  $sql .= "min_duration = '".$min_duration."', ";
  $sql .= "block_size = '".$block_size."', ";
  $sql .= "connect = '".$connect."', ";
  $sql .= "disconnect = '".$disconnect."', ";
  $sql .= "schedule_id = '".$schedule_id."';";
  sql($sql,"query");
}

function cdrcost_rate_get($id) {
  $sql = "SELECT * FROM call_rate WHERE id = '".$id."'";
  return sql($sql,"getAll",DB_FETCHMODE_ASSOC);
}

function cdrcost_rate_list() {
  $sql = "SELECT id, name FROM call_rate ORDER BY name";
  return sql($sql,"getAll");
}

function cdrcost_rate_configpageinit($dispnum) {
  global $currentcomponent;
  if ( configpageinit('rate', 'tool') ) {
    $item = 'zonelist';
    $currentcomponent->addoptlist($item, false);
    $list = cdrcost_zone_list();
    if (is_array($list) && count($list) > 0) {
      foreach ($list as $temp) {
        $currentcomponent->addoptlistitem($item, $temp[0], $temp[1]);
      }
    }
    $item = 'schedulelist';
    $currentcomponent->addoptlist($item, false);
    $list = cdrcost_schedule_list();
    if (is_array($list) && count($list) > 0) {
      foreach ($list as $temp) {
        $currentcomponent->addoptlistitem($item, $temp[0], $temp[1]);
      }
    }
  }
}

function cdrcost_rate_configpageload() {
  global $currentcomponent;
  extract($_REQUEST);
  $disppart = 'Rate';
  if ( configpageload($disppart) ) {
    $rate_begin = '1900-01-01 00:00:00';
    $rate_end   = '2100-01-01 00:00:00';
    $rate_rate  = 0;
    $rate_min_duration = 0;
    $rate_block_size = 1;
    $rate_connect = 0;
    $rate_disconnect = 0;
    $rate = cdrcost_rate_get($extdisplay);
    if ( is_array($rate) && count($rate) == 1 )
      extract($rate[0], EXTR_PREFIX_ALL, 'rate');
    $section = $disppart.' Options';
    $currentcomponent->addguielem($section, new gui_textbox('name', $rate_name, 'Name', 'The name of this Rate.', 'isEmpty()', 'Please enter a valid Name'));
    $currentcomponent->addguielem($section, new gui_textbox('accountcode', $rate_accountcode, 'Account Code', 'The accountcode used in the extension config. If empty then this rate is for all accountcode.', '!isAlphanumeric()', 'Please enter a valid account code'));
    $currentcomponent->addguielem($section, new gui_textbox('begin', $rate_begin, 'Valid from', "This rate is valid from this time. The format is '1979-10-30 01:02:03'.", '', 'Please enter a valid date'));
    $currentcomponent->addguielem($section, new gui_textbox('end', $rate_end, 'Valid till', "This rate is valid untill this time. The format is '1979-10-30 01:02:03'.", '', 'Please enter a valid date'));
    $currentcomponent->addguielem($section, new gui_textbox('trunk', $rate_trunk, 'Trunk', 'The name of the Trunk for this rate is applicable.', '!isAlphanumeric()', 'Please enter a valid trunk'));
    $currentcomponent->addguielem($section, new gui_selectbox('zone_id', $currentcomponent->getoptlist('zonelist'), $rate_zone_id, 'Zone', 'The zone of this rate', false));
    $currentcomponent->addguielem($section, new gui_textbox('rate', $rate_rate, 'Rate', 'The cost of this rate per seconds.', '!isFloat()', 'Please enter a valid number'));
    $currentcomponent->addguielem($section, new gui_textbox('min_duration', $rate_min_duration, 'Minimum duration', 'The minimum duration will be applied in second.', '!isInteger()', 'Please enter a valid duration'));
    $currentcomponent->addguielem($section, new gui_textbox('block_size', $rate_block_size, 'Block size', 'The increment size which will be applied in second.', '!isInteger()', 'Please enter a valid block size'));
    $currentcomponent->addguielem($section, new gui_textbox('connect', $rate_connect, 'Connection cost', 'The cost of the estabilished connections.', '!isFloat()', 'Please enter a valid cost'));
    $currentcomponent->addguielem($section, new gui_textbox('disconnect', $rate_disconnect, 'Disconnection cost', 'The cost of the disconnections.', '!isFloat()', 'Please enter a valid cost'));
    $currentcomponent->addguielem($section, new gui_selectbox('schedule_id', $currentcomponent->getoptlist('schedulelist'), $rate_schedule_id, 'Schedule', 'In which schedule this rate valid.', false));
  }
}

function cdrcost_rate_configprocess() {
  cdrcost_configprocess(cdrcost_rate_add, cdrcost_rate_del, cdrcost_rate_edit);
}

/* end page.rate.php functions */

/* begin page.maint.php functions */

function get_cost($uniqueid) {
  $sql = "SELECT * FROM asteriskcdrdb.cdr WHERE uniqueid = '".$uniqueid."'";
  $result = sql($sql,"getAll",DB_FETCHMODE_ASSOC);
  if (is_array($result) && count($result) == 1) {
    extract($result[0]);
  } else {
    die("There can't be two uniqueid cdr!");
  }

  $result = getdate(strtotime($calldate));
  $wday = $result["wday"];
  $time = $result["hours"].":".$result["minutes"].":".$result["seconds"];

  $sql_sch = "SELECT id FROM call_schedule_part WHERE (weekday = -1 OR weekday = ".$wday.") AND begin <= '".$time."' AND '".$time."' <= end";
  $sql_zone = "SELECT id FROM call_zone WHERE '".$dst."' REGEXP pattern";
  
  $sql = "SELECT id FROM call_rate WHERE ";
  $sql .= "accountcode = '".$accountcode."'";
  $sql .= " AND begin <= '".$calldate."' AND '".$calldate."' <= end";
  $sql .= " AND LOCATE(trunk,'".$dstchannel."') = 1";
  $sql .= " AND schedule_id IN (".$sql_sch.")";
  $sql .= " AND zone_id IN (".$sql_zone.")";
  $result = sql($sql,"getAll");
  $costs = array();
  if (is_array($result) && count($result) > 0) {
    foreach ($result as $rid) {
      $sql = "SELECT * FROM call_rate WHERE id = ".$rid[0];
      $tmp = sql($sql,"getAll",DB_FETCHMODE_ASSOC);
      extract($tmp[0]);
      $costs[$rid[0]] = max(ceil($billsec / $block_size) * $block_size, $min_duration) * $rate / 60.0 + $connect + $disconnect;
    }
  }
  return $costs;
}

function last_uniqueid() {
  $sql = "SELECT MAX(uniqueid) FROM asteriskcdrdb.cdr WHERE disposition = 'ANSWERED'";
  $result = sql($sql,"getAll");
  return $result[0][0];
}

function getnext_uniqueid($last) {
  if ($last == '') {
    $sql = "SELECT value FROM globals WHERE variable = 'CDRCOST_MAX'";
    $result = sql($sql,"getAll");
    if (is_array($result) && count($result) == 1) {
      $last = $result[0][0];
    }
  }
  $sql = "SELECT MIN(uniqueid) FROM asteriskcdrdb.cdr WHERE disposition = 'ANSWERED'";
  if ($last <> '') {
    $sql .= " AND uniqueid > '".$last."'";
  }
  $result = sql($sql,"getAll");
  if (is_array($result) && count($result) == 1) {
    return $result[0][0];
  } else {
    return '';
  }
}

function fill_cdrcost() {
  $next = getnext_uniqueid('');
  while ($next <> '') {
    //print($next."\n");
    $costs = get_cost($next);
    if (count($costs) > 0) {
      arsort($costs,SORT_NUMERIC);
      $rid = key($costs);
      $cost = current($costs);
      $sql = "INSERT INTO asteriskcdrdb.cdrcost (uniqueid, rate_id, cost) VALUES ('".$next."', ".$rid.", ".$cost.")";
      sql($sql,"query");
    }
    $last = $next;
    $next = getnext_uniqueid($last);
  }
  if ($last <> '') {
    $sql = "INSERT INTO globals (variable, value) VALUES ('CDRCOST_MAX', '".$last."')";
    sql($sql,"query");
  }
}

function cdrcost_maint_add($name) {
  //$sql = "INSERT INTO call_zone_group (name) VALUES ('".$name."');";
  //sql($sql,"query");
}

function cdrcost_maint_del($name) {
  //$sql = "DELETE FROM call_zone_group WHERE name = '".$name."'";
  //sql($sql,"query");
}

function cdrcost_maint_list() {
  //$sql = "SELECT name FROM call_zone_group ORDER BY name";
  //return sql($sql,"getAll");
}

function cdrcost_maint_configpageinit($dispnum) {
}

function cdrcost_maint_configpageload() {
}

function cdrcost_maint_configprocess() {
}


/* end page.maint.php functions */

?>