Asterisk. Интеграция с amoCRM, step-by-step guid

server {     server_name asterisk.vistep.ru;     listen 138.201.164.52:80;     rewrite ^  https://asterisk.vistep.ru$request_uri? permanent; } server {     access_log /var/log/nginx/asterisk.vistep.ru.access.log;     error_log /var/log/nginx/asterisk.vistep.ru.error.log;     listen 443 ssl;     server_name asterisk.vistep.ru;     resolver 8.8.8.8;     ssl_stapling on;     ssl on;     ssl_certificate /etc/nginx/certs/vistep.ru.pem;     ssl_certificate_key /etc/nginx/certs/vistep.ru.key;     ssl_dhparam /etc/nginx/certs/dhparam.pem;     ssl_session_timeout 24h;     ssl_session_cache shared:SSL:2m;     ssl_protocols TLSv1 TLSv1.1 TLSv1.2;     ssl_ciphers kEECDH+AES128:kEECDH:kEDH:-3DES:kRSA+AES128:kEDH+3DES:DES-CBC3-SHA:!RC4:!aNULL:!eNULL:!MD5:!EXPORT:!LOW:!SEED:!CAMELLIA:!IDEA:!PSK:!SRP:!SSLv2;     ssl_prefer_server_ciphers on;     add_header Strict-Transport-Security "max-age=31536000;";     add_header Content-Security-Policy-Report-Only "default-src https:; script-src https: 'unsafe-eval' 'unsafe-inline'; style-src https: 'unsafe-inline'; img-src https: data:; font-src https: data:; report-uri /csp-report"; 	root /var/www/asterisk; 	index index.php index.html index.htm index.nginx-debian.html;      location records/ {     autoindex off;     allow 89.108.120.223;         allow 89.108.122.9;         allow 95.213.171.78;         allow 95.213.156.46;         allow 209.160.27.20;         allow 89.189.163.20; # адреса выше - адреса amoCRM и они нужны, а этот - мой домашний, не нужно его вставлять в конфиг ;) актуальный список адресов - https://www.amocrm.ru/security/iplist.txt     deny all; }   	location / { 		try_files $uri $uri/ =404;         allow 89.108.120.223;          allow 89.108.122.9;         allow 95.213.171.78;         allow 95.213.156.46;         allow 209.160.27.20;         allow 89.189.163.20; # адреса выше - адреса amoCRM и они нужны, а этот - мой домашний, не нужно его вставлять в конфиг ;) актуальный список адресов - https://www.amocrm.ru/security/iplist.txt 	deny all; 	} 	location ~ \.php$ { 	        fastcgi_pass unix:/var/run/php5-fpm.sock; 	       	fastcgi_index index.php; 	        fastcgi_param SCRIPT_FILENAME $document_root$fastcgi_script_name; 	        include fastcgi_params; 		fastcgi_buffers 16 16k;  		fastcgi_buffer_size 32k; 	} } 

openssl dhparam -out /etc/nginx/certs/dhparam.pem 4096 

 [general] enabled = yes port = 5038 bindaddr = 0.0.0.0 webenabled = yes httptimeout = 60 debug = on  [amocrm] secret = JD3clEB8f4-_3ry84gJ deny = 0.0.0.0/0.0.0.0 permit = 127.0.0.1/255.255.255.0 read = cdr,reporting,originate write = reporting,originate 

 [general] enabled=yes enablestatic=yes bindaddr=0.0.0.0 bindport=8088 prefix=asterisk 

Global Settings:
----------------
Manager (AMI): Yes
Web Manager (AMI/HTTP): Yes
TCP Bindaddress: 0.0.0.0:5038
HTTP Timeout (minutes): 60
TLS Enable: No
TLS Bindaddress: Disabled
TLS Certfile: asterisk.pem
TLS Privatekey:
TLS Cipher:
Allow multiple login: Yes
Display connects: Yes
Timestamp events: No
Channel vars:
Debug: Yes

globals {     WAV=/var/calls; //Временный каталог с WAV     MP3=/var/calls; //Куда выгружать mp3 файлы     RECORDING=1; // Запись, 1 - включена. };  macro recording (calling,called) {         if ("${RECORDING}" = "1"){               Set(fname=${UNIQUEID}-${STRFTIME(${EPOCH},,%Y-%m-%d-%H_%M)}-${calling}-${called}); 	      Set(datedir=${STRFTIME(${EPOCH},,%Y/%m/%d)}); 	      System(mkdir -p ${WAV}/${datedir});               Set(monopt=nice -n 19 /usr/bin/lame -b 32  --silent "${WAV}/${datedir}/${fname}.wav"  "${MP3}/${datedir}/${fname}.mp3" && chmod o+r "${MP3}/${datedir}/${fname}.*");               Set(CDR(filename)=${fname}.mp3); 	      Set(CDR(recordingfile)=${fname}.wav);               Set(CDR(realdst)=${called});               MixMonitor(${WAV}/${datedir}/${fname}.wav,b,${monopt});         }; };   context dial_out { // звоним друг другу _[71]XX => {         &recording(${CALLERID(number)},${EXTEN});         Dial(SIP/${EXTEN},,tTr);         Hangup();         }  // кому позвонить решит amoCRM! 100500 => {         Set(DEFMAN=123); // по умолчанию звоним на 123         Set(TOEXT=${SHELL(wget -O - --quiet "https://vistepru.amocrm.ru/private/acceptors/asterisk_new/?redirect=Y&number=${CALLERID(num)}&USER_LOGIN=ceo@vistep.ru&USER_HASH=1dc1444b0d3172c1113ffea9078c575c")}); // получаем номер ответственного менеджера         Dial(SIP/${TOEXT},,tTr); // звоним ответственному менеджеру // если он не отвечает или ошибка, звоним на номер по умолчанию         if ("${DIALSTSTUS}" != "ANSWERED") {             Dial(SIP/${DEFMAN},,tTr);         }         HangUP(); } // end 100500  _XXXXXX => { NoOP(=== CALL FROM ${CALLERID(number)} TO ${EXTEN} ===); &recording(${CALLERID(number)},${EXTEN}); Dial(SIP/83843${EXTEN}@multifon,180,tT); HangUP(); } // end of _XXXXXX  _[78]XXXXXXXXXX => { NoOP(=== CALL TO ${EXTEN} ===); &recording(${CALLERID(number)},${EXTEN}); Dial(SIP/${EXTEN}@multifon,180,tT); HangUP(); }// end of _[78]XXXXXXXXXX   _+7XXXXXXXXXX => { NoOP(=== CALL TO ${EXTEN} ===); &recording(${CALLERID(number)},${EXTEN}); Dial(SIP/${EXTEN}@multifon,180,tT); HangUP(); }// end of _+7XXXXXXXXXX   //все остальные звонки, не прописанные выше, идут в лес _X. => {         Hangup();         }  }   context default { // в контексте по умолчанию все отправляется лесом _X. => {         Hangup();         } };    context incoming { _[87]XXXXXXXXXX => { 	&recording(${CALLERID(number)},${EXTEN}); 	Answer(); 	Set(CHANNEL(musicclass)=vistep.ru); 	Set(CUSTOMER_NAME=${SHELL(wget -O - --quiet  "https://vistepru.amocrm.ru/private/acceptors/asterisk_new/?number=${CALLERID(num)}&USER_LOGIN=ceo@vistep.ru&USER_HASH=1dc1444b0d3172c1113ffea9078c575c"|cut -d "|" -f1)}); 	Set(CALLERID(name)=${CUSTOMER_NAME}); 	Queue(queue_1,tT); 	NoOp(=== ${HANGUPCAUSE} ===); 	HangUP(); } } 

 // кому позвонить решит amoCRM! 100500 => {         Set(DEFMAN=123); // по умолчанию звоним на 123         Set(TOEXT=${SHELL(wget -O - --quiet "https://vistepru.amocrm.ru/private/acceptors/asterisk_new/?redirect=Y&number=${CALLERID(num)}&USER_LOGIN=ceo@vistep.ru&USER_HASH=1dc1444b0d3172c1113ffea9078c575c")}); // получаем номер ответственного менеджера         Dial(SIP/${TOEXT},,tTr); // звоним ответственному менеджеру // если он не отвечает или ошибка, звоним на номер по умолчанию         if ("${DIALSTSTUS}" != "ANSWERED") {             Dial(SIP/${DEFMAN},,tTr);         }         HangUP(); } // end 100500 

<?php /* 	amoCRM to  asterisk integration. 	QSOFT LLC,  All rights reserved. 	mailto:      support@amocrm.com. 	Date:   10.04.2012   rev: 102703 	Cannot be redistributed  without 	     a written permission.                          _____ _____  __  __                         / ____|  __ \|  \/  |    __ _ _ __ ___   ___ | |    | |__) | \  / |   / _` | '_ ` _ \ / _ \| |    |  _  /| |\/| |  | (_| | | | | | | (_) | |____| | \ \| |  | |_   \__,_|_| |_| |_|\___/ \_____|_|  \_\_|  |_(_)     */ ini_set('log_errors','On'); ini_set('error_log', '/var/log/php_errors.log'); define('AC_HOST','localhost'); // где слушает  AMI/AJAM define('AC_PORT',8088); // какой порт слушает (у нас 8088) см. http.conf Asterisk'а define('AC_PREFIX','/asterisk/'); // см. http.conf Asterisk'а define('AC_TLS',false); define('AC_DB_CS','mysql:host=localhost;port=3306;dbname=asterisk'); //хост, где крутится MySQL с БД Asterisk'а, порт и имя БД define('AC_DB_UNAME','asterisk_user'); //каким юзером цепляться к БД define('AC_DB_UPASS','232wwQd293f_2edxse3e'); //пароль этого юзера define('AC_TIMEOUT',0.75); define('AC_RECORD_PATH','https://asterisk.vistep.ru/records/%Y/%m/%d/#'); //путь, по которому забирать файлы записей разговоров define('AC_TIME_DELTA',7); // hours. Ex. GMT+4 = 4   $db_cs=AC_DB_CS; $db_u=!strlen(AC_DB_UNAME)?NULL:AC_DB_UNAME; $db_p=!strlen(AC_DB_UPASS)?NULL:AC_DB_UPASS; date_default_timezone_set('UTC');   if (AC_PORT<1) die('Please, configure settings first!'); // die if not if (defined('AC_RECORD_PATH') AND !empty($_GET['GETFILE'])){ 	//get file. Do not check auth. (uniqueid is rather unique) 	$p=AC_RECORD_PATH; 	if (empty($p)) die('Error while getting file from asterisk'); 	try { 		$dbh = new PDO($db_cs, $db_u, $db_p); 		$sth = $dbh->prepare('SELECT calldate,recordingfile FROM cdr WHERE uniqueid= :uid'); 		$sth->bindValue(':uid',strval($_GET['GETFILE'])); 		$sth->execute(); 		$r = $sth->fetch(PDO::FETCH_ASSOC); 		if ($r===false OR empty($r['recordingfile'])) die('Error while getting file from asterisk'); 		$date=strtotime($r['calldate']); 		$replace=array(); 		$replace['#']=$r['recordingfile']; 		$dates=array('d','m','Y','y'); 		foreach ($dates as $d) $replace['%'.$d]=date($d,$date); // not a good idea! 		$p=str_replace(array_keys($replace),array_values($replace),$p); 		if (empty($_GET['noredirect'])) header('Location: '.$p); 		die($p); 	} catch (PDOException $e) { 		die('Error while getting file from asterisk'); 	} }   // filter parameters from _GET foreach (array('login','secret','action') as $k){ 	if (empty($_GET['_'.$k])) die('NO_PARAMS'); 	$$k=strval($_GET['_'.$k]); } // trying to check accacess $loginArr=array( 	'Action'=>'Login', 	'username'=>$login, 	'secret'=>$secret, //	'Events'=>'off', ); $resp=asterisk_req($loginArr,true); // problems? exiting if ($resp[0]['response']!=='Success') answer(array('status'=>'error','data'=>$resp[0]));  //auth OK. Lets perform actions if ($action==='status'){ // list channels status 	$params=array( 'action'=>'status'); 	$resp=asterisk_req($params); 	// report error of any 	if ($resp[0]['response']!=='Success') answer(array('status'=>'error','data'=>$resp[0])); 	// first an last chunks are useless 	unset($resp[end(array_keys($resp))],$resp[0]); 	// renumber keys for JSON 	$resp=array_values($resp); 	// report OK 	answer(array('status'=>'ok','action'=>$action,'data'=>$resp));  }elseif ($action==='call'){ // originate a call 	$params=array( 		'action'=>'Originate', 		'channel'=>'SIP/'.intval($_GET['from']), 		'Exten'=>strval($_GET['to']), 		'Context'=>'dial_out', //was from-internal 		'priority'=>'2', 		'Callerid'=>'"'.strval($_GET['as']).'" <'.intval($_GET['from']).'>', 		'Async'=>'Yes', 		// Not Implemented: 		//'Callernumber'=>'150', 		//'CallerIDName'=>'155', 	); 	$resp=asterisk_req($params,true); 	if ($resp[0]['response']!=='Success') answer(array('status'=>'error','data'=>$resp[0])); 	answer(array('status'=>'ok','action'=>$action,'data'=>$resp[0]));  } elseif ($action==='test_cdr'){ // test if DB connection params are OK. 	if (!class_exists('PDO')) answer(array('status'=>'error','data'=>'PDO_NOT_INSTALLED')); // we use PDO for accessing mySQL pgSQL sqlite within same algorythm 	try { 		$dbh = new PDO($db_cs, $db_u, $db_p); 	} catch (PDOException $e) { 		answer(array('status'=>'error','data'=>$e->getMessage())); 	} 	answer(array('status'=>'ok','data'=>'connection ok')); } elseif ($action==='cdr'){ // fetch call history 	try { 		$dbh = new PDO($db_cs, $db_u, $db_p);  		foreach (array('date_from','date_to') as $k){ 			$v=doubleval( (!empty($_GET[$k]))?intval($_GET[$k]):0 ); 			if ($v<0) $v=time()-$v; 			$$k=$v; 		} 		if ($date_from<time()-10*24*3600) $date_from=time()-7*24*3600; //retr. not more than 10d before 		$date_from=($date_from?$date_from+AC_TIME_DELTA*3600:0); //default 01-01-1970 		$date_to  =($date_to  ?$date_to  +AC_TIME_DELTA*3600:time()+AC_TIME_DELTA*3600);//default now() 		$sth = $dbh->prepare('SELECT calldate, src,dst,duration,billsec,uniqueid,recordingfile FROM cdr WHERE disposition=\'ANSWERED\' AND billsec>=:minsec AND calldate> :from AND calldate< :to'); 		// BETWEEN is illegal on some bcknds 		header("X-REAL_DATE:" . gmdate('Y-m-d H:i:s',$date_from).'@'. gmdate('Y-m-d H:i:s',$date_to)); 		$sth->bindValue(':from', date('Y-m-d H:i:s',$date_from) ); 		$sth->bindValue(':to',	 date('Y-m-d H:i:s',$date_to)); 		$sth->bindValue(':minsec',!empty($_GET['minsec'])?$_GET['minsec']:5,PDO::PARAM_INT); 		$sth->execute(); 		//$sth->debugDumpParams(); 	var_dump($sth->errorInfo()); 		$r = $sth->fetchAll(PDO::FETCH_ASSOC); 		foreach ($r as $k=>$v) $r[$k]['calldate']=date('Y-m-d H:i:s',strtotime($v['calldate'])-AC_TIME_DELTA*3600); 		answer(array('status'=>'ok','data'=>$r),true); 	} catch (PDOException $e) { 		answer(array('status'=>'error','data'=>$e->getMessage()),true); 	} } elseif ($action==='pop'){// fill test data. Maybe you will need it. Just comment line below. 	die(); 	$dbh = new PDO($db_cs, $db_u, $db_p); 	for ($i=0;$i<(int)$_GET['n'];$i++){ 		$array=array( 			date('Y-m-d H:i:s',time()-rand(100,7*24*3600)), 			'Auto <150>', 150,'791612345678','n/a','n/a','n/a','n/a','n/a',999, rand(7,999), 'ANSWERED',3,'',uniqid(),'','','' 		); 		$str=array(); 		foreach ($array as  $v) $str[]="'{$v}'"; 		$str=implode(', ',$str); 		$dbh->query("INSERT INTO cdr VALUES ({$str});"); 	} }  /** MakeRequest to asterisk interfacees  * @param $params -- array of req. params  * @return array -- response  */ function asterisk_req($params,$quick=false){ 	// lets decide if use AJAM or AMI 	return !defined('AC_PREFIX')?ami_req($params,$quick):ajam_req($params); }  /**  * Shudown function. Gently close the socket  */ function asterisk_socket_shutdown(){ami_req(NULL);}  /*** Make request with AMI  * @param $params -- array of req. params  * @param bool $quick -- if we need more than action result  * @return array result of req  */ function ami_req($params,$quick=false){ 	static $connection; 	if ($params===NULL and $connection!==NULL) { 		// close connection 		fclose($connection); 		return; 	} 	if ($connection===NULL){ 		$en=$es=''; 		$connection = fsockopen(AC_HOST, AC_PORT, $en, $es, 3); 		// trying to connect. Return an error on fail 		if ($connection) register_shutdown_function('asterisk_socket_shutdown'); 		else {$connection=NULL; return array(0=>array('response'=>'error','message'=>'socket_err:'.$en.'/'.$es));} 	} 	// building req. 	$str=array(); 	foreach($params as $k=>$v) $str[]="{$k}: {$v}"; 	$str[]=''; 	$str=implode("\r\n",$str); 	// writing 	fwrite($connection,$str."\r\n"); 	// Setting stream timeout 	$seconds=ceil(AC_TIMEOUT); 	$ms=round((AC_TIMEOUT-$seconds)*1000000); 	stream_set_timeout($connection,$seconds,$ms); 	// reading respomse and parsing it 	$str= ami_read($connection,$quick); 	$r=rawman_parse($str); 	//var_dump($r,$str); 	return $r; } /*** Reads data from coinnection  * @param $connection -- active connection  * @param bool $quick -- should we wait for timeout or return an answer after getting command status  * @return string RAW response  */ function ami_read($connection,$quick=false){ 	$str=''; 	do { 		$line = fgets($connection, 4096); 		$str .= $line; 		$info = stream_get_meta_data($connection); 		if ($quick and $line== "\r\n") break; 	}while ($info['timed_out'] == false ); 	return $str; }  /*** Echo`s data  * @param $array answer data  * @param bool $no_callback shold we output as JSON or use callback function  */ function answer($array,$no_callback=false){ 	header('Content-type: text/javascript;'); 	if (!$no_callback)  echo "asterisk_cb(".json_encode($array).');'; 	else echo json_encode($array); 	die(); }  /** Parse RAW response  * @param $lines RAW response  * @return array parsed response  */ function rawman_parse($lines){ 	$lines=explode("\n",$lines); 	$messages=array(); 	$message=array();  	foreach ($lines as $l){ 		$l=trim($l); 		if (empty($l) and count($message)>0){ $messages[]= $message;  $message=array(); continue;} 		if (empty($l))  continue; 		if (strpos($l,':')===false)  continue; 		list($k,$v)=explode(':',$l); 		$k=strtolower(trim($k)); 		$v=trim($v); 		if (!isset( $message[$k]))  $message[$k]=$v; 		elseif (!is_array( $message[$k]))  $message[$k]=array( $message[$k],$v); 		else  $message[$k][]=$v; 	} 	if (count($message)>0) $messages[]= $message; 	return $messages; }   /** Make request via AJAM  * @param $params req. params  * @return array parsed resp.  */ function ajam_req($params){ 	static $cookie; 	// EveryRequest Ajam sends back a cookir, needed for auth handling 	if ($cookie===NULL) $cookie=''; 	// make req. and store cookie 	list($body,$cookie)= rq(AC_PREFIX.'rawman?'.http_build_query($params),$cookie); 	// parse an answer 	return rawman_parse($body); }  /** make http req. to uri with cookie, parse resp and fetch a new cookie  * @param $url  * @param string $cookie  * @return array  ($body,$newcookie)  */ function rq($url,$cookie=''){ 	// get RAW data 	$r=_rq($url,$cookie); 	// divide in 2 parts 	list($headersRaw,$body)=explode("\r\n\r\n",$r,2); 	// parse headers 	$headersRaw=explode("\r\n",$headersRaw); 	$headers=array(); 	foreach ($headersRaw as $h){ 		if (strpos($h,':')===false) continue; 		list($hname,$hv)=explode(":",$h,2); 		$headers[strtolower(trim($hname))]=trim($hv); 	} 	// fetch cookie 	if (!empty($headers['set-cookie'])){ 		$listcookies=explode(';',$headers['set-cookie']); 		foreach ($listcookies as $c){ 			list($k,$v)=explode('=',trim($c),2); 			if ($k=='mansession_id') $cookie=$v; 		} 	}  	return array($body,$cookie); }  /**  mare a request to URI and return RAW resp or false on fail  * @param $url  * @param $cookie  * @return bool|string  */ function _rq($url,$cookie){ 	$errno=$errstr=""; 	$fp = fsockopen(AC_HOST, AC_PORT, $errno, $errstr, 3); 	if (!$fp) return false; 	$out = "GET {$url} HTTP/1.1\r\n"; 	$out .= "Host: ".AC_HOST."\r\n"; 	if (!empty($cookie)) $out.="Cookie: mansession_id={$cookie}\r\n"; 	$out .= "Connection: Close\r\n\r\n"; 	fwrite($fp, $out); 	$r=''; 	while (!feof($fp)) $r.=fgets($fp); 	fclose($fp); 	return $r; }