#include "../DB/LDBTool.h"
|
#include <basic/debug/Debug.h>
|
#include "loadManage.h"
|
#include <QDateTime>
|
#include <QString>
|
#include <QVector>
|
|
|
loadFileManage::loadFileManage(LDBTool *dbTool) : TaskManage(dbTool) {
|
init();
|
}
|
|
loadFileManage::~loadFileManage() {
|
|
}
|
|
void loadFileManage::init(void) {
|
//search all loadfile_info where finish_flag = 0
|
m_list = db_c->searchLoadFileTableAll();
|
}
|
|
|
#define Record_Cam_Chn2pChannelLoadFileManage(RCC, RESULT) \
|
{\
|
RESULT.strDevID = RCC.str_storage_dev_id.toStdString();\
|
RESULT.nChannelID = RCC.n_chn;\
|
RESULT.startTime.Year = RCC.tim_do_time.date().year();\
|
RESULT.startTime.Month = RCC.tim_do_time.date().month();\
|
RESULT.startTime.Day = RCC.tim_do_time.date().day();\
|
RESULT.startTime.Hour = RCC.tim_do_time.time().hour();\
|
RESULT.startTime.Minute = RCC.tim_do_time.time().minute();\
|
RESULT.startTime.Second = RCC.tim_do_time.time().second();\
|
nDuration = db_c->searchDurationByDeviceId(RCC.str_storage_dev_id);\
|
/*endTime = RCC.tim_do_time.addSecs(nDuration * 3600);//nDuration 1格为0.5小时*/\
|
endTime = RCC.tim_do_time.addSecs(nDuration * 1800);\
|
RESULT.endTime.Year = endTime.date().year();\
|
RESULT.endTime.Month = endTime.date().month();\
|
RESULT.endTime.Day = endTime.date().day();\
|
RESULT.endTime.Hour = endTime.time().hour();\
|
RESULT.endTime.Minute = endTime.time().minute();\
|
RESULT.endTime.Second = endTime.time().second();\
|
}
|
|
ChannelLoadFileManage loadFileManage::getTask(void) {
|
ChannelLoadFileManage result;
|
|
QDateTime endTime;
|
int nDuration;
|
|
if (m_list.size() > 0) {
|
Record_Load_File_info rec = *m_list.begin();
|
m_list.pop_front();
|
Record_Cam_Chn2pChannelLoadFileManage(rec, result);
|
} else {
|
//get task from cam_chn_table
|
Record_Cam_Chn rec = db_c->searchOldestRecordfromChnTableByUpdateTime();
|
if (rec.n_id == 0 || rec.tim_do_time.secsTo(QDateTime::currentDateTime()) <= nDuration * 1800) {
|
DBG("searchOldestRecordfromChnTableByUpdateTime NULL"
|
<< rec.tim_do_time.secsTo(QDateTime::currentDateTime())
|
<< rec.tim_do_time.toString("yyyy-MM-dd hh:mm:ss").toStdString());
|
return result;
|
}
|
//#todo search nDuration from deviceTable where rec.str_storage_dev_id
|
|
Record_Cam_Chn2pChannelLoadFileManage(rec, result);
|
|
Record_Load_File_info loadFileRec{0, rec.str_storage_dev_id, rec.n_chn, rec.tim_do_time, false, "",
|
QDateTime::currentDateTime(), ""};
|
|
//修改更新时间和处理时间
|
rec.tim_update_time = QDateTime::currentDateTime();
|
rec.tim_do_time = endTime;
|
|
if (rec.str_storage_dev_id.size() <= 0) {
|
ERR(" " << rec.str_storage_dev_id.toStdString());
|
}
|
|
//insert rec to loadfile_info && update cam_chn
|
bool ret = db_c->insertLoadFileTableAndUpdateChannelTable(loadFileRec, rec);
|
if (!ret) return ChannelLoadFileManage();
|
|
}
|
return result;
|
}
|
|
|
bool loadFileManage::finishTask(const pChannelLoadFileManage finishInfo) {
|
//TODO
|
//根据设备id/通道号/开始时间找到该条记录，然后更新，将该条记录的标志置1,添加path
|
//update db
|
char charStr[256] = {0};
|
sprintf(charStr, "%4d-%02d-%02d %02d:%02d:%02d", finishInfo->startTime.Year, finishInfo->startTime.Month,
|
finishInfo->startTime.Day, finishInfo->startTime.Hour, finishInfo->startTime.Minute,
|
finishInfo->startTime.Second);
|
QString strBuffer = QString(charStr);
|
|
QDateTime time = QDateTime::fromString(strBuffer, "yyyy-MM-dd hh:mm:ss");
|
|
Record_Load_File_info loadFileRec{0, QString::fromStdString(finishInfo->strDevID), finishInfo->nChannelID,
|
time, true, QString::fromStdString(finishInfo->srcPath),
|
QDateTime::currentDateTime(), ""};
|
db_c->updateLoadFileTable(loadFileRec);
|
return true;
|
}
|
