freeswitch支持电话拨入，可以接入远端IPPBX实现和现网电话的互通。

有时候我们需要统计记录所有的电话详单，并输出到指定的数据库用于数据统计。

包括呼叫方，被叫方，呼叫时间，接听时间，挂断时间，通话时长，会话等等信息。

于是，这部分可以自己写一个freeswitch插件来完成上述功能。

自己动手即可。

诀窍很简单，只要知道几个关键API即可。

首先创建一个插件。

SWITCH_MODULE_LOAD_FUNCTION(mod_cdr_mysql_load)

{

switch_status_t status = SWITCH_STATUS_SUCCESS;

load_config(pool);

if ((status = switch_dir_make_recursive(globals.log_dir, SWITCH_DEFAULT_DIR_PERMS, pool)) != SWITCH_STATUS_SUCCESS) {

switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Error creating %s\n", globals.log_dir);

}

switch_core_add_state_handler(&state_handlers);

*module_interface = switch_loadable_module_create_module_interface(pool, modname);

return status;

}

SWITCH_MODULE_SHUTDOWN_FUNCTION(mod_cdr_mysql_shutdown)

{

globals.shutdown = 1;

switch_mutex_lock(globals.db_mutex);

if(globals.db_connection) {

mysql_close(globals.db_connection);

}

switch_mutex_unlock(globals.db_mutex);

switch_mutex_destroy(globals.db_mutex);

switch_core_remove_state_handler(&state_handlers);

return SWITCH_STATUS_SUCCESS;

}

这里基本都是固定的写法。

这里有一个要注意自己实现的函数，就是load_config(pool);

在这个函数中，你可以实现对XML配置文件的读取，比如，对mysql的连接信息相关读取。

此后，实现一个函数来处理电话结束后的详单生成。

这里有一个核心函数

switch_core_add_state_handler(&state_handlers);

这里是告诉freesweitch，我要关心你的那些状态。并回调绑定对应的函数。

state_handlers包括了如下状态(各个freeswitch版本不同可能有些差异)

static switch_state_handler_table_t state_handlers = {

/*.on_init */ NULL,

/*.on_routing */ NULL,

/*.on_execute */ NULL,

/*.on_hangup */ NULL,

/*.on_exchange_media */ NULL,

/*.on_soft_execute */ NULL,

/*.on_consume_media */ NULL,

/*.on_hibernate */ NULL,

/*.on_reset */ NULL,

/*.on_park */ NULL,

/*.on_reporting */ on_reporting

};

上述代码，我只关心on_reporting 状态。

剩下的状态，请自行谷歌。

下一步，我们要绑定事件产生后的处理函数了。怎么做呢？看见上面的on_reporting没，这就是你的函数指针的名字。

于是就直接写下如下代码即可。

static switch_status_t on_reporting(switch_core_session_t *session)

{

switch_channel_t *channel = switch_core_session_get_channel(session);

switch_status_t status = SWITCH_STATUS_SUCCESS;

const char *template_str = NULL;

char *expanded_vars = NULL, *sql = NULL;

char *answer_vars = NULL;

char *user_vars = NULL;

if (globals.shutdown) {

return SWITCH_STATUS_SUCCESS;

}

{

const char * channel_name = NULL;

const char * filter = "loopback/";

if ((channel_name = switch_channel_get_variable(channel, "channel_name"))) {

if(!strncasecmp(channel_name,filter, sizeof(filter))){

return SWITCH_STATUS_SUCCESS;

}

}

}

if(check_cdr_direction(session) != SWITCH_STATUS_SUCCESS ){

if (!((globals.legs & CDR_LEG_A) && (globals.legs & CDR_LEG_B))) {

if ((globals.legs & CDR_LEG_A)) {

if (switch_channel_get_originator_caller_profile(channel)) {

return SWITCH_STATUS_SUCCESS;

}

} else {

if (switch_channel_get_originatee_caller_profile(channel)) {

return SWITCH_STATUS_SUCCESS;

}

}

}

}

if (!((globals.legs & CDR_LEG_A) && (globals.legs & CDR_LEG_B))) {

if ((globals.legs & CDR_LEG_A)) {

if (switch_channel_get_originator_caller_profile(channel)) {

return SWITCH_STATUS_SUCCESS;

}

} else {

if (switch_channel_get_originatee_caller_profile(channel)) {

return SWITCH_STATUS_SUCCESS;

}

}

}

if (globals.debug) {

switch_event_t *event;

if (switch_event_create_plain(&event, SWITCH_EVENT_CHANNEL_DATA) == SWITCH_STATUS_SUCCESS) {

char *buf;

switch_channel_event_set_data(channel, event);

switch_event_serialize(event, &buf, SWITCH_FALSE);

switch_assert(buf);

switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "CHANNEL_DATA:\n%s\n", buf);

switch_event_destroy(&event);

switch_safe_free(buf);

}

}

template_str = (const char *) switch_core_hash_find(globals.template_hash, globals.default_template);

if (!template_str) {

template_str = default_template;

}

//switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "[my_on_reporting]template_str=%s.\n", template_str);expanded_vars = switch_channel_expand_variables(channel, template_str);

}

这里的大部分代码是固定的，直接照抄就可以。

这里强调两个API是你必须要会用的。

(1) switch_core_hash_find

这个函数是，根据你的配置模板，加载指定的配置项目。

简单来说，freeswitch支持什么参数呢？

例如：

const char *default_template =

"\"${caller_id_name}\",\"${caller_id_number}\",\"${destination_number}\",\"${context}\","

"\"${start_stamp}\",\"${answer_stamp}\",\"${end_stamp}\",${duration},${billsec},"

"\"${hangup_cause}\",\"${uuid}\",\"${accountcode}\"";

这些参数名都是固定的。你可以从话单中获得这些参数的值。

你可以任意缩减或者增加这些参数名，已达到话单要求的目的。

(2)switch_channel_expand_variables

根据参数名找到对应的数值。

返回值是一个静态的const char* 这个对应你上面给出的参数名。

剩下的就是拼装sql入库的代码了，这部分，就不许赘述了。

以上，你就可以得到完整的freeswitch中的话单信息并入库。