📄 trans_ser.ec

📁 C语言写的报文转换程序
💻 EC
字号:
/*
** 功能描述：描述交易报文处理模块
** 开发时间：2006-6-26
** 开发人员：郝宪禄、曾衍涛
** 运行环境：UNIX、ESQL
*/
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <memory.h>
#include <time.h>
EXEC SQL include sqlca;
#define MAX_TRACE_LEN	1024
#define MAX_FIELDS 126;
#define DEBUG

void WriteLog(char *DispStr,char *TraceStr,int len);int get_comm(char *rvcd);
int get_rcvtrcd( char *ogno,char *tran);
int up_pack(char *in_buf,int in_len,char *itid,char *flag);
int dw_pack(char flag,char *itid,char *out_buf,int *out_len);

int shift_data(sUP_DATA *data_from, sDW_DATA *data_to);


EXEC SQL begin declare section;	EXEC SQL include "../include/comm_tb.h";	EXEC SQL include "../include/commcont.h";	EXEC SQL include "../include/rcvtrcd.h";
	EXEC SQL include "../include/up_data.h";
	EXEC SQL include "../include/dw_data.h";	COMM_TB   sCOMM_TB;    COMMCONT  sCOMMCONT;    RCVTRCD   sRCVTRCD;
    UP_DATA  sUP_DATA[MAX_FIELDS];
    DW_DATA  sDW_DATA[MAX_FIELDS];
EXEC SQL end declare section;

/*
** 函数功能:转换包文主函数
** 输入参数:
**		tag_flag	:特征码
**		trans_id	:交易码
**		up_buff		:上传报文
** 输出参数:
**		dw_buff		:下传报文
**		dw_len		:下传报文长度
** 程 序 员:郝宪禄-hxl
** 开发日期:2006-06-26
*/
int trans_ser(char *tag_flag,char *trans_id,char *up_buff,char *dw_buff,int *dw_len)
{

	EXEC SQL database dbfront;
	
	WriteLog("上传报文",up_buff,up_len);
	
	memset((char *)&sCOMM_TB,0x00,sizeof(sCOMM_TB));
	memset((char *)&sCOMMCONT,0x00,sizeof(sCOMMCONT));	memset((char *)&sRCVTRCD,0x00,sizeof(sRCVTRCD));	memset((char *)&sUP_DATA[MAX_FIELDS],0x00,sizeof(sUP_DATA)[MAX_FIELDS]);
	memset((char *)&sDW_DATA[MAX_FIELDS],0x00,sizeof(sDW_DATA)[MAX_FIELDS]);	
	/*获取COMM_TB结构体内容*/
	if (get_comm(tag_flag)!= 0)
	{
#ifdef DEBUG
		WriteLog("验证来源失败",tag_flag,strlen(tag_flag));
		printf("验证来源失败!!!\n");
#endif	
		goto err_exit;	}
	WriteLog("验证来源成功",tag_flag,strlen(tag_flag));
	WriteLog("单位ID",sCOMM_TB.UPTP,strlen(sCOMM_TB.UPTP));
	
	/*获取RCVTRCD结构体内容*/
	if (get_rcvtrcd(sCOMM_TB.UPTP,trans_id))!= 0)
	{
#ifdef DEBUG
		WriteLog("交易映射失败",trans_id,strlen(trans_id));
		printf("交易映射失败!!!\n");
#endif	
		goto err_exit;	}
	WriteLog("交易映射成功",trans_id,strlen(trans_id));
	
	/*上传报文解报*/	
	if(up_pack(up_buff,up_len,sRCVTRCD.ITID,sCOMM_TB.UPTY)!=0)
	{
#ifdef DEBUG
		WriteLog("分解上传报文失败",sRCVTRCD.ITID,strlen(sRCVTRCD.ITID));
		printf("分解上传报文失败!!!\n");
#endif	
		goto err_exit;
	}
	WriteLog("组建下传报文",ostr,outlen);	
	
	/*下传报文组报*/
	if(dw_pack(sRCVTRCD.ITID,sCOMM_TB.UPTY,ostr,&outlen)!=0)
	{
#ifdef DEBUG
		WriteLog("组建下传报文失败",sRCVTRCD.ITID,strlen(sRCVTRCD.ITID));
		printf("组建下传报文失败!!!\n");
#endif		
		goto err_exit;
	}
	WriteLog("组建下传报文",ostr,outlen);	
	
	/*返回上传报文*/
	*dw_len=outlen;
	memcpy(dw_buff,ostr,dw_len);
	EXEC SQL close database;	return(0);	
	err_exit:
	EXEC SQL close database;	return(-1);
}


