学步园

接下来是最关键的对象登场了：语音控制核心线程！

using System;<br /> using System.Collections.Generic;<br /> using System.Text;<br /> using CC.QJ.Tools;<br /> using System.Threading;<br /> using CC.DJ081A.Lib;<br /> using System.Collections;<br /> using CC.QJSocket.Server;<br /> using System.Net.Sockets;<br /> using System.Configuration;</p> <p>namespace CallCenterApp<br /> {<br /> public class CallThread : MainThread<br /> {<br /> public SocketListener _socketListener;<br /> public CardHelper.refreshlv _RefreshLv;<br /> int chn;<br /> Trunk[] _channel;<br /> private static readonly string recordpaht = ConfigurationManager.AppSettings["recordpath"];</p> <p> public CallThread(Trunk[] ichannel,int ichn)<br /> {<br /> chn = ichn;<br /> _channel = ichannel;<br /> }<br /> public override void run()<br /> {<br /> do<br /> {<br /> base.run();<br /> MainEvent();<br /> Thread.Sleep(50);<br /> } while (isStart);</p> <p> }</p> <p> private void MainEvent()<br /> {<br /> Tc08a32.PUSH_PLAY();<br /> Tc08a32.FeedSigFunc();<br /> for (int i = 0; i < chn; i++)<br /> {<br /> _RefreshLv(_channel[i]);</p> <p> if (_channel[i].chnstatus == CHN_STATUS.LINE_INIT)<br /> {<br /> ResetChannel(i);<br /> }<br /> else<br /> {</p> <p> if (_channel[i].chntype == CHN_TYPE.CHTYPE_TRUNK)<br /> {<br /> if (Tc08a32.Sig_CheckBusy(i) == 1) //监测到忙音<br /> {<br /> if (_channel[i].connchn != -1) Tc08a32.StartPlaySignal(_channel[i].connchn, 2); ////给与外线相连的内线忙音<br /> ResetChannel(i);<br /> }<br /> }</p> <p> if (_channel[i].chntype == CHN_TYPE.CHTYPE_USER)<br /> {<br /> if (!Tc08a32.OffHookDetect(i) && _channel[i].chnstatus != CHN_STATUS.LINE_IDLE && _channel[i].busyflag == false)<br /> ResetChannel(i);<br /> }<br /> }<br /> DoWork(i);<br /> }<br /> }</p> <p> private void ResetChannel(int ichn)<br /> {<br /> Tc08a32.StopPlayFile(ichn);<br /> Tc08a32.StartPlaySignal(ichn, (int)SingleVType.SIG_STOP);<br /> _channel[ichn].callee = string.Empty;<br /> _channel[ichn].caller = string.Empty;<br /> _channel[ichn].calltime = string.Empty;<br /> _channel[ichn].chn = ichn;<br /> _channel[ichn].connchn = -1;<br /> _channel[ichn].filename = null;<br /> _channel[ichn].dtmflength = 0;<br /> _channel[ichn].dtmf = string.Empty;<br /> _channel[ichn].play_count = 0;<br /> _channel[ichn].workflag = false;<br /> _channel[ichn].busyflag = false;<br /> _channel[ichn].eventtype = -1;<br /> _channel[ichn].dispstatus = CardHelper.GetDescByStatus(CHN_STATUS.LINE_IDLE);<br /> _channel[ichn].chnstatus = CHN_STATUS.LINE_IDLE;</p> <p> if (_channel[ichn].chntype == CHN_TYPE.CHTYPE_TRUNK)<br /> {<br /> _myLog(LogFile.Trace, "重置外线通道属性,通道号" + ichn.ToString());<br /> Tc08a32.HangUp(ichn);<br /> Tc08a32.InitDtmfBuf(ichn);<br /> Tc08a32.ResetCallerIDBuffer(ichn);<br /> }</p> <p> if (_channel[ichn].chntype == CHN_TYPE.CHTYPE_USER)<br /> {<br /> _myLog(LogFile.Trace, "重置内线通道属性,通道号" + ichn.ToString());<br /> Tc08a32.FeedPower(ichn);</p> <p> }<br /> }</p> <p> //核心线程<br /> private void DoWork(int i)<br /> {<br /> switch (_channel[i].chnstatus)<br /> {<br /> case CHN_STATUS.LINE_IDLE:<br /> {<br /> if (Tc08a32.RingDetect(i)) //检测外线振铃，或者内线是否摘机<br /> {<br /> _channel[i].busyflag = true;<br /> if (_channel[i].chntype == CHN_TYPE.CHTYPE_TRUNK)<br /> {<br /> _channel[i].dispstatus = "外线用户振铃";<br /> byte[] IDStr = new byte[128];<br /> /*<br /> int callerId = Tc08a32.GetCallerIDStr(i, IDStr);<br /> if (callerId == 3 || callerId == 4)<br /> {<br /> Tc08a32.OffHook(i); //外线摘机<br /> Tc08a32.StartSigCheck(i);</p> <p> string caller = Encoding.UTF8.GetString(IDStr);<br /> _channel[i].caller = caller;<br /> _myLog(LogFile.Trace, "接收的主叫号码:" + caller);<br /> _channel[i].chnstatus = CHN_STATUS.LINE_WELCOME;<br /> }*/<br /> Tc08a32.OffHook(i); //外线摘机<br /> Tc08a32.StartSigCheck(i);<br /> _channel[i].chnstatus = CHN_STATUS.LINE_WELCOME;</p> <p> }<br /> /*<br /> if (_channel[i].chntype == CHN_TYPE.CHTYPE_USER)<br /> {<br /> Tc08a32.StartHangUpDetect(i);<br /> Tc08a32.StartPlaySignal(i, (int)SingleVType.SIG_DIALTONE);<br /> _channel[i].dispstatus = "内线用户振铃";<br /> _channel[i].chnstatus = CHN_STATUS.LINE_GET_DTMF; //内线收DTMF<br /> }*/<br /> }<br /> }<br /> break;<br /> case CHN_STATUS.LINE_WELCOME:<br /> {<br /> Tc08a32.InitDtmfBuf(i); //清空接收DTMF的缓冲区</p> <p> _channel[i].dtmflength = 0;<br /> _channel[i].dispstatus = "对外线用户播放提示音...";<br /> StringBuilder filename = new StringBuilder("voc//1.pcm");<br /> _channel[i].filename = filename;<br /> Tc08a32.StartPlayFile(i, filename, 1);<br /> _myLog(LogFile.Trace, "播放提示音:" + filename);<br /> _channel[i].play_count = 1;<br /> Tc08a32.StartSigCheck(i);<br /> Tc08a32.StartTimer(i, pubparam.TIMER_NO); //通道启动计时器<br /> _channel[i].chnstatus = CHN_STATUS.LINE_WELCOME1;<br /> filename = null;<br /> }<br /> break;<br /> case CHN_STATUS.LINE_WELCOME1:<br /> {<br /> int check2 = Tc08a32.ReadCheckResult(i, 1);<br /> if (check2 == 0x21)<br /> {<br /> _myLog(LogFile.Trace, "播放欢迎词时，检测到外线挂机");<br /> _channel[i].chnstatus = CHN_STATUS.LINE_WAIT_HANGUP;<br /> break;<br /> }</p> <p> int b = -1;<br /> b = Tc08a32.GetDtmfCode(i);<br /> if (b < 0 || b > 16)<br /> {<br /> if (Tc08a32.CheckPlayEnd(i) == 1) //放音结束<br /> {<br /> if (_channel[i].play_count < 2)<br /> {<br /> _channel[i].play_count++;<br /> Tc08a32.StartPlayFile(i, _channel[i].filename, 0);<br /> _myLog(LogFile.Trace, "播放提示音:" + _channel[i].filename);<br /> }<br /> else<br /> {<br /> _channel[i].chnstatus = CHN_STATUS.LINE_WAIT_HANGUP;<br /> }<br /> }<br /> break;<br /> }<br /> else<br /> {<br /> _myLog(LogFile.Trace, "播放欢迎词检测到其他按键,dtmf=:" + b.ToString()+"chn ="+i.ToString());<br /> Tc08a32.StopPlayFile(i);<br /> Tc08a32.StartPlaySignal(i, (int)SingleVType.SIG_STOP);<br /> if (_channel[i].chntype == CHN_TYPE.CHTYPE_USER)<br /> {<br /> _channel[i].dispstatus = "内线收DTMF号码...";<br /> }<br /> if (_channel[i].chntype == CHN_TYPE.CHTYPE_TRUNK)<br /> {</p> <p> _channel[i].dispstatus = "接收外线DTMF按键...";<br /> switch (b)<br /> {<br /> case 12: //#号键，返回主菜单:<br /> {<br /> _channel[i].chnstatus = CHN_STATUS.LINE_WELCOME;<br /> break;<br /> }<br /> case 1: //播放水厂地址<br /> {<br /> _channel[i].dispstatus = "对外播放水厂地址信息...";<br /> StringBuilder filename = new StringBuilder("voc//9.pcm");<br /> _myLog(LogFile.Trace, "播放水厂地址:" + filename);<br /> _channel[i].filename = filename;<br /> Tc08a32.StartPlayFile(i, filename, 0);<br /> _channel[i].play_count = 1;<br /> _channel[i].eventtype = 1;<br /> Tc08a32.StartTimer(i, pubparam.TIMER_NO); //通道启动计时器<br /> _channel[i].chnstatus = CHN_STATUS.LINE_PLAY_ONLY;<br /> }<br /> break;<br /> case 2:<br /> {<br /> StringBuilder filename = new StringBuilder("voc//10.pcm");<br /> _channel[i].filename = filename;<br /> Tc08a32.StartPlayFile(i, filename, 0);<br /> _channel[i].play_count = 1;<br /> _channel[i].eventtype = 2;<br /> _channel[i].chnstatus = CHN_STATUS.LINE_SELECT;</p> <p> }<br /> break;<br /> case 3: //播放水质监测中心电话:85723236多文件拼接播放方式<br /> {<br /> StringBuilder filename = new StringBuilder("voc//6.pcm"); //播放整个文件<br /> _channel[i].filename = filename;<br /> Tc08a32.StartPlayFile(i, filename, 0);<br /> _channel[i].play_count = 1;<br /> _channel[i].eventtype = 3;<br /> _channel[i].chnstatus = CHN_STATUS.LINE_PLAY_ONLY;<br /> }<br /> break;<br /> case 4: //播报停水通知文件<br /> {<br /> object f = CardHelper.GetFileNameByDb(1);<br /> StringBuilder sb = new StringBuilder();<br /> if (f == null)<br /> {<br /> sb.Append("voc//8.pcm"); //您好，没有停水通知<br /> }<br /> else<br /> {<br /> string filepah = recordpaht + f.ToString();<br /> bool bexsit = CardHelper.fileExist(filepah, recordpaht);<br /> if (bexsit)<br /> {<br /> sb.Append(filepah); //播放停水通知文件<br /> }<br /> else<br /> {<br /> sb.Append("voc//8.pcm"); //您好，没有停水通知<br /> }<br /> }<br /> _channel[i].filename = sb;<br /> Tc08a32.StartPlayFile(i, sb, 0);<br /> _channel[i].play_count = 1;<br /> _channel[i].eventtype = 9;<br /> _channel[i].chnstatus = CHN_STATUS.LINE_PLAY_ONLY;<br /> }<br /> break;<br /> case 9: //告知客户端为咨询<br /> {<br /> Tc08a32.StopPlayFile(i);<br /> _channel[i].eventtype = 3;<br /> _channel[i].chnstatus = CHN_STATUS.LINE_CHECK_IDLE;<br /> }<br /> break;<br /> case 10: //0号键：转坐席://告知客户端为受理<br /> {<br /> Tc08a32.StopPlayFile(i);<br /> _channel[i].eventtype = 4;<br /> _channel[i].chnstatus = CHN_STATUS.LINE_CHECK_IDLE;<br /> }<br /> break;<br /> default:<br /> {<br /> StringBuilder filename = new StringBuilder("voc//7.pcm"); //选择了其他按键<br /> _channel[i].filename = filename;<br /> Tc08a32.StartPlayFile(i, filename, 0);<br /> _channel[i].play_count = 1;<br /> _channel[i].chnstatus = CHN_STATUS.LINE_OTHER_KEY;<br /> }<br /> break;<br /> }<br /> }<br /> }<br /> break;<br /> }<br /> case CHN_STATUS.LINE_SELECT: //第二集菜单的选择<br /> {<br /> if (Tc08a32.Sig_CheckBusy(i) == 1)<br /> {<br /> Tc08a32.HangUp(i);<br /> _channel[i].chnstatus = CHN_STATUS.LINE_INIT;<br /> break;<br /> }</p> <p> int b = Tc08a32.GetDtmfCode(i);<br /> if (b < 0 || b > 16)<br /> {<br /> if (Tc08a32.CheckPlayEnd(i) == 1) //放音结束<br /> {<br /> if (_channel[i].play_count < 2)<br /> {<br /> _channel[i].play_count++;<br /> Tc08a32.StartPlayFile(i, _channel[i].filename, 0);<br /> break;<br /> }<br /> else<br /> {<br /> _channel[i].chnstatus = CHN_STATUS.LINE_WAIT_HANGUP;<br /> }<br /> }<br /> }<br /> else<br /> {<br /> Tc08a32.StopPlayFile(i);<br /> Tc08a32.StartPlaySignal(i, (int)SingleVType.SIG_STOP);<br /> switch (b)<br /> {<br /> case 1: //非节假日 4<br /> {<br /> StringBuilder filename = new StringBuilder("voc//4.pcm");<br /> _channel[i].filename = filename;<br /> Tc08a32.StartPlayFile(i, filename, 0);<br /> _channel[i].play_count = 1;<br /> _channel[i].chnstatus = CHN_STATUS.LINE_PLAY_ONLY;</p> <p> }<br /> break;<br /> case 2: //节假日 5<br /> {<br /> StringBuilder filename = new StringBuilder("voc//5.pcm");<br /> _channel[i].filename = filename;<br /> Tc08a32.StartPlayFile(i, filename, 0);<br /> _channel[i].play_count = 1;<br /> _channel[i].chnstatus = CHN_STATUS.LINE_PLAY_ONLY;</p> <p> }<br /> break;<br /> case 12: //#号键，返回主菜单:<br /> {<br /> _channel[i].chnstatus = CHN_STATUS.LINE_WELCOME;<br /> }<br /> break;<br /> default:<br /> {<br /> StringBuilder filename = new StringBuilder("voc//7.pcm"); //选择了其他按键<br /> _channel[i].filename = filename;<br /> Tc08a32.StartPlayFile(i, filename, 0);<br /> _channel[i].play_count = 1;<br /> _channel[i].chnstatus = CHN_STATUS.LINE_OTHER_KEY;<br /> }<br /> break;<br /> }<br /> }<br /> }<br /> break;</p> <p> case CHN_STATUS.LINE_PLAY_ONLY: //播放水厂地址，播放水质电话<br /> if (Tc08a32.CheckPlayEnd(i) == 1)<br /> {<br /> if (_channel[i].play_count < 2)<br /> {<br /> _channel[i].play_count++;<br /> Tc08a32.StartPlayFile(i, _channel[i].filename, 0);<br /> break;<br /> }<br /> else<br /> {<br /> _channel[i].chnstatus = CHN_STATUS.LINE_WAIT_HANGUP;<br /> }<br /> }<br /> break;<br /> case CHN_STATUS.LINE_OTHER_KEY: //其他按键.<br /> {<br /> if (Tc08a32.CheckPlayEnd(i) == 1)<br /> {<br /> if (_channel[i].play_count < 2)<br /> {<br /> _channel[i].play_count++;<br /> Tc08a32.StartPlayFile(i, _channel[i].filename, 0);<br /> _channel[i].chnstatus = CHN_STATUS.LINE_WELCOME1;<br /> break;<br /> }<br /> else<br /> {<br /> _channel[i].chnstatus = CHN_STATUS.LINE_WAIT_HANGUP;<br /> }<br /> }<br /> }<br /> break;<br /> case CHN_STATUS.LINE_CHECK_IDLE: //检测是否有空闲坐席<br /> {<br /> int userchn = GetIdleUserChn();</p> <p> if (userchn < 0) //提示坐席忙请等待.<br /> {<br /> StringBuilder filename = new StringBuilder("voc//11.pcm"); //对不起，坐席全忙.<br /> _channel[i].filename = filename;<br /> Tc08a32.StartPlayFile(i, filename, 0);<br /> _channel[i].play_count = 1;<br /> _channel[i].chnstatus = CHN_STATUS.LINE_CHECK_IDLE;<br /> }<br /> else //连通坐席人员...<br /> {<br /> _channel[i].connchn = userchn;<br /> _channel[userchn].connchn = i;<br /> _channel[userchn].busyflag = true; //将该通道占用。<br /> Tc08a32.StartPlaySignal(i,(int)SingleVType.SIG_RINGBACK);<br /> Tc08a32.FeedRealRing(userchn); //对某一路内线通道馈断续的铃流<br /> _channel[i].chnstatus = CHN_STATUS.LINE_LINK_USER;<br /> _channel[userchn].chnstatus = CHN_STATUS.LINE_LINK_USER;<br /> }<br /> }<br /> break;<br /> case CHN_STATUS.LINE_LINK_USER: //连通坐席<br /> {<br /> if (Tc08a32.OffHookDetect(_channel[i].connchn)) //检测外线振铃，或者内线是否摘机<br /> {<br /> //再处理相应的状态....<br /> Tc08a32.StartPlaySignal(i, (int)SingleVType.SIG_STOP);</p> <p> Tc08a32.FeedPower(_channel[i].connchn);<br /> _channel[i].dispstatus = "内线用户摘机";</p> <p> Tc08a32.StopPlayFile(_channel[i].connchn);</p> <p> int k = Tc08a32.SetLink( _channel[i].connchn,i);<br /> Tc08a32.StartHangUpDetect(_channel[i].connchn); //开始挂机检测<br /> Tc08a32.InitDtmfBuf(_channel[i].connchn); //如果不初始化，则无法收到按键...<br /> _channel[i].chnstatus = CHN_STATUS.LINE_LINK_CONNECT;<br /> _channel[_channel[i].connchn].chnstatus = CHN_STATUS.LINE_LINK_CONNECT;</p> <p> Tc08a32.StartSigCheck(_channel[i].connchn);<br /> Tc08a32.StartSigCheck(i);</p> <p> //发送消息到客户端：：：：：：//eventtype 有具体的定义 ...<br /> string caller = "12345678";<br /> SendMessageToClient(caller, _channel[i].connchn, _channel[i].eventtype);</p> <p> }</p> <p> }<br /> break;<br /> //case CHN_STATUS.LINE_RECORDING:<br /> case CHN_STATUS.LINE_LINK_CONNECT:<br /> {<br /> _channel[i].dispstatus = "话路联通";<br /> //内线挂机<br /> int check = Tc08a32.HangUpDetect(i);<br /> if (check == 1)<br /> {<br /> _myLog(LogFile.Trace, "话路通，内线挂机.." + i.ToString());<br /> }<br /> //联通过程中，任何一方挂机。(检测不到内线挂机？？？)<br /> int check2 = Tc08a32.ReadCheckResult(i, 1);<br /> if (check2 == 0x21)<br /> {<br /> _myLog(LogFile.Trace, "话路通，外线挂机.." + i.ToString());<br /> }</p> <p> if(check2 == 0x21 || check == 1)<br /> {<br /> _myLog(LogFile.Trace, "停止可能的录音,开始挂机流程.." + i.ToString());<br /> Tc08a32.StopRecordFile(i);</p> <p> _channel[i].chnstatus = CHN_STATUS.LINE_WAIT_HANGUP;<br /> //将另一方挂断.<br /> if (_channel[i].connchn >= 0 && _channel[_channel[i].connchn].chnstatus != CHN_STATUS.LINE_IDLE)<br /> {<br /> Tc08a32.HangUp(_channel[i].connchn);<br /> _channel[_channel[i].connchn].chnstatus = CHN_STATUS.LINE_INIT;<br /> }<br /> }</p> <p> if (_channel[i].chntype == CHN_TYPE.CHTYPE_TRUNK)<br /> {<br /> break;<br /> }</p> <p> //下列是内线处理。。。。。。。。<br /> int b = Tc08a32.GetDtmfCode(i);<br /> if (b == 11) //是否需要开始录音 *<br /> {<br /> _channel[_channel[i].connchn].dispstatus = "话路录音";<br /> bool f = Tc08a32.StartRecordFile(_channel[i].connchn, Encoding.UTF8.GetBytes(CardHelper.GetFileName()), 36000 * 100);<br /> _myLog(LogFile.Trace, "对外线通道录音,通道号：" + _channel[i].connchn.ToString());<br /> }<br /> if (b == 12) //#号键:坐席挂机、对外线放音（外线暂时不能挂）<br /> {<br /> _myLog(LogFile.Trace, "接收到#,通道号：" + _channel[i].connchn.ToString());<br /> //检测socket消息队列...........<br /> Tc08a32.StopRecordFile(i);<br /> if (_channel[i].chntype == CHN_TYPE.CHTYPE_USER)<br /> {<br /> _myLog(LogFile.Trace, "准备内线挂机，并对外线放音,通道号：" + _channel[i].connchn.ToString());<br /> _channel[i].chnstatus = CHN_STATUS.LINE_WAIT_HANGUP;<br /> //准备接收Socket通讯，开始对外放音...<br /> }<br /> }<br /> }<br /> break;<br /> case CHN_STATUS.LINE_WAIT_HANGUP:<br /> {<br /> Tc08a32.HangUp(i);<br /> _channel[i].chnstatus = CHN_STATUS.LINE_INIT;<br /> }<br /> break;<br /> case CHN_STATUS.LINE_PLAY_RECORD:<br /> if (Tc08a32.CheckIndexPlayFile(i) == 1)<br /> {<br /> if (_channel[i].play_count < 2)<br /> {<br /> _channel[i].play_count++;<br /> Tc08a32.StartIndexPlayFile(i);<br /> break;<br /> }<br /> else<br /> {<br /> Tc08a32.StopIndexPlayFile(i);<br /> _channel[i].chnstatus = CHN_STATUS.LINE_WAIT_HANGUP;<br /> }<br /> }<br /> break;</p> <p> default: break;<br /> }</p> <p> }</p> <p> //来自socket客户端的消息...<br /> public void listener_CbMessage(string ip, string message)<br /> {<br /> _myLog(LogFile.Trace, "回调到语音卡线程,IP：" + ip + " 信息：" + message);<br /> //对收到的数据进行解析，然后做相应的处理.<br /> if (message == string.Empty)<br /> {<br /> _myLog(LogFile.Trace, "内容为空！为什么？");<br /> return;<br /> }<br /> string[] sip = ip.Split(':');</p> <p> string[] data = message.Split('|');<br /> if (data == null || data.Length < 2)<br /> {<br /> _myLog(LogFile.Trace, "内容不全，什么意思？");<br /> return;<br /> }</p> <p> int ifunc = int.Parse(data[0]);<br /> switch (ifunc)<br /> {<br /> case -1: //注销<br /> {<br /> _myLog(LogFile.Trace, "坐席离开！");<br /> }<br /> break;<br /> case 1: //坐席注册<br /> {<br /> if (data[1].ToString() != "hello qianjia")<br /> {<br /> _myLog(LogFile.Trace, "注册信息不正确！");<br /> }<br /> else<br /> {<br /> //注册<br /> CardHelper.ChangerRegStatusOfInner(sip[0], 1);<br /> _myLog(LogFile.Trace, "坐席注册信息成功,IP:" + sip[0]);<br /> }<br /> }<br /> break;<br /> case 2: //对外线放音电话号码<br /> {<br /> int ichn = CardHelper.GetChnByIp(sip[0]); //内线通道<br /> if (ichn < 0)<br /> {<br /> _myLog(LogFile.Trace, "没有该IP对应的通道号,IP:" + sip[0]);<br /> }<br /> else<br /> {<br /> int outichn = _channel[ichn].connchn; //外线通道<br /> if (outichn > -1)<br /> {<br /> string telephone = data[1];<br /> string[] files = CardHelper.GetFileNameByTelephone(telephone);<br /> if (files == null)<br /> {<br /> _myLog(LogFile.Trace, "无法获取语音文件，可能是传入的号码有误，原文：" + telephone);<br /> break;<br /> }<br /> else<br /> {<br /> Tc08a32.StopPlayFile(outichn);<br /> Tc08a32.RsetIndexPlayFile(outichn);<br /> foreach (string s in files)<br /> {<br /> Tc08a32.AddIndexPlayFile(outichn, new StringBuilder(s));<br /> }<br /> Tc08a32.StartIndexPlayFile(outichn);<br /> _channel[outichn].play_count = 1;<br /> _channel[ichn].chnstatus = CHN_STATUS.LINE_WAIT_HANGUP;<br /> _channel[outichn].chnstatus = CHN_STATUS.LINE_PLAY_RECORD;<br /> }<br /> }<br /> else<br /> {<br /> _myLog(LogFile.Trace, "没有对应的连接通道！");<br /> }<br /> }<br /> }<br /> break;<br /> default:<br /> _myLog(LogFile.Trace, "未知功能按键!");<br /> break;<br /> }<br /> }</p> <p> /// <summary><br /> /// 根据业务流程给对应的客户端发送消息<br /> /// </summary><br /> /// <param name="message"></param><br /> /// <param name="ichn"></param><br /> private void SendMessageToClient(string message,int ichn,int eventtype)<br /> {<br /> if (_socketListener.Connection == null)<br /> {<br /> _myLog(LogFile.Error, "socket的监听不为空!");<br /> return;<br /> }</p> <p> string senders = string.Empty;</p> <p> foreach (configObject obj in pubvar.configlist)<br /> {<br /> if(ichn == obj.ClinetLine && obj.ClientStatus == 1) //==1 表示已经注册信息<br /> {<br /> senders = obj.ClinetIP;<br /> break;<br /> }<br /> }<br /> if (senders == string.Empty)<br /> {<br /> _myLog(LogFile.Error, "没有对应的socket客户端,无法发送消息!");<br /> return;<br /> }</p> <p> foreach (DictionaryEntry socket in _socketListener.Connection)<br /> {<br /> string[] sip = socket.Key.ToString().Split(':');<br /> if (senders == sip[0])<br /> {<br /> string temp = eventtype.ToString()+"|"+ message ;<br /> byte[] bs = Encoding.UTF8.GetBytes(temp);<br /> if (((Connection)(socket.Value))._connection != null)<br /> {<br /> ((Connection)(socket.Value))._connection.Send(bs, bs.Length, 0);<br /> _myLog(LogFile.Trace, "发送消息到对应的客户端：" + senders + " 消息内容：" + temp);<br /> bs = null;<br /> }<br /> break;<br /> }<br /> }<br /> }</p> <p> private int GetIdleUserChn()<br /> {<br /> int userchn = -1;<br /> for (int j = 0; j < chn; j++)<br /> {<br /> if (_channel[j].chntype == CHN_TYPE.CHTYPE_USER && _channel[j].chnstatus == CHN_STATUS.LINE_IDLE)<br /> {<br /> userchn = j;<br /> _myLog(LogFile.Trace, "获取一个空闲通道.通道号：." + j.ToString());<br /> break;<br /> }<br /> }<br /> return userchn;<br /> }</p> <p> }<br /> }<br />