zhangsheng/3500
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

modify ftp upload to scp

Browse Source
This commit is contained in:
zhangsheng 2026-02-03 20:31:37 +08:00
parent a00e1135af
commit a86981f8e1
24 changed files with 1009 additions and 290 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

72
BoardSetting.cpp
View File

@ -3,6 +3,7 @@
#include "global.h" #include "global.h"
#include <QListView> #include <QListView>
#include "sqlitedb.h" #include "sqlitedb.h"
#include "scp_client.h"
CBoardSetting::CBoardSetting(QWidget *parent) : CBoardSetting::CBoardSetting(QWidget *parent) :
QWidget(parent), QWidget(parent),
@ -480,12 +481,15 @@ void CBoardSetting::PushData()
strTablename = "t_TriggerConfig"; strTablename = "t_TriggerConfig";
g_SqliteDB->DeleteData(strTablename); g_SqliteDB->DeleteData(strTablename);
QString strURL = QString("ftp://%1/CIDW/qtconfig/%2").arg(IP).arg("UnitWorkConditionsInfo.json"); QString remotePath = QString("/CIDW/qtconfig/%1").arg("UnitWorkConditionsInfo.json");
// g_FtpClient->SetServerInfo(strURL); ScpClient scp;
// g_FtpClient->SetUserInfo("root","@#cidw!@123456"); bool res = scp.connectToHost(IP, 22, "root", "@#cidw!@123456");
// g_FtpClient->UpLoadFile(fileName,"UnitWorkConditionsInfo.json"); if(!res){
QMessageBox::information(nullptr, QStringLiteral("提示"), "连接失败！");
return;
}
scp.upload(fileName, remotePath,"UnitWorkConditionsInfo.json");
g_FtpClient->uploadFile(strURL,fileName,"UnitWorkConditionsInfo.json");
QJsonDocument jsonDocUnit; QJsonDocument jsonDocUnit;
QJsonObject UnitObj; QJsonObject UnitObj;
UnitObj["NULL"] = ""; UnitObj["NULL"] = "";
@ -502,12 +506,9 @@ void CBoardSetting::PushData()
fileUnit.open(QIODevice::WriteOnly); fileUnit.open(QIODevice::WriteOnly);
fileUnit.write(jsonDocUnit.toJson()); fileUnit.write(jsonDocUnit.toJson());
fileUnit.close(); fileUnit.close();
QString str2 = QString("ftp://%1/CIDW/qtconfig/%2").arg(IP).arg("UnitConfigurations.json");
// g_FtpClient->SetServerInfo(str2);
// g_FtpClient->SetUserInfo("root","@#cidw!@123456");
// g_FtpClient->UpLoadFile(fileNameUnit,"UnitConfigurations.json");
g_FtpClient->uploadFile(str2,fileNameUnit,"UnitConfigurations.json"); remotePath = QString("/CIDW/qtconfig/%1").arg("UnitConfigurations.json");
scp.upload(fileName, remotePath,"UnitConfigurations.json");
#ifdef Q_OS_WIN32 #ifdef Q_OS_WIN32
QString fileNameUnit2 = QCoreApplication::applicationDirPath() + "\\config\\UnitConfigurations2.json"; QString fileNameUnit2 = QCoreApplication::applicationDirPath() + "\\config\\UnitConfigurations2.json";
#endif #endif
@ -520,12 +521,10 @@ void CBoardSetting::PushData()
fileUnit2.open(QIODevice::WriteOnly); fileUnit2.open(QIODevice::WriteOnly);
fileUnit2.write(jsonDocUnit.toJson()); fileUnit2.write(jsonDocUnit.toJson());
fileUnit2.close(); fileUnit2.close();
QString str22 = QString("ftp://%1/CIDW/qtconfig/%2").arg(IP).arg("UnitConfigurations2.json");
// g_FtpClient->SetServerInfo(str22);
// g_FtpClient->SetUserInfo("root","@#cidw!@123456");
// g_FtpClient->UpLoadFile(fileNameUnit2,"UnitConfigurations2.json");
g_FtpClient->uploadFile(str22,fileNameUnit2,"UnitConfigurations2.json"); remotePath = QString("/CIDW/qtconfig/%1").arg("UnitConfigurations2.json");
scp.upload(fileName, remotePath,"UnitConfigurations2.json");
g_channelSetting = g_SqliteDB->GetDataMultiLine("t_ChannelSetting"); g_channelSetting = g_SqliteDB->GetDataMultiLine("t_ChannelSetting");
for (int i = 0; i < g_channelSetting.size(); i++) for (int i = 0; i < g_channelSetting.size(); i++)
@ -577,12 +576,8 @@ void CBoardSetting::PushData()
fileTri.open(QIODevice::WriteOnly); fileTri.open(QIODevice::WriteOnly);
fileTri.write(jsonDocTri.toJson()); fileTri.write(jsonDocTri.toJson());
fileTri.close(); fileTri.close();
QString str1 = QString("ftp://%1/CIDW/qtconfig/%2").arg(IP).arg("TriggerSettings.json"); remotePath = QString("/CIDW/qtconfig/%1").arg("TriggerSettings.json");
// g_FtpClient->SetServerInfo(str1); scp.upload(fileName, remotePath,"TriggerSettings.json");
// g_FtpClient->SetUserInfo("root","@#cidw!@123456");
// g_FtpClient->UpLoadFile(fileNameTri,"TriggerSettings.json");
g_FtpClient->uploadFile(str1,fileNameTri,"TriggerSettings.json");
#ifdef Q_OS_WIN32 #ifdef Q_OS_WIN32
QString fileNameTri2 = QCoreApplication::applicationDirPath() + "\\config\\TriggerSettings2.json"; QString fileNameTri2 = QCoreApplication::applicationDirPath() + "\\config\\TriggerSettings2.json";
@ -595,17 +590,12 @@ void CBoardSetting::PushData()
fileTri2.open(QIODevice::WriteOnly); fileTri2.open(QIODevice::WriteOnly);
fileTri2.write(jsonDocTri.toJson()); fileTri2.write(jsonDocTri.toJson());
fileTri2.close(); fileTri2.close();
QString strTri2 = QString("ftp://%1/CIDW/qtconfig/%2").arg(IP).arg("TriggerSettings2.json"); remotePath = QString("/CIDW/qtconfig/%1").arg("TriggerSettings2.json");
// g_FtpClient->SetServerInfo(strTri2); scp.upload(fileName, remotePath,"TriggerSettings2.json");
// g_FtpClient->SetUserInfo("root","@#cidw!@123456");
// g_FtpClient->UpLoadFile(fileNameTri2,"TriggerSettings2.json");
g_FtpClient->uploadFile(strTri2,fileNameTri2,"TriggerSettings2.json");
QString str = QString("ftp://%1/CIDW/qtconfig/%2").arg(IP).arg("UnitBoardsInfo.json"); remotePath = QString("/CIDW/qtconfig/%1").arg("UnitBoardsInfo.json");
// g_FtpClient->SetServerInfo(str); scp.upload(fileName, remotePath,"UnitBoardsInfo.json");
// g_FtpClient->SetUserInfo("root","@#cidw!@123456"); scp.disconnectFromHost();
// g_FtpClient->UpLoadFile(name,"UnitBoardsInfo.json");
g_FtpClient->uploadFile(str,name,"UnitBoardsInfo.json");
disconnect(g_NetMgr,SIGNAL(sigNetMgr(QString, const QVariant&)), this, SLOT(slotNetMgr(QString,const QVariant&))); disconnect(g_NetMgr,SIGNAL(sigNetMgr(QString, const QVariant&)), this, SLOT(slotNetMgr(QString,const QVariant&)));
} }
@ -929,10 +919,6 @@ void CBoardSetting::on_pushButton_Init_clicked()
strTablename = "t_TriggerConfig"; strTablename = "t_TriggerConfig";
g_SqliteDB->DeleteData(strTablename); g_SqliteDB->DeleteData(strTablename);
// QString strURL = QString("ftp://%1/CIDW/qtconfig/%2").arg(IP).arg("UnitWorkConditionsInfo.json");
// g_FtpClient->SetServerInfo(strURL);
// g_FtpClient->SetUserInfo("root","@#cidw!@123456");
// g_FtpClient->UpLoadFile(fileName,"UnitWorkConditionsInfo.json");
customLogMessageHandler(QtDebugMsg,"初始化工况配置信息推送完成！"); customLogMessageHandler(QtDebugMsg,"初始化工况配置信息推送完成！");
QJsonDocument jsonDocUnit; QJsonDocument jsonDocUnit;
QJsonObject UnitObj; QJsonObject UnitObj;
@ -949,10 +935,6 @@ void CBoardSetting::on_pushButton_Init_clicked()
fileUnit.open(QIODevice::WriteOnly); fileUnit.open(QIODevice::WriteOnly);
fileUnit.write(jsonDocUnit.toJson()); fileUnit.write(jsonDocUnit.toJson());
fileUnit.close(); fileUnit.close();
// QString str2 = QString("ftp://%1/CIDW/qtconfig/%2").arg(IP).arg("UnitConfigurations.json");
// g_FtpClient->SetServerInfo(str2);
// g_FtpClient->SetUserInfo("root","@#cidw!@123456");
// g_FtpClient->UpLoadFile(fileNameUnit,"UnitConfigurations.json");
customLogMessageHandler(QtDebugMsg,"初始化机组配置信息推送完成！"); customLogMessageHandler(QtDebugMsg,"初始化机组配置信息推送完成！");
g_channelSetting = g_SqliteDB->GetDataMultiLine("t_ChannelSetting"); g_channelSetting = g_SqliteDB->GetDataMultiLine("t_ChannelSetting");
g_ChannelBaseInfo.clear(); g_ChannelBaseInfo.clear();
@ -1006,15 +988,7 @@ void CBoardSetting::on_pushButton_Init_clicked()
fileTri.open(QIODevice::WriteOnly); fileTri.open(QIODevice::WriteOnly);
fileTri.write(jsonDocTri.toJson()); fileTri.write(jsonDocTri.toJson());
fileTri.close(); fileTri.close();
// QString str1 = QString("ftp://%1/CIDW/qtconfig/%2").arg(IP).arg("TriggerSettings.json");
// g_FtpClient->SetServerInfo(str1);
// g_FtpClient->SetUserInfo("root","@#cidw!@123456");
// g_FtpClient->UpLoadFile(fileNameTri,"TriggerSettings.json");
// QString str = QString("ftp://%1/CIDW/qtconfig/%2").arg(IP).arg("UnitBoardsInfo.json");
// g_FtpClient->SetServerInfo(str);
// g_FtpClient->SetUserInfo("root","@#cidw!@123456");
// g_FtpClient->UpLoadFile(name,"UnitBoardsInfo.json");
customLogMessageHandler(QtDebugMsg,"初始化机组板卡配置信息推送完成！"); customLogMessageHandler(QtDebugMsg,"初始化机组板卡配置信息推送完成！");
#ifndef NO_FILTER #ifndef NO_FILTER
QJsonObject sendData; QJsonObject sendData;
@ -1172,10 +1146,6 @@ void CBoardSetting::putJson()
g_ChannelBaseInfo.append(tempchannelbaseinfo); g_ChannelBaseInfo.append(tempchannelbaseinfo);
} }
initReadConfig(); initReadConfig();
// QString str = QString("ftp://%1/CIDW/qtconfig/%2").arg(IP).arg("ChannelSettings.json");
// g_FtpClient->SetServerInfo(str);
// g_FtpClient->SetUserInfo("root","@#cidw!@123456");
// g_FtpClient->UpLoadFile(name,"ChannelSettings.json");
customLogMessageHandler(QtDebugMsg,"初始化通道配置信息推送完成！"); customLogMessageHandler(QtDebugMsg,"初始化通道配置信息推送完成！");
disconnect(g_NetMgr,SIGNAL(sigNetMgr(QString, const QVariant&)), this, SLOT(slotNetMgr(QString,const QVariant&))); disconnect(g_NetMgr,SIGNAL(sigNetMgr(QString, const QVariant&)), this, SLOT(slotNetMgr(QString,const QVariant&)));
} }

14
ChannelList.cpp
View File

@ -9,6 +9,7 @@
#include <QInputDialog> #include <QInputDialog>
#include <QListView> #include <QListView>
#include "NetMgr.h" #include "NetMgr.h"
#include "scp_client.h"
CChannelList::CChannelList(QWidget *parent) : CChannelList::CChannelList(QWidget *parent) :
QWidget(parent), QWidget(parent),
@ -519,10 +520,15 @@ void CChannelList::putJson()
} }
initReadConfig(); initReadConfig();
#if QT_NO_DEBUG #if QT_NO_DEBUG
QString str = QString("ftp://%1/CIDW/qtconfig/%2").arg(IP).arg("ChannelSettings.json"); QString remotePath = QString("/CIDW/qtconfig/%1").arg("ChannelSettings.json");
g_FtpClient->SetServerInfo(str); ScpClient scp;
g_FtpClient->SetUserInfo("root","@#cidw!@123456"); bool res = scp.connectToHost(IP, 22, "root", "@#cidw!@123456");
g_FtpClient->UpLoadFile(name,"ChannelSettings.json"); if(!res){
QMessageBox::information(nullptr, QStringLiteral("提示"), "连接失败！");
return;
}
scp.upload(name, remotePath,"ChannelSettings.json");
scp.disconnectFromHost();
#endif #endif
} }

22
Configuration.cpp
View File

@ -4,7 +4,7 @@
#include <QMenu> #include <QMenu>
#include <QInputDialog> #include <QInputDialog>
#include <QScrollArea> #include <QScrollArea>
#include "scp_client.h"
CConfiguration::CConfiguration(QWidget *parent) : CConfiguration::CConfiguration(QWidget *parent) :
QWidget(parent), QWidget(parent),
@ -1024,15 +1024,17 @@ void CConfiguration::PushData()
QString tableName = " t_UnitConfiguration "; QString tableName = " t_UnitConfiguration ";
g_SqliteDB->DeleteDataW(tableName,""); g_SqliteDB->DeleteDataW(tableName,"");
QString str = QString("ftp://%1/CIDW/qtconfig/%2").arg(IP).arg("UnitConfigurations.json"); QString remotePath = QString("/CIDW/qtconfig/%1").arg("UnitConfigurations.json");
g_FtpClient->SetServerInfo(str); ScpClient scp;
g_FtpClient->SetUserInfo("root","@#cidw!@123456"); bool res = scp.connectToHost(IP, 22, "root", "@#cidw!@123456");
g_FtpClient->UpLoadFile(fileName,"UnitConfigurations.json"); if(!res){
QMessageBox::information(nullptr, QStringLiteral("提示"), "连接失败！");
QString str2 = QString("ftp://%1/CIDW/qtconfig/%2").arg(IP).arg("UnitConfigurations2.json"); return;
g_FtpClient->SetServerInfo(str2); }
g_FtpClient->SetUserInfo("root","@#cidw!@123456"); scp.upload(fileName, remotePath,"UnitConfigurations.json");
g_FtpClient->UpLoadFile(fileName2,"UnitConfigurations2.json"); remotePath = QString("/CIDW/qtconfig/%1").arg("UnitConfigurations2.json");
scp.upload(fileName, remotePath,"UnitConfigurations2.json");
scp.disconnectFromHost();
} }

223
CopyDatFile.cpp
View File

@ -3,7 +3,16 @@
#include <QMenu> #include <QMenu>
#include "NetMgr.h" #include "NetMgr.h"
#include <QNetworkRequest> #include <QNetworkRequest>
#ifdef _WIN32
#include <winsock2.h>
#include <ws2tcpip.h>
#else
#include <arpa/inet.h>
#include <netinet/in.h>
#include <sys/socket.h>
#include <unistd.h>
#endif
static const QString kUpItem = "__UP__";
CCopyDatFile::CCopyDatFile(QWidget *parent) : CCopyDatFile::CCopyDatFile(QWidget *parent) :
QWidget(parent), QWidget(parent),
ui(new Ui::CCopyDatFile) ui(new Ui::CCopyDatFile)
@ -19,128 +28,166 @@ CCopyDatFile::CCopyDatFile(QWidget *parent) :
ui->treeWidget_fileList->setContextMenuPolicy(Qt::CustomContextMenu); ui->treeWidget_fileList->setContextMenuPolicy(Qt::CustomContextMenu);
QObject::connect(ui->treeWidget_fileList ,SIGNAL(customContextMenuRequested(const QPoint &)),this,SLOT(on_treeWidget_customContextMenuRequested(const QPoint &))); QObject::connect(ui->treeWidget_fileList ,SIGNAL(customContextMenuRequested(const QPoint &)),this,SLOT(on_treeWidget_customContextMenuRequested(const QPoint &)));
connect(ui->treeWidget_dist, &QTreeWidget::itemActivated,this, &CCopyDatFile::processItem); connect(ui->treeWidget_dist, &QTreeWidget::itemActivated,this, &CCopyDatFile::processItem);
connect(ui->treeWidget_fileList, &QTreeWidget::itemDoubleClicked,
this, &CCopyDatFile::onItemDoubleClicked);
ui->label_path->setText("/run/media/"); ui->label_path->setText("/run/media/");
connectToFtp(); connectToFtp();
} }
CCopyDatFile::~CCopyDatFile() CCopyDatFile::~CCopyDatFile()
{ {
scp.disconnectFromHost();
delete ui; delete ui;
} }
void CCopyDatFile::connectToFtp() void CCopyDatFile::connectToFtp()
{ {
ftp = new QFtp(this); bool res = scp.connectToHost("192.168.0.102", 22, "root", "@#cidw!@123456");
ftp -> connectToHost(IP,21); if(!res){
ftp -> login("root","@#cidw!@123456"); QMessageBox::information(this, QStringLiteral("提示"), "连接失败！");
connect(ftp, SIGNAL(commandFinished(int, bool)),this, SLOT(ftpCommandFinished(int, bool))); return;
connect(ftp, SIGNAL(listInfo(const QUrlInfo&)),this, SLOT(addToList(const QUrlInfo&))); }
connect(ftp, SIGNAL(listInfo(const QUrlInfo&)),this, SLOT(addToDistList(const QUrlInfo&))); QString path = "/opt/";
QVector<RemoteFileInfo> files ;
scp.listRemoteDir(path,files);
fillTreeWidget(ui->treeWidget_fileList, files, path);
} }
void CCopyDatFile::ftpCommandFinished(int, bool error) void CCopyDatFile::ftpCommandFinished(int, bool error)
{ {
qDebug() << ftp->currentCommand() <<endl; // qDebug() << ftp->currentCommand() <<endl;
if (ftp->currentCommand() == QFtp::ConnectToHost) // if (ftp->currentCommand() == QFtp::ConnectToHost)
// {
// if (error) {
// return;
// }
// else {
// return;
// }
// }
// if (ftp->currentCommand() == QFtp::Login){
// qDebug() << "连接成功！" << endl;
// ftp -> cd("/var/www/html/cidwdat/");
// ftp->list();
// }
// if (ftp->currentCommand() == QFtp::Get) {
// if (error) {
// } else {
// }
// } else if (ftp->currentCommand() == QFtp::List) {
// qDebug() << "List" << endl;
// }
}
static QString permToString(uint perm)
{ {
if (error) { QString s;
s += (perm & 0400) ? "r" : "-";
return; s += (perm & 0200) ? "w" : "-";
} s += (perm & 0100) ? "x" : "-";
else { s += (perm & 0040) ? "r" : "-";
s += (perm & 0020) ? "w" : "-";
return; s += (perm & 0010) ? "x" : "-";
} s += (perm & 0004) ? "r" : "-";
s += (perm & 0002) ? "w" : "-";
s += (perm & 0001) ? "x" : "-";
return s;
} }
if (ftp->currentCommand() == QFtp::Login){ void CCopyDatFile::fillTreeWidget(
qDebug() << "连接成功！" << endl; QTreeWidget *tree,
ftp -> cd("/var/www/html/cidwdat/"); const QVector<RemoteFileInfo> &files,
ftp->list(); const QString &currentPath)
} {
tree->clear();
QTreeWidgetItem *up = new QTreeWidgetItem;
up->setText(ColName, "..");
up->setText(ColType, "Dir");
up->setIcon(ColName, QIcon(":/icons/up.png"));
//up->setData(ColName, Qt::UserRole, kUpItem);
ui->treeWidget_fileList->addTopLevelItem(up);
if (ftp->currentCommand() == QFtp::Get) { for (const auto &f : files) {
if (error) {
QTreeWidgetItem *item = new QTreeWidgetItem(tree);
item->setText(ColName, f.name);
item->setText(ColSize, f.isDir ? "" : QString::number(f.size));
item->setText(ColType, f.isDir ? "Dir" : "File");
item->setText(ColPerm, permToString(f.permissions));
item->setText(ColOwner, f.owner);
item->setText(ColGroup, f.group);
item->setText(ColModified, f.lastModified.toString("yyyy-MM-dd HH:mm:ss"));
item->setData(ColName, Qt::UserRole, f.name);
// 📁 目录加图标
if (f.isDir) {
item->setIcon(ColName,
QApplication::style()->standardIcon(QStyle::SP_DirIcon));
// 标记可展开（即使还没加载）
item->setChildIndicatorPolicy(
QTreeWidgetItem::ShowIndicator);
} else { } else {
item->setIcon(ColName,
QApplication::style()->standardIcon(QStyle::SP_FileIcon));
} }
// 存远程完整路径（关键）
QString fullPath = currentPath;
if (!fullPath.endsWith('/'))
fullPath += '/';
fullPath += f.name;
} else if (ftp->currentCommand() == QFtp::List) { item->setData(ColName, Qt::UserRole, fullPath);
qDebug() << "List" << endl;
}
}
void CCopyDatFile::addToList(const QUrlInfo &urlInfo)
{
QTreeWidgetItem *item = new QTreeWidgetItem;
item->setText(0, urlInfo.name());
item->setText(1, QString::number(urlInfo.size()));
item->setText(2, urlInfo.owner());
item->setText(3, urlInfo.group());
item->setText(4, urlInfo.lastModified().toString("yyyy-MM-dd HH:mm:ss").toLocal8Bit().data());
QPixmap pixmap(urlInfo.isDir() ? ":/images/images/dir.png" : ":/images/images/file.png");
item->setIcon(0, pixmap);
item->setData(0, Qt::UserRole,urlInfo.name());
isDirectory[urlInfo.name()] = urlInfo.isDir();
this -> ui -> treeWidget_fileList->addTopLevelItem(item);
if (!this -> ui -> treeWidget_fileList->currentItem()) {
this -> ui -> treeWidget_fileList->setCurrentItem(this -> ui -> treeWidget_fileList->topLevelItem(0));
this -> ui -> treeWidget_fileList->setEnabled(true);
} }
} }
void CCopyDatFile::addToDistList(const QUrlInfo &urlInfo)
{
QTreeWidgetItem *item = new QTreeWidgetItem;
item->setText(0, urlInfo.name());
item->setText(1, QString::number(urlInfo.size()));
item->setText(2, urlInfo.owner());
item->setText(3, urlInfo.group());
item->setText(4, urlInfo.lastModified().toString("yyyy-MM-dd HH:mm:ss").toLocal8Bit().data());
QPixmap pixmap(urlInfo.isDir() ? ":/images/images/dir.png" : ":/images/images/file.png");
item->setIcon(0, pixmap);
isDirectory[urlInfo.name()] = urlInfo.isDir();
this -> ui -> treeWidget_dist->addTopLevelItem(item);
if (!this -> ui -> treeWidget_dist->currentItem()) {
this -> ui -> treeWidget_dist->setCurrentItem(this -> ui -> treeWidget_dist->topLevelItem(0));
this -> ui -> treeWidget_dist->setEnabled(true);
}
}
void CCopyDatFile::on_pushButton_refresh_clicked() void CCopyDatFile::on_pushButton_refresh_clicked()
{ {
disconnect(ftp, SIGNAL(listInfo(const QUrlInfo&)),this, SLOT(addToList(const QUrlInfo&))); QString path = "/opt/";
QVector<RemoteFileInfo> files ;
scp.listRemoteDir(path,files);
fillTreeWidget(ui->treeWidget_dist, files, path);
QString path_dist = "/run/media";
}
void CCopyDatFile::onItemDoubleClicked(QTreeWidgetItem *item, int column)
{
if (item->text(ColType) != "Dir")
return;
QString path = item->data(ColName, Qt::UserRole).toString();
QVector<RemoteFileInfo> files ;
scp.listRemoteDir(path,files);
fillTreeWidget(ui->treeWidget_fileList, files, path);
ui->treeWidget_fileList->setProperty("currentPath", path);
ui->label_path->setText(path);
ui -> treeWidget_dist ->clear();
ftp -> cd("/run/media/");
ui->label_path->setText("/run/media/");
m_strDistPath = "";
m_strDistPath = "/run/media/";
ftp->list();
} }
void CCopyDatFile::processItem(QTreeWidgetItem *item, int /*column*/) void CCopyDatFile::processItem(QTreeWidgetItem *item, int /*column*/)
{ {
QString name = item->text(0);
if (isDirectory.value(name)) {
this -> ui -> treeWidget_dist->clear();
isDirectory.clear();
currentPath += '/';
currentPath += name;
ftp->cd(name);
m_strDistPath = "";
m_strDistPath = "/run/media" + currentPath;
ui->label_path->setText(m_strDistPath);
currentPath = "";
ftp->list();
return;
}
} }

