yx1api.c

unix 下用pro*c tuxedo 开发的东西

/* Result Sets Interface */
#ifndef SQL_CRSR
#  define SQL_CRSR
  struct sql_cursor
  {
    unsigned int curocn;
    void *ptr1;
    void *ptr2;
    unsigned long magic;
  };
  typedef struct sql_cursor sql_cursor;
  typedef struct sql_cursor SQL_CURSOR;
#endif /* SQL_CRSR */

/* Thread Safety */
typedef void * sql_context;
typedef void * SQL_CONTEXT;

/* File name & Package Name */
struct sqlcxp
{
  unsigned short fillen;
           char  filnam[10];
};
static struct sqlcxp sqlfpn =
{
    9,
    "yx1api.pc"
};


static unsigned long sqlctx = 41539;


static struct sqlexd {
   unsigned int   sqlvsn;
   unsigned int   arrsiz;
   unsigned int   iters;
   unsigned int   offset;
   unsigned short selerr;
   unsigned short sqlety;
   unsigned int   unused;
            short *cud;
   unsigned char  *sqlest;
            char  *stmt;
   unsigned char  **sqphsv;
   unsigned int   *sqphsl;
            short **sqpind;
   unsigned int   *sqparm;
   unsigned int   **sqparc;
   unsigned char  *sqhstv[4];
   unsigned int   sqhstl[4];
            short *sqindv[4];
   unsigned int   sqharm[4];
   unsigned int   *sqharc[4];
} sqlstm = {8,4};

/* Prototypes */
extern sqlcxt (/*_ void **, unsigned long *,
                   struct sqlexd *, struct sqlcxp * _*/);
extern sqlcx2t(/*_ void **, unsigned long *,
                   struct sqlexd *, struct sqlcxp * _*/);
extern sqlbuft(/*_ void **, char * _*/);
extern sqlgs2t(/*_ void **, char * _*/);
extern sqlorat(/*_ void **, unsigned long *, void * _*/);

/* Forms Interface */
static int IAPSUCC = 0;
static int IAPFAIL = 1403;
static int IAPFTL  = 535;
extern void sqliem(/*_ char *, int * _*/);

typedef struct { unsigned short len; unsigned char arr[1]; } VARCHAR;
typedef struct { unsigned short len; unsigned char arr[1]; } varchar;

/* cud (compilation unit data) array */
static short sqlcud0[] =
{8,4130,
2,0,0,1,0,0,1051,113,0,3,3,0,0,128,1,9,0,0,1,9,0,0,1,9,0,0,1,97,0,0,
32,0,0,2,44,0,3,172,0,3,3,0,1,0,1,97,0,0,1,97,0,0,1,3,0,0,
58,0,0,3,65,0,3,188,0,4,4,0,1,0,1,3,0,0,1,3,0,0,1,97,0,0,1,3,0,0,
88,0,0,4,0,0,32,207,0,0,0,0,1,0,
102,0,0,5,47,0,4,213,0,1,0,0,1,0,2,3,0,0,
120,0,0,6,69,0,3,215,0,3,3,0,1,0,1,3,0,0,1,97,0,0,1,1,0,0,
146,0,0,7,69,0,3,226,0,3,3,0,1,0,1,3,0,0,1,97,0,0,1,1,0,0,
172,0,0,8,42,0,5,242,0,2,2,0,1,0,1,1,0,0,1,3,0,0,
};


#include <stdio.h>
#include <math.h>
#include <stdlib.h>

#include <sqlca.h>
#include <sqlcpr.h>
#include <signal.h>

#include "/usr/bkfx/include/Pcs_Snd_YX1/cmYXStr.h"
#include "/usr/bkfx/include/Pcs_Snd_YX1/cmdef.h"
#include "/usr/bkfx/include/Pcs_Snd_YX1/Pcs_Snd_YX1.h"
#include "/usr/bkfx/include/Pcs_Snd_YX1/yx1api.h"

/*  get filename from input path/filename  */
/*  the target is trim the path from input */

void ProcessError( char *LOG, char *sErrorMessage1, char *sErrorMessage2 )
{
	FILE* hErrorFile;
	char cDateTime[100],tempstr[100];
	int i,j,len,n;
	
	tempstr[0]='\0';
	len=strlen(sErrorMessage1);
	for(i=0;i<=len;i++)
	{
		if(sErrorMessage1[i]=='%')
		{			
			n=i;
			if(len!=i+1)
			{
				for(j=0;j<200&&sErrorMessage1[i+2]!='\0';j++,i++)
				tempstr[j]=sErrorMessage1[i+2];
				tempstr[j]='\0';
			}	
			break;
		}
		if(sErrorMessage1[i]=='\0')
		{
			n=i;
			tempstr[0] = '\0';
			break;
		}
			
	}
	
	
	sErrorMessage1[n]='\0';
	hErrorFile = fopen( ERROR_LOG_FILE, "a" );
	if( hErrorFile == NULL )
	{
		printf( "Critical! Cannot open ERROR_LOG_FILE for append or cannot create!\n");
		return;
	}
	fseek( hErrorFile, 0 ,SEEK_END );
	fputs( "\n",hErrorFile);
	fputs( LOG ,hErrorFile);
	printf("\n%s",LOG);
	fputs( sErrorMessage1,hErrorFile );
	printf("%s",sErrorMessage1);
	fputs( sErrorMessage2,hErrorFile );
	printf("%s",sErrorMessage2);
	fputs( tempstr,hErrorFile );
	printf("%s\n",tempstr);
	fputs( "\n",hErrorFile);
	fclose( hErrorFile );
	sprintf( cDateTime, "date >> %s\n", ERROR_LOG_FILE );
	system( cDateTime );
}

