#include <Ice/Ice.h>
#include <basic/rpc/IceRpc.hpp>
#include <thread>
//#include "StructureAppI.h"
//#include "../AppManager/rpc/AppManager.h"
#include "AppPipeController.h"
#include <basic/util/app/AppPreference.hpp>
#include <basic/db/ES/es/ManagerEsDB.h>

int main(int argc, char **argv) {
    SAVE_APP_ARGS;

//    ManagerEsDB pManagerEsDB;
//    bool ret = pManagerEsDB.addDB("facedb233");

//    pManagerEsDB.faceResInsert("facedb","6666666","{\"test222\":\"sdfasdf\"}");

    appPref.setLongData("gpu.index", 0);
    appPref.setIntData("show.image", 1);

    //yolo server
    appPref.setStringData("yolo.proxy", "yoloServer");
    //#todo
    appPref.setStringData("yolo.ip", "");
    appPref.setIntData("yolo.port", 10003);
//    rpcClient(appPref.getStringData("yolo.proxy"), appPref.getStringData("yolo.ip"), appPref.getLongData("yolo.port"),"tcp"),


    //face detect server
    appPref.setStringData("faceDete.proxy", "faceServer");
    //#todo
    appPref.setStringData("faceDete.ip", "");
    appPref.setIntData("faceDete.port", 10002);
//rpcClient(appPref.getStringData("faceDete.proxy"), appPref.getStringData("faceDete.ip"), appPref.getLongData("faceDete.port"),"tcp"),
//    rpcClient("faceServer","",10002,"tcp"),


    //fece extern server
    appPref.setStringData("faceExte.proxy", "faceExtractServer");
    //#todo
    appPref.setStringData("faceExte.ip", "");
    appPref.setIntData("faceExte.port", 10008);
//rpcClient(appPref.getStringData("faceExte.proxy"), appPref.getStringData("faceExte.ip"), appPref.getLongData("faceExte.port"),"tcp"),
//        "faceExtractServer", "", 10008, "tcp"),//人脸特征提取 修改成点对点通讯


    //face search server
    appPref.setStringData("faceSear.proxy", "faceCmServer");
    //#todo
    appPref.setStringData("faceSear.ip", "");
    appPref.setIntData("faceSear.port", 10004);
//rpcClient(appPref.getStringData("faceSear.proxy"), appPref.getStringData("faceSear.ip"), appPref.getLongData("faceSear.port"),"tcp"),
//    faceSearchRpcClient("faceCmServer", "", 10004, "tcp")

    appPref.setStringData("ipAdd", "192.168.1.159");
    appPref.setIntData("ipPort", 9200);

    Json::Value json;
    json["rtsp"] = "/home/bsk/development/c++/Qt/QiaoJiaSystem/build/load/123456/33/201808/27/123456-33-201808-20180827093100/2018-08-27 09:31:00.mp4";
    json["face.enable"] = "1";
    json["yolo.enable"] = "1";

//    AppPipeController appPipeController(0, json);
//    appPipeController.resetVideoCapturePath(
//        "/home/bsk/development/c++/Qt/QiaoJiaSystem/build/load/123456/33/201808/27/123456-33-201808-20180827093100/2018-08-27 09:31:00.mp4");
//    appPipeController.start();
//    getchar();
//    appPipeController.stop();
//    appPipeController.wait();
    return 0;
}

#include "HttpRequestWithCrul.hpp"

int main2() {


    HttpRequestWithCrul httpRequestWithCrul;


    // test post requery
    string postUrlStr = "http://192.168.1.159:9200/facedb/external/fffffff";
    string postParams = "{\"assss\":\"cccc\"}";
    string postResponseStr;
    auto res = httpRequestWithCrul.curl_post_req(postUrlStr, postParams, postResponseStr);
    auto res2 = httpRequestWithCrul.curl_post_req(postUrlStr, postParams, postResponseStr);
    if (res != CURLE_OK)
        cerr << "curl_easy_perform() failed: " + string(curl_easy_strerror(res)) << endl;
    else
        cout << postResponseStr << endl;
//    system("pause");
    return 0;
}