{"id":2686,"date":"2016-07-11T16:08:32","date_gmt":"2016-07-11T21:08:32","guid":{"rendered":"http:\/\/itsoftware.com.co\/content\/?p=2686"},"modified":"2019-05-18T12:41:59","modified_gmt":"2019-05-18T17:41:59","slug":"consultar-extensiones-caidas-asterisk-historicamente","status":"publish","type":"post","link":"https:\/\/itsoftware.com.co\/content\/consultar-extensiones-caidas-asterisk-historicamente\/","title":{"rendered":"Consultar extensiones ca\u00eddas en Asterisk hist\u00f3ricamente"},"content":{"rendered":"

Este art\u00edculo busca crear un procedimiento para informar por correo electr\u00f3nico, el comportamiento de extensiones ca\u00eddas en Asterisk, por periodos de 10 o m\u00e1s d\u00edas.<\/p>\n

Estado Extensiones Asterisk<\/figcaption><\/figure>\n

<\/p>\n

El problema en general con respecto al estado de las extensiones Asterisk, radica en que s\u00f3lo se nos reporta el estado actual de las extensiones, a modo de una foto en el instante en que hacemos un requerimiento de estado de las mismas. No existe un historial que nos indique cu\u00e1nto tiempo una extensi\u00f3n ha estado desconectada en el transcurso del d\u00eda o de los d\u00edas.<\/p>\n

Para darle una soluci\u00f3n a esta problem\u00e1tica, el siguiente procedimiento busca tomar el estado de las extensiones cada hora, subiendo esta informaci\u00f3n a una tabla de la base de datos MySQL. Si una extensi\u00f3n ha estado desconectada por 19 o m\u00e1s veces en un d\u00eda, entonces se considera que ha estado desconectada durante ese d\u00eda. Con base en esa premisa, se buscan todas las extensiones que han estado desconectadas por 10 o m\u00e1s d\u00edas consecutivos, para crear una lista que se env\u00eda por correo electr\u00f3nico.<\/p>\n

Los siguientes ser\u00edan los pasos a realizar para activar esta soluci\u00f3n:<\/p>\n

A) En la DB MySQL<\/b><\/p>\n

1) Se crea una tabla para subir los estados de las extensiones:<\/p>\n

CREATE TABLE `t_peer_status` (
\n`cod_peer_status` int(11) NOT NULL AUTO_INCREMENT,
\n`date_st` datetime NOT NULL DEFAULT ‘0000-00-00 00:00:00’,
\n`username` varchar(26) CHARACTER SET latin1 NOT NULL DEFAULT \u00bb,
\n`host` varchar(40) CHARACTER SET latin1 DEFAULT \u00bb,
\n`dyn` varchar(4) CHARACTER SET latin1 DEFAULT NULL,
\n`forceport` varchar(11) CHARACTER SET latin1 DEFAULT NULL,
\n`acl` varchar(4) CHARACTER SET latin1 DEFAULT NULL,
\n`port` varchar(9) CHARACTER SET latin1 DEFAULT NULL,
\n`status` varchar(12) CHARACTER SET latin1 DEFAULT NULL,
\nPRIMARY KEY (`cod_peer_status`),
\nUNIQUE KEY `date_st` (`date_st`,`username`)
\n) ENGINE=MyISAM AUTO_INCREMENT=9774040 DEFAULT CHARSET=utf8;<\/p><\/blockquote>\n

<\/div>\n
<\/div>\n

2) Se crea una tabla para almacenar los nombres de los archivos logs de estados de extensiones:<\/p>\n

CREATE TABLE `t_files_peer_st` (
\n`cod_file_per_st` int(11) NOT NULL AUTO_INCREMENT,
\n`NOMBRE` varchar(30) DEFAULT NULL,
\n`MODIFICACION` datetime DEFAULT NULL,
\n`DIRECTORIO` varchar(30) DEFAULT NULL,
\nPRIMARY KEY (`cod_file_per_st`)
\n) ENGINE=MyISAM AUTO_INCREMENT=285 DEFAULT CHARSET=latin1;<\/p><\/blockquote>\n

