🥇स्वतः तरतूद करणे Yealink T19 + डायनॅमिक अॅड्रेस बुक

जेव्हा मी या कंपनीसाठी काम करण्यासाठी आलो, तेव्हा माझ्याकडे आधीच काही IP उपकरणांचा डेटाबेस, तारांकन असलेले अनेक सर्व्हर आणि फ्रीबीपीएक्सच्या रूपात पॅच होते. याव्यतिरिक्त, एनालॉग पीबीएक्स सॅमसंग आयडीसीएस 500 समांतरपणे कार्य केले आणि सर्वसाधारणपणे, कंपनीतील मुख्य संप्रेषण प्रणाली होती; आयपी टेलिफोनी केवळ विक्री विभागासाठी कार्य करते. आणि सर्व काही असेच शिजत राहिले असते, परंतु एका चांगल्या दिवशी प्रत्येकाला आयपी टेलिफोनीवर हस्तांतरित करण्याचा हुकूम देण्यात आला, मुदती मान्य केल्या गेल्या, उपकरणे खरेदी केली गेली आणि 21 व्या शतकात एंटरप्राइझ हस्तांतरित करण्याची योजना अंमलात आणली जाऊ लागली.
अशा परिस्थितीत पहिली गोष्ट जी काळजी करू लागते ती म्हणजे झपाट्याने वाढणाऱ्या टेलिफोन संचांची संख्या ज्यांना कसे तरी व्यवस्थापित करणे आवश्यक आहे, दुसरी गोष्ट जी खूप चिंताजनक होती ती म्हणजे फोन बुक. जर एंडपॉईंट मॅनेजर आम्हाला पहिल्यामध्ये मदत करू शकला (जे, तसे, फ्रीपीबीएक्सच्या नवीनतम आवृत्त्यांमधून कापले गेले), तर पुस्तकात काही प्रश्न उद्भवले:

प्रथम, वापरकर्त्यांचे स्थान/तरलता सतत बदलत असताना त्याची अचूकता कशी सुनिश्चित करावी?
दुसरे म्हणजे, फोन पूर्णपणे वैयक्‍तिक कसे करायचे. आणि प्रत्येक वेळी संपर्काचे नाव भरायचे नाही?

समस्या मनोरंजक होती, समाधान येण्यास वेळ लागला नाही. आता मी संपूर्ण यादी देईन, आणि नंतर आम्ही ते क्रमाने पाहू.

from scapy.all import sniff
from scapy.layers.inet import IP
import mysql.connector
import ldap
import getpass
import tftpy
import requests
import os
import time
from string import replace

def conn_ldap(login):
    ad = ldap.initialize('ldap://***.local')
    ad.simple_bind_s('voip@***.local', 'password')
    basedn = 'OU=IT,DC=***,DC=LOCAL'
    basedn_user = 'OU=***,OU=***,DC=***,DC=LOCAL'
    scope = ldap.SCOPE_SUBTREE
    filterexp = "(&(sAMAccountName=" + login + ")(ObjectClass=person))"
    filterexp2 = "(&(ObjectClass=organizationUnit))"
    attrlist = ['cn']
    attrlist2 = ['OU']
    search = ad.search_s(basedn, scope, filterexp, attrlist)
    adname = search[0][1]['cn'][0].decode('utf-8')
    if adname == ' ':
        search = ad.search_s(basedn_user, scope, filterexp2, attrlist2)
        for i in range(1, len(search)+1):
            group = search[i][1]['ou'][0]
            basedn_user2 = 'OU='+group+','+basedn_user
            search = ad.search_s(basedn_user2, scope, filterexp, attrlist)
            adname = search[0][1]['cn'][0].decode('utf-8')
            if adname != ' ':
                return adname
        adname = search[0][1]['cn'][0].decode('utf-8')
    ad.unbind_s()
    return adname


