DataProcessService/DataProcessService/ytWaterProcess/watercore.h

#ifndef WATERCORE_H
#define WATERCORE_H

#include <QObject>
#include <QString>
#include <QTimer>
#include <qmqtt.h>
#include "waterserver.h"
#include "waterserver2.h"
#include "waterserver3.h"
#include "waterserver4.h"
#include "wateruserver.h"
#include "wateruserver2.h"
#include "databasethread.h"
#include "logthread.h"
#include "../ytUserInfoProcess/wechartthreads.h"
#include "../ytRTUProcess/ttsthreads.h"
#include "redis.h"

class WaterCore : public QObject
{
    Q_OBJECT
public:
    explicit WaterCore(QObject *parent = nullptr);
    ~WaterCore();
    void start();
    int redis_init();
    int redis_save(const char *cmd);
    QString redis_qstring(const char *cmd);
    int redis_int(const char *cmd);
    void redis_free();
signals:

public slots:
    void timeout();
    void getOnLine(int deviceidx, QString deviceid, bool flag, QDateTime t);
    void getValue(int deviceidx, QString deviceid, QString d1, int d2, int d3, double d4, QString d5, QDateTime t);
    void getAlarm(int deviceidx, QString deviceid, QString d1, int d2, int d3, double d4, QString d5, QString note, QDateTime t);
    void getCommData(QString data);
    void AlarmReport(QString addr, quint64 insertid, QString type, QString time);
    void wxchart(quint16 idx, QDateTime t, QString data, bool dirflag);
    void repLog(quint16 idx, QDateTime t, QString data, bool dirflag);
    void SqlLog(QString log);
    void mqttConnect(QString ip,QString port,QString name,QString passwd);
    void mqconnected();
private:
    QTimer *timer;
    DatabaseThread *dbThread;
    LogThread *logThread;
    WaterServer *waterServer;
    waterserver2 *waterServer2;
    waterserver3 *waterServer3;
    WaterServer4 *waterServer4;
    wateruserver *userver;
    wateruserver2 *userver2;
    quint8 wxcur,repcur;
    WechartThreads *wxThreads[3][16];
    ttsThreads *wssThread[16];
    ttsThreads *repThread[16];

    QMQTT::Client *m_client;
    quint16 mqttinfoIdx,mqttalarmIdx,mqttmhinfoIdx,mqttmhalertIdx,mqttmhsta0Idx,mqttmhsta1Idx;
    int redisconnected;
    redisContext *c;
};

#endif // WATERCORE_H