DataProcessService/DataProcessService/ytRTUProcess/databasethread.h

#ifndef DATABASETHREAD_H
#define DATABASETHREAD_H

#include <QThread>
#include <QDateTime>
#include <QSqlDatabase>
#include <QSqlQuery>
#include <QSqlError>
#include <QVariant>
#include <QStringList>
#include <QList>
#include "AlarmReport.h"

class ApTable {
public:
    ApTable(QString deviceid,QString sql,QString time,QString status,QString port,QString ncmd,QString pname,QString data1,QString content){
        DeviceId = deviceid;
        Sql = sql;
        Time = time;
        Status = status;
        Port = port;
        nCmd = ncmd;
        pName = pname;
        Data1 = data1;
        Content = content;
    }
    QString DeviceId;
    QString Sql;
    QString Time;
    QString Status;
    QString Port;
    QString nCmd;
    QString pName;
    QString Data1;
    QString Content;
};

class DatabaseThread : public QThread
{
    Q_OBJECT
public:
    explicit DatabaseThread(QObject *parent = nullptr);
    void appendSql(QString sql);
    void appendAlarm(AlarmRep rep);
    void appendTable(ApTable tab);
    void run();
    void check_devicelist();
    void stop();
signals:
    void AlarmReport(QString addr, quint64 insertid, QString type, QString time, QString ptype, QString pnumber);
    void TableReport(QString deviceid,quint64 insertid,QString time,QString status,QString port,QString ncmd,QString pname,QString data1,QString content);
    void SqlLog(QString log);
    void MqttInfo(QString ip,QString port,QString name,QString passwd);
public slots:

private:
    int hour;
    QSqlDatabase db;
    QStringList sqlList;
    QList<AlarmRep> alarmRepList;
    QList<ApTable> apTableList;
    bool keep;
};

#endif // DATABASETHREAD_H