ysapi.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[9];
};
static struct sqlcxp sqlfpn =
{
    8,
    "ysapi.pc"
};


static unsigned long sqlctx = 21059;


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[16];
   unsigned int   sqhstl[16];
            short *sqindv[16];
   unsigned int   sqharm[16];
   unsigned int   *sqharc[16];
} sqlstm = {8,16};

/* 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,31,129,0,0,0,0,1,0,
16,0,0,2,0,0,31,132,0,0,0,0,1,0,
30,0,0,3,52,0,3,153,0,4,4,0,1,0,1,3,0,0,1,1,0,0,1,1,0,0,1,97,0,0,
60,0,0,4,57,0,5,183,0,3,3,0,1,0,1,1,0,0,1,3,0,0,1,97,0,0,
86,0,0,5,0,0,27,291,0,3,3,0,1,0,1,9,0,0,1,9,0,0,1,10,0,0,
112,0,0,6,86,0,3,1283,0,13,13,0,1,0,1,97,0,0,1,97,0,0,1,3,0,0,1,97,0,0,1,4,0,0,
1,3,0,0,1,4,0,0,1,3,0,0,1,4,0,0,1,97,0,0,1,97,0,0,1,3,0,0,1,3,0,0,
178,0,0,7,69,0,3,1344,0,4,4,0,1,0,1,3,0,0,1,97,0,0,1,97,0,0,1,3,0,0,
208,0,0,8,159,0,3,1467,0,14,14,0,1,0,1,97,0,0,1,97,0,0,1,97,0,0,1,3,0,0,1,3,0,
0,1,97,0,0,1,4,0,0,1,3,0,0,1,4,0,0,1,3,0,0,1,4,0,0,1,97,0,0,1,3,0,0,1,3,0,0,
278,0,0,9,101,0,3,1500,0,16,16,0,1,0,1,97,0,0,1,97,0,0,1,97,0,0,1,3,0,0,1,3,0,
0,1,3,0,0,1,3,0,0,1,97,0,0,1,4,0,0,1,3,0,0,1,4,0,0,1,3,0,0,1,4,0,0,1,97,0,0,1,
3,0,0,1,3,0,0,
356,0,0,10,69,0,3,1569,0,4,4,0,1,0,1,3,0,0,1,97,0,0,1,97,0,0,1,3,0,0,
386,0,0,11,34,0,4,1789,0,1,0,0,1,0,2,5,0,0,
404,0,0,12,57,0,4,1795,0,2,1,0,1,0,2,3,0,0,1,97,0,0,
426,0,0,13,72,0,4,1796,0,3,2,0,1,0,2,3,0,0,1,97,0,0,1,3,0,0,
452,0,0,14,74,0,4,1807,0,3,2,0,1,0,2,3,0,0,1,97,0,0,1,3,0,0,
478,0,0,15,72,0,4,1808,0,3,2,0,1,0,2,3,0,0,1,97,0,0,1,3,0,0,
504,0,0,16,74,0,4,1819,0,3,2,0,1,0,2,3,0,0,1,97,0,0,1,3,0,0,
530,0,0,17,72,0,4,1820,0,3,2,0,1,0,2,3,0,0,1,97,0,0,1,3,0,0,
556,0,0,18,57,0,5,1827,0,3,3,0,1,0,1,1,0,0,1,3,0,0,1,97,0,0,
582,0,0,19,57,0,5,1833,0,3,3,0,1,0,1,1,0,0,1,3,0,0,1,97,0,0,
608,0,0,20,0,0,32,1871,0,0,0,0,1,0,
622,0,0,21,34,0,4,1887,0,1,0,0,1,0,2,97,0,0,
640,0,0,22,56,0,4,1894,0,1,0,0,1,0,2,1,0,0,
658,0,0,23,68,0,4,1904,0,3,2,0,1,0,2,3,0,0,1,97,0,0,1,3,0,0,
};


#include <stdio.h>

#include <stdlib.h>

#include <sqlca.h>

#include <time.h>

#include <stddef.h>

#include <fcntl.h>

#include <signal.h>

#include "sqlcpr.h"

#include "/usr/bkfx/include/myapi.h"

#include "/usr/bkfx/include/Pcs_RD_BK_Q_x/Pcs_RD_BK_Q_YS.h"

#include "/usr/bkfx/include/Pcs_RD_BK_Q_x/ysapi.h"



void ProcessError( char *LOG, char *sErrorMessage1, char *sErrorMessage2 )
{
	FILE* hErrorFile;
	char cDateTime[100],tempstr[100];
	int i,j,len,n;
	long filesize;
	char bakfile[100];
	
	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;
		}
			
	}
	
	printf("\n%s",LOG);
	printf("%s",sErrorMessage1);
	printf("%s",sErrorMessage2);
	printf("%s\n",tempstr);

	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 );
	filesize = ftell(hErrorFile);
	if (filesize > 5242880/5)
	{
		fclose(hErrorFile );
		sprintf(bakfile, "mv %s %s.bak", ERROR_LOG_FILE, ERROR_LOG_FILE);
		system(bakfile);
		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);
	fputs( sErrorMessage1,hErrorFile );
	fputs( sErrorMessage2,hErrorFile );
	fputs( tempstr,hErrorFile );
	fputs( "\n",hErrorFile);
	fclose( hErrorFile );

	sprintf( cDateTime, "date >> %s\n", ERROR_LOG_FILE );
	system( cDateTime );
	system( "date");
}

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



void sqlerror()
{
	char tempstring[200];
	char ERR_CODE[10];
	int init_time=0;
	
	ERROR=1;
	/* EXEC SQL WHENEVER sqlerror continue; */ 

	ProcessError( LOG_ERROR, "PCS_RCV_YS: ",sqlca.sqlerrm.sqlerrmc );
	strncpy(ERR_CODE,sqlca.sqlerrm.sqlerrmc,9);
	ERR_CODE[9]='\0';
	if( strcmp(ERR_CODE,"ORA-03127")==0|| strcmp(ERR_CODE,"ORA-03114")==0|| strcmp(ERR_CODE,"ORA-03123")==0|| strcmp(ERR_CODE,"ORA-01034")==0|| strcmp(ERR_CODE,"ORA-01089")==0||strcmp(ERR_CODE,"ORA-01012")==0||strcmp(ERR_CODE,"ORA-01089") ==0||strcmp( ERR_CODE, "ORA-01033") ==0 )
	{
		sleep(INIT_INTERVAL);
		init_time++;
		if (init_time == 6)
		{
			ProcessError(LOG_NORMAL, "PCS_RCV_YS: Could not connect to the database, so exit now!",END);
			freect(0);
			exit(0);
		}
		InitPcsRcvYS();
		/* EXEC SQL ROLLBACK WORK; */ 

{
  struct sqlexd sqlstm;

  sqlstm.sqlvsn = 8;
  sqlstm.arrsiz = 0;
  sqlstm.iters = (unsigned int  )1;
  sqlstm.offset = (unsigned int  )2;
  sqlstm.cud = sqlcud0;
  sqlstm.sqlest = (unsigned char  *)&sqlca;
  sqlstm.sqlety = (unsigned short)0;
  sqlcxt((void **)0, &sqlctx, &sqlstm, &sqlfpn);
}


		return;
	}
	/* EXEC SQL ROLLBACK WORK; */ 

