Бинарное чтение\ запись

Tmain_form      *main_form;
 
HANDLE          COMThread; // дескриптор главного потока, опрашивающего приборы
//===========================================================================
 
HANDLE fmtm_re ;
_SECURITY_ATTRIBUTES temp_mtm,Attr_val_or;
unsigned long l_ser_or,l_val_or;
 
 
 
//===========================================================================
int        __fastcall
Tmain_form::FormCreate(AnsiString &fmtm_re,AnsiString temp_mtm,
              int viRegime,int viSeek,int viNumber,int viType)
{
 HFILE       hFile;
 AnsiString  fmtm_re=temp_mtm+"\\"+fmtm_re;
 DWORD       dwCounter;
 OFSTRUCT    tOfStr;
 tOfStr.cBytes = sizeof tOfStr;
 // Открыть файл
 hFile = OpenFile(vasFileName.c_str(),&tOfStr,OF_READWRITE);
 if(hFile == HFILE_ERROR)
 {
  CloseHandle(HANDLE(hFile));
  //Сообщение об ошибке
  return 1;
 }
 BY_HANDLE_FILE_INFORMATION bhFileInformation;
 GetFileInformationByHandle
 (
  HANDLE(hFile), // Дескриптор файла
  // Адрес структуры, в которой сохраняется информация
  &bhFileInformation
 );
 viRazmer=bhFileInformation.nFileSizeLow;
 //сдвинуться
 switch(viType)
 {
  case 0:
   if(_llseek(hFile,viSeek*sizeof(int),0) != (long)(viSeek*sizeof(int)))
   {
    CloseHandle(HANDLE(hFile));
    //Сообщение об ошибке
   return 1;
   }
   break;
  case 1:
   if(_llseek(hFile,viSeek*sizeof(char),0) != (long)(viSeek*sizeof(char)))
   {
    CloseHandle(HANDLE(hFile));
    //Сообщение об ошибке
   return 1;
   }
  break;
 }
 // считать (записать)данные из (в) файл
 switch(viRegime)
 {
  case 1:
   if(viType == 0)
   {
    if(!WriteFile(HANDLE(hFile),virgRDWRBuff,
                  (DWORD)(viNumber*sizeof(int)),&dwCounter,0))
    {
     //Сообщение об ошибке
     CloseHandle(HANDLE(hFile));
    return 1;
    }
   }else
   {
    if(!WriteFile(HANDLE(hFile),(char far*) vchrgRDWRBuf,
               (DWORD)(viNumber*sizeof(char)),&dwCounter,0))
    {
     //Сообщение об ошибке
     CloseHandle(HANDLE(hFile));
     return 1;
    }
   }//if(viType == 0)
  break;
  case 0:
   if(viType == 0)
   {
    if(!ReadFile(HANDLE(hFile),virgRDWRBuff,
                (DWORD)(viNumber*sizeof(int)),&dwCounter,0))
    {
     //Сообщение об ошибке
     CloseHandle(HANDLE(hFile));
     return 1;
    }
   }else
   {
    if(!ReadFile(HANDLE(hFile),(char far*) vchrgRDWRBuf,
               (DWORD)(viNumber*sizeof(char)),&dwCounter,0))
    {
     //Сообщение об ошибке
     CloseHandle(HANDLE(hFile));
     return 1;
    }
   }//if(viType == 0)
  break;
 }//switch(viRegime)
 CloseHandle(HANDLE(hFile));
return 0;
}           /**/
 
//===========================================================================
//===========================================================================
//---------------------------------------------------------------------------
static const int BaudRate[] =
{
    CBR_110,     CBR_300,    CBR_600,    CBR_1200,    CBR_2400,    CBR_4800,
    CBR_9600,    CBR_14400,  CBR_19200,  CBR_38400,   CBR_56000,   CBR_57600,
    CBR_115200,  CBR_128000, CBR_256000
};
// Имена используемых портов:
//#define COM_Name(i) "COM"##i
static const char* COM_Name[] = {"COM3", "COM4", "COM5", "COM6"};
 