3) Se crea la siguiente vista de apoyo para recoger el estado de las extensiones de los \u00faltimos 12 d\u00edas:<\/p>\n

<\/div>\n
\n
CREATE ALGORITHM=UNDEFINED DEFINER=`root`@`localhost` SQL SECURITY DEFINER VIEW `v_exten_cur` AS select `t_peer_status`.`cod_peer_status` AS `cod_peer_status`,`t_peer_status`.`date_st` AS `date_st`,`t_peer_status`.`username` AS `username`,`t_peer_status`.`host` AS `host`,`t_peer_status`.`dyn` AS `dyn`,`t_peer_status`.`forceport` AS `forceport`,`t_peer_status`.`acl` AS `acl`,`t_peer_status`.`port` AS `port`,`t_peer_status`.`status` AS `status` from `t_peer_status` where (cast(`t_peer_status`.`date_st` as date) between (curdate() – interval 12 day) and curdate());<\/div>\n
<\/div>\n
<\/div>\n<\/blockquote>\n

4) Se crea un procedimiento almacenado para hacer la consulta de los 10 d\u00edas desconectados en forma continua, haciendo uso tambi\u00e9n de un cursor para detectar l\u00edneas desconectadas en ese tiempo :<\/p>\n

\n
<\/div>\n
CREATE DEFINER=`root`@`localhost` PROCEDURE `off_days`(_inicio int(11),_extension varchar(50), out _exten INT(11))
\nbegin
\nSET @extension=trim(_extension);
\nSET @inicio=_inicio;
\nset @c=\u00bb;PREPARE stmt FROM \u00abselect SC.cont\u00a0 INTO @c from (
\nselect distinct count(username) as cont,date(date_st),hour(date_st),username
\nfrom v_exten_cur
\nwhere (date(date_st) = (curdate() – interval (?) day)) and (substring(status,1,2)<>’OK’) and (username = ? )
\ngroup by username
\n) SC\u00bb;EXECUTE stmt USING @inicio,@extension;
\nDEALLOCATE PREPARE stmt;
\nset _exten=@c;
\nend;<\/div>\n
<\/div>\n
<\/div>\n
CREATE DEFINER=`root`@`localhost` PROCEDURE `exten_down_10`(_inicio INT)
\nbegin
\nDECLARE _extension varchar (26);
\nDECLARE _dias\u00a0 INT;
\nDECLARE _dias_caidos\u00a0 INT;
\nDECLARE _fin_down INT;
\nDECLARE _exten INT;
\nDECLARE fin INTEGER DEFAULT 0;DECLARE dircon CURSOR FOR select SC.username from (
\nselect count(username) as cont,date(date_st),hour(date_st) ,username
\nfrom t_peer_status
\nwhere date(date_st) = curdate() – interval (_inicio) day and substring(status,1,2)<>’OK’
\ngroup by\u00a0 username
\n)
\nSC where SC.cont>=19;DECLARE CONTINUE HANDLER FOR NOT FOUND SET fin=1;DROP TEMPORARY\u00a0 TABLE IF EXISTS tmp_exten_down;CREATE\u00a0 TEMPORARY TABLE tmp_exten_down (extension varchar(20), dias int);OPEN dircon;loop1: LOOPSET _dias = _inicio;
\nSET _dias_caidos = 0;
\nSET _fin_down=0;
\nSET _exten=0;FETCH dircon INTO _extension;<\/p>\n

IF fin = 1 THEN
\nLEAVE loop1;
\nEND IF;<\/p>\n

while _fin_down=0 and _dias < 11 DO<\/p>\n

call off_days(_dias,_extension,_exten);<\/p>\n

