kenmirrors/freeswitch
1
0
Fork 0
mirror of https://github.com/signalwire/freeswitch.git synced 2025-03-14 04:54:49 +00:00
Code Issues Projects Releases Wiki Activity

Merge 6726c3aa0d2487b162d0288a0df34d1632100f82 into 675bd8f27d7ef201673f21c4ae6dd6fef73383b4

Browse Source
This commit is contained in:
Marc Olivier Chouinard 2025-03-10 20:39:23 +00:00 committed by GitHub
commit 4c5ca848b3
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 70 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

76
src/mod/applications/mod_callcenter/mod_callcenter.c
View File

@ -53,6 +53,7 @@ SWITCH_MODULE_DEFINITION(mod_callcenter, mod_callcenter_load, mod_callcenter_shu
static switch_status_t load_agent(const char *agent_name, switch_event_t *params, switch_xml_t x_agents_cfg);
static switch_status_t load_tiers(switch_bool_t load_all, const char *queue_name, const char *agent_name, switch_event_t *params, switch_xml_t x_tiers_cfg);
static const char *global_cf = "callcenter.conf";
struct cc_status_table {
@ -259,6 +260,8 @@ static char tiers_sql[] =
" level INTEGER NOT NULL DEFAULT 1,\n"
" position INTEGER NOT NULL DEFAULT 1\n" ");\n";
cc_status_t cc_agent_get(const char *key, const char *agent, char *ret_result, size_t ret_result_size);
static switch_xml_config_int_options_t config_int_0_86400 = { SWITCH_TRUE, 0, SWITCH_TRUE, 86400 };
/* TODO This is temporary until we either move it to the core, or use it differently in the module */
@ -929,16 +932,74 @@ done:
cc_status_t cc_agent_del(const char *agent)
{
cc_status_t result = CC_STATUS_SUCCESS;
switch_event_t *event;
cc_status_t result = CC_STATUS_FALSE;
char *sql;
int deleted_row_count;
char ret[64];
cc_status_t res;
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Deleted Agent %s\n", agent);
sql = switch_mprintf("DELETE FROM agents WHERE name = '%q';"
"DELETE FROM tiers WHERE agent = '%q';",
agent, agent);
cc_execute_sql(NULL, sql, NULL);
/* Check to see if agent exist and if status is Logged Out */
switch (res = cc_agent_get("status", agent, ret, sizeof(ret))) {
case CC_STATUS_SUCCESS:
if (strcasecmp(cc_agent_status2str(CC_AGENT_STATUS_LOGGED_OUT), ret)) {
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Agent %s status [%s] is not Waiting, cannot be deleted\n", ret, agent);
result = CC_STATUS_AGENT_INVALID_STATUS;
goto done;
}
break;
case CC_STATUS_AGENT_NOT_FOUND:
result = CC_STATUS_AGENT_NOT_FOUND;
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Agent %s doesn't exist, cannot be deleted\n", agent);
goto done;
default:
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Unknown error code occur %d\n", (int)res);
goto done;
}
/* Check to see if agent state is Waiting */
switch (res = cc_agent_get("state", agent, ret, sizeof(ret))) {
case CC_STATUS_SUCCESS:
if (strcasecmp(cc_agent_status2str(CC_AGENT_STATE_WAITING), ret)) {
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Agent %s state [%s] is not Waiting, cannot be deleted\n", ret, agent);
result = CC_STATUS_AGENT_INVALID_STATE;
goto done;
}
break;
case CC_STATUS_AGENT_NOT_FOUND:
result = CC_STATUS_AGENT_NOT_FOUND;
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Agent %s doesn't exist, cannot be deleted\n", agent);
goto done;
default:
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Unknown error code occur %d\n", (int)res);
goto done;
}
sql = switch_mprintf("DELETE FROM agents WHERE name = '%q' AND status = '%s' AND state = '%s';", agent, cc_agent_status2str(CC_AGENT_STATUS_LOGGED_OUT), cc_agent_status2str(CC_AGENT_STATE_WAITING));
deleted_row_count = cc_execute_sql_affected_rows(sql);
switch_safe_free(sql);
if (deleted_row_count > 0) {
sql = switch_mprintf("DELETE FROM tiers WHERE agent = '%q';", agent);
cc_execute_sql(NULL, sql, NULL);
switch_safe_free(sql);
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Deleted Agent %s and associated tiers\n", agent);
if (switch_event_create_subclass(&event, SWITCH_EVENT_CUSTOM, CALLCENTER_EVENT) == SWITCH_STATUS_SUCCESS) {
switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "CC-Agent", agent);
switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "CC-Action", "agent-del");
switch_event_fire(&event);
}
result = CC_STATUS_SUCCESS;
} else {
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Agent %s status or state changed, cannot be deleted\n", agent);
result = CC_STATUS_AGENT_NOT_FOUND;
}
done:
return result;
}
@ -3603,6 +3664,9 @@ SWITCH_STANDARD_API(cc_config_api_function)
case CC_STATUS_SUCCESS:
stream->write_function(stream, "%s", "+OK\n");
break;
case CC_STATUS_AGENT_NOT_FOUND:
stream->write_function(stream, "%s", "-ERR Agent not found!\n");
goto done;
default:
stream->write_function(stream, "%s", "-ERR Unknown Error!\n");
goto done;