electrocardiograph_upper/mainwindow.cpp

#include "mainwindow.h"

#include <QDateTime>
#include <QMessageBox>
#include <QtConcurrent>
#include <QtSerialPort/QSerialPort>
#include <QtSerialPort/QSerialPortInfo>

#include "./ui_mainwindow.h"
#include "electrocardiograph_tester.hpp"
#include "logger.hpp"
#include "qt_serial_datachannel.hpp"
#include "zexception.hpp"

using namespace std;
using namespace iflytop;
typedef enum {
  kone_lead_ecg,
  kthree_lead_ecg,
} device_type_t;

static MainWindow   *m_mainWindow;
static QTDataChannel G_QTDataChannel;
static QTDataChannel G_WaveDataChannel;
static device_type_t m_devicetype;

#define TAG "MainWindow"

static const char *fmt(const char *fmt, ...) {
  va_list args;
  va_start(args, fmt);
  static char buf[1024] = {0};
  vsnprintf(buf, sizeof(buf), fmt, args);
  va_end(args);
  return buf;
}

void MainWindow::log_output(QtMsgType type, const QMessageLogContext &context, const QString &msg) {}
void MainWindow::doinui_slot(QFunction func) {
  if (func.get()) func.get()();
}

void MainWindow::instructionPreviewShow(const char *fmt, ...) {
  va_list args;
  va_start(args, fmt);
  char buf[1024] = {0};
  vsnprintf(buf, sizeof(buf), fmt, args);
  va_end(args);
  QString text(buf);
  QString info;

  info.append(QDateTime::currentDateTime().toString("hh:mm:ss.zzz "));
  info.append(" |");
  info.append(text);
  emit doinui_signal(QFunction([this, info]() { ui->instructionPreview->append(info); }));
}

void MainWindow::instructionPreviewClear() { ui->instructionPreview->document()->clear(); }

void MainWindow::reportPreviewShow(const char *fmt, ...) {
  va_list args;
  va_start(args, fmt);
  char buf[1024] = {0};
  vsnprintf(buf, sizeof(buf), fmt, args);
  va_end(args);
  QString text(buf);
  QString info;

  info.append(QDateTime::currentDateTime().toString("hh:mm:ss.zzz "));
  info.append(text);
  emit doinui_signal(QFunction([this, info]() {
    if (ui->reportPreview->document()->lineCount() > 1000) {
      ui->reportPreview->document()->clear();
    }
    ui->reportPreview->append(info);
  }));
}

void MainWindow::blockDataUploadPreviewShow(const char *fmt, ...) {
  va_list args;
  va_start(args, fmt);
  char buf[1024] = {0};
  vsnprintf(buf, sizeof(buf), fmt, args);
  va_end(args);
  QString text(buf);
  QString info;

  info.append(QDateTime::currentDateTime().toString("hh:mm:ss.zzz "));
  info.append(text);
  emit doinui_signal(QFunction([this, info]() {
    if (ui->uploadDataPreview->document()->lineCount() > 1000) {
      ui->uploadDataPreview->document()->clear();
    }
    ui->uploadDataPreview->append(info);
  }));
}
void MainWindow::rawDataPreviewShow(const char *fmt, ...) {
  va_list args;
  va_start(args, fmt);
  char buf[1024] = {0};
  vsnprintf(buf, sizeof(buf), fmt, args);
  va_end(args);
  QString text(buf);
  QString info;

  info.append(QDateTime::currentDateTime().toString("hh:mm:ss.zzz"));
  info.append(text);
  emit doinui_signal(QFunction([this, info]() {
    if (ui->rawDataPreview->document()->lineCount() > 1000) {
      ui->rawDataPreview->document()->clear();
    }
    ui->rawDataPreview->append(info);
  }));
}
// uploadDataPreview

#pragma pack(push, 1)
typedef struct {
  uint16_t header;
  int16_t  wave1;
  int16_t  wave2;
  int16_t  wave3;
  int16_t  wave4;
  int16_t  wave5;
  uint8_t  check;
  uint16_t tail;
} Wave_t;
#pragma pack(pop)

void MainWindow::displayWave(int16_t wave1, int16_t wave2, int16_t wave3) {
  // 1. 生成波形数据
  Wave_t wave;
  wave.header = 0xAAAA;
  wave.wave1  = wave1;
  wave.wave2  = wave2;
  wave.wave3  = wave3;
  wave.wave4  = 0;
  wave.wave5  = 0;
  wave.tail   = 0x5555;
  wave.check  = 0;

  uint8_t check = 0;
  for (size_t i = 2; i < sizeof(wave) - 2; i++) {
    check += ((uint8_t *)&wave)[i];
  }
  wave.check = check;
  // 2. 发送波形数据
  G_WaveDataChannel.send((uint8_t *)&wave, sizeof(wave));
}

