#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
|
|
#ifdef GLOG
|
ENABLEGLOG(GET_STR_CONFIG("logPath").c_str());
|
#endif
|
|
appPref.setLongData("gpu.index", 1);
|
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"));
|
appPref.setStringData("clusterID", appConfig.getStringProperty("clusterID"));
|
|
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;
|
|
}
|
