grf_reader.cpp

#include "grf_reader.h"
#include "mainwindow.h"

/**
 * @brief GRF_Reader::GRF_Reader
 * @param file_name
 *
 * Ñîçäàåì îáúåêò ôàéëà, îòêðûâàþ ôàéë â ðåæèìå ÷òåíèÿ è çàïèñè.
 * Çàòåì çàãðóæàþ ñîäåðæèìîå ôàéëà â áóôåð memfile.
 */
GRF_Reader::GRF_Reader(QString &file_name) {
  utf_codec = QTextCodec::codecForName("Windows-1251");
  memfile = NULL;
  stream = NULL;
  error_flag = false;             //Îøèáîê íåò
  grf_fil = new QFile(file_name); //Ñîçäàåì îáúåêò ôàéëà
  if (grf_fil->exists()) {
    grf_fil->open(
        QIODevice::ReadWrite); //Îòêðûâàåì ôàéë â ðåæèìå ÷òåíèÿ è çàïèñè
    memfile = new QByteArray(grf_fil->readAll()); //çàãðóæàþ ôàéë â ïàìÿòü
    stream = new QDataStream(memfile, QIODevice::ReadWrite); //Ñîçäàþ îáúåêò
    //ïîòîêîâîãî ââîäà
    //âûâîäà â áóôåð
    // memfile
    stream->setByteOrder(
        QDataStream::LittleEndian); //Óñòàíàâëèâàþ ïðÿìîé ïîðÿäîê áàéò â ïîòîêå

    *stream >> records_type; //Ñ÷èòûâàþ Òèï çàïèñåé
    *stream >> record_count; //Ñ÷èòûâàþ Êîëè÷åñòâî çàïèñåé
                             /*
                                                   * Ïðîâåðÿåì ÷èñëî çàïèñåé è òèï íà êîððåêòíîñòü
                                                   */
    if (record_count < 1000 &&
        (records_type == RECTYPE || records_type == RECTYPE_NEW ||
         records_type == RECTYPE_OLD)) {
      //((MainWindow *)parent_wdg_ptr)
      //    ->setStatusLabelText(
      //        "Ôàéë îòãðóçêè çàãðóæåí"); //Âûâîäèì òåêñò îøèáêè â statusbar
    } else {
      error_flag = true;
      //((MainWindow *)parent_wdg_ptr)
      //    ->setStatusLabelText(
      //        "Íåèçâåñòíûé ôîðìàò ôàéëà"); //Âûâîäèì òåêñò îøèáêè â statusbar
    }
  } else {
    error_flag =
        true; //Åñëè ôàéëà íå ñóùåñòâóåò, òî óñòàíàâëèâàåì ïðèçíàê îøèáêè
    //((MainWindow *)parent_wdg_ptr)
    //    ->setStatusLabelText(
    //        "Îøèáêà ÷òåíèÿ ôàéëà"); //Âûâîäèì òåêñò îøèáêè â statusbar
    delete grf_fil;
  }
}

/*!
 * \brief GRF_Reader::~GRF_Reader Äåñòðóêòîð êëàññà. Î÷èùàåò âñå ïîëÿ êëàññà.
 */
GRF_Reader::~GRF_Reader() {
  /* Ñáðàñûâàþ ïîòîê ââîäà/âûâîäà â áóôåð */
  this->stream->unsetDevice();
  this->stream->resetStatus();
  /* Óäàëÿþ óêàçàòåëü íà îáúåêò ïîòîêà */
  delete this->stream;
  /* Î÷èùàþ áóôåð ôàéëà */
  this->memfile->clear();
  /* Óäàëÿþ óêàçàòåëü íà áóôåð */
  delete this->memfile;

  /* Î÷èùàþ è óäàëÿþ ìàññèâû çàïèñåé, çàãðóæåííûå â ïàìÿòü */
  for (int i = 0; i < record_count; i++) {
    if (records_type == RECTYPE) {
      this->recs[i].currency_array->clear();
      this->recs[i].speed_array->clear();
      delete this->recs[i].r;
    }
    if (records_type == RECTYPE_NEW) {
      this->newrecs[i].currency_array->clear();
      this->newrecs[i].speed_array->clear();
      delete this->newrecs[i].r;
    }
    if (records_type == RECTYPE_OLD) {
      this->oldrecs[i].currency_array->clear();
      this->oldrecs[i].speed_array->clear();
      delete this->oldrecs[i].r;
    }
  }
  if (records_type == RECTYPE) {
    delete this->recs;
  }
  if (records_type == RECTYPE_NEW) {
    delete this->newrecs;
  }
  if (records_type == RECTYPE_OLD) {
    delete this->oldrecs;
  }
}

