Paradox - Urgente exportar

/*----------------------------------------------------------------*\

 * Nombre         : oServer.c                                    *

 * ---------------------------------------------------------------*

 *----------------------------------------------------------------*

 * Compile        : cc -o oServer.o -c oServer.c

 * Compile        : cc -o oServer.o -c oServer.c -w

 * Enlace Binario : cc -o oServer oServer.o -w

 *----------------------------------------------------------------*

 *               curl -v telnet://11.212.30.70:1921

 *               curl -v telnet://Host56narvi.red.intra:1921

\*----------------------------------------------------------------*/

#define Equ     ==

#define And     &&

#define Or      ||

#define SOCKET  int

#include <netinet/in.h>

#include <netinet/tcp.h>

#include <arpa/inet.h>

#include <sys/types.h>

#include <sys/socket.h>

#include <sys/wait.h>

#include <time.h>

#include <stdio.h>

#include <string.h>

#include <stdlib.h>

#include <errno.h>

#include <unistd.h>

/*--------------------------------------------------------------*\

 | Max of IO errors when no value is defined                    |

\*--------------------------------------------------------------*/

#define OVERSION      "1.8.9(Release)"

#define FAILURE       (-1)

#define MAX_IO_ERRORS (9999)

#define false         (0)

#define true          (!false)

#define TRUE  1

#define FALSE 0

/*--------------------------------------------------------------*\

 | Max of Length of char * variables                            |

\*--------------------------------------------------------------*/

#define LMAX_FILE     220     /*   Usado para variables PATH+NAMFELE.EXT           */

#define LMAX_CMND     280     /*   Usado para comandos and ShellScripts            */

#define LMAX_MSGE     280     /*   Usado para definir longitud de Mensaje          */

#define LMAX_TITU     90      /*   Usado para definir vars de ASUNTO  de mail      */

#define LSUB_MAIL     280     /*                                                   */

#define LDES_MAIL     220     /*                                                   */

#define LMAX_RESP     220     /*                                                   */

#define TENGO_Q_SALIR 0

/*--------------------------------------------------------------*\

 | Definition of tipo Procedencia                               |

\*--------------------------------------------------------------*/

#define IS_DATANET    1

#define IS_CERRAR     5

/*--------------------------------------------------------------*\

 | Functions Prototype                                          |

\*--------------------------------------------------------------*/

int Recibe(SOCKET Socket, char * cCadena, int nBuffLen) ;

int Presentacion() ;

int GetProcedencia( char * cMensaje ) ;

int GetProcedenciav2( char * cMensaje );

void GetNameDatanetLog(char * ccDataLog);

void GetNameDatanetResp(char * ccDataResp);

void GetNameJyam11Log(char * ccJyam11Log);

void GetRespuestaDatanet(char * ccRipo, char * cNameFile);

void GrabaLogs(char * ccFileLog, char * cMessage, char * cRpta);

void GrabaDatanetLog(char * cMessage, char * cRpta);

void GrabaLogJyam11(char * cMessage );

void SendMailDataNet(char * cSubject, char * cGrupete) ;

void SaveBodyDataNet(char * cStrLine, char * ccAsunto);

void GetAsuntoMail(char * ccSubject, char * ccResp );

int GetCodigoRespuesta(char * cRespuesta);

void EliminaLogs(char * cArchivo) ;

void Rta_RTrim( char * ccDestino, char a[LMAX_FILE]);

void rtrim( char * ccDestino, char a[LMAX_MSGE]);

void ltrim( char * ccDestino, char b[LMAX_MSGE]);

void  trim( char * ccDestino, char c[LMAX_MSGE]);

void AvisoToCompliance( char * cStrLine );

void ProcJyam11();

int GetPortOfListen();

void GrabaTCPULog(char * cMessage);

void QuitarEndOfLine( char *cadenaOriginal );

void QuitarExtChar( char *cadenaOriginal );

void getSubString(char *str, char *subStr, int start, int length);

static char Error110[] = "Saldo Insuficiente";

static char Error104[] = "Cuenta Invalida o Inexistente";

static char Error105[] = "Cuenta Cerrada";

static char Error106[] = "Operacion Fuera de Fecha";

static char Error107[] = "Error Interno en Particularidades De La Cuenta";