IF\u00a0 _exten = 0\u00a0 THEN
\nSET _fin_down=1;
\nEND IF;<\/p>\n

SET _dias=_dias+1;<\/p>\n

IF\u00a0 _exten >= 19\u00a0 THEN
\nSET _dias_caidos=_dias_caidos + 1;
\nEND IF;<\/p>\n

end while;<\/p>\n

insert into tmp_exten_down values (_extension, _dias_caidos);<\/p>\n

END LOOP loop1;<\/p>\n

CLOSE dircon;<\/p>\n

select * from tmp_exten_down where dias>=0\u00a0 ;<\/p>\n

DROP TEMPORARY\u00a0 TABLE IF EXISTS tmp_exten_down;<\/p>\n

end;<\/p>\n<\/div>\n<\/blockquote>\n

<\/div>\n
<\/div>\n

B) En el servidor Asterisk (Linux):<\/b>
\n1) Se crea un script\u00a0(query.sh<\/em>) para traer el estado de las extensiones (asterisk -rx \u00absip show peers<\/em>\u00ab) y guardarlo en un archivo de texto (extension_<fecha><\/em>) :<\/p>\n

#!\/bin\/bash<\/p>\n

printf \u00ab\\n\\n******************\\n\u00bb\u00a0 >> \/home\/soporte\/extensiones\/logs\/extension_$(date +\u00bb%m-%d-%y\u00bb)<\/p>\n

printf \u00ab$(date +\u00bb%Y-%m-%d %H:%M\u00bb)\\n\u00bb\u00a0 >> \/home\/soporte\/extensiones\/logs\/extension_$(date +\u00bb%m-%d-%y\u00bb)<\/p>\n

printf \u00ab$(\/usr\/sbin\/asterisk -rx \u00absip show peers\u00bb)\u00bb\u00a0\u00a0 >> \/home\/soporte\/extensiones\/logs\/extension_$(date +\u00bb%m-%d-%y\u00bb)<\/p>\n

exit<\/p><\/blockquote>\n

2) Se crea un archivo importa.php<\/em> para recoger los datos de los archivos logs con los estados de las extensiones, al final llama al php ext_down.php<\/em> que reporta las extensiones ca\u00eddas por 10 o m\u00e1s d\u00edas:<\/p>\n

<?php<\/p>\n

require_once(\u00abincludes\/CConexion.php\u00bb);<\/p>\n

$conex=new CConexion();<\/p>\n

$conex->Conectar();
\n$original_mem = ini_get(‘memory_limit’);
\nmysql_query(\u00abSET AUTOCOMMIT=0″,$conex->getConexion()) or die(mysql_error());<\/p>\n

function ExplorarDir($ruta){
\n$direct=null;<\/p>\n

if($dh=opendir($ruta)){
\n$j=0;
\nwhile (($file = readdir($dh)) !== false) {
\nif (is_dir($ruta . $file) && $file!=\u00bb.\u00bb && $file!=\u00bb..\u00bb){
\n$direct[$j]=(string)$file;
\n$j++;
\n}
\n}
\nclosedir($dh);
\n}
\nreturn $direct;
\n}<\/p>\n

function ExplorarFile($ruta){
\n$files=null;
\necho $ruta.\u00bb<br>\u00bb;
\nif($dh=opendir($ruta)){
\n$j=0;
\nwhile (($file = readdir($dh)) !== false) {<\/p>\n

if (!is_dir($ruta . $file) && $file!=\u00bb.\u00bb && $file!=\u00bb..\u00bb){
\n$files[$j]=(string)$file;
\n$j++;
\n}
\n}
\nclosedir($dh);
\n}
\nreturn $files;
\n}<\/p>\n

function TraerFecha($mifecha){
\nreturn $mifecha;
\n}<\/p>\n

$ruta=\u00bb\/home\/soporte\/extensiones\/logs\u00bb;<\/p>\n

