DAProcess.h

#ifndef DAPROCESS_H
#define DAPROCESS_H
#include <QProcess>
#include "DAUtilsAPI.h"
class QThread;
class QTextStream;
namespace DA
{
 
class DAUTILS_API DAProcess : public QProcess
{
    Q_OBJECT
public:
    DAProcess(QObject* par = nullptr);
public slots:
    // 对start函数的槽映射，可以通过object-with-thread模式跨线程运行
    void run();
    void run(QIODevice::OpenMode mode);
    void run(const QString& command, QIODevice::OpenMode mode);
    void run(const QString& program, const QStringList& arguments, QIODevice::OpenMode mode);
    // 设置编码
    void setEncoding(const char* codecName);
signals:
    void processStarandOutput(const QString& str);
    void processErrorOutput(const QString& str);
private slots:
    // 标准输出
    void onReadyReadStandardOutput();
    // 标准错误
    void onReadyReadStandardError();
 
private:
    void setEncoding(QTextStream* ss, const QString& codec);
 
private:
    QString mCodecName;  
};
 
class DAUTILS_API DAProcessWithThread : public QObject
{
    Q_OBJECT
public:
    DAProcessWithThread(QObject* par = nullptr);
    ~DAProcessWithThread();
    // 参数
    void setArguments(const QStringList& arguments);
    QStringList getArguments() const;
    // 设置程序
    void setProgram(const QString& program);
    QString getProgram() const;
    //
public slots:
    // 运行进程，发射beginRunProcess
    void runProcess();
    // kill,发射beginKillProcess
    void kill();
    // terminate,发射beginTerminateProcess
    void terminate();
signals:
    void errorOccurred(QProcess::ProcessError error, const QString& errString);
    void processStarandOutput(const QString& str);
    void processErrorOutput(const QString& str);
    void beginRunProcess();
    void processStarted();
    void processFinished(int code);
    void beginKillProcess();
    void beginTerminateProcess();
 
private:
    DAProcess* mProcess { nullptr };
    QThread* mThread { nullptr };
    //
    QString mProgram;
    QStringList mArguments;
    // 记录最后的错误
    QString mLastError;
};
 
}
 
#endif  // DAPROCESS_H