static char Error108[] = "Cuenta Bloqueada";

static char Error113[] = "Importe en Cero ";

static char Error114[] = "Param.Divisa del Movim. Faltante ";

static char Error999[] = "Error Interno. No Se Ejecuta Bloqueo de Saldo en PALLAS II";

static char ErrorDef[] = "Error Indefinido";

/*-------------------------------------------------------------*\

 | Nombre......: main()                                        |

 | Tipo........: void                                          |

 | Autor.......: Golen Von Miller                                 |

 | Fecha.......: 15-05-2009                                    |

 | ............:                                               |

 | Descripcion.:                                               |

 | ............:                                               |

\*-------------------------------------------------------------*/

int main(int argc, char *argv[]) {

     SOCKET  ServerSocket = 0;

     SOCKET  ClientSocket = 0;

     struct  sockaddr_in    ServerInetAddress = { 0,0,0,0};

     struct  linger linger = { 0 , 0 };

     long    InetAddressLen = sizeof(ServerInetAddress);

     int     port      = 0,

             nLen      = 0;

     int     bNoDelay  = 1;

     int     nSysProcd = 0;

     char    ccTcplog[LMAX_MSGE]    = {0x00};

     char    ccRegLog[LMAX_MSGE]    = {0x00};

     char    scCadena[LMAX_MSGE]    = {0x00};

     char    cCadena [LMAX_MSGE]    = {0x00};

     char    *pCadena               = cCadena;

     char    cc_Jcl_GLVER34[LMAX_MSGE] = {0x00};

     char    cDatanetLog[LMAX_FILE] = {0x00} ;

     char    cDatanetRta[LMAX_FILE] = {0x00} ;

     char    ccResp[LMAX_FILE]      = {0x00};

     char    cAsunto[LMAX_TITU]     = {0x00} ;

     int     iConDatanet            = 0;

     int     iCblo                  = 0;

     int     idErroneos             = 0;

     int     ioErroneos             = 0;

     int     EstoyActivo            = 1;

     char    ccCblo[6]              = {0x00} ;

     pthread_attr_t tattr;

     pthread_t   handJyam11;

     void *status;

     /*======================================*/

     char client_ip[INET_ADDRSTRLEN];

     /*======================================*/

     time_t RawTime;

     char ccRawTime[25]      = {0x00} ;

     char cDreamTeam[LDES_MAIL]   = "polan.truv@au.korean.com,golen.fgf@au.korean.com";

     char cCapitMarket[LDES_MAIL] = "Sea.bo.capmarket@ua.korean.com,ism.vera@au.korean.com";

     Presentacion() ;

     /*--------------------------------------------------*\

      *  Allocate the server's socket descriptor         *

     \*--------------------------------------------------*/

     if  ((ServerSocket = socket(AF_INET,SOCK_STREAM, 0)) == FAILURE) {

          printf("Error de creacion del socket\r\n");

          system( "GLVER34 MAIL" );

          exit(FAILURE);

     }

     printf("Socket creado\r\n");

     /*--------------------------------------------------*\

      *  Set the linger option to force immediate closing*

     \*--------------------------------------------------*/

     linger.l_onoff  = 1; /* turn on timer     */

     linger.l_linger = 0; /* close immediately */

     if  ((setsockopt(ServerSocket, SOL_SOCKET, SO_LINGER, (char *)(&linger), sizeof(linger))) == FAILURE)

     {

           printf("Error de opcion sobre el socket - linger\r\n");

           system( "GLVER34 MAIL" );

           exit(FAILURE);

     }

     /*--------------------------------------------------*\

      *  Don't buffer up requests - send them immediately*

     \*--------------------------------------------------*/

     if  ((setsockopt(ServerSocket, IPPROTO_TCP, TCP_NODELAY, (char *)(&bNoDelay), sizeof(bNoDelay))) == FAILURE) {

          printf("Error de creacion del socket - delay\r\n");

          system( "GLVER34 MAIL" );

          exit(FAILURE);

     }

     GetNameDatanetLog(cDatanetLog);

     printf("LOG Datanet \t %s \n", cDatanetLog) ;

     printf("***************************************************************************\r\n");

     printf("Transferencias Datanet Online ONLINE \t\t Version %s \n", OVERSION);

     printf("***************************************************************************\r\n");

     GetNameDatanetResp(cDatanetRta);

     /*--------------------------------------------------*\

     *  Initialize the socket address so we can bind it   *

     \*--------------------------------------------------*/

     /*

      |

      |  port = atoi(argv[1]);

      |  ---------------------

      */

     port=GetPortOfListen();

     printf("Port Number[ %i ]\n", port);

     memset(&ServerInetAddress, 0x00, sizeof(ServerInetAddress));

     ServerInetAddress.sin_family      = AF_INET;

     ServerInetAddress.sin_addr.s_addr = INADDR_ANY; /* Let anyone connect  */

     ServerInetAddress.sin_port        = htons(port);

     /*------------------------------------------*\

     * Bind socket to the well-known port number  *

     \*------------------------------------------*/

     if (bind(ServerSocket, (struct sockaddr*)&ServerInetAddress, sizeof(ServerInetAddress)) == FAILURE)

     {

         printf("Error de enlace al socket\r\n");

         system( "GLVER34 MAIL" );

         exit(FAILURE);

     }

     /*--------------------------------------------------*\

      * Show we are willing to listen                    *

     \*--------------------------------------------------*/

     if (listen(ServerSocket, 1) == FAILURE) {

         printf("Error de escucha sobre el socket\r\n");

         system( "GLVER34 MAIL" );

         exit(FAILURE);

     }

     EstoyActivo=1;

     while ( EstoyActivo ) {

         printf("Escuchando...\r\n");

         /*if ((ClientSocket = accept(ServerSocket, (struct sockaddr*)&ServerInetAddress, &InetAddressLen)) == FAILURE) */

         if ((ClientSocket = accept(ServerSocket , (struct sockaddr*)&ServerInetAddress,(socklen_t *)&InetAddressLen)) == FAILURE) {

              printf("Error de aceptacion sobre el socket\r\n");

              system( "GLVER34 MAIL" );

              exit(FAILURE);

         }

         memset(ccTcplog, '\0', sizeof(ccTcplog));

         memset(ccRawTime, '\0', sizeof(ccRawTime));

         time(&RawTime);

         sprintf(ccRawTime,"%s", ctime( &RawTime ) );

         /*===========================================================================================*/

         inet_ntop(AF_INET, &(ServerInetAddress.sin_addr), client_ip, INET_ADDRSTRLEN);

         /*   printf("Client IP: %s\n", client_ip);   */

         printf("Conexion IP [%s] aceptada:(handle: %i) Hora [%s]\n", client_ip, ClientSocket, ccRawTime);

         sprintf(ccTcplog, "IP[ %s ] Conectada a Hs:[ %s ] ", client_ip, ctime( &RawTime ) );

         // QuitarEndOfLine( ccTcplog );

         GrabaTCPULog( ccTcplog );

         /*===========================================================================================*/

         /*

          printf("Conexion cliente aceptada:(%i)\r\n",ClientSocket);

          */

         /*---------------------------------*\

          *  Recibe data from the client    *

         \*---------------------------------*/

         memset( scCadena, '\0', sizeof(scCadena));

         memset(  cCadena, '\0', sizeof( cCadena));

         if ((nLen=Recibe(ClientSocket, scCadena, sizeof(scCadena)-1)) < 0) {

              close(ClientSocket);

              ClientSocket = 0;

              printf("Conexion cliente cerrada\r\n");

              system( "GLVER34 ERROR" );

              continue ;

         } else {

             QuitarExtChar( scCadena ); /**/

             memset(ccTcplog, '\0', sizeof(ccTcplog));

             strncpy(ccTcplog, scCadena, 228);

             printf("acabo de recibir:(%s)\r\n", ccTcplog);

             memset(ccTcplog, '\0', sizeof(ccTcplog));

             strncpy(ccTcplog, scCadena, 220);

             GrabaTCPULog( ccTcplog );

             memset(ccRawTime, '\0', sizeof(ccRawTime));

             time(&RawTime);

             sprintf(ccRawTime,"%s", ctime( &RawTime ) );

             /* printf("Recv of Time:  %s\n", ccRawTime);  */

             memset(ccRegLog, '\0', sizeof(ccRegLog));

             rtrim( cCadena, scCadena );

             pCadena = cCadena ;

             /*  printf("(%s)\r\n", cCadena);             */

             memcpy(scCadena, cCadena, LMAX_MSGE );

             sprintf(ccRegLog, "%s  : %s\n", cCadena , ccRawTime );

             /* printf("%s \n", ccRegLog);                */

             memcpy(scCadena, cCadena, LMAX_MSGE );

             QuitarEndOfLine( cCadena );

             nSysProcd=GetProcedenciav2( cCadena );

             switch (nSysProcd)

             {

             case IS_DATANET:

                    memset(cc_Jcl_GLVER34, '\0', sizeof(cc_Jcl_GLVER34));

                    strncpy(cc_Jcl_GLVER34,"GLVER34 ",7) ;

                    /*-------------------------------------------------*\

                     *       PONE DELIMTADOR DE DOBLES COMILLAS        *

                    \*-------------------------------------------------*/

                    /*

                     |                   strcat( cc_Jcl_GLVER34, "\"") ;

                     */

                    strcat( cc_Jcl_GLVER34, "\"");

                    strcat( cc_Jcl_GLVER34, cCadena);

                    strcat( cc_Jcl_GLVER34, "\"");

                    /*

                     |                    strncat( cc_Jcl_GLVER34, "\"", 1) ;

                     */

                    /*-------------------------------------------------*\

                     *       EJECUTA EL JCL SELECCIONADO               *   1234567890

                    \*-------------------------------------------------*/

                    /*

                     | printf("[%s]\n", cc_Jcl_GLVER34);

                     */

                    system( cc_Jcl_GLVER34 ) ;

                    memset( ccResp, '\0', sizeof(ccResp));

                    GetRespuestaDatanet(ccResp, cDatanetRta);

                    iCblo=0;

                    memset( ccCblo, '\0', sizeof(ccCblo));

                    strncpy(ccCblo, &ccResp[46], 3);

                    iCblo=atoi(ccCblo) ;

                    printf("Respuesta[%s]  Numerico[%i]\n", ccResp, iCblo );

                    /*=======================================================*/

                    /* iCblo=GetCodigoRespuesta(ccResp);                     */

                    /* printf("GetCodigoRespuesta(ccResp)=[%i] \n",iCblo) ;  */

                    /*=======================================================*/

                    GrabaTCPULog( ccResp );

                    if ( iCblo Equ 120) {

                         printf("ccRegLog=[%s] \n",ccRegLog) ;

                         GrabaLogJyam11( ccRegLog );

                    }

                    /*=======================================*/

                    strcat(ccResp, "\x03");

                    /*=======================================*/

                    if (send(ClientSocket, ccResp, strlen(ccResp), 0) == FAILURE) {

                         close(ClientSocket);

                         ClientSocket = 0;

                         system( "GLVER34 ERROR" );

                    }

                    iConDatanet=iConDatanet+1;

                    GrabaDatanetLog(ccRegLog, ccResp) ;

                    /*

                      aqui se eleimino gran parte del codigo

                      que sera reemplazado por un shell

                      en otro job

                    */

                    break;

             case IS_CERRAR:

                    EstoyActivo = TENGO_Q_SALIR;

                    break;

             default:

                    printf("resultado en nSysProcd: %i \r\n", nSysProcd);

                    printf("Procedencia ERRONEA \n");

             }

         }

         /*----------------------------------------------------*\

          *        INICIALIZA VARIABLE PUNTERO AL CLIENT-SOCKET*

         \*----------------------------------------------------*/

         printf("Respuesta Enviada....\n");

         close(ClientSocket) ;

         ClientSocket = 0 ;

     }

     /*---------------------------------------------------*\

      * CLOSE THE SERVER CONNECTION - ONLY WHEN NO MORE   *

      * CONNECTION REQUESTS WILL BE ACCEPTED              *

     \*---------------------------------------------------*/

     close(ServerSocket);

     ServerSocket = 0;

     printf("fin de programa\r\n");

     return 0;

}

