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,
             std::list<DeviceController*>>  m_mpDevControler;   // 订阅列表

public slots:
    void sltSubData_td(const std::string, const std::string);
    void sltSubData_mqtt(const std::string, const std::string);

private:
    void startup_DataAlarm(DeviceInfo di);
    void startup_CommAlarm(DeviceInfo di);
    void startup_AlarmMgr(DeviceInfo di);

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