Программирование Com порта в Microsoft Visual Studio 9.0 C++

DEV_FRAME frame;
unsigned char buf_frame[31]; //буфер для фрейма
int index_frame = 0; //сколько в буфере лежит
 
void CWorkCtrl::convBBufToDFrame(const unsigned char *buf, DEV_FRAME &df)
{
//  USHORT temp;
    USHORT t;
    t = buf[0];
    t=buf[1];
    t=buf[2];
    df.RegN[0] = ((USHORT)buf[3]) | (((USHORT)buf[4]) << 8) ;
    df.Tail[0] = ((USHORT)buf[5]) | (((USHORT)buf[6]) << 8) ;
    df.RegN[1] = ((USHORT)buf[7]) | (((USHORT)buf[8]) << 8) ;
    df.Tail[1] = ((USHORT)buf[9]) | (((USHORT)buf[10]) << 8) ;
    df.RegN[2] = ((USHORT)buf[11]) | (((USHORT)buf[12]) << 8) ;
    df.Tail[2] = ((USHORT)buf[13]) | (((USHORT)buf[14]) << 8) ;
    df.RegN[3] = ((USHORT)buf[15]) | (((USHORT)buf[16]) << 8) ;
    df.Tail[3] = ((USHORT)buf[17]) | (((USHORT)buf[18]) << 8) ;
    df.RegN[4] = ((USHORT)buf[19]) | (((USHORT)buf[20]) << 8) ;
    df.Tail[4] = ((USHORT)buf[21]) | (((USHORT)buf[22]) << 8) ;
    df.RegN[5] = ((USHORT)buf[23]) | (((USHORT)buf[24]) << 8) ;
    df.Tail[5] = ((USHORT)buf[25]) | (((USHORT)buf[26]) << 8) ;
    df.RegWind[0] = buf[27];
    df.RegWind[1] = buf[28];
    df.RegWind[2] = buf[29];
    df.RegWind[3] = buf[30];
}

//////////////////////////////////////////////////////////////////////
 
#include "stdafx.h"
#include "WorkCtrl.h"
 
 
//////////////////////////////////////////////////////////////////////
// Construction/Destruction
//////////////////////////////////////////////////////////////////////
 
DEV_FRAME frame;
unsigned char buf_frame[31]; //буфер для фрейма
int index_frame = 0; //сколько в буфере лежит
 
void CWorkCtrl::convBBufToDFrame(const unsigned char *buf, DEV_FRAME &df)
{
//  USHORT temp;
    USHORT t;
    t = buf[0];
    t=buf[1];
    t=buf[2];
    df.RegN[0] = ((USHORT)buf[3]) | (((USHORT)buf[4]) << 8) ;
    df.Tail[0] = ((USHORT)buf[5]) | (((USHORT)buf[6]) << 8) ;
    df.RegN[1] = ((USHORT)buf[7]) | (((USHORT)buf[8]) << 8) ;
    df.Tail[1] = ((USHORT)buf[9]) | (((USHORT)buf[10]) << 8) ;
    df.RegN[2] = ((USHORT)buf[11]) | (((USHORT)buf[12]) << 8) ;
    df.Tail[2] = ((USHORT)buf[13]) | (((USHORT)buf[14]) << 8) ;
    df.RegN[3] = ((USHORT)buf[15]) | (((USHORT)buf[16]) << 8) ;
    df.Tail[3] = ((USHORT)buf[17]) | (((USHORT)buf[18]) << 8) ;
    df.RegN[4] = ((USHORT)buf[19]) | (((USHORT)buf[20]) << 8) ;
    df.Tail[4] = ((USHORT)buf[21]) | (((USHORT)buf[22]) << 8) ;
    df.RegN[5] = ((USHORT)buf[23]) | (((USHORT)buf[24]) << 8) ;
    df.Tail[5] = ((USHORT)buf[25]) | (((USHORT)buf[26]) << 8) ;
    df.RegWind[0] = buf[27];
    df.RegWind[1] = buf[28];
    df.RegWind[2] = buf[29];
    df.RegWind[3] = buf[30];
}

// WorkCtrl.h: interface for the CWorkCtrl class.
//
 
