#ifndef HTTP_CONFIGSERVER_H
|
#define HTTP_CONFIGSERVER_H
|
|
#include <boost/property_tree/json_parser.hpp>
|
#include <boost/property_tree/ptree.hpp>
|
|
#include "opencv2/opencv.hpp"
|
#include <string>
|
#include "HttpSrvRetRecieve.hpp"
|
#include "LDBTool.h"
|
#include <ErlangDbTool.h>
|
#include <basic/util/BASE64/Base64.h>
|
#include <basic/util/opencv/CvUtil.h>
|
#include <sys/sem.h>
|
|
#include <LocalDBTool/SqliteFaceEncap.h>
|
#include <CurlDownloadImg.hpp>
|
#include <basic/util/fastdfs/FastFds.hpp>
|
#include <atomic>
|
#include "../FaceSearchServer/CasiaFaceWrapper/CasiaFaceWrapperN.h"
|
#include "AppPipeController.h"
|
|
#include <NsqMsgTool.hpp>
|
|
typedef std::shared_ptr<HttpServer::Response> PResponse;
|
|
|
struct srsPipeController_s {
|
AppPipeController *appPC;
|
std::atomic<int> userCounter;
|
};
|
|
class devHttpServer_c {
|
public:
|
devHttpServer_c();
|
|
devHttpServer_c(std::string test);
|
|
devHttpServer_c(std::string ip, int port, int pthNum);
|
|
~devHttpServer_c();
|
|
//private:
|
std::string dev_edit(std::string ip, unsigned int port, std::string content, PResponse &response);
|
|
std::string dev_show(std::string ip, unsigned int port, std::string content, PResponse &response);
|
|
std::string devchn_show(std::string ip, unsigned int port, std::string content, PResponse &response);
|
|
std::string devchn_edit(std::string ip, unsigned int port, std::string content, PResponse &response);
|
|
std::string dev_search_chns(std::string ip, unsigned int port, std::string content, PResponse &response);
|
|
std::string chk_chn_connet(std::string ip, unsigned int port, std::string content, PResponse &response);
|
|
std::string cam_edit(std::string ip, unsigned int port, std::string content, PResponse &response);
|
|
std::string cam_show(std::string ip, unsigned int port, std::string content, PResponse &response);
|
|
std::string chk_cam_connet(std::string ip, unsigned int port, std::string content, PResponse &response);
|
|
std::string chk_cam_disconnet(std::string ip, unsigned int port, std::string content, PResponse &response);
|
|
std::string dev_del(std::string ip, unsigned int port, std::string content, PResponse &response);
|
|
std::string cam_del(std::string ip, unsigned int port, std::string content, PResponse &response);
|
|
std::string server_info_edit(std::string ip, unsigned int port, std::string content, PResponse &response);
|
|
std::string server_info_show(std::string ip, unsigned int port, std::string content, PResponse &response);
|
|
std::string cut_dura_edit(std::string ip, unsigned int port, std::string content, PResponse &response);
|
|
std::string cut_dura_show(std::string ip, unsigned int port, std::string content, PResponse &response);
|
|
std::string netconfig_edit(std::string ip, unsigned int port, std::string content, PResponse &response);
|
|
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);
|
|
std::string findDevId(std::string ip, unsigned int port, std::string content, PResponse &response);
|
|
std::string editDevName(std::string ip, unsigned int port, std::string content, PResponse &response);
|
|
std::string editDevId(std::string ip, unsigned int port, std::string content, PResponse &response);
|
|
std::string findSdkRule(std::string ip, unsigned int port, std::string content, PResponse &response);
|
|
std::string editSdkRule(std::string ip, unsigned int port, std::string content, PResponse &response);
|
|
std::string getSnapshot(std::string ip, unsigned int port, std::string content, PResponse &response);
|
|
private:
|
void init(void);
|
|
private:
|
|
HttpSrvRetRecieve _HttpSrvRetRecieve;
|
LDBTool db_c;
|
std::string m_cluster_id;
|
std::string m_cluster_name;
|
std::map<std::string, srsPipeController_s> m_rtmp;
|
|
|
ErlangTool::ErlangDbTool *erlangDbTool;
|
SqliteFaceEncap m_SqliteFaceEncap;
|
|
// ErlangDbTool *erlangDbTool;
|
std::map<std::thread::id, CasiaFaceWrapperN *> m_handleMap;
|
CvUtil cvutil;
|
Base64 base64;
|
std::string m_batch;
|
std::string m_SerialNumber;
|
|
CurlDownloadImg m_curlDownloadImg;
|
|
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;
|
|
bool getDevChnList(const char *ip, const int port, const char *username, const char *passwd, \
|
const char *brand, std::vector<int> &lvecUsefulChans) const;
|
|
bool loadCurrentVideo(const char *ip, const int port, const char *username, const char *passwd, \
|
const char *brand, const int chn, std::string &videopath) const;
|
|
bool cam_connect_video_start(std::string ip, int port, std::string username, std::string passwd, \
|
std::string brand) const;
|
|
bool cam_connect_video_stop(std::string ip) const;
|
|
void runAllApp() const;
|
|
void killFaceSearchServerApp() const;
|
|
void killVideoAnalysFromHCApp() const;
|
|
bool getUVDevSerialNumber(const char *ip, const char *username, const char *passwd,
|
unsigned char *serialNumber = NULL) const;
|
|
bool getHKDevSerialNumber(const char *ip, const int port, const char *username, const char *passwd,
|
unsigned char *serialNumber = NULL) const;
|
|
bool createDevId(const int &dev_batch, const int &dev_sequence);
|
|
|
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
|
