Запись входящих звонков26.05.2016 10:33

def fastAgiMain( agi ):
    sequence = fastagi.InSequence()
    # Указываем какие переменные необходимо получить.
    cdr_vars = {
            'CDR(start)':'',
            'CDR(disposition)}':'',
            'CDR(duration)':'',
            'CDR(end)':'',
            'DIALSTATUS':'',
            }
    # Получаем информацию и там же отправляем её в easla.com в отдельном потоке
    sequence.append(sendCDR, None, agi, cdr_vars, iter(cdr_vars))
    # После возвращаем упроавление в asterisk
    sequence.append(agi.finish)
    def onFailure( reason ):
        log.error( "Failure: %s", reason.getTraceback())
        agi.finish()
    return sequence().addErrback( onFailure )

# Рекурсивная функция, которая получает все переменные указанные в cdr_vars
def sendCDR(result, agi, cdr_vars, keys):

    def setVar(result, key):
        cdr_vars[key] = result

    def notAvailable(reason, key):
        print "key " + key + " not found"

    try:
        key = keys.next()
    except StopIteration, err:
        duration = str(timedelta(seconds=int(cdr_vars['CDR(duration)'])))
        # Не используя getVariable можно получить callerid и uniqueid
        caller_id = agi.variables['agi_callerid']
        wav_file = '/data/wav/' + agi.variables['agi_uniqueid'] + '.wav'
        status = cdr_vars['DIALSTATUS']
        # В отдельном потоке отправляем информацию о звонке
        thread = Thread(target=sendCallInfo, args=(caller_id, duration, wav_file, status))
        thread.start()
        return None
    else:
        return agi.getVariable(key) \ # Получаем переменную key
                        .addCallback(setVar, key) \ # Записываем её в cdr_vars
                        .addErrback(notAvailable, key) \ # Если ошибка во время получения переменной key
                        .addCallback(sendCDR, agi, cdr_vars, keys) # Вызываем себя еще раз

def sendCallInfo(callid, callduration, wav_file ,status):
    raw_params = {
        'incoming_call_number': callid,
        'incoming_call_time': callduration,}
    if status:
        if status == 'ANSWER':
            raw_params['status'] = 'incoming_call_answered'
        if status == 'BUSY':
            raw_params['status'] = 'incoming_call_busy'
        if status == 'NOANSWER':
            raw_params['status'] = 'incoming_call_unanswered'
        if status == 'CANCEL':
            raw_params['status'] = 'incoming_call_unanswered'
        if status == 'CONGESTION':
            raw_params['status'] = 'incoming_call_congestion'

    url = 'http://easla.com/user/soap'
    client = Client(url)
    client.service.login('login','password')

    call_management_proc = client.service.getProcess('call_management')
    incoming_call_def = client.service.getObjectdef(call_management_proc,
            'incoming_call', 0)

    keyval_array = client.factory.create('KeyValuesPairSoapArray')
    # Наполняем массив KeyValuesPairSoapArray для отправки в easla.com
    for key, value in raw_params.iteritems():
        keyval = client.factory.create('KeyValuesPairSoap')
        keyval.key = key
        keyval.values.item.append(value)
        keyval_array.item.append(keyval)

    # Создаем объект входящий звонок в easla.com
    incoming_call_obj = client.service.createObjectref(incoming_call_def,
            None, keyval_array)

    if os.path.exists(wav_file):
        # asterisk может еще не освободить файл
        while is_locked(wav_file):
            time.sleep(1)

        mp3_file = wav2mp3(wav_file)
        with open(mp3_file, "rb") as image_file:
            encoded_string = base64.b64encode(image_file.read())

        if encoded_string:
            # Создаем атрибут в котором будет лежать mp3 файл
            file_attr = client.factory.create('KeyValuePairSoapArray')
            file_name = client.factory.create('KeyValuePairSoap')
            file_content = client.factory.create('KeyValuePairSoap')
            file_name.key = 'srcname'
            file_name.value = os.path.basename(mp3_file)
            file_content.key = 'content'
            file_content.value = encoded_string
            file_attr.item.append(file_name)
            file_attr.item.append(file_content)
            # Добавляем атрибут к объекту
            client.service.addFile(incoming_call_obj, 'incoming_call_file',
                        file_attr)
            if wav_file:
                os.remove(wav_file)
            if mp3_file:
                os.remove(mp3_file)