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"

/*  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];
	VARCHAR password[20];
	VARCHAR mn1[20];
	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;
	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()
{
    	EXEC SQL WHENEVER SQLERROR CONTINUE;
 	ProcessError(LOG_ERROR,"PCS_Snd_YX1: ", sqlca.sqlerrm.sqlerrmc);
   	ERROR=1;
    	EXEC SQL ROLLBACK WORK RELEASE;
    	return;
}

int CreateSndLogAndHZRec(long *serial_no,char *datatype,char *rcv_province_code,char status)
{
    	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) VALUES (
                          :key,
                          :rcv_province_code,
                          SYSDATE,
                          :status);
    	*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);
}