datafuncold.h

170话费催交系统

				TRACE("%s: Play ended by TM_MAXTIME",dxinfo[channel].chdevname);
			if(term & TM_EOD)
				TRACE("%s: Play ended by TM_EOD",dxinfo[channel].chdevname);
			//发送屏显
			ChnPrintf(channel+1,"_STATE","写数据库日志");
			dxinfo[channel].chdevzt=CHDEVZT_F;
			GetTime(teleinfo[channel].zzsj_time);
			ChnPrintf(channel+1,"_END",teleinfo[channel].zzsj_time);
			teleinfo[channel].cjcount++;
			datarecord.chdevno = channel;
			pRecordData.SetEvent();
			break;
		case CHDEVZT_G:
			//发送屏显
			ChnPrintf(channel+1,"_STATE","写数据库成功");
			yin_fwaon(channel);
			break;
		case CHDEVZT_F:
			ChnPrintf(channel+1,"_STATE","未写数据库");
			yin_fwaon(channel);
			break;
		case CHDEVZT_H:
			//发送屏显
			ChnPrintf(channel+1,"_STATE","写数据库失败");
			yin_fwaon(channel);
			break;
		}
		break;
	case TDX_PLAYTONE:
		TRACE("--- EVENT DATA: TDX_PLAYTONE");
		// TM_TONE不处理;
		break;
	case TDX_DIAL:
		TRACE("--- EVENT DATA: TDX_DIAL");
		//这里不是通过拨号建立通话方式
		break;
	default:
		TRACE("--- EVENT TYPE AND DATA: %ld UNKNOWN",eventtype);
		//产生了其它的不须处理的事件
		break;
	}  // end switch
	return(0);
}

/*************************************************************************
* Name : end_prog()
* Input: none.
* Des:   This function stops, setonhook and closes all channels
*
**************************************************************************/
int end_prog()
{
	int i;
	unsigned long ta=0L, tm=0L;

	//关闭通道
	for(i=0;i<MAXDEVS;i++){
		dx_stopch(dxinfo[i].chdev,EV_ASYNC);
		yin_fwaon(i);
		dx_close(dxinfo[i].chdev);
		dt_close(dxinfo[i].dtdev);
	}
	//关闭语音文件
	for(i=0;i<=MAXFILES;i++){
		if(dx_fileclose(szfile[i].filehandle)==-1){
			//AfxMessageBox("close file %s error",szfile[filenumber].filename);
		    TRACE("close file error");
		}
	}
	//AfxMessageBox("All channels closed");
	return 0;
}

