#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"

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);


    std::string addNode(std::string ip, unsigned int port, std::string content, PResponse &response);

    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);

    std::string removeNode(std::string ip, unsigned int port, std::string content, PResponse &response);

    std::string createDatabase(std::string ip, unsigned int port, std::string content, PResponse &response);

    std::string deleteDatabase(std::string ip, unsigned int port, std::string content, PResponse &response);

    std::string updateDatabase(std::string ip, unsigned int port, std::string content, PResponse &response);

    std::string findAllDatabase(std::string ip, unsigned int port, std::string content, PResponse &response);

    std::string findLocalDatabase(std::string ip, unsigned int port, std::string content, PResponse &response);

    std::string addPerson(std::string ip, unsigned int port, std::string content, PResponse &response);

    std::string addPersons(std::string ip, unsigned int port, std::string content, PResponse &response);

    std::string personIsExists(std::string ip, unsigned int port, std::string content, PResponse &response);

    std::string updatePersonByOldId(std::string ip, unsigned int port, std::string content, PResponse &response);


    std::string delPerson(std::string ip, unsigned int port, std::string content, PResponse &response);

    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;

    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