void MainWindow::displayInfo(bool suc, QString info) {}

MainWindow::MainWindow(QWidget *parent) : QMainWindow(parent), ui(new Ui::MainWindow) {
  /*******************************************************************************
   *                                  QT初始化                                   *
   *******************************************************************************/
  ui->setupUi(this);
  m_mainWindow = this;
  qRegisterMetaType<int32_t>("int32_t");
  qRegisterMetaType<uint32_t>("uint32_t");
  qRegisterMetaType<float>("float");
  qRegisterMetaType<function<void()>>("function<void()>");
  qRegisterMetaType<QFunction>("QFunction");
  connect(this, SIGNAL(doinui_signal(QFunction)), this, SLOT(doinui_slot(QFunction)));
  // qInstallMessageHandler(log_output);

  /*******************************************************************************
   *                               页面逻辑初始化                                *
   *******************************************************************************/
  constructUI();

  /*******************************************************************************
   *                                业务逻辑构造                                 *
   *******************************************************************************/
  G_QTDataChannel.init();
  G_WaveDataChannel.init();
  ElectrocardiographTester::ins()->initialize(&G_QTDataChannel);
}
MainWindow::~MainWindow() { delete ui; }

/*******************************************************************************
 *                                 UI相关构造                                  *
 *******************************************************************************/
