diff --git a/src/commandwidget.cpp b/src/commandwidget.cpp index df0f79b..e69d951 100644 --- a/src/commandwidget.cpp +++ b/src/commandwidget.cpp @@ -27,41 +27,51 @@ void CommandWidget::on_settingToolBtn_clicked() { // 连接 void CommandWidget::on_startConnectionToolBtn_clicked() { ui->startConnectionToolBtn->setDisabled(true); - if (!g_networkSettingInfo) return; + + if (!g_networkSettingInfo) { + qWarning() << "Network settings are not initialized!"; + return; + } + int dataSourceType = g_networkSettingInfo->value("DataSource").toInt(); QString groupName = ""; + switch (dataSourceType) { - case 0: - groupName = "LLink"; - break; - case 1: - groupName = "SATCOM1"; - break; - case 2: - groupName = "SATCOM2"; - break; - default: - break; + case 0: + groupName = "LLink"; + break; + case 1: + groupName = "SATCOM1"; + break; + case 2: + groupName = "SATCOM2"; + break; + default: + qWarning() << "Unknown data source type:" << dataSourceType; + return; } - m_remoteIP = - g_networkSettingInfo->value(groupName + "/remoteIP").toString(); - m_remotePort = - g_networkSettingInfo->value(groupName + "/remotePort").toInt(); - int localPort = - g_networkSettingInfo->value(groupName + "/localPort").toInt(); - QString localIP = - g_networkSettingInfo->value(groupName + "/localIP").toString(); + m_remoteIP = g_networkSettingInfo->value(groupName + "/remoteIP").toString(); + m_remotePort = g_networkSettingInfo->value(groupName + "/remotePort").toInt(); + int localPort = g_networkSettingInfo->value(groupName + "/localPort").toInt(); + QString localIP = g_networkSettingInfo->value(groupName + "/localIP").toString(); + + // 校验 IP 和端口 + if (m_remoteIP.isEmpty() || m_remotePort <= 0 || localIP.isEmpty() || localPort <= 0) { + qWarning() << "Invalid IP or port configuration!"; + return; + } if (dataSourceType == 0) { // 组播 + qDebug() << "Starting multicast connection to" << m_remoteIP << ":" << m_remotePort; emit startConnectionSignal(m_remoteIP, m_remotePort); } else { // 单播 + qDebug() << "Starting unicast connection on" << localIP << ":" << localPort; emit startConnectionSignal(localIP, localPort); } ui->stopConnectionToolBtn->setDisabled(false); } - // 断开 void CommandWidget::on_stopConnectionToolBtn_clicked() { ui->stopConnectionToolBtn->setDisabled(true); @@ -75,3 +85,176 @@ void CommandWidget::on_stopConnectionToolBtn_clicked() { void CommandWidget::receiveMessageSlots(QString message, int type) { emit sendErrorMessage(message, type); } + + + +unsigned char CommandWidget::getCrc(quint8* data, quint8 length) +{ + quint16 crc = 0; + int i=0; + while (length-- > 0) + { + crc = CRC8TAB[crc ^ (data[i]&0x00FF)]; + + i++; + } + + return crc&0x00ff; + +} + +ProtocalKB CommandWidget::EncodeCommandCmd(quint8 cmd) +{ + std::unique_ptr pBuff = std::make_unique(); + pBuff->head[0] = PROTOCOL_HEAD_0; + pBuff->head[1] = PROTOCOL_HEAD_1; + pBuff->reserved = PROTOCOL_RESERVED; + pBuff->data[0] = cmd; + pBuff->data[1] = cmd; + pBuff->data[2] = cmd; + pBuff->curPage = PROTOCOL_CUR_PAGE; + quint8 *ptr = reinterpret_cast(&pBuff); + pBuff->CHKSUM = getCrc(ptr, sizeof(pBuff) - sizeof(pBuff->CHKSUM)); + + return *pBuff; +} + + + + + +bool CommandWidget::writeBufferToClient(const QByteArray &data) +{ + // 目标地址和端口 + QHostAddress destination("172.10.1.216"); // 目标 IP 地址 + quint16 port = 9003; // 目标端口 + + // 发送数据 + qint64 bytesSent = g_CommandudpSocket->writeDatagram(data, destination, port); + if (bytesSent == -1) { + qDebug() << "发送失败：" << g_CommandudpSocket->errorString(); + return false; + } else { + qDebug() << "发送成功，字节数:" << bytesSent; + return true; + } + + +} + +void CommandWidget::buttonResponse(quint8 cmd) +{ + + ProtocalKB packet = EncodeCommandCmd(cmd); + // 将 ProtocalKB 结构体转换为 QByteArray + QByteArray data; + data.append(reinterpret_cast(&packet), sizeof(ProtocalKB)); + for(int i=0;i<3;i++) + { + writeBufferToClient(data); + } + +} + +void CommandWidget::on_pushButton_clicked() +{ + buttonResponse(0x75); + +} + + +void CommandWidget::on_pushButton_2_clicked() +{ + buttonResponse(0x76); +} + + +void CommandWidget::on_pushButton_5_clicked() +{ + buttonResponse(0x7D); +} + + +void CommandWidget::on_pushButton_6_clicked() +{ + buttonResponse(0x7C); +} + + +void CommandWidget::on_pushButton_10_clicked() +{ + buttonResponse(0x69); +} + + +void CommandWidget::on_pushButton_9_clicked() +{ + buttonResponse(0x6A); +} + + +void CommandWidget::on_pushButton_4_clicked() +{ + buttonResponse(0x77); +} + + +void CommandWidget::on_pushButton_3_clicked() +{ + buttonResponse(0x78); +} + + +void CommandWidget::on_pushButton_14_clicked() +{ + buttonResponse(0x79); +} + + +void CommandWidget::on_pushButton_13_clicked() +{ + buttonResponse(0xC6); +} + + +void CommandWidget::on_pushButton_17_clicked() +{ + buttonResponse(0x66); +} + + +void CommandWidget::on_pushButton_8_clicked() +{ + buttonResponse(0x67); +} + + +void CommandWidget::on_pushButton_7_clicked() +{ + buttonResponse(0x68); +} + + +void CommandWidget::on_pushButton_12_clicked() +{ + buttonResponse(0x7B); +} + + +void CommandWidget::on_pushButton_11_clicked() +{ + buttonResponse(0x7A); +} + + +void CommandWidget::on_pushButton_16_clicked() +{ + buttonResponse(0xC8); +} + + +void CommandWidget::on_pushButton_15_clicked() +{ + buttonResponse(0xC9); +} + diff --git a/src/commandwidget.h b/src/commandwidget.h index c85233a..e818ed6 100644 --- a/src/commandwidget.h +++ b/src/commandwidget.h @@ -6,6 +6,74 @@ #include "communicationsettingdlg.h" +typedef struct struProtocalKB { + quint8 head[2]; //帧头0x + quint8 reserved; //预留 + quint8 data[3]; //开关指令 + quint8 curPage; //指令页 + quint8 CHKSUM; //校验字节 +}ProtocalKB; + +// 定义常量 +const unsigned char PROTOCOL_HEAD_0 = 0xEB; +const unsigned char PROTOCOL_HEAD_1 = 0x98; +const unsigned char PROTOCOL_RESERVED = 0x00; +const unsigned char PROTOCOL_CUR_PAGE = 0x01; + +const quint16 CRC8TAB[256] = + { + //0 + 0x0000, 0x0031, 0x0062, 0x0053, 0x00C4, 0x00F5, 0x00A6, 0x0097, + 0x00B9, 0x0088, 0x00DB, 0x00EA, 0x007D, 0x004C, 0x001F, 0x002E, + //1 + 0x0043, 0x0072, 0x0021, 0x0010, 0x0087, 0x00B6, 0x00E5, 0x00D4, + 0x00FA, 0x00CB, 0x0098, 0x00A9, 0x003E, 0x000F, 0x005C, 0x006D, + //2 + 0x0086, 0x00B7, 0x00E4, 0x00D5, 0x0042, 0x0073, 0x0020, 0x0011, + 0x003F, 0x000E, 0x005D, 0x006C, 0x00FB, 0x00CA, 0x0099, 0x00A8, + //3 + 0x00C5, 0x00F4, 0x00A7, 0x0096, 0x0001, 0x0030, 0x0063, 0x0052, + 0x007C, 0x004D, 0x001E, 0x002F, 0x00B8, 0x0089, 0x00DA, 0x00EB, + //4 + 0x003D, 0x000C, 0x005F, 0x006E, 0x00F9, 0x00C8, 0x009B, 0x00AA, + 0x0084, 0x00B5, 0x00E6, 0x00D7, 0x0040, 0x0071, 0x0022, 0x0013, + //5 + 0x007E, 0x004F, 0x001C, 0x002D, 0x00BA, 0x008B, 0x00D8, 0x00E9, + 0x00C7, 0x00F6, 0x00A5, 0x0094, 0x0003, 0x0032, 0x0061, 0x0050, + //6 + 0x00BB, 0x008A, 0x00D9, 0x00E8, 0x007F, 0x004E, 0x001D, 0x002C, + 0x0002, 0x0033, 0x0060, 0x0051, 0x00C6, 0x00F7, 0x00A4, 0x0095, + //7 + 0x00F8, 0x00C9, 0x009A, 0x00AB, 0x003C, 0x000D, 0x005E, 0x006F, + 0x0041, 0x0070, 0x0023, 0x0012, 0x0085, 0x00B4, 0x00E7, 0x00D6, + //8 + 0x007A, 0x004B, 0x0018, 0x0029, 0x00BE, 0x008F, 0x00DC, 0x00ED, + 0x00C3, 0x00F2, 0x00A1, 0x0090, 0x0007, 0x0036, 0x0065, 0x0054, + //9 + 0x0039, 0x0008, 0x005B, 0x006A, 0x00FD, 0x00CC, 0x009F, 0x00AE, + 0x0080, 0x00B1, 0x00E2, 0x00D3, 0x0044, 0x0075, 0x0026, 0x0017, + //A + 0x00FC, 0x00CD, 0x009E, 0x00AF, 0x0038, 0x0009, 0x005A, 0x006B, + 0x0045, 0x0074, 0x0027, 0x0016, 0x0081, 0x00B0, 0x00E3, 0x00D2, + //B + 0x00BF, 0x008E, 0x00DD, 0x00EC, 0x007B, 0x004A, 0x0019, 0x0028, + 0x0006, 0x0037, 0x0064, 0x0055, 0x00C2, 0x00F3, 0x00A0, 0x0091, + //C + 0x0047, 0x0076, 0x0025, 0x0014, 0x0083, 0x00B2, 0x00E1, 0x00D0, + 0x00FE, 0x00CF, 0x009C, 0x00AD, 0x003A, 0x000B, 0x0058, 0x0069, + //D + 0x0004, 0x0035, 0x0066, 0x0057, 0x00C0, 0x00F1, 0x00A2, 0x0093, + 0x00BD, 0x008C, 0x00DF, 0x00FE, 0x0079, 0x0048, 0x001B, 0x002A, + //E + 0x00C1, 0x00F0, 0x00A3, 0x0092, 0x0005, 0x0034, 0x0067, 0x0056, + 0x0078, 0x0049, 0x001A, 0x002B, 0x00BC, 0x008D, 0x00DE, 0x00EF, + //F + 0x0082, 0x00B3, 0x00E0, 0x00D1, 0x0046, 0x0077, 0x0024, 0x0015, + 0x003B, 0x000A, 0x0059, 0x0068, 0x00FF, 0x00CE, 0x009D, 0x00AC +}; + + + namespace Ui { class CommandWidget; } @@ -31,12 +99,55 @@ private slots: void receiveMessageSlots(QString message, int type); + void on_pushButton_clicked(); + + void on_pushButton_2_clicked(); + + void on_pushButton_5_clicked(); + + void on_pushButton_6_clicked(); + + void on_pushButton_10_clicked(); + + void on_pushButton_9_clicked(); + + void on_pushButton_4_clicked(); + + void on_pushButton_3_clicked(); + + void on_pushButton_14_clicked(); + + void on_pushButton_13_clicked(); + + void on_pushButton_17_clicked(); + + void on_pushButton_8_clicked(); + + void on_pushButton_7_clicked(); + + void on_pushButton_12_clicked(); + + void on_pushButton_11_clicked(); + + void on_pushButton_16_clicked(); + + void on_pushButton_15_clicked(); + private: Ui::CommandWidget *ui; CommunicationSettingDlg settingDlg; QString m_remoteIP; int m_remotePort; + + unsigned char getCrc(quint8* data, quint8 length); + ProtocalKB EncodeCommandCmd(quint8 cmd); + bool writeBufferToClient(const QByteArray &data); + + void buttonResponse(quint8 cmd); + + + }; #endif // COMMANDWIDGET_H diff --git a/src/global.cpp b/src/global.cpp index 1412248..f48b2df 100644 --- a/src/global.cpp +++ b/src/global.cpp @@ -1,6 +1,10 @@ #include "global.h" + + QSettings* g_networkSettingInfo; +QUdpSocket* g_CommandudpSocket; + void getLocalIP(QStringList& localIPList) { QHostInfo hostInfo = QHostInfo::fromName(QHostInfo::localHostName()); diff --git a/src/global.h b/src/global.h index 1d5b192..03bc69c 100644 --- a/src/global.h +++ b/src/global.h @@ -8,8 +8,9 @@ #include #include #include - +#include extern QSettings* g_networkSettingInfo; +extern QUdpSocket* g_CommandudpSocket; extern void getLocalIP(QStringList& localIPList); diff --git a/src/mainwindow.cpp b/src/mainwindow.cpp index cf7ea95..eb9e4a1 100644 --- a/src/mainwindow.cpp +++ b/src/mainwindow.cpp @@ -89,6 +89,7 @@ MainWindow::MainWindow(QWidget *parent) initSignalConnection(); initNotifyManager(); initNotifyMessageConnection(); + initCommunitions(); } MainWindow::~MainWindow() { @@ -110,6 +111,7 @@ void MainWindow::initNotifyMessageConnection() { &MainWindow::showMessageSlots); } + void MainWindow::initNotifyManager() { m_notifyManager = new NotifyManager(this, this); m_notifyManager->setMaxCount(5); @@ -117,6 +119,21 @@ void MainWindow::initNotifyManager() { m_notifyManager->setNotifyWndSize(400, 60); } +void MainWindow::initCommunitions() +{ + + g_CommandudpSocket = new QUdpSocket(this); + // 将套接字绑定到指定端口 + if (g_CommandudpSocket->bind(QHostAddress::Any, 1200)) { + qDebug() << "UDP 套接字已绑定到端口 1200"; + } else { + qDebug() << "绑定 UDP 套接字失败"; + } + + +} + + void MainWindow::showMessageSlots(QString message, int type) { if (m_notifyManager) { m_notifyManager->notify(message, "", type, 3000); diff --git a/src/mainwindow.h b/src/mainwindow.h index c26930d..aa39fd0 100644 --- a/src/mainwindow.h +++ b/src/mainwindow.h @@ -32,6 +32,7 @@ private: void initNotifyManager(); void showMessageSlots(QString message, int type); + void initCommunitions(); // void installWindowAgent();