def tftp_file_change(config,place,adname,current_account,current_account_password):

    client = tftpy.TftpClient("192.168.0.3", 69)
    client.download('template.cfg', place)
    fileread = open(place, 'r')
    line = fileread.readlines()
    fileread.close()
    line[5] = (('account.1.label = ').encode('utf-8') + adname.encode('utf-8') + 'n')
    line[2] = (('account.1.auth_name = ').encode('utf-8') + current_account.encode('utf-8') + 'n')
    line[3] = (('account.1.display_name = ').encode('utf-8') + current_account.encode('utf-8') + 'n')
    line[6] = (('account.1.password = ').encode('utf-8') + current_account_password[0][0] + 'n')
    filewrite = open(place, 'w')
    for i in line:
      filewrite.write(i)
    filewrite.close()
    print place
    print config
    client.upload(config,place)


def get_phone_inform(ipaddr):
    fileconf = requests.get('http://admin:admin@'+ipaddr+'/servlet?phonecfg=get[&accounts=1]')
    conf = fileconf.text.split('|')
    current_account = conf[2]
    return current_account


def sniff_frame():
    pcapf = sniff(count=1, timeout=70, filter="dst host 192.168.0.3 and port 5060")
    if len(pcapf) == 0:
        exit()
    frame = pcapf[0]
    macaddr = frame.src
    print macaddr[:8]
    if macaddr[:8] != '80:5e:c0':
        exit()
    ipaddr = frame[0][IP].src
    return macaddr, ipaddr


def conn_mysql(query,fquery,macaddr,qwery2):
    connect = mysql.connector.connect(host='192.168.0.3', database='voip', user='voip_wr', password='***')
    cursor = connect.cursor()
    cursor.execute(fquery)
    state = cursor.fetchall()
    state = bool(state[0][0])
    if state == True:
        cursor.execute(qwery2)
        connect.commit()
        connect.close()
    else:
        cursor.execute(query)
        connect.commit()
        connect.close()


def check_account(current_account):
    connect = mysql.connector.connect(host='192.168.0.3', database='asterisk', user='voip_wr', password='***')
    cursor = connect.cursor()
    qwery = 'select data from sip where id=' + current_account + ' and keyword="secret";'
    cursor.execute(qwery)
    password = cursor.fetchall()
    if password == ' ':
        exit()
    else:
        return password


if __name__ == '__main__':
    macaddr, ipaddr = sniff_frame()
    current_account = get_phone_inform(ipaddr)
    current_account_password = check_account(current_account)
    macaddr = macaddr.replace(':', '')
    ipaddr = ipaddr.decode('utf-8')
    adname = conn_ldap(getpass.getuser())
    query = 'INSERT INTO station (mac, ip, name, number) VALUES (' + '"' + macaddr + '",' + '"' + ipaddr + '",' + '"' + adname + '",' + '"' + get_phone_inform(ipaddr) + '"' + ')'
    qwery2 = 'UPDATE station SET ip=' + '"' + ipaddr + '"' + ', name=' + '"' + adname + '"' + ', number=' + '"' + get_phone_inform(ipaddr) + '"' + ' WHERE mac=' + '"' + macaddr + '"'
    fquery = 'SELECT EXISTS(SELECT mac FROM voip.station WHERE mac=' + '"' + macaddr + '")'
    query = query.encode('utf-8')
    fquery = fquery.encode('utf-8')
    config = macaddr + '.cfg'
    place = os.path.expanduser("~") + "" + "AppDataLocal" + config
    conn_mysql(query,fquery,macaddr,qwery2)
    tftp_file_change(config,place,adname,current_account,current_account_password)
    requests.get('http://admin:admin@'+ipaddr+'/cgi-bin/ConfigManApp.com?key=AutoP')
    requests.get('http://admin:admin@'+ipaddr+'/cgi-bin/ConfigManApp.com?key=Reboot')

प्रोग्राम वापरकर्त्याच्या संगणकावर चालतो आणि संगणक फोनद्वारे नेटवर्कशी कनेक्ट केलेला असल्यास कार्य करतो, कारण Yealink T19 गेटवे म्हणून काम करू शकत नाही.