20
CopyDatFile.h
View File

@ -9,10 +9,21 @@
#include <QStandardItemModel> #include <QStandardItemModel>
#include <QFile> #include <QFile>
#include "global.h" #include "global.h"
#include "scp_client.h"
namespace Ui { namespace Ui {
class CCopyDatFile; class CCopyDatFile;
} }
enum Columns {
ColName = 0,
ColSize,
ColType,
ColPerm,
ColOwner,
ColGroup,
ColModified,
ColCount
};
class CCopyDatFile : public QWidget class CCopyDatFile : public QWidget
{ {
@ -27,14 +38,16 @@ private slots:
//void cancelDownload(); //void cancelDownload();
void ftpCommandFinished(int commandId, bool error); void ftpCommandFinished(int commandId, bool error);
void addToList(const QUrlInfo &urlInfo);
void addToDistList(const QUrlInfo &urlInfo);
void on_pushButton_refresh_clicked(); void on_pushButton_refresh_clicked();
void processItem(QTreeWidgetItem *item, int column); void processItem(QTreeWidgetItem *item, int column);
void on_treeWidget_customContextMenuRequested(const QPoint &pos); void on_treeWidget_customContextMenuRequested(const QPoint &pos);
void slotCopyItem(); void slotCopyItem();
void on_pushButton_exit_clicked(); void on_pushButton_exit_clicked();
void onItemDoubleClicked(QTreeWidgetItem *item, int column);
void fillTreeWidget(
QTreeWidget *tree,
const QVector<RemoteFileInfo> &files,
const QString &currentPath);
private: private:
Ui::CCopyDatFile *ui; Ui::CCopyDatFile *ui;
QHash<QString, bool> isDirectory; QHash<QString, bool> isDirectory;
@ -44,6 +57,7 @@ private:
QString currentPath; QString currentPath;
QString m_strDistPath; QString m_strDistPath;
QAction *copyAction; QAction *copyAction;
ScpClient scp;
}; };
#endif // COPYDATFILE_H #endif // COPYDATFILE_H

17
DataWatch3500_GUI.pro
View File

@ -6,11 +6,11 @@
QT += core gui network charts QT += core gui network charts
greaterThan(QT_MAJOR_VERSION, 4): QT += widgets sql ftp printsupport greaterThan(QT_MAJOR_VERSION, 4): QT += widgets sql printsupport
TARGET = DataWatch3500_GUI TARGET = DataWatch3500_GUI
TEMPLATE = app TEMPLATE = app
win32:CONFIG += console
# The following define makes your compiler emit warnings if you use # The following define makes your compiler emit warnings if you use
# any feature of Qt which has been marked as deprecated (the exact warnings # any feature of Qt which has been marked as deprecated (the exact warnings
# depend on your compiler). Please consult the documentation of the # depend on your compiler). Please consult the documentation of the
@ -76,6 +76,7 @@ SOURCES += \
BoardSetting.cpp \ BoardSetting.cpp \
UnitSetting.cpp \ UnitSetting.cpp \
WorkingCondition.cpp \ WorkingCondition.cpp \
scp_client.cpp \
sqlitedb.cpp sqlitedb.cpp
HEADERS += \ HEADERS += \
@ -129,6 +130,7 @@ HEADERS += \
BoardSetting.h \ BoardSetting.h \
UnitSetting.h \ UnitSetting.h \
WorkingCondition.h \ WorkingCondition.h \
scp_client.h \
sqlitedb.h \ sqlitedb.h \
utils_global.h utils_global.h
@ -182,7 +184,8 @@ DISTFILES += \
INCLUDEPATH += $$PWD/include/mqtt INCLUDEPATH += $$PWD/include/mqtt
INCLUDEPATH += $$PWD/include/fftw INCLUDEPATH += $$PWD/include/fftw
INCLUDEPATH += $$PWD/include/libssh2
INCLUDEPATH += $$PWD/include/openssl
win32:CONFIG(release, debug|release): LIBS += -L$$PWD/lib/fftw/ -llibfftw3-3 -llibfftw3f-3 -llibfftw3l-3 win32:CONFIG(release, debug|release): LIBS += -L$$PWD/lib/fftw/ -llibfftw3-3 -llibfftw3f-3 -llibfftw3l-3
else:win32:CONFIG(debug, debug|release): LIBS += -L$$PWD/lib/fftw/ -llibfftw3-3 -llibfftw3f-3 -llibfftw3l-3 else:win32:CONFIG(debug, debug|release): LIBS += -L$$PWD/lib/fftw/ -llibfftw3-3 -llibfftw3f-3 -llibfftw3l-3
@ -191,3 +194,11 @@ else:unix: LIBS += -L$$PWD/lib/fftw/ -lfftw3
win32:CONFIG(release, debug|release): LIBS += -L$$PWD/lib/mqtt/ -lQt5Qmqtt win32:CONFIG(release, debug|release): LIBS += -L$$PWD/lib/mqtt/ -lQt5Qmqtt
else:win32:CONFIG(debug, debug|release): LIBS += -L$$PWD/lib/mqtt/ -lQt5Qmqttd else:win32:CONFIG(debug, debug|release): LIBS += -L$$PWD/lib/mqtt/ -lQt5Qmqttd
else:unix: LIBS += -L$$PWD/lib/mqtt/ -lQt5Qmqtt else:unix: LIBS += -L$$PWD/lib/mqtt/ -lQt5Qmqtt
win32:CONFIG(release, debug|release): LIBS += -L$$PWD/lib/openssl/ -lssl -lcrypto -lws2_32
else:win32:CONFIG(debug, debug|release): LIBS += -L$$PWD/lib/openssl/ -lssl -lcrypto -lws2_32
else:unix: LIBS += -L$$PWD/lib/openssl/linux -lssl -lcrypto
win32:CONFIG(release, debug|release): LIBS += -L$$PWD/lib/libssh2/ -lssh2
else:win32:CONFIG(debug, debug|release): LIBS += -L$$PWD/lib/libssh2/ -lssh2
else:unix: LIBS += -L$$PWD/lib/libssh2/linux -lssh2

47
FileServerConfig.cpp
View File

