<?php
/**
* @package FS_CURL
* @subpackage FS_CURL_Directory
* fs_directory.php
*/
if (basename ( $_SERVER ['PHP_SELF'] ) == basename ( __FILE__ )) {
header ( 'Location: index.php' );
}
/**
* @package FS_CURL
* @subpackage FS_CURL_Directory
* @author Raymond Chandler (intralanman) <intralanman@gmail.com>
* @license BSD
* @version 0.1
* Class for XML directory
*/
class fs_directory extends fs_curl {
private $user;
private $userid;
private $users_vars;
private $users_params;
private $users_gateways;
private $users_gateway_params;
public function fs_directory() {
$this->fs_curl ();
if (array_key_exists ( 'user', $this->request )) {
$this->user = $this->request ['user'];
}
$this->comment ( "User is " . $this->user );
}
public function main() {
$this->comment ( $this->request );
if (array_key_exists ( 'VM-Action', $this->request ) && $this->request ['VM-Action'] == 'change-password') {
$this->update_pin ( $this->request ['VM-User'], $this->request ['VM-User-Password'] );
} else {
if (array_key_exists ( 'domain', $this->request )) {
$domains = $this->get_domains ( $this->request ['domain'] );
} else {
$domains = $this->get_domains ();
}
$this->get_user_gateway_params ();
$this->xmlw->startElement ( 'section' );
$this->xmlw->writeAttribute ( 'name', 'directory' );
$this->xmlw->writeAttribute ( 'description', 'FreeSWITCH Directory' );
foreach ( $domains as $domain ) {
$directory_array = $this->get_directory ( $domain );
$this->writedirectory ( $directory_array, $domain );
}
$this->xmlw->endElement (); // </section>
$this->output_xml ();
}
}
private function update_pin($username, $new_pin) {
$this->debug ( "update pin for $username to $new_pin" );
$and = '';
if (array_key_exists ( 'domain', $this->request )) {
$and = sprintf ( 'AND %1$sdomain%1$s = \'%2$s\')', DB_FIELD_QUOTE, $this->request ['domain'] );
}
$query = sprintf ( 'UPDATE %1$sdirectory_params%1$s
SET %1$sparam_value%1$s = \'%2$s\'
WHERE %1$sparam_name%1$s = \'vm-password\'
AND %1$sdirectory_id%1$s =
(SELECT %1$sid%1$s
FROM %1$sdirectory%1$s
WHERE %1$susername%1$s = \'%3$s\' %4$s', DB_FIELD_QUOTE, $new_pin, $username, $and );
$this->debug ( $query );
$this->db->exec ( $query );
$this->debug ( $this->db->errorInfo () );
}
/**
* This method will pull directory from database
* @return array
* @todo add GROUP BY to query to make sure we don't get duplicate users
*/
private function get_directory($domain) {
$directory_array = array ();
$join_clause = '';
$where_array [] = sprintf ( "domain_id='%s'", $domain ['id'] );
if (array_key_exists ( 'user', $this->request )) {
$where_array [] = sprintf ( "username='%s'", $this->user );
}
if (array_key_exists ( 'group', $this->request )) {
$where_array [] = sprintf ( "group_name='%s'", $this->request ['group'] );
$join_clause = "JOIN directory_group_user_map dgum ON d.id=dgum.user_id ";
$join_clause .= "JOIN directory_groups dg ON dgum.group_id=dg.group_id ";
}
if (! empty ( $where_array )) {
if (count ( $where_array ) > 1) {
$where_clause = sprintf ( 'WHERE %s', implode ( ' AND ', $where_array ) );
} else {
$where_clause = sprintf ( 'WHERE %s', $where_array [0] );
}
} else {
$where_clause = '';
}
$query = sprintf ( "SELECT * FROM directory d %s %s ORDER BY username", $join_clause, $where_clause );
$this->debug ( $query );
$res = $this->db->queryAll ( $query );
if (FS_PDO::isError ( $res )) {
$this->comment ( $query );
$this->comment ( $this->db->getMessage () );
$this->comment ( $this->db->getMessage () );
$this->file_not_found ();
}
if (! empty ( $this->user )) {
$this->userid = $res [0] ['id'];
$this->comment ( sprintf ( 'user id is: %d', $this->userid ) );
}
return $res;
}
/**
* This method will pull the params for every user in a domain
* @return array of users' params
*/
private function get_users_params() {
$where = '';
if (! empty ( $this->userid )) {
$where = sprintf ( 'WHERE directory_id = %d', $this->userid );
}
$query = sprintf ( "SELECT * FROM directory_params %s;", $where );
$res = $this->db->queryAll ( $query );
if (FS_PDO::isError ( $res )) {
$this->comment ( $query );
$this->comment ( $this->db->getMessage () );
$this->file_not_found ();
}
$record_count = count ( $res );
for($i = 0; $i < $record_count; $i ++) {
$di = $res [$i] ['directory_id'];
$pn = $res [$i] ['param_name'];
$this->users_params [$di] [$pn] = $res [$i] ['param_value'];
}
}
/**
* Writes XML for directory user's <params>
* This method will pull all of the user params based on the passed user_id
* @param integer $user_id
* @return void
*/
private function write_params($user_id) {
if (! is_array ( $this->users_params )) {
return;
}
if (array_key_exists ( $user_id, $this->users_params ) && is_array ( $this->users_params [$user_id] ) && count ( $this->users_params [$user_id] ) > 0) {
$this->xmlw->startElement ( 'params' );
foreach ( $this->users_params [$user_id] as $pname => $pvalue ) {
$this->xmlw->startElement ( 'param' );
$this->xmlw->writeAttribute ( 'name', $pname );
$this->xmlw->writeAttribute ( 'value', $pvalue );
$this->xmlw->endElement ();
}
$this->xmlw->endElement ();
}
}
/**
* Get all the users' variables
*/
private function get_users_vars() {
$where = '';
if (! empty ( $this->userid )) {
$where = sprintf ( 'WHERE directory_id = %d', $this->userid );
}
$query = sprintf ( "SELECT * FROM directory_vars %s;", $where );
$this->debug ( $query );
$res = $this->db->queryAll ( $query );
if (FS_PDO::isError ( $res )) {
$this->comment ( $this->db->getMessage () );
$this->file_not_found ();
}
$record_count = count ( $res );
for($i = 0; $i < $record_count; $i ++) {
$di = $res [$i] ['directory_id'];
$vn = $res [$i] ['var_name'];
$this->users_vars [$di] [$vn] = $res [$i] ['var_value'];
}
}
/**
* Write all the <variables> for a given user
*
* @param integer $user_id
* @return void
*/
private function write_variables($user_id) {
if (! is_array ( $this->users_vars )) {
return;
}
if (array_key_exists ( $user_id, $this->users_vars ) && is_array ( $this->users_vars [$user_id] )) {
$this->xmlw->startElement ( 'variables' );
foreach ( $this->users_vars [$user_id] as $vname => $vvalue ) {
$this->xmlw->startElement ( 'variable' );
$this->xmlw->writeAttribute ( 'name', $vname );
$this->xmlw->writeAttribute ( 'value', $vvalue );
$this->xmlw->endElement ();
}
$this->xmlw->endElement ();
}
}
/**
* get the users' gateways
*/
private function get_users_gateways() {
$where = '';
if (! empty ( $this->userid )) {
$where = sprintf ( 'WHERE directory_id = %d', $this->userid );
}
$query = sprintf ( "SELECT * FROM directory_gateways %s;", $where );
$this->debug ( $query );
$res = $this->db->queryAll ( $query );
if (FS_PDO::isError ( $res )) {
$this->comment ( $this->db->getMessage () );
$this->file_not_found ();
}
$record_count = count ( $res );
for($i = 0; $i < $record_count; $i ++) {
$di = $res [$i] ['directory_id'];
$this->users_gateways [$di] [] = $res [$i];
}
}
/**
* Write all of the XML for the user's <gateways>
* This method takes the id of the user from the directory table and pulls
* all of the user's gateways. It then calls write_single_gateway for
* each of them to write out all of the params
* @param integer $user_id
* @return void
*/
private function write_gateways($user_id) {
if (is_array ( $this->users_gateways ) && array_key_exists ( $user_id, $this->users_gateways ) && is_array ( $this->users_gatewa
fs_mod_curl_php.zip （27个子文件） 
fs_mod_curl_php 
fs_pdo.php 3KB index.php 3KB fs_dialplan.php 9KB fs_chatplan.php 7KB global_defines.php 2KB fs_directory.php 13KB dialplans lcr.php 3KB fs_configuration.php 3KB fs_cdr.php 3KB configuration console.conf.php 2KB post_load_modules.conf.php 2KB lcr.conf.php 3KB ivr.conf.php 4KB voicemail.conf.php 4KB acl.conf.php 3KB conference.conf.php 6KB dialplan_importer.php 7KB rss.conf.php 2KB spidermonkey.conf.php 1KB local_stream.conf.php 2KB xml_cdr.conf.php 1KB sofia.conf.php 7KB easyroute.conf.php 2KB dingaling.conf.php 4KB iax.conf.php 6KB limit.conf.php 2KB fs_curl.php 12KB资源评论
Lv_19969212021-01-28你好都是php源码 请问下具体是怎么实现的