void MainWindow::constructUI() {
  /*******************************************************************************
   *                                 指令串口UI                                  *
   *******************************************************************************/
  {
    const auto infos = QSerialPortInfo::availablePorts();
    for (const QSerialPortInfo &info : infos) {
      ui->serialPortCB->addItem(info.portName());
    }
  }

  ui->serialBaudrateCB->addItem("9600");
  ui->serialBaudrateCB->addItem("14400");
  ui->serialBaudrateCB->addItem("19200");
  ui->serialBaudrateCB->addItem("38400");
  ui->serialBaudrateCB->addItem("57600");
  ui->serialBaudrateCB->addItem("115200");
  ui->serialBaudrateCB->addItem("460800");
  ui->serialBaudrateCB->addItem("500000");
  ui->serialBaudrateCB->setCurrentIndex(6);

  connect(ui->serialPortRefreshKey, &QPushButton::clicked, this, [this](bool check) {
    ui->serialPortCB->clear();
    const auto infos = QSerialPortInfo::availablePorts();
    for (const QSerialPortInfo &info : infos) {
      ui->serialPortCB->addItem(info.portName());
    }
  });

  connect(ui->serialOpenKey, &QPushButton::clicked, this, [=](bool check) {
    // 打开串口
    if (ui->serialOpenKey->text() == "打开") {
      G_QTDataChannel.setPortName(ui->serialPortCB->currentText().toStdString());
      G_QTDataChannel.setBaudRate(ui->serialBaudrateCB->currentText().toInt());
      G_QTDataChannel.setDataBits(QSerialPort::Data8);
      G_QTDataChannel.setParity(QSerialPort::NoParity);
      G_QTDataChannel.setFlowControl(QSerialPort::NoFlowControl);
      G_QTDataChannel.setStopBits(QSerialPort::OneStop);

      if (!G_QTDataChannel.open()) {
        QMessageBox::about(NULL, "提示", "串口无法打开，串口不存在或已被占??");
        return;
      }
      ui->serialOpenKey->setText("关闭");
      // 下拉菜单控件使能
      ui->serialBaudrateCB->setEnabled(false);
      ui->serialPortCB->setEnabled(false);
      ui->serialPortRefreshKey->setEnabled(false);
    } else {
      G_QTDataChannel.close();
      ui->serialOpenKey->setText("打开");
      ui->serialBaudrateCB->setEnabled(true);
      ui->serialPortCB->setEnabled(true);
      ui->serialPortRefreshKey->setEnabled(true);
    }
  });

  /*******************************************************************************
   *                                 波形串口UI                                  *
   *******************************************************************************/
  {
    const auto infos = QSerialPortInfo::availablePorts();
    for (const QSerialPortInfo &info : infos) {
      ui->waveSerialPortCB->addItem(info.portName());
    }
  }

  ui->waveSerialBaudrateCB->addItem("9600");
  ui->waveSerialBaudrateCB->addItem("14400");
  ui->waveSerialBaudrateCB->addItem("19200");
  ui->waveSerialBaudrateCB->addItem("38400");
  ui->waveSerialBaudrateCB->addItem("57600");
  ui->waveSerialBaudrateCB->addItem("115200");
  ui->waveSerialBaudrateCB->addItem("460800");
  ui->waveSerialBaudrateCB->addItem("500000");
  ui->waveSerialBaudrateCB->setCurrentIndex(6);

  connect(ui->waveSerialPortRefreshKey, &QPushButton::clicked, this, [this](bool check) {
    ui->waveSerialPortCB->clear();
    const auto infos = QSerialPortInfo::availablePorts();
    for (const QSerialPortInfo &info : infos) {
      ui->waveSerialPortCB->addItem(info.portName());
    }
  });

  connect(ui->waveSerialOpenKey, &QPushButton::clicked, this, [=](bool check) {
    // 打开串口
    if (ui->waveSerialOpenKey->text() == "打开") {
      G_WaveDataChannel.setPortName(ui->waveSerialPortCB->currentText().toStdString());
      G_WaveDataChannel.setBaudRate(ui->waveSerialBaudrateCB->currentText().toInt());
      G_WaveDataChannel.setDataBits(QSerialPort::Data8);
      G_WaveDataChannel.setParity(QSerialPort::NoParity);
      G_WaveDataChannel.setFlowControl(QSerialPort::NoFlowControl);
      G_WaveDataChannel.setStopBits(QSerialPort::OneStop);

      if (!G_WaveDataChannel.open()) {
        QMessageBox::about(NULL, "提示", "串口无法打开，串口不存在或已被占??");
        return;
      }
      ui->waveSerialOpenKey->setText("关闭");
      // 下拉菜单控件使能
      ui->waveSerialBaudrateCB->setEnabled(false);
      ui->waveSerialPortCB->setEnabled(false);
      ui->waveSerialPortRefreshKey->setEnabled(false);
    } else {
      G_WaveDataChannel.close();
      ui->waveSerialOpenKey->setText("打开");
      ui->waveSerialBaudrateCB->setEnabled(true);
      ui->waveSerialPortCB->setEnabled(true);
      ui->waveSerialPortRefreshKey->setEnabled(true);
    }
  });

  // 事件填充
  ElectrocardiographTester::ins()->regReportCB([this](bool checkok, ify_hrs_packet_t *report_packet, size_t len) {
    int reportType = report_packet->cmd;
    switch (reportType) {
      case ify_hrs_report_heartrate_data: {
        heartrate_report_packet_t *heartrate_report = (heartrate_report_packet_t *)report_packet;
        // reportPreviewShow("[preview data  ]  index %llu", heartrate_report->sample_data_index);

        uint16_t header = 0xA55A;
        uint16_t tail   = 0xB55B;
        G_WaveDataChannel.send((uint8_t *)&header, sizeof(header));
        G_WaveDataChannel.send((uint8_t *)report_packet, len);
        G_WaveDataChannel.send((uint8_t *)&tail, sizeof(tail));

        // if (m_devicetype == kone_lead_ecg) {
        reportPreviewShow("[preview data  ] checksum_ok:%d index %llu", checkok, heartrate_report->sample_data_index);
        // } else if (m_devicetype == kthree_lead_ecg) {
        // displayWave(heartrate_report->data[0], heartrate_report->data[1], heartrate_report->data[2]);
        // }

        break;
      }
      case ify_hrs_report_battery_level: {
        reportPreviewShow("[battery_level ]");
        break;
      }
      case ify_hrs_report_low_battey_level: {
        reportPreviewShow("[low_battey    ]");
        break;
      }
      case ify_hrs_report_sample_finish_end: {
        reportPreviewShow("[sample_finish ]");
        break;
      }
      case ify_hrs_report_sensor_drop_detect: {
        sensor_drop_event_report_packet_t *sensor_drop_report = (sensor_drop_event_report_packet_t *)report_packet->data;
        reportPreviewShow("[sensor_drop   ] %s %s", zhex2binary(sensor_drop_report->drop_state0).c_str(), zhex2binary(sensor_drop_report->drop_state1).c_str());
        break;
      }
      case ify_hrs_report_record_upload_end: {
        uint32_t checksum = *(uint32_t *)report_packet->data;
        reportPreviewShow("[upload end    ]  checksum: 0x%08x", checksum);
        break;
      }
      default:
        break;
    }
  });

  ElectrocardiographTester::ins()->regCh4CheckSumPacketReport([this](uint32_t rxcnt, uint32_t report_packet_checksum) {  //
    blockDataUploadPreviewShow("RXCNT %d  CHECKSUM 0x%08x", rxcnt, report_packet_checksum);
  });
  ElectrocardiographTester::ins()->regRawDataCB([this](raw_data_type_t type, uint8_t *hex, uint32_t hexlen) {
    if (type == kcmd_cmd) {
      rawDataPreviewShow("[CMD    ] %s", zhex2str(hex, hexlen).c_str());
    } else if (type == kcmd_receipt) {
      rawDataPreviewShow("[RECEIPT] %s", zhex2str(hex, hexlen).c_str());
    } else if (type == kcmd_report) {
      rawDataPreviewShow("[REPORT ] %s", zhex2str(hex, hexlen).c_str());
    } else if (type == kcmd_ch4_data) {
      // rawDataPreviewShow("[CH4    ] %s", zhex2str(hex, hexlen).c_str());
    }
  });
}

