-
- |
- |
- Date and Time
- |
- Caller
- |
- Duration
- |
-
- ");
+ $htmlBody .= sprintf(
+ "Received Calls
+
+
+
+ |
+ Date and Time |
+ Caller |
+ Duration |
+
"
+ );
$i=1;
foreach ($sessions['received'] as $_session) {
+ if ($i >= $count) {
+ break;
+ }
- if ($i >= $count) break;
-
- $htmlBody.=sprintf ("| %s | %s | sip:%s | %s |
",
- $i,
- $_session['date'],
- $_session['from'],
- $_session['from'],
- $_session['duration']
+ $htmlBody .= sprintf(
+ "| %s | %s | sip:%s | %s |
",
+ $i,
+ $_session['date'],
+ $_session['from'],
+ $_session['from'],
+ $_session['duration']
);
- $txtBody.=sprintf ("%s,%s,%s,%s\n",
- $i,
- $_session['date'],
- $_session['from'],
- $_session['duration']
+ $txtBody .= sprintf(
+ "%s,%s,%s,%s\n",
+ $i,
+ $_session['date'],
+ $_session['from'],
+ $_session['duration']
);
$i++;
}
$htmlBody.="
";
}
$htmlBody.="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'))
- );
+ $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');
$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));
+ $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);
+ syslog(LOG_NOTICE, $log);
}
- $query=sprintf("update memcache set `value` = '%s' where `key` = '%s'",Date('Y-m-d'),'notifySessionsLastRun');
+ $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);
+ $log = sprintf("Database error for query %s: %s (%s)", $query, $this->cdrtool->Error, $this->cdrtool->Errno);
print $log;
- syslog(LOG_NOTICE,$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');
+ $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);
+ $log=sprintf("Database error for query %s: %s (%s)", $query, $this->cdrtool->Error, $this->cdrtool->Errno);
print $log;
- syslog(LOG_NOTICE,$log);
+ syslog(LOG_NOTICE, $log);
return false;
}
}
}
}
- function getCallerId($account) {
+ function getCallerId($account)
+ {
if (!$account) {
- return NULL;
+ return null;
}
if ($this->callerid_cache[$account]) {
return $this->callerid_cache[$account];
}
- list($username,$domain) = explode('@',$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));
+ $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;
+ $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));
+ $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;
+ $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;
+ return null;
}
- function rate_on_net_enabled($username, $domain) {
+ 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));
+ $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);
+ $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;
+ $_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 {
+class CDR_opensips extends CDR
+{
- function CDR_opensips($parent, $CDRfields) {
+ function CDR_opensips($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);
}
$this->buildMongoCDR();
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];
+ 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);
+ syslog(LOG_NOTICE, $log);
$this->application = $this->defaultApplicationType;
}
//$this->applicationNormalized=$this->application;
if ($this->aNumber) {
- $NormalizedNumber = $this->CDRS->NormalizeNumber($this->aNumber,"source");
+ $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);
+ $_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 (!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'];
- } else if ($this->CDRS->trustedPeers[$_billing_party_els[1]]['reseller']) {
+ } elseif ($this->CDRS->trustedPeers[$_billing_party_els[1]]['reseller']) {
$this->ResellerId = $this->CDRS->trustedPeers[$_billing_party_els[1]]['reseller'];
}
- } else if (count($_billing_party_els)==1) {
+ } 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->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])) {
-
+ 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];
- } else if (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])) {
-
+ } 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);
+ $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;
- } else if ($this->cNumber) {
+ } 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);
+ $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);
+ $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);
+ $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';
}
- } else if ($this->CalleeIsLocal) {
+ } 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);
+ 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-off-net'
|| $this->flow == 'on-net-diverted-on-net'
|| $this->flow == 'diverted-on-net'
- || $this->flow == 'diverted-off-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($query);
- $this->tdb->query($query);
+ && $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,'@')) {
+ 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);
+ $this->inputTrafficPrint = number_format($this->inputTraffic/1024, 2);
} else {
- $this->inputTrafficPrint=0;
+ $this->inputTrafficPrint = 0;
}
if ($this->outputTraffic) {
- $this->outputTrafficPrint = number_format($this->outputTraffic/1024,2);
+ $this->outputTrafficPrint = number_format($this->outputTraffic/1024, 2);
} else {
- $this->outputTrafficPrint=0;
+ $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
+ $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);
+ $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';
}
}
}
- function buildMongoCDR() {
+ function buildMongoCDR()
+ {
# TODO = remove me
$this->mongo_cdr = array();
$int_values = array('duration', 'inputTraffic', 'outputTraffic', 'timestamp', 'disconnect');
foreach (array_keys($this->CDRS->CDRFields) as $field) {
if (in_array($field, $int_values)) {
$this->mongo_cdr[$field] = intval($this->$field);
} else {
$this->mongo_cdr[$field] = $this->$field;
}
}
if ($this->CanonicalURI) {
$this->mongo_cdr['CanonicalURI'] = $this->CanonicalURI;
}
if ($this->RemoteAddress) {
$this->mongo_cdr['RemoteAddress'] = $this->RemoteAddress;
}
if ($this->BillingPartyId) {
$this->mongo_cdr['BillingPartyId'] = $this->BillingPartyId;
}
if ($this->aNumber) {
$this->mongo_cdr['aNumber'] = $this->aNumber;
}
if ($this->cNumber) {
$this->mongo_cdr['cNumber'] = $this->cNumber;
}
if ($this->SipRPID) {
$this->mongo_cdr['SipRPID'] = $this->SipRPID;
}
}
- function buildCDRdetail() {
+ function buildCDRdetail()
+ {
global $perm;
global $found;
if (!is_object($perm)) return;
$this->geo_location=$this->lookupGeoLocation($this->SourceIP);
$this->cdr_details="
SIP Signalling
";
- $this->cdr_details.= sprintf("
-
Click here to show only this call id
- ",
- $this->CDRS->url_run,
- urlencode($this->callId)
+ $this->cdr_details.= sprintf(
+ "
Click here to show only this call id",
+ $this->CDRS->url_run,
+ urlencode($this->callId)
);
if ($this->CDRS->sipTrace) {
- $trace_datasource = $this->CDRS->sipTrace;
- $callid_enc = urlencode(quoted_printable_decode($this->callId));
- $fromtag_enc = urlencode(quoted_printable_decode($this->SipFromTag));
- $totag_enc = urlencode(quoted_printable_decode($this->SipToTag));
- $this->traceLink="
SipProxyServer', '_blank',
- 'toolbar=0,status=0,menubar=0,scrollbars=1,resizable=1,width=1300px,height=600')\">Click here for the SIP trace ";
+ $trace_query = array(
+ 'cdr_source' => $this->CDRS->sipTrace,
+ 'callid' => $this->callId,
+ 'fromtag' => $this->SipFromTag,
+ 'totag' => $this->SipToTag,
+ 'proxyIP' => $this->SipProxyServer
+ );
- $this->cdr_details.= "
+ $this->traceLink = sprintf(
+ "
+ Click here for the SIP trace ",
+ http_build_query($trace_query)
+ );
+
+ $this->cdr_details .= "
";
}
- $this->cdr_details.= sprintf("
+ $this->cdr_details .= sprintf(
+ "
- ", $this->traceLink);
+ ",
+ $this->traceLink
+ );
- $this->cdr_details.= "
+ $this->cdr_details .= "
From tag:
$this->SipFromTag
Start Time:
$this->startTime $providerTimezone
Stop Time:
$this->stopTime
";
- $this->cdr_details.= sprintf("
-
- ",$this->geo_location);
+ $this->cdr_details.= sprintf(
+ "
+
+ ",
+ $this->geo_location
+ );
$this->cdr_details.= "
Method:
$this->SipMethod from $this->SourceIP:$this->SourcePort
From:
$this->aNumberPrint
From Header:
$this->FromHeaderPrint
User Agent:
$this->UserAgentPrint
To (dialed URI):
$this->cNumberPrint
";
if ($this->CanonicalURI) {
- $this->cdr_details.= sprintf("
-
-
-
Canonical URI:
-
%s
-
- ",htmlentities($this->CanonicalURI));
+ $this->cdr_details .= sprintf(
+ "
+
+ ",
+ htmlentities($this->CanonicalURI)
+ );
}
- $this->cdr_details.= sprintf("
-
- ",htmlentities($this->RemoteAddress));
-
- if ($this->DestinationId) {
- $this->cdr_details.= "
+ $this->cdr_details .= sprintf(
+ "
-
-
Destination:
-
$this->destinationName ($this->DestinationId)
+
Next Hop URI:
+
%s
+ ",
+ htmlentities($this->RemoteAddress)
+ );
+
+ if ($this->DestinationId) {
+ $this->cdr_details .= "
+
+
Destination:
+
$this->destinationName ($this->DestinationId)
+
";
}
if ($this->ENUMtld && $this->ENUMtld != 'none' && $this->ENUMtld != 'N/A') {
$this->cdr_details.= "
-
-
-
ENUM TLD:
-
$this->ENUMtld
-
+
+
ENUM TLD:
+
$this->ENUMtld
+
";
}
if ($this->SipRPID) {
$this->cdr_details .= "
-
-
-
Caller ID:
-
$this->SipRPIDPrint
-
+
+
Caller ID:
+
$this->SipRPIDPrint
+
";
}
if ($this->CalleeCallerId) {
$this->cdr_details .= "
-
-
-
Called ID:
-
$this->CalleeCallerId
-
+
+
Called ID:
+
$this->CalleeCallerId
+
";
}
$this->cdr_details.= "
Billing Party:
$this->BillingPartyIdPrint
Reseller:
$this->ResellerId
";
$this->cdr_details.= "
";
if ($this->application != 'message') {
$this->cdr_details.= "
Media Streams
";
if ($this->CDRS->mediaTrace) {
- $media_trace_datasource = $this->CDRS->mediaTrace;
-
- $this->mediaTraceLink="
SipProxyServer', '_blank',
- 'toolbar=0,status=0,menubar=0,scrollbars=1,resizable=1,width=800,height=730')\">Click here for media information ";
+ $media_query = array(
+ 'cdr_source' => $this->CDRS->mediaTrace,
+ 'callid' => $this->callId,
+ 'fromtag' => $this->SipFromTag,
+ 'totag' => $this->SipToTag,
+ 'proxyIP' => $this->SipProxyServer
+ );
- $this->cdr_details.= sprintf("
-
- ", $this->mediaTraceLink);
+ $this->mediaTraceLink=sprintf(
+ "
Click here for media information ",
+ http_build_query($media_query)
+ );
+ $this->cdr_details.= sprintf(
+ "
+
+ ",
+ $this->mediaTraceLink
+ );
}
$this->SipCodec = quoted_printable_decode($this->SipCodec);
if ($this->SipCodec) {
$this->cdr_details.= "
";
}
$this->cdr_details.= "
-
-
-
Caller RTP:
-
$this->inputTrafficPrint KB
-
-
-
-
Called RTP:
-
$this->outputTrafficPrint KB
-
+
+
Caller RTP:
+
$this->inputTrafficPrint KB
+
+
+
Called RTP:
+
$this->outputTrafficPrint KB
+
";
if ($this->MediaInfo) {
$this->cdr_details.= "
-
Media Info:
-
$this->MediaInfo
+
Media Info:
+
$this->MediaInfo
";
}
$this->cdr_details.= "
Applications:
$this->application_print
";
-
}
if ($this->SipUserAgents) {
$this->SipUserAgents = quoted_printable_decode($this->SipUserAgents);
- $callerAgents=explode("+",$this->SipUserAgents);
- $callerUA=htmlentities($callerAgents[0]);
- $calledUA=htmlentities($callerAgents[1]);
+ $callerAgents = explode("+", $this->SipUserAgents);
+ $callerUA = htmlentities($callerAgents[0]);
+ $calledUA = htmlentities($callerAgents[1]);
$this->cdr_details.= "
";
}
$this->cdr_details.= "
";
if ($perm->have_perm("showPrice") && $this->normalized) {
$this->cdr_details.= "
Rating
";
if ($this->price > 0 || $this->rate) {
$this->ratePrint=nl2br($this->rate);
$this->cdr_details.= "
-
- $this->ratePrint
-
+
+ $this->ratePrint
+
";
-
} else {
$this->cdr_details.= "
Free call
";
}
$this->cdr_details.= "
";
}
$this->cdr_details.= "
";
}
- function traceIn () {
+ 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=
- "".
- "In".
- "";
+ $cdr_table = Date('Ym', time($this->timestamp));
+
+ $this->traceIn =
+ "".
+ "In".
+ "";
}
- function traceOut () {
+ 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));
+ $c_number = preg_replace("/^(0+)/", "", $this->remoteUsername);
+ $cdr_table = Date('Ym', time($this->timestamp));
$this->traceOut=
"".
"Out".
"";
}
- function show() {
+ 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';
+ if ($this->normalized) {
+ $found_print.='N';
+ }
$providerTimezone=$this->CDRS->CDRTool['provider']['timezone'];
print "
| $found_print |
$this->startTime |
$this->flow |
$this->aNumberPrint |
$this->geo_location |
$this->SipProxyServer |
$this->application |
$this->destinationPrint
";
if ($this->DestinationId) {
if ($this->DestinationId != $this->CanonicalURI) {
print " ($this->destinationName $this->DestinationId)";
} else {
print " ($this->destinationName)";
}
}
print " | ";
- if (!$this->normalized){
- if ($this->duration > 0 ) {
+ if (!$this->normalized) {
+ if ($this->duration > 0) {
print "$this->duration(s) | ";
} else {
print "in progress | ";
}
} else {
print "
$this->durationPrint |
$this->pricePrint |
$this->inputTrafficPrint |
$this->outputTrafficPrint |
";
}
- $SIPclass=substr($this->disconnect,0,1);
+ $SIPclass=substr($this->disconnect, 0, 1);
if ($SIPclass=="6") {
$status_color="";
- } else if ($SIPclass=="5" ) {
+ } elseif ($SIPclass == "5") {
$status_color="";
- } else if ($SIPclass=="4" ) {
+ } elseif ($SIPclass == "4") {
$status_color="";
- } else if ($SIPclass=="3" ) {
+ } elseif ($SIPclass == "3") {
$status_color="";
- } else if ($SIPclass=="2" ) {
+ } elseif ($SIPclass == "2") {
$status_color="";
- } else {
+ } else {
$status_color="";
}
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") {
+ $disclass = substr($this->disconnectOrig, 0, 1);
+ if ($disclass == "6" || $disclass == "5") {
$status1_color="";
- } else if ($disclass=="4" ) {
+ } elseif ($disclass == "4") {
$status1_color="";
- } else if ($disclass=="3" ) {
+ } elseif ($disclass == "3") {
$status1_color="";
- } else if ($disclass=="2" ) {
+ } elseif ($disclass == "2") {
$status1_color="";
- } else {
+ } else {
$status1_color="";
}
}
print "
$this->SipCodec |
$status_color $this->disconnectPrint";
if ($this->disconnectOrig != $this->disconnect
&& $this->CDRS->rating_settings['rate_on_net_diverted_calls']) {
print "$status1_color $this->disconnectOrigPrint";
}
print " |
";
}
- function export() {
+ function export()
+ {
global $found;
$disconnectName = $this->CDRS->disconnectCodesDescription[$this->disconnect];
- $UserAgents = explode("+",$this->SipUserAgents);
+ $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->SipRPIDPrint";
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)));
+ 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)));
+ printf(",%s", preg_replace("/,/", "/", quoted_printable_decode($this->SipCodec)));
print ",$this->application";
print "\n";
}
- function showSubscriber() {
+ 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';
+ if ($this->normalized) {
+ $found_print.='N';
+ }
print "
| $found_print |
$this->startTime $timezone_print |
$this->aNumberPrint |
$this->geo_location |
$this->SipProxyServer |
$this->destinationPrint $this->destinationName |
$this->durationPrint |
";
if ($this->CDRS->rating) {
print "$this->pricePrint | ";
}
print "
$this->inputTrafficPrint |
$this->outputTrafficPrint |
";
print "
";
-
} else {
- $disconnectName=$this->CDRS->disconnectCodesDescription[$this->disconnect];
- $UserAgents=explode("+",$this->SipUserAgents);
- $CallingUserAgent=trim($UserAgents[0]);
- $CalledUserAgent=trim($UserAgents[1]);
+ $disconnectName = $this->CDRS->disconnectCodesDescription[$this->disconnect];
+ $UserAgents = explode("+", $this->SipUserAgents);
+ $CallingUserAgent = trim($UserAgents[0]);
+ $CalledUserAgent = trim($UserAgents[1]);
print "$found,$this->startTime,$this->stopTime,$this->BillingPartyId,$this->domain,$this->aNumberPrint,$this->cNumberPrint,$this->DestinationId,$this->destinationName,$this->RemoteAddressPrint,$this->duration,$this->price,$this->SipProxyServer,$this->inputTraffic,$this->outputTraffic,$CallingUserAgent,$CalledUserAgent,$this->disconnect,$disconnectName,$this->SipCodec,$this->application\n";
}
}
- function isBillingPartyLocal() {
- $els=explode("@",$this->BillingPartyId);
+ function isBillingPartyLocal()
+ {
+ $els = explode("@", $this->BillingPartyId);
if ($els[1] && isset($this->CDRS->localDomains[$els[1]])) {
return true;
}
return false;
}
- function isCallerLocal() {
+ function isCallerLocal()
+ {
if (isset($this->CDRS->localDomains[$this->aNumberDomain])) {
- $this->CallerIsLocal=true;
+ $this->CallerIsLocal = true;
$this->SipRPID = $this->CDRS->getCallerId($this->BillingPartyId);
$this->SipRPIDPrint = $this->SipRPID;
#$this->SipRPIDPrint = quoted_printable_decode($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 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() {
+ function obfuscateCallerId()
+ {
global $obfuscateCallerId;
if ($obfuscateCallerId) {
-
//Caller party
- $caller_els=explode("@",$this->aNumberPrint);
+ $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';
+ $_user = substr($caller_els[0], 0, strlen($caller_els[0])-3).'xxx';
} else {
- $_user='caller';
+ $_user = 'caller';
}
- if (count($caller_els)== 2) {
- $this->aNumberPrint=$_user.'@'.$caller_els[1];
+ if (count($caller_els) == 2) {
+ $this->aNumberPrint = $_user.'@'.$caller_els[1];
} else {
- $this->aNumberPrint=$_user;
+ $this->aNumberPrint = $_user;
}
//Billing party
- $caller_els=explode("@",$this->BillingPartyIdPrint);
+ $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';
+ $_user = substr($caller_els[0], 0, strlen($caller_els[0])-3).'xxx';
} else {
- $_user='party';
+ $_user = 'party';
}
- $this->BillingPartyIdPrint=$_user.'@'.$caller_els[1];
+ $this->BillingPartyIdPrint = $_user.'@'.$caller_els[1];
// Destination
- $caller_els=explode("@",$this->destinationPrint);
+ $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';
+ $_user = substr($caller_els[0], 0, strlen($caller_els[0])-3).'xxx';
} else {
- $_user='destination';
+ $_user = 'destination';
}
- if (count($caller_els)== 2) {
- $this->destinationPrint=$_user.'@'.$caller_els[1];
+ if (count($caller_els) == 2) {
+ $this->destinationPrint = $_user.'@'.$caller_els[1];
} else {
- $this->destinationPrint=$_user;
+ $this->destinationPrint = $_user;
}
- $caller_els=explode("@",$this->cNumberPrint);
+ $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';
+ $_user = substr($caller_els[0], 0, strlen($caller_els[0])-3).'xxx';
} else {
- $_user='dialedNumber';
+ $_user = 'dialedNumber';
}
- if (count($caller_els)== 2) {
- $this->cNumberPrint=$_user.'@'.$caller_els[1];
+ if (count($caller_els) == 2) {
+ $this->cNumberPrint = $_user.'@'.$caller_els[1];
} else {
- $this->cNumberPrint=$_user;
+ $this->cNumberPrint = $_user;
}
- $caller_els=explode("@",$this->RemoteAddressPrint);
+ $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';
+ $_user = substr($caller_els[0], 0, strlen($caller_els[0])-3).'xxx';
} else {
- $_user='remoteAddress';
+ $_user = 'remoteAddress';
}
- if (count($caller_els)== 2) {
- $this->RemoteAddressPrint=$_user.'@'.$caller_els[1];
+ if (count($caller_els) == 2) {
+ $this->RemoteAddressPrint = $_user.'@'.$caller_els[1];
} else {
- $this->RemoteAddressPrint=$_user;
+ $this->RemoteAddressPrint = $_user;
}
// Canonical URI
- $caller_els=explode("@",$this->CanonicalURIPrint);
+ $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';
+ $_user = substr($caller_els[0], 0, strlen($caller_els[0])-3).'xxx';
} else {
- $_user='canonicalURI';
+ $_user = 'canonicalURI';
}
- if (count($caller_els)== 2) {
- $this->CanonicalURIPrint=$_user.'@'.$caller_els[1];
+ if (count($caller_els) == 2) {
+ $this->CanonicalURIPrint = $_user.'@'.$caller_els[1];
} else {
- $this->CanonicalURIPrint=$_user;
+ $this->CanonicalURIPrint = $_user;
}
if (is_numeric($this->SipRPIDPrint) && strlen($this->SipRPIDPrint) > 3) {
- $this->SipRPIDPrint=substr($this->SipRPID,0,strlen($this->SipRPID)-3).'xxx';
+ $this->SipRPIDPrint = substr($this->SipRPID, 0, strlen($this->SipRPID)-3).'xxx';
} else {
- $_user='callerId';
+ $_user = 'callerId';
}
// IP address
- $this->SourceIP='xxx.xxx.xxx.xxx';
+ $this->SourceIP = 'xxx.xxx.xxx.xxx';
}
}
}
-class CDRS_opensips_mongo extends CDRS_opensips {
- var $CDR_class = "CDR_opensips_mongo";
- var $mongo_db_ro = NULL;
- var $mongo_db_rw = NULL;
+class CDRS_opensips_mongo extends CDRS_opensips
+{
+ public $CDR_class = "CDR_opensips_mongo";
+ public $mongo_db_ro = null;
+ public $mongo_db_rw = null;
- function getCDRtables() {
+ function getCDRtables()
+ {
if (!is_object($this->mongo_db_rw) && !$this->initDatabaseConnection) {
return array();
}
$_tables=array();
try {
$_tables=$this->mongo_db_rw->listCollections();
} catch (Exception $e) {
printf("Caught Mongo exception in getCDRtables(): %s", $e->getMessage());
}
$t=count($_tables);
- if ($this->table) $this->tables[]=$this->table;
+ if ($this->table) {
+ $this->tables[]=$this->table;
+ }
foreach ($_tables as $_table) {
$_table=strval($_table);
- if (preg_match("/^.*\.(radacct\d{6})$/",$_table,$m)) {
- if ($list_t > 24) break;
+ if (preg_match("/^.*\.(radacct\d{6})$/", $_table, $m)) {
+ if ($list_t > 24) {
+ break;
+ }
if (!in_array($m[1], $this->tables)) {
$this->tables[]=$m[1];
}
$list_t++;
}
$t--;
}
$this->tables=array_unique($this->tables);
}
- function initDatabaseConnection() {
+ function initDatabaseConnection()
+ {
if ($this->DATASOURCES[$this->cdr_source]['mongo_db']) {
$mongo_db = $this->CDRTool['mongo_db'][$this->DATASOURCES[$this->cdr_source]['mongo_db']];
$mongo_uri = $mongo_db['uri'];
$mongo_replicaSet = $mongo_db['replicaSet'];
$mongo_database = $mongo_db['database'];
try {
$mongo_connection_ro = new Mongo("mongodb://$mongo_uri?readPreference=secondaryPreferred", array("replicaSet" => $mongo_replicaSet));
$this->mongo_db_ro = $mongo_connection_ro->selectDB($mongo_database);
$mongo_connection_rw = new Mongo("mongodb://$mongo_uri?readPreference=primaryPreferred", array("replicaSet" => $mongo_replicaSet));
$this->mongo_db_rw = $mongo_connection_rw->selectDB($mongo_database);
return true;
} catch (Exception $e) {
printf("
Caught exception in initDatabaseConnection(): %s", $e->getMessage());
return false;
}
}
return true;
}
- function getMongoTable($table, $rw=false) {
+ function getMongoTable($table, $rw=false)
+ {
try {
if ($rw) {
if (!$this->mongo_db_rw && !$this->initDatabaseConnection()) {
- return NULL;
+ return null;
}
$table = $this->mongo_db_rw->selectCollection($table);
} else {
if (!$this->mongo_db_ro && !$this->initDatabaseConnection()) {
- return NULL;
+ return null;
}
$table = $this->mongo_db_ro->selectCollection($table);
}
return $table;
} catch (Exception $e) {
printf("
Caught exception in getMongoTable(): %s", $e->getMessage());
}
- return NULL;
+ return null;
}
- function initCDRFields() {
+ function initCDRFields()
+ {
// init names of CDR fields
foreach (array_keys($this->CDRFields) as $field) {
- $mongo_field=$field;
- $_field=$field."Field";
- $this->$_field=$mongo_field;
+ $mongo_field = $field;
+ $_field = $field."Field";
+ $this->$_field = $mongo_field;
}
}
- function _readCDRFieldsFromDB($mongo_result) {
+ function _readCDRFieldsFromDB($mongo_result)
+ {
foreach (array_keys($this->CDRFields) as $field) {
$CDRStructure[$this->CDRFields[$field]] = $mongo_result[$field];
}
return $CDRStructure;
}
- function getUnNormalized($where="",$table) {
- # TODO
- return 0;
+ function getUnNormalized($where="", $table)
+ {
+ // TODO
+ return 0;
}
- function show() {
+ function show()
+ {
global $perm;
foreach ($this->FormElements as $_el) {
${$_el} = trim($_REQUEST[$_el]);
}
if ($begin_time) {
- list($begin_hour,$begin_min)=explode(":",$begin_time);
+ list($begin_hour, $begin_min) = explode(":", $begin_time);
}
if ($end_time) {
- list($end_hour,$end_min)=explode(":",$end_time);
+ list($end_hour, $end_min) = explode(":", $end_time);
}
if ($begin_date) {
- list($begin_year,$begin_month,$begin_day)=explode("-",$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);
+ 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'];
+ $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);
+ $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);
+ $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";
+ $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);
+ $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);
+ $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;
+ $order_by = $this->idField;
}
$mongo_where = array();
- if (!$cdr_table) $cdr_table=$this->table;
+ if (!$cdr_table) {
+ $cdr_table=$this->table;
+ }
$mongo_table_ro = $this->getMongoTable($cdr_table);
$mongo_table_rw = $this->getMongoTable($cdr_table, true);
- $this->url=sprintf("?cdr_source=%s&cdr_table=%s",$this->cdr_source,$cdr_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']);
- } else if ($Realms) {
- $this->url .= sprintf("&Realms=%s",urlencode($Realms));
- $Realms = explode(" ",$Realms);
+ $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']));
+ $this->url .= sprintf("&UserName=%s", urlencode($this->CDRTool['filter']['aNumber']));
}
if ($this->CDRTool['filter']['after_date']) {
$mongo_where[$this->startTimeField] = array('$gte' => $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("&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));
+ $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) {
$mongo_where[$this->startTimeField] = array('$gte' => $begin_datetime, '$lt' => $end_datetime);
} else {
$mongo_where[$this->startTimeField] = array('$gte' => '1970-01-01');
}
if ($MONTHYEAR) {
$mongo_where[$this->startTimeField] = new MongoRegex("/^$MONTHYEAR/");
- $this->url.= sprintf("&MONTHYEAR=%s",urlencode($MONTHYEAR));
+ $this->url.= sprintf("&MONTHYEAR=%s", urlencode($MONTHYEAR));
}
if ($flow) {
- $this->url.=sprintf("&flow=%s",urlencode($flow));
+ $this->url.=sprintf("&flow=%s", urlencode($flow));
$mongo_where[$this->flowField] = $flow;
}
if ($this->CDRTool['filter']['aNumber']) {
// force user to see only CDRS with his a_numbers
$mongo_where['$or'] = array(array($this->usernameField => $this->CDRTool['filter']['aNumber']), array($this->CanonicalURIField => $this->CDRTool['filter']['aNumber']));
- $UserName_comp='equal';
- $UserName=$this->CDRTool['filter']['aNumber'];
+ $UserName_comp = 'equal';
+ $UserName = $this->CDRTool['filter']['aNumber'];
}
if ($UserName_comp == "empty") {
$mongo_where[$this->usernameField] = '';
- $this->url.=sprintf("&UserName_comp=%s",urlencode($UserName_comp));
- } else if (strlen($UserName) && !$this->CDRTool['filter']['aNumber']) {
- if (!$UserName_comp) $UserName_comp='begin';
+ $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") {
$mongo_where[$this->usernameField] = new MongoRegex("/^$UserName/");
} elseif ($UserName_comp=="contain") {
$mongo_where[$this->usernameField] = new MongoRegex("/$UserName/");
} elseif ($UserName_comp=="equal") {
$mongo_where[$this->usernameField] = $UserName;
} else {
$mongo_where[$this->usernameField] = '';
}
- $this->url.=sprintf("&UserName=%s&UserName_comp=%s",urlencode($UserName),$UserName_comp);
+ $this->url.=sprintf("&UserName=%s&UserName_comp=%s", urlencode($UserName), $UserName_comp);
}
$a_number=trim($a_number);
if ($a_number_comp == "empty") {
$mongo_where[$this->aNumberField] = '';
- $this->url.=sprintf("&a_number_comp=%s",urlencode($a_number_comp));
- } else if (strlen($a_number)) {
+ $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";
+ if (!$a_number_comp) {
+ $a_number_comp="equal";
+ }
- $this->url.=sprintf("&a_number=%s",urlencode($a_number));
+ $this->url.=sprintf("&a_number=%s", urlencode($a_number));
if ($a_number_comp=="begin") {
$mongo_where[$this->aNumberField] = new MongoRegex("/^$a_number/");
} elseif ($a_number_comp=="contain") {
$mongo_where[$this->aNumberField] = new MongoRegex("/$a_number/");
} elseif ($a_number_comp=="equal") {
$mongo_where[$this->aNumberField] = $a_number;
}
- $this->url.=sprintf("&a_number_comp=%s",urlencode($a_number_comp));
+ $this->url.=sprintf("&a_number_comp=%s", urlencode($a_number_comp));
}
$c_number=trim($c_number);
if ($c_number_comp == "empty") {
$mongo_where[$this->CanonicalURIField] = '';
- $this->url.=sprintf("&c_number_comp=%s",urlencode($c_number_comp));
- } else if (strlen($c_number)) {
+ $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";
+ }
if (!$c_number_comp || $c_number_comp=="begin") {
$mongo_where[$this->CanonicalURIField] = new MongoRegex("/^$c_number/");
} elseif ($c_number_comp=="contain") {
$mongo_where[$this->CanonicalURIField] = new MongoRegex("/$c_number/");
} elseif ($c_number_comp=="equal") {
$mongo_where[$this->CanonicalURIField] = $c_number;
}
- $this->url.=sprintf("&c_number=%s&c_number_comp=%s",urlencode($c_number),urlencode($c_number_comp));
+ $this->url.=sprintf("&c_number=%s&c_number_comp=%s", urlencode($c_number), urlencode($c_number_comp));
}
$Realm=trim($Realm);
- if ($Realms) {
+ if ($Realms) {
$d_array=array();
foreach ($Realms as $realm) {
$d_array[] = array($this->domainField => $realm);
}
$mongo_where['$or'] = $d_array;
- } else if ($Realm) {
+ } elseif ($Realm) {
$Realm=urldecode($Realm);
$mongo_where[$this->domainField] = $Realm;
- $this->url.=sprintf("&Realm=%s",urlencode($Realm));
+ $this->url.=sprintf("&Realm=%s", urlencode($Realm));
}
$BillingId=trim($BillingId);
- if (preg_match("/^\d+$/",$BillingId) && $this->BillingIdField) {
+ if (preg_match("/^\d+$/", $BillingId) && $this->BillingIdField) {
$mongo_where[$this->BillingIdField] = $BillingId;
- $this->url.=sprintf("&BillingId=%s",urlencode($BillingId));
+ $this->url.=sprintf("&BillingId=%s", urlencode($BillingId));
}
if ($application) {
$mongo_where[$this->applicationField] = new MongoRegex("/$application/");
- $this->url.=sprintf("&application=%s",urlencode($application));
+ $this->url.=sprintf("&application=%s", urlencode($application));
}
if ($DestinationId) {
if ($DestinationId=="empty") {
$DestinationIdSQL="";
} else {
$DestinationIdSQL=$DestinationId;
}
$mongo_where[$this->DestinationIdField] = $DestinationIdSQL;
- $this->url.=sprintf("&DestinationId=%s",urlencode($DestinationId));
+ $this->url.=sprintf("&DestinationId=%s", urlencode($DestinationId));
}
if (strlen(trim($ExcludeDestinations))) {
# TODO: migrateb clause to mongo
- $ExcludeDestArray=explode(" ",trim($ExcludeDestinations));
+ $ExcludeDestArray = explode(" ", trim($ExcludeDestinations));
foreach ($ExcludeDestArray as $exclDst) {
- if (preg_match("/^0+(\d+)$/",$exclDst,$m)) {
+ 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));
+ $this->url.=sprintf("&ExcludeDestinations=%s", urlencode($ExcludeDestinations));
}
$call_id=trim($call_id);
if ($call_id) {
$call_id=urldecode($call_id);
$mongo_where[$this->callIdField] = $call_id;
- $this->url.=sprintf("&call_id=%s",urlencode($call_id));
+ $this->url.=sprintf("&call_id=%s", urlencode($call_id));
}
if ($sip_proxy) {
$sip_proxy=urldecode($sip_proxy);
$mongo_where[$this->SipProxyServerField] = $sip_proxy;
- $this->url.=sprintf("&sip_proxy=%s",urlencode($sip_proxy));
+ $this->url.=sprintf("&sip_proxy=%s", urlencode($sip_proxy));
}
if ($SipCodec) {
- $this->url.=sprintf("&SipCodec=%s",urlencode($SipCodec));
+ $this->url.=sprintf("&SipCodec=%s", urlencode($SipCodec));
if ($SipCodec != "empty") {
$mongo_where[$this->SipCodecField] = $SipCodec;
} else {
$mongo_where[$this->SipCodecField] = '';
}
}
if ($SipRPID) {
- $this->url.=sprintf("&SipRPID=%s",urlencode($SipRPID));
+ $this->url.=sprintf("&SipRPID=%s", urlencode($SipRPID));
if ($SipRPID != "empty") {
$mongo_where[$this->SipRPIDField] = $SipRPID;
} else {
$mongo_where[$this->SipRPIDField] = '';
}
}
if ($UserAgent) {
$mongo_where[$this->UserAgentField] = $UserAgent;
- $this->url.=sprintf("&UserAgent=%s",urlencode($UserAgent));
+ $this->url.=sprintf("&UserAgent=%s", urlencode($UserAgent));
}
if (strlen($sip_status)) {
$mongo_where[$this->disconnectField] = $sip_status;
- $this->url.=sprintf("&sip_status=%s",urlencode($sip_status));
+ $this->url.=sprintf("&sip_status=%s", urlencode($sip_status));
}
if ($sip_status_class) {
$mongo_where[$this->disconnectField] = new MongoRegex("/^$sip_status_class/");
- $this->url.=sprintf("&sip_status_class=%s",urlencode($sip_status_class));
+ $this->url.=sprintf("&sip_status_class=%s", urlencode($sip_status_class));
}
if ($this->CDRTool[filter]["gateway"]) {
$mongo_where[$this->gatewayField] = $this->CDRTool[filter]["gateway"];
- } else if ($gateway) {
+ } elseif ($gateway) {
$gateway=urldecode($gateway);
$mongo_where[$this->gatewayField] = $gateway;
- $this->url.=sprintf("&gateway=%s",$gateway);
+ $this->url.=sprintf("&gateway=%s", $gateway);
}
if ($duration) {
- if (preg_match("/\d+/",$duration) ) {
- $mongo_where[$this->durationField] = array('$gt' => 0);;
- } elseif (preg_match("/onehour/",$duration) ) {
+ if (preg_match("/\d+/", $duration)) {
+ $mongo_where[$this->durationField] = array('$gt' => 0);
+ } elseif (preg_match("/onehour/", $duration)) {
$mongo_where[$this->durationField] = array('$lt' => 3610, '$gt' => 3530);
} elseif ($duration == "zero") {
$mongo_where[$this->durationField] = 0;
} elseif ($duration == "zeroprice" && $this->priceField) {
$mongo_where[$this->durationField] = array('$gt' => 0);
- $mongo_where[$this->priceField] = NULL;
+ $mongo_where[$this->priceField] = null;
} elseif ($duration == "nonzero") {
$mongo_where[$this->durationField] = array('$gt' => 0);
} elseif ($duration == "onewaymedia") {
$mongo_where['$or'] = array(array($this->outputTrafficField => 0), array($this->inputTrafficField => 0));
} elseif ($duration == "nomedia") {
$mongo_where[$this->inputTrafficField] = 0;
$mongo_where[$this->outputTrafficField] = 0;
}
- $this->url.=sprintf("&duration=%s",urlencode($duration));
+ $this->url.=sprintf("&duration=%s", urlencode($duration));
}
if ($media_info) {
- $this->url.=sprintf("&media_info=%s",urlencode($media_info));
+ $this->url.=sprintf("&media_info=%s", urlencode($media_info));
$mongo_where[$this->MediaInfoField] = $media_info;
}
- $this->url.=sprintf("&maxrowsperpage=%s",addslashes($this->maxrowsperpage));
+ $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.=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") {
$mongo_where[$this->normalizedField] = '0';
}
if ($duration == "unnormalized_duration") {
$mongo_where[$this->normalizedField] = '0';
$mongo_where[$this->durationField] = array('$gt' => 0);
}
if ($group_by) {
-
$this->group_byOrig=$group_by;
- if ($group_by=="hour") {
- $group_by="HOUR(AcctStartTime)";
- } else if (preg_match("/^DAY/",$group_by)) {
- $group_by="$group_by(AcctStartTime)";
- } else if (preg_match("/BYMONTH/",$group_by)) {
- $group_by="DATE_FORMAT(AcctStartTime,'%Y-%m')";
- } else if (preg_match("/BYYEAR/",$group_by)) {
- $group_by="DATE_FORMAT(AcctStartTime,'%Y')";
- } else if ($group_by=="UserAgentType") {
- $group_by="SUBSTRING_INDEX($this->SipUserAgentsField, ' ', '1')";
+ 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));
}
$field = array_search($group_by, $this->CDRFields);
$pipeline=array(
array('$match' => $mongo_where),
array('$group' => array("_id" => sprintf('$%s', $field),
'calls' => array('$sum' => 1))),
array('$match' => array('calls' => array('$gte' => 0)))
);
$rows = 0;
if ($mongo_table_ro) {
try {
$group_results = $mongo_table_ro->aggregate($pipeline);
$rows = count($group_results);
} catch (Exception $e) {
printf("
Caught Mongo exception in show(): %s", $e->getMessage());
}
}
-
} else {
$rows = 0;
if ($mongo_table_ro) {
try {
$rows = $mongo_table_ro->find($mongo_where)->slaveOkay()->count();
} catch (Exception $e) {
printf("
Caught Mongo exception in show(): %s", $e->getMessage());
}
}
}
dprint_r($mongo_where);
$this->rows=$rows;
if ($this->CDRTool['filter']['aNumber']) {
- $this->showResultsMenuSubscriber('0',$begin_datetime,$end_datetime);
+ $this->showResultsMenuSubscriber('0', $begin_datetime, $end_datetime);
} else {
- $this->showResultsMenu('0',$begin_datetime,$end_datetime);
+ $this->showResultsMenu('0', $begin_datetime, $end_datetime);
}
- if (!$this->next) {
+ if (!$this->next) {
$i=0;
$this->next=0;
} else {
$i=$this->next;
}
$j=0;
$z=0;
- if ($rows>0) {
-
+ if ($rows>0) {
if ($call_id && $ReNormalize) {
if ($mongo_table_rw) {
$mongo_table_rw->update(array($this->normalizedField=>0), array('$set' => array($this->callIdField => $call_id)));
}
}
- if ($UnNormalizedCalls=$this->getUnNormalized($mongo_where,$cdr_table)) {
+ if ($UnNormalizedCalls=$this->getUnNormalized($mongo_where, $cdr_table)) {
if (!$this->DATASOURCES[$this->cdr_source]['skipNormalizeOnPageLoad']) {
if ($UnNormalizedCalls < $this->maxCDRsNormalizeWeb) {
- $this->NormalizeCDRS($mongo_where,$cdr_table);
- if (!$this->export && $this->status['normalized'] ) {
+ $this->NormalizeCDRS($mongo_where, $cdr_table);
+ if (!$this->export && $this->status['normalized']) {
print "
";
- printf ("%d CDRs normalized. ",$this->status['normalized']);
+ printf("%d CDRs normalized. ", $this->status['normalized']);
if ($this->status['cached_keys']['saved_keys']) {
- printf ("Quota usage updated for %d accounts. ",$this->status['cached_keys']['saved_keys']);
+ printf("Quota usage updated for %d accounts. ", $this->status['cached_keys']['saved_keys']);
}
print "
";
}
}
}
}
- if ($rows > $this->maxrowsperpage) {
+ 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'];
}
$mongo_order_by = '_id';
if ($order_type == DESC) {
$mongo_order_type = -1;
} else {
$mongo_order_type = 1;
}
if ($group_by) {
if ($order_by == "group_by") {
$mongo_order_by = '_id';
} else {
$_tmp = array_search($order_by, $this->CDRFields);
if (in_array($_tmp, array('price', 'duration','inputTraffic', 'outputTraffic'))) {
$mongo_order_by = $_tmp;
} else {
$mongo_order_by = 'calls';
}
}
- $pipeline=array(
- array('$match' => $mongo_where),
- array('$group' => array('_id' => sprintf('$%s', $field),
- 'calls' => array( '$sum' => 1),
- 'duration' => array( '$sum' => '$duration'),
- 'inputTraffic' => array( '$sum' => '$inputTraffic'),
- 'outputTraffic' => array( '$sum' => '$outputTraffic'),
- 'price' => array( '$sum' => '$price'),
- 'zero' => array( '$sum' => array('$cond'=> array(array('$eq' => array('$duration', 0)), 1, 0 ))),
- 'nonzero' => array( '$sum' => array('$cond'=> array(array('$gt' => array('$duration', 0)), 1, 0 )))
- )
- ),
-
- array('$match' => array('calls' => array('$gte' => 0))),
- array('$sort' => array($mongo_order_by => $mongo_order_type)),
- array('$skip' => intval($i)),
- array('$limit' => intval($this->maxrowsperpage))
+ $pipeline = array(
+ array('$match' => $mongo_where),
+ array('$group' => array(
+ '_id' => sprintf('$%s', $field),
+ 'calls' => array( '$sum' => 1),
+ 'duration' => array( '$sum' => '$duration'),
+ 'inputTraffic' => array( '$sum' => '$inputTraffic'),
+ 'outputTraffic' => array( '$sum' => '$outputTraffic'),
+ 'price' => array( '$sum' => '$price'),
+ 'zero' => array( '$sum' => array('$cond'=> array(array('$eq' => array('$duration', 0)), 1, 0 ))),
+ 'nonzero' => array( '$sum' => array('$cond'=> array(array('$gt' => array('$duration', 0)), 1, 0 )))
+ )),
+ array('$match' => array('calls' => array('$gte' => 0))),
+ array('$sort' => array($mongo_order_by => $mongo_order_type)),
+ array('$skip' => intval($i)),
+ array('$limit' => intval($this->maxrowsperpage))
);
//dprint_r($pipeline);
try {
$group_results = $mongo_table_ro->aggregate($pipeline);
} catch (Exception $e) {
printf("Caught Mongo exception in show(): %s", $e->getMessage());
}
$this->showTableHeaderStatistics();
foreach ($group_results as $result) {
$found=$i+1;
$mygroup = $result['_id'];
$calls = $result['calls'];
$seconds = $result['duration'];
$price = $result['price'];
$zero = $result['zero'];
$zeroP = $calls/$zero * 100;
$nonzero = $result['nonzero'];
$nonzeroP = $calls/$nonzero * 100;
- $seconds_print = number_format($seconds,0);
- $minutes = number_format($seconds/60,0,"","");
- $minutes_print = number_format($seconds/60,0);
+ $seconds_print = number_format($seconds, 0);
+ $minutes = number_format($seconds/60, 0, "", "");
+ $minutes_print = number_format($seconds/60, 0);
$hours = sec2hms($seconds);
- $AcctInputOctets = number_format($result['inputTraffic'] * 2/ 1024/1024,2,".","");
- $AcctOutputOctets = number_format($result['outputTraffic'] * 2/ 1024/1024,2,".","");
+ $AcctInputOctets = number_format($result['inputTraffic'] * 2/ 1024/1024, 2, ".", "");
+ $AcctOutputOctets = number_format($result['outputTraffic'] * 2/ 1024/1024, 2, ".", "");
$NetRateIn = $result['inputTraffic']*8*2/1024/$seconds;
$NetRateOut = $result['outputTraffic']*8*2/1024/$seconds;
- $success = number_format($nonzero/$calls*100,2,".","");
- $failure = number_format($zero/$calls*100,2,".","");
+ $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);
+ $NetworkRateIn = number_format($NetRateIn, 2);
+ $NetworkRateOut = number_format($NetRateOut, 2);
+ $NetworkRate = max($NetworkRateIn, $NetworkRateOut);
- $rr=floor($found/2);
- $mod=$found-$rr*2;
+ $rr = floor($found/2);
+ $mod = $found - $rr * 2;
- if ($mod ==0) {
- $inout_color="lightgrey";
+ if ($mod == 0) {
+ $inout_color = "lightgrey";
} else {
- $inout_color="white";
+ $inout_color = "white";
}
$traceValue="";
$mygroup_print=quoted_printable_decode($mygroup);
- if ($this->group_byOrig==$this->DestinationIdField) {
+ 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']);
+ list($_dst_id, $_dst_name) = $this->getPSTNDestinationId($mygroup, '', $this->CDRTool['filter']['domain']);
$description=$_dst_name;
} else {
$description=$this->destinations[0]["default"][$mygroup]["name"];
}
if ($mygroup) {
$traceValue=$mygroup;
} else {
$traceValue="empty";
}
-
- } else if ($this->group_byOrig==$this->aNumberField) {
- # Normalize Called Station Id
+ } 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);
- } else if ($this->group_byOrig==$this->CanonicalURIField) {
- $traceField="c_number";
- $traceValue=urlencode($mygroup);
- } else if ($this->group_byOrig==$this->SipProxyServerField) {
+ $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);
- } else if ($this->group_byOrig==$this->SipCodecField) {
+ } elseif ($this->group_byOrig == $this->SipCodecField) {
$traceField="SipCodec";
- } else if (preg_match("/UserAgent/",$this->group_byOrig)) {
+ } elseif (preg_match("/UserAgent/", $this->group_byOrig)) {
$traceField="UserAgent";
- } else if (preg_match("/^BY/",$this->group_byOrig)) {
+ } elseif (preg_match("/^BY/", $this->group_byOrig)) {
$traceField="MONTHYEAR";
- } else if ($this->group_byOrig==$this->callIdField) {
+ } elseif ($this->group_byOrig == $this->callIdField) {
$traceField="call_id";
- } else if ($this->group_byOrig=="SourceIP") {
+ } elseif ($this->group_byOrig == "SourceIP") {
$traceField = "gateway";
- } else if ($this->group_byOrig=="SipResponseCode") {
+ } elseif ($this->group_byOrig == "SipResponseCode") {
$description = $this->disconnectCodesDescription[$mygroup];
$traceField="sip_status";
- } else if ($this->group_byOrig=="SipApplicationType") {
+ } elseif ($this->group_byOrig == "SipApplicationType") {
$traceField="application";
- } else if ($this->group_byOrig=="ServiceType") {
+ } 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 "
| $found |
$calls |
$seconds_print |
$minutes_print |
$hours |
";
- if ($perm->have_perm("showPrice")) {
- $pricePrint=number_format($price,4,".","");
- } else {
- $pricePrint='x.xxx';
- }
- print "
+ if ($perm->have_perm("showPrice")) {
+ $pricePrint=number_format($price, 4, ".", "");
+ } else {
+ $pricePrint='x.xxx';
+ }
+ print "
$pricePrint |
$AcctInputOctets |
$AcctOutputOctets |
$success% |
($nonzero calls) |
$failure% |
($zero calls) |
$mygroup_print |
$description |
";
- printf("Display calls | ",$url_calls,$traceField,$traceValue_enc,$traceField,$comp_type);
- print "
+ printf("Display calls", $url_calls, $traceField, $traceValue_enc, $traceField, $comp_type);
+ print "
";
+ } else {
+ print "$found,";
+ print "$calls,";
+ print "$seconds,";
+ print "$minutes,";
+ print "$hours,";
+ if ($perm->have_perm("showPrice")) {
+ $pricePrint = $price;
} 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";
+ $pricePrint = 'x.xxx';
}
- $i++;
- }
+ 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 "
+ if (!$this->export) {
+ print "
- ";
- }
-
- } else {
- if (!$this->export) {
- // printf ("