Context Navigation

source: ogServer-Git/src/ogAdmServer.c @ 24c8b94

Last change on this file since 24c8b94 was fe1ce97, checked in by OpenGnSys Support Team <soporte-og@…>, 4 years ago

#988 remove legacy configuration

Use og_server_cfg everywhere. Convert port to string to make it easy for the
dbi API since it expects a string. Remove legacy example configuration file.

Property mode set to 100644

File size: 36.2 KB

Line
1	// *******************************************************************************************************
2	// Servicio: ogAdmServer
3	// Autor: José Manuel Alonso (E.T.S.I.I.) Universidad de Sevilla
4	// Fecha Creación: Marzo-2010
5	// Fecha Última modificación: Marzo-2010
6	// Nombre del fichero: ogAdmServer.cpp
7	// Descripción :Este fichero implementa el servicio de administración general del sistema
8	// *******************************************************************************************************
9	#include "ogAdmServer.h"
10	#include "dbi.h"
11	#include "utils.h"
12	#include "list.h"
13	#include "rest.h"
14	#include "client.h"
15	#include "json.h"
16	#include "schedule.h"
17	#include "wol.h"
18	#include <syslog.h>
19	#include <sys/ioctl.h>
20	#include <sys/types.h>
21	#include <sys/stat.h>
22	#include <fcntl.h>
23	#include <jansson.h>
24	#include <time.h>
25
26	// ________________________________________________________________________________________________________
27	// Función: actualizaConfiguracion
28	//
29	// Descripción:
30	// Esta función actualiza la base de datos con la configuracion de particiones de un cliente
31	// Parámetros:
32	// - db: Objeto base de datos (ya operativo)
33	// - tbl: Objeto tabla
34	// - cfg: cadena con una Configuración
35	// - ido: Identificador del ordenador cliente
36	// Devuelve:
37	// true: Si el proceso es correcto
38	// false: En caso de ocurrir algún error
39	// Especificaciones:
40	// Los parametros de la configuración son:
41	// par= Número de partición
42	// cpt= Codigo o tipo de partición
43	// sfi= Sistema de ficheros que está implementado en la partición
44	// soi= Nombre del sistema de ficheros instalado en la partición
45	// tam= Tamaño de la partición
46	// ________________________________________________________________________________________________________
47	bool actualizaConfiguracion(struct og_dbi dbi, char cfg, int ido)
48	{
49	int lon, p, c,i, dato, swu, idsoi, idsfi,k;
50	char ptrPar[MAXPAR], ptrCfg[7], *ptrDual[2], tbPar[LONSTD];
51	char ser, disk, par, cpt, sfi, soi, tam, uso; // Parametros de configuración.
52	dbi_result result, result_update;
53	const char *msglog;
54
55	lon = 0;
56	p = splitCadena(ptrPar, cfg, '\n');
57	for (i = 0; i < p; i++) {
58	c = splitCadena(ptrCfg, ptrPar[i], '\t');
59
60	// Si la 1ª línea solo incluye el número de serie del equipo; actualizar BD.
61	if (i == 0 && c == 1) {
62	splitCadena(ptrDual, ptrCfg[0], '=');
63	ser = ptrDual[1];
64	if (strlen(ser) > 0) {
65	// Solo actualizar si número de serie no existía.
66	result = dbi_conn_queryf(dbi->conn,
67	"UPDATE ordenadores SET numserie='%s'"
68	" WHERE idordenador=%d AND numserie IS NULL",
69	ser, ido);
70	if (!result) {
71	dbi_conn_error(dbi->conn, &msglog);
72	syslog(LOG_ERR, "failed to query database (%s:%d) %s\n",
73	__func__, __LINE__, msglog);
74	return false;
75	}
76	dbi_result_free(result);
77	}
78	continue;
79	}
80
81	// Distribución de particionado.
82	disk = par = cpt = sfi = soi = tam = uso = NULL;
83
84	splitCadena(ptrDual, ptrCfg[0], '=');
85	disk = ptrDual[1]; // Número de disco
86
87	splitCadena(ptrDual, ptrCfg[1], '=');
88	par = ptrDual[1]; // Número de partición
89
90	k=splitCadena(ptrDual, ptrCfg[2], '=');
91	if(k==2){
92	cpt = ptrDual[1]; // Código de partición
93	}else{
94	cpt = (char*)"0";
95	}
96
97	k=splitCadena(ptrDual, ptrCfg[3], '=');
98	if(k==2){
99	sfi = ptrDual[1]; // Sistema de ficheros
100	/* Comprueba existencia del s0xistema de ficheros instalado */
101	idsfi = checkDato(dbi, sfi, "sistemasficheros", "descripcion","idsistemafichero");
102	}
103	else
104	idsfi=0;
105
106	k=splitCadena(ptrDual, ptrCfg[4], '=');
107	if(k==2){ // Sistema operativo detecdtado
108	soi = ptrDual[1]; // Nombre del S.O. instalado
109	/* Comprueba existencia del sistema operativo instalado */
110	idsoi = checkDato(dbi, soi, "nombresos", "nombreso", "idnombreso");
111	}
112	else
113	idsoi=0;
114
115	splitCadena(ptrDual, ptrCfg[5], '=');
116	tam = ptrDual[1]; // Tamaño de la partición
117
118	splitCadena(ptrDual, ptrCfg[6], '=');
119	uso = ptrDual[1]; // Porcentaje de uso del S.F.
120
121	lon += sprintf(tbPar + lon, "(%s, %s),", disk, par);
122
123	result = dbi_conn_queryf(dbi->conn,
124	"SELECT numdisk, numpar, tamano, uso, idsistemafichero, idnombreso"
125	" FROM ordenadores_particiones"
126	" WHERE idordenador=%d AND numdisk=%s AND numpar=%s",
127	ido, disk, par);
128	if (!result) {
129	dbi_conn_error(dbi->conn, &msglog);
130	syslog(LOG_ERR, "failed to query database (%s:%d) %s\n",
131	__func__, __LINE__, msglog);
132	return false;
133	}
134	if (!dbi_result_next_row(result)) {
135	result_update = dbi_conn_queryf(dbi->conn,
136	"INSERT INTO ordenadores_particiones(idordenador,numdisk,numpar,codpar,tamano,uso,idsistemafichero,idnombreso,idimagen)"
137	" VALUES(%d,%s,%s,0x%s,%s,%s,%d,%d,0)",
138	ido, disk, par, cpt, tam, uso, idsfi, idsoi);
139	if (!result_update) {
140	dbi_conn_error(dbi->conn, &msglog);
141	syslog(LOG_ERR, "failed to query database (%s:%d) %s\n",
142	__func__, __LINE__, msglog);
143	return false;
144	}
145	dbi_result_free(result_update);
146
147	} else { // Existe el registro
148	swu = true; // Se supone que algún dato ha cambiado
149
150	dato = dbi_result_get_uint(result, "tamano");
151	if (atoi(tam) == dato) {// Parámetro tamaño igual al almacenado
152	dato = dbi_result_get_uint(result, "idsistemafichero");
153	if (idsfi == dato) {// Parámetro sistema de fichero igual al almacenado
154	dato = dbi_result_get_uint(result, "idnombreso");
155	if (idsoi == dato) {// Parámetro sistema de fichero distinto al almacenado
156	swu = false; // Todos los parámetros de la partición son iguales, no se actualiza
157	}
158	}
159	}
160	if (swu) { // Hay que actualizar los parámetros de la partición
161	result_update = dbi_conn_queryf(dbi->conn,
162	"UPDATE ordenadores_particiones SET "
163	" codpar=0x%s,"
164	" tamano=%s,"
165	" uso=%s,"
166	" idsistemafichero=%d,"
167	" idnombreso=%d,"
168	" idimagen=0,"
169	" idperfilsoft=0,"
170	" fechadespliegue=NULL"
171	" WHERE idordenador=%d AND numdisk=%s AND numpar=%s",
172	cpt, tam, uso, idsfi, idsoi, ido, disk, par);
173	} else { // Actualizar porcentaje de uso.
174	result_update = dbi_conn_queryf(dbi->conn,
175	"UPDATE ordenadores_particiones SET "
176	" codpar=0x%s,"
177	" uso=%s"
178	" WHERE idordenador=%d AND numdisk=%s AND numpar=%s",
179	cpt, uso, ido, disk, par);
180	}
181	if (!result_update) {
182	dbi_conn_error(dbi->conn, &msglog);
183	syslog(LOG_ERR, "failed to query database (%s:%d) %s\n",
184	__func__, __LINE__, msglog);
185	return false;
186	}
187
188	dbi_result_free(result_update);
189	}
190	dbi_result_free(result);
191	}
192	lon += sprintf(tbPar + lon, "(0,0)");
193	// Eliminar particiones almacenadas que ya no existen
194	result_update = dbi_conn_queryf(dbi->conn,
195	"DELETE FROM ordenadores_particiones WHERE idordenador=%d AND (numdisk, numpar) NOT IN (%s)",
196	ido, tbPar);
197	if (!result_update) {
198	dbi_conn_error(dbi->conn, &msglog);
199	syslog(LOG_ERR, "failed to query database (%s:%d) %s\n",
200	__func__, __LINE__, msglog);
201	return false;
202	}
203	dbi_result_free(result_update);
204
205	return true;
206	}
207	// ________________________________________________________________________________________________________
208	// Función: checkDato
209	//
210	// Descripción:
211	// Esta función comprueba si existe un dato en una tabla y si no es así lo incluye. devuelve en
212	// cualquier caso el identificador del registro existenet o del insertado
213	// Parámetros:
214	// - db: Objeto base de datos (ya operativo)
215	// - tbl: Objeto tabla
216	// - dato: Dato
217	// - tabla: Nombre de la tabla
218	// - nomdato: Nombre del dato en la tabla
219	// - nomidentificador: Nombre del identificador en la tabla
220	// Devuelve:
221	// El identificador del registro existente o el del insertado
222	//
223	// Especificaciones:
224	// En caso de producirse algún error se devuelve el valor 0
225	// ________________________________________________________________________________________________________
226
227	int checkDato(struct og_dbi dbi, char dato, const char *tabla,
228	const char nomdato, const char nomidentificador)
229	{
230	const char *msglog;
231	int identificador;
232	dbi_result result;
233
234	if (strlen(dato) == 0)
235	return (0); // EL dato no tiene valor
236	result = dbi_conn_queryf(dbi->conn,
237	"SELECT %s FROM %s WHERE %s ='%s'", nomidentificador,
238	tabla, nomdato, dato);
239
240	// Ejecuta consulta
241	if (!result) {
242	dbi_conn_error(dbi->conn, &msglog);
243	syslog(LOG_ERR, "failed to query database (%s:%d) %s\n",
244	__func__, __LINE__, msglog);
245	return (0);
246	}
247	if (!dbi_result_next_row(result)) { // Software NO existente
248	dbi_result_free(result);
249
250	result = dbi_conn_queryf(dbi->conn,
251	"INSERT INTO %s (%s) VALUES('%s')", tabla, nomdato, dato);
252	if (!result) {
253	dbi_conn_error(dbi->conn, &msglog);
254	syslog(LOG_ERR, "failed to query database (%s:%d) %s\n",
255	__func__, __LINE__, msglog);
256	return (0);
257	}
258	// Recupera el identificador del software
259	identificador = dbi_conn_sequence_last(dbi->conn, NULL);
260	} else {
261	identificador = dbi_result_get_uint(result, nomidentificador);
262	}
263	dbi_result_free(result);
264
265	return (identificador);
266	}
267
268	// ________________________________________________________________________________________________________
269	// Función: Levanta
270	//
271	// Descripción:
272	// Enciende ordenadores a través de la red cuyas macs se pasan como parámetro
273	// Parámetros:
274	// - iph: Cadena de direcciones ip separadas por ";"
275	// - mac: Cadena de direcciones mac separadas por ";"
276	// - mar: Método de arranque (1=Broadcast, 2=Unicast)
277	// Devuelve:
278	// true: Si el proceso es correcto
279	// false: En caso de ocurrir algún error
280	// ________________________________________________________________________________________________________
281
282	bool Levanta(char ptrIP[], char ptrMacs[], char *ptrNetmasks[], int lon,
283	char *mar)
284	{
285	int i, s;
286
287	s = wol_socket_open();
288	if (s < 0)
289	return false;
290
291	for (i = 0; i < lon; i++) {
292	if (!WakeUp(s, ptrIP[i], ptrMacs[i], ptrNetmasks[i], mar)) {
293	syslog(LOG_ERR, "problem sending magic packet\n");
294	close(s);
295	return false;
296	}
297	}
298	close(s);
299	return true;
300	}
301
302	enum wol_delivery_type {
303	OG_WOL_BROADCAST = 1,
304	OG_WOL_UNICAST = 2
305	};
306
307	//_____________________________________________________________________________________________________________
308	// Función: WakeUp
309	//
310	// Descripción:
311	// Enciende el ordenador cuya MAC se pasa como parámetro
312	// Parámetros:
313	// - s : Socket para enviar trama magic packet
314	// - iph : Cadena con la dirección ip
315	// - mac : Cadena con la dirección mac en formato XXXXXXXXXXXX
316	// - mar: Método de arranque (1=Broadcast, 2=Unicast)
317	// Devuelve:
318	// true: Si el proceso es correcto
319	// false: En caso de ocurrir algún error
320	//_____________________________________________________________________________________________________________
321	//
322	bool WakeUp(int s, char* iph, char mac, char netmask, char *mar)
323	{
324	struct in_addr addr, netmask_addr, broadcast_addr ={};
325	unsigned int macaddr[OG_WOL_MACADDR_LEN];
326	char HDaddress_bin[OG_WOL_MACADDR_LEN];
327	struct sockaddr_in WakeUpCliente;
328	struct wol_msg Trama_WakeUp;
329	bool ret;
330	int i;
331
332	if (inet_aton(iph, &addr) < 0) {
333	syslog(LOG_ERR, "bad IP address\n");
334	return false;
335	}
336
337	if (inet_aton(netmask, &netmask_addr) < 0) {
338	syslog(LOG_ERR, "bad netmask address: %s\n", netmask);
339	return false;
340	}
341
342	broadcast_addr.s_addr = addr.s_addr \| ~netmask_addr.s_addr;
343
344	for (i = 0; i < 6; i++) // Primera secuencia de la trama Wake Up (0xFFFFFFFFFFFF)
345	Trama_WakeUp.secuencia_FF[i] = 0xFF;
346
347	sscanf(mac, "%02x%02x%02x%02x%02x%02x",
348	&macaddr[0], &macaddr[1], &macaddr[2],
349	&macaddr[3], &macaddr[4], &macaddr[5]);
350
351	for (i = 0; i < 6; i++)
352	HDaddress_bin[i] = (uint8_t)macaddr[i];
353
354	for (i = 0; i < 16; i++) // Segunda secuencia de la trama Wake Up , repetir 16 veces su la MAC
355	memcpy(&Trama_WakeUp.macbin[i][0], &HDaddress_bin, 6);
356
357	/* Creación de socket del cliente que recibe la trama magic packet */
358	WakeUpCliente.sin_family = AF_INET;
359	WakeUpCliente.sin_port = htons((short) PUERTO_WAKEUP);
360
361	switch (atoi(mar)) {
362	case OG_WOL_BROADCAST:
363	ret = wake_up_broadcast(s, &WakeUpCliente, &Trama_WakeUp);
364	ret &= wake_up_send(s, &WakeUpCliente, &Trama_WakeUp,
365	&broadcast_addr);
366	break;
367	case OG_WOL_UNICAST:
368	ret = wake_up_send(s, &WakeUpCliente, &Trama_WakeUp, &addr);
369	break;
370	default:
371	syslog(LOG_ERR, "unknown wol type\n");
372	ret = false;
373	break;
374	}
375	return ret;
376	}
377
378	// ________________________________________________________________________________________________________
379	// Función: actualizaCreacionImagen
380	//
381	// Descripción:
382	// Esta función actualiza la base de datos con el resultado de la creación de una imagen
383	// Parámetros:
384	// - db: Objeto base de datos (ya operativo)
385	// - tbl: Objeto tabla
386	// - idi: Identificador de la imagen
387	// - dsk: Disco de donde se creó
388	// - par: Partición de donde se creó
389	// - cpt: Código de partición
390	// - ipr: Ip del repositorio
391	// - ido: Identificador del ordenador modelo
392	// Devuelve:
393	// true: Si el proceso es correcto
394	// false: En caso de ocurrir algún error
395	// ________________________________________________________________________________________________________
396	bool actualizaCreacionImagen(struct og_dbi dbi, char idi, char *dsk,
397	char par, char cpt, char ipr, char ido)
398	{
399	const char *msglog;
400	dbi_result result;
401	int idr,ifs;
402
403	/* Toma identificador del repositorio correspondiente al ordenador modelo */
404	result = dbi_conn_queryf(dbi->conn,
405	"SELECT repositorios.idrepositorio"
406	" FROM repositorios"
407	" LEFT JOIN ordenadores USING (idrepositorio)"
408	" WHERE repositorios.ip='%s' AND ordenadores.idordenador=%s", ipr, ido);
409
410	if (!result) {
411	dbi_conn_error(dbi->conn, &msglog);
412	syslog(LOG_ERR, "failed to query database (%s:%d) %s\n",
413	__func__, __LINE__, msglog);
414	return false;
415	}
416	if (!dbi_result_next_row(result)) {
417	syslog(LOG_ERR,
418	"repository does not exist in database (%s:%d)\n",
419	__func__, __LINE__);
420	dbi_result_free(result);
421	return false;
422	}
423	idr = dbi_result_get_uint(result, "idrepositorio");
424	dbi_result_free(result);
425
426	/* Toma identificador del perfilsoftware */
427	result = dbi_conn_queryf(dbi->conn,
428	"SELECT idperfilsoft"
429	" FROM ordenadores_particiones"
430	" WHERE idordenador=%s AND numdisk=%s AND numpar=%s", ido, dsk, par);
431
432	if (!result) {
433	dbi_conn_error(dbi->conn, &msglog);
434	syslog(LOG_ERR, "failed to query database (%s:%d) %s\n",
435	__func__, __LINE__, msglog);
436	return false;
437	}
438	if (!dbi_result_next_row(result)) {
439	syslog(LOG_ERR,
440	"software profile does not exist in database (%s:%d)\n",
441	__func__, __LINE__);
442	dbi_result_free(result);
443	return false;
444	}
445	ifs = dbi_result_get_uint(result, "idperfilsoft");
446	dbi_result_free(result);
447
448	/* Actualizar los datos de la imagen */
449	result = dbi_conn_queryf(dbi->conn,
450	"UPDATE imagenes"
451	" SET idordenador=%s, numdisk=%s, numpar=%s, codpar=%s,"
452	" idperfilsoft=%d, idrepositorio=%d,"
453	" fechacreacion=NOW(), revision=revision+1"
454	" WHERE idimagen=%s", ido, dsk, par, cpt, ifs, idr, idi);
455
456	if (!result) {
457	dbi_conn_error(dbi->conn, &msglog);
458	syslog(LOG_ERR, "failed to query database (%s:%d) %s\n",
459	__func__, __LINE__, msglog);
460	return false;
461	}
462	dbi_result_free(result);
463
464	/* Actualizar los datos en el cliente */
465	result = dbi_conn_queryf(dbi->conn,
466	"UPDATE ordenadores_particiones"
467	" SET idimagen=%s, revision=(SELECT revision FROM imagenes WHERE idimagen=%s),"
468	" fechadespliegue=NOW()"
469	" WHERE idordenador=%s AND numdisk=%s AND numpar=%s",
470	idi, idi, ido, dsk, par);
471	if (!result) {
472	dbi_conn_error(dbi->conn, &msglog);
473	syslog(LOG_ERR, "failed to query database (%s:%d) %s\n",
474	__func__, __LINE__, msglog);
475	return false;
476	}
477	dbi_result_free(result);
478
479	return true;
480	}
481
482	// ________________________________________________________________________________________________________
483	// Función: actualizaRestauracionImagen
484	//
485	// Descripción:
486	// Esta función actualiza la base de datos con el resultado de la restauración de una imagen
487	// Parámetros:
488	// - db: Objeto base de datos (ya operativo)
489	// - tbl: Objeto tabla
490	// - idi: Identificador de la imagen
491	// - dsk: Disco de donde se restauró
492	// - par: Partición de donde se restauró
493	// - ido: Identificador del cliente donde se restauró
494	// - ifs: Identificador del perfil software contenido en la imagen
495	// Devuelve:
496	// true: Si el proceso es correcto
497	// false: En caso de ocurrir algún error
498	// ________________________________________________________________________________________________________
499	bool actualizaRestauracionImagen(struct og_dbi dbi, char idi,
500	char dsk, char par, char ido, char ifs)
501	{
502	const char *msglog;
503	dbi_result result;
504
505	/* Actualizar los datos de la imagen */
506	result = dbi_conn_queryf(dbi->conn,
507	"UPDATE ordenadores_particiones"
508	" SET idimagen=%s, idperfilsoft=%s, fechadespliegue=NOW(),"
509	" revision=(SELECT revision FROM imagenes WHERE idimagen=%s),"
510	" idnombreso=IFNULL((SELECT idnombreso FROM perfilessoft WHERE idperfilsoft=%s),0)"
511	" WHERE idordenador=%s AND numdisk=%s AND numpar=%s", idi, ifs, idi, ifs, ido, dsk, par);
512
513	if (!result) {
514	dbi_conn_error(dbi->conn, &msglog);
515	syslog(LOG_ERR, "failed to query database (%s:%d) %s\n",
516	__func__, __LINE__, msglog);
517	return false;
518	}
519	dbi_result_free(result);
520
521	return true;
522	}
523	// ________________________________________________________________________________________________________
524	// Función: actualizaHardware
525	//
526	// Descripción:
527	// Actualiza la base de datos con la configuracion hardware del cliente
528	// Parámetros:
529	// - db: Objeto base de datos (ya operativo)
530	// - tbl: Objeto tabla
531	// - hrd: cadena con el inventario hardware
532	// - ido: Identificador del ordenador
533	// - npc: Nombre del ordenador
534	// - idc: Identificador del centro o Unidad organizativa
535	// ________________________________________________________________________________________________________
536	//
537	bool actualizaHardware(struct og_dbi dbi, char hrd, char ido, char npc,
538	char *idc)
539	{
540	const char *msglog;
541	int idtipohardware, idperfilhard;
542	int lon, i, j, aux;
543	bool retval;
544	char *whard;
545	int tbidhardware[MAXHARDWARE];
546	char tbHardware[MAXHARDWARE],dualHardware[2], strInt[LONINT], *idhardwares;
547	dbi_result result;
548
549	/* Toma Centro (Unidad Organizativa) */
550	result = dbi_conn_queryf(dbi->conn,
551	"SELECT idperfilhard FROM ordenadores WHERE idordenador=%s",
552	ido);
553	if (!result) {
554	dbi_conn_error(dbi->conn, &msglog);
555	syslog(LOG_ERR, "failed to query database (%s:%d) %s\n",
556	__func__, __LINE__, msglog);
557	return false;
558	}
559	if (!dbi_result_next_row(result)) {
560	syslog(LOG_ERR, "client does not exist in database (%s:%d)\n",
561	__func__, __LINE__);
562	dbi_result_free(result);
563	return false;
564	}
565	idperfilhard = dbi_result_get_uint(result, "idperfilhard");
566	dbi_result_free(result);
567
568	whard=escaparCadena(hrd); // Codificar comillas simples
569	if(!whard)
570	return false;
571	/* Recorre componentes hardware*/
572	lon = splitCadena(tbHardware, whard, '\n');
573	if (lon > MAXHARDWARE)
574	lon = MAXHARDWARE; // Limita el número de componentes hardware
575	/*
576	for (i=0;i<lon;i++){
577	sprintf(msglog,"Linea de inventario: %s",tbHardware[i]);
578	RegistraLog(msglog,false);
579	}
580	*/
581	for (i = 0; i < lon; i++) {
582	splitCadena(dualHardware, rTrim(tbHardware[i]), '=');
583	//sprintf(msglog,"nemonico: %s",dualHardware[0]);
584	//RegistraLog(msglog,false);
585	//sprintf(msglog,"valor: %s",dualHardware[1]);
586	//RegistraLog(msglog,false);
587	result = dbi_conn_queryf(dbi->conn,
588	"SELECT idtipohardware,descripcion FROM tipohardwares WHERE nemonico='%s'",
589	dualHardware[0]);
590	if (!result) {
591	dbi_conn_error(dbi->conn, &msglog);
592	syslog(LOG_ERR, "failed to query database (%s:%d) %s\n",
593	__func__, __LINE__, msglog);
594	return false;
595	}
596	if (!dbi_result_next_row(result)) { // Tipo de Hardware NO existente
597	dbi_result_free(result);
598	return false;
599	} else { // Tipo de Hardware Existe
600	idtipohardware = dbi_result_get_uint(result, "idtipohardware");
601	dbi_result_free(result);
602
603	result = dbi_conn_queryf(dbi->conn,
604	"SELECT idhardware FROM hardwares WHERE idtipohardware=%d AND descripcion='%s'",
605	idtipohardware, dualHardware[1]);
606
607	if (!result) {
608	dbi_conn_error(dbi->conn, &msglog);
609	syslog(LOG_ERR, "failed to query database (%s:%d) %s\n",
610	__func__, __LINE__, msglog);
611	return false;
612	}
613
614	if (!dbi_result_next_row(result)) { // Hardware NO existente
615	dbi_result_free(result);
616	result = dbi_conn_queryf(dbi->conn,
617	"INSERT hardwares (idtipohardware,descripcion,idcentro,grupoid) "
618	" VALUES(%d,'%s',%s,0)", idtipohardware,
619	dualHardware[1], idc);
620	if (!result) {
621	dbi_conn_error(dbi->conn, &msglog);
622	syslog(LOG_ERR, "failed to query database (%s:%d) %s\n",
623	__func__, __LINE__, msglog);
624	return false;
625	}
626
627	// Recupera el identificador del hardware
628	tbidhardware[i] = dbi_conn_sequence_last(dbi->conn, NULL);
629	} else {
630	tbidhardware[i] = dbi_result_get_uint(result, "idhardware");
631	}
632	dbi_result_free(result);
633	}
634	}
635	// Ordena tabla de identificadores para cosultar si existe un pefil con esas especificaciones
636
637	for (i = 0; i < lon - 1; i++) {
638	for (j = i + 1; j < lon; j++) {
639	if (tbidhardware[i] > tbidhardware[j]) {
640	aux = tbidhardware[i];
641	tbidhardware[i] = tbidhardware[j];
642	tbidhardware[j] = aux;
643	}
644	}
645	}
646	/* Crea cadena de identificadores de componentes hardware separados por coma */
647	sprintf(strInt, "%d", tbidhardware[lon - 1]); // Pasa a cadena el último identificador que es de mayor longitud
648	aux = strlen(strInt); // Calcula longitud de cadena para reservar espacio a todos los perfiles
649	idhardwares = calloc(1, sizeof(aux) * lon + lon);
650	if (idhardwares == NULL) {
651	syslog(LOG_ERR, "%s:%d OOM\n", __FILE__, __LINE__);
652	return false;
653	}
654	aux = sprintf(idhardwares, "%d", tbidhardware[0]);
655	for (i = 1; i < lon; i++)
656	aux += sprintf(idhardwares + aux, ",%d", tbidhardware[i]);
657
658	if (!cuestionPerfilHardware(dbi, idc, ido, idperfilhard, idhardwares,
659	npc, tbidhardware, lon)) {
660	syslog(LOG_ERR, "Problem updating client hardware\n");
661	retval=false;
662	} else {
663	retval=true;
664	}
665	free(whard);
666	free(idhardwares);
667
668	return (retval);
669	}
670	// ________________________________________________________________________________________________________
671	// Función: cuestionPerfilHardware
672	//
673	// Descripción:
674	// Comprueba existencia de perfil hardware y actualización de éste para el ordenador
675	// Parámetros:
676	// - db: Objeto base de datos (ya operativo)
677	// - tbl: Objeto tabla
678	// - idc: Identificador de la Unidad organizativa donde se encuentra el cliente
679	// - ido: Identificador del ordenador
680	// - tbidhardware: Identificador del tipo de hardware
681	// - con: Número de componentes detectados para configurar un el perfil hardware
682	// - npc: Nombre del cliente
683	// ________________________________________________________________________________________________________
684	bool cuestionPerfilHardware(struct og_dbi dbi, char idc, char *ido,
685	int idperfilhardware, char idhardwares, char npc, int *tbidhardware,
686	int lon)
687	{
688	const char *msglog;
689	dbi_result result;
690	int i;
691	int nwidperfilhard;
692
693	// Busca perfil hard del ordenador que contenga todos los componentes hardware encontrados
694	result = dbi_conn_queryf(dbi->conn,
695	"SELECT idperfilhard FROM"
696	" (SELECT perfileshard_hardwares.idperfilhard as idperfilhard,"
697	" group_concat(cast(perfileshard_hardwares.idhardware AS char( 11) )"
698	" ORDER BY perfileshard_hardwares.idhardware SEPARATOR ',' ) AS idhardwares"
699	" FROM perfileshard_hardwares"
700	" GROUP BY perfileshard_hardwares.idperfilhard) AS temp"
701	" WHERE idhardwares LIKE '%s'", idhardwares);
702
703	if (!result) {
704	dbi_conn_error(dbi->conn, &msglog);
705	syslog(LOG_ERR, "failed to query database (%s:%d) %s\n",
706	__func__, __LINE__, msglog);
707	return false;
708	}
709	if (!dbi_result_next_row(result)) {
710	// No existe un perfil hardware con esos componentes de componentes hardware, lo crea
711	dbi_result_free(result);
712	result = dbi_conn_queryf(dbi->conn,
713	"INSERT perfileshard (descripcion,idcentro,grupoid)"
714	" VALUES('Perfil hardware (%s) ',%s,0)", npc, idc);
715	if (!result) {
716	dbi_conn_error(dbi->conn, &msglog);
717	syslog(LOG_ERR, "failed to query database (%s:%d) %s\n",
718	__func__, __LINE__, msglog);
719	return false;
720	}
721	dbi_result_free(result);
722
723	// Recupera el identificador del nuevo perfil hardware
724	nwidperfilhard = dbi_conn_sequence_last(dbi->conn, NULL);
725
726	// Crea la relación entre perfiles y componenetes hardware
727	for (i = 0; i < lon; i++) {
728	result = dbi_conn_queryf(dbi->conn,
729	"INSERT perfileshard_hardwares (idperfilhard,idhardware)"
730	" VALUES(%d,%d)", nwidperfilhard, tbidhardware[i]);
731	if (!result) {
732	dbi_conn_error(dbi->conn, &msglog);
733	syslog(LOG_ERR, "failed to query database (%s:%d) %s\n",
734	__func__, __LINE__, msglog);
735	return false;
736	}
737	dbi_result_free(result);
738	}
739	} else { // Existe un perfil con todos esos componentes
740	nwidperfilhard = dbi_result_get_uint(result, "idperfilhard");
741	dbi_result_free(result);
742	}
743	if (idperfilhardware != nwidperfilhard) { // No coinciden los perfiles
744	// Actualiza el identificador del perfil hardware del ordenador
745	result = dbi_conn_queryf(dbi->conn,
746	"UPDATE ordenadores SET idperfilhard=%d"
747	" WHERE idordenador=%s", nwidperfilhard, ido);
748	if (!result) {
749	dbi_conn_error(dbi->conn, &msglog);
750	syslog(LOG_ERR, "failed to query database (%s:%d) %s\n",
751	__func__, __LINE__, msglog);
752	return false;
753	}
754	dbi_result_free(result);
755	}
756	/* Eliminar Relación de hardwares con Perfiles hardware que quedan húerfanos */
757	result = dbi_conn_queryf(dbi->conn,
758	"DELETE FROM perfileshard_hardwares WHERE idperfilhard IN "
759	" (SELECT idperfilhard FROM perfileshard WHERE idperfilhard NOT IN"
760	" (SELECT DISTINCT idperfilhard from ordenadores))");
761	if (!result) {
762	dbi_conn_error(dbi->conn, &msglog);
763	syslog(LOG_ERR, "failed to query database (%s:%d) %s\n",
764	__func__, __LINE__, msglog);
765	return false;
766	}
767	dbi_result_free(result);
768
769	/* Eliminar Perfiles hardware que quedan húerfanos */
770	result = dbi_conn_queryf(dbi->conn,
771	"DELETE FROM perfileshard WHERE idperfilhard NOT IN"
772	" (SELECT DISTINCT idperfilhard FROM ordenadores)");
773	if (!result) {
774	dbi_conn_error(dbi->conn, &msglog);
775	syslog(LOG_ERR, "failed to query database (%s:%d) %s\n",
776	__func__, __LINE__, msglog);
777	return false;
778	}
779	dbi_result_free(result);
780
781	/* Eliminar Relación de hardwares con Perfiles hardware que quedan húerfanos */
782	result = dbi_conn_queryf(dbi->conn,
783	"DELETE FROM perfileshard_hardwares WHERE idperfilhard NOT IN"
784	" (SELECT idperfilhard FROM perfileshard)");
785	if (!result) {
786	dbi_conn_error(dbi->conn, &msglog);
787	syslog(LOG_ERR, "failed to query database (%s:%d) %s\n",
788	__func__, __LINE__, msglog);
789	return false;
790	}
791	dbi_result_free(result);
792
793	return true;
794	}
795	// ________________________________________________________________________________________________________
796	// Función: actualizaSoftware
797	//
798	// Descripción:
799	// Actualiza la base de datos con la configuración software del cliente
800	// Parámetros:
801	// - db: Objeto base de datos (ya operativo)
802	// - tbl: Objeto tabla
803	// - sft: cadena con el inventario software
804	// - par: Número de la partición
805	// - ido: Identificador del ordenador del cliente en la tabla
806	// - npc: Nombre del ordenador
807	// - idc: Identificador del centro o Unidad organizativa
808	// Devuelve:
809	// true: Si el proceso es correcto
810	// false: En caso de ocurrir algún error
811	//
812	// Versión 1.1.0: Se incluye el sistema operativo. Autora: Irina Gómez - ETSII Universidad Sevilla
813	// ________________________________________________________________________________________________________
814	bool actualizaSoftware(struct og_dbi dbi, char sft, char par,char ido,
815	char npc, char idc)
816	{
817	int i, j, lon, aux, idperfilsoft, idnombreso;
818	bool retval;
819	char *wsft;
820	int tbidsoftware[MAXSOFTWARE];
821	char tbSoftware[MAXSOFTWARE], strInt[LONINT], idsoftwares;
822	const char *msglog;
823	dbi_result result;
824
825	/* Toma Centro (Unidad Organizativa) y perfil software */
826	result = dbi_conn_queryf(dbi->conn,
827	"SELECT idperfilsoft,numpar"
828	" FROM ordenadores_particiones"
829	" WHERE idordenador=%s", ido);
830	if (!result) {
831	dbi_conn_error(dbi->conn, &msglog);
832	syslog(LOG_ERR, "failed to query database (%s:%d) %s\n",
833	__func__, __LINE__, msglog);
834	return false;
835	}
836	idperfilsoft = 0; // Por defecto se supone que el ordenador no tiene aún detectado el perfil software
837	while (dbi_result_next_row(result)) {
838	aux = dbi_result_get_uint(result, "numpar");
839	if (aux == atoi(par)) { // Se encuentra la partición
840	idperfilsoft = dbi_result_get_uint(result, "idperfilsoft");
841	break;
842	}
843	}
844	dbi_result_free(result);
845	wsft=escaparCadena(sft); // Codificar comillas simples
846	if(!wsft)
847	return false;
848
849	/* Recorre componentes software*/
850	lon = splitCadena(tbSoftware, wsft, '\n');
851
852	if (lon == 0)
853	return true; // No hay lineas que procesar
854	if (lon > MAXSOFTWARE)
855	lon = MAXSOFTWARE; // Limita el número de componentes software
856
857	idnombreso = 0;
858	for (i = 0; i < lon; i++) {
859	// Primera línea es el sistema operativo: se obtiene identificador
860	if (i == 0) {
861	idnombreso = checkDato(dbi, rTrim(tbSoftware[i]), "nombresos", "nombreso", "idnombreso");
862	continue;
863	}
864
865	result = dbi_conn_queryf(dbi->conn,
866	"SELECT idsoftware FROM softwares WHERE descripcion ='%s'",
867	rTrim(tbSoftware[i]));
868	if (!result) {
869	dbi_conn_error(dbi->conn, &msglog);
870	syslog(LOG_ERR, "failed to query database (%s:%d) %s\n",
871	__func__, __LINE__, msglog);
872	return false;
873	}
874
875	if (!dbi_result_next_row(result)) {
876	dbi_result_free(result);
877	result = dbi_conn_queryf(dbi->conn,
878	"INSERT INTO softwares (idtiposoftware,descripcion,idcentro,grupoid)"
879	" VALUES(2,'%s',%s,0)", tbSoftware[i], idc);
880	if (!result) { // Error al insertar
881	dbi_conn_error(dbi->conn, &msglog);
882	syslog(LOG_ERR, "failed to query database (%s:%d) %s\n",
883	__func__, __LINE__, msglog);
884	return false;
885	}
886
887	// Recupera el identificador del software
888	tbidsoftware[i] = dbi_conn_sequence_last(dbi->conn, NULL);
889	} else {
890	tbidsoftware[i] = dbi_result_get_uint(result, "idsoftware");
891	}
892	dbi_result_free(result);
893	}
894
895	// Ordena tabla de identificadores para cosultar si existe un pefil con esas especificaciones
896
897	for (i = 0; i < lon - 1; i++) {
898	for (j = i + 1; j < lon; j++) {
899	if (tbidsoftware[i] > tbidsoftware[j]) {
900	aux = tbidsoftware[i];
901	tbidsoftware[i] = tbidsoftware[j];
902	tbidsoftware[j] = aux;
903	}
904	}
905	}
906	/* Crea cadena de identificadores de componentes software separados por coma */
907	sprintf(strInt, "%d", tbidsoftware[lon - 1]); // Pasa a cadena el último identificador que es de mayor longitud
908	aux = strlen(strInt); // Calcula longitud de cadena para reservar espacio a todos los perfiles
909	idsoftwares = calloc(1, (sizeof(aux)+1) * lon + lon);
910	if (idsoftwares == NULL) {
911	syslog(LOG_ERR, "%s:%d OOM\n", __FILE__, __LINE__);
912	return false;
913	}
914	aux = sprintf(idsoftwares, "%d", tbidsoftware[0]);
915	for (i = 1; i < lon; i++)
916	aux += sprintf(idsoftwares + aux, ",%d", tbidsoftware[i]);
917
918	// Comprueba existencia de perfil software y actualización de éste para el ordenador
919	if (!cuestionPerfilSoftware(dbi, idc, ido, idperfilsoft, idnombreso, idsoftwares,
920	npc, par, tbidsoftware, lon)) {
921	syslog(LOG_ERR, "failed to query database (%s:%d) %s\n",
922	__func__, __LINE__, msglog);
923	retval=false;
924	} else {
925	retval=true;
926	}
927	free(wsft);
928	free(idsoftwares);
929
930	return retval;
931	}
932	// ________________________________________________________________________________________________________
933	// Función: CuestionPerfilSoftware
934	//
935	// Parámetros:
936	// - db: Objeto base de datos (ya operativo)
937	// - tbl: Objeto tabla
938	// - idcentro: Identificador del centro en la tabla
939	// - ido: Identificador del ordenador del cliente en la tabla
940	// - idnombreso: Identificador del sistema operativo
941	// - idsoftwares: Cadena con los identificadores de componentes software separados por comas
942	// - npc: Nombre del ordenador del cliente
943	// - particion: Número de la partición
944	// - tbidsoftware: Array con los identificadores de componentes software
945	// - lon: Número de componentes
946	// Devuelve:
947	// true: Si el proceso es correcto
948	// false: En caso de ocurrir algún error
949	//
950	// Versión 1.1.0: Se incluye el sistema operativo. Autora: Irina Gómez - ETSII Universidad Sevilla
951	//_________________________________________________________________________________________________________
952	bool cuestionPerfilSoftware(struct og_dbi dbi, char idc, char *ido,
953	int idperfilsoftware, int idnombreso,
954	char idsoftwares, char npc, char *par,
955	int *tbidsoftware, int lon)
956	{
957	int i, nwidperfilsoft;
958	const char *msglog;
959	dbi_result result;
960
961	// Busca perfil soft del ordenador que contenga todos los componentes software encontrados
962	result = dbi_conn_queryf(dbi->conn,
963	"SELECT idperfilsoft FROM"
964	" (SELECT perfilessoft_softwares.idperfilsoft as idperfilsoft,"
965	" group_concat(cast(perfilessoft_softwares.idsoftware AS char( 11) )"
966	" ORDER BY perfilessoft_softwares.idsoftware SEPARATOR ',' ) AS idsoftwares"
967	" FROM perfilessoft_softwares"
968	" GROUP BY perfilessoft_softwares.idperfilsoft) AS temp"
969	" WHERE idsoftwares LIKE '%s'", idsoftwares);
970
971	if (!result) {
972	dbi_conn_error(dbi->conn, &msglog);
973	syslog(LOG_ERR, "failed to query database (%s:%d) %s\n",
974	__func__, __LINE__, msglog);
975	return false;
976	}
977	if (!dbi_result_next_row(result)) { // No existe un perfil software con esos componentes de componentes software, lo crea
978	dbi_result_free(result);
979	result = dbi_conn_queryf(dbi->conn,
980	"INSERT perfilessoft (descripcion, idcentro, grupoid, idnombreso)"
981	" VALUES('Perfil Software (%s, Part:%s) ',%s,0,%i)", npc, par, idc,idnombreso);
982	if (!result) {
983	dbi_conn_error(dbi->conn, &msglog);
984	syslog(LOG_ERR, "failed to query database (%s:%d) %s\n",
985	__func__, __LINE__, msglog);
986	return false;
987	}
988
989	dbi_result_free(result);
990	// Recupera el identificador del nuevo perfil software
991	nwidperfilsoft = dbi_conn_sequence_last(dbi->conn, NULL);
992
993	// Crea la relación entre perfiles y componenetes software
994	for (i = 0; i < lon; i++) {
995	result = dbi_conn_queryf(dbi->conn,
996	"INSERT perfilessoft_softwares (idperfilsoft,idsoftware)"
997	" VALUES(%d,%d)", nwidperfilsoft, tbidsoftware[i]);
998	if (!result) {
999	dbi_conn_error(dbi->conn, &msglog);
1000	syslog(LOG_ERR, "failed to query database (%s:%d) %s\n",
1001	__func__, __LINE__, msglog);
1002	return false;
1003	}
1004	dbi_result_free(result);
1005	}
1006	} else { // Existe un perfil con todos esos componentes
1007	nwidperfilsoft = dbi_result_get_uint(result, "idperfilsoft");
1008	dbi_result_free(result);
1009	}
1010
1011	if (idperfilsoftware != nwidperfilsoft) { // No coinciden los perfiles
1012	// Actualiza el identificador del perfil software del ordenador
1013	result = dbi_conn_queryf(dbi->conn,
1014	"UPDATE ordenadores_particiones SET idperfilsoft=%d,idimagen=0"
1015	" WHERE idordenador=%s AND numpar=%s", nwidperfilsoft, ido, par);
1016	if (!result) { // Error al insertar
1017	dbi_conn_error(dbi->conn, &msglog);
1018	syslog(LOG_ERR, "failed to query database (%s:%d) %s\n",
1019	__func__, __LINE__, msglog);
1020	return false;
1021	}
1022	dbi_result_free(result);
1023	}
1024
1025	/* DEPURACIÓN DE PERFILES SOFTWARE */
1026
1027	/* Eliminar Relación de softwares con Perfiles software que quedan húerfanos */
1028	result = dbi_conn_queryf(dbi->conn,
1029	"DELETE FROM perfilessoft_softwares WHERE idperfilsoft IN "\
1030	" (SELECT idperfilsoft FROM perfilessoft WHERE idperfilsoft NOT IN"\
1031	" (SELECT DISTINCT idperfilsoft from ordenadores_particiones) AND idperfilsoft NOT IN"\
1032	" (SELECT DISTINCT idperfilsoft from imagenes))");
1033	if (!result) {
1034	dbi_conn_error(dbi->conn, &msglog);
1035	syslog(LOG_ERR, "failed to query database (%s:%d) %s\n",
1036	__func__, __LINE__, msglog);
1037	return false;
1038	}
1039	dbi_result_free(result),
1040	/* Eliminar Perfiles software que quedan húerfanos */
1041	result = dbi_conn_queryf(dbi->conn,
1042	"DELETE FROM perfilessoft WHERE idperfilsoft NOT IN"
1043	" (SELECT DISTINCT idperfilsoft from ordenadores_particiones)"\
1044	" AND idperfilsoft NOT IN"\
1045	" (SELECT DISTINCT idperfilsoft from imagenes)");
1046	if (!result) {
1047	dbi_conn_error(dbi->conn, &msglog);
1048	syslog(LOG_ERR, "failed to query database (%s:%d) %s\n",
1049	__func__, __LINE__, msglog);
1050	return false;
1051	}
1052	dbi_result_free(result),
1053
1054	/* Eliminar Relación de softwares con Perfiles software que quedan húerfanos */
1055	result = dbi_conn_queryf(dbi->conn,
1056	"DELETE FROM perfilessoft_softwares WHERE idperfilsoft NOT IN"
1057	" (SELECT idperfilsoft from perfilessoft)");
1058	if (!result) {
1059	dbi_conn_error(dbi->conn, &msglog);
1060	syslog(LOG_ERR, "failed to query database (%s:%d) %s\n",
1061	__func__, __LINE__, msglog);
1062	return false;
1063	}
1064	dbi_result_free(result);
1065
1066	return true;
1067	}

Note: See TracBrowser for help on using the repository browser.

Download in other formats: