#include <iostream>
|
#include <VideoServer/QiaoJia/DB/DBStruct.h>
|
#include <jsoncpp/json/json.h>
|
#include "http_configserver.h"
|
#include <QString>
|
#include <basic/util/app/AppConfig.h>
|
#include "net_config/net_config.h"
|
#include "HCNetSDK.h"
|
#include "univiewDriver.h"
|
#include <basic/util/app/AppPreference.hpp>
|
#include "HttpRequestWithCrul.hpp"
|
|
#include <stdio.h>
|
#include <stdlib.h>
|
#include <sys/types.h>
|
#include <sys/stat.h>
|
|
#include <GetUUId.h>
|
|
#include <uuid/uuid.h>
|
//#include "HcRecord.h"
|
#include <time.h>
|
#include <dirent.h>
|
using namespace std;
|
|
devHttpServer_c::devHttpServer_c()
|
: _HttpSrvRetRecieve("0.0.0.0", 8083, 1), erlangDbTool(nullptr), m_SqliteFaceEncap("LocalDataDB") {
|
init();
|
}
|
|
devHttpServer_c::devHttpServer_c(std::string test)
|
: _HttpSrvRetRecieve("0.0.0.0", 8083, 1), erlangDbTool(nullptr), m_SqliteFaceEncap("LocalDataDB") {
|
|
fdfsClient.rwLock.wrlock();
|
fdfsClient.fastFds = new FastFds("WebFDSClient.conf");
|
fdfsClient.rwLock.unlock();
|
}
|
|
|
devHttpServer_c::devHttpServer_c(std::string ip, int port, int pthNum)
|
: _HttpSrvRetRecieve(ip, port, pthNum), erlangDbTool(nullptr), m_SqliteFaceEncap("LocalDataDB") {
|
|
auto erlNode = appConfig.getStringProperty("erlNode");
|
auto erlCookie = appConfig.getStringProperty("erlCookie");
|
auto erlPath = appConfig.getStringProperty("erlPath");
|
auto erlFatherNode = appConfig.getStringProperty("erlFatherNode");
|
if (erlNode.size() > 0 && erlCookie.size() > 0) {
|
string str_tmp = "DataWebserver";
|
erlangDbTool = new ErlangTool::ErlangDbTool(erlPath, erlNode, erlCookie, str_tmp);
|
if (erlangDbTool->initErlang() == 1) {
|
erlangDbTool->startNodeDb(erlFatherNode);
|
} else {
|
DBG("not is startNodeDb");
|
}
|
}
|
init();
|
}
|
|
devHttpServer_c::~devHttpServer_c() {
|
|
}
|
|
|
void devHttpServer_c::init(void) {
|
|
std::string strDevId = appConfig.getStringProperty("DEV_ID");
|
// DSVAD010120181119
|
m_batch = strDevId.substr(5, 2);
|
m_SerialNumber = strDevId.substr(7, 2);
|
|
|
fdfsClient.rwLock.wrlock();
|
fdfsClient.fastFds = new FastFds("WebFDSClient.conf");
|
fdfsClient.rwLock.unlock();
|
|
_HttpSrvRetRecieve.setInfo("^/dev_show$", "POST", std::bind(&devHttpServer_c::dev_show, this,
|
std::placeholders::_1, std::placeholders::_2,
|
std::placeholders::_3, std::placeholders::_4));
|
|
_HttpSrvRetRecieve.setInfo("^/dev_edit$", "POST", std::bind(&devHttpServer_c::dev_edit, this,
|
std::placeholders::_1, std::placeholders::_2,
|
std::placeholders::_3, std::placeholders::_4));
|
|
_HttpSrvRetRecieve.setInfo("^/devchn_show$", "POST", std::bind(&devHttpServer_c::devchn_show, this,
|
std::placeholders::_1, std::placeholders::_2,
|
std::placeholders::_3, std::placeholders::_4));
|
|
_HttpSrvRetRecieve.setInfo("^/devchn_edit$", "POST", std::bind(&devHttpServer_c::devchn_edit, this,
|
std::placeholders::_1, std::placeholders::_2,
|
std::placeholders::_3, std::placeholders::_4));
|
|
_HttpSrvRetRecieve.setInfo("^/dev_search_chns$", "POST", std::bind(&devHttpServer_c::dev_search_chns, this,
|
std::placeholders::_1, std::placeholders::_2,
|
std::placeholders::_3, std::placeholders::_4));
|
|
_HttpSrvRetRecieve.setInfo("^/chk_chn_connet$", "POST", std::bind(&devHttpServer_c::chk_chn_connet, this,
|
std::placeholders::_1, std::placeholders::_2,
|
std::placeholders::_3, std::placeholders::_4));
|
|
_HttpSrvRetRecieve.setInfo("^/cam_edit$", "POST", std::bind(&devHttpServer_c::cam_edit, this,
|
std::placeholders::_1, std::placeholders::_2,
|
std::placeholders::_3, std::placeholders::_4));
|
|
_HttpSrvRetRecieve.setInfo("^/cam_show$", "POST", std::bind(&devHttpServer_c::cam_show, this,
|
std::placeholders::_1, std::placeholders::_2,
|
std::placeholders::_3, std::placeholders::_4));
|
|
_HttpSrvRetRecieve.setInfo("^/chk_cam_connet$", "POST", std::bind(&devHttpServer_c::chk_cam_connet, this,
|
std::placeholders::_1, std::placeholders::_2,
|
std::placeholders::_3, std::placeholders::_4));
|
|
_HttpSrvRetRecieve.setInfo("^/chk_cam_disconnet$", "POST", std::bind(&devHttpServer_c::chk_cam_disconnet, this,
|
std::placeholders::_1, std::placeholders::_2,
|
std::placeholders::_3, std::placeholders::_4));
|
|
_HttpSrvRetRecieve.setInfo("^/dev_del$", "POST", std::bind(&devHttpServer_c::dev_del, this,
|
std::placeholders::_1, std::placeholders::_2,
|
std::placeholders::_3, std::placeholders::_4));
|
|
_HttpSrvRetRecieve.setInfo("^/cam_del$", "POST", std::bind(&devHttpServer_c::cam_del, this,
|
std::placeholders::_1, std::placeholders::_2,
|
std::placeholders::_3, std::placeholders::_4));
|
|
_HttpSrvRetRecieve.setInfo("^/server_info_edit$", "POST", std::bind(&devHttpServer_c::server_info_edit, this,
|
std::placeholders::_1, std::placeholders::_2,
|
std::placeholders::_3, std::placeholders::_4));
|
|
_HttpSrvRetRecieve.setInfo("^/server_info_show$", "POST", std::bind(&devHttpServer_c::server_info_show, this,
|
std::placeholders::_1, std::placeholders::_2,
|
std::placeholders::_3, std::placeholders::_4));
|
|
_HttpSrvRetRecieve.setInfo("^/cut_dura_edit$", "POST", std::bind(&devHttpServer_c::cut_dura_edit, this,
|
std::placeholders::_1, std::placeholders::_2,
|
std::placeholders::_3, std::placeholders::_4));
|
|
_HttpSrvRetRecieve.setInfo("^/cut_dura_show$", "POST", std::bind(&devHttpServer_c::cut_dura_show, this,
|
std::placeholders::_1, std::placeholders::_2,
|
std::placeholders::_3, std::placeholders::_4));
|
|
//#data modifyCluName
|
_HttpSrvRetRecieve.setInfo("^/addNode$", "POST", std::bind(&devHttpServer_c::addNode, this,
|
std::placeholders::_1, std::placeholders::_2,
|
std::placeholders::_3, std::placeholders::_4));
|
|
_HttpSrvRetRecieve.setInfo("^/searchNode$", "POST", std::bind(&devHttpServer_c::searchNode, this,
|
std::placeholders::_1, std::placeholders::_2,
|
std::placeholders::_3, std::placeholders::_4));
|
_HttpSrvRetRecieve.setInfo("^/modifyCluName$", "POST", std::bind(&devHttpServer_c::modifyCluName, this,
|
std::placeholders::_1, std::placeholders::_2,
|
std::placeholders::_3, std::placeholders::_4));
|
_HttpSrvRetRecieve.setInfo("^/removeNode$", "POST", std::bind(&devHttpServer_c::removeNode, this,
|
std::placeholders::_1, std::placeholders::_2,
|
std::placeholders::_3, std::placeholders::_4));
|
|
_HttpSrvRetRecieve.setInfo("^/createDatabase$", "POST", std::bind(&devHttpServer_c::createDatabase, this,
|
std::placeholders::_1, std::placeholders::_2,
|
std::placeholders::_3, std::placeholders::_4));
|
|
_HttpSrvRetRecieve.setInfo("^/deleteDatabase$", "POST", std::bind(&devHttpServer_c::deleteDatabase, this,
|
std::placeholders::_1, std::placeholders::_2,
|
std::placeholders::_3, std::placeholders::_4));
|
_HttpSrvRetRecieve.setInfo("^/updateDatabase$", "POST", std::bind(&devHttpServer_c::updateDatabase, this,
|
std::placeholders::_1, std::placeholders::_2,
|
std::placeholders::_3, std::placeholders::_4));
|
|
_HttpSrvRetRecieve.setInfo("^/findAllDatabase$", "POST", std::bind(&devHttpServer_c::findAllDatabase, this,
|
std::placeholders::_1, std::placeholders::_2,
|
std::placeholders::_3, std::placeholders::_4));
|
|
_HttpSrvRetRecieve.setInfo("^/findLocalDatabase$", "POST", std::bind(&devHttpServer_c::findLocalDatabase, this,
|
std::placeholders::_1, std::placeholders::_2,
|
std::placeholders::_3, std::placeholders::_4));
|
|
_HttpSrvRetRecieve.setInfo("^/addPerson$", "POST", std::bind(&devHttpServer_c::addPerson, this,
|
std::placeholders::_1, std::placeholders::_2,
|
std::placeholders::_3, std::placeholders::_4));
|
|
_HttpSrvRetRecieve.setInfo("^/addPersons$", "POST", std::bind(&devHttpServer_c::addPersons, this,
|
std::placeholders::_1, std::placeholders::_2,
|
std::placeholders::_3, std::placeholders::_4));
|
|
_HttpSrvRetRecieve.setInfo("^/personIsExists$", "POST", std::bind(&devHttpServer_c::personIsExists, this,
|
std::placeholders::_1, std::placeholders::_2,
|
std::placeholders::_3, std::placeholders::_4));
|
|
_HttpSrvRetRecieve.setInfo("^/updatePersonByOldId$", "POST", std::bind(&devHttpServer_c::updatePersonByOldId, this,
|
std::placeholders::_1, std::placeholders::_2,
|
std::placeholders::_3,
|
std::placeholders::_4));
|
|
_HttpSrvRetRecieve.setInfo("^/delPerson$", "POST", std::bind(&devHttpServer_c::delPerson, this,
|
std::placeholders::_1, std::placeholders::_2,
|
std::placeholders::_3, std::placeholders::_4));
|
|
_HttpSrvRetRecieve.setInfo("^/loadFaceFeaData$", "POST", std::bind(&devHttpServer_c::loadFaceFeaData, this,
|
std::placeholders::_1, std::placeholders::_2,
|
std::placeholders::_3, std::placeholders::_4));
|
|
_HttpSrvRetRecieve.setInfo("^/netconfig_edit$", "POST", std::bind(&devHttpServer_c::netconfig_edit, this,
|
std::placeholders::_1, std::placeholders::_2,
|
std::placeholders::_3, std::placeholders::_4));
|
|
_HttpSrvRetRecieve.setInfo("^/netconfig_show$", "POST", std::bind(&devHttpServer_c::netconfig_show, this,
|
std::placeholders::_1, std::placeholders::_2,
|
std::placeholders::_3, std::placeholders::_4));
|
|
_HttpSrvRetRecieve.setInfo("^/getAlarmImageFromVideoFile$", "POST",
|
std::bind(&devHttpServer_c::getAlarmImageFromVideoFile, this,
|
std::placeholders::_1, std::placeholders::_2,
|
std::placeholders::_3, std::placeholders::_4));
|
_HttpSrvRetRecieve.setInfo("^/getRecordVideoPath$", "POST",
|
std::bind(&devHttpServer_c::getRecordVideoPath, this,
|
std::placeholders::_1, std::placeholders::_2,
|
std::placeholders::_3, std::placeholders::_4));
|
|
_HttpSrvRetRecieve.setInfo("^/findDevId$", "POST",
|
std::bind(&devHttpServer_c::findDevId, this,
|
std::placeholders::_1, std::placeholders::_2,
|
std::placeholders::_3, std::placeholders::_4));
|
_HttpSrvRetRecieve.setInfo("^/editDevName$", "POST",
|
std::bind(&devHttpServer_c::editDevName, this,
|
std::placeholders::_1, std::placeholders::_2,
|
std::placeholders::_3, std::placeholders::_4));
|
_HttpSrvRetRecieve.setInfo("^/editDevId$", "POST",
|
std::bind(&devHttpServer_c::editDevId, this,
|
std::placeholders::_1, std::placeholders::_2,
|
std::placeholders::_3, std::placeholders::_4));
|
_HttpSrvRetRecieve.start();
|
_HttpSrvRetRecieve.waitForShutDown();
|
}
|
|
|
//显示磁盘阵列
|
std::string devHttpServer_c::dev_show(std::string ip, unsigned int port, std::string content, PResponse &response) {
|
DBG("ip:" << ip << "; port:" << port);
|
DBG("content: " << content);
|
|
Json::Value value;
|
Json::Value elem;
|
bool ret = false;
|
|
std::list<Record_Storage_Dev> rec_list = db_c.searchDeviceTableAll();
|
|
list<Record_Storage_Dev>::iterator iter;
|
|
for (iter = rec_list.begin(); iter != rec_list.end(); ++iter) {
|
elem["str_storage_dev_id"] = iter->str_storage_dev_id.toStdString();
|
elem["str_dev_name"] = iter->str_dev_name.toStdString();
|
elem["str_addr"] = iter->str_addr.toStdString();
|
elem["str_longitude"] = iter->str_longitude.toStdString();
|
elem["str_latitude"] = iter->str_latitude.toStdString();
|
elem["str_ip"] = iter->str_ip.toStdString();
|
elem["n_port"] = iter->n_port;
|
elem["str_username"] = iter->str_username.toStdString();
|
elem["str_password"] = iter->str_password.toStdString();
|
elem["tim_start_time"] = iter->tim_start_time.toString("yyyy-MM-dd hh:mm:ss").toStdString();
|
elem["n_duration"] = iter->n_duration;
|
elem["str_brand"] = iter->str_brand.toStdString();
|
elem["str_reserved"] = iter->str_reserved.toStdString();
|
cout << elem.toStyledString() << endl;
|
value.append(elem);
|
}
|
cout << value.toStyledString() << endl;
|
// std::string out = value.toStyledString();
|
std::string out = value.size() > 0 ? value.toStyledString() : "[]";
|
|
return out;
|
}
|
|
//************************************
|
// Method: string_replace
|
// FullName: string_replace
|
// Access: public
|
// Returns: void
|
// Qualifier: 把字符串的strsrc替换成strdst
|
// Parameter: std::string & strBig
|
// Parameter: const std::string & strsrc
|
// Parameter: const std::string & strdst
|
//************************************
|
static void string_replace(std::string &strBig, const std::string &strsrc, const std::string &strdst) {
|
std::string::size_type pos = 0;
|
std::string::size_type srclen = strsrc.size();
|
std::string::size_type dstlen = strdst.size();
|
|
while ((pos = strBig.find(strsrc, pos)) != std::string::npos) {
|
strBig.replace(pos, srclen, strdst);
|
pos += dstlen;
|
}
|
}
|
|
static std::string rtspAddrBuild(std::string ip, const int port, std::string username,
|
std::string passwd, std::string brand) {
|
std::string rtsp_url;
|
if (brand == "haikang") {
|
rtsp_url = "rtsp://" + username + ":" + passwd + "@" + ip + ":" + std::to_string(port) +
|
"/h264/ch1/main/av_stream";
|
} else if (brand == "dahua") {
|
//rtsp://username:password@ip:port/cam/realmonitor?channel=1&subtype=0
|
rtsp_url = "rtsp://" + username + ":" + passwd + "@" + ip + ":" + std::to_string(port) +
|
"/cam/realmonitor?channel=1&subtype=0";
|
//TODO
|
} else if (brand == "yushi") {
|
rtsp_url = "rtsp://" + username + ":" + passwd + "@" + ip + ":" + std::to_string(port) +
|
"/video1";
|
} else {
|
//TODO
|
}
|
|
return rtsp_url;
|
}
|
|
bool devHttpServer_c::getDevSerialNumber(const char *ip, const int port, const char *username, const char *passwd, \
|
const char *brand, unsigned char *serialNumber) const {
|
std::string strBrand(brand);
|
if (strBrand == "haikang") {
|
getHKDevSerialNumber(ip, port, username, passwd, serialNumber);
|
} else if (strBrand == "dahua") {
|
//TODO
|
} else if (strBrand == "yushi") {
|
return getUVDevSerialNumber(ip, username, passwd, serialNumber);
|
} else {
|
//TODO
|
}
|
|
return true;
|
}
|
|
bool devHttpServer_c::getHKDevSerialNumber(const char *ip, const int port, const char *username, const char *passwd,
|
unsigned char *serialNumber) const {
|
NET_DVR_Init();
|
//设置连接时间与重连时间
|
NET_DVR_SetConnectTime(2000, 1);
|
NET_DVR_SetReconnect(10000, true);
|
|
NET_DVR_USER_LOGIN_INFO struLoginInfo = {0};
|
struLoginInfo.bUseAsynLogin = 0; //同步登录方式
|
strcpy(struLoginInfo.sDeviceAddress, ip); //设备IP地址
|
struLoginInfo.wPort = port; //设备服务端口
|
strcpy(struLoginInfo.sUserName, username); //设备登录用户名
|
strcpy(struLoginInfo.sPassword, passwd); //设备登录密码
|
|
//设备信息, 输出参数
|
NET_DVR_DEVICEINFO_V40 struDeviceInfoV40 = {0};
|
|
LONG m_lUserID = NET_DVR_Login_V40(&struLoginInfo, &struDeviceInfoV40);
|
if (m_lUserID < 0) {
|
// printf("Login failed, error code: %d\n", NET_DVR_GetLastError());
|
NET_DVR_Cleanup();
|
return false;
|
}
|
|
if (serialNumber != NULL) {
|
memcpy(serialNumber, struDeviceInfoV40.struDeviceV30.sSerialNumber, SERIALNO_LEN);//TODO获取磁盘阵列的设备id
|
string serialNO((char *) serialNumber);
|
|
string_replace(serialNO, " ", "_");
|
serialNO.copy(serialNumber, serialNO.length(), 0);
|
*(serialNumber + serialNO.length()) = '\0';
|
}
|
|
//注销用户
|
NET_DVR_Logout(m_lUserID);
|
//释放SDK资源
|
NET_DVR_Cleanup();
|
}
|
|
bool
|
devHttpServer_c::getUVDevSerialNumber(const char *ip, const char *username, const char *passwd,
|
unsigned char *serialNumber) const {
|
ULONG ulRet = 0;
|
CHAR szUserID[1024] = {0};
|
IMOS_MW_BASIC_DEVICE_INFO_S *pstBasicInfo = NULL;
|
|
ulRet = IMOS_MW_Initiate();
|
if (ERR_COMMON_SUCCEED != ulRet) {
|
printf("Initiate ret[%lu]", ulRet);
|
return false;
|
}
|
|
/*sdk login*/
|
ulRet = IMOS_MW_Login(username, passwd, ip, 0, szUserID);
|
if (ERR_COMMON_SUCCEED != ulRet) {
|
printf("Login error ulRet[%lu]", ulRet);
|
return false;
|
}
|
|
pstBasicInfo = (IMOS_MW_BASIC_DEVICE_INFO_S *) malloc(sizeof(IMOS_MW_BASIC_DEVICE_INFO_S));
|
ulRet = IMOS_MW_GetDeviceStatus(szUserID, 0, IMOS_MW_STATUS_BASIC_INFO, (void *) pstBasicInfo);
|
if (ERR_COMMON_SUCCEED != ulRet) {
|
printf("GetDeviceStatus Error[%lu]\n", ulRet);
|
return false;
|
}
|
|
if (serialNumber != NULL) {
|
printf("SerialNumber :%s\n", pstBasicInfo->szSerialNumber);
|
strcpy((char *) serialNumber, pstBasicInfo->szSerialNumber);//TODO获取磁盘阵列的设备id
|
string serialNO((char *) serialNumber);
|
|
string_replace(serialNO, " ", "_");
|
serialNO.copy(serialNumber, serialNO.length(), 0);
|
*(serialNumber + serialNO.length()) = '\0';
|
free(pstBasicInfo);
|
}
|
|
(VOID) IMOS_MW_Logout(szUserID);
|
(VOID) IMOS_MW_Cleanup();
|
|
return true;
|
}
|
|
bool devHttpServer_c::getDevChnList(const char *ip, const int port, const char *username, const char *passwd, \
|
const char *brand, std::vector<int> &lvecUsefulChans) const {
|
std::string strBrand(brand);
|
if (strBrand == "haikang") {
|
NET_DVR_Init();
|
//设置连接时间与重连时间
|
NET_DVR_SetConnectTime(2000, 1);
|
NET_DVR_SetReconnect(10000, true);
|
|
//登录参数，包括设备地址、登录用户、密码等
|
NET_DVR_USER_LOGIN_INFO struLoginInfo = {0};
|
struLoginInfo.bUseAsynLogin = 0; //同步登录方式
|
strcpy(struLoginInfo.sDeviceAddress, ip); //设备IP地址
|
struLoginInfo.wPort = port; //设备服务端口
|
strcpy(struLoginInfo.sUserName, username); //设备登录用户名
|
strcpy(struLoginInfo.sPassword, passwd); //设备登录密码
|
|
//设备信息, 输出参数
|
NET_DVR_DEVICEINFO_V40 struDeviceInfoV40 = {0};
|
|
LONG m_lUserID = NET_DVR_Login_V40(&struLoginInfo, &struDeviceInfoV40);
|
if (m_lUserID < 0) {
|
// printf("Login failed, error code: %d\n", NET_DVR_GetLastError());
|
NET_DVR_Cleanup();
|
return false;
|
}
|
|
|
NET_DVR_IPPARACFG_V40 ipOut;
|
long len;
|
int iGroupNO = 0 + 33;//33 offset
|
BOOL bret = NET_DVR_GetDVRConfig(m_lUserID, NET_DVR_GET_IPPARACFG_V40, iGroupNO, &ipOut,
|
sizeof(NET_DVR_IPPARACFG_V40),
|
(LPDWORD) &len);
|
DWORD dErr = NET_DVR_GetLastError();
|
NET_DVR_PICCFG_V40 picOut;
|
|
bret = NET_DVR_GetDVRConfig(m_lUserID, NET_DVR_GET_PICCFG_V40, iGroupNO, &picOut, sizeof(NET_DVR_PICCFG_V40),
|
(LPDWORD) &len);
|
dErr = NET_DVR_GetLastError();
|
lvecUsefulChans.clear();
|
for (int i = 0; i < ipOut.dwDChanNum; i++) {
|
if (ipOut.struStreamMode[i].uGetStream.struChanInfo.byEnable) {
|
|
BYTE byIPID, byIPIDHigh;
|
int iDevInfoIndex;
|
byIPID = ipOut.struStreamMode[i].uGetStream.struChanInfo.byIPID;
|
byIPIDHigh = ipOut.struStreamMode[i].uGetStream.struChanInfo.byIPIDHigh;
|
iDevInfoIndex = byIPIDHigh * 256 + byIPID - 1 - iGroupNO * 64;
|
// printf("IP channel no.%d is online, IP: %s\n", i + 1,
|
// ipOut.struIPDevInfo[iDevInfoIndex].struIP.sIpV4);
|
|
|
lvecUsefulChans.push_back(i + 33);
|
}
|
}
|
|
//注销用户
|
NET_DVR_Logout(m_lUserID);
|
//释放SDK资源
|
NET_DVR_Cleanup();
|
} else if (strBrand == "dahua") {
|
return false;//TODO
|
} else if (strBrand == "yushi") {
|
return false;//TODO
|
} else {
|
return false;//TODO
|
}
|
|
return true;
|
}
|
|
bool devHttpServer_c::loadCurrentVideo(const char *ip, const int port, const char *username, const char *passwd, \
|
const char *brand, const int chn, std::string &videopath) const {
|
std::string strBrand(brand);
|
if (strBrand == "haikang") {
|
NET_DVR_Init();
|
//设置连接时间与重连时间
|
NET_DVR_SetConnectTime(2000, 1);
|
NET_DVR_SetReconnect(10000, true);
|
|
//登录参数，包括设备地址、登录用户、密码等
|
NET_DVR_USER_LOGIN_INFO struLoginInfo = {0};
|
struLoginInfo.bUseAsynLogin = 0; //同步登录方式
|
strcpy(struLoginInfo.sDeviceAddress, ip); //设备IP地址
|
struLoginInfo.wPort = port; //设备服务端口
|
strcpy(struLoginInfo.sUserName, username); //设备登录用户名
|
strcpy(struLoginInfo.sPassword, passwd); //设备登录密码
|
|
//设备信息, 输出参数
|
NET_DVR_DEVICEINFO_V40 struDeviceInfoV40 = {0};
|
|
LONG m_lUserID = NET_DVR_Login_V40(&struLoginInfo, &struDeviceInfoV40);
|
if (m_lUserID < 0) {
|
// printf("Login failed, error code: %d\n", NET_DVR_GetLastError());
|
NET_DVR_Cleanup();
|
return false;
|
}
|
|
NET_DVR_PLAYCOND struDownloadCond = {0};
|
struDownloadCond.dwChannel = chn;
|
|
time_t rowtime;
|
time(&rowtime);
|
time_t start_time = rowtime - 7200;
|
time_t end_time = rowtime - 7200 + 10;
|
struct tm *pStartTime = localtime(&start_time);
|
|
struDownloadCond.struStartTime.dwYear = pStartTime->tm_year + 1900;
|
struDownloadCond.struStartTime.dwMonth = pStartTime->tm_mon + 1;
|
struDownloadCond.struStartTime.dwDay = pStartTime->tm_mday;
|
struDownloadCond.struStartTime.dwHour = pStartTime->tm_hour;
|
struDownloadCond.struStartTime.dwMinute = pStartTime->tm_min;
|
struDownloadCond.struStartTime.dwSecond = pStartTime->tm_sec;
|
|
struct tm *pEndTime = localtime(&end_time);
|
struDownloadCond.struStopTime.dwYear = pEndTime->tm_year + 1900;
|
struDownloadCond.struStopTime.dwMonth = pEndTime->tm_mon + 1;
|
struDownloadCond.struStopTime.dwDay = pEndTime->tm_mday;
|
struDownloadCond.struStopTime.dwHour = pEndTime->tm_hour;
|
struDownloadCond.struStopTime.dwMinute = pEndTime->tm_min;
|
struDownloadCond.struStopTime.dwSecond = pEndTime->tm_sec;
|
|
std::string ip_t(ip);
|
std::string filePath = "./" + ip_t + ":" + \
|
std::to_string(port) + "-" + \
|
std::to_string(chn) + "-" + \
|
std::to_string(struDownloadCond.struStopTime.dwYear) + "-" + \
|
std::to_string(struDownloadCond.struStopTime.dwMonth) + "-" + \
|
std::to_string(struDownloadCond.struStopTime.dwDay) + "_" + \
|
std::to_string(struDownloadCond.struStopTime.dwHour) + ":" + \
|
std::to_string(struDownloadCond.struStopTime.dwMinute) + ":" + \
|
std::to_string(struDownloadCond.struStopTime.dwSecond) + ".mp4";
|
|
std::string filePath_tmp = "./" + ip_t + ":" + \
|
std::to_string(port) + "-" + \
|
std::to_string(chn) + "-" + \
|
std::to_string(struDownloadCond.struStopTime.dwYear) + "-" + \
|
std::to_string(struDownloadCond.struStopTime.dwMonth) + "-" + \
|
std::to_string(struDownloadCond.struStopTime.dwDay) + "_" + \
|
std::to_string(struDownloadCond.struStopTime.dwHour) + ":" + \
|
std::to_string(struDownloadCond.struStopTime.dwMinute) + ":" + \
|
std::to_string(struDownloadCond.struStopTime.dwSecond) + "_tmp.mp4";
|
|
//---------------------------------------
|
//按时间下载
|
int hPlayback;
|
hPlayback = NET_DVR_GetFileByTime_V40(m_lUserID, (char *) filePath.c_str(), &struDownloadCond);
|
if (hPlayback < 0) {
|
printf("NET_DVR_GetFileByTime_V40 fail,last error %d\n", NET_DVR_GetLastError());
|
NET_DVR_Logout(m_lUserID);
|
NET_DVR_Cleanup();
|
return false;
|
}
|
|
//---------------------------------------
|
//开始下载
|
if (!NET_DVR_PlayBackControl_V40(hPlayback, NET_DVR_PLAYSTART, NULL, 0, NULL, NULL)) {
|
printf("Play back control failed [%d]\n", NET_DVR_GetLastError());
|
NET_DVR_Logout(m_lUserID);
|
NET_DVR_Cleanup();
|
return false;
|
}
|
|
int nPos = 0;
|
for (nPos = 0; nPos < 100 && nPos >= 0; nPos = NET_DVR_GetDownloadPos(hPlayback)) {
|
//printf("Be downloading... %d %%\n",nPos);
|
sleep(5); //millisecond
|
}
|
if (!NET_DVR_StopGetFile(hPlayback)) {
|
printf("failed to stop get file [%d]\n", NET_DVR_GetLastError());
|
NET_DVR_Logout(m_lUserID);
|
NET_DVR_Cleanup();
|
return false;
|
}
|
if (nPos < 0 || nPos > 100) {
|
printf("download err [%d]\n", NET_DVR_GetLastError());
|
NET_DVR_Logout(m_lUserID);
|
NET_DVR_Cleanup();
|
return false;
|
}
|
|
std::string cmd_transform = "ffmpeg -i " + filePath + " -strict -2 -vf scale=640:360 " + filePath_tmp;
|
system(cmd_transform.c_str());
|
std::string cmd_delsrc = "rm -f " + filePath;
|
system(cmd_delsrc.c_str());
|
videopath = filePath_tmp;
|
|
//注销用户
|
NET_DVR_Logout(m_lUserID);
|
//释放SDK资源
|
NET_DVR_Cleanup();
|
} else if (strBrand == "dahua") {
|
//TODO
|
} else if (strBrand == "yushi") {
|
//TODO
|
} else {
|
//TODO
|
}
|
|
return true;
|
}
|
|
#define DEV_NO_TYPE (0)
|
#define DEV_STORAGE (1)
|
#define DEV_CAMERA (2)
|
|
//编辑磁盘阵列
|
std::string devHttpServer_c::dev_edit(std::string ip, unsigned int port, std::string content, PResponse &response) {
|
DBG("ip:" << ip << "; port:" << port);
|
DBG("content: " << content);
|
|
Json::Reader reader;
|
Json::Value value;
|
bool ret = false;
|
|
int dev_type = db_c.searchDevTypeFromConfigTable();
|
if (DEV_CAMERA == dev_type) {
|
return "{\"ret_status\": \"内容有误，请检查！\"}";
|
} else {
|
DBG("dev_type :" << dev_type);
|
}
|
|
Record_Storage_Dev dev_rec;
|
if (reader.parse(content, value)) {
|
dev_rec.str_dev_name = QString::fromStdString(value["str_dev_name"].asString());
|
dev_rec.n_total_chn = 0;
|
dev_rec.str_all_chn_num = "";
|
dev_rec.str_addr = QString::fromStdString(value["str_addr"].asString());
|
dev_rec.str_longitude = QString::fromStdString(value["str_longitude"].asString());
|
dev_rec.str_latitude = QString::fromStdString(value["str_latitude"].asString());
|
dev_rec.str_ip = QString::fromStdString(value["str_ip"].asString());
|
dev_rec.n_port = value["n_port"].asInt();
|
dev_rec.str_username = QString::fromStdString(value["str_username"].asString());
|
dev_rec.str_password = QString::fromStdString(value["str_password"].asString());
|
dev_rec.tim_start_time = QDateTime::fromString(QString::fromStdString(value["tim_start_time"].asString()), \
|
"yyyy-MM-dd hh:mm:ss");
|
dev_rec.n_duration = value["n_duration"].asInt();
|
dev_rec.str_brand = QString::fromStdString(value["str_brand"].asString());
|
dev_rec.str_reserved = "";
|
|
unsigned char serialnumber[SERIALNO_LEN] = {0};
|
ret = getDevSerialNumber(value["str_ip"].asCString(), value["n_port"].asInt(),
|
value["str_username"].asCString(), \
|
value["str_password"].asCString(), value["str_brand"].asCString(), serialnumber);
|
if ((!ret) || (serialnumber[0] == 0)) {
|
return "{\"ret_status\": \"内容有误，请检查！\"}";
|
}
|
|
dev_rec.str_storage_dev_id = QString::fromLatin1((const char *) serialnumber);//获取磁盘阵列的设备id
|
std::cout << dev_rec.str_storage_dev_id.toStdString() << std::endl;
|
ret = db_c.updateDeviceTable(dev_rec);
|
} else {
|
return "{\"ret_status\": \"传输错误，请检查！\"}";
|
}
|
|
if (ret) {
|
if (DEV_NO_TYPE == dev_type) {
|
db_c.updateConfigTableByDevType(DEV_STORAGE);
|
runAllApp();
|
} else {
|
DBG("dev_type :" << dev_type);
|
}
|
|
Json::Value value_out;
|
value_out["str_storage_dev_id"] = dev_rec.str_storage_dev_id.toStdString();
|
std::string out = value_out.toStyledString();
|
|
return out;
|
} else {
|
return "{\"ret_status\": \"内容有误，请检查！\"}";
|
}
|
}
|
|
//搜索磁盘阵列通道
|
std::string
|
devHttpServer_c::dev_search_chns(std::string ip, unsigned int port, std::string content, PResponse &response) {
|
DBG("ip:" << ip << "; port:" << port);
|
DBG("content: " << content);
|
|
Json::Reader reader;
|
Json::Value value_reader;
|
|
if (!reader.parse(content, value_reader)) {
|
return "{\"ret_status\": \"传输错误，请检查！\"}";
|
}
|
|
Record_Storage_Dev rec = db_c.searchDeviceTableByDeviceId(
|
QString::fromStdString(value_reader["str_storage_dev_id"].asString()));
|
//调用海康大华磁盘阵列sdk，获取磁盘的通道列表
|
std::vector<int> lvecUsefulChans;
|
getDevChnList(rec.str_ip.toStdString().c_str(), rec.n_port, rec.str_username.toStdString().c_str(), \
|
rec.str_password.toStdString().c_str(), rec.str_brand.toStdString().c_str(), lvecUsefulChans);
|
|
std::string str_result;
|
std::string str_tmp;
|
for (int i = 0; i < lvecUsefulChans.size(); i++) {
|
std::cout << lvecUsefulChans.at(i) << std::endl;
|
str_tmp = std::to_string(lvecUsefulChans.at(i));
|
str_result += str_tmp;
|
str_result += ",";
|
}
|
str_result = str_result.substr(0, str_result.length() - 1);
|
Json::Value value;
|
|
value["devchn_list"] = str_result;
|
std::string out = value.toStyledString();
|
|
return out;
|
}
|
|
//测试磁盘阵列通道连接
|
std::string
|
devHttpServer_c::chk_chn_connet(std::string ip, unsigned int port, std::string content, PResponse &response) {
|
DBG("ip:" << ip << "; port:" << port);
|
DBG("content: " << content);
|
|
Json::Reader reader;
|
Json::Value value_reader;
|
|
if (!reader.parse(content, value_reader)) {
|
return "{\"ret_status\": \"传输错误，请检查！\"}";
|
}
|
|
Record_Storage_Dev rec = db_c.searchDeviceTableByDeviceId(\
|
QString::fromStdString(value_reader["str_storage_dev_id"].asString()));
|
|
//TODO
|
//调用海康大华磁盘阵列sdk，获取磁盘value_reader["str_storage_dev_id"].asString(),value_reader["n_chn"].asString()
|
std::string loadpath;
|
bool ret = loadCurrentVideo(rec.str_ip.toStdString().c_str(), \
|
rec.n_port, \
|
rec.str_username.toStdString().c_str(), \
|
rec.str_password.toStdString().c_str(), \
|
rec.str_brand.toStdString().c_str(), \
|
value_reader["n_chn"].asInt(), \
|
loadpath);
|
|
fdfsClient.rwLock.rdlock();
|
std::string vid_url = "http://";
|
if (fdfsClient.fastFds != nullptr) {
|
vid_url.append(fdfsClient.fastFds->getIp() + "/");
|
std::string t_strVid = "";
|
if (!fdfsClient.fastFds->uploadFile(loadpath, t_strVid)) {
|
vid_url = "upload video fail";
|
} else {
|
vid_url.append(t_strVid);
|
}
|
}
|
fdfsClient.rwLock.unlock();
|
std::string cmd_delsrc = "rm -f " + loadpath;
|
system(cmd_delsrc.c_str());
|
|
Json::Value value;
|
if (!ret) {
|
value["connect_status"] = "False";
|
value["video_url"] = "";
|
} else {
|
|
|
value["connect_status"] = "True";
|
value["video_url"] = vid_url;
|
}
|
|
std::string out = value.toStyledString();
|
|
return out;
|
}
|
|
static std::vector<int> string2vectorint(std::string str_list) {
|
std::vector<int> result_int;
|
char *property_list = const_cast<char *>(str_list.c_str());
|
const char *c_Analyse = ",";
|
char *t_property;
|
|
#ifdef linux
|
char *t_save = NULL;
|
t_property = strtok_r(property_list, c_Analyse, &t_save);
|
#else
|
t_property = strtok(property_list,c_Analyse);
|
#endif
|
|
while (t_property) {
|
std::string str_pro(t_property);
|
result_int.push_back(std::stoi(str_pro));
|
#ifdef linux
|
t_property = strtok_r(t_save, c_Analyse, &t_save);
|
#else
|
t_property = strtok(NULL,c_Analyse);
|
#endif
|
|
}
|
return result_int;
|
}
|
|
//显示磁盘阵列通道列表
|
std::string
|
devHttpServer_c::devchn_show(std::string ip, unsigned int port, std::string content, PResponse &response) {
|
DBG("ip:" << ip << "; port:" << port);
|
DBG("content: " << content);
|
|
Json::Reader reader;
|
Json::Value value_reader;
|
Json::Value value;
|
Json::Value elem;
|
Json::Value chn_unused;
|
bool ret = false;
|
|
if (reader.parse(content, value_reader)) {
|
QString dev_id = QString::fromStdString(value_reader["str_storage_dev_id"].asString());
|
|
std::list<Record_Cam_Chn> rec_list = db_c.searchChannelTableByDevlId(dev_id);
|
list<Record_Cam_Chn>::iterator iter;
|
|
Record_Storage_Dev rec = db_c.searchDeviceTableByDeviceId(
|
QString::fromStdString(value_reader["str_storage_dev_id"].asString()));
|
std::vector<int> chns;
|
getDevChnList(rec.str_ip.toStdString().c_str(), rec.n_port, rec.str_username.toStdString().c_str(), \
|
rec.str_password.toStdString().c_str(), rec.str_brand.toStdString().c_str(), chns);
|
|
for (iter = rec_list.begin(); iter != rec_list.end(); ++iter) {
|
// elem["str_storage_dev_id"] = iter->str_storage_dev_id.toStdString();
|
elem["str_name"] = iter->str_name.toStdString();
|
elem["n_chn"] = iter->n_chn;
|
elem["str_addr"] = iter->str_addr.toStdString();
|
elem["str_longitude"] = iter->str_longitude.toStdString();
|
elem["str_latitude"] = iter->str_latitude.toStdString();
|
elem["str_reserved"] = iter->str_reserved.toStdString();
|
|
Record_Chn_Sdk rec_sdk = db_c.searchChnSdkTableByChannelId(iter->str_storage_dev_id, iter->n_chn);
|
elem["str_sdks"] = rec_sdk.str_sdks.toStdString();
|
elem["str_det_thr"] = rec_sdk.str_det_thr.toStdString();
|
elem["str_cmp_thr"] = rec_sdk.str_cmp_thr.toStdString();
|
|
for (std::vector<int>::iterator it = chns.begin(); it != chns.end();) {
|
if (*it == iter->n_chn) {
|
it = chns.erase(it); //删除元素，返回值指向已删除元素的下一个位置
|
} else {
|
++it; //指向下一个位置
|
}
|
}
|
|
cout << elem.toStyledString() << endl;
|
value.append(elem);
|
}
|
|
for (std::vector<int>::iterator it1 = chns.begin(); it1 != chns.end(); it1++) {
|
chn_unused["n_chn"] = *it1;
|
cout << "*it1" << *it1 << endl;
|
value.append(chn_unused);
|
}
|
|
cout << value.toStyledString() << endl;
|
// std::string out = value.toStyledString();
|
std::string out = value.size() > 0 ? value.toStyledString() : "[]";
|
return out;
|
}
|
|
return "{\"ret_status\": \"传输错误，请检查！\"}";
|
}
|
|
//编辑磁盘阵列通道
|
std::string
|
devHttpServer_c::devchn_edit(std::string ip, unsigned int port, std::string content, PResponse &response) {
|
DBG("ip:" << ip << "; port:" << port);
|
DBG("content: " << content);
|
|
Json::Reader reader;
|
Json::Value value;
|
bool ret = false;
|
Record_Chn_Sdk rec_sdk_old;
|
Record_Chn_Sdk rec_sdk;
|
|
if (reader.parse(content, value)) {
|
Record_Cam_Chn rec;
|
rec.str_storage_dev_id = QString::fromStdString(value["str_storage_dev_id"].asString());
|
rec.n_chn = value["n_chn"].asInt();
|
rec.str_name = QString::fromStdString(value["str_name"].asString());
|
rec.str_addr = QString::fromStdString(value["str_addr"].asString());
|
rec.str_longitude = QString::fromStdString(value["str_longitude"].asString());
|
rec.str_latitude = QString::fromStdString(value["str_latitude"].asString());
|
|
Record_Storage_Dev dev_rec = db_c.searchDeviceTableByDeviceId(rec.str_storage_dev_id);
|
rec.tim_do_time = dev_rec.tim_start_time;
|
rec.tim_update_time = QDateTime::currentDateTime();
|
|
rec_sdk_old = db_c.searchChnSdkTableByChannelId(rec.str_storage_dev_id, rec.n_chn);
|
|
rec_sdk.str_storage_dev_id = QString::fromStdString(value["str_storage_dev_id"].asString());
|
rec_sdk.n_chn = value["n_chn"].asInt();
|
rec_sdk.str_sdks = QString::fromStdString(value["str_sdks"].asString());
|
rec_sdk.str_det_thr = QString::fromStdString(value["str_det_thr"].asString());
|
rec_sdk.str_cmp_thr = QString::fromStdString(value["str_cmp_thr"].asString());
|
|
ret = db_c.updateDevChnAndSdk(rec, rec_sdk);
|
if (!ret) {
|
return "{\"ret_status\": \"内容有误，请检查！\"}";
|
}
|
} else {
|
return "{\"ret_status\": \"传输错误，请检查！\"}";
|
}
|
|
//edit chn's sdks
|
if ((rec_sdk_old.str_sdks != rec_sdk.str_sdks) ||
|
(rec_sdk_old.str_det_thr != rec_sdk.str_det_thr) ||
|
(rec_sdk_old.str_cmp_thr != rec_sdk.str_cmp_thr)) {
|
killVideoAnalysFromHCApp();
|
sleep(1);
|
runAllApp();
|
}
|
|
return "{\"ret_status\": \"ok_ack\"}";
|
}
|
|
void devHttpServer_c::killFaceSearchServerApp() const {
|
string local_passwd = appConfig.getStringProperty("localPasswd");
|
string cmd_kill = "sleep 1 && echo \"" + local_passwd + "\" | sudo -S pkill -9 FaceSearch";
|
system(cmd_kill.c_str());
|
DBG("system(\"sudo -S pkill -9 FaceSearchServer\");");
|
}
|
|
void devHttpServer_c::killVideoAnalysFromHCApp() const {
|
string local_passwd = appConfig.getStringProperty("localPasswd");
|
string cmd_kill = "echo \"" + local_passwd + "\" | sudo -S pkill -9 VideoAnalysFrom";
|
system(cmd_kill.c_str());
|
DBG("system(\"sudo -S pkill -9 VideoAnalysFromHC\");");
|
}
|
|
void devHttpServer_c::runAllApp() const {
|
string buildAddr = appConfig.getStringProperty("buildAddr");
|
string cmd = "cd " + buildAddr + " && sh runAll.sh &";
|
system(cmd.c_str());
|
DBG("system(\"cd ~/Apps/QiaoJiaSystem/build/ && sh runAll.sh\");");
|
}
|
|
//显示摄像机列表
|
std::string devHttpServer_c::cam_show(std::string ip, unsigned int port, std::string content, PResponse &response) {
|
DBG("ip:" << ip << "; port:" << port);
|
DBG("content: " << content);
|
|
Json::Value value;
|
Json::Value elem;
|
|
std::list<Record_Cam_Dev> rec_list = db_c.searchCamDevTableAll();
|
list<Record_Cam_Dev>::iterator iter;
|
|
for (iter = rec_list.begin(); iter != rec_list.end(); ++iter) {
|
// elem["str_storage_dev_id"] = iter->str_storage_dev_id.toStdString();
|
elem["str_cam_dev_id"] = iter->str_cam_dev_id.toStdString();
|
elem["str_name"] = iter->str_name.toStdString();
|
elem["str_addr"] = iter->str_addr.toStdString();
|
elem["str_longitude"] = iter->str_longitude.toStdString();
|
elem["str_latitude"] = iter->str_latitude.toStdString();
|
elem["str_ip"] = iter->str_ip.toStdString();
|
elem["n_port"] = iter->n_port;
|
elem["str_username"] = iter->str_username.toStdString();
|
elem["str_password"] = iter->str_password.toStdString();
|
elem["str_brand"] = iter->str_brand.toStdString();
|
elem["str_reserved"] = iter->str_reserved.toStdString();
|
|
Record_Cam_Sdk rec_sdk = db_c.searchCamSdkTableByCamId(iter->str_cam_dev_id);
|
elem["str_sdks"] = rec_sdk.str_sdks.toStdString();
|
elem["str_det_thr"] = rec_sdk.str_det_thr.toStdString();
|
elem["str_cmp_thr"] = rec_sdk.str_cmp_thr.toStdString();
|
|
cout << elem.toStyledString() << endl;
|
|
value.append(elem);
|
}
|
|
cout << value.toStyledString() << endl;
|
std::string out = value.size() > 0 ? value.toStyledString() : "[]";
|
return out;
|
}
|
|
//编辑摄像机
|
std::string devHttpServer_c::cam_edit(std::string ip, unsigned int port, std::string content, PResponse &response) {
|
DBG("ip:" << ip << "; port:" << port);
|
DBG("content: " << content);
|
|
Json::Reader reader;
|
Json::Value value;
|
bool ret = false;
|
Record_Cam_Dev rec;
|
Record_Cam_Sdk rec_sdk_old;
|
Record_Cam_Sdk rec_sdk;
|
|
int dev_type = db_c.searchDevTypeFromConfigTable();
|
if (DEV_STORAGE == dev_type) {
|
return "{\"ret_status\": \"内容有误，请检查！\"}";
|
}
|
|
if (reader.parse(content, value)) {
|
unsigned char serialnumber[SERIALNO_LEN] = {0};
|
ret = getDevSerialNumber(value["str_ip"].asCString(), value["n_port"].asInt(),
|
value["str_username"].asCString(), \
|
value["str_password"].asCString(), value["str_brand"].asCString(), serialnumber);
|
if ((!ret) || (serialnumber[0] == 0)) {
|
return "{\"ret_status\": \"内容有误，请检查！\"}";
|
}
|
|
rec.str_cam_dev_id = QString::fromLatin1((const char *) serialnumber);//摄像机id cam_mac
|
rec.str_name = QString::fromStdString(value["str_name"].asString());
|
rec.str_addr = QString::fromStdString(value["str_addr"].asString());
|
rec.str_longitude = QString::fromStdString(value["str_longitude"].asString());
|
rec.str_latitude = QString::fromStdString(value["str_latitude"].asString());
|
rec.str_ip = QString::fromStdString(value["str_ip"].asString());
|
rec.n_port = value["n_port"].asInt();
|
rec.str_username = QString::fromStdString(value["str_username"].asString());
|
rec.str_password = QString::fromStdString(value["str_password"].asString());
|
rec.str_brand = QString::fromStdString(value["str_brand"].asString());
|
|
rec_sdk_old = db_c.searchCamSdkTableByCamId(rec.str_cam_dev_id);
|
|
rec_sdk.str_cam_dev_id = rec.str_cam_dev_id;
|
rec_sdk.str_sdks = QString::fromStdString(value["str_sdks"].asString());
|
rec_sdk.str_det_thr = QString::fromStdString(value["str_det_thr"].asString());
|
rec_sdk.str_cmp_thr = QString::fromStdString(value["str_cmp_thr"].asString());
|
|
ret = db_c.updateCamAndSdkTable(rec, rec_sdk);
|
if (!ret) {
|
return "err_db_content";
|
}
|
} else {
|
return "{\"ret_status\": \"传输错误，请检查！\"}";
|
}
|
|
if (DEV_NO_TYPE == dev_type) {//add new camera
|
db_c.updateConfigTableByDevType(DEV_CAMERA);
|
runAllApp();
|
}
|
//edit camera's sdks
|
else/* if ((rec_sdk_old.str_sdks != rec_sdk.str_sdks) ||
|
(rec_sdk_old.str_det_thr != rec_sdk.str_det_thr) ||
|
(rec_sdk_old.str_cmp_thr != rec_sdk.str_cmp_thr)) */{
|
killVideoAnalysFromHCApp();
|
sleep(1);
|
runAllApp();
|
}
|
|
Json::Value value_out;
|
value_out["str_cam_dev_id"] = rec.str_cam_dev_id.toStdString();
|
std::string out = value_out.toStyledString();
|
|
return out;
|
}
|
|
bool devHttpServer_c::cam_connect_video_start(std::string ip, int port, std::string username, std::string passwd, \
|
std::string brand) const {
|
|
if (brand == "haikang") {
|
bool ret = getHKDevSerialNumber(ip.c_str(), port, username.c_str(), passwd.c_str());
|
if (!ret) {
|
ERR("getHKDevSerialNumber ERR");
|
return false;
|
}
|
//调用rtsp流rtsp://admin:a1234567@192.168.1.215:554/h264/ch1/main/av_stream
|
port = 554;//TODO
|
// std::string rtsp_url = "rtsp://" + username + ":" + passwd + "@" + ip + ":" + std::to_string(port) +
|
// "/h264/ch1/main/av_stream";
|
std::string rtsp_url = rtspAddrBuild(ip.c_str(), port, username.c_str(), passwd.c_str(), brand.c_str());
|
if (rtsp_url.empty()) {
|
return false;
|
}
|
|
DBG("rtsp_url:" << rtsp_url);
|
Json::Value json;
|
json["rtsp"] = rtsp_url;
|
|
//拼接json
|
string str_uuid;
|
uuid_t t_uuid;
|
char str[36];
|
uuid_generate(t_uuid);
|
uuid_unparse(t_uuid, str);
|
str_uuid = str;
|
|
std::string rtmpAddr = appConfig.getStringProperty("srsAddr");
|
std::string publish_basepath = rtmpAddr + "cam" + str_uuid;
|
DBG("publish_basepath:" << publish_basepath);
|
appPref.setStringData("publish.basepath", publish_basepath);
|
appPref.setIntData("pulish.width", 640);
|
appPref.setIntData("pulish.height", 360);
|
|
if (m_rtmp.find(ip) != m_rtmp.end()) {
|
if (m_rtmp[ip].appPC == nullptr) {
|
m_rtmp[ip].userCounter = 0;
|
m_rtmp[ip].appPC = new AppPipeController(0, json);
|
m_rtmp[ip].appPC->start();
|
}
|
m_rtmp[ip].userCounter++;
|
|
} else {
|
m_rtmp[ip].appPC = new AppPipeController(0, json);
|
m_rtmp[ip].appPC->start();
|
m_rtmp[ip].userCounter = 1;
|
}
|
|
DBG("m_rtmp[ip]->start(); ip:" << ip);
|
|
} else if (brand == "dahua") {
|
//rtsp://username:password@ip:port/cam/realmonitor?channel=1&subtype=0
|
return false;//TODO
|
} else if (brand == "yushi") {
|
// rtsp://admin:admin@192.168.8.8:554/video1
|
bool ret = getUVDevSerialNumber(ip.c_str(), username.c_str(), passwd.c_str());
|
if (!ret) {
|
ERR("getUVDevSerialNumber ERR");
|
return false;
|
}
|
|
port = 554;
|
// std::string rtsp_url = "rtsp://" + username + ":" + passwd + "@" + ip + ":" + std::to_string(port) +
|
// "/video1";
|
std::string rtsp_url = rtspAddrBuild(ip.c_str(), port, username.c_str(), passwd.c_str(), brand.c_str());
|
if (rtsp_url.empty()) {
|
return false;
|
}
|
DBG("rtsp_url:" << rtsp_url);
|
Json::Value json;
|
json["rtsp"] = rtsp_url;
|
|
//拼接json
|
string str_uuid;
|
uuid_t t_uuid;
|
char str[36];
|
uuid_generate(t_uuid);
|
uuid_unparse(t_uuid, str);
|
str_uuid = str;
|
|
std::string rtmpAddr = appConfig.getStringProperty("srsAddr");
|
std::string publish_basepath = rtmpAddr + "cam" + str_uuid;
|
DBG("publish_basepath:" << publish_basepath);
|
appPref.setStringData("publish.basepath", publish_basepath);
|
appPref.setIntData("pulish.width", 640);
|
appPref.setIntData("pulish.height", 360);
|
|
if (m_rtmp.find(ip) != m_rtmp.end()) {
|
if (m_rtmp[ip].appPC == nullptr) {
|
m_rtmp[ip].userCounter = 0;
|
m_rtmp[ip].appPC = new AppPipeController(0, json);
|
m_rtmp[ip].appPC->start();
|
}
|
m_rtmp[ip].userCounter++;
|
|
} else {
|
m_rtmp[ip].appPC = new AppPipeController(0, json);
|
m_rtmp[ip].appPC->start();
|
m_rtmp[ip].userCounter = 1;
|
}
|
|
DBG("m_rtmp[ip]->start(); ip:" << ip);
|
|
} else {
|
DBG("other brand");
|
return false;//TODO
|
}
|
|
return true;
|
}
|
|
bool devHttpServer_c::cam_connect_video_stop(std::string ip) const {
|
|
DBG("cam_connect_video_stop begin");
|
// if (m_rtmp.size() > 0) {
|
// auto it = m_rtmp.begin();
|
// while (it != m_rtmp.end()) {
|
// m_rtmp[it->first]->stop();
|
// m_rtmp[it->first]->wait();
|
// it++;
|
// }
|
// }
|
if (m_rtmp.find(ip) != m_rtmp.end()) {
|
if (m_rtmp[ip].appPC == nullptr) {
|
m_rtmp.erase(ip);
|
} else {
|
m_rtmp[ip].userCounter--;
|
|
if (m_rtmp[ip].userCounter == 0) {
|
m_rtmp[ip].appPC->stop();
|
m_rtmp[ip].appPC->wait();
|
m_rtmp.erase(ip);
|
}
|
}
|
}
|
DBG("cam_connect_video_stop end");
|
|
|
return true;
|
}
|
|
//测试摄像机连接
|
std::string
|
devHttpServer_c::chk_cam_connet(std::string ip, unsigned int port, std::string content, PResponse &response) {
|
DBG("ip:" << ip << "; port:" << port);
|
DBG("content: " << content);
|
|
Json::Reader reader;
|
Json::Value value_reader;
|
|
if (!reader.parse(content, value_reader)) {
|
return "{\"ret_status\": \"传输错误，请检查！\"}";
|
}
|
|
//TODO
|
//调用rtsp流rtsp://admin:a1234567@192.168.1.215:554/h264/ch1/main/av_stream
|
// std::string rtsp_url = "rtsp://" + username + ":" + passwd + "@" + ip + ":" + std::to_string(port) + "/h264/ch1/main/av_stream";
|
bool ret = cam_connect_video_start(value_reader["str_ip"].asString(), value_reader["n_port"].asInt(), \
|
value_reader["str_username"].asString(), value_reader["str_password"].asString(), \
|
value_reader["str_brand"].asString());
|
if (!ret) {
|
return "{\"ret_status\": \"内容有误，请检查！\"}";
|
}
|
|
std::string rtmp_url = m_rtmp[value_reader["str_ip"].asCString()].appPC->getRtmp();
|
Json::Value value;
|
value["connect_status"] = "True";
|
value["video_url"] = rtmp_url;
|
std::string out = value.toStyledString();
|
|
return out;
|
}
|
|
//测试摄像机连接
|
std::string
|
devHttpServer_c::chk_cam_disconnet(std::string ip, unsigned int port, std::string content, PResponse &response) {
|
DBG("ip:" << ip << "; port:" << port);
|
DBG("content: " << content);
|
|
Json::Reader reader;
|
Json::Value value_reader;
|
|
if (!reader.parse(content, value_reader)) {
|
return "{\"ret_status\": \"传输错误，请检查！\"}";
|
}
|
|
//TODO
|
//调用rtsp流rtsp://admin:a1234567@192.168.1.215:554/h264/ch1/main/av_stream
|
// std::string rtsp_url = "rtsp://" + username + ":" + passwd + "@" + ip + ":" + std::to_string(port) + "/h264/ch1/main/av_stream";
|
DBG("cam_connect_video_stop begin");
|
bool ret = cam_connect_video_stop(value_reader["str_ip"].asString());
|
if (!ret) {
|
return "{\"ret_status\": \"传输错误，请检查！\"}";
|
}
|
DBG("cam_connect_video_stop end");
|
|
Json::Value value;
|
value["ret_status"] = "ok_ack";
|
|
std::string out = value.toStyledString();
|
|
return out;
|
}
|
|
//删除磁盘阵列及对应通道列表
|
std::string devHttpServer_c::dev_del(std::string ip, unsigned int port, std::string content, PResponse &response) {
|
DBG("ip:" << ip << "; port:" << port);
|
DBG("content: " << content);
|
|
Json::Reader reader;
|
Json::Value value_reader;
|
|
int dev_type = db_c.searchDevTypeFromConfigTable();
|
if (DEV_CAMERA == dev_type) {
|
return "{\"ret_status\": \"内容有误，请检查！\"}";
|
}
|
|
if (reader.parse(content, value_reader)) {
|
QString dev_id = QString::fromStdString(value_reader["str_storage_dev_id"].asString());
|
int ret = db_c.deleteDeviceTableAndChnAndSdk(dev_id);
|
if (ret) {
|
killVideoAnalysFromHCApp();
|
db_c.deleteLoadFileTablebyDevID(QString::fromStdString(value_reader["str_storage_dev_id"].asString()));
|
db_c.deleteCutVideoTablebyDevID(QString::fromStdString(value_reader["str_storage_dev_id"].asString()));
|
db_c.deleteSdkHdlTablebyDevID(QString::fromStdString(value_reader["str_storage_dev_id"].asString()));
|
int dev_record = db_c.searchDeviceNumber();
|
if (dev_record == 0) {
|
db_c.updateConfigTableByDevType(DEV_NO_TYPE);
|
} else {
|
runAllApp();
|
}
|
return "{\"ret_status\": \"ok_ack\"}";
|
} else {
|
return "err_db";
|
}
|
}
|
|
return "{\"ret_status\": \"传输错误，请检查！\"}";
|
}
|
|
//删除摄像机
|
std::string devHttpServer_c::cam_del(std::string ip, unsigned int port, std::string content, PResponse &response) {
|
DBG("ip:" << ip << "; port:" << port);
|
DBG("content: " << content);
|
|
Json::Reader reader;
|
Json::Value value_reader;
|
|
int dev_type = db_c.searchDevTypeFromConfigTable();
|
if (DEV_STORAGE == dev_type) {
|
return "{\"ret_status\": \"内容有误，请检查！\"}";
|
}
|
|
|
if (reader.parse(content, value_reader)) {
|
QString cam_id = QString::fromStdString(value_reader["str_cam_dev_id"].asString());
|
int ret = db_c.deleteCamDevandSdkByCamID(cam_id);
|
if (ret) {
|
killVideoAnalysFromHCApp();
|
int dev_record = db_c.searchCamDevNumber();
|
if (dev_record == 0) {
|
db_c.updateConfigTableByDevType(DEV_NO_TYPE);
|
} else {
|
runAllApp();
|
}
|
return "{\"ret_status\": \"ok_ack\"}";
|
} else {
|
return "err_db";
|
}
|
}
|
|
return "{\"ret_status\": \"传输错误，请检查！\"}";
|
}
|
|
//修改ip 端口等配置信息
|
std::string
|
devHttpServer_c::server_info_edit(std::string ip, unsigned int port, std::string content, PResponse &response) {
|
DBG("ip:" << ip << "; port:" << port);
|
DBG("content: " << content);
|
|
Json::Reader reader;
|
Json::Value value;
|
bool ret = false;
|
|
if (reader.parse(content, value)) {
|
Record_Config lRec;
|
lRec.str_alarm_ip = QString::fromStdString(value["alarm_ip"].asString());
|
lRec.n_alarm_port = value["alarm_port"].asInt();
|
lRec.str_web_pic_ip = QString::fromStdString(value["web_pic_ip"].asString());
|
lRec.n_web_pic_port = value["web_pic_port"].asInt();
|
lRec.str_es_pic_ip = QString::fromStdString(value["es_pic_ip"].asString());
|
lRec.n_es_pic_port = value["es_pic_port"].asInt();
|
if ((checkip(lRec.str_alarm_ip.toStdString())) &&
|
(checkip(lRec.str_web_pic_ip.toStdString())) &&
|
(checkip(lRec.str_es_pic_ip.toStdString()))) {
|
ret = db_c.updateConfigTableByServerInfo(lRec);
|
|
//#todo webserver
|
std::string cmd_web =
|
"sed -i '/tracker_server=/d' ./WebFDSClient.conf && sed -i '/\\\"host:port\\\"/atracker_server=" + \
|
value["web_pic_ip"].asString() + ":" + std::to_string(value["web_pic_port"].asInt()) + \
|
"' ./WebFDSClient.conf";//
|
std::cout << "cmd_web:" << cmd_web << std::endl;
|
system(cmd_web.c_str());
|
|
//#todo fastDfsClient
|
//system("sed -i '/tracker_server=/d' ./fastDfsClient.conf && sed -i '/\"host:port\"/atracker_server=192.168.1.188:22122' ./fastDfsClient.conf");
|
std::string cmd_es =
|
"sed -i '/tracker_server=/d' ./fastDfsClient.conf && sed -i '/\\\"host:port\\\"/atracker_server=" + \
|
value["es_pic_ip"].asString() + ":" + std::to_string(value["es_pic_port"].asInt()) + \
|
"' ./fastDfsClient.conf";
|
std::cout << "cmd_es:" << cmd_es << std::endl;
|
system(cmd_es.c_str());
|
|
//#todo config
|
{
|
fdfsClient.rwLock.wrlock();
|
if (fdfsClient.fastFds != nullptr) {
|
delete fdfsClient.fastFds;
|
}
|
fdfsClient.fastFds = new FastFds("./WebFDSClient.conf");
|
fdfsClient.rwLock.unlock();
|
}
|
|
//# http client 127.0.0.1:9999/resetFdfs
|
std::string http_cmd = "http://127.0.0.1:9999/resetFdfs";
|
HttpRequestWithCrul httpRequestWithCrul;
|
std::string response_bak = "";
|
std::string postParams_bak = "";
|
httpRequestWithCrul.curl_post_req("http://127.0.0.1:9999/resetFdfs", postParams_bak, response_bak);
|
}
|
} else {
|
return "{\"ret_status\": \"传输错误，请检查！\"}";
|
}
|
|
if (ret) {
|
return "{\"ret_status\": \"ok_ack\"}";
|
} else {
|
return "{\"ret_status\": \"内容有误，请检查！\"}";
|
}
|
}
|
|
//查询 ip 端口等配置信息
|
std::string
|
devHttpServer_c::server_info_show(std::string ip, unsigned int port, std::string content, PResponse &response) {
|
DBG("ip:" << ip << "; port:" << port);
|
DBG("content: " << content);
|
|
Json::Value value;
|
|
Record_Config rec = db_c.searchConfigTableWithinServerInfo();
|
|
value["alarm_ip"] = rec.str_alarm_ip.toStdString();
|
value["alarm_port"] = rec.n_alarm_port;
|
value["web_pic_ip"] = rec.str_web_pic_ip.toStdString();
|
value["web_pic_port"] = rec.n_web_pic_port;
|
value["es_pic_ip"] = rec.str_es_pic_ip.toStdString();
|
value["es_pic_port"] = rec.n_es_pic_port;
|
|
std::string out = value.toStyledString();
|
|
return out;
|
}
|
|
//编辑 裁剪视频时长
|
std::string
|
devHttpServer_c::cut_dura_edit(std::string ip, unsigned int port, std::string content, PResponse &response) {
|
DBG("ip:" << ip << "; port:" << port);
|
DBG("content: " << content);
|
|
Json::Reader reader;
|
Json::Value value;
|
bool ret = false;
|
|
if (reader.parse(content, value)) {
|
int cut_max_duration = value["cut_max_duration"].asInt();
|
|
ret = db_c.updateConfigTableByCutDuration(cut_max_duration);
|
|
} else {
|
return "{\"ret_status\": \"传输错误，请检查！\"}";
|
}
|
|
if (ret) {
|
killVideoAnalysFromHCApp();
|
sleep(1);
|
runAllApp();
|
return "{\"ret_status\": \"ok_ack\"}";
|
} else {
|
return "{\"ret_status\": \"内容有误，请检查！\"}";
|
}
|
}
|
|
//查询 裁剪视频时长
|
std::string
|
devHttpServer_c::cut_dura_show(std::string ip, unsigned int port, std::string content, PResponse &response) {
|
DBG("ip:" << ip << "; port:" << port);
|
DBG("content: " << content);
|
|
Json::Value value;
|
|
int cut_max_duration = db_c.searchConfigTableWithinCutDuration();
|
|
value["cut_max_duration"] = cut_max_duration;
|
|
std::string out = value.toStyledString();
|
|
return out;
|
}
|
|
//设置本机netconfig netconfig_edit
|
std::string
|
devHttpServer_c::netconfig_edit(std::string ip, unsigned int port, std::string content, PResponse &response) {
|
DBG("ip:" << ip << "; port:" << port);
|
DBG("content: " << content);
|
|
Json::Reader reader;
|
Json::Value value;
|
bool ret = false;
|
unsigned char ip_old[15] = {0};
|
unsigned char netmask_old[15] = {0};
|
unsigned char gateway_old[15] = {0};
|
|
if (reader.parse(content, value)) {
|
std::string ip_addr = value["ipaddr"].asString();
|
std::string netmask = value["netmask"].asString();
|
std::string gateway = value["gateway"].asString();
|
|
//ipaddr
|
std::string net_ifname = appConfig.getStringProperty("netIfName");
|
if (!((GetIpAddress(net_ifname.c_str(), ip_old)) && \
|
(GetMaskAddress(net_ifname.c_str(), netmask_old)) && \
|
(GetGateWay(net_ifname.c_str(), gateway_old)))) {
|
// return "{\"ret_status\": \"内容有误，请检查！\"}";
|
}
|
|
std::string ip_old_temp((char *) ip_old);
|
std::string netmask_old_temp((char *) netmask_old);
|
std::string gateway_old_temp((char *) gateway_old);
|
|
if (!((ip_old_temp == ip_addr) && \
|
(netmask_old_temp == netmask) && \
|
(gateway_old_temp == gateway))) {
|
if (!((checkip(ip_addr)) && (checkMask(netmask)) && (checkip(gateway)))) {
|
return "{\"ret_status\": \"内容有误，请检查！\"}";
|
}
|
|
ret = SetIpAddress(net_ifname.c_str(), ip_addr.c_str());
|
if (!ret) {
|
return "{\"ret_status\": \"内容有误，请检查！\"}";
|
}
|
ret = SetMaskAddress(net_ifname.c_str(), netmask.c_str());
|
if (!ret) {
|
return "{\"ret_status\": \"内容有误，请检查！\"}";
|
}
|
ret = SetGateWay(net_ifname.c_str(), gateway_old_temp.c_str(), gateway.c_str());
|
if (!ret) {
|
//return "{\"ret_status\": \"内容有误，请检查！\"}";
|
}
|
|
//#todo /etc/network/interfaces
|
//system("sed -i '/tracker_server=/d' ./fastDfsClient.conf && sed -i '/\"host:port\"/atracker_server=192.168.1.188:22122' ./fastDfsClient.conf");
|
// system("sed -i 's/address .*$/address 192.168.1.111/g' test");
|
std::string cmd_ip =
|
"sed -i 's/address .*$/address " + ip_addr + "/g' /etc/network/interfaces";
|
std::cout << "cmd_ip:" << cmd_ip << std::endl;
|
system(cmd_ip.c_str());
|
|
//修改config.json
|
std::string strtmp = appConfig.getStringProperty("erlNode");
|
std::string::size_type pos = strtmp.find_last_of("@");
|
if (pos != std::string::npos) {
|
++pos;//保留sep '@'
|
strtmp.replace(pos, strtmp.size() - pos, ip_addr);
|
appConfig.setStringProperty("erlNode", strtmp);
|
}
|
|
strtmp = appConfig.getStringProperty("erlFatherNode");
|
pos = strtmp.find_last_of("@");
|
if (pos != std::string::npos) {
|
++pos;//保留sep '@'
|
strtmp.replace(pos, strtmp.size() - pos, ip_addr);
|
appConfig.setStringProperty("erlFatherNode", strtmp);
|
}
|
//ES_IP
|
appConfig.setStringProperty("ES_IP", ip_addr);
|
|
strtmp = appConfig.getStringProperty("srsAddr");
|
strtmp.replace(strtmp.begin() + 7, strtmp.begin() + strtmp.find(":1934/live/"), ip_addr);
|
appConfig.setStringProperty("srsAddr", strtmp);
|
appConfig.save();
|
|
sleep(10);
|
system("reboot");
|
}
|
} else {
|
return "{\"ret_status\": \"传输错误，请检查！\"}";
|
}
|
|
return "{\"ret_status\": \"ok_ack\"}";
|
}
|
|
//查询 本机netconfig netconfig_show
|
std::string
|
devHttpServer_c::netconfig_show(std::string ip, unsigned int port, std::string content, PResponse &response) {
|
DBG("ip:" << ip << "; port:" << port);
|
DBG("content: " << content);
|
|
Json::Value value;
|
unsigned char netmask_old[15] = {0};
|
unsigned char gateway_old[15] = {0};
|
unsigned char ip_old[15] = {0};
|
|
std::string net_ifname = appConfig.getStringProperty("netIfName");
|
// if (!((GetIpAddress(net_ifname.c_str(), ip_old)) && \
|
// (GetMaskAddress(net_ifname.c_str(), netmask_old)) && \
|
// (GetGateWay(net_ifname.c_str(), gateway_old)))) {
|
// return "{\"ret_status\": \"内容有误，请检查！\"}";
|
// }
|
if (GetIpAddress(net_ifname.c_str(), ip_old)) {
|
std::string ip_old_temp((char *) ip_old);
|
value["ipaddr"] = ip_old_temp;
|
} else {
|
value["ipaddr"] = "";
|
}
|
|
if (GetMaskAddress(net_ifname.c_str(), netmask_old)) {
|
std::string netmask_old_temp((char *) netmask_old);
|
value["netmask"] = netmask_old_temp;
|
} else {
|
value["netmask"] = "";
|
}
|
|
if (GetGateWay(net_ifname.c_str(), gateway_old)) {
|
std::string gateway_old_temp((char *) gateway_old);
|
value["gateway"] = gateway_old_temp;
|
} else {
|
value["gateway"] = "";
|
}
|
|
std::string out = value.toStyledString();
|
|
return out;
|
}
|
|
std::string devHttpServer_c::addNode(std::string ip, unsigned int port, std::string content, PResponse &response) {
|
DBG("ip:" << ip << "; port:" << port);
|
DBG("content: " << content);
|
Json::Reader reader;
|
Json::Value value;
|
bool ret = false;
|
if (reader.parse(content, value)) {
|
|
//#todo nodeName Automatic generated?
|
//#todo nodes have counter?
|
//#todo nodeName Automatic generated?
|
//#todo devId+num
|
std::string uuid = GetUUId::getUUID();
|
|
unsigned char ip_old[15] = {0};
|
std::string str_netIfName = appConfig.getStringProperty("netIfName");
|
GetIpAddress(str_netIfName.c_str(), ip_old);
|
std::string str_ip((char *) ip_old);
|
std::string nodeName = uuid.append("@" + str_ip);
|
|
std::string cookie = value["cookie"].asString();
|
std::string FatherNodeName = value["fatherNodeName"].asString();
|
|
//#todo ClusterID ClusterName
|
std::string clusterID = value["culID"].asString();
|
clusterID = clusterID.size() > 0 ? clusterID : GetUUId::getUUID();
|
std::string clusterName = value["culName"].asString();
|
std::string devID = value["devID"].asString();
|
std::string devName = value["devName"].asString();
|
|
|
std::string path = std::string("/opt/erlang/").append(nodeName.substr(0, nodeName.find("@")));
|
if (erlangDbTool != nullptr) {
|
//gaunbi node
|
//clear data
|
// erlangDbTool.stop();
|
delete erlangDbTool;
|
erlangDbTool = nullptr;
|
}
|
|
if (cookie.size() > 0 && (clusterID.size() > 0 || clusterName.size() > 0)) {
|
// erlangDbTool = new ErlangTool::ErlangDbTool(path, nodeName, cookie);
|
string str_tmp = "DataWebserver";
|
erlangDbTool = new ErlangTool::ErlangDbTool(path, nodeName, cookie, clusterID, clusterName, str_tmp);
|
bool ret = erlangDbTool->initErlang();
|
FatherNodeName = FatherNodeName.size() > 0 ? FatherNodeName : " ";
|
// FatherNodeName = clusterID.size() > 0 ? clusterID : " ";
|
ret = erlangDbTool->startNodeDb(FatherNodeName, devID);
|
|
if (ret) {
|
appConfig.setStringProperty("erlNode", nodeName);
|
appConfig.setStringProperty("erlCookie", cookie);
|
appConfig.setStringProperty("erlPath", path);
|
appConfig.setStringProperty("erlFatherNode", FatherNodeName);
|
appConfig.save();
|
// erlangDbTool->findAllNode();
|
//face search server reboot
|
killFaceSearchServerApp();
|
runAllApp();
|
// sleep(4);
|
} else {
|
appConfig.setStringProperty("erlNode", "");
|
appConfig.setStringProperty("erlCookie", "");
|
appConfig.setStringProperty("erlPath", "");
|
appConfig.setStringProperty("erlFatherNode", "");
|
appConfig.save();
|
delete erlangDbTool;
|
erlangDbTool = nullptr;
|
}
|
|
std::string str_result = std::string("{\"result\":").append("\"" + std::to_string(ret) + "\"}");
|
return str_result;
|
} else {
|
std::string str_result = std::string("{\"result\":").append("\"数据有误\"}");
|
return str_result;
|
}
|
} else {
|
response->write(SimpleWeb::StatusCode::server_error_not_implemented, "{\"error\":\"传输错误，请检查！ \"}");
|
return "";
|
}
|
}
|
|
std::string devHttpServer_c::removeNode(std::string ip, unsigned int port, std::string content, PResponse &response) {
|
DBG("ip:" << ip << "; port:" << port);
|
DBG("content: " << content);
|
|
bool ret = false;
|
|
if (erlangDbTool != nullptr) {
|
|
ret = erlangDbTool->removeNode();
|
|
appConfig.setStringProperty("erlNode", "");
|
appConfig.setStringProperty("erlCookie", "");
|
appConfig.setStringProperty("erlPath", "");
|
appConfig.setStringProperty("erlFatherNode", "");
|
appConfig.save();
|
delete erlangDbTool;
|
erlangDbTool = nullptr;
|
std::string str_result = std::string("{\"result\":").append("\"" + std::to_string(ret) + "\"}");
|
//#todo
|
system("pkill beam.*");
|
return str_result;
|
} else {
|
response->write(SimpleWeb::StatusCode::server_error_not_implemented, "{\"error\":\"节点不存在 \"}");
|
return "";
|
}
|
}
|
|
string devHttpServer_c::searchNode(std::string ip, unsigned int port, std::string content,
|
PResponse &response) {
|
DBG("ip:" << ip << "; port:" << port);
|
DBG("content: " << content);
|
if (erlangDbTool == nullptr) {
|
ERR("{\"error\":\"节点不存在 \"}");
|
response->write(SimpleWeb::StatusCode::server_error_not_implemented, "{\"error\":\"节点不存在 \"}");
|
return "";
|
// return "{\"error\":\"erlang is null\"}";
|
}
|
// sleep(1);
|
auto resu = erlangDbTool->findAllNode();
|
string json = "";
|
if (resu.size() > 0) {
|
auto t_itor = resu.begin();
|
m_cluster_id = t_itor->second.cluster_id;
|
m_cluster_name = t_itor->second.cluster_name;
|
json.append("{ \"cluster_id\":\"" + t_itor->second.cluster_id
|
+ "\",\"cluster_name\":\"" + t_itor->second.cluster_name + "\",\"list\":[");
|
for (auto &item : resu) {
|
string subJson = "{ ";
|
subJson.append("\"uuid\":\"" + item.second.uuid + "\",");
|
subJson.append("\"create_time\":\"" + item.second.create_time + "\",");
|
subJson.append("\"dev_id\":\"" + item.second.device_id + "\",");
|
//#todo
|
auto rec = db_c.searchConfigTableWithinServerInfo();
|
subJson.append("\"dev_name\":\"" + rec.dev_name.toStdString() + "\",");
|
|
string t_nodeId = item.second.node_id;
|
subJson.append(
|
"\"node_ip\":\"" + t_nodeId.substr(t_nodeId.find("@") + 1, t_nodeId.size() - t_nodeId.find("@")) +
|
"\",");
|
subJson.append("\"node_id\":\"" + item.second.node_id + "\"");
|
subJson.append("},");
|
json.append(subJson);
|
}
|
auto str = json.substr(0, json.size() - 1);
|
str.append("]}");
|
DBG(str);
|
return str;
|
} else {
|
ERR("resu is null");
|
// response->write(SimpleWeb::StatusCode::err_erlNodeIsNull, "{\"error\":\"err_erlNodeIsNull \"}");
|
return "{}";
|
}
|
}
|
|
string devHttpServer_c::modifyCluName(std::string ip, unsigned int port, std::string content,
|
PResponse &response) {
|
DBG("ip:" << ip << "; port:" << port);
|
DBG("content: " << content);
|
|
if (erlangDbTool == nullptr) {
|
response->write(SimpleWeb::StatusCode::server_error_not_implemented, "{\"error\":\"节点不存在 \"}");
|
return "";
|
return "{\"error\":\"erlang is null\"}";
|
}
|
|
Json::Reader reader;
|
Json::Value value;
|
// bool ret = false;
|
|
if (reader.parse(content, value)) {
|
std::string cluster_id = value["cluster_id"].asString();
|
std::string cluster_name = value["cluster_name"].asString();
|
bool ret = false;
|
if (cluster_id.size() <= 0 || cluster_name.size() <= 0) {
|
return "{\"error\":\"参数错误，请检查！\"}";
|
}
|
|
ret = erlangDbTool->modifyCluName(cluster_id, cluster_name);
|
|
std::string str_result = std::string("{\"result\":").append("\"" + std::to_string(ret) + "\"}");
|
return str_result;
|
|
} else {
|
response->write(SimpleWeb::StatusCode::server_error_not_implemented, "{\"error\":\"传输错误，请检查！ \"}");
|
return "";
|
return "{\"error\":\"传输错误，请检查！\"}";
|
}
|
}
|
|
std::string devHttpServer_c::createDatabase(std::string ip, unsigned int port, std::string content,
|
PResponse &response) {
|
DBG("ip:" << ip << "; port:" << port);
|
DBG("content: " << content);
|
if (erlangDbTool == nullptr) {
|
response->write(SimpleWeb::StatusCode::server_error_not_implemented, "{\"error\":\"节点不存在 \"}");
|
return "";
|
return "{\"error\":\"erlang is null\"}";
|
}
|
|
Json::Reader reader;
|
Json::Value value;
|
// bool ret = false;
|
|
if (reader.parse(content, value)) {
|
std::string TableType = value["TableType"].asString();
|
std::string TableName = value["TableName"].asString();
|
int SyncType = atoi(value["SyncType"].asCString());
|
std::string BwType = value["BwType"].asString();
|
std::string StartTime = value["StartTime"].asString();
|
std::string EndTime = value["EndTime"].asString();
|
bool ret = false;
|
if (SyncType == 1) {
|
//同步库
|
ret = erlangDbTool->createDatabase(TableType, TableName, SyncType, BwType, StartTime, EndTime);
|
} else if (SyncType == 0) {
|
TableName.insert(0, "lt_");
|
//本地库
|
FieldValues fieldValues;
|
fieldValues.insert(std::make_pair("uuid", GetUUId::getUUID()));
|
fieldValues.insert(std::make_pair("tableName", TableName));
|
fieldValues.insert(std::make_pair("tableDesc", "ceshi"));
|
fieldValues.insert(std::make_pair("tableType", TableType));
|
fieldValues.insert(std::make_pair("bwType", BwType));
|
fieldValues.insert(std::make_pair("startTime", StartTime));
|
fieldValues.insert(std::make_pair("endTime", EndTime));
|
fieldValues.insert(std::make_pair("create_by", "who"));
|
ret = m_SqliteFaceEncap.createTable(TableName, fieldValues);
|
}
|
|
erlangDbTool->sendMessage();
|
std::string str_result = std::string("{\"result\":").append("\"" + std::to_string(ret) + "\"}");
|
return str_result;
|
|
} else {
|
response->write(SimpleWeb::StatusCode::server_error_not_implemented, "{\"error\":\"传输错误，请检查！ \"}");
|
return "";
|
return "{\"error\":\"传输错误，请检查！\"}";
|
}
|
}
|
|
std::string devHttpServer_c::deleteDatabase(std::string ip, unsigned int port, std::string content,
|
PResponse &response) {
|
DBG("ip:" << ip << "; port:" << port);
|
DBG("content: " << content);
|
if (erlangDbTool == nullptr) {
|
response->write(SimpleWeb::StatusCode::server_error_not_implemented, "{\"error\":\"节点不存在 \"}");
|
return "";
|
return "{\"error\":\"erlang is null\"}";
|
}
|
|
Json::Reader reader;
|
Json::Value value;
|
// bool ret = false;
|
|
if (reader.parse(content, value)) {
|
std::string uuid = value["uuid"].asString();
|
std::string TableType = value["TableType"].asString();
|
std::string TableName = value["TableName"].asString();
|
int SyncType = atoi(value["SyncType"].asCString());
|
|
bool ret = false;
|
if (SyncType == 1) {
|
//同步库
|
ret = erlangDbTool->deleteDatabase(TableType, TableName, SyncType);
|
} else if (SyncType == 0) {
|
//本地库
|
if (TableName.find("lt_") != 0) {
|
TableName.insert(0, "lt_");
|
}
|
ret = m_SqliteFaceEncap.deleteTable(TableName);
|
}
|
erlangDbTool->sendMessage();
|
std::string str_result = std::string("{\"result\":").append("\"" + std::to_string(ret) + "\"}");
|
return str_result;
|
} else {
|
response->write(SimpleWeb::StatusCode::server_error_not_implemented, "{\"error\":\"传输错误，请检查！ \"}");
|
return "";
|
return "{\"error\":\"传输错误，请检查！\"}";
|
}
|
}
|
|
std::string devHttpServer_c::findAllDatabase(std::string ip, unsigned int port, std::string content,
|
PResponse &response) {
|
DBG("ip:" << ip << "; port:" << port);
|
DBG("content: " << content);
|
|
if (erlangDbTool == nullptr) {
|
response->write(SimpleWeb::StatusCode::server_error_not_implemented, "{\"error\":\"节点不存在 \"}");
|
return "";
|
return "{\"error\":\"erlang is null\"}";
|
}
|
|
auto resDB = erlangDbTool->findAllDatabase();
|
auto si = resDB.size();
|
if (resDB.size() > 0) {
|
// auto resType = erlangDbTool->findAllTypeInfo();
|
string json = "[";
|
for (auto &item : resDB) {
|
if (item.second.tableName.find("lt_") == 0) {
|
continue;
|
}
|
string subJson = "{ ";
|
subJson.append("\"uuid\":\"" + item.second.uuid + "\",");
|
subJson.append("\"tableName\":\"" + item.second.tableName + "\",");
|
subJson.append("\"tableType\":\"" + item.second.tableType + "\",");
|
// subJson.append("\"bwType\":\"" + resType[item.second.tableName].bwType + "\",");
|
subJson.append("\"bwType\":\"" + item.second.bwType + "\",");
|
//#todo modify
|
subJson.append("\"start_time\":\"" + item.second.startTime + "\",");
|
subJson.append("\"end_time\":\"" + item.second.endTime + "\"");
|
subJson.append("},");
|
json.append(subJson);
|
}
|
|
auto str = json.substr(0, json.size() - 1);
|
if (str.size() <= 1)
|
return "[]";
|
str.append("]");
|
return str;
|
} else {
|
// response->write(SimpleWeb::StatusCode::server_error_not_implemented, "{\"error\":\"size is 0 \"}");
|
// return "";
|
return "[]";
|
}
|
}
|
|
std::string devHttpServer_c::findLocalDatabase(std::string ip, unsigned int port, std::string content,
|
PResponse &response) {
|
DBG("ip:" << ip << "; port:" << port);
|
DBG("content: " << content);
|
|
if (erlangDbTool == nullptr) {
|
response->write(SimpleWeb::StatusCode::server_error_not_implemented, "{\"error\":\"节点不存在\"}");
|
return "";
|
return "{\"error\":\"erlang is null\"}";
|
}
|
string str_local = "lt_";
|
// auto resDB = erlangDbTool->findAllDatabase();
|
// auto si = resDB.size();
|
|
auto resDB = m_SqliteFaceEncap.getTableInfos();
|
|
if (resDB.size() > 0) {
|
string json = "[";
|
for (auto &item : resDB) {
|
string subJson = "{ ";
|
subJson.append("\"uuid\":\"" + item.uuid + "\",");
|
subJson.append("\"tableName\":\"" + item.tableName + "\",");
|
subJson.append("\"tableType\":\"" + item.tableType + "\",");
|
subJson.append("\"bwType\":\"" + item.bwType + "\",");
|
subJson.append("\"start_time\":\"" + item.startTime + "\",");
|
subJson.append("\"end_time\":\"" + item.endTime + "\"");
|
subJson.append("},");
|
json.append(subJson);
|
}
|
auto str = json.substr(0, json.size() - 1);
|
if (str.size() <= 1)
|
return "[]";
|
str.append("]");
|
return str;
|
} else {
|
// response->write(SimpleWeb::StatusCode::server_error_not_implemented, "{\"error\":\"size is 0\"}");
|
// return "";
|
return "[]";
|
}
|
}
|
|
std::string devHttpServer_c::addPerson(std::string ip, unsigned int port, std::string content,
|
PResponse &response) {
|
DBG("ip:" << ip << "; port:" << port);
|
// DBG("content: " << content);
|
if (erlangDbTool == nullptr) {
|
response->write(SimpleWeb::StatusCode::server_error_not_implemented, "{\"error\":\"节点不存在\"}");
|
return "";
|
// return "{\"error\":\"erlang is null\"}";
|
}
|
|
Json::Reader reader;
|
Json::Value value;
|
|
if (reader.parse(content, value)) {
|
std::string TableName = value["TableName"].asString();
|
std::string img_url = value["img_url"].asString();
|
auto tests = value["img_base64"].size();
|
auto ret = value["img_base64"].isString();
|
|
std::string img_base64 = value["img_base64"].asString();
|
std::string idcard = value["idcard"].asString();
|
std::string strUUID = value["uuid"].asString();
|
|
cv::Mat image;
|
if (img_url.size() > 0) {
|
auto t_results = m_curlDownloadImg.download_jpeg(const_cast<char *>(img_url.c_str()));
|
cvutil.buffer2CvMat(t_results.buffer, image);
|
} else if (img_base64.size() > 0) {
|
img_url = "http://";
|
auto str_img = base64.Decode(img_base64.c_str(), img_base64.size());
|
std::vector<unsigned char> buffer(str_img.size());
|
memcpy(buffer.data(), str_img.data(), str_img.size());
|
cvutil.buffer2CvMat(buffer, image);
|
|
|
fdfsClient.rwLock.rdlock();
|
if (fdfsClient.fastFds != nullptr) {
|
img_url.append(fdfsClient.fastFds->getIp() + "/");
|
std::string t_strImg = "";
|
if (!fdfsClient.fastFds->uploadFile(buffer, t_strImg, "jpg")) {
|
img_url = "upload image fail";
|
} else {
|
img_url.append(t_strImg);
|
img_url.clear();
|
img_url = t_strImg;
|
// img_url.append("/").append(t_strImg);
|
}
|
}
|
fdfsClient.rwLock.unlock();
|
} else {
|
response->write(SimpleWeb::StatusCode::server_error_not_implemented, "{\"error\":\"not found img\"}");
|
return "";
|
// return "{\"error\":\"not found img\"}";
|
}
|
|
thread::id pid = std::this_thread::get_id();
|
if (m_handleMap[pid] == nullptr) {
|
DBG("pid is " << pid);
|
m_handleMap[pid] = new CasiaFaceWrapperN;
|
}
|
CasiaFaceWrapperN *t_CasiaFaceWapper = m_handleMap[pid];
|
|
std::string feature_base64;
|
FaceImageN faceImage{image.cols, image.rows, image.step, image.data};
|
auto faceResults = t_CasiaFaceWapper->extractFace(faceImage);
|
|
if (faceResults.size() <= 0) {
|
response->write(SimpleWeb::StatusCode::server_error_not_implemented, "{\"error\":\"not found face\"}");
|
// string str_path = "./img/";
|
// str_path.append(AppUtil::getTimeString() + ".jpg");
|
// cv::imwrite(str_path, image);
|
return "";
|
// return "{\"error\":\"not found face\"}";
|
}
|
|
for (auto &item : faceResults) {
|
feature_base64 = base64.Encode(item.feature.data(), item.feature.size());
|
}
|
auto size = feature_base64.size();
|
// std::string uuid = "";
|
bool ret_addPerson = false;
|
|
if (TableName.find("lt_") == 0) {
|
FieldValues fieldValues;
|
AddFaceData addFaceData;
|
addFaceData.feature.resize(faceResults[0].feature.size());
|
memcpy(addFaceData.feature.data(), faceResults[0].feature.data(), faceResults[0].feature.size());
|
|
//#todo uuid have value is update
|
if (strUUID.size() <= 0) {
|
// get Person id
|
|
strUUID = AppUtil::getPersonId(m_batch, m_SerialNumber);
|
addFaceData.uuid = strUUID;
|
addFaceData.faceUrl = img_url;
|
|
fieldValues.insert(std::make_pair("uuid", strUUID));
|
fieldValues.insert(std::make_pair("idCard", idcard));
|
auto t_id = m_SqliteFaceEncap.addFace(TableName, addFaceData, fieldValues);
|
ret_addPerson = t_id.size() > 0 ? true : false;
|
} else {
|
//#todo update table
|
addFaceData.uuid = strUUID;
|
addFaceData.faceUrl = img_url;
|
|
fieldValues.insert(std::make_pair("uuid", strUUID));
|
fieldValues.insert(std::make_pair("idCard", idcard));
|
m_SqliteFaceEncap.updateFace(TableName, addFaceData, fieldValues);
|
}
|
|
} else {
|
//#todo update data
|
// get Person id
|
strUUID = strUUID.size() > 0 ? strUUID : AppUtil::getPersonId(m_batch, m_SerialNumber);
|
ret_addPerson = erlangDbTool->addPerson(strUUID, TableName, feature_base64, img_url, idcard);
|
}
|
|
if (ret_addPerson && strUUID.size() > 0) {
|
std::string str_result = std::string("{\"uuid\":").append(
|
"\"" + strUUID + "\",\"img_url\":\"" + img_url + "\"}");
|
// usleep(100);
|
erlangDbTool->sendMessage();
|
//todo send person to backServer
|
HttpRequestWithCrul m_requestWithCrul;
|
|
std::thread sendPerson([&](std::string parm_uuid, std::string parm_img_url, std::string parm_idcard,
|
std::string parm_fea) {
|
Json::Value perInfos;
|
Json::Value perInfo;
|
// #todo get string from config.json file
|
// get
|
perInfo["id"] = parm_uuid;
|
perInfo["distributionIds"] = m_cluster_id;
|
perInfo["distributionNames"] = m_cluster_name;
|
auto rec = db_c.searchConfigTableWithinServerInfo();
|
perInfo["deviceId"] = rec.dev_id.toStdString();
|
perInfo["photos"] = parm_img_url;
|
// perInfo["featureBase"] = feature_base64;
|
perInfo["featureBase64"] = parm_fea;
|
perInfo["cardId"] = parm_idcard;
|
perInfos.append(perInfo);
|
|
std::string str_serIp = GET_STR_CONFIG("mainServerIp");
|
std::string str_serPort = GET_STR_CONFIG("mainServerPort");
|
|
// string sendUrl = "192.168.1.203:3697/addPerson/uploadToTemporary";
|
string sendUrl = str_serIp;
|
sendUrl.append(":").append(str_serPort).append("/addPerson/uploadToTemporary");
|
string postParams = perInfos.toStyledString();
|
string str_addRes;
|
|
m_requestWithCrul.curl_post_req(sendUrl, postParams, str_addRes);
|
}, strUUID, img_url, idcard, feature_base64);
|
sendPerson.detach();
|
|
return str_result;
|
} else {
|
std::string str_result = std::string("{\"error\":\"addPerson error\"}");
|
return str_result;
|
}
|
|
} else {
|
response->write(SimpleWeb::StatusCode::server_error_not_implemented, "{\"error\":\"传输错误，请检查！\"}");
|
return "";
|
// return "{\"error\":\"传输错误，请检查！\"}";
|
}
|
}
|
|
std::string devHttpServer_c::loadFaceFeaData(std::string ip, unsigned int port, std::string content,
|
PResponse &response) {
|
DBG("ip:" << ip << "; port:" << port);
|
DBG("content: " << content);
|
if (erlangDbTool == nullptr) {
|
response->write(SimpleWeb::StatusCode::server_error_not_implemented, "{\"error\":\"节点不存在\"}");
|
return "";
|
// return "{\"error\":\"erlang is null\"}";
|
}
|
|
Json::Reader reader;
|
Json::Value value;
|
|
if (reader.parse(content, value)) {
|
std::string TableName = value["TableName"].asString();
|
|
|
if (TableName.find("lt_") == 0) {
|
auto t_resDB = m_SqliteFaceEncap.getFacesFromTable(TableName);
|
auto t_faceInfoCache = m_SqliteFaceEncap.getFaceInfoFromTable(TableName);
|
|
auto &resDB = *t_resDB;
|
if (resDB.size() > 0) {
|
string json = "[";
|
for (auto &item : resDB) {
|
string subJson = "{ ";
|
subJson.append("\"uuid\":\"" + item.second.uuid + "\",");
|
subJson.append("\"tableName\":\"" + TableName + "\",");
|
subJson.append("\"idcard\":\"" + t_faceInfoCache[item.second.uuid].idCard + "\",");
|
subJson.append("\"imgUrl\":\"" + item.second.faceurl + "\"");
|
// subJson.append("\"feature\":\"" + item.second.feature + "\",");
|
//#todo modifysvn upda svn comm
|
// subJson.append("\"start_time\":\"" + item.second.create_time + "\",");
|
// subJson.append("\"end_time\":\"" + item.second.update_time + "\"");
|
subJson.append("},");
|
json.append(subJson);
|
}
|
auto str = json.substr(0, json.size() - 1);
|
str.append("]");
|
return str;
|
}
|
} else {
|
auto resDB = erlangDbTool->loadFaceFeaData2(TableName);
|
if (resDB.size() > 0) {
|
string json = "[";
|
for (auto &item : resDB) {
|
string subJson = "{ ";
|
subJson.append("\"uuid\":\"" + item.second.id + "\",");
|
subJson.append("\"tableName\":\"" + TableName + "\",");
|
subJson.append("\"idcard\":\"" + item.second.idcard + "\",");
|
subJson.append("\"imgUrl\":\"" + item.second.img + "\"");
|
// subJson.append("\"feature\":\"" + item.second.feature + "\",");
|
//#todo modifysvn upda svn comm
|
// subJson.append("\"start_time\":\"" + item.second.create_time + "\",");
|
// subJson.append("\"end_time\":\"" + item.second.update_time + "\"");
|
subJson.append("},");
|
json.append(subJson);
|
}
|
auto str = json.substr(0, json.size() - 1);
|
str.append("]");
|
return str;
|
}
|
}
|
|
|
// response->write(SimpleWeb::StatusCode::server_error_not_implemented, "{\"error\":\"size is 0\"}");
|
// return "";
|
return "[]";
|
} else {
|
response->write(SimpleWeb::StatusCode::server_error_not_implemented, "{\"error\":\"传输错误，请检查！\"}");
|
return "";
|
// return "{\"error\":\"传输错误，请检查！\"}";
|
}
|
}
|
|
std::string devHttpServer_c::updateDatabase(std::string ip, unsigned int port, std::string content,
|
PResponse &response) {
|
DBG("ip:" << ip << "; port:" << port);
|
DBG("content: " << content);
|
if (erlangDbTool == nullptr) {
|
response->write(SimpleWeb::StatusCode::server_error_not_implemented, "{\"error\":\"节点不存在\"}");
|
return "";
|
return "{\"error\":\"erlang is null\"}";
|
}
|
|
Json::Reader reader;
|
Json::Value value;
|
// bool ret = false;
|
|
if (reader.parse(content, value)) {
|
std::string Uuid = value["uuid"].asString();
|
std::string TableType = value["TableType"].asString();
|
std::string TableName = value["TableName"].asString();
|
int SyncType = atoi(value["SyncType"].asCString());
|
std::string BwType = value["BwType"].asString();
|
std::string StartTime = value["StartTime"].asString();
|
std::string EndTime = value["EndTime"].asString();
|
|
bool ret = false;
|
if (SyncType == 1) {
|
//同步库
|
ret = erlangDbTool->updateDatabase(Uuid, TableType, TableName, SyncType, BwType, StartTime, EndTime);
|
} else if (SyncType == 0) {
|
//本地库
|
//#更新底库管理表
|
FieldValues fieldValues;
|
fieldValues.insert(std::make_pair("uuid", Uuid));
|
if (TableName.find("lt_") != 0) {
|
TableName.insert(0, "lt_");
|
}
|
fieldValues.insert(std::make_pair("tableName", TableName));
|
// fieldValues.insert(std::make_pair("tableDesc", "ceshi2"));
|
fieldValues.insert(std::make_pair("tableType", TableType));
|
fieldValues.insert(std::make_pair("bwType", BwType));
|
fieldValues.insert(std::make_pair("startTime", StartTime));
|
fieldValues.insert(std::make_pair("endTime", EndTime));
|
// fieldValues.insert(std::make_pair("create_by", "who"));
|
ret = m_SqliteFaceEncap.updateTable("sys_o_tables", fieldValues);
|
}
|
|
erlangDbTool->sendMessage();
|
std::string str_result = std::string("{\"result\":").append("\"" + std::to_string(ret) + "\"}");
|
return str_result;
|
} else {
|
response->write(SimpleWeb::StatusCode::server_error_not_implemented, "{\"error\":\"传输错误，请检查！\"}");
|
return "";
|
return "{\"error\":\"传输错误，请检查！\"}";
|
}
|
}
|
|
std::string devHttpServer_c::delPerson(std::string ip, unsigned int port, std::string content, PResponse &response) {
|
DBG("ip:" << ip << "; port:" << port);
|
DBG("content: " << content);
|
|
if (erlangDbTool == nullptr) {
|
response->write(SimpleWeb::StatusCode::server_error_not_implemented, "{\"error\":\"节点不存在\"}");
|
return "";
|
// return "{\"error\":\"erlang is null\"}";
|
}
|
|
Json::Reader reader;
|
Json::Value value;
|
|
if (reader.parse(content, value)) {
|
std::string TableName = value["TableName"].asString();
|
std::string strUUID = value["uuid"].asString();
|
|
bool ret = false;
|
if (TableName.find("lt_") == 0) {
|
ret = m_SqliteFaceEncap.deleteFace(TableName, strUUID);
|
} else {
|
ret = erlangDbTool->delPerson(strUUID, TableName);
|
}
|
|
erlangDbTool->sendMessage();
|
std::string str_result = std::string("{\"result\":").append("\"" + std::to_string(ret) + "\"}");
|
return str_result;
|
} else {
|
response->write(SimpleWeb::StatusCode::server_error_not_implemented, "{\"error\":\"传输错误，请检查！\"}");
|
return "";
|
// return "{\"error\":\"传输错误，请检查！\"}";
|
}
|
}
|
|
std::string devHttpServer_c::getAlarmImageFromVideoFile(std::string ip, unsigned int port, std::string content,
|
PResponse &response) {
|
DBG("ip:" << ip << "; port:" << port);
|
DBG("content: " << content);
|
Json::Reader reader;
|
Json::Value value;
|
try {
|
if (reader.parse(content, value)) {
|
std::string videoPath;
|
std::string devId = value["videoNum"].asString();
|
std::string picDate = value["picDate"].asString();
|
|
//std::string path_uuid = videoPath;//value["path_uuid"].asString();
|
qint64 sub ;
|
std::string path = getVideoPathByTime(picDate,devId,sub);
|
|
if (path.empty()) {
|
ERR("{\"error\":\"not find path\"}");
|
return "{\"error\":\"未查到视频路径\"}";
|
}
|
DBG("path="<<path);
|
videoPath.clear();
|
videoPath = path;
|
|
|
|
// sub = (dt.toMSecsSinceEpoch() - dtFile.toMSecsSinceEpoch());
|
//#yanchi buchong
|
// sub = sub > 3000 ? sub - 3000 : 0000;
|
//shijian yuejie buchang
|
// sub = sub < 0 ? 0000 : sub;
|
int haomiao = sub % 1000;
|
sub /= 1000;
|
int m = sub;
|
int shi, fen, miao;
|
char ch_time[128];
|
if (m / 3600 < 24) {
|
shi = m / 3600;
|
fen = m / 60 % 60;
|
miao = m % 60;
|
sprintf(ch_time, "%02d:%02d:%02d.%03d", shi, fen, miao, haomiao);
|
cout << ch_time << endl;
|
} else printf("输入数值太大");
|
|
std::string str_time(ch_time);
|
//#todo 按照时间命名
|
std::string str_imgName(AppUtil::getTimeString() + ".jpg");// = "test.jpg";
|
|
std::string cmd_getVideoFileTime(
|
" ffmpeg -i '" + videoPath + "' 2>&1 | grep 'Duration' | cut -d ' ' -f 4 | sed s/,//");
|
|
std::string str_tmpTime = AppUtil::getCmdResult(cmd_getVideoFileTime);
|
|
if (str_time > str_tmpTime) {
|
ERR("{\"error\":\"Time error\"}" << str_time << " str_tmpTime " << str_tmpTime);
|
str_time = str_tmpTime.size() > 0 ? str_tmpTime.substr(0, str_tmpTime.rfind(".")) : str_time;
|
// return "{\"error\":\"Time error\"}";
|
}
|
|
std::string cmd("ffmpeg -ss " + str_time + " -i '" + videoPath + "' -y '" + str_imgName + "'");
|
DBG(cmd);
|
system(cmd.c_str());
|
|
cv::Mat img = cv::imread(str_imgName);
|
if (img.empty()) {
|
ERR("{\"error\":\"Video File error\"}");
|
return "{\"error\":\"视频文件错误\"}";
|
}
|
std::vector<unsigned char> buffer;
|
CvUtil::cvMat2Buffer(img, buffer);
|
std::string img_url = "http://";
|
fdfsClient.rwLock.rdlock();
|
if (fdfsClient.fastFds != nullptr) {
|
img_url.append(fdfsClient.fastFds->getIp() + "/");
|
std::string t_strImg = "";
|
if (!fdfsClient.fastFds->uploadFile(buffer, t_strImg, "jpg")) {
|
img_url = "upload image fail";
|
} else {
|
std::string str_tmp_cmd("rm -f '" + str_imgName + "'");
|
system(str_tmp_cmd.c_str());
|
img_url.append(t_strImg);
|
img_url.clear();
|
img_url = t_strImg;
|
// img_url.append("/").append(t_strImg);
|
}
|
}
|
fdfsClient.rwLock.unlock();
|
std::string result("{\"img_url\":\"" + img_url + "\"}");
|
// cout << result << endl;
|
return result;
|
} else {
|
response->write(SimpleWeb::StatusCode::server_error_not_implemented, "{\"error\":\"传输错误，请检查！\"}");
|
return "";
|
// return "{\"error\":\"传输错误，请检查！\"}";
|
}
|
}
|
catch (std::exception ex) {
|
std::string message = "{\"error\":\"异常错误！";
|
message.append(const_cast<char *>(ex.what())).append("\"}");
|
response->write(SimpleWeb::StatusCode::server_error_not_implemented, message);
|
return "";
|
}
|
}
|
|
std::string
|
devHttpServer_c::getRecordVideoPath(std::string ip, unsigned int port, std::string content, PResponse &response) {
|
|
Json::Reader reader;
|
Json::Value value;
|
|
if (reader.parse(content, value))
|
{
|
std::string devId = value["videoNum"].asString();
|
std::string picDate = value["picDate"].asString();
|
qint64 sub;
|
std::string path=getVideoPathByTime(picDate,devId,sub);
|
if (path.empty())
|
{
|
|
return "{\"ret_status\":\"内容有误，请检查！\"}";
|
}
|
else
|
{
|
std::string result = "{\"file_path\":\"" + path + "\"}";
|
return result;
|
}
|
}
|
else
|
{
|
return "{\"ret_status\":\"传输错误，请检查！\"}";
|
}
|
}
|
|
std::string devHttpServer_c::findDevId(std::string ip, unsigned int port, std::string content, PResponse &response) {
|
|
Record_Config rc = db_c.searchConfigTableWithinServerInfo();
|
|
Json::Value value;
|
value["dev_id"] = rc.dev_id.toStdString();
|
value["dev_name"] = rc.dev_name.toStdString();
|
|
return value.toStyledString();
|
|
}
|
|
std::string devHttpServer_c::editDevName(std::string ip, unsigned int port, std::string content, PResponse &response) {
|
Json::Reader reader;
|
Json::Value value;
|
|
if (reader.parse(content, value)) {
|
std::string dev_name = value["dev_name"].asString();
|
if (dev_name.empty()) {
|
return "{\"ret_status\":\"内容有误，请检查！\"}";
|
}
|
|
if (db_c.updateDevNameConfigTable(QString::fromStdString(dev_name))) {
|
return "{\"ret_status\": \"ok_ack\"}";
|
} else {
|
return "{\"ret_status\":\"内容有误，请检查！\"}";
|
}
|
|
} else {
|
return "{\"ret_status\":\"传输错误，请检查！\"}";
|
}
|
|
}
|
|
|
std::string devHttpServer_c::editDevId(std::string ip, unsigned int port, std::string content, PResponse &response) {
|
Json::Reader reader;
|
Json::Value value;
|
|
if (reader.parse(content, value)) {
|
//DSVAD010120181114
|
int dev_batch = value["dev_batch"].asInt();
|
int dev_sequence = value["dev_sequence"].asInt();
|
if (createDevId(dev_batch, dev_sequence)) {
|
return "{\"ret_status\": \"ok_ack\"}";
|
} else {
|
return "{\"ret_status\":\"传输错误，请检查！\"}";
|
}
|
|
} else {
|
return "{\"ret_status\":\"传输错误，请检查！\"}";
|
}
|
|
}
|
|
bool devHttpServer_c::createDevId(const int &dev_batch, const int &dev_sequence) {
|
// std::string dev_id="DSVAD";
|
char buf[12] = {0};
|
char dev_id[17] = {0};
|
|
time_t cur = time(nullptr);
|
|
strftime(buf, 12, "%Y%m%d", localtime(&cur));
|
sprintf(dev_id, "%s%02d%02d%s", "DSVAD", dev_batch, dev_sequence, buf);
|
|
|
if (strlen(dev_id) != 17) {
|
return false;
|
}
|
|
appConfig.setStringProperty("DEV_ID", dev_id);
|
appConfig.save();
|
//std::cout<<dev_id<<std::endl;
|
return true;
|
}
|
|
std::string devHttpServer_c::getVideoPathByTime(const std::string& time,const std::string& camId,qint64& sub)
|
{
|
std::string t_FilePath = appConfig.getStringProperty("cutPath");
|
|
bool find=false;;
|
if (t_FilePath.back() != '/') {
|
t_FilePath.push_back('/');
|
}
|
|
QDateTime dt = QDateTime::fromString(QString::fromStdString(time), "yyyy-MM-dd hh:mm:ss:zzz");
|
|
std::string t_strTime=dt.toString("yyyyMMddhh").toStdString();
|
//# ./camIndex/YYYYMM/DD/
|
t_FilePath.append(camId + "/" + t_strTime.substr(0, 6)+ "/" +t_strTime.substr(6, 2) + "/");
|
//YYYYMMDDHH
|
t_FilePath.append(t_strTime.substr(0,10) + "/");
|
|
|
qint64 t=dt.toMSecsSinceEpoch();
|
std::vector<std::string> vec=forEachFile(t_FilePath);
|
std::sort(vec.begin(),vec.end());
|
DBG("t_FilePath" << t_FilePath);
|
DBG("vec.size()" << vec.size());
|
int size=vec.size();
|
for(int i=0;i<size;++i)
|
{
|
qint64 t1=QDateTime::fromString(QString::fromStdString(vec[i]), "yyyy-MM-dd hh:mm:ss:zzz").toMSecsSinceEpoch();
|
if(i+1<size)
|
{
|
qint64 t2=QDateTime::fromString(QString::fromStdString(vec[i+1]), "yyyy-MM-dd hh:mm:ss:zzz").toMSecsSinceEpoch();
|
if(t>=t1 && t<t2)
|
{
|
DBG("path="<<vec[i]);
|
t_FilePath+=vec[i]+".mp4";
|
sub=t-t1;
|
find=true;
|
break;
|
}
|
|
}
|
else
|
{
|
sub=t-t1;
|
if(t>=t1 && sub<=3000)
|
{
|
DBG("path="<<vec[i]);
|
t_FilePath+=vec[i]+".mp4";
|
find=true;
|
break;
|
}
|
}
|
|
|
}
|
DBG("sub="<<sub);
|
if(!find)
|
{
|
t_FilePath="";
|
}
|
return t_FilePath;
|
|
}
|
std::vector<std::string> devHttpServer_c::forEachFile(const std::string &dir_name)
|
{
|
std::vector<std::string> v;
|
auto dir = opendir(dir_name.data());
|
struct dirent *ent;
|
int len = 0;
|
if (dir) {
|
while ((ent = readdir(dir)) != NULL) {
|
std::string filename = std::string(ent->d_name);
|
std::string temp;
|
if(filename!="."&&filename!="..")
|
{
|
|
temp = filename.substr(0, filename.rfind('.'));
|
v.push_back(temp);
|
}
|
|
}
|
closedir(dir);
|
}
|
return v;
|
}
|
|
std::string devHttpServer_c::addPersons(std::string ip, unsigned int port, std::string content, PResponse &response) {
|
DBG("ip:" << ip << "; port:" << port);
|
// DBG("content: " << content);
|
if (erlangDbTool == nullptr) {
|
response->write(SimpleWeb::StatusCode::server_error_not_implemented, "{\"error\":\"节点不存在\"}");
|
return "";
|
// return "{\"error\":\"erlang is null\"}";
|
}
|
|
Json::Reader reader;
|
Json::Value value;
|
|
if (reader.parse(content, value)) {
|
string strUUID = value["uuid"].asString();
|
auto perlists = value["personList"];
|
|
std::vector<SyncDB::AddPersonInfo> tmpPers;
|
// int lsize = perlists.size();
|
for (auto &item : perlists) {
|
SyncDB::AddPersonInfo addPersonInfo;
|
addPersonInfo.personid = item["personId"].asString();
|
addPersonInfo.idcard = item["idcard"].asString();
|
addPersonInfo.personPic = item["personPic"].asString();
|
addPersonInfo.feature = item["feature"].asString();
|
tmpPers.push_back(addPersonInfo);
|
}
|
|
auto ret_addPersons = erlangDbTool->addPersons(strUUID, tmpPers);
|
|
std::string str_result;
|
if (ret_addPersons.size() > 0) {
|
str_result = "[";
|
for (auto &item : ret_addPersons) {
|
string subJson = "{ ";
|
subJson.append("\"personId\":\"" + item.PersonId + "\",");
|
subJson.append("\"result\":\"" + item.Result + "\",");
|
subJson.append("\"msg\":\"" + item.msg + "\"");
|
subJson.append("},");
|
str_result.append(subJson);
|
}
|
auto str = str_result.substr(0, str_result.size() - 1);
|
str_result.swap(str.append("]"));
|
erlangDbTool->sendMessage();
|
} else {
|
str_result = "[]";
|
}
|
return str_result;
|
} else {
|
response->write(SimpleWeb::StatusCode::server_error_not_implemented, "{\"error\":\"传输错误，请检查！\"}");
|
return "";
|
// return "{\"error\":\"传输错误，请检查！\"}";
|
}
|
}
|
|
std::string
|
devHttpServer_c::personIsExists(std::string ip, unsigned int port, std::string content, PResponse &response) {
|
DBG("ip:" << ip << "; port:" << port);
|
DBG("content: " << content);
|
if (erlangDbTool == nullptr) {
|
response->write(SimpleWeb::StatusCode::server_error_not_implemented, "{\"error\":\"节点不存在\"}");
|
return "";
|
// return "{\"error\":\"erlang is null\"}";
|
}
|
|
Json::Reader reader;
|
Json::Value value;
|
|
if (reader.parse(content, value)) {
|
std::string str_res;
|
try {
|
string strUUID = value["personId"].asString();
|
//#todo 连接失败的判断.
|
auto ret_resPerEits = erlangDbTool->personIsExistOnClu(strUUID);
|
std::string str_result = "[";
|
if (ret_resPerEits.size() > 0) {
|
for (auto &item : ret_resPerEits) {
|
// tableName ,uuid 无此人是id为null
|
if (item.uuid == "null") {
|
continue;
|
}
|
string subJson = "{ ";
|
subJson.append("\"tableName\":\"" + item.tableName + "\",");
|
subJson.append("\"uuid\":\"" + item.tableUuid + "\"");
|
subJson.append("},");
|
str_result.append(subJson);
|
}
|
auto str = str_result.substr(0, str_result.size() - 1);
|
if (str.size() <= 1) {
|
str_result = "[]";
|
} else {
|
str_result.swap(str.append("]"));
|
}
|
} else {
|
str_result = "[]";
|
}
|
if (str_result == "[]") {
|
str_res = "{\"result\":\"0\",\"msg\":\"success\",\"existDataBase\":[]}";
|
} else {
|
str_res = "{\"result\":\"1\",\"msg\":\"success\",\"existDataBase\":";
|
str_res.append(str_result).append("}");
|
}
|
} catch (std::exception ex) {
|
str_res = "{\"result\":\"-1\",\"msg\":\"error\",\"existDataBase\":[]}";
|
ERR(ex.what());
|
}
|
return str_res;
|
} else {
|
response->write(SimpleWeb::StatusCode::server_error_not_implemented, "{\"error\":\"传输错误，请检查！\"}");
|
return "";
|
// return "{\"error\":\"传输错误，请检查！\"}";
|
}
|
}
|
|
std::string
|
devHttpServer_c::updatePersonByOldId(std::string ip, unsigned int port, std::string content, PResponse &response) {
|
DBG("ip:" << ip << "; port:" << port);
|
DBG("content: " << content);
|
if (erlangDbTool == nullptr) {
|
response->write(SimpleWeb::StatusCode::server_error_not_implemented, "{\"error\":\"节点不存在\"}");
|
return "";
|
// return "{\"error\":\"erlang is null\"}";
|
}
|
|
Json::Reader reader;
|
Json::Value value;
|
|
if (reader.parse(content, value)) {
|
std::string str_res;
|
try {
|
string newPerId = value["newPerId"].asString();
|
string idcard = value["idcard"].asString();
|
string perPicUrl = value["perPicUrl"].asString();
|
string oldId = value["oldId"].asString();
|
string perFea = value["feature"].asString();
|
//#todo 连接失败的判断.
|
auto ret_resUpdPersRet = erlangDbTool->singlePersonUpdate(newPerId, oldId, idcard, perPicUrl, perFea);
|
std::string str_result = "[";
|
int notexist_conNum = 0;
|
if (ret_resUpdPersRet.size() > 0) {
|
for (auto &item : ret_resUpdPersRet) {
|
// tableName ,uuid 无此人是id为null
|
if (item.result == "true") {
|
continue;
|
}
|
if (item.result == "notexist") {
|
notexist_conNum++;
|
continue;
|
}
|
|
string subJson = "{ ";
|
subJson.append("\"tableName\":\"" + item.tableName + "\",");
|
subJson.append("\"uuid\":\"" + item.tableUuid + "\"");
|
subJson.append("},");
|
str_result.append(subJson);
|
}
|
auto str = str_result.substr(0, str_result.size() - 1);
|
if (str.size() <= 1) {
|
str_result = "[]";
|
} else {
|
str_result.swap(str.append("]"));
|
}
|
} else {
|
str_result = "error";
|
}
|
if (str_result == "[]") {
|
if (notexist_conNum == ret_resUpdPersRet.size()) {
|
str_res = "{\"result\":\"0\",\"msg\":\"success\",\"existDataBase\":[]}";
|
} else {
|
str_res = "{\"result\":\"1\",\"msg\":\"success\",\"existDataBase\":[]}";
|
}
|
} else if (str_result == "error") {
|
str_res = "{\"result\":\"-1\",\"msg\":\"error\",\"existDataBase\":[]}";
|
} else {
|
str_res = "{\"result\":\"-1\",\"msg\":\"success\",\"existDataBase\":";
|
str_res.append(str_result).append("}");
|
}
|
} catch (std::exception ex) {
|
str_res = "{\"result\":\"-1\",\"msg\":\"error\",\"existDataBase\":[]}";
|
ERR(ex.what());
|
}
|
return str_res;
|
} else {
|
response->write(SimpleWeb::StatusCode::server_error_not_implemented, "{\"error\":\"传输错误，请检查！\"}");
|
return "";
|
// return "{\"error\":\"传输错误，请检查！\"}";
|
}
|
}
|