/*-------------------------------------------------------------*\

 | Nombre......: Recibe()                                      |

 | Tipo........: void                                          |

 | Autor.......: Golen Von Miller                                 |

 | Fecha.......: 15-05-2009                                    |

 | ............:                                               |

 | Descripcion.:                                               |

 | ............:                                               |

\*-------------------------------------------------------------*/

int Recibe(SOCKET Socket, char * cCadena, int nBuffLen) {

     int  nBytesRx  = 0,

          nLen      = 0,

          nBlocklen = nBuffLen;

     char *p = cCadena;

     while( true ) {

         if ((nBytesRx = recv(Socket, p, nBlocklen - nLen, 0)) == FAILURE)

             return FAILURE;

         else if ( 0 == nBytesRx )

             break;

         if( nBlocklen - nLen == 0)

             break;

         if( strchr(p, 0x03) )

             break;

         if( strchr(p, 0x0d) )

             break;

         if( strchr(p, 0x0a) )

             break;

         if( strchr(p, 0x0D) )

             break;

         if( strchr(p, 0x0A) )

             break;

         nLen += nBytesRx;

         p += nBytesRx;

     }

     nLen = nBlocklen;

     return nLen;

}

/*-------------------------------------------------------------*\

 | Nombre......: Presentacion()                                |

 | Tipo........: void                                          |

 | Autor.......: Golen Von Miller                                 |

 | Fecha.......: 15-05-2009                                    |

 | ............:                                               |

 | Descripcion.:                                               |

 | ............:                                               |

\*-------------------------------------------------------------*/

