#include "mainwindow.h"

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

#include "./ui_mainwindow.h"
#include "camera_light_src_timing_controller/qt_serial_datachannel.hpp"
#include "logger.hpp"
#include "xsync_regs.hpp"

using namespace iflytop;
using namespace clst;
using namespace std;

static MainWindow    *m_mainWindow;
static CLSTControler *m_clstc;
#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;
}

static const uint32_t str2int(QString str) {
  // 如果0x开头，按16进制转换
  // 如果0b开头，按2进制转换
  // 否则按10进制转换
  // 去除掉str中_
  str.remove("_");

  if (str.startsWith("0x")) {
    return str.toUInt(nullptr, 16);
  } else if (str.startsWith("0b")) {
    // remove 0b
    str.remove(0, 2);
    return str.toUInt(nullptr, 2);
  } else {
    return str.toUInt(nullptr, 10);
  }
}
static QSerialPort   G_SerialPort;
static QTDataChannel G_QTDataChannel;

static const QString zaferror_to_str(zaf_error_code_t value) {
  if (value == kaf_ec_overtime) {
    return "操作超时";
  } else if (value == kaf_ec_device_notopen) {
    return "设备未打开";
  } else {
    return "未知错误";
  }
}

#define DO(action)                                             \
  {                                                            \
    zaf_error_code_t ecode = action;                           \
    if (ecode != kaf_ec_success) {                             \
      ui->informationBrowser->setText(zaferror_to_str(ecode)); \
      return;                                                  \
    }                                                          \
  }

void MainWindow::log_output(QtMsgType type, const QMessageLogContext &context, const QString &msg) {
  // QString text;
  // text.append(msg);
}
// void MainWindow::append_log_slot(QString text) { ui->logbrowser->append(text); }
void MainWindow::doinui_slot(QFunction func) {
  if (func.get()) func.get()();
}

void MainWindow::constructUI() {
  /*******************************************************************************
   *                                serialPortCB                                 *
   *******************************************************************************/
  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->setCurrentIndex(5);

  /*******************************************************************************
   *                                  刷新串口                                   *
   *******************************************************************************/
  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_SerialPort.setPortName(ui->serialPortCB->currentText());
      if (G_SerialPort.open(QIODevice::ReadWrite)) {
        G_SerialPort.setBaudRate(ui->serialBaudrateCB->currentText().toInt());
        G_SerialPort.setDataBits(QSerialPort::Data8);
        G_SerialPort.setParity(QSerialPort::NoParity);
        G_SerialPort.setFlowControl(QSerialPort::NoFlowControl);
        G_SerialPort.setStopBits(QSerialPort::OneStop);
      } else {
        QMessageBox::about(NULL, "提示", "串口无法打开，串口不存在或已被占用");
        return;
      }
      ui->serialOpenKey->setText("关闭");
      // 下拉菜单控件使能
      ui->serialBaudrateCB->setEnabled(false);
      ui->serialPortCB->setEnabled(false);
      ui->serialPortRefreshKey->setEnabled(false);
    } else {
      G_SerialPort.close();
      ui->serialOpenKey->setText("打开");
      ui->serialBaudrateCB->setEnabled(true);
      ui->serialPortCB->setEnabled(true);
      ui->serialPortRefreshKey->setEnabled(true);
    }
  });

  /*******************************************************************************
   *                                  刷新页面                                   *
   *******************************************************************************/
  connect(ui->refreshPageKey, &QPushButton::clicked, this, [=](bool check) {  //

  });

  /*******************************************************************************
   *                                  保存配置                                   *
   *******************************************************************************/
  connect(ui->storageConfigKey, &QPushButton::clicked, this, [=](bool check) {  //
    DO(m_clstc->storageConfigs());
    ui->informationBrowser->setText("保存配置成功");
  });

  /*******************************************************************************
   *                                  重启设备                                   *
   *******************************************************************************/
  connect(ui->rebootDeviceKey, &QPushButton::clicked, this, [=](bool check) {  //
    DO(m_clstc->reboot());
    ui->informationBrowser->setText("重启设备成功");
  });

  /*******************************************************************************
   *                                恢复出厂设置                                 *
   *******************************************************************************/
  connect(ui->factoryResetKey, &QPushButton::clicked, this, [=](bool check) {  //
    DO(m_clstc->factoryReset());
    ui->informationBrowser->setText("恢复出厂设置成功");
  });
}

MainWindow::MainWindow(QWidget *parent) : QMainWindow(parent), ui(new Ui::MainWindow) {
  G_QTDataChannel.bind(&G_SerialPort);
  CLSTControler::ins()->initialize(&G_QTDataChannel);
  m_clstc = CLSTControler::ins();

  ui->setupUi(this);
  m_mainWindow = this;

  qRegisterMetaType<int32_t>("int32_t");
  qRegisterMetaType<uint32_t>("uint32_t");
  qRegisterMetaType<function<void()>>("function<void()>");
  qRegisterMetaType<QFunction>("QFunction");
  // qInstallMessageHandler(log_output);
  connect(this, SIGNAL(doinui_signal(QFunction)), this, SLOT(doinui_slot(QFunction)));
  constructUI();

  m_clstc->regRawDataListener([this](uart_message_type_t type, uint8_t *data, size_t len) {
    QString text;
    if (type == kuart_raw_tx) {
      text.append("TX: ");
      for (size_t i = 0; i < len; i++) {
        text.append(fmt("%02X ", data[i]));
      }
    } else if (type == kuart_raw_rx) {
      text.append("RX: ");
      for (size_t i = 0; i < len; i++) {
        text.append(fmt("%02X ", data[i]));
      }
    }
    emit doinui_signal(QFunction([this, text]() {
      if (ui->instructionPreview->document()->lineCount() > 20) {
        ui->instructionPreview->clear();
      }
      ui->instructionPreview->append(text);
    }));
  });
}

MainWindow::~MainWindow() { delete ui; }