#ifndef CORE_H #define CORE_H #include #include #include #include #include #include #include #include #include #include #include #include #include #include #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 getJaPnoValue(QString pnoset); QList 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 jaDevList; QList syncDevList; QList cnDevList; QList ypSyncdataList; QList cnSyncdataLiet; QList 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