The task is for subscribers with a certain geography to give the opportunity not to wait until the operator is free, and by pressing 0 hear “Thank you for the call. We will definitely call you back ”, disconnect and calmly wait for a call from the operator, well or
Create tables
CREATE TABLE asterisk.callback (
id int (11) NOT NULL AUTO_INCREMENT,
dt timestamp DEFAULT CURRENT_TIMESTAMP,
cid varchar (32) DEFAULT NULL,
dst varchar (32) DEFAULT NULL,
status smallint (6) NOT NULL DEFAULT 0,
tot_calls int (11) NOT NULL DEFAULT 0,
last_call timestamp DEFAULT '0000-00-00 00:00:00',
compl_dt timestamp DEFAULT '0000-00-00 00:00:00',
uniqueid varchar (32) DEFAULT NULL,
queue varchar (255) DEFAULT NULL,
PRIMARY KEY (ID)
)
ENGINE = INNODB
CREATE TABLE asterisk.callback_log (
id int (11) NOT NULL AUTO_INCREMENT,
callback_id int (11) NOT NULL,
dt timestamp DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
status varchar (32) DEFAULT NULL,
params varchar (2048) DEFAULT NULL,
PRIMARY KEY (id),
CONSTRAINT callback_log_fk1 FOREIGN KEY (callback_id)
REFERENCES asterisk.callback (id) ON DELETE CASCADE ON UPDATE CASCADE
)
ENGINE = INNODB
Editing extensions.conf
exten => 88142590067, s, 1
same => n, GotoIf ($ ["$ {CALLERID (num): 0: 4}" = "8814"]? extra); if the number is local, then allow CALLBACK
.... you can insert more checks here ...
same => n, Goto (call)
same => n (extra), NoOp (Allow callback for $ {CALLERID (num)})
same => n, Set (ALLOW_CALLBACK = 1)
same => n, Set (CALLBACK_QUEUE = operators)
same => n, Background (vse / press0-to-callback)
same => n (call), NoOp (Ask for operators. GROUP_COUNT = $ {GROUP_COUNT (operators)})
same => n, queue (operators, tThH)
same => n, Hangup
include => main_menu_press
[main_menu_press]
exten => 0.1, NoOp ('-------------------- $ {CALLERID (num)} PRESS BUTTON $ {EXTEN}. ALLOW_CALLBACK = $ {ALLOW_CALLBACK} ')
same => n, GotoIf ($ [$ {ALLOW_CALLBACK} = 1]? callback, s, 1: i, 1)
[callback]
exten => s, 1, NoOp (CALLBACK)
same => n, Playback (thank-you-for-calling & vse / my-vam-perezvonim)
same => n, Hangup
exten => h, 1, agi (callback.php, gen, 0, $ {CALLBACK_QUEUE})
[do-callback]
exten => _X., 1, NoOp (Try to dial to queue ($ {CALLBACK_QUEUE}) and callback to $ {CALLBACK_NUM})
same => n, Set (__ DST = "?")
same => n, Set (CALLERID (num) = $ {CALLBACK_NUM})
same => n (call), queue ($ {CALLBACK_QUEUE}, tT)
same => n, NoOp (CALLBACK QUEUESTATUS = $ {QUEUESTATUS})
[macro-queue-answ]; We get here when the operator answered.
exten => s, 1, NoOp (Queue member answered uniq = $ {UNIQUEID} cid = $ {CALLERID (num)} chan = $ {CHANNEL} callback_id = $ {CALLBACK_ID} callback_num = $ {CALLBACK_NU
same => n, GotoIf ($ ["$ {CALLBACK_ID} x" = "x"]? skip)
same => n, Set (DST = $ {CHANNEL})
same => n, Set (CALLERID (num) = 067)
same => n, Playback (priv-trying); Play operator "Wait for connection"
same => n, agi (callback.php, queue-answering, $ {CALLBACK_ID}, $ {CHANNEL}, $ {UNIQUEID})
same => n, Dial (Local / $ {CALLBACK_NUM} @from_office_new)
same => n, NoOp ([macro-queue-answ] dial timeout)
same => n (skip), NoOp ()
exten => h, 1, NoOp ([macro-queue-answing] dial hangup)
same => n, GotoIf ($ ["$ {CALLBACK_ID} x" = "x"]? end)
same => n, NoOp (dialstatus = $ {DIALSTATUS} hangupcause = $ {HANGUPCAUSE} queuestatus = $ {QUEUESTATUS})
same => n, NoOp (my_dialstatus = $ {MY_DIALSTATUS} my_hangupcause = $ {MY_HANGUPCAUSE})
same => n, agi (callback.php, hangup-queue-answing, $ {CALLBACK_ID}, $ {CHANNEL}, $ {UNIQUEID})
same => n (end), NoOp
[callback-complete]
exten => s, 1, NoOp (Callback complete. CALLBACK_ID = $ {CALLBACK_ID}, uniq = $ {UNIQUEID}, dst = $ {DST} chan = $ {CHANNEL})
same => n, NoOp (dialstatus = $ {DIALSTATUS} hangupcause = $ {HANGUPCAUSE} queuestatus = $ {QUEUESTATUS})
same => n, NoOp (my_dialstatus = $ {MY_DIALSTATUS} my_hangupcause = $ {MY_HANGUPCAUSE})
Queues.conf file
[operators]
ringinuse = no
strategy = rrmemory
music = default
member => SIP / 321
member => SIP / 322
member => SIP / 323
member => SIP / 324
member => SIP / 325
member => Agent / 1
member => Agent / 2
member => Agent / 3
member => Agent / 4
member => Agent / 5
context = main_menu_press
timeout = 0
announce-position = yes
announce-frequency = 60
periodic-announce-frequency = 30
queue-youarenext = queue-youarenext
membermacro = queue-answ
Well, actually the scripts (PHP detected)
config.php
<?php ob_implicit_flush(true); set_time_limit(6); date_default_timezone_set('Europe/Moscow'); mysql_connect("localhost","asterisk","***") or die('Mysql connect error'); mysql_select_db("asterisk"); // ******************************* function genCallbackFile($id,$cid,$queue) { $fname='/var/spool/asterisk/outgoing/callback-'.$id; if (file_exists($fname)) return; $callfile="Channel: Local/".$cid."@do-callback\n". "WaitTime: 60\n". "MaxRetries: 1\n"."RetryTime: 120\n". "Context: callback-complete\n". "Extension: s\n". "Set: __CALLBACK_ID=$id\n". "Set: __CALLBACK_QUEUE=$queue\n". "Set: __CALLBACK_NUM=$cid\n"; $fp=fopen($fname,'w+');fputs($fp,$callfile);fclose($fp); } ?>
callback.php
#!/usr/bin/php <? $arg=$_SERVER["argv"]; $a=$arg[1]; $id=abs($arg[2]); include('/var/lib/asterisk/agi-bin/config.php'); $in = fopen("php://stdin","r"); $stdlog = fopen("/var/log/asterisk/callback.log", "a+"); // toggle debugging output (more verbose) $debug = false; // parse agi headers into array while ($env=read()) { $s = split(": ",$env); $agi[str_replace("agi_","",$s[0])] = trim($s[1]); if (($env == "") || ($env == "\n")) { break; } } // main program ************************ $dt=date('dmY H:i:s'); $cid=$agi[callerid]; switch ($a) { case 'cid-answ' : { // - $stmt='select * from callback where id='.$id; $result=mysql_query($stmt); $row=mysql_fetch_object($result); $cid=$row->cid; $stmt="select * from callback where id=$id or (dt>(now()-interval 24 hour) and cid='$cid' and STATUS<>2)"; $result=mysql_query($stmt); while ($row=mysql_fetch_object($result)) { $id=$row->id; $stmt="update callback set status=2,compl_dt=now() where id=$id"; $result=mysql_query($stmt); rename('/var/spool/asterisk/outgoing/callback-'.$id,'/tmp/callback-'.$id); } break; } case 'queue-answ' : { // . $dst=$arg[3]; $stmt=sprintf('update callback set status=1,last_call=now(),tot_calls=tot_calls+1,dst="%s",uniqueid="%s" where id=%d",$dst,$agi[uniqueid],$id); $result=mysql_query($stmt); break; } case 'complete' : { // , , callfile $id=abs($arg[2]); $stmt='select * from callback where id='.$id; $result=mysql_query($stmt); $row=mysql_fetch_object($result); if ($row->status!=2) genCallBackFile($id,$row->cid,$row->queue); break; } case 'gen': { // $qname=trim($arg[3]); if (!$qname) $qname='operators'; // 0, , . $stmt=sprintf('select * from callback where cid="%s" and queue="%s" status<>2 and dt>now()-interval 24 hour',$cid,$qname); $result=mysql_query($stmt); if (!$row=mysql_fetch_object($result)) { $stmt="insert into callback (cid,queue) values ('$cid','$qname')"; $result=mysql_query($stmt); $id=mysql_insert_id(); fputs($stdlog,"$dt|$stmt\n"); } else { $log_status='cid '.$cid.' already in spool '.$qname; } genCallBackFile($id,$cid,$qname); break; } } $stmt=sprintf('insert into callback_log (callback_id,status) values (%d,"%s -> %s")',$id,$a,$log_status); $result=mysql_query($stmt); $log_id=mysql_insert_id(); // clean up file handlers etc. fclose($in); fclose($stdlog); exit; // **************************************** ?>
And we put one more callback-regen.php file for the regeneration of call files in crowns every 5 minutes between 8 a.m. and 8 p.m.
With each attempt, the time of the repeated call is increased by 5 minutes. After 10 attempts to mock the operator, stop
#!/usr/bin/php <? include('/var/lib/asterisk/agi-bin/config.php'); $stmt='select * from callback where status<>2 and dt>now()-interval 24 hour and tot_calls<=10 '. ' and last_call<now()-interval tot_calls*5 minute '. ' group by cid,queue'; $result=mysql_query($stmt); while ($row=mysql_fetch_object($result)) { genCallBackFile($row->id,$row->cid,$row->queue); } // **************************************** ?>