int Presentacion() {

      char cA2_Type_Env[LMAX_FILE]={0x00} ;

      char cA2_LibEnv[LMAX_FILE]={0x00} ;

      char cA2_Base[LMAX_FILE]={0x00} ;

      char cA2_OraVer[LMAX_FILE]={0x00} ;

      char cA2_NivPatch[LMAX_FILE]={0x00} ;

      char cA2_Niv_Info[LMAX_FILE]={0x00} ;

      printf("***************************************************************************\r\n");

      printf("GOLIAN tea \t\t\t Aires\n") ;

      printf("PALLAS II    \t\t\t DEV\n") ;

      printf("***************************************************************************\r\n");

      memcpy(cA2_Type_Env, getenv("A2_TYPE_ENV"), LMAX_FILE );

      memcpy(cA2_LibEnv  , getenv("A2_LIBENV"), LMAX_FILE );

      memcpy(cA2_Base    , getenv("A2_BASE"), LMAX_FILE );

      memcpy(cA2_OraVer  , getenv("A2_ORAVER"), LMAX_FILE );

      memcpy(cA2_NivPatch, getenv("A2_NIVPATCH"), LMAX_FILE );

      memcpy(cA2_Niv_Info, getenv("A2_NIV_INFO"), LMAX_FILE );

      printf("Tipo Ambiente      \t %s \n", cA2_Type_Env ) ;

      printf("Ambiente           \t %s \n", cA2_LibEnv   ) ;

      printf("Nombre de la Base  \t %s \n", cA2_Base     ) ;

      printf("Version Oracle     \t %s \n", cA2_OraVer   ) ;

      printf("Nivel de Gestab    \t %s \n", cA2_NivPatch ) ;

      printf("Nivel de DIN       \t %s \n", cA2_Niv_Info ) ;

      return 0;

}