/*
** 函数功能:上传报文解析处理
** 输入参数:
**		in_buf 上传报文
**		in_len 上传报文长度
**		itid_str 交易码
**		flag	报文格式
** 输出参数:
**		
** 程 序 员:郝宪禄-hxl
** 开发日期:2006-06-27
*/
int up_pack(char *in_buf,int in_len,char *itid,char *flag)
{
EXEC SQL begin declare section;
	char itid_str[21];
EXEC SQL end declare section;
	int	 ok=0;  

	int fd_num;
	int i;
	int r;
//*********************************
//*********added by Zeng Yantao****
char *buf_index1, *buf_index2;
int len_uptf;
int len_tok=0;
int len_roff;
int i_;
//*********************************
		
	EXEC SQL declare commcont_cur cursor for select * from commcont		where stcd = '0' and itid = itid_str ;	EXEC SQL open commcont_cur;	for(;;)	{		EXEC SQL fetch commcont_cur into :sCOMMCONT;		if(sqlca.sqlcode == 100)			break;		if(sqlca.sqlcode < 0 )		{			goto Error_exit;		}		ok++;
		sUP_DATA[sCOMMCONT.SQNO].FDLI=sCOMMCONT.FDLI;		memcpy(sUP_DATA[sCOMMCONT.SQNO].FDID,sCOMMCONT.FDID,sCOMMCONT.FDLI);		sUP_DATA[sCOMMCONT.SQNO].FDLN=sCOMMCONT.FDLN;			sUP_DATA[sCOMMCONT.SQNO].GTTP=sCOMMCONT.GTTP;			sUP_DATA[sCOMMCONT.SQNO].CVTP=sCOMMCONT.CVTP;	
		fd_num++;	}	EXEC SQL close  commcont_cur;
	
	switch(flag[0])	{
	/*定长解报文处理*/	case '0':
		for(i=1;i<=fd_num;i++) 		{
			if(sUP_DATA[i].FDLN<=0)					goto Error_exit;			memcpy(sUP_DATA[i].FDVL,in_buf+r,sUP_DATA[i].FDLN);				sUP_DATA[i].FDVL[sUP_DATA[i].FDLN]=0x00;
			
			r+=sUP_DATA[i].FDLN;
		}
		break;
	/*分割符解报文处理*/
	case '1':
//*********************************************************
//*************writen by Zeng Yantao***********************
		len_roff=in_len;
		len_uptf=strlen(sCOMM_TB.UPTF);
		for(i_=1;i_<=fd_num;i_++,buf_index1=buf_index2+len_uptf){
/*
  if(sUP_DATA[i_].FDLN<=0)
  goto Error_exit;
*/
		    if( i_==1 )buf_index1 = in_buf;
		    if(buf_index1-in_buf>=in_len)break;
		    if( (buf_index2 = strstr(buf_index1 , sCOMM_TB.UPTF)) == NULL ){
			buf_index2 = buf_index1+len_roff;
		    }
		    len_tok = buf_index2 - buf_index1;
		    memcpy(sUP_DATA[i_].FDVL,buf_index1,len_tok);
		    sUP_DATA[i_].FDVL[len_tok]='\0';
		    len_roff=len_roff-(len_tok+len_uptf);
		    
		}  
//***********************************************************
//***********************************************************
/*		for(i=1;i<=fd_num;i++) 		{
			if(sUP_DATA[i].FDLN<=0)					goto Error_exit;
			/*
			memset(in_buf_td,0x00,sizeof(in_buf_td));
			memccpy(s_tmp,in_buf_ts,'|',strlen(in_buf_ts));
			memcpy(sUP_DATA[i].FDVL,s_tmp,strlen(s_tmp)-1);
			sUP_DATA[i].FDVL[sUP_DATA[i].FDLN]=0x00;
			memcpy(in_buf_td,in_buf_ts+strlen(s_tmp),strlen(in_buf_ts)-strlen(s_tmp));
			memset(in_buf_ts,0x00,sizeof(in_buf_ts));
			memcpy(in_buf_ts,in_buf_td,strlen(in_buf_td));
			*/
			
			sUP_DATA[i].FDVL[sUP_DATA[i].FDLN]=0x00;
		}
*/
//*****************************************************************
		break;
	/*标记解报文处理*/
	case '2':
		/*暂时不考虑*/
		goto err_exit;
		break;
	/*错误报文*/
	default:
		goto err_exit;		break;	} 
	
	return 0;