/*************************************************************************
*			Fuction    : int yin_mfc(int channel) 
*			Description: MultiFrequencyControl Procedure
**************************************************************************/
int yin_mfc(int channel)
{
	int fwsig;

	//FW: 1  6  8  KA 5  0  4  5  3  6  4 SIGI_15 SIGII_3(KD)
	//BW:  A1 A1 A6 A1 A1 A1 A1 A1 A1 A1 A1   A3    B1(KB)
	//Where KA is the calling' s category
	//      DNIS=168, ANI=5045364

	//FW: 1  6  KA 5  0  4  5  3  6  4 SIGI_15 8  SIGII_3(KD)
	//BW:  A1 A6 A1 A1 A1 A1 A1 A1 A1 A1   A1   A3    B1(KB)
	//Where KA is the calling' s category
	//      DNIS=168, ANI=5045364, KD=SIGII_3, Local Call

	if(dxinfo[channel].bksig==SIGA_2) {//send from first digit
		dxinfo[channel].bksig=SIGA_1;
		dxinfo[channel].ani_num=0;
		dxinfo[channel].dnis_num=0;
		dxinfo[channel].Sending=0; //(=0 for DNIS),(=1 for ANI)
	}
	
	switch (dxinfo[channel].bksig){
	case SIGA_1:
		switch (dxinfo[channel].Sending){
		case 0: // Sending DNIS
			if(dxinfo[channel].dnis_num < sizeof(teleinfo[channel].num)) {
				fwsig=(teleinfo[channel].num[dxinfo[channel].dnis_num]=='0')?SIGI_10:(teleinfo[channel].num[dxinfo[channel].dnis_num]-0x31+SIGI_1);
				dxinfo[channel].dnis_num++;
				break;
			} 
			else { // = DNIS_LEN in case that no A6/A3 received
				fwsig=SIGI_1; // KA
				dxinfo[channel].Sending=1;
				break;
			}
			break;
		case 1: // Sending ANI
			/*This line is for special use, dedicate to hangup during MFC
			if((i % 2) && (dev[i].ani_num==2)) {
				yin_fwaon(i);
				return 0;
			}
			*********************************/

			if (dxinfo[channel].ani_num>=ani_len){
				fwsig=SIGI_15;
				dxinfo[channel].Sending=(dxinfo[channel].dnis_num < sizeof(teleinfo[channel].num))?2:3;
				//=2 means sending the left DNIS number
				//=3 means into Group_II, wait for SIGA_3				
				break;
			}
			else {
				fwsig=(Ani[dxinfo[channel].ani_num]=='0')?SIGI_10:(Ani[dxinfo[channel].ani_num]-0x31+SIGI_1);
				dxinfo[channel].ani_num++;
				break;
			}
			break;
		case 2: //Sending the left DNIS number if not complete
			if(dxinfo[channel].dnis_num < sizeof(teleinfo[channel].num)) {
				fwsig=(teleinfo[channel].num[dxinfo[channel].dnis_num]=='0')?SIGI_10:(teleinfo[channel].num[dxinfo[channel].dnis_num]-0x31+SIGI_1);
				dxinfo[channel].dnis_num++;
				break;
			}
			else { // = DNIS_LEN in case that no A6/A3 received
				//in fact this statement should not be run in correct A3 comes
				fwsig=SIGI_1; //send a more digit
				dxinfo[channel].Sending=3;
				break;
			}
			break;
		case 3: // no more digit to send, change to Group_II
		default:
			fwsig=SIGI_1; //send a more digit
			dxinfo[channel].Sending=3;
			break;
		}
		break;

	case SIGA_6:
		fwsig=SIGI_1; //send KA, local call
		dxinfo[channel].Sending=1;
		break;

	case SIGA_3:
		dxinfo[channel].ani_num=ani_len+1;
		dxinfo[channel].dnis_num=strlen(teleinfo[channel].num)+1;
		fwsig=SIGII_3;
		dxinfo[channel].Sending=END_R2MF;
		//end R2MF;
		break;

	case SIGA_4: // Congestion, hangup then
		TRACE("%s: SIGA_4: %s -- Network Congestion",dxinfo[channel].chdevname,teleinfo[channel].num);
		return yin_fwaon(channel);
		break;

	case SIGA_5: // Invalid number, hangup then
		TRACE("%s: SIGA_5: %s -- Invalid Number",dxinfo[channel].chdevname,teleinfo[channel].num);
		return yin_fwaon(channel);
		break;

	default: //hangup then
		// will not arrive here
		return yin_fwaon(channel);
		break;
	}

	TRACE("%s: State %2d, In yin_mfc(), ---- fwsig=%d",
		dxinfo[channel].chdevname,dxinfo[channel].chdevzt,fwsig);
	if(yin_r2_playfsig(channel,fwsig) == -1){
		TRACE("yin_r2_playfsig error");
		return(-1);
	}

	return 0;
}

/*************************************************************************
 *	FUNCTION NAME: int yin_r2_playfsig(int channel, int forwardsig)
 *	DESCRIPTION: to play a forward signal
 *	INPUT: voice device handle, forwardsig, and play mode
 *  RETURN: if in EV_SYNC mode the return the terminate backward ToneID
 *************************************************************************/
int yin_r2_playfsig(int channel, int forwardsig)
{
	int mode=EV_ASYNC;
	int i;
		
	i=forwardsig - SIGI_1;

	if(dx_playtone(dxinfo[channel].chdev,&tngen[i],r2_tpt,mode) == -1){
		TRACE("dx_playtone error");
		return(-1);
	}
	return(0);
}

