Когда я полтора года назад, будучи студентом 4 курса телекоммуникаций, пришел работать в компанию на должность сисадмина, я понял что работы у меня будет очень много, а учить всего нового придется еще больше. Учебу я отодвинул на второй план, а потом и вовсе стал появляться на парах раз в месяц, потому как работы было много, и она была уж точно интереснее того, чему пытались учить в универе.
Компания занималась продажами, и естественно здесь оказалось много таких человечков, которых зовут менеджерами по продажам, и им нужно было очень много звонить!
В первый же день мне показали существующую систему телефонии. 5 шлюзов VoIP Audiocodes MP-202B и десяток DECT телефонов+ отдельный SIP транк на каждом телефоне. Этими-то телефонами и жонглировали 30 человек весь день. Чё за …, подумал я и решил поставить Asterisk.
В процессе обсуждения с руководством новой системы телефонии было решено взять этих самых Huawei E1550 несколько штук, т.к. было значительно дешевле купить 4 модема, чем GSM шлюз на 4 канала. Это и была моя ошибка по неопытности. Это казалось временным решением, но мы то с вами знаем, что нет ничего более постоянного, чем временное. И тут я познал боль. Боль что:
- Модемы вставленные в материнскую плату бок о бок кол-вом 4 штуки работать нормально не будут, потому что во первых: не на всех хватает тока (нужно каждому модему 500mA на порт, а материнка не справляется), а во-вторых: судя по всему модемы между собой интерферируют, что тоже не есть гуд.
- Не все USB хабы одинаково хороши, и далеко не каждый производители впаивает все конденсаторы. Как итог, я купил STLab U-340 (вообще планировал купить D-Link DUB-H7, но его на тот момент нигде не было). Подключил его к серверу, ткнул модемы в него — и ничего не поменялось, так и остались пропадания речи и периодические отваливания модемов. Первое что я сделал, это разобрал его, и увидел, что нифига там нет конденсаторов. Купил. Впаял. Подключил. Поулыбался. Работает. Лучше. Не идеально, но намного лучше, отпадания минимизировались основательно, слышно стало лучше(позже я еще прикупил USB удлинителей 15см, чтоб рознести модемы друг от друга).
И вот когда это все заработало, нужно было уже что-то решать с тем, как балансировать исходящие звонки, т. к. минут на каждом модеме было по 1000, а нам же нужно что б расходовалось равномерно.
С самого начала у меня был стандартный диалплан. Неудобно ИМХО. Особеннко после того, как я набрался опыта в сисадминистрировании, подучил Python для автоматизации, и… познакомился с Lua. Я переписал весь диалплан на Lua и он с 650 строк превратился в 200 с лишним. И писать диалплан на Lua очень удобно, советую.
Но вот решение по балансировке исходящих вызовов я решил написать на Python3.4.
Суть в чем. Есть карточки от МТС. Я подключил Виртуальный менеджер, что бы можно было проверять кол-во минут на каждой карточке. Так вот скрипт ходит по Cron’у на сайт, парсит его, вытаскивает значения минут и пишет в SQLite базу. Вот что происходит в диалплане: в момент набора номера сотрудником из базы вытаскивается название карточки, на которой больше всего минут, и через нее совершается звонок.
Вот пример кода Pyhton скрипта, которых ходит на сайт и парсит минуты:
#!/usr/bin/env python3.4 import requests, bs4, threading, sys, sqlite3, smtplib, os numbers_dic = { # <имя канала в Астериске> что то типа mts1 из строчки Dongle/mts1 в диалплане #все ID я брал из сайта с помощью FireBug #дл примера '111111':'mts1' '<конкретный_id_для канала>':'<имя канала в Астериске>', '<конкретный_id_для канала>':'<имя канала в Астериске>', '<конкретный_id_для канала>':'<имя канала в Астериске>', '<конкретный_id_для канала>':'<имя канала в Астериске>', '<конкретный_id_для канала>':'<имя канала в Астериске>' } bill_info_dic={} bill_info = [] # словарь в котором будут храниться ключами имя каналов, а значениями кол-во минут minutes_lines={} # авторизация на сайте session = requests.session() session.post('https://manager.mts.ua/Ncih/Security.mvc/LogOn', { # это как бы ваш URL для логина 'Name': '<your_login_name>', 'Password': '<your_password_name>', 'remember': 1, }) # главная страница в Виртуальном менеджере url="https://manager.mts.ua/Ncih/ObjectInfo.mvc/Phone" headers = { 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; WOW64; rv:42.0) Gecko/20100101 Firefox/42.0', 'Accept': '*/*', 'Content-Type': 'application/x-www-form-urlencoded; charset=UTF-8', 'X-Requested-With': 'XMLHttpRequest', 'Referer': 'https://manager.mts.ua/Ncih/Hierarchy.mvc' } # метод который ходит на сайт и тащит мне весь биллинг по аккаунту def request_to_billing(): url = "https://manager.mts.ua/Ncih/ObjectInfo.mvc/PersonalAccount" data_obj = { 'objectId': '<some_id>' #все ID я брал из сайта с помощью FireBug } content = session.get(url, data=data_obj, headers=headers) parsed = bs4.BeautifulSoup(content.content,'html.parser') # вот тут я из конкретных <td> вытаскиваю инфу по биллингу td_blocks = parsed.select('td') balance=(td_blocks[1].getText().split()[0]) waste_1_of_month=(td_blocks[5].getText().split()[0]) sum_of_last_pay=(td_blocks[9].getText().split()[0]) calculate_period_balance=(td_blocks[17].getText().split()[0]) # заменяем запятые на точки, и заносим все в словарь bill_info_dic bill_info_dic[float(balance.replace(",", "."))]="Balance" bill_info_dic[float(waste_1_of_month.replace(",", "."))]="Spented from 1st of current month" bill_info_dic[float(sum_of_last_pay.replace(",", "."))]="Sum of last pay" bill_info_dic[float(calculate_period_balance.replace(",", "."))]="Balance at the beginning of the calculation period" # пишем все в массив bill_info bill_info.append(balance) bill_info.append("Balance") bill_info.append(waste_1_of_month) bill_info.append("Spented from 1st of current month") bill_info.append(sum_of_last_pay) bill_info.append("Sum of last pay") bill_info.append(calculate_period_balance) bill_info.append("Balance at the beginning of the calculation period") # метод который ниже вызывается в цикле в отдельном треде, ходит на сайт и тащит мне минуты def request_to_min(num_id): url = "https://manager.mts.ua/Ncih/ObjectInfo.mvc/Phone" data_obj = { 'objectId': num_id } content = session.get(url, data=data_obj, headers=headers) parsed = bs4.BeautifulSoup(content.content,'html.parser') span_blocks = parsed.select('span') minutes = (span_blocks[2].getText()) sminutes = minutes.split() minutes_lines[numbers_dic[num_id]]=float(sminutes[1].replace(",", ".")) # тут идет проверка на аргументы командной строки (инструкция есть в конце скрипта) if ((len(sys.argv) > 1) and (sys.argv[1] == "billing")): request_to_billing() # создаем sqlite базу conn = sqlite3.connect('/etc/asterisk/scripts/asterisk_dp.db') curs = conn.cursor() # создаем таблицу curs.execute('CREATE TABLE IF NOT EXISTS mts_billing(id INTEGER PRIMARY KEY, money REAL, description VARCHAR(50))') conn.commit() # если хотите почистить базу, есть соотвествующие ключи для скрипта del и new if ((len(sys.argv) > 2) and (sys.argv[2] == "del")): curs.execute('DELETE FROM mts_billing') conn.commit() n_bill = 1 for money, descr in bill_info_dic.items(): if ((len(sys.argv) > 2) and (sys.argv[2] == "new")): curs.execute('INSERT INTO mts_billing VALUES (NULL, %f, "%s")' % (money, descr)) else: curs.execute('UPDATE mts_billing set money = %f, description = "%s" WHERE id = %d' % (money, descr, n_bill)) n_bill += 1 conn.commit() conn.close() # тут ключ billing_mail отправляет мне на почту инфу elif ((len(sys.argv) > 1) and (sys.argv[1] == "billing_mail")): request_to_billing() conn = sqlite3.connect('/etc/asterisk/scripts/asterisk_dp.db') curs = conn.cursor() curs.execute("SELECT * FROM mts_minutes") conn.commit() d = curs.fetchall() msg = 'From:xxx@xxx.com\n' \ 'Subject:GSM BILLING FROM ASTERISK\n\n' \ '%s => %s\n%s => %s\n%s => %s\n%s => %s\n%s\n' % (bill_info[0],bill_info[1],bill_info[2], bill_info[3],bill_info[4],bill_info[5], bill_info[6],bill_info[7],d) sender_addr = 'xxx@xxx.com' rcpt_addr = 'yyy@gmail.com' smtpobj=smtplib.SMTP_SSL('<ip or domain name of mail server>') smtpobj.ehlo() smtpobj.login('xxx@xxx.com', '<password>') smtpobj.sendmail(sender_addr, rcpt_addr, msg) # ключ minutes пишет кол-во минут в базу elif ((len(sys.argv) > 1) and (sys.argv[1] == "minutes")): threads = [] for id in numbers_dic: thrd = threading.Thread(target=request_to_min, args=(id,)) thrd.start() threads.append(thrd) for t in threads: t.join() conn = sqlite3.connect('/etc/asterisk/scripts/asterisk_dp.db') curs = conn.cursor() curs.execute('CREATE TABLE IF NOT EXISTS mts_minutes(id INTEGER PRIMARY KEY, minutes REAL, number VARCHAR(15))') conn.commit() if ((len(sys.argv) > 2) and (sys.argv[2] == "del")): curs.execute('DELETE FROM mts_minutes') conn.commit() n_min = 1 for num in sorted(minutes_lines, reverse=True, key=lambda num: minutes_lines[num]): if ((len(sys.argv) > 2) and (sys.argv[2] == "new")): curs.execute('INSERT INTO mts_minutes VALUES (NULL, %f, "%s")' % (minutes_lines[num], num)) elif ((len(sys.argv) > 2) and (sys.argv[2] == "show")): print("min: %s => number: %s" % (minutes_lines[num], num)) else: curs.execute('UPDATE mts_minutes set minutes = %f, number = "%s" WHERE id = %d' % (minutes_lines[num], num, n_min)) n_min += 1 conn.commit() conn.close() msg = 'From:xxx@xxx.com\nSubject:MINUTES\n\n%s' % sorted(minutes_lines) sender_addr = 'xxx@xxx.com' rcpt_addr = 'yyy@gmail.com' smtpobj=smtplib.SMTP_SSL('<ip or domain name of mail server>') smtpobj.ehlo() smtpobj.login('xxx@xxx.com', '<password>') smtpobj.sendmail(sender_addr, rcpt_addr, msg) else: print(" -"*10) print(" MINUTES REQUEST TOOL", end='\n'*2) print(" HELP", end='\n'*2) print(" ARGS") print(" minutes [del|new] -- запускает скрипт и записывает минуты в таблицу mts_minutes (del очистит таблицу, new запущеный только после del, создаст строки которые будут обновляться") print(" billing [del|new] -- запускает скрипт и записывает минуты в таблицу mts_billing (del очистит таблицу, new запущеный только после del, создаст строки которые будут обновляться") print(" billing_mail -- отправляет на почту биллинг") print(" -"*10)
Я не особо пока шарю в программировании, и то что написано выше может показаться кодом не очень хорошим, но это работает + каждый может его переделать. Понятно что этот код работает до тех пор, пока HTML код страницы не поменяется. Ну что ж… это работает для меня. Если у ват другой оператор, другой билинг, то вам понятное дело придется сменить URL’ы и пройтись по HTML коду страницы, что бы понять что и как правильно парсить. Еще мне кстати очень удобно было отлаживать некоторые моменты скрипта в консольной версии питона IPython3, удобно.
Вообще скрипт для себя я делал более функциональным. Он мне на почту и биллинг отсылает, и инфу по минутам. А вот пример который только узнает кол-во минут и пишет их в базу:
#!/usr/bin/env python3.4 import requests, bs4, threading, sys, sqlite3, os numbers_dic = { # <имя канала в Астериске> что то типа mts1 из строчки Dongle/mts1 в диалплане #все ID я брал из сайта с помощью FireBug #дл примера '111111':'mts1' '<конкретный_id_для канала>':'<имя канала в Астериске>', '<конкретный_id_для канала>':'<имя канала в Астериске>', '<конкретный_id_для канала>':'<имя канала в Астериске>', '<конкретный_id_для канала>':'<имя канала в Астериске>', '<конкретный_id_для канала>':'<имя канала в Астериске>' } # словарь в котором будут храниться ключами имя каналов, а значениями кол-во минут minutes_lines={} # авторизация на сайте session = requests.session() session.post('https://manager.mts.ua/Ncih/Security.mvc/LogOn', { # это как бы ваш URL для логина 'Name': '<your_login_name>', 'Password': '<your_password_name>', 'remember': 1, }) # главная страница в Виртуальном менеджере url="https://manager.mts.ua/Ncih/ObjectInfo.mvc/Phone" headers = { 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; WOW64; rv:42.0) Gecko/20100101 Firefox/42.0', 'Accept': '*/*', 'Content-Type': 'application/x-www-form-urlencoded; charset=UTF-8', 'X-Requested-With': 'XMLHttpRequest', 'Referer': 'https://manager.mts.ua/Ncih/Hierarchy.mvc' } # метод который ниже вызывается в цикле в отдельном треде, ходит на сайт и тащит мне минуты def request_to_min(num_id): url = "https://manager.mts.ua/Ncih/ObjectInfo.mvc/Phone" data_obj = { 'objectId': num_id } content = session.get(url, data=data_obj, headers=headers) parsed = bs4.BeautifulSoup(content.content,'html.parser') span_blocks = parsed.select('span') minutes = (span_blocks[2].getText()) sminutes = minutes.split() minutes_lines[numbers_dic[num_id]]=float(sminutes[1].replace(",", ".")) # тут идет проверка на аргументы командной строки (инструкция есть в конце скрипта) # ключ minutes пишет кол-во минут в базу elif ((len(sys.argv) > 1) and (sys.argv[1] == "minutes")): threads = [] for id in numbers_dic: thrd = threading.Thread(target=request_to_min, args=(id,)) thrd.start() threads.append(thrd) for t in threads: t.join() conn = sqlite3.connect('/etc/asterisk/scripts/asterisk_dp.db') curs = conn.cursor() curs.execute('CREATE TABLE IF NOT EXISTS mts_minutes(id INTEGER PRIMARY KEY, minutes REAL, number VARCHAR(15))') conn.commit() if ((len(sys.argv) > 2) and (sys.argv[2] == "del")): curs.execute('DELETE FROM mts_minutes') conn.commit() n_min = 1 for num in sorted(minutes_lines, reverse=True, key=lambda num: minutes_lines[num]): if ((len(sys.argv) > 2) and (sys.argv[2] == "new")): curs.execute('INSERT INTO mts_minutes VALUES (NULL, %f, "%s")' % (minutes_lines[num], num)) elif ((len(sys.argv) > 2) and (sys.argv[2] == "show")): print("min: %s => number: %s" % (minutes_lines[num], num)) else: curs.execute('UPDATE mts_minutes set minutes = %f, number = "%s" WHERE id = %d' % (minutes_lines[num], num, n_min)) n_min += 1 conn.commit() conn.close()
Вот пример диалплана на Lua который берет значения из базы (Asterisk кстати скомпилирован с Lua версии 5.2):
local sqlite3 = require("lsqlite3") -- функция которая ходит в базу и берет номер, через который будет совершаться звонок function gsm_outgoing(context, extension) local db = sqlite3.open("/etc/asterisk/scripts/asterisk_dp.db", "wc") -- kyivstar section -- номера которые Киевстар, вызываются через один канал Dongle/kyivstar, в базу ходить не надо if ((extension:sub(1,3) == extension:sub(1,3):match('06[7,8]')) or (extension:sub(1,3) == extension:sub(1,3):match('09[6,7,8]'))) then app.dial(string.format("Dongle/kyivstar/%s, 45 tkr", extension)) local state = channel.DIALSTATUS:get() -- но канал Dongle/kyivstar один, и если он занят, то мы все же позвоним через один из МТС if (state == "CHANUNAVAIL") then for _, _, c in db:urows("SELECT * FROM mts_minutes") do app.noop("Calling through "..c) app.dial(string.format("Dongle/%s/%s, 45 tkr", c, extension)) local state = channel.DIALSTATUS:get() if (state ~= "CHANUNAVAIL") then app.noop("Device "..c.." in status "..state) break else app.noop("Device "..c.." in status "..state) end; end; end; app.hangup() ---mts section else for _, _, c in db:urows("SELECT * FROM mts_minutes") do app.noop("Calling through "..c) app.dial(string.format("Dongle/%s/%s, 45 tkr", c, extension)) local state = channel.DIALSTATUS:get() if (state ~= "CHANUNAVAIL") then app.noop("GOOD ! Device "..c.." in status "..state) break else app.noop("So sad ! Device "..c.." in status "..state) end; end; app.hangup() end; end; extensions = { -- Исходящие звонки МТС gsm = { ["_03[1,2,3,4,5,6,7,8]XXXXXXX"] = gsm_outgoing;--mts ["_04[1,2,3,5,6,7,8,9]XXXXXXX"] = gsm_outgoing;--mts ["_05[0,1,2,3,4,5,6,7,8,9]XXXXXXX"] = gsm_outgoing;--mts ["_06[1,2,3,4,5,6,9]XXXXXXX"] = gsm_outgoing;--mts ["_07[3]XXXXXXX"] = gsm_outgoing;--life ["_09[1,2,3,4,5,9]XXXXXXX"] = gsm_outgoing;--mts ["_06[7,8]XXXXXXX"] = gsm_outgoing;--kyivstar ["_09[6,7,8]XXXXXXX"] = gsm_outgoing;--kyivstar }; }
Резюмируя, по поводу системы телефонии в общем, то да, Asterisk — круто и возможностей у него много, очень много. Но вот лепить туда такое как GSM модемы, я не советую. Да! Оно работает, и при умении пользоваться паяльником, оно работает еще лучше, но… Оно вам надо? Покупайте нормальные шлюзы. У меня все. Все пис!
ссылка на оригинал статьи http://habrahabr.ru/post/273661/
Добавить комментарий