{
 struct sqlexd sqlstm;

 sqlstm.sqlvsn = 8;
 sqlstm.arrsiz = 0;
 sqlstm.iters = (unsigned int  )1;
 sqlstm.offset = (unsigned int  )16;
 sqlstm.cud = sqlcud0;
 sqlstm.sqlest = (unsigned char  *)&sqlca;
 sqlstm.sqlety = (unsigned short)0;
 sqlcxt((void **)0, &sqlctx, &sqlstm, &sqlfpn);
}


	return;
}	


/************** insert a record into the t_jsrz  ****************/

int CreateRecLogRec(char datatype, char *fssbh ,long int lg_Key )

{

	int i;

	char b;

	b='1';

	ERROR=0;

	/* EXEC SQL WHENEVER SQLERROR DO sqlerror(); */ 


	/* EXEC SQL INSERT INTO T_JSRZ VALUES (:lg_Key, :datatype, :b,:fssbh, sysdate ); */ 

{
 struct sqlexd sqlstm;

 sqlstm.sqlvsn = 8;
 sqlstm.arrsiz = 4;
 sqlstm.stmt = "insert into T_JSRZ values (:b0,:b1,:b2,:b3,sysdate )";
 sqlstm.iters = (unsigned int  )1;
 sqlstm.offset = (unsigned int  )30;
 sqlstm.cud = sqlcud0;
 sqlstm.sqlest = (unsigned char  *)&sqlca;
 sqlstm.sqlety = (unsigned short)0;
 sqlstm.sqhstv[0] = (unsigned char  *)&lg_Key;
 sqlstm.sqhstl[0] = (unsigned int  )4;
 sqlstm.sqindv[0] = (         short *)0;
 sqlstm.sqharm[0] = (unsigned int  )0;
 sqlstm.sqhstv[1] = (unsigned char  *)&datatype;
 sqlstm.sqhstl[1] = (unsigned int  )1;
 sqlstm.sqindv[1] = (         short *)0;
 sqlstm.sqharm[1] = (unsigned int  )0;
 sqlstm.sqhstv[2] = (unsigned char  *)&b;
 sqlstm.sqhstl[2] = (unsigned int  )1;
 sqlstm.sqindv[2] = (         short *)0;
 sqlstm.sqharm[2] = (unsigned int  )0;
 sqlstm.sqhstv[3] = (unsigned char  *)fssbh;
 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 )

	{

		ERROR=0;

		return(-1);

	}

	

	return(1);

}



