#!/usr/bin/env python3.4
import requests, bs4, threading, sys, sqlite3, smtplib, os
numbers_dic = {
                # <имя канала в Астериске> что то типа mts1 из строчки Dongle/mts1 в диалплане
                #все ID я брал из сайта с помощью FireBug
                #дл примера  '111111':'mts1'
               '<конкретный_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[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.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)

#!/usr/bin/env python3.4
import requests, bs4, threading, sys, sqlite3, os

numbers_dic = {
                # <имя канала в Астериске> что то типа mts1 из строчки Dongle/mts1 в диалплане
                #все ID я брал из сайта с помощью FireBug
                #дл примера  '111111':'mts1'
               '<конкретный_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()

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
  };
}