chenshijun
2019-04-16 f946a62d3921e86b44ff8e2973138304b9cd53cd
QiaoJiaSystem/VideoAnalysFromHC/RtspAnalysElement.h
@@ -11,6 +11,7 @@
#include <VideoServer/QiaoJia/DB/LDBTool.h>
#include <basic/util/app/AppPreference.hpp>
#include "NsqMsgTool.hpp"
class RtspAnalysElement {
@@ -21,7 +22,7 @@
    virtual ~RtspAnalysElement();
    int addCamera(const std::string &, const std::map<int, SdkRule>& sdkRuleMap);
    int addCamera(const std::string &, const std::map<int, SdkRule> &sdkRuleMap);
    int removeCamera(const std::string &);
@@ -36,21 +37,28 @@
private:
    void init();
//    std::string resetFdfs(std::string ip = "", unsigned int port = 0, std::string content = "");
    static void OnMsgFunc(void *msgPtr, void *pThisPtr);
    std::string resetFdfs(std::string ip = "", unsigned int port = 0, std::string content = "");
    static std::vector<int> chnString2Vec(std::string str_list);
//    void setDataByType(Json::Value& json,const SdkRule& rule);
private:
    LDBTool *m_lDBTool;
    //nsq
    BasicMsg::Nsq::NsqMsgConsumer *nsqMsgConsumer;
    LDBTool *m_lDBTool;
    int m_GB28181_Enable;
    std::map<std::string, AppPipeController *> controllers;
    std::atomic<int> currentCount;
    int maxCount;
    FastFdsWithLock fdfsClient;
    std::map<int, SdkRule> sdkRuleMap;
    void addCamWithSearchRuleMap(const Record_Cam_Dev &item, string rtsp_url);
};