48k.eu-mirror
/
ogserver
mirror of https://git.48k.eu/ogserver
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

#941 use dbi layer from actualizaConfiguracion()

master
OpenGnSys Support Team 2019-05-17 18:53:38 +02:00
parent 0fde10b973
commit fa6b891637
2 changed files with 164 additions and 251 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

405
sources/ogAdmServer.cpp
View File

@ -388,8 +388,6 @@ bool procesoInclusionCliente(struct og_client *cli, TRAMA *ptrTrama)
const char *msglog, *str; const char *msglog, *str;
struct og_dbi *dbi; struct og_dbi *dbi;
dbi_result result; dbi_result result;
Database db;
Table tbl;
char *iph, *cfg; char *iph, *cfg;
char nombreordenador[LONFIL]; char nombreordenador[LONFIL];
@ -399,14 +397,6 @@ bool procesoInclusionCliente(struct og_client *cli, TRAMA *ptrTrama)
iph = copiaParametro("iph",ptrTrama); // Toma ip iph = copiaParametro("iph",ptrTrama); // Toma ip
cfg = copiaParametro("cfg",ptrTrama); // Toma configuracion cfg = copiaParametro("cfg",ptrTrama); // Toma configuracion
if (!db.Open(usuario, pasguor, datasource, catalog)) {
liberaMemoria(iph);
liberaMemoria(cfg);
syslog(LOG_ERR, "cannot open connection database (%s:%d)\n",
__func__, __LINE__);
return false;
}
dbi = og_dbi_open(&dbi_config); dbi = og_dbi_open(&dbi_config);
if (!dbi) { if (!dbi) {
syslog(LOG_ERR, "cannot open connection database (%s:%d)\n", syslog(LOG_ERR, "cannot open connection database (%s:%d)\n",
@ -446,10 +436,9 @@ bool procesoInclusionCliente(struct og_client *cli, TRAMA *ptrTrama)
idcentro = dbi_result_get_uint(result, "idcentro"); idcentro = dbi_result_get_uint(result, "idcentro");
dbi_result_free(result); dbi_result_free(result);
resul = actualizaConfiguracion(db, tbl, cfg, idordenador); // Actualiza la configuración del ordenador resul = actualizaConfiguracion(dbi, cfg, idordenador); // Actualiza la configuración del ordenador
liberaMemoria(cfg); liberaMemoria(cfg);
og_dbi_close(dbi); og_dbi_close(dbi);
db.Close();
if (!resul) { if (!resul) {
liberaMemoria(iph); liberaMemoria(iph);
@ -514,12 +503,13 @@ err_dbi_open:
// soi= Nombre del sistema de ficheros instalado en la partición // soi= Nombre del sistema de ficheros instalado en la partición
// tam= Tamaño de la partición // tam= Tamaño de la partición
// ________________________________________________________________________________________________________ // ________________________________________________________________________________________________________
bool actualizaConfiguracion(Database db, Table tbl, char *cfg, int ido) bool actualizaConfiguracion(struct og_dbi *dbi, char *cfg, int ido)
{ {
char msglog[LONSTD], sqlstr[LONSQL];
int lon, p, c,i, dato, swu, idsoi, idsfi,k; int lon, p, c,i, dato, swu, idsoi, idsfi,k;
char *ptrPar[MAXPAR], *ptrCfg[7], *ptrDual[2], tbPar[LONSTD]; char *ptrPar[MAXPAR], *ptrCfg[7], *ptrDual[2], tbPar[LONSTD];
char *ser, *disk, *par, *cpt, *sfi, *soi, *tam, *uso; // Parametros de configuración. char *ser, *disk, *par, *cpt, *sfi, *soi, *tam, *uso; // Parametros de configuración.
dbi_result result, result_update;
const char *msglog;
lon = 0; lon = 0;
p = splitCadena(ptrPar, cfg, '\n'); p = splitCadena(ptrPar, cfg, '\n');
@ -532,12 +522,13 @@ bool actualizaConfiguracion(Database db, Table tbl, char *cfg, int ido)
ser = ptrDual[1]; ser = ptrDual[1];
if (strlen(ser) > 0) { if (strlen(ser) > 0) {
// Solo actualizar si número de serie no existía. // Solo actualizar si número de serie no existía.
sprintf(sqlstr, "UPDATE ordenadores SET numserie='%s'" result = dbi_conn_queryf(dbi->conn,
"UPDATE ordenadores SET numserie='%s'"
" WHERE idordenador=%d AND numserie IS NULL", " WHERE idordenador=%d AND numserie IS NULL",
ser, ido); ser, ido);
if (!db.Execute(sqlstr, tbl)) { // Error al insertar if (!result) {
db.GetErrorErrStr(msglog); dbi_conn_error(dbi->conn, &msglog);
og_info(msglog); og_info((char *)msglog);
return false; return false;
} }
} }
@ -564,7 +555,7 @@ bool actualizaConfiguracion(Database db, Table tbl, char *cfg, int ido)
if(k==2){ if(k==2){
sfi = ptrDual[1]; // Sistema de ficheros sfi = ptrDual[1]; // Sistema de ficheros
/* Comprueba existencia del s0xistema de ficheros instalado */ /* Comprueba existencia del s0xistema de ficheros instalado */
idsfi = checkDato(db, tbl, sfi, "sistemasficheros", "descripcion","idsistemafichero"); idsfi = checkDato(dbi, sfi, "sistemasficheros", "descripcion","idsistemafichero");
} }
else else
idsfi=0; idsfi=0;
@ -573,7 +564,7 @@ bool actualizaConfiguracion(Database db, Table tbl, char *cfg, int ido)
if(k==2){ // Sistema operativo detecdtado if(k==2){ // Sistema operativo detecdtado
soi = ptrDual[1]; // Nombre del S.O. instalado soi = ptrDual[1]; // Nombre del S.O. instalado
/* Comprueba existencia del sistema operativo instalado */ /* Comprueba existencia del sistema operativo instalado */
idsoi = checkDato(db, tbl, soi, "nombresos", "nombreso", "idnombreso"); idsoi = checkDato(dbi, soi, "nombresos", "nombreso", "idnombreso");
} }
else else
idsoi=0; idsoi=0;
@ -586,55 +577,45 @@ bool actualizaConfiguracion(Database db, Table tbl, char *cfg, int ido)
lon += sprintf(tbPar + lon, "(%s, %s),", disk, par); lon += sprintf(tbPar + lon, "(%s, %s),", disk, par);
sprintf(sqlstr, "SELECT numdisk, numpar, tamano, uso, idsistemafichero, idnombreso" result = dbi_conn_queryf(dbi->conn,
"SELECT numdisk, numpar, tamano, uso, idsistemafichero, idnombreso"
" FROM ordenadores_particiones" " FROM ordenadores_particiones"
" WHERE idordenador=%d AND numdisk=%s AND numpar=%s", " WHERE idordenador=%d AND numdisk=%s AND numpar=%s",
ido, disk, par); ido, disk, par);
if (!result) {
dbi_conn_error(dbi->conn, &msglog);
if (!db.Execute(sqlstr, tbl)) {
db.GetErrorErrStr(msglog);
syslog(LOG_ERR, "failed to query database (%s:%d) %s\n", syslog(LOG_ERR, "failed to query database (%s:%d) %s\n",
__func__, __LINE__, msglog); __func__, __LINE__, msglog);
return false; return false;
} }
if (tbl.ISEOF()) { // Si no existe el registro if (!dbi_result_next_row(result)) {
sprintf(sqlstr, "INSERT INTO ordenadores_particiones(idordenador,numdisk,numpar,codpar,tamano,uso,idsistemafichero,idnombreso,idimagen)" result_update = dbi_conn_queryf(dbi->conn,
"INSERT INTO ordenadores_particiones(idordenador,numdisk,numpar,codpar,tamano,uso,idsistemafichero,idnombreso,idimagen)"
" VALUES(%d,%s,%s,0x%s,%s,%s,%d,%d,0)", " VALUES(%d,%s,%s,0x%s,%s,%s,%d,%d,0)",
ido, disk, par, cpt, tam, uso, idsfi, idsoi); ido, disk, par, cpt, tam, uso, idsfi, idsoi);
if (!result_update) {
dbi_conn_error(dbi->conn, &msglog);
if (!db.Execute(sqlstr, tbl)) { // Error al insertar og_info((char *)msglog);
db.GetErrorErrStr(msglog);
og_info(msglog);
return false; return false;
} }
dbi_result_free(result_update);
} else { // Existe el registro } else { // Existe el registro
swu = true; // Se supone que algún dato ha cambiado swu = true; // Se supone que algún dato ha cambiado
if (!tbl.Get("tamano", dato)) { // Toma dato
tbl.GetErrorErrStr(msglog); // Error al acceder al registro dato = dbi_result_get_uint(result, "tamano");
og_info(msglog); if (atoi(tam) == dato) {// Parámetro tamaño igual al almacenado
return false; dato = dbi_result_get_uint(result, "idsistemafichero");
} if (idsfi == dato) {// Parámetro sistema de fichero igual al almacenado
if (atoi(tam) == dato) { // Parámetro tamaño igual al almacenado dato = dbi_result_get_uint(result, "idnombreso");
if (!tbl.Get("idsistemafichero", dato)) { // Toma dato if (idsoi == dato) {// Parámetro sistema de fichero distinto al almacenado
tbl.GetErrorErrStr(msglog); // Error al acceder al registro
og_info(msglog);
return false;
}
if (idsfi == dato) { // Parámetro sistema de fichero igual al almacenado
if (!tbl.Get("idnombreso", dato)) { // Toma dato
tbl.GetErrorErrStr(msglog); // Error al acceder al registro
og_info(msglog);
return false;
}
if (idsoi == dato) { // Parámetro sistema operativo distinto al almacenado
swu = false; // Todos los parámetros de la partición son iguales, no se actualiza swu = false; // Todos los parámetros de la partición son iguales, no se actualiza
} }
} }
} }
if (swu) { // Hay que actualizar los parámetros de la partición if (swu) { // Hay que actualizar los parámetros de la partición
sprintf(sqlstr, "UPDATE ordenadores_particiones SET " result_update = dbi_conn_queryf(dbi->conn,
"UPDATE ordenadores_particiones SET "
" codpar=0x%s," " codpar=0x%s,"
" tamano=%s," " tamano=%s,"
" uso=%s," " uso=%s,"
@ -646,30 +627,36 @@ bool actualizaConfiguracion(Database db, Table tbl, char *cfg, int ido)
" WHERE idordenador=%d AND numdisk=%s AND numpar=%s", " WHERE idordenador=%d AND numdisk=%s AND numpar=%s",
cpt, tam, uso, idsfi, idsoi, ido, disk, par); cpt, tam, uso, idsfi, idsoi, ido, disk, par);
} else { // Actualizar porcentaje de uso. } else { // Actualizar porcentaje de uso.
sprintf(sqlstr, "UPDATE ordenadores_particiones SET " result_update = dbi_conn_queryf(dbi->conn,
"UPDATE ordenadores_particiones SET "
" codpar=0x%s," " codpar=0x%s,"
" uso=%s" " uso=%s"
" WHERE idordenador=%d AND numdisk=%s AND numpar=%s", " WHERE idordenador=%d AND numdisk=%s AND numpar=%s",
cpt, uso, ido, disk, par); cpt, uso, ido, disk, par);
} }
if (!db.Execute(sqlstr, tbl)) { if (!result_update) {
db.GetErrorErrStr(msglog); dbi_conn_error(dbi->conn, &msglog);
syslog(LOG_ERR, "failed to query database (%s:%d) %s\n", syslog(LOG_ERR, "failed to query database (%s:%d) %s\n",
__func__, __LINE__, msglog); __func__, __LINE__, msglog);
return false; return false;
} }
dbi_result_free(result_update);
} }
} }
lon += sprintf(tbPar + lon, "(0,0)"); lon += sprintf(tbPar + lon, "(0,0)");
// Eliminar particiones almacenadas que ya no existen // Eliminar particiones almacenadas que ya no existen
sprintf(sqlstr, "DELETE FROM ordenadores_particiones WHERE idordenador=%d AND (numdisk, numpar) NOT IN (%s)", result_update = dbi_conn_queryf(dbi->conn,
"DELETE FROM ordenadores_particiones WHERE idordenador=%d AND (numdisk, numpar) NOT IN (%s)",
ido, tbPar); ido, tbPar);
if (!db.Execute(sqlstr, tbl)) { if (!result_update) {
db.GetErrorErrStr(msglog); dbi_conn_error(dbi->conn, &msglog);
syslog(LOG_ERR, "failed to query database (%s:%d) %s\n", syslog(LOG_ERR, "failed to query database (%s:%d) %s\n",
__func__, __LINE__, msglog); __func__, __LINE__, msglog);
return false; return false;
} }
dbi_result_free(result_update);
return true; return true;
} }
// ________________________________________________________________________________________________________ // ________________________________________________________________________________________________________
@ -692,52 +679,45 @@ bool actualizaConfiguracion(Database db, Table tbl, char *cfg, int ido)
// En caso de producirse algún error se devuelve el valor 0 // En caso de producirse algún error se devuelve el valor 0
// ________________________________________________________________________________________________________ // ________________________________________________________________________________________________________
int checkDato(Database db, Table tbl, char *dato, const char *tabla, int checkDato(struct og_dbi *dbi, char *dato, const char *tabla,
const char *nomdato, const char *nomidentificador) const char *nomdato, const char *nomidentificador)
{ {
char msglog[LONSTD], sqlstr[LONSQL]; const char *msglog;
int identificador; int identificador;
dbi_result result;
if (strlen(dato) == 0) if (strlen(dato) == 0)
return (0); // EL dato no tiene valor return (0); // EL dato no tiene valor
sprintf(sqlstr, "SELECT %s FROM %s WHERE %s ='%s'", nomidentificador, result = dbi_conn_queryf(dbi->conn,
"SELECT %s FROM %s WHERE %s ='%s'", nomidentificador,
tabla, nomdato, dato); tabla, nomdato, dato);
// Ejecuta consulta // Ejecuta consulta
if (!db.Execute(sqlstr, tbl)) { if (!result) {
db.GetErrorErrStr(msglog); dbi_conn_error(dbi->conn, &msglog);
syslog(LOG_ERR, "failed to query database (%s:%d) %s\n", syslog(LOG_ERR, "failed to query database (%s:%d) %s\n",
__func__, __LINE__, msglog); __func__, __LINE__, msglog);
return (0); return (0);
} }
if (tbl.ISEOF()) { // Software NO existente if (!dbi_result_next_row(result)) { // Software NO existente
sprintf(sqlstr, "INSERT INTO %s (%s) VALUES('%s')", tabla, nomdato, dato); dbi_result_free(result);
if (!db.Execute(sqlstr, tbl)) { // Error al insertar
db.GetErrorErrStr(msglog); // Error al acceder al registro result = dbi_conn_queryf(dbi->conn,
og_info(msglog); "INSERT INTO %s (%s) VALUES('%s')", tabla, nomdato, dato);
if (!result) {
dbi_conn_error(dbi->conn, &msglog);
og_info((char *)msglog);
return (0); return (0);
} }
dbi_result_free(result);
// Recupera el identificador del software // Recupera el identificador del software
sprintf(sqlstr, "SELECT LAST_INSERT_ID() as identificador"); identificador = dbi_conn_sequence_last(dbi->conn, NULL);
if (!db.Execute(sqlstr, tbl)) { // Error al leer
db.GetErrorErrStr(msglog); // Error al acceder al registro
og_info(msglog);
return (0);
}
if (!tbl.ISEOF()) { // Si existe registro
if (!tbl.Get("identificador", identificador)) {
tbl.GetErrorErrStr(msglog); // Error al acceder al registro
og_info(msglog);
return (0);
}
}
} else { } else {
if (!tbl.Get(nomidentificador, identificador)) { // Toma dato identificador = dbi_result_get_uint(result, nomidentificador);
tbl.GetErrorErrStr(msglog); // Error al acceder al registro
og_info(msglog);
return (0);
}
} }
dbi_result_free(result);
return (identificador); return (identificador);
} }
// ________________________________________________________________________________________________________ // ________________________________________________________________________________________________________
@ -1762,25 +1742,14 @@ static bool RESPUESTA_CrearSoftIncremental(TRAMA* ptrTrama, struct og_client *cl
// //
static bool RESPUESTA_RestaurarImagen(TRAMA* ptrTrama, struct og_client *cli) static bool RESPUESTA_RestaurarImagen(TRAMA* ptrTrama, struct og_client *cli)
{ {
char msglog[LONSTD];
Database db;
Table tbl;
bool res; bool res;
char *iph, *ido, *idi, *dsk, *par, *ifs, *cfg; char *iph, *ido, *idi, *dsk, *par, *ifs, *cfg;
struct og_dbi *dbi; struct og_dbi *dbi;
if (!db.Open(usuario, pasguor, datasource, catalog)) {
db.GetErrorErrStr(msglog);
syslog(LOG_ERR, "cannot open connection database (%s:%d) %s\n",
__func__, __LINE__, msglog);
return false;
}
dbi = og_dbi_open(&dbi_config); dbi = og_dbi_open(&dbi_config);
if (!dbi) { if (!dbi) {
syslog(LOG_ERR, "cannot open connection database (%s:%d)\n", syslog(LOG_ERR, "cannot open connection database (%s:%d)\n",
__func__, __LINE__); __func__, __LINE__);
db.Close();
return false; return false;
} }
@ -1802,10 +1771,10 @@ static bool RESPUESTA_RestaurarImagen(TRAMA* ptrTrama, struct og_client *cli)
ifs = copiaParametro("ifs",ptrTrama); // Identificador del perfil software contenido ifs = copiaParametro("ifs",ptrTrama); // Identificador del perfil software contenido
cfg = copiaParametro("cfg",ptrTrama); // Configuración de discos cfg = copiaParametro("cfg",ptrTrama); // Configuración de discos
if(cfg){ if(cfg){
actualizaConfiguracion(db, tbl, cfg, atoi(ido)); // Actualiza la configuración del ordenador actualizaConfiguracion(dbi, cfg, atoi(ido)); // Actualiza la configuración del ordenador
liberaMemoria(cfg); liberaMemoria(cfg);
} }
res=actualizaRestauracionImagen(db, tbl, idi, dsk, par, ido, ifs); res=actualizaRestauracionImagen(dbi, idi, dsk, par, ido, ifs);
liberaMemoria(iph); liberaMemoria(iph);
liberaMemoria(ido); liberaMemoria(ido);
@ -1817,8 +1786,6 @@ static bool RESPUESTA_RestaurarImagen(TRAMA* ptrTrama, struct og_client *cli)
if(!res) if(!res)
syslog(LOG_ERR, "Problem after restoring image\n"); syslog(LOG_ERR, "Problem after restoring image\n");
db.Close(); // Cierra conexión
return res; return res;
} }
// ________________________________________________________________________________________________________ // ________________________________________________________________________________________________________
@ -1872,25 +1839,28 @@ static bool RESPUESTA_RestaurarSoftIncremental(TRAMA* ptrTrama, struct og_client
// true: Si el proceso es correcto // true: Si el proceso es correcto
// false: En caso de ocurrir algún error // false: En caso de ocurrir algún error
// ________________________________________________________________________________________________________ // ________________________________________________________________________________________________________
bool actualizaRestauracionImagen(Database db, Table tbl, char *idi, bool actualizaRestauracionImagen(struct og_dbi *dbi, char *idi,
char *dsk, char *par, char *ido, char *ifs) char *dsk, char *par, char *ido, char *ifs)
{ {
char msglog[LONSTD], sqlstr[LONSQL]; const char *msglog;
dbi_result result;
/* Actualizar los datos de la imagen */ /* Actualizar los datos de la imagen */
snprintf(sqlstr, LONSQL, result = dbi_conn_queryf(dbi->conn,
"UPDATE ordenadores_particiones" "UPDATE ordenadores_particiones"
" SET idimagen=%s, idperfilsoft=%s, fechadespliegue=NOW()," " SET idimagen=%s, idperfilsoft=%s, fechadespliegue=NOW(),"
" revision=(SELECT revision FROM imagenes WHERE idimagen=%s)," " revision=(SELECT revision FROM imagenes WHERE idimagen=%s),"
" idnombreso=IFNULL((SELECT idnombreso FROM perfilessoft WHERE idperfilsoft=%s),0)" " idnombreso=IFNULL((SELECT idnombreso FROM perfilessoft WHERE idperfilsoft=%s),0)"
" WHERE idordenador=%s AND numdisk=%s AND numpar=%s", idi, ifs, idi, ifs, ido, dsk, par); " WHERE idordenador=%s AND numdisk=%s AND numpar=%s", idi, ifs, idi, ifs, ido, dsk, par);
if (!db.Execute(sqlstr, tbl)) { if (!result) {
db.GetErrorErrStr(msglog); dbi_conn_error(dbi->conn, &msglog);
syslog(LOG_ERR, "failed to query database (%s:%d) %s\n", syslog(LOG_ERR, "failed to query database (%s:%d) %s\n",
__func__, __LINE__, msglog); __func__, __LINE__, msglog);
return false; return false;
} }
dbi_result_free(result);
return true; return true;
} }
// ________________________________________________________________________________________________________ // ________________________________________________________________________________________________________
@ -1907,25 +1877,14 @@ bool actualizaRestauracionImagen(Database db, Table tbl, char *idi,
// ________________________________________________________________________________________________________ // ________________________________________________________________________________________________________
static bool RESPUESTA_EjecutarScript(TRAMA* ptrTrama, struct og_client *cli) static bool RESPUESTA_EjecutarScript(TRAMA* ptrTrama, struct og_client *cli)
{ {
char msglog[LONSTD];
Database db;
Table tbl;
char *iph, *ido,*cfg; char *iph, *ido,*cfg;
struct og_dbi *dbi; struct og_dbi *dbi;
bool res = true; bool res = true;
if (!db.Open(usuario, pasguor, datasource, catalog)) {
db.GetErrorErrStr(msglog);
syslog(LOG_ERR, "cannot open connection database (%s:%d) %s\n",
__func__, __LINE__, msglog);
return false;
}
dbi = og_dbi_open(&dbi_config); dbi = og_dbi_open(&dbi_config);
if (!dbi) { if (!dbi) {
syslog(LOG_ERR, "cannot open connection database (%s:%d)\n", syslog(LOG_ERR, "cannot open connection database (%s:%d)\n",
__func__, __LINE__); __func__, __LINE__);
db.Close();
return false; return false;
} }
@ -1942,7 +1901,7 @@ static bool RESPUESTA_EjecutarScript(TRAMA* ptrTrama, struct og_client *cli)
cfg = copiaParametro("cfg",ptrTrama); // Toma configuración de particiones cfg = copiaParametro("cfg",ptrTrama); // Toma configuración de particiones
if(cfg){ if(cfg){
res = actualizaConfiguracion(db, tbl, cfg, atoi(ido)); // Actualiza la configuración del ordenador res = actualizaConfiguracion(dbi, cfg, atoi(ido)); // Actualiza la configuración del ordenador
liberaMemoria(cfg); liberaMemoria(cfg);
} }
@ -1953,8 +1912,6 @@ static bool RESPUESTA_EjecutarScript(TRAMA* ptrTrama, struct og_client *cli)
if (!res) if (!res)
syslog(LOG_ERR, "Problem updating client configuration\n"); syslog(LOG_ERR, "Problem updating client configuration\n");
db.Close(); // Cierra conexión
return res; return res;
} }
// ________________________________________________________________________________________________________ // ________________________________________________________________________________________________________
@ -2332,25 +2289,14 @@ bool cuestionPerfilHardware(Database db, Table tbl, char *idc, char *ido,
// ________________________________________________________________________________________________________ // ________________________________________________________________________________________________________
static bool RESPUESTA_InventarioSoftware(TRAMA* ptrTrama, struct og_client *cli) static bool RESPUESTA_InventarioSoftware(TRAMA* ptrTrama, struct og_client *cli)
{ {
char msglog[LONSTD];
Database db;
Table tbl;
bool res; bool res;
char *iph, *ido, *npc, *idc, *par, *sft, *buffer; char *iph, *ido, *npc, *idc, *par, *sft, *buffer;
struct og_dbi *dbi; struct og_dbi *dbi;
if (!db.Open(usuario, pasguor, datasource, catalog)) {
db.GetErrorErrStr(msglog);
syslog(LOG_ERR, "cannot open connection database (%s:%d) %s\n",
__func__, __LINE__, msglog);
return false;
}
dbi = og_dbi_open(&dbi_config); dbi = og_dbi_open(&dbi_config);
if (!dbi) { if (!dbi) {
syslog(LOG_ERR, "cannot open connection database (%s:%d)\n", syslog(LOG_ERR, "cannot open connection database (%s:%d)\n",
__func__, __LINE__); __func__, __LINE__);
db.Close();
return false; return false;
} }
@ -2372,7 +2318,7 @@ static bool RESPUESTA_InventarioSoftware(TRAMA* ptrTrama, struct og_client *cli)
buffer = rTrim(leeArchivo(sft)); buffer = rTrim(leeArchivo(sft));
if (buffer) if (buffer)
res=actualizaSoftware(db, tbl, buffer, par, ido, npc, idc); res=actualizaSoftware(dbi, buffer, par, ido, npc, idc);
liberaMemoria(iph); liberaMemoria(iph);
liberaMemoria(ido); liberaMemoria(ido);
@ -2385,8 +2331,6 @@ static bool RESPUESTA_InventarioSoftware(TRAMA* ptrTrama, struct og_client *cli)
if (!res) if (!res)
syslog(LOG_ERR, "cannot update software\n"); syslog(LOG_ERR, "cannot update software\n");
db.Close(); // Cierra conexión
return res; return res;
} }
// ________________________________________________________________________________________________________ // ________________________________________________________________________________________________________
@ -2408,43 +2352,37 @@ static bool RESPUESTA_InventarioSoftware(TRAMA* ptrTrama, struct og_client *cli)
// //
// Versión 1.1.0: Se incluye el sistema operativo. Autora: Irina Gómez - ETSII Universidad Sevilla // Versión 1.1.0: Se incluye el sistema operativo. Autora: Irina Gómez - ETSII Universidad Sevilla
// ________________________________________________________________________________________________________ // ________________________________________________________________________________________________________
bool actualizaSoftware(Database db, Table tbl, char *sft, char *par,char *ido, bool actualizaSoftware(struct og_dbi *dbi, char *sft, char *par,char *ido,
char *npc, char *idc) char *npc, char *idc)
{ {
int i, j, lon, aux, idperfilsoft, idnombreso; int i, j, lon, aux, idperfilsoft, idnombreso;
bool retval; bool retval;
char *wsft; char *wsft;
int tbidsoftware[MAXSOFTWARE]; int tbidsoftware[MAXSOFTWARE];
char *tbSoftware[MAXSOFTWARE],msglog[LONSTD], sqlstr[LONSQL], strInt[LONINT], *idsoftwares; char *tbSoftware[MAXSOFTWARE], strInt[LONINT], *idsoftwares;
const char *msglog;
dbi_result result;
/* Toma Centro (Unidad Organizativa) y perfil software */ /* Toma Centro (Unidad Organizativa) y perfil software */
sprintf(sqlstr, "SELECT idperfilsoft,numpar" result = dbi_conn_queryf(dbi->conn,
"SELECT idperfilsoft,numpar"
" FROM ordenadores_particiones" " FROM ordenadores_particiones"
" WHERE idordenador=%s", ido); " WHERE idordenador=%s", ido);
if (!result) {
if (!db.Execute(sqlstr, tbl)) { dbi_conn_error(dbi->conn, &msglog);
db.GetErrorErrStr(msglog);
syslog(LOG_ERR, "failed to query database (%s:%d) %s\n", syslog(LOG_ERR, "failed to query database (%s:%d) %s\n",
__func__, __LINE__, msglog); __func__, __LINE__, msglog);
return false; return false;
} }
idperfilsoft = 0; // Por defecto se supone que el ordenador no tiene aún detectado el perfil software idperfilsoft = 0; // Por defecto se supone que el ordenador no tiene aún detectado el perfil software
while (!tbl.ISEOF()) { // Recorre particiones while (dbi_result_next_row(result)) {
if (!tbl.Get("numpar", aux)) { aux = dbi_result_get_uint(result, "numpar");
tbl.GetErrorErrStr(msglog);
og_info(msglog);
return false;
}
if (aux == atoi(par)) { // Se encuentra la partición if (aux == atoi(par)) { // Se encuentra la partición
if (!tbl.Get("idperfilsoft", idperfilsoft)) { idperfilsoft = dbi_result_get_uint(result, "idperfilsoft");
tbl.GetErrorErrStr(msglog);
og_info(msglog);
return false;
}
break; break;
} }
tbl.MoveNext();
} }
dbi_result_free(result);
wsft=escaparCadena(sft); // Codificar comillas simples wsft=escaparCadena(sft); // Codificar comillas simples
if(!wsft) if(!wsft)
return false; return false;
@ -2460,50 +2398,36 @@ bool actualizaSoftware(Database db, Table tbl, char *sft, char *par,char *ido,
for (i = 0; i < lon; i++) { for (i = 0; i < lon; i++) {
// Primera línea es el sistema operativo: se obtiene identificador // Primera línea es el sistema operativo: se obtiene identificador
if (i == 0) { if (i == 0) {
idnombreso = checkDato(db, tbl, rTrim(tbSoftware[i]), "nombresos", "nombreso", "idnombreso"); idnombreso = checkDato(dbi, rTrim(tbSoftware[i]), "nombresos", "nombreso", "idnombreso");
continue; continue;
} }
sprintf(sqlstr, result = dbi_conn_queryf(dbi->conn,
"SELECT idsoftware FROM softwares WHERE descripcion ='%s'", "SELECT idsoftware FROM softwares WHERE descripcion ='%s'",
rTrim(tbSoftware[i])); rTrim(tbSoftware[i]));
if (!result) {
if (!db.Execute(sqlstr, tbl)) { dbi_conn_error(dbi->conn, &msglog);
db.GetErrorErrStr(msglog);
syslog(LOG_ERR, "failed to query database (%s:%d) %s\n", syslog(LOG_ERR, "failed to query database (%s:%d) %s\n",
__func__, __LINE__, msglog); __func__, __LINE__, msglog);
return false; return false;
} }
if (tbl.ISEOF()) { // Software NO existente if (!dbi_result_next_row(result)) {
sprintf(sqlstr, "INSERT INTO softwares (idtiposoftware,descripcion,idcentro,grupoid)" dbi_result_free(result);
result = dbi_conn_queryf(dbi->conn,
"INSERT INTO softwares (idtiposoftware,descripcion,idcentro,grupoid)"
" VALUES(2,'%s',%s,0)", tbSoftware[i], idc); " VALUES(2,'%s',%s,0)", tbSoftware[i], idc);
if (!result) { // Error al insertar
dbi_conn_error(dbi->conn, &msglog);
og_info((char *)msglog);
return false;
}
dbi_result_free(result);
if (!db.Execute(sqlstr, tbl)) { // Error al insertar
db.GetErrorErrStr(msglog); // Error al acceder al registro
og_info(msglog);
return false;
}
// Recupera el identificador del software // Recupera el identificador del software
sprintf(sqlstr, "SELECT LAST_INSERT_ID() as identificador"); tbidsoftware[i] = dbi_conn_sequence_last(dbi->conn, NULL);
if (!db.Execute(sqlstr, tbl)) { // Error al leer
db.GetErrorErrStr(msglog); // Error al acceder al registro
og_info(msglog);
return false;
}
if (!tbl.ISEOF()) { // Si existe registro
if (!tbl.Get("identificador", tbidsoftware[i])) {
tbl.GetErrorErrStr(msglog); // Error al acceder al registro
og_info(msglog);
return false;
}
}
} else { } else {
if (!tbl.Get("idsoftware", tbidsoftware[i])) { // Toma dato tbidsoftware[i] = dbi_result_get_uint(result, "idsoftware");
tbl.GetErrorErrStr(msglog); // Error al acceder al registro
og_info(msglog);
return false;
}
} }
} }
@ -2531,10 +2455,10 @@ bool actualizaSoftware(Database db, Table tbl, char *sft, char *par,char *ido,
aux += sprintf(idsoftwares + aux, ",%d", tbidsoftware[i]); aux += sprintf(idsoftwares + aux, ",%d", tbidsoftware[i]);
// Comprueba existencia de perfil software y actualización de éste para el ordenador // Comprueba existencia de perfil software y actualización de éste para el ordenador
if (!cuestionPerfilSoftware(db, tbl, idc, ido, idperfilsoft, idnombreso, idsoftwares, if (!cuestionPerfilSoftware(dbi, idc, ido, idperfilsoft, idnombreso, idsoftwares,
npc, par, tbidsoftware, lon)) { npc, par, tbidsoftware, lon)) {
syslog(LOG_ERR, "cannot update software\n"); syslog(LOG_ERR, "cannot update software\n");
og_info(msglog); og_info((char *)msglog);
retval=false; retval=false;
} }
else { else {
@ -2564,21 +2488,18 @@ bool actualizaSoftware(Database db, Table tbl, char *sft, char *par,char *ido,
// //
// Versión 1.1.0: Se incluye el sistema operativo. Autora: Irina Gómez - ETSII Universidad Sevilla // Versión 1.1.0: Se incluye el sistema operativo. Autora: Irina Gómez - ETSII Universidad Sevilla
//_________________________________________________________________________________________________________ //_________________________________________________________________________________________________________
bool cuestionPerfilSoftware(Database db, Table tbl, char *idc, char *ido, bool cuestionPerfilSoftware(struct og_dbi *dbi, char *idc, char *ido,
int idperfilsoftware, int idnombreso, int idperfilsoftware, int idnombreso,
char *idsoftwares, char *npc, char *par, char *idsoftwares, char *npc, char *par,
int *tbidsoftware, int lon) int *tbidsoftware, int lon)
{ {
char *sqlstr, msglog[LONSTD];
int i, nwidperfilsoft; int i, nwidperfilsoft;
const char *msglog;
dbi_result result;
sqlstr = reservaMemoria(strlen(idsoftwares)+LONSQL); // Reserva para escribir sentencia SQL
if (sqlstr == NULL) {
syslog(LOG_ERR, "%s:%d OOM\n", __FILE__, __LINE__);
return false;
}
// Busca perfil soft del ordenador que contenga todos los componentes software encontrados // Busca perfil soft del ordenador que contenga todos los componentes software encontrados
sprintf(sqlstr, "SELECT idperfilsoft FROM" result = dbi_conn_queryf(dbi->conn,
"SELECT idperfilsoft FROM"
" (SELECT perfilessoft_softwares.idperfilsoft as idperfilsoft," " (SELECT perfilessoft_softwares.idperfilsoft as idperfilsoft,"
" group_concat(cast(perfilessoft_softwares.idsoftware AS char( 11) )" " group_concat(cast(perfilessoft_softwares.idsoftware AS char( 11) )"
" ORDER BY perfilessoft_softwares.idsoftware SEPARATOR ',' ) AS idsoftwares" " ORDER BY perfilessoft_softwares.idsoftware SEPARATOR ',' ) AS idsoftwares"
@ -2586,103 +2507,95 @@ bool cuestionPerfilSoftware(Database db, Table tbl, char *idc, char *ido,
" GROUP BY perfilessoft_softwares.idperfilsoft) AS temp" " GROUP BY perfilessoft_softwares.idperfilsoft) AS temp"
" WHERE idsoftwares LIKE '%s'", idsoftwares); " WHERE idsoftwares LIKE '%s'", idsoftwares);
if (!db.Execute(sqlstr, tbl)) { if (!result) {
db.GetErrorErrStr(msglog); dbi_conn_error(dbi->conn, &msglog);
syslog(LOG_ERR, "failed to query database (%s:%d) %s\n", syslog(LOG_ERR, "failed to query database (%s:%d) %s\n",
__func__, __LINE__, msglog); __func__, __LINE__, msglog);
liberaMemoria(sqlstr);
return false; return false;
} }
if (tbl.ISEOF()) { // No existe un perfil software con esos componentes de componentes software, lo crea if (!dbi_result_next_row(result)) { // No existe un perfil software con esos componentes de componentes software, lo crea
sprintf(sqlstr, "INSERT perfilessoft (descripcion, idcentro, grupoid, idnombreso)" dbi_result_free(result);
result = dbi_conn_queryf(dbi->conn,
"INSERT perfilessoft (descripcion, idcentro, grupoid, idnombreso)"
" VALUES('Perfil Software (%s, Part:%s) ',%s,0,%i)", npc, par, idc,idnombreso); " VALUES('Perfil Software (%s, Part:%s) ',%s,0,%i)", npc, par, idc,idnombreso);
if (!db.Execute(sqlstr, tbl)) { // Error al insertar if (!result) {
db.GetErrorErrStr(msglog); dbi_conn_error(dbi->conn, &msglog);
og_info(msglog); og_info((char *)msglog);
return false; return false;
} }
dbi_result_free(result);
// Recupera el identificador del nuevo perfil software // Recupera el identificador del nuevo perfil software
sprintf(sqlstr, "SELECT LAST_INSERT_ID() as identificador"); nwidperfilsoft = dbi_conn_sequence_last(dbi->conn, NULL);
if (!db.Execute(sqlstr, tbl)) { // Error al leer
tbl.GetErrorErrStr(msglog);
og_info(msglog);
liberaMemoria(sqlstr);
return false;
}
if (!tbl.ISEOF()) { // Si existe registro
if (!tbl.Get("identificador", nwidperfilsoft)) {
tbl.GetErrorErrStr(msglog);
og_info(msglog);
liberaMemoria(sqlstr);
return false;
}
}
// Crea la relación entre perfiles y componenetes software // Crea la relación entre perfiles y componenetes software
for (i = 0; i < lon; i++) { for (i = 0; i < lon; i++) {
sprintf(sqlstr, "INSERT perfilessoft_softwares (idperfilsoft,idsoftware)" result = dbi_conn_queryf(dbi->conn,
"INSERT perfilessoft_softwares (idperfilsoft,idsoftware)"
" VALUES(%d,%d)", nwidperfilsoft, tbidsoftware[i]); " VALUES(%d,%d)", nwidperfilsoft, tbidsoftware[i]);
if (!db.Execute(sqlstr, tbl)) { // Error al insertar if (!result) {
db.GetErrorErrStr(msglog); dbi_conn_error(dbi->conn, &msglog);
og_info(msglog); og_info((char *)msglog);
liberaMemoria(sqlstr);
return false; return false;
} }
dbi_result_free(result);
} }
} else { // Existe un perfil con todos esos componentes } else { // Existe un perfil con todos esos componentes
if (!tbl.Get("idperfilsoft", nwidperfilsoft)) { nwidperfilsoft = dbi_result_get_uint(result, "idperfilsoft");
tbl.GetErrorErrStr(msglog); dbi_result_free(result);
og_info(msglog);
liberaMemoria(sqlstr);
return false;
}
} }
if (idperfilsoftware != nwidperfilsoft) { // No coinciden los perfiles if (idperfilsoftware != nwidperfilsoft) { // No coinciden los perfiles
// Actualiza el identificador del perfil software del ordenador // Actualiza el identificador del perfil software del ordenador
sprintf(sqlstr, "UPDATE ordenadores_particiones SET idperfilsoft=%d,idimagen=0" result = dbi_conn_queryf(dbi->conn,
"UPDATE ordenadores_particiones SET idperfilsoft=%d,idimagen=0"
" WHERE idordenador=%s AND numpar=%s", nwidperfilsoft, ido, par); " WHERE idordenador=%s AND numpar=%s", nwidperfilsoft, ido, par);
if (!db.Execute(sqlstr, tbl)) { // Error al insertar if (!result) { // Error al insertar
db.GetErrorErrStr(msglog); dbi_conn_error(dbi->conn, &msglog);
og_info(msglog); og_info((char *)msglog);
liberaMemoria(sqlstr);
return false; return false;
} }
dbi_result_free(result);
} }
/* DEPURACIÓN DE PERFILES SOFTWARE */ /* DEPURACIÓN DE PERFILES SOFTWARE */
/* Eliminar Relación de softwares con Perfiles software que quedan húerfanos */ /* Eliminar Relación de softwares con Perfiles software que quedan húerfanos */
sprintf(sqlstr, "DELETE FROM perfilessoft_softwares WHERE idperfilsoft IN "\ result = dbi_conn_queryf(dbi->conn,
"DELETE FROM perfilessoft_softwares WHERE idperfilsoft IN "\
" (SELECT idperfilsoft FROM perfilessoft WHERE idperfilsoft NOT IN"\ " (SELECT idperfilsoft FROM perfilessoft WHERE idperfilsoft NOT IN"\
" (SELECT DISTINCT idperfilsoft from ordenadores_particiones) AND idperfilsoft NOT IN"\ " (SELECT DISTINCT idperfilsoft from ordenadores_particiones) AND idperfilsoft NOT IN"\
" (SELECT DISTINCT idperfilsoft from imagenes))"); " (SELECT DISTINCT idperfilsoft from imagenes))");
if (!db.Execute(sqlstr, tbl)) { // Error al insertar if (!result) {
db.GetErrorErrStr(msglog); dbi_conn_error(dbi->conn, &msglog);
og_info(msglog); og_info((char *)msglog);
liberaMemoria(sqlstr);
return false; return false;
} }
dbi_result_free(result),
/* Eliminar Perfiles software que quedan húerfanos */ /* Eliminar Perfiles software que quedan húerfanos */
sprintf(sqlstr, "DELETE FROM perfilessoft WHERE idperfilsoft NOT IN" result = dbi_conn_queryf(dbi->conn,
"DELETE FROM perfilessoft WHERE idperfilsoft NOT IN"
" (SELECT DISTINCT idperfilsoft from ordenadores_particiones)"\ " (SELECT DISTINCT idperfilsoft from ordenadores_particiones)"\
" AND idperfilsoft NOT IN"\ " AND idperfilsoft NOT IN"\
" (SELECT DISTINCT idperfilsoft from imagenes)"); " (SELECT DISTINCT idperfilsoft from imagenes)");
if (!db.Execute(sqlstr, tbl)) { // Error al insertar if (!result) {
db.GetErrorErrStr(msglog); dbi_conn_error(dbi->conn, &msglog);
og_info(msglog); og_info((char *)msglog);
liberaMemoria(sqlstr);
return false; return false;
} }
dbi_result_free(result),
/* Eliminar Relación de softwares con Perfiles software que quedan húerfanos */ /* Eliminar Relación de softwares con Perfiles software que quedan húerfanos */
sprintf(sqlstr, "DELETE FROM perfilessoft_softwares WHERE idperfilsoft NOT IN" result = dbi_conn_queryf(dbi->conn,
"DELETE FROM perfilessoft_softwares WHERE idperfilsoft NOT IN"
" (SELECT idperfilsoft from perfilessoft)"); " (SELECT idperfilsoft from perfilessoft)");
if (!db.Execute(sqlstr, tbl)) { // Error al insertar if (!result) {
db.GetErrorErrStr(msglog); dbi_conn_error(dbi->conn, &msglog);
og_info(msglog); og_info((char *)msglog);
liberaMemoria(sqlstr);
return false; return false;
} }
liberaMemoria(sqlstr); dbi_result_free(result);
return true; return true;
} }
// ________________________________________________________________________________________________________ // ________________________________________________________________________________________________________

10
sources/ogAdmServer.h
View File

@ -43,7 +43,7 @@ bool procesoInclusionClienteWinLnx(int socket, TRAMA*,int*,char*);
bool procesoInclusionCliente(struct og_client *, TRAMA*); bool procesoInclusionCliente(struct og_client *, TRAMA*);
bool clienteExistente(char *,int *); bool clienteExistente(char *,int *);
bool clienteDisponible(char *,int *); bool clienteDisponible(char *,int *);
bool actualizaConfiguracion(Database , Table ,char* ,int); bool actualizaConfiguracion(struct og_dbi *,char* ,int);
bool recorreProcedimientos(struct og_dbi *,char* ,FILE*,char*); bool recorreProcedimientos(struct og_dbi *,char* ,FILE*,char*);
bool buscaComandos(char *,TRAMA *,int *); bool buscaComandos(char *,TRAMA *,int *);
bool respuestaConsola(int socket, TRAMA *,int); bool respuestaConsola(int socket, TRAMA *,int);
@ -52,10 +52,10 @@ bool Levanta(char**, char**, int, char*);
bool WakeUp(int,char*,char*,char*); bool WakeUp(int,char*,char*,char*);
void PasaHexBin(char *,char *); void PasaHexBin(char *,char *);
bool actualizaCreacionImagen(Database,Table,char*,char*,char*,char*,char*,char*); bool actualizaCreacionImagen(Database,Table,char*,char*,char*,char*,char*,char*);
bool actualizaRestauracionImagen(Database,Table,char*,char*,char*,char*,char*); bool actualizaRestauracionImagen(struct og_dbi *,char*,char*,char*,char*,char*);
bool actualizaHardware(Database, Table,char* ,char*,char*,char*); bool actualizaHardware(Database, Table,char* ,char*,char*,char*);
bool cuestionPerfilHardware(Database,Table,char*,char*,int,char*,char*,int *,int); bool cuestionPerfilHardware(Database,Table,char*,char*,int,char*,char*,int *,int);
bool actualizaSoftware(Database , Table , char* , char* , char*,char*,char*); bool actualizaSoftware(struct og_dbi *, char* , char* , char*,char*,char*);
bool cuestionPerfilSoftware(Database, Table, char*, char*,int,int,char*,char*,char*,int *,int); bool cuestionPerfilSoftware(struct og_dbi *, char*, char*,int,int,char*,char*,char*,int *,int);
int checkDato(Database,Table,char*,const char*,const char*,const char*); int checkDato(struct og_dbi *,char*,const char*,const char*,const char*);