$work=true;
\n$directorio = null;
\n$archivos = null;
\n$directorio=ExplorarDir($ruta);
\n$ingresos=0;
\n$error_de_insercion=0;
\n$archivos=null;
\n$archivos=ExplorarFile(\u00ab\/home\/soporte\/extensiones\/logs\u00bb);<\/p>\n

for($k=0;$k<count($archivos);$k++)
\n{
\necho \u00abCONTEO: $i – DIRECTORIO:\u00bb.$directorio.\u00bb- ARCHIVO:\u00bb.$archivos[$k].\u00bb<br>\u00bb;<\/p>\n

$modificacion=date(\u00abY-m-d H:i:s.\u00bb, filemtime($ruta.$directorio.\u00bb\/\u00bb.$archivos[$k]));
\n$res_t=mysql_query(\u00abselect count(*) as cuenta from t_files_peer_st where NOMBRE='\u00bb.$archivos[$k].\u00bb‘ AND MODIFICACION = ‘\u00bb.$modificacion.\u00bb‘\u00bb,$conex->getConexion());<\/p>\n

if($reg_t=mysql_fetch_assoc($res_t))
\nif(!$reg_t[\u00abcuenta\u00bb])\/\/Si no exste coincidencia en la base de datos
\n{
\n$error_de_insercion=0;
\n$cont_lineas=0;
\n$periodo=0;
\n$cerrado=false;
\necho $ruta.$directorio;<\/p>\n

$archivo=fopen($ruta.$directorio.\u00bb\/\u00bb.$archivos[$k], \u00abr\u00bb);<\/p>\n

if(!$archivo)
\n{
\necho \u00abEl archivo \u00ab.$archivos[$k].\u00bb no pudo abrirse\u00bb;
\nexit();
\n}
\n$start=false;
\nwhile ($linea = fgets($archivo,1024))
\n{
\necho $linea.\u00bb<br \/>\u00bb;
\nif(trim($linea)==\u00bb******************\u00bb)\u00a0\u00a0 \u00a0{
\n$start=true;
\necho \u00abencabezado\u00bb;
\n}
\nelse
\n{
\nif($start)
\n{
\n$fecha=trim($linea);
\n$start=false;
\necho $fecha;
\n}
\nelse
\n{
\n$work=true;
\nif((strpos($linea,\u00bbName\/username\u00bb)!==FALSE ) || (strpos($linea,\u00bb*********\u00bb)!==FALSE )\u00a0 || (strpos($linea,\u00bbsip peers\u00bb)!==FALSE ) || trim($linea)==\u00bb\u00bb )
\n$work=false;<\/p>\n

if ($work) {
\n$string = $linea;
\n$intervals = array(27, 40, 4, 11, 4,9,11);
\n$start1 = 0;
\n$parts = array();
\nforeach ($intervals as $i)
\n{
\n$parts[] = trim(mb_substr($string, $start1, $i));
\n$start1 += $i;
\n}
\n$sql=\u00bb
\ninsert into t_peer_status
\n(
\ndate_st,
\nusername,
\nhost,
\ndyn,
\nforceport,
\nacl,
\nport,
\nstatus
\n)
\nvalues (
\n‘$fecha’,
\n‘\u00bb.$parts[0].\u00bb‘,
\n‘\u00bb.$parts[1].\u00bb‘,
\n‘\u00bb.$parts[2].\u00bb‘,
\n‘\u00bb.$parts[3].\u00bb‘,
\n‘\u00bb.$parts[4].\u00bb‘,
\n‘\u00bb.$parts[5].\u00bb‘,
\n‘\u00bb.$parts[6].\u00bb‘
\n)
\n\u00ab;
\necho $sql;
\n}
\nmysql_query($sql,$conex->getConexion()) ;
\n}<\/p>\n

}<\/p>\n

$cont_lineas++;
\n}<\/p>\n

if(!$cerrado)
\nfclose ($archivo);<\/p>\n

$sql=\u00bbinsert into t_files_peer_st (NOMBRE,DIRECTORIO,MODIFICACION) values (‘\u00bb.$archivos[$k].\u00bb‘,'\u00bb.$directorio.\u00bb‘,'\u00bb.$modificacion.\u00bb‘)\u00bb;
\n$res_a=@mysql_query($sql,$conex->getConexion());<\/p>\n

if(!$res_a){
\necho \u00abHubo un inconveniente al ingresar el nombre del archivo a la base de datos<br>\u00bb;
\n\/\/exit();
\n}<\/p>\n

mysql_query(\u00abCOMMIT\u00bb,$conex->getConexion());<\/p>\n

}\/\/Cierra no existe en la base de datos
\nelse
\necho \u00ab$i – El archivo \u00ab.$archivos[$k].\u00bb ya se encuentra ingresado<br>\u00bb;<\/p>\n

}\/\/cierra el for k<\/p>\n

\/\/mysql_query(\u00abROLLBACK\u00bb,$conex->getConexion());
\n$conex->Desconectar();
\nini_set(‘memory_limit’,$original_mem);
\nini_set(‘max_execution_time’, 30);<\/p>\n

require_once(\u00abext_down.php\u00bb);
\n?><\/p><\/blockquote>\n

3) Se crea el script php ext_down.php<\/em> para traer las extensiones con 10 d\u00edas o m\u00e1s y reportarlas por correo electr\u00f3nico:<\/p>\n

