166 lines
4.1 KiB
C++
166 lines
4.1 KiB
C++
#include "capturethread.h"
|
|
|
|
#if _MSC_VER >= 1600
|
|
#pragma execution_character_set("utf-8")
|
|
#endif
|
|
|
|
CaptureThread::CaptureThread(QString url, MicasenseConfig conf): conf(conf)
|
|
{
|
|
cli = new MyClient(url.toStdString(), 80);
|
|
cli->set_timeout_sec(12);
|
|
cli->set_keep_alive_max_count(10);
|
|
cli->set_read_timeout(20, 20);
|
|
for(int i = 0; i < 6; i++) sync_flags[i] = true;//下载完成标志
|
|
}
|
|
|
|
CaptureThread::~CaptureThread()
|
|
{
|
|
emit Log(now() + "\t已停止捕获线程");
|
|
delete cli;
|
|
}
|
|
|
|
void CaptureThread::SafeQuit()
|
|
{
|
|
mutex.lock();
|
|
this->quit();
|
|
mutex.unlock();
|
|
}
|
|
|
|
QString CaptureThread::now()
|
|
{
|
|
QDateTime current_date_time = QDateTime::currentDateTime();
|
|
return current_date_time.toString("yyyyMMdd-HHmmss");
|
|
}
|
|
|
|
void CaptureThread::capture()//给命令曝光
|
|
{
|
|
|
|
mutex.lock();
|
|
QString CMD = "/capture?&block=true&cache_raw="+QString::number(conf.cache_raw)+"&store_capture" + conf.store_capture
|
|
+ "&preview" + conf.preview + "&anti_sat" + conf.anti_sat;
|
|
|
|
QtJson::JsonObject rejson;
|
|
|
|
try
|
|
{
|
|
auto res = cli->Mget(CMD);
|
|
rejson = cli->Parser(res->body);
|
|
}
|
|
catch(MyException error)
|
|
{
|
|
emit Log(error.what());
|
|
mutex.unlock();
|
|
return;
|
|
}
|
|
|
|
if(rejson["status"] != "complete")
|
|
{
|
|
throw MyException("Capture not finished ", 800);
|
|
return;
|
|
}
|
|
|
|
QList<QString> keys = rejson["raw_cache_path"].toMap().keys();
|
|
datetime = QDateTime::currentDateTime();
|
|
|
|
for(QString key : keys)
|
|
{
|
|
QString name = rejson["raw_cache_path"].toMap()[key].toString();
|
|
|
|
sync_flags[key.toInt()] = false;//下载未完成
|
|
|
|
emit this->AddDownloadTask(name, key, datetime.toString("yyyy_MM_dd_hh_mm_ss_zzz"));
|
|
}
|
|
mutex.unlock();
|
|
}
|
|
|
|
void CaptureThread::TimerCaptureSlot()
|
|
{
|
|
timer->stop();
|
|
|
|
while(!(sync_flags[0] && sync_flags[1] && sync_flags[2] && sync_flags[3] && sync_flags[4]&& sync_flags[5]))
|
|
{
|
|
DelayBusy(100);
|
|
}
|
|
//阻塞 当本次任务中所有通道都下载结束退出阻塞 均为true 阻塞过程中停止定时器。
|
|
capture();
|
|
timer->start();
|
|
|
|
}
|
|
|
|
void CaptureThread::run()
|
|
{
|
|
//qDebug() << "Run " <<"threadID : "<<QThread::currentThread();
|
|
QtJson::setPrettySerialize(true);
|
|
if(conf.mode == 1)
|
|
{
|
|
try
|
|
{
|
|
capture();
|
|
}
|
|
catch(MyException error)
|
|
{
|
|
emit Log(error.what());
|
|
}
|
|
}
|
|
else if(conf.mode == 2)
|
|
{
|
|
timer = new QTimer();
|
|
timer->stop();
|
|
timer->setInterval(conf.interval);
|
|
connect(timer, &QTimer::timeout, [ = ]
|
|
{
|
|
TimerCaptureSlot();
|
|
});
|
|
TimerCaptureSlot();//立即执行一次
|
|
emit Log(now() + "\tMicaSense Start TimerCapture, invterval=" + QString::number(conf.interval));
|
|
|
|
timer->start();
|
|
this->exec();
|
|
}
|
|
else if(conf.mode == 3)//信号触发模式 你MicaSense开发他么是猪么？ 信号触发直接从HTTP给？
|
|
{
|
|
connect(this, &CaptureThread::QSignalEmit, [ = ]
|
|
{
|
|
|
|
try
|
|
{
|
|
while(!(sync_flags[0] && sync_flags[1] && sync_flags[2] && sync_flags[3] && sync_flags[4]&& sync_flags[5]))
|
|
{
|
|
DelayBusy(100);
|
|
}
|
|
//阻塞 当本次任务中所有通道都下载结束退出阻塞 均为true 阻塞过程中停止定时器。
|
|
capture();
|
|
}
|
|
catch(MyException error)
|
|
{
|
|
emit Log(error.what());
|
|
}
|
|
|
|
});
|
|
emit Log(now() + "\tMicaSense Start QSignalMode, Wait For Signal..." );
|
|
this->exec();
|
|
}
|
|
}
|
|
|
|
void CaptureThread::QSignalEmited()
|
|
{
|
|
emit QSignalEmit();
|
|
}
|
|
|
|
void CaptureThread::GetStatues()
|
|
{
|
|
auto res = cli->Mget("/status");
|
|
QtJson::JsonObject rejson = cli->Parser(res->body);
|
|
QString sta = QtJson::serialize(rejson);
|
|
emit SendStatues(sta);
|
|
}
|
|
|
|
void CaptureThread::DelayBusy(int msec)//阻塞延时
|
|
{
|
|
QTime n=QTime::currentTime();
|
|
QTime now;
|
|
do{
|
|
now=QTime::currentTime();
|
|
}while (n.msecsTo(now)<=msec);
|
|
}
|