Changed the PARK CUSTOMER option in campaigns to use a true Music-on-Hold context
Added new IVR PARK CUSTOMER feature to campaigns allowing an agent to park a customer to an IVR, collect data, then go back to the agent git-svn-id: svn://192.168.202.10@1533 3d104415-ff17-0410-8863-d5cf3c621b8a
This commit is contained in:
mattf
+185
-54
@@ -1,6 +1,6 @@
|
||||
#!/usr/bin/perl
|
||||
#
|
||||
# park_CID.agi version 2.2.0 *DBI-version*
|
||||
# park_CID.agi version 2.4
|
||||
#
|
||||
# runs before the park extension to populate the parked_channels entry with the channel's callerid
|
||||
#
|
||||
@@ -12,13 +12,14 @@
|
||||
# exten => 8301,3,Playback(park)
|
||||
# exten => 8301,4,Hangup
|
||||
#
|
||||
# Copyright (C) 2009 Matt Florell <vicidial@gmail.com> LICENSE: AGPLv2
|
||||
# Copyright (C) 2010 Matt Florell <vicidial@gmail.com> LICENSE: AGPLv2
|
||||
#
|
||||
# changes:
|
||||
# 60731-1423 - changed to use DBI-DBD::mysql
|
||||
# - changed to use /etc/astguiclient.conf for configs
|
||||
# 60815-1256 - added output options check from database
|
||||
# 90909-0922 - Fixed calleridname issue
|
||||
# 101004-1012 - Changed park to Music On Hold, added option for park on AGI
|
||||
#
|
||||
|
||||
$script = 'park_CID.agi';
|
||||
@@ -77,6 +78,8 @@ if (!$VARDB_port) {$VARDB_port='3306';}
|
||||
if (!$AGILOGfile) {$AGILOGfile = "$PATHlogs/agiout.$year-$mon-$mday";}
|
||||
|
||||
use DBI;
|
||||
use Asterisk::AGI;
|
||||
$AGI = new Asterisk::AGI;
|
||||
|
||||
$dbhA = DBI->connect("DBI:mysql:$VARDB_database:$VARDB_server:$VARDB_port", "$VARDB_user", "$VARDB_pass")
|
||||
or die "Couldn't connect to database: " . DBI->errstr;
|
||||
@@ -90,27 +93,27 @@ $rec_count=0;
|
||||
while ($sthArows > $rec_count)
|
||||
{
|
||||
$AGILOG = '0';
|
||||
@aryA = $sthA->fetchrow_array;
|
||||
$DBagi_output = "$aryA[0]";
|
||||
if ($DBagi_output =~ /STDERR/) {$AGILOG = '1';}
|
||||
if ($DBagi_output =~ /FILE/) {$AGILOG = '2';}
|
||||
if ($DBagi_output =~ /BOTH/) {$AGILOG = '3';}
|
||||
$rec_count++;
|
||||
@aryA = $sthA->fetchrow_array;
|
||||
$DBagi_output = $aryA[0];
|
||||
if ($DBagi_output =~ /STDERR/) {$AGILOG = '1';}
|
||||
if ($DBagi_output =~ /FILE/) {$AGILOG = '2';}
|
||||
if ($DBagi_output =~ /BOTH/) {$AGILOG = '3';}
|
||||
$rec_count++;
|
||||
}
|
||||
$sthA->finish();
|
||||
|
||||
|
||||
### begin parsing run-time options ###
|
||||
if (length($ARGV[0])>1)
|
||||
{
|
||||
{
|
||||
if ($AGILOG) {$agi_string = "Perl Environment Dump:"; &agi_output;}
|
||||
$i=0;
|
||||
while ($#ARGV >= $i)
|
||||
{
|
||||
$args = "$args $ARGV[$i]";
|
||||
if ($AGILOG) {$agi_string = "$i|$ARGV[$i]"; &agi_output;}
|
||||
$i++;
|
||||
}
|
||||
{
|
||||
$args = "$args $ARGV[$i]";
|
||||
if ($AGILOG) {$agi_string = "$i|$ARGV[$i]"; &agi_output;}
|
||||
$i++;
|
||||
}
|
||||
if ($args =~ />| |\"/i)
|
||||
{
|
||||
@CID = split(/-----/, $args);
|
||||
@@ -120,48 +123,49 @@ if (length($ARGV[0])>1)
|
||||
}
|
||||
|
||||
if ($args =~ /--help/i)
|
||||
{
|
||||
print "allowed run time options:\n [-q] = quiet\n [-t] = test\n [-debug] = verbose debug messages\n\n";
|
||||
}
|
||||
{
|
||||
print "allowed run time options:\n [-q] = quiet\n [-t] = test\n [-debug] = verbose debug messages\n\n";
|
||||
}
|
||||
else
|
||||
{
|
||||
{
|
||||
if ($args =~ /-V/i)
|
||||
{
|
||||
$V=1;
|
||||
}
|
||||
{
|
||||
$V=1;
|
||||
}
|
||||
if ($args =~ /-debug/i)
|
||||
{
|
||||
$DG=1;
|
||||
}
|
||||
{
|
||||
$DG=1;
|
||||
}
|
||||
if ($args =~ /-dbAVS/i)
|
||||
{
|
||||
$DGA=1;
|
||||
}
|
||||
{
|
||||
$DGA=1;
|
||||
}
|
||||
if ($args =~ /-q/i)
|
||||
{
|
||||
$q=1;
|
||||
$Q=1;
|
||||
}
|
||||
{
|
||||
$q=1;
|
||||
$Q=1;
|
||||
}
|
||||
if ($args =~ /-t/i)
|
||||
{
|
||||
$TEST=1;
|
||||
$T=1;
|
||||
{
|
||||
$TEST=1;
|
||||
$T=1;
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
$|=1;
|
||||
while(<STDIN>) {
|
||||
while(<STDIN>)
|
||||
{
|
||||
chomp;
|
||||
last unless length($_);
|
||||
if ($AGILOG)
|
||||
{
|
||||
if (/^agi_(\w+)\:\s+(.*)$/)
|
||||
{
|
||||
if (/^agi_(\w+)\:\s+(.*)$/)
|
||||
{
|
||||
$AGI{$1} = $2;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
if (/^agi_uniqueid\:\s+(.*)$/) {$unique_id = $1;}
|
||||
if (/^agi_channel\:\s+(.*)$/) {$channel = $1;}
|
||||
@@ -174,6 +178,8 @@ while(<STDIN>) {
|
||||
if ( $calleridname =~ /\"/) {$calleridname =~ s/\"//gi;}
|
||||
if ( (!$callerid) or ($callerid =~ /unknown/) or ( ($calleridname =~ /\d\d\d\d\d\d\d\d\d/) && (length($calleridname) > 16) ) )
|
||||
{$callerid = $calleridname;}
|
||||
if ( ($callerid =~ / /) && (length($callerid) > 20) )
|
||||
{$callerid =~ s/ .*//gi;}
|
||||
|
||||
### allow for ANI being sent with the DNIS "*3125551212*9999*"
|
||||
if ($extension =~ /^\*\d\d\d\d\d\d\d\d\d\d\*/)
|
||||
@@ -186,14 +192,14 @@ while(<STDIN>) {
|
||||
}
|
||||
$calleridname = $callerid;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
if ($AGILOG) {$agi_string = "AGI Environment Dump:"; &agi_output;}
|
||||
|
||||
foreach $i (sort keys %AGI)
|
||||
{
|
||||
{
|
||||
if ($AGILOG) {$agi_string = " -- $i = $AGI{$i}"; &agi_output;}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
if ($AGILOG) {$agi_string = "AGI Variables: |$unique_id|$channel|$extension|$type|$callerid|"; &agi_output;}
|
||||
@@ -206,25 +212,150 @@ $stmtA = "UPDATE parked_channels set channel_group='$callerid' where server_ip='
|
||||
$affected_rows = $dbhA->do($stmtA);
|
||||
if ($AGILOG) {$agi_string = "-- Park record updated: |$affected_rows| |$callerid|$channel|$VARserver_ip"; &agi_output;}
|
||||
|
||||
$VACcount=0;
|
||||
$VAC_campaign_id='';
|
||||
$VAC_call_type='';
|
||||
$VAC_extension='';
|
||||
$VLAcount=0;
|
||||
$VLA_user='';
|
||||
$VLA_campaign_id='';
|
||||
$VCcount=0;
|
||||
$park_context='default';
|
||||
$MOHfiles=0;
|
||||
|
||||
$stmtA = "SELECT campaign_id,call_type,extension FROM vicidial_auto_calls where callerid='$callerid';";
|
||||
$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
|
||||
$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
|
||||
$VACcount=$sthA->rows;
|
||||
if ($VACcount > 0)
|
||||
{
|
||||
@aryA = $sthA->fetchrow_array;
|
||||
$VAC_campaign_id = $aryA[0];
|
||||
$VAC_call_type = $aryA[1];
|
||||
$VAC_extension = $aryA[2];
|
||||
}
|
||||
$sthA->finish();
|
||||
|
||||
if ($VACcount > 0)
|
||||
{
|
||||
$stmtA = "SELECT user,campaign_id FROM vicidial_live_agents where callerid='$callerid';";
|
||||
$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
|
||||
$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
|
||||
$VLAcount=$sthA->rows;
|
||||
if ($VLAcount > 0)
|
||||
{
|
||||
@aryA = $sthA->fetchrow_array;
|
||||
$VLA_user = $aryA[0];
|
||||
$VLA_campaign_id = $aryA[1];
|
||||
}
|
||||
$sthA->finish();
|
||||
if ($VLAcount > 0)
|
||||
{
|
||||
$stmtA = "SELECT park_file_name,ivr_park_call_agi FROM vicidial_campaigns where campaign_id='$VLA_campaign_id';";
|
||||
$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
|
||||
$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
|
||||
$VCcount=$sthA->rows;
|
||||
if ($VCcount > 0)
|
||||
{
|
||||
@aryA = $sthA->fetchrow_array;
|
||||
$park_context = $aryA[0];
|
||||
$VC_ivr_park_call_agi = $aryA[1];
|
||||
}
|
||||
$sthA->finish();
|
||||
|
||||
$stmtA = "SELECT count(*) FROM vicidial_music_on_hold_files where moh_id='$park_context';";
|
||||
$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
|
||||
$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
|
||||
$MOHcount=$sthA->rows;
|
||||
if ($MOHcount > 0)
|
||||
{
|
||||
@aryA = $sthA->fetchrow_array;
|
||||
$MOHfiles = $aryA[0];
|
||||
}
|
||||
$sthA->finish();
|
||||
if ($MOHfiles< 1)
|
||||
{
|
||||
if ($AGILOG) {$agi_string = "-- Context empty, switching to default: |$park_context|$MOHcount|$MOHfiles| |$callerid|"; &agi_output;}
|
||||
|
||||
$park_context = 'default';
|
||||
}
|
||||
|
||||
### call was parked to an IVR, launch the AGI script
|
||||
if ( ($VCcount > 0) && ($VAC_extension =~ /PARK_IVR/) && (length($VC_ivr_park_call_agi)>2) )
|
||||
{
|
||||
if ($AGILOG) {$agi_string = "-- Starting AGI: |$VC_ivr_park_call_agi| |$callerid|"; &agi_output;}
|
||||
|
||||
print "EXEC AGI $VC_ivr_park_call_agi\n";
|
||||
checkresult($result);
|
||||
|
||||
if ($AGILOG) {$agi_string = "-- AGI Done: |$callerid|"; &agi_output;}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
$dbhA->disconnect();
|
||||
|
||||
|
||||
$AGI->stream_file('sip-silence');
|
||||
$AGI->stream_file('sip-silence');
|
||||
$AGI->stream_file('sip-silence');
|
||||
$AGI->stream_file('sip-silence');
|
||||
|
||||
if ($AGILOG) {$agi_string = "-- Starting MoH: |$park_context| |$callerid|"; &agi_output;}
|
||||
|
||||
print "SET MUSIC ON $park_context\n";
|
||||
checkresult($result);
|
||||
|
||||
sleep(360);
|
||||
|
||||
if ($AGILOG) {$agi_string = "-- MoH Done: |$callerid|"; &agi_output;}
|
||||
|
||||
|
||||
exit;
|
||||
|
||||
|
||||
|
||||
sub agi_output
|
||||
{
|
||||
if ($AGILOG >=2)
|
||||
{
|
||||
### open the log file for writing ###
|
||||
open(Lout, ">>$AGILOGfile")
|
||||
|| die "Can't open $AGILOGfile: $!\n";
|
||||
print Lout "$now_date|$script|$agi_string\n";
|
||||
close(Lout);
|
||||
if ($AGILOG >=2)
|
||||
{
|
||||
### open the log file for writing ###
|
||||
open(Lout, ">>$AGILOGfile")
|
||||
|| die "Can't open $AGILOGfile: $!\n";
|
||||
print Lout "$now_date|$script|$agi_string\n";
|
||||
close(Lout);
|
||||
}
|
||||
### send to STDERR writing ###
|
||||
if ( ($AGILOG == '1') || ($AGILOG == '3') )
|
||||
{print STDERR "$now_date|$script|$agi_string\n";}
|
||||
$agi_string='';
|
||||
}
|
||||
|
||||
|
||||
sub checkresult
|
||||
{
|
||||
my ($res) = @_;
|
||||
my $retval;
|
||||
$tests++;
|
||||
chomp $res;
|
||||
if ($res =~ /^200/)
|
||||
{
|
||||
$res =~ /result=(-?\d+)/;
|
||||
if (!length($1))
|
||||
{
|
||||
# print STDERR "FAIL ($res)\n";
|
||||
$fail++;
|
||||
}
|
||||
else
|
||||
{
|
||||
# print STDERR "PASS ($1)\n";
|
||||
$pass++;
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
# print STDERR "FAIL (unexpected result '$res')\n";
|
||||
$fail++;
|
||||
}
|
||||
}
|
||||
### send to STDERR writing ###
|
||||
if ( ($AGILOG == '1') || ($AGILOG == '3') )
|
||||
{print STDERR "$now_date|$script|$agi_string\n";}
|
||||
$agi_string='';
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user