[Freeswitch-svn] [commit] r12653 - freeswitch/trunk/scripts/contrib/swk/php/esl_cdr

[FreeSWITCH SVN]

Author: silik0n
Date: Tue Mar 17 16:09:12 2009
New Revision: 12653

Log:
just a little something for an example of how to do CDRs from ESL with PHP

Added:
   freeswitch/trunk/scripts/contrib/swk/php/esl_cdr/
   freeswitch/trunk/scripts/contrib/swk/php/esl_cdr/esl_cdr.php
   freeswitch/trunk/scripts/contrib/swk/php/esl_cdr/esl_cdr.postgres.sql

Added: freeswitch/trunk/scripts/contrib/swk/php/esl_cdr/esl_cdr.php
==============================================================================
--- (empty file)
+++ freeswitch/trunk/scripts/contrib/swk/php/esl_cdr/esl_cdr.php	Tue Mar 17 16:09:12 2009
@@ -0,0 +1,92 @@
+<?
+require_once('ESL.php');
+require_once("MDB2.php");
+
+$esl_host = '127.0.0.1';
+$esl_port = '8021';
+$esl_password = 'ClueCon';
+
+
+$db_url ="pgsql://root@localhost/esl_cdr";
+
+$con = MDB2::factory($db_url);
+if(PEAR::isError($con)) {
+    die("Error while connecting : " . $con->getMessage());
+}
+
+/* set up the ESL Connection */
+$esl = new eslConnection('204.8.45.218', '8021', 'disasterisk-sucks');
+$e = $esl->sendRecv("api status");
+print $e->getBody();
+$esl->events("plain", "channel_hangup");
+for(;;) {
+	print "foo - 1\n";
+	$e = $esl->recvEvent();
+	if ($e) {
+		$lines = explode("\n", $e->serialize());
+		foreach ($lines as $line){
+			$temp_data = explode(": ", $line);
+			
+			if ($temp_data[0]){
+				if ($temp_data[0] == 'variable_easy_acctcode'){
+					$data['acctcode'] = $temp_data[1];
+				} elseif ($temp_data[0] == 'variable_acctcode'){
+					$data['acctcode'] = $temp_data[1];
+				} elseif ($temp_data[0] == 'variable_accountcode'){
+					$data['acctcode'] = $temp_data[1];
+				} elseif ($temp_data[0] == 'variable_account_code'){
+					$data['acctcode'] = $temp_data[1];
+				} else {
+					$data[$temp_data[0]] = $temp_data[1];
+				}
+			}
+		}
+
+        $insert = sprintf("INSERT into cdr (uuid, acctcode, ani, e164_ani, dnis, translated_dnis, e164_dnis, src_host, read_codec, write_codec, clid_name, ".
+	"clid_number, src_sdp, dest_sdp, originate_disposition, bridge_to_uuid, endpoint_disposition, sip_hangup_disposition, term_cause, ".
+	"hangup_cause, start_stamp, answer_stamp, progress_media_stamp, end_stamp, duration, billsec, progress_mediasec, billmin, ".
+	"carrier_id, cust_cost, carrier_cost)".
+	"VALUES".
+	"('%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', %s, '%s', '%s',".
+	"%s, %s, %s, %s, %s, %s, %s)",
+	$data['Unique-ID'],
+	$data['acctcode'],
+	$data['Caller-Caller-ID-Number'],
+	$data['Caller-Caller-ID-Number'],
+	urldecode($data['Caller-Destination-Number']),
+	urldecode($data['Caller-Destination-Number']),
+	urldecode($data['Caller-Destination-Number']),
+	$data['Caller-Network-Addr'],
+	$data['Channel-Read-Codec-Name']."-". $data['Channel-Read-Codec-Rate'],
+	$data['Channel-Write-Codec-Name']."-". $data['Channel-Write-Codec-Rate'],
+	urlencode($data['Caller-Caller-ID-Name']),
+	$data['Caller-Caller-ID-Number'],
+	$data['variable_switch_r_sdp'],
+	$data['variable_switch_m_sdp'],
+	$data['variable_originate_disposition'],
+	$data['variable_bridge_to'],
+	$data['variable_endpoint_disposition'],
+	$data['variable_sip_hangup_disposition'],
+	$data['variable_sip_term_cause'],
+	$data['variable_hangup_cause'],
+	urldecode($data['variable_start_stamp']) . '-05',
+	isset($data['variable_answer_stamp'])?'\''. urldecode($data['variable_answer_stamp']) . '-05\'':'null',
+	urldecode($data['variable_progress_media_stamp']) . '-05',
+	urldecode($data['variable_end_stamp']) . '-05',
+	$data['variable_duration'],
+	$data['variable_billsec'],
+	$data['variable_progress_mediasec'],
+	$data['variable_billsec'],
+	"0",
+	"0",
+	"0"
+	);
+
+		$result = $con->query($insert);
+                if(PEAR::isError($result)) {
+                        echo "$insert\n";
+			die();
+                }
+	}
+}
+?> 

Added: freeswitch/trunk/scripts/contrib/swk/php/esl_cdr/esl_cdr.postgres.sql
==============================================================================
--- (empty file)
+++ freeswitch/trunk/scripts/contrib/swk/php/esl_cdr/esl_cdr.postgres.sql	Tue Mar 17 16:09:12 2009
@@ -0,0 +1,71 @@
+--
+-- PostgreSQL database dump
+--
+
+SET client_encoding = 'UTF8';
+SET standard_conforming_strings = off;
+SET check_function_bodies = false;
+SET client_min_messages = warning;
+SET escape_string_warning = off;
+
+SET search_path = public, pg_catalog;
+
+SET default_tablespace = '';
+
+SET default_with_oids = false;
+
+--
+-- Name: cdr; Type: TABLE; Schema: public; Owner: root; Tablespace: 
+--
+
+CREATE TABLE cdr (
+    uuid character varying,
+    acctcode character varying,
+    ani character varying,
+    e164_ani character varying,
+    dnis character varying,
+    translated_dnis character varying,
+    e164_dnis character varying,
+    src_host character varying,
+    read_codec character varying,
+    write_codec character varying,
+    clid_name character varying,
+    clid_number character varying,
+    src_sdp character varying,
+    dest_sdp character varying,
+    originate_disposition character varying,
+    bridge_to_uuid character varying,
+    endpoint_disposition character varying,
+    sip_hangup_disposition character varying,
+    term_cause character varying,
+    hangup_cause character varying,
+    start_stamp timestamp with time zone,
+    answer_stamp timestamp with time zone,
+    progress_media_stamp timestamp with time zone,
+    end_stamp timestamp with time zone,
+    duration integer,
+    billsec integer,
+    progress_mediasec integer,
+    billmin numeric(8,2),
+    carrier_id integer,
+    cust_cost numeric(7,4),
+    carrier_cost numeric(7,4)
+);
+
+
+ALTER TABLE public.cdr OWNER TO root;
+
+--
+-- Name: public; Type: ACL; Schema: -; Owner: postgres
+--
+
+REVOKE ALL ON SCHEMA public FROM PUBLIC;
+REVOKE ALL ON SCHEMA public FROM postgres;
+GRANT ALL ON SCHEMA public TO postgres;
+GRANT ALL ON SCHEMA public TO PUBLIC;
+
+
+--
+-- PostgreSQL database dump complete
+--
+