//-------------------------- ГЛОБАЛЬНЫЕ -------------------------------------
modbus_connection    connection; //
//int                  idx;        //
float                idx = 0.0f;
DWORD                dwThreadId, dwThrdParam = 1;
unsigned int         last_msec;   // время предыдущего опроса в мс от заспуска ОС
unsigned int         curr_msec;   // текущее время в мс от запуска ОС
float                data[4][13][5];
/** массив data[порт][прибор][канал] читамых данных
[порт]......0->COM3, 1->COM4, 2->COM5, 3->COM6;
[прибор]....1->MTM1, 2->MTM3, 4-12->НЕ_ИСП., 13->MTM13;
[канал].....0->0x130->1й_канал, 1->0х132->2й канал, ..., 5->0x13A->6й канал  **/
//com_port             port;        //
com_port             COM[4];      // массив портов
//---------------------------------------------------------------------------
#define MTM1         1
#define MTM2         2
#define MTM3         3
#define MTM4         4
#define MTM13       13
// #define MTM*** 0 // добвавить!
// register type:
#define REG0        0x130
#define REG1        0x132
#define REG2        0x134
#define REG3        0x136
#define REG4        0x138
#define REG5        0x13A
const int REG[] = {REG0, REG1, REG2, REG3, REG4, REG5};
// addres type:
#define HOLD_REG    0
#define IN_REEG     1
#define DI_REG      2
#define DO_REG      3
// data type:
#define DATA_INT    0
#define DATA_UINT   1
#define DATA_LONG   2
#define DATA_ULONG  3
#define DATA_FLOAT  4
#define DATA_DOUBLE 5
//---------------------------------------------------------------------------
#define PERIOD      1000 // период опроса датчиков в мс
#define WORK_COLOR  (TColor)0x008F00
#define DENY_COLOR  (TColor)0x0000D0
//---------------------------------------------------------------------------
/**/
#define Status(c,s) { \
    main_form->warnings->Font->Color = c; \
    main_form->warnings->Caption     = s; \
}
 
#define CHART_T main_form->chart_temp
#define CHART_L main_form->chart_level
 
#define SwitchSource(a, r) \
    connection.slave_address    = a; \
    connection.register_address = r;
 
