source: admin/WebConsole/comandos/gestores/gestor_Comandos.php @ 812496d

918-git-images-111dconfigfileconfigure-oglivegit-imageslgromero-new-oglivemainmaint-cronmount-efivarfsmultivmmultivm-ogboot-installerogClonningEngineogboot-installer-jenkinsoglive-ipv6test-python-scriptsticket-301ticket-50ticket-50-oldticket-577ticket-585ticket-611ticket-612ticket-693ticket-700ubu24tplunification2use-local-agent-oglivevarios-instalacionwebconsole3
Last change on this file since 812496d was 812496d, checked in by ramon <ramongomez@…>, 8 years ago

#718: OGAgent para macOS soporta apagado, reinicio y preparado para otras operaciones; corrección de erratas en el envío de comandos REST desde la consola web.

git-svn-id: https://opengnsys.es/svn/branches/version1.1@5208 a21b9725-9963-47de-94b9-378ad31fedc9
  • Property mode set to 100644
File size: 14.6 KB
Line 
1<?php
2// *************************************************************************************************************************************************
3// Aplicación WEB: ogAdmWebCon
4// Autor: José Manuel Alonso (E.T.S.I.I.) Universidad de Sevilla
5// Fecha Creación: Año 2009-2010
6// Fecha Última modificación: Agosto-2010
7// Nombre del fichero: gestor_Comandos.php
8// Descripción :
9//              Gestor de todos los comandos
10// *************************************************************************************************************************************************
11include_once("../../includes/ctrlacc.php");
12include_once("../../includes/restfunctions.php");
13include_once("../../clases/AdoPhp.php");
14include_once("../../clases/SockHidra.php");
15include_once("../../includes/constantes.php");
16include_once("../../includes/comunes.php");
17include_once("../../includes/cuestionacciones.php");
18include_once("../../includes/CreaComando.php");
19include_once("../../includes/RecopilaIpesMacs.php");
20//________________________________________________________________________________________________________
21include_once("../includes/capturaacciones.php");
22//________________________________________________________________________________________________________
23
24 // Recoge parametros de seguimiento
25$sw_ejya="";
26$sw_seguimiento="";
27$sw_ejprg="";
28$sw_mkprocedimiento="";
29$nombreprocedimiento="";
30$idprocedimiento="";
31$ordprocedimiento=0;
32
33$sw_mktarea="";
34$nombretarea="";
35$idtarea="";
36$ordtarea=0;
37
38if (isset($_POST["sw_ejya"]))   $sw_ejya=$_POST["sw_ejya"];
39if (isset($_POST["sw_seguimiento"]))    $sw_seguimiento=$_POST["sw_seguimiento"];
40
41if (isset($_POST["sw_ejprg"]))  $sw_ejprg=$_POST["sw_ejprg"];
42
43if (isset($_POST["sw_mkprocedimiento"]))        $sw_mkprocedimiento=$_POST["sw_mkprocedimiento"];
44if (isset($_POST["nombreprocedimiento"]))       $nombreprocedimiento=$_POST["nombreprocedimiento"];
45if (isset($_POST["idprocedimiento"]))   $idprocedimiento=$_POST["idprocedimiento"];
46if (isset($_POST["ordprocedimiento"]))  $ordprocedimiento=$_POST["ordprocedimiento"];
47if(empty($ordprocedimiento)) $ordprocedimiento=0;
48
49if (isset($_POST["sw_mktarea"]))        $sw_mktarea=$_POST["sw_mktarea"];
50if (isset($_POST["nombretarea"]))       $nombretarea=$_POST["nombretarea"];
51if (isset($_POST["idtarea"]))   $idtarea=$_POST["idtarea"];
52if (isset($_POST["ordtarea"]))  $ordtarea=$_POST["ordtarea"];
53if(empty($ordtarea)) $ordtarea=0;
54
55//__________________________________________________________________
56$cmd=CreaComando($cadenaconexion);
57if (!$cmd)
58        Header('Location: '.$pagerror.'?herror=2'); // Error de conexión con servidor B.D.
59//__________________________________________________________________
60$funcion="nfn=".$funcion.chr(13); // Nombre de la función que procesa el comando y el script que lo implementa
61$aplicacion=""; // Ámbito de aplicación (cadena de ipes separadas por ";" y de identificadores de ordenadores por ","
62$acciones=""; // Cadena de identificadores de acciones separadas por ";" para seguimiento
63
64
65
66$atributos=str_replace('@',chr(13),$atributos); // Reemplaza caracters
67$atributos=str_replace('#',chr(10),$atributos);
68$atributos=str_replace('$',chr(9),$atributos);
69
70
71//__________________________________________________________________
72?>
73<HTML>
74<HEAD>
75        <meta http-equiv="Content-Type" content="text/html;charset=UTF-8">
76<BODY>
77        <SCRIPT language="javascript" src="../jscripts/comunescomandos.js"></SCRIPT>
78        <? echo '<SCRIPT language="javascript" src="../../idiomas/javascripts/'.$idioma.'/comandos/comunescomandos_'.$idioma.'.js"></SCRIPT>'?>
79
80<?php
81//##################################################################
82/* Recopila identificadore ,ipes y macs para envío de comandos */
83$cadenaid="";
84$cadenaip="";
85$cadenamac="";
86$cadenaoga="";  // Clave de acceso a la API REST de OGAgent.
87
88if(!empty($filtro)){ // Ambito restringido a un subconjuto de ordenadores
89        if(substr($filtro,strlen($cadenaid)-1,1)==";") // Si el último caracter es una coma
90                $filtro=substr($filtro,0,strlen($filtro)-1); // Quita la coma
91}
92RecopilaIpesMacs($cmd,$ambito,$idambito,$filtro);
93
94/*--------------------------------------------------------------------------------------------------------------------
95        Creación de parametros para sentencias SQL
96--------------------------------------------------------------------------------------------------------------------*/
97$cmd->CreaParametro("@tipoaccion",0,1);
98$cmd->CreaParametro("@idtipoaccion",0,1);
99$cmd->CreaParametro("@descriaccion","",0);
100$cmd->CreaParametro("@idordenador",0,1);
101$cmd->CreaParametro("@ip","",0);
102$cmd->CreaParametro("@sesion",0,1);
103$cmd->CreaParametro("@parametros","",0);
104$cmd->CreaParametro("@fechahorareg","",0);
105$cmd->CreaParametro("@estado",0,1);
106$cmd->CreaParametro("@resultado",0,1);
107$cmd->CreaParametro("@idcentro",0,1);
108$cmd->CreaParametro("@idprocedimiento",0,1);
109$cmd->CreaParametro("@descripcion","",0);
110$cmd->CreaParametro("@idcomando",0,1);
111$cmd->CreaParametro("@idtarea",0,1);
112$cmd->CreaParametro("@ambito",0,1);
113$cmd->CreaParametro("@idambito",0,1);
114$cmd->CreaParametro("@restrambito","",0);
115$cmd->CreaParametro("@ordprocedimiento",0,1);
116$cmd->CreaParametro("@ordtarea",0,1);
117
118if($ambito==0){ // Ambito restringido a un subconjuto de ordenadores con formato (idordenador1,idordenador2,etc)
119        $cmd->ParamSetValor("@restrambito",$idambito);
120        $idambito=0;
121}
122if(!empty($filtro)){ // Ambito restringido a un subconjuto de ordenadores
123        $cmd->ParamSetValor("@restrambito",$filtro);
124}
125$resul=true;
126
127/*--------------------------------------------------------------------------------------------------------------------
128        Switch de ejecución inmediata y de seguimiento
129--------------------------------------------------------------------------------------------------------------------*/
130if($sw_ejya=='on' || $sw_ejprg=="on" ){
131        $parametros=$funcion.$atributos;
132        $aplicacion=chr(13)."ido=".$cadenaid.chr(13)."mac=".$cadenamac.chr(13)."iph=".$cadenaip.chr(13);
133        if($sw_seguimiento==1 || $sw_ejprg=="on"){ // Switch de ejecución con seguimiento o comando programado
134                $sesion=time();
135                $cmd->ParamSetValor("@tipoaccion",$EJECUCION_COMANDO);
136                $cmd->ParamSetValor("@idtipoaccion",$idcomando);
137                $cmd->ParamSetValor("@descriaccion",$descricomando);
138                $cmd->ParamSetValor("@sesion",$sesion);
139                $cmd->ParamSetValor("@idcomando",$idcomando);
140                $cmd->ParamSetValor("@parametros",$parametros);
141                $cmd->ParamSetValor("@fechahorareg",date("y/m/d H:i:s"));
142                if($sw_ejprg=="on") // Switch de ejecución con programación (se para el comando tarea para lanzarlo posteriormente)
143                        $cmd->ParamSetValor("@estado",$ACCION_DETENIDA);
144                else
145                        $cmd->ParamSetValor("@estado",$ACCION_INICIADA);
146                $cmd->ParamSetValor("@resultado",$ACCION_SINRESULTADO);
147                $cmd->ParamSetValor("@ambito",$ambito);
148                $cmd->ParamSetValor("@idambito",$idambito);                     
149                $cmd->ParamSetValor("@idcentro",$idcentro);
150                $auxID=split(",",$cadenaid);
151                $auxIP=split(";",$cadenaip);
152                for ($i=0;$i<sizeof($auxID);$i++){
153                        $cmd->ParamSetValor("@idordenador",$auxID[$i]);
154                        $cmd->ParamSetValor("@ip",$auxIP[$i]);
155                        $cmd->texto="INSERT INTO acciones (idordenador,tipoaccion,idtipoaccion,descriaccion,ip,
156                                                sesion,idcomando,parametros,fechahorareg,estado,resultado,ambito,idambito,restrambito,idcentro)
157                                                VALUES (@idordenador,@tipoaccion,@idtipoaccion,@descriaccion,@ip,
158                                                @sesion,@idcomando,@parametros,@fechahorareg,@estado,@resultado,@ambito,@idambito,@restrambito,@idcentro)";
159                        $resul=$cmd->Ejecutar();
160                }
161                $acciones=chr(13)."ids=".$sesion.chr(13); // Para seguimiento
162        }
163        if (!$resul){
164                echo '<SCRIPT language="javascript">';
165                echo 'resultado_comando(7);'.chr(13);
166                echo '</SCRIPT>';
167        }
168        else{
169                $ValorParametros=extrae_parametros($parametros,chr(13),'=');
170                $script=urldecode($ValorParametros["scp"]);
171                if($sw_ejya=='on'){     
172                        // Envio al servidor
173                        $shidra=new SockHidra($servidorhidra,$hidraport);
174                        if ($shidra->conectar()){ // Se ha establecido la conexión con el servidor hidra
175                                $parametros.=$aplicacion;
176                                $parametros.=$acciones;
177                                //die($parametros);
178                                $resul=$shidra->envia_comando($parametros);
179                                if($resul)
180                                        $trama=$shidra->recibe_respuesta();
181                                        if($resul){
182                                                $hlonprm=hexdec(substr($trama,$LONCABECERA,$LONHEXPRM));
183                                                $parametros=substr($trama,$LONCABECERA+$LONHEXPRM,$hlonprm);
184                                                $ValorParametros=extrae_parametros($parametros,chr(13),'=');
185                                                $resul=$ValorParametros["res"];
186                                        }
187                                $shidra->desconectar();
188                        }
189                        // Guardamos resultado de ogAgent original
190                        $resulhidra = $resul;
191
192                        // Comprobamos si el comando es soportado por el nuevo ogAgent
193                        $numip=0;
194                        $ogAgentNuevo = false;
195                        switch ($idcomando) {
196                                case 2:
197                                        // Apagar
198                                        $urlcomando = 'poweroff';
199                                        $ogAgentNuevo = true;
200                                        break;
201                                case 5:
202                                        // Reiniciar
203                                        $urlcomando = 'reboot';
204                                        $ogAgentNuevo = true;
205                                        break;
206                                case 8:
207                                        // Ejecutar script
208                                        $urlcomando = 'script';
209                                        $ogAgentNuevo = true;
210                                        $paramsPost = '{"script":"'.base64_encode($script).'"}';
211                                        break;
212                        }
213
214                        // Se envía acción al nuevo ogAgent
215                        if ( $ogAgentNuevo ) {
216                                // Send REST requests to new OGAgent clients.
217                                $urls = array();
218                                $ipsuccess = '';
219                                // Compose array of REST URLs.
220                                $auxIp = explode(';', $cadenaip);
221                                $auxKey = explode(";", $cadenaoga);
222                                $i = 0;
223                                foreach ($auxIp as $ip) {
224                                        $urls[$ip]['url'] = "https://$ip:8000/opengnsys/$urlcomando";
225                                        if (isset($auxKey[$i]))  $urls[$ip]['header'] = Array("Authorization: ".$auxKey[$i]);
226                                        if (isset($paramsPost))  $urls[$ip]['post'] = $paramsPost;
227
228                                        $i++;
229                                }
230                                // Launch concurrent requests.
231                                $responses = multiRequest($urls);
232                                // Process responses array (IP as array index).
233                                foreach ($responses as $ip => $resp) {
234                                        // Check if response code is OK (200).
235                                        if ($resp['code'] == 200) {
236                                                $ipsuccess .= "'".$ip."',";
237                                                $numip++;
238                                        }
239                                }
240                                // quitamos último carácter ','
241                                $ipsuccess=substr($ipsuccess, 0, -1);
242
243                                // Actualizamos la cola de acciones con los que no dan error
244                                if ( $numip >> 0 ) {
245                                        $fin= date ("Y-m-d H:i:s");
246                                        $cmd->texto="UPDATE acciones SET resultado='1', estado='3', ".
247                                                " descrinotificacion='', fechahorafin='".$fin."' ".
248                                                " WHERE ip IN  ($ipsuccess) AND idcomando='$idcomando' ".
249                                                " ORDER BY idaccion DESC LIMIT $numip";
250                                        $resul=$cmd->Ejecutar();
251                                }
252                        }
253                        // Mostramos mensaje con resultado
254                        if (!$resulhidra && $numip == 0){
255                                echo '<SCRIPT language="javascript">';
256                                echo 'resultado_comando(1);'.chr(13);
257                                echo '</SCRIPT>';
258                        }
259                        else{
260                                echo '<SCRIPT language="javascript">'.chr(13);
261                                echo 'resultado_comando(2);'.chr(13);
262                                echo '</SCRIPT>'.chr(13);
263                        }               
264                }
265        }
266}
267/*--------------------------------------------------------------------------------------------------------------------
268        Switch de creación o inclusión en procedimiento
269--------------------------------------------------------------------------------------------------------------------*/
270if($sw_mkprocedimiento=='on' || $sw_mktarea=='on'){
271        $resul=false;
272        if($idprocedimiento==0 || $sw_mktarea=='on'){ // Nuevo procedimiento o Tarea
273                if($sw_mktarea=='on' && empty($nombreprocedimiento)){ // Si tarea con inclusión de procedimiento...
274                        if(!empty($nombretarea))
275                                $nombreprocedimiento="Proc($nombretarea)";      // .. tarea nueva
276                        else
277                                $nombreprocedimiento="Proc($idtarea)";  // .. inclusión en tarea
278                }
279                $cmd->ParamSetValor("@descripcion",$nombreprocedimiento);
280                $cmd->ParamSetValor("@idcentro",$idcentro);
281                $cmd->texto="INSERT INTO procedimientos(descripcion,idcentro) VALUES (@descripcion,@idcentro)";
282                $resul=$cmd->Ejecutar();
283                if($resul){
284                        if($idprocedimiento==0) // Cambia el identificador sólo si es nuevo procedimiento
285                                $idprocedimiento=$cmd->Autonumerico();
286                        if($sw_mktarea=='on')
287                                $idprocedimientotarea=$cmd->Autonumerico(); // Identificador para la tarea;     
288                }
289        }
290        if( $idprocedimiento>0 || $sw_mktarea=='on'){ //  inclusión en procedimiento existente
291                $cmd->ParamSetValor("@idprocedimiento",$idprocedimiento);
292                $cmd->ParamSetValor("@idcomando",$idcomando);
293                $cmd->ParamSetValor("@ordprocedimiento",$ordprocedimiento);
294                $parametros=$funcion.$atributos;
295                $cmd->ParamSetValor("@parametros",$parametros);
296                $cmd->texto="INSERT INTO procedimientos_acciones(idprocedimiento,orden,idcomando,parametros)
297                                    VALUES (@idprocedimiento,@ordprocedimiento,@idcomando,@parametros)";
298                $resul=$cmd->Ejecutar();
299                if($sw_mktarea=='on' && $idprocedimiento!=$idprocedimientotarea){ // Si es tarea se graba para su procedimiento independiente aunque los parametros sean los mismos
300                        $cmd->ParamSetValor("@idprocedimiento",$idprocedimientotarea);         
301                        $cmd->texto="INSERT INTO procedimientos_acciones(idprocedimiento,orden,idcomando,parametros)
302                                            VALUES (@idprocedimiento,@ordprocedimiento,@idcomando,@parametros)";
303                        $resul=$cmd->Ejecutar();
304                }
305        }
306        if (!$resul){
307                echo '<SCRIPT language="javascript">';
308                echo 'resultado_comando(3);'.chr(13);
309                echo '</SCRIPT>';
310        }
311        else{
312                if($sw_mkprocedimiento=='on'){
313                        echo '<SCRIPT language="javascript">'.chr(13);
314                        echo 'resultado_comando(4);'.chr(13);
315                        echo '</SCRIPT>'.chr(13);
316                }
317        }
318}       
319/*--------------------------------------------------------------------------------------------------------------------
320        Switch de creación o inclusión en tarea
321--------------------------------------------------------------------------------------------------------------------*/
322if($sw_mktarea=='on'){
323        $resul=false;
324        if($idtarea==0){ // Nueva tarea
325                $cmd->ParamSetValor("@descripcion",$nombretarea);
326                $cmd->ParamSetValor("@idcentro",$idcentro);
327                $cmd->ParamSetValor("@ambito",$ambito);
328                $cmd->ParamSetValor("@idambito",$idambito);             
329                $cmd->texto="INSERT INTO tareas(descripcion,idcentro,ambito,idambito,restrambito)
330                                        VALUES (@descripcion,@idcentro,@ambito,@idambito,@restrambito)";
331                $resul=$cmd->Ejecutar();
332                if($resul)
333                        $idtarea=$cmd->Autonumerico();
334        }
335        if($idtarea>0){ //  inclusión en tarea existente
336                $cmd->ParamSetValor("@idtarea",$idtarea);
337                $cmd->ParamSetValor("@idprocedimiento",$idprocedimientotarea);
338                $cmd->ParamSetValor("@ordtarea",$ordtarea);
339                $cmd->texto="INSERT INTO tareas_acciones(idtarea,orden,idprocedimiento)
340                                                        VALUES (@idtarea,@ordtarea,@idprocedimiento)";
341                $resul=$cmd->Ejecutar();
342                //echo $cmd->texto;
343        }
344        if (!$resul){
345                echo '<SCRIPT language="javascript">'.chr(13);
346                echo 'resultado_comando(5);'.chr(13);
347                echo '</SCRIPT>'.chr(13);
348        }
349        else{
350                echo '<SCRIPT language="javascript">'.chr(13);
351                echo 'resultado_comando(6);'.chr(13);
352                echo '</SCRIPT>'.chr(13);
353        }
354}
355/* Programación del comando */
356if ($resul){
357        if($sw_ejprg=="on" ){   
358                echo '<SCRIPT language="javascript">'.chr(13);
359                echo 'var whref="../../varios/programaciones.php?idcomando='.$idcomando.'";'.chr(13);
360                echo 'whref+="&sesion='.$sesion.'&descripcioncomando='.UrlEncode($descricomando).'&tipoaccion='.$EJECUCION_COMANDO.'";'.chr(13);
361                echo 'location.href=whref;';
362                echo '</SCRIPT>';
363        }
364}
365?>
366</BODY>
367</HTML>
368
Note: See TracBrowser for help on using the repository browser.