void MainWindow::processException(zexception &e) { instructionPreviewShow("%s:%s", e.what(), hrs_ecode2str((ify_hrs_error_code_t)e.ecode())); }

void MainWindow::on_readDeviceVersion_clicked() {
  instructionPreviewClear();
  try {
    device_version_info_receipt_t version;
    ElectrocardiographTester::ins()->readDeviceVersion(&version);
    instructionPreviewShow("-------------- version ----------------");
    instructionPreviewShow(" blestack_version:   %d", version.blestack_version);
    instructionPreviewShow(" bootloader_version: %d", version.bootloader_version);
    instructionPreviewShow(" firmware_version:   %d", version.firmware_version);
    instructionPreviewShow(" hardware_version:   %d", version.hardware_version);
  } catch (zexception &exception) {
    processException(exception);
  }
}

void MainWindow::on_readDeviceState_clicked() {
  instructionPreviewClear();
  try {
    device_state_receipt_t state;
    ElectrocardiographTester::ins()->readDeviceState(&state);
    instructionPreviewShow("-------------- state ----------------");
    instructionPreviewShow(" drop_state0:       %s", zhex2binary(state.drop_state0).c_str());
    instructionPreviewShow(" drop_state1:       %s", zhex2binary(state.drop_state1).c_str());

    instructionPreviewShow(" sampling_state:    %d", state.device_state0.sampling_state);
    instructionPreviewShow(" report_state:      %d", state.device_state0.report_state);
    instructionPreviewShow(" low_battery:       %d", state.device_state0.low_battery);
    instructionPreviewShow(" full_storge:       %d", state.device_state0.full_storge);
    instructionPreviewShow(" holder:            %d", state.device_state0.holder);
    instructionPreviewShow(" powerlevel:        %d", state.powerlevel);
    instructionPreviewShow(" storage_item_num:  %d", state.storage_item_num);
  } catch (zexception &exception) {
    processException(exception);
  }
}

void MainWindow::on_readTime_clicked() {
  instructionPreviewClear();
  try {
    read_time_receipt_t time;
    ElectrocardiographTester::ins()->readTime(&time);
    instructionPreviewShow("-------------- time ----------------");
    instructionPreviewShow(" %d/%d/%d %d:%d:%d", time.year + 2000, time.month, time.day, time.hour, time.minute, time.second);

  } catch (zexception &exception) {
    processException(exception);
  }
}

void MainWindow::on_syncTime_clicked() {
  instructionPreviewClear();
  try {
    // 获取系统时间
    QDateTime now = QDateTime::currentDateTime();
    ElectrocardiographTester::ins()->syncTime(now.date().year() - 2000, now.date().month(), now.date().day(), now.time().hour(), now.time().minute(), now.time().second());
    instructionPreviewShow("sync time success!");
  } catch (zexception &exception) {
    processException(exception);
  }
}

std::string zhex2time(const uint8_t *hex, size_t len) {
  std::string str;
  if (len < 6) return str;
  str.append(fmt("%d/%d/%d %2d:%2d:%2d", hex[0] + 2000, hex[1], hex[2], hex[3], hex[4], hex[5]));
  return str;
}

