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;
}
数据解包处理，这里就必须根据外部设备定义的通讯协议来处理了。
{
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;
}
至此，基本的通讯外围程序基本完成，如果我们要扩充多个串口多线程的话，我们可以做如下修改:
{
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);
}
我们对各种发送命令函数进行载入形参的方法来解决。
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);
}
[1] [2]