#pragma once
 
 
class CWorkCtrl  
{
public:
char *buf; 
DEV_FRAME m_df;
void convBBufToDFrame(const unsigned char *buf, DEV_FRAME &df)
private:
 
};

#pragma once
//http://britter.ru/index.php?docindex=4&offset=14900
#include <windows.h>
#include <string>
using namespace std;

enum CBaudrate  //скорости
{
    cbr110    = CBR_110,
    cbr300    = CBR_300,
    cbr600    = CBR_600,
    cbr1200   = CBR_1200,
    cbr2400   = CBR_2400,
    cbr4800   = CBR_4800,
    cbr9600   = CBR_9600,
    cbr14400  = CBR_14400,
    cbr19200  = CBR_19200,
    cbr38400  = CBR_38400,
    cbr56000  = CBR_56000,
    cbr115200 = CBR_115200,
    cbr128000 = CBR_128000,
    cbr256000 = CBR_256000
};
 
enum CParity //четность
{
    paEven = EVENPARITY,
    paMark = MARKPARITY,
    paNone = NOPARITY,
    paOdd  = ODDPARITY,
    paSpace= SPACEPARITY
};
 
enum CStopbits //кол стоп бит
{
    sb1   = ONESTOPBIT,
    sb1p5 = ONE5STOPBITS,
    sb2   = TWOSTOPBITS
};
 
enum CDatabits //кол бит данных
{
    db4 = 4, db5, db6, db7, db8
};
 
//перечисляет все события
//так чтобы никуда не лазить
enum CCommEvents
{
    CEV_BREAK  = EV_BREAK,
    CEV_CTS    = EV_CTS,
    CEV_DSR    = EV_DSR,
    CEV_ERR    = EV_ERR,
    CEV_RING   = EV_RING,
    CEV_RLSD   = EV_RLSD,
    CEV_RXCHAR = EV_RXCHAR,
    CEV_RXFLAG = EV_RXFLAG,
    CEV_TXEMPTY= EV_TXEMPTY
};
 
//Это для событий
#define WM_COMPORT WM_USER+1
 
//сообщения от порта
//у всех событий wParam - указатель на класс порта ComPort*
//передается HIWORD(lParam)
#define CP_BASE     0
#define CP_BREAK   (CP_BASE+1)  //
#define CP_CTS     (CP_BASE+2)  //
#define CP_DSR     (CP_BASE+3)  //
#define CP_ERR     (CP_BASE+4)  //
#define CP_RING    (CP_BASE+5)  //
#define CP_RLSD    (CP_BASE+6)  //
#define CP_RXCHAR  (CP_BASE+7)  //LOWORD(lParam) - количество байт
#define CP_RXFLAG  (CP_BASE+8)  //
#define CP_TXEMPTY (CP_BASE+9)  //

class ComPort
{
public:
    ComPort(HWND parent);          //порт нельзя создать без родителя, родителю мы и будем отсылать сообщения
    ComPort(HWND parent, string name);
    virtual ~ComPort(void); //
 
    BOOL Open();  //открыть порт 0 - не открылся 1-открылся
    BOOL Close(); //закрыть порт 1 - все нормально
 
    BOOL IsOpened() const {return bOpened;};     
 
    string GetDeviceName() const {return sName;};   //имя порта
    void SetDeviceName(string name);             //задать имя порта
 
    int  GetBaudRate() const {return iBaudRate;};
    BOOL SetBaudRate(CBaudrate br);
    BOOL SetBaudRate(int br);
    CParity GetParity() const {return Parity;};
    BOOL SetParity(CParity pa);
    CStopbits GetStopBits() const {return StopBits;};
    BOOL SetStopBits(CStopbits sb);
    CDatabits GetDataBits() const {return DataBits;};
    BOOL SetDataBits(CDatabits db);
    BOOL SetInputBufferSize(unsigned int size);
    unsigned int GetInputBufferSize() const; 
    BOOL SetOutputBufferSize(unsigned int size);
    unsigned int GetOutputBufferSize() const; 
 
    //нам надо задавать маски
    BOOL SetMaskEvent(unsigned int mask); //задает маску CCommEvents
    unsigned int GetMaskEvent();          //читаем маску порта CCommEvents
 
