From e15c4888f720b8781260b901ac82d058f8f7c3b5 Mon Sep 17 00:00:00 2001 From: chenshijun <csj_sky@126.com> Date: 星期三, 27 三月 2019 14:34:37 +0800 Subject: [PATCH] 移植nsq到项目中,将最短最长时长的参数修改成nsq配置 --- QiaoJiaSystem/DataManagerServer/http_configserver.h | 35 +++++++++++++++++++++++++++++++++-- 1 files changed, 33 insertions(+), 2 deletions(-) diff --git a/QiaoJiaSystem/DataManagerServer/http_configserver.h b/QiaoJiaSystem/DataManagerServer/http_configserver.h index a8b8aa6..559119b 100644 --- a/QiaoJiaSystem/DataManagerServer/http_configserver.h +++ b/QiaoJiaSystem/DataManagerServer/http_configserver.h @@ -19,6 +19,7 @@ #include <atomic> #include "../FaceSearchServer/CasiaFaceWrapper/CasiaFaceWrapperN.h" #include "AppPipeController.h" +#include "NsqMsgTool.hpp" typedef std::shared_ptr<HttpServer::Response> PResponse; @@ -107,7 +108,12 @@ std::string loadFaceFeaData(std::string ip, unsigned int port, std::string content, PResponse &response); + std::string getAlarmImageFromVideoFile(std::string ip, unsigned int port, std::string content, PResponse &response); + + + + std::string getRecordVideoPath(std::string ip, unsigned int port, std::string content, PResponse &response); @@ -149,6 +155,10 @@ FastFdsWithLock fdfsClient; + //nsq + BasicMsg::Nsq::NsqMsgProducer *nsqMsgProducer; + + bool getDevSerialNumber(const char *ip, const int port, const char *username, \ const char *passwd, const char *brand, unsigned char *serialNumber) const; @@ -176,12 +186,33 @@ unsigned char *serialNumber = NULL) const; bool createDevId(const int &dev_batch, const int &dev_sequence); - - std::string getVideoPathByTime(const std::string &time, const std::string &camId, qint64 &sub); + std::vector<std::string> forEachFile(const std::string &dir_name); qint64 getVideoTime(/*const std::string& videoPath*/std::string &str_tmpTime); + + + //鏍规嵁PicDate鑾峰彇鎶ヨ鍥� + std::string getAlarmImageByPicDateAndDevId(const std::string& picDate,const std::string& devId, + PResponse &response); + + //鏍规嵁ImgKey鑾峰彇鎶ヨ鍥� + std::string getAlarmImageByImageKeyAndDevId(const std::string& imgKey,const std::string& devId, + PResponse &response); + + //鏍规嵁PicData鑾峰彇瑙嗛璺緞 + std::string getVideoPathByPicDate(const std::string &picDate, const std::string &camId, qint64 &sub); + + //鏍规嵁ImgKey鑾峰彇瑙嗛鐨勮矾寰� + std::string getVideoPathByImgKey(const std::string &imgKey, const std::string &camId); + + //鑾峰彇dir_name涓嬬殑鎵�鏈夋枃浠�,甯︽墿灞曞悕 + std::vector<std::string> forEachFileByImgKey(const std::string &dir_name); + + //鏍规嵁ImgKey鑾峰彇瑙嗛鍚� + std::string GetVideoNameByImgKey(const std::string& imgKey,const std::string& strPath); + }; #endif -- Gitblit v1.8.0