/**
* @brief GRF_Reader::SetParentWidgetPointer    Óñòàíîâèòü óêàçàòåëü íà îáúåêò
* ðîäèòåëüñêîãî îêíà
* @param w Óêàçàòåëü
*/
void GRF_Reader::SetParentWidgetPointer(void *w) { this->parent_wdg_ptr = w; }

#include "mainwindow.h"

/*!
 * \brief GRF_Reader::BeginReading
 */
void GRF_Reader::BeginReading(void *w) {
  /*
 *  Ïî òèïó çàïèñåé, ñ÷èòàííîãî èç ôàéëà, âûäåëÿåì ïàìÿòü ïîä îïðåäåëåííûé
 * ìàññèâ
 */
  MainWindow *wnd = reinterpret_cast<MainWindow *>(w);
  if (records_type == RECTYPE)
    this->recs = new st_record<Record>[record_count];
  if (records_type == RECTYPE_NEW)
    this->newrecs = new st_record<NewRecord>[record_count];
  if (records_type == RECTYPE_OLD)
    this->oldrecs = new st_record<OldRecord>[record_count];
  /*
   * Öèêë ñ÷èòûâàíèÿ çàïèñåé â ìàññèâ.
   * Ïî òèïó çàïèñè îïðåäåëÿåì ÷òî è êóäà íàäî ñ÷èòûâàòü.
   * Ïîñëå ÷òåíèÿ îäíîé çàïèñè, âûäåëÿþ ìåñòî ïîä ìàññèâ ñîðîñòè è òîêà.
   * Çàòåì ñ÷èòûâàþ ìàññèâû.
   */
  for (int i = 0; i < record_count; i++) {
    if (records_type == RECTYPE) {
      ReadRecord(&recs[i]);
      wnd->SetTable(recs[i].r);
    }
    if (records_type == RECTYPE_NEW) {
      ReadRecord(&newrecs[i]);
      wnd->SetTable(newrecs[i].r);
    }
    if (records_type == RECTYPE_OLD) {
      ReadRecord(&oldrecs[i]);
      wnd->SetTable(oldrecs[i].r);
    }
  }
}

/*!
 * \brief GRF_Reader::ReadRecord
 * \param record
 * Ôóíêöèÿ ñ÷èòûâàåò îäíó çàïèñü èç ôàéëà îòãðóçêè
 */
void GRF_Reader::ReadRecord(st_record<Record> *record) {
  record->currency_array = NULL;
  record->r = new Record();
  record->speed_array = NULL;
  // Ñ÷èòûâàþ îäíó çàïèñü
  stream->readRawData((char *)record->r, sizeof(Record));
  // Âûäåëÿþ ìåñòî ïîä ìàññèâû
  record->speed_array = new QVector<quint16>(record->r->count);
  record->currency_array = new QVector<quint16>(record->r->count);
  // Ñ÷èòûâàþ ìàññèâû
  stream->readRawData((char *)record->currency_array->data(),
                      sizeof(quint16) * record->r->count);
  stream->readRawData((char *)record->speed_array->data(),
                      sizeof(quint16) * record->r->count);
  quint16 t;
  *stream >> t;
}

/*!
 * \brief GRF_Reader::ReadRecord
 * \param record
 */
void GRF_Reader::ReadRecord(st_record<NewRecord> *record) {
  record->currency_array = NULL;
  record->r = new NewRecord();
  record->speed_array = NULL;
  //Ñ÷èòûâàþ îäíó çàïèñü
  stream->readRawData((char *)record->r, sizeof(NewRecord));
  // Âûäåëÿþ ìåñòî ïîä ìàññèâû
  record->speed_array = new QVector<quint16>(record->r->count);
  record->currency_array = new QVector<quint16>(record->r->count);
  //Ñ÷èòûâàþ ìàññèâû
  stream->readRawData((char *)record->currency_array->data(),
                      sizeof(quint16) * record->r->count);
  stream->readRawData((char *)record->speed_array->data(),
                      sizeof(quint16) * record->r->count);
  quint8 t;
  *stream >> t;
}
/*!
 * \brief GRF_Reader::ReadRecord
 * \param record
 */
void GRF_Reader::ReadRecord(st_record<OldRecord> *record) {
  record->currency_array = NULL;
  record->r = new OldRecord();
  record->speed_array = NULL;
  //Ñ÷èòûâàþ îäíó çàïèñü
  stream->readRawData((char *)record->r, sizeof(NewRecord));
  // Âûäåëÿþ ìåñòî ïîä ìàññèâû
  record->speed_array = new QVector<quint16>(record->r->count);
  record->currency_array = new QVector<quint16>(record->r->count);
  //Ñ÷èòûâàþ ìàññèâû
  for (int j = 0; j < 2 * record->r->count; j++) {
    if (j < record->r->count)
      stream->readRawData((char *)&record->currency_array[j], 2);
    else
      stream->readRawData((char *)&record->speed_array[j], 2);
  }
}