From dccc8c41c31866785fdaf5cba40354cdc7afbd8f Mon Sep 17 00:00:00 2001 From: miyanhui <dennismi1024@gmail.com> Date: 星期三, 13 二月 2019 14:28:37 +0800 Subject: [PATCH] videoAnalysisFromHC崩溃日志增加 --- QiaoJiaSystem/StructureApp/AppPipeController.cpp | 62 +++++++++++++++++++++++++++++-- 1 files changed, 58 insertions(+), 4 deletions(-) diff --git a/QiaoJiaSystem/StructureApp/AppPipeController.cpp b/QiaoJiaSystem/StructureApp/AppPipeController.cpp index 18c22b4..d13a670 100644 --- a/QiaoJiaSystem/StructureApp/AppPipeController.cpp +++ b/QiaoJiaSystem/StructureApp/AppPipeController.cpp @@ -177,6 +177,56 @@ string test_str; + +void AppPipeController::RecordVideo() { + std::string imgKeyYolo = yoloRpcElement.getProperty("imgKey"); + + std::string imgKeyFace = faceRpcElement.getProperty("imgKey"); + if(faceRpcElement.getTriggerState() || + personElement.getTriggerState() || + leftJudgment.getTriggerState() || + rightJudgment.getTriggerState() || + perimeterElement.getTriggerState() || + crowdElement.getTriggerState() || + perHubElement.getTriggerState() || + perStaticElement.getTriggerState()) + { + try { + auto server = rpcClient.getServer(); + if (!server) + { + ERR("server is null"); + return; + } + + if(imgKeyFace != imgKeyYolo) + { + server->recordVideo(imgKeyFace); + server->recordVideo(imgKeyYolo); + INFO("Record Video Face: "<<imgKeyFace); + INFO("Record Video Yolo: "<<imgKeyYolo); + } else { + INFO("Record Video: "<<imgKeyYolo); + server->recordVideo(imgKeyFace); + } + } + catch (std::exception &e) + { + ERR("Record Video ImgKeyFace: "<<imgKeyFace <<" ImgKeyYolo :"<<imgKeyYolo <<" Message: "<<e.what()); + return ; + } + } + else { + INFO("faceRpcElement: "<< faceRpcElement.getTriggerState() <<" "<< + "personElement: "<<personElement.getTriggerState() <<" "<< + "leftJudgment: "<<leftJudgment.getTriggerState() <<" "<< + "leftJudgment: "<<rightJudgment.getTriggerState() <<" "<< + "perimeterElement: "<<perimeterElement.getTriggerState()<<" "<< + "crowdElement: "<<crowdElement.getTriggerState()<<" "<< + "perHubElement: "<<perHubElement.getTriggerState()<<" "<< + "perStaticElement: "<<perStaticElement.getTriggerState()); + } +} void AppPipeController::init() { unsigned char ip_old[15] = {0}; @@ -209,7 +259,7 @@ m_hiredisTool.listRpop(m_camId,imgKey); if(imgKey.empty()) { - ERR("imgKey.empty() "<<imgKey); + ERR("CamId "<<m_camId<<" No ImgKey"); return; } @@ -226,7 +276,7 @@ m_hiredisTool.delKey(imgKey); if(imageTemp.empty()) { - ERR("No Image Data In: "<<imgKey); + ERR("No Image Data In: "<<m_camId<<" ImgKey:"<<imgKey); return; } std::string strNewTime = AppUtil::getTimeUSecString(); @@ -258,7 +308,7 @@ imageDrawElement.submit(); } - if(faceRpcElement.getTriggerState() || + /*if(faceRpcElement.getTriggerState() || personElement.getTriggerState() || leftJudgment.getTriggerState() || rightJudgment.getTriggerState() || @@ -292,7 +342,7 @@ "crowdElement: "<<crowdElement.getTriggerState()<<" "<< "perHubElement: "<<perHubElement.getTriggerState()<<" "<< "perStaticElement: "<<perStaticElement.getTriggerState()); - } + }*/ } }); @@ -303,10 +353,14 @@ personElement.setObjsResults(yoloRpcElement.getLastScoreRects()); personElement.submit(); } + INFO("Record Video By Yolo"); + this->RecordVideo(); }); faceRpcElement.registerConnector([&] { imageDrawElement.setFaces(faceRpcElement.getLastScoreRects()); + INFO("Record Video By Face"); + this->RecordVideo(); }); yoloRpcElement.registerConnector("YoloTrigger", [&] { -- Gitblit v1.8.0