ytService/ytServiceCore整合版本/core.h

#ifndef CORE_H
#define CORE_H

#include <QObject>
#include <QTimer>
#include <QSqlDatabase>
#include <QSqlQuery>
#include <QVariant>
#include <QDir>
#include <QFileInfo>
#include <QDateTime>
#include <QFileInfoList>
#include <QStringList>
#include <QList>
#include <QNetworkAccessManager>
#include <QNetworkRequest>
#include <QNetworkReply>
#include "ytServiceShm.h"
#include "db_syncthread.h"
#include "QReplyTimeout.h"
#include "datacenter.h"
#include "wscenter.h"
#include "logthread.h"
#include "subsysreport.h"
#include "../../DataProcessService/ytUserInfoProcess/wechartthreads.h"

class SyncRep {
public:
    explicit SyncRep(QString id="", QString str=""){
        Id = id;
        JsonStr = str;
    }

    QString Id;
    QString JsonStr;
};

class CnSyncRep {
public:
    explicit CnSyncRep(QString id="", QString str="", int devcategory=0){
        Id = id;
        JsonStr = str;
        devCategory =devcategory;
    }

    int devCategory;
    QString Id;
    QString JsonStr;
};

class JaSyncRep {
public:
    explicit JaSyncRep(int xh=0,QString id="",QString str=""){
        Xh = xh;
        Id = id;
        JsonStr = str;
    }
    int Xh;
    QString Id;
    QString JsonStr;
};

class Core : public QObject
{
    Q_OBJECT
public:
    explicit Core(QObject *parent = 0);
    void start();
    bool chk_table(QString tablename, QStringList tables);
    void db_init();
    QList<JaPno> getJaPnoValue(QString pnoset);
    QList<CnPno> getPnoValue(QString pnoset);

signals:

public slots:
    void time_out();
    void SyncData(QString uuid, QString jsonstr);
    void cnSyncData(QString uuid, QString jsonstr, int devCategory);
    void jaSyncData(int xh,QString uuid,QString jsonstr);
    void companyAlarmChanged(QString companyCode);
    void finishedSlot(QNetworkReply *reply);
    void reply_timeout();
    void finishedSlot2(QNetworkReply *reply);
    void finishedSlot3(QNetworkReply *reply);
    void reply_timeout2();
    void reply_timeout3();
    void chkInList1(QString devid);
    void needSync(QString deviceCode);
    void subReport(quint16 subType, QString DeviceID, quint64 insertId, quint16 flag, QString CompanyCode, QString evt_name, QString evt, QString alarm_time);
    void wxchart(quint16 idx, QDateTime t, QString data, bool dirflag);
    void AlarmReport(QString addr, quint64 insertid, quint16 type, QString CompanyCode, QString evt_name, QString evt, QString alarm_time, int version);
private:
    QSqlDatabase db,mdb;
    time_t work_time,jaworktime;
    bool isRunning,isSending,isSending2,isSending3,mdbOpened;
    QTimer *timer;
    DB_SyncThread *thread;
    QList<JASyncDev> jaDevList;
    QList<YPSyncDev> syncDevList;
    QList<CNSyncDev> cnDevList;
    QList<SyncRep> ypSyncdataList;
    QList<CnSyncRep> cnSyncdataLiet;
    QList<JaSyncRep> jaSyncdataLiet;
    QNetworkAccessManager *netAccessManager, *cnnetAccessManager, *janetAccessManager;
    QStringList sqlList, sqlList2,sqlList3;
    DataCenter *dc;
    WSCenter *wsCenter;
    uint times;
    LogThread *logThread;
    SubSysReport *subReportServer;
    quint8 wxcur,wxcur1,wxcur2,wxcur3,wxcur4,wxcur5;
    WechartThreads *wxThreads[16];
    WechartThreads *wxThreads1[16];
    WechartThreads *wxThreads2[16];
    WechartThreads *wxThreads3[16];
    WechartThreads *wxThreads4[16];
    WechartThreads *wxThreads5[16];
//    WSCenter *wsCenter;
};

#endif // CORE_H