mirror of
https://github.com/JasonYANG170/IOTConnect-PC.git
synced 2024-10-19 05:21:49 +00:00
270 lines
8.7 KiB
C++
270 lines
8.7 KiB
C++
#include "dialog.h"
|
||
#include "ui_dialog.h"
|
||
#include <QtMqtt/QtMqtt>
|
||
#include <QMessageBox>
|
||
QStringList parts;
|
||
QByteArray byteArray;
|
||
QString formattedVersion;
|
||
QString newves;
|
||
QString ID;
|
||
QString remainderx;
|
||
Dialog::Dialog(const QString& text, QWidget *parent) :
|
||
QDialog(parent),
|
||
ui(new Ui::Dialog),
|
||
client(new QMqttClient(this))
|
||
{
|
||
ui->setupUi(this);
|
||
setWindowTitle("设备管理");
|
||
ID=text;
|
||
ui->label_6->setText("设备ID："+text);
|
||
trimmedText = text.mid(2); // 从索引2（即"fp"之后）开始截取文本
|
||
|
||
client->setHostname("url");
|
||
client->setPort(123);
|
||
client->setClientId("clientid");
|
||
client->connectToHost();
|
||
|
||
QObject::connect(client, &QMqttClient::connected, [this]() {
|
||
qDebug() << "Connected to MQTT broker!";
|
||
// 订阅主题
|
||
QMqttTopicFilter filter("Flowerpot");
|
||
client->subscribe(filter);
|
||
});
|
||
|
||
QObject::connect(client, &QMqttClient::messageReceived, [this](const QByteArray& message, const QMqttTopicName& topic) {
|
||
QString messageContent = message;
|
||
QString desiredPrefix = "#ID" + trimmedText;
|
||
formattedVersion ="";
|
||
if (messageContent.startsWith(desiredPrefix)) {
|
||
|
||
ui->label_7->setText("设备状态：在线");
|
||
QString messageString = QString::fromUtf8(message);
|
||
qDebug() << "Received message:" << message << "from topic:" << topic.name();
|
||
parts = messageString.split('#');
|
||
|
||
for (const QString& part : parts) {
|
||
qDebug() << "Split part:" << part;
|
||
}
|
||
QString firmwareVersion = parts[8];
|
||
int versionNumber = firmwareVersion.toInt(); // 将字符串转换为整数
|
||
|
||
int x = versionNumber / 100; // 获取百位数
|
||
int y = (versionNumber / 10) % 10; // 获取十位数
|
||
int z = versionNumber % 10; // 获取个位数
|
||
|
||
formattedVersion = QString("V%1.%2.%3").arg(x).arg(y).arg(z); // 创建格式化后的版本号字符串
|
||
ui->label_8->setText("固件版本："+formattedVersion);
|
||
ui->label_3->setText(parts[2]+"%");
|
||
ui->label_4->setText(parts[4]+"%");
|
||
ui->label_5->setText(parts[3]+"%");
|
||
if(parts[6]=="1"){
|
||
ui->pushButton->setStyleSheet("background-color: red;");
|
||
}else{
|
||
ui->pushButton->setStyleSheet("background-color: white;");
|
||
}
|
||
if(parts[7]=="1"){
|
||
ui->pushButton_2->setStyleSheet("background-color: red;");
|
||
}else{
|
||
ui->pushButton_2->setStyleSheet("background-color: white;");
|
||
}
|
||
if(parts[5]=="1"){
|
||
ui->pushButton_3->setStyleSheet("background-color: red;");
|
||
}else{
|
||
ui->pushButton_3->setStyleSheet("background-color: white;");
|
||
}
|
||
ui->checkBox->blockSignals(true);
|
||
if (parts[9] == "1") {
|
||
ui->checkBox->setCheckState(Qt::Checked); // 设置为选中状态
|
||
} else {
|
||
ui->checkBox->setCheckState(Qt::Unchecked); // 设置为未选中状态
|
||
}
|
||
ui->checkBox->blockSignals(false);
|
||
} else {
|
||
// 忽略其他的消息
|
||
}
|
||
});
|
||
//更新检查服务器
|
||
QNetworkAccessManager *manager = new QNetworkAccessManager(this);
|
||
QUrl url("updata url");
|
||
QNetworkRequest request(url);
|
||
|
||
// Set unsafe SSL configuration
|
||
QSslConfiguration config = request.sslConfiguration();
|
||
config.setPeerVerifyMode(QSslSocket::VerifyNone);
|
||
request.setSslConfiguration(config);
|
||
|
||
QNetworkReply *reply = manager->get(request);
|
||
|
||
// Connect to the finished signal
|
||
connect(reply, &QNetworkReply::finished, [=]() {
|
||
if (reply->error() == QNetworkReply::NoError) {
|
||
// Read the JSON data
|
||
QByteArray data = reply->readAll();
|
||
|
||
// Display the JSON data in a message box
|
||
QJsonDocument jsonDoc = QJsonDocument::fromJson(QString(data).toUtf8());
|
||
QJsonObject jsonObj = jsonDoc.object();
|
||
|
||
// 获取数据
|
||
QJsonObject jObj2 = jsonDoc["data"].toObject();
|
||
QString str = jObj2 ["content"].toString();
|
||
qDebug() << str;
|
||
newves = str.left(6); // 提取前6个字符组成newves
|
||
|
||
remainderx = str.mid(6); // 提取剩下的字符
|
||
remainderx.replace("#", "\n");
|
||
qDebug() << "update1111111";
|
||
qDebug() << newves;
|
||
qDebug() << formattedVersion;
|
||
if (newves != formattedVersion) {
|
||
// QMessageBox::warning(this, "Error", "已发布新版本\"" + info + "\"。\n点击\"设置\"下载最新版本。");
|
||
// ui->pushButton_4->setText("发现新版本");
|
||
ui->pushButton_6->setStyleSheet("background-color: red;");
|
||
ui->pushButton_6->setText("发现新版本！");
|
||
qDebug() << "update";
|
||
}
|
||
else {
|
||
// ui->pushButton_4->setText("暂无更新");
|
||
qDebug() << "no";
|
||
}
|
||
}
|
||
else {
|
||
// Display an error message
|
||
QMessageBox::warning(this, "Error", reply->errorString());
|
||
}
|
||
|
||
// Clean up
|
||
reply->deleteLater();
|
||
manager->deleteLater();
|
||
});
|
||
}
|
||
|
||
Dialog::~Dialog()
|
||
{
|
||
delete ui;
|
||
}
|
||
|
||
|
||
|
||
void Dialog::on_pushButton_clicked()
|
||
{
|
||
if (client->state() == QMqttClient::Connected) {
|
||
QMqttTopicName topic("Flowerpot");
|
||
if (parts[6]=="1") {
|
||
QString str = "#IDTO" + trimmedText+"&OFFHOT";
|
||
byteArray = str.toUtf8();
|
||
}else{
|
||
QString str = "#IDTO" + trimmedText+"&ONHOT";
|
||
byteArray = str.toUtf8();
|
||
}
|
||
|
||
|
||
client->publish(topic, byteArray, 0, false);
|
||
// 发送消息后做其他处理
|
||
} else {
|
||
QMessageBox::warning(this, "Error", "MQTT client is not connected!");
|
||
}
|
||
}
|
||
|
||
|
||
void Dialog::on_pushButton_2_clicked()
|
||
{
|
||
if (client->state() == QMqttClient::Connected) {
|
||
QMqttTopicName topic("Flowerpot");
|
||
if (parts[7]=="1") {
|
||
QString str = "#IDTO" + trimmedText+"&OFFLED";
|
||
byteArray = str.toUtf8();
|
||
}else{
|
||
QString str = "#IDTO" + trimmedText+"&ONLED";
|
||
byteArray = str.toUtf8();
|
||
}
|
||
|
||
|
||
client->publish(topic, byteArray, 0, false);
|
||
// 发送消息后做其他处理
|
||
} else {
|
||
QMessageBox::warning(this, "Error", "MQTT client is not connected!");
|
||
}
|
||
}
|
||
|
||
|
||
void Dialog::on_pushButton_3_clicked()
|
||
{
|
||
if (client->state() == QMqttClient::Connected) {
|
||
QMqttTopicName topic("Flowerpot");
|
||
if (parts[5]=="1") {
|
||
QString str = "#IDTO" + trimmedText+"&OFFPUMP";
|
||
byteArray = str.toUtf8();
|
||
}else{
|
||
QString str = "#IDTO" + trimmedText+"&ONPUMP";
|
||
byteArray = str.toUtf8();
|
||
}
|
||
|
||
|
||
client->publish(topic, byteArray, 0, false);
|
||
// 发送消息后做其他处理
|
||
} else {
|
||
QMessageBox::warning(this, "Error", "MQTT client is not connected!");
|
||
}
|
||
}
|
||
|
||
|
||
void Dialog::on_pushButton_4_clicked()
|
||
{
|
||
// 实例化第二个 Dialog2 对象
|
||
Dialog2 dialog2;
|
||
|
||
// 显示第二个 Dialog2
|
||
dialog2.exec();
|
||
}
|
||
|
||
void Dialog::on_pushButton_5_clicked()
|
||
{
|
||
|
||
}
|
||
|
||
void Dialog::on_pushButton_6_clicked()
|
||
{
|
||
form* formDialog = new form(ID, formattedVersion,newves,remainderx,this); // 使用其他名称替换 'form'
|
||
formDialog->show();
|
||
}
|
||
|
||
|
||
void Dialog::on_checkBox_stateChanged(int arg1)
|
||
{
|
||
if (arg1 == Qt::Checked) {
|
||
qDebug() << "复选框被选中";
|
||
// 根据选中状态执行特定操作
|
||
if (client->state() == QMqttClient::Connected) {
|
||
QMqttTopicName topic("Flowerpot");
|
||
QString str = "#IDTO" + trimmedText+"&ONAUTO";
|
||
byteArray = str.toUtf8();
|
||
client->publish(topic, byteArray, 0, false);
|
||
// 发送消息后做其他处理
|
||
} else {
|
||
QMessageBox::warning(this, "Error", "MQTT client is not connected!");
|
||
}
|
||
} else if (arg1 == Qt::Unchecked) {
|
||
qDebug() << "复选框未被选中";
|
||
// 根据未选中状态执行特定操作
|
||
if (client->state() == QMqttClient::Connected) {
|
||
QMqttTopicName topic("Flowerpot");
|
||
QString str = "#IDTO" + trimmedText+"&OFFAUTO";
|
||
byteArray = str.toUtf8();
|
||
client->publish(topic, byteArray, 0, false);
|
||
// 发送消息后做其他处理
|
||
} else {
|
||
QMessageBox::warning(this, "Error", "MQTT client is not connected!");
|
||
}
|
||
}
|
||
}
|
||
|
||
void Dialog::closeEvent(QCloseEvent *event)
|
||
{
|
||
// 断开 MQTT 连接
|
||
client->disconnectFromHost();
|
||
|
||
// 调用父类的关闭事件处理函数
|
||
QDialog::closeEvent(event);
|
||
}
|