代码拉取完成，页面将自动刷新
同步操作将从 mirrors_dagwieers/freepbx 强制同步，此操作会覆盖自 Fork 仓库以来所做的任何修改，且无法恢复！！！
确定后同步将在后台操作，完成时将刷新页面，请耐心等待。
<?php
// vim: set ai ts=4 sw=4 ft=php:
namespace FreePBX\modules;
class Core extends \FreePBX_Helpers implements \BMO {
private $drivers = array();
private $deviceCache = array();
private $getUserCache = array();
private $getDeviceCache = array();
private $listUsersCache = array();
public function __construct($freepbx = null) {
parent::__construct($freepbx);
//other options
$this->database = $freepbx->Database;
$this->config = $freepbx->Config;
$this->freepbx = $freepbx;
$this->astman = $freepbx->astman;
//load drivers
$this->loadDrivers();
}
/**
* Get Right Nav
* @param array $request The request
* @return string The Right nav html
*/
public function getRightNav($request) {
$display_mode = "advanced";
$mode = $this->freepbx->Config()->get("FPBXOPMODE");
if(!empty($mode)) {
$display_mode = $mode;
}
switch($request['display']){
case 'extensions':
case 'devices':
$popover = isset($request['fw_popover']) ? "&fw_popover=".$request['fw_popover'] : '';
$show = isset($request['tech_hardware']) || (isset($request['view']) && $request['view'] == "add") || (isset($request['extdisplay']) && trim($request['extdisplay']) != "");
if($display_mode == "basic" && (!isset($request['extdisplay']) || trim($request['extdisplay']) == "")) {
return array();
}
return load_view(__DIR__."/views/rnav.php",array("show" => $show, "display" => $request['display'], "popover"=>$popover));
break;
case 'trunks':
if(isset($request['tech'])||(isset($request['extdisplay']) && !empty($request['extdisplay']))){
$html = load_view(__DIR__.'/views/trunks/bootnav.php', array('trunk_types' => \FreePBX::Core()->listTrunkTypes()));
return $html;
}
break;
case 'did':
if(isset($request['view'])){
$html = load_view(__DIR__.'/views/did/rnav.php');
return $html;
}
break;
case 'routing':
if(isset($request['view'])){
$html = load_view(__DIR__.'/views/routing/bootnav.php');
return $html;
}
break;
case 'dahdichandids':
if(isset($request['view'])){
$html = load_view(__DIR__.'/views/dahdichandids/bootnav.php');
return $html;
}
break;
case 'ampusers':
$html = load_view(__DIR__.'/views/ampusers/bootnav.php');
return $html;
break;
}
}
/**
* Get all drivers from the private handler
* this is so they cant be modified by some outside source
*/
public function getAllDrivers() {
return $this->drivers;
}
/**
* Get a single driver object
* @param string $driver The driver name
* @return object The driver Object
*/
public function getDriver($driver) {
return isset($this->drivers[$driver]) ? $this->drivers[$driver] : false;
}
/**
* Load all "core" drivers
*/
public function loadDrivers() {
if(!class_exists("FreePBX\Modules\Core\Driver",false)) {
include(__DIR__."/functions.inc/Driver.class.php");
}
$driverNamespace = "\\FreePBX\\Modules\\Core\\Drivers";
foreach(glob(__DIR__."/functions.inc/drivers/*.class.php") as $driver) {
if(preg_match("/\/([a-z1-9]*)\.class\.php$/i",$driver,$matches)) {
$name = $matches[1];
$class = $driverNamespace . "\\" . $name;
if(!class_exists($class,false)) {
include($driver);
}
if(class_exists($class,false)) {
$this->drivers[strtolower($name)] = new $class($this->freepbx);
} else {
throw new \Exception("Invalid Class inside the drivers folder");
}
}
}
}
/**
* Get all information about all drivers
*/
public function getAllDriversInfo() {
$final = array();
foreach($this->drivers as $driver) {
$info = $driver->getInfo();
if($info === false) {
continue;
}
$rn = $info['rawName'];
$final[$rn] = $info;
}
return $final;
}
/**
* Quick Extension Create Display
*/
public function getQuickCreateDisplay() {
$devs = $this->getAllUsersByDeviceType();
$dev = end($devs);
$startExt = $dev['extension'] + 1;
$pages = array();
$pages[0][] = array(
'html' => load_view(__DIR__.'/views/quickCreate.php',array('startExt' => $startExt)),
'validate' => 'if($("#extension").val().trim() == "") {warnInvalid($("#extension"),"'._("Extension can not be blank!").'");return false}if(typeof extmap[$("#extension").val().trim()] !== "undefined") {warnInvalid($("#extension"),"'._("Extension already in use!").'");return false}if($("#name").val().trim() == "") {warnInvalid($("#name"),"'._("Display Name can not be blank!").'");return false}'
);
$modules = $this->freepbx->Hooks->processHooks();
foreach($modules as $module) {
foreach($module as $page => $datas) {
foreach($datas as $html) {
$pages[$page][] = $html;
}
}
}
return $pages;
}
/**
* Process the Quick Extension Create Display
* @param string $tech The tech type (provided by the driver)
* @param int $extension The extension number
* @param array $data Data passed from $_POST on submit
*/
public function processQuickCreate($tech, $extension, $data) {
if(!is_numeric($extension)) {
return array("status" => false, "message" => _("Extension was not numeric!"));
}
$settings = $this->generateDefaultDeviceSettings($tech,$extension,$data['name']);
if(!$this->addDevice($extension,$tech,$settings)) {
return array("status" => false, "message" => _("Device was not added!"));
}
$settings = $this->generateDefaultUserSettings($extension,$data['name']);
$settings['outboundcid'] = $data['outboundcid'];
try {
if(!$this->addUser($extension, $settings)) {
//cleanup
$this->delDevice($extension);
return array("status" => false, "message" => _("There was an unknown error creating this extension"));
}
} catch(\Exception $e) {
//cleanup
$this->delDevice($extension);
throw $e;
}
try {
$modules = $this->freepbx->Hooks->processHooks($tech, $extension, $data);
} catch(\Exception $e) {
//cleanup
$this->delDevice($extension);
$this->delUser($extension);
throw $e;
}
needreload();
return array("status" => true, "ext" => $extension, "name" => $data['name']);
}
/**
* Propagator for genConfig() from BMO that is passed on
* to child drivers
*/
public function genConfig() {
$conf = array();
foreach($this->drivers as $driver) {
$c = $driver->genConfig();
if(!empty($c)) {
$conf = array_merge($c, $conf);
}
}
return $conf;
}
/**
* Propagator for writeConfig() from BMO that is passed on
* to child drivers
* @param array $config Config Array
*/
public function writeConfig($config) {
foreach($this->drivers as $driver) {
$config = $driver->writeConfig($config);
}
return $config;
}
public function getActionBar($request) {
$buttons = array();
switch($request['display']) {
case 'ampusers':
$buttons = array(
'delete' => array(
'name' => 'delete',
'id' => 'delete',
'value' => _('Delete')
),
'reset' => array(
'name' => 'reset',
'id' => 'reset',
'value' => _('Reset')
),
'submit' => array(
'name' => 'submit',
'id' => 'submit',
'value' => _('Submit')
)
);
if (empty($request['userdisplay'])) {
unset($buttons['delete']);
}
break;
case 'users':
case 'devices':
$buttons = array(
'delete' => array(
'name' => 'delete',
'id' => 'delete',
'value' => _('Delete')
),
'reset' => array(
'name' => 'reset',
'id' => 'reset',
'value' => _('Reset')
),
'submit' => array(
'name' => 'submit',
'id' => 'submit',
'value' => _('Submit')
)
);
if($request['view'] == 'add' || !empty($request['tech_hardware'])) {
unset($buttons['delete']);
} elseif(!isset($request['extdisplay']) || trim($request['extdisplay']) == '') {
$buttons = array();
}
break;
case 'extensions':
$buttons = array(
'delete' => array(
'name' => 'delete',
'id' => 'delete',
'value' => _('Delete')
),
'reset' => array(
'name' => 'reset',
'id' => 'reset',
'value' => _('Reset')
),
'submit' => array(
'name' => 'submit',
'id' => 'submit',
'value' => _('Submit')
)
);
if(!empty($request['tech_hardware'])) {
unset($buttons['delete']);
} elseif(!isset($request['extdisplay']) || trim($request['extdisplay']) == '') {
$buttons = array();
}
break;
case 'advancedsettings':
$buttons = array(
'reset' => array(
'name' => 'reset',
'id' => 'reset',
'value' => _('Reset')
),
'submit' => array(
'name' => 'submit',
'id' => 'submit',
'value' => _('Submit')
)
);
break;
case 'dahdichandids':
$buttons = array(
'delete' => array(
'name' => 'delete',
'id' => 'delete',
'value' => _('Delete')
),
'reset' => array(
'name' => 'reset',
'id' => 'reset',
'value' => _('Reset')
),
'submit' => array(
'name' => 'submit',
'id' => 'submit',
'value' => _('Submit')
)
);
if (empty($request['extdisplay'])) {
unset($buttons['delete']);
}
case 'did':
$buttons = array(
'delete' => array(
'name' => 'delete',
'id' => 'delete',
'value' => _('Delete')
),
'reset' => array(
'name' => 'reset',
'id' => 'reset',
'value' => _('Reset')
),
'submit' => array(
'name' => 'submit',
'id' => 'submit',
'value' => _('Submit')
)
);
if (empty($request['extdisplay'])) {
unset($buttons['delete']);
}
if(!isset($request['view'])||$request['view'] == ''){
$buttons = array();
}
break;
case 'routing':
$buttons = array(
'delete' => array(
'name' => 'delete',
'id' => 'delete',
'value' => _('Delete')
),
'duplicate' => array(
'name' => 'duplicate',
'id' => 'duplicate',
'value' => _('Duplicate')
),
'reset' => array(
'name' => 'reset',
'id' => 'reset',
'value' => _('Reset')
),
'submit' => array(
'name' => 'submit',
'id' => 'submit',
'value' => _('Submit')
)
);
if (empty($request['id'])) {
unset($buttons['delete'], $buttons['duplicate']);
}
if (empty($request['view'])){
$buttons = array();
}
break;
case 'trunks':
$tmpButtons = array(
'delete' => array(
'name' => 'delete',
'id' => 'delete',
'value' => _('Delete')
),
'duplicate' => array(
'name' => 'duplicate',
'id' => 'duplicate',
'value' => _('Duplicate')
),
'reset' => array(
'name' => 'reset',
'id' => 'reset',
'value' => _('Reset')
),
'submit' => array(
'name' => 'submit',
'id' => 'submit',
'value' => _('Submit')
)
);
if (!empty($request['extdisplay'])) {
$buttons = $tmpButtons;
} else if (!empty($request['tech'])) {
unset($tmpButtons['delete'], $tmpButtons['duplicate']);
$buttons = $tmpButtons;
}
break;
case 'dahdichandids':
$buttons = array(
'delete' => array(
'name' => 'delete',
'id' => 'delete',
'value' => _('Delete')
),
'reset' => array(
'name' => 'reset',
'id' => 'reset',
'value' => _('Reset')
),
'submit' => array(
'name' => 'submit',
'id' => 'submit',
'value' => _('Submit')
)
);
if ($request['view'] == 'add') {
unset($buttons['delete']);
}
break;
}
return $buttons;
}
public function install() {
}
public function uninstall() {
}
public function backup() {
}
public function restore($backup) {
}
public function doTests($db) {
return true;
}
public function ajaxRequest($req, &$setting) {
switch($req) {
case "delastmodule":
case "addastmodule":
case "quickcreate":
case "delete":
case "getJSON":
case "getExtensionGrid":
case "getDeviceGrid":
case "getUserGrid":
case "updateRoutes":
case "delroute":
case "getnpanxxjson":
case "populatenpanxx":
return true;
break;
}
return false;
}
public function ajaxHandler() {
switch($_REQUEST['command']) {
case "addastmodule":
$section = isset($_REQUEST['section'])?$_REQUEST['section']:'';
$module = isset($_REQUEST['astmod'])?$_REQUEST['astmod']:'';
switch($section){
case 'amodload':
return $this->ModulesConf->load($module);
break;
case 'amodnoload':
return $this->ModulesConf->noload($module);
break;
case 'amodpreload':
return $this->ModulesConf->preload($module);
break;
}
break;
case "delastmodule":
$section = isset($_REQUEST['section'])?$_REQUEST['section']:'';
$module = isset($_REQUEST['astmod'])?$_REQUEST['astmod']:'';
switch($section){
case 'amodload':
return $this->ModulesConf->removeload($module);
break;
case 'amodnoload':
return $this->ModulesConf->removenoload($module);
break;
case 'amodpreload':
return $this->ModulesConf->removepreload($module);
break;
}
break;
case "delroute":
if (!function_exists('core_routing_delbyid')) {
if (file_exists(__DIR__."/functions.inc.php")) {
include __DIR__."/functions.inc.php";
}
}
$ret = core_routing_delbyid($_POST['id']);
// re-order the routes to make sure that there are no skipped numbers.
// example if we have 001-test1, 002-test2, and 003-test3 then delete 002-test2
// we do not want to have our routes as 001-test1, 003-test3 we need to reorder them
// so we are left with 001-test1, 002-test3
needreload();
return $ret;
break;
case "updateRoutes":
$order = $_REQUEST['data'];
array_shift($order);
return $this->setRouteOrder($order);
break;
case "getUserGrid":
$users = $this->getAllUsers();
if(empty($users)) {
return array();
}
$ampuser = $this->astman->database_show("AMPUSER");
// Get all CW settings
$cwsetting = $this->astman->database_show("CW");
// get all CF settings
$cfsetting = $this->astman->database_show("CF");
// get all CFB settings
$cfbsetting = $this->astman->database_show("CFB");
// get all CFU settings
$cfusetting = $this->astman->database_show("CFU");
// get all DND settings
$dndsetting = $this->astman->database_show("DND");
foreach($users as &$user) {
$exten = $user['extension'];
$user['settings'] = array(
'cw' => (isset($cwsetting['/CW/'.$exten]) && $cwsetting['/CW/'.$exten] == "ENABLED"),
'dnd' => (isset($dndsetting['/DND/'.$exten]) && $dndsetting['/DND/'.$exten] == "YES"),
'cf' => (isset($cfsetting['/CF/'.$exten])),
'cfb' => (isset($cfbsetting['/CFB/'.$exten])),
'cfu' => (isset($cfusetting['/CFU/'.$exten])),
'fmfm' => (isset($ampuser['/AMPUSER/'.$exten.'/followme/ddial']) && $ampuser['/AMPUSER/'.$exten.'/followme/ddial'] == "DIRECT")
);
$user['actions'] = '<a href="?display=users&extdisplay='.$exten.'"><i class="fa fa-edit"></i></a><a class="clickable delete" data-id="'.$exten.'"><i class="fa fa-trash"></i></a>';
}
return array_values($users);
break;
case "getExtensionGrid":
$ampuser = $this->astman->database_show("AMPUSER");
// Get all CW settings
$cwsetting = $this->astman->database_show("CW");
// get all CF settings
$cfsetting = $this->astman->database_show("CF");
// get all CFB settings
$cfbsetting = $this->astman->database_show("CFB");
// get all CFU settings
$cfusetting = $this->astman->database_show("CFU");
// get all DND settings
$dndsetting = $this->astman->database_show("DND");
if($_REQUEST['type'] == "all") {
$devices = $this->getAllUsersByDeviceType();
if(empty($devices)) {
return array();
}
foreach($devices as &$device) {
$exten = $device['extension'];
$device['settings'] = array(
'cw' => (isset($cwsetting['/CW/'.$exten]) && $cwsetting['/CW/'.$exten] == "ENABLED"),
'dnd' => (isset($dndsetting['/DND/'.$exten]) && $dndsetting['/DND/'.$exten] == "YES"),
'cf' => (isset($cfsetting['/CF/'.$exten])),
'cfb' => (isset($cfbsetting['/CFB/'.$exten])),
'cfu' => (isset($cfusetting['/CFU/'.$exten])),
'fmfm' => (isset($ampuser['/AMPUSER/'.$exten.'/followme/ddial']) && $ampuser['/AMPUSER/'.$exten.'/followme/ddial'] == "DIRECT")
);
$device['actions'] = '<a href="?display=extensions&extdisplay='.$exten.'"><i class="fa fa-edit"></i></a><a class="clickable delete" data-id="'.$exten.'"><i class="fa fa-trash"></i></a>';
}
return $devices;
} else {
$devices = $this->getAllUsersByDeviceType($_REQUEST['type']);
if(empty($devices)) {
return array();
}
foreach($devices as &$device) {
$exten = $device['extension'];
$device['settings'] = array(
'cw' => (isset($cwsetting['/CW/'.$exten]) && $cwsetting['/CW/'.$exten] == "ENABLED"),
'dnd' => (isset($dndsetting['/DND/'.$exten]) && $dndsetting['/DND/'.$exten] == "YES"),
'cf' => (isset($cfsetting['/CF/'.$exten])),
'cfb' => (isset($cfbsetting['/CFB/'.$exten])),
'cfu' => (isset($cfusetting['/CFU/'.$exten]))
);
$device['actions'] = '<a href="?display=extensions&extdisplay='.$exten.'"><i class="fa fa-edit"></i></a><a class="clickable delete" data-id="'.$exten.'"><i class="fa fa-trash"></i></a>';
}
return $devices;
}
break;
case "getDeviceGrid":
if($_REQUEST['type'] == "all") {
$devices = $this->getAllDevicesByType();
if(empty($devices)) {
return array();
}
foreach($devices as &$device) {
$exten = $device['id'];
$device['actions'] = '<a href="?display=devices&extdisplay='.$exten.'"><i class="fa fa-edit"></i></a><a class="clickable delete" data-id="'.$exten.'"><i class="fa fa-trash"></i></a>';
}
return $devices;
} else {
$devices = $this->getAllDevicesByType($_REQUEST['type']);
if(empty($devices)) {
return array();
}
foreach($devices as &$device) {
$exten = $device['id'];
$device['actions'] = '<a href="?display=devices&extdisplay='.$exten.'"><i class="fa fa-edit"></i></a><a class="clickable delete" data-id="'.$exten.'"><i class="fa fa-trash"></i></a>';
}
return $devices;
}
break;
case "delete":
if(!empty($_POST['extensions'])) {
switch($_POST['type']) {
case "extensions":
foreach($_POST['extensions'] as $ext) {
$this->delUser($ext);
$this->delDevice($ext);
}
return array("status" => true);
break;
case "users":
foreach($_POST['extensions'] as $ext) {
$this->delUser($ext);
}
return array("status" => true);
break;
case "devices":
foreach($_POST['extensions'] as $ext) {
$this->delDevice($ext);
}
return array("status" => true);
break;
}
}
break;
case "quickcreate":
$status = $this->processQuickCreate($_POST['tech'], $_POST['extension'], $_POST);
return $status;
break;
case "getJSON":
switch ($_REQUEST['jdata']) {
case 'allDID':
$dids = $this->getAllDIDs();
$dids = is_array($dids)?$dids:array();
foreach ($dids as $key => $value) {
$dids[$key]['cidnum'] = urlencode($value['cidnum']);
$dids[$key]['extension'] = urlencode($value['extension']);
}
return array_values($dids);
break;
case 'allTrunks':
return array_values($this->listTrunks());
break;
case 'routingrnav':
return array_values($this->getAllRoutes());
break;
case 'dahdichannels':
return array_values($this->listDahdiChannels());
break;
case 'ampusers':
return array_values($this->listAMPUsers('assoc'));
break;
}
break;
case 'getnpanxxjson':
try {
$npa = $_REQUEST['npa'];
$nxx = $_REQUEST['nxx'];
$url = 'http://www.localcallingguide.com/xmllocalprefix.php?npa=602&nxx=930';
$request = new \Pest('http://www.localcallingguide.com/xmllocalprefix.php');
$data = $request->get('?npa='.$npa.'&nxx='.$nxx);
$xml = new \SimpleXMLElement($data);
$pfdata = $xml->xpath('//lca-data/prefix');
$retdata = array();
foreach($pfdata as $item){
$inpa = (string)$item->npa;
$inxx = (string)$item->nxx;
$retdata[$inpa.$inxx] = array('npa' => $inpa, 'nxx' => $inxx);
}
return $retdata;
}catch(Pest_NotFound $e){
return array('error' => $e);
}
break;
case 'populatenpanxx':
$dialpattern_array = $dialpattern_insert;
if (preg_match("/^([2-9]\d\d)-?([2-9]\d\d)$/", $_REQUEST["npanxx"], $matches)) {
// first thing we do is grab the exch:
$ch = curl_init();
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
curl_setopt($ch, CURLOPT_URL, "http://www.localcallingguide.com/xmllocalprefix.php?npa=".$matches[1]."&nxx=".$matches[2]);
curl_setopt($ch, CURLOPT_USERAGENT, "Mozilla/5.0 (Linux; FreePBX Local Trunks Configuration)");
$str = curl_exec($ch);
curl_close($ch);
// quick 'n dirty - nabbed from PEAR
global $amp_conf;
require_once($amp_conf['AMPWEBROOT'] . '/admin/modules/core/XML_Parser.php');
require_once($amp_conf['AMPWEBROOT'] . '/admin/modules/core/XML_Unserializer.php');
$xml = new xml_unserializer;
$xml->unserialize($str);
$xmldata = $xml->getUnserializedData();
$hash_filter = array(); //avoid duplicates
if (isset($xmldata['lca-data']['prefix'])) {
// we do the loops separately so patterns are grouped together
// match 1+NPA+NXX (dropping 1)
foreach ($xmldata['lca-data']['prefix'] as $prefix) {
if (isset($hash_filter['1'.$prefix['npa'].$prefix['nxx']])) {
continue;
} else {
$hash_filter['1'.$prefix['npa'].$prefix['nxx']] = true;
}
$dialpattern_array[] = array(
'prepend_digits' => '',
'match_pattern_prefix' => '1',
'match_pattern_pass' => htmlspecialchars($prefix['npa'].$prefix['nxx']).'XXXX',
'match_cid' => '',
);
}
// match NPA+NXX
foreach ($xmldata['lca-data']['prefix'] as $prefix) {
if (isset($hash_filter[$prefix['npa'].$prefix['nxx']])) {
continue;
} else {
$hash_filter[$prefix['npa'].$prefix['nxx']] = true;
}
$dialpattern_array[] = array(
'prepend_digits' => '',
'match_pattern_prefix' => '',
'match_pattern_pass' => htmlspecialchars($prefix['npa'].$prefix['nxx']).'XXXX',
'match_cid' => '',
);
}
// match 7-digits
foreach ($xmldata['lca-data']['prefix'] as $prefix) {
if (isset($hash_filter[$prefix['nxx']])) {
continue;
} else {
$hash_filter[$prefix['nxx']] = true;
}
$dialpattern_array[] = array(
'prepend_digits' => '',
'match_pattern_prefix' => '',
'match_pattern_pass' => htmlspecialchars($prefix['nxx']).'XXXX',
'match_cid' => '',
);
}
unset($hash_filter);
} else {
$errormsg = _("Error fetching prefix list for: "). $request["npanxx"];
}
} else {
// what a horrible error message... :p
$errormsg = _("Invalid format for NPA-NXX code (must be format: NXXNXX)");
}
if (isset($errormsg)) {
return array('error' => "<script language=\"javascript\">alert('".addslashes($errormsg)."');</script>");
unset($errormsg);
}
break;
}
}
public function doConfigPageInit($page) {
//Reassign $_REQUEST as it will be immutable in the future.
$request = $_REQUEST;
global $amp_conf;
if ($page == "advancedsettings"){
$freepbx_conf = $this->config;
$settings = $freepbx_conf->get_conf_settings();
foreach($request as $key => $val){
if (isset($settings[$key])) {
if($key == 'CRONMAN_UPDATES_CHECK') {
$cm = \cronmanager::create($db);
if($val == 'true') {
$cm->enable_updates();
} else {
$cm->disable_updates();
}
}
switch($settings[$key]['type']) {
case CONF_TYPE_BOOL:
$val = ($val == 'true') ? 1 : 0;
break;
default:
$val = trim($val);
break;
}
//FREEPBX-11431 Call Forward Ringtimer Default - Setting does not work
// lets add CFRINGTIMERDEFAULT value in to asteriskDB so that we can use latter in the dialplan
if($key === 'CFRINGTIMERDEFAULT'){
$astman = $this->FreePBX->astman;
if ($astman->connected()){
$astman->database_put("FREEPBXCONF",'CFRINGTIMERDEFAULT',$val);
}
}
$freepbx_conf->set_conf_values(array($key => $val),true,$amp_conf['AS_OVERRIDE_READONLY']);
$status = $freepbx_conf->get_last_update_status();
if ($status[$key]['saved']) {
//debug(sprintf(_("Advanced Settings changed freepbx_conf setting: [$key] => [%s]"),$val));
needreload();
}
}
}
}// $page == "advancedsettings"
if ($page == "dahdichandids"){
if(!isset($_REQUEST['action'])){
return;
}
$type = isset($request['type']) ? $request['type'] : 'setup';
$action = isset($request['action']) ? $request['action'] : '';
if (isset($request['delete'])) $action = 'delete';
$extdisplay = isset($request['extdisplay']) ? $request['extdisplay'] : '';
$channel = isset($request['channel']) ? $request['channel'] : false;
$description = isset($request['description']) ? $request['description'] : '';
$did = isset($request['did']) ? $request['did'] : '';
switch ($action) {
case 'add':
if (core_dahdichandids_add($description, $channel, $did)) {
needreload();
$_REQUEST['extdisplay'] = $channel;
$this->freepbx->View->redirect_standard('extdisplay');
}
break;
case 'edit':
if (core_dahdichandids_edit($description, $channel, $did)) {
needreload();
}
break;
case 'delete':
core_dahdichandids_delete($channel);
needreload();
break;
}
}// $page == "dahdichandids"
if ($page == "routing") {
$display='routing';
$extdisplay=isset($request['extdisplay'])?$request['extdisplay']:'';
$action = isset($request['action'])?$request['action']:'';
if (isset($request['copyroute'])) {
$action = 'copyroute';
}
$repotrunkdirection = isset($request['repotrunkdirection'])?$request['repotrunkdirection']:'';
//this was effectively the sequence, now it becomes the route_id and the value past will have to change
$repotrunkkey = isset($request['repotrunkkey'])?$request['repotrunkkey']:'';
// Check if they uploaded a CSV file for their route patterns
//
if (isset($_FILES['pattern_file']) && $_FILES['pattern_file']['tmp_name'] != '') {
$fh = fopen($_FILES['pattern_file']['tmp_name'], 'r');
if ($fh !== false) {
$csv_file = array();
$index = array();
// Check first row, ingoring empty rows and get indices setup
//
while (($row = fgetcsv($fh, 5000, ",", "\"")) !== false) {
if (count($row) == 1 && $row[0] == '') {
continue;
} else {
$count = count($row) > 4 ? 4 : count($row);
for ($i=0;$i<$count;$i++) {
switch (strtolower($row[$i])) {
case 'prepend':
case 'prefix':
case 'match pattern':
case 'callerid':
$index[strtolower($row[$i])] = $i;
break;
default:
break;
}
}
// If no headers then assume standard order
if (count($index) == 0) {
$index['prepend'] = 0;
$index['prefix'] = 1;
$index['match pattern'] = 2;
$index['callerid'] = 3;
if ($count == 4) {
$csv_file[] = $row;
}
}
break;
}
}
$row_count = count($index);
while (($row = fgetcsv($fh, 5000, ",", "\"")) !== false) {
if (count($row) == $row_count) {
$csv_file[] = $row;
}
}
}
}
// If we have a CSV file it replaces any existing patterns
//
if (!empty($csv_file)) {
foreach ($csv_file as $row) {
$this_prepend = isset($index['prepend']) ? htmlspecialchars(trim($row[$index['prepend']])) : '';
$this_prefix = isset($index['prefix']) ? htmlspecialchars(trim($row[$index['prefix']])) : '';
$this_match_pattern = isset($index['match pattern']) ? htmlspecialchars(trim($row[$index['match pattern']])) : '';
$this_callerid = isset($index['callerid']) ? htmlspecialchars(trim($row[$index['callerid']])) : '';
if ($this_prepend != '' || $this_prefix != '' || $this_match_pattern != '' || $this_callerid != '') {
$dialpattern_insert[] = array(
'prepend_digits' => $this_prepend,
'match_pattern_prefix' => $this_prefix,
'match_pattern_pass' => $this_match_pattern,
'match_cid' => $this_callerid,
);
}
}
} else if (isset($request["bulk_patterns"])) {
$prepend = '/^([^+]*)\+/';
$prefix = '/^([^|]*)\|/';
$match_pattern = '/([^/]*)/';
$callerid = '/\/(.*)$/';
$data = explode("\n",$request['bulk_patterns']);
foreach($data as $list) {
if (preg_match('/^\s*$/', $list)) {
continue;
}
$this_prepend = $this_prefix = $this_callerid = '';
if (preg_match($prepend, $list, $matches)) {
$this_prepend = $matches[1];
$list = preg_replace($prepend, '', $list);
}
if (preg_match($prefix, $list, $matches)) {
$this_prefix = $matches[1];
$list = preg_replace($prefix, '', $list);
}
if (preg_match($callerid, $list, $matches)) {
$this_callerid = $matches[1];
$list = preg_replace($callerid, '', $list);
}
$dialpattern_insert[] = array(
'prepend_digits' => htmlspecialchars(trim($this_prepend)),
'match_pattern_prefix' => htmlspecialchars(trim($this_prefix)),
'match_pattern_pass' => htmlspecialchars(trim($list)),
'match_cid' => htmlspecialchars(trim($this_callerid)),
);
$i++;
}
} else if (isset($request["dialpatterndata"])) {
$dp = json_decode($request['dialpatterndata'],true);
$dp = is_array($dp) ? $dp : array();
foreach ($dp as $pattern) {
if ($pattern['prepend_digit'] !='' || $pattern['pattern_prefix']!='' || $pattern['pattern_pass'] !='' || $pattern['match_cid'] !='') {
$dialpattern_insert[] = array(
'prepend_digits' => htmlspecialchars(trim($pattern['prepend_digit'])),
'match_pattern_prefix' => htmlspecialchars(trim($pattern['pattern_prefix'])),
'match_pattern_pass' => htmlspecialchars(trim($pattern['pattern_pass'])),
'match_cid' => htmlspecialchars(trim($pattern['match_cid'])),
);
}
}
}
if ( isset($request['reporoutedirection']) && $request['reporoutedirection'] != '' && isset($request['reporoutekey']) && $request['reporoutekey'] != '') {
$request['route_seq'] = core_routing_setrouteorder($request['reporoutekey'], $request['reporoutedirection']);
}
$trunkpriority = array();
if (isset($request["trunkpriority"])) {
$trunkpriority = $request["trunkpriority"];
if (!$trunkpriority) {
$trunkpriority = array();
}
// delete blank entries and reorder
foreach (array_keys($trunkpriority) as $key) {
if ($trunkpriority[$key] == '') {
// delete this empty
unset($trunkpriority[$key]);
} else if (($key==($repotrunkkey-1)) && ($repotrunkdirection=="up")) {
// swap this one with the one before (move up)
$temptrunk = $trunkpriority[$key];
$trunkpriority[ $key ] = $trunkpriority[ $key+1 ];
$trunkpriority[ $key+1 ] = $temptrunk;
} else if (($key==($repotrunkkey)) && ($repotrunkdirection=="down")) {
// swap this one with the one after (move down)
$temptrunk = $trunkpriority[ $key+1 ];
$trunkpriority[ $key+1 ] = $trunkpriority[ $key ];
$trunkpriority[ $key ] = $temptrunk;
}
}
unset($temptrunk);
$trunkpriority = array_unique(array_values($trunkpriority)); // resequence our numbers
if ($action == '') {
$action = "updatetrunks";
}
}
$routename = isset($request['routename']) ? $request['routename'] : '';
$routepass = isset($request['routepass']) ? $request['routepass'] : '';
$emergency = isset($request['emergency']) ? $request['emergency'] : '';
$intracompany = isset($request['intracompany']) ? $request['intracompany'] : '';
$mohsilence = isset($request['mohsilence']) ? $request['mohsilence'] : '';
$outcid = isset($request['outcid']) ? $request['outcid'] : '';
$outcid_mode = isset($request['outcid_mode']) ? $request['outcid_mode'] : '';
$time_group_id = isset($request['time_group_id']) ? $request['time_group_id'] : '';
$route_seq = isset($request['route_seq']) ? $request['route_seq'] : '';
$goto = isset($request['goto0'])?$request['goto0']:'';
$dest = $goto ? $request[$goto . '0'] : '';
//if submitting form, update database
switch ($action) {
case 'ajaxroutepos':
$ret = core_routing_setrouteorder($repotrunkkey, $repotrunkdirection);
needreload();
header("Content-type: application/json");
echo json_encode(array('position' => $ret));
exit;
break;
case "copyroute":
$routename .= "_copy_$extdisplay";
$extdisplay='';
$route_seq++;
// Fallthrough to addtrunk now...
//
case "addroute":
$extdisplay = core_routing_addbyid($routename, $outcid, $outcid_mode, $routepass, $emergency, $intracompany, $mohsilence, $time_group_id, $dialpattern_insert, $trunkpriority, $route_seq, $dest);
needreload();
break;
case "editroute":
$extdisplay = $_REQUEST['id'];
core_routing_editbyid($extdisplay, $routename, $outcid, $outcid_mode, $routepass, $emergency, $intracompany, $mohsilence, $time_group_id, $dialpattern_insert, $trunkpriority, $route_seq, $dest);
needreload();
break;
case "delroute":
if (!function_exists('core_routing_delbyid')) {
if (file_exists(__DIR__."/functions.inc.php")) {
include __DIR__."/functions.inc.php";
}
}
$ret = core_routing_delbyid($_REQUEST['id']);
// re-order the routes to make sure that there are no skipped numbers.
// example if we have 001-test1, 002-test2, and 003-test3 then delete 002-test2
// we do not want to have our routes as 001-test1, 003-test3 we need to reorder them
// so we are left with 001-test1, 002-test3
needreload();
return $ret;
break;
case "updatetrunks":
$ret = core_routing_updatetrunks($extdisplay, $trunkpriority, true);
header("Content-type: application/json");
echo json_encode(array('result' => $ret));
needreload();
exit;
break;
case 'prioritizeroute':
needreload();
break;
case 'getnpanxxjson':
try {
$npa = $request['npa'];
$nxx = $request['nxx'];
$url = 'http://www.localcallingguide.com/xmllocalprefix.php?npa=602&nxx=930';
$request = new \Pest('http://www.localcallingguide.com/xmllocalprefix.php');
$data = $request->get('?npa='.$npa.'&nxx='.$nxx);
$xml = new \SimpleXMLElement($data);
$pfdata = $xml->xpath('//lca-data/prefix');
$retdata = array();
foreach($pfdata as $item){
$inpa = (string)$item->npa;
$inxx = (string)$item->nxx;
$retdata[$inpa.$inxx] = array('npa' => $inpa, 'nxx' => $inxx);
}
$ret = json_encode($retdata);
header("Content-type: application/json");
echo $ret;
exit;
}catch(Pest_NotFound $e){
header("Content-type: application/json");
echo json_encode(array('error' => $e));
exit;
}
break;
case 'populatenpanxx':
$dialpattern_array = $dialpattern_insert;
if (preg_match("/^([2-9]\d\d)-?([2-9]\d\d)$/", $_REQUEST["npanxx"], $matches)) {
// first thing we do is grab the exch:
$ch = curl_init();
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
curl_setopt($ch, CURLOPT_URL, "http://www.localcallingguide.com/xmllocalprefix.php?npa=".$matches[1]."&nxx=".$matches[2]);
curl_setopt($ch, CURLOPT_USERAGENT, "Mozilla/5.0 (Linux; FreePBX Local Trunks Configuration)");
$str = curl_exec($ch);
curl_close($ch);
// quick 'n dirty - nabbed from PEAR
global $amp_conf;
require_once($amp_conf['AMPWEBROOT'] . '/admin/modules/core/XML_Parser.php');
require_once($amp_conf['AMPWEBROOT'] . '/admin/modules/core/XML_Unserializer.php');
$xml = new xml_unserializer;
$xml->unserialize($str);
$xmldata = $xml->getUnserializedData();
$hash_filter = array(); //avoid duplicates
if (isset($xmldata['lca-data']['prefix'])) {
// we do the loops separately so patterns are grouped together
// match 1+NPA+NXX (dropping 1)
foreach ($xmldata['lca-data']['prefix'] as $prefix) {
if (isset($hash_filter['1'.$prefix['npa'].$prefix['nxx']])) {
continue;
} else {
$hash_filter['1'.$prefix['npa'].$prefix['nxx']] = true;
}
$dialpattern_array[] = array(
'prepend_digits' => '',
'match_pattern_prefix' => '1',
'match_pattern_pass' => htmlspecialchars($prefix['npa'].$prefix['nxx']).'XXXX',
'match_cid' => '',
);
}
// match NPA+NXX
foreach ($xmldata['lca-data']['prefix'] as $prefix) {
if (isset($hash_filter[$prefix['npa'].$prefix['nxx']])) {
continue;
} else {
$hash_filter[$prefix['npa'].$prefix['nxx']] = true;
}
$dialpattern_array[] = array(
'prepend_digits' => '',
'match_pattern_prefix' => '',
'match_pattern_pass' => htmlspecialchars($prefix['npa'].$prefix['nxx']).'XXXX',
'match_cid' => '',
);
}
// match 7-digits
foreach ($xmldata['lca-data']['prefix'] as $prefix) {
if (isset($hash_filter[$prefix['nxx']])) {
continue;
} else {
$hash_filter[$prefix['nxx']] = true;
}
$dialpattern_array[] = array(
'prepend_digits' => '',
'match_pattern_prefix' => '',
'match_pattern_pass' => htmlspecialchars($prefix['nxx']).'XXXX',
'match_cid' => '',
);
}
unset($hash_filter);
} else {
$errormsg = _("Error fetching prefix list for: "). $request["npanxx"];
}
} else {
// what a horrible error message... :p
$errormsg = _("Invalid format for NPA-NXX code (must be format: NXXNXX)");
}
if (isset($errormsg)) {
echo "<script language=\"javascript\">alert('".addslashes($errormsg)."');</script>";
unset($errormsg);
}
break;
}
}// $page == "routing"
if ($page == "did") {
$extdisplay= htmlspecialchars(isset($request['extdisplay'])?$request['extdisplay']:'');
$old_extdisplay = $extdisplay;
$dispnum = 'did'; //used for switch on config.php
$account = isset($request['account'])?$request['account']:'';
$action = isset($request['action'])?$request['action']:'';
$goto = isset($request['goto0'])?$request['goto0']:'';
$ringing = isset($request['ringing'])?$request['ringing']:'';
$reversal = isset($request['reversal'])?$request['reversal']:'';
$description = htmlspecialchars(isset($request['description'])?$request['description']:'');
$privacyman = isset($request['privacyman'])?$request['privacyman']:'0';
$pmmaxretries = isset($request['pmmaxretries'])?$request['pmmaxretries']:'';
$pmminlength = isset($request['pmminlength'])?$request['pmminlength']:'';
$alertinfo = htmlspecialchars(isset($request['alertinfo'])?$request['alertinfo']:'');
$mohclass = isset($request['mohclass'])?$request['mohclass']:'default';
$grppre = isset($request['grppre'])?$request['grppre']:'';
$delay_answer = isset($request['delay_answer'])&&$request['delay_answer']?$request['delay_answer']:'0';
$pricid = isset($request['pricid'])?$request['pricid']:'';
$rnavsort = isset($request['rnavsort'])?$request['rnavsort']:'description';
$didfilter = isset($request['didfilter'])?$request['didfilter']:'';
if (isset($request['submitclear']) && isset($request['goto0'])) {
$request[$request['goto0'].'0'] = '';
}
if (isset($request['extension']) && isset($request['cidnum'])) {
$extdisplay = $request['extension']."/".$request['cidnum'];
}
if (isset($request['old_extension']) && isset($request['old_cidnum'])) {
$old_extdisplay = $request['old_extension']."/".$request['old_cidnum'];
}
//update db if submiting form
switch ($action) {
case 'addIncoming':
//create variables from request
extract($request, EXTR_SKIP);
//add details to the 'incoming' table
if (core_did_add($request)) {
needreload();
$_REQUEST['extdisplay'] = $_REQUEST['extension']."/".$_REQUEST['cidnum'];
$this->freepbx->View->redirect_standard('extdisplay', 'didfilter', 'rnavsort');
}
break;
case 'delIncoming':
$extarray=explode('/',$extdisplay,2);
core_did_del($extarray[0],$extarray[1]);
needreload();
break;
case 'edtIncoming':
$extarray=explode('/',$old_extdisplay,2);
if (core_did_edit($extarray[0],$extarray[1],$_REQUEST)) {
needreload();
}
break;
}
}// $page == "did"
if ($page == "astmodules") {
$action = !empty($request['action']) ? $request['action'] : "";
$section = !empty($request['section']) ? $request['section'] : "";
if(empty($request['module'])){
return false;
}
$modinfo = new \SplFileInfo($module);
if($modinfo->getExtension() !== 'so'){
return false;
}
$module = $modinfo->getBasename();
unset($modinfo);
switch($action){
case 'add':
switch($section){
case 'amodload':
$this->ModulesConf->load($module);
return true;
break;
case 'amodnoload':
$this->ModulesConf->noload($module);
return true;
break;
case 'amodpreload':
$this->ModulesConf->preload($module);
return true;
break;
default:
return false;
break;
}
break;
case 'del':
switch($section){
case 'amodnoload':
$this->ModulesConf->removenoload($module);
return true;
break;
case 'amodpreload':
$this->ModulesConf->removepreload($module);
return true;
break;
default:
return false;
break;
}
break;
default:
return false;
break;
}
} // $page == "astmodules"
}
/**
* Converts a request into an array that core wants.
* @param {int} $account The Account Number
* @param {string} The TECH type
* @param {int} &$flag The Flag Number
*/
public function convertRequest2Array($account,$tech,&$flag = 2) {
if(!isset($account) || (trim($account) === "") || !ctype_digit($account)) {
throw new \Exception("Account must be set!");
}
if(empty($tech)) {
throw new \Exception("tech must be set!");
}
$flag = !empty($flag) ? $flag : 2;
$fields = array();
$tech = strtoupper($tech);
foreach ($_REQUEST as $req=>$data) {
if ( substr($req, 0, 8) == 'devinfo_' ) {
$keyword = substr($req, 8);
$data = trim($data);
if ( $keyword == 'dial' && $data == '' ) {
if($tech == 'ZAP' || $tech == 'DAHDI') {
$chan = $_REQUEST['devinfo_channel'] != '' ? $_REQUEST['devinfo_channel'] : $_REQUEST['channel'];
$fields[$keyword] = array("value" => $tech.'/'.$chan, "flag" => $flag++);
} else {
$fields[$keyword] = array("value" => $tech.'/'.$account, "flag" => $flag++);
}
} elseif ($keyword == 'mailbox' && $data == '') {
if($_REQUEST['vm'] == 'enabled') {
$fields['mailbox'] = array("value" => $account.'@device', "flag" => $flag++);
}
} elseif ($keyword == 'vmexten' && $data == '') {
// don't add it
} else {
$fields[$keyword] = array("value" => $data, "flag" => $flag++);
}
}
}
if(empty($fields)) {
die_freepbx('Fields are empty');
}
$fields['account'] = array("value" => $account, "flag" => $flag++);
$fields['callerid'] = array("value" => (isset($_REQUEST['description']) && $_REQUEST['description']) ? $_REQUEST['description']." <".$account.'>' : 'device'." <".$account.'>', "flag" => $flag++);
return $fields;
}
/**
* Generate the default settings when creating a user
* @param int $number The exten or device number
* @param string $displayname The displayname
*/
public function generateDefaultUserSettings($number,$displayname) {
return array(
"extension" => $number,
"name" => $displayname,
"outboundcid" => "",
"password" => "",
"sipname" => "",
"ringtimer" => 0,
"callwaiting" => "enabled",
"pinless" => "disabled",
"recording_in_external" => "dontcare",
"recording_out_external" => "dontcare",
"recording_in_internal" => "dontcare",
"recording_out_internal" => "dontcare",
"recording_ondemand" => "disabled",
"recording_priority" => "10",
"answermode" => "disabled",
"intercom" => "enabled",
"cid_masquerade" => "",
"noanswer_dest" => "",
"busy_dest" => "",
"concurrency_limit" => "",
"chanunavail_dest" => ""
);
}
/**
* Generate a secret to be used as a password Up to the SIPSECRETSIZE
*/
public function generateSecret(){
global $amp_conf;
$secret = md5(uniqid());//32 char
if(isset($amp_conf['SIPSECRETSIZE']) && $amp_conf['SIPSECRETSIZE'] < 32){
$secret = substr($secret, 0, $amp_conf['SIPSECRETSIZE']);
}
return $secret;
}
/**
* Generate the default settings when creating a device
* @param {string} The TECH
* @param {int} The exten or device number
* @param {string} $displayname The displayname
*/
public function generateDefaultDeviceSettings($tech,$number,$displayname,&$flag = 2) {
$flag = !empty($flag) ? $flag : 2;
$dial = '';
$settings = array();
//Ask our tech if it has default settings
if(isset($this->drivers[$tech])) {
$settings = $this->drivers[$tech]->getDefaultDeviceSettings($number, $displayname, $flag);
if(empty($settings)) {
return array();
}
}
$gsettings = array(
"devicetype" => array(
"value" => "fixed"
),
"user" => array(
"value" => $number
),
"description" => array(
"value" => $displayname
),
"emergency_cid" => array(
"value" => '',
),
"dial" => array(
"value" => $settings['dial']."/".$number,
"flag" => $flag++
),
"secret" => array(
"value" => $this->generateSecret(),
"flag" => $flag++
),
"context" => array(
"value" => "from-internal",
"flag" => $flag++
),
"mailbox" => array(
"value" => $number."@device",
"flag" => $flag++
),
"account" => array(
"value" => $number,
"flag" => $flag++
),
"callerid" => array(
"value" => "device <".$number.">",
"flag" => $flag++
)
);
return array_merge($settings['settings'],$gsettings);
}
/**
* Add Device
* @param {int} The Device Number
* @param {string} The TECH type
* @param {array} $settings=array() Array with all settings
* @param {bool} $editmode=false If edited, (this is so it doesnt destroy the AsteriskDB)
*/
public function addDevice($id,$tech,$settings=array(),$editmode=false) {
if ($tech == '' || trim($tech) == 'virtual') {
return true;
}
if (trim($id) == '' || empty($settings)) {
throw new \Exception(_("Device Extension was blank or there were no settings defined"));
return false;
}
//ensure this id is not already in use
$dev = $this->getDevice($id);
if(!empty($dev)) {
throw new \Exception(_("This device id is already in use"));
}
//unless defined, $dial is TECH/id
if ($settings['dial']['value'] == '') {
//zap, dahdi are exceptions
if (strtolower($tech) == "zap" || strtolower($tech) == 'dahdi') {
$thischan = $settings['devinfo_channel']['value'] != '' ? $settings['devinfo_channel']['value'] : $settings['channel']['value'];
$settings['dial']['value'] = strtoupper($tech).'/'.$thischan;
//-------------------------------------------------------------------------------------------------
// Added to enable the unsupported misdn module
//
} else if (strtolower($tech) == "misdn") {
$settings['dial']['value'] = $settings['devinfo_port']['value'].'/'.($settings['devinfo_msn']['value'] ? $settings['devinfo_msn']['value'] : $id);
//-------------------------------------------------------------------------------------------------
} else {
$settings['dial']['value'] = strtoupper($tech)."/".$id;
}
}
$settings['user']['value'] = ($settings['user']['value'] == 'new') ? $id : $settings['user']['value'];
$settings['emergency_cid']['value'] = trim($settings['emergency_cid']['value']);
$settings['description']['value'] = trim($settings['description']['value']);
//insert into devices table
$sql="INSERT INTO devices (id,tech,dial,devicetype,user,description,emergency_cid) values (?,?,?,?,?,?,?)";
$sth = $this->database->prepare($sql);
try {
$sth->execute(array($id,$tech,$settings['dial']['value'],$settings['devicetype']['value'],$settings['user']['value'],$settings['description']['value'],$settings['emergency_cid']['value']));
} catch(\Exception $e) {
die_freepbx("Could Not Insert Device", $e->getMessage());
return false;
}
$astman = $this->FreePBX->astman;
//add details to astdb
if ($astman->connected()) {
// if adding or editting a fixed device, user property should always be set
if ($settings['devicetype']['value'] == 'fixed' || !$editmode) {
$astman->database_put("DEVICE",$id."/user",$settings['user']['value']);
}
// If changing from a fixed to an adhoc, the user property should be intialized
// to the new default, not remain as the previous fixed user
if ($editmode) {
$previous_type = $astman->database_get("DEVICE",$id."/type");
if ($previous_type == 'fixed' && $settings['devicetype']['value'] == 'adhoc') {
$astman->database_put("DEVICE",$id."/user",$settings['user']['value']);
}
}
$astman->database_put("DEVICE",$id."/dial",$settings['dial']['value']);
$astman->database_put("DEVICE",$id."/type",$settings['devicetype']['value']);
$astman->database_put("DEVICE",$id."/default_user",$settings['user']['value']);
if($settings['emergency_cid']['value'] != '') {
$astman->database_put("DEVICE",$id."/emergency_cid",$settings['emergency_cid']['value']);
} else {
$astman->database_del("DEVICE",$id."/emergency_cid");
}
$apparent_connecteduser = ($editmode && $settings['user']['value'] != "none") ? $astman->database_get("DEVICE",$id."/user") : $settings['user']['value'];
if ($settings['user']['value'] != "none" && $apparent_connecteduser == $settings['user']['value']) {
$existingdevices = $astman->database_get("AMPUSER",$settings['user']['value']."/device");
if (empty($existingdevices)) {
$astman->database_put("AMPUSER",$settings['user']['value']."/device",$id);
} else {
$existingdevices_array = explode('&',$existingdevices);
if (!in_array($id, $existingdevices_array)) {
$existingdevices_array[]=$id;
$existingdevices = implode('&',$existingdevices_array);
$astman->database_put("AMPUSER",$settings['user']['value']."/device",$existingdevices);
}
}
}
} else {
die_freepbx("Cannot connect to Asterisk Manager with ".$this->config->get('AMPMGRUSER')."/".$this->config->get('AMPMGRPASS'));
}
// create a voicemail symlink if needed
// TODO: This should be hooked from voicemail
if ( $this->FreePBX->Modules->moduleHasMethod('Voicemail','setupMailboxSymlinks') ) {
$this->FreePBX->Voicemail->setupMailboxSymlinks($settings['user']['value']);
}
// before calling device specifc funcitions, get rid of any bogus fields in the array
//
if (isset($settings['devinfo_secret_origional'])) {
unset($settings['devinfo_secret_origional']);
}
unset($settings['devicetype']);
unset($settings['user']);
unset($settings['description']);
unset($settings['emergency_cid']);
unset($settings['changecdriver']);
//take care of sip/iax/zap config
$tech = strtolower($tech);
if(isset($this->drivers[$tech])) {
return $this->drivers[$tech]->addDevice($id, $settings);
}
$this->deviceCache = array();
return true;
}
/**
* List All DAHDi Channels
* @return array Array of DAHDi Channels
*/
public function listDahdiChannels(){
$sql = "SELECT * FROM dahdichandids ORDER BY channel";
$stmt = $this->database->prepare($sql);
$stmt->execute();
$results = $stmt->fetchAll(\PDO::FETCH_ASSOC);
return $results;
}
/**
* Delete trunk from inbound route by id.
* @param int $trunk_id id of the trunk
* @return bool Return from db call
*/
public function delRouteTrunkByID($trunk_id){
$sql ='DELETE FROM outbound_route_trunks WHERE trunk_id = :trunk_id';
$stmt = $this->database->prepare($sql);
return $stmt->execute(array(':trunk_id' => $trunk_id));
}
/**
* Delete Trunk
* @param string $trunknum Trunk ID
* @param srting $tech Trunk tech
* @return mixed Return (bool) true on success or array on failure.
*/
public function deleteTrunk($trunknum, $tech = null, $edit = false){
if ($tech === null) { // in EditTrunk, we get this info anyways
$tech = $this->getTrunkTech($trunknum);
}
// conditionally, delete from iax or sip
switch (strtolower($tech)) {
case "iax2":
$tech = "iax";
// fall through
case "iax":
case "sip":
$sql = "DELETE FROM $tech WHERE id IN (:trunknum1, :trunknum2, :trunknum3)";
$stmt = $this->database->prepare($sql);
$ret1 = $stmt->execute(array(':trunknum1'=>'tr-peer-'.$trunknum,':trunknum2' => 'tr-user-'.$trunknum, ':trunknum3' => 'tr-reg-'.$trunknum));
break;
case "pjsip":
$sql = "DELETE FROM pjsip WHERE id = :trunknum";
$stmt = $this->database->prepare($sql);
$ret1 = $stmt->execute(array(':trunknum'=>$trunknum));
break;
}
$sql = "DELETE FROM trunks WHERE trunkid = :trunknum";
$stmt = $this->database->prepare($sql);
$ret = $stmt->execute(array(':trunknum'=>$trunknum));
if ($this->astman) {
$this->astman->database_del("TRUNK", $trunknum . '/dialopts');
}
//Handle hooks
$this->freepbx->Hooks->processHooks($trunknum, $tech);
//Remove trunk from inbound routes
if(!$edit){
$this->delRouteTrunkByID($trunknum);
}
if($ret & $ret1){
return true;
}else{
return array('status' => false, 'techdelete' => $ret1, 'trunksdel' => $ret);
}
}
/**
* List All Trunks
* @return array Array of Trunks
*/
public function listTrunks() {
$sql = 'SELECT * from `trunks` ORDER BY `trunkid`';
$stmt = $this->database->prepare($sql);
$ret = $stmt->execute();
$result = $stmt->fetchAll(\PDO::FETCH_ASSOC);
$trunk_list = array();
foreach ($result as $trunk) {
if ($trunk['name'] == '') {
$tech = strtoupper($trunk['tech']);
switch ($tech) {
case 'CUSTOM':
$trunk['name'] = 'AMP:'.$trunk['channelid'];
break;
default:
$trunk['name'] = $tech.'/'.$trunk['channelid'];
break;
}
}
$trunk['dialopts'] = $this->freepbx->astman->database_get("TRUNK",$trunk['trunkid'] . "/dialopts");
$trunk_list[$trunk['trunkid']] = $trunk;
}
return $trunk_list;
}
public function trunkHasRegistrations($type = ''){
$types = array(
'zap',
'dahdi',
'custom',
''
);
return !in_array($type, $types);
}
public function deleteTrunkDialRulesByID($trunknum) {
$sql = "DELETE FROM `trunk_dialpatterns` WHERE `trunkid` = ?";
$sth = $this->database->prepare($sql);
$sth->execute(array($trunknum));
}
public function getTrunkRoutesByID($trunknum) {
$sql = 'SELECT a.seq, b.name FROM outbound_route_trunks a JOIN outbound_routes b ON a.route_id = b.route_id WHERE trunk_id = ?';
$sth = $this->database->prepare($sql);
$sth->execute(array($trunknum));
$results = $sth->fetchAll(\PDO::FETCH_ASSOC);
$routes = array();
foreach ($results as $entry) {
$routes[$entry['name']] = $entry['seq'];
}
return $routes;
}
public function updateRouteTrunks($route_id, &$trunks, $delete = false) {
$insert_trunk = array();
$seq = 0;
foreach ($trunks as $trunk) {
$insert_trunk[] = array( $route_id,$trunk, $seq);
$seq++;
}
if ($delete) {
$sth = $this->database->prepare("DELETE FROM `outbound_route_trunks` WHERE `route_id`= ?");
$sth->execute(array($route_id));
}
$stmt = $this->database->prepare('INSERT INTO `outbound_route_trunks` (`route_id`, `trunk_id`, `seq`) VALUES (?,?,?)');
$ret = array();
foreach($insert_trunk as $t){
$ret[] = $stmt->execute($t);
}
return $ret;
}
public function updateTrunkDialRules($trunknum, &$patterns, $delete = false) {
$filter_prepend = '/[^0-9+*#wW]/';
$filter_prefix = '/[^0-9*#+xnzXNZ\-\[\]]/';
$filter_match = '/[^0-9.*#+xnzXNZ\-\[\]]/';
$insert_pattern = array();
$seq = 0;
foreach ($patterns as $pattern) {
$match_pattern_prefix = preg_replace($filter_prefix,'',strtoupper(trim($pattern['match_pattern_prefix'])));
$match_pattern_pass = preg_replace($filter_match,'',strtoupper(trim($pattern['match_pattern_pass'])));
$prepend_digits = str_replace('W', 'w', preg_replace($filter_prepend,'',strtoupper(trim($pattern['prepend_digits']))));
if ($match_pattern_prefix.$match_pattern_pass == '') {
continue;
}
// if duplicate prepend, get rid of subsequent since they will never be checked
$hash_index = md5($match_pattern_prefix.$match_pattern_pass);
if (!isset($insert_pattern[$hash_index])) {
$insert_pattern[$hash_index] = array($match_pattern_prefix, $match_pattern_pass, $prepend_digits, $seq);
$seq++;
}
}
if ($delete) {
$sth = $this->database->prepare("DELETE FROM `trunk_dialpatterns` WHERE `trunkid`= ?");
$sth->execute(array($trunknum));
}
$sth = $this->database->prepare('INSERT INTO `trunk_dialpatterns` (`trunkid`, `match_pattern_prefix`, `match_pattern_pass`, `prepend_digits`, `seq`) VALUES (?,?,?,?,?)');
foreach($insert_pattern as $pattern) {
array_unshift($pattern, $trunknum);
$sth->execute($pattern);
}
}
public function getRouteByID($route_id) {
$sql = 'SELECT a.*, b.seq FROM `outbound_routes` a JOIN `outbound_route_sequence` b ON a.route_id = b.route_id WHERE a.route_id=?';
$sth = $this->database->prepare($sql);
$sth->execute(array($route_id));
return $sth->fetch(\PDO::FETCH_ASSOC);
}
public function getAllTrunkDialRules() {
$sql = "SELECT * FROM `trunk_dialpatterns` ORDER BY `trunkid`, `seq`";
$sth = $this->database->prepare($sql);
$sth->execute();
return $sth->fetchAll(\PDO::FETCH_ASSOC);
}
public function getRouteTrunksByID($route_id) {
$sql = "SELECT `trunk_id` FROM `outbound_route_trunks` WHERE `route_id` = ? ORDER BY `seq`";
$sth = $this->database->prepare($sql);
$sth->execute(array($route_id));
$res = $sth->fetchAll(\PDO::FETCH_COLUMN);
return $res;
}
public function getRoutePatternsByID($route_id) {
$sql = "SELECT * FROM `outbound_route_patterns` WHERE `route_id` = ? ORDER BY `match_pattern_prefix`, `match_pattern_pass`";
$sth = $this->database->prepare($sql);
$sth->execute(array($route_id));
return $sth->fetchAll(\PDO::FETCH_ASSOC);
}
public function getTrunkDialRulesByID($trunkid) {
$sql = "SELECT * FROM `trunk_dialpatterns` WHERE `trunkid` = ? ORDER BY `seq`";
$sth = $this->database->prepare($sql);
$sth->execute(array($trunkid));
return $sth->fetchAll(\PDO::FETCH_ASSOC);
}
public function getTrunkTrunkNameByID() {
$name = "SELECT `name` FROM `trunks` WHERE `trunkid` = ?";
$sth = $this->database->prepare($name);
$sth->execute(array($trunknum));
$results = $sth->fetch(\PDO::FETCH_ASSOC);
return isset($results['name']) ? $results['name'] : false;
}
public function getTrunkPeerDetailsByID($trunkid) {
$tech = $this->getTrunkTech($trunkid);
if (!$this->trunkHasRegistrations($tech)){
return '';
}
$sql = "SELECT keyword,data FROM $tech WHERE `id` = ? ORDER BY flags, keyword DESC";
$sth = $this->database->prepare($sql);
$sth->execute(array('tr-peer-'.$trunkid));
$results = $sth->fetchAll(\PDO::FETCH_ASSOC);
foreach ($results as $result) {
if ($result['keyword'] != 'account') {
if (isset($confdetail)) {
$confdetail .= $result['keyword'] .'='. $result['data'] . "\n";
} else {
$confdetail = $result['keyword'] .'='. $result['data'] . "\n";
}
}
}
return isset($confdetail)?$confdetail:null;
}
public function getTrunkUserContext($trunkid) {
$sql = "SELECT `usercontext` FROM `trunks` WHERE `trunkid` = ?";
$sth = $this->database->prepare($sql);
$sth->execute(array($trunkid));
$results = $sth->fetch(\PDO::FETCH_ASSOC);
return ((isset($results['usercontext'])) ? $results['usercontext'] : '');
}
public function getTrunkUserConfigByID($trunkid) {
$tech = $this->getTrunkTech($trunkid);
if (!$this->trunkHasRegistrations($tech)){
return '';
}
$sql = "SELECT keyword,data FROM $tech WHERE `id` = ? ORDER BY flags, keyword DESC";
$sth = $this->database->prepare($sql);
$sth->execute(array('tr-user-'.$trunkid));
$results = $sth->fetchAll(\PDO::FETCH_ASSOC);
foreach ($results as $result) {
if ($result['keyword'] != 'account') {
if (isset($confdetail)) {
$confdetail .= $result['keyword'] .'='. $result['data'] . "\n";
} else {
$confdetail = $result['keyword'] .'='. $result['data'] . "\n";
}
}
}
return isset($confdetail)?$confdetail:null;
}
public function getTrunkRegisterStringByID($trunkid) {
$tech = $this->getTrunkTech($trunkid);
if (!$this->trunkHasRegistrations($tech)){
return '';
}
$sql = "SELECT `data` FROM $tech WHERE `id` = ?";
$sth = $this->database->prepare($sql);
$sth->execute(array('tr-reg-'.$trunkid));
$result = $sth->fetch(\PDO::FETCH_ASSOC);
return isset($result['data'])?$result['data']:null;
}
public function getTrunkByID($trunkid) {
$sql = 'SELECT * from `trunks` WHERE `trunkid` = ?';
$stmt = $this->database->prepare($sql);
$ret = $stmt->execute(array($trunkid));
$trunk = $stmt->fetch(\PDO::FETCH_ASSOC);
if ($trunk['name'] == '') {
$tech = strtoupper($trunk['tech']);
switch ($tech) {
case 'CUSTOM':
$trunk['name'] = 'AMP:'.$trunk['channelid'];
break;
default:
$trunk['name'] = $tech.'/'.$trunk['channelid'];
break;
}
}
$trunk['dialopts'] = $this->freepbx->astman->database_get("TRUNK",$trunk['trunkid'] . "/dialopts");
return $trunk;
}
public function getTrunkByChannelID($trunkid) {
$sql = 'SELECT * from `trunks` WHERE `channelid` = ?';
$stmt = $this->database->prepare($sql);
$ret = $stmt->execute(array($trunkid));
$result = $stmt->fetch(\PDO::FETCH_ASSOC);
return $result;
}
/**
* Get all the users
* @param {bool} $get_all=false Whether to get all of check in the range
*/
function listUsers($get_all=false) {
if (empty($this->listUsersCache)) {
$sql = 'SELECT extension,name,voicemail FROM users ORDER BY extension';
$sth = $this->database->prepare($sql);
$sth->execute();
$results = $sth->fetchAll(\PDO::FETCH_BOTH);
$this->listUsersCache = $results;
} else {
$results = $this->listUsersCache;
}
//only allow extensions that are within administrator's allowed range
foreach($results as $result){
if ($get_all || \checkRange($result[0])){
$extens[] = array($result[0],$result[1],$result[2]);
}
}
if (isset($extens)) {
sort($extens);
return $extens;
} else {
return array();
}
}
/**
* Delete a Device
* @param {int} The Device ID
* @param {bool} $editmode=false If in edit mode (this is so it doesnt destroy the AsteriskDB)
*/
public function delDevice($account,$editmode=false) {
$astman = $this->FreePBX->astman;
//get all info about device
$devinfo = $this->getDevice($account);
if (empty($devinfo)) {
return true;
}
//delete details to astdb
if ($astman->connected()) {
// If a user was selected, remove this device from the user
$deviceuser = $astman->database_get("DEVICE",$account."/user");
if (isset($deviceuser) && $deviceuser != "none") {
// Remove the device record from the user's device list
$userdevices = $astman->database_get("AMPUSER",$deviceuser."/device");
// We need to remove just this user and leave the rest alone
$userdevicesarr = explode("&", $userdevices);
$userdevicesarr_hash = array_flip($userdevicesarr);
unset($userdevicesarr_hash[$account]);
$userdevicesarr = array_flip($userdevicesarr_hash);
$userdevices = implode("&", $userdevicesarr);
if (empty($userdevices)) {
$astman->database_del("AMPUSER",$deviceuser."/device");
} else {
$astman->database_put("AMPUSER",$deviceuser."/device",$userdevices);
}
}
if (!$editmode) {
$astman->database_del("DEVICE",$account."/dial");
$astman->database_del("DEVICE",$account."/type");
$astman->database_del("DEVICE",$account."/user");
$astman->database_del("DEVICE",$account."/default_user");
$astman->database_del("DEVICE",$account."/emergency_cid");
}
//delete from devices table
$sql = "DELETE FROM devices WHERE id = ?";
$sth = $this->database->prepare($sql);
try {
$sth->execute(array($account));
} catch(\Exception $e) {
}
//voicemail symlink
$spooldir = $this->config->get('ASTSPOOLDIR');
$account = preg_replace("/\D/","",$account);
if(trim($account) !== "" && file_exists($spooldir."/voicemail/device/".$account)) {
exec("rm -f ".escapeshellarg($spooldir."/voicemail/device/".$account));
}
} else {
die_freepbx("Cannot connect to Asterisk Manager with ".$this->config->get("AMPMGRUSER")."/".$this->config->get("AMPMGRPASS"));
}
$tech = $devinfo['tech'];
//TODO should only delete the record for this device buuuutttt......
if(isset($this->drivers[$tech])) {
$this->drivers[$tech]->delDevice($account);
}
$this->freepbx->Hooks->processHooks($account, $editmode);
$this->getDeviceHeadersCache = array();
$this->deviceCache = array();
$this->getDeviceCache = array();
return true;
}
/**
* Get all devices by type
* @param string $type The device type
*/
public function getAllDevicesByType($type="") {
if(empty($type)) {
if (empty($this->deviceCache['full'])) {
$sql = "SELECT * FROM devices ORDER BY id";
$sth = $this->database->prepare($sql);
try {
$sth->execute();
$results = $sth->fetchAll(\PDO::FETCH_ASSOC);
} catch(\Exception $e) {
return array();
}
$this->deviceCache['full'] = $results;
} else {
$results = $this->deviceCache['full'];
}
} else {
if (empty($this->deviceCache[$type])) {
$sql = "SELECT * FROM devices WHERE tech = ? ORDER BY id";
$sth = $this->database->prepare($sql);
try {
$sth->execute(array($type));
$results = $sth->fetchAll(\PDO::FETCH_ASSOC);
} catch(\Exception $e) {
return array();
}
$this->deviceCache[$type] = $results;
} else {
$results = $this->deviceCache[$type];
}
}
return $results;
}
/**
* Get All Routes
*/
public function getAllRoutes(){
$sql = "SELECT a.*, b.seq FROM `outbound_routes` a JOIN `outbound_route_sequence` b ON a.route_id = b.route_id ORDER BY `seq`";
$stmt = $this->database->prepare($sql);
$stmt->execute();
$routes = $stmt->fetchAll(\PDO::FETCH_ASSOC);
return $routes;
}
/**
* Get all Users
*/
public function getAllUsers() {
if (empty($this->allUsersCache)) {
$sql = 'SELECT extension,name,voicemail FROM users ORDER BY extension';
$sth = $this->database->prepare($sql);
try {
$sth->execute();
$results = $sth->fetchAll(\PDO::FETCH_ASSOC);
$final = array();
foreach($results as $res) {
$ext = $res['extension'];
$ret = checkRange($ext);
if($ret){
$final[$ext] = $res;
}
}
$this->allUsersCache = $final;
} catch(\Exception $e) {
return array();
}
} else {
$final = $this->allUsersCache;
}
return $final;
}
/**
* Get all Users by Device Type
* @param string $type A specific device type to get
*/
public function getAllUsersByDeviceType($type="") {
if(empty($type) || $type == "virtual") {
$sql = "SELECT * FROM users LEFT JOIN devices ON users.extension = devices.id ORDER BY users.extension";
$sth = $this->database->prepare($sql);
try {
$sth->execute();
$results = $sth->fetchAll(\PDO::FETCH_ASSOC);
} catch(\Exception $e) {
return array();
}
} else {
$sql = "SELECT * FROM users LEFT JOIN devices ON users.extension = devices.id WHERE devices.tech = ? ORDER BY users.extension";
$sth = $this->database->prepare($sql);
try {
$sth->execute(array($type));
$results = $sth->fetchAll(\PDO::FETCH_ASSOC);
} catch(\Exception $e) {
return array();
}
}
$astman = $this->FreePBX->astman;
$dbfamily = $astman->connected() ? $astman->database_show("AMPUSER") : array();
//Virtual Extensions are strange
$final = array();
foreach($results as $result) {
if(!checkRange($result['extension'])){
continue;
}
if(empty($result['tech'])) {
$result['tech'] = 'virtual';
} elseif(!empty($result['tech']) && $type == "virtual") {
continue;
}
$result['recording_in_external'] = isset($dbfamily['/AMPUSER/'.$result['extension'].'/recording/in/external']) ? $dbfamily['/AMPUSER/'.$result['extension'].'/recording/in/external'] : "";
$result['recording_out_external'] = isset($dbfamily['/AMPUSER/'.$result['extension'].'/recording/out/external']) ? $dbfamily['/AMPUSER/'.$result['extension'].'/recording/out/external'] : "";
$result['recording_in_internal'] = isset($dbfamily['/AMPUSER/'.$result['extension'].'/recording/in/internal']) ? $dbfamily['/AMPUSER/'.$result['extension'].'/recording/in/internal'] : "";
$result['recording_out_internal'] = isset($dbfamily['/AMPUSER/'.$result['extension'].'/recording/out/internal']) ? $dbfamily['/AMPUSER/'.$result['extension'].'/recording/out/internal'] : "";
$result['recording_ondemand'] = isset($dbfamily['/AMPUSER/'.$result['extension'].'/recording/ondemand']) ? $dbfamily['/AMPUSER/'.$result['extension'].'/recording/ondemand'] : "";
$result['recording_priority'] = isset($dbfamily['/AMPUSER/'.$result['extension'].'/recording/priority']) ? (int) $dbfamily['/AMPUSER/'.$result['extension'].'/recording/priority'] : "10";
$result['answermode'] = $this->FreePBX->Modules->checkStatus("paging") && isset($dbfamily['/AMPUSER/'.$result['extension'].'/answermode']) ? $dbfamily['/AMPUSER/'.$result['extension'].'/answermode'] : "";
$result['intercom'] = $this->FreePBX->Modules->checkStatus("paging") && isset($dbfamily['/AMPUSER/'.$result['extension'].'/intercom']) ? $dbfamily['/AMPUSER/'.$result['extension'].'/intercom'] : "";
$final[] = $result;
}
return $final;
}
/**
* Check if a SIP Name is in use
* For SIP Alias/Direct SIP dialing
* @param string $sipname The SIP Name to check
* @param int $extension The Extension to check against
*/
public function checkSipnameInUse($sipname, $extension) {
if (!isset($sipname) || trim($sipname)=='') {
return true;
}
$sql = "SELECT sipname FROM users WHERE sipname = ? AND extension != ?";
$sth = $this->database->prepare($sql);
$sth->execute(array($sipname, $extension));
try {
$results = $sth->fetch(\PDO::FETCH_ASSOC);
} catch(\Exception $e) {
die_freepbx($e->getMessage().$sql);
}
if (isset($results['sipname']) && trim($results['sipname']) == $sipname) {
return false;
} else {
return true;
}
}
/**
* Get Inbound Routes (DIDs)
* @param string $order Whether to order results by extension or description
*/
public function getAllDIDs($order='extension') {
switch ($order) {
case 'description':
$sql = "SELECT * FROM incoming ORDER BY description,extension,cidnum";
break;
case 'extension':
default:
$sql = "SELECT * FROM incoming ORDER BY extension,cidnum";
}
$sth = $this->database->prepare($sql);
$sth->execute();
try {
$results = $sth->fetchAll(\PDO::FETCH_ASSOC);
} catch(\Exception $e) {
return array();
}
return $results;
}
/**
* Add Inbound Route
* @param array $settings Array of Inbound Route Settings
*/
public function addDID($settings) {
//Strip <> just to be on the safe side otherwise this is not deleteable from the GUI
$invalidDIDChars = array('<', '>');
$settings['extension'] = trim(str_replace($invalidDIDChars, "", $settings['extension']));
$settings['cidnum'] = trim(str_replace($invalidDIDChars, "", $settings['cidnum']));
$settings['rvolume'] = isset($settings['rvolume']) ? $settings['rvolume'] : "";
// XXX: Kludge for empty value
if ($settings['delay_answer'] == '') {
$settings['delay_answer'] = '0';
}
// Check to make sure the did is not being used elsewhere
//
$existing = $this->getDID($settings['extension'], $settings['cidnum']);
if (empty($existing)) {
$sql="INSERT INTO incoming (rvolume, cidnum, extension, destination, privacyman, pmmaxretries, pmminlength, alertinfo, ringing, reversal, mohclass, description, grppre, delay_answer, pricid) VALUES (:rvolume, :cidnum, :extension, :destination, :privacyman, :pmmaxretries, :pmminlength, :alertinfo, :ringing, :reversal, :mohclass, :description, :grppre, :delay_answer, :pricid)";
$sth = $this->database->prepare($sql);
$sth->execute(array(':rvolume' => $settings['rvolume'], ':cidnum' => $settings['cidnum'], ':extension' => $settings['extension'], ':destination' => $settings['destination'], ':privacyman' => $settings['privacyman'], ':pmmaxretries' => $settings['pmmaxretries'], ':pmminlength' => $settings['pmminlength'], ':alertinfo' => $settings['alertinfo'], ':ringing' => $settings['ringing'], ':reversal' => $settings['reversal'], ':mohclass' => $settings['mohclass'], ':description' => $settings['description'], ':grppre' => $settings['grppre'], ':delay_answer' => $settings['delay_answer'], ':pricid' => $settings['pricid']));
$this->freepbx->Hooks->processHooks($settings);
return true;
} else {
return false;
}
}
/**
* Delete a DID
* @param string $extension The DID Extension
* @param string $cidnum The DID cidnum
*/
public function delDID($extension,$cidnum) {
$sql = "DELETE FROM incoming WHERE cidnum = ? AND extension = ?";
$sth = $this->database->prepare($sql);
$sth->execute(array($cidnum, $extension));
$this->freepbx->Hooks->processHooks($extension, $cidnum);
}
/**
* Get Inbound Route (DID) based on extension (DID) or CID Number
* @param int $extension Inbound Route DID
* @param int $cidnum The CID Number
*/
public function getDID($extension="",$cidnum="") {
$sql = "SELECT * FROM incoming WHERE cidnum = ? AND extension = ?";
$sth = $this->database->prepare($sql);
$sth->execute(array($cidnum, $extension));
try {
$results = $sth->fetch(\PDO::FETCH_ASSOC);
} catch(\Exception $e) {
return array();
}
return $results;
}
/**
* Edit DID
* @param string $oldExtension The old extension
* @param string $oldCidnum The old CID Num
* @param array $incoming Array of new data to use
*/
public function editDID($oldExtension,$oldCidnum, $incoming) {
$extension = trim($incoming['extension']);
$cidnum = trim($incoming['cidnum']);
// if did or cid changed, then check to make sure that this pair is not already being used.
//
if (($extension != $oldExtension) || ($cidnum != $oldCidnum)) {
$existing = $this->getDID($extension,$cidnum);
}
if (empty($existing)) {
$this->delDID($oldExtension,$oldCidnum);
$this->addDID($incoming);
return true;
} else {
return false;
}
}
/**
* Create a new did with values passed into $did_vars and defaults used otherwise
* @param array $did_vars Array of new values
*/
public function createUpdateDID($did_vars) {
$did_create['extension'] = isset($did_vars['extension']) ? $did_vars['extension'] : '';
$did_create['cidnum'] = isset($did_vars['cidnum']) ? $did_vars['cidnum'] : '';
$coredid = $this->getDID($did_create['extension'], $did_create['cidnum']);
if (!empty($coredid) && count($coredid)) {
return $this->editDIDProperties($did_vars); //already exists so just edit properties
} else {
$did_create['privacyman'] = isset($did_vars['privacyman']) ? $did_vars['privacyman'] : '';
$did_create['pmmaxretries'] = isset($did_vars['pmmaxretries']) ? $did_vars['pmmaxretries'] : '';
$did_create['pmminlength'] = isset($did_vars['pmminlength']) ? $did_vars['pmminlength'] : '';
$did_create['alertinfo'] = isset($did_vars['alertinfo']) ? $did_vars['alertinfo'] : '';
$did_create['ringing'] = isset($did_vars['ringing']) ? $did_vars['ringing'] : '';
$did_create['reversal'] = isset($did_vars['reversal']) ? $did_vars['reversal'] : '';
$did_create['mohclass'] = isset($did_vars['mohclass']) ? $did_vars['mohclass'] : 'default';
$did_create['description'] = isset($did_vars['description']) ? $did_vars['description'] : '';
$did_create['grppre'] = isset($did_vars['grppre']) ? $did_vars['grppre'] : '';
$did_create['delay_answer']= isset($did_vars['delay_answer'])? $did_vars['delay_answer']: '0';
$did_create['pricid'] = isset($did_vars['pricid']) ? $did_vars['pricid'] : '';
$did_create['destination'] = isset($did_vars['destination']) ? $did_vars['destination'] : '';
return $this->addDID($did_create);
}
}
/**
* Edits the poperties of a did
* but not the did or cid nums since those could of course be in conflict
* @param array $did_vars Array of variables
* @return [type] [description]
*/
public function editDIDProperties($did_vars) {
if (!is_array($did_vars)) {
return false;
}
$extension = isset($did_vars['extension']) ? $did_vars['extension'] : '';
$cidnum = isset($did_vars['cidnum']) ? $did_vars['cidnum'] : '';
$sql = "";
foreach ($did_vars as $key => $value) {
switch ($key) {
case 'privacyman':
case 'pmmaxretries':
case 'pmminlength':
case 'alertinfo':
case 'ringing':
case 'reversal':
case 'mohclass':
case 'description':
case 'grppre':
case 'delay_answer':
case 'pricid':
case 'destination':
$sql_value = $this->database->escapeSimple($value);
$sql .= " `$key` = $sql_value,";
break;
default:
}
}
if ($sql == '') {
return false;
}
$sql = substr($sql,0,(strlen($sql)-1)); //strip off tailing ','
$sql_update = "UPDATE `incoming` SET"."$sql WHERE `extension` = ? AND `cidnum` = ?";
$sth = $this->database->prepare($sql_update);
return $sth->execute(array($extension, $cidnum));
}
/**
* Add user (Part of Users/Devices)
* @param int $extension The exten numer
* @param array $settings Array of settings to pass in
* @param bool $editmode If in edit mode (So that the AsteriskDB is not destroyed)
*/
public function addUser($extension, $settings, $editmode=false) {
if (trim($extension) == '' ) {
throw new \Exception(_("You must put in an extension (or user) number"));
}
//ensure this id is not already in use
$extens = $this->listUsers();
if(is_array($extens)) {
foreach($extens as $exten) {
if ($exten[0]===$extension) {
throw new \Exception(sprintf(_("This user/extension %s is already in use"),$extension));
}
}
}
$settings['newdid_name'] = isset($settings['newdid_name']) ? $settings['newdid_name'] : '';
$settings['newdid'] = isset($settings['newdid']) ? preg_replace("/[^0-9._XxNnZz\[\]\-\+]/" ,"", trim($settings['newdid'])) : '';
$settings['newdidcid'] = isset($settings['newdidcid']) ? trim($settings['newdidcid']) : '';
if (!preg_match('/^priv|^block|^unknown|^restrict|^unavail|^anonym|^withheld/',strtolower($settings['newdidcid']))) {
$settings['newdidcid'] = preg_replace("/[^0-9._XxNnZz\[\]\-\+]/" ,"", $settings['newdidcid']);
}
if ($settings['newdid'] != '' || $settings['newdidcid'] != '') {
$existing = $this->getDID($settings['newdid'], $settings['newdidcid']);
if (!empty($existing)) {
throw new \Exception(sprintf(_("A route with this DID/CID: %s/%s already exists"),$existing['extension'],$existing['cidnum']));
}
}
$settings['sipname'] = isset($settings['sipname']) ? preg_replace("/\s/" ,"", trim($settings['sipname'])) : '';
if (!$this->checkSipnameInUse($settings['sipname'], $extension)) {
throw new \Exception(_("This sipname: {$sipname} is already in use"));
}
// strip the ugly return of the gui radio funciton which comes back as "recording_out_internal=always" for example
// TODO this should be done with a hook
if (isset($settings['recording_in_external'])) {
$rec_tmp = explode('=',$settings['recording_in_external'],2);
$settings['recording_in_external'] = count($rec_tmp) == 2 ? $rec_tmp[1] : $rec_tmp[0];
} else {
$settings['recording_in_external'] = 'dontcare';
}
if (isset($settings['recording_out_external'])) {
$rec_tmp = explode('=',$settings['recording_out_external'],2);
$settings['recording_out_external'] = count($rec_tmp) == 2 ? $rec_tmp[1] : $rec_tmp[0];
} else {
$settings['recording_out_external'] = 'dontcare';
}
if (isset($settings['recording_in_internal'])) {
$rec_tmp = explode('=',$settings['recording_in_internal'],2);
$settings['recording_in_internal'] = count($rec_tmp) == 2 ? $rec_tmp[1] : $rec_tmp[0];
} else {
$settings['recording_in_internal'] = 'dontcare';
}
if (isset($settings['recording_out_internal'])) {
$rec_tmp = explode('=',$settings['recording_out_internal'],2);
$settings['recording_out_internal'] = count($rec_tmp) == 2 ? $rec_tmp[1] : $rec_tmp[0];
} else {
$settings['recording_out_internal'] = 'dontcare';
}
if (isset($settings['recording_ondemand'])) {
$rec_tmp = explode('=',$settings['recording_ondemand'],2);
$settings['recording_ondemand'] = count($rec_tmp) == 2 ? $rec_tmp[1] : $rec_tmp[0];
} else {
$settings['recording_ondemand'] = 'disabled';
}
//if voicemail is enabled, set the box@context to use
//havn't checked but why is voicemail needed on users anyway? Doesn't exactly make it modular !
//TODO use a hook here
if ( $this->FreePBX->Modules->moduleHasMethod('Voicemail','getMailbox') ) {
$vmbox = $this->FreePBX->Voicemail->getMailbox($extension);
if ( $vmbox == null ) {
$settings['voicemail'] = "novm";
} else {
$settings['voicemail'] = $vmbox['vmcontext'];
}
}
$sql = "INSERT INTO users (extension,password,name,voicemail,ringtimer,noanswer,recording,outboundcid,sipname,noanswer_cid,busy_cid,chanunavail_cid,noanswer_dest,busy_dest,chanunavail_dest) " .
"VALUES (:extension, :password, :name, :voicemail, :ringtimer, :noanswer, :recording, :outboundcid, :sipname, :noanswer_cid, :busy_cid, :chanunavail_cid, :noanswer_dest, :busy_dest, :chanunavail_dest)";
$sth = $this->database->prepare($sql);
try {
$sth->execute(array(
"extension" => $extension,
"password" => isset($settings['password']) ? $settings['password'] : '',
"name" => isset($settings['name']) ? preg_replace(array('/</','/>/'), array('(',')'), trim($settings['name'])) : '',
"voicemail" => isset($settings['voicemail']) ? $settings['voicemail'] : 'default',
"ringtimer" => isset($settings['ringtimer']) ? $settings['ringtimer'] : '',
"noanswer" => isset($settings['noanswer']) ? $settings['noanswer'] : '',
"recording" => isset($settings['recording']) ? $settings['recording'] : '',
"outboundcid" => isset($settings['outboundcid']) ? $settings['outboundcid'] : '',
"sipname" => isset($settings['sipname']) ? $settings['sipname'] : '',
"noanswer_cid" => isset($settings['noanswer_cid']) ? $settings['noanswer_cid'] : "",
"busy_cid" => isset($settings['busy_cid']) ? $settings['busy_cid'] : "",
"chanunavail_cid" => isset($settings['chanunavail_cid']) ? $settings['chanunavail_cid'] : "",
"noanswer_dest" => !empty($settings['noanswer_dest'])? $settings['noanswer_dest']: "",
"busy_dest" => !empty($settings['busy_dest']) ? $settings['busy_dest'] : "",
"chanunavail_dest" => !empty($settings['chanunavail_dest']) ? $settings['chanunavail_dest'] : ""
));
} catch(\Exception $e) {
throw new \Exception("Unable to insert into users: ".addSlashes($e->getMessage()));
}
//write to astdb
$astman = $this->FreePBX->astman;
$fpc = $this->FreePBX->Config();
if ($astman->connected()) {
$astman->database_put("AMPUSER",$extension."/rvolume",isset($settings['rvolume']) ? $settings['rvolume'] : '');
$astman->database_put("AMPUSER",$extension."/password",isset($settings['password']) ? $settings['password'] : '');
$astman->database_put("AMPUSER",$extension."/ringtimer",isset($settings['ringtimer']) ? $settings['ringtimer'] : $fpc->get('RINGTIMER'));
$astman->database_put("AMPUSER",$extension."/cfringtimer",isset($settings['cfringtimer']) ? $settings['cfringtimer'] : $fpc->get('CFRINGTIMERDEFAULT'));
$astman->database_put("AMPUSER",$extension."/concurrency_limit",isset($settings['concurrency_limit']) ? $settings['concurrency_limit'] : $fpc->get('CONCURRENCYLIMITDEFAULT'));
$astman->database_put("AMPUSER",$extension."/noanswer",isset($settings['noanswer']) ? $settings['noanswer'] : '');
$astman->database_put("AMPUSER",$extension."/recording",isset($settings['recording']) ? $settings['recording'] : '');
$astman->database_put("AMPUSER",$extension."/outboundcid",isset($settings['outboundcid']) ? $settings['outboundcid'] : '');
$astman->database_put("AMPUSER",$extension."/cidname",isset($settings['name']) ? $settings['name'] : '');
$astman->database_put("AMPUSER",$extension."/cidnum",(isset($settings['cid_masquerade']) && trim($settings['cid_masquerade']) != "") ? trim($settings['cid_masquerade']) : $extension);
$astman->database_put("AMPUSER",$extension."/voicemail",isset($settings['voicemail']) ? $settings['voicemail'] : '');
//TODO need to be in paging soon
$astman->database_put("AMPUSER",$extension."/answermode",isset($settings['answermode']) ? $settings['answermode']: 'disabled');
$astman->database_put("AMPUSER",$extension."/intercom",isset($settings['intercom']) ? $settings['intercom']: 'enabled');
$astman->database_put("AMPUSER",$extension."/recording/in/external",$settings['recording_in_external']);
$astman->database_put("AMPUSER",$extension."/recording/out/external",$settings['recording_out_external']);
$astman->database_put("AMPUSER",$extension."/recording/in/internal",$settings['recording_in_internal']);
$astman->database_put("AMPUSER",$extension."/recording/out/internal",$settings['recording_out_internal']);
$astman->database_put("AMPUSER",$extension."/recording/ondemand",$settings['recording_ondemand']);
$astman->database_put("AMPUSER",$extension."/recording/priority",isset($settings['recording_priority']) ? $settings['recording_priority'] : '10');
// If not set then we are using system default so delete the tree all-together
//
if (isset($settings['dialopts'])) {
$astman->database_put("AMPUSER",$extension."/dialopts", $settings['dialopts']);
} else {
$astman->database_del("AMPUSER",$extension."/dialopts");
}
$call_screen = isset($settings['call_screen']) ? $settings['call_screen'] : '0';
switch ($call_screen) {
case '0':
$astman->database_del("AMPUSER",$extension."/screen");
break;
case 'nomemory':
$astman->database_put("AMPUSER",$extension."/screen",'nomemory');
break;
case 'memory':
$astman->database_put("AMPUSER",$extension."/screen",'memory');
break;
default:
break;
}
if (!$editmode) {
$astman->database_put("AMPUSER",$extension."/device",isset($settings['device']) ? $settings['device'] : $extension);
}
if (trim($settings['callwaiting']) == 'enabled') {
$astman->database_put("CW",$extension,"ENABLED");
} else if (trim($settings['callwaiting']) == 'disabled') {
$astman->database_del("CW",$extension);
}
if (trim($settings['pinless']) == 'enabled') {
$astman->database_put("AMPUSER",$extension."/pinless","NOPASSWD");
} else if (trim($settings['pinless']) == 'disabled') {
$astman->database_del("AMPUSER",$extension."/pinless");
}
} else {
die_freepbx("Cannot connect to Asterisk Manager with ".$this->FreePBX->Config->get("AMPMGRUSER")."/".$this->FreePBX->Config->get("AMPMGRPASS"));
}
// OK - got this far, if they entered a new inbound DID/CID let's deal with it now
// remember - in the nice and ugly world of this old code, $vars has been extracted
// newdid and newdidcid
// Now if $newdid is set we need to add the DID to the routes
//
if ($settings['newdid'] != '' || $settings['newdidcid'] != '') {
$did_dest = 'from-did-direct,'.$extension.',1';
$did_vars = array();
$did_vars['extension'] = $settings['newdid'];
$did_vars['cidnum'] = $settings['newdidcid'];
$did_vars['privacyman'] = '';
$did_vars['alertinfo'] = '';
$did_vars['ringing'] = '';
$did_vars['reversal'] = '';
$did_vars['mohclass'] = 'default';
$did_vars['description'] = $settings['newdid_name'];
$did_vars['grppre'] = '';
$did_vars['delay_answer']= '0';
$did_vars['pricid']= '';
core_did_add($did_vars, $did_dest);
}
$this->getUserCache = array();
$this->listUsersCache = array();
$this->freepbx->Hooks->processHooks($extension, $settings, $editmode);
return true;
}
/**
* Delete a User
* @param int $extension The user extension
* @param {bool} $editmode=false If in edit mode (this is so it doesnt destroy the AsteriskDB)
*/
public function delUser($extension, $editmode=false) {
global $db;
global $amp_conf;
global $astman;
//delete from devices table
$sql = "DELETE FROM users WHERE extension = ?";
$sth = $this->database->prepare($sql);
$sth->execute(array($extension));
//delete details to astdb
$astman = $this->FreePBX->astman;
if($astman->connected()) {
$astman->database_del("AMPUSER",$extension."/screen");
}
if ($astman->connected() && !$editmode) {
// TODO just change this to delete everything
$astman->database_deltree("AMPUSER/".$extension);
}
$astman->database_del("CW",$extension);
//TODO: Should only delete it's reference
//but the array is multidimensional and sucks
//OUT > Array
//(
// [0] => Array
// (
// [extension] => 1005
// [0] => 1005
// [name] => WTF
// [1] => WTF
// [voicemail] => novm
// [2] => novm
// )
//
//)
$this->getUserCache = array();
$this->listUsersCache = array();
$this->freepbx->Hooks->processHooks($extension, $editmode);
return true;
}
/**
* Get User Details
* @param int $extension The user number (extension)
*/
public function getUser($extension) {
if (!empty($this->getUserCache[$extension])) {
return $this->getUserCache[$extension];
}
$sql = "SELECT * FROM users WHERE extension = ?";
$sth = $this->database->prepare($sql);
try {
$sth->execute(array($extension));
$results = $sth->fetch(\PDO::FETCH_ASSOC);
} catch(\Exception $e) {
return array();
}
if(empty($results)) {
return array();
}
$astman = $this->FreePBX->astman;
if ($astman->connected()) {
if ($this->FreePBX->Modules->checkStatus("paging")) {
$answermode=$astman->database_get("AMPUSER",$extension."/answermode");
$results['answermode'] = (trim($answermode) == '') ? $this->freepbx->Config->get("DEFAULT_INTERNAL_AUTO_ANSWER") : $answermode;
$astman->database_put("AMPUSER",$extension."/answermode",$results['answermode']); //incase it was updated from above
$intercom=$astman->database_get("AMPUSER",$extension."/intercom");
$results['intercom'] = (trim($intercom) == '') ? 'enabled' : $intercom;
}
$cw = $astman->database_get("CW",$extension);
$results['callwaiting'] = (trim($cw) == 'ENABLED') ? 'enabled' : 'disabled';
$cid_masquerade=$astman->database_get("AMPUSER",$extension."/cidnum");
$results['cid_masquerade'] = (trim($cid_masquerade) != "")?$cid_masquerade:$extension;
$call_screen=$astman->database_get("AMPUSER",$extension."/screen");
$results['call_screen'] = (trim($call_screen) != "")?$call_screen:'0';
$pinless=$astman->database_get("AMPUSER",$extension."/pinless");
$results['pinless'] = (trim($pinless) == 'NOPASSWD') ? 'enabled' : 'disabled';
$results['ringtimer'] = (int) $astman->database_get("AMPUSER",$extension."/ringtimer");
$results['cfringtimer'] = (int) $astman->database_get("AMPUSER",$extension."/cfringtimer");
$results['concurrency_limit'] = (int) $astman->database_get("AMPUSER",$extension."/concurrency_limit");
$results['dialopts'] = $astman->database_get("AMPUSER",$extension."/dialopts");
$results['recording_in_external'] = strtolower($astman->database_get("AMPUSER",$extension."/recording/in/external"));
$results['recording_out_external'] = strtolower($astman->database_get("AMPUSER",$extension."/recording/out/external"));
$results['recording_in_internal'] = strtolower($astman->database_get("AMPUSER",$extension."/recording/in/internal"));
$results['recording_out_internal'] = strtolower($astman->database_get("AMPUSER",$extension."/recording/out/internal"));
$results['recording_ondemand'] = strtolower($astman->database_get("AMPUSER",$extension."/recording/ondemand"));
$results['recording_priority'] = (int) $astman->database_get("AMPUSER",$extension."/recording/priority");
$results['rvolume'] = strtolower($astman->database_get("AMPUSER",$extension."/rvolume"));
} else {
throw new \Exception("Cannot connect to Asterisk Manager with ".$this->FreePBX->Config->get("AMPMGRUSER")."/".$this->FreePBX->Config->get("AMPMGRPASS"));
}
$this->getUserCache[$extension] = $results;
return $results;
}
/**
* Get Device Details
* @param {int} $account The Device ID
*/
public function getDevice($account) {
if (!empty($this->getDeviceCache[$account])) {
return $this->getDeviceCache[$account];
}
$sql = "SELECT * FROM devices WHERE id = ?";
$sth = $this->database->prepare($sql);
try {
$sth->execute(array($account));
$device = $sth->fetch(\PDO::FETCH_ASSOC);
} catch(\Exception $e) {
return array();
}
if (empty($device)) {
return array();
}
$t = $device['tech'];
$tech = array();
if(isset($this->drivers[$t])) {
$tech = $this->drivers[$t]->getDevice($account);
}
$results = array_merge($device,$tech);
$this->getDeviceCache[$account] = $results;
return $this->getDeviceCache[$account];
}
/**
* Hook Tabs for hooking
* @param [type] $page [description]
* @return [type] [description]
*/
public function hookTabs($page){
$module_hook = \moduleHook::create();
$mods = $this->freepbx->Hooks->processHooks($page);
$sections = array();
foreach($mods as $mod => $contents) {
if(empty($contents)) {
continue;
}
if(is_array($contents)) {
foreach($contents as $content) {
if(!isset($sections[$content['rawname']])) {
$sections[$content['rawname']] = array(
"title" => $content['title'],
"rawname" => $content['rawname'],
"content" => $content['content']
);
} else {
$sections[$content['rawname']]['content'] .= $content['content'];
}
}
} else {
if(!isset($sections[$mod])) {
$sections[$mod] = array(
"title" => ucfirst(strtolower($mod)),
"rawname" => $mod,
"content" => $contents
);
} else {
$sections[$mod]['content'] .= $contents;
}
}
}
$hookTabs = $hookcontent = '';
foreach ($sections as $data) {
$hookTabs .= '<li role="presentation"><a href="#corehook'.$data['rawname'].'" aria-controls="corehook'.$data['rawname'].'" role="tab" data-toggle="tab">'.$data['title'].'</a></li>';
$hookcontent .= '<div role="tabpanel" class="tab-pane" id="corehook'.$data['rawname'].'">';
$hookcontent .= $data['content'];
$hookcontent .= '</div>';
}
return array("hookTabs" => $hookTabs, "hookContent" => $hookcontent, "oldHooks" => $module_hook->hookHtml);
}
public function bulkhandlerGetTypes() {
return array(
'extensions' => array(
'name' => _('Extensions'),
'description' => _('Extensions')
),
'dids' => array(
'name' => _('DIDs'),
'description' => _('DIDs / Inbound Routes')
)
);
}
/**
* Bulk Handler Get headers
* @param string $type The type of bulk handler
* @return array Array of headers
*/
public function bulkhandlerGetHeaders($type) {
switch ($type) {
case 'extensions':
$headers = array(
'extension' => array(
'required' => true,
'identifier' => _('Extension'),
'description' => _('Extension'),
),
'name' => array(
'identifier' => _('Name'),
'description' => _('Name'),
),
'description' => array(
'identifier' => _('Description'),
'description' => _('Description'),
),
'tech' => array(
'required' => true,
'identifier' => _('Device Technology'),
'description' => _('Device Technology'),
),
);
foreach($this->drivers as $driver) {
if (method_exists($driver, 'getDeviceHeaders')) {
$driverheaders = $driver->getDeviceHeaders();
if ($driverheaders) {
$headers = array_merge($headers, $driverheaders);
}
}
}
return $headers;
break;
case 'dids':
$headers = array(
'description' => array(
'identifier' => _('Description'),
'description' => _('Description'),
),
'extension' => array(
'identifier' => _('Incoming DID'),
'description' => _('Incoming DID')
),
'cidnum' => array(
'identifier' => _('Caller ID'),
'description' => _('Caller ID Number')
),
'destination' => array(
'identifier' => _('Destination'),
'description' => _('The context, extension, priority to go to when this DID is matched. Example: app-daynight,0,1'),
'type' => 'destination',
),
);
return $headers;
break;
}
}
/**
* Used to Validate bulk handler items
* @param string $type The bulk handler item
* @param array $rawData Array of data to import
* @return array Message containing status
*/
public function bulkhandlerValidate($type, $rawData) {
$ret = NULL;
switch ($type) {
case 'extensions':
if (true) {
$ret = array(
'status' => true,
);
} else {
$ret = array(
'status' => false,
'message' => sprintf(_('%s records failed validation'), count($rawData))
);
}
break;
}
return $ret;
}
/**
* Bulk Handler import
* @param string $type The type of import
* @param array $rawData Array of data to import
* @param boolean $replaceExisting Should we replace existing data?
* @return array Message containing status
*/
public function bulkhandlerImport($type, $rawData, $replaceExisting = true) {
$ret = NULL;
switch ($type) {
case 'extensions':
$defaulttech = \FreePBX::Sipsettings()->getSipPortOwner();
foreach ($rawData as $data) {
array_change_key_case($data, CASE_LOWER);
if (!is_numeric($data['extension'])) {
return array("status" => false, "message" => _("Extension is not numeric."));
}
if(empty($data['tech'])) {
if ($defaulttech == "none") {
$data['tech'] = 'sip';
} else {
$data['tech'] = $defaulttech;
}
}
if(empty($data['name'])) {
return array("status" => false, "message" => _("Device 'name' can not be blank."));
}
$settings = $this->generateDefaultDeviceSettings($data['tech'], $data['extension'], $data['name']);
foreach ($settings as $key => $value) {
if (isset($data[$key])) {
/* Override default setting with our value. */
if($key == "secret" && $data[$key] == "REGEN"){
continue;
}
$settings[$key]['value'] = $data[$key];
}
}
$device = $this->getDevice($data['extension']);
if($replaceExisting && !empty($device)) {
$this->delDevice($data['extension'],true);
}
$user = $this->getUser($data['extension']);
if($replaceExisting && !empty($user)) {
$this->delUser($data['extension'],true);
}
try {
if (!$this->addDevice($data['extension'], $data['tech'], $settings)) {
return array("status" => false, "message" => _("Device could not be added."));
}
} catch(\Exception $e) {
return array("status" => false, "message" => $e->getMessage());
}
$settings = $this->generateDefaultUserSettings($data['extension'], $data['name']);
foreach ($settings as $key => $value) {
if (isset($data[$key])) {
/* Override default setting with our value. */
// if concurrency_limit is "" dont override
if ($key == 'concurrency_limit') {
if ($data[$key] != "") {// there is some valid value
$settings[$key] = $data[$key];
} else { // unsetting.. So while adding it will set default value
unset($settings[$key]);
}
} else {
$settings[$key] = $data[$key];
}
}
}
try {
if (!$this->addUser($data['extension'], $settings)) {
//cleanup
$this->delDevice($data['extension'], $replaceExisting);
return array("status" => false, "message" => _("User could not be added."));
}
} catch(\Exception $e) {
//cleanup
$this->delDevice($data['extension'], $replaceExisting);
return array("status" => false, "message" => $e->getMessage());
}
}
needreload();
$ret = array(
'status' => true,
);
break;
case "dids":
foreach ($rawData as $data) {
$exists = $this->getDID($data['extension'], $data['cidnum']);
if(!$replaceExisting && !empty($exists)) {
return array("status" => false, "message" => _("DID already exists"));
} elseif($replaceExisting && !empty($exists)) {
$this->delDID($data['extension'], $data['cidnum']);
}
$this->addDID($data);
}
needreload();
$ret = array(
'status' => true,
);
break;
}
return $ret;
}
/**
* Bulk Handler Export hook
* @param string $type The type of bulk handling
* @return array Array of data
*/
public function bulkhandlerExport($type) {
$data = NULL;
switch ($type) {
case 'extensions':
$users = $this->getAllUsersByDeviceType();
foreach ($users as $user) {
$device = $this->getDevice($user['extension']);
if (isset($device['secret_origional'])) {
/* Don't expose our typo laden craziness to users. We like our users! */
unset($device['secret_origional']);
}
if (isset($device['vm'])) {
/* This value doesnt make sense since we control vm externally through voicemail */
unset($device['vm']);
}
$du = $this->freepbx->Config->get("AMPEXTENSIONS");
if($du != "deviceanduser") {
unset($device['password']);
unset($device['devicetype']);
unset($device['user']);
unset($device['id']);
unset($device['name']);
unset($device['account']);
}
$tmp_user_data = $this->getUser($user['extension']);
if(isset($tmp_user_data['cid_masquerade'])) {
$user['cid_masquerade'] = $tmp_user_data['cid_masquerade'];
}
if(isset($tmp_user_data['concurrency_limit'])) {
$user['concurrency_limit'] = $tmp_user_data['concurrency_limit'];;
}
$data[$user['extension']] = array_merge($user, $device);
}
break;
case 'dids':
$dids = $this->getAllDIDs();
$data = array();
foreach($dids as $did) {
$key = $did['extension']."/".$did["cidnum"];
$data[$key] = $did;
}
break;
}
return $data;
}
/**
* Set Outbound Routes Order
*/
public function setRouteOrder($routes){
$dbh = $this->database();
$stmt = $dbh->prepare('DELETE FROM `outbound_route_sequence` WHERE 1');
$stmt->execute();
$stmt = $dbh->prepare('INSERT INTO outbound_route_sequence (route_id, seq) VALUES (?,?)');
$ret = array();
foreach ($routes as $key => $value) {
$seq = ($key+1);
$ret[] = $stmt->execute(array($value,$seq));
}
needreload();
return $ret;
}
/**
* List Admin Users
* @param string $datatype The type of data to return
* @return array Return Array
*/
public function listAMPUsers($datatype = ''){
$sql = "SELECT username FROM ampusers ORDER BY username";
$stmt = $this->database->prepare($sql);
$stmt->execute();
switch ($datatype) {
case 'assoc':
return $stmt->fetchall(\PDO::FETCH_ASSOC);
break;
default:
return $stmt->fetchall(\PDO::FETCH_BOTH);
break;
}
}
/**
* Add Admin User
* @param string $username The username
* @param string $password The password
* @param integer $extension_low The lowest extension
* @param integer $extension_high The highest extension
* @param string $deptname The department name
* @param array $sections Sections to allow
*/
public function addAMPUser($username, $password, $extension_low, $extension_high, $deptname, $sections){
if (strlen($password) == 40 && ctype_xdigit($password)) {
$password_sha1 = $password;
}else {
$password_sha1 = sha1($password);
}
$sections = implode(";",$sections);
$vars = array(
':username' => $username,
':password_sha1' => $password_sha1,
':extension_low' => $extension_low,
':extension_high' => $extension_high,
':deptname' => $deptname,
':sections' => $sections,
);
$sql = "INSERT INTO ampusers (username, password_sha1, extension_low, extension_high, deptname, sections) VALUES (:username,
:password_sha1,
:extension_low,
:extension_high,
:deptname,
:sections)";
$stmt = $this->database->prepare($sql);
try{
$stmt->execute($vars);
return true;
}catch(\PDOException $e){
//data colission
if($e->getCode() == '23000'){
return false;
}else{
echo $e->getMessage();
throw $e;
}
}
}
/**
* List Trunk Types
* @return array Array of Trunk Types
*/
public function listTrunkTypes(){
$sipdriver = \FreePBX::create()->Config->get_conf_setting('ASTSIPDRIVER');
$default_trunk_types = array(
"DAHDI" => 'DAHDi',
"IAX2" => 'IAX2',
"ENUM" => 'ENUM',
"DUNDI" => 'DUNDi',
"CUSTOM" => 'Custom'
);
$sip = ($sipdriver == 'both' || $sipdriver == 'chan_sip') ? array("SIP" => sprintf(_('SIP (%s)'),'chan_sip')) : array();
$pjsip = ($sipdriver == 'both' || $sipdriver == 'chan_pjsip') ? array("PJSIP" => sprintf(_('SIP (%s)'),'chan_pjsip')) : array();
$trunk_types = $pjsip+$sip+$default_trunk_types;
// Added to enable the unsupported misdn module
if (function_exists('misdn_ports_list_trunks') && count(misdn_ports_list_trunks())) {
$trunk_types['MISDN'] = 'mISDN';
}
return $trunk_types;
}
/**
* Search query for global search
* @param string $query The query
* @param array $results Results
*/
public function search($query, &$results) {
if($this->freepbx->Config->get('AMPEXTENSIONS') == "extensions") {
$sql = "SELECT * FROM devices WHERE id LIKE ? or description LIKE ?";
$sth = $this->database->prepare($sql);
$sth->execute(array("%".$query."%","%".$query."%"));
$rows = $sth->fetchAll(\PDO::FETCH_ASSOC);
foreach($rows as $row) {
if(ctype_digit($query)) {
$results[] = array("text" => _("Extension")." ".$row['id'], "type" => "get", "dest" => "?display=extensions&extdisplay=".$row['id']);
} else {
$results[] = array("text" => $row['description']." (".$row['id'].")", "type" => "get", "dest" => "?display=extensions&extdisplay=".$row['id']);
}
}
} else {
$sql = "SELECT * FROM devices WHERE id LIKE ? or description LIKE ?";
$sth = $this->database->prepare($sql);
$sth->execute(array("%".$query."%","%".$query."%"));
$rows = $sth->fetchAll(\PDO::FETCH_ASSOC);
foreach($rows as $row) {
if(ctype_digit($query)) {
$results[] = array("text" => _("Device")." ".$row['id'], "type" => "get", "dest" => "?display=extensions&extdisplay=".$row['id']);
} else {
$results[] = array("text" => $row['description']." (".$row['id'].")", "type" => "get", "dest" => "?display=extensions&extdisplay=".$row['id']);
}
}
$sql = "SELECT * FROM users WHERE extension LIKE ? or name LIKE ?";
$sth = $this->database->prepare($sql);
$sth->execute(array("%".$query."%","%".$query."%"));
$rows = $sth->fetchAll(\PDO::FETCH_ASSOC);
foreach($rows as $row) {
if(ctype_digit($query)) {
$results[] = array("text" => _("User")." ".$row['extension'], "type" => "get", "dest" => "?display=extensions&extdisplay=".$row['extension']);
} else {
$results[] = array("text" => $row['name']." (".$row['extension'].")", "type" => "get", "dest" => "?display=extensions&extdisplay=".$row['extension']);
}
}
}
if(!ctype_digit($query)) {
$sql = "SELECT * FROM outbound_routes WHERE name LIKE ?";
$sth = $this->database->prepare($sql);
$sth->execute(array("%".$query."%"));
$rows = $sth->fetchAll(\PDO::FETCH_ASSOC);
foreach($rows as $row) {
$results[] = array("text" => _("Outbound Route:")." ".$row['name'], "type" => "get", "dest" => "?display=routing&view=form&id=".$row['route_id']);
}
$sql = "SELECT * FROM trunks WHERE name LIKE ?";
$sth = $this->database->prepare($sql);
$sth->execute(array("%".$query."%"));
$rows = $sth->fetchAll(\PDO::FETCH_ASSOC);
foreach($rows as $row) {
$results[] = array("text" => _("Trunk:")." ".$row['name'], "type" => "get", "dest" => "?display=trunks&tech=".$row['tech']."&extdisplay=OUT_".$row['trunkid']);
}
$sql = "SELECT * FROM incoming WHERE description LIKE ?";
$sth = $this->database->prepare($sql);
$sth->execute(array("%".$query."%"));
$rows = $sth->fetchAll(\PDO::FETCH_ASSOC);
foreach($rows as $row) {
$display = urlencode($row['extension']."/".$row['cidnum']);
$results[] = array("text" => _("Inbound Route:")." ".$row['description'], "type" => "get", "dest" => "?display=did&view=form&extdisplay=".$display);
}
} else {
$sql = "SELECT * FROM incoming WHERE cidnum LIKE :search OR extension LIKE :search";
$sth = $this->database->prepare($sql);
$sth->execute(array("search" => "%".$query."%"));
$rows = $sth->fetchAll(\PDO::FETCH_ASSOC);
foreach($rows as $row) {
$display = urlencode($row['extension']."/".$row['cidnum']);
$results[] = array("text" => _("Inbound Route:")." ".$row['extension']."/".$row['cidnum'], "type" => "get", "dest" => "?display=did&view=form&extdisplay=".$display);
}
}
}
/**
* Disable Trunk
* @method disableTrunk
* @param string $id The trunk ID
* @return boolean Result of execute
*/
public function disableTrunk($id){
$tech = $this->getTrunkTech($id);
if(!$tech){
return false;
}
$sql = "UPDATE trunks set disabled = 'on' WHERE trunkid = ?";
$ob = $this->database->prepare($sql);
return $ob->execute(array($id));
}
/**
* Enable Trunk
* @method enableTrunk
* @param string $id The trunk ID
* @return boolean Result of execute
*/
public function enableTrunk($id){
$sql = "UPDATE trunks set disabled = 'off' WHERE trunkid = ?";
$ob = $this->database->prepare($sql);
return $ob->execute(array($id));
}
/**
* Get Trunk Tech
* @method getTrunkTech
* @param string $trunknum The trunk id
* @return string The trunk tech
*/
public function getTrunkTech($trunknum) {
$sql = "SELECT tech FROM trunks WHERE trunkid = ?";
$ob = $this->database->prepare($sql);
$ob->execute(array($trunknum));
$tech = $ob->fetchColumn();
if (!$tech) {
return false;
}
$tech = strtolower($tech);
if ($tech == "iax2") {
$tech = "iax"; // same thing, here
}
return $tech;
}
}
此处可能存在不合适展示的内容，页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容，可点击提交进行申诉，我们将尽快为您处理。
马建仓 AI 助手