/*-------------------------------------------------------------*\

 | Nombre......: GetProcedencia()                              |

 | Tipo........: int                                           |

 | Autor.......: Golen Von Miller                                 |

 | Fecha.......: 15-05-2009                                    |

 | ............:                                               |

 | Descripcion.: SELECCION DEL SHELL A EJECUTAR DE ACUERDO A   |

 | ............: PROCEDENCIA DEL MENSAJE QUE PUEDE SER:        |

 | ............: "DATANET"                                     |

\*-------------------------------------------------------------*/

int GetProcedencia( char * cMensaje ) {

      char cProcen[8] = "" ;

      int iComp1      = 0 ;

      int iComp5      = 0 ;

      char *pMensaje  = cMensaje ;

      int nResul      = -1 ;

      strncpy(cProcen, &pMensaje[51], 7) ;

      iComp1  = strncmp(cProcen,"DATANET",7) ;

      iComp5  = strncmp(cProcen,"CERRAR ",7) ;

      if (iComp1!=0 && iComp5!=0)

          nResul = -1 ;

      if (iComp1==0)

          nResul = 1 ;

      if (iComp5==0)

          nResul = 5 ;

      return nResul ;

}

/*-------------------------------------------------------------*\

 | Nombre......: int GetProcedenciav2( char * cMensaje )       |

 | Tipo........: int                                           |

 | Autor.......: Golen Von Miller                                 |

 | Fecha.......: 03-04-2025                                    |

 | ............:                                               |

 | Descripcion.: SELECCION DEL SHELL A EJECUTAR DE ACUERDO A   |

 | ............: PROCEDENCIA DEL MENSAJE QUE PUEDE SER:        |

 | ............: "DATANET"                                     |

\*-------------------------------------------------------------*/

