#include <stdio.h>
#include <iostream>
#include <unistd.h>
#include "HCNetSDK.h"
#include <cstring>
#include "HcRecord.h"
#include "TestThreads.h"
#include "AppController.h"
#include "DBManageClass.h"
#include "RtspAnalysElement.h"
#include <basic/debug/Debug.h>
#include "StructureApp/NewEncodeVideoManager.h"
//#include "PerimeterAlarmManager.h"
//#include "KeepRightManager.h"
//"192.168.1.4", 8000, "admin", "basic123"

using namespace std;

#include <basic/util/file/FileUtil.h>
#include <basic/util/app/AppPreference.hpp>
#include <basic/util/app/AppConfig.h>


static void startDBManageClass(LDBTool *_dbTool) {
    DBManageClass _DBManageClass(_dbTool);
    //from DEV_table get DEV config  DS-7808N-SN0820161208AARR691369356WCVU
    auto lst = _dbTool->searchDeviceTableAll();
    if (lst.size() > 0) {
        for (auto item : lst) {
            _DBManageClass.addDevice(item.str_storage_dev_id.toStdString(), item.str_ip.toStdString().c_str(),
                                     item.n_port, item.str_username.toStdString().c_str(),
                                     item.str_password.toStdString().c_str());
        }
        _DBManageClass.start(4, 8, 16);
    } else {
        ERR("searchDeviceTableAll size is 0");
    }
    while (1) {
        sleep(1 * 60 * 60 * 12);
    }
}

static void startRtspAnalysElement(LDBTool *_dbTool) {
    RtspAnalysElement rtspAnalysElement(_dbTool);
    NewEncodeVideoManager  newEncodeVideoManager;
    newEncodeVideoManager.start();
    while (1) {
        sleep(1 * 60 * 60 * 12);
    }
}

//static void startPerimeterAlarmManager(LDBTool *_dbTool) {
//    PerimeterAlarmManager perimeterAlarmManager(_dbTool);
//    while (1) {
//        sleep(1 * 60 * 60 * 12);
//    }
//}
//static void startKeepRightManager(LDBTool *_dbTool) {
//    KeepRightManager keepRightManager(_dbTool);
//    while (1) {
//        sleep(1 * 60 * 60 * 12);
//    }
//}

#include <basic/util/app/AppConfig.h>

int main(int argc, char **argv) {
    SAVE_APP_ARGS
    ENABLEGLOG(GET_STR_CONFIG("logPath").c_str());

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

    //#todo get from config File
//    appPref.setStringData("ipAdd", "192.168.1.185");
//    appPref.setIntData("ipPort", 9200);

    appPref.setStringData("ipAdd", appConfig.getStringProperty("ES_IP"));
    appPref.setIntData("ipPort", appConfig.getIntProperty("ES_PORT"));

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

    //loopRecord server
    appPref.setStringData("loopRecord.proxy", "LoopRecordVideoServer");
    //#todo
    appPref.setStringData("loopRecord.ip", "");
    appPref.setIntData("loopRecord.port", 10010);
//rpcClient(appPref.getStringData("loopRecord.proxy"), appPref.getStringData("loopRecord.ip"), appPref.getLongData("loopRecord.port"),"tcp"),

    LDBTool _dbTool;
    //"192.168.1.4", 8000, "admin", "basic123"

    auto rec = _dbTool.searchConfigTableWithinServerInfo();

    appPref.setStringData("fxDevID", rec.dev_id.toStdString());
    appPref.setStringData("fxDevNAME", rec.dev_name.toStdString());
    appPref.setStringData("user.loop.absolute.path", appConfig.getStringProperty("cutPath"));


    bool loopRet = true;
    while (loopRet) {
       switch (_dbTool.searchDevTypeFromConfigTable()) {

            case 0: {
                DBG("case 0");
                sleep(5);
                break;
            }
            case 1: {
                DBG("case 1");
                //#todo add if
                thread startDBManage(startDBManageClass, &_dbTool);
                startDBManage.detach();
                loopRet = false;
                break;
            }
            case 2: {
                DBG("case 2");
                //#todo add 实时流地址
                thread startRtspAnalys(startRtspAnalysElement, &_dbTool);
                startRtspAnalys.detach();
                loopRet = false;
                break;
            }
//            case 3: {
//                   DBG("case 3");
//                   //#todo add 周界报警
//                   thread startPAManager(startPerimeterAlarmManager, &_dbTool);
//                   startPAManager.detach();
//                   loopRet = false;
//                   break;
//                   }
//            case 4: {
//                   DBG("case 4");
//                   //#todo add KeepRight
//                   thread startKPManager(startKeepRightManager, &_dbTool);
//                   startKPManager.detach();
//                   loopRet = false;
//                   break;
//                   }
            default:
                ERR("searchDevTypeFromConfigTable type is error");
        }
    }


    INFO("get char");
//    getchar();
//    INFO("get char after");
    while (1) {
        sleep(1 * 60 * 60 * 12);
    }
    return 0;

}