chenshijun
2019-04-22 291dbcd9331cd0df41addef74defa4654ee034fb
QiaoJiaSystem/DataManagerServer/http_configserver.h
@@ -19,7 +19,8 @@
#include <atomic>
#include "../FaceSearchServer/CasiaFaceWrapper/CasiaFaceWrapperN.h"
#include "AppPipeController.h"
#include "NsqMsgTool.hpp"
#include <NsqMsgTool.hpp>
typedef std::shared_ptr<HttpServer::Response> PResponse;
@@ -77,42 +78,153 @@
    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);
@@ -186,7 +298,7 @@
                              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);
@@ -194,12 +306,12 @@
    //根据PicDate获取报警图
    std::string getAlarmImageByPicDateAndDevId(const std::string& picDate,const std::string& devId,
                                                        PResponse &response);
    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);
    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);
@@ -211,7 +323,7 @@
    std::vector<std::string> forEachFileByImgKey(const std::string &dir_name);
    //根据ImgKey获取视频名
    std::string GetVideoNameByImgKey(const std::string& imgKey,const std::string& strPath);
    std::string GetVideoNameByImgKey(const std::string &imgKey, const std::string &strPath);
};