databasethread.h 1.1 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455
  1. #ifndef DATABASETHREAD_H
  2. #define DATABASETHREAD_H
  3. #include <QThread>
  4. #include <QDateTime>
  5. #include <QSqlDatabase>
  6. #include <QSqlQuery>
  7. #include <QSqlError>
  8. #include <QVariant>
  9. #include <QStringList>
  10. #include <QList>
  11. #include <QJsonDocument>
  12. #include <QJsonObject>
  13. #include <QJsonArray>
  14. #include <QJsonValue>
  15. #include <QVariant>
  16. #include <QJsonParseError>
  17. class AlarmRep {
  18. public:
  19. AlarmRep(QString deviceId="",QString sql="",QString atype="", QString t=""){
  20. DeviceId = deviceId;
  21. Sql = sql;
  22. AlarmType = atype;
  23. AlarmTime=t;
  24. }
  25. QString DeviceId;
  26. QString Sql;
  27. QString AlarmType;
  28. QString AlarmTime;
  29. };
  30. class DatabaseThread : public QThread
  31. {
  32. Q_OBJECT
  33. public:
  34. explicit DatabaseThread(QObject *parent = nullptr);
  35. void appendSql(QString sql);
  36. void appendAlarm(AlarmRep rep);
  37. void run();
  38. void check_devicelist();
  39. signals:
  40. void AlarmReport(QString addr, quint64 insertid, QString type, QString time, QString companycode, QString phonelist);
  41. public slots:
  42. private:
  43. int hour;
  44. QSqlDatabase db;
  45. QStringList sqlList;
  46. QList<AlarmRep> alarmRepList;
  47. };
  48. #endif // DATABASETHREAD_H