DataProcessService/DataProcessService/ytUserInfoProcess/userinfoprocesscore.h

#ifndef USERINFOPROCESSCORE_H
#define USERINFOPROCESSCORE_H
//#define SyncIface
#define JdxfDb

//#define SubCenter

#include <QObject>
#include <QSqlDatabase>
#include <QTcpServer>
#include <QTcpSocket>
#include <QHostAddress>
#include <QUrl>
#include <QTimer>
#include <json-c/json.h>

#include "userinfocommthread.h"
#include "databasethread.h"
//#include "reportsender.h"
#include "logthread.h"
#include "wssserver.h"

#ifdef SyncIface
//#include "changningsyncthread.h"
#include "syncchangning.h"
#endif

#include "wechartthreads.h"
#include "ttsthreads.h"
//#include "RepThread.h"

class AlarmSet {
public:
    AlarmSet(unsigned int idx, QString name="", QString data="", quint8 type=0, uint time=0, quint8 enabled=0){
        DeviceIdx = idx;
        DevName = name;
        AlarmData = data;
        dwType = type;
        AlarmTime = time;
        Enabled = enabled;
    }

    unsigned int DeviceIdx;
    quint8 dwType;
    QString DevName;
    QString AlarmData;
    uint AlarmTime;
    quint8 Enabled;
};

class UserInfoProcessCore : public QObject
{
    Q_OBJECT
public:
    explicit UserInfoProcessCore(QObject *parent = nullptr);
    bool chk1byte(quint8 d, quint8 v);
    bool chk2byte(quint16 d, quint16 v);
    bool chk4byte(quint32 d, quint32 v);
    bool check_dev(qulonglong devId);
    quint16 get_method(qulonglong devId);
    QString getMAddr(quint64 devid, quint16 method, quint8 sysAddr, quint64 uaddr);
    qint16 getDeviceIdx(quint64 addr);
    QString getSysStructType(quint8 stype);
    QString getUnitType(quint8 utype);
    QString devNumStr(quint64 addr);
    QString getOwnerAddr(quint64 devid, quint8 sysAddr, quint32 areaid, quint32 point, quint32 hostNum);
    void start();
    void appendReportCount(quint64 srcAddr, quint8 repType);