@ -1,6 +1,7 @@
#include "FileServerConfig.h" #include "FileServerConfig.h"
#include "ui_FileServerConfig.h" #include "ui_FileServerConfig.h"
#include "NetMgr.h" #include "NetMgr.h"
#include "scp_client.h"
CFileServerConfig::CFileServerConfig(QWidget *parent) : CFileServerConfig::CFileServerConfig(QWidget *parent) :
QWidget(parent), QWidget(parent),
@ -224,10 +225,14 @@ void CFileServerConfig::on_pushButtonPush_clicked()
file.write(jsonDoc.toJson()); file.write(jsonDoc.toJson());
file.close(); file.close();
QString str2 = QString("ftp://%1/CIDW/qtconfig/%2").arg(IP).arg("NetWorkConfig.json"); QString remotePath = QString("/CIDW/qtconfig/%1").arg("NetWorkConfig.json");
g_FtpClient->SetServerInfo(str2); ScpClient scp;
g_FtpClient->SetUserInfo("root","@#cidw!@123456"); bool res = scp.connectToHost(IP, 22, "root", "@#cidw!@123456");
g_FtpClient->UpLoadFile(fileName,"NetWorkConfig.json"); if(!res){
QMessageBox::information(nullptr, QStringLiteral("提示"), "连接失败！");
return;
}
scp.upload(fileName, remotePath,"NetWorkConfig.json");
QJsonObject tempObj,OptionObj; QJsonObject tempObj,OptionObj;
OptionObj["localServerIpAddress"] = ui->lineEdit_ServerIP->text(); OptionObj["localServerIpAddress"] = ui->lineEdit_ServerIP->text();
@ -254,10 +259,9 @@ void CFileServerConfig::on_pushButtonPush_clicked()
file2.write(jsonDoc.toJson()); file2.write(jsonDoc.toJson());
file2.close(); file2.close();
QString str3 = QString("ftp://%1/CIDW/qtconfig/%2").arg(IP).arg("ServerConfig.json"); remotePath = QString("/CIDW/qtconfig/%1").arg("ServerConfig.json");
g_FtpClient->SetServerInfo(str3); scp.upload(fileName, remotePath,"ServerConfig.json");
g_FtpClient->SetUserInfo("root","@#cidw!@123456"); scp.disconnectFromHost();
g_FtpClient->UpLoadFile(fileName,"ServerConfig.json");
} }
void CFileServerConfig::slotNetMgr(QString sAddr, const QVariant &msg) void CFileServerConfig::slotNetMgr(QString sAddr, const QVariant &msg)
@ -346,11 +350,15 @@ void CFileServerConfig::on_pushButtonConfirm_clicked()
file.open(QIODevice::WriteOnly); file.open(QIODevice::WriteOnly);
file.write(jsonDoc.toJson()); file.write(jsonDoc.toJson());
file.close(); file.close();
QString remotePath = QString("/CIDW/qtconfig/%1").arg("TcpConfig.json");
QString str = QString("ftp://%1/CIDW/qtconfig/%2").arg(IP).arg("TcpConfig.json"); ScpClient scp;
g_FtpClient->SetServerInfo(str); bool res = scp.connectToHost(IP, 22, "root", "@#cidw!@123456");
g_FtpClient->SetUserInfo("root","@#cidw!@123456"); if(!res){
g_FtpClient->UpLoadFile(fileName,"TcpConfig.json"); QMessageBox::information(nullptr, QStringLiteral("提示"), "连接失败！");
return;
}
scp.upload(fileName, remotePath,"TcpConfig.json");
scp.disconnectFromHost();
} }
@ -375,9 +383,14 @@ void CFileServerConfig::on_pushButtonConfirm2_clicked()
file.write(jsonDoc.toJson()); file.write(jsonDoc.toJson());
file.close(); file.close();
QString str = QString("ftp://%1/CIDW/qtconfig/%2").arg(IP).arg("ModbusConfig.json"); QString remotePath = QString("/CIDW/qtconfig/%1").arg("ModbusConfig.json");
g_FtpClient->SetServerInfo(str); ScpClient scp;
g_FtpClient->SetUserInfo("root","@#cidw!@123456"); bool res = scp.connectToHost(IP, 22, "root", "@#cidw!@123456");
g_FtpClient->UpLoadFile(fileName,"ModbusConfig.json"); if(!res){
QMessageBox::information(nullptr, QStringLiteral("提示"), "连接失败！");
return;
}
scp.upload(fileName, remotePath,"ModbusConfig.json");
scp.disconnectFromHost();
} }

48
HistoryAlarm.cpp
View File

@ -7,6 +7,7 @@
#include "ftpclient.h" #include "ftpclient.h"
#include "global.h" #include "global.h"
#include "NetMgr.h" #include "NetMgr.h"
#include "scp_client.h"
CHistoryAlarm::CHistoryAlarm(QWidget *parent) : CHistoryAlarm::CHistoryAlarm(QWidget *parent) :
QWidget(parent), QWidget(parent),
@ -552,13 +553,16 @@ void CHistoryAlarm::OpenDatFile(QString& strFileName)
void CHistoryAlarm::downloadProcess_Slot(qint64 byteSend, qint64 byteTotal) void CHistoryAlarm::downloadProcess_Slot(qint64 byteSend, qint64 byteTotal)
{ {
qDebug() << byteSend << byteTotal << endl; qDebug() << byteSend << byteTotal << endl;
downloadProgressDialog->setRange(0, byteTotal); if (byteTotal <= 0) return;
downloadProgressDialog->setValue(byteSend); if (!downloadProgressDialog || downloadProgressDialog->wasCanceled()) {
if(byteSend == byteTotal){ return;
disconnect(g_FtpClient,SIGNAL(sigDownloadProcess(qint64 , qint64 )),this,SLOT(downloadProcess_Slot(qint64 , qint64)));
customLogMessageHandler(QtDebugMsg,"HistoryAlarm Open:" + g_LocalFile);
OpenDatFile(g_LocalFile);
} }
if (downloadProgressDialog->maximum() != byteTotal) {
downloadProgressDialog->setRange(0, byteTotal);
}
downloadProgressDialog->setValue(byteSend);
int percent = (double)byteSend / byteTotal * 100.0;
downloadProgressDialog->setLabelText(tr("正在下载... %1%").arg(percent));
} }
void CHistoryAlarm::Details(const QModelIndex &index) void CHistoryAlarm::Details(const QModelIndex &index)
@ -585,20 +589,30 @@ void CHistoryAlarm::Details(const QModelIndex &index)
if(file.exists()){ if(file.exists()){
OpenDatFile(strPath); OpenDatFile(strPath);
}else{ }else{
downloadProgressDialog = new QProgressDialog(this); downloadProgressDialog = new QProgressDialog(this);
downloadProgressDialog->setWindowFlags(Qt::CustomizeWindowHint | Qt::FramelessWindowHint); downloadProgressDialog->setWindowFlags(Qt::Dialog | Qt::FramelessWindowHint | Qt::CustomizeWindowHint);
downloadProgressDialog->setWindowModality(Qt::WindowModal); downloadProgressDialog->setWindowModality(Qt::WindowModal);
downloadProgressDialog->setWindowTitle(tr("Please Wait")); downloadProgressDialog->setLabelText(tr("正在下载... 0%"));
downloadProgressDialog->setLabelText(tr("下载中...")); downloadProgressDialog->setCancelButtonText(tr("取消"));
//downloadProgressDialog->setCancelButton(0);
downloadProgressDialog->show(); downloadProgressDialog->show();
qDebug() << "file2" << endl; if(this->isVisible()){
connect(g_FtpClient,SIGNAL(sigDownloadProcess(qint64 , qint64 )),this,SLOT(downloadProcess_Slot(qint64 , qint64))); int x = this->geometry().center().x() - downloadProgressDialog->width() / 2;
//connect(g_FtpClient,SIGNAL(sigDownloadStatus()),this,SLOT(DownloadStatus_Slot())); int y = this->geometry().center().y() - downloadProgressDialog->height() / 2;
QString str = QString("ftp://%1/").arg(IP); downloadProgressDialog->move(x, y);
g_FtpClient->SetServerInfo(str); }
g_FtpClient->SetUserInfo("root","@#cidw!@123456"); ScpClient scp;
g_FtpClient->DownLoad(strFileName,strPath); connect(downloadProgressDialog, &QProgressDialog::canceled, [&scp]() {
// 执行停止下载的操作
scp.cancel();
qDebug() << "Download task canceled by user.";
});
connect(&scp, SIGNAL(progress(qint64 , qint64 )), this,SLOT(downloadProcess_Slot(qint64 , qint64 )));
connect(&scp, SIGNAL(error(const QString &)), this,SLOT(downloadError_Slot(const QString &)));
connect(&scp, SIGNAL(finished()), this,SLOT(downloadFinished_Slot()));
scp.connectToHost(IP, 22, "root", "cidw!@123456");
scp.download(strFileName, strPath);
qDebug() << "filename_list" << strPath;
} }
} }

44
ImportConfig.cpp
View File

