From 12879769af38a00425309e292b2c167afc6612c1 Mon Sep 17 00:00:00 2001
From: pansen <pansen626@sina.com>
Date: 星期四, 04 四月 2019 11:27:38 +0800
Subject: [PATCH] 增加点播功能
---
QiaoJiaSystem/VideoAnalysFromHC/RtspAnalysElement.h | 14 +++++++++++---
1 files changed, 11 insertions(+), 3 deletions(-)
diff --git a/QiaoJiaSystem/VideoAnalysFromHC/RtspAnalysElement.h b/QiaoJiaSystem/VideoAnalysFromHC/RtspAnalysElement.h
index d943d1c..084f8c2 100644
--- a/QiaoJiaSystem/VideoAnalysFromHC/RtspAnalysElement.h
+++ b/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);
};
--
Gitblit v1.8.0