msgtrk.cpp

ISO 8583 with c++ for financial transaction standard

//
// IT24 Sistemas S.A.
// Message Tracker Library 
//
//     Libreria de Registracion de Mensajes (genericos y/o ISO-8583), en
// formato ASCII-Text, y una linea por registro, como para poder
// ser importada o vista por otras aplicaciones posteriormente.
//     Opcionalmente, el tracking por dia es en un archivo distinto, bajo el
// nombre formateado con fecha ISO-YYMMDD.
//   Las funciones de I/O son estandard de bajo nivel ANSI C y ANSI UNIX.
//
// Tarea        Fecha           Autor   Observaciones
// (Inicial)    1997.10.01      mdc     Base
// (Inicial)    1997.10.03      mdc     Tracking por dia
// (Inicial)    1997.10.21      mdc     Precondiciones extendidas
// (Inicial)    1997.11.11      mdc     Chequeo de Tracking diario internamente
// (Inicial)    1997.11.14      mdc     Chequeo de Tracking diario externamente
// (Inicial)    1997.11.26      mdc     Variables locales no estaticas
// (Beta)       1998.07.22      mdc     strcpy x lstrcpy
// (Beta)       1998.11.01      mdc     hFile = NULL en constructor
// (Beta)       2002.01.31      mdc     Open() y Close() en cada Write()
// (Beta)       2002.05.09      mdc     Estadisticas, incluye #header con TIMESTAMP por linea.
// (Beta)       2003.07.04      mdc     Cambio de libreria estandar IO.H por STDIO.H
// (Beta)       2004.07.05      mdc     BSD/UNIX para microsegundos (dependencies)
//

// Header propio/local
#include <qusrinc/msgtrk.h>
#include <qusrinc/typedefs.h>

// Headers globales
#include <memory.h>
#include <string.h>
#include <ctype.h>
#include <stdio.h>
#include <stdlib.h>
#include <sys/stat.h>
#include <sys/types.h>
#include <sys/time.h>
#ifdef _WIN32
#include <windows.h>
#endif // WIN32

///////////////////////////////////////////////////////////
// Constructor
EXPORT MessageTracker::MessageTracker(LPCSTR pszFName, BOOL bTrackByDay) 
    { 
    // Asegurar handle de flujo de I/O en NULL    
    hfFile = NULL;
    // Bytes de I/O
    cbReadWrite = 0;
    // Hora de Inicio de Traking a cero
    tTrackStartTime = NULL;
    // Open y close en cada Write?
    bOpenCloseInWrite = TRUE;
    // Apertura opcional
    if(pszFName != NULL) 
        Open(pszFName,bTrackByDay);        
    }

///////////////////////////////////////////////////////////
// Destructor
EXPORT MessageTracker::~MessageTracker(void) 
    { 
    // Cierre
    Close();
    // Bytes de I/O
    cbReadWrite = 0;
    // Hora de Inicio de Traking a cero
    tTrackStartTime = NULL;
    }

///////////////////////////////////////////////////////////
// Apertura 
BOOL EXPORT MessageTracker::Open(LPCSTR pszFName, BOOL bTrackByDay)
    {    
    // Precondicion: Cerrado
    Close();          
    // Precondicion: Nombre parametrizado 
    if(pszFName == NULL) 
        return FALSE;

    // Hora de Inicio/ReInicio actual tomada del Sistema (ANSI Unix)
    tTrackStartTime = time(NULL);

    // Tracking dia a dia?
    if((bByDay = bTrackByDay) == TRUE)
        {                
        // Formatear fecha de hoy al nombre del archivo parametrizado,
        // en formato ISO-YYMMDD
        if(!SetTodayFileName(pszFName, (LPSTR)szFileName))
            return FALSE;            
        }
    else
        {
        // Copia de Nombre parametrizado
        strcpy(szFileName, pszFName);    
        }

    // Error al abrir en modo ASCII-Text compartido?    
    if((hfFile = fopen((LPSTR)szFileName, "atr+" )) == NULL)
        {
        // Intentar crearlo para saber si no existe ya
        if (!Create((LPSTR)szFileName)) return FALSE;
        // Una vez creado, cerrarlo y reabrirlo compartido
        Close();
        // Abrirlo         
        return ((hfFile = fopen((LPSTR)szFileName, "atr+" )) == NULL) 
                 ? FALSE 
                 : TRUE ;
        }
    else 
        {
        // Ok
        return TRUE;
        }
    }

