From c8e6fb13202d18e3c1ada38578d2a5cc3c184198 Mon Sep 17 00:00:00 2001 From: miyanhui <dennismi1024@gmail.com> Date: 星期一, 18 二月 2019 17:15:45 +0800 Subject: [PATCH] VideoToImageMulth和VideoAnalyFromHC支持RPC的端口设置 --- QiaoJiaSystem/DataManagerServer/http_configserver.cpp | 377 ++++++++++++++++++++++++++++++++++++++++++++++------- 1 files changed, 324 insertions(+), 53 deletions(-) diff --git a/QiaoJiaSystem/DataManagerServer/http_configserver.cpp b/QiaoJiaSystem/DataManagerServer/http_configserver.cpp index 67e82a4..c9f86a9 100644 --- a/QiaoJiaSystem/DataManagerServer/http_configserver.cpp +++ b/QiaoJiaSystem/DataManagerServer/http_configserver.cpp @@ -21,7 +21,7 @@ //#include "HcRecord.h" #include <time.h> #include <dirent.h> - +#include "basic/pipe_element/ffmpeg/basic_struct_for_video_image.h" using namespace std; devHttpServer_c::devHttpServer_c() @@ -65,10 +65,12 @@ 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); + DBG("DevID: "<<strDevId<<" Batch: "<<m_batch <<" SerNum: "<<m_SerialNumber); fdfsClient.rwLock.wrlock(); fdfsClient.fastFds = new FastFds("WebFDSClient.conf"); @@ -395,6 +397,7 @@ /*sdk login*/ ulRet = IMOS_MW_Login(username, passwd, ip, 0, szUserID); if (ERR_COMMON_SUCCEED != ulRet) { + (VOID) IMOS_MW_Cleanup(); printf("Login error ulRet[%lu]", ulRet); return false; } @@ -402,6 +405,8 @@ 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) { + (VOID) IMOS_MW_Logout(szUserID); + (VOID) IMOS_MW_Cleanup(); printf("GetDeviceStatus Error[%lu]\n", ulRet); return false; } @@ -1048,7 +1053,7 @@ { if(is_exist) { - return "{\"ret_status\": \"鍐呭鏈夎锛岃妫�鏌ワ紒\"}"; + return "{\"ret_status\": \"璇峰嬁閲嶅娣诲姞!\"}"; } else { @@ -1087,13 +1092,14 @@ 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(); -// } + 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(); @@ -2044,10 +2050,44 @@ std::string img_base64 = value["img_base64"].asString(); std::string idcard = value["idcard"].asString(); std::string strUUID = value["uuid"].asString(); +// if (strUUID.size() > 0) { +// bool ret_addPerson = false; +// if (TableName.find("lt_") == 0) { +// FieldValues fieldValues; +// AddFaceData addFaceData; +// //#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 { +// ret_addPerson = erlangDbTool->addPerson(strUUID, TableName, feature_base64, img_url, idcard); +// } +// } cv::Mat image; if (img_url.size() > 0) { + + if (img_url.find("ManCarAnaly") != string::npos && img_url.find("group") != string::npos) { + auto pos = img_url.find("group"); + auto img_tmp = img_url.substr(pos); + std::string img_str = "http://"; + if (fdfsClient.fastFds != nullptr) { + img_str.append(fdfsClient.fastFds->getIp() + "/").append(img_tmp); + img_url.swap(img_str); + } + } else { + std::string img_str = "http://"; + if (fdfsClient.fastFds != nullptr) { + img_str.append(fdfsClient.fastFds->getIp() + "/").append(img_url); + img_url.swap(img_str); + } + } + auto t_results = m_curlDownloadImg.download_jpeg(const_cast<char *>(img_url.c_str())); + DBG(img_url << "t_results size is " << t_results.all << " : " << t_results.buffer.size()); cvutil.buffer2CvMat(t_results.buffer, image); } else if (img_base64.size() > 0) { auto str_img = base64.Decode(img_base64.c_str(), img_base64.size()); @@ -2074,9 +2114,10 @@ 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); + system("mkdir -p img"); + string str_path = "./img/"; + str_path.append(AppUtil::getTimeString() + ".jpg"); + cv::imwrite(str_path, image); return ""; // return "{\"error\":\"not found face\"}"; } else if (faceResults.size() > 1) { @@ -2111,7 +2152,6 @@ } } fdfsClient.rwLock.unlock(); - } auto size = feature_base64.size(); // std::string uuid = ""; @@ -2367,21 +2407,15 @@ } } -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(); +std::string devHttpServer_c::getAlarmImageByPicDateAndDevId(const std::string& picDate,const std::string& devId, + PResponse &response) { + try { + if(!devId.empty() && !picDate.empty()) + { + std::string videoPath; qint64 sub; - std::string path = getVideoPathByTime(picDate, devId, sub); + std::string path = getVideoPathByPicDate(picDate, devId, sub); if (path.empty()) { ERR("{\"error\":\"not find path\"}"); @@ -2421,26 +2455,26 @@ std::string str_tmpTime = AppUtil::getCmdResult(cmd_getVideoFileTime); - if (str_time > str_tmpTime) { //str_time = str_tmpTime.size() > 0 ? str_tmpTime : str_time; - qint64 v_time=getVideoTime(str_tmpTime)-1000; - int haomiao = (v_time % 1000) > 50 ? ((v_time % 1000) - 50) : 0; - v_time /= 1000; - int m = v_time; - 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.%02d", shi, fen, miao, haomiao / 10); + qint64 v_time = getVideoTime(str_tmpTime) - 1000; + int haomiao = (v_time % 1000) > 50 ? ((v_time % 1000) - 50) : 0; + v_time /= 1000; + int m = v_time; + 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.%02d", shi, fen, miao, haomiao / 10); - } else printf("杈撳叆鏁板�煎お澶�"); + } else printf("杈撳叆鏁板�煎お澶�"); - str_time=ch_time; - ERR("{\"error\":\"Time error\"}" << str_time << " str_tmpTime " << str_tmpTime<<" ch_time="<<ch_time); + str_time = ch_time; + ERR("{\"error\":\"Time error\"}" << str_time << " str_tmpTime " << str_tmpTime << " ch_time=" + << ch_time); // return "{\"error\":\"Time error\"}"; } @@ -2473,12 +2507,10 @@ } 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) { @@ -2489,28 +2521,162 @@ } } + + +std::string devHttpServer_c::getAlarmImageFromVideoFile(std::string ip, unsigned int port, std::string content, + PResponse &response) { + INFO("ip:" << ip << "; port:" << port << "content: " << content); + Json::Reader reader; + Json::Value value; + try { + if (reader.parse(content, value)) { + std::string devId = value["videoNum"].asString(); + std::string picDate = value["picDate"].asString(); + std::string imgKey = value["imgKey"].asString(); + //鍏煎鏃х増鏈� + if(imgKey=="undefined" || imgKey.empty()) + { + return getAlarmImageByPicDateAndDevId(picDate,devId,response); + } + else + { + return getAlarmImageByImageKeyAndDevId(imgKey,devId,response); + } + } + else{ + response->write(SimpleWeb::StatusCode::server_error_not_implemented, "{\"error\":\"浼犺緭閿欒锛岃妫�鏌ワ紒\"}"); + ERR("ImageURL:浼犺緭閿欒锛岃妫�鏌�"); + return ""; + } + } + 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); + ERR("ImageURL:寮傚父閿欒 "<<ex.what()); + return ""; + } +} + + + +std::string devHttpServer_c::getAlarmImageByImageKeyAndDevId(const std::string& imgKey,const std::string& devId, + PResponse &response) { + try { + if (!devId.empty() && !imgKey.empty()) { + std::string videoPath; + std::string path = getVideoPathByImgKey(imgKey, devId); + if (path.empty()) { + ERR("Not Find Path: "<<path); + return "{\"error\":\"鏈煡鍒拌棰戣矾寰刓"}"; + } + videoPath.clear(); + videoPath = path; + + VideoName_s_t videoSt = VideoName_s_t::fromString(path); + ImageName_s_t imgSt = ImageName_s_t::fromString(imgKey); + + //#todo 鎸夌収鏃堕棿鍛藉悕 + std::string str_imgName(AppUtil::getTimeString() + ".jpg");// = "test.jpg"; + + auto frameIdDiff = imgSt.m_frameId-videoSt.m_startFrameId; + char selectExpBuff[32]={0}; + std::string strSelectTemplate=R"#( -vf "select=eq(n\,%d)")#"; + sprintf(selectExpBuff,strSelectTemplate.c_str(),frameIdDiff-1); + if(videoSt.Valid() && imgSt.Valid() ) { + std::string cmd("ffmpeg -i '" + videoPath+"'"+std::string(selectExpBuff)+" -vframes 1" +" -y '" + str_imgName + "'"); + INFO("Video To Image Cmd: "<<cmd); + system(cmd.c_str()); + } + else { + ERR("Parse Video and Image Failed Path: "<<path <<" ImageId: "<<imgKey); + return "{\"error\":\"鏈煡鍒拌棰戣矾寰刓"}"; + } + + 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) { + std::string t_strImg = ""; + if (!fdfsClient.fastFds->uploadFile(buffer, t_strImg, "jpg")) { + img_url = "upload image fail"; + ERR("Upload Image Failed "<<str_imgName); + } 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; + } + } + fdfsClient.rwLock.unlock(); + std::string result("{\"img_url\":\"" + img_url + "\"}"); + INFO("ImageURL:"<<img_url); + return result; + } else { + response->write(SimpleWeb::StatusCode::server_error_not_implemented, "{\"error\":\"浼犺緭閿欒锛岃妫�鏌ワ紒\"}"); + ERR("ImageURL:浼犺緭閿欒锛岃妫�鏌�"); + return ""; + } + } + 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); + ERR("ImageURL:寮傚父閿欒 "<<ex.what()); + return ""; + } +} + + std::string devHttpServer_c::getRecordVideoPath(std::string ip, unsigned int port, std::string content, PResponse &response) { Json::Reader reader; Json::Value value; + INFO("REQ From: "<<ip<<":"<<port<<" Content:"<<content); 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()) { + std::string imgKey = value["imgKey"].asString(); + std::string path; - return "{\"ret_status\":\"鍐呭鏈夎锛岃妫�鏌ワ紒\"}"; + //鍏煎鏃х増鏈� + if(imgKey=="undefined"||imgKey.empty()) + { + qint64 sub; + path = getVideoPathByPicDate(picDate,devId,sub); + } + else + { + path = getVideoPathByImgKey(imgKey,devId); + } + //std::string path = getVideoPathByImgKey(imgKey, devId, sub); + ERR("VideoNum: "<<devId <<" PicDate: "<<picDate<<" imgKey: "<<imgKey); + if (path.empty()) { + std::string strRsp = "{\"ret_status\":\"鍐呭鏈夎锛岃妫�鏌ワ紒\"}"; + ERR("RSP:"<< strRsp); + return strRsp; } else { std::string result = "{\"file_path\":\"" + path + "\"}"; + INFO("RSP:"<<result); return result; } } else { - return "{\"ret_status\":\"浼犺緭閿欒锛岃妫�鏌ワ紒\"}"; + std::string strRsp="{\"ret_status\":\"浼犺緭閿欒锛岃妫�鏌ワ紒\"}"; + ERR("RSP:"<< strRsp); + return strRsp; } } + std::string devHttpServer_c::findDevId(std::string ip, unsigned int port, std::string content, PResponse &response) { @@ -2588,7 +2754,8 @@ return true; } -std::string devHttpServer_c::getVideoPathByTime(const std::string &time, const std::string &camId, qint64 &sub) { + +std::string devHttpServer_c::getVideoPathByPicDate(const std::string &time, const std::string &camId, qint64 &sub) { std::string t_FilePath = appConfig.getStringProperty("cutPath"); bool find = false; @@ -2648,7 +2815,74 @@ } -qint64 devHttpServer_c::getVideoTime(/*const std::string &videoPath,*/std::string& str_tmpTime) { + +std::string devHttpServer_c::GetVideoNameByImgKey(const std::string& imgKey,const std::string& strPath) { + static std::mutex g_mutex; + std::lock_guard<std::mutex> lock(g_mutex); + std::vector<std::string> vec = forEachFileByImgKey(strPath); + ImageName_s_t imgSt = ImageName_s_t::fromString(imgKey); + if(!imgSt.Valid()) + { + ERR("ParseImageName Failed : "<<imgKey); + return ""; + } + std::vector<VideoName_s_t> videoStVec; + for (const auto &item : vec) { + auto videoParseResult = VideoName_s_t::fromString(item); + if (videoParseResult.Valid()) { + if (videoParseResult.m_startFrameId <= imgSt.m_frameId && + imgSt.m_frameId <= videoParseResult.m_endFrameId) { + auto imgTm = AppUtil::ParseFromHypenTimeStr(imgSt.m_timeStamp); + auto videoTm = AppUtil::ParseFromHypenTimeStr(videoParseResult.m_timeStamp); + if (AppUtil::IsRightAfterLeft(imgTm, videoTm)) { + videoStVec.emplace_back(videoParseResult); + INFO("Image " << imgKey << " Video: " << item << " Match"); + } else { + ERR("Image " << imgKey << " Video: " << item << " Not Match"); + } + } else{ + ERR("ImageID: "<<imgSt.m_frameId <<" VideoRange: "<<videoParseResult.m_startFrameId<<" , "<<videoParseResult.m_endFrameId); + } + + } else { + ERR("VideoName : " << item << " Parse Failed"); + } + } + + if (videoStVec.size() >= 1) { + std::string strVideoName = strPath + videoStVec[0].ToVideoName(); + INFO("ImageName: "<<imgKey<<" SingleMatchVideo: "<<strVideoName); + return strVideoName; + } else { + ERR("ImageName: "<<imgKey<<" MatchVideoCount: "<<videoStVec.size()); + for(auto& item:vec) + { + ERR("VideoName: "<<item); + } + return ""; + } +} + +//鏂扮殑鏍规嵁鍥剧墖鍚嶇О鑾峰彇璺緞鐨勬柟娉� +std::string devHttpServer_c::getVideoPathByImgKey(const std::string &imgKey, const std::string &camId) +{ + INFO("GetVideoFor: "<<imgKey<<" CamID:"<<camId); + ImageName_s_t imgSt= ImageName_s_t::fromString(imgKey); + + struct tm imgTime = AppUtil::ParseFromHypenTimeStr(imgSt.m_timeStamp); + char curFolder[128]={0}; + // 201901/26/2019012614 ---- 201901/26/2019012615 {骞存湀}/{鏃/{骞存湀鏃ユ椂}/ + sprintf(curFolder,"%04d%02d/%02d/%04d%02d%02d%02d/",imgTime.tm_year+1900,imgTime.tm_mon+1, + imgTime.tm_mday, + imgTime.tm_year+1900,imgTime.tm_mon+1,imgTime.tm_mday,imgTime.tm_hour); + std::string t_FilePath = appConfig.getStringProperty("cutPath"); + std::string videoPath = t_FilePath+"/"+camId+"/"+std::string(curFolder); + return GetVideoNameByImgKey(imgKey,videoPath); +} + + + +qint64 devHttpServer_c::getVideoTime(/*const std::string &videoPath,*/std::string &str_tmpTime) { // std::string cmd_getVideoFileTime( // " ffmpeg -i '" + videoPath + "' 2>&1 | grep 'Duration' | cut -d ' ' -f 4 | sed s/,//"); @@ -2672,6 +2906,7 @@ return len_ms; } +//鑾峰彇鏌愪釜鐩綍涓嬬殑鎵�鏈夋枃浠讹紝涓嶅甫鎵╁睍鍚� std::vector<std::string> devHttpServer_c::forEachFile(const std::string &dir_name) { std::vector<std::string> v; auto dir = opendir(dir_name.data()); @@ -2685,6 +2920,26 @@ temp = filename.substr(0, filename.rfind('.')); v.push_back(temp); + } + + } + closedir(dir); + } + return v; +} + +//鑾峰彇鏌愪釜鐩綍涓嬬殑鎵�鏈夋枃浠讹紝甯︽墿灞曞悕 +std::vector<std::string> devHttpServer_c::forEachFileByImgKey(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 != "..") { + v.push_back(filename); } } @@ -3014,16 +3269,31 @@ std::string pass = value["str_password"].asString(); std::string brand = value["str_brand"].asString(); std::string rtsp_url = rtspAddrBuild(ip, port, username, pass, brand); - if (rtsp_url.empty()) { + if (rtsp_url.empty() ) + { return "{\"ret_status\":\"鍐呭鏈夎锛岃妫�鏌ワ紒\"}"; } +// unsigned char serialnumber[SERIALNO_LEN] = {0}; +// int ret = getDevSerialNumber(ip.c_str(), port,username.c_str(),pass.c_str(),brand.c_str(),serialnumber); + + +// if ((!ret) || (serialnumber[0] == 0)) +// { +// return "{\"ret_status\": \"鍐呭鏈夎锛岃妫�鏌ワ紒\"}"; +// } + +// std::string str_cam_dev_id = std::string((char *) serialnumber);//鎽勫儚鏈篿d cam_mac + std::string str_imgName = appConfig.getStringProperty("cutPath"); if (str_imgName.back() != '/') { str_imgName.push_back('/'); } + str_imgName +=ip; + str_imgName +="-"; str_imgName += "snapshot.jpg"; //admin:a1234567@192.168.1.201:554/h264/ch1/main/av_stream -r 1/25 -f image2 -s 1920*1080 /home/basic/work_src/a.jpg - std::string cmd("ffmpeg -i " + rtsp_url + " -r 1/25 -f image2 -s 1920*1080 -y " + str_imgName); + std::string cmd("ffmpeg -i " + rtsp_url + " -vf select='eq(pict_type\\,I)',setpts='N/(25*TB)' -f image2 -s 1920*1080 -y " + str_imgName); +// std::string cmd("ffmpeg -i " + rtsp_url + " -r 1/25 -f image2 -s 1920*1080 -y " + str_imgName); DBG(cmd); system(cmd.c_str()); @@ -3040,13 +3310,14 @@ CvUtil::cvMat2Buffer(img, buffer); std::string strImgUrlTmp = ""; fdfsClient.fastFds->uploadFile(buffer, strImgUrlTmp, "jpg"); - strImgUrl.append(fdfsClient.fastFds->getIp() + "/" + strImgUrlTmp); + // strImgUrl.append(fdfsClient.fastFds->getIp() + "/" + strImgUrlTmp); strImgUrl.clear(); strImgUrl = strImgUrlTmp; } fdfsClient.rwLock.unlock(); Json::Value result; result["imgUrl"] = strImgUrl; + db_c.updateCamDevSnapshot(QString::fromStdString(ip),QString::fromStdString(strImgUrl)); return result.toStyledString(); -- Gitblit v1.8.0