#include "NewEncodeVideo.h"

NewEncodeVideo::NewEncodeVideo():
videoEncoderElement(cv::Size(1920, 1080), 8, 0)
{

}
NewEncodeVideo::~NewEncodeVideo()
{

}

void NewEncodeVideo::threadFunc()
{

    std::string src_path=getProperty("src_path");
    if(src_path.empty())
    {
        return ;
    }
    int size=m_hiredisTool.getSize(src_path);
  //  DBG("buf_size="<<size<<"  file_name="<<src_path);
    bool fileCreate = false;
    for(int i=0;i<size;++i)
    {
        cv::Mat img;
        m_hiredisTool.getImage(src_path,img);
        if(img.empty())
         continue;
        if(!fileCreate)
        {
            fileCreate = true;
            DBG("fileCreate buf_size="<<size<<"  file_name="<<src_path);
             videoEncoderElement.threadInitial(getProperty("src_path"),img);

        }
        else
        {
            videoEncoderElement.doFunc(img);
        }
         usleep(2*1000);
    }
 //    bool isOpen=false;
//    while(!m_imgQue.empty())
//    {
//        if(!isOpen)
//        {
//           videoEncoderElement.threadInitial(getProperty("src_path"),m_imgQue.back());
//           isOpen=true;
//        }
//        else
//        {
//              videoEncoderElement.doFunc(m_imgQue.back());

//        }
//        m_imgQue.pop();
//    }
    videoEncoderElement.threadClosing();
    m_hiredisTool.delKey(src_path);
    m_hiredisTool.hashDel(file_list,src_path);
}