settle.ec

在SCO UNIX制定界面程序 可根据文件配制菜单,而不必修改源程序,非常方便

		where proc_flag='0'
		and sd_bankid=$sys.adm_bank_id
		and sd_hostid=$sys.adm_host_id
		for update of proc_flag;
		
		$open load_settle1;
	}
	
	if ( SQLCODE ) {
		$rollback work;
		daylog ( ERROR , "Unable open load_settle cursor !" );
		return -1;
	}
	
	while (1) {
		if ( head_flag == 0 ) 
			$fetch load_settle0 into $mx_log;
		else
			$fetch load_settle1 into $mx_log;
		
		if ( SQLCODE )
			break;
		
		del_st_space("mx_logtab", &mx_log);

		cnt++;
		
		sprintf ( file_name , "%s/box/mx/R/%11.11s" , getenv("WORKDIR") , mx_log.file_name );
	
		sprintf ( buf , "dbaccess - - 2>/dev/null >/dev/null <<!\ndatabase %s;\nload from \"%s\" insert into cur_settle_ls ;\n!",getenv("DBNAME"), file_name);
		sys_ret = system ( buf);
		if (sys_ret){
			daylog ( ERROR ,\
			"Unable load from %13.13s insert into settle_ls !" ,\
			mx_log.file_name );

			disp_log_day ( DISP_ONLY , ERROR ,\
			"装入%13.13s失败!(联行号=%4.4s-%2.2s)" ,\
			mx_log.file_name , mx_log.sd_bankid, mx_log.sd_hostid);
			continue;
		}
		
		if ( head_flag == 0 ) {
			$update mx_logtab set proc_flag='1'
			where current of load_settle0;
		}
		else {
			$update mx_logtab set proc_flag='1'
			where current of load_settle1;
		}
		
		if ( SQLCODE ) {
			daylog ( ERROR , \
			"Unable update mx_logtab's proc_flag to '1' ( file_name = %s ) !" , mx_log.file_name );

			disp_log_day ( DISP_ONLY, ERROR , "装入%13.13s失败!(联行号=%4.4s-%2.2s)" , \
			mx_log.file_name , mx_log.sd_bankid, mx_log.sd_hostid);
			continue;
		}

		disp_log_day ( DISP_ONLY , DEBUG, "装入%13.13s成功!(联行号=%4.4s-%2.2s)" ,\
		mx_log.file_name , mx_log.sd_bankid, mx_log.sd_hostid);
	}
	
	if ( head_flag == 0 ) 
		$close load_settle0;
	else
		$close load_settle1;
	
	disp_log_day ( DISP_ONLY, DEBUG, "共装入%d个交易明细!" , cnt );

	$commit work;

	$delete from mx_logtab 
	where proc_flag='1';
	
	if ( SQLCODE ) {
		daylog ( ERROR, "Unable delete mx_logtab!" );
	}
	
	return 0;
}

/*
 * 下传清算文件
 */
/* send the reconciliation file to the branch */

int down_settle_file ()
{
$char datebuf[12];
$char ipaddr[21];
$char head[12]; 
$char file_name[200],tmpfile[50];
$char file_name2[200];
$ S_bank_base bank_base;
$ S_sys_param sys;
char buf[1024];
time_t t;
struct tm *tm;

	$select * into $sys from sys_param;

	if ( SQLCODE ) {
		daylog ( ERROR , "Select sys_param table error !");
		return -1;
	}
	
	del_st_space("sys_param", &sys);

	time ( &t );
	tm = localtime ( &t );

	$declare downcur cursor for 
	select bank_id, host_id from bank_info x
	where (adm_bank_id != bank_id)
	and   adm_bank_id = $sys.bank_id and adm_host_id = $sys.host_id
	and exists (
		select bank_id, host_id from bank_info
		where ( (bank_id = x.bank_id and host_id = x.host_id) or
			bank_id in ( select bank_id from bank_info
				    where adm_bank_id = x.bank_id ))
		and   ( bank_id in ( select bank_id from bank_base
				    where settle_flag = '1' ))
	);
	if ( SQLCODE ) {
		daylog ( ERROR ,"Unable declare  downcur!" );
		return (-1) ;
	}

	$open downcur;
	if ( SQLCODE ) {
		daylog ( ERROR ,"Unable open downcur !" );
		return (-1);
	}
	
	while (1) {
		$fetch downcur into $bank_base.bank_id, $bank_base.host_id;
		if ( SQLCODE && SQLCODE != 100 ) {
			daylog ( ERROR ,"Unable fetch downcur !" );
			$close downcur;
			return (-1) ;
		} else if ( SQLCODE == 100 ){
			$close downcur;
			return (0);
		}
		DelSpace(bank_base.bank_id);
		DelSpace(bank_base.host_id);
		
		sprintf ( file_name , "%s/box/mx/S/%11.11s.%02d%02d%02d" , \
		getenv("WORKDIR"), bank_base.bank_id, tm->tm_year , tm->tm_mon+1 , \
		tm->tm_mday );

		sprintf ( file_name2 , "%s/box/mx/R/%4.4s.%02d%02d%02d" , \
		getenv("WORKDIR"), sys.bank_id , tm->tm_year , tm->tm_mon+1 , \
		tm->tm_mday );

		sprintf(buf, "dbaccess - - 2>/dev/null >/dev/null <<!\ndatabase %s;\nunload to '%s' select * from cur_settle_ls where card_type='%s' and (iss_bank_id='%s' or iss_bank_id in (select bank_id from bank_info where adm_bank_id='%s')) and (iss_bank_id in (select bank_id from bank_base where settle_flag='1')) and tran_type not in (%d, %d) and saf_flag='0' and tran_flag='0';\n!", getenv("DBNAME"), file_name, CREDIT_CARD, bank_base.bank_id, bank_base.bank_id, POS_VOID, PRE_AUTH);

		system ( buf);

		$select settle_ip_addr into $ipaddr from bank_base 
		where bank_id=$bank_base.bank_id
		and   host_id=$bank_base.host_id;
		DelSpace(ipaddr);

		if ( mail(sys.bank_id, bank_base.bank_id, ipaddr, 
			    MX_RECV_PORT , file_name , "c",file_name2 )) {
			disp_log_day ( DISP_ONLY, ERROR , "下传%s联行失败!" , bank_base.bank_id );
			$close downcur;
			daylog ( ERROR , "Unable mail %s to %s!",sys.bank_id,bank_base.bank_id);
			return ( -1 );
		}
		
		disp_log_day ( DISP_ONLY, DEBUG, "下传%s联行成功!" , bank_base.bank_id );
	}
}

