SecurePlay/SecurePlayAuxServer/Application/FuncBase.cpp

#include "FuncBase.h"

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

FuncBase::FuncBase()
{
    m_fromRedis = std::make_shared<FromRedis>();
    m_toEQMDataBase = std::make_shared<ToEQMDataBase>();
}

FuncBase::~FuncBase()
{

}

/* 任务线程 */
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_funcAct.appFunction == AppFunction::APP_NONE)
    {
        SPDLOG_LOGGER_ERROR(m_logger, "未设置线程功能信息");
        return;
    }
    SPDLOG_LOGGER_INFO(m_logger, "开启 {} 功能线程, ChannelID:{}",m_funcAct.strFunctionName, m_funcAct.ChannelID);
    /* 设置线程运行状态 */
    m_bRunning = true;
    /* 执行线程功能，会一直阻塞，直到退出 */
    task();
    /* 设置线程退出的状态，设置成 RUN_STATE_EXITCOMPLET ,就会被管理线程回收 */
    GThreadInfo.setThreadState(m_funcAct, RunTimeState::RUN_STATE_EXITCOMPLET);
    SPDLOG_LOGGER_INFO(m_logger, "{} 功能线程退出，Channel:{}", m_funcAct.strFunctionName, m_funcAct.ChannelID);
    m_bRunning = false;
}

/* 设置功能信息 */
void FuncBase::setFuncActionInfo(FuncActionInfo* pFuncAct)
{
    m_funcAct = *pFuncAct;
}
void FuncBase::setFuncActionInfo(FuncActionInfo& FuncAct)
{
    m_funcAct = FuncAct;
}

/* 获取该实例的功能 */
AppFunction FuncBase::getApp()
{
    return m_funcAct.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;
}