source: ogServer-Git/src/ogAdmServer.c @ 6fc89cd

Last change on this file since 6fc89cd was 6fc89cd, checked in by OpenGnSys Support Team <soporte-og@…>, 3 years ago

#1042 incorrect initialization of software profiles array

The position 0 of the software profiles array is not initialized,
this triggers a bug randomly on image creation if the position 0
comes zero. Adjust the loop to initialize position 0 accordingly.

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