kenmirrors/freeswitch
1
0
Fork 0
mirror of https://github.com/signalwire/freeswitch.git synced 2025-07-15 11:29:56 +00:00
Code Issues Projects Releases Wiki Activity

FS-9248 [mod_callcenter] Adding truncate-tiers-on-load and truncate-agents-on-load options.

Browse Source
This commit is contained in:
Italo Rossi 2016-06-09 16:53:21 -03:00
parent e7758cb724
commit 0f3204feb3
1 changed files with 21 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -417,6 +417,8 @@ static struct {
char *odbc_dsn; char *odbc_dsn;
char *dbname; char *dbname;
switch_bool_t reserve_agents; switch_bool_t reserve_agents;
switch_bool_t truncate_tiers;
switch_bool_t truncate_agents;
int32_t threads; int32_t threads;
int32_t running; int32_t running;
switch_mutex_t *mutex; switch_mutex_t *mutex;
@ -1428,8 +1430,12 @@ static switch_status_t load_config(void)
globals.dbname = strdup(val); globals.dbname = strdup(val);
} else if (!strcasecmp(var, "odbc-dsn")) { } else if (!strcasecmp(var, "odbc-dsn")) {
globals.odbc_dsn = strdup(val); globals.odbc_dsn = strdup(val);
} else if(!strcasecmp(var, "reserve-agents")) { } else if (!strcasecmp(var, "reserve-agents")) {
globals.reserve_agents = switch_true(val); globals.reserve_agents = switch_true(val);
} else if (!strcasecmp(var, "truncate-tiers-on-load")) {
globals.truncate_tiers = switch_true(val);
} else if (!strcasecmp(var, "truncate-agents-on-load")) {
globals.truncate_agents = switch_true(val);
} }
} }
} }
@ -1465,6 +1471,20 @@ static switch_status_t load_config(void)
cc_execute_sql(NULL, sql, NULL); cc_execute_sql(NULL, sql, NULL);
switch_safe_free(sql); switch_safe_free(sql);
/* Truncating tiers if needed */
if (globals.truncate_tiers) {
sql = switch_mprintf("delete from tiers;");
cc_execute_sql(NULL, sql, NULL);
switch_safe_free(sql);
}
/* Truncating agents if needed */
if (globals.truncate_agents) {
sql = switch_mprintf("delete from agents;");
cc_execute_sql(NULL, sql, NULL);
switch_safe_free(sql);
}
/* Loading queue into memory struct */ /* Loading queue into memory struct */
if ((x_queues = switch_xml_child(cfg, "queues"))) { if ((x_queues = switch_xml_child(cfg, "queues"))) {
for (x_queue = switch_xml_child(x_queues, "queue"); x_queue; x_queue = x_queue->next) { for (x_queue = switch_xml_child(x_queues, "queue"); x_queue; x_queue = x_queue->next) {