    void getBuildingFireCtrlSysStatusReport(quint16 sn,quint64 srcAddr,quint64 destAddr,quint8 dataType,quint8 sysType,quint8 sysAddr,quint16 sysStatus,QDateTime sendTime,QDateTime reportTime);
    void getBuildingFireCtrlSysStatusRestoreReport(quint16 sn,quint64 srcAddr,quint64 destAddr,quint8 dataType,quint8 sysType,quint8 sysAddr,quint16 sysStatus,QDateTime sendTime,QDateTime reportTime);
    void getBuildingFireCtrlUintStatusRestoreReport(quint16 sn,quint64 srcAddr,quint64 destAddr,quint8 dataType,quint8 sysType,quint8 sysAddr,quint8 unitType, quint32 unitAddr,quint16 uintStatus,QString unitNote,QDateTime sendTime,QDateTime reportTime);
    void getBuildingFireCtrlUintStatusReport2(quint16 sn,quint64 srcAddr,quint64 destAddr,quint8 dataType,quint8 sysType,quint8 sysAddr,quint8 unitType, quint32 unitAddr,quint32 uintStatus,QString unitNote,QDateTime sendTime,QDateTime reportTime);
    void getBuildingFireCtrlUintStatusRestoreReport2(quint16 sn,quint64 srcAddr,quint64 destAddr,quint8 dataType,quint8 sysType,quint8 sysAddr,quint8 unitType, quint32 unitAddr,quint32 uintStatus,QString unitNote,QDateTime sendTime,QDateTime reportTime);
    void getBuildingFireCtrlUintDateReport(quint16 sn,quint64 srcAddr,quint64 destAddr,quint8 dataType,quint8 sysType,quint8 sysAddr,quint8 unitType, quint32 unitAddr,quint8 unitDataType,qint16 uintData,QDateTime sendTime, QDateTime reportTime);
    void getBuildingFireCtrlOperationReport(quint16 sn,quint64 srcAddr,quint64 destAddr,quint8 dataType,quint8 sysType,quint8 sysAddr,quint8 operationType, quint8 userId,QDateTime sendTime,QDateTime reportTime);
    void getBuildingFireCtrlVersionReport(quint16 sn,quint64 srcAddr,quint64 destAddr,quint8 dataType,quint8 sysType,quint8 sysAddr,quint16 version,QDateTime sendTime);
    void getBuildingFireCtrlSystemNoteReport(quint16 sn,quint64 srcAddr,quint64 destAddr,quint8 dataType,quint8 sysType,quint8 sysAddr,QString sysNote,QDateTime sendTime);
    void getBuildingFireCtrlUintNoteReport(quint16 sn,quint64 srcAddr,quint64 destAddr,quint8 dataType,quint8 sysType,quint8 sysAddr,quint8 unitType, quint32 unitAddr,QString unitNote,QDateTime sendTime);
    void getBuildingFireCtrlTimeReport(quint16 sn,quint64 srcAddr,quint64 destAddr,quint8 dataType,quint8 sysType,quint8 sysAddr,QDateTime sendTime,QDateTime reportTime);
    void getBuildingFireUserinfoStaReport(quint16 sn,quint64 srcAddr,quint64 destAddr,quint8 dataType,quint8 userinfoStatus,QDateTime sendTime,QDateTime reportTime);
    void getBuildingFireUserinfoStaRestoreReport(quint16 sn,quint64 srcAddr,quint64 destAddr,quint8 dataType,quint8 userinfoStatus,QDateTime sendTime,QDateTime reportTime);
    void getBuildingFireUserinfoVersionReport(quint16 sn,quint64 srcAddr,quint64 destAddr,quint8 dataType,quint16 version,QDateTime sendTime);
    void getBuildingFireUserinfoParamNoteReport(quint16 sn,quint64 srcAddr,quint64 destAddr,quint8 dataType,QString pNote,QDateTime sendTime);
    void getBuildingFireUserinfoTimeReport(quint16 sn,quint64 srcAddr,quint64 destAddr,quint8 dataType,QDateTime sendTime,QDateTime uiTime);
    void getBuildingFireUserinfoManuDateReport(quint16 sn,quint64 srcAddr,quint64 destAddr,quint8 dataType,QDateTime sendTime,QDateTime manuTime);
    void getBuildingFireUserinfoSignupTimeReport(quint16 sn,quint64 srcAddr,quint64 destAddr,quint8 dataType,QDateTime sendTime,QDateTime signupTime);
    void getBuildingFireUserinfoBootReport(quint16 sn,quint64 srcAddr,quint64 destAddr,quint8 dataType,quint8 userId,QDateTime sendTime,QDateTime bootTime);
    void getBuildingFireUserinfoShutdownReport(quint16 sn,quint64 srcAddr,quint64 destAddr,quint8 dataType,quint8 userId,QDateTime sendTime,QDateTime shutdownTime);
    void getBuildingFireCtrlSysBootReport(quint16 sn,quint64 srcAddr,quint64 destAddr,quint8 dataType,quint8 sysType,quint8 sysAddr,QDateTime sendTime,QDateTime bootTime);
    void getBuildingFireCtrlSysShutdownReport(quint16 sn,quint64 srcAddr,quint64 destAddr,quint8 dataType,quint8 sysType,quint8 sysAddr,QDateTime sendTime,QDateTime shutdownTime);
    void getBuildingFireUserinfoCommStaReport(quint16 sn, quint64 srcAddr, quint64 destAddr, quint8 dataType, quint8 commSta, QDateTime sendTime, QDateTime reportTime);
    void getBuildingFireUserinfoCommStaRestoreReport(quint16 sn, quint64 srcAddr, quint64 destAddr, quint8 dataType, quint8 commSta, QDateTime sendTime, QDateTime reportTime);
    void getBuildingFireUserinfoPostsoutReport(quint16 sn, quint64 srcAddr, quint64 destAddr, quint8 dataType, quint8 userId, QDateTime sendTime, QDateTime reportTime);
    void getBuildingFireCtrlUintFireTypeReport(quint16 sn,quint64 srcAddr,quint64 destAddr,quint8 dataType,quint8 sysType,quint8 sysAddr,quint8 unitType, quint32 unitAddr,quint16 fireType,QString unitNote,QDateTime sendTime,QDateTime reportTime);
    void getBuildingFireCtrlSysActStatusReport(quint16 sn,quint64 srcAddr,quint64 destAddr,quint8 dataType,quint8 sysType,quint8 sysAddr,quint16 actStatus,QDateTime sendTime,QDateTime reportTime);
    void getBuildingFireUserinfoOptTimeReport(quint16 sn,quint64 srcAddr,quint64 destAddr,quint8 dataType,quint8 userId,QDateTime sendTime,QDateTime reportTime);
    bool check_voicealarm(qulonglong devid);
//    void getSyncData(quint64 srcAddr, QByteArray data);
    void OnConnected();

signals:
    
public slots:
    void new_incomming();
//    void ui_incomming();
//    void get_cmd();
    void getOnLine(quint64 srcAddr, bool sta);
    void getOffLine(quint64 srcAddr);
    void getBuildingFireCtrlReport(quint8 dataType, QString ip, void *data);
    void time_out();
    void appendLOg(QString log);
    void CommData(QString deviceid, int dir, QString data);
    void getWrongData(QString data);
    void AlarmReport(quint64 addr, quint64 insertid, QString type, QString time, QString name,quint64 port=0, QString address="");
    void getHaertBeat(quint64 srcAddr);
    void wxchart(quint16 idx, QDateTime t, QString data, bool dirflag);
    void ttslog(quint16 idx, QDateTime t, QString data, bool dirflag);
    void replog(quint16 idx, QDateTime t, QString data, bool dirflag);
    void wsslog(quint16 idx, QDateTime t, QString data, bool dirflag);
    void getSyncData(quint64 srcAddr, QByteArray data);
    void MqttInfo(QString infoStr,QString alarmStr,QString statusStr,QString topic1,QString topic2,QString topic3);
    void MqttConnect(QString ip,QString port,QString name,QString passwd);

private:
    QTcpServer *sr;//, *usr;
    DataBaseThread *dbThread;
    LogThread *logthread;
    QTimer *timer;
    quint32 CurrentIdx;
    quint8 wxcur,ttscur,repcur;
    WechartThreads *wxThreads[2][16];
    ttsThreads *voiceThreads[16];
    ttsThreads *repThread[16],*wssThread[16];
    QSqlDatabase db;
    WssServer *wssServer;

    QMQTT::Client *m_client;
    quint16 idx1;
    quint16 idx2;
    quint16 idx3;


#ifdef SubCenter
    bool SyncWorking;
    uint SyncTime_T;
    uint lastSyncTime_T;
    QTcpSocket *syncSo;
#endif
//#ifdef JdxfDb
//    ReportSender *wxSender1, *wxSender2;
//#endif
#ifdef SyncIface
    SyncChangning *syncThread;
#endif
//    SyncChangning *syncThread[16];
};

#endif // USERINFOPROCESSCORE_H