| | |
| | | |
| | | 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}; |
| | |
| | | imageDrawElement.submit(); |
| | | } |
| | | |
| | | if(faceRpcElement.getTriggerState() || |
| | | /*if(faceRpcElement.getTriggerState() || |
| | | personElement.getTriggerState() || |
| | | leftJudgment.getTriggerState() || |
| | | rightJudgment.getTriggerState() || |
| | |
| | | "crowdElement: "<<crowdElement.getTriggerState()<<" "<< |
| | | "perHubElement: "<<perHubElement.getTriggerState()<<" "<< |
| | | "perStaticElement: "<<perStaticElement.getTriggerState()); |
| | | } |
| | | }*/ |
| | | } |
| | | }); |
| | | |
| | |
| | | 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", [&] { |