datafunc.c

170话费催交系统

					//不做处理
				}
			}
			if(i>=MAXCHAN-1)
				i=0;
			else
				i++;
		}
		idle(0);
	}
	return(0);
}

/************************************************************************
*     名称:BOOL Cmpcjarg(CJ_ARG* lpcjarg)
*     功能:判定是否到了催缴时间
************************************************************************/
BOOL Cmpcjarg(CJ_ARG* lpcjarg)
{
	char ls_time[TIME_LENGTH];
	char* ls_timea;
	char* ls_timeb;
	int li_year;
	int li_month;
	int li_day;
	int li_hour;
	int li_minute;
	int li_second;

	GetTime(ls_time);
	ls_timea=ls_time;
	ls_timeb=ls_timea+4;
	*ls_timeb='\0';
	ls_timeb++;
	li_year=atoi(ls_timea);
	ls_timea=ls_timeb;
	ls_timeb=ls_timea+2;
	*ls_timeb='\0';
	ls_timeb++;
	li_month=atoi(ls_timea);
	ls_timea=ls_timeb;
	ls_timeb=ls_timea+2;
	*ls_timeb='\0';
	ls_timeb++;
	li_day=atoi(ls_timea);
	ls_timea=ls_timeb;
	ls_timeb=ls_timea+2;
	*ls_timeb='\0';
	ls_timeb++;
	li_hour=atoi(ls_timea);
	ls_timea=ls_timeb;
	ls_timeb=ls_timea+2;
	*ls_timeb='\0';
	ls_timeb++;
	li_minute=atoi(ls_timea);
	ls_timea=ls_timeb;
	ls_timeb=ls_timea+2;
	*ls_timeb='\0';
	li_second=atoi(ls_timea);

	if(lpcjarg->cjtime_one == 1) {
		if((li_month>=lpcjarg->cjtime[0].start_month)&&(li_month<=lpcjarg->cjtime[0].end_month)&&
			(li_day>=lpcjarg->cjtime[0].start_day)&&(li_day<=lpcjarg->cjtime[0].end_day)&&
			 (li_hour>=lpcjarg->cjtime[0].start_hour)&&(li_hour<=lpcjarg->cjtime[0].end_hour)&&
			  (li_minute>=lpcjarg->cjtime[0].start_minute)&&(li_minute<=lpcjarg->cjtime[0].end_minute)) {
				return TRUE;
		}
	}
	if(lpcjarg->cjtime_two == 1){
		if((li_month>=lpcjarg->cjtime[1].start_month)&&(li_month<=lpcjarg->cjtime[1].end_month)&&
			(li_day>=lpcjarg->cjtime[1].start_day)&&(li_day<=lpcjarg->cjtime[1].end_day)&&
			 (li_hour>=lpcjarg->cjtime[1].start_hour)&&(li_hour<=lpcjarg->cjtime[1].end_hour)&&
			  (li_minute>=lpcjarg->cjtime[1].start_minute)&&(li_minute<=lpcjarg->cjtime[1].end_minute)) {
				return TRUE;
		}
	}
	if(lpcjarg->cjtime_three == 1){
		if((li_month>=lpcjarg->cjtime[2].start_month)&&(li_month<=lpcjarg->cjtime[2].end_month)&&
			(li_day>=lpcjarg->cjtime[2].start_day)&&(li_day<=lpcjarg->cjtime[2].end_day)&&
			 (li_hour>=lpcjarg->cjtime[2].start_hour)&&(li_hour<=lpcjarg->cjtime[2].end_hour)&&
			  (li_minute>=lpcjarg->cjtime[2].start_minute)&&(li_minute<=lpcjarg->cjtime[2].end_minute)) {
				return TRUE;
		}
	}
	if((lpcjarg->cjtime_one != 1)&&(lpcjarg->cjtime_one != 1)&&(lpcjarg->cjtime_one != 1)) {
		return TRUE;
	}
	return FALSE;
}

/*************************************************************************
 *			Fuction    : int yin_seize(int i)
 *			Description: set abit off (j<MAXCHAN) prepare to dialout
 **************************************************************************/
