GB28181集成完成。录像bug暂未解决，已注释

pansen

2019-03-07 979bc003bce710bf300bc2bd87a8278585678763

 QiaoJiaSystem/VideoToImageMulth/RtspCaptureElement.h

@@ -5,62 +5,71 @@
#include <opencv2/opencv.hpp>
#include "../StructureApp/HiredisTool.h"
#include <atomic>

class RtspAnalysManager;

struct CvCapture_FFMPEG;

    /**
     * 使用ffmpeg封装的视频采集流水元素
     * 输入，rtsp地址或文件（mp4或avi）路径，输出opencv中的cv::Mat
     * 支持GPU硬解码
     * 主要完成视频帧的获取以及向CvCapture_FFMPEG传送数据
     */
    class RtspCaptureElement: public TimerElement {
    public:
        RtspCaptureElement(const std::string& path,const std::string& camId, int fps = 30, int reOpenTime = -1, int gpuIndex = -1,RtspAnalysManager* manager= nullptr);
        //保存视频接口,从RtspAnalysManager发起调用
        void SaveVideo(const std::string& strImageName);
/**
 * 使用ffmpeg封装的视频采集流水元素
 * 输入，rtsp地址或文件（mp4或avi）路径，输出opencv中的cv::Mat
 * 支持GPU硬解码
 * 主要完成视频帧的获取以及向CvCapture_FFMPEG传送数据
 */
class RtspCaptureElement : public TimerElement {
public:
    RtspCaptureElement(const std::string &path, const std::string &camId, int fps = 30, int reOpenTime = -1,
                       int gpuIndex = -1, RtspAnalysManager *manager = nullptr);

        //设置保存视频的最小和最大长度,单位是秒,实际的运行情况有一些差距，需要完善
        void SetVideoMinMaxSeconds(const int minSeconds,const int maxSeconds);
    private:
        //线程执行函数
        virtual void timerFunc() override;
        //线程的一些变量初始化,线程启动的时候调用
        virtual void threadInitial() override;
        //线程结束函数的时候调用,完成一些资源的释放
        virtual void threadClosing() override;
        //打开视频
        void openVideo();
    //保存视频接口,从RtspAnalysManager发起调用
    void SaveVideo(const std::string &strImageName);

        //根据timeStamp创建路径
        std::string MakeDir(const std::string& timeStamp);
    private:
        //用来抓取视频的Ffmpeg的封装类
        CvCapture_FFMPEG* m_capture;
        //保存视频流的路径,类似于rtsp://admin:a1234567@192.168.1.201:554/h264/ch2/main/av_stream
        std::string m_path;
    //设置保存视频的最小和最大长度,单位是秒,实际的运行情况有一些差距，需要完善
    void SetVideoMinMaxSeconds(const int minSeconds, const int maxSeconds);

        // Redis的工具类
private:
    //线程执行函数
    virtual void timerFunc() override;

    //线程的一些变量初始化,线程启动的时候调用
    virtual void threadInitial() override;

    //线程结束函数的时候调用,完成一些资源的释放
    virtual void threadClosing() override;

    //打开视频
    void openVideo();

    //根据timeStamp创建路径
    std::string MakeDir(const std::string &timeStamp);

private:
    //用来抓取视频的Ffmpeg的封装类
    CvCapture_FFMPEG *m_capture;
    //保存视频流的路径,类似于rtsp://admin:a1234567@192.168.1.201:554/h264/ch2/main/av_stream
    std::string m_path;

    // Redis的工具类
//        HiredisTool m_redisTool;

        //对保存到Redis的图片进行计数
        std::atomic<int> m_picCount{0};
        //GPU的索引
        int m_gpuIndex;
    //对保存到Redis的图片进行计数
    std::atomic<int> m_picCount{0};
    //GPU的索引
    int m_gpuIndex;

        //打开视频流失败的时候，sleep一段时间
        int m_reopenTime;
    //打开视频流失败的时候，sleep一段时间
    int m_reopenTime;

        //摄像机ID
        std::string m_camId;
    //摄像机ID
    std::string m_camId;

        //用来保存录像视频的路径
        std::string m_cutPath;
    //用来保存录像视频的路径
    std::string m_cutPath;

        //几张图丢一张,目前是8张丢一张
        const int m_nPicsPickOne = 8;
    //几张图丢一张,目前是8张丢一张
    const int m_nPicsPickOne = 8;

        RtspAnalysManager * m_pManager;
    };
    RtspAnalysManager *m_pManager;
};

#endif // VIDEOCAPTUREELEMENT_H