///////////////////////////////////////////////////////////
// Lectura de siguiente registro 
BOOL EXPORT MessageTracker::Read(LPBYTE lpbBuffer, SHORT cbLen,PSHORT pcbCopy)
    {
    // Precondicion: handle valido
    if(NULL == hfFile) 
        return FALSE;    
    // Precondicion: puntero a buffer y longitudes validos
    if(lpbBuffer == NULL || pcbCopy == NULL || cbLen <= 0) 
        return FALSE;

    // Lectura en si misma de 1 registro hasta CarriageReturn+LineFeed,
    // que es el modo ASCII-Text:
    cbReadWrite = fread((LPBYTE)lpbBuffer, cbLen, 1, hfFile);
    // Copia externa de los bytes leidos
    (*pcbCopy) = cbReadWrite ;
    // Retorno incorrecto?
    return ((cbReadWrite != 0) && (cbReadWrite != NULL)) 
            ? TRUE 
            : FALSE;
    }       

///////////////////////////////////////////////////////////     
// Escritura de registro
BOOL EXPORT MessageTracker::Write(LPBYTE lpbBuffer, SHORT cbLen, BOOL bLineEnd)
    {    
    // Buffer local de formateo ASCII-Text (y no estatico)
    char szTrkBuffer[BTRKMESSAGESIZE * 10];
    short cbCommit = 0;
    short cbHdrLen = 0;
    // Agregada en cada linea, el TIMESTAMP para estadisticas posteriores
    // En plataforma WINDOWS, resolucion al milisegundo....
    stSYSTEMTIME stSystemTime;
    // En otras plataformas, resolucion al segundo/nanosegundo
    time_t tTimestamp = time( NULL );
    tm *ptmLocal      = localtime( &tTimestamp );
    ///////////////////////////////////////////////////
    // En otras plataformas, resolucion al segundo/nanosegundo    
    struct timeval  tvTOD = {0,0};
    struct timezone tzTZ  = {0,0};
    int    iReturn = gettimeofday( &tvTOD, &tzTZ );    
    ///////////////////////////////////////////////////
    
    // Precondicion: handle valido y abierto
    if(NULL == hfFile) 
        return FALSE;
    // Precondicion: puntero a buffer y longitudes validos
    if(lpbBuffer == NULL || cbLen <= 0) 
        return FALSE;
    // Precondicion: si es a diario, autochequear fecha de tracking    
    if(bByDay)
        CheckTrackingDay();

    tTimestamp = time( NULL );
    ptmLocal   = localtime( &tTimestamp );
    iReturn    = gettimeofday( &tvTOD, &tzTZ );  // Time Of Day
        
    // Verificar longitud y forzarla si se excede el maximo
    // (menos 2 caracteres=LineFeed+NULL)
    if((cbLen+2) > sizeof szTrkBuffer) 
        cbLen = sizeof(szTrkBuffer)-2; // (menos 2 caracteres=LineFeed+NULL)

    //////////////////////////////////////////////////////////////////////
    // Fecha y Hora de Transmision, formato YY/MM/DD HH:MM:SS 
    // Fecha de Transmision, formato MM/DD/YYYY (XMIT-DATE), ISO-FIELD-07    
    stSystemTime.wYear    = ptmLocal->tm_year + 1900; /* years since 1900 */
    stSystemTime.wMonth   = ptmLocal->tm_mon + 1;     /* months since January - [0;11] */
    stSystemTime.wDay     = ptmLocal->tm_mday;        /* day of the month - [1;31] */
    stSystemTime.wHour    = ptmLocal->tm_hour;        /* hours since midnight - [0;23] */        
    stSystemTime.wMinute  = ptmLocal->tm_min;         /* minutes after the hour - [0;59] */
    stSystemTime.wSecond  = ptmLocal->tm_sec;         /* seconds after the minute - [0;59] */
    stSystemTime.wMilliseconds = 0;                   /* default is zero milliseconds */
#ifdef _WIN32
    GetLocalTime( (SYSTEMTIME *)&stSystemTime );
    tvTOD.tv_sec  = stSystemTime.wSecond ;
    tvTOD.tv_usec = stSystemTime.wMilliseconds;
#endif // _WIN32
    sprintf(szTrkBuffer,"%04i/%02i/%02i %02i:%02i:%02i:%09i |", 
            stSystemTime.wYear,           
            stSystemTime.wMonth,
            stSystemTime.wDay,
            stSystemTime.wHour,
            stSystemTime.wMinute,
            stSystemTime.wSecond,
            tvTOD.tv_usec );
    // Header opcional de estadisticas medira N caracteres.
    cbHdrLen = strlen(szTrkBuffer);
    //////////////////////////////////////////////////////////////////////

    // Debe agregarse un LineFeed al final del buffer, para
    // formatear el Tracker linea a linea, 1 para cada registro.
    // Entonces se copia localmente y se agrega el LineFeed+NULL.