err_exit:
	return -1;
}
/*
** 函数功能:下传报文组报处理
** 输入参数:
**		itid_str 交易码
**		flag	报文格式
** 输出参数:
**		out_buf 下传报文
**		out_len 下传报文长度
** 程 序 员:郝宪禄-hxl
** 开发日期:2006-06-28
*/
int dw_pack(char *flag,char *itid,char *out_buf,int *out_len)
{
EXEC SQL begin declare section;
	char itid_str[21];
EXEC SQL end declare section;
	int	 ok=0;  

	int fd_num;
	int i;
	int j;
	int r;
	char tmpstr[61];

	memset(itid_str,0x00,sizeof(itid_str));
	memcpy(itid_str,itid,strlen(itid));	
	
	EXEC SQL declare commcont_cur cursor for select * from commcont		where stcd = '0' and itid = itid_str ;	EXEC SQL open commcont_cur;	for(;;)	{		EXEC SQL fetch commcont_cur into :sCOMMCONT;		if(sqlca.sqlcode == 100)			break;		if(sqlca.sqlcode < 0 )		{			goto Error_exit;		}		ok++;		sDW_DATA[sCOMMCONT.SQNO].FDLI=sCOMMCONT.FDLI;		memcpy(sDW_DATA[sCOMMCONT.SQNO].FDID,sCOMMCONT.FDID,sCOMMCONT.FDLI);		memcpy(sDW_DATA[sCOMMCONT.SQNO].FDVL,sCOMMCONT.FDVL, sCOMMCONT.FDLN);	
		sDW_DATA[sCOMMCONT.SQNO].FDLN=sCOMMCONT.FDLN;			sDW_DATA[sCOMMCONT.SQNO].GTTP=sCOMMCONT.GTTP;			sDW_DATA[sCOMMCONT.SQNO].CVTP=sCOMMCONT.CVTP;					fd_num++;	}	EXEC SQL close  commcont_cur;
	
	/*上下报文交易码映射*/
//	memcpy(
	
	/*组报处理*/
	switch(flag[0])	{
	/*定长组报文处理*/	case '0':
		for(i=1;i<fd_num;i++)		{
			for(j=1;j<MAX_FIELDS;j++)
			{				if(strncmp(sDW_DATA[i].FDID,sUP_DATA[j].FDID,sDW_DATA[i].FDLI)==0)				{
					/*memset(tmpstr,0x00,strlen(tmpstr));					域值转换函数
					memcpy(tmpstr,sUP_DATA[j].FDVL, sUP_DATA[j].FDLN);
					*/
					if( shift_data(&sUP_DATA[j], &sDW_DATA[i])!=0)goto err_exit;//writen by Zeng Yantao.					break;					}	
			}
			memcpy(out_buf+r,sDW_DATA[i].FDVL, sDW_DATA1[i].FDLN);	
			r+=sDW_DATA[i].FDLN;		}
		break;
	/*分割符组报文处理*/
	case '1':
		for(i=1;i<fd_num;i++)		{
			for(j=1;j<MAX_FIELDS;j++)
			{				if(strncmp(sDW_DATA[i].FDID,sUP_DATA[j].FDID,sDW_DATA[i].FDLI)==0)				{
					/*memset(tmpstr,0x00,strlen(tmpstr));
					**					**memcpy(tmpstr,sUP_DATA[j].FDVL, strlen(sUP_DATA[j].FDVL));
					**strcat(tmpstr,sCOMM_TB.DWTF);*/
					if( shift_data(&sUP_DATA[j], &sDW_DATA[i])!=0)goto err_exit;//writen by Zeng Yantao.					break;					}	
			}
			strcat(sDW_DATA[i].FDVL,sCOMM_TB.DWTF);
			memcpy(out_buf+r,sDW_DATA[i].FDVL,strlen(sDW_DATA[i].FDVL));
			r+=strlen(sDW_DATA[i].FDVL);		}
		break;
	/*标记组报文处理*/
	case '2':
	
		break;
	/*错误报文*/
	default:
		goto err_exit;		break;	} 
	*out_len = r;
	return 0;
err_exit:
	return -1;
	
}
/*
** 函数功能:交易码映射处理
** 输入参数:
**		ogno_str 单位ID
** 输出参数:
**		获取RCVTRCD结构体内容
** 程 序 员:郝宪禄-hxl
** 开发日期:2006-06-27
*/
int get_rcvtrcd( char *ogno,char *tran){
EXEC SQL begin declare section;
	char ogno_str[5];
	char tran_str[9];
EXEC SQL end declare section;
	int	 ok=0;  

	memset(ogno_str,0x00,5);
	memset(tran_str,0x00,9);
	memcpy(ogno_str,ogno,strlen(ogno));
	memcpy(tran_str,tran,strlen(tran));

	EXEC SQL declare rcvtrcd_cur cursor for select * from rcvtrcd 
		where ogno=ogno_str and uptr=tran_str and stcd = '0';	EXEC SQL open rcvtrcd_cur;	for(;;)	{		EXEC SQL fetch rcvtrcd_cur into :sRCVTRCD;		if(sqlca.sqlcode == 100)			break;		if(sqlca.sqlcode < 0 )		{
#ifdef DEBUG			printf("error code [%d]\n",sqlca.sqlcode);
#endif						goto Error_exit;		}		ok++;		break;	}	if(ok==0)	{
#ifdef DEBUG		printf("无特殊处理\n");
#endif		goto Error_exit;	}	
	EXEC SQL close  rcvtrcd_cur;
	return (0);
	Error_exit:	EXEC SQL close rcvtrcd_cur;	return (-1);}

/*
** 函数功能:判断来源包的标识
** 输入参数:
**		rvcd_str 特征码
** 输出参数:
**		获取COMM_TB结构体内容
** 程 序 员:郝宪禄-hxl
** 开发日期:2006-06-27
*/int get_comm( char *rvcd ){

EXEC SQL begin declare section;
	char rvcd_str[11];
EXEC SQL end declare section;
	int	 ok=0;  

	memset(rvcd_str,0x00,11);
	memcpy(rvcd_str,rvcd,strlen(rvcd));
	
	EXEC SQL declare comm_cur cursor for select * from comm_tb	where rvcd=rvcd_str and stcd = '0' order by cdln desc;	EXEC SQL open comm_cur;	for(;;)	{		EXEC SQL fetch comm_cur into :sCOMM_TB;		if(sqlca.sqlcode == 100)			break;		if(sqlca.sqlcode < 0 )		{
#ifdef DEBUG				printf("error code [%d]\n",sqlca.sqlcode);
#endif						goto Error_exit;		}		ok++;		break;	}	if(ok==0)	{
#ifdef DEBUG		printf("无特殊处理\n");
#endif				goto Error_exit;	}	
	EXEC SQL close  comm_cur;
	return (0);
	Error_exit:	EXEC SQL close comm_cur;	return (-1);}


/*
** 函数功能:转换包文
** 输入参数:
**		DispStr		:提示信息
**		TraceStr	:日志信息
**		len			:日志信息长度
** 输出参数:
**		无
** 程 序 员:郝宪禄-hxl
** 开发日期:2006-06-26
*/void WriteLog(char *DispStr,char *TraceStr,int len){	FILE *fp;	time_t t1;	struct tm *t2;	int D_line,lineOK,i,line;	char TraceFile[20],tmpbuf[81];	t1=time(0);	t2=localtime(&t1);	sprintf(TraceFile,"../Trace%02d%02d.log",t2->tm_mon+1,t2->tm_mday);	fp=fopen(TraceFile,"a+");	if(fp==NULL)		return;	fprintf(fp,"[%04d/%02d/%02d %02d:%02d:%02d] ",t2->tm_year+1900,t2->tm_mon+1,t2->tm_mday,t2->tm_hour,t2->tm_min,t2->tm_sec);	fprintf(fp,"%s len=%d\n",DispStr,len);	fprintf(fp,"01 02 03 04 05 06 07 08-11 12 13 14 15 16 17 18\n");	fprintf(fp,"===============================================================================\n");	fprintf(fp,"[%s]\n",TraceStr);	fprintf(fp,"===============================================================================\n");	fclose(fp);}
💿 文件大小 10 K
👤 上传用户 zjf646
📂 所属分类 Linux/Unix编程
🏷️ 相关标签

#C语言 #转换 #程序
⌨️ 快捷键说明

复制代码 Ctrl + C
搜索代码 Ctrl + F
全屏模式 F11
切换主题 Ctrl + Shift + D
显示快捷键 ?
增大字号 Ctrl + =
减小字号 Ctrl + -