    unsigned int InCount();  //сколько байт во входном буфере
    unsigned int OutCount(); //сколько байт в выходном буфере
 
    BOOL PurgeIn();  //очищаем входной буфер
    BOOL PurgeOut(); //очищаем выходной буфер
 
    //интерфейс чтение
    bool ReadByte(unsigned char &byte);
    unsigned short ReadByts(void* buffer, unsigned short cnt);  //выделить достаточно места под буффер перед вызовом
    unsigned short ReadBytsEx(void* buffer, unsigned short cnt, unsigned int timeout); //если метод не воплнился до 
                                                                                       //конца за время timeout происходит 
                                                                                       //выход из функции
 
    //интерфейс запись
    bool SendByte(unsigned char byte);
    unsigned short SendByts(const void* buffer, unsigned short cnt);
    unsigned short SendBytsEx(const void* buffer, unsigned short cnt, unsigned int timeout);
protected:
    HANDLE hHandle;  //дискриптор порта
    string sName;    //имя
    HWND hParent;    //родитель
 
    int iBaudRate;      //
    CBaudrate BaudRate; //скорость
    CParity Parity;
    CStopbits StopBits;
    CDatabits DataBits;
    unsigned int uEventMask;  //маска прерываний порта
    //Размеры принимающего и отправляющего буффера
    unsigned int uInputBuffSize;
    unsigned int uOutputBuffSize;
 
    BOOL bOpened;    //1-открыт 0-закрыт
 
    //настройка порта
    BOOL UpdateDCB();  
    BOOL UpdateTimeouts();
    BOOL UpdateBuffers();
 
    //
    unsigned int GetCount(int i);  //выдает количество байт в буфере 0 -входной, 1-выходной
 
    //Это вызывается для обработки событий порта
    void PreEvent(unsigned int e);  //в ней мы обрабатываем все события 
 
    //чтение и запись в порт
    unsigned int Send(const void* buffer, unsigned short cnt);  //возвращает кол-во отправленных байт
    unsigned int Read(void* buffer, unsigned short cnt);  //возвращает кол-во прочитанных байт
 
    //Поток
    /*
      Поток понадобится для сигнала что во входном буфере есть данные для чтения
    */
    HANDLE hThread;    //дискриптор потока
       //так как функция является статической она будет единой для всех классов
       //в общем если интересно почитай про статические функции класса
       //в общем это необычная функция класса
    static DWORD WINAPI ComPortProc(LPVOID lParam);  //функция потока
    HANDLE hEventStop; //событие завершения потока
    OVERLAPPED overlapped; //структура испол. в потоке
    //для данной структуры надо создать событие поле hEvent
    DWORD uMaskEvent;  //Используется в WaitComEvent 
    DWORD uResult;     //результат функции WaitForMultipleObjects
    DWORD uBytesTrans; //нужно для GetOverlappedResult
    
    HANDLE hEvent[2];  //просто массив, нужен для WaitForMultipleEvent
};

// ИмяТвоегоКласса.h
#pragma once
 
// здесь описываешь все свои константы
 
class ИмяТвоегоКласса
{
public: //то что описываешь тут доступно для всего проекта в котором использован класс
 
    ИмяТвоегоКласса(HWND parent);                       //конструктор с одним аргументом
    ИмяТвоегоКласса(HWND parent, string name);      //конструктор с двумя аргументами
    virtual ~ComPort(void);                                     //деструктор 
/*имя конструктора и деструктора всегда совпадает с именем класса
   деструктор отличается от конструктора тильдой "~"
   конструкторов может быть несколько. Какой вызовется будет зависеть от количества 
   передаваемых аргуметов*/
 
protected: //все что описываешь здесь, доступно только внутри класса(с о своей программы ты к 
               //этим описаниям обратиться уже не сможешь
};

#include "ИмяТвоегоКласса.h" //подключаешь файл заголовков своего класса
 
ИмяТвоегоКласса::ИмяТвоегоКласса(HWND parent) : //описание конструктора с один аргументом
{
}
 
ComPort::ComPort(HWND parent, string name) : //описание конструктора с двумя аргументами
{
}
 
