117 lines
2.4 KiB
C++
117 lines
2.4 KiB
C++
#pragma once
|
|
|
|
#include <QMainWindow>
|
|
#include <QMap>
|
|
#include <QtSerialPort/QSerialPortInfo>
|
|
#include <QtSerialPort/QSerialPort>
|
|
#include <QFile>
|
|
#include <QTimer>
|
|
|
|
#include "asio.hpp"
|
|
#include "MQTTOpenration.h"
|
|
#include "log_utils.h"
|
|
#include "SeriaPort.h"
|
|
|
|
#include "BijectiveMap.hpp"
|
|
|
|
|
|
using namespace SerialPortTools;
|
|
|
|
namespace Ui
|
|
{
|
|
class CommunicationWgtClass;
|
|
}
|
|
|
|
class CommunicationWgt : public QMainWindow
|
|
{
|
|
Q_OBJECT
|
|
|
|
public:
|
|
explicit CommunicationWgt(QWidget* parent = nullptr);
|
|
~CommunicationWgt();
|
|
|
|
signals:
|
|
void sigMqttCallback(QString strTopic, QString strMessage);
|
|
void sigMqttCallback(QString strTopic, QByteArray arrayMessage);
|
|
void sigMqttSetOpen(QString ip,int port);
|
|
|
|
private slots:
|
|
void OnButtonClicked();
|
|
void OnSerialPortComboxCurIndexChanged(int index);
|
|
|
|
public slots:
|
|
void sltMQTTSendMessage(QString strTopic, QString strMessage);
|
|
void sltMQTTSendMessage(QString strTopic, QByteArray arrayMessage);
|
|
void sltMQTTSubcribe(QString strTopic);
|
|
void sltMQTTCancelTopic(QString strTopic);
|
|
void revMQTTSendMessage(QString strTopic, QByteArray arrayMessage);
|
|
|
|
public:
|
|
|
|
void initUi();
|
|
protected:
|
|
|
|
struct Settings
|
|
{
|
|
// 串口名
|
|
QString name;
|
|
|
|
// 波特率
|
|
asio::serial_port::baud_rate baudRate;
|
|
QString strBaudRate;
|
|
|
|
// 奇偶校验
|
|
asio::serial_port::parity parity;
|
|
QString strParity;
|
|
|
|
// 流控制
|
|
asio::serial_port::flow_control flowControl;
|
|
QString strFlowControl;
|
|
|
|
// 数据位
|
|
asio::serial_port::character_size dataBits;
|
|
QString strDataBits;
|
|
|
|
// 停止位
|
|
asio::serial_port::stop_bits stopBits;
|
|
QString strStopBits;
|
|
|
|
};
|
|
|
|
private:
|
|
/*
|
|
* 串口相关函数
|
|
*/
|
|
void FillPortsParameters();
|
|
void FillPortsInfo();
|
|
void UpdateSettings();
|
|
void LoadConnect();
|
|
void ShowMsg(QString title, QString msg);
|
|
void InitMQTTtopic();
|
|
|
|
private:
|
|
void InitStyles();
|
|
void setOpenStatus(bool isOpen);
|
|
|
|
private:
|
|
Ui::CommunicationWgtClass* ui;
|
|
/*
|
|
* 串口相关
|
|
*/
|
|
Settings m_varSerialPortSettings;
|
|
|
|
QTimer m_timer;
|
|
QStringList m_portNameList;
|
|
|
|
/*
|
|
* MQTT相关
|
|
*/
|
|
|
|
bool m_bMQTTisOpen = false; //MQTT服务是否连接
|
|
QStringList m_topicList; //订阅主题
|
|
|
|
BijectiveMap<int /*port_index*/, int /*通信类型*/> m_BijectiveMap;
|
|
bool m_currentBtnIsOpen=false;
|
|
|
|
};
|