<?php
\n$conexion = mysql_connect(‘localhost’, ‘root’, ‘xxxx’);
\nmysql_select_db(‘mya2billing’);
\n$exten=array();
\n$sql3=\u00bbCALL mya2billing.exten_down_10(0)\u00bb;
\n$j=0;
\n$res3=mysql_query($sql3,$conexion) or die(mysql_error());<\/p>\n

while($reg=mysql_fetch_assoc($res3)){
\n$exten[$j][0]=$reg[\u00abextension\u00bb];
\n$exten[$j][1]=$reg[\u00abdias\u00bb];
\n$j++;
\n}<\/p>\n

require(\u00abclass.phpmailer.php\u00bb);
\n$mail = new PHPMailer();
\n$mail->PluginDir = \u00ab\u00bb;
\n$mail->Mailer = \u00absmtp\u00bb;
\n$mail->SMTPAuth = false;
\n$mail->Host = \u00abmail.xxx.com\u00bb;
\n$mail->Port = 25;
\n$mail->From = \u00abprueba@correo.com\u00bb;
\n$mail->FromName = \u00abSistema de Informacion\u00bb;
\n$mail->Subject = \u00abInforme Extensiones Caidas\u00bb;
\n$mail->Username = \u00abprueba@correo.com\u00bb;
\n$mail->Password = \u00abxxxxxx\u00bb;
\n$mail->AddCC(\u00abprueba1@correo.com\u00bb);
\n$body .= \u00ab<b>Extensiones con 10 dias consecutivos desconectados<\/b> <br><br>\u00bb;
\n$body .= \u00ab<table style=’font-family:Arial, Helvetica, sans-serif;\u00a0 font-size:11px; border-right: 1px solid #001f27; text-indent: 5px;
\nborder-bottom: 1px solid #001f27; border-top: 1px solid #001f27; border-left: 1px solid #001f27;’ border=’0′ width=’100%’ >
\n<tr>
\n<td style=’background-color:#069; color:#FFF; ‘><strong>EXTENSION<\/strong><\/td>
\n<td style=’background-color:#069; color:#FFF; ‘><strong>DIAS CAIDOS<\/strong><\/td>
\n<\/tr>\u00bb;<\/p>\n

