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 <QUuid>
#include "ytServiceShm.h"
#include "QReplyTimeout.h"
#include "wscenter.h"
#include "logthread.h"
#include "databasethread.h"

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

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

    QString Id;
    QString JsonStr;
};

class YPSyncDev{
public:
    explicit YPSyncDev(int id=0, QString ownerName="", QString ownerCode="",QString unitinfo="",QString company="",int deviceType=0)
    {
        Id = id;
        OwnerName = ownerName;
        OwnerCode = ownerCode;
        Unitinfo = unitinfo;
        Company = company;
        DeviceType = deviceType;
    }

    int Id;
    QString OwnerName;
    QString OwnerCode;
    QString Unitinfo;
    QString Company;
    int DeviceType;
};

class XfzdSyncDev{
public:
    explicit XfzdSyncDev(QString deviceCode="", QString deviceName="", QString descript="",int deviceType=0, QString deviceTypeName="", QString openProjectId="", int devtype=0, QString data="",QString port="",QString deviceFloor="")
    {
        DeviceCode = deviceCode;
        DeviceName = deviceName;
        Descript = descript;
        DeviceType = deviceType;
        DeviceTypeName = deviceTypeName;
        OpenProjectId= openProjectId;
        devCategory = devtype;
        Data = data;
        Port = port;
        DeviceFloor = deviceFloor;
    }

    QString DeviceCode;
    QString DeviceName;
    QString Descript;
    int DeviceType;
    QString DeviceTypeName;
    QString OpenProjectId;
    int devCategory;
    QString Data;
    QString Port;
    QString DeviceFloor;
};

class XfzdSyncRep {
public:
    explicit XfzdSyncRep(int xh=0,QString id="", QString str="", int devcategory=0, QString devicecode=""){
        Xh = xh;
        Id = id;
        JsonStr = str;
        devCategory =devcategory;
        deviceCode = devicecode;
    }

    int Xh;
    int devCategory;
    QString Id;
    QString JsonStr;
    QString deviceCode;
};

class CnPno{
public:
    explicit CnPno(QString name="", int pno=0, QString def=""){
        PName = name;
        Pno = pno;
        Default = def;
    }

    QString PName;
    int Pno;
    QString Default;
};

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

signals:

public slots:
    void time_out();
    void SyncData(QString uuid, QString jsonstr);
    void companyAlarmChanged(QString companyCode);
    void finishedSlot(QNetworkReply *reply);
    void reply_timeout();
    void appendLog(QString log);
    void needSync(QString deviceCode);
    void XfzdSyncData(int xh,QString uuid, QString jsonstr, int devCategory, QString deviceCode);
    void finishedSlot9(QNetworkReply *reply);
    void reply_timeout9();
private:
    QSqlDatabase db,mdb;
    time_t lhworktime,work_time,xfzdworktime,lhworktime1;
    int hour,hour1,minute;
    bool isRunning,isSending,mdbOpened,isSending9;
    int ypCount,ypdisCount,ypxyCount,cnCount,jaCount,hpCount;
    QTimer *timer;
    QList<YPSyncDev> syncDevList;
    QList<XfzdSyncDev> XfzdDevList;
    QList<YpYwSyncRep> ypYwSyncDataList;
    QList<SyncRep> ypSyncdataList;
    QList<SyncRep> ypSyncDisdataList;
    QList<XfzdSyncRep> XfzdSyncdataLiet;
    QNetworkAccessManager *netAccessManager,*XfzdnetAccessManager;
    QStringList sqlList, sqlList2,sqlList3;
    WSCenter *wsCenter;
    uint times;
    LogThread *logThread;
    DataBaseThread *dbThread;
//    WSCenter *wsCenter;
};

#endif // CORE_H