int yin_seize(int i)
{
	long tsbits;
	int arcv,brcv,crcv,drcv,axmt,bxmt,cxmt,dxmt;
	int chan_ok=0;
	char ls_i[10];

	if((tsbits=ATDT_TSSGBIT(dxinfo[i].dtdev))==AT_FAILURE){
		TRACE("ATDT_TSSGBIT() error");
		return -1;
	}
	arcv=(tsbits & DTSG_RCVA)?1:0;
	brcv=(tsbits & DTSG_RCVB)?1:0;
	crcv=(tsbits & DTSG_RCVC)?1:0;
	drcv=(tsbits & DTSG_RCVD)?1:0;
	axmt=(tsbits & DTSG_XMTA)?1:0;
	bxmt=(tsbits & DTSG_XMTB)?1:0;
	cxmt=(tsbits & DTSG_XMTC)?1:0;
	dxmt=(tsbits & DTSG_XMTD)?1:0;

	chan_ok=(arcv==1)&&(brcv==0)&&(crcv==1)&&(drcv==1);
	if(!chan_ok){
		TRACE("%s: RX(%d%d%d%d) ****** CPE Not Ready ***** %2d",
			dxinfo[i].dtdevname,arcv,brcv,crcv,drcv,i);
		chan_init(i);
		return 0;
	}

	chan_ok=(axmt==1)&&(bxmt==0)&&(cxmt==1)&&(dxmt==1);
	if(!chan_ok){
		TRACE("%s: TX(%d%d%d%d) ****** CO Not Ready ***** %2d",
			dxinfo[i].dtdevname,axmt,bxmt,cxmt,dxmt,i);
		chan_init(i);
		return 0;
	}
	
	if(dt_settssig(dxinfo[i].dtdev,DTB_ABIT,DTA_SUBMSK)!=0){
		TRACE("%s: dt_settssig() error",dxinfo[i].dtdevname);
		return -1;
	}
	dxinfo[i].chdevzt=CHDEVZT_B;
	GetTime(teleinfo[i].qssj_time);
	itoa(i+1,ls_i,10);
	itoa(CHDEVWORK,signlight[i].chn_value,10);
	SetSemaphoneFile(ls_i,chnvalue,signlight[i].chn_value);
	//clr_output(i);
	ChnPrintf(i+1,"_BEGIN",teleinfo[i].qssj_time);
	ChnPrintf(i+1,"_START","摘机");
	init_count[i]=0;
	return 1;
}

/*************************************************************************
 *          Name: int chan_init(int i)
 *      Function: set dti device on hook
 *	    Parameter: channel cur_num
 *  Return value: 0, if successful
 *					 : -1, unsuccessful	 
 *************************************************************************/
int chan_init(int i)
{
	char ls_i[10];
	//int devzt;

	itoa(i+1,ls_i,10);
	dxinfo[i].chdevzt=CHDEVZT_A;
	dxinfo[i].bksig=SIGA_1;
	dxinfo[i].ani_num=0;
	dxinfo[i].dnis_num=0;
	dxinfo[i].Sending=0; //(=0 for DNIS),(=1 for ANI)
	//dxinfo[i].chdialcount=0;
	dt_settssigsim(dxinfo[i].dtdev,DTB_AON|DTB_BOFF|DTB_CON|DTB_DON);
	//devzt=CHDEVIDLE;
	//itoa(devzt,signlight[i].chn_value,10);
	itoa(CHDEVIDLE,signlight[i].chn_value,10);
	SetSemaphoneFile(ls_i,chnvalue,signlight[i].chn_value);
	clr_output(channel);
	ChnPrintf(channel+1,"_START","空闲");
	return 0;
}

/************************************************************************
*     名称:UINT Cjwork(LPVOID pParam)
*     功能:催缴工作线程函数
************************************************************************/
UINT Cjwork(LPVOID pParam)
{
	unsigned long  evt_handle;
	long tmp_dev;
	long eventtype;
	int channel;

	while(1) {
		if(sr_waitevtEx(cjchdev, cjdevcounts, -1, &evt_handle)==-1){
			Sleep(30);
			TRACE("sr_waitevtEx error");
			continue;
		}

		tmp_dev = sr_getevtdev(evt_handle);
		eventtype = sr_getevttype(evt_handle);
		if((tmp_dev==SRL_DEVICE)&&(eventtype==USEREVT_KEYBOARD)){
            //WinPrintf("Stop the dialogic thread");
			break;
		}

		// Get the channel number from which the event was received.
		channel=0;
		while (channel < (cjdevcounts/2)) {
			if(dxinfo[channel].dtdev==tmp_dev) {
				break;
			}
			if(dxinfo[channel].chdev==tmp_dev) {
				break;
			}
			channel++;
		}

		if(Process(channel, evt_handle)!=0)
			break;
	}

    //结束时关闭所有通道
	end_prog();

	return(0);
}

