用VC实现多串口多线程工业控制

来源：VCHELP 作者：出处：巧巧读书 2005-12-19 进入讨论组

关键词：
exchange
window
协议

　　LONG C×××View::OnCommunication(WPARAM ch, LPARAM port)进行数据处理，WPARAM,LPARAM类型是多态性数据(polymorphic data type),在WIN32中为32位，支持多种数据类型，根据需要自动适应，这样程序就有很强的适应性。

再次我们这里理解成为BYTE类型（与外围设备通讯协议保持一致，方便解包）。每当串口接收缓冲区内有一个字符的时候，就会产生一个WM_COMM_RXCHAR消息，触发OnCommunication函数，下面我们可以根据我们的需要进行解包处理了；


LONG CMy11View::OnCommunication(WPARAM ch, LPARAM port)


{ 


　if(port == 1)


　{


　　m_RecBuff[nColts] += (BYTE)(char *)(ch);


　　nColts++;


　　if(nColts == 24)//这里根据通讯协议规定的发送定制要数据命令就会上传24个字节的数据报文内容。这里可以根据不同外部设备进行不同的设置


　　{


　　　DataProcessTemp(m_RecBuff);//处理解包


　　　nColts = 0;//缓冲区指针清0，准备接收下一台设备数据


　　　ResetBuffVal();//清空缓冲区内容


　　　SetCommVal(); //发送下一台设备内容 


　　} 


　}


　return 0;


}

　　数据解包处理，这里就必须根据外部设备定义的通讯协议来处理了。


void CMy11View::DataProcessTemp(BYTE m_Inbuff[])


{


　int nTempAddr = nColtAddr - 1;


　if(nTempAddr 
< 0) 


　　nTempAddr = 19;


　　int nHAdd,nLAdd; 


　　nHAdd = ExchangeAscII((nTempAddr>
>
4)&0x0f);


　　nLAdd = ExchangeAscII(nTempAddr&0x0f);


　if(m_Inbuff[0] == 0x40)


　{


　　if(m_Inbuff[1] == nHAdd && m_Inbuff[2] == nLAdd)


　　{


　　　if(m_Inbuff[3] == 0x52 && m_Inbuff[4] == 0x44)


　　　{ 


　　　　int nzTemp[5];


　　　　float fTemp;


　　　　nzTemp[0] = m_Inbuff[7];


　　　　nzTemp[1] = m_Inbuff[8];


　　　　nzTemp[2] = m_Inbuff[9];


　　　　nzTemp[3] = m_Inbuff[10];


　　　　for(int i = 0 ; i 
< 4; i ++)


　　　　{


　　　　　if(nzTemp[i] >
0x39)


　　　　　　nzTemp[i] -= 0x37;


　　　　　else


　　　　　　nzTemp[i] -= 0x30;


　　　　} 


　　　　fTemp=float(nzTemp[1]+(nzTemp[0]
<
<4)+(nzTemp[3]
<
<8)+(nzTemp[2]
<
<12))/10;


　　　　fVal[nTempAddr] = fTemp;


　　　　RedrawWindow();


　　　}


　　}


　} 


}




void CMy11View::ResetBuffVal()


{


　for(int i=0;i
<1000;i++)


　　m_RecBuff[i] = 0;


}

　　至此，基本的通讯外围程序基本完成，如果我们要扩充多个串口多线程的话，我们可以做如下修改:


CSerialPort m_Ports[20];


BYTE m_RecBuff[20][1000];


BYTE m_SendBuff[5][1000];


int nColts[20];


int nZBKType[24];


int nWrongCount[20][20];


int nColtAddr[20];


HANDLE m_pThread;




//Protect Device


if(this->
m_Ports[0].InitPort(this,2,9600,'N',8,1,EV_RXCHAR|EV_RXFLAG,1024))


{ 


　this->
m_Ports[0].StartMonitoring();


　SetComBufferVal(0);


} 


//Diandu Device


if(this->
m_Ports[1].InitPort(this,4,1200,'E',8,1,EV_RXCHAR|EV_RXFLAG,1024))


{ 


　this->
m_Ports[1].StartMonitoring();


　SetComBufferVal(1);


}