void PutintoF(char *string )
{
	FILE *fp;
	fp=fopen("checkfile.txt","w");
	fputs(string,fp);
	fclose(fp);
}

void trimpath( char *string,char *filename )
{
	int len;
	int i,k;
	filename[0]='\0';
	len=strlen(string);
	for( i=len ; i>=0 ; i-- )
		if( string[i]=='/' )
			break;
	if( i==0 )
		strcpy(filename,string);
	else
	{	
		for( k=0 ; k<len-i ; k++ )
			filename[k]=string[i+k+1];
	}
}

int InitPCSSndYX1()
{
	char dbs11[]="10.5.1.1";
	/* EXEC SQL BEGIN DECLARE SECTION; */ 

	/* VARCHAR username[20]; */ 
struct { unsigned short len; unsigned char arr[20]; } username;

	/* VARCHAR password[20]; */ 
struct { unsigned short len; unsigned char arr[20]; } password;

	/* VARCHAR mn1[20]; */ 
struct { unsigned short len; unsigned char arr[20]; } mn1;

	/* EXEC SQL END DECLARE SECTION; */ 

	
	strcpy(username.arr,"bkdba");
	username.len=strlen(username.arr);
	strcpy(password.arr,"dba");
	password.len=strlen(password.arr);
	strcpy(mn1.arr,"mn1");
	mn1.len=strlen(mn1.arr);
	/* EXEC SQL WHENEVER SQLERROR DO sqlerror(); */ 

	/* EXEC SQL CONNECT :username IDENTIFIED BY :password AT :dbs11 USING :mn1; */ 

{
 struct sqlexd sqlstm;

 sqlstm.sqlvsn = 8;
 sqlstm.arrsiz = 4;
 sqlstm.iters = (unsigned int  )10;
 sqlstm.offset = (unsigned int  )2;
 sqlstm.cud = sqlcud0;
 sqlstm.sqlest = (unsigned char  *)&sqlca;
 sqlstm.sqlety = (unsigned short)0;
 sqlstm.sqhstv[0] = (unsigned char  *)&username;
 sqlstm.sqhstl[0] = (unsigned int  )22;
 sqlstm.sqindv[0] = (         short *)0;
 sqlstm.sqharm[0] = (unsigned int  )0;
 sqlstm.sqhstv[1] = (unsigned char  *)&password;
 sqlstm.sqhstl[1] = (unsigned int  )22;
 sqlstm.sqindv[1] = (         short *)0;
 sqlstm.sqharm[1] = (unsigned int  )0;
 sqlstm.sqhstv[2] = (unsigned char  *)&mn1;
 sqlstm.sqhstl[2] = (unsigned int  )22;
 sqlstm.sqindv[2] = (         short *)0;
 sqlstm.sqharm[2] = (unsigned int  )0;
 sqlstm.sqhstv[3] = (unsigned char  *)dbs11;
 sqlstm.sqhstl[3] = (unsigned int  )0;
 sqlstm.sqindv[3] = (         short *)0;
 sqlstm.sqharm[3] = (unsigned int  )0;
 sqlstm.sqphsv = sqlstm.sqhstv;
 sqlstm.sqphsl = sqlstm.sqhstl;
 sqlstm.sqpind = sqlstm.sqindv;
 sqlstm.sqparm = sqlstm.sqharm;
 sqlstm.sqparc = sqlstm.sqharc;
 sqlcxt((void **)0, &sqlctx, &sqlstm, &sqlfpn);
 if (sqlca.sqlcode < 0) sqlerror();
}


	if ( ERROR==0 )
	{
		return(0);
	}
	else 
	{
		ERROR=0;
		return(-1);
	}
}

int OpenYXFileForRead()
{

    	fp = fopen(FILENAME,"r");
    	if (fp !=  NULL)
       		return(0);
    	else
        	return(-1);
}

long getyxfilelen()
{
    	long filelen;
  
    	fseek(fp,0L,SEEK_END);
    	filelen = ftell(fp);
    	fseek(fp,0L,SEEK_SET);
    	return(filelen);
}

static long count = LEN_YX_REC; 
int ReadYXFileData(char *yx_Data)
{
    	int numread;
    	long int position;
   
    	position = ftell(fp);
    	if ((filelen - position) <= LEN_YX_REC ) 
    	{ 
       		count = filelen - position ;
       		numread = fread(yx_Data,count,1,fp);
		yx_Data[count] = '\0';
		return(1);
    	}
    	else
    	{	
    		numread = fread(yx_Data,LEN_YX_REC,1,fp);
		yx_Data[count] = '\0';
    		return(0);
    	}	
}