/***************************************************************
 *	名称:int Process(int channel,unsigned long evt_handle)
 *	功能:催缴工作线程中调用到的处理函数
 **************************************************************/
int Process(int channel,unsigned long evt_handle)
{
	long eventtype;
	long *datap;
	DX_CST *cstp;
	long term;

	eventtype = sr_getevttype(evt_handle);
	switch(EventType){
	case DTEV_SIG: //event on DTI
		datap=(long*)sr_getevtdatap(evt_handle);
		if((*datap & DTMM_AON)==DTMM_AON){
			TRACE("%s: --- EVENT DATA: DTMM_AON",dxinfo[channel].dtdevname);
			//处理DTMM_AON事件(挂机，不处理)
		}
		if((*datap & DTMM_AOFF)==DTMM_AOFF){
			TRACE("%s: --- EVENT DATA: DTMM_AOFF",dxinfo[channel].dtdevname);
			//处理DTMM_AOFF事件(远端摘机，放催缴音)
			dxinfo[channel].chdevzt=CHDEVZT_E;
			//发送屏显
			ChnPrintf(channel+1,"_START","用户接听");
			yin_playf(channel);
		}
		if((*datap & DTMM_BON)==DTMM_BON){
			TRACE("%s: --- EVENT DATA: DTMM_BON",dxinfo[channel].dtdevname);
			//处理DTMM_BON事件(交换机应答，发一个playtone)
			dxinfo[channel].chdevzt=CHDEVZT_C;
			//应答前先从缓冲区中读一条数据，
			if(Readdata(channel) == -1){
				return(0);
			}
			//写屏显信息
			ChnPrintf(channel+1,"_START","拨催缴号");
			ChnPrintf(channel+1,"_TELE",teleinfo[channel].num);
			yin_mfc(channel);
		}
		if((*datap & DTMM_BOFF)==DTMM_BOFF){
			TRACE("%s: --- EVENT DATA: DTMM_BOFF",dxinfo[channel].dtdevname);
			//处理DTMM_BOFF事件(远端挂机)
			//播音完成前用户挂机产生此事件时，通道停止播放催缴音
			if(dxinfo[channel].chdevzt==CHDEVZT_E)
				dx_stopch(dxinfo[channel].chdev,EV_ASYNC);
		}
		break;
	case TDX_CST:
		cstp=(DX_CST*)sr_getevtdatap(evt_handle);
		switch (cstp->cst_event){
		case DE_TONEON:
			TRACE("--- EVENT DATA: DE_TONEON");
			//处理 DE_TONEON事件(接收bksig，并处理)
			yin_getbksig(channel,evt_handle);
			break;
		case DE_TONEOFF:
			TRACE("--- EVENT DATA: DE_TONEOFF");
			//处理 DE_TONEOFF事件(接收完成，发送下一个playtone)
			yin_mfc(channel);
			break;
		}
	case TDX_PLAY: /* Play ENDS*/
		switch(dxinfo[channel].chdevzt){
		case CHDEVZT_E:
			dxinfo[channel].playflag=0;
			term=ATDX_TERMMSK(dxinfo[channel].chdev);
			if(term & TM_USRSTOP)
				TRACE("%s: Play ended by TM_USRSTOP",dxinfo[channel].chdevname);
				//break;
			if(term & TM_MAXTIME)
				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);
			dxinfo[channel].cjcount++;
			datawrite.chdevno = channel;
			pUpdateData.SetEvent();
			break;
		case CHDEVZT_G:
			//发送屏显
			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[channel].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){
			//WinPrintf("close file %s error",szfile[filenumber].filename);
		    TRACE("close file error");
		}
	}
	//WinPrintf("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<strlen(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<strlen(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<strlen(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=ain_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