/***************************************************************************
 *	FUNCTION NAME: playtone_init()
 *	DESCRIPTION: to initialize tonegen and r2_tpt
 *  RETURN: 
 **************************************************************************/
int playtone_init(void)
{
	int i;

	memset(tngen,0,sizeof(tngen));
	for(i=0;i<15;i++)
		dx_bldtngen(&tngen[i],fsig[i][0],fsig[i][1],R2_DEFAMPL,R2_DEFAMPL,200);

	memset(r2_tpt,0,sizeof(r2_tpt));

	r2_tpt[0].tp_type=IO_CONT;
	r2_tpt[0].tp_termno=DX_TONE;
	r2_tpt[0].tp_length=SIGA_1;
	r2_tpt[0].tp_flags=TF_TONE;
	r2_tpt[0].tp_data=DX_TONEON;

	r2_tpt[1].tp_type=IO_CONT;
	r2_tpt[1].tp_termno=DX_TONE;
	r2_tpt[1].tp_length=SIGA_6;
	r2_tpt[1].tp_flags=TF_TONE;
	r2_tpt[1].tp_data=DX_TONEON;

	r2_tpt[2].tp_type=IO_CONT;
	r2_tpt[2].tp_termno=DX_TONE;
	r2_tpt[2].tp_length=SIGA_3;
	r2_tpt[2].tp_flags=TF_TONE;
	r2_tpt[2].tp_data=DX_TONEON;

	r2_tpt[3].tp_type=IO_CONT;
	r2_tpt[3].tp_termno=DX_TONE;
	r2_tpt[3].tp_length=SIGB_1;
	r2_tpt[3].tp_flags=TF_TONE;
	r2_tpt[3].tp_data=DX_TONEON;

	r2_tpt[4].tp_type=IO_EOT;
	r2_tpt[4].tp_termno=DX_MAXTIME;
	r2_tpt[4].tp_length=300;
	r2_tpt[4].tp_flags=TF_10MS;

	return 0;
}

/*************************************************************************
*			Fuction    : int yin_bwboff(int channel)
*			Description: Backword hangup during MFC
**************************************************************************/
int yin_bwboff(int channel)
{
	int retval;

	dx_stopch(dxinfo[channel].chdev,EV_ASYNC);
	//backword signal hangs up first
	//BW:11-->10
	if((retval=dt_settssig(dxinfo[channel].dtdev,DTB_ABIT,DTA_ADDMSK))!=0){
		TRACE("%s: dt_settssig() in yin_bwboff() error",dxinfo[channel].dtdevname);
		return -1;
	}

	return chan_init(channel);
}

/*************************************************************************
*
*			Fuction    : yin_getbksig()
*			Description: Get backward signal
**************************************************************************/
int yin_getbksig(int channel,unsigned long evt_handle)
{
	DX_CST* cstp;

	cstp=(DX_CST*)sr_getevtdatap(evt_handle);
	dxinfo[channel].bksig=cstp->cst_data;

	if(dxinfo[channel].Sending==END_R2MF)
		switch (dxinfo[channel].bksig){
		case SIGB_1://The Called Party is Idle, free
		case SIGB_6://The Called Party is Idle, free
			dxinfo[channel].chdevzt=CHDEVZT_D;
			//ChnPrintf(channel+1,"_STATE","振铃");
			break;
		case SIGB_2://Local Call Busy
		case SIGB_3://Long Distance Call Busy
		case SIGB_4://Congestion
			TRACE("%s: %s -- Line is Busy",dxinfo[channel].chdevname,teleinfo[channel].num);
			ChnPrintf(channel+1,"_STATE","线路忙");
			Writeappdata(channel);
			yin_fwaon(channel);//hangup at this state
			break;
		case SIGB_5://There is no this number
			TRACE("%s: %s -- Invalid Telephone Number",dxinfo[channel].chdevname,teleinfo[channel].num);
			ChnPrintf(channel+1,"_STATE","无此号码");
			yin_fwaon(channel);
			break;
		};
	return 0;
}