int GetProcedenciav2( char * cMensaje ) {

      char ccCoaTrf[8] = {0x00};

      int iComp1       = 0 ;

      char csData[245] ={0x00};

      int nResul       = -1 ;

      memset(csData,'\0', sizeof(csData));

      memset(ccCoaTrf,'\0', sizeof(ccCoaTrf));

      strcat(csData, cMensaje);

      getSubString(csData, ccCoaTrf, 51, 7);

      /*

        printf("In getSubString [%s]\n", ccCoaTrf );

       */

      iComp1  = strcmp(ccCoaTrf,"DATANET") ;

      if ( iComp1==0)

           nResul = 1 ;

      else

           nResul = -1 ;

      return nResul ;

}

/*-------------------------------------------------------------*\

 | Nombre......: GetNameDatanetLog()                           |

 | Tipo........: void                                          |

 | Autor.......: Golen Von Miller                                 |

 | Fecha.......: 05-05-2009                                    |

 | ............:                                               |

 | Descripcion.: Genera el Nombre del Archivo LOG donde grabara|

 |               el Mensaje que llega por Socket               |

\*-------------------------------------------------------------*/

void GetNameDatanetLog(char * ccDataLog) {

      /* memset(ccDataLog, '\0', sizeof(ccDataLog));   */

      memset(ccDataLog, '\0', LMAX_FILE);

      memcpy(ccDataLog, getenv("A2_IMP"), LMAX_FILE );

      /*  printf("ccDataLog es : %s\n ", ccDataLog );   */

      strcat(ccDataLog, "/GLVER34.DATANET.log" );

      /*  printf("ccDataLog es : %s\n ", ccDataLog );  */

      return;

}

/*-------------------------------------------------------------*\

 | Nombre......: GetNameDatanetResp()                          |

 | Tipo........: void                                          |

 | Autor.......: Golen Von Miller                                 |

 | Fecha.......: 05-05-2009                                    |

 | ............:                                               |

 | Descripcion.: Genera el Nombre del Archivo donde Leera la   |

 |               PRESPUESTA del Programa Cobol que Ejecuta el  |

 |               Mensaje para DATANET                          |

\*-------------------------------------------------------------*/

void GetNameDatanetResp(char * ccDataResp) {

      /*  memset(ccDataResp, '\0', sizeof(ccDataResp));   */

      memset(ccDataResp, '\0', LMAX_FILE);

      memcpy(ccDataResp, getenv("A2_IMP"), LMAX_FILE );

      strcat(ccDataResp, "/GLVER34.XM001.sysout" );

      return;

}

/*-------------------------------------------------------------*\

 | Nombre......: GetNameJyam11Log()                            |

 | Tipo........: void                                          |

 | Autor.......: Golen Von Miller                                 |

 | Fecha.......: 08-12-2022                                    |

 | ............:                                               |

 | Descripcion.: Genera el Nombre del Archivo LOG donde grabara|

 |               el Mensaje que genero una respuest 120        |

\*-------------------------------------------------------------*/

void GetNameJyam11Log(char * ccJyam11Log) {

      memset(ccJyam11Log, '\0', LMAX_FILE);

      memcpy(ccJyam11Log, getenv("A2_IMP"), LMAX_FILE );

      strcat(ccJyam11Log, "/GLVER34.SOLO120.log" );

      return;

}

/*-------------------------------------------------------------*\

 | Nombre......: GetRespuestaDatanet()                         |

 | Tipo........: void                                          |

 | Autor.......: Golen Von Miller                                 |

 | Fecha.......: 05-05-2009                                    |

 | ............:                                               |

 | Descripcion.: Lee la Respuesta de DATANET                   |

\*-------------------------------------------------------------*/