hfcjzc.cpp

170话费催交系统

	//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");*/
	//dxinfo[channel].chdevztmx[0]='\0';
	dxinfo[channel].chdevcjjg[0]='\0';
	teleinfo[channel].num[0]='\0';			//电话号码
	teleinfo[channel].cuijiao[0]='\0';	//催缴金额
	teleinfo[channel].qssj_time[0]='\0';	//催缴起始时间
	teleinfo[channel].zzsj_time[0]='\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;
		}
	}
}

/************************************************************************
*     名称:int Readdata(int channel)
*     功能:从缓冲区读一条数据
************************************************************************/
int Readdata(int channel)
{
	//清空原数据
	teleinfo[channel].hth[0]='\0';
	teleinfo[channel].num[0]='\0';
	teleinfo[channel].cuijiao[0]='\0';
	teleinfo[channel].qfmonth[0]='\0';
	teleinfo[channel].cjcount=0;
	teleinfo[channel].cjmonth[0]='\0';
	teleinfo[channel].cjyin_flag=1;
	teleinfo[channel].append_count=0;
	//写入新数据
	if(appendcounts > 0){
		strcpy(teleinfo[channel].hth,appendcjdata[readappend].hth);
		strcpy(teleinfo[channel].num,appendcjdata[readappend].num);
		strcpy(teleinfo[channel].cuijiao,appendcjdata[readappend].cuijiao);
		strcpy(teleinfo[channel].qfmonth,appendcjdata[readappend].qfmonth);
		teleinfo[channel].cjcount=appendcjdata[readappend].cjcount;
		strcpy(teleinfo[channel].cjmonth,appendcjdata[readappend].cjmonth);
		teleinfo[channel].cjyin_flag=appendcjdata[readappend].cjyin_flag;
		teleinfo[channel].append_count=appendcjdata[readappend].append_count;	//进辅缓冲区的次数
		
		appendcounts--;
		if(readappend>=APPENDDATA_COUNTS-1)
			readappend=0;
		else
			readappend++;

		return(0);
	}

	if(maincounts > 0){
		strcpy(teleinfo[channel].hth,maincjdata[readmain].hth);
		strcpy(teleinfo[channel].num,maincjdata[readmain].num);
		strcpy(teleinfo[channel].cuijiao,maincjdata[readmain].cuijiao);
		strcpy(teleinfo[channel].qfmonth,maincjdata[readmain].qfmonth);
		teleinfo[channel].cjcount=maincjdata[readmain].cjcount;
		strcpy(teleinfo[channel].cjmonth,maincjdata[readmain].cjmonth);
		teleinfo[channel].cjyin_flag=maincjdata[readmain].cjyin_flag;
		teleinfo[channel].append_count=0;				//进辅缓冲区的次数
		
		maincounts--;
		if(readmain>=MAINDATA_COUNTS-1)
			readmain=0;
		else
			readmain++;

		return(0);
	}
	return(-1);
}

/************************************************************************
*     名称:int Writeappdata(int channel)
*     功能:往辅缓冲区写数据
************************************************************************/
int Writeappdata(int channel)
{
	if(teleinfo[channel].append_count>=cjarg.cb_count) {
		return(-1);
	}
	teleinfo[channel].append_count++;
	if(appendcounts < APPENDDATA_COUNTS){
		//先清空缓冲区上一次的数据
		appendcjdata[writeappend].hth[0]='\0';
		appendcjdata[writeappend].num[0]='\0';
		appendcjdata[writeappend].cuijiao[0]='\0';
		appendcjdata[writeappend].qfmonth[0]='\0';
		appendcjdata[writeappend].cjcount=0;
		appendcjdata[writeappend].cjmonth[0]='\0';
		appendcjdata[writeappend].cjyin_flag=1;
		appendcjdata[writeappend].append_count=0;
		//写入新数据
		strcpy(appendcjdata[writeappend].hth,teleinfo[channel].hth);
		strcpy(appendcjdata[writeappend].num,teleinfo[channel].num);
		strcpy(appendcjdata[writeappend].cuijiao,teleinfo[channel].cuijiao);
		strcpy(appendcjdata[writeappend].qfmonth,teleinfo[channel].qfmonth);
		appendcjdata[writeappend].cjcount=teleinfo[channel].cjcount;
		strcpy(appendcjdata[writeappend].cjmonth,teleinfo[channel].cjmonth);
		appendcjdata[writeappend].cjyin_flag=teleinfo[channel].cjyin_flag;
		appendcjdata[writeappend].append_count=teleinfo[channel].append_count;	//进辅缓冲区的次数

		appendcounts++;
		if(writeappend>=APPENDDATA_COUNTS-1)
			writeappend=0;
		else
			writeappend++;