/*
 * 转入历史流水
 */
int day_end()
{
	char filename[128], screen[128];
	$char s_date[15], e_date[15];
	int ret;

	sprintf(screen, "/tmp/.day_end.%d", getpid());
	scr_dump(screen);
	disp_below("转入历史流水");
	clear_wline(stdscr, LINES-1);
	my_win = newwin(18, 80, 3, 0);
	mvwprintw(my_win, 0, 0, "━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━");
	wrefresh(my_win);
	line = COL_LEE;

	getdatef(s_date, "");
	dateadd(s_date, -1, s_date);
	mvwprintw(my_win, 2, 4, "请输入起始清算日期: [%s]", s_date);
	ret = in_item(my_win, "", 2, 25, s_date, 8, NULL, NULL, 0, 0);
	if (ret != ENTER) {
		delwin(my_win);
		scr_restore(screen);
		unlink(screen);
		return(-1);
	}
	
	strcpy(e_date, s_date);

	//mvwprintw(my_win, 2, 41, "请输入结束清算日期: [%s]", e_date);
	//ret = in_item(my_win, "", 2, 62, e_date, 8, NULL, NULL, 0, 0);
	mvwprintw(my_win, 3, 4, "请输入结束清算日期: [%s]", e_date);
	ret = in_item(my_win, "", 3, 25, e_date, 8, NULL, NULL, 0, 0);
	if (ret != ENTER) {
		delwin(my_win);
		scr_restore(screen);
		unlink(screen);
		return(-1);
	}

#ifdef wyz_mod_011229
#else
	if (strcmp(s_date, e_date) >0 ){
		line = PGS_LEE;
		disp_log_day(DISP_LOG, ERROR,
		"起始日期大于结束日期, 操作失败, 按任意键继续");
		getch();
		delwin(my_win);
		scr_restore(screen);
		unlink(screen);
		return(-1);
	}
#endif

	line = line+3;
	disp_log_day(DISP_LOG, DEBUG, "警告: 转入历史流水后将无法处理当日报表!  请确认已进行过日终报表处理!");
	line++;
	if (yorn(my_win, line, "    是否继续?", "1.是", "0.否", 1, 0)) {
		delwin(my_win);
		scr_restore(screen);
		unlink(screen);
		return(0);
	}

	disp_log_day(DISP_LOG, DEBUG, "警告: 转入历史流水后将无法传送当日清算文件! 请确认已进行过清算文件传送!");
	line++;
	if (yorn(my_win, line, "    是否继续?", "1.是", "0.否", 1, 0)) {
		delwin(my_win);
		scr_restore(screen);
		unlink(screen);
		return(0);
	}

	disp_log_day(DISP_LOG, DEBUG, "转入历史流水, 请稍候 ...");

	EXEC SQL INSERT INTO his_settle_ls
		SELECT * FROM cur_settle_ls
		WHERE snd_settle_date >= $s_date
		AND snd_settle_date <= $e_date
		AND edc_err_flag = '0';

	if (SQLCODE) {
		line = PGS_LEE;
		disp_log_day(DISP_LOG, ERROR, "备份表 settle_ls 出错, 请立即联系系统管理员! 按任意键继续");
		getch();
		delwin(my_win);
		scr_restore(screen);
		unlink(screen);
		return(0);
	}

	EXEC SQL DELETE FROM cur_settle_ls
		WHERE snd_settle_date >= $s_date
		AND snd_settle_date <= $e_date
		AND edc_err_flag = '0';

	if (SQLCODE) {
		line = PGS_LEE;
		disp_log_day(DISP_LOG, ERROR, "清理表 settle_ls 出错, 请立即联系系统管理员! 按任意键继续");
		getch();
		delwin(my_win);
		scr_restore(screen);
		unlink(screen);
		return(0);
	}

	line = PGS_LEE;
	disp_log_day(DISP_LOG, DEBUG, "转入历史流水成功, 按任意键继续");
	getch();
	delwin(my_win);
	scr_restore(screen);
	unlink(screen);
	return(0);
}







