freeswitch xml_curl模块使用

<?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