source: admin/Services/ogAdmAgent/sources/ogAdmAgent.cpp @ 1678fa1

918-git-images-111dconfigfileconfigure-oglivegit-imageslgromero-new-oglivemainmaint-cronmount-efivarfsmultivmmultivm-ogboot-installerogClonningEngineogboot-installer-jenkinsoglive-ipv6test-python-scriptsticket-301ticket-50ticket-50-oldticket-577ticket-585ticket-611ticket-612ticket-693ticket-700ubu24tplunification2use-local-agent-oglivevarios-instalacionwebconsole3
Last change on this file since 1678fa1 was fc97b46, checked in by alonso <alonso@…>, 15 years ago

git-svn-id: https://opengnsys.es/svn/trunk@1006 a21b9725-9963-47de-94b9-378ad31fedc9
  • Property mode set to 100644
File size: 24.9 KB
Line 
1// *************************************************************************
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 :
8//             
9// ****************************************************************************
10#include "ogAdmAgent.h"
11#include "ogAdmLib.c"
12
13//________________________________________________________________________________________________________
14//
15// Función: TomaConfiguracion
16//
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//________________________________________________________________________________________________________
22int 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);
118}
119// _____________________________________________________________________________________________________________
120// Función: busca_accion
121//
122//               Descripción:
123//                      Esta Función busca en la base de datos, acciones programadas
124//              Parametros:
125//                      - dia : Día actual del mes
126//                      - mes : mes en curso
127//                      - anno : Año en curso
128//                      - hora : Hora actual
129//                      - minutos : Minutos actuales
130//                      - diasemana : Dia de la semana 1=lunes,2=martes ... ( 0 Domingo)
131// _____________________________________________________________________________________________________________
132int 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;
141        anno=anno-2009; // Año de comienzo es 2004
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
151        // Cuestión semanas
152        ordiasem_1=DiadelaSemana(1,mes,anno+2009);
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
155                maxdias=dias_meses[mes];
156        else{
157                if (bisiesto(anno+2009))
158                        maxdias=29;
159                else
160                        maxdias=28;
161        }
162        ordulsem=SemanadelMes(ordiasem_1,maxdias); // Calcula el número de última semana
163
164        bitsemana=HEX_semanas[ordsem];
165        if(ordsem==ordulsem) // Si es la última semana del mes
166                bitsemana|=HEX_semanas[6];
167
168        if (!db.Open(usuario, pasguor, datasource, catalog)) { // error de conexion
169                        db.GetErrorErrStr(ErrStr);
170                        return (false);
171        }
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
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        }
193        if (!wdb.Open(usuario, pasguor, datasource, catalog)) { // error de conexion
194                        db.GetErrorErrStr(ErrStr);
195                        return (false);
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                }
206                if(tipoaccion==EJECUCION_TAREA){ // Es una programación de una tarea
207                        EjecutarTarea(identificador,0,0,0,wdb,parametros);
208                }
209                else{
210                        if(tipoaccion==EJECUCION_TRABAJO){
211                                EjecutarTrabajo(identificador,wdb,parametros); // Es una programación de un trabajo
212                        }
213                        else{
214                                if(tipoaccion==EJECUCION_RESERVA){
215                                        EjecutarReserva(identificador,wdb,parametros); // Es una programación de un trabajo
216                                }
217                        }
218                }
219                tbl.MoveNext();
220        }
221        return(true); 
222}
223// _____________________________________________________________________________________________________________
224// Función: bisiesto
225//
226//              Descripción:
227//                      Esta Función devuelve true si el año pasado como parámetro es bisiesto y false si no lo es
228//              Parametros:
229//                      - anob : un año en formato aaaa
230// _____________________________________________________________________________________________________________
231bool bisiesto(WORD anob){
232        return(anob%4==0);
233}
234// _____________________________________________________________________________________________________________
235// Función: DiadelaSemana
236//
237//              Descripción:
238//                      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
239//              Parametros:
240//                      - dia : Un día
241//                      - mes : Un mes
242//                      - anno : Un año
243// _____________________________________________________________________________________________________________
244int DiadelaSemana(WORD dia,WORD mes,WORD anno)
245{
246        int i,cont,dias_anuales;
247        int desplazamiento_dias=6;
248        int orddiasem;
249
250        cont =0;
251        for (i=1900;i<anno;i++){
252                if (bisiesto(i)) dias_anuales=366; else dias_anuales=365;
253                cont+=dias_anuales;
254        }
255        for (i=1;i<mes;i++){
256                if (i!=2)
257                        cont+=dias_meses[i];
258                else{
259                        if (bisiesto(anno))
260                                cont+=29;
261                        else
262                                cont+=28;
263                }
264        }
265        cont+=dia+desplazamiento_dias;
266        orddiasem=(cont%7);
267        if(orddiasem==0) orddiasem=7;
268        return(orddiasem);
269}
270// _____________________________________________________________________________________________________________
271// Función: SemanadelMes
272//
273//              Descripción:
274//                      Esta Función devuelve el número de semana perteneciente a un día de ese mes
275//              Parámetros:
276//                      - ordiasem_1 : Orden semenal (1,2...) del dia del primer dia del mes que se pasa como parámetro
277//                      - diames : El mes concreto
278// _____________________________________________________________________________________________________________
279int SemanadelMes(int ordiasem_1,int diames)
280{
281        int nwdia,resto,cociente;
282
283        nwdia=diames+ordiasem_1-1;
284        cociente=nwdia/7;
285        resto=nwdia%7;
286        if(resto>0) cociente++;
287        return(cociente);
288}
289// _____________________________________________________________________________________________________________
290// Función: Pausa
291//
292//              Descripción:
293//                      Hace una pausa en segundos
294//              Parametros:
295//                      - s : Segundos de pausa
296// _____________________________________________________________________________________________________________
297void Pausa(int s)
298{
299        int seg=0;
300        clock_t comienzo;
301
302    comienzo = clock();
303    do{
304                seg=(clock()-comienzo)/CLOCKS_PER_SEC;
305        }while(seg<s);
306}
307// _____________________________________________________________________________________________________________
308// Función: EjecutarTrabajo
309//
310//              Descripción:
311//                      Registra una acción (Trabajo y la envía para su ejecución
312//              Parámetros:
313//                      - idtrabajo : Identificador del trabajo
314//                      - db: una conexion ADO operativa
315//                      - parametros: Parámetros de la acción
316// _____________________________________________________________________________________________________________
317int EjecutarTrabajo(int idtrabajo,Database db,char*parametros )
318{
319        char sqlstr[1000],ErrStr[200];
320        Table tbl;
321        int cont_tareas=0,lon;
322        int  idtarea,idtrabajotarea,idcentro;
323        char wambitrabajo[500],ambitrabajo[4000];
324        char wparamtrabajo[20],paramtrabajo[1000];
325        int  tbTareasidtarea[100],tbTareasidnotificador[100];
326        char *tbTareasparametros[100],*tbTareasambitoambitskwrk[100];
327        char ambitskwrk[500];
328
329        ambitrabajo[0]=(char)NULL; // Inicialización
330        strcpy(paramtrabajo,"tsk="); // Inicialización
331
332        // recupera el identificador del Centro propietario de la tarea
333        sprintf(sqlstr,"SELECT idcentro FROM trabajos WHERE idtrabajo=%d",idtrabajo);
334        if(!db.Execute(sqlstr,tbl)){ // Error al leer
335                db.GetErrorErrStr(ErrStr);
336                return(false);
337        }
338        if(tbl.ISEOF()) return(true);
339        if(!tbl.Get("idcentro",idcentro)){ // Toma dato
340                tbl.GetErrorErrStr(ErrStr); // error al acceder al registro
341                return(false);
342        }
343        // Recupera las tareas que forman parte del trabajo
344        sprintf(sqlstr,"SELECT * FROM trabajos_tareas WHERE idtrabajo=%d ORDER by orden",idtrabajo);
345        if(!db.Execute(sqlstr,tbl)){ // Error al leer
346                db.GetErrorErrStr(ErrStr);
347                return(false);
348        }
349        if(tbl.ISEOF()) return(true);
350        // Recorre trabajos-tareas
351        while(!tbl.ISEOF()){   
352                if(!tbl.Get("idtrabajotarea",idtrabajotarea)){ // Toma dato
353                        tbl.GetErrorErrStr(ErrStr); // error al acceder al registro
354                        return(false);
355                }
356                tbTareasidnotificador[cont_tareas]=idtrabajotarea;
357
358                if(!tbl.Get("idtarea",idtarea)){ // Toma dato
359                        tbl.GetErrorErrStr(ErrStr); // error al acceder al registro
360                        return(false);
361                }
362                tbTareasidtarea[cont_tareas]=idtarea;
363
364                if(!tbl.Get("parametros",parametros)){ // Toma dato
365                        tbl.GetErrorErrStr(ErrStr); // error al acceder al registro
366                        return(false);
367                }
368                lon=strlen(parametros);
369                tbTareasparametros[cont_tareas]=(char*)malloc(lon);
370                if(tbTareasparametros[cont_tareas]==NULL)
371                        return(false); // No hay memoria bastante
372                strcpy(tbTareasparametros[cont_tareas],parametros);
373               
374                if(!tbl.Get("ambitskwrk",ambitskwrk)){ // Toma dato
375                        tbl.GetErrorErrStr(ErrStr); // error al acceder al registro
376                        return(false);
377                }
378                lon=strlen(ambitskwrk);
379                tbTareasambitoambitskwrk[cont_tareas]=(char*)malloc(lon);
380                strcpy(tbTareasambitoambitskwrk[cont_tareas],ambitskwrk);
381
382                sprintf(wambitrabajo,"%s;",ambitskwrk);
383                strcat(ambitrabajo,wambitrabajo);
384
385                sprintf(wparamtrabajo,"%d;",idtrabajotarea);
386                strcat(paramtrabajo,wparamtrabajo);
387
388                cont_tareas++;
389                tbl.MoveNext();
390        }
391        lon=strlen(ambitrabajo);
392        ambitrabajo[lon-1]=(char)NULL; // Quita la coma final
393
394        lon=strlen(paramtrabajo);
395        paramtrabajo[lon-1]=(char)NULL; // Quita la coma final
396
397        char fechareg[100];
398
399
400        struct tm* st;
401        st = TomaHora();
402        sprintf(fechareg, "%d/%d/%d %d:%d:%d", st->tm_year + 1900, st->tm_mon + 1,
403                                st->tm_mday, st->tm_hour, st->tm_min, st->tm_sec);
404
405        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);
406        if(!db.Execute(sqlstr)){ // Error al insertar
407                db.GetErrorErrStr(ErrStr);
408                return(false);
409        }
410        int accionid=0;
411        // Toma identificador de la acción
412        sprintf(sqlstr,"SELECT @@identity as identificador");
413        if(!db.Execute(sqlstr,tbl)){ // Error al leer
414                db.GetErrorErrStr(ErrStr);
415                return(false);
416        }
417        if(!tbl.ISEOF()){ // Si existe registro
418                if(!tbl.Get("identificador",accionid)){
419                        tbl.GetErrorErrStr(ErrStr); // error al acceder al registro
420                        return(false);
421                }
422        }
423        int i;
424        // Insertar acciones:tareas
425        for (i=0;i<cont_tareas;i++){
426                if(!EjecutarTarea(tbTareasidtarea[i],accionid,tbTareasidnotificador[i],idcentro,db,parametros)){
427                        free(tbTareasparametros[i]);
428                        free(tbTareasambitoambitskwrk[i]);
429                        return(false);
430                }
431                free(tbTareasparametros[i]);
432                free(tbTareasambitoambitskwrk[i]);
433        }
434        return(true);
435}
436// _____________________________________________________________________________________________________________
437// Función: EjecutarTarea
438//
439//              Descripción:
440//                      Registra una acción (Tarea) y la envía para su ejecución
441//              Parámetros:
442//                      - idtarea : Identificador de la tarea
443//                      - accionid: identificador del trabajo padre (si existe)
444//                      - idnotificador:  identificador del trabajo_tarea incluido en trabajo padre (si existe)
445//                      - idcentro: Centro propietario del trabjo padre (si existe este trabajo)
446//                      - db: una conexion ADO operativa
447//                      - parametros: Parámetros de la acción
448// _____________________________________________________________________________________________________________
449int EjecutarTarea(int idtarea,int accionid,int idnotificador,int idcentro,Database db,char *parametros )
450{
451        char sqlstr[1000],ErrStr[200],ambito;
452        Table tbl;
453        int cont_comandos=0,lon;
454        int  idcomando,idambito,idtareacomando,accionidcmd;
455        char wambitarea[20],ambitarea[4000];
456        char wparamtarea[20],paramtarea[1000],pids[20];
457        int  tbComandosidcomando[100],tbComandosambito[100],tbComandosidnotificador[100],tbComandosidambito[100];
458        char *tbComandosparametros[100];
459
460        ambitarea[0]=(char)NULL; // Inicialización
461        strcpy(paramtarea,"cmd="); // Inicialización
462        if(idcentro==0){
463                // recupera el identificador del Centro propietario de la tarea
464                sprintf(sqlstr,"SELECT idcentro FROM tareas WHERE idtarea=%d",idtarea);
465                if(!db.Execute(sqlstr,tbl)){ // Error al leer
466                        db.GetErrorErrStr(ErrStr);
467                        return(false);
468                }
469                if(tbl.ISEOF()) return(true);
470                if(!tbl.Get("idcentro",idcentro)){ // Toma dato
471                        tbl.GetErrorErrStr(ErrStr); // error al acceder al registro
472                        return(false);
473                }
474        }
475        // Recupera los comandos que forman parte de la tarea
476        sprintf(sqlstr,"SELECT * FROM tareas_comandos WHERE idtarea=%d ORDER by orden",idtarea);
477        if(!db.Execute(sqlstr,tbl)){ // Error al leer
478                db.GetErrorErrStr(ErrStr);
479                return(false);
480        }
481        if(tbl.ISEOF()) return(true);
482               
483        // Recorre tareas-comandos
484        while(!tbl.ISEOF()){   
485                if(!tbl.Get("idcomando",idcomando)){ // Toma dato
486                        tbl.GetErrorErrStr(ErrStr); // error al acceder al registro
487                        return(false);
488                }
489                tbComandosidcomando[cont_comandos]=idcomando;
490
491                if(!tbl.Get("ambito",ambito)){ // Toma dato
492                        tbl.GetErrorErrStr(ErrStr); // error al acceder al registro
493                        return(false);
494                }
495                tbComandosambito[cont_comandos]=ambito;
496
497                if(!tbl.Get("idambito",idambito)){ // Toma dato
498                        tbl.GetErrorErrStr(ErrStr); // error al acceder al registro
499                        return(false);
500                }
501                tbComandosidambito[cont_comandos]=idambito;
502
503
504                if(!tbl.Get("parametros",parametros)){ // Toma dato
505                        tbl.GetErrorErrStr(ErrStr); // error al acceder al registro
506                        return(false);
507                }
508
509                lon=strlen(parametros);
510                tbComandosparametros[cont_comandos]=(char*)malloc(lon+20);
511                if(tbComandosparametros[cont_comandos]==NULL)
512                        return(false); // No hay memoria bastante
513
514                strcpy(tbComandosparametros[cont_comandos],parametros);
515               
516                if(!tbl.Get("idtareacomando",idtareacomando)){ // Toma dato
517                        tbl.GetErrorErrStr(ErrStr); // error al acceder al registro
518                        return(false);
519                }
520                tbComandosidnotificador[cont_comandos]=idtareacomando;
521
522                sprintf(wambitarea,"%d:%d;",ambito,idambito);
523                strcat(ambitarea,wambitarea);
524
525                sprintf(wparamtarea,"%d;",idtareacomando);
526                strcat(paramtarea,wparamtarea);
527
528                cont_comandos++;
529                tbl.MoveNext();
530        }
531        lon=strlen(ambitarea);
532        ambitarea[lon-1]=(char)NULL; // Quita la coma final
533
534        lon=strlen(paramtarea);
535        paramtarea[lon-1]=(char)NULL; // Quita la coma final
536
537        char fechareg[100];
538
539
540        struct tm* st;
541    st = TomaHora();
542    sprintf(fechareg, "%d/%d/%d %d:%d:%d", st->tm_year + 1900, st->tm_mon + 1,
543                        st->tm_mday, st->tm_hour, st->tm_min, st->tm_sec);
544
545        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);
546        if(!db.Execute(sqlstr)){ // Error al insertar
547                db.GetErrorErrStr(ErrStr);
548                return(false);
549        }
550        accionid=0;
551        // Toma identificador de la acción
552        sprintf(sqlstr,"SELECT @@identity as identificador");
553        if(!db.Execute(sqlstr,tbl)){ // Error al leer
554                db.GetErrorErrStr(ErrStr);
555                return(false);
556        }
557        if(!tbl.ISEOF()){ // Si existe registro
558                if(!tbl.Get("identificador",accionid)){
559                        tbl.GetErrorErrStr(ErrStr); // error al acceder al registro
560                        return(false);
561                }
562        }
563        int i;
564        // Insertar acciones:comandos
565        for (i=0;i<cont_comandos;i++){
566                st = TomaHora();
567                sprintf(fechareg, "%d/%d/%d %d:%d:%d", st->tm_year + 1900, st->tm_mon
568                                                + 1, st->tm_mday, st->tm_hour, st->tm_min, st->tm_sec);
569
570                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]);
571                if(!db.Execute(sqlstr)){ // Error al insertar
572                        db.GetErrorErrStr(ErrStr);
573                        free(tbComandosparametros[i]);
574                        return(false);
575                }
576
577                // Toma identificador dela acción
578                sprintf(sqlstr,"SELECT @@identity as identificador");
579                if(!db.Execute(sqlstr,tbl)){ // Error al leer
580                        db.GetErrorErrStr(ErrStr);
581                        return(false);
582                }
583
584                if(!tbl.ISEOF()){ // Si existe registro
585                        if(!tbl.Get("identificador",accionidcmd)){
586                        tbl.GetErrorErrStr(ErrStr); // error al acceder al registro
587                        return(false);
588                        }
589                }
590                sprintf(pids,"ids=%d\r",accionidcmd);
591                strcat(tbComandosparametros[i],pids); // Le añade el identificador de la acción
592                envia_comando(tbComandosparametros[i]);
593                free(tbComandosparametros[i]);
594        }
595        return(true);
596}
597// _____________________________________________________________________________________________________________
598// Función: EjecutarReserva
599//
600//              Descripción:
601//                      Registra una acción (Tarea) y la envía para su ejecución
602//              Parámetros:
603//                      - idreserva : Identificador de la reserva
604//                      - db: una conexion ADO operativa
605//                      - parametros: Parámetros de la acción
606// _____________________________________________________________________________________________________________
607int EjecutarReserva(int idreserva,Database db,char*parametros )
608{
609        char sqlstr[1000],ErrStr[200];
610        Table tbl;
611        int idaccion;
612
613        sprintf(sqlstr,"SELECT idtarea,idtrabajo FROM reservas WHERE idreserva=%d",idreserva);
614        if(!db.Execute(sqlstr,tbl)){ // Error al leer
615                db.GetErrorErrStr(ErrStr);
616                return(false);
617        }
618        if(tbl.ISEOF()){
619                return(false);  // No hay acciones previas en la  reserva
620        }
621
622        if(!tbl.Get("idtarea",idaccion)){ // Toma dato
623                tbl.GetErrorErrStr(ErrStr); // error al acceder al registro
624                return(false);
625        }
626        if(idaccion>0)
627                EjecutarTarea(idaccion,0,0,0,db,parametros); // Es una reserva con tarea previa
628
629        if(!tbl.Get("idtrabajo",idaccion)){ // Toma dato
630                tbl.GetErrorErrStr(ErrStr); // error al acceder al registro
631                return(false);
632        }
633        if(idaccion>0)
634                EjecutarTrabajo(idaccion,db,parametros); // Es una reserva con trabajo previo
635
636        return(true);
637}
638// _____________________________________________________________________________________________________________
639// Función: envia_comando
640//
641//              Descripción:
642//                      Envía un comando a la red. Para ello es necesario tener iniciado el servicio hidra.
643//              Parámetros:
644//                      - parametros: Parámetros del comando
645// _____________________________________________________________________________________________________________
646int envia_comando(char* parametros)
647{
648        SOCKET sClient;
649        TRAMA trama;
650
651        sClient = AbreConexion(servidorhidra,puerto);
652        if (sClient == (SOCKET)NULL)
653                return(FALSE);
654
655        trama.arroba='@';
656        strncpy(trama.identificador,"JMMLCAMDJ",9);
657        trama.ejecutor=parametros[0];
658        strcpy(trama.parametros,(char*)&parametros[1]);
659    return(manda_trama(sClient,&trama));
660}
661
662/// _____________________________________________________________________________________________________________
663// Función: manda_trama
664//
665//              Descripción:
666//                      Esta Función envía una trama por la red (TCP)
667//              Parámetros:
668//                      - sock : El socket del host al que se dirige la trama
669//                      - trama: El contenido de la trama
670/// _____________________________________________________________________________________________________________
671int manda_trama(SOCKET sock,TRAMA* trama)
672{
673        int nLeft,idx,ret;
674
675        Encriptar((char*)trama);
676        nLeft = strlen((char*)trama);
677        idx = 0;
678        while(nLeft > 0){
679                ret = send(sock,(char*)&trama[idx], nLeft, 0);
680                if (ret == 0)
681                        break;
682                else
683                        if (ret == SOCKET_ERROR){
684                                RegistraLog("***AGENT***send() fallo al enviar trama:",true);
685                                return(FALSE);
686                        }
687                nLeft -= ret;
688                idx += ret;
689        }
690        return(TRUE);
691}
692//******************************************************************************************************************************************
693// PROGRAMA PRINCIPAL
694//******************************************************************************************************************************************
695int main(int argc, char *argv[]) {
696
697        struct tm* st;
698
699        strcpy(szPathFileCfg, "ogAdmAgent.cfg");
700        strcpy(szPathFileLog, "ogAdmAgent.log");
701        int i;
702        for (i = 1; (i + 1) < argc; i += 2) {
703                if (argv[i][0] == '-') {
704                        switch (tolower(argv[i][1])) {
705                        case 'f':
706                                if (argv[i + 1] != NULL)
707                                        strcpy(szPathFileCfg, argv[i + 1]);
708                                else {
709                                        RegistraLog(
710                                                        "Fallo en los parámetros: Debe especificar el fichero de configuración del servicio",
711                                                        false);
712                                        exit(EXIT_FAILURE);
713                                }
714                                break;
715                        case 'l':
716                                if (argv[i + 1] != NULL)
717                                        strcpy(szPathFileLog, argv[i + 1]);
718                                else {
719                                        RegistraLog(
720                                                        "Fallo en los parámetros: Debe especificar el fichero de log para el servicio",
721                                                        false);
722                                        exit(EXIT_FAILURE);
723                                }
724                                break;
725                        default:
726                                RegistraLog(
727                                                "Fallo de sintaxis en los parámetros: Debe especificar -f nombre_del_fichero_de_configuración_del_servicio",
728                                                false);
729                                exit(EXIT_FAILURE);
730                                break;
731                        }
732                }
733        }
734        if (szPathFileCfg == NULL) {
735                printf("***Error. No se ha especificado fichero de configuración\n");
736                exit(EXIT_FAILURE);
737        }
738        if (!TomaConfiguracion(szPathFileCfg)) { // Toma parametros de configuración
739                RegistraLog(
740                                "El fichero de configuración contiene un error de sintaxis",
741                                false);
742                exit(EXIT_FAILURE);
743        }
744
745        int pseg;
746        while (TRUE){
747                st = TomaHora();
748                //pseg=1000*(65-st->tm_sec); // Calcula milisegundos de inactividad de la hebra
749                pseg=65-st->tm_sec; // Calcula segundos de inactividad de la hebra
750                sleep(pseg);
751
752                // Toma la hora
753                st = TomaHora();
754                busca_accion(st->tm_mday,st->tm_mon+1,st->tm_year+1900,st->tm_hour,st->tm_min,st->tm_wday );
755        }
756}
757       
Note: See TracBrowser for help on using the repository browser.