@ -3,6 +3,7 @@
#include <QFileDialog> #include <QFileDialog>
#include <QProcess> #include <QProcess>
#include "sqlitedb.h" #include "sqlitedb.h"
#include "scp_client.h"
CImportConfig::CImportConfig(QWidget *parent) : CImportConfig::CImportConfig(QWidget *parent) :
QWidget(parent), QWidget(parent),
@ -172,6 +173,14 @@ void CImportConfig::on_pushButton_confirm_clicked()
copyDir2.removeRecursively(); copyDir2.removeRecursively();
} }
QString remotePath = "";
ScpClient scp;
bool res = scp.connectToHost(IP, 22, "root", "@#cidw!@123456");
if(!res){
QMessageBox::information(nullptr, QStringLiteral("提示"), "连接失败！");
return;
}
#ifdef Q_OS_WIN32 #ifdef Q_OS_WIN32
QString fileNameInfo = QCoreApplication::applicationDirPath() + "\\config\\UnitWorkConditionsInfo.json"; QString fileNameInfo = QCoreApplication::applicationDirPath() + "\\config\\UnitWorkConditionsInfo.json";
@ -180,9 +189,8 @@ void CImportConfig::on_pushButton_confirm_clicked()
QString fileNameInfo = QCoreApplication::applicationDirPath() + "/config/UnitWorkConditionsInfo.json"; QString fileNameInfo = QCoreApplication::applicationDirPath() + "/config/UnitWorkConditionsInfo.json";
#endif #endif
QString strURL = QString("ftp://%1/CIDW/qtconfig/%2").arg(IP).arg("UnitWorkConditionsInfo.json"); remotePath = QString("/CIDW/qtconfig/%1").arg("UnitWorkConditionsInfo.json");
scp.upload(fileNameInfo, remotePath,"UnitWorkConditionsInfo.json");
g_FtpClient->uploadFile(strURL,fileNameInfo,"UnitWorkConditionsInfo.json");
@ -192,10 +200,10 @@ void CImportConfig::on_pushButton_confirm_clicked()
#ifdef Q_OS_LINUX #ifdef Q_OS_LINUX
QString fileNameUnit = QCoreApplication::applicationDirPath() + "/config/UnitConfigurations.json"; QString fileNameUnit = QCoreApplication::applicationDirPath() + "/config/UnitConfigurations.json";
#endif #endif
remotePath = QString("/CIDW/qtconfig/%1").arg("UnitConfigurations.json");
scp.upload(fileNameUnit, remotePath,"UnitConfigurations.json");
QString str2 = QString("ftp://%1/CIDW/qtconfig/%2").arg(IP).arg("UnitConfigurations.json");
g_FtpClient->uploadFile(str2,fileNameUnit,"UnitConfigurations.json");
#ifdef Q_OS_WIN32 #ifdef Q_OS_WIN32
QString fileNameUnit2 = QCoreApplication::applicationDirPath() + "\\config\\UnitConfigurations2.json"; QString fileNameUnit2 = QCoreApplication::applicationDirPath() + "\\config\\UnitConfigurations2.json";
#endif #endif
@ -203,9 +211,8 @@ void CImportConfig::on_pushButton_confirm_clicked()
QString fileNameUnit2 = QCoreApplication::applicationDirPath() + "/config/UnitConfigurations2.json"; QString fileNameUnit2 = QCoreApplication::applicationDirPath() + "/config/UnitConfigurations2.json";
#endif #endif
QString str22 = QString("ftp://%1/CIDW/qtconfig/%2").arg(IP).arg("UnitConfigurations2.json"); remotePath = QString("/CIDW/qtconfig/%1").arg("UnitConfigurations2.json");
scp.upload(fileNameUnit2, remotePath,"UnitConfigurations2.json");
g_FtpClient->uploadFile(str22,fileNameUnit2,"UnitConfigurations2.json");
#ifdef Q_OS_WIN32 #ifdef Q_OS_WIN32
QString fileNameTri = QCoreApplication::applicationDirPath() + "\\config\\TriggerSettings.json"; QString fileNameTri = QCoreApplication::applicationDirPath() + "\\config\\TriggerSettings.json";
@ -213,10 +220,8 @@ void CImportConfig::on_pushButton_confirm_clicked()
#ifdef Q_OS_LINUX #ifdef Q_OS_LINUX
QString fileNameTri = QCoreApplication::applicationDirPath() + "/config/TriggerSettings.json"; QString fileNameTri = QCoreApplication::applicationDirPath() + "/config/TriggerSettings.json";
#endif #endif
remotePath = QString("/CIDW/qtconfig/%1").arg("TriggerSettings.json");
QString str1 = QString("ftp://%1/CIDW/qtconfig/%2").arg(IP).arg("TriggerSettings.json"); scp.upload(fileNameTri, remotePath,"TriggerSettings.json");
g_FtpClient->uploadFile(str1,fileNameTri,"TriggerSettings.json");
#ifdef Q_OS_WIN32 #ifdef Q_OS_WIN32
QString fileNameTri2 = QCoreApplication::applicationDirPath() + "\\config\\TriggerSettings2.json"; QString fileNameTri2 = QCoreApplication::applicationDirPath() + "\\config\\TriggerSettings2.json";
@ -225,9 +230,8 @@ void CImportConfig::on_pushButton_confirm_clicked()
QString fileNameTri2 = QCoreApplication::applicationDirPath() + "/config/TriggerSettings2.json"; QString fileNameTri2 = QCoreApplication::applicationDirPath() + "/config/TriggerSettings2.json";
#endif #endif
QString strTri2 = QString("ftp://%1/CIDW/qtconfig/%2").arg(IP).arg("TriggerSettings2.json"); remotePath = QString("/CIDW/qtconfig/%1").arg("TriggerSettings2.json");
scp.upload(fileNameTri2, remotePath,"TriggerSettings2.json");
g_FtpClient->uploadFile(strTri2,fileNameTri2,"TriggerSettings2.json");
#ifdef Q_OS_WIN32 #ifdef Q_OS_WIN32
QString name = QCoreApplication::applicationDirPath() + "\\config\\UnitBoardsInfo.json"; QString name = QCoreApplication::applicationDirPath() + "\\config\\UnitBoardsInfo.json";
@ -235,9 +239,8 @@ void CImportConfig::on_pushButton_confirm_clicked()
#ifdef Q_OS_LINUX #ifdef Q_OS_LINUX
QString name = QCoreApplication::applicationDirPath() + "/config/UnitBoardsInfo.json"; QString name = QCoreApplication::applicationDirPath() + "/config/UnitBoardsInfo.json";
#endif #endif
QString str = QString("ftp://%1/CIDW/qtconfig/%2").arg(IP).arg("UnitBoardsInfo.json"); remotePath = QString("/CIDW/qtconfig/%1").arg("UnitBoardsInfo.json");
scp.upload(name, remotePath,"UnitBoardsInfo.json");
g_FtpClient->uploadFile(str,name,"UnitBoardsInfo.json");
#ifdef Q_OS_WIN32 #ifdef Q_OS_WIN32
QString fileNameChannel = QCoreApplication::applicationDirPath() + "\\config\\ChannelSettings.json"; QString fileNameChannel = QCoreApplication::applicationDirPath() + "\\config\\ChannelSettings.json";
@ -245,9 +248,10 @@ void CImportConfig::on_pushButton_confirm_clicked()
#ifdef Q_OS_LINUX #ifdef Q_OS_LINUX
QString fileNameChannel = QCoreApplication::applicationDirPath() + "/config/ChannelSettings.json"; QString fileNameChannel = QCoreApplication::applicationDirPath() + "/config/ChannelSettings.json";
#endif #endif
QString strChannelSettings = QString("ftp://%1/CIDW/qtconfig/%2").arg(IP).arg("ChannelSettings.json"); remotePath = QString("/CIDW/qtconfig/%1").arg("ChannelSettings.json");
scp.upload(fileNameChannel, remotePath,"ChannelSettings.json");
g_FtpClient->uploadFile(strChannelSettings,fileNameChannel,"ChannelSettings.json"); scp.disconnectFromHost();
qApp->exit(0); qApp->exit(0);
QProcess::startDetached(qApp->applicationFilePath(), QStringList()); QProcess::startDetached(qApp->applicationFilePath(), QStringList());

19
NTPServerConfig.cpp
View File

@ -3,7 +3,7 @@
#include "NetMgr.h" #include "NetMgr.h"
#include <QTime> #include <QTime>
#include <QRegExpValidator> #include <QRegExpValidator>
#include "ftpclient.h" #include "scp_client.h"
CNTPServerConfig::CNTPServerConfig(QWidget *parent) : CNTPServerConfig::CNTPServerConfig(QWidget *parent) :
QWidget(parent), QWidget(parent),
@ -154,11 +154,18 @@ void CNTPServerConfig::slotReplyStatus(int result)
file.write(jsonDoc.toJson()); file.write(jsonDoc.toJson());
file.close(); file.close();
} }
disconnect(g_NetMgr,SIGNAL(sigReplyStatus(int)), this, SLOT(slotReplyStatus(int)));
} }
void CNTPServerConfig::on_radioButton_switch_clicked() void CNTPServerConfig::on_radioButton_switch_clicked()
{ {
connect(g_FtpClient, SIGNAL(sigReplyStatus(int)), this, SLOT(slotReplyStatus(int))); ScpClient scp;
bool res = scp.connectToHost(IP, 22, "root", "@#cidw!@123456");
if(!res){
QMessageBox::information(nullptr, QStringLiteral("提示"), "连接失败！");
return;
}
connect(g_NetMgr, SIGNAL(sigReplyStatus(int)), this, SLOT(slotReplyStatus(int)));
QJsonObject NTPServerObj,itemObj; QJsonObject NTPServerObj,itemObj;
itemObj["ntpNetworkStation"] = ui->lineEdit_NTP_IP->text(); itemObj["ntpNetworkStation"] = ui->lineEdit_NTP_IP->text();
@ -187,11 +194,9 @@ void CNTPServerConfig::on_radioButton_switch_clicked()
file.open(QIODevice::WriteOnly); file.open(QIODevice::WriteOnly);
file.write(jsonDoc.toJson()); file.write(jsonDoc.toJson());
file.close(); file.close();
QString remotePath = QString("/CIDW/qtconfig/%1").arg("ServerConfig.json");
QString str = QString("ftp://%1/CIDW/qtconfig/%2").arg(IP).arg("ServerConfig.json"); scp.upload(fileName, remotePath,"ServerConfig.json",4);
g_FtpClient->SetServerInfo(str); scp.disconnectFromHost();
g_FtpClient->SetUserInfo("root","@#cidw!@123456");
g_FtpClient->UpLoadFile(fileName,"ServerConfig.json",4);
} }

22
NetMgr.cpp
View File

