No OneTemporary
Actions

Size

328 KB

Referenced Files

None

Subscribers

None

View Options

This file is larger than 256 KB, so syntax highlighting was skipped.

	diff --git a/library/cdr_generic.php b/library/cdr_generic.php
	index 5a0a003..c7b1030 100644
	--- a/library/cdr_generic.php
	+++ b/library/cdr_generic.php
	@@ -1,3399 +1,3418 @@
	<?php
	$tz = $CDRTool['provider']['timezone'];
	putenv("TZ=$tz");

	#[AllowDynamicProperties]
	class CDRS
	{
	public $cdrtool;
	public $cdr_source;
	public $CDRTool;
	public $rating_settings;
	public $DATASOURCES;
	public $ratingEnabled;
	public $rating;
	public $quota_init_flag;
	public $quota_reset_flag;
	public $daily_quota;
	public $primary_database;
	public $secondary_database;
	public $CDRdb;
	public $CDRdb1;
	public $db_class;
	public $AccountsDB;
	public $db_subscribers;
	public $enableThor;
	public $missed_calls;
	public $traceInURL;
	public $traceOutURL;
	public $protocolTraceURL;
	public $scriptFile;
	public $next;
	public $export;
	public $trace;
	private $destinations_count;
	private $destinations_sip_count;
	private $_destinations;
	private $_destinations_sip;
	private $destinations_default_count;
	private $destinations_gateway_count;
	private $destinations_domain_count;
	private $destinations_subscriber_count;
	private $destinations;
	private $destinations_sip;
	private $destinations_length;
	private $ENUMtlds;
	public $domain_table;
	public $trusted_table;
	public $tables;
	private $initOK;

	var $CDR_class = 'CDR';
	var $intAccessCode = '00';
	var $natAccessCode = '0';
	var $maxrowsperpage = 15;
	var $status = array();
	var $normalizedField = 'Normalized';
	var $DestinationIdField = 'DestinationId';
	var $BillingIdField = 'UserName';
	var $defaults = array();
	var $whereUnnormalized = '';
	var $skipNormalize = false;
	var $reNormalize = false;
	var $usageKeysForDeletionFromCache = array();
	var $localDomains = array();
	var $trustedPeers = array();
	var $maxCDRsNormalizeWeb = 500;
	var $E164_class = 'E164_Europe';
	var $quotaEnabled = false;
	var $csv_writter = false;

	var $CallerIsLocal = false;
	var $CalleeIsLocal = false;

	var $CDRNormalizationFields = array(
	'id' => 'RadAcctId',
	'callId' => 'AcctSessionId',
	'username' => 'UserName',
	'domain' => 'Realm',
	'gateway' => 'NASIPAddress',
	'duration' => 'AcctSessionTime',
	'startTime' => 'AcctStartTime',
	'stopTime' => 'AcctStopTime',
	'inputTraffic' => 'AcctInputOctets',
	'outputTraffic' => 'AcctOutputOctets',
	'aNumber' => 'CallingStationId',
	'cNumber' => 'CalledStationId',
	'timestamp' => 'timestamp',
	'BillingPartyId' => 'UserName',
	'sipRPID' => 'SipRPID',
	'ResellerId' => 'BillingId',
	'price' => 'Price',
	'DestinationId' => 'DestinationId'
	);

	function _readCDRNormalizationFieldsFromDB()
	{
	foreach (array_keys($this->CDRNormalizationFields) as $field) {
	$mysqlField = $this->CDRNormalizationFields[$field];
	$CDRStructure[$mysqlField] = $this->CDRdb->f($mysqlField);
	}

	return $CDRStructure;
	}

	protected function _readCDRFieldsFromDB()
	{
	foreach (array_keys($this->CDRFields) as $field) {
	$mysqlField = $this->CDRFields[$field];
	$CDRStructure[$mysqlField] = $this->CDRdb->f($mysqlField);
	}
	return $CDRStructure;
	}

	public function initCDRFields()
	{
	// init names of CDR fields
	foreach (array_keys($this->CDRFields) as $field) {
	$mysqlField = $this->CDRFields[$field];
	$_field = $field."Field";
	$this->$_field = $mysqlField;
	}
	}

	private function initDatabaseConnection()
	{
	// connect to the CDR database(s)
	if(!$this->DATASOURCES[$this->cdr_source]['db_class']) {
	$log = sprintf("Error: \$DATASOURCES['%s']['db_class'] is not defined (init)", $this->cdr_source);
	syslog(LOG_NOTICE, $log);
	return 0;
	}

	$_dbClass = $this->DATASOURCES[$this->cdr_source]['db_class'];

	if (is_array($_dbClass)) {
	if ($_dbClass[0]) $this->primary_database = $_dbClass[0];
	if ($_dbClass[1]) $this->secondary_database = $_dbClass[1];
	} else {
	$this->primary_database = $_dbClass;
	}

	if(!class_exists($this->primary_database)) {
	$log = sprintf("Error: database class '%s' is not defined", $this->primary_database);
	syslog(LOG_NOTICE, $log);
	return 0;
	}

	$this->CDRdb = new $this->primary_database;

	// check db connectivity
	if (!$this->CDRdb->query('SELECT 1')) {
	$log = sprintf("Error: failed to connect to the primary CDR database %s\n", $this->primary_database);
	syslog(LOG_NOTICE, $log);

	if ($this->secondary_database) {
	$this->CDRdb = new $this->secondary_database;
	if (!$this->CDRdb->query('SELECT 1')) {
	$log = sprintf("Error: failed to connect to the secondary CDR database %s\n", $this->secondary_database);
	syslog(LOG_NOTICE, $log);
	return 0;
	} else {
	$this->CDRdb1 = new $this->secondary_database;
	$this->db_class = $this->secondary_database;
	}
	} else {
	return 0;
	}
	} else {
	$this->CDRdb1 = new $this->primary_database;
	$this->db_class = $this->primary_database;
	}
	return 1;
	}

	public function __construct($cdr_source)
	{
	global $CDRTool;
	global $DATASOURCES;
	global $RatingEngine;

	if (!$cdr_source) {
	$log = "Error: cdr_source not defined\n";
	syslog(LOG_NOTICE, $log);
	return 0;
	}

	if (!$DATASOURCES[$cdr_source]) {
	$log = sprintf("Error: no such datasource defined (%s)\n", $cdr_source);
	syslog(LOG_NOTICE, $log);
	return 0;
	}

	$this->initDefaults();

	$this->cdrtool = new DB_CDRTool();
	$this->cdr_source = $cdr_source;
	$this->CDRTool = $CDRTool;
	$this->rating_settings = $RatingEngine;
	$this->DATASOURCES = $DATASOURCES;

	$this->cdrtool->Halt_On_Error = "no";

	$this->table = $this->DATASOURCES[$this->cdr_source]['table'];

	$this->initCDRFields();

	if ($this->DATASOURCES[$this->cdr_source]['rating']) {
	$this->ratingEnabled = 1;
	$this->rating = $this->DATASOURCES[$this->cdr_source]['rating'];
	if ($this->DATASOURCES[$this->cdr_source]['showRate']) $this->showRate = $this->DATASOURCES[$this->cdr_source]['showRate'];
	if ($this->DATASOURCES[$this->cdr_source]['rateField']) $this->rateField = $this->DATASOURCES[$this->cdr_source]['rateField'];
	if ($this->DATASOURCES[$this->cdr_source]['priceField']) $this->priceField = $this->DATASOURCES[$this->cdr_source]['priceField'];
	}

	if ($this->DATASOURCES[$this->cdr_source]['UserQuotaClass']) {
	$this->quotaEnabled = 1;
	$this->quota_init_flag = $this->cdr_source.':quotaCheckInit';
	$this->quota_reset_flag = $this->cdr_source.':reset_quota_for';
	if ($this->DATASOURCES[$this->cdr_source]['daily_quota']) {
	$this->daily_quota=$this->DATASOURCES[$this->cdr_source]['daily_quota'];
	}
	}

	$this->initDatabaseConnection();

	if ($this->DATASOURCES[$this->cdr_source]['DestinationIdField']) {
	$this->DestinationIdField = $this->DATASOURCES[$this->cdr_source]['DestinationIdField'];
	}

	if ($this->DATASOURCES[$this->cdr_source]['normalizedField']) {
	$this->normalizedField = $this->DATASOURCES[$this->cdr_source]['normalizedField'];
	}

	if (array_key_exists('intAccessCode', $this->DATASOURCES[$this->cdr_source])
	&& strlen($this->DATASOURCES[$this->cdr_source]['intAccessCode'])
	) {
	$this->intAccessCode = $this->DATASOURCES[$this->cdr_source]['intAccessCode'];
	}

	if (array_key_exists('natAccessCode', $this->DATASOURCES[$this->cdr_source])
	&& strlen($this->DATASOURCES[$this->cdr_source]['natAccessCode'])
	) {
	$this->natAccessCode = $this->DATASOURCES[$this->cdr_source]['natAccessCode'];
	}

	if ($this->DATASOURCES[$this->cdr_source]['db_subscribers']) {
	if (class_exists($this->DATASOURCES[$this->cdr_source]['db_subscribers'])) {
	$this->AccountsDB = new $this->DATASOURCES[$this->cdr_source]['db_subscribers'];
	$this->db_subscribers = $this->DATASOURCES[$this->cdr_source]['db_subscribers'];
	} else {
	$log = sprintf(
	"Error: subscribers database class %s is not defined",
	$this->DATASOURCES[$this->cdr_source]['db_subscribers']
	);
	syslog(LOG_NOTICE, $log);
	return 0;
	}
	- } else if (class_exists('DB_opensips')) {
	+ } elseif (class_exists('DB_opensips')) {
	$this->AccountsDB = new DB_opensips();
	$this->db_subscribers = 'DB_opensips';
	} else {
	$log = sprintf(
	"Error: subscribers database is not defined, please define 'db_subscribers' in datasource '%s'",
	$this->cdr_source
	);
	syslog(LOG_NOTICE, $log);
	return 0;
	}

	if ($this->DATASOURCES[$this->cdr_source]['BillingIdField']) {
	$this->BillingIdField = $this->DATASOURCES[$this->cdr_source]['BillingIdField'];
	}

	if ($this->DATASOURCES[$this->cdr_source]['E164_class']) {
	if (class_exists($this->DATASOURCES[$this->cdr_source]['E164_class'])) {
	$this->E164_class = $this->DATASOURCES[$this->cdr_source]['E164_class'];
	} else {
	printf(
	"Error: E164 class '%s' defined in datasource %s does not exist, using default '%s'",
	$this->DATASOURCES[$this->cdr_source]['E164_class'],
	$this->cdr_source,
	$this->E164_class
	);
	}
	}

	if ($this->DATASOURCES[$this->cdr_source]['sipTrace']) {
	$this->sipTrace = $this->DATASOURCES[$this->cdr_source]['sipTrace'];
	}

	if ($this->DATASOURCES[$this->cdr_source]['mediaTrace']) {
	$this->mediaTrace = $this->DATASOURCES[$this->cdr_source]['mediaTrace'];
	}

	if ($this->DATASOURCES[$this->cdr_source]['domain_table']) {
	$this->domain_table = $this->DATASOURCES[$this->cdr_source]['domain_table'];
	}

	if ($this->DATASOURCES[$this->cdr_source]['skipNormalize']) {
	$this->skipNormalize = $this->DATASOURCES[$this->cdr_source]['skipNormalize'];
	}

	if ($this->DATASOURCES[$this->cdr_source]['enableThor']) {
	$this->enableThor = $this->DATASOURCES[$this->cdr_source]['enableThor'];
	}

	if (is_array($this->CDRTool['normalize']['CS_CODES'])) $this->CS_CODES=array_keys($this->CDRTool['normalize']['CS_CODES']);

	$this->missed_calls = $this->DATASOURCES[$this->cdr_source]['missed_calls'];
	$this->traceInURL = $this->DATASOURCES[$this->cdr_source]['traceInURL'];
	$this->traceOutURL = $this->DATASOURCES[$this->cdr_source]['traceOutURL'];
	$this->protocolTraceURL = $this->DATASOURCES[$this->cdr_source]['protocolTraceURL'];

	- $spath = explode("/",$_SERVER["PHP_SELF"]);
	+ $spath = explode("/", $_SERVER["PHP_SELF"]);
	$last = count($spath)-1;
	$this->scriptFile=$spath[$last];

	$this->next = $_REQUEST["next"];
	$this->export = $_REQUEST["export"];
	$this->trace = $_REQUEST["trace"];

	if ($this->export) {
	$this->maxrowsperpage=10000000;
	} else {
	if ($_REQUEST["maxrowsperpage"]) {
	$this->maxrowsperpage = $_REQUEST["maxrowsperpage"];
	} else {
	$this->maxrowsperpage = "25";
	}
	}

	$this->LoadDisconnectCodes();

	$this->LoadDestinations();

	$this->LoadENUMtlds();

	$this->LoadDomains();

	$this->LoadTrustedPeers();

	$this->getCDRtables();

	if ($this->DATASOURCES[$this->cdr_source]['csv_writer_class']) {
	$csv_writter_class=$this->DATASOURCES[$this->cdr_source]['csv_writer_class'];
	if (class_exists($csv_writter_class)) {
	$this->csv_writter = new $csv_writter_class(
	$this->cdr_source,
	$this->DATASOURCES[$this->cdr_source]['csv_directory'],
	$this->db_subscribers
	);
	}
	}

	$this->initOK=1;
	}

	function initDefaults()
	{
	if (is_readable('/etc/default/cdrtool')) {
	$defaultContentLines = explode("\n", file_get_contents('/etc/default/cdrtool'));

	foreach ($defaultContentLines as $_line) {
	list($defaults_key, $defaults_value) = explode("=", $_line);
	if (strlen($defaults_value)) $this->defaults[trim($defaults_key)]=trim($defaults_value);
	}
	}
	}

	function LoadDomains()
	{
	}

	function LoadTrustedPeers()
	{
	}

	function LoadAccounts()
	{
	}

	function LoadDestinations()
	{

	$_destinations = array();
	$_destinations_sip = array();

	$this->destinations_count = 0;
	$this->destinations_sip_count = 0;

	$query = sprintf("select `value` from memcache where `key` = 'destinations'");

	if (!$this->cdrtool->query($query)) {
	$log = sprintf(
	"Database error for query %s: %s (%s)",
	$query,
	$this->cdrtool->Error,
	$this->cdrtool->Errno
	);
	print $log;
	syslog(LOG_NOTICE, $log);
	return false;
	}

	if ($this->cdrtool->num_rows()) {
	$b = time();

	$this->cdrtool->next_record();
	- $_destinations = json_decode($this->cdrtool->f('value'),true);
	+ $_destinations = json_decode($this->cdrtool->f('value'), true);

	foreach (array_keys($_destinations) as $_key1) {
	- foreach(array_keys($_destinations[$_key1]) as $_key2) {
	+ foreach (array_keys($_destinations[$_key1]) as $_key2) {
	$this->destinations_count = $this->destinations_count + count($_destinations[$_key1][$_key2]);
	}
	}

	if (!$this->destinations_count) {
	$log = "Error: cached destinations key contains no data";
	syslog(LOG_NOTICE, $log);
	}

	$query = sprintf("select `value` from memcache where `key` = 'destinations_sip'");

	if (!$this->cdrtool->query($query)) {
	$log = sprintf(
	"Database error for query %s: %s (%s)",
	$query,
	$this->cdrtool->Error,
	$this->cdrtool->Errno
	);
	print $log;
	syslog(LOG_NOTICE, $log);
	return false;
	}

	if ($this->cdrtool->num_rows()) {
	$this->cdrtool->next_record();
	$_destinations_sip = json_decode($this->cdrtool->f('value'), true);

	foreach (array_keys($_destinations_sip) as $_key1) {
	foreach (array_keys($_destinations_sip[$_key1]) as $_key2) {
	$this->destinations_sip_count = $this->destinations_count + count($_destinations_sip[$_key1][$_key2]);
	}
	}
	}

	/*
	$e=time();
	$log=sprintf("Read %d PSTN destinations from cache in %d seconds",$this->destinations_count,$e-$b);
	syslog(LOG_NOTICE,$log);

	if ($this->destinations_sip_count) {
	$e=time();
	$log=sprintf("Read %d SIP destinations from cache in %d seconds",$this->destinations_sip_count,$e-$b);
	syslog(LOG_NOTICE,$log);
	}
	*/
	$this->destinations = $_destinations;
	$this->destinations_sip = $_destinations_sip;
	unset($_destinations);
	unset($_destinations_sip);
	} else {
	$this->CacheDestinations();

	$this->destinations = $this->_destinations;
	$this->destinations_sip = $this->_destinations_sip;

	unset($this->_destinations);
	unset($this->_destinations_sip);
	}

	if (is_array($this->destinations)) {
	foreach (array_keys($this->destinations) as $_reseller) {
	foreach ($this->destinations[$_reseller] as $key => $val) {
	$this->destinations_length[$_reseller][$key] = max(array_map('strlen', array_keys($val)));
	}
	}
	}

	$c = $this->destinations_count + $this->destinations_sip_count;
	return $c;
	}

	function CacheDestinations()
	{

	$this->_destinations = array();
	$this->_destinations_sip = array();

	$this->destinations_count = 0;
	$this->destinations_sip_count = 0;

	$b=time();

	$query = "select * from destinations";
	if ($this->CDRTool['filter']['aNumber']) {
	$faNumber=$this->CDRTool['filter']['aNumber'];
	$query .= sprintf(" where subscriber = '%s' or (subscriber = '' and domain = '' and gateway = '') ", addslashes($faNumber));
	} elseif ($this->CDRTool['filter']['domain']) {
	$fdomain=$this->CDRTool['filter']['domain'];
	$query .= sprintf(" where domain = '%s' or (subscriber = '' and domain = '' and gateway = '') ", addslashes($fdomain));
	} elseif ($this->CDRTool['filter']['gateway']) {
	$fgateway=$this->CDRTool['filter']['gateway'];
	$query .= sprintf(" where gateway = '%s' or (subscriber = '' and domain = '' and gateway = '') ",addslashes($fgateway));
	}

	$this->cdrtool->query($query);

	if (!$this->cdrtool->num_rows()) {
	$log = "Error: could not find any entries in the destinations table";
	syslog(LOG_NOTICE, $log);
	return 0;
	}

	$destinations_cache = "\n";
	$destinations_sip_cache = "\n";

	$this->destinations_count = 0;
	$this->destinations_default_count = 0;
	$this->destinations_gateway_count = 0;
	$this->destinations_domain_count = 0;
	$this->destinations_subscriber_count = 0;

	$j=0;
	while ($this->cdrtool->next_record()) {
	$j++;

	$reseller_id = $this->cdrtool->Record['reseller_id'];
	$gateway = trim($this->cdrtool->Record['gateway']);
	$domain = trim($this->cdrtool->Record['domain']);
	$subscriber = trim($this->cdrtool->Record['subscriber']);
	$dest_id = trim($this->cdrtool->Record['dest_id']);
	$region = iso8859_1_to_utf8($this->cdrtool->Record['region']);
	$name = iso8859_1_to_utf8($this->cdrtool->Record['dest_name']);

	$name_print = $this->cdrtool->Record['dest_name']." (".$dest_id.")";

	if (strstr($dest_id, '@')) {
	// SIP destination

	if ($subscriber) {
	$this->_destinations_sip[$reseller_id][$subscriber][$dest_id] = array(
	'name' => $name,
	'region' => $region
	);
	$this->destinations_sip_count++;
	} elseif ($domain) {
	$this->_destinations_sip[$reseller_id][$domain][$dest_id] = array(
	'name' => $name,
	'region' => $region
	);
	$this->destinations_sip_count++;
	} elseif ($gateway) {
	$this->_destinations_sip[$reseller_id][$gateway][$dest_id] = array(
	'name' => $name,
	'region' => $region
	);
	$this->destinations_sip_count++;
	} elseif ($dest_id) {
	$this->_destinations_sip[$reseller_id]["default"][$dest_id] = array(
	'name' => $name,
	'region' => $region
	);
	$this->destinations_sip_count++;
	}
	} else {
	// PSTN destination
	if (!is_numeric($dest_id)) {
	$log = sprintf(
	"Error: cannot load non-numeric destination '%s' from row id %d",
	$dest_id,
	$this->cdrtool->Record['id']
	);
	syslog(LOG_NOTICE, $log);
	continue;
	}

	if ($subscriber) {
	$this->destinations_subscriber_count++;
	$this->_destinations[$reseller_id][$subscriber][$dest_id]=array(
	'name' => $name,
	'region' => $region
	);
	$this->destinations_count++;
	} elseif ($domain) {
	$this->destinations_domain_count++;
	$this->_destinations[$reseller_id][$domain][$dest_id]=array(
	'name' => $name,
	'region' => $region
	);
	$this->destinations_count++;
	} elseif ($gateway) {
	$this->destinations_gateway_count++;
	$this->_destinations[$reseller_id][$gateway][$dest_id]=array(
	'name' => $name,
	'region'=> $region
	);
	$this->destinations_count++;
	} elseif ($dest_id) {
	$this->destinations_default_count++;
	$this->_destinations[$reseller_id]["default"][$dest_id]=array(
	'name' => $name,
	'region' => $region
	);
	$this->destinations_count++;
	}
	}
	}

	$destinations_cache = json_encode($this->_destinations);
	$destinations_sip_cache = json_encode($this->_destinations_sip);

	$log = sprintf("PSTN destinations cache size: %0.2f MB", strlen($destinations_cache) / 1024 / 1024);
	syslog(LOG_NOTICE, $log);

	if ($destinations_sip_cache) {
	$log = sprintf("SIP destinations cache size: %0.2f MB", strlen($destinations_sip_cache) / 1024 / 1024);
	syslog(LOG_NOTICE, $log);
	}

	$query = sprintf("select `value` from memcache where `key` = 'destinations'");
	if (!$this->cdrtool->query($query)) {
	$log = sprintf(
	"Database error for query %s: %s (%s)",
	$query,
	$this->cdrtool->Error,
	$this->cdrtool->Errno
	);
	print $log;
	syslog(LOG_NOTICE, $log);
	return false;
	}

	if ($this->cdrtool->num_rows()) {
	$query = sprintf(
	"update memcache set value = '%s' where `key` = 'destinations'",
	addslashes($destinations_cache)
	);
	if (!$this->cdrtool->query($query)) {
	$log = sprintf(
	"Database error for query %s: %s (%s)",
	$query,
	$this->cdrtool->Error,
	$this->cdrtool->Errno
	);
	print $log;
	syslog(LOG_NOTICE, $log);
	return false;
	}

	$log = sprintf(
	"Cached %d total, %d default, %d gateway, %d domain, %d subscriber destinations",
	$this->destinations_count,
	$this->destinations_default_count,
	$this->destinations_gateway_count,
	$this->destinations_domain_count,
	$this->destinations_subscriber_count
	);
	syslog(LOG_NOTICE, $log);
	} else {
	$query = sprintf(
	"insert into memcache (`key`,`value`) values ('destinations','%s')",
	addslashes($destinations_cache)
	);
	if (!$this->cdrtool->query($query)) {
	$log = sprintf(
	"Database error for query %s: %s (%s)",
	$query,
	$this->cdrtool->Error,
	$this->cdrtool->Errno
	);
	print $log;
	syslog(LOG_NOTICE, $log);
	return false;
	}

	$log = sprintf(
	"Cached %d total, %d default, %d gateway, %d domain, %d subscriber destinations",
	$this->destinations_count,
	$this->destinations_default_count,
	$this->destinations_gateway_count,
	$this->destinations_domain_count,
	$this->destinations_subscriber_count
	);
	syslog(LOG_NOTICE, $log);
	}

	$query = sprintf("select `value` from memcache where `key` = 'destinations_sip'");
	if (!$this->cdrtool->query($query)) {
	$log = sprintf(
	"Database error for query %s: %s (%s)",
	$query,
	$this->cdrtool->Error,
	$this->cdrtool->Errno
	);
	print $log;
	syslog(LOG_NOTICE, $log);
	return false;
	}

	if ($this->cdrtool->num_rows()) {
	$query = sprintf(
	"update memcache set value = '%s' where `key` = 'destinations_sip'",
	addslashes($destinations_sip_cache)
	);
	if (!$this->cdrtool->query($query)) {
	$log = sprintf(
	"Database error for query %s: %s (%s)",
	$query,
	$this->cdrtool->Error,
	$this->cdrtool->Errno
	);
	print $log;
	syslog(LOG_NOTICE, $log);
	return false;
	}
	$log = sprintf("Cached %d SIP destinations", $this->destinations_sip_count);
	syslog(LOG_NOTICE, $log);
	} else {
	$query = sprintf(
	"insert into memcache (`key`,`value`) values ('destinations_sip','%s')",
	addslashes($destinations_sip_cache)
	);

	if (!$this->cdrtool->query($query)) {
	$log = sprintf(
	"Database error for query %s: %s (%s)",
	$query,
	$this->cdrtool->Error,
	$this->cdrtool->Errno
	);
	print $log;
	syslog(LOG_NOTICE, $log);
	return false;
	}
	$log = sprintf("Updated cache for %d SIP destinations", $this->destinations_sip_count);
	syslog(LOG_NOTICE, $log);
	}

	return true;
	}

	function LoadENUMtlds()
	{
	$_ENUMtlds = array();

	$query = "select * from billing_enum_tlds";

	$this->cdrtool->query($query);

	while ($this->cdrtool->next_record()) {
	$_ENUMtlds[trim($this->cdrtool->Record['enum_tld'])] = array(
	'discount' => trim($this->cdrtool->Record['discount']),
	'e164_regexp' => trim($this->cdrtool->Record['e164_regexp'])
	);
	}

	$this->ENUMtlds = $_ENUMtlds;
	$c = count($this->ENUMtlds);

	return count($this->ENUMtlds);
	}

	public function LoadDisconnectCodes()
	{
	}

	function initForm()
	{
	}

	public function searchForm()
	{
	}

	function showTableHeader()
	{
	}

	function showTableHeaderStatistics()
	{
	}

	function showResultsMenu($hide_rows = "", $begin_datetime = '', $end_datetime = '')
	{
	global $loginname;
	if (!$this->export) {
	print "
	<form class='form-inline' action=log.phtml method=post>
	<div class='row-fluid'>
	<div class='span6'>";
	print "
	<div class=\"btn-group pull-right\">
	<a class=\"btn\" href=\"$this->url_edit\" ><i class=icon-search></i> Refine search</a><a class=\"btn\" href=\"$this->url_run\"><i class=\"icon-refresh\"></i> Refresh</a>";


	$log_query = sprintf(
	"insert into log
	(date,login,ip,url,results,rerun,reedit,datasource,reseller_id)
	values
	(NOW(),'%s','%s','%s','%s','%s','%s','%s',%d)",
	addslashes($loginname),
	addslashes($_SERVER["REMOTE_ADDR"]),
	addslashes($this->url),
	addslashes($this->rows),
	addslashes($this->url_run),
	addslashes($this->url_edit),
	addslashes($this->cdr_source),
	addslashes($this->CDRTool['filter']['reseller'])
	);

	if ($this->cdrtool->query($log_query)) {
	$this->cdrtool->query("select LAST_INSERT_ID() as lid");
	$this->cdrtool->next_record();
	$current_log=$this->cdrtool->f('lid');
	}

	if ($this->rows) {
	print "<a class=\"btn\" href=\"$this->url_export\" target=_new><i class=\"icon-file\"></i> Export results to file</a>
	</div></div>";
	} else {
	print "</div></div>";
	}
	print "
	<div class='span6'>
	<div class='input-append'>
	<input class='input-medium' rel='popover' data-placement=\"bottom\" data-content=\"Want to share the results with others? Enter a name and press Save \" data-original-title=\"Save Query\" placeholder='Query name' type=text name=log_description value=\"$old_description\"><button class='btn' type=submit value=Save>Save</button>
	</div>
	<input type=hidden name=current_log value=$current_log>
	<input type=hidden name=task value=edit>
	</div>
	</div>
	</form>
	";

	if (!$hide_rows) {
	print "
	<div class=\"alert alert-success\"><center>";
	if ($this->rows == 0) {
	print "No records found";
	} else {
	print "$this->rows records found";
	}

	if ($begin_datetime && $end_datetime) {
	printf(" between %s and %s", $begin_datetime, $end_datetime);
	}

	print "</center></div>
	";
	}
	}
	}

	function showResultsMenuSubscriber($hide_rows = "", $begin_datetime = '', $end_datetime = '')
	{
	global $loginname;

	if (!$this->export) {
	print "
	<form action=log.phtml method=post>
	<table border=0 align=center>
	<tr>
	<td>
	<td>
	<a href=\"$this->url_edit\">Refine search</a>
	\| <a href=\"$this->url_run\">Refresh</a>
	</td>
	";

	$log_query = sprintf(
	"insert into log
	(date,login,ip,url,results,rerun,reedit,datasource,reseller_id)
	values
	(NOW(),'%s','%s','%s','%s','%s','%s','%s',%d)",
	addslashes($loginname),
	addslashes($_SERVER["REMOTE_ADDR"]),
	addslashes($this->url),
	addslashes($this->rows),
	addslashes($this->url_run),
	addslashes($this->url_edit),
	addslashes($this->cdr_source),
	0
	);

	if ($this->cdrtool->query($log_query)) {
	$this->cdrtool->query("select LAST_INSERT_ID() as lid");
	$this->cdrtool->next_record();
	$current_log=$this->cdrtool->f('lid');
	}

	if (!$this->CDRTool['filter']['aNumber']) {
	if ($this->rows) {
	print " \| <a href=\"$this->url_export\" target=_new>Export results to file</a>";
	}
	print "
	</td>
	<td valign=middle>
	\| Save a description for this query:
	</td>
	<td valign=middle>
	<input type=text name=log_description value=\"$old_description\">
	<input type=hidden name=current_log value=$current_log>
	<input type=hidden name=task value=edit>
	<input type=submit value=Save>
	</td>
	</form>
	";
	}

	print "
	</tr>
	</table>
	";
	if (!$hide_rows) {
	print "<div class=\"alert alert-success\"><center>";
	if ($this->rows == 0) {
	print "No records found";
	} else {
	print "$this->rows records found";
	}
	if ($begin_datetime && $end_datetime) {
	printf(" between %s and %s",$begin_datetime,$end_datetime);
	}

	print "</center>
	</div>
	";
	}
	}
	}

	function showDateTimeElements($f)
	{
	print "
	<tr>
	<td valign=middle align=left>
	<b>Start Time</b>
	</td>
	<td><div class='input-append date'>
	";

	$f->show_element("begin_date","");
	print "<span class=\"add-on\">
	<i class=\"icon-calendar\"></i>
	</span></div> ";

	print "Time: ";
	print "<div class=\"input-append bootstrap-timepicker\">";
	$f->show_element("begin_time","");
	print "<span class=\"add-on\"><i class=\"icon-time\"></i></span>
	</div>
	</td>
	</tr>
	<tr>
	<td valign=middle align=left>
	<b>Stop Time</b>
	</td>
	<td><div class='input-append date'>
	";

	$f->show_element("end_date","");
	print "<span class=\"add-on\">
	<i class=\"icon-calendar\"></i>
	</span></div> ";

	print "Time: ";
	print "<div class=\"input-append bootstrap-timepicker\">";
	$f->show_element("end_time","");
	print "<span class=\"add-on\"><i class=\"icon-time\"></i></span>
	</div>
	</td>
	</tr>
	";
	}

	function showDataSources($f)
	{
	global $perm;
	print "
	<tr>
	<td class=cdr valign=middle align=left>
	<b>Data Source</b>
	</td>
	<td valign=middle>";
	- $f->show_element("cdr_source","");
	+ $f->show_element("cdr_source", "");
	if (count($this->tables) > 0) {
	print " Table: ";
	- $this->f->show_element("cdr_table","");
	+ $this->f->show_element("cdr_table", "");
	}
	print "
	</td>
	</tr>
	<tr>
	";
	}

	function showPagination($next, $maxrows)
	{
	$PHP_SELF = $_SERVER["PHP_SELF"];

	if (!$this->export) {
	print "
	<ul class=\"pager\">
	";
	if ($next != 0) {
	$show_next = $this->maxrowsperpage - $next;
	if ($show_next < 0) {
	$mod_show_next = $show_next - 2 * $show_next;
	}
	$url_prev = $PHP_SELF.$this->url."&action=search&next=$mod_show_next";
	print "<li><a href=\"$url_prev\"> ← Previous</a></li>";
	}

	print "
	</td>
	<td>
	";
	if ($this->rows > $this->maxrowsperpage && $this->rows != $maxrows) {
	$show_next = $this->maxrowsperpage + $this->next;
	$url_next = $PHP_SELF.$this->url."&action=search&next=$show_next";
	print "<li><a href=\"$url_next\">Next →</a></li>";
	}
	print "
	</ul>
	";
	}
	}

	function show()
	{
	}

	function dump()
	{
	}

	function unNormalize($where = "", $table = "")
	{
	if ($this->skipNormalize) {
	return 0;
	}

	if (!$this->normalizedField) {
	return 0;
	}

	// do not allow renormalization for readonly accounts
	global $perm;
	if (is_object($perm) && $perm->have_perm('readonly')) return false;

	if (!$where) $where=" (1=1) ";

	if (!$table) $table=$this->table;

	$query=sprintf(
	"update %s set %s = '0' where %s ",
	addslashes($table),
	addslashes($this->normalizedField),
	$where
	);

	$c=0;

	if ($this->CDRdb->query($query)) {
	$c = $this->CDRdb->affected_rows();
	$this->reNormalize = true;
	}

	return $c;
	}

	function buildWhereForUnnormalizedSessions()
	{
	$this->whereUnnormalized = sprintf(" %s = '0'",$this->normalizedField);

	if ($this->stopTimeField) $this->whereUnnormalized .= " and $this->stopTimeField not like '0000-00-00 00:00:00%' ";

	if ($this->CDRFields['MediaTimeout']) {
	/*
	If we use MediaProxy information then eliminate all possible raise conditions

	1. Session started and is in progress:
	AcctStopTime = '0000-00-00 00:00:00'
	AcctSessionTime = 0
	MediaInfo is NULL
	ConnectInfo_stop is NULL

	2. Session closed with a negative response code ([4-6]XX):
	AcctSessionTime = 0
	AcctStopTime != '0000-00-00 00:00:00'
	MediaInfo is NULL
	ConnectInfo_stop is NULL

	3. Session received a BYE:
	ConnectInfo_stop is not NULL
	AcctStopTime != '0000-00-00 00:00:00'

	4. Media has timed-out:
	MediaInfo = 'timeout'
	ConnectInfo_stop is NULL
	AcctStopTime != '0000-00-00 00:00:00'

	5. MediaProxy update before BYE is received:
	MediaInfo = ''
	ConnectInfo_stop is NULL
	AcctStopTime != '0000-00-00 00:00:00'

	6. Mofified 5. for the case where the session received a broken BYE
	that did not generate a STOP while MediaProxy generated an UPDATE

	*/

	$this->whereUnnormalized .= " and (ConnectInfo_stop is not NULL or MediaInfo is NULL or MediaInfo != '' or (UNIX_TIMESTAMP(NOW()) - UNIX_TIMESTAMP(AcctStopTime) > 20)) ";
	}
	}

	function getUnNormalized($where = "", $table = "")
	{

	if ($this->skipNormalize) {
	return 0;
	}

	if (!$where) $where=" (1=1) ";
	if (!$table) $table=$this->table;

	$ReNormalize = $_REQUEST["ReNormalize"];

	if ($ReNormalize) $this->unNormalize($where, $table);

	if (!$this->normalizedField) {
	return 0;
	}

	$this->buildWhereForUnnormalizedSessions();

	$query=sprintf(
	"select count(*) as c from %s where %s and %s",
	addslashes($table),
	$where,
	$this->whereUnnormalized
	);

	if ($this->CDRdb->query($query)) {
	$this->CDRdb->next_record();
	$c = $this->CDRdb->f('c');
	}

	return $c;
	}

	function NormalizeCDRS($where = "", $table = "")
	{
	$this->missing_destinations=array();

	$b=time();

	if (!$where) $where=" (1=1) ";
	if (!$table) $table=$this->table;

	if ($this->skipNormalize) {
	return 1;
	}

	if (!$this->normalizedField) {
	return 1;
	}

	$lockName = sprintf("%s:%s", $this->cdr_source, $table);

	if (!$this->getNormalizeLock($lockName)) {
	//printf("Cannot get obtain lock %s",$lockName);
	return true;
	}

	$this->buildWhereForUnnormalizedSessions();

	$this->status['cdr_to_normalize'] = 0;
	$this->status['normalized'] = 0;
	$this->status['normalize_failures'] = 0;

	$query = sprintf(
	"select count(*) as c from %s where %s and %s",
	addslashes($table),
	$where,
	$this->whereUnnormalized
	);

	if ($this->CDRdb->query($query)) {
	$this->CDRdb->next_record();
	$c=$this->CDRdb->f('c');
	}

	$this->status['cdr_to_normalize']=$c;

	//$this->status['cdr_to_normalize']=$this->CDRdb->num_rows();

	//print "<p>$query";

	if ($this->status['cdr_to_normalize'] > 0) {
	if ($this->ratingEnabled) {
	// Load rating tables
	$this->RatingTables = new RatingTables();
	$this->RatingTables->LoadRatingTables();
	}
	} else {
	return 0;
	}

	$this->usageKeysForDeletionFromCache = array();

	// For loop to process 1k records each time
	for ($i = 0; $i <= $this->status['cdr_to_normalize']; $i=$i+1000) {
	$query = sprintf(
	"select *, UNIX_TIMESTAMP($this->startTimeField) as timestamp
	from %s where %s and %s limit 0,1000",
	addslashes($table),
	$where,
	$this->whereUnnormalized
	);


	if (!$this->CDRdb->query($query)) {
	$log = sprintf(
	"Database error: %s (%s)\n",
	$this->CDRdb->Error,
	$this->CDRdb->Errno
	);
	syslog(LOG_NOTICE, $log);
	print $log;
	return false;
	}

	while ($this->CDRdb->next_record()) {
	//$Structure=$this->_readCDRNormalizationFieldsFromDB();
	$Structure=$this->_readCDRFieldsFromDB();
	if ($this->csv_writter) {
	if (!$this->csv_file_cannot_be_opened) {
	if (!$this->csv_writter->ready) {
	if (!$this->csv_writter->open_file($Structure[$this->CDRNormalizationFields['id']])) {
	$this->csv_file_cannot_be_opened = true;
	} else {
	$this->csv_file_ready = true;
	}
	}
	}
	}

	$found++;

	$CDR = new $this->CDR_class($this, $Structure);

	if ($CDR->normalize("Save", $table)) {
	$this->status['normalized']++;
	if ($this->csv_file_ready) {
	if (!$this->csv_writter->write_cdr($CDR)) {
	// stop writing future records if we have a failure
	$this->csv_file_cannot_be_opened = true;
	}
	}

	if ($CDR->broken_rate) {
	$this->brokenRates[$CDR->DestinationId]++;
	}
	} else {
	$this->status['normalize_failures']++;
	}

	if ($this->reNormalize && !$this->usageKeysForDeletionFromCache[$CDR->BillingPartyId]) {
	$this->usageKeysForDeletionFromCache[$CDR->BillingPartyId]++;
	}

	if ($this->status['cdr_to_normalize'] > 1000) {
	if ($found > $progress*$this->status['cdr_to_normalize']/100) {
	$progress++;
	if ($progress%10==0) {
	print "$progress% ";
	flush();
	}
	}
	}
	}
	}

	if ($this->ratingEnabled && is_array($this->brokenRates) && count($this->brokenRates) > 0) {
	if ($this->rating_settings['reportMissingRates']) {
	if (count($this->brokenRates)) {
	foreach (array_keys($this->brokenRates) as $dest) {
	$missingRatesBodytext=$missingRatesBodytext."\nDestination id $dest (".$this->brokenRates[$dest]." calls)";
	}

	$to = $this->CDRTool['provider']['toEmail'];

	$from = $this->CDRTool['provider']['fromEmail'];

	$log = sprintf(
	"Mailing missing rates for %d destination(s) to %s",
	count($this->brokenRates),
	$to
	);
	syslog(LOG_NOTICE, $log);

	mail($to, "Missing CDRTool rates",$missingRatesBodytext, "From: $from");
	}
	}
	}

	if (count($this->missing_destinations)) {
	$to = $this->CDRTool['provider']['toEmail'];
	$from = $this->CDRTool['provider']['fromEmail'];

	$body = '';
	foreach ($this->missing_destinations as $_dest) {
	if (!$seen[$_dest]) {
	$body .= sprintf("No destination for number %s\n", $_dest);
	}
	$seen[$_dest]++;
	}
	mail($to, "Missing CDRTool destinations", $body, "From: $from");
	}

	if ($this->status['cdr_to_normalize'] > 0) {
	$d = time() - $b;
	$log = sprintf("Normalization done in %d s, memory usage: %0.2f MB", $d, memory_get_usage() / 1024 / 1024);
	syslog(LOG_NOTICE, $log);
	}

	if ($this->csv_file_ready) {
	$this->csv_writter->close_file();
	$this->csv_writter->ready = false;
	}

	if (count($this->usageKeysForDeletionFromCache)) {
	$this->resetQuota(array_keys($this->usageKeysForDeletionFromCache));
	}

	return 1;
	}

	function NormalizeNumber($Number, $type = "destination", $subscriber = "", $domain = "", $gateway = "", $CountryCode = "", $ENUMtld = "", $reseller_id = 0)
	{
	$this->CSCODE="";

	$Number = strtolower(quoted_printable_decode($Number));

	if ($pos = strpos($Number, "@")) {
	// this is a SIP URI
	$NumberStack['username'] = substr($Number, 0, $pos);
	if (strlen($NumberStack['username']) < 1) {
	$NumberStack['username'] = "unknown";
	}
	$NumberStack['domain'] = substr($Number,$pos+1);
	$NumberStack['delimiter'] = "@";

	$pos = strpos($NumberStack['username'], ":");
	if ($pos) {
	$NumberStack['protocol'] = substr($NumberStack['username'], 0, $pos+1);
	$NumberStack['username'] = substr($NumberStack['username'], $pos+1);
	}

	if (preg_match("/^(.*)[=:;]/U", $NumberStack['domain'], $p)){
	$NumberStack['domain'] = $p[1];
	}
	} elseif (preg_match("/^([a-z0-9]+:)(.*)$/i", $Number, $m)) {
	#$oct=preg_split("/\./",$m[2]);
	$oct = explode(",", $m[2]);
	if (sizeof($oct) == 4) {
	// This is a SIP address without username
	$NumberStack['username'] = "";
	$NumberStack['domain'] = $m[2];
	} else {
	// This is a SIP address without domain
	$NumberStack['username'] = $m[2];
	$NumberStack['domain'] = "";
	}
	$NumberStack['protocol'] = $m[1];
	$NumberStack['delimiter'] = "";
	} else {
	// This is a simple address like a phone number
	$NumberStack['protocol'] = "";
	$NumberStack['username'] = $Number;
	$NumberStack['delimiter'] = "";
	$NumberStack['domain'] = "";
	}

	if (preg_match("/^(.*)[=:;]/U", $NumberStack['domain'], $p)){
	$NumberStack['domain'] = $p[1];
	}

	// Translate the domain
	if (is_array($this->DATASOURCES[$this->cdr_source]['domainTranslationDestination'])
	&& isset($this->DATASOURCES[$this->cdr_source]['domainTranslationDestination'][$NumberStack['domain']])
	) {
	$NumberStack['domain'] = $this->DATASOURCES[$this->cdr_source]['domainTranslationDestination'][$NumberStack['domain']];
	}

	if ($type=="destination" && is_numeric($NumberStack['username'])) {
	// strip custom prefix from destination
	$usernameLength = strlen($NumberStack['username']);
	if (is_array($this->CS_CODES)) {
	foreach ($this->CS_CODES as $strip_prefix) {
	$prefixLength = strlen($strip_prefix);
	$restLength = $usernameLength-$prefixLength;
	if ($restLength > 0 and preg_match("/^$strip_prefix(.*)$/", $NumberStack['username'], $m)) {
	$NumberStack['username'] = $m[1];
	$this->CSCODE = $strip_prefix;
	break;
	}
	}
	}

	if (!$CountryCode) $CountryCode = $this->CDRTool['normalize']['defaultCountryCode'];

	$e164class = $this->E164_class;
	$E164 = new $e164class(
	$this->intAccessCode,
	$this->natAccessCode,
	$CountryCode,
	$this->ENUMtlds[$ENUMtld]['e164_regexp']
	);

	$NumberStack['E164'] = $E164->E164Format($NumberStack['username']);
	}

	if ($type=="destination" && $NumberStack['E164']) {
	// lookup destination id for the E164 number
	$dst_struct = $this->lookupDestination(
	$NumberStack['E164'],
	$subscriber,
	$domain,
	$gateway,$reseller_id
	);
	$NumberStack['DestinationId'] = $dst_struct[0];
	$NumberStack['destinationName'] = $dst_struct[1];

	$NumberStack['NumberPrint'] = "+".$NumberStack['E164'];

	if (!$ENUMtld) {
	$NumberStack['Normalized'] = $this->intAccessCode.
	$NumberStack['E164'].
	$NumberStack['delimiter'].
	$NumberStack['domain'];
	} else {
	$NumberStack['Normalized'] =
	$NumberStack['username'].
	$NumberStack['delimiter'].
	$NumberStack['domain'];
	}
	} else {
	$dst_struct = $this->lookupDestination(
	$Number,
	$subscriber,
	$domain,
	$gateway,
	$reseller_id
	);
	$NumberStack['DestinationId'] = $dst_struct[0];
	$NumberStack['destinationName'] = $dst_struct[1];

	$NumberStack['NumberPrint'] = $NumberStack['username'].
	$NumberStack['delimiter'].
	$NumberStack['domain'];

	$NumberStack['Normalized'] = $NumberStack['username'].
	$NumberStack['delimiter'].
	$NumberStack['domain'];
	}

	return $NumberStack;
	}

	function lookupDestination($destination, $subscriber = "", $domain = "", $gateway = "", $reseller_id = 0)
	{
	if (!$destination) return;

	if (is_numeric($destination)) {
	return $this->lookupPSTNDestination($destination, $subscriber, $domain, $gateway, $reseller_id);
	} else {
	return $this->lookupSipDestination($destination, $subscriber, $domain, $gateway, $reseller_id);
	}
	}

	function lookupSipDestination($destination = '', $subscriber = '', $domain = '', $gateway = '', $reseller_id = 0)
	{
	if ($this->destinations_sip[$reseller_id][$subscriber]) {
	$destinations_sip = $this->destinations_sip[$reseller_id][$subscriber];
	$fCustomer = "subscriber=$subscriber";
	} elseif ($this->destinations_sip[$reseller_id][$domain]) {
	$destinations_sip = $this->destinations_sip[$reseller_id][$domain];
	$fCustomer = "domain=$domain";
	} elseif ($this->destinations_sip[$reseller_id][$gateway]) {
	$destinations_sip = $this->destinations_sip[$reseller_id][$gateway];
	$fCustomer = "gateway=$gateway";
	} elseif ($this->destinations_sip[$reseller_id]['default']) {
	$destinations_sip = $this->destinations_sip[$reseller_id]['default'];
	$fCustomer = "default";
	} elseif ($this->destinations_sip[0][$subscriber]) {
	$destinations_sip = $this->destinations_sip[0][$subscriber];
	$fCustomer = "subscriber=$subscriber";
	} elseif ($this->destinations_sip[0][$domain]) {
	$destinations_sip = $this->destinations_sip[0][$domain];
	$fCustomer = "domain=$domain";
	} elseif ($this->destinations_sip[0][$gateway]) {
	$destinations_sip = $this->destinations_sip[0][$gateway];
	$fCustomer = "gateway=$gateway";
	} elseif ($this->destinations_sip[0]['default']) {
	$destinations_sip = $this->destinations_sip[0]['default'];
	$fCustomer = "default";
	}

	$ret = false;
	if ($destinations_sip[$destination]) {
	$ret = array($destination,$destinations_sip[$destination]['name']);
	} else {
	list($user,$domain) = explode("@", $destination);
	if ($domain) {
	$domain = sprintf("@%s", $domain);
	if ($destinations_sip[$domain]) {
	$ret = array($domain, $destinations_sip[$domain]['name']);
	}
	}
	}
	return $ret;
	}

	function lookupPSTNDestination($destination = '', $subscriber = '', $domain = '', $gateway = '', $reseller_id = 0)
	{
	if ($this->destinations[$reseller_id][$subscriber]) {
	$_destinations = $this->destinations[$reseller_id][$subscriber];
	$maxLength = $this->destinations_length[$reseller_id][$subscriber];
	$fCustomer="subscriber=$subscriber";
	} elseif ($this->destinations[$reseller_id][$domain]) {
	$_destinations = $this->destinations[$reseller_id][$domain];
	$maxLength = $this->destinations_length[$reseller_id][$domain];
	$fCustomer="domain=$domain";
	} elseif ($this->destinations[$reseller_id][$gateway]) {
	$_destinations = $this->destinations[$reseller_id][$gateway];
	$maxLength = $this->destinations_length[$reseller_id][$gateway];
	$fCustomer="gateway=$gateway";
	} elseif ($this->destinations[$reseller_id]['default']) {
	$_destinations = $this->destinations[$reseller_id]['default'];
	$maxLength = $this->destinations_length[$reseller_id]['default'];
	$fCustomer="default";
	} elseif ($this->destinations[0][$subscriber]) {
	$_destinations = $this->destinations[0][$subscriber];
	$maxLength = $this->destinations_length[0][$subscriber];
	$fCustomer="subscriber=$subscriber";
	} elseif ($this->destinations[0][$domain]) {
	$_destinations = $this->destinations[0][$domain];
	$maxLength = $this->destinations_length[0][$domain];
	$fCustomer="domain=$domain";
	} elseif ($this->destinations[0][$gateway]) {
	$_destinations = $this->destinations[0][$gateway];
	$maxLength = $this->destinations_length[0][$gateway];
	$fCustomer="gateway=$gateway";
	} elseif ($this->destinations[0]['default']) {
	$_destinations = $this->destinations[0]['default'];
	$maxLength = $this->destinations_length[0]['default'];
	$fCustomer="default";
	} else {
	$log = sprintf(
	"Error: cannot find destinations for subscriber='%s', domain ='%s', gateway='%s', reseller='%s'\n",
	$subscriber,
	$domain,
	$gateway,
	$reseller_id
	);
	syslog(LOG_NOTICE, $log);
	}

	if (count($_destinations) > 0) {
	$length = min(strlen($destination), $maxLength);
	for ($i = $length; $i > 0; $i--) {
	$buf = substr($destination, 0, $i);
	if ($_destinations[$buf]) {
	return array($buf, $_destinations[$buf]['name']);
	}
	}
	}

	$log = sprintf(
	"Error: cannot find destination id for %s of customer = '%s', total destinations = %d\n",
	$destination,
	$fCustomer,
	count($_destinations)
	);
	syslog(LOG_NOTICE, $log);

	$this->missing_destinations[] = $destination;
	return false;
	}

	function import($file)
	{
	}

	function RadiusRecordRead($fp)
	{
	$keepreading=1;

	while ($keepreading) {
	$contents = fgets($fp, 8192);
	if (preg_match("/^$/", $contents)) {
	$keepreading=0;
	} else {
	$record[]=$contents;
	}
	}
	return $record;
	}

	function RadiusRecordParse($record)
	{
	unset($radiusParsed);
	if (!is_array($record)) {
	return 0;
	}

	foreach ($record as $line) {
	$line=trim($line);
	foreach (array_keys($this->radiusAttributes) as $attribute) {
	if (preg_match("/$attribute = (.*)$/", $line, $m)) {
	$value = preg_replace("/\"/", "", trim($m[1]));
	$radiusParsed[$attribute] = $value;
	}
	}
	}
	return $radiusParsed;
	}

	function getCDRtables()
	{
	if (!is_object($this->CDRdb)) return 0;
	$_tables=$this->CDRdb->table_names();
	$t=count($_tables);

	if ($this->table) $this->tables[]=$this->table;

	while ($t <> 0) {
	$_table=$_tables[$t-1]["table_name"];
	if ($_table=='radacct') $this->tables[]='radacct';

	if (preg_match("/^(\w+)(\d{6})$/", $_table, $m)) {
	if ($list_t > 24) break;
	$this->tables[] = $_table;
	$list_t++;
	}
	$t--;
	}
	$this->tables=array_unique($this->tables);
	}

	function rotateTable($sourceTable, $month, $action)
	{
	// create a new table tableYYYYMM and copy data from the main table into it
	// if no month is supplied, the default is the previous month

	if (!$month) $month=date('Ym', mktime(0, 0, 0, date("m") - 1, "01", date("Y")));

	if (!$sourceTable) $sourceTable = $this->table;

	if (preg_match("/^(\w+)\d{6}$/", $sourceTable, $m)) {
	$destinationTable = $m[1].$month;
	} else {
	$destinationTable = $sourceTable.$month;
	}

	print("rotateTable($sourceTable, $month, $destinationTable)\n");

	if ($sourceTable == $destinationTable) {
	$log = sprintf("Error: cannot copy records to the same table %s.\n", $destinationTable);
	syslog(LOG_NOTICE, $log);
	print $log;
	return 0;
	}

	$createTableFile = $this->CDRTool['Path'].$this->createTableFile;

	if (!$this->createTableFile \|\| !is_readable($createTableFile)) {
	$log = sprintf("Error: cannot locate mysql creation file\n");
	syslog(LOG_NOTICE, $log);
	print $log;
	return 0;
	}

	$lockFile="/var/lock/CDRTool_".$this->cdr_source."_rotateTable.lock";

	$f = fopen($lockFile, "w");
	if (flock($f, LOCK_EX + LOCK_NB, $w)) {
	if ($w) {
	$log = sprintf("Another CDRTool rotate table is in progress. Aborting.\n");
	syslog(LOG_NOTICE, $log);
	print $log;
	return 0;
	}
	} else {
	$log = sprintf("Another CDRTool rotate table is in progress. Aborting.\n");
	syslog(LOG_NOTICE, $log);
	print $log;
	return 0;
	}

	$b=time();

	if (!preg_match("/^(\d{4})(\d{2})$/", $month, $m)) {
	print "Error: Month $month must be in YYYYMM format\n";
	return 0;
	} else {
	if ($m[2] > 12) {
	print "Error: Month must be in YYYYMM format\n";
	return 0;
	}

	$lastMonth = $month;
	$startSQL = $m[1]."-".$m[2]."-01";
	$stopSQL =date('Y-m-01', mktime(0, 0, 0, $m[2] + 1, "01", $m[1]));
	}

	$query = sprintf(
	"select count(*) as c from %s where %s >='%s' and %s < '%s'\n",
	addslashes($sourceTable),
	addslashes($this->CDRFields['startTime']),
	addslashes($startSQL),
	addslashes($this->CDRFields['startTime']),
	addslashes($stopSQL)
	);


	if ($this->CDRdb->query($query)) {
	$this->CDRdb->next_record();
	$rowsSourceTable = $this->CDRdb->f('c');
	$log=sprintf("Source table %s has %d records in month %s\n", $sourceTable, $rowsSourceTable, $month);
	syslog(LOG_NOTICE, $log);
	print $log;
	if (!$rowsSourceTable) return 1;
	} else {
	$log = sprintf("Error: %s (%s)\n", $this->table, $this->CDRdb->Error);
	syslog(LOG_NOTICE, $log);
	print $log;
	return 0;
	}

	$query = sprintf("select count(*) as c from %s\n", addslashes($destinationTable));

	if ($this->CDRdb->query($query)) {
	$this->CDRdb->next_record();
	$rowsDestinationTable = $this->CDRdb->f('c');
	$log = sprintf("Destination table %s has %d records\n", $destinationTable, $rowsDestinationTable);
	syslog(LOG_NOTICE, $log);
	print $log;

	if ($rowsDestinationTable != $rowsSourceTable) {
	$log = sprintf(
	"Error: source table has %d records and destination table has %d records\n",
	$rowsSourceTable,
	$rowsDestinationTable
	);
	syslog(LOG_NOTICE, $log);
	print $log;
	} else {
	$log = sprintf("Tables are in sync\n");
	syslog(LOG_NOTICE, $log);
	print $log;
	}
	} else {
	$log = sprintf("%s (%s)\n", $this->CDRdb->Error, $this->CDRdb->Errno);
	syslog(LOG_NOTICE, $log);
	print $log;

	if ($this->CDRdb->Errno==1146) {
	$destinationTableTmp = $destinationTable."_tmp";
	$query=sprintf("drop table if exists %s", addslashes($destinationTableTmp));
	print($query);
	$this->CDRdb->query($query);

	if ($query=file_get_contents($createTableFile)) {
	$query=preg_replace("/CREATE TABLE.*/", "CREATE TABLE $destinationTableTmp (", $query);
	if (!$this->CDRdb->query($query)) {
	$log = sprintf("Error creating table %s: %s, %s\n", $destinationTableTmp, $this->CDRdb->Error,$query);
	syslog(LOG_NOTICE, $log);
	print $log;
	return 0;
	}
	} else {
	$log = sprintf("Cannot read file %s\n",$createTableFile);
	syslog(LOG_NOTICE, $log);
	print $log;
	return 0;
	}

	// if we reached this point we start to copy records
	$query = sprintf(
	"insert into %s select * from %s where %s >='%s' and %s < '%s'",
	addslashes($destinationTableTmp),
	addslashes($sourceTable),
	addslashes($this->CDRFields['startTime']),
	addslashes($startSQL),
	addslashes($this->CDRFields['startTime']),
	addslashes($stopSQL)
	);

	return;

	if ($this->CDRdb->query($query)) {
	$e=time();
	$d=$e-$b;
	$rps=0;
	if ($this->CDRdb->affected_rows() && $d) $rps=$this->CDRdb->affected_rows()/$d;

	$log = printf("Copied %d CDRs into table %s in %d s @ %.0f rps\n",$this->CDRdb->affected_rows(),$destinationTableTmp,$d,$rps);
	syslog(LOG_NOTICE,$log);
	print $log;

	$query=sprinf("rename table %s to %s", addslashes($destinationTableTmp),addslashes($destinationTableTmp));

	if (!$this->CDRdb->query($query)) {
	printf ("Error renaming table %s to %s: %s\n",$destinationTableTmp,$destinationTable,$this->CDRdb->Error);
	return 0;
	}
	} else {
	printf ("Error copying records in table %s: %s\n",$destinationTable,$this->CDRdb->Error);
	return 0;
	}
	}
	}
	}

	function purgeTable($sourceTable, $month)
	{
	// delete records for a given month with minimal locking of database
	// this function is useful after archive of CDR data using rotate script
	$begin = time();

	if ($month) {
	if (!preg_match("/^(\d{4})(\d{2})$/", $month, $m)) {
	print "Error: Month must be in YYYYMM format\n";
	return 0;
	} else {
	$beginDate=$m[1]."-".$m[2]."-01";
	$endDate=date('Y-m-d', mktime(0, 0, 0, $m[2]+1, '01', $m[1]));
	}
	- } else if (is_int($this->DATASOURCES[$this->cdr_source]['purgeCDRsAfter'])) {
	+ } elseif (is_int($this->DATASOURCES[$this->cdr_source]['purgeCDRsAfter'])) {
	$beginDate="1970-01-01";
	$endDate=date('Y-m-d', mktime(0, 0, 0, Date('m'), Date('d')-$this->DATASOURCES[$this->cdr_source]['purgeCDRsAfter'], Date('Y')));
	} else {
	return 0;
	}

	if (!$sourceTable) $sourceTable=$this->table;

	$query = sprintf(
	"select min(%s) as min,max(%s) as max from %s where %s >= '%s' and %s < '%s' ",
	addslashes($this->CDRFields['id']),
	addslashes($this->CDRFields['id']),
	addslashes($sourceTable),
	addslashes($this->CDRFields['startTime']),
	addslashes($beginDate),
	addslashes($this->CDRFields['startTime']),
	addslashes($endDate)
	);

	dprint($query);

	if (!$this->CDRdb->query($query)) {
	printf("Error: %s", $this->CDRdb->Error);
	return 0;
	}

	$this->CDRdb->next_record();
	$min=$this->CDRdb->f('min');
	$max=$this->CDRdb->f('max');

	if (!$min \|\| !$max) {
	$log = sprintf("No CDRs found in %s between %s and %s\n", $sourceTable, $beginDate, $endDate);
	print $log;
	syslog(LOG_NOTICE, $log);
	return 0;
	}

	$deleted=0;
	$i=$min;
	$interval=100;

	$rows2delete=$max-$min;
	$found = 0;

	print "$rows2delete CDRs will be deleted between $min and $max, $interval at a time\n";

	while ($i <= $max) {
	$found=$found+$interval;

	if ($i + $interval < $max) {
	$top=$i;
	} else {
	$top=$max;
	}

	$query = sprintf(
	"delete low_priority from %s where %s <= '%d' and %s >= '%d'",
	addslashes($sourceTable),
	addslashes($this->CDRFields['id']),
	addslashes($top),
	addslashes($this->CDRFields['id']),
	addslashes($min)
	);


	if ($this->CDRdb->query($query)) {
	$deleted=$deleted+$this->CDRdb->affected_rows();
	} else {
	$log=sprintf("Error: %s (%s)",$this->CDRdb->Error,$this->CDRdb->Errno);
	syslog(LOG_NOTICE,$log);
	print $log;
	return 0;
	}

	if ($found > $progress*$rows2delete/100) {
	$progress++;
	if ($progress%10==0) {
	print "$progress% ";
	flush();
	}
	}

	print ".";
	flush();

	$i=$i+$interval;
	}

	print "\n";

	$end = time();
	$duration = $end-$begin;
	$rps=0;

	if ($deleted && $duration) $rps=$deleted/$duration;

	$log=sprintf("%s CDRs of month %s deleted from %s in %d s @ %.0f rps\n",$deleted,$month,$sourceTable,$duration,$rps);
	syslog(LOG_NOTICE,$log);
	print $log;
	return 1;
	}

	function cacheQuotaUsage($accounts = array())
	{
	if (!$this->quotaEnabled) return true;

	$saved_keys=0;
	$failed_keys=0;

	foreach (array_keys($accounts) as $_key) {

	$query=sprintf("select id from quota_usage where datasource = '%s' and account = '%s'",addslashes($this->cdr_source),addslashes($_key));

	if (!$this->cdrtool->query($query)){
	$log=sprintf ("Database error: %s (%s)",$this->cdrtool->Error,$this->cdrtool->Errno);
	syslog(LOG_NOTICE, $log);
	print($log);
	return false;
	}

	if ($this->cdrtool->num_rows()) {
	// sync with quota_usage table
	$query=sprintf("update quota_usage set
	calls = calls + %d,
	duration = duration + %d,
	cost = cost + '%s',
	cost_today = cost_today + '%s',
	traffic = traffic + '%s'
	where account = '%s'
	",
	addslashes($accounts[$_key]['usage']['calls']),
	addslashes($accounts[$_key]['usage']['duration']),
	addslashes($accounts[$_key]['usage']['cost']),
	addslashes($accounts[$_key]['usage']['cost_today']),
	addslashes($accounts[$_key]['usage']['traffic']),
	addslashes($_key)
	);

	if (!$this->cdrtool->query($query)){
	$log=sprintf ("Database error: %s (%s)",$this->cdrtool->Error,$this->cdrtool->Errno);
	syslog(LOG_NOTICE, $log);
	$failed_keys++;
	} else {
	$saved_keys++;
	}
	} else {
	$quota=$this->getQuota($_key);
	$blocked=$this->getBlockedByQuotaStatus($_key);

	list($_u,$_d)=explode("@",$_key);

	$query=sprintf("insert into quota_usage
	(datasource,account,domain,quota,calls,duration,cost,cost_today,traffic,blocked,reseller_id)
	values
	('%s','%s','%s',%d,%d,'%s','%s','%s','%s','%s',%d)
	",
	addslashes($this->cdr_source),
	addslashes($_key),
	addslashes($_d),
	addslashes($quota),
	addslashes($accounts[$_key]['usage']['calls']),
	addslashes($accounts[$_key]['usage']['duration']),
	addslashes($accounts[$_key]['usage']['cost']),
	addslashes($accounts[$_key]['usage']['cost_today']),
	addslashes($accounts[$_key]['usage']['traffic']),
	intval($blocked),
	addslashes($this->localDomains[$_d]['reseller'])
	);

	if (!$this->cdrtool->query($query)){
	$log=sprintf ("Database error: %s (%s)",$this->cdrtool->Error,$this->cdrtool->Errno);
	syslog(LOG_NOTICE, $log);
	$failed_keys++;
	} else {
	$saved_keys++;
	}
	}
	}

	$this->status['cached_keys']['saved_keys'] = $this->status['cached_keys']['saved_keys'] + $saved_keys;
	$this->status['cached_keys']['failed_keys'] = $this->status['cached_keys']['failed_keys'] + $failed_keys;

	return 1;
	}

	function getNormalizeLock($lockname='') {

	if (!$locker = new DB_Locker()) {
	$log=sprintf("Error: cannot init locker database. ");
	print $log;
	syslog(LOG_NOTICE, $log);
	return 0;
	}

	if (!$lockname) {
	$log=sprintf("Error: no lockname provided. ");
	print $log;
	syslog(LOG_NOTICE, $log);
	return 0;
	}

	unset($this->lock_connection_id);

	register_shutdown_function("unLockNormalization",$locker,$lockname);

	$query=sprintf("SELECT GET_LOCK('%s',0)",addslashes($lockname));

	if ($locker->query($query)) {
	$locker->next_record();
	$return = $locker->Record["GET_LOCK('$lockname',0)"];

	$query=sprintf("SELECT IS_USED_LOCK('%s')",addslashes($lockname));
	if ($locker->query($query)) {
	$locker->next_record();
	$this->lock_connection_id=$locker->Record["IS_USED_LOCK('$lockname')"];
	}

	if ($return == 0) {
	$log=sprintf("Lock %s already aquired by another process with id %s ",$lockname,$this->lock_connection_id);
	syslog(LOG_NOTICE, $log);
	print "$log\n";
	return 0;
	} else {
	$log=sprintf("Normalize lock id %s aquired for %s ",$this->lock_connection_id,$lockname);
	syslog(LOG_NOTICE, $log);
	//print "$log\n";
	return 1;
	}
	} else {
	$log = sprintf("Database error: failed to request mysql lock %s (%s)\n", $locker->Error, $locker->Errno);
	print $log;
	syslog(LOG_NOTICE, $log);
	return 0;
	}
	}

	function getQuota($account)
	{
	}

	function getBlockedByQuotaStatus($account)
	{
	}

	function resetQuota($accounts = array())
	{

	if (!$this->quotaEnabled) return true;

	$_reset_array = array_unique($accounts);

	foreach ($_reset_array as $_el) {
	if (strlen($_el)) $_accounts[]=$_el;
	}

	$_reset_array = $_accounts;

	$log=sprintf("Next quota check will rebuild the counters for %s accounts",count($_reset_array));
	syslog(LOG_NOTICE,$log );

	$query=sprintf("delete from memcache where `key` in ('%s','%s')",addslashes($this->quota_init_flag),addslashes($this->quota_reset_flag));
	if (!$this->cdrtool->query($query)) {
	$log=sprintf ("Database error for query %s: %s (%s)",$query,$this->cdrtool->Error,$this->cdrtool->Errno);
	print $log;
	syslog(LOG_NOTICE, $log);
	return false;
	}

	$query=sprintf("insert into memcache (`key`,`value`) values ('%s','%s')",addslashes($this->quota_reset_flag),addslashes(json_encode($_reset_array)));
	if (!$this->cdrtool->query($query)) {
	$log=sprintf ("Database error for query %s: %s (%s)",$query,$this->cdrtool->Error,$this->cdrtool->Errno);
	print $log;
	syslog(LOG_NOTICE, $log);
	return false;
	}

	$query="delete from quota_usage where account in (";
	$t=0;
	foreach ($_reset_array as $_el) {
	if ($t) $query.=",";
	$query.= sprintf("'%s'",addslashes($_el));
	$t++;
	}

	$query.=")";

	if (!$this->cdrtool->query($query)) {
	$log=sprintf ("Database error: %s (%s)",$this->cdrtool->Error,$this->cdrtool->Errno);
	syslog(LOG_NOTICE,$log);
	print $log;
	return 0;
	} else {
	return 1;
	}
	}
	}

	class CDRS_unknown extends CDRS
	{
	function searchForm()
	{
	return;
	}
	}

	class E164
	{
	// Class that helps normalization of a telephone number in E164 format

	// Based on this normalization, CDRTool rating engine decides whether
	// to consider the session a PSTN destination and rate it according
	// to the PSTN rating plan

	function E164($intAccessCode='00', $natAccessCode='0',$CountryCode='',$ENUMtldRegexp="") {
	$this->regexp_international = "/^".$intAccessCode."([0-9]{5,})\$/";
	$this->regexp_national = "/^".$natAccessCode."([0-9]{3,})\$/";
	$this->CountryCode = trim($CountryCode);
	$this->ENUMtldRegexp = trim($ENUMtldRegexp);
	}

	function E164Format($Number)
	{
	//dprint "E164Format($Number,ENUMtldRegexp=$this->ENUMtldRegexp)";
	// This function returns the full E164 format for a PSTN number without leading zero or +
	// E164 = Country Code + Network Code + Subscriber Number
	// Example: 31208015100 is an E164 number from Holland (country code 31)

	// If nothing is returned by this function the session is considered an Internet destination

	if (preg_match($this->regexp_international,$Number,$m)) {
	return $m[1];
	- } else if (preg_match($this->regexp_national,$Number,$m)) {
	+ } elseif (preg_match($this->regexp_national,$Number,$m)) {
	// Add default country code
	return $this->CountryCode.$m[1];
	- } else if (strlen($this->ENUMtldRegexp)) {
	+ } elseif (strlen($this->ENUMtldRegexp)) {
	$_regexp="/^".$this->ENUMtldRegexp."\$/";
	if (preg_match($_regexp,$Number,$m)) {
	return $m[1];
	}
	}
	return false;
	}
	}

	class E164_Europe extends E164 {
	function E164_Europe ($intAccessCode='00', $natAccessCode='0',$CountryCode='',$ENUMtldRegexp="([1-9][0-9]{7,})") {
	$this->regexp_international = "/^".$intAccessCode."([1-9][0-9]{5,})\$/";
	$this->regexp_national = "/^".$natAccessCode."([1-9][0-9]{3,})\$/";
	$this->CountryCode = trim($CountryCode);
	$this->ENUMtldRegexp = trim($ENUMtldRegexp);
	}
	}

	class E164_US extends E164 {
	function E164_US($intAccessCode='011', $natAccessCode='[1-9][0-9]{2}',$CountryCode='',$ENUMtldRegexp="([1-9][0-9]{7,})") {
	$this->regexp_international = "/^".$intAccessCode."([1-9][0-9]{5,})\$/";
	$this->regexp_national = "/^".$natAccessCode."([0-9]{3,})\$/";
	$this->CountryCode = trim($CountryCode);
	$this->ENUMtldRegexp = trim($ENUMtldRegexp);
	}
	}

	class CDR
	{
	// we need two db descriptors to update a CDR
	// within same result set
	var $idField = "RadAcctId";
	var $callIdField = "AcctSessionId";
	var $usernameField = "UserName";
	var $domainField = "Realm";
	var $gatewayField = "NASIPAddress";
	var $gatewayPortField = "CiscoNASPort";
	var $timestampField = "timestamp";
	var $portIdField = "NASPortId";
	var $portTypeField = "NASPortType";
	var $startTimeField = "AcctStartTime";
	var $stopTimeField = "AcctStopTime";
	var $durationField = "AcctSessionTime";
	var $inputTrafficField = "AcctInputOctets";
	var $outputTrafficField = "AcctOutputOctets";
	var $serviceTypeField = "ServiceType";
	var $cNumberField = "CalledStationId";
	var $aNumberField = "CallingStationId";
	var $disconnectField = "H323DisconnectCause";
	var $traceIn = "";
	var $traceOut = "";
	var $defaultApplicationType = "audio";
	var $supportedApplicationTypes = array(
	'audio',
	'message',
	'video',
	'chat',
	'file-transfer'
	);

	- function CDR() {
	+ public function __construct()
	+ {
	}

	- function NormalizeDisconnect() {
	+ function NormalizeDisconnect()
	+ {
	$causePrint=$this->CDRS->disconnectCodesDescription[$this->disconnect]." (".$this->disconnect.")";
	return $causePrint;
	}

	- function traceOut () {
	+ function traceOut()
	+ {
	}

	- function traceIn () {
	+ function traceIn()
	+ {
	}

	- function show() {
	+ function show()
	+ {
	}

	- function normalize($save="",$table="") {
	+ function normalize($save = "", $table = "")
	+ {
	if (!$table) $table = $this->CDRS->table;

	if ($this->CDRS->CSCODE && $CarrierInfo = $this->CDRS->CDRTool['normalize']['CS_CODES'][$this->CDRS->CSCODE]) {
	// We found a carrier so we set the BillingId
	$this->BillingId = $CarrierInfo[BillingPartyId];
	}

	if ($save) {
	-
	if (!$this->id) {
	return 0;
	}

	$query ="";
	$query1 ="";
	$query2 ="";

	if ($this->CDRS->normalizedField) {
	if ($updatedFields) $query .= ", ";
	$updatedFields++;
	$query.=sprintf(" %s='1' ",addslashes($this->CDRS->normalizedField));
	}

	if ($this->CDRS->BillingPartyIdField && $this->BillingPartyId) {
	if ($updatedFields) $query .= ", ";
	$updatedFields++;
	$query.=sprintf(" %s = '%s' ",addslashes($this->CDRS->BillingPartyIdField),addslashes($this->BillingPartyId));
	}

	if (strlen($this->durationNormalized) && $this->durationNormalized != $this->duration) {
	if ($updatedFields) $query .= ", ";
	$updatedFields++;
	$query.=sprintf(" %s ='%s' ",addslashes($this->CDRS->durationField),addslashes($this->durationNormalized));
	$this->duration=$this->durationNormalized;
	}

	if ($this->CDRS->DestinationIdField) {
	if ($updatedFields) $query .= ", ";
	$updatedFields++;
	$query.=sprintf(" %s = '%s' ",addslashes($this->CDRS->DestinationIdField),addslashes($this->DestinationId));
	}

	if ($this->CDRS->ResellerIdField) {
	if ($updatedFields) $query .= ", ";
	$updatedFields++;
	$query.=sprintf(" %s = '%s' ",addslashes($this->CDRS->ResellerIdField),addslashes($this->ResellerId));
	}

	if ($this->usernameNormalized && $this->usernameNormalized!=$this->username) {
	if ($updatedFields) $query .= ", ";
	$updatedFields++;
	$query.=sprintf(" %s = '%s' ",addslashes($this->CDRS->usernameField),addslashes($this->usernameNormalized));
	}

	if ($this->aNumberNormalized && $this->aNumberNormalized!=$this->aNumber) {
	if ($updatedFields) $query .= ", ";
	$updatedFields++;
	$query.=sprintf(" %s = '%s' ",addslashes($this->CDRS->aNumberField),addslashes($this->aNumberNormalized));
	$this->aNumber=$this->aNumberNormalized;
	}

	if ($this->CDRS->applicationField && $this->applicationNormalized) {
	if ($updatedFields) $query .= ", ";
	$updatedFields++;
	$query.=sprintf(" %s = '%s' ",addslashes($this->CDRS->applicationField), addslashes($this->applicationNormalized));
	$this->application=$this->applicationNormalized;
	}

	if ($this->CDRS->flowField && $this->flow) {
	if ($updatedFields) $query .= ", ";
	$updatedFields++;
	$query.=sprintf(" %s = '%s' ",addslashes($this->CDRS->flowField),addslashes($this->flow));
	}

	if ($this->domainNormalized && $this->domainNormalized != $this->domain) {
	if ($updatedFields) $query .= ", ";
	$updatedFields++;
	$query.=sprintf(" %s = '%s' ",addslashes($this->CDRS->domainField),addslashes($this->domainNormalized));
	$this->domainNumber=$this->domainNormalized;
	$this->domain=$this->domainNormalized;
	}

	if ($this->cNumberNormalized && $this->cNumberNormalized!=$this->cNumber) {
	if ($updatedFields) $query .= ", ";
	$updatedFields++;
	$query.=sprintf(" %s = '%s' ",addslashes($this->CDRS->cNumberField),addslashes($this->cNumberNormalized));
	$this->cNumber=$this->cNumberNormalized;
	}

	if ($this->CDRS->BillingIdField && $this->BillingId) {
	if ($updatedFields) $query .= ", ";
	$updatedFields++;
	$query.=sprintf(" %s = '%s' ",addslashes($this->CDRS->BillingIdField),addslashes($this->BillingId));
	}

	if ($this->CDRS->RemoteAddressField && $this->RemoteAddressNormalized && $this->RemoteAddressNormalized!= $this->RemoteAddress) {
	if ($updatedFields) $query .= ", ";
	$updatedFields++;
	$query.=sprintf(" %s = '%s' ",addslashes($this->CDRS->RemoteAddressField),addslashes($this->RemoteAddressNormalized));
	}

	if ($this->CDRS->CanonicalURIField && $this->CanonicalURINormalized && $this->CanonicalURINormalized!= $this->CanonicalURI) {
	if ($updatedFields) $query .= ", ";
	$updatedFields++;
	$query.=sprintf(" %s = '%s' ",addslashes($this->CDRS->CanonicalURIField),addslashes($this->CanonicalURINormalized));
	}

	if ($this->stopTimeNormalized) {
	if ($updatedFields) $query .= ", ";
	$updatedFields++;
	$query.=sprintf(" %s = '%s' ",addslashes($this->CDRS->stopTimeField),addslashes($this->stopTimeNormalized));
	}

	if ($this->CDRS->ratingEnabled && ($this->duration \|\| $this->application == 'message')) {
	if ($this->DestinationId) {
	$Rate = new Rate($this->CDRS->rating_settings, $this->CDRS->cdrtool);

	if ($this->application == 'message') {
	$RateDictionary = array(
	'callId' => $this->callId,
	'timestamp' => $this->timestamp,
	'duration' => $this->duration,
	'DestinationId' => $this->DestinationId,
	'BillingPartyId' => $this->BillingPartyId,
	'ResellerId' => $this->ResellerId,
	'domain' => $this->domain,
	'gateway' => $this->gateway,
	'RatingTables' => $this->CDRS->RatingTables,
	'aNumber' => $this->aNumber,
	'cNumber' => $this->cNumber
	);

	$Rate->calculateMessage($RateDictionary);
	} else {
	$RateDictionary = array(
	'callId' => $this->callId,
	'timestamp' => $this->timestamp,
	'duration' => $this->duration,
	'DestinationId' => $this->DestinationId,
	'inputTraffic' => $this->inputTraffic,
	'outputTraffic' => $this->outputTraffic,
	'BillingPartyId' => $this->BillingPartyId,
	'ResellerId' => $this->ResellerId,
	'domain' => $this->domain,
	'gateway' => $this->gateway,
	'RatingTables' => $this->CDRS->RatingTables,
	'aNumber' => $this->aNumber,
	'cNumber' => $this->cNumber,
	'ENUMtld' => $this->ENUMtld,
	'application' => $this->application
	);

	$Rate->calculateAudio($RateDictionary);
	}

	$this->pricePrint = $Rate->pricePrint;
	$this->price = $Rate->price;
	$this->rateInfo = $Rate->rateInfo;
	$this->rateDuration = $Rate->duration;

	if ($Rate->broken_rate) {
	$this->broken_rate = true;
	}
	} else {
	$this->rateInfo = '';
	$this->pricePrint = '';
	$this->price = '';
	}

	// strict mysql query fails when price is being set to ''
	if ($this->pricePrint === null \|\| $this->pricePrint === '') {
	$this->pricePrint = '0.00';
	}

	if ($this->CDRS->priceField) {
	if ($updatedFields) $query .= ", ";
	$updatedFields++;
	$query .= sprintf(
	" %s = '%s' ",
	addslashes($this->CDRS->priceField),
	addslashes($this->pricePrint)
	);

	if ($this->CDRS->rateField ) {
	if ($updatedFields) $query .= ", ";
	$updatedFields++;
	$query.=sprintf(" %s = '%s' ",addslashes($this->CDRS->rateField),addslashes($this->rateInfo));
	}
	}
	}

	$query1 = sprintf(
	"update %s set %s where %s = '%s'",
	addslashes($table),
	$query,
	addslashes($this->idField),
	addslashes($this->id));
	dprint_sql($query1);

	if ($updatedFields) {
	if ($this->CDRS->CDRdb1->query($query1)) {
	if ($this->CDRS->CDRdb1->affected_rows()) {
	if ( $this->isBillingPartyLocal() && $table == "radacct".date('Ym')) {
	// cache usage only if current month

	$_traffic = ($this->inputTraffic + $this->outputTraffic) / 2;
	$_usage = array(
	'calls' => 1,
	'duration' => $this->duration,
	'cost' => $this->price,
	'cost_today' => $this->price,
	'traffic' => $_traffic
	);

	$this->cacheQuotaUsage($_usage);
	}
	} else {
	if (preg_match("/^(\w+)(\d{4})(\d{2})$/", $table, $m)) {
	$previousTable=$m[1].date('Ym', mktime(0, 0, 0, $m[3]-1, "01", $m[2]));
	$query2 = sprintf("update %s set %s where %s = '%s'",addslashes($previousTable),$query,addslashes($this->idField),addslashes($this->id));

	if ($this->CDRS->CDRdb1->query($query2)) {
	if ($this->CDRS->CDRdb1->affected_rows()) {
	if ($this->isBillingPartyLocal() && $previousTable == "radacct".date('Ym')) {
	// cache usage only if current month

	$_traffic = ($this->inputTraffic + $this->outputTraffic) / 2;
	$_usage = array(
	'calls' => 1,
	'duration' => $this->duration,
	'cost' => $this->price,
	'cost_today' => $this->price,
	'traffic' => $_traffic
	);
	$this->cacheQuotaUsage($_usage);
	}
	}
	} else {
	$log = sprintf(
	"Database error: %s (%s)",
	$this->CDRS->CDRdb1->Error,
	$this->CDRS->CDRdb1->Errno
	);
	syslog(LOG_NOTICE, $log);
	print($log);
	return 0;
	}
	}
	}

	return 1;
	} else {
	$log = sprintf(
	"Database error for query %s: %s (%s)",
	$query1,
	$this->CDRS->CDRdb1->Error,
	$this->CDRS->CDRdb1->Errno
	);
	syslog(LOG_NOTICE, $log);
	print($log);
	return 0;
	}
	}
	} else {
	if ($this->CDRS->BillingPartyIdField && $CarrierInfo['BillingPartyId']) {
	$this->domain = $CarrierInfo['BillingDomain'];
	}

	if ($this->usernameNormalized && $this->usernameNormalized!=$this->username) {
	$this->username = $this->usernameNormalized;
	}

	if ($this->aNumberNormalized && $this->aNumberNormalized!=$this->aNumber) {
	$this->aNumber = $this->aNumberNormalized;
	}

	if ($this->domainNormalized && $this->domainNormalized != $this->domain) {
	$this->domainNumber = $this->domainNormalized;
	}

	if ($this->cNumberNormalized && $this->cNumberNormalized!=$this->cNumber) {
	$this->cNumber = $this->cNumberNormalized;
	}

	if ($this->CDRS->RemoteAddressField && $this->RemoteAddressNormalized && $this->RemoteAddressNormalized!= $this->RemoteAddress) {
	$this->RemoteAddress = $this->RemoteAddressNormalized;
	}
	}
	return 1;
	}

	function cacheQuotaUsage($usage)
	{

	if (!is_array($usage)) return ;

	$accounts[$this->BillingPartyId]['usage'] = $usage;
	$this->CDRS->cacheQuotaUsage($accounts);
	}

	function isCallerLocal()
	{
	return false;
	}

	function isCalleeLocal()
	{
	return false;
	}

	function isBillingPartyLocal()
	{
	return false;
	}

	function obfuscateCallerId()
	{
	global $obfuscateCallerId;
	if ($obfuscateCallerId) {
	}
	}

	function lookupRateFromNetwork($RateDictionary, $fp)
	{
	$this->rateInfo='';
	$this->pricePrint='';
	$this->price='';

	$countEndofLines=0;
	$cmd="ShowPrice";
	foreach (array_keys($RateDictionary) as $key) {
	$cmd .=" ".$key."=".$RateDictionary[$key]." ";
	}

	$this->price = 0;
	$this->pricePrint = "";
	$this->rateInfo = "";

	if (fputs($fp,"$cmd\n") !== false) {
	$i=0;
	while ($i < 100) {
	$i++;

	$line = fgets($fp,1024);

	if (!$line) {
	syslog(LOG_NOTICE, "Error: lookupRateFromNetwork(): connection to network socket died");
	break;
	}

	if (preg_match("/^\n/",$line) \|\| preg_match("/^END/",$line)) {
	break;
	}

	if ($i == 1) {
	$this->price = trim($line);
	$this->pricePrint = number_format($this->price, 4);
	continue;
	}

	$this->rateInfo.=$line;
	}
	}
	}

	function lookupGeoLocation($ip)
	{
	if ($_loc=geoip_record_by_name($ip)) {
	return $_loc['country_name'].'/'.$_loc['city'];
	- } else if ($_loc=geoip_country_name_by_name($ip)) {
	+ } elseif ($_loc=geoip_country_name_by_name($ip)) {
	return $_loc;
	} else {
	return '';
	}
	}
	}

	-function getLocalTime($timezone,$timestamp) {
	+function getLocalTime($timezone,$timestamp)
	+{
	global $CDRTool;

	if (!$timezone \|\| $timezone == $CDRTool['provider']['timezone']) {
	return date("Y-m-d H:i:s", $timestamp);
	}

	putenv("TZ=$timezone");
	$startTimeLocal=date("Y-m-d H:i:s", $timestamp);
	$timezone=$CDRTool['provider']['timezone'];
	putenv("TZ=$timezone");
	return $startTimeLocal;
	}

	-function validDay($month,$day,$year) {
	+function validDay($month, $day, $year)
	+{
	if (!$month \|\| !$year) {
	return $day;
	}
	while (1) {
	- if (!checkdate($month,$day,$year) && $day) {
	+ if (!checkdate($month, $day, $year) && $day) {
	$day--;
	- next;
	} else {
	break;
	}
	}
	return $day;
	}

	// include CDRTool modules defined in global.inc
	if (is_array($CDRToolModules)) {
	foreach ($CDRToolModules as $module) {
	$module_filename="cdr_".$module.".php";
	include($module_filename);
	}
	}

	-function unLockNormalization ($dbid,$lockname) {
	- $query=sprintf("SELECT RELEASE_LOCK('%s')",addslashes($lockname));
	- $log=sprintf("Unlock %s",$lockname);
	+function unLockNormalization($dbid, $lockname)
	+{
	+ $query=sprintf("SELECT RELEASE_LOCK('%s')", addslashes($lockname));
	+ $log=sprintf("Unlock %s", $lockname);
	syslog(LOG_NOTICE, $log);

	if (!$dbid->query($query)) {
	$log="Error in unLockNormalization()";
	syslog(LOG_NOTICE, $log);
	}
	}

	-class SIPonline {
	-
	- function SIPonline ($datasource='',$database='db',$table='location') {
	+class SIPonline
	+{
	+ function __construct($datasource='',$database='db',$table='location')
	+ {
	global $CDRTool;

	$expandAll = $_REQUEST['expandAll'];
	$domain = $_REQUEST['domain'];

	$this->expandAll = $expandAll;
	$this->domain = $domain;
	$this->datasource = $datasource;

	if (strlen($CDRTool['filter']['domain'])) {
	$this->allowedDomains=explode(" ",$CDRTool['filter']['domain']);
	$allowed_domains_sql="";
	$j=0;
	foreach ($this->allowedDomains as $_domain) {
	if ($j>0) $allowed_domains_sql.=",";
	$allowed_domains_sql.="'".addslashes($_domain)."'";
	$j++;
	}
	}

	$this->locationDB = new $database;
	$this->locationTable = $table;

	$this->Registered=array();
	$this->countUA=array();

	$where = " where (1=1) " ;

	if ($allowed_domains_sql) {
	$where.= sprintf("and domain in (%s)",addslashes($allowed_domains_sql)) ;
	}

	$query=sprintf("select count(*) as c, domain from %s %s group by domain order by domain ASC",
	addslashes($this->locationTable),
	$where
	);

	$this->locationDB->query($query);
	$this->domains=$this->locationDB->num_rows();
	while ($this->locationDB->next_record()) {
	$this->Registered[$this->locationDB->f('domain')]=$this->locationDB->f('c');
	$this->total=$this->total+$this->locationDB->f('c');
	}

	$query=sprintf("select count(*) as c, user_agent from %s %s",addslashes($this->locationTable),$where);
	if ($this->domain) {
	$query.=sprintf(" and domain = '%s' ",addslashes($this->domain));
	}

	$query.="
	group by user_agent
	order by c DESC";

	$this->locationDB->query($query);
	while ($this->locationDB->next_record()) {
	$this->countUA[$this->locationDB->f('user_agent')]=$this->locationDB->f('c');
	}
	}

	- function showHeader() {
	+ function showHeader()
	+ {
	print "<table id='opensips_registrar' class='table table-striped table-condensed'>";
	print "<thead><tr>
	";

	if ($this->domain) {
	print "
	<th></th>
	<th width=120 align=right>User@Domain</th>
	<th></th>
	<th>SIP UA contact</th>
	<th>NAT address</th>
	<th>User Agent</th>
	<th>Expires</th>
	<th>Remain</th>
	";
	} else {
	print "
	<th></td>
	<th align=right>Users@</th>
	<th>Domain</th>
	";
	}
	print "
	</tr></thead>
	";
	}

	- function showFooter() {
	+ function showFooter()
	+ {
	print "
	<tr>
	<th></th>
	<th align=right>$this->total users@</td>
	<th align=left>$this->domains domains</td>
	</tr>
	</table>
	";
	}

	- function showAll() {
	+ function showAll()
	+ {
	global $found;

	$this->showHeader();
	foreach (array_keys($this->Registered) as $ld) {

	$onlines=$this->Registered[$ld];

	if ($this->expandAll \|\| ($this->domain && $this->domain==$ld)) {
	$this->show($ld);
	} else {
	$found++;

	$url = sprintf("%s?datasource=%s&domain=%s",
	$_SERVER['PHP_SELF'],
	urlencode($this->datasource),
	urlencode($ld)
	);

	print "
	<tr>
	<td valign=top align=right>$found</td>
	<td valign=top align=right>$onlines users@</td>
	<td valign=top><a href=$url>$ld</a></td>
	";

	if ($this->domain) {
	print "
	<td></td>
	<td></td>
	<td></td>
	<td></td>
	";
	}
	print "
	</tr>
	";
	}
	}

	$this->showfooter();
	/*
	print "<p>";
	$this->showUAdistribution();
	*/

	}

	- function show() {
	+ function show()
	+ {
	global $found;

	$query="SELECT *, SEC_TO_TIME(UNIX_TIMESTAMP(expires)-UNIX_TIMESTAMP(NOW())) AS remain
	FROM location
	";
	if ($this->domain) $query.=sprintf(" where domain = '%s'", addslashes($this->domain));

	$query.= " ORDER BY domain ASC, username ASC ";

	$this->locationDB->query($query);

	while ($this->locationDB->next_record()) {

	$found++;

	$username = $this->locationDB->f('username');
	$domain = $this->locationDB->f('domain');
	$contact = $this->locationDB->f('contact');
	$received = $this->locationDB->f('received');
	$user_agent = $this->locationDB->f('user_agent');
	$expires = $this->locationDB->f('expires');
	$remain = $this->locationDB->f('remain');

	$contact_print=substr($contact,4);

	$c_els=explode(";", $contact);
	$r_els=explode(";", $received);

	$transport="UDP";

	if ($c_els[1] && preg_match("/transport=(tcp\|tls)/i",$c_els[1],$m)) {
	$transport=strtoupper($m[1]);
	}

	$sip_account=$username."@".$domain;

	print "
	<tr>
	<td valign=top align=right>$found</td>
	<td valign=top>$sip_account</td>
	<td valign=top>$transport</td>
	<td valign=top align=right>$c_els[0]</td>
	<td valign=top align=right>$r_els[0]</td>
	<td valign=top>$user_agent</td>
	<td valign=top>$expires</td>
	<td valign=top align=right>$remain</td>
	</tr>
	";

	$seen[$username]++;
	$seen[$domain]++;

	}
	}

	- function showUAdistribution () {
	+ function showUAdistribution()
	+ {
	print "<table border=0 cellspacing=1 class=border>";
	print "<tr bgcolor=lightgrey> ";
	print "<td></td>";
	print "<th>User agent</th>";
	print "<th>Users</th>";
	print "</tr> ";

	foreach ($this->countUA as $k => $v) {
	$users=$users+$v;
	$count++;
	print "<tr> ";
	print "<td>$count</td>";
	print "<td>$k</td>";
	print "<td>$v</td>";
	print "</tr>";
	}

	print "<tr bgcolor=lightgrey> ";
	print "<td></td>";
	print "<td><b>$this->domain</b></td>";
	print "<td><b>$users</b></td>";
	print "</tr> ";

	print "</table>";

	}
	}

	-class PrepaidHistory {
	- function PrepaidHistory() {
	+class PrepaidHistory
	+{
	+ public function __construct()
	+ {
	$this->db = new DB_cdrtool;
	}

	- function purge($days=7) {
	+ function purge($days = 7)
	+ {
	$beforeDate=Date("Y-m-d", time()-$days360024);
	$query=sprintf("delete from prepaid_history where date < '%s' and action like 'Debit balance%s'",addslashes($beforeDate),'%');

	if (!$this->db->query($query)) {
	$log=sprintf ("Database error for query %s: %s (%s)\n",$query,$this->db->Error,$this->db->Errno);
	print $log;
	syslog(LOG_NOTICE,$log);
	} else {
	$log=sprintf ("Purged %d records from prepaid history before %s\n",$this->db->affected_rows(),$beforeDate);
	print $log;
	syslog(LOG_NOTICE,$log);
	}
	}
	}

	-class CSVWritter {
	+class CSVWritter
	+{
	var $csv_directory = '/var/spool/cdrtool/normalize';
	var $filename_extension = '.csv';
	var $fields = array();
	var $ready = false;
	var $cdr_type = array();
	var $lines = 0;

	- function CSVWritter($cdr_source='',$csv_directory='') {
	+ public function __construct($cdr_source = '',$csv_directory = '') {
	if ($cdr_source) {
	$this->cdr_source = $cdr_source;
	} else {
	$this->cdr_source = 'unknown';
	}

	if ($csv_directory) {
	if (is_dir($csv_directory)) {
	$this->csv_directory = $csv_directory;
	} else {
	$log=sprintf ("CSV writter error: %s is not a directory\n",$csv_directory);
	syslog(LOG_NOTICE,$log);
	return false;
	}
	}

	$this->directory=$this->csv_directory."/".date("Ymd");

	if (!is_dir($this->directory)) {
	if (!mkdir($this->directory)) {
	$log=sprintf ("CSV writter error: cannot create directory %s\n",$this->directory);
	syslog(LOG_NOTICE,$log);
	return false;
	}
	chmod($this->directory, 0775);
	}

	$this->directory_ready = true;
	}

	- function open_file ($filename_suffix='') {
	+ function open_file ($filename_suffix = '')
	+ {
	if ($this->ready) return true;

	if (!$this->directory_ready) return false;

	if (!$filename_suffix) {
	$log=sprintf ("CSV writter error: no filename suffix provided\n");
	syslog(LOG_NOTICE,$log);
	return false;
	}

	$this->filename_prefix = strtolower($this->cdr_source).'-'.date('YmdHi');

	$this->full_path=rtrim($this->directory,'/').'/'.$this->filename_prefix.'-'.$filename_suffix.$this->filename_extension;

	$this->full_path_tmp=$this->full_path.'.tmp';

	if (!$this->fp = fopen($this->full_path_tmp, 'w')) {
	$log=sprintf ("CSV writter error: cannot open %s for writing\n",$this->full_path_tmp);
	syslog(LOG_NOTICE,$log);
	return false;
	}

	$this->ready = true;
	return true;
	}

	- function close_file () {
	+ function close_file()
	+ {
	if (!$this->ready) return false;

	fclose($this->fp);

	if (!rename($this->full_path_tmp, $this->full_path)) {
	$log=sprintf ("CSV writter error: cannot rename %s to %s\n",$this->full_path_tmp,$this->full_path);
	syslog(LOG_NOTICE,$log);
	} else {
	$log=sprintf ("%d normalized CDRs written to %s\n",$this->lines, $this->full_path);
	syslog(LOG_NOTICE,$log);
	}
	}

	- function write_cdr ($CDR) {
	+ function write_cdr($CDR)
	+ {
	if (!$this->ready) return false;

	- $line = sprintf("%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s\n",
	- $CDR->id,
	- $CDR->callId,
	- $CDR->flow,
	- $CDR->application,
	- $CDR->username,
	- $CDR->CanonicalURI,
	- $CDR->startTime,
	- $CDR->stopTime,
	- $CDR->duration,
	- $CDR->DestinationId,
	- $CDR->BillingPartyId,
	- $CDR->ResellerId,
	- $CDR->price
	- );
	+ $line = sprintf(
	+ "%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s\n",
	+ $CDR->id,
	+ $CDR->callId,
	+ $CDR->flow,
	+ $CDR->application,
	+ $CDR->username,
	+ $CDR->CanonicalURI,
	+ $CDR->startTime,
	+ $CDR->stopTime,
	+ $CDR->duration,
	+ $CDR->DestinationId,
	+ $CDR->BillingPartyId,
	+ $CDR->ResellerId,
	+ $CDR->price
	+ );

	if (!fputs($this->fp,$line)) {
	$this->ready = false;
	return false;
	}

	$this->lines++;

	return true;
	}
	}

	-class MaxRate extends CSVWritter {
	+class MaxRate extends CSVWritter
	+{
	var $skip_prefixes = array();
	var $skip_numbers = array();
	var $skip_domains = array();
	var $rpid_cache = array();
	var $translate_uris = array();

	- function MaxRate ($cdr_source='', $csv_directory='', $db_subscribers='') {
	+ function __construct($cdr_source='', $csv_directory='', $db_subscribers='') {
	global $MaxRateSettings; // set in global.inc

	/*
	$MaxRateSettings= array(
	'translate_uris'=> array( '1233@10.0.0.2'=>'+1233',
	'[1-9][0-9]{4}.*@10.0.0.2'=>'+1233'),
	'skip_domains' => array('example.net','10.0.0.1'),
	'skip_numbers' => array('1233'), // skip CDRs that has the username part in this array
	'skip_prefixes' => array('0031901') // skip CDRs that begin with any of this prefixes
	);
	*/


	if (is_array($MaxRateSettings['skip_domains'])) {
	$this->skip_domains=$MaxRateSettings['skip_domains'];
	}

	if (is_array($MaxRateSettings['skip_numbers'])) {
	$this->skip_numbers=$MaxRateSettings['skip_numbers'];
	}

	if (is_array($MaxRateSettings['skip_prefixes'])) {
	$this->skip_prefixes=$MaxRateSettings['skip_prefixes'];
	}

	if (is_array($MaxRateSettings['translate_uris'])) {
	$this->translate_uris=$MaxRateSettings['translate_uris'];
	}

	$this->AccountsDB = new $db_subscribers();

	- $this->CSVWritter($cdr_source, $csv_directory);
	+ parent::__construct($cdr_source, $csv_directory);

	}

	- function write_cdr($CDR) {
	+ function write_cdr($CDR)
	+ {
	if (!$this->ready) return false;

	# skip if no audio
	if ($CDR->application != 'audio') return true;

	# skip if no duration
	if (!$CDR->duration && ($CDR->disconnect != 200)) return true;

	# normalize destination
	if ($CDR->CanonicalURIE164) {
	$cdr['destination'] = '+'.$CDR->CanonicalURIE164;
	} else {
	$cdr['destination'] = $CDR->CanonicalURI;
	}

	list($canonical_username, $canonical_domain)=explode("@",$cdr['destination']);

	# skip domains
	if ($canonical_domain && in_array($canonical_domain,$this->skip_domains)) return true;

	# skip numbers
	if ($canonical_username && in_array($canonical_username,$this->skip_numbers)) return true;

	# skip prefixes
	if ($canonical_username && count($this->skip_prefixes)) {
	foreach ($this->skip_prefixes as $prefix) {
	if (preg_match("/^$prefix/",$canonical_username)) return true;
	}
	}

	# get RPID if caller is local
	if ($CDR->flow != 'incoming') {
	$CallerRPID=$this->getRPIDforAccount($CDR->aNumberPrint);
	}


	if ($CallerRPID) {
	# normalize RPID
	$cdr['origin'] = '0031'.ltrim($CallerRPID,'0');
	} else {
	# normalize caller id numbers from PSTN gateway to 00format
	if (preg_match("/^\+?0([1-9][0-9]+)@(.*)$/",$CDR->aNumberPrint,$m)) {
	$cdr['origin'] = "0031".$m[1];
	- } else if (preg_match("/^\+?00([1-9][0-9]+)@(.*)$/",$CDR->aNumberPrint,$m)) {
	+ } elseif (preg_match("/^\+?00([1-9][0-9]+)@(.*)$/",$CDR->aNumberPrint,$m)) {
	$cdr['origin'] = "00".$m[1];
	- } else if (preg_match("/^([1-9][0-9]+)@(.*)$/",$CDR->aNumberPrint,$m)) {
	+ } elseif (preg_match("/^([1-9][0-9]+)@(.*)$/",$CDR->aNumberPrint,$m)) {
	$cdr['origin'] = "0031".$m[1];
	- } else if (preg_match("/^\+([1-9][0-9]+)@(.*)$/",$CDR->aNumberPrint,$m)) {
	+ } elseif (preg_match("/^\+([1-9][0-9]+)@(.*)$/",$CDR->aNumberPrint,$m)) {
	$cdr['origin'] = "00".$m[1];
	- } else if (preg_match("/^anonymous@(.*)$/",$CDR->aNumberPrint) && $CDR->SipRPID) {
	+ } elseif (preg_match("/^anonymous@(.*)$/",$CDR->aNumberPrint) && $CDR->SipRPID) {
	if (preg_match("/^\+?0([1-9][0-9]+)$/",$CDR->SipRPID,$m)) {
	$cdr['origin'] = "0031".$m[1];
	- } else if (preg_match("/^\+?00([1-9][0-9]+)$/",$CDR->SipRPID,$m)) {
	+ } elseif (preg_match("/^\+?00([1-9][0-9]+)$/",$CDR->SipRPID,$m)) {
	$cdr['origin'] = "00".$m[1];
	- } else if (preg_match("/^([1-9][0-9]+)@(.*)$/",$CDR->SipRPID,$m)) {
	+ } elseif (preg_match("/^([1-9][0-9]+)@(.*)$/",$CDR->SipRPID,$m)) {
	$cdr['origin'] = $m[1];
	- } else if (preg_match("/^\+([1-9][0-9]+)@(.*)$/",$CDR->SipRPID,$m)) {
	+ } elseif (preg_match("/^\+([1-9][0-9]+)@(.*)$/",$CDR->SipRPID,$m)) {
	$cdr['origin'] = "00".$m[1];
	- } else if (preg_match("/^\+?0[0-9]?+@?(.*)?$/",$CDR->SipRPID,$m)) {
	+ } elseif (preg_match("/^\+?0[0-9]?+@?(.*)?$/",$CDR->SipRPID,$m)) {
	$cdr['origin'] = "0031123456789";
	- } else if (preg_match("/^.[a-zA-Z].$/",$CDR->SipRPID,$m)) {
	+ } elseif (preg_match("/^.[a-zA-Z].$/",$CDR->SipRPID,$m)) {
	$cdr['origin'] = "0031123456789";
	- } else if (preg_match("/^ims.imscore.net.*$/",$CDR->SipRPID,$m)) {
	+ } elseif (preg_match("/^ims.imscore.net.*$/",$CDR->SipRPID,$m)) {
	$cdr['origin'] = "0031123456789";
	} else {
	$cdr['origin'] = $CDR->SipRPID;
	}
	} else {
	$cdr['origin'] = "0031123456789";
	//$cdr['origin'] = $CDR->aNumberPrint;
	}
	}

	# normalize short origins
	if (preg_match("/^\d{1,3}@.*$/",$cdr['origin'])) {
	$cdr['origin']='+31000000000';
	}

	# normalize anonymous origins
	if (preg_match("/^anonymous@.*$/",$cdr['origin'])) {
	$cdr['origin']='+31000000000';
	}

	#translate destination URIs to desired format
	if ($CDR->CanonicalURINormalized && count($this->translate_uris)) {
	foreach ($this->translate_uris as $key => $uri) {
	if ( preg_match("/^$key/", $CDR->CanonicalURINormalized)) {
	$cdr['destination']=$uri;
	break;
	}
	}
	}

	preg_match("/^(\d{4})-(\d{2})-(\d{2}) (\d{2}:\d{2}:\d{2})$/",$CDR->startTime,$m);

	$cdr['start_date'] = sprintf ("%s/%s/%s %s",$m[3],$m[2],$m[1],$m[4]);
	$cdr['diversion'] = '';
	preg_match("/^(\d{4})-(\d{2})-(\d{2}) (\d{2}:\d{2}:\d{2})$/",$CDR->stopTime,$m);
	$cdr['stop_date'] = sprintf ("%s/%s/%s %s",$m[3],$m[2],$m[1],$m[4]);

	$cdr['product'] = $this->product;

	# normalize duration based on billed duration
	if ($CDR->rateDuration) {
	$cdr['duration'] = $CDR->rateDuration;
	} else {
	$cdr['duration'] = $CDR->duration;
	}

	$rate_info = explode("\n", $CDR->rateInfo);

	for ($i = 0; $i < sizeof($rate_info); ++$i)
	{
	//dprint_r($rate_info[$i]);
	if (strpos($rate_info[$i], "ProfileId:") !== false)
	{
	$cdr['profile'] = ltrim(str_replace("ProfileId: ", '', $rate_info[$i]));
	}
	}

	//$cdr['extra']="$CDR->callId";

	list($cdr['username'],$cdr['domain'])= explode('@',$CDR->username);

	$cdr['charge_info'] = sprintf('"%s","%s","%s"',$CDR->price,$cdr['profile'],$CDR->destinationName);

	if ($CDR->flow == 'on-net') {

	# RFP 4.2.1

	$CalleeRPID=$this->getRPIDforAccount($CDR->CanonicalURI);

	if ($CalleeRPID) {
	$cdr['destination'] = '0031'.ltrim($CalleeRPID,'0');
	}

	$cdr['extra'] = $cdr['extra']."$CDR->flow";
	- } else if ($CDR->flow == 'outgoing') {
	+ } elseif ($CDR->flow == 'outgoing') {
	# RFP 4.2.2

	$cdr['extra'] = $cdr['extra']."$CDR->flow";
	-
	- } else if ($CDR->flow == 'incoming') {
	+ } elseif ($CDR->flow == 'incoming') {
	# RFP 4.2.3

	if ($this->inbound_trunks[$CDR->SourceIP]) {
	$inbound_trunk = $this->inbound_trunks[$CDR->SourceIP];
	} else {
	$inbound_trunk = 'unknown';
	}

	$cdr['username'] = $canonical_username;

	$CalleeRPID=$this->getRPIDforAccount($CDR->CanonicalURI);

	if ($CalleeRPID) {
	$cdr['destination'] = '0031'.ltrim($CalleeRPID,'0');
	}

	$cdr['extra'] = $cdr['extra']."$CDR->flow";
	-
	- } else if ($CDR->flow == 'diverted-on-net') {
	+ } elseif ($CDR->flow == 'diverted-on-net') {
	# RFP 4.2.4

	$CalleeRPID=$this->getRPIDforAccount($CDR->CanonicalURI);

	$DiverterRPID=$this->getRPIDforAccount($CDR->username);

	if ($DiverterRPID) {
	$diverter_origin = '0031'.ltrim($DiverterRPID,'0');
	} else {
	$diverter_origin = $CDR->username;
	}

	if ($CalleeRPID) {
	$cdr['c_num'] = '0031'.ltrim($CalleeRPID,'0');
	}

	# Set destination to B-Number
	$cdr['destination'] = $diverter_origin;

	$cdr['diversion'] = $cdr['c_num'];

	$cdr['extra'] = $cdr['extra']."incoming-diverted-on-net";
	-
	- } else if ($CDR->flow == 'diverted-off-net') {
	+ } elseif ($CDR->flow == 'diverted-off-net') {
	# RFP 4.2.5

	$DiverterRPID=$this->getRPIDforAccount($CDR->username);

	if ($DiverterRPID) {
	$diverter_origin = '0031'.ltrim($DiverterRPID,'0');
	} else {
	$diverter_origin = $CDR->username;
	}

	$cdr['c_num'] = $cdr['destination'];

	# Set destination to B-Number
	$cdr['destination']=$diverter_origin;
	$cdr['diversion'] = $cdr['c_num'];

	$cdr['extra'] = $cdr['extra']."incoming-diverted-off-net";
	-
	- } else if ($CDR->flow == 'on-net-diverted-on-net') {
	+ } elseif ($CDR->flow == 'on-net-diverted-on-net') {
	# RFP 4.2.6

	$DiverterRPID=$this->getRPIDforAccount($CDR->username);

	if ($DiverterRPID) {
	$diverter_origin = '0031'.ltrim($DiverterRPID,'0');
	} else {
	$diverter_origin = $CDR->username;
	}

	$CalleeRPID=$this->getRPIDforAccount($CDR->CanonicalURI);

	if ($CalleeRPID) {
	$cdr['c_num'] = '0031'.ltrim($CalleeRPID,'0');
	}

	# Set destination to B-Number
	$cdr['destination'] = $diverter_origin;
	$cdr['diversion'] = $cdr['c_num'];

	$cdr['extra'] = $cdr['extra']."$CDR->flow";
	-
	- } else if ($CDR->flow == 'on-net-diverted-off-net') {
	+ } elseif ($CDR->flow == 'on-net-diverted-off-net') {
	# RFP 4.2.7

	$DiverterRPID=$this->getRPIDforAccount($CDR->username);

	if ($DiverterRPID) {
	$diverter_origin = '0031'.ltrim($DiverterRPID,'0');
	} else {
	$diverter_origin = $CDR->username;
	}

	$cdr['c_num']= $cdr['destination'];

	# Set destination to B-Number
	$cdr['destination'] = $diverter_origin;

	$cdr['diversion'] = $cdr['c_num'];
	$cdr['extra'] = $cdr['extra']."$CDR->flow";
	}

	$cdr['username'] = preg_replace('/caiw0+\|test0+/', "", $cdr['username']);
	$cdr['origin'] = str_replace('+','00',$cdr['origin']);
	$cdr['destination'] = str_replace('+','00',$cdr['destination']);
	$cdr['diversion'] = str_replace('+','00',$cdr['diversion']);

	- $line = sprintf('"%s","%s","%s","%s","%s","%s","%s","%s","%s",%s'."\n",
	- $CDR->callId,
	- $cdr['origin'],
	- $cdr['username'],
	- $cdr['destination'],
	- $cdr['diversion'],
	- $cdr['start_date'],
	- $cdr['stop_date'],
	- $cdr['duration'],
	- $cdr['extra'],
	- $cdr['charge_info']
	- );
	+ $line = sprintf(
	+ '"%s","%s","%s","%s","%s","%s","%s","%s","%s",%s'."\n",
	+ $CDR->callId,
	+ $cdr['origin'],
	+ $cdr['username'],
	+ $cdr['destination'],
	+ $cdr['diversion'],
	+ $cdr['start_date'],
	+ $cdr['stop_date'],
	+ $cdr['duration'],
	+ $cdr['extra'],
	+ $cdr['charge_info']
	+ );

	if (!fputs($this->fp,$line)) {
	$log=sprintf ("CSV writter error: cannot append to file %s\n",$this->full_path_tmp);
	syslog(LOG_NOTICE,$log);

	$this->close_file();
	$this->ready = false;
	return false;
	}

	$this->lines++;

	return true;
	}

	- function getRPIDforAccount($account) {
	+ function getRPIDforAccount($account)
	+ {
	if (!$account) return false;

	if ($this->rpid_cache[$account]) {
	return $this->rpid_cache[$account];
	}

	- list($username,$domain) = explode('@',$account);
	+ list($username,$domain) = explode('@', $account);

	$query=sprintf("select * from sip_accounts where username = '%s' and domain = '%s'",addslashes($username),addslashes($domain));

	if (!$this->AccountsDB->query($query)) {
	$log=sprintf ("Database error for query %s: %s (%s)",$query,$this->AccountsDB->Error,$this->AccountsDB->Errno);
	syslog(LOG_NOTICE,$log);
	return false;
	}

	if ($this->AccountsDB->num_rows()) {
	$this->AccountsDB->next_record();
	$_profile=json_decode(trim($this->AccountsDB->f('profile')));
	$this->rpid_cache[$account]=$_profile->rpid;
	return $_profile->rpid;
	-
	} else {
	return false;
	}
	}
	}

	?>
	diff --git a/library/cdr_opensips.php b/library/cdr_opensips.php
	index a180c1a..2abd821 100644
	--- a/library/cdr_opensips.php
	+++ b/library/cdr_opensips.php
	@@ -1,5354 +1,5352 @@
	<?php
	class CDRS_opensips extends CDRS
	{
	public $table = "radacct";
	public $CDR_class = "CDR_opensips";
	public $subscriber_table = "subscriber";
	public $ENUMtld = '';
	public $maxCDRsNormalizeWeb = 500;
	public $sipTrace = 'sip_trace';
	public $mediaTrace = 'media_trace';
	public $missed_calls_group = 'missed-calls';
	public $rate_on_net_group = 'rate-on-net';
	public $callerid_cache = array();

	public $CDRFields = array(
	'id' => 'RadAcctId',
	'callId' => 'AcctSessionId',
	'duration' => 'AcctSessionTime',
	'startTime' => 'AcctStartTime',
	'stopTime' => 'AcctStopTime',
	'inputTraffic' => 'AcctInputOctets',
	'outputTraffic' => 'AcctOutputOctets',
	'flow' => 'ServiceType',
	'tlscn' => 'AcctAuthentic',
	'aNumber' => 'CallingStationId',
	'username' => 'UserName',
	'domain' => 'Realm',
	'cNumber' => 'CalledStationId',
	'timestamp' => 'timestamp',
	'SipMethod' => 'SipMethod',
	'disconnect' => 'SipResponseCode',
	'disconnectOrig' => 'AcctTerminateCause',
	'SipFromTag' => 'SipFromTag',
	'SipToTag' => 'SipToTag',
	'RemoteAddress' => 'SipTranslatedRequestURI',
	'SipCodec' => 'SipCodecs',
	'SipUserAgents' => 'SipUserAgents',
	'application' => 'SipApplicationType',
	'BillingPartyId' => 'UserName',
	'SipRPID' => 'SipRPID',
	'SipProxyServer' => 'NASIPAddress',
	'MediaProxy' => 'FramedIPAddress',
	'gateway' => 'SourceIP',
	'SourceIP' => 'SourceIP',
	'SourcePort' => 'SourcePort',
	'CanonicalURI' => 'CanonicalURI',
	'normalized' => 'Normalized',
	'rate' => 'Rate',
	'price' => 'Price',
	'DestinationId' => 'DestinationId',
	'ResellerId' => 'BillingId',
	'MediaInfo' => 'MediaInfo',
	'RTPStatistics' => 'RTPStatistics',
	'ENUMtld' => 'ENUMtld',
	'UserAgent' => 'UserAgent',
	'FromHeader' => 'FromHeader'
	);

	public $CDRNormalizationFields = array(
	'id' => 'RadAcctId',
	'callId' => 'AcctSessionId',
	'username' => 'UserName',
	'domain' => 'Realm',
	'gateway' => 'SourceIP',
	'duration' => 'AcctSessionTime',
	'startTime' => 'AcctStartTime',
	'stopTime' => 'AcctStopTime',
	'inputTraffic' => 'AcctInputOctets',
	'outputTraffic' => 'AcctOutputOctets',
	'aNumber' => 'CallingStationId',
	'cNumber' => 'CalledStationId',
	'timestamp' => 'timestamp',
	'disconnect' => 'SipResponseCode',
	'RemoteAddress' => 'SipTranslatedRequestURI',
	'CanonicalURI' => 'CanonicalURI',
	'SipRPID' => 'SipRPID',
	'SipMethod' => 'SipMethod',
	'application' => 'SipApplicationType',
	'flow' => 'ServiceType',
	'BillingPartyId' => 'UserName',
	'ResellerId' => 'BillingId',
	'price' => 'Price',
	'DestinationId' => 'DestinationId',
	'ENUMtld' => 'ENUMtld'
	);

	public $GROUPBY = array(
	'UserName' => 'SIP Billing Party',
	'CallingStationId' => 'SIP Caller Party',
	'SipRPID' => 'SIP Remote Party Id',
	'CanonicalURI' => 'SIP Canonical URI',
	'DestinationId' => 'SIP Destination Id',
	'NASIPAddress' => 'SIP Proxy',
	'FramedIPAddress' => 'Media Proxy',
	'MediaInfo' => 'Media Information',
	'AcctAuthentic' => 'TLS Common Name',
	'SourceIP' => 'Source IP',
	'Realm' => 'SIP Billing domain',
	'UserAgent' => 'User Agent',
	'SipCodecs' => 'Codec type',
	'SipApplicationType' => 'Application',
	'SipResponseCode' => 'SIP status code',
	'BillingId' => 'Tech prefix',
	'ServiceType' => 'Call Flow',
	' ' => '-------------',
	'hour' => 'Hour of day',
	'DAYOFWEEK' => 'Day of Week',
	'DAYOFMONTH' => 'Day of Month',
	'DAYOFYEAR' => 'Day of Year',
	'BYMONTH' => 'Month',
	'BYYEAR' => 'Year'
	);

	public $FormElements = array(
	"begin_hour","begin_min","begin_month","begin_day","begin_year","begin_datetime","begin_time","end_time",
	"end_hour","end_min","end_month","end_day","end_year","end_datetime","end_date","begin_date",
	"call_id","sip_proxy", "media_proxy", "tlscn",
	"a_number","a_number_comp","UserName","UserName_comp","BillingId",
	"c_number","c_number_comp","DestinationId","ExcludeDestinations",
	"NASPortId","Realm","Realms",
	"SipMethod","SipCodec","SipRPID","UserAgent",
	"application","sip_status","sip_status_class","gateway",
	"duration","action","MONTHYEAR",
	"order_by","order_type","group_by",
	"cdr_source","trace",
	"ReNormalize","media_info","cdr_table","maxrowsperpage", "flow"
	);

	public function LoadDisconnectCodes()
	{
	$query = "select * from sip_status order by code";
	$this->disconnectCodesElements[] = array("label"=>"Any Status","value"=>"");
	$this->disconnectCodesElements[] = array("label"=>"Undefined (0)","value"=>"0");
	$this->disconnectCodesClassElements[] = array("label"=>"Any Status Class","value"=>"");
	$seen = array();
	if ($this->cdrtool->query($query)) {
	while ($this->cdrtool->next_record()) {
	$key = $this->cdrtool->f('code');
	$value = $this->cdrtool->f('description');
	$value_print = $this->cdrtool->f('description')." (".$this->cdrtool->f('code').")";

	if (preg_match("/^[^2-6]/", $key)) {
	continue;
	}
	$this->disconnectCodesElements[] = array("label"=>$value_print,"value"=>$key);
	$this->disconnectCodesDescription[$key] = $value;

	$class = substr($key, 0, 1);
	$class_text = substr($key, 0, 1)."XX (".$this->cdrtool->f('code_type').")";
	if (!in_array($class, $seen)) {
	$this->disconnectCodesClassElements[] = array("label"=>$class_text,"value"=>substr($key, 0, 1));
	$this->disconnectCodesClassDescription[substr($key, 0, 1)] = $class_text;
	$seen[] = $class;
	}
	$i++;
	}
	}
	}

	function showTableHeader()
	{
	print "
	<table class='table table-hover table-condensed'>
	<thead>
	<tr>
	<th>Id</th>
	<th>Start Time</th>
	<th>Media/Flow</th>
	<th>SIP Caller</th>
	<th>Caller Location</th>
	<th>Sip Proxy</th>
	<th>Media Proxy</th>
	<th>SIP Destination</th>
	<th>Dur</th>
	<th>Price</th>
	<th>KBIn</th>
	<th>KBOut</th>
	<th class='pull-right'>Status</th>
	</tr>
	</thead>
	";
	}

	function showExportHeader()
	{
	global $perm;

	$fields = array(
	"id",
	"StartTime",
	"StopTime",
	"BillingParty",
	"BillingDomain",
	"CallerParty",
	"CalledParty",
	"DestinationId",
	"DestinationName",
	"RemoteAddress",
	"CanonicalURI",
	"Duration",
	"Price",
	"SIPProxy",
	"Caller KBIn",
	"Called KBIn",
	"CallingUserAgent",
	"CalledUserAgent",
	"StatusCode",
	"StatusName",
	"Codec",
	"MediaProxy",
	"TLSCN"
	);

	if ($perm->have_perm("showCallerId")) {
	array_push($fields, 'PAssertedIdentity');
	}
	printf("%s\n", implode(',', $fields));
	}

	function showTableHeaderSubscriber()
	{
	if (!$this->export) {
	print "
	<table class='table table-striped table-condensed'>
	<thead>
	<tr>
	<th>Id</th>
	<th>Start Time</th>
	<th>SIP Caller</th>
	<th>Caller Location</th>
	<th>Sip Proxy</th>
	<th>SIP Destination</th>
	<th>Duration</th>
	<th>Price</th>
	<th>KBIn</th>
	<th>KBOut</th>
	</tr>
	</thead>
	";
	} else {
	print "id,StartTime,StopTime,SIPBillingParty,SIPBillingDomain,CallerParty,CalledParty,DestinationId,DestinationName,RemoteAddress,CanonicalURI,Duration,Price,SIPProxy,Applications,Caller KBIn,Called KBIn,CallingUserAgent,CalledUserAgent,StatusCode,StatusName,Codec,Application\n";
	}
	}

	function showTableHeaderStatistics()
	{
	$group_byPrint = $this->GROUPBY[$this->group_byOrig];

	if (!$this->export) {
	print "
	<table class='table table-striped table-condensed'>
	<thead>
	<tr>
	<th></th>
	<th>Calls</th>
	<th>Seconds</th>
	<th>Minutes</th>
	<th>Hours</th>
	<th>Price</th>
	<th>TrafficIn(MB)</th>
	<th>TrafficOut(MB)</th>
	<th colspan=2>Success</th>
	<th colspan=2>Failure</th>
	<th>$group_byPrint</th>
	<th>Description</th>
	<th>Action</th>
	</tr>
	</thead>
	";
	} else {
	print "id,Calls,Seconds,Minutes,Hours,Price,TrafficIn(MB),TrafficOut(MB),Success(%),Success(calls),Failure(%),Failure(calls),$group_byPrint,Description\n";
	}
	}


	function initForm()
	{
	// form els added below must have global vars
	foreach ($this->FormElements as $_el) {
	global ${$_el};
	${$_el} = trim($_REQUEST[$_el]);
	}

	$action = "search";

	if ($this->CDRTool['filter']['gateway']) {
	$gateway = $this->CDRTool["filter"]["gateway"];
	}

	if ($this->CDRTool['filter']['aNumber']) {
	$UserName = $this->CDRTool['filter']['aNumber'];
	}

	if ($this->CDRTool['filter']['domain']) {
	$Realm = $this->CDRTool['filter']['domain'];
	}

	if (!$maxrowsperpage) {
	$maxrowsperpage = 15;
	}

	$this->f = new form;

	if (isset($this->CDRTool['dataSourcesAllowed'])) {
	foreach ($this->CDRTool['dataSourcesAllowed'] as $k => $v) {
	if ($this->DATASOURCES[$v]['invisible']) continue;
	$cdr_source_els[]=array("label"=>$this->DATASOURCES[$v]['name'],"value"=>$v);
	}
	}

	if (!$cdr_source) {
	$cdr_source=$cdr_source_els[0]['value'];
	}

	$this->f->add_element(
	array(
	"name"=>"cdr_source",
	"type"=>"select",
	"options"=>$cdr_source_els,
	"size"=>"1",
	"extrahtml"=>"class=span2 onChange=\"document.datasource.submit.disabled = true; location.href = 'callsearch.phtml?cdr_source=' + this.options[this.selectedIndex].value\"",
	"value"=>"$cdr_source"
	)
	);

	$cdr_table_els = array();
	foreach ($this->tables as $_table) {
	if (preg_match("/^.*(\d{6})$/", $_table, $m)) {
	$cdr_table_els[]=array("label"=>$m[1],"value"=>$_table);
	} else {
	$cdr_table_els[]=array("label"=>$_table,"value"=>$_table);
	}
	}

	$this->f->add_element(
	array(
	"name"=>"cdr_table",
	"type"=>"select",
	"options"=>$cdr_table_els,
	"size"=>"1",
	"class"=>"span2",
	"value"=>$cdr_table,
	"extrahtml"=>"class=span2"
	)
	);

	if ($begin_datetime) {
	preg_match("/^(\d\d\d\d)-(\d+)-(\d+)\s+(\d\d):(\d\d)/", "$begin_datetime", $parts);
	$begin_year = date("Y", $begin_datetime);
	$begin_month = date("m", $begin_datetime);
	$begin_day = date("d", $begin_datetime);
	$begin_hour = date("H", $begin_datetime);
	$begin_min = date("i", $begin_datetime);
	} else {
	$begin_day = $_REQUEST["begin_day"];
	$begin_month = $_REQUEST["begin_month"];
	$begin_year = $_REQUEST["begin_year"];
	$begin_hour = $_REQUEST["begin_hour"];
	$begin_min = $_REQUEST["begin_min"];
	list($begin_hour, $begin_min)=explode(":", $begin_time);
	list($begin_year, $begin_month, $begin_day)=explode("-", $begin_date);
	}

	if ($end_datetime) {
	preg_match("/^(\d\d\d\d)-(\d+)-(\d+)\s+(\d\d):(\d\d)/", "$end_datetime", $parts);
	$end_year = date("Y", $end_datetime);
	$end_month = date("m", $end_datetime);
	$end_day = date("d", $end_datetime);
	$end_hour = date("H", $end_datetime);
	$end_min = date("i", $end_datetime);
	} else {
	$end_day = $_REQUEST["end_day"];
	$end_month = $_REQUEST["end_month"];
	$end_year = $_REQUEST["end_year"];
	$end_hour = $_REQUEST["end_hour"];
	$end_min = $_REQUEST["end_min"];
	list($end_hour, $end_min)=explode(":", $end_time);
	list($end_year, $end_month, $end_day)=explode("-", $end_date);
	}

	// corect last day of the month to be valid day
	$begin_day = validDay($begin_month, $begin_day, $begin_year);
	$end_day = validDay($end_month, $end_day, $end_year);

	$default_year = Date("Y");
	$default_month = Date("m");
	$default_day = Date("d");
	$default_hour = Date("H", time());

	if ($default_hour > 1) {
	$default_hour=$default_hour-1;
	}

	$default_hour = preg_replace("/^(\d)$/", "0$1", $default_hour);
	$default_min = Date("i");

	if ($default_min > 10) {
	$default_min = $default_min-10;
	$default_min = preg_replace("/^(\d)$/", "0$1", $default_min);
	}

	if (!$begin_hour) $begin_hour = $default_hour;
	if (!$begin_min) $begin_min = $default_min;
	if (!$begin_day) $begin_day = $default_day;
	if (!$begin_month) $begin_month = $default_month;
	if (!$begin_year) $begin_year = $default_year;

	if (!$end_hour) $end_hour = 23;
	if (!$end_min) $end_min = 55;
	if (!$end_day) $end_day = $default_day;
	if (!$end_month) $end_month = $default_month;
	if (!$end_year) $end_year = $default_year;

	$this->f->add_element(
	array(
	"name"=>"begin_time",
	"size"=>"1",
	"type"=>"text",
	"extrahtml"=>"id='timepicker1' class=\"input-small\" data-show-meridian='false' data-minute-step='1' data-default-time='$begin_hour:$begin_min'"
	)
	);
	$this->f->add_element(
	array(
	"name"=>"end_time",
	"size"=>"1",
	"type"=>"text",
	"extrahtml"=>"id='timepicker2' class=\"input-small\" data-show-meridian='false' data-minute-step='1' data-default-time='$end_hour:$end_min'"
	)
	);
	$this->f->add_element(
	array(
	"name"=>"call_id",
	"type"=>"text",
	"size"=>"50",
	"maxlength"=>"100",
	"extrahtml"=>"class=span4"
	)
	);

	$this->f->add_element(
	array(
	"name"=>"UserName",
	"type"=>"text",
	"size"=>"25",
	"maxlength"=>"255",
	"extrahtml"=>"class=span2"
	)
	);

	$this->f->add_element(
	array(
	"name"=>"a_number",
	"type"=>"text",
	"size"=>"25",
	"maxlength"=>"255",
	"extrahtml"=>"class=span2"
	)
	);
	$this->f->add_element(
	array(
	"name"=>"BillingId",
	"type"=>"text",
	"size"=>"25",
	"maxlength"=>"255",
	"extra_html"=>"class=span2"
	)
	);
	$this->f->add_element(
	array(
	"name"=>"c_number",
	"type"=>"text",
	"size"=>"25",
	"maxlength"=>"255",
	"extrahtml"=>"class=span2"
	)
	);
	$this->f->add_element(
	array(
	"name" => "sip_status",
	"type" => "select",
	"options" => $this->disconnectCodesElements,
	"size" => "1",
	"value" => $sip_status,
	"extrahtml" => "class=span3"
	)
	);
	$this->f->add_element(
	array(
	"name" => "sip_status_class",
	"type" => "select",
	"options" => $this->disconnectCodesClassElements,
	"size" => "1",
	"extrahtml" => "class=span3"
	)
	);

	if (!$this->CDRTool['filter']['aNumber']) {
	$durations_els = array(
	array("label"=>"All calls","value"=>""),
	array("label"=>"0 seconds","value"=>"zero"),
	array("label"=>"non 0 seconds","value"=>"nonzero"),
	array("label"=>"non 0 seconds without price","value"=>"zeroprice"),
	array("label"=>"less than 5 seconds","value"=>"< 5"),
	array("label"=>"more than 5 seconds","value"=>"> 5"),
	array("label"=>"less than 60 seconds","value"=>"< 60"),
	array("label"=>"more than 2 minutes","value"=>"> 120"),
	array("label"=>"greater than 1 hour","value"=>"> 3600"),
	array("label"=>"one hour","value"=>"onehour"),
	array("label"=>"greater than 5 hours","value"=>"> 18000"),
	array("label"=>"Un-normalized calls","value"=>"unnormalized"),
	array("label"=>"Un-normalized calls > 0s","value"=>"unnormalized_duration"),
	array("label"=>"One way media","value"=>"onewaymedia"),
	array("label"=>"No media","value"=>"nomedia")
	);
	} else {
	$durations_els = array(
	array("label"=>"All calls","value"=>""),
	array("label"=>"0 seconds call","value"=>"zero"),
	array("label"=>"Succesfull calls","value"=>"nonzero"),
	array("label"=>"less than 60 seconds","value"=>"< 60"),
	array("label"=>"greater than 1 hour","value"=>"> 3600")
	);
	$this->GROUPBY = array(
	'UserName' => 'SIP Billing Party',
	'CallingStationId' => 'SIP Caller Party',
	'DestinationId' => 'SIP Destination Id',
	'SipApplicationType' => 'Application',
	' ' => '-------------',
	'hour' => 'Hour of day',
	'DAYOFWEEK' => 'Day of Week',
	'DAYOFMONTH' => 'Day of Month',
	'DAYOFYEAR' => 'Day of Year',
	'BYMONTH' => 'Month',
	'BYYEAR' => 'Year'
	);
	}

	$flow_els = array(
	array("label"=>"Any Call Flow","value"=>""),
	array("label"=>"On Net","value"=>"on-net"),
	array("label"=>"Incoming","value"=>"incoming"),
	array("label"=>"Outgoing","value"=>"outgoing"),
	array("label"=>"Transit","value"=>"transit"),
	array("label"=>"Diverted On Net","value"=>"diverted-on-net"),
	array("label"=>"Diverted Off Net","value"=>"diverted-off-net"),
	array("label"=>"On Net Diverted On Net","value"=>"on-net-diverted-on-net"),
	array("label"=>"On Net Diverted Off Net","value"=>"on-net-diverted-off-net"),
	array("label"=>"Unknown Flow","value"=>"Sip-Session")
	);

	$this->f->add_element(array( "name"=>"flow",
	"type"=>"select",
	"options"=>$flow_els,
	"value"=>"",
	"size"=>"1",
	"extrahtml"=>"class=span3"
	));

	$this->f->add_element(array( "name"=>"duration",
	"type"=>"select",
	"options"=>$durations_els,
	"value"=>"All",
	"size"=>"1",
	"extrahtml"=>"class=span3"
	));
	$comp_ops_els = array(
	array("label"=>"Begins with","value"=>"begin"),
	array("label"=>"Contains","value"=>"contain"),
	array("label"=>"Is empty","value"=>"empty"),
	array("label"=>"Equal","value"=>"equal")
	);
	$this->f->add_element(array( "name"=>"a_number_comp",
	"type"=>"select",
	"options"=>$comp_ops_els,
	"value"=>"begin",
	"size"=>"1",
	"extrahtml"=>"class=span2"
	));
	$this->f->add_element(array( "name"=>"c_number_comp",
	"type"=>"select",
	"options"=>$comp_ops_els,
	"value"=>"begin",
	"size"=>"1",
	"extrahtml"=>"class=span2"
	));
	$this->f->add_element(array( "name"=>"UserName_comp",
	"type"=>"select",
	"options"=>$comp_ops_els,
	"value"=>"begin",
	"size"=>"1",
	"extrahtml"=>"class=span2"
	));
	$this->f->add_element(array( "name"=>"Realm",
	"type"=>"text",
	"size"=>"25",
	"maxlength"=>"25",
	"extrahtml"=>"class=span2"
	));

	$media_info_els=array(
	array("label"=>"","value"=>""),
	array("label"=>"Timeout","value"=>"timeout"),
	array("label"=>"ICE session","value"=>"ICE session")
	);

	$this->f->add_element(array( "name"=>"media_info",
	"type"=>"select",
	"options"=>$media_info_els,
	"size"=>"1",
	"value"=>"",
	"extrahtml"=>"class=span2"
	));

	$this->f->add_element(array("type"=>"submit",
	"name"=>"submit",
	"value"=>"Search","extrahtml"=>"class=btn"
	));
	$max_els = array(
	array("label"=>"5","value"=>"5"),
	array("label"=>"10","value"=>"10"),
	array("label"=>"15","value"=>"15"),
	array("label"=>"25","value"=>"25"),
	array("label"=>"50","value"=>"50"),
	array("label"=>"100","value"=>"100"),
	array("label"=>"500","value"=>"500")
	);
	$this->f->add_element(array( "name"=>"maxrowsperpage",
	"type"=>"select",
	"options"=>$max_els,
	"size"=>"1",
	"value"=>"25",
	"extrahtml"=>"class = span2"
	));
	$order_type_els = array(
	array("label"=>"Descending","value"=>"DESC"),
	array("label"=>"Ascending","value"=>"ASC")
	);
	$this->f->add_element(array( "name"=>"order_type",
	"type"=>"select",
	"options"=>$order_type_els,
	"size"=>"1",
	"extrahtml"=>"class=span2"
	));
	$this->f->add_element(array("type"=>"hidden",
	"name"=>"action",
	"value"=>$action
	));

	$order_by_els = array(array("label"=>"Id","value"=>"RadAcctId"),
	array("label"=>"Date","value"=>"AcctStopTime"),
	array("label"=>"Billing Party","value"=>"UserName"),
	array("label"=>"Remote Party Id","value"=>"SipRPID"),
	array("label"=>"Caller Party","value"=>"CallingStationId"),
	array("label"=>"Destination","value"=>"CalledStationId"),
	array("label"=>"Duration","value"=>"AcctSessionTime"),
	array("label"=>"Input traffic","value"=>"AcctInputOctets"),
	array("label"=>"Output traffic","value"=>"AcctOutputOctets"),
	array("label"=>"Price","value"=>"Price"),
	array("label"=>"Failures(%)","value"=>"zeroP"),
	array("label"=>"Success(%)","value"=>"nonzeroP"),
	array("label"=>"Group by","value"=>"group_by")
	);

	$group_by_els[] = array("label"=>"", "value"=>"");

	global $perm;

	if (!$perm->have_perm("showCallerId")) {
	$order_by_els = array_filter(
	$order_by_els,
	function ($element) {
	return $element['label'] != "Remote Party Id";
	}
	);
	unset($this->GROUPBY['SipRPID']);
	}

	foreach ($this->GROUPBY as $k => $v) {
	$group_by_els[]=array("label"=>$v,"value"=>$k);
	}

	$this->f->add_element(
	array(
	"name" => "order_by",
	"type" => "select",
	"options" => $order_by_els,
	"value" => $order_by,
	"size" => "1",
	"extrahtml" => "class=span3"
	)
	);

	$this->f->add_element(
	array(
	"name"=> "group_by",
	"type" => "select",
	"options" => $group_by_els,
	"value" => $group_by,
	"size" => "1",
	"extrahtml" => "class=span3"
	)
	);

	$application_els = array(
	array(
	"label" => "Any Application",
	"value" => ""
	),
	array(
	"label" => "Audio",
	"value" => "audio"
	),
	array(
	"label" => "Video",
	"value"=>"video"
	),
	array(
	"label" => "Message",
	"value" => "message"
	),
	array(
	"label" => "IM Chat" ,
	"value" => "chat"
	),
	array(
	"label" => "Audio + Chat" ,
	"value" => "audio=2C chat"
	),
	array(
	"label" => "File Transfer",
	"value" => "file-transfer"
	)
	);

	$this->f->add_element(array("name"=>"application",
	"type"=>"select",
	"options"=>$application_els,
	"value"=>$application,
	"size"=>"1",
	"extrahtml"=>"class=span2"
	));
	$this->f->add_element(array("name"=>"UserAgent",
	"type"=>"text",
	"size"=>"25",
	"maxlength"=>"50",
	"value"=>$UserAgent,
	"extrahtml"=>"class=span2"
	));
	$this->f->add_element(array("name"=>"SipCodec",
	"type"=>"text",
	"size"=>"10",
	"maxlength"=>"50",
	"value"=>$SipCodec,
	"extrahtml"=>"class=span2"
	));
	$this->f->add_element(
	array(
	"name"=>"sip_proxy",
	"type"=>"text",
	"size"=>"25",
	"maxlength"=>"255",
	"value"=>$sip_proxy,
	"extrahtml"=>"class=span2"
	)
	);
	$this->f->add_element(
	array(
	"name"=>"media_proxy",
	"type"=>"text",
	"size"=>"25",
	"maxlength"=>"255",
	"value"=>$media_proxy,
	"extrahtml"=>"class=span2"
	)
	);
	$this->f->add_element(
	array(
	"name"=>"tlscn",
	"type"=>"text",
	"size"=>"25",
	"maxlength"=>"255",
	"value"=>$tlscn,
	"extrahtml"=>"class=span2"
	)
	);
	$this->f->add_element(
	array(
	"name"=>"gateway",
	"type"=>"text",
	"size"=>"25",
	"maxlength"=>"255",
	"value"=>$gateway,
	"extrahtml"=>"class=span2"
	)
	);
	$this->f->add_element(
	array(
	"name"=>"DestinationId",
	"type"=>"text",
	"size"=>"10",
	"extrahtml"=>"class=span3"
	)
	);
	$this->f->add_element(
	array(
	"name"=>"ExcludeDestinations",
	"type"=>"text",
	"size"=>"20",
	"maxlength"=>"255",
	"extrahtml"=>"class=span3"
	)
	);
	$this->f->load_defaults();
	$this->f->add_element(
	array(
	"name"=>"begin_date",
	"size"=>"10",
	"maxlength"=>"10",
	"type"=>"text",
	"value" => "$begin_year-$begin_month-$begin_day",
	"extrahtml"=>"id='begin_date' data-date-format=\"yyyy-mm-dd\" class=\"span2\""
	)
	);
	$this->f->add_element(array(
	"name"=>"end_date",
	"size"=>"1",
	"type"=>"text",
	"value"=>"$end_year-$end_month-$end_day",
	"extrahtml"=>"id='end_date' data-date-format=\"yyyy-mm-dd\" class=\"span2\""
	));
	}

	public function searchForm()
	{
	global $perm;

	$this->initForm();
	$this->f->start("", "POST", "", "", "datasource");

	print "<table id='search' class='table table-bordered table-condensed' cellpadding=5 width=100% align=center>";

	$this->showDataSources($this->f);
	$this->showDateTimeElements($this->f);
	$ff = array();
	// freeze some form els
	if ($this->CDRTool['filter']['aNumber']) {
	$ff[]="a_number";
	$ff[]="a_number_comp";
	$ff[]="UserName";
	$ff[]="UserName_comp";
	}

	if ($this->CDRTool['filter']['domain']) {
	$Realm=$this->CDRTool['filter']['domain'];
	$ff[]="Realm";
	}

	if ($this->CDRTool['filter']['gateway']) {
	$gateway=$this->CDRTool['filter']['gateway'];
	$ff[]="gateway";
	}

	if (count($ff)) {
	$this->f->freeze($ff);
	}

	print "
	<tr>
	<td align=left>
	<b>SIP Call Id / Source IP</b>
	</td>
	<td>
	<div class=\"input-prepend\">
	<div class=\"input-append\">";
	$this->f->show_element("call_id", "");
	print "<span class=\"add-on\">/</span></div>";
	$this->f->show_element("gateway", "");
	print "</div>
	Sip Proxy ";

	$this->f->show_element("sip_proxy", "");
	print "
	</td>
	</tr>
	<tr>
	</tr>
	";

	print "
	<tr>
	<td align=left>
	<b>User Agent / Media Codecs</b>
	</td>
	<td >
	";
	$this->f->show_element("UserAgent", "");
	print " Codec: ";
	$this->f->show_element("SipCodec", "");
	print " Media Proxy:";
	$this->f->show_element("media_proxy", "");
	print "
	</td>
	</tr>
	<tr>
	</tr>
	";

	print "
	<tr>
	<td align=left>
	<b>SIP Billing Party (Username)</b>
	</td>
	<td>
	";
	$this->f->show_element("UserName_comp", "");
	print "
	<div class=\"input-prepend\">
	<div class=\"input-append\">
	";
	$this->f->show_element("UserName", "");
	print "<span class=\"add-on\">@</span></div>";
	$this->f->show_element("Realm", "");
	print "</div> Tech prefix: ";
	$this->f->show_element("BillingId", "");
	print "</div>
	</td>
	</tr>
	<tr>
	</tr>
	";

	print "
	<tr>
	<td align=left>
	<b>
	SIP Caller Party (From URI)
	</b>
	</td>
	<td valign=top>
	";
	$this->f->show_element("a_number_comp", "");
	print " ";
	$this->f->show_element("a_number");
	print "  TLS CN:";
	$this->f->show_element("tlscn");
	print "
	</td>
	</tr>
	<tr>
	</tr>
	";

	print "
	<tr>
	<td align=left>
	<b>SIP Destination (Canonical URI)
	</b>
	</td>
	<td valign=top> ";
	$this->f->show_element("c_number_comp", "");
	print " ";

	$this->f->show_element("c_number", "");
	print " Exclude: ";
	$this->f->show_element("ExcludeDestinations_comp");
	$this->f->show_element("ExcludeDestinations", "");
	print "
	</td>
	</tr>
	<tr>
	</tr>
	";

	print "
	<tr>
	<td align=left><b>Application / Call Flow</b></td>
	<td valign=top> ";
	$this->f->show_element("flow", "");
	print " ";
	$this->f->show_element("application", "");
	print " Media Info: ";
	$this->f->show_element("media_info", "");
	print "
	</td>
	</tr>
	";

	print "
	<tr>
	<td align=left><b>Duration / Status</b></td>
	<td valign=top> ";
	$this->f->show_element("duration", "");
	print " ";
	$this->f->show_element("sip_status", "");
	print " ";
	$this->f->show_element("sip_status_class", "");
	print "
	</td>
	</tr>
	";
	print "
	<tr>
	<td align=left>
	<b>Order by / Group by</b>
	</td>
	<td valign=top>
	";
	$this->f->show_element("order_by", "");
	print " ";
	$this->f->show_element("order_type", "");

	if ($perm->have_perm("statistics")) {
	print " Group by ";
	$this->f->show_element("group_by", "");
	}

	print " Max results per page ";
	$this->f->show_element("maxrowsperpage", "");

	print "</nobr>&nbsp";

	if (!$perm->have_perm('readonly')) {
	print ";   <nobr>ReNormalize ";
	print "<input type=checkbox name=ReNormalize value=1>
	";
	}

	print "
	</td>
	</tr>
	";

	print "
	</table>
	<p>
	<center>
	";

	$this->f->show_element("submit", "");
	$this->f->finish();

	print "
	</center>
	";
	}

	function searchFormSubscriber()
	{
	global $perm;

	$this->initForm();
	$this->f->start("", "POST", "", "", "datasource");

	print "
	<table id='search' class='table table-bordered table-condensed' cellpadding=5 width=100% align=center>
	";
	$this->showDataSources($this->f);
	$this->showDateTimeElements($this->f);

	// freeze some form els
	if ($this->CDRTool['filter']['aNumber']) {
	$ff[]="UserName";
	}

	if ($this->CDRTool['filter']['domain']) {
	$ff[]="Realm";
	}

	if ($this->CDRTool["filter"]["gateway"]) {
	$ff[]="gateway";
	}

	if (count($ff)) {
	$this->f->freeze($ff);
	}

	print "
	<tr>
	<td align=left>
	<b>
	SIP Caller Party
	</b>
	</td>
	<td valign=top>
	";
	$this->f->show_element("a_number", "");
	print "
	</td>
	</tr>
	<tr>
	</tr>
	";

	print "
	<tr>
	<td align=left>
	<b>
	SIP Billing Party
	</b>
	</td>
	<td valign=top>
	";
	$this->f->show_element("UserName", "");
	print "
	</td>
	</tr>
	<tr>
	</tr>
	";

	print "
	<tr>
	<td align=left>
	<b>
	SIP Destination
	</b>
	</td>
	<td valign=top> ";
	$this->f->show_element("c_number_comp", "");
	$this->f->show_element("c_number", "");
	//$this->f->show_element("DestinationId","");
	print "
	</td>
	</tr>
	<tr>
	</tr>
	";

	print "
	<tr>
	<td align=left>
	<b>SIP Session duration</b>
	</td>
	<td valign=top> ";
	$this->f->show_element("duration", "");
	print " Application ";
	$this->f->show_element("application", "");
	print "
	</td>
	</tr>
	";
	print "
	<tr>
	<td align=left>
	<b>Order by</b>
	</td>
	<td valign=top>
	";
	$this->f->show_element("order_by", "");
	$this->f->show_element("order_type", "");

	if ($perm->have_perm("statistics")) {
	print " Group by ";
	$this->f->show_element("group_by", "");
	}

	print " Max results per page ";
	$this->f->show_element("maxrowsperpage", "");
	print "
	</td>
	</tr>
	";

	print "
	</table>
	<p>
	<center>
	";

	$this->f->show_element("submit", "");
	$this->f->finish();

	print "
	</center>
	";
	}

	function show()
	{
	global $perm;

	if (!is_object($this->CDRdb)) {
	$log = sprintf("Error: CDR database is not initalized");
	print $log;
	return false;
	}

	foreach ($this->FormElements as $_el) {
	${$_el} = trim($_REQUEST[$_el]);
	}

	if ($begin_time) {
	list($begin_hour, $begin_min)=explode(":", $begin_time);
	}

	if ($end_time) {
	list($end_hour, $end_min)=explode(":", $end_time);
	}

	if ($begin_date) {
	list($begin_year, $begin_month, $begin_day)=explode("-", $begin_date);
	}

	if ($end_date) {
	list($end_year, $end_month, $end_day)=explode("-", $end_date);
	}
	// overwrite some elements based on user rights
	if ($this->CDRTool['filter']['gateway']) {
	$gateway =$this->CDRTool['filter']['gateway'];
	}

	if (!$this->export) {
	if (!$begin_datetime) {
	$begin_datetime="$begin_year-$begin_month-$begin_day $begin_hour:$begin_min";
	$begin_datetime_timestamp = mktime($begin_hour, $begin_min, 0, $begin_month, $begin_day, $begin_year);
	} else {
	$begin_datetime_timestamp=$begin_datetime;
	$begin_datetime = Date("Y-m-d H:i", $begin_datetime);
	}

	if (!$end_datetime) {
	$end_datetime_timestamp = mktime($end_hour, $end_min, 0, $end_month, $end_day, $end_year);
	$end_datetime="$end_year-$end_month-$end_day $end_hour:$end_min";
	} else {
	$end_datetime_timestamp=$end_datetime;
	$end_datetime = Date("Y-m-d H:i", $end_datetime);
	}
	} else {
	$begin_datetime = Date("Y-m-d H:i", $begin_datetime);
	$end_datetime = Date("Y-m-d H:i", $end_datetime);
	}

	if (!$order_by \|\| (!$group_by && $order_by == "group_by")) {
	$order_by=$this->idField;
	}

	if (!$cdr_table) {
	$cdr_table=$this->table;
	}

	$this->url = sprintf("?cdr_source=%s&cdr_table=%s", $this->cdr_source, $cdr_table);

	if ($this->CDRTool['filter']['domain']) {
	$this->url .= sprintf("&Realms=%s", urlencode($this->CDRTool['filter']['domain']));
	$Realms = explode(" ", $this->CDRTool['filter']['domain']);
	} elseif ($Realms) {
	$this->url .= sprintf("&Realms=%s", urlencode($Realms));
	$Realms = explode(" ", $Realms);
	}

	if ($this->CDRTool['filter']['aNumber']) {
	$this->url .= sprintf("&UserName=%s", urlencode($this->CDRTool['filter']['aNumber']));
	}

	if ($this->CDRTool['filter']['after_date']) {
	$where .= sprintf(" and %s >= '%s' ", addslashes($this->startTimeField), addslashes($this->CDRTool['filter']['after_date']));
	}

	if ($order_by) {
	$this->url.=sprintf("&order_by=%s&order_type=%s", addslashes($order_by), addslashes($order_type));
	}

	$this->url.=sprintf("&begin_datetime=%s", urlencode($begin_datetime_timestamp));
	$this->url.=sprintf("&end_datetime=%s", urlencode($end_datetime_timestamp));

	if (!$call_id && $begin_datetime && $end_datetime) {
	$where .= sprintf(
	" (%s >= '%s' and %s < '%s') ",
	addslashes($this->startTimeField),
	addslashes($begin_datetime),
	addslashes($this->startTimeField),
	addslashes($end_datetime)
	);
	} else {
	$where .= sprintf(" (%s >= '1970-01-01' ) ", addslashes($this->startTimeField));
	}

	if ($MONTHYEAR) {
	$where .= sprintf(" and %s like '%s%s' ", addslashes($this->startTimeField), addslashes($MONTHYEAR), '%');
	$this->url.= sprintf("&MONTHYEAR=%s", urlencode($MONTHYEAR));
	}

	if ($flow) {
	$this->url.=sprintf("&flow=%s", urlencode($flow));
	$where .= sprintf(" and %s = '%s' ", addslashes($this->flowField), addslashes($flow));
	}

	if ($this->CDRTool['filter']['aNumber']) {
	// force user to see only CDRS with his a_numbers
	$where .= sprintf(
	" and ( %s = '%s' or %s = '%s') ",
	addslashes($this->usernameField),
	addslashes($this->CDRTool['filter']['aNumber']),
	addslashes($this->CanonicalURIField),
	addslashes($this->CDRTool['filter']['aNumber'])
	);
	$UserName_comp='equal';
	$UserName=$this->CDRTool['filter']['aNumber'];
	}

	if ($UserName_comp == "empty") {
	$where .= sprintf(" and %s = ''", addslashes($this->usernameField));
	$this->url.=sprintf("&UserName_comp=%s", urlencode($UserName_comp));
	} elseif (strlen($UserName) && !$this->CDRTool['filter']['aNumber']) {
	if (!$UserName_comp) {
	$UserName_comp='begin';
	}

	if ($UserName_comp=="begin") {
	$where .= sprintf(" and %s like '%s%s'", addslashes($this->usernameField), addslashes($UserName), '%');
	} elseif ($UserName_comp=="contain") {
	$where .= sprintf(" and %s like '%s%s%s'", addslashes($this->usernameField), '%', addslashes($UserName), '%');
	} elseif ($UserName_comp=="equal") {
	$where .= sprintf(" and %s = '%s'", addslashes($this->usernameField), addslashes($UserName));
	} else {
	$where .= sprintf(" and %s = ''", addslashes($this->usernameField));
	}

	$this->url.= sprintf("&UserName=%s&UserName_comp=%s", urlencode($UserName), $UserName_comp);
	}

	$a_number = trim($a_number);
	if ($a_number_comp == "empty") {
	$where .= sprintf(" and %s = ''", addslashes($this->aNumberField));
	$this->url.=sprintf("&a_number_comp=%s", urlencode($a_number_comp));
	} elseif (strlen($a_number)) {
	$a_number = urldecode($a_number);
	if (!$a_number_comp) {
	$a_number_comp = "equal";
	}

	$this->url.=sprintf("&a_number=%s", urlencode($a_number));

	if ($a_number_comp=="begin") {
	$where .= sprintf(" and %s like '%s%s'", addslashes($this->aNumberField), addslashes($a_number), '%');
	} elseif ($a_number_comp=="contain") {
	$where .= sprintf(" and %s like '%s%s%s'", addslashes($this->aNumberField), '%', addslashes($a_number), '%');
	} elseif ($a_number_comp=="equal") {
	$where .= sprintf(" and %s = '%s'", addslashes($this->aNumberField), addslashes($a_number));
	}

	$this->url.=sprintf("&a_number_comp=%s", urlencode($a_number_comp));
	}

	$c_number = trim($c_number);
	if ($c_number_comp == "empty") {
	$where .= sprintf(" and %s = ''", addslashes($this->CanonicalURIField));
	$this->url.=sprintf("&c_number_comp=%s", urlencode($c_number_comp));
	} elseif (strlen($c_number)) {
	$c_number = urldecode($c_number);
	if (!$c_number_comp) {
	$c_number_comp = "begin";
	}

	if (!$c_number_comp \|\| $c_number_comp == "begin") {
	$where .= sprintf(" and %s like '%s%s'", addslashes($this->CanonicalURIField), addslashes($c_number), '%');
	} elseif ($c_number_comp=="contain") {
	$where .= sprintf(" and %s like '%s%s%s'", addslashes($this->CanonicalURIField), '%', addslashes($c_number), '%');
	} elseif ($c_number_comp=="equal") {
	$where .= sprintf(" and %s = '%s'", addslashes($this->CanonicalURIField), addslashes($c_number));
	}
	$this->url.=sprintf("&c_number=%s&c_number_comp=%s", urlencode($c_number), urlencode($c_number_comp));
	}

	$Realm = trim($Realm);

	if ($Realms) {
	$where .= sprintf(" and (");
	$count_realms = count($Realms);
	$j = 1;
	foreach ($Realms as $realm) {
	$where .= sprintf(" ( %s like '%%%s' or %s like '%%%s' ) ", $this->domainField, addslashes($realm), $this->CanonicalURIField, addslashes($realm));

	if ($j < $count_realms) {
	$where .= " or ";
	}
	$j = $j + 1;
	}
	$where .= ") ";
	} elseif ($Realm) {
	$Realm = urldecode($Realm);
	$where .= sprintf(" and %s like '%s' ", $this->domainField, addslashes($Realm));
	$this->url.=sprintf("&Realm=%s", urlencode($Realm));
	}

	$BillingId = trim($BillingId);
	if (preg_match("/^\d+$/", $BillingId) && $this->BillingIdField) {
	$where .= " and $this->BillingIdField = '".addslashes($BillingId)."'";
	$this->url.=sprintf("&BillingId=%s", urlencode($BillingId));
	}

	if ($application) {
	$where .= " and $this->applicationField like '%".addslashes($application)."%'";
	$this->url.=sprintf("&application=%s", urlencode($application));
	}

	if ($DestinationId) {
	if ($DestinationId=="empty") {
	$DestinationIdSQL = "";
	} else {
	$DestinationIdSQL = $DestinationId;
	}
	$where .= " and $this->DestinationIdField = '".addslashes($DestinationIdSQL)."'";
	$this->url.=sprintf("&DestinationId=%s", urlencode($DestinationId));
	}

	if (strlen(trim($ExcludeDestinations))) {
	$ExcludeDestArray = explode(" ", trim($ExcludeDestinations));

	foreach ($ExcludeDestArray as $exclDst) {
	if (preg_match("/^0+(\d+)$/", $exclDst, $m)) {
	$exclDest_id = $m[1];
	} else {
	$exclDest_id = $exclDst;
	}

	$where .= " and ".
	$this->CanonicalURIField.
	" not like '".
	addslashes(trim($exclDst)).
	"'";
	}

	$this->url .= sprintf("&ExcludeDestinations=%s", urlencode($ExcludeDestinations));
	}

	$call_id = trim($call_id);

	if ($call_id) {
	$call_id = urldecode($call_id);
	$where .= " and $this->callIdField = '".addslashes($call_id)."'";
	$this->url.=sprintf("&call_id=%s", urlencode($call_id));
	}

	if ($sip_proxy) {
	$sip_proxy = urldecode($sip_proxy);
	$where .= " and $this->SipProxyServerField = '".addslashes($sip_proxy)."'";
	$this->url.=sprintf("&sip_proxy=%s", urlencode($sip_proxy));
	}

	if ($media_proxy) {
	$media_proxy = urldecode($media_proxy);
	$where .= " and $this->MediaProxyField = '".addslashes($media_proxy)."'";
	$this->url.=sprintf("&media_proxy=%s", urlencode($media_proxy));
	}

	if ($tlscn) {
	$tlscn = urldecode($tlscn);
	$where .= " and $this->tlscnField = '".addslashes($tlscn)."'";
	$this->url.=sprintf("&tlscn=%s", urlencode($tlscn));
	}

	if ($SipCodec) {
	$this->url.=sprintf("&SipCodec=%s", urlencode($SipCodec));
	if ($SipCodec != "empty") {
	$where .= " and $this->SipCodecField = '".addslashes($SipCodec)."'";
	} else {
	$where .= " and $this->SipCodecField = ''";
	}
	}

	if ($SipRPID) {
	$this->url.=sprintf("&SipRPID=%s", urlencode($SipRPID));
	if ($SipRPID != "empty") {
	$where .= " and $this->SipRPIDField = '".addslashes($SipRPID)."'";
	} else {
	$where .= " and $this->SipRPIDField = ''";
	}
	}

	if ($UserAgent) {
	$where .= " and $this->UserAgentField like '%".addslashes($UserAgent)."%'";
	$this->url.=sprintf("&UserAgent=%s", urlencode($UserAgent));
	}

	if (strlen($sip_status)) {
	$where .= " and $this->disconnectField ='".addslashes($sip_status)."'";
	$this->url.=sprintf("&sip_status=%s", urlencode($sip_status));
	}

	if ($sip_status_class) {
	$where .= " and $this->disconnectField like '$sip_status_class%'";
	$this->url.=sprintf("&sip_status_class=%s", urlencode($sip_status_class));
	}

	if ($this->CDRTool['filter']["gateway"]) {
	$gatewayFilter=$this->CDRTool[filter]["gateway"];
	$where .= " and $this->gatewayField = '".addslashes($gatewayFilter)."'";
	} elseif ($gateway) {
	$gateway = urldecode($gateway);
	$where .= " and $this->gatewayField = '".addslashes($gateway)."'";
	$this->url.=sprintf("&gateway=%s", urlencode($gateway));
	}

	if ($duration) {
	if (preg_match("/\d+/", $duration)) {
	$where .= " and ($this->durationField > 0 and $this->durationField $duration) ";
	} elseif (preg_match("/onehour/", $duration)) {
	$where .= " and ($this->durationField < 3610 and $this->durationField > 3530) ";
	} elseif ($duration == "zero") {
	$where .= " and $this->durationField = 0";
	} elseif ($duration == "zeroprice" && $this->priceField) {
	$where .= " and $this->durationField > 0 and ($this->priceField = '' or $this->priceField is NULL)";
	} elseif ($duration == "nonzero") {
	$where .= " and $this->durationField > 0";
	} elseif ($duration == "onewaymedia") {
	$where .= " and (($this->inputTrafficField > 0 && $this->outputTrafficField = 0) \|\| ($this->inputTrafficField = 0 && $this->outputTrafficField > 0)) " ;
	} elseif ($duration == "nomedia") {
	$where .= " and ($this->inputTrafficField = 0 && $this->outputTrafficField = 0) " ;
	}
	$this->url.=sprintf("&duration=%s", urlencode($duration));
	}

	if ($media_info) {
	$this->url.=sprintf("&media_info=%s", urlencode($media_info));
	$where .= sprintf(" and %s = '%s' ", addslashes($this->MediaInfoField), addslashes($media_info));
	}

	$this->url.=sprintf("&maxrowsperpage=%s", addslashes($this->maxrowsperpage));
	$url_calls = $this->scriptFile.$this->url."&action=search";

	if ($group_by) {
	$this->url.=sprintf("&group_by=%s", urlencode($group_by));
	}

	$this->url_edit = $this->scriptFile.$this->url."&action=edit";
	$this->url_run = $this->scriptFile.$this->url."&action=search";
	$this->url_export = $_SERVER["PHP_SELF"].$this->url."&action=search&export=1";

	if ($duration == "unnormalized") {
	$where .= " and $this->normalizedField = '0' ";
	}

	if ($duration == "unnormalized_duration") {
	$where .= " and $this->normalizedField = '0' and $this->durationField > 0 ";
	}

	if ($group_by) {
	$this->group_byOrig=$group_by;

	if ($group_by=="hour") {
	$group_by="HOUR(AcctStartTime)";
	} elseif (preg_match("/^DAY/", $group_by)) {
	$group_by="$group_by(AcctStartTime)";
	} elseif (preg_match("/BYMONTH/", $group_by)) {
	$group_by="DATE_FORMAT(AcctStartTime,'%Y-%m')";
	} elseif (preg_match("/BYYEAR/", $group_by)) {
	$group_by="DATE_FORMAT(AcctStartTime,'%Y')";
	} elseif ($group_by=="UserAgentType") {
	$group_by="SUBSTRING_INDEX($this->SipUserAgentsField, ' ', '1')";
	}

	$this->group_by=$group_by;

	if ($group_by==$this->callIdField) {
	$having = sprintf(" having count(%s) > 1 ", addslashes($group_by));
	}

	$query= sprintf(
	"
	select
	sum(%s) as duration,
	SEC_TO_TIME(sum(%s)) as duration_print,
	count(%s) as calls,
	%s
	from
	%s
	where
	%s
	group by
	%s %s
	",
	addslashes($this->durationField),
	addslashes($this->durationField),
	$group_by,
	$group_by,
	addslashes($cdr_table),
	$where,
	$group_by,
	$having
	);
	} else {
	$query = sprintf("select count(*) as records from %s where ", addslashes($cdr_table)). $where;
	}

	dprint_sql($query);

	if ($this->CDRdb->query($query)) {
	$this->CDRdb->next_record();
	if ($group_by) {
	$rows = $this->CDRdb->num_rows();
	} else {
	$rows = $this->CDRdb->f('records');
	}
	} else {
	printf("%s", $this->CDRdb->Error);
	$rows = 0;
	}

	$this->rows=$rows;

	if ($this->CDRTool['filter']['aNumber']) {
	$this->showResultsMenuSubscriber('0', $begin_datetime, $end_datetime);
	} else {
	$this->showResultsMenu('0', $begin_datetime, $end_datetime);
	}

	if (!$this->next) {
	$i=0;
	$this->next=0;
	} else {
	$i = intval($this->next);
	}
	$j=0;
	$z=0;


	if ($rows > 0) {
	if ($call_id && $ReNormalize) {
	$query = sprintf(
	"
	update
	%s
	set
	%s = '0'
	where
	%s = '%s'
	",
	addslashes($cdr_table),
	addslashes($this->normalizedField),
	addslashes($this->callIdField),
	addslashes($call_id)
	);

	$this->CDRdb->query($query);
	}

	if ($UnNormalizedCalls = $this->getUnNormalized($where, $cdr_table)) {
	if (!$this->DATASOURCES[$this->cdr_source]['skipNormalizeOnPageLoad']) {
	if ($UnNormalizedCalls < $this->maxCDRsNormalizeWeb) {
	$this->NormalizeCDRS($where, $cdr_table);
	if (!$this->export && $this->status['normalized']) {
	print "<div class=\"alert alert-info\">";
	print "<i class='icon-info-sign icon-large'></i>  ";
	printf("<b><span class=\"alert-heading\">%d</span></b> CDRs normalized. ", $this->status['normalized']);
	if ($this->status['cached_keys']['saved_keys']) {
	printf("Quota usage updated for <b><span class=\"alert-heading\">%d</span></b> accounts. ", $this->status['cached_keys']['saved_keys']);
	}
	print "</div>";
	}
	}
	}
	}

	if ($rows > $this->maxrowsperpage) {
	$maxrows = $this->maxrowsperpage + $this->next;
	if ($maxrows > $rows) {
	$maxrows = $rows;
	$prev_rows = $maxrows;
	}
	} else {
	$maxrows = $rows;
	}

	if ($duration == "unnormalized") {
	// if display un normalized calls we must substract
	// the amount of calls normalized above
	$maxrows=$maxrows-$this->status['normalized'];
	}

	if ($group_by) {
	if ($order_by == "group_by") {
	$order_by1 = $group_by;
	} else {
	if ($order_by == $this->inputTrafficField
	\|\| $order_by == $this->outputTrafficField
	\|\| $order_by == $this->durationField
	\|\| $order_by == $this->priceField
	\|\| $order_by == "zeroP"
	\|\| $order_by == "nonzeroP"
	) {
	$order_by1 = $order_by;
	} else {
	$order_by1 = "calls";
	}
	}

	$this->SipMethodField = $this->CDRFields['SipMethod'];
	$query = "
	select
	sum($this->durationField) as $this->durationField,
	SEC_TO_TIME(sum($this->durationField)) as hours,
	count($group_by) as calls,
	$this->SipMethodField,
	2*sum($this->inputTrafficField)/1024/1024 as $this->inputTrafficField,
	2*sum($this->outputTrafficField)/1024/1024 as $this->outputTrafficField,
	SUM($this->durationField = '0') as zero,
	SUM($this->durationField > '0') as nonzero,";

	if ($order_by=="zeroP" \|\| $order_by=="nonzeroP") {
	$query .= "
	SUM($this->durationField = '0')/count($group_by)*100 as zeroP,
	SUM($this->durationField > '0')/count($group_by)*100 as nonzeroP,";
	}

	$query .= "
	sum($this->inputTrafficField)82/1024/sum($this->durationField) as netrate_in,
	sum($this->outputTrafficField)82/1024/sum($this->durationField) as netrate_out";

	if ($this->priceField) {
	$query .= ", sum($this->priceField) as $this->priceField
	";
	}

	$_max_rows = intval($this->maxrowsperpage);
	if (!$_max_rows) {
	$_max_rows = 10;
	}
	/*
	$query.= "
	, $group_by as mygroup
	from $cdr_table
	where $where
	group by $group_by
	$having
	order by $order_by1 $order_type
	limit $i,$_max_rows
	";
	*/

	$query.= sprintf(
	"
	, %s as mygroup from %s
	where
	%s
	group by
	%s
	%s
	order by
	%s %s
	limit %d, %d
	",
	$group_by,
	addslashes($cdr_table),
	$where,
	$group_by,
	addslashes($having),
	addslashes($order_by1),
	addslashes($order_type),
	$i,
	$_max_rows
	);
	dprint_sql($query);

	$this->CDRdb->query($query);

	$this->showTableHeaderStatistics();
	while ($i<$maxrows) {
	$found = $i + 1;
	$this->CDRdb->next_record();

	$calls = $this->CDRdb->f('calls');
	$seconds = $this->CDRdb->f($this->durationField);
	$seconds = $this->CDRdb->f($this->durationField);
	$seconds_print = number_format($this->CDRdb->f($this->durationField), 0);
	$minutes = number_format($this->CDRdb->f($this->durationField)/60, 0, "", "");
	$minutes_print = number_format($this->CDRdb->f($this->durationField)/60, 0);
	$hours = $this->CDRdb->f('hours');

	$AcctInputOctets = number_format($this->CDRdb->f($this->inputTrafficField), 2, ".", "");
	$AcctOutputOctets = number_format($this->CDRdb->f($this->outputTrafficField), 2, ".", "");
	$NetRateIn = $this->CDRdb->f('netrate_in');
	$NetRateOut = $this->CDRdb->f('netrate_out');
	$SipMethod = $this->CDRdb->f($this->callTypeField);
	$AcctTerminateCause = $this->CDRdb->f($this->disconnectField);
	$mygroup = $this->CDRdb->f('mygroup');

	$zero = $this->CDRdb->f('zero');
	$nonzero = $this->CDRdb->f('nonzero');
	$success = number_format($nonzero/$calls*100, 2, ".", "");
	$failure = number_format($zero/$calls*100, 2, ".", "");

	$NetworkRateIn = number_format($NetRateIn, 2);
	$NetworkRateOut = number_format($NetRateOut, 2);
	$NetworkRate = max($NetworkRateIn, $NetworkRateOut);

	if ($this->priceField) {
	$price = $this->CDRdb->f($this->priceField);
	}

	$rr = floor($found/2);
	$mod=$found-$rr*2;

	if ($mod ==0) {
	$inout_color="lightgrey";
	} else {
	$inout_color="white";
	}

	$traceValue="";
	$mygroup_print = quoted_printable_decode($mygroup);

	if ($this->group_byOrig==$this->DestinationIdField) {
	if ($this->CDRTool['filter']['domain'] && $this->destinations[$this->CDRTool['filter']['domain']]) {
	list($_dst_id, $_dst_name) = $this->getPSTNDestinationId($mygroup, '', $this->CDRTool['filter']['domain']);
	$description=$_dst_name;
	} else {
	$description=$this->destinations[0]["default"][$mygroup]["name"];
	//list($_dst_id,$_dst_name)=$this->getPSTNDestinationId($mygroup);
	//$description=$_dst_name;
	}

	if ($mygroup) {
	$traceValue=$mygroup;
	} else {
	$traceValue="empty";
	}
	} elseif ($this->group_byOrig==$this->aNumberField) {
	// Normalize Called Station Id
	$N=$this->NormalizeNumber($mygroup);
	$mygroup_print=$N['username']."@".$N[domain];
	$description="";
	$traceField="a_number";
	$traceValue = urlencode($mygroup);
	} elseif ($this->group_byOrig==$this->CanonicalURIField) {
	$traceField="c_number";
	$traceValue = urlencode($mygroup);
	} elseif ($this->group_byOrig==$this->SipProxyServerField) {
	$traceField="sip_proxy";
	$traceValue = urlencode($mygroup);
	} elseif ($this->group_byOrig==$this->MediaProxyField) {
	$traceField="media_proxy";
	$traceValue = urlencode($mygroup);
	} elseif ($this->group_byOrig==$this->tlscnField) {
	$traceField="tlscn";
	$traceValue = urlencode($mygroup);
	} elseif ($this->group_byOrig==$this->SipCodecField) {
	$traceField="SipCodec";
	} elseif (preg_match("/UserAgent/", $this->group_byOrig)) {
	$traceField="UserAgent";
	} elseif (preg_match("/^BY/", $this->group_byOrig)) {
	$traceField="MONTHYEAR";
	} elseif ($this->group_byOrig==$this->callIdField) {
	$traceField="call_id";
	} elseif ($this->group_byOrig=="DAYOFWEEK") {
	if ($mygroup == "1") {
	$description="Sunday";
	} elseif ($mygroup == "2") {
	$description="Monday";
	} elseif ($mygroup == "3") {
	$description="Tuesday";
	} elseif ($mygroup == "4") {
	$description="Wednesday";
	} elseif ($mygroup == "5") {
	$description="Thursday";
	} elseif ($mygroup == "6") {
	$description="Friday";
	} elseif ($mygroup == "7") {
	$description="Saturday";
	}
	} elseif ($this->group_byOrig=="DAYOFMONTH") {
	$description =$this->CDRdb->f('day');
	} elseif ($this->group_byOrig=="DAYOFYEAR") {
	$description =$this->CDRdb->f('day');
	} elseif ($this->group_byOrig=="SourceIP") {
	$traceField="gateway";
	} elseif ($this->group_byOrig=="SipResponseCode") {
	$description =$this->disconnectCodesDescription[$mygroup];
	$traceField="sip_status";
	} elseif ($this->group_byOrig=="SipApplicationType") {
	$traceField="application";
	} elseif ($this->group_byOrig=="ServiceType") {
	$traceField="flow";
	} else {
	$description="";
	}

	if (!$traceField) {
	$traceField = $group_by;
	}

	if (!$traceValue) {
	$traceValue = $mygroup;
	}

	if (!$traceValue) {
	$traceValue="";
	$comp_type="empty";
	} else {
	$comp_type="begin";
	}

	$traceValue_enc = urlencode($traceValue);

	if (!$this->export) {
	print "
	<tr>
	<td><b>$found</b></td>
	<td align=right>$calls</td>
	<td align=right>$seconds_print</td>
	<td align=right>$minutes_print</td>
	<td align=right>$hours</td>
	";
	if ($perm->have_perm("showPrice")) {
	$pricePrint = number_format($price, 4, ".", "");
	} else {
	$pricePrint = 'x.xxx';
	}
	print "
	<td align=right>$pricePrint</td>
	<td align=right>$AcctInputOctets</td>
	<td align=right>$AcctOutputOctets</td>
	<td align=right>$success%</td>
	<td align=right>($nonzero calls)</td>
	<td align=right>$failure%</td>
	<td align=right>($zero calls)</td>
	<td>$mygroup_print</td>
	<td>$description</td>
	<td>";
	printf(
	"<a href=%s&%s=%s&%s_comp=%s target=_new>Display calls</a></td>",
	$url_calls,
	$traceField,
	$traceValue_enc,
	$traceField,
	$comp_type
	);
	print "</tr>";
	} else {
	print "$found,";
	print "$calls,";
	print "$seconds,";
	print "$minutes,";
	print "$hours,";
	if ($perm->have_perm("showPrice")) {
	$pricePrint=$price;
	} else {
	$pricePrint='x.xxx';
	}
	print "$pricePrint,";
	print "$AcctInputOctets,";
	print "$AcctOutputOctets,";
	print "$success,";
	print "$nonzero,";
	print "$failure,";
	print "$zero,";
	print "$mygroup_print,";
	print "$description";
	print "\n";
	}
	$i++;
	}

	if (!$this->export) {
	print "</table>";
	}
	} else {
	if (!$this->export) {
	// printf ("<div class='alert alert-info'><i style='font-size:13px' class='icon-info-sign'></i> For more information about each call click on its Id column.</div>");
	}

	if ($order_by=="zeroP" \|\| $order_by=="nonzeroP") {
	$order_by="timestamp";
	}
	$_max_rows = intval($this->maxrowsperpage);
	if (!$_max_rows) {
	$_max_rows = 10;
	}
	$query = sprintf(
	"select *, UNIX_TIMESTAMP($this->startTimeField) as timestamp from %s where %s order by %s %s limit %d, %d",
	addslashes($cdr_table),
	$where,
	addslashes($order_by),
	addslashes($order_type),
	intval($i),
	$_max_rows
	);

	$this->CDRdb->query($query);

	if ($this->CDRTool['filter']['aNumber']) {
	$this->showTableHeaderSubscriber();
	} else {
	if (!$this->export) {
	$this->showTableHeader();
	} else {
	$this->showExportHeader();
	}
	}

	while ($i<$maxrows) {
	global $found;
	$found = $i + 1;
	$this->CDRdb->next_record();

	$Structure = $this->_readCDRFieldsFromDB();
	//dprint_r($Structure);
	$CDR = new $this->CDR_class($this, $Structure);

	if ($this->CDRTool['filter']['aNumber']) {
	$CDR->showSubscriber();
	} else {
	if (!$this->export) {
	$CDR->show();
	} else {
	$CDR->export();
	}
	}
	$i++;
	}

	if (!$this->export) {
	print "</table>";
	}
	}
	$this->showPagination($this->next, $maxrows);
	}
	}

	function LoadDomains()
	{

	if (!$this->db_subscribers) {
	$log = printf("Error: Cannot load domains because db_subscribers is not defined in datasource %s", $this->cdr_source);
	print $log;
	syslog(LOG_NOTICE, $log);
	return false;
	}

	if (!is_object($this->AccountsDB)) {
	$log = printf("Error: AccountsDB is not a valid database object");
	print $log;
	syslog(LOG_NOTICE, $log);
	return false;
	}

	if (strlen($this->DATASOURCES[$this->cdr_source]['enableThor'])) {
	$this->domain_table = "sip_domains";
	} else {
	$this->domain_table = "domain";
	}

	$query = sprintf("select * from %s", $this->domain_table);

	if ($this->CDRTool['filter']['aNumber']) {
	$els = explode("@", $this->CDRTool['filter']['aNumber']);
	$query.= sprintf(" where domain = '%s' ", addslashes($els[1]));
	} elseif ($this->CDRTool['filter']['domain']) {
	$fdomain = $this->CDRTool['filter']['domain'];
	$query.=sprintf(" where domain = '%s' ", addslashes($fdomain));
	}

	if (!$this->AccountsDB->query($query)) {
	$log=sprintf("Database %s error: %s (%d) %s\n", $this->db_subscribers, $this->AccountsDB->Error, $this->AccountsDB->Errno, $query);
	print $log;
	syslog(LOG_NOTICE, $log);
	return false;
	}

	while ($this->AccountsDB->next_record()) {
	if ($this->AccountsDB->f('domain')) {
	$this->localDomains[$this->AccountsDB->f('domain')] = array(
	'name' => $this->AccountsDB->f('domain'),
	'reseller' => intval($this->AccountsDB->f('reseller_id'))
	);
	}
	}

	return count($this->localDomains);
	}

	function LoadTrustedPeers()
	{

	if (!$this->db_subscribers) {
	$log = printf(
	"Error: Cannot load trusted peers because db_subscribers is not defined in datasource %s",
	$this->cdr_source
	);
	print $log;
	syslog(LOG_NOTICE, $log);
	return false;
	}

	if (!is_object($this->AccountsDB)) {
	$log = printf("Error: AccountsDB is not a valid database object");
	print $log;
	syslog(LOG_NOTICE, $log);
	return false;
	}

	if (strlen($this->DATASOURCES[$this->cdr_source]['enableThor'])) {
	$this->trusted_table = "sip_trusted";
	} else {
	$this->trusted_table = "trusted_peers";
	}

	$query=sprintf("select * from %s", addslashes($this->trusted_table));

	if (!$this->AccountsDB->query($query)) {
	$log = sprintf("Database %s error: %s (%d) %s\n", $this->db_subscribers, $this->AccountsDB->Error, $this->AccountsDB->Errno, $query);
	print $log;
	syslog(LOG_NOTICE, $log);
	return false;
	}

	while ($this->AccountsDB->next_record()) {
	if ($this->AccountsDB->f('ip')) {
	$this->trustedPeers[$this->AccountsDB->f('ip')] = array(
	'ip' => $this->AccountsDB->f('ip'),
	'reseller' => intval($this->AccountsDB->f('reseller_id'))
	);
	}
	}

	return count($this->trustedPeers);
	}

	function getQuota($account)
	{

	if (!$this->quotaEnabled) {
	return true;
	}

	if (!$account) {
	return;
	}

	if (!is_object($this->AccountsDB)) {
	$log = printf("Error: AccountsDB is not a valid database object");
	print $log;
	syslog(LOG_NOTICE, $log);
	return false;
	}

	list($username, $domain) = explode("@", $account);

	if ($this->enableThor) {
	$query = sprintf("select * from sip_accounts where username = '%s' and domain = '%s'", addslashes($username), addslashes($domain));

	if (!$this->AccountsDB->query($query)) {
	$log = sprintf(
	"Database error for query 1 %s: %s (%s)",
	$query,
	$this->AccountsDB->Error,
	$this->AccountsDB->Errno
	);
	syslog(LOG_NOTICE, $log);
	return 0;
	}

	if ($this->AccountsDB->num_rows()) {
	$this->AccountsDB->next_record();
	$_profile=json_decode(trim($this->AccountsDB->f('profile')));
	return $_profile->quota;
	} else {
	return 0;
	}
	} else {
	$query=sprintf("select quota from subscriber where username = '%s' and domain = '%s'", addslashes($username), addslashes($domain));

	if (!$this->AccountsDB->query($query)) {
	$log = sprintf(
	"Database error for query %s: %s (%s)",
	$query,
	$this->AccountsDB->Error,
	$this->AccountsDB->Errno
	);
	syslog(LOG_NOTICE, $log);
	return 0;
	}

	if ($this->AccountsDB->num_rows()) {
	$this->AccountsDB->next_record();
	return $this->AccountsDB->f('quota');
	} else {
	return 0;
	}
	}
	}

	function getBlockedByQuotaStatus($account)
	{
	if (!$this->quotaEnabled) {
	return true;
	}

	if (!$account) {
	return 0;
	}

	if (!is_object($this->AccountsDB)) {
	$log = printf("Error: AccountsDB is not a valid database object");
	print $log;
	syslog(LOG_NOTICE, $log);
	return false;
	}

	list($username, $domain) = explode("@", $account);

	if ($this->enableThor) {
	$query = sprintf("select * from sip_accounts where username = '%s' and domain = '%s'", addslashes($username), addslashes($domain));

	if (!$this->AccountsDB->query($query)) {
	$log = sprintf(
	"Database error for query2 %s: %s (%s)",
	$query,
	$this->AccountsDB->Error,
	$this->AccountsDB->Errno
	);
	syslog(LOG_NOTICE, $log);
	return 0;
	}

	if ($this->AccountsDB->num_rows()) {
	$this->AccountsDB->next_record();

	$_profile=json_decode(trim($this->AccountsDB->f('profile')));
	if (in_array('quota', $_profile->groups)) {
	return 1;
	} else {
	return 0;
	}
	} else {
	return 0;
	}
	} else {
	$query=sprintf("select CONCAT(username,'@',domain) as account from grp where grp = 'quota' and username = '%s' and domain = '%s'", addslashes($username), addslashes($domain));

	if (!$this->AccountsDB->query($query)) {
	$log = sprintf("Database error for query %s: %s (%s)", $query, $this->AccountsDB->Error, $this->AccountsDB->Errno);
	syslog(LOG_NOTICE, $log);
	return 0;
	}

	if ($this->AccountsDB->num_rows()) {
	return 1;
	} else {
	return 0;
	}
	}

	return 0;
	}

	- function notifyLastSessions($count='200', $account='')
	+ public function notifyLastSessions($count='200', $account='')
	{
	// send emails with last missed and received sessions to subscribers in group $this->missed_calls_group

	$lockName = sprintf("%s:notifySessions", $this->cdr_source);

	if (!$this->getNormalizeLock($lockName)) {
	return true;
	}

	if (strlen($account)) {
	list($username, $domain) = explode('@', $account);
	if (!strlen($username) \|\| !strlen($domain)) {
	return false;
	}
	} else {
	$query=sprintf("select * from memcache where `key` = '%s'", 'notifySessionsLastRun');
	$this->cdrtool->query($query);
	if ($this->cdrtool->num_rows()) {
	$this->cdrtool->next_record();
	$lastRun=$this->cdrtool->f('value');
	if (Date('Y-m-d') == $lastRun) {
	$log=sprintf("Notify sessions script already run for date %s\n", $lastRun);
	print $log;
	syslog(LOG_NOTICE, $log);
	return true;
	}
	}
	}

	$this->notifySubscribers=array();

	require_once('Mail.php');
	require_once('Mail/mime.php');

	if ($this->enableThor) {
	$query=sprintf("select * from sip_accounts");
	if (strlen($account)) {
	$query=sprintf("select * from sip_accounts where username = '%s' and domain = '%s'", addslashes($username), addslashes($domain));
	}

	if (!$this->AccountsDB->query($query)) {
	$log = sprintf(
	"Database error for query %s: %s (%s)",
	$query,
	$this->AccountsDB->Error,
	$this->AccountsDB->Errno
	);
	syslog(LOG_NOTICE, $log);
	return 0;
	}

	if ($this->AccountsDB->num_rows()) {
	while ($this->AccountsDB->next_record()) {
	$_profile=json_decode(trim($this->AccountsDB->f('profile')));
	if (in_array($this->missed_calls_group, $_profile->groups)) {
	$this->notifySubscribers[$this->AccountsDB->f('username').'@'.$this->AccountsDB->f('domain')]=array('email'=>$this->AccountsDB->f('email'),'timezone' => $_profile->timezone);
	}
	}
	} else {
	return 0;
	}
	} else {
	$query = sprintf(
	"select CONCAT(username,'@',domain) as account,email_address,timezone from grp join subscriber on grp.subscriber_id =subscriber.id where grp = '%s'",
	addslashes($this->missed_calls_group)
	);
	if (strlen($account)) {
	$query.= sprintf(" and username = '%s' and domain = '%s' ", $username, $domain);
	}

	if (!$this->AccountsDB->query($query)) {
	$log = sprintf("Database error for query %s: %s (%s)", $query, $this->AccountsDB->Error, $this->AccountsDB->Errno);
	syslog(LOG_NOTICE, $log);
	return 0;
	}

	if ($this->AccountsDB->num_rows()) {
	while ($this->AccountsDB->next_record()) {
	$this->notifySubscribers[$this->AccountsDB->f('account')]=array('email'=>$this->AccountsDB->f('email_address'),'timezone' => $this->AccountsDB->f('timezone'));
	}
	} else {
	return 0;
	}
	}

	if (!count($this->notifySubscribers)) {
	return 0;
	}

	$j = 0;
	foreach (array_keys($this->notifySubscribers) as $_subscriber) {
	$j++;
	$_last_sessions=array();
	unset($textBody);
	unset($htmlBody);

	$query = sprintf(
	"
	SELECT
	*,
	UNIX_TIMESTAMP(%s) as timestamp
	FROM
	%s
	where
	(%s = '%s' or %s = '%s')
	and %s > DATE_ADD(NOW(), INTERVAL -1 day)
	order by %s desc
	limit 200",
	addslashes($this->startTimeField),
	addslashes($this->table),
	addslashes($this->usernameField),
	addslashes($_subscriber),
	addslashes($this->CanonicalURIField),
	addslashes($_subscriber),
	addslashes($this->startTimeField),
	addslashes($this->startTimeField)
	);

	if (!$this->CDRdb->query($query)) {
	$log = sprintf("Database error for query %s: %s (%s)", $query, $this->CDRdb->Error, $this->CDRdb->Errno);
	syslog(LOG_NOTICE, $log);
	print $log;
	return 0;
	}

	if (Date('d') == 1) {
	while ($this->CDRdb->next_record()) {
	$_last_sessions[] = array(
	'duration' => $this->CDRdb->f($this->durationField),
	'from' => $this->CDRdb->f($this->aNumberField),
	'to' => $this->CDRdb->f($this->cNumberField),
	'username' => $this->CDRdb->f($this->usernameField),
	'canonical' => $this->CDRdb->f($this->CanonicalURIField),
	'date' => getlocaltime($this->notifySubscribers[$_subscriber]['timezone'], $this->CDRdb->f('timestamp'))
	);
	}

	if (preg_match("/^(\w+)(\d{4})(\d{2})$/", $this->table, $m)) {
	$previousTable=$m[1].date('Ym', mktime(0, 0, 0, $m[3]-1, "01", $m[2]));
	$query = sprintf(
	"
	SELECT
	*,
	UNIX_TIMESTAMP(%s) as timestamp
	FROM
	%s
	where
	%s = '%s'
	and %s > DATE_ADD(NOW(), INTERVAL -1 day)
	order by
	%s desc
	limit 200
	",
	addslashes($this->startTimeField),
	addslashes($previousTable),
	addslashes($this->CanonicalURIField),
	addslashes($_subscriber),
	addslashes($this->startTimeField),
	addslashes($this->startTimeField)
	);

	if (!$this->CDRdb->query($query)) {
	$log = sprintf("Database error for query %s: %s (%s)", $query, $this->CDRdb->Error, $this->CDRdb->Errno);
	syslog(LOG_NOTICE, $log);
	print $log;
	return 0;
	}

	while ($this->CDRdb->next_record()) {
	$_last_sessions[] = array(
	'duration' => $this->CDRdb->f($this->durationField),
	'from' => $this->CDRdb->f($this->aNumberField),
	'to' => $this->CDRdb->f($this->cNumberField),
	'username' => $this->CDRdb->f($this->usernameField),
	'canonical' => $this->CDRdb->f($this->CanonicalURIField),
	'date' => getlocaltime($this->notifySubscribers[$_subscriber]['timezone'], $this->CDRdb->f('timestamp'))
	);
	}
	}
	} else {
	while ($this->CDRdb->next_record()) {
	$_last_sessions[] = array(
	'duration' => $this->CDRdb->f($this->durationField),
	'from' => $this->CDRdb->f($this->aNumberField),
	'to' => $this->CDRdb->f($this->cNumberField),
	'username' => $this->CDRdb->f($this->usernameField),
	'canonical' => $this->CDRdb->f($this->CanonicalURIField),
	'date' => getlocaltime($this->notifySubscribers[$_subscriber]['timezone'], $this->CDRdb->f('timestamp'))
	);
	}
	}

	if (!count($_last_sessions)) {
	continue;
	}

	$sessions=array(
	'missed' => array(),
	'received' => array(),
	'diverted' => array()
	);

	$have_sessions=0;

	foreach ($_last_sessions as $_s) {
	if ($_s['duration'] == 0 && $_s['canonical'] == $_subscriber) {
	$sessions['missed'][]=$_s;
	$have_sessions++;
	continue;
	}

	if ($_s['duration'] > 0 && $_s['canonical'] == $_subscriber) {
	$sessions['received'][]=$_s;
	$have_sessions++;
	continue;
	}

	if ($_s['from'] != $_subscriber && $_s['canonical'] != $_subscriber) {
	$sessions['diverted'][]=$_s;
	$have_sessions++;
	continue;
	}
	}

	if (!$have_sessions) {
	continue;
	}

	if (count($sessions['missed'])) {
	// missed sessions
	$textBody .= sprintf(
	"
	Missed sessions\n\n
	Id,Date,From,Duration\n
	"
	);

	$htmlBody .= sprintf("<h2>Missed Calls</h2>
	<p>
	<table border=0>
	<tr>
	<th>
	</th>
	<th>Date and Time
	</th>
	<th>Caller
	</th>
	</tr>
	");

	$i=0;
	foreach ($sessions['missed'] as $_session) {
	$i++;
	if ($i >= $count) {
	break;
	}
	$htmlBody .= sprintf(
	"
	<tr>
	<td>%s</td>
	<td>%s</td>
	<td><a href=sip:%s>sip:%s</a></td>
	</tr>
	",
	$i,
	$_session['date'],
	$_session['from'],
	$_session['from']
	);


	$txtBody.=sprintf(
	"%s,%s,%s,%s,%s\n",
	$i,
	$_session['date'],
	$_session['from'],
	$_session['to']
	);
	}

	$htmlBody.="</table>";
	}

	if (count($sessions['diverted'])) {
	// diverted sessions
	$textBody .= sprintf("Diverted Calls\n\n
	Id,Date,From,Diverted to\n
	");

	$htmlBody .= sprintf("<h2>Diverted Calls</h2>
	<p>
	<table border=0>
	<tr>
	<th>
	</th>
	<th>Date and Time
	</th>
	<th>Caller
	</th>
	<th>Diverted to
	</th>
	</tr>
	");

	$i=0;
	foreach ($sessions['diverted'] as $_session) {
	$i++;
	if ($i >= $count) break;

	$htmlBody.=sprintf(
	"
	<tr>
	<td>%s</td>
	<td>%s</td>
	<td><a href=sip:%s>sip:%s</a></td>
	<td>%s</td>
	</tr>
	",
	$i,
	$_session['date'],
	$_session['from'],
	$_session['from'],
	$_session['canonical']
	);

	$txtBody .= sprintf(
	"%s,%s,%s,%s\n",
	$i,
	$_session['date'],
	$_session['from'],
	$_session['canonical']
	);
	}

	$htmlBody.="</table>";
	}

	if (count($sessions['received'])) {
	// received sessions
	$textBody .= sprintf("Received Calls\n\nId,Date,From,Duration\n");

	$htmlBody .= sprintf(
	"<h2>Received Calls</h2>
	<p>
	<table border=0>
	<tr>
	<th></th>
	<th>Date and Time</th>
	<th>Caller</th>
	<th>Duration</th>
	</tr>"
	);

	$i=1;
	foreach ($sessions['received'] as $_session) {
	if ($i >= $count) {
	break;
	}

	$htmlBody .= sprintf(
	"<tr><td>%s</td><td>%s</td><td><a href=sip:%s>sip:%s</a></td><td>%s</td></tr>",
	$i,
	$_session['date'],
	$_session['from'],
	$_session['from'],
	$_session['duration']
	);


	$txtBody .= sprintf(
	"%s,%s,%s,%s\n",
	$i,
	$_session['date'],
	$_session['from'],
	$_session['duration']
	);

	$i++;
	}

	$htmlBody.="</table>";
	}

	$htmlBody.="<p>This is an automatically generated message, do not reply.";
	$txtBody.="\nThis is an automatically generated message, do not reply.\n";

	$crlf = "\n";
	$hdrs = array(
	'From'=> $this->CDRTool['provider']['fromEmail'],
	'Subject' => sprintf("Incoming Calls for %s on %s", $_subscriber, date('Y-m-d'))
	);

	$mime = new Mail_mime($crlf);
	$mime->setTXTBody($textBody);
	$mime->setHTMLBody($htmlBody);

	$body = $mime->get();
	$hdrs = $mime->headers($hdrs);

	$mail =& Mail::factory('mail');
	if (version_compare(PHP_VERSION, '8.0.0') >= 0) {
	$mail->sep = "\r\n";
	}
	$mail->send($this->notifySubscribers[$_subscriber]['email'], $hdrs, $body);

	$log=sprintf(
	"Notify %s at %s with last %d sessions\n",
	$_subscriber,
	$this->notifySubscribers[$_subscriber]['email'],
	count($_last_sessions)
	);
	print $log;
	syslog(LOG_NOTICE, $log);
	}

	$query = sprintf("update memcache set `value` = '%s' where `key` = '%s'", Date('Y-m-d'), 'notifySessionsLastRun');

	if (!$this->cdrtool->query($query)) {
	$log = sprintf("Database error for query %s: %s (%s)", $query, $this->cdrtool->Error, $this->cdrtool->Errno);
	print $log;
	syslog(LOG_NOTICE, $log);
	return false;
	}

	if (!$this->cdrtool->affected_rows()) {
	$query=sprintf("insert into memcache (`value`,`key`) values ('%s','%s')", Date('Y-m-d'), 'notifySessionsLastRun');
	if (!$this->cdrtool->query($query)) {
	if ($this->cdrtool->Errno != 1062) {
	$log=sprintf("Database error for query %s: %s (%s)", $query, $this->cdrtool->Error, $this->cdrtool->Errno);
	print $log;
	syslog(LOG_NOTICE, $log);
	return false;
	}
	}
	}
	}

	function getCallerId($account)
	{
	if (!$account) {
	return null;
	}

	if ($this->callerid_cache[$account]) {
	return $this->callerid_cache[$account];
	}

	list($username, $domain) = explode('@', $account);

	if ($this->enableThor) {
	$query=sprintf("select * from sip_accounts where username = '%s' and domain = '%s'", addslashes($username), addslashes($domain));

	if (!$this->AccountsDB->query($query)) {
	$log=sprintf("Database error for query %s: %s (%s)", $query, $this->AccountsDB->Error, $this->AccountsDB->Errno);
	syslog(LOG_NOTICE, $log);
	return null;
	}

	if ($this->AccountsDB->num_rows()) {
	$this->AccountsDB->next_record();
	$_profile=json_decode(trim($this->AccountsDB->f('profile')));
	$this->callerid_cache[$account]=$_profile->rpid;
	return $_profile->rpid;
	}
	} else {
	$query=sprintf("select rpid from subscriber where username = '%s' and domain = '%s'", addslashes($username), addslashes($domain));

	if (!$this->AccountsDB->query($query)) {
	$log=sprintf("Database error for query %s: %s (%s)", $query, $this->AccountsDB->Error, $this->AccountsDB->Errno);
	syslog(LOG_NOTICE, $log);
	return null;
	}

	if ($this->AccountsDB->num_rows()) {
	$this->AccountsDB->next_record();
	$rpid = $this->AccountsDB->f('rpid');
	$this->callerid_cache[$account]=$rpid;
	return $rpid;
	}
	}
	return null;
	}

	function rate_on_net_enabled($username, $domain)
	{
	if ($this->enableThor) {
	$query=sprintf("select * from sip_accounts where username = '%s' and domain = '%s'", addslashes($username), addslashes($domain));
	if (!$this->AccountsDB->query($query)) {
	$log=sprintf("Database error for query %s: %s (%s)", $query, $this->AccountsDB->Error, $this->AccountsDB->Errno);
	syslog(LOG_NOTICE, $log);
	return false;
	}

	if ($this->AccountsDB->num_rows()) {
	while ($this->AccountsDB->next_record()) {
	$_profile = json_decode(trim($this->AccountsDB->f('profile')));
	if (in_array($this->rate_on_net_group, $_profile->groups)) {
	return true;
	}
	}
	}
	}
	return false;
	}
	}

	class CDR_opensips extends CDR
	{

	- function __construct($parent, $CDRfields)
	+ public function __construct($parent, $CDRfields)
	{

	$this->CDRS = $parent;

	$this->cdr_source = $this->CDRS->cdr_source;

	foreach (array_keys($this->CDRS->CDRFields) as $field) {
	$this->$field = $CDRfields[$this->CDRS->CDRFields[$field]];
	}

	if ($this->CanonicalURI) {
	$this->CanonicalURI = quoted_printable_decode($this->CanonicalURI);
	}

	if ($this->RemoteAddress) {
	$this->RemoteAddress = quoted_printable_decode($this->RemoteAddress);
	}

	if ($this->BillingPartyId) {
	$this->BillingPartyId = quoted_printable_decode($this->BillingPartyId);
	}

	if ($this->aNumber) {
	$this->aNumber = quoted_printable_decode($this->aNumber);
	}

	if ($this->cNumber) {
	$this->cNumber = quoted_printable_decode($this->cNumber);
	}

	if ($this->SipRPID) {
	$this->SipRPID = quoted_printable_decode($this->SipRPID);
	}

	if (!$this->application && $this->SipMethod) {
	$_method=strtolower($this->SipMethod);
	if ($_method == 'message') {
	$this->application = 'message';
	$this->stopTimeNormalized=$this->startTime;
	} else {
	$this->application = 'audio';
	}
	}

	if ($this->application == 'message') {
	$this->stopTimeNormalized=$this->startTime;
	}

	$this->application=strtolower($this->application);

	$this->application_print=quoted_printable_decode($this->application);

	$this->FromHeaderPrint = quoted_printable_decode($this->FromHeader);
	if (strstr($this->FromHeaderPrint, ';')) {
	$_els=explode(";", $this->FromHeaderPrint);
	$this->FromHeaderPrint = $_els[0];
	}

	$this->FromHeaderPrint = htmlentities($this->FromHeaderPrint);

	$this->UserAgentPrint = quoted_printable_decode($this->UserAgent);

	$app_prefix = preg_replace('/[.].*$/', '', $this->application);
	if (!in_array($app_prefix, $this->supportedApplicationTypes)) {
	$log=sprintf("Changing application from %s to %s\n", $this->application, $this->defaultApplicationType);
	syslog(LOG_NOTICE, $log);
	$this->application = $this->defaultApplicationType;
	}

	//$this->applicationNormalized=$this->application;

	if ($this->aNumber) {
	$NormalizedNumber = $this->CDRS->NormalizeNumber($this->aNumber, "source");
	$this->aNumberPrint = $NormalizedNumber['NumberPrint'];
	$this->aNumberNormalized = $NormalizedNumber['Normalized'];
	$this->aNumberUsername = $NormalizedNumber['username'];
	$this->aNumberDomain = $NormalizedNumber['domain'];
	}

	if (!$this->BillingPartyId \|\| $this->BillingPartyId == 'n/a') {
	$this->BillingPartyId=$this->aNumberPrint;
	}

	$this->ResellerId=0;
	// calculate reseller
	$_billing_party_els=explode("@", $this->BillingPartyId);
	if ($this->isBillingPartyLocal()) {
	$this->ResellerId = $this->CDRS->localDomains[$_billing_party_els[1]]['reseller'];
	} else {
	if (!strlen($_billing_party_els[0])) {
	$this->BillingPartyId=$_billing_party_els[1];
	}
	if (count($_billing_party_els) == 2) {
	if (!$this->domain) {
	$this->domain=$_billing_party_els[1];
	}
	if ($this->CDRS->localDomains[$_billing_party_els[1]]['reseller']) {
	$this->ResellerId = $this->CDRS->localDomains[$_billing_party_els[1]]['reseller'];
	} elseif ($this->CDRS->trustedPeers[$_billing_party_els[1]]['reseller']) {
	$this->ResellerId = $this->CDRS->trustedPeers[$_billing_party_els[1]]['reseller'];
	}
	} elseif (count($_billing_party_els)==1) {
	$this->ResellerId=$this->CDRS->trustedPeers[$_billing_party_els[0]]['reseller'];
	}
	}

	if (!strlen($this->ResellerId)) {
	$this->ResellerId = 0;
	}

	$this->BillingPartyId=strtolower($this->BillingPartyId);

	$this->BillingPartyIdPrint = $this->BillingPartyId;

	$this->domainNormalized = $this->domain;

	if (is_array($this->CDRS->DATASOURCES[$this->cdr_source]['domainTranslation_SourceIP'])
	&& isset($this->CDRS->DATASOURCES[$this->cdr_source]['domainTranslation_SourceIP'][$this->SourceIP])
	&& strlen($this->CDRS->DATASOURCES[$this->cdr_source]['domainTranslation_SourceIP'][$this->SourceIP])
	) {
	$this->domainNormalized=$this->CDRS->DATASOURCES[$this->cdr_source]['domainTranslation_SourceIP'][$this->SourceIP];
	} elseif (is_array($this->CDRS->DATASOURCES[$this->cdr_source]['domainTranslation'])
	&& isset($this->CDRS->DATASOURCES[$this->cdr_source]['domainTranslation'][$this->domain])
	&& strlen($this->CDRS->DATASOURCES[$this->cdr_source]['domainTranslation'][$this->domain])
	) {
	$this->domainNormalized=$this->CDRS->DATASOURCES[$this->cdr_source]['domainTranslation'][$this->domain];
	}

	$this->domainNormalized=strtolower($this->domainNormalized);

	$this->RemoteAddressPrint=quoted_printable_decode($this->RemoteAddress);

	$_timestamp_stop=$this->timestamp+$this->duration;

	$this->dayofweek = date("w", $this->timestamp);
	$this->hourofday = date("G", $this->timestamp);
	$this->dayofyear = date("Y-m-d", $this->timestamp);

	// Called Station ID or cNumber should not be used for rating purposes because
	// it is chosen by the subscriber but the Proxy rewrites it into a different
	// final destination (the Canonical URI)

	// Canonical URI is the final logical SIP destination after all
	// lookups like aliases, usrloc , call forwarding, ENUM
	// mappings or PSTN gateways but before the DNS lookup
	// Canonical URI must be saved in the SIP Proxy and added as an extra
	// Radius attribute in the Radius START packet

	if (!$this->CanonicalURI) {
	if ($this->RemoteAddress) {
	$this->CanonicalURI=$this->RemoteAddress;
	} elseif ($this->cNumber) {
	$this->CanonicalURI=$this->cNumber;
	}
	}

	if ($this->CanonicalURI) {
	$this->CanonicalURIPrint = $this->CanonicalURI;
	$NormalizedNumber = $this->CDRS->NormalizeNumber(
	$this->CanonicalURI,
	"destination",
	$this->BillingPartyId,
	$this->domain,
	$this->gateway,
	'',
	$this->ENUMtld,
	$this->ResellerId
	);
	$this->CanonicalURINormalized = $NormalizedNumber['Normalized'];
	$this->CanonicalURIUsername = $NormalizedNumber['username'];
	$this->CanonicalURIDomain = $NormalizedNumber['domain'];
	$this->CanonicalURIPrint = $NormalizedNumber['NumberPrint'];
	$this->CanonicalURIDelimiter = $NormalizedNumber['delimiter'];
	$this->CanonicalURIE164 = $NormalizedNumber['E164'];

	// Destination Id is used for rating purposes
	$this->DestinationId = $NormalizedNumber['DestinationId'];
	$this->destinationName = $NormalizedNumber['destinationName'];
	$this->region = $NormalizedNumber['region'];
	}

	if ($this->cNumber) {
	$NormalizedNumber = $this->CDRS->NormalizeNumber(
	$this->cNumber,
	"destination",
	$this->BillingPartyId,
	$this->domain,
	$this->gateway,
	'',
	$this->ENUMtld,
	$this->ResellerId
	);
	$this->cNumberNormalized = $NormalizedNumber['Normalized'];
	$this->cNumberUsername = $NormalizedNumber['username'];
	$this->cNumberDomain = $NormalizedNumber['domain'];
	$this->cNumberPrint = $NormalizedNumber['username'].$NormalizedNumber['delimiter'].$NormalizedNumber['domain'];
	$this->cNumberDelimiter = $NormalizedNumber['delimiter'];
	$this->cNumberE164 = $NormalizedNumber['E164'];
	}

	if ($this->RemoteAddress) {
	// Next hop is the real destination after all lookups including DNS
	$NormalizedNumber = $this->CDRS->NormalizeNumber(
	$this->RemoteAddress,
	"destination",
	$this->BillingPartyId,
	$this->domain,
	$this->gateway,
	'',
	$this->ENUMtld,
	$this->ResellerId
	);
	$this->RemoteAddressPrint = $NormalizedNumber['NumberPrint'];
	$this->RemoteAddressNormalized = $NormalizedNumber['Normalized'];
	$this->RemoteAddressDestinationId = $NormalizedNumber['DestinationId'];
	$this->RemoteAddressDestinationName = $NormalizedNumber['destinationName'];
	$this->RemoteAddressUsername = $NormalizedNumber['username'];
	$this->RemoteAddressDelimiter = $NormalizedNumber['delimiter'];
	$this->RemoteAddressE164 = $NormalizedNumber['E164'];

	$this->remoteGateway = $NormalizedNumber['domain'];
	$this->remoteUsername = $NormalizedNumber['username'];
	}

	$this->isCalleeLocal();
	$this->isCallerLocal();

	if ($this->CallerIsLocal) {
	if ($this->aNumberPrint == $this->BillingPartyId) {
	// call is not diverted

	if ($this->CalleeIsLocal) {
	$this->flow = 'on-net';
	} else {
	$this->flow = 'outgoing';
	}
	} else {
	// call is diverted
	if ($this->CalleeIsLocal) {
	$this->flow = 'on-net-diverted-on-net';
	} else {
	$this->flow = 'on-net-diverted-off-net';
	}
	}
	} else {
	if ($this->isBillingPartyLocal()) {
	// call is diverted by local user
	if ($this->CalleeIsLocal) {
	$this->flow = 'diverted-on-net';
	} else {
	$this->flow = 'diverted-off-net';
	}
	} elseif ($this->CalleeIsLocal) {
	$this->flow = 'incoming';
	} else {
	// transit from trusted peer
	$this->flow = 'transit';
	}
	}

	if ((
	$this->flow == 'on-net'
	\|\| $this->flow == 'diverted-on-net'
	\|\| $this->flow == 'on-net-diverted-on-net'
	)
	&& $this->application == 'audio'
	&& $this->CDRS->rating_settings['rate_on_net_calls']
	&& $this->CDRS->rate_on_net_enabled($_billing_party_els[0], $_billing_party_els[1])
	&& !$this->DestinationId
	&& $this->CalleeCallerId
	) {
	$_dest = preg_replace("/^\+(\d+)$/", "00$1", $this->CalleeCallerId);
	$NormalizedNumber = $this->CDRS->NormalizeNumber(
	$_dest,
	"destination",
	$this->BillingPartyId,
	$this->domain,
	$this->gateway,
	'',
	$this->ENUMtld,
	$this->ResellerId
	);
	$this->DestinationId = $NormalizedNumber['DestinationId'];
	$this->destinationName = $NormalizedNumber['destinationName'];
	}

	if ($this->CDRS->rating_settings['rate_on_net_calls']
	&& $this->CDRS->rating_settings['rate_on_net_diverted_calls']
	&& ( $this->flow == 'on-net-diverted-off-net'
	\|\| $this->flow == 'on-net-diverted-on-net'
	\|\| $this->flow == 'diverted-on-net'
	\|\| $this->flow == 'diverted-off-net'
	)
	&& !$this->normalized
	&& $this->duration != '0'
	&& $this->disconnect == $this->disconnectOrig
	) {
	$query = sprintf(
	"
	update
	%s
	set
	AcctStopTime ='%s',
	Normalized='0',
	AcctSessionTime='%s',
	SipResponseCode='200'
	where
	AcctSessionId='%s'
	and SipFromTag='%s'
	and SipToTag!='%s'
	and (
	ServiceType='on-net'
	or ServiceType='on-net-diverted-on-net'
	or ServiceType='diverted-on-net'
	or ServiceType='incoming')
	and AcctSessionTime=''
	",
	$this->CDRS->table,
	$this->stopTime,
	$this->duration,
	$this->callId,
	$this->SipFromTag,
	$this->SipToTag
	);
	$this->tdb = new DB_radius;
	dprint_sql($query);
	$this->tdb->query($query);
	}

	if ($this->application == "presence") {
	$this->destinationPrint = $this->cNumberUsername.$this->cNumberDelimiter.$this->cNumberDomain;
	$this->DestinationForRating = $this->cNumberNormalized;
	} else {
	if (!$this->DestinationId) {
	if ($this->CanonicalURIDomain) {
	$this->destinationPrint = $this->CanonicalURIUsername.$this->CanonicalURIDelimiter.$this->CanonicalURIDomain;
	} else {
	$this->destinationPrint = $this->cNumberUsername.$this->cNumberDelimiter.$this->cNumberDomain;
	}

	if (strstr($this->CanonicalURINormalized, '@')) {
	$this->DestinationForRating = $this->CanonicalURINormalized;
	} else {
	$this->DestinationForRating = $this->RemoteAddressNormalized;
	}
	} else {
	$this->DestinationForRating = $this->CanonicalURINormalized;
	$this->destinationPrint = $this->CanonicalURIPrint;
	}
	}

	if ($this->inputTraffic) {
	$this->inputTrafficPrint = number_format($this->inputTraffic/1024, 2);
	} else {
	$this->inputTrafficPrint = 0;
	}

	if ($this->outputTraffic) {
	$this->outputTrafficPrint = number_format($this->outputTraffic/1024, 2);
	} else {
	$this->outputTrafficPrint = 0;
	}

	if (!$CDRfields['skip_fix_prepaid_duration']) {
	if (!$this->normalized && $this->callId) {
	// fix the duration of prepaid sessions if the prepaid duration is different than radius calculated duration
	$query = sprintf(
	"
	select
	duration
	from
	prepaid_history
	where
	session = '%s'
	and destination = '%s'
	order by id
	desc limit 1
	",
	addslashes($this->callId),
	addslashes($this->destinationPrint) // must be synced with maxsession time
	);

	if ($this->CDRS->cdrtool->query($query)) {
	if ($this->CDRS->cdrtool->num_rows()) {
	$this->CDRS->cdrtool->next_record();
	$this->durationNormalized = $this->CDRS->cdrtool->f('duration');
	$this->durationPrint = sec2hms($this->durationNormalized);
	} else {
	$this->durationPrint = sec2hms($this->duration);
	}
	} else {
	$log = sprintf(
	"Database error for query %s: %s (%s)",
	$query,
	$this->CDRS->cdrtool->Error,
	$this->CDRS->cdrtool->Errno
	);
	syslog(LOG_NOTICE, $log);
	}
	} else {
	$this->durationPrint = sec2hms($this->duration);
	}
	} else {
	$this->durationPrint = sec2hms($this->duration);
	}

	if ($this->disconnect) {
	$this->disconnectPrint = $this->NormalizeDisconnect($this->disconnect);
	}

	if ($this->disconnectOrig != $this->disconnect
	&& $this->disconnect
	&& $this->CDRS->rating_settings['rate_on_net_diverted_calls']) {
	$this->disconnectOrigPrint = $this->CDRS->disconnectCodesDescription[$this->disconnectOrig]." (".$this->disconnectOrig.")";
	}

	$this->traceIn();
	$this->traceOut();

	$this->obfuscateCallerId();

	if ($this->CDRS->rating) {
	global $perm;
	if (is_object($perm) && $perm->have_perm("showPrice")) {
	$this->pricePrint=$this->price;
	} else {
	$this->pricePrint='x.xxx';
	}
	}
	}

	private function buildCDRdetail()
	{
	global $perm;
	global $found;

	if (!is_object($perm)) return;

	$this->geo_location = $this->lookupGeoLocation($this->SourceIP);

	$this->cdr_details = "
	<div class=\"alert alert-info\" style='color: black'>
	<div class='row-fluid'>
	<div class='span4'>
	<h5>SIP Signalling</h5>

	";

	$this->cdr_details .= sprintf(
	"<a href=%s&call_id=%s><font color=orange>Click here to show only this call id</font></a>",
	$this->CDRS->url_run,
	urlencode($this->callId)
	);

	if ($this->CDRS->sipTrace) {
	$trace_query = array(
	'cdr_source' => $this->CDRS->sipTrace,
	'callid' => quoted_printable_decode($this->callId),
	'fromtag' => quoted_printable_decode($this->SipFromTag),
	'totag' => quoted_printable_decode($this->SipToTag),
	'proxyIP' => $this->SipProxyServer
	);

	$this->traceLink = sprintf(
	"<a href=\"javascript:void(null);\" onClick=\"return window.open('sip_trace.phtml?%s', '_blank','toolbar=0,status=0,menubar=0,scrollbars=1,resizable=1,width=1300px,height=600')\">
	<font color=red>Click here for the SIP trace</font></a>  ",
	http_build_query($trace_query)
	);

	$this->cdr_details .= "
	<div class=\"row-fluid\">
	<div class=\"span3\">Call id:</div>
	<div class=\"span9\">$this->callId </div>
	</div>
	";
	}

	$this->cdr_details .= sprintf(
	"
	<div class=\"row-fluid\">
	<div class=\"span12\">%s</div>
	</div>
	",
	$this->traceLink
	);

	$this->cdr_details .= "
	<div class=\"row-fluid\">
	<div class=\"span3\">From tag: </div>
	<div class=\"span9\">$this->SipFromTag</div>
	</div>
	<div class=\"row-fluid\">
	<div class=\"span3\">To tag: </div>
	<div class=\"span9\">$this->SipToTag</div>
	</div>
	<div class=\"row-fluid\">
	<div class=\"span3\">Start Time:</div>
	<div class=\"span9\">$this->startTime $providerTimezone</div>
	</div>
	<div class=\"row-fluid\">
	<div class=\"span3\">Stop Time:</div>
	<div class=\"span9\">$this->stopTime</div>
	</div>
	";

	$this->cdr_details .= sprintf(
	"
	<div class=\"row-fluid\">
	<div class=\"span3\">Country:</div>
	<div class=\"span9\">%s</div>
	</div>
	",
	$this->geo_location
	);

	$this->cdr_details .= "
	<div class=\"row-fluid\">
	<div class=\"span3\">Method:</div>
	<div class=\"span9\">$this->SipMethod from <i>$this->SourceIP:$this->SourcePort</i></div>
	</div>
	<div class=\"row-fluid\">
	<div class=\"span3\">From:</div>
	<div class=\"span9\">$this->aNumberPrint</div>
	</div>

	<div class=\"row-fluid\">
	<div class=\"span3\">From Header:</div>
	<div class=\"span9\">$this->FromHeaderPrint</div>
	</div>
	<div class=\"row-fluid\">
	<div class=\"span3\">User Agent:</div>
	<div class=\"span9\">$this->UserAgentPrint</div>
	</div>
	<div class=\"row-fluid\">
	<div class=\"span3\">Domain:</div>
	<div class=\"span9\">$this->domain</div>
	</div>
	<div class=\"row-fluid\">
	<div class=\"span3\">To (dialed URI):</div>
	<div class=\"span9\">$this->cNumberPrint</div>
	</div>
	";

	if ($perm->have_perm("showCallerId") && $this->SipRPID) {
	$this->cdr_details .= sprintf(
	"
	<div class=\"row-fluid\">
	<div class=\"span3\">PAI Header: </div>
	<div class=\"span9\">%s</div>
	</div>
	",
	htmlentities($this->SipRPIDPrint)
	);
	}

	if ($this->tlscn) {
	$this->cdr_details .= sprintf(
	"
	<div class=\"row-fluid\">
	<div class=\"span3\">TLS Common Name: </div>
	<div class=\"span9\">%s</div>
	</div>
	",
	htmlentities($this->tlscn)
	);
	}

	if ($this->CanonicalURI) {
	$this->cdr_details .= sprintf(
	"
	<div class=\"row-fluid\">
	<div class=\"span3\">Canonical URI: </div>
	<div class=\"span9\">%s</div>
	</div>
	",
	htmlentities($this->CanonicalURI)
	);
	}

	$this->cdr_details .= sprintf(
	"
	<div class=\"row-fluid\">
	<div class=\"span3\">Next Hop URI:</div>
	<div class=\"span9\">%s</div>
	</div>
	",
	htmlentities($this->RemoteAddress)
	);

	if ($this->DestinationId) {
	$this->cdr_details .= "
	<div class=\"row-fluid\">
	<div class=\"span3\">Destination: </div>
	<div class=\"span9\">$this->destinationName ($this->DestinationId)</div>
	</div>
	";
	}

	if ($this->ENUMtld && $this->ENUMtld != 'none' && $this->ENUMtld != 'N/A') {
	$this->cdr_details .= "
	<div class=\"row-fluid\">
	<div class=\"span3\">ENUM TLD: </div>
	<div class=\"span9\">$this->ENUMtld</div>
	</div>
	";
	}

	if ($this->CalleeCallerId) {
	$this->cdr_details .= "
	<div class=\"row-fluid\">
	<div class=\"span3\">Called ID: </div>
	<div class=\"span9\">$this->CalleeCallerId</div>
	</div>
	";
	}

	$this->cdr_details .= "
	<div class=\"row-fluid\">
	<div class=\"span3\">Billing Party:</div>
	<div class=\"span9\"><font color=brown>$this->BillingPartyIdPrint</font></div>
	</div>
	<div class=\"row-fluid\">
	<div class=\"span3\">Reseller:</div>
	<div class=\"span9\"><font color=brown>$this->ResellerId</font></div>
	</div>
	</div>
	";

	$this->cdr_details .= "<div class='span3'>";

	if ($this->application != 'message') {
	$this->cdr_details .= "<h5>Media Streams</h5>";

	if ($this->CDRS->mediaTrace) {
	$media_query = array(
	'cdr_source' => $this->CDRS->mediaTrace,
	'callid' => quoted_printable_decode($this->callId),
	'fromtag' => quoted_printable_decode($this->SipFromTag),
	'totag' => quoted_printable_decode($this->SipToTag),
	'proxyIP' => $this->SipProxyServer
	);

	$this->mediaTraceLink = sprintf(
	"<a href=\"javascript:void(null);\" onClick=\"return window.open('media_trace.phtml?%s', '_blank',
	'toolbar=0,status=0,menubar=0,scrollbars=1,resizable=1,width=800,height=730')\">Click here for media information</a>  ",
	http_build_query($media_query)
	);

	$this->cdr_details .= sprintf(
	"
	<div class=\"row-fluid\">
	<div class='span12'>%s</div>
	</div>
	",
	$this->mediaTraceLink
	);
	}

	$sessionId = rtrim(base64_encode(hash('md5', $this->callId, true)), "=");
	$this->cdr_details .= "
	<div class=\"row-fluid\">
	<div class=\"span5\">Session ID: </div>
	<div class=\"span7\">$sessionId</div>
	</div>
	";

	$this->SipCodec = quoted_printable_decode($this->SipCodec);

	if ($this->SipCodec) {
	$this->cdr_details .= "
	<div class=\"row-fluid\">
	<div class=\"span5\">Codecs: </div>
	<div class=\"span7\">$this->SipCodec</div>
	</div>
	";
	}

	$this->cdr_details .= "
	<div class=\"row-fluid\">
	<div class=\"span5\">Caller RTP: </div>
	<div class=\"span7\">$this->inputTrafficPrint KB</div>
	</div>
	<div class=\"row-fluid\">
	<div class=\"span5\">Called RTP: </div>
	<div class=\"span7\">$this->outputTrafficPrint KB</div>
	</div>
	";

	if ($this->MediaInfo) {
	$this->cdr_details .= "
	<div class=\"row-fluid\">
	<div class=\"span5\">Media Info:</div>
	<div class=\"span7\"><font color=red>$this->MediaInfo</font></div>
	</div>
	";
	}

	$this->cdr_details .= "
	<div class=\"row-fluid\">
	<div class=\"span5\">Applications: </div>
	<div class=\"span7\">$this->application_print</div>
	</div>
	";
	}


	if ($this->SipUserAgents) {
	$this->SipUserAgents = quoted_printable_decode($this->SipUserAgents);

	$callerAgents = explode("+", $this->SipUserAgents);
	$callerUA = htmlentities($callerAgents[0]);
	$calledUA = htmlentities($callerAgents[1]);

	$this->cdr_details.= "
	<div class=\"row-fluid\">
	<div class=\"span5\">Caller SIP UA: </div>
	<div class=\"span7\">$callerUA</div>
	</div>
	<div class=\"row-fluid\">
	<div class=\"span5\">Called SIP UA: </div>
	<div class=\"span7\">$calledUA</div>
	</div>
	";
	}

	$this->cdr_details.= "
	</div>";


	if ($perm->have_perm("showPrice") && $this->normalized) {
	$this->cdr_details.= "
	<div class=\"span3\">
	<h5>Rating</h5>
	";

	if ($this->price > 0 \|\| $this->rate) {
	$this->ratePrint=nl2br($this->rate);
	$this->cdr_details.= "
	<div class=\"row-fluid\">
	$this->ratePrint
	</div>
	";
	} else {
	$this->cdr_details.= "
	<div class=\"row-fluid\">
	Free call
	</div>
	";
	}

	$this->cdr_details.= "
	</div>
	";
	}

	$this->cdr_details.= "
	</div>
	</div>
	";
	}

	function traceIn()
	{
	$datasource=$this->CDRS->traceInURL[$this->SourceIP];
	global $DATASOURCES;

	if (!$datasource \|\| !$DATASOURCES[$datasource]) {
	return;
	}

	$tplus = $this->timestamp+$this->duration+300;
	$tmin = $this->timestamp-300;
	$c_number = $this->remoteUsername;
	$cdr_table = Date('Ym', time($this->timestamp));

	$this->traceIn =
	"<a href=callsearch.phtml".
	"?cdr_source=$datasource".
	"&cdr_table=$cdr_table".
	"&trace=1".
	"&action=search".
	"&c_number=$c_number".
	"&c_number_comp=begins".
	"&begin_datetime=$tmin".
	"&end_datetime=$tplus".
	" target=bottom>".
	"In".
	"</a>";
	}

	function traceOut()
	{
	$datasource = $this->CDRS->traceOutURL[$this->remoteGateway];
	global $DATASOURCES;

	if (!$datasource \|\| !$DATASOURCES[$datasource]) {
	return;
	}

	$tplus = $this->timestamp+$this->duration+300;
	$tmin = $this->timestamp-300;
	$c_number = preg_replace("/^(0+)/", "", $this->remoteUsername);
	$cdr_table = Date('Ym', time($this->timestamp));

	$this->traceOut=
	"<a href=callsearch.phtml".
	"?cdr_source=$datasource".
	"&cdr_table=$cdr_table".
	"&trace=1".
	"&action=search".
	"&c_number=$c_number".
	"&c_number_comp=contain".
	"&begin_datetime=$tmin".
	"&end_datetime=$tplus".
	" target=bottom>".
	"Out".
	"</a>";
	}

	public function show()
	{
	$this->buildCDRdetail();

	global $found;
	global $perm;

	$rr = floor($found / 2);
	$mod = $found - $rr * 2;

	if ($mod == 0) {
	$inout_color = "#F9F9F9";
	} else {
	$inout_color = "white";
	}

	$this->ratePrint = nl2br($this->rate);

	if ($this->CDRS->Accounts[$this->BillingPartyId]['timezone']) {
	$timezone_print = $this->CDRS->Accounts[$this->BillingPartyId]['timezone'];
	} else {
	$timezone_print = $this->CDRS->CDRTool['provider']['timezone'];
	}

	$found_print = $found;

	if ($this->normalized) {
	$found_print .= 'N';
	}

	$providerTimezone = $this->CDRS->CDRTool['provider']['timezone'];

	print "
	<tr rel=tooltip data-placement='bottom' data-original-title='For more information about this call click the row.'>
	<td valign=top onClick=\"return toggleVisibility('row$found')\"><a href=#>$found_print</a></td>
	<td valign=top onClick=\"return toggleVisibility('row$found')\"><nobr>$this->startTime</nobr></td>
	<td valign=top onClick=\"return toggleVisibility('row$found')\"><nobr>$this->application $this->flow</nobr></td>
	<td valign=top onClick=\"return toggleVisibility('row$found')\"><nobr>$this->aNumberPrint</td>
	<td valign=top onClick=\"return toggleVisibility('row$found')\"><nobr>$this->geo_location</td>
	<td valign=top onClick=\"return toggleVisibility('row$found')\">$this->SipProxyServer</td>
	<td valign=top onClick=\"return toggleVisibility('row$found')\">$this->MediaProxy</td>
	<td valign=top><nobr>$this->destinationPrint</nobr>
	";

	if ($this->DestinationId) {
	if ($this->DestinationId != $this->CanonicalURI) {
	print " ($this->destinationName $this->DestinationId)";
	} else {
	print " ($this->destinationName)";
	}
	}

	print "</td>";

	if (!$this->normalized) {
	if ($this->duration > 0) {
	print "<td valign=top align=left colspan=4><font color=red>$this->duration(s)</a></td>";
	} else {
	print "<td valign=top align=left colspan=4><font color=red>in progress</a></td>";
	}
	} else {
	print "
	<td valign=top align=right>$this->durationPrint</td>
	<td valign=top align=right>$this->pricePrint</td>
	<td valign=top align=right>$this->inputTrafficPrint </td>
	<td valign=top align=right>$this->outputTrafficPrint</td>
	";
	}

	$SIPclass=substr($this->disconnect, 0, 1);

	if ($SIPclass=="6") {
	$status_color="<span class=\"pull-right label label-important\">";
	} elseif ($SIPclass == "5") {
	$status_color="<span class=\"pull-right label label-important\">";
	} elseif ($SIPclass == "4") {
	$status_color="<span class=\"pull-right label label-info\">";
	} elseif ($SIPclass == "3") {
	$status_color="<span class=\"pull-right label label-success\">";
	} elseif ($SIPclass == "2") {
	$status_color="<span class=\"pull-right label label-success\">";
	} else {
	$status_color="<span class=\"pull-right label\">";
	}

	if ($this->disconnectOrig != $this->disconnect
	&& $this->CDRS->rating_settings['rate_on_net_diverted_calls']) {
	$disclass = substr($this->disconnectOrig, 0, 1);
	if ($disclass == "6" \|\| $disclass == "5") {
	$status1_color="<span class=\"pull-right label label-important\">";
	} elseif ($disclass == "4") {
	$status1_color="<span class=\"pull-right label label-info\">";
	} elseif ($disclass == "3") {
	$status1_color="<span class=\"pull-right label label-success\">";
	} elseif ($disclass == "2") {
	$status1_color="<span class=\"pull-right label label-success\">";
	} else {
	$status1_color="<span class=\"pull-right label\">";
	}
	}

	print "
	<td valign=top align=right>$status_color $this->disconnectPrint</span>";
	if ($this->disconnectOrig != $this->disconnect
	&& $this->CDRS->rating_settings['rate_on_net_diverted_calls']) {
	print "$status1_color $this->disconnectOrigPrint</span>";
	}
	print "</td>
	</tr>
	<tr class=extrainfo id='row$found'>
	<td></td>
	<td colspan=13>$this->cdr_details</td>
	</tr>

	";
	}

	function export()
	{
	global $found;
	global $perm;

	$disconnectName = $this->CDRS->disconnectCodesDescription[$this->disconnect];
	$UserAgents = explode("+", $this->SipUserAgents);
	$CallingUserAgent = trim($UserAgents[0]);
	$CalledUserAgent = trim($UserAgents[1]);

	print "$found";
	print ",$this->startTime";
	print ",$this->stopTime";
	print ",$this->BillingPartyIdPrint";
	print ",$this->domain";
	print ",$this->aNumberPrint";
	print ",$this->destinationPrint";
	print ",$this->DestinationId";
	print ",$this->destinationName";
	print ",$this->RemoteAddressPrint";
	print ",$this->CanonicalURIPrint";
	print ",$this->duration";
	print ",$this->price";
	print ",$this->SipProxyServer";
	print ",$this->inputTraffic";
	print ",$this->outputTraffic";
	printf(",%s", preg_replace("/,/", "/", quoted_printable_decode($CallingUserAgent)));
	printf(",%s", preg_replace("/,/", "/", quoted_printable_decode($CalledUserAgent)));
	print ",$this->disconnect";
	print ",$disconnectName";
	printf(",%s", preg_replace("/,/", "/", quoted_printable_decode($this->SipCodec)));
	print ",$this->application";
	print ",$this->MediaProxy";
	print ",$this->tlscn";

	if ($perm->have_perm("showCallerId")) {
	print ",$this->SipRPIDPrint";
	}
	print "\n";
	}

	function showSubscriber()
	{
	$this->buildCDRdetail();
	global $found;

	$rr=floor($found/2);
	$mod=$found-$rr*2;

	if ($mod ==0) {
	$inout_color="lightgrey";
	} else {
	$inout_color="white";
	}

	if (!$this->CDRS->export) {
	$timezone_print=$this->CDRS->CDRTool['provider']['timezone'];

	$found_print=$found;

	if ($this->normalized) {
	$found_print.='N';
	}

	print "
	<tr rel=tooltip data-placement='bottom' data-original-title='For more information about this call click the row.'>
	<td valign=top onClick=\"return toggleVisibility('row$found')\"><a href=#>$found_print</a></td>
	<td valign=top onClick=\"return toggleVisibility('row$found')\"><nobr>$this->startTime $timezone_print</nobr></td>
	<td valign=top><nobr>$this->aNumberPrint</nobr></td>
	<td valign=top onClick=\"return toggleVisibility('row$found')\"><nobr>$this->geo_location</td>
	<td valign=top onClick=\"return toggleVisibility('row$found')\">$this->SipProxyServer</td>
	<td valign=top><nobr>$this->destinationPrint $this->destinationName</td>
	<td valign=top align=right>$this->durationPrint</td>
	";

	if ($this->CDRS->rating) {
	print "<td valign=top align=right>$this->pricePrint</td>";
	}

	print "
	<td valign=top align=right>$this->inputTrafficPrint </td>
	<td valign=top align=right>$this->outputTrafficPrint</td>
	</tr>
	";
	print "
	<tr class=extrainfo id='row$found'>
	<td></td>
	<td colspan=11>$this->cdr_details</td>
	</tr>
	";
	} else {
	$disconnectName = $this->CDRS->disconnectCodesDescription[$this->disconnect];
	$UserAgents = explode("+", $this->SipUserAgents);
	$CallingUserAgent = trim($UserAgents[0]);
	$CalledUserAgent = trim($UserAgents[1]);
	print "$found";
	print ",$this->startTime";
	print ",$this->stopTime";
	print ",$this->BillingPartyId";
	print ",$this->domain";
	print ",$this->aNumberPrint";
	print ",$this->cNumberPrint";
	print ",$this->DestinationId";
	print ",$this->destinationName";
	print ",$this->RemoteAddressPrint";
	print ",$this->duration";
	print ",$this->price";
	print ",$this->SipProxyServer";
	print ",$this->inputTraffic";
	print ",$this->outputTraffic";
	print ",$CallingUserAgent";
	print ",$CalledUserAgent";
	print ",$this->disconnect";
	print ",$disconnectName";
	print ",$this->SipCodec";
	print ",$this->application\n";
	}
	}

	function isBillingPartyLocal()
	{
	$els = explode("@", $this->BillingPartyId);

	if ($els[1] && isset($this->CDRS->localDomains[$els[1]])) {
	return true;
	}

	return false;
	}

	function isCallerLocal()
	{
	if (isset($this->CDRS->localDomains[$this->aNumberDomain])) {
	$this->CallerIsLocal = true;
	$this->SipRPID = $this->CDRS->getCallerId($this->BillingPartyId);
	#$this->SipRPIDPrint = quoted_printable_decode($this->SipRPID);
	}
	$this->SipRPIDPrint = $this->SipRPID;
	}

	function isCalleeLocal()
	{
	if (isset($this->CDRS->localDomains[$this->CanonicalURIDomain]) && !preg_match("/^0/", $this->CanonicalURIUsername)) {
	$this->CalleeIsLocal = true;
	$this->CalleeCallerId = $this->CDRS->getCallerId($this->CanonicalURI);
	}
	}

	function obfuscateCallerId()
	{
	global $obfuscateCallerId;
	if ($obfuscateCallerId) {
	//Caller party
	$caller_els=explode("@", $this->aNumberPrint);

	if (is_numeric($caller_els[0]) && strlen($caller_els[0]>3)) {
	$_user = substr($caller_els[0], 0, strlen($caller_els[0])-3).'xxx';
	} else {
	$_user = 'caller';
	}

	if (count($caller_els) == 2) {
	$this->aNumberPrint = $_user.'@'.$caller_els[1];
	} else {
	$this->aNumberPrint = $_user;
	}

	//Billing party
	$caller_els = explode("@", $this->BillingPartyIdPrint);

	if (is_numeric($caller_els[0]) && strlen($caller_els[0]>3)) {
	$_user = substr($caller_els[0], 0, strlen($caller_els[0])-3).'xxx';
	} else {
	$_user = 'party';
	}

	$this->BillingPartyIdPrint = $_user.'@'.$caller_els[1];

	// Destination
	$caller_els = explode("@", $this->destinationPrint);

	if (is_numeric($caller_els[0]) && strlen($caller_els[0]>3)) {
	$_user = substr($caller_els[0], 0, strlen($caller_els[0])-3).'xxx';
	} else {
	$_user = 'destination';
	}

	if (count($caller_els) == 2) {
	$this->destinationPrint = $_user.'@'.$caller_els[1];
	} else {
	$this->destinationPrint = $_user;
	}

	$caller_els = explode("@", $this->cNumberPrint);

	if (is_numeric($caller_els[0]) && strlen($caller_els[0]>3)) {
	$_user = substr($caller_els[0], 0, strlen($caller_els[0])-3).'xxx';
	} else {
	$_user = 'dialedNumber';
	}

	if (count($caller_els) == 2) {
	$this->cNumberPrint = $_user.'@'.$caller_els[1];
	} else {
	$this->cNumberPrint = $_user;
	}

	$caller_els = explode("@", $this->RemoteAddressPrint);

	if (is_numeric($caller_els[0]) && strlen($caller_els[0]>3)) {
	$_user = substr($caller_els[0], 0, strlen($caller_els[0])-3).'xxx';
	} else {
	$_user = 'remoteAddress';
	}

	if (count($caller_els) == 2) {
	$this->RemoteAddressPrint = $_user.'@'.$caller_els[1];
	} else {
	$this->RemoteAddressPrint = $_user;
	}

	// Canonical URI
	$caller_els = explode("@", $this->CanonicalURIPrint);

	if (is_numeric($caller_els[0]) && strlen($caller_els[0]>3)) {
	$_user = substr($caller_els[0], 0, strlen($caller_els[0])-3).'xxx';
	} else {
	$_user = 'canonicalURI';
	}

	if (count($caller_els) == 2) {
	$this->CanonicalURIPrint = $_user.'@'.$caller_els[1];
	} else {
	$this->CanonicalURIPrint = $_user;
	}

	if (is_numeric($this->SipRPIDPrint) && strlen($this->SipRPIDPrint) > 3) {
	$this->SipRPIDPrint = substr($this->SipRPID, 0, strlen($this->SipRPID)-3).'xxx';
	} else {
	$_user = 'callerId';
	}

	// IP address
	$this->SourceIP = 'xxx.xxx.xxx.xxx';
	}
	}
	}

	class SIP_trace
	{
	public $enableThor = false;
	public $trace_array = array();
	public $traced_ip = array();
	public $SIPProxies = array();
	public $mediaTrace = false;
	public $thor_nodes = array();
	public $hostnames = array();

	public function __construct($cdr_source)
	{
	global $DATASOURCES, $auth;
	require_once 'errors.php';

	$this->cdr_source = $cdr_source;
	$this->cdrtool = new DB_CDRTool();

	if (!is_array($DATASOURCES[$this->cdr_source])) {
	$log = sprintf("Error: datasource '%s' is not defined\n", $this->cdr_source);
	print $log;
	throw new DataSourceUndefinedError($log);
	return 0;
	}

	if (strlen($DATASOURCES[$this->cdr_source]['enableThor'])) {
	$this->enableThor = $DATASOURCES[$this->cdr_source]['enableThor'];
	}

	if (strlen($DATASOURCES[$this->cdr_source]['mediaTrace'])) {
	$this->mediaTrace = $DATASOURCES[$this->cdr_source]['mediaTrace'];
	}

	if ($this->enableThor) {
	require '/etc/cdrtool/ngnpro_engines.inc';
	require_once 'ngnpro_soap_library.php';
	if ($DATASOURCES[$this->cdr_source]['soapEngineId'] && in_array($DATASOURCES[$this->cdr_source]['soapEngineId'], array_keys($soapEngines))) {
	$this->soapEngineId=$DATASOURCES[$this->cdr_source]['soapEngineId'];

	$this->SOAPlogin = array(
	"username" => $soapEngines[$this->soapEngineId]['username'],
	"password" => $soapEngines[$this->soapEngineId]['password'],
	"admin" => true
	);

	$this->SOAPurl=$soapEngines[$this->soapEngineId]['url'];

	$this->SoapAuth = array('auth', $this->SOAPlogin , 'urn:AGProjects:NGNPro', 0, '');

	// Instantiate the SOAP client
	$this->soapclient = new WebService_NGNPro_SipPort($this->SOAPurl);

	$this->soapclient->setOpt('curl', CURLOPT_TIMEOUT, 5);
	$this->soapclient->setOpt('curl', CURLOPT_SSL_VERIFYPEER, 0);
	$this->soapclient->setOpt('curl', CURLOPT_SSL_VERIFYHOST, 0);

	if (is_array($soapEngines[$this->soapEngineId]['hostnames'])) {
	$this->hostnames=$soapEngines[$this->soapEngineId]['hostnames'];
	}
	} else {
	printf("<p><font color=red>Error: soapEngineID not defined in datasource %s</font>", $this->cdr_source);
	return false;
	}
	} else {
	$this->table = $DATASOURCES[$this->cdr_source]['table'];
	$db_class = $DATASOURCES[$this->cdr_source]['db_class'];
	$this->purgeRecordsAfter = $DATASOURCES[$this->cdr_source]['purgeRecordsAfter'];

	if (class_exists($db_class)) {
	$this->db = new $db_class;
	} else {
	printf("<p><font color=red>Error: database class '%s' is not defined</font>", $db_class);
	return false;
	}
	}

	if (is_object($auth)) {
	$this->isAuthorized=1;
	}

	if (is_array($DATASOURCES[$this->cdr_source]['SIPProxies'])) {
	$this->SIPProxies = $DATASOURCES[$this->cdr_source]['SIPProxies'];
	}
	}

	private function isProxy($ip, $sip_proxy = '')
	{
	if (!$ip) {
	return false;
	}

	if (!$this->enableThor) {
	if (!is_array($this->SIPProxies)) {
	return false;
	}

	if (in_array($ip, array_keys($this->SIPProxies))) {
	return true;
	}
	} elseif ($sip_proxy) {
	if (isset($this->thor_nodes[$ip])) {
	return true;
	} else {
	if (isThorNode($ip, $sip_proxy) \|\| isThorNode($ip, $sip_proxy, 'msteams_gateway')) {
	$this->thor_nodes[$ip]=1;
	return true;
	} else {
	return false;
	}
	}
	}

	return false;
	}

	private function getTrace($proxyIP, $callid, $fromtag, $totag)
	{
	if ($this->enableThor) {
	// get trace using soap request
	if (!$proxyIP \|\| !$callid \|\| !$fromtag) {
	return false;
	}

	global $DATASOURCES;
	if (is_array($DATASOURCES[$this->cdr_source]['proxyTranslation_IP'])
	&& isset($DATASOURCES[$this->cdr_source]['proxyTranslation_IP'][$proxyIP])
	&& strlen($DATASOURCES[$this->cdr_source]['proxyTranslation_IP'][$proxyIP])
	) {
	$proxyIP = $DATASOURCES[$this->cdr_source]['proxyTranslation_IP'][$proxyIP];
	}
	if (!is_object($this->soapclient)) {
	print "Error: soap client is not defined.";
	return false;
	}

	$filter = array(
	'nodeIp' => $proxyIP,
	'callId' => $callid,
	'fromTag' => $fromtag,
	'toTag' => $totag
	);
	$this->soapclient->addHeader($this->SoapAuth);

	$result = $this->soapclient->getSipTrace($filter);

	if ((new PEAR)->isError($result)) {
	$error_msg = $result->getMessage();
	$error_fault = $result->getFault();
	$error_code = $result->getCode();

	printf(
	"
	<div style='display: flex; align-items: center; justify-content: center;'>
	<div class='span10' style='padding-top:40px;'>
	<div class='alert alert-danger'><h4>Error from %s</h4><br/>%s (%s)</div>
	</div>
	</div>
	",
	$this->SOAPurl,
	$error_fault->detail->exception->errorstring,
	$error_fault->detail->exception->errorcode
	);
	return false;
	}

	$columns = 0;

	$traces = json_decode($result);

	$trace_array = array();

	foreach ($traces as $_trace) {
	if (preg_match("/^(udp\|tcp\|tls):(.):(.)$/", $_trace->to_ip, $m)) {
	$toip = $m[2];
	$transport = $m[1];
	$toport = $m[3];
	} elseif (preg_match("/^(.):(.)$/", $_trace->to_ip, $m)) {
	$toip = $m[1];
	$transport = 'udp';
	$toport = $m[2];
	} else {
	$toip = $_trace->to_ip;
	$transport = $_trace->to_proto;
	$toport = $_trace->to_port;
	}

	if (preg_match("/^(udp\|tcp\|tls):(.):(.)$/", $_trace->from_ip, $m)) {
	$fromip = $m[2];
	$fromport = $m[3];
	} elseif (preg_match("/^(.):(.)$/", $_trace->from_ip, $m)) {
	$fromip = $m[1];
	$fromport = $m[2];
	} else {
	$fromip = $_trace->from_ip;
	$fromport = $_trace->from_port;
	}

	if (!isset($this->column[$fromip])) {
	$this->column[$fromip] = $columns + 1;
	$this->column_port[$fromip] = $fromport;
	$columns++;
	}

	if (!isset($this->column[$toip])) {
	$this->column[$toip] = $columns+1;
	$this->column_port[$toip] = $toport;
	$columns++;
	}

	preg_match("/^(\d+)-(\d+)-(\d+) (\d+):(\d+):(\d+)$/", $_trace->time_stamp, $m);
	$timestamp = mktime($m[4], $m[5], $m[6], $m[2], $m[3], $m[1]);

	$idx=$proxyIP.'_'.$_trace->id;

	$trace_array[$idx] = array (
	'id' => $idx,
	'direction' => $_trace->direction,
	'fromip' => $fromip,
	'toip' => $toip,
	'fromport' => $fromport,
	'toport' => $toport,
	'method' => $_trace->method,
	'transport' => $transport,
	'date' => $_trace->time_stamp,
	'status' => $_trace->status,
	'timestamp' => $timestamp,
	'msg' => $_trace->message,
	'md5' => md5($_trace->message)
	);
	}

	$this->trace_array=$trace_array;
	$this->rows = count($this->trace_array);
	} else {
	// get trace from SQL

	if (!is_object($this->db)) {
	print "<p><font color=red>Error: no database connection defined</font>";
	return false;
	}

	$query = sprintf(
	"
	select
	*,
	UNIX_TIMESTAMP(time_stamp) as timestamp
	from
	%s
	where
	callid = '%s'
	order by id asc
	",
	addslashes($this->table),
	addslashes($callid)
	);

	if (!$this->db->query($query)) {
	printf("Database error for query %s: %s (%s)", $query, $this->db->Error, $this->db->Errno);
	return false;
	}

	$this->rows = $this->db->num_rows();

	$columns = 0;

	while ($this->db->next_record()) {
	if (preg_match("/^(udp\|tcp\|tls):(.):(.)$/", $this->db->f('toip'), $m)) {
	$toip = $m[2];
	$transport = $m[1];
	$toport = $m[3];
	} elseif (preg_match("/^(.):(.)$/", $this->db->f('toip'), $m)) {
	$toip = $m[1];
	$transport = 'udp';
	$toport = $m[2];
	} else {
	$toip = $this->db->f('toip');
	$toport = '5060';
	}

	if (preg_match("/^(udp\|tcp\|tls):(.):(.)$/", $this->db->f('fromip'), $m)) {
	$fromip = $m[2];
	$fromport = $m[3];
	} elseif (preg_match("/^(.):(.)$/", $this->db->f('fromip'), $m)) {
	$fromip = $m[1];
	$fromport = $m[2];
	} else {
	$fromip = $this->db->f('fromip');
	$transport = 'udp';
	$fromport = '5060';
	}

	if (!$this->column[$fromip]) {
	$this->column[$fromip]=$columns+1;
	$this->column_port[$fromip]=$fromport;
	$columns++;
	}

	if (!$this->column[$toip]) {
	$this->column[$toip] = $columns + 1;
	$this->column_port[$toip]=$toport;
	$columns++;
	}

	$this->trace_array[$this->db->f('id')] =
	array (
	'id' => $this->db->f('id'),
	'direction' => $this->db->f('direction'),
	'fromip' => $fromip,
	'toip' => $toip,
	'method' => $this->db->f('method'),
	'fromport' => $fromport,
	'toport' => $toport,
	'transport' => $transport,
	'date' => $this->db->f('time_stamp'),
	'status' => $this->db->f('status'),
	'timestamp' => $this->db->f('timestamp'),
	'msg' => $this->db->f('msg'),
	'md5' => md5($this->db->f('msg'))
	);
	}
	}
	}

	private function printLabelProtocolPort($transport, $port)
	{
	echo '<span class="label">';
	if ($transport == 'tls') {
	echo "<span><i class='icon-lock'></i></span> ";
	}
	printf('%s: %d', strtoupper($transport), $port);
	echo '</span>';
	}

	public function show($proxyIP, $callid, $fromtag, $totag)
	{
	$action = $_REQUEST['action'];
	$toggleVisibility = $_REQUEST['toggleVisibility'];

	if ($action == 'toggleVisibility') {
	$this->togglePublicVisibility($callid, $fromtag, $toggleVisibility);
	}

	if ($_SERVER['HTTPS'] == "on") {
	$protocolURL = "https://";
	} else {
	$protocolURL = "http://";
	}

	$this->getTrace($proxyIP, $callid, $fromtag, $totag);

	/* No trace can be found */

	if (!count($this->trace_array)) {
	echo "
	<div style='display: flex; align-items: center; justify-content: center;'>
	<div class='span10' style='padding-top:40px;'>
	<p class='alert'>SIP trace for session id <strong>$callid</strong> is not available.</p>
	</div>
	</div>
	";
	return;
	}

	echo "
	<div class=container-fluid>
	<div id=trace class=main>
	<h1 class='page-header'>CDRTool SIP trace<br /><small>Call ID: $callid $authorize</small></h1>
	<div class=row-fluid>
	<div class=span9>
	";
	$basicURL = $protocolURL.$_SERVER['HTTP_HOST'].$_SERVER['REQUEST_URI'];

	$fullURL = $basicURL;
	print "URLs for this trace: <a href=$fullURL>HTML</a> \| <a href=$fullURL&format=text>TEXT</a></td>";

	if ($this->mediaTrace) {
	$media_query = array(
	'cdr_source' => $this->mediaTrace,
	'callid' => $callid,
	'fromtag' => $fromtag,
	'totag' => $totag,
	'proxyIP' => $proxyIP
	);
	$this->mediaTraceLink = sprintf(
	"<p class=pull-right>
	<a href=\"javascript:void(null);\" onClick=\"return window.open('media_trace.phtml?%s', 'mediatrace','toolbar=0,status=0,menubar=0,scrollbars=1,resizable=1,width=800,height=730')\">
	Click here for RTP media information
	</a>
	</p>",
	http_build_query($media_query)
	);
	}

	print "
	</div>
	<div class='span3'>
	<p class='pull-right'>Click on each packet to expand its body content</p>
	$this->mediaTraceLink
	</div>
	</div>
	";

	foreach (array_keys($this->trace_array) as $key) {
	$this->trace_array[$key]['isProxy'] = 0;

	if ($this->trace_array[$key]['direction'] == 'in') {
	if (is_array($this->SIPProxies)) {
	$thisIP=explode(":", $this->trace_array[$key]['fromip']);
	if ($this->isProxy($thisIP[0], $proxyIP)) {
	$this->trace_array[$key]['isProxy'] = 1;
	}
	}

	$this->trace_array[$key]['msg_possition'] = $this->column[$this->trace_array[$key]['toip']];
	$this->trace_array[$key]['arrow_possition'] = $this->column[$this->trace_array[$key]['fromip']];
	$this->trace_array[$key]['arrow_direction'] = $arrow_direction;

	// handle self-generated BYE
	if ($this->trace_array[$key]['fromip'] == $this->trace_array[$key]['toip']) {
	-
	if ($this->trace_array[$key]['method'] == 'BYE') {
	$bye_ip = $this->trace_array[$key]['fromip'];
	$bye_lines = preg_split('/\n\|\r\n?/', $this->trace_array[$key]['msg']);

	$bye_line = $bye_lines[0];
	$fi=$this->trace_array[$key]['fromip'];
	$fp=$this->trace_array[$key]['fromport'];
	$ti=$this->trace_array[$key]['toip'];
	$tp=$this->trace_array[$key]['toport'];

	if (preg_match("/^BYE (sip:\|sips:)(.)\@(.):(\d)(.)$/", $bye_line, $m)) {
	$bye_ip = $m[3];
	$bye_port = $m[4];
	if ($this->column[$bye_ip]){
	$this->trace_array[$key]['fromip'] = $bye_ip;
	$this->trace_array[$key]['fromport'] = $bye_port;
	$this->trace_array[$key]['arrow_possition'] = $this->column[$bye_ip];
	} else {
	$found_bye_ip = false;
	foreach ($bye_lines as $_line) {
	if (preg_match("/^Route:(.*)$/", $_line, $mr)) {
	$line = str_replace(array('<', '>'), "", $mr[1]);
	$routes = explode(",", $line);
	foreach ($routes as $r) {
	if (preg_match("/(.sip:\|sips:)(.):(\d+)(.*)$/", $r, $mm)) {
	$bye_ip = $mm[2];
	$bye_port = $mm[3];
	if ($this->column[$bye_ip]){
	$this->trace_array[$key]['fromip'] = $bye_ip;
	$this->trace_array[$key]['fromport'] = $bye_port;
	$this->trace_array[$key]['arrow_possition'] = $this->column[$bye_ip];
	$found_bye_ip = true;
	break;
	}
	}
	}

	- if ($found_bye_ip){
	+ if ($found_bye_ip) {
	break;
	}
	}
	-
	}
	}
	} else {
	$arrow_direction = "loop";
	}

	if ($this->column[$this->trace_array[$key]['fromip']] < $this->column[$proxyIP]) {
	$arrow_direction = "left";
	} else {
	$arrow_direction = "right";
	}
	} else {
	$arrow_direction = "loop";
	}
	} elseif ($this->column[$this->trace_array[$key]['fromip']] < $this->column[$this->trace_array[$key]['toip']]) {
	$arrow_direction = "right";
	} else {
	$arrow_direction = "left";
	}

	$this->trace_array[$key]['arrow_direction'] = $arrow_direction;

	} else {
	if ($this->trace_array[$key]['fromip'] == $this->trace_array[$key]['toip']) {
	$arrow_direction = "loop";
	} elseif ($this->column[$this->trace_array[$key]['fromip']] < $this->column[$this->trace_array[$key]['toip']]) {
	$arrow_direction = "right";
	} else {
	$arrow_direction = "left";
	}

	$this->trace_array[$key]['msg_possition'] = $this->column[$this->trace_array[$key]['fromip']];
	$this->trace_array[$key]['arrow_possition'] = $this->column[$this->trace_array[$key]['toip']];
	$this->trace_array[$key]['arrow_direction'] = $arrow_direction;
	}
	}
	echo "
	<table class='table siptrace'>
	<thead>
	<tr>
	<th>Packet</th>
	<th>Time</th>
	";

	$_seen_timeline = array();
	foreach (array_keys($this->column) as $_key) {
	$IPels = explode(":", $_key);

	if (isset($this->hostnames[$IPels[0]])) {
	$_hostname = $this->hostnames[$IPels[0]];
	} else {
	$_hostname = $_key;
	}

	print "<th style='text-align: center' colspan=\"2\">";
	if ($proxyIP != $IPels[0] && $this->isProxy($IPels[0], $proxyIP)) {
	$trace_query = array(
	'cdr_source' => $this->cdr_source,
	'callid' => $callid,
	'fromtag' => $fromtag,
	'totag' => $totag,
	'proxyIP' => $IPels[0]
	);
	$trace_link = sprintf(
	"<a href=\"javascript:void(null);\" onClick=\"return window.open('sip_trace.phtml?%s', '_self',
	'toolbar=0,status=1,menubar=1,scrollbars=1,resizable=1,width=1000,height=600')\">%s:%s</a>",
	http_build_query($trace_query),
	$_hostname,
	$this->column_port[$_key]
	);
	printf("%s", $trace_link);
	} else {
	printf("%s", $_hostname);
	}
	print "</th>";
	}

	print "</tr>
	</thead>";

	/* Rows */

	$i=0;
	foreach (array_keys($this->trace_array) as $key) {
	$i++;

	$id = $this->trace_array[$key]['id'];
	$msg = $this->trace_array[$key]['msg'];
	$fromip = $this->trace_array[$key]['fromip'];
	$toip = $this->trace_array[$key]['toip'];
	$date = substr($this->trace_array[$key]['date'], 11);
	$status = $this->trace_array[$key]['status'];
	$direction = $this->trace_array[$key]['direction'];
	$timestamp = $this->trace_array[$key]['timestamp'];
	$method = $this->trace_array[$key]['method'];
	$isProxy = $this->trace_array[$key]['isProxy'];
	$transport = $this->trace_array[$key]['transport'];

	$msg_possition = $this->trace_array[$key]['msg_possition'];
	$arrow_possition = $this->trace_array[$key]['arrow_possition'];
	$arrow_direction = $this->trace_array[$key]['arrow_direction'];
	$md5 = $this->trace_array[$key]['md5'];

	if ($i == 1) {
	$begin_timestamp = $timestamp;
	}
	$timeline = $timestamp - $begin_timestamp;

	$sip_phone_img = getImageForUserAgent($msg);

	if ($seen_msg[$md5]) {
	continue;
	}

	$SIPclass = substr($status, 0, 1);
	switch ($SIPclass) {
	case 6:
	$status_color = "red";
	break;
	case 5:
	$status_color = "red";
	break;
	case 4:
	$status_color = "red";
	break;
	case 3:
	$status_color = "green";
	break;
	case 2:
	$status_color = "green";
	break;
	case 1:
	$status_color = "orange";
	break;
	default:
	$status_color = "blue";
	if ($method == "ACK") {
	$status_color = 'cyan';
	} else if ($method == "CANCEL") {
	$status_color = 'magenta';
	}
	break;
	}

	$_lines = explode("\n", $msg);

	if (preg_match("/^(.*) SIP/", $_lines[0], $m)) {
	$_lines[0] = $m[1];
	} elseif (preg_match("/^SIP\/2\.0 (.*)/", $_lines[0], $m)) {
	$_lines[0] = $m[1];
	}

	unset($media);
	unset($diversions);

	$media_index=0;
	$search_ice=0;
	$search_ip=0;
	$contact_header='';

	foreach ($_lines as $_line) {
	if (preg_match("/^(Diversion: ).;(.)$/", $_line, $m)) {
	$diversions[]=$m[1].$m[2];
	}

	if (preg_match("/^Cseq:\s\d+\s(.*)$/i", $_line, $m)) {
	$status_for_method=$m[1];
	}

	if (preg_match("/^c=IN \w+ ([\d\|\w\.]+)/i", $_line, $m)) {
	$media['ip']=$m[1];
	}

	if (preg_match("/^m=(\w+) (\d+) /i", $_line, $m)) {
	$media_index++;
	$search_ice=1;
	$search_ip=1;
	$media['streams'][$media_index] = array(
	'type' => $m[1],
	'ip' => $media['ip'],
	'port' => $m[2],
	'ice' => ''
	);
	}

	if ($search_ip && preg_match("/^c=IN \w+ ([\d\|\w\.]+)/i", $_line, $m)) {
	$media['streams'][$media_index]['ip']=$m[1];
	$search_ip=0;
	}

	if ($search_ice && preg_match("/^a=ice/i", $_line, $m)) {
	$media['streams'][$media_index]['ice']="ICE";
	$search_ice=0;
	}
	}


	$_els = explode(";", $_lines[0]);

	$cell_content = "<div id=\"packet$i\"><span>$_els[0]</span>";

	if ($status) {
	$cell_content .= " <font color=black>for ".$status_for_method."</font>";
	}

	if (is_array($diversions)) {
	foreach ($diversions as $_diversion) {
	$cell_content.="<br><em class='gray'>$_diversion</em>";
	}
	}

	if (is_array($media['streams'])) {
	foreach (array_keys($media['streams']) as $_key) {
	$_stream = sprintf(
	"%s: %s:%s %s",
	$media['streams'][$_key]['type'],
	$media['streams'][$_key]['ip'],
	$media['streams'][$_key]['port'],
	$media['streams'][$_key]['ice']
	);
	if ($media['streams'][$_key]['port']) {
	$cell_content.="<br><em class='gray'>$_stream</em>";
	} else {
	$cell_content.="<br><em style='text-decoration: line-through'>$_stream</em>";
	}
	}
	}

	$cell_content.="
	</div>
	";

	print "
	<tr onClick=\"return toggleVisibility('row$i')\">
	";

	$packet_length = strlen($msg);

	print "
	<td><span>$i/$this->rows </span></td>
	<td><span><nobr>$date</nobr></span>";
	if ($timeline && !isset($_seen_timeline[$timeline])) {
	printf("  <span class='badge badge-info'>+%ds</span>", $timeline);
	$_seen_timeline[$timeline] = 1;
	}

	print "<br /><nobr>$packet_length bytes</nobr></td>
	";

	$column_current = 1;
	while ($column_current <= count($this->column)) {
	if ($arrow_possition == $column_current) {
	/* First cell, first port, append extra cell */
	if ($column_current < count($this->column) && $column_current < $msg_possition) {
	print "<td style='text-align: right' class='span2'>";
	if ($direction == 'in') {
	$this->printLabelProtocolPort($transport, $this->trace_array[$key]['fromport']);
	} else {
	$this->printLabelProtocolPort($transport, $this->trace_array[$key]['toport']);
	}
	echo "</td>";
	}

	$arrowColor = $status_color;

	if ($arrow_direction == 'loop') {
	print "<td><i style='font-size: 2.4em' class=\"icon-refresh pull-right\"></i></td>";
	}

	if ($arrow_possition >= 2 * $msg_possition) {
	$arrow_span = ($arrow_possition * 2) - 4;
	echo "<td colspan='$arrow_span' style='border-left: 2px solid #95b3d0; border-right: 2px solid #95b3d0; width:66%'>";
	} else {
	echo "<td colspan='2' style='border-left: 2px solid #95b3d0; border-right: 2px solid #95b3d0; width:33%'>";
	}


	if ($arrow_direction != 'loop') {
	print "<div class='sarrow $arrowColor $arrow_direction'></div>";
	}

	if ($arrow_direction == "left") {
	print "<div style='text-align: right; padding-right:16px;'>$cell_content</div>";
	} else {
	print "<div style='float:left; padding-left:16px;'>$cell_content</div>";
	}
	echo "</td>";

	if ($column_current < count($this->column) && $column_current > $msg_possition) {
	print "<td class='span2'>";
	if ($direction == 'in') {
	$this->printLabelProtocolPort($transport, $this->trace_array[$key]['fromport']);
	} else {
	$this->printLabelProtocolPort($transport, $this->trace_array[$key]['toport']);
	}
	echo "</td>";
	}
	} else {
	if ($msg_possition == $column_current) {
	if ($msg_possition < $arrow_possition) {
	print "<td style='width: 17%;text-align: right'>";
	if ($direction == 'out') {
	$this->printLabelProtocolPort($transport, $this->trace_array[$key]['fromport']);
	} else {
	$this->printLabelProtocolPort($transport, $this->trace_array[$key]['toport']);
	}
	} else {
	print "<td style='width: 17%'>";
	if ($direction == 'out') {
	$this->printLabelProtocolPort($transport, $this->trace_array[$key]['fromport']);
	} else {
	$this->printLabelProtocolPort($transport, $this->trace_array[$key]['toport']);
	}
	}
	} elseif ($arrow_possition != $column_current
	&& ( $column_current == 1
	\|\| ( $arrow_possition < $column_current
	&& $arrow_possition != $msg_possition)
	)) {
	print "<td style='width: 17%; border-right: 2px solid #95b3d0'>";
	print "</td><td>";
	print " ";
	} elseif ($arrow_possition == $msg_possition) {
	echo "<td></td>";
	#} elseif ($column_current != $this->column[$fromip] && $column_current != $this->column[$toip]) {
	# echo "<td colspan=2 border-left: 2px solid #95b3d0'></td>";
	}
	echo "</td>";
	}

	if ($arrow_possition == $column_current && $column_current == count($this->column)) {
	echo "<td style='width:17%'>";
	if ($direction == 'in') {
	$this->printLabelProtocolPort($transport, $this->trace_array[$key]['fromport']);
	} else {
	$this->printLabelProtocolPort($transport, $this->trace_array[$key]['toport']);
	}
	echo "</td>";
	}
	$column_current++;
	if ($arrow_direction == 'loop') {
	$seen_msg[$md5]++;
	}
	}

	echo "</tr>";

	if (is_array($this->SIPProxies)) {
	$IPels = explode(":", $fromip);
	$justIP = $IPels[0];
	foreach (array_keys($this->SIPProxies) as $localProxy) {
	if ($localProxy == $justIP) {
	$direction="out";
	break;
	}
	}
	}

	/* Details */

	$trace_span = count($this->column) * 2 + 3;

	print "
	<tr class='extrainfo $status_color' id=row$i>
	<td colspan=$trace_span>
	<div class='row-fluid'>
	<div class='span2' style='max-width: 120px; padding-left: 15px;'>
	";

	if ($direction == "out" or $isProxy) {
	print "<nobr><h1>SIP Proxy</h1></nobr>";
	} else {
	if ($sip_phone_img && $sip_phone_img!='unknown.png') {
	print "<img style='max-width:none' src=images/$sip_phone_img>";
	} else {
	print "<i style=\"font-size:28px\" class=\"icon-question\"></i>";
	}
	}
	print "<br />";
	if ($timeline > 0) {
	printf("<p>+%s s<br>(%s)</p>", $timeline, sec2hms($timeline));
	}
	print "</div><div class=span10 style='font-family: monospace; color: #333333;'>";

	$msg = nl2br(htmlentities($msg));

	print "<span>$msg</span>
	</div>
	</div>";

	echo "
	</td>
	</tr>
	";
	}

	print "
	</table>
	";
	}

	public function showText($proxyIP, $callid, $fromtag, $totag)
	{
	$this->getTrace($proxyIP, $callid, $fromtag, $totag);
	print "<pre>";

	if (!count($this->trace_array)) {
	print "SIP trace for session id $callid is not available.";
	return false;
	}

	printf("SIP trace on proxy %s for session %s\n--\n\n", $proxyIP, $callid);

	foreach (array_keys($this->trace_array) as $key) {
	$i++;
	printf(
	"Packet %d at %s from %s to %s (%s)\n",
	$i,
	$this->trace_array[$key]['date'],
	$this->trace_array[$key]['fromip'],
	$this->trace_array[$key]['toip'],
	$this->trace_array[$key]['direction']
	);
	printf(
	"\n%s\n",
	htmlspecialchars($this->trace_array[$key]['msg'])
	);
	print "---\n";
	}
	print "</pre>";
	}

	public function togglePublicVisibility($callid, $fromtag, $public = '0')
	{
	$key="callid-".trim($callid).trim($fromtag);

	if (!$public) {
	$query = sprintf("delete from memcache where `key` = '%s'", addslashes($key));
	$this->cdrtool->query($query);
	} else {
	$query = sprintf("delete from memcache where `key` = '%s'", addslashes($key));
	$this->cdrtool->query($query);
	$query = sprintf("insert into memcache values ('%s','public')", addslashes($key));
	$this->cdrtool->query($query);
	}
	}

	public function purgeRecords($days = '')
	{
	if ($this->enableThor) {
	return true;
	}

	$b=time();

	if ($days) {
	$this->purgeRecordsAfter = $days;
	} elseif (!$this->purgeRecordsAfter) {
	$this->purgeRecordsAfter = 15;
	}

	$beforeDate=Date("Y-m-d", time()-$this->purgeRecordsAfter360024);

	$query = sprintf(
	"SELECT id as min, time_stamp FROM %s ORDER BY id ASC limit 1",
	addslashes($this->table)
	);

	if ($this->db->query($query)) {
	if ($this->db->num_rows()) {
	$this->db->next_record();
	$min=$this->db->f('min');
	$begindate=$this->db->f('date');
	} else {
	$log = sprintf("No records found in %s\n", $this->table);
	print $log;
	syslog(LOG_NOTICE, $log);
	return false;
	}
	} else {
	$log = sprintf("Error: %s (%s)\n", $this->db->Error, $query);
	print $log;
	syslog(LOG_NOTICE, $log);
	return false;
	}

	$query=sprintf(
	"select id as max from %s where time_stamp < '%s' order by id DESC limit 1",
	addslashes($this->table),
	addslashes($beforeDate)
	);

	if ($this->db->query($query) && $this->db->num_rows()) {
	$this->db->next_record();
	$max=$this->db->f('max');
	} else {
	$log=sprintf(
	"No records found in %s before %s, records start after %s\n",
	$this->table,
	$beforeDate,
	$begindate
	);
	syslog(LOG_NOTICE, $log);
	print $log;
	return false;
	}

	$deleted = 0;
	$i = $min;

	$interval = 1000;

	$rows2delete = $max - $min;
	$found = 0;

	print "$rows2delete traces to delete between $min and $max\n";

	while ($i<=$max) {
	$found=$found+$interval;

	if ($i + $interval < $max) {
	$top=$i;
	} else {
	$top=$max;
	}
	$query=sprintf(
	"delete low_priority from %s where id >= '%d' and id <='%d'",
	addslashes($this->table),
	addslashes($min),
	addslashes($top)
	);
	if ($this->db->query($query)) {
	$deleted = $deleted + $this->db->affected_rows();
	} else {
	$log = sprintf("Error: %s (%s)", $this->db->Error, $this->db->Errno);
	syslog(LOG_NOTICE, $log);
	return false;
	}

	if ($found > $progress * $rows2delete / 100) {
	$progress++;
	if ($progress % 10 == 0) {
	print "$progress% ";
	}
	flush();
	}

	$i = $i + $interval;
	}

	print "\n";

	$e = time();
	$d = $e - $b;
	$rps = 0;

	if ($deleted && $d) {
	$rps=$deleted/$d;
	}

	$log = sprintf(
	"%s records before %s from %s deleted in %d s @ %.0f rps\n",
	$deleted,
	$beforeDate,
	$this->table,
	$d,
	$rps
	);
	syslog(LOG_NOTICE, $log);
	print $log;

	return true;
	}
	}

	class Media_trace
	{
	public $enableThor = false;
	public $table = 'media_sessions';

	- function __construct($cdr_source)
	+ public function __construct($cdr_source)
	{
	global $DATASOURCES;

	require_once 'errors.php';

	$this->cdr_source = $cdr_source;
	$this->cdrtool = new DB_CDRTool();

	if (!is_array($DATASOURCES[$this->cdr_source])) {
	$log = sprintf("Error: datasource '%s' is not defined", $this->cdr_source);
	print $log;
	throw new DataSourceUndefinedError($log);
	return 0;
	}

	if (strlen($DATASOURCES[$this->cdr_source]['enableThor'])) {
	$this->enableThor = $DATASOURCES[$this->cdr_source]['enableThor'];
	}

	if ($this->enableThor) {
	require '/etc/cdrtool/ngnpro_engines.inc';
	require_once 'ngnpro_soap_library.php';

	if ($DATASOURCES[$this->cdr_source]['soapEngineId'] && in_array($DATASOURCES[$this->cdr_source]['soapEngineId'], array_keys($soapEngines))) {
	$this->soapEngineId=$DATASOURCES[$this->cdr_source]['soapEngineId'];

	$this->SOAPlogin = array(
	"username" => $soapEngines[$this->soapEngineId]['username'],
	"password" => $soapEngines[$this->soapEngineId]['password'],
	"admin" => true
	);

	$this->SOAPurl=$soapEngines[$this->soapEngineId]['url'];

	$this->SoapAuth = array('auth', $this->SOAPlogin , 'urn:AGProjects:NGNPro', 0, '');

	// Instantiate the SOAP client
	$this->soapclient = new WebService_NGNPro_SipPort($this->SOAPurl);

	$this->soapclient->setOpt('curl', CURLOPT_TIMEOUT, 5);
	$this->soapclient->setOpt('curl', CURLOPT_SSL_VERIFYPEER, 0);
	$this->soapclient->setOpt('curl', CURLOPT_SSL_VERIFYHOST, 0);
	} else {
	print "Error: soapEngineID not defined in datasource $this->cdr_source";
	return false;
	}
	} else {
	if ($DATASOURCES[$this->cdr_source]['table']) {
	$this->table = $DATASOURCES[$this->cdr_source]['table'];
	}

	$db_class = $DATASOURCES[$this->cdr_source]['db_class'];
	if (class_exists($db_class)) {
	$this->db = new $db_class;
	} else {
	printf("<p><font color=red>Error: database class %s is not defined in datasource %s</font>", $db_class, $this->cdr_source);
	return false;
	}
	}
	}

	private function getTrace($proxyIP, $callid, $fromtag, $totag)
	{
	if ($this->enableThor) {
	// get trace using soap request
	if (!$proxyIP \|\| !$callid \|\| !$fromtag) {
	echo "
	<div style='display: flex; align-items: center; justify-content: center;'>
	<div class='span10' style='padding-top:40px;'>
	<p class='alert alert-danger'><strong>Error</strong>: proxyIP or callid or fromtag are not defined</p>
	</div>
	</div>
	";
	return false;
	}

	global $DATASOURCES;
	if (is_array($DATASOURCES[$this->cdr_source]['proxyTranslation_IP'])
	&& isset($DATASOURCES[$this->cdr_source]['proxyTranslation_IP'][$proxyIP])
	&& strlen($DATASOURCES[$this->cdr_source]['proxyTranslation_IP'][$proxyIP])
	) {
	$proxyIP = $DATASOURCES[$this->cdr_source]['proxyTranslation_IP'][$proxyIP];
	}

	if (!is_object($this->soapclient)) {
	print "<p><font color=red>Error: soap client is not defined</font>";
	return false;
	}

	$filter = array(
	'nodeIp' => $proxyIP,
	'callId' => $callid,
	'fromTag' => $fromtag,
	'toTag' => $totag
	);

	$this->soapclient->addHeader($this->SoapAuth);

	$result = $this->soapclient->getMediaTrace($filter);

	if ((new PEAR)->isError($result)) {
	$error_msg = $result->getMessage();
	$error_fault = $result->getFault();
	$error_code = $result->getCode();

	if ($error_fault->detail->exception->errorcode != 1060) {
	printf(
	"
	<div style='display: flex; align-items: center; justify-content: center;'>
	<div class='span10' style='padding-top:40px;'>
	<div class='alert alert-danger'><h4>Error from %s</h4><br/>%s (%s)</div>
	</div>
	</div>
	",
	$this->SOAPurl,
	$error_fault->detail->exception->errorstring,
	$error_fault->detail->exception->errorcode
	);
	}
	return false;
	}

	$this->info = json_decode($result);
	} else {
	if (!is_object($this->db)) {
	print "<p><font color=red>Error: no database connection defined</font>";
	return false;
	}

	// get trace from SQL
	$query = sprintf(
	"select info from %s where call_id = '%s' and from_tag = '%s' and to_tag= '%s'",
	addslashes($this->table),
	addslashes($callid),
	addslashes($fromtag),
	addslashes($totag)
	);

	if (!$this->db->query($query)) {
	printf(
	"<p><font color=red>Database error for query %s: %s (%s)</font>",
	$query,
	$this->db->Error,
	$this->db->Errno
	);
	return false;
	}

	if ($this->db->num_rows()) {
	$this->db->next_record();
	$this->info = json_decode($this->db->f('info'));
	}
	}
	}

	public function show($proxyIP, $callid, $fromtag, $totag)
	{

	if ($_SERVER['HTTPS'] == "on") {
	$protocolURL = "https://";
	} else {
	$protocolURL = "http://";
	}

	$this->getTrace($proxyIP, $callid, $fromtag, $totag);

	if (!is_object($this->info)) {
	echo "
	<div style='display: flex; align-items: center; justify-content: center;'>
	<div class='span10' style='padding-top:40px;'>
	<div class='alert'>No information available</div>
	</div>
	</div>
	";
	return false;
	}

	if (empty($this->info->streams)) {
	echo "
	<div style='display: flex; align-items: center; justify-content: center;'>
	<div class='span10' style='padding-top:40px;'>
	<div class='alert alert-info'>No RTP media streams have been established</div>
	</div>
	</div>
	";
	return;
	}

	print "<div class='container-fluid'><div id=trace class='main'>";
	$sessionId = rtrim(base64_encode(hash('md5', $callid, true)), "=");
	print "<h1 class=page-header>CDRTool Media Trace<br/><small>Call ID: $callid</small><br /><small>Media Session ID: $sessionId</small></h1>";

	foreach (array_values($this->info->streams) as $_val) {
	$_diff=$_val->end_time-$_val->timeout_wait;
	$seen_stamp[$_val->start_time]++;
	$seen_stamp[$_val->end_time]++;
	$seen_stamp[$_diff]++;
	$media_types[]=$_val->media_type;
	}

	print "<h2>Media Information</h2>";

	print "<table border=0>";
	printf("<tr><td class=border>Call duration</td><td class=border>%s</td></tr>", $this->info->duration);
	list($relay_ip, $relay_port)=explode(":", $this->info->streams[0]->caller_local);
	printf("<tr><td class=border>Media relay</td><td class=border>%s</td></tr>", $relay_ip);
	print "</table>";

	print "<h2>Media Streams</h2>";

	print "<table class='table table-condensed table-striped' style='width:600px' border=0>";
	print "<thead><tr><th></th>";

	foreach (array_values($media_types) as $_type) {
	printf("<th>%s</th>", ucfirst($_type));
	}

	print "</tr></thead>";

	foreach ($this->info->streams[0] as $_val => $_value) {
	printf("<tr><td class=border>%s</td>", ucfirst(preg_replace("/_/", " ", $_val)));
	$j=0;
	while ($j < count($media_types)) {
	printf("<td class=border>%s</td>", $this->info->streams[$j]->$_val);
	$j++;
	}

	printf("</tr>\n");
	}

	print "</table>";

	print "<br><h2>Stream Succession</h2>";

	$w_legend_bar = 500;
	$w_text = 30;
	$stamps = array_keys($seen_stamp);
	sort($stamps);

	$w_table = $w_legend_bar + $w_text;

	print "<table border=0 cellpadding=1 cellspacing=1 width=$w_table>";

	$j = 0;

	$_index = 0;
	foreach (array_values($this->info->streams) as $_val) {
	if ($_val->status == 'unselected ice candidate') {
	continue;
	}

	$_index = $_index+$_val->start_time;

	$_duration = $_val->end_time-$_val->start_time;
	$_timeout = $_val->timeout_wait;

	$duration_print = $_duration;

	if ($_val->status == 'conntrack timeout') {
	$w_duration = intval(($_duration-$_timeout)*$w_legend_bar/$this->info->duration);
	$w_timeout = intval($_timeout*$w_legend_bar/$this->info->duration);
	$duration_print = $_duration - $_timeout;
	} elseif ($_val->status == 'no-traffic timeout') {
	$w_duration = intval($_duration*$w_legend_bar/$this->info->duration);
	$w_timeout = intval($_timeout*$w_legend_bar/$this->info->duration);
	} elseif ($_val->status == 'closed') {
	$w_duration = intval($_duration * $w_legend_bar / $this->info->duration);
	$w_timeout = 0;
	}


	$w_start_time = intval($_index*$w_legend_bar/$this->info->duration);
	$w_rest = $w_legend_bar-$w_duration-$w_timeout-$w_start_time;
	$w_duration_p = ($w_legend_bar/$w_duration) * 100;
	$w_timeout = 0;
	if ($w_timeout > 0) {
	$w_timeout_p = ($w_legend_bar/$w_timeout) * 100;
	}
	$w_start_p = 0;
	if ($w_start_time > 0) {
	$w_start_p = ($w_legend_bar/$w_start_time)* 100;
	}
	//printf ("%s, %s, %s, %s<br>\n",$w_start_p,$w_duration_p,$w_timeout_p,$w_rest);

	if ($_val->caller_packets != '0' && $_val->callee_packets != '0') {
	print "<tr><td width=$w_text class=border>$_val->media_type</td>";
	print "<td width=$w_legend_bar>\n";
	//print "<table width=100% border=0 cellpadding=0 cellspacing=0><tr>\n";
	print "<div class='progress progress-striped'>";
	print "<div class=bar style='width:$w_start_p%'></div>\n";
	print "<div class='bar bar-success' style='width:$w_duration_p% ; text-align:center'><font color=white>$duration_print</font></div>\n";

	if ($_val->timeout_wait) {
	print "<div class='bar bar-danger' style='width:$w_timeout%; text-align:center'><font color=white>$_timeout</font></div>\n";
	} else {
	print "<div class='bar bar-warning' style='width:$w_timeout%; text-align:center'></div>\n";
	}
	//print "<td width=$w_rest bgcolor=white align=center></td>\n";

	//print "</table>\n";

	print "</td></tr>";
	} elseif ($_val->status == 'unselected ICE candidate') {
	print "<tr><td>ICE session</td></tr>";
	} else {
	print "<tr><td>No stream data found</td></tr>";
	}
	}

	print "</table>";

	print "<br><strong>Legend</strong>";
	print "<p><table border=0>
	<tr><td width=50><div class='progress progress-striped progress-success'><div class='bar' style='width:100%'></div></div></td><td>Session data</td></tr>
	<tr><td><div class='progress progress-striped progress-danger'><div class='bar' style='width:100%'></div></div></td><td>Timeout period</td></tr>
	</table></p></div></div>
	";
	}
	}

	include_once "phone_images.php";

	function getImageForUserAgent($msg)
	{
	global $userAgentImages;

	$msg_lines = explode("\n", $msg);
	foreach ($msg_lines as $line) {
	$els = explode(":", $line);
	if (strtolower($els[0]) == 'user-agent' \|\| strtolower($els[0]) == 'server') {
	foreach ($userAgentImages as $agentRegexp => $image) {
	if (preg_match("/^(user-agent\|server):.*$agentRegexp/i", $line)) {
	return $image;
	}
	}
	}
	}
	return "unknown.png";
	}

	function isThorNode($ip, $sip_proxy, $role="sip_proxy")
	{
	if (!$ip \|\| !$sip_proxy) {
	return false;
	}

	$socket = fsockopen($sip_proxy, 9500, $errno, $errstr, 1);

	if (!$socket) {
	return false;
	}

	$request=sprintf("is_online %s as %s", $ip, $role);

	if (fputs($socket, "$request\r\n") !== false) {
	$ret = trim(fgets($socket, 4096));
	fclose($socket);
	} else {
	fclose($socket);
	return false;
	}

	if ($ret == 'Yes') {
	return true;
	} else {
	return false;
	}
	}

	?>

File Metadata

Mime Type: text/x-diff
Expires: Tue, Nov 26, 7:41 AM (1 d, 21 h)
Storage Engine: blob
Storage Format: Raw Data
Storage Handle: 3414529
Default Alt Text: (328 KB)

No OneTemporaryActions

View Options

File Metadata

Event Timeline

No OneTemporary
Actions