lp-data-alarm/EngineAlarm/DataEngine.h

#pragma once
#include "../RedisAgent/RedisAgent.h"
#include "../TDAgent/TDAgent.h"
#include "../MQTTAgent/MQTTAgent.h"
#include "BaseModule.h"
#include "DeviceController.h"
#include <QtCore/QObject>
#include <list>

// 模块加载
class DataEngine : public QObject,public DataConsumer
{
    Q_OBJECT
public:
    DataEngine();

private:
    RedisAgent*               m_pRedis;          // 读取配置
    TDAgent*                  m_pTDengine;       // 订阅发布
    MQTTAgent*                m_pMqtt;           // 订阅发布

    std::map<std::string,
             DeviceController*>  m_mpDevControler;

public slots:
    void sltSubData(char* topic, char* msg);

public:
    virtual void OnData(std::string name,QVariant val);
    void Startup();
};