source: admin/WebConsole/comandos/gestores/gestor_Comandos.php @ 8b1c92b

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-instalacion
Last change on this file since 8b1c92b was d233fdb, checked in by OpenGnSys Support Team <soporte-og@…>, 6 years ago

#915: Adapt web to use new image/restore cmd in REST API

SocketHidra? restaurar imagen has been replaced by POST image/restore.
  • Property mode set to 100644
File size: 16.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
24define('OG_CMD_ID_WAKEUP', 1);
25define('OG_CMD_ID_POWEROFF', 2);
26define('OG_CMD_ID_RESTORE_IMAGE', 3);
27define('OG_CMD_ID_CREATE_IMAGE', 4);
28define('OG_CMD_ID_REBOOT', 5);
29define('OG_CMD_ID_HARDWARE', 6);
30define('OG_CMD_ID_SOFTWARE', 7);
31define("OG_CMD_ID_SCRIPT", 8);
32define('OG_CMD_ID_SESSION', 9);
33define('OG_CMD_ID_SENDMESSAGE', 16);
34
35// Recoge parametros de seguimiento
36$sw_ejya="";
37$sw_seguimiento="";
38$sw_ejprg="";
39$sw_mkprocedimiento="";
40$nombreprocedimiento="";
41$idprocedimiento="";
42$ordprocedimiento=0;
43$avisoRepo=false;
44
45$sw_mktarea="";
46$nombretarea="";
47$idtarea="";
48$ordtarea=0;
49
50if (isset($_POST["sw_ejya"]))   $sw_ejya=$_POST["sw_ejya"];
51if (isset($_POST["sw_seguimiento"]))    $sw_seguimiento=$_POST["sw_seguimiento"];
52
53if (isset($_POST["sw_ejprg"]))  $sw_ejprg=$_POST["sw_ejprg"];
54
55if (isset($_POST["sw_mkprocedimiento"]))        $sw_mkprocedimiento=$_POST["sw_mkprocedimiento"];
56if (isset($_POST["nombreprocedimiento"]))       $nombreprocedimiento=$_POST["nombreprocedimiento"];
57if (isset($_POST["idprocedimiento"]))   $idprocedimiento=$_POST["idprocedimiento"];
58if (isset($_POST["ordprocedimiento"]))  $ordprocedimiento=$_POST["ordprocedimiento"];
59if(empty($ordprocedimiento)) $ordprocedimiento=0;
60
61if (isset($_POST["sw_mktarea"]))        $sw_mktarea=$_POST["sw_mktarea"];
62if (isset($_POST["nombretarea"]))       $nombretarea=$_POST["nombretarea"];
63if (isset($_POST["idtarea"]))   $idtarea=$_POST["idtarea"];
64if (isset($_POST["ordtarea"]))  $ordtarea=$_POST["ordtarea"];
65if(empty($ordtarea)) $ordtarea=0;
66
67//__________________________________________________________________
68$cmd=CreaComando($cadenaconexion);
69if (!$cmd)
70        Header('Location: '.$pagerror.'?herror=2'); // Error de conexión con servidor B.D.
71//__________________________________________________________________
72$funcion="nfn=".$funcion.chr(13); // Nombre de la función que procesa el comando y el script que lo implementa
73$aplicacion=""; // Ámbito de aplicación (cadena de ipes separadas por ";" y de identificadores de ordenadores por ","
74$acciones=""; // Cadena de identificadores de acciones separadas por ";" para seguimiento
75
76
77
78$atributos=str_replace('@',chr(13),$atributos); // Reemplaza caracters
79$atributos=str_replace('#',chr(10),$atributos);
80$atributos=str_replace('$',chr(9),$atributos);
81
82
83//__________________________________________________________________
84?>
85<HTML>
86<HEAD>
87        <meta http-equiv="Content-Type" content="text/html;charset=UTF-8">
88        <SCRIPT language="javascript" src="../jscripts/comunescomandos.js"></SCRIPT>
89        <?php echo '<SCRIPT language="javascript" src="../../idiomas/javascripts/'.$idioma.'/comandos/comunescomandos_'.$idioma.'.js"></SCRIPT>'?>
90
91<?php
92//##################################################################
93/* Recopila identificadore ,ipes y macs para envío de comandos */
94$cadenaid="";
95$cadenaip="";
96$cadenamac="";
97$cadenaoga="";  // Clave de acceso a la API REST de OGAgent.
98
99if(!empty($filtro)){ // Ambito restringido a un subconjuto de ordenadores
100        if(substr($filtro,strlen($cadenaid)-1,1)==";") // Si el último caracter es una coma
101                $filtro=substr($filtro,0,strlen($filtro)-1); // Quita la coma
102}
103RecopilaIpesMacs($cmd,$ambito,$idambito,$filtro);
104
105/*--------------------------------------------------------------------------------------------------------------------
106        Creación de parametros para sentencias SQL
107--------------------------------------------------------------------------------------------------------------------*/
108$cmd->CreaParametro("@tipoaccion",0,1);
109$cmd->CreaParametro("@idtipoaccion",0,1);
110$cmd->CreaParametro("@descriaccion","",0);
111$cmd->CreaParametro("@idordenador",0,1);
112$cmd->CreaParametro("@ip","",0);
113$cmd->CreaParametro("@sesion",0,1);
114$cmd->CreaParametro("@parametros","",0);
115$cmd->CreaParametro("@fechahorareg","",0);
116$cmd->CreaParametro("@estado",0,1);
117$cmd->CreaParametro("@resultado",0,1);
118$cmd->CreaParametro("@idcentro",0,1);
119$cmd->CreaParametro("@idprocedimiento",0,1);
120$cmd->CreaParametro("@descripcion","",0);
121$cmd->CreaParametro("@idcomando",0,1);
122$cmd->CreaParametro("@idtarea",0,1);
123$cmd->CreaParametro("@ambito",0,1);
124$cmd->CreaParametro("@idambito",0,1);
125$cmd->CreaParametro("@restrambito","",0);
126$cmd->CreaParametro("@ordprocedimiento",0,1);
127$cmd->CreaParametro("@ordtarea",0,1);
128
129/* PARCHE UHU heredado de la version 1.1.0: Si la accion a realizar es Arrancar incluimos una pagina para arrancar desde el repo */
130switch ($idcomando) {
131        case OG_CMD_ID_WAKEUP:
132                include("wakeonlan_repo.php");
133                break;
134        case OG_CMD_ID_SESSION:
135                session($cadenaip, $atributos);
136                break;
137        case OG_CMD_ID_POWEROFF:
138                poweroff($cadenaip);
139                break;
140        case OG_CMD_ID_CREATE_IMAGE:
141                create_image($cadenaip, $atributos);
142                break;
143        case OG_CMD_ID_RESTORE_IMAGE:
144                restore_image($cadenaip, $atributos);
145                break;
146        case OG_CMD_ID_REBOOT:
147                reboot($cadenaip);
148                break;
149        case OG_CMD_ID_HARDWARE:
150                hardware($cadenaip);
151                break;
152        case OG_CMD_ID_SOFTWARE:
153                software($cadenaip);
154}
155
156if($ambito==0){ // Ambito restringido a un subconjuto de ordenadores con formato (idordenador1,idordenador2,etc)
157        $cmd->ParamSetValor("@restrambito",$idambito);
158        $idambito=0;
159}
160if(!empty($filtro)){ // Ambito restringido a un subconjuto de ordenadores
161        $cmd->ParamSetValor("@restrambito",$filtro);
162}
163$resul=true;
164
165/*--------------------------------------------------------------------------------------------------------------------
166        Switch de ejecución inmediata y de seguimiento
167--------------------------------------------------------------------------------------------------------------------*/
168if($sw_ejya=='on' || $sw_ejprg=="on" ){
169        $parametros=$funcion.$atributos;
170        $aplicacion=chr(13)."ido=".$cadenaid.chr(13)."mac=".$cadenamac.chr(13)."iph=".$cadenaip.chr(13);
171        if($sw_seguimiento==1 || $sw_ejprg=="on"){ // Switch de ejecución con seguimiento o comando programado
172                $sesion=time();
173                $cmd->ParamSetValor("@tipoaccion",$EJECUCION_COMANDO);
174                $cmd->ParamSetValor("@idtipoaccion",$idcomando);
175                $cmd->ParamSetValor("@descriaccion",$descricomando);
176                $cmd->ParamSetValor("@sesion",$sesion);
177                $cmd->ParamSetValor("@idcomando",$idcomando);
178                $cmd->ParamSetValor("@parametros",$parametros);
179                $cmd->ParamSetValor("@fechahorareg",date("y/m/d H:i:s"));
180                if($sw_ejprg=="on") // Switch de ejecución con programación (se para el comando tarea para lanzarlo posteriormente)
181                        $cmd->ParamSetValor("@estado",$ACCION_DETENIDA);
182                else
183                        $cmd->ParamSetValor("@estado",$ACCION_INICIADA);
184                $cmd->ParamSetValor("@resultado",$ACCION_SINRESULTADO);
185                $cmd->ParamSetValor("@ambito",$ambito);
186                $cmd->ParamSetValor("@idambito",$idambito);                     
187                $cmd->ParamSetValor("@idcentro",$idcentro);
188                $auxID=explode(",",$cadenaid);
189                $auxIP=explode(";",$cadenaip);
190                for ($i=0;$i<sizeof($auxID);$i++){
191                        $cmd->ParamSetValor("@idordenador",$auxID[$i]);
192                        $cmd->ParamSetValor("@ip",$auxIP[$i]);
193                        $cmd->texto="INSERT INTO acciones (idordenador,tipoaccion,idtipoaccion,descriaccion,ip,
194                                                sesion,idcomando,parametros,fechahorareg,estado,resultado,ambito,idambito,restrambito,idcentro)
195                                                VALUES (@idordenador,@tipoaccion,@idtipoaccion,@descriaccion,@ip,
196                                                @sesion,@idcomando,@parametros,@fechahorareg,@estado,@resultado,@ambito,@idambito,@restrambito,@idcentro)";
197                        $resul=$cmd->Ejecutar();
198                }
199                $acciones=chr(13)."ids=".$sesion.chr(13); // Para seguimiento
200        }
201        if (!$resul){
202                echo '<SCRIPT language="javascript">';
203                echo 'resultado_comando(7);'.chr(13);
204                echo '</SCRIPT>';
205        }
206        else{
207                $ValorParametros=extrae_parametros($parametros,chr(13),'=');
208                $script=@urldecode($ValorParametros["scp"]);
209                if($sw_ejya=='on'){     
210                        if ($idcomando != OG_CMD_ID_SENDMESSAGE &&
211                            $idcomando != OG_CMD_ID_WAKEUP &&
212                            $idcomando != OG_CMD_ID_CREATE_IMAGE &&
213                            $idcomando != OG_CMD_ID_RESTORE_IMAGE &&
214                            $idcomando != OG_CMD_ID_SESSION &&
215                            $idcomando != OG_CMD_ID_POWEROFF &&
216                            $idcomando != OG_CMD_ID_HARDWARE &&
217                            $idcomando != OG_CMD_ID_SOFTWARE &&
218                            $idcomando != OG_CMD_ID_REBOOT) {
219                            // Envío al servidor
220                            $shidra=new SockHidra($servidorhidra,$hidraport);
221                            if ($shidra->conectar()){ // Se ha establecido la conexión con el servidor hidra
222                                $parametros.=$aplicacion;
223                                $parametros.=$acciones;
224                                $resul=$shidra->envia_comando($parametros);
225                                if($resul)
226                                        $trama=$shidra->recibe_respuesta();
227                                        if($resul){
228                                                $hlonprm=hexdec(substr($trama,$LONCABECERA,$LONHEXPRM));
229                                                $parametros=substr($trama,$LONCABECERA+$LONHEXPRM,$hlonprm);
230                                                $ValorParametros=extrae_parametros($parametros,chr(13),'=');
231                                                $resul=$ValorParametros["res"];
232                                        }
233                                $shidra->desconectar();
234                            }
235                            // Guardamos resultado de ogAgent original
236                            $resulhidra = $resul;
237                        } else {
238                            // En agente nuevo devuelvo siempre correcto
239                            $resulhidra = 1;
240                        }
241
242                        // Comprobamos si el comando es soportado por el nuevo OGAgent
243                        $numip=0;
244                        $ogAgentNuevo = false;
245                        switch ($idcomando) {
246                                case OG_CMD_ID_POWEROFF:
247                                        // Apagar
248                                        $urlcomando = 'poweroff';
249                                        $ogAgentNuevo = true;
250                                        break;
251                                case OG_CMD_ID_REBOOT:
252                                        // Reiniciar
253                                        $urlcomando = 'reboot';
254                                        $ogAgentNuevo = true;
255                                        break;
256                                case OG_CMD_ID_SCRIPT:
257                                        // Ejecutar script
258                                        $urlcomando = 'script';
259                                        $ogAgentNuevo = true;
260                                        $client = (isset ($_POST['modoejecucion']) && $_POST['modoejecucion'] != '' ) ? $_POST['modoejecucion'] : 'true';
261                                        $paramsPost = '{"script":"'.base64_encode($script).'","client":"'.$client.'"}';
262                                        break;
263                                case OG_CMD_ID_SENDMESSAGE:
264                                        // Enviar mensaje
265                                        $urlcomando = 'popup';
266                                        $ogAgentNuevo = true;
267                                        $paramsPost = '{"title":"'.$_POST['titulo'].'","message":"'.$_POST['mensaje'].'"}';
268                                        break;
269                        }
270
271                        // Se envía acción al nuevo ogAgent
272                        if ( $ogAgentNuevo ) {
273                                // Send REST requests to new OGAgent clients.
274                                $urls = array();
275                                $ipsuccess = '';
276                                // Compose array of REST URLs.
277                                $auxIp = explode(';', $cadenaip);
278                                $auxKey = explode(";", $cadenaoga);
279                                $i = 0;
280                                foreach ($auxIp as $ip) {
281                                        $urls[$ip]['url'] = "https://$ip:8000/opengnsys/$urlcomando";
282                                        if (isset($auxKey[$i]))  $urls[$ip]['header'] = Array("Authorization: ".$auxKey[$i]);
283                                        if (isset($paramsPost))  $urls[$ip]['post'] = $paramsPost;
284                                        $i++;
285                                }
286                                // Launch concurrent requests.
287                                $responses = multiRequest($urls);
288                                // Process responses array (IP as array index).
289                                foreach ($responses as $ip => $resp) {
290                                        // Check if response code is OK (200).
291                                        if ($resp['code'] == 200) {
292                                                $ipsuccess .= "'".$ip."',";
293                                                $numip++;
294                                        }
295                                }
296                                // quitamos último carácter ','
297                                $ipsuccess=substr($ipsuccess, 0, -1);
298
299                                // Actualizamos la cola de acciones con los que no dan error
300                                if ( $numip >> 0 ) {
301                                        $fin= date ("Y-m-d H:i:s");
302                                        $cmd->texto="UPDATE acciones SET resultado='1', estado='3', ".
303                                                " descrinotificacion='', fechahorafin='".$fin."' ".
304                                                " WHERE ip IN  ($ipsuccess) AND idcomando='$idcomando' ".
305                                                " ORDER BY idaccion DESC LIMIT $numip";
306                                        $resul=$cmd->Ejecutar();
307                                }
308                        }
309                        // Mostramos mensaje con resultado
310                        if (!$resulhidra && $numip == 0){
311                                echo '<SCRIPT language="javascript">';
312                                echo 'resultado_comando(1);'.chr(13);
313                                echo '</SCRIPT>';
314                        }
315                        else{
316                                echo '<SCRIPT language="javascript">'.chr(13);
317                                if ($avisoRepo) {
318                                        echo 'resultado_comando(17);'.chr(13);
319                                } else {
320                                        echo 'resultado_comando(2);'.chr(13);
321                                }
322                                echo '</SCRIPT>'.chr(13);
323                        }               
324                }
325        }
326}
327/*--------------------------------------------------------------------------------------------------------------------
328        Switch de creación o inclusión en procedimiento
329--------------------------------------------------------------------------------------------------------------------*/
330if($sw_mkprocedimiento=='on' || $sw_mktarea=='on'){
331        $resul=false;
332        if($idprocedimiento==0 || $sw_mktarea=='on'){ // Nuevo procedimiento o Tarea
333                if($sw_mktarea=='on' && empty($nombreprocedimiento)){ // Si tarea con inclusión de procedimiento...
334                        if(!empty($nombretarea))
335                                $nombreprocedimiento="Proc($nombretarea)";      // .. tarea nueva
336                        else
337                                $nombreprocedimiento="Proc($idtarea)";  // .. inclusión en tarea
338                }
339                $cmd->ParamSetValor("@descripcion",$nombreprocedimiento);
340                $cmd->ParamSetValor("@idcentro",$idcentro);
341                $cmd->texto="INSERT INTO procedimientos(descripcion,idcentro) VALUES (@descripcion,@idcentro)";
342                $resul=$cmd->Ejecutar();
343                if($resul){
344                        if($idprocedimiento==0) // Cambia el identificador sólo si es nuevo procedimiento
345                                $idprocedimiento=$cmd->Autonumerico();
346                        if($sw_mktarea=='on')
347                                $idprocedimientotarea=$cmd->Autonumerico(); // Identificador para la tarea;     
348                }
349        }
350        if( $idprocedimiento>0 || $sw_mktarea=='on'){ //  inclusión en procedimiento existente
351                $cmd->ParamSetValor("@idprocedimiento",$idprocedimiento);
352                $cmd->ParamSetValor("@idcomando",$idcomando);
353                $cmd->ParamSetValor("@ordprocedimiento",$ordprocedimiento);
354                $parametros=$funcion.$atributos;
355                $cmd->ParamSetValor("@parametros",$parametros);
356                $cmd->texto="INSERT INTO procedimientos_acciones(idprocedimiento,orden,idcomando,parametros)
357                                    VALUES (@idprocedimiento,@ordprocedimiento,@idcomando,@parametros)";
358                $resul=$cmd->Ejecutar();
359                if($sw_mktarea=='on' && $idprocedimiento!=$idprocedimientotarea){ // Si es tarea se graba para su procedimiento independiente aunque los parametros sean los mismos
360                        $cmd->ParamSetValor("@idprocedimiento",$idprocedimientotarea);         
361                        $cmd->texto="INSERT INTO procedimientos_acciones(idprocedimiento,orden,idcomando,parametros)
362                                            VALUES (@idprocedimiento,@ordprocedimiento,@idcomando,@parametros)";
363                        $resul=$cmd->Ejecutar();
364                }
365        }
366        if (!$resul){
367                echo '<SCRIPT language="javascript">';
368                echo 'resultado_comando(3);'.chr(13);
369                echo '</SCRIPT>';
370        }
371        else{
372                if($sw_mkprocedimiento=='on'){
373                        echo '<SCRIPT language="javascript">'.chr(13);
374                        echo 'resultado_comando(4);'.chr(13);
375                        echo '</SCRIPT>'.chr(13);
376                }
377        }
378}       
379/*--------------------------------------------------------------------------------------------------------------------
380        Switch de creación o inclusión en tarea
381--------------------------------------------------------------------------------------------------------------------*/
382if($sw_mktarea=='on'){
383        $resul=false;
384        if($idtarea==0){ // Nueva tarea
385                $cmd->ParamSetValor("@descripcion",$nombretarea);
386                $cmd->ParamSetValor("@idcentro",$idcentro);
387                $cmd->ParamSetValor("@ambito",$ambito);
388                $cmd->ParamSetValor("@idambito",$idambito);             
389                $cmd->texto="INSERT INTO tareas(descripcion,idcentro,ambito,idambito,restrambito)
390                                        VALUES (@descripcion,@idcentro,@ambito,@idambito,@restrambito)";
391                $resul=$cmd->Ejecutar();
392                if($resul)
393                        $idtarea=$cmd->Autonumerico();
394        }
395        if($idtarea>0){ //  inclusión en tarea existente
396                $cmd->ParamSetValor("@idtarea",$idtarea);
397                $cmd->ParamSetValor("@idprocedimiento",$idprocedimientotarea);
398                $cmd->ParamSetValor("@ordtarea",$ordtarea);
399                $cmd->texto="INSERT INTO tareas_acciones(idtarea,orden,idprocedimiento)
400                                                        VALUES (@idtarea,@ordtarea,@idprocedimiento)";
401                $resul=$cmd->Ejecutar();
402                //echo $cmd->texto;
403        }
404        if (!$resul){
405                echo '<SCRIPT language="javascript">'.chr(13);
406                echo 'resultado_comando(5);'.chr(13);
407                echo '</SCRIPT>'.chr(13);
408        }
409        else{
410                echo '<SCRIPT language="javascript">'.chr(13);
411                echo 'resultado_comando(6);'.chr(13);
412                echo '</SCRIPT>'.chr(13);
413        }
414}
415/* Programación del comando */
416if ($resul){
417        if($sw_ejprg=="on" ){   
418                echo '<SCRIPT language="javascript">'.chr(13);
419                echo 'var whref="../../varios/programaciones.php?idcomando='.$idcomando.'";'.chr(13);
420                echo 'whref+="&sesion='.$sesion.'&descripcioncomando='.UrlEncode($descricomando).'&tipoaccion='.$EJECUCION_COMANDO.'";'.chr(13);
421                echo 'location.href=whref;';
422                echo '</SCRIPT>';
423        }
424}
425?>
426</HEAD>
427<BODY>
428</BODY>
429</HTML>
430
Note: See TracBrowser for help on using the repository browser.