Изменение статусов операторов в очереди через AMI, посредством мониторинга базы данных

В данной статье мы будем рассматривать вариант смены статусов операторов в очереди (пауза/свободен), в зависимости от записей в базе данных. Можно автоматизировать смену статусо операторов, например, по сменам или в зависимости от каких либо событий, отраженных в базе данных.

Т.е. можно автоматизировать рабочее и нерабочее время операторов по сменам или в зависимости от каких-то событий отраженных в БД.

Для примера, смену статусов организуем по расписанию, с проверкой каждый час.

Соответственно в базу данных необходимо будет внести таблицу с полями: номер, время работы, очередь, пояснение. Скриптом будем получать данные и изменять статусы.

Для подключения как к базе данных, так и к AMI необходимо создать пользователя с нужными правами (а для базы данных еще и создать базу с таблицей). В данном случае для AMI необходимы будут права на запись для команд, а для базы соответственно на запись и чтение в/из созданной таблицы.

create table chmstatus (
        num varchar(8) NOT NULL PRIMARY KEY, 
        date varchar(20), 
        descr varchar(50)
        );
GRANT ALL PRIVILEGES on asteriskcdrdb.chmstatus to 'chmuser'@'localhost' IDENTIFIED BY 'chmpass';
FLUSH PRIVILEGES;

Заносить данные будем вручную, однако при необходимости каждый может создать себе простую веб-форму для записи в базу по аналогии со статьей.

В скрипте необходимо получить текущее время и сравнить его со временем из базы, при совпадении или наличии времени в нужном отрезке, изменяем статус на паузу, при выходе из пула соответственно паузу снимаем.

Для запросов в базу и AMI необходимы функции, опишем их в начале скрипта:

#!/usr/bin/php –q
<?
// доступы
define('AMI_HOST','localhost');
define('AMI_PORT','5038');
define('AMI_USER','');
define('AMI_PASS','');
define('BD_HOST','localhost');
define('BD_USER','chmuser');
define('BD_PASS','chmpass');
// AMI подключение
function ami_request($ingect){
  $answer=false;
  if ($socket = fsockopen(AMI_HOST, AMI_PORT, $ac_err_num, $ac_err_msg, 1)){
    stream_set_timeout($socket, 1);
    $action  = "Action: login\r\n";
    $action .= "Username: ".AMI_USER."\r\n";
    $action .= "Secret: ".AMI_PASS."\r\n\r\n";
    $action .= $ingect;
    $action .= "Action: Logoff\r\n\r\n";
    fwrite($socket,$action);
    sleep(1);
    $answer = fread($socket,8291);
    fclose($socket);
  }
  return $answer;
}


// MYSQL подключение
function bd_bridge($dataBase,$query){
  $link = @mysqli_connect(BD_HOST,BD_USER,BD_PASS,$dataBase) or die("Error: ".mysqli_connect_error($link));
  $sqlTable = @mysqli_query($link, $query) or die("Error: ".mysqli_error($link));
  $result = [];
  while($row = @mysqli_fetch_assoc($sqlTable)) $result[] = $row;
  @mysqli_close($link);
  return $result;
}

Далее запрашиваем время системы в нужном нам формате:

$date=date("H:i");

И данные из базы:

$arr=bd_bridge("asteriskcdrdb","select * from chmstatus");

После получения данных, необходимо открыть массив данных в цикле, для обработки:

$action="";
foreach ($arr as $value) {
	$datearr=explode('-',$value['date']);
	$time1=strtotime($datearr[0]);
	$time2=strtotime($datearr[1]);
	$time=strtotime($date);
	$num=$value['num'];
	$queue=$value['queue'];
	$descr=$value['descr'];
//проверяем время и выставляем значение паузы
	if (($time>=$time1) and ($time<=$time2)) {
		echo $stat='true';
	} else $stat='false';
$action.="Action: QueuePause\r\n";//формируем action для постановки/снятия паузы
$action.="Interface: Local/$num@from-queue/n\r\n";
$action.="Paused: $stat\r\n";
$action.="Queue: $queue\r\n\r\n";
}

После формирования Action его лучше вывести на экран, чтобы проверить:

echo $action;

После проверки можем отправлять action в AMI с помощью ранее созданной функции:

ami_request($action); или echo ami_request($action);

Далее скрипт можно поместить в крон на выполнение, например, каждый час:

0 */1 * * * /usr/src/test/chmstat.php