/*************************************************************************
*			Fuction    : yin_fwaon()
*			Description: Forward hangup after end of play
**************************************************************************/
int  yin_fwaon(int channel)
{
	if(dt_settssig(dxinfo[channel].dtdev,DTB_ABIT,DTA_ADDMSK)!=0){
		TRACE("%s: dt_settssig() error",dxinfo[channel].dtdevname);
		return -1;
	}
	chan_init(channel);
	return 0;
}

/*************************************************************************
*
*			Fuction    : yin_playf()
*			Description: Set up IOTT and TPT's and Play-Back sample.vox
**************************************************************************/
int yin_playf(int channel)
{
	//play sample.vox file
	dx_clrdigbuf(dxinfo[channel].chdev);

	//add the counter
	telecount.success_count++;
	
    //索引语音串
	Index_sz(channel);
	/* Play VOX File on D/30PCI-E1 Channel, Normal Play Back */
	if (dx_playiottdata(dxinfo[channel].chdev,dxinfo[channel].iott_cjvalue,tptplay,&xpbVox,EV_ASYNC)==-1 ){
		TRACE("%s: %s in dx_playiottdata() error",dxinfo[channel].chdevname,ATDV_ERRMSGP(dxinfo[channel].chdev));
		return -1;
	}
	dxinfo[channel].playflag=1;
	TRACE("%s: %2d, %s -- Playing...",dxinfo[channel].chdevname,channel,teleinfo[channel].num);
	return 0;
}

/************************************************************************
*     名称:int clr_output(int channel)
*     功能:清除某通道屏显的函数
************************************************************************/
int clr_output(int channel)
{
	//清除某通道的屏显
	ChnPrintf(channel+1,"_USER"," ");
	ChnPrintf(channel+1,"_STATE"," ");
	ChnPrintf(channel+1,"_TELE"," ");
	ChnPrintf(channel+1,"_BEGIN","0");
	ChnPrintf(channel+1,"_END","0");
	return(0);
}

/*************************************************************************
*
*			Fuction    : void time_process(void)
*			Description: 超时处理函数
**************************************************************************/
void time_process(void)
{
	int channel;

	if(datajy_counts>=DATAJY_COUNTS) {
		 datajy_counts=0;
		 datacon.chdevno=-1;
		 //校验数据库连接的线程事件
		 JiaoYan.SetEvent();
	}

	for(channel=0;channel<MAXDEVS;channel++) {
		//init_count[channel]++;
		/*if(init_count[channel]>=INIT_COUNT) {
			init_count[channel]=0;
			clr_output(channel);
		}*/
		if(strcmp(signlight[channel].app_id,cjappid)!=0){
			continue;
		}
		if(atoi(signlight[channel].chn_value)==CHDEVIDLE) {
			continue;
		}
		if(dxinfo[channel].playflag==0) {
			dxinfo[channel].chtime++;
		}
		switch(dxinfo[channel].chdevzt){
		case CHDEVZT_A:
			dxinfo[channel].chtime=0;
			break;
		case CHDEVZT_B:
			if(dxinfo[channel].chtime>5){
				dxinfo[channel].chtime=0;
				chan_init(channel);
			}
			break;
		case CHDEVZT_C:
			if(dxinfo[channel].chtime>10){
				dxinfo[channel].chtime=0;
				Writeappdata(channel);
				chan_init(channel);
			}
			break;
		case CHDEVZT_D:
			if(dxinfo[channel].chtime>cjarg.ringtime){ //响铃超过最大秒数
				dxinfo[channel].chtime=0;
				Writeappdata(channel);
				chan_init(channel);
			}
			break;
		case CHDEVZT_E:
			if(dxinfo[channel].chtime>5){
				dxinfo[channel].chtime=0;
				yin_bwboff(channel);
			}
			break;
		case CHDEVZT_F:
			if(dxinfo[channel].chtime>WRITEDATATIME){
				dxinfo[channel].chtime=0;
				chan_init(channel);
			}
			break;
		case CHDEVZT_G:
		case CHDEVZT_H:
			if(dxinfo[channel].chtime>5){
				dxinfo[channel].chtime=0;
				chan_init(channel);
			}
			break;
		}
	}
}

/************************************************************************