You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
285 lines
6.9 KiB
285 lines
6.9 KiB
|
|
|
|
|
|
#include <stdio.h>
|
|
#include <string.h>
|
|
|
|
#include<iostream>
|
|
|
|
#include <WinSock2.h>
|
|
#include <windows.h>
|
|
#include <tchar.h>
|
|
|
|
#include "Serial8008.h"
|
|
|
|
#include "WWSerialPort.h"
|
|
|
|
WWSerialPort::WWSerialPort()
|
|
{
|
|
HANDLE hCom = NULL;
|
|
memcpy(pHandle, &hCom, sizeof(hCom));
|
|
}
|
|
|
|
WWSerialPort::~WWSerialPort()
|
|
{
|
|
|
|
}
|
|
|
|
bool WWSerialPort::open(const char* portname,
|
|
int baudrate,
|
|
char parity,
|
|
char databit,
|
|
char stopbit,
|
|
char synchronizeflag)
|
|
{
|
|
this->synchronizeflag = synchronizeflag;
|
|
HANDLE hCom = NULL;
|
|
if (this->synchronizeflag)
|
|
{
|
|
//同步方式
|
|
hCom = CreateFileA(portname, //串口名
|
|
GENERIC_READ | GENERIC_WRITE, //支持读写
|
|
0, //独占方式，串口不支持共享
|
|
NULL,//安全属性指针，默认值为NULL
|
|
OPEN_EXISTING, //打开现有的串口文件
|
|
0, //0：同步方式，FILE_FLAG_OVERLAPPED：异步方式
|
|
NULL);//用于复制文件句柄，默认值为NULL，对串口而言该参数必须置为NULL
|
|
}
|
|
else
|
|
{
|
|
//异步方式
|
|
hCom = CreateFileA(portname, //串口名
|
|
GENERIC_READ | GENERIC_WRITE, //支持读写
|
|
0, //独占方式，串口不支持共享
|
|
NULL,//安全属性指针，默认值为NULL
|
|
OPEN_EXISTING, //打开现有的串口文件
|
|
FILE_FLAG_OVERLAPPED, //0：同步方式，FILE_FLAG_OVERLAPPED：异步方式
|
|
NULL);//用于复制文件句柄，默认值为NULL，对串口而言该参数必须置为NULL
|
|
}
|
|
|
|
if(hCom == (HANDLE)-1)
|
|
{
|
|
std::cerr << "open error" << std::endl;
|
|
//*pHandle = -1;
|
|
return false;
|
|
}
|
|
|
|
//配置缓冲区大小
|
|
if(! SetupComm(hCom,1024, 1024))
|
|
{
|
|
std::cerr << "SetupComm error" << std::endl;
|
|
return false;
|
|
}
|
|
|
|
// 配置参数
|
|
DCB p;
|
|
memset(&p, 0, sizeof(p));
|
|
p.DCBlength = sizeof(p);
|
|
p.BaudRate = baudrate; // 波特率
|
|
p.ByteSize = databit; // 数据位
|
|
|
|
switch (parity) //校验位
|
|
{
|
|
case 0:
|
|
p.Parity = NOPARITY; //无校验
|
|
break;
|
|
case 1:
|
|
p.Parity = ODDPARITY; //奇校验
|
|
break;
|
|
case 2:
|
|
p.Parity = EVENPARITY; //偶校验
|
|
break;
|
|
case 3:
|
|
p.Parity = MARKPARITY; //标记校验
|
|
break;
|
|
}
|
|
|
|
switch(stopbit) //停止位
|
|
{
|
|
case 1:
|
|
p.StopBits = ONESTOPBIT; //1位停止位
|
|
break;
|
|
case 2:
|
|
p.StopBits = TWOSTOPBITS; //2位停止位
|
|
break;
|
|
case 3:
|
|
p.StopBits = ONE5STOPBITS; //1.5位停止位
|
|
break;
|
|
}
|
|
|
|
if(! SetCommState(hCom, &p))
|
|
{
|
|
// 设置参数失败
|
|
std::cerr << "SetCommState error" << std::endl;
|
|
return false;
|
|
}
|
|
|
|
//超时处理,单位：毫秒
|
|
//总超时＝时间系数×读或写的字符数＋时间常量
|
|
COMMTIMEOUTS TimeOuts;
|
|
TimeOuts.ReadIntervalTimeout = 1000; //读间隔超时
|
|
TimeOuts.ReadTotalTimeoutMultiplier = 500; //读时间系数
|
|
TimeOuts.ReadTotalTimeoutConstant = 5000; //读时间常量
|
|
TimeOuts.WriteTotalTimeoutMultiplier = 500; // 写时间系数
|
|
TimeOuts.WriteTotalTimeoutConstant = 2000; //写时间常量
|
|
SetCommTimeouts(hCom,&TimeOuts);
|
|
|
|
PurgeComm(hCom,PURGE_TXCLEAR|PURGE_RXCLEAR);//清空串口缓冲区
|
|
|
|
memcpy(pHandle, &hCom, sizeof(hCom));// 保存句柄
|
|
|
|
return true;
|
|
}
|
|
|
|
void WWSerialPort::close()
|
|
{
|
|
HANDLE hCom = *(HANDLE*)pHandle;
|
|
if ((hCom != NULL) && (hCom != (HANDLE)-1)) {
|
|
CloseHandle(hCom);
|
|
}
|
|
}
|
|
|
|
int WWSerialPort::send(const void *buf,int len)
|
|
{
|
|
HANDLE hCom = *(HANDLE*)pHandle;
|
|
|
|
if (this->synchronizeflag)
|
|
{
|
|
// 同步方式
|
|
DWORD dwBytesWrite = len; //成功写入的数据字节数
|
|
BOOL bWriteStat = WriteFile(hCom, //串口句柄
|
|
buf, //数据首地址
|
|
dwBytesWrite, //要发送的数据字节数
|
|
&dwBytesWrite, //DWORD*，用来接收返回成功发送的数据字节数
|
|
NULL); //NULL为同步发送，OVERLAPPED*为异步发送
|
|
if (!bWriteStat)
|
|
{
|
|
std::cerr << "send error" << std::endl;
|
|
//*pHandle = -1;
|
|
return 0;
|
|
}
|
|
return dwBytesWrite;
|
|
}
|
|
else
|
|
{
|
|
//异步方式
|
|
DWORD dwBytesWrite = len; //成功写入的数据字节数
|
|
DWORD dwErrorFlags; //错误标志
|
|
COMSTAT comStat; //通讯状态
|
|
OVERLAPPED m_osWrite; //异步输入输出结构体
|
|
|
|
//创建一个用于OVERLAPPED的事件处理，不会真正用到，但系统要求这么做
|
|
memset(&m_osWrite, 0, sizeof(m_osWrite));
|
|
//m_osWrite.hEvent = CreateEvent(NULL, TRUE, FALSE, L"WriteEvent");//unicode
|
|
//m_osWrite.hEvent = CreateEvent(NULL, TRUE, FALSE, "WriteEvent");
|
|
m_osWrite.hEvent = CreateEvent(NULL, TRUE, FALSE, _T("WriteEvent"));
|
|
|
|
ClearCommError(hCom, &dwErrorFlags, &comStat); //清除通讯错误，获得设备当前状态
|
|
BOOL bWriteStat = WriteFile(hCom, //串口句柄
|
|
buf, //数据首地址
|
|
dwBytesWrite, //要发送的数据字节数
|
|
&dwBytesWrite, //DWORD*，用来接收返回成功发送的数据字节数
|
|
&m_osWrite); //NULL为同步发送，OVERLAPPED*为异步发送
|
|
if (!bWriteStat)
|
|
{
|
|
if (GetLastError() == ERROR_IO_PENDING) //如果串口正在写入
|
|
{
|
|
WaitForSingleObject(m_osWrite.hEvent, 1000); //等待写入事件1秒钟
|
|
}
|
|
else
|
|
{
|
|
std::cerr << "WriteFile error:" << GetLastError()<< std::endl;
|
|
ClearCommError(hCom, &dwErrorFlags, &comStat); //清除通讯错误
|
|
CloseHandle(m_osWrite.hEvent); //关闭并释放hEvent内存
|
|
return 0;
|
|
}
|
|
}
|
|
return dwBytesWrite;
|
|
}
|
|
}
|
|
|
|
int WWSerialPort::receive(void *buf,int maxlen)
|
|
{
|
|
HANDLE hCom = *(HANDLE*)pHandle;
|
|
|
|
if (this->synchronizeflag)
|
|
{
|
|
//同步方式
|
|
DWORD wCount = maxlen; //成功读取的数据字节数
|
|
BOOL bReadStat = ReadFile(hCom, //串口句柄
|
|
buf, //数据首地址
|
|
wCount, //要读取的数据最大字节数
|
|
&wCount, //DWORD*,用来接收返回成功读取的数据字节数
|
|
NULL); //NULL为同步发送，OVERLAPPED*为异步发送
|
|
if (!bReadStat)
|
|
{
|
|
//std::cerr << "receive error1:" << std::endl;
|
|
return 0;
|
|
}
|
|
return wCount;
|
|
}
|
|
else
|
|
{
|
|
//异步方式
|
|
DWORD wCount = maxlen; //成功读取的数据字节数
|
|
DWORD dwErrorFlags; //错误标志
|
|
COMSTAT comStat; //通讯状态
|
|
OVERLAPPED m_osRead; //异步输入输出结构体
|
|
|
|
//创建一个用于OVERLAPPED的事件处理，不会真正用到，但系统要求这么做
|
|
memset(&m_osRead, 0, sizeof(m_osRead));
|
|
//m_osRead.hEvent = CreateEvent(NULL, TRUE, FALSE, L"ReadEvent");
|
|
//m_osRead.hEvent = CreateEvent(NULL, TRUE, FALSE, "ReadEvent");
|
|
m_osRead.hEvent = CreateEvent(NULL, TRUE, FALSE, _T("ReadEvent"));
|
|
|
|
ClearCommError(hCom, &dwErrorFlags, &comStat); //清除通讯错误，获得设备当前状态
|
|
if (!comStat.cbInQue) {
|
|
//std::cerr << "ClearCommError error:" << std::endl;
|
|
return 0; //如果输入缓冲区字节数为0，则返回false
|
|
}
|
|
|
|
BOOL bReadStat = ReadFile(hCom, //串口句柄
|
|
buf, //数据首地址
|
|
wCount, //要读取的数据最大字节数
|
|
&wCount, //DWORD*,用来接收返回成功读取的数据字节数
|
|
&m_osRead); //NULL为同步发送，OVERLAPPED*为异步发送
|
|
if (!bReadStat)
|
|
{
|
|
if (GetLastError() == ERROR_IO_PENDING) //如果串口正在读取中
|
|
{
|
|
//GetOverlappedResult函数的最后一个参数设为TRUE
|
|
//函数会一直等待，直到读操作完成或由于错误而返回
|
|
GetOverlappedResult(hCom, &m_osRead, &wCount, TRUE);
|
|
}
|
|
else
|
|
{
|
|
//std::cerr << "receive error2:" << GetLastError() << std::endl;
|
|
ClearCommError(hCom, &dwErrorFlags, &comStat); //清除通讯错误
|
|
CloseHandle(m_osRead.hEvent); //关闭并释放hEvent的内存
|
|
return 0;
|
|
}
|
|
}
|
|
return wCount;
|
|
}
|
|
|
|
}
|
|
|
|
void WWSerialPort::send_command(int argc, int cmd, int param) {
|
|
|
|
int msg_len = 0;
|
|
char msg_buff[MAX_MSG_LEN] = { 0 };
|
|
mob_gs_msg* msg = (mob_gs_msg*)msg_buff;
|
|
|
|
createCommandMsg(argc,cmd,param , msg, &msg_len );
|
|
|
|
send(msg, msg_len);
|
|
|
|
}
|
|
|
|
void* WWSerialPort::recv_results() {
|
|
|
|
HANDLE hCom = *(HANDLE*)pHandle;
|
|
|
|
recv_resultsForTimes(1,hCom);
|
|
return nullptr;
|
|
}
|