Нужно добавить парсинг из вашей таблицы queue_log. Делается это так:
Код: Выделить всё
// Populates an array with the EVENTS ids
$query = "SELECT * FROM qevent ORDER BY event_id";
$res = consulta_db($query,0,0);
while($row = db_fetch_row($res)) {
$event_array["$row[1]"] = $row[0];
}
// *******************************************************************************************************
// fetch realtime data
$query = "SELECT `time`, callid, queuename, agent, `event`, `data` FROM asterisk.queue_log WHERE time > '".mysql_real_escape_string($last_event_ts)."' ORDER BY id";
$res = consulta_db($query,0,0);
while($row = db_fetch_row($res)) {
procesa(implode('|', $row));
}
// *******************************************************************************************************
$filename = "$queue_log_dir/$queue_log_file";
$dataFile = fopen( $filename, "r" );
Часть, выделенную ********************************, надо добавить в файл parselog.php. Если ваша БД не asterisk, то нужно указать ее имя тут, вместо asterisk: "FROM asterisk.queue_log WHERE".