convapi.c

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

 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();
}


	trim(jsfs);
	tmp_jsfs=jsfs[0];


/*** this is the clause to insert into temp table t_tempysflag ***/
	/* EXEC SQL SELECT COUNT(*) INTO :avoid_repeat FROM t_tempysflag WHERE jsxh=:Match_key AND sjbh=:sjbh; */ 

{
 struct sqlexd sqlstm;

 sqlstm.sqlvsn = 8;
 sqlstm.arrsiz = 15;
 sqlstm.stmt = "select count(*)  into :b0  from t_tempysflag where (jsxh=:b1\
 and sjbh=:b2)";
 sqlstm.iters = (unsigned int  )1;
 sqlstm.offset = (unsigned int  )428;
 sqlstm.selerr = (unsigned short)1;
 sqlstm.cud = sqlcud0;
 sqlstm.sqlest = (unsigned char  *)&sqlca;
 sqlstm.sqlety = (unsigned short)0;
 sqlstm.sqhstv[0] = (unsigned char  *)&avoid_repeat;
 sqlstm.sqhstl[0] = (unsigned int  )4;
 sqlstm.sqindv[0] = (         short *)0;
 sqlstm.sqharm[0] = (unsigned int  )0;
 sqlstm.sqhstv[1] = (unsigned char  *)&Match_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 ( avoid_repeat==0 )
		/* EXEC SQL INSERT INTO t_tempysflag VALUES ( :fbkjbh,:tmp_jsfs,:Match_key,:sjbh,sysdate ); */ 

{
  struct sqlexd sqlstm;

  sqlstm.sqlvsn = 8;
  sqlstm.arrsiz = 15;
  sqlstm.stmt = "insert into t_tempysflag values (:b0,:b1,:b2,:b3,sysdate )";
  sqlstm.iters = (unsigned int  )1;
  sqlstm.offset = (unsigned int  )454;
  sqlstm.cud = sqlcud0;
  sqlstm.sqlest = (unsigned char  *)&sqlca;
  sqlstm.sqlety = (unsigned short)0;
  sqlstm.sqhstv[0] = (unsigned char  *)fbkjbh;
  sqlstm.sqhstl[0] = (unsigned int  )3;
  sqlstm.sqindv[0] = (         short *)0;
  sqlstm.sqharm[0] = (unsigned int  )0;
  sqlstm.sqhstv[1] = (unsigned char  *)&tmp_jsfs;
  sqlstm.sqhstl[1] = (unsigned int  )1;
  sqlstm.sqindv[1] = (         short *)0;
  sqlstm.sqharm[1] = (unsigned int  )0;
  sqlstm.sqhstv[2] = (unsigned char  *)&Match_key;
  sqlstm.sqhstl[2] = (unsigned int  )4;
  sqlstm.sqindv[2] = (         short *)0;
  sqlstm.sqharm[2] = (unsigned int  )0;
  sqlstm.sqhstv[3] = (unsigned char  *)sjbh;
  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( (strcmp(jsfs,"0")!=0)&&(strcmp(jsfs,"3")!=0) )
	{
		
/*		UpdateJSRZ_cved(Match_key,sjbh);
*/		return(0);
	}
	message=(char *)malloc((YSSM_LEN+1)*sizeof(char));
	if( message==NULL )
	{
		ProcessError(LOG_ERROR,"PCS_Convert_File: error no space in memory when use function ","CallConvertZDYS");
		return(-1);
	}
	strcpy(tempstr,FBKJ_PATH);
	strcat(tempstr,fbkjbh);
	strcat(tempstr,"/bak/");
	strcpy(file_locat,tempstr);
	switch( temp )
	{
		case ZZ:	strcat(tempstr,"BZZY");
			break;
		case KZZ:	strcat(tempstr,"KZZY");
			break;
		case ZJ:	strcat(tempstr,"BZJY");
			break;
		case KZJ:	strcat(tempstr,"KZJY");
			break;
		default:	ErrorEnded("PCS_Convert_File: error in function CallConvertZDYS yslx is not in zdys");
				return(-1);
	}
	/* get zdys data filename */
/*	tempstring[0]='\0';
	strcat(tempstr,".");
	strcpy(tempstring,ZDSMDB.sjbh);
	trim(tempstring);
	strcat(tempstr,tempstring);
*/	h_zdys=fopen(tempstr,"a");
	if( h_zdys == NULL )
	{
		ProcessError(LOG_ERROR,"PCS_Convert_File: cannot open ",tempstr);
		createdir();
		free(message);
		return(-1);
	}
	fseek(h_zdys,0,SEEK_END);
	tempstr[0]='\0';
	str_givenlen( ZDSMDB.bkdh,6,RIGHT );
	strcpy(message,ZDSMDB.bkdh);
	strcat(message,BsbhFromT);
	strcat(message,ZDSMDB.sjbh);
	itoa(ZDSMDB.qdqa,tempstr,2);
	strcat(message,tempstr);
	strcat(message,"      ");
	strcat(message,ZDSMDB.kq);
	if(dingj_id==-1)
		strcat(message,"      ");
	else
	{
		ftoa(ZDSMDB.dingj,tempstr,2,7);
		str_givenlen(tempstr,6,LEFT);
		strcat(message,tempstr);
	}
	if(dyzs_id==-1)
		strcat(message,"          ");
	else
	{
		itoa(ZDSMDB.dyzs,tempstr,10);
		str_givenlen(tempstr,10,LEFT);
		strcat(message,tempstr);
	}
	if(dyk_id==-1)
		strcat(message,"           ");
	else
	{
		ftoa(ZDSMDB.dyk,tempstr,2,12);
		str_givenlen(tempstr,11,LEFT);
		strcat(message,tempstr);
	}
	tempstr[0]='\0';
	if(lszs_id==-1)
		strcat(message,"          ");
	else
	{
		itoa(ZDSMDB.lszs,tempstr,10);
		str_givenlen(tempstr,10,LEFT);
	
		strcat(message,tempstr);
	}
	tempstr[0]='\0';
	if(lsk_id==-1)
		strcat(message,"           ");
	else
	{
		ftoa(ZDSMDB.lsk,tempstr,2,12);
		str_givenlen(tempstr,11,LEFT);
		strcat(message,tempstr);
	}
	if( ((ZDSMDB.yxnf)%2)==1 )
		strcpy(tempstr,"1");
	else
		strcpy(tempstr,"0");
	strcat(message,tempstr);
	strcat(message,"\n");
	fputs(message,h_zdys);
	free(message);
	fclose(h_zdys);

	strcpy(temp_bkdh,ZDSMDB.bkdh);
	trim(temp_bkdh);
	
	if( temp=='1' || temp=='7' )
	{
		strcpy(tempstring,"ZZ");
		strcat(tempstring,temp_bkdh);
		strcat(tempstring,".");
		strcat(tempstring,ZDSMDB.sjbh);
	}
	else if ( temp=='2' || temp=='8' )
	{
		strcpy(tempstring,"ZJ");
		strcat(tempstring,temp_bkdh);
		strcat(tempstring,".");
		strcat(tempstring,ZDSMDB.sjbh);
	}

	if( temp=='1' )
	{
		strcpy(tempstr,"BZZ");
		YS_SINGAL[0]='1';
	}
	else if( temp=='7' )
	{
		strcpy(tempstr,"KZZ");
		YS_SINGAL[6]='1';
	}
	else if( temp=='2' )
	{
		strcpy(tempstr,"BZJ");
		YS_SINGAL[1]='1';
	}
	else if( temp=='8' )
	{
		strcpy(tempstr,"KZJ");
		YS_SINGAL[7]='1';
	}

	
	messagesj=(char *)malloc(MAX_YSSJ_LEN*sizeof(char));
	if( messagesj==NULL )
	{
		ProcessError(LOG_ERROR,"PCS_Convert_File: no space in memory when use ","CallConvertZDYS");
		return(-1);
	}
	messagesj[0]='\0';
	switch( temp )
	{
		case ZZ:	retcode=ConvertZZYSSJ(tempstring,messagesj,Match_key,ZDSMDB.sjbh,ZDSMDB.yxnf);
			break;
		case KZZ:	retcode=ConvertZZYSSJ(tempstring,messagesj,Match_key,ZDSMDB.sjbh,ZDSMDB.yxnf);
			break;
		case ZJ:	retcode=ConvertZJYSSJ(tempstring,messagesj,Match_key,ZDSMDB.sjbh);
				
			break;
		case KZJ:	retcode=ConvertZJYSSJ(tempstring,messagesj,Match_key,ZDSMDB.sjbh);
				
			break;
		default:	ErrorEnded("PCS_Convert_File: error in function CallConvertZDYS yslx is not in zdys");
				return(-1);
	}

	if( retcode!=0 )
	{
		ProcessError(LOG_ERROR,"PCS_CONVERT_FILE: error when convert yssj! ",END);
		free(messagesj);
		return(-1);
	}
	strcat(file_locat,tempstr);
	h_zdsj=fopen(file_locat,"a");
	if( h_zdsj == NULL )
	{
		ProcessError(LOG_ERROR,"PCS_Convert_File: cannot open ",file_locat);
		
		free(messagesj);
		return(-1);
	}
	fseek(h_zdsj,0,SEEK_END);
	fputs(messagesj,h_zdsj);
	
	
	free(messagesj);
	fclose(h_zdsj);
	UpdateJSRZ_cved(Match_key,sjbh);
	return(0);
}

int qdqbconv(int key,char ch[2])
{
	if(key<0)
	return(-1);
	if(key<10)
	{
		ch[0]=(char) (key+48);
		ch[1]='\0';
		return(0);
	}
	if(key>31)
	return(-1);
	ch[0]=(char)(key+55);
	ch[1]='\0';
}

int ConvertPDYSSJ(char *tempstring,char *messagesj,long int key,char *sjbh)
{
	int num_zjfs,round_count,i;
	char zfjbh[SHORT_LEN];
	char tempstr[MID_LEN];
	
/*	strcpy(messagesj,tempstring);*/
	/* EXEC SQL WHENEVER SQLERROR DO sqlerror(); */ 

	/* EXEC SQL SELECT count(*) INTO :round_count FROM t_jspdyssj 
		 WHERE jsxh=:key and sjbh=:sjbh; */ 

{
 struct sqlexd sqlstm;

 sqlstm.sqlvsn = 8;
 sqlstm.arrsiz = 15;
 sqlstm.stmt = "select count(*)  into :b0  from t_jspdyssj where (jsxh=:b1 a\
nd sjbh=:b2)";
 sqlstm.iters = (unsigned int  )1;
 sqlstm.offset = (unsigned int  )484;
 sqlstm.selerr = (unsigned short)1;
 sqlstm.cud = sqlcud0;
 sqlstm.sqlest = (unsigned char  *)&sqlca;
 sqlstm.sqlety = (unsigned short)0;
 sqlstm.sqhstv[0] = (unsigned char  *)&round_count;
 sqlstm.sqhstl[0] = (unsigned int  )4;
 sqlstm.sqindv[0] = (         short *)0;
 sqlstm.sqharm[0] = (unsigned int  )0;
 sqlstm.sqhstv[1] = (unsigned char  *)&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();
}

 
	/* EXEC SQL DECLARE cur_pdsj CURSOR FOR
		SELECT zjfs,zfjbh FROM t_jspdyssj WHERE jsxh=:key and sjbh=:sjbh; */ 

	/* EXEC SQL OPEN cur_pdsj; */ 

{
 struct sqlexd sqlstm;

 sqlstm.sqlvsn = 8;
 sqlstm.arrsiz = 15;
 sqlstm.stmt = sq0017;
 sqlstm.iters = (unsigned int  )1;
 sqlstm.offset = (unsigned int  )510;
 sqlstm.cud = sqlcud0;
 sqlstm.sqlest = (unsigned char  *)&sqlca;
 sqlstm.sqlety = (unsigned short)0;
 sqlstm.sqhstv[0] = (unsigned char  *)&key;
 sqlstm.sqhstl[0] = (unsigned int  )4;
 sqlstm.sqindv[0] = (         short *)0;
 sqlstm.sqharm[0] = (unsigned int  )0;
 sqlstm.sqhstv[1] = (unsigned char  *)sjbh;
 sqlstm.sqhstl[1] = (unsigned int  )0;
 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();
}


	messagesj[0]='\0';
	
	strcat(messagesj,tempstring);
	strcat(messagesj,"\n");
	for( i=0;i<round_count;i++ )
	{
		/* EXEC SQL FETCH cur_pdsj INTO :num_zjfs,:zfjbh; */ 

{
  struct sqlexd sqlstm;

  sqlstm.sqlvsn = 8;
  sqlstm.arrsiz = 15;
  sqlstm.iters = (unsigned int  )1;
  sqlstm.offset = (unsigned int  )532;
  sqlstm.cud = sqlcud0;
  sqlstm.sqlest = (unsigned char  *)&sqlca;
  sqlstm.sqlety = (unsigned short)0;
  sqlstm.sqhstv[0] = (unsigned char  *)&num_zjfs;
  sqlstm.sqhstl[0] = (unsigned int  )4;
  sqlstm.sqindv[0] = (         short *)0;
  sqlstm.sqharm[0] = (unsigned int  )0;
  sqlstm.sqhstv[1] = (unsigned char  *)zfjbh;
  sqlstm.sqhstl[1] = (unsigned int  )10;
  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 )
		{
			ERROR=0;
			ProcessError(LOG_ERROR,"PCS_CONVERT_FILE: error when get zjfs! ",END);
			/* EXEC SQL CLOSE cur_pdsj; */ 

{
   struct sqlexd sqlstm;

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


			return(-1);
		}
		trim(zfjbh);
/*		strcat(messagesj,zfjbh);
		strcat(messagesj,",");
		itoa(num_zjfs,tempstr,10);
		trim(tempstr);
		strcat(messagesj,tempstr);
		strcat(messagesj,",");
*/
		sprintf(messagesj,"%s%s,%ld,",messagesj,zfjbh,num_zjfs);
	}
	strcat(messagesj,"\n");
	/* EXEC SQL CLOSE cur_pdsj; */ 

{
 struct sqlexd sqlstm;

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