mirror of
https://github.com/asterisk/asterisk.git
synced 2025-10-24 05:38:11 +00:00
Send a manager AgentComplete event when the agent transfers the call, in
addition to where it is already sent if either side hangs up. (issue #9219, rgollent) In passing, I put this code in a function so it would not be duplicated a third time. git-svn-id: https://origsvn.digium.com/svn/asterisk/trunk@58123 65c4cc65-6c06-0410-ace0-fbb531ad65f3
This commit is contained in:
@@ -2330,6 +2330,48 @@ static int calc_metric(struct call_queue *q, struct member *mem, int pos, struct
|
|||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
enum agent_complete_reason {
|
||||||
|
CALLER,
|
||||||
|
AGENT,
|
||||||
|
TRANSFER
|
||||||
|
};
|
||||||
|
|
||||||
|
static void send_agent_complete(const struct queue_ent *qe, const char *queuename,
|
||||||
|
const struct ast_channel *peer, const struct member *member, time_t callstart,
|
||||||
|
char *vars, size_t vars_len, enum agent_complete_reason rsn)
|
||||||
|
{
|
||||||
|
const char *reason;
|
||||||
|
|
||||||
|
if (!qe->parent->eventwhencalled)
|
||||||
|
return;
|
||||||
|
|
||||||
|
switch (rsn) {
|
||||||
|
case CALLER:
|
||||||
|
reason = "caller";
|
||||||
|
break;
|
||||||
|
case AGENT:
|
||||||
|
reason = "agent";
|
||||||
|
break;
|
||||||
|
case TRANSFER:
|
||||||
|
reason = "transfer";
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
|
||||||
|
manager_event(EVENT_FLAG_AGENT, "AgentComplete",
|
||||||
|
"Queue: %s\r\n"
|
||||||
|
"Uniqueid: %s\r\n"
|
||||||
|
"Channel: %s\r\n"
|
||||||
|
"Member: %s\r\n"
|
||||||
|
"MemberName: %s\r\n"
|
||||||
|
"HoldTime: %ld\r\n"
|
||||||
|
"TalkTime: %ld\r\n"
|
||||||
|
"Reason: %s\r\n"
|
||||||
|
"%s",
|
||||||
|
queuename, qe->chan->uniqueid, peer->name, member->interface, member->membername,
|
||||||
|
(long)(callstart - qe->start), (long)(time(NULL) - callstart), reason,
|
||||||
|
qe->parent->eventwhencalled == QUEUE_EVENT_VARIABLES ? vars2manager(qe->chan, vars, vars_len) : "");
|
||||||
|
}
|
||||||
|
|
||||||
static int try_calling(struct queue_ent *qe, const char *options, char *announceoverride, const char *url, int *go_on, const char *agi, const char *macro)
|
static int try_calling(struct queue_ent *qe, const char *options, char *announceoverride, const char *url, int *go_on, const char *agi, const char *macro)
|
||||||
{
|
{
|
||||||
struct member *cur;
|
struct member *cur;
|
||||||
@@ -2741,39 +2783,15 @@ static int try_calling(struct queue_ent *qe, const char *options, char *announce
|
|||||||
ast_queue_log(queuename, qe->chan->uniqueid, member->membername, "TRANSFER", "%s|%s|%ld|%ld",
|
ast_queue_log(queuename, qe->chan->uniqueid, member->membername, "TRANSFER", "%s|%s|%ld|%ld",
|
||||||
qe->chan->exten, qe->chan->context, (long) (callstart - qe->start),
|
qe->chan->exten, qe->chan->context, (long) (callstart - qe->start),
|
||||||
(long) (time(NULL) - callstart));
|
(long) (time(NULL) - callstart));
|
||||||
|
send_agent_complete(qe, queuename, peer, member, callstart, vars, sizeof(vars), TRANSFER);
|
||||||
} else if (qe->chan->_softhangup) {
|
} else if (qe->chan->_softhangup) {
|
||||||
ast_queue_log(queuename, qe->chan->uniqueid, peer->name, "COMPLETECALLER", "%ld|%ld|%d",
|
ast_queue_log(queuename, qe->chan->uniqueid, peer->name, "COMPLETECALLER", "%ld|%ld|%d",
|
||||||
(long) (callstart - qe->start), (long) (time(NULL) - callstart), qe->opos);
|
(long) (callstart - qe->start), (long) (time(NULL) - callstart), qe->opos);
|
||||||
if (qe->parent->eventwhencalled)
|
send_agent_complete(qe, queuename, peer, member, callstart, vars, sizeof(vars), CALLER);
|
||||||
manager_event(EVENT_FLAG_AGENT, "AgentComplete",
|
|
||||||
"Queue: %s\r\n"
|
|
||||||
"Uniqueid: %s\r\n"
|
|
||||||
"Channel: %s\r\n"
|
|
||||||
"Member: %s\r\n"
|
|
||||||
"MemberName: %s\r\n"
|
|
||||||
"HoldTime: %ld\r\n"
|
|
||||||
"TalkTime: %ld\r\n"
|
|
||||||
"Reason: caller\r\n"
|
|
||||||
"%s",
|
|
||||||
queuename, qe->chan->uniqueid, peer->name, member->interface, member->membername,
|
|
||||||
(long)(callstart - qe->start), (long)(time(NULL) - callstart),
|
|
||||||
qe->parent->eventwhencalled == QUEUE_EVENT_VARIABLES ? vars2manager(qe->chan, vars, sizeof(vars)) : "");
|
|
||||||
} else {
|
} else {
|
||||||
ast_queue_log(queuename, qe->chan->uniqueid, member->membername, "COMPLETEAGENT", "%ld|%ld|%d",
|
ast_queue_log(queuename, qe->chan->uniqueid, member->membername, "COMPLETEAGENT", "%ld|%ld|%d",
|
||||||
(long) (callstart - qe->start), (long) (time(NULL) - callstart), qe->opos);
|
(long) (callstart - qe->start), (long) (time(NULL) - callstart), qe->opos);
|
||||||
if (qe->parent->eventwhencalled)
|
send_agent_complete(qe, queuename, peer, member, callstart, vars, sizeof(vars), AGENT);
|
||||||
manager_event(EVENT_FLAG_AGENT, "AgentComplete",
|
|
||||||
"Queue: %s\r\n"
|
|
||||||
"Uniqueid: %s\r\n"
|
|
||||||
"Channel: %s\r\n"
|
|
||||||
"MemberName: %s\r\n"
|
|
||||||
"HoldTime: %ld\r\n"
|
|
||||||
"TalkTime: %ld\r\n"
|
|
||||||
"Reason: agent\r\n"
|
|
||||||
"%s",
|
|
||||||
queuename, qe->chan->uniqueid, peer->name, member->membername, (long)(callstart - qe->start),
|
|
||||||
(long)(time(NULL) - callstart),
|
|
||||||
qe->parent->eventwhencalled == QUEUE_EVENT_VARIABLES ? vars2manager(qe->chan, vars, sizeof(vars)) : "");
|
|
||||||
}
|
}
|
||||||
|
|
||||||
if (bridge != AST_PBX_NO_HANGUP_PEER)
|
if (bridge != AST_PBX_NO_HANGUP_PEER)
|
||||||
|
|||||||
Reference in New Issue
Block a user