ИмяТвоегоКласса::~ИмяТвоегоКласса(void) //деструктор 
{
    if(bOpened)
        Close();
}
//до этой строки все что обязательно должно быть...
 
// далее реализация - ""ВсеГо" - что: может, должен и будет делать класс"

typedef struct _DEV_FRAME
{
//....
}DEV_FRAME;

LRESULT CALLBACK OnComPort(ComPort* p, unsigned int Event, unsigned short arg)
{
    int length;
    switch(Event)
    {
    case CP_RXCHAR: //это событие что есть байты во входном буфере читаем
        //кол-во байт занесено в arg
        BufferCount = p->ReadByts(Buffer, arg);
        length = ::GetWindowTextLength(hEditRecieved) + 1;
        
        char* text = new char[length+BufferCount];
        ::GetWindowText(hEditRecieved, text, length);
        memmove(&text[length-1], Buffer, BufferCount);
        text[length+BufferCount-1] = 0;
        ::SetWindowText(hEditRecieved, text);
 
        delete [] text;
        break;
    }
    return 0;
}

void CWorkCtrl::convBBufToDFrame(BYTE *buf, DEV_FRAME &df)
{
//  USHORT temp;
    USHORT t;
    t = buf[0];
    t=buf[1];
    t=buf[2];
    df.RegN[0] = ((USHORT)buf[3]) | (((USHORT)buf[4]) << 8) ;
    df.Tail[0] = ((USHORT)buf[5]) | (((USHORT)buf[6]) << 8) ;
    df.RegN[1] = ((USHORT)buf[7]) | (((USHORT)buf[8]) << 8) ;
    df.Tail[1] = ((USHORT)buf[9]) | (((USHORT)buf[10]) << 8) ;
    df.RegN[2] = ((USHORT)buf[11]) | (((USHORT)buf[12]) << 8) ;
    df.Tail[2] = ((USHORT)buf[13]) | (((USHORT)buf[14]) << 8) ;
    df.RegN[3] = ((USHORT)buf[15]) | (((USHORT)buf[16]) << 8) ;
    df.Tail[3] = ((USHORT)buf[17]) | (((USHORT)buf[18]) << 8) ;
    df.RegN[4] = ((USHORT)buf[19]) | (((USHORT)buf[20]) << 8) ;
    df.Tail[4] = ((USHORT)buf[21]) | (((USHORT)buf[22]) << 8) ;
    df.RegN[5] = ((USHORT)buf[23]) | (((USHORT)buf[24]) << 8) ;
    df.Tail[5] = ((USHORT)buf[25]) | (((USHORT)buf[26]) << 8) ;
    df.RegWind[0] = buf[27];
    df.RegWind[1] = buf[28];
    df.RegWind[2] = buf[29];
    df.RegWind[3] = buf[30];
}

//Добавляем в наш проект
#include "WorkCtrl.h"
 
 
//Создаем экземпляр класса
CWorkCtrl workCtrl;
 
//Это для выделения фрейма из потока
unsigned char buf_frame[31]; //буфер для фрейма
int index_frame = 0; //сколько в буфере лежит
 
//Вот как должна выглядеть функция в таком случае
LRESULT CALLBACK OnComPort(ComPort* p, unsigned int Event, unsigned short arg)
{
        switch(Event)
        {
        case CP_RXCHAR: //это событие что есть байты во входном буфере читаем
                //кол-во байт занесено в arg
                BufferCount = p->ReadByts(Buffer, arg);
                for( int i = 0; i< BufferCount; i++){
                        if( Buffer[i] == 0xE6 && (index_frame <= 1) )
                                buf_frame[index_frame++] = Buffer[i];
                        }else {
                                if( index_frame <= 1 ){
                                        index_frame = 0; continue;
                                }
                                buf_frame[index_frame++] = Buffer[i];
                                if( index_frame >= 31 ){
                                        //
                                        //Тут у тебя уже в массиве buf_frame
                                        //лежит кадр тот который нужен
                                        
                                        workCtrl.convBBufToDFrame(buf_frame, m_dfCurFrame);
                                        
                                        //
                                        //
                                        index_frame = 0;                                        
                                }
                        }
                }
                break;
        }
        return 0;
}