@ -17,6 +17,7 @@
#include <QMessageAuthenticationCode> #include <QMessageAuthenticationCode>
#include "log.h" #include "log.h"
#include "global.h" #include "global.h"
#include <QMessageBox>
enum{ enum{
HTTP_CMD_ID = QNetworkRequest::User+100, HTTP_CMD_ID = QNetworkRequest::User+100,
@ -343,13 +344,32 @@ void NetMgr::httpFinished(QNetworkReply *reply)
void NetMgr::parseData(const QByteArray &szData, const QString &sUrlPath, QString sAddr) void NetMgr::parseData(const QByteArray &szData, const QString &sUrlPath, QString sAddr)
{ {
//qDebug() << sUrlPath << szData; qDebug() << sUrlPath << szData;
QJsonDocument doc = QJsonDocument::fromJson(szData); QJsonDocument doc = QJsonDocument::fromJson(szData);
QJsonObject obj = doc.object(); QJsonObject obj = doc.object();
QVariant var; QVariant var;
var.setValue(obj); var.setValue(obj);
customLogMessageHandler(QtDebugMsg,QString(QJsonDocument(obj).toJson())); customLogMessageHandler(QtDebugMsg,QString(QJsonDocument(obj).toJson()));
emit sigNetMgr(sAddr, var); emit sigNetMgr(sAddr, var);
QJsonObject objec = var.value<QJsonObject>();
qDebug() << objec;
if(objec.contains("cmd"))
{
QJsonValue arrays_value = objec.take("cmd");
qDebug()<<"cmd ="<<arrays_value.toString();
if(arrays_value.toString() == "90" || arrays_value.toString() == "46" )
{
bool Status = objec.take("success").toBool();
QString strMessage = objec.take("message").toString();
if(Status){
sigReplyStatus(1);
QMessageBox::information(nullptr, QStringLiteral("提示"), QStringLiteral("保存成功！"));
}else{
QMessageBox::information(nullptr, QStringLiteral("提示"), strMessage);
sigReplyStatus(0);
}
}
}
} }
void NetMgr::setReqUserAttr(QNetworkRequest &req, QVariant attr) void NetMgr::setReqUserAttr(QNetworkRequest &req, QVariant attr)

1
NetMgr.h
View File

@ -16,6 +16,7 @@ class NetMgr:public QObject
Q_OBJECT Q_OBJECT
signals: signals:
void sigNetMgr(QString sAddr,const QVariant& variant); void sigNetMgr(QString sAddr,const QVariant& variant);
void sigReplyStatus(int result);
public: public:
static NetMgr& instance(); static NetMgr& instance();
NetMgr(QObject* parent = nullptr); NetMgr(QObject* parent = nullptr);

16
OtherConfig.cpp
View File

@ -5,7 +5,8 @@
#include <QTextCodec> #include <QTextCodec>
#include <QInputDialog> #include <QInputDialog>
#include <QFileDialog> #include <QFileDialog>
#include "ftpclient.h" #include <QtNetwork/QNetworkRequest>
#include "scp_client.h"
COtherConfig::COtherConfig(QWidget *parent) : COtherConfig::COtherConfig(QWidget *parent) :
QWidget(parent), QWidget(parent),
@ -240,10 +241,15 @@ void COtherConfig::on_pushButto_Trigger_clicked()
file.write(jsonDoc.toJson()); file.write(jsonDoc.toJson());
file.close(); file.close();
} }
QString strURL = QString("ftp://%1/CIDW/qtconfig/%2").arg(IP).arg("TriggerConfig.json"); QString remotePath = QString("/CIDW/qtconfig/%1").arg("TriggerConfig.json");
g_FtpClient->SetServerInfo(strURL); ScpClient scp;
g_FtpClient->SetUserInfo("root","@#cidw!@123456"); bool res = scp.connectToHost(IP, 22, "root", "@#cidw!@123456");
g_FtpClient->UpLoadFile(fileName,"TriggerConfig.json"); if(!res){
QMessageBox::information(nullptr, QStringLiteral("提示"), "连接失败！");
return;
}
scp.upload(fileName, remotePath,"TriggerConfig.json");
scp.disconnectFromHost();
} }
QString COtherConfig::GBK2UTF8(QByteArray inStr) QString COtherConfig::GBK2UTF8(QByteArray inStr)
{ {

52
RealTimeAlarm.cpp
View File

@ -5,7 +5,7 @@
#include "AlarmDetails.h" #include "AlarmDetails.h"
#include "sqlitedb.h" #include "sqlitedb.h"
#include <QTimeZone> #include <QTimeZone>
#include "ftpclient.h" #include "scp_client.h"
CRealTimeAlarm::CRealTimeAlarm(QWidget *parent) : CRealTimeAlarm::CRealTimeAlarm(QWidget *parent) :
@ -500,20 +500,22 @@ void CRealTimeAlarm::OpenDatFile(QString& strFileName)
} }
DateViewdialog->SetDataIDs(strIDList, tr("Data Watch "),strChannleType,strChannleNameList); DateViewdialog->SetDataIDs(strIDList, tr("Data Watch "),strChannleType,strChannleNameList);
} }
void CRealTimeAlarm::DownloadStatus_Slot() void CRealTimeAlarm::downloadFinished_Slot()
{ {
OpenDatFile(g_LocalFile); OpenDatFile(g_LocalFile);
disconnect(g_FtpClient,SIGNAL(sigDownloadProcess(qint64 , qint64 )),this,SLOT(downloadProcess_Slot(qint64 , qint64)));
disconnect(g_FtpClient,SIGNAL(sigDownloadStatus()),this,SLOT(DownloadStatus_Slot()));
} }
void CRealTimeAlarm::downloadProcess_Slot(qint64 byteSend, qint64 byteTotal) void CRealTimeAlarm::downloadProcess_Slot(qint64 byteSend, qint64 byteTotal)
{ {
downloadProgressDialog->setRange(0, byteTotal); if (byteTotal <= 0) return;
downloadProgressDialog->setValue(byteSend); if (!downloadProgressDialog || downloadProgressDialog->wasCanceled()) {
if(byteSend == byteTotal){ return;
disconnect(g_FtpClient,SIGNAL(sigDownloadProcess(qint64 , qint64 )),this,SLOT(downloadProcess_Slot(qint64 , qint64)));
OpenDatFile(g_LocalFile);
} }
if (downloadProgressDialog->maximum() != byteTotal) {
downloadProgressDialog->setRange(0, byteTotal);
}
downloadProgressDialog->setValue(byteSend);
int percent = (double)byteSend / byteTotal * 100.0;
downloadProgressDialog->setLabelText(tr("正在下载... %1%").arg(percent));
} }
void CRealTimeAlarm::Details(const QModelIndex &index) void CRealTimeAlarm::Details(const QModelIndex &index)
@ -541,20 +543,30 @@ void CRealTimeAlarm::Details(const QModelIndex &index)
qDebug() << "file1" << endl; qDebug() << "file1" << endl;
OpenDatFile(strPath); OpenDatFile(strPath);
}else{ }else{
downloadProgressDialog = new QProgressDialog(this); downloadProgressDialog = new QProgressDialog(this);
downloadProgressDialog->setWindowFlags(Qt::CustomizeWindowHint | Qt::FramelessWindowHint); downloadProgressDialog->setWindowFlags(Qt::Dialog | Qt::FramelessWindowHint | Qt::CustomizeWindowHint);
downloadProgressDialog->setWindowModality(Qt::WindowModal); downloadProgressDialog->setWindowModality(Qt::WindowModal);
downloadProgressDialog->setWindowTitle(tr("Please Wait")); downloadProgressDialog->setLabelText(tr("正在下载... 0%"));
downloadProgressDialog->setLabelText(tr("下载中...")); downloadProgressDialog->setCancelButtonText(tr("取消"));
//downloadProgressDialog->setCancelButton(0);
downloadProgressDialog->show(); downloadProgressDialog->show();
qDebug() << "file2" << endl; if(this->isVisible()){
connect(g_FtpClient,SIGNAL(sigDownloadProcess(qint64 , qint64 )),this,SLOT(downloadProcess_Slot(qint64 , qint64))); int x = this->geometry().center().x() - downloadProgressDialog->width() / 2;
//connect(g_FtpClient,SIGNAL(sigDownloadStatus()),this,SLOT(DownloadStatus_Slot())); int y = this->geometry().center().y() - downloadProgressDialog->height() / 2;
QString str = QString("ftp://%1/").arg(IP); downloadProgressDialog->move(x, y);
g_FtpClient->SetServerInfo(str); }
g_FtpClient->SetUserInfo("root","@#cidw!@123456"); ScpClient scp;
g_FtpClient->DownLoad(strFileName,strPath); connect(downloadProgressDialog, &QProgressDialog::canceled, [&scp]() {
// 执行停止下载的操作
scp.cancel();
qDebug() << "Download task canceled by user.";
});
connect(&scp, SIGNAL(progress(qint64 , qint64 )), this,SLOT(downloadProcess_Slot(qint64 , qint64 )));
connect(&scp, SIGNAL(error(const QString &)), this,SLOT(downloadError_Slot(const QString &)));
connect(&scp, SIGNAL(finished()), this,SLOT(downloadFinished_Slot()));
scp.connectToHost(IP, 22, "root", "cidw!@123456");
scp.download(strFileName, strPath);
qDebug() << "filename_list" << strPath;
} }
} }

2
RealTimeAlarm.h
View File

@ -29,7 +29,7 @@ private slots:
public slots: public slots:
void downloadProcess_Slot(qint64 byteSend, qint64 byteTotal); void downloadProcess_Slot(qint64 byteSend, qint64 byteTotal);
void DownloadStatus_Slot(); void downloadFinished_Slot();
signals: signals:
void ItemCheckStateSignal(QString strID, bool bChecked); void ItemCheckStateSignal(QString strID, bool bChecked);
private: private:

16
TerminalInfo.cpp
View File

@ -2,7 +2,7 @@
#include "ui_TerminalInfo.h" #include "ui_TerminalInfo.h"
#include "NetMgr.h" #include "NetMgr.h"
#include <QNetworkRequest> #include <QNetworkRequest>
#include "ftpclient.h" #include "scp_client.h"
#include "CopyDatFile.h" #include "CopyDatFile.h"
#include "Backup.h" #include "Backup.h"
#include "ImportConfig.h" #include "ImportConfig.h"
@ -287,14 +287,20 @@ void CTerminalInfo::on_pushButton_Update_clicked()
if(FileName.isEmpty()) if(FileName.isEmpty())
return; return;
QString str = QString("ftp://%1/var/%2").arg(IP).arg(FileName);
g_FtpClient->SetServerInfo(str);
g_FtpClient->SetUserInfo("root","@#cidw!@123456");
if(text == "系统") if(text == "系统")
curIndex = 0; curIndex = 0;
else if(text == "后端主程序") else if(text == "后端主程序")
curIndex = 1; curIndex = 1;
g_FtpClient->UpLoadFile(filepath,FileName,curIndex);
QString remotePath = QString("/var/%1").arg(FileName);
ScpClient scp;
bool res = scp.connectToHost(IP, 22, "root", "@#cidw!@123456");
if(!res){
QMessageBox::information(this, QStringLiteral("提示"), "连接失败！");
return;
}
scp.upload(filepath, remotePath,FileName,curIndex);
scp.disconnectFromHost();
} }

22
TriggerConfig.cpp
View File

@ -4,6 +4,7 @@
#include <QListView> #include <QListView>
#include "ftpclient.h" #include "ftpclient.h"
#include "ViewTriggerConfig.h" #include "ViewTriggerConfig.h"
#include "scp_client.h"
CTriggerConfig::CTriggerConfig(QWidget *parent) : CTriggerConfig::CTriggerConfig(QWidget *parent) :
QWidget(parent), QWidget(parent),
@ -837,16 +838,17 @@ void CTriggerConfig::PushData()
g_SqliteDB->GetTriggerConfig("t_TriggerConfig",""); g_SqliteDB->GetTriggerConfig("t_TriggerConfig","");
QString str = QString("ftp://%1/CIDW/qtconfig/%2").arg(IP).arg("TriggerSettings.json"); QString remotePath = QString("/CIDW/qtconfig/%1").arg("TriggerSettings.json");
g_FtpClient->SetServerInfo(str); ScpClient scp;
g_FtpClient->SetUserInfo("root","@#cidw!@123456"); bool res = scp.connectToHost(IP, 22, "root", "@#cidw!@123456");
g_FtpClient->UpLoadFile(fileName,"TriggerSettings.json"); if(!res){
QMessageBox::information(nullptr, QStringLiteral("提示"), "连接失败！");
QString str2 = QString("ftp://%1/CIDW/qtconfig/%2").arg(IP).arg("TriggerSettings2.json"); return;
g_FtpClient->SetServerInfo(str2); }
g_FtpClient->SetUserInfo("root","@#cidw!@123456"); scp.upload(fileName, remotePath,"TriggerSettings.json");
g_FtpClient->UpLoadFile(fileName2,"TriggerSettings2.json"); remotePath = QString("/CIDW/qtconfig/%1").arg("TriggerSettings2.json");
scp.upload(fileName, remotePath,"TriggerSettings2.json");
scp.disconnectFromHost();
disconnect(g_NetMgr,SIGNAL(sigNetMgr(QString, const QVariant&)), this, SLOT(slotNetMgr(QString,const QVariant&))); disconnect(g_NetMgr,SIGNAL(sigNetMgr(QString, const QVariant&)), this, SLOT(slotNetMgr(QString,const QVariant&)));

