#include "EncodeVideoManager.h"
#include "NewRecordVideoElement.h"
#include <basic/util/app/AppConfig.h>
#include <qdatetime.h>

EncodeVideoManager::EncodeVideoManager():
TimerElement(10*1000)
{
   // m_hiredisTool.delKey("")
    int thread_num=appConfig.getIntProperty("encode_thread_num");

    for(int i=0;i<thread_num;++i)
    {
         EncodeVideo* newEncodeViedo=new EncodeVideo();
         if(newEncodeViedo)
         {

               m_newEncodeVideoVec.push_back(newEncodeViedo);
               newEncodeViedo->start();
         }

    }

}
EncodeVideoManager::~EncodeVideoManager()
{
    for(int i=0;i<m_newEncodeVideoVec.size();++i)
    {
        if(m_newEncodeVideoVec[i])
        {
            m_newEncodeVideoVec[i]->stop();
            delete m_newEncodeVideoVec[i];
            m_newEncodeVideoVec[i]=nullptr;
        }
    }
    m_newEncodeVideoVec.clear();

}
void EncodeVideoManager::timerFunc()
{
        //    std::string tmp="camId="+m_camId+"videoCaptureElement";
            //ClockTimer cl("timerFunc");
   std::map<std::string,int> fileMap=m_hiredisTool.findAllFileStatus();
//   auto it=fileMap.begin();
   for(auto it=fileMap.begin();it!=fileMap.end();it++)
   {
       if(it->second == RECORD_ENDING)
       {

           for(int i=0;i<m_newEncodeVideoVec.size();++i)
           {
               if(m_newEncodeVideoVec[i] && !m_newEncodeVideoVec[i]->isBusy())
               {
                  m_hiredisTool.hashSet(file_list,it->first,RECORD_STOP);
                  m_newEncodeVideoVec[i]->setProperty("src_path",it->first);
                  m_newEncodeVideoVec[i]->submit();
                  break;
               }
           }


       }
       else
       {
           //----/home/basic/work/qiaojia/cut/DS-2CD2T46WDA2-I20180622AACHC30488278/201901/22/2019012210/2019-01-22 10:32:38:171.mp4

           std::string file_name=it->first;
           int begin=file_name.find_last_of("/")+1;
           int end= file_name.find(".mp4");
           std::string file_time=file_name.substr(begin,end-begin);
           QDateTime dt = QDateTime::fromString(QString::fromStdString(file_time), "yyyy-MM-dd hh:mm:ss:zzz");
           if( (AppUtil::getCurrentUs()-dt.toMSecsSinceEpoch())>5*60*1000*1000)
           {
               DBG(file_name<<">5*60*1000*1000");
               m_hiredisTool.hashSet(file_list,file_name,RECORD_ENDING);
           }

       }
   }
}