for($i=0;$i<sizeof($exten);$i++)
\n$body .= \u00ab<tr style=’background-color: #FFF; font-size:10px;’>
\n<td style=’font-size:10px; color: $font’>\u00bb.$exten[$i][0].\u00bb<\/td>
\n<td style=’font-size:10px; color: $font’>\u00bb.$exten[$i][1].\u00bb<\/td>
\n<\/tr>\u00bb;
\n$mail->Body = $body;<\/p>\n

if (!$mail->Send())
\n{
\necho \u00abOperaci\u00f3n Fallida: \u00ab.$mail->ErrorInfo.\u00bb<\/br><\/br>\u00bb;
\n}
\nelse
\n{
\necho \u00abNotificaci\u00f3n Enviada<\/br><\/br>\u00bb;
\n$mail->Timeout=120;
\n}
\nmysql_close($conexion);
\n?><\/p><\/blockquote>\n

4) Se crean las siguientes tareas programadas para realizar autom\u00e1ticamente esta operaci\u00f3n (a las 11:30 pm se importan los datos de los archivos logs, y a las 00 se reporta por correo las extensiones ca\u00eddas):<\/p>\n

<\/div>\n
\n
$ crontab -l<\/div>\n
00 * * * * \/home\/soporte\/extensiones\/query.sh<\/div>\n
30 23 * * * php \/home\/soporte\/extensiones\/importa\/importa.php<\/div>\n<\/blockquote>\n
<\/div>\n

En resumen:<\/p>\n

El script query.sh<\/i> se encarga de crear cada hora los logs de estado de las extensiones. Se crea un archivo diario con todas las extensiones.<\/p>\n

El archivo importa.php<\/i> se encarga de importar los archivos creados por query.sh<\/i>, para subirlos a la base de datos. Luego llama las consultas para determinar el n\u00famero de d\u00edas de desconexi\u00f3n de las extensiones, y env\u00eda dicho resultado por correo electr\u00f3nico, mediante el script ext_down.php<\/em>.<\/p>\n

Si est\u00e1s interesado en realizar automatizaciones de este tipo o similares, en ITSoftware SAS<\/a> contamos con personal especializado para hacer m\u00e1s eficientes cualquier proceso que quieras mejorar.<\/p>\n","protected":false},"excerpt":{"rendered":"

Este art\u00edculo busca crear un procedimiento para informar por correo electr\u00f3nico, el comportamiento de extensiones ca\u00eddas en Asterisk, por periodos de 10 o m\u00e1s d\u00edas.<\/p>\n","protected":false},"author":1,"featured_media":8125,"comment_status":"open","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"_jetpack_memberships_contains_paid_content":false,"footnotes":""},"categories":[305],"tags":[785,801,802],"class_list":["post-2686","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-automatizacion","tag-automatizaciones","tag-scripts-linux","tag-scripts-php"],"aioseo_notices":[],"jetpack_featured_media_url":"https:\/\/itsoftware.com.co\/content\/wp-content\/uploads\/2016\/07\/asterisk-caidas.jpg","jetpack_sharing_enabled":true,"_links":{"self":[{"href":"https:\/\/itsoftware.com.co\/content\/wp-json\/wp\/v2\/posts\/2686","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/itsoftware.com.co\/content\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/itsoftware.com.co\/content\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/itsoftware.com.co\/content\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/itsoftware.com.co\/content\/wp-json\/wp\/v2\/comments?post=2686"}],"version-history":[{"count":0,"href":"https:\/\/itsoftware.com.co\/content\/wp-json\/wp\/v2\/posts\/2686\/revisions"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/itsoftware.com.co\/content\/wp-json\/wp\/v2\/media\/8125"}],"wp:attachment":[{"href":"https:\/\/itsoftware.com.co\/content\/wp-json\/wp\/v2\/media?parent=2686"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/itsoftware.com.co\/content\/wp-json\/wp\/v2\/categories?post=2686"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/itsoftware.com.co\/content\/wp-json\/wp\/v2\/tags?post=2686"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}