//---------------------------------------------------------------------------
float GetData(com_port* prt, int addr, int reg, int serie)
{
    // переключение на <addr> прибор, <reg> регистр
    SwitchSource(addr, reg);
    //connection.slave_address    = addr;
    //connection.register_address = reg;
    // ожидание готовности порта (В СЛУЧАЕ ОТСУТСВИЯ ЦИКЛ БЕСКОНЕЧЕН!):
    while (!connection.get_sync(prt)) { Sleep(10); }
    // чтение данных из порта:
    return connection.get_raw_value(); // serie = 0...5
}
//---------------------------------------------------------------------------
void MAIN_LOOP ()
{
    while (!Application->Terminated) {
        //curr_msec = GetTickCount();
        // для редактирования компонентов не из основного потока:
        CHART_T->Locked = true; CHART_L->Locked = true;
        // опрос каналов с выводом в TChart (ДОБАВИТЬ ОПРОС ВСЕХ ПОРТОВ!!!):
        /***** ОПРОС 1го ДАТЧИКА: *****
        for (int regN=0; regN<6; regN++) {
            data[regN] = GetData(&COM[0], MTM1, REG[regN], regN); // взять данные с i-го канала
            CHART_T->Series[regN]->AddXY(idx, data[regN]); // вывод в форму
        } // for addrN
        /***** ОПРОС 2го ДАТЧИКА: *****/
        data[1][13][0] = GetData(&COM[1], MTM13, REG[0], 0); CHART_T->Series[0]->AddXY(idx, data[1][13][0],Time()); // ТЕМПЕРАТУРА эмульсии
        data[1][13][1] = GetData(&COM[1], MTM13, REG[1], 1); CHART_T->Series[1]->AddXY(idx, data[1][13][1],Time()); // ДАВЛЕНИЕ густой смазки
        data[1][13][2] = GetData(&COM[1], MTM13, REG[2], 1); CHART_L->Series[1]->AddXY(idx, data[1][13][2],Time()); // УРОВЕНЬ эмульсии в баке 1
        data[1][13][3] = GetData(&COM[1], MTM13, REG[3], 0); CHART_L->Series[0]->AddXY(idx, data[1][13][3],Time()); // УРОВЕНЬ эмульсии в баке 2
        data[1][13][5] = GetData(&COM[1], MTM13, REG[5], 0); CHART_T->Series[5]->AddXY(idx, data[1][13][5],Time()); // ТЕМПЕРАТУРА в пирометрической
 
        /**/
        // для редактирования компонентов не из основного потока:
        CHART_T->Locked = false; CHART_L->Locked = false;
        //Status(WORK_COLOR, "Связь: устройство готово");
        Sleep(PERIOD); // задержка размером в период опроса
        idx += PERIOD/1000.0; // ПЕРЕСЧИТАТЬ РЕАЛЬНОЕ ВРЕМЯ ДЛЯ ГРАФИКА!!!
 
 
//---------------------------------------------------------------------------
 
 
 
 
 /**  **/
    }
 
 
 
 
    // while !terminated
} // MAIN_LOOP /**/
//---------------------------------------------------------------------------
void Set_COM_props(com_port* port,    // адрес переменной с настройками порта
                   std::string _name     = "COM3",
                   const int   _BaudRate = CBR_9600,
                   int         _Parity   = 0,
                   int         _ByteSize = 8,
                   int         _StopBits = 0)
{
    port->system_name           = _name;
    port->dcb.DCBlength         = sizeof(port->dcb);
    port->dcb.BaudRate          = _BaudRate;
    port->dcb.fBinary           = true;
    port->dcb.fParity           = _Parity;
    port->dcb.fOutxCtsFlow      = false;
    port->dcb.fOutxDsrFlow      = false;
    port->dcb.fDtrControl       = DTR_CONTROL_DISABLE;
    port->dcb.fDsrSensitivity   = false;
    port->dcb.fTXContinueOnXoff = false;
    port->dcb.fOutX             = false;
    port->dcb.fInX              = false;
    port->dcb.fErrorChar        = false;
    port->dcb.fNull             = false;
    port->dcb.fRtsControl       = RTS_CONTROL_DISABLE;
    port->dcb.fAbortOnError     = false;
    port->dcb.ByteSize          = _ByteSize;
    port->dcb.Parity            = _Parity; // ????
    port->dcb.StopBits          = _StopBits;
    port->dcb.XonChar           = '\x11';
    port->dcb.XoffChar          = '\x13';
    port->dcb.ErrorChar         = '\x00';
    port->dcb.EofChar           = '\x00';
    port->dcb.EvtChar           = '\x00';
}
//---------------------------------------------------------------------------
#define COM_Name(i) ("COM"+IntToStr(i+3)).c_str()
//---------------------------------------------------------------------------
__fastcall Tmain_form::Tmain_form(TComponent* Owner) : TForm(Owner)
{
    // настройка регистра и типа передаваемых данных
    connection.address_type = HOLD_REG;
    connection.data_type    = DATA_FLOAT;
    // инициализация и открытие портов:
    for (int i=0; i<4; i++) { // проверить генерацию имени портов !!!
        Set_COM_props(&COM[i], COM_Name(i), CBR_9600, 0, 8, 0);
        COM[i].open();
        if (!COM[i].active())
            Application->MessageBox(("Ошибка открытия порта " + COM[i].system_name).c_str(), "Ошибка");
   } // for
    /**/
}
//---------------------------------------------------------------------------
void __fastcall Tmain_form::FormClose(TObject *Sender, TCloseAction &Action)
{
    CloseHandle(COMThread);
    for (int i=0; i<4; i++)
        COM[i].close();
    //port.close();
}
//---------------------------------------------------------------------------
void __fastcall Tmain_form::FormCreate(TObject *Sender)
{
    // настройка источника данных:
    SwitchSource(MTM1, REG1);
    connection.address_type = HOLD_REG;
    connection.data_type    = DATA_FLOAT;
    // создание потока:
    COMThread = CreateThread(  //BeginThread(
        NULL,                              // default security attributes
        0,                                 // use default stack size
        (LPTHREAD_START_ROUTINE)MAIN_LOOP, // thread function
        &dwThrdParam,                      // argument to thread function
        0,                                 // use default creation flags
        &dwThreadId);                      // returns the thread identifier
    //last_msec = GetTickCount();
 
 
} /**/