 |
|
|
|
Создаём систему учета исходящих телефонных звонков
Создаём систему учета исходящих телефонных звонков Сегодня мы займемся созданием системы учета исходящих телефонных звонков на примере УАТС LG GDK-162. От вас требуется: навыки работы в UNIX-подобных операционных системах, умение программировать на Perl и базовые знания в SQL. Недавно руководство поставило задачу – необходимо вести учет всех исходящих телефонных звонков. В офисе установлена УАТС LG GDK-162 емкостью 48 внутренних номеров и 8 внешних линий. Различные программы тарификации имеются в избытке. Но ни одна меня не устроила. Большинство из них платные и написаны под Windows, из некоммерческих только SMDR 1.0 поддерживает LG GDK-162. Для операционных систем Linux и FreeBSD существует очень интересный проект ATSlog: http://www.atslog.dp.ua. Вот описание с сайта программы: «ATSlog предоставляет удобный интерфейс с доступом через веб-браузер для просмотра и анализа звонков различных моделей мини-АТС. Программа бесплатная, распространяется под лицензией GPL, имеет полностью открытый код. Программа успешно работает с моделями Panasonic KX-TA308, KX-TA308RU, KX-TA616RU, KX-TD816RU, KX-TD1232; Samsung SKP-816». К сожалению, не нашел в списке поддерживаемых АТС LG GDK. Для добавления поддержки нужной модели можно отослать автору образцы текстовых лог-файлов. Но это требует времени. Я решил попробовать справиться с задачей своими силами. Это оказалось несложным. Надеюсь, что мой опыт окажется вам полезен.
Рисунок 1. Схема учета исходящих телефонных звонков LG GDK-162, как и большинство офисных АТС, можно подключить к компьютеру через порт RS-232. Параметры порта: 9600 бит/с, 8 бит данных, без контроля паритета, 1 стоповый бит. Таблица 1. Распайка кабеля (стандартный нуль-модем)
Я подключился к последовательному порту УАТС при помощи терминальной программы и стал анализировать считываемые данные. Оказалось, что LG GDK-162 протоколирует свою работу в режиме реального времени, а записи об исходящих звонках выглядят следующим образом:
Рассмотрим её содержимое:
Таким образом, задача учета исходящих телефонных звонков свелась к написанию программы для считывания журнала работы УАТС через порт RS-232, обработки и сохранения соответствующих записей. Можно приступать к реализации. Исходные данные: учет будет осуществляться на машине Cel 1200/RAM 128 Мб/HDD 20 Гб, операционная система – Debian GNU/Linux 3.1r Sarg, СУБД – PostgreSQL v. 7.4.7, УАТС подключена к последовательному порту /dev/ttyS1. Создадим пользователя, от которого будет работать программа и рабочий каталог. Кроме этого, изменим права доступа к /dev/ttyS1: # sudo useradd -d /var/gdklog -s /bin/sh gdk # sudo passwd gdk # sudo mkdir /var/gdklog # sudo chown gdk:gdk /var/gdklog # sudo chown root:gdk /dev/ttyS1 # sudo chmod 640 /dev/ttyS1 Создадим пользователя и базу данных в PostgreSQL: # createuser -U postgres -A -D gdk # createdb -U postgres -O gdk pbxbilling Создадим таблицу gdklog для хранения статистики. Таблица имеет пять полей:
# vi gdklog.sql CREATE TABLE gdklog ( "d_time" timestamp, "station" int2, "line" int2, "t_call" time, "c_number" numeric (30, 0) ); REVOKE ALL on "gdklog" from PUBLIC; GRANT ALL on "gdklog" to "gdk"; # psql -U gdk -d pbxbilling < gdklog.sql Писать программу учета я решил на perl. Полный текст вы можете скачать с сайта www.samag.ru, раздел «Исходный код». Для чтения данных из последовательного порта вполне подойдут стандартные функции для работы с файлами. Естественно, порт необходимо предварительно настроить. Для этого я использовал вызов программы sty: my $ttys = "/dev/ttyS1"; # Количество строк журнала, кэшируемых в памяти my $m_cache = 50; system ("/bin/stty -F $ttys 9600 cs8 -parenb -cstopb"); # Читаем данные из последовательного порта open (TTYS, "< $ttys") or die "Can’t open $ttys!"; while (<TTYS>) { parse_log; } Функция parse_log – единственная в программе, специфичная для LG GDK-162. sub parse_log { # Если массив log содержит m_cache строк, то заносим данные в БД if (@log >= $m_cache) { push_to_db; } # Отбираем строки фиксирующие исходящие звонки if (/O\d+/) { # Удаляем символы *, #, O s/[\*,O,\#]+//g; # Сохраняем полученную строку в массив log push (@log, $_); } print; } Допустим, надо добавить поддержку АТС, пишущую протокол в формате:
Для этого достаточно будет дописать еще одну конструкцию if в функцию parse_log (кроме этого, надо не забыть проверить параметры последовательного порта). if (/^(d{4}-d{2}-d{2})s+(d{2}-d{2}-d{2})s+(d{2})s+(d+)s+(d{2}:d{2}:d{2})s+ { push (@log, "00 $6 $3 $5 $1 $2 $4"); } Постоянно держать открытым соединение с базой данных – не очень хорошая идея. Поэтому все строки, соответствующие регулярному выражению «/Od/g» (журнал исходящих вызовов), сначала заносятся в массив @log. Как только в нем накапливается $m_cache строк – вызывается процедура push_to_db, которая устанавливает соединение с базой pbxbilling и записывает данные в таблицу gdklog: # $d_time // Дата и время # $station // Внутренний номер # $line // Внешняя линия # $t_call // Продолжительность вызова # $date // Дата # $time // Время # $c_number // Вызванный номер my ($d_time, $station, $line, $t_call, $date, $time, $c_number, @log); # Параметры соединения с базой данных my $base = "pbxbilling"; my $user = "gdk"; my $pass = ""; sub push_to_db { # Подготовка соединения my $dbh=DBI->connect("DBI:Pg:dbname=$base", "$user", "$pass", {PrintError => 0, RaiseError => 0} ) or return 2; # Подготовка запроса my $ins = $dbh->prepare(q{ INSERT INTO gdklog (d_time , station, line, t_call, c_number) VALUES (?, ?, ?, ?, ?) }); # Перебираем в цикле все сохраненные строки foreach my $log (@log) { # Разбираем строку (undef, $station, $line, $t_call, $date, $time, $c_number) = split (/\s+/, $log); if (length ($t_call) < 6) { $t_call="00:$t_call"; } $d_time = "$date $time"; # Выполняем INSERT $ins->execute($d_time, $station, $line, $t_call, $c_number) or return 2; } # Очистим массив undef (@log); $dbh->disconnect(); return 0; } Кроме этого, мне нужно было, чтобы программа могла работать в режиме демона: # В режиме демона в этот файл перенаправляем все сообщения об ошибках my $err_file = "/var/gdklog/gdklogd.err"; # PID-файл my $pid_file = "/var/gdklog/gdklogd.pid"; sub begin_daemon { # Делаем fork my $pid = fork; exit if $pid; die "Couldn’t fork: $!" unless defined($pid); # Сохраняем PID в файл open (F_PID, ">$pid_file") or die "Can’t open $pid_file: $!"; print F_PID "$$\n"; close F_PID; # Перенаправляем вывод STDERR в файл open (*STDERR, ">> $err_file") or die "Can’t reopen *STDERR to $err_file: $!"; # Перенаправляем STDIN и STDOUT в /dev/null for my $handle (*STDIN, *STDOUT) { open ($handle, "> /dev/null") or die "Can’t reopen $handle to /dev/null: $!"; } # Установка sid процесса POSIX::setsid() or die "Can’t start a new session: $!"; } Чтобы обеспечить целостность данных, я установил обработчики сигналов INT и TERM. Получая один из них, программа будет пытаться немедленно записать данные в базу, если это окончится неудачей (например, сервер БД отключен), то выполнится процедура dump_to_file, которая просто запишет содержимое @log в текстовый файл. После этого работа программы будет завершена. Второй обработчик добавляет возможность записи данных в базу по сигналу HUP без выхода из программы. $SIG{INT} = $SIG{TERM} = sub { dump_to_file if push_to_db; exit }; $SIG{HUP} = sub { dump_to_file if push_to_db }; Меняем владельца и права доступа: # sudo chown root:gdk /usr/local/sbin/gdklogd # sudo chmod 750 /usr/local/sbin/gdklogd Напишем стартовый сценарий: # vi /etc/init.d/gdklogd #!/bin/sh DAEMON=/usr/local/sbin/gdklogd DAEMONFLAGS="-D" KILL=/bin/kill PID=/var/gdklog/gdklogd.pid CAT=/bin/cat SU=/bin/su start () { echo -n $"Starting $DAEMON: " # Запуск с правами непривилегированного пользователя $SU -c "$DAEMON $DAEMONFLAGS" gdk 2>/dev/null 1>&2 } stop () { echo -n $"Stopping $DAEMON: " $KILL `$CAT $PID` 2>/dev/null 1>&2 } case "$1" in start) start ;; stop) stop ;; restart) stop start ;; *) echo $"Usage: $0 {start|stop|restart}" exit 1 esac # sudo chown root:root /etc/init.d/gdklogd # sudo chmod 700 /etc/init.d/gdklogd Запустим: # sudo /etc/init.d/gdklogd start После запуска сценария с параметром -D он переходит в режим демона, настраивает последовательный порт и начинает считывать из него данные. При запуске без параметра -D сценарий не отсоединяется от терминала, а записи об исходящих звонках дублируются на экран. Если все сделано правильно, то через некоторое время таблица gdklog начнет заполняться записями. # sudo kill –HUP `cat /var/gdklog/gdklogd.pid` # psql -c "SELECT * FROM gdklog;" -U gdk pbxbilling
Вот и все. При минимуме усилий мы получили вполне работоспособную и переносимую систему учета исходящих звонков УАТС LG GDK-162. Работа скрипта проверялась на Debian GNU/Linux 3.1r Sarg и FreeBSD 5.2.1 (надо изменить только имя файла последовательного порта $ttys). Модуль DBI позволяет использовать любую поддерживаемую им СУБД с минимальной правкой кода, а также доступ к базе данных по сети. Для получения отчетов к нашим услугам вся мощь SQL. Несложно добавить поддержку других моделей УАТС. А при наличии свободного времени можно написать веб-интерфейс. Успехов! |
ДЕНИС СОКОЛОВ
| Комментарии |
| Добавить комментарий |
|
Комментарии могут оставлять только зарегистрированные пользователи |
|
