!356 fix:修复了更新器安装完成后显示下载完成的bug

Merge pull request !356 from momen/Thunder

spark-update-tool/src/downloadmanager.cpp

@@ -0,0 +1,117 @@
+#include "downloadmanager.h"
+#include <QFileInfo>
+#include <QDir>
+#include <QFile>
+#include <QRegularExpression>
+#include <QDebug>
+
+DownloadManager::DownloadManager(QObject *parent) : QObject(parent)
+{
+    cleanupTempFiles();
+}
+
+void DownloadManager::startDownload(const QString &packageName, const QString &url, const QString &outputPath)
+{
+    if (m_processes.contains(packageName)) {
+        qWarning() << packageName << " is already downloading.";
+        return;
+    }
+
+    QString metalinkUrl = url + ".metalink";
+    QFileInfo fileInfo(outputPath);
+
+    QStringList arguments = {
+        "--enable-rpc=false",
+        "--console-log-level=warn",
+        "--summary-interval=1",
+        "--allow-overwrite=true",
+        "--dir=" + fileInfo.absolutePath(),
+        "--out=" + fileInfo.fileName(),
+        metalinkUrl
+    };
+
+    QProcess *process = new QProcess(this);
+    m_processes.insert(packageName, process);
+
+    // 新增：准备日志文件
+    QString logPath = QString("/tmp/%1_download.log").arg(packageName);
+    QFile *logFile = new QFile(logPath, process);
+    if (logFile->open(QIODevice::Append | QIODevice::Text)) {
+        // 设置权限为777
+        QFile::setPermissions(logPath, QFile::ReadOwner | QFile::WriteOwner | QFile::ExeOwner |
+                                         QFile::ReadGroup | QFile::WriteGroup | QFile::ExeGroup |
+                                         QFile::ReadOther | QFile::WriteOther | QFile::ExeOther);
+        connect(process, &QProcess::readyReadStandardOutput, this, [this, packageName, process, logFile]() {
+            while (process->canReadLine()) {
+                QString line = QString::fromUtf8(process->readLine()).trimmed();
+                // 写入日志
+                logFile->write(line.toUtf8() + '\n');
+                logFile->flush();
+                QRegularExpression regex(R"(\((\d+)%\))");
+                QRegularExpressionMatch match = regex.match(line);
+                if (match.hasMatch()) {
+                    int progress = match.captured(1).toInt();
+                    emit downloadProgress(packageName, progress);
+                }
+            }
+        });
+        connect(process, &QProcess::readyReadStandardError, this, [process, logFile]() {
+            QByteArray err = process->readAllStandardError();
+            logFile->write(err);
+            logFile->flush();
+        });
+    }
+
+    connect(process, QOverload<int, QProcess::ExitStatus>::of(&QProcess::finished),
+            this, [this, packageName, outputPath, logFile](int exitCode, QProcess::ExitStatus status) {
+        bool success = (exitCode == 0 && status == QProcess::NormalExit);
+        if (!success) {
+            qWarning() << "Download failed for" << packageName << "exit code:" << exitCode;
+        }
+
+        removeAria2Files(outputPath); // 清理残留 .aria2
+        emit downloadFinished(packageName, success);
+
+        if (logFile) logFile->close();
+
+        QProcess *proc = m_processes.take(packageName);
+        if (proc) proc->deleteLater();
+    });
+
+    process->start("aria2c", arguments);
+}
+
+void DownloadManager::cancelDownload(const QString &packageName)
+{
+    if (!m_processes.contains(packageName)) return;
+
+    QProcess *process = m_processes.take(packageName);
+    if (process) {
+        process->kill(); // 立即终止
+        process->waitForFinished(3000); // 最多等待3秒
+        process->deleteLater();
+    }
+
+    emit downloadFinished(packageName, false); // 显式通知取消
+
+}
+
+void DownloadManager::removeAria2Files(const QString &filePath)
+{
+    QString ariaFile = filePath + ".aria2";
+    QFile::remove(ariaFile);
+}
+
+bool DownloadManager::isDownloading(const QString &packageName) const
+{
+    return m_processes.contains(packageName);
+}
+
+void DownloadManager::cleanupTempFiles()
+{
+    QDir tempDir(QDir::tempPath());
+    QStringList leftovers = tempDir.entryList(QStringList() << "*.aria2", QDir::Files);
+    for (const QString &f : leftovers) {
+        tempDir.remove(f);
+    }
+}