15
UnitSetting.cpp
View File

@ -3,6 +3,7 @@
#include "global.h" #include "global.h"
#include <QListView> #include <QListView>
#include "ftpclient.h" #include "ftpclient.h"
#include "scp_client.h"
CUnitSetting::CUnitSetting(QWidget *parent) : CUnitSetting::CUnitSetting(QWidget *parent) :
QWidget(parent), QWidget(parent),
@ -316,10 +317,16 @@ void CUnitSetting::PushData()
file.open(QIODevice::WriteOnly); file.open(QIODevice::WriteOnly);
file.write(jsonDoc.toJson()); file.write(jsonDoc.toJson());
file.close(); file.close();
QString str = QString("ftp://%1/CIDW/qtconfig/%2").arg(IP).arg("UnitParameters.json");
g_FtpClient->SetServerInfo(str); QString remotePath = QString("/CIDW/qtconfig/%1").arg("UnitParameters.json");
g_FtpClient->SetUserInfo("root","@#cidw!@123456"); ScpClient scp;
g_FtpClient->UpLoadFile(fileName,"UnitParameters.json"); bool res = scp.connectToHost(IP, 22, "root", "@#cidw!@123456");
if(!res){
QMessageBox::information(nullptr, QStringLiteral("提示"), "连接失败！");
return;
}
scp.upload(fileName, remotePath,"UnitParameters.json");
scp.disconnectFromHost();
disconnect(g_NetMgr,SIGNAL(sigNetMgr(QString, const QVariant&)), this, SLOT(slotNetMgr(QString,const QVariant&))); disconnect(g_NetMgr,SIGNAL(sigNetMgr(QString, const QVariant&)), this, SLOT(slotNetMgr(QString,const QVariant&)));
} }

15
WorkingCondition.cpp
View File

@ -4,6 +4,7 @@
#include <QListView> #include <QListView>
#include "NetMgr.h" #include "NetMgr.h"
#include "ftpclient.h" #include "ftpclient.h"
#include "scp_client.h"
CWorkingcondition::CWorkingcondition(QWidget *parent) : CWorkingcondition::CWorkingcondition(QWidget *parent) :
QWidget(parent), QWidget(parent),
@ -871,12 +872,16 @@ void CWorkingcondition::PushData()
file.write(jsonDoc.toJson()); file.write(jsonDoc.toJson());
file.close(); file.close();
QString str = QString("ftp://%1/CIDW/qtconfig/%2").arg(IP).arg("UnitWorkConditionsInfo.json");
g_FtpClient->SetServerInfo(str);
g_FtpClient->SetUserInfo("root","@#cidw!@123456");
g_FtpClient->UpLoadFile(fileName,"UnitWorkConditionsInfo.json");
disconnect(g_NetMgr,SIGNAL(sigNetMgr(QString, const QVariant&)), this, SLOT(slotNetMgr(QString,const QVariant&)));
QString remotePath = QString("ftp://%1/CIDW/qtconfig/%2").arg(IP).arg("UnitWorkConditionsInfo.json");
ScpClient scp;
bool res = scp.connectToHost(IP, 22, "root", "@#cidw!@123456");
if(!res){
QMessageBox::information(this, QStringLiteral("提示"), "连接失败！");
return;
}
scp.upload(fileName, remotePath,"UnitWorkConditionsInfo.json");
} }
void CWorkingcondition::slotNetMgr(QString sAddr, const QVariant &msg) void CWorkingcondition::slotNetMgr(QString sAddr, const QVariant &msg)
{ {

36
ftpclient.cpp
View File

@ -46,24 +46,24 @@ void FtpClient::SetServerInfo(const QString fileAddr, int Port/* =21 */)
void FtpClient::slotNetMgr(QString sAddr, const QVariant &msg) void FtpClient::slotNetMgr(QString sAddr, const QVariant &msg)
{ {
QJsonObject objec = msg.value<QJsonObject>(); // QJsonObject objec = msg.value<QJsonObject>();
if(objec.contains("cmd")) // if(objec.contains("cmd"))
{ // {
QJsonValue arrays_value = objec.take("cmd"); // QJsonValue arrays_value = objec.take("cmd");
qDebug()<<"cmd ="<<arrays_value.toString(); // qDebug()<<"cmd ="<<arrays_value.toString();
if(arrays_value.toString() == "90" || arrays_value.toString() == "46" ) // if(arrays_value.toString() == "90" || arrays_value.toString() == "46" )
{ // {
bool Status = objec.take("success").toBool(); // bool Status = objec.take("success").toBool();
QString strMessage = objec.take("message").toString(); // QString strMessage = objec.take("message").toString();
if(Status){ // if(Status){
sigReplyStatus(1); // sigReplyStatus(1);
QMessageBox::information(this, QStringLiteral("提示"), QStringLiteral("保存成功！")); // QMessageBox::information(this, QStringLiteral("提示"), QStringLiteral("保存成功！"));
}else{ // }else{
QMessageBox::information(this, QStringLiteral("提示"), strMessage); // QMessageBox::information(this, QStringLiteral("提示"), strMessage);
sigReplyStatus(0); // sigReplyStatus(0);
} // }
} // }
} // }
} }
void FtpClient::finished(QNetworkReply* reply) void FtpClient::finished(QNetworkReply* reply)

1
mainwindow.cpp
View File

@ -17,7 +17,6 @@ MainWindow::MainWindow(QWidget *parent) :
g_SqliteDB->OpenDataBase(); g_SqliteDB->OpenDataBase();
g_NetMgr = new NetMgr(this); g_NetMgr = new NetMgr(this);
g_FtpClient = new FtpClient();
//读取ini //读取ini

1
realtimeform.cpp
View File

@ -1007,6 +1007,7 @@ void CRealTimeForm::LoadGraphicsConfig(int type) {
pText->setData(4, key["static"].toString()); pText->setData(4, key["static"].toString());
pText->setDefaultTextColor(QColor(31, 81, 136)); pText->setDefaultTextColor(QColor(31, 81, 136));
pText->setFont(font2); pText->setFont(font2);
pText->setPlainText("0.0");
} }
pItemGroup->addToGroup(pText); pItemGroup->addToGroup(pText);
} }

491
scp_client.cpp Normal file
View File

