recsysdlg.cpp

百色电信中继电话录音系统,是对于电话会议接入到本中继系统进行电话录音

			m_trunkstatelist.SetItemText(orginfo_queue[wParam].trunkno,4,"");
			m_trunkstatelist.SetItemText(orginfo_queue[wParam].trunkno,5,"");
			TrunkProc_state=PROCSTATE_WARNING;
		}
		break;
	case CHN_IDLE :
		{
			m_trunkstatelist.GetItemText( orginfo_queue[wParam].trunkno, 1, state, 50 );
			m_trunkstatelist.GetItemText( orginfo_queue[wParam].trunkno, 5, state2, 50 );
			if((strcmp(state,"空闲")==0)&&(*state2==0))
				return 0;
			m_trunkstatelist.SetItemText(orginfo_queue[wParam].trunkno,1,"空闲");
			m_trunkstatelist.SetItemText(orginfo_queue[wParam].trunkno,2,"");
			m_trunkstatelist.SetItemText(orginfo_queue[wParam].trunkno,3,"");
			m_trunkstatelist.SetItemText(orginfo_queue[wParam].trunkno,4,"");
			m_trunkstatelist.SetItemText(orginfo_queue[wParam].trunkno,5,"");
			TrunkProc_state=PROCSTATE_WORKING;
		}
		break;
	case SHOW_SYS_MSG :
		{
			ts.Format("%s:%04d-%s",curtime,orginfo_queue[wParam].trunkno,orginfo_queue[wParam].trkerrmsg);
			m_trunkmsglist.InsertString(0,ts);
			WriteLog(ts);
		}
		break;
	case SHOW_ERR_MSG:
		{
			m_trunkstatelist.SetItemText(orginfo_queue[wParam].trunkno,5,orginfo_queue[wParam].trkerrmsg);
		}
		break;
	case IDLE_CALLIN :
		{
			m_trunkstatelist.GetItemText( orginfo_queue[wParam].trunkno, 1, state, 50 );
			if(strcmp(state,"呼入")==0)
				return 0;
			m_trunkstatelist.SetItemText(orginfo_queue[wParam].trunkno,1,"呼入");
			m_trunkstatelist.SetItemText(orginfo_queue[wParam].trunkno,2,"主叫");
			m_trunkstatelist.SetItemText(orginfo_queue[wParam].trunkno,3,orginfo_queue[wParam].caller);
			m_trunkstatelist.SetItemText(orginfo_queue[wParam].trunkno,4,orginfo_queue[wParam].callee);
			m_trunkstatelist.SetItemText(orginfo_queue[wParam].trunkno,5,"");
			TrunkProc_state=PROCSTATE_WORKING;
		}
		break;
	case IDLE_CALLOUT :
		{
			m_trunkstatelist.GetItemText( orginfo_queue[wParam].trunkno, 1, state, 50 );
			if(0==strcmp(state,"呼出"))
				return 0;
			m_trunkstatelist.SetItemText(orginfo_queue[wParam].trunkno,1,"呼出");
			m_trunkstatelist.SetItemText(orginfo_queue[wParam].trunkno,2,"被叫");
			m_trunkstatelist.SetItemText(orginfo_queue[wParam].trunkno,3,orginfo_queue[wParam].caller);
			m_trunkstatelist.SetItemText(orginfo_queue[wParam].trunkno,4,orginfo_queue[wParam].callee);
			m_trunkstatelist.SetItemText(orginfo_queue[wParam].trunkno,5,"");
			TrunkProc_state=PROCSTATE_WORKING;
		}
		break;
	case CHKCHN_DIALING :
		{
			m_trunkstatelist.GetItemText( orginfo_queue[wParam].trunkno, 1, state, 50 );
			if(0==strcmp(state,"正在拨号"))
				return 0;
			m_trunkstatelist.SetItemText(orginfo_queue[wParam].trunkno,1,"正在拨号");
			TrunkProc_state=PROCSTATE_WORKING;
		}
		break;
	case CHKCHN_BUSY :
		{
			m_trunkstatelist.GetItemText( orginfo_queue[wParam].trunkno, 2, state, 50 );
			if(0==strcmp(state,"被叫忙"))
				return 0;
			m_trunkstatelist.SetItemText(orginfo_queue[wParam].trunkno,2,"被叫忙");
			m_trunkstatelist.SetItemText(orginfo_queue[wParam].trunkno,5,"");
			//主被叫原始信息入库
			ts.Format("insert into ORGCALL_INFOMATION values"
				"(%d,'%s','%s','%s','%s','%s','%s','%s','%s',%d,%d)",
				orginfo_queue[wParam].trunkno,orginfo_queue[wParam].caller,orginfo_queue[wParam].callee,
				orginfo_queue[wParam].callin_time,orginfo_queue[wParam].callin_time,orginfo_queue[wParam].answer_time,
				orginfo_queue[wParam].clear_time,"SLB","",orginfo_queue[wParam].groupid,
				orginfo_queue[wParam].calltype);
			sprintf(Sql_Command[m_sqlcompos],"%s",ts);
			SqlProc_pTh->PostThreadMessage(WM_EXESQL,m_sqlcompos,0);
			m_sqlcompos=(m_sqlcompos+1)%SQLPROC_MAXQUEUE;
			//
			//主被叫原始信息入库
			ts.Format("insert into ORGCALL_INFOMATION values"
				"(%d,'%s','%s','%s','%s','%s','%s','%s','%s',%d,%d)",
				orginfo_queue[wParam].opch,orginfo_queue[wParam].caller,orginfo_queue[wParam].callee,
				orginfo_queue[wParam].callin_time,orginfo_queue[wParam].callin_time,orginfo_queue[wParam].answer_time,
				orginfo_queue[wParam].clear_time,"SLB","",orginfo_queue[wParam].groupid,
				orginfo_queue[wParam].calltype);
			sprintf(Sql_Command[m_sqlcompos],"%s",ts);
			SqlProc_pTh->PostThreadMessage(WM_EXESQL,m_sqlcompos,0);
			m_sqlcompos=(m_sqlcompos+1)%SQLPROC_MAXQUEUE;
			TrunkProc_state=PROCSTATE_WORKING;
		}
		break;
	case CHKCHN_ACM :
		{
			m_trunkstatelist.GetItemText( orginfo_queue[wParam].trunkno, 1, state, 50 );
			if(0==strcmp(state,"等应答"))
				return 0;
			m_trunkstatelist.SetItemText(orginfo_queue[wParam].trunkno,1,"等应答");
			if(orginfo_queue[wParam].iscaller==false)
			m_trunkstatelist.SetItemText(orginfo_queue[wParam].trunkno,2,"被叫");
			else
				m_trunkstatelist.SetItemText(orginfo_queue[wParam].trunkno,2,"主叫");
			m_trunkstatelist.SetItemText(orginfo_queue[wParam].trunkno,3,orginfo_queue[wParam].caller);
			m_trunkstatelist.SetItemText(orginfo_queue[wParam].trunkno,4,orginfo_queue[wParam].callee);
			m_trunkstatelist.SetItemText(orginfo_queue[wParam].trunkno,5,"");
			TrunkProc_state=PROCSTATE_WORKING;
		}
		break;
	case CHKCHN_INVIALNO :
		{
			m_trunkstatelist.SetItemText(orginfo_queue[wParam].trunkno,5,"被叫号码不存在");
			//主被叫原始信息入库
			ts.Format("insert into ORGCALL_INFOMATION values"
				"(%d,'%s','%s','%s','%s','%s','%s','%s','%s',%d,%d)",
				orginfo_queue[wParam].trunkno,orginfo_queue[wParam].caller,orginfo_queue[wParam].callee,
				orginfo_queue[wParam].callin_time,orginfo_queue[wParam].callin_time,orginfo_queue[wParam].answer_time,
				orginfo_queue[wParam].clear_time,"UNN","",orginfo_queue[wParam].groupid,
				orginfo_queue[wParam].calltype);
			sprintf(Sql_Command[m_sqlcompos],"%s",ts);
			SqlProc_pTh->PostThreadMessage(WM_EXESQL,m_sqlcompos,0);
			m_sqlcompos=(m_sqlcompos+1)%SQLPROC_MAXQUEUE;
			//主被叫原始信息入库
			ts.Format("insert into ORGCALL_INFOMATION values"
				"(%d,'%s','%s','%s','%s','%s','%s','%s','%s',%d,%d)",
				orginfo_queue[wParam].opch,orginfo_queue[wParam].caller,orginfo_queue[wParam].callee,
				orginfo_queue[wParam].callin_time,orginfo_queue[wParam].callin_time,orginfo_queue[wParam].answer_time,
				orginfo_queue[wParam].clear_time,"UNN","",orginfo_queue[wParam].groupid,
				orginfo_queue[wParam].calltype);
			sprintf(Sql_Command[m_sqlcompos],"%s",ts);
			SqlProc_pTh->PostThreadMessage(WM_EXESQL,m_sqlcompos,0);
			m_sqlcompos=(m_sqlcompos+1)%SQLPROC_MAXQUEUE;
			TrunkProc_state=PROCSTATE_WORKING;
		}
		break;
	case CHKCHN_INHUNGUP :	//主叫在等待过程中挂机
		{
			m_trunkstatelist.SetItemText(orginfo_queue[wParam].trunkno,5,"主叫挂机");
			//主被叫原始信息入库
			ts.Format("insert into ORGCALL_INFOMATION values"
				"(%d,'%s','%s','%s','%s','%s','%s','%s','%s',%d,%d)",
				orginfo_queue[wParam].trunkno,orginfo_queue[wParam].caller,orginfo_queue[wParam].callee,
				orginfo_queue[wParam].callin_time,orginfo_queue[wParam].callin_time,orginfo_queue[wParam].answer_time,
				orginfo_queue[wParam].clear_time,"CLF","",orginfo_queue[wParam].groupid,
				orginfo_queue[wParam].calltype);
			sprintf(Sql_Command[m_sqlcompos],"%s",ts);
			SqlProc_pTh->PostThreadMessage(WM_EXESQL,m_sqlcompos,0);
			m_sqlcompos=(m_sqlcompos+1)%SQLPROC_MAXQUEUE;
			//主被叫原始信息入库
			ts.Format("insert into ORGCALL_INFOMATION values"
				"(%d,'%s','%s','%s','%s','%s','%s','%s','%s',%d,%d)",
				orginfo_queue[wParam].opch,orginfo_queue[wParam].caller,orginfo_queue[wParam].callee,
				orginfo_queue[wParam].callin_time,orginfo_queue[wParam].callin_time,orginfo_queue[wParam].answer_time,
				orginfo_queue[wParam].clear_time,"CLF","",orginfo_queue[wParam].groupid,
				orginfo_queue[wParam].calltype);
			sprintf(Sql_Command[m_sqlcompos],"%s",ts);
			SqlProc_pTh->PostThreadMessage(WM_EXESQL,m_sqlcompos,0);
			m_sqlcompos=(m_sqlcompos+1)%SQLPROC_MAXQUEUE;
			TrunkProc_state=PROCSTATE_WORKING;
		}
		break;
	case CHKCHN_DIALFAILURE :
		{
			m_trunkstatelist.GetItemText( orginfo_queue[wParam].trunkno, 1, state, 50 );
			if(0==strcmp(state,"呼出失败"))
				return 0;
			m_trunkstatelist.SetItemText(orginfo_queue[wParam].trunkno,1,"呼出失败");
			m_trunkstatelist.SetItemText(orginfo_queue[wParam].trunkno,5,orginfo_queue[wParam].release_resean);
			//主被叫原始信息入库
			ts.Format("insert into ORGCALL_INFOMATION values"
				"(%d,'%s','%s','%s','%s','%s','%s','%s','%s',%d,%d)",
				orginfo_queue[wParam].trunkno,orginfo_queue[wParam].caller,orginfo_queue[wParam].callee,
				orginfo_queue[wParam].callin_time,orginfo_queue[wParam].callin_time,orginfo_queue[wParam].answer_time,
				orginfo_queue[wParam].clear_time,"SLB","",orginfo_queue[wParam].groupid,
				orginfo_queue[wParam].calltype);
			sprintf(Sql_Command[m_sqlcompos],"%s",ts);
			SqlProc_pTh->PostThreadMessage(WM_EXESQL,m_sqlcompos,0);
			m_sqlcompos=(m_sqlcompos+1)%SQLPROC_MAXQUEUE;
			//主被叫原始信息入库
			ts.Format("insert into ORGCALL_INFOMATION values"
				"(%d,'%s','%s','%s','%s','%s','%s','%s','%s',%d,%d)",
				orginfo_queue[wParam].opch,orginfo_queue[wParam].caller,orginfo_queue[wParam].callee,
				orginfo_queue[wParam].callin_time,orginfo_queue[wParam].callin_time,orginfo_queue[wParam].answer_time,
				orginfo_queue[wParam].clear_time,"SLB","",orginfo_queue[wParam].groupid,
				orginfo_queue[wParam].calltype);
			sprintf(Sql_Command[m_sqlcompos],"%s",ts);
			SqlProc_pTh->PostThreadMessage(WM_EXESQL,m_sqlcompos,0);
			m_sqlcompos=(m_sqlcompos+1)%SQLPROC_MAXQUEUE;
			TrunkProc_state=PROCSTATE_WORKING;
		}
		break;
	case CHKCHN_REV_OTHMSG :
		{
			m_trunkstatelist.SetItemText(orginfo_queue[wParam].trunkno,5,orginfo_queue[wParam].release_resean);
			//原始信息入库
			ts.Format("insert into ORGCALL_INFOMATION values"
				"(%d,'%s','%s','%s','%s','%s','%s','%s','%s',%d,%d)",
				orginfo_queue[wParam].trunkno,orginfo_queue[wParam].caller,orginfo_queue[wParam].callee,
				orginfo_queue[wParam].callin_time,orginfo_queue[wParam].callin_time,orginfo_queue[wParam].answer_time,
				orginfo_queue[wParam].clear_time,orginfo_queue[wParam].release_resean,
				"",orginfo_queue[wParam].groupid,orginfo_queue[wParam].calltype);
			sprintf(Sql_Command[m_sqlcompos],"%s",ts);
			SqlProc_pTh->PostThreadMessage(WM_EXESQL,m_sqlcompos,0);
			m_sqlcompos=(m_sqlcompos+1)%SQLPROC_MAXQUEUE;
			//主被叫原始信息入库
			ts.Format("insert into ORGCALL_INFOMATION values"
				"(%d,'%s','%s','%s','%s','%s','%s','%s','%s',%d,%d)",
				orginfo_queue[wParam].opch,orginfo_queue[wParam].caller,orginfo_queue[wParam].callee,
				orginfo_queue[wParam].callin_time,orginfo_queue[wParam].callin_time,orginfo_queue[wParam].answer_time,
				orginfo_queue[wParam].clear_time,orginfo_queue[wParam].release_resean,
				"",orginfo_queue[wParam].groupid,orginfo_queue[wParam].calltype);
			sprintf(Sql_Command[m_sqlcompos],"%s",ts);
			SqlProc_pTh->PostThreadMessage(WM_EXESQL,m_sqlcompos,0);
			m_sqlcompos=(m_sqlcompos+1)%SQLPROC_MAXQUEUE;
			TrunkProc_state=PROCSTATE_WORKING;
		}
		break;
	case CHKCHN_NOANSWER :
		{
			m_trunkstatelist.SetItemText(orginfo_queue[wParam].trunkno,5,"无人应答");
			//原始信息入库
			ts.Format("insert into ORGCALL_INFOMATION values"
				"(%d,'%s','%s','%s','%s','%s','%s','%s','%s',%d,%d)",
				orginfo_queue[wParam].trunkno,orginfo_queue[wParam].caller,orginfo_queue[wParam].callee,
				orginfo_queue[wParam].callin_time,orginfo_queue[wParam].callin_time,orginfo_queue[wParam].answer_time,
				orginfo_queue[wParam].clear_time,"SLB","",
				orginfo_queue[wParam].groupid,orginfo_queue[wParam].calltype);
			sprintf(Sql_Command[m_sqlcompos],"%s",ts);
			SqlProc_pTh->PostThreadMessage(WM_EXESQL,m_sqlcompos,0);
			m_sqlcompos=(m_sqlcompos+1)%SQLPROC_MAXQUEUE;
			//主被叫原始信息入库
			ts.Format("insert into ORGCALL_INFOMATION values"
				"(%d,'%s','%s','%s','%s','%s','%s','%s','%s',%d,%d)",
				orginfo_queue[wParam].opch,orginfo_queue[wParam].caller,orginfo_queue[wParam].callee,
				orginfo_queue[wParam].callin_time,orginfo_queue[wParam].callin_time,orginfo_queue[wParam].answer_time,
				orginfo_queue[wParam].clear_time,"SLB","",
				orginfo_queue[wParam].groupid,orginfo_queue[wParam].calltype);
			sprintf(Sql_Command[m_sqlcompos],"%s",ts);
			SqlProc_pTh->PostThreadMessage(WM_EXESQL,m_sqlcompos,0);
			m_sqlcompos=(m_sqlcompos+1)%SQLPROC_MAXQUEUE;
			TrunkProc_state=PROCSTATE_WORKING;
		}
		break;
	case RECORDING_SAY :
		{
			m_trunkstatelist.GetItemText( orginfo_queue[wParam].trunkno, 1, state, 50 );
			if(0==strcmp(state,"通话中"))
				return 0;
			m_trunkstatelist.SetItemText(orginfo_queue[wParam].trunkno,1,"通话中");
			m_trunkstatelist.SetItemText(orginfo_queue[wParam].opch,5,"");
			m_trunkstatelist.GetItemText( orginfo_queue[wParam].opch, 1, state, 50 );
			if(0==strcmp(state,"通话中"))
				return 0;
			m_trunkstatelist.SetItemText(orginfo_queue[wParam].opch,1,"通话中");
			m_trunkstatelist.SetItemText(orginfo_queue[wParam].opch,5,"");
			TrunkProc_state=PROCSTATE_WORKING;
		}
		break;
	case RECORDING_HUNGUP_B :
		{
			m_trunkstatelist.SetItemText(orginfo_queue[wParam].trunkno,5,"被叫挂机");
			//原始信息入库
			ts.Format("insert into ORGCALL_INFOMATION values"
				"(%d,'%s','%s','%s','%s','%s','%s','%s','%s',%d,%d)",
				orginfo_queue[wParam].trunkno,orginfo_queue[wParam].caller,orginfo_queue[wParam].callee,
				orginfo_queue[wParam].callin_time,orginfo_queue[wParam].callin_time,orginfo_queue[wParam].answer_time,
				orginfo_queue[wParam].clear_time,"CBK",
				"",orginfo_queue[wParam].groupid,orginfo_queue[wParam].calltype);
			sprintf(Sql_Command[m_sqlcompos],"%s",ts);
			SqlProc_pTh->PostThreadMessage(WM_EXESQL,m_sqlcompos,0);
			m_sqlcompos=(m_sqlcompos+1)%SQLPROC_MAXQUEUE;
			//主被叫原始信息入库
			ts.Format("insert into ORGCALL_INFOMATION values"
				"(%d,'%s','%s','%s','%s','%s','%s','%s','%s',%d,%d)",
				orginfo_queue[wParam].opch,orginfo_queue[wParam].caller,orginfo_queue[wParam].callee,
				orginfo_queue[wParam].callin_time,orginfo_queue[wParam].callin_time,orginfo_queue[wParam].answer_time,
				orginfo_queue[wParam].clear_time,"CBK",
				orginfo_queue[wParam].rec_filename,orginfo_queue[wParam].groupid,
				orginfo_queue[wParam].calltype);
			sprintf(Sql_Command[m_sqlcompos],"%s",ts);
			SqlProc_pTh->PostThreadMessage(WM_EXESQL,m_sqlcompos,0);
			m_sqlcompos=(m_sqlcompos+1)%SQLPROC_MAXQUEUE;
			//录音信息入库
			ts.Format("insert into REC_INDEX values"
				"(%d,'%s','%s','%s','%s','%s','%s',%d)",
				orginfo_queue[wParam].trunkno,orginfo_queue[wParam].caller,orginfo_queue[wParam].callee,
				orginfo_queue[wParam].callin_time,orginfo_queue[wParam].answer_time,
				orginfo_queue[wParam].clear_time,orginfo_queue[wParam].rec_filename,
				orginfo_queue[wParam].groupid);
			sprintf(Sql_Command[m_sqlcompos],"%s",ts);
			SqlProc_pTh->PostThreadMessage(WM_EXESQL,m_sqlcompos,0);
			m_sqlcompos=(m_sqlcompos+1)%SQLPROC_MAXQUEUE;
			//
			switch(FtpServer_state) {
			case PROCSTATE_WORKING:
				{
					strcpy(ftpinfo[m_ftpinfopos].filename,orginfo_queue[wParam].rec_filename);
					ftpinfo[m_ftpinfopos].groupid=orginfo_queue[wParam].groupid;
					FtpProc_pTh->PostThreadMessage(FTP_WANTE,m_ftpinfopos,0);
					m_ftpinfopos=(m_ftpinfopos+1)%FTPQUEUE_MAX;
				}
				break;
			case PROCSTATE_WARNING	:	
			case PROCSATAE_FAILD	:	
			case PROCSTATE_NOTSTART	:
				{
					ts.Format("insert into FTP_QUEUE values"
						"('%s','%s',%d,0)",curtime,orginfo_queue[wParam].rec_filename
						,orginfo_queue[wParam].groupid);
					sprintf(Sql_Command[m_sqlcompos],"%s",ts);
					SqlProc_pTh->PostThreadMessage(WM_EXESQL,m_sqlcompos,0);
					m_sqlcompos=(m_sqlcompos+1)%SQLPROC_MAXQUEUE;
					ts.Format("%s因FTP服务器失效，文件:%s 暂存本地!",curtime,orginfo_queue[wParam].rec_filename);
					m_trunkmsglist.InsertString(0,ts);
				}
				break;
			default: break;
			}
			TrunkProc_state=PROCSTATE_WORKING;
		}
		break;
	case RECORDING_HUNGUP_NOREC :
		{
			m_trunkstatelist.SetItemText(orginfo_queue[wParam].trunkno,5,"被叫挂机");
			//原始信息入库
			ts.Format("insert into ORGCALL_INFOMATION values"
				"(%d,'%s','%s','%s','%s','%s','%s','%s','%s',%d,%d)",
				orginfo_queue[wParam].trunkno,orginfo_queue[wParam].caller,orginfo_queue[wParam].callee,
				orginfo_queue[wParam].callin_time,orginfo_queue[wParam].callin_time,orginfo_queue[wParam].answer_time,
				orginfo_queue[wParam].clear_time,"CBK",
				"",orginfo_queue[wParam].groupid,orginfo_queue[wParam].calltype);
			sprintf(Sql_Command[m_sqlcompos],"%s",ts);
			SqlProc_pTh->PostThreadMessage(WM_EXESQL,m_sqlcompos,0);
			m_sqlcompos=(m_sqlcompos+1)%SQLPROC_MAXQUEUE;
			//主被叫原始信息入库
			ts.Format("insert into ORGCALL_INFOMATION values"
				"(%d,'%s','%s','%s','%s','%s','%s','%s','%s',%d,%d)",
				orginfo_queue[wParam].opch,orginfo_queue[wParam].caller,orginfo_queue[wParam].callee,
				orginfo_queue[wParam].callin_time,orginfo_queue[wParam].callin_time,orginfo_queue[wParam].answer_time,
				orginfo_queue[wParam].clear_time,"CBK",
				orginfo_queue[wParam].rec_filename,orginfo_queue[wParam].groupid,
				orginfo_queue[wParam].calltype);
			sprintf(Sql_Command[m_sqlcompos],"%s",ts);
			SqlProc_pTh->PostThreadMessage(WM_EXESQL,m_sqlcompos,0);
			m_sqlcompos=(m_sqlcompos+1)%SQLPROC_MAXQUEUE;
			TrunkProc_state=PROCSTATE_WORKING;
		}
		break;
	case RECORDING_HUNGUP_Z :
		{
			m_trunkstatelist.SetItemText(orginfo_queue[wParam].trunkno,5,"主叫挂机");
			//原始信息入库
			ts.Format("insert into ORGCALL_INFOMATION values"
				"(%d,'%s','%s','%s','%s','%s','%s','%s','%s',%d,%d)",
				orginfo_queue[wParam].trunkno,orginfo_queue[wParam].caller,orginfo_queue[wParam].callee,
				orginfo_queue[wParam].callin_time,orginfo_queue[wParam].callin_time,orginfo_queue[wParam].answer_time,
				orginfo_queue[wParam].clear_time,"CLF",
				orginfo_queue[wParam].rec_filename,orginfo_queue[wParam].groupid,orginfo_queue[wParam].calltype);
			sprintf(Sql_Command[m_sqlcompos],"%s",ts);
			SqlProc_pTh->PostThreadMessage(WM_EXESQL,m_sqlcompos,0);
			m_sqlcompos=(m_sqlcompos+1)%SQLPROC_MAXQUEUE;
			//主被叫原始信息入库
			ts.Format("insert into ORGCALL_INFOMATION values"
				"(%d,'%s','%s','%s','%s','%s','%s','%s','%s',%d,%d)",
				orginfo_queue[wParam].opch,orginfo_queue[wParam].caller,orginfo_queue[wParam].callee,
				orginfo_queue[wParam].callin_time,orginfo_queue[wParam].callin_time,orginfo_queue[wParam].answer_time,
				orginfo_queue[wParam].clear_time,"CLF","",orginfo_queue[wParam].groupid,
				orginfo_queue[wParam].calltype);
			sprintf(Sql_Command[m_sqlcompos],"%s",ts);
			SqlProc_pTh->PostThreadMessage(WM_EXESQL,m_sqlcompos,0);
			m_sqlcompos=(m_sqlcompos+1)%SQLPROC_MAXQUEUE;
			//录音信息入库
			ts.Format("insert into REC_INDEX values"
				"(%d,'%s','%s','%s','%s','%s','%s',%d)",
				orginfo_queue[wParam].trunkno,orginfo_queue[wParam].caller,orginfo_queue[wParam].callee,
				orginfo_queue[wParam].callin_time,orginfo_queue[wParam].answer_time,
				orginfo_queue[wParam].clear_time,orginfo_queue[wParam].rec_filename
				,orginfo_queue[wParam].groupid);
			sprintf(Sql_Command[m_sqlcompos],"%s",ts);
			SqlProc_pTh->PostThreadMessage(WM_EXESQL,m_sqlcompos,0);