void	copy_file(FILE *source_fp, long loc_s, long loc_e, FILE *target_fp)
{	
	char	buff[256];
	long	loc, len;

	fseek(source_fp, loc_s, SEEK_SET);
	loc = loc_s;
	while((len = loc_e - loc) > 0) {
		if(len > 256) {
			fread(buff, sizeof(buff), 1, source_fp);
			fwrite(buff, sizeof(buff), 1, target_fp);
			loc += 256;
		}
		else {
			fread(buff, len, 1, source_fp); 
			fwrite(buff, len, 1, target_fp);
			loc = loc_e;
		}
	}
}


int	delete_ln(char *buf)
{
    	int i;
    	for(i=strlen(buf); i>=0; i--) {
        	if( buf[i] == '\r') {
	            	buf[i] = 0;
	    		return(delete_ln(buf));
        	}
        	else if( buf[i] == '\n') {
            		buf[i] = 0;
	    		return(delete_ln(buf));
        	}
        	else if( buf[i] == ']') {
            		buf[i] = 0;
	    		return(delete_ln(buf));
        	}
    	}
    	return (0);
}


int 	writetab(Tabname,grp,key,val)
	char 	*Tabname;
	char 	*grp;
	char 	*key;
	char 	*val;
{
	FILE 	*fp, *fp1;
	char 	tmp[81], tmp1[81], tmp2[81], cmd[150], fname1[80], fname2[80];
	long	location1, location2;


    	if( Tabname[0] != '/' )
		sprintf(fname1, "%s/etc/%s", getenv("WORKDIR"), Tabname);
    	else
		sprintf(fname1, "%s", Tabname);
    	fp = fopen(fname1, "r");
    	if(fp == (FILE *)NULL) {
        	daylog(ERROR, "Fopen [%s] Error", fname1);
        	return(-1);
    	}
	sprintf(fname2, "%s.tmp", fname1);
    	fp1 = fopen(fname2, "w");
    	if(fp1 == (FILE *)NULL) {
        	daylog(ERROR, "Fopen [%s] Error", fname2);
		fclose(fp);
        	return(-1);
    	}

    	while(!feof(fp)) {
        	fgets(tmp, 81, fp);
		delete_ln(tmp);
        	if(tmp[0] == '[' && strcmp(tmp+1, grp)==0)
            		break;
    	}
    	if(!feof(fp))
        	while(!feof(fp)) {
			location1 = ftell(fp);
            		fgets(tmp, 81, fp);
            		if(tmp[0] == '#' || tmp[0] == '$' || tmp[0] == '*' 
                    		|| tmp[0] == '\n' || tmp[0] == '\r')
                		continue;
	    		delete_ln(tmp);
            		if(tmp[0] == '[') {
                		fclose(fp);
				fclose(fp1);
                		return(-1);
            		}
            		sscanf(tmp, "%s %s", tmp1, tmp2);
            		if(strcmp(key, tmp1)==0) {
				location2 = ftell(fp);
				copy_file(fp, 0L, location1, fp1); 
				sprintf(tmp, "%s\t%s", key, val);
				fprintf(fp1, "%s\n", tmp);
				location1 = location2;
				fseek(fp, 0L, SEEK_END);
				location2 = ftell(fp);
				copy_file(fp, location1, location2, fp1);
                		fclose(fp);
				fclose(fp1);

				sprintf(cmd, "cp %s %s", fname2, fname1);
				if(system(cmd)) {
					daylog(ERROR, "%s faild!", cmd); 
					unlink(fname2);
					return(-1);
				}
				unlink(fname2);
                		return(0);
            		}
        	}
    	fclose(fp);
    	fclose(fp1);
    	return(-1);
}



int	get_date(char *fname, char *settle_date)
{
	FILE	*fp;
	char	date[20];

	fp = fopen(fname, "r");

	if(fp == NULL) {
		daylog(ERROR, "%s文件不存在", fname);
		return (-1);
	}
	fscanf(fp, "%s", date);
	strncpy(settle_date, date, 8);

	return (0);
}


int 	get_nas_sysparam(S_sys_param *sy)
{
	EXEC SQL BEGIN DECLARE SECTION;

	S_sys_param	sys;

	EXEC SQL END DECLARE SECTION;