void MainWindow::on_readAllRecords_clicked() {
  // 读取当前有多少条记录
  instructionPreviewClear();
  try {
    device_state_receipt_t state;
    ElectrocardiographTester::ins()->readDeviceState(&state);
    instructionPreviewShow("index recordid       frameNum dataSize sensorNum captRate captPrec compAlgo checksum");
    for (int32_t i = 0; i < state.storage_item_num; i++) {
      read_record_info_receipt_t record;
      ElectrocardiographTester::ins()->readRecordsInfo(i, &record);
      instructionPreviewShow("%d   %s %8d %8d %8d %8d %8d %8d 0x%08x", i, zhex2time(record.record_id, 6).c_str(), record.frameNum, record.dataSize, record.sensorNum, record.captureRate, record.capturePrecision, record.compressAlgorithm, record.checksum);
    }
  } catch (zexception &exception) {
    processException(exception);
  }
}

void MainWindow::on_startUploadRecord_clicked() {
  instructionPreviewClear();
  int reportIndex = ui->startUploadRecord_p0->toPlainText().toInt();
  try {
    read_record_info_receipt_t record;
    ElectrocardiographTester::ins()->readRecordsInfo(reportIndex, &record);
    ElectrocardiographTester::ins()->startUploadRecord(record.record_id);
    instructionPreviewShow("start upload record [%s] success", zhex2time(record.record_id, 6).c_str());
  } catch (zexception &exception) {
    processException(exception);
  }
}

void MainWindow::on_readSensorInfo_clicked() {
  instructionPreviewClear();
  try {
    sensor_info_receipt_t sensor;
    ElectrocardiographTester::ins()->readSensorInfo(&sensor);
    instructionPreviewShow("-------------- sensor ----------------");
    instructionPreviewShow(" sensor_num:        %d", sensor.sensor_num);
    instructionPreviewShow(" sensor_precision:  %d", sensor.sensor_precision);
    instructionPreviewShow(" sensor_sample_rate:%d", sensor.sensor_sample_rate);
    instructionPreviewShow(" sensor0_pos:       %d", sensor.sensor0_pos);
    instructionPreviewShow(" sensor1_pos:       %d", sensor.sensor1_pos);
    instructionPreviewShow(" sensor2_pos:       %d", sensor.sensor2_pos);
  } catch (zexception &exception) {
    processException(exception);
  }
}

void MainWindow::on_readSN_clicked() {
  instructionPreviewClear();
  try {
    string sn;
    ElectrocardiographTester::ins()->readSn(sn);
    instructionPreviewShow("-------------- sn ----------------");
    instructionPreviewShow(" sn: %s", sn.c_str());
  } catch (zexception &exception) {
    processException(exception);
  }
}

void MainWindow::on_stopUploadRecord_clicked() {
  instructionPreviewClear();
  try {
    ElectrocardiographTester::ins()->stopUploadRecord();
    instructionPreviewShow("stop upload record success");
  } catch (zexception &exception) {
    processException(exception);
  }
}

void MainWindow::on_delRecord_clicked() {
  instructionPreviewClear();
  int reportIndex = ui->delRecord_p0->toPlainText().toInt();
  try {
    read_record_info_receipt_t record;
    ElectrocardiographTester::ins()->readRecordsInfo(reportIndex, &record);
    ElectrocardiographTester::ins()->delRecord(record.record_id);
    instructionPreviewShow("delete record [%s] success", zhex2time(record.record_id, 6).c_str());
  } catch (zexception &exception) {
    processException(exception);
  }
}

void MainWindow::on_startCapture_clicked() {
  instructionPreviewClear();
  try {
    ElectrocardiographTester::ins()->startCapture();
    instructionPreviewShow("start capture success");
  } catch (zexception &exception) {
    processException(exception);
  }
}

void MainWindow::on_stopCapture_clicked() {
  instructionPreviewClear();
  try {
    ElectrocardiographTester::ins()->stopCapture();
    instructionPreviewShow("stop capture success");
  } catch (zexception &exception) {
    processException(exception);
  }
}

void MainWindow::on_startRealtimeReport_clicked() {
  instructionPreviewClear();
  try {
    ElectrocardiographTester::ins()->startRealtimeReport();
    instructionPreviewShow("start realtime report success");
  } catch (zexception &exception) {
    processException(exception);
  }
}

void MainWindow::on_stopRealtimeReport_clicked() {
  instructionPreviewClear();
  try {
    ElectrocardiographTester::ins()->stopRealtimeReport();
    instructionPreviewShow("stop realtime report success");
  } catch (zexception &exception) {
    processException(exception);
  }
}

void MainWindow::on_clearPreview_clicked() {
  ui->reportPreview->document()->clear();
  ui->uploadDataPreview->document()->clear();
  ui->rawDataPreview->document()->clear();
  ui->instructionPreview->document()->clear();
}