/***  update jsrz  ***/

int UpdateJSRZ_rec( long int lg_key,char *sjbh )

{

	char temp=WAITFORCONVERT;

	/* EXEC SQL WHENEVER SQLERROR DO sqlerror(); */ 


	/* EXEC SQL UPDATE T_JSRZ SET SJZT=:temp WHERE JSXH=:lg_key AND SJBH=:sjbh; */ 

{
 struct sqlexd sqlstm;

 sqlstm.sqlvsn = 8;
 sqlstm.arrsiz = 4;
 sqlstm.stmt = "update T_JSRZ  set SJZT=:b0 where (JSXH=:b1 and SJBH=:b2)";
 sqlstm.iters = (unsigned int  )1;
 sqlstm.offset = (unsigned int  )60;
 sqlstm.cud = sqlcud0;
 sqlstm.sqlest = (unsigned char  *)&sqlca;
 sqlstm.sqlety = (unsigned short)0;
 sqlstm.sqhstv[0] = (unsigned char  *)&temp;
 sqlstm.sqhstl[0] = (unsigned int  )1;
 sqlstm.sqindv[0] = (         short *)0;
 sqlstm.sqharm[0] = (unsigned int  )0;
 sqlstm.sqhstv[1] = (unsigned char  *)&lg_key;
 sqlstm.sqhstl[1] = (unsigned int  )4;
 sqlstm.sqindv[1] = (         short *)0;
 sqlstm.sqharm[1] = (unsigned int  )0;
 sqlstm.sqhstv[2] = (unsigned char  *)sjbh;
 sqlstm.sqhstl[2] = (unsigned int  )0;
 sqlstm.sqindv[2] = (         short *)0;
 sqlstm.sqharm[2] = (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 )

	{

		ERROR=0;

		return(-1);

	}

	return(1);

}



/***delete the ' ' or '\n' of a string at the begin and end***/



void trim(char *CAline)

{

	int i,j;

	char temp_string[100];

	i=strlen(CAline);

	while(i>0)		/*delete the end ' ' or '\n' */

	{

		if(CAline[i-1]==' '||CAline[i-1]=='\n')

			CAline[i-1]='\0';

		else

			break;

		i--;

	}

	i=0;j=0;

	while( CAline[i]!='\0' )	/*delete the head ' ' or '\n' */

	{

		if(CAline[i]==' '||CAline[i]=='\n')

			i++;

		else

		{

			for (j=0;CAline[i]!='\0';i++,j++)

				CAline[j]=CAline[i];

			break;	

		}	

	}

	CAline[j]='\0';

}





/* init the main function such as DB environment */

int InitPcsRcvYS()

{

	/* 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;


	/* EXEC SQL END DECLARE SECTION; */ 


	

	strcpy(username.arr,"pcsdba");

	username.len=strlen(username.arr);

	strcpy(password.arr,"dba");

	password.len=strlen(password.arr);

	

	/* EXEC SQL WHENEVER SQLERROR DO sqlerror(); */ 


	/* EXEC SQL CONNECT :username IDENTIFIED BY :password; */ 

{
 struct sqlexd sqlstm;

 sqlstm.sqlvsn = 8;
 sqlstm.arrsiz = 4;
 sqlstm.iters = (unsigned int  )10;
 sqlstm.offset = (unsigned int  )86;
 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.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);

	}

}





/*	Read a string from Pstring to Cstring 		*/

/*	m,n define the first point and the last point	*/

int myapi_ReadString(char *Pstring,char *Cstring,int m,int n)

{

	int i,j;

	Cstring[0]='\0';	/*First make the target string as a null string*/

	if( (strlen(Pstring)<n) || (m>n) || (m<0) )

	{	

		return(0);/*Some error when use this function */

	}

	for(i=m,j=0;i<=n;i++,j++)

	{