[5ea3638] | 1 | // *************************************************************************
|
---|
[9182fd9] | 2 | // Aplicación: OPENGNSYS
|
---|
| 3 | // Autor: José Manuel Alonso (E.T.S.I.I.) Universidad de Sevilla
|
---|
| 4 | // Fecha Creación: Año 2003-2004
|
---|
| 5 | // Fecha Última modificación: Marzo-2006
|
---|
| 6 | // Nombre del fichero: ogAdmAgent.cpp
|
---|
| 7 | // Descripción :
|
---|
[5ea3638] | 8 | //
|
---|
| 9 | // ****************************************************************************
|
---|
| 10 | #include "ogAdmAgent.h"
|
---|
| 11 | #include "ogAdmLib.c"
|
---|
| 12 |
|
---|
[9182fd9] | 13 | //________________________________________________________________________________________________________
|
---|
[5ea3638] | 14 | //
|
---|
[9182fd9] | 15 | // Función: TomaConfiguracion
|
---|
[5ea3638] | 16 | //
|
---|
[9182fd9] | 17 | // Descripción:
|
---|
| 18 | // Esta función lee el fichero de configuración del programa hidralinuxcli y toma los parámetros
|
---|
| 19 | // Parámetros:
|
---|
| 20 | // - pathfilecfg : Ruta al fichero de configuración
|
---|
| 21 | //________________________________________________________________________________________________________
|
---|
| 22 | int TomaConfiguracion(char* pathfilecfg) {
|
---|
| 23 | long lSize;
|
---|
| 24 | char * buffer, *lineas[100], *dualparametro[2];
|
---|
| 25 | char ch[2];
|
---|
| 26 | int i, numlin, resul;
|
---|
| 27 |
|
---|
| 28 | if (pathfilecfg == NULL)
|
---|
| 29 | return (FALSE); // Nombre del fichero en blanco
|
---|
| 30 |
|
---|
| 31 | Fconfig = fopen(pathfilecfg, "rb");
|
---|
| 32 | if (Fconfig == NULL)
|
---|
| 33 | return (FALSE);
|
---|
| 34 | fseek(Fconfig, 0, SEEK_END); // Obtiene tamaño del fichero.
|
---|
| 35 | lSize = ftell(Fconfig);
|
---|
| 36 | rewind(Fconfig);
|
---|
| 37 | buffer = (char*) malloc(lSize); // Toma memoria para el buffer de lectura.
|
---|
| 38 | if (buffer == NULL)
|
---|
| 39 | return (FALSE);
|
---|
| 40 | fread(buffer, 1, lSize, Fconfig); // Lee contenido del fichero
|
---|
| 41 | fclose(Fconfig);
|
---|
| 42 |
|
---|
| 43 | //inicializar
|
---|
| 44 | IPlocal[0] = (char) NULL;
|
---|
| 45 | servidorhidra[0] = (char) NULL;
|
---|
| 46 | Puerto[0] = (char) NULL;
|
---|
| 47 |
|
---|
| 48 | usuario[0] = (char) NULL;
|
---|
| 49 | pasguor[0] = (char) NULL;
|
---|
| 50 | datasource[0] = (char) NULL;
|
---|
| 51 | catalog[0] = (char) NULL;
|
---|
| 52 |
|
---|
| 53 | strcpy(ch, "\n");// caracter delimitador (salto de linea)
|
---|
| 54 | numlin = split_parametros(lineas, buffer, ch);
|
---|
| 55 | for (i = 0; i < numlin; i++) {
|
---|
| 56 | strcpy(ch, "=");// caracter delimitador
|
---|
| 57 | split_parametros(dualparametro, lineas[i], ch); // Toma primer nombre del parametro
|
---|
| 58 |
|
---|
| 59 | resul = strcmp(dualparametro[0], "IPhidra");
|
---|
| 60 | if (resul == 0)
|
---|
| 61 | strcpy(IPlocal, dualparametro[1]);
|
---|
| 62 |
|
---|
| 63 | resul = strcmp(dualparametro[0], "IPhidra");
|
---|
| 64 | if (resul == 0)
|
---|
| 65 | strcpy(servidorhidra, dualparametro[1]);
|
---|
| 66 |
|
---|
| 67 | resul = strcmp(dualparametro[0], "Puerto");
|
---|
| 68 | if (resul == 0)
|
---|
| 69 | strcpy(Puerto, dualparametro[1]);
|
---|
| 70 |
|
---|
| 71 | resul = strcmp(dualparametro[0], "Usuario");
|
---|
| 72 | if (resul == 0)
|
---|
| 73 | strcpy(usuario, dualparametro[1]);
|
---|
| 74 |
|
---|
| 75 | resul = strcmp(dualparametro[0], "PassWord");
|
---|
| 76 | if (resul == 0)
|
---|
| 77 | strcpy(pasguor, dualparametro[1]);
|
---|
| 78 |
|
---|
| 79 | resul = strcmp(dualparametro[0], "DataSource");
|
---|
| 80 | if (resul == 0)
|
---|
| 81 | strcpy(datasource, dualparametro[1]);
|
---|
| 82 |
|
---|
| 83 | resul = strcmp(dualparametro[0], "Catalog");
|
---|
| 84 | if (resul == 0)
|
---|
| 85 | strcpy(catalog, dualparametro[1]);
|
---|
| 86 | }
|
---|
| 87 | if (IPlocal[0] == (char) NULL) {
|
---|
| 88 | RegistraLog("IPlocal, NO se ha definido este parámetro", false);
|
---|
| 89 | return (FALSE);
|
---|
| 90 | }
|
---|
| 91 | if (servidorhidra[0] == (char) NULL) {
|
---|
| 92 | RegistraLog("IPhidra, NO se ha definido este parámetro", false);
|
---|
| 93 | return (FALSE);
|
---|
| 94 | }
|
---|
| 95 | if (Puerto[0] == (char) NULL) {
|
---|
| 96 | RegistraLog("Puerto, NO se ha definido este parámetro", false);
|
---|
| 97 | return (FALSE);
|
---|
| 98 | }
|
---|
| 99 | puerto = atoi(Puerto);
|
---|
| 100 |
|
---|
| 101 | if (usuario[0] == (char) NULL) {
|
---|
| 102 | RegistraLog("Usuario, NO se ha definido este parámetro", false);
|
---|
| 103 | return (FALSE);
|
---|
| 104 | }
|
---|
| 105 | if (pasguor[0] == (char) NULL) {
|
---|
| 106 | RegistraLog("PassWord, NO se ha definido este parámetro", false);
|
---|
| 107 | return (FALSE);
|
---|
| 108 | }
|
---|
| 109 | if (datasource[0] == (char) NULL) {
|
---|
| 110 | RegistraLog("DataSource, NO se ha definido este parámetro", false);
|
---|
| 111 | return (FALSE);
|
---|
| 112 | }
|
---|
| 113 | if (catalog[0] == (char) NULL) {
|
---|
| 114 | RegistraLog("Catalog, NO se ha definido este parámetro", false);
|
---|
| 115 | return (FALSE);
|
---|
| 116 | }
|
---|
| 117 | return (TRUE);
|
---|
[5ea3638] | 118 | }
|
---|
| 119 | // _____________________________________________________________________________________________________________
|
---|
[9182fd9] | 120 | // Función: busca_accion
|
---|
[5ea3638] | 121 | //
|
---|
[9182fd9] | 122 | // Descripción:
|
---|
| 123 | // Esta Función busca en la base de datos, acciones programadas
|
---|
[5ea3638] | 124 | // Parametros:
|
---|
[9182fd9] | 125 | // - dia : Día actual del mes
|
---|
[5ea3638] | 126 | // - mes : mes en curso
|
---|
[9182fd9] | 127 | // - anno : Año en curso
|
---|
[5ea3638] | 128 | // - hora : Hora actual
|
---|
| 129 | // - minutos : Minutos actuales
|
---|
| 130 | // - diasemana : Dia de la semana 1=lunes,2=martes ... ( 0 Domingo)
|
---|
| 131 | // _____________________________________________________________________________________________________________
|
---|
| 132 | int busca_accion(WORD dia,WORD mes,WORD anno,WORD hora,WORD minutos,WORD diasemana)
|
---|
| 133 | {
|
---|
| 134 | char sqlstr[1000],ErrStr[200];
|
---|
| 135 | Database db,wdb;
|
---|
| 136 | Table tbl;
|
---|
| 137 | char parametros[LONGITUD_PARAMETROS];
|
---|
| 138 | BYTE swampm,bitsemana;
|
---|
| 139 | int tipoaccion,identificador;
|
---|
| 140 | int ordsem,ordulsem,ordiasem_1,maxdias;
|
---|
[231f87d] | 141 | anno=anno-2009; // Año de comienzo es 2004
|
---|
[5ea3638] | 142 | if(hora>11){
|
---|
| 143 | hora-=12;
|
---|
| 144 | swampm=1; // Es pm
|
---|
| 145 | }
|
---|
| 146 | else
|
---|
| 147 | swampm=0; // Es am
|
---|
| 148 |
|
---|
| 149 | if(diasemana==0) diasemana=7; // El domingo
|
---|
| 150 |
|
---|
[9182fd9] | 151 | // Cuestión semanas
|
---|
[231f87d] | 152 | ordiasem_1=DiadelaSemana(1,mes,anno+2009);
|
---|
[9182fd9] | 153 | ordsem=SemanadelMes(ordiasem_1,dia); // Calcula el número de la semana
|
---|
| 154 | if (mes!=2) // Toma el último día de ese mes
|
---|
[5ea3638] | 155 | maxdias=dias_meses[mes];
|
---|
| 156 | else{
|
---|
[231f87d] | 157 | if (bisiesto(anno+2009))
|
---|
[5ea3638] | 158 | maxdias=29;
|
---|
| 159 | else
|
---|
| 160 | maxdias=28;
|
---|
| 161 | }
|
---|
[9182fd9] | 162 | ordulsem=SemanadelMes(ordiasem_1,maxdias); // Calcula el número de última semana
|
---|
[5ea3638] | 163 |
|
---|
| 164 | bitsemana=HEX_semanas[ordsem];
|
---|
[9182fd9] | 165 | if(ordsem==ordulsem) // Si es la última semana del mes
|
---|
[5ea3638] | 166 | bitsemana|=HEX_semanas[6];
|
---|
| 167 |
|
---|
[9182fd9] | 168 | if (!db.Open(usuario, pasguor, datasource, catalog)) { // error de conexion
|
---|
| 169 | db.GetErrorErrStr(ErrStr);
|
---|
| 170 | return (false);
|
---|
[5ea3638] | 171 | }
|
---|
[231f87d] | 172 | sprintf(sqlstr,"SELECT DISTINCT tipoaccion,identificador FROM programaciones WHERE "\
|
---|
| 173 | " suspendida=0 "\
|
---|
| 174 | " AND (annos & %d <> 0) "\
|
---|
| 175 | " AND (meses & %d<>0) "\
|
---|
| 176 | " AND ((diario & %d<>0) OR (dias & %d<>0) OR (semanas & %d<>0))"\
|
---|
| 177 | " AND (horas & %d<>0) AND ampm=%d AND minutos=%d",\
|
---|
| 178 | HEX_annos[anno],\
|
---|
| 179 | HEX_meses[mes],\
|
---|
| 180 | HEX_dias[dia],\
|
---|
| 181 | HEX_diasemana[diasemana],
|
---|
| 182 | bitsemana,\
|
---|
| 183 | HEX_horas[hora],\
|
---|
| 184 | swampm,minutos);
|
---|
| 185 |
|
---|
[5ea3638] | 186 | if(!db.Execute(sqlstr,tbl)){ // Error al leer
|
---|
| 187 | db.GetErrorErrStr(ErrStr);
|
---|
| 188 | return(false);
|
---|
| 189 | }
|
---|
| 190 | if(tbl.ISEOF()){
|
---|
| 191 | return(true); // No hay acciones programadas
|
---|
| 192 | }
|
---|
[9182fd9] | 193 | if (!wdb.Open(usuario, pasguor, datasource, catalog)) { // error de conexion
|
---|
| 194 | db.GetErrorErrStr(ErrStr);
|
---|
| 195 | return (false);
|
---|
[5ea3638] | 196 | }
|
---|
| 197 | while(!tbl.ISEOF()){ // Busca entre todas las programaciones
|
---|
| 198 | if(!tbl.Get("tipoaccion",tipoaccion)){ // Toma dato
|
---|
| 199 | tbl.GetErrorErrStr(ErrStr); // error al acceder al registro
|
---|
| 200 | return(false);
|
---|
| 201 | }
|
---|
| 202 | if(!tbl.Get("identificador",identificador)){ // Toma dato
|
---|
| 203 | tbl.GetErrorErrStr(ErrStr); // error al acceder al registro
|
---|
| 204 | return(false);
|
---|
| 205 | }
|
---|
[9182fd9] | 206 | if(tipoaccion==EJECUCION_TAREA){ // Es una programación de una tarea
|
---|
[5ea3638] | 207 | EjecutarTarea(identificador,0,0,0,wdb,parametros);
|
---|
| 208 | }
|
---|
| 209 | else{
|
---|
| 210 | if(tipoaccion==EJECUCION_TRABAJO){
|
---|
[9182fd9] | 211 | EjecutarTrabajo(identificador,wdb,parametros); // Es una programación de un trabajo
|
---|
[5ea3638] | 212 | }
|
---|
| 213 | else{
|
---|
| 214 | if(tipoaccion==EJECUCION_RESERVA){
|
---|
[9182fd9] | 215 | EjecutarReserva(identificador,wdb,parametros); // Es una programación de un trabajo
|
---|
[5ea3638] | 216 | }
|
---|
| 217 | }
|
---|
| 218 | }
|
---|
| 219 | tbl.MoveNext();
|
---|
| 220 | }
|
---|
[ab25df5] | 221 | db.Close();
|
---|
[5ea3638] | 222 | return(true);
|
---|
| 223 | }
|
---|
| 224 | // _____________________________________________________________________________________________________________
|
---|
[9182fd9] | 225 | // Función: bisiesto
|
---|
[5ea3638] | 226 | //
|
---|
[9182fd9] | 227 | // Descripción:
|
---|
| 228 | // Esta Función devuelve true si el año pasado como parámetro es bisiesto y false si no lo es
|
---|
[5ea3638] | 229 | // Parametros:
|
---|
[9182fd9] | 230 | // - anob : un año en formato aaaa
|
---|
[5ea3638] | 231 | // _____________________________________________________________________________________________________________
|
---|
| 232 | bool bisiesto(WORD anob){
|
---|
| 233 | return(anob%4==0);
|
---|
| 234 | }
|
---|
| 235 | // _____________________________________________________________________________________________________________
|
---|
[9182fd9] | 236 | // Función: DiadelaSemana
|
---|
[5ea3638] | 237 | //
|
---|
[9182fd9] | 238 | // Descripción:
|
---|
| 239 | // Esta Función devuelve el número del día de la semana: 1=Lunes, 2=martes ... 6=sábado 7=domingo de una fecha determinada
|
---|
[5ea3638] | 240 | // Parametros:
|
---|
[9182fd9] | 241 | // - dia : Un día
|
---|
[5ea3638] | 242 | // - mes : Un mes
|
---|
[9182fd9] | 243 | // - anno : Un año
|
---|
[5ea3638] | 244 | // _____________________________________________________________________________________________________________
|
---|
| 245 | int DiadelaSemana(WORD dia,WORD mes,WORD anno)
|
---|
| 246 | {
|
---|
| 247 | int i,cont,dias_anuales;
|
---|
| 248 | int desplazamiento_dias=6;
|
---|
| 249 | int orddiasem;
|
---|
| 250 |
|
---|
| 251 | cont =0;
|
---|
| 252 | for (i=1900;i<anno;i++){
|
---|
| 253 | if (bisiesto(i)) dias_anuales=366; else dias_anuales=365;
|
---|
| 254 | cont+=dias_anuales;
|
---|
| 255 | }
|
---|
| 256 | for (i=1;i<mes;i++){
|
---|
| 257 | if (i!=2)
|
---|
| 258 | cont+=dias_meses[i];
|
---|
| 259 | else{
|
---|
| 260 | if (bisiesto(anno))
|
---|
| 261 | cont+=29;
|
---|
| 262 | else
|
---|
| 263 | cont+=28;
|
---|
| 264 | }
|
---|
| 265 | }
|
---|
| 266 | cont+=dia+desplazamiento_dias;
|
---|
| 267 | orddiasem=(cont%7);
|
---|
| 268 | if(orddiasem==0) orddiasem=7;
|
---|
| 269 | return(orddiasem);
|
---|
| 270 | }
|
---|
| 271 | // _____________________________________________________________________________________________________________
|
---|
[9182fd9] | 272 | // Función: SemanadelMes
|
---|
[5ea3638] | 273 | //
|
---|
[9182fd9] | 274 | // Descripción:
|
---|
| 275 | // Esta Función devuelve el número de semana perteneciente a un día de ese mes
|
---|
| 276 | // Parámetros:
|
---|
| 277 | // - ordiasem_1 : Orden semenal (1,2...) del dia del primer dia del mes que se pasa como parámetro
|
---|
[5ea3638] | 278 | // - diames : El mes concreto
|
---|
| 279 | // _____________________________________________________________________________________________________________
|
---|
| 280 | int SemanadelMes(int ordiasem_1,int diames)
|
---|
| 281 | {
|
---|
| 282 | int nwdia,resto,cociente;
|
---|
| 283 |
|
---|
| 284 | nwdia=diames+ordiasem_1-1;
|
---|
| 285 | cociente=nwdia/7;
|
---|
| 286 | resto=nwdia%7;
|
---|
| 287 | if(resto>0) cociente++;
|
---|
| 288 | return(cociente);
|
---|
| 289 | }
|
---|
| 290 | // _____________________________________________________________________________________________________________
|
---|
[9182fd9] | 291 | // Función: Pausa
|
---|
[5ea3638] | 292 | //
|
---|
[9182fd9] | 293 | // Descripción:
|
---|
[5ea3638] | 294 | // Hace una pausa en segundos
|
---|
| 295 | // Parametros:
|
---|
| 296 | // - s : Segundos de pausa
|
---|
| 297 | // _____________________________________________________________________________________________________________
|
---|
| 298 | void Pausa(int s)
|
---|
| 299 | {
|
---|
| 300 | int seg=0;
|
---|
| 301 | clock_t comienzo;
|
---|
| 302 |
|
---|
| 303 | comienzo = clock();
|
---|
| 304 | do{
|
---|
| 305 | seg=(clock()-comienzo)/CLOCKS_PER_SEC;
|
---|
| 306 | }while(seg<s);
|
---|
| 307 | }
|
---|
| 308 | // _____________________________________________________________________________________________________________
|
---|
[9182fd9] | 309 | // Función: EjecutarTrabajo
|
---|
[5ea3638] | 310 | //
|
---|
[9182fd9] | 311 | // Descripción:
|
---|
| 312 | // Registra una acción (Trabajo y la envía para su ejecución
|
---|
| 313 | // Parámetros:
|
---|
[5ea3638] | 314 | // - idtrabajo : Identificador del trabajo
|
---|
[9182fd9] | 315 | // - db: una conexion ADO operativa
|
---|
| 316 | // - parametros: Parámetros de la acción
|
---|
[5ea3638] | 317 | // _____________________________________________________________________________________________________________
|
---|
| 318 | int EjecutarTrabajo(int idtrabajo,Database db,char*parametros )
|
---|
| 319 | {
|
---|
| 320 | char sqlstr[1000],ErrStr[200];
|
---|
| 321 | Table tbl;
|
---|
| 322 | int cont_tareas=0,lon;
|
---|
| 323 | int idtarea,idtrabajotarea,idcentro;
|
---|
| 324 | char wambitrabajo[500],ambitrabajo[4000];
|
---|
| 325 | char wparamtrabajo[20],paramtrabajo[1000];
|
---|
| 326 | int tbTareasidtarea[100],tbTareasidnotificador[100];
|
---|
| 327 | char *tbTareasparametros[100],*tbTareasambitoambitskwrk[100];
|
---|
| 328 | char ambitskwrk[500];
|
---|
| 329 |
|
---|
[9182fd9] | 330 | ambitrabajo[0]=(char)NULL; // Inicialización
|
---|
| 331 | strcpy(paramtrabajo,"tsk="); // Inicialización
|
---|
[5ea3638] | 332 |
|
---|
| 333 | // recupera el identificador del Centro propietario de la tarea
|
---|
| 334 | sprintf(sqlstr,"SELECT idcentro FROM trabajos WHERE idtrabajo=%d",idtrabajo);
|
---|
| 335 | if(!db.Execute(sqlstr,tbl)){ // Error al leer
|
---|
| 336 | db.GetErrorErrStr(ErrStr);
|
---|
| 337 | return(false);
|
---|
| 338 | }
|
---|
| 339 | if(tbl.ISEOF()) return(true);
|
---|
| 340 | if(!tbl.Get("idcentro",idcentro)){ // Toma dato
|
---|
| 341 | tbl.GetErrorErrStr(ErrStr); // error al acceder al registro
|
---|
| 342 | return(false);
|
---|
| 343 | }
|
---|
| 344 | // Recupera las tareas que forman parte del trabajo
|
---|
| 345 | sprintf(sqlstr,"SELECT * FROM trabajos_tareas WHERE idtrabajo=%d ORDER by orden",idtrabajo);
|
---|
| 346 | if(!db.Execute(sqlstr,tbl)){ // Error al leer
|
---|
| 347 | db.GetErrorErrStr(ErrStr);
|
---|
| 348 | return(false);
|
---|
| 349 | }
|
---|
| 350 | if(tbl.ISEOF()) return(true);
|
---|
| 351 | // Recorre trabajos-tareas
|
---|
| 352 | while(!tbl.ISEOF()){
|
---|
| 353 | if(!tbl.Get("idtrabajotarea",idtrabajotarea)){ // Toma dato
|
---|
| 354 | tbl.GetErrorErrStr(ErrStr); // error al acceder al registro
|
---|
| 355 | return(false);
|
---|
| 356 | }
|
---|
| 357 | tbTareasidnotificador[cont_tareas]=idtrabajotarea;
|
---|
| 358 |
|
---|
| 359 | if(!tbl.Get("idtarea",idtarea)){ // Toma dato
|
---|
| 360 | tbl.GetErrorErrStr(ErrStr); // error al acceder al registro
|
---|
| 361 | return(false);
|
---|
| 362 | }
|
---|
| 363 | tbTareasidtarea[cont_tareas]=idtarea;
|
---|
| 364 |
|
---|
| 365 | if(!tbl.Get("parametros",parametros)){ // Toma dato
|
---|
| 366 | tbl.GetErrorErrStr(ErrStr); // error al acceder al registro
|
---|
| 367 | return(false);
|
---|
| 368 | }
|
---|
| 369 | lon=strlen(parametros);
|
---|
| 370 | tbTareasparametros[cont_tareas]=(char*)malloc(lon);
|
---|
| 371 | if(tbTareasparametros[cont_tareas]==NULL)
|
---|
| 372 | return(false); // No hay memoria bastante
|
---|
| 373 | strcpy(tbTareasparametros[cont_tareas],parametros);
|
---|
| 374 |
|
---|
| 375 | if(!tbl.Get("ambitskwrk",ambitskwrk)){ // Toma dato
|
---|
| 376 | tbl.GetErrorErrStr(ErrStr); // error al acceder al registro
|
---|
| 377 | return(false);
|
---|
| 378 | }
|
---|
| 379 | lon=strlen(ambitskwrk);
|
---|
| 380 | tbTareasambitoambitskwrk[cont_tareas]=(char*)malloc(lon);
|
---|
| 381 | strcpy(tbTareasambitoambitskwrk[cont_tareas],ambitskwrk);
|
---|
| 382 |
|
---|
| 383 | sprintf(wambitrabajo,"%s;",ambitskwrk);
|
---|
| 384 | strcat(ambitrabajo,wambitrabajo);
|
---|
| 385 |
|
---|
| 386 | sprintf(wparamtrabajo,"%d;",idtrabajotarea);
|
---|
| 387 | strcat(paramtrabajo,wparamtrabajo);
|
---|
| 388 |
|
---|
| 389 | cont_tareas++;
|
---|
| 390 | tbl.MoveNext();
|
---|
| 391 | }
|
---|
| 392 | lon=strlen(ambitrabajo);
|
---|
| 393 | ambitrabajo[lon-1]=(char)NULL; // Quita la coma final
|
---|
| 394 |
|
---|
| 395 | lon=strlen(paramtrabajo);
|
---|
| 396 | paramtrabajo[lon-1]=(char)NULL; // Quita la coma final
|
---|
| 397 |
|
---|
[9182fd9] | 398 | char fechareg[100];
|
---|
| 399 |
|
---|
| 400 |
|
---|
| 401 | struct tm* st;
|
---|
| 402 | st = TomaHora();
|
---|
| 403 | sprintf(fechareg, "%d/%d/%d %d:%d:%d", st->tm_year + 1900, st->tm_mon + 1,
|
---|
| 404 | st->tm_mday, st->tm_hour, st->tm_min, st->tm_sec);
|
---|
[5ea3638] | 405 |
|
---|
[9182fd9] | 406 | sprintf(sqlstr,"INSERT INTO acciones (tipoaccion,idtipoaccion,cateaccion,ambito,idambito,ambitskwrk,fechahorareg,estado,resultado,idcentro,parametros,accionid,idnotificador) VALUES (%d,%d,%d,0,0,'%s','%s','%s','%s',%d,'%s',0,0)",EJECUCION_TRABAJO,idtrabajo,PROCESOS,ambitrabajo,fechareg,ACCION_INICIADA,ACCION_SINERRORES,idcentro,paramtrabajo);
|
---|
[5ea3638] | 407 | if(!db.Execute(sqlstr)){ // Error al insertar
|
---|
| 408 | db.GetErrorErrStr(ErrStr);
|
---|
| 409 | return(false);
|
---|
| 410 | }
|
---|
| 411 | int accionid=0;
|
---|
[9182fd9] | 412 | // Toma identificador de la acción
|
---|
[5ea3638] | 413 | sprintf(sqlstr,"SELECT @@identity as identificador");
|
---|
| 414 | if(!db.Execute(sqlstr,tbl)){ // Error al leer
|
---|
| 415 | db.GetErrorErrStr(ErrStr);
|
---|
| 416 | return(false);
|
---|
| 417 | }
|
---|
| 418 | if(!tbl.ISEOF()){ // Si existe registro
|
---|
| 419 | if(!tbl.Get("identificador",accionid)){
|
---|
| 420 | tbl.GetErrorErrStr(ErrStr); // error al acceder al registro
|
---|
| 421 | return(false);
|
---|
| 422 | }
|
---|
| 423 | }
|
---|
| 424 | int i;
|
---|
| 425 | // Insertar acciones:tareas
|
---|
| 426 | for (i=0;i<cont_tareas;i++){
|
---|
| 427 | if(!EjecutarTarea(tbTareasidtarea[i],accionid,tbTareasidnotificador[i],idcentro,db,parametros)){
|
---|
| 428 | free(tbTareasparametros[i]);
|
---|
| 429 | free(tbTareasambitoambitskwrk[i]);
|
---|
| 430 | return(false);
|
---|
| 431 | }
|
---|
| 432 | free(tbTareasparametros[i]);
|
---|
| 433 | free(tbTareasambitoambitskwrk[i]);
|
---|
| 434 | }
|
---|
| 435 | return(true);
|
---|
| 436 | }
|
---|
| 437 | // _____________________________________________________________________________________________________________
|
---|
[9182fd9] | 438 | // Función: EjecutarTarea
|
---|
[5ea3638] | 439 | //
|
---|
[9182fd9] | 440 | // Descripción:
|
---|
| 441 | // Registra una acción (Tarea) y la envía para su ejecución
|
---|
| 442 | // Parámetros:
|
---|
[5ea3638] | 443 | // - idtarea : Identificador de la tarea
|
---|
| 444 | // - accionid: identificador del trabajo padre (si existe)
|
---|
| 445 | // - idnotificador: identificador del trabajo_tarea incluido en trabajo padre (si existe)
|
---|
| 446 | // - idcentro: Centro propietario del trabjo padre (si existe este trabajo)
|
---|
[9182fd9] | 447 | // - db: una conexion ADO operativa
|
---|
| 448 | // - parametros: Parámetros de la acción
|
---|
[5ea3638] | 449 | // _____________________________________________________________________________________________________________
|
---|
| 450 | int EjecutarTarea(int idtarea,int accionid,int idnotificador,int idcentro,Database db,char *parametros )
|
---|
| 451 | {
|
---|
| 452 | char sqlstr[1000],ErrStr[200],ambito;
|
---|
| 453 | Table tbl;
|
---|
| 454 | int cont_comandos=0,lon;
|
---|
| 455 | int idcomando,idambito,idtareacomando,accionidcmd;
|
---|
| 456 | char wambitarea[20],ambitarea[4000];
|
---|
| 457 | char wparamtarea[20],paramtarea[1000],pids[20];
|
---|
| 458 | int tbComandosidcomando[100],tbComandosambito[100],tbComandosidnotificador[100],tbComandosidambito[100];
|
---|
| 459 | char *tbComandosparametros[100];
|
---|
| 460 |
|
---|
[9182fd9] | 461 | ambitarea[0]=(char)NULL; // Inicialización
|
---|
| 462 | strcpy(paramtarea,"cmd="); // Inicialización
|
---|
[5ea3638] | 463 | if(idcentro==0){
|
---|
| 464 | // recupera el identificador del Centro propietario de la tarea
|
---|
| 465 | sprintf(sqlstr,"SELECT idcentro FROM tareas WHERE idtarea=%d",idtarea);
|
---|
| 466 | if(!db.Execute(sqlstr,tbl)){ // Error al leer
|
---|
| 467 | db.GetErrorErrStr(ErrStr);
|
---|
| 468 | return(false);
|
---|
| 469 | }
|
---|
| 470 | if(tbl.ISEOF()) return(true);
|
---|
| 471 | if(!tbl.Get("idcentro",idcentro)){ // Toma dato
|
---|
| 472 | tbl.GetErrorErrStr(ErrStr); // error al acceder al registro
|
---|
| 473 | return(false);
|
---|
| 474 | }
|
---|
| 475 | }
|
---|
| 476 | // Recupera los comandos que forman parte de la tarea
|
---|
| 477 | sprintf(sqlstr,"SELECT * FROM tareas_comandos WHERE idtarea=%d ORDER by orden",idtarea);
|
---|
| 478 | if(!db.Execute(sqlstr,tbl)){ // Error al leer
|
---|
| 479 | db.GetErrorErrStr(ErrStr);
|
---|
| 480 | return(false);
|
---|
| 481 | }
|
---|
| 482 | if(tbl.ISEOF()) return(true);
|
---|
| 483 |
|
---|
| 484 | // Recorre tareas-comandos
|
---|
| 485 | while(!tbl.ISEOF()){
|
---|
| 486 | if(!tbl.Get("idcomando",idcomando)){ // Toma dato
|
---|
| 487 | tbl.GetErrorErrStr(ErrStr); // error al acceder al registro
|
---|
| 488 | return(false);
|
---|
| 489 | }
|
---|
| 490 | tbComandosidcomando[cont_comandos]=idcomando;
|
---|
| 491 |
|
---|
| 492 | if(!tbl.Get("ambito",ambito)){ // Toma dato
|
---|
| 493 | tbl.GetErrorErrStr(ErrStr); // error al acceder al registro
|
---|
| 494 | return(false);
|
---|
| 495 | }
|
---|
| 496 | tbComandosambito[cont_comandos]=ambito;
|
---|
| 497 |
|
---|
| 498 | if(!tbl.Get("idambito",idambito)){ // Toma dato
|
---|
| 499 | tbl.GetErrorErrStr(ErrStr); // error al acceder al registro
|
---|
| 500 | return(false);
|
---|
| 501 | }
|
---|
| 502 | tbComandosidambito[cont_comandos]=idambito;
|
---|
| 503 |
|
---|
| 504 |
|
---|
| 505 | if(!tbl.Get("parametros",parametros)){ // Toma dato
|
---|
| 506 | tbl.GetErrorErrStr(ErrStr); // error al acceder al registro
|
---|
| 507 | return(false);
|
---|
| 508 | }
|
---|
| 509 |
|
---|
| 510 | lon=strlen(parametros);
|
---|
| 511 | tbComandosparametros[cont_comandos]=(char*)malloc(lon+20);
|
---|
| 512 | if(tbComandosparametros[cont_comandos]==NULL)
|
---|
| 513 | return(false); // No hay memoria bastante
|
---|
| 514 |
|
---|
| 515 | strcpy(tbComandosparametros[cont_comandos],parametros);
|
---|
| 516 |
|
---|
| 517 | if(!tbl.Get("idtareacomando",idtareacomando)){ // Toma dato
|
---|
| 518 | tbl.GetErrorErrStr(ErrStr); // error al acceder al registro
|
---|
| 519 | return(false);
|
---|
| 520 | }
|
---|
| 521 | tbComandosidnotificador[cont_comandos]=idtareacomando;
|
---|
| 522 |
|
---|
| 523 | sprintf(wambitarea,"%d:%d;",ambito,idambito);
|
---|
| 524 | strcat(ambitarea,wambitarea);
|
---|
| 525 |
|
---|
| 526 | sprintf(wparamtarea,"%d;",idtareacomando);
|
---|
| 527 | strcat(paramtarea,wparamtarea);
|
---|
| 528 |
|
---|
| 529 | cont_comandos++;
|
---|
| 530 | tbl.MoveNext();
|
---|
| 531 | }
|
---|
| 532 | lon=strlen(ambitarea);
|
---|
| 533 | ambitarea[lon-1]=(char)NULL; // Quita la coma final
|
---|
| 534 |
|
---|
| 535 | lon=strlen(paramtarea);
|
---|
| 536 | paramtarea[lon-1]=(char)NULL; // Quita la coma final
|
---|
| 537 |
|
---|
[9182fd9] | 538 | char fechareg[100];
|
---|
[5ea3638] | 539 |
|
---|
[9182fd9] | 540 |
|
---|
| 541 | struct tm* st;
|
---|
| 542 | st = TomaHora();
|
---|
| 543 | sprintf(fechareg, "%d/%d/%d %d:%d:%d", st->tm_year + 1900, st->tm_mon + 1,
|
---|
| 544 | st->tm_mday, st->tm_hour, st->tm_min, st->tm_sec);
|
---|
| 545 |
|
---|
| 546 | sprintf(sqlstr,"INSERT INTO acciones (tipoaccion,idtipoaccion,cateaccion,ambito,idambito,ambitskwrk,fechahorareg,estado,resultado,idcentro,parametros,accionid,idnotificador) VALUES (%d,%d,%d,0,0,'%s','%s','%s','%s',%d,'%s',%d,%d)",EJECUCION_TAREA,idtarea,PROCESOS,ambitarea,fechareg,ACCION_INICIADA,ACCION_SINERRORES,idcentro,paramtarea,accionid,idnotificador);
|
---|
[5ea3638] | 547 | if(!db.Execute(sqlstr)){ // Error al insertar
|
---|
| 548 | db.GetErrorErrStr(ErrStr);
|
---|
| 549 | return(false);
|
---|
| 550 | }
|
---|
| 551 | accionid=0;
|
---|
[9182fd9] | 552 | // Toma identificador de la acción
|
---|
[5ea3638] | 553 | sprintf(sqlstr,"SELECT @@identity as identificador");
|
---|
| 554 | if(!db.Execute(sqlstr,tbl)){ // Error al leer
|
---|
| 555 | db.GetErrorErrStr(ErrStr);
|
---|
| 556 | return(false);
|
---|
| 557 | }
|
---|
| 558 | if(!tbl.ISEOF()){ // Si existe registro
|
---|
| 559 | if(!tbl.Get("identificador",accionid)){
|
---|
| 560 | tbl.GetErrorErrStr(ErrStr); // error al acceder al registro
|
---|
| 561 | return(false);
|
---|
| 562 | }
|
---|
| 563 | }
|
---|
| 564 | int i;
|
---|
| 565 | // Insertar acciones:comandos
|
---|
| 566 | for (i=0;i<cont_comandos;i++){
|
---|
[9182fd9] | 567 | st = TomaHora();
|
---|
| 568 | sprintf(fechareg, "%d/%d/%d %d:%d:%d", st->tm_year + 1900, st->tm_mon
|
---|
| 569 | + 1, st->tm_mday, st->tm_hour, st->tm_min, st->tm_sec);
|
---|
| 570 |
|
---|
| 571 | sprintf(sqlstr,"INSERT INTO acciones (tipoaccion,idtipoaccion,cateaccion,ambito,idambito,fechahorareg,estado,resultado,idcentro,parametros,accionid,idnotificador) VALUES (%d,%d,%d,%d,%d,'%s','%s','%s',%d,'%s',%d,%d)",EJECUCION_COMANDO,tbComandosidcomando[i],PROCESOS,tbComandosambito[i],tbComandosidambito[i],fechareg,ACCION_EXITOSA,ACCION_SINERRORES,idcentro,tbComandosparametros[i],accionid,tbComandosidnotificador[i]);
|
---|
[5ea3638] | 572 | if(!db.Execute(sqlstr)){ // Error al insertar
|
---|
| 573 | db.GetErrorErrStr(ErrStr);
|
---|
| 574 | free(tbComandosparametros[i]);
|
---|
| 575 | return(false);
|
---|
| 576 | }
|
---|
| 577 |
|
---|
[9182fd9] | 578 | // Toma identificador dela acción
|
---|
[5ea3638] | 579 | sprintf(sqlstr,"SELECT @@identity as identificador");
|
---|
| 580 | if(!db.Execute(sqlstr,tbl)){ // Error al leer
|
---|
| 581 | db.GetErrorErrStr(ErrStr);
|
---|
| 582 | return(false);
|
---|
| 583 | }
|
---|
| 584 |
|
---|
| 585 | if(!tbl.ISEOF()){ // Si existe registro
|
---|
| 586 | if(!tbl.Get("identificador",accionidcmd)){
|
---|
| 587 | tbl.GetErrorErrStr(ErrStr); // error al acceder al registro
|
---|
| 588 | return(false);
|
---|
| 589 | }
|
---|
| 590 | }
|
---|
| 591 | sprintf(pids,"ids=%d\r",accionidcmd);
|
---|
[9182fd9] | 592 | strcat(tbComandosparametros[i],pids); // Le añade el identificador de la acción
|
---|
[5ea3638] | 593 | envia_comando(tbComandosparametros[i]);
|
---|
| 594 | free(tbComandosparametros[i]);
|
---|
| 595 | }
|
---|
| 596 | return(true);
|
---|
| 597 | }
|
---|
| 598 | // _____________________________________________________________________________________________________________
|
---|
[9182fd9] | 599 | // Función: EjecutarReserva
|
---|
[5ea3638] | 600 | //
|
---|
[9182fd9] | 601 | // Descripción:
|
---|
| 602 | // Registra una acción (Tarea) y la envía para su ejecución
|
---|
| 603 | // Parámetros:
|
---|
[5ea3638] | 604 | // - idreserva : Identificador de la reserva
|
---|
[9182fd9] | 605 | // - db: una conexion ADO operativa
|
---|
| 606 | // - parametros: Parámetros de la acción
|
---|
[5ea3638] | 607 | // _____________________________________________________________________________________________________________
|
---|
| 608 | int EjecutarReserva(int idreserva,Database db,char*parametros )
|
---|
| 609 | {
|
---|
| 610 | char sqlstr[1000],ErrStr[200];
|
---|
| 611 | Table tbl;
|
---|
| 612 | int idaccion;
|
---|
| 613 |
|
---|
| 614 | sprintf(sqlstr,"SELECT idtarea,idtrabajo FROM reservas WHERE idreserva=%d",idreserva);
|
---|
| 615 | if(!db.Execute(sqlstr,tbl)){ // Error al leer
|
---|
| 616 | db.GetErrorErrStr(ErrStr);
|
---|
| 617 | return(false);
|
---|
| 618 | }
|
---|
| 619 | if(tbl.ISEOF()){
|
---|
| 620 | return(false); // No hay acciones previas en la reserva
|
---|
| 621 | }
|
---|
| 622 |
|
---|
| 623 | if(!tbl.Get("idtarea",idaccion)){ // Toma dato
|
---|
| 624 | tbl.GetErrorErrStr(ErrStr); // error al acceder al registro
|
---|
| 625 | return(false);
|
---|
| 626 | }
|
---|
| 627 | if(idaccion>0)
|
---|
| 628 | EjecutarTarea(idaccion,0,0,0,db,parametros); // Es una reserva con tarea previa
|
---|
| 629 |
|
---|
| 630 | if(!tbl.Get("idtrabajo",idaccion)){ // Toma dato
|
---|
| 631 | tbl.GetErrorErrStr(ErrStr); // error al acceder al registro
|
---|
| 632 | return(false);
|
---|
| 633 | }
|
---|
| 634 | if(idaccion>0)
|
---|
| 635 | EjecutarTrabajo(idaccion,db,parametros); // Es una reserva con trabajo previo
|
---|
| 636 |
|
---|
| 637 | return(true);
|
---|
| 638 | }
|
---|
| 639 | // _____________________________________________________________________________________________________________
|
---|
[9182fd9] | 640 | // Función: envia_comando
|
---|
[5ea3638] | 641 | //
|
---|
[9182fd9] | 642 | // Descripción:
|
---|
| 643 | // Envía un comando a la red. Para ello es necesario tener iniciado el servicio hidra.
|
---|
| 644 | // Parámetros:
|
---|
| 645 | // - parametros: Parámetros del comando
|
---|
[5ea3638] | 646 | // _____________________________________________________________________________________________________________
|
---|
| 647 | int envia_comando(char* parametros)
|
---|
| 648 | {
|
---|
| 649 | SOCKET sClient;
|
---|
| 650 | TRAMA trama;
|
---|
| 651 |
|
---|
| 652 | sClient = AbreConexion(servidorhidra,puerto);
|
---|
| 653 | if (sClient == (SOCKET)NULL)
|
---|
| 654 | return(FALSE);
|
---|
| 655 |
|
---|
| 656 | trama.arroba='@';
|
---|
| 657 | strncpy(trama.identificador,"JMMLCAMDJ",9);
|
---|
| 658 | trama.ejecutor=parametros[0];
|
---|
| 659 | strcpy(trama.parametros,(char*)¶metros[1]);
|
---|
| 660 | return(manda_trama(sClient,&trama));
|
---|
| 661 | }
|
---|
| 662 |
|
---|
| 663 | /// _____________________________________________________________________________________________________________
|
---|
[9182fd9] | 664 | // Función: manda_trama
|
---|
[5ea3638] | 665 | //
|
---|
[9182fd9] | 666 | // Descripción:
|
---|
| 667 | // Esta Función envía una trama por la red (TCP)
|
---|
| 668 | // Parámetros:
|
---|
[5ea3638] | 669 | // - sock : El socket del host al que se dirige la trama
|
---|
| 670 | // - trama: El contenido de la trama
|
---|
| 671 | /// _____________________________________________________________________________________________________________
|
---|
| 672 | int manda_trama(SOCKET sock,TRAMA* trama)
|
---|
| 673 | {
|
---|
| 674 | int nLeft,idx,ret;
|
---|
| 675 |
|
---|
| 676 | Encriptar((char*)trama);
|
---|
| 677 | nLeft = strlen((char*)trama);
|
---|
| 678 | idx = 0;
|
---|
| 679 | while(nLeft > 0){
|
---|
| 680 | ret = send(sock,(char*)&trama[idx], nLeft, 0);
|
---|
| 681 | if (ret == 0)
|
---|
| 682 | break;
|
---|
| 683 | else
|
---|
| 684 | if (ret == SOCKET_ERROR){
|
---|
| 685 | RegistraLog("***AGENT***send() fallo al enviar trama:",true);
|
---|
| 686 | return(FALSE);
|
---|
| 687 | }
|
---|
| 688 | nLeft -= ret;
|
---|
| 689 | idx += ret;
|
---|
| 690 | }
|
---|
| 691 | return(TRUE);
|
---|
| 692 | }
|
---|
| 693 | //******************************************************************************************************************************************
|
---|
[9182fd9] | 694 | // PROGRAMA PRINCIPAL
|
---|
[5ea3638] | 695 | //******************************************************************************************************************************************
|
---|
[9182fd9] | 696 | int main(int argc, char *argv[]) {
|
---|
| 697 |
|
---|
| 698 | struct tm* st;
|
---|
| 699 |
|
---|
| 700 | strcpy(szPathFileCfg, "ogAdmAgent.cfg");
|
---|
| 701 | strcpy(szPathFileLog, "ogAdmAgent.log");
|
---|
| 702 | int i;
|
---|
| 703 | for (i = 1; (i + 1) < argc; i += 2) {
|
---|
| 704 | if (argv[i][0] == '-') {
|
---|
| 705 | switch (tolower(argv[i][1])) {
|
---|
| 706 | case 'f':
|
---|
| 707 | if (argv[i + 1] != NULL)
|
---|
| 708 | strcpy(szPathFileCfg, argv[i + 1]);
|
---|
| 709 | else {
|
---|
| 710 | RegistraLog(
|
---|
| 711 | "Fallo en los parámetros: Debe especificar el fichero de configuración del servicio",
|
---|
| 712 | false);
|
---|
| 713 | exit(EXIT_FAILURE);
|
---|
| 714 | }
|
---|
| 715 | break;
|
---|
| 716 | case 'l':
|
---|
| 717 | if (argv[i + 1] != NULL)
|
---|
| 718 | strcpy(szPathFileLog, argv[i + 1]);
|
---|
| 719 | else {
|
---|
| 720 | RegistraLog(
|
---|
| 721 | "Fallo en los parámetros: Debe especificar el fichero de log para el servicio",
|
---|
| 722 | false);
|
---|
| 723 | exit(EXIT_FAILURE);
|
---|
| 724 | }
|
---|
| 725 | break;
|
---|
| 726 | default:
|
---|
| 727 | RegistraLog(
|
---|
| 728 | "Fallo de sintaxis en los parámetros: Debe especificar -f nombre_del_fichero_de_configuración_del_servicio",
|
---|
| 729 | false);
|
---|
| 730 | exit(EXIT_FAILURE);
|
---|
| 731 | break;
|
---|
| 732 | }
|
---|
| 733 | }
|
---|
| 734 | }
|
---|
| 735 | if (szPathFileCfg == NULL) {
|
---|
| 736 | printf("***Error. No se ha especificado fichero de configuración\n");
|
---|
| 737 | exit(EXIT_FAILURE);
|
---|
| 738 | }
|
---|
| 739 | if (!TomaConfiguracion(szPathFileCfg)) { // Toma parametros de configuración
|
---|
| 740 | RegistraLog(
|
---|
| 741 | "El fichero de configuración contiene un error de sintaxis",
|
---|
| 742 | false);
|
---|
| 743 | exit(EXIT_FAILURE);
|
---|
| 744 | }
|
---|
[5ea3638] | 745 |
|
---|
[9182fd9] | 746 | int pseg;
|
---|
[5ea3638] | 747 | while (TRUE){
|
---|
[9182fd9] | 748 | st = TomaHora();
|
---|
| 749 | //pseg=1000*(65-st->tm_sec); // Calcula milisegundos de inactividad de la hebra
|
---|
| 750 | pseg=65-st->tm_sec; // Calcula segundos de inactividad de la hebra
|
---|
| 751 | sleep(pseg);
|
---|
| 752 |
|
---|
[5ea3638] | 753 | // Toma la hora
|
---|
[9182fd9] | 754 | st = TomaHora();
|
---|
[231f87d] | 755 | busca_accion(st->tm_mday,st->tm_mon+1,st->tm_year+1900,st->tm_hour,st->tm_min,st->tm_wday );
|
---|
[5ea3638] | 756 | }
|
---|
[9182fd9] | 757 | }
|
---|
[5ea3638] | 758 |
|
---|