प्रथम, आपण ते कनेक्ट केलेले आहे की नाही हे समजून घेणे आवश्यक आहे? आणि आमच्या फोनमध्ये काय मॅक आणि आयपी आहे.

def sniff_frame():
    pcapf = sniff(count=1, timeout=70, filter="dst host 192.168.0.3 and port 5060")
    if len(pcapf) == 0:
        exit()
    frame = pcapf[0]
    macaddr = frame.src
    print macaddr[:8]
    if macaddr[:8] != '80:5e:c0':
        exit()
    ipaddr = frame[0][IP].src
    return macaddr, ipaddr

येथे आम्ही स्कॅपी फ्रेमवर्कमधून स्निफ फंक्शन वापरतो, त्याच्या मदतीने आम्हाला पूर्वनिर्धारित udp पॅकेट मिळते, 70 सेकंद थांबा आणि आम्हाला काहीही पकडले नाही तर आम्ही बाहेर पडतो.

count=1, timeout=70, filter="dst host 192.168.0.3 and port 5060"

पुढे, आम्ही खात्री करतो की डिव्हाइस खरोखरच येलिंक आहे आणि आवश्यक मूल्ये (ip आणि mac) परत करतो.

विशेष विनंती वापरून, आम्ही फोनवर चालू खाते शोधतो. हे करण्यासाठी, वर्तमान कॉन्फिगरेशन फोनवरून डाउनलोड केले जाते आणि विश्लेषित केले जाते.

def get_phone_inform(ipaddr):
    fileconf = requests.get('http://admin:admin@'+ipaddr+'/servlet?phonecfg=get[&accounts=1]')
    conf = fileconf.text.split('|')
    current_account = conf[2]
    return current_account

या खात्याचा पासवर्ड शोधा. हे करण्यासाठी, आम्ही asterisk.sip टेबल आणि त्यातील डेटा फील्डकडे वळतो.

def check_account(current_account):
    connect = mysql.connector.connect(host='192.168.0.3', database='asterisk', user='voip_wr', password='***')
    cursor = connect.cursor()
    qwery = 'select data from sip where id=' + current_account + ' and keyword="secret";'
    cursor.execute(qwery)
    password = cursor.fetchall()
    if password == ' ':
        exit()
    else:
        return password

बरं, अंतिम टप्प्यासाठी आम्ही ldap AD शी कनेक्ट करतो आणि फंक्शनद्वारे प्राप्त केलेले sAMAccountName वापरतो. getpass.getuser() वर्तमान वापरकर्त्याचे सीएन घ्या (ज्यामध्ये सहसा वापरकर्त्याचे पूर्ण नाव असते).

def conn_ldap(login):
    ad = ldap.initialize('ldap://***.local')
    ad.simple_bind_s('voip@***.local', 'password')
    basedn = 'OU=***,DC=***,DC=LOCAL'
    basedn_user = 'OU=***,OU=***,DC=***,DC=LOCAL'
    scope = ldap.SCOPE_SUBTREE
    filterexp = "(&(sAMAccountName=" + login + ")(ObjectClass=person))"
    filterexp2 = "(&(ObjectClass=organizationUnit))"
    attrlist = ['cn']
    attrlist2 = ['OU']
    search = ad.search_s(basedn, scope, filterexp, attrlist)
    adname = search[0][1]['cn'][0].decode('utf-8')
    if adname == ' ':
        search = ad.search_s(basedn_user, scope, filterexp2, attrlist2)
        for i in range(1, len(search)+1):
            group = search[i][1]['ou'][0]
            basedn_user2 = 'OU='+group+','+basedn_user
            search = ad.search_s(basedn_user2, scope, filterexp, attrlist)
            adname = search[0][1]['cn'][0].decode('utf-8')
            if adname != ' ':
                return adname
        adname = search[0][1]['cn'][0].decode('utf-8')
    ad.unbind_s()
    return adname

