yx1api.pc

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

#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"

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 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()
{
	EXEC SQL BEGIN DECLARE SECTION;
	VARCHAR username[20];
	VARCHAR password[20];
	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;
	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);
    	}	
}


int InsertSndYXDBRec(struct stYXDBRec rec_YX_DB)
{
   	ERROR=0;
    	EXEC SQL WHENEVER SQLERROR DO sqlerror();
    	EXEC SQL INSERT INTO t_fsyxsj VALUES (:rec_YX_DB);
	if( ERROR!=0 )
    	{
    		ERROR=0;
    		return(-1);
    	}

    	return(0);
}


int InsertSndTMPDBRec(long serial_no,int groupid,char *yx_Data)
{
    
   	EXEC SQL WHENEVER SQLERROR DO sqlerror();
      
   	EXEC SQL INSERT INTO t_zcfssj (fsxh,zh,zcfssj,zzh) VALUES
                   (:serial_no,
                    :groupid,
                    :yx_Data,
                    :total_zh);
    	if( ERROR!=0 )
    	{
    		ERROR=0;
    		return(-1);
    	}
    	
   	return(0);
 }    
 void sqlerror()
{
	char tempstring[200];
	char ERR_CODE[10];
	int init_time=0;
	
	ERROR=1;
	EXEC SQL WHENEVER sqlerror continue;
	ProcessError( LOG_ERROR, "PCS_SND_YX1: ",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_SND_YX1: Could not connect to the database, so exit now!",END);
			freect(0);
			exit(0);
		}
		InitPCSSndYX1();
		EXEC SQL ROLLBACK WORK;
		return;
	}
	EXEC SQL ROLLBACK WORK;
	return;
}	


int CreateSndLogAndHZRec(long *serial_no,char *datatype,char *rcv_province_code,char status)
{
	char bz[]="";
    	EXEC SQL SELECT s_fsxh.NEXTVAL INTO :key FROM sys.dual;
    	EXEC SQL WHENEVER SQLERROR DO sqlerror();     /*  SQL error handling */
    	EXEC SQL INSERT INTO t_fsrz(fsxh,sjfl,sjzt,jssj) VALUES (
                          :key,
                          :datatype,
                          :status,
                          SYSDATE);
    	if( ERROR!=0 )
    	{
    		ERROR=0;
    		return(-1);
    	}
    
     	EXEC SQL INSERT INTO t_HZ  (fsxh,sjbh,hzjssj,hzzt,bz,pc) VALUES (
                          :key,
                          :rcv_province_code,
                          SYSDATE,
                          :status,
			  :bz,
			  :YX_PC_INT);
    	*serial_no = key;
    	return(0);
}
                     
            


int UpdateSndLogStatus(long serial_no,char status)
{
   
    	EXEC SQL WHENEVER SQLERROR DO sqlerror();     /*  SQL error handling */
    	EXEC SQL UPDATE t_fsrz  SET sjzt = :status  
                       WHERE fsxh = :serial_no;
    	if( ERROR!=0 )
    	{
    		ERROR=0;
    		return(-1);
    	}
    	return(0);
}