@ -0,0 +1,491 @@
#include "scp_client.h"
#include <QFile>
#include <QDebug>
#ifdef Q_OS_UNIX
#include <pwd.h>
#include <grp.h>
#endif
#ifdef _WIN32
#include <winsock2.h>
#include <ws2tcpip.h>
#else
#include <arpa/inet.h>
#include <netinet/in.h>
#include <sys/socket.h>
#include <unistd.h>
#endif
#include "NetMgr.h"
#include <QJsonArray>
#include <QJsonObject>
#include <QtNetwork/QNetworkRequest>
#include "global.h"
ScpClient::ScpClient(QObject *parent)
: QObject(parent)
{
#ifdef _WIN32
WSADATA wsadata;
WSAStartup(MAKEWORD(2,2), &wsadata);
#endif
m_sock = -1;
m_session = nullptr;
}
ScpClient::~ScpClient()
{
disconnectFromHost();
#ifdef _WIN32
WSACleanup();
#endif
}
void ScpClient::cancel()
{
m_cancelled.store(true);
}
bool ScpClient::connectToHost(const QString &host,
int port,
const QString &user,
const QString &password,
int timeoutMs)
{
disconnectFromHost();
m_sock = socket(AF_INET, SOCK_STREAM, 0);
if (m_sock < 0) {
emit error("Failed to create socket");
return false;
}
struct sockaddr_in sin{};
sin.sin_family = AF_INET;
#ifdef _WIN32
sin.sin_addr.s_addr = inet_addr(host.toUtf8().constData());
#else
if (inet_pton(AF_INET, host.toUtf8().constData(), &sin.sin_addr) <= 0) {
emit error("Invalid IP address");
return false;
}
#endif
sin.sin_port = htons(port);
if (::connect(m_sock, (struct sockaddr*)&sin, sizeof(sin)) != 0) {
emit error("Failed to connect");
return false;
}
m_session = libssh2_session_init();
if (!m_session) {
emit error("Failed to init libssh2 session");
return false;
}
// 阻塞模式
libssh2_session_set_blocking(m_session, 1);
if (libssh2_session_handshake(m_session, m_sock) != 0) {
emit error("Handshake failed");
return false;
}
if (libssh2_userauth_password(
m_session,
user.toUtf8().constData(),
password.toUtf8().constData()) != 0)
{
emit error("Authentication failed");
return false;
}
return true;
}
void ScpClient::disconnectFromHost()
{
m_cancelled.store(true);
if (m_session) {
libssh2_session_disconnect(m_session, "Bye");
libssh2_session_free(m_session);
m_session = nullptr;
}
#ifdef _WIN32
if (m_sock != -1) closesocket(m_sock);
#else
if (m_sock != -1) close(m_sock);
#endif
m_sock = -1;
}
bool ScpClient::download(const QString &remotePath, const QString &localPath)
{
if (!m_session) return false;
m_cancelled.store(false);
libssh2_struct_stat st;
// 使用 scp_recv2 获取远程文件信息
LIBSSH2_CHANNEL* channel = libssh2_scp_recv2(
m_session,
remotePath.toUtf8().constData(),
&st);
if (!channel) {
char *errmsg;
libssh2_session_last_error(m_session, &errmsg, nullptr, 0);
emit error(QString("SCP recv failed: %1").arg(errmsg));
return false;
}
QFile file(localPath);
if (!file.open(QIODevice::WriteOnly)) {
emit error("Open local file failed");
libssh2_channel_free(channel);
return false;
}
qint64 totalSize = st.st_size;
qint64 received = 0;
char buffer[16384]; // 使用 16KB 固定缓冲区
while (received < totalSize && !m_cancelled.load()) {
if (m_cancelled.load()) {
emit error("Download cancelled");
break;
}
// 计算剩余需要读取的字节数，防止溢出
int toRead = sizeof(buffer);
if (totalSize - received < toRead) {
toRead = totalSize - received;
}
ssize_t rc = libssh2_channel_read(channel, buffer, toRead);
if (rc > 0) {
file.write(buffer, rc);
received += rc;
emit progress(received, totalSize);
} else if (rc < 0) {
emit error("Read error during download");
break;
} else {
// rc == 0 意味着服务器提前关闭了流
break;
}
}
file.flush();
file.close();
// 标准清理流程
libssh2_channel_free(channel);
if (!m_cancelled.load() && received != totalSize) {
emit error("File size mismatch (Incomplete download)");
return false;
}
emit finished();
return received == totalSize;
}
bool ScpClient::upload(const QString &localPath,
const QString &remotePath,const QString& fileName,int type,
int fileMode)
{
if (!m_session) return false;
m_cancelled.store(false);
m_Type = type;
m_fileName = fileName;
QFile file(localPath);
if (!file.open(QIODevice::ReadOnly)) {
emit error("Open local file failed");
return false;
}
qint64 fileSize = file.size();
qint64 sent = 0;
LIBSSH2_CHANNEL* channel = libssh2_scp_send64(
m_session,
remotePath.toUtf8().constData(),
fileMode,
fileSize,
0, 0);
if (!channel) {
emit error("SCP send failed");
return false;
}
char buffer[16384];
while (sent < fileSize) {
if (m_cancelled.load()) {
emit error("Upload cancelled");
break;
}
qint64 n = file.read(buffer, sizeof(buffer));
if (n <= 0) break;
char* ptr = buffer;
while (n > 0) {
ssize_t rc = libssh2_channel_write(channel, ptr, n);
if (rc <= 0) {
emit error("Write failed");
goto cleanup;
}
ptr += rc;
n -= rc;
sent += rc;
emit progress(sent, fileSize);
if(sent == fileSize){
uploadFinish();
}
}
}
cleanup:
libssh2_channel_send_eof(channel);
libssh2_channel_wait_eof(channel);
libssh2_channel_wait_closed(channel);
libssh2_channel_free(channel);
file.close();
emit finished();
return sent == fileSize;
}
void ScpClient::uploadFinish(){
if(m_fileName != ""){
qDebug() << "uploadFinish" ;
QJsonObject allObj,cmdBody,temp;
QJsonArray tempArray;
if(m_fileName.contains(".json")){
allObj.insert("cmd", "90");
temp["fileName"] = m_fileName;
if(m_Type >= 0)
temp["content"] = m_Type;
tempArray.append(temp);
allObj.insert("cmdBody",tempArray);
}else{
allObj.insert("cmd", "46");
allObj.insert("type", m_Type);
temp["fileName"] = m_fileName;
allObj.insert("cmdBody",temp);
}
qDebug() << allObj << endl;
QNetworkRequest req;
QString sUrl = QString("http://%1/cgi-bin/General.cgi/").arg(IP);
req.setUrl(sUrl);
g_NetMgr->PostJson(req,allObj);
m_fileName = "";
m_Type = -1;
}
}
QString ScpClient::uidToName(uint uid)
{
#ifdef Q_OS_UNIX
struct passwd *pw = getpwuid(uid);
if (pw)
return QString::fromLocal8Bit(pw->pw_name);
#endif
return QString::number(uid);
}
QString ScpClient::gidToName(uint gid)
{
#ifdef Q_OS_UNIX
struct group *gr = getgrgid(gid);
if (gr)
return QString::fromLocal8Bit(gr->gr_name);
return QString::number(gid);
#endif
return QString::number(gid);
}
void ScpClient::waitSocket(SOCKET sock)
{
fd_set fds;
FD_ZERO(&fds);
FD_SET(sock, &fds);
timeval tv;
tv.tv_sec = 10;
tv.tv_usec = 0;
select(0, &fds, &fds, nullptr, &tv);
}
bool ScpClient::listRemoteDir(const QString &path,
QVector<RemoteFileInfo> &outList)
{
outList.clear();
LIBSSH2_SFTP *sftp = nullptr;
for (;;) {
sftp = libssh2_sftp_init(m_session);
if (sftp)
break;
int err = libssh2_session_last_errno(m_session);
if (err == LIBSSH2_ERROR_EAGAIN) {
waitSocket(m_sock); // 必须
continue;
}
qDebug() << "sftp init failed:" << err;
return false;
}
if (!sftp) {
emit error("sftp init failed");
return false;
}
LIBSSH2_SFTP_HANDLE *dir =
libssh2_sftp_opendir(sftp, path.toUtf8().constData());
if (!dir) {
emit error("sftp opendir failed: " + path);
libssh2_sftp_shutdown(sftp);
return false;
}
char filename[512];
LIBSSH2_SFTP_ATTRIBUTES attrs;
while (true) {
memset(&attrs, 0, sizeof(attrs));
int rc = libssh2_sftp_readdir(dir, filename, sizeof(filename), &attrs);
if (rc <= 0)
break;
QString name = QString::fromUtf8(filename);
if (name == "." || name == "..")
continue;
RemoteFileInfo info;
info.name = name;
info.size = static_cast<qint64>(attrs.filesize);
info.permissions = attrs.permissions;
info.isDir = LIBSSH2_SFTP_S_ISDIR(attrs.permissions);
if (attrs.mtime) {
info.lastModified =
QDateTime::fromSecsSinceEpoch(attrs.mtime);
}
info.uid = attrs.uid;
info.gid = attrs.gid;
info.owner = uidToName(attrs.uid);
info.group = gidToName(attrs.gid);
outList.push_back(info);
}
libssh2_sftp_closedir(dir);
libssh2_sftp_shutdown(sftp);
QString out;
if (exec("pwd", out))
m_currentPath = out.trimmed();
else
m_currentPath = "/";
return true;
}
bool ScpClient::makeRemoteDir(const QString &path, int mode)
{
LIBSSH2_SFTP *sftp = libssh2_sftp_init(m_session);
if (!sftp)
return false;
int rc = libssh2_sftp_mkdir(
sftp, path.toUtf8().constData(), mode);
libssh2_sftp_shutdown(sftp);
return (rc == 0);
}
bool ScpClient::removeRemoteFile(const QString &path)
{
LIBSSH2_SFTP *sftp = libssh2_sftp_init(m_session);
if (!sftp)
return false;
int rc = libssh2_sftp_unlink(
sftp, path.toUtf8().constData());
libssh2_sftp_shutdown(sftp);
return (rc == 0);
}
bool ScpClient::removeRemoteDir(const QString &path)
{
LIBSSH2_SFTP *sftp = libssh2_sftp_init(m_session);
if (!sftp)
return false;
int rc = libssh2_sftp_rmdir(
sftp, path.toUtf8().constData());
libssh2_sftp_shutdown(sftp);
return (rc == 0);
}
bool ScpClient::renameRemote(const QString &oldPath,
const QString &newPath)
{
LIBSSH2_SFTP *sftp = libssh2_sftp_init(m_session);
if (!sftp)
return false;
int rc = libssh2_sftp_rename(
sftp,
oldPath.toUtf8().constData(),
newPath.toUtf8().constData());
libssh2_sftp_shutdown(sftp);
return (rc == 0);
}
bool ScpClient::exec(const QString &cmd, QString &output)
{
LIBSSH2_CHANNEL *channel = libssh2_channel_open_session(m_session);
if (!channel)
return false;
if (libssh2_channel_exec(channel, cmd.toUtf8().constData()) != 0) {
libssh2_channel_free(channel);
return false;
}
char buffer[4096];
for (;;) {
ssize_t n = libssh2_channel_read(channel, buffer, sizeof(buffer));
if (n <= 0)
break;
output.append(QString::fromUtf8(buffer, n));
}
libssh2_channel_close(channel);
libssh2_channel_free(channel);
return true;
}
bool ScpClient::goUp()
{
if (m_currentPath.isEmpty() || m_currentPath == "/")
return true; // 已经在根目录，仍返回 true
int idx = m_currentPath.lastIndexOf('/');
if (idx <= 0) {
m_currentPath = "/";
} else {
m_currentPath = m_currentPath.left(idx);
}
// 测试能否列出目录，确保路径有效
QString dummy;
QString cmd = QString("ls -l %1").arg(m_currentPath);
if (!exec(cmd, dummy))
return false;
return true;
}

83
scp_client.h Normal file
View File

@ -0,0 +1,83 @@
#pragma once
#include <QObject>
#include <QString>
#include <atomic>
#include <libssh2.h>
#include <libssh2_sftp.h>
#include <sys/stat.h>
#include <QDateTime>
#ifndef LIBSSH2_S_ISDIR
#define LIBSSH2_S_ISDIR(mode) (((mode) & LIBSSH2_SFTP_S_IFMT) == LIBSSH2_SFTP_S_IFDIR)
#endif
#ifndef LIBSSH2_S_ISREG
#define LIBSSH2_S_ISREG(mode) (((mode) & LIBSSH2_SFTP_S_IFMT) == LIBSSH2_SFTP_S_IFREG)
#endif
struct RemoteFileInfo {
QString name;
qint64 size;
bool isDir;
uint permissions;
QDateTime lastModified; // 修改日期
uint uid; // 用户ID
uint gid; // 组ID
QString owner; // 用户名
QString group; // 组名
};
class ScpClient : public QObject
{
Q_OBJECT
public:
explicit ScpClient(QObject *parent = nullptr);
~ScpClient();
bool connectToHost(const QString &host,
int port,
const QString &user,
const QString &password,
int timeoutMs = 10000);
void disconnectFromHost();
bool download(const QString &remotePath,
const QString &localPath);
bool upload(const QString &localPath,
const QString &remotePath,const QString& fileName,int type = -1,
int fileMode = 0644);
void cancel();
void uploadFinish();
// ===== SFTP 相关 =====
bool listRemoteDir(const QString &path, QVector<RemoteFileInfo> &outList);
bool makeRemoteDir(const QString &path, int mode = 0755);
bool removeRemoteFile(const QString &path);
bool removeRemoteDir(const QString &path);
bool renameRemote(const QString &oldPath, const QString &newPath);
bool exec(const QString &cmd, QString &output);
void waitSocket(SOCKET sock);
bool goUp();
QString m_currentPath;
signals:
void progress(qint64 current, qint64 total);
void error(const QString &msg);
void finished();
private:
int m_sock{-1};
LIBSSH2_SESSION *m_session{nullptr};
std::atomic_bool m_cancelled{false};
int m_Type;
QString m_fileName;
QString uidToName(uint uid);
QString gidToName(uint gid);
};