1С + asterisk (автоматический обзвон) часть 1

здравствуйте, вас беспокоит система контроля качества компании , 
... на этой неделе вы посещали , если вам все
 понравилось, просим нажать 1, если у вас есть замечания нажмите 2 и мы 
соединим с оператором, нажмите 0 - ... и тд

https://tts.voicetech.yandex.net/generate?text=здравствуйте!%20вас%20беспокоит%20система%20контрол
....&format=mp3&lang=ru-RU&speaker=oksana&emotion=good&key=46e933b8-30aa-4383-3&speed=0.9

[ng_ext_autodial]
exten => _X.,1,Verbose(0,=> Outbound  :  ${CALLERID(num)}        =>  ${EXTEN})
 same  => n,Dial(SIP/ng_ext/${EXTEN},,M(after-up,${file_name}))

 [macro-after-up]
exten => s,1,Wait(0.2) 
 same => n,Goto(retry)
 same => n(retry),NoOp
 same => n,Read(var_a,${ARG1},1,,,10)
 same => n,GotoIf($[${var_a} == 0]?press_zero)
 same => n,GotoIf($[${var_a} == 1]?press_one)
 same => n,GotoIf($[${var_a} == 2]?press_two)
 same => n,Goto(retry)
 
; same => n(press_any),NoOp
; same => n,SayNumber(${var_a})
; same => n,Goto(exit)
  
 same => n(press_zero),NoOp
 same => n,Goto(exit)
 same => n(press_one),NoOp
 same => n,Goto(exit)
 same => n(press_two),NoOp
 same => n,Playback(/usr/local/share/asterisk/moh//auto/connect)
 same => n,Playback(/usr/local/share/asterisk/moh//auto/sps)
 same => n,Dial(SIP/ng_ext/8345XXXXXXXX,,tT)
 same => n,Goto(exit)
 
 same => n(exit),NoOp

from http.server import HTTPServer, BaseHTTPRequestHandler
from socketserver import ThreadingMixIn
from common import ami_client
import sys
from common import common

class ThreadedHTTPServer(ThreadingMixIn, HTTPServer):
    """Handle requests in a separate thread."""

if __name__ == '__main__':
    parser = common.createParser()
    namespace = parser.parse_args(sys.argv[1:])
    api_ones_serv = ami_client.AmiClient()
    server = ThreadedHTTPServer((namespace.ip, int(namespace.port)), ami_client.AmiClient_Handler)
    print('starting ami client server '+str(namespace.ip)+':'+str(namespace.port)+' (use <Ctrl-C> to stop)')
    server.serve_forever()

from http.server import HTTPServer, BaseHTTPRequestHandler
import json

from urllib.parse import urlparse, parse_qs

from common import common

import sys


from common import api_func, path_list

class AmiClient_Exception(Exception):
    pass

class AmiClient_Handler(BaseHTTPRequestHandler):
    callback = None

    def log_message(self, format, *args):
        return

    def smart_response(self, code, message, headers = []):
        self.send_response(code)
        for h, v in headers:
            self.send_header(h, v)

        self.send_header("Content-type", "text/plain; charset=utf-8")

        self.end_headers()
        if (code != 200):
            print(message)
            message = message

        return self.wfile.write(message.encode())

    def do_GET(self):
        path = urlparse(self.path).path
        qs = urlparse(self.path).query
        qs = parse_qs(qs)
        
        res = self.callback(path, qs, self)

class AmiClient():
    server = None
    parser = common.createParser()
    namespace = parser.parse_args(sys.argv[1:])
    
    server_host = namespace.ip
    server_port = int(namespace.port)
        
    handler = AmiClient_Handler

    pathmap = {}
    
    def __init__(self, caller = None):
        self.init_pathmap()
        #self.init_post_proc_func()
        self.handler.callback = self.callback
        #_thread.start_new_thread(self.upd_loop, ())

    def register(self, method, path, function):
        self.pathmap[path] = function
    
    def register_post_proc_func(self, method, path, function):
        self.pathmap[path] = function
    
    def callback(self, path, qs, handler):
        while path and path[0] == '/':

            func = self.pathmap.get(path)
            if func is None:
                return handler.smart_response(404, "Не найден метод: "+str(path))
            
            try:
                res = func(qs)
            except KeyError as e:
                return handler.smart_response(500, "Не задано значение параметра: %s" % e)
            except ValueError as e:
                return handler.smart_response(500, "Ошибка в значении параметра: %s" % e)
            except AmiClient_Exception as e:
                return handler.smart_response(500, "%s" % e)
            except Exception as e:
                return handler.smart_response(500, "Неожиданная ошибка: %s" % e)

            content_type = "application/json"

            if not res:
                res = json.dumps([], default=common.json_serial)

            else:
                res = json.dumps(res, default=common.json_serial)

            try:
                handler.smart_response(200, res, [
                    ("Content-type", content_type),
                    ("Access-Control-Allow-Origin", "*"),
                    ("Access-Control-Expose-Headers", "Access-Control-Allow-Origin"),
                    ("Access-Control-Allow-Headers", "Origin, X-Requested-With, Content-Type, Accept"),
                ])
            except socket.error as e:
                pass

            return
        else:
            handler.smart_response(401, "Unauthorized call: %s from %s" % (path, client_address))
  
    def init_pathmap(self):
        for x in path_list.get():
            self.register(x['method'], x['func'], x['handler'])

import datetime

from common import common

import os
import time
from asterisk.ami import AMIClient, AMIClientAdapter
import socket
import re
from common.conf import * 


d = {'channel':'', 'channel2':'', 'DTMF':'', 'status':'', 'log':''}


#region interfaces_func

def make_call_auto(param):
    tel = kwargs_get(param, 'tel')
    file = kwargs_get(param, 'file')
    
    client = AMIClient(address=AMI_ADDRESS, port=AMI_PORT)
    future = client.login(username=AMI_USER, secret=AMI_SECRET)

    if future.response.is_error():
        raise Exception(str(future.response))

    adapter = AMIClientAdapter(client)

    channel = f'Local/{tel}@ng_ext_autodial'
    d['channel'] = channel

    action_id = tel

    variable = FILE_NAMES[file]

    client.add_event_listener(event_listener)

    #res_call = simple_call_without_oper(channel, data)
    res_call = simple_call_without_oper(adapter, channel, DATA, APP, action_id, variable, tel)

    while True:
        if d['status']=='Error':
            break
        elif d['status']=='ANSWER':
            break
        elif d['status']=='BUSY':
            break
        elif d['status']=='Success':
            break
        if not res_call.response is None:
            d['status'] = res_call.response.status
        time.sleep(0.2)

    client.logoff()

    #print(d['DTMF'])
    #print(d['status'])

    return d

#endregion

#region internal_func_bp

def simple_call_with_oper(channel, exten, caller_id, caller_id_name, action_id, timeout='', context='ng_ext_autodial', priority=1):
    res = adapter.Originate(Channel=channel, Context=context, Exten=exten, ActionID=action_id, Priority=priority,  CallerID=caller_id, CallerIDName=caller_id_name, Timeout=timeout, _callback=callback_response)

    return res

def simple_call_without_oper(adapter, channel, data, app, action_id, variable = '', exten='', timeout='45000', context='ng_ext_autodial'):
    res = adapter.Originate(Channel=channel, Context=context, Application=app, Exten=exten, ActionID=action_id,  Data=data, Timeout=timeout, _callback=callback_response, Variable=variable)

    return res

def callback_response(response):
    if response.status=='Error':
        d['status'] = 'Error'

    return None

def event_listener(event,**kwargs):
    #print('"%s" "%s" \n \r' % (event.name, str(event)))
    if 'DTMF' in event.name:
        if d['channel2'] in event.keys['Channel']:
            d['DTMF'] = event.keys['Digit']
            d['log'] += str(event)

    if not event.keys.get('Channel') is None:
        if d['channel'] in event.keys['Channel']:
            d['log'] += str(event)
            if 'Dial' in event.name:
                d['channel2'] = event.keys['Destination']
            elif 'VarSet' in event.name:
                if event.keys['Variable']=='DIALSTATUS':
                    d['status'] = event.keys['Value']

    return None

#endregion

def kwargs_get(qs, key, default=None):
    res, *junk = qs.get(key, (default,))
    if default is None and res is default:
        raise KeyError(key)
    return res

from common import api_func

def get():

    reg_path_list = []

    reg_path_list.append({'method':'GET', 'func':'/make_call_auto', 'handler':api_func.make_call_auto})

    return reg_path_list

AMI_SECRET = 'secret' 
AMI_USER = 'usr'
AMI_PORT = 5038 
AMI_ADDRESS = '192.168.10.19' 


APP = 'PlayBack'
DATA = '/usr/local/share/asterisk/moh//auto/sps'


FILE_NAMES = {'kia':'file_name=/usr/local/share/asterisk/moh//auto/auto_kia', 
              'ford':'file_name=/usr/local/share/asterisk/moh//auto/auto_ford', 
              'renault':'file_name=/usr/local/share/asterisk/moh//auto/auto_renault'}

	ТелоЗапроса = "tel="+tel+"&file="+file; 
	
	Сервер = "";
	ПортСервера = "";
	ТаймАут = 0;
	
	Соединение = Новый HTTPСоединение(Сервер, ПортСервера,,,,ТаймАут);
	
	Запрос = Новый HTTPЗапрос("/make_call_auto?"+ТелоЗапроса);
	
	Попытка
		
		Результат = Соединение.Получить(Запрос);
		
	Исключение
		
		
	КонецПопытки;
	
	Сообщить(Результат.ПолучитьТелоКакСтроку());

	
	РезультатЗапроса = Запрос.Выполнить();
	
	ВыборкаДетальныеЗаписи = РезультатЗапроса.Выбрать();
	
	Пока ВыборкаДетальныеЗаписи.Следующий() Цикл
		
		file = получить имя файла для бэка
		
		Если file=Неопределено Тогда 
			Продолжить;
		КонецЕсли;
		
		ТелоЗапроса = "tel="+ВыборкаДетальныеЗаписи.Телефон+"&file="+file; 
		
		Сервер = ";
		ПортСервера = "";
		ТаймАут = 60*5;
		
		Соединение = Новый HTTPСоединение(Сервер, ПортСервера,,,,ТаймАут);
		
		Запрос = Новый HTTPЗапрос("/make_call_auto?"+ТелоЗапроса);
		
		Попытка
			
			Результат = Соединение.Получить(Запрос);
			
		Исключение
			
			Продолжить;
			
		КонецПопытки;
		
		СтрокаДжейсон = Результат.ПолучитьТелоКакСтроку();
		
		Данные = JSON.лПрочитатьJSON(СтрокаДжейсон,,,Истина);

... логика обработки

		Логи.ЗафиксироватьИнформацию("Автообзвон", СтрокаДжейсон);
		
	КонецЦикла;
	

			...

			ОбъектHTTP = СоздатьОбъект("WinHttp.WinHttpRequest.5.1");
	
		    ОбъектHTTP.Open("GET", ТелоЗапроса);
				
			Рез = ОбъектHTTP.Send(); 
            
            ...