From dad25d2735da7a04ccf111d1ae14da4d4bc4955b Mon Sep 17 00:00:00 2001
From: zhangmeng <775834166@qq.com>
Date: 星期六, 08 六月 2019 10:35:59 +0800
Subject: [PATCH] 轮询
---
QiaoJiaSystem/DataManagerServer/http_configserver.h | 147 ++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 145 insertions(+), 2 deletions(-)
diff --git a/QiaoJiaSystem/DataManagerServer/http_configserver.h b/QiaoJiaSystem/DataManagerServer/http_configserver.h
index a8b8aa6..98399e4 100644
--- a/QiaoJiaSystem/DataManagerServer/http_configserver.h
+++ b/QiaoJiaSystem/DataManagerServer/http_configserver.h
@@ -20,6 +20,8 @@
#include "../FaceSearchServer/CasiaFaceWrapper/CasiaFaceWrapperN.h"
#include "AppPipeController.h"
+#include <NsqMsgTool.hpp>
+
typedef std::shared_ptr<HttpServer::Response> PResponse;
@@ -76,38 +78,154 @@
std::string netconfig_show(std::string ip, unsigned int port, std::string content, PResponse &response);
+ /***
+ * 鍒涘缓闆嗙兢鑺傜偣
+ * @param ip
+ * @param port
+ * @param content
+ * @param response
+ * @return
+ */
std::string addNode(std::string ip, unsigned int port, std::string content, PResponse &response);
+ /***
+ * 鏌ヨ鍦ㄧ嚎鑺傜偣
+ * @param ip
+ * @param port
+ * @param content
+ * @param response
+ * @return
+ */
std::string searchNode(std::string ip, unsigned int port, std::string content, PResponse &response);
std::string modifyCluName(std::string ip, unsigned int port, std::string content, PResponse &response);
+ /***
+ * 閫�鍑洪泦缇�
+ * @param ip
+ * @param port
+ * @param content
+ * @param response
+ * @return
+ */
std::string removeNode(std::string ip, unsigned int port, std::string content, PResponse &response);
+ /**
+ *鍒涘缓鏁版嵁搴曞簱
+ * @param ip
+ * @param port
+ * @param content
+ * @param response
+ * @return
+ */
std::string createDatabase(std::string ip, unsigned int port, std::string content, PResponse &response);
+ /**
+ * 鍒犻櫎鏁版嵁 搴曞簱
+ * @param ip
+ * @param port
+ * @param content
+ * @param response
+ * @return
+ */
std::string deleteDatabase(std::string ip, unsigned int port, std::string content, PResponse &response);
+ /***
+ * 鏇存柊鏁版嵁 搴曞簱
+ * @param ip
+ * @param port
+ * @param content
+ * @param response
+ * @return
+ */
std::string updateDatabase(std::string ip, unsigned int port, std::string content, PResponse &response);
+ /**
+ * 鏌ヨ鎵�鏈夊悓姝ュ簱
+ * @param ip
+ * @param port
+ * @param content
+ * @param response
+ * @return
+ */
std::string findAllDatabase(std::string ip, unsigned int port, std::string content, PResponse &response);
+ /**
+ * 鏌ヨ鎵�鏈夋湰鍦板簱
+ * @param ip
+ * @param port
+ * @param content
+ * @param response
+ * @return
+ */
std::string findLocalDatabase(std::string ip, unsigned int port, std::string content, PResponse &response);
+ /***
+ * 涓婁紶浜哄憳
+ * @param ip
+ * @param port
+ * @param content
+ * @param response
+ * @return
+ */
std::string addPerson(std::string ip, unsigned int port, std::string content, PResponse &response);
+ //#todo 鎵归噺娣诲姞浜哄憳鍊熷彛
+
+ /***
+ * 鍚戝悓姝ュ簱鎵归噺娣诲姞浜哄憳鍙婃洿鏂颁汉鍛�
+ * feature_addPersonTracking 鍒嗘敮涓洿鏂板姛鑳藉垎绂讳负鏂板�熷彛
+ * @param ip
+ * @param port
+ * @param content
+ * @param response
+ * @return
+ */
std::string addPersons(std::string ip, unsigned int port, std::string content, PResponse &response);
+ /***
+ * 鍒ゆ柇鍚屾搴撲腑浜哄憳鏄惁瀛樺湪
+ * @param ip
+ * @param port
+ * @param content
+ * @param response
+ * @return
+ */
std::string personIsExists(std::string ip, unsigned int port, std::string content, PResponse &response);
+ /**
+ * 鏇存柊鍚屾搴撲腑鐨勪汉鍛�
+ * @param ip
+ * @param port
+ * @param content
+ * @param response
+ * @return
+ */
std::string updatePersonByOldId(std::string ip, unsigned int port, std::string content, PResponse &response);
-
+ /**
+ * 鍒犻櫎浜哄憳
+ * @param ip
+ * @param port
+ * @param content
+ * @param response
+ * @return
+ */
std::string delPerson(std::string ip, unsigned int port, std::string content, PResponse &response);
+ /**
+ * 鍔犺浇鐗瑰緛
+ * @param ip
+ * @param port
+ * @param content
+ * @param response
+ * @return
+ */
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 +267,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;
@@ -177,11 +299,32 @@
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