#ifndef APPPIPECONTROLLER_H
|
#define APPPIPECONTROLLER_H
|
|
#include <basic/pipe/PipeController.h>
|
#include <basic/pipe_element/ffmpeg/FfmpegElement.h>
|
#include <basic/pipe_element/ImageShowElement.h>
|
#include <basic/util/curl/HttpRequestWithCrul.hpp>
|
#include "ImageDrawElement.h"
|
#include "FaceRpcElement.h"
|
#include "FaceExtractElement.h"
|
#include "YoloRpcElement.h"
|
#include "RecordVideoElement.h"
|
#include <TriggerElement.h>
|
#include <QtCore/QDateTime>
|
#include "PerimeterElement.h"
|
#include "JudgmentRetrogradeTool.h"
|
#include "NewRecordVideoElement.h"
|
#include <jsoncpp/json/json.h>
|
|
|
class AppPipeController : public PipeController {
|
public:
|
/***
|
* 用于快速视频结构化
|
* @param folderPath 任务根目录，用于做共享内存id
|
* @param json 参数为rtsp流地址 sdk是否启用的标识
|
*/
|
AppPipeController(std::string folderPath, const Json::Value &json);
|
|
AppPipeController(int index, const Json::Value &json, bool RecordVideoEnable = false);
|
|
AppPipeController(std::string camId, const Json::Value &json, bool RecordVideoEnable);
|
|
virtual ~AppPipeController();
|
|
bool resetVideoCapturePath(std::string path);
|
|
bool getRunning();
|
|
std::string getRtmp();
|
|
void setfdfsClient(FastFdsWithLock *p_fdfsClient);
|
|
private:
|
void init();
|
|
private://Perimete
|
PerimeterElement perimeterElement;
|
// TriggerElement peTriggerElement;
|
|
void initPerimeter();
|
|
private://Crowd
|
PerimeterElement crowdElement;
|
//TriggerElement crowdTriggerElement;
|
|
void initCrowd();
|
|
private://KeepRight
|
JudgmentRetrogradeTool leftJudgment;
|
JudgmentRetrogradeTool rightJudgment;
|
|
// TriggerElement leftTriggerElement;
|
// TriggerElement rightTriggerElement;
|
|
void intKeepRight();
|
|
private:
|
ffmpeg::VideoCaptureElement videoCaptureElement;
|
YoloRpcElement yoloRpcElement;
|
FaceRpcElement faceRpcElement;
|
FaceExtractElement faceExtractElement;
|
ImageDrawElement imageDrawElement;
|
RecordVideoElement recordVideoElement;
|
NewRecordVideoElement newRecordVideoElement;
|
|
int m_index;
|
std::string m_camId;
|
std::string m_folderPath;
|
Json::Value m_json;
|
Json::Value m_json_Record;
|
|
Json::FastWriter m_fastWriter;
|
FastFdsWithLock *fdfsClient;
|
|
bool bRecordVideoEnable;
|
std::map<std::string, bool> recordRetMap;
|
|
TriggerElement triggerElement;
|
std::atomic<bool> bUp;
|
|
QDateTime m_dt;
|
|
std::string getFullFileName();
|
|
|
void recordInit(int videoMin, int videoMax);
|
void setSdkTrigger();
|
void doRecord();
|
int fileMin;
|
int fileMax;
|
bool sdkTrigger;
|
int triggerDelay;
|
|
#define RECORD_STOP (0)
|
#define RECORD_DOING (1)
|
#define RECORD_ENDING (2)
|
|
int recordStatus;
|
int videoLength;
|
int recordDelay;
|
|
|
};
|
|
#endif // APPPIPECONTROLLER_H
|
