diff options
Diffstat (limited to 'fs_selfservice/fri/modules/callmonitor.module')
| -rw-r--r-- | fs_selfservice/fri/modules/callmonitor.module | 675 |
1 files changed, 0 insertions, 675 deletions
diff --git a/fs_selfservice/fri/modules/callmonitor.module b/fs_selfservice/fri/modules/callmonitor.module deleted file mode 100644 index 36f5f28..0000000 --- a/fs_selfservice/fri/modules/callmonitor.module +++ /dev/null @@ -1,675 +0,0 @@ -<?php - -/** - * @file - * Functions for the interface to the call monitor recordings - */ - -/** - * Class for Callmonitor - */ -class Callmonitor { - - /* - * rank (for prioritizing modules) - */ - function rank() { - - $rank = 2; - return $rank; - } - - /* - * init - */ - function init() { - } - - /* - * Adds menu item to nav menu - * - * @param $args - * Common arguments - */ - function navMenu($args) { - - $ret .= "<p><small><small><a href='" . $_SESSION['ARI_ROOT'] . "?m=Callmonitor&f=display'>" . _("Call History") . "</a></small></small></p><br>"; - - return $ret; - } - - /* - * Acts on the selected call monitor recordings in the method indicated by the action and updates page - * - * @param $args - * Common arguments - */ - function recAction($args) { - - // args - $m = getArgument($args,'m'); - $a = getArgument($args,'a'); - $q = getArgument($args,'q'); - $start = getArgument($args,'start'); - $span = getArgument($args,'span'); - $order = getArgument($args,'order'); - $sort = getArgument($args,'sort'); - $duration_filter = getArgument($args,'duration_filter'); - - // get files - $files = array(); - foreach($_REQUEST as $key => $value) { - if (preg_match('/selected/',$key)) { - array_push($files, $value); - } - } - - if ($a=='delete') { - $this->deleteRecData($files); - } - - if ($a=='ignore') { - - $start = 0; - - setcookie("ari_duration_filter", $duration_filter, time()+365*24*60*60); - } - - // redirect to see updated page - $ret .= " - <head> - <script> - <!-- - window.location = \"" . $_SESSION['ARI_ROOT'] . "?m=" . $m . "&q=" . $q . "&start=" . $start . "&span=" . $span . "&order=" . $order . "&sort=" . $sort . "&duration_filter=" . $duration_filter . "\" - // --> - </script> - </head>"; - - return $ret; - } - - /* - * Displays stats page - * - * @param $args - * Common arguments - */ - function display($args) { - - global $ASTERISK_CALLMONITOR_PATH; - global $CALLMONITOR_ALLOW_DELETE; - global $AJAX_PAGE_REFRESH_ENABLE; - - $display = new DisplaySearch(); - - // get the search string - $m = getArgument($args,'m'); - $f = getArgument($args,'f'); - $q = getArgument($args,'q'); - $start = getArgument($args,'start'); - $span = getArgument($args,'span'); - $order = getArgument($args,'order'); - $sort = getArgument($args,'sort'); - $duration_filter = getArgument($args,'duration_filter'); - - $start = $start=='' ? 0 : $start; - $span = $span=='' ? 15 : $span; - $order = $order=='' ? 'calldate' : $order; - $sort = $sort=='' ? 'desc' : $sort; - - $displayname = $_SESSION['ari_user']['displayname']; - $extension = $_SESSION['ari_user']['extension']; - - // get data - $record_count = $this->getCdrCount($q,$duration_filter); - $data = $this->getCdrData($q,$duration_filter,$start,$span,$order,$sort); - - // get the call monitor recording files - $paths = split(';',$ASTERISK_CALLMONITOR_PATH); - foreach($paths as $key => $path) { - if (!is_dir($path)) { - $_SESSION['ari_error'] .= sprintf(_("Path is not a directory: %s"),$path) . "<br>"; - } - } - $recordings = $this->getRecordings($ASTERISK_CALLMONITOR_PATH,$data); - - // build controls - if ($CALLMONITOR_ALLOW_DELETE) { - $controls .= " - <button class='infobar' type='submit' onclick=\"document.callmonitor_form.a.value='delete'\"> - " . _("delete") . " - </button> - "; - } - - $controls .= " - <small>" . _("duration") . "</small> - <input name='duration_filter' type='text' size=4 maxlength=8 value='" . $_COOKIE['ari_duration_filter'] . "'> - <button class='infobar' type='submit' onclick=\"document.callmonitor_form.a.value='ignore'\"> - " . _("ignore") . " - </button>"; - - // table header - if ($CALLMONITOR_ALLOW_DELETE) { - $recording_delete_header = "<th></th>"; - } - - $fields[0]['field'] = "calldate"; - $fields[0]['text'] = _("Date"); - $fields[1]['field'] = "calldate"; - $fields[1]['text'] = _("Time"); - $fields[2]['field'] = "clid"; - $fields[2]['text'] = _("Caller ID"); - $fields[3]['field'] = "src"; - $fields[3]['text'] = _("Source"); - $fields[4]['field'] = "dst"; - $fields[4]['text'] = _("Destination"); - $fields[5]['field'] = "dcontext"; - $fields[5]['text'] = _("Context"); - $fields[6]['field'] = "duration"; - $fields[6]['text'] = _("Duration"); - - $i = 0; - while ($fields[$i]) { - - $field = $fields[$i]['field']; - $text = $fields[$i]['text']; - if ($order==$field) { - if ($sort=='asc') { - $currentSort = 'desc'; - $arrowImg = "<img src='theme/images/arrow-asc.gif' alt='sort'>"; - } - else { - $currentSort = 'asc'; - $arrowImg = "<img src='theme/images/arrow-desc.gif' alt='sort'>"; - } - - if ($i==1) { - $arrowImg = ''; - } - } - else { - $arrowImg = ''; - $currentSort = 'desc'; - } - - $unicode_q = urlencode($q); - $recording_header .= "<th><a href=" . $_SESSION['ARI_ROOT'] . "?m=" . $m . "&f=" . $f . "&q=" . $unicode_q . "&order=" . $field . "&sort=" . $currentSort . ">" . $text . $arrowImg . "</a></th>"; - - $i++; - } - $recording_header .= "<th>" . _("Monitor") . "</th>"; - - // table body - foreach($data as $key=>$value) { - - // recording file - $recording = $recordings[$value['uniqueid'] . $value['calldate']]; - - // date and time - $buf = split(' ', $value[calldate]); - $date = $buf[0]; - $time = $buf[1]; - - // recording delete checkbox - if ($CALLMONITOR_ALLOW_DELETE) { - $recording_delete_checkbox = "<td class='checkbox'><input type=checkbox name='selected" . ++$i . "' value=" . $recording . "></td>"; - } - - $recordingLink = ''; - if (is_file($recordings[$value['uniqueid'] . $value['calldate']])) { - $recordingLink = "<a href='#' onClick=\"javascript:popUp('misc/recording_popup.php?recording=" . $recording . "&date=" . $date . "&time=" . $time . "'); return false;\">" . _("play") . "</a>"; - } - - $recording_body .= "<tr> - " . $recording_delete_checkbox . " - <td width=70>" . $date . "</td> - <td>" . $time . "</td> - <td>" . $value[clid] . "</td> - <td>" . $value[src] . "</td> - <td>" . $value[dst] . "</td> - <td>" . $value[dcontext] . "</td> - <td width=90>" . $value[duration] . " sec</td> - <td>" . $recordingLink . "</td> - </tr>"; - } - if (!count($data)) { - $recording_body .= "<tr></tr>"; - } - - // options - $url_opts = array(); - $url_opts['sort'] = $sort; - $url_opts['order'] = $order; - $url_opts['duration_filter'] = $duration_filter; - - // build page content - $ret .= checkErrorMessage(); - - // ajax page refresh script - if ($AJAX_PAGE_REFRESH_ENABLE) { - // $ret .= ajaxRefreshScript($args); - } - - // header - if ($_SESSION['ari_user']['admin_callmonitor']) { - $header_text = _("Call History"); - } else { - $header_text = sprintf(_("Call History for %s (%s)"),$displayname,$extension); - } - $ret .= $display->displayHeaderText($header_text); - $ret .= $display->displaySearchBlock('left',$m,$q,$url_opts,true); - - // start form - if ($CALLMONITOR_ALLOW_DELETE) { - - $ret .= " - <form name='callmonitor_form' action='" . $_SESSION['ARI_ROOT'] . "' method='GET'> - <input type=hidden name=m value=" . $m . "> - <input type=hidden name=f value=recAction> - <input type=hidden name=a value=''> - <input type=hidden name=q value=" . $q . "> - <input type=hidden name=start value=" . $start . "> - <input type=hidden name=span value=" . $span . "> - <input type=hidden name=order value=" . $order . "> - <input type=hidden name=sort value=" . $sort . ">"; - } - - $ret .= $display->displayInfoBarBlock($controls,$q,$start,$span,$record_count); - - // javascript for popup and message actions - $ret .= " - <SCRIPT LANGUAGE='JavaScript'> - <!-- Begin - function popUp(URL) { - eval(\"page = window.open(URL, 'play', 'toolbar=0,scrollbars=0,location=0,statusbar=0,menubar=0,resizable=1,width=324,height=110');\"); - } - - function checkAll(form,set) { - var elem = 0; - var i = 0; - while (elem = form.elements[i]) { - if (set) { - elem.checked = true; - } else { - elem.checked = false; - } - i++; - } - return true; - } - // End --> - </script>"; - - // call monitor delete recording controls - if ($CALLMONITOR_ALLOW_DELETE) { - $ret .= " - <table> - <tr> - <td> - <small>" . _("select") . ": </small> - <small><a href='' OnClick=\"checkAll(document.callmonitor_form,true); return false;\">" . _("all") . "</a></small> - <small><a href='' OnClick=\"checkAll(document.callmonitor_form,false); return false;\">" . _("none") . "</a></small> - </td> - </tr> - </table>"; - } - else { - $ret .= "<br>"; - } - - // table - $ret .= " - <table class='callmonitor'> - <tr> - " . $recording_delete_header . " - " . $recording_header . " - </tr> - " . $recording_body . " - </table>"; - - $start = getArgument($args,'start'); - $span = getArgument($args,'span'); - $order = getArgument($args,'order'); - $sort = getArgument($args,'sort'); - - // end form - if ($CALLMONITOR_ALLOW_DELETE) { - $ret .= "</form>"; - } - - $ret .= $display->displaySearchBlock('center',$m,$q,$url_opts,false); - $ret .= $display->displayNavigationBlock($m,$q,$url_opts,$start,$span,$record_count); - - return $ret; - } - - /* - * Checks for a recording file - * - * @param $asterisk_callmonitor_path - * path call monitor recording directory on the asterisk server - * @param $data - * current call monitor recordings on the asterisk server - * @return $recording - * returns an array of $recording file names if found - */ - function getRecordings($asterisk_callmonitor_path,$data) { - - global $CALLMONITOR_ONLY_EXACT_MATCHING; - global $CALLMONITOR_AGGRESSIVE_MATCHING; - - $recordings = array(); - - $extension = $_SESSION['ari_user']['extension']; - - $paths = split(';',$asterisk_callmonitor_path); - foreach($paths as $key => $path) { - $paths[$key] = fixPathSlash($paths[$key]); - } - - $files = array(); - if (!$CALLMONITOR_ONLY_EXACT_MATCHING) { - $filter = ''; - $recursiveMax = 6; - $recursiveCount = 0; - foreach($paths as $key => $path) { - $path_files = getFiles($path,$filter,$recursiveMax,$recursiveCount); - if ($path_files) { - $files = array_merge($files,$path_files); - } - } - rsort($files); - } - - foreach($data as $data_key => $data_value) { - - $recording=''; - - $calldate = $data_value['calldate']; - $duration = $data_value['duration']; - $lastdata = $data_value['lastdata']; - $uniqueid = $data_value['uniqueid']; - $userfield = $data_value['userfield']; - - // timestamps - $st = trim(strtotime($calldate)); - $et = trim(strtotime($calldate) + $duration); // for on-demand call recordings - - // unique file key - if ($uniqueid) { - $buf = preg_replace('/\-|\:/', '', $calldate); - $calldate_key = preg_replace('/\s+/', '-', $buf); - $unique_file_key = $calldate_key . "-" . $uniqueid; - } - if ($unique_file_key=='') { - $buf = preg_split("/\|/", $lastdata); - $unique_file_key = $buf[1]; - } - - $recordingLink = ''; - foreach($paths as $callmonitor_key => $path) { - - // try to find an exact match using the uniqueid - if (isset($uniqueid)) { - - $check_files = array(); - array_push($check_files,$path . $uniqueid . ".WAV"); - array_push($check_files,$path . $uniqueid . ".wav"); - array_push($check_files,$path . $uniqueid . ".gsm"); - - array_push($check_files,$path . $unique_file_key . ".WAV"); - array_push($check_files,$path . $unique_file_key . ".wav"); - array_push($check_files,$path . $unique_file_key . ".gsm"); - - array_push($check_files,$path . "g" . $extension . "-" . $unique_file_key . ".WAV"); - array_push($check_files,$path . "g" . $extension . "-" . $unique_file_key . ".wav"); - array_push($check_files,$path . "g" . $extension . "-" . $unique_file_key . ".gsm"); - - array_push($check_files,$path . "q" . $extension . "-" . $unique_file_key . ".WAV"); - array_push($check_files,$path . "q" . $extension . "-" . $unique_file_key . ".wav"); - array_push($check_files,$path . "q" . $extension . "-" . $unique_file_key . ".gsm"); - - array_push($check_files,$path . "OUT" . $extension . "-" . $unique_file_key . ".WAV"); - array_push($check_files,$path . "OUT" . $extension . "-" . $unique_file_key . ".wav"); - array_push($check_files,$path . "OUT" . $extension . "-" . $unique_file_key . ".gsm"); - - array_push($check_files,$path . $userfield); - - // try to match - foreach($check_files as $check_file) { - if (is_file($check_file)) { - $recording = $check_file; - break; - } - } - } - - // if found do not need to check the rest of the paths - if ($recording!='') { - break; - } - } - - // get all the callmonitor recordings on server and try to find a non-exact match for this log entry - if (!$CALLMONITOR_ONLY_EXACT_MATCHING) { - - // try to find a file using the uniqueid - if (!$recording) { - - // try and match the unique id - if (!$recording) { - foreach($files as $key => $path) { - if (strlen($uniqueid)>1 && strpos($path,$uniqueid)!==FALSE) { - $recording = $path; - $files[$key] = ''; // remove it from the recording files so it will not be matched twice - break; - } - } - } - } - - // try and match a file using the calldate (if no unique number from database) - if (!$recording) { - - foreach($files as $key => $path) { - $parts = split("-", $path); - if (strlen($st)>1 && - (strpos($path,$st)!==FALSE) || - (strpos($path,"auto")!==FALSE && $parts[1] >= $st && $parts[1] <= $et)) { - $recording = $path; - $files[$key] = ''; // remove it from the recording files so it will not be matched twice - break; - } - } - } - - if ($CALLMONITOR_AGGRESSIVE_MATCHING) { - - // one last stab at finding a recording by adding one or two seconds to the call time - if (!$recording) { - $st_1 = trim($st+1); - $st_2 = trim($st+2); - $et_1 = trim($et+1); - $et_2 = trim($et+2); - foreach($files as $key => $path) { - $split = explode("-", $path); - if (strlen($st)>1 - && ((strpos($path,$st_1)!==FALSE) || - (strpos($path,$st_2)!==FALSE) || - (strpos($path,"auto")!==FALSE && $parts[1] >= $st_1 && $parts[1] <= $et_1) || - (strpos($path,"auto")!==FALSE && $parts[1] >= $st_2 && $parts[1] <= $et_2))) { - $recording = $path; - $files[$key] = ''; // remove it from the recording files so it will not be matched twice - break; - } - } - } - } - } - - // add to array to be returned - if ($recording) { - $recordings[$uniqueid . $calldate] = $recording; - } - } - - return $recordings; - } - - /* - * Deletes selected call monitor recordings - * - * @param $files - * Array of files to delete - */ - function deleteRecData($files) { - - foreach($files as $key => $file) { - if (is_writable($file)) { - unlink($file); - } else { - $_SESSION['ari_error'] = _("Only deletes recording files, not cdr log"); - } - } - } - - /* - * Gets cdr record count - * - * @param $q - * query text - */ - function getSearchText($q,$duration_filter) { - - // search text - if ($q!='*' && $q!=NULL) { - $searchText .= "WHERE "; - $tok = strtok($q," \n\t"); - while ($tok) { - $searchText .= " (calldate regexp '" . $tok . "' - OR clid regexp '" . $tok . "' - OR src regexp '" . $tok . "' - OR dst regexp '" . $tok . "' - OR dstchannel regexp '" . $tok . "' - OR dcontext regexp '" . $tok . "' - OR duration regexp '" . $tok . "' - OR disposition regexp '" . $tok . "' - OR uniqueid regexp '" . $tok . "' - OR userfield regexp '" . $tok . "' - )"; - $tok = strtok(" \n\t"); - if ($tok) { - $searchText .= " AND"; - } - } - } - - // duration_filter - if ($duration_filter) { - if (!$searchText) { - $searchText .= "WHERE "; - } else { - $searchText .= "AND "; - } - $searchText .= "duration>" . $duration_filter . " "; - } - - // admin - if (!$_SESSION['ari_user']['admin_callmonitor']) { - if (!$searchText) { - $searchText .= "WHERE "; - } else { - $searchText .= "AND "; - } - - // allow entries to be viewed with users extension - $searchText .= "(src = '" . $_SESSION['ari_user']['extension'] . "' - OR dst = '" . $_SESSION['ari_user']['extension'] . "' - - OR channel LIKE 'IAX2/" . $_SESSION['ari_user']['extension'] ."-%' - OR dstchannel LIKE 'IAX2/" . $_SESSION['ari_user']['extension'] ."-%' - - OR channel LIKE 'SIP/" . $_SESSION['ari_user']['extension'] ."-%' - OR dstchannel LIKE 'SIP/" . $_SESSION['ari_user']['extension'] ."-%')"; - - // allow entries to be viewed with users outbound CID - if (isset($_SESSION['ari_user']['outboundCID']) && trim($_SESSION['ari_user']['outboundCID']) != '') { - $searchText .= "OR (src = '" . $_SESSION['ari_user']['outboundCID'] . "' - OR dst = '" . $_SESSION['ari_user']['outboundCID'] . "')"; - } - } - - return $searchText; - } - - /* - * Gets cdr record count - * - * @param $q - * query text - * @return $count - * Number of cdr records counted - */ - function getCdrCount($q,$duration_filter) { - - global $ASTERISKCDR_DBTABLE; - - $searchText = $this->getSearchText($q,$duration_filter); - - $dbh = $_SESSION['dbh_cdr']; - $sql = "SELECT count(*) - FROM " . $ASTERISKCDR_DBTABLE . " - " . $searchText; - - $result = $dbh->getAll($sql); - if (DB::isError($result)) { - $_SESSION['ari_error'] = $result->getMessage(); - return; - } - $count = $result[0][0]; - - return $count; - } - - /* - * Gets cdr data - * - * @param $q - * query text - * @param $start - * start record - * @param $span - * number of records to return - * @return $data - * cdr data to be returned - */ - function getCdrData($q,$duration_filter,$start,$span,$order,$sort) { - - global $ASTERISKCDR_DBTABLE; - - $data = array(); - - $searchText = $this->getSearchText($q,$duration_filter); - - $dbh = $_SESSION['dbh_cdr']; - $sql = "SELECT * - FROM " . $ASTERISKCDR_DBTABLE . " - " . $searchText . " - ORDER BY " . $order . " " . $sort . " - LIMIT " . $start . "," . $span; - $result = $dbh->getAll($sql,DB_FETCHMODE_ASSOC); - if (DB::isError($result)) { - $_SESSION['ari_error'] = $result->getMessage(); - return; - } - $data = $result; - - return $data; - } - - -} - - -?> |