आम्ही डेटाबेसमधील पूर्व-निर्मित टेबलशी कनेक्ट करतो (मी ते तेथे तयार केले आहे) आणि आम्ही शिकलेल्या सर्व गोष्टी प्रविष्ट करतो, म्हणजे: ip, mac, वापरकर्तानाव.

def conn_mysql(query,fquery,macaddr,qwery2):
    connect = mysql.connector.connect(host='192.168.0.3', database='voip', user='voip_wr', password='***')
    cursor = connect.cursor()
    cursor.execute(fquery)
    state = cursor.fetchall()
    state = bool(state[0][0])
    if state == True:
        cursor.execute(qwery2)
        connect.commit()
        connect.close()
    else:
        cursor.execute(query)
        connect.commit()
        connect.close()

आम्ही येथे थांबू शकतो, कारण आम्ही आधीच डायनॅमिक अॅड्रेस बुक तयार केले आहे, तुम्ही विचारू शकता, परंतु मी पुढे जाऊन येथे डिव्हाइसेसची स्वयं-तरतुदी जोडली.

हे करण्यासाठी, पूर्व-कॉन्फिगर केलेल्या tftp सर्व्हरवरून टेम्पलेट कॉन्फिगरेशन डाउनलोड केले जाते, ज्यामध्ये आम्ही आमचे बदल करतो आणि ते mac.cfg म्हणून सेव्ह करतो. म्हणजेच, येलिंकसाठी कॉन्फिगरेशनचे दोन प्रकार आहेत, एक जागतिक आहे आणि दुसरे विशिष्ट फोनला लागू होते आणि ते mac_phone.cfg स्वरूपाचे असावे.

फाईलमधील सर्व बदल केल्यानंतर आणि ती tftp सर्व्हरवर परत सेव्ह केल्यानंतर, आम्ही फोनला डिव्हाइसची तरतूद आणि रीबूट करण्याची आज्ञा देतो.

def tftp_file_change(config,place,adname,current_account,current_account_password):

    client = tftpy.TftpClient("192.168.0.3", 69)
    client.download('template.cfg', place)
    fileread = open(place, 'r')
    line = fileread.readlines()
    fileread.close()
    line[5] = (('account.1.label = ').encode('utf-8') + adname.encode('utf-8') + 'n')
    line[2] = (('account.1.auth_name = ').encode('utf-8') + current_account.encode('utf-8') + 'n')
    line[3] = (('account.1.display_name = ').encode('utf-8') + current_account.encode('utf-8') + 'n')
    line[6] = (('account.1.password = ').encode('utf-8') + current_account_password[0][0] + 'n')
    filewrite = open(place, 'w')
    for i in line:
      filewrite.write(i)
    filewrite.close()
    print place
    print config
    client.upload(config,place)

requests.get('http://admin:admin@'+ipaddr+'/cgi-bin/ConfigManApp.com?key=AutoP')
requests.get('http://admin:admin@'+ipaddr+'/cgi-bin/ConfigManApp.com?key=Reboot')

डिव्हाइस रीबूट केल्यानंतर, आम्हाला फोन स्क्रीनवर आमचे पूर्ण नाव मिळते + डेटाबेसच्या रूपात नेहमी योग्यरित्या भरलेले अॅड्रेस बुक, त्यानंतर सामग्री डायनॅमिकपणे प्रदर्शित करण्यासाठी XML आणि थोडे PHP जोडणे बाकी आहे. अशी बरीच उदाहरणे आहेत, अगदी YEALINK मध्ये देखील आहेत.

PS: अधिक स्केलेबिलिटीसाठी, तुम्ही मुख्य सेटिंग्ज (व्हेरिएबल्स) वेगळ्या फाइलमध्ये हलवू शकता.

स्त्रोत: www.habr.com

ऑटो प्रोव्हिजनिंग येलिंक T19 + डायनॅमिक अॅड्रेस बुक

एक टिप्पणी जोडा Отменить ответ