SecurePlay/SecurePlayAuxServer/Application/FuncBase.cpp

#include "FuncBase.h"

#include "GlobalVariable.h"
#include "GlobalConfig.h"
#include "FromRedis.h"
#include "FromWebAPI.h"

FuncBase::FuncBase()
{
    m_fromRedis = std::make_shared<FromRedis>();
    m_fromWebAPI = std::make_shared<FromWebAPI>();
}

FuncBase::~FuncBase()
{
    if(m_fromRedis != nullptr)
    {
        m_fromRedis.reset();
        m_fromRedis = nullptr;
    }
    if(m_fromWebAPI != nullptr)
    {
        m_fromWebAPI.reset();
        m_fromWebAPI = nullptr;
    }
    if(m_logger != nullptr)
    {
        m_logger.reset();
        m_logger = nullptr;
    }
}

/* 任务线程 */
void FuncBase::thread_task()
{
    /* 先做一些通用的初始化 */
    if(m_logger == nullptr)
    {
        m_logger = spdlog::get("SPAServer");
        if(m_logger == nullptr)
        {
            SPDLOG_ERROR("SPAServer logger is nullptr");
            return;
        }
    }
    /* 线程功能信息 */
    if(m_funcThreadInfo.appFunction == AppFunction::APP_NONE)
    {
        SPDLOG_LOGGER_ERROR(m_logger, "未设置线程功能信息");
        return;
    }
    SPDLOG_LOGGER_INFO(m_logger, "开启频道: [{}:{}] {}功能线程", m_funcThreadInfo.ChannelID, m_funcThreadInfo.strChannelName, m_funcThreadInfo.strFunctionName);
    for(auto& room : m_funcThreadInfo.listRoomCamActInfo)
    {
        for(auto& cam : room.mapCameraAction)
        {
            for(auto& act : cam.second)
            {
                SPDLOG_LOGGER_DEBUG(m_logger, "房间ID: {}, 摄像机ID: {}, 算法ID: {}", room.RoomID, cam.first, act);
            }
        }
    }
    /* 设置线程运行状态 */
    m_bRunning = true;
    /* 执行线程功能，会一直阻塞，直到退出 */
    // task();
    /* 设置线程退出的状态，设置成 RUN_STATE_EXITCOMPLET ,就会被管理线程回收 */
    GThreadInfo.setThreadState(m_funcThreadInfo, RunTimeState::RUN_STATE_EXITCOMPLET);
    SPDLOG_LOGGER_INFO(m_logger, "{} 功能线程退出，Channel:{}", m_funcThreadInfo.strFunctionName, m_funcThreadInfo.ChannelID);
    m_bRunning = false;
}

/* 设置功能信息 */
void FuncBase::setFuncThreadInfo(FuncThreadInfo* pFuncAct)
{
    m_funcThreadInfo = *pFuncAct;
}
void FuncBase::setFuncThreadInfo(FuncThreadInfo& FuncAct)
{
    m_funcThreadInfo = FuncAct;
}

/* 获取该实例的功能 */
AppFunction FuncBase::getApp()
{
    return m_funcThreadInfo.appFunction;
}

/* 获取线程运行状态 */
bool FuncBase::getThreadRunning() const
{
    return m_bRunning;
}


/* 判断是否在检测时间内 */
bool FuncBase::isInDetectTime(const QDateTime& start, const QDateTime& end)
{
    QDateTime now = QDateTime::currentDateTime();
    if(start.isValid() && end.isValid())
    {
        if(now >= start && now <= end)
        {
            return true;
        }
    }
    return false;
}